16 changed files with 409 additions and 35 deletions
@ -0,0 +1,161 @@
|
||||
package com.logpm.trunkline.mq.waybil; |
||||
|
||||
import cn.hutool.core.util.ObjectUtil; |
||||
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; |
||||
import org.springblade.common.constant.broadcast.FanoutConstants; |
||||
import org.springblade.common.enums.BizOperationEnums; |
||||
import org.springblade.common.model.DistributionReCheckSignVO; |
||||
import org.springblade.common.model.NodeFanoutMsg; |
||||
import org.springblade.common.model.PackageData; |
||||
import org.springblade.common.model.workNode.PickUpByReCheckVO; |
||||
import org.springframework.amqp.core.ExchangeTypes; |
||||
import org.springframework.amqp.rabbit.annotation.Exchange; |
||||
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; |
||||
|
||||
/** |
||||
* 运单日志和状态变更 |
||||
*/ |
||||
@Slf4j |
||||
@Component |
||||
@AllArgsConstructor |
||||
public class StatusLogListener { |
||||
|
||||
private final ITrunklineWaybillTrackClient trunklineWaybillTrackClient ; |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSignReview.QUEUE.waybillStatusLog, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillSignReview.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
)) |
||||
@Transactional(rollbackFor = Exception.class) |
||||
public void statusPickUpLog(String msg) { |
||||
|
||||
log.info("自提复核处理运单日志和状态: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
return; |
||||
} |
||||
NodeFanoutMsg bean = JSONUtil.toBean(msg, NodeFanoutMsg.class); |
||||
Object main = bean.getMain(); |
||||
JSONObject entries = JSONUtil.parseObj(main); |
||||
PickUpByReCheckVO vo = JSONUtil.toBean(entries, PickUpByReCheckVO.class); |
||||
Long warehouseId = bean.getWarehouseId(); |
||||
BizOperationEnums bizOperation = bean.getBizOperation(); |
||||
List<PackageData> details = vo.getPackageDataList(); |
||||
|
||||
// 按照运单号进行分组 后面的集合 按照创建时间进行排序
|
||||
Map<String, List<PackageData>> map = details.stream().collect(Collectors.groupingBy(PackageData::getWaybillNumber)); |
||||
// 根据运单号 统计 每个运单的数量
|
||||
Map<String, Integer> waybillCountMap = new HashMap<>(); |
||||
|
||||
for (PackageData packageData : details) { |
||||
String waybillNumber = packageData.getWaybillNumber(); |
||||
waybillCountMap.put(waybillNumber, waybillCountMap.getOrDefault(waybillNumber, 0) + packageData.getNumber()); |
||||
} |
||||
Set<String> strings = waybillCountMap.keySet(); |
||||
|
||||
for (String waybillNumber : strings) { |
||||
|
||||
WaybillLogDTO t = new WaybillLogDTO(); |
||||
List<PackageData> packageDataList = map.get(waybillNumber); |
||||
if (packageDataList != null && !packageDataList.isEmpty()) { |
||||
packageDataList.sort(Comparator.comparing(PackageData::getSignTime)); |
||||
// 获取排序第一个
|
||||
t.setSignUser(packageDataList.get(0).getSignUser()); |
||||
t.setSignTime(packageDataList.get(0).getSignTime()); |
||||
} |
||||
t.setWaybillNo(waybillNumber); |
||||
t.setWarehouseName(bean.getWarehouse()); |
||||
t.setWarehouseId(warehouseId); |
||||
|
||||
t.setTrainNumber(vo.getPickupBatch()); |
||||
t.setCarNumber(vo.getCarNumber()); |
||||
t.setDriverName(vo.getDriverName()); |
||||
t.setDeliveryTime(vo.getDeliveryTime()); |
||||
t.setNum(waybillCountMap.get(waybillNumber)); |
||||
t.setSignOrderCode(vo.getPickupBatch()); |
||||
t.setType(3); |
||||
trunklineWaybillTrackClient.addSignWaybillLog(t); |
||||
|
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
|
||||
/** |
||||
* 配送签收复核 |
||||
* @param msg |
||||
*/ |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
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); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
return; |
||||
} |
||||
NodeFanoutMsg bean = JSONUtil.toBean(msg, NodeFanoutMsg.class); |
||||
Object main = bean.getMain(); |
||||
JSONObject entries = JSONUtil.parseObj(main); |
||||
DistributionReCheckSignVO vo = JSONUtil.toBean(entries, DistributionReCheckSignVO.class); |
||||
Long warehouseId = bean.getWarehouseId(); |
||||
BizOperationEnums bizOperation = bean.getBizOperation(); |
||||
List<PackageData> details = vo.getPackageDataList(); |
||||
|
||||
// 按照运单号进行分组 后面的集合 按照创建时间进行排序
|
||||
Map<String, List<PackageData>> map = details.stream().collect(Collectors.groupingBy(PackageData::getWaybillNumber)); |
||||
// 根据运单号 统计 每个运单的数量
|
||||
Map<String, Integer> waybillCountMap = new HashMap<>(); |
||||
|
||||
for (PackageData packageData : details) { |
||||
String waybillNumber = packageData.getWaybillNumber(); |
||||
waybillCountMap.put(waybillNumber, waybillCountMap.getOrDefault(waybillNumber, 0) + packageData.getNumber()); |
||||
} |
||||
Set<String> strings = waybillCountMap.keySet(); |
||||
|
||||
for (String waybillNumber : strings) { |
||||
|
||||
WaybillLogDTO t = new WaybillLogDTO(); |
||||
List<PackageData> packageDataList = map.get(waybillNumber); |
||||
if (packageDataList != null && !packageDataList.isEmpty()) { |
||||
packageDataList.sort(Comparator.comparing(PackageData::getSignTime)); |
||||
// 获取排序第一个
|
||||
t.setSignUser(packageDataList.get(0).getSignUser()); |
||||
t.setSignTime(packageDataList.get(0).getSignTime()); |
||||
} |
||||
t.setWaybillNo(waybillNumber); |
||||
t.setWarehouseName(bean.getWarehouse()); |
||||
t.setWarehouseId(warehouseId); |
||||
|
||||
t.setTrainNumber(vo.getTrainNumber()); |
||||
t.setCarNumber(vo.getVehicleName()); |
||||
t.setDriverName(vo.getDriverName()); |
||||
t.setDeliveryTime(vo.getDeliveryTime()); |
||||
t.setNum(waybillCountMap.get(waybillNumber)); |
||||
t.setSignOrderCode(vo.getReservationCode()); |
||||
t.setType(3); |
||||
trunklineWaybillTrackClient.addSignWaybillLog(t); |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue