|
@@ -8,6 +8,7 @@ import cn.newfeifan.mall.module.distri.mq.message.order.OrderCalcMessage;
|
|
|
import cn.newfeifan.mall.module.distri.mq.message.order.OrderItemMessage;
|
|
|
import cn.newfeifan.mall.module.trade.mq.producer.order.DistriOrderProducer;
|
|
|
import cn.newfeifan.mall.module.trade.service.order.TradeOrderQueryService;
|
|
|
+import org.quartz.DisallowConcurrentExecution;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
@@ -21,6 +22,7 @@ import java.util.stream.Collectors;
|
|
|
* @author 非繁源码
|
|
|
*/
|
|
|
@Component
|
|
|
+@DisallowConcurrentExecution
|
|
|
public class TradeOrderAutoCalcJob implements JobHandler {
|
|
|
|
|
|
@Resource
|