PublicController.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365
  1. <?php
  2. namespace app\api\controller;
  3. use app\admin\model\system\SystemAttachment;
  4. use app\models\store\StoreCategory;
  5. use app\models\store\StoreCouponIssue;
  6. use app\models\store\StoreOrder;
  7. use app\models\store\StoreProduct;
  8. use app\models\store\StoreService;
  9. use app\models\system\Express;
  10. use app\models\system\SystemCity;
  11. use app\models\system\SystemStore;
  12. use app\models\system\SystemStoreStaff;
  13. use app\models\user\UserBill;
  14. use app\models\user\WechatUser;
  15. use app\Request;
  16. use crmeb\services\CacheService;
  17. use crmeb\services\UtilService;
  18. use crmeb\services\workerman\ChannelService;
  19. use think\db\exception\DataNotFoundException;
  20. use think\db\exception\DbException;
  21. use think\db\exception\ModelNotFoundException;
  22. use think\facade\Cache;
  23. use crmeb\services\upload\Upload;
  24. /**
  25. * 公共类
  26. * Class PublicController
  27. * @package app\api\controller
  28. */
  29. class PublicController
  30. {
  31. public function test(Request $request)
  32. {
  33. if (StoreOrder::set_parent($request->get('uid', 0))) {
  34. } else {
  35. var_dump(StoreOrder::getErrorInfo());
  36. }
  37. }
  38. /**
  39. * @param Request $request
  40. * @return mixed
  41. * @throws DataNotFoundException
  42. * @throws ModelNotFoundException
  43. * @throws \think\exception\DbException
  44. */
  45. public function index(Request $request)
  46. {
  47. $banner = sys_data('routine_home_banner') ?: [];//TODO 首页banner图
  48. $menus = sys_data('routine_home_menus') ?: [];//TODO 首页按钮
  49. $roll = sys_data('routine_home_roll_news') ?: [];//TODO 首页滚动新闻
  50. $activity = sys_data('routine_home_activity', 3) ?: [];//TODO 首页活动区域图片
  51. $site_name = sys_config('site_name');
  52. $routine_index_page = sys_data('routine_index_page');
  53. $info['fastInfo'] = $routine_index_page[0]['fast_info'] ?? '';//sys_config('fast_info');//TODO 快速选择简介
  54. $info['bastInfo'] = $routine_index_page[0]['bast_info'] ?? '';//sys_config('bast_info');//TODO 会员商品简介
  55. $info['firstInfo'] = $routine_index_page[0]['first_info'] ?? '';//sys_config('first_info');//TODO 首发新品简介
  56. $info['salesInfo'] = $routine_index_page[0]['sales_info'] ?? '';//sys_config('sales_info');//TODO 促销单品简介
  57. $logoUrl = sys_config('routine_index_logo');//TODO 促销单品简介
  58. if (strstr($logoUrl, 'http') === false && $logoUrl) $logoUrl = sys_config('site_url') . $logoUrl;
  59. $logoUrl = str_replace('\\', '/', $logoUrl);
  60. $fastNumber = sys_config('fast_number', 0);//TODO 快速选择分类个数
  61. $bastNumber = sys_config('bast_number', 0);//TODO 会员商品个数
  62. $firstNumber = sys_config('first_number', 0);//TODO 首发新品个数
  63. $promotionNumber = sys_config('promotion_number', 0);//TODO 首发新品个数
  64. $info['fastList'] = StoreCategory::byIndexList((int)$fastNumber, false);//TODO 快速选择分类个数
  65. $info['bastList'] = StoreProduct::getBestProduct('id,image,store_name,cate_id,price,ot_price,IFNULL(sales,0) + IFNULL(ficti,0) as sales,unit_name', (int)$bastNumber, $request->uid(), false);//TODO 会员商品个数
  66. //$info['firstList'] = StoreProduct::getNewProduct('id,image,store_name,cate_id,price,unit_name,IFNULL(sales,0) + IFNULL(ficti,0) as sales', (int)$firstNumber, $request->uid(), false);//TODO 首发新品个数
  67. $info['firstList'] = storeproduct::getnewproduct('id,image,store_name,cate_id,price,unit_name,IFNULL(sales,0) + IFNULL(ficti,0) as sales', 1000, $request->uid(), false);
  68. $info['bastBanner'] = sys_data('routine_home_bast_banner') ?? [];//TODO 首页精品推荐图片
  69. $benefit = StoreProduct::getBenefitProduct('id,image,store_name,cate_id,price,ot_price,stock,unit_name', $promotionNumber);//TODO 首页促销单品
  70. $lovely = sys_data('routine_home_new_banner') ?: [];//TODO 首发新品顶部图
  71. $likeInfo = StoreProduct::getHotProduct('id,image,store_name,cate_id,price,ot_price,unit_name', 3);//TODO 热门榜单 猜你喜欢
  72. $couponList = StoreCouponIssue::getIssueCouponList($request->uid(), 3);
  73. if ($request->uid()) {
  74. $subscribe = WechatUser::where('uid', $request->uid())->value('subscribe') ? true : false;
  75. } else {
  76. $subscribe = true;
  77. }
  78. $newGoodsBananr = sys_config('new_goods_bananr');
  79. $tengxun_map_key = sys_config('tengxun_map_key');
  80. return app('json')->successful(compact('banner', 'menus', 'roll', 'info', 'activity', 'lovely', 'benefit', 'likeInfo', 'logoUrl', 'couponList', 'site_name', 'subscribe', 'newGoodsBananr', 'tengxun_map_key'));
  81. }
  82. /**
  83. * @param Request $request
  84. * @return mixed
  85. * @throws DataNotFoundException
  86. * @throws DbException
  87. * @throws ModelNotFoundException
  88. */
  89. public function cityArea(Request $request)
  90. {
  91. $province = SystemCity::where('level', 0)->where('parent_id', 0)->field('name,city_id')->select()->each(function ($item) {
  92. $item['city'] = SystemCity::where('level', 1)
  93. ->where('parent_id', $item['city_id'])
  94. ->field('name,city_id')
  95. ->select()->each(function ($sub_item) {
  96. $sub_item['area'] = SystemCity::where('level', 2)
  97. ->where('parent_id', $sub_item['city_id'])
  98. ->column('name');
  99. unset($sub_item['city_id']);
  100. })->toArray();
  101. unset($item['city_id']);
  102. });
  103. return app('json')->success('ok', $province->toArray());
  104. }
  105. /**
  106. * 获取分享配置
  107. * @return mixed
  108. */
  109. public function share()
  110. {
  111. $data['img'] = sys_config('wechat_share_img');
  112. if (strstr($data['img'], 'http') === false) $data['img'] = sys_config('site_url') . $data['img'];
  113. $data['img'] = str_replace('\\', '/', $data['img']);
  114. $data['title'] = sys_config('wechat_share_title');
  115. $data['synopsis'] = sys_config('wechat_share_synopsis');
  116. return app('json')->successful(compact('data'));
  117. }
  118. /**
  119. * 获取个人中心菜单
  120. * @param Request $request
  121. * @return mixed
  122. * @throws DataNotFoundException
  123. * @throws ModelNotFoundException
  124. * @throws \think\exception\DbException
  125. */
  126. public function menu_user(Request $request)
  127. {
  128. $menusInfo = sys_data('routine_my_menus') ?? [];
  129. $user = $request->user();
  130. $vipOpen = sys_config('vip_open');
  131. $vipOpen = is_string($vipOpen) ? (int)$vipOpen : $vipOpen;
  132. foreach ($menusInfo as $key => &$value) {
  133. $value['pic'] = set_file_url($value['pic']);
  134. if ($value['id'] == 137 && !(intval(sys_config('store_brokerage_statu')) == 2 || $user->is_promoter == 1))
  135. unset($menusInfo[$key]);
  136. if ($value['id'] == 174 && !StoreService::orderServiceStatus($user->uid))
  137. unset($menusInfo[$key]);
  138. if (((!StoreService::orderServiceStatus($user->uid)) && (!SystemStoreStaff::verifyStatus($user->uid))) && $value['wap_url'] === '/order/order_cancellation')
  139. unset($menusInfo[$key]);
  140. if (((!StoreService::orderServiceStatus($user->uid)) && (!SystemStoreStaff::verifyStatus($user->uid))) && $value['wap_url'] === '/admin/order_cancellation/index')
  141. unset($menusInfo[$key]);
  142. if ((!StoreService::orderServiceStatus($user->uid)) && $value['wap_url'] === '/admin/order/index')
  143. unset($menusInfo[$key]);
  144. if ($value['wap_url'] == '/user/vip' && !$vipOpen)
  145. unset($menusInfo[$key]);
  146. if ($value['wap_url'] == '/customer/index' && !StoreService::orderServiceStatus($user->uid))
  147. unset($menusInfo[$key]);
  148. }
  149. return app('json')->successful(['routine_my_menus' => $menusInfo]);
  150. }
  151. /**
  152. * 热门搜索关键字获取
  153. * @return mixed
  154. * @throws DataNotFoundException
  155. * @throws ModelNotFoundException
  156. * @throws \think\exception\DbException
  157. */
  158. public function search()
  159. {
  160. $routineHotSearch = sys_data('routine_hot_search') ?? [];
  161. $searchKeyword = [];
  162. if (count($routineHotSearch)) {
  163. foreach ($routineHotSearch as $key => &$item) {
  164. array_push($searchKeyword, $item['title']);
  165. }
  166. }
  167. return app('json')->successful($searchKeyword);
  168. }
  169. /**
  170. * 图片上传
  171. * @param Request $request
  172. * @return mixed
  173. * @throws \Psr\SimpleCache\InvalidArgumentException
  174. */
  175. public function upload_image(Request $request)
  176. {
  177. $data = UtilService::postMore([
  178. ['filename', 'file'],
  179. ], $request);
  180. if (!$data['filename']) return app('json')->fail('参数有误');
  181. if (Cache::has('start_uploads_' . $request->uid()) && Cache::get('start_uploads_' . $request->uid()) >= 100) return app('json')->fail('非法操作');
  182. $upload_type = sys_config('upload_type', 1);
  183. $upload = new Upload((int)$upload_type, [
  184. 'accessKey' => sys_config('accessKey'),
  185. 'secretKey' => sys_config('secretKey'),
  186. 'uploadUrl' => sys_config('uploadUrl'),
  187. 'storageName' => sys_config('storage_name'),
  188. 'storageRegion' => sys_config('storage_region'),
  189. ]);
  190. $info = $upload->to('store/comment')->validate()->move($data['filename']);
  191. if ($info === false) {
  192. return app('json')->fail($upload->getError());
  193. }
  194. $res = $upload->getUploadInfo();
  195. SystemAttachment::attachmentAdd($res['name'], $res['size'], $res['type'], $res['dir'], $res['thumb_path'], 1, $upload_type, $res['time'], 2);
  196. if (Cache::has('start_uploads_' . $request->uid()))
  197. $start_uploads = (int)Cache::get('start_uploads_' . $request->uid());
  198. else
  199. $start_uploads = 0;
  200. $start_uploads++;
  201. Cache::set('start_uploads_' . $request->uid(), $start_uploads, 86400);
  202. $res['dir'] = path_to_url($res['dir']);
  203. if (strpos($res['dir'], 'http') === false) $res['dir'] = $request->domain() . $res['dir'];
  204. return app('json')->successful('图片上传成功!', ['name' => $res['name'], 'url' => $res['dir']]);
  205. }
  206. /**
  207. * 物流公司
  208. * @return mixed
  209. */
  210. public function logistics()
  211. {
  212. $expressList = Express::lst();
  213. if (!$expressList) return app('json')->successful([]);
  214. return app('json')->successful($expressList->hidden(['code', 'id', 'sort', 'is_show'])->toArray());
  215. }
  216. /**
  217. * 短信购买异步通知
  218. *
  219. * @param Request $request
  220. * @return mixed
  221. */
  222. public function sms_pay_notify(Request $request)
  223. {
  224. list($order_id, $price, $status, $num, $pay_time, $attach) = UtilService::postMore([
  225. ['order_id', ''],
  226. ['price', 0.00],
  227. ['status', 400],
  228. ['num', 0],
  229. ['pay_time', time()],
  230. ['attach', 0],
  231. ], $request, true);
  232. if ($status == 200) {
  233. ChannelService::instance()->send('PAY_SMS_SUCCESS', ['price' => $price, 'number' => $num], [$attach]);
  234. return app('json')->successful();
  235. }
  236. return app('json')->fail();
  237. }
  238. /**
  239. * 记录用户分享
  240. * @param Request $request
  241. * @return mixed
  242. */
  243. public function user_share(Request $request)
  244. {
  245. return app('json')->successful(UserBill::setUserShare($request->uid()));
  246. }
  247. /**
  248. * 获取图片base64
  249. * @param Request $request
  250. * @return mixed
  251. */
  252. public function get_image_base64(Request $request)
  253. {
  254. list($imageUrl, $codeUrl) = UtilService::postMore([
  255. ['image', ''],
  256. ['code', ''],
  257. ], $request, true);
  258. try {
  259. $codeTmp = $code = $codeUrl ? image_to_base64($codeUrl) : false;
  260. if (!$codeTmp) {
  261. $putCodeUrl = put_image($codeUrl);
  262. $code = $putCodeUrl ? image_to_base64($_SERVER['HTTP_HOST'] . '/' . $putCodeUrl) : false;
  263. $code ?? unlink($_SERVER["DOCUMENT_ROOT"] . '/' . $putCodeUrl);
  264. }
  265. $imageTmp = $image = $imageUrl ? image_to_base64($imageUrl) : false;
  266. if (!$imageTmp) {
  267. $putImageUrl = put_image($imageUrl);
  268. $image = $putImageUrl ? image_to_base64($_SERVER['HTTP_HOST'] . '/' . $putImageUrl) : false;
  269. $image ?? unlink($_SERVER["DOCUMENT_ROOT"] . '/' . $putImageUrl);
  270. }
  271. return app('json')->successful(compact('code', 'image'));
  272. } catch (\Exception $e) {
  273. return app('json')->fail($e->getMessage());
  274. }
  275. }
  276. /**
  277. * 门店列表
  278. * @return mixed
  279. */
  280. public function store_list(Request $request)
  281. {
  282. list($latitude, $longitude, $page, $limit) = UtilService::getMore([
  283. ['latitude', ''],
  284. ['longitude', ''],
  285. ['page', 1],
  286. ['limit', 10]
  287. ], $request, true);
  288. $list = SystemStore::lst($latitude, $longitude, $page, $limit);
  289. if (!$list) $list = [];
  290. $data['list'] = $list;
  291. $data['tengxun_map_key'] = sys_config('tengxun_map_key');
  292. return app('json')->successful($data);
  293. }
  294. /**
  295. * 门店详情
  296. * @param Request $request
  297. * @param int $id
  298. * @return mixed
  299. */
  300. public function store_detail(Request $request, $id)
  301. {
  302. list($latitude, $longitude) = UtilService::getMore([
  303. ['latitude', ''],
  304. ['longitude', ''],
  305. ], $request, true);
  306. $info = SystemStore::get($id);
  307. $info['distance'] = sqrt((pow((((float)$latitude - (float)$info['latitude']) * 111000), 2)) + (pow((((float)$longitude - (float)$info['longitude']) * 111000), 2)));
  308. //转换单位
  309. $info['range'] = bcdiv($info['distance'], 1000, 1);
  310. return app('json')->successful('ok', compact('info'));
  311. }
  312. /**
  313. * 查找城市数据
  314. * @param Request $request
  315. * @return mixed
  316. */
  317. public function city_list(Request $request)
  318. {
  319. $list = CacheService::get('CITY_LIST', function () {
  320. $list = SystemCity::with('children')->field(['city_id', 'name', 'id', 'parent_id'])->where('parent_id', 0)->order('id asc')->select()->toArray();
  321. $data = [];
  322. foreach ($list as &$item) {
  323. $value = ['v' => $item['city_id'], 'n' => $item['name']];
  324. if ($item['children']) {
  325. foreach ($item['children'] as $key => &$child) {
  326. $value['c'][$key] = ['v' => $child['city_id'], 'n' => $child['name']];
  327. unset($child['id'], $child['area_code'], $child['merger_name'], $child['is_show'], $child['level'], $child['lng'], $child['lat'], $child['lat']);
  328. if (SystemCity::where('parent_id', $child['city_id'])->count()) {
  329. $child['children'] = SystemCity::where('parent_id', $child['city_id'])->field(['city_id', 'name', 'id', 'parent_id'])->select()->toArray();
  330. foreach ($child['children'] as $kk => $vv) {
  331. $value['c'][$key]['c'][$kk] = ['v' => $vv['city_id'], 'n' => $vv['name']];
  332. }
  333. }
  334. }
  335. }
  336. $data[] = $value;
  337. }
  338. return $data;
  339. }, 0);
  340. return app('json')->successful($list);
  341. }
  342. }