Goods.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719
  1. <?php
  2. namespace app\admin\controller\shop;
  3. use app\common\controller\Backend;
  4. use Exception;
  5. use think\Db;
  6. use think\exception\PDOException;
  7. use think\exception\ValidateException;
  8. use app\admin\model\shop\GoodsAttr;
  9. use app\admin\model\shop\Spec;
  10. use app\admin\model\shop\GoodsSkuSpec;
  11. use app\common\Enum\GoodsEnum;
  12. use app\common\Service\SkuSpec as SkuSpecService;
  13. /**
  14. * 商品管理
  15. *
  16. * @icon fa fa-circle-o
  17. */
  18. class Goods extends Backend
  19. {
  20. /**
  21. * 快速搜索时执行查找的字段
  22. */
  23. protected $searchFields = 'id,goods_sn,title,subtitle';
  24. /**
  25. * Goods模型对象
  26. * @var \app\admin\model\shop\Goods
  27. */
  28. protected $model = null;
  29. protected $sku_model = null;
  30. public function _initialize()
  31. {
  32. parent::_initialize();
  33. $this->model = new \app\admin\model\shop\Goods;
  34. $this->sku_model = new \app\admin\model\shop\GoodsSku;
  35. // $this->view->assign("flagList", $this->model->getFlagList());
  36. // $this->view->assign("statusList", $this->model->getStatusList());
  37. $this->view->assign("goodsTypeList", GoodsEnum::getGoodsTypeMap());
  38. $this->assignconfig("goodsTypeList", json_encode(GoodsEnum::getGoodsTypeMap()));
  39. $this->view->assign("statusList", GoodsEnum::getGoodsStatusMap());
  40. $this->assignconfig("statusList", json_encode(GoodsEnum::getGoodsStatusMap()));
  41. $this->view->assign("specTypeList", GoodsEnum::getSpecTypeMap());
  42. $this->assignconfig("specTypeList", json_encode(GoodsEnum::getSpecTypeMap()));
  43. $this->view->assign("deliveryTypeList", GoodsEnum::getDeliveryTypeMap());
  44. $this->view->assign("onlineTypeList", GoodsEnum::getOnlineTypeMap());
  45. $this->view->assign("expressTypeList", GoodsEnum::getExpressTypeMap());
  46. $this->view->assign("stockShowTypeList", GoodsEnum::getStockShowTypeMap());
  47. $this->view->assign("salesShowTypeList", GoodsEnum::getSalesShowTypeMap());
  48. }
  49. /**
  50. * 检查商品编码是否重复
  51. */
  52. public function checkGoodsSn()
  53. {
  54. $goods_sn = $this->request->param('goods_sn');
  55. $id = $this->request->param('id', 0);
  56. if (empty($goods_sn)) {
  57. $this->error('商品编码不能为空');
  58. }
  59. $where = [['goods_sn', '=', $goods_sn]];
  60. if ($id > 0) {
  61. $where[] = ['id', '<>', $id];
  62. }
  63. $exists = $this->model->where($where)->find();
  64. if ($exists) {
  65. $this->error('商品编码已存在');
  66. }
  67. $this->success('商品编码可用');
  68. }
  69. /**
  70. * 查看
  71. */
  72. public function index()
  73. {
  74. //设置过滤方法
  75. $this->request->filter(['strip_tags', 'trim']);
  76. if ($this->request->isAjax()) {
  77. //如果发送的来源是Selectpage,则转发到Selectpage
  78. if ($this->request->request('keyField')) {
  79. return $this->selectpage();
  80. }
  81. list($where, $sort, $order, $offset, $limit) = $this->buildparams();
  82. $list = $this->model
  83. ->with(['Freight', 'Brand', 'Category'])
  84. ->where($where)
  85. ->order($sort, $order)
  86. ->paginate($limit);
  87. $result = array("total" => $list->total(), "rows" => $list->items());
  88. return json($result);
  89. }
  90. return $this->view->fetch();
  91. }
  92. /**
  93. * 查看
  94. */
  95. public function select()
  96. {
  97. //设置过滤方法
  98. $this->request->filter(['strip_tags', 'trim']);
  99. if ($this->request->isAjax()) {
  100. //如果发送的来源是Selectpage,则转发到Selectpage
  101. if ($this->request->request('keyField')) {
  102. return $this->selectpage();
  103. }
  104. list($where, $sort, $order, $offset, $limit) = $this->buildparams();
  105. $list = $this->model
  106. ->with(['Freight', 'Brand', 'Category'])
  107. ->where($where)
  108. ->order($sort, $order)
  109. ->paginate($limit);
  110. $result = array("total" => $list->total(), "rows" => $list->items());
  111. return json($result);
  112. }
  113. return $this->view->fetch();
  114. }
  115. //检查属性skus 和 spec 是否对上
  116. protected function checkSku($skus, $spec)
  117. {
  118. foreach ($skus as $item) {
  119. if (!isset($item['skus']) || !is_array($item['skus']) || empty($item['skus'])) {
  120. throw new Exception('规格属性不能为空');
  121. }
  122. if (!isset($item['price'])) {
  123. throw new Exception('请录入价格');
  124. }
  125. foreach ($item['skus'] as $k => $v) {
  126. if (empty($v) && !is_numeric($v)) {
  127. throw new Exception('规格【' . $v . '】属性值不能为空');
  128. }
  129. if (!isset($spec[$k]['value']) || (empty($spec[$k]['name']) && !is_numeric($spec[$k]['name']))) {
  130. throw new Exception('规格【' . $v . '】名称不能为空');
  131. }
  132. foreach ($spec[$k]['value'] as $m => $n) {
  133. // 兼容新格式(对象)和旧格式(字符串)
  134. $valueText = is_array($n) ? $n['name'] : $n;
  135. if (stripos($valueText, ',') !== false) {
  136. throw new Exception('规格【' . $v . '】属性值中不能包含,');
  137. }
  138. }
  139. // 检查重复值(提取name字段进行比较)
  140. $valueNames = array_map(function($n) {
  141. return is_array($n) ? $n['name'] : $n;
  142. }, $spec[$k]['value']);
  143. if (count($valueNames) != count(array_unique($valueNames))) {
  144. throw new Exception('规格【' . $v . '】属性值中不能有重复值');
  145. }
  146. // 检查规格值是否匹配(支持新旧格式)
  147. $valueNames = array_map(function($n) {
  148. return is_array($n) ? $n['name'] : $n;
  149. }, $spec[$k]['value']);
  150. if (empty($spec[$k]['value']) || !in_array($v, $valueNames)) {
  151. throw new Exception('规格【' . $v . '】属性不匹配');
  152. }
  153. }
  154. }
  155. }
  156. protected function getSkuId($skus, $newSpec, $spec)
  157. {
  158. $arr = [];
  159. foreach ($skus as $index => $item) {
  160. $specArr = $spec[$index];
  161. foreach ($newSpec as $subindex => $subitem) {
  162. if ($subitem['spec_name'] == $specArr['name'] && $subitem['spec_value_value'] == $item) {
  163. $arr[] = $subitem['id'];
  164. }
  165. }
  166. }
  167. sort($arr);
  168. return implode(',', $arr);
  169. }
  170. /**
  171. * 根据上下架时间计算商品状态
  172. * @param array $params 商品参数
  173. * @return int 商品状态
  174. */
  175. protected function calculateGoodsStatus($params)
  176. {
  177. $currentTime = time();
  178. // 获取上架时间设置 - 前端传递的上架类型字段(使用status字段)
  179. $onlineType = isset($params['status']) ? intval($params['status']) : GoodsEnum::ONLINE_TYPE_NOT_NOW;
  180. $scheduledOnlineTime = isset($params['scheduled_online_time']) ? strtotime($params['scheduled_online_time']) : 0;
  181. // 获取下架时间设置
  182. $isAutoOffline = isset($params['is_auto_offline']) ? intval($params['is_auto_offline']) : 0;
  183. $scheduledOfflineTime = isset($params['scheduled_offline_time']) ? strtotime($params['scheduled_offline_time']) : 0;
  184. // 根据上架类型判断状态
  185. switch ($onlineType) {
  186. case GoodsEnum::ONLINE_TYPE_IMMEDIATE: // 立即上架
  187. // 检查是否需要自动下架
  188. if ($isAutoOffline && $scheduledOfflineTime > 0) {
  189. if ($currentTime >= $scheduledOfflineTime) {
  190. return GoodsEnum::STATUS_OFF_SALE; // 已下架
  191. }
  192. }
  193. return GoodsEnum::STATUS_ON_SALE; // 销售中
  194. case GoodsEnum::ONLINE_TYPE_NOT_NOW: // 暂不上架
  195. return GoodsEnum::STATUS_IN_STORAGE; // 仓库中
  196. case GoodsEnum::ONLINE_TYPE_SCHEDULED: // 定时上架
  197. if ($scheduledOnlineTime <= 0) {
  198. return GoodsEnum::STATUS_IN_STORAGE; // 未设置上架时间,保持仓库中
  199. }
  200. if ($currentTime < $scheduledOnlineTime) {
  201. return GoodsEnum::STATUS_IN_STORAGE; // 未到上架时间,仓库中
  202. }
  203. // 已到上架时间,检查下架时间
  204. if ($isAutoOffline && $scheduledOfflineTime > 0) {
  205. if ($currentTime >= $scheduledOfflineTime) {
  206. return GoodsEnum::STATUS_OFF_SALE; // 已下架
  207. }
  208. }
  209. return GoodsEnum::STATUS_ON_SALE; // 销售中
  210. default:
  211. return GoodsEnum::STATUS_IN_STORAGE; // 默认仓库中
  212. }
  213. }
  214. //处理商品SKU(统一处理单规格和多规格)
  215. protected function processGoodsSku($params, $goods_id)
  216. {
  217. // 统一通过skus和spec字段处理
  218. if (isset($params['skus']) && isset($params['spec'])) {
  219. $skus = (array)json_decode($params['skus'], true);
  220. $spec = (array)json_decode($params['spec'], true);
  221. // 判断是单规格还是多规格
  222. if (empty($spec) && count($skus) === 1) {
  223. // 单规格处理
  224. $this->addSingleSpecSku($skus[0], $goods_id);
  225. } else {
  226. // 多规格处理
  227. $this->addMultiSpecSku($skus, $spec, $goods_id);
  228. }
  229. } else {
  230. throw new \Exception('SKU数据格式错误');
  231. }
  232. }
  233. //添加单规格商品SKU
  234. protected function addSingleSpecSku($skuData, $goods_id)
  235. {
  236. // 如果原来是多规格,先清理多余的SKU记录
  237. $existingSkuCount = $this->sku_model->where('goods_id', $goods_id)->count();
  238. if ($existingSkuCount > 1) {
  239. // 从多规格改为单规格,删除所有旧记录
  240. $this->sku_model->where('goods_id', $goods_id)->delete();
  241. }
  242. // 查询现有的SKU记录
  243. $existingSku = $this->sku_model->where('goods_id', $goods_id)->find();
  244. // 创建单规格SKU数据
  245. $newSkuData = [
  246. 'goods_id' => $goods_id,
  247. 'spec_value_ids' => '', // 单规格无规格值ID
  248. 'sku_sn' => $skuData['sku_sn'] ?? '',
  249. 'image' => $skuData['image'] ?? '',
  250. 'price' => $skuData['price'] ?? 0,
  251. 'lineation_price'=> $skuData['lineation_price'] ?? 0,
  252. 'cost_price' => $skuData['cost_price'] ?? 0,
  253. 'weight' => $skuData['weight'] ?? 0,
  254. 'volume' => $skuData['volume'] ?? 0,
  255. 'stocks' => $skuData['stocks'] ?? 0,
  256. 'status' => 1,
  257. 'is_default' => 1, // 单规格默认为默认SKU
  258. ];
  259. $defaultSkuId = 0;
  260. if ($existingSku) {
  261. // 单规格商品已存在SKU记录,直接更新(保持ID和销量不变)
  262. $newSkuData['sales'] = $existingSku->sales; // 保持原有销量
  263. $existingSku->save($newSkuData);
  264. $defaultSkuId = $existingSku->id;
  265. } else {
  266. // 新商品,创建SKU记录
  267. $newSkuData['sales'] = 0;
  268. $newSku = $this->sku_model->create($newSkuData);
  269. $defaultSkuId = $newSku->id;
  270. }
  271. // 更新商品主表信息
  272. $updateData = [
  273. 'spec_type' => 0, // 单规格
  274. 'stocks' => $skuData['stocks'] ?? 0,
  275. 'min_price' => $skuData['price'] ?? 0,
  276. 'max_price' => $skuData['price'] ?? 0,
  277. 'price' => $skuData['price'] ?? 0,
  278. 'min_lineation_price'=> $skuData['lineation_price'] ?? 0,
  279. 'max_lineation_price'=> $skuData['lineation_price'] ?? 0,
  280. 'lineation_price' => $skuData['lineation_price'] ?? 0,
  281. 'default_sku_id' => $defaultSkuId,
  282. ];
  283. $this->model->where('id', $goods_id)->update($updateData);
  284. }
  285. //添加商品多规格
  286. protected function addMultiSpecSku($skus, $spec, $goods_id)
  287. {
  288. //属性入库
  289. $specList = Spec::push($spec);
  290. $newSpec = GoodsSkuSpec::push($specList, $goods_id);
  291. //匹配属性
  292. $list = $this->sku_model->where('goods_id', $goods_id)->select();
  293. $newData = [];
  294. $stocks = 0;
  295. foreach ($skus as $k => $sk) {
  296. $newSkuId = $this->getSkuId($sk['skus'], $newSpec, $spec);
  297. $newSkuData = [
  298. 'goods_id' => $goods_id,
  299. 'spec_value_ids' => $newSkuId,
  300. 'sku_sn' => $sk['goods_sn'] ?? '',
  301. 'image' => $sk['image'] ?? '',
  302. 'price' => $sk['price'] ?? 0,
  303. 'lineation_price' => $sk['lineation_price'] ?? 0,
  304. 'cost_price' => $sk['cost_price'] ?? 0,
  305. 'weight' => $sk['weight'] ?? 0,
  306. 'volume' => $sk['volume'] ?? 0,
  307. 'stocks' => $sk['stocks'] ?? 0,
  308. 'status' => isset($sk['status']) ? intval($sk['status']) : 1,
  309. 'is_default' => isset($sk['is_default']) ? intval($sk['is_default']) : 0,
  310. ];
  311. if (isset($list[$k])) {
  312. $row = $list[$k];
  313. $oldSkuIdsArr = explode(',', $row['spec_value_ids']);
  314. sort($oldSkuIdsArr);
  315. $oldSkuId = implode(',', $oldSkuIdsArr);
  316. if ($oldSkuId == $newSkuId) {
  317. //相等的更新
  318. $row->save($newSkuData);
  319. } else {
  320. //不等的
  321. $row->save(array_merge($newSkuData, ['sales' => 0]));
  322. }
  323. unset($list[$k]);
  324. } else { //多余的
  325. $newData[] = array_merge($newSkuData, ['sales' => 0]);
  326. }
  327. $stocks = bcadd($stocks, $sk['stocks'] ?? 0);
  328. }
  329. if (!empty($newData)) {
  330. $this->sku_model->saveAll($newData);
  331. }
  332. // 处理默认SKU
  333. $defaultSkuId = 0;
  334. $hasDefault = false;
  335. foreach ($skus as $k => $sk) {
  336. if (isset($sk['is_default']) && $sk['is_default']) {
  337. $hasDefault = true;
  338. break;
  339. }
  340. }
  341. // 如果没有明确设置默认SKU,则使用第一个SKU作为默认
  342. if (!$hasDefault && !empty($skus)) {
  343. $firstSku = $this->sku_model->where('goods_id', $goods_id)->order('id', 'asc')->find();
  344. if ($firstSku) {
  345. $firstSku->save(['is_default' => 1]);
  346. $defaultSkuId = $firstSku->id;
  347. }
  348. } else {
  349. // 查找默认SKU的ID
  350. $defaultSku = $this->sku_model->where('goods_id', $goods_id)->where('is_default', 1)->find();
  351. if ($defaultSku) {
  352. $defaultSkuId = $defaultSku->id;
  353. }
  354. }
  355. //更新库存和默认SKU,计算价格范围
  356. if (!empty($skus)) {
  357. $prices = array_column($skus, 'price');
  358. $lineationPrices = array_column($skus, 'lineation_price');
  359. // 使用bc函数计算平均价格,保证精度
  360. $totalPrice = '0';
  361. $validPriceCount = 0;
  362. foreach ($prices as $price) {
  363. if ($price > 0) {
  364. $totalPrice = bcadd($totalPrice, (string)$price, 2);
  365. $validPriceCount++;
  366. }
  367. }
  368. // 计算平均价格
  369. $avgPrice = $validPriceCount > 0 ? bcdiv($totalPrice, (string)$validPriceCount, 2) : '0.00';
  370. // 使用bc函数计算平均划线价格
  371. $totalLineationPrice = '0';
  372. $validLineationPriceCount = 0;
  373. foreach ($lineationPrices as $lineationPrice) {
  374. if ($lineationPrice > 0) {
  375. $totalLineationPrice = bcadd($totalLineationPrice, (string)$lineationPrice, 2);
  376. $validLineationPriceCount++;
  377. }
  378. }
  379. // 计算平均划线价格
  380. $avgLineationPrice = $validLineationPriceCount > 0 ? bcdiv($totalLineationPrice, (string)$validLineationPriceCount, 2) : '0.00';
  381. // 过滤掉0值的划线价格来计算最大最小值
  382. $validLineationPrices = array_filter($lineationPrices, function($price) {
  383. return $price > 0;
  384. });
  385. $updateData = [
  386. 'stocks' => $stocks,
  387. 'spec_type' => 1,
  388. 'min_price' => min($prices),
  389. 'max_price' => max($prices),
  390. 'price' => $avgPrice,
  391. 'min_lineation_price' => !empty($validLineationPrices) ? min($validLineationPrices) : '0.00',
  392. 'max_lineation_price' => !empty($validLineationPrices) ? max($validLineationPrices) : '0.00',
  393. 'lineation_price' => $avgLineationPrice
  394. ];
  395. if ($defaultSkuId > 0) {
  396. $updateData['default_sku_id'] = $defaultSkuId;
  397. }
  398. $this->model->where('id', $goods_id)->update($updateData);
  399. } else {
  400. $this->model->where('id', $goods_id)->update(['spec_type' => 0]);
  401. }
  402. //原来多的删除
  403. foreach ($list as $it) {
  404. $it->delete();
  405. }
  406. }
  407. /**
  408. * 添加
  409. */
  410. public function add()
  411. {
  412. if ($this->request->isPost()) {
  413. $params = $this->request->post("row/a");
  414. if ($params) {
  415. $params = $this->preExcludeFields($params);
  416. if ($this->dataLimit && $this->dataLimitFieldAutoFill) {
  417. $params[$this->dataLimitField] = $this->auth->id;
  418. }
  419. $result = false;
  420. Db::startTrans();
  421. try {
  422. //是否采用模型验证
  423. if ($this->modelValidate) {
  424. $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
  425. $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.add' : $name) : $this->modelValidate;
  426. // 添加规格数据到验证参数中
  427. if (isset($params['skus']) && isset($params['spec'])) {
  428. $params['spec_data'] = json_decode($params['spec'], true);
  429. $params['sku_data'] = json_decode($params['skus'], true);
  430. }
  431. $this->model->validateFailException(true)->validate($validate);
  432. }
  433. // 备份上架类型,因为status字段将被覆盖为最终状态
  434. $originalOnlineType = $params['online_type'] ?? GoodsEnum::ONLINE_TYPE_NOT_NOW;
  435. // 将online_type映射到status字段用于计算
  436. if (isset($params['online_type'])) {
  437. $params['status'] = $params['online_type'];
  438. unset($params['online_type']);
  439. }
  440. // 先保存商品基础信息(暂时不保存status字段)
  441. $statusBackup = $params['status'] ?? null;
  442. unset($params['status']); // 临时移除status避免冲突
  443. $result = $this->model->allowField(true)->save($params);
  444. // 根据上下架时间自动计算商品状态并更新
  445. $params['status'] = $statusBackup; // 恢复用于计算
  446. $calculatedStatus = $this->calculateGoodsStatus($params);
  447. $this->model->where('id', $this->model->id)->update([
  448. 'status' => $calculatedStatus,
  449. 'online_type' => $originalOnlineType // 保存原始上架类型用于编辑时回显
  450. ]);
  451. // 调试输出
  452. \think\Log::write('商品添加 - 上架类型: ' . $originalOnlineType . ', 计算状态: ' . $calculatedStatus, 'info');
  453. //商品规格处理
  454. if (isset($params['skus']) && isset($params['spec'])) {
  455. $skus = (array)json_decode($params['skus'], true);
  456. $spec = (array)json_decode($params['spec'], true);
  457. // 只对多规格进行checkSku验证
  458. if (!empty($spec)) {
  459. $this->checkSku($skus, $spec);
  460. }
  461. // 统一处理SKU
  462. $this->processGoodsSku($params, $this->model->id);
  463. } else {
  464. throw new \Exception('商品规格数据不能为空');
  465. }
  466. //商品属性
  467. if (isset($params['attribute_ids'])) {
  468. GoodsAttr::addGoodsAttr($params['attribute_ids'], $this->model->id);
  469. }
  470. Db::commit();
  471. } catch (ValidateException $e) {
  472. Db::rollback();
  473. $this->error($e->getMessage());
  474. } catch (PDOException $e) {
  475. Db::rollback();
  476. $this->error($e->getMessage());
  477. } catch (Exception $e) {
  478. Db::rollback();
  479. $this->error($e->getMessage());
  480. }
  481. if ($result !== false) {
  482. $this->success();
  483. } else {
  484. $this->error(__('No rows were inserted'));
  485. }
  486. }
  487. $this->error(__('Parameter %s can not be empty', ''));
  488. }
  489. return $this->view->fetch();
  490. }
  491. /**
  492. * 编辑
  493. */
  494. public function edit($ids = null)
  495. {
  496. $row = $this->model->get($ids);
  497. if (!$row) {
  498. $this->error(__('No Results were found'));
  499. }
  500. $adminIds = $this->getDataLimitAdminIds();
  501. if (is_array($adminIds)) {
  502. if (!in_array($row[$this->dataLimitField], $adminIds)) {
  503. $this->error(__('You have no permission'));
  504. }
  505. }
  506. if ($this->request->isPost()) {
  507. $params = $this->request->post("row/a");
  508. if ($params) {
  509. $params = $this->preExcludeFields($params);
  510. $result = false;
  511. Db::startTrans();
  512. try {
  513. //是否采用模型验证
  514. if ($this->modelValidate) {
  515. $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
  516. $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate;
  517. // 添加规格数据到验证参数中
  518. if (isset($params['skus']) && isset($params['spec'])) {
  519. $params['spec_data'] = json_decode($params['spec'], true);
  520. $params['sku_data'] = json_decode($params['skus'], true);
  521. }
  522. $row->validateFailException(true)->validate($validate);
  523. }
  524. // 备份上架类型,因为status字段将被覆盖为最终状态
  525. $originalOnlineType = $params['online_type'] ?? GoodsEnum::ONLINE_TYPE_NOT_NOW;
  526. // 将online_type映射到status字段用于计算
  527. if (isset($params['online_type'])) {
  528. $params['status'] = $params['online_type'];
  529. unset($params['online_type']);
  530. }
  531. // 先保存商品基础信息(暂时不保存status字段)
  532. $statusBackup = $params['status'] ?? null;
  533. unset($params['status']); // 临时移除status避免冲突
  534. $result = $row->allowField(true)->save($params);
  535. // 根据上下架时间自动计算商品状态并更新
  536. $params['status'] = $statusBackup; // 恢复用于计算
  537. $calculatedStatus = $this->calculateGoodsStatus($params);
  538. $this->model->where('id', $row->id)->update([
  539. 'status' => $calculatedStatus,
  540. 'online_type' => $originalOnlineType // 保存原始上架类型用于编辑时回显
  541. ]);
  542. // 调试输出
  543. \think\Log::write('商品编辑 - 上架类型: ' . $originalOnlineType . ', 计算状态: ' . $calculatedStatus, 'info');
  544. //商品规格处理
  545. if (isset($params['skus']) && isset($params['spec'])) {
  546. $skus = (array)json_decode($params['skus'], true);
  547. $spec = (array)json_decode($params['spec'], true);
  548. // 只对多规格进行checkSku验证
  549. if (!empty($spec)) {
  550. $this->checkSku($skus, $spec);
  551. }
  552. // 统一处理SKU
  553. $this->processGoodsSku($params, $row->id);
  554. } else {
  555. throw new \Exception('商品规格数据不能为空');
  556. }
  557. //商品属性
  558. if (isset($params['attribute_ids'])) {
  559. GoodsAttr::addGoodsAttr($params['attribute_ids'], $row->id);
  560. }
  561. Db::commit();
  562. } catch (ValidateException $e) {
  563. Db::rollback();
  564. $this->error($e->getMessage());
  565. } catch (PDOException $e) {
  566. Db::rollback();
  567. $this->error($e->getMessage());
  568. } catch (Exception $e) {
  569. Db::rollback();
  570. $this->error($e->getMessage());
  571. }
  572. if ($result !== false) {
  573. $this->success();
  574. } else {
  575. $this->error(__('No rows were updated'));
  576. }
  577. }
  578. $this->error(__('Parameter %s can not be empty', ''));
  579. }
  580. // 查询SKU数据,包含规格属性字符串
  581. $list = $this->sku_model->field("sku.*,GROUP_CONCAT(sp.name,':',sv.value ORDER BY sp.id asc) sku_attr")
  582. ->alias('sku')
  583. ->where('sku.goods_id', $row->id)
  584. ->join('shop_goods_sku_spec p', "FIND_IN_SET(p.id,sku.spec_value_ids)", 'LEFT')
  585. ->join('shop_spec sp', 'sp.id=p.spec_id', 'LEFT')
  586. ->join('shop_spec_value sv', 'sv.id=p.spec_value_id', 'LEFT')
  587. ->group('sku.id')
  588. ->select();
  589. // 查询规格值的详细信息(包含图片等扩展字段)
  590. $spec_values = [];
  591. if ($row->spec_type == 1) { // 多规格商品
  592. $spec_values = Db::name('shop_goods_sku_spec')
  593. ->alias('gss')
  594. ->field('sp.name as spec_name, sv.value, sv.image, sv.desc')
  595. ->join('shop_spec sp', 'sp.id = gss.spec_id', 'LEFT')
  596. ->join('shop_spec_value sv', 'sv.id = gss.spec_value_id', 'LEFT')
  597. ->where('gss.goods_id', $row->id)
  598. ->group('gss.spec_id, gss.spec_value_id')
  599. ->order('sp.id asc, sv.id asc')
  600. ->select();
  601. }
  602. $this->view->assign("row", $row);
  603. $this->assignconfig('goods', $row);
  604. $this->assignconfig('goods_skus', $list);
  605. $this->assignconfig('spec_values', $spec_values); // 传递规格值详细信息
  606. return $this->view->fetch();
  607. }
  608. /**
  609. * 根据ID批量获取商品信息
  610. */
  611. public function get_goods_by_ids()
  612. {
  613. $ids = $this->request->request('ids');
  614. if (!$ids) {
  615. $this->error('请选择商品');
  616. }
  617. $ids = explode(',', $ids);
  618. $list = $this->model
  619. ->with(['Category'])
  620. ->where('id', 'in', $ids)
  621. ->select();
  622. // 处理图片URL
  623. foreach ($list as &$item) {
  624. if ($item['image']) {
  625. $item['image'] = cdnurl($item['image'], true);
  626. }
  627. }
  628. return json($list);
  629. }
  630. }