From 32904dd6dd3d200157134c5e1f7b1aff5e138b55 Mon Sep 17 00:00:00 2001
From: luofei <604446095@qq.com>
Date: Tue, 4 Jul 2023 17:47:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BF=A1=E7=94=A8=E8=B4=AD?=
 =?UTF-8?q?=E8=AE=A2=E5=8D=95=E9=80=BE=E6=9C=9F=E5=AE=9A=E6=97=B6=E9=80=9A?=
 =?UTF-8?q?=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../store/order/StoreOrderRepository.php      |  9 +++++--
 app/common/service/JgPush.php                 | 12 +++++++++
 app/controller/api/store/order/StoreOrder.php |  3 ++-
 crmeb/listens/AutoCheckCreditBuyListen.php    | 26 +++++++++++++++++++
 crmeb/services/SmsService.php                 |  3 +++
 5 files changed, 50 insertions(+), 3 deletions(-)
 create mode 100644 crmeb/listens/AutoCheckCreditBuyListen.php

diff --git a/app/common/repositories/store/order/StoreOrderRepository.php b/app/common/repositories/store/order/StoreOrderRepository.php
index fad9f4e3..5c293f24 100644
--- a/app/common/repositories/store/order/StoreOrderRepository.php
+++ b/app/common/repositories/store/order/StoreOrderRepository.php
@@ -2505,10 +2505,11 @@ class StoreOrderRepository extends BaseRepository
      * 确认接单
      * @param $user
      * @param $id
+     * @param $type
      * @return void
      * @throws Exception
      */
-    public function confirm($user, $id)
+    public function confirm($user, $id, $type)
     {
         /** @var StoreGroupOrderRepository $groupOrderRepository */
         $groupOrderRepository = app()->make(StoreGroupOrderRepository::class);
@@ -2523,7 +2524,11 @@ class StoreOrderRepository extends BaseRepository
             if ($order->status != StoreOrder::STATUS_WAIT_CONFIRM) {
                 throw new Exception('订单状态错误');
             }
-            $order->status = StoreOrder::STATUS_WAIT_PAY;
+            if ($type == 2) {
+                $order->is_del = 1;
+            } else {
+                $order->status = StoreOrder::STATUS_WAIT_PAY;
+            }
             $order->save();
             Db::commit();
         } catch (\Exception $e) {
diff --git a/app/common/service/JgPush.php b/app/common/service/JgPush.php
index cbec4ce5..7e2828f5 100644
--- a/app/common/service/JgPush.php
+++ b/app/common/service/JgPush.php
@@ -55,6 +55,18 @@ class JgPush
                     }
                 }
                 break;
+            case 'MERCHANT_CREDIT_BUY_NOTICE':
+                $route = "/pages/admin/orderDetail/index?id={$data['orderId']}&mer_id={$data['id']}";
+                $merUserId = Merchant::where('mer_id', $data['id'])->value('uid');
+                $jgRegisterId = User::where('uid', $merUserId)->value('jg_register_id');
+                if (empty($jgRegisterId)) {
+                    break;
+                }
+                $this->addRegistrationId($jgRegisterId);
+                $this->androidNotification('您的先货后款订单即将逾期，请尽快处理！', ['extras' => ['route' => $route]]);
+                $this->iosNotification('您的先货后款订单即将逾期，请尽快处理！', ['extras' => ['route' => $route]]);
+                $this->push->send();
+                break;
             default:
                 break;
         }
diff --git a/app/controller/api/store/order/StoreOrder.php b/app/controller/api/store/order/StoreOrder.php
index 09047bf5..039218a0 100644
--- a/app/controller/api/store/order/StoreOrder.php
+++ b/app/controller/api/store/order/StoreOrder.php
@@ -326,8 +326,9 @@ class StoreOrder extends BaseController
     public function confirm()
     {
         $id = $this->request->param('id/d');
+        $type = $this->request->param('type/d');
         try {
-            $this->repository->confirm($this->request->userInfo(), $id);
+            $this->repository->confirm($this->request->userInfo(), $id, $type);
             return app('json')->success('success');
         } catch (\Exception $e) {
             return app('json')->fail($e->getMessage());
diff --git a/crmeb/listens/AutoCheckCreditBuyListen.php b/crmeb/listens/AutoCheckCreditBuyListen.php
new file mode 100644
index 00000000..d55ace66
--- /dev/null
+++ b/crmeb/listens/AutoCheckCreditBuyListen.php
@@ -0,0 +1,26 @@
+<?php
+
+namespace crmeb\listens;
+
+use app\common\model\store\order\StoreOrderInterest;
+use crmeb\interfaces\ListenerInterface;
+use crmeb\jobs\SendSmsJob;
+use crmeb\services\TimerService;
+use think\facade\Queue;
+
+class AutoCheckCreditBuyListen extends TimerService implements ListenerInterface
+{
+    public function handle($event): void
+    {
+        $tomorrow = strtotime('tomorrow 10:00:00');
+        $time = ($tomorrow - time()) * 1000;
+        $this->tick($time, function () {
+            request()->clearCache();
+            $time = strtotime('+3 days');
+            $unSettle = StoreOrderInterest::whereBetweenTime('start_time', time(), $time)->where('status', 0)->group('mer_id')->column('order_id,mer_id');
+            foreach ($unSettle as $item) {
+                Queue::push(SendSmsJob::class, ['tempId' => 'MERCHANT_CREDIT_BUY_NOTICE', 'id' => $item['mer_id'], 'orderId' => $item['order_id']]);
+            }
+        });
+    }
+}
diff --git a/crmeb/services/SmsService.php b/crmeb/services/SmsService.php
index ef0a14cf..b40079b2 100644
--- a/crmeb/services/SmsService.php
+++ b/crmeb/services/SmsService.php
@@ -282,6 +282,9 @@ class SmsService
             case 'SVIP_PAY_SUCCESS':
                 self::create()->send($id['phone'], $tempId, ['store_name' => systemConfig('site_name'),'date' => $id['date']]);
                 break;
+            case 'MERCHANT_CREDIT_BUY_NOTICE':
+                self::sendMerMessage($id, $tempId, ['order_id' => $data['orderId']]);
+                break;
         }
     }