seaBlueApi/Model/Enterprise/MEnterprise.Class.php

<?php
/**
 * 企业管理Model
 * Created by PhpStorm.
 * User: 小威
 * Date: 2019/11/04
 * Time: 11:50
 */

namespace JinDouYun\Model\Enterprise;

use Exception;
use Jindouyun\Cache\EnterpriseCache;
use Jindouyun\Cache\RoleAclCache;
use JinDouYun\Dao\Commission\DCommissionSetting;
use JinDouYun\Dao\Department\DStaff;
use JinDouYun\Dao\Merchant\DMerchantApply;
use JinDouYun\Dao\Shop\DShop;
use JinDouYun\Dao\Shop\DShopBindStaff;
use JinDouYun\Dao\Shop\DShopClock;
use JinDouYun\Dao\Shop\DShopKey;
use JinDouYun\Dao\Shop\DShopRostering;
use JinDouYun\Dao\Shop\DShopSubscribe;
use JinDouYun\Model\Commission\MCommissionGrade;
use JinDouYun\Model\Department\MDepartment;
use JinDouYun\Model\Department\MRole;
use JinDouYun\Model\GoodsCategory\MGoodsCategory;
use JinDouYun\Model\GoodsManage\MGoodsBrand;
use JinDouYun\Model\Merchant\MMerchant;
use JinDouYun\Model\Shop\MShop;
use JinDouYun\Model\Shop\MShopRostering;
use JinDouYun\Model\Shop\MShopSubscribe;
use JinDouYun\Model\ShopPartner\MShopPartner;
use JinDouYun\Model\Stock\MWarehouse;
use JinDouYun\Model\System\MPaymentSetting;
use Mall\Framework\Core\ErrorCode;
use Mall\Framework\Core\StatusCode;
use Mall\Framework\Core\ResultWrapper;

use JinDouYun\Dao\Enterprise\DEnterprise;
use JinDouYun\Dao\UserCenter\DUserCenter;
use JinDouYun\Dao\Enterprise\DUserBindEnterprise;
use JinDouYun\Model\SysAreaChina\MSysAreaChina;
use JinDouYun\Model\Department\MStaff;



class MEnterprise
{

    private $objDEnterprise;
    private $objDUserBindEnterprise;
    private $objDUserCenter;
    private $cutTable = 500000;

    public function __construct()
    {
        $this->objDUserCenter = new DUserCenter('default');
        $this->objDEnterprise = new DEnterprise('default');
        $this->objDUserBindEnterprise = new DUserBindEnterprise('default');
    }

    /**
     * 分表
     * @param $id
     * @throws Exception
     */
    public function enterpriseSubTable()
    {
        //企业表不考虑分表
        $this->objDEnterprise->setTable('qianniao_enterprise_1');
//        $tableName = $this->objDEnterprise->getTableName('qianniao_enterprise_', $id, $this->cutTable);
//        $this->objDEnterprise->setTable($tableName);
    }

    /**
     * 生成appid
     * @param $userCenterId
     * @return array
     */
    public function createAppid($userCenterId)
    {
        $returnData = [];

        //1 + 时间戳转日期(1107)4位 + 用户id(2位) + 毫秒时间提取(4位)
        $appid = '1'.date('md').substr(strval($userCenterId+100),-2).substr(microtime(),2, 4);
        $returnData['appid'] = intval($appid);

        $returnData['appSecret'] = md5($returnData['appid'].'qiannaio');

        $returnData['token'] = md5(md5($returnData['appid'].$returnData['appSecret'].'qianniao'));

        return $returnData;
    }

    /**
     * 增
     */

