diff --git a/business/jxcallback/orderman/waybill.go b/business/jxcallback/orderman/waybill.go index 6988ab3aa..b1c11f057 100644 --- a/business/jxcallback/orderman/waybill.go +++ b/business/jxcallback/orderman/waybill.go @@ -260,11 +260,11 @@ func ComplaintRider(ctx *jxcontext.Context, vendorOrderID string, waybillVendorI if len(wayBillList) != model.YES { return fmt.Errorf("订单所属运单不存在,或运单为分配骑手,无法投诉") } - p := partner.GetDeliveryPlatformFromVendorID(wayBillList[0].WaybillVendorID).Handler if err == nil && len(wayBillList) > 0 { for _, v := range wayBillList { if utils.Int2Str(v.WaybillVendorID) == waybillVendorID { - err = p.ComplaintRider(wayBillList[0], complaintID, complaintReasonsMap[complaintID]) + p := partner.GetDeliveryPlatformFromVendorID(wayBillList[0].WaybillVendorID).Handler + err = p.ComplaintRider(v, complaintID, complaintReasonsMap[complaintID]) } } } diff --git a/business/jxcallback/scheduler/basesch/basesch.go b/business/jxcallback/scheduler/basesch/basesch.go index 18e3f02f0..31fb0718e 100644 --- a/business/jxcallback/scheduler/basesch/basesch.go +++ b/business/jxcallback/scheduler/basesch/basesch.go @@ -142,7 +142,7 @@ func (c *BaseScheduler) SelfDeliverDelivering(order *model.GoodsOrder, userName localBill, _ := partner.CurOrderManager.LoadWaybill(order.VendorWaybillID, order.WaybillVendorID) // 获取抖音配送状态 tiktokWayBillStatus, _ := partner.GetPurchasePlatformFromVendorID(order.VendorID).OrderLogisticsStatus(order.VendorOrderID) - if tiktokWayBillStatus != nil && tiktokWayBillStatus.LogisticsStatus >= tiktokShop.ShipmentStatusReceived { + if tiktokWayBillStatus != nil && tiktokWayBillStatus.LogisticsStatus >= tiktokShop.ShipmentStatusReceived && tiktokWayBillStatus.LogisticsStatus != tiktokShop.ShipmentStatusCanceled { //取消抖音配送转自送 err = c.CancelWaybill(localBill, partner.CancelWaybillReasonDYPSCancel, partner.CancelWaybillReasonStrDYPSCancel+"抖音骑手已经接单,无法取消") partner.CurOrderManager.OnOrderMsg(order, "取消抖音配送,转用门店自配送/三方配送", "抖音骑手已经接单,无法取消") diff --git a/business/jxcallback/scheduler/defsch/defsch_afs.go b/business/jxcallback/scheduler/defsch/defsch_afs.go index 4a7e855b3..b1ac9bf6b 100644 --- a/business/jxcallback/scheduler/defsch/defsch_afs.go +++ b/business/jxcallback/scheduler/defsch/defsch_afs.go @@ -48,7 +48,7 @@ func (s *DefScheduler) OnAfsOrderNew(order *model.AfsOrder, isPending bool) (err // 京西云打印机打印数据-如果门店使用京西打印机才使用如下代码块 store, err := dao.GetStoreDetail(dao.GetDB(), order.JxStoreID, order.VendorID, order.VendorOrgCode) - if err == nil && store.PrinterVendorID == model.VendorIDJxprint { + if err == nil && store.PrinterVendorID == model.VendorIDJxprint && store.IsPrintCancelOrder == model.YES { if handler := partner.GetPurchaseOrderHandlerFromVendorID(order.VendorID); handler != nil { orderObj, err2 := handler.GetOrder(order.VendorOrgCode, order.VendorOrderID, "") if err2 != nil { diff --git a/business/jxcallback/scheduler/defsch/defsch_ext.go b/business/jxcallback/scheduler/defsch/defsch_ext.go index c3e7bf2c3..4f49188c6 100644 --- a/business/jxcallback/scheduler/defsch/defsch_ext.go +++ b/business/jxcallback/scheduler/defsch/defsch_ext.go @@ -470,7 +470,6 @@ func (s *DefScheduler) QueryOrderWaybillFeeInfoEx(ctx *jxcontext.Context, vendor if order.DeliveryType == model.OrderDeliveryTypeSelfTake { return nil, fmt.Errorf("订单:%s是自提单", vendorOrderID) } - // 获取用户送货地址 storeCourierList, err := dao.GetStoreCourierList(db, []int{jxutils.GetSaleStoreIDFromOrder(order)}, nil, model.StoreStatusAll, model.StoreAuditStatusOnline) if err != nil { @@ -508,7 +507,8 @@ func (s *DefScheduler) QueryOrderWaybillFeeInfoEx(ctx *jxcontext.Context, vendor if handler := partner.GetDeliveryPlatformFromVendorID(storeCourier.VendorID); handler != nil { if handler.Use4CreateWaybill { // 获取订单配送费用 - if feeInfo, err = handler.Handler.GetWaybillFee(order); err != nil { + feeInfo, err = handler.Handler.GetWaybillFee(order) + if err != nil { feeInfo = &partner.WaybillFeeInfo{ ErrCode: partner.WaybillFeeErrCodeCourierOthers, ErrStr: err.Error(), diff --git a/business/jxstore/cms/cms.go b/business/jxstore/cms/cms.go index 631c3480c..0b4a7515e 100644 --- a/business/jxstore/cms/cms.go +++ b/business/jxstore/cms/cms.go @@ -5,6 +5,7 @@ import ( "fmt" "git.rosy.net.cn/baseapi/platformapi/autonavi" "git.rosy.net.cn/baseapi/platformapi/baidunavi" + "git.rosy.net.cn/jx-callback/globals" "math" "reflect" "regexp" @@ -681,6 +682,7 @@ func GetSToURidingDistance2(sLng, sLat, uLng, uLat float64, orderId string) (way } } } + globals.SugarLogger.Debugf("=======================1") // 当这个运单为假物流/门店真实自送/获取运单骑手信息为空的时候使用假的骑手信息 if (v.WaybillVendorID == model.VendorJXFakeWL || v.WaybillVendorID == model.VendorIDUnknown || v.CourierCoordinate == "") && v.OriginalData != "" { @@ -750,26 +752,5 @@ func GetCyclingLine(sLng, sLat, uLng, uLat float64) (polyLineList []string, dist polyLineList = append(polyLineList, strings.Split(v.Path, ";")...) } - // 高德()免费次数太少暂时不用 - //for { - // polyLineList, distance, duration, errCode = api.AutonaviAPI.GetCyclingPlan(origin, destination) - // if errCode != nil { - // ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "获取骑行路线:", utils.Format4Output(errCode, false)) - // } - // if errCode != nil && (errCode.Error() == autonavi.DAILYQUERYOVERLIMIT || errCode.Error() == autonavi.USERDAILYQUERYOVERLIMIT) { - // AutonaviKeyIndex += model.YES - // if AutonaviKeyIndex >= len(AutonaviKeyList) { - // AutonaviKeyIndex = model.NO - // } - // api.AutonaviAPI.SetKey(AutonaviKeyList[AutonaviKeyIndex]) - // } else if errCode != nil { - // return nil, 0, 0, errCode - // } - // - // if len(polyLineList) > model.NO { - // return polyLineList, distance, duration, errCode - // } - //} - return } diff --git a/business/jxstore/cms/system_store_sku.go b/business/jxstore/cms/system_store_sku.go index 967969027..1e5fee079 100644 --- a/business/jxstore/cms/system_store_sku.go +++ b/business/jxstore/cms/system_store_sku.go @@ -4,6 +4,7 @@ import ( "encoding/json" "fmt" "git.rosy.net.cn/jx-callback/globals" + beego "github.com/astaxie/beego/server/web" "time" "git.rosy.net.cn/baseapi/platformapi/mtwmapi" @@ -12,7 +13,6 @@ import ( "git.rosy.net.cn/jx-callback/business/jxutils/tasksch" "git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model/dao" - "git.rosy.net.cn/jx-callback/business/partner" ) // CopyOnStoreSkuToOther 将一个美团门店分类和商品复制到另一个门店 @@ -26,15 +26,18 @@ func CopyOnStoreSkuToOther(ctx *jxcontext.Context, fromVendorStoreId, toStoreId if err != nil { return "", err } - toApi := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, toStore.VendorOrgCode).(*mtwmapi.API) + //firstApi := api.Mtwm2API + toApi := mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "") toApi.SetToken(toStore.MtwmToken) fromStore, err := dao.GetStoreDetailByVendorStoreID(db, utils.Int2Str(fromVendorStoreId), model.VendorIDMTWM, "") if err != nil { return "", err } - fromApi := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API) + fromApi := mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "") fromApi.SetToken(fromStore.MtwmToken) + //fromApi := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, fromStore.VendorOrgCode).(*mtwmapi.API) + //fromApi.SetToken(fromStore.MtwmToken) taskName := fmt.Sprintf("将平台门店[%d],分类和商品复制到[%d]", fromVendorStoreId, toStoreId) config := tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(false) @@ -49,8 +52,9 @@ func CopyOnStoreSkuToOther(ctx *jxcontext.Context, fromVendorStoreId, toStoreId //} case 2: // 同步分类 - //fromCategoryList, _ := fromApi.RetailCatList(utils.Int2Str(fromVendorStoreId)) - // + //fromCategoryList, err := fromApi.RetailCatList(utils.Int2Str(fromVendorStoreId)) + //globals.SugarLogger.Debugf("fromCategoryList ============ %d", len(fromCategoryList)) + //globals.SugarLogger.Debugf("err ============ %v", err) //for _, v := range fromCategoryList { // categoryErr := toApi.RetailCatUpdate(toStore.VendorStoreID, v.Name, &mtwmapi.Param4UpdateCat{ // CategoryCode: v.Code, @@ -84,7 +88,7 @@ func CopyOnStoreSkuToOther(ctx *jxcontext.Context, fromVendorStoreId, toStoreId return nil, fmt.Errorf("fromFoodList 为空 %s ,i:= %d", utils.Format4Output(err1, false), i) } - if err := BatchInitData(ctx, fromFoodList, toApi, toStore.VendorStoreID); err != nil { + if err := BatchInitData(ctx, fromFoodList, toApi, toStore.VendorStoreID, i); err != nil { globals.SugarLogger.Debugf("BatchInitData : %s", utils.Format4Output(err, false)) } if len(fromFoodList) < 100 { @@ -158,7 +162,7 @@ type Skus struct { } // BatchInitData 批量创建商品 -func BatchInitData(ctx *jxcontext.Context, fromSku []*mtwmapi.AppFood, toApi *mtwmapi.API, vendorStoreID string) error { +func BatchInitData(ctx *jxcontext.Context, fromSku []*mtwmapi.AppFood, toApi *mtwmapi.API, vendorStoreID string, i int) error { foodDataList := make([]map[string]interface{}, len(fromSku)) for i, storeSku := range fromSku { foodData := make(map[string]interface{}) @@ -238,7 +242,7 @@ func BatchInitData(ctx *jxcontext.Context, fromSku []*mtwmapi.AppFood, toApi *mt if i == count-1 { failedFoodList, err2 := toApi.RetailBatchInitData(ctx.GetTrackInfo(), vendorStoreID, foodDataList[i*10:]) if err2 != nil { - globals.SugarLogger.Debugf("RetailBatchInitData err3 :%s", utils.Format4Output(err2, false)) + globals.SugarLogger.Debugf("RetailBatchInitData err3 :%v", err2) } if len(failedFoodList) != 0 { globals.SugarLogger.Debugf("RetailBatchInitData err4 :%s", utils.Format4Output(failedFoodList, false)) @@ -246,7 +250,7 @@ func BatchInitData(ctx *jxcontext.Context, fromSku []*mtwmapi.AppFood, toApi *mt } else { failedFoodList, err2 := toApi.RetailBatchInitData(ctx.GetTrackInfo(), vendorStoreID, foodDataList[i*10:(i+1)*10]) if err2 != nil { - globals.SugarLogger.Debugf("RetailBatchInitData err3 :%s", utils.Format4Output(err2, false)) + globals.SugarLogger.Debugf("RetailBatchInitData err3 :%v", err2) } if len(failedFoodList) != 0 { globals.SugarLogger.Debugf("RetailBatchInitData err4 :%s", utils.Format4Output(failedFoodList, false)) diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 0935c3b33..937c1c586 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -2,7 +2,6 @@ package misc import ( "fmt" - "git.rosy.net.cn/jx-callback/business/jxcallback/auto_delivery" "sync" "time" @@ -217,10 +216,10 @@ func Init() { }, 10*time.Second, 5*time.Minute) // (自动发单拣货,设置骑手) 刷单用 - ScheduleTimerFuncByInterval(func() { - auto_delivery.Init() // 初始化骑手列表 - auto_delivery.AutoSettingFakeDelivery() - }, 10*time.Second, 5*time.Minute) + //ScheduleTimerFuncByInterval(func() { + // auto_delivery.Init() // 初始化骑手列表 + // auto_delivery.AutoSettingFakeDelivery() + //}, 10*time.Second, 5*time.Minute) // 定时任务更新负责人信息 ScheduleTimerFunc("RefreshStoreOperator", func() { diff --git a/business/jxutils/enterprise_msg/enterprise_send_msg.go b/business/jxutils/enterprise_msg/enterprise_send_msg.go index 9e7da1b83..a72db5006 100644 --- a/business/jxutils/enterprise_msg/enterprise_send_msg.go +++ b/business/jxutils/enterprise_msg/enterprise_send_msg.go @@ -19,12 +19,12 @@ var enterpriseUserIdMap = map[string]string{ "18981810340": "LiuLei", "187447 76542": "WuTingQi", "17358644830": "ShengTianBanZi1376", - "15729837802": "ZhangShuWei", "1": "2f43b42fd833d1e77420a8dae7419000", // 未设置号码 "15928865396": "HeJiaMeng2", "18780171617": "TianQinXin", "17381914617": "TianQinXin2", "15881105234": "WenShiQi", + "17342535201": "XuXiaox", } // SendUserMessage 发送文本卡片 diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index 11f9107d3..126c72d9f 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -106,7 +106,6 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) { if orderId == "" { // 订单id为空是,是定时轮询操作,不做此状态 waybillList, _ := dao.GetWaybills(dao.GetDB(), v.VendorOrderID, nil) if len(waybillList) > 0 && waybillList[0].Status > model.WaybillStatusEndBegin { - globals.SugarLogger.Debug("订单物流状态结束,不在推送订单状态:orderID[%s],wayBillId[%s]", v.VendorOrderID, waybillList[0].VendorWaybillID) continue } } @@ -330,6 +329,7 @@ func makeRiderInfo(fakeWayBill *model.Waybill, riderInfo *utils.RiderInfo) { if err != nil { ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "百度地图骑行方案获取错误:", utils.Format4Output(err.Error(), false)) } + courierCoordinate := strings.Split(waybill2.CourierCoordinate, ",") if len(courierCoordinate) < 2 && fakeWayBill.Status < model.WaybillStatusDelivered { courierCoordinate = append(courierCoordinate, utils.Float64ToStr(jxutils.IntCoordinate2Standard(storeDetail.Lng)), utils.Float64ToStr(jxutils.IntCoordinate2Standard(storeDetail.Lat))) @@ -400,6 +400,7 @@ func UpdateFakeWayBillToTiktok() { //if randTimeSchedule > 500 { // return //} + globals.SugarLogger.Debugf("===================fakeWayBill := %s", "开始") fakeWayBill, err := dao.GetWayBillFakeOrder() if err != nil { @@ -416,6 +417,7 @@ func UpdateFakeWayBillToTiktok() { continue } + globals.SugarLogger.Debugf("===================fakeWayBill := %s", fakeWayBill[i].VendorOrderID) riderInfo := &utils.RiderInfo{ OrderId: fakeWayBill[i].VendorOrderID, ThirdCarrierOrderId: fakeWayBill[i].VendorOrderID, @@ -427,6 +429,7 @@ func UpdateFakeWayBillToTiktok() { // 设置骑手和下一状态时间 makeRiderInfo(fakeWayBill[i], riderInfo) + globals.SugarLogger.Debugf("===================makeRiderInfo := %s", utils.Format4Output(fakeWayBill[i], false)) if riderInfo.CourierName == "" && fakeWayBill[i].CourierName != "" { riderInfo.CourierName = fakeWayBill[i].CourierName riderInfo.CourierPhone = fakeWayBill[i].CourierMobile @@ -444,6 +447,7 @@ func UpdateFakeWayBillToTiktok() { handler := partner.GetPurchaseOrderHandlerFromVendorID(fakeWayBill[i].OrderVendorID) if handler != nil { order, _ := partner.CurOrderManager.LoadOrder(fakeWayBill[i].VendorOrderID, fakeWayBill[i].OrderVendorID) + globals.SugarLogger.Debugf("===================paramsMap := %s", utils.Format4Output(paramsMap, false)) if err := handler.GetOrderRider(fakeWayBill[i].VendorOrgCode, order.VendorStoreID, paramsMap); err != nil { partner.CurOrderManager.OnOrderMsg(order, tao_vegetable.OrderStatusDelivery, fmt.Sprintf("Fake Pull Rider Info Err :%s--%s--%v", riderInfo.OrderId, riderInfo.ThirdCarrierOrderId, err)) } else { diff --git a/business/partner/im/im.go b/business/partner/im/im.go index 4ff6ce02a..599766d75 100644 --- a/business/partner/im/im.go +++ b/business/partner/im/im.go @@ -5,6 +5,8 @@ import ( "encoding/json" "errors" "fmt" + "git.rosy.net.cn/baseapi/platformapi/dingdingapi" + "git.rosy.net.cn/jx-callback/business/jxutils/ddmsg" "strings" "time" @@ -175,6 +177,7 @@ func ReadMsgFromVendor(vendorID int, elmAppID string, msg []byte) error { //3 cid推送新消息 if err = PushMsgByCid(vendorStoreID, vendorID, string(msg)); err != nil { errList.AddErr(fmt.Errorf("向商家cid推送新消息错误:%v", err)) + ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "向商家cid推送新消息错误: ", err.Error()) } if errList.GetErrListAsOne() != nil { diff --git a/business/partner/purchase/ebai/waybill.go b/business/partner/purchase/ebai/waybill.go index 5b7569e4e..cd8969ada 100644 --- a/business/partner/purchase/ebai/waybill.go +++ b/business/partner/purchase/ebai/waybill.go @@ -5,7 +5,6 @@ import ( "git.rosy.net.cn/baseapi/platformapi/ebaiapi" "git.rosy.net.cn/baseapi/utils" - "git.rosy.net.cn/jx-callback/business/jxcallback/scheduler" "git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/partner" "git.rosy.net.cn/jx-callback/globals/api" @@ -49,15 +48,15 @@ func (c *PurchaseHandler) onWaybillMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaiap order.CourierMobile = utils.Interface2String(result["phone"]) } - if order.Status == model.WaybillStatusNew { - order2, _ := partner.CurOrderManager.LoadOrder(order.VendorOrderID, order.WaybillVendorID) - if order2 != nil { - if order2.Status == model.OrderStatusWaitAccepted { - order2.Status = model.OrderStatusNew - scheduler.CurrentScheduler.OnOrderNew(order2, false, false) - } - } - } + //if order.Status == model.WaybillStatusNew { + // order2, _ := partner.CurOrderManager.LoadOrder(order.VendorOrderID, order.WaybillVendorID) + // if order2 != nil { + // if order2.Status == model.OrderStatusWaitAccepted { + // order2.Status = model.OrderStatusNew + // scheduler.CurrentScheduler.OnOrderNew(order2, false, false) + // } + // } + //} } else if order.Status == model.WaybillStatusCanceled { utils.AfterFuncWithRecover(timeout4WaybillCancel, func() { if localOrder, err2 := partner.CurOrderManager.LoadOrder(order.VendorOrderID, model.VendorIDEBAI); err2 == nil { diff --git a/business/partner/purchase/tao_vegetable/callback.go b/business/partner/purchase/tao_vegetable/callback.go index 9d8c09894..6beb0cc26 100644 --- a/business/partner/purchase/tao_vegetable/callback.go +++ b/business/partner/purchase/tao_vegetable/callback.go @@ -13,7 +13,7 @@ import ( // OnCallbackMsg 淘宝回调接口 func OnCallbackMsg(orderStatus, orderId string, msg interface{}) (response *tao_vegetable.CallBackResult) { if CurPurchaseHandler != nil { - jxutils.CallMsgHandler(func() { + jxutils.CallMsgHandlerAsync(func() { response = CurPurchaseHandler.onOrderMsg(orderStatus, orderId, msg) }, jxutils.ComposeUniversalOrderID(orderId, model.VendorIDTaoVegetable)) } diff --git a/business/partner/purchase/tao_vegetable/order.go b/business/partner/purchase/tao_vegetable/order.go index bcf555b8a..9c5daf53f 100644 --- a/business/partner/purchase/tao_vegetable/order.go +++ b/business/partner/purchase/tao_vegetable/order.go @@ -112,8 +112,8 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve StoreSubName: "", Count: utils.Float64TwoInt(*extra.BuySaleQuantity), VendorSkuID: *extra.SkuCode, - SkuID: utils.Str2Int(*extra.SkuCode), - JxSkuID: utils.Str2Int(*extra.SkuCode), + SkuID: 0, + JxSkuID: 0, SkuName: *extra.SkuName, ShopPrice: *extra.Price, VendorPrice: *extra.OriginalFee / utils.Float64TwoInt64(*extra.BuySaleQuantity), @@ -126,7 +126,11 @@ func (p *PurchaseHandler) getOrder(vendorOrgCode string, vendorOrderID int64, ve IsVendorAct: 0, Upc: *extra.Barcode, } - + // extra.SkuCode 为int类型会超出长度,有时商品为平台创建 + if len(*extra.SkuCode) <= 10 { + sku.SkuID = utils.Str2Int(*extra.SkuCode) + sku.JxSkuID = utils.Str2Int(*extra.SkuCode) + } activityId := make([]int64, 0) activityName := make([]string, 0) if extra.Activitys != nil { diff --git a/business/partner/purchase/tiktok_store/order.go b/business/partner/purchase/tiktok_store/order.go index b83d692e8..904bee2c5 100644 --- a/business/partner/purchase/tiktok_store/order.go +++ b/business/partner/purchase/tiktok_store/order.go @@ -581,7 +581,7 @@ func (c *PurchaseHandler) Swtich2SelfDeliver(order *model.GoodsOrder, userName s if err2 != nil { return err2 } - if remoteWaybill.ShipmentStatus >= tiktokShop.ShipmentStatusArrived { //骑手取货后不可取消 + if remoteWaybill.ShipmentStatus >= tiktokShop.ShipmentStatusArrived && remoteWaybill.ShipmentStatus != tiktokShop.ShipmentStatusCanceled { //骑手取货后不可取消 return errors.New("抖音配送骑手已取货,不可转门店自配送/三方配送") } if len(remoteWaybill.TrackNo) != 0 { //存在运单 diff --git a/controllers/mtwm_callback.go b/controllers/mtwm_callback.go index 9047edbd5..aabaf8b9e 100644 --- a/controllers/mtwm_callback.go +++ b/controllers/mtwm_callback.go @@ -20,7 +20,9 @@ func (c *MtwmController) onCallbackMsg(msgType string) { callbackResponse = mtwmapi.Err2CallbackResponse(nil, "") } } - c.Data["json"] = callbackResponse + c.Data["json"] = mtwmapi.Err2CallbackResponse(nil, "") + + //c.Data["json"] = callbackResponse c.ServeJSON() } diff --git a/controllers/taobao_vegetable.go b/controllers/taobao_vegetable.go index ac503eacb..809e586c2 100644 --- a/controllers/taobao_vegetable.go +++ b/controllers/taobao_vegetable.go @@ -46,7 +46,7 @@ func (c *TaoBaoVegetableController) GetCode() { // 创建或者更新账号token param := &model.VendorOrgCode{ VendorID: model.VendorIDTaoVegetable, - VendorOrgCode: api.TaoVegetableApi.GetVendorOrgCode(), + VendorOrgCode: tokenInfo.UserId, Comment: tokenInfo.UserNick, VendorType: "platform", IsJxCat: 1, diff --git a/globals/api/apimanager/apimanager.go b/globals/api/apimanager/apimanager.go index 05a247815..600db0751 100644 --- a/globals/api/apimanager/apimanager.go +++ b/globals/api/apimanager/apimanager.go @@ -82,12 +82,11 @@ func (a *APIManager) GetAPI(vendorID int, appOrgCode string) (pfAPI interface{}) } if tokenInfo.AccessToken != "" && tokenInfo.ExpireTime > time.Now().UnixNano()/1e6 { api2.SetToken(tokenInfo.AccessToken) + api2.SetVendorOrgCode(code.VendorOrgCode) } else { ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "淘鲜达token过期", ",请重新授权") } } - api.TaoVegetableApi = api2 - pfAPI = api2 case model.VendorIDEBAI: pfAPI = api.EbaiAPI