From f287bb7d32b6f5004868dd36dc96a58447575edd Mon Sep 17 00:00:00 2001
From: weigang <mr.shuixiang@aliyun.com>
Date: Sat, 12 Sep 2020 17:12:08 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E5=95=86=E5=88=86=E8=B4=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../SeparateAccountsService.php               | 75 +++++++++++++++++++
 1 file changed, 75 insertions(+)

diff --git a/app/Service/v3/Implementations/SeparateAccountsService.php b/app/Service/v3/Implementations/SeparateAccountsService.php
index 2e5054a..444ddf7 100644
--- a/app/Service/v3/Implementations/SeparateAccountsService.php
+++ b/app/Service/v3/Implementations/SeparateAccountsService.php
@@ -5,7 +5,11 @@ namespace App\Service\v3\Implementations;
 use App\Commons\Log;
 use App\Constants\v3\LogLabel;
 use App\Constants\v3\OrderState;
+use App\Constants\v3\OrderType;
 use App\Model\v3\FinancialRecord;
+use App\Model\v3\Market;
+use App\Model\v3\MmInfo;
+use App\Model\v3\MpInfo;
 use App\Model\v3\Order;
 use App\Model\v3\OrderMain;
 use App\Model\v3\ServiceReward;
@@ -17,8 +21,10 @@ use App\Service\v3\Interfaces\MiniprogramServiceInterface;
 use App\Service\v3\Interfaces\OrderOnlineServiceInterface;
 use App\Service\v3\Interfaces\SeparateAccountsServiceInterface;
 use App\Service\v3\Interfaces\UserServiceInterface;
+use App\TaskWorker\SSDBTask;
 use Hyperf\DbConnection\Db;
 use Hyperf\Di\Annotation\Inject;
+use Hyperf\Utils\ApplicationContext;
 
 class SeparateAccountsService implements SeparateAccountsServiceInterface
 {
@@ -90,6 +96,8 @@ class SeparateAccountsService implements SeparateAccountsServiceInterface
         Db::beginTransaction();
         try {
 
+            $ssdb = ApplicationContext::getContainer()->get(SSDBTask::class);
+
             // =======商户订单收入流水 / Start=======
             // 查询子订单
             $orders = Order::query()
@@ -142,6 +150,73 @@ class SeparateAccountsService implements SeparateAccountsServiceInterface
 
             // =======社区服务点分账 / End=======
 
+            // =======服务商、市场经理奖励分账 / Start=======
+            // 前提A：新用户下单并且订单完成（线上、线下都行）
+            // 奖励规则A：用户是平台新用户，奖励市场经理 1 元，服务商 0.5 元，如果是线上订单，服务商有6%的订单分成
+            // 前提B：新商户旗下产生 10 个新用户
+            // 奖励规则B：奖励市场经理 25 元，服务商 10 元（仅仅奖励一次）
+            // 前提C：用户线上下单并且订单完成
+            // 奖励规则C：奖励服务商账单 6% 分成
+            // 判断是新商户：入驻绑定的时候把关系存在SSDB
+            // =======服务商、市场经理奖励分账 / Start=======
+
+            $MmMpAwardConfig = [
+                'mm_new_user' => 1,
+                'mm_new_store' => 25,
+                'mp_new_user' => 0.5,
+                'mp_new_store' => 10,
+                'separate_rate' => 6,
+                'limit_new_user_number' => 10,
+            ];
+            foreach ($orders as $key => &$order) {
+
+                // 当前订单（子）对应商户是否有市场经理绑定关系
+                $store = Store::query()->find($order['store_id']); // 商户
+                $mmInfo = MmInfo::query()->where(['user_id' =>  $store->mm_user_id])->first(); // 市场经理
+                $market = Market::query()->find($mmInfo->market_id); // 市场
+                $mpInfo = MpInfo::query()->find($market->mp_id); // 服务商
+
+                $ssdbName = 'mm_'.$mmInfo->id.'_award_'.$store->id;
+
+                // TODO 暂时在这里初始化
+                if (!$ssdb->exec('hexists', $ssdbName, 'is_awarded')) {
+                    $ssdb->exec('hset', $ssdbName, 'is_awarded', 0);
+                }
+
+                if (!$ssdb->exec('hexists', $ssdbName, 'new_user_number')) {
+                    $ssdb->exec('hset', $ssdbName, 'new_user_number', 0);
+                }
+
+                // 平台新用户
+                if ($this->userService->isPlatformNewUser($orderMain->user_id, $orderMain->id)) {
+                    $ssdb->exec('hincr', $ssdbName, 'new_user_number', 1);
+                    $this->financialRecordService->mmAwardByPlatNewUser($mmInfo->admin_user_id, $globalOrderId, $MmMpAwardConfig['mm_new_user'], '发展新用户'); // 市场经理新用户奖励
+                    $this->financialRecordService->mpAwardByPlatNewUser($mpInfo->admin_user_id, $globalOrderId, $MmMpAwardConfig['mp_new_user'], '市场经理「'.$mmInfo->name.'」发展新用户'); // 服务商新用户奖励
+                }
+
+                $record = $ssdb->exec('hgetall', $ssdbName);
+
+                // 判断是否已经奖励过新拓展商户的奖励，没有的话判断新用户个数是否达到要求，进行奖励
+                if (
+                    !empty($record)
+                    &&$record['is_awarded']==0
+                    &&$record['new_user_number']>=$MmMpAwardConfig['limit_new_user_number']
+                ) { // 存在记录且未发放奖励，同时新用户数已经超过10
+                    $ssdb->exec('hset', $ssdbName, 'is_awarded', 1);
+                    $this->financialRecordService->mmAwardByNewStore($mmInfo->admin_user_id, $globalOrderId, $MmMpAwardConfig['mm_new_store'], '发展新商户【'.$store->name.'】'); // 市场经理新商户奖励
+                    $this->financialRecordService->mpAwardByNewStore($mpInfo->admin_user_id, $globalOrderId, $MmMpAwardConfig['mp_new_store'], '市场经理「'.$mmInfo->name.'」发展新商户【'.$store->name.'】'); // 服务商新商户奖励
+                }
+
+            }
+
+            // 线上订单服务商分账
+            if ($orderMain->type == OrderType::ONLINE) {
+                $money = bcmul($orderMain->money, bcdiv($MmMpAwardConfig['separate_rate'], 100, 6), 2);
+                $this->financialRecordService->mpSeparateAccountByOLOrderComp($mpInfo->admin_user_id, $globalOrderId, $money);
+            }
+
+            // =======服务商、市场经理奖励分账 / End=======
+
             Db::commit();
             return true;