shop-php/app/controller/api/store/merchant/MerchantIntention.php

<?php

// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------

namespace app\controller\api\store\merchant;

use app\common\model\system\merchant\Merchant;
use app\common\repositories\system\merchant\MerchantAdminRepository;
use app\common\repositories\system\merchant\MerchantCategoryRepository;
use app\common\repositories\system\merchant\MerchantRepository;
use app\common\repositories\system\merchant\MerchantTypeRepository;
use app\common\repositories\system\CacheRepository;
use app\validate\api\MerchantIntentionValidate;
use crmeb\services\SmsService;
use crmeb\services\SwooleTaskService;
use crmeb\services\YunxinSmsService;
use think\App;
use think\facade\Db;
use think\facade\Log;
use crmeb\basic\BaseController;
use app\common\repositories\system\merchant\MerchantIntentionRepository as repository;
use think\exception\ValidateException;

class MerchantIntention extends BaseController
{
    protected $repository;
    protected $userInfo;

    public function __construct(App $app, repository $repository)
    {
        parent::__construct($app);
        $this->repository = $repository;
        $this->userInfo = $this->request->isLogin() ? $this->request->userInfo() : null;
    }

    public function create()
    {
        $data = $this->checkParams();
        if (!systemConfig('mer_intention_open')) {
            return app('json')->fail('未开启商户入驻');
        }
        if ($this->userInfo) $data['uid'] = $this->userInfo->uid;
        if (($this->userInfo->phone ?? false) && ($this->userInfo->phone != ($data['phone'] ?? ''))) {
            throw new ValidateException('联系电话和注册手机不一致');
        }

        $intentionInfo = Db::name('merchant_intention')->where('social_credit_code', $data['social_credit_code'])->where('status', '<>', 2)->find();
        if ($intentionInfo) {
            throw new ValidateException('此统一社会信用代码已申请商户');
        }
        $merInfo = Db::name('merchant_intention')->where('uid', $this->userInfo->uid)->where('status', 'in',[0,1])->where('is_del',0)->find();
        if ($merInfo) {
            throw new ValidateException('该用户已申请商户，不可重复申请');
        }
        $make = app()->make(MerchantRepository::class);
        if ($make->fieldExists('mer_name', $data['mer_name']))
            throw new ValidateException('商户名称已存在，不可申请');
        if ($make->fieldExists('mer_phone', $data['phone']))
            throw new ValidateException('手机号已存在，不可申请');
        $adminRepository = app()->make(MerchantAdminRepository::class);
        if ($adminRepository->fieldExists('account', $data['phone']))
            throw new ValidateException('手机号已是管理员，不可申请');
        // 数据表的village_id为int型，前端传的是village_code，可能超过11位，int最大可存储11位，导致sql报错。 转换为主键id存储
        $data['village_id'] = Db::name('geo_village')->where('village_code', $data['village_id'])->value('village_id');
        $intention = $this->repository->create($data);
        SwooleTaskService::admin('notice', [
            'type' => 'new_intention',
            'data' => [
                'title' => '商户入驻申请',
                'message' => '您有一个新的商户入驻申请',
                'id' => $intention->mer_intention_id
            ]
        ]);
        $areaInfo = Db::name('geo_area')->where('area_code', $data['area_id'] ?? '')->find();
        $sendData = [
            'type' => 1,
            'type_name' => Db::name('merchant_type')->where('mer_type_id', $data['mer_type_id'])->value('type_name', ''),
            'category_name' => Db::name('merchant_category')->where('merchant_category_id', $data['merchant_category_id'])->value('category_name', ''),
            'mer_name' => $data['mer_name'] ?? '',
            'company_name' => $data['company_name'] ?? '',
            'organization_code' => $data['social_credit_code'] ?? '',
            'master_name' => $data['name'],
            'master_phone' => $data['phone'],
            'images' => !empty($data['images']) ? json_encode($data['images']) : '',
            'city' => $areaInfo['city_code'] ?? '',
            'area' => $data['area_id'] ?? '',
            'street' =>  $data['street_id'] ?? '',
            'village' =>  $data['village_id'] ?? '',
            'address' =>  $data['address'] ?? '',
            'mer_intention_id' =>  $intention->mer_intention_id,
            'type_id'=>$data['mer_type_id']??''
        ];
        $postUrl = env('TASK_WORKER_HOST_URL') . '/adminapi/company/createShopMerchant';
        $res = $this->sendMerIntentionApply($sendData, $postUrl);
        if (!$res['ok']) {
            Db::name('merchant_intention')->where('mer_intention_id', $intention->mer_intention_id)->delete();
            throw new ValidateException('供销平台申请商户入驻失败，' . $res['msg']);
        }
        return app('json')->success('提交成功');
    }

