成为会员的逻辑简化

app/mall/controllers/UserController.php

@@ -92,8 +92,7 @@ class UserController extends BaseController
 		$arr = Json::decode($result);
 		$mobile = isset($arr['purePhoneNumber']) ? $arr['purePhoneNumber'] : '';
 		$userId = $user['id'];
-		
-		UserService::upgradeToMember($userId, $merchantId, ['mobile' => $mobile]);
+		UserService::becomeMember($userId, $merchantId, ['mobile' => $mobile]);
 		util::success(['mobile' => $mobile]);
 	}
 	
@@ -157,7 +156,7 @@ class UserController extends BaseController
 			util::fail('手机号已经注册过了');
 		}
 		$update['mobile'] = $mobile;
-		UserService::upgradeToMember($userId, $this->merchantId, $update);
+		UserService::becomeMember($userId, $this->merchantId, $update);
 		util::complete('注册成功');
 	}
 

app/saas/controllers/WxController.php

@@ -116,7 +116,7 @@ class WxController extends PublicController
         $MediaId = $postObj->MediaId;//图片媒体id
         $Content = trim($postObj->Content); // 消息内容
 
-	    
+
         if ($wxBaseAppId == $appId) {
             if ($this->msgType == 'event') {
 
@@ -188,32 +188,19 @@ class WxController extends PublicController
                     case 'subscribe':
                         $getUserInfo = wxUtil::userInfo($this->fromUsername, $merchant);//从微信接口获取用户信息
                         $source = UserClass::$userSourceId['official']['name'];
-                        Yii::info('关注公众号，获得用户信息：' . json_encode($getUserInfo));
+                        $getUserInfo['subscribe'] = 1;
                         $user = UserService::replaceUser($getUserInfo, $source, $merchantId);
-                        $userId = $user['id'];
-                        $text = $this->replyTextContent("等您好久，终于等到您~\n\n注册会员享折扣哦，<a href='" . Yii::$app->params['frontUrl'] . "/center/right?account={$merchant['id']}'>详情</a>");
-                        if ($merchant['merchantName'] == '花卉宝') {
-                            $text = $this->replyTextContent("等您好久，终于等到您 /::)");
-                        }
-
                         //响应扫码的场景事件 shish 2019.9.5
                         if (strstr($EventKey, 'qrscene_')) {
                             Yii::info($EventKey);
                             $sceneId = str_replace('qrscene_', '', $EventKey);
                             WxSceneService::respondScanEvent($merchant, $user, (string)$sceneId);
                         }
-
                         $pc = new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
                         $encryptMsg = '';
+                        $text = $this->replyTextContent("等您好久，终于等到您 /::)");
                         $pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
                         echo $encryptMsg;
-
-                        $admin = xhAdminService::getByOpenId($this->fromUsername);
-                        if (!empty($admin)) {
-                            $adminId = $admin['id'];
-                            xhAdminService::updateById($adminId, ['subscribe' => 1]);
-                        }
-
                         break;
                     //取消关注
                     case 'unsubscribe':

biz/user/services/UserService.php

@@ -18,215 +18,215 @@ use common\components\wxUtil;
 
 class UserService extends BaseService
 {
-	
-	public static $baseFile = '\biz\user\classes\UserClass';
-	
-	//获取客户列表 shish 2019.11.30
-	public static function getUserList($where, $delStatus = 0)
-	{
-		//默认取没有删除的用户
-		$where['delStatus'] = $delStatus;
-		$data = UserClass::getList('*', $where, 'visitTime DESC');
-		$list = isset($data['list']) && !empty($data['list']) ? $data['list'] : [];
-		if (empty($list)) {
-			return $data;
-		}
-		$data['list'] = UserClass::groupUserBaseInfo($list);
-		return $data;
-	}
-	
-	//获取客户基本和资产信息 shish 2019.11.30
-	public static function getUserInfo($id,$sensitive = true)
-	{
-		return UserClass::getUserInfo($id,$sensitive);
-	}
-	
-	//获取客户基本、资产和订单信息 shish 2019.11.30
-	public static function getFullUserInfo($id)
-	{
-		$userInfo = UserClass::getUserInfo($id);
-		$order = OrderService::getUserOrder($id, 10, 'addTime desc');
-		$userInfo['orderList'] = $order;
-		return $userInfo;
-	}
-	
-	//根据手机号查询客户 shish 2019.12.1
-	public static function getByMobile($mobile, $merchantId)
-	{
-		return UserClass::getByMobile($mobile, $merchantId);
-	}
-	
-	//添加更新客户 shish 2020.2.7
-	public static function replaceUser($userInfo, $source, $merchantId)
-	{
-		return UserClass::replaceUser($userInfo, $source, $merchantId);
-	}
-	
-	public static function getByOpenId($openId, $merchantId)
-	{
-		return UserClass::getByOpenId($openId, $merchantId);
-	}
-	
-	public static function getByMiniOpenId($miniOpenId, $merchantId)
-	{
-		return UserClass::getByMiniOpenId($miniOpenId, $merchantId);
-	}
-	
-	//同步微信用户 shish 2020.2.8
-	public static function syncWxAllUser($merchantId)
-	{
-		$return = UserClass::syncWxUser($merchantId);
-		while (isset($return['count']) && $return['count'] > 0 && isset($return['nextOpenId']) && !empty($return['nextOpenId'])) {
-			$nextOpenId = $return['nextOpenId'];
-			$return = UserClass::syncWxUser($merchantId, $nextOpenId);
-		}
-		return ['total' => $return['total']];
-	}
-	
-	//更新微信头像 shish 2020.1.12
-	public static function syncAvatar($merchantId, $nextOpenId = '')
-	{
-		set_time_limit(0);
-		$merchant = xhMerchantService::getById($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'] : [];
-		if ($count == 0) {
-			util::stop("完成更新\n");
-		}
-		$total = count($openIdList);
-		$totalPage = $total > 100 ? ceil($total / 100) : 1;
-		for ($m = 1; $m <= $totalPage; $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) {
-				$headImgUrl = $val['headimgurl'];
-				$openId = $val['openid'];
-				$img = ImageService::generateAvatar($merchantId, $headImgUrl);
-				if (!empty($img)) {
-					UserClass::updateByCondition(['openId' => $openId], ['avatar' => $img]);
-				}
-			}
-		}
-		echo "更新成功\n";
-	}
-	
-	/**
-	 * 更新用户的访问时间
-	 */
-	public static function updateVisitTime($merchantId, $userId)
-	{
-		$date = date("Ymd");
-		if (empty($userId)) {
-			return false;
-		}
-		//每5分钟更新一次访问时间
-		$key = 'UserVisitTime_' . $date . '_' . $merchantId . '_' . $userId;
-		$respond = Yii::$app->redis->executeCommand('GET', [$key]);
-		//每过5分钟更新访问时间
-		if (empty($respond)) {
-			Yii::$app->redis->executeCommand('SET', [$key, $date]);
-			Yii::$app->redis->executeCommand('EXPIRE', [$key, 300]);
-			$time = time();
-			self::updateById($userId, ['visitTime' => $time]);
-		}
-	}
-
-	//升级成为会员，并更新用户相关信息 shish 2019.9.7
-	public static function upgradeToMember($userId, $merchantId, $data)
-	{
-		self::updateById($userId, $data);
-		//会员数+1
-		MerchantAssetService::addMemberNum($merchantId);
-	}
-	
-	//取消关注 shish 2019.9.8
-	public static function unFocus($userId, $merchantId)
-	{
-		self::updateById($userId, ['subscribe' => 0, 'hasSubscribe' => 1]);
-		/**商家粉丝减少**/
-		MerchantAssetClass::reduceFans($merchantId);
-	}
-	
-	//批量获取用户信息，图片等信息处理好了 shish 2019.11.28
-	public static function getUserByIds($ids)
-	{
-		return UserClass::getUserByIds($ids);
-	}
-
-	//验证支付密码是否正确 shish 2019.12.6
-	public static function validPayPassword($password, $user)
-	{
-		if (isset($user['hasPayPwd']) == false || $user['hasPayPwd'] == 0) {
-			util::fail('您还没有设置支付密码');
-		}
-		$payPassword = $user['payPassword'];
-		if (password_verify($password, $payPassword) == false) {
-			util::fail('密码错误');
-		}
-	}
-
-	//验证用户权限
-	public static function valid($info, $merchantId)
-	{
-		return UserClass::valid($info, $merchantId);
-	}
-	
-	//根据消费次数和有没领优惠券来判断是不是新人
-	public static function newUser($userInfo)
-	{
-		return UserClass::newUser($userInfo);
-	}
-	
-	//添加新客户 shish 2020.1.10
-	public static function addUser($data)
-	{
-		//merchantId $source $realName $member $growth $balance $mobile
-		//必传参数
-		validate::easyCheck(['merchantId', 'mobile'], $data);
-		
-		$merchantId = $data['merchantId'];
-		$source = isset($data['source']) ? $data['source'] : 'official';
-		$mobile = $data['mobile'];
-		$realName = isset($data['realName']) ? $data['realName'] : $mobile;
-		$member = isset($data['member']) ? $data['member'] : -1;
-		$balance = isset($data['balance']) ? $data['balance'] : 0;
-		$growth = isset($data['growth']) ? $data['growth'] : 0;
-		
-		$originalInfo = [];
-		$originalInfo['merchantId'] = $merchantId;
-		$originalInfo['mobile'] = $mobile;
-		$originalInfo['realName'] = $realName;
-		$originalInfo['userName'] = $realName;
-		
-		$user = UserClass::replaceUser($originalInfo, $source, $merchantId);
-		
-		$extend = MerchantExtendService::getByMerchantId($merchantId);
-		
-		//等级
-		if ($member > 0) {
-			$gradeList = xhMerchantExtendService::getGradeList($extend, 'desc');
-			$growth = isset($gradeList[$member]['growth']) ? $gradeList[$member]['growth'] : 0;
-		}
-		
-		//余额成长值更新
-		$userId = $user['id'];
-		$data = [];
-		$data['growth'] = $growth;
-		$data['balance'] = $balance > 0 ? $balance : 0;
-		UserAssetService::updateByUserId($userId, $data);
-		
-		//会员升级
-		UserIntegralService::increaseToUpgrade(0, $growth, 0, $userId, $merchantId, $extend);
-		return $user;
-	}
-	
+
+    public static $baseFile = '\biz\user\classes\UserClass';
+
+    //获取客户列表 shish 2019.11.30
+    public static function getUserList($where, $delStatus = 0)
+    {
+        //默认取没有删除的用户
+        $where['delStatus'] = $delStatus;
+        $data = UserClass::getList('*', $where, 'visitTime DESC');
+        $list = isset($data['list']) && !empty($data['list']) ? $data['list'] : [];
+        if (empty($list)) {
+            return $data;
+        }
+        $data['list'] = UserClass::groupUserBaseInfo($list);
+        return $data;
+    }
+
+    //获取客户基本和资产信息 shish 2019.11.30
+    public static function getUserInfo($id, $sensitive = true)
+    {
+        return UserClass::getUserInfo($id, $sensitive);
+    }
+
+    //获取客户基本、资产和订单信息 shish 2019.11.30
+    public static function getFullUserInfo($id)
+    {
+        $userInfo = UserClass::getUserInfo($id);
+        $order = OrderService::getUserOrder($id, 10, 'addTime desc');
+        $userInfo['orderList'] = $order;
+        return $userInfo;
+    }
+
+    //根据手机号查询客户 shish 2019.12.1
+    public static function getByMobile($mobile, $merchantId)
+    {
+        return UserClass::getByMobile($mobile, $merchantId);
+    }
+
+    //添加更新客户 shish 2020.2.7
+    public static function replaceUser($userInfo, $source, $merchantId)
+    {
+        return UserClass::replaceUser($userInfo, $source, $merchantId);
+    }
+
+    public static function getByOpenId($openId, $merchantId)
+    {
+        return UserClass::getByOpenId($openId, $merchantId);
+    }
+
+    public static function getByMiniOpenId($miniOpenId, $merchantId)
+    {
+        return UserClass::getByMiniOpenId($miniOpenId, $merchantId);
+    }
+
+    //同步微信用户 shish 2020.2.8
+    public static function syncWxAllUser($merchantId)
+    {
+        $return = UserClass::syncWxUser($merchantId);
+        while (isset($return['count']) && $return['count'] > 0 && isset($return['nextOpenId']) && !empty($return['nextOpenId'])) {
+            $nextOpenId = $return['nextOpenId'];
+            $return = UserClass::syncWxUser($merchantId, $nextOpenId);
+        }
+        return ['total' => $return['total']];
+    }
+
+    //更新微信头像 shish 2020.1.12
+    public static function syncAvatar($merchantId, $nextOpenId = '')
+    {
+        set_time_limit(0);
+        $merchant = xhMerchantService::getById($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'] : [];
+        if ($count == 0) {
+            util::stop("完成更新\n");
+        }
+        $total = count($openIdList);
+        $totalPage = $total > 100 ? ceil($total / 100) : 1;
+        for ($m = 1; $m <= $totalPage; $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) {
+                $headImgUrl = $val['headimgurl'];
+                $openId = $val['openid'];
+                $img = ImageService::generateAvatar($merchantId, $headImgUrl);
+                if (!empty($img)) {
+                    UserClass::updateByCondition(['openId' => $openId], ['avatar' => $img]);
+                }
+            }
+        }
+        echo "更新成功\n";
+    }
+
+    /**
+     * 更新用户的访问时间
+     */
+    public static function updateVisitTime($merchantId, $userId)
+    {
+        $date = date("Ymd");
+        if (empty($userId)) {
+            return false;
+        }
+        //每5分钟更新一次访问时间
+        $key = 'UserVisitTime_' . $date . '_' . $merchantId . '_' . $userId;
+        $respond = Yii::$app->redis->executeCommand('GET', [$key]);
+        //每过5分钟更新访问时间
+        if (empty($respond)) {
+            Yii::$app->redis->executeCommand('SET', [$key, $date]);
+            Yii::$app->redis->executeCommand('EXPIRE', [$key, 300]);
+            $time = time();
+            self::updateById($userId, ['visitTime' => $time]);
+        }
+    }
+
+    //升级成为会员，并更新用户相关信息 shish 2019.9.7
+    public static function becomeMember($userId, $merchantId, $data)
+    {
+        self::updateById($userId, $data);
+        //会员数+1
+        MerchantAssetService::addMemberNum($merchantId);
+    }
+
+    //取消关注 shish 2019.9.8
+    public static function unFocus($userId, $merchantId)
+    {
+        self::updateById($userId, ['subscribe' => 0, 'hasSubscribe' => 1]);
+        //商家粉丝减少
+        MerchantAssetClass::reduceFans($merchantId);
+    }
+
+    //批量获取用户信息，图片等信息处理好了 shish 2019.11.28
+    public static function getUserByIds($ids)
+    {
+        return UserClass::getUserByIds($ids);
+    }
+
+    //验证支付密码是否正确 shish 2019.12.6
+    public static function validPayPassword($password, $user)
+    {
+        if (isset($user['hasPayPwd']) == false || $user['hasPayPwd'] == 0) {
+            util::fail('您还没有设置支付密码');
+        }
+        $payPassword = $user['payPassword'];
+        if (password_verify($password, $payPassword) == false) {
+            util::fail('密码错误');
+        }
+    }
+
+    //验证用户权限
+    public static function valid($info, $merchantId)
+    {
+        return UserClass::valid($info, $merchantId);
+    }
+
+    //根据消费次数和有没领优惠券来判断是不是新人
+    public static function newUser($userInfo)
+    {
+        return UserClass::newUser($userInfo);
+    }
+
+    //添加新客户 shish 2020.1.10
+    public static function addUser($data)
+    {
+        //merchantId $source $realName $member $growth $balance $mobile
+        //必传参数
+        validate::easyCheck(['merchantId', 'mobile'], $data);
+
+        $merchantId = $data['merchantId'];
+        $source = isset($data['source']) ? $data['source'] : 'official';
+        $mobile = $data['mobile'];
+        $realName = isset($data['realName']) ? $data['realName'] : $mobile;
+        $member = isset($data['member']) ? $data['member'] : -1;
+        $balance = isset($data['balance']) ? $data['balance'] : 0;
+        $growth = isset($data['growth']) ? $data['growth'] : 0;
+
+        $originalInfo = [];
+        $originalInfo['merchantId'] = $merchantId;
+        $originalInfo['mobile'] = $mobile;
+        $originalInfo['realName'] = $realName;
+        $originalInfo['userName'] = $realName;
+
+        $user = UserClass::replaceUser($originalInfo, $source, $merchantId);
+
+        $extend = MerchantExtendService::getByMerchantId($merchantId);
+
+        //等级
+        if ($member > 0) {
+            $gradeList = xhMerchantExtendService::getGradeList($extend, 'desc');
+            $growth = isset($gradeList[$member]['growth']) ? $gradeList[$member]['growth'] : 0;
+        }
+
+        //余额成长值更新
+        $userId = $user['id'];
+        $data = [];
+        $data['growth'] = $growth;
+        $data['balance'] = $balance > 0 ? $balance : 0;
+        UserAssetService::updateByUserId($userId, $data);
+
+        //会员升级
+        UserIntegralService::increaseToUpgrade(0, $growth, 0, $userId, $merchantId, $extend);
+        return $user;
+    }
+
 }