1;mq瘦身
This commit is contained in:
parent
5c7cfb87d2
commit
824e5756a5
|
@ -4,12 +4,11 @@ import java.time.LocalDateTime;
|
||||||
|
|
||||||
public class MqDataInfo{
|
public class MqDataInfo{
|
||||||
|
|
||||||
private String content;
|
private String storeCode;
|
||||||
private String channel;
|
private String channel;
|
||||||
|
|
||||||
private BusOrderInfo busOrderInfo;
|
private BusOrderInfo busOrderInfo;
|
||||||
private BusAgentInfo agentInfo;
|
private BusAgentInfo agentInfo;
|
||||||
private BusStoreInfo storeInfo;
|
|
||||||
|
|
||||||
private BusStoreConfigInfo busStoreConfigInfo;
|
private BusStoreConfigInfo busStoreConfigInfo;
|
||||||
|
|
||||||
|
@ -37,12 +36,12 @@ public class MqDataInfo{
|
||||||
this.busOrderInfo = busOrderInfo;
|
this.busOrderInfo = busOrderInfo;
|
||||||
}
|
}
|
||||||
|
|
||||||
public String getContent() {
|
public String getStoreCode() {
|
||||||
return content;
|
return storeCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setContent(String content) {
|
public void setStoreCode(String storeCode) {
|
||||||
this.content = content;
|
this.storeCode = storeCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
public String getChannel() {
|
public String getChannel() {
|
||||||
|
@ -53,11 +52,4 @@ public class MqDataInfo{
|
||||||
this.channel = channel;
|
this.channel = channel;
|
||||||
}
|
}
|
||||||
|
|
||||||
public BusStoreInfo getStoreInfo() {
|
|
||||||
return storeInfo;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setStoreInfo(BusStoreInfo storeInfo) {
|
|
||||||
this.storeInfo = storeInfo;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -65,7 +65,9 @@ public class AiConsumer {
|
||||||
long startTime = System.currentTimeMillis();
|
long startTime = System.currentTimeMillis();
|
||||||
System.out.println("开始======="+startTime);
|
System.out.println("开始======="+startTime);
|
||||||
BusAgentInfo agentInfo = mqDataInfo.getAgentInfo();
|
BusAgentInfo agentInfo = mqDataInfo.getAgentInfo();
|
||||||
BusStoreInfo busStoreInfo = mqDataInfo.getStoreInfo();
|
BusStoreInfo busStoreInfo = new BusStoreInfo();
|
||||||
|
busStoreInfo.setStoreCode(mqDataInfo.getStoreCode());
|
||||||
|
busStoreInfo.setMarketingChannels(mqDataInfo.getChannel());
|
||||||
BusOrderInfo busOrderInfo = mqDataInfo.getBusOrderInfo();
|
BusOrderInfo busOrderInfo = mqDataInfo.getBusOrderInfo();
|
||||||
BusStoreConfigInfo busStoreConfigInfo = mqDataInfo.getBusStoreConfigInfo();
|
BusStoreConfigInfo busStoreConfigInfo = mqDataInfo.getBusStoreConfigInfo();
|
||||||
try {
|
try {
|
||||||
|
|
|
@ -289,9 +289,16 @@ public class AiServiceImpl implements IAiService {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
MqDataInfo mqDataInfo = new MqDataInfo();
|
MqDataInfo mqDataInfo = new MqDataInfo();
|
||||||
|
agentInfo.setAgentName(null);
|
||||||
mqDataInfo.setAgentInfo(agentInfo);
|
mqDataInfo.setAgentInfo(agentInfo);
|
||||||
mqDataInfo.setStoreInfo(busStoreInfo);
|
mqDataInfo.setStoreCode(storeInfo.getStoreCode());
|
||||||
|
mqDataInfo.setChannel(storeInfo.getMarketingChannels());
|
||||||
|
busOrderInfo.setOrderStatus(null);
|
||||||
|
busOrderInfo.setStoreName(null);
|
||||||
|
busOrderInfo.setRecipientPhone(null);
|
||||||
|
busOrderInfo.setRecipientBindedPhone(null);
|
||||||
mqDataInfo.setBusOrderInfo(busOrderInfo);
|
mqDataInfo.setBusOrderInfo(busOrderInfo);
|
||||||
|
busStoreConfigInfo.setStoreName(null);
|
||||||
mqDataInfo.setBusStoreConfigInfo(busStoreConfigInfo);
|
mqDataInfo.setBusStoreConfigInfo(busStoreConfigInfo);
|
||||||
// 调用
|
// 调用
|
||||||
aiProducer.sendInfo(mqDataInfo);
|
aiProducer.sendInfo(mqDataInfo);
|
||||||
|
|
Loading…
Reference in New Issue