wip:历史业绩时间

saleFlush/main.go

@@ -2,7 +2,6 @@ package main
 
 import (
 	"context"
-	"fmt"
 	_ "github.com/gogf/gf/contrib/drivers/mysql/v2"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gfile"
@@ -67,7 +66,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' ")
+	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 orderCode='153906243232'")
 	if err != nil {
 		panic(err)
 	}
@@ -79,26 +78,26 @@ func init() {
 		)
 		beforeMoneyMap[orderCode] = beforeMoneyMap[orderCode] - payMoney
 	}
-	//加载已刷新过的业绩
-	res2, err := g.DB().Query(context.TODO(), fmt.Sprintf("SELECT ordercode from %s ", table))
-	if err != nil {
-		panic(err)
-	}
-	for _, row := range res2.List() {
-		var (
-			orderCode = gconv.String(row["ordercode"])
-		)
-		hasSaleMap[orderCode] = true
-	}
+	////加载已刷新过的业绩
+	//res2, err := g.DB().Query(context.TODO(), fmt.Sprintf("SELECT ordercode from %s ", table))
+	//if err != nil {
+	//	panic(err)
+	//}
+	//for _, row := range res2.List() {
+	//	var (
+	//		orderCode = gconv.String(row["ordercode"])
+	//	)
+	//	hasSaleMap[orderCode] = true
+	//}
 }
 
 func main() {
 	redRecord(context.TODO())
-	CreateSaleRecord(context.TODO())
+	//CreateSaleRecord(context.TODO())
 }
 
 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') 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  order_code in ('153906243232')")
 	if err != nil {
 		panic(err)
 	}
@@ -329,6 +328,7 @@ func SaveDb(ctx context.Context, data []map[string]interface{}) {
 }
 
 func UpdateSaleTime(ctx context.Context) {
+	return
 	for orderCode, m := range updateSaleTimeMapping {
 		_, err := g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
 			"sale_time": m["new_sale_time"],
@@ -343,6 +343,7 @@ func UpdateSaleTime(ctx context.Context) {
 
 // redRecord 红冲记录补全
 func redRecord(ctx context.Context) {
+
 	for orderCode, money := range beforeMoneyMap {
 		if _, ok := hasSaleMap[orderCode]; ok {
 			continue