    /**
     * 企业添加
     * @param $params
     * @return ResultWrapper
     * @throws Exception
     */
    public function addEnterprise($params, $authorization)
    {
        //调用分表
        self::enterpriseSubTable();

        #777 查询商铺id 是否存在
        $params['createTime'] = $params['updateTime'];

        $params['expireTime'] = strtotime('+30 day');

        //增加加密字段
        $appidData = $this->createAppid($params['userCenterId']);
        $params = array_merge($params, $appidData);


        $enterpriseId = $this->objDEnterprise->insert($params);
        if($enterpriseId === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }

        //增加用户公司关系表
        $UserBindEnterpriseData = [
            'userCenterId' => $params['userCenterId'],
            'roleType' => StatusCode::$roleType['admin'],
            'enterpriseId' => $enterpriseId,
            'updateTime' => time(),
            'createTime' => time(),
        ];
        $dbResult = $this->objDUserBindEnterprise->insert($UserBindEnterpriseData);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }

        $returnData = [
            'enterpriseId' => $enterpriseId,
            'token' => $appidData['token'],
        ];

        //调用自动创建队列
        $data = [
            'userCenterId' => $params['userCenterId'],
            'enterpriseId' => $enterpriseId,
            'Authorization' => $authorization,
            'PROJECT_DOMAIN' => PROJECT_DOMAIN
        ];
        self::autoCreate($data, 'MEnterprise');

