458 lines
13 KiB
PHP
458 lines
13 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace app\common\service;
|
||
|
|
|
||
|
|
use app\common\validate\UsedCarDetailValidate;
|
||
|
|
use app\common\traits\crud\CrudServiceTrait;
|
||
|
|
use app\common\model\UsedCarDetail;
|
||
|
|
use app\common\model\User;
|
||
|
|
use support\exception\BusinessException;
|
||
|
|
use support\Log;
|
||
|
|
use support\Request;
|
||
|
|
use support\Redis;
|
||
|
|
|
||
|
|
class UsedCarDetailService
|
||
|
|
{
|
||
|
|
|
||
|
|
use CrudServiceTrait;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 指定当前要操作的模型
|
||
|
|
*/
|
||
|
|
protected string $modelClass = UsedCarDetail::class;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 验证器
|
||
|
|
*/
|
||
|
|
protected $validator = UsedCarDetailValidate::class;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取验证器
|
||
|
|
*/
|
||
|
|
public function getValidator()
|
||
|
|
{
|
||
|
|
return new $this->validator;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 构建查询配置
|
||
|
|
*/
|
||
|
|
protected function buildQueryConfig(Request $request, string $scene = 'default'): array
|
||
|
|
{
|
||
|
|
$p = $request->all();
|
||
|
|
|
||
|
|
$config = [];
|
||
|
|
$config['model'] = $this->modelClass;
|
||
|
|
|
||
|
|
switch ($scene) {
|
||
|
|
case 'default':
|
||
|
|
$config['where']['status'] = 1;
|
||
|
|
$config['order']['sort'] = 'desc';
|
||
|
|
$config['order']['id'] = 'desc';
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'index':
|
||
|
|
// 默认只显示审核通过的数据
|
||
|
|
$config['where']['status'] = 1;
|
||
|
|
|
||
|
|
// 审核状态筛选
|
||
|
|
if (isset($p['status'])) {
|
||
|
|
$config['where']['status'] = $p['status'];
|
||
|
|
}
|
||
|
|
|
||
|
|
// 我的车辆
|
||
|
|
if (isset($p['scene']) && $p['scene'] == 'self') {
|
||
|
|
$config['where']['user_id'] = $request->user['id'];
|
||
|
|
unset($config['where']['status']);
|
||
|
|
}
|
||
|
|
|
||
|
|
// 关键字搜索
|
||
|
|
if (isset($p['keyword']) && $p['keyword']) {
|
||
|
|
$k = '%' . $p['keyword'] . '%';
|
||
|
|
foreach (['product_name', 'code', 'vin', 'manufacturer'] as $col) {
|
||
|
|
$config['orWhere'][] = [$col, 'like', $k];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// 品牌筛选
|
||
|
|
if (isset($p['crawl_brand_id']) && $p['crawl_brand_id']) {
|
||
|
|
$config['where']['crawl_brand_id'] = $p['crawl_brand_id'];
|
||
|
|
}
|
||
|
|
|
||
|
|
// 车系筛选
|
||
|
|
if (isset($p['crawl_series_id']) && $p['crawl_series_id']) {
|
||
|
|
$config['where']['crawl_series_id'] = $p['crawl_series_id'];
|
||
|
|
}
|
||
|
|
|
||
|
|
// 价格区间
|
||
|
|
if (isset($p['min_price']) && $p['min_price']) {
|
||
|
|
$config['where'][] = ['price', '>=', $p['min_price']];
|
||
|
|
}
|
||
|
|
if (isset($p['max_price']) && $p['max_price']) {
|
||
|
|
$config['where'][] = ['price', '<=', $p['max_price']];
|
||
|
|
}
|
||
|
|
|
||
|
|
$config['order']['sort'] = 'desc';
|
||
|
|
$config['order']['id'] = 'desc';
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'show':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
// 关联FAQ
|
||
|
|
$config['with'] = ['faqs'];
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'store':
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'update':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'destroy':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
return $config;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 创建前数据处理
|
||
|
|
*/
|
||
|
|
public function beforeServiceStore($data, Request $request): array
|
||
|
|
{
|
||
|
|
if (empty($data['product_name'])) {
|
||
|
|
throw new BusinessException('产品名称不能为空');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 设置用户信息
|
||
|
|
$data['user_id'] = $request->user['id'];
|
||
|
|
$user = User::where('id', $request->user['id'])->first();
|
||
|
|
$data['role_wp'] = $user['role_wp'] ?? 1;
|
||
|
|
|
||
|
|
// 默认待审核状态
|
||
|
|
if (!isset($data['status'])) {
|
||
|
|
$data['status'] = 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
// 生成车辆编号
|
||
|
|
$data['code'] = $this->getCode($request->user['id']);
|
||
|
|
|
||
|
|
// 处理图片数据
|
||
|
|
if (!empty($data['images'])) {
|
||
|
|
if (is_array($data['images'])) {
|
||
|
|
$data['images'] = json_encode($data['images']);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$data['images'] = '';
|
||
|
|
}
|
||
|
|
|
||
|
|
// 处理附件数据
|
||
|
|
if (!empty($data['attachment'])) {
|
||
|
|
if (is_array($data['attachment'])) {
|
||
|
|
$data['attachment'] = json_encode($data['attachment']);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$data['attachment'] = '';
|
||
|
|
}
|
||
|
|
|
||
|
|
// 处理介绍图片
|
||
|
|
if (!empty($data['intro_images'])) {
|
||
|
|
if (is_array($data['intro_images'])) {
|
||
|
|
$data['intro_images'] = json_encode($data['intro_images']);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$data['intro_images'] = '';
|
||
|
|
}
|
||
|
|
|
||
|
|
// 检查来源URL是否重复
|
||
|
|
if (!empty($data['source_url'])) {
|
||
|
|
$exists = UsedCarDetail::where('source_url', $data['source_url']);
|
||
|
|
$exists = $exists->where('user_id', $data['user_id']);
|
||
|
|
if ($exists->exists()) {
|
||
|
|
throw new BusinessException('该车源已收录');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return $data;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 更新前数据处理
|
||
|
|
*/
|
||
|
|
public function beforeServiceUpdate($data, Request $request): array
|
||
|
|
{
|
||
|
|
if (empty($data['product_name'])) {
|
||
|
|
throw new BusinessException('产品名称不能为空');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 获取车辆信息
|
||
|
|
$carId = $data['id'] ?? null;
|
||
|
|
if ($carId) {
|
||
|
|
$car = UsedCarDetail::find($carId);
|
||
|
|
if (!$car) {
|
||
|
|
throw new BusinessException('车辆不存在');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 审核通过的车辆禁止修改
|
||
|
|
if ($car->status == 1) {
|
||
|
|
throw new BusinessException('审核通过的车辆禁止修改');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 审核拒绝的车辆修改后状态改为待审核
|
||
|
|
if ($car->status == 2) {
|
||
|
|
$data['status'] = 0;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// 处理图片数据
|
||
|
|
if (isset($data['images'])) {
|
||
|
|
if (is_array($data['images'])) {
|
||
|
|
$data['images'] = json_encode($data['images']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// 处理附件数据
|
||
|
|
if (isset($data['attachment'])) {
|
||
|
|
if (is_array($data['attachment'])) {
|
||
|
|
$data['attachment'] = json_encode($data['attachment']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// 处理介绍图片
|
||
|
|
if (isset($data['intro_images'])) {
|
||
|
|
if (is_array($data['intro_images'])) {
|
||
|
|
$data['intro_images'] = json_encode($data['intro_images']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return $data;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 更新状态
|
||
|
|
*/
|
||
|
|
public function serviceUpdateStatus(Request $request, array $data)
|
||
|
|
{
|
||
|
|
if (empty($data['id'])) {
|
||
|
|
throw new BusinessException('id不能为空');
|
||
|
|
}
|
||
|
|
if (!isset($data['status'])) {
|
||
|
|
throw new BusinessException('status错误');
|
||
|
|
}
|
||
|
|
return UsedCarDetail::where('id', $data['id'])->update(['status' => $data['status']]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 保存FAQ
|
||
|
|
*/
|
||
|
|
public function saveFaqs(int $carId, array $faqs)
|
||
|
|
{
|
||
|
|
// 删除旧的FAQ
|
||
|
|
\app\common\model\UsedCarFaq::where('car_id', $carId)->delete();
|
||
|
|
|
||
|
|
// 创建新的FAQ
|
||
|
|
if (!empty($faqs)) {
|
||
|
|
foreach ($faqs as $faq) {
|
||
|
|
\app\common\model\UsedCarFaq::create([
|
||
|
|
'car_id' => $carId,
|
||
|
|
'question' => $faq['question'] ?? '',
|
||
|
|
'answer' => $faq['answer'] ?? '',
|
||
|
|
'sort' => $faq['sort'] ?? 0,
|
||
|
|
'status' => $faq['status'] ?? 1,
|
||
|
|
]);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 生成车辆编号
|
||
|
|
*/
|
||
|
|
public function getCode(int $userId): string
|
||
|
|
{
|
||
|
|
$userCount = Redis::get('used_car_detail_count_' . $userId, 0);
|
||
|
|
$todayStart = strtotime('today');
|
||
|
|
$count = UsedCarDetail::where('user_id', $userId)
|
||
|
|
->where('created_at', '>=', $todayStart)
|
||
|
|
->count();
|
||
|
|
$count = $count < $userCount ? $userCount + 1 : $count + 1;
|
||
|
|
$countCode = str_pad($count, 3, '0', STR_PAD_LEFT);
|
||
|
|
$userCode = str_pad($userId, 3, '0', STR_PAD_LEFT);
|
||
|
|
Redis::set('used_car_detail_count_' . $userId, $count, 86400);
|
||
|
|
|
||
|
|
$user = User::where('id', $userId)->first();
|
||
|
|
$nameInitials = $this->getNameInitials($user['name'] ?? '');
|
||
|
|
|
||
|
|
return 'UCD' . $nameInitials . $userCode . date('Ymd') . $countCode;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取中文名拼音首字母
|
||
|
|
*/
|
||
|
|
private function getNameInitials(string $name): string
|
||
|
|
{
|
||
|
|
$initials = '';
|
||
|
|
$len = mb_strlen($name);
|
||
|
|
for ($i = 0; $i < $len; $i++) {
|
||
|
|
$char = mb_substr($name, $i, 1);
|
||
|
|
$initials .= $this->getFirstChar($char);
|
||
|
|
}
|
||
|
|
return strtoupper($initials);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取单个字符的首字母
|
||
|
|
*/
|
||
|
|
private function getFirstChar(string $char): string
|
||
|
|
{
|
||
|
|
$s = iconv('UTF-8', 'GB2312//IGNORE', $char);
|
||
|
|
$asc = ord($s[0]);
|
||
|
|
|
||
|
|
if ($asc >= 65 && $asc <= 90) {
|
||
|
|
return $char;
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($s === false || strlen($s) < 2) {
|
||
|
|
return '';
|
||
|
|
}
|
||
|
|
|
||
|
|
$code = ord($s[0]) * 256 + ord($s[1]) - 65536;
|
||
|
|
|
||
|
|
$map = [
|
||
|
|
[-20319, -20284, 'A'],
|
||
|
|
[-20283, -19776, 'B'],
|
||
|
|
[-19775, -19219, 'C'],
|
||
|
|
[-19218, -18711, 'D'],
|
||
|
|
[-18710, -18527, 'E'],
|
||
|
|
[-18526, -18240, 'F'],
|
||
|
|
[-18239, -17923, 'G'],
|
||
|
|
[-17922, -17418, 'H'],
|
||
|
|
[-17417, -16475, 'J'],
|
||
|
|
[-16474, -16213, 'K'],
|
||
|
|
[-16212, -15641, 'L'],
|
||
|
|
[-15640, -15166, 'M'],
|
||
|
|
[-15165, -14923, 'N'],
|
||
|
|
[-14922, -14915, 'O'],
|
||
|
|
[-14914, -14631, 'P'],
|
||
|
|
[-14630, -14150, 'Q'],
|
||
|
|
[-14149, -14091, 'R'],
|
||
|
|
[-14090, -13319, 'S'],
|
||
|
|
[-13318, -12839, 'T'],
|
||
|
|
[-12838, -12557, 'W'],
|
||
|
|
[-12556, -11848, 'X'],
|
||
|
|
[-11847, -11056, 'Y'],
|
||
|
|
[-11055, -10247, 'Z']
|
||
|
|
];
|
||
|
|
|
||
|
|
foreach ($map as [$start, $end, $letter]) {
|
||
|
|
if ($code >= $start && $code <= $end) {
|
||
|
|
return $letter;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return '';
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 提交审核
|
||
|
|
*/
|
||
|
|
public function submitAudit(Request $request, int $carId)
|
||
|
|
{
|
||
|
|
$car = UsedCarDetail::find($carId);
|
||
|
|
if (!$car) {
|
||
|
|
throw new BusinessException('车辆不存在');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 检查权限：只能提交自己创建的车辆
|
||
|
|
if ($car->user_id != $request->user['id']) {
|
||
|
|
throw new BusinessException('无权操作');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 只有待审核状态才能提交
|
||
|
|
if ($car->status != 0) {
|
||
|
|
throw new BusinessException('当前状态不允许提交审核');
|
||
|
|
}
|
||
|
|
|
||
|
|
return UsedCarDetail::where('id', $carId)->update(['status' => 0]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 审核车辆
|
||
|
|
*/
|
||
|
|
public function audit(Request $request, array $data)
|
||
|
|
{
|
||
|
|
$carId = $data['car_id'] ?? null;
|
||
|
|
$auditStatus = $data['audit_status'] ?? null;
|
||
|
|
$auditReason = $data['audit_reason'] ?? '';
|
||
|
|
|
||
|
|
if (empty($carId)) {
|
||
|
|
throw new BusinessException('车辆ID不能为空');
|
||
|
|
}
|
||
|
|
if (!isset($auditStatus) || !in_array($auditStatus, [1, 2])) {
|
||
|
|
throw new BusinessException('审核状态错误');
|
||
|
|
}
|
||
|
|
|
||
|
|
$car = UsedCarDetail::find($carId);
|
||
|
|
if (!$car) {
|
||
|
|
throw new BusinessException('车辆不存在');
|
||
|
|
}
|
||
|
|
|
||
|
|
$beforeStatus = $car->status;
|
||
|
|
|
||
|
|
// 创建审核记录
|
||
|
|
\app\common\model\UsedCarDetailAudit::create([
|
||
|
|
'car_id' => $carId,
|
||
|
|
'auditor_id' => $request->user['id'],
|
||
|
|
'audit_status' => $auditStatus,
|
||
|
|
'audit_reason' => $auditReason,
|
||
|
|
'before_status' => $beforeStatus,
|
||
|
|
'after_status' => $auditStatus,
|
||
|
|
]);
|
||
|
|
|
||
|
|
// 更新车辆状态
|
||
|
|
return UsedCarDetail::where('id', $carId)->update(['status' => $auditStatus]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取审核记录列表
|
||
|
|
*/
|
||
|
|
public function getAuditRecords(int $carId)
|
||
|
|
{
|
||
|
|
return \app\common\model\UsedCarDetailAudit::where('car_id', $carId)
|
||
|
|
->with(['auditor:id,name'])
|
||
|
|
->orderBy('created_at', 'desc')
|
||
|
|
->get()
|
||
|
|
->map(function ($item) {
|
||
|
|
return [
|
||
|
|
'id' => $item->id,
|
||
|
|
'audit_status' => $item->audit_status,
|
||
|
|
'audit_status_text' => $item->audit_status_text,
|
||
|
|
'audit_reason' => $item->audit_reason,
|
||
|
|
'before_status' => $item->before_status,
|
||
|
|
'after_status' => $item->after_status,
|
||
|
|
'auditor_name' => $item->auditor->name ?? '',
|
||
|
|
'created_at' => date('Y-m-d H:i:s', $item->created_at),
|
||
|
|
];
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取审核统计数据
|
||
|
|
*/
|
||
|
|
public function getAuditStats(Request $request)
|
||
|
|
{
|
||
|
|
$query = UsedCarDetail::query();
|
||
|
|
|
||
|
|
// 如果不是管理员，只能看到自己的数据
|
||
|
|
if ($request->user['role_wp'] != 3) {
|
||
|
|
$query->where('user_id', $request->user['id']);
|
||
|
|
}
|
||
|
|
|
||
|
|
return [
|
||
|
|
'pending' => (clone $query)->where('status', 0)->count(),
|
||
|
|
'approved' => (clone $query)->where('status', 1)->count(),
|
||
|
|
'rejected' => (clone $query)->where('status', 2)->count(),
|
||
|
|
'total' => $query->count(),
|
||
|
|
];
|
||
|
|
}
|
||
|
|
}
|