24 changed files with 1188 additions and 557 deletions
@ -0,0 +1,419 @@
|
||||
package com.logpm.distribution.receiver.report; |
||||
|
||||
import cn.hutool.core.util.StrUtil; |
||||
import com.logpm.distribution.pros.DistributionProperties; |
||||
import com.rabbitmq.client.Channel; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springblade.common.constant.broadcast.FanoutConstants; |
||||
import org.springblade.common.constant.report.ReportConstants; |
||||
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.amqp.support.AmqpHeaders; |
||||
import org.springframework.messaging.handler.annotation.Header; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import java.io.IOException; |
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 配送明细报表作业节点监听器 |
||||
* |
||||
* @author zhaoqiaobo |
||||
* @create 2024-03-18 0:02 |
||||
*/ |
||||
@Slf4j |
||||
@Component |
||||
@AllArgsConstructor |
||||
public class ReportListener { |
||||
|
||||
private final DistributionProperties destinationProperties; |
||||
private final List<ReportService> reportServices; |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillPlan.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillPlan.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void billPlanReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getBillPlanReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("自提任务生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(BillPlanReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("自提任务生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSignReview.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillSignReview.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void billReViewReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getBillReviewReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("自提复核生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(BillReViewReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("自提复核生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSign.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillSign.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void billSignforReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getBillSignforReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("自提签收扫描生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(BillSignforReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("自提签收扫描生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndCarStart.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndCarStart.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void carStartReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getCarStartReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("发车生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(CarStartReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("发车生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndConsigneeArrive.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndConsigneeArrive.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void consigneeArriveReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getConsigneeArriveReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("配送到达生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(ConsigneeArriveReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("配送到达生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndFinish.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndFinish.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void deliverFinishReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getDeliverFinishReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("车次完成生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(DeliverFinishReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("车次完成生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndLoading.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndLoading.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void loadingReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getLoadingReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("装车生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(LoadingReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("装车生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndPlan.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndPlan.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void planReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getPlanReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("配送计划生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(PlanReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("配送计划生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.reservation.OwnReservation.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.reservation.OwnReservation.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void reservationPlanReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getReservationPlanReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("预约计划生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(ReservationPlanReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("预约计划生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndReturnWarehouse.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndReturnWarehouse.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void returnWarehouseReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getReturnWarehouseReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("回库生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(ReturnWarehouseReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("回库生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndrecheck.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndrecheck.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void reViewReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getReViewReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("文员复核生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(ReViewReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("文员复核生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.DeliveryAndSignfor.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndSignfor.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void signforReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getSignforReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("签收扫描生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(SignforReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("签收扫描生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = FanoutConstants.distribution.stock.QUEUE.REPORT, durable = "true"), |
||||
exchange = @Exchange(name = FanoutConstants.distribution.stock.EXCHANGE, type = ExchangeTypes.FANOUT) |
||||
), ackMode = "MANUAL") |
||||
public void stockReportListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getStockReport()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("备货生成明细报表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(StockReportListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("备货生成明细报表失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
@RabbitListener(bindings = @QueueBinding( |
||||
value = @Queue(name = ReportConstants.REPORT_QUALITY_DELIVER_QUEUE, durable = "true"), |
||||
exchange = @Exchange(name = ReportConstants.REPORT_QUALITY_DELIVER_EXCHANGE, type = ExchangeTypes.TOPIC), |
||||
key = ReportConstants.REPORT_QUALITY_DELIVER_ROUTINGKEY |
||||
), ackMode = "MANUAL") |
||||
public void qualityDeliverListener(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) { |
||||
Boolean flag = Boolean.TRUE; |
||||
if (!destinationProperties.getReport().getQualityDeliver()) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
log.info("配送明细基础表: {}", msg); |
||||
if (StrUtil.isEmpty(msg)) { |
||||
flag = Boolean.FALSE; |
||||
} |
||||
if (flag) { |
||||
try { |
||||
selectReportService(QualityDeliverListener.class).buildReport(msg); |
||||
} catch (Exception e) { |
||||
log.error("配送明细基础表处理失败: {}", e.getMessage()); |
||||
} |
||||
} |
||||
try { |
||||
channel.basicAck(tag, false); |
||||
} catch (IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
|
||||
private ReportService selectReportService(Class<? extends ReportService> clazz) { |
||||
// 根据某些条件选择具体的实现类
|
||||
for (ReportService reportService : reportServices) { |
||||
if (clazz.isInstance(reportService)) { |
||||
return reportService; |
||||
} |
||||
} |
||||
// 默认返回第一个实现类
|
||||
return reportServices.get(0); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,11 @@
|
||||
package com.logpm.distribution.receiver.report; |
||||
|
||||
/** |
||||
* @Author: zqb |
||||
* @Date: 2024/12/10 |
||||
*/ |
||||
public interface ReportService { |
||||
|
||||
void buildReport(String msg); |
||||
|
||||
} |
||||
Loading…
Reference in new issue