        return ResultWrapper::success( array_merge($params,$returnData) );
    }

    /**
     * 删
     */

    /**
     * 企业删除
     * @param $params
     * @return ResultWrapper
     * @throws Exception
     */
    public function deleteEnterprise($params)
    {
        //#777 校验公司id数据是否属于该用户id下的公司
        //调用分表
        self::enterpriseSubTable();
        $updateData = [
                'deleteStatus' => StatusCode::$delete,
                'updateTime' => time(),
            ];
        $dbResult = $this->objDEnterprise->update($updateData, ['id' => $params['enterpriseId']]);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }
        //删除用户企业关联表里的数据
        $dbReturn = $this->objDUserBindEnterprise->delete(['userCenterId' => $params['userCenterId'], 'enterpriseId' => $params['enterpriseId']]);
        if($dbReturn === false){
            return ResultWrapper::fail($this->objDUserBindEnterprise->error(), ErrorCode::$dberror);
        }

        return ResultWrapper::success($dbResult);
    }

    /**
     * 改
     */

    /**
     * 企业修改
     * @param $updateData
     * @param $params
     * @return ResultWrapper
     * @throws Exception
     */
    public function updateEnterprise($updateData, $params)
    {
        //#777 校验公司id数据是否属于该用户id下的公司
        //调用分表
        self::enterpriseSubTable();
        unset($updateData['userCenterId']);
        $updateData['updateTime'] = time();
        $dbResult = $this->objDEnterprise->update($updateData, $params);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }else{
            return ResultWrapper::success($dbResult);
        }
    }

    /**
     * 用户修改密码
     * @param $params
     * @param $where
     * @return ResultWrapper
     */
    public function updateUserCenterData($params, $where)
    {
        $dbResult = $this->objDUserCenter->get($where);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDUserCenter->error(), ErrorCode::$dberror);
        }
        if(empty($dbResult)){
            return ResultWrapper::fail('用户信息为空', ErrorCode::$dberror);
        }
        $userCenterData = $dbResult;
        unset($dbResult);

        if(password_verify($params['oldPassword'], $userCenterData['password']) === false){
            return ResultWrapper::fail('旧密码错误', ErrorCode::$paramError);
        }

        $updateData = [
            'password' => password_hash($params['newPassword'], PASSWORD_DEFAULT ),
            'updateTime' => time(),
        ];
        $dbResult = $this->objDUserCenter->update($updateData, $where);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDUserCenter->error(), ErrorCode::$dberror);
        }
        return ResultWrapper::success($dbResult);
    }

    /**
     * 查出当前登录用户下的企业列表
     * @param $userCenterId
     * @return ResultWrapper
     * @throws Exception
     */
    public function getAllEnterprise($userCenterId, $source = 1)
    {
        if(empty($userCenterId)){
            return ResultWrapper::fail('userCenterId参数为空', ErrorCode::$paramError);
        }

        switch ($source){
            case 1://管理员,员工
                $roleType = StatusCode::$roleType['admin'] . "," .StatusCode::$roleType['staff'];
                break;
            case 2://供应商
                $roleType = StatusCode::$roleType['supplier'];
                break;
            case 3://商户
                $roleType = StatusCode::$roleType['merchant'];
                break;
            default:
                return ResultWrapper::fail('获取企业列表source参数错误', ErrorCode::$paramError);
        }
        //企业表不考虑分表
        $this->objDEnterprise->setTable('qianniao_enterprise_1');
        $sql = "select b.userCenterId,b.enterpriseId,b.roleType,b.shopId,e.enterpriseName,e.logo,e.appid,e.token,e.expireTime,e.createTime,e.scope,e.isoem from " . $this->objDUserBindEnterprise->get_Table() . " b left join " . $this->objDEnterprise->get_Table() . " e on b.enterpriseId = e.id where b.userCenterId = ".$userCenterId." and b.roleType in (".$roleType.") and e.deleteStatus = " . StatusCode::$standard . " order by e.expireTime desc";
        $bindData = $this->objDUserBindEnterprise->query($sql);
        if ($bindData === false) {
            return ResultWrapper::fail($this->objDUserBindEnterprise->error(), ErrorCode::$dberror);
        }
        $return = [];
        $objDMerchantApply = new DMerchantApply();
        foreach($bindData as $value){
            $value['merchantData'] = [];
            switch ($value['roleType']){
                case StatusCode::$roleType['admin']:
                    //管理员
                    $value['isInEnterprise'] = StatusCode::$standard;
                    break;
                case StatusCode::$roleType['staff']:
                    //员工
                    if(empty($value['shopId'])){
                        $value['isInEnterprise'] = StatusCode::$standard;
                    }
                    break;
                case StatusCode::$roleType['merchant']:
                    //商户
                    $value['isInEnterprise'] = StatusCode::$delete;
                    //查询商户数据
                    $where =
                        [
                            'userCenterId' => $value['userCenterId'],
                            'enterpriseId' => $value['enterpriseId'],
                            'deleteStatus' => StatusCode::$standard,
                            'auditStatus' => StatusCode::$auditStatus['auditPass'],
                        ];
                    $dbResult = $objDMerchantApply->get($where, 'id,`name`,`desc`,category,contactName,contactMobile,expireTime,enabledStatus');
                    if($dbResult === false){
                        return ResultWrapper::fail($objDMerchantApply->error(), ErrorCode::$dberror);
                    }
                   
                    if($dbResult['enabledStatus'] == StatusCode::$delete){
                        return ResultWrapper::fail('该商户已禁用', ErrorCode::$accountfail);
                    }
                    $value['merchantData'] = $dbResult;
                    unset($dbResult);
                    break;
                default:
                    $value['isInEnterprise'] = StatusCode::$delete;
                    break;
            }
            if(!isset($return[$value['enterpriseId']])){
                $value['roleType'] = [$value['roleType']];
                $return[$value['enterpriseId']] = $value;
            }else{
                $return[$value['enterpriseId']]['roleType'][] = $value['roleType'];
            }
        }
        return ResultWrapper::success(self::format(array_values($return)));
    }

    /**
     * 企业详情
     * @param $params
     * @return ResultWrapper
     * @throws Exception
     */
    public function getEnterpriseInfo($params)
    {
        //调用分表
        self::enterpriseSubTable();

        $dbResult = $this->objDEnterprise->get(['id' => $params['enterpriseId']]);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }else{
            $objMSysAreaChina = new MSysAreaChina();
            if (isset($dbResult['provinceCode']) && isset($dbResult['cityCode']) && isset($dbResult['districtCode'])) {
                $areaName = $objMSysAreaChina->getNameByCode([
                    $dbResult['provinceCode'],
                    $dbResult['cityCode'],
                    $dbResult['districtCode']
                ]);
                $dbResult['area']['provinceName'] = isset($areaName[$dbResult['provinceCode']]) ? $areaName[$dbResult['provinceCode']] : '';
                $dbResult['area']['cityName'] = isset($areaName[$dbResult['cityCode']]) ? $areaName[$dbResult['cityCode']] : '';
                $dbResult['area']['districtName'] = isset($areaName[$dbResult['districtCode']]) ? $areaName[$dbResult['districtCode']] : '';
                $dbResult['area']['address'] = $dbResult['address'];
            }
            return ResultWrapper::success($dbResult);
        }
    }

    /**
     * 根据企业id获取企业数据
     * @param $enterpriseId
     * @return ResultWrapper
     * @throws Exception
     */
    public function getEnterpriseDataByEnterpriseId($enterpriseId)
    {
        //调用分表
        self::enterpriseSubTable();
        $dbResult = $this->objDEnterprise->get(['id' => $enterpriseId, 'deleteStatus' => StatusCode::$standard]);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }
        return ResultWrapper::success($dbResult);
    }

    /**
     * 根据用户id获取企业信息
     * @param $userId
     * @return array|bool|ResultWrapper
     * @throws Exception
     */
    public function getEnterpriseByUserId($userId)
    {
        //调用分表
        self::enterpriseSubTable();
        $sql = "select e.token,b.roleType from qianniao_user_bind_enterprise b LEFT JOIN ".$this->objDEnterprise->get_Table()." e on b.enterpriseId = e.id where b.userCenterId = ".$userId;
        $bindData = $this->objDUserBindEnterprise->query($sql);
        if($bindData === false){
            return ResultWrapper::fail($this->objDUserBindEnterprise->error(), ErrorCode::$dberror);
        }
        return ResultWrapper::success($bindData);
    }

    /**
     * 根据企业id获取企业的管理员信息
     * @param $enterpriseId
     * @param array $userCenterId
     * @return ResultWrapper
     * @throws Exception
     */
    public function getAdminsByEnterpriseId($enterpriseId, $userCenterId = [])
    {
        empty($enterpriseId) && ResultWrapper::fail('参数错误', ErrorCode::$paramError);
        $whereSql = '';
        if(!empty($userCenterId) && $userCenterId != false){
            if(is_array($userCenterId)){
                if(count($userCenterId) == 1){
                    $whereSql .= ' AND u.id in('. array_shift($userCenterId).')';
                }else{
                    $whereSql .= ' AND u.id in('.implode(',', $userCenterId).')';
                }
            }else{
                $whereSql .= ' AND u.id in('.$userCenterId.')';
            }
        }
        $sql = 'SELECT b.*,u.mobile AS userMobile FROM qianniao_user_bind_enterprise b LEFT JOIN qianniao_user_center u ON b.userCenterId = u.id  WHERE b.enterpriseId = '.$enterpriseId.' AND b.roleType BETWEEN '.StatusCode::$roleType['admin'].' AND '.StatusCode::$roleType['staff'].' AND u.deleteStatus ='.StatusCode::$standard.$whereSql;
        $dbResult = $this->objDUserBindEnterprise->query($sql);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDUserBindEnterprise->error(), ErrorCode::$dberror);
        }

        $createAdminId = 0;
        foreach($dbResult as &$value){
            if($value['roleType'] == StatusCode::$roleType['admin']){
                if(!$createAdminId){
                    //企业创建者NAME
                    //调用分表
                    $createAdminId = $value['userCenterId'];
                    self::enterpriseSubTable();
                    $enterpriseDbResult = $this->objDEnterprise->get(['id' => $enterpriseId, 'userCenterId' => $createAdminId], 'contact');
                    if($enterpriseDbResult === false){
                        return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
                    }
                    if(empty($enterpriseDbResult)){
                        return ResultWrapper::fail('企业信息查询失败', ErrorCode::$paramError);
                    }
                    $value['name'] = $enterpriseDbResult['contact'];
                }else{
                    return ResultWrapper::fail('角色id错误', ErrorCode::$paramError);//一个企业不可能有多个创建者
                }
            }else{
                $value['name'] = '';
                $userCenterIds[] = $value['userCenterId'];
            }
        }
        unset($value);
        if(empty($userCenterIds)){
            return ResultWrapper::success($dbResult);
        }
        //职工name
        $objMStaff = new MStaff($enterpriseId);
        $modelResult = $objMStaff->getStaffByUserCenterIds($userCenterIds);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
        }
        $staffData = $modelResult->getData();
        $newStaffData = [];
        if(!empty($staffData)){
            foreach ($staffData as $key => $value){
                $newStaffData[$value['userCenterId']] = $value;
            }
        }

        foreach($dbResult as $key => $value){
           if(isset($newStaffData[$value['userCenterId']])){
               $dbResult[$key]['name'] = $newStaffData[$value['userCenterId']]['staffName'];
           }else if($value['roleType'] == StatusCode::$roleType['staff']){
               unset($dbResult[$key]);
           }
        }
        return ResultWrapper::success($dbResult);
    }

    /**
     * 格式化企业列表数据 过期状态
     * @param $data
     * @return mixed
     */
    public function format($data)
    {
        $objEnterpriseCache = new EnterpriseCache();
        foreach($data as &$v){
            $v['expireStatus'] = true;
            if($v['expireTime'] > time()){
                $v['expireStatus'] = false;
            }
            //映射redis缓存里的企业生产日期设置
            $cacheResult = $objEnterpriseCache->getEnterpriseData($v['enterpriseId'], 'shelfLifeSetUp');
            $v['shelfLifeSetUp'] = $cacheResult ? $cacheResult : StatusCode::$delete;
        }
        return $data;
    }

    /**
     * 根据用户token获取用户信息(无用)
     * @param $params
     * @return ResultWrapper
     * @throws Exception
     */
    public function getStaffByToken($params)
    {
        //调用分表
        self::enterpriseSubTable();
        //1.查询是否有角色绑定
        $where = [
            'enterpriseId' => $params['enterpriseId'],
//            'shopId' => $params['shopId'],
            'userCenterId' => $params['userCenterId'],
        ];

        $dbResult = $this->objDUserBindEnterprise->get($where);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDUserBindEnterprise->error(), ErrorCode::$dberror);
        }
        $bind = $dbResult;
        unset($dbResult);
        $returnData = [
            'staffId' => '',
            'name' => '',
            'userCenterId' => $params['userCenterId']
        ];
        if(empty($bind)){
            return ResultWrapper::success($returnData);
        }
        if($bind['roleType'] == StatusCode::$roleType['merchant']){
            //商户
            $objMMerchant = new MMerchant($params['enterpriseId'], false);
            $modelResult = $objMMerchant->getMerchantData(['id' => $bind['merchantId']]);
            if(!$modelResult->isSuccess()){
                return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
            }
            $merchant = $modelResult->getData();
            unset($modelResult);
            $returnData['name'] = $merchant['contactName'];
        }else{
            //员工
            $objMStaff = new MStaff($params['enterpriseId']);
            $modelResult = $objMStaff->getStaffData(['userCenterId' => $params['userCenterId'], 'deleteStatus' => StatusCode::$standard]);
            if(!$modelResult->isSuccess()){
                return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
            }
            $staff = $modelResult->getData();
            unset($modelResult);
            if(empty($staff)){
                return ResultWrapper::success($returnData);
            }
            $returnData['staffId'] = $staff['id'];
            $returnData['name'] = $staff['staffName'];
        }
        return ResultWrapper::success($returnData);
    }

    /**
     * 判断用户id是否是某企业下的
     * @param $userCenterId
     * @param $enterpriseId
     * @param bool $roleType
     * @return ResultWrapper
     */
    public function isUserCenterBindEnterprise($userCenterId, $enterpriseId, $roleType = false)
    {
        $where = [
            'userCenterId' => $userCenterId,
            'enterpriseId' => $enterpriseId,
        ];
        $roleType && $where['roleType'] = $roleType;
        $dbResult = $this->objDUserBindEnterprise->select($where);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDUserBindEnterprise->error(), ErrorCode::$dberror);
        }
        if(empty($dbResult)){
            return ResultWrapper::fail('账号不存在', ErrorCode::$paramError);
        }
        return ResultWrapper::success($dbResult);
    }

    /**
     * 自动创建
     * @param $data
     * @param $className
     */
    protected static function autoCreate($data, $className)
    {
        $i = 1;
        do {
            $postData = [
                'topicName'         => 'MyJob',
                'topicClass'        => "Jobs\Model\MTopic\Enterprise\\".$className,
                'topicMethon'       => 'autoCreate',
                'topicMethonParams' => [
                    'data' => $data
                ],
            ];
            $url = QIANNIAO_QUEUE . '/CAddJob/add';
            $result = request($url, $postData);
            $i++;
        } while ($result['httpcode'] != 200 && $i <= 3);
    }

    /**
     * 创建企业自动创建数据
     * @param $userCenterId
     * @param $enterpriseId
     * @return ResultWrapper
     * @throws Exception
     */
    public function autoCreateData($userCenterId, $enterpriseId)
    {
        self::enterpriseSubTable();

        //查询企业数据
        $dbResult = $this->objDEnterprise->get(['id'=> $enterpriseId]);

        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }
        $enterpriseData = $dbResult;
        unset($dbResult);

        //新建合伙人
