mall/modules/alliance/controllers/MerchantController.php

<?php
/**
 * 重庆赤晓店信息科技有限公司
 * https://www.chixiaodian.com
 * Copyright (c) 2023 赤店商城 All rights reserved.
 */
namespace app\modules\alliance\controllers;

use app\constants\OptionSetting;
use app\models\Admin;
use app\models\Option;
use app\models\AggregateQrcode;
use app\models\District;
use app\models\MerchantInfo;
use app\models\Order;
use app\models\OrderDetail;
use app\models\SaasCategory;
use app\models\SaasStoreReferral;
use app\models\SaasUser;
use app\models\Salesman;
use app\models\SalesmanNewStore;
use app\models\SharingReceiver;
use app\models\Store;
use app\models\StoreAudit;
use app\models\StoreSchedule;
use app\modules\alliance\controllers\BaseController;
use app\utils\ShareQrcode;
use app\utils\WechatMerchant\Merchant;
use yii\data\Pagination;
use yii\helpers\Json;

class MerchantController extends BaseController
{
    public function actionCat() {
        $query = SaasCategory::find()->where([
            'is_delete' => 0,
        ]);
        $list = $query->orderBy('sort ASC')->asArray()->all();
        return $this->asJson([
            'code' => 0,
            'msg' => 'success',
            'data' => $list,
        ]);
    }
    /**
     * 业务员列表
     * @return \yii\web\Response
     */
    public function actionSalesman() {
        $salesman = Salesman::find()->where(['is_delete' => 0])->asArray()->all();
        foreach ($salesman as &$value) {
            $value['name'] = SaasUser::findOne($value['saas_user_id'])->name;
        }
        return $this->asJson([
            'code' => 0,
            'data' => $salesman
        ]);
    }

    public function actionSubmitMerchant() {
        $saas_user_id = get_saas_user_id();
        // todo: salesman 如何绑定
        $id = post_params('id');
        $name = post_params('name');
//        $store_number = post_params('store_number');
        $cat_id = post_params('cat_id', 0);
        $mobile = post_params('mobile');
        $salesman_id = post_params('salesman_id');
        $password = post_params('password');
        $business_pic = post_params('business_pic', '');
        $permit_pic = post_params('permit_pic', '');
        $logo = post_params('logo', '');
        $type = post_params('type', 0);
        $district_id = post_params('district_id', 0);
        $city_id = post_params('city_id', 0);
        $province_id = post_params('province_id', 0);
        // $merchant_info = post_params('merchant_info', '');
        $qrcode_id = post_params('qrcode_id', '');
        
        $saas_user = get_saas_user();
        if(empty($mobile)){
            $mobile = $saas_user->mobile;
        }
        if(empty($password)){
            $password = substr($saas_user->mobile, -6);
        }

        if (empty($name) || empty($mobile) || empty($password) || empty($logo)) {
            return $this->asJson([
                'code' => 1,
                'msg' => '参数错误'
            ]);
        }
        if ((int)$type === 0 && empty($salesman_id)) {
            return $this->asJson([
                'code' => 1,
                'msg' => '参数错误'
            ]);
        }
        $admin = Admin::findOne(['saas_user_id' => $saas_user->id, 'is_delete' => 0, 'type' => 'store']);
        if ($admin) {
            return $this->asJson([
                'code' => 1,
                'msg' => '当前注册用户已存在'
            ]);
        }
        $admin = Admin::findOne(['name' => $name, 'is_delete' => 0]);
        if ($admin) {
            return $this->asJson([
                'code' => 1,
                'msg' => '当前注册店铺名称已存在'
            ]);
        }

        //判断后台开启通联
//        $oldConf = Option::get(OptionSetting::SAAS_YUNST_SETTING, 0, 'saas')['value'];
//        if ($oldConf) {
//            $oldConf = json_decode($oldConf, true);
//            if (!empty($oldConf) && !empty(trim($oldConf['appid']))) {
//                //查询后台是否有该店铺编号
//                $store_info = Store::find()->where(['store_number' => $store_number])->one();
//
//                if ($store_info){
//                    return $this->asJson([
//                        'code' => 1,
//                        'msg' => '当前店铺编号已存在'
//                    ]);
//                }
//            }
//        }


        $audit = StoreAudit::findOne($id);
        if ($audit && (int)$audit->status !== 2) {
            return $this->asJson([
                'code' => 1,
                'msg' => '当前申请单不可编辑'
            ]);
        }
        //TODO 兼容
        //(int)$type !== 0 &&
        if ((int)$type !== 0 && empty(get_saas_user()->mobile)) {
            return $this->asJson([
                'code' => 1,
                'msg' => '当前用户的手机号为空'
            ]);
        }

        $t = \Yii::$app->db->beginTransaction();

        try {
            $audit = $audit ?: new StoreAudit();
            $audit->saas_user_id = $saas_user_id;
            $audit->mobile = get_saas_user()->mobile;
            if ($type == 0) {
                $audit->salesman_id = $salesman_id;
                $audit->mobile = $mobile;
            }
            $audit->name = $name;
//            $audit->store_number = $store_number;
            $audit->logo = $logo;
            $audit->cat_id = $cat_id;
            $audit->business_pic = $business_pic;
            $audit->permit_pic = $permit_pic;
            $audit->password = \Yii::$app->security->generatePasswordHash($password);
            $audit->is_single_store = \Yii::$app->prod_is_dandianpu() ? 1 : 0;
            $audit->district_id = $district_id;
            $audit->city_id = $city_id;
            $audit->province_id = $province_id;
            if ($audit->save()) {
                
                $store_apply_audit = Option::get('store_apply_audit', 0, 'saas', 0)['value'];
                if($store_apply_audit == 0){
                    $form = new \app\modules\admin\models\StoreForm();
                    $form->id = $audit->id;
                    $form->status = 1;
                    $form->business_model = 1;
                    $form->qrcode_id = 0;
                    $result = $form->storeAudit();
                    \Yii::error([__METHOD__, $form, $result]);
                    if($result['code']){
                        $t->rollBack();
                        return $this->asJson($result);
                    }
                    $store = $result['store'];
                }
                $t->commit();
                return $this->asJson([
                    'code' => 0,
                    'store' => $store ? $store : null,
                    'msg' => '提交成功'
                ]);
            }
        } catch (\Exception $e) {
            $t->rollBack();
            return $this->asJson([
                'code' => 1,
                'msg' => $e->getMessage(),
            ]);
        }
        
        return $this->asJson([
            'code' => 1,
            'msg' => "申请单错误"
        ]);
    }

