大客数据处理

clueSync/jobutil.go

@@ -502,6 +502,7 @@ func orders() {
 	selectTimeStart := time.Unix(time.Now().Unix()-7200, 0).Format(date.Date_Full_Layout)
 	selectTimeEnd := time.Unix(time.Now().Unix()-3600, 0).Format(date.Date_Full_Layout)
 	sql := fmt.Sprintf(`select * from dataexport_order where create_time <= "%s" and create_time >= "%s" and id > %s`, selectTimeEnd, selectTimeStart, fmt.Sprint(lastOrderId))
+	//sql := fmt.Sprintf(`select * from dataexport_order where id=260265`)
 	data := Mysql.SelectBySql(sql)
 	if data != nil && *data != nil && len(*data) > 0 {
 		for _, v := range *data {
@@ -510,6 +511,7 @@ func orders() {
 			product_type_str1 := `"大会员","VIP订阅","数据流量包","历史数据"`
 			product_type := common.ObjToString(v["product_type"])
 			if order_status == 0 && is_backstage_order == 0 && strings.Contains(product_type_str1, product_type) {
+				log.Println("orders111", v)
 				ok1, ok2, _ := FormatData(v, "orders")
 				if !ok1 {
 					common.WriteSysConfig(&cfg)