//        $objMShopPartner = new MShopPartner($enterpriseId, $userCenterId);
//        $insertShopPartnerData = [
//            "logo"         => $enterpriseData['logo'],
//            "name"         => $enterpriseData['enterpriseName'],//合伙名称
//            "model"        => 1,
//            "provinceCode" => $enterpriseData['provinceCode'],//省编码
//            "cityCode"     => $enterpriseData['cityCode'],//市编码
//            "districtCode" => $enterpriseData['districtCode'],//区编码
//            "address"      => $enterpriseData['address'], //详细地址
//            "userCenterId" => $userCenterId,//负责人id
//            "userName"     => $enterpriseData['contact'],//负责人名称
//            "mobile"       => $enterpriseData['mobile'], //负责人电话
//            "enterpriseId" => $enterpriseId,
//            'updateTime'   => time(),
//            'createTime'   => time(),
//        ];
//        $modelResult = $objMShopPartner->addShopPartner($insertShopPartnerData);
//        if(!$modelResult->isSuccess()){
//            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
//        }
//        $shopPartnerId = $modelResult->getData();
//        unset($modelResult);


        //新建仓库
        $objMWarehouse = new MWarehouse($enterpriseId);
        $insertWarehouseData = [
            "warehouseName" => '默认仓库',
            "contactName" => $enterpriseData['contact'],
            "contactMobile" => $enterpriseData['mobile'],
            "provinceCode" => $enterpriseData['provinceCode'],
            "cityCode" => $enterpriseData['cityCode'],
            "districtCode" => $enterpriseData['districtCode'],
            "contactAddress" =>  $enterpriseData['address'],
            "costType" => 1,
            "deleteStatus" => StatusCode::$standard,
            "enableStatus" => StatusCode::$standard,
            'updateTime' => time(),
            'createTime' => time(),
        ];
        $modelResult = $objMWarehouse->addWarehouse($insertWarehouseData);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
        }
        $warehouseId = $modelResult->getData();
        unset($modelResult);
        //新建商铺
        $objMShop = new MShop($enterpriseId, $userCenterId);

        $insertShopData = [
            'logo'           => $enterpriseData['logo'],//logo
            'shopType'       => 1,//商铺类型
            'isMaster'       => 5,//自动创建
            'costType'       => 1,//成本计算方式 1移动加权 2个别计价
            'name'           => '默认门店',//名称
            'warehouseId'    => $warehouseId,
            'openTime'       => '{"end": "", "start": "", "isAllDay": 1}',//营业时间
            'contactName'    => $enterpriseData['contact'],//联系人
            'mobile'         => $enterpriseData['mobile'],//联系电话
//            'shopPartnerId'  => $shopPartnerId,//合伙人Id
            "provinceCode"   => $enterpriseData['provinceCode'],//省编码
            "cityCode"       => $enterpriseData['cityCode'],//市编码
            "districtCode"   => $enterpriseData['districtCode'],//区编码6
            "address"        => $enterpriseData['address'], //详细地址
            'salesArea'      => '["0-0-0"]',
            'deleteStatus'   => StatusCode::$standard,
            'enableStatus'   => StatusCode::$standard,
            'createTime'     => time(),
            'updateTime'     => time(),
        ];
        $modelResult = $objMShop->addShop($insertShopData);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
        }
        $shopId = $modelResult->getData();
        unset($modelResult);
        //新建分类
        $objMGoodsCategory = new MGoodsCategory($userCenterId, $enterpriseId);
        $insertGoodsCategory = [
            'sort'       => 0,//排序
            'title'      => '默认分类',//分类名称
            'adImage'    => $enterpriseData['logo'],//广告图片
            'images'     => $enterpriseData['logo'],//图片
            'link'       => '',//分类链路
            'pid'        => 0,
            'enableStatus' => StatusCode::$standard
        ];
        $modelResult = $objMGoodsCategory->addCategory($insertGoodsCategory);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(),$modelResult->getErrorCode());
        }
        $goodsCategoryId = $modelResult->getData();
        unset($modelResult);

        //新建品牌
        $objMGoodsBrand = new MGoodsBrand($userCenterId,$enterpriseId);
        $insertGoodsBrand = [
            'title'         => '默认品牌',//名称
            'images'        => $enterpriseData['logo'],//图片
            'enableStatus'  =>  StatusCode::$standard,
            'createTime'    => time(),
            'updateTime'    => time(),
        ];
        $modelResult = $objMGoodsBrand->addBrand($insertGoodsBrand);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(),$modelResult->getErrorCode());
        }
        $goodsBrandId = $modelResult->getData();
        unset($modelResult);

        //新建部门
        $objMDepartment = new MDepartment($enterpriseId);

        $insertDepartment = [
            "departmentName" => '总裁办',
            "pid" => 0,
            "order" => 0,
            "desc" => '',
            "extend" => [],
            "updateTime" => time(),
        ];
        $insertDepartment['extend']['departmentPidPath'] = '';
        $insertDepartment['extend'] = json_encode($insertDepartment['extend']);

        $modelResult = $objMDepartment->addDepartment($insertDepartment);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
        }
        $departmentId = $modelResult->getData();
        unset($modelResult);

        //新建岗位
        $objMRole = new MRole($enterpriseId);
        $insertRole = [
            "roleName" => '总裁',
            "isAdministrator" => 5,
            "pid" => 0,
            "updateTime" => time(),
            "acl" => null,
        ];

        $insertRole['acl'] = !empty($insertRole['acl']) ? json_encode($insertRole['acl']) : NULL;

        $modelResult = $objMRole->addRole($insertRole);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
        }
        $roleId = $modelResult->getData();
        unset($modelResult);

        //添加职工
        $insertStaff = [
            "userCenterId" => $userCenterId, // int(10) DEFAULT NULL COMMENT '用户中心id',
            "departmentId" => $departmentId, //int(10) DEFAULT NULL COMMENT '部门id',
            "staffName" => $enterpriseData['contact'], //varchar(30) DEFAULT NULL COMMENT '员工姓名',
            "roleId" => $roleId, //int(10) DEFAULT NULL COMMENT '角色id',
            "mobile" => $enterpriseData['mobile'], //varchar(11) DEFAULT NULL COMMENT '手机号',
            "deleteStatus" => StatusCode::$standard, //tinyint(3) NOT NULL DEFAULT '5' COMMENT '删除状态 4:删除 5:正常',
            "createTime" => time(), //int(10) DEFAULT NULL COMMENT '创建时间',
            "updateTime" => time(), //int(10) DEFAULT NULL COMMENT '修改时间',
            "extend" => '{"rolePidPath": "1", "departmentPidPath": "1"}',
            "dataField" => '{"shopIds": [], "staffIds": [], "dataField": 3, "shopNames": [], "staffNames": []}', //json DEFAULT NULL COMMENT '数据域',
        ];
        $objDStaff = new DStaff();
        $objDStaff->setTable($objDStaff->get_Table().'_'.$enterpriseId);
        $dbResult = $objDStaff->insert($insertStaff);
        if($dbResult === false){
            return ResultWrapper::fail($objDStaff->error, ErrorCode::$dberror);
        }
        $staffId = $dbResult;
        unset($dbResult);
        // 添加排班表
        $objMShopRostering = new DShopRostering();
        $objMShopRostering->setTable($objMShopRostering->get_Table().'_'.$enterpriseId);
        //添加预约表
        $objMShopSubscribe = new DShopSubscribe();
        $objMShopSubscribe->setTable($objMShopSubscribe->get_Table().'_'.$enterpriseId);

        //添加打卡记录表
