huahuibao/app-hd/controllers/CustomController.php

<?php

namespace hd\controllers;

use bizHd\admin\services\AdminService;
use bizHd\custom\classes\CustomClass;
use bizHd\custom\classes\HdClass;
use bizHd\custom\services\CustomService;
use biz\sj\services\MerchantAssetService;
use biz\sj\services\MerchantRemarkService;
use bizHd\order\classes\OrderClass;
use bizHd\stat\classes\StatVisitClass;
use bizHd\user\services\UserAssetService;
use bizHd\user\services\UserGrowthService;
use bizHd\user\services\UserService;
use bizHd\user\services\UserUpgradeService;
use common\components\wxUtil;
use common\services\xhMerchantExtendService;
use common\services\xhRechargeService;
use common\services\xhTMessageService;
use Yii;
use common\components\stringUtil;
use common\components\util;
use biz\sj\services\MerchantExtendService;
use bizHd\message\services\SmsService;
use bizHd\user\classes\UserClass;
use yii\helpers\Json;

class CustomController extends BaseController
{

    public $guestAccess = ['list'];

    //修改生日 ssh 20250814
    public function actionModifyBirthday()
    {
        $get = Yii::$app->request->get();
        $customId = $get['customId'];
        CustomClass::modifyBirthday($customId, $this->shopId, $get);
        util::complete('修改成功');
    }

