零售端 客户

app/shop/controllers/BaseController.php

@@ -4,6 +4,7 @@ namespace shop\controllers;
 
 use biz\admin\classes\AdminClass;
 use biz\admin\services\ShopAdminService;
+use biz\custom\classes\CustomClass;
 use biz\merchant\classes\MerchantExtendClass;
 use biz\merchant\classes\ShopClass;
 use biz\merchant\services\AdminService;
@@ -18,7 +19,8 @@ use common\components\util;
 
 class BaseController extends PublicController
 {
-    public $admin, $adminId, $adminAvatar, $account;
+
+    public $admin, $adminId, $adminAvatar, $account, $customId, $custom;
     public $sjId = 0, $sj = [], $sjExtend = [], $signPackage, $shopId = 0;
     public $appId;
     public $isWx = false;
@@ -48,6 +50,13 @@ class BaseController extends PublicController
                 util::fail('没有找到店铺');
             }
             $sjId = $shop['merchantId'] ?? 0;
+            $custom = CustomClass::getCustom(['sjId' => $sjId, 'adminId' => $adminId]);
+            $customId = $custom['id'] ?? 0;
+            if (empty($customId)) {
+                util::fail('没有找到客户信息');
+            }
+            $this->custom = $custom;
+            $this->customId = $customId;
             $this->sjId = $sjId;
             $sj = MerchantService::getMerchantById($sjId);
             $this->sj = $sj;

app/shop/controllers/CustomController.php

