diff --git a/business/jxcallback/orderman/orderman_ext.go b/business/jxcallback/orderman/orderman_ext.go index 8051da777..bdc7dd678 100644 --- a/business/jxcallback/orderman/orderman_ext.go +++ b/business/jxcallback/orderman/orderman_ext.go @@ -510,6 +510,7 @@ func (c *OrderManager) ExportOrders(ctx *jxcontext.Context, fromDateStr, toDateS paramDamages := []interface{}{v.VendorOrderID, model.OrderStatusCanceled} if err := dao.GetRow(dao.GetDB(), damages, sqlDamages, paramDamages); err == nil { v.LiquidatedDamages = damages.Damages + v.DesiredFee += damages.Damages } orders2 = append(orders2, v) } else { diff --git a/business/jxcallback/scheduler/defsch/defsch_ext.go b/business/jxcallback/scheduler/defsch/defsch_ext.go index 4d5dd5433..a3b3017f6 100644 --- a/business/jxcallback/scheduler/defsch/defsch_ext.go +++ b/business/jxcallback/scheduler/defsch/defsch_ext.go @@ -500,6 +500,9 @@ func (s *DefScheduler) QueryOrderWaybillFeeInfoEx(ctx *jxcontext.Context, vendor } } else { feeInfo.DeliveryFee += model.WayBillDeliveryMarkUp // 加收两毛 + if storeCourier.VendorID == model.VendorIDFengNiao { + feeInfo.DeliveryFee += model.WayBillDeliveryMarkUp // 蜂鸟加 + } feeInfo.TimeoutSecond = timeoutSecond } } else { diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index 3a2a4ba60..b1e69a54a 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -6,7 +6,6 @@ import ( "encoding/json" "errors" "fmt" - "git.rosy.net.cn/jx-callback/business/partner/delivery/mtps" "io" "math" "mime/multipart" @@ -2218,20 +2217,34 @@ func updateCourierStores(ctx *jxcontext.Context, storeID int) (err error) { func UpdateStoreName() error { var db = dao.GetDB() - sql := ` SELECT * FROM store_courier_map WHERE vendor_id = ? AND deleted_at = ?` - data := make([]*model.StoreCourierMap, 0, 0) - if err := dao.GetRows(db, &data, sql, []interface{}{model.VendorIDMTPS, utils.DefaultTimeValue}...); err != nil { + sql := ` SELECT * FROM store_courier_map WHERE vendor_id IN (?,?,?,?) AND deleted_at = ?` + courierList := make([]*model.StoreCourierMap, 0, 0) + if err := dao.GetRows(db, &courierList, sql, []interface{}{model.VendorIDMTPS, model.VendorIDFengNiao, model.VendorIDDada, model.VendorIDUUPT, utils.DefaultTimeValue}...); err != nil { globals.SugarLogger.Debugf("query Order err := %v", err) return err } - for _, v := range data { - storeDetail, _ := dao.GetStoreDetail2(db, v.StoreID, v.VendorStoreID, model.VendorIDMTPS) - formalizeStore4Courier(storeDetail) - if err := mtps.UpdateStoreName(v.VendorStoreID, storeDetail.Name); err != nil { - globals.SugarLogger.Debugf("err := %s,storeID : %s,storeName :%s", utils.Format4Output(err, false), v.VendorStoreID, storeDetail.Name) - } - } + work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + var resultList []interface{} + storeCourier := batchItemList[0].(*model.StoreCourierMap) + errList := errlist.New() + db := dao.GetDB() + + storeDetail, _ := dao.GetStoreDetail2(db, storeCourier.StoreID, storeCourier.VendorStoreID, storeCourier.VendorID) + formalizeStore4Courier(storeDetail) + if handlerInfo := partner.GetDeliveryPlatformFromVendorID(storeDetail.VendorID); handlerInfo != nil { + if updateHandler, _ := handlerInfo.Handler.(partner.IDeliveryUpdateStoreHandler); updateHandler != nil { + if err := updateHandler.UpdateStoreName(storeDetail.VendorStoreID, storeDetail.Name); err != nil { + errList.AddErr(err) + globals.SugarLogger.Debugf("err := %s,storeID : %s,storeName :%s", utils.Format4Output(err, false), storeDetail.VendorStoreID, storeDetail.Name) + } + } + } + return resultList, errList.GetErrListAsOne() + } + // 定时任务更新或者创建时修改东西 + task := tasksch.NewParallelTask("UpdateStoreName", tasksch.NewParallelConfig().SetIsContinueWhenError(false), jxcontext.AdminCtx, work, courierList) + tasksch.HandleTask(task, nil, len(courierList) > 1).Run() return nil } diff --git a/business/partner/delivery/dada/waybill.go b/business/partner/delivery/dada/waybill.go index 291892ad8..1c3e4909c 100644 --- a/business/partner/delivery/dada/waybill.go +++ b/business/partner/delivery/dada/waybill.go @@ -624,3 +624,7 @@ func (c *DeliveryHandler) GetDeliverLiquidatedDamages(orderId string, deliverId } return vendorPrice, nil } + +func (c *DeliveryHandler) UpdateStoreName(storeId, name string) (err error) { + return err +} diff --git a/business/partner/delivery/fn/waybill.go b/business/partner/delivery/fn/waybill.go index bb8e47379..b640f7b01 100644 --- a/business/partner/delivery/fn/waybill.go +++ b/business/partner/delivery/fn/waybill.go @@ -344,10 +344,10 @@ func (c *DeliveryHandler) OnWaybillExcept(msg *fnpsapi.AbnormalReportNotify) (re return retVal } -// 查询订单配送费 +// 查询订单配送费(蜂鸟加4毛) func GetDesiredFee(vendorOrderID string) (desiredFee, acuteFee int64) { if result, err := api.FnAPI.QueryOrder(vendorOrderID); err == nil { - return result.OrderTotalAmountCent + int64(utils.WayBillDeliveryMarkUp), result.OrderActualAmountCent + return result.OrderTotalAmountCent, result.OrderActualAmountCent } return desiredFee, acuteFee } @@ -473,3 +473,7 @@ func (c *DeliveryHandler) GetDeliverLiquidatedDamages(orderId string, deliverId } return vendorPrice, nil } + +func (c *DeliveryHandler) UpdateStoreName(storeId, name string) (err error) { + return err +} diff --git a/business/partner/delivery/mtps/store.go b/business/partner/delivery/mtps/store.go index 485d4c036..6bda0797e 100644 --- a/business/partner/delivery/mtps/store.go +++ b/business/partner/delivery/mtps/store.go @@ -184,7 +184,7 @@ func (c *DeliveryHandler) UpdateStore(ctx *jxcontext.Context, storeDetail *dao.S } // 美团配送,修改门店名称 -func UpdateStoreName(storeId, name string) (err error) { +func (c *DeliveryHandler) UpdateStoreName(storeId, name string) (err error) { shopInfo := &mtpsapi.ShopInfo{ ShopID: storeId, ShopName: name, diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index 222e64471..bef95a17c 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -543,6 +543,11 @@ func GetVendorRiderInfo(wayBillVendorId, vendorId int, vendorOrderId, vendorWayb } } + if riderInfo.CourierName != "" && riderInfo.CourierPhone != "" { + riderInfo.LogisticsContext = fmt.Sprintf(riderInfo.LogisticsContext, riderInfo.CourierName, riderInfo.CourierPhone) + } else { + riderInfo.LogisticsContext = fmt.Sprintf(riderInfo.LogisticsContext, "暂无", "暂无") + } return } diff --git a/business/partner/delivery/uupt/waybill.go b/business/partner/delivery/uupt/waybill.go index e7a7cbad2..910925a20 100644 --- a/business/partner/delivery/uupt/waybill.go +++ b/business/partner/delivery/uupt/waybill.go @@ -404,3 +404,7 @@ func getReallyStoreID(storeID, jxStoreID int) int { return storeID } } + +func (c *DeliveryHandler) UpdateStoreName(storeId, name string) (err error) { + return err +} diff --git a/business/partner/partner_delivery.go b/business/partner/partner_delivery.go index 59ed20cc3..b34087e85 100644 --- a/business/partner/partner_delivery.go +++ b/business/partner/partner_delivery.go @@ -54,6 +54,7 @@ type IDeliveryPlatformHandler interface { type IDeliveryUpdateStoreHandler interface { UpdateStore(ctx *jxcontext.Context, storeDetail *dao.StoreDetail2) (err error) + UpdateStoreName(storeId, name string) (err error) } type DeliveryPlatformHandlerInfo struct {