wip:历史业绩时间

saleFlush/config.yaml

@@ -1,10 +1,11 @@
 database:
   release:
     link: "mysql:readuser:jyTi_R202403@tcp(192.168.3.71:4003)/jianyu"
-    #debug: true
+    debug: true
   default:
-    link: "mysql:root:=PDT49#80Z!RVv52_z@tcp(192.168.3.14:4000)/jianyu"
-    #debug: true
+    #link: "mysql:root:=PDT49#80Z!RVv52_z@tcp(192.168.3.14:4000)/jianyu"
+    link: "mysql:Wangkaiyue:Wky@20230316#@tcp(127.0.0.1:4000)/jianyu"
+    debug: true
 
 logger:
   level: "all"

saleFlush/main.go

@@ -40,9 +40,9 @@ var (
 	codeDeptMapping = map[string]*newDept{}
 	beforeMoneyMap  = map[string]int{}  //红冲单子
 	hasSaleMap      = map[string]bool{} //已存在业绩
-	table           = "order_sale_record_release1"
+	table           = "order_sale_record"
 
-	updateSaleTimeMapping = map[string]interface{}{}
+	updateSaleTimeMapping = map[string]map[string]interface{}{}
 )
 
 type (
@@ -67,7 +67,7 @@ func init() {
 		}
 	}
 	//加载红冲记录
-	res, err := g.DB("release").Query(context.TODO(), "SELECT createTime,orderCode,payMoney from moneyCorrection WHERE redType='金额红冲' and payMoney!=0 AND createTime >'2024-01-01 00:00:00' and createTime < '2024-09-10 00:00:00'")
+	res, err := g.DB("release").Query(context.TODO(), "SELECT createTime,orderCode,payMoney from moneyCorrection WHERE redType='金额红冲' and payMoney!=0 AND createTime >'2024-01-01 00:00:00' ")
 	if err != nil {
 		panic(err)
 	}
@@ -98,7 +98,7 @@ func main() {
 }
 
 func CreateSaleRecord(ctx context.Context) {
-	res, err := g.DB("release").Query(ctx, "SELECT order_status,order_money,order_code,pay_money,saleDep,salesperson_id,salesperson,saleMoney,is_backstage_order,sale_time,pay_time,refund_status,create_time FROM dataexport_order WHERE (create_time >'2024-01-01 00:00:00' and create_time < '2024-09-10 00:00:00') or order_code in ('112519605433','090810057631','104306434632','155349703173','111059225831')")
+	res, err := g.DB("release").Query(ctx, "SELECT order_status,order_money,order_code,pay_money,saleDep,salesperson_id,salesperson,saleMoney,is_backstage_order,sale_time,pay_time,refund_status,create_time FROM dataexport_order WHERE (create_time >'2024-01-01 00:00:00') or order_code in ('112519605433','090810057631','104306434632','155349703173','111059225831')")
 	if err != nil {
 		panic(err)
 	}
@@ -121,12 +121,12 @@ func CreateSaleRecord(ctx context.Context) {
 			reason          = "" //协议归档
 			statistics_time = ""
 		)
-		if _, ok := beforeMoneyMap[order_code]; ok {
-			continue
-		}
-		if _, ok := hasSaleMap[order_code]; ok {
-			continue
-		}
+		//if _, ok := beforeMoneyMap[order_code]; ok {
+		//	continue
+		//}
+		//if _, ok := hasSaleMap[order_code]; ok {
+		//	continue
+		//}
 		if is_backstage_order == 1 {
 			//后台创建订单获取业绩时间
 			if (refund_status == 1 || refund_status == 2 || order_status == 1) && pay_money > 0 {
@@ -302,16 +302,18 @@ func CreateSaleRecord(ctx context.Context) {
 			insertArr = append(insertArr, m)
 		}
 		//save
-		if len(insertArr) >= 100 {
-			SaveDb(ctx, insertArr)
-			insertArr = []map[string]interface{}{}
-		}
+		//if len(insertArr) >= 100 {
+		//	SaveDb(ctx, insertArr)
+		//	insertArr = []map[string]interface{}{}
+		//}
 	}
 	//save
-	if len(insertArr) > 0 {
-		SaveDb(ctx, insertArr)
-		insertArr = []map[string]interface{}{}
-	}
+	//if len(insertArr) > 0 {
+	//	SaveDb(ctx, insertArr)
+	//	insertArr = []map[string]interface{}{}
+	//}
+	//UpdateSaleTime(context.TODO())
+
 	g.Log().Printf(ctx, "%d", len(updateSaleTimeMapping))
 	if err := gfile.PutContents("./aaa.json", gconv.String(updateSaleTimeMapping)); err != nil {
 		panic(err)
@@ -326,6 +328,19 @@ func SaveDb(ctx context.Context, data []map[string]interface{}) {
 	}
 }
 
+func UpdateSaleTime(ctx context.Context) {
+	for orderCode, m := range updateSaleTimeMapping {
+		_, err := g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
+			"sale_time": m["new_sale_time"],
+		}, map[string]interface{}{
+			"order_code": orderCode,
+		})
+		if err != nil {
+			g.Log().Errorf(ctx, "%s err %v", orderCode, err)
+		}
+	}
+}
+
 // redRecord 红冲记录补全
 func redRecord(ctx context.Context) {
 	for orderCode, money := range beforeMoneyMap {