    public function actionGetAudit()
    {
        try {
            $saas_user_id = get_saas_user_id();
            $audit = StoreAudit::find()->where(['sa.saas_user_id' => $saas_user_id])->alias('sa')//, su.name salesman_name
//                ->leftJoin(['sm' => Salesman::tableName()], 'sa.salesman_id = sm.id')
//            ->leftJoin(['su' => SaasUser::tableName()], 'su.id = sm.saas_user_id')
            ->leftJoin(['sc' => SaasCategory::tableName()], 'sa.cat_id = sc.id')
            ->select('sa.status, sa.mobile, sa.cat_id, sa.logo, sa.name, sa.salesman_id, sa.id, sc.name category_name, sa.district_id, sa.city_id, sa.province_id,sa.store_number')//, su.name salesman_name
                ->orderBy('sa.id desc')->asArray()->one();
            if (!empty($audit['salesman_id'])) {
                $salesman = Salesman::findOne($audit['salesman_id']);
                $saasUser = SaasUser::findOne($salesman->saas_user_id);
                $audit['salesman_name'] = $saasUser->name;
            }
            $audit['city'] = '';
            if (!empty($audit['province_id']) || !empty($audit['city_id']) || !empty($audit['district_id'])) {
                $arr = [$audit['province_id'], $audit['city_id'], $audit['district_id']];
                $arr = District::find()->where(['id' => $arr])->select('name')->column();
                $audit['city'] = implode('/', $arr);
            }
            $admin = Admin::findOne(['type' => 'store', 'saas_user_id' => $saas_user_id, 'is_delete' => 0]);
            if ($admin) {
                $store = Store::findOne(['id' => $admin->type_id, 'is_delete' => 0]);
            }
            if (isset($store) && $store) {
                $audit = null;
            }
            return $this->asJson([
                'code' => 0,
                'msg' => "获取成功",
                'data' => $audit ?: [
                    'mobile' => get_saas_user()->mobile
                ]
            ]);
        } catch (\Exception $e) {
            return $this->asJson([
                'code' => 1,
                'msg' => $e->getMessage()
            ]);
        }
    }

    public function actionOtherInfo() {
        $store_apply_banner = Option::get('store_apply_banner', 0, 'saas', '')['value'];
        $admin_copyright = Option::get('store_apply_agreement', 0, 'saas', '')['value'];
        $store_apply_audit = Option::get('store_apply_audit', 0, 'saas', 0)['value'];
        $store_apply_free = Option::get('store_apply_free', 0, 'saas', 1)['value'];
        $store_apply_free_days = Option::get('store_apply_free_days', 0, 'saas', 5)['value'];
        $store_apply_buy_type = Option::get('store_apply_buy_type', 0, 'saas', 'free')['value'];//free/once/renew
        $store_apply_buy_money = Option::get('store_apply_buy_money', 0, 'saas', 0)['value'];
        $store_apply_renew = Option::get('store_apply_renew', 0, 'saas', 'sys')['value']; //sys/custom
        $priceList = \app\models\StorePrice::findAll(['is_delete' => 0]);
        return $this->asJson([
            'code' => 0,
            'data' => [
                'store_apply_banner' => $store_apply_banner ? Json::decode($store_apply_banner) : [],
                'store_apply_agreement' => $admin_copyright,
                'store_apply_audit' => $store_apply_audit,
                'store_apply_free' => $store_apply_free,
                'store_apply_free_days' => $store_apply_free_days,
                'store_apply_buy_type' => $store_apply_buy_type,
                'store_apply_buy_money' => $store_apply_buy_money,
                'store_apply_renew' => $store_apply_renew,
                'priceList' => $priceList,
            ]
        ]);
    }

