Przeglądaj źródła

[消息][修改][优化msg_record表更新死锁问题]

release_toaliyun_real
luozukai 7 lat temu
rodzic
commit
5d5b7c2328
2 zmienionych plików z 2 dodań i 4 usunięć
  1. +1
    -3
      mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java
  2. +1
    -1
      mallinkService/src/main/java/com/iformall/service/impl/WxMsgRecordServiceImpl.java

+ 1
- 3
mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java Wyświetl plik

@@ -37,12 +37,10 @@ public class RabbitMqMessageProducer implements MqBaseProducer {
public void sendMessage(BaseMsg data, String topic, String tags, String keys) {
try {
data.setUuid(UUID.randomUUID().toString());
wxMsgRecordService.save(data);

rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data));

data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode());
wxMsgRecordMapper.update(data);
wxMsgRecordService.save(data);
} catch (Exception e) {
log.error("RabbitMqMessageProducer: Send Message Error ", e);
}


+ 1
- 1
mallinkService/src/main/java/com/iformall/service/impl/WxMsgRecordServiceImpl.java Wyświetl plik

@@ -46,7 +46,7 @@ public class WxMsgRecordServiceImpl implements WxMsgRecordService {
msgRecord.setUuid(data.getUuid());
msgRecord.setId(idWorker.nextId());
msgRecord.setMsgJson(JsonUtil.obj2Json(data));
msgRecord.setMsgStatus(EnumMsgRecordStatus.DEFAULT.getCode());
msgRecord.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode());
wxMsgRecordMapper.save(msgRecord);
}



Ładowanie…
Anuluj
Zapisz