BasicPanel.php 84 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553
  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. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  568. ->select(['company_name', DB::raw('count(company_name) as count')])->groupby('company_name')->orderby('count', 'desc')
  569. ->paginate($limit);
  570. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  571. }
  572. /**
  573. * 低价挂网省份统计
  574. * @author 唐远望
  575. * @version 1.0
  576. * @date 2026-02-10
  577. *
  578. */
  579. public function get_low_price_province_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  580. {
  581. $request->scene('get_low_price_province_count')->validate();
  582. $admin_company_id = request('admin_company_id', '0');
  583. $company_id = request('access_token.company_id', '0');
  584. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  585. //终端类型B端、C端、OTO
  586. $terminal_type = request('terminal_type', '');
  587. $product_name = request('product_name', ''); //商品名称
  588. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  589. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  590. $start_time_string = request('start_time', '');
  591. $end_time_string = request('end_time', '');
  592. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  593. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  594. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  595. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  596. // 时间条件
  597. $map = [];
  598. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  599. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  600. // 权限判断
  601. if ($is_admin != 1 && $company_id != 0) {
  602. $map[] = ['company_id', '=', $company_id];
  603. } else {
  604. $map[] = ['company_id', '=', $admin_company_id];
  605. }
  606. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  607. // 禁止挂网省份统计
  608. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  609. if ($terminal_type) {
  610. $platform = [];
  611. switch ($terminal_type) {
  612. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  613. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  614. break;
  615. case '2': //C端:美团、拼多多、天猫、京东、药房网
  616. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  617. break;
  618. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  619. $platform = ['0'];
  620. break;
  621. default:
  622. # code...
  623. break;
  624. }
  625. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  626. }
  627. try {
  628. // 假设 LowPriceGoodsModel 中有 province 字段,表示省份信息
  629. // 查询指定时间范围内的数据,并按 province 分组统计数量
  630. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  631. ->select(['province_name', DB::raw('count(province_name) as count')])
  632. ->groupby('province_name')
  633. ->orderby('count', 'desc')
  634. ->get()->toArray();
  635. $province_totle_count = 0;
  636. if (!empty($result)) {
  637. $province_totle_count = array_sum(array_column($result, 'count'));
  638. foreach ($result as $key => $value) {
  639. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  640. }
  641. }
  642. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  643. } catch (\Exception $e) {
  644. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  645. }
  646. }
  647. /**
  648. * 低价挂网城市统计
  649. * @author 唐远望
  650. * @version 1.0
  651. * @date 2026-02-10
  652. *
  653. */
  654. public function get_low_price_city_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  655. {
  656. $request->scene('get_low_price_city_count')->validate();
  657. $admin_company_id = request('admin_company_id', '0');
  658. $company_id = request('access_token.company_id', '0');
  659. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  660. //终端类型B端、C端、OTO
  661. $province_id = request('province_id', ''); //省份id
  662. $terminal_type = request('terminal_type', '');
  663. $product_name = request('product_name', ''); //商品名称
  664. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  665. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  666. $start_time_string = request('start_time', '');
  667. $end_time_string = request('end_time', '');
  668. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  669. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  670. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  671. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  672. // 时间条件
  673. $map = [];
  674. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  675. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  676. // 权限判断
  677. if ($is_admin != 1 && $company_id != 0) {
  678. $map[] = ['company_id', '=', $company_id];
  679. } else {
  680. $map[] = ['company_id', '=', $admin_company_id];
  681. }
  682. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  683. if ($province_id) $map[] = ['province_id', '=', $province_id];
  684. // 禁止挂网城市统计
  685. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  686. if ($terminal_type) {
  687. $platform = [];
  688. switch ($terminal_type) {
  689. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  690. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  691. break;
  692. case '2': //C端:美团、拼多多、天猫、京东、药房网
  693. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  694. break;
  695. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  696. $platform = ['0'];
  697. break;
  698. default:
  699. # code...
  700. break;
  701. }
  702. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  703. }
  704. try {
  705. // 假设 LowPriceGoodsModel 中有 city 字段,表示城市信息
  706. // 查询指定时间范围内的数据,并按 city 分组统计数量
  707. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  708. ->select(['city_name', DB::raw('count(city_name) as count')])
  709. ->groupby('city_name')
  710. ->orderby('count', 'desc')
  711. ->get()->toArray();
  712. $city_totle_count = 0;
  713. if (!empty($result)) {
  714. $city_totle_count = array_sum(array_column($result, 'count'));
  715. foreach ($result as $key => $value) {
  716. $result[$key]['percent'] = round(($value['count'] / $city_totle_count) * 100, 2);
  717. }
  718. }
  719. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  720. } catch (\Exception $e) {
  721. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  722. }
  723. }
  724. /**
  725. * 低价挂网平台分布
  726. * @author 唐远望
  727. * @version 1.0
  728. * @date 2026-02-27
  729. *
  730. */
  731. public function get_low_price_platform_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  732. {
  733. $request->scene('get_low_price_platform_count')->validate();
  734. $admin_company_id = request('admin_company_id', '0');
  735. $company_id = request('access_token.company_id', '0');
  736. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  737. //终端类型B端、C端、OTO
  738. $terminal_type = request('terminal_type', '');
  739. $product_name = request('product_name', ''); //商品名称
  740. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  741. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  742. $start_time_string = request('start_time', '');
  743. $end_time_string = request('end_time', '');
  744. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  745. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  746. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  747. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  748. // 时间条件
  749. $map = [];
  750. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  751. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  752. // 权限判断
  753. if ($is_admin != 1 && $company_id != 0) {
  754. $map[] = ['company_id', '=', $company_id];
  755. } else {
  756. $map[] = ['company_id', '=', $admin_company_id];
  757. }
  758. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  759. // 禁止挂网平台分布统计
  760. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  761. if ($terminal_type) {
  762. $platform = [];
  763. switch ($terminal_type) {
  764. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  765. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  766. break;
  767. case '2': //C端:美团、拼多多、天猫、京东、药房网
  768. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  769. break;
  770. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  771. $platform = ['0'];
  772. break;
  773. default:
  774. # code...
  775. break;
  776. }
  777. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  778. }
  779. try {
  780. // 假设 LowPriceGoodsModel 中有 platform 字段,表示平台信息
  781. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  782. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  783. ->select(['platform', DB::raw('count(platform) as count')])
  784. ->groupby('platform')
  785. ->orderby('count', 'desc')
  786. ->get()->toArray();
  787. $platform_totle_count = 0;
  788. if (!empty($result)) {
  789. $platform_totle_count = array_sum(array_column($result, 'count'));
  790. foreach ($result as $key => $value) {
  791. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  792. }
  793. }
  794. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  795. } catch (\Exception $e) {
  796. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  797. }
  798. }
  799. /**
  800. * 低价挂网平台省份分布
  801. * @author 唐远望
  802. * @version 1.0
  803. * @date 2026-02-27
  804. *
  805. */
  806. public function get_low_price_platform_province_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  807. {
  808. $request->scene('get_low_price_platform_province_count')->validate();
  809. $admin_company_id = request('admin_company_id', '0');
  810. $company_id = request('access_token.company_id', '0');
  811. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  812. //终端类型B端、C端、OTO
  813. $terminal_type = request('terminal_type', '');
  814. $product_name = request('product_name', ''); //商品名称
  815. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  816. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  817. $start_time_string = request('start_time', '');
  818. $end_time_string = request('end_time', '');
  819. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  820. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  821. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  822. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  823. // 时间条件
  824. $map = [];
  825. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  826. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  827. // 权限判断
  828. if ($is_admin != 1 && $company_id != 0) {
  829. $map[] = ['company_id', '=', $company_id];
  830. } else {
  831. $map[] = ['company_id', '=', $admin_company_id];
  832. }
  833. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  834. // 禁止挂网平台分布统计
  835. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  836. if ($terminal_type) {
  837. $platform = [];
  838. switch ($terminal_type) {
  839. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  840. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  841. break;
  842. case '2': //C端:美团、拼多多、天猫、京东、药房网
  843. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  844. break;
  845. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  846. $platform = ['0'];
  847. break;
  848. default:
  849. # code...
  850. break;
  851. }
  852. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  853. }
  854. try {
  855. // 假设 LowPriceGoodsModel 中有 province 字段,表示省份信息
  856. // 查询指定时间范围内的数据,并按 province 分组统计数量
  857. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  858. ->select(['province_name', DB::raw('count(province_name) as count')])
  859. ->groupby('province_name')
  860. ->orderby('count', 'desc')
  861. ->get();
  862. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  863. } catch (\Exception $e) {
  864. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  865. }
  866. }
  867. /**
  868. * 禁止挂网平台分布
  869. * @author 唐远望
  870. * @version 1.0
  871. * @date 2026-02-27
  872. *
  873. */
  874. public function get_violation_platform_count(request $request, ViolationProductModel $violationProductModel)
  875. {
  876. $request->scene('get_violation_platform_count')->validate();
  877. $admin_company_id = request('admin_company_id', '0');
  878. $company_id = request('access_token.company_id', '0');
  879. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  880. //终端类型B端、C端、OTO
  881. $terminal_type = request('terminal_type', '');
  882. $product_name = request('product_name', ''); //商品名称
  883. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  884. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  885. $start_time_string = request('start_time', '');
  886. $end_time_string = request('end_time', '');
  887. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  888. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  889. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  890. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  891. // 时间条件
  892. $map = [];
  893. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  894. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  895. // 权限判断
  896. if ($is_admin != 1 && $company_id != 0) {
  897. $map[] = ['company_id', '=', $company_id];
  898. } else {
  899. $map[] = ['company_id', '=', $admin_company_id];
  900. }
  901. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  902. // 禁止挂网平台分布统计
  903. $violationProductModel = $violationProductModel->query();
  904. if ($terminal_type) {
  905. $platform = [];
  906. switch ($terminal_type) {
  907. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  908. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  909. break;
  910. case '2': //C端:美团、拼多多、天猫、京东、药房网
  911. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  912. break;
  913. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  914. $platform = ['0'];
  915. break;
  916. default:
  917. # code...
  918. break;
  919. }
  920. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  921. }
  922. try {
  923. // 假设 ViolationProductModel 中有 platform 字段,表示平台信息
  924. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  925. $result = $violationProductModel->where($map)->where('status', 0)
  926. ->select(['platform', DB::raw('count(platform) as count')])
  927. ->groupby('platform')
  928. ->orderby('count', 'desc')
  929. ->get()->toArray();
  930. $platform_totle_count = 0;
  931. if (!empty($result)) {
  932. $platform_totle_count = array_sum(array_column($result, 'count'));
  933. foreach ($result as $key => $value) {
  934. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  935. }
  936. }
  937. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  938. } catch (\Exception $e) {
  939. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  940. }
  941. }
  942. /**
  943. * 禁止挂网平台省份分布
  944. * @author 唐远望
  945. * @version 1.0
  946. * @date 2026-02-27
  947. *
  948. */
  949. public function get_violation_platform_province_count(request $request, ViolationProductModel $violationProductModel)
  950. {
  951. $request->scene('get_violation_platform_province_count')->validate();
  952. $admin_company_id = request('admin_company_id', '0');
  953. $company_id = request('access_token.company_id', '0');
  954. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  955. //终端类型B端、C端、OTO
  956. $terminal_type = request('terminal_type', '');
  957. $product_name = request('product_name', ''); //商品名称
  958. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  959. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  960. $start_time_string = request('start_time', '');
  961. $end_time_string = request('end_time', '');
  962. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  963. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  964. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  965. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  966. // 时间条件
  967. $map = [];
  968. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  969. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  970. // 权限判断
  971. if ($is_admin != 1 && $company_id != 0) {
  972. $map[] = ['company_id', '=', $company_id];
  973. } else {
  974. $map[] = ['company_id', '=', $admin_company_id];
  975. }
  976. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  977. // 禁止挂网平台分布统计
  978. $violationProductModel = $violationProductModel->query();
  979. if ($terminal_type) {
  980. $platform = [];
  981. switch ($terminal_type) {
  982. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  983. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  984. break;
  985. case '2': //C端:美团、拼多多、天猫、京东、药房网
  986. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  987. break;
  988. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  989. $platform = ['0'];
  990. break;
  991. default:
  992. # code...
  993. break;
  994. }
  995. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  996. }
  997. try {
  998. // 假设 ViolationProductModel 中有 platform 字段,表示平台信息
  999. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  1000. $result = $violationProductModel->where($map)->where('status', 0)
  1001. ->select(['province_name', DB::raw('count(province_name) as count')])
  1002. ->groupby(['province_name'])
  1003. ->orderby('count', 'desc')
  1004. ->get();
  1005. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1006. } catch (\Exception $e) {
  1007. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1008. }
  1009. }
  1010. /**
  1011. * 违规公司平台占比
  1012. * @author 唐远望
  1013. * @version 1.0
  1014. * @date 2026-03-23
  1015. *
  1016. */
  1017. public function get_violation_company_platform_proportion(request $request, ViolationProductModel $violationProductModel)
  1018. {
  1019. $request->scene('get_violation_company_platform_proportion')->validate();
  1020. $admin_company_id = request('admin_company_id', '0');
  1021. $company_id = request('access_token.company_id', '0');
  1022. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1023. //终端类型B端、C端、OTO
  1024. $terminal_type = request('terminal_type', '');
  1025. $product_name = request('product_name', ''); //商品名称
  1026. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1027. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1028. $start_time_string = request('start_time', '');
  1029. $end_time_string = request('end_time', '');
  1030. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1031. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1032. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1033. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1034. // 时间条件
  1035. $map = [];
  1036. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1037. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1038. // 权限判断
  1039. if ($is_admin != 1 && $company_id != 0) {
  1040. $map[] = ['company_id', '=', $company_id];
  1041. } else {
  1042. $map[] = ['company_id', '=', $admin_company_id];
  1043. }
  1044. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  1045. // 禁止挂网平台分布统计
  1046. $violationProductModel = $violationProductModel->query();
  1047. if ($terminal_type) {
  1048. $platform = [];
  1049. switch ($terminal_type) {
  1050. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1051. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1052. break;
  1053. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1054. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1055. break;
  1056. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1057. $platform = ['0'];
  1058. break;
  1059. default:
  1060. # code...
  1061. break;
  1062. }
  1063. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  1064. }
  1065. try {
  1066. // 假设 LowPriceGoodsModel 中有 platform 字段,表示平台信息
  1067. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  1068. $result = $violationProductModel->where($map)->where('status', 0)
  1069. ->select(['platform', DB::raw('count(platform) as count')])
  1070. ->distinct('company_name')
  1071. ->groupby('platform')
  1072. ->orderby('count', 'desc')
  1073. ->get()->toArray();
  1074. $platform_totle_count = 0;
  1075. if (!empty($result)) {
  1076. $platform_totle_count = array_sum(array_column($result, 'count'));
  1077. foreach ($result as $key => $value) {
  1078. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  1079. }
  1080. }
  1081. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1082. } catch (\Exception $e) {
  1083. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1084. }
  1085. }
  1086. /**
  1087. * 违规店铺平台占比
  1088. * @author 唐远望
  1089. * @version 1.0
  1090. * @date 2026-03-23
  1091. *
  1092. */
  1093. public function get_violation_store_platform_proportion(request $request, ViolationStoreModel $ViolationStoreModel)
  1094. {
  1095. $request->scene('get_violation_store_platform_proportion')->validate();
  1096. $admin_company_id = request('admin_company_id', '0');
  1097. $company_id = request('access_token.company_id', '0');
  1098. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1099. //终端类型B端、C端、OTO
  1100. $terminal_type = request('terminal_type', '');
  1101. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1102. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1103. $start_time_string = request('start_time', '');
  1104. $end_time_string = request('end_time', '');
  1105. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1106. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1107. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1108. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1109. // 时间条件
  1110. $map = [];
  1111. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1112. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1113. // 权限判断
  1114. if ($is_admin != 1 && $company_id != 0) {
  1115. $map[] = ['company_id', '=', $company_id];
  1116. } else {
  1117. $map[] = ['company_id', '=', $admin_company_id];
  1118. }
  1119. // 禁止挂网平台分布统计
  1120. $ViolationStoreModel = $ViolationStoreModel->query();
  1121. if ($terminal_type) {
  1122. $platform = [];
  1123. switch ($terminal_type) {
  1124. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1125. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1126. break;
  1127. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1128. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1129. break;
  1130. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1131. $platform = ['0'];
  1132. break;
  1133. default:
  1134. # code...
  1135. break;
  1136. }
  1137. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1138. }
  1139. try {
  1140. // 假设 LowPriceGoodsModel 中有 platform 字段,表示平台信息
  1141. // 查询指定时间范围内的数据,并按 platform 分组统计数量
  1142. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1143. ->select(['platform', DB::raw('count(platform) as count')])
  1144. ->groupby('platform')
  1145. ->orderby('count', 'desc')
  1146. ->get()->toArray();
  1147. $platform_totle_count = 0;
  1148. if (!empty($result)) {
  1149. $platform_totle_count = array_sum(array_column($result, 'count'));
  1150. foreach ($result as $key => $value) {
  1151. $result[$key]['percent'] = round(($value['count'] / $platform_totle_count) * 100, 2);
  1152. }
  1153. }
  1154. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1155. } catch (\Exception $e) {
  1156. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1157. }
  1158. }
  1159. /**
  1160. * 违规店铺平台省份分布
  1161. * @author 唐远望
  1162. * @version 1.0
  1163. * @date 2026-03-23
  1164. *
  1165. */
  1166. public function get_violation_store_province_count(request $request, ViolationStoreModel $ViolationStoreModel)
  1167. {
  1168. $request->scene('get_violation_store_province_count')->validate();
  1169. $admin_company_id = request('admin_company_id', '0');
  1170. $company_id = request('access_token.company_id', '0');
  1171. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1172. //终端类型B端、C端、OTO
  1173. $terminal_type = request('terminal_type', '');
  1174. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1175. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1176. $start_time_string = request('start_time', '');
  1177. $end_time_string = request('end_time', '');
  1178. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1179. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1180. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1181. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1182. // 时间条件
  1183. $map = [];
  1184. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1185. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1186. // 权限判断
  1187. if ($is_admin != 1 && $company_id != 0) {
  1188. $map[] = ['company_id', '=', $company_id];
  1189. } else {
  1190. $map[] = ['company_id', '=', $admin_company_id];
  1191. }
  1192. // 违规公司平台分布统计
  1193. $ViolationStoreModel = $ViolationStoreModel->query();
  1194. if ($terminal_type) {
  1195. $platform = [];
  1196. switch ($terminal_type) {
  1197. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1198. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1199. break;
  1200. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1201. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1202. break;
  1203. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1204. $platform = ['0'];
  1205. break;
  1206. default:
  1207. # code...
  1208. break;
  1209. }
  1210. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1211. }
  1212. try {
  1213. // 假设 $violationProductModel 中有 province 字段,表示省份信息
  1214. // 查询指定时间范围内的数据,并按 province 分组统计数量
  1215. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1216. ->select(['province_name', DB::raw('count(province_name) as count')])
  1217. ->groupby('province_name')
  1218. ->orderby('count', 'desc')
  1219. ->get();
  1220. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1221. } catch (\Exception $e) {
  1222. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1223. }
  1224. }
  1225. /**
  1226. * 违规店铺省份统计占比
  1227. * @author 唐远望
  1228. * @version 1.0
  1229. * @date 2026-03-23
  1230. *
  1231. */
  1232. public function get_violation_store_province_proportion(request $request, ViolationStoreModel $ViolationStoreModel)
  1233. {
  1234. $request->scene('get_violation_store_province_proportion')->validate();
  1235. $admin_company_id = request('admin_company_id', '0');
  1236. $company_id = request('access_token.company_id', '0');
  1237. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1238. //终端类型B端、C端、OTO
  1239. $terminal_type = request('terminal_type', '');
  1240. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1241. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1242. $start_time_string = request('start_time', '');
  1243. $end_time_string = request('end_time', '');
  1244. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1245. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1246. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1247. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1248. // 时间条件
  1249. $map = [];
  1250. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1251. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1252. // 权限判断
  1253. if ($is_admin != 1 && $company_id != 0) {
  1254. $map[] = ['company_id', '=', $company_id];
  1255. } else {
  1256. $map[] = ['company_id', '=', $admin_company_id];
  1257. }
  1258. // 违规店铺省份统计
  1259. $ViolationStoreModel = $ViolationStoreModel->query();
  1260. if ($terminal_type) {
  1261. $platform = [];
  1262. switch ($terminal_type) {
  1263. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1264. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1265. break;
  1266. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1267. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1268. break;
  1269. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1270. $platform = ['0'];
  1271. break;
  1272. default:
  1273. # code...
  1274. break;
  1275. }
  1276. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1277. }
  1278. try {
  1279. // 假设 $ViolationStoreModel 中有 province 字段,表示省份信息
  1280. // 查询指定时间范围内的数据,并按 province 分组统计数量
  1281. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1282. ->select(['province_name', DB::raw('count(province_name) as count')])
  1283. ->groupby('province_name')
  1284. ->orderby('count', 'desc')
  1285. ->get()->toArray();
  1286. $province_totle_count = 0;
  1287. if (!empty($result)) {
  1288. $province_totle_count = array_sum(array_column($result, 'count'));
  1289. //计算占比
  1290. foreach ($result as $key => $value) {
  1291. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  1292. }
  1293. }
  1294. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1295. } catch (\Exception $e) {
  1296. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1297. }
  1298. }
  1299. /**
  1300. * 违规店铺城市统计占比
  1301. * @author 唐远望
  1302. * @version 1.0
  1303. * @date 2026-03-23
  1304. *
  1305. */
  1306. public function get_violation_store_city_proportion(request $request, ViolationStoreModel $ViolationStoreModel)
  1307. {
  1308. $request->scene('get_violation_store_city_proportion')->validate();
  1309. $admin_company_id = request('admin_company_id', '0');
  1310. $company_id = request('access_token.company_id', '0');
  1311. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1312. //终端类型B端、C端、OTO
  1313. $province_id = request('province_id', ''); //省份id
  1314. $terminal_type = request('terminal_type', '');
  1315. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1316. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1317. $start_time_string = request('start_time', '');
  1318. $end_time_string = request('end_time', '');
  1319. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1320. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1321. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1322. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1323. // 时间条件
  1324. $map = [];
  1325. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1326. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1327. if ($province_id) $map[] = ['province_id', '=', $province_id];
  1328. // 权限判断
  1329. if ($is_admin != 1 && $company_id != 0) {
  1330. $map[] = ['company_id', '=', $company_id];
  1331. } else {
  1332. $map[] = ['company_id', '=', $admin_company_id];
  1333. }
  1334. // 违规店铺省份统计
  1335. $ViolationStoreModel = $ViolationStoreModel->query();
  1336. if ($terminal_type) {
  1337. $platform = [];
  1338. switch ($terminal_type) {
  1339. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1340. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1341. break;
  1342. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1343. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1344. break;
  1345. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1346. $platform = ['0'];
  1347. break;
  1348. default:
  1349. # code...
  1350. break;
  1351. }
  1352. $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
  1353. }
  1354. try {
  1355. // 假设 $ViolationStoreModel 中有 province 字段,表示省份信息
  1356. // 查询指定时间范围内的数据,并按 province 分组统计数量
  1357. $result = $ViolationStoreModel->where($map)->where('status', 0)
  1358. ->select(['city_name', DB::raw('count(city_name) as count')])
  1359. ->distinct('company_name')
  1360. ->groupby('city_name')
  1361. ->orderby('count', 'desc')
  1362. ->get()->toArray();
  1363. $province_totle_count = 0;
  1364. if (!empty($result)) {
  1365. $province_totle_count = array_sum(array_column($result, 'count'));
  1366. //计算占比
  1367. foreach ($result as $key => $value) {
  1368. $result[$key]['percent'] = round(($value['count'] / $province_totle_count) * 100, 2);
  1369. }
  1370. }
  1371. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1372. } catch (\Exception $e) {
  1373. return json_send(['code' => 'error', 'msg' => '获取失败:' . $e->getMessage()]);
  1374. }
  1375. }
  1376. /*
  1377. * 低价挂网商品规格数统计排行
  1378. * @author 唐远望
  1379. * @version 1.0
  1380. * @date 2026-03-24
  1381. *
  1382. */
  1383. public function get_low_price_product_spec_count(request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  1384. {
  1385. $request->scene('get_low_price_product_spec_count')->validate();
  1386. $admin_company_id = request('admin_company_id', '0');
  1387. $company_id = request('access_token.company_id', '0');
  1388. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1389. //终端类型B端、C端、OTO
  1390. $terminal_type = request('terminal_type', '');
  1391. $limit = request('limit', config('page_num', 10));
  1392. $product_name = request('product_name', ''); //商品名称
  1393. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1394. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1395. $start_time_string = request('start_time', '');
  1396. $end_time_string = request('end_time', '');
  1397. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1398. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1399. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1400. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1401. // 时间条件
  1402. $map = [];
  1403. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1404. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1405. // 权限判断
  1406. if ($is_admin != 1 && $company_id != 0) {
  1407. $map[] = ['company_id', '=', $company_id];
  1408. } else {
  1409. $map[] = ['company_id', '=', $admin_company_id];
  1410. }
  1411. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  1412. $LowPriceGoodsModel = $LowPriceGoodsModel->query();
  1413. if ($terminal_type) {
  1414. $platform = [];
  1415. switch ($terminal_type) {
  1416. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1417. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1418. break;
  1419. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1420. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1421. break;
  1422. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1423. $platform = ['0'];
  1424. break;
  1425. default:
  1426. # code...
  1427. break;
  1428. }
  1429. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
  1430. }
  1431. $result = $LowPriceGoodsModel->where($map)->where('status', 0)
  1432. ->select(['product_name', 'product_specs', DB::raw('count(*) as count')])
  1433. ->groupby('product_name', 'product_specs')
  1434. ->orderby('count', 'desc')
  1435. ->paginate($limit);
  1436. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1437. }
  1438. /**
  1439. * 禁止挂网商品规格数统计排行
  1440. * @author 唐远望
  1441. * @version 1.0
  1442. * @date 2026-03-24
  1443. *
  1444. */
  1445. public function get_violation_product_spec_count(request $request, ViolationProductModel $violationProductModel)
  1446. {
  1447. $request->scene('get_violation_product_spec_count')->validate();
  1448. $admin_company_id = request('admin_company_id', '0');
  1449. $company_id = request('access_token.company_id', '0');
  1450. //终端类型B端、C端、OTO
  1451. $terminal_type = request('terminal_type', '');
  1452. $product_name = request('product_name', ''); //商品名称
  1453. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  1454. $limit = request('limit', config('page_num', 10));
  1455. $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
  1456. $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
  1457. $start_time_string = request('start_time', '');
  1458. $end_time_string = request('end_time', '');
  1459. $start_time = $start_time_string ? strtotime($start_time_string . ' 00:00:00') : $yesterdayStart;
  1460. $end_time = $end_time_string ? strtotime($end_time_string . ' 23:59:59') : $yesterdayEnd;
  1461. $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
  1462. // if ($start_time > $todayStart || $end_time > $todayStart) return json_send(['code' => 'error', 'msg' => '不支持查询今天或以后时间', 'data' => '']);
  1463. // 时间条件
  1464. $map = [];
  1465. if ($start_time) $map[] = ['insert_time', '>=', $start_time];
  1466. if ($end_time) $map[] = ['insert_time', '<=', $end_time];
  1467. // 权限判断
  1468. if ($is_admin != 1 && $company_id != 0) {
  1469. $map[] = ['company_id', '=', $company_id];
  1470. } else {
  1471. $map[] = ['company_id', '=', $admin_company_id];
  1472. }
  1473. if ($product_name) $map[] = ['product_name', 'like', '%' . $product_name . '%'];
  1474. $violationProductModel = $violationProductModel->query();
  1475. if ($terminal_type) {
  1476. $platform = [];
  1477. switch ($terminal_type) {
  1478. case '1': //B端:药师帮、1药城、药久久、药易购、药帮忙、熊猫药药
  1479. $platform = ['0', '5', '6', '7', '8', '9', '10']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1480. break;
  1481. case '2': //C端:美团、拼多多、天猫、京东、药房网
  1482. $platform = ['0', '1', '2', '3', '4', '11']; //1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  1483. break;
  1484. case '3': //OTO:美团买药、淘宝闪送、京东秒送
  1485. $platform = ['0'];
  1486. break;
  1487. default:
  1488. # code...
  1489. break;
  1490. }
  1491. $violationProductModel = $violationProductModel->whereIn('platform', $platform);
  1492. }
  1493. $result = $violationProductModel->where($map)->where('status', 0)
  1494. ->select(['product_name', 'product_specs', DB::raw('count(*) as count')])
  1495. ->groupby('product_name', 'product_specs')
  1496. ->orderby('count', 'desc')
  1497. ->paginate($limit);
  1498. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  1499. }
  1500. }