lanzu_api_2021-12-26/app/Service/SeparateAccountsService.php

<?php

namespace App\Service;

use App\Commons\Log;
use App\Constants\LogLabel;
use App\Model\FinancialRecord;
use App\Model\Order;
use App\Model\OrderMain;
use App\Model\ServiceReward;
use App\Model\Store;
use App\Model\StoreAccount;
use App\Model\SystemConfig;
use App\Model\UserBalance;
use App\Model\UserRelationBind;
use Hyperf\DbConnection\Db;
use Hyperf\Di\Annotation\Inject;

class SeparateAccountsService implements SeparateAccountsServiceInterface
{
    /**
     * @Inject
     * @var Log
     */
    protected $log;

    /**
     * @Inject
     * @var UserServiceInterface
     */
    protected $userService;

    /**
     * @Inject
     * @var FinancialRecordServiceInterface
     */
    protected $financialRecordService;

    /**
     * @Inject
     * @var MiniprogramServiceInterface
     */
    protected $miniprogramService;

    /**
     * @inheritDoc
     */
    public function orderOnlinePaid($global_order_id)
    {
        // 线上订单支付完成
        // 订单
        $orderMain = OrderMain::query()
            ->where(['global_order_id' => $global_order_id])
            ->first();

        if (empty($orderMain)) {
            return false;
        }

        // =======用户支付流水 / Start=======
        $this->financialRecordService->userByOFLOrderPaid($orderMain->user_id, $orderMain->id, $orderMain->money);
        // =======用户支付流水 / End=======
    }

    /**
     * @inheritDoc
     */
    public function orderOnlineCompleted($global_order_id)
    {
        // 线上订单完成（用户点击确认收货完成/管理后台点击完成/配送员点击完成/自动收货等），进行相关分账
        // 订单
        $orderMain = OrderMain::query()
            ->where(['global_order_id' => $global_order_id])
            ->whereIn('state', [OrderMain::ORDER_STATE_COMPLETE,OrderMain::ORDER_STATE_EVALUATED,OrderMain::ORDER_STATE_UNREFUND])
            ->first();

        if (empty($orderMain)) {
            return false;
        }

        $currentTime = time();
        Db::beginTransaction();
        try {

            // =======商户订单收入流水 / Start=======
            // 查询子订单
            $orders = Order::query()->select(['id', 'money', 'user_id', 'store_id', 'pay_time'])
                ->where(['order_main_id' => $orderMain->id])
                ->get()->toArray();

            foreach ($orders as $key => &$order) {

                // 商户
                $store = Store::find($order['store_id']);

                // 旧商户流水基础数据  TODO 直接移除或后续考虑移除
                $storeAccountBase = [
                    'user_id' => $order['user_id'],
                    'order_id' => $order['id'],
                    'store_id' => $order['store_id'],
                    'type' => 1,
                    'time' => date('Y-m-d H:i:s', $currentTime),
                    'add_time' => $currentTime,
                ];

                // 旧商户流水 TODO 直接移除或后续考虑移除
                $storeAccount = [
                    'money' => $order['money'],
                    'note' => '线上订单',
                    'category' => 1,
                ];
                StoreAccount::query()->insert(array_merge($storeAccountBase, $storeAccount));

                // 新商户流水
                $this->financialRecordService->storeByOLOrderComp($store->user_id, $orderMain->id ,$order['money']);
            }
            // =======商户订单收入流水 / End=======

            // =======社区服务点分账 / Start=======
            // 前提：用户线上下单并且订单完成
            // 奖励规则A：用户是平台新用户，奖励社区服务点平台新用户奖励x元+平台新用户首单奖励y元+订单商品金额z%的分成
            // 奖励规则B：用户是非新用户，奖励社区服务点订单实际支付金额z%的分成
            // =======社区服务点分账 / Start=======

            // 当前用户的社区服务点绑定关系
            $communityBind = UserRelationBind::query()
                ->where(['bind_type' => UserRelationBind::BIND_TYPE_COMMUNITY, 'user_id' => $orderMain->user_id])
                ->first();

            if ($communityBind) {

                // 奖励/分账金额
                $award = ServiceReward::query()->where(['type' => ServiceReward::TYPE_COMMUNITY])->first();
                if (empty($award)) {
                    Db::rollBack();
                    return false;
                }

                $award = $award->set_reward;

                // 平台新用户
                if ($this->userService->isPlatformNewUser($orderMain->user_id, $orderMain->id)) {
                    $this->financialRecordService->communityAwardByPlatNewUser($communityBind->source_id, $orderMain->global_order_id, $award['new_user_reward']);
                    $this->financialRecordService->communityAwardByPlatNewUserFirstOLOrder($communityBind->source_id, $orderMain->global_order_id, $award['first_reward']);
                }

                // 账单分成
                $money = bcmul($orderMain->money, bcdiv($award['flow_reward'], 100, 6), 2);
                $this->financialRecordService->communitySeparateAccountsByOrderComp($communityBind->source_id, $orderMain->global_order_id, $money);
            }

            // =======社区服务点分账 / End=======

            Db::commit();
            return true;

        } catch (\Exception $e) {

            $this->log->event(LogLabel::SEPARATE_ACCOUNTS_LOG, ['exception' => $e->getMessage(), 'order_main' => json_encode($orderMain)]);
            Db::rollBack();
            return false;
        }

    }

