qimall/addons/QiDingDong/common/service/FundService.php

<?php

namespace addons\QiDingDong\common\service;

use addons\QiDingDong\common\enums\QiDingDongEnums;
use addons\QiDingDong\common\models\QiDingDongBalance;
use addons\QiDingDong\common\models\QiDingDongBalanceLog;
use addons\QiDingDong\common\models\QiDingDongGoods;
use common\enums\AddonsEnum;
use common\enums\RabbitMqEnum;
use common\enums\StatusEnum;
use common\helpers\FormatHelper;
use common\models\mall\Mall;
use common\models\order\Order;

class FundService
{
    public function page(int $mall_id, array $params)
    {
        $where = [
            ['status' => [StatusEnum::DISABLED, StatusEnum::ENABLED]]
        ];

        if (SettingService::isMasterMall($mall_id)) {
            if (!empty($params['keyword'])) {
                $ids = Mall::find()->where(['status' => [StatusEnum::ENABLED, StatusEnum::DISABLED]])
                    ->andWhere(['or', ['like', 'id', $params['keyword']], ['like', 'id', $params['keyword']]])->select('id')->column();
                if (empty($ids)) return [];
                $where[] = ['mall_id' => $ids];
            }
        } else {
            $where[] = ['mall_id' => $mall_id];
        }

        if (!empty($params['date_start'])) $where[] = ['>=', 'created_at', strtotime($params['date_start'])];
        if (!empty($params['date_end'])) $where[] = ['<=', 'created_at', strtotime($params['date_end'])];

        $ret = QiDingDongBalanceLog::listPage([
            'where' => $where,
            'order' => 'id desc',
            'limit' => $params['limit'] ?? 10,
            'with'  => ['mall']
        ]);

        if (!empty(QiDingDongBalanceLog::getStaticError())) return QiDingDongBalanceLog::getStaticError();

        if (!empty($ret['list'])) {
            foreach ($ret['list'] as &$item) {
                $item['type_txt'] = QiDingDongEnums::BALANCE_LOG_TYPE_MAP[$item['type']] ?? '未知类型';
                $item['mall']['logo'] = MallService::getLogo($item['mall_id']);
            }
        }

        return $ret;
    }

    /**
     * 异动
     * @param array $params mall_id, amount, remark, type, direction, order_no, addons
     * @return string|QiDingDongBalanceLog
     */
    public function create(array $params)
    {
        $t = \Yii::$app->db->beginTransaction();
        try {

            $params['status'] = SettingService::isMasterMall($params['mall_id']) ? StatusEnum::DELETE : StatusEnum::ENABLED;

            $params['amount'] = intval(bcmul($params['amount'], 100));

            if ($params['status'] == StatusEnum::ENABLED) { //  非主商城的则需要判断有没有钱
                $account = QiDingDongBalance::findOne(['mall_id' => $params['mall_id']]);
                if (empty($account)) {
                    $account = new QiDingDongBalance();
                    $account->mall_id = $params['mall_id'];
                }

                $balance = $account->balance;
                if ($params['direction'] == StatusEnum::ENABLED) {  //  +
                    $account->balance = bcadd($account->balance, $params['amount']);
                } else {    //  -
                    $account->balance = bcsub($account->balance, $params['amount']);
                }

                if ($account->balance < 0) throw new \Exception("余额不足,账户金额为: " .
                    bcmul(empty($balance) ? 0 : $balance, 0.01, 2));

                if (!$account->save()) throw new \Exception($account->getErrorMessage());

                $params['before_amount'] = $balance;
                $params['after_amount'] = $account->balance;
            }

            $model = new QiDingDongBalanceLog();
            $model->loadDefaultValues();
            if (!$model->load($params, '') || !$model->save()) throw new \Exception($model->getErrorMessage());
            $t->commit();
        } catch (\Exception $exception) {
            $t->rollBack();
            return $exception->getMessage();
        }
        return $model;
    }

    /**
     * 充值
     * @param array $params
     * @param $admin
     * @return string|QiDingDongBalanceLog
     */
    public function recharge(array $params, $admin)
    {
        $data = [
            'mall_id'   => $params['mall_id'],
            'amount'    => abs($params['amount']),
            'remark'    => "ID为[{$admin['id']}]的雇员,为商城[{$params['mall_id']}]操作金额为[{$params['amount']}],其备注信息为[{$params['remark']}]",
            'type'      => $params['amount'] > 0 ? QiDingDongEnums::BALANCE_LOG_TYPE_RECHARGE : QiDingDongEnums::BALANCE_LOG_TYPE_DEDUCT,
            'direction' => $params['amount'] > 0 ? 1 : 2,
            'order_no'  => Order::generateOrderNo('RC'),
            'addons'    => AddonsEnum::ADDONS_NAME_QI_DING_DONG
        ];
        return $this->create($data);
    }

    /**
     * @param array $params
     * @return mixed|string|true|null
     */
    public function setRate(array $params)
    {
        $account = QiDingDongBalance::findOne(['mall_id' => $params['mall_id']]);
        if (empty($account)) {
            $account = new QiDingDongBalance();
            $account->mall_id = $params['mall_id'];
        }

        $account->{$params['field']} = bcmul($params['val'], 100);

        if (!$account->save()) return $account->getErrorMessage();

        //  更新商品价格  1 * 1.2 * 1.5

        try {
            (new GoodsService())->changePrice($params['mall_id']);
        } catch (\Exception $e) {
            return $e->getMessage();
        }

        return true;
    }

    public function statistics(array $params)
    {
        $rQuery = QiDingDongBalanceLog::find()->where(['direction' => 1]);
        $dQuery = QiDingDongBalanceLog::find()->where(['direction' => 2]);
        if (!empty($params['mall_id'])) {
            $rQuery->andWhere(['mall_id' => $params['mall_id']]);
            $dQuery->andWhere(['mall_id' => $params['mall_id']]);
        }
        $r = $rQuery->sum('amount');
        $d = $dQuery->sum('amount');
        return [
            'recharge'  => !empty($r) ? $r : 0,
            'deduct'    => !empty($d) ? $d : 0,
        ];
    }

    public static function asyncRefund(int $id)
    {
        \Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_ORDER, RabbitMqEnum::ORDER_QUEUE, ['id' => $id],
            self::class, 'refund');
    }

    public function refund($params)
    {
        if (empty($params) || empty($params['id'])) return true;
        $id = $params['id'];
        $t = \Yii::$app->db->beginTransaction();
        try {
            $fund = QiDingDongBalanceLog::findOne($id);
            if (empty($fund)) return true;

            $fund->status = StatusEnum::DELETE;
            if (!$fund->save()) throw new \Exception($fund->getErrorMessage());

            $mall = QiDingDongBalance::findOne(['mall_id' => $fund->mall_id]);
            $mall->balance += $fund->amount;
            if (!$mall->save()) throw new \Exception($mall->getErrorMessage());
            $t->commit();
        } catch (\Exception $e) {
            $t->rollBack();
            \Yii::error(FormatHelper::exception($e, __METHOD__));
            return false;
        }
        return true;
    }
}