Goods.php 30 KB

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