1

business/jxcallback/scheduler/defsch/defsch_afs.go

@@ -32,9 +32,19 @@ func (s *DefScheduler) OnAfsOrderNew(order *model.AfsOrder, isPending bool) (err
 					}
 				}
 			}
-			msghub.OnNewWait4ApproveAfsOrder(order)
-			weixinmsg.NotifyAfsOrderStatus(order)
-			push.NotifyAfsOrder(order)
+
+			if order != nil && order.VendorID == model.VendorIDTaoVegetable {
+				result, _ := dao.GetAfsOrders(dao.GetDB(), model.VendorIDTaoVegetable, order.VendorOrderID, "")
+				if len(result) <= model.YES {
+					msghub.OnNewWait4ApproveAfsOrder(order)
+					weixinmsg.NotifyAfsOrderStatus(order)
+					push.NotifyAfsOrder(order)
+				}
+			} else {
+				msghub.OnNewWait4ApproveAfsOrder(order)
+				weixinmsg.NotifyAfsOrderStatus(order)
+				push.NotifyAfsOrder(order)
+			}
 
 			// 京西云打印机打印数据-如果门店使用京西打印机才使用如下代码块
 			store, err := dao.GetStoreDetail(dao.GetDB(), order.JxStoreID, order.VendorID, order.VendorOrgCode)