zhenghaoyu
1 year ago
26 changed files with 437 additions and 27 deletions
@ -0,0 +1,54 @@
|
||||
package com.logpm.trunkline.dto; |
||||
|
||||
import com.alibaba.excel.annotation.ExcelProperty; |
||||
import lombok.Data; |
||||
|
||||
import java.io.Serializable; |
||||
|
||||
@Data |
||||
public class OrderNoPackageExcelDTO implements Serializable { |
||||
|
||||
@ExcelProperty(value = "下单日期") |
||||
private String orderTime; |
||||
@ExcelProperty(value = "商场名称") |
||||
private String dealerName; |
||||
@ExcelProperty(value = "订单自编号") |
||||
private String orderCode; |
||||
@ExcelProperty(value = "物料名称") |
||||
private String materialName; |
||||
@ExcelProperty(value = "物料编码") |
||||
private String materialCode; |
||||
@ExcelProperty(value = "单位") |
||||
private String materialUnit; |
||||
@ExcelProperty(value = "销售数量") |
||||
private String num; |
||||
@ExcelProperty(value = "商场收货人") |
||||
private String consigneePerson; |
||||
@ExcelProperty(value = "商场收货人电话") |
||||
private String consigneeMobile; |
||||
@ExcelProperty(value = "商场收货地址") |
||||
private String consigneeAddress; |
||||
@ExcelProperty(value = "收货人") |
||||
private String customerName ; |
||||
@ExcelProperty(value = "联系电话") |
||||
private String customerPhone ; |
||||
@ExcelProperty(value = "地址") |
||||
private String customerAddress ; |
||||
@ExcelProperty(value = "车次") |
||||
private String trainNumber ; |
||||
@ExcelProperty(value = "发货日期") |
||||
private String sendDateStr ; |
||||
@ExcelProperty(value = "品牌") |
||||
private String brand ; |
||||
@ExcelProperty(value = "一级品类") |
||||
private String firsts ; |
||||
@ExcelProperty(value = "二级品类") |
||||
private String sencods ; |
||||
@ExcelProperty(value = "三级品类") |
||||
private String thirds ; |
||||
@ExcelProperty(value = "配送区域") |
||||
private String area ; |
||||
@ExcelProperty(value = "服务号") |
||||
private String serviceNum ; |
||||
|
||||
} |
||||
@ -0,0 +1,62 @@
|
||||
package com.logpm.trunkline.config; |
||||
|
||||
import com.alibaba.nacos.shaded.com.google.common.collect.Maps; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springblade.common.constant.RabbitConstant; |
||||
import org.springframework.amqp.core.*; |
||||
import org.springframework.amqp.rabbit.connection.ConnectionFactory; |
||||
import org.springframework.amqp.rabbit.connection.CorrelationData; |
||||
import org.springframework.amqp.rabbit.core.RabbitTemplate; |
||||
import org.springframework.context.annotation.Bean; |
||||
import org.springframework.context.annotation.Configuration; |
||||
|
||||
import java.util.Map; |
||||
|
||||
@Slf4j |
||||
@Configuration |
||||
public class RabbitMqConfiguration { |
||||
|
||||
@Bean |
||||
public RabbitTemplate createRabbitTemplate(ConnectionFactory connectionFactory){ |
||||
RabbitTemplate template = new RabbitTemplate(); |
||||
template.setConnectionFactory(connectionFactory); |
||||
template.setMandatory(true); |
||||
template.setConfirmCallback(new RabbitTemplate.ConfirmCallback() { |
||||
@Override |
||||
public void confirm(CorrelationData correlationData, boolean b, String s) { |
||||
System.out.println("确认回调-相关数据："+correlationData); |
||||
System.out.println("确认回调-确认情况："+b); |
||||
System.out.println("确认回调-原因："+s); |
||||
} |
||||
}); |
||||
|
||||
template.setReturnsCallback(new RabbitTemplate.ReturnsCallback() { |
||||
@Override |
||||
public void returnedMessage(ReturnedMessage returnedMessage) { |
||||
System.out.println("返回回调-消息："+returnedMessage.getMessage()); |
||||
System.out.println("返回回调-回应码："+returnedMessage.getReplyCode()); |
||||
System.out.println("返回回调-回应信息："+returnedMessage.getReplyText()); |
||||
System.out.println("返回回调-交换机："+returnedMessage.getExchange()); |
||||
System.out.println("返回回调-路由键："+returnedMessage.getRoutingKey()); |
||||
} |
||||
}); |
||||
return template; |
||||
} |
||||
|
||||
@Bean |
||||
public Queue unloadConfirmQueue() { |
||||
return new Queue(RabbitConstant.TRUNKLINE_UNLOAD_CONFIRM_QUEUE, true); |
||||
} |
||||
@Bean |
||||
public CustomExchange unloadConfirmExchange() { |
||||
Map<String, Object> args = Maps.newHashMap(); |
||||
args.put("x-delayed-type", "direct"); |
||||
return new CustomExchange(RabbitConstant.TRUNKLINE_UNLOAD_CONFIRM_EXCHANGE, "x-delayed-message", true, false, args); |
||||
} |
||||
@Bean |
||||
public Binding unloadConfirmBinding(Queue unloadConfirmQueue, CustomExchange unloadConfirmExchange) { |
||||
return BindingBuilder.bind(unloadConfirmQueue).to(unloadConfirmExchange).with(RabbitConstant.TRUNKLINE_UNLOAD_CONFIRM_ROUTING).noargs(); |
||||
} |
||||
|
||||
|
||||
} |
||||
Loading…
Reference in new issue