定时任务测试

http/handle/api/scheduled.go

@@ -106,7 +106,7 @@ func CronScheduled(ctx context.Context) {
 	})
 	dayCron.Start()
 	// ymy.YmyCron(pastureinfo.Werks, pastureinfo.Pastureid)
-	
+	// manualUdData(pastureinfo)
 	// 0 无同步 1 圣牧 2 现代牧业 3 新希望 4 乐源 5 光明ud 6 多语言京鹏ud 7 一牧云
 	if setting.ServerSetting.SyncStatus == 1 {
 		// 圣牧
@@ -1097,74 +1097,77 @@ func processAnalysisEarlyWarning(target []string, pastureId string, serviceId in
 func manualUdData(pastureinfo *udPastureInfo) {
 	c := cron.New()
 	c.AddFunc("30 16 * * *", func() {
+		// fmt.Println(time.Now(),"testtesttesttesttesttesttesttest")
+		tx := restful.Engine.NewSession()
+		defer tx.Close()
+		now := time.Now().AddDate(0, 0, -1).Format("2006-01-02")
+		// now := "2023-02-22"
+		dataList, err := tx.SQL(" select id  from downloadedplan where mydate = ? ", now).QueryString()
+		if err != nil {
+			logging.Error("manualUdData-error-1:", err)
+			return
+		}
+		var idList []string
+		for _, data := range dataList {
+			idList = append(idList, data["id"])
+		}
+
+		upList := make([]*ScheduledUpInfo, 0)
+		// tx.ShowSQL(true) 
+		up := tx.Table("scheduled_up")
+
+		up.Where("company = ? ", "ud")
+		up.Where("datatype in(3,4,1)")
+		// up.Where("datatype in (8)")
+		// up.Where("automatic = '1'")
+		err = up.Find(&upList)
+		if err != nil {
+			logging.Error("manualUdData-error-2: ", err)
+			return
+		}
+	
 		fmt.Println(time.Now(),"testtesttesttesttesttesttesttest")
-		// tx := restful.Engine.NewSession()
-		// defer tx.Close()
-		// now := time.Now().AddDate(0, 0, -1).Format("2006-01-02")
-		// // now := "2023-02-22"
-		// dataList, err := tx.SQL(" select id  from downloadedplan where mydate = ? ", now).QueryString()
-		// if err != nil {
-		// 	logging.Error("manualUdData-error-1:", err)
-		// 	return
-		// }
-		// var idList []string
-		// for _, data := range dataList {
-		// 	idList = append(idList, data["id"])
-		// }
+		for _, item := range upList {
+			if item.Datasql != "" {
+				// if item.Datatype == 4 {
+				targetdataList := strings.Split(item.Targetdata, ",")
+				var args []interface{}
+				for _, targetdata := range targetdataList {
+					if targetdata == "pastureid" {
+						args = append(args, pastureinfo.Pastureid)
+					} else if targetdata == "idlist" {
+						item.Datasql = strings.ReplaceAll(item.Datasql, "idlist", strings.Join(idList, ","))
+					} else if targetdata == "date" {
+						args = append(args, now)
+					}
+				}
+				data, err := tx.SQL(item.Datasql, args...).Query().List()
+				if err != nil {
+					logging.Error("manualUdData-error-3: ", err)
+					continue
+				}
+				if len(data) > 0 {
+					databyte, err := json.Marshal(data)
+					if err != nil {
+						logging.Error("manualUdData-error-4: ", err)
+						continue
+					}
+					exist, err := tx.SQL(`select * from saplog where pastureId = ? and msgtype = ? and date_format(dataDate ,'%Y-%m-%d') = ?  `,
+						pastureinfo.Pastureid, item.Datatype, now).Exist()
+					if exist {
+						continue
+					}
 
-		// upList := make([]*ScheduledUpInfo, 0)
-		// up := tx.Table("scheduled_up")
-
-		// up.Where("company = ? ", "ud")
-		// up.Where("datatype in (3,4,1)")
-		// // up.Where("datatype in (8)")
-		// up.Where("automatic = 1")
-		// err = up.Find(&upList)
-		// if err != nil {
-		// 	logging.Error("manualUdData-error-2: ", err)
-		// 	return
-		// }
+					tx.Exec(` insert into saplog(pastureId,request,response,status,msgtext,createTime,msgtype,dataDate,url)
+					values(?,?,?,?,?,now(),?,?,?)`, pastureinfo.Pastureid, string(databyte), "", "", "", item.Datatype, now, "https://wdc.unidairy.cn/copartner_uploads/")
 
-		// for _, item := range upList {
-		// 	if item.Datasql != "" {
-		// 		// if item.Datatype == 4 {
-		// 		targetdataList := strings.Split(item.Targetdata, ",")
-		// 		var args []interface{}
-		// 		for _, targetdata := range targetdataList {
-		// 			if targetdata == "pastureid" {
-		// 				args = append(args, pastureinfo.Pastureid)
-		// 			} else if targetdata == "idlist" {
-		// 				item.Datasql = strings.ReplaceAll(item.Datasql, "idlist", strings.Join(idList, ","))
-		// 			} else if targetdata == "date" {
-		// 				args = append(args, now)
-		// 			}
-		// 		}
-		// 		data, err := tx.SQL(item.Datasql, args...).Query().List()
-		// 		if err != nil {
-		// 			logging.Error("manualUdData-error-3: ", err)
-		// 			continue
-		// 		}
-		// 		if len(data) > 0 {
-		// 			databyte, err := json.Marshal(data)
-		// 			if err != nil {
-		// 				logging.Error("manualUdData-error-4: ", err)
-		// 				continue
-		// 			}
-		// 			exist, err := tx.SQL(`select * from saplog where pastureId = ? and msgtype = ? and date_format(dataDate ,'%Y-%m-%d') = ?  `,
-		// 				pastureinfo.Pastureid, item.Datatype, now).Exist()
-		// 			if exist {
-		// 				continue
-		// 			}
-
-		// 			tx.Exec(` insert into saplog(pastureId,request,response,status,msgtext,createTime,msgtype,dataDate,url)
-		// 			values(?,?,?,?,?,now(),?,?,?)`, pastureinfo.Pastureid, string(databyte), "", "", "", item.Datatype, now, "https://wdc.unidairy.cn/copartner_uploads/")
-
-		// 			var method string
-		// 			UDPostPush1(fmt.Sprintf(item.Package, string(databyte), len(data)), method)
-		// 		}
-		// 		// }
-		// 	}
-		// }
+					var method string
+					// fmt.Println(fmt.Sprintf(item.Package, string(databyte), len(data)), method)
+					UDPostPush1(fmt.Sprintf(item.Package, string(databyte), len(data)), method)
+				}
+				// }
+			}
+		}
 	})
 	c.Start()