GoodsService.php 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466
  1. <?php
  2. namespace app\admin\service\goods;
  3. use app\model\Goods;
  4. use app\model\GoodsComponent;
  5. use app\model\GoodsDetail;
  6. use app\model\GoodsLabel;
  7. use app\model\GoodsRunning;
  8. use app\model\GoodsSku;
  9. use app\model\SysCategory;
  10. use app\model\SysSerial;
  11. use support\Db;
  12. use support\exception\BusinessException;
  13. use support\Redis;
  14. use support\Request;
  15. use support\Response;
  16. class GoodsService
  17. {
  18. public static function selectAll($goodsIds)
  19. {
  20. $goods = Goods::where('goods_status', 'ON')
  21. ->when($goodsIds != '', function ($query) use ($goodsIds) {
  22. $query->whereIn('goods_id', $goodsIds);
  23. })
  24. ->select('goods_id', 'goods_name')
  25. ->get();
  26. return json_success('', $goods);
  27. }
  28. public static function select(Request $request, $classify = "GOODS")
  29. {
  30. $page = $request->get('page');
  31. $pageSize = $request->get('pageSize');
  32. $goodsName = $request->get('goods_name', '');
  33. $categoryId = $request->get('join_goods_category_id', null);
  34. $rows = Goods::with([
  35. 'category' => function ($query) {
  36. $query->select('category_id', 'category_name');
  37. },
  38. 'running' => function ($query) {
  39. $query->select('join_running_goods_id', 'goods_running_storage');
  40. },
  41. 'supplier' => function ($query) {
  42. $query->select('supplier_id', 'supplier_name');
  43. }
  44. ])->select('goods_id', 'join_goods_category_id', 'join_goods_supplier_id', 'goods_status', 'goods_sales_price', 'goods_category', 'goods_name', 'goods_title', 'goods_cover', 'goods_sort', 'goods_addtimes')
  45. ->when($goodsName != '', function ($query) use ($goodsName) {
  46. $query->where(function ($q) use ($goodsName) {
  47. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  48. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  49. });
  50. })->when($categoryId != null, function ($query) use ($categoryId) {
  51. $query->where('join_goods_category_id', $categoryId);
  52. })
  53. ->when($classify != '', function ($query) use ($classify) {
  54. if ($classify == 'GOODS') {
  55. $query->whereIn('join_goods_category_id', ['6', '7', '8', '9', '10', '11', '12', '30']);
  56. } else {
  57. $query->where('goods_classify', $classify);
  58. }
  59. })
  60. ->orderBy('goods_addtimes', 'DESC')
  61. ->forPage($page, $pageSize)
  62. ->get()
  63. ->toArray();
  64. $total = Goods::when($goodsName != '', function ($query) use ($goodsName) {
  65. $query->where(function ($q) use ($goodsName) {
  66. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  67. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  68. });
  69. })->when($categoryId != null, function ($query) use ($categoryId) {
  70. $query->where('join_goods_category_id', $categoryId);
  71. })->when($classify != '', function ($query) use ($classify) {
  72. if ($classify == 'GOODS') {
  73. $query->whereIn('join_goods_category_id', ['6', '7', '8', '9', '10', '11', '12', '30']);
  74. } else {
  75. $query->where('goods_classify', $classify);
  76. }
  77. })
  78. ->count();
  79. foreach ($rows as &$row) {
  80. $row['goods_cover'] = getenv('STORAGE_DOMAIN') . $row['goods_cover'];
  81. if (isset($row['running'])) {
  82. $row['running']['goods_running_storage'] = intval($row['running']['goods_running_storage']);
  83. }
  84. }
  85. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  86. }
  87. public static function selectSpecial(Request $request)
  88. {
  89. $page = $request->get('page');
  90. $pageSize = $request->get('pageSize');
  91. $goodsName = $request->get('goods_name', '');
  92. $categoryId = $request->get('join_goods_category_id', null);
  93. if ($categoryId == null) {
  94. $categoryId = [65, 43];
  95. } elseif (is_string($categoryId)) {
  96. $categoryId = [$categoryId];
  97. }
  98. $rows = Goods::with([
  99. 'category' => function ($query) {
  100. $query->select('category_id', 'category_name');
  101. },
  102. 'running' => function ($query) {
  103. $query->select('join_running_goods_id', 'goods_running_storage');
  104. },
  105. 'supplier' => function ($query) {
  106. $query->select('supplier_id', 'supplier_name');
  107. }
  108. ])->select('goods_id', 'join_goods_category_id', 'join_goods_supplier_id', 'goods_status', 'goods_sales_price', 'goods_category', 'goods_name', 'goods_title', 'goods_cover', 'goods_sort', 'goods_addtimes')
  109. ->when($goodsName != '', function ($query) use ($goodsName) {
  110. $query->where(function ($q) use ($goodsName) {
  111. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  112. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  113. });
  114. })->whereIn('join_goods_category_id', $categoryId)
  115. ->orderBy('goods_addtimes', 'DESC')
  116. ->forPage($page, $pageSize)
  117. ->get()
  118. ->toArray();
  119. $total = Goods::when($goodsName != '', function ($query) use ($goodsName) {
  120. $query->where(function ($q) use ($goodsName) {
  121. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  122. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  123. });
  124. })->whereIn('join_goods_category_id', $categoryId)->count();
  125. foreach ($rows as &$row) {
  126. $row['goods_cover'] = getenv('STORAGE_DOMAIN') . $row['goods_cover'];
  127. if (isset($row['running'])) {
  128. $row['running']['goods_running_storage'] = intval($row['running']['goods_running_storage']);
  129. }
  130. }
  131. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  132. }
  133. public static function selectPicking(Request $request)
  134. {
  135. $page = $request->get('page');
  136. $pageSize = $request->get('pageSize');
  137. $goodsName = $request->get('goods_name', '');
  138. $rows = Goods::with([
  139. 'category' => function ($query) {
  140. $query->select('category_id', 'category_name');
  141. },
  142. 'running' => function ($query) {
  143. $query->select('join_running_goods_id', 'goods_running_storage');
  144. },
  145. 'supplier' => function ($query) {
  146. $query->select('supplier_id', 'supplier_name');
  147. }
  148. ])->select('goods_id', 'join_goods_category_id', 'join_goods_supplier_id', 'goods_status', 'goods_sales_price', 'goods_category', 'goods_name', 'goods_title', 'goods_cover', 'goods_sort', 'goods_addtimes')
  149. ->when($goodsName != '', function ($query) use ($goodsName) {
  150. $query->where(function ($q) use ($goodsName) {
  151. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  152. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  153. });
  154. })->where('goods_classify', 'SERVICE')
  155. ->where('goods_category', 'FARM')
  156. ->orderBy('goods_addtimes', 'DESC')
  157. ->forPage($page, $pageSize)
  158. ->get()
  159. ->toArray();
  160. $total = Goods::when($goodsName != '', function ($query) use ($goodsName) {
  161. $query->where(function ($q) use ($goodsName) {
  162. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  163. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  164. });
  165. })->where('goods_classify', 'SERVICE')
  166. ->where('goods_category', 'FARM')
  167. ->count();
  168. foreach ($rows as &$row) {
  169. $row['goods_cover'] = getenv('STORAGE_DOMAIN') . $row['goods_cover'];
  170. if (isset($row['running'])) {
  171. $row['running']['goods_running_storage'] = intval($row['running']['goods_running_storage']);
  172. }
  173. }
  174. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  175. }
  176. public static function selectPackage(Request $request)
  177. {
  178. $page = $request->get('page');
  179. $pageSize = $request->get('pageSize');
  180. $goodsName = $request->get('goods_name', '');
  181. $categoryId = $request->get('join_goods_category_id', null);
  182. $rows = Goods::with([
  183. 'category' => function ($query) {
  184. $query->select('category_id', 'category_name');
  185. },
  186. 'running' => function ($query) {
  187. $query->select('join_running_goods_id', 'goods_running_storage');
  188. },
  189. 'supplier' => function ($query) {
  190. $query->select('supplier_id', 'supplier_name');
  191. },
  192. ])->select('goods_id', 'join_goods_category_id', 'join_goods_supplier_id', 'goods_status', 'goods_sales_price', 'goods_category', 'goods_name', 'goods_title', 'goods_cover', 'goods_sort', 'goods_addtimes')
  193. ->when($goodsName != '', function ($query) use ($goodsName) {
  194. $query->where(function ($q) use ($goodsName) {
  195. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  196. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  197. });
  198. })->when($categoryId != null, function ($query) use ($categoryId) {
  199. $query->where('join_goods_category_id', $categoryId);
  200. })
  201. ->where('goods_classify', 'PACKAGE')
  202. ->orderBy('goods_addtimes', 'DESC')
  203. ->forPage($page, $pageSize)
  204. ->get()
  205. ->toArray();
  206. $total = Goods::when($goodsName != '', function ($query) use ($goodsName) {
  207. $query->where(function ($q) use ($goodsName) {
  208. $q->where('goods_name', 'like', '%' . $goodsName . '%')
  209. ->OrWhere('goods_title', 'like', '%' . $goodsName . '%');
  210. });
  211. })->when($categoryId != null, function ($query) use ($categoryId) {
  212. $query->where('join_goods_category_id', $categoryId);
  213. })->where('goods_classify', 'PACKAGE')->count();
  214. foreach ($rows as &$row) {
  215. $row['goods_cover'] = getenv('STORAGE_DOMAIN') . $row['goods_cover'];
  216. if (isset($row['running'])) {
  217. $row['running']['goods_running_storage'] = intval($row['running']['goods_running_storage']);
  218. }
  219. // if (!empty($row['component'])) {
  220. // $ids = [];
  221. // $contentList = [];
  222. // foreach ($row['component'] as $component) {
  223. // $ids[] = $component['join_component_goods_id'];
  224. // $configJson = json_decode($component['goods_component_config_json'], true);
  225. // $contentList[] = [
  226. // 'goods_name' => $configJson['goods_name'] ?? '',
  227. // 'goods_sales_price' => $component['goods_component_price'],
  228. // 'nbr' => $configJson['nbr'] ?? 0
  229. // ];
  230. // }
  231. //
  232. // $row['join_component_goods_id'] = $ids;
  233. // $row['goodsContentList'] = $contentList;
  234. // }
  235. }
  236. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  237. }
  238. /**
  239. * @Desc 下拉选择服务商品
  240. * @Author Gorden
  241. * @Date 2024/4/24 13:32
  242. *
  243. * @param Request $request
  244. * @return Response
  245. */
  246. public static function selectList(Request $request, $goodsClassify = "SERVICE")
  247. {
  248. $keywords = $request->get('keywords', '');
  249. // if (!$keywords){
  250. // return json_success('暂无数据');
  251. // }
  252. $categoryIds = SysCategory::whereIn('category_super_id', [5, 31, 32, 42, 66, 70, 72])->pluck('category_id');
  253. $goods = Goods::with('sku')
  254. ->whereIn('join_goods_category_id', $categoryIds)
  255. ->when($keywords != '', function ($query) use ($keywords) {
  256. $query->where('goods_name', 'like', "%" . $keywords . "%");
  257. })
  258. ->select('goods_id', 'goods_name', 'goods_sales_price', 'join_goods_category_id')
  259. ->get()
  260. ->toArray();
  261. foreach ($goods as &$good) {
  262. if (!empty($good['sku'])) {
  263. foreach ($good['sku'] as $key => $sku) {
  264. if (!empty($sku['goods_sku_specs_json'])) {
  265. $good['sku'][$key]['goods_sku_specs_json'] = json_decode($sku['goods_sku_specs_json']);
  266. $skuName = '';
  267. foreach ($good['sku'][$key]['goods_sku_specs_json'] as $specsKey => $skuSpecs) {
  268. if (is_array($skuSpecs)) {
  269. $skuName = $skuName . ' ' . $specsKey . ' ' . implode(' ', $skuSpecs);
  270. } else {
  271. $skuName = $skuName . ' ' . $specsKey . ' ' . $skuSpecs;
  272. }
  273. }
  274. $good['sku'][$key]['sku_name'] = $skuName;
  275. }
  276. }
  277. } else {
  278. $good['sku'] = [];
  279. }
  280. }
  281. return json_success('', $goods);
  282. }
  283. /**
  284. * @Desc 商品详情
  285. * @Author Gorden
  286. * @Date 2024/3/28 10:25
  287. *
  288. * @param $goodsId
  289. * @return Response
  290. */
  291. public static function info($goodsId)
  292. {
  293. try {
  294. // 商品主表
  295. $main = Goods::where('goods_id', $goodsId)->first();
  296. if (!empty($main)) {
  297. $main = $main->toArray();
  298. $main['goods_sku_json'] = json_decode($main['goods_sku_json'], true);
  299. $main['specList'] = [];
  300. foreach ($main['goods_sku_json'] as $key => $sku) {
  301. $main['specList'][] = [
  302. 'label' => $key,
  303. 'tags' => $sku
  304. ];
  305. }
  306. } else {
  307. $main = [];
  308. }
  309. // 详情表
  310. $detail = GoodsDetail::where('join_detail_goods_id', $goodsId)->first();
  311. if (!empty($detail)) {
  312. $detail = $detail->toArray();
  313. } else {
  314. $detail = [];
  315. }
  316. // 标签表
  317. $label = GoodsLabel::where('join_label_goods_id', $goodsId)->first();
  318. if (!empty($label)) {
  319. $label = $label->toArray();
  320. } else {
  321. $label = [];
  322. }
  323. // Running表
  324. $running = GoodsRunning::where('join_running_goods_id', $goodsId)->first();
  325. if (!empty($running)) {
  326. $running = $running->toArray();
  327. if (!empty($running['goods_running_off_json']) && is_json($running['goods_running_off_json'])) {
  328. $goodsRunningOffJson = json_decode($running['goods_running_off_json'], true);
  329. $running['goods_off_addtimes'] = isset($goodsRunningOffJson['time']) ? date("Y-m-d H:i", $goodsRunningOffJson['time']) : '';
  330. }
  331. } else {
  332. $running = [];
  333. }
  334. // Sku表
  335. $skus = GoodsSku::where('join_sku_goods_id', $goodsId)->get();
  336. if (!empty($skus)) {
  337. $skus = $skus->toArray();
  338. $submitList = [];
  339. foreach ($skus as $key => $sku) {
  340. $skuSpecsJson = json_decode($sku['goods_sku_specs_json'], true);
  341. $skuSpecs = '';
  342. $skuNameValue = [];
  343. $i = 1;
  344. foreach ($skuSpecsJson as $k => $item) {
  345. if (is_array($item)) {
  346. $item = implode(',', $item);
  347. }
  348. $skuSpecs = $skuSpecs . $item . ',';
  349. $skuNameKey = 'skuName' . $i;
  350. $skuValueKey = 'skuValue' . $i;
  351. $skuNameValue[$skuNameKey] = $k;
  352. $skuNameValue[$skuValueKey] = $item;
  353. $skuNameValue[$k] = $item;
  354. $i++;
  355. }
  356. $storage = json_decode($sku['goods_sku_storage_json'], true);
  357. $priceStorage = [
  358. 'sku_id' => $sku['goods_sku_id'],
  359. 'sku' => rtrim($skuSpecs, ',') ?? '',
  360. 'stock' => $storage['storage'] ?? '',
  361. 'price' => $sku['goods_sku_sales_price'] ?? '',
  362. ];
  363. $submitList[] = array_merge($skuNameValue, $priceStorage);
  364. }
  365. $skus['submitList'] = $submitList;
  366. } else {
  367. $skus = [];
  368. }
  369. // 合并数据
  370. $data = array_merge($main, $detail, $label, $running, ['sku' => $skus]);
  371. $data['goods_sku_json_label'] = [];
  372. $data['goods_label'] = !empty($data['goods_label']) ? explode(',', $data['goods_label']) : [];
  373. $data['goods_json'] = $data['goods_json'] ? json_decode($data['goods_json'], true) : [];
  374. $data['goods_cover'] = getenv('STORAGE_DOMAIN') . $data['goods_cover'];
  375. if (!empty($data['goods_detail_slider_json'])) {
  376. $data['goods_detail_slider_json'] = json_decode($data['goods_detail_slider_json'], true);
  377. // ……
  378. if (isset($data['goods_detail_slider_json']['slider'])) {
  379. $data['goods_detail_slider_json'] = explode(',', $data['goods_detail_slider_json']['slider']);
  380. }
  381. $slider = '';
  382. foreach ($data['goods_detail_slider_json'] as $item) {
  383. $slider .= getenv('STORAGE_DOMAIN') . $item . ',';
  384. }
  385. $data['goods_detail_slider_json'] = rtrim($slider, ',');
  386. }
  387. $extendJson = [];
  388. if (!empty($data['goods_attribute_json'])) {
  389. $extendJson = json_decode($data['goods_attribute_json'], true);
  390. }
  391. $data['appointment_times'] = [];
  392. if ($data['is_support_appointment'] == 'Y' && isset($extendJson['dates'])) {
  393. $data['dates'] = $extendJson['dates'] ?? [];
  394. if (isset($extendJson['times'])) {
  395. $times = [];
  396. foreach ($extendJson['times'] as $time) {
  397. if (!empty($time['duration'])) {
  398. $startEndTime = explode('-', $time['duration']);
  399. $times[] = [
  400. 'person' => $time['person'],
  401. 'appointmentTimeStart' => $startEndTime[0],
  402. 'appointmentTimeEnd' => $startEndTime[1],
  403. ];
  404. }
  405. }
  406. $data['appointment_times'] = $times;
  407. }
  408. if (isset($extendJson['address'])) {
  409. $data['address'] = $extendJson['address'];
  410. }
  411. if (isset($extendJson['position'])) {
  412. $data['position'] = $extendJson['position'];
  413. }
  414. if (isset($extendJson['label'])) {
  415. $data['appointment_label'] = $extendJson['label'];
  416. }
  417. }
  418. if (!empty($data['goods_json']) && $data['join_goods_category_id'] == 65) {
  419. foreach ($data['goods_json'] as $key => $datum) {
  420. $data['goods_json'][$key]['color'] = rgbToHex($datum['color']);
  421. }
  422. } elseif (!empty($data['goods_json']) && $data['join_goods_category_id'] == 43) {
  423. // dump($data['goods_json']);
  424. foreach ($data['goods_json'] as $key1 => $item1) {
  425. $data['goods_json'][$key1]['title'] = $key1;
  426. foreach ($item1['items'] as $key2 => $item2) {
  427. $data['goods_json'][$key1]['items'][$key2]['key'] = $key2;
  428. $data['goods_json'][$key1]['items'][$key2]['params'] = $item2;
  429. }
  430. }
  431. }
  432. $data['goods_on_addtimes'] = date('Y-m-d\TH:i:s.u\Z', $data['goods_on_addtimes'] - 60 * 60 * 8);
  433. return json_success('', $data);
  434. } catch (\Exception $e) {
  435. dump($e->getMessage());
  436. return json_fail("查询错误~");
  437. }
  438. }
  439. public static function infoPackage($goodsId)
  440. {
  441. try {
  442. // 商品主表
  443. $main = Goods::where('goods_id', $goodsId)->first();
  444. if (!empty($main)) {
  445. $main = $main->toArray();
  446. $main['goods_sku_json'] = json_decode($main['goods_sku_json'], true);
  447. $main['specList'] = [];
  448. foreach ($main['goods_sku_json'] as $key => $sku) {
  449. $main['specList'][] = [
  450. 'label' => $key,
  451. 'tags' => $sku
  452. ];
  453. }
  454. } else {
  455. $main = [];
  456. }
  457. // 详情表
  458. $detail = GoodsDetail::where('join_detail_goods_id', $goodsId)->first();
  459. if (!empty($detail)) {
  460. $detail = $detail->toArray();
  461. } else {
  462. $detail = [];
  463. }
  464. // 标签表
  465. $label = GoodsLabel::where('join_label_goods_id', $goodsId)->first();
  466. if (!empty($label)) {
  467. $label = $label->toArray();
  468. } else {
  469. $label = [];
  470. }
  471. // Running表
  472. $running = GoodsRunning::where('join_running_goods_id', $goodsId)->first();
  473. if (!empty($running)) {
  474. $running = $running->toArray();
  475. if (!empty($running['goods_running_off_json']) && is_json($running['goods_running_off_json'])) {
  476. $goodsRunningOffJson = json_decode($running['goods_running_off_json'], true);
  477. $running['goods_off_addtimes'] = isset($goodsRunningOffJson['time']) ? date("Y-m-d H:i", $goodsRunningOffJson['time']) : '';
  478. }
  479. } else {
  480. $running = [];
  481. }
  482. // 组件表
  483. $component = GoodsComponent::where('join_component_master_goods_id', $goodsId)->get()->toArray();
  484. $componentArr['join_component_goods_id'] = [];
  485. $componentArr['goodsContentList'] = [];
  486. if ($component) {
  487. $ids = [];
  488. $contentList = [];
  489. foreach ($component as $item) {
  490. if (empty($item['join_component_goods_id'])) {
  491. continue;
  492. }
  493. $skus = GoodsSku::where('join_sku_goods_id', $item['join_component_goods_id'])
  494. ->select('goods_sku_id', 'join_sku_goods_id', 'goods_sku_specs_json', 'goods_sku_sales_price')
  495. ->get()
  496. ->toArray();
  497. foreach ($skus as $key => $sku2) {
  498. if (!empty($sku2['goods_sku_specs_json'])) {
  499. $skus[$key]['goods_sku_specs_json'] = json_decode($sku2['goods_sku_specs_json'], true);
  500. $skuName = '';
  501. foreach ($skus[$key]['goods_sku_specs_json'] as $specsKey => $skuSpecs) {
  502. if (is_array($skuSpecs)) {
  503. $skuName = $skuName . ' ' . $specsKey . ' ' . implode(' ', $skuSpecs);
  504. } else {
  505. $skuName = $skuName . ' ' . $specsKey . ' ' . $skuSpecs;
  506. }
  507. }
  508. $skus[$key]['sku_name'] = $skuName;
  509. }
  510. }
  511. $ids[] = $item['join_component_goods_id'];
  512. $configJson = json_decode($item['goods_component_json'], true);
  513. $contentList[] = [
  514. 'goods_id' => $item['join_component_goods_id'],
  515. 'goods_name' => $configJson['goods_name'] ?? '',
  516. 'goods_sales_price' => $item['goods_component_price'],
  517. 'nbr' => $configJson['nbr'] ?? 0,
  518. 'sku_id' => $configJson['sku_id'] ?? '',
  519. 'skus' => $skus
  520. ];
  521. }
  522. $componentArr['join_component_goods_id'] = $ids;
  523. $componentArr['goodsContentList'] = $contentList;
  524. }
  525. // 合并数据
  526. $data = array_merge($main, $detail, $label, $running, $componentArr);
  527. $data['goods_sku_json_label'] = [];
  528. $data['goods_label'] = !empty($data['goods_label']) ? explode(',', $data['goods_label']) : [];
  529. $data['goods_cover'] = getenv('STORAGE_DOMAIN') . $data['goods_cover'];
  530. if (!empty($data['goods_detail_slider_json'])) {
  531. $data['goods_detail_slider_json'] = json_decode($data['goods_detail_slider_json'], true);
  532. $slider = '';
  533. foreach ($data['goods_detail_slider_json'] as $item) {
  534. $slider .= getenv('STORAGE_DOMAIN') . $item . ',';
  535. }
  536. $data['goods_detail_slider_json'] = rtrim($slider, ',');
  537. }
  538. $data['goods_on_addtimes'] = date('Y-m-d\TH:i:s.u\Z', $data['goods_on_addtimes'] - 60 * 60 * 8);
  539. return json_success('', $data);
  540. } catch (\Exception $e) {
  541. dump($e->getTrace());
  542. return json_fail("查询错误~");
  543. }
  544. }
  545. /**
  546. * @Desc 添加商品
  547. * @Author Gorden
  548. * @Date 2024/3/11 10:20
  549. *
  550. * @param $params
  551. * @return Response
  552. */
  553. public static function insert($params): Response
  554. {
  555. Db::beginTransaction();
  556. try {
  557. $params['goods_id'] = "GD" . sprintf('%016d', SysSerial::getSerial()) . random_string(6, 'up');
  558. // 主表
  559. self::mainInsert($params);
  560. // 商品详情表
  561. self::detailInsert($params);
  562. // 商品标签表
  563. self::labelInsert($params);
  564. // 产品运行控制信息表
  565. self::goodsRunningInsert($params);
  566. // sku表
  567. self::goodsSkuSet($params, 'insert');
  568. // 待上架状态,上架时间大于当前时间
  569. if ($params['goods_status'] == 'PENDING' && strtotime($params['goods_on_addtimes']) > time()) {
  570. $redis = Redis::connection();
  571. $key = date('YmdHi', strtotime($params['goods_on_addtimes']));
  572. $redis->sAdd(Goods::LISTING_KEY_PREFIX . $key, $params['goods_id']);
  573. }
  574. // 自动下架
  575. if (!empty($params['goods_running_off_type']) && $params['goods_running_off_type'] == 'T' && !empty($params['goods_off_addtimes'])) {
  576. $redis = Redis::connection();
  577. $key = Goods::LISTING_OFF_KEY_PREFIX . date('YmdHi', strtotime($params['goods_off_addtimes']));
  578. $redis->sAdd($key, $params['goods_id']);
  579. }
  580. Db::commit();
  581. } catch (\PDOException $e) {
  582. Db::rollBack();
  583. dump($e->getMessage());
  584. return json_fail('数据写入失败~');
  585. } catch (BusinessException $e) {
  586. Db::rollBack();
  587. dump($e->getMessage());
  588. return json_fail($e->getMessage());
  589. } catch (\Exception $e) {
  590. Db::rollBack();
  591. dump($e->getTrace());
  592. return json_fail('数据写入失败~');
  593. }
  594. _syslog("添加商品", "商品名【" . $params['goods_name'] . "】");
  595. return json_success('success');
  596. }
  597. public static function insertPackage($params): Response
  598. {
  599. Db::beginTransaction();
  600. try {
  601. $params['goods_id'] = "GD" . sprintf('%016d', SysSerial::getSerial()) . random_string(6, 'up');
  602. // 主表
  603. self::mainInsert($params);
  604. // 商品详情表
  605. self::detailInsert($params);
  606. // 套包组件表
  607. self::componentUpdate($params, 'insert');
  608. // 商品标签表
  609. self::labelInsert($params);
  610. // 产品运行控制信息表
  611. self::goodsRunningInsert($params);
  612. // sku表
  613. self::goodsSkuSet($params, 'insert');
  614. // 待上架状态,上架时间大于当前时间
  615. if ($params['goods_status'] == 'PENDING' && strtotime($params['goods_on_addtimes']) > time()) {
  616. $redis = Redis::connection();
  617. $key = date('YmdHi', strtotime($params['goods_on_addtimes']));
  618. $redis->sAdd(Goods::LISTING_KEY_PREFIX . $key, $params['goods_id']);
  619. }
  620. Db::commit();
  621. } catch (\PDOException $e) {
  622. Db::rollBack();
  623. dump($e->getMessage());
  624. return json_fail('数据写入失败~');
  625. } catch (BusinessException $e) {
  626. Db::rollBack();
  627. dump($e->getMessage());
  628. return json_fail($e->getMessage());
  629. } catch (\Exception $e) {
  630. Db::rollBack();
  631. dump($e->getTrace());
  632. return json_fail('数据写入失败~');
  633. }
  634. _syslog("添加套餐", "商品名【" . $params['goods_name'] . "】");
  635. return json_success('success');
  636. }
  637. public static function update($params)
  638. {
  639. Db::beginTransaction();
  640. try {
  641. // 主表
  642. self::mainUpdate($params);
  643. // 商品详情表
  644. self::detailUpdate($params);
  645. // 商品标签表
  646. self::labelUpdate($params);
  647. // 产品运行控制信息表
  648. self::goodsRunningUpdate($params);
  649. // sku表
  650. self::goodsSkuSet($params, 'update');
  651. Db::commit();
  652. } catch (BusinessException $e) {
  653. Db::rollBack();
  654. return json_fail($e->getMessage());
  655. } catch (\Exception $e) {
  656. Db::rollBack();
  657. return json_fail('数据更新失败~');
  658. }
  659. _syslog("编辑商品", "商品名【" . $params['goods_name'] . "】" ?? "商品ID:【" . $params['goods_id'] . "】");
  660. return json_success('success');
  661. }
  662. public static function changeStatus($params)
  663. {
  664. try {
  665. Goods::where('goods_id', $params['goods_id'])->update(['goods_status' => $params['goods_status']]);
  666. return json_success('修改成功');
  667. } catch (\Exception $e) {
  668. return json_fail('修改状态失败');
  669. }
  670. }
  671. public static function updatePackage($params)
  672. {
  673. Db::beginTransaction();
  674. try {
  675. // 主表
  676. self::mainUpdate($params);
  677. // 商品详情表
  678. self::detailUpdate($params);
  679. // 套包组件表
  680. self::componentUpdate($params, 'update');
  681. // 商品标签表
  682. self::labelUpdate($params);
  683. // 产品运行控制信息表
  684. self::goodsRunningUpdate($params);
  685. Db::commit();
  686. } catch (BusinessException $e) {
  687. Db::rollBack();
  688. return json_fail($e->getMessage());
  689. } catch (\Exception $e) {
  690. Db::rollBack();
  691. dump($e->getTrace());
  692. return json_fail('数据更新失败~');
  693. }
  694. _syslog("编辑套餐", "商品名【" . $params['goods_name'] . "】" ?? "商品ID:【" . $params['goods_id'] . "】");
  695. return json_success('success');
  696. }
  697. /**
  698. * @Desc 删除商品
  699. * @Author Gorden
  700. * @Date 2024/3/28 13:20
  701. *
  702. * @param $ids
  703. * @return Response
  704. */
  705. public static function delete($ids)
  706. {
  707. if (!$ids) {
  708. return json_fail("数据错误~");
  709. }
  710. if (!is_array($ids)) {
  711. $ids = [$ids];
  712. }
  713. $goods = Goods::whereIn('goods_id', $ids)->get()->toArray();
  714. if (!$goods) {
  715. return json_fail("数据错误~");
  716. }
  717. Db::beginTransaction();
  718. try {
  719. Goods::whereIn('goods_id', $ids)->delete();
  720. GoodsDetail::whereIn('join_detail_goods_id', $ids)->delete();
  721. GoodsLabel::whereIn('join_label_goods_id', $ids)->delete();
  722. GoodsRunning::whereIn('join_running_goods_id', $ids)->delete();
  723. GoodsSku::whereIn('join_sku_goods_id', $ids)->delete();
  724. Db::commit();
  725. _syslog("删除商品 / 套餐", "ID:【" . implode(',', $ids) . "】", $goods);
  726. return json_success("商品删除成功");
  727. } catch (\Exception $e) {
  728. Db::rollBack();
  729. return json_fail("商品删除失败~");
  730. }
  731. }
  732. /**
  733. * @Desc 商品主表
  734. * @Author Gorden
  735. * @Date 2024/3/11 11:20
  736. *
  737. * @param $params
  738. * @return mixed|string
  739. * @throws BusinessException
  740. */
  741. public static function mainInsert($params)
  742. {
  743. if (!empty($params['goods_cover'])) {
  744. $params['goods_cover'] = str_replace(getenv('STORAGE_DOMAIN'), '', $params['goods_cover']);
  745. }
  746. // 如果产品是待处理状态
  747. if ($params['goods_status'] == 'PENDING') {
  748. if (strtotime($params['goods_on_addtimes']) <= time()) {
  749. $params['goods_status'] = 'ON';
  750. }
  751. }
  752. $category = SysCategory::where('category_id', $params['join_goods_category_id'])->first();
  753. if (!$category) {
  754. throw new BusinessException("产品分类不存在~");
  755. }
  756. try {
  757. $model = new Goods();
  758. $model->goods_id = $params['goods_id'];
  759. $model->join_goods_category_id = $params['join_goods_category_id'] ?? 0;
  760. $model->join_goods_supplier_id = $params['join_goods_supplier_id'] ?? 0;
  761. $model->goods_classify = $params['goods_classify'] ?? '';
  762. $model->goods_status = $params['goods_status'] ?? '';
  763. $model->goods_category = $category->category_classify ?? '';
  764. $model->goods_prefix = $params['goods_prefix'] ?? ($category->category_name ? '【' . $category->category_name . '】' : '');
  765. $model->goods_name = $params['goods_name'];
  766. $model->goods_market_price = $params['goods_market_price'] ?? 0;
  767. $model->goods_sales_price = $params['goods_sales_price'] ?? 0;
  768. $model->goods_sku_json = !empty($params['goods_sku_json_label']) ? json_encode($params['goods_sku_json_label']) : json_encode(['规格' => []]);
  769. $model->goods_attribute_json = !empty($params['goods_attribute_json']) ? $params['goods_attribute_json'] : '{}';
  770. // $model->goods_service_json = !empty($params['goods_service_json']) ? $params['goods_service_json'] : '{}';
  771. $model->goods_title = $params['goods_title'] ?? '';
  772. $model->goods_cover = $params['goods_cover'] ?? '';
  773. $model->goods_on_addtimes = $params['goods_on_addtimes'] ? strtotime($params['goods_on_addtimes']) : null;
  774. $model->goods_sort = $params['goods_sort'] ?? null;
  775. $model->goods_groupby = $params['goods_groupby'] ?? '';
  776. $model->goods_remark = $params['goods_remark'] ?? '';
  777. $model->goods_extend_json = $params['goods_extend_json'] ?? '{}';
  778. $model->is_support_appointment = $params['is_support_appointment'] ?? 'N';
  779. $model->goods_addtimes = time();
  780. if (!empty($params['is_support_appointment']) && $params['is_support_appointment'] == 'Y' && !empty($params['appointment_times'])) {
  781. $times = [];
  782. foreach ($params['appointment_times'] as $time) {
  783. $times[$time['appointmentTimeStart']] = [
  784. 'person' => $time['person'],
  785. 'duration' => $time['appointmentTimeStart'] . '-' . $time['appointmentTimeEnd']
  786. ];
  787. }
  788. $model->goods_attribute_json = json_encode([
  789. 'icon' => '',
  790. 'dates' => $params['dates'] ?? [],
  791. 'times' => $times
  792. ]);
  793. }
  794. if (!empty($params['goods_json']) && $params['join_goods_category_id'] == 65) {
  795. $goodsJson = json_decode($params['goods_json'], true);
  796. foreach ($goodsJson as $key => $item) {
  797. $goodsJson[$key]['color'] = hexToRgb($item['color']);
  798. }
  799. $model->goods_json = json_encode($goodsJson);
  800. } elseif (!empty($params['goods_json']) && $params['join_goods_category_id'] == 43) {
  801. $goodsJson = json_decode($params['goods_json'], true);
  802. $newGoodsJson = [];
  803. foreach ($goodsJson as $item1) {
  804. $newItem1 = [];
  805. foreach ($item1['items'] as $item2) {
  806. $newItem1['items'][$item2['key']] = $item2['params'];
  807. }
  808. $newItem1['service'] = $item1['service'];
  809. $newGoodsJson[$item1['title']] = $newItem1;
  810. }
  811. $model->goods_json = json_encode($newGoodsJson);
  812. } else {
  813. $model->goods_json = '[]';
  814. }
  815. if ($model->save()) {
  816. return $model->goods_id;
  817. }
  818. // 异常
  819. throw new BusinessException("数据写入失败~");
  820. } catch (\Exception $e) {
  821. dump($e->getMessage());
  822. throw new BusinessException("数据写入失败~");
  823. }
  824. }
  825. /**
  826. * @Desc 详情表
  827. * @Author Gorden
  828. * @Date 2024/3/11 11:19
  829. *
  830. * @param $params
  831. * @return void
  832. * @throws BusinessException
  833. */
  834. public static function detailInsert($params)
  835. {
  836. if (!empty($params['goods_detail_slider_json'])) {
  837. $params['goods_detail_slider_json'] = str_replace(getenv('STORAGE_DOMAIN'), '', $params['goods_detail_slider_json']);
  838. $params['goods_detail_slider_json'] = json_encode(['slider' => $params['goods_detail_slider_json']]);
  839. }
  840. try {
  841. $model = new GoodsDetail();
  842. $model->join_detail_goods_id = $params['goods_id'];
  843. $model->goods_detail_code_json = $params['goods_detail_code_json'] ?? '{}';
  844. $model->goods_detail_slider_json = $params['goods_detail_slider_json'] ?? '{}';
  845. $model->goods_detail_specs_json = $params['goods_detail_specs_json'] ?? '{}';
  846. $model->goods_detail_content = $params['goods_detail_content'] ?? '';
  847. if (!$model->save()) {
  848. // 异常
  849. throw new BusinessException("数据写入失败~");
  850. }
  851. } catch (\Exception $e) {
  852. dump($e->getMessage());
  853. throw new BusinessException("数据写入失败~");
  854. }
  855. }
  856. public static function componentUpdate($params, $type = 'insert')
  857. {
  858. Db::beginTransaction();
  859. try {
  860. // 有先删除
  861. if ($type == 'update') {
  862. GoodsComponent::where('join_component_master_goods_id', $params['goods_id'])->delete();
  863. } else {
  864. Goods::where('goods_id', $params['goods_id'])->update(['goods_sku_json' => '{"规格": ["标准"]}']);
  865. $skuData = [
  866. 'join_sku_goods_id' => $params['goods_id'],
  867. 'goods_sku_status' => 'ON',
  868. 'goods_sku_specs_json' => '{"规格": "标准"}',
  869. 'goods_sku_title' => "标准" . $params['goods_name'],
  870. 'goods_sku_market_price' => $params['goods_market_price'] ?? 0,
  871. 'goods_sku_sales_price' => $params['goods_sales_price'] ?? 0,
  872. ];
  873. GoodsSku::insert($skuData);
  874. }
  875. $data = [];
  876. foreach ($params['goods_content_list'] as $item) {
  877. $goods = Goods::where('goods_id', $params['goods_id'])->first();
  878. if (!$goods) {
  879. continue;
  880. }
  881. $data[] = [
  882. 'join_component_master_goods_id' => $params['goods_id'],
  883. 'join_component_goods_id' => $item['goods_id'] ?? '',
  884. 'goods_component_price' => $item['goods_sales_price'] ?? '',
  885. 'goods_component_cover' => $goods->goods_cover,
  886. 'goods_component_json' => json_encode(['goods_name' => $item['goods_name'], 'nbr' => $item['nbr'], 'sku_id' => $item['sku_id'] ?? '']),
  887. 'goods_component_addtimes' => time()
  888. ];
  889. }
  890. dump($data);
  891. if ($data) {
  892. GoodsComponent::insert($data);
  893. }
  894. Db::commit();
  895. } catch (\Exception $e) {
  896. Db::rollBack();
  897. dump($e->getMessage());
  898. throw new BusinessException("数据写入失败~");
  899. }
  900. }
  901. /**
  902. * @Desc 标签表
  903. * @Author Gorden
  904. * @Date 2024/3/11 11:32
  905. *
  906. * @param $params
  907. * @return void
  908. * @throws BusinessException
  909. */
  910. public static function labelInsert($params)
  911. {
  912. $model = new GoodsLabel();
  913. $model->join_label_goods_id = $params['goods_id'];
  914. $model->goods_label = $params['goods_label'] ? implode(',', $params['goods_label']) : '';
  915. $model->goods_label_extend_json = !empty($params['goods_label_extend_json']) ? $params['goods_label_extend_json'] : '{}';
  916. if (!$model->save()) {
  917. // 异常
  918. throw new BusinessException('数据写入失败~');
  919. }
  920. }
  921. /**
  922. * @Desc 产品运行控制信息表
  923. * @Author Gorden
  924. * @Date 2024/3/11 11:38
  925. *
  926. * @param $params
  927. * @return void
  928. * @throws BusinessException
  929. */
  930. public static function goodsRunningInsert($params)
  931. {
  932. try {
  933. $model = new GoodsRunning();
  934. $model->join_running_goods_id = $params['goods_id'];
  935. $model->goods_running_storage = $params['goods_running_storage'] ?? '';
  936. $model->goods_running_sale = $params['goods_running_sale'] ?? '';
  937. $model->goods_running_off_type = !empty($params['goods_running_off_type']) ? $params['goods_running_off_type'] : '';
  938. $model->goods_running_off_json = !empty($params['goods_running_off_type']) && $params['goods_running_off_type'] == 'T' && !empty($params['goods_off_addtimes']) ? json_encode(['time' => strtotime($params['goods_off_addtimes'])]) : '[]';
  939. if (!$model->save()) {
  940. throw new BusinessException('数据写入失败');
  941. }
  942. } catch (\Exception $e) {
  943. dump($e->getMessage());
  944. throw new BusinessException('数据写入失败');
  945. }
  946. }
  947. /**
  948. * @Desc SKU
  949. * @Author Gorden
  950. * @Date 2024/3/11 12:01
  951. *
  952. * @param $params
  953. * @return void
  954. * @throws BusinessException
  955. */
  956. public static function skuInsert($params)
  957. {
  958. $model = new GoodsSku();
  959. $model->join_sku_goods_id = $params['goods_id'];
  960. $model->goods_sku_status = $params['goods_sku_status'];
  961. $model->goods_sku_specs_json = $params['goods_sku_specs_json'];
  962. $model->goods_sku_title = $params['goods_sku_title'];
  963. $model->goods_sku_images_json = $params['goods_sku_images_json'];
  964. $model->goods_sku_content = $params['goods_sku_content'];
  965. $model->goods_sku_market_price = $params['goods_sku_market_price'];
  966. $model->goods_sku_sales_price = $params['goods_sku_sales_price'];
  967. $model->goods_sku_storage_json = $params['goods_sku_storage_json'];
  968. $model->goods_sku_service_json = $params['goods_sku_service_json'];
  969. $model->goods_sku_extend_json = $params['goods_sku_extend_json'];
  970. if (!$model->save()) {
  971. throw new BusinessException('数据写入失败~');
  972. }
  973. }
  974. /**
  975. * @Desc
  976. * @Author Gorden
  977. * @Date 2024/3/12 8:44
  978. *
  979. * @param $params
  980. * @return void
  981. * @throws BusinessException
  982. */
  983. public static function mainUpdate($params)
  984. {
  985. try {
  986. $data = self::inputFilter($params, new Goods());
  987. if (!empty($data['goods_cover'])) {
  988. $data['goods_cover'] = str_replace(getenv('STORAGE_DOMAIN'), '', $data['goods_cover']);
  989. }
  990. $data['goods_on_addtimes'] = strtotime($data['goods_on_addtimes']);
  991. $data['goods_sku_json'] = !empty($params['goods_sku_json_label']) ? json_encode($params['goods_sku_json_label']) : json_encode(['规格' => []]);
  992. $row = Goods::find($data['goods_id']);
  993. if ($row->join_goods_category_id != $data['join_goods_category_id']) {
  994. $category = SysCategory::where('category_id', $params['join_goods_category_id'])->first();
  995. if (!$category) {
  996. throw new BusinessException("产品分类不存在~");
  997. }
  998. $data['goods_category'] = $category->category_classify ?? '';
  999. $data['goods_prefix'] = $data['goods_prefix'] ?? ($category->category_name ? '【' . $category->category_name . '】' : '');
  1000. }
  1001. // 上架时间有变动
  1002. if ($data['goods_status'] == 'PENDING' && $row->goods_on_addtimes != $data['goods_on_addtimes']) {
  1003. $redis = Redis::connection();
  1004. // 删掉原来的
  1005. $oldKey = Goods::LISTING_KEY_PREFIX . date('YmdHi', $row->goods_on_addtimes);
  1006. $redis->srem($oldKey, $data['goods_id']);
  1007. // 加入新的
  1008. $newKey = Goods::LISTING_KEY_PREFIX . date('YmdHi', $data['goods_on_addtimes']);
  1009. $redis->sadd($newKey, $data['goods_id']);
  1010. }
  1011. if (!empty($params['is_support_appointment']) && $params['is_support_appointment'] == 'Y' && !empty($params['appointment_times'])) {
  1012. $times = [];
  1013. foreach ($params['appointment_times'] as $time) {
  1014. $times[$time['appointmentTimeStart']] = [
  1015. 'person' => $time['person'],
  1016. 'duration' => $time['appointmentTimeStart'] . '-' . $time['appointmentTimeEnd']
  1017. ];
  1018. }
  1019. $attributeJson = [
  1020. 'icon' => '',
  1021. 'dates' => $params['dates'] ?? [],
  1022. 'times' => $times
  1023. ];
  1024. if (!empty($params['appointment_label'])) {
  1025. $attributeJson['label'] = $params['appointment_label'];
  1026. }
  1027. if (!empty($params['address'])) {
  1028. $attributeJson['address'] = $params['address'];
  1029. $attributeJson['position'] = $params['position'];
  1030. }
  1031. $data['goods_attribute_json'] = json_encode($attributeJson);
  1032. }
  1033. if (!empty($data['goods_json']) && $data['join_goods_category_id'] == 65) {
  1034. $goodsJson = json_decode($data['goods_json'], true);
  1035. foreach ($goodsJson as $key => $item) {
  1036. $goodsJson[$key]['color'] = hexToRgb($item['color']);
  1037. }
  1038. $data['goods_json'] = json_encode($goodsJson);
  1039. } elseif (!empty($data['goods_json']) && $data['join_goods_category_id'] == 43) {
  1040. $goodsJson = json_decode($data['goods_json'], true);
  1041. $newGoodsJson = [];
  1042. foreach ($goodsJson as $item1) {
  1043. $newItem1 = [];
  1044. foreach ($item1['items'] as $item2) {
  1045. $newItem1['items'][$item2['key']] = $item2['params'];
  1046. }
  1047. $newItem1['service'] = $item1['service'];
  1048. $newGoodsJson[$item1['title']] = $newItem1;
  1049. }
  1050. $data['goods_json'] = json_encode($newGoodsJson);
  1051. } else {
  1052. $data['goods_json'] = '[]';
  1053. }
  1054. dump($data);
  1055. foreach ($data as $key => $val) {
  1056. $row->{$key} = $val;
  1057. }
  1058. $row->save();
  1059. } catch (BusinessException $e) {
  1060. throw new BusinessException($e->getMessage());
  1061. } catch (\Exception $e) {
  1062. dump($e->getMessage());
  1063. throw new BusinessException('数据更新异常~1');
  1064. }
  1065. }
  1066. /**
  1067. * @Desc
  1068. * @Author Gorden
  1069. * @Date 2024/3/12 9:57
  1070. *
  1071. * @param $params
  1072. * @return void
  1073. * @throws BusinessException
  1074. */
  1075. public static function detailUpdate($params)
  1076. {
  1077. try {
  1078. $data = self::inputFilter($params, new GoodsDetail());
  1079. if (!empty($data['goods_detail_slider_json'])) {
  1080. $data['goods_detail_slider_json'] = str_replace(getenv('STORAGE_DOMAIN'), '', $data['goods_detail_slider_json']);
  1081. $data['goods_detail_slider_json'] = json_encode(['slider' => $data['goods_detail_slider_json']]);
  1082. }
  1083. // 根据goods_id 查详情ID
  1084. $detail = GoodsDetail::where('join_detail_goods_id', $params['goods_id'])->first();
  1085. if ($detail) {
  1086. self::doUpdate($detail->join_detail_goods_id, $data, new GoodsDetail());
  1087. } else {
  1088. $data['join_detail_goods_id'] = $params['goods_id'];
  1089. GoodsDetail::insert($data);
  1090. }
  1091. } catch (BusinessException $e) {
  1092. throw new BusinessException($e->getMessage());
  1093. } catch (\Exception $e) {
  1094. dump($e->getMessage());
  1095. throw new BusinessException('数据更新异常~2');
  1096. }
  1097. }
  1098. /**
  1099. * @Desc
  1100. * @Author Gorden
  1101. * @Date 2024/3/12 9:58
  1102. *
  1103. * @param $params
  1104. * @return void
  1105. * @throws BusinessException
  1106. */
  1107. public static function labelUpdate($params)
  1108. {
  1109. try {
  1110. $data = self::inputFilter($params, new GoodsLabel());
  1111. dump($data);
  1112. // 根据goods_id 查详情ID
  1113. $detail = GoodsLabel::where('join_label_goods_id', $params['goods_id'])->first();
  1114. if ($detail) {
  1115. self::doUpdate($detail->goods_label_id, $data, new GoodsLabel());
  1116. }else{
  1117. $data['join_label_goods_id'] = $params['goods_id'];
  1118. GoodsLabel::insert($data);
  1119. }
  1120. } catch (BusinessException $e) {
  1121. throw new BusinessException($e->getMessage());
  1122. } catch (\Exception $e) {
  1123. dump($e->getMessage());
  1124. throw new BusinessException('数据更新异常~3');
  1125. }
  1126. }
  1127. /**
  1128. * @Desc
  1129. * @Author Gorden
  1130. * @Date 2024/3/12 9:59
  1131. *
  1132. * @param $params
  1133. * @return void
  1134. * @throws BusinessException
  1135. */
  1136. public static function goodsRunningUpdate($params)
  1137. {
  1138. try {
  1139. $data = self::inputFilter($params, new GoodsRunning());
  1140. // 根据goods_id 查详情ID
  1141. $detail = GoodsRunning::where('join_running_goods_id', $params['goods_id'])->first();
  1142. if (!empty($params['goods_running_off_type']) && $params['goods_running_off_type'] == 'T') {
  1143. $redis = Redis::connection();
  1144. if (!empty($detail->goods_running_off_json)) {
  1145. $goodsRunningOffJson = json_decode($detail->goods_running_off_json, true);
  1146. if (isset($goodsRunningOffJson['time'])) {
  1147. $oldKey = Goods::LISTING_OFF_KEY_PREFIX . date('YmdHi', $goodsRunningOffJson['time']);
  1148. $goodsRunningOffJson['time'] = strtotime($params['goods_off_addtimes']);
  1149. $data['goods_running_off_json'] = json_encode($goodsRunningOffJson);
  1150. // 有老的下架时间,删除老的
  1151. $redis->srem($oldKey, $params['goods_id']);
  1152. } else {
  1153. $goodsRunningOffJson['time'] = strtotime($params['goods_off_addtimes']);
  1154. $data['goods_running_off_json'] = json_encode($goodsRunningOffJson);
  1155. }
  1156. } else {
  1157. $data['goods_running_off_json'] = json_encode(['time' => strtotime($params['goods_off_addtimes'])]);
  1158. }
  1159. // 加入自动下架
  1160. $newKey = Goods::LISTING_OFF_KEY_PREFIX . date('YmdHi', strtotime($params['goods_off_addtimes']));
  1161. $redis->sAdd($newKey, $params['goods_id']);
  1162. } else if (!empty($params['goods_running_off_type']) && !empty($detail->goods_running_off_type) && $params['goods_running_off_type'] == 'H' && $detail->goods_running_off_type == 'T') {
  1163. $goodsRunningOffJson = json_decode($detail->goods_running_off_json, true);
  1164. if (isset($goodsRunningOffJson['time'])) {
  1165. $oldKey = Goods::LISTING_OFF_KEY_PREFIX . date('YmdHi', $goodsRunningOffJson['time']);
  1166. $redis = Redis::connection();
  1167. $redis->srem($oldKey, $params['goods_id']);
  1168. }
  1169. }
  1170. if ($detail) {
  1171. self::doUpdate($detail->join_running_goods_id, $data, new GoodsRunning());
  1172. } else {
  1173. // 兼容老数据……
  1174. $data['join_running_goods_id'] = $params['goods_id'];
  1175. GoodsRunning::insert($data);
  1176. }
  1177. } catch (BusinessException $e) {
  1178. throw new BusinessException($e->getMessage());
  1179. } catch (\Exception $e) {
  1180. dump($e->getMessage());
  1181. throw new BusinessException('数据更新异常~4');
  1182. }
  1183. }
  1184. /**
  1185. * @Desc sku 设置
  1186. * @Author Gorden
  1187. * @Date 2024/4/10 10:43
  1188. *
  1189. * @param $params
  1190. * @return void
  1191. * @throws BusinessException
  1192. */
  1193. public static function goodsSkuSet($params, $operation = 'insert')
  1194. {
  1195. try {
  1196. Db::beginTransaction();
  1197. $skusOldIds = [];
  1198. if ($operation == 'update') {
  1199. // 查出所有的
  1200. $skusOldIds = GoodsSku::where('join_sku_goods_id', $params['goods_id'])->pluck('goods_sku_id', 'goods_sku_id');
  1201. // 删掉原有的
  1202. // GoodsSku::where('join_sku_goods_id', $params['goods_id'])->delete();
  1203. }
  1204. if (empty($skusOldIds) && empty($params['goods_sku_json_value'])){
  1205. $skuData = [
  1206. 'join_sku_goods_id' => $params['goods_id'],
  1207. 'goods_sku_status' => 'ON',
  1208. 'goods_sku_specs_json' => '{"规格": "标准"}',
  1209. 'goods_sku_title' => "标准" . $params['goods_name'],
  1210. 'goods_sku_market_price' => $params['goods_market_price'] ?? 0,
  1211. 'goods_sku_sales_price' => $params['goods_sales_price'] ?? 0,
  1212. ];
  1213. GoodsSku::insert($skuData);
  1214. }
  1215. // 入新的
  1216. if (!empty($params['goods_sku_json_value'])) {
  1217. foreach ($params['goods_sku_json_value'] as $item) {
  1218. $skus = explode(',', $item['sku']);
  1219. $skuArr = [];
  1220. for ($i = 1; $i <= count($skus); $i++) {
  1221. $skuName = "skuName" . $i;
  1222. $key = $item[$skuName];
  1223. $skuArr[$key] = $skus[$i - 1];
  1224. }
  1225. $specsJson = json_encode($skuArr);
  1226. $skuTitle = str_replace('-', ',', $item['sku']) . $params['goods_name'];
  1227. if ($operation == 'update' && !empty($item['sku_id'])) {
  1228. $model = GoodsSku::where('goods_sku_id', $item['sku_id'])->first();
  1229. if (!$model) {
  1230. $model = new GoodsSku();
  1231. } else {
  1232. unset($skusOldIds[$model->goods_sku_id]);
  1233. }
  1234. } else {
  1235. $model = GoodsSku::where('join_sku_goods_id', $params['goods_id'])->where('goods_sku_title', $skuTitle)->first();
  1236. if (!$model) {
  1237. $model = new GoodsSku();
  1238. } else {
  1239. dump($model->goods_sku_id);
  1240. unset($skusOldIds[$model->goods_sku_id]);
  1241. }
  1242. }
  1243. $model->join_sku_goods_id = $params['goods_id'];
  1244. $model->goods_sku_status = $params['goods_status'];
  1245. $model->goods_sku_specs_json = $specsJson;
  1246. $model->goods_sku_title = $skuTitle;
  1247. $model->goods_sku_market_price = $params['goods_market_price'] ?? 0;
  1248. $model->goods_sku_sales_price = $item['price'];
  1249. $model->goods_sku_storage_json = json_encode(['storage' => $item['stock']]);
  1250. $model->save();
  1251. }
  1252. }
  1253. if ($operation == 'update' && !empty($skusOldIds)) {
  1254. GoodsSku::whereIn('goods_sku_id', $skusOldIds)->delete();
  1255. }
  1256. Db::commit();
  1257. } catch (\Exception $e) {
  1258. dump($e->getTrace());
  1259. Db::rollBack();
  1260. throw new BusinessException('数据更新异常~5');
  1261. }
  1262. }
  1263. /**
  1264. * @Desc
  1265. * @Author Gorden
  1266. * @Date 2024/3/12 8:45
  1267. *
  1268. * @param array $data
  1269. * @param $model
  1270. * @return array
  1271. * @throws BusinessException
  1272. */
  1273. private static function inputFilter(array $data, $model): array
  1274. {
  1275. $table = config('database.connections.mysql.prefix') . $model->getTable();
  1276. $allow_column = $model->getConnection()->select("desc `$table`");
  1277. if (!$allow_column) {
  1278. throw new BusinessException('表不存在', 2);
  1279. }
  1280. $columns = array_column($allow_column, 'Type', 'Field');
  1281. foreach ($data as $col => $item) {
  1282. if (!isset($columns[$col])) {
  1283. unset($data[$col]);
  1284. continue;
  1285. }
  1286. // 非字符串类型传空则为null
  1287. if ($item === '' && strpos(strtolower($columns[$col]), 'varchar') === false && strpos(strtolower($columns[$col]), 'text') === false) {
  1288. $data[$col] = null;
  1289. }
  1290. if (is_array($item)) {
  1291. $data[$col] = implode(',', $item);
  1292. }
  1293. if ($item != '' && (strpos(strtolower($columns[$col]), 'varchar') || strpos(strtolower($columns[$col]), 'text'))) {
  1294. $data[$col] = htmlspecialchars($item);
  1295. }
  1296. }
  1297. if (empty($data['created_at'])) {
  1298. unset($data['created_at']);
  1299. }
  1300. if (empty($data['updated_at'])) {
  1301. unset($data['updated_at']);
  1302. }
  1303. return $data;
  1304. }
  1305. /**
  1306. * @Desc 执行更新
  1307. * @Author Gorden
  1308. * @Date 2024/3/12 8:43
  1309. *
  1310. * @param $id
  1311. * @param $data
  1312. * @param $model
  1313. * @return void
  1314. */
  1315. private static function doUpdate($id, $data, $model)
  1316. {
  1317. $row = $model->find($id);
  1318. foreach ($data as $key => $val) {
  1319. $row->{$key} = $val;
  1320. }
  1321. $row->save();
  1322. }
  1323. /**
  1324. * @Desc 上架定时
  1325. * @Author Gorden
  1326. * @Date 2024/4/11 15:13
  1327. *
  1328. * @return void
  1329. */
  1330. public static function checkListing()
  1331. {
  1332. $key = Goods::LISTING_KEY_PREFIX . date('YmdHi');
  1333. $redis = Redis::connection();
  1334. if (!$redis->exists($key)) {
  1335. return;
  1336. }
  1337. $goodsIds = $redis->sMembers($key);
  1338. if (Goods::whereIn('goods_id', $goodsIds)->update(['goods_status' => 'ON'])) {
  1339. $redis->del($key);
  1340. }
  1341. }
  1342. /**
  1343. * @Desc 自动下架
  1344. * @Author Gorden
  1345. * @Date 2024/4/26 15:26
  1346. *
  1347. * @return void
  1348. */
  1349. public static function checkOffListing()
  1350. {
  1351. $key = Goods::LISTING_OFF_KEY_PREFIX . date('YmdHi');
  1352. $redis = Redis::connection();
  1353. if (!$redis->exists($key)) {
  1354. return;
  1355. }
  1356. $goodsIds = $redis->sMembers($key);
  1357. if (Goods::whereIn('goods_id', $goodsIds)->update(['goods_status' => 'OFF'])) {
  1358. $redis->del($key);
  1359. }
  1360. }
  1361. }