@@ -0,0 +1,418 @@
+<?php
+
+namespace shop\controllers;
+
+use biz\admin\services\AdminService;
+use biz\custom\classes\CustomClass;
+use biz\merchant\services\MerchantAssetService;
+use biz\merchant\services\MerchantRemarkService;
+use biz\user\services\UserAssetService;
+use biz\user\services\UserGrowthService;
+use biz\user\services\UserService;
+use biz\user\services\UserUpgradeService;
+use common\components\wxUtil;
+use common\services\xhMerchantExtendService;
+use common\services\xhRechargeService;
+use common\services\xhTMessageService;
+use common\services\xhUserIntegralService;
+use Yii;
+use common\components\stringUtil;
+use common\components\util;
+use biz\merchant\services\MerchantExtendService;
+use biz\message\services\SmsService;
+use biz\user\classes\UserClass;
+use yii\helpers\Json;
+
+class CustomController extends BaseController
+{
+
+    //客户列表 shish 2019.11.30
+    public function actionList()
+    {
+        $get = Yii::$app->request->get();
+        $type = isset($get['type']) ? $get['type'] : -1;
+        $search = isset($get['search']) ? $get['search'] : '';
+        $where = ['merchantId' => $this->sjId];
+        switch ($type) {
+            case 1:
+                //粉丝
+                $where['subscribe'] = 1;
+                break;
+            case 2:
+                //会员
+                $where['member>'] = 0;
+                break;
+            default:
+        }
+        if (!empty($search)) {
+            if (stringUtil::isMobile($search)) {
+                $where['mobile'] = $search;
+            } else {
+                $where['userName'] = ['like', $search];
+            }
+        }
+        $list = UserService::getUserList($where);
+        $list['asset'] = MerchantAssetService::getByMerchantId($this->sjId);
+        util::success($list);
+    }
+
+    //获取客户基本和资产信息 shish 2019.11.30
+    public function actionDetail()
+    {
+        $userId = Yii::$app->request->get('userId');
+        $info = UserService::getUserInfo($userId);
+        if (isset($info['merchantId']) == false || $this->sjId != $info['merchantId']) {
+            util::fail('没有权限');
+        }
+        util::success($info);
+    }
+
+    //获取客户详情，包括基本信息、资产、订单和备注 2019.11.30
+    public function actionUserDetail()
+    {
+        $userId = Yii::$app->request->get('userId');
+        $info = UserService::getFullUserInfo($userId);
+        UserService::valid($info, $this->sjId);
+
+        $list = MerchantRemarkService::getRemarkList($userId);
+        $info['remarkList'] = $list;
+        util::success($info);
+    }
+
+    //添加客户，申请会员时会自动同步资产 shish 2019.11.30
+    public function actionAdd()
+    {
+        $post = Yii::$app->request->post();
+        if (isset($post['mobile']) == false || stringUtil::isMobile($post['mobile']) == false) {
+            util::fail('请输入手机号');
+        }
+        if ($post['mobile'] != $post['confirmMobile']) {
+            util::fail('二次输入手机号不一样');
+        }
+
+        $confirmPassword = isset($post['confirmPassword']) ? $post['confirmPassword'] : '';
+        AdminService::verifyConfirmPassword($this->adminId, $confirmPassword);
+
+        $mobile = $post['mobile'];
+        $user = UserService::getByMobile($mobile, $this->sjId);
+        if (!empty($user)) {
+            util::fail('手机号已使用');
+        }
+
+        $post['merchantId'] = $this->sjId;
+        $post['member'] = $post['memberLevel'];
+        UserService::addUser($post);
+
+        util::complete();
+    }
+
+    //充值 shish 2019.12.1
+    public function actionRecharge()
+    {
+        $post = Yii::$app->request->post();
+        $confirmPassword = isset($post['confirmPassword']) ? $post['confirmPassword'] : '';
+        AdminService::verifyConfirmPassword($this->adminId, $confirmPassword);
+
+        $userId = isset($post['userId']) ? $post['userId'] : 0;
+        $rechargeAmount = isset($post['rechargeAmount']) ? $post['rechargeAmount'] : 1;
+        $user = UserService::getById($userId);
+        if (empty($user)) {
+            util::fail('找不到客户');
+        }
+        if ($user['merchantId'] != $this->sjId) {
+            util::fail('您没有权限操作');
+        }
+        $userAsset = UserAssetService::getByUserId($userId);
+        $totalBalance = $userAsset['balance'] + $rechargeAmount;
+        $totalRecharge = $userAsset['totalRecharge'] + $rechargeAmount;
+        $upData['balance'] = $totalBalance;
+        $upData['totalRecharge'] = $totalRecharge;
+        $merchantAsset = MerchantAssetService::getByMerchantId($this->sjId);
+        $return = xhRechargeService::recharge($rechargeAmount, $user, $this->adminId, $this->sj, $this->sjExtend, $merchantAsset);
+        if ($return['code'] == 'A0001') {
+            util::complete();
+        }
+        util::fail();
+    }
+
+    //升级 shish 2019.12.1
+    public function actionUpgrade()
+    {
+        $post = Yii::$app->request->post();
+        $userId = isset($post['userId']) ? $post['userId'] : 0;
+        $member = isset($post['member']) ? $post['member'] : 0;
+        $user = UserService::getById($userId);
+        if (empty($user)) {
+            util::fail('客户不存在');
+        }
+        //验证是否商家客户
+        UserService::valid($user, $this->sjId);
+        //验证确认密码
+        $confirmPassword = $post['confirmPassword'];
+        AdminService::verifyConfirmPassword($this->adminId, $confirmPassword);
+
+        $grade = xhMerchantExtendService::getGradeList($this->sjExtend, 'desc');
+        //升级后的成长值
+        $newLevelGrowth = $grade[$member]['growth'];
+        $newDiscount = $grade[$member]['discount'];
+        $userAsset = UserAssetService::getByUserId($userId);
+        if ($userAsset['member'] >= $member) {
+            util::fail('客户已经达到此级别了');
+        }
+
+        $now = time();
+        $date = date("Y-m-d H:i", $now);
+
+        $connection = Yii::$app->db;//事务处理
+        $transaction = $connection->beginTransaction();
+        try {
+
+            $addGrowth = $newLevelGrowth - $userAsset['growth'];
+            $upData['growth'] = $newLevelGrowth;
+            $upData['member'] = $member;
+            $upData['discount'] = $newDiscount;
+            UserAssetService::updateByUserId($userId, $upData);
+            UserService::updateById($userId, ['member' => $member]);
+
+            $upgradeData = [
+                'member' => $member,
+                'prevMember' => $userAsset['member'],
+                'merchantId' => $this->sjId,
+                'gainType' => 0,
+                'addTime' => $now,
+                'userId' => $userId,
+            ];
+            $upgradeRespond = UserUpgradeService::add($upgradeData);
+
+            $growthData = [
+                'userId' => $userId,
+                'userName' => $user['userName'],
+                'merchantId' => $this->sjId,
+                'relateId' => $upgradeRespond['id'],
+                'growth' => $newLevelGrowth,
+                'num' => $addGrowth,
+                'io' => 1,
+                'payWay' => 4,
+                'alipayId' => '',
+                'event' => '管理员操作升到' . $member . '级增加成长值',
+                'operatorId' => $userId,
+                'createTime' => $date,
+                'gainType' => 0,
+                'addTime' => $now,
+            ];
+            UserGrowthService::add($growthData);
+            $transaction->commit();
+        } catch (Exception $e) {
+            $transaction->rollBack();
+            util::fail();
+        }
+        $allTM = xhTMessageService::getList($this->sjId);
+        $openId = isset($user['openId']) ? $user['openId'] : '';
+        if (empty($openId)) {
+            util::complete();
+        }
+        $shortTempId = 'OPENTM205211943';//升级通知
+        if (isset($allTM[$shortTempId]) == false) {
+            util::complete();
+        }
+        $tempId = $allTM[$shortTempId];
+        $data = [
+            "touser" => $openId, "template_id" => $tempId, "url" => '',
+            "data" => [
+                "first" => ["value" => "恭喜，您已经升为{$member}级会员。", "color" => "#173177"],
+                "keyword1" => ["value" => $user['userName'], "color" => "#173177"],
+                "keyword2" => ["value" => $date, "color" => "#173177"],
+                "remark" => ["value" => "点击查看会员权益", "color" => "#173177"],
+            ]];
+        wxUtil::sendTaskInform($data, $this->sj);
+        util::complete();
+    }
+
+    //重置客户密码
+    public function actionResetPayPassword()
+    {
+        $post = Yii::$app->request->post();
+        $userId = isset($post['userId']) ? $post['userId'] : 0;
+        $password = isset($post['password']) ? $post['password'] : 0;
+        $info = UserService::getById($userId);
+        UserService::valid($info, $this->sjId);
+        UserService::updateById($userId, ['payPassword' => password_hash($password, PASSWORD_BCRYPT)]);
+        util::complete();
+    }
+
+    //获取登陆客户的资产 shish 2019.11.22
+    public function actionAsset()
+    {
+        $asset = UserAssetService::getByUserId($this->adminId);
+        util::success($asset);
+    }
+
+    //获取登陆客户的优惠情况  shish 2019.12.3
+    public function actionDiscount()
+    {
+        $discount = UserAssetService::getDiscount($this->adminId);
+        util::success($discount);
+    }
+
+    //小程序用户完整信息 shish 2019.12.12
+    public function actionMiniFullInfo()
+    {
+        $post = Yii::$app->request->post();
+        $iv = isset($post['iv']) ? $post['iv'] : '';
+        $encryptedData = isset($post['encryptedData']) ? $post['encryptedData'] : '';
+        $appId = $this->sj['miniAppId'];
+        $merchantId = $this->sjId;
+        $miniOpenId = $this->user['miniOpenId'];
+        if (empty($miniOpenId)) {
+            util::fail('mini_open_id empty');
+        }
+        $cacheKey = 'MALL_MINI_SESSION_KEY_' . $miniOpenId;
+        $sessionKey = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
+        $wxMiniSecret = Yii::getAlias("@vendor/weixinMiniSecret");
+        require_once($wxMiniSecret . '/wxBizDataCrypt.php');
+        $pc = new \WXBizDataCrypt($appId, $sessionKey);
+        $errCode = $pc->decryptData($encryptedData, $iv, $result);
+        if ($errCode != 0) {
+            Yii::info($result . ' ' . $errCode);
+            util::fail('获取用户信息失败');
+        }
+        Yii::info('小程序获取用户信息：' . $result);
+        $originalInfo = Json::decode($result);
+        $source = UserClass::$userSourceId['mini']['name'];
+        $user = UserService::replaceUser($originalInfo, $source, $merchantId);
+        $userId = $user['id'];
+        $userInfo = UserService::getUserInfo($userId);
+        util::success($userInfo);
+    }
+
+    //小程序用户手机号
+    public function actionMiniMobile()
+    {
+        $post = Yii::$app->request->post();
+        $iv = $post['iv'];
+        $encryptedData = $post['encryptedData'];
+        $merchantId = $this->sjId;
+        $merchant = $this->sj;
+        $appId = $merchant['miniAppId'];
+        $miniOpenId = $this->user['miniOpenId'];
+        $user = $this->user;
+        if (!empty($user) && !empty($user['mobile'])) {
+            $userId = $user['id'];
+            util::success(['mobile' => $user['mobile']]);
+        }
+        $cacheKey = 'MALL_MINI_SESSION_KEY_' . $miniOpenId;
+        $sessionKey = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
+        if (empty($sessionKey)) {
+            util::fail('系统错误，sesstion empty');
+        }
+        $wxMiniSecret = Yii::getAlias("@vendor/weixinMiniSecret");
+        require_once($wxMiniSecret . '/wxBizDataCrypt.php');
+
+        $pc = new \WXBizDataCrypt($appId, $sessionKey);
+        $errCode = $pc->decryptData($encryptedData, $iv, $result);
+        if ($errCode != 0) {
+            util::fail('解密失败');
+        }
+        $arr = Json::decode($result);
+        $mobile = isset($arr['purePhoneNumber']) ? $arr['purePhoneNumber'] : '';
+        if (empty($mobile)) {
+            util::fail('没有获取手机号，请重试');
+        }
+        $userId = $user['id'];
+        UserService::becomeMember($user, $merchant, ['mobile' => $mobile]);
+        util::success(['mobile' => $mobile]);
+    }
+
+    //密码修改
+    public function actionPassword()
+    {
+        $post = Yii::$app->request->post();
+        $old = isset($post['old']) ? $post['old'] : '';
+        $new = isset($post['new']) ? $post['new'] : '';
+        $confirm = isset($post['confirm']) ? $post['confirm'] : '';
+        if (empty($new)) {
+            util::fail('请输入新密码');
+        }
+        if ($new != $confirm) {
+            util::fail('二次密码不一致');
+        }
+        $userId = $this->adminId;
+        $user = UserService::getUserInfo($userId, false);
+        if (isset($user['hasPayPwd']) && $user['hasPayPwd'] == 1) {
+            if (empty($old)) {
+                util::fail('请填写旧密码');
+            }
+            if (password_verify($old, $user['payPassword']) == false) {
+                util::fail('旧密码错误');
+            }
+        }
+        UserService::updateById($userId, ['payPassword' => password_hash($new, PASSWORD_BCRYPT), 'hasPayPwd' => 1]);
+        util::complete('修改成功');
+    }
+
+    //申请会员 shish 2019.12.18
+    public function actionApplyMember()
+    {
+        $post = Yii::$app->request->post();
+        $mobile = isset($post['mobile']) ? $post['mobile'] : 0;
+        if (stringUtil::isMobile($mobile) == false) {
+            util::fail('请输入手机号');
+        }
+        $userId = $this->adminId;
+        $asset = UserAssetService::getByUserId($userId);
+        if (isset($asset['member']) && $asset['member'] != -1) {
+            util::fail('已经是会员了');
+        }
+        $code = isset($post['code']) ? $post['code'] : '';
+        $cacheCode = SmsService::getApplyMemberCode($userId, $mobile);
+        if (empty($cacheCode) || $cacheCode != $code) {
+            util::fail('验证码错误');
+        }
+        $update = [];
+        if (isset($post['realName']) && !empty($post['realName'])) {
+            $update['realName'] = $post['realName'];
+        }
+        if (isset($post['birthday']) && !empty($post['birthday'])) {
+            $update['birthday'] = $post['birthday'];
+        }
+        $user = UserService::getByCondition(['merchantId' => $this->sjId, 'mobile' => $mobile]);
+        if ($userId == $user['id']) {
+            util::fail('手机号已验证');
+        }
+        if (!empty($user)) {
+            util::fail('手机号已经注册过了');
+        }
+        $update['mobile'] = $mobile;
+        UserService::becomeMember($this->user, $this->sj, $update);
+        util::complete('注册成功');
+    }
+
+    //用户基本信息和资产 shish 2019.12.19
+    public function actionMyProfile()
+    {
+        $custom = $this->custom;
+        $user = UserService::getUserInfo($this->adminId);
+        $growth = $custom['growth'] ?? 0;
+        $extend = $this->sjExtend;
+        $grade = MerchantExtendService::getGradeList($extend, 'asc');
+        //下个等级的积分
+        $nextLevelGrowth = 0;
+        foreach ($grade as $val) {
+            $currentGrowth = $val['growth'];
+            if ($currentGrowth > $growth) {
+                $nextLevelGrowth = $currentGrowth;
+                break;
+            }
+        }
+        $user['userAsset']['nextLevelGrowth'] = $nextLevelGrowth;
+        util::success($user);
+    }
+
+    //登陆客户的信息 shish 2020.3.12
+    public function actionLoginDetail()
+    {
+        $user = $this->user;
+        util::success($user);
+    }
+
+}

