huahuibao/biz/user/classes/UserClass.php

<?php

namespace biz\user\classes;

use biz\merchant\classes\MerchantAssetClass;
use biz\merchant\classes\MerchantClass;
use biz\merchant\services\MerchantService;
use biz\message\classes\ChatClass;
use biz\user\services\UserIntegralService;
use common\components\business;
use common\components\configDict;
use common\components\util;
use common\components\wxUtil;
use common\services\ImageService;
use common\services\xhMerchantExtendService;
use common\services\xhUserCapitalService;
use common\services\xhUserIntegralService;
use common\services\xhUserMergeService;
use Yii;
use biz\base\classes\BaseClass;

class UserClass extends BaseClass
{

    public static $baseFile = '\biz\user\models\User';

    //用户和收入的来源
    public static $sourceType = [
        2 => '朋友圈',
        1 => '门店',
        0 => '公众号',
        3 => '淘宝',
    ];

    //用户来源分类
    public static $userSource = [
        0 => ['name' => 'official', 'title' => '公众号'],
        1 => ['name' => 'alipay', 'title' => '支付宝'],
        2 => ['name' => 'mini', 'title' => '小程序'],
    ];

    //用户来源分类ID
    public static $userSourceId = [
        'official' => ['id' => 0, 'name' => 'official'],
        'alipay' => ['id' => 1, 'name' => 'alipay'],
        'mini' => ['id' => 2, 'name' => 'mini'],
    ];

    //组合客户基本和资产信息
    public static function groupUserBaseInfo($list, $sensitive = true)
    {
        //取客户资产
        $ids = array_column($list, 'id');
        $ids = array_unique($ids);
        $asset = UserAssetClass::getByUserIds($ids, 'userId');

        $merchantIdList = array_column($list, 'merchantId');
        $merchantIdList = array_filter(array_unique($merchantIdList));
        $merchantList = MerchantService::getByIds($merchantIdList, null, 'id');

        foreach ($list as $key => $val) {
            $userId = $val['id'];
            //访问时间
            $visitTime = date("m-d H:i", $val['visitTime']);
            if (date("m-d") == date("m-d", $val['visitTime'])) {
                $visitTime = '今天 ' . date("H:i", $val['visitTime']);
            }
            $list[$key]['visitTimeFormat'] = $visitTime;
            $list[$key]['userAsset'] = isset($asset[$userId]) ? $asset[$userId] : [];
            //客户发来新消息数
            $list[$key]['unReadNum'] = ChatClass::getUnreadNum($userId);
            $list[$key] = business::formatUserAvatar($list[$key]);
            $merchantId = $val['merchantId'];
            $list[$key]['merchantName'] = isset($merchantList[$merchantId]['merchantName']) ? $merchantList[$merchantId]['merchantName'] : '';
            //敏感信息不要输出
            if ($sensitive) {
                unset($list[$key]['password']);
                unset($list[$key]['payPassword']);
            }
        }
        return $list;
    }

    //获取客户基本和资产信息 shish 2019.11.30
    public static function getUserInfo($id, $sensitive = true)
    {
        $list = self::getByIds([$id]);
        $data = self::groupUserBaseInfo($list, $sensitive);
        return current($data);
    }

    //根据手机号查询客户 shish 2019.12.1
    public static function getByMobile($mobile, $merchantId)
    {
        return self::getByCondition(['merchantId' => $merchantId, 'mobile' => $mobile]);
    }

