model = new \app\admin\model\shop\Goods; $this->sku_model = new \app\admin\model\shop\GoodsSku; // $this->view->assign("flagList", $this->model->getFlagList()); // $this->view->assign("statusList", $this->model->getStatusList()); $this->view->assign("goodsTypeList", GoodsEnum::getGoodsTypeMap()); $this->assignconfig("goodsTypeList", json_encode(GoodsEnum::getGoodsTypeMap())); $this->view->assign("statusList", GoodsEnum::getGoodsStatusMap()); $this->assignconfig("statusList", json_encode(GoodsEnum::getGoodsStatusMap())); $this->view->assign("specTypeList", GoodsEnum::getSpecTypeMap()); $this->assignconfig("specTypeList", json_encode(GoodsEnum::getSpecTypeMap())); $this->view->assign("deliveryTypeList", GoodsEnum::getDeliveryTypeMap()); $this->view->assign("onlineTypeList", GoodsEnum::getOnlineTypeMap()); $this->view->assign("expressTypeList", GoodsEnum::getExpressTypeMap()); $this->view->assign("stockShowTypeList", GoodsEnum::getStockShowTypeMap()); $this->view->assign("salesShowTypeList", GoodsEnum::getSalesShowTypeMap()); } /** * 检查商品编码是否重复 */ public function checkGoodsSn() { $goods_sn = $this->request->param('goods_sn'); $id = $this->request->param('id', 0); if (empty($goods_sn)) { $this->error('商品编码不能为空'); } $where = [['goods_sn', '=', $goods_sn]]; if ($id > 0) { $where[] = ['id', '<>', $id]; } $exists = $this->model->where($where)->find(); if ($exists) { $this->error('商品编码已存在'); } $this->success('商品编码可用'); } /** * 查看 */ public function index() { //设置过滤方法 $this->request->filter(['strip_tags', 'trim']); if ($this->request->isAjax()) { //如果发送的来源是Selectpage,则转发到Selectpage if ($this->request->request('keyField')) { return $this->selectpage(); } list($where, $sort, $order, $offset, $limit) = $this->buildparams(); $list = $this->model ->with(['Freight', 'Brand', 'Category']) ->where($where) ->order($sort, $order) ->paginate($limit); $result = array("total" => $list->total(), "rows" => $list->items()); return json($result); } return $this->view->fetch(); } /** * 查看 */ public function select() { //设置过滤方法 $this->request->filter(['strip_tags', 'trim']); if ($this->request->isAjax()) { //如果发送的来源是Selectpage,则转发到Selectpage if ($this->request->request('keyField')) { return $this->selectpage(); } list($where, $sort, $order, $offset, $limit) = $this->buildparams(); $list = $this->model ->with(['Freight', 'Brand', 'Category']) ->where($where) ->order($sort, $order) ->paginate($limit); // 为每个商品添加SKU信息 $items = $list->items(); foreach ($items as &$item) { // 获取商品的第一个SKU ID(单规格商品通常只有一个SKU) $sku = \app\common\model\Sku::where('goods_id', $item['id'])->find(); $item['sku_id'] = $sku ? $sku['id'] : 0; } $result = array("total" => $list->total(), "rows" => $items); return json($result); } return $this->view->fetch(); } //检查属性skus 和 spec 是否对上 protected function checkSku($skus, $spec) { foreach ($skus as $item) { if (!isset($item['skus']) || !is_array($item['skus']) || empty($item['skus'])) { throw new Exception('规格属性不能为空'); } if (!isset($item['price'])) { throw new Exception('请录入价格'); } foreach ($item['skus'] as $k => $v) { if (empty($v) && !is_numeric($v)) { throw new Exception('规格【' . $v . '】属性值不能为空'); } if (!isset($spec[$k]['value']) || (empty($spec[$k]['name']) && !is_numeric($spec[$k]['name']))) { throw new Exception('规格【' . $v . '】名称不能为空'); } foreach ($spec[$k]['value'] as $m => $n) { // 兼容新格式(对象)和旧格式(字符串) $valueText = is_array($n) ? $n['name'] : $n; if (stripos($valueText, ',') !== false) { throw new Exception('规格【' . $v . '】属性值中不能包含,'); } } // 检查重复值(提取name字段进行比较) $valueNames = array_map(function($n) { return is_array($n) ? $n['name'] : $n; }, $spec[$k]['value']); if (count($valueNames) != count(array_unique($valueNames))) { throw new Exception('规格【' . $v . '】属性值中不能有重复值'); } // 检查规格值是否匹配(支持新旧格式) $valueNames = array_map(function($n) { return is_array($n) ? $n['name'] : $n; }, $spec[$k]['value']); if (empty($spec[$k]['value']) || !in_array($v, $valueNames)) { throw new Exception('规格【' . $v . '】属性不匹配'); } } } } protected function getSkuId($skus, $newSpec, $spec) { $arr = []; foreach ($skus as $index => $item) { $specArr = $spec[$index]; foreach ($newSpec as $subindex => $subitem) { if ($subitem['spec_name'] == $specArr['name'] && $subitem['spec_value_value'] == $item) { $arr[] = $subitem['id']; } } } sort($arr); return implode(',', $arr); } /** * 根据上下架时间计算商品状态 * @param array $params 商品参数 * @return int 商品状态 */ protected function calculateGoodsStatus($params) { $currentTime = time(); // 获取上架时间设置 - 前端传递的上架类型字段(使用status字段) $onlineType = isset($params['status']) ? intval($params['status']) : GoodsEnum::ONLINE_TYPE_NOT_NOW; $scheduledOnlineTime = isset($params['scheduled_online_time']) ? strtotime($params['scheduled_online_time']) : 0; // 获取下架时间设置 $isAutoOffline = isset($params['is_auto_offline']) ? intval($params['is_auto_offline']) : 0; $scheduledOfflineTime = isset($params['scheduled_offline_time']) ? strtotime($params['scheduled_offline_time']) : 0; // 根据上架类型判断状态 switch ($onlineType) { case GoodsEnum::ONLINE_TYPE_IMMEDIATE: // 立即上架 // 检查是否需要自动下架 if ($isAutoOffline && $scheduledOfflineTime > 0) { if ($currentTime >= $scheduledOfflineTime) { return GoodsEnum::STATUS_OFF_SALE; // 已下架 } } return GoodsEnum::STATUS_ON_SALE; // 销售中 case GoodsEnum::ONLINE_TYPE_NOT_NOW: // 暂不上架 return GoodsEnum::STATUS_IN_STORAGE; // 仓库中 case GoodsEnum::ONLINE_TYPE_SCHEDULED: // 定时上架 if ($scheduledOnlineTime <= 0) { return GoodsEnum::STATUS_IN_STORAGE; // 未设置上架时间,保持仓库中 } if ($currentTime < $scheduledOnlineTime) { return GoodsEnum::STATUS_IN_STORAGE; // 未到上架时间,仓库中 } // 已到上架时间,检查下架时间 if ($isAutoOffline && $scheduledOfflineTime > 0) { if ($currentTime >= $scheduledOfflineTime) { return GoodsEnum::STATUS_OFF_SALE; // 已下架 } } return GoodsEnum::STATUS_ON_SALE; // 销售中 default: return GoodsEnum::STATUS_IN_STORAGE; // 默认仓库中 } } //处理商品SKU(统一处理单规格和多规格) protected function processGoodsSku($params, $goods_id) { // 统一通过skus和spec字段处理 if (isset($params['skus']) && isset($params['spec'])) { $skus = (array)json_decode($params['skus'], true); $spec = (array)json_decode($params['spec'], true); // 判断是单规格还是多规格 if (empty($spec) && count($skus) === 1) { // 单规格处理 $this->addSingleSpecSku($skus[0], $goods_id); } else { // 多规格处理 $this->addMultiSpecSku($skus, $spec, $goods_id); } } else { throw new \Exception('SKU数据格式错误'); } } //添加单规格商品SKU protected function addSingleSpecSku($skuData, $goods_id) { // 如果原来是多规格,先清理多余的SKU记录 $existingSkuCount = $this->sku_model->where('goods_id', $goods_id)->count(); if ($existingSkuCount > 1) { // 从多规格改为单规格,删除所有旧记录 $this->sku_model->where('goods_id', $goods_id)->delete(); } // 查询现有的SKU记录 $existingSku = $this->sku_model->where('goods_id', $goods_id)->find(); // 创建单规格SKU数据 $newSkuData = [ 'goods_id' => $goods_id, 'spec_value_ids' => '', // 单规格无规格值ID 'sku_sn' => $skuData['sku_sn'] ?? '', 'image' => $skuData['image'] ?? '', 'price' => $skuData['price'] ?? 0, 'lineation_price'=> $skuData['lineation_price'] ?? 0, 'cost_price' => $skuData['cost_price'] ?? 0, 'weight' => $skuData['weight'] ?? 0, 'volume' => $skuData['volume'] ?? 0, 'stocks' => $skuData['stocks'] ?? 0, 'status' => 1, 'is_default' => 1, // 单规格默认为默认SKU ]; $defaultSkuId = 0; if ($existingSku) { // 单规格商品已存在SKU记录,直接更新(保持ID和销量不变) $newSkuData['sales'] = $existingSku->sales; // 保持原有销量 $existingSku->save($newSkuData); $defaultSkuId = $existingSku->id; } else { // 新商品,创建SKU记录 $newSkuData['sales'] = 0; $newSku = $this->sku_model->create($newSkuData); $defaultSkuId = $newSku->id; } // 更新商品主表信息 $updateData = [ 'spec_type' => 0, // 单规格 'stocks' => $skuData['stocks'] ?? 0, 'min_price' => $skuData['price'] ?? 0, 'max_price' => $skuData['price'] ?? 0, 'price' => $skuData['price'] ?? 0, 'min_lineation_price'=> $skuData['lineation_price'] ?? 0, 'max_lineation_price'=> $skuData['lineation_price'] ?? 0, 'lineation_price' => $skuData['lineation_price'] ?? 0, 'default_sku_id' => $defaultSkuId, ]; $this->model->where('id', $goods_id)->update($updateData); } //添加商品多规格 protected function addMultiSpecSku($skus, $spec, $goods_id) { //属性入库 $specList = Spec::push($spec); $newSpec = GoodsSkuSpec::push($specList, $goods_id); //匹配属性 $list = $this->sku_model->where('goods_id', $goods_id)->select(); $newData = []; $stocks = 0; foreach ($skus as $k => $sk) { $newSkuId = $this->getSkuId($sk['skus'], $newSpec, $spec); $newSkuData = [ 'goods_id' => $goods_id, 'spec_value_ids' => $newSkuId, 'sku_sn' => $sk['goods_sn'] ?? '', 'image' => $sk['image'] ?? '', 'price' => $sk['price'] ?? 0, 'lineation_price' => $sk['lineation_price'] ?? 0, 'cost_price' => $sk['cost_price'] ?? 0, 'weight' => $sk['weight'] ?? 0, 'volume' => $sk['volume'] ?? 0, 'stocks' => $sk['stocks'] ?? 0, 'status' => isset($sk['status']) ? intval($sk['status']) : 1, 'is_default' => isset($sk['is_default']) ? intval($sk['is_default']) : 0, ]; if (isset($list[$k])) { $row = $list[$k]; $oldSkuIdsArr = explode(',', $row['spec_value_ids']); sort($oldSkuIdsArr); $oldSkuId = implode(',', $oldSkuIdsArr); if ($oldSkuId == $newSkuId) { //相等的更新 $row->save($newSkuData); } else { //不等的 $row->save(array_merge($newSkuData, ['sales' => 0])); } unset($list[$k]); } else { //多余的 $newData[] = array_merge($newSkuData, ['sales' => 0]); } $stocks = bcadd($stocks, $sk['stocks'] ?? 0); } if (!empty($newData)) { $this->sku_model->saveAll($newData); } // 处理默认SKU $defaultSkuId = 0; $hasDefault = false; foreach ($skus as $k => $sk) { if (isset($sk['is_default']) && $sk['is_default']) { $hasDefault = true; break; } } // 如果没有明确设置默认SKU,则使用第一个SKU作为默认 if (!$hasDefault && !empty($skus)) { $firstSku = $this->sku_model->where('goods_id', $goods_id)->order('id', 'asc')->find(); if ($firstSku) { $firstSku->save(['is_default' => 1]); $defaultSkuId = $firstSku->id; } } else { // 查找默认SKU的ID $defaultSku = $this->sku_model->where('goods_id', $goods_id)->where('is_default', 1)->find(); if ($defaultSku) { $defaultSkuId = $defaultSku->id; } } //更新库存和默认SKU,计算价格范围 if (!empty($skus)) { $prices = array_column($skus, 'price'); $lineationPrices = array_column($skus, 'lineation_price'); // 使用bc函数计算平均价格,保证精度 $totalPrice = '0'; $validPriceCount = 0; foreach ($prices as $price) { if ($price > 0) { $totalPrice = bcadd($totalPrice, (string)$price, 2); $validPriceCount++; } } // 计算平均价格 $avgPrice = $validPriceCount > 0 ? bcdiv($totalPrice, (string)$validPriceCount, 2) : '0.00'; // 使用bc函数计算平均划线价格 $totalLineationPrice = '0'; $validLineationPriceCount = 0; foreach ($lineationPrices as $lineationPrice) { if ($lineationPrice > 0) { $totalLineationPrice = bcadd($totalLineationPrice, (string)$lineationPrice, 2); $validLineationPriceCount++; } } // 计算平均划线价格 $avgLineationPrice = $validLineationPriceCount > 0 ? bcdiv($totalLineationPrice, (string)$validLineationPriceCount, 2) : '0.00'; // 过滤掉0值的划线价格来计算最大最小值 $validLineationPrices = array_filter($lineationPrices, function($price) { return $price > 0; }); $updateData = [ 'stocks' => $stocks, 'spec_type' => 1, 'min_price' => min($prices), 'max_price' => max($prices), 'price' => $avgPrice, 'min_lineation_price' => !empty($validLineationPrices) ? min($validLineationPrices) : '0.00', 'max_lineation_price' => !empty($validLineationPrices) ? max($validLineationPrices) : '0.00', 'lineation_price' => $avgLineationPrice ]; if ($defaultSkuId > 0) { $updateData['default_sku_id'] = $defaultSkuId; } $this->model->where('id', $goods_id)->update($updateData); } else { $this->model->where('id', $goods_id)->update(['spec_type' => 0]); } //原来多的删除 foreach ($list as $it) { $it->delete(); } } /** * 添加 */ public function add() { if ($this->request->isPost()) { $params = $this->request->post("row/a"); if ($params) { $params = $this->preExcludeFields($params); if ($this->dataLimit && $this->dataLimitFieldAutoFill) { $params[$this->dataLimitField] = $this->auth->id; } $result = false; Db::startTrans(); try { //是否采用模型验证 if ($this->modelValidate) { $name = str_replace("\\model\\", "\\validate\\", get_class($this->model)); $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.add' : $name) : $this->modelValidate; // 添加规格数据到验证参数中 if (isset($params['skus']) && isset($params['spec'])) { $params['spec_data'] = json_decode($params['spec'], true); $params['sku_data'] = json_decode($params['skus'], true); } $this->model->validateFailException(true)->validate($validate); } // 备份上架类型,因为status字段将被覆盖为最终状态 $originalOnlineType = $params['online_type'] ?? GoodsEnum::ONLINE_TYPE_NOT_NOW; // 将online_type映射到status字段用于计算 if (isset($params['online_type'])) { $params['status'] = $params['online_type']; unset($params['online_type']); } // 先保存商品基础信息(暂时不保存status字段) $statusBackup = $params['status'] ?? null; unset($params['status']); // 临时移除status避免冲突 $result = $this->model->allowField(true)->save($params); // 根据上下架时间自动计算商品状态并更新 $params['status'] = $statusBackup; // 恢复用于计算 $calculatedStatus = $this->calculateGoodsStatus($params); $this->model->where('id', $this->model->id)->update([ 'status' => $calculatedStatus, 'online_type' => $originalOnlineType // 保存原始上架类型用于编辑时回显 ]); // 调试输出 \think\Log::write('商品添加 - 上架类型: ' . $originalOnlineType . ', 计算状态: ' . $calculatedStatus, 'info'); //商品规格处理 if (isset($params['skus']) && isset($params['spec'])) { $skus = (array)json_decode($params['skus'], true); $spec = (array)json_decode($params['spec'], true); // 只对多规格进行checkSku验证 if (!empty($spec)) { $this->checkSku($skus, $spec); } // 统一处理SKU $this->processGoodsSku($params, $this->model->id); } else { throw new \Exception('商品规格数据不能为空'); } //商品属性 if (isset($params['attribute_ids'])) { GoodsAttr::addGoodsAttr($params['attribute_ids'], $this->model->id); } Db::commit(); } catch (ValidateException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were inserted')); } } $this->error(__('Parameter %s can not be empty', '')); } return $this->view->fetch(); } /** * 编辑 */ public function edit($ids = null) { $row = $this->model->get($ids); if (!$row) { $this->error(__('No Results were found')); } $adminIds = $this->getDataLimitAdminIds(); if (is_array($adminIds)) { if (!in_array($row[$this->dataLimitField], $adminIds)) { $this->error(__('You have no permission')); } } if ($this->request->isPost()) { $params = $this->request->post("row/a"); if ($params) { $params = $this->preExcludeFields($params); $result = false; Db::startTrans(); try { //是否采用模型验证 if ($this->modelValidate) { $name = str_replace("\\model\\", "\\validate\\", get_class($this->model)); $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate; // 添加规格数据到验证参数中 if (isset($params['skus']) && isset($params['spec'])) { $params['spec_data'] = json_decode($params['spec'], true); $params['sku_data'] = json_decode($params['skus'], true); } $row->validateFailException(true)->validate($validate); } // 备份上架类型,因为status字段将被覆盖为最终状态 $originalOnlineType = $params['online_type'] ?? GoodsEnum::ONLINE_TYPE_NOT_NOW; // 将online_type映射到status字段用于计算 if (isset($params['online_type'])) { $params['status'] = $params['online_type']; unset($params['online_type']); } // 先保存商品基础信息(暂时不保存status字段) $statusBackup = $params['status'] ?? null; unset($params['status']); // 临时移除status避免冲突 $result = $row->allowField(true)->save($params); // 根据上下架时间自动计算商品状态并更新 $params['status'] = $statusBackup; // 恢复用于计算 $calculatedStatus = $this->calculateGoodsStatus($params); $this->model->where('id', $row->id)->update([ 'status' => $calculatedStatus, 'online_type' => $originalOnlineType // 保存原始上架类型用于编辑时回显 ]); // 调试输出 \think\Log::write('商品编辑 - 上架类型: ' . $originalOnlineType . ', 计算状态: ' . $calculatedStatus, 'info'); //商品规格处理 if (isset($params['skus']) && isset($params['spec'])) { $skus = (array)json_decode($params['skus'], true); $spec = (array)json_decode($params['spec'], true); // 只对多规格进行checkSku验证 if (!empty($spec)) { $this->checkSku($skus, $spec); } // 统一处理SKU $this->processGoodsSku($params, $row->id); } else { throw new \Exception('商品规格数据不能为空'); } //商品属性 if (isset($params['attribute_ids'])) { GoodsAttr::addGoodsAttr($params['attribute_ids'], $row->id); } Db::commit(); } catch (ValidateException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were updated')); } } $this->error(__('Parameter %s can not be empty', '')); } // 查询SKU数据,包含规格属性字符串 $list = $this->sku_model->field("sku.*,GROUP_CONCAT(sp.name,':',sv.value ORDER BY sp.id asc) sku_attr") ->alias('sku') ->where('sku.goods_id', $row->id) ->join('shop_goods_sku_spec p', "FIND_IN_SET(p.id,sku.spec_value_ids)", 'LEFT') ->join('shop_spec sp', 'sp.id=p.spec_id', 'LEFT') ->join('shop_spec_value sv', 'sv.id=p.spec_value_id', 'LEFT') ->group('sku.id') ->select(); // 查询规格值的详细信息(包含图片等扩展字段) $spec_values = []; if ($row->spec_type == 1) { // 多规格商品 $spec_values = Db::name('shop_goods_sku_spec') ->alias('gss') ->field('sp.name as spec_name, sv.value, sv.image, sv.desc') ->join('shop_spec sp', 'sp.id = gss.spec_id', 'LEFT') ->join('shop_spec_value sv', 'sv.id = gss.spec_value_id', 'LEFT') ->where('gss.goods_id', $row->id) ->group('gss.spec_id, gss.spec_value_id') ->order('sp.id asc, sv.id asc') ->select(); } $this->view->assign("row", $row); $this->assignconfig('goods', $row); $this->assignconfig('goods_skus', $list); $this->assignconfig('spec_values', $spec_values); // 传递规格值详细信息 return $this->view->fetch(); } /** * 根据ID批量获取商品信息 */ public function get_goods_by_ids() { $ids = $this->request->request('ids'); if (!$ids) { $this->error('请选择商品'); } $ids = explode(',', $ids); $list = $this->model ->with(['Category']) ->where('id', 'in', $ids) ->select(); // 处理图片URL和SKU信息 foreach ($list as &$item) { if ($item['image']) { $item['image'] = cdnurl($item['image'], true); } // 获取商品的第一个SKU ID(单规格商品通常只有一个SKU) $sku = \app\common\model\Sku::where('goods_id', $item['id'])->find(); $item['sku_id'] = $sku ? $sku['id'] : 0; } return json($list); } }