package com.ltkj.web.controller.system; import java.nio.channels.NonReadableChannelException; import java.util.*; import java.util.stream.Collectors; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ltkj.common.annotation.Excel; import com.ltkj.common.utils.poi.ExcelUtil; import com.ltkj.framework.config.UserHoder; import com.ltkj.hosp.domain.TjAdvice; import com.ltkj.hosp.domain.TjAdviceKjbq; import com.ltkj.hosp.domain.TjProject; import com.ltkj.hosp.domain.TjUserAdvice; import com.ltkj.hosp.service.ITjAdviceService; import com.ltkj.hosp.service.ITjProjectService; import com.ltkj.hosp.service.TjAdviceKjbqService; import com.ltkj.hosp.service.TjUserAdviceService; import com.ltkj.system.service.ISysUserService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; import com.ltkj.common.annotation.Log; import com.ltkj.common.core.domain.AjaxResult; import com.ltkj.common.enums.BusinessType; /** * adviceController * * @author ltkj * @date 2022-11-24 */ @RestController @RequestMapping("/advice/advice") @Api(tags = "体检建议管理接口") public class TjAdviceController { @Resource private ITjAdviceService tjAdviceService; @Resource private ITjProjectService tjProjectService; @Resource private TjAdviceKjbqService kjbqService; @Resource private TjUserAdviceService userAdviceService; @Autowired private ISysUserService userService; @PostMapping("/addTjAdviceKjbq") @ApiOperation(value = "新增体检建议快捷标签接口") public AjaxResult addTjAdviceKjbq(@RequestBody TjAdviceKjbq adviceKjbq) { return AjaxResult.success(kjbqService.save(adviceKjbq)); } @DeleteMapping("/deletedTjAdviceKjbq") @ApiOperation(value = "根据id删除体检建议快捷标签接口") public AjaxResult deletedTjAdviceKjbq(@RequestParam Long adviceKjbqId) { return AjaxResult.success(kjbqService.removeById(adviceKjbqId)); } @PutMapping("/updateTjAdviceKjbq") @ApiOperation(value = "修改体检建议快捷标签接口") public AjaxResult updateTjAdviceKjbq(@RequestBody TjAdviceKjbq adviceKjbq) { return AjaxResult.success(kjbqService.updateById(adviceKjbq)); } @PostMapping("/updateQybzTjAdviceKjbqById") @ApiOperation(value = "修改体检建议快捷标签启用状态接口") public AjaxResult updateQybzTjAdviceKjbqById(@RequestParam int qybz, @RequestParam Long id) { TjAdviceKjbq kjbq = kjbqService.getById(id); kjbq.setQyzt(String.valueOf(qybz)); return AjaxResult.success(kjbqService.updateById(kjbq)); } @GetMapping("/getTjAdviceKjbqByFl") @ApiOperation(value = "根据标签分类查询体检建议快捷标签接口") public AjaxResult getTjAdviceKjbqByFl(@RequestParam(required = false) @ApiParam(value = "用户id 传当前登录人 超管登录时不传 为null") String userId, @RequestParam(required = false) @ApiParam(value = "启用状态 0启用 1停用") Integer qyzt, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); Page page1 = new Page<>(page, pageSize); if (null != userId && !userId.equals("")) { wq.eq(TjAdviceKjbq::getUserId, userId); } if (null != qyzt) { wq.eq(TjAdviceKjbq::getQyzt, qyzt); } Page kjbqPage = kjbqService.page(page1, wq); if (null != kjbqPage.getRecords() && kjbqPage.getRecords().size() > 0) { for (TjAdviceKjbq record : kjbqPage.getRecords()) { if (null != record.getUserId()) { record.setUserName(userService.getById(record.getUserId()).getNickName()); } } } return AjaxResult.success(kjbqPage); } @GetMapping("/getKjTjAdviceKjbqBySex") @ApiOperation(value = "根据体检人性别和是否为总检查询体检建议接口") public AjaxResult getKjTjAdviceKjbqBySex(@RequestParam String sex, @RequestParam @ApiParam(value = "1常规医生 0总检") String isZj, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); Page page1 = new Page<>(page, pageSize); wq.eq(TjAdvice::getAdSex, sex).or().isNull(TjAdvice::getAdSex); wq.eq(TjAdvice::getIsZj, isZj); Page kjbqPage = tjAdviceService.page(page1, wq); return AjaxResult.success(kjbqPage); } @GetMapping("/getCyTjAdviceKjbqBySex") @ApiOperation(value = "根据当前登录人id获取常用建议") public AjaxResult getCyTjAdviceKjbqBySex(@RequestParam String sex, @RequestParam @ApiParam(value = "用户id 传当前登录人") Long userId, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); Page page1 = new Page<>(page, pageSize); // wq.eq(TjAdvice::getAdSex,sex).or().eq(TjAdvice::getAdSex,"2"); if (null != userId) { LambdaQueryWrapper wq0 = new LambdaQueryWrapper<>(); wq0.eq(TjUserAdvice::getUserId, userId); List list = userAdviceService.list(wq0); if (null != list && list.size() > 0) { List longs = list.stream().map(TjUserAdvice::getAdviceId).collect(Collectors.toList()); wq.in(TjAdvice::getId,longs); wq.last("and (ad_sex=1 OR ad_sex=2)"); Page kjbqPage = tjAdviceService.page(page1,wq); return AjaxResult.success(kjbqPage); } } return AjaxResult.success("该用户暂时没有常用建议!"); } @GetMapping("/addCyTjAdviceByUserId") @ApiOperation(value = "添加当前登录人常用建议接口") public AjaxResult addCyTjAdviceByUserId(@RequestParam @ApiParam(value = "所选建议主键id数组") List adviceIds) { String userId = UserHoder.getLoginUser().getUserId(); if (null != adviceIds && adviceIds.size() > 0) { for (Long id : adviceIds) { TjUserAdvice tjUserAdvice = userAdviceService.getTjUserAdviceByUserId(Long.valueOf(userId), id); if (null == tjUserAdvice) { TjUserAdvice userAdvice = new TjUserAdvice(); userAdvice.setAdviceId(id); userAdvice.setUserId(Long.valueOf(userId)); userAdviceService.save(userAdvice); } } return AjaxResult.success("添加成功!"); } return AjaxResult.success("请选择您要添加的建议!"); } @PostMapping("/addCyTjAdvice") @ApiOperation(value = "添加常用建议接口") public AjaxResult addCyTjAdvice(@RequestBody TjAdvice adviceId) { String userId = UserHoder.getLoginUser().getUserId(); if (null != adviceId) { if (tjAdviceService.save(adviceId)) { TjUserAdvice tjUserAdvice = userAdviceService.getTjUserAdviceByUserId(Long.valueOf(userId),adviceId.getId()); if (null == tjUserAdvice) { TjUserAdvice userAdvice = new TjUserAdvice(); userAdvice.setAdviceId(adviceId.getId()); userAdvice.setUserId(Long.valueOf(userId)); userAdviceService.save(userAdvice); } } return AjaxResult.success("操作成功!"); } return AjaxResult.success("请选择您要添加的建议!"); } // ================/**/================================================================================================================================== /** * 查询advice列表 */ // @PreAuthorize("@ss.hasPermi('advice:advice:list')") @GetMapping("/list") @ApiOperation(value = "体检建议列表查询") public AjaxResult list(@RequestParam(required = false) @ApiParam(value = "项目名") String proName, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { Page page1 = new Page<>(page, pageSize); Map map = new HashMap<>(); List list = null; long total = 0; if (null != proName) { LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); list = new ArrayList<>(); wq.like(TjProject::getProName, proName); List projectList = tjProjectService.list(wq); if (null != projectList && projectList.size() > 0) { for (TjProject project : projectList) { LambdaQueryWrapper wqq = new LambdaQueryWrapper<>(); wqq.eq(TjAdvice::getProId, project.getProId()); IPage adviceList = tjAdviceService.page(page1, wqq); if (null != adviceList.getRecords() && adviceList.getRecords().size() > 0) { for (TjAdvice record : adviceList.getRecords()) { record.setProName(project.getProName()); String kjbq = record.getKjbq(); if(null !=kjbq && !kjbq.equals("")){ String[] split = kjbq.split(","); record.setKjbqz(Arrays.asList(split)); } } list.addAll(adviceList.getRecords()); } total = adviceList.getTotal(); } } map.put("list", list); map.put("total", total); return AjaxResult.success(map); } Page page2 = tjAdviceService.page(page1); list = page2.getRecords(); if (null != list && list.size() > 0) { for (TjAdvice advice : list) { TjProject tjProject = tjProjectService.getById(advice.getProId()); if (null != tjProject) { advice.setProName(tjProject.getProName()); } String kjbq = advice.getKjbq(); if(null !=kjbq && !kjbq.equals("")){ String[] split = kjbq.split(","); advice.setKjbqz(Arrays.asList(split)); } } } map.put("list", list); map.put("total", page2.getTotal()); return AjaxResult.success(map); } /** * 导出advice列表 */ // @PreAuthorize("@ss.hasPermi('advice:advice:export')") @Log(title = "advice", businessType = BusinessType.EXPORT) @PostMapping("/export") public void export(HttpServletResponse response, TjAdvice tjAdvice) { List list = tjAdviceService.selectTjAdviceList(tjAdvice); ExcelUtil util = new ExcelUtil(TjAdvice.class); util.exportExcel(response, list, "advice数据"); } /** * 获取advice详细信息 */ // @PreAuthorize("@ss.hasPermi('advice:advice:query')") @GetMapping(value = "/{id}") @ApiOperation(value = "根据主键id获取advice详细信息") public AjaxResult getInfo(@PathVariable("id") Long id) { TjAdvice advice = tjAdviceService.getById(id); if(null !=advice){ String kjbq = advice.getKjbq(); if(null !=kjbq && !kjbq.equals("")){ String[] split = kjbq.split(","); advice.setKjbqz(Arrays.asList(split)); } } return AjaxResult.success(advice); } /** * 新增advice */ // @PreAuthorize("@ss.hasPermi('advice:advice:add')") @Log(title = "advice", businessType = BusinessType.INSERT) @PostMapping @ApiOperation(value = "新增体检建议接口") public AjaxResult add(@RequestBody TjAdvice tjAdvice) { return AjaxResult.success(tjAdviceService.save(tjAdvice)); } /** * 修改advice */ // @PreAuthorize("@ss.hasPermi('advice:advice:edit')") @Log(title = "advice", businessType = BusinessType.UPDATE) @PutMapping public AjaxResult edit(@RequestBody TjAdvice tjAdvice) { return AjaxResult.success(tjAdviceService.updateById(tjAdvice)); } /** * 删除advice */ // @PreAuthorize("@ss.hasPermi('advice:advice:remove')") @Log(title = "advice", businessType = BusinessType.DELETE) @DeleteMapping("/{ids}") public AjaxResult remove(@PathVariable Long[] ids) { return AjaxResult.success(tjAdviceService.deleteTjAdviceByIds(ids)); } }