zhijiayun/app/Http/Controllers/Manager/Collect/Product.php

<?php

namespace App\Http\Controllers\Manager\Collect;

use App\Http\Controllers\Controller;
use App\Http\Requests\Manager\Collect\Product as Request;
use App\Models\Manager\Collect\Product as ProductModel;
use Illuminate\Support\Facades\DB;
use App\Models\Manager\Collect\ProductKeyword as ProductKeywordModel;

/**
 * 采集配置-商品管理
 * @author    唐远望
 * @version   1.0
 * @date      2025-12-30
 */
class Product extends Controller
{
    /**
     * 列表
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-30
     * 
     */
    public function list(Request $request, ProductModel $ProductModel)
    {
        $request->scene('list')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0');
        // 查询条件
        $map  = [];
        $limit = request('limit', config('page_num', 10));
        $status    = request('status', '');
        $start_time = request('start_time', '');
        $end_time = request('end_time', '');
        $product_name = request('product_name', '');
        $platforms = request('platform', '');
        $product_brand = request('product_brand', '');
        // 时间条件
        if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
        if ($end_time) $map[]   = ['insert_time', '<=', strtotime($end_time)];
        // 其他条件
        if (is_numeric($status)) $map[] = ['status', '=', $status];
        if ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
        if (is_numeric($platforms) || $platforms) {
            $ProductModel = $ProductModel
                ->where(function ($query) use ($platforms) {
                    $platforms = explode(',',$platforms);
                    foreach ($platforms as $platform) {
                        $query->orWhereRaw("FIND_IN_SET(?, platform)", [$platform]);
                    }
                });
        }
        if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $map[] = ['company_id', '=', $company_id];
        } else {
            $map[] = ['company_id', '=', $admin_company_id];
        }
        // 查询数据
        $result = $ProductModel
            ->where($map)
            ->with(['product_keyword'])
            ->orderByDesc('id')
            ->paginate($limit)->toarray();
        // 分配数据
        if (!$result)  return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
        if (isset($result['data']) && count($result['data']) > 0) {
            foreach ($result['data'] as $key => $value) {
                $result['data'][$key]['platform'] = isset($value['platform']) ? explode(',', $value['platform']) : '';
                $product_specs = isset($value['product_specs']) ?  explode(',', $value['product_specs']) : '';
                //移除空数组
                $result['data'][$key]['product_specs'] = $product_specs ? array_filter($product_specs) : '';
            }
        }
        // 加载模板
        return        json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
    }

    /**
     * 商品名称规格列表
     * @author    唐远望
     * @version   1.0
     * @date      2026-03-25
     * 
     */
    public function product_name_specs_list(Request $request, ProductModel $ProductModel, ProductKeywordModel $ProductKeywordModel)
    {

        $request->scene('product_name_specs_list')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0');
        // 查询条件
        $map  = [];
        $map2  = [];
        $map3  = [];
        $start_time = request('start_time', '');
        $end_time = request('end_time', '');
        $product_name = request('product_name', '');
        $product_brand = request('product_brand', '');
        // 时间条件
        if ($start_time) {
            $map[] = ['insert_time', '>=', strtotime($start_time)];
            $map2[] = ['insert_time', '>=', strtotime($start_time)];
            $map3[] = ['insert_time', '>=', strtotime($start_time)];
        }
        if ($end_time) {
            $map[]   = ['insert_time', '<=', strtotime($end_time)];
            $map2[]   = ['insert_time', '<=', strtotime($end_time)];
            $map3[]   = ['insert_time', '<=', strtotime($end_time)];
        }
        // 其他条件
        $map[] = ['status', '=', 0];
        if ($product_name) $map2[] = ['product_name', 'like', "%$product_name%"];
        if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $map[] = ['company_id', '=', $company_id];
            $map2[] = ['company_id', '=', $company_id];
            $map3[] = ['company_id', '=', $company_id];
        } else {
            $map[] = ['company_id', '=', $admin_company_id];
            $map2[] = ['company_id', '=', $admin_company_id];
            $map3[] = ['company_id', '=', $admin_company_id];
        }
        // 查询数据
        $result = $ProductModel->query()
            ->where($map)
            ->where([['product_brand', '!=', ''], ['product_brand', '!=', null]])
            ->select([DB::raw('MAX(id) as id'), 'product_brand'])
            ->groupBy(['product_brand'])
            ->orderByDesc('id')->get()->toarray();
        if (!$result)  return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
        foreach ($result as $key => $value) {
            $product_list = $ProductModel->query()
                ->where($map2)
                ->where([['product_name', '!=', ''], ['product_name', '!=', null]])
                ->where(['product_brand' => $value['product_brand']])
                ->select([DB::raw('MAX(id) as id'), 'product_name'])
                ->groupBy(['product_name'])
                ->orderByDesc('id')->get()->toarray();
            if (!empty($product_list)) {
                foreach ($product_list as $key2 => $value2) {
                    $product_keyword = $ProductKeywordModel->query()
                        ->where(['collect_product_id' => $value2['id']])
                        ->select('keyword')
                        ->groupBy(['keyword'])
                        ->get()->toarray();
                    $product_list[$key2]['product_keyword'] = $product_keyword ? array_column($product_keyword, 'keyword') : [];
                    $product_specs = $ProductModel->query()
                        ->where($map3)
                        ->where([['product_specs', '!=', ''], ['product_specs', '!=', null]])
                        ->where(['product_name' => $value2['product_name']])
                        ->where(['product_brand' => $value['product_brand']])
                        ->select([DB::raw('MAX(id) as id'), 'product_specs'])
                        ->groupBy(['product_specs'])
                        ->orderByDesc('id')->get()->toarray();
                    $product_specs_tring = [];
                    if (count($product_specs) > 0) {
                        foreach ($product_specs as $key3 => $value3) {
                            $product_specs_item = isset($value3['product_specs']) ?  explode(',', $value3['product_specs']) : '';
                            //合并数组
                            if (!empty($product_specs_item)) {
                                $product_specs_tring = array_merge($product_specs_tring, $product_specs_item);
                            }
                        }
                        //去重
                        $product_specs_tring = array_unique($product_specs_tring);
                    }
                    //移除空数组
                    $product_list[$key2]['product_specs'] = $product_specs_tring ? array_filter($product_specs_tring) : '';
                }
            }
            $result[$key]['product_list'] = !empty($product_list) ? $product_list : [];
        }
        // 加载模板
        return        json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
    }


    /**
     * 详情
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-30
     */
    public function detail(Request $request, ProductModel $ProductModel)
    {
        $request->scene('detail')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0');
        // 接收参数
        $id = request('id', 0);
        $map = ['id' => $id];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $map['company_id'] = $company_id;
        } else {
            $map['company_id'] = $admin_company_id;
        }
        $data = $ProductModel->where($map)->with(['product_keyword'])->first();
        if (!$data)     return json_send(['code' => 'error', 'msg' => '记录不存在']);

        $data->platform = isset($data->platform) ? explode(',', $data->platform) : '';
        $product_specs = isset($data->product_specs) ?  explode(',', $data->product_specs) : '';
        //移除空数组
        $data->product_specs = $product_specs ? array_filter($product_specs) : '';
        // 加载模板
        return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
    }

    /**
     * 添加
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-30
     * 
     */
    public function add(Request $request, ProductModel $ProductModel)
    {
        $request->scene('add')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        //商品启用数量
        // $product_count = $ProductModel->where('status', 0)->count();
        //判断是否超过限制
        // if ($product_count >= 50) {
        //     return json_send(['code' => 'error', 'msg' => '启用数量超过限制,不能超过50条']);
        // }
        // 接收数据
        $all_data = request()->all();
        $product_brand = request('product_brand', '');
        $product_keyword = request('product_keyword', '');
        $platform_string = $all_data['platform'];
        if(empty($platform_string)) return json_send(['code' => 'error', 'msg' => '平台不能为空']);
        $all_data['product_brand'] = $product_brand;
        $all_data['product_keyword'] = $product_keyword;
        if (trim($product_keyword) != '') {
            $product_keyword_count = count(explode(',', $product_keyword));
            if ($product_keyword_count > 5) {
                return json_send(['code' => 'error', 'msg' => '商品关键词不能超过5个']);
            }
        }
        //采集信息配置
        $enable_full_quantity = request('enable_full_quantity', 1); //全量，0启用，1禁用
        $all_data['enable_full_quantity'] = $enable_full_quantity;
        if ($enable_full_quantity == 1 && !isset($all_data['product_specs'])) {
            return json_send(['code' => 'error', 'msg' => '非全量采集时，商品规格不能为空']);
        }
        $minimum_order_quantity = request('minimum_order_quantity', 1);
        $sampling_cycle = request('sampling_cycle', '0');
        $sampling_start_time = request('sampling_start_time', '');
        $sampling_end_time = request('sampling_end_time', '');
        $all_data['sampling_cycle'] = $sampling_cycle;
        $all_data['sampling_start_time'] = $sampling_start_time ? strtotime($sampling_start_time . '00:00:00') : '0';
        $all_data['sampling_end_time'] = $sampling_end_time ? strtotime($sampling_end_time . '23:59:59') : '0';
        $all_data['minimum_order_quantity'] = $minimum_order_quantity;
        if ($all_data['sampling_start_time']  && strtotime(date('Y-m-d', $all_data['sampling_start_time']) . '23:59:59') < time()) return json_send(['code' => 'error', 'msg' => '采集开始时间必须大于当前时间']);
        if ($all_data['sampling_end_time']  && $all_data['sampling_end_time'] < time()) return json_send(['code' => 'error', 'msg' => '采集结束时间必须大于当前时间']);
        //查询是否存在
        $map = ['product_brand' => $product_brand, 'product_name' => $all_data['product_name']];
        if ($is_admin != 1 && $company_id != 0) {
            $map['company_id'] = $company_id;
            $all_data['company_id'] = $company_id;
        } else {
            $map['company_id'] = $admin_company_id;
            $all_data['company_id'] = $admin_company_id;
        }
        $data = $ProductModel->where($map)->first();
        if (!empty($data)) {
            //继续校验规格是否存在
            $product_specs_tring = $all_data['product_specs'];
            $product_specs = $product_specs_tring ?  explode(',', $product_specs_tring) : '';
            $product_specs = $product_specs ? array_unique($product_specs) : '';
            //继续校平台是否存在
           
            $platforms = $platform_string ?  explode(',', $platform_string) : '';
            $platforms = $platforms ? array_unique($platforms) : '';

            $platform_data = $ProductModel->platform_data();
            foreach ($platforms as $platform) {
                $product_specs_log = $ProductModel
                    ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
                    ->where(['product_brand' => $product_brand, 'product_name' => $all_data['product_name']])
                    ->where(function ($query) use ($product_specs) {
                        // 平台条件（固定）
                        $query->where(function ($query_li) use ($product_specs) {

                            foreach ($product_specs as $product_spec) {
                                if (empty($product_specs)) continue;
                                $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
                            }
                        });
                    })->first();
                $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
                if (!empty($product_specs_log)) {
                    return json_send(['code' => 'error', 'msg' => $platform_name.'存在重复的商品规格记录']);
                }
            }
        }

        // 写入数据表
        $result     =  $ProductModel->addProduct($all_data);
        // 如果操作失败
        if (!$result)     return json_send(['code' => 'error', 'msg' => '新增失败']);
        // 记录行为
        $admin_id   = request('access_token.uid', 0); //用户ID
        $table_name = $ProductModel->getTable();
        $notes_type = 1; //操作类型，1添加，2修改，3=删除
        $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, [], $all_data, '新增了商品' . $all_data['product_name'] . '信息');
        // 告知结果
        return json_send(['code' => 'success', 'msg' => '新增成功']);
    }

    /**
     * 修改
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-30
     * 
     */
    public function edit(Request $request, ProductModel $ProductModel)
    {
        $request->scene('edit')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收参数
        $id         = request('id', 0);
        // 接收数据
        $all_data = request()->all();
        $product_brand = request('product_brand', '');
        $product_keyword = request('product_keyword', '');
        $platform_string = $all_data['platform'];
        if(empty($platform_string)) return json_send(['code' => 'error', 'msg' => '平台不能为空']);
        $all_data['product_brand'] = $product_brand;
        $all_data['product_keyword'] = $product_keyword;
        if (trim($product_keyword) != '') {
            $product_keyword_count = count(explode(',', $product_keyword));
            if ($product_keyword_count > 5) {
                return json_send(['code' => 'error', 'msg' => '商品关键词不能超过5个']);
            }
        }
        //采集信息配置
        $enable_full_quantity = request('enable_full_quantity', 1); //全量，0启用，1禁用
        $all_data['enable_full_quantity'] = $enable_full_quantity;
        if ($enable_full_quantity == 1 && !isset($all_data['product_specs'])) {
            return json_send(['code' => 'error', 'msg' => '非全量采集时，商品规格不能为空']);
        }
        $minimum_order_quantity = request('minimum_order_quantity', 1);
        $sampling_cycle = request('sampling_cycle', '0');
        $sampling_start_time = request('sampling_start_time', '');
        $sampling_end_time = request('sampling_end_time', '');
        $all_data['sampling_cycle'] = $sampling_cycle;
        $all_data['sampling_start_time'] = $sampling_start_time ? strtotime($sampling_start_time . '00:00:00') : '0';
        $all_data['sampling_end_time'] = $sampling_end_time ? strtotime($sampling_end_time . '23:59:59') : '0';
        $all_data['minimum_order_quantity'] = $minimum_order_quantity;
        if ($all_data['sampling_start_time']  && strtotime(date('Y-m-d', $all_data['sampling_start_time']) . '23:59:59') < time()) return json_send(['code' => 'error', 'msg' => '采集开始时间必须大于当前时间']);
        if ($all_data['sampling_end_time']  && $all_data['sampling_end_time'] < time()) return json_send(['code' => 'error', 'msg' => '采集结束时间必须大于当前时间']);
        //查询是否存在
        $map = ['product_brand' => $product_brand, 'product_name' => $all_data['product_name']];
        if ($is_admin != 1 && $company_id != 0) {
            $map['company_id'] = $company_id;
        } else {
            $map['company_id'] = $admin_company_id;
        }
        $data = $ProductModel->where($map)->where('id', '!=', $id)->first();
        if (!empty($data)) {
            //继续校验规格是否存在
            $product_specs_tring = $all_data['product_specs'];
            $product_specs = $product_specs_tring ?  explode(',', $product_specs_tring) : '';
            $product_specs = $product_specs ? array_unique($product_specs) : '';
            //继续校平台是否存在
           
            $platforms = $platform_string ?  explode(',', $platform_string) : '';
            $platforms = $platforms ? array_unique($platforms) : '';

            $platform_data = $ProductModel->platform_data();
            foreach ($platforms as $platform) {
                $product_specs_log = $ProductModel
                    ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
                    ->where(['product_brand' => $product_brand, 'product_name' => $all_data['product_name']])
                    ->where('id', '!=', $id)
                    ->where(function ($query) use ($product_specs) {
                        // 平台条件（固定）
                        $query->where(function ($query_li) use ($product_specs) {

                            foreach ($product_specs as $product_spec) {
                                if (empty($product_specs)) continue;
                                $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
                            }
                        });
                    })->first();
                $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
                if (!empty($product_specs_log)) {
                    return json_send(['code' => 'error', 'msg' => $platform_name.'存在重复的商品规格记录']);
                }
            }
        }
        // 更新数据表
        $where = ['id' => $id];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $where['company_id'] = $company_id;
        } else {
            $where['company_id'] = $admin_company_id;
        }
        $Product = $ProductModel->where($where)->first();
        if (!$Product) return json_send(['code' => 'error', 'msg' => '记录不存在']);
        $oldData = $Product->toarray();
        $result =  $ProductModel->editProduct_content($Product, $all_data);
        // 如果操作失败
        if (!$result)     return json_send(['code' => 'error', 'msg' => '修改失败']);
        // 记录行为
        $admin_id   = request('access_token.uid', 0); //用户ID
        $table_name = $ProductModel->getTable();
        $notes_type = 2; //操作类型，1添加，2修改，3=删除
        $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, $oldData, $all_data, '修改了商品' . $oldData['product_name'] . '信息');
        // 告知结果
        return json_send(['code' => 'success', 'msg' => '修改成功']);
    }

    /**
     * 修改状态
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-30
     * 
     */
    public function set_status(Request $request, ProductModel $ProductModel)
    {
        // 验证参数
        $request->scene('set_status')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收数据
        $id                = request('id', 0);
        $status            = request('status', 0);
        if ($status == 0) {
            //获取商品启用数量
            // $product_count = $ProductModel->where('status', 0)->count();
            //判断是否超过限制
            // if ($product_count >= 50) {
            //     return json_send(['code' => 'error', 'msg' => '启用数量超过限制,不能超过50条']);
            // }
        }
        // 查询用户
        $where = ['id' => $id];
        if ($is_admin != 1 && $company_id != 0) {
            $where['company_id'] = $company_id;
        } else {
            $where['company_id'] = $admin_company_id;
        }
        $Product = $ProductModel->where($where)->first();
        if (!$Product) return json_send(['code' => 'error', 'msg' => '记录不存在']);
        // 执行修改
        $result            =  $ProductModel->changeStatus($Product, $status);
        // 提示新增失败
        if (!$result)    return json_send(['code' => 'error', 'msg' => '设置失败']);
        // 记录行为
        $admin_id   = request('access_token.uid', 0); //用户ID
        $table_name = $ProductModel->getTable();
        $notes_type = 2; //操作类型，1添加，2修改，3=删除
        $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, [], ['status' => $status], '修改了商品' . $Product->product_name . '状态');
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '设置成功']);
    }


    /**
     * 删除
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-30
     * 
     */
    public function delete(Request $request, ProductModel $ProductModel)
    {
        // 验证参数
        $request->scene('delete')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收数据
        $id = request('id', 0);
        // 查询用户
        $where = ['id' => $id];
        if ($is_admin != 1 && $company_id != 0) {
            $where['company_id'] = $company_id;
        } else {
            $where['company_id'] = $admin_company_id;
        }
        // 执行删除
        $Product = $ProductModel->where($where)->first();
        if (!$Product) {
            return             json_send(['code' => 'error', 'msg' => '删除失败，记录不存在']);
        }
        DB::beginTransaction();
        try {
            $Product->delete();
            // 记录行为
            $admin_id   = request('access_token.uid', 0); //用户ID
            $table_name = $ProductModel->getTable();
            $notes_type = 3; //操作类型，1添加，2修改，3=删除
            $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, $Product->toarray(), [], '删除了商品' . $Product->product_name . '信息');
            // 告知结果
            DB::commit();
            return             json_send(['code' => 'success', 'msg' => '删除成功']);
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            return             json_send(['code' => 'error', 'msg' => '删除失败']);
        }
    }
}