Skip to content

Z
zhichan
Commit 68bbd47b by 张云飞
Options

zyf

parent 9956f261
Showing with 141 additions and 119 deletions
ic-name/hanshujisuan.py
......@@ -20,19 +20,18 @@ ES_USER = ""
ES_PWD = ""
ES_PORT = ""
environDict = os.environ
dbdict = json.loads(environDict.get("ZYF"))
if dbdict:
print(dbdict, "---------------------------")
DB_HOST = dbdict.get('DB_HOST')
DB_PORT = dbdict.get('DB_PORT')
DB_USER = dbdict.get('DB_USER')
DB_PWD = dbdict.get('DB_PWD')
QCC_APPKEY = dbdict.get('QCC_APPKEY')
QCC_SECRETKEY = dbdict.get('QCC_SECRETKEY')
ES_HOST = dbdict.get('ES_HOST')
ES_USER = dbdict.get('ES_USER')
ES_PWD = dbdict.get('ES_PWD')
ES_PORT = dbdict.get('ES_PORT')
print(environDict.get('DB_HOST'), "---------------------------")
print(environDict.get('ES_HOST'), "---------------------------")
DB_HOST = environDict.get('DB_HOST')
DB_PORT = environDict.get('DB_PORT')
DB_USER = environDict.get('DB_USER')
DB_PWD = environDict.get('DB_PWD')
QCC_APPKEY = environDict.get('QCC_APPKEY')
QCC_SECRETKEY = environDict.get('QCC_SECRETKEY')
ES_HOST = environDict.get('ES_HOST')
ES_USER = environDict.get('ES_USER')
ES_PWD = environDict.get('ES_PWD')
ES_PORT = environDict.get('ES_PORT')
def findByType():
......
ic-name/main.py
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2020-05-27 9:53
# @Time : 2020-07-01 22:10
# @Author : zhangyunfei
# @File : main.py
# @File : mysqltest.py
# @Software: PyCharm
import pymysql
import ast
import json
from hanshujisuan import heming
from flask import Flask,request,jsonify
server = Flask(__name__)
server.config['JSON_AS_ASCII'] =False
@server.route('/gsb/heming', methods=['POST'])
def my_handler():
# get request_body
if request.method == 'POST':
input_data = request.json
print(input_data)
if len(input_data) != 0:
if input_data.get("cityname") != None and input_data.get("keyword") != None and input_data.get("btname") != None:
try:
if input_data.get("cityname") == "":
jsondata = {
"code": "500",
"message": "缺少cityname值",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
elif input_data.get("keyword") == "":
jsondata = {
"code": "500",
"message": "缺少keyname值",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
elif input_data.get("btname") == "":
jsondata = {
"code": "500",
"message": "缺少btname值",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
elif input_data.get("orgname") == None and input_data.get("sitcity") == None:
input_data.update({"orgname": "有限公司"})
input_data.update({"sitcity": "1"})
info = heming(input_data)
# return value must be iterable
return jsonify(info)
elif input_data.get("orgname") == None:
input_data.update({"orgname": "有限公司"})
if input_data.get("sitcity") == "":
input_data.update({"sitcity": "1"})
info = heming(input_data)
# return value must be iterable
return jsonify(info)
else:
info = heming(input_data)
# return value must be iterable
return jsonify(info)
elif input_data.get("sitcity") == None:
input_data.update({"sitcity": "1"})
if input_data.get("orgname") == "":
input_data.update({"orgname": "有限公司"})
info = heming(input_data)
# return value must be iterable
return jsonify(info)
else:
info = heming(input_data)
# return value must be iterable
return jsonify(info)
else:
info = heming(input_data)
# return value must be iterable
return jsonify(info)
except Exception as e:
jsondata = {
"code": "500",
"message": "异常："+str(e),
"data": {}
}
return jsonify(jsondata)
else:
jsondata = {
"code": "500",
"message": "缺少参数",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
else:
jsondata = {
"code": "500",
"message": "数据结构传输错误",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
# server.run(host='192.168.1.131', port=15502, debug=True)
server.run(host='0.0.0.0', port=15502, debug=True)
if __name__ == '__main__':
conn = pymysql.connect(host="9.139.8.35", port=13057, user="brg", password="Brg2020!", db="brg-tx-shop")
sql = 'SELECT * FROM x_product_type'
# 获取游标
cursor = conn.cursor()
# 执行sql语句
conn.ping(reconnect=True)
cursor.execute(sql)
conn.commit()
result = cursor.fetchall()
print("---------------------start-------------")
print(result)
print("---------------------end-------------")
cursor.close()
conn.close()
ic-name/test_main.py 0 → 100755
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2020-05-27 9:53
# @Author : zhangyunfei
# @File : main.py
# @Software: PyCharm
import ast
import json
from hanshujisuan import heming
from flask import Flask,request,jsonify
server = Flask(__name__)
server.config['JSON_AS_ASCII'] =False
@server.route('/gsb/heming', methods=['POST'])
def my_handler():
# get request_body
if request.method == 'POST':
input_data = request.json
print(input_data)
if len(input_data) != 0:
if input_data.get("cityname") != None and input_data.get("keyword") != None and input_data.get("btname") != None:
try:
if input_data.get("cityname") == "":
jsondata = {
"code": "500",
"message": "缺少cityname值",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
elif input_data.get("keyword") == "":
jsondata = {
"code": "500",
"message": "缺少keyname值",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
elif input_data.get("btname") == "":
jsondata = {
"code": "500",
"message": "缺少btname值",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
elif input_data.get("orgname") == None and input_data.get("sitcity") == None:
input_data.update({"orgname": "有限公司"})
input_data.update({"sitcity": "1"})
info = heming(input_data)
# return value must be iterable
return jsonify(info)
elif input_data.get("orgname") == None:
input_data.update({"orgname": "有限公司"})
if input_data.get("sitcity") == "":
input_data.update({"sitcity": "1"})
info = heming(input_data)
# return value must be iterable
return jsonify(info)
else:
info = heming(input_data)
# return value must be iterable
return jsonify(info)
elif input_data.get("sitcity") == None:
input_data.update({"sitcity": "1"})
if input_data.get("orgname") == "":
input_data.update({"orgname": "有限公司"})
info = heming(input_data)
# return value must be iterable
return jsonify(info)
else:
info = heming(input_data)
# return value must be iterable
return jsonify(info)
else:
info = heming(input_data)
# return value must be iterable
return jsonify(info)
except Exception as e:
jsondata = {
"code": "500",
"message": "异常："+str(e),
"data": {}
}
return jsonify(jsondata)
else:
jsondata = {
"code": "500",
"message": "缺少参数",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
else:
jsondata = {
"code": "500",
"message": "数据结构传输错误",
"data": {}
}
# jsondata = json.dumps(jsondata, ensure_ascii=False)
# infostr = jsondata
return jsonify(jsondata)
# server.run(host='192.168.1.131', port=15502, debug=True)
server.run(host='0.0.0.0', port=15502, debug=True)
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