# -*- coding: utf-8 -*- # !/usr/bin/env python import datetime import os import time from base import init_env from apps.web.services.bluetooth.service import ActionBtDeviceBuilder os.environ.setdefault("DJANGO_SETTINGS_MODULE", "configs.testing") init_env(interactive = False) from apps import serviceCache from django.conf import settings from apps.web.constant import RechargeRecordVia from apps.web.core.db import copy_document_classes from apps.web.dealer.proxy import DealerIncomeProxy from apilib.monetary import RMB from apps.web.user.models import RechargeRecord from bson import ObjectId from apps.web.common.models import WithdrawRecord, WithdrawRefundRecord from apps.web.dealer.models import Dealer # from apps.web.dealer.tasks import generate_business_stats_report_by_dealer # # filePath = 'uploaded/reports/20301215/test.xlsx' # queryAttrs = {"kind": "income", "dealerId": "5b9ae99ad89a177846459999", "dateTimeAdded__lte": 1639583999.0, "dateTimeAdded__gte": 1613318400.0} # generate_business_stats_report_by_dealer(filePath = filePath, queryAttrs = queryAttrs) # ownerId = '607677150030485278a2de64' # # devNoList = [dev.devNo for dev in Device.objects(ownerId = ownerId)] # # dataList = [] # # for item in SerialTimeOut.objects(devNo__in = devNoList): # dev = Device.get_dev(devNo = item.devNo) # type: DeviceDict # # tempData = OrderedDict([ # (u"logicalCode", item.logicalCode), # (u"devNo", item.devNo), # (u'softVer', dev.softVer), # (u'dVer', dev.driverVersion), # (u"time", item.dateTimeAdded.strftime("%Y-%m-%d %H:%M:%S")), # (u"packet", item.packet) # ]) # # dataList.append(tempData) # # dataForm = pandas.DataFrame(dataList) # writer = pandas.ExcelWriter(u"统计.xlsx") # dataForm.to_excel(writer, sheet_name = u"统计", index = False) # writer.save() # # from apps.web.device.timescale import PowerManager # # port = '3' # eTime = datetime.datetime.now() # sTime = eTime - datetime.timedelta(hours = 10) # print PowerManager.instence().get_raw(devNo = '868739054076587', port = port, sTime = sTime, eTime = eTime) # print json_dumps("aaa") # 5fb88e09c3631dd06e3dd35a_devList '{groupId}_devList' # partner_group_ids_5bdff2f51748b31ab827cfca # ctr_868739059936207 # group_616145ec1dcf2fe43e27b4c4 # 868739059936207_online # Device.get_dev_by_l(logicalCode = '25619') # ownerId = '60c4ba9700304825e46ad1c0' # # his_model_cls = copy_document_classes(DealerIncomeProxy, '{}_his'.format(DealerIncomeProxy.__name__), 'report_his') # his_data = his_model_cls.sum_by_dealer(dealerId = ownerId) # # now_data = DealerIncomeProxy.sum_by_dealer(dealerId = ownerId, **{'dateTimeAdded__gte': datetime.datetime(2021,10,1)}) # print 'his = {}'.format(float(str(his_data))) # print 'now = {}'.format(float(str(now_data))) # print 'total = {}'.format(float(str(his_data)) + float(str(now_data))) # # withdraw_value = WithdrawRecord.objects(ownerId = ownerId, refunded = False).sum('amount') # print 'withdraw = {}'.format(withdraw_value) # # dealer = Dealer.objects(id = ownerId).first() # type: Dealer # print 'left = {}'.format(dealer.sub_balance("device")) # # start_month = 1 # end_month = 2 # # month_income = RMB(0) # # skip = 0 # loop = 2000 # # # # while True: # start_time = int(time.time()) # # items = DealerIncomeProxy.objects(dateTimeAdded__gte = datetime.datetime(2021,start_month,1,0,0,0), dateTimeAdded__lt = datetime.datetime(2022,end_month,1,0,0,0)).skip(skip).limit(loop) # if len(items) == 0: # break # # ref_ids = {item.ref_id: item for item in items} # # rechargs = RechargeRecord.get_collection().find({'_id':{'$in': ref_ids.keys()}}, {'via', 'money', 'result', 'withdrawSourceKey'}) # for recharge in rechargs: # type: RechargeRecord # if recharge['result'] != 'success': # print 'recharge {} result is wrong.'.format(str(recharge['_id'])) # continue # # if settings.MY_PRIMARY_AGENT_ID not in recharge['withdrawSourceKey']: # # print 'recharge {} is not my.'.format(str(['_id'])) # continue # # if recharge['via'] not in [RechargeRecordVia.VirtualCard, RechargeRecordVia.Card, RechargeRecordVia.Balance, RechargeRecordVia.Cash, RechargeRecordVia.Insurance, RechargeRecordVia.MonthlyPackage]: # print 'recharge {} is wrong via.'.format(str(['_id'])) # continue # # income_proxy = ref_ids.get(ObjectId(recharge['_id'])) # type: DealerIncomeProxy # # month_income += RMB(income_proxy.totalAmount) # # skip = skip + loop # # end_time = int(time.time()) # # print 'time is: {}'.format(end_time - start_time) # # print month_income # print serviceCache.get('58.243.250.169-2022-01-19') # from binascii import * # import crcmod # import random # def crc16Add(read): # crc16 = crcmod.mkCrcFun(0x18005, rev=True, initCrc=0xFFFF, xorOut=0x0000) # data = read.replace(" ", "") #消除空格 # readcrcout = hex(crc16(unhexlify(data))).upper() # str_list = list(readcrcout) # # print(str_list) # if len(str_list) == 5: # str_list.insert(2, '0') # 位数不足补0，因为一般最少是5个 # crc_data = "".join(str_list) #用""把数组的每一位结合起来 组成新的字符串 # # print(crc_data) # read = read.strip() + ' ' + crc_data[4:] + ' ' + crc_data[2:4] #把源代码和crc校验码连接起来 # # print('CRC16校验:', crc_data[4:] + ' ' + crc_data[2:4]) # print(read) # return crc_data[2:4] + crc_data[4:] # # print crc16Add('22200000013201060011030801020F30322E37302E3130000101010101010101010104') # from apps.web.core.networking import MessageSender # msg = {"IMEI": "866250061275610", "cmd": 210, "data": "00", "funCode": "01","port":8771} # MessageSender.send_car_tcpip('127.0.0.1', 50000, msg) # from apps.web.core.adapter.base import string_to_ascstring # print string_to_ascstring('192.168.224.25',32) # from apps.web.device.models import Device # from apps.web.core.helpers import ActionDeviceBuilder # dev = Device.get_dev(devNo = '32010600291765') # # box = ActionDeviceBuilder.create_action_device(dev) # box.update_charger(1,40960,'211.159.224.10',21,'ftpuser','123456','/data',1,10) # # print 'ddd' from apps.web.core.payment.base import WithdrawGateway record = WithdrawRecord.objects(order='20220926162612WDA177846459999AZK').first() withdraw_gateway = WithdrawGateway.from_withdraw_gateway_key(record.withdrawGatewayKey, record.extras.get('gateway_version', 'v1')) query_result = withdraw_gateway.get_transfer_result_via_changes(record.order)