违约规则

performance-web/src/main/java/com/clx/performance/service/impl/breakcontract/BreakContractMqServiceImpl.java

@@ -6,6 +6,7 @@ import com.clx.performance.common.MqWrapper;
 import com.clx.performance.constant.RabbitKeyBreakContractConstants;
 import com.clx.performance.param.mq.BreakContractDriverRecordAddMqParam;
 import com.clx.performance.param.mq.BreakContractOwnerRuleAddMqParam;
+import com.clx.performance.service.breakcontract.BreakContractMqHandlerService;
 import com.clx.performance.service.breakcontract.BreakContractMqService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -28,17 +29,21 @@ public class BreakContractMqServiceImpl implements BreakContractMqService {
     @Autowired
     private RabbitTemplate rabbitTemplate;
 
+    @Autowired
+    private BreakContractMqHandlerService breakContractMqHandlerService;
+
 
     @Override
     public void ownerRuleAdd(Integer ruleId) {
         BreakContractOwnerRuleAddMqParam mq = new BreakContractOwnerRuleAddMqParam();
         mq.setRuleId(ruleId);
 
-        MqDelay<MqWrapper<BreakContractOwnerRuleAddMqParam>> delay = new MqDelay<>(RabbitKeyBreakContractConstants.DEFAULT_EXCHANGE, RabbitKeyBreakContractConstants.OWNER_RULE_ADD_ROUTING_KEY, new MqWrapper<>(mq));
-        Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(delay)).getBytes()).build();
-        message.getMessageProperties().setExpiration("5000");
-        rabbitTemplate.send(RabbitKeyBreakContractConstants.DEFAULT_EXCHANGE, RabbitKeyBreakContractConstants.DEFAULT_DELAY_ROUTING_KEY, message);
+//        MqDelay<MqWrapper<BreakContractOwnerRuleAddMqParam>> delay = new MqDelay<>(RabbitKeyBreakContractConstants.DEFAULT_EXCHANGE, RabbitKeyBreakContractConstants.OWNER_RULE_ADD_ROUTING_KEY, new MqWrapper<>(mq));
+//        Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(delay)).getBytes()).build();
+//        message.getMessageProperties().setExpiration("5000");
+//        rabbitTemplate.send(RabbitKeyBreakContractConstants.DEFAULT_EXCHANGE, RabbitKeyBreakContractConstants.DEFAULT_DELAY_ROUTING_KEY, message);
 
+        breakContractMqHandlerService.ownerRuleAdd(mq);
     }
 
     @Override