    /**
     * @inheritDoc
     */
    public function orderOfflinePaid($global_order_id)
    {
        // 线下订单支付完成
        // 订单
        $orderMain = OrderMain::query()
            ->where(['global_order_id' => $global_order_id])
            ->first();

        if (empty($orderMain)) {
            return false;
        }

        // 查询子订单，当面付目前实际上只有一个子订单
        $order = Order::query()->select(['id', 'money', 'user_id', 'store_id', 'pay_time'])
            ->where(['order_main_id' => $orderMain->id])
            ->first();

        if (empty($order)) {
            return false;
        }

        $currentTime = time();
        Db::beginTransaction();
        try {

            // =======用户支付流水 / Start=======
            $this->financialRecordService->userByOFLOrderPaid($orderMain->user_id, $orderMain->id, $orderMain->money);
            // =======用户支付流水 / End=======

            // =======线下订单支付完成商户分账 / Start=======
            // 前提：用户线上下单并且支付完成
            // 奖励规则A：用户是平台新用户，奖励商户2元
            // 奖励规则B：用户是非新用户，但是是商户当日首单，奖励商户0.05元
            // =======线下订单支付完成商户分账 / Start=======

            // 旧商户订单流水基础数据 TODO 直接移除或后续考虑移除
            $storeAccountBase = [
                'user_id' => $order->user_id,
                'order_id' => $order->id,
                'store_id' => $order->store_id,
                'type' => 1,
                'time' => date('Y-m-d H:i:s', $currentTime),
                'add_time' => $currentTime,
            ];

            // 旧商户订单流水 TODO 直接移除或后续考虑移除
            $storeAccount = [
                'money' => $order->money,
                'note' => '当面付订单收入',
                'category' => 2,
            ];
            StoreAccount::query()->insert(array_merge($storeAccountBase, $storeAccount));

            // 商户
            $store = Store::find($order->store_id);

            // 新商户订单流水
            $this->financialRecordService->storeByOFLOrderComp($store->user_id, $orderMain->id, $order->money);

            $needAward = false;
            $awardAmount = 0;
            // 新用户商户奖励
            if ($this->userService->isPlatformNewUser($orderMain->user_id, $orderMain->id)) {

                $awardAmount = SystemConfig::query()->where(['type' => 1, 'menu_name' => 'award_new_user'])->value('value');
                // 旧商户流水 TODO 直接移除或后续考虑移除
                $storeAccount = [
                    'money' => $awardAmount,
                    'note' => '新用户下单成功，平台奖励',
                    'category' => 3,
                ];
                // 新商户流水
                $this->financialRecordService->storeAwardByPlatNewUserOFLOrder($store->user_id, $orderMain->id, $awardAmount);
                $needAward = true;

            } else {
                // 商户当日首单奖励
                if (
                    $this->userService->isStoreFirstOrderToday(
                        $order->user_id,
                        $order->store_id,
                        $order->id,
                        FinancialRecord::OFL_FIRST_AWARD_LIMIT_AMOUNT
                    )
                ) {

                    $awardAmount = SystemConfig::query()->where(['type' => 1, 'menu_name' => 'award_each_order'])->value('value');
                    // 旧商户流水 TODO 直接移除或后续考虑移除
                    $storeAccount = [
                        'money' => $awardAmount,
                        'note' => '用户下单成功，平台奖励',
                        'category' => 4,
                    ];
                    // 新商户流水
                    $this->financialRecordService->storeAwardByTodayFirstOFLOrder($store->user_id, $orderMain->id, $awardAmount);
                    $needAward = true;

                }
            }

            if ($needAward && $awardAmount) {

                // 旧商户流水 TODO 直接移除或后续考虑移除
                StoreAccount::query()->insert(array_merge($storeAccountBase, $storeAccount));

                // 发模板消息
                $openid = Users::query()->where(['id' => $store['user_id']])->value('openid');
                $res = $this->miniprogramService->sendTemMsgForAward($storeAccount['money'], $storeAccount['note'], $openid, $storeAccountBase['time']);
            }

            // =======线下订单支付完成商户分账 / End=======

            Db::commit();
            return true;
        } catch (\Exception $e) {

            $this->log->event(LogLabel::SEPARATE_ACCOUNTS_LOG, ['exception' => $e->getMessage(), 'order_main' => json_encode($orderMain)]);
            Db::rollBack();
            return false;
        }
    }
}