    public function settlementApply()
    {
        $status = $this->request->post('status', 0);
        if ($this->userInfo) $data['uid'] = $this->userInfo->uid;
        if ($status == 1) {
            Db::name('merchant')->where('uid', $this->userInfo->uid)->update(['mer_settlement_agree_status' => 1]);
        }
        return app('json')->success('操作成功');
    }

    public function businessApply()
    {
        $data = $this->request->params([
            'phone',
            'mer_name',
            'company_name',
            'address',
            'name',
            'code',
            'images',
            'merchant_category_id',
            'mer_type_id',
            'social_credit_code',
            'area_id',
            'street_id',
            'village_id',
            'is_nmsc',
            'bank_username',
            'bank_opening',
            'bank_front',
            'bank_back',
            'cardno_front',
            'cardno_back',
        ]);

        if (empty($data['bank_username']) || empty($data['bank_opening']) || empty($data['bank_front']) || empty($data['bank_back']) || empty($data['cardno_front']) || empty($data['cardno_back'])) {
            return app('json')->fail('请完善银行卡及身份信息');
        }

        if (!systemConfig('mer_intention_open')) {
            return app('json')->fail('未开启商户入驻');
        }
        if ($this->userInfo) $data['uid'] = $this->userInfo->uid;
        $merInfo = Db::name('merchant')->where('uid', $this->userInfo->uid)->where('status', 1)->find();
        if (empty($merInfo)) {
            return app('json')->fail('请申请商户入驻申请！');
        }
        if (!empty($merInfo['business_status']) && ($merInfo['business_status'] == 1)) {
            return app('json')->fail('商户交易已申请，正在审核中！');
        }
        if (!empty($merInfo['business_status']) && ($merInfo['business_status'] == 2)) {
            return app('json')->fail('商户交易申请已通过');
        }
        $intenInfo = Db::name('merchant_intention')->where('mer_intention_id', $merInfo['mer_intention_id'] ?? 0)->where('type', 1)->find();
        if (empty($intenInfo)) {
            // 兼容处理已开通商户
            $intenInfo = [
                'uid'        => $merInfo['uid'],
                'mer_id'     => $merInfo['mer_id'],
                'phone'      => $merInfo['mer_phone'],
                'mer_name'   => $merInfo['mer_name'],
                'name'   => $merInfo['mer_name'],
                'merchant_category_id' => $merInfo['category_id'],
                'mer_type_id'          => $merInfo['type_id'],
            ];
        }
        $intenInfo['bank_username'] = $data['bank_username'];
        $intenInfo['bank_opening'] = $data['bank_opening'];
        $intenInfo['bank_front'] = $data['bank_front'];
        $intenInfo['bank_back'] = $data['bank_back'];
        $intenInfo['cardno_front'] = $data['cardno_front'];
        $intenInfo['cardno_back'] = $data['cardno_back'];

        $intenInfo['type'] = 2;
        $intenInfo['status'] = 0;
        $intenInfo['create_time'] = date('Y-m-d H:i:s');

        unset($intenInfo['mer_intention_id']);

        $intentionId = Db::name('merchant_intention')->insertGetId($intenInfo);
        $areaInfo = Db::name('geo_area')->where('area_code', $intenInfo['area_id'] ?? '')->find();
        $sendData = [
            'type' => 2,
            'type_name' => Db::name('merchant_type')->where('mer_type_id', $merInfo['type_id'])->value('type_name', ''),
            'category_name' => Db::name('merchant_category')->where('merchant_category_id', $merInfo['category_id'])->value('category_name', ''),
            'mer_name' => $intenInfo['mer_name'] ?? '',
            'company_name' => $intenInfo['company_name'] ?? '',
            'organization_code' => $intenInfo['social_credit_code'] ?? '',
            'master_name' => $intenInfo['name'],
            'master_phone' => $intenInfo['phone'],
            'images' => !empty($intenInfo['images']) ? json_encode(explode(',', $intenInfo['images'])) : '',
            'city' => $areaInfo['city_code'] ?? '',
            'area' => $merInfo['area_id'] ?? '',
            'street' =>  $merInfo['street_id'] ?? '',
            'village' =>  $data['village_id'] ?? '',
            'address' =>  $intenInfo['address'] ?? '',
            'bank_username' => $data['bank_username'] ?? '',
            'bank_opening' => $data['bank_opening'] ?? '',
            'bank_front' => $data['bank_front'] ?? '',
            'bank_back' => $data['bank_back'] ?? '',
            'cardno_front' => $data['cardno_front'] ?? '',
            'cardno_back' => $data['cardno_back'] ?? '',
            'mer_intention_id' =>  $intentionId,
            'type_id'=>$merInfo['type_id']??''

        ];
        $postUrl = env('TASK_WORKER_HOST_URL') . '/adminapi/company/createShopMerchant';
        $res = $this->sendMerIntentionApply($sendData, $postUrl);
        if (!$res['ok']) {
            Db::name('merchant_intention')->where('mer_intention_id', $intentionId)->delete();
            throw new ValidateException('供销平台商户交易申请失败，' . $res['msg']);
        }
        Db::name('merchant')->where('uid', $this->userInfo->uid)->where('status', 1)->update(['business_status' => 1]);
        return app('json')->success('申请成功');
    }

