|
|
<?php
|
|
|
|
|
|
namespace App\Http\Controllers\Admin;
|
|
|
|
|
|
use App\Exports\CommonExport;
|
|
|
use App\Helpers\ResponseCode;
|
|
|
use App\Helpers\StarterResponseCode;
|
|
|
use App\Jobs\SendCourseCar;
|
|
|
use App\Jobs\SendCourseDoor;
|
|
|
use App\Models\AppointmentTotalLog;
|
|
|
use App\Models\Course;
|
|
|
use App\Models\CourseAppointmentTotal;
|
|
|
use App\Models\CourseForm;
|
|
|
use App\Models\CourseSign;
|
|
|
use App\Models\CustomFormField;
|
|
|
use App\Models\User;
|
|
|
use App\Notifications\AuditNotify;
|
|
|
use App\Notifications\FeeNotify;
|
|
|
use App\Notifications\FeeResultNotify;
|
|
|
use Illuminate\Support\Carbon;
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
use Illuminate\Support\Facades\Log;
|
|
|
use Illuminate\Support\Facades\Notification;
|
|
|
use Illuminate\Support\Facades\Validator;
|
|
|
use Maatwebsite\Excel\Facades\Excel;
|
|
|
use Rap2hpoutre\FastExcel\FastExcel;
|
|
|
|
|
|
class CourseSignController extends BaseController
|
|
|
{
|
|
|
|
|
|
/**
|
|
|
* 构造函数
|
|
|
*/
|
|
|
public function __construct()
|
|
|
{
|
|
|
parent::__construct(new CourseSign());
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Get(
|
|
|
* path="/api/admin/course-signs/index",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="列表",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="is_export", in="query", @OA\Schema(type="string"), required=false, description="是否导出0否1是"),
|
|
|
* @OA\Parameter(name="export_fields", in="query", @OA\Schema(type="string"), required=false, description="需要导出的字段数组"),
|
|
|
* @OA\Parameter(name="file_name", in="query", @OA\Schema(type="string"), required=false, description="导出文件名"),
|
|
|
* @OA\Parameter(name="filter", in="query", @OA\Schema(type="string"), required=false, description="查询条件。数组"),
|
|
|
* @OA\Parameter(name="show_relation", in="query", @OA\Schema(type="string"), required=false, description="需要输出的关联关系数组，填写输出指定数据.thirdAppointmentLogs第三方日志记录，thirdPlateLogs第三方车牌预约记录"),
|
|
|
* @OA\Parameter(name="page_size", in="query", @OA\Schema(type="string"), required=false, description="每页显示的条数"),
|
|
|
* @OA\Parameter(name="page", in="query", @OA\Schema(type="string"), required=false, description="页码"),
|
|
|
* @OA\Parameter(name="sort_name", in="query", @OA\Schema(type="string"), required=false, description="排序字段名字"),
|
|
|
* @OA\Parameter(name="sort_type", in="query", @OA\Schema(type="string"), required=false, description="排序类型"),
|
|
|
* @OA\Parameter(name="name", in="query", @OA\Schema(type="string"), required=false, description="名字"),
|
|
|
* @OA\Parameter(name="company_name", in="query", @OA\Schema(type="string"), required=false, description="公司名字"),
|
|
|
* @OA\Parameter(name="company_position", in="query", @OA\Schema(type="string"), required=false, description="职务"),
|
|
|
* @OA\Parameter(name="company_area", in="query", @OA\Schema(type="string"), required=false, description="所属区域"),
|
|
|
* @OA\Parameter(name="company_type", in="query", @OA\Schema(type="string"), required=false, description="企业性质"),
|
|
|
* @OA\Parameter(name="company_industry", in="query", @OA\Schema(type="string"), required=false, description="所属行业"),
|
|
|
* @OA\Parameter(name="is_schoolmate", in="query", @OA\Schema(type="string"), required=false, description="is_schoolmate"),
|
|
|
* @OA\Parameter(name="mobile", in="query", @OA\Schema(type="string"), required=true, description="手机号"),
|
|
|
* @OA\Parameter(name="education", in="query", @OA\Schema(type="string"), required=true, description="education学历"),
|
|
|
* @OA\Parameter(name="filter_date", in="query", @OA\Schema(type="string"), required=true, description="自定义字段筛选二维数组，包含键名name,value"),
|
|
|
* @OA\Parameter(name="start_date", in="query", @OA\Schema(type="string"), required=true, description="开始日期"),
|
|
|
* @OA\Parameter(name="end_date", in="query", @OA\Schema(type="string"), required=true, description="结束日期"),
|
|
|
* @OA\Parameter(name="course_type_id", in="query", @OA\Schema(type="string"), required=true, description="课程体系id，多个英文逗号"),
|
|
|
* @OA\Parameter(name="clear", in="query", @OA\Schema(type="string"), required=true, description="是否简单模式0否1是"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function index()
|
|
|
{
|
|
|
$all = request()->all();
|
|
|
$clear = request('clear', 1);
|
|
|
$list = $this->model->with(['course.typeDetail', 'user' => function ($query) use ($all, $clear) {
|
|
|
if ($clear) {
|
|
|
$query->with(['company', 'courseSigns' => function ($q) {
|
|
|
$q->where('status', 1)->with('course');
|
|
|
}]);
|
|
|
}
|
|
|
}])->whereHas('user', function ($query) use ($all) {
|
|
|
if (isset($all['is_vip'])) {
|
|
|
$query->where('is_vip', $all['is_vip']);
|
|
|
}
|
|
|
if (isset($all['company_name'])) {
|
|
|
$query->where('company_name', 'like', '%' . $all['company_name'] . '%');
|
|
|
}
|
|
|
if (isset($all['company_position'])) {
|
|
|
$query->where('company_position', $all['company_position']);
|
|
|
}
|
|
|
if (isset($all['company_area'])) {
|
|
|
$company_area = explode(',', $all['company_area']);
|
|
|
$query->whereIn('company_area', $company_area);
|
|
|
}
|
|
|
if (isset($all['company_type'])) {
|
|
|
$company_type = explode(',', $all['company_type']);
|
|
|
$query->where(function ($q) use ($company_type) {
|
|
|
foreach ($company_type as $v) {
|
|
|
$q->orWhereRaw('FIND_IN_SET(?, company_type)', [$v]);
|
|
|
}
|
|
|
});
|
|
|
}
|
|
|
if (isset($all['company_industry'])) {
|
|
|
$company_industry = explode(',', $all['company_industry']);
|
|
|
$query->whereIn('company_industry', $company_industry);
|
|
|
}
|
|
|
if (isset($all['is_schoolmate'])) {
|
|
|
$query->where('is_schoolmate', $all['is_schoolmate']);
|
|
|
}
|
|
|
if (isset($all['mobile'])) {
|
|
|
$query->where('mobile', 'like', '%' . $all['mobile'] . '%');
|
|
|
}
|
|
|
if (isset($all['education'])) {
|
|
|
$education = explode(',', $all['education']);
|
|
|
$query->whereIn('education', $education);
|
|
|
}
|
|
|
if (isset($all['type'])) {
|
|
|
$type = explode(',', $all['type']);
|
|
|
$query->where(function ($q) use ($type) {
|
|
|
foreach ($type as $v) {
|
|
|
$q->orWhereRaw('FIND_IN_SET(?, type)', [$v]);
|
|
|
}
|
|
|
});
|
|
|
}
|
|
|
})->where(function ($query) use ($all) {
|
|
|
if (isset($all['filter_date']) && !empty($all['filter_date'])) {
|
|
|
foreach ($all['filter_date'] as $item) {
|
|
|
$query->whereJsonContains("data->{$item->name}", $item->value);
|
|
|
}
|
|
|
}
|
|
|
})->where(function ($query) use ($all, $clear) {
|
|
|
if ($clear) {
|
|
|
$query->with('thirdAppointmentLogs');
|
|
|
}
|
|
|
if (isset($all['start_date'])) {
|
|
|
$query->whereDate('created_at', '>=', $all['start_date']);
|
|
|
}
|
|
|
if (isset($all['end_date'])) {
|
|
|
$query->whereDate('created_at', '<=', $all['end_date']);
|
|
|
}
|
|
|
if (isset($all['course_type_id'])) {
|
|
|
$course_type_id = explode(',', $all['course_type_id']);
|
|
|
$courses = Course::where(function ($query) use ($all) {
|
|
|
if (isset($all['start_date'])) {
|
|
|
$query->where('start_date', '>=', $all['start_date']);
|
|
|
}
|
|
|
if (isset($all['end_date'])) {
|
|
|
$query->where('start_date', '<=', $all['end_date']);
|
|
|
}
|
|
|
})->whereIn('type', $course_type_id)->get();
|
|
|
$query->whereNotIn('status', [4, 5])
|
|
|
->where(function ($query) use ($courses) {
|
|
|
$query->whereIn('course_id', $courses->pluck('id'));
|
|
|
});
|
|
|
}
|
|
|
if (isset($all['name'])) {
|
|
|
$query->where(function ($q) use ($all) {
|
|
|
$q->whereHas('user', function ($q) use ($all) {
|
|
|
$q->where('name', 'like', '%' . $all['name'] . '%');
|
|
|
})->orWhere('change_data', 'like', '%' . $all['name'] . '%');
|
|
|
});
|
|
|
}
|
|
|
if (isset($all['filter']) && !empty($all['filter'])) {
|
|
|
foreach ($all['filter'] as $condition) {
|
|
|
$key = $condition['key'] ?? null;
|
|
|
$op = $condition['op'] ?? null;
|
|
|
$value = $condition['value'] ?? null;
|
|
|
if (!isset($key) || !isset($op) || !isset($value)) {
|
|
|
continue;
|
|
|
}
|
|
|
// 等于
|
|
|
if ($op == 'eq') {
|
|
|
$query->where($key, $value);
|
|
|
}
|
|
|
// 不等于
|
|
|
if ($op == 'neq') {
|
|
|
$query->where($key, '!=', $value);
|
|
|
}
|
|
|
// 模糊搜索
|
|
|
if ($op == 'like') {
|
|
|
$query->where($key, 'like', '%' . $value . '%');
|
|
|
}
|
|
|
// 否定模糊搜索
|
|
|
if ($op == 'notlike') {
|
|
|
$query->where($key, 'not like', '%' . $value . '%');
|
|
|
}
|
|
|
// 范围搜索
|
|
|
if ($op == 'range') {
|
|
|
list($from, $to) = explode(',', $value);
|
|
|
if (empty($from) || empty($to)) {
|
|
|
continue;
|
|
|
}
|
|
|
$query->whereBetween($key, [$from, $to]);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
})->orderBy($all['sort_name'] ?? 'id', $all['sort_type'] ?? 'desc')
|
|
|
->orderBy('created_at', 'desc');
|
|
|
if (isset($all['is_export']) && !empty($all['is_export'])) {
|
|
|
$list = $list->limit(5000)->get()->toArray();
|
|
|
return Excel::download(new CommonExport($list, $all['export_fields'] ?? ''), $all['file_name'] ?? '' . date('YmdHis') . '.xlsx');
|
|
|
} else {
|
|
|
// 输出
|
|
|
$list = $list->paginate($all['page_size'] ?? 20);
|
|
|
}
|
|
|
return $this->success($list);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Get(
|
|
|
* path="/api/admin/course-signs/show",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="详情",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="id", in="query", @OA\Schema(type="string"), required=true, description="id"),
|
|
|
* @OA\Parameter(name="show_relation", in="query", @OA\Schema(type="string"), required=false, description="需要输出的关联关系数组，填写输出指定数据.thirdAppointmentLogs第三方日志记录，thirdPlateLogs第三方车牌预约记录"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function show()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$messages = [
|
|
|
'id.required' => 'Id必填',
|
|
|
];
|
|
|
$validator = Validator::make($all, [
|
|
|
'id' => 'required'
|
|
|
], $messages);
|
|
|
if ($validator->fails()) {
|
|
|
return $this->fail([ResponseCode::ERROR_PARAMETER, implode(',', $validator->errors()->all())]);
|
|
|
}
|
|
|
$detail = $this->model->with(underlineToHump($all['show_relation'] ?? []))->find($all['id']);
|
|
|
$detail->audits = $detail->audits()->with('user')->get();
|
|
|
return $this->success($detail);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Post(
|
|
|
* path="/api/admin/course-signs/save",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="更新或新增",
|
|
|
* @OA\Parameter(name="update_user", in="query", @OA\Schema(type="integer"), required=true, description="是否更新用户信息0否1是"),
|
|
|
* @OA\Parameter(name="id", in="query", @OA\Schema(type="integer"), required=true, description="课程ID（存在则更新，不存在则新增）"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="验证token"),
|
|
|
* @OA\Parameter(name="course_id", in="query", @OA\Schema(type="string"), description="课程id"),
|
|
|
* @OA\Parameter(name="title", in="query", @OA\Schema(type="string", format="date"), description="标题"),
|
|
|
* @OA\Parameter(name="content", in="query", @OA\Schema(type="string", format="date"), description="内容"),
|
|
|
* @OA\Parameter(name="status", in="query", @OA\Schema(type="string", format="date"), description="状态0待审核1通过2拒绝3备选"),
|
|
|
* @OA\Parameter(name="reason", in="query", @OA\Schema(type="string", format="date"), description="原因"),
|
|
|
* @OA\Parameter(name="score", in="query", @OA\Schema(type="string", format="date"), description="分数"),
|
|
|
* @OA\Parameter(name="position", in="query", @OA\Schema(type="string", format="date"), description="职位"),
|
|
|
* @OA\Parameter(name="fee_status", in="query", @OA\Schema(type="string", format="date"), description="0未缴费1缴费成功2缴费失败3待确认"),
|
|
|
* @OA\Parameter(name="file_ids", in="query", @OA\Schema(type="string", format="date"), description="附件id数组"),
|
|
|
* @OA\Response(
|
|
|
* response=200,
|
|
|
* description="操作成功"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function save()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$update_user = request('update_user', 0);
|
|
|
DB::beginTransaction();
|
|
|
try {
|
|
|
if (isset($all['id'])) {
|
|
|
$model = $this->model->find($all['id']);
|
|
|
if (empty($model)) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '数据不存在']);
|
|
|
}
|
|
|
// 检测手机号是否存在
|
|
|
if (isset($all['mobile'])) {
|
|
|
$otherUser = User::where('mobile', $all['mobile'])->where('id', '!=', $model->id)->first();
|
|
|
if ($otherUser) return $this->fail([ResponseCode::ERROR_BUSINESS, '该手机号已存在']);
|
|
|
}
|
|
|
} else {
|
|
|
$model = $this->model;
|
|
|
$all['admin_id'] = $this->getUserId();
|
|
|
$all['department_id'] = $this->getUser()->department_id;
|
|
|
// 检测手机号是否存在
|
|
|
if (isset($all['mobile'])) {
|
|
|
$otherUser = User::where('mobile', $all['mobile'])->first();
|
|
|
if ($otherUser) return $this->fail([ResponseCode::ERROR_BUSINESS, '该手机号已存在']);
|
|
|
}
|
|
|
}
|
|
|
$original = $model->getOriginal();
|
|
|
$model->fill($all);
|
|
|
$model->save();
|
|
|
// 是否强制更新用户信息
|
|
|
if ($update_user == 1 && $model->change_data) {
|
|
|
// 强制更新用户信息
|
|
|
$user = User::find($model->user_id);
|
|
|
foreach ($model->status == 1 && $model->change_data as $key => $value) {
|
|
|
$user->$key = $value;
|
|
|
}
|
|
|
$user->save();
|
|
|
}
|
|
|
DB::commit();
|
|
|
// 获取课程信息
|
|
|
$course = Course::find($model->course_id);
|
|
|
// 缴费结果通知和关联设置
|
|
|
if (($original && !in_array($original['fee_status'], [1, 2]) && in_array($model->fee_status, [1, 2]))) {
|
|
|
// 发通知
|
|
|
$data = ['course_sign_id' => $model->id];
|
|
|
Notification::send(User::find($model->user_id), new FeeResultNotify($data));
|
|
|
// 缴费成功则设置成vip
|
|
|
if ($model->fee_status == 1) {
|
|
|
$user = User::find($model->user_id);
|
|
|
$user->is_vip = 1;
|
|
|
$user->save();
|
|
|
}
|
|
|
}
|
|
|
// 多条件讨论
|
|
|
// 其他状态到审核通过
|
|
|
if ($original['status'] != 1 && $model->status == 1) {
|
|
|
// 发通过通知
|
|
|
$data = ['course_sign_id' => $model->id];
|
|
|
Notification::send(User::find($model->user_id), new AuditNotify($data));
|
|
|
}
|
|
|
// 其他条件到审核不通过
|
|
|
if ($original['status'] != 2 && $model->status == 2) {
|
|
|
// 发不通过通知
|
|
|
$data = ['course_sign_id' => $model->id];
|
|
|
Notification::send(User::find($model->user_id), new AuditNotify($data));
|
|
|
}
|
|
|
// 审核通过到其他条件，减少次数
|
|
|
if ($original['status'] == 1 && $model->status != 1) {
|
|
|
// 减少预约次数
|
|
|
CourseAppointmentTotal::reduce($model->user_id, $model->id);
|
|
|
}
|
|
|
// 执行预约操作
|
|
|
if (($course->is_fee == 0 && $model->status == 1) || ($course->is_fee == 1 && $model->fee_status == 1)) {
|
|
|
// 预约车
|
|
|
$user = User::find($model->user_id);
|
|
|
// 发送车辆预约信息
|
|
|
if ($user->plate) {
|
|
|
$plateArray = explode(',', $user->plate);
|
|
|
foreach ($plateArray as $plate) {
|
|
|
// 车辆预约
|
|
|
dispatch((new SendCourseCar($model, $plate)));
|
|
|
}
|
|
|
}
|
|
|
// 预约门禁
|
|
|
dispatch((new SendCourseDoor($model)));
|
|
|
}
|
|
|
|
|
|
// 记录日志
|
|
|
$this->saveLogs($original, $model);
|
|
|
return $this->success($model);
|
|
|
} catch (\Exception $exception) {
|
|
|
DB::rollBack();
|
|
|
return $this->fail([$exception->getCode(), $exception->getMessage()]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Get(
|
|
|
* path="/api/admin/course-signs/destroy",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="删除",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="id", in="query", @OA\Schema(type="string"), required=true, description="id"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function destroy()
|
|
|
{
|
|
|
return parent::destroy();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Post(
|
|
|
* path="/api/admin/course-signs/excel-show",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="导入预览",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="course_id", in="query", @OA\Schema(type="string"), required=true, description="课程id"),
|
|
|
* @OA\Parameter(name="file", in="query", @OA\Schema(type="string"), required=true, description="文件"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function excelShow()
|
|
|
{
|
|
|
$file = \request()->file('file');
|
|
|
$course_id = request('course_id');
|
|
|
//判断文件是否有效
|
|
|
if (!(\request()->hasFile('file') && $file->isValid())) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '文件不存在或无效']);
|
|
|
}
|
|
|
//获取文件大小
|
|
|
$img_size = floor($file->getSize() / 1024);
|
|
|
if ($img_size >= 50 * 1024) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '文件必须小于50M']);
|
|
|
}
|
|
|
//过滤文件后缀
|
|
|
$ext = $file->getClientOriginalExtension();
|
|
|
if (!in_array($ext, ['xls', 'xlsx', 'csv'])) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '仅支持xls/xlsx/csv格式']);
|
|
|
}
|
|
|
$tempFile = $file->getRealPath();
|
|
|
$dataArray = (new FastExcel)->import($tempFile)->toArray();
|
|
|
// 数据过滤，只能导入数据表有的字段
|
|
|
// 获取用户表信息
|
|
|
$userFieldByComment = (new CustomFormField)->getRowTableFieldsByComment('users');
|
|
|
// 获取自定义的字段的信息
|
|
|
$course_forms = CourseForm::where('course_id', $course_id)->pluck('name', 'field')->toArray();
|
|
|
// 获取所有的字段
|
|
|
$fields = array_merge($userFieldByComment, $course_forms);
|
|
|
$fields = array_filter($fields);
|
|
|
$statusList = CourseSign::$intToString['status'];
|
|
|
$statusList = array_flip($statusList);
|
|
|
$list = [];
|
|
|
foreach ($dataArray as $key => $value) {
|
|
|
foreach ($fields as $k => $v) {
|
|
|
if (isset($value[$v])) {
|
|
|
// 日期格式
|
|
|
if ($value[$v] instanceof \DateTimeImmutable) {
|
|
|
$list[$key][$k] = Carbon::parse($value[$v])->toDateString();
|
|
|
} else {
|
|
|
if (in_array($k, ['company_type', 'type'])) {
|
|
|
$list[$key][$k] = str_replace('、', ',', $value[$v]);
|
|
|
$list[$key][$k] = str_replace('，', ',', $list[$key][$k]);;
|
|
|
} else {
|
|
|
$list[$key][$k] = $value[$v];
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
// 审核状态匹配
|
|
|
if (isset($value['审核状态']) && !empty($value['审核状态'])) {
|
|
|
// 获取审核状态
|
|
|
$list[$key]['status'] = $statusList[$value['审核状态']];
|
|
|
$list[$key]['status_name'] = $value['审核状态'];
|
|
|
} else {
|
|
|
$list[$key]['status'] = 0;
|
|
|
$list[$key]['status_name'] = '待审核';
|
|
|
}
|
|
|
$list[$key] = array_merge($list[$key], ['course_id' => $course_id, 'from' => '跟班学员']);
|
|
|
}
|
|
|
return $this->success($list);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Post(
|
|
|
* path="/api/admin/course-signs/import",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="导入",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="data", in="query", @OA\Schema(type="string"), required=true, description="导入分析获取到的二维数组"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function import()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$messages = [
|
|
|
'data.required' => '数据必填',
|
|
|
];
|
|
|
$validator = Validator::make($all, [
|
|
|
'data' => 'required',
|
|
|
], $messages);
|
|
|
if ($validator->fails()) {
|
|
|
return $this->fail([ResponseCode::ERROR_PARAMETER, implode(',', $validator->errors()->all())]);
|
|
|
}
|
|
|
$records = $all['data'];
|
|
|
if (!isset($records[0]['course_id']) || empty($records[0]['course_id'])) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '课程id不存在']);
|
|
|
}
|
|
|
if (!isset($records[0]['mobile']) || empty($records[0]['mobile'])) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '联系方式必填']);
|
|
|
}
|
|
|
$course_id = $records[0]['course_id'];
|
|
|
DB::beginTransaction();
|
|
|
try {
|
|
|
// 获取数据表的所有字段
|
|
|
// 获取用户表信息
|
|
|
$userFieldByComment = (new CustomFormField)->getRowTableFieldsByComment('users');
|
|
|
// 获取自定义的字段的信息
|
|
|
$course_forms = CourseForm::where('course_id', $course_id)->pluck('name', 'field')->toArray();
|
|
|
// 获取所有的字段
|
|
|
$fields = array_merge($userFieldByComment, $course_forms);
|
|
|
foreach ($records as $item) {
|
|
|
if (empty($item['mobile'])) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, ($item['姓名'] ?? '') . '手机号不存在']);
|
|
|
}
|
|
|
$where = ['mobile' => $item['mobile']];
|
|
|
// 去除空值更新
|
|
|
$userItem = array_filter($item, function ($value) {
|
|
|
return $value != '';
|
|
|
});
|
|
|
// 所有数据通过追加的形式更新
|
|
|
$user = User::where($where)->first();
|
|
|
if ($user) {
|
|
|
// 更新，所有$record里的数组通过追加在原来数据后面的形式更新
|
|
|
foreach ($userItem as $k => &$v) {
|
|
|
if (!in_array($k, User::$coverFields)) {
|
|
|
// 追加更新
|
|
|
$tempArray = explode(',', $user->$k . ',' . $v);
|
|
|
$tempArray = array_unique(array_filter($tempArray));
|
|
|
$v = implode(',', $tempArray);
|
|
|
}
|
|
|
}
|
|
|
$user->fill($userItem);
|
|
|
$user->save();
|
|
|
} else {
|
|
|
// 新增
|
|
|
$userItem['is_import'] = 1;
|
|
|
$user = User::create($userItem);
|
|
|
}
|
|
|
// 更新报名表
|
|
|
$signWhere = ['user_id' => $user->id, 'course_id' => $course_id];
|
|
|
$signData = [];
|
|
|
foreach ($item as $k2 => $v2) {
|
|
|
if (isset($course_forms[$k2])) {
|
|
|
$signData[] = [
|
|
|
'name' => $course_forms[$k2],
|
|
|
'field' => $k2,
|
|
|
'value' => $v2
|
|
|
];
|
|
|
}
|
|
|
}
|
|
|
$course = Course::find($course_id);
|
|
|
$fee_status = $course->is_fee;
|
|
|
if ($item['status'] == 0) $fee_status = 0;
|
|
|
$courseSign = CourseSign::updateOrCreate($signWhere, ['is_import' => 1, 'user_id' => $user->id, 'status' => $item['status'], 'fee_status' => $fee_status, 'course_id' => $course_id, 'data' => $signData]);
|
|
|
// 加预约次数
|
|
|
if ($item['status'] == 1) {
|
|
|
CourseAppointmentTotal::add($courseSign->user_id, $courseSign->id);
|
|
|
if ($fee_status == 1) {
|
|
|
// 设置vip
|
|
|
$user->is_vip = 1;
|
|
|
$user->save();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
DB::commit();
|
|
|
return $this->success(['total' => count($records)]);
|
|
|
} catch (\Exception $exception) {
|
|
|
DB::rollBack();
|
|
|
return $this->fail([$exception->getTrace(), $exception->getMessage()]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Post(
|
|
|
* path="/api/admin/course-signs/batch-update-status",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="批量修改审核状态",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="course_id", in="query", @OA\Schema(type="string"), required=true, description="课程id"),
|
|
|
* @OA\Parameter(name="ids", in="query", @OA\Schema(type="string"), required=true, description="英文逗号分隔的id数组"),
|
|
|
* @OA\Parameter(name="status", in="query", @OA\Schema(type="string"), required=true, description="状态0待审核1通过2拒绝"),
|
|
|
* @OA\Parameter(name="reason", in="query", @OA\Schema(type="string"), required=true, description="reason"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function batchUpdateStatus()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$messages = [
|
|
|
'course_id.required' => '课程必填',
|
|
|
'ids.required' => '编号必填',
|
|
|
'status.required' => '状态必填',
|
|
|
];
|
|
|
$validator = Validator::make($all, [
|
|
|
'course_id' => 'required',
|
|
|
'ids' => 'required',
|
|
|
'status' => 'required',
|
|
|
], $messages);
|
|
|
if ($validator->fails()) {
|
|
|
return $this->fail([StarterResponseCode::START_ERROR_PARAMETER, implode(',', $validator->errors()->all())]);
|
|
|
}
|
|
|
DB::beginTransaction();
|
|
|
try {
|
|
|
$idsArray = explode(',', $all['ids']);
|
|
|
foreach ($idsArray as $id) {
|
|
|
$model = $this->model->find($id);
|
|
|
if (empty($model)) continue;
|
|
|
$data = ['course_id' => $all['course_id'], 'course_sign_id' => $id, 'status_text' => CourseSign::$intToString['status'][$all['status']]];
|
|
|
$model->status = $all['status'];
|
|
|
$model->reason = $all['reason'] ?? '';
|
|
|
$model->save();
|
|
|
if ($model->status == 1) {
|
|
|
Notification::send(User::find($model->user_id), new AuditNotify($data));
|
|
|
}
|
|
|
}
|
|
|
DB::commit();
|
|
|
return $this->success('批量更新成功');
|
|
|
} catch (\Exception $exception) {
|
|
|
DB::rollBack();
|
|
|
return $this->fail([$exception->getCode(), $exception->getMessage()]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Post(
|
|
|
* path="/api/admin/course-signs/batch-update-fee-status",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="批量修改缴费状态",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="ids", in="query", @OA\Schema(type="string"), required=true, description="英文逗号分隔的id数组"),
|
|
|
* @OA\Parameter(name="fee_status", in="query", @OA\Schema(type="string"), required=true, description="0未缴费1缴费成功2缴费失败"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function batchUpdateFeeStatus()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$messages = [
|
|
|
'ids.required' => '编号必填',
|
|
|
'fee_status.required' => '状态必填',
|
|
|
];
|
|
|
$validator = Validator::make($all, [
|
|
|
'ids' => 'required',
|
|
|
'fee_status' => 'required',
|
|
|
], $messages);
|
|
|
if ($validator->fails()) {
|
|
|
return $this->fail([StarterResponseCode::START_ERROR_PARAMETER, implode(',', $validator->errors()->all())]);
|
|
|
}
|
|
|
$idsArray = explode(',', $all['ids']);
|
|
|
$this->model->whereIn('id', $idsArray)->update(['fee_status' => $all['fee_status']]);
|
|
|
return $this->success('批量更新成功');
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Post(
|
|
|
* path="/api/admin/course-signs/batch-notice",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="批量发送缴费通知",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="course_id", in="query", @OA\Schema(type="string"), required=true, description="课程id"),
|
|
|
* @OA\Parameter(name="ids", in="query", @OA\Schema(type="string"), required=true, description="英文逗号分隔的id数组"),
|
|
|
* @OA\Parameter(name="content", in="query", @OA\Schema(type="string"), required=true, description="发送内容"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function batchNotice()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$messages = [
|
|
|
'course_id.required' => '课程必填',
|
|
|
'ids.required' => 'id必填',
|
|
|
'content.required' => '内容必填',
|
|
|
];
|
|
|
$validator = Validator::make($all, [
|
|
|
'course_id' => 'required',
|
|
|
'ids' => 'required',
|
|
|
'content' => 'required',
|
|
|
], $messages);
|
|
|
if ($validator->fails()) {
|
|
|
return $this->fail([StarterResponseCode::START_ERROR_PARAMETER, implode(',', $validator->errors()->all())]);
|
|
|
}
|
|
|
$idsArray = explode(',', $all['ids']);
|
|
|
$data = ['course_id' => $all['course_id'], 'content' => $all['content']];
|
|
|
DB::beginTransaction();
|
|
|
try {
|
|
|
foreach ($idsArray as $id) {
|
|
|
$model = $this->model->find($id);
|
|
|
if (empty($model)) continue;
|
|
|
if ($model->fee_status == 0) {
|
|
|
Notification::send(User::find($model->user_id), new FeeNotify($data));
|
|
|
}
|
|
|
}
|
|
|
DB::commit();
|
|
|
return $this->success('发送成功');
|
|
|
} catch (\Exception $exception) {
|
|
|
DB::rollBack();
|
|
|
return $this->fail([$exception->getCode(), $exception->getMessage()]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @OA\Get(
|
|
|
* path="/api/admin/course-signs/retry-appointment",
|
|
|
* tags={"报名管理"},
|
|
|
* summary="重新发送第三方预约信息",
|
|
|
* description="",
|
|
|
* @OA\Parameter(name="id", in="query", @OA\Schema(type="string"), required=true, description="id"),
|
|
|
* @OA\Parameter(name="token", in="query", @OA\Schema(type="string"), required=true, description="token"),
|
|
|
* @OA\Response(
|
|
|
* response="200",
|
|
|
* description="暂无"
|
|
|
* )
|
|
|
* )
|
|
|
*/
|
|
|
public function retryAppointment()
|
|
|
{
|
|
|
$all = \request()->all();
|
|
|
$messages = [
|
|
|
'id.required' => 'Id必填',
|
|
|
];
|
|
|
$validator = Validator::make($all, [
|
|
|
'id' => 'required'
|
|
|
], $messages);
|
|
|
if ($validator->fails()) {
|
|
|
return $this->fail([ResponseCode::ERROR_PARAMETER, implode(',', $validator->errors()->all())]);
|
|
|
}
|
|
|
$model = $this->model->find($all['id']);
|
|
|
if (empty($model)) {
|
|
|
return $this->fail([ResponseCode::ERROR_BUSINESS, '数据不存在']);
|
|
|
}
|
|
|
$model = $this->model->witg('course')->find($all['id']);
|
|
|
$course = $model->course;
|
|
|
// 执行预约
|
|
|
// 执行预约操作
|
|
|
if (($course->is_fee == 0 && $model->status == 1) || ($course->is_fee == 1 && $model->fee_status == 1)) {
|
|
|
// 预约车
|
|
|
$user = User::find($model->user_id);
|
|
|
// 发送车辆预约信息
|
|
|
if ($user->plate) {
|
|
|
$plateArray = explode(',', $user->plate);
|
|
|
foreach ($plateArray as $plate) {
|
|
|
// 车辆预约
|
|
|
dispatch((new SendCourseCar($model, $plate)));
|
|
|
}
|
|
|
}
|
|
|
// 预约门禁
|
|
|
dispatch((new SendCourseDoor($model)));
|
|
|
}
|
|
|
return $this->success('成功');
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
