From 2c1d662a089de8303e88889c645d79f600b352a3 Mon Sep 17 00:00:00 2001 From: dengbiao Date: Tue, 3 Sep 2024 21:46:51 +0800 Subject: [PATCH] update --- .../svc_central_kitchen_for_school_order.go | 26 +-- main.go | 160 +++++++++++------- 2 files changed, 113 insertions(+), 73 deletions(-) diff --git a/app/admin/svc/order/svc_central_kitchen_for_school_order.go b/app/admin/svc/order/svc_central_kitchen_for_school_order.go index ab6e8b3..5175e29 100644 --- a/app/admin/svc/order/svc_central_kitchen_for_school_order.go +++ b/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::处理订单状态 diff --git a/main.go b/main.go index 5e690a7..d1d3984 100644 --- a/main.go +++ b/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服务参数