update

app/admin/svc/order/svc_central_kitchen_for_school_order.go

@@ -405,19 +405,20 @@ func CentralKitchenForSchoolOrderRefundAudit(c *gin.Context, req md.CentralKitch
 	}
 	wxSvc := refunddomestic.RefundsApiService{Client: client}
 	for k, v := range dealReturnOrdMapForWx {
-		resp, _, err6 := wxSvc.Create(c,
-			refunddomestic.CreateRequest{
-				SubMchid:    core.String(v.WxMchId),
-				OutTradeNo:  core.String(k),
-				OutRefundNo: core.String(v.OutRequestNo),
-				Reason:      core.String("央厨订餐退款"),
-				NotifyUrl:   core.String(sysCfg[enum.WxJsapiRefundPayNotifyUrl]),
-				Amount: &refunddomestic.AmountReq{
-					Currency: core.String("CNY"),
-					Refund:   core.Int64(int64(math.Round(v.Amount * 100))),
-					Total:    core.Int64(int64(math.Round(utils.StrToFloat64(v.Total) * 100))),
-				},
+		createRequest := refunddomestic.CreateRequest{
+			SubMchid:    core.String(v.WxMchId),
+			OutTradeNo:  core.String(k),
+			OutRefundNo: core.String(v.OutRequestNo),
+			Reason:      core.String("央厨订餐退款"),
+			NotifyUrl:   core.String(sysCfg[enum.WxJsapiRefundPayNotifyUrl]),
+			Amount: &refunddomestic.AmountReq{
+				Currency: core.String("CNY"),
+				Refund:   core.Int64(int64(math.Round(v.Amount * 100))),
+				Total:    core.Int64(int64(math.Round(utils.StrToFloat64(v.Total) * 100))),
 			},
+		}
+		resp, _, err6 := wxSvc.Create(c,
+			createRequest,
 		)
 
 		fmt.Println(">>>>wxRefund<<<<", resp)
@@ -446,6 +447,7 @@ func CentralKitchenForSchoolOrderRefundAudit(c *gin.Context, req md.CentralKitch
 				"sql":  sql,
 				"sql1": sql1,
 				"err":  err6.Error(),
+				"args": createRequest,
 			}))
 		} else {
 			//TODO::处理订单状态

main.go

@@ -30,76 +30,114 @@ func init() {
 
 }
 
-func main() {
-	//svc.CentralKitchenForSchoolAlipayTradeFastpayRefundQuery(db.Db)
-	//var list []model.CentralKitchenForSchoolUserRefundDay
-	//if err := db.Db.Where("create_at >= '2024-01-15 18:00:00' AND state = 4 and uid < 0").Desc("id").Find(&list); err != nil {
+func DealClassWithUser() {
+	//var list []model.ClassWithUser
+	//if err := db.Db.Where("id < ").Desc("id").Find(&list); err != nil {
 	//	fmt.Println(err)
 	//}
-	//
-	//var notCanUserIds []int
+	//var notIds = map[int]bool{}
 	//for _, v := range list {
-	//	v.RecordsId = -v.RecordsId
-	//	v.OutTradeNo = "-" + v.OutTradeNo
-	//	affected1, err := db.Db.Where("id=?", v.Id).Cols("records_id", "out_trade_no").Update(&v)
-	//	if err != nil {
-	//		fmt.Println(err)
+	//	if notIds[v.Id] {
+	//		continue
 	//	}
-	//	fmt.Println(">>>>>>>>>>>>>>>>>affected1<<<<<<<<<<<<<<<<<<<", affected1)
-	//	continue
-	//	var mm []model.CentralKitchenForSchoolUserRefundDay
-	//	if err := db.Db.Where("uid = ?", v.Uid).And("state = 1").Desc("records_id").Find(&mm); err != nil {
+	//	var tmpList []model.ClassWithUser
+	//	if err := db.Db.Where("id !=? and user_identity_id=?", v.Id, v.UserIdentityId).And("class_id =?", v.ClassId).Find(&tmpList); err != nil {
 	//		fmt.Println(err)
 	//	}
-	//
-	//	if len(mm) > 0 {
-	//		mmm := new(model.CentralKitchenForSchoolUserWithDay)
-	//		_, err := db.Db.Where("id =?", mm[0].RecordsId).Get(mmm)
-	//		if err != nil {
-	//			fmt.Println(err)
-	//		}
-	//		//if mmm.Date == "2024-01-31" {
-	//		//1、更改当前记录
-	//		v.Uid = -v.Uid
-	//		affected1, err := db.Db.Where("id=?", v.Id).Cols("uid").Update(&v)
-	//		if err != nil {
-	//			fmt.Println(err)
-	//		}
-	//		fmt.Println(">>>>>>>>>>>>>>>>>affected1<<<<<<<<<<<<<<<<<<<", affected1)
-	//		vv := new(model.CentralKitchenForSchoolUserWithDay)
-	//		_, err = db.Db.Where("id =?", v.RecordsId).Get(vv)
-	//		if err != nil {
-	//			fmt.Println(err)
-	//		}
-	//		vv.State = 2
-	//		affected11, err := db.Db.Where("id=?", vv.Id).Cols("state").Update(vv)
-	//		if err != nil {
-	//			fmt.Println(err)
+	//	if len(tmpList) > 0 {
+	//		for _, vv := range tmpList {
+	//			notIds[vv.Id] = true
+	//			utils.FilePutContents("test_test", utils.IntToStr(vv.Id))
 	//		}
-	//		fmt.Println(">>>>>>>>>>>>>>>>>affected11<<<<<<<<<<<<<<<<<<<", affected11)
-	//
-	//		//2、更改兑换记录
-	//		mm[0].OutRequestNo = v.OutRequestNo
-	//		mm[0].State = v.State
-	//		mm[0].RefundDate = v.RefundDate
-	//		mm[0].Memo = "exchange"
-	//		affected2, err := db.Db.Where("id=?", mm[0].Id).Cols("out_request_no", "state", "refund_date", "memo").Update(mm[0])
-	//		if err != nil {
-	//			fmt.Println(err)
-	//		}
-	//		fmt.Println(">>>>>>>>>>>>>>>>>affected2<<<<<<<<<<<<<<<<<<<", affected2)
-	//		mmm.State = 4
-	//		affected22, err := db.Db.Where("id=?", mmm.Id).Cols("state").Update(mmm)
-	//		if err != nil {
-	//			fmt.Println(err)
-	//		}
-	//		fmt.Println(">>>>>>>>>>>>>>>>>affected22<<<<<<<<<<<<<<<<<<<", affected22)
-	//
-	//		//}
-	//	} else {
-	//		notCanUserIds = append(notCanUserIds, v.Uid)
 	//	}
+	//	fmt.Println(v)
+	//}
+	//return
+}
+func main() {
+	//var list []model.CentralKitchenForSchoolPackageOrdForReserve
+	//if err := db.Db.Where("create_at >= '2024-09-01 15:00:00'").Desc("id").Find(&list); err != nil {
+	//	fmt.Println(err)
+	//}
+	////
+	//var ordIds = map[string]string{}
+	//for _, v := range list {
+	//	if ordIds[v.OutTradeNo+"_"+utils.AnyToString(v.Kind)+"_"+v.ReserveMonth] != "" {
+	//		continue
+	//	}
+	//	var tmpList []model.CentralKitchenForSchoolPackageOrdForReserve
+	//	if err := db.Db.Where("out_trade_no = ?", v.OutTradeNo).And("kind =?", v.Kind).And("reserve_month =?", v.ReserveMonth).
+	//		And("total_price =?", v.TotalPrice).Find(&tmpList); err != nil {
+	//		fmt.Println(err)
+	//	}
+	//	fmt.Println(v.OutTradeNo)
+	//	if len(tmpList) > 1 {
+	//		ordIds[v.OutTradeNo+"_"+utils.AnyToString(v.Kind)+"_"+v.ReserveMonth] = v.OutTradeNo
+	//		utils.FilePutContents("test_test_test", v.OutTradeNo)
+	//	}
+	//	//	v.RecordsId = -v.RecordsId
+	//	//	v.OutTradeNo = "-" + v.OutTradeNo
+	//	//	affected1, err := db.Db.Where("id=?", v.Id).Cols("records_id", "out_trade_no").Update(&v)
+	//	//	if err != nil {
+	//	//		fmt.Println(err)
+	//	//	}
+	//	//	fmt.Println(">>>>>>>>>>>>>>>>>affected1<<<<<<<<<<<<<<<<<<<", affected1)
+	//	//	continue
+	//	//	var mm []model.CentralKitchenForSchoolUserRefundDay
+	//	//	if err := db.Db.Where("uid = ?", v.Uid).And("state = 1").Desc("records_id").Find(&mm); err != nil {
+	//	//		fmt.Println(err)
+	//	//	}
+	//	//
+	//	//	if len(mm) > 0 {
+	//	//		mmm := new(model.CentralKitchenForSchoolUserWithDay)
+	//	//		_, err := db.Db.Where("id =?", mm[0].RecordsId).Get(mmm)
+	//	//		if err != nil {
+	//	//			fmt.Println(err)
+	//	//		}
+	//	//		//if mmm.Date == "2024-01-31" {
+	//	//		//1、更改当前记录
+	//	//		v.Uid = -v.Uid
+	//	//		affected1, err := db.Db.Where("id=?", v.Id).Cols("uid").Update(&v)
+	//	//		if err != nil {
+	//	//			fmt.Println(err)
+	//	//		}
+	//	//		fmt.Println(">>>>>>>>>>>>>>>>>affected1<<<<<<<<<<<<<<<<<<<", affected1)
+	//	//		vv := new(model.CentralKitchenForSchoolUserWithDay)
+	//	//		_, err = db.Db.Where("id =?", v.RecordsId).Get(vv)
+	//	//		if err != nil {
+	//	//			fmt.Println(err)
+	//	//		}
+	//	//		vv.State = 2
+	//	//		affected11, err := db.Db.Where("id=?", vv.Id).Cols("state").Update(vv)
+	//	//		if err != nil {
+	//	//			fmt.Println(err)
+	//	//		}
+	//	//		fmt.Println(">>>>>>>>>>>>>>>>>affected11<<<<<<<<<<<<<<<<<<<", affected11)
+	//	//
+	//	//		//2、更改兑换记录
+	//	//		mm[0].OutRequestNo = v.OutRequestNo
+	//	//		mm[0].State = v.State
+	//	//		mm[0].RefundDate = v.RefundDate
+	//	//		mm[0].Memo = "exchange"
+	//	//		affected2, err := db.Db.Where("id=?", mm[0].Id).Cols("out_request_no", "state", "refund_date", "memo").Update(mm[0])
+	//	//		if err != nil {
+	//	//			fmt.Println(err)
+	//	//		}
+	//	//		fmt.Println(">>>>>>>>>>>>>>>>>affected2<<<<<<<<<<<<<<<<<<<", affected2)
+	//	//		mmm.State = 4
+	//	//		affected22, err := db.Db.Where("id=?", mmm.Id).Cols("state").Update(mmm)
+	//	//		if err != nil {
+	//	//			fmt.Println(err)
+	//	//		}
+	//	//		fmt.Println(">>>>>>>>>>>>>>>>>affected22<<<<<<<<<<<<<<<<<<<", affected22)
+	//	//
+	//	//		//}
+	//	//	} else {
+	//	//		notCanUserIds = append(notCanUserIds, v.Uid)
+	//	//	}
 	//}
+	//return
+
 	r := router.Init() //创建路由
 
 	srv := &http.Server{ //设置http服务参数