You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

312 lines
12 KiB
PHP

<?php
namespace Base\Service;
use Base\Facade\Request;
class PromoteCompanyService
{
const BELONG_INSIDE = 0;
const BELONG_OUTSIDE = 1;
const BELONG_OUTSIDE_SP = 2;
const BELONG_NONE = 3;
public static $belongs = [
0 => '内团',
1 => '外团',
2 => '外团-分发',
3 => '无',
];
public function getOutBelongs()
{
return [
self::BELONG_OUTSIDE => self::$belongs[self::BELONG_OUTSIDE],
self::BELONG_OUTSIDE_SP => self::$belongs[self::BELONG_OUTSIDE_SP],
];
}
public function getCompanies(array $ids = null, $fields = '*')
{
$map = [];
if (is_null($ids)) {
$map['_string'] = '1=1';
} elseif (count($ids) == 0) {
return [];
} else {
$map['id'] = ['in', $ids];
}
$rules = M('promote_company', 'tab_')->field($fields)->where($map)->select();
return index_by_column('id', $rules);
}
public function getCompaniesByBelong($belong = null, $fields = '*')
{
$map = [];
if (is_null($belong)) {
$map['_string'] = '1=1';
} else {
$map['company_belong'] = $belong;
}
$rules = M('promote_company', 'tab_')->field($fields)->where($map)->select();
return index_by_column('id', $rules);
}
public function checkPromotes($promotes, $exceptId = 0)
{
if (count($promotes) == 0) {
return;
}
foreach ($promotes as $promote) {
if (empty($promote['account'])) {
throw new \Exception('请输入会长账号');
}
if (strlen($promote['account']) > 15 || strlen($promote['account']) < 6) {
throw new \Exception('会长账号长度为6-15个字符');
}
if (!preg_match("/^[a-zA-Z0-9_\.]+$/", $promote['account'])) {
throw new \Exception('会长账号只能为数字,字母和下划线');
}
if (!empty($promote['mobile_phone'])) {
if (!preg_match("/^1[3456789]{1}\d{9}$/", $promote['mobile_phone'])) {
throw new \Exception('会长手机号格式错误');
}
}
if (!empty($promote['real_name'])) {
if (mb_strlen($promote['real_name']) < 2 || mb_strlen($promote['real_name']) > 4) {
throw new \Exception('会长姓名只能为2-4个字符');
}
}
}
$accounts = array_column($promotes, 'account');
$mobiles = array_column($promotes, 'mobile_phone');
if (count($accounts) != count(array_unique($accounts))) {
throw new \Exception('会长含有相同账号');
}
foreach ($mobiles as $key => $value) {
if ($value == '') {
unset($mobiles[$key]);
}
}
if (count($mobiles) != count(array_unique($mobiles))) {
throw new \Exception('会长含有相同手机号');
}
$existPromote = M('promote', 'tab_')->field('id')->where(['account' => ['in', $accounts]])->find();
if ($existPromote) {
throw new \Exception('会长账号已存在');
}
if (count($mobiles) > 0) {
$existPromote = M('promote', 'tab_')->field('id')->where(['mobile_phone' => ['in', $mobiles]])->find();
if ($existPromote) {
throw new \Exception('会长手机号已存在');
}
}
$verifyingPromotes = $this->getVerifyingPromotes($exceptId);
if ($this->isExistVerifyingPromoteAccount($accounts, $verifyingPromotes)) {
throw new \Exception('会长账号已存在');
}
if ($this->isExistVerifyingPromoteAccount($mobiles, $verifyingPromotes)) {
throw new \Exception('会长手机号已存在');
}
}
public function isExistVerifyingPromoteAccount($accounts, $verifyingPromotes)
{
$verifyingAccounts = array_column($verifyingPromotes, 'account');
$sameAccounts = array_intersect($accounts, $verifyingAccounts);
return count($sameAccounts) > 0;
}
public function isExistVerifyingPromoteMobile($mobiles, $verifyingPromotes)
{
$verifyingMobiles = array_unique(array_column($verifyingPromotes, 'mobile'));
$sameMobiles = array_intersect($mobiles, $verifyingMobiles);
return count($sameMobiles) > 0;
}
public function getVerifyingPromotes($exceptId = 0)
{
$promotes = [];
$verifyCompanies = M('promote_company_verify', 'tab_')->field(['company_info'])->where(['verify_status' => ['in', [0, 1]]])->getField('company_info', true);
if ($verifyCompanies) {
foreach ($verifyCompanies as $item) {
$row = json_decode($item, true);
if (isset($row['promotes'])) {
$promotes = array_merge($promotes, $row['promotes']);
}
}
}
return $promotes;
}
public function checkCompanyRelation($params)
{
if (empty($params['self_company_id'])) {
throw new \Exception('请选择己方公司');
}
}
public function adminAgree($application, $isAuto = false)
{
$adminInfo = $_SESSION['onethink_admin']['user_auth'];
$verifyLog = json_decode($application['verify_log'], true);
$verifyLog['admin_user'] = $isAuto ? 'AUOT' : $adminInfo["username"];
$verifyLog['admin_time'] = date("Y-m-d H:i:s");
$application['verify_log'] = json_encode($verifyLog);
$application['verify_status'] = 2;
$companyInfo = json_decode($application['company_info'], true);
$creator = M('ucenter_member', 'sys_')->field(['id', 'username'])->where(['username' => $verifyLog['create_user']])->find();
$deposit = null;
$bindRelation = $companyInfo['relation'];
$promotes = $companyInfo['promotes'];
if (isset($companyInfo['deposit'])) {
$deposit = $companyInfo['deposit'];
unset($companyInfo['deposit']);
}
unset($companyInfo['relation']);
unset($companyInfo['promotes']);
$isNewDeposit = false;
if($application['company_id'] == 0){
//新增
$isNewDeposit = true;
$application['company_id'] = $companyInfo['id'] = M('promote_company', 'tab_')->add($companyInfo);
}else{
//编辑
$oldInfo = M('promote_company', 'tab_')->field(['id', 'company_belong'])->where(['id' => $application['company_id']])->find();
/** 内团/无 切换为外团 */
if (in_array($companyInfo['company_belong'], [1, 2]) && !in_array($oldInfo['company_belong'], [1, 2])) {
$isNewDeposit = true;
}
M('promote_company', 'tab_')->save($companyInfo);
$this->changePromote($companyInfo);
}
$this->savePromoteCompanyRelation($bindRelation, $companyInfo);
$this->savePromotes($promotes, $companyInfo, $creator);
if ($isNewDeposit && in_array($companyInfo['company_belong'], [1, 2])) {
$depositService = new PresidentDepositService();
$depositService->save($deposit, $companyInfo);
}
//业务逻辑
M('PromoteCompanyVerify', 'tab_')->save($application);
addOperationLog(['op_type'=>1, 'key' => $application['id'], 'op_name'=>'管理员审核', 'url'=>U('index')]);
}
protected function savePromoteCompanyRelation($bindRelation, $company)
{
$selfCompany = M('company_info', 'tab_')->where(['id' => $bindRelation['self_company_id']])->find();
$where = '(first_company_type=2 and first_company_id=' . $company['id'] .
') or (second_company_type=2 and second_company_id=' . $company['id'] . ')';
$relation = M('company_relation', 'tab_')->where($where)->find();
$data = [];
if ($bindRelation['collaborate_way'] == 1) {
$data['first_company_id'] = $company['id'];
$data['first_company_name'] = $company['company_name'];
$data['first_company_type'] = 2;
$data['second_company_id'] = $selfCompany['id'];
$data['second_company_name'] = $selfCompany['partner'];
$data['second_company_type'] = 0;
} else {
$data['first_company_id'] = $selfCompany['id'];
$data['first_company_name'] = $selfCompany['partner'];
$data['first_company_type'] = 0;
$data['second_company_id'] = $company['id'];
$data['second_company_name'] = $company['company_name'];
$data['second_company_type'] = 2;
}
$data['settlement_type'] = $bindRelation['settlement_type'];
$data['invoice_type'] = $bindRelation['invoice_type'];
$data['collection'] = $bindRelation['collection'];
$data['is_payment'] = $bindRelation['is_payment'];
$data['invoice_content'] = $bindRelation['invoice_content'];
if ($relation) {
M('company_relation', 'tab_')->where(['id' => $relation['id']])->save($data);
} else {
M('company_relation', 'tab_')->add($data);
}
}
protected function changePromote($companyInfo){
$isChangeBelong = false;
$isChangeRelation =false;
if(empty($companyInfo['id'])){
return;
}
$companyId = $companyInfo['id'];
$oldInfo = M('promote_company', 'tab_')->field('company_belong,develop_type,game_ids')->where(['id' => $companyId])->find();
if(isset($companyInfo['company_belong']) && ($oldInfo['company_belong'] != $companyInfo['company_belong'])){
$isChangeBelong = true;
}
if(isset($companyInfo['develop_type']) && ($oldInfo['develop_type'] != $companyInfo['develop_type'])){
$isChangeRelation = true;
}
//处理底下所有会长的公会属性
if($isChangeBelong || $isChangeRelation ) {
$data = array(
'company_belong' => $save['company_belong'],
'company_relation' => $save['develop_type']
);
M('promote', 'tab_')->where(['company_id' => $companyId])->save($data);
// 权限跟随
if($isChangeBelong){
$authGroup = M('auth_group', 'sys_')->where(['title'=>'市场总监'])->find();
$subPromoteIds = M('promote', 'tab_')->where(['level' => 1, 'company_id' => $companyId])->getField('id', true);
$dataPresident = explode(',', $authGroup['data_president']);
if ($save['company_belong'] == 1 || $save['company_belong'] == 2) {
$dataPresident = array_unique(array_merge($dataPresident, $subPromoteIds));
} else {
$dataPresident = array_diff($dataPresident, $subPromoteIds);
}
M('auth_group', 'sys_')->where(['title' => '市场总监'])->save(['data_president' => implode(',', $dataPresident)]);
}
}
}
private function savePromotes($records, $company, $creator)
{
$promoteService = new PromoteService();
foreach ($records as $record) {
$promoteService->addPromote([
'account' => $record['account'],
'password' => $record['password'],
'real_name' => $record['real_name'],
'email' => $record['email'],
'mobile_phone' => $record['mobile_phone'],
'can_view_recharge' => $record['can_view_recharge'],
'company_id' => $company['id'],
'company_belong' => $company['company_belong'],
'company_relation' => $company['develop_type'],
'admin_id' => $creator ? $creator['id'] : 0,
]);
}
}
public function marketAgree($application, $isAuto = false)
{
$adminInfo = $_SESSION['onethink_admin']['user_auth'];
$application['verify_log'] = json_decode($application['verify_log'],true);
$application['verify_log']['market_user']= $isAuto ? 'AUOT' : $adminInfo["username"];
$application['verify_log']['market_time'] = date("Y-m-d H:i:s");
$application['verify_log'] = json_encode($application['verify_log']);
$application['verify_status'] = 1;
M('promote_company_verify', 'tab_')->where(['id' => $application['id']])->save($application);
addOperationLog(['op_type'=>1, 'key'=> $application['id'], "op_name"=>"市场部审核", 'url'=>U('index')]);
return $application;
}
}