|
|
@@ -162,6 +162,8 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
@Autowired
|
|
|
private LiveOrderMapper liveOrderMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private FsIntegralOrderLogsMapper fsIntegralOrderLogsMapper;
|
|
|
@Autowired
|
|
|
private LiveOrderItemMapper liveOrderItemMapper;
|
|
|
|
|
|
@@ -198,6 +200,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始推送订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.CREAT_ORDER, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -254,6 +259,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始取消订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_CANCEL, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -309,6 +317,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始取消订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_CANCEL, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -358,6 +369,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始取消订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_CANCEL, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -410,6 +424,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
map.put("mailNumber", mailNumber);
|
|
|
log.info("开始查询路由结果,参数为: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_DELIVERY, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return erpDeliverysResponse;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
dfApiResponse.setCode(mailNumber);
|
|
|
@@ -593,10 +610,16 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
Long orderId = order.getOrderId();
|
|
|
Long dfAccountId = getSFAccountIndex(orderId);
|
|
|
+ if (dfAccountId == null){
|
|
|
+ log.info("代服管家 getOrderDeliveryStatus-订单id: {}", orderId);
|
|
|
+ }
|
|
|
map.put("orderNumber", order.getOrderCode());
|
|
|
map.put("mailNumber", order.getDeliverySn());
|
|
|
try {
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_DELIVERY_STATUS, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if ("运单不存在".equals(dfApiResponse.getMsg())) {
|
|
|
|
|
|
@@ -659,7 +682,7 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
case 9:
|
|
|
//已签收
|
|
|
deliveryStatus = 3;
|
|
|
- stateEx = "301"; //退货签收
|
|
|
+ stateEx = "301";
|
|
|
SysConfig sysConfig = sysConfigMapper.selectConfigByConfigKey("his.store");
|
|
|
Map<String, Object> config = (Map<String, Object>) JSON.parse(sysConfig.getConfigValue());
|
|
|
Object isUpdateOrder = config.get("isUpdateOrder");
|
|
|
@@ -760,34 +783,43 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
case 1:
|
|
|
break;
|
|
|
case 2:
|
|
|
- sBuilder.append("您好,您有一个包裹正在准备发货,请耐心等待;\n");
|
|
|
- if (order.getDeliverySn() != null && !order.getDeliverySn().isEmpty()) {
|
|
|
- sBuilder.append(" 物流单号为:").append(order.getDeliverySn()).append("\n");
|
|
|
- }
|
|
|
- sBuilder.append("\uD83C\uDF39\uD83C\uDF39\uD83C\uDF39");
|
|
|
break;
|
|
|
case 3:
|
|
|
- if ("202".equals(stateEx)) {
|
|
|
- //211
|
|
|
- //你好,这边查询到您购买的XXX(购买套餐)在XXX(时间)已经送到了,送货员电话为XXX(送货员信息)
|
|
|
- ErpDeliverysRequest erpDeliverysRequest = new ErpDeliverysRequest();
|
|
|
- erpDeliverysRequest.setCode(order.getOrderCode());
|
|
|
- ErpDeliverysResponse express = null;
|
|
|
- express = getDeliver(erpDeliverysRequest);
|
|
|
- sBuilder.append("这边查询到您有一个包裹 ");
|
|
|
- if (express != null && express.getDeliverys() != null && !express.getDeliverys().isEmpty()) {
|
|
|
- List<ErpDeliverys> deliverys = express.getDeliverys();
|
|
|
- ErpDeliverys tracesDTO = deliverys.get(deliverys.size() - 1);
|
|
|
- String remark = tracesDTO.getRemark();
|
|
|
- if ("派送至".equals(remark)) {
|
|
|
- sBuilder.append(" 在").append(tracesDTO.getAcceptTime()).append("已经送到了\n");
|
|
|
+ //你好,这边查询到您购买的XXX(购买套餐)在XXX(时间)已经送到了,送货员电话为XXX(送货员信息)
|
|
|
+ ErpDeliverysRequest erpDeliverysRequest = new ErpDeliverysRequest();
|
|
|
+ erpDeliverysRequest.setCode(order.getOrderCode());
|
|
|
+ ErpDeliverysResponse express = null;
|
|
|
+ express = getDeliver(erpDeliverysRequest);
|
|
|
+ if (express != null && express.getDeliverys() != null && !express.getDeliverys().isEmpty()) {
|
|
|
+ List<ErpDeliverys> deliverys = express.getDeliverys();
|
|
|
+ ErpDeliverys tracesDTO = deliverys.get(deliverys.size() - 1);
|
|
|
+ String remark = tracesDTO.getRemark();
|
|
|
+
|
|
|
+ if ("0".equals(stateEx) || "1".equals(stateEx) || "2".equals(stateEx)) {
|
|
|
+ if (remark.contains("已收取快件")){
|
|
|
+ sBuilder.append("您好,您有一个包裹正在准备发货,请耐心等待;\n");
|
|
|
+ if (order.getDeliverySn() != null && !order.getDeliverySn().isEmpty()) {
|
|
|
+ sBuilder.append(" 物流单号为:").append(order.getDeliverySn()).append("\n");
|
|
|
+ }
|
|
|
+ sBuilder.append("\uD83C\uDF39\uD83C\uDF39\uD83C\uDF39");
|
|
|
+ }
|
|
|
+ } else if ("202".equals(stateEx)) {
|
|
|
+ if (remark.contains("正在派送")) {
|
|
|
+ sBuilder.append("这边查询到您有一个包裹 ");
|
|
|
+ sBuilder.append("正在派送中\n");
|
|
|
+ sBuilder.append(" 物流单号为:").append(order.getDeliverySn()).append("\n");
|
|
|
+ sBuilder.append("物流信息:").append(remark).append("\n");
|
|
|
+ sBuilder.append("\uD83C\uDF39\uD83C\uDF39\uD83C\uDF39");
|
|
|
+ }
|
|
|
+
|
|
|
+ } else if ("301".equals(stateEx)){
|
|
|
+ if (remark.contains("派送至本人") || remark.contains("签收")) {
|
|
|
+ sBuilder.append("这边查询到您有一个包裹 ");
|
|
|
+ sBuilder.append(" 在").append(tracesDTO.getAcceptTime()).append("已经签收了\n");
|
|
|
sBuilder.append(" 物流单号为:").append(order.getDeliverySn()).append("\n");
|
|
|
sBuilder.append("物流信息:").append(remark).append("\n");
|
|
|
}
|
|
|
- } else {
|
|
|
- sBuilder.append(" 已经送到了\n");
|
|
|
}
|
|
|
- sBuilder.append("\uD83C\uDF39\uD83C\uDF39\uD83C\uDF39");
|
|
|
}
|
|
|
break;
|
|
|
case 4:
|
|
|
@@ -821,6 +853,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
map.put("mailNumber", order.getDeliveryId());
|
|
|
try {
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_DELIVERY_STATUS, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if ("运单不存在".equals(dfApiResponse.getMsg())) {
|
|
|
|
|
|
@@ -916,6 +951,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
map.put("mailNumber", order.getDeliverySn());
|
|
|
try {
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_DELIVERY_STATUS, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if ("运单不存在".equals(dfApiResponse.getMsg())) {
|
|
|
//查看原来物流状态
|
|
|
@@ -1048,10 +1086,12 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
order.setStatus(1);//设置待发货状态
|
|
|
order.setDeliverySn("");
|
|
|
integralOrderMapper.updateById(order);
|
|
|
+ fsIntegralOrderLogsMapper.insert(FsIntegralOrderLogs.builder().orderId(order.getOrderId()).changeType(FsStoreOrderLogEnum.UPDATE_ORDER_DF.getValue()).changeMessage("运单不存在," + FsStoreOrderLogEnum.UPDATE_ORDER_DF.getDesc()).build());
|
|
|
} else {
|
|
|
log.info("积分订单物流被取消,退款积分订单{}",order.getOrderCode());
|
|
|
//以前查询到过物流信息,现在查不到,物流被人为取消
|
|
|
integralOrderService.mandatoryRefunds(order.getOrderCode());
|
|
|
+ fsIntegralOrderLogsMapper.insert(FsIntegralOrderLogs.builder().orderId(order.getOrderId()).changeType(FsStoreOrderLogEnum.REFUND_ORDER_DF.getValue()).changeMessage("运单不存在," + FsStoreOrderLogEnum.REFUND_ORDER_DF.getDesc()).build());
|
|
|
}
|
|
|
log.info("取消订单代服记录更新id{}",order.getOrderCode());
|
|
|
FsIntegralOrderDf df = new FsIntegralOrderDf();
|
|
|
@@ -1115,6 +1155,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始推送订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.CREAT_ORDER, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -1166,6 +1209,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始推送订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.CREAT_ORDER, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -1213,6 +1259,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
//2.请求
|
|
|
log.info("开始推送订单,参数: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.CREAT_ORDER, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return new ErpOrderResponse();
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
//3.处理请求结果
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
@@ -1675,6 +1724,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
String status = map.get("exInterfaceType").toString();
|
|
|
log.info("开始查询订单结果,参数为: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_RESULT, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return ;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
log.info("查询订单结果,结果: {}", JSON.toJSONString(dfApiResponse));
|
|
|
@@ -1728,6 +1780,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
String status = map.get("exInterfaceType").toString();
|
|
|
log.info("开始查询订单结果,参数为: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_RESULT, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
log.info("查询订单结果,结果: {}", JSON.toJSONString(dfApiResponse));
|
|
|
@@ -1781,6 +1836,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
String status = map.get("exInterfaceType").toString();
|
|
|
log.info("开始查询订单结果,参数为: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_RESULT, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
log.info("查询订单结果,结果: {}", JSON.toJSONString(dfApiResponse));
|
|
|
@@ -1974,6 +2032,8 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
order.setStatus(2);//修改积分订单为待收货状态
|
|
|
order.setDeliveryTime(DateUtils.getNowDate()); //更新发货时间
|
|
|
fsIntegralOrderMapper.updateById(order);
|
|
|
+ //订单发货日志
|
|
|
+ fsIntegralOrderLogsMapper.insert(FsIntegralOrderLogs.builder().orderId(order.getOrderId()).changeType("delivery_goods").changeMessage(FsStoreOrderLogEnum.DELIVERY_GOODS.getDesc()).build());
|
|
|
// fsStoreOrderLogsService.create(order.getOrderId(), FsStoreOrderLogEnum.DELIVERY_GOODS.getValue(), FsStoreOrderLogEnum.DELIVERY_GOODS.getDesc());
|
|
|
// redisCache.deleteObject(DELIVERY+":"+order.getOrderCode());
|
|
|
// if (order.getCompanyId() != null && order.getCompanyId() > 0) {
|
|
|
@@ -2189,6 +2249,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
|
|
|
String status = map.get("exInterfaceType").toString();
|
|
|
log.info("开始查询订单结果,参数为: {}", JSON.toJSONString(map));
|
|
|
String response = client.execute(RequestUrlEnum.ORDER_RESULT, map, dfAccountId);
|
|
|
+ if (StringUtils.isBlank(response)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
DFApiResponse dfApiResponse = JSON.parseObject(response, DFApiResponse.class);
|
|
|
if (dfApiResponse != null && "ok".equals(dfApiResponse.getCode())) {
|
|
|
log.info("查询订单结果,结果: {}", JSON.toJSONString(dfApiResponse));
|