1

business/jxcallback/orderman/order_afs.go

@@ -211,6 +211,10 @@ func (c *OrderManager) addAfsOrderStatus(db *dao.DaoDB, orderStatus *model.Order
 					"VendorStatus",
 					"Status",
 				}
+				if orderStatus.VendorID == model.VendorIDDD {
+					order.Flag = 0
+					updateFields = append(updateFields, "Flag")
+				}
 				if model.IsAfsOrderFinalStatus(orderStatus.Status) {
 					order.AfsFinishedAt = orderStatus.StatusTime
 					if utils.IsTimeZero(order.AfsFinishedAt) {

business/jxcallback/scheduler/defsch/defsch.go

@@ -586,6 +586,10 @@ func (s *DefScheduler) OnWaybillStatusChanged(bill *model.Waybill, isPending boo
 				s.saveDeliveryFeeFromAndStartWatch(savedOrderInfo, bill.StatusTime)
 			}
 			// s.sendCourierOrderSMS(bill)
+			// 抖店在创建运单时,推送发单
+			if order.VendorID == model.VendorIDDD && bill.Status == model.WaybillStatusNew {
+				partner.GetPurchaseOrderHandlerFromVendorID(order.VendorID).SelfDeliverDelivering(order, "")
+			}
 		} else {
 			isBillExist := s.updateBillsInfo(savedOrderInfo, bill)
 			if !isBillExist {

business/partner/delivery/rider.go

@@ -152,6 +152,7 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) {
 		case model.VendorIDJDShop: // 京东商城
 		case model.VendorIDWSC: // 微盟微商城
 		case model.VendorIDDD: // 抖店小时达
+			// 呼叫骑手的时候推送发货
 			// 抖店由于发配送时运单id已经固定了,我们系统在重新发货,或者运单号发生改变时去推送信息时.抖店只识别第一个运单号所以在这儿修改成发单时的第一个运单号!
 			riderInfo.ThirdCarrierOrderId = riderInfo.OrderId
 			paramsMap := utils.Struct2Map(riderInfo, "", true)