WebsiteService.php 41 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267
  1. <?php
  2. namespace App\JsonRpc;
  3. use App\Model\Article;
  4. use App\Model\Ad;
  5. use App\Model\Category;
  6. use App\Model\AdPlace;
  7. use App\Model\Department;
  8. use App\Model\District;
  9. use App\Model\Link;
  10. use App\Model\LetterOfComplaint;
  11. use App\Model\TemplateClass;
  12. use App\Model\Template;
  13. use App\Model\User;
  14. use App\Model\WebsiteRole;
  15. use App\Model\WebsiteRoleUser;
  16. use App\Model\Website;
  17. use App\Model\WebsiteColumn;
  18. use Hyperf\DbConnection\Db;
  19. use Hyperf\RpcServer\Annotation\RpcService;
  20. use App\Tools\Result;
  21. use Carbon\Carbon;
  22. use App\Model\WebsiteCategory;
  23. use function PHPUnit\Framework\isNull;
  24. #[RpcService(name: "WebsiteService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
  25. class WebsiteService implements WebsiteServiceInterface
  26. {
  27. /**
  28. * @param string $keyword
  29. * @param int $page
  30. * @param int $pageSize
  31. * @return array
  32. */
  33. public function getWebsitetList(array $data): array
  34. {
  35. $where = [];
  36. if(isset($data['keyword']) && !empty($data['keyword'])){
  37. array_push($where,['website.website_name','like','%'.$data['keyword'].'%']);
  38. }
  39. if(isset($data['website_column_id']) && !empty($data['website_column_id'])){
  40. array_push($where,['website.website_column_id','=',$data['website_column_id']]);
  41. }
  42. if(isset($data['city_id']) && !empty($data['city_id'])){
  43. array_push($where,['website.city_id','=',$data['city_id']]);
  44. }
  45. $result = Website::where($where)
  46. ->leftJoin("website_column","website.website_column_id","website_column.id")
  47. ->leftJoin("district","district.id","website.city_id")
  48. ->select("website.*","website_column.column_name","district.name as city_name")
  49. ->limit($data['pageSize'])->offset(($data['page']-1)*$data['pageSize'])->orderBy("website.id","desc")->get();
  50. $count = Website::where($where)->count();
  51. if (empty($result)) {
  52. return Result::error("没有数据",0);
  53. }
  54. $data = [
  55. 'rows'=>$result->toArray(),
  56. 'count'=>$count
  57. ];
  58. return Result::success($data);
  59. }
  60. /**
  61. * @param array $data
  62. * @return array
  63. */
  64. public function createWebsite(array $data): array
  65. {
  66. var_dump("网站数据:",$data);
  67. $insertData = [
  68. 'website_name'=>$data['website_name'],
  69. 'logo'=>$data['logo']??'',
  70. 'website_url'=>$data['website_url']??'',
  71. 'city_id'=>$data['city_id']??0,
  72. 'website_column_id'=>$data['website_column_id'],
  73. 'title'=>$data['title']??'',
  74. 'keywords'=>$data['keywords']??'',
  75. 'description'=>$data['description']??'',
  76. 'status'=>$data['status']??0,
  77. 'website_column_arr_id'=>$data['website_column_arr_id'],
  78. 'city_arr_id'=>$data['city_arr_id']??[0],
  79. 'template_id' =>$data['template_id']??0,
  80. ];
  81. $result = Website::insertGetId($insertData);
  82. if(empty($result)){
  83. return Result::error("创建失败",0);
  84. }else{
  85. return Result::success(["id"=>$result]);
  86. }
  87. }
  88. /**
  89. * @param int $id
  90. * @param array $data
  91. * @return array
  92. */
  93. public function updateWebsite(int $id,array $data): array
  94. {
  95. $insertData = [
  96. 'website_name'=>$data['website_name'],
  97. 'logo'=>$data['logo']??'',
  98. 'website_url'=>$data['website_url']??'',
  99. 'city_id'=>$data['city_id']??0,
  100. 'website_column_id'=>$data['website_column_id'],
  101. 'title'=>$data['title']??'',
  102. 'keywords'=>$data['keywords']??'',
  103. 'description'=>$data['description']??'',
  104. 'status'=>$data['status']??0,
  105. 'website_column_arr_id'=>$data['website_column_arr_id'],
  106. 'city_arr_id'=>$data['city_arr_id']??[0],
  107. 'template_id' =>$data['template_id']??0,
  108. ];
  109. $result = Website::where('id',$id)->update($insertData);
  110. var_dump("更新站点",$result);
  111. if(empty($result)){
  112. return Result::error("更新失败",0);
  113. }else{
  114. return Result::success();
  115. }
  116. }
  117. /**
  118. * @param int $id
  119. * @return array
  120. */
  121. public function delWebsite(int $id): array
  122. {
  123. $result = Website::where('id',$id )->delete();
  124. if(empty($result)){
  125. return Result::error("删除失败",0);
  126. }else{
  127. return Result::success();
  128. }
  129. }
  130. /**
  131. * @param int $id
  132. * @return array
  133. */
  134. public function getWebsiteInfo(int $id): array
  135. {
  136. $where = [
  137. ['website.id','=',$id]
  138. ];
  139. $result = Website::where($where )
  140. ->leftJoin("template","template.id","website.template_id")
  141. ->select("website.*","template.template_name","template.template_img")
  142. ->first();
  143. if(empty($result)){
  144. return Result::error("数据不存在",0);
  145. }else{
  146. return Result::success($result->toArray());
  147. }
  148. }
  149. /**
  150. * 查询所有的站点栏目
  151. * @return array
  152. */
  153. public function getWebsiteColumn(array $data): array
  154. {
  155. $result = WebsiteColumn::where($data)->get();
  156. if(empty($result)){
  157. return Result::error("数据不存在",0);
  158. }else{
  159. return Result::success($result->toArray());
  160. }
  161. }
  162. /**
  163. * @param string $keyword
  164. * @param int $page
  165. * @param int $pageSize
  166. * @return array
  167. */
  168. public function getWebsiteColumnList(array $data):array
  169. {
  170. $where = [];
  171. if(isset($data['keyword']) && $data['keyword']){
  172. array_push($where,['website_column.column_name','like','%'.$data['keyword'].'%']);
  173. }
  174. $result = WebsiteColumn::where($where)
  175. ->leftJoin("website_column as wc","website_column.pid","wc.id")
  176. ->select("website_column.*","wc.column_name as parent_column_name")
  177. ->limit($data['pageSize'])->offset(($data['page']-1)*$data['pageSize'])->get();
  178. $count = WebsiteColumn::where($where)->count();
  179. if (empty($result)) {
  180. return Result::error("没有数据",0);
  181. }
  182. $data = [
  183. 'rows'=>$result->toArray(),
  184. 'count'=>$count
  185. ];
  186. return Result::success($data);
  187. }
  188. /**
  189. * @param array $data
  190. * @return array
  191. */
  192. public function createWebsiteColumn(array $data): array
  193. {
  194. $insertData = [
  195. 'column_name'=>$data['column_name'],
  196. 'pid'=>$data['pid']??'',
  197. 'column_arr_id'=>$data['column_arr_id']??[0],
  198. 'sort'=>$data['sort']??0,
  199. 'remark'=>$data['remark']??'',
  200. ];
  201. $result = WebsiteColumn::insertGetId($insertData);
  202. if(empty($result)){
  203. return Result::error("创建失败",0);
  204. }else{
  205. return Result::success(["id"=>$result]);
  206. }
  207. }
  208. /**
  209. * @param int $id
  210. * @param array $data
  211. * @return array
  212. */
  213. public function updateWebsiteColumn(int $id,array $data): array
  214. {
  215. $insertData = [
  216. 'column_name'=>$data['column_name'],
  217. 'pid'=>$data['pid']??'',
  218. 'column_arr_id'=>$data['column_arr_id']??[0],
  219. 'sort'=>$data['sort']??0,
  220. 'remark'=>$data['remark']??'',
  221. ];
  222. $result = WebsiteColumn::where('id',$id)->update($insertData);
  223. if(empty($result)){
  224. return Result::error("更新失败",0);
  225. }else{
  226. return Result::success();
  227. }
  228. }
  229. /**
  230. * @param int $id
  231. * @return array
  232. */
  233. public function delWebsiteColumn(int $id): array
  234. {
  235. $list = WebsiteColumn::where(['pid'=>$id])->get();
  236. if($list){
  237. return Result::error("存在子网系,不能删除,请先删除子网系",0);
  238. }
  239. $result = WebsiteColumn::where('id',$id )->delete();
  240. if(empty($result)){
  241. return Result::error("删除失败",0);
  242. }else{
  243. return Result::success();
  244. }
  245. }
  246. /**
  247. * @param string $keyword
  248. * @param int $page
  249. * @param int $pageSize
  250. * @return array
  251. */
  252. public function getWebsiteRoleList(string $keyword,int $page,int $pageSize,int $websiteId):array
  253. {
  254. $where = [
  255. ['role.role_name','like','%'.$keyword.'%'],
  256. ['website_role.website_id','=',$websiteId],
  257. ];
  258. $result = WebsiteRole::where($where)
  259. ->leftJoin("role","role.id","website_role.role_id")
  260. ->select("role.*","website_role.type","website_role.role_id","website_role.id as website_role_id","website_role.website_id")
  261. ->limit($pageSize)->offset(($page-1)*$pageSize)->get();
  262. $count = WebsiteRole::where($where) ->leftJoin("role","role.id","website_role.role_id")->count();
  263. if (empty($result)) {
  264. return Result::error("没有数据",0);
  265. }
  266. $data = [
  267. 'rows'=>$result->toArray(),
  268. 'count'=>$count
  269. ];
  270. return Result::success($data);
  271. }
  272. /**
  273. * @param array $data
  274. * @return array
  275. */
  276. public function createWebsiteRole(array $data): array
  277. {
  278. $insertData = [
  279. 'website_id'=>$data['website_id'],
  280. 'role_id'=>$data['role_id']??''
  281. ];
  282. $info = WebsiteRole::where($insertData)->first();
  283. if($info){
  284. return Result::error("不能重复添加角色",0);
  285. }
  286. $insertData['admin_user_id'] = $data['admin_user_id']??'';
  287. $insertData['type'] = $data['type']??'';
  288. $result = WebsiteRole::insertGetId($insertData);
  289. if(empty($result)){
  290. return Result::error("创建失败",0);
  291. }else{
  292. return Result::success(["id"=>$result]);
  293. }
  294. }
  295. /**
  296. * 暂时用不上
  297. * @param int $id
  298. * @param array $data
  299. * @return array
  300. */
  301. public function updateWebsiteRole(int $id,array $data): array
  302. {
  303. $insertData = [
  304. 'website_id'=>$data['website_id'],
  305. 'type'=>$data['type']??'',
  306. ];
  307. $result = WebsiteRole::where('id',$id)->update($insertData);
  308. if(empty($result)){
  309. return Result::error("更新失败",0);
  310. }else{
  311. return Result::success();
  312. }
  313. }
  314. /**
  315. * @param int $id
  316. * @return array
  317. */
  318. public function delWebsiteRole(int $id): array
  319. {
  320. $result = WebsiteRole::where('id',$id )->delete();
  321. if(empty($result)){
  322. return Result::error("删除失败",0);
  323. }else{
  324. return Result::success();
  325. }
  326. }
  327. /**
  328. * @param string $keyword
  329. * @param int $page
  330. * @param int $pageSize
  331. * @return array
  332. */
  333. public function getWebsiteRoleUserList(string $keyword,int $page,int $pageSize,int $websiteId,int $roleId):array
  334. {
  335. $where = [
  336. ['website_role_user.website_id','=',$websiteId],
  337. ['website_role_user.role_id','=',$roleId],
  338. ];
  339. $count = WebsiteRoleUser::where($where)->count();
  340. $where[] = ['u.user_name','like','%'.$keyword.'%'];
  341. $result = WebsiteRoleUser::where($where)
  342. ->leftJoin("user as u","website_role_user.user_id","u.id")
  343. ->leftJoin("website as w","website_role_user.website_id","u.id")
  344. ->leftJoin("role as r","website_role_user.role_id","r.id")
  345. ->select("u.*","u.user_name",'w.website_name','r.role_name','website_role_user.id as website_role_user_id','website_role_user.updated_at as user_update_at')
  346. ->limit($pageSize)->offset(($page-1)*$pageSize)->get();
  347. if (empty($result)) {
  348. return Result::error("没有数据",0);
  349. }
  350. $data = [
  351. 'rows'=>$result->toArray(),
  352. 'count'=>$count
  353. ];
  354. return Result::success($data);
  355. }
  356. /**
  357. * @param array $data
  358. * @return array
  359. */
  360. public function createWebsiteRoleUser(array $data): array
  361. {
  362. $insertData = [
  363. 'website_id'=>$data['website_id'],
  364. 'user_id'=>$data['user_id']??'',
  365. ];
  366. $info = WebsiteRoleUser::where($insertData)->first();
  367. if($info){
  368. return Result::error("不能重复添加角色用户",0);
  369. }
  370. $insertData['role_id'] = $data['role_id']??'';
  371. $insertData['admin_user_id'] = $data['admin_user_id']??'';
  372. $insertData['type'] = $data['type']??'';
  373. $result = WebsiteRoleUser::insertGetId($insertData);
  374. if(empty($result)){
  375. return Result::error("创建失败",0);
  376. }else{
  377. return Result::success(["id"=>$result]);
  378. }
  379. }
  380. /**
  381. * @param int $id
  382. * @param array $data
  383. * @return array
  384. */
  385. public function updateWebsiteRoleUser(int $id,array $data): array
  386. {
  387. $insertData = [
  388. 'website_id'=>$data['website_id'],
  389. 'type'=>$data['type']??'',
  390. 'type_id'=>$data['type_id']??'',
  391. 'role_id'=>$data['role_id']??'',
  392. ];
  393. $result = WebsiteRoleUser::where('id',$id)->update($insertData);
  394. if(empty($result)){
  395. return Result::error("更新失败",0);
  396. }else{
  397. return Result::success();
  398. }
  399. }
  400. /**
  401. * @param int $id
  402. * @return array
  403. */
  404. public function delWebsiteRoleUser(int $id): array
  405. {
  406. $result = WebsiteRoleUser::where('id',$id )->delete();
  407. if(empty($result)){
  408. return Result::error("删除失败",0);
  409. }else{
  410. return Result::success();
  411. }
  412. }
  413. /**
  414. * 根据域名获取网站 站点id
  415. * @param array $data
  416. * @return array
  417. */
  418. public function getWebsiteId(array $data): array
  419. {
  420. $result = Website::whereJsonContains('website_url',$data['website_url'])->first();
  421. if(empty($result)){
  422. return Result::error("查询站点失败",0);
  423. }else{
  424. return Result::success($result);
  425. }
  426. }
  427. /**
  428. * 查询网站下面的导航
  429. * @param array $data
  430. * @return array
  431. */
  432. public function getWebsiteCategory(array $data): array
  433. {
  434. $where = [
  435. 'website_id'=>$data['website_id'],
  436. 'pid'=>0
  437. ];
  438. $result = WebsiteCategory::where($where)->orderBy('sort','asc')->get();
  439. if(empty($result)){
  440. return Result::error("查询站点栏目失败",0);
  441. }else{
  442. return Result::success($result);
  443. }
  444. }
  445. /**
  446. * 查询网站的广告
  447. * @param array $data
  448. * @return array
  449. */
  450. public function getWebsiteAdvertisement(array $data): array
  451. {
  452. $where = [
  453. 'website_id' => $data['website_id'],
  454. 'id' => $data['ad_placeid']
  455. ];
  456. $ad_place = AdPlace::where($where)->orderBy('id','asc')->limit(1)->get();
  457. $today = Carbon::now();
  458. if(empty($ad_place)){
  459. return Result::error("error",0);
  460. }else{
  461. foreach($ad_place as $val){
  462. $adplaceid = $val;
  463. }
  464. $ad=Ad::where('pid',$adplaceid['id'])->where('status',1)->orderBy('id','asc')->get();
  465. if(empty($ad)){
  466. $result=$adplaceid;
  467. return Result::success($result);
  468. }else{
  469. foreach($ad as $i)
  470. {
  471. $starttime=Carbon::parse($i['fromtime']);
  472. $endtime=Carbon::parse($i['totime']);
  473. $time=$today->between($starttime,$endtime);
  474. if($time)
  475. {
  476. $result=$i;
  477. }
  478. }
  479. if(empty($result)){
  480. $result=$ad;
  481. return Result::success($result);
  482. }else{
  483. return Result::success($result);
  484. }
  485. }
  486. }
  487. }
  488. /**
  489. *
  490. * @param array $data
  491. * @return array
  492. */
  493. /**网站行政职能搜索 */
  494. public function selectWebsiteDepartment(array $data): array
  495. {
  496. $depart = Department::where('pid',0)->orderBy('id','asc')->limit(10)->get();
  497. if(isset($data['keyword']) && !empty($data['keyword'])){
  498. $departments= Department::where('name', 'like', '%' . $data['keyword'] . '%')->get();
  499. if(empty($departments)){
  500. $result['message']="未查询到与此相关职能部门";
  501. }else{
  502. $count = Department::where('name','like',"%{$data['keyword']}%")->count();
  503. $m = [
  504. 'department'=>$depart,
  505. 'type'=>$departments,
  506. 'count'=>$count
  507. ];
  508. }
  509. $result['sele'] = $m;
  510. return Result::success($result['sele']);
  511. }
  512. $result=$depart;
  513. return Result::success($result['data']);
  514. }
  515. /**
  516. *
  517. * @param array $data
  518. * @return array
  519. */
  520. /**
  521. * 搜索地区
  522. */
  523. public function selectWebsiteArea(array $data): array
  524. {
  525. $provinces=District::where('pid',0)->where('status',1)->get();
  526. if(isset($data['province'])){
  527. $province=District::where('pid',0)->where('status',1)->where('id',$data['province'])->orderBy('id')->get();
  528. $province=$province->toArray();
  529. if(!empty($province)){
  530. $citys=District::where('pid',$data['province'])->where('status',1)->orderBy('id')->get();
  531. if(!empty($citys) && isset($data['city']) && !empty($data['city'])){
  532. // $province = $province->toArray();
  533. $province_id=[];
  534. foreach($province as $val){
  535. array_push($province_id,$val['id']);
  536. }
  537. // var_dump($province_id);
  538. $city=District::whereIn('pid',$province_id)->where('status',1)->where('id',$data['city'])->orderBy('id')->get();
  539. if(!empty($city)){
  540. $city_id=[];
  541. foreach($city as $val){
  542. array_push($city_id,$val['id']);
  543. }
  544. $regions=District::whereIn('pid',$city_id)->where('status',1)->orderBy('id')->get();
  545. $result=[
  546. 'province' => $province,
  547. 'city' => $city,
  548. 'region' => $regions
  549. ];
  550. }else{
  551. return Result::error("未查询到此城市",0);
  552. }
  553. }else{
  554. $result=[
  555. 'province' => $province,
  556. 'city' => $citys,
  557. 'region' => null
  558. ];
  559. }
  560. }else{
  561. return Result::error("未查询到此省份",0);
  562. }
  563. }else{
  564. // $keys = array('data');
  565. $result = $provinces;
  566. }
  567. return Result::success($result);
  568. }
  569. /**
  570. * @param array $data
  571. * @return array
  572. */
  573. //获取栏目
  574. public function getWebsiteModelCategory(array $data): array
  575. {
  576. $website_id=[
  577. 'website_id' => $data['website_id']
  578. ];
  579. $placeid=$data['placeid']-1;
  580. $pid=[
  581. 'pid' => $data['pid'],
  582. ];
  583. $num = $data['num'];
  584. $result=WebsiteCategory::where($website_id)->where($pid)->orderBy('sort')->offset($placeid)->limit($num)->get();
  585. $result = $result->toArray();
  586. if(!empty($result)){
  587. return Result::success($result);
  588. }else{
  589. return Result::error("本网站暂无栏目",0);
  590. }
  591. }
  592. /**
  593. * @param array $data
  594. * @return array
  595. */
  596. //获取友情链接
  597. public function selectWebsiteLinks(array $data): array
  598. {
  599. $where = [
  600. 'website_id' => $data['website_id'],
  601. 'status' => 1,
  602. 'type' => $data['type']
  603. ];
  604. $num=$data['num'];
  605. $result=Link::where($where)->orderBy('id')->limit($num)->get();
  606. if(!empty($result)){
  607. return Result::success($result);
  608. }else{
  609. return Result::error("本网站暂无此类型友情链接",0);
  610. }
  611. }
  612. /**
  613. * 网站首页数据统计, 管理员
  614. * @return void
  615. */
  616. public function getAdminIndex(array $data): array
  617. {
  618. var_dump("用户类型:",$data['type_id']);
  619. switch ($data['type_id']){
  620. case 4:
  621. $result = Db::select('SELECT DATE(created_at) AS date,COUNT(*) AS total_count FROM letter_of_complaint WHERE created_at >= CURDATE() - INTERVAL 30 DAY GROUP BY DATE(created_at) ORDER BY date ASC;');
  622. return Result::success($result);
  623. break;
  624. case 10000:
  625. $res = [];
  626. //网站
  627. $res['website']['count'] = 0;
  628. $res['website']['growth_rate'] = 0;
  629. //资讯
  630. $res['article']['count'] = 0;
  631. $res['article']['growth_rate'] = 0;
  632. //导航池
  633. $res['category']['count'] = 0;
  634. $res['category']['growth_rate'] = 0;
  635. //近一月数据
  636. $res['monthArticle']= [];
  637. //用户类型
  638. $res['userType'] = [];
  639. $res['website']['count'] = Website::where([])->count();
  640. $res['article']['count'] = Article::whereNotIn('status',['404'])->count();
  641. $res['category']['count'] = Category::where([])->count();
  642. $res['monthArticle'] = Db::select('SELECT DATE(created_at) AS date,COUNT(*) AS total_count FROM article WHERE created_at >= CURDATE() - INTERVAL 30 DAY GROUP BY DATE(created_at) ORDER BY date ASC;');
  643. $res['userType'] = User::where([])->selectRaw("count(*) as counts,type_id")->groupBy('type_id')->get();
  644. return Result::success($res);
  645. }
  646. return [];
  647. }
  648. /**
  649. * 获取模板类型
  650. * @return void
  651. */
  652. public function getTemplateClass(array $data): array
  653. {
  654. $where = [];
  655. if(isset($data['name']) && $data['name']){
  656. array_push($where,['name','like','%'.$data['name'].'%']);
  657. }
  658. $result = TemplateClass::where($where)->orderBy('sort','asc')->get();
  659. if(empty($result)){
  660. return Result::error("没有模板类型",0);
  661. }else{
  662. return Result::success($result);
  663. }
  664. }
  665. /**
  666. * 添加模板类型
  667. * @param
  668. * @return void
  669. */
  670. public function addTemplateClass(array $data): array
  671. {
  672. $insertData = [
  673. 'name'=>$data['name']
  674. ];
  675. $result = TemplateClass::insertGetId($insertData);
  676. if(empty($result)){
  677. return Result::error("创建失败",0);
  678. }else{
  679. return Result::success(["id"=>$result]);
  680. }
  681. }
  682. /**
  683. * 更新模板
  684. * @param array $data
  685. * @return array
  686. */
  687. public function upTemplateClass(array $data): array
  688. {
  689. $where = [
  690. 'id'=>$data['id']
  691. ];
  692. $insertData = [
  693. 'name'=>$data['name']
  694. ];
  695. $result = TemplateClass::where($where)->update($insertData);
  696. if(empty($result)){
  697. return Result::error("更新失败",0);
  698. }else{
  699. return Result::success();
  700. }
  701. }
  702. /**
  703. * 删除模板
  704. * @param array $data
  705. * @return array
  706. */
  707. public function delTemplateClass(array $data): array
  708. {
  709. $where = [
  710. 'id'=>$data['id']
  711. ];
  712. $result = TemplateClass::where($where)->delete();
  713. if(empty($result)){
  714. return Result::error("删除失败",0);
  715. }else{
  716. return Result::success();
  717. }
  718. }
  719. /**
  720. * 获取分类下的模板
  721. * @param array $data
  722. * @return array
  723. */
  724. public function getTemplate(array $data): array
  725. {
  726. $page = $data['page'];
  727. $pageSize = $data['pageSize'];
  728. $where = [];
  729. if(isset($data['template_class_id']) && $data['template_class_id']){
  730. array_push($where,['template_class_id','=',$data['template_class_id']]);
  731. }
  732. $result = Template::where($where)
  733. ->limit($pageSize)->offset(($page-1)*$pageSize)->get();
  734. $count = Template::where($where)->count();
  735. if (empty($result)) {
  736. return Result::error("没有数据",0);
  737. }
  738. $data = [
  739. 'rows'=>$result->toArray(),
  740. 'count'=>$count
  741. ];
  742. return Result::success($data);
  743. }
  744. /**
  745. * 创建模板
  746. * @param
  747. * @return void
  748. */
  749. public function addTemplate(array $data): array
  750. {
  751. $insertData = [
  752. 'template_name'=>$data['template_name'],
  753. 'template_img'=>json_encode($data['template_img']),
  754. 'template_class_id'=>$data['template_class_id'],
  755. ];
  756. $result = Template::insertGetId($insertData);
  757. if(empty($result)){
  758. return Result::error("创建模板失败",0);
  759. }else{
  760. return Result::success(["id"=>$result]);
  761. }
  762. }
  763. /**
  764. * 更新模板
  765. * @param array $data
  766. * @return array
  767. */
  768. public function upTemplate(array $data): array
  769. {
  770. $where = [
  771. 'id'=>$data['id']
  772. ];
  773. $insertData = [
  774. 'template_name'=>$data['template_name'],
  775. 'template_img'=>json_encode($data['template_img']),
  776. 'template_class_id'=>$data['template_class_id'],
  777. ];
  778. $result = Template::where($where)->update($insertData);
  779. if(empty($result)){
  780. return Result::error("更新模板失败",0);
  781. }else{
  782. return Result::success();
  783. }
  784. }
  785. /**
  786. * 删除模板
  787. * @param array $data
  788. * @return array
  789. */
  790. public function delTemplate(array $data): array
  791. {
  792. $where = [
  793. 'id'=>$data['id']
  794. ];
  795. $result = Template::where($where)->delete();
  796. if(empty($result)){
  797. return Result::error("删除模板失败",0);
  798. }else{
  799. return Result::success();
  800. }
  801. }
  802. /**
  803. * 搜索网站
  804. * @param array $data
  805. * @return array
  806. */
  807. public function websiteList(array $data): array
  808. {
  809. $where = [];
  810. if(isset($data['keyword']) && !empty($data['keyword'])){
  811. array_push($where,['website.website_name','like','%'.$data['keyword'].'%']);
  812. }
  813. $result = Website::where($where)->get();
  814. if($result){
  815. return Result::success($result);
  816. }else{
  817. return Result::error("没有网站",0);
  818. }
  819. }
  820. public function addWebsiteCategory(array $data): array
  821. {
  822. $website_id = $data['website_id'];
  823. $category_arr_id = $data['category_arr_id'];
  824. $categoryList = Category::whereIn('id',$category_arr_id)->get();
  825. $categoryListIds = [];
  826. if($categoryList){
  827. foreach ($categoryList->toArray() as $val){
  828. array_push($categoryListIds,$val['id']);
  829. }
  830. }
  831. $arr = [];
  832. if($categoryListIds){
  833. foreach ($categoryListIds as $v){
  834. $ids = $this->getUnderlingUIds(intval($v));
  835. $ids_arr = explode(",", $ids);
  836. array_push($arr,$ids_arr);
  837. }
  838. }
  839. $mergedArray = [];
  840. foreach ($arr as $subarray) {
  841. $mergedArray = array_merge($mergedArray, $subarray);
  842. }
  843. var_dump("所有:",$arr,$mergedArray);
  844. //查询出所有的分类进行分割插入 组装数据
  845. $categoryListData = Category::whereIn('id',$mergedArray)->get();
  846. $categoryListData = $categoryListData->toArray();
  847. $insertData = [];
  848. if($categoryListData){
  849. foreach ($categoryListData as $key=>$value){
  850. $insertData[$key]['website_id'] = $website_id;
  851. $insertData[$key]['name'] = $value['name'];
  852. $insertData[$key]['sort'] = $value['sort'];
  853. $insertData[$key]['pid'] = $value['pid'];
  854. $insertData[$key]['pid_arr'] = $value['pid_arr'];
  855. $insertData[$key]['seo_title'] = $value['seo_title'];
  856. $insertData[$key]['seo_keywords'] = $value['seo_keywords'];
  857. $insertData[$key]['seo_description'] = $value['seo_description'];
  858. $insertData[$key]['alias'] = $value['name'];
  859. $insertData[$key]['category_id'] = $value['id'];
  860. }
  861. }
  862. $result = WebsiteCategory::insert($insertData);
  863. var_dump("插入数据状态:",$result);
  864. if($result){
  865. return Result::success($result);
  866. }else{
  867. return Result::error("创建失败",0);
  868. }
  869. }
  870. /**
  871. * 删除网站导航
  872. * @param array $data
  873. * @return array
  874. */
  875. public function delWebsiteCategory(array $data): array
  876. {
  877. $website_id = $data['website_id']??0;
  878. $category_id = $data['category_id']??0;
  879. $ids = $this->getUnderlingUIds(intval($category_id));
  880. $ids_arr = explode(",", $ids);
  881. $result = WebsiteCategory::where(['website_id'=>$website_id])->whereIn("category_id",$ids_arr)->delete();
  882. if($result){
  883. return Result::success($result);
  884. }else{
  885. return Result::error("删除失败",0);
  886. }
  887. }
  888. /**
  889. * 获取网站导航
  890. * @param array $data
  891. * @return array
  892. */
  893. public function getAdminWebsiteCategory(array $data): array
  894. {
  895. $where = [
  896. 'website_id'=>$data['website_id'],
  897. 'pid'=>0
  898. ];
  899. $result = WebsiteCategory::where($where)->get();
  900. if($result){
  901. return Result::success($result);
  902. }else{
  903. return Result::error("查询失败",0);
  904. }
  905. }
  906. /**
  907. * 更新网站导航
  908. * @param array $data
  909. * @return array
  910. */
  911. public function upWebsiteCategory(array $data): array
  912. {
  913. Db::beginTransaction();
  914. try{
  915. //合并栏目id
  916. $reqIds = array_merge($data['old_category_arr_id'],$data['new_category_arr_id']);
  917. //对比old 数组差异化,把差异化的删除
  918. $result = WebsiteCategory::where(['website_id'=>$data['website_id'],'pid'=>0])->get();
  919. $result = $result->toArray();
  920. $categoryIds = [];
  921. if($result){
  922. foreach ($result as $val){
  923. array_push($categoryIds,$val['category_id']);
  924. }
  925. }
  926. //和原始数据对比取交际
  927. $reqidsIntersect = array_intersect($reqIds,$categoryIds);
  928. //再取差集 进行对比
  929. $differenceIDS = array_merge(array_diff($reqidsIntersect, $categoryIds),array_diff($categoryIds,$reqidsIntersect));
  930. var_dump("差集:",$differenceIDS);
  931. $arr_ids = [];
  932. if(count($differenceIDS)>0){
  933. foreach ($differenceIDS as $vv){
  934. $idV = $this->getUnderlingUIds(intval($vv));
  935. $ids_arrV = explode(",", $idV);
  936. array_push($arr_ids,$ids_arrV);
  937. }
  938. }
  939. $del_ids = array_reduce($arr_ids, 'array_merge', array());
  940. //有差异 删除
  941. if(count($del_ids)>0){
  942. WebsiteCategory::where(['website_id'=>$data['website_id']])->whereIn("category_id",$del_ids)->delete();
  943. }
  944. //传过来的值 和 交际 对比,选出要添加的值 进行插入
  945. $insertIDS = array_merge(array_diff($reqIds, $reqidsIntersect),array_diff($reqidsIntersect,$reqIds));
  946. var_dump("要存储的:",$insertIDS);
  947. //新的数组重新创建
  948. if(count($insertIDS)>0){
  949. $arr = [];
  950. $categoryListIds = $insertIDS;
  951. if($categoryListIds){
  952. foreach ($categoryListIds as $v){
  953. $ids = $this->getUnderlingUIds(intval($v));
  954. $ids_arr = explode(",", $ids);
  955. array_push($arr,$ids_arr);
  956. }
  957. }
  958. $mergedArray = [];
  959. foreach ($arr as $subarray) {
  960. $mergedArray = array_merge($mergedArray, $subarray);
  961. }
  962. var_dump("要插入的ID:",$mergedArray);
  963. //查询出所有的分类进行分割插入 组装数据
  964. $categoryListData = Category::whereIn('id',$mergedArray)->get();
  965. $categoryListData = $categoryListData->toArray();
  966. $insertData = [];
  967. if($categoryListData){
  968. foreach ($categoryListData as $key=>$value){
  969. $insertData[$key]['website_id'] = $data['website_id'];
  970. $insertData[$key]['name'] = $value['name'];
  971. $insertData[$key]['sort'] = $value['sort'];
  972. $insertData[$key]['pid'] = $value['pid'];
  973. $insertData[$key]['pid_arr'] = $value['pid_arr'];
  974. $insertData[$key]['seo_title'] = $value['seo_title'];
  975. $insertData[$key]['seo_keywords'] = $value['seo_keywords'];
  976. $insertData[$key]['seo_description'] = $value['seo_description'];
  977. $insertData[$key]['alias'] = $value['name'];
  978. $insertData[$key]['category_id'] = $value['id'];
  979. }
  980. }
  981. WebsiteCategory::insert($insertData);
  982. }
  983. Db::commit();
  984. } catch(\Throwable $ex){
  985. Db::rollBack();
  986. var_dump($ex->getMessage());
  987. return Result::error("修改失败",0);
  988. }
  989. return Result::success();
  990. }
  991. /**
  992. * 获取网站列表
  993. * @param array $data
  994. * @return array
  995. */
  996. public function getWebsiteCategoryList(array $data): array
  997. {
  998. $where = [];
  999. if(isset($data['keyword']) && !empty($data['keyword'])){
  1000. array_push($where,['website.website_name','like','%'.$data['keyword'].'%']);
  1001. }
  1002. if(isset($data['website_column_id']) && !empty($data['website_column_id'])){
  1003. array_push($where,['website.website_column_id','=',$data['website_column_id']]);
  1004. }
  1005. $result = Website::where($where)
  1006. ->with(["websiteCategory"=>function ($query) {
  1007. $query->where(['pid'=>0])->select('website_id','name','alias','category_id');
  1008. }])
  1009. ->limit($data['pageSize'])->offset(($data['page']-1)*$data['pageSize'])
  1010. ->get();
  1011. $count = Website::where($where)->count();
  1012. if (empty($result)) {
  1013. return Result::error("没有数据",0);
  1014. }
  1015. $data = [
  1016. 'rows'=>$result->toArray(),
  1017. 'count'=>$count
  1018. ];
  1019. if($result){
  1020. return Result::success($data);
  1021. }else{
  1022. return Result::error("查询失败",0);
  1023. }
  1024. }
  1025. /**
  1026. * 删除网站下的所有导航
  1027. * @param array $data
  1028. * @return array
  1029. */
  1030. public function delWebsiteAllCategory(array $data): array
  1031. {
  1032. $website_id = $data['website_id'];
  1033. $result = WebsiteCategory::where(['website_id'=>$website_id])->delete();
  1034. if($result){
  1035. return Result::success($result);
  1036. }else{
  1037. return Result::error("删除失败",0);
  1038. }
  1039. }
  1040. /**
  1041. * 获取网站下的某一个导航
  1042. * @param array $data
  1043. * @return array
  1044. */
  1045. public function getWebsiteCategoryOnes(array $data): array
  1046. {
  1047. $website_id = $data['website_id'];
  1048. $category_id = $data['category_id'];
  1049. $result = WebsiteCategory::where(['website_category.website_id'=>$website_id,'website_category.category_id'=>$category_id])
  1050. ->first();
  1051. if($result){
  1052. return Result::success($result);
  1053. }else{
  1054. return Result::error("查询失败",0);
  1055. }
  1056. }
  1057. /**
  1058. * 更新网闸下的某一个导航
  1059. * @param array $data
  1060. * @return array
  1061. */
  1062. public function upWebsiteCategoryones(array $data): array
  1063. {
  1064. $where = [
  1065. 'website_id'=>$data['website_id'],
  1066. 'category_id'=>$data['category_id'],
  1067. ];
  1068. $result = WebsiteCategory::where($where)->update($data);
  1069. if($result){
  1070. return Result::success($result);
  1071. }else{
  1072. return Result::error("更新失败",0);
  1073. }
  1074. }
  1075. /**
  1076. * 获取网站下的所有导航(包含子导航)
  1077. * @param array $data
  1078. * @return array
  1079. */
  1080. public function getWebsiteAllCategory(array $data): array
  1081. {
  1082. $where = [];
  1083. if(isset($data['website_id']) && !empty($data['website_id'])){
  1084. array_push($where,['website_category.website_id','=',$data['website_id']]);
  1085. }
  1086. if(isset($data['name']) && !empty($data['name'])){
  1087. array_push($where,['website_category.name','like','%'.$data['name'].'%']);
  1088. }
  1089. if(isset($data['alias']) && !empty($data['alias'])){
  1090. array_push($where,['website_category.alias','like','%'.$data['alias'].'%']);
  1091. }
  1092. if(isset($data['department_id']) && !empty($data['department_id'])){
  1093. array_push($where,['category.department_id','=',$data['department_id']]);
  1094. }
  1095. if(isset($data['city_id']) && !empty($data['city_id'])){
  1096. array_push($where,['category.city_id','=',$data['city_id']]);
  1097. }
  1098. $result = WebsiteCategory::where($where)
  1099. ->leftJoin("category",'website_category.category_id','category.id')
  1100. ->leftJoin("department",'category.department_id','department.id')
  1101. ->leftJoin("district",'category.city_id','district.id')
  1102. ->select("website_category.*","department.name as department_name","district.name as city_name")
  1103. ->limit($data['pageSize'])->offset(($data['page']-1)*$data['pageSize'])
  1104. ->get();
  1105. $count = WebsiteCategory::where($where)
  1106. ->leftJoin("category",'website_category.category_id','category.id')
  1107. ->leftJoin("department",'category.department_id','department.id')
  1108. ->leftJoin("district",'category.city_id','district.id')
  1109. ->count();
  1110. if (empty($result)) {
  1111. return Result::error("没有数据",0);
  1112. }
  1113. $data = [
  1114. 'rows'=>$result->toArray(),
  1115. 'count'=>$count
  1116. ];
  1117. if($result){
  1118. return Result::success($data);
  1119. }else{
  1120. return Result::error("查询失败",0);
  1121. }
  1122. if($result){
  1123. return Result::success($result);
  1124. }else{
  1125. return Result::error("查询失败",0);
  1126. }
  1127. }
  1128. /**
  1129. * 递归查询数据
  1130. * @param $id
  1131. * @param $ids
  1132. * @return string
  1133. */
  1134. public function getUnderlingUIds($id, $ids='')
  1135. {
  1136. $back = Category::where(['pid'=>$id])->get();
  1137. $back = $back->toArray();
  1138. if (!empty($back) && is_array($back)) {
  1139. foreach ($back as $v) {
  1140. //防止当前人的ID重复去查询,形成恶性循环
  1141. if ($v['id'] == $id) {
  1142. continue;
  1143. }
  1144. $back2 = Category::where(['pid'=>$id])->count('id');
  1145. if ($back2 > 0) {
  1146. $ids = $this->getUnderlingUIds($v['id'],$ids);
  1147. } else {
  1148. $ids .= ','.$v['id'];
  1149. }
  1150. }
  1151. }
  1152. $ids = $id.','.$ids.',';
  1153. $ids = str_replace(',,', ",", $ids);
  1154. $ids = trim($ids, ',');
  1155. return $ids;
  1156. }
  1157. /**
  1158. * 检测网站名称是否重复
  1159. * @param array $data
  1160. * @return array
  1161. */
  1162. public function checkWebsiteName(array $data): array
  1163. {
  1164. if(isset($data['id'])){
  1165. $data[] = ['id',"!=",$data['id']];
  1166. unset($data['id']);
  1167. }
  1168. $websiteInfo = Website::query()->where($data)->first();
  1169. if (empty($websiteInfo)) {
  1170. return Result::error("找不到网站",0);
  1171. }
  1172. return Result::success($websiteInfo->toArray());
  1173. }
  1174. /**
  1175. * 检测网站url是否重复
  1176. * @param array $data
  1177. * @return array
  1178. */
  1179. public function checkWebsiteUrl(array $data): array
  1180. {
  1181. $whereData = [];
  1182. if(isset($data['id'])){
  1183. $whereData = [['id',"!=",$data['id']]];
  1184. unset($data['id']);
  1185. }
  1186. $websiteInfo = Website::query()->where($whereData)->whereJsonContains('website_url', $data['website_url'])->first();
  1187. if (empty($websiteInfo)) {
  1188. return Result::error("找不到URL",0);
  1189. }
  1190. return Result::success($websiteInfo->toArray());
  1191. }
  1192. }