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)
	{
		//取客户资产
		$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'] : '';
		}
		return $list;
	}
	
	//获取客户基本和资产信息 shish 2019.11.30
	public static function getUserInfo($id)
	{
		$list = self::getByIds([$id]);
		$data = self::groupUserBaseInfo($list);
		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();
		$getUserInfo['userName'] = isset($getUserInfo['userName']) ? preg_replace('/[\x{10000}-\x{10FFFF}]/u', '', $getUserInfo['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'] : 0;
		$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]);
		}
		
		$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'];
				$name = ImageService::generateAvatar($merchantId, $imgUrl);
				self::updateById($userId, ['avatar' => $name]);
			}
		}

		//商家客户粉丝 +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;
		}
		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);
				$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'];
		}
		if (isset($info['nickName'])) {
			$info['userName'] = $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];
	}
	
}