App_Controller_NewsController.proxy.php 9.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229
  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. /**
  11. * Class NewsController
  12. * @package App\Controller
  13. */
  14. //#[AutoController]
  15. class NewsController extends AbstractController
  16. {
  17. use \Hyperf\Di\Aop\ProxyTrait;
  18. use \Hyperf\Di\Aop\PropertyHandlerTrait;
  19. function __construct(\Hyperf\Logger\LoggerFactory $loggerFactory)
  20. {
  21. if (method_exists(parent::class, '__construct')) {
  22. parent::__construct(...func_get_args());
  23. }
  24. $this->__handlePropertyHandler(__CLASS__);
  25. }
  26. #[Inject]
  27. protected ValidatorFactoryInterface $validationFactory;
  28. /**
  29. * @var NewsServiceInterface
  30. */
  31. #[Inject]
  32. private $newsServiceClient;
  33. /**
  34. * 分类列表
  35. * @return void
  36. */
  37. public function getCategoryList()
  38. {
  39. $requireData = $this->request->all();
  40. $validator = $this->validationFactory->make($requireData, ['pid' => 'required'], ['pid.required' => 'pid不能为空']);
  41. if ($validator->fails()) {
  42. $errorMessage = $validator->errors()->first();
  43. return Result::error($errorMessage);
  44. }
  45. $requireData['website_id'] = $this->websiteId;
  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['website_id'] = $this->websiteId;
  61. $result = $this->newsServiceClient->categoryList($requireData);
  62. var_dump($result);
  63. $rep = PublicData::buildMenuTree($result['data']);
  64. return $result ? Result::success($rep) : Result::error($result['message']);
  65. }
  66. /**
  67. * 添加分类
  68. * @return array|void
  69. */
  70. public function addCategory()
  71. {
  72. $requireData = $this->request->all();
  73. $validator = $this->validationFactory->make($requireData, ['name' => 'required'], ['name.required' => '分类名称不能为空']);
  74. if ($validator->fails()) {
  75. $errorMessage = $validator->errors()->first();
  76. return Result::error($errorMessage);
  77. }
  78. if (isset($requireData['pid']) && is_array($requireData['pid'])) {
  79. $requireData['pid_arr'] = json_encode($requireData['pid']);
  80. $requireData['pid'] = end($requireData['pid']);
  81. } else {
  82. $id = [0];
  83. $requireData['pid_arr'] = json_encode($id);
  84. $requireData['pid'] = end($id);
  85. }
  86. $requireData['website_id'] = $this->websiteId;
  87. $result = $this->newsServiceClient->addCategory($requireData);
  88. return $result ? Result::success($result['data']) : Result::error($result['message']);
  89. }
  90. public function updateCategory()
  91. {
  92. $requireData = $this->request->all();
  93. $validator = $this->validationFactory->make($requireData, ['id' => 'required', 'name' => 'required'], ['name.required' => '分类名称不能为空', 'id.required' => 'ID不能为空']);
  94. if ($validator->fails()) {
  95. $errorMessage = $validator->errors()->first();
  96. return Result::error($errorMessage);
  97. }
  98. if (isset($requireData['pid']) && is_array($requireData['pid'])) {
  99. $requireData['pid_arr'] = json_encode($requireData['pid']);
  100. $requireData['pid'] = end($requireData['pid']);
  101. } else {
  102. $id = [0];
  103. $requireData['pid_arr'] = json_encode($id);
  104. $requireData['pid'] = end($id);
  105. }
  106. $requireData['website_id'] = $this->websiteId;
  107. $result = $this->newsServiceClient->updateCategory($requireData);
  108. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  109. }
  110. /**
  111. * 删除分类
  112. * @return array
  113. */
  114. public function delCategory()
  115. {
  116. $requireData = $this->request->all();
  117. $validator = $this->validationFactory->make($requireData, ['id' => 'required'], ['id.required' => 'id不能为空']);
  118. if ($validator->fails()) {
  119. $errorMessage = $validator->errors()->first();
  120. return Result::error($errorMessage);
  121. }
  122. $requireData['website_id'] = $this->websiteId;
  123. $result = $this->newsServiceClient->delCategory($requireData);
  124. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  125. }
  126. /**
  127. * 资讯列表
  128. * @return void
  129. */
  130. public function getArticleList()
  131. {
  132. $requireData = $this->request->all();
  133. $requireData['website_id'] = $this->websiteId;
  134. var_dump("资讯:", $requireData);
  135. $result = $this->newsServiceClient->getArticleList($requireData);
  136. //1通过,2待审核,3待发 4,拒绝 5删除
  137. $statusList = ['1' => '通过', '2' => '待审核', '3' => '待发', '4' => '拒绝', '5' => '删除'];
  138. if ($result['data']) {
  139. foreach ($result['data']['rows'] as $k => $v) {
  140. $result['data']['rows'][$k]['cat_arr_id'] = $v['cat_arr_id'] ? json_decode($v['cat_arr_id']) : [0];
  141. $result['data']['rows'][$k]['tag'] = $v['tag'] ? json_decode($v['tag']) : [];
  142. $result['data']['rows'][$k]['status_name'] = $statusList[$v['status']];
  143. $result['data']['rows'][$k]['level'] = (string) $v['level'];
  144. $result['data']['rows'][$k]['islink'] = isset($v['islink']) && $v['islink'] > 0 ? true : false;
  145. }
  146. }
  147. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  148. }
  149. /**
  150. * 添加分类
  151. * @return array|void
  152. */
  153. public function addArticle()
  154. {
  155. $requireData = $this->request->all();
  156. $validator = $this->validationFactory->make($requireData, ['title' => 'required', 'catid' => 'required', 'author' => 'required'], ['title.required' => '标题不能为空', 'catid.required' => '分类不能为空', 'author.required' => '作者不能为空']);
  157. if ($validator->fails()) {
  158. $errorMessage = $validator->errors()->first();
  159. return Result::error($errorMessage);
  160. }
  161. if (isset($requireData['catid']) && is_array($requireData['catid'])) {
  162. $requireData['cat_arr_id'] = json_encode($requireData['catid']);
  163. $requireData['catid'] = end($requireData['catid']);
  164. } else {
  165. $id = [0];
  166. $requireData['cat_arr_id'] = json_encode($id);
  167. $requireData['catid'] = end($id);
  168. }
  169. $loginIp = $this->request->getHeader('x-forwarded-for')[0] ?? $this->request->getHeader('x-real-ip')[0] ?? $this->request->getServerParams()['remote_addr'] ?? '0.0.0.0';
  170. $requireData['ip'] = $loginIp;
  171. $requireData['website_id'] = $this->websiteId;
  172. $requireData['admin_user_id'] = $this->UserId;
  173. $result = $this->newsServiceClient->addArticle($requireData);
  174. return $result ? Result::success($result['data']) : Result::error($result['message']);
  175. }
  176. public function updateArticle()
  177. {
  178. $requireData = $this->request->all();
  179. $validator = $this->validationFactory->make($requireData, ['id' => 'required', 'name' => 'required'], ['name.required' => '分类名称不能为空', 'id.required' => 'ID不能为空']);
  180. if ($validator->fails()) {
  181. $errorMessage = $validator->errors()->first();
  182. return Result::error($errorMessage);
  183. }
  184. if (isset($requireData['pid']) && is_array($requireData['pid'])) {
  185. $requireData['pid_arr'] = json_encode($requireData['pid']);
  186. $requireData['pid'] = end($requireData['pid']);
  187. } else {
  188. $id = [0];
  189. $requireData['pid_arr'] = json_encode($id);
  190. $requireData['pid'] = end($id);
  191. }
  192. $requireData['website_id'] = $this->websiteId;
  193. $result = $this->newsServiceClient->updateArticle($requireData);
  194. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  195. }
  196. /**
  197. * 删除分类
  198. * @return array
  199. */
  200. public function delArticle()
  201. {
  202. $requireData = $this->request->all();
  203. $validator = $this->validationFactory->make($requireData, ['id' => 'required'], ['id.required' => 'id不能为空']);
  204. if ($validator->fails()) {
  205. $errorMessage = $validator->errors()->first();
  206. return Result::error($errorMessage);
  207. }
  208. $requireData['website_id'] = $this->websiteId;
  209. $result = $this->newsServiceClient->delArticle($requireData);
  210. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  211. }
  212. /**
  213. * 获取资讯信息
  214. * @return array
  215. */
  216. public function getArticleInfo()
  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. $result = $this->newsServiceClient->getArticleInfo($requireData);
  225. return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
  226. }
  227. }