|
@@ -118,10 +118,10 @@ public class InsOrderPushMsgServiceImpl extends ServiceImpl<InsOrderPushMsgMappe
|
|
|
messageProperties.setContentEncoding("UTF-8");
|
|
messageProperties.setContentEncoding("UTF-8");
|
|
|
Message message_cj = new Message(item.getBytes(StandardCharsets.UTF_8), messageProperties);
|
|
Message message_cj = new Message(item.getBytes(StandardCharsets.UTF_8), messageProperties);
|
|
|
//推送
|
|
//推送
|
|
|
- InsOrderPushMsg insOrderPushMsg = new InsOrderPushMsg(null, pushDataVo.getInsAreaCompany().getId(), "0", new Date(), pushDataVo.toString());
|
|
|
|
|
|
|
+ //InsOrderPushMsg insOrderPushMsg = new InsOrderPushMsg(null, pushDataVo.getInsAreaCompany().getId(), "0", new Date(), pushDataVo.toString());
|
|
|
try{
|
|
try{
|
|
|
//更新狀態
|
|
//更新狀態
|
|
|
- insOrderPushMsgService.save(insOrderPushMsg);
|
|
|
|
|
|
|
+ //insOrderPushMsgService.save(insOrderPushMsg);
|
|
|
this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode(), message_cj);
|
|
this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode(), message_cj);
|
|
|
Thread.sleep(1500);
|
|
Thread.sleep(1500);
|
|
|
}catch(Exception e){
|
|
}catch(Exception e){
|