Goods.php 31 KB

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