479 lines
19 KiB
PHP
479 lines
19 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\Admin;
|
|
|
|
use App\Events\OperationLoggedEvent;
|
|
use App\Exports\QuotaExport;
|
|
use App\Exports\QuotaLogExport;
|
|
use App\Facades\HttpService;
|
|
use App\Http\Controllers\Controller;
|
|
use App\Http\Response\ResponseJson;
|
|
use App\Models\AgentUser;
|
|
use App\Models\Collaborator;
|
|
use App\Models\Office;
|
|
use App\Models\Quota;
|
|
use App\Models\QuotaLog;
|
|
use App\Models\Station;
|
|
use App\Models\StationLog;
|
|
use App\Models\User;
|
|
use App\Validators\CollaboratorValidator;
|
|
use Exception;
|
|
use Illuminate\Database\Eloquent\ModelNotFoundException;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Validator;
|
|
use Maatwebsite\Excel\Facades\Excel;
|
|
|
|
class CollaboratorsController extends Controller
|
|
{
|
|
use ResponseJson;
|
|
|
|
protected CollaboratorValidator $validator;
|
|
|
|
/**
|
|
* @param CollaboratorValidator $validator
|
|
*/
|
|
public function __construct(CollaboratorValidator $validator)
|
|
{
|
|
$this->validator = $validator;
|
|
}
|
|
|
|
/**
|
|
* 合作商列表
|
|
*
|
|
* @param Request $request
|
|
* @return \Illuminate\Contracts\Foundation\Application|\Illuminate\Contracts\View\Factory|\Illuminate\Contracts\View\View|\Illuminate\Http\JsonResponse
|
|
*/
|
|
public function index(Request $request)
|
|
{
|
|
$keyword = $request->input('keyword');
|
|
$status = $request->input('status',null);
|
|
$page_size = $request->input('page_size',15);
|
|
$type = $request->input('type');
|
|
$no_page = $request->input('no_page');
|
|
$query = Collaborator::query()
|
|
->when($status !== null,function ($query) use ($status) {
|
|
$query->where('status',$status);
|
|
})
|
|
->when(strlen($type) > 0,function ($query) use ($type) {
|
|
$query->where('type',$type);
|
|
})
|
|
->when($keyword,function ($query) use($keyword){
|
|
$query->where("name", 'like', '%'.$keyword.'%')
|
|
->orWhere('mobile', 'like', '%'.$keyword.'%');
|
|
})
|
|
->orderByDesc('updated_at')
|
|
->orderByDesc('id');
|
|
|
|
if($no_page){
|
|
$collaborator = $query->get();
|
|
}else{
|
|
$collaborator = $query->paginate($page_size);
|
|
}
|
|
foreach ($collaborator as $item){
|
|
$station = Station::where('user_id',$item->user_id)->first();
|
|
$item->office_name = '';
|
|
$item->office_id = '';
|
|
if($station){
|
|
$office = Office::where('id',$station->office_id)->first();
|
|
$item->office_name = $office->office_name;
|
|
$item->office_id = $office->office_id;
|
|
}
|
|
}
|
|
|
|
return $this->success('ok', $collaborator);
|
|
}
|
|
|
|
public function detail($id)
|
|
{
|
|
try {
|
|
$collaborator = Collaborator::query()->findOrFail($id);
|
|
$station = Station::where('user_id',$collaborator->user_id)->first();
|
|
if($station){
|
|
$office = Office::where('id',$station->office_id)->first();
|
|
}
|
|
$collaborator->office_id = $office->id??'';
|
|
$collaborator->office_name = $office->office_name??'';
|
|
$collaborator->station_id = $station->id??'';
|
|
$collaborator->station_number = $station->number??'';
|
|
return $this->success('ok',$collaborator);
|
|
}catch (ModelNotFoundException){
|
|
return $this->jsonResponse(1,'合作商不存在');
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 修改合作商信息
|
|
*
|
|
* @param Request $request
|
|
* @param $id
|
|
* @return \Illuminate\Contracts\Foundation\Application|\Illuminate\Contracts\View\Factory|\Illuminate\Contracts\View\View|\Illuminate\Http\JsonResponse
|
|
*/
|
|
public function update(Request $request, $id)
|
|
{
|
|
DB::beginTransaction();
|
|
try {
|
|
//绑定工位
|
|
$office_id = $request->get('office_id');
|
|
if(!$office_id){
|
|
return $this->failure('请选择房间');
|
|
}
|
|
$data = $request->only(['avatar','name','mobile','intro','specialty','bio','protocols','diploma','type','id_card','agreement_number']);
|
|
|
|
$collaborator = Collaborator::query()->findOrFail($id);
|
|
|
|
if ($data['mobile'] && $data['mobile'] != $collaborator->mobile) {
|
|
$exist = Collaborator::where('mobile', $data['mobile'])->whereNot('id', $collaborator->id)->exists();
|
|
if ($exist)throw new Exception("手机号存在账号");
|
|
}
|
|
|
|
$collaborator->update($data);
|
|
|
|
//查看用户是否有工位
|
|
$user_station = Station::where('user_id',$collaborator->user_id)->first();
|
|
$station_id = $request->get('station_id');
|
|
if(!empty($user_station)){
|
|
$user_station->office_id = $office_id;
|
|
if(!$station_id){
|
|
//插入解绑记录
|
|
$log_unbind_map = [];
|
|
$log_unbind_map['station_id'] = $user_station->id;
|
|
$log_unbind_map['user_id'] = $collaborator->user_id;
|
|
$log_unbind_map['type'] = StationLog::TYPE_UNBIND;
|
|
$log_unbind_map['remark'] = '用户id:'.$collaborator->user_id.'解绑了工位:'.$user_station->number;
|
|
StationLog::create($log_unbind_map);
|
|
|
|
$user_station->number = Station::NO_FIXED_STATION;
|
|
$user_station->save();
|
|
|
|
//插入绑定记录
|
|
$log_map = [];
|
|
$log_map['station_id'] = $user_station->id;
|
|
$log_map['user_id'] = $collaborator->user_id;
|
|
$log_map['type'] = StationLog::TYPE_BIND;
|
|
$log_map['remark'] = '用户id:'.$collaborator->user_id.'绑定了工位:'.Station::NO_FIXED_STATION;
|
|
StationLog::create($log_map);
|
|
}else{
|
|
$station = Station::where('id',$station_id)->first();
|
|
if($station->user_id != $collaborator->user_id){
|
|
return $this->failure('该工位已绑定用户');
|
|
}
|
|
// $user_station->user_id = null;
|
|
// $user_station->save();
|
|
$log_unbind_map = [];
|
|
$log_unbind_map['station_id'] = $user_station->id;
|
|
$log_unbind_map['user_id'] = $collaborator->user_id;
|
|
$log_unbind_map['type'] = StationLog::TYPE_UNBIND;
|
|
$log_unbind_map['remark'] = '用户id:'.$collaborator->user_id.'解绑了工位:'.$user_station->number;
|
|
StationLog::create($log_unbind_map);
|
|
|
|
$station->user_id = $collaborator->user_id;
|
|
$station->save();
|
|
|
|
$log_map = [];
|
|
$log_map['station_id'] = $user_station->id;
|
|
$log_map['user_id'] = $collaborator->user_id;
|
|
$log_map['type'] = StationLog::TYPE_BIND;
|
|
$log_map['remark'] = '用户id:'.$collaborator->user_id.'绑定了工位:'.$station->number;
|
|
StationLog::create($log_map);
|
|
}
|
|
}else{
|
|
if(!$station_id){
|
|
$number = Station::NO_FIXED_STATION;
|
|
$model = Station::create(['office_id'=>$office_id,'number'=>$number,'user_id'=>$collaborator->user_id]);
|
|
}else{
|
|
$model = Station::where('id',$station_id)->first();
|
|
if(!empty($model->user_id)){
|
|
return $this->failure('该工位已绑定用户');
|
|
}
|
|
$number = $model->number;
|
|
$model->office_id = $office_id;
|
|
$model->user_id = $collaborator->user_id;
|
|
$model->save();
|
|
}
|
|
$log_map = [];
|
|
$log_map['station_id'] = $model->id;
|
|
$log_map['user_id'] = $collaborator->user_id;
|
|
$log_map['type'] = StationLog::TYPE_BIND;
|
|
$log_map['remark'] = '用户id:'.$collaborator->user_id.'绑定了工位:'.$number;
|
|
StationLog::create($log_map);
|
|
}
|
|
|
|
|
|
//操作记录
|
|
OperationLoggedEvent::dispatch("修改了合作商:$id 的信息");
|
|
|
|
DB::commit();
|
|
return $this->success('ok');
|
|
}catch (ModelNotFoundException){
|
|
return $this->jsonResponse(1,'合作商记录不存在');
|
|
}catch (Exception $e){
|
|
DB::rollBack();
|
|
return $this->jsonResponse(1,$e->getMessage());
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 删除合作商
|
|
*
|
|
* @param $id
|
|
* @return \Illuminate\Contracts\Foundation\Application|\Illuminate\Contracts\View\Factory|\Illuminate\Contracts\View\View|\Illuminate\Http\JsonResponse
|
|
*/
|
|
public function destroy($id)
|
|
{
|
|
try {
|
|
$collaborator = Collaborator::query()->findOrFail($id);
|
|
$collaborator->delete();
|
|
|
|
return $this->success('ok');
|
|
}catch (ModelNotFoundException){
|
|
return $this->jsonResponse(1,'合作商记录不存在');
|
|
}catch (Exception $e){
|
|
return $this->jsonResponse(1,$e->getMessage());
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 合作商审核
|
|
*
|
|
* @param Request $request
|
|
* @param $id
|
|
* @return \Illuminate\Contracts\Foundation\Application|\Illuminate\Contracts\View\Factory|\Illuminate\Contracts\View\View|\Illuminate\Http\JsonResponse
|
|
*/
|
|
public function audit(Request $request, $id)
|
|
{
|
|
DB::beginTransaction();
|
|
try {
|
|
$data = $request->only(['status','reason','type']);
|
|
|
|
$this->validator->scene('audit')->validate($data);
|
|
|
|
$collaborator = Collaborator::query()->findOrFail($id);
|
|
$collaborator->update($data);
|
|
//审核通过携带办公室id
|
|
$office_id = $request->input('office_id');
|
|
if(!empty($office_id)){
|
|
Station::create(['office_id'=>$office_id,'user_id'=>$collaborator->user_id,'number'=>Station::NO_FIXED_STATION]);
|
|
}
|
|
//审核通过以后更新用户表,先查看是否存在
|
|
if ($data['status'] == 1) {
|
|
User::updateServerUser($collaborator->mobile,$collaborator->user_id);
|
|
}
|
|
// if($data['status'] == Collaborator::STATUS_PASS && $data['type'] == Collaborator::TYPE_FULL_TIME){
|
|
// Station::create(['office_id'=>$office_id,'user_id'=>$collaborator->user_id,'number'=>Station::NO_FIXED_STATION]);
|
|
// }
|
|
|
|
|
|
//审核通过后加入服务用户表
|
|
// if ($data['status'] == 1) {
|
|
// //审核通过以后如果小程序有用户数据，则同步用户数据
|
|
// $user_data = User::getMpUser($collaborator->mobile);
|
|
// if($user_data){
|
|
// User::sameDataToUser($collaborator->user_id,$user_data->id);
|
|
// }
|
|
// }
|
|
User::where('id', $collaborator->user_id)->update(['name'=>$collaborator->name, 'mobile'=>$collaborator->mobile]);
|
|
//增加批发商
|
|
if ($data['status'] == 1 && $data['type'] == Collaborator::TYPE_FULL_TIME) //员工
|
|
{
|
|
//Mia说合作商审核和批发商角色没有关系
|
|
// AgentUser::changeLevel($collaborator->user_id, AgentUser::AgentStaff, "合作商员工审核", true);
|
|
}
|
|
DB::commit();
|
|
return $this->success('ok');
|
|
}catch (ModelNotFoundException){
|
|
return $this->jsonResponse(1,'合作商记录不存在');
|
|
}catch (Exception $e){
|
|
DB::rollBack();
|
|
return $this->jsonResponse(1,$e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function add(Request $request){
|
|
DB::beginTransaction();
|
|
try {
|
|
//绑定工位
|
|
$office_id = $request->get('office_id');
|
|
if(!$office_id){
|
|
return $this->failure('请选择房间');
|
|
}
|
|
$data = $request->only(['avatar','name','mobile','intro','specialty','bio','protocols','diploma','type','id_card','agreement_number']);
|
|
$data['status'] = Collaborator::STATUS_PASS;
|
|
$data['type'] = Collaborator::TYPE_USER;
|
|
|
|
$exist = User::where('mobile',$data['mobile'])->exists();
|
|
if ($exist) return $this->failure('手机号已被注册');
|
|
|
|
$agreement_number = Collaborator::where('agreement_number', $data['agreement_number'])->exists();
|
|
if ($agreement_number) return $this->failure('协议号已存在');
|
|
|
|
$user_model = User::create(['name'=>$data['name'],'mobile'=>$data['mobile'],'avatar'=>$data['avatar']]);
|
|
|
|
$station = Station::create(['office_id'=>$office_id,'number'=>Station::NO_FIXED_STATION,'user_id'=>$user_model->id]);
|
|
|
|
StationLog::create(['station_id'=>$station->id,'user_id'=>$user_model->id,'type'=>StationLog::TYPE_BIND,'remark'=>'用户id:'.$user_model->id.'绑定了工位:'.Station::NO_FIXED_STATION]);
|
|
|
|
$data['user_id'] = $user_model->id;
|
|
Collaborator::create($data);
|
|
|
|
DB::commit();
|
|
return $this->success('ok');
|
|
}catch (\Exception $e){
|
|
DB::rollBack();
|
|
return $this->failure($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function addQuota(Request $request){
|
|
try {
|
|
$data = $request->only(['agency_id','collaborator_id','num','agreement_number']);
|
|
$validated = Validator::make($data, [
|
|
'collaborator_id' => 'required',
|
|
'num' => 'required',
|
|
], [
|
|
'collaborator_id.required' => '请选择人员',
|
|
'num.required' => '请填写名额',
|
|
]);
|
|
if ($validated->fails()) {
|
|
$errors = $validated->errors()->all();
|
|
$error = count($errors) ? $errors[0] : null;
|
|
return $this->failure($error);
|
|
}
|
|
$agency_id = $data['agency_id']??'';
|
|
|
|
$query = Quota::query();
|
|
$query->when($agency_id,function ($query) use($agency_id){
|
|
$query->where("agency_id", $agency_id);
|
|
});
|
|
$quota = $query->where('collaborator_id',$data['collaborator_id'])->where('agreement_number',$data['agreement_number'])->first();
|
|
|
|
$admin = auth()->user();
|
|
if($quota){
|
|
$quota->num = $quota->num+$data['num'];
|
|
$quota->operate_user_id = $admin->id;
|
|
$quota->operate_user_name = $admin->name;
|
|
$quota->save();
|
|
}else{
|
|
$data['operate_user_id'] = $admin->id;
|
|
$data['operate_user_name'] = $admin->name;
|
|
Quota::create($data);
|
|
}
|
|
return $this->success('ok');
|
|
}catch (\Exception $e){
|
|
Log::error('addAgreement:'.$e->getMessage());
|
|
return $this->failure($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function getQuotaList(Request $request){
|
|
try {
|
|
$keyword = $request->input('keyword');
|
|
$is_export = $request->input('is_export');
|
|
$no_page = $request->input('no_page');
|
|
if($is_export){
|
|
$no_page = true;
|
|
}
|
|
$id = $request->input('id');
|
|
|
|
$query = Quota::query()->with('collaboratorInfo','agencyInfo');
|
|
|
|
$query->when($keyword,function ($query) use ($keyword){
|
|
// $query->where('agreement_number','like',"%{$keyword}%");
|
|
// $query->whereHas('collaboratorInfo',function ($query) use ($keyword) {
|
|
// $query->where('name','like',"%{$keyword}%")->orWhere('mobile','like',"%{$keyword}%");
|
|
// });
|
|
$query->where(function ($query) use ($keyword) {
|
|
$query->where('agreement_number', 'like', "%{$keyword}%")
|
|
->orWhereHas('collaboratorInfo', function ($query) use ($keyword) {
|
|
$query->where('name', 'like', "%{$keyword}%")
|
|
->orWhere('mobile', 'like', "%{$keyword}%");
|
|
});
|
|
});
|
|
});
|
|
|
|
$query->when($id,function ($query) use ($id){
|
|
$query->where('collaborator_id',$id);
|
|
});
|
|
|
|
$query->orderByDesc('id');
|
|
if($no_page){
|
|
$list = $query->get();
|
|
}else{
|
|
$list = $query->paginate();
|
|
}
|
|
if($is_export){
|
|
return Excel::download(new QuotaExport($list), '名额.xlsx');
|
|
}
|
|
return $this->success('ok',$list);
|
|
}catch (\Exception $e){
|
|
Log::error('getQuotaList:'.$e->getMessage());
|
|
return $this->failure($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function getQuotaLogList(Request $request,$id){
|
|
try {
|
|
$keyword = $request->input('keyword');
|
|
$is_export = $request->input('is_export');
|
|
|
|
$query = QuotaLog::query()->with('orderInfo');
|
|
|
|
$query->when($keyword,function ($query) use ($keyword) {
|
|
$query->whereHas('orderInfo',function ($query) use ($keyword) {
|
|
$query->where('name','like',"%{$keyword}%");
|
|
});
|
|
});
|
|
|
|
$query->when($id,function ($query) use ($id){
|
|
$query->where('quota_id',$id);
|
|
});
|
|
|
|
$query->orderByDesc('id');
|
|
|
|
if($is_export){
|
|
$list = $query->get();
|
|
}else{
|
|
$list = $query->paginate();
|
|
}
|
|
|
|
if($is_export){
|
|
return Excel::download(new QuotaLogExport($list), '名额使用记录.xlsx');
|
|
}
|
|
return $this->success('ok',$list);
|
|
}catch (\Exception $e){
|
|
Log::error('getQuotaList:'.$e->getMessage());
|
|
return $this->failure($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function updateQuota(Request $request,$id,Quota $quota){
|
|
try {
|
|
$data = $request->only(['agency_id','collaborator_id','num','agreement_number']);
|
|
$quota_info = $quota->find($id);
|
|
$quota_info->update($data);
|
|
if(!empty($data['num']) && ($data['num'] != $quota_info->num)){
|
|
$admin = auth()->user();
|
|
QuotaLog::addQuotaLog($admin,0,$data['num'],$quota_info->id);
|
|
}
|
|
return $this->success('ok');
|
|
}catch (\Exception $e){
|
|
Log::error('updateQuota:'.$e->getMessage());
|
|
return $this->failure($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function delQuota($id,Quota $quota){
|
|
try {
|
|
$quota->where('id',$id)->delete();
|
|
return $this->success('ok');
|
|
}catch (\Exception $e){
|
|
Log::error('delQuota:'.$e->getMessage());
|
|
return $this->failure($e->getMessage());
|
|
}
|
|
}
|
|
}
|