NewsService.php 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583
  1. <?php
  2. namespace App\JsonRpc;
  3. use App\Model\Article;
  4. use App\Model\ArticleData;
  5. use App\Model\Category;
  6. use App\Model\Website;
  7. use App\Model\WebsiteCategory;
  8. use App\Model\ArticleSurvey;
  9. use App\Model\District;
  10. use App\Model\jobHunting;
  11. use App\Model\JobEnum;
  12. use App\Model\JobIndustry;
  13. use App\Model\JobPosition;
  14. use App\Model\JobRecruiting;
  15. use App\Model\Good;
  16. use App\Model\JobNature;
  17. use App\Model\User;
  18. use App\Model\UserRole;
  19. use App\Model\News;
  20. use App\Model\UserInfo;
  21. use App\Model\WebsiteGroup;
  22. use Hyperf\DbConnection\Db;
  23. use Hyperf\RpcServer\Annotation\RpcService;
  24. use App\Tools\Result;
  25. use Directory;
  26. use Ramsey\Uuid\Uuid;
  27. use Hyperf\Utils\Random;
  28. #[RpcService(name: "NewsService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
  29. class NewsService implements NewsServiceInterface
  30. {
  31. /**
  32. * 获取导航池列表
  33. * @param array $data
  34. * @return array
  35. */
  36. public function getCategoryList(array $data): array
  37. {
  38. $rep = Category::select("category.*")->orderBy('category.updated_at',"desc")->get();
  39. if (empty($rep)) {
  40. return Result::error("没有导航池数据");
  41. }
  42. return Result::success($rep);
  43. }
  44. public function myCategoryList(array $data): array
  45. {
  46. $sszq = $data['sszq'] ?? '';
  47. unset($data['sszq']);
  48. //1,2,3 根据这些webid,。从website_category表中取出对应的分类id,然后从category表中取出分类信息
  49. $catorytids = WebsiteCategory::whereIn('website_id', explode(',', $sszq))->get()->pluck('category_id')->toArray();
  50. $where[] = [
  51. 'pid', '=', $data['pid'],
  52. ];
  53. if (isset($data['name'])) {
  54. array_push($where, ['category.name', 'like', '%' . $data['name'] . '%']);
  55. }
  56. var_dump($where);
  57. //根据分类id,从category表中取出分类信息
  58. $result = Category::where($where)
  59. ->whereIn('category.id', $catorytids)
  60. ->select('category.*', 'category.id as category_id')->get();
  61. if (empty($result)) {
  62. return Result::error("没有栏目数据");
  63. }
  64. return Result::success($result);
  65. }
  66. /**
  67. * @param array $data
  68. * @return array
  69. */
  70. public function categoryList(array $data): array
  71. {
  72. $where[] = [
  73. 'pid', '=', $data['pid'],
  74. ];
  75. if (isset($data['name'])) {
  76. array_push($where, ['category.name', 'like', '%' . $data['name'] . '%']);
  77. }
  78. var_dump($where);
  79. $result = Category::where($where)->select('category.*', 'category.id as category_id')->get();
  80. if (empty($result)) {
  81. return Result::error("没有栏目数据");
  82. }
  83. return Result::success($result);
  84. }
  85. /**
  86. * @param array $data
  87. * @return array
  88. */
  89. public function addCategory(array $data): array
  90. {
  91. if (isset($data['id'])) {
  92. unset($data['id']);
  93. }
  94. $id = Category::insertGetId($data);
  95. if (empty($id)) {
  96. return Result::error("添加失败");
  97. }
  98. return Result::success(['id' => $id]);
  99. }
  100. /**
  101. * @param array $data
  102. * @return array
  103. */
  104. public function delCategory(array $data): array
  105. {
  106. $categoryList = Category::where(['pid' => $data['id']])->get();
  107. var_dump("分类列表:", $data, $categoryList);
  108. if ($categoryList->toArray()) {
  109. return Result::error("分类下面有子分类不能删除");
  110. }
  111. $articleList = Article::where(['catid' => $data['id']])->get();
  112. var_dump("文章列表:", $articleList);
  113. if ($articleList->toArray()) {
  114. return Result::error("分类下面有资讯不能删除");
  115. }
  116. $result = Category::where($data)->delete();
  117. if (!$result) {
  118. return Result::error("删除失败");
  119. }
  120. return Result::success($result);
  121. }
  122. /**
  123. * @param array $data
  124. * @return array
  125. */
  126. public function updateCategory(array $data): array
  127. {
  128. $where = [
  129. 'id' => $data['id'],
  130. ];
  131. $result = Category::where($where)->update($data);
  132. if ($result) {
  133. return Result::success($result);
  134. } else {
  135. return Result::error("更新失败");
  136. }
  137. }
  138. /**
  139. * 获取导航池信息
  140. * @param array $data
  141. * @return array
  142. */
  143. public function getCategoryInfo(array $data): array
  144. {
  145. $where = [
  146. 'id' => $data['id'],
  147. ];
  148. $result = Category::where($where)->first();
  149. if ($result) {
  150. return Result::success($result);
  151. } else {
  152. return Result::error("更新失败");
  153. }
  154. }
  155. /**
  156. * @param array $data
  157. * @return array
  158. */
  159. public function getArticleList(array $data): array
  160. {
  161. //判断是否是管理员'1:个人会员 2:政务会员 3:企业会员 4:调研员 10000:管理员 20000:游客(小程序)'
  162. $type_id = $data['type_id'];
  163. unset($data['type_id']);
  164. $user_id = $data['user_id'];
  165. unset($data['user_id']);
  166. $where = [];
  167. $status1 = [];
  168. if (isset($data['title']) && $data['title']) {
  169. array_push($where, ['article.title', 'like', '%' . $data['title'] . '%']);
  170. }
  171. if (isset($data['category_name']) && $data['category_name']) {
  172. array_push($where, ['category.name', 'like', '%' . $data['category_name'] . '%']);
  173. }
  174. if (isset($data['author']) && $data['author']) {
  175. array_push($where, ['article.author', '=', $data['author']]);
  176. }
  177. if (isset($data['islink']) && $data['islink'] !== "") {
  178. array_push($where, ['article.islink', '=', $data['islink']]);
  179. }
  180. if (isset($data['status']) && $data['status'] !== "") {
  181. array_push($where, ['article.status', '=', $data['status']]);
  182. }
  183. if (isset($data['status1'])) {
  184. $status1 = json_decode(($data['status1']));
  185. }
  186. //不是管理员展示个人数据;
  187. if ($type_id != 10000) {
  188. $where[] = ['article.admin_user_id', '=', $user_id];
  189. }
  190. $rep = Article::where($where)
  191. ->whereNotIn('article.status', [404])
  192. ->when($status1, function ($query) use ($status1) {
  193. if (isset($status1) && $status1) {
  194. $query->whereIn('article.status', $status1);
  195. }
  196. })
  197. ->leftJoin('category', 'article.catid', 'category.id')
  198. ->select("article.*", "category.name as category_name")
  199. ->orderBy("article.updated_at", "desc")
  200. ->limit($data['pageSize'])
  201. ->offset(($data['page'] - 1) * $data['pageSize'])->get();
  202. $count = Article::where($where)->whereNotIn('article.status', [404])
  203. ->when($status1, function ($query) use ($status1) {
  204. if (isset($status1) && $status1) {
  205. $query->whereIn('article.status', $status1);
  206. }
  207. })
  208. ->leftJoin('category', 'article.catid', 'category.id')->count();
  209. $data = [
  210. 'rows' => $rep->toArray(),
  211. 'count' => $count,
  212. ];
  213. if (empty($rep)) {
  214. return Result::error("没有信息数据");
  215. }
  216. return Result::success($data);
  217. }
  218. /**
  219. * @param array $data
  220. * @return array
  221. */
  222. public function addArticle(array $data): array
  223. {
  224. var_dump($data, '----------12-----------1');
  225. var_dump($data, '----------12-----------1');
  226. unset($data['user_type']);
  227. unset($data['nav_add_pool_id']);
  228. // $data['cat_arr_id'] = is_string($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : '';
  229. Db::beginTransaction();
  230. try {
  231. //处理投票
  232. $is_survey = isset($data['is_survey']) ? $data['is_survey'] : 0;
  233. $survey_name = isset($data['survey_name']) ? $data['survey_name'] : '';
  234. $suvey_array = isset($data['suvey_array']) ? $data['suvey_array'] : '';
  235. $website_id = isset($data['website_id']) ? $data['website_id'] : 2;
  236. unset($data['is_survey']);
  237. unset($data['survey_name']);
  238. unset($data['suvey_array']);
  239. // unset($data['website_id']);
  240. // unset($data['web_site_id']);
  241. // $data['web_site_id'] = is_array($data['web_site_id']) ? json_encode($data['web_site_id']) : ($data['web_site_id']);
  242. if ($data['hits'] == '') {
  243. $data['hits'] = 0;
  244. }
  245. if ($data['is_original'] == '') {
  246. $data['is_original'] = 0;
  247. }
  248. if ($data['status'] == '') {
  249. $data['status'] = 0;
  250. }
  251. $articleData = $data;
  252. unset($articleData['content']);
  253. //自动处理缩略图、关键字、描述
  254. if ($articleData['imgurl'] == '') {
  255. //如果没有图,设置level=0
  256. $levelArr = json_decode($articleData['level'], true);
  257. var_dump($levelArr, '----------levelArr-----------1');
  258. //content中提取图片第一个图,正则提取
  259. $reg = '/<img.*?src=[\"|\']?(.*?)[\"|\']?\s.*?>/i';
  260. preg_match_all($reg, $data['content'], $matches);
  261. if (isset($matches[1][0])) {
  262. $articleData['imgurl'] = $matches[1][0];
  263. //如果有图,设置level=3
  264. if (!in_array(3, $levelArr)) {$levelArr[] = 3;}
  265. $articleData['level'] = json_encode($levelArr);
  266. } else {
  267. if (!in_array(0, $levelArr)) {
  268. $levelArr[] = 0;
  269. }
  270. $articleData['level'] = json_encode($levelArr);
  271. }
  272. }
  273. var_dump($articleData['level'], '----------$articleData[level]----------1');
  274. if ($articleData['keyword'] == '') {
  275. //提取标题+内容中的关键词
  276. $articleData['keyword'] = $data['title'] . substr(str_replace(' ', '', strip_tags($data['content'])), 0, 20);
  277. }
  278. if ($articleData['introduce'] == '') {
  279. //提取内容中的描述
  280. $articleData['introduce'] = substr(str_replace(' ', '', strip_tags($data['content'])), 0, 100);
  281. }
  282. $id = Article::insertGetId($articleData);
  283. $articleDataContent = [
  284. 'article_id' => $id,
  285. 'content' => $data['content'],
  286. ];
  287. ArticleData::insertGetId($articleDataContent);
  288. //处理投票
  289. if ($is_survey == 1) {
  290. //生成年月日时分秒+8位随机数
  291. $uuid = date('YmdHis') . rand(10000000, 99999999);
  292. var_dump($suvey_array, 'suvey_array________');
  293. $suveys_array = is_array($suvey_array) ? $suvey_array : json_decode($suvey_array);
  294. var_dump($suveys_array, '---------------------1');
  295. var_dump($suvey_array, '---------------------2');
  296. $suvey_data = [];
  297. foreach ($suveys_array as $key => $value) {
  298. if ($value == '') {
  299. continue;
  300. }
  301. if (is_array($value)) {
  302. $suvey_data[] = [
  303. 'sur_id' => $uuid,
  304. 'art_id' => $id,
  305. 'website_id' => $website_id ?? 2,
  306. 'survey_name' => $survey_name,
  307. 'choice_name' => $value[1],
  308. 'is_other' => 1,
  309. 'other_id' => 0,
  310. 'results' => 0,
  311. ];
  312. } else {
  313. $suvey_data[] = [
  314. 'sur_id' => $uuid,
  315. 'art_id' => $id,
  316. 'website_id' => $website_id ?? 2,
  317. 'survey_name' => $survey_name,
  318. 'choice_name' => $value,
  319. 'is_other' => 0,
  320. 'other_id' => 0,
  321. 'results' => 0,
  322. ];
  323. }
  324. if (empty($suvey_data)) {
  325. throw new \Exception("投票数据为空");
  326. }
  327. }
  328. $result = ArticleSurvey::insert($suvey_data);
  329. if (!$result) {
  330. throw new \Exception("投票失败,ArticleSurvey插入失败");
  331. }
  332. $result = Article::where('id', $id)->update(['survey_id' => $uuid, 'survey_name' => $survey_name, 'is_survey' => $is_survey]);
  333. if (!$result) {
  334. throw new \Exception("投票失败,更新主表失败");
  335. }
  336. }
  337. Db::commit();
  338. return Result::success(['id' => $id]);
  339. } catch (\Throwable $ex) {
  340. Db::rollBack();
  341. var_dump($ex->getMessage());
  342. return Result::error("创建失败", 0);
  343. }
  344. }
  345. /**
  346. * @param array $data
  347. * @return array
  348. */
  349. public function delArticle(array $data): array
  350. {
  351. $result = Article::where($data)->delete();
  352. //survey投票删除
  353. articleSurvey::where(['art_id' => $data['id']])->delete();
  354. if (!$result) {
  355. return Result::error("删除失败");
  356. }
  357. return Result::success($result);
  358. }
  359. /**
  360. * @param array $data
  361. * @return array
  362. */
  363. public function updateArticle(array $data): array
  364. {
  365. var_dump($data, '----------12-----------1');
  366. Db::beginTransaction();
  367. unset($data['user_type']);
  368. // unset($data['web_site_id']);
  369. unset($data['nav_add_pool_id']);
  370. try {
  371. //处理投票
  372. $is_survey = isset($data['is_survey']) ? $data['is_survey'] : 0;
  373. $survey_name = isset($data['survey_name']) ? $data['survey_name'] : '';
  374. $suvey_array = isset($data['suvey_array']) ? $data['suvey_array'] : '';
  375. $website_id = isset($data['website_id']) ? $data['website_id'] : 2;
  376. unset($data['is_survey']);
  377. unset($data['survey_name']);
  378. unset($data['suvey_array']);
  379. unset($data['website_id']);
  380. $data['web_site_id'] = is_array($data['web_site_id']) ? json_encode($data['web_site_id']) : ($data['web_site_id']);
  381. if ($data['hits'] == '') {
  382. $data['hits'] = 0;
  383. }
  384. if ($data['is_original'] == '') {
  385. $data['is_original'] = 0;
  386. }
  387. if ($data['status'] == '') {
  388. $data['status'] = 0;
  389. }
  390. $data['cat_arr_id'] = isset($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : '';
  391. $data['tag'] = isset($data['tag']) ? json_encode($data['tag']) : '';
  392. $articleData = $data;
  393. unset($articleData['content']);
  394. unset($articleData['status_name']);
  395. unset($articleData['name']);
  396. unset($articleData['content']);
  397. unset($articleData['pid_arr']);
  398. unset($articleData['pid']);
  399. //自动处理缩略图、关键字、描述
  400. if ($articleData['imgurl'] == '') {
  401. //如果没有图,设置level=0
  402. $levelArr = json_decode($articleData['level'], true);
  403. var_dump($levelArr, '----------levelArr-----------1');
  404. //content中提取图片第一个图,正则提取
  405. $reg = '/<img.*?src=[\"|\']?(.*?)[\"|\']?\s.*?>/i';
  406. preg_match_all($reg, $data['content'], $matches);
  407. if (isset($matches[1][0])) {
  408. $articleData['imgurl'] = $matches[1][0];
  409. //如果有图,设置level=3
  410. if (!in_array(3, $levelArr)) {$levelArr[] = 3;}
  411. $articleData['level'] = json_encode($levelArr);
  412. } else {
  413. if (!in_array(0, $levelArr)) {
  414. $levelArr[] = 0;
  415. }
  416. $articleData['level'] = json_encode($levelArr);
  417. }
  418. }
  419. var_dump($articleData['level'], '----------$articleData[level]----------1');
  420. if ($articleData['keyword'] == '') {
  421. //提取标题+内容中的关键词
  422. $articleData['keyword'] = $data['title'] . substr(str_replace(' ', '', strip_tags($data['content'])), 0, 20);
  423. }
  424. if ($articleData['introduce'] == '') {
  425. //提取内容中的描述
  426. $articleData['introduce'] = substr(str_replace(' ', '', strip_tags($data['content'])), 0, 100);
  427. }
  428. $id = Article::where(['id' => $data['id']])->update($articleData);
  429. $articleDataContent = [
  430. 'content' => $data['content'],
  431. ];
  432. ArticleData::where(['article_id' => $data['id']])->update($articleDataContent);
  433. //处理投票
  434. $id = $data['id'];
  435. $surveydata = ArticleSurvey::where(['art_id' => $data['id']])->delete();
  436. var_dump($suvey_array, 'suvey_array________delete');
  437. //处理投票
  438. if ($is_survey == 1) {
  439. //生成年月日时分秒+8位随机数
  440. $uuid = date('YmdHis') . rand(10000000, 99999999);
  441. $suveys_array = is_array($suvey_array) ? $suvey_array : json_decode($suvey_array);
  442. var_dump($suveys_array, '---------------------1');
  443. var_dump($suvey_array, '---------------------2');
  444. $suvey_data = [];
  445. if (is_array($suveys_array)) {
  446. foreach ($suveys_array as $key => $value) {
  447. if ($value == '') {
  448. continue;
  449. }
  450. if (is_array($value)) {
  451. $suvey_data[] = [
  452. 'sur_id' => $uuid,
  453. 'art_id' => $id,
  454. 'website_id' => $website_id ?? 2,
  455. 'survey_name' => $survey_name,
  456. 'choice_name' => $value[1],
  457. 'is_other' => 1,
  458. 'other_id' => 0,
  459. 'results' => 0,
  460. ];
  461. } else {
  462. $suvey_data[] = [
  463. 'sur_id' => $uuid,
  464. 'art_id' => $id,
  465. 'website_id' => $website_id ?? 2,
  466. 'survey_name' => $survey_name,
  467. 'choice_name' => $value,
  468. 'is_other' => 0,
  469. 'other_id' => 0,
  470. 'results' => 0,
  471. ];
  472. }
  473. if (empty($suvey_data)) {
  474. throw new \Exception("投票数据为空");
  475. }
  476. }
  477. }
  478. $result = ArticleSurvey::insert($suvey_data);
  479. if (!$result) {
  480. throw new \Exception("投票失败");
  481. }
  482. $result = Article::where('id', $id)->update(['survey_id' => $uuid, 'survey_name' => $survey_name, 'is_survey' => $is_survey]);
  483. if (!$result) {
  484. throw new \Exception("投票失败");
  485. }
  486. } else {
  487. $result = Article::where('id', $id)->update(['survey_id' => '', 'survey_name' => '', 'is_survey' => 0]);
  488. }
  489. Db::commit();
  490. return Result::success([]);
  491. } catch (\Throwable $ex) {
  492. Db::rollBack();
  493. var_dump($ex->getMessage());
  494. return Result::error("更新失败1" . $ex->getMessage(), 0);
  495. }
  496. }
  497. /**
  498. * 更新资讯状态
  499. * @param array $data
  500. * @return array
  501. */
  502. public function upArticleStatus(array $data): array
  503. {
  504. $result = Article::where(['id' => $data['id']])->update($data);
  505. if ($result) {
  506. return Result::success();
  507. } else {
  508. return Result::error("更新状态失败", 0);
  509. }
  510. }
  511. /**
  512. * 获取新闻详情
  513. * @param array $data
  514. * @return array
  515. */
  516. public function getArticleInfo(array $data): array
  517. {
  518. $where = [
  519. 'article.id' => $data['id'],
  520. // 'article.status' => 1,
  521. ];
  522. $result = Article::where($where)->leftJoin("article_data", "article.id", "article_data.article_id")->first();
  523. $articleSurvey = ArticleSurvey::where(['art_id' => $data['id']])->get()->all();
  524. var_dump($articleSurvey, 'articleSurvey');
  525. $info = $result;
  526. var_dump($info, 'info');
  527. // $info['survey_array'] = $articleSurvey == null ? [] : $info['survey_array'];
  528. if ($result) {
  529. return Result::success($info);
  530. } else {
  531. return Result::error("查询失败", 0);
  532. }
  533. return Result::success($result);
  534. }
  535. /**
  536. * 获取头条新闻
  537. * @param array $data
  538. * @return array
  539. */
  540. public function getWebsiteArticlett(array $data): array
  541. {
  542. $category = WebsiteCategory::where('website_id', $data['website_id'])->pluck('category_id');
  543. $result = [];
  544. if ($category) {
  545. $placeid = isset($data['placeid']) && !empty($data['placeid']) ? $data['placeid'] - 1 : 0;
  546. $where = [
  547. 'status' => 1,
  548. ];
  549. var_dump($data, 'data-----------------');
  550. //如果是4:最新资讯(数据库已不存在) 5:资讯推荐(数据库已不存在);
  551. // 1:头条资讯;2:轮播图;6:热点资讯;(数据库)
  552. var_dump($where, 'where-----------------');
  553. $result = Article::where($where)
  554. ->whereIn("catid", $category)
  555. ->where(function ($query) use ($data) {
  556. $query->whereRaw("JSON_CONTAINS(ignore_ids, '" . intval($data['website_id']) . "') = 0")
  557. ->orWhereNull("ignore_ids");
  558. })
  559. //$data['level'] == 4 || $data['level'] == 5 查询随机
  560. ->when($data['level'] == 5, function ($query) {
  561. $query->inRandomOrder()
  562. //updated_at最近三十天;
  563. ->where('updated_at', '>', date("Y-m-d H:i:s", strtotime("-30 day")));
  564. })
  565. ->when($data['level'] == 4, function ($query) {
  566. $query->orderBy("updated_at", "desc");
  567. })
  568. ->when(!empty($data['level']), function ($query) use ($data) {
  569. if ($data['level'] != 4 && $data['level'] != 5) {
  570. $query->whereRaw("JSON_CONTAINS(level, '" . intval($data['level']) . "') = 1")
  571. ->orderBy("updated_at", "desc");
  572. }
  573. })
  574. ->offset($placeid)
  575. ->limit($data['pageSize'])
  576. ->get();
  577. if (empty($result)) {
  578. return Result::error("暂无头条新闻", 0);
  579. }
  580. return Result::success($result);
  581. } else {
  582. return Result::error("本网站下暂无相关栏目", 0);
  583. }
  584. }
  585. /**
  586. * 获取模块新闻
  587. * @param array $data
  588. * @return array
  589. */
  590. public function getWebsiteModelArticles(array $data): array
  591. {
  592. $catid = $data['catid'];
  593. $category = WebsiteCategory::where('website_id', $data['website_id'])->where('category_id', $catid)->select('category_id')->get();
  594. $category = $category->toArray();
  595. if (!empty($category)) {
  596. $where = [
  597. 'status' => 1,
  598. 'catid' => $catid,
  599. ];
  600. $placeid = isset($data['placeid']) && !empty($data['placeid']) ? $data['placeid'] - 1 : 0;
  601. // 1:文字新闻;2:轮播图;3:图文;
  602. // 级别:0:未分类
  603. // 3:推荐图片
  604. if ($data['level'] == 1) {
  605. $data['level'] = 0;
  606. }
  607. $result = Article::where($where)
  608. ->where(function ($query) use ($data) {
  609. $query->whereRaw("JSON_CONTAINS(level, '" . intval($data['level']) . "') = 1")
  610. ->orWhereNull("level")
  611. ->orWhereRaw("level = '[]'");
  612. })
  613. ->where(function ($query) use ($data) {
  614. $query->whereRaw("JSON_CONTAINS(ignore_ids, '" . intval($data['website_id']) . "') = 0")
  615. ->orWhereNull("ignore_ids");
  616. })
  617. ->orderBy("updated_at", "desc")
  618. ->offset($placeid)
  619. ->limit($data['pagesize'])
  620. ->get();
  621. if (empty($result)) {
  622. return Result::error("此栏目暂无相关新闻", 0);
  623. }
  624. } else {
  625. return Result::error("此网站暂无此栏目", 0);
  626. }
  627. return Result::success($result);
  628. }
  629. /**
  630. *获取新闻列表
  631. * @param array $data
  632. * @return array
  633. */
  634. public function getWebsiteArticleList(array $data): array
  635. {
  636. $where[] = ['status', '=', 1];
  637. if (isset($data['keyword']) && !empty($data['keyword'])) {
  638. array_push($where, ['article.title', 'like', '%' . $data['keyword'] . '%']);
  639. }
  640. if (isset($data['catid']) && !empty($data['catid'])) {
  641. if (is_array($data['catid'])) {
  642. $category = WebsiteCategory::where('website_id', $data['website_id'])->whereIn('category_id', $data['catid'])->pluck('category_id');
  643. array_push($where, ['catid', 'in', $data['catid']]);
  644. } else {
  645. $category = WebsiteCategory::where('website_id', $data['website_id'])->where('category_id', $data['catid'])->pluck('category_id');
  646. array_push($where, ['catid', '=', $data['catid']]);
  647. }
  648. if (empty($category)) {
  649. return Result::error("此网站暂无此栏目", 0);
  650. }
  651. }
  652. // return Result::success($where);
  653. $rep = Article::where(function ($query) use ($where) {
  654. foreach ($where as $condition) {
  655. if ($condition[1] === 'in') {
  656. $query->whereIn($condition[0], $condition[2]);
  657. } else {
  658. $query->where($condition[0], $condition[1], $condition[2]);
  659. }
  660. }
  661. })
  662. ->where(function ($query) use ($data) {
  663. $query->whereRaw("JSON_CONTAINS(ignore_ids, '" . intval($data['website_id']) . "') = 0")
  664. ->orWhereNull("ignore_ids");
  665. })
  666. ->orderBy("updated_at", "desc")
  667. ->limit($data['pageSize'])
  668. ->offset(($data['page'] - 1) * $data['pageSize'])
  669. ->get();
  670. $count = Article::where(function ($query) use ($where) {
  671. foreach ($where as $condition) {
  672. if ($condition[1] === 'in') {
  673. $query->whereIn($condition[0], $condition[2]);
  674. } else {
  675. $query->where($condition[0], $condition[1], $condition[2]);
  676. }
  677. }
  678. })->count();
  679. $data = [
  680. 'rows' => $rep->toArray(),
  681. 'count' => $count,
  682. ];
  683. if (empty($rep)) {
  684. return Result::error("没有信息数据");
  685. }
  686. return Result::success($data);
  687. }
  688. /**
  689. * 前端-获取新闻详情
  690. * @param array $data
  691. * @return array
  692. */
  693. public function selectWebsiteArticleInfo(array $data): array
  694. {
  695. $where = [
  696. 'article.id' => $data['id'],
  697. 'article.status' => 1,
  698. ];
  699. $result = Article::where($where)->leftJoin("article_data", "article.id", "article_data.article_id")
  700. ->where(function ($query) use ($data) {
  701. $query->whereRaw("JSON_CONTAINS(ignore_ids, '" . intval($data['website_id']) . "') = 0")
  702. ->orWhereNull("ignore_ids");
  703. })
  704. ->first();
  705. if (empty($result)) {
  706. return Result::error("暂无此新闻!", 0);
  707. }
  708. $category = WebsiteCategory::leftJoin('website', 'website.id', '=', 'website_category.website_id')
  709. ->select('website_category.*', 'website.website_name', 'website.suffix')
  710. ->where('website_category.website_id', $data['website_id'])
  711. ->where(['website_category.category_id' => $result['catid']])
  712. ->first();
  713. if (empty($category)) {
  714. return Result::error("查询失败", 0);
  715. }
  716. $result['category_id'] = $category['category_id'];
  717. $result['cat_name'] = $category['alias'];
  718. $result['website_name'] = $category['website_name'] ?? "";
  719. $result['suffix'] = $category['suffix'] ?? "";
  720. return Result::success($result);
  721. }
  722. /**
  723. * 前端-获取网站调查问卷
  724. * @param array $data
  725. * @return array
  726. */
  727. public function getWebsiteSurvey(array $data): array
  728. {
  729. if (isset($data['website_id']) && !empty($data['website_id'])) {
  730. $website = Website::where('id', $data['website_id'])->first();
  731. if (empty($website)) {
  732. return Result::error("暂无此网站", 0);
  733. }
  734. }
  735. if (isset($data['art_id']) && !empty($data['art_id'])) {
  736. $article = Article::where('id', $data['art_id'])->where('status', 1)->first();
  737. if (empty($article)) {
  738. return Result::error("暂无此文章", 0);
  739. }
  740. // return Result::error($data,0);
  741. $where['art_id'] = $data['art_id'];
  742. // $query = ArticleSurvey::where('art_id',$data['art_id']);
  743. } else {
  744. $survey = ArticleSurvey::where('website_id', $data['website_id'])->orderBy('created_at')->first();
  745. if (empty($survey)) {
  746. return Result::error("暂无调查问卷", 0);
  747. }
  748. $where['sur_id'] = $survey['sur_id'];
  749. // $query = ArticleSurvey::where('sur_id',$survey['sur_id']);
  750. }
  751. // return Result::success($where);
  752. $result = ArticleSurvey::where($where)
  753. ->where(function ($query) {
  754. $query->where('is_other', 0)
  755. ->orWhere(function ($subQuery) {
  756. $subQuery->where('is_other', 1)
  757. ->where('other_id', 0);
  758. });
  759. })
  760. ->leftJoin('article', 'article_survey.art_id', 'article.id')
  761. ->select('article_survey.*', 'article.survey_type')
  762. ->get()->all();
  763. if(empty($result)){
  764. return Result::error("此文章暂无调查问卷",0);
  765. }
  766. return Result::success($result);
  767. }
  768. /**
  769. * 前端-添加网站调查问卷选项
  770. * @param array $data
  771. * @return array
  772. */
  773. public function addWebsiteSurveyOption(array $data): array
  774. {
  775. if (isset($data['website_id']) && !empty($data['website_id'])) {
  776. $website = Website::where('id', $data['website_id'])->first();
  777. if (empty($website)) {
  778. return Result::error("暂无此网站", 0);
  779. }
  780. if (isset($data['sur_id']) && !empty($data['sur_id'])) {
  781. $survey = ArticleSurvey::where('sur_id', $data['sur_id'])->where('website_id', $data['website_id'])->where('is_other', 1)->where('other_id', 0)->first();
  782. if (empty($survey)) {
  783. return Result::error("此调查问卷不可添加选项", 0);
  784. }
  785. if (isset($data['choice_name']) && !empty($data['choice_name'])) {
  786. $choice = [
  787. 'art_id' => $survey['art_id'],
  788. 'website_id' => $data['website_id'],
  789. 'survey_name' => $survey['survey_name'],
  790. 'choice_name' => $data['choice_name'],
  791. 'sur_id' => $survey['sur_id'],
  792. 'is_other' => 1,
  793. 'other_id' => $survey['id'],
  794. ];
  795. $result = ArticleSurvey::insertGetId($choice);
  796. if (empty($result)) {
  797. return Result::error("添加失败", 0);
  798. }
  799. return Result::success($result);
  800. }
  801. }
  802. return Result::error("添加失败", 0);
  803. }
  804. return Result::error("添加失败", 0);
  805. }
  806. /**
  807. * 前端-调查问卷投票
  808. * @param array $data
  809. * @return array
  810. */
  811. public function addWebsiteSurveyVote(array $data): array
  812. {
  813. if(isset($data['website_id']) && !empty($data['website_id'])){
  814. $website = Website::where('id',$data['website_id'])->first();
  815. if(empty($website)){
  816. return Result::error("暂无此网站",0);
  817. }
  818. if(isset($data['sur_id']) && !empty($data['sur_id'])){
  819. $survey['data'] = ArticleSurvey::where('sur_id',$data['sur_id'])
  820. ->where('website_id',$data['website_id'])
  821. ->where('other_id', 0)
  822. ->get();
  823. // return Result::success($survey);
  824. if(empty($survey)){
  825. return Result::error("此调查问卷不存在",0);
  826. }
  827. // return Result::success($survey);
  828. // 调查问卷类型
  829. if(isset($data['choice_id']) &&!empty($data['choice_id'])){
  830. //多选 若是json型则转化成数组类型
  831. if (strpos($data['choice_id'], '[') === 0) {
  832. $data['choice_id'] = json_decode($data['choice_id'], true);
  833. } else {
  834. // 单选 也转换成数组
  835. $data['choice_id'] = [$data['choice_id']];
  836. }
  837. $data['choice_id'] = array_map('intval', $data['choice_id']);
  838. $other = ArticleSurvey::whereIn('id',$data['choice_id'])
  839. ->where('website_id',$data['website_id'])
  840. ->where('is_other',1)
  841. ->where('other_id',0)
  842. ->first();
  843. if(!empty($other)){
  844. return Result::error("请选择已有的选项!",0);
  845. }
  846. $choice['other'] = ArticleSurvey::whereIn('id',$data['choice_id'])
  847. ->where('website_id',$data['website_id'])
  848. ->where('is_other',1)
  849. ->where('other_id','!=',0)
  850. ->first();
  851. // return Result::success($choice['other']);
  852. $choice_id = $data['choice_id'];
  853. if(!empty($choice['other'])){
  854. array_push($data['choice_id'],$choice['other']['other_id']);
  855. if(!empty($choice_id)){
  856. $key = array_search($choice['other']['id'], $choice_id);
  857. if ($key!== false) {
  858. $$choice_id[$key]=$choice['other']['other_id'];
  859. }
  860. }else{
  861. $choice_id[0] = $choice['other']['other_id'];
  862. }
  863. // return Result::success($data['choice_id']);
  864. }
  865. // return Result::success($data);
  866. $choice = ArticleSurvey::whereIn('id', $data['choice_id'])
  867. ->where('website_id', $data['website_id'])
  868. ->increment('results', 1);
  869. if (empty($choice)) {
  870. return Result::error("请选择已有的选项!", 0);
  871. }
  872. $survey['choice'] = $choice_id;
  873. return Result::success($survey);
  874. }
  875. return Result::error("参数必填!");
  876. }
  877. return Result::error("此调查问卷不存在", 0);
  878. }
  879. return Result::error("参数必填!");
  880. }
  881. /**
  882. * 后端-获取网站调查问卷列表
  883. * @param array $data
  884. * @return array
  885. */
  886. public function getSurveyList(array $data): array
  887. {
  888. $where = [];
  889. if (isset($data['survey_name']) && !empty($data['survey_name'])) {
  890. array_push($where, ['survey_name', 'like', '%' . $data['survey_name'] . '%']);
  891. }
  892. if (isset($data['survey_type']) && $data['survey_type'] != null) {
  893. array_push($where, ['survey_type', '=', $data['survey_type']]);
  894. }
  895. if (isset($data['is_survey']) && $data['is_survey'] != null) {
  896. array_push($where, ['is_survey', '=', $data['is_survey']]);
  897. }
  898. // return Result::success($where);
  899. if (!empty($where)) {
  900. $query = Article::where($where)->where(function ($q) {
  901. $q->whereNotNull('survey_name')->where('survey_name', '!=', '');
  902. });
  903. } else {
  904. $query = Article::where(function ($q) {
  905. $q->whereNotNull('survey_name')->where('survey_name', '!=', '');
  906. });
  907. }
  908. $count = $query->count();
  909. $survey = $query->orderByDesc('id')
  910. ->limit($data['pageSize'])
  911. ->offset(($data['page'] - 1) * $data['pageSize'])
  912. ->get();
  913. if (empty($survey->toArray())) {
  914. return Result::error("暂无调查问卷!", 0);
  915. }
  916. $result = [
  917. 'rows' => $survey,
  918. 'count' => $count,
  919. ];
  920. return Result::success($result);
  921. }
  922. /**
  923. * 后端-获取网站调查问卷详情
  924. * @param array $data
  925. * @return array
  926. */
  927. public function getSurveyInfo(array $data): array
  928. {
  929. if (isset($data['sur_id']) && !empty($data['sur_id'])) {
  930. $where = ['sur_id' => $data['sur_id']];
  931. $choose = ArticleSurvey::where($where)->where('is_other', 0)
  932. ->leftJoin('article', 'article_survey.art_id', 'article.id')
  933. ->select('article_survey.*', 'article.survey_type')
  934. ->get()->all();
  935. if (empty($choose)) {
  936. return Result::error("此调查问卷不存在", 0);
  937. }
  938. $resultsArray = array_column($choose, 'results');
  939. $total = array_sum($resultsArray);
  940. $other = ArticleSurvey::where($where)->where('is_other', 1)->where('other_id', 0)->first();
  941. $others = ArticleSurvey::where($where)->where('is_other', 1)->where('other_id', '!=', 0)->orderByDesc('created_at')->get()->all();
  942. // $total = 0;
  943. if (!empty($other)) {
  944. $total = $total + $other['results'];
  945. $other['choice_name'] = $other['choice_name'] . '(其他)';
  946. if (!empty($others)) {
  947. $other['hasChildren'] = true;
  948. // array_push($other,['hasChildren','=',true]);
  949. $other['children'] = $others;
  950. $other_choices = [$other->toArray()];
  951. $mer_choice = array_merge($choose, $other_choices);
  952. $value_choice = array_values($mer_choice);
  953. } else {
  954. // return Result::error('1111');
  955. $other_choices = [$other->toArray()];
  956. $other_choices = array_merge($choose, $other_choices);
  957. $value_choice = array_values($other_choices);
  958. // return Result::success($result);
  959. }
  960. } else {
  961. $value_choice = $choose;
  962. }
  963. $result = [
  964. 'choose' => $value_choice,
  965. 'total' => $total,
  966. ];
  967. }
  968. return Result::success($result);
  969. }
  970. /**
  971. * 前端-搜索新闻列表
  972. * @param array $data
  973. * @return array
  974. */
  975. public function selectWebsiteArticle(array $data): array
  976. {
  977. $where = [];
  978. // 初始化查询构造器
  979. $category = WebsiteCategory::where('website_id', $data['website_id'])->pluck('category_id');
  980. $query = Article::where('status', 1)
  981. ->whereIn('catid', $category)
  982. ->where(function ($query) use ($data) {
  983. $query->where(function ($subQuery) use ($data) {
  984. $subQuery->whereRaw("JSON_CONTAINS(ignore_ids, '" . intval($data['website_id']) . "') = 0");
  985. })->orWhereNull("ignore_ids");
  986. });
  987. // return Result::success($all_articles);
  988. // 检查是否存在 cityid 参数
  989. if (isset($data['cityid']) && !empty($data['cityid'])) {
  990. $query->whereRaw("JSON_CONTAINS(city_arr_id, '" . intval($data['cityid']) . "')");
  991. }
  992. // 检查是否存在 department_id 参数
  993. if (isset($data['department_id']) && !empty($data['department_id'])) {
  994. $query->whereRaw("JSON_CONTAINS(department_arr_id, '" . intval($data['department_id']) . "')");
  995. }
  996. // 检查是否存在 keyword 参数
  997. if (isset($data['keyword']) && !empty($data['keyword'])) {
  998. $query->where('title', 'like', '%' . $data['keyword'] . '%');
  999. }
  1000. // 计算总数
  1001. $count = $query->count();
  1002. // 分页查询
  1003. $articles = $query->orderBy("updated_at", "desc")
  1004. ->limit($data['pageSize'])
  1005. ->offset(($data['page'] - 1) * $data['pageSize'])
  1006. ->get()->all();
  1007. if (empty($articles)) {
  1008. return Result::error("没有符合条件的资讯数据");
  1009. }
  1010. $data = [
  1011. 'rows' => $articles,
  1012. 'count' => $count,
  1013. ];
  1014. return Result::success($data);
  1015. }
  1016. /**
  1017. * 验证导航名称是否重复
  1018. * @return void
  1019. */
  1020. public function checkCategoryName(array $data): array
  1021. {
  1022. $result = Category::when($data, function ($query) use ($data) {
  1023. if (isset($data['name']) && $data['name']) {
  1024. $query->where("name", $data['name']);
  1025. }
  1026. if (isset($data['id']) && $data['id']) {
  1027. $query->where("id", "!=", $data['id']);
  1028. }
  1029. })->first();
  1030. if ($result) {
  1031. return Result::error("已存在");
  1032. } else {
  1033. return Result::success();
  1034. }
  1035. }
  1036. //20250226 产品列表
  1037. public function getGoodList(array $data): array
  1038. {
  1039. $type_id = isset($data['type_id']) ? $data['type_id'] : '';
  1040. unset($data['type_id']);
  1041. $user_id = isset($data['user_id']) ? $data['user_id'] : '';
  1042. $where = [];
  1043. if ($type_id != '10000') {
  1044. $where = [
  1045. 'good.user_id' => $user_id,
  1046. ];
  1047. }
  1048. //类型
  1049. if (isset($data['type_id']) && $data['type_id']) {
  1050. $where = [
  1051. 'type_id' => $data['type_id'],
  1052. ];
  1053. }
  1054. //名称
  1055. if (isset($data['name']) && $data['name']) {
  1056. $where = [
  1057. 'good.name' => $data['name'],
  1058. ];
  1059. }
  1060. $where1 = [];
  1061. //website_id
  1062. // if (isset($data['website_id']) && $data['website_id']) {
  1063. // $where1 = [
  1064. // 'good.website_id', 'like', '%' . $data['website_id'] . '%',
  1065. // ];
  1066. // }
  1067. // website_name
  1068. if (isset($data['website_name']) && $data['website_name']) {
  1069. $where1[] = ['website.website_name', 'like', '%' . $data['website_name'] . '%'];
  1070. }
  1071. // catid
  1072. if (isset($data['category_name']) && $data['category_name']) {
  1073. $where1[] = ['category.name', 'like', '%' . $data['category_name'] . '%'];
  1074. }
  1075. // $result = Good::where($where)
  1076. // ->orderBy("updated_at", "desc")->paginate($data['pige_size'], ['*'], 'page', $data['page']);
  1077. $result = Good::where($where)
  1078. ->when(!empty($where1), function ($query) use ($where1) {
  1079. return $query->where($where1);
  1080. })
  1081. ->leftJoin('district', 'good.city_id', '=', 'district.id')
  1082. ->leftJoin('website', 'good.website_id', '=', 'website.id')
  1083. ->leftJoin('category', 'good.catid', '=', 'category.id')
  1084. ->select('good.*', 'district.name as cityname', 'website.website_name as website_name', 'category.name as category_name')
  1085. ->orderBy("id", "desc")
  1086. ->limit($data['page_size'])
  1087. ->offset(($data['page'] - 1) * $data['page_size'])
  1088. ->get();
  1089. $count = Good::where($where)
  1090. ->leftJoin('district', 'good.city_id', '=', 'district.id')
  1091. ->leftJoin('website', 'good.website_id', '=', 'website.id')
  1092. ->leftJoin('category', 'good.catid', '=', 'category.id')
  1093. ->select('good.*', 'district.name as cityname', 'website.website_name as website_name', 'category.name as category_name')
  1094. ->orderBy("updated_at", "desc")->count();
  1095. $data = [
  1096. 'rows' => $result->toArray(),
  1097. 'count' => $count,
  1098. ];
  1099. if (empty($result)) {
  1100. return Result::error("此栏目暂无相关产品", 0);
  1101. }
  1102. return Result::success($data);
  1103. }
  1104. public function getGoodInfo(array $data): array
  1105. {
  1106. $result = Good::where('id', $data['id'])->first();
  1107. if (empty($result)) {
  1108. return Result::error("此产品不存在", 0);
  1109. }
  1110. return Result::success($result);
  1111. }
  1112. public function addGood(array $data): array
  1113. {
  1114. // unset($data['city_arr_id']);
  1115. // unset($data['cat_arr_id']);
  1116. $data['city_id'] = end($data['city_arr_id']);
  1117. $data['catid'] = end($data['cat_arr_id']);
  1118. $data['city_arr_id'] = isset($data['city_arr_id']) ? json_encode($data['city_arr_id']) : '';
  1119. $data['cat_arr_id'] = isset($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : '';
  1120. $data['imgurl'] = isset($data['imgurl']) ? json_encode($data['imgurl']) : '';
  1121. unset($data['imgUrl']);
  1122. $result = Good::insert($data);
  1123. if (empty($result)) {
  1124. return Result::error("添加失败", 0);
  1125. }
  1126. return Result::success($result);
  1127. }
  1128. public function updateGood(array $data): array
  1129. {
  1130. $data['city_id'] = end($data['city_arr_id']);
  1131. $data['catid'] = end($data['cat_arr_id']);
  1132. $data['city_arr_id'] = isset($data['city_arr_id']) ? json_encode($data['city_arr_id']) : '';
  1133. $data['cat_arr_id'] = isset($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : '';
  1134. $data['imgurl'] = isset($data['imgurl']) ? json_encode($data['imgurl']) : '';
  1135. //设置东八区
  1136. date_default_timezone_set('Asia/Shanghai');
  1137. $data['updated_at'] = date('Y-m-d H:i:s');
  1138. $result = Good::where('id', $data['id'])->update($data);
  1139. if (empty($result)) {
  1140. return Result::error("更新失败", 0);
  1141. }
  1142. return Result::success($result);
  1143. }
  1144. public function delGood(array $data): array
  1145. {
  1146. $result = Good::where('id', $data['id'])->delete();
  1147. if (empty($result)) {
  1148. return Result::error("删除失败", 0);
  1149. }
  1150. return Result::success($result);
  1151. }
  1152. //20250226 产品列表
  1153. //20250306 求职信息
  1154. public function getJobHuntingList(array $data): array
  1155. {
  1156. $where = [];
  1157. if (isset($data['username']) && !empty($data['username'])) {
  1158. $where[] = ['user.user_name', 'like', '%' . $data['username'] . '%'];
  1159. }
  1160. $type_id = isset($data['type_id']) ? $data['type_id'] : '';
  1161. $user_id = isset($data['user_id']) ? $data['user_id'] : '';
  1162. unset($data['type_id']);
  1163. if ($type_id != '10000') {
  1164. $where[] = ['job_hunting.user_id', '=', $user_id];
  1165. }
  1166. $result = JobHunting::where($where)
  1167. ->leftJoin('user', 'user.id', '=', 'job_hunting.user_id')
  1168. ->leftJoin('website', 'website.id', '=', 'job_hunting.website_id')
  1169. ->select('job_hunting.*', 'user.nickname as nickname', 'user.user_name as username', 'website.website_name as website_name')
  1170. ->orderBy("id", "desc")
  1171. ->limit($data['page_size'])
  1172. ->offset(($data['page'] - 1) * $data['page_size'])
  1173. ->get();
  1174. if (empty($result)) {
  1175. return Result::error("查询失败", 0);
  1176. }
  1177. $count = JobHunting::where($where)
  1178. ->leftJoin('user', 'user.id', '=', 'job_hunting.user_id')
  1179. ->leftJoin('website', 'website.id', '=', 'job_hunting.website_id')
  1180. ->count();
  1181. $data = [
  1182. 'rows' => $result->toArray(),
  1183. 'count' => $count,
  1184. ];
  1185. return Result::success($data);
  1186. }
  1187. // 20250306 招聘
  1188. /*
  1189. * 招聘列表
  1190. * */
  1191. public function getJobRecruitingList(array $data): array
  1192. {
  1193. $where = [];
  1194. if (isset($data['keyword']) && !empty($data['keyword'])) {
  1195. array_push($where, ['job_recruiting.title', 'like', '%' . $data['keyword'] . '%']);
  1196. }
  1197. $user = User::where('id', $data['user_id'])->first();
  1198. if (empty($user)) {
  1199. return Result::error("用户不存在", 0);
  1200. }
  1201. // 3:企业会员
  1202. if ($user['type_id'] == 3) {
  1203. array_push($where, ['user_id', $data['user_id']]);
  1204. }
  1205. $result = JobRecruiting::where($where)
  1206. ->leftJoin('website', 'job_recruiting.website_id', '=', 'website.id')
  1207. ->leftJoin('user', 'job_recruiting.user_id', '=', 'user.id')
  1208. ->select('job_recruiting.*', 'website.website_name as website_name', 'user.user_name as user_name')
  1209. ->orderBy("updated_at", "desc")
  1210. ->offset(($data['page'] - 1) * $data['page_size'])
  1211. ->limit($data['page_size'])
  1212. ->get()
  1213. ->all();
  1214. if (empty($result)) {
  1215. return Result::error("暂无招聘信息", 0);
  1216. }
  1217. return Result::success($result);
  1218. }
  1219. /*
  1220. * 招聘信息详情
  1221. * */
  1222. public function getJobRecruitingInfo(array $data): array
  1223. {
  1224. $result = JobRecruiting::where('job_recruiting.id', $data['id'])
  1225. ->leftJoin('user_info', 'job_recruiting.user_id', 'user_info.id')
  1226. ->leftJoin('user', 'job_recruiting.user_id', 'user.id')
  1227. ->select(
  1228. 'job_recruiting.*',
  1229. 'user_info.business_name', // 企业名称
  1230. 'user_info.hy_id', // 企业所属行业
  1231. 'user_info.company_size', // 公司规模
  1232. 'user_info.company_nature', // 公司性质
  1233. 'user_info.introduction', // 公司简介
  1234. 'user_info.real_name', // 企业联系人
  1235. 'user.mobile', // 企业联系电话
  1236. 'user_info.company_url', // 企业网址
  1237. 'user_info.address_arr_id', // 企业地址
  1238. 'user_info.address', // 企业地址
  1239. 'user.email', // 企业邮箱
  1240. )
  1241. ->orderBy("updated_at", "desc")
  1242. ->first();
  1243. if (empty($result)) {
  1244. return Result::error("暂无招聘信息", 0);
  1245. }
  1246. return Result::success($result);
  1247. }
  1248. /*
  1249. * 招聘信息添加
  1250. * */
  1251. public function addJobRecruiting(array $data): array
  1252. {
  1253. $user = User::where('id', $data['user_id'])->first();
  1254. if (empty($user)) {
  1255. return Result::error("用户不存在", 0);
  1256. }
  1257. // 3:企业会员
  1258. if ($user['type_id'] != 3) {
  1259. if ($data['website_id'] == 0) {
  1260. return Result::error("请选择所属网站", 0);
  1261. }
  1262. $website = Website::where('id', $data['website_id'])->first();
  1263. if (empty($website)) {
  1264. return Result::error("网站不存在", 0);
  1265. }
  1266. $data['website_id'] = $website['id'];
  1267. }
  1268. $data['cat_arr_id'] = array_values(array_unique($data['cat_arr_id']));
  1269. $data['city_arr_id'] = array_values(array_unique($data['city_arr_id']));
  1270. $data['cat_arr_id'] = isset($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : '';
  1271. $data['city_arr_id'] = isset($data['city_arr_id']) ? json_encode($data['city_arr_id']) : '';
  1272. $result = JobRecruiting::insertGetId($data);
  1273. if (empty($result)) {
  1274. return Result::error("添加失败", 0);
  1275. }
  1276. return Result::success($result);
  1277. }
  1278. /*
  1279. * 招聘信息更新
  1280. * */
  1281. public function upJobRecruiting(array $data): array
  1282. {
  1283. $job = JobRecruiting::where('id', $data['id'])->first();
  1284. if (empty($job)) {
  1285. return Result::error("招聘信息不存在", 0);
  1286. }
  1287. $user = User::where('id', $data['user_id'])->first();
  1288. if (empty($user)) {
  1289. return Result::error("用户不存在", 0);
  1290. }
  1291. // 3:企业会员
  1292. if ($user['type_id'] != 3) {
  1293. if ($data['website_id'] == 0) {
  1294. return Result::error("请选择所属网站", 0);
  1295. }
  1296. $website = Website::where('id', $data['website_id'])->first();
  1297. if (empty($website)) {
  1298. return Result::error("网站不存在", 0);
  1299. }
  1300. $data['website_id'] = $website['id'];
  1301. }
  1302. $data['cat_arr_id'] = array_values(array_unique($data['cat_arr_id']));
  1303. $data['city_arr_id'] = array_values(array_unique($data['city_arr_id']));
  1304. $data['cat_arr_id'] = isset($data['cat_arr_id']) ? json_encode($data['cat_arr_id']) : '';
  1305. $data['city_arr_id'] = isset($data['city_arr_id']) ? json_encode($data['city_arr_id']) : '';
  1306. $result = JobRecruiting::where('id', $data['id'])->update($data);
  1307. if (empty($result)) {
  1308. return Result::error("更新失败", 0);
  1309. }
  1310. return Result::success($data);
  1311. }
  1312. /*
  1313. * 招聘信息删除
  1314. * */
  1315. public function delJobRecruiting(array $data): array
  1316. {
  1317. $job = JobRecruiting::where('id', $data['id'])->first();
  1318. if (empty($job)) {
  1319. return Result::error("招聘信息不存在", 0);
  1320. }
  1321. $result = JobRecruiting::where('id', $data['id'])->delete();
  1322. if (empty($result)) {
  1323. return Result::error("删除失败", 0);
  1324. }
  1325. return Result::success($data);
  1326. }
  1327. /*
  1328. * 获取省-市
  1329. * */
  1330. public function getJobRecruitingArea(array $data): array
  1331. {
  1332. if (isset($data['province_id']) && $data['province_id'] != null) {
  1333. $result = District::where('pid', $data['pid'])->get()->all();
  1334. } else {
  1335. $result = District::where('level', 1)->get()->all();
  1336. }
  1337. if (empty($result)) {
  1338. return Result::error("暂无此省市", 0);
  1339. }
  1340. return Result::success($result);
  1341. }
  1342. /*
  1343. * 获取行业分类
  1344. * */
  1345. public function getIndustry(array $data): array
  1346. {
  1347. $result = JobIndustry::get()->all();
  1348. if (empty($result)) {
  1349. return Result::error("暂无行业分类", 0);
  1350. }
  1351. return Result::success($result);
  1352. }
  1353. /*
  1354. * 获取职位
  1355. * */
  1356. public function getPositionList(array $data): array
  1357. {
  1358. if (isset($data['zwpid']) && $data['zwpid'] != null) {
  1359. $result = JobPosition::where('zwpid', $data['zwpid'])->get()->all();
  1360. } else {
  1361. $result = JobPosition::where('zwpid', 0)->get()->all();
  1362. }
  1363. if (empty($result)) {
  1364. return Result::error("暂无此职位", 0);
  1365. }
  1366. return Result::success($result);
  1367. }
  1368. /*
  1369. * 获取工作性质-菜单
  1370. * */
  1371. public function getJobNature(array $data): array
  1372. {
  1373. $result = JobEnum::where('egroup', 'nature')->get()->all();
  1374. if (empty($result)) {
  1375. return Result::error("暂无工作性质", 0);
  1376. }
  1377. return Result::success($result);
  1378. }
  1379. /*
  1380. * 获取工作经验-菜单
  1381. * */
  1382. public function getExperience(array $data): array
  1383. {
  1384. $result = JobEnum::where('egroup', 'years')->get()->all();
  1385. if (empty($result)) {
  1386. return Result::error("暂无工作经验", 0);
  1387. }
  1388. return Result::success($result);
  1389. }
  1390. /*
  1391. * 获取学历-菜单
  1392. * */
  1393. public function getEducation(array $data): array
  1394. {
  1395. $result = JobEnum::where('egroup', 'education')->get()->all();
  1396. if (empty($result)) {
  1397. return Result::error("暂无学历", 0);
  1398. }
  1399. return Result::success($result);
  1400. }
  1401. /*
  1402. * 获取薪资-菜单
  1403. * */
  1404. public function getSalary(array $data): array
  1405. {
  1406. $result = JobEnum::where('egroup', 'income')->get()->all();
  1407. if (empty($result)) {
  1408. return Result::error("暂无薪资", 0);
  1409. }
  1410. return Result::success($result);
  1411. }
  1412. /*
  1413. * 获取语言-菜单
  1414. * */
  1415. public function getLanguage(array $data): array
  1416. {
  1417. $result = JobEnum::where('egroup', 'language')->get()->all();
  1418. if (empty($result)) {
  1419. return Result::error("暂无语言", 0);
  1420. }
  1421. return Result::success($result);
  1422. }
  1423. /*
  1424. * 获取掌握程度-菜单
  1425. * */
  1426. public function getLevel(array $data): array
  1427. {
  1428. $result = JobEnum::where('egroup', 'languagetype')->get()->all();
  1429. if (empty($result)) {
  1430. return Result::error("暂无工作性质", 0);
  1431. }
  1432. return Result::success($result);
  1433. }
  1434. // 公司信息
  1435. /*
  1436. * 获取公司性质-菜单
  1437. * */
  1438. public function getCompanyNature(array $data): array
  1439. {
  1440. $result = JobNature::get()->all();
  1441. if (empty($result)) {
  1442. return Result::error("暂无公司性质", 0);
  1443. }
  1444. return Result::success($result);
  1445. }
  1446. /*
  1447. * 获取公司规模-菜单
  1448. * */
  1449. public function getCompanySize(array $data): array
  1450. {
  1451. $result = JobEnum::where('egroup', 'cosize')->get()->all();
  1452. if (empty($result)) {
  1453. return Result::error("暂无公司规模", 0);
  1454. }
  1455. return Result::success($result);
  1456. }
  1457. // 20250306 招聘
  1458. public function addJobHunting(array $data): array
  1459. {
  1460. date_default_timezone_set('Asia/Shanghai');
  1461. unset($data['company_name']);
  1462. unset($data['job_industry']);
  1463. unset($data['job_name']);
  1464. unset($data['department']);
  1465. unset($data['job_timeList']);
  1466. unset($data['job_content']);
  1467. $data['created_at'] = date('Y-m-d H:i:s');
  1468. $data['updated_at'] = date('Y-m-d H:i:s');
  1469. var_dump($data, '-----------------test---------');
  1470. $result = JobHunting::create($data);
  1471. if (empty($result)) {
  1472. return Result::error("添加失败", 0);
  1473. }
  1474. return Result::success($result);
  1475. }
  1476. public function delJobHunting(array $data): array
  1477. {
  1478. $result = JobHunting::where('id', $data['id'])->delete();
  1479. if (empty($result)) {
  1480. return Result::error("删除失败", 0);
  1481. }
  1482. return Result::success($result);
  1483. }
  1484. public function updateJobHunting(array $data): array
  1485. {
  1486. //设置东八区
  1487. date_default_timezone_set('Asia/Shanghai');
  1488. unset($data['company_name']);
  1489. unset($data['job_industry']);
  1490. unset($data['job_name']);
  1491. unset($data['department']);
  1492. unset($data['job_timeList']);
  1493. unset($data['job_content']);
  1494. $data['created_at'] = date('Y-m-d H:i:s');
  1495. $data['updated_at'] = date('Y-m-d H:i:s');
  1496. $result = JobHunting::where('id', $data['id'])->update($data);
  1497. if (empty($result)) {
  1498. return Result::error("更新失败", 0);
  1499. }
  1500. return Result::success($result);
  1501. }
  1502. public function getJobHuntingInfo(array $data): array
  1503. {
  1504. $result = JobHunting::where('id', $data['id'])->first();
  1505. if (empty($result)) {
  1506. return Result::error("查询失败", 0);
  1507. }
  1508. return Result::success($result);
  1509. }
  1510. public function getJobHuntingData(array $data): array
  1511. {
  1512. $jobEnum = JobEnum::get();
  1513. $jobIndustry = JobIndustry::get();
  1514. $jobNature = JobNature::get();
  1515. $jobPosition = JobPosition::get();
  1516. $data = [
  1517. 'jobEnum' => $jobEnum,
  1518. 'jobIndustry' => $jobIndustry,
  1519. 'jobNature' => $jobNature,
  1520. 'jobPosition' => $jobPosition,
  1521. ];
  1522. return Result::success($data);
  1523. }
  1524. public function delJobHuntingInfo(array $data): array
  1525. {
  1526. $result = JobHunting::where('id', $data['id'])->delete();
  1527. return Result::success();
  1528. }
  1529. }