    public function actionChangeLevel()
    {
        $get = Yii::$app->request->get();
        $customId = $get['customId'];
        $level = $get['level'] ?? 0;
        if ($level < 0) {
            util::fail('等级选择错误');
        }
        $custom = CustomClass::getById($customId, true);
        if (empty($custom)) {
            util::fail('没有找到客户');
        }
        $shopId = $this->shopId;
        if ($custom->shopId != $shopId) {
            util::fail('不是你的客户');
        }
        $hdId = $custom->hdId;
        $hd = HdClass::getById($hdId, true);
        if (empty($hd)) {
            util::fail('客户信息缺失，编号3445');
        }
        $staff = $this->shopAdmin;
        $staffId = $staff->id;
        $staffName = $staff->name;
        $params = [
            'style' => 1,//手动修改
            'staffId' => $staffId,
            'adminId' => $this->adminId,
            'staffName' => $staffName,
        ];
        $shop = $this->shop;
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            $beforeLevel = $custom->member ?? 0;
            CustomClass::levelChange($beforeLevel, $level, $shop, $custom, $hd, $params);
            $transaction->commit();
            util::complete('修改成功');
        } catch (\Exception $exception) {
            $transaction->rollBack();
            Yii::info("修改失败：" . $exception->getMessage());
            util::fail('修改失败');
        }

    }

    //修改客户地址 ssh 20231109
    public function actionModifyAddress()
    {
        $post = Yii::$app->request->post();
        $id = $post['id'] ?? 0;
        unset($post['id']);
        $custom = CustomClass::getById($id, true);
        if (empty($custom)) {
            util::fail('没有找到客户信息');
        }
        $userId = $custom->userId ?? 0;
        $city = $post['city'] ?? '';
        $dist = $post['dist'] ?? '';
        $address = $post['address'] ?? '';
        $floor = $post['floor'] ?? '';
        $post['fullAddress'] = $city . $dist . $address . $floor;
        UserClass::updateByCondition(['id' => $userId], $post);
        CustomClass::updateByCondition(['id' => $id], $post);
        util::complete('修改成功');
    }

    //会员权限开关
    public function actionChangeVip()
    {
        $post = Yii::$app->request->post();
        $vip = $post['vip'];
        $id = $post['customId'];
        unset($post['id']);
        $custom = CustomClass::getById($id, true, 'id, shopId, vip');
        if (empty($custom)) {
            util::fail('没有找到客户信息');
        }
        if ($custom->shopId != $this->shopId) {
            util::fial('你不能操作');
        }
        if (!isset($this->shopAdmin->founder) || $this->shopAdmin->founder != 2) {
            util::fail('超管才能操作哦');
        }
        $custom->vip = $vip;
        $custom->save();
        $hint = $vip == 1 ? '已开启' : '已关闭';
        util::complete($hint);
    }

    //修改名称 ssh 2022096
    public function actionChangeName()
    {
        $get = Yii::$app->request->get();
        $name = $get['name'] ?? '';
        $id = $get['id'] ?? 0;
        if (empty($name)) {
            util::fail('请填写名称');
        }
        $py = stringUtil::py($name);
        $custom = CustomClass::getById($id, true);
        CustomClass::valid($custom, $this->shopId);
        $custom->name = $name;
        $custom->py = $py;
        $custom->save();
        OrderClass::updateByCondition(['customId' => $id], ['customName' => $name, 'customNamePy' => $py]);
        util::complete();
    }

    //批量添加客户 ssh 20220919
    public function actionBatchAddCustom()
    {
        $post = Yii::$app->request->post();
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            for ($i = 1; $i <= 5; $i++) {
                $name = $post['name' . $i] ?? '';
                $mobile = $post['mobile' . $i] ?? '';
                $confirmMobile = $post['confirmMobile' . $i] ?? '';
                if (empty($name) && empty($mobile) && empty($confirmMobile)) {
                    continue;
                }
                if (empty($name)) {
                    util::fail('客户名称不能为空');
                }
                if (stringUtil::getWordNum($name) > 15) {
                    util::fail('名称不能超过15个汉字');
                }
                if (empty($mobile)) {
                    util::fail($name . " 手机号不能为空");
                }
                if (stringUtil::isMobile($mobile) == false) {
                    util::fail($name . " 手机号格式不正确");
                }
                if ($mobile != $confirmMobile) {
                    util::fail($name . " 二次手机号不一致");
                }
                $user = \bizMall\user\classes\UserClass::replaceUser(['name' => $name, 'mobile' => $mobile]);
                if (isset($this->shop) && !empty($this->shop)) {
                    //花店增加客户，散客增加门店
                    CustomClass::buildRelation($this->shop, $user);
                }
            }
            $transaction->commit();
            util::complete();
        } catch (\Exception $e) {
            $transaction->rollBack();
            util::fail('添加失败');
        }
    }

    //客户列表 ssh 2019.11.30
    public function actionList()
    {
        $get = Yii::$app->request->get();
        $type = $get['type'] ?? 0;
        $searchStyle = $get['searchStyle'] ?? 0;
        $where = ['shopId' => $this->shopId];
        $all = CustomClass::getCount($where);

        if ($type == 1) {
            //消费排行
            $sort = 'buyAmount DESC';
        } else if ($type == 2) {
            //余额客户
            $sort = 'balance DESC';
        } else if ($type == 3) {
            //生日
            $sort = 'birthdayTime ASC';
            $where['birthdayTime>'] = 0;
        } else if ($type == 4) {
            //已经删除的客户
            $sort = 'id ASC';
            $where['delStatus'] = 1;
        } else if ($type == 5) {
            //只显示VIP用户
            $sort = 'id ASC';
            $where['vip'] = 1;
        } else {
            $sort = 'visitTime DESC';
        }

        $name = $get['name'] ?? '';
        if (empty($name)) {
            $name = $get['keyword'] ?? '';
        }
        if (empty($name)) {
            $name = $get['searchText'] ?? '';
        }
        if (!empty($name)) {
            if ($searchStyle == 0) {
                $where['mobile'] = ['like', $name];
            } else {
                if (stringUtil::isLetter($name)) {
                    $where['py'] = ['like', $name];
                } else {
                    $where['name'] = ['like', $name];
                }
            }
        }
        $list = CustomService::getCustomList($where, $sort);
        $list['all'] = $all; //全部的总人数
        $list['balance'] = $all; //余额排行的总人数
        $list['buyAmount'] = $all; //消费排行的总人数
        $list['birth'] = CustomClass::getCount(array_merge(['shopId' => $this->shopId], ['birthdayTime>' => 0])); //有设置生日的总人数
        $list['deleted'] = CustomClass::getCount(array_merge(['shopId' => $this->shopId], ['delStatus' => 1])); //被删除的总人数
        $list['vip'] = CustomClass::getCount(array_merge(['shopId' => $this->shopId], ['vip' => 1])); //是vip的总人数

        util::success($list);
    }

    //获取客户信息 ssh 20250510
    public function actionInfo()
    {
        $get = Yii::$app->request->get();
        $id = $get['id'] ?? 0;
        $custom = CustomClass::getById($id, true);
        if (empty($custom)) {
            util::fail('没有找到客户信息');
        }
        if ($custom->shopId != $this->shopId) {
            util::fail('不是你的客户');
        }
        util::success(['custom' => $custom]);
    }

    //获取客户基本和资产信息 ssh 2019.11.30
    public function actionDetail()
    {
        $userId = Yii::$app->request->get('userId');
        $info = CustomClass::getCustomInfo($userId);
        CustomClass::valid($info, $this->shopId);
        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);
    }

    //添加客户，申请会员时会自动同步资产 ssh 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('二次输入手机号不一样');
        }

        $payPassword = isset($post['payPassword']) ? $post['payPassword'] : '';
        AdminService::verifyPayPassword($this->adminId, $payPassword);

        $mobile = $post['mobile'];
        $user = UserService::getByMobile($mobile, $this->sjId);
        if (!empty($user)) {
            util::fail('手机号已使用');
        }

        $post['sjId'] = $this->sjId;
        $post['member'] = $post['memberLevel'];
        UserService::addUser($post);

        util::complete();
    }

    //充值 ssh 2019.12.1
    public function actionRecharge()
    {
        $post = Yii::$app->request->post();
        $payPassword = isset($post['payPassword']) ? $post['payPassword'] : '';
        AdminService::verifyPayPassword($this->adminId, $payPassword);

        $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['sjId'] != $this->sjId) {
            util::fail('您无法操作');
        }
        $userAsset = UserAssetService::getByUserId($userId);
        $totalBalance = $userAsset['balance'] + $rechargeAmount;
        $totalRecharge = $userAsset['totalRecharge'] + $rechargeAmount;
        $upData['balance'] = $totalBalance;
        $upData['totalRecharge'] = $totalRecharge;
        $merchantAsset = MerchantAssetService::getBySjId($this->sjId);
        $return = xhRechargeService::recharge($rechargeAmount, $user, $this->adminId, $this->sj->attributes, $this->sjExtend->attributes, $merchantAsset);
        if ($return['code'] == 'A0001') {
            util::complete();
        }
        util::fail();
    }

    //升级 ssh 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);
        //验证确认密码
        $payPassword = $post['payPassword'];
        AdminService::verifyPayPassword($this->adminId, $payPassword);

        $grade = xhMerchantExtendService::getGradeList($this->sjExtend->attributes, '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'],
                'sjId' => $this->sjId,
                'gainType' => 0,
                'addTime' => $now,
                'userId' => $userId,
            ];
            $upgradeRespond = UserUpgradeService::add($upgradeData);

            $growthData = [
                'userId' => $userId,
                'userName' => $user['userName'],
                'sjId' => $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();
    }

    //获取登陆客户的资产 ssh 2019.11.22
    public function actionAsset()
    {
        $asset = UserAssetService::getByUserId($this->adminId);
        util::success($asset);
    }

    //获取登陆客户的优惠情况  ssh 2019.12.3
    public function actionDiscount()
    {
        $discount = UserAssetService::getDiscount($this->adminId);
        util::success($discount);
    }

    //小程序用户完整信息 ssh 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'];
        $sjId = $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, $sjId);
        $userId = $user['id'];
        $userInfo = UserService::getUserInfo($userId);
        util::success($userInfo);
    }

    //小程序用户手机号
    public function actionMiniMobile()
    {
        $post = Yii::$app->request->post();
        $iv = $post['iv'];
        $encryptedData = $post['encryptedData'];
        $sjId = $this->sjId;
        $merchant = $this->sj->attributes;
        $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);
        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('修改成功');
    }

    //申请会员 ssh 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(['sjId' => $this->sjId, 'mobile' => $mobile]);
        if ($userId == $user['id']) {
            util::fail('手机号已验证');
        }
        if (!empty($user)) {
            util::fail('手机号已经注册过了');
        }
        $update['mobile'] = $mobile;
        UserService::becomeMember($this->user, $this->sj->attributes, $update);
        util::complete('注册成功');
    }

    //用户基本信息和资产 ssh 2019.12.19
    public function actionMyProfile()
    {
        $custom = $this->custom;
        $user = UserService::getUserInfo($this->adminId);
        $growth = $custom['growth'] ?? 0;
        $extend = $this->sjExtend->attributes;
        $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);
    }

    //登陆客户的信息 ssh 2020.3.12
    public function actionLoginDetail()
    {
        $user = $this->user;
        util::success($user);
    }

    //总挂账和总余额汇总 ssh 20250620
    public function actionShowTotalBalance()
    {
        $lookMoney = \bizGhs\shop\classes\ShopAdminClass::lookMoneyPower($this->shopAdmin, $this->shop);
        if ($lookMoney == 0) {
            util::fail('无法查看哦');
        }

        $lsShop = $this->shop;
        $pfShopId = $lsShop->pfShopId;
        $lsShopId = $this->shopId;
        $respond = \bizGhs\custom\classes\CustomClass::showTotalBalance($pfShopId, $lsShopId);
        $respond['pfShopId'] = $pfShopId;
        $respond['lsShopId'] = $lsShopId;
        util::success($respond);
    }

    //今日访客
    public function actionGetVisit()
    {
        $userIds = StatVisitClass::getVisitCustomIds($this->shopId);
        if (empty($userIds)) {
            util::success(['list' => []]);
        }
        $sort = 'visitTime DESC';
        $where = [
            'shopId' => $this->shopId,
            'userId' => ['in', $userIds]
        ];
        $list = CustomService::getCustomList($where, $sort);
        util::success($list);
    }

    //删除客户 ssh 20250923
    public function actionDelCustom()
    {
        $get = Yii::$app->request->get();
        $id = $get['id'] ?? 0;
        $custom = CustomClass::getById($id, true);
        if (empty($custom)) {
            util::fail('没有找到客户');
        }
        if ($custom->shopId != $this->shopId) {
            util::fail('不是你的客户');
        }
        $hdId = $custom->hdId ?? 0;
        $hd = HdClass::getById($hdId, true);
        if (empty($hd)) {
            util::fail('客户信息缺失');
        }
        $custom->delStatus = 1;
        $custom->save();
        $hd->delStatus = 1;
        $hd->save();
        util::complete('删除成功');
    }

    //重新统计客户的消费总额
    public function actionUpdateBuyAmount()
    {
        $post = Yii::$app->request->post();
        $customId = $post['customId'];

        $c = CustomClass::getLockById($customId);

        // 1.重新统计客户的消费总额
        $orderList = OrderClass::getAllByCondition(['customId' => $customId], null, 'id, forward, actPrice');

        $buyAmount = 0;
        if (!empty($orderList)) {
            foreach ($orderList as $order) {
                if ($order['forward'] == 0) { //0 常规订单
                    $buyAmount = bcadd($buyAmount, $order['actPrice'], 2);
                } elseif ($order['forward'] == 1) { //1 售后付款单(红冲)
                    $buyAmount = bcsub($buyAmount, $order['actPrice'], 2);
                } else {
                    Yii::info('订单类型不存在');
                    continue;
                }
            }
        }
        $c->buyAmount = $buyAmount;
        $c->listend = false;
        $c->save();

        // 2.更新此客户所对应花店的消费金额 expendAmount ---- xhHd -> expendAmount
        HdClass::updateById($c->hdId, ['expendAmount' => $buyAmount]);

        util::success(['customId' => $customId, 'buyAmount' => $buyAmount]);
    }
}