    public static function generateUser($getUserInfo, $merchantId)
    {
        $date = date("Y-m-d H:i:s");
        $time = time();
        //替换掉微信名称不支持的图片
        $userName = isset($getUserInfo['userName']) ? preg_replace('/[\x{10000}-\x{10FFFF}]/u', '', $getUserInfo['userName']) : '';
        $getUserInfo['userName'] = $userName;
        $getUserInfo['nickName'] = $userName;
        $getUserInfo['realName'] = isset($getUserInfo['realName']) && !empty($getUserInfo['realName']) ? $getUserInfo['realName'] : '';
        $getUserInfo['sex'] = isset($getUserInfo['sex']) ? $getUserInfo['sex'] : 0;//未知
        $getUserInfo['identity'] = 0;
        $subscribe = isset($getUserInfo['subscribe']) ? $getUserInfo['subscribe'] : 0;
        $getUserInfo['subscribe'] = $subscribe;
        $getUserInfo['merchantId'] = $merchantId;
        $getUserInfo['status'] = 0;
        //默认没有完整用户信息
        $isFull = isset($getUserInfo['headImgUrl']) && !empty($getUserInfo['headImgUrl']) ? 1 : 0;
        $getUserInfo['isFull'] = $isFull;
        $getUserInfo['createTime'] = $date;
        $getUserInfo['avatar'] = '';
        $getUserInfo['password'] = '';
        $getUserInfo['payPassword'] = '';
        $getUserInfo['mobile'] = isset($getUserInfo['mobile']) ? $getUserInfo['mobile'] : '';
        $getUserInfo['addTime'] = $time;
        $getUserInfo['visitTime'] = $time;
        $getUserInfo['source'] = isset($getUserInfo['source']) ? $getUserInfo['source'] : 0;
        $getUserInfo['hasSubscribe'] = 0;
        //生成用户基础信息
        $user = self::add($getUserInfo);
        $userId = $user['id'];
        if (empty($user['userName'])) {
            self::updateById($userId, ['userName' => $userId,'nickname'=>$userId]);
        }

        $assetData = ['userId' => $userId, 'merchantId' => $merchantId, 'createTime' => $date];
        //生成用户资产信息
        UserAssetClass::add($assetData);

        //保存头像
        if (isset($getUserInfo['headImgUrl']) && !empty($getUserInfo['headImgUrl'])) {
            if (empty($preUser) || (isset($preUser['avatar']) && empty($preUser['avatar']))) {
                $imgUrl = $getUserInfo['headImgUrl'];
                $currentImg = ImageService::generateAvatar($merchantId, $imgUrl);
                if (!empty($currentImg)) {
                    self::updateById($userId, ['avatar' => $currentImg]);
                }
            }
        }

        //商家客户粉丝 +1
        $type = $subscribe == 1 ? 3 : 1;
        MerchantAssetClass::addUserNum($merchantId, $type);
        return $user;
    }

    public static function updateUser($originalUser, $getUserInfo, $merchantId)
    {
        $data = [];
        $assetData = [];
        $userId = $originalUser['id'];
        //替换掉微信不支持的图片
        $userName = isset($getUserInfo['userName']) ? preg_replace('/[\x{10000}-\x{10FFFF}]/u', '', $getUserInfo['userName']) : '';
        if (!empty($userName)) {
            $data['userName'] = $userName;
            $data['nickName'] = $userName;
        }
        if (isset($getUserInfo['openId']) && !empty($getUserInfo['openId'])) {
            $openId = $getUserInfo['openId'];
            $data['openId'] = $openId;
        }
        if (isset($getUserInfo['miniOpenId']) && !empty($getUserInfo['miniOpenId'])) {
            $data['miniOpenId'] = $getUserInfo['miniOpenId'];
        }
        if (isset($getUserInfo['unionId']) && !empty($getUserInfo['unionId'])) {
            $data['unionId'] = $getUserInfo['unionId'];
        }
        if (isset($getUserInfo['sex'])) {
            $data['sex'] = $getUserInfo['sex'];
        }
        if (isset($getUserInfo['subscribe'])) {
            $data['subscribe'] = $getUserInfo['subscribe'];
        }
        if (isset($getUserInfo['subscribeTime'])) {
            $data['subscribeTime'] = $getUserInfo['subscribeTime'];
        }
        $data['merchantId'] = $merchantId;
        if (isset($getUserInfo['alipayId']) && !empty($getUserInfo['alipayId'])) {
            $data['alipayId'] = $getUserInfo['alipayId'];
        }
        if (isset($getUserInfo['isFull'])) {
            $data['isFull'] = $getUserInfo['isFull'];
        }
        if (isset($getUserInfo['headImgUrl']) && !empty($getUserInfo['headImgUrl'])) {
            $data['isFull'] = 1;
        }
        /**更新头像**/
        if (isset($originalUser['avatar']) == false || empty($originalUser['avatar'])) {
            if (isset($getUserInfo['headImgUrl']) && !empty($getUserInfo['headImgUrl'])) {
                $imgUrl = $getUserInfo['headImgUrl'];
                $name = ImageService::generateAvatar($merchantId, $imgUrl);
                if (!empty($name)) {
                    $data['avatar'] = $name;
                }
            }
        }

        /**商家增加粉丝**/
        if (isset($originalUser['subscribe']) && $originalUser['subscribe'] == 0 && isset($getUserInfo['subscribe']) && $getUserInfo['subscribe'] == 1) {
            MerchantAssetClass::addUserNum($merchantId, 2);
        }

        //更新访问时间
        self::updateById($userId, $data);
        if (!empty($assetData)) {
            UserAssetClass::updateByUserId($userId, $assetData);
        }
        $user = self::getById($userId);
        return $user;
    }

