BasicPanel.php 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745
  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()->toarray();
  280. $province_totle_count = 0;
  281. if(!empty($result)){
  282. $province_totle_count = array_sum(array_column($result, 'count'));
  283. //计算占比
  284. foreach ($result as $key => $value) {
  285. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  286. }
  287. }
  288. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  289. } catch (\Exception $e) {
  290. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  291. }
  292. }
  293. /**
  294. * 禁止挂网城市统计
  295. * @author 唐远望
  296. * @version 1.0
  297. * @date 2026-02-10
  298. *
  299. */
  300. public function get_violation_city_count(request $request, ViolationProductModel $violationProductModel)
  301. {
  302. $request->scene('get_violation_city_count')->validate();
  303. $admin_company_id = request('admin_company_id', '0');
  304. $company_id = request('access_token.company_id', '0');
  305. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  306. //终端类型B端、C端、OTO
  307. $terminal_type = request('terminal_type', '');
  308. $product_name = request('product_name', ''); //商品名称
  309. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  310. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  311. $start_time_string = request('start_time', '');
  312. $end_time_string = request('end_time', '');
  313. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  314. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  315. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  316. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  317. // 时间条件
  318. $map = [];
  319. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  320. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  321. // 权限判断
  322. if ($is_admin != 1 && $company_id != 0) {
  323. $map[] = ['company_id', '=', $company_id];
  324. } else {
  325. $map[] = ['company_id', '=', $admin_company_id];
  326. }
  327. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  328. // 禁止挂网城市统计
  329. $violationProductModel = $violationProductModel->query();
  330. if ($terminal_type) {
  331. $platform = [];
  332. switch ($terminal_type) {
  333. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  334. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  335. break;
  336. case '2': //C端:美团、拼多多、天猫、京东
  337. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  338. break;
  339. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  340. $platform = ['0'];
  341. break;
  342. default:
  343. # code...
  344. break;
  345. }
  346. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  347. }
  348. try {
  349. // 假设 ViolationProductModel 中有 city 字段,表示城市信息
  350. // 查询指定时间范围内的数据,并按 city 分组统计数量
  351. $result = $violationProductModel->where($map)->where('status', 0)
  352. ->select(['city_name', DB::raw('count(city_name) as count')])
  353. ->groupby('city_name')
  354. ->orderby('count', 'desc')
  355. ->get()->toarray();
  356. $city_totle_count = 0;
  357. if(!empty($result)){
  358. $city_totle_count = array_sum(array_column($result->toarray(), 'count'));
  359. //计算占比
  360. foreach ($result as $key => $value) {
  361. $result[$key]['percent'] = round(($value['count'] / $city_totle_count) * 100, 2);
  362. }
  363. }
  364. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  365. } catch (\Exception $e) {
  366. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  367. }
  368. }
  369. /**
  370. * 禁止挂网公司数统计
  371. * @author 唐远望
  372. * @version 1.0
  373. * @date 2026-02-10
  374. *
  375. */
  376. public function get_violation_company_count(request $request, ViolationProductModel $violationProductModel)
  377. {
  378. $request->scene('get_violation_company_count')->validate();
  379. $admin_company_id = request('admin_company_id', '0');
  380. $company_id = request('access_token.company_id', '0');
  381. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  382. //终端类型B端、C端、OTO
  383. $terminal_type = request('terminal_type', '');
  384. $limit = request('limit', config('page_num', 10));
  385. $product_name = request('product_name', ''); //商品名称
  386. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  387. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  388. $start_time_string = request('start_time', '');
  389. $end_time_string = request('end_time', '');
  390. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  391. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  392. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  393. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  394. // 时间条件
  395. $map = [];
  396. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  397. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  398. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  399. // 权限判断
  400. if ($is_admin != 1 && $company_id != 0) {
  401. $map[] = ['company_id', '=', $company_id];
  402. } else {
  403. $map[] = ['company_id', '=', $admin_company_id];
  404. }
  405. $violationProductModel = $violationProductModel->query();
  406. if ($terminal_type) {
  407. $platform = [];
  408. switch ($terminal_type) {
  409. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  410. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  411. break;
  412. case '2': //C端:美团、拼多多、天猫、京东
  413. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  414. break;
  415. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  416. $platform = ['0'];
  417. break;
  418. default:
  419. # code...
  420. break;
  421. }
  422. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  423. }
  424. $result = $violationProductModel->where($map)->where('status', 0)
  425. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  426. ->paginate($limit);
  427. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  428. }
  429. /*
  430. * 低价违规商品数统计
  431. * @author 唐远望
  432. * @version 1.0
  433. * @date 2026-02-10
  434. *
  435. */
  436. public function get_low_price_product_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  437. {
  438. $request->scene('get_low_price_product_count')->validate();
  439. $admin_company_id = request('admin_company_id', '0');
  440. $company_id = request('access_token.company_id', '0');
  441. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  442. //终端类型B端、C端、OTO
  443. $terminal_type = request('terminal_type', '');
  444. $limit = request('limit', config('page_num', 10));
  445. $product_name = request('product_name', ''); //商品名称
  446. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  447. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  448. $start_time_string = request('start_time', '');
  449. $end_time_string = request('end_time', '');
  450. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  451. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  452. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  453. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  454. // 时间条件
  455. $map = [];
  456. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  457. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  458. // 权限判断
  459. if ($is_admin != 1 && $company_id != 0) {
  460. $map[] = ['company_id', '=', $company_id];
  461. } else {
  462. $map[] = ['company_id', '=', $admin_company_id];
  463. }
  464. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  465. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  466. if ($terminal_type) {
  467. $platform = [];
  468. switch ($terminal_type) {
  469. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  470. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  471. break;
  472. case '2': //C端:美团、拼多多、天猫、京东
  473. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  474. break;
  475. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  476. $platform = ['0'];
  477. break;
  478. default:
  479. # code...
  480. break;
  481. }
  482. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  483. }
  484. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  485. ->select(['product_name', DB::raw('count(product_name) as count')])->distinct('product_name')->orderby('count', 'desc')
  486. ->groupby('product_name')->paginate($limit);
  487. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  488. }
  489. /*
  490. * 低价违规公司数统计
  491. * @author 唐远望
  492. * @version 1.0
  493. * @date 2026-02-10
  494. *
  495. */
  496. public function get_low_price_company_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  497. {
  498. $request->scene('get_low_price_company_count')->validate();
  499. $admin_company_id = request('admin_company_id', '0');
  500. $company_id = request('access_token.company_id', '0');
  501. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  502. //终端类型B端、C端、OTO
  503. $terminal_type = request('terminal_type', '');
  504. $limit = request('limit', config('page_num', 10));
  505. $product_name = request('product_name', ''); //商品名称
  506. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  507. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  508. $start_time_string = request('start_time', '');
  509. $end_time_string = request('end_time', '');
  510. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  511. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  512. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  513. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  514. // 时间条件
  515. $map = [];
  516. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  517. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  518. // 权限判断
  519. if ($is_admin != 1 && $company_id != 0) {
  520. $map[] = ['company_id', '=', $company_id];
  521. } else {
  522. $map[] = ['company_id', '=', $admin_company_id];
  523. }
  524. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  525. if ($terminal_type) {
  526. $platform = [];
  527. switch ($terminal_type) {
  528. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  529. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  530. break;
  531. case '2': //C端:美团、拼多多、天猫、京东
  532. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  533. break;
  534. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  535. $platform = ['0'];
  536. break;
  537. default:
  538. # code...
  539. break;
  540. }
  541. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  542. }
  543. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  544. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  545. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  546. ->paginate($limit);
  547. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  548. }
  549. /**
  550. * 低价挂网省份统计
  551. * @author 唐远望
  552. * @version 1.0
  553. * @date 2026-02-10
  554. *
  555. */
  556. public function get_low_price_province_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  557. {
  558. $request->scene('get_low_price_province_count')->validate();
  559. $admin_company_id = request('admin_company_id', '0');
  560. $company_id = request('access_token.company_id', '0');
  561. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  562. //终端类型B端、C端、OTO
  563. $terminal_type = request('terminal_type', '');
  564. $product_name = request('product_name', ''); //商品名称
  565. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  566. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  567. $start_time_string = request('start_time', '');
  568. $end_time_string = request('end_time', '');
  569. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  570. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  571. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  572. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  573. // 时间条件
  574. $map = [];
  575. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  576. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  577. // 权限判断
  578. if ($is_admin != 1 && $company_id != 0) {
  579. $map[] = ['company_id', '=', $company_id];
  580. } else {
  581. $map[] = ['company_id', '=', $admin_company_id];
  582. }
  583. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  584. // 禁止挂网省份统计
  585. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  586. if ($terminal_type) {
  587. $platform = [];
  588. switch ($terminal_type) {
  589. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  590. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  591. break;
  592. case '2': //C端:美团、拼多多、天猫、京东
  593. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  594. break;
  595. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  596. $platform = ['0'];
  597. break;
  598. default:
  599. # code...
  600. break;
  601. }
  602. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  603. }
  604. try {
  605. // 假设 LowPriceGoodsModel 中有 province 字段,表示省份信息
  606. // 查询指定时间范围内的数据,并按 province 分组统计数量
  607. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  608. ->select(['province_name', DB::raw('count(province_name) as count')])
  609. ->groupby('province_name')
  610. ->orderby('count', 'desc')
  611. ->get()->toarray();
  612. $province_totle_count = 0;
  613. if (!empty($result)) {
  614. $province_totle_count = array_sum(array_column($result->toarray(), 'count'));
  615. foreach ($result as $key => $value) {
  616. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  617. }
  618. }
  619. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  620. } catch (\Exception $e) {
  621. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  622. }
  623. }
  624. /**
  625. * 低价挂网城市统计
  626. * @author 唐远望
  627. * @version 1.0
  628. * @date 2026-02-10
  629. *
  630. */
  631. public function get_low_price_city_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  632. {
  633. $request->scene('get_low_price_city_count')->validate();
  634. $admin_company_id = request('admin_company_id', '0');
  635. $company_id = request('access_token.company_id', '0');
  636. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  637. //终端类型B端、C端、OTO
  638. $terminal_type = request('terminal_type', '');
  639. $product_name = request('product_name', ''); //商品名称
  640. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  641. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  642. $start_time_string = request('start_time', '');
  643. $end_time_string = request('end_time', '');
  644. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  645. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  646. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  647. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  648. // 时间条件
  649. $map = [];
  650. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  651. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  652. // 权限判断
  653. if ($is_admin != 1 && $company_id != 0) {
  654. $map[] = ['company_id', '=', $company_id];
  655. } else {
  656. $map[] = ['company_id', '=', $admin_company_id];
  657. }
  658. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  659. // 禁止挂网城市统计
  660. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  661. if ($terminal_type) {
  662. $platform = [];
  663. switch ($terminal_type) {
  664. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  665. $platform = ['0', '5', '6', '7', '8', '9', '10']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  666. break;
  667. case '2': //C端:美团、拼多多、天猫、京东
  668. $platform = ['0', '1', '2', '3', '4']; //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药
  669. break;
  670. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  671. $platform = ['0'];
  672. break;
  673. default:
  674. # code...
  675. break;
  676. }
  677. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  678. }
  679. try {
  680. // 假设 LowPriceGoodsModel 中有 city 字段,表示城市信息
  681. // 查询指定时间范围内的数据,并按 city 分组统计数量
  682. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  683. ->select(['city_name', DB::raw('count(city_name) as count')])
  684. ->groupby('city_name')
  685. ->orderby('count', 'desc')
  686. ->get()->toarray();
  687. $city_totle_count = 0;
  688. if (!empty($result)) {
  689. $city_totle_count = array_sum(array_column($result->toarray(), 'count'));
  690. foreach ($result as $key => $value) {
  691. $result[$key]['percent'] = round(($value['count'] / $city_totle_count) * 100, 2);
  692. }
  693. }
  694. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  695. } catch (\Exception $e) {
  696. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  697. }
  698. }
  699. }