origin.py 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203
  1. #!/usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. """
  4. demeter web page
  5. name:origin.py
  6. author:rabin
  7. """
  8. from __load__ import *
  9. #import qrcode
  10. from datetime import *
  11. import os
  12. import short_url
  13. import uuid
  14. import random
  15. class Code(object):
  16. @staticmethod
  17. def get(self, value):
  18. cdate = Demeter.date(value['cdate'], '%Y%m%d%H%M%S')
  19. #number = Demeter.compressUuid(value['id']).upper()
  20. min = 1000
  21. max = 9999
  22. number = 'XN' + str(value['farm_id'] + 10000) + '-' + str(value['cdate']) + str(random.randint(min, max))
  23. info = self.service('common').one('origin_batch', number=number)
  24. if info and info['id'] != value['id']:
  25. return Code.get(self, value)
  26. #url = Demeter.config['front']['qrcode'] + self.data['setting']['web'] + 'origin/view?qrcode=' + self.data['list'][key]['number']
  27. update = {}
  28. update['number'] = number
  29. state = self.service('common').update('origin_batch', value['id'], update)
  30. return number
  31. class index_path(Load):
  32. @Web.auth
  33. def get(self):
  34. mobile = Demeter.checkMobile(self.request)
  35. if mobile:
  36. self.redirect('/device')
  37. return
  38. self.data['list'] = self.service('common').list('origin_batch', search={'farm_id':self.data['setting']['farm']})
  39. if self.data['list']:
  40. for key, value in enumerate(self.data['list']):
  41. self.data['list'][key]['cdates'] = Demeter.date(value['cdate'], '%Y%m%d')
  42. self.data['list'][key]['zzdates'] = Demeter.date(value['zzdate'], '%Y-%m-%d')
  43. self.data['list'][key]['csdates'] = Demeter.date(value['csdate'], '%Y-%m-%d')
  44. product = self.service('common').one('farm_product', id=value['product_id'])
  45. if product:
  46. self.data['list'][key]['product'] = product['name']
  47. else:
  48. self.data['list'][key]['product'] = ''
  49. if not value['number']:
  50. self.data['list'][key]['number'] = Code.get(self, value)
  51. value['number'] = self.data['list'][key]['number']
  52. self.data['list'][key]['url'] = '/origin/view?id=' + value['id']
  53. self.view("origin/index.html")
  54. class view_path(Load):
  55. @Web.auth
  56. def get(self):
  57. id = self.input('id')
  58. self.data['info'] = self.service('common').one('origin_batch', id=id)
  59. self.data['url'] = self.data['setting']['web'] + 'origin?id=' + id + '&code=' + self.data['info']['number']
  60. self.data['qrcode'] = Demeter.config['front']['qrcode'] + self.data['url']
  61. self.view("origin/view.html")
  62. class update_path(Load):
  63. @Web.auth
  64. def get(self):
  65. id = self.input('id')
  66. copy_id = self.input('copy_id')
  67. if copy_id:
  68. id = copy_id
  69. self.data['product'] = self.service('common').list('farm_product', search={'status':True,'farm_id':self.data['setting']['farm']})
  70. self.data['land'] = self.service('common').list('farm_work_land', search={'farm_id':self.data['setting']['farm']})
  71. self.data['gateway'] = self.service('common').list('device_gateway', search={'farm_id':self.data['setting']['farm']})
  72. self.data['device'] = Device.getByGateway(self, search={'hardware_type' : 2,'farm_id':self.data['setting']['farm']})
  73. self.data['camera'] = self.service('common').list('device_info', search={'hardware_type': 6,'farm_id':self.data['setting']['farm']})
  74. self.data['info'] = {}
  75. self.data['growth'] = []
  76. if id:
  77. self.data['growth'] = self.service('common').list('origin_growth', search={'batch_id': id})
  78. if self.data['growth']:
  79. for key, value in enumerate(self.data['growth']):
  80. self.data['growth'][key]['date'] = Demeter.date(value['date'], '%Y-%m-%d')
  81. self.data['info'] = self.service('common').one('origin_batch', id=id)
  82. if self.data['info']:
  83. self.data['info']['zzdate'] = Demeter.date(self.data['info']['zzdate'], '%Y-%m-%d')
  84. self.data['info']['csdate'] = Demeter.date(self.data['info']['csdate'], '%Y-%m-%d')
  85. if copy_id:
  86. self.data['info']['id'] = None
  87. self.view("origin/update.html")
  88. @Web.auth
  89. def post(self):
  90. id = self.input('id')
  91. update = {}
  92. update['devices'] = self.inputs('update_devices')
  93. update['amount'] = self.input('update_amount')
  94. update['product_id'] = self.input('update_product_id')
  95. update['device_camera_id'] = self.input('update_device_camera_id')
  96. update['land_id'] = self.input('update_land_id')
  97. update['name'] = self.input('update_name')
  98. update['zzdate'] = self.input('update_zzdate')
  99. update['csdate'] = self.input('update_csdate')
  100. growth = {}
  101. growth['name'] = self.inputs('update_growth_name')
  102. growth['date'] = self.inputs('update_growth_date')
  103. growth['pic'] = self.inputs('update_growth_pic')
  104. growth['id'] = self.inputs('update_growth_id')
  105. if not update['name']:
  106. self.out(u'请输入批次名称')
  107. return
  108. if not update['product_id']:
  109. self.out(u'请选择产品')
  110. return
  111. if not update['land_id']:
  112. self.out(u'请选择地块')
  113. return
  114. if not update['devices']:
  115. self.out(u'请选择设备')
  116. return
  117. if not update['device_camera_id']:
  118. self.out(u'请选择摄像头')
  119. return
  120. if not update['zzdate'] or not update['csdate']:
  121. self.out(u'请选择生长周期')
  122. return
  123. if not growth['name'] or not growth['date'] or not growth['pic']:
  124. self.out(u'请添加生长阶段')
  125. return
  126. if not update['amount']:
  127. self.out(u'请输入本批产量')
  128. return
  129. update['devices'] = str(update['devices'])
  130. state = self.service('common').update('origin_batch', id, update)
  131. if state:
  132. model = Demeter.model('origin_growth')
  133. model.batch_id = state
  134. model.delete()
  135. for key,value in enumerate(growth['name']):
  136. if value and growth['date'][key]:
  137. gid = growth['id'][key]
  138. gupdate = {}
  139. gupdate['name'] = value
  140. gupdate['date'] = growth['date'][key]
  141. gupdate['pic'] = growth['pic'][key]
  142. gupdate['batch_id'] = state
  143. self.service('common').update('origin_growth', gid, gupdate)
  144. self.out('yes', {'state':state})
  145. @Web.auth
  146. def delete(self):
  147. id = self.input('id')
  148. if not id:
  149. self.out('no')
  150. return
  151. state = self.input('state', False)
  152. state = self.service('common').delete('origin_batch', id, state)
  153. self.out('yes', {'state':state})
  154. class printer_path(Load):
  155. @Web.auth
  156. def get(self):
  157. id = self.input('id')
  158. table_id = self.input('table_id');
  159. self.data['info'] = {}
  160. self.data['printer'] = self.service('common').list('device_printer', search={'farm_id':self.data['setting']['farm']})
  161. self.data['table_id'] = table_id
  162. if id:
  163. self.data['info'] = self.service('common').one('device_printer_log', id=id)
  164. self.view("origin/printer.html")
  165. @Web.auth
  166. def post(self):
  167. id = self.input('id')
  168. update = {}
  169. update['printer_id'] = self.input('update_printer_id')
  170. update['num'] = self.input('update_num')
  171. if not update['printer_id']:
  172. self.out(u'请选择打印机')
  173. return
  174. if not update['num']:
  175. self.out(u'请输入张数')
  176. return
  177. update['uid'] = self.data['setting']['userInfo']['id']
  178. update['table_name'] = 'origin_batch'
  179. update['table_id'] = self.input('update_table_id')
  180. if not update['table_id']:
  181. self.out(u'错误的来源')
  182. return
  183. info = self.service('common').one(update['table_name'], id=update['table_id'])
  184. update['content'] = '打印' + info['name'] + '溯源码:' + str(update['num']) + '张'
  185. state = self.service('common').update('device_printer_log', id, update)
  186. self.out('已发送至打印机队列')