BasicPanel.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715
  1. <?php
  2. namespace App\Http\Controllers\manager\Statistics;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\Manager\Statistics\BasicPanel as request;
  5. use App\Models\Manager\Process\LowPriceGoods as LowPriceGoodsModel;
  6. use App\Models\Manager\Process\ViolationProduct as ViolationProductModel;
  7. use App\Models\Manager\Process\ViolationStore as ViolationStoreModel;
  8. use App\Models\Manager\Collect\Product as ProductModel;
  9. use Illuminate\Support\Facades\DB;
  10. use Illuminate\Support\Carbon;
  11. /**
  12. * 报表统计-基础概览面板
  13. * @author 唐远望
  14. * @version 1.0
  15. * @date 2026-02-10
  16. *
  17. */
  18. class BasicPanel extends Controller
  19. {
  20. /*
  21. * 挂网数据统计
  22. * @author 唐远望
  23. * @version 1.0
  24. * @date 2026-02-10
  25. *
  26. */
  27. public function get_online_goods_count(request $request, LowPriceGoodsModel $lowPriceGoodsModel, ViolationProductModel $violationProductModel, ViolationStoreModel $violationStoreModel, ProductModel $productModel)
  28. {
  29. $request->scene('get_online_goods_count')->validate();
  30. $admin_company_id = request('admin_company_id', '0');
  31. $company_id = request('access_token.company_id', '0');
  32. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  33. $product_name = request('product_name', ''); //商品名称
  34. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  35. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  36. $start_time_string = request('start_time', '');
  37. $end_time_string = request('end_time', '');
  38. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  39. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  40. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  41. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  42. // 时间条件
  43. $map = [];
  44. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  45. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  46. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  47. // 统计挂网商品数量=低价挂网商品数量(去重)+ 禁止挂网商品数量(去重)
  48. $lowPriceGoodsModel = $lowPriceGoodsModel->query();
  49. $violationProductModel = $violationProductModel->query();
  50. if ($is_admin != 1 && $company_id != 0) {
  51. $lowPriceGoodsModel = $lowPriceGoodsModel->where('company_id', $company_id);
  52. $violationProductModel = $violationProductModel->where('company_id', $company_id);
  53. $violationStoreModel = $violationStoreModel->where('company_id', $company_id);
  54. $productModel = $productModel->where('company_id', $company_id);
  55. } else {
  56. $lowPriceGoodsModel = $lowPriceGoodsModel->where('company_id', $admin_company_id);
  57. $violationProductModel = $violationProductModel->where('company_id', $admin_company_id);
  58. $violationStoreModel = $violationStoreModel->where('company_id', $admin_company_id);
  59. $productModel = $productModel->where('company_id', $admin_company_id);
  60. }
  61. // 低价挂网商品数量查询
  62. $lowPriceGoodsCount = $lowPriceGoodsModel->where($map)
  63. ->where('status', 0)
  64. ->groupBy('product_name')
  65. ->select('product_name')
  66. ->get()->count();
  67. // 禁止挂网商品数量查询
  68. $violationProductCount = $violationProductModel->where($map)
  69. ->where('status', 0)
  70. ->groupBy('product_name')
  71. ->select('product_name')
  72. ->get()->count();
  73. $store_map = [];
  74. if ($start_time) $store_map[] = ['insert_time', '>=', $start_time];
  75. if ($end_time) $store_map[] = ['insert_time', '<=', $end_time];
  76. // 违规店铺数量查询
  77. $violationStoreCount = $violationStoreModel->where($store_map)
  78. ->where('status', 0)
  79. ->groupBy('company_name')
  80. ->select('company_name')
  81. ->get()->count();
  82. //获取终端类型B端、C端、OTO,配置品规数量
  83. $productModel = new ProductModel();
  84. $productModel_map = [];
  85. if ($start_time) $productModel_map[] = ['insert_time', '>=', $start_time];
  86. if ($end_time) $productModel_map[] = ['insert_time', '<=', $end_time];
  87. $productNames = $productModel
  88. ->where(function ($query) {
  89. $platforms = ['0', '5', '6', '7', '8', '9', '10'];
  90. foreach ($platforms as $platform) {
  91. $query->orWhereRaw("FIND_IN_SET(?, platform)", [$platform]);
  92. }
  93. })
  94. ->where('status', 0)
  95. ->where($productModel_map)
  96. ->distinct('product_name')
  97. ->pluck('product_name');
  98. $collect_b_product_count = $productModel
  99. ->whereIn('product_name', $productNames)
  100. ->where('status', 0)
  101. ->where($productModel_map)
  102. ->sum('product_specs_number');
  103. $productModel = new ProductModel();
  104. $productModel_map = [];
  105. if ($start_time) $productModel_map[] = ['insert_time', '>=', $start_time];
  106. if ($end_time) $productModel_map[] = ['insert_time', '<=', $end_time];
  107. $productNames = $productModel
  108. ->where(function ($query) {
  109. $platforms = ['0', '1', '2', '3', '4'];
  110. foreach ($platforms as $platform) {
  111. $query->orWhereRaw("FIND_IN_SET(?, platform)", [$platform]);
  112. }
  113. })
  114. ->where('status', 0)
  115. ->where($productModel_map)
  116. ->distinct('product_name')
  117. ->pluck('product_name');
  118. $collect_c_product_count = $productModel
  119. ->whereIn('product_name', $productNames)
  120. ->where('status', 0)
  121. ->where($productModel_map)
  122. ->sum('product_specs_number');
  123. $productModel = new ProductModel();
  124. $productModel_map = [];
  125. if ($start_time) $productModel_map[] = ['insert_time', '>=', $start_time];
  126. if ($end_time) $productModel_map[] = ['insert_time', '<=', $end_time];
  127. $productNames = $productModel
  128. ->where(function ($query) {
  129. $platforms = ['0'];
  130. foreach ($platforms as $platform) {
  131. $query->orWhereRaw("FIND_IN_SET(?, platform)", [$platform]);
  132. }
  133. })
  134. ->where('status', 0)
  135. ->where($productModel_map)
  136. ->distinct('product_name')
  137. ->pluck('product_name');
  138. $collect_oto_product_count = $productModel
  139. ->whereIn('product_name', $productNames)
  140. ->where('status', 0)
  141. ->where($productModel_map)
  142. ->sum('product_specs_number');
  143. // 所有终端品规数量
  144. $collect_totle_product_count = $collect_b_product_count + $collect_c_product_count + $collect_oto_product_count;
  145. $result_data = [
  146. 'low_price_goods_count' => $lowPriceGoodsCount, // 低价挂网商品数量
  147. 'violation_product_count' => $violationProductCount, // 禁止挂网商品数量
  148. 'violation_store_count' => $violationStoreCount, // 违规店铺数量
  149. 'totle_product_count' => $lowPriceGoodsCount + $violationProductCount, // 总商品数量
  150. 'collect_b_product_count' => $collect_b_product_count, // B端品规数量
  151. 'collect_c_product_count' => $collect_c_product_count, // C端品规数量
  152. 'collect_oto_product_count' => $collect_oto_product_count, // OTO品规数量
  153. 'collect_totle_product_count' => $collect_totle_product_count, // 所有终端品规数量
  154. ];
  155. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result_data]);
  156. }
  157. /**
  158. * 禁止挂网商品数统计
  159. * @author 唐远望
  160. * @version 1.0
  161. * @date 2026-02-10
  162. *
  163. */
  164. public function get_violation_product_count(request $request, ViolationProductModel $violationProductModel)
  165. {
  166. $request->scene('get_violation_product_count')->validate();
  167. $admin_company_id = request('admin_company_id', '0');
  168. $company_id = request('access_token.company_id', '0');
  169. //终端类型B端、C端、OTO
  170. $terminal_type = request('terminal_type', '');
  171. $product_name = request('product_name', ''); //商品名称
  172. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  173. $limit = request('limit', config('page_num', 10));
  174. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  175. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  176. $start_time_string = request('start_time', '');
  177. $end_time_string = request('end_time', '');
  178. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  179. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  180. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  181. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  182. // 时间条件
  183. $map = [];
  184. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  185. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  186. // 权限判断
  187. if ($is_admin != 1 && $company_id != 0) {
  188. $map[] = ['company_id', '=', $company_id];
  189. } else {
  190. $map[] = ['company_id', '=', $admin_company_id];
  191. }
  192. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  193. $violationProductModel = $violationProductModel->query();
  194. if ($terminal_type) {
  195. $platform = [];
  196. switch ($terminal_type) {
  197. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  198. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  199. break;
  200. case '2': //C端:美团、拼多多、天猫、京东
  201. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  202. break;
  203. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  204. $platform = ['0'];
  205. break;
  206. default:
  207. # code...
  208. break;
  209. }
  210. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  211. }
  212. $result = $violationProductModel->where($map)->where('status', 0)
  213. ->select(['product_name', DB::raw('count(product_name) as count')])->distinct('product_name')->orderby('count', 'desc')
  214. ->groupby('product_name')->paginate($limit);
  215. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  216. }
  217. /**
  218. * 禁止挂网省份统计
  219. * @author 唐远望
  220. * @version 1.0
  221. * @date 2026-02-10
  222. *
  223. */
  224. public function get_violation_province_count(request $request, ViolationProductModel $violationProductModel)
  225. {
  226. $request->scene('get_violation_province_count')->validate();
  227. $admin_company_id = request('admin_company_id', '0');
  228. $company_id = request('access_token.company_id', '0');
  229. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  230. //终端类型B端、C端、OTO
  231. $terminal_type = request('terminal_type', '');
  232. $product_name = request('product_name', ''); //商品名称
  233. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  234. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  235. $start_time_string = request('start_time', '');
  236. $end_time_string = request('end_time', '');
  237. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  238. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  239. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  240. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  241. // 时间条件
  242. $map = [];
  243. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  244. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  245. // 权限判断
  246. if ($is_admin != 1 && $company_id != 0) {
  247. $map[] = ['company_id', '=', $company_id];
  248. } else {
  249. $map[] = ['company_id', '=', $admin_company_id];
  250. }
  251. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  252. // 禁止挂网省份统计
  253. $violationProductModel = $violationProductModel->query();
  254. if ($terminal_type) {
  255. $platform = [];
  256. switch ($terminal_type) {
  257. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  258. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  259. break;
  260. case '2': //C端:美团、拼多多、天猫、京东
  261. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  262. break;
  263. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  264. $platform = ['0'];
  265. break;
  266. default:
  267. # code...
  268. break;
  269. }
  270. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  271. }
  272. try {
  273. // 假设 ViolationProductModel 中有 province 字段,表示省份信息
  274. // 查询指定时间范围内的数据,并按 province 分组统计数量
  275. $result = $violationProductModel->where($map)->where('status', 0)
  276. ->select(['province_name', DB::raw('count(province_name) as count')])
  277. ->groupby('province_name')
  278. ->orderby('count', 'desc')
  279. ->get();
  280. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  281. } catch (\Exception $e) {
  282. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  283. }
  284. }
  285. /**
  286. * 禁止挂网城市统计
  287. * @author 唐远望
  288. * @version 1.0
  289. * @date 2026-02-10
  290. *
  291. */
  292. public function get_violation_city_count(request $request, ViolationProductModel $violationProductModel)
  293. {
  294. $request->scene('get_violation_city_count')->validate();
  295. $admin_company_id = request('admin_company_id', '0');
  296. $company_id = request('access_token.company_id', '0');
  297. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  298. //终端类型B端、C端、OTO
  299. $terminal_type = request('terminal_type', '');
  300. $product_name = request('product_name', ''); //商品名称
  301. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  302. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  303. $start_time_string = request('start_time', '');
  304. $end_time_string = request('end_time', '');
  305. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  306. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  307. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  308. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  309. // 时间条件
  310. $map = [];
  311. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  312. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  313. // 权限判断
  314. if ($is_admin != 1 && $company_id != 0) {
  315. $map[] = ['company_id', '=', $company_id];
  316. } else {
  317. $map[] = ['company_id', '=', $admin_company_id];
  318. }
  319. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  320. // 禁止挂网城市统计
  321. $violationProductModel = $violationProductModel->query();
  322. if ($terminal_type) {
  323. $platform = [];
  324. switch ($terminal_type) {
  325. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  326. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  327. break;
  328. case '2': //C端:美团、拼多多、天猫、京东
  329. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  330. break;
  331. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  332. $platform = ['0'];
  333. break;
  334. default:
  335. # code...
  336. break;
  337. }
  338. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  339. }
  340. try {
  341. // 假设 ViolationProductModel 中有 city 字段,表示城市信息
  342. // 查询指定时间范围内的数据,并按 city 分组统计数量
  343. $result = $violationProductModel->where($map)->where('status', 0)
  344. ->select(['city_name', DB::raw('count(city_name) as count')])
  345. ->groupby('city_name')
  346. ->orderby('count', 'desc')
  347. ->get();
  348. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  349. } catch (\Exception $e) {
  350. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  351. }
  352. }
  353. /**
  354. * 禁止挂网公司数统计
  355. * @author 唐远望
  356. * @version 1.0
  357. * @date 2026-02-10
  358. *
  359. */
  360. public function get_violation_company_count(request $request, ViolationProductModel $violationProductModel)
  361. {
  362. $request->scene('get_violation_company_count')->validate();
  363. $admin_company_id = request('admin_company_id', '0');
  364. $company_id = request('access_token.company_id', '0');
  365. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  366. //终端类型B端、C端、OTO
  367. $terminal_type = request('terminal_type', '');
  368. $limit = request('limit', config('page_num', 10));
  369. $product_name = request('product_name', ''); //商品名称
  370. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  371. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  372. $start_time_string = request('start_time', '');
  373. $end_time_string = request('end_time', '');
  374. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  375. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  376. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  377. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  378. // 时间条件
  379. $map = [];
  380. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  381. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  382. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  383. // 权限判断
  384. if ($is_admin != 1 && $company_id != 0) {
  385. $map[] = ['company_id', '=', $company_id];
  386. } else {
  387. $map[] = ['company_id', '=', $admin_company_id];
  388. }
  389. $violationProductModel = $violationProductModel->query();
  390. if ($terminal_type) {
  391. $platform = [];
  392. switch ($terminal_type) {
  393. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  394. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  395. break;
  396. case '2': //C端:美团、拼多多、天猫、京东
  397. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  398. break;
  399. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  400. $platform = ['0'];
  401. break;
  402. default:
  403. # code...
  404. break;
  405. }
  406. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  407. }
  408. $result = $violationProductModel->where($map)->where('status', 0)
  409. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  410. ->paginate($limit);
  411. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  412. }
  413. /*
  414. * 低价违规商品数统计
  415. * @author 唐远望
  416. * @version 1.0
  417. * @date 2026-02-10
  418. *
  419. */
  420. public function get_low_price_product_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  421. {
  422. $request->scene('get_low_price_product_count')->validate();
  423. $admin_company_id = request('admin_company_id', '0');
  424. $company_id = request('access_token.company_id', '0');
  425. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  426. //终端类型B端、C端、OTO
  427. $terminal_type = request('terminal_type', '');
  428. $limit = request('limit', config('page_num', 10));
  429. $product_name = request('product_name', ''); //商品名称
  430. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  431. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  432. $start_time_string = request('start_time', '');
  433. $end_time_string = request('end_time', '');
  434. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  435. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  436. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  437. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  438. // 时间条件
  439. $map = [];
  440. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  441. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  442. // 权限判断
  443. if ($is_admin != 1 && $company_id != 0) {
  444. $map[] = ['company_id', '=', $company_id];
  445. } else {
  446. $map[] = ['company_id', '=', $admin_company_id];
  447. }
  448. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  449. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  450. if ($terminal_type) {
  451. $platform = [];
  452. switch ($terminal_type) {
  453. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  454. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  455. break;
  456. case '2': //C端:美团、拼多多、天猫、京东
  457. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  458. break;
  459. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  460. $platform = ['0'];
  461. break;
  462. default:
  463. # code...
  464. break;
  465. }
  466. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  467. }
  468. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  469. ->select(['product_name', DB::raw('count(product_name) as count')])->distinct('product_name')->orderby('count', 'desc')
  470. ->groupby('product_name')->paginate($limit);
  471. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  472. }
  473. /*
  474. * 低价违规公司数统计
  475. * @author 唐远望
  476. * @version 1.0
  477. * @date 2026-02-10
  478. *
  479. */
  480. public function get_low_price_company_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  481. {
  482. $request->scene('get_low_price_company_count')->validate();
  483. $admin_company_id = request('admin_company_id', '0');
  484. $company_id = request('access_token.company_id', '0');
  485. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  486. //终端类型B端、C端、OTO
  487. $terminal_type = request('terminal_type', '');
  488. $limit = request('limit', config('page_num', 10));
  489. $product_name = request('product_name', ''); //商品名称
  490. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  491. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  492. $start_time_string = request('start_time', '');
  493. $end_time_string = request('end_time', '');
  494. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  495. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  496. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  497. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  498. // 时间条件
  499. $map = [];
  500. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  501. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  502. // 权限判断
  503. if ($is_admin != 1 && $company_id != 0) {
  504. $map[] = ['company_id', '=', $company_id];
  505. } else {
  506. $map[] = ['company_id', '=', $admin_company_id];
  507. }
  508. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  509. if ($terminal_type) {
  510. $platform = [];
  511. switch ($terminal_type) {
  512. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  513. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  514. break;
  515. case '2': //C端:美团、拼多多、天猫、京东
  516. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  517. break;
  518. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  519. $platform = ['0'];
  520. break;
  521. default:
  522. # code...
  523. break;
  524. }
  525. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  526. }
  527. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  528. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  529. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  530. ->paginate($limit);
  531. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  532. }
  533. /**
  534. * 低价挂网省份统计
  535. * @author 唐远望
  536. * @version 1.0
  537. * @date 2026-02-10
  538. *
  539. */
  540. public function get_low_price_province_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  541. {
  542. $request->scene('get_low_price_province_count')->validate();
  543. $admin_company_id = request('admin_company_id', '0');
  544. $company_id = request('access_token.company_id', '0');
  545. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  546. //终端类型B端、C端、OTO
  547. $terminal_type = request('terminal_type', '');
  548. $product_name = request('product_name', ''); //商品名称
  549. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  550. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  551. $start_time_string = request('start_time', '');
  552. $end_time_string = request('end_time', '');
  553. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  554. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  555. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  556. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  557. // 时间条件
  558. $map = [];
  559. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  560. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  561. // 权限判断
  562. if ($is_admin != 1 && $company_id != 0) {
  563. $map[] = ['company_id', '=', $company_id];
  564. } else {
  565. $map[] = ['company_id', '=', $admin_company_id];
  566. }
  567. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  568. // 禁止挂网省份统计
  569. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  570. if ($terminal_type) {
  571. $platform = [];
  572. switch ($terminal_type) {
  573. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  574. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  575. break;
  576. case '2': //C端:美团、拼多多、天猫、京东
  577. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  578. break;
  579. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  580. $platform = ['0'];
  581. break;
  582. default:
  583. # code...
  584. break;
  585. }
  586. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  587. }
  588. try {
  589. // 假设 LowPriceGoodsModel 中有 province 字段,表示省份信息
  590. // 查询指定时间范围内的数据,并按 province 分组统计数量
  591. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  592. ->select(['province_name', DB::raw('count(province_name) as count')])
  593. ->groupby('province_name')
  594. ->orderby('count', 'desc')
  595. ->get();
  596. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  597. } catch (\Exception $e) {
  598. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  599. }
  600. }
  601. /**
  602. * 低价挂网城市统计
  603. * @author 唐远望
  604. * @version 1.0
  605. * @date 2026-02-10
  606. *
  607. */
  608. public function get_low_price_city_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  609. {
  610. $request->scene('get_low_price_city_count')->validate();
  611. $admin_company_id = request('admin_company_id', '0');
  612. $company_id = request('access_token.company_id', '0');
  613. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  614. //终端类型B端、C端、OTO
  615. $terminal_type = request('terminal_type', '');
  616. $product_name = request('product_name', ''); //商品名称
  617. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  618. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  619. $start_time_string = request('start_time', '');
  620. $end_time_string = request('end_time', '');
  621. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  622. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  623. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  624. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  625. // 时间条件
  626. $map = [];
  627. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  628. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  629. // 权限判断
  630. if ($is_admin != 1 && $company_id != 0) {
  631. $map[] = ['company_id', '=', $company_id];
  632. } else {
  633. $map[] = ['company_id', '=', $admin_company_id];
  634. }
  635. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  636. // 禁止挂网城市统计
  637. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  638. if ($terminal_type) {
  639. $platform = [];
  640. switch ($terminal_type) {
  641. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  642. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  643. break;
  644. case '2': //C端:美团、拼多多、天猫、京东
  645. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  646. break;
  647. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  648. $platform = ['0'];
  649. break;
  650. default:
  651. # code...
  652. break;
  653. }
  654. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  655. }
  656. try {
  657. // 假设 LowPriceGoodsModel 中有 city 字段,表示城市信息
  658. // 查询指定时间范围内的数据,并按 city 分组统计数量
  659. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  660. ->select(['city_name', DB::raw('count(city_name) as count')])
  661. ->groupby('city_name')
  662. ->orderby('count', 'desc')
  663. ->get();
  664. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  665. } catch (\Exception $e) {
  666. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  667. }
  668. }
  669. }