huahuibao/common/services/xhUserAssetService.php

<?php

namespace common\services;

use bizHd\user\services\UserIntegralService;
use common\models\xhActive;
use Yii;
use common\components\dict;
use common\components\stringUtil;
use common\components\wxUtil;
use common\models\xhUserAsset;

class xhUserAssetService
{

    /**
     * 获取用户资产信息
     */
    public static function getByUserId($userId)
    {
        return xhUserAsset::find()->where(['userId' => $userId])->asArray()->one();
    }

    public static function updateByUserId($userId, $data)
    {
        xhUserAsset::updateByCondition(['userId' => $userId], $data);
    }

    public static function add($userId, $data)
    {
        $user = xhUserAsset::add($data);
        self::getByUserId($userId);
        return $user;
    }

    /**
     * 用户资金变化增加积分
     * 充值、微信付款、余额付款等改变用户资产
     * 此方法用于资金增减并引起积分增加，会员等级升级
     */
    public static function ioChangeAsset($user, $userAsset, $upAssetData, $merchant, $merchantExtend, $order, $capitalType)
    {
        $userId = $user['id'];
        $sjId = $merchant['id'];
        $orderId = isset($order['id']) ? $order['id'] : '';
        $orderSn = isset($order['orderSn']) ? $order['orderSn'] : '';
        $openId = $user['openId'];
        $miniOpenId = isset($user['miniOpenId']) ? $user['miniOpenId'] : '';
        $growth = isset($upAssetData['growth']) ? $upAssetData['growth'] : 0;
        $preLevel = $userAsset['member'];
        $preGrowth = $userAsset['growth'];
        $addGrowth = stringUtil::calcSub($growth, $preGrowth);

        $allTM = xhTMessageService::getList($sjId);

        //没有成长值，后续升级流程不需要再走
        if (empty($growth)) {
            self::updateByUserId($userId, $upAssetData);
            return;
        }
        switch ($capitalType) {//根据流水类型定制通知内容
            case dict::getDict('capitalType', 'xhOrder', 'id'):
                //购买商品
                $goodsNum = $order['goodsNum'];
                $totalFee = $order['actPrice'];
                $name = isset($order['orderName']) && !empty($order['orderName']) ? $order['orderName'] : '门店商品';
                $sourceType = $order['sourceType'];
                if ($sourceType == 0) {
                    $shortTempId = 'OPENTM202297555';//下单成功通知
                    $tempId = isset($allTM[$shortTempId]) ? $allTM[$shortTempId] : 0;
                    if (!empty($tempId)) {
                        $data = [
                            "touser" => $openId,
                            "template_id" => $tempId,
                            "url" => Yii::$app->params['mallDomain'] . "/#/pages/order/detail?account=" . $merchant['id'] . "&shopId=" . $order['shopId'] . "&id=" . $orderId,
                            "data" => [
                                "first" => ["value" => '亲，您已成功下单！', "color" => "#173177"],
                                "keyword1" => ["value" => (string)$orderSn, "color" => "#173177"],
                                "keyword2" => ["value" => $name, "color" => "#173177"],
                                "keyword3" => ["value" => $goodsNum . '件', "color" => "#173177"],
                                "keyword4" => ["value" => number_format($totalFee, 2) . '元', "color" => "#173177"],
                                "keyword5" => ["value" => '微信支付', "color" => "#173177"],
                                "remark" => ["value" => "", "color" => "#173177"]
                            ]
                        ];
                        if (!empty($miniOpenId)) {
                            $data['miniprogram']['appid'] = $merchantExtend['miniAppId'];
                            $data['miniprogram']['pagepath'] = 'pages/order/detail?id=' . $orderId;
                        }
                        wxUtil::sendTaskInform($data, $merchant);
                    }
                } else {
                    if ($addGrowth > 0) {
                        $shortTempId = 'TM00230';
                        $tempId = isset($allTM[$shortTempId]) ? $allTM[$shortTempId] : 0;
                        if (!empty($tempId)) {
                            $changeData = [
                                "touser" => $openId,
                                "template_id" => $tempId,
                                "url" => Yii::$app->params['mallDomain'] . "/center/order-detail?id=$orderId&account=" . $merchant['id'],
                                "data" => [
                                    "first" => ["value" => "您在本店购物获得成长值", "color" => "#173177"],
                                    "FieldName" => ["value" => "会员名称", "color" => "#0F0F0F"],
                                    "Account" => ["value" => $user['userName'], "color" => "#173177"],
                                    "change" => ["value" => "增加", "color" => "#0F0F0F"],
                                    "CreditChange" => ["value" => $addGrowth, "color" => "#173177"],
                                    "CreditTotal" => ["value" => $growth, "color" => "#173177"],
                                    "Remark" => ["value" => "点此查看订单明细、添加编辑收花人信息", "color" => "#173177"],
                                ],
                            ];
                            wxUtil::sendTaskInform($changeData, $merchant);
                        }
                    }
                }
                break;
            case dict::getDict('capitalType', 'xhActiveOrder', 'id'):
                $activeId = $order['activeId'];
                $active = xhActiveService::getById($activeId);
                $newApplyNum = $active['applyNum'] + 1;//活动报名人数+1
                xhActiveService::updateById($activeId, ['applyNum' => $newApplyNum]);
                $shortTempId = 'TM00575';//报名成功通知
                $tempId = isset($allTM[$shortTempId]) ? $allTM[$shortTempId] : 0;
                if (!empty($tempId)) {
                    $changeData = [
                        "touser" => $openId,
                        "template_id" => $tempId,
                        "url" => Yii::$app->params['mallDomain'] . '/active/order?id=' . $orderId . '&account=' . $merchant['id'],
                        "data" => [
                            "first" => ["value" => "您好，您已报名成功", "color" => "#173177"],
                            "keynote1" => ["value" => $active['title'], "color" => "#173177"],
                            "keynote2" => ["value" => date("m-d H:i", $active['startTime']), "color" => "#173177"],
                            "keynote3" => ["value" => $active['address'], "color" => "#173177"],
                            "remark" => ["value" => "欢迎您的参加哦！", "color" => "#173177"],
                        ],
                    ];
                    wxUtil::sendTaskInform($changeData, $merchant);
                }
                break;
            case dict::getDict('capitalType', 'xhRecharge', 'id'):
                $totalBalance = isset($upAssetData['balance']) ? $upAssetData['balance'] : 0;
                $rechargeAmount = $order['amount'];
                $url = Yii::$app->params['mallDomain'] . "/#/pages/home/user?account=" . $merchant['id'];
                $remark = '您当前帐户余额：' . $totalBalance . '元';
                $shortTempId = 'TM00006';
                $tempId = isset($allTM[$shortTempId]) ? $allTM[$shortTempId] : 0;
                if (!empty($tempId)) {
                    $data = [
                        "touser" => $openId,
                        "template_id" => $tempId,
                        "url" => $url,
                        "data" => [
                            "first" => ["value" => $remark, "color" => "#173177"],
                            "accountType" => ["value" => '会员类型', "color" => "#000000"],
                            "account" => ["value" => '点击查看', "color" => "#173177"],
                            "amount" => ["value" => $rechargeAmount . '元', "color" => "#173177"],
                            "result" => ["value" => '充值成功', "color" => "#173177"],
                            "remark" => ["value" => '', "color" => "#173177"]]
                    ];
                    if (!empty($miniOpenId)) {
                        $data['miniprogram']['appid'] = $merchantExtend['miniAppId'];
                        $data['miniprogram']['pagepath'] = 'pages/home/user';
                    }
                    wxUtil::sendTaskInform($data, $merchant);
                }
                break;
            case dict::getDict('capitalType', 'xhUserUnite', 'id'):
                $addIntegral = 0;
                if ($addIntegral > 0) {
                    $shortTempId = 'TM00230';
                    $tempId = isset($allTM[$shortTempId]) ? $allTM[$shortTempId] : 0;
                    if (!empty($tempId)) {
                        $changeData = [
                            "touser" => $openId,
                            "template_id" => $tempId,
                            "url" => Yii::$app->params['mallDomain'] . '/center/right?account=' . $merchant['id'],
                            "data" => [
                                "first" => ["value" => "支付宝绑定成功，获得积分：", "color" => "#173177"],
                                "FieldName" => ["value" => "会员名称", "color" => "#0F0F0F"],
                                "Account" => ["value" => $user['userName'], "color" => "#173177"],
                                "change" => ["value" => "增加", "color" => "#0F0F0F"],
                                "CreditChange" => ["value" => $addIntegral, "color" => "#173177"],
                                "CreditTotal" => ["value" => $growth, "color" => "#173177"],
                                "Remark" => ["value" => "点此查看明细！", "color" => "#173177"],
                            ],
                        ];
                        wxUtil::sendTaskInform($changeData, $merchant);
                    }
                }
                break;
            default:
        }
        //新增积分
        UserIntegralService::increaseToUpgrade($preGrowth, $growth, $preLevel, $userId, $sjId, $merchantExtend);
        self::updateByUserId($userId, $upAssetData);
    }

}