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

<?php

namespace App\Service\v3\Implementations;

use App\Commons\Log;
use App\Constants\v3\LogLabel;
use App\Constants\v3\OrderState;
use App\Model\v3\FinancialRecord;
use App\Model\v3\Order;
use App\Model\v3\OrderMain;
use App\Model\v3\ServiceReward;
use App\Model\v3\Store;
use App\Model\v3\UserRelationBind;
use App\Model\v3\User;
use App\Service\v3\Interfaces\FinancialRecordServiceInterface;
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 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;

    /**
     * @Inject
     * @var OrderOnlineServiceInterface
     */
    protected $orderOnlineService;

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

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

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

            return true;
        } catch (\Exception $e) {
            $this->log->event(LogLabel::SEPARATE_ACCOUNTS_LOG, ['exception' => $e->getMessage()]);
            return false;
        }
    }

    /**
     * @inheritDoc
     */
    public function orderOnlineCompleted($globalOrderId, $userId)
    {
        // 线上订单完成（用户点击确认收货完成/管理后台点击完成/配送员点击完成/自动收货等），进行相关分账
        // 订单
        $orderMain = $this->orderOnlineService->check($globalOrderId, $userId,OrderState::FINISH);

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

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

            // 新商户流水
            foreach ($orders as $key => &$order) {
                $store = Store::query()->find($order['store_id']);
                $this->financialRecordService->storeByOLOrderComp($store->user_id, $orderMain->global_order_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->global_order_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($globalOrderId)
    {
        // 线下订单支付完成
        // 订单
        $orderMain = OrderMain::query()->where(['global_order_id' => $globalOrderId]);

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

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

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

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

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

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

            $message = [];

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

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

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

                $awardAmount = 2;
                // 旧商户流水 TODO 直接移除或后续考虑移除
                $message = [
                    'money' => $awardAmount,
                    'note' => '新用户下单成功，平台奖励',
                ];
                // 新商户流水
                $this->financialRecordService->storeAwardByPlatNewUserOFLOrder($store->user_id, $orderMain->global_order_id, $awardAmount);
                $needAward = true;

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

                    $awardAmount = 0.05;
                    // 旧商户流水 TODO 直接移除或后续考虑移除
                    $message = [
                        'money' => $awardAmount,
                        'note' => '用户下单成功，平台奖励',
                    ];
                    // 新商户流水
                    $this->financialRecordService->storeAwardByTodayFirstOFLOrder($store->user_id, $orderMain->global_order_id, $awardAmount);
                    $needAward = true;

                }
            }

            if ($needAward && $awardAmount) {
                // 发模板消息
                $openid = User::query()->where(['id' => $store['user_id']])->value('openid');
                $res = $this->miniprogramService->sendTemMsgForAward($message['money'], $message['note'], $openid, date('Y-m-d H:i:s', $currentTime));
            }

            // =======线下订单支付完成商户分账 / 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;
        }
    }
}