订单取消任务

internal/cron/supply.go

@@ -48,6 +48,8 @@ func (s *supplyTask) run() {
 	go s.data()
 	// 拆单
 	go s.orderSplit()
+	// 订单取消
+	go s.orderChange()
 }
 
 // @Title 价格更新通知
@@ -134,7 +136,7 @@ func (s *supplyTask) orderChange() {
 			log.Println("供应链拆单mq错误", recoverErr)
 		}
 		time.Sleep(time.Second * 3)
-		s.orderSplit()
+		s.orderChange()
 	}()
 	pool, _ := ants.NewPool(5)
 	rabbitmq.Rabbitmq.Consume(supply.Api.Mq.OrderCancel(), false, 5, func(delivery amqp.Delivery) {