    //发送商户申请
    public function sendMerIntentionApply($data, $postUrl)
    {
        Log::info("商户申请URL: {$postUrl}");
        Log::info("发送商户申请信息: " . json_encode($data));
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $postUrl);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        $resData = curl_exec($ch);
        curl_close($ch);
        $rtnData = [
            'ok' => false,
            'msg' => ''
        ];
        if (!empty($resData) && is_string($resData)) {
            Log::info("商户申请反馈信息" . $resData);
            $resInfo = json_decode($resData, true);
            if (!empty($resInfo['code']) && $resInfo['code'] == 1) {
                $rtnData['ok'] = true;
            } else {
                $rtnData['msg'] = $resInfo['msg'];
            }
        }
        return $rtnData;
    }

    public function update($id)
    {
        $merIntentionInfo = $this->repository->getWhere(['mer_intention_id' => (int)$id, 'uid' => $this->userInfo->uid, 'is_del' => 0]);
        if (!$merIntentionInfo)
            return app('json')->fail('数据不存在');
        if ($merIntentionInfo['status'] == 1) {
            return app('json')->fail('已通过审核数据不能修改');
        }
        $data = $this->checkParams();
        if (!systemConfig('mer_intention_open')) {
            return app('json')->fail('未开启商户入驻');
        }
        if (($this->userInfo->phone ?? false) && ($this->userInfo->phone != ($data['phone'] ?? ''))) {
            throw new ValidateException('联系电话和注册手机不一致');
        }
        $intentionInfo = Db::name('merchant_intention')->where('social_credit_code', $data['social_credit_code'])->where('status', '<>', 2)->find();
        if ($intentionInfo) {
            throw new ValidateException('此统一社会信用代码已申请商户');
        }
        if (!empty($data['mer_phone'])) {
            unset($data['mer_phone']);
        }
        $make = app()->make(MerchantRepository::class);
        if ($make->fieldExists('mer_name', $data['mer_name']))
            throw new ValidateException('商户名称已存在，不可申请');
        $adminRepository = app()->make(MerchantAdminRepository::class);
        if ($adminRepository->fieldExists('account', $data['phone']))
            throw new ValidateException('手机号已是管理员，不可申请');
        $data['create_time'] = date('Y-m-d H:i:s', time());
        $updateIntention=$this->repository->updateIntention((int)$id, $data);
        SwooleTaskService::admin('notice', [
            'type' => 'new_intention',
            'data' => [
                'title' => '商户入驻申请',
                'message' => '您有一个新的商户入驻申请',
                'id' => $id
            ]
        ]);
        $areaInfo = Db::name('geo_area')->where('area_code', $data['area_id'] ?? '')->find();
        $sendData = [
            'type' => 1,
            'type_name' => Db::name('merchant_type')->where('mer_type_id', $data['mer_type_id'])->value('type_name', ''),
            'category_name' => Db::name('merchant_category')->where('merchant_category_id', $data['merchant_category_id'])->value('category_name', ''),
            'mer_name' => $data['mer_name'] ?? '',
            'company_name' => $data['company_name'] ?? '',
            'organization_code' => $data['social_credit_code'] ?? '',
            'master_name' => $data['name'],
            'master_phone' => $data['phone'],
            'images' => !empty($data['images']) ? json_encode($data['images']) : '',
            'city' => $areaInfo['city_code'] ?? '',
            'area' => $data['area_id'] ?? '',
            'street' =>  $data['street_id'] ?? '',
            'village' =>  $data['village_id'] ?? '',
            'address' =>  $data['address'] ?? '',
            'mer_intention_id' =>  $id,
            'type_id'=>$data['mer_type_id']??''

        ];
        $postUrl = env('TASK_WORKER_HOST_URL') . '/adminapi/company/createShopMerchant';
        $res = $this->sendMerIntentionApply($sendData, $postUrl);
        if (!$res['ok']) {
            throw new ValidateException('供销平台申请商户入驻失败，' . $res['msg']);
        }
        if($updateIntention){
            return app('json')->success('修改成功');
        }else{
            return app('json')->success('修改失败');
        }
    }

    public function lst()
    {
        [$page, $limit] = $this->getPage();
        $type = $this->request->get('type', 1);
        $data = $this->repository->getList(['uid' => $this->userInfo->uid, 'type' => $type], $page, $limit);
        return app('json')->success($data);
    }

    function detail($id)
    {
        $data = $this->repository->detail((int)$id, $this->userInfo->uid);
        if (!$data) {
            return app('json')->fail('数据不存在');
        }
        if ($data->status == 1) {
            $data['login_url'] = rtrim(systemConfig('site_url'), '/') . '/' . config('admin.merchant_prefix');
        }
        return app('json')->success($data);
    }

    protected function checkParams()
    {
        $data = $this->request->params([
            'phone',
            'mer_name',
            'company_name',
            'address',
            'name',
            'code',
            'images',
            'mer_type_id',
            'merchant_category_id',
            'social_credit_code',
            'area_id',
            'street_id',
            'village_id',
            'is_nmsc'
        ]);

        app()->make(MerchantIntentionValidate::class)->check($data);
        $check = app()->make(SmsService::class)->checkSmsCode($data['phone'], $data['code'], 'intention');
        $data['mer_type_id'] = (int)$data['mer_type_id'];
        if (!env('APP_DEBUG')) {
            if (!$check) throw new ValidateException('验证码不正确');
        }
        // if (!app()->make(MerchantCategoryRepository::class)->get($data['merchant_category_id'])) throw new ValidateException('商户分类不存在');
        if ($data['mer_type_id'] && !app()->make(MerchantTypeRepository::class)->exists($data['mer_type_id'])) {
            throw new ValidateException('店铺类型不存在');
        }
        // if ($data['merchant_category_name'] == '') {
        //     throw new ValidateException('商户分类，不能为空');
        // }
        // $merchant_category_id=Db::name('merchant_category')->where('category_name',$data['merchant_category_name'])->value('merchant_category_id');
        // if(!$merchant_category_id){
        //     throw new ValidateException('没有对应的商户分类,请联系工作人员添加');
        // }
        // $data['merchant_category_id']=$merchant_category_id;
        unset($data['code']);
        return $data;
    }

    /**
     * 商户分类
     * @Author:Qinii
     * @Date: 2020/9/15
     * @return mixed
     */
    public function cateLst()
    {
        $lst = app()->make(MerchantCategoryRepository::class)->getSelect();
        return app('json')->success($lst);
    }

    /**
     * v2商户分类
     * @Author:Qinii
     * @Date: 2020/9/15
     * @return mixed
     */
    public function v2CateLst()
    {
        $lst = app()->make(MerchantCategoryRepository::class)->getSelect(1);
        return app('json')->success($lst);
    }

    public function typeLst()
    {
        /** @var MerchantTypeRepository $repo */
        $siftStore = $this->request->param('sift_store', 0);
        $repo = app()->make(MerchantTypeRepository::class);
        $repo->userApply = true;
        $lst = $repo->getSelect(false, $siftStore);
        return app('json')->success($lst);
    }
}