d

calc_result/RiskComputer.py

@@ -38,7 +38,7 @@ class RiskComputer:
                 self.IndexRes[indexItem.Name]="0"
     def Ret2Json(self):#把指标结果转化为樊辉需要的Json
         #json写入数据库
-        db = pymysql.connect(host=FK_DB_HOST,port=FK_DB_PORT,user=FK_DB_USER,password=FK_DB_PWD,db=FK_DB_NAME,charset="utf8mb4")
+        db = pymysql.connect(host=FK_DB_HOST,port=int(FK_DB_PORT),user=FK_DB_USER,password=FK_DB_PWD,db=FK_DB_NAME,charset="utf8mb4")
         cursor = db.cursor()
         for key in self.IndexRes:
             sql = """INSERT INTO result_set(batchno,indexName,status) VALUES ('"""+str(self.batch_No)+"""', '"""+str(key)+"""','"""+str(self.IndexRes[key])+"""')"""

calc_result/Update.py

@@ -12,7 +12,7 @@ FK_DB_USER = env_dist.get('FK_DB_USER')      #获取mysql用户名
 FK_DB_PWD = env_dist.get('FK_DB_PWD')      #获取mysql密码
 FK_DB_NAME = env_dist.get('FK_DB_NAME')   #获取mysql库
 class UpdateId:
-    conn = pymysql.connect(host=FK_DB_HOST,port=FK_DB_PORT,user=FK_DB_USER,password=FK_DB_PWD,db=FK_DB_NAME,charset="utf8mb4")
+    conn = pymysql.connect(host=FK_DB_HOST,port=int(FK_DB_PORT),user=FK_DB_USER,password=FK_DB_PWD,db=FK_DB_NAME,charset="utf8mb4")
     def Update(self,BatchNo):
         cursor = self.conn.cursor()
         sql = "UPDATE upload_batch SET batchstatuscode = 'rptover' WHERE id = %s;"