ArticleMapController.php 8.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Http\Resources\ArticleMapResource;
  4. use App\Models\Article;
  5. use App\Models\ArticleCollection;
  6. use App\Models\Collection;
  7. use App\Services\AuthService;
  8. use Illuminate\Http\Request;
  9. use Illuminate\Http\Response;
  10. class ArticleMapController extends Controller
  11. {
  12. /**
  13. * Display a listing of the resource.
  14. *
  15. * @return Response
  16. */
  17. public function index(Request $request)
  18. {
  19. $request->validate([
  20. 'id' => ['required', 'uuid'],
  21. ]);
  22. switch ($request->input('view')) {
  23. case 'anthology':
  24. $table = ArticleCollection::where('collect_id', $request->input('id'))
  25. ->leftJoin('articles', 'articles.uid', '=', 'article_collections.article_id');
  26. break;
  27. case 'article':
  28. $table = ArticleCollection::where('article_id', $request->input('id'))
  29. ->leftJoin('articles', 'articles.uid', '=', 'article_collections.article_id');
  30. break;
  31. default:
  32. return $this->error('unknown view', null, 422);
  33. }
  34. $count = $table->count();
  35. $result = [];
  36. if (! empty($request->input('parent'))) {
  37. // 输出某节点的子节点
  38. $node = $table->where('article_id', $request->input('parent'))->first();
  39. if ($node) {
  40. $nodeList = ArticleCollection::where('collect_id', $request->input('id'))
  41. ->where('id', '>', (int) $node->id)->orderBy('id')->get();
  42. foreach ($nodeList as $key => $curr) {
  43. if ($curr->level <= $node->level) {
  44. break;
  45. }
  46. if ($request->has('lazy')) {
  47. if ($curr->level === $node->level + 1) {
  48. $result[] = $curr;
  49. }
  50. } else {
  51. $result[] = $curr;
  52. }
  53. }
  54. }
  55. } else {
  56. if ($request->has('lazy') && $count > 300) {
  57. $table = $table->where('level', 1);
  58. }
  59. $result = $table->select([
  60. 'article_collections.id',
  61. 'collect_id',
  62. 'article_id',
  63. 'level',
  64. 'article_collections.title',
  65. 'children',
  66. 'article_collections.editor_id',
  67. 'article_collections.deleted_at',
  68. 'articles.status',
  69. ])->orderBy('id')->get();
  70. }
  71. return $this->ok(['rows' => ArticleMapResource::collection($result), 'count' => $count]);
  72. }
  73. /**
  74. * Store a newly created resource in storage.
  75. *
  76. * @return Response
  77. */
  78. public function store(Request $request)
  79. {
  80. //
  81. $validated = $request->validate([
  82. 'anthology_id' => 'required',
  83. 'operation' => 'required',
  84. ]);
  85. $collection = Collection::find($request->input('anthology_id'));
  86. if (! $collection) {
  87. return $this->error('no recorder');
  88. }
  89. // 鉴权
  90. $user = AuthService::current($request);
  91. if (! $user) {
  92. return $this->error(__('auth.failed'));
  93. }
  94. if (! CollectionController::UserCanEdit($user['user_uid'], $collection)) {
  95. return $this->error(__('auth.failed'));
  96. }
  97. switch ($validated['operation']) {
  98. case 'add':
  99. // 添加多个文章到文集
  100. $count = 0;
  101. foreach ($request->input('article_id') as $key => $article) {
  102. // code...
  103. if (! ArticleCollection::where('article_id', $article)
  104. ->where('collect_id', $request->input('anthology_id'))
  105. ->exists()) {
  106. $new = new ArticleCollection;
  107. $new->id = app('snowflake')->id();
  108. $new->article_id = $article;
  109. $new->collect_id = $request->input('anthology_id');
  110. $new->title = Article::find($article)->title;
  111. $new->level = 1;
  112. $new->editor_id = $user['user_id'];
  113. $new->save();
  114. $count++;
  115. }
  116. }
  117. return $this->ok($count);
  118. break;
  119. default:
  120. return $this->error('unknown operation');
  121. break;
  122. }
  123. }
  124. /**
  125. * Display the specified resource.
  126. *
  127. * @param ArticleCollection $articleCollection
  128. * @return Response
  129. */
  130. public function show(string $articleCollection)
  131. {
  132. //
  133. $id = explode('_', $articleCollection);
  134. $result = ArticleCollection::where('article_id', $id[0])
  135. ->where('collect_id', $id[1])
  136. ->first();
  137. if ($result) {
  138. return $this->ok(new ArticleMapResource($result));
  139. } else {
  140. return $this->error('no');
  141. }
  142. }
  143. /**
  144. * Update the specified resource in storage.
  145. *
  146. * @return Response
  147. */
  148. public function update(Request $request, string $id)
  149. {
  150. //
  151. $validated = $request->validate([
  152. 'operation' => 'required',
  153. ]);
  154. $collection = Collection::find($id);
  155. if (! $collection) {
  156. return $this->error('no recorder');
  157. }
  158. // 鉴权
  159. $user = AuthService::current($request);
  160. if (! $user) {
  161. return $this->error(__('auth.failed'));
  162. }
  163. if (! CollectionController::UserCanEdit($user['user_uid'], $collection)) {
  164. return $this->error(__('auth.failed'));
  165. }
  166. switch ($validated['operation']) {
  167. case 'anthology':
  168. $delete = ArticleCollection::where('collect_id', $id)->delete();
  169. $count = 0;
  170. foreach ($request->input('data') as $key => $row) {
  171. // code...
  172. $new = new ArticleCollection;
  173. $new->id = app('snowflake')->id();
  174. $new->article_id = $row['article_id'];
  175. $new->collect_id = $id;
  176. $new->title = $row['title'];
  177. $new->level = $row['level'];
  178. $new->children = $row['children'];
  179. $new->editor_id = $user['user_id'];
  180. if (isset($row['deleted_at'])) {
  181. $new->deleted_at = $row['deleted_at'];
  182. }
  183. $new->save();
  184. $count++;
  185. }
  186. ArticleMapController::updateCollection($id);
  187. return $this->ok($count);
  188. break;
  189. }
  190. }
  191. /**
  192. * Remove the specified resource from storage.
  193. *
  194. * @return Response
  195. */
  196. public function destroy(ArticleCollection $articleCollection)
  197. {
  198. //
  199. }
  200. public static function deleteArticle(string $articleId)
  201. {
  202. // 查找有这个文章的文集
  203. $collections = ArticleCollection::where('article_id', $articleId)
  204. ->select('collect_id')
  205. ->groupBy('collect_id')
  206. ->get();
  207. // 设置为删除
  208. ArticleCollection::where('article_id', $articleId)
  209. ->update(['deleted_at' => now()]);
  210. // 查找没有下级文章的文集
  211. $updateCollections = ArticleCollection::where('article_id', $articleId)
  212. ->where('children', 0)
  213. ->select('collect_id')
  214. ->groupBy('collect_id')
  215. ->get();
  216. // 真的删除没有下级文章的文集中的文章
  217. $count = ArticleCollection::where('article_id', $articleId)
  218. ->where('children', 0)
  219. ->delete();
  220. // 更新改动的文集
  221. foreach ($updateCollections as $collection) {
  222. // code...
  223. ArticleMapController::updateCollection($collection->collect_id);
  224. }
  225. return [count($collections), $count];
  226. }
  227. public static function deleteCollection(string $collectionId)
  228. {
  229. $count = ArticleCollection::where('collect_id', $collectionId)
  230. ->delete();
  231. return $count;
  232. }
  233. /**
  234. * 用表中的数据生成json,更新collection 表中的字段
  235. */
  236. public static function updateCollection(string $collectionId)
  237. {
  238. $result = ArticleCollection::where('collect_id', $collectionId)
  239. ->select(['article_id', 'level', 'title'])
  240. ->orderBy('id')->get();
  241. Collection::where('uid', $collectionId)
  242. ->update(['article_list' => json_encode($result, JSON_UNESCAPED_UNICODE)]);
  243. return count($result);
  244. }
  245. }