HistoryController.java 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. package com.free.controller;
  2. import java.time.LocalDateTime;
  3. import java.util.HashMap;
  4. import java.util.List;
  5. import java.util.Map;
  6. import javax.validation.Valid;
  7. import com.free.service.HistoryService;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.web.bind.annotation.DeleteMapping;
  10. import org.springframework.web.bind.annotation.GetMapping;
  11. import org.springframework.web.bind.annotation.PathVariable;
  12. import org.springframework.web.bind.annotation.PostMapping;
  13. import org.springframework.web.bind.annotation.RequestBody;
  14. import org.springframework.web.bind.annotation.RequestMapping;
  15. import org.springframework.web.bind.annotation.RequestParam;
  16. import org.springframework.web.bind.annotation.RestController;
  17. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  18. import com.baomidou.mybatisplus.core.metadata.IPage;
  19. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  20. import com.free.annotation.PassToken;
  21. import com.free.config.CustomizationException;
  22. import com.free.config.ExceptionEnum;
  23. import com.free.config.ResponseFormat;
  24. import com.free.entity.History;
  25. import io.swagger.annotations.Api;
  26. import io.swagger.annotations.ApiOperation;
  27. @RestController
  28. @RequestMapping("/history")
  29. @Api(tags = "历史记录")
  30. public class HistoryController {
  31. @Autowired
  32. private HistoryService service;
  33. @PassToken
  34. /** 创建数据 */
  35. @ApiOperation("创建数据")
  36. @PostMapping("")
  37. public Object save(@RequestBody @Valid History data) {
  38. QueryWrapper checkHasQw = new QueryWrapper<>();
  39. checkHasQw.eq("user_id", data.getUser_id());
  40. checkHasQw.eq("question_id", data.getQuestion_id());
  41. History dbData = this.service.getOne(checkHasQw);
  42. if (null == dbData) {
  43. // 没有数据,创建新的数据
  44. data.setTime(LocalDateTime.now());
  45. this.service.save(data);
  46. QueryWrapper qw = new QueryWrapper<>();
  47. qw.eq("id", data.getId());
  48. Map returnData = this.service.getMap(qw);
  49. return ResponseFormat.success(returnData);
  50. } else {
  51. // 有数据, 浏览次数加1
  52. dbData.setViews(dbData.getViews() + 1);
  53. dbData.setTime(LocalDateTime.now());
  54. this.service.updateById(dbData);
  55. Object newData = this.service.getById(dbData.getId());
  56. return ResponseFormat.success(newData);
  57. }
  58. }
  59. /** 修改数据, 接口不需要 */
  60. @PassToken
  61. @ApiOperation("修改数据")
  62. // @PostMapping("/{id}")
  63. public Object update(@PathVariable long id, @RequestBody History data) {
  64. QueryWrapper qw = new QueryWrapper<>();
  65. qw.eq("id", id);
  66. Long num = this.service.count(qw);
  67. if (num <= 0) {
  68. throw new CustomizationException(ExceptionEnum.NOT_FOUND);
  69. }
  70. data.setId(id);
  71. this.service.updateById(data);
  72. Object newData = this.service.getById(id);
  73. return ResponseFormat.success(newData);
  74. }
  75. /** 列表查询 */
  76. @PassToken
  77. @ApiOperation("查询数据列表")
  78. @SuppressWarnings({ "unchecked" })
  79. @GetMapping()
  80. public Object list(@RequestParam Map<String, Object> allParams) {
  81. Long skip = null, limit = null;
  82. Map map = new HashMap();
  83. QueryWrapper qw = new QueryWrapper<>();
  84. qw.orderByDesc("time");
  85. /** 参数处理处理 */
  86. for (String key : allParams.keySet()) {
  87. Object value = allParams.get(key);
  88. if (key.equals("skip")) {
  89. skip = Long.valueOf(String.valueOf(value));
  90. } else if (key.equals("limit")) {
  91. limit = Long.valueOf(String.valueOf(value));
  92. } else {
  93. // 其他为查询条件
  94. qw.eq(key, value);
  95. }
  96. }
  97. /** 分页处理 */
  98. if (null != skip && null != limit) {
  99. IPage page = new Page<>(skip, limit);
  100. IPage pageResult = service.page(page, qw);
  101. List<History> data = pageResult.getRecords();
  102. List<Map> newData = service.getQuestionsName(data);
  103. long total = pageResult.getTotal();
  104. map.put("data", newData);
  105. map.put("total", total);
  106. } else {
  107. List<History> list = service.list(qw);
  108. List<Map> newData = service.getQuestionsName(list);
  109. map.put("data", newData);
  110. }
  111. return ResponseFormat.success(map);
  112. }
  113. /** 根据id查询 */
  114. @PassToken
  115. @ApiOperation("查询数据")
  116. @GetMapping("/{id}")
  117. public Object fetch(@PathVariable long id) {
  118. Object newData = service.getById(id);
  119. return ResponseFormat.success(newData);
  120. }
  121. /** 根据id删除数据 */
  122. @PassToken
  123. @ApiOperation("删除数据")
  124. @DeleteMapping("/{id}")
  125. public Object delete(@PathVariable long id) {
  126. QueryWrapper qw = new QueryWrapper<>();
  127. qw.eq("id", id);
  128. Long num = service.count(qw);
  129. if (num <= 0) {
  130. throw new CustomizationException(ExceptionEnum.NOT_FOUND);
  131. }
  132. service.removeById(id);
  133. return ResponseFormat.success();
  134. }
  135. /** 根据user_id删除数据 */
  136. @PassToken
  137. @ApiOperation("清空用户数据")
  138. @DeleteMapping("/clear/{user_id}")
  139. public Object clear(@PathVariable long user_id) {
  140. QueryWrapper qw = new QueryWrapper<>();
  141. qw.eq("user_id", user_id);
  142. service.remove(qw);
  143. return ResponseFormat.success();
  144. }
  145. }