|
|
|
@ -5,9 +5,6 @@ import cn.hutool.core.util.StrUtil;
|
|
|
|
|
import cn.hutool.json.JSONObject; |
|
|
|
|
import cn.hutool.json.JSONUtil; |
|
|
|
|
import com.logpm.trunkline.dto.WaybillLogDTO; |
|
|
|
|
import com.logpm.trunkline.feign.ITrunklineWaybillTrackClient; |
|
|
|
|
import com.logpm.trunkline.mapper.TrunklineWaybillPackageMapper; |
|
|
|
|
import com.logpm.trunkline.service.ITrunklineWaybillPackageService; |
|
|
|
|
import com.logpm.trunkline.service.ITrunklineWaybillTrackService; |
|
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
@ -23,7 +20,6 @@ import org.springframework.amqp.rabbit.annotation.Queue;
|
|
|
|
|
import org.springframework.amqp.rabbit.annotation.QueueBinding; |
|
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
|
import java.util.*; |
|
|
|
|
import java.util.stream.Collectors; |
|
|
|
@ -110,7 +106,6 @@ public class StatusLogListener {
|
|
|
|
|
value = @Queue(name = FanoutConstants.distribution.DeliveryAndrecheck.QUEUE.waybillStatusLog, durable = "true"), |
|
|
|
|
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndrecheck.EXCHANGE, type = ExchangeTypes.FANOUT) |
|
|
|
|
)) |
|
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
|
public void statusDekiveryLog(String msg) { |
|
|
|
|
|
|
|
|
|
log.info("商/市配送 复核处理运单日志和状态: {}", msg); |
|
|
|
|