App_Controller_NewsController.proxy.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245
  1. <?php
  2. declare (strict_types=1);
  3. namespace App\Controller;
  4. use App\JsonRpc\NewsServiceInterface;
  5. use App\Tools\PublicData;
  6. use Hyperf\Di\Annotation\Inject;
  7. use Hyperf\HttpServer\Annotation\AutoController;
  8. use App\Tools\Result;
  9. use Hyperf\Validation\Contract\ValidatorFactoryInterface;
  10. use Hyperf\Context\Context;
  11. /**
  12. * Class NewsController
  13. * @package App\Controller
  14. */
  15. //#[AutoController]
  16. class NewsController extends AbstractController
  17. {
  18. use \Hyperf\Di\Aop\ProxyTrait;
  19. use \Hyperf\Di\Aop\PropertyHandlerTrait;
  20. function __construct()
  21. {
  22. if (method_exists(parent::class, '__construct')) {
  23. parent::__construct(...func_get_args());
  24. }
  25. $this->__handlePropertyHandler(__CLASS__);
  26. }
  27. #[Inject]
  28. protected ValidatorFactoryInterface $validationFactory;
  29. /**
  30. * @var NewsServiceInterface
  31. */
  32. #[Inject]
  33. private $newsServiceClient;
  34. /**
  35. * 导航池列表
  36. * @return void
  37. */
  38. public function getCategoryList()
  39. {
  40. $requireData = $this->request->all();
  41. $validator = $this->validationFactory->make($requireData, ['page' => 'required', 'pageSize' => 'required'], ['page.required' => '第几页不能为空', 'pageSize.required' => '每页显示条数不能为空']);
  42. if ($validator->fails()) {
  43. $errorMessage = $validator->errors()->first();
  44. return Result::error($errorMessage);
  45. }
  46. $result = $this->newsServiceClient->getCategoryList($requireData);
  47. if ($result['data']) {
  48. foreach ($result['data']['rows'] as $k => $v) {
  49. $result['data']['rows'][$k]['pid_arr'] = $v['pid_arr'] ? json_decode($v['pid_arr']) : [0];
  50. }
  51. }
  52. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  53. }
  54. /**
  55. * 站点下的导航池
  56. * @return void
  57. */
  58. public function categoryList()
  59. {
  60. $requireData = $this->request->all();
  61. $validator = $this->validationFactory->make($requireData, ['pid' => 'required'], ['pid.required' => '父级ID不能为空']);
  62. if ($validator->fails()) {
  63. $errorMessage = $validator->errors()->first();
  64. return Result::error($errorMessage);
  65. }
  66. $result = $this->newsServiceClient->categoryList($requireData);
  67. $rep = PublicData::buildMenuTree($result['data']);
  68. return $result ? Result::success($rep) : Result::error($result['message']);
  69. }
  70. /**
  71. * 添加导航
  72. * @return array|void
  73. */
  74. public function addCategory()
  75. {
  76. $requireData = $this->request->all();
  77. $validator = $this->validationFactory->make($requireData, ['name' => 'required', 'seo_title' => 'required', 'seo_keywords' => 'required', 'seo_description' => 'required'], ['name.required' => '导航池名称不能为空', 'seo_title.required' => 'seo标题名称不能为空', 'seo_keywords.required' => 'seo关键词不能为空', 'seo_description.required' => 'seo描述不能为空']);
  78. if ($validator->fails()) {
  79. $errorMessage = $validator->errors()->first();
  80. return Result::error($errorMessage);
  81. }
  82. $requireData['pid'] = isset($requireData['pid_arr']) ? end($requireData['pid_arr']) : '';
  83. $requireData['pid_arr'] = isset($requireData['pid_arr']) ? json_encode($requireData['pid_arr']) : '';
  84. $requireData['city_id'] = isset($requireData['city_arr_id']) ? end($requireData['city_arr_id']) : '';
  85. $requireData['city_arr_id'] = isset($requireData['city_arr_id']) ? json_encode($requireData['city_arr_id']) : '';
  86. $requireData['department_id'] = isset($requireData['department_arr_id']) ? end($requireData['department_arr_id']) : '';
  87. $requireData['department_arr_id'] = isset($requireData['department_arr_id']) ? json_encode($requireData['department_arr_id']) : '';
  88. $result = $this->newsServiceClient->addCategory($requireData);
  89. return $result ? Result::success($result['data']) : Result::error($result['message']);
  90. }
  91. /**
  92. * 更新导航池
  93. * @return array
  94. */
  95. public function updateCategory()
  96. {
  97. $requireData = $this->request->all();
  98. $validator = $this->validationFactory->make($requireData, ['id' => 'required', 'name' => 'required', 'seo_title' => 'required', 'seo_keywords' => 'required', 'seo_description' => 'required'], ['id.required' => 'ID不能为空', 'name.required' => '栏目池名称不能为空', 'seo_title.required' => 'seo标题名称不能为空', 'seo_keywords.required' => 'seo关键词不能为空', 'seo_description.required' => 'seo描述不能为空']);
  99. if ($validator->fails()) {
  100. $errorMessage = $validator->errors()->first();
  101. return Result::error($errorMessage);
  102. }
  103. $requireData['pid'] = isset($requireData['pid_arr']) ? end($requireData['pid_arr']) : '';
  104. $requireData['pid_arr'] = isset($requireData['pid_arr']) ? json_encode($requireData['pid_arr']) : '';
  105. $requireData['city_id'] = isset($requireData['city_arr_id']) ? end($requireData['city_arr_id']) : '';
  106. $requireData['city_arr_id'] = isset($requireData['city_arr_id']) ? json_encode($requireData['city_arr_id']) : '';
  107. $requireData['department_id'] = isset($requireData['department_arr_id']) ? end($requireData['department_arr_id']) : '';
  108. $requireData['department_arr_id'] = isset($requireData['department_arr_id']) ? json_encode($requireData['department_arr_id']) : '';
  109. $result = $this->newsServiceClient->updateCategory($requireData);
  110. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  111. }
  112. /**
  113. * 删除分类
  114. * @return array
  115. */
  116. public function delCategory()
  117. {
  118. $requireData = $this->request->all();
  119. $validator = $this->validationFactory->make($requireData, ['id' => 'required'], ['id.required' => 'id不能为空']);
  120. if ($validator->fails()) {
  121. $errorMessage = $validator->errors()->first();
  122. return Result::error($errorMessage);
  123. }
  124. $result = $this->newsServiceClient->delCategory($requireData);
  125. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  126. }
  127. /**
  128. * 资讯列表
  129. * @return void
  130. */
  131. public function getArticleList()
  132. {
  133. $requireData = $this->request->all();
  134. $requireData['website_id'] = $this->websiteId;
  135. var_dump("资讯:", $requireData);
  136. $result = $this->newsServiceClient->getArticleList($requireData);
  137. //1通过,2待审核,3待发 4,拒绝 5删除
  138. $statusList = ['1' => '通过', '2' => '待审核', '3' => '待发', '4' => '拒绝', '5' => '删除'];
  139. if ($result['data']) {
  140. foreach ($result['data']['rows'] as $k => $v) {
  141. $result['data']['rows'][$k]['cat_arr_id'] = $v['cat_arr_id'] ? json_decode($v['cat_arr_id']) : [0];
  142. $result['data']['rows'][$k]['tag'] = $v['tag'] ? json_decode($v['tag']) : [];
  143. $result['data']['rows'][$k]['status_name'] = $statusList[$v['status']];
  144. $result['data']['rows'][$k]['level'] = (string) $v['level'];
  145. $result['data']['rows'][$k]['islink'] = isset($v['islink']) && $v['islink'] > 0 ? true : false;
  146. }
  147. }
  148. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  149. }
  150. /**
  151. * 获取导航池信息
  152. * @return void
  153. */
  154. public function getCategoryInfo()
  155. {
  156. $requireData = $this->request->all();
  157. $validator = $this->validationFactory->make($requireData, ['id' => 'required'], ['id.required' => 'id不能为空']);
  158. if ($validator->fails()) {
  159. $errorMessage = $validator->errors()->first();
  160. return Result::error($errorMessage);
  161. }
  162. $result = $this->newsServiceClient->getCategoryInfo($requireData);
  163. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  164. }
  165. /**
  166. * 添加分类
  167. * @return array|void
  168. */
  169. public function addArticle()
  170. {
  171. $requireData = $this->request->all();
  172. $validator = $this->validationFactory->make($requireData, ['title' => 'required', 'catid' => 'required', 'author' => 'required'], ['title.required' => '标题不能为空', 'catid.required' => '分类不能为空', 'author.required' => '作者不能为空']);
  173. if ($validator->fails()) {
  174. $errorMessage = $validator->errors()->first();
  175. return Result::error($errorMessage);
  176. }
  177. if (isset($requireData['catid']) && is_array($requireData['catid'])) {
  178. $requireData['cat_arr_id'] = json_encode($requireData['catid']);
  179. $requireData['catid'] = end($requireData['catid']);
  180. } else {
  181. $id = [0];
  182. $requireData['cat_arr_id'] = json_encode($id);
  183. $requireData['catid'] = end($id);
  184. }
  185. $loginIp = $this->request->getHeader('x-forwarded-for')[0] ?? $this->request->getHeader('x-real-ip')[0] ?? $this->request->getServerParams()['remote_addr'] ?? '0.0.0.0';
  186. $requireData['ip'] = $loginIp;
  187. $requireData['website_id'] = $this->websiteId;
  188. $requireData['admin_user_id'] = Context::get("UserId");
  189. $result = $this->newsServiceClient->addArticle($requireData);
  190. return $result ? Result::success($result['data']) : Result::error($result['message']);
  191. }
  192. public function updateArticle()
  193. {
  194. $requireData = $this->request->all();
  195. $validator = $this->validationFactory->make($requireData, ['id' => 'required', 'name' => 'required'], ['name.required' => '分类名称不能为空', 'id.required' => 'ID不能为空']);
  196. if ($validator->fails()) {
  197. $errorMessage = $validator->errors()->first();
  198. return Result::error($errorMessage);
  199. }
  200. if (isset($requireData['pid']) && is_array($requireData['pid'])) {
  201. $requireData['pid_arr'] = json_encode($requireData['pid']);
  202. $requireData['pid'] = end($requireData['pid']);
  203. } else {
  204. $id = [0];
  205. $requireData['pid_arr'] = json_encode($id);
  206. $requireData['pid'] = end($id);
  207. }
  208. $requireData['website_id'] = $this->websiteId;
  209. $result = $this->newsServiceClient->updateArticle($requireData);
  210. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  211. }
  212. /**
  213. * 删除分类
  214. * @return array
  215. */
  216. public function delArticle()
  217. {
  218. $requireData = $this->request->all();
  219. $validator = $this->validationFactory->make($requireData, ['id' => 'required'], ['id.required' => 'id不能为空']);
  220. if ($validator->fails()) {
  221. $errorMessage = $validator->errors()->first();
  222. return Result::error($errorMessage);
  223. }
  224. $requireData['website_id'] = $this->websiteId;
  225. $result = $this->newsServiceClient->delArticle($requireData);
  226. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  227. }
  228. /**
  229. * 获取资讯信息
  230. * @return array
  231. */
  232. public function getArticleInfo()
  233. {
  234. $requireData = $this->request->all();
  235. $validator = $this->validationFactory->make($requireData, ['id' => 'required'], ['id.required' => 'id不能为空']);
  236. if ($validator->fails()) {
  237. $errorMessage = $validator->errors()->first();
  238. return Result::error($errorMessage);
  239. }
  240. $result = $this->newsServiceClient->getArticleInfo($requireData);
  241. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  242. }
  243. }