    /**
     * 审核列表接口
     * @return \yii\web\Response
     */
    public function actionStoreList() {
        $saas_user_id = get_saas_user_id();



//        $list = $query->select('s.*')->orderBy('s.created_at DESC, s.updated_at DESC')->limit($pagination->limit)->offset($pagination->offset)->asArray()->all();

        $salesman = Salesman::findOne(['saas_user_id' => $saas_user_id, 'is_delete' => 0]);
        if (!$salesman) {
            return $this->asJson([
                'code' => 1,
                'msg' => '当前登录账户非业务员'
            ]);
        }


        $store_ids = SalesmanNewStore::find()->where(['salesman_saas_id' => $saas_user_id])
            ->andWhere(['>', 'store_id', 0])->select('store_id')->column();

        $query = Store::find()->where(['is_delete' => 0]);
        $query->andWhere([
            'or',
            ['salesman_id' => $salesman->id],//修改店铺业务员时候修改的
            ['store_admin' => $saas_user_id],//修改店铺业务员时候修改的
            ['in', 'id', $store_ids]//业务员帮助店铺进件时候增加
        ]);

        $sql = $query->createCommand()->getRawSql();
        $pagination = pagination_make($query);
        $list = $pagination['list'];


        foreach ($list as &$value) {
            $value['mobile'] = $value['contact_tel'] ?: (Admin::findOne($value['admin_id'])->mobile ?: (Option::get(OptionSetting::STORE_CONTACT_TEL, $value['id'])['value'] ?: '未设置手机号'));
            $value['cat_name'] = SaasCategory::findOne($value['category_id'])->name;
            $value['created_at'] = date('Y-m-d H:i:s', $value['created_at']);
            $value['logo'] = $value['logo'] ?: Option::get('web_log', $value['id'], 'web', '')['value'];
        }
        $result = [
            'code' => 0,
            'msg' => 'success',
            'data' => [
                'row_count' => $pagination['totalCount'],
                'page_count' => $pagination['pageNo'],
                'list' => $list,
                'sq' => $sql
            ],
        ];
        return $this->asJson($result);
    }

    /**
     * 业务员推荐商城，订单所获取的佣金
     */
    public function actionOrderList() {
        $saas_user_id = get_saas_user_id();
        $page = get_params('page', 1);
        $status = get_params('status', -1);
        $query = SharingReceiver::find()->alias('sr')->where(['sr.user_id' => $saas_user_id, 'sr.from' => SharingReceiver::FROM_RECOMMEND])
            ->leftJoin(['o' => Order::tableName()], 'o.order_no=sr.order_no')->andWhere(['like', 'sr.order_no', 'ML']);
        if (in_array($status, [0, 1])) {
            $query->andWhere(['sr.is_pay' => $status]);
        }
        $count = $query->count();
        $pagination = new Pagination(['totalCount' => $count, 'page' => $page - 1, 'pageSize' => 20]);
        $list = $query->select('sr.amount, o.id, o.order_no, o.pay_price, o.created_at, sr.is_pay')->orderBy('sr.updated_at DESC, sr.created_at DESC')->limit($pagination->limit)->offset($pagination->offset)->asArray()->all();
        foreach ($list as &$order) {
            $order['created_at'] = date('Y-m-d H:i:s', $order['created_at']);
            $order['goods_list'] = OrderDetail::find()->where(['order_id' => $order['id']])->select('goods_name, num, pic, total_price')->asArray()->all();
        }
        return $this->asJson([
            'code' => 0,
            'msg' => 'success',
            'data' => [
                'row_count' => $count,
                'page_count' => $pagination->pageCount,
                'list' => $list,
            ],
        ]);
    }
    /**
     * 关系绑定小程序码
     * @return \yii\web\Response
     */
    public function actionQr() {
        $saas_user_id = get_saas_user_id();
        $salesman_id = Salesman::findOne(['saas_user_id' => $saas_user_id, 'is_delete' => 0])->id;
        $scene = "salesman_id={$salesman_id}";
        $res = ShareQrcode::wxQrcode('salesman/salesman/applyShop', $scene, 600, true);
        if (isset($res['code']) && $res['code'] == 1) {
            return $this->asJson([
                'code' => 1,
                'msg' => $res['response']['errmsg'],
            ]);
        }
        return $this->asJson([
            'code' => 0,
            'data' => [
                'qr_url' => $res['url_path']
            ]
        ]);
    }

}