StoreProductController.php 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378
  1. <?php
  2. namespace app\api\controller\store;
  3. use app\admin\model\store\StoreDescription;
  4. use app\admin\model\system\SystemAttachment;
  5. use app\admin\model\system\SystemDealerLevel;
  6. use app\admin\model\user\UserDealer;
  7. use app\models\routine\RoutineCode;
  8. use app\models\store\StoreOrder;
  9. use app\models\store\StoreVisit;
  10. use app\models\system\SystemStore;
  11. use app\models\store\StoreProduct;
  12. use app\models\store\StoreProductAttr;
  13. use app\models\store\StoreProductRelation;
  14. use app\models\store\StoreProductReply;
  15. use app\models\user\User;
  16. use app\Request;
  17. use crmeb\services\GroupDataService;
  18. use crmeb\services\QrcodeService;
  19. use crmeb\services\SystemConfigService;
  20. use crmeb\services\UploadService;
  21. use crmeb\services\UtilService;
  22. use crmeb\services\upload\Upload;
  23. use Overtrue\Pinyin\Pinyin;
  24. use think\exception\DbException;
  25. /**
  26. * 商品类
  27. * Class StoreProductController
  28. * @package app\api\controller\store
  29. */
  30. class StoreProductController
  31. {
  32. /**
  33. * 商品列表
  34. * @param Request $request
  35. * @return mixed
  36. */
  37. public function lst(Request $request)
  38. {
  39. $data = UtilService::getMore([
  40. ['sid', 0],
  41. ['cid', 0],
  42. ['keyword', ''],
  43. ['priceOrder', ''],
  44. ['salesOrder', ''],
  45. ['news', 0],
  46. ['page', 0],
  47. ['limit', 0],
  48. ['type', 0],
  49. ['is_wholesale',0],
  50. ['mer_id',0]
  51. ], $request);
  52. return app('json')->successful(StoreProduct::getProductList($data, $request->uid()));
  53. }
  54. /**
  55. * 产品分享二维码 推广员
  56. * @param Request $request
  57. * @param $id
  58. * @return mixed
  59. */
  60. public function code(Request $request, $id)
  61. {
  62. if (!$id || !($storeInfo = StoreProduct::getValidProduct($id, 'id'))) return app('json')->fail('商品不存在或已下架');
  63. $userType = $request->get('user_type', 'wechat');
  64. $user = $request->user();
  65. try {
  66. switch ($userType) {
  67. case 'wechat':
  68. //公众号
  69. $name = $id . '_product_detail_' . $user['uid'] . '_is_promoter_' . $user['is_promoter'] . '_wap.jpg';
  70. $url = QrcodeService::getWechatQrcodePath($name, '/detail/' . $id . '?spread=' . $user['uid']);
  71. if ($url === false)
  72. return app('json')->fail('二维码生成失败');
  73. else
  74. return app('json')->successful(['code' => image_to_base64($url)]);
  75. break;
  76. case 'routine':
  77. //小程序
  78. $name = $id . '_' . $user['uid'] . '_' . $user['is_promoter'] . '_product.jpg';
  79. $imageInfo = SystemAttachment::getInfo($name, 'name');
  80. $siteUrl = sys_config('site_url');
  81. if (!$imageInfo) {
  82. $data = 'id=' . $id;
  83. if ($user['is_promoter'] || sys_config('store_brokerage_statu') == 2) $data .= '&pid=' . $user['uid'];
  84. $res = \app\models\routine\RoutineCode::getPageCode('pages/product/product', $data, 280);
  85. if (!$res) return app('json')->fail('二维码生成失败');
  86. $uploadType = (int)sys_config('upload_type', 1);
  87. $upload = new Upload($uploadType, [
  88. 'accessKey' => sys_config('accessKey'),
  89. 'secretKey' => sys_config('secretKey'),
  90. 'uploadUrl' => sys_config('uploadUrl'),
  91. 'storageName' => sys_config('storage_name'),
  92. 'storageRegion' => sys_config('storage_region'),
  93. ]);
  94. $res = $upload->to('routine/product')->validate()->stream($res, $name);
  95. if ($res === false) {
  96. return app('json')->fail($upload->getError());
  97. }
  98. $imageInfo = $upload->getUploadInfo();
  99. $imageInfo['image_type'] = $uploadType;
  100. if ($imageInfo['image_type'] == 1) $remoteImage = UtilService::remoteImage($siteUrl . $imageInfo['dir']);
  101. else $remoteImage = UtilService::remoteImage($imageInfo['dir']);
  102. if (!$remoteImage['status']) return app('json')->fail('小程序二维码未能生成');
  103. SystemAttachment::attachmentAdd($imageInfo['name'], $imageInfo['size'], $imageInfo['type'], $imageInfo['dir'], $imageInfo['thumb_path'], 1, $imageInfo['image_type'], $imageInfo['time'], 2);
  104. $url = $imageInfo['dir'];
  105. } else $url = $imageInfo['att_dir'];
  106. if ($imageInfo['image_type'] == 1) $url = $siteUrl . $url;
  107. return app('json')->successful(['code' => $url]);
  108. }
  109. } catch (\Exception $e) {
  110. return app('json')->fail($e->getMessage(), [
  111. 'code' => $e->getCode(),
  112. 'line' => $e->getLine(),
  113. 'message' => $e->getMessage()
  114. ]);
  115. }
  116. }
  117. /**
  118. * 产品详情
  119. * @param Request $request
  120. * @param $id
  121. * @param int $type
  122. * @return mixed
  123. */
  124. public function detail(Request $request, $id, $type = 0)
  125. {
  126. if (!$id || !($storeInfo = StoreProduct::getValidProduct($id))) return app('json')->fail('商品不存在或已下架');
  127. $siteUrl = sys_config('site_url');
  128. $storeInfo['image'] = set_file_url($storeInfo['image'], $siteUrl);
  129. $storeInfo['image_base'] = set_file_url($storeInfo['image'], $siteUrl);
  130. $storeInfo['code_base'] = QrcodeService::getWechatQrcodePath($id . '_product_detail_wap.jpg', '/detail/' . $id);
  131. $uid = $request->uid();
  132. $data['uid'] = $uid;
  133. $storeInfo['description'] = htmlspecialchars_decode(StoreDescription::getDescription($id));
  134. //替换windows服务器下正反斜杠问题导致图片无法显示
  135. $storeInfo['description'] = preg_replace_callback('#<img.*?src="([^"]*)"[^>]*>#i', function ($imagsSrc) {
  136. return isset($imagsSrc[1]) && isset($imagsSrc[0]) ? str_replace($imagsSrc[1], str_replace('\\', '/', $imagsSrc[1]), $imagsSrc[0]) : '';
  137. }, $storeInfo['description']);
  138. $storeInfo['userCollect'] = StoreProductRelation::isProductRelation($id, $uid, 'collect');
  139. $storeInfo['userLike'] = StoreProductRelation::isProductRelation($id, $uid, 'like');
  140. list($productAttr, $productValue) = StoreProductAttr::getProductAttrDetail($id, $uid, $type);
  141. // 过滤特供规格:非经销商用户不可见 dealer_visible_grade > 0 的SKU
  142. $canSeeSpecial = false;
  143. if ($uid) {
  144. $dealerGrade = User::where('uid', $uid)->value('dealer');
  145. if ($dealerGrade > 0) {
  146. $levelId = UserDealer::where('uid', $uid)->where('is_del', 0)
  147. ->order('grade desc')->value('level_id');
  148. if ($levelId) {
  149. $canSeeSpecial = SystemDealerLevel::where('id', $levelId)->value('can_see_special') > 0;
  150. }
  151. }
  152. }
  153. if (!$canSeeSpecial) {
  154. foreach ($productValue as $suk => $value) {
  155. if (($value['dealer_visible_grade'] ?? 0) > 0) {
  156. unset($productValue[$suk]);
  157. }
  158. }
  159. }
  160. StoreVisit::setView($uid, $id, $storeInfo['cate_id'], 'viwe');
  161. $data['storeInfo'] = StoreProduct::setLevelPrice($storeInfo, $uid, true);
  162. $data['similarity'] = StoreProduct::cateIdBySimilarityProduct($storeInfo['cate_id'], 'id,store_name,image,price,sales,ficti', 4);
  163. $data['productAttr'] = $productAttr;
  164. $data['productValue'] = $productValue;
  165. $data['priceName'] = 0;
  166. if ($uid) {
  167. $user = $request->user();
  168. if (!$user->is_promoter) {
  169. $price = StoreOrder::where(['paid' => 1, 'refund_status' => 0, 'uid' => $uid])->sum('pay_price');
  170. $status = is_brokerage_statu($price);
  171. if ($status) {
  172. User::where('uid', $uid)->update(['is_promoter' => 1]);
  173. $user->is_promoter = 1;
  174. }
  175. }
  176. if ($user->is_promoter) {
  177. $data['priceName'] = StoreProduct::getPacketPrice($storeInfo, $productValue);
  178. }
  179. if (!strlen(trim($data['priceName'])))
  180. $data['priceName'] = 0;
  181. }
  182. $data['reply'] = StoreProductReply::getRecProductReply($storeInfo['id']);
  183. $data['replyCount'] = StoreProductReply::productValidWhere()->where('product_id', $storeInfo['id'])->count();
  184. if ($data['replyCount']) {
  185. $goodReply = StoreProductReply::productValidWhere()->where('product_id', $storeInfo['id'])->where('product_score', 5)->count();
  186. $data['replyChance'] = $goodReply;
  187. if ($goodReply) {
  188. $data['replyChance'] = bcdiv($goodReply, $data['replyCount'], 2);
  189. $data['replyChance'] = bcmul($data['replyChance'], 100, 2);
  190. }
  191. } else $data['replyChance'] = 0;
  192. $data['mer_id'] = $storeInfo['mer_id'];
  193. $data['system_store'] = ($res = SystemStore::getStoreDispose($data['mer_id'])) ? $res : [];
  194. $data['good_list'] = StoreProduct::getGoodList(18, 'image,store_name,price,id,ot_price');
  195. $data['mapKey'] = sys_config('tengxun_map_key');
  196. $data['store_self_mention'] = (int)sys_config('store_self_mention') ?? 0;//门店自提是否开启
  197. $data['activity'] = StoreProduct::activity($data['storeInfo']['id'], false);
  198. return app('json')->successful($data);
  199. }
  200. /**
  201. * 为你推荐
  202. *
  203. * @param Request $request
  204. * @return mixed
  205. * @throws \think\db\exception\DataNotFoundException
  206. * @throws \think\db\exception\ModelNotFoundException
  207. * @throws DbException
  208. */
  209. public function product_hot(Request $request)
  210. {
  211. list($page, $limit) = UtilService::getMore([
  212. ['page', 0],
  213. ['limit', 0]
  214. ], $request, true);
  215. if (!$limit) return app('json')->successful([]);
  216. $productHot = StoreProduct::getHotProductLoading('id,image,store_name,cate_id,price,unit_name,ot_price', (int)$page, (int)$limit);
  217. if (!empty($productHot)) {
  218. foreach ($productHot as $k => $v) {
  219. $productHot[$k]['activity'] = StoreProduct::activity($v['id']);
  220. }
  221. }
  222. return app('json')->successful($productHot);
  223. }
  224. /**
  225. * 获取首页推荐不同类型产品的轮播图和产品
  226. * @param Request $request
  227. * @param $type
  228. * @return mixed
  229. * @throws \think\db\exception\DataNotFoundException
  230. * @throws \think\db\exception\ModelNotFoundException
  231. * @throws DbException
  232. */
  233. public function groom_list(Request $request, $type)
  234. {
  235. $info['banner'] = [];
  236. $info['list'] = [];
  237. if ($type == 1) {//TODO 精品推荐
  238. $info['banner'] = sys_data('routine_home_bast_banner') ?: [];//TODO 首页精品推荐图片
  239. $info['list'] = StoreProduct::getBestProduct('id,image,store_name,cate_id,price,ot_price,IFNULL(sales,0) + IFNULL(ficti,0) as sales,unit_name,sort');//TODO 精品推荐个数
  240. } else if ($type == 2) {//TODO 热门榜单
  241. $info['banner'] = sys_data('routine_home_hot_banner') ?: [];//TODO 热门榜单 猜你喜欢推荐图片
  242. $info['list'] = StoreProduct::getHotProduct('id,image,store_name,cate_id,price,ot_price,unit_name,sort,IFNULL(sales,0) + IFNULL(ficti,0) as sales', 0, $request->uid());//TODO 热门榜单 猜你喜欢
  243. } else if ($type == 3) {//TODO 首发新品
  244. $info['banner'] = sys_data('routine_home_new_banner') ?: [];//TODO 首发新品推荐图片
  245. $info['list'] = StoreProduct::getNewProduct('id,image,store_name,cate_id,price,ot_price,unit_name,sort,IFNULL(sales,0) + IFNULL(ficti,0) as sales', 0, $request->uid());//TODO 首发新品
  246. } else if ($type == 4) {//TODO 促销单品
  247. $info['banner'] = sys_data('routine_home_benefit_banner') ?: [];//TODO 促销单品推荐图片
  248. $info['list'] = StoreProduct::getBenefitProduct('id,image,store_name,cate_id,price,ot_price,stock,unit_name,sort');//TODO 促销单品
  249. } else if ($type == 5) {//TODO 促销单品
  250. $info['banner'] = sys_data('routine_home_benefit_banner') ?: [];//TODO 促销单品推荐图片
  251. $info['list'] = StoreProduct::getIntegralProduct('max_integral,min_integral,id,image,store_name,cate_id,price,ot_price,stock,unit_name,sort');//TODO 促销单品
  252. }
  253. return app('json')->successful($info);
  254. }
  255. /**
  256. * 产品评价数量和好评度
  257. * @param $id
  258. * @return mixed
  259. */
  260. public function reply_config($id)
  261. {
  262. if (!$id || !is_numeric($id)) return app('json')->fail('参数错误!');
  263. return app('json')->successful(StoreProductReply::productReplyCount($id));
  264. }
  265. /**
  266. * 获取产品评论
  267. * @param Request $request
  268. * @param $id
  269. * @param $type
  270. * @return mixed
  271. */
  272. public function reply_list(Request $request, $id)
  273. {
  274. list($page, $limit, $type) = UtilService::getMore([
  275. ['page', 0], ['limit', 0], ['type', 0]
  276. ], $request, true);
  277. if (!$id || !is_numeric($id)) return app('json')->fail('参数错误!');
  278. $list = StoreProductReply::getProductReplyList($id, (int)$type, $page, $limit);
  279. return app('json')->successful($list);
  280. }
  281. /**
  282. * 砍价海报
  283. * @param Request $request
  284. * @return mixed
  285. */
  286. public function poster(Request $request)
  287. {
  288. list($bargainId, $from) = UtilService::postMore([['productId', 0], ['from', 'wechat']], $request, true);
  289. if (!$bargainId) return app('json')->fail('参数错误');
  290. $user = $request->user();
  291. // var_dump($user);
  292. $storeBargainInfo = StoreProduct::getValidProduct($bargainId);
  293. $price = $storeBargainInfo['price'];//TODO 获取砍价剩余金额
  294. try {
  295. $siteUrl = sys_config('site_url');
  296. $data['title'] = $storeBargainInfo['store_name'];
  297. $data['image'] = $storeBargainInfo['image'];
  298. $data['price'] = $price;
  299. $data['user_nickname'] = $user['nickname'];
  300. $data['user_avatar'] = $user['avatar'];
  301. $pinyin = new Pinyin();
  302. $data['user_nickname_pinyin'] = $pinyin->convert($user['nickname']);
  303. $data['ot_price'] = $storeBargainInfo['ot_price'];
  304. if ($from == 'routine') {
  305. //小程序
  306. $name = $bargainId . '_' . $user['uid'] . '_' . $user['is_promoter'] . '_product_share_routine.jpg';
  307. $imageInfo = SystemAttachment::getInfo($name, 'name');
  308. if (!$imageInfo) {
  309. $valueData = 'id=' . $bargainId;
  310. if ($user['is_promoter'] || sys_config('store_brokerage_statu') == 2) $valueData .= '&pid=' . $user['uid'];
  311. $res = RoutineCode::getPageCode('pages/product/product', $valueData, 280);
  312. if (!$res) return app('json')->fail('二维码生成失败');
  313. $uploadType = (int)sys_config('upload_type', 1);
  314. $upload = new Upload($uploadType, [
  315. 'accessKey' => sys_config('accessKey'),
  316. 'secretKey' => sys_config('secretKey'),
  317. 'uploadUrl' => sys_config('uploadUrl'),
  318. 'storageName' => sys_config('storage_name'),
  319. 'storageRegion' => sys_config('storage_region'),
  320. ]);
  321. $res = $upload->to('routine/product/code')->validate()->stream($res, $name);
  322. if ($res === false) {
  323. return app('json')->fail($upload->getError());
  324. }
  325. $imageInfo = $upload->getUploadInfo();
  326. $imageInfo['image_type'] = $uploadType;
  327. if ($imageInfo['image_type'] == 1) $remoteImage = UtilService::remoteImage($siteUrl . $imageInfo['dir']);
  328. else $remoteImage = UtilService::remoteImage($imageInfo['dir']);
  329. if (!$remoteImage['status']) return app('json')->fail($remoteImage['msg']);
  330. SystemAttachment::attachmentAdd($imageInfo['name'], $imageInfo['size'], $imageInfo['type'], $imageInfo['dir'], $imageInfo['thumb_path'], 1, $imageInfo['image_type'], $imageInfo['time'], 2);
  331. $url = $imageInfo['dir'];
  332. } else $url = $imageInfo['att_dir'];
  333. $data['url'] = $url;
  334. if ($imageInfo['image_type'] == 1)
  335. $data['url'] = $siteUrl . $url;
  336. $posterImage = UtilService::setShareProductPoster($data, 'routine/product/poster');
  337. if (!is_array($posterImage)) return app('json')->fail('海报生成失败');
  338. SystemAttachment::attachmentAdd($posterImage['name'], $posterImage['size'], $posterImage['type'], $posterImage['dir'], $posterImage['thumb_path'], 1, $posterImage['image_type'], $posterImage['time'], 2);
  339. if ($posterImage['image_type'] == 1) $posterImage['dir'] = $siteUrl . $posterImage['dir'];
  340. $routinePosterImage = UtilService::setHttpType($posterImage['dir'], 0);//小程序推广海报
  341. return app('json')->successful(['url' => $routinePosterImage]);
  342. } else if ($from == 'wechat') {
  343. //公众号
  344. $name = $bargainId . '_' . $user['uid'] . '_' . $user['is_promoter'] . '_product_share_wap.jpg';
  345. $imageInfo = SystemAttachment::getInfo($name, 'name');
  346. if (!$imageInfo) {
  347. $codeUrl = UtilService::setHttpType($siteUrl . '/index/pages/product/product?id=' . $bargainId . '&spread=' . $user['uid'], 0);//二维码链接
  348. $imageInfo = UtilService::getQRCodePath($codeUrl, $name);
  349. if (!$imageInfo) return app('json')->fail('二维码生成失败');
  350. SystemAttachment::attachmentAdd($imageInfo['name'], $imageInfo['size'], $imageInfo['type'], $imageInfo['dir'], $imageInfo['thumb_path'], 1, $imageInfo['image_type'], $imageInfo['time'], 2);
  351. $url = $imageInfo['dir'];
  352. } else $url = $imageInfo['att_dir'];
  353. $data['url'] = $url;
  354. if ($imageInfo['image_type'] == 1) $data['url'] = $siteUrl . $url;
  355. $posterImage = UtilService::setShareProductPoster($data, 'wap/product/poster');
  356. if (!is_array($posterImage)) return app('json')->fail('海报生成失败');
  357. SystemAttachment::attachmentAdd($posterImage['name'], $posterImage['size'], $posterImage['type'], $posterImage['dir'], $posterImage['thumb_path'], 1, $posterImage['image_type'], $posterImage['time'], 2);
  358. if ($posterImage['image_type'] == 1) $posterImage['dir'] = $siteUrl . $posterImage['dir'];
  359. $wapPosterImage = UtilService::setHttpType($posterImage['dir'], 1);//公众号推广海报
  360. return app('json')->successful(['url' => $wapPosterImage]);
  361. }
  362. return app('json')->fail('参数错误');
  363. } catch (\Exception $e) {
  364. return app('json')->fail(['line' => $e->getLine(), 'message' => $e->getMessage()]);
  365. }
  366. }
  367. }