    public static function getByMiniOpenId($miniOpenId, $merchantId)
    {
        return self::getByCondition(['merchantId' => $merchantId, 'miniOpenId' => $miniOpenId]);
    }

    public static function getByAlipayId($alipayId, $merchantId)
    {
        return self::getByCondition(['merchantId' => $merchantId, 'alipayId' => $alipayId]);
    }

    public static function getByOpenId($openId, $merchantId)
    {
        return self::getByCondition(['merchantId' => $merchantId, 'openId' => $openId]);
    }

    public static function getByUnionId($unionId, $merchantId)
    {
        return self::getByCondition(['merchantId' => $merchantId, 'unionId' => $unionId]);
    }

    /**
     * 合并用户
     */
    public static function mergeUser($delUser, $retainUser)
    {
        $connection = Yii::$app->db;//事务处理
        $transaction = $connection->beginTransaction();
        try {

            $delUserId = $delUser['id'];
            $retainUserId = $retainUser['id'];

            $userName = $retainUser['userName'];
            $merchantId = $retainUser['merchantId'];

            //合并记录
            $return = UserMergeClass::add(['delUserId' => $delUserId, 'merchantId' => $merchantId, 'retainUserId' => $retainUserId, 'addTime' => time(), 'createTime' => date("Y-m-d H:i:s")]);
            $targetId = $return['id'];

            $typeList = configDict::getConfig('capitalType');
            $capitalType = $typeList['xhMergeUser']['id'];
            $now = time();
            $date = date("Y-m-d H:i:s");

            //数据迁移
            $updateData = [];
            $updateKey = [
                'mobile',
                'password',
                'payPassword',
                'subscribe',
                'hasSubscribe',
                'subscribeTime',
                'alipayId',
                'openId',
                'miniOpenId',
                'unionId',
            ];
            foreach ($updateKey as $key) {
                if (isset($delUser[$key]) && !empty($delUser[$key])) {
                    $updateData[$key] = $delUser[$key];
                }
            }
            if (!empty($updateData)) {
                $updateData['visitTime'] = time();
                self::updateById($retainUserId, $updateData);
            }

            //资产累加
            $addData = [];
            $delUserAsset = UserAssetClass::getByUserId($delUserId);
            $retainUserAsset = UserAssetClass::getByUserId($retainUserId);
            if (!empty($delUserAsset)) {
                //累计消费
                $delTotalExpend = isset($delUserAsset['totalExpend']) ? $delUserAsset['totalExpend'] : 0;
                if (!empty($delTotalExpend)) {
                    $addData['totalExpend'] = $retainUserAsset['totalExpend'] + $delTotalExpend;
                    //变化记录要增加
                }
                //累计收入
                $delTotalIncome = isset($delUserAsset['totalIncome']) ? $delUserAsset['totalIncome'] : 0;
                if (!empty($delTotalIncome)) {
                    $addData['totalIncome'] = $retainUserAsset['totalIncome'] + $delTotalIncome;
                    //变化记录要增加
                }
                //累计充值
                $delTotalRecharge = isset($delUserAsset['totalRecharge']) ? $delUserAsset['totalRecharge'] : 0;
                if (!empty($delTotalRecharge)) {
                    $addData['totalRecharge'] = $retainUserAsset['totalRecharge'] + $delTotalRecharge;
                    //变化记录要增加
                }
                //累计购买数量
                $delTotalBuyNum = isset($delUserAsset['totalBuyNum']) ? $delUserAsset['totalBuyNum'] : 0;
                if (!empty($delTotalBuyNum)) {
                    $addData['totalBuyNum'] = $retainUserAsset['totalBuyNum'] + $delTotalBuyNum;
                    //变化记录要增加
                }
                //余额
                $delBalance = isset($delUserAsset['balance']) ? $delUserAsset['balance'] : 0;
                if (!empty($delBalance)) {
                    $addData['balance'] = $retainUserAsset['balance'] + $delBalance;
                    //变化记录要增加
                    $userCapitalData = [
                        'relateId' => $targetId,
                        'balance' => $addData['balance'],
                        'totalIncome' => $retainUserAsset['totalIncome'] + $delBalance,
                        'totalExpend' => $retainUserAsset['totalExpend'],
                        'amount' => $delBalance,
                        'io' => 1,
                        'payWay' => 0,
                        'event' => '帐号合并',
                        'merchantId' => $merchantId,
                        'userId' => $retainUserId,
                        'alipayId' => '',
                        'userName' => $userName,
                        'operateId' => 0,
                        'createTime' => $date,
                        'addTime' => $now,
                        'capitalType' => $capitalType,
                    ];
                    xhUserCapitalService::add($userCapitalData);//用户资金流水增加
                }

                //成长值
                $delGrowth = isset($delUserAsset['growth']) ? $delUserAsset['growth'] : 0;
                if (!empty($delGrowth)) {
                    $addData['growth'] = $retainUserAsset['growth'] + $delGrowth;
                    //注意会员等级要进行重新计算！！！！！还有积分变化记录要增加
                    $growthData = [
                        'userId' => $retainUserId,
                        'userName' => $userName,
                        'merchantId' => $merchantId,
                        'relateId' => $targetId,
                        'integral' => $addData['growth'],
                        'num' => $delGrowth,
                        'io' => 1,
                        'payWay' => 0,
                        'alipayId' => '',
                        'event' => '帐号合并',
                        'operatorId' => 0,
                        'createTime' => $date,
                        'capitalType' => $capitalType,
                        'addTime' => $now,
                    ];
                    UserGrowthClass::add($growthData);
                    //成长值增加升级
                    $preLevel = $retainUserAsset['member'];
                    $preGrowth = $retainUserAsset['growth'];
                    $merchantExtend = xhMerchantExtendService::getByMerchantId($merchantId);
                    UserIntegralService::increaseToUpgrade($preGrowth, $addData['growth'], $preLevel, $retainUserId, $merchantId, $merchantExtend);
                }
                if (!empty($addData)) {
                    UserAssetClass::updateByUserId($retainUserId, $addData);
                }
            }

            //删除用户
            $clearData = ['openId' => '', 'miniOpenId' => '', 'unionId' => '', 'alipayId' => '', 'merchantId' => 0];
            self::updateById($delUserId, $clearData);
            UserAssetClass::updateByUserId($delUserId, ['merchantId' => 0]);
            //清除支付宝用户
            $clearAlipayData = ['alipayId' => '', 'alipayAccount' => '', 'merchantId' => 0];
            UserAlipayClass::updateByUserId($delUserId, $clearAlipayData);

            $transaction->commit();

            return self::getById($retainUserId);

        } catch (Exception $e) {
            $transaction->rollBack();
            Yii::info("合并userid $delUserId $retainUserId 时事务回滚，原因：" . $e->getMessage());
            return [];
        }

    }

