19 changed files with 330 additions and 60 deletions
@ -0,0 +1,134 @@
|
||||
package com.logpm.distribution.receiver.report; |
||||
|
||||
import cn.hutool.core.util.StrUtil; |
||||
import cn.hutool.json.JSONObject; |
||||
import cn.hutool.json.JSONUtil; |
||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.distribution.dto.ReportQualityDeliverDTO; |
||||
import com.logpm.distribution.entity.QualityDeliverEntity; |
||||
import com.logpm.distribution.service.IQualityDeliverService; |
||||
import com.logpm.factorydata.feign.IFactoryDataClient; |
||||
import com.logpm.factorydata.vo.SendMsg; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springblade.common.constant.broadcast.FanoutConstants; |
||||
import org.springblade.common.constant.report.ReportConstants; |
||||
import org.springblade.common.enums.BizOperationEnums; |
||||
import org.springblade.common.model.ConsigneeArriveVO; |
||||
import org.springblade.common.model.NodeFanoutMsg; |
||||
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 javax.annotation.Resource; |
||||
|
||||
/** |
||||
* 配送到达生成明细报表 |
||||
* |
||||
* @author zhaoqiaobo |
||||
* @create 2024-03-18 0:02 |
||||
*/ |
||||
@Slf4j |
||||
@Component |
||||
@AllArgsConstructor |
||||
public class ConsigneeArriveReportListener { |
||||
|
||||
@Resource |
||||
private IQualityDeliverService qualityDeliverService; |
||||
@Resource |
||||
private IFactoryDataClient factoryDataClient; |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndConsigneeArrive.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndConsigneeArrive.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
)) |
||||
@Transactional(rollbackFor = Exception.class) |
||||
public void buildReport(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); |
||||
ConsigneeArriveVO vo = JSONUtil.toBean(entries, ConsigneeArriveVO.class); |
||||
Long warehouseId = bean.getWarehouseId(); |
||||
BizOperationEnums bizOperation = bean.getBizOperation(); |
||||
if (BizOperationEnums.DELETE.equals(bizOperation)) { |
||||
LambdaUpdateWrapper<QualityDeliverEntity> wrapper = Wrappers.<QualityDeliverEntity>lambdaUpdate() |
||||
.set(QualityDeliverEntity::getArriveCarUserName, null) |
||||
.set(QualityDeliverEntity::getArriveCarTime, null) |
||||
.eq(QualityDeliverEntity::getLoadTrainNumber, vo.getTrainNumber()) |
||||
.eq(QualityDeliverEntity::getPlanReservationCode, vo.getReservationCode()) |
||||
.ne(QualityDeliverEntity::getBizStatus, 110); |
||||
qualityDeliverService.update(wrapper); |
||||
} |
||||
if (BizOperationEnums.ADD.equals(bizOperation)) { |
||||
LambdaUpdateWrapper<QualityDeliverEntity> wrapper = Wrappers.<QualityDeliverEntity>lambdaUpdate() |
||||
.set(QualityDeliverEntity::getArriveCarUserName, vo.getDriverName()) |
||||
.set(QualityDeliverEntity::getArriveCarTime, bean.getOperatorTime()) |
||||
.eq(QualityDeliverEntity::getLoadTrainNumber, vo.getTrainNumber()) |
||||
.eq(QualityDeliverEntity::getPlanReservationCode, vo.getReservationCode()) |
||||
.ne(QualityDeliverEntity::getBizStatus, 110); |
||||
qualityDeliverService.update(wrapper); |
||||
} |
||||
// if (BizOperationEnums.MODIFY.equals(bizOperation) || BizOperationEnums.DELETE.equals(bizOperation)) {
|
||||
// // 根据预约单号查询出所有这个预约单下的数据 先置空
|
||||
// LambdaUpdateWrapper<QualityDeliverEntity> wrapper = Wrappers.<QualityDeliverEntity>lambdaUpdate()
|
||||
// .set(QualityDeliverEntity::getLoadUserName, null)
|
||||
// .set(QualityDeliverEntity::getLoadTime, null)
|
||||
// .set(QualityDeliverEntity::getLoadLicensePlate, null)
|
||||
// .set(QualityDeliverEntity::getLoadNum, null)
|
||||
// .ne(QualityDeliverEntity::getBizStatus, 110);
|
||||
// qualityDeliverService.update(wrapper);
|
||||
// }
|
||||
|
||||
// List<PackageData> details = new ArrayList<>();
|
||||
// if (CollUtil.isNotEmpty(details)) {
|
||||
// for (PackageData detail : details) {
|
||||
// QualityDeliverEntity qualityDeliverEntity = QualityDeliverEntity.builder()
|
||||
// .warehouseName(bean.getWarehouse())
|
||||
// .warehouseId(warehouseId)
|
||||
// .startCarUserName(bean.getOperator())
|
||||
// .startCarTime(bean.getOperatorTime())
|
||||
// .build();
|
||||
// if (ObjectUtil.equals(detail.getPackageType(), PackageTypeEnums.CMP)) {
|
||||
// qualityDeliverEntity.setConditions(1);
|
||||
// qualityDeliverEntity.setLoadNum(1);
|
||||
// sendReport(bizOperation, qualityDeliverEntity);
|
||||
// } else if (ObjectUtil.equals(detail.getPackageType(), PackageTypeEnums.LTL)) {
|
||||
// qualityDeliverEntity.setOrderCode(detail.getOrderCode());
|
||||
// qualityDeliverEntity.setCostCategory(detail.getProductName());
|
||||
// qualityDeliverEntity.setRevenueCategory(detail.getProductName());
|
||||
// qualityDeliverEntity.setConditions(2);
|
||||
// sendReport(bizOperation, qualityDeliverEntity);
|
||||
// } else if (ObjectUtil.equals(detail.getPackageType(), PackageTypeEnums.INV)) {
|
||||
// qualityDeliverEntity.setIncomingBatch(detail.getPickupBatch());
|
||||
// qualityDeliverEntity.setMallName(detail.getMallName());
|
||||
// qualityDeliverEntity.setMaterielCode(detail.getMaterialCode());
|
||||
// qualityDeliverEntity.setMaterielName(detail.getMaterialName());
|
||||
// qualityDeliverEntity.setConditions(3);
|
||||
// sendReport(bizOperation, qualityDeliverEntity);
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
} |
||||
|
||||
private void sendReport(BizOperationEnums bizOperation, QualityDeliverEntity qualityDeliverEntity) { |
||||
if (BizOperationEnums.ADD.equals(bizOperation) || BizOperationEnums.MODIFY.equals(bizOperation)) { |
||||
ReportQualityDeliverDTO dto = ReportQualityDeliverDTO.builder().data(JSONUtil.toJsonStr(qualityDeliverEntity)).operation(BizOperationEnums.MODIFY).build(); |
||||
factoryDataClient.sendMessage(SendMsg.builder() |
||||
.exchange(ReportConstants.REPORT_QUALITY_DELIVER_EXCHANGE) |
||||
.routingKey(ReportConstants.REPORT_QUALITY_DELIVER_ROUTINGKEY) |
||||
.message(JSONUtil.toJsonStr(dto)) |
||||
.delay(3000) |
||||
.build()); |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,120 @@
|
||||
package com.logpm.distribution.receiver.report; |
||||
|
||||
import cn.hutool.core.collection.CollUtil; |
||||
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.distribution.dto.ReportQualityDeliverDTO; |
||||
import com.logpm.distribution.entity.QualityDeliverEntity; |
||||
import com.logpm.distribution.service.IQualityDeliverService; |
||||
import com.logpm.factorydata.feign.IFactoryDataClient; |
||||
import com.logpm.factorydata.vo.SendMsg; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springblade.common.constant.broadcast.FanoutConstants; |
||||
import org.springblade.common.constant.report.ReportConstants; |
||||
import org.springblade.common.enums.BizOperationEnums; |
||||
import org.springblade.common.enums.PackageTypeEnums; |
||||
import org.springblade.common.model.DistributionSignforVO; |
||||
import org.springblade.common.model.NodeFanoutMsg; |
||||
import org.springblade.common.model.PackageData; |
||||
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 javax.annotation.Resource; |
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 文员复核生成明细报表 |
||||
* |
||||
* @author zhaoqiaobo |
||||
* @create 2024-03-18 0:02 |
||||
*/ |
||||
@Slf4j |
||||
@Component |
||||
@AllArgsConstructor |
||||
public class ReViewReportListener { |
||||
|
||||
@Resource |
||||
private IQualityDeliverService qualityDeliverService; |
||||
@Resource |
||||
private IFactoryDataClient factoryDataClient; |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndrecheck.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndrecheck.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
)) |
||||
@Transactional(rollbackFor = Exception.class) |
||||
public void buildReport(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); |
||||
DistributionSignforVO vo = JSONUtil.toBean(entries, DistributionSignforVO.class); |
||||
Long warehouseId = bean.getWarehouseId(); |
||||
BizOperationEnums bizOperation = bean.getBizOperation(); |
||||
List<PackageData> details = vo.getPackageDataList(); |
||||
// if (BizOperationEnums.MODIFY.equals(bizOperation) || BizOperationEnums.DELETE.equals(bizOperation)) {
|
||||
// // 根据预约单号查询出所有这个预约单下的数据 先置空
|
||||
// LambdaUpdateWrapper<QualityDeliverEntity> wrapper = Wrappers.<QualityDeliverEntity>lambdaUpdate()
|
||||
// .set(QualityDeliverEntity::getLoadUserName, null)
|
||||
// .set(QualityDeliverEntity::getLoadTime, null)
|
||||
// .set(QualityDeliverEntity::getLoadLicensePlate, null)
|
||||
// .set(QualityDeliverEntity::getLoadNum, null)
|
||||
// .ne(QualityDeliverEntity::getBizStatus, 110);
|
||||
// qualityDeliverService.update(wrapper);
|
||||
// }
|
||||
if (CollUtil.isNotEmpty(details)) { |
||||
for (PackageData detail : details) { |
||||
QualityDeliverEntity qualityDeliverEntity = QualityDeliverEntity.builder() |
||||
.warehouseName(bean.getWarehouse()) |
||||
.warehouseId(warehouseId) |
||||
.orderPackageCode(detail.getPackageCode()) |
||||
.reviewUserName(bean.getOperator()) |
||||
.reviewTime(bean.getOperatorTime()) |
||||
.build(); |
||||
if (ObjectUtil.equals(detail.getPackageType(), PackageTypeEnums.CMP)) { |
||||
qualityDeliverEntity.setConditions(1); |
||||
qualityDeliverEntity.setLoadNum(1); |
||||
sendReport(bizOperation, qualityDeliverEntity); |
||||
} else if (ObjectUtil.equals(detail.getPackageType(), PackageTypeEnums.LTL)) { |
||||
qualityDeliverEntity.setPlanReservationCode(vo.getReservationCode()); |
||||
qualityDeliverEntity.setOrderCode(detail.getOrderCode()); |
||||
qualityDeliverEntity.setCostCategory(detail.getProductName()); |
||||
qualityDeliverEntity.setRevenueCategory(detail.getProductName()); |
||||
qualityDeliverEntity.setConditions(2); |
||||
sendReport(bizOperation, qualityDeliverEntity); |
||||
} else if (ObjectUtil.equals(detail.getPackageType(), PackageTypeEnums.INV)) { |
||||
qualityDeliverEntity.setIncomingBatch(detail.getPickupBatch()); |
||||
qualityDeliverEntity.setMallName(detail.getMallName()); |
||||
qualityDeliverEntity.setMaterielCode(detail.getMaterialCode()); |
||||
qualityDeliverEntity.setMaterielName(detail.getMaterialName()); |
||||
qualityDeliverEntity.setConditions(3); |
||||
sendReport(bizOperation, qualityDeliverEntity); |
||||
} |
||||
} |
||||
} |
||||
} |
||||
|
||||
private void sendReport(BizOperationEnums bizOperation, QualityDeliverEntity qualityDeliverEntity) { |
||||
if (BizOperationEnums.ADD.equals(bizOperation) || BizOperationEnums.MODIFY.equals(bizOperation)) { |
||||
ReportQualityDeliverDTO dto = ReportQualityDeliverDTO.builder().data(JSONUtil.toJsonStr(qualityDeliverEntity)).operation(BizOperationEnums.MODIFY).build(); |
||||
factoryDataClient.sendMessage(SendMsg.builder() |
||||
.exchange(ReportConstants.REPORT_QUALITY_DELIVER_EXCHANGE) |
||||
.routingKey(ReportConstants.REPORT_QUALITY_DELIVER_ROUTINGKEY) |
||||
.message(JSONUtil.toJsonStr(dto)) |
||||
.delay(3000) |
||||
.build()); |
||||
} |
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue