From f26b69361b522027e7dfa2975238701623787600 Mon Sep 17 00:00:00 2001
From: quyixiao <2621048238@qq.com>
Date: Thu, 23 Oct 2025 19:33:43 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../api/data/dto/PackageDelivedDelayDTO.java  |  2 +-
 .../service/impl/vv/VvPackageServiceImpl.java |  2 +-
 .../request/mm/enums/DelayTypeEnums.java      | 30 +++++++++++
 .../mm/order/resp/AppTradeOrderLineResp.java  |  3 --
 .../listener/DelaySimpleRabbitListener.java   | 50 ++++++++++++++++---
 5 files changed, 74 insertions(+), 13 deletions(-)
 create mode 100644 api-third/src/main/java/com/heyu/api/alibaba/request/mm/enums/DelayTypeEnums.java

diff --git a/api-mapper/src/main/java/com/heyu/api/data/dto/PackageDelivedDelayDTO.java b/api-mapper/src/main/java/com/heyu/api/data/dto/PackageDelivedDelayDTO.java
index da4c130..2622150 100644
--- a/api-mapper/src/main/java/com/heyu/api/data/dto/PackageDelivedDelayDTO.java
+++ b/api-mapper/src/main/java/com/heyu/api/data/dto/PackageDelivedDelayDTO.java
@@ -6,6 +6,6 @@ import lombok.Data;
 @Data
 public class PackageDelivedDelayDTO  extends DelayDTO{
 
-    private String packageId;
+    private Long packageId;
 
 }
diff --git a/api-mapper/src/main/java/com/heyu/api/data/service/impl/vv/VvPackageServiceImpl.java b/api-mapper/src/main/java/com/heyu/api/data/service/impl/vv/VvPackageServiceImpl.java
index ac0f230..88956df 100644
--- a/api-mapper/src/main/java/com/heyu/api/data/service/impl/vv/VvPackageServiceImpl.java
+++ b/api-mapper/src/main/java/com/heyu/api/data/service/impl/vv/VvPackageServiceImpl.java
@@ -131,7 +131,7 @@ public class VvPackageServiceImpl extends ServiceImpl<VvPackageDao, VvPackageEnt
                             // 设置签收时间
                             vvPackageEntity.setGmtSignReceipt(time);
                             PackageDelivedDelayDTO dto = new PackageDelivedDelayDTO();
-                            dto.setPackageId(vvPackageEntity.getId() + "");
+                            dto.setPackageId(vvPackageEntity.getId() );
                             dto.setRole(role);
                             dto.setSendTime(DateUtils.formatDate(new Date(), com.heyu.api.data.utils.DateUtils.YYYY_MM_DD_HH_MM_SS));
                             dto.setDelayTime(DateUtils.formatDate(timeAfter15, com.heyu.api.data.utils.DateUtils.YYYY_MM_DD_HH_MM_SS));