    //找出相同unionId的用户
    public static function getSameUnionId($merchantId, $unionId)
    {
        return self::getAllByCondition(['merchantId' => $merchantId, 'unionId' => $unionId], 'addTime desc', '*');
    }

    public static function valid($info, $merchantId)
    {
        if (empty($info)) {
            util::fail('找不到客户');
        }
        if ($info['merchantId'] != $merchantId) {
            util::fail('这个客户您没有权限操作');
        }
    }

    //根据消费次数和有没领优惠券来判断是不是新人
    public static function newUser($userInfo)
    {
        $asset = isset($userInfo['userAsset']) ? $userInfo['userAsset'] : [];
        $totalBuyNum = isset($asset['totalBuyNum']) ? $asset['totalBuyNum'] : 0;
        if ($totalBuyNum > 0) {
            return false;
        }
        $getCouponNum = isset($asset['getCouponNum']) ? $asset['getCouponNum'] : 0;
        if ($getCouponNum) {
            return false;
        }
        return true;
    }

    public static function getUserByIds($ids)
    {
        $info = self::getByIds($ids, null, 'id');
        if (empty($info)) {
            return [];
        }
        $data = self::groupUserBaseInfo($info);
        return $data;
    }

    //将微信和小程序获取的用户信息转成可以保存的用户信息
    public static function switchUserInfo($info, $source)
    {
        $openId = '';
        if (isset($info['openid']) && !empty($info['openid'])) {
            $openId = $info['openid'];
            unset($info['openId']);
        }
        if (isset($info['openId']) && !empty($info['openId'])) {
            $openId = $info['openId'];
            unset($info['openId']);
        }
        if (!empty($openId)) {
            $userSource = self::$userSourceId;
            switch ($source) {
                case $userSource['mini']['name']:
                    $info['miniOpenId'] = $openId;
                    break;
                case $userSource['official']['name']:
                    $info['openId'] = $openId;
                    break;
                default:

            }
        }
        if (isset($info['nickName'])) {
            $info['userName'] = $info['nickname'];
            $info['nickName'] = $info['nickName'];
        }
        if (isset($info['unionid'])) {
            $info['unionId'] = $info['unionid'];
        }
        if (isset($info['unionId'])) {
            $info['unionId'] = $info['unionId'];
        }
        if (isset($info['headimgurl'])) {
            $info['headImgUrl'] = $info['headimgurl'];
        }
        if (isset($info['avatarUrl'])) {
            $info['headImgUrl'] = $info['avatarUrl'];
        }
        if (isset($info['subscribe_time'])) {
            $info['subscribeTime'] = $info['subscribe_time'];
        }
        if (isset($info['subscribe'])) {
            $info['subscribe'] = $info['subscribe'];
        }
        return $info;
    }