biz/custom/classes/CustomClass.php

@@ -10,4 +10,14 @@ class CustomClass extends BaseClass
 
     public static $baseFile = '\biz\custom\models\Custom';
 
+    //获取客户信息
+    public static function getCustom($data)
+    {
+        $custom = self::getByCondition($data);
+        if (empty($custom)) {
+            $custom = self::add($data);
+        }
+        return $custom;
+    }
+
 }

sql.sql

@@ -1040,4 +1040,24 @@ merchantId INT NOT NULL DEFAULT 0 COMMENT '商家id',
 `addTime` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '添加时间',
 `updateTime` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间'
 ) AUTO_INCREMENT=12563516 COMMENT='零售客户表';
-
+DROP TABLE IF EXISTS `xhCustom`;
+CREATE TABLE `xhCustom` (
+  `id` int(11) NOT NULL AUTO_INCREMENT,
+  `name` varchar(30) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '' COMMENT '客户名称',
+  `adminId` int(11) NOT NULL DEFAULT '0' COMMENT 'adminId',
+  `sjId` int(11) NOT NULL DEFAULT '0' COMMENT '商家id',
+  `totalExpend` decimal(9,2) NOT NULL DEFAULT '0.00' COMMENT '累计消费',
+  `totalIncome` decimal(9,2) NOT NULL DEFAULT '0.00' COMMENT '累计收入',
+  `totalRecharge` decimal(9,2) NOT NULL DEFAULT '0.00' COMMENT '累计充值',
+  `totalBuyNum` int(11) NOT NULL DEFAULT '0' COMMENT '消费次数',
+  `getCouponNum` int(11) NOT NULL DEFAULT '0' COMMENT '已领卷次数',
+  `balance` decimal(9,2) NOT NULL DEFAULT '0.00' COMMENT '余额',
+  `integral` int(11) NOT NULL DEFAULT '0' COMMENT '积分',
+  `growth` int(11) NOT NULL DEFAULT '0' COMMENT '成长值',
+  `discount` float(3,2) NOT NULL DEFAULT '1.00' COMMENT '折扣',
+  `inviteNum` int(11) NOT NULL DEFAULT '0' COMMENT '邀请新人数量',
+  `member` smallint(6) NOT NULL DEFAULT '0' COMMENT '会员等级 0普遍客户 大于等于1 会员',
+  `addTime` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '添加时间',
+  `updateTime` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`)
+) COMMENT='客户表';