package com.izouma.nineth.web; import com.izouma.nineth.config.MetaConstants; import com.izouma.nineth.domain.MetaProp; import com.izouma.nineth.domain.MetaTask; import com.izouma.nineth.dto.MetaRestResult; import com.izouma.nineth.dto.PageQuery; import com.izouma.nineth.enums.MetaAwardTypeEnum; import com.izouma.nineth.enums.MetaTaskTarget; import com.izouma.nineth.exception.BusinessException; import com.izouma.nineth.repo.CollectionRepo; import com.izouma.nineth.repo.MetaPropRepo; import com.izouma.nineth.repo.MetaTaskRepo; import com.izouma.nineth.repo.MetaTaskToUserRepo; import com.izouma.nineth.service.MetaTaskService; import com.izouma.nineth.utils.ObjUtils; import com.izouma.nineth.utils.excel.ExcelUtils; import lombok.AllArgsConstructor; import org.springframework.data.domain.Page; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.util.Arrays; import java.util.List; import java.util.Objects; @RestController @RequestMapping("/metaTask") @AllArgsConstructor public class MetaTaskController extends BaseController { private MetaTaskService metaTaskService; private MetaTaskRepo metaTaskRepo; private MetaTaskToUserRepo metaTaskToUserRepo; private CollectionRepo collectionRepo; private MetaPropRepo metaPropRepo; //@PreAuthorize("hasRole('ADMIN')") @PostMapping("/save") public MetaTask save(@RequestBody MetaTask record) { if (record.getType().equals(MetaTaskTarget.COLLECT_COLLECTION)) { String[] split = record.getValue().split(MetaConstants.BLANK); Arrays.stream(split).forEach(collectionId -> { collectionRepo.findByIdAndDelFalse(Long.parseLong(collectionId)).orElseThrow(new BusinessException(String.format("不存在collectionId[%S]的藏品", collectionId))); }); } if (record.getId() != null) { MetaTask orig = metaTaskRepo.findById(record.getId()).orElseThrow(new BusinessException("无记录")); ObjUtils.merge(orig, record); if (MetaAwardTypeEnum.GOLD.equals(record.getAwardType())) { orig.setAwardPic(null); orig.setMetaPropId(null); } if (MetaAwardTypeEnum.NFT.equals(record.getAwardType())) { orig.setGoldNum(0); orig.setMetaPropId(null); } if (MetaAwardTypeEnum.META_PROP.equals(record.getAwardType())) { orig.setGoldNum(0); orig.setAwardPic(null); } return metaTaskRepo.save(orig); } return metaTaskRepo.save(record); } //@PreAuthorize("hasRole('ADMIN')") @PostMapping("/all") public Page all(@RequestBody PageQuery pageQuery) { return metaTaskService.all(pageQuery); } @GetMapping("/get/{id}") public MetaTask get(@PathVariable Long id) { return metaTaskRepo.findById(id).orElseThrow(new BusinessException("无记录")); } @PostMapping("/del/{id}") public void del(@PathVariable Long id) { metaTaskRepo.softDelete(id); } @GetMapping("/excel") @ResponseBody public void excel(HttpServletResponse response, PageQuery pageQuery) throws IOException { List data = all(pageQuery).getContent(); ExcelUtils.export(response, data); } @GetMapping("/findAll") public MetaRestResult> findAll() { List metaTasks = metaTaskRepo.findAllByPublishAndDelAndFinish(true, false, false); return MetaRestResult.returnSuccess(metaTasks); } @GetMapping("/{userId}/{channelId}/canGet") public MetaRestResult> canGet(@PathVariable Long userId, @PathVariable Long channelId) { List metaTasks = metaTaskRepo.canGet(userId, channelId); metaTasks.forEach(metaTask -> { if (MetaAwardTypeEnum.META_PROP.equals(metaTask.getAwardType()) && Objects.nonNull(metaTask.getMetaPropId())) { MetaProp metaProp = metaPropRepo.findByIdAndDel(metaTask.getMetaPropId(), false); if (Objects.isNull(metaProp)) { throw new BusinessException(String.format("道具[%S]不存在!", metaTask.getMetaPropId())); } metaTask.setMetaProp(metaProp); } }); return MetaRestResult.returnSuccess(metaTasks); } @PostMapping("/{id}/finish") private void finish(@PathVariable Long id) { metaTaskService.finish(id); } }