hj

calc_result/IndexComputerFile.py

@@ -93,7 +93,7 @@ class IndexComputer:
                     print("计算异常公式时")
                     print('finance error:', err)
                     return "∞"
-                Finance_result = int(X[j - 1])
+                Finance_result = X[j - 1]
                 if Finance_result ==0.0:
                     Finance_result= int(Finance_result)
                 else:

calc_result/RiskComputer.py

@@ -49,6 +49,10 @@ class RiskComputer:
                     if ret == "—":
                         ret = "—"
                     else:
+                        if "率" in a:
+                            ret1 = float('%.2f' % ret)
+                            ret = str(float('%.2f' % (ret1*100))) + '%'
+                        else:
                             ret = format(ret, ',')  # 指定逗号位数字的千分位分隔符
                     self.IndexRes1[a]={Curr_Date:ret}
                 else:
@@ -56,6 +60,10 @@ class RiskComputer:
                         if ret == "—":
                             ret = "—"
                         else:
+                            if "率" in a:
+                                ret1 = float('%.2f' % ret)
+                                ret = str(float('%.2f' % (ret1*100))) + '%'
+                            else:
                                 ret = format(ret, ',')  # 指定逗号位数字的千分位分隔符
                         self.IndexRes1[a][Previous_Date]=ret
                     else:
@@ -64,24 +72,18 @@ class RiskComputer:
                         elif ret == '—':
                             ret = '—'
                         else:
-                            print(type(ret),"====ret")
                             ret1 = float('%.2f' % ret)
-                            ret = str(ret1 * 100) + '%'
+                            ret = str(float('%.2f' % (ret1*100))) + '%'
                         self.IndexRes1[a]["change_rate"] = ret
 
     def Ret2Json(self):#把指标结果转化为樊辉需要的Json
         #json写入数据库
-        # db = pymysql.connect(host='47.105.186.2',port=3307,user='caishui',password='jvmfTVDuG5YE(*Z',db='fktaxctl',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()
         arr = [self.IndexRes,self.IndexRes1]
         ss = ['ri','fi']
         for i,index_results in enumerate(arr): #索引，值
-            print(i,"=============i")
-            print(index_results, "=============qq")
             for key in index_results:
-                # print(self.indexs['id'],"=======公式id")
-                #'factors_name':'指标状态47.105.186.2'
                 ri1 = {}
                 ri1[key]= index_results[key]
                 insert_batch_No = "'"+str(self.batch_No)+"'"
@@ -100,7 +102,7 @@ class RiskComputer:
                 # 提交到数据库执行
                     db.commit()
                 except Exception as e:
-                    print(e)
+                    # print(e)
                     db.rollback()
             # 关闭数据库连接
         db.close()