package com.izouma.nineth.web; import com.izouma.nineth.domain.Rice; import com.izouma.nineth.domain.User; import com.izouma.nineth.dto.PageQuery; import com.izouma.nineth.dto.R; import com.izouma.nineth.exception.BusinessException; import com.izouma.nineth.repo.RiceRepo; import com.izouma.nineth.repo.SysConfigRepo; import com.izouma.nineth.repo.UserDetailRepo; import com.izouma.nineth.repo.UserRepo; import com.izouma.nineth.service.RiceService; import com.izouma.nineth.service.SysConfigService; import com.izouma.nineth.service.UserDetailService; import com.izouma.nineth.service.UserService; import com.izouma.nineth.utils.ObjUtils; import com.izouma.nineth.utils.SecurityUtils; import com.izouma.nineth.utils.excel.ExcelUtils; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.data.domain.Page; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.util.List; import java.util.Map; import java.util.Optional; @RestController @RequestMapping("/rice") @AllArgsConstructor @Slf4j public class RiceController extends BaseController { private RiceService riceService; private RiceRepo riceRepo; private UserDetailService userDetailService; private UserDetailRepo userDetailRepo; private UserService userService; private UserRepo userRepo; private SysConfigService sysConfigService; private SysConfigRepo sysConfigRepo; private static final int MAX_NICKNAME_LENGTH = 14; private static final String UPDATE_SUCCESS_MSG = "修改成功"; @PreAuthorize("hasRole('ADMIN')") @PostMapping("/save") public Rice save(@RequestBody Rice record) { if (record.getId() != null) { Rice orig = riceRepo.findById(record.getId()).orElseThrow(new BusinessException("无记录")); ObjUtils.merge(orig, record); return riceRepo.save(orig); } return riceRepo.save(record); } @PreAuthorize("hasRole('ADMIN')") @PostMapping("/all") public Page all(@RequestBody PageQuery pageQuery) { return riceService.all(pageQuery); } @GetMapping("/get/{id}") public Rice get(@PathVariable Long id) { return riceRepo.findById(id).orElseThrow(new BusinessException("无记录")); } @PostMapping("/del/{id}") public void del(@PathVariable Long id) { riceRepo.softDelete(id); } @GetMapping("/excel") @ResponseBody public void excel(HttpServletResponse response, PageQuery pageQuery) throws IOException { List data = all(pageQuery).getContent(); ExcelUtils.export(response, data); } //点击水稻游戏后对riceuser进行初始化赋值 @GetMapping("/current") public R> getCurrentUser() throws BusinessException { User authenticatedUser = SecurityUtils.getAuthenticatedUser(); return R.success(riceService.getCurrentRiceUser(authenticatedUser)); } //修改用户昵称 @PostMapping("/updateNickName") public R updateNickName(@RequestParam("userId") Long userId, @RequestParam("nickname") String nickname) { return riceService.updateNickName(userId, nickname); } //等级显示 @GetMapping("/showLevel") public R getCurrentLevel() { User authenticatedUser = SecurityUtils.getAuthenticatedUser(); Long authId = authenticatedUser.getId(); Optional byUserId = riceRepo.findByUserId(authId); if (byUserId.isPresent()) { Rice rice = byUserId.get(); String currentLevel = riceService.getCurrentLevel(rice.getEmpiricalValue()); return R.success("查询成功").add("riceLevel", currentLevel); } else { throw new BusinessException("用户不存在"); } } //获取用户积分 @GetMapping("/selfScore") public R getCurrentScore() { return riceService.getCurrentScore(); } //一个获取积分排行榜的接口 @GetMapping("/scoreRanking") public R>> getScoreRanking() { List> top100 = riceService.getTop100(); return R.success(top100); } }