1.0

internal/dao/dong.go

@@ -29,7 +29,7 @@ var Model_dong = map[int]string{
 	43:"退货率",
 	43:"退货率",
 	44:"近6个月逾期变化率",
 	44:"近6个月逾期变化率",
 	45:"近6个月参保人数变化率",
 	45:"近6个月参保人数变化率",
-	999:"统计动态分数",
+	999:"累计动态分数",
 }
 }
 //动态模型对应的日志文件名称
 //动态模型对应的日志文件名称
 var Model_dong_log = map[int]string{
 var Model_dong_log = map[int]string{
@@ -47,7 +47,6 @@ var Model_dong_log = map[int]string{
 
 
 //计算逾期金额率：延期支付时间超过平均账期的金额/收款总额:
 //计算逾期金额率：延期支付时间超过平均账期的金额/收款总额:
 func (d *dao) DongMain(ctx context.Context,project_id int,erp_company_code string) (r []map[string]interface{},err error) {
 func (d *dao) DongMain(ctx context.Context,project_id int,erp_company_code string) (r []map[string]interface{},err error) {
-
 	var (
 	var (
 		ladder_rate float64  //计算出来的各个动态分数率
 		ladder_rate float64  //计算出来的各个动态分数率
 		ladder_score float64 =0; //对应梯度分数
 		ladder_score float64 =0; //对应梯度分数
@@ -146,7 +145,10 @@ func (d *dao) DongMain(ctx context.Context,project_id int,erp_company_code strin
 			fmt.Print(log2)
 			fmt.Print(log2)
 			logic.Loginfo(log2,log_pre)
 			logic.Loginfo(log2,log_pre)
 		}
 		}
+		fmt.Print("XIE:"+v["erp_company_code"])
 	}
 	}
+
+	//d.Close(); //关闭数据库连接
 	logic.Loginfo("统计"+mod_name+"完成",log_pre)
 	logic.Loginfo("统计"+mod_name+"完成",log_pre)
 	return
 	return
 }
 }

internal/dao/scores.go

@@ -10,7 +10,7 @@ import (
 
 
 //增加或者修改记录
 //增加或者修改记录
 func (d *dao) InsertScores(ctx context.Context,score model.Scores) (insertId int64,err error) {
 func (d *dao) InsertScores(ctx context.Context,score model.Scores) (insertId int64,err error) {
-
+	//defer d.db.Close()
 	var(
 	var(
 		exitId int
 		exitId int
 		execSql string
 		execSql string
@@ -43,6 +43,6 @@ func (d *dao) InsertScores(ctx context.Context,score model.Scores) (insertId int
 	}
 	}
 	insertId = affectNum
 	insertId = affectNum
 
 
-	//defer d.db.Close()
+
 	return
 	return
 }
 }