Skip to content

T
tour_business
Commit a590461e by 魏强
Options

update；

parents
Showing with 2766 additions and 0 deletions
.gitignore 0 → 100644
# Byte-compiled / optimized / DLL files
__pycache__/
*.py[cod]
# C extensions
*.so
# Distribution / packaging
.Python
env/
build/
develop-eggs/
dist/
downloads/
eggs/
.eggs/
lib/
lib64/
parts/
sdist/
var/
*.egg-info/
.installed.cfg
*.egg
__pycache__/
.idea/
*.pyc
.gz
.txt
# PyInstaller
# Usually these files are written by a python script from a template
# before PyInstaller builds the exe, so as to inject date/other infos into it.
*.manifest
*.spec
# Installer logs
pip-log.txt
pip-delete-this-directory.txt
# Unit test / coverage reports
htmlcov/
.tox/
.coverage
.coverage.*
.cache
nosetests.xml
coverage.xml
*,cover
# Translations
*.mo
*.pot
# Django stuff:
*.log
# Sphinx documentation
docs/_build/
# PyBuilder
target/
Config/base_config.py 0 → 100644
# -*- coding: utf-8 -*-
import os
is_prod = os.getenv("RUN_ENV", "test") == 'prod'
if is_prod:
SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://root:Boosal2014!!@sh-cdb-kzmpyjqw.sql.tencentcdb.com:63037/suishenwan'
else:
SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://root:JYfd9X0w5DFAg4bU@sh-cdb-hcnle4m0.sql.tencentcdb.com:63443/suishenwan'
SECRET_KEY = "MgwuKKEcAk2UIaGxHAwnf38YvjvXMCqb"
SQLALCHEMY_TRACK_MODIFICATIONS = False
if is_prod:
TENCENT_REDIS_URL = "redis://:Boosal2014@172.17.0.5:6379"
else:
TENCENT_REDIS_URL = "redis://:Boosal2014@49.235.36.102:16379"
IMG_HEAD_URL = "https://dev-1255927177.cos.ap-shanghai.myqcloud.com"
ACTION_PWD = "Ssw@666"
Config/common_config.py 0 → 100644
# -*- coding: utf-8 -*-
import os
is_prod = os.getenv("RUN_ENV", "test") == 'prod'
ONENET_CONFIG = {
"encoding_AES_key": "XzHtYS3PbRiCDErEaztV286Cf4QmmL21T77tEY4Yb2m",
"he_cloud_token": "suishenwanonenettesttokenhecloud",
"url": 'http://api.js.cmcconenet.com',
}
if is_prod:
ONENET_CONFIG['api_key'] = "aFpHq1TkvggQrHkTgMlTKA2pXAI="
else:
ONENET_CONFIG['api_key'] = "H9x=yfGVGPPPBZxzyaaGhbaJ6kM="
MINA_APP = {
"app_id": "wx3185fb4a3633beb0",
"app_key": "d0fee84366bfb19c95505f4ddfa47b63",
"mch_id": "1487106062",
"pay_key": "huituzhineng3MaChengjunhandsomeh",
"wx_pay_cert_path": "Libs/cert/AllTour_cert/apiclient_cert.pem",
"wx_pay_key_path": "Libs/cert/AllTour_cert/apiclient_key.pem"
}
INVOICE_CONFIG = {
"app_id": "c58c70bb672e397b5ff908dc67d97a39c1c88a306bfc4c5b46146c419ef85779" if is_prod else "6d29f136114544bcc73edcce960c430231183cc192c433e2b9ebcad56e8ceb08",
"app_key": "8C8A5FD94F08F1D8" if is_prod else "5EE6C2C11DD421F2",
"xsf_nsrsbh": "913205943138134162" if is_prod else "110109500321655",
"xsf_mc": "苏州随身玩信息技术有限公司" if is_prod else "百旺电子测试2",
"url": "https://www.fapiao.com:63089/fpt-dsqz/invoice" if is_prod else "https://dev.fapiao.com:18944/fpt-dsqz/invoice",
"spbm": "304020300000000000001" if is_prod else "3070401000000000000",
"cert_path": "Libs/cert/invoice/cert.pem" if is_prod else "Libs/cert/invoice/testISSUE.pem",
"content": "*旅游娱乐服务*讲解服务",
"dizhi_dianhua": "苏州工业园区若水路1号0512-62748449",
"yinhang_zhanghao": "招商银行苏州分行营业部512905030310801",
"kaipiaoren": "随身玩",
"shoukuanren": "随身玩",
"fuheren": "曹云香"
}
SMS_CONFIG = {
'app_id': 1400068750,
'app_key': '3431474d060edb7fdd12f05bc7b3f848'
}
LOGIN_TYPE = {
'code_login': 1,
'token_login': 2,
'send_code': 3,
'password': 4
}
AGENT_STATUS = {
'1': '超级管理员',
'2': '代理商',
'3': '调试'
}
ACCOUNT_STATUS = {
'on_use': 1,
'delete': 2
}
Controller/InvoiceController.py 0 → 100644
# -*- coding: utf-8 -*-
from flask import Blueprint, request, jsonify, g
from Libs.ErrorTips import BASE_RESPONSE
from Libs.Helper.Helper import getFormatDate
from Model.Base import db
from Model.Customer.CustomerModel import Customer
from Model.Production.ProductionModel import Production
from Model.Rent.RentModel import Rent
from Model.invoice.InvoiceModel import Invoice
from Model.invoice.InvoiceRecoreModel import InvoiceRecord
from Service.InvoiceService import InvoiceService
route_invoice = Blueprint('invoice', __name__)
@route_invoice.route('/list')
def invoice_list():
if g.user.id != 4:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='permission denied').to_dict())
invoice_info = InvoiceRecord.query.filter(InvoiceRecord.status == 1, InvoiceRecord.parent_id > 0).all()
data = []
for info in invoice_info:
customer_info = Customer.query.filter_by(id=info.customer_id).first()
phone = customer_info.phone if customer_info else None
tmp = {
'invoice_id': info.id,
'data': getFormatDate(info.created_at),
'total': info.pay_money,
'status': info.status,
'phone': phone
}
data.append(tmp)
return jsonify(BASE_RESPONSE(data=data).to_dict())
@route_invoice.route('/verify', methods=['GET', 'POST'])
def invoice_compare():
if g.user.id != 4:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='permission denied').to_dict())
json_data = request.get_json()
invoice_id = json_data['invoice_id'] if 'invoice_id' in json_data else 0
if int(invoice_id) < 1:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='invoice id error').to_dict())
new_invoice_info = InvoiceRecord.query.filter_by(id=invoice_id).first()
if not new_invoice_info:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='error').to_dict())
if new_invoice_info.parent_id == 0:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='该发票没有重开过').to_dict())
old_invoice_info = InvoiceRecord.query.filter_by(id=new_invoice_info.parent_id).first()
if not old_invoice_info:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='error').to_dict())
customer_info = Customer.query.filter_by(id=new_invoice_info.customer_id).first()
phone = customer_info.phone if customer_info else None
new_rent_list = new_invoice_info.rent_list.split(",")
new_info = {
"company_name": new_invoice_info.company_name,
"payment_id": new_invoice_info.payment_id,
"e_account": new_invoice_info.e_account,
"remark": new_invoice_info.remark,
"address": new_invoice_info.address,
"account": new_invoice_info.account,
"rent_count": len(new_rent_list),
"apply_time": getFormatDate(new_invoice_info.created_at),
"phone": phone
}
old_rent_list = old_invoice_info.rent_list.split(",")
old_info = {
"company_name": old_invoice_info.company_name,
"payment_id": old_invoice_info.payment_id,
"e_account": old_invoice_info.e_account,
"remark": old_invoice_info.remark,
"address": old_invoice_info.address,
"account": old_invoice_info.account,
"rent_count": len(old_rent_list),
"apply_time": getFormatDate(old_invoice_info.created_at),
"phone": phone
}
return jsonify(BASE_RESPONSE(data={'new_info': new_info, 'old_info': old_info}).to_dict())
@route_invoice.route('/submit', methods=['GET', 'POST'])
def invoice_submit():
if g.user.id != 4:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='permission denied').to_dict())
json_data = request.get_json()
invoice_id = json_data['invoice_id'] if 'invoice_id' in json_data else None
invoice_type = json_data['type'] if 'type' in json_data else None # 1:同意 2:驳回 3:拒绝
reason = json_data['reason'] if 'reason' in json_data else None # 理由
if not invoice_id or not type:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='params error').to_dict())
if int(invoice_id) < 1:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='invoice id error').to_dict())
current_invoice = InvoiceRecord.query.filter_by(id=invoice_id).first()
if not current_invoice:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='no such invoice').to_dict())
parent_id = current_invoice.parent_id
if parent_id == 0:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='该发票未重开过').to_dict())
invoice_detail = db.session.query(Invoice, InvoiceRecord).outerjoin(InvoiceRecord,
Invoice.id == InvoiceRecord.invoice_id).filter(
InvoiceRecord.id == parent_id).first()
if int(invoice_type) == 1:
# 审核成功
invoice_info = InvoiceService()
# 红冲
red_result = invoice_info.red_rush(invoice_detail.Invoice.fp_dm, invoice_detail.Invoice.fp_hm)
gmf_mc = current_invoice.company_name
gmf_nsrsbh = current_invoice.payment_id
gmf_dzyx = current_invoice.e_account
address = current_invoice.address
account = current_invoice.account
remark = current_invoice.remark
rent_list = current_invoice.rent_list
# 重开发票
repeat_result, new_id = invoice_info.dict_content(gmf_mc, gmf_nsrsbh, gmf_dzyx, address, account, remark,
rent_list)
if new_id != 0:
new_info = Invoice.query.filter_by(id=new_id).first()
new_info.is_red = 2
db.session.add(new_info)
current_invoice.status = 2
current_invoice.invoice_id = new_id
db.session.add(current_invoice)
db.session.commit()
data = {
'red_result': red_result,
'repeat_result': repeat_result
}
return jsonify(BASE_RESPONSE(data=data).to_dict())
elif int(invoice_type) == 2:
# 驳回
current_invoice.status = 3
current_invoice.reason = reason
db.session.add(current_invoice)
db.session.commit()
return jsonify(BASE_RESPONSE().to_dict())
else:
# 拒绝
current_invoice.status = 4
current_invoice.reason = reason
db.session.add(current_invoice)
db.session.commit()
return jsonify(BASE_RESPONSE().to_dict())
@route_invoice.route('/rent_list', methods=['GET', 'POST'])
def invoice_rent():
if g.user.id != 4:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='permission denied').to_dict())
json_data = request.get_json()
invoice_id = json_data['invoice_id'] if 'invoice_id' in json_data else 0
if int(invoice_id) < 1:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='invoice id error').to_dict())
invoice_info = InvoiceRecord.query.filter_by(id=invoice_id).first()
if not invoice_info:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='no invoice info').to_dict())
data = []
rent_all = invoice_info.rent_list
rent_all_list = rent_all.split(",")
for info in rent_all_list:
cur_info = db.session.query(Rent, Production).join(Production, Production.rent_id == Rent.id).filter(
Rent.rent_no == info).first()
tmp = {}
tmp["rent_no"] = cur_info.Rent.rent_no
tmp["hatch_no"] = cur_info.Production.rent_hatch_no
tmp["total"] = 0 if cur_info.Production.total is None else cur_info.Production.total
if cur_info.Production.is_return == 1:
if tmp["total"] <= 0:
if cur_info.Production.return_hatch_no == 127:
tmp["status"] = 3
else:
tmp["status"] = 2
else:
tmp["status"] = 1
else:
tmp["status"] = 0
data.append(tmp)
return jsonify(BASE_RESPONSE(data=data).to_dict())
Controller/RepairController.py 0 → 100644
# -*- coding: utf-8 -*-
import base64
import hmac
import random
import time
from flask import Blueprint, jsonify, request, g
from Libs.ErrorTips import BASE_RESPONSE
from Libs.Logger import logger
from Service.RepairService import RepairService
route_repair = Blueprint('repair', __name__)
@route_repair.route('/repair', methods=['GET', 'POST'])
def repairCreate():
json_data = request.get_json()
system_user_id = g.user.id
# system_user_id = json_data['system_user_id'] if 'system_user_id' in json_data else 0
remark = json_data['remark'] if 'remark' in json_data else ''
tel = json_data['tel'] if 'tel' in json_data else ''
pics = json_data['pics'] if 'pics' in json_data else []
spot_id = json_data['spot_id'] if 'spot_id' in json_data else ''
machine_id = json_data['machine_id'] if 'machine_id' in json_data else ''
logger.info('####### spot id #######')
logger.info(spot_id)
RepairService.create(system_user_id, remark, tel, pics, spot_id, machine_id)
return jsonify(BASE_RESPONSE().to_dict())
@route_repair.route('/tencentUploadAuthorization', methods=['POST'])
def tencentUploadAuthorization():
json_data = request.get_json()
app_id = '1255927177'
bucket = 'dev'
secret_id = 'AKIDQp9OXawOAqWAjCAr9LRRL9vcEj8QMkke'
secret_key = 'wnXDmFbqy1yoXhmldQ8kEf1GOPLBufMy'
postfix = json_data['postfix'] if 'postfix' in json_data else 'png'
filename = RepairService.guid() + '.' + postfix
pathname = '/' + app_id + '/' + bucket + '/img/' + filename
now = int(time.time())
randoma = random.randint(1, 9999999999)
expired = int(time.time()) + 300
plainText = 'a=' + app_id + '&b=' + bucket + '&k=' + secret_id + '&e=' + str(expired) + '&t=' + str(
now) + '&r=' + str(randoma) + '&f=' + pathname
bin = hmac.new(secret_key.encode('utf-8'), plainText.encode('utf-8'), 'SHA1').digest()
new_bin = bin + plainText.encode()
signature = base64.encodebytes(new_bin).decode()
signature = signature.replace("\n", "")
data = {'auth': signature, 'filename': pathname}
return jsonify(BASE_RESPONSE(data=data).to_dict())
Controller/ReportController.py 0 → 100644
# -*- coding: utf-8 -*-
import datetime
from flask import Blueprint, jsonify, request, g
from Libs.ErrorTips import BASE_RESPONSE
from Libs.Helper import Helper
from Model.Customer.CustomerModel import Customer
from Service.ReportService import ReportService
route_report = Blueprint('report', __name__)
@route_report.route('/chart', methods=['GET', 'POST'])
def user_chart():
json_data = request.get_json()
spot_id = json_data['spot_id'] if 'spot_id' in json_data else 0
type = json_data['type'] if 'type' in json_data else 1
if type not in [1, 2, 3]:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='type error').to_dict())
yesterday = datetime.datetime.now() - datetime.timedelta(days=1)
zero_yesterday = yesterday - datetime.timedelta(hours=yesterday.hour, minutes=yesterday.minute,
seconds=yesterday.second,
microseconds=yesterday.microsecond)
last_yesterday = zero_yesterday + datetime.timedelta(hours=23, minutes=59, seconds=59)
cur_user = g.user
if cur_user.level == 1:
if type == 2:
seven_start = zero_yesterday - datetime.timedelta(days=6)
data = ReportService.get_history_rent_number_admin(spot_id, seven_start, last_yesterday)
elif type == 3:
thirty_start_date = zero_yesterday - datetime.timedelta(days=29)
data = ReportService.get_history_rent_number_admin(spot_id, thirty_start_date, last_yesterday)
else:
data = ReportService.get_today_rent_number_admin(spot_id)
return jsonify(BASE_RESPONSE(data=data).to_dict())
elif cur_user.level == 2:
if type == 2:
seven_start = zero_yesterday - datetime.timedelta(days=6)
data = ReportService.get_history_rent_number_agent(spot_id, seven_start, last_yesterday)
elif type == 3:
thirty_start_date = zero_yesterday - datetime.timedelta(days=29)
data = ReportService.get_history_rent_number_agent(spot_id, thirty_start_date, last_yesterday)
else:
data = ReportService.get_today_rent_number_agent(spot_id)
return jsonify(BASE_RESPONSE(data=data).to_dict())
else:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='Failed').to_dict())
@route_report.route('/gender')
def user_gender():
male = 0
female = 0
unknown = 0
gender_info = Customer.query.with_entities(Customer.gender).all()
for info in gender_info:
if info.gender == 1:
male += 1
elif info.gender == 2:
female += 1
else:
unknown += 1
return jsonify({'code': 200, 'msg': 'success', 'data': {'male': male, 'female': female, 'unknown': unknown}})
@route_report.route('/rent_number', methods=['GET', 'POST'])
def user_rent_number():
json_data = request.get_json()
spot_id = json_data['spot_id'] if 'spot_id' in json_data else 0
number_info = ReportService.get_customer_rent_number(spot_id)
return jsonify(BASE_RESPONSE(data=number_info).to_dict())
@route_report.route('/rent_time', methods=['GET', 'POST'])
def user_rent_time():
json_data = request.get_json()
spot_id = json_data['spot_id'] if 'spot_id' in json_data else 0
rent_time_info = ReportService.get_customer_rent_time(spot_id)
return jsonify(BASE_RESPONSE(data=rent_time_info).to_dict())
@route_report.route('/income_chart', methods=['GET', 'POST'])
def user_income_chart():
json_data = request.get_json()
spot_id = json_data['spot_id'] if 'spot_id' in json_data else 0
data_type = json_data['type'] if 'type' in json_data else 1 # 1:七天，2:一个月，3:六个月
if int(data_type) not in [1, 2, 3]:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='type error').to_dict())
if int(data_type) == 2:
start_time, end_time = Helper.get_recent_someday_date(29)
data = ReportService.get_spot_day_income(spot_id, start_time, end_time, 30)
return jsonify(BASE_RESPONSE(data=data).to_dict())
elif int(data_type) == 3:
start_time, end_time = Helper.get_recent_six_month()
data = ReportService.get_spot_month_income(spot_id, start_time, end_time)
return jsonify(BASE_RESPONSE(data=data).to_dict())
else:
start_time, end_time = Helper.get_recent_someday_date(6)
data = ReportService.get_spot_day_income(spot_id, start_time, end_time, 7)
return jsonify(BASE_RESPONSE(data=data).to_dict())
@route_report.route('/over_record', methods=['GET', 'POST'])
def rent_over_record():
json_data = request.get_json()
spot_id = json_data['spot_id'] if 'spot_id' in json_data else 0
data_type = json_data['type'] if 'type' in json_data else 1 # 1:日,2:月
date = json_data['date'] if 'date' in json_data else ''
page = json_data['page'] if 'page' in json_data else 0
limit = json_data['limit'] if 'limit' in json_data else 10
if int(data_type) not in [1, 2]:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='type error').to_dict())
total, data = ReportService.get_spot_rent_record(spot_id, int(data_type), date, page, limit)
return jsonify({'error_code': 200, 'error_message': 'Success', 'total': total, 'data': data})
Controller/SpotController.py 0 → 100644
# -*- coding: utf-8 -*-
from flask import Blueprint, jsonify, g, request
from Libs.ErrorTips import BASE_RESPONSE
from Service.SpotService import SpotService
route_spot = Blueprint('spot', __name__)
@route_spot.route('/spot_info')
def all_spot_info():
info = SpotService.get_spot_info()
return jsonify(BASE_RESPONSE(data=info).to_dict())
@route_spot.route('/spot_machine_list', methods=["POST"])
def get_spot_machine_list():
json_data = request.get_json()
spot_id = json_data.get("spot_id")
info = SpotService.get_spot_machine_list(spot_id)
return jsonify(BASE_RESPONSE(data=info).to_dict())
Controller/ToolController.py 0 → 100644
# -*- coding: utf-8 -*-
import time
from flask import Blueprint, jsonify, request
from Libs.ErrorTips import MACHINE_NOT_EXIST_ERROR, MACHINE_HATCH_NOT_ILLEGAL, MACHINE_NOT_ONLINE, BASE_RESPONSE
from Libs.Onenet.Message.Message import CommandMessage
from Libs.Onenet.OneNetApi import OneNetApi
from Model.Base import db
from Model.Machine.MachineModel import Machine
from Model.Power.PowerModel import Power
from Service.ToolService import ToolService
route_tool = Blueprint('tool', __name__)
@route_tool.route('/power_info', methods=['GET', 'POST'])
def get_power_info():
json_data = request.get_json()
mac_no = json_data['mac_no'] if 'mac_no' in json_data else None
if not mac_no:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='illegal mac no').to_dict())
machine_info = Machine.query.filter_by(mac_no=mac_no).first()
if not machine_info:
return jsonify(MACHINE_NOT_EXIST_ERROR)
data = ToolService.get_power_info_by_machine(machine_info.id)
return jsonify(BASE_RESPONSE(data=data).to_dict())
@route_tool.route('/takeout', methods=['GET', 'POST'])
def take_out():
json_data = request.get_json()
mac_no = json_data['mac_no'] if 'mac_no' in json_data else None
hatch_no = json_data['hatch_no'] if 'hatch_no' in json_data else None
if not mac_no or not hatch_no:
return jsonify(MACHINE_HATCH_NOT_ILLEGAL)
if hatch_no > 60 or hatch_no < 1:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='mac_no or hatch_no error').to_dict())
machine_info = Machine.query.filter_by(mac_no=mac_no).first()
if not machine_info:
return jsonify(MACHINE_NOT_EXIST_ERROR)
if machine_info.life != 1:
return jsonify(MACHINE_NOT_ONLINE)
command_message = CommandMessage(machine_info.he_cloud_device_id, chr(0x46), str(hatch_no - 1))
one_api = OneNetApi()
result = one_api.send_data_to_edp(command_message.get_device_id(), 1, 0, command_message.pack())
if "errno" in result.keys() and result['errno'] == 0:
if result['error'] == 'succ':
return jsonify(BASE_RESPONSE().to_dict())
else:
if "error_message" in result.keys():
return jsonify(BASE_RESPONSE(error_message=result['error_message']).to_dict())
else:
return jsonify(BASE_RESPONSE(error_code=-1, error_message='Fail').to_dict())
@route_tool.route('/takeout_multiple', methods=['GET', 'POST'])
def take_out_multiple():
json_data = request.get_json()
mac_no = json_data['mac_no'] if 'mac_no' in json_data else None
hatch_no_list = json_data['hatch_no'] if 'hatch_no' in json_data else []
if not mac_no or not hatch_no_list:
return jsonify(MACHINE_HATCH_NOT_ILLEGAL)
machine_info = Machine.query.filter_by(mac_no=mac_no).first()
if not machine_info:
return jsonify(MACHINE_NOT_EXIST_ERROR)
if machine_info.life != 1:
return jsonify(MACHINE_NOT_ONLINE)
data = {}
for i in hatch_no_list:
command_message = CommandMessage(machine_info.he_cloud_device_id, chr(0x46), str(i - 1))
one_api = OneNetApi()
result = one_api.send_data_to_edp(command_message.get_device_id(), 1, 0, command_message.pack())
if 'errno' in result.keys() and result['errno'] == 0:
if result['error'] == 'succ':
data[i] = 'success'
Power.query.filter_by(hatch_no=i, machine_id=machine_info.id).update({'status': 8, 'has_power': 0})
db.session.commit()
else:
data[i] = 'fail'
else:
if 'error_message' in result.keys():
data[i] = result['error_message']
else:
data[i] = 'fail'
time.sleep(3)
return jsonify(BASE_RESPONSE(data=data).to_dict())
Controller/__init__.py 0 → 100644
# -*- coding: utf-8 -*-
\ No newline at end of file
Libs/ErrorTips.py 0 → 100644
# -*- coding: utf-8 -*-
class BASE_RESPONSE(object):
def __init__(self, error_code=200, error_message='Success', data=None):
self.error_code = error_code
self.error_message = error_message
self.data = data
def to_dict(self):
return {'error_code': self.error_code, 'error_message': self.error_message, 'data': self.data}
TOKEN_NOT_VALID_ERROR = {
"error_code": 1001,
"error_message": "无效的token"
}
TOKEN_NOT_PROVIDER_ERROR = {
"error_code": 1002,
"error_message": "token未提供"
}
TOKEN_EXPIRE_ERROR = {
"error_code": 1003,
"error_message": "token超时"
}
PHONE_NOT_NULL_ERROR = {
"error_code": 1004,
"error_message": "手机号为空"
}
PHONE_NOT_VALID_ERROR = {
"error_code": 1005,
"error_message": "无效的手机号"
}
PHONE_NOT_PERMISSION = {
"error_code": 1006,
"error_message": "无权登录"
}
LOGIN_ERROR = {
"error_code": 1007,
"error_message": "验证码为空"
}
VERIFICATION_CODE_INVALID_ERROR = {
"error_code": 1008,
"error_message": "验证码已失效"
}
VERIFICATION_CODE_ERROR = {
"error_code": 1009,
"error_message": "验证码错误"
}
USER_NOT_EXIST = {
"error_code": 1010,
"error_message": "用户不存在"
}
PARAMETER_ERROR = {
"error_code": 1011,
"error_message": "参数有误"
}
MACHINE_HATCH_NOT_ILLEGAL = {
"error_code": 1101,
"error_message": "机柜或仓口号错误"
}
MACHINE_NOT_EXIST_ERROR = {
"error_code": 1102,
"error_message": "机柜不存在"
}
MACHINE_NOT_ONLINE = {
"error_code": 1103,
"error_message": "机柜不在线"
}
ACCOUNT_ALREADY_EXISTS_ERROR = {
"error_code": 1201,
"error_message": "该账号已存在"
}
ACCOUNT_NOT_EXISTS_ERROR = {
"error_code": 1202,
"error_message": "账号不存在"
}
ACCOUNT_ALREADY_DELETE_ERROR = {
"error_code": 1203,
"error_message": "账号已被删除"
}
ACCOUNT_AGENT_SPOT_NULL_ERROR = {
"error_code": 1204,
"error_message": "代理商景点列表为空"
}
REFUND_NOT_RENT_INFO = {
"error_code": 1301,
"error_message": "没有该订单信息"
}
REFUND_BACK_TIME_ERROR = {
"error_code": 1302,
"error_message": "归还时间异常"
}
REFUND_NOT_PRODUCTION_INFO = {
"error_code": 1303,
"error_message": "没有该讲解器信息"
}
REFUND_MONEY_IS_ZERO = {
"error_code": 1304,
"error_message": "退款金额为零"
}
OPERATE_TYPE_ERROR = {
"error_code": 1401,
"error_message": "type错误"
}
OPERATE_LEVEL_ERROR = {
"error_code": 1402,
"error_message": "权限错误"
}
OPERATE_ERROR = {
"error_code": 1403,
"error_message": "操作有误"
}
ACTION_CODE_ERROR = {
"error_code": 1501,
"error_message": "退款操作码错误"
}
Libs/Helper/Helper.py 0 → 100644
# -*- coding: utf-8 -*-
import calendar
import datetime
import re
import time
def getFormatDate(date=None, format="%Y-%m-%d %H:%M:%S"):
'''
获取格式化时间
:param date: 时间
:param format: 格式
:return:
'''
if date is None:
date = datetime.datetime.now()
return date.strftime(format)
def getTodayDate():
'''
获取今天零点和24点
:return:
'''
now = datetime.datetime.now()
zero_today = now - datetime.timedelta(hours=now.hour, minutes=now.minute, seconds=now.second,
microseconds=now.microsecond)
last_today = zero_today + datetime.timedelta(hours=23, minutes=59, seconds=59)
return getFormatDate(zero_today), getFormatDate(last_today)
def getSevenDate():
'''
获取近七天零点和24点
:return:
'''
now = datetime.datetime.now()
zero_today = now - datetime.timedelta(hours=now.hour, minutes=now.minute, seconds=now.second,
microseconds=now.microsecond)
last_today = zero_today + datetime.timedelta(hours=23, minutes=59, seconds=59)
seven_start = zero_today - datetime.timedelta(days=6)
return getFormatDate(seven_start), getFormatDate(last_today)
def get_recent_someday_date(days):
now = datetime.datetime.now() - datetime.timedelta(days=1)
zero_today = now - datetime.timedelta(hours=now.hour, minutes=now.minute, seconds=now.second,
microseconds=now.microsecond)
last_today = zero_today + datetime.timedelta(hours=23, minutes=59, seconds=59)
seven_start = zero_today - datetime.timedelta(days=days)
return seven_start.strftime('%Y-%m-%d'), last_today.strftime('%Y-%m-%d')
def get_recent_six_month():
now = datetime.datetime.now()
first = now.replace(day=1)
last_month = first - datetime.timedelta(days=1)
second = last_month.replace(day=1)
last_second_month = second - datetime.timedelta(days=1)
third = last_second_month.replace(day=1)
last_third_month = third - datetime.timedelta(days=1)
four = last_third_month.replace(day=1)
last_four_month = four - datetime.timedelta(days=1)
five = last_four_month.replace(day=1)
last_five_month = five - datetime.timedelta(days=1)
six = last_five_month.replace(day=1)
last_six_month = six - datetime.timedelta(days=1)
return last_six_month.strftime('%Y%m'), last_month.strftime('%Y%m')
def getYesterdayDate():
'''
获取昨天零点和24点
:return:
'''
now = datetime.datetime.now() - datetime.timedelta(days=1)
zero_today = now - datetime.timedelta(hours=now.hour, minutes=now.minute, seconds=now.second,
microseconds=now.microsecond)
last_today = zero_today + datetime.timedelta(hours=23, minutes=59, seconds=59)
return getFormatDate(zero_today), getFormatDate(last_today)
def getWeekDate():
'''
获取本周一和周日
:return:
'''
now = datetime.datetime.now()
zero_week = now - datetime.timedelta(days=now.weekday(), hours=now.hour, minutes=now.minute, seconds=now.second,
microseconds=now.microsecond)
last_week = now + datetime.timedelta(days=6 - now.weekday(), hours=23 - now.hour, minutes=59 - now.minute,
seconds=59 - now.second)
return getFormatDate(zero_week), getFormatDate(last_week)
def getLastWeekDate():
'''
获取上周一和周日
:return:
'''
now = datetime.datetime.now()
zero_last_week = now - datetime.timedelta(days=now.weekday() + 7, hours=now.hour, minutes=now.minute,
seconds=now.second, microseconds=now.microsecond)
last_last_week = now - datetime.timedelta(days=now.weekday() + 1) \
+ datetime.timedelta(hours=23 - now.hour, minutes=59 - now.minute, seconds=59 - now.second)
return getFormatDate(zero_last_week), getFormatDate(last_last_week)
def getMonthDate():
'''
获取本月第一天和最后一天
:return:
'''
now = datetime.datetime.now()
zero_month = datetime.datetime(now.year, now.month, 1)
cur_month = now.month
cur_year = now.year
if now.month == 12:
cur_month = 0
cur_year += 1
last_month = datetime.datetime(cur_year, cur_month + 1, 1) - datetime.timedelta(days=1) + datetime.timedelta(
hours=23, minutes=59, seconds=59)
return getFormatDate(zero_month), getFormatDate(last_month)
def getLastMonthDate():
'''
获取上月第一天和最后一天
:return:
'''
now = datetime.datetime.now()
last_last_month = datetime.datetime(now.year, now.month, 1) - datetime.timedelta(days=1) + datetime.timedelta(
hours=23, minutes=59, seconds=59)
zero_last_month = datetime.datetime(last_last_month.year, last_last_month.month, 1)
return getFormatDate(zero_last_month), getFormatDate(last_last_month)
def checkPhone(phone):
phone_pat = re.compile('^(13\d|14[5|7]|15\d|166|17[3|6|7]|18\d|19\d)\d{8}$')
res = re.search(phone_pat, phone)
return res
def checkTime(start_time, end_time):
if start_time is None or end_time is None:
return 0
start_time_array = time.strptime(str(start_time), "%Y-%m-%d %H:%M:%S")
end_time_array = time.strptime(str(end_time), "%Y-%m-%d %H:%M:%S")
start_time_stamp = time.mktime(start_time_array)
end_time_stamp = time.mktime(end_time_array)
use_time = end_time_stamp - start_time_stamp
return round(use_time / 60, 2)
def get_this_month_day(date):
if date:
date_list = date.split('-')
if len(date_list) == 2:
new_date = calendar.monthrange(int(date_list[0]), int(date_list[1]))
return '-' + str(new_date[1]) + ' 23:59:59'
Libs/Logger.py 0 → 100644
# -*- coding: utf-8 -*-
import logging
import os
from logging.handlers import TimedRotatingFileHandler
class Log(object):
def __init__(self, name, level=logging.DEBUG):
self.name = name
self.level = level
self.path = os.getcwd() + "/logs/"
self.formatter = logging.Formatter("%(asctime)s - %(filename)s -[line:%(lineno)d] - %(levelname)s: %(message)s",
"%Y-%m-%d %H:%M:%S")
def getLogger(self):
logger = logging.getLogger(self.name)
logger.setLevel(self.level)
# logger.addHandler(self.get_file_handler())
logger.addHandler(self.get_console_handler())
return logger
def get_file_handler(self):
file_name = "{0}{1}.log".format(self.path, self.name)
file_handler = TimedRotatingFileHandler(
filename=file_name,
when="D",
interval=1,
backupCount=7
)
file_handler.suffix = "%Y-%m-%d"
file_handler.setLevel(self.level)
file_handler.setFormatter(self.formatter)
return file_handler
def get_console_handler(self):
console_handler = logging.StreamHandler()
console_handler.setLevel(self.level)
console_handler.setFormatter(self.formatter)
return console_handler
logger = Log(name='main').getLogger()
Libs/Onenet/Message/Message.py 0 → 100644
# -*- coding: utf-8 -*-
from abc import ABCMeta, abstractmethod
class Message(metaclass=ABCMeta):
def __init__(self, device_id):
self.device_id = device_id
def get_device_id(self):
return self.device_id
def set_device_id(self, device_id):
self.device_id = device_id
@abstractmethod
def pack(self):
pass
@abstractmethod
def unpack(self, value):
pass
class CommandMessage(Message):
def __init__(self, device_id, command, *param):
super().__init__(device_id)
self.command = command
self.param = param
def get_command(self):
return self.command
def set_command(self, command):
self.command = command
def pack(self):
params = (str(i) for i in self.param)
msg = "{" + self.command + ''.join(params) + "}"
return msg
def unpack(self, value):
print('unpack')
Libs/Onenet/OneNet.py 0 → 100644
# -*- coding: utf-8 -*-
from Libs.Onenet.Message.Message import CommandMessage
from Libs.Onenet.OneNetApi import OneNetApi
class OneNet(object):
@staticmethod
def open(machine, position):
command_message = CommandMessage(machine.he_cloud_device_id, chr(0x46), str(position - 1))
one_api = OneNetApi()
result = one_api.send_data_to_edp(command_message.get_device_id(), 1, 0, command_message.pack())
if not result or result.get("error", None) is not None:
return False
return True
Libs/cert/AllTour_cert/apiclient_cert.pem 0 → 100644
-----BEGIN CERTIFICATE-----
MIIEbDCCA9WgAwIBAgIEAWJK2zANBgkqhkiG9w0BAQUFADCBijELMAkGA1UEBhMC
Q04xEjAQBgNVBAgTCUd1YW5nZG9uZzERMA8GA1UEBxMIU2hlbnpoZW4xEDAOBgNV
BAoTB1RlbmNlbnQxDDAKBgNVBAsTA1dYRzETMBEGA1UEAxMKTW1wYXltY2hDQTEf
MB0GCSqGSIb3DQEJARYQbW1wYXltY2hAdGVuY2VudDAeFw0xNzA4MDcwOTAwNDZa
Fw0yNzA4MDUwOTAwNDZaMIGbMQswCQYDVQQGEwJDTjESMBAGA1UECBMJR3Vhbmdk
b25nMREwDwYDVQQHEwhTaGVuemhlbjEQMA4GA1UEChMHVGVuY2VudDEOMAwGA1UE
CxMFTU1QYXkxMDAuBgNVBAMUJ+iLj+W3numaj+i6q+eOqeS/oeaBr+aKgOacr+ac
iemZkOWFrOWPuDERMA8GA1UEBBMINDEyOTEyMTcwggEiMA0GCSqGSIb3DQEBAQUA
A4IBDwAwggEKAoIBAQDeUEFC0H3NiPALgWZQGtAEFoyiAMEcGKWKxDAXA+7RTzkH
Y6rRqWa4UtmLn+y2Dq3Bqj0JV9/hpxH4XDGmyVEPoeX1vrvjY+hZa5vsHo5iAowC
+/5tfbSK0MCIqLVu32RUL/2XNKzu1uI9qJCyG5S5xviwY+LUsIiQVSYS68xxPmQi
UvB/Si7nPVu8flQp/CErGj67+UnfRstzdlXmIedVZI2B/zDY36GWz99OcC1vKAoH
1Qyr0djSPKUjBW728SgKgt7koS1DV4tQdd+Z3d0JUMaf1xC3HQgYxrIsOAo/mRki
fCvRG19WB6UgQn57pAPQ1aRmc8uHoc4K0t5PG3z3AgMBAAGjggFGMIIBQjAJBgNV
HRMEAjAAMCwGCWCGSAGG+EIBDQQfFh0iQ0VTLUNBIEdlbmVyYXRlIENlcnRpZmlj
YXRlIjAdBgNVHQ4EFgQUkwjPtBG/QHSUDjRnzQs7jkYgkHwwgb8GA1UdIwSBtzCB
tIAUPgUm9iJitBVbiM1kfrDUYqflhnShgZCkgY0wgYoxCzAJBgNVBAYTAkNOMRIw
EAYDVQQIEwlHdWFuZ2RvbmcxETAPBgNVBAcTCFNoZW56aGVuMRAwDgYDVQQKEwdU
ZW5jZW50MQwwCgYDVQQLEwNXWEcxEzARBgNVBAMTCk1tcGF5bWNoQ0ExHzAdBgkq
hkiG9w0BCQEWEG1tcGF5bWNoQHRlbmNlbnSCCQC7VJcrvADoVzAOBgNVHQ8BAf8E
BAMCBsAwFgYDVR0lAQH/BAwwCgYIKwYBBQUHAwIwDQYJKoZIhvcNAQEFBQADgYEA
NkWBjd8qNtg5LT8u+lns5kmoqMgJmPqWsLkeAdDzGQgk0umVIivnbvjBK9gyQDo8
M3uQjHDOeoL9kpYQoZCzcC/0NqMluXjmvfXiarc1lv2RYu4nNoUVp4ix/15dFhML
pS65pTZ3LXXDigY76nFOu6XztJNvylnDZ/c7nejsC3g=
-----END CERTIFICATE-----
Libs/cert/AllTour_cert/apiclient_key.pem 0 → 100644
-----BEGIN PRIVATE KEY-----
MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDeUEFC0H3NiPAL
gWZQGtAEFoyiAMEcGKWKxDAXA+7RTzkHY6rRqWa4UtmLn+y2Dq3Bqj0JV9/hpxH4
XDGmyVEPoeX1vrvjY+hZa5vsHo5iAowC+/5tfbSK0MCIqLVu32RUL/2XNKzu1uI9
qJCyG5S5xviwY+LUsIiQVSYS68xxPmQiUvB/Si7nPVu8flQp/CErGj67+UnfRstz
dlXmIedVZI2B/zDY36GWz99OcC1vKAoH1Qyr0djSPKUjBW728SgKgt7koS1DV4tQ
dd+Z3d0JUMaf1xC3HQgYxrIsOAo/mRkifCvRG19WB6UgQn57pAPQ1aRmc8uHoc4K
0t5PG3z3AgMBAAECggEAIepAan8AEjEH3dl50FKm1VjTT4up6i1gY9EWPQyejFP3
sUblMmMThp8tDP3y0LtgiqD7+sbrIrOoLCl0catYsHfUay8T3tbJBYtDGDx5ID6f
OX1UDUQWHO9H0BFczHNMDQPdPgoNL8qcbSegG2vVvpm6Kr6yRhxAWTSEQHK0l7nS
F30WM0uTtu4iaJi71MCvZZSHiRkr1hJettfeECJYZoCxxKpI/+DXV2bi1xVbyBTl
k4/n6sBV7lSS5ELsm4RGkV9YIMuHmjeV0qGn4pnvt79tCK72KAP5a06OorrVHUqH
IKymJqi8MTPceI4h2D2Q3XN0YUUjAsko2bg54kQBgQKBgQD4dck0IizWQdu2fb3W
n/42I7XEA9YtgXuiQRAnSgzTi6Yk98vcVyDDUi4xfw8JzxvPSpIlItJVEEiQSJOt
9nK6VXW5ZAGiG6C2RKrtZ4bWEYmp57C0mu3Q3X7NBez/mRkvkc2p64ZN4o9p4pBL
NKow0EFH+0LaTVHkgef39Qh91wKBgQDlD1f3p8jtClIYMYKrLjW7wUmd2+o+VpFT
Dkfx39Kx9GzS0UdpwUAXdrWX8a9q33raMj0hih5GSc0hYOA+TVZ7feZxwDwvfsra
uY/9Z7ShoYKs35Tz0i6quqQtbOz47bDo63uvivf8C/juXR+tdJFt8Dw7he9v7IT5
sduzVXfV4QKBgQCGJFmf+v+IIgB0k4jF8pV2N2twS737zZepb0VAYRtxr0jhVqPK
74Nx0NG9yWKeIiJalWE4CYfTgzoaJAUPfCpO7crkb9jt48qt/X7nM+i5dLiFceCW
cbsJ9Dv8h0GAcfEGHMsT/WQCctqJCVhsMh/cwOMt8LsUT4ByRayu061k+wKBgQC0
Pz22uUZoGS3+sb8kWwmXhIMcgHg0s8RJujws/jb7J98Wie6LLrHzhMtjFKE4FUHE
P7JRGTG3l82ejXAINq1uIeVb76yspzaTpV/ERX4jjkeZJ5s7vlJQsOwOft9/BvOm
Zd9/hHid0wIA+DC8OrVR8LBFGqEOzuzY2/eJiCDzoQKBgQDmPl4D02GIeORgO46R
/SVVMdK4/wz9OhwaWX2NNkHi6d5YZjR+e0w7XmmmT1n8C+Dcf0i3EdSCH2ci9kYU
dQ5A0wHPVYX1tw6yeqQYXYyfVHwcLCZO4sTJXUwD2OZ4AncjhI3PG1YnhJUov0Y8
dVXi8bkgyP/Wo47YevasN7t2qQ==
-----END PRIVATE KEY-----
Libs/cert/invoice/cert.pem 0 → 100644
Bag Attributes
friendlyName: ޏo/ Pl
localKeyID: 54 69 6D 65 20 31 35 37 39 30 35 33 34 35 35 35 37 37
Key Attributes: <No Attributes>
-----BEGIN PRIVATE KEY-----
MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBAOHP9QLh1+lz1zm8
BtfzJpbESBlZhhrSRzgCDVLDJs1nVawe5jSK7xK93Q89oarPy/pJEA33ChezSfWD
UAiY/0Md5e+A1LgP/TPWdPFkSaI2GyNifz4XqffwlHW9tM8gS9/4gjWKXcxaQ2UZ
fPtnRK0SNVIq+zQ6RQ/q7nb3QYR5AgMBAAECgYBlGnYp/zJr3SjtOamawMxzTpi1
eObZVXL7ubd7adMSvoSWVxNdTSNzsbyrWT3sO7OpcVMV3ZkQOX8QxOVtpAsNi0eH
sKZd8l+I41d0RIMIbiWhicXC64vZy4VO0hrCCiIJ+6k0e0xX80++b/tuXiuCuOST
Fo1zgBV2Epcx7WYPjQJBAP7ao0KNPKVcvF4fx8LP3FLFtrsLsCpZF38WbzK3IVIA
YpZovoaxFuP8UFgMKXiyxQWgFwFK34PBI/D1kfxZqIcCQQDi0+OyfxYRRHCAFe59
BcPjeQXQ7K/GZfyesUdGPNVl6l5nzbfrYy+osJ0TpKPRd2cU4s8BYJtd/3dz9FX2
76r/AkBxzI86GHcMH+y82tQIWWi4TTDbNMzlHAMx7IKa0ss+Io3jO8JXwpvGEdSO
fF/IVYtEh8e9/ADyhDvYTM9zL1XhAkA935jL9vi5Cxc5CUJ93hW6NigM/pNQJj/L
tgYANdXsMAtCe45A6lR0yoB+fDmniM+YlenrsUOQV4BpI+xTKLtXAkA1EnstEXVP
M2DaEbHy4K7wjtcZxSdvOMrw/GMf+Zwp/6mnhFrx7wYVFmM0rD0z2dUzQaAJu9E8
hVKcbRGrlRfY
-----END PRIVATE KEY-----
Bag Attributes
friendlyName: ޏo/ Pl
localKeyID: 54 69 6D 65 20 31 35 37 39 30 35 33 34 35 35 35 37 37
subject=/C=CN/ST=\xE5\xB9\xBF\xE4\xB8\x9C\xE7\x9C\x81/L=\xE6\xB7\xB1\xE5\x9C\xB3\xE5\xB8\x82/O=\xE8\x8B\x8F\xE5\xB7\x9E\xE9\x9A\x8F\xE8\xBA\xAB\xE7\x8E\xA9\xE4\xBF\xA1\xE6\x81\xAF\xE6\x8A\x80\xE6\x9C\xAF\xE6\x9C\x89\xE9\x99\x90\xE5\x85\xAC\xE5\x8F\xB8/OU=913205943138134162/CN=\xE8\x8B\x8F\xE5\xB7\x9E\xE9\x9A\x8F\xE8\xBA\xAB\xE7\x8E\xA9\xE4\xBF\xA1\xE6\x81\xAF\xE6\x8A\x80\xE6\x9C\xAF\xE6\x9C\x89\xE9\x99\x90\xE5\x85\xAC\xE5\x8F\xB8
issuer=/C=CN/ST=Guangdong/L=Shenzhen/O=fapiao.com/OU=fapiao.com/CN=FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIIDKzCCAhOgAwIBAgILAav439MuoTwyGG8wDQYJKoZIhvcNAQELBQAwczELMAkG
A1UEBhMCQ04xEjAQBgNVBAgTCUd1YW5nZG9uZzERMA8GA1UEBxMIU2hlbnpoZW4x
EzARBgNVBAoTCmZhcGlhby5jb20xEzARBgNVBAsTCmZhcGlhby5jb20xEzARBgNV
BAMTCkZBUElBTy5DT00wIBcNMjAwMTE1MDE1NzM1WhgPMjA1MDAxMDcwMTU3MzVa
MIG2MQswCQYDVQQGEwJDTjESMBAGA1UECAwJ5bm/5Lic55yBMRIwEAYDVQQHDAnm
t7HlnLPluIIxMDAuBgNVBAoMJ+iLj+W3numaj+i6q+eOqeS/oeaBr+aKgOacr+ac
iemZkOWFrOWPuDEbMBkGA1UECxMSOTEzMjA1OTQzMTM4MTM0MTYyMTAwLgYDVQQD
DCfoi4/lt57pmo/ouqvnjqnkv6Hmga/mioDmnK/mnInpmZDlhazlj7gwgZ8wDQYJ
KoZIhvcNAQEBBQADgY0AMIGJAoGBAOHP9QLh1+lz1zm8BtfzJpbESBlZhhrSRzgC
DVLDJs1nVawe5jSK7xK93Q89oarPy/pJEA33ChezSfWDUAiY/0Md5e+A1LgP/TPW
dPFkSaI2GyNifz4XqffwlHW9tM8gS9/4gjWKXcxaQ2UZfPtnRK0SNVIq+zQ6RQ/q
7nb3QYR5AgMBAAEwDQYJKoZIhvcNAQELBQADggEBAD0akYERYKvOtwZywEQa0SW6
6q9zRYzuxD9GlW1jqDYMnnorJeseasMDrzOv2OG1zR4foIen80gMS1d1KV1PzGVo
HQI84/xrdAxRuvolbHlcUOQD9wxXZe6985hygWI4cCIKTzSGIFNkH+wPQbtzJFSV
+k0526JitlhWNCG3pCAYPNiB+Hv3DzTDJsHJ/Q0g5wS2s0jSvKqNZQrwzQJfaj7X
pUq+48EieATuq9yze22zC6EdTScScJV4BHagQ3Nt+kXs4IiVomOYtdQzhZPLBnfb
Rpb5x1pgCG5AKGkiwUs4OW//RrSgskT2KOJl+N9xVYCx+eeM1pblF/h10Jwir6E=
-----END CERTIFICATE-----
Bag Attributes
friendlyName: CN=FAPIAO.COM,OU=fapiao.com,O=fapiao.com,L=Shenzhen,ST=Guangdong,C=CN
subject=/C=CN/ST=Guangdong/L=Shenzhen/O=fapiao.com/OU=fapiao.com/CN=FAPIAO.COM
issuer=/C=CN/ST=Guangdong/L=Shenzhen/O=fapiao.com/OU=fapiao.com/CN=FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIID0zCCArugAwIBAgIBATANBgkqhkiG9w0BAQsFADBzMQswCQYDVQQGEwJDTjES
MBAGA1UECBMJR3Vhbmdkb25nMREwDwYDVQQHEwhTaGVuemhlbjETMBEGA1UEChMK
ZmFwaWFvLmNvbTETMBEGA1UECxMKZmFwaWFvLmNvbTETMBEGA1UEAxMKRkFQSUFP
LkNPTTAeFw0xNzAzMTcwMDAwMDBaFw00NzAzMTcwMDAwMDBaMHMxCzAJBgNVBAYT
AkNOMRIwEAYDVQQIEwlHdWFuZ2RvbmcxETAPBgNVBAcTCFNoZW56aGVuMRMwEQYD
VQQKEwpmYXBpYW8uY29tMRMwEQYDVQQLEwpmYXBpYW8uY29tMRMwEQYDVQQDEwpG
QVBJQU8uQ09NMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAzYNOZvkd
6gHrJ1HmiymABAYZv301G6gl3oRTXCjHuSymAtLiBIH2JNkc3RPbLGVhrfBDl+DO
W/cLZw1uamSmu+eaPkm2BN0jOR8Tsl157jNqNCaW7KFtuTrRJMknpdJ8BRIyF5V6
g9US+KyodJA0oyF5pZPSWhyPE13EWR1d7cMxNReM0XBL9A5Pg+IS8X2LmE1Ao+uL
ALEz7Rz7RMpVhpZbR/r6ffWFrvSrPrmJg2aA+KjUHWEOx96mTFCRRUY8JkqaV4Pp
9SVdee/u00gqdK9DFPsMvFWt9s9olSUoGujTFbrVxcHBdBgGSnoBLdohmHM49F6d
WGwWJLZgrqj2JwIDAQABo3IwcDAPBgNVHRMBAf8EBTADAQH/MB0GA1UdDgQWBBSE
Fk9/I8TFerc3y4O/q1OWCdTBOTALBgNVHQ8EBAMCAQYwEQYJYIZIAYb4QgEBBAQD
AgAHMB4GCWCGSAGG+EIBDQQRFg94Y2EgY2VydGlmaWNhdGUwDQYJKoZIhvcNAQEL
BQADggEBAGvzauj7RHJSFe3IlzNHunLJKKsTi6vOhVSR0J1RtmVRI1Pu1qcUkhpN
OiLhVbR/yhbEP1YfepqubP0E3rx70RIzYhhUxsHobmC/tu2/iKkX3IbFV0h2JI3Y
TjtdsxE64TJUbiLpq+gaIQTA0uZaQQ+Zpnh19rFbxLEzw8a9TSQS845eXX5LHUH3
ndpc6gMI4K1r36sZvd0MKbX2mOGPOD5tjnAsZDEndcxoL9z/A4ylh7mYuuYtR1GR
fC7a7hMSX9iPy1pMyc6mTq6WzLuJM81+UYjzNxXZEHmXkoziw2wI1n8SWveTN6Pi
oBFqXBY8Xqaz5nSPve3PLd6xYro7bBQ=
-----END CERTIFICATE-----
Libs/cert/invoice/cert2.crt 0 → 100644
-----BEGIN CERTIFICATE-----
MIIF5TCCBM2gAwIBAgIQHYtZAdpWwLET8sFQNsSUzDANBgkqhkiG9w0BAQsFADBE
MQswCQYDVQQGEwJDTjEaMBgGA1UECgwRV29TaWduIENBIExpbWl0ZWQxGTAXBgNV
BAMMEFdvU2lnbiBPViBTU0wgQ0EwHhcNMTcwODA4MDc1NTA2WhcNMjAwODA2MDc1
NTA2WjCBkzELMAkGA1UEBhMCQ04xRTBDBgNVBAoMPOeZvuacm+eUteWtkOWPkeel
qOaVsOaNruacjeWKoeaciemZkOWFrOWPuOa3seWcs+i/kOiQpeS4reW/gzESMBAG
A1UEBwwJ5rex5Zyz5biCMRIwEAYDVQQIDAnlub/kuJznnIExFTATBgNVBAMMDCou
ZmFwaWFvLmNvbTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAMe68gUh
2LHtow0SIGBhBbZlFXclyhSdr+gkPPAW4WeEBtiXwFcTBykZV3hbwqvXeC/npmnd
cuTMlovjdcheIE377ivzqvgJTBwQVhFpI3/gFvrPbdF2Pm8TQTjkoirQjMjeHRyh
rxo1gRRoVR8MI3q/C6CgYG2tqgVMC/lgluX36OT+Pzzotbqnurf2IrzWVDiwTFXQ
dQelAH2WV8m3nw5A/hu9/WnIDorK0Q3VSEx53Md1iYy1oHj13h5/cvmRXSl3P7oS
mrADHp63XRiQiG+vgIrcGOkw5aSo3Xu7eGt1+maOj2NGHfTZRy0UnROrpt+E9m8+
rZvgkmfNgMi0r4cCAwEAAaOCAoEwggJ9MAwGA1UdEwEB/wQCMAAwPAYDVR0fBDUw
MzAxoC+gLYYraHR0cDovL3dvc2lnbi5jcmwuY2VydHVtLnBsL3dvc2lnbi1vdmNh
LmNybDB3BggrBgEFBQcBAQRrMGkwLgYIKwYBBQUHMAGGImh0dHA6Ly93b3NpZ24t
b3ZjYS5vY3NwLWNlcnR1bS5jb20wNwYIKwYBBQUHMAKGK2h0dHA6Ly9yZXBvc2l0
b3J5LmNlcnR1bS5wbC93b3NpZ24tb3ZjYS5jZXIwHwYDVR0jBBgwFoAUoRNU3FZz
LCeCysiE7+6/AP1fq1YwHQYDVR0OBBYEFN+JmFD32Qxm6NjMJst5qqtwv3NvMA4G
A1UdDwEB/wQEAwIFoDCCASAGA1UdIASCARcwggETMAgGBmeBDAECAjCCAQUGDCqE
aAGG9ncCBQEMAjCB9DCB8QYIKwYBBQUHAgIwgeQwHxYYQXNzZWNvIERhdGEgU3lz
dGVtcyBTLkEuMAMCAQEagcBVc2FnZSBvZiB0aGlzIGNlcnRpZmljYXRlIGlzIHN0
cmljdGx5IHN1YmplY3RlZCB0byB0aGUgQ0VSVFVNIENlcnRpZmljYXRpb24gUHJh
Y3RpY2UgU3RhdGVtZW50IChDUFMpIGluY29ycG9yYXRlZCBieSByZWZlcmVuY2Ug
aGVyZWluIGFuZCBpbiB0aGUgcmVwb3NpdG9yeSBhdCBodHRwczovL3d3dy5jZXJ0
dW0ucGwvcmVwb3NpdG9yeS4wHQYDVR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUFBwMC
MCMGA1UdEQQcMBqCDCouZmFwaWFvLmNvbYIKZmFwaWFvLmNvbTANBgkqhkiG9w0B
AQsFAAOCAQEAVbW/dkDpLso5ysVgzj6Tpaida0LXvRcfWzoFIi6WHMU4hGNNcdPh
K9bRHys8ue6WjuC170pFhKeSmrF/ph4xIGd66a/zM4IrJwFKn1xnbHEZNJBCtEfJ
x19zQUd9EkHZDqpj+pWZFVf7Cwzw7IPuCSZShZr7FZLX8Muddpv+gP158yDzw0tH
RClcsSgNjQntjxWvAt8O91Xgr3+YK0h2v0t51Lj7GOsz7Wb4jAB+5dD2lBpXjCrU
EEIqSsdypwLY8cvVbB93Nvg1LDTFrS27Gzu4Nr+7/RvtvsVmppy9bhxzbwOgO4TL
D3E3nXiSFBBYlfk1jEp9ywrRi7Fj2Vm2Wg==
-----END CERTIFICATE-----
Libs/cert/invoice/cert2.key 0 → 100644
-----BEGIN RSA PRIVATE KEY-----
MIICXQIBAAKBgQCXsNL6cWpwZ2rEtUNKCF2ogaMJSqdeHoeMQq4YwP+FpEcrWupl
nkOGundwMZaXDG522PjQeR4AVXPUQ8jy8y5GwbUVi6Mmx2p3r1V0OfJ3G1gLdTcI
mAGfunYM3QJIEy6rdznb1pU5sm0UHOQPliJODhlVLPxfAxVkwEdM6DMp/QIDAQAB
AoGAadyskL2gI8v4tkkuKbeG7XdzeaORBF1YCanraDkg2nqYdIhhdwOpapgtjK3+
w3GYkfbARnWQW3lHecbIsczG6N5m8k8wXkX/p485nQB00kBjS46y4rxsdW6sDjTp
L/0xvlWNUZNlpSvMEzxPxM2lMlq/lFSpittFaX7KntfOxF0CQQD28Y2sM+xOPRqz
/FWtwmzlUWS87RQWhXBWDR4MS5gD4iNr8ljBQwvKZiMjKTnsy5lekbmnEfXXFFpq
W8zyd4fDAkEAnUD7mxD2ix9OM0NsWTtH3mu8wZPqELSlI+NVYm9c6TM+7njvTS+E
pkrAXfnaYhpW/RAROFbDtTw0S/1j/mkrPwJATbcNYAFjP+gpDDXAfROwE6c+7doq
tT+/b8VnDHWJ3McBYMp/Nis0fbkRG9KwoR4eIU35QGP9m3eTUN+dKz2E4wJBAJCt
A48DyT/v2ltxkZJ65sEsb+nM8xDRkgl1ks3QVTO70Q9HtipWKH1x0o/jWlbdkuCa
Uq15re7k59xt0Px0t7MCQQCa+aOmU8A9O2sdhnMN+AWlFxNIPvgW2zp1d3qvl7mE
qvUu6m/3pl9ZvGSE23EvQMx8zBcMQSJB8OHtIIjX1i1j
-----END RSA PRIVATE KEY-----
Libs/cert/invoice/cert22.key 0 → 100644
-----BEGIN RSA PRIVATE KEY-----
MIICXQIBAAKBgQCXsNL6cWpwZ2rEtUNKCF2ogaMJSqdeHoeMQq4YwP+FpEcrWupl
nkOGundwMZaXDG522PjQeR4AVXPUQ8jy8y5GwbUVi6Mmx2p3r1V0OfJ3G1gLdTcI
mAGfunYM3QJIEy6rdznb1pU5sm0UHOQPliJODhlVLPxfAxVkwEdM6DMp/QIDAQAB
AoGAadyskL2gI8v4tkkuKbeG7XdzeaORBF1YCanraDkg2nqYdIhhdwOpapgtjK3+
w3GYkfbARnWQW3lHecbIsczG6N5m8k8wXkX/p485nQB00kBjS46y4rxsdW6sDjTp
L/0xvlWNUZNlpSvMEzxPxM2lMlq/lFSpittFaX7KntfOxF0CQQD28Y2sM+xOPRqz
/FWtwmzlUWS87RQWhXBWDR4MS5gD4iNr8ljBQwvKZiMjKTnsy5lekbmnEfXXFFpq
W8zyd4fDAkEAnUD7mxD2ix9OM0NsWTtH3mu8wZPqELSlI+NVYm9c6TM+7njvTS+E
pkrAXfnaYhpW/RAROFbDtTw0S/1j/mkrPwJATbcNYAFjP+gpDDXAfROwE6c+7doq
tT+/b8VnDHWJ3McBYMp/Nis0fbkRG9KwoR4eIU35QGP9m3eTUN+dKz2E4wJBAJCt
A48DyT/v2ltxkZJ65sEsb+nM8xDRkgl1ks3QVTO70Q9HtipWKH1x0o/jWlbdkuCa
Uq15re7k59xt0Px0t7MCQQCa+aOmU8A9O2sdhnMN+AWlFxNIPvgW2zp1d3qvl7mE
qvUu6m/3pl9ZvGSE23EvQMx8zBcMQSJB8OHtIIjX1i1j
-----END RSA PRIVATE KEY-----
Libs/cert/invoice/cert22.pem 0 → 100644
Bag Attributes
localKeyID: 91 7A D8 5B 8B 8D 00 24 4F AE DE 99 5C 59 AF A0 E5 32 A6 58
subject=/C=CN/ST=SC/L=CD/O=BenZeph/OU=ISI/CN=\xE6\xB5\x8B\xE8\xAF\x95\xE8\xAF\x81\xE4\xB9\xA6
issuer=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIIC2TCCAcGgAwIBAgIENNsNsjANBgkqhkiG9w0BAQsFADCBgjELMAkGA1UEBhMC
Q04xEjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UEBxMIU0hFTlpIRU4xGDAWBgNV
BAoTD3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMPdGVzdC5mYXBpYW8uY29tMRgw
FgYDVQQDEw9URVNULkZBUElBTy5DT00wHhcNMTcwMzIxMDcyMjQxWhcNMjcwMzE5
MDcyMjQxWjBeMQswCQYDVQQGEwJDTjELMAkGA1UECBMCU0MxCzAJBgNVBAcTAkNE
MRAwDgYDVQQKEwdCZW5aZXBoMQwwCgYDVQQLEwNJU0kxFTATBgNVBAMMDOa1i+iv
leivgeS5pjCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEAl7DS+nFqcGdqxLVD
SghdqIGjCUqnXh6HjEKuGMD/haRHK1rqZZ5Dhrp3cDGWlwxudtj40HkeAFVz1EPI
8vMuRsG1FYujJsdqd69VdDnydxtYC3U3CJgBn7p2DN0CSBMuq3c529aVObJtFBzk
D5YiTg4ZVSz8XwMVZMBHTOgzKf0CAwEAATANBgkqhkiG9w0BAQsFAAOCAQEAhUT1
TQQ9Ur+oqKhm25RGyu9IpKi3ZXIoHSUEsVISMEcbr3jvGxcD1ICUE7VytWJGpxFL
kbVbvftaIlUgnqqAjl4f6CRjTNg3Jlx+edS04AzRINWnIqNyABCa4+J3w850DFu4
Jl0ho+ic7Y7mluuvPKeKnWSJIR9letDaaq++hXBT8Pq+VQ4O2hD+XnOvsWYmQGlf
MwLILG9QKpJXVnvbYy1MZY/56mKTWGyMCS/B9OTfx9G2o7PghBoAgbkzcv6GK/l+
WG4qCN4jdTQgaGirSXpMbPBb3OyKSiCZtN1mruja5SbG0Nft8n5/Zx/APHxsYkve
NBMsCYpEjCGr6IaPUw==
-----END CERTIFICATE-----
Bag Attributes
localKeyID: 91 7A D8 5B 8B 8D 00 24 4F AE DE 99 5C 59 AF A0 E5 32 A6 58
Key Attributes: <No Attributes>
Libs/cert/invoice/fapiao.com2018.pem 0 → 100644
-----BEGIN CERTIFICATE-----
MIIF5TCCBM2gAwIBAgIQHYtZAdpWwLET8sFQNsSUzDANBgkqhkiG9w0BAQsFADBE
MQswCQYDVQQGEwJDTjEaMBgGA1UECgwRV29TaWduIENBIExpbWl0ZWQxGTAXBgNV
BAMMEFdvU2lnbiBPViBTU0wgQ0EwHhcNMTcwODA4MDc1NTA2WhcNMjAwODA2MDc1
NTA2WjCBkzELMAkGA1UEBhMCQ04xRTBDBgNVBAoMPOeZvuacm+eUteWtkOWPkeel
qOaVsOaNruacjeWKoeaciemZkOWFrOWPuOa3seWcs+i/kOiQpeS4reW/gzESMBAG
A1UEBwwJ5rex5Zyz5biCMRIwEAYDVQQIDAnlub/kuJznnIExFTATBgNVBAMMDCou
ZmFwaWFvLmNvbTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAMe68gUh
2LHtow0SIGBhBbZlFXclyhSdr+gkPPAW4WeEBtiXwFcTBykZV3hbwqvXeC/npmnd
cuTMlovjdcheIE377ivzqvgJTBwQVhFpI3/gFvrPbdF2Pm8TQTjkoirQjMjeHRyh
rxo1gRRoVR8MI3q/C6CgYG2tqgVMC/lgluX36OT+Pzzotbqnurf2IrzWVDiwTFXQ
dQelAH2WV8m3nw5A/hu9/WnIDorK0Q3VSEx53Md1iYy1oHj13h5/cvmRXSl3P7oS
mrADHp63XRiQiG+vgIrcGOkw5aSo3Xu7eGt1+maOj2NGHfTZRy0UnROrpt+E9m8+
rZvgkmfNgMi0r4cCAwEAAaOCAoEwggJ9MAwGA1UdEwEB/wQCMAAwPAYDVR0fBDUw
MzAxoC+gLYYraHR0cDovL3dvc2lnbi5jcmwuY2VydHVtLnBsL3dvc2lnbi1vdmNh
LmNybDB3BggrBgEFBQcBAQRrMGkwLgYIKwYBBQUHMAGGImh0dHA6Ly93b3NpZ24t
b3ZjYS5vY3NwLWNlcnR1bS5jb20wNwYIKwYBBQUHMAKGK2h0dHA6Ly9yZXBvc2l0
b3J5LmNlcnR1bS5wbC93b3NpZ24tb3ZjYS5jZXIwHwYDVR0jBBgwFoAUoRNU3FZz
LCeCysiE7+6/AP1fq1YwHQYDVR0OBBYEFN+JmFD32Qxm6NjMJst5qqtwv3NvMA4G
A1UdDwEB/wQEAwIFoDCCASAGA1UdIASCARcwggETMAgGBmeBDAECAjCCAQUGDCqE
aAGG9ncCBQEMAjCB9DCB8QYIKwYBBQUHAgIwgeQwHxYYQXNzZWNvIERhdGEgU3lz
dGVtcyBTLkEuMAMCAQEagcBVc2FnZSBvZiB0aGlzIGNlcnRpZmljYXRlIGlzIHN0
cmljdGx5IHN1YmplY3RlZCB0byB0aGUgQ0VSVFVNIENlcnRpZmljYXRpb24gUHJh
Y3RpY2UgU3RhdGVtZW50IChDUFMpIGluY29ycG9yYXRlZCBieSByZWZlcmVuY2Ug
aGVyZWluIGFuZCBpbiB0aGUgcmVwb3NpdG9yeSBhdCBodHRwczovL3d3dy5jZXJ0
dW0ucGwvcmVwb3NpdG9yeS4wHQYDVR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUFBwMC
MCMGA1UdEQQcMBqCDCouZmFwaWFvLmNvbYIKZmFwaWFvLmNvbTANBgkqhkiG9w0B
AQsFAAOCAQEAVbW/dkDpLso5ysVgzj6Tpaida0LXvRcfWzoFIi6WHMU4hGNNcdPh
K9bRHys8ue6WjuC170pFhKeSmrF/ph4xIGd66a/zM4IrJwFKn1xnbHEZNJBCtEfJ
x19zQUd9EkHZDqpj+pWZFVf7Cwzw7IPuCSZShZr7FZLX8Muddpv+gP158yDzw0tH
RClcsSgNjQntjxWvAt8O91Xgr3+YK0h2v0t51Lj7GOsz7Wb4jAB+5dD2lBpXjCrU
EEIqSsdypwLY8cvVbB93Nvg1LDTFrS27Gzu4Nr+7/RvtvsVmppy9bhxzbwOgO4TL
D3E3nXiSFBBYlfk1jEp9ywrRi7Fj2Vm2Wg==
-----END CERTIFICATE-----
Libs/cert/invoice/rmp.pem 0 → 100644
-----BEGIN CERTIFICATE-----
MIIF5TCCBM2gAwIBAgIQHYtZAdpWwLET8sFQNsSUzDANBgkqhkiG9w0BAQsFADBE
MQswCQYDVQQGEwJDTjEaMBgGA1UECgwRV29TaWduIENBIExpbWl0ZWQxGTAXBgNV
BAMMEFdvU2lnbiBPViBTU0wgQ0EwHhcNMTcwODA4MDc1NTA2WhcNMjAwODA2MDc1
NTA2WjCBkzELMAkGA1UEBhMCQ04xRTBDBgNVBAoMPOeZvuacm+eUteWtkOWPkeel
qOaVsOaNruacjeWKoeaciemZkOWFrOWPuOa3seWcs+i/kOiQpeS4reW/gzESMBAG
A1UEBwwJ5rex5Zyz5biCMRIwEAYDVQQIDAnlub/kuJznnIExFTATBgNVBAMMDCou
ZmFwaWFvLmNvbTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAMe68gUh
2LHtow0SIGBhBbZlFXclyhSdr+gkPPAW4WeEBtiXwFcTBykZV3hbwqvXeC/npmnd
cuTMlovjdcheIE377ivzqvgJTBwQVhFpI3/gFvrPbdF2Pm8TQTjkoirQjMjeHRyh
rxo1gRRoVR8MI3q/C6CgYG2tqgVMC/lgluX36OT+Pzzotbqnurf2IrzWVDiwTFXQ
dQelAH2WV8m3nw5A/hu9/WnIDorK0Q3VSEx53Md1iYy1oHj13h5/cvmRXSl3P7oS
mrADHp63XRiQiG+vgIrcGOkw5aSo3Xu7eGt1+maOj2NGHfTZRy0UnROrpt+E9m8+
rZvgkmfNgMi0r4cCAwEAAaOCAoEwggJ9MAwGA1UdEwEB/wQCMAAwPAYDVR0fBDUw
MzAxoC+gLYYraHR0cDovL3dvc2lnbi5jcmwuY2VydHVtLnBsL3dvc2lnbi1vdmNh
LmNybDB3BggrBgEFBQcBAQRrMGkwLgYIKwYBBQUHMAGGImh0dHA6Ly93b3NpZ24t
b3ZjYS5vY3NwLWNlcnR1bS5jb20wNwYIKwYBBQUHMAKGK2h0dHA6Ly9yZXBvc2l0
b3J5LmNlcnR1bS5wbC93b3NpZ24tb3ZjYS5jZXIwHwYDVR0jBBgwFoAUoRNU3FZz
LCeCysiE7+6/AP1fq1YwHQYDVR0OBBYEFN+JmFD32Qxm6NjMJst5qqtwv3NvMA4G
A1UdDwEB/wQEAwIFoDCCASAGA1UdIASCARcwggETMAgGBmeBDAECAjCCAQUGDCqE
aAGG9ncCBQEMAjCB9DCB8QYIKwYBBQUHAgIwgeQwHxYYQXNzZWNvIERhdGEgU3lz
dGVtcyBTLkEuMAMCAQEagcBVc2FnZSBvZiB0aGlzIGNlcnRpZmljYXRlIGlzIHN0
cmljdGx5IHN1YmplY3RlZCB0byB0aGUgQ0VSVFVNIENlcnRpZmljYXRpb24gUHJh
Y3RpY2UgU3RhdGVtZW50IChDUFMpIGluY29ycG9yYXRlZCBieSByZWZlcmVuY2Ug
aGVyZWluIGFuZCBpbiB0aGUgcmVwb3NpdG9yeSBhdCBodHRwczovL3d3dy5jZXJ0
dW0ucGwvcmVwb3NpdG9yeS4wHQYDVR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUFBwMC
MCMGA1UdEQQcMBqCDCouZmFwaWFvLmNvbYIKZmFwaWFvLmNvbTANBgkqhkiG9w0B
AQsFAAOCAQEAVbW/dkDpLso5ysVgzj6Tpaida0LXvRcfWzoFIi6WHMU4hGNNcdPh
K9bRHys8ue6WjuC170pFhKeSmrF/ph4xIGd66a/zM4IrJwFKn1xnbHEZNJBCtEfJ
x19zQUd9EkHZDqpj+pWZFVf7Cwzw7IPuCSZShZr7FZLX8Muddpv+gP158yDzw0tH
RClcsSgNjQntjxWvAt8O91Xgr3+YK0h2v0t51Lj7GOsz7Wb4jAB+5dD2lBpXjCrU
EEIqSsdypwLY8cvVbB93Nvg1LDTFrS27Gzu4Nr+7/RvtvsVmppy9bhxzbwOgO4TL
D3E3nXiSFBBYlfk1jEp9ywrRi7Fj2Vm2Wg==
-----END CERTIFICATE-----
Libs/cert/invoice/testISSUE.pem 0 → 100644
Bag Attributes
friendlyName: testK
localKeyID: 54 69 6D 65 20 31 34 39 30 30 38 30 39 36 32 31 31 30
Key Attributes: <No Attributes>
-----BEGIN PRIVATE KEY-----
MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBAJew0vpxanBnasS1
Q0oIXaiBowlKp14eh4xCrhjA/4WkRyta6mWeQ4a6d3AxlpcMbnbY+NB5HgBVc9RD
yPLzLkbBtRWLoybHanevVXQ58ncbWAt1NwiYAZ+6dgzdAkgTLqt3OdvWlTmybRQc
5A+WIk4OGVUs/F8DFWTAR0zoMyn9AgMBAAECgYBp3KyQvaAjy/i2SS4pt4btd3N5
o5EEXVgJqetoOSDaeph0iGF3A6lqmC2Mrf7DcZiR9sBGdZBbeUd5xsixzMbo3mby
TzBeRf+njzmdAHTSQGNLjrLivGx1bqwONOkv/TG+VY1Rk2WlK8wTPE/EzaUyWr+U
VKmK20Vpfsqe187EXQJBAPbxjawz7E49GrP8Va3CbOVRZLztFBaFcFYNHgxLmAPi
I2vyWMFDC8pmIyMpOezLmV6RuacR9dcUWmpbzPJ3h8MCQQCdQPubEPaLH04zQ2xZ
O0fea7zBk+oQtKUj41Vib1zpMz7ueO9NL4SmSsBd+dpiGlb9EBE4VsO1PDRL/WP+
aSs/AkBNtw1gAWM/6CkMNcB9E7ATpz7t2iq1P79vxWcMdYncxwFgyn82KzR9uREb
0rChHh4hTflAY/2bd5NQ350rPYTjAkEAkK0DjwPJP+/aW3GRknrmwSxv6czzENGS
CXWSzdBVM7vRD0e2KlYofXHSj+NaVt2S4JpSrXmt7uTn3G3Q/HS3swJBAJr5o6ZT
wD07ax2Gcw34BaUXE0g++BbbOnV3eq+XuYSq9S7qb/emX1m8ZITbcS9AzHzMFwxB
IkHw4e0giNfWLWM=
-----END PRIVATE KEY-----
Bag Attributes
friendlyName: testK
localKeyID: 54 69 6D 65 20 31 34 39 30 30 38 30 39 36 32 31 31 30
subject=/C=CN/ST=SC/L=CD/O=BenZeph/OU=ISI/CN=\xE6\xB5\x8B\xE8\xAF\x95\xE8\xAF\x81\xE4\xB9\xA6
issuer=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIIC2TCCAcGgAwIBAgIENNsNsjANBgkqhkiG9w0BAQsFADCBgjELMAkGA1UEBhMC
Q04xEjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UEBxMIU0hFTlpIRU4xGDAWBgNV
BAoTD3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMPdGVzdC5mYXBpYW8uY29tMRgw
FgYDVQQDEw9URVNULkZBUElBTy5DT00wHhcNMTcwMzIxMDcyMjQxWhcNMjcwMzE5
MDcyMjQxWjBeMQswCQYDVQQGEwJDTjELMAkGA1UECBMCU0MxCzAJBgNVBAcTAkNE
MRAwDgYDVQQKEwdCZW5aZXBoMQwwCgYDVQQLEwNJU0kxFTATBgNVBAMMDOa1i+iv
leivgeS5pjCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEAl7DS+nFqcGdqxLVD
SghdqIGjCUqnXh6HjEKuGMD/haRHK1rqZZ5Dhrp3cDGWlwxudtj40HkeAFVz1EPI
8vMuRsG1FYujJsdqd69VdDnydxtYC3U3CJgBn7p2DN0CSBMuq3c529aVObJtFBzk
D5YiTg4ZVSz8XwMVZMBHTOgzKf0CAwEAATANBgkqhkiG9w0BAQsFAAOCAQEAhUT1
TQQ9Ur+oqKhm25RGyu9IpKi3ZXIoHSUEsVISMEcbr3jvGxcD1ICUE7VytWJGpxFL
kbVbvftaIlUgnqqAjl4f6CRjTNg3Jlx+edS04AzRINWnIqNyABCa4+J3w850DFu4
Jl0ho+ic7Y7mluuvPKeKnWSJIR9letDaaq++hXBT8Pq+VQ4O2hD+XnOvsWYmQGlf
MwLILG9QKpJXVnvbYy1MZY/56mKTWGyMCS/B9OTfx9G2o7PghBoAgbkzcv6GK/l+
WG4qCN4jdTQgaGirSXpMbPBb3OyKSiCZtN1mruja5SbG0Nft8n5/Zx/APHxsYkve
NBMsCYpEjCGr6IaPUw==
-----END CERTIFICATE-----
Bag Attributes
friendlyName: CN=TEST.FAPIAO.COM,OU=test.fapiao.com,O=test.fapiao.com,L=SHENZHEN,ST=GUANGDONG,C=CN
subject=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
issuer=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIID8zCCAtugAwIBAgIBATANBgkqhkiG9w0BAQsFADCBgjELMAkGA1UEBhMCQ04x
EjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UEBxMIU0hFTlpIRU4xGDAWBgNVBAoT
D3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMPdGVzdC5mYXBpYW8uY29tMRgwFgYD
VQQDEw9URVNULkZBUElBTy5DT00wHhcNMTcwMzIwMDAwMDAwWhcNNDcwMzIwMDAw
MDAwWjCBgjELMAkGA1UEBhMCQ04xEjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UE
BxMIU0hFTlpIRU4xGDAWBgNVBAoTD3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMP
dGVzdC5mYXBpYW8uY29tMRgwFgYDVQQDEw9URVNULkZBUElBTy5DT00wggEiMA0G
CSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDUGbclvZWREPvoFEDIZNibmuVJuKPl
CMyvVmtZURr45fVRXykUcs5gSLYaZNWmWhYxhA5aR+DuCuscHZAOYjAWrDNHHBPc
AplzvwAWAjRnObFG8yWp1TFObEFgEzYBnDI7Wm2rUwyr9/IZqtmh9CAto/tt6oez
+AfEI2yHjRrNu0CCWKxDIe+HabP8ElWOSoDseBMCeFIS/eIrnRGlo/nMjVWrwJSn
4XAwDXiyOhWzEQXYc+smOVVP67FYdyMKkVleRrokZbQecVPH22aDqmg5jCrAAqzM
JJ0N3OX7JvRiUg+7xxGxWz8Wu8yS+N53jPCXDYs/+5GVgq7ncASbKEtVAgMBAAGj
cjBwMA8GA1UdEwEB/wQFMAMBAf8wHQYDVR0OBBYEFDxbw3+e5JQ6248psoo2uIQC
7u/lMAsGA1UdDwQEAwIBBjARBglghkgBhvhCAQEEBAMCAAcwHgYJYIZIAYb4QgEN
BBEWD3hjYSBjZXJ0aWZpY2F0ZTANBgkqhkiG9w0BAQsFAAOCAQEAVhyUyOP9DjD8
EI2HIGbWWW32bauEHYC0ngYBHULpJRmo0l69AaYjPaKygmvTy+OIjZcseX1ojfJz
GnqRjDn8Hyd3qiSi9nKeiKxDfEjhsGDCT7hMK2z+7Pym7Je2yq5gSd2GjZJQfepE
M6ViNuwy+j/Qw2c7txJaxxeJCJrsieuB8PZ7+G3qW2b1z2YckjxYZtUrMaBfo8c+
3XYxRpGqu6JrI8uzieTrIjuarlnnR8Sqfgjj7YrNzyGQ6Xah8oUU2gOPtO6KA/bU
1UmMisjUnBqcOcHMnVbCIZcPEumB/hRrcyjOqWxmK+KQs0NF22y2B3yZ1PwQ+bpB
2a0+KO+wAw==
-----END CERTIFICATE-----
Libs/cert/invoice/testISSUEWithKey.pem 0 → 100644
Bag Attributes
friendlyName: testK
localKeyID: 54 69 6D 65 20 31 34 39 30 30 38 30 39 36 32 31 31 30
Key Attributes: <No Attributes>
-----BEGIN ENCRYPTED PRIVATE KEY-----
MIICxjBABgkqhkiG9w0BBQ0wMzAbBgkqhkiG9w0BBQwwDgQIF+258htus7gCAggA
MBQGCCqGSIb3DQMHBAivgydcDBctvgSCAoAw+pej9FhjiALD3psPHU1ctufqeSTf
3wETFnNJmSCslDUHX/+9jNWT+yX/7nTSGwiBdeRC+Hd2fTtdVCdJbq87kfd9sbVH
zJ7xO4F69a04NuCcaiCVkMJHigMOdwN+xzBgFyKCWZX4xHkC44ikZczANtuw78Gi
OfQv/7S9vPdH1um3DJasEXUy79XsAbAYe8fmXIzyZv+GwCXCFv6ZVnaeBgADuXDg
RXLjAXCbievYPw7kg/JLS2pJUHEhfYCEtTDTDO8TUle4gHMEHuMK/7/Tw9M3a03D
LVRqu08HoE60xIJECqLhZEuxZkem3COo29ITW7FrdTHj+1+ncuk4tYg8ZCuoj78r
5Zha7Fzc5S0OM/Wx0VYh7tmInv3JfyAp6Q1wDEMW1whX9ki7klozTcMx7CuQ9cW2
XO5Z/1ZBa+2FDbrqUFMZczUlex7D2+CKIvnKICxZ16+lYOx1GkPCeBBLs3LjxFVF
bBzxJQtbJJFD80oKwpH7/yAfMLOuDRktgcLU7in9ZZ0F4U66Ud8BMLbZJ0DAmd7U
G3lKuPh+x0HFoXsKgsnB/5JEwIW5nlS65PKc1mTTUDHn5QagjEiF7248wqWCn97b
fs8FJ4BqbUVohoFm54cunJ62qtCSXYLTOlDKUVQsVyS5GdspTBVC+TPb+YLWi56r
hwoC577Bs+e0kJiSi586C2CZClOxc+U2f9r2gPJpKBnGZfEQB/a7z4Z1ZTRfbQpA
zIuw0RtIZI7RIaQiHyQLlPF0UZzPWJN6GSW9HpMF8ZhujgnHq3CQxIzT0DrR0MFl
xMHpno0k9mU14vn3asPTTuZEPGLKtkD/T4bTtOc/L7EsyvxI5+d8iJAH
-----END ENCRYPTED PRIVATE KEY-----
Bag Attributes
friendlyName: testK
localKeyID: 54 69 6D 65 20 31 34 39 30 30 38 30 39 36 32 31 31 30
subject=/C=CN/ST=SC/L=CD/O=BenZeph/OU=ISI/CN=\xE6\xB5\x8B\xE8\xAF\x95\xE8\xAF\x81\xE4\xB9\xA6
issuer=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIIC2TCCAcGgAwIBAgIENNsNsjANBgkqhkiG9w0BAQsFADCBgjELMAkGA1UEBhMC
Q04xEjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UEBxMIU0hFTlpIRU4xGDAWBgNV
BAoTD3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMPdGVzdC5mYXBpYW8uY29tMRgw
FgYDVQQDEw9URVNULkZBUElBTy5DT00wHhcNMTcwMzIxMDcyMjQxWhcNMjcwMzE5
MDcyMjQxWjBeMQswCQYDVQQGEwJDTjELMAkGA1UECBMCU0MxCzAJBgNVBAcTAkNE
MRAwDgYDVQQKEwdCZW5aZXBoMQwwCgYDVQQLEwNJU0kxFTATBgNVBAMMDOa1i+iv
leivgeS5pjCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEAl7DS+nFqcGdqxLVD
SghdqIGjCUqnXh6HjEKuGMD/haRHK1rqZZ5Dhrp3cDGWlwxudtj40HkeAFVz1EPI
8vMuRsG1FYujJsdqd69VdDnydxtYC3U3CJgBn7p2DN0CSBMuq3c529aVObJtFBzk
D5YiTg4ZVSz8XwMVZMBHTOgzKf0CAwEAATANBgkqhkiG9w0BAQsFAAOCAQEAhUT1
TQQ9Ur+oqKhm25RGyu9IpKi3ZXIoHSUEsVISMEcbr3jvGxcD1ICUE7VytWJGpxFL
kbVbvftaIlUgnqqAjl4f6CRjTNg3Jlx+edS04AzRINWnIqNyABCa4+J3w850DFu4
Jl0ho+ic7Y7mluuvPKeKnWSJIR9letDaaq++hXBT8Pq+VQ4O2hD+XnOvsWYmQGlf
MwLILG9QKpJXVnvbYy1MZY/56mKTWGyMCS/B9OTfx9G2o7PghBoAgbkzcv6GK/l+
WG4qCN4jdTQgaGirSXpMbPBb3OyKSiCZtN1mruja5SbG0Nft8n5/Zx/APHxsYkve
NBMsCYpEjCGr6IaPUw==
-----END CERTIFICATE-----
Bag Attributes
friendlyName: CN=TEST.FAPIAO.COM,OU=test.fapiao.com,O=test.fapiao.com,L=SHENZHEN,ST=GUANGDONG,C=CN
subject=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
issuer=/C=CN/ST=GUANGDONG/L=SHENZHEN/O=test.fapiao.com/OU=test.fapiao.com/CN=TEST.FAPIAO.COM
-----BEGIN CERTIFICATE-----
MIID8zCCAtugAwIBAgIBATANBgkqhkiG9w0BAQsFADCBgjELMAkGA1UEBhMCQ04x
EjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UEBxMIU0hFTlpIRU4xGDAWBgNVBAoT
D3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMPdGVzdC5mYXBpYW8uY29tMRgwFgYD
VQQDEw9URVNULkZBUElBTy5DT00wHhcNMTcwMzIwMDAwMDAwWhcNNDcwMzIwMDAw
MDAwWjCBgjELMAkGA1UEBhMCQ04xEjAQBgNVBAgTCUdVQU5HRE9ORzERMA8GA1UE
BxMIU0hFTlpIRU4xGDAWBgNVBAoTD3Rlc3QuZmFwaWFvLmNvbTEYMBYGA1UECxMP
dGVzdC5mYXBpYW8uY29tMRgwFgYDVQQDEw9URVNULkZBUElBTy5DT00wggEiMA0G
CSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDUGbclvZWREPvoFEDIZNibmuVJuKPl
CMyvVmtZURr45fVRXykUcs5gSLYaZNWmWhYxhA5aR+DuCuscHZAOYjAWrDNHHBPc
AplzvwAWAjRnObFG8yWp1TFObEFgEzYBnDI7Wm2rUwyr9/IZqtmh9CAto/tt6oez
+AfEI2yHjRrNu0CCWKxDIe+HabP8ElWOSoDseBMCeFIS/eIrnRGlo/nMjVWrwJSn
4XAwDXiyOhWzEQXYc+smOVVP67FYdyMKkVleRrokZbQecVPH22aDqmg5jCrAAqzM
JJ0N3OX7JvRiUg+7xxGxWz8Wu8yS+N53jPCXDYs/+5GVgq7ncASbKEtVAgMBAAGj
cjBwMA8GA1UdEwEB/wQFMAMBAf8wHQYDVR0OBBYEFDxbw3+e5JQ6248psoo2uIQC
7u/lMAsGA1UdDwQEAwIBBjARBglghkgBhvhCAQEEBAMCAAcwHgYJYIZIAYb4QgEN
BBEWD3hjYSBjZXJ0aWZpY2F0ZTANBgkqhkiG9w0BAQsFAAOCAQEAVhyUyOP9DjD8
EI2HIGbWWW32bauEHYC0ngYBHULpJRmo0l69AaYjPaKygmvTy+OIjZcseX1ojfJz
GnqRjDn8Hyd3qiSi9nKeiKxDfEjhsGDCT7hMK2z+7Pym7Je2yq5gSd2GjZJQfepE
M6ViNuwy+j/Qw2c7txJaxxeJCJrsieuB8PZ7+G3qW2b1z2YckjxYZtUrMaBfo8c+
3XYxRpGqu6JrI8uzieTrIjuarlnnR8Sqfgjj7YrNzyGQ6Xah8oUU2gOPtO6KA/bU
1UmMisjUnBqcOcHMnVbCIZcPEumB/hRrcyjOqWxmK+KQs0NF22y2B3yZ1PwQ+bpB
2a0+KO+wAw==
-----END CERTIFICATE-----
Model/Agent/AgentAccountModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, FetchedValue, DateTime
from Config.common_config import AGENT_STATUS
from Model.Base import BaseModel
class AgentAccount(BaseModel):
__tablename__ = 'agent_account'
id = Column(Integer, primary_key=True)
agent_no = Column(String(25, 'utf8mb4_unicode_ci'), nullable=False)
user_name = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False)
phone = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, server_default=FetchedValue())
level = Column(Integer, nullable=False, server_default=FetchedValue(), comment='1:超级管理员， 2：代理商')
status = Column(Integer, nullable=False, server_default=FetchedValue(), comment='1:正常 2：删除')
access_token = Column(String(255, 'utf8mb4_unicode_ci'))
salt = Column(String(255, 'utf8mb4_unicode_ci'))
password = Column(String(255, 'utf8mb4_unicode_ci'))
salt_pwd = Column(String(255, 'utf8mb4_unicode_ci'))
comment = Column(String(255, 'utf8mb4_unicode_ci'))
last_login = Column(DateTime)
expire_time = Column(DateTime)
@property
def level_desc(self):
return AGENT_STATUS[str(self.level)]
Model/Agent/AgentLogRecordModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, FetchedValue, String, DateTime
from Model.Base import BaseModel
class AgentLogRecord(BaseModel):
__tablename__ = 'agent_log_record'
id = Column(Integer, primary_key=True)
phone = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, server_default=FetchedValue())
ip = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, server_default=FetchedValue())
last_login = Column(DateTime, nullable=False, server_default=FetchedValue())
login_type = Column(Integer, nullable=False, server_default=FetchedValue(), comment='1:验证码登录 2：token 3:发送验证码')
Model/Agent/AgentSpotModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, FetchedValue
from Model.Base import BaseModel
class AgentSpot(BaseModel):
__tablename__ = 'agent_spot'
id = Column(Integer, primary_key=True)
agent_no = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, server_default=FetchedValue())
spot_no = Column(Integer, nullable=False, server_default=FetchedValue())
status = Column(Integer, nullable=False, server_default=FetchedValue())
Model/Base.py 0 → 100644
# -*- coding: utf-8 -*-
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy import func, Column
db = SQLAlchemy()
class BaseModel(db.Model):
__abstract__ = True
created_at = Column(db.TIMESTAMP, nullable=False, server_default=func.now())
updated_at = Column(db.TIMESTAMP, nullable=False, server_default=func.now(), onupdate=func.now())
\ No newline at end of file
Model/Coupon/CouponOrderModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, Index, DateTime, FetchedValue, Date
from Model.Base import BaseModel
class CouponOrder(BaseModel):
__tablename__ = 'coupon_order'
__table_args__ = (
Index('wx_guide_id_customer_id', 'wx_guide_id', 'customer_id'),
)
id = Column(Integer, primary_key=True)
spot_id = Column(Integer, comment='景点id')
business_id = Column(Integer, comment='商户id')
coupon_type_id = Column(Integer, nullable=False, comment='优惠券id')
wx_guide_id = Column(Integer, comment='对应导游的id')
customer_id = Column(Integer, comment='用户的id')
status = Column(Integer, nullable=False, server_default=FetchedValue(), comment='领取状态，1代表领取，2代表使用过，3过期')
add_time = Column(DateTime, nullable=False, server_default=FetchedValue(), comment='用户领取时间')
expire_time = Column(Date, nullable=False, comment='优惠的过期时间')
Model/Coupon/WxGuideModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, DateTime, String
from Model.Base import BaseModel
class WxGuide(BaseModel):
__tablename__ = 'wx_guide'
id = Column(Integer, primary_key=True)
user_id = Column(Integer, comment='领取的导游id')
qrcode = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, unique=True, comment='优惠二维码')
spot_id = Column(Integer, nullable=False, comment='景点id')
coupon_type_id = Column(Integer, nullable=False, comment='优惠券类型')
business_id = Column(Integer, nullable=False, comment='商户id')
expire_time = Column(Integer, nullable=False, comment='活动截止时间')
bonus = Column(Integer, comment='提成')
number = Column(Integer, comment='优惠群个数')
old = Column(Integer, nullable=False, comment='区分老旧数据')
Model/Customer/CustomerModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, DateTime, FetchedValue
from Model.Base import BaseModel
class Customer(BaseModel):
__tablename__ = 'customers'
id = Column(Integer, primary_key=True)
mini_program_open_id = Column(String(191, 'utf8mb4_unicode_ci'), comment='微信支付宝小程序openID')
openid = Column(String(191, 'utf8mb4_unicode_ci'), comment='微信支付宝公众平台openID')
unionid = Column(String(191, 'utf8mb4_unicode_ci'), comment='微信支付宝unionid')
platform = Column(Integer, nullable=False, server_default=FetchedValue(), comment='平台 1微信 2支付宝')
phone = Column(String(191, 'utf8mb4_unicode_ci'), comment='手机号')
deposit = Column(Integer, nullable=False, server_default=FetchedValue(), comment='押金')
language = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='语种')
nick_name = Column(String(191, 'utf8mb4_unicode_ci'), comment='昵称')
gender = Column(Integer, nullable=False, server_default=FetchedValue(), comment='性别')
avatar_url = Column(String(191, 'utf8mb4_unicode_ci'), comment='头像')
status = Column(Integer, nullable=False, comment='状态 0停用 1正常')
last_login_at = Column(DateTime, comment='上次登录时间')
Model/Income/DayIncomeModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Index, Column, Integer, Date
from sqlalchemy.ext.declarative import declarative_base
from Model.Base import db
Base = declarative_base()
metadata = Base.metadata
class Dayincome(db.Model):
__tablename__ = 'dayincome'
__table_args__ = (
Index('spot_id_day', 'spot_id', 'day'),
)
id = Column(Integer, primary_key=True)
spot_id = Column(Integer, nullable=False, comment='景区id')
business_id = Column(Integer, nullable=False, comment='商户id')
total = Column(Integer, nullable=False, comment='总金额')
guide_total = Column(Integer, nullable=False, comment='同游共听')
day = Column(Date, nullable=False, comment='总金额')
Model/Machine/MachineModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, FetchedValue, String
from sqlalchemy.sql.sqltypes import NullType
from Model.Base import BaseModel
class Machine(BaseModel):
__tablename__ = 'machine'
id = Column(Integer, primary_key=True)
mac_no = Column(String(16, 'utf8mb4_unicode_ci'), nullable=False, comment='机柜编号')
he_cloud_device_id = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='机柜号对应的波所的编号')
one_day_price = Column(Integer, nullable=False, comment='日租金')
deposit = Column(Integer, nullable=False, server_default=FetchedValue(), comment='押金')
free_time = Column(Integer, nullable=False, server_default=FetchedValue(), comment='免费时间')
position = Column(NullType, comment='机柜位置坐标')
address = Column(String(191, 'utf8mb4_unicode_ci'), comment='机柜位置')
spot_id = Column(Integer, nullable=False)
business_id = Column(Integer, nullable=False)
wx_mini_program = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='微信租借二维码地址')
ali_mini_program = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='支付宝租借二维码地址')
version = Column(String(191, 'utf8mb4_unicode_ci'), comment='版本号')
iccid = Column(String(191, 'utf8mb4_unicode_ci'), comment='iccid')
life = Column(Integer, nullable=False, server_default=FetchedValue(), comment='机柜在线状态默认0不在线1在线')
type = Column(Integer, nullable=False, comment='机柜类型')
hatch_number = Column(Integer, nullable=False, server_default=FetchedValue(), comment='机柜的仓口数量')
take_out_tool = Column(Integer, nullable=False, comment='0:没有弹出功能 ， 1：有')
Model/Power/PowerModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, FetchedValue
from Model.Base import BaseModel
class Power(BaseModel):
__tablename__ = 'power'
id = Column(Integer, primary_key=True)
power_no = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='充电宝编号')
power_type = Column(String(10, 'utf8mb4_unicode_ci'), comment='讲解器类型')
season = Column(Integer, server_default=FetchedValue(), comment='季节0暂无1春2夏3秋4冬')
has_power = Column(Integer, nullable=False, server_default=FetchedValue(), comment='充电宝电量')
status = Column(Integer, nullable=False, server_default=FetchedValue(), comment='充电宝状态1在仓库2在机柜可用3在机柜占用4出货成功')
is_miss = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否丢失 0未丢 1丢失')
machine_id = Column(Integer, comment='机柜id')
hatch_no = Column(Integer, comment='机柜仓口号')
Model/Production/ProductionModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, DateTime, FetchedValue
from Model.Base import BaseModel
class Production(BaseModel):
__tablename__ = 'production'
id = Column(Integer, primary_key=True)
rent_id = Column(Integer, nullable=False, comment='租借id')
is_out = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否取出')
power_id = Column(Integer, nullable=False, comment='讲解器id')
power_no = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='讲解器编号')
rent_machine_id = Column(Integer, nullable=False, comment='租的机柜id')
rent_hatch_no = Column(Integer, nullable=False, comment='租的仓口')
is_return = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否归还')
return_machine_id = Column(Integer, comment='还的机柜id')
return_hatch_no = Column(Integer, comment='还的仓口')
return_time = Column(DateTime, comment='还的时间')
is_refund = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否退款')
refund_no = Column(String(191, 'utf8mb4_unicode_ci'), comment='退款单号')
refund_time = Column(DateTime, comment='退款时间')
total = Column(Integer, comment='消费金额')
spot_id = Column(Integer, nullable=False, comment='景点id')
business_id = Column(Integer, nullable=False, comment='商家id')
Model/Rent/RentModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, DateTime, FetchedValue
from Model.Base import BaseModel
class Rent(BaseModel):
__tablename__ = 'rent'
id = Column(Integer, primary_key=True)
rent_no = Column(String(19, 'utf8mb4_unicode_ci'), nullable=False, comment='租借单号')
number = Column(Integer, nullable=False, comment='租借数量')
deposit = Column(Integer, nullable=False, comment='单个押金')
one_day_price = Column(Integer, nullable=False, comment='日单价')
free_time = Column(Integer, nullable=False, comment='免费时间')
machine_id = Column(Integer, nullable=False, comment='机柜id')
power_type = Column(String(10, 'utf8mb4_unicode_ci'), comment='讲解器类型')
customer_id = Column(Integer, nullable=False, comment='用户id')
total = Column(Integer, nullable=False, server_default=FetchedValue(), comment='应收金额')
real_total = Column(Integer, nullable=False, server_default=FetchedValue(), comment='实收金额')
back_money = Column(Integer, nullable=False, server_default=FetchedValue(), comment='退款金额')
is_pay = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否支付')
rent_type = Column(Integer, nullable=False, server_default=FetchedValue(), comment='租借类型1现场租借2预约')
add_time = Column(DateTime, nullable=False, server_default=FetchedValue(), comment='下单时间')
pay_time = Column(DateTime, comment='支付时间')
is_take = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否取货')
take_time = Column(DateTime, comment='开始发货时间')
is_over = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否完结')
is_cancel = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否取消交易')
refund_no = Column(String(191, 'utf8mb4_unicode_ci'), comment='退款单号')
spot_id = Column(Integer, nullable=False, comment='景点id')
business_id = Column(Integer, nullable=False, comment='商家id')
expire_handle = Column(Integer, nullable=False, server_default=FetchedValue(), comment='是否做过期处理')
prepay_id = Column(String(191, 'utf8mb4_unicode_ci'), comment='微信支付prepay_id')
over_time = Column(DateTime, comment='订单完结时间')
Model/Rent/RentRefundModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, FetchedValue, Text
from Model.Base import BaseModel
class RentRefund(BaseModel):
__tablename__ = 'rent_refund'
id = Column(Integer, primary_key=True)
refund_no = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False)
production_id = Column(Integer, server_default=FetchedValue(), nullable=False)
fee = Column(Integer, server_default=FetchedValue(), nullable=False)
comment = Column(Text(collation='utf8mb4_unicode_ci'), nullable=False)
Model/Repairs/RepairImagesModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, ForeignKey, String
from sqlalchemy.orm import relationship
from Model.Base import BaseModel
class RepairImage(BaseModel):
__tablename__ = 'repair_images'
id = Column(Integer, primary_key=True)
repairs_id = Column(ForeignKey('repairs.id', ondelete='CASCADE'), index=True)
url = Column(String(200))
repairs = relationship('Repair', primaryjoin='RepairImage.repairs_id == Repair.id', backref='repair_images')
Model/Repairs/RepairModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, ForeignKey, Text, String, FetchedValue
from sqlalchemy.orm import relationship
from Model.Base import BaseModel
class Repair(BaseModel):
__tablename__ = 'repairs'
id = Column(Integer, primary_key=True)
spot_id = Column(ForeignKey('spot.id', ondelete='CASCADE'), nullable=False, index=True, comment='景区编号')
machine_id = Column(ForeignKey('machine.id', ondelete='CASCADE'), nullable=False, index=True, comment='机柜编号')
system_users_id = Column(Integer, comment='商家账号id')
remark = Column(Text, comment='问题描述')
tel = Column(String(50), comment='联系方式')
status = Column(Integer, server_default=FetchedValue(), comment='状态')
machine = relationship('Machine', primaryjoin='Repair.machine_id == Machine.id', backref='repairs')
spot = relationship('Spot', primaryjoin='Repair.spot_id == Spot.id', backref='repairs')
Model/Settlement/SettlementModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, FetchedValue, DateTime
from sqlalchemy.ext.declarative import declarative_base
from Model.Base import db
Base = declarative_base()
metadata = Base.metadata
class Settlement(db.Model):
__tablename__ = 'settlement'
id = Column(Integer, primary_key=True)
spot_id = Column(Integer, nullable=False)
business_id = Column(Integer, nullable=False)
month = Column(Integer, nullable=False)
total = Column(Integer, nullable=False)
guide_total = Column(Integer, nullable=False)
status = Column(Integer, nullable=False, server_default=FetchedValue())
bill_id = Column(Integer)
created_at = Column(DateTime)
updated_at = Column(DateTime)
Model/Spot/SpotModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, FetchedValue
from Model.Base import BaseModel
class Spot(BaseModel):
__tablename__ = 'spot'
id = Column(Integer, primary_key=True)
spotname = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='景点名')
business_id = Column(Integer, nullable=False, comment='关联id')
main_title = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='主标题')
vic_title = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='副标题')
detail_img = Column(String(191, 'utf8mb4_unicode_ci'), comment='展示界面的图片')
wx_logo = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='微信头像')
go_url = Column(String(191, 'utf8mb4_unicode_ci'), comment='定制化界面')
listen_img = Column(String(191, 'utf8mb4_unicode_ci'), comment='手机游二维码')
page_id = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='微信id')
code = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='唯一值')
time = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='开始时间')
overtime = Column(String(191, 'utf8mb4_unicode_ci'), nullable=False, comment='结束时间')
open_week = Column(String(255), server_default=FetchedValue(), comment='营业时间')
address = Column(String(255), nullable=False, server_default=FetchedValue())
return_img = Column(String(255, 'utf8mb4_unicode_ci'), comment='归还图片')
spotname_english = Column(String(191, 'utf8mb4_unicode_ci'), comment='景点英文名')
Model/invoice/InvoiceModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, Integer, String, FetchedValue
from Model.Base import BaseModel
class Invoice(BaseModel):
__tablename__ = 'invoice'
id = Column(Integer, primary_key=True)
fpqqlsh = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='发票请求流水号')
fp_dm = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='发票代码')
fp_hm = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='发票号码')
kprq = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='开票日期')
jym = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='校验码')
pdf_url = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='PDF下载地址')
sp_url = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='售票地址')
is_red = Column(Integer, nullable=False, server_default=FetchedValue(), comment='0:未红冲 1:已红冲 2:红冲发票')
status = Column(Integer, nullable=False, server_default=FetchedValue(), comment='1:正常 2:删除')
Model/invoice/InvoiceRecoreModel.py 0 → 100644
# -*- coding: utf-8 -*-
from sqlalchemy import Column, String, Integer
from Model.Base import BaseModel
class InvoiceRecord(BaseModel):
__tablename__ = 'invoice_record'
id = Column(Integer, primary_key=True)
invoice_id = Column(Integer, nullable=False, comment='对应发票id')
customer_id = Column(Integer, nullable=False, comment='用户id')
company_name = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='发票抬头')
payment_id = Column(String(255, 'utf8mb4_unicode_ci'), comment='税号')
pay_money = Column(Integer, nullable=False, comment='合计金额')
e_account = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='电子邮箱')
remark = Column(String(255, 'utf8mb4_unicode_ci'), comment='备注')
address = Column(String(255, 'utf8mb4_unicode_ci'), comment='地址电话')
account = Column(String(255, 'utf8mb4_unicode_ci'), comment='开户行账号')
parent_id = Column(Integer, nullable=False, comment='父节点')
rent_list = Column(String(255, 'utf8mb4_unicode_ci'), nullable=False, comment='订单id列表')
status = Column(Integer, nullable=False, comment='0：正常开发票1：等待审核2：审核成功3：驳回4：拒绝')
reason = Column(String(255, 'utf8mb4_unicode_ci'), comment='审核理由')
README.md 0 → 100644
#tour_business
Redis_Cache.py 0 → 100644
# -*- coding: utf-8 -*-
from flask_redis import FlaskRedis
redis = FlaskRedis(config_prefix='TENCENT_REDIS')
Service/AgentService.py 0 → 100644
# -*- coding: utf-8 -*-
import base64
import datetime
import hashlib
import random
import string
from Config.common_config import ACCOUNT_STATUS
from Model.Agent.AgentAccountModel import AgentAccount
from Model.Agent.AgentSpotModel import AgentSpot
from Model.Base import db
from Model.Spot.SpotModel import Spot
from Service.SpotService import SpotService
class AgentService():
@staticmethod
def gene_salt(length=16):
key_list = [random.choice((string.ascii_letters + string.digits)) for i in range(length)]
return ("".join(key_list))
@staticmethod
def gene_agent_code(agent_info, salt):
m = hashlib.md5()
str = "%s-%s-%s-%s" % (agent_info.id, agent_info.user_name, agent_info.phone, salt)
m.update(str.encode("utf-8"))
return m.hexdigest()
@staticmethod
def gene_pwd(pwd, salt):
m = hashlib.md5()
str = "%s-%s" % (base64.encodebytes(pwd.encode("utf-8")), salt)
m.update(str.encode("utf-8"))
return m.hexdigest()
@staticmethod
def check_agent_token(token):
token = base64.b64decode(token).decode("utf-8")
try:
agent_info = AgentAccount.query.filter_by(access_token=token).first()
except Exception as e:
return 1
if not agent_info:
return 1
s = token.split("#")
if len(s) != 2:
return 1
if AgentService.gene_agent_code(agent_info, agent_info.salt) != s[0]:
return 1
if agent_info.expire_time < datetime.datetime.now():
return 2
return agent_info
@staticmethod
def create_agent_no():
'''
生成用户编号
:return:
'''
ran_int = str(random.randint(1, 999999)).zfill(6)
return 'ssw' + ran_int
@staticmethod
def get_spot_info(agent_info):
spot_info = []
if agent_info.level == 2 or agent_info.level == 3:
infos = db.session.query(AgentAccount, AgentSpot, Spot).join(AgentSpot,
AgentAccount.id == AgentSpot.agent_no).join(
Spot, Spot.id == AgentSpot.spot_no).filter(AgentAccount.id == agent_info.id,
AgentAccount.status == ACCOUNT_STATUS['on_use'],
AgentSpot.status == ACCOUNT_STATUS['on_use']).all()
for info in infos:
cur_info = {}
cur_info['id'] = info.Spot.id
cur_info['spotname'] = info.Spot.spotname
cur_info['letter'] = SpotService.get_pinyin(info.Spot.spotname)
spot_info.append(cur_info)
else:
infos = Spot.query.with_entities(Spot.id, Spot.spotname).all()
for info in infos:
cur_info = {}
cur_info['id'] = info.id
cur_info['spotname'] = info.spotname
cur_info['letter'] = SpotService.get_pinyin(info.spotname)
spot_info.append(cur_info)
return spot_info
Service/IndexService.py 0 → 100644
# -*- coding: utf-8 -*-
from Model.Base import db
from Model.Coupon.CouponOrderModel import CouponOrder
from Model.Coupon.WxGuideModel import WxGuide
from Model.Machine.MachineModel import Machine
from Model.Power.PowerModel import Power
from Model.Production.ProductionModel import Production
from Model.Rent.RentModel import Rent
class IndexService():
@staticmethod
def get_total_production(spot_id, start_time, end_time):
'''
获取该景区当前时间段内收益和租借充电宝的数量
:param spot_id:
:param start_time:
:param end_time:
:return:
'''
income_info = db.session.query(Production.total).filter(Production.spot_id == spot_id, Production.total > 0,
Production.created_at >= start_time,
Production.created_at <= end_time).all()
total = 0
for info in income_info:
total += info.total
return round(total / 100, 2), len(income_info)
@staticmethod
def get_total_power(spot_id, start_time, end_time):
'''
获取该景区当前时间段内租借充电宝的总量
:param spot_id:
:param start_time:
:param end_time:
:return:
'''
where = {
Rent.spot_id == spot_id,
Production.created_at >= start_time,
Production.created_at <= end_time
}
count = db.session.query(Production, Rent).join(Rent, Rent.id == Production.rent_id).filter(*where).count()
return count
@staticmethod
def get_total_production_num(spot_id, start_time, end_time):
where = {
Production.is_out == 1,
Production.spot_id == spot_id,
Production.created_at >= start_time,
Production.created_at <= end_time
}
count = Production.query.filter(*where).count()
return count
@staticmethod
def get_total_production_finished(spot_id, start_time, end_time):
'''
获取已完成的充电宝数量
:param spot_id:
:param start_time:
:param end_time:
:return:
'''
where = {
Production.is_out == 1,
Production.is_return == 1,
Production.total > 0,
Production.spot_id == spot_id,
Production.created_at >= start_time,
Production.created_at <= end_time
}
return Production.query.filter(*where).count()
@staticmethod
def get_not_return_production(spot_id, start_time, end_time):
'''
获取未归还的充电宝数量
:param spot_id:
:param start_time:
:param end_time:
:return:
'''
where = {
Production.is_return == 0,
Production.spot_id == spot_id,
Production.created_at >= start_time,
Production.created_at <= end_time
}
count = Production.query.filter(*where).count()
return count
@staticmethod
def get_invalid_production(spot_id, start_time, end_time):
'''
获取无效的充电宝数量
:param spot_id:
:param start_time:
:param end_time:
:return:
'''
where = {
Production.is_out == 1,
Production.is_return == 1,
Production.total <= 0,
Production.spot_id == spot_id,
Production.created_at >= start_time,
Production.created_at <= end_time
}
return Production.query.filter(*where).count()
@staticmethod
def get_invalid_production_info(spot_id, start_time, end_time):
'''
获取无效的充电宝信息
:param spot_id:
:param start_time:
:param end_time:
:return:
'''
where = {
Production.is_return == 1,
Production.spot_id == spot_id,
Production.total == 0,
Production.created_at >= start_time,
Production.created_at <= end_time
}
total = 0
infos = db.session.query(Rent.one_day_price).join(Production, Production.rent_id == Rent.id).filter(
*where).all()
for info in infos:
total += info.one_day_price
return round(total / 100, 2), len(infos)
@staticmethod
def get_invalid_production_info_all(spot_id):
'''
获取当前景区所有的无效充电宝信息
:param spot_id:
:return:
'''
where = {
Production.is_return == 1,
Production.spot_id == spot_id,
Production.total == 0
}
total = 0
infos = db.session.query(Rent.one_day_price).join(Production, Production.rent_id == Rent.id).filter(
*where).all()
for info in infos:
total += info.one_day_price
return round(total / 100, 2), len(infos)
@staticmethod
def get_refund_rent(spot_id, start_time, end_time):
info = db.session.query(Production, Rent).join(Rent, Rent.id == Production.rent_id).filter(
Production.spot_id == spot_id, Production.is_refund == 1, Production.return_hatch_no == 127,
Production.refund_time >= start_time, Production.refund_time <= end_time).all()
total_income = 0
for i in info:
total_income += i.Production.total
return round(total_income / 100, 2), len(info)
@staticmethod
def get_history_refund_rent(spot_id):
info = db.session.query(Production, Rent).join(Rent, Rent.id == Production.rent_id).filter(
Production.spot_id == spot_id, Production.is_refund == 1, Production.return_hatch_no == 127).all()
total_income = 0
for i in info:
total_income += i.Production.total
return round(total_income / 100, 2), len(info)
@staticmethod
def get_history_income_production(spot_id):
'''
获取历史收益通过production
:param spot_id:
:return:
'''
# total = db.session.query(func.sum(Production.total)).filter(Production.spot_id == spot_id).scalar()
# logger.info(total)
# return round(total / 100, 2)
total = 0
income_info = db.session.query(Production.total).filter(Production.spot_id == spot_id,
Production.total > 0).all()
for info in income_info:
total += info.total
return round(total / 100, 2)
@staticmethod
def get_history_production(spot_id):
'''
获取历史租借充电宝数量
:param spot_id:
:return:
'''
where = {
Production.is_out == 1,
Production.is_return == 1,
Production.total > 0,
Production.spot_id == spot_id
}
total = Production.query.filter(*where).count()
return total
@staticmethod
def get_available_power_number(machine_id):
power_info = Power.query.filter(Power.has_power > 75, Power.status == 2, Power.machine_id == machine_id).count()
return power_info
@staticmethod
def get_machine_total_power(machine_id):
total = 55
power_info = Power.query.filter_by(machine_id=machine_id).all()
for power in power_info:
if power.power_no.startswith("00000000"):
total -= 1
return total
@staticmethod
def get_machine_info(spot_id):
machine_info = Machine.query.filter(Machine.spot_id == spot_id).all()
machine = []
for info in machine_info:
cur_machine = {}
cur_machine['mac_no'] = info.mac_no
cur_machine['life'] = info.life
cur_machine['hatch_number'] = IndexService.get_machine_total_power(info.id)
cur_machine['take_out_tool'] = info.take_out_tool
cur_machine['available_number'] = IndexService.get_available_power_number(info.id)
machine.append(cur_machine)
return machine
@staticmethod
def get_discount_money(spot_id, start_time, end_time):
discount_info = db.session.query(CouponOrder, WxGuide).join(WxGuide,
WxGuide.id == CouponOrder.wx_guide_id).filter(
CouponOrder.spot_id == spot_id, CouponOrder.updated_at >= start_time,
CouponOrder.updated_at <= end_time).all()
total = 0
for info in discount_info:
total += info.WxGuide.bonus
return round(total / 100, 2)
Service/RepairService.py 0 → 100644
# -*- coding: utf-8 -*-
import datetime
import hashlib
import random
import time
from sqlalchemy.exc import SQLAlchemyError
from Model.Base import db
from Model.Repairs.RepairImagesModel import RepairImage
from Model.Repairs.RepairModel import Repair
class RepairService():
@staticmethod
def create(system_users_id, remark, tel, pics, spot_id, machine_id):
repair = RepairService.createRepairStub(system_users_id, remark, tel, spot_id, machine_id)
if repair:
try:
db.session.add(repair)
db.session.commit()
except SQLAlchemyError as e:
raise e
if len(pics) > 0:
for item in pics:
repair_images = RepairService.createRepairImage(repair.id, item)
if repair_images:
try:
db.session.add(repair_images)
db.session.commit()
except SQLAlchemyError as e:
raise e
return repair
@staticmethod
def createRepairImage(repair_id, pic):
repairImage = RepairImage()
repairImage.repairs_id = repair_id
repairImage.url = pic
repairImage.created_at = datetime.datetime.now()
repairImage.updated_at = datetime.datetime.now()
return repairImage
@staticmethod
def createRepairStub(system_users_id, remark, tel, spot_id, machine_id):
repair = Repair()
repair.system_users_id = system_users_id
repair.remark = remark
repair.tel = tel
repair.status = 0
repair.spot_id = spot_id
repair.machine_id = machine_id
repair.created_at = datetime.datetime.now()
repair.updated_at = datetime.datetime.now()
return repair
@staticmethod
def guid():
timestamp = int(time.time())
ranstr = random.randint(9999, 9999999999)
return RepairService.MD5(str(timestamp) + str(ranstr)) + RepairService.MD5(str(ranstr))[0: 8]
@staticmethod
def MD5(info):
m = hashlib.md5()
m.update(info.encode("utf-8"))
return m.hexdigest()
Service/SMSService.py 0 → 100644
# -*- coding: utf-8 -*-
import random
import string
from qcloudsms_py import SmsSingleSender
from qcloudsms_py.httpclient import HTTPError
from Config.common_config import SMS_CONFIG
from Libs.Logger import logger
from Redis_Cache import redis
class SMSService():
def __init__(self):
self.appid = SMS_CONFIG['app_id']
self.appKey = SMS_CONFIG['app_key']
try:
self.ssender = SmsSingleSender(self.appid, self.appKey)
except Exception as e:
print(e)
def create_code(self, length=4):
'''
生成验证码
:param length:
:return:
'''
verification = []
letters = string.digits
for i in range(length):
letter = letters[random.randint(0, 9)]
verification.append(letter)
return "".join(verification)
def make_code(self, phoneNumber):
'''
设置验证码300秒有效
:param phoneNumber:
:return:
'''
code = self.create_code(4)
redis.set('V_C' + str(phoneNumber), code, 300)
logger.info("code: " + code)
return code
def phoneSendCode(self, phoneNumber, tempId, sign='灰兔智能'):
'''
发送验证码
:param phoneNumber:
:param tempId:
:param sign:
:return:
'''
code = self.make_code(phoneNumber)
params = [code]
try:
result = self.ssender.send_with_param(86, phoneNumber, tempId, params, sign=sign, extend="", ext='')
return result
except HTTPError as e:
print(e)
except Exception as e:
print(e)
return
def phoneSendCodeWithContent(self, phoneNumber, tempId, Content, sign='灰兔智能'):
'''
发送验证码
:param phoneNumber:
:param tempId:
:param sign:
:return:
'''
try:
result = self.ssender.send_with_param(86, phoneNumber, tempId, Content, sign=sign, extend="", ext='')
return result
except HTTPError as e:
print(e)
except Exception as e:
print(e)
return
def verificate(self, phoneNumber, code):
'''
判断验证码，-1验证码过期 -2验证码错误 0匹配
:param phoneNumber:
:param code:
:return:
'''
logger.info("phone:" + phoneNumber + ", code:" + code)
ver = redis.get('V_C' + str(phoneNumber))
logger.info(ver)
if ver is None:
return -1
else:
if ver == str(code).encode('utf-8'):
return 0
else:
return -2
Service/SpotService.py 0 → 100644
# -*- coding: utf-8 -*-
from xpinyin import Pinyin
from Config.common_config import ACCOUNT_STATUS
from Model.Agent.AgentAccountModel import AgentAccount
from Model.Agent.AgentSpotModel import AgentSpot
from Model.Base import db
from Model.Machine.MachineModel import Machine
from Model.Spot.SpotModel import Spot
class SpotService():
@staticmethod
def get_spot_info():
infos = []
spot_info = Spot.query.with_entities(Spot.spotname, Spot.id).all()
for info in spot_info:
cur_info = {}
cur_info['id'] = info.id
cur_info['letter'] = SpotService.get_pinyin(info.spotname)
cur_info['spotname'] = info.spotname
cur_info['agent_info'] = SpotService.get_agent_spot(info.id)
infos.append(cur_info)
return infos
@staticmethod
def get_agent_spot(spot_id):
agent_spot = db.session.query(AgentSpot, AgentAccount).join(AgentAccount,
AgentAccount.id == AgentSpot.agent_no).filter(
AgentSpot.spot_no == spot_id, AgentAccount.status == ACCOUNT_STATUS['on_use'],
AgentSpot.status == ACCOUNT_STATUS['on_use']).all()
total_info = []
for info in agent_spot:
cur_info = {}
cur_info['agent_name'] = info.AgentAccount.user_name
cur_info['phone'] = info.AgentAccount.phone
cur_info['comment'] = info.AgentAccount.comment
cur_info['spot_info'] = SpotService.get_spot_agent(info.AgentAccount.id)
total_info.append(cur_info)
return total_info
@staticmethod
def get_spot_agent(agent_id):
spot_agent = db.session.query(AgentAccount, AgentSpot, Spot).join(AgentSpot,
AgentAccount.id == AgentSpot.agent_no).join(
Spot, Spot.id == AgentSpot.spot_no).filter(AgentAccount.id == agent_id,
AgentAccount.status == ACCOUNT_STATUS['on_use'],
AgentSpot.status == ACCOUNT_STATUS['on_use']).all()
total_info = []
for info in spot_agent:
cur_info = {}
cur_info['spot_id'] = info.Spot.id
cur_info['spot_name'] = info.Spot.spotname
total_info.append(cur_info)
return total_info
@staticmethod
def get_pinyin(word):
s = Pinyin().get_initials(word)
return s[0:1].upper()
@classmethod
def get_spot_machine_list(cls, spot_id):
res = Machine.query.filter_by(spot_id=spot_id).all()
if res:
result = []
for i in res:
tmp = {
"id": i.id,
"mac_no": i.mac_no
}
result.append(tmp)
return result
else:
return []
Service/ToolService.py 0 → 100644
# -*- coding: utf-8 -*-
from Model.Power.PowerModel import Power
class ToolService():
@staticmethod
def get_power_info_by_machine(machine_id):
power_data = []
power_infos = Power.query.filter_by(machine_id=machine_id).order_by(Power.hatch_no.asc()).all()
if not power_infos:
for i in range(55):
cur_power = {}
cur_power['hatch_no'] = i+1
cur_power['power'] = 0
cur_power['status'] = 0
power_data.append(cur_power)
else:
for power_info in power_infos:
cur_power = {}
cur_power['hatch_no'] = power_info.hatch_no
cur_power['power'] = power_info.has_power
if power_info.status == 7:
cur_power['status'] = 7
else:
cur_power['status'] = 1
power_data.append(cur_power)
return power_data
Service/WeChatService.py 0 → 100644
# -*- coding: utf-8 -*-
import hashlib
import uuid
import xml.etree.ElementTree as ET
import requests
from Config.common_config import MINA_APP
from Libs.Logger import logger
class WeChatService():
def __init__(self, app_id=None, app_key=None, mch_id=None, pay_key=None, pay_cert_path=None, pay_key_path=None):
self.app_id = MINA_APP["app_id"] if not app_id else app_id
self.app_key = MINA_APP["app_key"] if not app_key else app_key
self.mch_id = MINA_APP["mch_id"] if not mch_id else mch_id
self.pay_key = MINA_APP["pay_key"] if not pay_key else pay_key
self.pay_cert_path = MINA_APP["wx_pay_cert_path"] if not pay_cert_path else pay_cert_path
self.pay_key_path = MINA_APP["wx_pay_key_path"] if not pay_key_path else pay_key_path
self.default_data = {
"appid": self.app_id,
"mch_id": self.mch_id,
"nonce_str": self.get_nonce_str()
}
def create_sign(self, pay_data):
'''
生成签名
:return:
'''
stringA = '&'.join(["{0}={1}".format(k, pay_data.get(k)) for k in sorted(pay_data)])
stringSignTemp = '{0}&key={1}'.format(stringA, self.pay_key)
sign = hashlib.md5(stringSignTemp.encode("utf-8")).hexdigest()
return sign.upper()
def refund(self, refund_data=None):
'''
申请退款信息
:param refund_data:
:return:
'''
refund_data.update(self.default_data)
sign = self.create_sign(refund_data)
refund_data['sign'] = sign
xml_data = self.dict_to_xml(refund_data)
headers = {'Content-Type': 'application/xml'}
url = "https://api.mch.weixin.qq.com/secapi/pay/refund"
cert = (self.pay_cert_path, self.pay_key_path)
r = requests.post(url=url, data=xml_data.encode('utf-8'), headers=headers, cert=cert)
r.encoding = 'utf-8'
logger.info(r.text)
if r.status_code == 200:
_return_data = self.xml_to_dict(r.text)
if _return_data["return_code"] == "SUCCESS":
if _return_data["result_code"] == "SUCCESS":
return True
return False
def query_refund_info(self, refund_data=None):
'''
查询退款信息
:param refund_data:
:return:
'''
refund_data.update(self.default_data)
sign = self.create_sign(refund_data)
refund_data['sign'] = sign
xml_data = WeChatService.dict_to_xml(refund_data)
headers = {'Content-Type': 'application/xml'}
url = 'https://api.mch.weixin.qq.com/pay/refundquery'
r = requests.post(url=url, data=xml_data.encode('utf-8'), headers=headers)
r.encoding = 'utf-8'
logger.info("查询退款信息参数")
logger.info(r.text)
if r.status_code == 200:
_return_data = WeChatService.xml_to_dict(r.text)
return _return_data
return False
@staticmethod
def get_nonce_str():
'''
获取随机字符串
:return:
'''
return str(uuid.uuid4()).replace('-', '')
@staticmethod
def dict_to_xml(dict_data):
'''
dict to xml
:param dict_data:
:return:
'''
xml = ["<xml>"]
for k, v in dict_data.items():
xml.append("<{0}>{1}</{0}>".format(k, v))
xml.append("</xml>")
return "".join(xml)
@staticmethod
def xml_to_dict(xml_data):
'''
xml to dict
:param xml_data:
:return:
'''
xml_dict = {}
root = ET.fromstring(xml_data)
for child in root:
xml_dict[child.tag] = child.text
return xml_dict
app.py 0 → 100644
from flask import Flask, request, url_for, jsonify, g
from flask_cors import CORS
from Libs.ErrorTips import TOKEN_NOT_PROVIDER_ERROR, TOKEN_NOT_VALID_ERROR, TOKEN_EXPIRE_ERROR
from Libs.Logger import logger
from Model.Agent.AgentAccountModel import AgentAccount
from Service.AgentService import AgentService
from Model.Base import db
from Redis_Cache import redis
from Controller.IndexController import route_index
from Controller.ToolController import route_tool
from Controller.AccountController import route_account
from Controller.ReportController import route_report
from Controller.RentController import route_rent
from Controller.RepairController import route_repair
from Controller.SpotController import route_spot
from Controller.InvoiceController import route_invoice
app = Flask(__name__)
app.config.from_object('Config.base_config')
CORS(app)
# 初始化数据库
db.init_app(app)
# 初始化redis
redis.init_app(app)
app.register_blueprint(route_index, url_prefix='/business/index')
app.register_blueprint(route_tool, url_prefix='/business/tool')
app.register_blueprint(route_account, url_prefix='/business/account')
app.register_blueprint(route_report, url_prefix='/business/report')
app.register_blueprint(route_rent, url_prefix='/business/rent')
app.register_blueprint(route_repair, url_prefix='/business/repair')
app.register_blueprint(route_spot, url_prefix='/business/spot')
app.register_blueprint(route_invoice, url_prefix='/business/invoice')
@app.before_request
def log_enter_interface():
logger.info("#################### 进入 {} 接口 ####################".format(request.path))
@app.before_request
def verify_auth_token():
'''
用户登录验证token
:return:
'''
NO_AUTH_CHECK_URL = [url_for('account.test'), url_for('account.login'), url_for('account.send_code')]
if request.path not in NO_AUTH_CHECK_URL:
token = request.headers.get('token')
if not token:
return jsonify(TOKEN_NOT_PROVIDER_ERROR)
result = AgentService.check_agent_token(token)
if result == 1:
return jsonify(TOKEN_NOT_VALID_ERROR)
elif result == 2:
return jsonify(TOKEN_EXPIRE_ERROR)
else:
g.user = result
logger.info("本次登录用户名称：{0}，手机号：{1}，类型：{2}".format(result.user_name, result.phone, result.level_desc))
@app.after_request
def log_out_interface(environ):
logger.info("#################### 退出 {} 接口 ####################\n".format(request.path))
return environ
if __name__ == '__main__':
app.run(port='5056')
requirements.txt 0 → 100644
altgraph==0.16.1
APScheduler==3.6.1
autopy==2.1.0
backports.csv==1.0.7
certifi==2019.6.16
chardet==3.0.4
cipher==0.1
Click==7.0
colorama==0.4.1
configobj==5.0.6
crypto==1.4.1
defusedxml==0.6.0
Django==2.2.1
docopt==0.6.2
dpkt==1.9.2
dss==0.8
et-xmlfile==1.0.1
Flask==1.0.3
Flask-Cache==0.13.1
Flask-Caching==1.7.2
Flask-Cors==3.0.8
flask-redis==0.4.0
Flask-Script==2.0.6
flask-sqlacodegen==1.1.6.1
Flask-SQLAlchemy==2.4.0
future==0.17.1
idna==2.8
inflect==2.1.0
itsdangerous==1.1.0
jdcal==1.4.1
Jinja2==2.10.1
jsonify==0.5
macholib==1.11
MarkupSafe==1.1.1
mysqlclient==1.4.2.post1
Naked==0.1.31
netifaces==0.10.9
odfpy==1.4.0
openpyxl==2.4.11
pefile==2019.4.18
psutil==5.6.2
pycryptodome==3.8.2
PyInstaller==3.4
PyMySQL==0.9.3
python-xlib==0.25
pytz==2019.1
pywin32-ctypes==0.2.0
PyYAML==5.1.1
qcloudsms-py==0.1.3
qrcode==6.1
records==0.5.3
redis==3.2.1
requests==2.22.0
schedule==0.6.0
Serializer==0.2.1
shellescape==3.4.1
simplejson==3.16.0
singledispatch==3.4.0.3
six==1.12.0
SQLAlchemy==1.3.5
sqlparse==0.3.0
tablib==0.13.0
tzlocal==2.0.0
urllib3==1.25.3
Werkzeug==0.15.4
xlrd==1.2.0
xlwt==1.3.0
start_server.sh 0 → 100644
ps -ef|grep 'tour_business/uwsgi.ini' |grep -v grep|cut -c 9-15|xargs kill -9
nohup /root/.pyenv/versions/env4tour_business/bin/uwsgi --ini /data/www/tour_business/uwsgi.ini >/dev/null 2>&1 &
uwsgi.ini 0 → 100644
[uwsgi]
# uwsgi 启动时所使用的地址与端口
socket = 127.0.0.1:5056
# 指向网站目录
chdir = /data/www/tour_business
# python 启动程序文件
wsgi-file = app.py
# python 程序内用以启动的 application 变量名
callable = app
# 处理器数
processes = 1
# 线程数
threads = 2
daemonize = /data/www/tour_business/server.log
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment