views.py 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998
  1. # -*- coding: utf-8 -*-
  2. # !/usr/bin/env python
  3. import datetime
  4. import hashlib
  5. import logging
  6. import re
  7. import ssl
  8. import subprocess
  9. import time
  10. import urllib2
  11. import simplejson as json
  12. import xmltodict
  13. from django.http import HttpResponse, JsonResponse, HttpResponseBadRequest
  14. from django.views.generic.base import View
  15. from pymongo.results import UpdateResult
  16. from typing import TYPE_CHECKING, Iterable, Dict
  17. from voluptuous import MultipleInvalid
  18. from apilib.monetary import RMB
  19. from apilib.utils import generate_RSA_key_pairs
  20. from apilib.utils_datetime import to_datetime
  21. from apilib.utils_string import cn
  22. from apps import serviceCache
  23. from apps.web import district
  24. from apps.web.ad.models import Advertisement, AdStatistics
  25. from apps.web.agent.models import MoniApp
  26. from apps.web.common.models import AddressType, WithdrawRecord, WithdrawBanks, WithdrawDistrict, \
  27. WithdrawBranchBanks, WithdrawBankCard
  28. from apps.web.common.models import FrontendLog, FAQ
  29. from apps.web.common.transaction.pay.alipay import AliPayWithdrawNotifier
  30. from apps.web.common.utils import WechatMessage, WechatText, WechatMenu, WechatSubscribe, WechatUnSubscribe, \
  31. WechatScanEvent, MessageHandler
  32. from apps.web.constant import Const, AppPlatformType, AdSpace, USER_RECHARGE_TYPE
  33. from apps.web.core import ROLE
  34. from apps.web.core.exceptions import InvalidFileSize, InvalidFileName
  35. from apps.web.core.file import AliOssFileUploader, WechatSubscriptionAccountVerifyFileUploader
  36. from apps.web.core.models import WechatPayApp, AliApp
  37. from apps.web.core.utils import DefaultJsonErrorResponse, JsonOkResponse, JsonErrorResponse
  38. from apps.web.dealer.models import Dealer
  39. from apps.web.device.models import Device
  40. from apps.web.device.timescale import PowerManager
  41. from apps.web.user.models import MoniUser, AskRobot
  42. from apps.web.user.models import MyUser
  43. from apps.web.user.utils import get_consume_order
  44. from apps.web.utils import error_tolerate, permission_required, concat_dealer_main_page_url, \
  45. concat_front_end_url, concat_user_center_url, concat_user_login_entry_url
  46. from apps.web.validation import SaveWithdrawBankCardSchema, SaveWithdrawAlipaySchema, SaveWithdrawWechatSchema
  47. from library.misc import BankAPI
  48. if TYPE_CHECKING:
  49. from apps.web.core.db import RoleBaseDocument
  50. from django.core.handlers.wsgi import WSGIRequest
  51. from apps.web.device.models import DeviceDict
  52. from apps.web.core.adapter.bolai_gateway import ChargingGatewayBox
  53. from apps.web.core.payment.ali import AliPayGateway
  54. logger = logging.getLogger(__name__)
  55. @permission_required(ROLE.dealer, ROLE.agent, ROLE.supermanager)
  56. def loadDistrictData(request):
  57. return JsonResponse({'result': 1, 'description': None, 'payload': district.DISTRICT})
  58. @error_tolerate(nil = lambda: JsonResponse({'result': 0, 'description': u'系统错误'}), logger = logger)
  59. def logFrontend(request):
  60. """
  61. 收集来自前端的日志
  62. :param request:
  63. :return:
  64. """
  65. if not request.body:
  66. return JsonResponse({'result': 1, 'description': u'BODY为空'})
  67. payload = json.loads(request.body)
  68. if 'onlyLog' in payload and payload['onlyLog']:
  69. logger.debug('--[BLUETOOTH]onlyLog--' + str(payload) + '--eof onlyLog--')
  70. else:
  71. FrontendLog(**payload).save()
  72. return JsonResponse({'result': 1, 'description': u'记录成功'})
  73. def getFAQ(request):
  74. """
  75. 使用的常见说明
  76. :param request:
  77. :return:
  78. """
  79. current_user = request.user # type: RoleBaseDocument
  80. faqs = FAQ.get_by_role(current_user.role)
  81. return JsonResponse({
  82. "result": 1,
  83. "description": None,
  84. "payload": {'dataList': [faq.to_dict() for faq in faqs], 'total': len(faqs)}
  85. })
  86. def getNotifications(request):
  87. """
  88. 做一个临时的用户通知 如果可以使用京东引流 就通知经销商
  89. :param request:
  90. :return:
  91. """
  92. return JsonResponse(
  93. {
  94. "result": 1,
  95. "description": None,
  96. "payload": {
  97. "total": 0,
  98. "dataList": []
  99. }
  100. }
  101. )
  102. # @trace_call()
  103. # def wx_biz_dispatch(request):
  104. # def response_xml(payload):
  105. # xmlData = dicttoxml.dicttoxml(payload, attr_type = False, custom_root = 'xml', cdata = True)
  106. # return HttpResponse(xmlData)
  107. #
  108. # logger.info('has receive wechat dispatch message')
  109. #
  110. # def check_signature(signature, timestamp, nonce, token):
  111. # args = [token, timestamp, nonce]
  112. # args.sort()
  113. # return hashlib.sha1(''.join(args).encode('utf-8')).hexdigest() == signature
  114. #
  115. # if request.method == 'GET':
  116. # signature = request.GET['signature']
  117. # timestamp = request.GET['timestamp']
  118. # nonce = request.GET['nonce']
  119. # echostr = request.GET['echostr']
  120. # if check_signature(signature, timestamp, nonce, settings.MY_WECHAT_USER_TOKEN):
  121. # return HttpResponse(str(echostr))
  122. # else:
  123. # return HttpResponse('')
  124. # else:
  125. # replyData = event_reply(request)
  126. # logger.info('calc replaydata = %s' % replyData)
  127. # if replyData:
  128. # return response_xml(replyData)
  129. #
  130. # return HttpResponse('success')
  131. @error_tolerate(nil = lambda: JsonResponse({'result': 0, 'description': u'文件操作有误'}), logger = logger)
  132. @permission_required(ROLE.dealer, ROLE.manager, ROLE.myuser, ROLE.advertiser, ROLE.supermanager, ROLE.subaccount)
  133. def uploadFile(request):
  134. """
  135. 公共的文件上传接口
  136. TODO 需要注意安全选项!!
  137. ..added 2018/03/21 添加参数判断安全路径
  138. :param request:
  139. :return:
  140. """
  141. UPLOADER_MAP = {
  142. 'wechatValidate': WechatSubscriptionAccountVerifyFileUploader,
  143. 'public': AliOssFileUploader
  144. }
  145. Uploader = UPLOADER_MAP.get(request.GET.get('category', 'public'))
  146. uploader = Uploader(inputFile = request.FILES.getlist('file')[0], uploadType = request.GET.get('type', 'others'))
  147. logger.info('[upload] %s is being used' % (repr(uploader),))
  148. try:
  149. outputUrl = uploader.upload()
  150. return JsonResponse({'result': 1, 'description': '', 'payload': outputUrl})
  151. except InvalidFileSize, e:
  152. logger.info(
  153. '%s(id=%s)\'s uploaded file reached limit' % (request.user.__class__.__name__, str(request.user.id),))
  154. return JsonResponse({'result': 0, 'description': e.message, 'payload': {}})
  155. except InvalidFileName, e:
  156. logger.info(
  157. '%s(id=%s)\'s uploaded file name is not legal' % (request.user.__class__.__name__, str(request.user.id),))
  158. return JsonResponse({'result': 0, 'description': e.message, 'payload': {}})
  159. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  160. @permission_required(ROLE.manager, ROLE.advertisement, ROLE.advertiser, ROLE.dealer, ROLE.agent, ROLE.subaccount)
  161. def getAddressType(request):
  162. # type: (WSGIRequest)->JsonResponse
  163. """
  164. 获取地址类型
  165. :param request:
  166. :return:
  167. """
  168. addressTypes = AddressType.objects.all().order_by('-showWeight') # type: Iterable[AddressType]
  169. dataList = [{'value': addressType.value, 'label': addressType.label} for addressType in addressTypes]
  170. return JsonResponse(
  171. {
  172. 'result': 1,
  173. 'description': '',
  174. 'payload':
  175. {
  176. 'dataList': dataList,
  177. 'total': len(dataList)
  178. }
  179. }
  180. )
  181. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  182. def getVersion(request):
  183. version = subprocess.check_output(["git", "log", "-1", "--format=%cd"]).strip()
  184. return JsonOkResponse(payload = {'version': version})
  185. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  186. @permission_required(ROLE.supermanager, ROLE.manager)
  187. def generateNewAppKeyPair(request):
  188. # type: (WSGIRequest)->JsonResponse
  189. """
  190. 生成新的应用私钥公匙对, 返回给前台私钥的地址和公钥的内容 (方便前台去粘贴给支付宝)
  191. :param request:
  192. :return:
  193. """
  194. payload = json.loads(request.body)
  195. appid = payload.get('appid')
  196. if not appid:
  197. return JsonErrorResponse(description = u'appid未传入')
  198. key = 'alipay_app_private_{appid}_{timestamp}'.format(appid = appid, timestamp = int(time.time() * 1000))
  199. pair = generate_RSA_key_pairs()
  200. serviceCache.set(key, pair.private, 3600)
  201. appPublicKeyContent = re.sub(r'-.*', '', pair.public)
  202. return JsonOkResponse(description = u'生成成功', payload = {'path': key, 'appPublicKeyContent': appPublicKeyContent})
  203. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  204. @permission_required(ROLE.supermanager, ROLE.manager)
  205. def verifyAppKeyPairs(request):
  206. # type: (WSGIRequest)->JsonResponse
  207. """
  208. :param request:
  209. :return:
  210. """
  211. return JsonErrorResponse(description = u'暂不开放')
  212. @error_tolerate(nil = DefaultJsonErrorResponse)
  213. @permission_required(ROLE.supermanager)
  214. def getAliAppList(request):
  215. # type: (WSGIRequest)->JsonResponse
  216. """
  217. 获取阿里APP列表
  218. :param request:
  219. :return:
  220. """
  221. page_index = int(request.GET.get('pageIndex', 1))
  222. page_size = int(request.GET.get('pageSize', 10))
  223. search_key = request.GET.get('searchKey', None)
  224. total, items = AliApp.list(page_index = page_index, page_size = page_size, search_key = search_key)
  225. return JsonResponse({'result': 1,
  226. 'description': None,
  227. 'payload': {
  228. 'total': total,
  229. 'dataList': items
  230. }
  231. })
  232. @error_tolerate(nil = DefaultJsonErrorResponse)
  233. @permission_required(ROLE.supermanager)
  234. def editAliApp(request):
  235. # type: (WSGIRequest)->JsonResponse
  236. """
  237. 编辑阿里APP
  238. :param request:
  239. :return:
  240. """
  241. payload = json.loads(request.body) # type: dict
  242. id = payload.pop('id', None)
  243. update = payload
  244. if id:
  245. query = {'_id': id}
  246. else:
  247. query = {'appid': payload.get('appid')}
  248. result = AliApp.get_collection().update_one(query, update, upsert = True) # type: UpdateResult
  249. return JsonResponse({
  250. 'result': 1 if (result.modified_count == 1 or result.upserted_id) else 0,
  251. 'description': u'修改成功' if (result.modified_count == 1 or result.upserted_id) else u'修改失败',
  252. 'payload': {
  253. 'id': str(result.upserted_id) if result.upserted_id else id
  254. }})
  255. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  256. @permission_required(ROLE.supermanager, ROLE.manager)
  257. def getWechatFundApp(request):
  258. # type: (WSGIRequest)->JsonResponse
  259. """
  260. 更改微信资金平台APP信息
  261. :param request:
  262. :return:
  263. """
  264. appid = request.GET.get('appid')
  265. mchid = request.GET.get('mchid')
  266. app = WechatPayApp.objects(appid = appid, mchid = mchid).first() # type: WechatPayApp
  267. if not app:
  268. return JsonOkResponse(payload = {})
  269. else:
  270. return JsonOkResponse(payload = app.to_dict())
  271. @error_tolerate(nil = DefaultJsonErrorResponse)
  272. @permission_required(ROLE.supermanager, ROLE.manager)
  273. def editWechatFundApp(request):
  274. # type: (WSGIRequest)->JsonResponse
  275. """
  276. 编辑阿里APP
  277. :param request:
  278. :return:
  279. """
  280. payload = json.loads(request.body) # type: dict
  281. id = payload.pop('id', None)
  282. update = payload
  283. if id:
  284. query = {'_id': id}
  285. else:
  286. query = {'appid': payload.get('appid')}
  287. result = WechatPayApp.get_collection().update_one(query, update, upsert = True) # type: UpdateResult
  288. return JsonResponse({
  289. 'result': 1 if (result.modified_count == 1 or result.upserted_id) else 0,
  290. 'description': u'修改成功' if (result.modified_count == 1 or result.upserted_id) else u'修改失败',
  291. 'payload': {
  292. 'id': str(result.upserted_id) if result.upserted_id else id
  293. }})
  294. @error_tolerate(nil = DefaultJsonErrorResponse)
  295. @permission_required(ROLE.supermanager, ROLE.manager)
  296. def getWechatAppList(request):
  297. # type: (WSGIRequest)->JsonResponse
  298. """
  299. 获取微信支付APP列表
  300. :param request:
  301. :return:
  302. """
  303. page_index = int(request.GET.get('pageIndex', 1))
  304. page_size = int(request.GET.get('pageSize', 10))
  305. search_key = request.GET.get('searchKey', None)
  306. total, items = WechatPayApp.list(page_index = page_index, page_size = page_size, search_key = search_key)
  307. return JsonResponse({'result': 1,
  308. 'description': None,
  309. 'payload': {
  310. 'total': total,
  311. 'dataList': items
  312. }
  313. })
  314. def event_reply(request):
  315. logger.info('has receive event_reply dispatch message = %s' % request.body)
  316. raw = xmltodict.parse(request.body)['xml']
  317. msgType = raw.get('MsgType', '')
  318. event = raw.get('Event', '')
  319. if msgType == 'event' and event in ['subscribe', 'unsubscribe']:
  320. moniOpenId = raw['FromUserName']
  321. rawAppId = raw['ToUserName']
  322. try:
  323. moniApp = MoniApp.objects.get(rawAppId = rawAppId)
  324. except Exception, e:
  325. return ''
  326. try:
  327. moniUser = MoniUser.objects.filter(moniAppId = moniApp.appId, moniOpenId = moniOpenId).first()
  328. if moniUser:
  329. if event == 'subscribe':
  330. moniUser.subTime = datetime.datetime.now()
  331. moniUser.isSubscribe = True
  332. AskRobot.reply(event, moniOpenId, '', moniApp.appId, moniApp.secret, openId = moniUser.openId)
  333. else:
  334. moniUser.unsubTime = datetime.datetime.now()
  335. moniUser.isSubscribe = False
  336. moniUser.save()
  337. else:
  338. user = MyUser.objects.filter(managerialOpenId = raw['FromUserName']).first()
  339. if user is None:
  340. newUser = MoniUser(moniAppId = moniApp.appId, moniOpenId = moniOpenId,
  341. subTime = datetime.datetime.now(), isSubscribe = True)
  342. newUser.save()
  343. else:
  344. AskRobot.reply(event, moniOpenId, '', moniApp.appId, moniApp.secret, openId = user.openId,
  345. agentId = user.agentId)
  346. except Exception, e:
  347. logger.exception('event_reply error=%s' % e)
  348. return ''
  349. elif msgType == 'text':
  350. try:
  351. # 如果是监督号,就直接回复。如果不是监督号,可能是用户的管理app,这个时候,需要走另外的流程。用户付费后关注
  352. moniApp = MoniApp.objects.filter(rawAppId = raw['ToUserName']).first()
  353. if moniApp:
  354. try:
  355. logger.info('111')
  356. moniUser = MoniUser.objects.filter(moniAppId = moniApp.appId,
  357. moniOpenId = raw['FromUserName']).first()
  358. if moniUser and moniUser.openId and moniUser.subAgentId:
  359. logger.info('222')
  360. logger.info('content = %s,openId=%s' % (raw['Content'], moniUser.openId))
  361. AskRobot.reply(event, raw['FromUserName'], raw['Content'], moniApp.appId, moniApp.secret,
  362. openId = moniUser.openId, agentId = moniUser.subAgentId)
  363. else:
  364. logger.info('333')
  365. user = MyUser.objects.filter(managerialOpenId = raw['FromUserName']).first()
  366. if user is None:
  367. logger.info('444')
  368. return {'MsgType': 'text', 'FromUserName': raw['ToUserName'],
  369. 'ToUserName': raw['FromUserName'], 'Content': u'没有找到您在平台扫码使用设备的任何信息',
  370. 'CreateTime': int(time.time())}
  371. AskRobot.reply(event, raw['FromUserName'], raw['Content'], moniApp.appId, moniApp.secret,
  372. openId = user.openId, agentId = user.agentId)
  373. except Exception, e:
  374. logger.exception('event_reply error=%s' % e)
  375. return ''
  376. logger.info('555')
  377. return ''
  378. except Exception, e:
  379. return ''
  380. return ''
  381. @error_tolerate(logger = logger, nil = JsonErrorResponse(u'故障部件图片存储失败,请重新上传'))
  382. @permission_required(ROLE.dealer, ROLE.subaccount)
  383. def uploadFaultPartPic(request):
  384. # type: (WSGIRequest)->JsonResponse
  385. files = request.FILES.getlist('file')
  386. if not len(files):
  387. return JsonResponse({'result': 0, 'description': u'故障部件图片存储失败,请重新上传', 'payload': ''})
  388. uploader = AliOssFileUploader(inputFile = request.FILES.getlist('file')[0], uploadType = 'fault')
  389. logger.info('[uploadFaultPartPic] %s is being used' % (repr(uploader),))
  390. try:
  391. outputUrl = uploader.upload()
  392. return JsonResponse({'result': 1, 'description': '', 'payload': outputUrl})
  393. except InvalidFileSize, e:
  394. logger.info(
  395. '%s(id=%s)\'s uploaded file reached limit' % (request.user.__class__.__name__, str(request.user.id),))
  396. return JsonResponse({'result': 0, 'description': e.message, 'payload': {}})
  397. except InvalidFileName, e:
  398. logger.info(
  399. '%s(id=%s)\'s uploaded file name is not legal' % (request.user.__class__.__name__, str(request.user.id),))
  400. return JsonResponse({'result': 0, 'description': e.message, 'payload': {}})
  401. def queryExpressInfo(request):
  402. orderNo = request.GET.get('orderNo')
  403. bodys = {}
  404. url = 'https://kuaidid.market.alicloudapi.com/danhao'
  405. bodys['com'] = ''
  406. bodys['src'] = orderNo
  407. from six.moves.urllib import parse
  408. post_data = parse.urlencode(bodys)
  409. request = urllib2.Request(url, post_data)
  410. request.add_header('Authorization', 'APPCODE ' + Const.KUAIDI_API_APPCODE)
  411. request.add_header('Content-Type', 'application/x-www-form-urlencoded; charset=UTF-8')
  412. ctx = ssl.create_default_context()
  413. ctx.check_hostname = False
  414. ctx.verify_mode = ssl.CERT_NONE
  415. response = urllib2.urlopen(request, timeout = 15, context = ctx)
  416. content = response.read()
  417. if (content):
  418. result = json.loads(content)
  419. if result['status'] == 200:
  420. resultList = []
  421. for info in result['msg']['context']:
  422. resultList.append({'time': datetime.datetime.fromtimestamp(info['time']).strftime(Const.DATETIME_FMT),
  423. 'desc': info['desc']})
  424. return JsonOkResponse(payload = {'dataList': resultList})
  425. else:
  426. return JsonErrorResponse(description = u'无法获取到订单详细信息')
  427. else:
  428. return JsonErrorResponse(description = u'无法获取到订单详细信息')
  429. @error_tolerate(logger = logger)
  430. def aliNotify(request):
  431. payload = request.POST.dict() # type: Dict
  432. logger.info('ali common notify: %s' % str(payload))
  433. if 'service' in payload and payload['service'] == 'alipay.service.check':
  434. biz_content = xmltodict.parse(payload['biz_content'])['XML']
  435. app = AliApp.objects(appid = biz_content['AppId']).first() # type: AliApp
  436. gateway = app.new_gateway(app_platform_type = AppPlatformType.ALIPAY) # type: AliPayGateway
  437. if gateway.check(data = payload, pop_sign_type = False):
  438. sign = gateway.client._sign('<success>true</success>')
  439. return HttpResponse(
  440. '<?xml version="1.0" encoding="GBK"?><alipay><response><success>true</success></response><app_cert_sn>{}</app_cert_sn><sign>{}</sign><sign_type>RSA2</sign_type></alipay>'.format(
  441. gateway.client.app_cert_sn, sign))
  442. if payload['msg_method'] == 'alipay.fund.trans.order.changed':
  443. payload['biz_content'] = json.loads(payload['biz_content'])
  444. order_no = payload['biz_content']['out_biz_no']
  445. if WithdrawRecord.is_my(order_no):
  446. return AliPayWithdrawNotifier(record_cls = WithdrawRecord).do(payload)
  447. else:
  448. logger.warn('not support this order. orderNo = {}'.format(order_no))
  449. else:
  450. logger.warn('not support this method = {}'.format(payload['msg_method']))
  451. return HttpResponse('success')
  452. @error_tolerate(logger=logger, nil=JsonErrorResponse(description=u"获取订单失败,请刷新"))
  453. def getReceipt(request): # type: (WSGIRequest)->JsonResponse
  454. """
  455. 获取支付结果
  456. 消费单的结果直接跳转回去
  457. """
  458. user = request.user # type: RoleBaseDocument
  459. order_type = request.GET.get('order_type', 'recharge')
  460. out_trade_no = request.GET.get('out_trade_no')
  461. check_code = request.GET.get('check_code', None)
  462. from apps.web.user.models import RechargeRecord, ConsumeRecord
  463. if order_type == 'consume':
  464. record = get_consume_order(out_trade_no) # type: ConsumeRecord
  465. payload = record.receiptDesc
  466. else:
  467. record = RechargeRecord.objects(__raw__={
  468. '$or': [
  469. {
  470. 'wxOrderNo': out_trade_no
  471. },
  472. {
  473. 'orderNo': out_trade_no
  474. }
  475. ]}).first() # type: RechargeRecord
  476. if not record:
  477. from apps.web.dealer.models import DealerRechargeRecord
  478. record = DealerRechargeRecord.objects(__raw__={
  479. '$or': [
  480. {
  481. 'wxOrderNo': out_trade_no
  482. },
  483. {
  484. 'orderNo': out_trade_no
  485. }
  486. ]}).first() # type: DealerRechargeRecord
  487. if not record:
  488. return JsonErrorResponse(description = u'订单获取失败,请重新获取')
  489. else:
  490. payload = {
  491. 'itemName': record.subject,
  492. 'orderNo': record.orderNo,
  493. 'payment': RMB.fen_to_yuan(record.totalFee),
  494. 'homeLink': concat_dealer_main_page_url(),
  495. 'finishedTime': record.finishedTime,
  496. 'adInfo': {
  497. 'adShow': 'noshow'
  498. }
  499. }
  500. if record.product == DealerRechargeRecord.ProductType.SimCard:
  501. payload.update(
  502. {'detailLink': concat_front_end_url(
  503. uri = '/app/payOrderDetail.html?orderNo={}'.format(record.orderNo))})
  504. return JsonOkResponse(payload = payload)
  505. else:
  506. if record.result != RechargeRecord.PayResult.SUCCESS:
  507. return JsonErrorResponse(description = u'订单回调还未调用')
  508. payload = {
  509. 'orderNo': record.orderNo,
  510. 'payment': record.money,
  511. 'finishedTime': record.finished_time
  512. }
  513. from apps.web.device.models import Device
  514. # 是否是启动设备的
  515. start_key = record.startKey
  516. if start_key:
  517. payload.update({
  518. 'startKey': start_key,
  519. 'devNo': record.devNo,
  520. 'logicalCode': record.logicalCode,
  521. 'homeLink': concat_user_login_entry_url(l = record.logicalCode),
  522. 'serviceLink': concat_user_center_url(l = record.logicalCode)
  523. })
  524. else:
  525. payload.update({
  526. 'serviceLink': concat_user_center_url(),
  527. 'homeLink': concat_user_center_url(),
  528. 'detailLink': concat_front_end_url(
  529. uri = '/user/index.html#/user/chargeRecordDetail?ownerId={}&id={}'.format(record.ownerId,
  530. str(record.id)))
  531. })
  532. if isinstance(record, RechargeRecord):
  533. payload['itemName'] = record.subject
  534. if record.devNo:
  535. device = Device.get_dev(record.devNo)
  536. else:
  537. device = None
  538. else:
  539. device = Device.get_dev(record.devNo)
  540. if record.port:
  541. payload['itemName'] = cn(u'{major_type}/{logicalCode}-端口{port}'.format(
  542. major_type = device.majorDeviceType[0:8], logicalCode = record.logicalCode,
  543. port = record.port))
  544. else:
  545. payload['itemName'] = cn(u'{major_type}/{logicalCode}'.format(
  546. major_type = device.majorDeviceType[0:8], logicalCode = record.logicalCode))
  547. if not check_code:
  548. owner = Dealer.objects(id=record.ownerId).first() # type: Dealer
  549. ad_dict = Advertisement.fetch_payafter_ad(
  550. ua=request.META.get('HTTP_USER_AGENT', ''), user=request.user, dealer=owner, device=device)
  551. logger.debug('ad dict is {}'.format(ad_dict))
  552. payload.update({'adInfo': ad_dict})
  553. else:
  554. AdStatistics.inc_make_count(adSpace=AdSpace.PAYAFTER, showType='payAfter_dianjin', gateway='wechat')
  555. return JsonOkResponse(payload=payload)
  556. def bolaiEvent(request):
  557. payload = json.loads(request.body)
  558. logger.debug('received bolai event: {}'.format(payload))
  559. gateId = payload.get('gateway_id')
  560. gateway_dev = Device.get_dev(gateId) # type: DeviceDict
  561. if gateway_dev is None: # 可能是一体化设备
  562. rcds = Device.get_collection().find({'gateImei': gateId})
  563. if rcds.count() == 0:
  564. return JsonOkResponse()
  565. gateway_dev = Device.get_dev(rcds[0]['devNo'])
  566. logger.info('this is gatewayplug device')
  567. if gateway_dev is None:
  568. return JsonOkResponse()
  569. if 'data' in payload and 'node_index' in payload['data']:
  570. if payload['data']['node_index'] != 0:
  571. logger.info('this is nodeplug device')
  572. gateway_adapter = gateway_dev.deviceAdapter # type: ChargingGatewayBox
  573. node_devno = gateway_adapter.get_node_devNo(str(payload['data']['node_index']))
  574. node_dev = Device.get_dev(node_devno) # type: DeviceDict
  575. if not node_dev:
  576. return JsonOkResponse()
  577. payload.update({
  578. 'nodeType': 'node'
  579. })
  580. event = node_dev.eventer.getEvent(payload)
  581. event.do()
  582. else:
  583. logger.info('this is gateway device')
  584. payload.update({
  585. 'nodeType': 'node'
  586. })
  587. event = gateway_dev.eventer.getEvent(payload)
  588. event.do()
  589. else:
  590. payload.update({
  591. 'nodeType': 'gateway'
  592. })
  593. event = gateway_dev.eventer.getEvent(payload)
  594. event.do()
  595. return JsonOkResponse()
  596. def bolaitenEvent(request):
  597. payload = json.loads(request.body)
  598. logger.debug('received bolai event: {}'.format(payload))
  599. devNo = payload.get('gateway_id')
  600. dev = Device.get_dev(devNo)
  601. if dev is None:
  602. return JsonOkResponse()
  603. if 'data' in payload:
  604. event = dev.eventer.getEvent(payload)
  605. event.do()
  606. return JsonOkResponse()
  607. @error_tolerate(nil = DefaultJsonErrorResponse)
  608. @permission_required(ROLE.dealer, ROLE.supermanager, ROLE.myuser)
  609. def getPowerGraphByDevice(request):
  610. startTime = to_datetime(request.GET.get('startTime'))
  611. endTime = to_datetime(request.GET.get('endTime'))
  612. port = str(request.GET.get('port', '1'))
  613. device = Device.get_dev_by_logicalCode(request.GET.get('logicalCode')) # type: DeviceDict
  614. if device.devTypeCode in [Const.DEVICE_TYPE_CODE_CHANGING_YUEWANGTONG]:
  615. interval = 600
  616. else:
  617. interval = device.cycle
  618. items = PowerManager.instence().get(devNo = device.devNo, port = port, sTime = startTime, eTime = endTime,
  619. interval = interval)
  620. return JsonOkResponse(payload = {'dataList': items})
  621. class WechatFollowView(View):
  622. def __init__(self, **kwargs):
  623. super(WechatFollowView, self).__init__(**kwargs)
  624. self.app = None
  625. @staticmethod
  626. def auth_request(request, app): # type:(WSGIRequest, MoniApp) -> bool
  627. """
  628. 对微信的请求进行验签
  629. """
  630. token = app.appToken
  631. signature = request.GET.get('signature')
  632. timestamp = request.GET.get('timestamp')
  633. nonce = request.GET.get('nonce')
  634. params = [token, timestamp, nonce]
  635. params.sort()
  636. return hashlib.sha1("".join(params)).hexdigest() == signature
  637. @staticmethod
  638. def get_followed_app(rawAppId):
  639. return MoniApp.get_app_by_raw(rawAppId)
  640. def dispatch(self, request, *args, **kwargs):
  641. rawAppId = kwargs.pop("rawAppId", "")
  642. app = self.get_followed_app(rawAppId)
  643. # 查找是否是入库的app
  644. if not app:
  645. logger.warning("[WechatFollowView dispatch], not find app! rawAppId = {}".format(rawAppId))
  646. return HttpResponseBadRequest()
  647. # 查找是否通过校验
  648. if not self.auth_request(request, app):
  649. logger.warning("[WechatFollowView dispatch], verify server error! params = {}".format(request.GET))
  650. return HttpResponseBadRequest()
  651. self.app = app
  652. return super(WechatFollowView, self).dispatch(request)
  653. def get(self, request):
  654. """
  655. 微信公众号服务器验证token使用 配置的时候只会访问一次
  656. """
  657. logger.info("[WechatFollowView GET], verify server success! params = {}, app = {}".format(request.GET, self.app))
  658. echoStr = request.GET["echostr"]
  659. return HttpResponse(echoStr)
  660. def post(self, request):
  661. """
  662. 业务请求都在这里
  663. 大致分为两类
  664. 1.业务事件(关注、订阅、点击菜单)
  665. 2.用户互动文字
  666. """
  667. logger.info("[WechatFollowView POST], payload = {}, app = {}".format(request.body, self.app))
  668. message = WechatMessage(request.body)
  669. if message.isText:
  670. response = WechatText(message, self.app).handle()
  671. elif message.isEvent:
  672. if message.isScanEvent:
  673. response = WechatScanEvent(message, self.app).handle()
  674. elif message.isSubscribeEvent:
  675. response = WechatSubscribe(message, self.app).handle()
  676. elif message.isUnSubscribeEvent:
  677. response = WechatUnSubscribe(message, self.app).handle()
  678. elif message.isMenuEvent:
  679. response = WechatMenu(message, self.app).handle()
  680. else:
  681. response = MessageHandler.defaultResponse()
  682. else:
  683. response = MessageHandler.defaultResponse()
  684. return response
  685. @permission_required(ROLE.dealer, ROLE.agent, ROLE.supermanager)
  686. def loadWithdrawArea(request):
  687. province = request.GET.get("province", None)
  688. return JsonOkResponse(payload = {'dataList': WithdrawDistrict.get_area(province)})
  689. @error_tolerate(logger = logger, nil = JsonErrorResponse(description = u"获取数据失败,请刷新"))
  690. @permission_required(ROLE.dealer, ROLE.agent, ROLE.supermanager)
  691. def supportedWithdrawBanks(request):
  692. # type: (WSGIRequest)->JsonResponse
  693. keyWord = request.GET.get('keyWord', None)
  694. chooseRange = request.GET.get('range', 'wechat')
  695. if chooseRange == 'all':
  696. return JsonOkResponse(payload = {'dataList': WithdrawBanks.get_all_banks(keyWord)})
  697. elif chooseRange == 'wechat':
  698. return JsonOkResponse(payload = {'dataList': WithdrawBanks.get_wechat_support_banks(keyWord)})
  699. else:
  700. return JsonErrorResponse(description = u'参数错误')
  701. @error_tolerate(logger = logger, nil = JsonErrorResponse(description = u"获取数据失败,请刷新"))
  702. @permission_required(ROLE.dealer, ROLE.agent, ROLE.supermanager)
  703. def getWithdrawBankByAccount(request):
  704. # type: (WSGIRequest)->JsonResponse
  705. accountCode = request.GET.get('accountCode', None)
  706. if not accountCode:
  707. return JsonResponse({'result': 2, 'description': u'银行账号不能为空', 'payload': {}})
  708. bank_info = BankAPI().get_bank_card_info(card_no = accountCode)
  709. if bank_info:
  710. rv = WithdrawBanks.get_by_bank_abbrev_code(bank_info['bankAbbrevCode'])
  711. if rv:
  712. return JsonOkResponse(payload = rv)
  713. else:
  714. logger.warning('not find this bank: {}'.format(bank_info))
  715. return JsonResponse({'result': 2, 'description': u'该银行卡不支持', 'payload': {}})
  716. else:
  717. return JsonResponse({'result': 2, 'description': u'没有查到该银行账号信息', 'payload': {}})
  718. @error_tolerate(logger = logger, nil = JsonErrorResponse(description = u"获取数据失败,请刷新"))
  719. @permission_required(ROLE.dealer, ROLE.agent, ROLE.supermanager)
  720. def withdrawBranchBankList(request):
  721. # type: (WSGIRequest)->JsonResponse
  722. provinceCode = request.GET.get('provinceCode')
  723. cityCode = request.GET.get('cityCode')
  724. bankCode = request.GET.get('bankCode')
  725. keyWord = request.GET.get('keyWord')
  726. queryset = WithdrawBranchBanks.objects(**{
  727. 'provinceCode': provinceCode,
  728. 'cityCode': cityCode,
  729. 'bankCode': bankCode
  730. }).search(keyWord)
  731. rv = [
  732. {
  733. 'code': item.code,
  734. 'name': item.name
  735. } for item in queryset
  736. ]
  737. return JsonOkResponse(payload = {'dataList': rv})
  738. @error_tolerate(nil = DefaultJsonErrorResponse)
  739. @permission_required(ROLE.dealer, ROLE.agent)
  740. def saveWithdrawBankCard(request):
  741. # type: (WSGIRequest)->JsonResponse
  742. """
  743. 添加银行卡
  744. """
  745. ownerId = str(request.user.id)
  746. if WithdrawBankCard.objects.filter(ownerId = ownerId, role = request.user.role).count() > 5:
  747. return JsonResponse({"result": 2, "description": u"银行卡数量已添加至上限(5),不允许继续添加"})
  748. try:
  749. payload = SaveWithdrawBankCardSchema(json.loads(request.body))
  750. except MultipleInvalid as e:
  751. logger.exception(e)
  752. return JsonErrorResponse(description = u"信息不完整")
  753. if WithdrawBankCard.objects(ownerId = ownerId, role = request.user.role,
  754. accountCode = payload['accountCode']).first():
  755. return JsonResponse({"result": 2, "description": u"请勿重复添加"})
  756. accountType = payload.pop('accountType')
  757. if accountType == WithdrawBankCard.AccountType.PERSONAL:
  758. item = WithdrawBankCard.new_personal_withdraw_bank_card(ownerId = ownerId, role = request.user.role, **payload)
  759. return JsonOkResponse(payload = {"id": str(item.id)})
  760. else:
  761. return JsonErrorResponse(description = u"不支持添加对公提现银行卡,请您开通商户。")
  762. @error_tolerate(nil = DefaultJsonErrorResponse)
  763. @permission_required(ROLE.dealer, ROLE.agent)
  764. def unbindWithdrawBankCard(request):
  765. # type: (WSGIRequest)->JsonResponse
  766. ownerId = str(request.user.id)
  767. payload = json.loads(request.body)
  768. accountCode = payload.get('accountCode')
  769. if not accountCode:
  770. return JsonResponse({"result": 2, "description": u"参数错误,请刷新后重试"})
  771. try:
  772. card = WithdrawBankCard.objects.get(ownerId = ownerId, role = request.user.role, accountCode = accountCode)
  773. except Exception as e:
  774. logger.exception(e)
  775. return JsonResponse({"result": 2, "description": u"解绑定失败,请联系客服解决。"})
  776. else:
  777. card.delete()
  778. return JsonOkResponse()
  779. @error_tolerate(nil = DefaultJsonErrorResponse)
  780. @permission_required(ROLE.dealer, ROLE.agent)
  781. def getWithdrawBankCards(request):
  782. # type: (WSGIRequest)->JsonResponse
  783. ownerId = str(request.user.id)
  784. bankCards = WithdrawBankCard.objects.filter(ownerId = ownerId, role = request.user.role)
  785. dataList = list()
  786. for bankCard in bankCards:
  787. dataList.append(bankCard.to_dict())
  788. return JsonOkResponse(payload = {'dataList': dataList})
  789. @error_tolerate(nil = DefaultJsonErrorResponse)
  790. @permission_required(ROLE.dealer, ROLE.agent)
  791. def saveAlipayWithdrawInfo(request):
  792. # type: (WSGIRequest)->JsonResponse
  793. try:
  794. payload = SaveWithdrawAlipaySchema(json.loads(request.body))
  795. except MultipleInvalid as e:
  796. logger.exception(e)
  797. return JsonErrorResponse(description = u"参数错误")
  798. else:
  799. request.user.set_withdraw_alipay(**payload)
  800. return JsonOkResponse()
  801. @error_tolerate(nil = DefaultJsonErrorResponse)
  802. @permission_required(ROLE.dealer, ROLE.agent)
  803. def saveWechatWithdrawInfo(request):
  804. # type: (WSGIRequest)->JsonResponse
  805. try:
  806. payload = SaveWithdrawWechatSchema(json.loads(request.body))
  807. except MultipleInvalid as e:
  808. logger.exception(e)
  809. return JsonErrorResponse(description = u"参数错误")
  810. else:
  811. request.user.set_withdraw_wechat(**payload)
  812. return JsonOkResponse()