    //创建以及更新用户 shish 2020.2.7
    public static function replaceUser($userInfo, $source, $merchantId)
    {
        $userInfo = self::switchUserInfo($userInfo, $source);
        $userSource = self::$userSourceId;
        switch ($source) {
            case $userSource['mini']['name']:
                $sourceId = $userSource['mini']['id'];
                $miniOpenId = $userInfo['miniOpenId'];
                $user = self::getByMiniOpenId($miniOpenId, $merchantId);
                break;
            case $userSource['alipay']['name']:
                $sourceId = $userSource['alipay']['id'];
                $alipayId = $userInfo['alipayId'];
                $user = self::getByAlipayId($alipayId, $merchantId);
                break;
            case $userSource['official']['name']:
                $sourceId = $userSource['official']['id'];
                //老客添加没有openId
                $openId = isset($userInfo['openId']) ? $userInfo['openId'] : '';
                $user = [];
                if (!empty($openId)) {
                    $user = self::getByOpenId($openId, $merchantId);
                }
                break;
            default:
                throw new \Exception('未知来源的用户');
        }
        if (empty($user)) {
            $userInfo['source'] = $sourceId;
            $userInfo['merchantId'] = $merchantId;
            $user = self::generateUser($userInfo, $merchantId);
        } else {
            //支付宝付款时不需要每次更新用户信息
            if ($source != $userSource['alipay']['name']) {
                $user = self::updateUser($user, $userInfo, $merchantId);
            }
        }

        //存在相同unionid则进行合并
        $unionId = isset($userInfo['unionId']) ? $userInfo['unionId'] : '';
        if (!empty($unionId)) {
            $same = self::getSameUnionId($merchantId, $unionId);
            if (count($same) == 2) {
                $delUser = $same[0];
                $retainUser = $same[1];
                $user = self::mergeUser($delUser, $retainUser);
            }
        }
        return $user;
    }

    //拉取粉丝 shish 2020.2.7
    public static function syncWxUser($merchantId, $nextOpenId = '')
    {
        $merchant = MerchantClass::getMerchantById($merchantId);
        //一次拉取调用最多拉取10000个关注者的OpenID
        $result = wxUtil::getSubscribeUserList($merchant, $nextOpenId);
        $total = isset($result['total']) ? $result['total'] : 0;
        $next_openid = isset($result['next_openid']) ? $result['next_openid'] : '';
        $count = isset($result['count']) ? $result['count'] : 0;
        $openIdList = isset($result['data']['openid']) ? $result['data']['openid'] : [];
        $currentTotal = count($openIdList);
        if ($count == 0 || $currentTotal == 0) {
            return ['total' => $total, 'count' => $count, 'nextOpenId' => $next_openid];
        }
        $currentTotalPage = $currentTotal > 100 ? ceil($currentTotal / 100) : 1;
        $userSource = Yii::$app->dict->getValue('userSourceGetId', 'official');
        $source = $userSource['name'];
        for ($m = 1; $m <= $currentTotalPage; $m++) {
            $offset = ($m - 1) * 100;
            $subIdList = array_slice($openIdList, $offset, 100);
            $info = wxUtil::batchGetUserInfo($merchant, $subIdList);
            if (empty($info) || isset($info['user_info_list']) == false || empty($info['user_info_list'])) {
                continue;
            }
            $user_info_list = $info['user_info_list'];
            foreach ($user_info_list as $val) {
                $val['isFull'] = 1;
                $val['unionId'] = $val['unionid'];
                $val['headImgUrl'] = $val['headimgurl'];
                $val['openId'] = $val['openid'];
                $val['nickName'] = $val['nickname'];
                $val['merchantId'] = $merchantId;
                self::replaceUser($val, $source, $merchantId);
            }
        }
        return ['total' => $total, 'count' => $count, 'nextOpenId' => $next_openid];
    }

}