Merchant.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
  1. <?php
  2. /**
  3. * @package merchant
  4. * @Author: Qinii
  5. * @Date: 2020/5/28
  6. */
  7. namespace app\controller\api\store\merchant;
  8. use think\App;
  9. use crmeb\basic\BaseController;
  10. use app\common\repositories\system\merchant\MerchantRepository as repository;
  11. use think\facade\Db;
  12. use think\facade\Log;
  13. use function Symfony\Component\VarDumper\Dumper\esc;
  14. class Merchant extends BaseController
  15. {
  16. protected $repository;
  17. protected $userInfo;
  18. private $merId;
  19. private $source;
  20. /**
  21. * ProductCategory constructor.
  22. * @param App $app
  23. * @param repository $repository
  24. */
  25. public function __construct(App $app, repository $repository)
  26. {
  27. parent::__construct($app);
  28. $this->repository = $repository;
  29. $this->userInfo =$this->request->isLogin() ? $this->request->userInfo():null;
  30. $this->source = $this->request->header('source');
  31. $this->merId = $this->request->header('merId');
  32. }
  33. /**
  34. * @Author:Qinii
  35. * @Date: 2020/5/27
  36. * @return mixed
  37. */
  38. public function lst()
  39. {
  40. [$page, $limit] = $this->getPage();
  41. $where = $this->request->params(['keyword','order','category_id']);
  42. return json_encode($where);
  43. return app('json')->success($this->repository->getList($where, $page,$limit,$this->userInfo));
  44. }
  45. /**
  46. * @Author:Qinii
  47. * @Date: 2020/5/29
  48. * @param $id
  49. * @return mixed
  50. */
  51. public function detail($id)
  52. {
  53. if(!$this->repository->apiGetOne($id))
  54. return app('json')->fail('店铺不存在');
  55. $lat=$this->request->param('lat','');
  56. $lng=$this->request->param('lng','');
  57. return app('json')->success($this->repository->detail($id,$this->userInfo,$lat, $lng));
  58. }
  59. /**
  60. * @Author:Qinii
  61. * @Date: 2020/5/29
  62. * @param $id
  63. * @return mixed
  64. */
  65. public function productList($id)
  66. {
  67. [$page, $limit] = $this->getPage();
  68. $where = $this->request->params(['keyword','order','mer_cate_id','price_on', 'price_off','brand_id']);
  69. $where['is_gift_bag'] = 0;
  70. $where['is_used'] = 1;
  71. $where['product_type'] = 0;
  72. $where['is_hide'] = 0;
  73. if($id==324){
  74. $where['mer_type']=1;
  75. }
  76. if($this->source=='yhc' && $this->merId==496){
  77. return app('json')->success($this->repository->productList_yhc($id,$where, $page, $limit,$this->userInfo));
  78. }
  79. return app('json')->success($this->repository->productList($id,$where, $page, $limit,$this->userInfo));
  80. }
  81. public function productTypeList()
  82. {
  83. $params= $this->request->params(['type','mer_cate_id','pageNum','pageSize','mer_id']);
  84. $name=$params['type'];
  85. $domain = $this->request->domain();
  86. $id=0;
  87. $type439=true;
  88. $is_commercetrade = 0;
  89. if($name=='dingsheng'){
  90. $id=486;
  91. }else if($name=='jingpin'){
  92. $id=439;
  93. $type439=false;
  94. }else if($name=='jifen'){
  95. $id=148;
  96. }else if($name=='gongchang'){
  97. if(strpos($domain, 'test.hebeiyhc.com') !== false) {
  98. // 域名中包含 "test.hebeiyhc.com'" 字符串
  99. $id=486;//测试环境工厂直供
  100. }else{
  101. $id=497;//生产环境工厂直供
  102. }
  103. }else if($name=='fugou'){
  104. $id=491;
  105. }// 商贸区
  106. else if($name=='commercetrade'){
  107. if (empty($params['mer_id'])) return app('json')->fail('店铺不存在');
  108. $id=$this->merId = $params['mer_id'];
  109. $is_commercetrade = 1;
  110. }
  111. [$page, $limit] = $this->getPage();
  112. if($params['pageNum']!=''){
  113. $page=$params['pageNum'];
  114. }
  115. if($params['pageSize']!=''){
  116. $limit=$params['pageSize'];
  117. }
  118. $where = $this->request->params(['keyword','order','mer_cate_id', 'cate_id','price_on', 'price_off','brand_id']);
  119. $where['is_gift_bag'] = 0;
  120. $where['is_used'] = 1;
  121. $where['product_type'] = 0;
  122. $where['is_hide'] = 0;
  123. log::info("====={$params['mer_cate_id']}===");
  124. if($params['mer_cate_id']){
  125. $where['cate_id'] = $params['mer_cate_id'];
  126. }
  127. return app('json')->success($this->repository->productList($id,$where, $page, $limit,$this->userInfo,$type439,$is_commercetrade));
  128. }
  129. /**
  130. * 获取商户上架的商品列表
  131. * @return mixed
  132. */
  133. public function getProductList()
  134. {
  135. $params = request()->only(['pageNum', 'pageSize', 'mer_id']);
  136. $merId = $params['mer_id'] ?? 0;
  137. [$page, $limit] = $this->getPage();
  138. $where = request()->only(['keyword']);
  139. $where['is_gift_bag'] = 0;
  140. $where['is_used'] = 1;
  141. $where['product_type'] = 0;
  142. $where['is_hide'] = 0;
  143. $result = $this->repository->productList($merId, $where, $page, $limit, $this->userInfo);
  144. $formatList = [];
  145. foreach ($result['list'] as $productInfo) {
  146. $formatList[] = [
  147. 'type' => 0,//京东商品
  148. 'merId' => $productInfo['mer_id'],
  149. 'skuId' => '',//itemId 京东官方 已不返回skuId , 使用 联盟商品ID 代替skuId
  150. 'id' => $productInfo['product_id'] ?? '', //id
  151. 'name' => $productInfo['store_name'],//名称
  152. 'thumb' => $productInfo['image'] ?? '',//商品缩略图
  153. 'pv' => $productInfo['pv'],//PV金额
  154. 'gongxian' => $productInfo['gongxian'],
  155. 'jifen' => $productInfo['jifen'],
  156. 'yanglaojin' => $productInfo['yanglao'],
  157. 'commission' => $productInfo['concession_pri'],//佣金
  158. 'commission_rate' => null,//佣金比例
  159. 'coupon_money' => [],
  160. 'coupon_link' => '',
  161. 'lowestCouponPrice' => $productInfo['price'],
  162. 'price' => $productInfo['ot_price'], //价格
  163. 'imageList' => $productInfo['slider_image'], //图片合集
  164. 'materialUrl' => ''
  165. ];
  166. }
  167. return app('json')->success($formatList);
  168. }
  169. /**
  170. * 商贸区店铺商品列表
  171. * @return mixed
  172. * @throws \think\db\exception\DataNotFoundException
  173. * @throws \think\db\exception\DbException
  174. * @throws \think\db\exception\ModelNotFoundException
  175. */
  176. public function commerceProductList()
  177. {
  178. $hajimi = Db::name('merchant')->where('mer_id',3478)->find();
  179. return app('json')->success($hajimi);
  180. // $params= $this->request->params(['pageNum','pageSize','category_id']);
  181. // $mer_id_unset = [496,486,439,148,491];
  182. // $domain = $this->request->domain();
  183. // if(strpos($domain, 'test.hebeiyhc.com') !== false) {
  184. // // 域名中包含 "test.hebeiyhc.com'" 字符串
  185. // array_push($mer_id_unset, 486);
  186. // }else{
  187. // array_push($mer_id_unset, 497);
  188. // }
  189. //
  190. // $is_commercetrade = 1;
  191. // [$page, $limit] = $this->getPage();
  192. // if($params['pageNum']!=''){
  193. // $page=$params['pageNum'];
  194. // }
  195. // if($params['pageSize']!=''){
  196. // $limit=$params['pageSize'];
  197. // }
  198. // $category_id = $params['category_id']?:0;
  199. // $where['is_del'] = 0;
  200. // $where['status'] = 1;
  201. // $category_id && $where['category_id'] = $category_id;
  202. //
  203. // $hasProductMerIdList = Db::name('store_product')
  204. // ->where('status', '=', 1)
  205. // ->where('is_show', '=', 1)
  206. // ->where('is_del', '=', 0)
  207. // ->group('mer_id')
  208. // ->field('mer_id')
  209. // ->select();
  210. // if ($hasProductMerIdList) {
  211. // $hasProductMerIdList = array_column($hasProductMerIdList->toArray(), 'mer_id');
  212. // }
  213. // $query = Db::name('merchant')->where($where);
  214. // if (!empty($hasProductMerIdList) && is_array($hasProductMerIdList)) {
  215. // $query->whereIn('mer_id', $hasProductMerIdList);
  216. // }
  217. // $mer_list = $query->page($page)->limit($limit)->select();
  218. // return app('json')->success(['list'=>$mer_list]);
  219. }
  220. /**
  221. * 查询代理人商品
  222. * @param $type
  223. * @return mixed
  224. */
  225. public function areaProductList()
  226. {
  227. [$page, $limit] = $this->getPage();
  228. $where = $this->request->params(['keyword','order','mer_cate_id','price_on', 'price_off','brand_id']);
  229. $where['is_gift_bag'] = 0;
  230. $where['is_used'] = 1;
  231. $where['product_type'] = 0;
  232. $where['is_hide'] = 0;
  233. $type = $this->request->param('type');
  234. Log::info('查询代理人商品请求参数,type:'.$type);
  235. $type = $type == 'district' ? 13 : ($type == 'town' ? 12 : ($type == 'village' ? 11 : -1));
  236. // $where['web_type'] = $type;
  237. $id = 324;
  238. $data = $this->repository->productList($id,$where, $page, $limit,$this->userInfo);
  239. Log::info('查询代理人商品返回'.json_encode($data,true));
  240. return app('json')->success($data);
  241. }
  242. /**
  243. * @Author:Qinii
  244. * @Date: 2020/5/29
  245. * @param int $id
  246. * @return mixed
  247. */
  248. public function categoryList($id)
  249. {
  250. if(!$this->repository->merExists($id))
  251. return app('json')->fail('店铺不存在');
  252. return app('json')->success($this->repository->categoryList($id));
  253. }
  254. public function qrcode($id)
  255. {
  256. $mer = \app\common\model\system\merchant\Merchant::getInstance()->where('mer_id', $id)->find();
  257. if(!$mer)
  258. return app('json')->fail('店铺不存在');
  259. $type = $this->request->param('type');
  260. $is_payment = $this->request->param('is_payment', 0);
  261. switch ($type) {
  262. case 'routine':
  263. if ($is_payment) {
  264. $url = $this->repository->routineQrcode(intval($id), '/h5payment/index.html','_store_routine_payment.jpg');
  265. } else {
  266. $url = $this->repository->routineQrcode(intval($id));
  267. }
  268. break;
  269. default:
  270. if ($is_payment) {
  271. $url = $this->repository->wxQrcode(intval($id), '/h5payment/index.html', '_store_wap_payment.jpg', $mer->mer_avatar);
  272. } else {
  273. $url = $this->repository->wxQrcode(intval($id));
  274. }
  275. }
  276. return app('json')->success(compact('url'));
  277. }
  278. public function payQrCode($id){
  279. $mer = \app\common\model\system\merchant\Merchant::getInstance()->where('mer_id', $id)->find();
  280. if(!$mer)
  281. return app('json')->fail('店铺不存在');
  282. $res = $this -> repository -> getQrCode($mer);
  283. return app('json') -> success($res);
  284. }
  285. /**
  286. * @Date: 2020/10/10
  287. * 店铺列表 :首页 最多十个
  288. * @return mixed
  289. */
  290. public function listindex()
  291. {
  292. // [$page, $limit] = $this->getPage();
  293. $page=input("page/d",1);
  294. $limit=input("limit/d",10);
  295. $keyword=input("keyword","");
  296. $order=input("order",0);
  297. $type=input("type",2);
  298. $lat=input("lat",1);
  299. $lng=input("lng",1);
  300. $data=[
  301. "lat"=>$lat,
  302. "lng"=>$lng,
  303. "keyword"=>$keyword,
  304. "order"=>$order
  305. ];
  306. return app('json')->success($this->repository->getLists($data,$page,$limit,$type));
  307. }
  308. /**
  309. * @Date: 2020/10/10
  310. * 店铺列表:
  311. * @param $keyword //搜索
  312. * @param $order //排序
  313. * @param $category_id //分类id
  314. * @return mixed
  315. */
  316. public function list()
  317. {
  318. $category_id=input("category_id",0);
  319. $page=input("page/d",1);
  320. $limit=input("limit/d",10);
  321. $keyword=input("keyword","");
  322. $order=input("order",0);
  323. $type=input("type",0);
  324. $lat=input("lat",'113.643636');
  325. $lng=input("lng",'34.73841');
  326. $city_name=input("city_name",'');
  327. if ($type==2){
  328. $data=[
  329. "lat"=>empty($lat)?"113.643636":$lat,
  330. "lng"=>empty($lng)?"34.73841":$lng,
  331. "keyword"=>$keyword,
  332. "order"=>$order
  333. ];
  334. return app('json')->success($this->repository->getLists($data,$page,$limit,$type));
  335. }
  336. $where=[];
  337. if ($category_id){
  338. $where["category_id"]=$category_id;
  339. }
  340. $data=[
  341. "lat"=>empty($lat)?"34.73841":$lat,
  342. "lng"=>empty($lng)?"113.643636":$lng,
  343. ];
  344. if ($city_name){
  345. $data["city_name"]=$city_name;
  346. }
  347. return app('json')->success($this->repository->getLists($data,1,10,1,$where));
  348. // return app('json')->success(['count'=>0,'list'=>[],'where'=>[]]);
  349. }
  350. /**
  351. * @Date: 2020/10/10
  352. * 店铺分类
  353. */
  354. public function merchantcategory()
  355. {
  356. [$page, $limit] = $this->getPage();
  357. return app('json')->success($this->repository->merchantcategory());
  358. }
  359. /**
  360. * 附近页面商家分类
  361. * @day 2020/10/30
  362. */
  363. public function mercat()
  364. {
  365. [$page, $limit] = $this->getPage();
  366. return app('json')->success($this->repository->mercat($page, $limit));
  367. }
  368. /*
  369. *分类下的商家列表
  370. * @author cabbage
  371. * @day 2020/10/30
  372. * */
  373. public function mercatStore(){
  374. [$page, $limit] = $this->getPage();
  375. $data = $this->request->params([
  376. 'order', //人气
  377. 'distance', //距离
  378. 'lat', //经度
  379. 'lng', //纬度
  380. 'user_id'
  381. ]);
  382. $where = $this->request->params([
  383. 'category_id', //商铺分类id
  384. 'keyword', //商铺名称
  385. ]);
  386. return app('json')->success($this->repository->getLst($data,$page,$limit,$where));
  387. // return app('json')->success([]);
  388. }
  389. /**
  390. * @param $id
  391. * @return mixed
  392. * @throws \think\db\exception\DbException
  393. * 店铺置顶
  394. */
  395. public function shop_topping($id)
  396. {
  397. if($id!=0){
  398. $res=Db::name('user')->where('uid',$this->request->uid())->update(['mer_topping'=>$id]);
  399. if($res!==false)
  400. $message='置顶成功';
  401. else
  402. $message='置顶失败';
  403. return app('json')->success($message);
  404. }else{
  405. $res=Db::name('user')->where('uid',$this->request->uid())->update(['mer_topping'=>0]);
  406. if($res!==false)
  407. $message='取消置顶成功';
  408. else
  409. $message='取消置顶失败';
  410. return app('json')->success($message);
  411. }
  412. }
  413. /**
  414. * @param $id
  415. * @return mixed
  416. * @throws \think\db\exception\DbException
  417. * 店铺点赞 or 店铺取消点赞
  418. */
  419. public function shop_fabulous($id)
  420. {
  421. $uid=$this->request->uid();
  422. $user_like=Db::name('store_fabulous')->where('uid',$uid)->where('mer_id',$id)->value('status');
  423. if($user_like=='0'){
  424. $res=Db::name('store_fabulous')->where('uid',$uid)->where('mer_id',$id)->update(['status'=>1]);
  425. if($res!==false)
  426. $message='点赞成功';
  427. else
  428. $message='点赞失败';
  429. }elseif ($user_like=='1'){
  430. $res=Db::name('store_fabulous')->where('uid',$uid)->where('mer_id',$id)->update(['status'=>0]);
  431. if($res!==false)
  432. $message='取消点赞成功';
  433. else
  434. $message='取消点赞失败';
  435. }else{
  436. $inser_data=[
  437. 'uid'=>$uid,
  438. 'mer_id'=>$id,
  439. 'ctime'=>time(),
  440. 'status'=>1
  441. ];
  442. $res=Db::name('store_fabulous')->insert($inser_data);
  443. if($res!==false)
  444. $message='点赞成功';
  445. else
  446. $message='点赞失败';
  447. }
  448. return app('json')->success($message);
  449. }
  450. }