WebsiteService.php 41 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277
  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. * 获取栏目
  571. * @param array $data
  572. * @return array
  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. * 获取友情链接
  594. * @param array $data
  595. * @return array
  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. }