scene('list')->validate(); // 查询条件 $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', ''); $platform = request('platform', ''); $store_scope = request('store_scope', ''); $company_scope = request('company_scope', ''); $category_id = request('category_id', ''); // 时间条件 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 ($platform) $map[] = ['platform', 'like', "%$platform%"]; if ($store_scope) $map[] = ['store_scope', '=', $store_scope]; if ($company_scope) $map[] = ['company_scope', '=', $company_scope]; if ($category_id) $map[] = ['category_id', '=', $category_id]; // 查询数据 $result = $LowPriceGoodsModel->query() ->where($map) ->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']) : ''; $category_name = $value['category_id'] > 0 ? $ProductCategoryModel->where('id', $value['category_id'])->value('name') : ''; $result['data'][$key]['category_name'] = $category_name; //查询店铺名称 if ($value['store_scope'] == '1') { $result['data'][$key]['store_name'] = ['全部店铺']; } else { $result['data'][$key]['store_name'] = ''; } //查询公司名称 if ($value['company_scope'] == '1') { $result['data'][$key]['company_name'] = ['全部公司']; } else { $company_data = $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $value['id']) ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_lowprice_product_company.company_id') ->select(['washconfig_violation_store.id', 'washconfig_violation_store.company_name', 'washconfig_lowprice_product_company.company_id'])->get()->toArray(); $result['data'][$key]['company_name'] = !empty($company_data) ? array_column($company_data, 'company_name') : ''; } } } // 加载模板 return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]); } /** * 详情 * @author 唐远望 * @version 1.0 * @date 2025-12-02 */ public function detail(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, LowPriceGoodsCompanyModel $LowPriceGoodsCompanyModel, ProductCategoryModel $ProductCategoryModel) { $request->scene('detail')->validate(); // 接收参数 $id = request('id', 0); $map = ['id' => $id]; $data = $LowPriceGoodsModel->where($map)->first(); if (!$data) return json_send(['code' => 'error', 'msg' => '记录不存在']); //查询店铺名称 if (trim($data['store_scope']) == '') { $data['store_name'] = ['全部店铺']; } else { $data['store_name'] = ''; } //查询公司名称 if ($data->company_scope == '1') { $data->company_name = ['全部公司']; $data->company_ids = ''; } else { $company_data = $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $data->id) ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_lowprice_product_company.company_id') ->select(['washconfig_violation_store.id', 'washconfig_violation_store.company_name', 'washconfig_lowprice_product_company.company_id'])->get()->toArray(); $data->company_name = !empty($company_data) ? array_column($company_data, 'company_name') : ''; $data->company_ids = !empty($company_data) ? array_column($company_data, 'company_id') : ''; } $data->platform = isset($data->platform) ? explode(',', $data->platform) : ''; $data->category_name = $data->category_id > 0 ? $ProductCategoryModel->where('id', $data->category_id)->value('name') : ''; // 加载模板 return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]); } /** * 添加 * @author 唐远望 * @version 1.0 * @date 2025-12-02 * */ public function add(Request $request, LowPriceGoodsModel $LowPriceGoodsModel,ViolationProductModel $ViolationProductModel) { $request->scene('add')->validate(); //获取禁止商品启动数量 $violation_product_count = $ViolationProductModel->where('status', 0)->count(); //获取低价挂网商品启用数量 $lowprice_product_count = $LowPriceGoodsModel->where('status', 0)->count(); //计算总数量 $product_totle = $violation_product_count + $lowprice_product_count; //判断是否超过限制 if ($product_totle >= 50) { return json_send(['code' => 'error', 'msg' => '启用数量超过限制,低价挂网和禁止商品不能超过50条']); } // 接收数据 $all_data = request()->all(); $store_scope = request('store_scope', ''); $all_data['store_scope'] = $store_scope; $company_scope = request('company_scope', ''); $all_data['company_scope'] = $company_scope; $category_id = request('category_id', '0'); $all_data['category_id'] = $category_id; $specify_responsible_person = request('specify_responsible_person', '0'); $all_data['specify_responsible_person'] = $specify_responsible_person; //查询是否存在 $map = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs'], 'platform' => $all_data['platform']]; $data = $LowPriceGoodsModel->where($map)->first(); if ($data) return json_send(['code' => 'error', 'msg' => '记录已存在']); // 写入数据表 $result = $LowPriceGoodsModel->addLowProduct($all_data); // 如果操作失败 if (!$result) return json_send(['code' => 'error', 'msg' => '新增失败']); // 记录行为 $admin_id = request('access_token.uid', 0); //用户ID $is_admin = request('access_token.is_admin'); //是否管理员操作 0=是1=否 $table_name = $LowPriceGoodsModel->getTable(); $notes_type = 1; //操作类型,1添加,2修改,3=删除 $this->addAdminHistory('清洗配置-低价商品管理', $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-02 * */ public function edit(Request $request, LowPriceGoodsModel $LowPriceGoodsModel) { $request->scene('edit')->validate(); // 接收参数 $id = request('id', 0); // 接收数据 $all_data = request()->all(); $store_scope = request('store_scope', ''); $all_data['store_scope'] = $store_scope; $company_scope = request('company_scope', ''); $all_data['company_scope'] = $company_scope; $category_id = request('category_id', '0'); $all_data['category_id'] = $category_id; $specify_responsible_person = request('specify_responsible_person', '0'); $all_data['specify_responsible_person'] = $specify_responsible_person; //查询是否存在 $map = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs'], 'platform' => $all_data['platform']]; $data = $LowPriceGoodsModel->where($map)->where('id', '!=', $id)->first(); if ($data) return json_send(['code' => 'error', 'msg' => '记录已存在']); // 更新数据表 $where = ['id' => $id]; $LowProduct = $LowPriceGoodsModel->where($where)->first(); if (!$LowProduct) return json_send(['code' => 'error', 'msg' => '记录不存在']); $oldData = $LowProduct->toarray(); $result = $LowPriceGoodsModel->editLowProduct_content($LowProduct, $all_data); // 如果操作失败 if (!$result) return json_send(['code' => 'error', 'msg' => '修改失败']); // 记录行为 $admin_id = request('access_token.uid', 0); //用户ID $is_admin = request('access_token.is_admin'); //是否管理员操作 0=是1=否 $table_name = $LowPriceGoodsModel->getTable(); $notes_type = 2; //操作类型,1添加,2修改,3=删除 $this->addAdminHistory('清洗配置-低价商品管理', $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-02 * */ public function set_status(Request $request, LowPriceGoodsModel $LowPriceGoodsModel,ViolationProductModel $ViolationProductModel) { // 验证参数 $request->scene('set_status')->validate(); // 接收数据 $id = request('id', 0); $status = request('status', 0); if ($status == 0) { //获取禁止商品启动数量 $violation_product_count = $ViolationProductModel->where('status', 0)->count(); //获取低价挂网商品启用数量 $lowprice_product_count = $LowPriceGoodsModel->where('status', 0)->count(); //计算总数量 $product_totle = $violation_product_count + $lowprice_product_count; //判断是否超过限制 if ($product_totle >= 50) { return json_send(['code' => 'error', 'msg' => '启用数量超过限制,低价挂网和禁止商品不能超过50条']); } } // 查询用户 $where = ['id' => $id]; $LowProduct = $LowPriceGoodsModel->where($where)->first(); if (!$LowProduct) return json_send(['code' => 'error', 'msg' => '记录不存在']); // 执行修改 $result = $LowPriceGoodsModel->changeStatus($LowProduct, $status); // 提示新增失败 if (!$result) return json_send(['code' => 'error', 'msg' => '设置失败']); // 记录行为 $admin_id = request('access_token.uid', 0); //用户ID $is_admin = request('access_token.is_admin'); //是否管理员操作 0=是1=否 $table_name = $LowPriceGoodsModel->getTable(); $notes_type = 2; //操作类型,1添加,2修改,3=删除 $this->addAdminHistory('清洗配置-低价商品管理', $admin_id, $is_admin, $table_name, $notes_type, [], ['status' => $status], '修改了低价商品' . $LowProduct->product_name . '状态'); // 告知结果 return json_send(['code' => 'success', 'msg' => '设置成功']); } /** * 删除 * @author 唐远望 * @version 1.0 * @date 2025-12-02 * */ public function delete(Request $request, LowPriceGoodsModel $LowPriceGoodsModel) { // 验证参数 $request->scene('delete')->validate(); // 接收数据 $id = request('id', 0); // 查询用户 $where = ['id' => $id]; // 执行删除 $LowProduct = $LowPriceGoodsModel->where($where)->first(); if (!$LowProduct) { return json_send(['code' => 'error', 'msg' => '记录不存在']); } DB::beginTransaction(); try { $LowPriceGoodsCompanyModel = new LowPriceGoodsCompanyModel(); $company_id_log = $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $LowProduct->id)->get(); if (!empty($company_id_log)) { $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $LowProduct->id)->delete(); } $LowProduct->delete(); // 记录行为 $admin_id = request('access_token.uid', 0); //用户ID $is_admin = request('access_token.is_admin'); //是否管理员操作 0=是1=否 $table_name = $LowPriceGoodsModel->getTable(); $notes_type = 3; //操作类型,1添加,2修改,3=删除 $this->addAdminHistory('清洗配置-低价商品管理', $admin_id, $is_admin, $table_name, $notes_type, $LowProduct->toarray(), [], '删除了低价商品' . $LowProduct->product_name . '信息'); DB::commit(); // 告知结果 return json_send(['code' => 'success', 'msg' => '删除成功']); // 成功处理... } catch (\Exception $e) { DB::rollBack(); // 错误处理... return json_send(['code' => 'error', 'msg' => '删除失败']); } } }