From b988922251e9d88f133c26439b89be4269f1d797 Mon Sep 17 00:00:00 2001
From: wuchunlei <mailcauchy@gmail.com>
Date: Tue, 28 Nov 2023 17:37:45 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=94=A8=E6=88=B7=E8=B4=AD?=
 =?UTF-8?q?=E4=B9=B0=E7=9A=84=E4=B9=A6=E7=B1=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       |  2 +-
 .../peanut/modules/job/task/ExpressTask.java  | 70 +++++++++++++++++++
 2 files changed, 71 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/peanut/modules/job/task/ExpressTask.java

diff --git a/pom.xml b/pom.xml
index 51525805..b770fe00 100644
--- a/pom.xml
+++ b/pom.xml
@@ -23,7 +23,7 @@
         <mysql.version>8.0.28</mysql.version>
         <mssql.version>4.0</mssql.version>
         <oracle.version>11.2.0.3</oracle.version>
-        <druid.version>1.1.13</druid.version>
+        <druid.version>1.2.1</druid.version>
         <quartz.version>2.3.0</quartz.version>
         <commons.lang.version>2.6</commons.lang.version>
         <commons.fileupload.version>1.2.2</commons.fileupload.version>
diff --git a/src/main/java/com/peanut/modules/job/task/ExpressTask.java b/src/main/java/com/peanut/modules/job/task/ExpressTask.java
new file mode 100644
index 00000000..128e9897
--- /dev/null
+++ b/src/main/java/com/peanut/modules/job/task/ExpressTask.java
@@ -0,0 +1,70 @@
+package com.peanut.modules.job.task;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import com.peanut.modules.book.entity.BuyOrder;
+import com.peanut.modules.book.entity.BuyOrderProduct;
+import com.peanut.modules.book.entity.ExpressOrder;
+import com.peanut.modules.book.entity.ExpressQueryResponse;
+import com.peanut.modules.book.service.BuyOrderProductService;
+import com.peanut.modules.book.service.BuyOrderService;
+import com.peanut.modules.book.service.ExpressOrderService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.List;
+import java.util.Map;
+
+@Component("expressTask")
+public class ExpressTask implements ITask{
+
+    @Autowired
+    private BuyOrderService buyOrderService;
+    @Autowired
+    private BuyOrderProductService productService;
+    @Autowired
+    private ExpressOrderService expressOrderService;
+
+    @Override
+    public void run(String params) {
+        System.out.println("------expressTask定时任务正在执行------");
+        System.out.println("------查询快递修改状态定时任务正在执行------");
+        System.out.println("------expressTask定时任务正在执行------");
+
+        LambdaQueryWrapper<BuyOrder> wrapper = new LambdaQueryWrapper();
+        wrapper.eq(BuyOrder::getOrderStatus,"2");
+        List<BuyOrder> list = buyOrderService.list(wrapper);
+        if (list.size() > 0){
+            for (BuyOrder buyOrder : list) {
+                MPJLambdaWrapper<BuyOrderProduct> w = new MPJLambdaWrapper();
+                w.selectAll(ExpressOrder.class);
+                w.eq(BuyOrderProduct::getOrderId,buyOrder.getOrderId());
+                w.leftJoin(ExpressOrder.class,ExpressOrder::getId,BuyOrderProduct::getExpressOrderId);
+                List<Map<String,Object>> plist = productService.listMaps(w);
+                if (plist.size() > 0){
+                    boolean flag = false;
+                    for (Map<String,Object> m : plist){
+                        String expressOrderSn = m.get("express_order_sn").toString();
+                        String consigneeMobile = m.get("consignee_mobile").toString();
+                        String expressCompanyCode = m.get("express_company_code").toString();
+                        String tel = consigneeMobile.substring(consigneeMobile.length()-4);
+                        ExpressQueryResponse expressQueryResponse = expressOrderService.queryExpressOrder(expressCompanyCode, expressOrderSn, tel);
+                        if ("3".equals(expressQueryResponse.getState())){
+                            flag = true;
+                        }else {
+                            flag = false;
+                        }
+                    }
+                    if (flag){
+                        buyOrder.setOrderStatus("3");
+                        buyOrderService.saveOrUpdate(buyOrder);
+                    }
+
+                }
+            }
+        }
+
+        System.out.println("------expressTask定时任务执行完毕------");
+        System.out.println("------查询快递修改状态定时任务执行完毕------");
+        System.out.println("------expressTask定时任务执行完毕------");
+    }
+}