BasicPanel.php 84 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554
  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. use App\Models\Manager\Collect\ProductTask as ProductTaskModel;
  12. /**
  13. * 数据分析-基础概览面板
  14. * @author 唐远望
  15. * @version 1.0
  16. * @date 2026-02-10
  17. *
  18. */
  19. class BasicPanel extends Controller
  20. {
  21. /*
  22. * 挂网数据统计
  23. * @author 唐远望
  24. * @version 1.0
  25. * @date 2026-02-10
  26. *
  27. */
  28. public function get_online_goods_count(request $request, LowPriceGoodsModel $lowPriceGoodsModel, ViolationProductModel $violationProductModel, ViolationStoreModel $violationStoreModel, ProductModel $productModel)
  29. {
  30. $request->scene('get_online_goods_count')->validate();
  31. $admin_company_id = request('admin_company_id', '0');
  32. $company_id = request('access_token.company_id', '0');
  33. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  34. $product_name = request('product_name', ''); //商品名称
  35. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  36. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  37. $start_time_string = request('start_time', '');
  38. $end_time_string = request('end_time', '');
  39. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  40. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  41. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  42. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  43. // 时间条件
  44. $map = [];
  45. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  46. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  47. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  48. // 统计挂网商品数量=低价挂网商品数量(去重)+ 禁止挂网商品数量(去重)
  49. $lowPriceGoodsModel = $lowPriceGoodsModel->query();
  50. $violationProductModel = $violationProductModel->query();
  51. if ($is_admin != 1 && $company_id != 0) {
  52. $lowPriceGoodsModel = $lowPriceGoodsModel->where('company_id', $company_id);
  53. $violationProductModel = $violationProductModel->where('company_id', $company_id);
  54. $violationStoreModel = $violationStoreModel->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. }
  60. //获取采集商品数量
  61. $collect_statistics_data = $this->get_product_count($start_time, $end_time, $product_name, $is_admin, $company_id, $admin_company_id);
  62. // 低价挂网商品数量查询
  63. $lowPriceGoodsCount = $lowPriceGoodsModel->where($map)
  64. ->where('status', 0)
  65. ->get()->count();
  66. // 禁止挂网商品数量查询
  67. $violationProductCount = $violationProductModel->where($map)
  68. ->where('status', 0)
  69. ->get()->count();
  70. $store_map = [];
  71. if ($start_time) $store_map[] = ['insert_time', '>=', $start_time];
  72. if ($end_time) $store_map[] = ['insert_time', '<=', $end_time];
  73. // 违规店铺数量查询
  74. $violationStoreCount = $violationStoreModel->where($store_map)
  75. ->where('status', 0)
  76. ->groupBy('store_name')
  77. ->select('store_name')
  78. ->get()->count();
  79. $result_data = [
  80. 'low_price_goods_count' => $lowPriceGoodsCount, // 低价挂网商品数量
  81. 'violation_product_count' => $violationProductCount, // 禁止挂网商品数量
  82. 'violation_store_count' => $violationStoreCount, // 违规店铺数量
  83. 'totle_product_count' => $lowPriceGoodsCount + $violationProductCount, // 总商品数量
  84. ];
  85. $result_data = array_merge($result_data, $collect_statistics_data);
  86. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result_data]);
  87. }
  88. /**
  89. * 品规数量统计
  90. * @author 唐远望
  91. * @version 1.0
  92. * @date 2026-02-10
  93. *
  94. */
  95. private function get_product_count($start_time, $end_time, $product_name, $is_admin, $company_id, $admin_company_id)
  96. {
  97. $ProductTaskModel = new ProductTaskModel();
  98. $select_company_id = 0;
  99. if ($is_admin != 1 && $company_id != 0) {
  100. $select_company_id = $company_id;
  101. } else {
  102. $select_company_id = $admin_company_id;
  103. }
  104. $map = [];
  105. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  106. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  107. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  108. //获取B端品规数量
  109. //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  110. $collect_b_product_count = 0;
  111. $collect_b_product_list_data = $ProductTaskModel
  112. ->whereIn('platform',['0', '5', '6', '7', '8', '9', '10'])//1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  113. ->where('company_id', $select_company_id)
  114. ->where($map)
  115. ->get()->toarray();
  116. $collect_b_product_list =[];
  117. if(!empty($collect_b_product_list_data)){
  118. foreach ($collect_b_product_list_data as $key => $value) {
  119. $collect_b_product_name =trim($value['product_brand'].'_'. $value['product_name']);
  120. $collect_b_product_specs = $value['product_specs'] !='' ? explode(',', $value['product_specs']) : [];
  121. if(isset($collect_b_product_list[$collect_b_product_name])){
  122. $collect_b_product_list[$collect_b_product_name] = array_merge($collect_b_product_list[$collect_b_product_name],$collect_b_product_specs);
  123. }else{
  124. $collect_b_product_list[$collect_b_product_name] = $collect_b_product_specs;
  125. }
  126. //去重$collect_b_product_list[$collect_b_product_name]数据
  127. $collect_b_product_list[$collect_b_product_name] =count($collect_b_product_list[$collect_b_product_name]) > 0 ? array_unique($collect_b_product_list[$collect_b_product_name]):[];
  128. }
  129. }
  130. //计算B端品规数量
  131. if(!empty($collect_b_product_list)){
  132. foreach ($collect_b_product_list as $key => $value) {
  133. if(empty($value)) $value = ['全量采集'];
  134. $collect_b_product_count = $collect_b_product_count + count($value);
  135. }
  136. }
  137. //获取C端品规数量
  138. //C端:美团、拼多多、天猫、京东、药房网
  139. $collect_c_product_count = 0;
  140. $collect_c_product_list_data = $ProductTaskModel
  141. ->whereIn('platform',['0', '1', '2', '3', '4', '11'])//1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  142. ->where('company_id', $select_company_id)
  143. ->where($map)
  144. ->get()->toarray();
  145. $collect_c_product_list =[];
  146. if(!empty($collect_c_product_list_data)){
  147. foreach ($collect_c_product_list_data as $key => $value) {
  148. $collect_c_product_name = trim($value['product_brand'].'_'. $value['product_name']);
  149. $collect_c_product_specs = $value['product_specs'] !='' ? explode(',', $value['product_specs']) : [];
  150. if(isset($collect_c_product_list[$collect_c_product_name])){
  151. $collect_c_product_list[$collect_c_product_name] = array_merge($collect_c_product_list[$collect_c_product_name],$collect_c_product_specs);
  152. }else{
  153. $collect_c_product_list[$collect_c_product_name] = $collect_c_product_specs;
  154. }
  155. //去重$collect_c_product_list[$collect_c_product_name]数据
  156. $collect_c_product_list[$collect_c_product_name] = count($collect_c_product_list[$collect_c_product_name]) > 0 ? array_unique($collect_c_product_list[$collect_c_product_name]):[];
  157. }
  158. }
  159. //计算C端品规数量
  160. if(!empty($collect_c_product_list)){
  161. foreach ($collect_c_product_list as $key => $value) {
  162. if(empty($value)) $value = ['全量采集'];
  163. $collect_c_product_count = $collect_c_product_count + count($value);
  164. }
  165. }
  166. //获取所有终端品规数量
  167. $collect_totle_product_count = $collect_b_product_count + $collect_c_product_count;
  168. $result_data = [
  169. 'collect_b_product_count' => $collect_b_product_count, // B端品规数量
  170. 'collect_c_product_count' => $collect_c_product_count, // C端品规数量
  171. 'collect_oto_product_count' => 0, // OTO品规数量
  172. 'collect_totle_product_count' => $collect_totle_product_count, // 所有终端品规数量
  173. 'collect_c_product_data' => $collect_c_product_list, // C端品规数据
  174. 'collect_b_product_data' => $collect_b_product_list, // B端品规数据
  175. ];
  176. return $result_data;
  177. }
  178. /**
  179. * 禁止挂网商品数统计
  180. * @author 唐远望
  181. * @version 1.0
  182. * @date 2026-02-10
  183. *
  184. */
  185. public function get_violation_product_count(request $request, ViolationProductModel $violationProductModel)
  186. {
  187. $request->scene('get_violation_product_count')->validate();
  188. $admin_company_id = request('admin_company_id', '0');
  189. $company_id = request('access_token.company_id', '0');
  190. //终端类型B端、C端、OTO
  191. $terminal_type = request('terminal_type', '');
  192. $product_name = request('product_name', ''); //商品名称
  193. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  194. $limit = request('limit', config('page_num', 10));
  195. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  196. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  197. $start_time_string = request('start_time', '');
  198. $end_time_string = request('end_time', '');
  199. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  200. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  201. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  202. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  203. // 时间条件
  204. $map = [];
  205. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  206. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  207. // 权限判断
  208. if ($is_admin != 1 && $company_id != 0) {
  209. $map[] = ['company_id', '=', $company_id];
  210. } else {
  211. $map[] = ['company_id', '=', $admin_company_id];
  212. }
  213. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  214. $violationProductModel = $violationProductModel->query();
  215. if ($terminal_type) {
  216. $platform = [];
  217. switch ($terminal_type) {
  218. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  219. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  220. break;
  221. case '2': //C端:美团、拼多多、天猫、京东、药房网
  222. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  223. break;
  224. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  225. $platform = ['0'];
  226. break;
  227. default:
  228. # code...
  229. break;
  230. }
  231. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  232. }
  233. $result = $violationProductModel->where($map)->where('status', 0)
  234. ->select(['product_name', DB::raw('count(product_name) as count')])->distinct('product_name')->orderby('count', 'desc')
  235. ->groupby('product_name')->paginate($limit);
  236. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  237. }
  238. /**
  239. * 禁止挂网省份统计
  240. * @author 唐远望
  241. * @version 1.0
  242. * @date 2026-02-10
  243. *
  244. */
  245. public function get_violation_province_count(request $request, ViolationProductModel $violationProductModel)
  246. {
  247. $request->scene('get_violation_province_count')->validate();
  248. $admin_company_id = request('admin_company_id', '0');
  249. $company_id = request('access_token.company_id', '0');
  250. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  251. //终端类型B端、C端、OTO
  252. $terminal_type = request('terminal_type', '');
  253. $product_name = request('product_name', ''); //商品名称
  254. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  255. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  256. $start_time_string = request('start_time', '');
  257. $end_time_string = request('end_time', '');
  258. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  259. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  260. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  261. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  262. // 时间条件
  263. $map = [];
  264. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  265. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  266. // 权限判断
  267. if ($is_admin != 1 && $company_id != 0) {
  268. $map[] = ['company_id', '=', $company_id];
  269. } else {
  270. $map[] = ['company_id', '=', $admin_company_id];
  271. }
  272. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  273. // 禁止挂网省份统计
  274. $violationProductModel = $violationProductModel->query();
  275. if ($terminal_type) {
  276. $platform = [];
  277. switch ($terminal_type) {
  278. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  279. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  280. break;
  281. case '2': //C端:美团、拼多多、天猫、京东、药房网
  282. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  283. break;
  284. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  285. $platform = ['0'];
  286. break;
  287. default:
  288. # code...
  289. break;
  290. }
  291. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  292. }
  293. try {
  294. // 假设 ViolationProductModel 中有 province 字段,表示省份信息
  295. // 查询指定时间范围内的数据,并按 province 分组统计数量
  296. $result = $violationProductModel->where($map)->where('status', 0)
  297. ->select(['province_name', DB::raw('count(province_name) as count')])
  298. ->groupby('province_name')
  299. ->orderby('count', 'desc')
  300. ->get()->toArray();
  301. $province_totle_count = 0;
  302. if (!empty($result)) {
  303. $province_totle_count = array_sum(array_column($result, 'count'));
  304. //计算占比
  305. foreach ($result as $key => $value) {
  306. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  307. }
  308. }
  309. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  310. } catch (\Exception $e) {
  311. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  312. }
  313. }
  314. /**
  315. * 禁止挂网城市统计
  316. * @author 唐远望
  317. * @version 1.0
  318. * @date 2026-02-10
  319. *
  320. */
  321. public function get_violation_city_count(request $request, ViolationProductModel $violationProductModel)
  322. {
  323. $request->scene('get_violation_city_count')->validate();
  324. $admin_company_id = request('admin_company_id', '0');
  325. $company_id = request('access_token.company_id', '0');
  326. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  327. //终端类型B端、C端、OTO
  328. $province_id = request('province_id', ''); //省份ID
  329. $terminal_type = request('terminal_type', '');
  330. $product_name = request('product_name', ''); //商品名称
  331. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  332. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  333. $start_time_string = request('start_time', '');
  334. $end_time_string = request('end_time', '');
  335. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  336. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  337. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  338. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  339. // 时间条件
  340. $map = [];
  341. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  342. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  343. // 权限判断
  344. if ($is_admin != 1 && $company_id != 0) {
  345. $map[] = ['company_id', '=', $company_id];
  346. } else {
  347. $map[] = ['company_id', '=', $admin_company_id];
  348. }
  349. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  350. if ($province_id) $map[] = ['province_id', '=', $province_id];
  351. // 禁止挂网城市统计
  352. $violationProductModel = $violationProductModel->query();
  353. if ($terminal_type) {
  354. $platform = [];
  355. switch ($terminal_type) {
  356. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  357. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  358. break;
  359. case '2': //C端:美团、拼多多、天猫、京东、药房网
  360. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  361. break;
  362. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  363. $platform = ['0'];
  364. break;
  365. default:
  366. # code...
  367. break;
  368. }
  369. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  370. }
  371. try {
  372. // 假设 ViolationProductModel 中有 city 字段,表示城市信息
  373. // 查询指定时间范围内的数据,并按 city 分组统计数量
  374. $result = $violationProductModel->where($map)->where('status', 0)
  375. ->select(['city_name', DB::raw('count(city_name) as count')])
  376. ->groupby('city_name')
  377. ->orderby('count', 'desc')
  378. ->get()->toArray();
  379. $city_totle_count = 0;
  380. if (!empty($result)) {
  381. $city_totle_count = array_sum(array_column($result, 'count'));
  382. //计算占比
  383. foreach ($result as $key => $value) {
  384. $result[$key]['percent'] = round(($value['count'] / $city_totle_count) * 100, 2);
  385. }
  386. }
  387. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  388. } catch (\Exception $e) {
  389. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  390. }
  391. }
  392. /**
  393. * 禁止挂网公司数统计
  394. * @author 唐远望
  395. * @version 1.0
  396. * @date 2026-02-10
  397. *
  398. */
  399. public function get_violation_company_count(request $request, ViolationProductModel $violationProductModel)
  400. {
  401. $request->scene('get_violation_company_count')->validate();
  402. $admin_company_id = request('admin_company_id', '0');
  403. $company_id = request('access_token.company_id', '0');
  404. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  405. //终端类型B端、C端、OTO
  406. $terminal_type = request('terminal_type', '');
  407. $limit = request('limit', config('page_num', 10));
  408. $product_name = request('product_name', ''); //商品名称
  409. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  410. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  411. $start_time_string = request('start_time', '');
  412. $end_time_string = request('end_time', '');
  413. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  414. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  415. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  416. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  417. // 时间条件
  418. $map = [];
  419. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  420. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  421. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  422. // 权限判断
  423. if ($is_admin != 1 && $company_id != 0) {
  424. $map[] = ['company_id', '=', $company_id];
  425. } else {
  426. $map[] = ['company_id', '=', $admin_company_id];
  427. }
  428. $violationProductModel = $violationProductModel->query();
  429. if ($terminal_type) {
  430. $platform = [];
  431. switch ($terminal_type) {
  432. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  433. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  434. break;
  435. case '2': //C端:美团、拼多多、天猫、京东、药房网
  436. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  437. break;
  438. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  439. $platform = ['0'];
  440. break;
  441. default:
  442. # code...
  443. break;
  444. }
  445. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  446. }
  447. $result = $violationProductModel->where($map)->where('status', 0)
  448. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  449. ->paginate($limit);
  450. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  451. }
  452. /*
  453. * 低价违规商品数统计
  454. * @author 唐远望
  455. * @version 1.0
  456. * @date 2026-02-10
  457. *
  458. */
  459. public function get_low_price_product_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  460. {
  461. $request->scene('get_low_price_product_count')->validate();
  462. $admin_company_id = request('admin_company_id', '0');
  463. $company_id = request('access_token.company_id', '0');
  464. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  465. //终端类型B端、C端、OTO
  466. $terminal_type = request('terminal_type', '');
  467. $limit = request('limit', config('page_num', 10));
  468. $product_name = request('product_name', ''); //商品名称
  469. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  470. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  471. $start_time_string = request('start_time', '');
  472. $end_time_string = request('end_time', '');
  473. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  474. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  475. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  476. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  477. // 时间条件
  478. $map = [];
  479. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  480. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  481. // 权限判断
  482. if ($is_admin != 1 && $company_id != 0) {
  483. $map[] = ['company_id', '=', $company_id];
  484. } else {
  485. $map[] = ['company_id', '=', $admin_company_id];
  486. }
  487. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  488. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  489. if ($terminal_type) {
  490. $platform = [];
  491. switch ($terminal_type) {
  492. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  493. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  494. break;
  495. case '2': //C端:美团、拼多多、天猫、京东、药房网
  496. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  497. break;
  498. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  499. $platform = ['0'];
  500. break;
  501. default:
  502. # code...
  503. break;
  504. }
  505. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  506. }
  507. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  508. ->select(['product_name', DB::raw('count(product_name) as count')])->distinct('product_name')->orderby('count', 'desc')
  509. ->groupby('product_name')->paginate($limit);
  510. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  511. }
  512. /*
  513. * 低价违规公司数统计
  514. * @author 唐远望
  515. * @version 1.0
  516. * @date 2026-02-10
  517. *
  518. */
  519. public function get_low_price_company_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  520. {
  521. $request->scene('get_low_price_company_count')->validate();
  522. $admin_company_id = request('admin_company_id', '0');
  523. $company_id = request('access_token.company_id', '0');
  524. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  525. //终端类型B端、C端、OTO
  526. $terminal_type = request('terminal_type', '');
  527. $limit = request('limit', config('page_num', 10));
  528. $product_name = request('product_name', ''); //商品名称
  529. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  530. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  531. $start_time_string = request('start_time', '');
  532. $end_time_string = request('end_time', '');
  533. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  534. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  535. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  536. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  537. // 时间条件
  538. $map = [];
  539. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  540. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  541. // 权限判断
  542. if ($is_admin != 1 && $company_id != 0) {
  543. $map[] = ['company_id', '=', $company_id];
  544. } else {
  545. $map[] = ['company_id', '=', $admin_company_id];
  546. }
  547. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  548. if ($terminal_type) {
  549. $platform = [];
  550. switch ($terminal_type) {
  551. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  552. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  553. break;
  554. case '2': //C端:美团、拼多多、天猫、京东、药房网
  555. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  556. break;
  557. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  558. $platform = ['0'];
  559. break;
  560. default:
  561. # code...
  562. break;
  563. }
  564. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  565. }
  566. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  567. $map[] = ['company_name', '!=', ''];
  568. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  569. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  570. ->paginate($limit);
  571. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  572. }
  573. /**
  574. * 低价挂网省份统计
  575. * @author 唐远望
  576. * @version 1.0
  577. * @date 2026-02-10
  578. *
  579. */
  580. public function get_low_price_province_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  581. {
  582. $request->scene('get_low_price_province_count')->validate();
  583. $admin_company_id = request('admin_company_id', '0');
  584. $company_id = request('access_token.company_id', '0');
  585. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  586. //终端类型B端、C端、OTO
  587. $terminal_type = request('terminal_type', '');
  588. $product_name = request('product_name', ''); //商品名称
  589. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  590. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  591. $start_time_string = request('start_time', '');
  592. $end_time_string = request('end_time', '');
  593. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  594. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  595. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  596. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  597. // 时间条件
  598. $map = [];
  599. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  600. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  601. // 权限判断
  602. if ($is_admin != 1 && $company_id != 0) {
  603. $map[] = ['company_id', '=', $company_id];
  604. } else {
  605. $map[] = ['company_id', '=', $admin_company_id];
  606. }
  607. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  608. // 禁止挂网省份统计
  609. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  610. if ($terminal_type) {
  611. $platform = [];
  612. switch ($terminal_type) {
  613. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  614. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  615. break;
  616. case '2': //C端:美团、拼多多、天猫、京东、药房网
  617. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  618. break;
  619. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  620. $platform = ['0'];
  621. break;
  622. default:
  623. # code...
  624. break;
  625. }
  626. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  627. }
  628. try {
  629. // 假设 LowPriceGoodsModel 中有 province 字段,表示省份信息
  630. // 查询指定时间范围内的数据,并按 province 分组统计数量
  631. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  632. ->select(['province_name', DB::raw('count(province_name) as count')])
  633. ->groupby('province_name')
  634. ->orderby('count', 'desc')
  635. ->get()->toArray();
  636. $province_totle_count = 0;
  637. if (!empty($result)) {
  638. $province_totle_count = array_sum(array_column($result, 'count'));
  639. foreach ($result as $key => $value) {
  640. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  641. }
  642. }
  643. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  644. } catch (\Exception $e) {
  645. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  646. }
  647. }
  648. /**
  649. * 低价挂网城市统计
  650. * @author 唐远望
  651. * @version 1.0
  652. * @date 2026-02-10
  653. *
  654. */
  655. public function get_low_price_city_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  656. {
  657. $request->scene('get_low_price_city_count')->validate();
  658. $admin_company_id = request('admin_company_id', '0');
  659. $company_id = request('access_token.company_id', '0');
  660. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  661. //终端类型B端、C端、OTO
  662. $province_id = request('province_id', ''); //省份id
  663. $terminal_type = request('terminal_type', '');
  664. $product_name = request('product_name', ''); //商品名称
  665. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  666. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  667. $start_time_string = request('start_time', '');
  668. $end_time_string = request('end_time', '');
  669. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  670. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  671. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  672. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  673. // 时间条件
  674. $map = [];
  675. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  676. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  677. // 权限判断
  678. if ($is_admin != 1 && $company_id != 0) {
  679. $map[] = ['company_id', '=', $company_id];
  680. } else {
  681. $map[] = ['company_id', '=', $admin_company_id];
  682. }
  683. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  684. if ($province_id) $map[] = ['province_id', '=', $province_id];
  685. // 禁止挂网城市统计
  686. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  687. if ($terminal_type) {
  688. $platform = [];
  689. switch ($terminal_type) {
  690. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  691. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  692. break;
  693. case '2': //C端:美团、拼多多、天猫、京东、药房网
  694. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  695. break;
  696. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  697. $platform = ['0'];
  698. break;
  699. default:
  700. # code...
  701. break;
  702. }
  703. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  704. }
  705. try {
  706. // 假设 LowPriceGoodsModel 中有 city 字段,表示城市信息
  707. // 查询指定时间范围内的数据,并按 city 分组统计数量
  708. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  709. ->select(['city_name', DB::raw('count(city_name) as count')])
  710. ->groupby('city_name')
  711. ->orderby('count', 'desc')
  712. ->get()->toArray();
  713. $city_totle_count = 0;
  714. if (!empty($result)) {
  715. $city_totle_count = array_sum(array_column($result, 'count'));
  716. foreach ($result as $key => $value) {
  717. $result[$key]['percent'] = round(($value['count'] / $city_totle_count) * 100, 2);
  718. }
  719. }
  720. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  721. } catch (\Exception $e) {
  722. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  723. }
  724. }
  725. /**
  726. * 低价挂网平台分布
  727. * @author 唐远望
  728. * @version 1.0
  729. * @date 2026-02-27
  730. *
  731. */
  732. public function get_low_price_platform_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  733. {
  734. $request->scene('get_low_price_platform_count')->validate();
  735. $admin_company_id = request('admin_company_id', '0');
  736. $company_id = request('access_token.company_id', '0');
  737. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  738. //终端类型B端、C端、OTO
  739. $terminal_type = request('terminal_type', '');
  740. $product_name = request('product_name', ''); //商品名称
  741. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  742. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  743. $start_time_string = request('start_time', '');
  744. $end_time_string = request('end_time', '');
  745. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  746. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  747. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  748. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  749. // 时间条件
  750. $map = [];
  751. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  752. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  753. // 权限判断
  754. if ($is_admin != 1 && $company_id != 0) {
  755. $map[] = ['company_id', '=', $company_id];
  756. } else {
  757. $map[] = ['company_id', '=', $admin_company_id];
  758. }
  759. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  760. // 禁止挂网平台分布统计
  761. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  762. if ($terminal_type) {
  763. $platform = [];
  764. switch ($terminal_type) {
  765. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  766. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  767. break;
  768. case '2': //C端:美团、拼多多、天猫、京东、药房网
  769. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  770. break;
  771. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  772. $platform = ['0'];
  773. break;
  774. default:
  775. # code...
  776. break;
  777. }
  778. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  779. }
  780. try {
  781. // 假设 LowPriceGoodsModel 中有 platform 字段,表示平台信息
  782. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  783. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  784. ->select(['platform', DB::raw('count(platform) as count')])
  785. ->groupby('platform')
  786. ->orderby('count', 'desc')
  787. ->get()->toArray();
  788. $platform_totle_count = 0;
  789. if (!empty($result)) {
  790. $platform_totle_count = array_sum(array_column($result, 'count'));
  791. foreach ($result as $key => $value) {
  792. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  793. }
  794. }
  795. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  796. } catch (\Exception $e) {
  797. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  798. }
  799. }
  800. /**
  801. * 低价挂网平台省份分布
  802. * @author 唐远望
  803. * @version 1.0
  804. * @date 2026-02-27
  805. *
  806. */
  807. public function get_low_price_platform_province_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  808. {
  809. $request->scene('get_low_price_platform_province_count')->validate();
  810. $admin_company_id = request('admin_company_id', '0');
  811. $company_id = request('access_token.company_id', '0');
  812. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  813. //终端类型B端、C端、OTO
  814. $terminal_type = request('terminal_type', '');
  815. $product_name = request('product_name', ''); //商品名称
  816. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  817. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  818. $start_time_string = request('start_time', '');
  819. $end_time_string = request('end_time', '');
  820. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  821. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  822. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  823. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  824. // 时间条件
  825. $map = [];
  826. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  827. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  828. // 权限判断
  829. if ($is_admin != 1 && $company_id != 0) {
  830. $map[] = ['company_id', '=', $company_id];
  831. } else {
  832. $map[] = ['company_id', '=', $admin_company_id];
  833. }
  834. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  835. // 禁止挂网平台分布统计
  836. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  837. if ($terminal_type) {
  838. $platform = [];
  839. switch ($terminal_type) {
  840. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  841. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  842. break;
  843. case '2': //C端:美团、拼多多、天猫、京东、药房网
  844. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  845. break;
  846. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  847. $platform = ['0'];
  848. break;
  849. default:
  850. # code...
  851. break;
  852. }
  853. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  854. }
  855. try {
  856. // 假设 LowPriceGoodsModel 中有 province 字段,表示省份信息
  857. // 查询指定时间范围内的数据,并按 province 分组统计数量
  858. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  859. ->select(['province_name', DB::raw('count(province_name) as count')])
  860. ->groupby('province_name')
  861. ->orderby('count', 'desc')
  862. ->get();
  863. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  864. } catch (\Exception $e) {
  865. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  866. }
  867. }
  868. /**
  869. * 禁止挂网平台分布
  870. * @author 唐远望
  871. * @version 1.0
  872. * @date 2026-02-27
  873. *
  874. */
  875. public function get_violation_platform_count(request $request, ViolationProductModel $violationProductModel)
  876. {
  877. $request->scene('get_violation_platform_count')->validate();
  878. $admin_company_id = request('admin_company_id', '0');
  879. $company_id = request('access_token.company_id', '0');
  880. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  881. //终端类型B端、C端、OTO
  882. $terminal_type = request('terminal_type', '');
  883. $product_name = request('product_name', ''); //商品名称
  884. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  885. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  886. $start_time_string = request('start_time', '');
  887. $end_time_string = request('end_time', '');
  888. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  889. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  890. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  891. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  892. // 时间条件
  893. $map = [];
  894. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  895. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  896. // 权限判断
  897. if ($is_admin != 1 && $company_id != 0) {
  898. $map[] = ['company_id', '=', $company_id];
  899. } else {
  900. $map[] = ['company_id', '=', $admin_company_id];
  901. }
  902. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  903. // 禁止挂网平台分布统计
  904. $violationProductModel = $violationProductModel->query();
  905. if ($terminal_type) {
  906. $platform = [];
  907. switch ($terminal_type) {
  908. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  909. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  910. break;
  911. case '2': //C端:美团、拼多多、天猫、京东、药房网
  912. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  913. break;
  914. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  915. $platform = ['0'];
  916. break;
  917. default:
  918. # code...
  919. break;
  920. }
  921. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  922. }
  923. try {
  924. // 假设 ViolationProductModel 中有 platform 字段,表示平台信息
  925. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  926. $result = $violationProductModel->where($map)->where('status', 0)
  927. ->select(['platform', DB::raw('count(platform) as count')])
  928. ->groupby('platform')
  929. ->orderby('count', 'desc')
  930. ->get()->toArray();
  931. $platform_totle_count = 0;
  932. if (!empty($result)) {
  933. $platform_totle_count = array_sum(array_column($result, 'count'));
  934. foreach ($result as $key => $value) {
  935. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  936. }
  937. }
  938. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  939. } catch (\Exception $e) {
  940. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  941. }
  942. }
  943. /**
  944. * 禁止挂网平台省份分布
  945. * @author 唐远望
  946. * @version 1.0
  947. * @date 2026-02-27
  948. *
  949. */
  950. public function get_violation_platform_province_count(request $request, ViolationProductModel $violationProductModel)
  951. {
  952. $request->scene('get_violation_platform_province_count')->validate();
  953. $admin_company_id = request('admin_company_id', '0');
  954. $company_id = request('access_token.company_id', '0');
  955. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  956. //终端类型B端、C端、OTO
  957. $terminal_type = request('terminal_type', '');
  958. $product_name = request('product_name', ''); //商品名称
  959. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  960. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  961. $start_time_string = request('start_time', '');
  962. $end_time_string = request('end_time', '');
  963. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  964. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  965. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  966. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  967. // 时间条件
  968. $map = [];
  969. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  970. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  971. // 权限判断
  972. if ($is_admin != 1 && $company_id != 0) {
  973. $map[] = ['company_id', '=', $company_id];
  974. } else {
  975. $map[] = ['company_id', '=', $admin_company_id];
  976. }
  977. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  978. // 禁止挂网平台分布统计
  979. $violationProductModel = $violationProductModel->query();
  980. if ($terminal_type) {
  981. $platform = [];
  982. switch ($terminal_type) {
  983. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  984. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  985. break;
  986. case '2': //C端:美团、拼多多、天猫、京东、药房网
  987. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  988. break;
  989. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  990. $platform = ['0'];
  991. break;
  992. default:
  993. # code...
  994. break;
  995. }
  996. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  997. }
  998. try {
  999. // 假设 ViolationProductModel 中有 platform 字段,表示平台信息
  1000. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  1001. $result = $violationProductModel->where($map)->where('status', 0)
  1002. ->select(['province_name', DB::raw('count(province_name) as count')])
  1003. ->groupby(['province_name'])
  1004. ->orderby('count', 'desc')
  1005. ->get();
  1006. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1007. } catch (\Exception $e) {
  1008. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1009. }
  1010. }
  1011. /**
  1012. * 违规公司平台占比
  1013. * @author 唐远望
  1014. * @version 1.0
  1015. * @date 2026-03-23
  1016. *
  1017. */
  1018. public function get_violation_company_platform_proportion(request $request, ViolationProductModel $violationProductModel)
  1019. {
  1020. $request->scene('get_violation_company_platform_proportion')->validate();
  1021. $admin_company_id = request('admin_company_id', '0');
  1022. $company_id = request('access_token.company_id', '0');
  1023. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1024. //终端类型B端、C端、OTO
  1025. $terminal_type = request('terminal_type', '');
  1026. $product_name = request('product_name', ''); //商品名称
  1027. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1028. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1029. $start_time_string = request('start_time', '');
  1030. $end_time_string = request('end_time', '');
  1031. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1032. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1033. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1034. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1035. // 时间条件
  1036. $map = [];
  1037. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1038. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1039. // 权限判断
  1040. if ($is_admin != 1 && $company_id != 0) {
  1041. $map[] = ['company_id', '=', $company_id];
  1042. } else {
  1043. $map[] = ['company_id', '=', $admin_company_id];
  1044. }
  1045. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  1046. // 禁止挂网平台分布统计
  1047. $violationProductModel = $violationProductModel->query();
  1048. if ($terminal_type) {
  1049. $platform = [];
  1050. switch ($terminal_type) {
  1051. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1052. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1053. break;
  1054. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1055. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1056. break;
  1057. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1058. $platform = ['0'];
  1059. break;
  1060. default:
  1061. # code...
  1062. break;
  1063. }
  1064. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  1065. }
  1066. try {
  1067. // 假设 LowPriceGoodsModel 中有 platform 字段,表示平台信息
  1068. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  1069. $result = $violationProductModel->where($map)->where('status', 0)
  1070. ->select(['platform', DB::raw('count(platform) as count')])
  1071. ->distinct('company_name')
  1072. ->groupby('platform')
  1073. ->orderby('count', 'desc')
  1074. ->get()->toArray();
  1075. $platform_totle_count = 0;
  1076. if (!empty($result)) {
  1077. $platform_totle_count = array_sum(array_column($result, 'count'));
  1078. foreach ($result as $key => $value) {
  1079. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  1080. }
  1081. }
  1082. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1083. } catch (\Exception $e) {
  1084. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1085. }
  1086. }
  1087. /**
  1088. * 违规店铺平台占比
  1089. * @author 唐远望
  1090. * @version 1.0
  1091. * @date 2026-03-23
  1092. *
  1093. */
  1094. public function get_violation_store_platform_proportion(request $request, ViolationStoreModel $ViolationStoreModel)
  1095. {
  1096. $request->scene('get_violation_store_platform_proportion')->validate();
  1097. $admin_company_id = request('admin_company_id', '0');
  1098. $company_id = request('access_token.company_id', '0');
  1099. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1100. //终端类型B端、C端、OTO
  1101. $terminal_type = request('terminal_type', '');
  1102. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1103. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1104. $start_time_string = request('start_time', '');
  1105. $end_time_string = request('end_time', '');
  1106. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1107. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1108. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1109. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1110. // 时间条件
  1111. $map = [];
  1112. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1113. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1114. // 权限判断
  1115. if ($is_admin != 1 && $company_id != 0) {
  1116. $map[] = ['company_id', '=', $company_id];
  1117. } else {
  1118. $map[] = ['company_id', '=', $admin_company_id];
  1119. }
  1120. // 禁止挂网平台分布统计
  1121. $ViolationStoreModel = $ViolationStoreModel->query();
  1122. if ($terminal_type) {
  1123. $platform = [];
  1124. switch ($terminal_type) {
  1125. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1126. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1127. break;
  1128. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1129. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1130. break;
  1131. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1132. $platform = ['0'];
  1133. break;
  1134. default:
  1135. # code...
  1136. break;
  1137. }
  1138. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1139. }
  1140. try {
  1141. // 假设 LowPriceGoodsModel 中有 platform 字段,表示平台信息
  1142. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  1143. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1144. ->select(['platform', DB::raw('count(platform) as count')])
  1145. ->groupby('platform')
  1146. ->orderby('count', 'desc')
  1147. ->get()->toArray();
  1148. $platform_totle_count = 0;
  1149. if (!empty($result)) {
  1150. $platform_totle_count = array_sum(array_column($result, 'count'));
  1151. foreach ($result as $key => $value) {
  1152. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  1153. }
  1154. }
  1155. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1156. } catch (\Exception $e) {
  1157. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1158. }
  1159. }
  1160. /**
  1161. * 违规店铺平台省份分布
  1162. * @author 唐远望
  1163. * @version 1.0
  1164. * @date 2026-03-23
  1165. *
  1166. */
  1167. public function get_violation_store_province_count(request $request, ViolationStoreModel $ViolationStoreModel)
  1168. {
  1169. $request->scene('get_violation_store_province_count')->validate();
  1170. $admin_company_id = request('admin_company_id', '0');
  1171. $company_id = request('access_token.company_id', '0');
  1172. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1173. //终端类型B端、C端、OTO
  1174. $terminal_type = request('terminal_type', '');
  1175. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1176. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1177. $start_time_string = request('start_time', '');
  1178. $end_time_string = request('end_time', '');
  1179. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1180. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1181. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1182. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1183. // 时间条件
  1184. $map = [];
  1185. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1186. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1187. // 权限判断
  1188. if ($is_admin != 1 && $company_id != 0) {
  1189. $map[] = ['company_id', '=', $company_id];
  1190. } else {
  1191. $map[] = ['company_id', '=', $admin_company_id];
  1192. }
  1193. // 违规公司平台分布统计
  1194. $ViolationStoreModel = $ViolationStoreModel->query();
  1195. if ($terminal_type) {
  1196. $platform = [];
  1197. switch ($terminal_type) {
  1198. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1199. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1200. break;
  1201. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1202. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1203. break;
  1204. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1205. $platform = ['0'];
  1206. break;
  1207. default:
  1208. # code...
  1209. break;
  1210. }
  1211. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1212. }
  1213. try {
  1214. // 假设 $violationProductModel 中有 province 字段,表示省份信息
  1215. // 查询指定时间范围内的数据,并按 province 分组统计数量
  1216. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1217. ->select(['province_name', DB::raw('count(province_name) as count')])
  1218. ->groupby('province_name')
  1219. ->orderby('count', 'desc')
  1220. ->get();
  1221. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1222. } catch (\Exception $e) {
  1223. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1224. }
  1225. }
  1226. /**
  1227. * 违规店铺省份统计占比
  1228. * @author 唐远望
  1229. * @version 1.0
  1230. * @date 2026-03-23
  1231. *
  1232. */
  1233. public function get_violation_store_province_proportion(request $request, ViolationStoreModel $ViolationStoreModel)
  1234. {
  1235. $request->scene('get_violation_store_province_proportion')->validate();
  1236. $admin_company_id = request('admin_company_id', '0');
  1237. $company_id = request('access_token.company_id', '0');
  1238. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1239. //终端类型B端、C端、OTO
  1240. $terminal_type = request('terminal_type', '');
  1241. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1242. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1243. $start_time_string = request('start_time', '');
  1244. $end_time_string = request('end_time', '');
  1245. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1246. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1247. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1248. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1249. // 时间条件
  1250. $map = [];
  1251. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1252. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1253. // 权限判断
  1254. if ($is_admin != 1 && $company_id != 0) {
  1255. $map[] = ['company_id', '=', $company_id];
  1256. } else {
  1257. $map[] = ['company_id', '=', $admin_company_id];
  1258. }
  1259. // 违规店铺省份统计
  1260. $ViolationStoreModel = $ViolationStoreModel->query();
  1261. if ($terminal_type) {
  1262. $platform = [];
  1263. switch ($terminal_type) {
  1264. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1265. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1266. break;
  1267. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1268. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1269. break;
  1270. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1271. $platform = ['0'];
  1272. break;
  1273. default:
  1274. # code...
  1275. break;
  1276. }
  1277. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1278. }
  1279. try {
  1280. // 假设 $ViolationStoreModel 中有 province 字段,表示省份信息
  1281. // 查询指定时间范围内的数据,并按 province 分组统计数量
  1282. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1283. ->select(['province_name', DB::raw('count(province_name) as count')])
  1284. ->groupby('province_name')
  1285. ->orderby('count', 'desc')
  1286. ->get()->toArray();
  1287. $province_totle_count = 0;
  1288. if (!empty($result)) {
  1289. $province_totle_count = array_sum(array_column($result, 'count'));
  1290. //计算占比
  1291. foreach ($result as $key => $value) {
  1292. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  1293. }
  1294. }
  1295. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1296. } catch (\Exception $e) {
  1297. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1298. }
  1299. }
  1300. /**
  1301. * 违规店铺城市统计占比
  1302. * @author 唐远望
  1303. * @version 1.0
  1304. * @date 2026-03-23
  1305. *
  1306. */
  1307. public function get_violation_store_city_proportion(request $request, ViolationStoreModel $ViolationStoreModel)
  1308. {
  1309. $request->scene('get_violation_store_city_proportion')->validate();
  1310. $admin_company_id = request('admin_company_id', '0');
  1311. $company_id = request('access_token.company_id', '0');
  1312. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1313. //终端类型B端、C端、OTO
  1314. $province_id = request('province_id', ''); //省份id
  1315. $terminal_type = request('terminal_type', '');
  1316. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1317. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1318. $start_time_string = request('start_time', '');
  1319. $end_time_string = request('end_time', '');
  1320. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1321. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1322. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1323. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1324. // 时间条件
  1325. $map = [];
  1326. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1327. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1328. if ($province_id) $map[] = ['province_id', '=', $province_id];
  1329. // 权限判断
  1330. if ($is_admin != 1 && $company_id != 0) {
  1331. $map[] = ['company_id', '=', $company_id];
  1332. } else {
  1333. $map[] = ['company_id', '=', $admin_company_id];
  1334. }
  1335. // 违规店铺省份统计
  1336. $ViolationStoreModel = $ViolationStoreModel->query();
  1337. if ($terminal_type) {
  1338. $platform = [];
  1339. switch ($terminal_type) {
  1340. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1341. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1342. break;
  1343. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1344. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1345. break;
  1346. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1347. $platform = ['0'];
  1348. break;
  1349. default:
  1350. # code...
  1351. break;
  1352. }
  1353. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1354. }
  1355. try {
  1356. // 假设 $ViolationStoreModel 中有 province 字段,表示省份信息
  1357. // 查询指定时间范围内的数据,并按 province 分组统计数量
  1358. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1359. ->select(['city_name', DB::raw('count(city_name) as count')])
  1360. ->distinct('company_name')
  1361. ->groupby('city_name')
  1362. ->orderby('count', 'desc')
  1363. ->get()->toArray();
  1364. $province_totle_count = 0;
  1365. if (!empty($result)) {
  1366. $province_totle_count = array_sum(array_column($result, 'count'));
  1367. //计算占比
  1368. foreach ($result as $key => $value) {
  1369. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  1370. }
  1371. }
  1372. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1373. } catch (\Exception $e) {
  1374. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1375. }
  1376. }
  1377. /*
  1378. * 低价挂网商品规格数统计排行
  1379. * @author 唐远望
  1380. * @version 1.0
  1381. * @date 2026-03-24
  1382. *
  1383. */
  1384. public function get_low_price_product_spec_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  1385. {
  1386. $request->scene('get_low_price_product_spec_count')->validate();
  1387. $admin_company_id = request('admin_company_id', '0');
  1388. $company_id = request('access_token.company_id', '0');
  1389. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1390. //终端类型B端、C端、OTO
  1391. $terminal_type = request('terminal_type', '');
  1392. $limit = request('limit', config('page_num', 10));
  1393. $product_name = request('product_name', ''); //商品名称
  1394. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1395. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1396. $start_time_string = request('start_time', '');
  1397. $end_time_string = request('end_time', '');
  1398. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1399. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1400. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1401. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1402. // 时间条件
  1403. $map = [];
  1404. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1405. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1406. // 权限判断
  1407. if ($is_admin != 1 && $company_id != 0) {
  1408. $map[] = ['company_id', '=', $company_id];
  1409. } else {
  1410. $map[] = ['company_id', '=', $admin_company_id];
  1411. }
  1412. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  1413. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  1414. if ($terminal_type) {
  1415. $platform = [];
  1416. switch ($terminal_type) {
  1417. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1418. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1419. break;
  1420. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1421. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1422. break;
  1423. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1424. $platform = ['0'];
  1425. break;
  1426. default:
  1427. # code...
  1428. break;
  1429. }
  1430. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  1431. }
  1432. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  1433. ->select(['product_name', 'product_specs', DB::raw('count(*) as count')])
  1434. ->groupby('product_name', 'product_specs')
  1435. ->orderby('count', 'desc')
  1436. ->paginate($limit);
  1437. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1438. }
  1439. /**
  1440. * 禁止挂网商品规格数统计排行
  1441. * @author 唐远望
  1442. * @version 1.0
  1443. * @date 2026-03-24
  1444. *
  1445. */
  1446. public function get_violation_product_spec_count(request $request, ViolationProductModel $violationProductModel)
  1447. {
  1448. $request->scene('get_violation_product_spec_count')->validate();
  1449. $admin_company_id = request('admin_company_id', '0');
  1450. $company_id = request('access_token.company_id', '0');
  1451. //终端类型B端、C端、OTO
  1452. $terminal_type = request('terminal_type', '');
  1453. $product_name = request('product_name', ''); //商品名称
  1454. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1455. $limit = request('limit', config('page_num', 10));
  1456. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1457. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1458. $start_time_string = request('start_time', '');
  1459. $end_time_string = request('end_time', '');
  1460. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1461. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1462. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1463. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1464. // 时间条件
  1465. $map = [];
  1466. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1467. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1468. // 权限判断
  1469. if ($is_admin != 1 && $company_id != 0) {
  1470. $map[] = ['company_id', '=', $company_id];
  1471. } else {
  1472. $map[] = ['company_id', '=', $admin_company_id];
  1473. }
  1474. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  1475. $violationProductModel = $violationProductModel->query();
  1476. if ($terminal_type) {
  1477. $platform = [];
  1478. switch ($terminal_type) {
  1479. case '1': //B端:药师帮、1药城、药九九、药易购、药帮忙、熊猫药药
  1480. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1481. break;
  1482. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1483. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1484. break;
  1485. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1486. $platform = ['0'];
  1487. break;
  1488. default:
  1489. # code...
  1490. break;
  1491. }
  1492. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  1493. }
  1494. $result = $violationProductModel->where($map)->where('status', 0)
  1495. ->select(['product_name', 'product_specs', DB::raw('count(*) as count')])
  1496. ->groupby('product_name', 'product_specs')
  1497. ->orderby('count', 'desc')
  1498. ->paginate($limit);
  1499. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1500. }
  1501. }