microservice / sl-express · Commits

Commit 97a8d0f61ce8f743c9227a6dcf19ee223a1ac36e

Authored by shaofan
1 parent 7c9bae68
build: skipped

Changes by shaofan

Inline Side-by-side
Showing 1 changed file with 3 additions and 0 deletions
sl-express-ms-transport-info-service/src/main/java/com/sl/transport/info/mq/TransportInfoMQListener.java
  View file @97a8d0f
@@ -9,6 +9,7 @@ import com.sl.transport.common.vo.TransportInfoMsg; @@ -9,6 +9,7 @@ import com.sl.transport.common.vo.TransportInfoMsg;
9 import com.sl.transport.domain.OrganDTO; 9 import com.sl.transport.domain.OrganDTO;
10 import com.sl.transport.info.entity.TransportInfoDetail; 10 import com.sl.transport.info.entity.TransportInfoDetail;
11 import com.sl.transport.info.service.TransportInfoService; 11 import com.sl.transport.info.service.TransportInfoService;
  12 +import lombok.extern.slf4j.Slf4j;
12 import org.springframework.amqp.core.ExchangeTypes; 13 import org.springframework.amqp.core.ExchangeTypes;
13 import org.springframework.amqp.rabbit.annotation.Exchange; 14 import org.springframework.amqp.rabbit.annotation.Exchange;
14 import org.springframework.amqp.rabbit.annotation.Queue; 15 import org.springframework.amqp.rabbit.annotation.Queue;
@@ -22,6 +23,7 @@ import org.springframework.transaction.annotation.Transactional; @@ -22,6 +23,7 @@ import org.springframework.transaction.annotation.Transactional;
22 * 物流信息消息 23 * 物流信息消息
23 */ 24 */
24 @Component 25 @Component
  26 +@Slf4j
25 public class TransportInfoMQListener { 27 public class TransportInfoMQListener {
26 28
27 @Autowired 29 @Autowired
@@ -39,6 +41,7 @@ public class TransportInfoMQListener { @@ -39,6 +41,7 @@ public class TransportInfoMQListener {
39 @Transactional 41 @Transactional
40 public void listenTransportInfoMsg(String msg) { 42 public void listenTransportInfoMsg(String msg) {
41 //{"info":"您的快件已到达【$organId】", "status":"运输中", "organId":90001, "transportOrderId":"SL920733749248" , "created":1653133234913} 43 //{"info":"您的快件已到达【$organId】", "status":"运输中", "organId":90001, "transportOrderId":"SL920733749248" , "created":1653133234913}
  44 + log.info("接收到更新物流信息的消息 >>> msg = {}", msg);
42 TransportInfoMsg transportInfoMsg = JSONUtil.toBean(msg, TransportInfoMsg.class); 45 TransportInfoMsg transportInfoMsg = JSONUtil.toBean(msg, TransportInfoMsg.class);
43 Long organId = transportInfoMsg.getOrganId(); 46 Long organId = transportInfoMsg.getOrganId();
44 String transportOrderId = Convert.toStr(transportInfoMsg.getTransportOrderId()); 47 String transportOrderId = Convert.toStr(transportInfoMsg.getTransportOrderId());