WebsiteService.php 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278
  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. }