//        $objDShopClock = new DShopClock();
//        $objDShopClock->setTable($objDShopClock->get_Table().'_'.$enterpriseId);

        //添加默认支付方式
        $objMPaymentSetting = new MPaymentSetting($userCenterId, $enterpriseId);
        $updateEnable['id'] = 3;
        $updateEnable['enableStatus'] = StatusCode::$standard;
        $modelResult = $objMPaymentSetting->updateEnableStatus($updateEnable);
        if(!$modelResult->isSuccess()){
            return ResultWrapper::fail($modelResult->getData(), $modelResult->getErrorCode());
        }
        unset($modelResult);

        $objDCommissionSetting = new DCommissionSetting();
        $objDCommissionSetting->setTable('qianniao_commission_setting');
        //自动新增分销
        $commissionSettingDate = [
            'enterpriseId'=>$enterpriseId,
            'self'=>StatusCode::$delete
        ];
        $insert = $objDCommissionSetting->insert($commissionSettingDate);
        if($insert === false){
            return ResultWrapper::fail($objDCommissionSetting->error(), ErrorCode::$dberror);
        }

        return ResultWrapper::success('自动创建成功');

    }
    /**
     * 通过企业toke获取企业id
     * @param string $token 企业token
     * @return ResultWrapper
     */
    public function getEnterpriseIdByToken($token)
    {
        $this->objDEnterprise->setTable('qianniao_enterprise_1');
        $dbResult =  $this->objDEnterprise->get_field('id', ['token'=>$token]);
        if($dbResult === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }
        if(empty($dbResult)){
            return ResultWrapper::success(0);
        }

        return ResultWrapper::success($dbResult);
    }

    /**
     * 列表
     * @param $where
     * @return mixed
     */
    public function list($where)
    {
        $where['deleteStatus'] = 5;
        $where['iosAuditStatus'] = 5;
        $this->objDEnterprise->setTable('qianniao_enterprise_1');
        $dbResult = $this->objDEnterprise->select($where, '*', 'id DESC');
        $count = $this->objDEnterprise->count($where);
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }

        $return = [
            'data' => $dbResult,
            'total' => $count,
        ];

        if($return === false){
            return ResultWrapper::fail($this->objDEnterprise->error(), ErrorCode::$dberror);
        }else{
            return ResultWrapper::success($return);
        }
    }

}