<?php namespace app\common\logic; use Symfony\Component\HttpClient\HttpClient; use think\Exception; class ShopRequestLogic extends BaseLogic { public static $shopUrlPrefix; public function __construct() { self::$shopUrlPrefix = env('url.shop_prefix'); parent::__construct(); } /** * 查询时间范围内,某一农科公司下的 供应链商户入驻统计 */ public static function getSupplyChainMerchantCount($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询供应链商户入驻5天内是否完成商品上架 */ public static function getProductListing($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 供应链商户入驻20天后是否完成库存更新 */ public static function getStockUpdate($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询商城商品列表 供任务,模板中指定商品 */ public static function getProductList($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询供应链商户指定商品采购金额 */ public static function getPurchaseAmount($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询供应链商户指定商品销售金额 */ public static function getTradeAmount($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询镇农科公司区域 指定时间范围内入驻的一般商户数量 */ public static function getGeneralMerchantCount($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询一般商户入驻5天内是否完成商品上架 */ public static function getGeneralMerchantProductListing($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询一般商户入驻5天内是否完成库存更新 */ public static function getGeneralMerchantStockUpdate($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询一般商户指定商品采购金额 */ public static function getGeneralMerchantPurchaseAmount($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } /** * 查询一般商户指定商品销售金额 */ public static function getGeneralMerchantTradeAmount($param) { try { $requestResponse = HttpClient::create()->request('GET', self::$shopUrlPrefix . '', [ 'query' => $param ]); return $requestResponse->getContent(); } catch (Exception $e) { self::setError($e->getMessage()); return false; } } }