From 9c8f2234276406d23a4f966db4ca1e928af31463 Mon Sep 17 00:00:00 2001
From: Lenovo <zhuacang@163.com>
Date: Tue, 9 Jul 2024 18:11:34 +0800
Subject: [PATCH] =?UTF-8?q?=E6=98=A8=E6=97=A5=E5=8D=95=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/ruoyi/quartz/task/RyTask.java    |  1 +
 .../business/service/IMeituanService.java     |  1 +
 .../service/impl/MeituanServiceImpl.java      | 53 ++++++++++++++++++-
 3 files changed, 54 insertions(+), 1 deletion(-)

diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
index 470f90b..956b678 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
@@ -53,6 +53,7 @@ public class RyTask {
     public void getOrders() {
         iMeituanService.getScore();
         iMeituanService.getComments();
+        iMeituanService.getYestodayCount();
         iMeituanService.orderInfoList();
     }
 
diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/IMeituanService.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/IMeituanService.java
index 0f477fd..aaf15cf 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/business/service/IMeituanService.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/IMeituanService.java
@@ -25,6 +25,7 @@ public interface IMeituanService {
      * @return
      */
     String getComments();
+    String getYestodayCount();
 
     /**
      * 获取评分
diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java
index 1ede2d6..16ed83e 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java
@@ -41,6 +41,7 @@ import org.springframework.stereotype.Service;
 
 import java.io.IOException;
 import java.net.URLEncoder;
+import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
@@ -109,7 +110,7 @@ public class MeituanServiceImpl implements IMeituanService {
             busStoreDayInfoMapper.insertBusStoreDayInfo(busStoreDayInfo);
             getCommentsOne(storeInfo);
             getScoreOne(storeInfo);
-            //昨日单量 todo
+            yesterdayCountOne(storeInfo);
 
             return R.ok();
         } else if (list.size() == 1) {
@@ -154,6 +155,23 @@ public class MeituanServiceImpl implements IMeituanService {
         return "ok";
     }
 
+    @Override
+    public String getYestodayCount() {
+        BusStoreInfo busStoreInfo = new BusStoreInfo();
+        List<BusStoreInfo> busStoreInfoList = busStoreInfoMapper.selectBusStoreInfoList(busStoreInfo);
+        for (BusStoreInfo store : busStoreInfoList) {
+            Boolean flag = yesterdayCountOne(store);
+            if (!flag) {
+                //掉线
+                BusStoreInfo busStoreInfo1 = new BusStoreInfo();
+                busStoreInfo1.setId(store.getId());
+                busStoreInfo1.setGrantStatus("2");
+                busStoreInfoMapper.updateBusStoreInfo(busStoreInfo1);
+            }
+        }
+        return "ok";
+    }
+
     /**
      * 获取评分批量
      *
@@ -200,6 +218,39 @@ public class MeituanServiceImpl implements IMeituanService {
         return "ok";
     }
 
+    public boolean yesterdayCountOne(BusStoreInfo storeInfo){
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        String wmPoiId = valueFromCookie("wmPoiId", storeInfo.getStoreCookie());
+        Calendar calendar = Calendar.getInstance();
+        calendar.add(Calendar.DAY_OF_MONTH,-1);
+        Date minusDay = calendar.getTime();
+        String date = sdf.format(minusDay);
+        JSONObject jsonObject = merchantOrders(1, date, storeInfo.getStoreCookie());
+        String code = jsonObject.getString("code");
+        if ("0".equals(code)) {
+            JSONObject data = jsonObject.getJSONObject("data");
+            String total = data.getString("totalCount");
+            BusStoreInfo store = new BusStoreInfo();
+            store.setStoreCode(wmPoiId);
+            List<BusStoreInfo> list = busStoreInfoService.selectBusStoreInfoList(store);
+            if (list.size() > 0) {
+                BusStoreDayInfo dayInfo = new BusStoreDayInfo();
+                dayInfo.setStoreId(list.get(0).getId());
+                List<BusStoreDayInfo> list1 = busStoreDayInfoService.selectBusStoreDayInfoList(dayInfo);
+                if (list1.size() > 0) {
+                    BusStoreDayInfo temp = list1.get(0);
+                    temp.setLastOrderNum(Integer.valueOf(total));
+                    busStoreDayInfoService.updateBusStoreDayInfo(temp);
+                } else {
+                    dayInfo.setLastOrderNum(Integer.valueOf(total));
+                    busStoreDayInfoService.insertBusStoreDayInfo(dayInfo);
+                }
+            }
+        }
+        System.out.println(jsonObject);
+        return true;
+    }
+
     /**
      * 获取订单
      *