main.py 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160
  1. # -*- coding: utf-8 -*-
  2. """
  3. demeter web page
  4. name:work.py
  5. author:rabin
  6. """
  7. from .__load__ import *
  8. class Common(object):
  9. @staticmethod
  10. def signature(self):
  11. key = self.input('key')
  12. nonce = self.input('nonce')
  13. signature = self.input('signature')
  14. file = self.input('file')
  15. if not key:
  16. self.out('参数错误:key')
  17. if not nonce:
  18. self.out('参数错误:nonce')
  19. if not signature:
  20. self.out('参数错误:signature')
  21. if not file:
  22. self.out('参数错误:file')
  23. site = Demeter.model('site')
  24. site.key = key
  25. self.data['site'] = site.select(type='fetchone')
  26. if not self.data['site']:
  27. self.out('站点信息不存在')
  28. key = key + '&' + self.data['site']['token'] + '&' + nonce + '&' + file
  29. key = Demeter.md5(key)
  30. if key != signature:
  31. self.out('验证失败')
  32. # 请求转换 /main/convert 接口必须后端获取,token不允许暴露
  33. class convert_path(Load):
  34. @Web.setting
  35. def get(self):
  36. file = self.input('file')
  37. self.data = {}
  38. Common.signature(self)
  39. service = Demeter.service('convert')
  40. file = service.update(self.data['site']['id'], self.data['site']['key'], file)
  41. if not file:
  42. self.out('未生成文件信息')
  43. # 推入到redis队列
  44. if file['status'] == 1:
  45. redis = Demeter.redis()
  46. config = Demeter.config['redis']
  47. redis.rpush(config['name'], file['id'])
  48. del self.data['site']['token']
  49. url = self.request.protocol + "://" + self.request.host
  50. self.data['file'] = {
  51. 'id' : file['id'],
  52. 'status' : file['status'],
  53. 'url' : url + file['url'],
  54. 'ext' : file['ext'],
  55. 'name' : file['name'],
  56. 'key' : file['key']
  57. }
  58. self.out('yes', self.data)
  59. # 获取信息 后端接口,token不允许暴露
  60. class get_path(Load):
  61. @Web.setting
  62. def get(self):
  63. file = self.input('file')
  64. self.data = {}
  65. Common.signature(self)
  66. service = Demeter.service('convert')
  67. file = service.get(self.data['site']['id'], self.data['site']['key'], file);
  68. if not file:
  69. self.out('未生成文件信息')
  70. del self.data['site']['token']
  71. url = self.request.protocol + "://" + self.request.host
  72. self.data['file'] = {
  73. 'id' : file['id'],
  74. 'status' : file['status'],
  75. 'url' : url + file['url'],
  76. 'page' : file['page'],
  77. 'ext' : file['ext'],
  78. 'name' : file['name'],
  79. 'key' : file['key']
  80. }
  81. self.out('yes', self.data)
  82. # 授权用户可以访问html的接口 后端接口,token不允许暴露 后续实现
  83. class auth_path(Load):
  84. @Web.setting
  85. def get(self):
  86. key = int(self.input('site', 1))
  87. user = self.input('user')
  88. token = self.input('token')
  89. file = self.input('file')
  90. site = Demeter.model('site')
  91. site.key = key
  92. data = {}
  93. data['site'] = site.select(type='fetchone')
  94. if not file:
  95. self.out('错误的文件信息')
  96. if not data['site']:
  97. self.out('站点信息不存在')
  98. if data['site']['token'] != token:
  99. self.out('验证失败')
  100. service = Demeter.service('convert')
  101. data['file'] = service.get(data['site']['id'], key, file);
  102. # 授权之后生成一个key,用于前端权限验证
  103. self.out('yes', data)
  104. # 读取html 带有权限控制 该接口为前端接口 需要有授权接口 后续实现
  105. class view_path(Load):
  106. @Web.setting
  107. def get(self):
  108. key = int(self.input('site', 1))
  109. token = self.input('token')
  110. file = self.input('file')
  111. site = Demeter.model('site')
  112. site.key = key
  113. data = {}
  114. data['site'] = site.select(type='fetchone')
  115. if not file:
  116. self.out('错误的文件信息')
  117. if not data['site']:
  118. self.out('站点信息不存在')
  119. if data['site']['token'] != token:
  120. self.out('验证失败')
  121. service = Demeter.service('convert')
  122. data['file'] = service.get(data['site']['id'], key, file);
  123. self.out('yes', data)