修改代码

app/data/controller/UserLevel.php

@@ -2,7 +2,7 @@
 
 namespace app\data\controller;
 
-use app\data\service\PrizeService;
+use app\data\service\RebateCurrentService;
 use think\admin\Controller;
 
 /**
@@ -41,7 +41,7 @@ class UserLevel extends Controller
         foreach ($data as &$vo) {
             $vo['rebate_rule'] = str2arr($vo['rebate_rule']);
             foreach ($vo['rebate_rule'] as &$v) {
-                $v = PrizeService::instance()->name($v);
+                $v = RebateCurrentService::instance()->name($v);
             }
         }
     }
@@ -77,7 +77,7 @@ class UserLevel extends Controller
     protected function _form_filter(array &$vo)
     {
         if ($this->request->isGet()) {
-            $this->prizes = PrizeService::PRIZES;
+            $this->prizes = RebateCurrentService::PRIZES;
             $vo['rebate_rule'] = str2arr($vo['rebate_rule'] ?? '');
         } else {
             $vo['utime'] = time();

app/data/service/RebateCurrentService.php

@@ -6,11 +6,11 @@ use think\admin\Service;
 use think\admin\Exception;
 
 /**
- * 用户奖励配置
- * Class PrizeService
+ * 实时返利服务
+ * Class RebateCurrentService
  * @package app\data\service
  */
-class PrizeService extends Service
+class RebateCurrentService extends Service
 {
     const PRIZE_01 = 'prize_01';
     const PRIZE_02 = 'prize_02';
@@ -75,7 +75,7 @@ class PrizeService extends Service
         $this->order = $this->app->db->name('ShopOrder')->where($map)->find();
         if (empty($this->order)) throw new Exception('订单不存在');
         // 获取用户数据
-        $map = ['id' => $this->order['uid']];
+        $map = ['id' => $this->order['uid'], 'deleted' => 0];
         $this->user = $this->app->db->name('DataUser')->where($map)->find();
         if (empty($this->user)) throw new Exception('用户不存在');
         // 获取推荐用户

app/data/service/RebateMonthService.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace app\data\service;
+
+use think\admin\Exception;
+use think\admin\Service;
+
+/**
+ * 月度返利服务
+ * Class RebateMonthService
+ * @package app\agent\service
+ */
+class RebateMonthService extends Service
+{
+    /** @var string */
+    protected $date;
+
+    /** @var array */
+    protected $user;
+
+    /**
+     * 绑定数据表
+     * @var string
+     */
+    private $table = 'DataUserRebate';
+
+    /**
+     * 指定用户发放奖励
+     * @param mixed $uid
+     * @param array $user
+     * @throws Exception
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function execute($uid, array $user)
+    {
+        if (empty($user)) $user = $this->app->db->name('DataUser')->where(['id' => $uid])->find();
+        if (empty($user)) throw new Exception("指定用户[{$uid}]不存在");
+        $this->app->log->notice("开始处理用户[{$user['id']}]月度[{$this->date}]返利");
+        $this->user = $user;
+        // $this->_prize_02();
+    }
+
+}

app/data/service/RebateQuarterService.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace app\data\service;
+
+use think\admin\Exception;
+use think\admin\Service;
+
+/**
+ * 季度返利服务
+ * Class RebateQuarterService
+ * @package app\data\service
+ */
+class RebateQuarterService extends Service
+{
+    /** @var string */
+    protected $quarter;
+
+    /** @var string */
+    protected $dateAfter;
+
+    /** @var string */
+    protected $dateStart;
+
+    /**
+     * 发放季度奖励
+     * @param string $year 年份
+     * @param string $month 月份
+     * @return RebateQuarterService
+     */
+    public function build(string $year = '', string $month = ''): RebateQuarterService
+    {
+        $year = $year ?: date('Y', '-3 month');
+        $month = $month ?: date('m', '-3 month');
+        $this->quarter = ceil(date('n', mktime(0, 0, 0, $month, 1, $year)) / 3);
+        $this->dateAfter = date('Y-m-t 23:59:59', mktime(0, 0, 0, ($this->quarter - 1) * 3 + 0, 1, date('Y')));
+        $this->dateStart = date('Y-m-01 00:00:00', mktime(0, 0, 0, ($this->quarter - 2) * 3 + 1, 1, date('Y')));
+        return $this;
+    }
+
+    /**
+     * 指定用户发放奖励
+     * @param mixed $uid
+     * @param array $user
+     * @throws Exception
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function execute($uid, $user = [])
+    {
+        if (empty($user)) $user = $this->app->db->name('DataUser')->where(['id' => $uid])->find();
+        if (empty($user)) throw new Exception("指定用户[{$uid}]不存在");
+        $this->app->log->notice("开始处理用户[{$user['id']}]季度[{$this->dateStart} - {$this->dateAfter}]返利");
+        // $this->_prize_05($user);
+    }
+}

app/data/service/RebateYearService.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace app\data\service;
+
+use think\admin\Exception;
+use think\admin\Service;
+
+/**
+ * 年度返利服务
+ * Class RebateYearService
+ * @package app\data\service
+ */
+class RebateYearService extends Service
+{
+    /** @var array */
+    protected $user;
+
+    /** @var string */
+    protected $year;
+
+    /**
+     * 发放年度奖励
+     * @param string $year 年份
+     * @return RebateYearService
+     */
+    public function build(string $year = ''): RebateYearService
+    {
+        $this->year = $year ?: date('Y', strtotime('-1 year'));
+        return $this;
+    }
+
+    /**
+     * 指定用户发放奖励
+     * @param mixed $uid
+     * @param array $user
+     * @throws Exception
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function execute($uid, $user = [])
+    {
+        if (empty($user)) $user = $this->app->db->name('DataUser')->where(['id' => $uid])->find();
+        if (empty($user)) throw new Exception("指定用户[{$uid}]不存在");
+        $this->app->log->notice("开始处理用户[{$user['id']}]年度[{$this->year}]返利");
+        $this->user = $user;
+        // $this->_prize_06();
+    }
+
+}

app/data/sys.php

@@ -8,11 +8,17 @@ use think\Console;
 
 if (app()->request->isCli()) {
     Console::starting(function (Console $console) {
+        $console->addCommand(UserLevel::class);
         $console->addCommand(OrderClear::class);
         $console->addCommand(UserBalance::class);
-        $console->addCommand(UserLevel::class);
         $console->addCommand(UserTransfer::class);
     });
+} else {
+    // 注册订单支付处理事件
+    app()->event->listen('ShopOrderPayment', function ($orderNo) {
+        app()->log->notice("订单支付事件，订单号：{$orderNo}");
+        \app\data\service\RebateCurrentService::instance()->execute($orderNo);
+    });
 }
 
 if (!function_exists('show_goods_spec')) {

vendor/services.php

@@ -1,5 +1,5 @@
 <?php 
-// This file is automatically generated at:2021-03-09 18:14:18
+// This file is automatically generated at:2021-03-10 10:48:21
 declare (strict_types = 1);
 return array (
   0 => 'think\\admin\\Library',