From 3521286562c2a06b70cdea097c283e39e8dad4ff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 14 Jul 2023 16:22:28 +0800 Subject: [PATCH 1/8] 1 --- business/jxcallback/orderman/order.go | 1 + business/partner/delivery/rider.go | 5 +++++ 2 files changed, 6 insertions(+) diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index 7c2d02618..8f5f34930 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -392,6 +392,7 @@ func (c *OrderManager) SaveOrder(order *model.GoodsOrder, isAdjust bool, db *dao } _, _, err = db.Db.ReadOrCreate(originalOrder, "VendorOrderID", "VendorID") if created { + globals.SugarLogger.Debugf("==========order.Skus======== : %s", utils.Format4Output(order.Skus, false)) if err = dao.CreateMultiEntities(db, order.Skus); err != nil { baseapi.SugarLogger.Warnf("saveOrder orderID:%s, save order_sku failed with error:%v", order.VendorOrderID, err) } diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index fce32f597..76d07ea61 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -188,6 +188,11 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) { riderInfo.CourierName = "石锋" riderInfo.CourierPhone = "18048531223" } + + if riderInfo.OrderId == "" { + riderInfo.OrderId = v.VendorOrderID + } + if riderInfo.ThirdCarrierOrderId == "" { riderInfo.ThirdCarrierOrderId = riderInfo.OrderId + "_fake" } From a73ecfb86cb639afa58897d6c442c92261a0bc77 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 14 Jul 2023 17:07:59 +0800 Subject: [PATCH 2/8] 1 --- business/jxcallback/orderman/order.go | 1 - business/model/const.go | 4 ++-- business/partner/delivery/rider.go | 1 + business/partner/purchase/tao_vegetable/order.go | 6 +++--- 4 files changed, 6 insertions(+), 6 deletions(-) diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index 8f5f34930..7c2d02618 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -392,7 +392,6 @@ func (c *OrderManager) SaveOrder(order *model.GoodsOrder, isAdjust bool, db *dao } _, _, err = db.Db.ReadOrCreate(originalOrder, "VendorOrderID", "VendorID") if created { - globals.SugarLogger.Debugf("==========order.Skus======== : %s", utils.Format4Output(order.Skus, false)) if err = dao.CreateMultiEntities(db, order.Skus); err != nil { baseapi.SugarLogger.Warnf("saveOrder orderID:%s, save order_sku failed with error:%v", order.VendorOrderID, err) } diff --git a/business/model/const.go b/business/model/const.go index 96609bfad..2df65c8fc 100644 --- a/business/model/const.go +++ b/business/model/const.go @@ -387,8 +387,8 @@ const ( ) const ( - BusinessTypeImmediate = 1 // 立即达 - BusinessTypeDingshida = 2 // 定时达 + BusinessTypeImmediate = 1 // 定时单 + BusinessTypeDingshida = 2 // 预订单 ) const ( diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index 76d07ea61..b4612520b 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -191,6 +191,7 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) { if riderInfo.OrderId == "" { riderInfo.OrderId = v.VendorOrderID + riderInfo.LogisticsProviderCode = "10017" } if riderInfo.ThirdCarrierOrderId == "" { diff --git a/business/partner/purchase/tao_vegetable/order.go b/business/partner/purchase/tao_vegetable/order.go index e9bdd8173..67c80201d 100644 --- a/business/partner/purchase/tao_vegetable/order.go +++ b/business/partner/purchase/tao_vegetable/order.go @@ -171,10 +171,10 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve // 期望送达时间两小时内为立即达 earliestTime := utils.Str2Time(strings.Split(*orderDetail.ReceiveInfo.ExpectArriveTime, "~")[0]).Unix() if earliestTime-time.Now().Unix() > 2*60*60 { - order.BusinessType = model.BusinessTypeImmediate + order.BusinessType = model.BusinessTypeDingshida order.ExpectedDeliveredTime = getTimeFromTimestamp(earliestTime + 30*60) // 预计最晚送达时间 } else { // 定时达 - order.BusinessType = model.BusinessTypeDingshida + order.BusinessType = model.BusinessTypeImmediate order.ExpectedDeliveredTime = getTimeFromTimestamp(earliestTime + 30*60) // 预计最晚送达时间 } @@ -206,7 +206,7 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve order.OrderSeq = orderSeq + 1 // 包装袋金额 - store, _ := dao.GetStoreDetail(dao.GetDB(), order.JxStoreID, order.VendorID, order.VendorOrgCode) + store, _ := dao.GetStoreDetail2(dao.GetDB(), 0, order.VendorStoreID, model.VendorIDTaoVegetable) if store != nil { order.PackagePrice = int(*orderDetail.PackageFee) + store.PackageSetting } else { From 2909a9ae8d5b12b043d0d0093bd6376ecce9a017 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 14 Jul 2023 17:24:39 +0800 Subject: [PATCH 3/8] 1 --- business/partner/purchase/tao_vegetable/order.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/business/partner/purchase/tao_vegetable/order.go b/business/partner/purchase/tao_vegetable/order.go index 67c80201d..dd1378acc 100644 --- a/business/partner/purchase/tao_vegetable/order.go +++ b/business/partner/purchase/tao_vegetable/order.go @@ -206,13 +206,14 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve order.OrderSeq = orderSeq + 1 // 包装袋金额 - store, _ := dao.GetStoreDetail2(dao.GetDB(), 0, order.VendorStoreID, model.VendorIDTaoVegetable) + store, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), order.VendorOrderID, model.VendorIDTaoVegetable, order.VendorOrgCode) if store != nil { + order.StoreName = store.Name // 真实门店名称 order.PackagePrice = int(*orderDetail.PackageFee) + store.PackageSetting } else { order.PackagePrice = int(*orderDetail.PackageFee) + order.StoreName = "未获取到" // 真实门店名称 } - order.StoreName = store.Name // 真实门店名称 globals.SugarLogger.Debugf("=====order : %s", utils.Format4Output(order, false)) return order, orderMap, err From 35ca3a47ccf895896a0c522989edc0345047ea65 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 14 Jul 2023 17:46:44 +0800 Subject: [PATCH 4/8] 1 --- business/jxcallback/orderman/order.go | 2 +- business/model/dao/dao_order.go | 2 +- business/model/order.go | 2 +- business/partner/purchase/tao_vegetable/order.go | 2 +- business/partner/purchase/tiktok_store/order.go | 2 +- controllers/jx_order.go | 4 ++-- 6 files changed, 7 insertions(+), 7 deletions(-) diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index 7c2d02618..8299d38c9 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -868,7 +868,7 @@ func updateSingleOrderEarningPrice(order *model.GoodsOrder, db *dao.DaoDB) { if actStoreSku := actStoreSkuMap.GetActStoreSku(jxStoreID, skuID, order.VendorID); actStoreSku != nil { v.EarningPrice = actStoreSku.EarningPrice if true { //v.StoreSubName != "" { // 之前这里为什么要加判断？ - v.StoreSubID = actStoreSku.ActID + v.StoreSubID = int64(actStoreSku.ActID) } } } diff --git a/business/model/dao/dao_order.go b/business/model/dao/dao_order.go index 637b4e99c..3a3a276ff 100644 --- a/business/model/dao/dao_order.go +++ b/business/model/dao/dao_order.go @@ -144,7 +144,7 @@ func QueryOrders(db *DaoDB, vendorOrderID string, actID int, vendorIDs []int, st ID: v.OrderSkuID, VendorOrderID: v.VendorOrderID, VendorID: v.VendorID, - StoreSubID: v.StoreSubID, + StoreSubID: int64(v.StoreSubID), StoreSubName: v.StoreSubName, Count: v.Count, VendorSkuID: v.VendorSkuID, diff --git a/business/model/order.go b/business/model/order.go index 8997a5041..44ad263d6 100644 --- a/business/model/order.go +++ b/business/model/order.go @@ -196,7 +196,7 @@ type OrderSku struct { VendorOrderID string `orm:"column(vendor_order_id);size(48)" json:"vendorOrderID"` VendorSubOrderID string `orm:"column(vendor_sub_order_id);size(48)" json:"vendorSubOrderID"` // 子订单id VendorID int `orm:"column(vendor_id)" json:"vendorID"` - StoreSubID int `orm:"column(store_sub_id)" json:"storeSubID"` // EarningActID，当前这个字段被当成结算活动ID用 + StoreSubID int64 `orm:"column(store_sub_id)" json:"storeSubID"` // EarningActID，当前这个字段被当成结算活动ID用 StoreSubName string `orm:"size(64)" json:"storeSubName"` // 当前这个字段被用作vendorActType Count int `json:"count"` VendorSkuID string `orm:"column(vendor_sku_id);size(48)" json:"vendorSkuID"` diff --git a/business/partner/purchase/tao_vegetable/order.go b/business/partner/purchase/tao_vegetable/order.go index dd1378acc..a171c4af6 100644 --- a/business/partner/purchase/tao_vegetable/order.go +++ b/business/partner/purchase/tao_vegetable/order.go @@ -148,7 +148,7 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve } if len(activityId) > 0 { - sku.StoreSubID = int(activityId[0]) + sku.StoreSubID = activityId[0] sku.StoreSubName = strings.Join(activityName, ",") } if sku.Weight == 0 { diff --git a/business/partner/purchase/tiktok_store/order.go b/business/partner/purchase/tiktok_store/order.go index 82a0d6653..eea07f2aa 100644 --- a/business/partner/purchase/tiktok_store/order.go +++ b/business/partner/purchase/tiktok_store/order.go @@ -162,7 +162,7 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode, vendorOrderID, vendorStoreID s activityName = append(activityName, utils.Int64ToStr(v.CampaignId)+":"+v.CampaignName) } if len(activityId) > 0 { - sku.StoreSubID = int(activityId[0]) + sku.StoreSubID = activityId[0] sku.StoreSubName = strings.Join(activityName, ",") } if sku.Weight == 0 { diff --git a/controllers/jx_order.go b/controllers/jx_order.go index 664e86d5e..652d05250 100644 --- a/controllers/jx_order.go +++ b/controllers/jx_order.go @@ -571,7 +571,7 @@ func skuList2Map(skuList []*model.OrderSku) (skuCount int, skuMap map[int64]*mod skuCount += sku.Count skuID := jxutils.GetSkuIDFromOrderSku(sku) if sku.SkuID > 0 { - index := jxutils.Combine2Int(skuID, sku.StoreSubID) + index := jxutils.Combine2Int(skuID, int(sku.StoreSubID)) if skuMap[index] == nil { tmpSku := *sku skuMap[index] = &tmpSku @@ -901,7 +901,7 @@ func fillSkuList(skuList, orderSkuList []*model.OrderSku) (isSame bool, err erro skuCount2 += sku.Count skuID := jxutils.GetSkuIDFromOrderSku(sku) actID := sku.StoreSubID - sku2 := getSkuFromMap(orderSkuMap, skuID, actID) + sku2 := getSkuFromMap(orderSkuMap, skuID, int(actID)) if sku2 == nil { err = fmt.Errorf("找不到SKU:%d", skuID) } else if sku.Count > sku2.Count { From 7d5837f570518ffd3f4f42e2e2e05229ee890484 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 14 Jul 2023 18:36:35 +0800 Subject: [PATCH 5/8] 1 --- .../partner/purchase/tao_vegetable/order.go | 2 +- controllers/act.go | 24 +++++++++---------- routers/commentsRouter_controllers.go | 16 ++++++------- 3 files changed, 21 insertions(+), 21 deletions(-) diff --git a/business/partner/purchase/tao_vegetable/order.go b/business/partner/purchase/tao_vegetable/order.go index a171c4af6..760c35459 100644 --- a/business/partner/purchase/tao_vegetable/order.go +++ b/business/partner/purchase/tao_vegetable/order.go @@ -206,7 +206,7 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve order.OrderSeq = orderSeq + 1 // 包装袋金额 - store, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), order.VendorOrderID, model.VendorIDTaoVegetable, order.VendorOrgCode) + store, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), order.VendorStoreID, model.VendorIDTaoVegetable, order.VendorOrgCode) if store != nil { order.StoreName = store.Name // 真实门店名称 order.PackagePrice = int(*orderDetail.PackageFee) + store.PackageSetting diff --git a/controllers/act.go b/controllers/act.go index 78b05aec3..ad3f93222 100644 --- a/controllers/act.go +++ b/controllers/act.go @@ -486,18 +486,18 @@ func (c *ActController) GetNotHaveSkuActList() { }) } -//// @Title 查询美团平台活动 -//// @Description 查询美团平台活动 -//// @Param token header string true "认证token" -//// @Success 200 {object} controllers.CallResult -//// @Failure 200 {object} controllers.CallResult -//// @router /RefreshMTActivityList [get] -//func (c *ActController) RefreshMTActivityList() { -// c.callRefreshMTActivityList(func(params *tActRefreshMTActivityListParams) (retVal interface{}, errCode string, err error) { -// err = act.RrefreshMtwmVendorAct(params.Ctx) -// return retVal, "", err -// }) -//} +// @Title 查询美团平台活动 +// @Description 查询美团平台活动 +// @Param token header string true "认证token" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /RefreshMTActivityList [get] +func (c *ActController) RefreshMTActivityList() { + c.callRefreshMTActivityList(func(params *tActRefreshMTActivityListParams) (retVal interface{}, errCode string, err error) { + err = act.RrefreshMtwmVendorAct(params.Ctx) + return retVal, "", err + }) +} // @Title 查询美团平台活动sku // @Description 查询美团平台活动sku diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index 208c07b5e..b59d985b8 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -114,14 +114,14 @@ func init() { Filters: nil, Params: nil}) - //web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ActController"] = append(web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ActController"], - // web.ControllerComments{ - // Method: "/RefreshMTActivityList", - // Router: `/RefreshMTActivityList`, - // AllowHTTPMethods: []string{"get"}, - // MethodParams: param.Make(), - // Filters: nil, - // Params: nil}) + web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ActController"] = append(web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ActController"], + web.ControllerComments{ + Method: "RefreshMTActivityList", + Router: `/RefreshMTActivityList`, + AllowHTTPMethods: []string{"get"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ActController"] = append(web.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ActController"], web.ControllerComments{ From 6c4fd0a9724969d915dbaad44530781766a458cc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Sun, 16 Jul 2023 19:59:02 +0800 Subject: [PATCH 6/8] 1 --- business/partner/delivery/mtps/waybill.go | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/business/partner/delivery/mtps/waybill.go b/business/partner/delivery/mtps/waybill.go index 045a1ce83..1fefc3b46 100644 --- a/business/partner/delivery/mtps/waybill.go +++ b/business/partner/delivery/mtps/waybill.go @@ -89,6 +89,11 @@ func (c *DeliveryHandler) OnWaybillExcept(msg *mtpsapi.CallbackOrderExceptionMsg func (c *DeliveryHandler) onWaybillMsg(msg *mtpsapi.CallbackOrderMsg) (retVal *mtpsapi.CallbackResponse) { order, goodsOrder := c.callbackMsg2Waybill(msg) + //查不到订单可能就是果园的订单 + if goodsOrder == nil && beego.BConfig.RunMode != "jxgy" { + c.pushToGy(msg) + return mtpsapi.SuccessResponse + } // 多次取消,只处理第一次 if msg.Status == mtpsapi.OrderStatusCanceled { orderStatus, _ := orderman.FixedOrderManager.GetWayBillStatusList(msg.OrderID, msg.MtPeisongID, model.VendorIDMTPS) @@ -133,13 +138,6 @@ func (c *DeliveryHandler) onWaybillMsg(msg *mtpsapi.CallbackOrderMsg) (retVal *m return mtpsapi.SuccessResponse } - order2, _ := partner.CurOrderManager.LoadOrder(order.VendorOrderID, order.OrderVendorID) - //查不到订单可能就是果园的订单 - if order2 == nil && beego.BConfig.RunMode != "jxgy" { - c.pushToGy(msg) - return mtpsapi.SuccessResponse - } - // 加入调度器 err := mtpsapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus) switch order.OrderVendorID { From 0cce5309df7bedeb2aa5860c7436e22b5eeb1870 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Mon, 17 Jul 2023 08:53:42 +0800 Subject: [PATCH 7/8] 1 --- controllers/mtps_order.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/controllers/mtps_order.go b/controllers/mtps_order.go index 9dc7cee5d..c8e7dee8c 100644 --- a/controllers/mtps_order.go +++ b/controllers/mtps_order.go @@ -1,6 +1,8 @@ package controllers import ( + "git.rosy.net.cn/baseapi/utils" + "git.rosy.net.cn/jx-callback/globals" "net/http" "git.rosy.net.cn/jx-callback/business/partner/delivery/mtps" @@ -21,6 +23,7 @@ func (c *MtpsController) Status() { } obj, callbackResponse := api.MtpsAPI.GetOrderCallbackMsg(c.Ctx.Request) + globals.SugarLogger.Debugf("==========obj := %s", utils.Format4Output(obj, false)) if callbackResponse == nil { callbackResponse = mtps.OnWaybillMsg(obj) } From 6c41b23ccbd8fb59bd4c7ceca0a22ef3af617de1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Mon, 17 Jul 2023 09:17:29 +0800 Subject: [PATCH 8/8] 1 --- business/partner/delivery/rider.go | 4 ++++ controllers/mtps_order.go | 3 --- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index b4612520b..fa963d83e 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -96,6 +96,10 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) { continue } + if (v.WaybillVendorID == model.YES || v.WaybillVendorID == -1) && v.VendorID == model.VendorIDMTWM { + continue + } + if orderId == "" { // 订单id为空是,是定时轮询操作,不做此状态 waybillList, _ := dao.GetWaybills(dao.GetDB(), v.VendorOrderID, nil) if len(waybillList) > 0 && waybillList[0].Status > model.WaybillStatusEndBegin { diff --git a/controllers/mtps_order.go b/controllers/mtps_order.go index c8e7dee8c..9dc7cee5d 100644 --- a/controllers/mtps_order.go +++ b/controllers/mtps_order.go @@ -1,8 +1,6 @@ package controllers import ( - "git.rosy.net.cn/baseapi/utils" - "git.rosy.net.cn/jx-callback/globals" "net/http" "git.rosy.net.cn/jx-callback/business/partner/delivery/mtps" @@ -23,7 +21,6 @@ func (c *MtpsController) Status() { } obj, callbackResponse := api.MtpsAPI.GetOrderCallbackMsg(c.Ctx.Request) - globals.SugarLogger.Debugf("==========obj := %s", utils.Format4Output(obj, false)) if callbackResponse == nil { callbackResponse = mtps.OnWaybillMsg(obj) }