views.py 107 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141
  1. # -*- coding: utf-8 -*-
  2. # !/usr/bin/env python
  3. import datetime
  4. import logging
  5. import re
  6. import simplejson as json
  7. from bson.objectid import ObjectId
  8. from django.conf import settings
  9. from django.contrib import auth
  10. from django.views.decorators.http import require_POST, require_GET
  11. from mongoengine.errors import DoesNotExist, NotUniqueError
  12. from typing import TYPE_CHECKING
  13. from voluptuous import MultipleInvalid
  14. from apilib import utils_datetime
  15. from apilib.monetary import RMB, Ratio, VirtualCoin
  16. from apilib.utils import is_number
  17. from apilib.utils_datetime import to_datetime
  18. from apilib.utils_json import JsonResponse
  19. from apilib.utils_string import make_title_from_dict
  20. from apilib.utils_sys import memcache_lock
  21. from apps import serviceCache
  22. from apps.web.agent import api
  23. from apps.web.agent.models import Agent, MoniApp, MoniAppPoint
  24. from apps.web.common.models import AddressType, FAQ, WithdrawBankCard, WithdrawBranchBanks
  25. from apps.web.common.models import Feature
  26. from apps.web.constant import Const, SimStatus
  27. from apps.web.core import ROLE
  28. from apps.web.core.bridge.wechat import WechatClientProxy
  29. from apps.web.core.exceptions import InvalidFileSize, InvalidFileName, \
  30. ManagerServiceTimeOutException, ManagerServiceSerialException, ServiceException, RentDeviceError
  31. from apps.web.core.file import AliOssFileUploader
  32. from apps.web.core.models import AliApp, WechatPayApp
  33. from apps.web.core.models import OfflineTask
  34. from apps.web.core.models import WechatAuthApp
  35. from apps.web.core.networking import MessageSender
  36. from apps.web.core.utils import DefaultJsonErrorResponse, JsonErrorResponse, JsonOkResponse
  37. from apps.web.dealer.models import Dealer, ExchangeOrder, DealerRechargeRecord, ApiAppInfo
  38. from apps.web.dealer.transaction_deprecated import refund_cash_to_dealer
  39. from apps.web.dealer.utils import create_dealer_sim_charge_order
  40. from apps.web.device.models import Device, DeviceType, MajorDeviceType, DeviceCommandParam, DeviceCommand, SIMCard, \
  41. Part, Group
  42. from apps.web.device.timescale import SignalManager
  43. from apps.web.exceptions import UserServerException
  44. from apps.web.helpers import get_manual_pay_gateway
  45. from apps.web.management.models import Manager, DeviceReplacement
  46. from apps.web.promotion.models import InsuranceOrder
  47. from apps.web.superadmin import OfflineTaskType
  48. from apps.web.superadmin.models import SuperManager, WebLog
  49. from apps.web.user.models import RechargeRecord, ConsumeRecord
  50. from apps.web.user.transaction_deprecated import refund_cash
  51. from apps.web.utils import permission_required, error_tolerate, super_manager_login, trace_call
  52. from apps.web.validation import SavePublicWithdrawBankCardExtraSchema, \
  53. SaveWithdrawBankCardSchemaForSuper
  54. from library.qiben import SimManager
  55. from taskmanager.mediator import task_caller
  56. if TYPE_CHECKING:
  57. from apps.web.device.models import DeviceDict
  58. from django.core.handlers.wsgi import WSGIRequest
  59. from apps.web.core.db import CustomQuerySet
  60. from typing import Dict, List, Callable, Iterable, Union, Any
  61. from apps.web.common.models import UserSearchable
  62. from apps.web.dealer.models import DealerDict
  63. from apps.web.user.models import MyUser
  64. from apps.web.device.models import GroupDict
  65. logger = logging.getLogger(__name__)
  66. def login(request):
  67. # type: (WSGIRequest)->JsonResponse
  68. try:
  69. payload = json.loads(request.body)
  70. username, password = payload['username'], payload['password']
  71. if SuperManager.objects(username = username).first():
  72. return super_manager_login(request, logger, username, password)
  73. else:
  74. return JsonResponse({'result': 0, 'description': u'用户名或者密码错误', 'payload': {}})
  75. except Exception as e:
  76. logger.exception('super manager login error = %s' % e)
  77. return JsonResponse({'result': 0, 'description': u'登录异常', 'payload': {}})
  78. @permission_required(ROLE.supermanager)
  79. def logout(request):
  80. # type: (WSGIRequest)->JsonResponse
  81. auth.logout(request)
  82. return JsonResponse({'result': 1})
  83. @permission_required(ROLE.supermanager)
  84. def getCurrentUserInfo(request):
  85. # type: (WSGIRequest)->JsonResponse
  86. return JsonResponse(
  87. {
  88. "result": 1,
  89. "description": "",
  90. "payload":
  91. {
  92. 'username': request.user.username,
  93. "nickname": request.user.nickname,
  94. "brandName": "厂商管理后台",
  95. "logo": ""
  96. }
  97. })
  98. @permission_required(ROLE.supermanager)
  99. def getManagerList(request):
  100. # type: (WSGIRequest)->JsonResponse
  101. pageIndex = int(request.GET.get('pageIndex', 1))
  102. pageSize = int(request.GET.get('pageSize', 40))
  103. searchKey = request.GET.get('searchKey', None)
  104. searchType = request.GET.get('searchType', None)
  105. if searchType is None:
  106. managers = Manager.search(searchKey).filter(domain = settings.MY_DOMAIN).order_by('-dateTimeAdded')
  107. elif searchType == ROLE.dealer:
  108. dealers = Dealer.objects().search(searchKey)
  109. agents = Agent.objects(id__in = [str(_.agentId) for _ in dealers])
  110. managers = Manager.objects(domain = settings.MY_DOMAIN, id__in = [str(_.managerId) for _ in agents])
  111. elif searchType == ROLE.agent:
  112. agents = Agent.objects().search(searchKey)
  113. managers = Manager.objects(domain = settings.MY_DOMAIN, id__in = [str(_.managerId) for _ in agents])
  114. else:
  115. return JsonErrorResponse(description = u'目前只支持按照代理商查询或经销商查询或厂商通用查询')
  116. total = managers.count()
  117. dataList = []
  118. for manager in managers.paginate(pageIndex = pageIndex, pageSize = pageSize): # type: Manager
  119. dictValue = manager.to_dict(shadow = (not request.user.universal_password_login))
  120. dictValue.update({'agentTotal': Agent.objects(managerId = str(manager.id)).count()})
  121. dataList.append(dictValue)
  122. return JsonOkResponse(payload = {'total': total, 'dataList': dataList})
  123. @permission_required(ROLE.supermanager)
  124. def addManager(request):
  125. # type: (WSGIRequest)->JsonResponse
  126. payload = json.loads(request.body)
  127. username = payload.pop('username')
  128. password = payload.pop('password')
  129. nickname = payload.get('nickname')
  130. logo_path = payload.pop('img', '')
  131. primaryAgentUsername = payload.pop('primaryAgentUsername')
  132. primaryAgentPassword = payload.pop('primaryAgentPassword')
  133. primaryAgentNickName = payload.pop('primaryAgentNickName')
  134. payload.update({'logo': logo_path})
  135. payload.update({'brandName': nickname})
  136. try:
  137. trafficCardCost = RMB(payload.get('trafficCardCost', Const.PLATFORM_DEFAULT_TRAFFIC_COST))
  138. if trafficCardCost < RMB(0):
  139. return JsonErrorResponse(description = u'流量卡年费输入错误')
  140. if 'withdrawFeeRatioCost' in payload:
  141. withdrawFeeRatioCost = Ratio(payload.get('withdrawFeeRatioCost'))
  142. else:
  143. withdrawFeeRatioCost = Const.PLATFORM_DEFAULT_WITHDRAW_FEE_RATIO
  144. if withdrawFeeRatioCost < Const.MIN_DEALER_WITHDRAW_FEE_RATIO or withdrawFeeRatioCost > Const.MAX_DEALER_WITHDRAW_FEE_RATIO:
  145. return JsonErrorResponse(description = u'提现费率输入错误')
  146. try:
  147. manager = Manager.create_user(username, password, **payload)
  148. except NotUniqueError as e:
  149. logger.exception('not unique super admin data, error=%s' % (e,))
  150. return JsonErrorResponse(description = u'重复的超级管理员电话号码')
  151. agent = Agent.create_user(username = primaryAgentUsername, password = primaryAgentPassword, **{
  152. 'managerId': str(manager.id),
  153. 'nickname': primaryAgentNickName,
  154. 'productName': nickname,
  155. 'productLogo': logo_path,
  156. 'annualTrafficCost': trafficCardCost,
  157. 'trafficCardCost': trafficCardCost,
  158. 'withdrawFeeRatio': withdrawFeeRatioCost,
  159. 'withdrawFeeRatioCost': withdrawFeeRatioCost})
  160. except NotUniqueError as e:
  161. logger.exception('not unique primary agent data, error=%s' % (e,))
  162. return JsonErrorResponse(description = u'重复的代理商电话号码')
  163. updated = manager.update(primeAgentId = str(agent.id))
  164. assert updated, u'更新主代理商ID错误'
  165. return JsonOkResponse()
  166. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  167. def editManager(request):
  168. # type: (WSGIRequest)->JsonResponse
  169. payload = json.loads(request.body)
  170. id_ = str(payload.pop('id'))
  171. updated = Manager.objects(id = id_).update(**payload)
  172. if updated:
  173. return JsonOkResponse()
  174. else:
  175. return JsonErrorResponse(description = u'编辑厂商失败')
  176. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  177. @permission_required(ROLE.supermanager)
  178. def editManagerPassword(request):
  179. # type: (WSGIRequest)->JsonResponse
  180. try:
  181. payload = json.loads(request.body)
  182. managerId = payload.get('id')
  183. password = payload.get('password')
  184. agent = Manager.objects.get(id = managerId)
  185. agent.set_password(password)
  186. return JsonResponse({'result': 1, 'description': u'修改成功', 'payload': {}})
  187. except DoesNotExist:
  188. return JsonResponse({'result': 0, 'description': u'厂商不存在,请刷新后再试', 'payload': {}})
  189. except Exception as e:
  190. logger.exception('cannot [editManagerPassword], error=%s' % (e,))
  191. return JsonResponse({'result': 0, 'description': u'修改失败', 'payload': {}})
  192. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  193. @permission_required(ROLE.supermanager)
  194. def editAgentPassword(request):
  195. # type: (WSGIRequest)->JsonResponse
  196. try:
  197. payload = json.loads(request.body)
  198. agentId = payload.get('id')
  199. password = payload.get('password')
  200. agent = Agent.objects.get(id = agentId)
  201. agent.set_password(password)
  202. return JsonResponse({'result': 1, 'description': u'修改成功', 'payload': {}})
  203. except DoesNotExist:
  204. return JsonResponse({'result': 0, 'description': u'代理商不存在,请刷新后再试', 'payload': {}})
  205. except Exception as e:
  206. logger.exception('cannot [editManagerPassword], error=%s' % (e,))
  207. return JsonResponse({'result': 0, 'description': u'修改失败', 'payload': {}})
  208. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  209. @permission_required(ROLE.supermanager)
  210. def editDealerPassword(request):
  211. # type: (WSGIRequest)->JsonResponse
  212. try:
  213. payload = json.loads(request.body)
  214. dealerId = payload.get('id')
  215. password = payload.get('password')
  216. dealer = Dealer.objects.get(id = dealerId)
  217. dealer.set_password(password)
  218. return JsonResponse({'result': 1, 'description': u'修改成功', 'payload': {}})
  219. except DoesNotExist:
  220. return JsonResponse({'result': 0, 'description': u'经销商不存在,请刷新后再试', 'payload': {}})
  221. except Exception as e:
  222. logger.exception('cannot [editManagerPassword], error=%s' % (e,))
  223. return JsonResponse({'result': 0, 'description': u'修改失败', 'payload': {}})
  224. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  225. @permission_required(ROLE.supermanager)
  226. def getDeviceDetailList(request):
  227. # type: (WSGIRequest)->JsonResponse
  228. pageIndex = int(request.GET.get('pageIndex', 1))
  229. pageSize = int(request.GET.get('pageSize', 40))
  230. searchKey = request.GET.get('searchKey', None)
  231. managerId = request.GET.get('managerId', None)
  232. dealerId = request.GET.get('dealerId', None)
  233. agentId = request.GET.get('agentId', None)
  234. online = request.GET.get('online', None)
  235. registered = request.GET.get('registered')
  236. logicalCode = request.GET.get("logicalCode", None)
  237. if logicalCode:
  238. data = Device.accurate_filter(logicalCode = logicalCode, shadow = (not request.user.universal_password_login))
  239. if not data:
  240. return JsonErrorResponse(description = u'无效的logicalCode')
  241. return JsonOkResponse(payload = {'total': 1, 'dataList': [data]})
  242. logicalCodeList = list(set(request.GET.getlist('logicalCodeList', None)))
  243. if logicalCodeList is not None:
  244. if len(logicalCodeList) > 0:
  245. dataList = []
  246. ds = Device.objects(logicalCode__in = logicalCodeList)
  247. for _ in ds.paginate(pageIndex = pageIndex, pageSize = pageSize):
  248. data = Device.accurate_filter(logicalCode = _.logicalCode,
  249. shadow = (not request.user.universal_password_login))
  250. if data is None:
  251. continue
  252. else:
  253. dataList.append(data)
  254. return JsonOkResponse(payload = {'total': ds.count(), 'dataList': dataList})
  255. try:
  256. if online is not None:
  257. online = json.loads(online)
  258. if registered is not None:
  259. registered = json.loads(registered)
  260. except ValueError:
  261. return JsonErrorResponse(description = u'参数不合法')
  262. total, device_list = Device.tree_filter(dealerId,
  263. agentId,
  264. managerId,
  265. searchKey,
  266. pageIndex,
  267. pageSize,
  268. online = online,
  269. registered = registered,
  270. shadow = (not request.user.universal_password_login))
  271. return JsonOkResponse(payload = {'total': total, 'dataList': device_list})
  272. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  273. @permission_required(ROLE.supermanager)
  274. def getOrderDetailList(request):
  275. # type: (WSGIRequest)->JsonResponse
  276. def get_consume_dataList(consumeRcd, index, size):
  277. return [{
  278. 'wxOrderNo': '',
  279. 'orderNo': '',
  280. 'orderResult': '',
  281. 'rechargeUser': '',
  282. 'rechargeType': '',
  283. 'money': '',
  284. 'coins': '',
  285. 'orderDetail': {},
  286. 'orderCreateTime': '',
  287. 'logicalCode': _.logicalCode,
  288. 'devNo': _.devNo,
  289. 'devTypeCode': Device.objects(devNo = _.devNo).first().devType.get('code', '') if Device.objects(
  290. devNo = _.devNo).first() is not None else '',
  291. 'consumeOrderNo': _.orderNo,
  292. 'consumeUser': _.nickname + ' ' + _.openId,
  293. 'consumeCoins': _.coin,
  294. 'consumeResult': u'消费成功' if _.isNormal else u'消费失败',
  295. 'failedReason': _.errorDesc,
  296. 'consumeOrderCreateTime': _.dateTimeAdded.strftime('%Y-%m-%d %H:%M:%S'),
  297. 'consumeDetail': _.attachParas,
  298. 'consumeDict': _.servicedInfo
  299. } for _ in consumeRcd.paginate(pageIndex = index, pageSize = size)]
  300. pageIndex = int(request.GET.get('pageIndex', 1))
  301. pageSize = int(request.GET.get('pageSize', 40))
  302. searchKey = request.GET['searchKey']
  303. searchType = request.GET['searchType']
  304. searchResult = True
  305. if searchType == 'logicalCodeRecharge':
  306. device = Device.objects(logicalCode = searchKey).first()
  307. if device is not None:
  308. devNo = device.devNo
  309. rs = RechargeRecord.objects(devNo = devNo, via__in = ['recharge', 'chargeCard']).order_by('-dateTimeAdded')
  310. dataList = [_.to_dict_for_super_admin() for _ in rs.paginate(pageIndex = pageIndex, pageSize = pageSize)]
  311. else:
  312. return JsonErrorResponse(description = u'设备编号不存在')
  313. elif searchType == 'logicalCodeConsume':
  314. device = Device.objects(logicalCode=searchKey).first()
  315. if device is not None:
  316. devNo = device.devNo
  317. cs = ConsumeRecord.objects(devNo=devNo).order_by('-dateTimeAdded')
  318. dataList = get_consume_dataList(cs, pageIndex, pageSize)
  319. else:
  320. return JsonErrorResponse(description=u'设备编号不存在')
  321. elif searchType == 'wxOrderNo':
  322. rs = RechargeRecord.objects(wxOrderNo = searchKey)
  323. if rs.count() == 0:
  324. searchResult = False
  325. dataList = [_.to_dict_for_super_admin() for _ in rs]
  326. elif searchType == 'orderNo':
  327. rs = RechargeRecord.objects(orderNo = searchKey)
  328. if rs.count() == 0:
  329. searchResult = False
  330. dataList = [_.to_dict_for_super_admin() for _ in rs]
  331. elif searchType == 'consumeOrderNo':
  332. cs = ConsumeRecord.objects(orderNo = searchKey)
  333. if cs.count() == 0:
  334. searchResult = False
  335. c = cs.first()
  336. if c.rechargeRcdId is None or c.rechargeRcdId == '':
  337. dataList = get_consume_dataList(cs, pageIndex, pageSize)
  338. else:
  339. rs = RechargeRecord.objects(id = str(c.rechargeRcdId))
  340. dataList = [_.to_dict_for_super_admin() for _ in rs.paginate(pageIndex = pageIndex, pageSize = pageSize)]
  341. else:
  342. return JsonErrorResponse(description = u'查询方式错误')
  343. if searchResult is False:
  344. return JsonErrorResponse(description = u'没有查询到结果')
  345. else:
  346. return JsonOkResponse(payload = {'total': 0, 'dataList': dataList})
  347. @error_tolerate(nil=JsonErrorResponse(u'退款失败'), logger=logger)
  348. @permission_required(ROLE.supermanager)
  349. def refundCashFromRecharge(request):
  350. # type: (WSGIRequest)->JsonResponse
  351. data = json.loads(request.body)
  352. orderNo = data['orderNo']
  353. money = data['money']
  354. rcd = RechargeRecord.objects(orderNo=orderNo).first() # type: RechargeRecord
  355. if rcd is None:
  356. return JsonErrorResponse(description=u"充值订单不存在,退款失败")
  357. if RMB(money) <= RMB(0):
  358. return JsonErrorResponse(description=u"退费金额错误")
  359. if float(money) > float(str(rcd.money)):
  360. return JsonErrorResponse(description=u"退款金额大于订单金额,退款失败")
  361. if not rcd.is_success:
  362. return JsonErrorResponse(description = u"退款失败,订单状态非成功,请联系平台客服")
  363. if not rcd.is_ledgered:
  364. return JsonErrorResponse(description=u"订单还没有分账,无法退款")
  365. try:
  366. deductCoins = VirtualCoin(rcd.coins) * Ratio(float(RMB(money)) / float(RMB(rcd.money)))
  367. refund_cash(recharge_record = rcd, refundFee = RMB(money), **{
  368. 'deductCoins': deductCoins,
  369. 'frozenCoins': deductCoins,
  370. 'operatorId': request.user.identity_id,
  371. 'checkWallet': True
  372. })
  373. return JsonOkResponse()
  374. except ServiceException as e:
  375. logger.error(e.result)
  376. return JsonErrorResponse(description=e.result.get("description"))
  377. except UserServerException as e:
  378. logger.error(e.message)
  379. return JsonResponse(e.message)
  380. @error_tolerate(nil = JsonErrorResponse(u'管理员强制删除失败'), logger = logger)
  381. @permission_required(ROLE.supermanager)
  382. def unbindDevByAdmin(request):
  383. # type: (WSGIRequest)->JsonResponse
  384. logicalCode = json.loads(request.body)['logicalCode']
  385. dev = Device.get_dev_by_logicalCode(logicalCode) # type: DeviceDict
  386. if dev is None:
  387. return JsonErrorResponse(description = u"该设备不存在,请刷新后再试")
  388. Device.un_register(dev, force = True, operator = request.user.human_id)
  389. return JsonOkResponse()
  390. ###############
  391. ##: 特性列表 :##
  392. ###############
  393. @error_tolerate(nil = JsonErrorResponse(u'获取特性列表失败'), logger = logger)
  394. @permission_required(ROLE.supermanager)
  395. def getFeatureList(request):
  396. # type: (WSGIRequest)->JsonResponse
  397. """
  398. :param request:
  399. :return:
  400. """
  401. pageIndex = int(request.GET.get('pageIndex', 1))
  402. pageSize = int(request.GET.get('pageSize', 40))
  403. role = request.GET.get('role')
  404. searchKey = request.GET.get('searchKey')
  405. if role is not None:
  406. query = {'role': role}
  407. else:
  408. query = {}
  409. queryset = Feature.objects(**query).search(searchKey)
  410. total = queryset.count()
  411. return JsonOkResponse(
  412. payload = {
  413. 'dataList': [_.to_dict() for _ in queryset.paginate(pageIndex = pageIndex, pageSize = pageSize)],
  414. 'total': total
  415. }
  416. )
  417. @error_tolerate(nil = JsonErrorResponse(u'增加特性失败'), logger = logger)
  418. @permission_required(ROLE.supermanager)
  419. def addFeature(request):
  420. # type: (WSGIRequest)->JsonResponse
  421. try:
  422. Feature(**json.loads(request.body)).save()
  423. except NotUniqueError:
  424. return JsonErrorResponse(description = u'已有相同的角色+特性名,重复数据')
  425. return JsonOkResponse(description = u'添加成功')
  426. @error_tolerate(nil = JsonErrorResponse(u'编辑特性失败'), logger = logger)
  427. @permission_required(ROLE.supermanager)
  428. def editFeature(request):
  429. # type: (WSGIRequest)->JsonResponse
  430. payload = json.loads(request.body)
  431. id_ = payload.pop('id')
  432. feature = Feature.objects(id = str(id_)).get()
  433. result = feature.update(**payload)
  434. if not result:
  435. logger.error(u'{0!r} 编辑特性失败 id={1}'.format(request.user, id_))
  436. return JsonOkResponse(description = u'编辑成功')
  437. @error_tolerate(nil = JsonErrorResponse(u'删除特性失败'), logger = logger)
  438. @permission_required(ROLE.supermanager)
  439. def removeFeatures(request):
  440. # type: (WSGIRequest)->JsonResponse
  441. ids = json.loads(request.body)['ids']
  442. queryset = Feature.objects(id__in = ids) # type: CustomQuerySet
  443. deleted = queryset.delete()
  444. if not deleted:
  445. logger.error(u'{0!r} 删除特性失败 ids={1}'.format(request.user, ids))
  446. return JsonErrorResponse(description = u'删除特性失败')
  447. return JsonOkResponse(description = u'删除成功')
  448. def edit_feature(request, model):
  449. # type: (WSGIRequest, Any)->JsonResponse
  450. payload = json.loads(request.body)
  451. id_ = payload['id']
  452. featureList = payload.get('featureList', [])
  453. specialFeature = payload.get('specialFeature')
  454. user = model.objects(id = id_).first() # type: Union[Dealer, Agent, Manager]
  455. if not user:
  456. return JsonErrorResponse(description = u'未找到该用户')
  457. result = user.edit_feature_list(featureList, specialFeature)
  458. if result:
  459. return JsonOkResponse(description = u'编辑成功')
  460. else:
  461. return JsonErrorResponse(description = u'编辑不成功')
  462. @error_tolerate(nil = JsonErrorResponse(u'编辑特性失败'), logger = logger)
  463. @permission_required(ROLE.supermanager)
  464. def editAgentFeature(request):
  465. # type: (WSGIRequest)->JsonResponse
  466. """
  467. :param request:
  468. :return:
  469. """
  470. return edit_feature(request, Agent)
  471. @error_tolerate(nil = JsonErrorResponse(u'编辑特性失败'), logger = logger)
  472. @permission_required(ROLE.supermanager)
  473. def editDealerFeature(request):
  474. # type: (WSGIRequest)->JsonResponse
  475. """
  476. :param request:
  477. :return:
  478. """
  479. return edit_feature(request, Dealer)
  480. @error_tolerate(nil = JsonErrorResponse(u'编辑特性失败'), logger = logger)
  481. @permission_required(ROLE.supermanager)
  482. def editManagerFeature(request):
  483. # type: (WSGIRequest)->JsonResponse
  484. """
  485. :param request:
  486. :return:
  487. """
  488. return edit_feature(request, Manager)
  489. #########
  490. # Utils #
  491. #########
  492. @error_tolerate(nil = JsonErrorResponse(u'设备更换失败'), logger = logger)
  493. @permission_required(ROLE.supermanager)
  494. def replaceDevice(request):
  495. # type: (WSGIRequest)->JsonResponse
  496. """
  497. 调换设备
  498. 动机:
  499. 部分设备因各种原因退役,但是二维码已经贴在机器上,更换其设备,保持老的逻辑设备即可
  500. :param request:
  501. :return:
  502. """
  503. payload = json.loads(request.body)
  504. oldLogicalCode = payload['old']
  505. newLogicalCode = payload['new']
  506. key = 'device-replacement-{old}-{new}'.format(old = payload['old'], new = payload['new'])
  507. with memcache_lock(key, '1', expire = 60) as acquired:
  508. if acquired:
  509. logger.debug(
  510. '%r started a new device replacement, old=%s, new=%s' % (request.user, oldLogicalCode, newLogicalCode))
  511. try:
  512. Device.replace(oldLogicalCode, newLogicalCode, request.user)
  513. return JsonOkResponse(description = u'替换成功')
  514. except UserServerException as e:
  515. return JsonErrorResponse(description = e.message)
  516. else:
  517. return JsonErrorResponse(description = u'已经同一个替换在进行')
  518. @error_tolerate(nil = JsonErrorResponse(u'设备互换失败'), logger = logger)
  519. @permission_required(ROLE.supermanager)
  520. def swapDevice(request):
  521. # type: (WSGIRequest)->JsonResponse
  522. """
  523. 调换设备
  524. 动机:
  525. 部分设备因各种原因退役,但是二维码已经贴在机器上,更换其设备,保持老的逻辑设备即可
  526. :param request:
  527. :return:
  528. """
  529. payload = json.loads(request.body)
  530. left_lc = payload['left']
  531. right_lc = payload['right']
  532. key = 'device-swap-{left}-{right}'.format(left = left_lc, right = right_lc)
  533. with memcache_lock(key, '1', expire = 60) as acquired:
  534. if acquired:
  535. logger.debug('%r started a new device swap, old=%s, new=%s' % (request.user, left_lc, right_lc))
  536. try:
  537. Device.swap(left_lc, right_lc, request.user)
  538. return JsonOkResponse(description = u'互换成功')
  539. except UserServerException as e:
  540. return JsonErrorResponse(description = e.message)
  541. else:
  542. return JsonErrorResponse(description = u'已经同一个互换在进行')
  543. @error_tolerate(nil = JsonErrorResponse(u'撤销设备更换失败'), logger = logger)
  544. @permission_required(ROLE.supermanager)
  545. def rollbackDeviceReplacement(request):
  546. # type: (WSGIRequest)->JsonResponse
  547. """
  548. 回退调换设备操作
  549. :param request:
  550. :return:
  551. """
  552. payload = json.loads(request.body) if request.body else {}
  553. if 'id' not in payload:
  554. return JsonErrorResponse(description = u'ID未传入')
  555. replacement_id = payload['id']
  556. key = 'device-replacement-revoke-{id}'.format(id = replacement_id)
  557. with memcache_lock(key, '1', expire = 60) as acquired:
  558. if acquired:
  559. try:
  560. Device.rollback_replacement(replacement_id)
  561. return JsonResponse({'result': 1, 'payload': {}, 'description': u'回滚成功'})
  562. except UserServerException as e:
  563. return JsonErrorResponse(description = e.message)
  564. else:
  565. return JsonErrorResponse(description = u'已有同一个回滚操作正在运行')
  566. @error_tolerate(nil = JsonErrorResponse(u'获取设备更换记录失败'), logger = logger)
  567. @permission_required(ROLE.supermanager)
  568. def getDeviceReplacements(request):
  569. # type: (WSGIRequest)->JsonResponse
  570. """
  571. 获取设备更换记录
  572. :param request:
  573. :return:
  574. """
  575. pageIndex = int(request.GET.get('pageIndex', 1))
  576. pageSize = int(request.GET.get('pageSize', 10))
  577. replace_type = request.GET.get('replaceType', 'replace')
  578. replacements = DeviceReplacement.objects(replaceType = replace_type).paginate(pageIndex,
  579. pageSize) # type: Iterable[DeviceReplacement]
  580. return JsonResponse(
  581. {
  582. 'result': 1,
  583. 'description': '',
  584. 'payload': {
  585. 'total': DeviceReplacement.objects().count(),
  586. 'dataList': [_.to_dict() for _ in replacements]
  587. }
  588. }
  589. )
  590. ##: 日志系统
  591. @error_tolerate(nil = JsonErrorResponse(u'获取网志失败'), logger = logger)
  592. @permission_required(ROLE.supermanager)
  593. def getWebLogs(request):
  594. # type: (WSGIRequest)->JsonResponse
  595. """
  596. 获取日志系统
  597. :param request:
  598. :return:
  599. """
  600. pageIndex = int(request.GET.get('pageIndex', 1))
  601. pageSize = int(request.GET.get('pageSize', 40))
  602. searchKey = request.GET.get('searchKey')
  603. logs = WebLog.objects().search(searchKey) \
  604. .order_by('-createdTime') \
  605. .paginate(pageIndex = pageIndex, pageSize = pageSize) # type: Iterable[WebLog]
  606. total = WebLog.objects().search(searchKey).count() # type: int
  607. return JsonResponse(
  608. {
  609. 'result': 1,
  610. 'description': '',
  611. 'payload':
  612. {
  613. 'dataList': [_.to_dict() for _ in logs],
  614. 'total': total
  615. }
  616. }
  617. )
  618. @error_tolerate(nil = JsonErrorResponse(u'添加日志失败'), logger = logger)
  619. @permission_required(ROLE.supermanager)
  620. def addWebLog(request):
  621. # type: (WSGIRequest)->JsonResponse
  622. """
  623. 添加超级管理员日志
  624. :param request:
  625. :return:
  626. """
  627. currentSuperManagerId = ObjectId(request.user.id)
  628. payload = json.loads(request.body)
  629. payload['superManagerId'] = currentSuperManagerId
  630. WebLog(**payload).save()
  631. return JsonResponse({'result': 1, 'description': u'添加成功'})
  632. @error_tolerate(nil = JsonErrorResponse(u'编辑日志失败'), logger = logger)
  633. @permission_required(ROLE.supermanager)
  634. def editWebLog(request):
  635. # type: (WSGIRequest)->JsonResponse
  636. """
  637. 编辑超级管理员日志
  638. :param request:
  639. :return:
  640. """
  641. payload = json.loads(request.body)
  642. log = WebLog.objects(id = payload['id']).get()
  643. updated = log.update(**payload)
  644. if not updated:
  645. return JsonErrorResponse(description = u'编辑失败')
  646. else:
  647. return JsonResponse({'result': 1, 'description': u'编辑成功', 'payload': {}})
  648. @error_tolerate(nil = JsonErrorResponse(u'查询主设备类型失败'), logger = logger)
  649. @permission_required(ROLE.supermanager)
  650. def getMajorDeviceType(request):
  651. # type: (WSGIRequest)->JsonResponse
  652. """
  653. 查询主设备类型
  654. :param request:
  655. :return:
  656. """
  657. pageIndex = int(request.GET.get('pageIndex', 1))
  658. pageSize = int(request.GET.get('pageSize', 10))
  659. searchKey = request.GET.get('searchKey')
  660. types = MajorDeviceType.objects().search(searchKey).order_by('-createdTime').paginate(pageIndex, pageSize)
  661. return JsonResponse(
  662. {
  663. 'result': 1,
  664. 'payload':
  665. {
  666. 'total': MajorDeviceType.objects().count(),
  667. 'dataList': [{'name': _.name, 'createdTime': _.createdTime} for _ in types]
  668. }
  669. }
  670. )
  671. @error_tolerate(nil = JsonErrorResponse(u'添加主设备类型失败'), logger = logger)
  672. @permission_required(ROLE.supermanager)
  673. def addMajorDeviceType(request):
  674. # type: (WSGIRequest)->JsonResponse
  675. """
  676. :param request:
  677. :return:
  678. """
  679. payload = json.loads(request.body)
  680. try:
  681. MajorDeviceType(name = payload['name']).save()
  682. except NotUniqueError:
  683. return JsonErrorResponse(description = u'该主设备类型名称已经存在')
  684. return JsonResponse({'result': 1, 'description': '', 'payload': ''})
  685. @require_GET
  686. @error_tolerate(nil = JsonErrorResponse(u'获取地址类型失败'), logger = logger)
  687. @permission_required(ROLE.supermanager)
  688. def getAddressType(request):
  689. # type: (WSGIRequest)->JsonResponse
  690. """
  691. :param request:
  692. :return:
  693. """
  694. pageIndex = int(request.GET.get('pageIndex', 1))
  695. pageSize = int(request.GET.get('pageSize', 10))
  696. addressTypes = AddressType.objects.all().order_by('-showWeight')
  697. dataList = [
  698. {
  699. 'value': addressType.value,
  700. 'name': addressType.label,
  701. 'count': addressType.showWeight,
  702. 'createdTime': addressType.createdAt
  703. } for addressType in addressTypes
  704. ]
  705. return JsonResponse(
  706. {
  707. 'result': 1,
  708. 'description': '',
  709. 'payload':
  710. {
  711. 'dataList': dataList[(pageIndex - 1) * pageSize: pageIndex * pageSize],
  712. 'total': len(dataList)
  713. }
  714. }
  715. )
  716. @require_POST
  717. @error_tolerate(nil = JsonErrorResponse(u'添加地址类型失败'), logger = logger)
  718. @permission_required(ROLE.supermanager)
  719. def addAddressType(request):
  720. payload = json.loads(request.body)
  721. try:
  722. obj = AddressType(value = payload['value'], label = payload['name'],
  723. showWeight = payload.get('showWeight', 0)).save()
  724. obj.save()
  725. except NotUniqueError:
  726. return JsonErrorResponse(description = u'添加地址类型失败')
  727. return JsonResponse({'result': 1, 'description': u'添加成功', 'payload': {}})
  728. @require_GET
  729. @error_tolerate(nil = JsonErrorResponse(u'获取代理商列表失败'), logger = logger)
  730. @permission_required(ROLE.supermanager)
  731. def getAgentsDetailList(request):
  732. # type: (WSGIRequest)->JsonResponse
  733. """
  734. :param request:
  735. :return:
  736. """
  737. page_index = int(request.GET.get('pageIndex', 1))
  738. page_size = int(request.GET.get('pageSize', 10))
  739. search_key = request.GET.get('searchKey')
  740. manager_id = request.GET.get('managerId')
  741. moniAppId = request.GET.get('moniAppId', None)
  742. total, items = Agent.filter(manager_id = manager_id, search_key = search_key, page_index = page_index,
  743. page_size = page_size, moniAppId = moniAppId,
  744. shadow = (not request.user.universal_password_login))
  745. return JsonOkResponse(
  746. payload =
  747. {
  748. 'total': total,
  749. 'dataList': items
  750. }
  751. )
  752. @require_GET
  753. @error_tolerate(nil = JsonErrorResponse(u'获取经销商列表失败'), logger = logger)
  754. @permission_required(ROLE.supermanager)
  755. def getDealerDetailList(request):
  756. # type: (WSGIRequest)->JsonResponse
  757. """
  758. :param request:
  759. :return:
  760. """
  761. pageIndex = int(request.GET.get('pageIndex', 1))
  762. pageSize = int(request.GET.get('pageSize', 10))
  763. searchKey = request.GET.get('searchKey')
  764. managerId = request.GET.get('managerId')
  765. agentId = request.GET.get('agentId')
  766. forceFollowGzh = request.GET.get('forceFollowGzh', None)
  767. devCountMin = request.GET.get('devCountMin', None)
  768. devCountMax = request.GET.get('devCountMax', None)
  769. query = {}
  770. # if all([managerId is None, agentId is None]) or not ((managerId is None) ^ (agentId is None)):
  771. # return JsonErrorResponse(description=u'代理商ID和厂商ID只能传递一个')
  772. if managerId is not None:
  773. agentIds = [str(_.id) for _ in Agent.objects(managerId = managerId)]
  774. query['agentId__in'] = agentIds
  775. if agentId is not None:
  776. query['agentId'] = agentId
  777. if forceFollowGzh:
  778. query['forceFollowGzh'] = forceFollowGzh
  779. if devCountMin:
  780. query['devCount__gte'] = devCountMin
  781. if devCountMax:
  782. query['devCount__lte'] = devCountMax
  783. dealers = Dealer.objects(**query).search(searchKey)
  784. total = dealers.count() # type: int
  785. pageAgentIds = []
  786. dealerList = []
  787. for dealer in dealers.order_by('-createdTime').paginate(pageIndex = pageIndex, pageSize = pageSize):
  788. dealerList.append(dealer)
  789. pageAgentIds.append(dealer.agentId)
  790. agentMap = {
  791. str(agent.id): agent # '%s - %s' % (agent.username, agent.nickname)
  792. for agent in Agent.objects(id__in = pageAgentIds)
  793. }
  794. def transform(_):
  795. agent = agentMap[_['agentId']]
  796. _['agentInfo'] = '%s-%s' % (agent.username, agent.nickname)
  797. return _
  798. dataList = []
  799. for dealer in dealerList:
  800. agent = agentMap.get(dealer.agentId)
  801. data = dealer.to_dict(shadow = (not request.user.universal_password_login))
  802. moniAppName = MoniApp.get_app_by_agent(str(agent.id)) # type: moniAppName
  803. data.update(
  804. {
  805. 'productName': agent.productName,
  806. 'moniAppName': moniAppName.appName if moniAppName else "",
  807. 'agentForceFollowGzh': agent.forceFollowGzh,
  808. 'devCount': dealer.devCount,
  809. 'agentInfo': '%s-%s' % (agent.username, agent.nickname),
  810. 'maxPackagePrice': float(str(dealer.maxPackagePrice))
  811. }
  812. )
  813. dataList.append(data)
  814. return JsonOkResponse(
  815. payload =
  816. {
  817. 'total': total,
  818. 'dataList': dataList
  819. }
  820. )
  821. @require_POST
  822. @error_tolerate(nil = JsonErrorResponse(u'封禁/解封失败'), logger = logger)
  823. def toggleDealerStatus(request):
  824. # type: (WSGIRequest)->JsonResponse
  825. """
  826. :param request:
  827. :return:
  828. """
  829. payload = json.loads(request.body) # type: dict
  830. dealer_id = payload.get('id')
  831. normal = payload.get('normal')
  832. if dealer_id is None or normal is None:
  833. return JsonErrorResponse(description = u'dealer id 或 normal 为空')
  834. else:
  835. dealer = Dealer.objects(id = ObjectId(dealer_id)).first()
  836. if not dealer:
  837. return JsonErrorResponse(description = u'找不到经销商')
  838. status = 'abnormal' if not normal else 'normal'
  839. updated = dealer.update(status = status)
  840. if not updated:
  841. return JsonErrorResponse(description = u'更新失败')
  842. else:
  843. return JsonOkResponse()
  844. @require_POST
  845. @error_tolerate(nil = JsonErrorResponse(u'封禁/解封失败'), logger = logger)
  846. def toggleDealerWithdrawStatus(request):
  847. # type: (WSGIRequest)->JsonResponse
  848. """
  849. :param request:
  850. :return:
  851. """
  852. payload = json.loads(request.body) # type: dict
  853. dealer_id = payload.get('dealer_id')
  854. noWithdraw = payload.get('noWithdraw')
  855. if dealer_id is None or noWithdraw is None:
  856. return JsonErrorResponse(description = u'dealer id 或 noWithdraw 为空')
  857. else:
  858. dealer = Dealer.objects(id = ObjectId(dealer_id)).first()
  859. if not dealer:
  860. return JsonErrorResponse(description = u'找不到经销商')
  861. status = 'normal' if not noWithdraw else 'noWithdraw'
  862. updated = dealer.update(status = status)
  863. if not updated:
  864. return JsonErrorResponse(description = u'更新失败')
  865. else:
  866. return JsonOkResponse()
  867. @require_POST
  868. @error_tolerate(nil = JsonErrorResponse(u'编辑广告开关失败'), logger = logger)
  869. @permission_required(ROLE.supermanager)
  870. def editAdShow(request):
  871. # type: (WSGIRequest)->JsonResponse
  872. """
  873. :param request:
  874. :return:
  875. """
  876. payload = json.loads(request.body) # type: dict
  877. def handle_manager(ids, adShow):
  878. # type:(List[str], bool)->bool
  879. Manager.get_collection().update_many(
  880. {'_id': {'$in': [ObjectId(_) for _ in ids]}},
  881. {'$set': {'adShow': adShow}})
  882. agents = Agent.get_collection().find({'managerId': {'$in': ids}})
  883. handle_agent([str(_['_id']) for _ in agents], adShow)
  884. return True
  885. def handle_agent(ids, adShow):
  886. # type:(List[str], bool)->bool
  887. Agent.get_collection().update_many(
  888. {'_id': {'$in': [ObjectId(_) for _ in ids]}},
  889. {'$set': {'adShow': adShow}})
  890. dealers = Dealer.get_collection().find({'agentId': {'$in': ids}})
  891. handle_dealer([str(_['_id']) for _ in dealers], adShow)
  892. return True
  893. def handle_dealer(ids, adShow):
  894. # type:(List[str], bool)->bool
  895. map(lambda _: Dealer.invalid_cache(_), ids)
  896. Dealer.get_collection().update_many(
  897. {'_id': {'$in': [ObjectId(_) for _ in ids]}},
  898. {'$set': {'adShow': adShow}})
  899. return True
  900. handler_map = {
  901. 'manager': handle_manager,
  902. 'agent': handle_agent,
  903. 'dealer': handle_dealer
  904. } # type: Dict[str, Callable]
  905. updated = handler_map[payload['role']](payload['ids'], adShow = payload['adShow'])
  906. if updated:
  907. return JsonOkResponse()
  908. else:
  909. return JsonErrorResponse(description = u'更新失败')
  910. @require_POST
  911. @error_tolerate(nil = JsonErrorResponse(u'编辑流量费用失败'), logger = logger)
  912. @permission_required(ROLE.supermanager)
  913. def setTrafficCardCost(request):
  914. # type: (WSGIRequest)->JsonResponse
  915. """
  916. :param request:
  917. :return:
  918. """
  919. payload = json.loads(request.body) # type: dict
  920. ids = payload.get('ids', [])
  921. cost = payload.get('cost')
  922. if cost is None or not ids:
  923. return JsonErrorResponse(description = u'设置错误,代理商ID列表为空或成本没传入')
  924. if RMB(cost) < RMB(0):
  925. return JsonErrorResponse(description = u'流量卡年费成本价格必须大于0')
  926. updated = Agent.objects(id__in = ids).update(set__trafficCardCost = RMB(cost).mongo_amount)
  927. if updated:
  928. return JsonOkResponse()
  929. else:
  930. return JsonErrorResponse(description = u'更新失败')
  931. @require_POST
  932. @error_tolerate(nil = JsonErrorResponse(u'编辑用户信息失败'), logger = logger)
  933. @permission_required(ROLE.supermanager)
  934. def editUserInfo(request):
  935. # type: (WSGIRequest)->JsonResponse
  936. """
  937. :param request:
  938. :return:
  939. """
  940. payload = json.loads(request.body) # type: dict
  941. id_ = payload.get('id')
  942. role = payload.get('role')
  943. info = payload.get('info', {})
  944. if role == 'dealer':
  945. updated = Dealer.objects(id = id_).update(**info)
  946. elif role == 'agent':
  947. updated = Agent.objects(id = id_).update(**info)
  948. else:
  949. return JsonErrorResponse(description = u'不支持编辑的角色')
  950. if updated:
  951. return JsonOkResponse(description = u'编辑成功')
  952. else:
  953. return JsonErrorResponse(description = u'编辑失败')
  954. # Commands
  955. @require_GET
  956. @error_tolerate(nil = JsonErrorResponse(u'获取命令列表失败'), logger = logger)
  957. @permission_required(ROLE.supermanager)
  958. def getDeviceCommands(request):
  959. # type: (WSGIRequest)->JsonResponse
  960. """
  961. :param request:
  962. :return:
  963. """
  964. pageIndex = int(request.GET.get("pageIndex"))
  965. pageSize = int(request.GET.get("pageSize"))
  966. searchKey = request.GET.get('searchKey')
  967. field = request.GET.get('field')
  968. if searchKey and field:
  969. field = None if field == "*" else field
  970. querySet = DeviceCommand.objects.search(searchKey, fields = [field])
  971. else:
  972. querySet = DeviceCommand.objects
  973. total = querySet.count()
  974. dataList = list()
  975. for _item in querySet.paginate(pageIndex, pageSize):
  976. dataList.append(_item.to_dict())
  977. return JsonOkResponse(payload = {"dataList": dataList, "total": total})
  978. @require_POST
  979. @error_tolerate(nil = JsonErrorResponse(u'添加命令失败'), logger = logger)
  980. @permission_required(ROLE.supermanager)
  981. def addDeviceCommand(request):
  982. # type: (WSGIRequest)->JsonResponse
  983. """
  984. :param request:
  985. :return:
  986. """
  987. payload = json.loads(request.body)
  988. params = payload.pop("params", None)
  989. command = DeviceCommand(**payload)
  990. if params:
  991. commandParams = [DeviceCommandParam(**_item) for _item in params]
  992. command.params = commandParams
  993. command.save()
  994. return JsonOkResponse(description = u"命令添加成功")
  995. @require_POST
  996. @error_tolerate(nil = JsonErrorResponse(u'编辑命令失败'), logger = logger)
  997. @permission_required(ROLE.supermanager)
  998. def editDeviceCommand(request):
  999. # type: (WSGIRequest)->JsonResponse
  1000. """
  1001. :param request:
  1002. :return:
  1003. """
  1004. payload = json.loads(request.body)
  1005. commandId = payload.pop("id")
  1006. updated = DeviceCommand.objects.filter(id = commandId).update(**payload)
  1007. if updated:
  1008. return JsonOkResponse(description = u"命令更新成功")
  1009. else:
  1010. return JsonErrorResponse(description = u'编辑命令更新失败')
  1011. @require_POST
  1012. @error_tolerate(nil = JsonErrorResponse(u'删除命令失败'), logger = logger)
  1013. @permission_required(ROLE.supermanager)
  1014. def deleteDeviceCommand(request):
  1015. # type: (WSGIRequest)->JsonResponse
  1016. """
  1017. :param request:
  1018. :return:
  1019. """
  1020. payload = json.loads(request.body) if request.body else {}
  1021. result = DeviceCommand.objects(id__in = payload['ids']).delete()
  1022. if result:
  1023. return JsonOkResponse()
  1024. else:
  1025. return JsonErrorResponse(description = u'删除失败')
  1026. @error_tolerate(nil = JsonErrorResponse(u'获取地图失败'), logger = logger)
  1027. @permission_required(ROLE.supermanager)
  1028. def getDevMapChart(request):
  1029. # type: (WSGIRequest)->JsonResponse
  1030. return JsonOkResponse(payload = {'dataList': []})
  1031. @error_tolerate(nil = JsonErrorResponse(u'获取收入趋势失败'), logger = logger)
  1032. @permission_required(ROLE.supermanager)
  1033. def getIncomeTrend(request):
  1034. return JsonOkResponse(payload = {'dataList': []})
  1035. @error_tolerate(nil = JsonErrorResponse(u'获取设备类型统计失败'), logger = logger)
  1036. @permission_required(ROLE.supermanager)
  1037. def getDeviceTypeStatistics(request):
  1038. return JsonOkResponse(payload = {'dataList': []})
  1039. @error_tolerate(nil = JsonErrorResponse(u'获取经销商收入和失败'), logger = logger)
  1040. @permission_required(ROLE.supermanager)
  1041. def getDealerIncomeTotalTop(request):
  1042. return JsonOkResponse(payload = {'dataList': []})
  1043. @error_tolerate(nil = JsonErrorResponse(u'获取用户趋势失败'), logger = logger)
  1044. @permission_required(ROLE.supermanager)
  1045. def getAllUserTrend(request):
  1046. return JsonOkResponse(payload = {'dataList': []})
  1047. @error_tolerate(nil = JsonErrorResponse(u'获取设备注册趋势失败'), logger = logger)
  1048. @permission_required(ROLE.supermanager)
  1049. def getDeviceRegTrend(request):
  1050. return JsonOkResponse(payload = {'dataList': []})
  1051. @error_tolerate(nil = JsonErrorResponse(u'获取反馈趋势失败'), logger = logger)
  1052. @permission_required(ROLE.supermanager)
  1053. def getAllFeedbackTrend(request):
  1054. return JsonOkResponse(payload = {'dataList': []})
  1055. @error_tolerate(nil = JsonErrorResponse(u'获取提现记录失败'), logger = logger)
  1056. @permission_required(ROLE.supermanager)
  1057. def getWithdrawTrend(request):
  1058. return JsonOkResponse(payload = {'dataList': []})
  1059. # noinspection PyUnresolvedReferences
  1060. @error_tolerate(nil = JsonErrorResponse(u'导入sim卡数据失败'), logger = logger)
  1061. @permission_required(ROLE.supermanager)
  1062. def importSim(request):
  1063. current_user = request.user # type: SuperManager
  1064. def get_offline_task_name(task_type, user, source):
  1065. # type: (basestring, SuperManager, str)->basestring
  1066. now_time = datetime.datetime.now()
  1067. tmp_list = [task_type, user.username, source, now_time.strftime('%Y-%m-%d %H:%M:%S'),
  1068. str(utils_datetime.generate_timestamp_ex())]
  1069. return '-'.join(tmp_list)
  1070. payload = json.loads(request.body)
  1071. excel_file = payload.get('file')
  1072. source = payload.get('source')
  1073. offline_task_name = get_offline_task_name(
  1074. task_type = OfflineTaskType.IMPORT_SIM_CARD,
  1075. user = current_user,
  1076. source = source)
  1077. offline_task = OfflineTask.issue(offline_task_name = offline_task_name,
  1078. process_func_name = 'import_simcard_excel_to_db',
  1079. task_type = OfflineTaskType.IMPORT_SIM_CARD,
  1080. userid = str(current_user.id),
  1081. role = ROLE.supermanager)
  1082. task_caller(offline_task.process_func_name,
  1083. offline_task_id = str(offline_task.id),
  1084. excelFile = excel_file,
  1085. source = source)
  1086. return JsonResponse({
  1087. 'result': 1,
  1088. 'description': u'成功创建任务,请您在sim卡任务管理中,查看任务执行情况',
  1089. 'payload': {
  1090. 'offline_task_id': str(offline_task.id)
  1091. }})
  1092. @error_tolerate(nil = JsonErrorResponse(u'查询sim卡数据失败'), logger = logger)
  1093. @permission_required(ROLE.supermanager)
  1094. def getSimCardList(request):
  1095. pageIndex = int(request.GET.get('pageIndex', 1))
  1096. pageSize = int(request.GET.get('pageSize', 10))
  1097. startTimeStr = request.GET.get('startTime', None)
  1098. endTimeStr = request.GET.get('endTime', None)
  1099. searchType = request.GET.get('searchType', '')
  1100. searchKey = request.GET.get('searchKey', '')
  1101. simCardSource = request.GET.get('simCardSource', '')
  1102. startTime = datetime.datetime.strptime(startTimeStr + ' 00:00:00', "%Y-%m-%d %H:%M:%S")
  1103. endTime = datetime.datetime.strptime(endTimeStr + ' 23:59:59', "%Y-%m-%d %H:%M:%S")
  1104. queryArr = ['expireTime__gte=startTime', 'expireTime__lte=endTime']
  1105. if searchType == 'IMSI' and searchKey != '':
  1106. queryArr.append('imsi=searchKey')
  1107. elif searchType == 'ICCID' and searchKey != '':
  1108. queryArr.append('iccid=searchKey')
  1109. else:
  1110. pass
  1111. if simCardSource != '':
  1112. queryArr.append('supplier=searchKey')
  1113. query = ','.join(queryArr)
  1114. ss = eval('SIMCard.objects({})'.format(query))
  1115. dataList = []
  1116. for _ in ss.paginate(pageIndex, pageSize):
  1117. device = Device.objects(iccid = _.iccid).first()
  1118. if device is not None:
  1119. dealer = Dealer.objects(id = device.ownerId).first()
  1120. logicalCode = device.logicalCode
  1121. if dealer is not None:
  1122. dealerStr = dealer.nickname + '_' + dealer.username + '_' + device.ownerId
  1123. agent = Agent.objects(id = dealer.agentId).first()
  1124. if agent is not None:
  1125. agentStr = agent.nickname + '_' + agent.username + '_' + dealer.agentId
  1126. manager = Manager.objects(id = agent.managerId).first()
  1127. if manager is not None:
  1128. managerStr = manager.nickname + '_' + manager.username + '_' + agent.managerId
  1129. else:
  1130. managerStr = ''
  1131. else:
  1132. agentStr = ''
  1133. managerStr = ''
  1134. else:
  1135. dealerStr = ''
  1136. agentStr = ''
  1137. managerStr = ''
  1138. else:
  1139. logicalCode = ''
  1140. dealerStr = ''
  1141. agentStr = ''
  1142. managerStr = ''
  1143. dataList.append({
  1144. 'imsi': _.imsi,
  1145. 'iccid': _.iccid,
  1146. 'simCardBrand': _.supplier,
  1147. 'expireDate': _.expireTime,
  1148. 'logicalCode': logicalCode,
  1149. 'dealerStr': dealerStr,
  1150. 'agentStr': agentStr,
  1151. 'managerStr': managerStr
  1152. })
  1153. return JsonResponse({'result': 1, 'description': '', 'payload': {'total': ss.count(), 'dataList': dataList}})
  1154. @error_tolerate(nil = DefaultJsonErrorResponse)
  1155. @permission_required(ROLE.supermanager)
  1156. def getOfflineTaskList(request):
  1157. # type: (WSGIRequest)->JsonResponse
  1158. """
  1159. 获取离线任务列表
  1160. :param request:
  1161. :return:
  1162. """
  1163. current_user = request.user # type: SuperManager
  1164. page_index = int(request.GET.get('pageIndex', 1))
  1165. page_size = int(request.GET.get('pageSize', 10))
  1166. search_key = request.GET.get('searchKey', None)
  1167. tasks = OfflineTask.objects(ownerId = current_user.id,
  1168. role = current_user.role).search(search_key).order_by('-dateTimeAdded')
  1169. total = tasks.count()
  1170. return JsonOkResponse(
  1171. payload = {
  1172. 'dataList': [t.to_dict() for t in tasks.paginate(pageSize = page_size, pageIndex = page_index)],
  1173. 'total': total
  1174. })
  1175. @error_tolerate(nil = DefaultJsonErrorResponse)
  1176. @permission_required(ROLE.supermanager)
  1177. def getOfflineTaskStatus(request):
  1178. # type: (WSGIRequest)->JsonResponse
  1179. task_id = request.GET.get('id')
  1180. if not task_id:
  1181. return JsonErrorResponse(description = u'查询ID为空')
  1182. task = OfflineTask.objects(id = str(task_id)).get() # type: OfflineTask
  1183. return JsonOkResponse(payload = task.status)
  1184. # noinspection PyUnresolvedReferences
  1185. @error_tolerate(nil = JsonErrorResponse(u'导入sim卡数据失败'), logger = logger)
  1186. @permission_required(ROLE.supermanager)
  1187. def exportExcel(request):
  1188. super_manager = request.user # type: SuperManager
  1189. def get_offline_task_name(task_type, user, **kwargs):
  1190. # type: (basestring, SuperManager, Dict)->basestring
  1191. tmp_list = [task_type, user.username]
  1192. if kwargs['simCardSource'] and kwargs['simCardSource']:
  1193. tmp_list.append(kwargs['simCardSource'])
  1194. tmp_list.append(u'%s至%s' % (kwargs['startTimeStr'], kwargs['endTimeStr']))
  1195. tmp_list.append(str(utils_datetime.generate_timestamp_ex()))
  1196. return '-'.join(tmp_list).replace("/", "_")
  1197. query_dict = {
  1198. 'startTimeStr': request.GET.get('startTime', None),
  1199. 'endTimeStr': request.GET.get('endTime', None),
  1200. 'searchKey': request.GET.get('searchKey', ''),
  1201. 'searchType': request.GET.get('searchType', ''),
  1202. 'simCardSource': request.GET.get('simCardSource', '')
  1203. }
  1204. offline_task_name = get_offline_task_name(
  1205. task_type = OfflineTaskType.EXPORT_SIM_CARD,
  1206. user = super_manager,
  1207. **query_dict)
  1208. file_path, offline_task = OfflineTask.issue_export_report(offline_task_name = offline_task_name,
  1209. process_func_name = 'export_simcard_excel_from_db',
  1210. task_type = OfflineTaskType.EXPORT_SIM_CARD,
  1211. userid = str(super_manager.id),
  1212. role = ROLE.supermanager)
  1213. task_caller(func_name = str(offline_task.process_func_name),
  1214. offline_task_id = str(offline_task.id),
  1215. filepath = file_path,
  1216. queryDict = query_dict)
  1217. return JsonResponse({
  1218. 'result': 1,
  1219. 'description': u"请前往离线任务查看任务处理情况",
  1220. 'payload': str(offline_task.id)
  1221. })
  1222. @error_tolerate(nil = JsonErrorResponse(u'导出设备数据失败'), logger = logger)
  1223. @permission_required(ROLE.supermanager)
  1224. def exportDevice(request):
  1225. super_manager = request.user # type: SuperManager
  1226. def get_offline_task_name(task_type, user, **kwargs):
  1227. # type: (basestring, SuperManager, Dict)->basestring
  1228. tmp_list = [task_type, user.username]
  1229. tmp_list.append(u'设备信息')
  1230. tmp_list.append(str(utils_datetime.generate_timestamp_ex()))
  1231. return '-'.join(tmp_list).replace("/", "_")
  1232. query_dict = {
  1233. 'logicalCodeList': list(set(request.GET.getlist('logicalCodeList', None)))
  1234. }
  1235. offline_task_name = get_offline_task_name(
  1236. task_type = OfflineTaskType.EXPORT_DEVICE,
  1237. user = super_manager,
  1238. **query_dict)
  1239. file_path, offline_task = OfflineTask.issue_export_report(offline_task_name = offline_task_name,
  1240. process_func_name = 'export_device_excel_from_db',
  1241. task_type = OfflineTaskType.EXPORT_DEVICE,
  1242. userid = str(super_manager.id),
  1243. role = ROLE.supermanager)
  1244. task_caller(func_name = str(offline_task.process_func_name),
  1245. offline_task_id = str(offline_task.id),
  1246. filepath = file_path,
  1247. queryDict = query_dict)
  1248. return JsonResponse({
  1249. 'result': 1,
  1250. 'description': u"请前往离线任务查看任务处理情况",
  1251. 'payload': str(offline_task.id)
  1252. })
  1253. @error_tolerate(nil = JsonErrorResponse(u'查询管理日志失败'), logger = logger)
  1254. @permission_required(ROLE.supermanager)
  1255. def getAdminLog(request):
  1256. pageIndex = int(request.GET.get('pageIndex', 1))
  1257. pageSize = int(request.GET.get('pageSize', 10))
  1258. startTime = request.GET.get('startTime', None)
  1259. endTime = request.GET.get('endTime', None)
  1260. searchKey = request.GET.get('searchKey', '')
  1261. return JsonResponse({'result': 1, 'description': '', 'payload': {'total': 0, 'dataList': []}})
  1262. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  1263. @permission_required(ROLE.supermanager)
  1264. def getAliApp(request):
  1265. # type: (WSGIRequest)->JsonResponse
  1266. """
  1267. 更改微信资金平台APP信息
  1268. :param request:
  1269. :return:
  1270. """
  1271. appid = str(request.GET.get('appid'))
  1272. app = AliApp.objects(appid = appid).first() # type: AliApp
  1273. if not app:
  1274. return JsonOkResponse(payload = {})
  1275. else:
  1276. return JsonOkResponse(payload = app.to_dict())
  1277. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  1278. @permission_required(ROLE.supermanager)
  1279. def bindAliApp(request):
  1280. # type: (WSGIRequest)->JsonResponse
  1281. """
  1282. 绑定自定义支付宝
  1283. :param request:
  1284. :return:
  1285. """
  1286. payload = json.loads(request.body) # type: dict
  1287. return api.bindAliApp(payload)
  1288. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  1289. @permission_required(ROLE.supermanager)
  1290. def bindWechatFund(request):
  1291. # type: (WSGIRequest)->JsonResponse
  1292. """
  1293. 绑定自定义微信公众号
  1294. :param request:
  1295. :return:
  1296. """
  1297. payload = json.loads(request.body) # type: dict
  1298. return api.bindWechatFund(payload)
  1299. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  1300. @permission_required(ROLE.supermanager)
  1301. def bindWechatCust(request):
  1302. # type: (WSGIRequest)->JsonResponse
  1303. """
  1304. 绑定自定义微信公众号
  1305. :param request:
  1306. :return:
  1307. """
  1308. payload = json.loads(request.body) # type: dict
  1309. return api.bindWechatCust(payload)
  1310. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  1311. @permission_required(ROLE.supermanager)
  1312. def getWechatFundApp(request):
  1313. # type: (WSGIRequest)->JsonResponse
  1314. """
  1315. 更改微信资金平台APP信息
  1316. :param request:
  1317. :return:
  1318. """
  1319. appid = request.GET.get('appid')
  1320. mchid = request.GET.get('mchid')
  1321. app = WechatPayApp.objects(appid = appid, mchid = mchid).first() # type: WechatPayApp
  1322. if not app:
  1323. return JsonOkResponse(payload = {})
  1324. else:
  1325. return JsonOkResponse(payload = app.to_dict())
  1326. @error_tolerate(nil = DefaultJsonErrorResponse, logger = logger)
  1327. @permission_required(ROLE.supermanager)
  1328. def sendCommand(request):
  1329. # type: (WSGIRequest)->JsonResponse
  1330. """
  1331. :param request:
  1332. :return:
  1333. """
  1334. payload = json.loads(request.body)
  1335. devNo = payload.get("devNo")
  1336. cmdID = payload.get("id")
  1337. params = payload.get("params", list())
  1338. dev = Device.get_dev(devNo)
  1339. if not dev:
  1340. return JsonErrorResponse(u"设备获取失败,请尝试重新发送指令")
  1341. command = DeviceCommand.objects.filter(id = cmdID, role = request.user.role).first()
  1342. if not command:
  1343. return JsonErrorResponse(u"命令获取失败,请尝试重新发送指令")
  1344. try:
  1345. commandDict = command.package_command(dev, params)
  1346. except Exception as e:
  1347. logger.exception(u"dev <{}>, command <{}> , package command error <{}>".format(devNo, cmdID, e))
  1348. return JsonErrorResponse(u"命令发送失败,请尝试重新发送指令")
  1349. cmd = commandDict.get("cmd")
  1350. try:
  1351. result = MessageSender.send(dev, cmd = cmd, payload = commandDict, timeout = 20)
  1352. if result.get("rst") == -1:
  1353. raise ManagerServiceTimeOutException()
  1354. if result.get("rst") == 1:
  1355. raise ManagerServiceSerialException()
  1356. except ServiceException as se:
  1357. return JsonErrorResponse(description = se.result.get("description"))
  1358. except Exception as e:
  1359. logger.exception('failed to send command, error = %s where command was %s' % (e, str(command)))
  1360. return JsonErrorResponse(description = u"指令发送异常")
  1361. return JsonResponse({'result': 1, 'description': u'发送成功', 'payload': json.dumps(result)})
  1362. @error_tolerate(nil = DefaultJsonErrorResponse)
  1363. @permission_required(ROLE.supermanager)
  1364. def getCommandByDevice(request):
  1365. # type: (WSGIRequest)->JsonResponse
  1366. """
  1367. :param request:
  1368. :return:
  1369. """
  1370. logicalCode = request.GET.get('logicalCode')
  1371. commands = DeviceCommand.common_and_type_specific(
  1372. logicalCode = logicalCode,
  1373. commander = request.user
  1374. )
  1375. return JsonResponse({
  1376. 'result': 1,
  1377. 'description': '',
  1378. 'payload': {"dataList": commands}
  1379. })
  1380. @error_tolerate(nil = DefaultJsonErrorResponse)
  1381. @permission_required(ROLE.supermanager)
  1382. def getSimDetail(request):
  1383. # type: (WSGIRequest)->JsonResponse
  1384. """
  1385. :param request:
  1386. :return:
  1387. """
  1388. iccid = request.GET.get('iccid')
  1389. if not iccid:
  1390. return JsonResponse({'result': 0, 'description': u'ICCID不合法', 'payload': ''})
  1391. sim = SIMCard.objects().filter(iccid = iccid).first() # type: SIMCard
  1392. if not sim:
  1393. payload = {
  1394. }
  1395. else:
  1396. payload = {
  1397. 'iccid': sim.iccid,
  1398. 'imsi': sim.imsi,
  1399. 'supplier': sim.supplier,
  1400. 'activeTime': sim.activeTime,
  1401. 'expireTime': sim.expireTime,
  1402. 'chargeTime': sim.chargeTime
  1403. }
  1404. if (not payload) or (payload['supplier'] == 'qiben'):
  1405. try:
  1406. response = SimManager().get_card_list(begin_iccid = iccid, end_iccid = iccid, card_type = 2)
  1407. if len(response['records']) > 0:
  1408. record = response['records'][0]
  1409. payload.update({
  1410. 'qiben_openCardTime': record['openCardTime'],
  1411. 'qiben_activateTime': record['activateTime'],
  1412. 'qiben_packageTime': record['packageTime'],
  1413. 'qiben_totalFlow': record['totalFlow'],
  1414. 'qiben_cardFlow': record['cardFlow'],
  1415. 'qiben_leftFlow': record['leftFlow'],
  1416. 'qiben_cardStatus': record['cardStatus']
  1417. })
  1418. except Exception as e:
  1419. logger.exception(e)
  1420. return JsonResponse({
  1421. 'result': 1,
  1422. 'description': '',
  1423. 'payload': payload
  1424. })
  1425. @error_tolerate(logger = logger, nil = JsonErrorResponse(u'二维码文件存储失败,请重新试试'))
  1426. @permission_required(ROLE.supermanager)
  1427. def uploadMoniQrcode(request):
  1428. # type: (WSGIRequest)->JsonResponse
  1429. files = request.FILES.getlist('file')
  1430. if not len(files):
  1431. return JsonResponse({'result': 0, 'description': u'未找到上传的二维码文件,请重新试试', 'payload': ''})
  1432. uploader = AliOssFileUploader(inputFile = request.FILES.getlist('file')[0], uploadType = 'qrcode')
  1433. logger.info('[uploadMoniQrcode] %s is being used' % (repr(uploader),))
  1434. try:
  1435. outputUrl = uploader.upload()
  1436. return JsonResponse({'result': 1, 'description': '', 'payload': outputUrl})
  1437. except InvalidFileSize, e:
  1438. logger.info(
  1439. '%s(id=%s)\'s uploaded file reached limit' % (request.user.__class__.__name__, str(request.user.id),))
  1440. return JsonResponse({'result': 0, 'description': e.message, 'payload': {}})
  1441. except InvalidFileName, e:
  1442. logger.info(
  1443. '%s(id=%s)\'s uploaded file name is not legal' % (request.user.__class__.__name__, str(request.user.id),))
  1444. return JsonResponse({'result': 0, 'description': e.message, 'payload': {}})
  1445. @error_tolerate(nil = DefaultJsonErrorResponse)
  1446. @permission_required(ROLE.supermanager)
  1447. def getMoniApps(request):
  1448. pageIndex = int(request.GET.get('pageIndex', 1))
  1449. pageSize = int(request.GET.get('pageSize', 40))
  1450. objs = MoniApp.objects.all()
  1451. dataList = []
  1452. total = objs.count()
  1453. for obj in objs.paginate(pageIndex = pageIndex, pageSize = pageSize):
  1454. dataList.append({
  1455. 'appName': obj.appName,
  1456. 'appId': obj.appId,
  1457. 'rawAppId': obj.rawAppId,
  1458. 'secret': obj.secret,
  1459. 'appType': obj.appType,
  1460. 'priority': obj.priority,
  1461. 'status': obj.status,
  1462. 'desc': obj.desc,
  1463. 'title': obj.title,
  1464. 'maxDayAddingCount': obj.maxDayAddingCount
  1465. })
  1466. return JsonOkResponse(payload = {'total': total, 'dataList': dataList})
  1467. def createMenu(appId, secret):
  1468. grzx = {
  1469. 'type': 'view',
  1470. 'name': u'个人中心',
  1471. 'url': "http://www.washpayer.com/user/moniUserAccess?moniAppId=%s&redirect=%s" % (appId, 'gerenzhongxin')
  1472. }
  1473. dangqianfuwu = {
  1474. 'type': 'view',
  1475. 'name': u'当前服务',
  1476. 'url': "http://www.washpayer.com/user/moniUserAccess?moniAppId=%s&redirect=%s" % (appId, 'dangqianfuwu')
  1477. }
  1478. changjianwenti = {
  1479. 'type': 'view',
  1480. 'name': u'常见问题',
  1481. 'url': "http://www.washpayer.com/user/moniUserAccess?moniAppId=%s&redirect=%s" % (appId, 'changjianwenti')
  1482. }
  1483. baogaolaoban = {
  1484. 'type': 'view',
  1485. 'name': u'报告老板',
  1486. 'url': "http://www.washpayer.com/user/moniUserAccess?moniAppId=%s&redirect=%s" % (appId, 'baogaolaoban')
  1487. }
  1488. toushushouli = {
  1489. 'type': 'view',
  1490. 'name': u'投诉受理',
  1491. 'url': "http://www.washpayer.com/user/moniUserAccess?moniAppId=%s&redirect=%s" % (appId, 'toushushouli')
  1492. }
  1493. menu = {
  1494. "button":
  1495. [
  1496. {
  1497. "name": u"服务&投诉",
  1498. "sub_button": [dangqianfuwu, changjianwenti, baogaolaoban, toushushouli]
  1499. },
  1500. {
  1501. "type": "scancode_push",
  1502. "name": u"扫一扫",
  1503. "key": "rselfmenu_0_1",
  1504. "sub_button": []
  1505. },
  1506. grzx
  1507. ]
  1508. }
  1509. app = WechatAuthApp(appid = appId, secret = secret)
  1510. proxy = WechatClientProxy(app)
  1511. proxy.client.menu.create(menu)
  1512. @error_tolerate(nil = DefaultJsonErrorResponse)
  1513. @permission_required(ROLE.supermanager)
  1514. def editMoniApp(request):
  1515. payload = json.loads(request.body)
  1516. appId = payload.get('appId', None)
  1517. if appId is None:
  1518. MoniApp.get_collection().insert(payload)
  1519. # 如果是新增加,需要生成菜单
  1520. createMenu(appId, payload['secret'])
  1521. else:
  1522. MoniApp.get_collection().update({'appId': appId}, {'$set': payload}, upsert = True)
  1523. return JsonOkResponse()
  1524. @error_tolerate(nil = DefaultJsonErrorResponse)
  1525. @permission_required(ROLE.supermanager)
  1526. def deleteMoniApp(request):
  1527. payload = json.loads(request.body)
  1528. appIds = payload.get('ids', None)
  1529. MoniApp.get_collection().remove({'appId': {'$in': appIds}})
  1530. return JsonOkResponse()
  1531. @error_tolerate(nil = DefaultJsonErrorResponse)
  1532. @permission_required(ROLE.supermanager)
  1533. def addMoniAppToAgents(request):
  1534. payload = json.loads(request.body)
  1535. agentIds = [ObjectId(_) for _ in payload.get('agentIds', [])]
  1536. moniAppIds = payload.get('moniAppIds', [])
  1537. agents = Agent.objects.filter(id__in = agentIds)
  1538. for agent in agents:
  1539. for appId in moniAppIds:
  1540. if appId not in agent.moniAppList:
  1541. agent.moniAppList.append(appId)
  1542. agent.save()
  1543. return JsonOkResponse()
  1544. @error_tolerate(nil = DefaultJsonErrorResponse)
  1545. @permission_required(ROLE.supermanager)
  1546. def removeMoniAppFromAgents(request):
  1547. payload = json.loads(request.body)
  1548. agentIds = [ObjectId(_) for _ in payload.get('agentIds', [])]
  1549. moniAppId = payload.get('moniAppId', None)
  1550. if moniAppId is None:
  1551. return JsonErrorResponse(description = u'未传入moni appId')
  1552. agents = Agent.objects.filter(id__in = agentIds)
  1553. for agent in agents:
  1554. if moniAppId in agent.moniAppList:
  1555. agent.moniAppList.remove(moniAppId)
  1556. agent.save()
  1557. return JsonOkResponse()
  1558. @error_tolerate(nil = DefaultJsonErrorResponse)
  1559. @permission_required(ROLE.supermanager)
  1560. def queryAgentsForMoniApp(request):
  1561. page_index = int(request.GET.get('pageIndex', 1))
  1562. page_size = int(request.GET.get('pageSize', 10))
  1563. moniAppId = request.GET.get('moniAppId', None)
  1564. if moniAppId is None:
  1565. return JsonErrorResponse(description = u'未传入moni appId')
  1566. total, items = Agent.filter(moniAppList = moniAppId, page_index = page_index,
  1567. page_size = page_size)
  1568. return JsonOkResponse(
  1569. payload =
  1570. {
  1571. 'total': total,
  1572. 'dataList': items
  1573. }
  1574. )
  1575. @error_tolerate(nil = DefaultJsonErrorResponse)
  1576. @permission_required(ROLE.supermanager)
  1577. def getCheckPointForAgent(request):
  1578. agentId = request.GET.get('agentId')
  1579. agent = Agent.objects.get(id = agentId)
  1580. pointDict = agent.moniAppCheckPointDict
  1581. return JsonOkResponse(payload = {'data': pointDict})
  1582. @error_tolerate(nil = DefaultJsonErrorResponse)
  1583. @permission_required(ROLE.supermanager)
  1584. def getCheckPointForDealer(request):
  1585. dealerId = request.GET.get('dealerId')
  1586. dealer = Dealer.objects.get(id = dealerId)
  1587. agent = Agent.objects.get(id = dealer.agentId)
  1588. return JsonOkResponse(
  1589. payload = {'dealerData': dealer.moniAppCheckPointDict, 'agentData': agent.moniAppCheckPointDict})
  1590. @error_tolerate(nil = DefaultJsonErrorResponse)
  1591. @permission_required(ROLE.supermanager)
  1592. def setCheckPointForAgents(request):
  1593. payload = json.loads(request.body)
  1594. agentIds = [ObjectId(_) for _ in payload.get('agentIds', [])]
  1595. pointDict = payload.get('pointDict')
  1596. agents = Agent.objects.filter(id__in = agentIds)
  1597. for agent in agents:
  1598. agent.moniAppCheckPointDict = pointDict
  1599. agent.save()
  1600. return JsonOkResponse()
  1601. @error_tolerate(nil = DefaultJsonErrorResponse)
  1602. @permission_required(ROLE.supermanager)
  1603. def setCheckPointForDealers(request):
  1604. payload = json.loads(request.body)
  1605. dealerIds = [ObjectId(_) for _ in payload.get('dealerIds', [])]
  1606. pointDict = payload.get('pointDict')
  1607. dealers = Dealer.objects.filter(id__in = dealerIds)
  1608. for dealer in dealers:
  1609. dealer.moniAppCheckPointDict = pointDict
  1610. dealer.save()
  1611. return JsonOkResponse()
  1612. def getMoniPointList(request):
  1613. pageIndex = int(request.GET.get('pageIndex', 1))
  1614. pageSize = int(request.GET.get('pageSize', 10))
  1615. objs = MoniAppPoint.objects.all()
  1616. dataList = [{'id': str(obj.id), 'key': obj.key, 'desc': obj.desc, 'name': obj.name} for obj in
  1617. objs.paginate(pageIndex = pageIndex, pageSize = pageSize)]
  1618. return JsonOkResponse(payload = {'dataList': dataList, 'total': objs.count()})
  1619. def editMoniPoint(request):
  1620. payload = json.loads(request.body)
  1621. objId = payload.get('id', None)
  1622. if objId is None:
  1623. MoniAppPoint.get_collection().insert(payload)
  1624. else:
  1625. MoniAppPoint.get_collection().update({'_id': ObjectId(objId)}, {
  1626. '$set': {'name': payload['name'], 'key': payload['key'], 'desc': payload['desc']}}, upsert = True)
  1627. return JsonOkResponse()
  1628. def deleteMoniPoint(request):
  1629. payload = json.loads(request.body)
  1630. ids = [ObjectId(_) for _ in payload.get('ids', [])]
  1631. MoniAppPoint.get_collection().remove({'_id': {'$in': ids}})
  1632. return JsonOkResponse()
  1633. def editMoniAppForAgents(request):
  1634. payload = json.loads(request.body)
  1635. agentIds = [ObjectId(_) for _ in payload.get('agentIds', [])]
  1636. moniApps = payload.get('moniApp')
  1637. agents = Agent.objects.filter(id__in = agentIds)
  1638. for agent in agents:
  1639. for moniApp in moniApps:
  1640. if moniApp['switch'] and (moniApp['appId'] not in agent.moniAppList):
  1641. agent.moniAppList.append(moniApp['appId'])
  1642. elif (not moniApp['switch']) and (moniApp['appId'] in agent.moniAppList):
  1643. agent.moniAppList.remove(moniApp['appId'])
  1644. agent.save()
  1645. return JsonOkResponse()
  1646. def editMoniPointForAgents(request):
  1647. payload = json.loads(request.body)
  1648. agentIds = [ObjectId(_) for _ in payload.get('agentIds', [])]
  1649. points = payload.get('moniPoint')
  1650. agents = Agent.objects.filter(id__in = agentIds)
  1651. for agent in agents:
  1652. for point in points:
  1653. agent.moniAppCheckPointDict.update({point['key']: point['switch']})
  1654. agent.save()
  1655. return JsonOkResponse()
  1656. def editMoniPointForDealers(request):
  1657. payload = json.loads(request.body)
  1658. dealerIds = [ObjectId(_) for _ in payload.get('dealerIds', [])]
  1659. points = payload.get('moniPoint')
  1660. dealers = Dealer.objects.filter(id__in = dealerIds)
  1661. for dealer in dealers:
  1662. for point in points:
  1663. dealer.moniAppCheckPointDict.update({point['key']: point['switch']})
  1664. dealer.save()
  1665. return JsonOkResponse()
  1666. def editDealerFollowGzh(request):
  1667. payload = json.loads(request.body)
  1668. dealerIds = [ObjectId(_) for _ in payload.get('ids', [])]
  1669. forceFollowGzh = payload.get('forceFollowGzh', 'agent')
  1670. if forceFollowGzh != 'never':
  1671. dealers = Dealer.objects.filter(id__in = dealerIds, forceFollowGzh__ne = 'never')
  1672. else:
  1673. dealers = Dealer.objects.filter(id__in = dealerIds)
  1674. needDealerIds = []
  1675. for dealer in dealers:
  1676. # 如果代理商已经never了,这里不允许更新
  1677. agent = Agent.objects.get(id = dealer.agentId)
  1678. if agent.forceFollowGzhForDealer == 'never':
  1679. continue
  1680. needDealerIds.append(dealer.id)
  1681. Dealer.get_collection().update({'_id': {'$in': needDealerIds}}, {'$set': {'forceFollowGzh': forceFollowGzh}},
  1682. multi = True)
  1683. return JsonOkResponse()
  1684. # def editDealerFollowGzh(request):
  1685. # payload = json.loads(request.body)
  1686. # dealerIds = [ObjectId(_) for _ in payload.get('ids',[])]
  1687. # forceFollowGzh = payload.get('forceFollowGzh','agent')
  1688. # Dealer.get_collection().update({'_id':{'$in':dealerIds}},{'$set':{'forceFollowGzh':forceFollowGzh}},multi = True)
  1689. # return JsonOkResponse()
  1690. #### FAQ
  1691. @error_tolerate(nil = DefaultJsonErrorResponse)
  1692. @permission_required(ROLE.supermanager)
  1693. def getFAQDetailList(request):
  1694. # type: (WSGIRequest)->JsonResponse
  1695. """
  1696. 超级管理员获取FAQ列表
  1697. :param request:
  1698. :return:
  1699. """
  1700. faqs = FAQ.objects(managerId = '')
  1701. return JsonResponse(
  1702. {
  1703. 'result': 1,
  1704. 'description': None,
  1705. 'payload': {
  1706. 'dataList': [faq.to_dict() for faq in faqs]
  1707. }
  1708. }
  1709. )
  1710. @error_tolerate(nil = DefaultJsonErrorResponse)
  1711. @permission_required(ROLE.supermanager)
  1712. def addFAQ(request):
  1713. # type: (WSGIRequest)->JsonResponse
  1714. payload = json.loads(request.body)
  1715. payload.update({'managerId': ''})
  1716. faq = FAQ(**payload).save()
  1717. return JsonResponse(
  1718. {
  1719. 'result': 1 if faq else 0,
  1720. 'description': None,
  1721. 'payload': {}
  1722. }
  1723. )
  1724. @error_tolerate(nil = DefaultJsonErrorResponse)
  1725. @permission_required(ROLE.supermanager)
  1726. def editFAQ(request):
  1727. # type: (WSGIRequest)->JsonResponse
  1728. payload = json.loads(request.body)
  1729. updated = FAQ.objects(id = str(payload['id'])).update(**payload)
  1730. return JsonResponse(
  1731. {
  1732. 'result': 1 if updated else 0,
  1733. 'description': None,
  1734. 'payload': {}
  1735. }
  1736. )
  1737. @error_tolerate(nil = DefaultJsonErrorResponse)
  1738. @permission_required(ROLE.supermanager)
  1739. def deleteFAQ(request):
  1740. # type: (WSGIRequest)->JsonResponse
  1741. ids = json.loads(request.body)['ids']
  1742. map(lambda _: _.delete(), FAQ.objects(id__in = ids))
  1743. return JsonResponse({'result': 1, 'description': '', 'payload': {}})
  1744. @error_tolerate(nil = DefaultJsonErrorResponse)
  1745. @permission_required(ROLE.supermanager)
  1746. def editAgentForceFollowGzh(request):
  1747. payload = json.loads(request.body)
  1748. agentStrIds = payload.get('ids', [])
  1749. ids = [ObjectId(_) for _ in agentStrIds]
  1750. forceFollowGzhForDealer = payload.get('forceFollowGzhForDealer', 'free')
  1751. forceFollowGzh = True if payload.get('forceFollowGzh', 'no') == 'yes' else False
  1752. # 先把代理商的统一修改掉
  1753. Agent.get_collection().update({'id': {'$in': ids}}, {'$set': {'forceFollowGzh': forceFollowGzh}}, multi = True)
  1754. # 经销商的,仅仅是把锁住的,全部解锁。或者全部加锁
  1755. if forceFollowGzhForDealer == 'free':
  1756. Dealer.get_collection().update({'agentId': {'$in': agentStrIds}, 'forceFollowGzh': 'never'},
  1757. {'$set': {'forceFollowGzh': 'free'}}, multi = True)
  1758. else:
  1759. Dealer.get_collection().update({'agentId': {'$in': agentStrIds}}, {'$set': {'forceFollowGzh': 'never'}},
  1760. multi = True)
  1761. if forceFollowGzh:
  1762. return JsonOkResponse(description = u'注意,如果打开代理商的强制关注,一定要在代理商系统把代理商的公众号相关信息,比如二维码、appId、secret相关信息配置OK')
  1763. return JsonOkResponse()
  1764. @error_tolerate(nil = DefaultJsonErrorResponse)
  1765. @trace_call(logger = logger)
  1766. @permission_required(ROLE.supermanager)
  1767. def getSignalTrendByDevice(request):
  1768. strStartTime = request.GET.get('startTime')
  1769. strEndTime = request.GET.get('endTime')
  1770. startTime = to_datetime(strStartTime)
  1771. endTime = to_datetime(strEndTime)
  1772. logicalCode = request.GET.get('logicalCode')
  1773. devNo = Device.get_devNo_by_logicalCode(logicalCode)
  1774. dataList = []
  1775. # 把redis的数据也补上去,然后重新排序,为的是防止数据库没有解析记录
  1776. nowTime = datetime.datetime.now()
  1777. tempStartTime = nowTime - datetime.timedelta(days = 7)
  1778. values = SignalManager.instence().get(devNo, tempStartTime, nowTime)
  1779. if values is not None:
  1780. for value in values:
  1781. timePoint = to_datetime(value['time'])
  1782. if timePoint >= startTime and timePoint <= endTime:
  1783. dataList.append('%s=%s' % (value['time'], value['signal']))
  1784. resultList = []
  1785. for data in dataList:
  1786. tempList = data.split('=')
  1787. resultList.append({
  1788. 'dateStr': tempList[0],
  1789. 'signal': tempList[1]
  1790. })
  1791. return JsonOkResponse(payload = {'dataList': resultList})
  1792. @error_tolerate(nil = DefaultJsonErrorResponse)
  1793. @permission_required(ROLE.supermanager)
  1794. def unLoginLock(request):
  1795. payload = json.loads(request.body)
  1796. role = payload['role']
  1797. if role == ROLE.dealer:
  1798. user = Dealer.objects(id = payload['id']).first() # type: UserSearchable
  1799. elif role == ROLE.agent:
  1800. user = Agent.objects(id = payload['id']).first() # type: UserSearchable
  1801. elif role == ROLE.manager or ROLE.manufacturer: # 传过来的字段不一样 constant里面加了一个字段manufacturer 做容错
  1802. user = Manager.objects(id = payload['id']).first() # type: UserSearchable
  1803. else:
  1804. return JsonErrorResponse(description = u'无效的用户类型')
  1805. if not user:
  1806. return JsonErrorResponse(description = u'找不到该用户,请刷新后再试')
  1807. user.unlock_login()
  1808. return JsonOkResponse(description = u'解锁成功')
  1809. @error_tolerate(nil = DefaultJsonErrorResponse)
  1810. @permission_required(ROLE.supermanager)
  1811. def unlockRegisterLimit(request):
  1812. payload = json.loads(request.body)
  1813. dealer = Dealer.objects(id = payload['id']).first()
  1814. if dealer is None:
  1815. return JsonErrorResponse(description = u'不存在的经销商')
  1816. serviceCache.delete('dealer_{}_registerEquipment_{}'.format(str(dealer.id), datetime.datetime.now().strftime(Const.DATE_FMT)))
  1817. return JsonOkResponse(description = u'解锁成功')
  1818. @error_tolerate(nil = DefaultJsonErrorResponse)
  1819. @permission_required(ROLE.supermanager)
  1820. def queryExchangeOrder(request):
  1821. pageIndex = int(request.GET.get('pageIndex', 1))
  1822. pageSize = int(request.GET.get('pageSize', 10))
  1823. searchKey = request.GET.get('searchKey', '')
  1824. managerId = request.GET.get('managerId')
  1825. agentId = request.GET.get('agentId')
  1826. dealerId = request.GET.get('dealerId')
  1827. query = {}
  1828. if managerId is not None:
  1829. query['factoryId'] = ObjectId(managerId)
  1830. if agentId is not None:
  1831. query['agentId'] = ObjectId(agentId)
  1832. if dealerId is not None:
  1833. query['ownerId'] = ObjectId(dealerId)
  1834. orders = ExchangeOrder.objects(**query).search(searchKey).order_by('-dateTimeAdded')
  1835. total = orders.count() # type: int
  1836. dataList = []
  1837. for order in orders.paginate(pageIndex = pageIndex, pageSize = pageSize):
  1838. data = {}
  1839. dealer = Dealer.objects.get(id = order.ownerId)
  1840. agent = Agent.objects.get(id = order.agentId)
  1841. factory = Manager.objects.get(id = order.factoryId)
  1842. data['dealerInfo'] = u'%s:%s' % (dealer.username, dealer.nickname)
  1843. data['agentInfo'] = u'%s:%s' % (agent.productName, agent.nickname)
  1844. data['factoryInfo'] = u'%s' % (factory.brandName)
  1845. data['logicalCode'] = order.logicalCode
  1846. objs = Part.objects.filter(id__in = order.parts)
  1847. data['parts'] = [{'partName': obj.partName, 'registerTime': obj.dateTimeAdded.strftime(Const.DATETIME_FMT),
  1848. 'expiredTime': obj.expiredTime.strftime(Const.DATETIME_FMT), 'SN': obj.partNo} for obj in
  1849. objs]
  1850. data['statusInfo'] = order.make_status_info()
  1851. data['pics'] = order.pics
  1852. data['id'] = str(order.id)
  1853. data['dateTimeAdded'] = order.dateTimeAdded.strftime(Const.DATETIME_FMT)
  1854. data['factoryOrderNo'] = order.factoryOrderNo
  1855. data['dealerOrderNo'] = order.dealerOrderNo
  1856. data['factoryAddr'] = order.factoryAddr
  1857. data['dealerAddr'] = order.dealerAddr
  1858. data['dealerWords'] = order.dealerWords
  1859. data['factoryWords'] = order.factoryWords
  1860. data['more'] = order.more
  1861. dataList.append(data)
  1862. return JsonOkResponse(payload = {'total': total, 'dataList': dataList})
  1863. @error_tolerate(nil = DefaultJsonErrorResponse)
  1864. @permission_required(ROLE.supermanager)
  1865. def operateOrder(request):
  1866. payload = json.loads(request.body)
  1867. orderId = payload['id']
  1868. cmd = payload['status']
  1869. factoryOrderNo = payload.get('factoryOrderNo', '')
  1870. order = ExchangeOrder.objects.get(id = orderId)
  1871. logicalCode = order.logicalCode
  1872. dev = Device.get_dev_by_l(logicalCode)
  1873. group = Group.get_group(groupId = dev['groupId'])
  1874. if cmd == 'agree':
  1875. if order.factoryStatus in ['sended', 'closed']:
  1876. return JsonErrorResponse(description = u'当前维护单已经走下去了,不需要再同意了')
  1877. else:
  1878. order.factoryStatus = 'agreed'
  1879. order.save()
  1880. elif cmd == 'disagree':
  1881. if order.factoryStatus in ['sended', 'closed']:
  1882. return JsonErrorResponse(description = u'当前维护单已经走下去了,不需要再同意了')
  1883. else:
  1884. order.factoryStatus = 'disagreed'
  1885. order.save()
  1886. elif cmd == 'close':
  1887. if order.factoryStatus == 'closed':
  1888. pass
  1889. elif order.dealerStatus == 'created' or order.factoryStatus != 'sended':
  1890. return JsonErrorResponse(description = u'经销商必须把有问题的产品寄回来,厂家必须把置换货发出去后,才允许关闭')
  1891. elif cmd == 'send':
  1892. if order.factoryStatus != 'agreed':
  1893. return JsonOkResponse(description = u'必须同意之后,才能够发货哦')
  1894. if not factoryOrderNo:
  1895. return JsonErrorResponse(description = u'需要输入发货快递单号')
  1896. order.factoryOrderNo = factoryOrderNo
  1897. order.save()
  1898. cmdDescDict = {'agree': u'同意换货', 'disagree': u'不同意换货', 'close': u'成功关闭', 'send': u'已经发货'}
  1899. titleDictList = [
  1900. {u'售后中心': cmdDescDict.get(cmd)},
  1901. {u'设备编号': logicalCode},
  1902. {u'地址名称': group["groupName"]}
  1903. ]
  1904. if cmd == 'send':
  1905. titleDictList.append({u'发货单号': factoryOrderNo})
  1906. dealer = Dealer.objects.get(id = order.ownerId)
  1907. partNames = [_.partName for _ in Part.objects.filter(id__in = order.parts)]
  1908. args = {
  1909. 'title': make_title_from_dict(titleDictList),
  1910. 'customer': u'%s\\n' % (dealer.nickname),
  1911. 'detail': u'质保换货,%s\\n' % u','.join(partNames),
  1912. 'person': u'售后中心\\n',
  1913. 'notifyTime': u'%s\\n' % datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
  1914. 'remark': u'您可以在设备管理中,查看详细情况\\n' if cmd != 'send' else u'售后中心已经给您寄货,请您尽快把问题组件寄回给我们\\n'
  1915. }
  1916. if dealer.managerialOpenId:
  1917. task_caller('report_to_dealer_via_wechat', openId = dealer.managerialOpenId,
  1918. dealerId = str(dealer.id),
  1919. templateName = 'exchange_order_notify',
  1920. **args)
  1921. return JsonOkResponse()
  1922. @error_tolerate(nil = DefaultJsonErrorResponse)
  1923. @permission_required(ROLE.supermanager)
  1924. def updateMaintenanceInfo(request):
  1925. payload = json.loads(request.body)
  1926. orderId = payload['id']
  1927. factoryWords = payload['factoryWords']
  1928. more = payload['more']
  1929. factoryAddr = payload['factoryAddr']
  1930. order = ExchangeOrder.objects.get(id = orderId)
  1931. order.more = more
  1932. order.factoryWords = factoryWords
  1933. order.factoryAddr = factoryAddr
  1934. order.save()
  1935. return JsonOkResponse()
  1936. @error_tolerate(nil = DefaultJsonErrorResponse)
  1937. @permission_required(ROLE.supermanager)
  1938. def saveFactoryAddress(request):
  1939. payload = json.loads(request.body)
  1940. name = payload.get('name', None)
  1941. addr = payload.get('addr', None)
  1942. tel = payload.get('tel', None)
  1943. managerId = payload.get('managerId', None)
  1944. if (not name) or (not addr) or (not tel):
  1945. return JsonErrorResponse(description = u'名称、地址、电话都不允许为空')
  1946. manager = Manager.objects(id = managerId).get()
  1947. manager.expressAddr = {'name': name, 'addr': addr, 'tel': tel}
  1948. manager.save()
  1949. return JsonOkResponse()
  1950. @error_tolerate(nil = DefaultJsonErrorResponse)
  1951. @permission_required(ROLE.supermanager)
  1952. def clearDeviceCache(request):
  1953. payload = json.loads(request.body)
  1954. devNo = payload.get('devNo')
  1955. Device.invalid_all_cache(Device.get_dev(devNo))
  1956. return JsonOkResponse()
  1957. @error_tolerate(nil = DefaultJsonErrorResponse)
  1958. @permission_required(ROLE.supermanager)
  1959. def setDeviceDebug(request):
  1960. payload = json.loads(request.body)
  1961. devNo = payload.get('devNo')
  1962. debugFlag = payload.get('debugFlag', '')
  1963. device = Device.objects(devNo = devNo).first() # type: Device
  1964. device.debug = debugFlag
  1965. device.save()
  1966. Device.invalid_device_cache(devNo)
  1967. return JsonOkResponse()
  1968. @error_tolerate(nil = DefaultJsonErrorResponse)
  1969. @permission_required(ROLE.supermanager)
  1970. def changeDealerAnnualTrafficCost(request):
  1971. payload = json.loads(request.body)
  1972. ownerId = payload['ids'][0]
  1973. annualTrafficCost = payload['annualTrafficCost']
  1974. # todo 先单独给德力西改流量费做特殊处理
  1975. if annualTrafficCost < 15:
  1976. return JsonErrorResponse(description = u'DLX改流量费, 经销商最低流量费价格不能小于15')
  1977. dealer = Dealer.objects(id = ownerId).first()
  1978. dealer.annualTrafficCost = RMB(str(annualTrafficCost))
  1979. dealer.trafficCardCost = RMB(str(annualTrafficCost))
  1980. dealer.save()
  1981. ds = Device.objects(ownerId = ownerId)
  1982. for _ in ds:
  1983. _.trafficCardCost = None
  1984. _.annualTrafficCost = None
  1985. _.save()
  1986. Device.invalid_device_cache(_.devNo)
  1987. return JsonOkResponse(description = u'修改成功')
  1988. @error_tolerate(nil = DefaultJsonErrorResponse)
  1989. @permission_required(ROLE.supermanager)
  1990. def getDealerRechargeRecord(request):
  1991. searchType = request.GET['searchType']
  1992. searchKey = request.GET.get('searchKey')
  1993. pageIndex = int(request.GET.get('pageIndex', 1))
  1994. pageSize = int(request.GET.get('pageSize', 40))
  1995. if searchType == u'logicalCode':
  1996. orderNo = ''
  1997. logicalCode = searchKey
  1998. elif searchType == u'orderNo':
  1999. orderNo = searchKey
  2000. logicalCode = ''
  2001. else:
  2002. return JsonErrorResponse(description = u'请输入正确的查询条件')
  2003. dataList = []
  2004. if orderNo != '':
  2005. dealerRechargeRcds = DealerRechargeRecord.objects(orderNo = orderNo, status = 'Paid')
  2006. if dealerRechargeRcds.count() == 0:
  2007. return JsonErrorResponse(description = u'未付款或不存在的订单号')
  2008. elif logicalCode != '':
  2009. dealerRechargeRcds = DealerRechargeRecord.objects(name__contains = ' ' + logicalCode, status = 'Paid')
  2010. if dealerRechargeRcds.count() == 0:
  2011. return JsonErrorResponse(description = u'未付款或不存在的订单号')
  2012. else:
  2013. return JsonErrorResponse(description = u'请输入查询条件')
  2014. for _ in dealerRechargeRcds.paginate(pageIndex = pageIndex, pageSize = pageSize):
  2015. dealer = Dealer.objects(id = _.dealerId).first()
  2016. if dealer is None:
  2017. dealerStr = ''
  2018. else:
  2019. dealerStr = dealer.nickname + ' ' + dealer.username
  2020. dataList.append({
  2021. 'orderNo': _.orderNo,
  2022. 'dealerStr': dealerStr,
  2023. 'orderParams': _.attachParas,
  2024. 'simOrderDict': {
  2025. 'name': _.name
  2026. },
  2027. 'totalFee': str(float(_.totalFee) / 100),
  2028. 'dateTimeAdded': _.finishedTime.strftime('%Y-%m-%d %H:%M:%S')
  2029. })
  2030. return JsonOkResponse(payload = {'dataList': dataList})
  2031. @error_tolerate(nil = DefaultJsonErrorResponse)
  2032. @permission_required(ROLE.supermanager)
  2033. def refundDealerRecharge(request):
  2034. payload = json.loads(request.body)
  2035. refundMoney = RMB(payload.get('refundMoney', '0.0'))
  2036. if refundMoney <= RMB('0.0'):
  2037. return JsonErrorResponse(description = u'未知错误')
  2038. dealerRechargeRecord = DealerRechargeRecord.objects(orderNo = payload.get('orderNo', '')).first()
  2039. if dealerRechargeRecord is None:
  2040. return JsonErrorResponse(description = u'订单编号错误')
  2041. try:
  2042. refund_cash_to_dealer(dealerRechargeRecord, refundMoney)
  2043. except UserServerException as e:
  2044. return JsonErrorResponse(description = e.message)
  2045. except Exception as e:
  2046. return JsonErrorResponse(description = u'系统错误')
  2047. return JsonOkResponse()
  2048. @error_tolerate(nil = DefaultJsonErrorResponse)
  2049. @permission_required(ROLE.supermanager)
  2050. def manualRechargeSimCard(request):
  2051. payload = json.loads(request.body)
  2052. lList = payload['logicalCode']
  2053. if len(lList) == 0:
  2054. return JsonErrorResponse(description = u'没有选择设备编号')
  2055. dealerMap = {}
  2056. for device in Device.objects(logicalCode__in = lList):
  2057. if device.simStatus == SimStatus.Charged:
  2058. logger.debug('sim status of {} is charged.'.format(str(device)))
  2059. continue
  2060. if str(device.ownerId) in dealerMap:
  2061. dealer = dealerMap[str(device.ownerId)]
  2062. else:
  2063. dealer = Dealer.objects(id = device.ownerId).first()
  2064. dealerMap[str(device.ownerId)] = dealer
  2065. payment_gateway = get_manual_pay_gateway(dealer)
  2066. rcd = create_dealer_sim_charge_order(payment_gateway, dealer, [device], payType = "manual")
  2067. if not rcd:
  2068. return JsonErrorResponse(
  2069. description = u'创建订单失败,部分设备线下续费失败,请检查后重试(设备号{})。'.format(device.logicalCode))
  2070. rcd.succeed(wxOrderNo = rcd.orderNo)
  2071. device.simStatus = u'chargedUnupdated'
  2072. device.save()
  2073. Device.invalid_device_cache(device.devNo)
  2074. return JsonOkResponse()
  2075. @error_tolerate(nil = DefaultJsonErrorResponse)
  2076. @permission_required(ROLE.supermanager)
  2077. def querySupporters(request):
  2078. return JsonOkResponse()
  2079. @error_tolerate(logger = logger, nil = JsonErrorResponse(u"获取免责声明失败"))
  2080. @permission_required(ROLE.supermanager)
  2081. def getAgentDisclaimer(request):
  2082. """
  2083. 获取代理商的免责声明 内容
  2084. :param request:
  2085. :return:
  2086. """
  2087. agentId = request.GET.get("agentId", "")
  2088. agent = Agent.objects.get(id = agentId)
  2089. payload = {
  2090. "content": agent.disclaimerContent,
  2091. "version": agent.disclaimerVersion.split("_")[1],
  2092. "needDisclaimer": agent.needDisclaimer
  2093. }
  2094. return JsonOkResponse(payload = payload)
  2095. @error_tolerate(logger = logger, nil = JsonErrorResponse(u"设置免责声明失败"))
  2096. @permission_required(ROLE.supermanager)
  2097. def setAgentDisclaimer(request):
  2098. """
  2099. 设置代理商的免责声明 内容
  2100. :param request:
  2101. :return:
  2102. """
  2103. payload = json.loads(request.body)
  2104. agentId = payload.get("agentId")
  2105. needDisclaimer = payload.get("needDisclaimer")
  2106. disclaimerContent = payload.get("content")
  2107. version = payload.get("version")
  2108. agent = Agent.objects.get(id = agentId)
  2109. agent.update(needDisclaimer = needDisclaimer)
  2110. agent.disclaimerVersion = version
  2111. agent.disclaimerContent = disclaimerContent
  2112. return JsonOkResponse()
  2113. @error_tolerate(nil = DefaultJsonErrorResponse)
  2114. @permission_required(ROLE.supermanager)
  2115. def modifyDeviceCode(request):
  2116. payload = json.loads(request.body)
  2117. logicalCodes = payload.get('logicalCodeList', [])
  2118. code = payload.get('code')
  2119. if not logicalCodes:
  2120. return JsonErrorResponse(description='没有选中的设备')
  2121. if not code:
  2122. return JsonErrorResponse(description='code输入有误')
  2123. mark = None
  2124. deviceOwner = Device.get_dev_by_l(logicalCodes[0]).owner
  2125. model_device = Device.objects.filter(ownerId=str(deviceOwner.id), devType__code=code).order_by('-id').first()
  2126. if model_device:
  2127. devType = model_device.devType
  2128. washConfig = model_device.washConfig
  2129. otherConf = model_device.otherConf
  2130. logger.info(
  2131. 'washConfig=<{}> otherConf=<{}> devType=<{}> sync params tar=<{}>'.format(washConfig, otherConf, devType,
  2132. logicalCodes))
  2133. mark = 1
  2134. else:
  2135. devType = DeviceType.objects.filter(agentId=deviceOwner.agentId, code=code).first() # type: DeviceType
  2136. if devType:
  2137. package = deviceOwner.defaultWashConfig.get(str(devType.id))
  2138. if not package:
  2139. package = devType.package
  2140. washConfig = dict(map(lambda _: (str(package.index(_) + 1), _), package))
  2141. otherConf = {}
  2142. devType = devType.to_dict()
  2143. logger.info('washConfig=<{}> otherConf=<{}> devType=<{}> sync params!! tar=<{}>'.format(washConfig, otherConf, devType,logicalCodes))
  2144. mark = 2
  2145. else:
  2146. devType = DeviceType.objects.filter(code=code).first() # type: DeviceType
  2147. if devType:
  2148. devType = DeviceType.objects.create(**{
  2149. "role": "manager",
  2150. "online": devType.online,
  2151. "unit": devType.unit,
  2152. "stock": devType.stock,
  2153. "payableWhileBusy": devType.payableWhileBusy,
  2154. "displayCoinsSwitch": True,
  2155. "displayPriceSwitch": True,
  2156. "displayTimeSwitch": True,
  2157. "name": devType.name,
  2158. "package": devType.package,
  2159. "code": code,
  2160. "majorDeviceType": devType.majorDeviceType,
  2161. "devFeatures": getattr(devType, 'devFeatures', []),
  2162. "agentId": deviceOwner.agentId
  2163. })
  2164. else:
  2165. return JsonErrorResponse(description='没有这个code, 去手动添加操作')
  2166. washConfig = dict(map(lambda _: (str(package.index(_)+1), _), devType.package))
  2167. otherConf = {}
  2168. devType = devType.to_dict()
  2169. logger.info('washConfig=<{}> otherConf=<{}> devType=<{}> sync params!!! tar=<{}>'.format(washConfig, otherConf, devType,logicalCodes))
  2170. mark = 3
  2171. devNos = []
  2172. for _ in logicalCodes:
  2173. devNos.append(Device.get_dev_by_logicalCode(_).devNo)
  2174. Device.get_collection().update_one({'devNo': {'$in': devNos}}, {
  2175. '$set': {'devType': devType, 'washConfig': washConfig, 'otherConf': otherConf}})
  2176. Device.invalid_many_device_cache(devNos)
  2177. payload = {'devType': devType, 'washConfig': washConfig, 'otherConf': otherConf, 'logicalCodes': logicalCodes}
  2178. if mark == 1:
  2179. return JsonOkResponse(description='修改成功并与设备:{} 同步参数'.format(model_device.logicalCode), payload=payload)
  2180. elif mark == 2:
  2181. return JsonOkResponse(description='修改成功', payload=payload)
  2182. elif mark == 3:
  2183. return JsonOkResponse(description='修改成功, 并新增一个设备类型<devType: {}>'.format(devType['code']), payload=payload)
  2184. else:
  2185. return JsonErrorResponse(description='修改失败!, 去手动添加操作')
  2186. @error_tolerate(nil = DefaultJsonErrorResponse)
  2187. @permission_required(ROLE.supermanager)
  2188. def rentDevice(request):
  2189. """
  2190. 出租设备
  2191. :param request:
  2192. :return:
  2193. """
  2194. payload = json.loads(request.body)
  2195. logicalCode = payload.get("logicalCode")
  2196. device = Device.objects.get(logicalCode = logicalCode)
  2197. try:
  2198. device.rent()
  2199. except RentDeviceError as renError:
  2200. return JsonErrorResponse(description = renError.message)
  2201. Device.invalid_device_cache(device.devNo)
  2202. return JsonOkResponse()
  2203. @error_tolerate(nil = DefaultJsonErrorResponse)
  2204. @permission_required(ROLE.supermanager)
  2205. def getInsuranceOrder(request):
  2206. """
  2207. 获取
  2208. :param request:
  2209. :return:
  2210. """
  2211. wxOrderNo = request.GET.get("outTradeNo")
  2212. if not wxOrderNo:
  2213. return JsonErrorResponse(u"请输入交易单号查询")
  2214. # 根据外部支付单号 找到唯一的支付订单
  2215. orders = RechargeRecord.objects.filter(wxOrderNo = wxOrderNo, via = 'insurance') # type: RechargeRecord
  2216. dataList = list()
  2217. for _order in orders:
  2218. _insuranceOrder = InsuranceOrder.objects.get(rechargeRcdId = _order.id)
  2219. _dealer = _insuranceOrder.dealer # type: DealerDict
  2220. _user = _insuranceOrder.user # type: MyUser
  2221. _group = _insuranceOrder.group # type: GroupDict
  2222. data = {
  2223. "id": _insuranceOrder.id,
  2224. "price": _insuranceOrder.money,
  2225. "dealerName": "{}".format(_dealer["nickname"], _dealer["username"]),
  2226. "devNo": _insuranceOrder.devNo,
  2227. "groupName": _group.groupName,
  2228. "logicalCode": _insuranceOrder.logicalCode,
  2229. "openId": _insuranceOrder.openId,
  2230. "userNickname": _user.nickname,
  2231. "startTime": _insuranceOrder.startTime,
  2232. "endTime": _insuranceOrder.endTime,
  2233. "via": _order.via,
  2234. "dateTimeAdded": _insuranceOrder.dateTimeAdded,
  2235. "refunded": not bool(_insuranceOrder.effective)
  2236. }
  2237. dataList.append(data)
  2238. return JsonOkResponse(payload = {"total": len(dataList), "dataList": dataList})
  2239. @error_tolerate(nil = DefaultJsonErrorResponse)
  2240. @permission_required(ROLE.supermanager)
  2241. def refundInsuranceOrder(request):
  2242. return JsonErrorResponse(u"保险产品已经下架")
  2243. @error_tolerate(nil = DefaultJsonErrorResponse)
  2244. @permission_required(ROLE.supermanager)
  2245. def setDealerMaxPackagePrice(request):
  2246. payload = json.loads(request.body)
  2247. dealerIds = payload.get('ids', [])
  2248. maxPackagePrice = payload.get('maxPackagePrice', 1)
  2249. if maxPackagePrice > 200:
  2250. return JsonErrorResponse(description = u'套餐金额过大')
  2251. if dealerIds == []:
  2252. return JsonErrorResponse(description = u'未选择经销商')
  2253. try:
  2254. for _ in dealerIds:
  2255. dealer = Dealer.objects(id = _).first()
  2256. if dealer is None:
  2257. continue
  2258. dealer.maxPackagePrice = RMB(int(maxPackagePrice))
  2259. dealer.save()
  2260. except Exception as e:
  2261. return JsonErrorResponse(description = u'未知错误')
  2262. return JsonOkResponse()
  2263. @error_tolerate(nil = DefaultJsonErrorResponse)
  2264. @permission_required(ROLE.supermanager)
  2265. def lockDeviceSimStatus(request):
  2266. payload = json.loads(request.body)
  2267. logicalCodes = payload.get('logicalCode', [])
  2268. if logicalCodes == []:
  2269. return JsonErrorResponse(description = u'未选择设备')
  2270. try:
  2271. for _ in logicalCodes:
  2272. device = Device.objects(logicalCode = _).first()
  2273. if device is None:
  2274. continue
  2275. device.simStatus = u'updated'
  2276. device.save()
  2277. Device.invalid_device_cache(device.devNo)
  2278. except Exception as e:
  2279. return JsonErrorResponse(description = u'未知错误')
  2280. return JsonOkResponse()
  2281. @error_tolerate(nil = DefaultJsonErrorResponse)
  2282. @permission_required(ROLE.supermanager)
  2283. def unlockDeviceSimStatus(request):
  2284. payload = json.loads(request.body)
  2285. logicalCodes = payload.get('logicalCode', [])
  2286. if logicalCodes == []:
  2287. return JsonErrorResponse(description = u'未选择设备')
  2288. try:
  2289. for _ in logicalCodes:
  2290. device = Device.objects(logicalCode = _).first()
  2291. if device is None:
  2292. continue
  2293. device.simStatus = u'chargedUnupdated'
  2294. device.save()
  2295. Device.invalid_device_cache(device.devNo)
  2296. except Exception as e:
  2297. return JsonErrorResponse(description = u'未知错误')
  2298. return JsonOkResponse()
  2299. @error_tolerate(nil = DefaultJsonErrorResponse)
  2300. @permission_required(ROLE.supermanager)
  2301. def showDeviceDevTypes(request):
  2302. payload = json.loads(request.body)
  2303. logicalCodes = payload.get('logicalCode', [])
  2304. if len(logicalCodes) != 1:
  2305. return JsonErrorResponse(description = u'设备选择有误')
  2306. logicalCode = logicalCodes[0]
  2307. device = Device.objects(logicalCode = logicalCode).first()
  2308. if device.ownerId == '':
  2309. return JsonErrorResponse(description = u'设备未注册')
  2310. dealer = Dealer.objects(id = device.ownerId).first()
  2311. if dealer is None:
  2312. return JsonErrorResponse(description = u'经销商不存在')
  2313. agentId = dealer.agentId
  2314. if agentId == '':
  2315. return JsonErrorResponse(description = u'代理商不存在, 系统异常')
  2316. dataList = [{
  2317. 'devTypeCode': _.code,
  2318. 'devTypeName': _.name,
  2319. 'devTypeId': str(_.id)
  2320. } for _ in DeviceType.objects(agentId = agentId)]
  2321. return JsonOkResponse(payload = {"total": len(dataList), "dataList": dataList})
  2322. @error_tolerate(nil = DefaultJsonErrorResponse)
  2323. @permission_required(ROLE.supermanager)
  2324. def changeDeviceDevType(request):
  2325. payload = json.loads(request.body)
  2326. logicalCodes = payload.get('logicalCode', [])
  2327. devTypeId = payload.get('devTypeId', '')
  2328. if len(logicalCodes) != 1:
  2329. return JsonErrorResponse(description = u'设备选择有误')
  2330. logicalCode = logicalCodes[0]
  2331. device = Device.objects(logicalCode = logicalCode).first()
  2332. devType = DeviceType.objects(id = devTypeId).first()
  2333. try:
  2334. Device.objects(logicalCode = logicalCode).update_one(upsert = False, **{'devType': devType.to_dict()})
  2335. except Exception as e:
  2336. return JsonErrorResponse(description = u'操作失败')
  2337. finally:
  2338. Device.invalid_device_cache(device.devNo)
  2339. return JsonOkResponse()
  2340. @error_tolerate(logger=logger, nil=JsonErrorResponse(u"查询失败"))
  2341. @permission_required(ROLE.supermanager)
  2342. def getApiAppInfo(request):
  2343. """
  2344. 获取经销上API注册信息
  2345. """
  2346. dealerId = request.GET.get("dealerId")
  2347. dealer = Dealer.objects(id=dealerId).first()
  2348. if not dealer:
  2349. logger.error('dealer<id={}> is not exists.'.format(dealerId))
  2350. return JsonErrorResponse(description='经销商不存在')
  2351. apiInfo = dealer.api_app # type: ApiAppInfo
  2352. return JsonOkResponse(payload={
  2353. 'people': apiInfo.people,
  2354. 'tel': apiInfo.tel,
  2355. 'callbackUrl': apiInfo.callbackUrl,
  2356. 'apiDeviceMax': apiInfo.apiDeviceMax,
  2357. 'apiDevicePerCost': float(apiInfo.apiDevicePerCost)
  2358. })
  2359. @error_tolerate(logger=logger, nil=JsonErrorResponse(u"设置失败"))
  2360. @permission_required(ROLE.supermanager)
  2361. def editApiAppInfo(request):
  2362. """
  2363. 编辑经销上API注册信息
  2364. """
  2365. def check_url(url):
  2366. return re.match(r'^((https|http|ftp|rtsp|mms)?:\/\/)[^\s]+', url)
  2367. payload = json.loads(request.body)
  2368. dealerId = payload.get('dealerId')
  2369. dealer = Dealer.objects(id=dealerId).first()
  2370. if not dealer:
  2371. logger.error('dealer<id={}> is not exists.'.format(dealerId))
  2372. return JsonErrorResponse(description='经销商不存在')
  2373. people = payload.get('people')
  2374. tel = payload.get('tel')
  2375. callbackUrl = payload.get('callbackUrl')
  2376. apiDeviceMax = payload.get('apiDeviceMax')
  2377. apiDevicePerCost = payload.get('apiDevicePerCost')
  2378. if callbackUrl and not check_url(callbackUrl):
  2379. return JsonErrorResponse(description='回调地址Url填写错误')
  2380. if not isinstance(apiDeviceMax, int):
  2381. return JsonErrorResponse(description='API配额参数错误')
  2382. if not is_number(apiDevicePerCost):
  2383. return JsonErrorResponse(description='配额单价参数错误')
  2384. dealer.update_api_app(**{
  2385. 'people': people,
  2386. 'tel': tel,
  2387. 'callbackUrl': callbackUrl,
  2388. 'apiDeviceMax': apiDeviceMax,
  2389. 'apiDevicePerCost': apiDevicePerCost
  2390. })
  2391. return JsonOkResponse()
  2392. @error_tolerate(logger=logger, nil=JsonErrorResponse(u"设置失败"))
  2393. @permission_required(ROLE.supermanager)
  2394. def setServiceButtonStatus(request):
  2395. """
  2396. 设置个人中心正在服务的功能按钮展示
  2397. """
  2398. payload = json.loads(request.body)
  2399. logicalCodes = payload.get('logicalCode', [])
  2400. if len(logicalCodes) != 1:
  2401. return JsonErrorResponse(description='设备数量错误')
  2402. stopUsing = payload.get('stopUsing', None)
  2403. continueToUse = payload.get('continueToUse', None)
  2404. device = Device.objects(logicalCode=logicalCodes[0]).first()
  2405. if device is None:
  2406. return JsonErrorResponse(description='未知错误')
  2407. deviceType = DeviceType.objects(id=device.devType['id']).first()
  2408. if deviceType is None:
  2409. return JsonErrorResponse(description='未知错误')
  2410. if stopUsing is not None:
  2411. deviceType.servicesButtonDict['stopUsing'] = stopUsing
  2412. deviceType.save()
  2413. if continueToUse is not None:
  2414. deviceType.servicesButtonDict['continueToUse'] = continueToUse
  2415. deviceType.save()
  2416. return JsonOkResponse()
  2417. @error_tolerate(logger = logger, nil = JsonErrorResponse(u"获取经销商银行卡失败"))
  2418. @permission_required(ROLE.supermanager)
  2419. def getDealerBanks(request):
  2420. dealerId = request.GET.get('dealerId')
  2421. if not dealerId:
  2422. return JsonErrorResponse(description = u'参数错误')
  2423. dealer = Dealer.objects(id = dealerId).first()
  2424. if not dealer:
  2425. return JsonErrorResponse(description = u'经销商不存在,请刷新后再试')
  2426. return JsonOkResponse(payload = {
  2427. 'dataList': [
  2428. card.to_dict() for card in
  2429. WithdrawBankCard.objects(ownerId = str(dealer.id), role = dealer.role).all()
  2430. ]
  2431. })
  2432. @error_tolerate(logger = logger, nil = JsonErrorResponse(u"保存经销商银行卡失败"))
  2433. @permission_required(ROLE.supermanager)
  2434. def saveDealerBankAccount(request):
  2435. payload = json.loads(request.body)
  2436. dealerId = payload.pop('dealerId', None)
  2437. if not dealerId:
  2438. return JsonErrorResponse(description = u'参数错误')
  2439. dealer = Dealer.objects(id = dealerId).first()
  2440. if not dealer:
  2441. return JsonErrorResponse(description = u'经销商不存在,请刷新后再试')
  2442. bank_card_id = payload.pop('id', None)
  2443. try:
  2444. payload = SaveWithdrawBankCardSchemaForSuper(payload)
  2445. except MultipleInvalid as e:
  2446. logger.exception(e)
  2447. return JsonErrorResponse(description = u"信息不完整(1001)")
  2448. isPublic = payload.pop('isPublic')
  2449. if isPublic:
  2450. try:
  2451. payload = SavePublicWithdrawBankCardExtraSchema(payload)
  2452. except MultipleInvalid as e:
  2453. logger.exception(e)
  2454. return JsonErrorResponse(description = u"信息不完整(1002)")
  2455. branchBank = WithdrawBranchBanks.objects(
  2456. code = payload['branchBankCode']).first() # type: WithdrawBranchBanks
  2457. if not branchBank:
  2458. return JsonErrorResponse(description = u"查询不到支行信息")
  2459. WithdrawBankCard.new_public_withdraw_bank_card(
  2460. id = bank_card_id,
  2461. ownerId = dealerId,
  2462. role = ROLE.dealer,
  2463. bankCode = payload['bankCode'],
  2464. bankName = payload['bankName'],
  2465. accountName = payload['accountName'],
  2466. accountCode = payload['accountCode'],
  2467. phone = payload.get('phone', ''),
  2468. provinceCode = payload['provinceCode'],
  2469. province = payload['province'],
  2470. cityCode = payload['cityCode'],
  2471. city = payload['city'],
  2472. branchBankCode = branchBank.code,
  2473. branchBankName = branchBank.name,
  2474. cnapsCode = branchBank.cnapsCode)
  2475. else:
  2476. WithdrawBankCard.new_personal_withdraw_bank_card(
  2477. id = bank_card_id,
  2478. ownerId = dealerId,
  2479. role = ROLE.dealer,
  2480. phone = payload.get('phone', ''),
  2481. bankName = payload['bankName'],
  2482. accountName = payload['accountName'],
  2483. accountCode = payload['accountCode'])
  2484. return JsonOkResponse()
  2485. @error_tolerate(logger = logger, nil = JsonErrorResponse(u"删除经销商银行卡失败"))
  2486. @permission_required(ROLE.supermanager)
  2487. def deleteDealerBankAccount(request):
  2488. payload = json.loads(request.body)
  2489. bank_card_id = payload.get('id', None)
  2490. if not bank_card_id:
  2491. return JsonErrorResponse(description = u'参数错误')
  2492. WithdrawBankCard.objects(id = bank_card_id).delete()
  2493. return JsonOkResponse()