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); } } }