diff --git a/api-third/src/main/java/com/heyu/api/alibaba/request/mm/enums/DelayTypeEnums.java b/api-third/src/main/java/com/heyu/api/alibaba/request/mm/enums/DelayTypeEnums.java
new file mode 100644
index 0000000..7b0b22c
--- /dev/null
+++ b/api-third/src/main/java/com/heyu/api/alibaba/request/mm/enums/DelayTypeEnums.java
@@ -0,0 +1,30 @@
+package com.heyu.api.alibaba.request.mm.enums;
+
+public enum DelayTypeEnums {
+    delivered("delivered", "妥投");
+
+    private String type;
+
+    private String desc;
+
+    DelayTypeEnums(String type, String desc) {
+        this.type = type;
+        this.desc = desc;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public void setDesc(String desc) {
+        this.desc = desc;
+    }
+}
diff --git a/api-third/src/main/java/com/heyu/api/alibaba/request/mm/order/resp/AppTradeOrderLineResp.java b/api-third/src/main/java/com/heyu/api/alibaba/request/mm/order/resp/AppTradeOrderLineResp.java
index a6a2b2d..494ce0f 100644
--- a/api-third/src/main/java/com/heyu/api/alibaba/request/mm/order/resp/AppTradeOrderLineResp.java
+++ b/api-third/src/main/java/com/heyu/api/alibaba/request/mm/order/resp/AppTradeOrderLineResp.java
@@ -21,7 +21,4 @@ public class AppTradeOrderLineResp  extends VvTradeOrderLineEntity {
      */
     private VvPackageEntity vvPackageEntity;
 
-
-
-
 }
diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java
index 8d5223c..785011f 100644
--- a/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java
+++ b/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java
@@ -1,16 +1,29 @@
 package com.heyu.api.listener;
 
+import com.alibaba.fastjson.JSONObject;
+import com.heyu.api.alibaba.request.mm.enums.DelayTypeEnums;
+import com.heyu.api.alibaba.request.mm.enums.OrderStatusEnums;
+import com.heyu.api.data.dao.vv.VvPackageDao;
+import com.heyu.api.data.dao.vv.VvTradeOrderLineDao;
+import com.heyu.api.data.dto.PackageDelivedDelayDTO;
+import com.heyu.api.data.entity.vv.VvPackageEntity;
+import com.heyu.api.data.entity.vv.VvTradeOrderLineEntity;
+import com.heyu.api.data.enums.RoleEnums;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.amqp.support.AmqpHeaders;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
 import org.springframework.stereotype.Component;
 
 import java.io.IOException;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 @Component
 @Slf4j
@@ -20,21 +33,42 @@ public class DelaySimpleRabbitListener {
     private String delayQueue;
 
 
+    @Autowired
+    private VvPackageDao vvPackageDao;
+
+
+    @Autowired
+    private VvTradeOrderLineDao vvTradeOrderLineDao;
+
+
     @RabbitHandler
     @RabbitListener(queues = "#{delayQueue.name}", containerFactory = "accountAmountQueueSimpleRabbitListenerContainerFactory")
     public void consumeMessage(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long delivertTag, Channel channel) {
         try {
             log.info("DeliveredDelaySimpleRabbitListener delayQueue :{} message:{}", delayQueue, message);
+            Map<String, Object> map = JSONObject.parseObject(message, Map.class);
+            String type = map.get("type") + "";
+            if (DelayTypeEnums.delivered.getType().equals(type)) {
+                PackageDelivedDelayDTO packageDelivedDelayDTO = JSONObject.parseObject(message, PackageDelivedDelayDTO.class);
+
+                // 更新包信息
+                VvPackageEntity vvPackage = vvPackageDao.selectVvPackageById(packageDelivedDelayDTO.getPackageId());
+                vvPackage.setIscheck("3");
+                vvPackage.setGmtDelivered(new Date());
+                vvPackage.setDeliveredBy(RoleEnums.job.getRole());
+
+                vvPackageDao.insertOrUpdateVvPackage(vvPackage);
 
 
-
-
-
-
-
-
-
-
+                // 更新子单信息
+                List<VvTradeOrderLineEntity> vvTradeOrderLineEntityList = vvTradeOrderLineDao.selectVvTradeOrderLineByTrackNumber(vvPackage.getTrackNumber());
+                for (VvTradeOrderLineEntity vvTradeOrderLineEntity : vvTradeOrderLineEntityList) {
+                    vvTradeOrderLineEntity.setDeliveredBy(RoleEnums.job.getRole());
+                    vvTradeOrderLineEntity.setGmtDelivered(new Date());
+                    vvTradeOrderLineEntity.setStatus(OrderStatusEnums.delivered.getStatus());
+                    vvTradeOrderLineDao.updateVvTradeOrderLineById(vvTradeOrderLineEntity);
+                }
+            }
         } catch (Exception e) {
             log.error("DeliveredDelaySimpleRabbitListener handle", e);
         } finally {