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 cn.hutool.core.util.StrUtil; 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.core.domain.entity.SysDept; import com.ltkj.common.utils.StringUtils; 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.ISysDeptService; import com.ltkj.system.service.ISysUserService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import jodd.util.StringUtil; 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; @Autowired private ISysDeptService sysDeptService; @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 && !StringUtils.isBlank(userId)) { 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().isEmpty()) { 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, @RequestParam(required = false) @ApiParam(value ="建议内容") String jynr, @RequestParam(required = false) @ApiParam(value ="建议标题") String jybt, @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); if(StringUtil.isNotBlank(jynr)) wq.like(TjAdvice::getAdvice,jynr); if(StringUtil.isNotBlank(jybt)) wq.like(TjAdvice::getTitle,jybt); wq.and(i -> i.eq(TjAdvice::getAdSex, sex).or().isNull(TjAdvice::getAdSex)); 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.isEmpty()) { 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 = "标题") @RequestParam(required = false) String bt, @ApiParam(value = "建议") @RequestParam(required = false) String nr, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize, @RequestParam(required = false)String deptId) { // LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); // wrapper.eq(SysDept::getParentId, 0); // SysDept sysDept = sysDeptService.getOne(wrapper); // 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.isEmpty()) { // for (TjProject project : projectList) { // LambdaQueryWrapper wqq = new LambdaQueryWrapper<>(); // wqq.eq(TjAdvice::getProId, project.getProId()); // if (!deptId.equals(String.valueOf(sysDept.getDeptId()))) { // wqq.eq(TjAdvice::getDept_id, deptId); // } // IPage adviceList = tjAdviceService.page(page1, wqq); // if (null != adviceList.getRecords() && !adviceList.getRecords().isEmpty()) { // for (TjAdvice record : adviceList.getRecords()) { // record.setProName(project.getProName()); // String kjbq = record.getKjbq(); // if(null !=kjbq && !kjbq.isEmpty()){ // String[] split = kjbq.split(","); // record.setKjbqz(Arrays.asList(split)); // } // } // list.addAll(adviceList.getRecords()); // } // total = adviceList.getTotal(); // } // } // map.put("list", list); // map.put("total", total); // List list1 = tjAdviceService.selectList(proName,deptId,(page -1) * pageSize,pageSize); // return AjaxResult.success(map); // } // LambdaQueryWrapper wq=new LambdaQueryWrapper<>(); // if(!StringUtil.isBlank(bt)) wq.like(TjAdvice::getTitle,bt); // if(!StringUtil.isBlank(nr)) wq.like(TjAdvice::getAdvice,nr); // if (!deptId.equals(String.valueOf(sysDept.getDeptId()))) { // wq.eq(TjAdvice::getDept_id, deptId); // } // Page page2 = tjAdviceService.page(page1,wq); // list = page2.getRecords(); // if (null != list && !list.isEmpty()) { // 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()); List tjAdvices = tjAdviceService.selectList(proName, deptId, (page - 1) * pageSize, pageSize,bt,nr); Integer count = tjAdviceService.selectListCount(proName, deptId,bt,nr); HashMap hashMap = new HashMap<>(); hashMap.put("list",tjAdvices); hashMap.put("total",count); return AjaxResult.success(hashMap); } /** * 导出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)); } }