|
@@ -107,6 +107,11 @@ public class KxsGdServiceImpl implements KxsGdService {
|
|
|
}
|
|
}
|
|
|
for (Object obj : dataList) {
|
|
for (Object obj : dataList) {
|
|
|
JSONObject orderData = JSON.parseObject(obj.toString());
|
|
JSONObject orderData = JSON.parseObject(obj.toString());
|
|
|
|
|
+ //1 订单生成2 订单正在运行3 待发货4 配送中5 订单成功结束6 已激活成功11 办理失败12 拒签13 订单取消中14 订单取消
|
|
|
|
|
+ int status = orderData.getInteger("status");
|
|
|
|
|
+ if(status != 6){
|
|
|
|
|
+ continue;
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
String gdMobile = orderData.getString("mobile");
|
|
String gdMobile = orderData.getString("mobile");
|
|
|
KxsGdReport kxsGdReport = kxsGdReportMapper.selectOne(Wrappers.<KxsGdReport>lambdaQuery()
|
|
KxsGdReport kxsGdReport = kxsGdReportMapper.selectOne(Wrappers.<KxsGdReport>lambdaQuery()
|
|
@@ -119,7 +124,7 @@ public class KxsGdServiceImpl implements KxsGdService {
|
|
|
RabbitGdActQueueMQ.MsgEntity msgEntity = new RabbitGdActQueueMQ.MsgEntity();
|
|
RabbitGdActQueueMQ.MsgEntity msgEntity = new RabbitGdActQueueMQ.MsgEntity();
|
|
|
msgEntity.setPosSn(orderData.getString("iccid"));
|
|
msgEntity.setPosSn(orderData.getString("iccid"));
|
|
|
msgEntity.setPhoneNo(orderData.getString("mobile"));
|
|
msgEntity.setPhoneNo(orderData.getString("mobile"));
|
|
|
- msgEntity.setProductName(orderData.getString("offerName"));
|
|
|
|
|
|
|
+ msgEntity.setProductName(orderData.getString("productName"));
|
|
|
msgEntity.setActivationStatusName("已激活");
|
|
msgEntity.setActivationStatusName("已激活");
|
|
|
msgEntity.setActivationTime(LocalDateTimeUtil.format(LocalDateTime.now(), DatePattern.NORM_DATETIME_PATTERN));
|
|
msgEntity.setActivationTime(LocalDateTimeUtil.format(LocalDateTime.now(), DatePattern.NORM_DATETIME_PATTERN));
|
|
|
|
|
|