views.py 40 KB

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