package com.ltkj.web.controller.system; import java.io.*; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; import cn.hutool.core.date.DateUtil; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.google.common.base.Joiner; import com.ltkj.common.core.domain.TreeSelect; import com.ltkj.common.core.domain.entity.SysRole; import com.ltkj.common.core.domain.entity.SysUser; import com.ltkj.common.core.redis.RedisCache; import com.ltkj.common.core.text.Convert; import com.ltkj.common.utils.SecurityUtils; import com.ltkj.common.utils.bean.BeanUtils; import com.ltkj.framework.config.MatchUtils; import com.ltkj.hosp.domain.*; import com.ltkj.hosp.mapper.TestMapper; import com.ltkj.hosp.service.*; import com.ltkj.system.domain.SysPost; import com.ltkj.system.domain.SysUserPost; import com.ltkj.system.service.*; import com.ltkj.web.controller.his.HisApiGetMethodService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.ArrayUtils; import org.apache.ibatis.jdbc.Null; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.ConvertingCursor; import org.springframework.data.redis.core.Cursor; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ScanOptions; import org.springframework.data.redis.serializer.RedisSerializer; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import com.ltkj.common.annotation.Log; import com.ltkj.common.constant.UserConstants; import com.ltkj.common.core.controller.BaseController; import com.ltkj.common.core.domain.AjaxResult; import com.ltkj.common.core.domain.entity.SysDept; import com.ltkj.common.enums.BusinessType; import com.ltkj.common.utils.StringUtils; import javax.annotation.Resource; /** * 部门信息 * * @author ltkj */ @RestController @RequestMapping("/system/dept") @Api(tags = "科室部门信息") @Slf4j public class SysDeptController extends BaseController implements Serializable { @Resource private ISysDeptService deptService; @Resource private ITjCustomerService customerService; @Resource private ITjProjectService projectService; @Autowired private ITjRuleAdviceService tjRuleAdviceService; @Resource private ITjOrderService orderService; @Resource private ITjOrderRemarkService remarkService; @Resource private ITjOrderDetailService detailService; @Resource private ISysUserService userService; @Resource private ITjStandardService tjStandardService; @Resource private ITjAdviceService tjAdviceService; @Resource private ITjCustomerService tjCustomerService; @Resource private ISysUserPostService userPostService; @Resource private ISysPostService postService; @Resource private TjAsyncService asyncService; @Resource private RedisCache redisCache; @Autowired private ITjOrderDetailRulesService tjOrderDetailRulesService; @Autowired private ITjRulesService tjRulesService; @Autowired public RedisTemplate redisTemplate; @Resource private TestMapper testMapper; @Autowired private ISysConfigService configService; @Autowired private ITjFlowingWaterService tjFlowingWaterService; @Autowired private HisApiGetMethodService hisApiGetMethodService; @Autowired private LtkjJianchajianyanTreeService ltkjJianchajianyanTreeService; /** * 该体检科室下客户列表显示接口 */ @GetMapping("/getProList") @ApiOperation("该体检科室下客户列表显示接口") public AjaxResult getProList(@ApiParam(value = "体检单号") @RequestParam(required = false) String tjNumber, @ApiParam(value = "0未检,1已检") @RequestParam(defaultValue = "0") Integer type, @ApiParam(value = "姓名)") @RequestParam(required = false) String name, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { String userId = SecurityUtils.getLoginUser().getUserId(); Integer ksId = null; SysUser sysUser = null; if (null != userId) { sysUser = userService.getById(Long.valueOf(userId)); if (null != sysUser) { ksId = Math.toIntExact(sysUser.getDeptId()); } } if (ksId == null) { return AjaxResult.error("请输入科室id"); } //根据当前登陆的人的科室id，获取该科室下的所有项目 List postIds = sysUser.getPostIds(); List ksproList = null; if (postIds != null) { for (Long postId : postIds) { LambdaQueryWrapper wq111 = new LambdaQueryWrapper<>(); wq111.eq(SysUserPost::getPostId, postId); SysUserPost one = userPostService.getOne(wq111); if (one != null) { SysPost byId = postService.getById(one.getPostId()); if (byId.getPostName().equals("录入员")) { ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId)); } } } } else { ksproList = projectService.getKsTjProjectIdList(); } if (ksproList == null || ksproList.size() == 0) { return AjaxResult.error("请完善科室项目信息"); } List customerLis = new ArrayList<>(); if(null==name) name=""; if(null==tjNumber) tjNumber=""; // //根据体检号查 // if (null != tjNumber) { // List orderList = orderService.getOrderListByLikeTjNum(tjNumber); // if (null == orderList) { // return AjaxResult.success("暂时没有数据"); // } // for (TjOrder order : orderList) { // List list = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); // if (list.size() == 0) { // continue; // } // LambdaQueryWrapper wqs = new LambdaQueryWrapper<>(); // wqs.eq(TjOrderRemark::getTjNumber, order.getTjNumber()); // wqs.in(TjOrderRemark::getType, 0,3); // List lists = remarkService.list(wqs); // TjCustomer customer = customerService.getById(order.getUserId()); // // //遍历项目 判断是否有重大阳性 标记 // for (TjOrderDetail tjOrderDetail11 : list) { // customer.setIsPositive(tjOrderDetail11.getIsPositive()); // if (tjOrderDetail11.getIsPositive()==1){ // break; // } // } // // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); // customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); // customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); // if (null != lists && lists.size() > 0) { // StringBuilder stringBuilder = new StringBuilder(); // for (TjOrderRemark remark : lists) { // TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); // TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); // if (one.getFlowingWaterId() != null) { // stringBuilder.append(byId.getProName()).append(";"); // } // // } // customer.setNotCheckeds(String.valueOf(stringBuilder)); // customer.setTjStatus(0L); // } else { // customer.setTjStatus(1L); // customer.setNotCheckeds("无"); // } // if (order.getTjType().equals("1")) { // customer.setTjType("团体"); // } // if (order.getTjType().equals("2")) { // customer.setTjType("个人"); // } // customer.setTjTime(order.getCreateTime()); // customer.setTjNumber(order.getTjNumber()); // customer.setOrderId(order.getOrderId()); // customer.setIsHz(order.getIsHz()); // customer.setTjCategory(order.getTjCategory()); // customerLis.add(customer); // } // if (customerLis.size() > 0) { // List customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Collections.reverse(customerList); // Map map = new HashMap<>(); // map.put("date", customerList); // map.put("total", customerLis.size()); // return AjaxResult.success(map); // } else { // return AjaxResult.success("暂无数据"); // } // } // // //根据姓名查询 // if (null != name && !"".equals(name)) { // LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); // wq.like(TjCustomer::getCusName, name); // List list = customerService.list(wq); // List list11111 = new ArrayList<>(); // if (null != list && list.size() > 0) { // for (TjCustomer customer : list) { // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); // customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); // customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); // List orderList = orderService.getOrderListByCusId(String.valueOf(customer.getCusId())); // if (null != orderList && orderList.size() > 0) { // for (TjOrder order : orderList) { // List list111 = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); // if (list111.size() == 0) { // continue; // } // //遍历项目 判断是否有重大阳性 标记 // for (TjOrderDetail tjOrderDetail11 : list111) { // customer.setIsPositive(tjOrderDetail11.getIsPositive()); // if (tjOrderDetail11.getIsPositive()==1){ // break; // } // } // List lists = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber()); // if (null != lists && lists.size() > 0) { // StringBuilder stringBuilder = new StringBuilder(); // for (TjOrderRemark remark : lists) { // TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); // TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); // if (one.getFlowingWaterId() != null) { // stringBuilder.append(byId.getProName()).append(";"); // } // } // customer.setNotCheckeds(String.valueOf(stringBuilder)); // if (null == customer.getNotCheckeds()) customer.setNotCheckeds("全部已检"); // customer.setTjStatus(0L); // } else { // customer.setNotCheckeds("无"); // customer.setTjStatus(1L); // } // if (order.getTjType().equals("1")) { // customer.setTjType("团体"); // } // if (order.getTjType().equals("2")) { // customer.setTjType("个人"); // } // customer.setTjTime(order.getCreateTime()); // customer.setTjNumber(order.getTjNumber()); // customer.setOrderId(order.getOrderId()); // customer.setIsHz(order.getIsHz()); // customer.setTjCategory(order.getTjCategory()); // list11111.add(customer); // } // } // } // if (list11111.size() == 0) { // return AjaxResult.success("暂无数据"); // } // Map map = new HashMap<>(); // List customers = list11111.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Collections.reverse(customers); // map.put("customers", customers); // map.put("total", list11111.size()); // return AjaxResult.success(map); // } else { // return AjaxResult.success("暂无数据"); // } // } // List customerLists = new ArrayList<>(); // String key="*"; // if(sysUser.isAdmin()){ // key="ks"+":*"; // }else { // key="ks:"+ksId+":*"; // } // ScanOptions options = ScanOptions.scanOptions() // //这里指定每次扫描key的数量(很多博客瞎说要指定Integer.MAX_VALUE，这样的话跟 keys有什么区别？) // .count(10000) // .match(key).build(); // RedisSerializer redisSerializer = (RedisSerializer) redisTemplate.getKeySerializer(); // 0未检,1已检 Map map=null; if (type == 0) { // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); // List customers = new ArrayList<>(); // while(cursor.hasNext()){ // String s = cursor.next().toString(); // TjCustomer wj = redisCache.getCacheMapValue(s,"0"); // if(null !=wj){ // customers.add(wj); // } // } //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a // cursor.close(); // customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj"); map = deptService.getSysDeptYjWjCustomerList13(String.valueOf(ksId), name, tjNumber, 0, page, pageSize); // customerLists = customers; } if (type == 1) { // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); // List customers = new ArrayList<>(); // while(cursor.hasNext()){ // String s = cursor.next().toString(); // TjCustomer wj = redisCache.getCacheMapValue(s,"1"); // if(null !=wj){ // customers.add(wj); // } // } //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a // cursor.close(); // customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj"); map = deptService.getSysDeptYjWjCustomerList13(String.valueOf(ksId), name, tjNumber, 1, page, pageSize); // customerLists = customers; } return AjaxResult.success(map); // asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId)); // if (null !=customerLists && customerLists.size() > 0) { // Collections.reverse(customerLists); // List customerList = customerLists.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Map map = new HashMap<>(); // map.put("date", customerList); // map.put("total", customerLists.size()); // return AjaxResult.success(map); // } else { // AjaxResult map = getAjaxResult(type, page, pageSize, ksproList, customerLis); // if (map != null) return map; // return AjaxResult.success("暂时没有数据"); // } } private AjaxResult getAjaxResult(Integer type, Integer page, Integer pageSize, List ksproList, List customerLis) { LambdaQueryWrapper wq1 = new LambdaQueryWrapper<>(); wq1.eq(TjOrderDetail::getTjStatus, type); wq1.in(TjOrderDetail::getProId, ksproList); wq1.isNotNull(TjOrderDetail::getFlowingWaterId); wq1.orderByDesc(TjOrderDetail::getCreateTime); List detailList = detailService.list(wq1); if (null != detailList && detailList.size() > 0) { //收集orderId并去重 List orderIds = detailList.stream().collect(Collectors.collectingAndThen(Collectors.toCollection( () -> new TreeSet<>(Comparator.comparing(TjOrderDetail::getOrderId)) ), ArrayList::new)).stream().map(TjOrderDetail::getOrderId).collect(Collectors.toList()); for (Long orderId : orderIds) { if (null != orderId) { TjOrder order = orderService.getById(orderId); if(null ==order){ continue; } if (type == 1) { List list = detailService.getTjOrderDetailListByOrderIdAndStatus(String.valueOf(orderId)); if (null != list && list.size() > 0) { continue; } } TjCustomer customer = customerService.getById(order.getUserId()); if (null != customer) { if (order.getTjType().equals("1")) { customer.setTjType("团体"); } if (order.getTjType().equals("2")) { customer.setTjType("个人"); } customer.setTjTime(order.getCreateTime()); customer.setTjNumber(order.getTjNumber()); customer.setOrderId(orderId); customer.setIsHz(order.getIsHz()); customer.setTjStatus(Long.valueOf(type)); List list = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber()); if (null != list && list.size() > 0) { StringBuilder stringBuilder = new StringBuilder(); for (TjOrderRemark remark : list) { TjProject byId = projectService.getById(remark.getProId()); if(null !=byId){ stringBuilder.append(byId.getProName()).append(";"); } } customer.setNotCheckeds(String.valueOf(stringBuilder)); if (null == customer.getNotCheckeds()) customer.setNotCheckeds("全部已检"); } customerLis.add(customer); } } } if (customerLis.size() > 0) { List customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); Collections.reverse(customerList); Map map = new HashMap<>(); map.put("date", customerList); map.put("total", customerLis.size()); return AjaxResult.success(map); } } return null; } /** * 化验检查页面列表 */ @GetMapping("/huaYangetProList") @ApiOperation("化验检查页面列表") public AjaxResult huaYangetProList(@ApiParam(value = "体检单号") @RequestParam(required = false) String tjNumber, @ApiParam(value = "0未检,1已检") @RequestParam(defaultValue = "0") Integer type, @ApiParam(value = "姓名)") @RequestParam(required = false) String name, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { // String userId = SecurityUtils.getLoginUser().getUserId(); // Integer ksId = null; // SysUser sysUser = null; // if (null != userId) { // sysUser = userService.getById(Long.valueOf(userId)); // if (null != sysUser) { // ksId = Math.toIntExact(sysUser.getDeptId()); // } // } // if (ksId == null) { // return AjaxResult.error("请输入科室id"); // } //A30化验 //根据当前登陆的人的科室id，获取该科室下的所有项目 // List postIds = sysUser.getPostIds(); List ksproList = null; // if (postIds != null) { // for (Long postId : postIds) { // LambdaQueryWrapper wq111 = new LambdaQueryWrapper<>(); // wq111.eq(SysUserPost::getPostId, postId); // SysUserPost one = userPostService.getOne(wq111); // if (one != null) { // SysPost byId = postService.getById(one.getPostId()); // if (byId.getPostName().equals("录入员")) { // ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId)); // } // } // } // } else { // ksproList = projectService.getKsTjProjectIdList(); // } // if(sysUser.getUserName().equals("10001")){ ksproList = projectService.getHuaYanProId(); // } // else { // ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId)); // } if (ksproList == null || ksproList.size() == 0) { return AjaxResult.error("请完善科室项目信息"); } //筛选化验的项目。 // ksproList = ksproList.stream() // .filter(element -> element ==1633660948860522629L) // .collect(Collectors.toList()); List customerLis = new ArrayList<>(); /* //根据体检号查 if (null != tjNumber) { List orderList = orderService.getOrderListByLikeTjNum(tjNumber); if (null == orderList) { return AjaxResult.success("暂时没有数据"); } for (TjOrder order : orderList) { List list = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); if (list.size() == 0) { continue; } LambdaQueryWrapper wqs = new LambdaQueryWrapper<>(); wqs.eq(TjOrderRemark::getTjNumber, order.getTjNumber()); wqs.in(TjOrderRemark::getType, 0,3); List lists = remarkService.list(wqs); TjCustomer customer = customerService.getById(order.getUserId()); //遍历项目 判断是否有重大阳性 标记 for (TjOrderDetail tjOrderDetail11 : list) { customer.setIsPositive(tjOrderDetail11.getIsPositive()); if (tjOrderDetail11.getIsPositive()==1){ break; } } customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); if (null != lists && lists.size() > 0) { StringBuilder stringBuilder = new StringBuilder(); for (TjOrderRemark remark : lists) { TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); if (one.getFlowingWaterId() != null) { stringBuilder.append(byId.getProName()).append(";"); } } customer.setNotCheckeds(String.valueOf(stringBuilder)); customer.setTjStatus(0L); } else { customer.setTjStatus(1L); customer.setNotCheckeds("无"); } if (order.getTjType().equals("1")) { customer.setTjType("团体"); } if (order.getTjType().equals("2")) { customer.setTjType("个人"); } customer.setTjTime(order.getCreateTime()); customer.setTjNumber(order.getTjNumber()); customer.setOrderId(order.getOrderId()); customer.setIsHz(order.getIsHz()); customerLis.add(customer); } if (customerLis.size() > 0) { List customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); Collections.reverse(customerList); Map map = new HashMap<>(); map.put("date", customerList); map.put("total", customerLis.size()); return AjaxResult.success(map); } else { return AjaxResult.success("暂无数据"); } } //根据姓名查询 if (null != name && !"".equals(name)) { LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); wq.like(TjCustomer::getCusName, name); List list = customerService.list(wq); List list11111 = new ArrayList<>(); if (null != list && list.size() > 0) { for (TjCustomer customer : list) { customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); List orderList = orderService.getOrderListByCusId(String.valueOf(customer.getCusId())); if (null != orderList && orderList.size() > 0) { for (TjOrder order : orderList) { List list111 = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); if (list111.size() == 0) { continue; } //遍历项目 判断是否有重大阳性 标记 for (TjOrderDetail tjOrderDetail11 : list111) { customer.setIsPositive(tjOrderDetail11.getIsPositive()); if (tjOrderDetail11.getIsPositive()==1){ break; } } List lists = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber()); if (null != lists && lists.size() > 0) { StringBuilder stringBuilder = new StringBuilder(); for (TjOrderRemark remark : lists) { TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); if (one.getFlowingWaterId() != null) { stringBuilder.append(byId.getProName()).append(";"); } } customer.setNotCheckeds(String.valueOf(stringBuilder)); if (null == customer.getNotCheckeds()) customer.setNotCheckeds("全部已检"); customer.setTjStatus(0L); } else { customer.setNotCheckeds("无"); customer.setTjStatus(1L); } if (order.getTjType().equals("1")) { customer.setTjType("团体"); } if (order.getTjType().equals("2")) { customer.setTjType("个人"); } customer.setTjTime(order.getCreateTime()); customer.setTjNumber(order.getTjNumber()); customer.setOrderId(order.getOrderId()); customer.setIsHz(order.getIsHz()); list11111.add(customer); } } } if (list11111.size() == 0) { return AjaxResult.success("暂无数据"); } Map map = new HashMap<>(); List customers = list11111.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); Collections.reverse(customers); map.put("customers", customers); map.put("total", list11111.size()); return AjaxResult.success(map); } else { return AjaxResult.success("暂无数据"); } } List customerLists = null;*/ // //根据体检号查 // if (null != tjNumber) { // List orderList = orderService.getOrderListByLikeTjNum(tjNumber); // if (null == orderList) { // return AjaxResult.success("暂时没有数据"); // } // for (TjOrder order : orderList) { // List list = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); // if (list.size() == 0) { // continue; // } // LambdaQueryWrapper wqs = new LambdaQueryWrapper<>(); // wqs.eq(TjOrderRemark::getTjNumber, order.getTjNumber()); // wqs.in(TjOrderRemark::getType, 0,3); // List lists = remarkService.list(wqs); // TjCustomer customer = customerService.getById(order.getUserId()); // // //遍历项目 判断是否有重大阳性 标记 // for (TjOrderDetail tjOrderDetail11 : list) { // customer.setIsPositive(tjOrderDetail11.getIsPositive()); // if (tjOrderDetail11.getIsPositive()==1){ // break; // } // } // // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); // customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); // customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); // if (null != lists && lists.size() > 0) { // StringBuilder stringBuilder = new StringBuilder(); // for (TjOrderRemark remark : lists) { // TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); // TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); // if (one.getFlowingWaterId() != null) { // stringBuilder.append(byId.getProName()).append(";"); // } // // } // customer.setNotCheckeds(String.valueOf(stringBuilder)); // customer.setTjStatus(0L); // } else { // customer.setTjStatus(1L); // customer.setNotCheckeds("无"); // } // if (order.getTjType().equals("1")) { // customer.setTjType("团体"); // } // if (order.getTjType().equals("2")) { // customer.setTjType("个人"); // } // customer.setTjTime(order.getCreateTime()); // customer.setTjNumber(order.getTjNumber()); // customer.setOrderId(order.getOrderId()); // customer.setIsHz(order.getIsHz()); // customer.setTjCategory(order.getTjCategory()); // customerLis.add(customer); // } // if (customerLis.size() > 0) { // List customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Collections.reverse(customerList); // Map map = new HashMap<>(); // map.put("date", customerList); // map.put("total", customerLis.size()); // return AjaxResult.success(map); // } else { // return AjaxResult.success("暂无数据"); // } // } // // //根据姓名查询 // if (null != name && !"".equals(name)) { // LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); // wq.like(TjCustomer::getCusName, name); // List list = customerService.list(wq); // List list11111 = new ArrayList<>(); // if (null != list && list.size() > 0) { // for (TjCustomer customer : list) { // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); // customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); // customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); // List orderList = orderService.getOrderListByCusId(String.valueOf(customer.getCusId())); // if (null != orderList && orderList.size() > 0) { // for (TjOrder order : orderList) { // List list111 = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); // if (list111.size() == 0) { // continue; // } // //遍历项目 判断是否有重大阳性 标记 // for (TjOrderDetail tjOrderDetail11 : list111) { // customer.setIsPositive(tjOrderDetail11.getIsPositive()); // if (tjOrderDetail11.getIsPositive()==1){ // break; // } // } // List lists = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber()); // if (null != lists && lists.size() > 0) { // StringBuilder stringBuilder = new StringBuilder(); // for (TjOrderRemark remark : lists) { // TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); // TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); // if (one.getFlowingWaterId() != null) { // stringBuilder.append(byId.getProName()).append(";"); // } // } // customer.setNotCheckeds(String.valueOf(stringBuilder)); // if (null == customer.getNotCheckeds()) customer.setNotCheckeds("全部已检"); // customer.setTjStatus(0L); // } else { // customer.setNotCheckeds("无"); // customer.setTjStatus(1L); // } // if (order.getTjType().equals("1")) { // customer.setTjType("团体"); // } // if (order.getTjType().equals("2")) { // customer.setTjType("个人"); // } // customer.setTjTime(order.getCreateTime()); // customer.setTjNumber(order.getTjNumber()); // customer.setOrderId(order.getOrderId()); // customer.setIsHz(order.getIsHz()); // customer.setTjCategory(order.getTjCategory()); // list11111.add(customer); // } // } // } // if (list11111.size() == 0) { // return AjaxResult.success("暂无数据"); // } // Map map = new HashMap<>(); // List customers = list11111.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Collections.reverse(customers); // map.put("customers", customers); // map.put("total", list11111.size()); // return AjaxResult.success(map); // } else { // return AjaxResult.success("暂无数据"); // } // } // List customerLists = new ArrayList<>(); // String key="*"; // if(sysUser.isAdmin()){ // key="ks"+":*"; // }else { // key="ks:"+ksId+":*"; // } // ScanOptions options = ScanOptions.scanOptions() // //这里指定每次扫描key的数量(很多博客瞎说要指定Integer.MAX_VALUE，这样的话跟 keys有什么区别？) // .count(10000) // .match(key).build(); // RedisSerializer redisSerializer = (RedisSerializer) redisTemplate.getKeySerializer(); // 0未检,1已检 Map map=null; if (type == 0) { // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); // List customers = new ArrayList<>(); // while(cursor.hasNext()){ // String s = cursor.next().toString(); // TjCustomer wj = redisCache.getCacheMapValue(s,"0"); // if(null !=wj){ // customers.add(wj); // } // } //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a // cursor.close(); // customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj"); map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A30", name, tjNumber, 0, page, pageSize); // customerLists = customers; } if (type == 1) { // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); // List customers = new ArrayList<>(); // while(cursor.hasNext()){ // String s = cursor.next().toString(); // TjCustomer wj = redisCache.getCacheMapValue(s,"1"); // if(null !=wj){ // customers.add(wj); // } // } //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a // cursor.close(); // customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj"); map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A30", name, tjNumber, 1, page, pageSize); // customerLists = customers; } // asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId)); // AjaxResult map = getAjaxResult(type, page, pageSize, ksproList, customerLis); // if (map != null) return map; return AjaxResult.success(map); } /** * 影像检查页面列表 */ @GetMapping("/yingXiangGetProList") @ApiOperation("影像检查页面列表") public AjaxResult yingXiangGetProList(@ApiParam(value = "体检单号") @RequestParam(required = false) String tjNumber, @ApiParam(value = "0未检,1已检") @RequestParam(defaultValue = "0") Integer type, @ApiParam(value = "姓名)") @RequestParam(required = false) String name, @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer page, @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize) { /* String userId = SecurityUtils.getLoginUser().getUserId(); Integer ksId = null; SysUser sysUser = null; if (null != userId) { sysUser = userService.getById(Long.valueOf(userId)); if (null != sysUser) { ksId = Math.toIntExact(sysUser.getDeptId()); } } if (ksId == null) { return AjaxResult.error("请输入科室id"); } //根据当前登陆的人的科室id，获取该科室下的所有项目 List postIds = sysUser.getPostIds(); List ksproList = null; if (postIds != null) { for (Long postId : postIds) { LambdaQueryWrapper wq111 = new LambdaQueryWrapper<>(); wq111.eq(SysUserPost::getPostId, postId); SysUserPost one = userPostService.getOne(wq111); if (one != null) { SysPost byId = postService.getById(one.getPostId()); if (byId.getPostName().equals("录入员")) { ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId)); } } } } else { ksproList = projectService.getKsTjProjectIdList(); } //筛选影像的项目。 A32影像 if (ksproList.size() == 0) { return AjaxResult.error("请完善科室项目信息"); } ksproList = ksproList.stream() .filter(element -> element ==1633660948860522589L // || element ==1633660948860522504L // || // element ==1633660948860522507L|| element ==1633660948860522508L // || // element ==1633660948860522515L|| element ==1633660948860522516L // || // element ==1633660948860522517L|| element ==1633660948860522519L // || // element ==1633660948860522524L|| element ==1633660948860522530L // || // element ==1633660948860522531L|| element ==1633660948860522533L ) .collect(Collectors.toList());*/ // List ksproList = projectService.getYingXiangProId(); // List customerLis = new ArrayList<>(); // // //根据体检号查 // if (null != tjNumber) { // List orderList = orderService.getOrderListByLikeTjNum(tjNumber); // if (null == orderList) { // return AjaxResult.success("暂时没有数据"); // } // for (TjOrder order : orderList) { // List list = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); // if (list.size() == 0) { // continue; // } // LambdaQueryWrapper wqs = new LambdaQueryWrapper<>(); // wqs.eq(TjOrderRemark::getTjNumber, order.getTjNumber()); // wqs.in(TjOrderRemark::getType, 0,3); // List lists = remarkService.list(wqs); // TjCustomer customer = customerService.getById(order.getUserId()); // //遍历项目 判断是否有重大阳性 标记 // for (TjOrderDetail tjOrderDetail11 : list) { // customer.setIsPositive(tjOrderDetail11.getIsPositive()); // if (tjOrderDetail11.getIsPositive()==1){ // break; // } // } // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); // customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); // customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); // if (null != lists && lists.size() > 0) { // StringBuilder stringBuilder = new StringBuilder(); // for (TjOrderRemark remark : lists) { // TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); // TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); // if (one.getFlowingWaterId() != null) { // stringBuilder.append(byId.getProName()).append(";"); // } // // } // customer.setNotCheckeds(String.valueOf(stringBuilder)); // customer.setTjStatus(0L); // } else { // customer.setTjStatus(1L); // customer.setNotCheckeds("无"); // } // if (order.getTjType().equals("1")) { // customer.setTjType("团体"); // } // if (order.getTjType().equals("2")) { // customer.setTjType("个人"); // } // customer.setTjTime(order.getCreateTime()); // customer.setTjNumber(order.getTjNumber()); // customer.setOrderId(order.getOrderId()); // customer.setIsHz(order.getIsHz()); // customerLis.add(customer); // // } // if (customerLis.size() > 0) { // List customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Collections.reverse(customerList); // Map map = new HashMap<>(); // map.put("date", customerList); // map.put("total", customerLis.size()); // return AjaxResult.success(map); // } else { // return AjaxResult.success("暂无数据"); // } // } // // //根据姓名查询 // if (null != name && !"".equals(name)) { // LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); // wq.like(TjCustomer::getCusName, name); // List list = customerService.list(wq); // List list11111 = new ArrayList<>(); // if (null != list && list.size() > 0) { // for (TjCustomer customer : list) { // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); // customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); // customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); // List orderList = orderService.getOrderListByCusId(String.valueOf(customer.getCusId())); // if (null != orderList && orderList.size() > 0) { // for (TjOrder order : orderList) { // List list111 = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get(); // if (list111.size() == 0) { // continue; // } // //遍历项目 判断是否有重大阳性 标记 // for (TjOrderDetail tjOrderDetail11 : list111) { // customer.setIsPositive(tjOrderDetail11.getIsPositive()); // if (tjOrderDetail11.getIsPositive()==1){ // break; // } // } // List lists = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber()); // if (null != lists && lists.size() > 0) { // StringBuilder stringBuilder = new StringBuilder(); // for (TjOrderRemark remark : lists) { // TjProject byId = projectService.selectTjProjectByProId(remark.getProId()); // TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId())); // if (one.getFlowingWaterId() != null) { // stringBuilder.append(byId.getProName()).append(";"); // } // } // customer.setNotCheckeds(String.valueOf(stringBuilder)); // if (null == customer.getNotCheckeds()) customer.setNotCheckeds("全部已检"); // customer.setTjStatus(0L); // } else { // customer.setNotCheckeds("无"); // customer.setTjStatus(1L); // } // if (order.getTjType().equals("1")) { // customer.setTjType("团体"); // } // if (order.getTjType().equals("2")) { // customer.setTjType("个人"); // } // customer.setTjTime(order.getCreateTime()); // customer.setTjNumber(order.getTjNumber()); // customer.setOrderId(order.getOrderId()); // customer.setIsHz(order.getIsHz()); // list11111.add(customer); // } // } // } // if (list11111.size() == 0) { // return AjaxResult.success("暂无数据"); // } // Map map = new HashMap<>(); // List customers = list11111.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Collections.reverse(customers); // map.put("customers", customers); // map.put("total", list11111.size()); // return AjaxResult.success(map); // } else { // return AjaxResult.success("暂无数据"); // } // } // List customerLists = null; Map map=null; if (type == 0) { // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); // List customers = new ArrayList<>(); // while(cursor.hasNext()){ // String s = cursor.next().toString(); // TjCustomer wj = redisCache.getCacheMapValue(s,"0"); // if(null !=wj){ // customers.add(wj); // } // } //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a // cursor.close(); // customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj"); map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A32", name, tjNumber, 0, page, pageSize); // customerLists = customers; } if (type == 1) { // Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize)); // List customers = new ArrayList<>(); // while(cursor.hasNext()){ // String s = cursor.next().toString(); // TjCustomer wj = redisCache.getCacheMapValue(s,"1"); // if(null !=wj){ // customers.add(wj); // } // } //// //切记这里一定要关闭，否则会耗尽连接数。报Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a // cursor.close(); // customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj"); map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A32", name, tjNumber, 1, page, pageSize); // customerLists = customers; } // asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId)); // if (customerLists.size() > 0) { // Collections.reverse(customerLists); // List customerList = customerLists.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); // Map map = new HashMap<>(); // map.put("date", customerList); // map.put("total", customerLists.size()); // return AjaxResult.success(map); // } else { // AjaxResult map = getAjaxResult(type, page, pageSize, ksproList, customerLis); // if (map != null) return map; // return AjaxResult.success("暂时没有数据"); return AjaxResult.success(map); // } } @GetMapping("/getTjYxjcList") @ApiOperation("查询个人影响检查项目结果集") public AjaxResult getTjYxjcList(@ApiParam(value = "姓名") @RequestParam String patname, @ApiParam(value = "性别") @RequestParam String sex, @ApiParam(value = "年龄") @RequestParam String patage, @ApiParam(value = "年龄单位") @RequestParam String patagename, @ApiParam(value = "生日)") @RequestParam Date patbirth) { String format = DateUtil.format(patbirth, "yyyy.MM.dd"); List> tjYxjcList = testMapper.getTjYxjcList(patname,sex,null); return AjaxResult.success(tjYxjcList); } // @GetMapping("/getSsTjYxjcList") // @ApiOperation("查询个人影响检查项目结果集(搜素用)") // public AjaxResult getSsTjYxjcList(@ApiParam(value = "姓名") @RequestParam String patname, // @ApiParam(value = "性别") @RequestParam String sex, // @ApiParam(value = "年龄") @RequestParam String patage) { // // // List> tjYxjcList = testMapper.getTjYxjcList(patname,sex,null,null); // return AjaxResult.success(tjYxjcList); // } /** * 查询客户体检历史记录 * * @param cusId * @return */ @GetMapping("/getHistory") @ApiOperation("查询客户体检历史记录") //@PreAuthorize("@ss.hasPermi('system:dept:getHistory')") public AjaxResult getHistory(@RequestParam @ApiParam(value = "体检客户id") Long cusId) { Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId()); Integer ksId = null; SysUser sysUser = userService.getById(userId); if (null != sysUser) { ksId = Math.toIntExact(sysUser.getDeptId()); } if (ksId == null) { return AjaxResult.error("请输入科室id"); } LambdaQueryWrapper wq0 = new LambdaQueryWrapper<>(); if (!sysUser.getUserName().equals("10001")) { wq0.eq(TjProject::getDeptId, ksId); } wq0.in(TjProject::getDeleted, 0, 1); List projectList = projectService.list(wq0); if (projectList == null || projectList.size() <= 0) { return AjaxResult.error("请完善科室项目信息"); } List ksproList = projectList.stream().map(TjProject::getProId).collect(Collectors.toList()); LambdaQueryWrapper wq1 = new LambdaQueryWrapper<>(); wq1.eq(TjOrder::getUserId, cusId); List orderList = orderService.list(wq1); if (null != orderList && orderList.size() > 0) { List orderList0 = new ArrayList<>(); for (TjOrder tjOrder : orderList) { LambdaQueryWrapper wq2 = new LambdaQueryWrapper<>(); wq2.eq(TjOrderDetail::getOrderId, tjOrder.getOrderId()); wq2.eq(TjOrderDetail::getTjStatus, 1); wq2.in(TjOrderDetail::getProId, ksproList); List detailList = detailService.list(wq2); tjOrder.setTjOrderList(detailList); orderList0.add(tjOrder); } return AjaxResult.success(orderList0); } return AjaxResult.success("暂时没有历史数据"); } /** * 查询客户体检历史记录 */ @GetMapping("/getHistoryDetail") @ApiOperation("查询客户体检历史记录详情") //@PreAuthorize("@ss.hasPermi('system:dept:getHistoryDetail')") public AjaxResult getHistoryDetail(@RequestParam @ApiParam(value = "体检客户id") Integer orderId) { Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId()); Integer ksId = null; SysUser sysUser = null; if (null != userId) { sysUser = userService.getById(userId); if (null != sysUser) { ksId = Math.toIntExact(sysUser.getDeptId()); } } if (ksId == null) { return AjaxResult.error("请输入科室id"); } LambdaQueryWrapper wq0 = new LambdaQueryWrapper<>(); if (!sysUser.getUserName().equals("10001")) { wq0.eq(TjProject::getDeptId, ksId); } List projectList = projectService.list(wq0); List ksproList = projectList.stream().map(TjProject::getProId).collect(Collectors.toList()); if (projectList == null) { return AjaxResult.error("请完善科室项目信息"); } LambdaQueryWrapper wq1 = new LambdaQueryWrapper<>(); wq1.eq(TjOrderDetail::getOrderId, orderId); wq1.in(TjOrderDetail::getProId, ksproList); wq1.eq(TjOrderDetail::getTjStatus, 1); List detailList = detailService.list(wq1); return AjaxResult.success(detailList); } /** * 获取科室部门列表 */ //@PreAuthorize("@ss.hasPermi('system:dept:list')") @GetMapping("/list") @ApiOperation(value = "获取科室部门列表") public AjaxResult list(SysDept dept) { List depts = deptService.selectDeptList(dept); if (depts != null) { for (SysDept sysDept : depts) { Long parentId = sysDept.getParentId(); if (parentId != 0) { SysDept sysDept1 = deptService.getById(parentId); String name = sysDept1.getDeptName(); if (null != name) sysDept.setParentName(name); } else { sysDept.setParentName(null); } } } return success(depts); } /** * 查询科室部门列表（排除节点） */ //@PreAuthorize("@ss.hasPermi('system:dept:excludeChild')") @GetMapping("/list/exclude/{deptId}") @ApiOperation(value = "查询科室部门列表（排除节点）") public AjaxResult excludeChild(@PathVariable(value = "deptId", required = false) Long deptId) { List depts = deptService.selectDeptList(new SysDept()); depts.removeIf(d -> d.getDeptId().intValue() == deptId || ArrayUtils.contains(StringUtils.split(d.getAncestors(), ","), deptId + "")); return success(depts); } /** * 根据科室部门编号获取详细信息 */ //@PreAuthorize("@ss.hasPermi('system:dept:getInfo')") @GetMapping(value = "/{deptId}") @ApiOperation(value = "根据科室部门编号获取详细信息") public AjaxResult getInfo(@PathVariable Long deptId) { deptService.checkDeptDataScope(deptId); return success(deptService.selectDeptById(deptId)); } /** * 新增科室部门 */ //@PreAuthorize("@ss.hasPermi('system:dept:add')") @Log(title = "部门管理", businessType = BusinessType.INSERT) @PostMapping @ApiOperation(value = "新增科室部门") public AjaxResult add(@Validated @RequestBody SysDept dept) { if (UserConstants.NOT_UNIQUE.equals(deptService.checkDeptNameUnique(dept))) { return error("新增部门'" + dept.getDeptName() + "'失败，部门名称已存在"); } dept.setCreateBy(getUsername()); return toAjax(deptService.insertDept(dept)); } @Resource private IDictHospService dictHospService; /** * 修改科室部门 */ //@PreAuthorize("@ss.hasPermi('system:dept:edit')") @Log(title = "部门管理", businessType = BusinessType.UPDATE) @PutMapping @ApiOperation(value = "修改科室部门") public AjaxResult edit(@Validated @RequestBody SysDept dept) { Long deptId = dept.getDeptId(); deptService.checkDeptDataScope(deptId); if (UserConstants.NOT_UNIQUE.equals(deptService.checkDeptNameUnique(dept))) { return error("修改部门'" + dept.getDeptName() + "'失败，部门名称已存在"); } else if (dept.getParentId().equals(deptId)) { return error("修改部门'" + dept.getDeptName() + "'失败，上级部门不能是自己"); } else if (StringUtils.equals(UserConstants.DEPT_DISABLE, dept.getStatus()) && deptService.selectNormalChildrenDeptById(deptId) > 0) { return error("该部门包含未停用的子部门！"); } dept.setUpdateBy(getUsername()); //查询院区名字赋值 if (dept.getHospId()!=null){ final DictHosp byId = dictHospService.getById(dept.getHospId()); if (byId!=null){ dept.setHospName(byId.getHospAreaName()); } } return toAjax(deptService.updateDept(dept)); } /** * 删除科室部门 */ //@PreAuthorize("@ss.hasPermi('system:dept:remove')") @Log(title = "部门管理", businessType = BusinessType.DELETE) @DeleteMapping("/{deptId}") @ApiOperation(value = "删除科室部门") public AjaxResult remove(@PathVariable Long deptId) { if (deptService.hasChildByDeptId(deptId)) { return warn("存在下级部门,不允许删除"); } if (deptService.checkDeptExistUser(deptId)) { return warn("部门存在用户,不允许删除"); } deptService.checkDeptDataScope(deptId); return toAjax(deptService.deleteDeptById(deptId)); } /** * 提交该科室下客户体检结果接口 */ @PostMapping("/addRemark") @ApiOperation("提交该科室下客户体检结果接口") @Transactional public AjaxResult addRemark(@ApiParam(value = "体检父项目备注集合") @RequestBody List remarklList) { Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId()); SysUser sysUser = userService.getById(userId); if (remarklList == null || remarklList.size() == 0) { return AjaxResult.success("操作失败"); } for (TjOrderRemark orderRemark : remarklList) { List summaryList = orderRemark.getSummaryList(); if (null != summaryList && summaryList.size()>0 && !summaryList.contains(null) ) { orderRemark.setSummary(Joiner.on(";").join(orderRemark.getSummaryList())); } LambdaQueryWrapper qw = new LambdaQueryWrapper<>(); qw.eq(TjOrder::getTjNumber, orderRemark.getTjNumber()); TjOrder order = orderService.getOne(qw); orderRemark.setDeptId(sysUser.getDeptId()); if (orderRemark.getDoctorName() == null) { orderRemark.setDoctorName(String.valueOf(sysUser.getUserId())); } List tjOrderDetailList = orderRemark.getTjOrderDetailList(); final TjCustomer byId1 = customerService.getById(order.getUserId()); if (null != tjOrderDetailList && tjOrderDetailList.size() > 0) { //----------------------------------start for (TjOrderDetail tjOrderDetail : tjOrderDetailList) { final TjProject byId = projectService.getById(tjOrderDetail.getProId()); //给病种记录表存 方便统计病种和客户信息之间的关系 if (tjOrderDetail.getRulesList()!=null){ for (TjRules tjRules : tjOrderDetail.getRulesList()) { TjOrderDetailRules orderDetailRules=new TjOrderDetailRules(); orderDetailRules.setAid(tjRules.getAid()); if (byId1!=null){ orderDetailRules.setCusName(byId1.getCusName()); orderDetailRules.setCusSex(String.valueOf(byId1.getCusSex())); orderDetailRules.setCusAge(String.valueOf(MatchUtils.getAgeByIdCard(byId1.getCusIdcard()))); orderDetailRules.setCusId(String.valueOf(byId1.getCusId())); } orderDetailRules.setBingzhong(tjRules.getBingzhong()); orderDetailRules.setDoctorName(sysUser.getNickName()); orderDetailRules.setTjNumber(order.getTjNumber()); if (byId!=null){ orderDetailRules.setProId(String.valueOf(byId.getProId())); orderDetailRules.setProName(byId.getProName()); } orderDetailRules.setDoctorId(String.valueOf(sysUser.getUserId())); tjOrderDetailRulesService.save(orderDetailRules); } } } asyncService.updateOrdeltile(tjOrderDetailList, sysUser, order); LambdaQueryWrapper qww = new LambdaQueryWrapper<>(); qww.eq(TjOrderDetail::getOrderId, order.getOrderId()); qww.eq(TjOrderDetail::getProId, orderRemark.getProId()); TjOrderDetail detail = detailService.getOne(qww); detail.setTjStatus(1L); detailService.updateById(detail); orderRemark.setType(1); LambdaQueryWrapper wq1 = new LambdaQueryWrapper<>(); wq1.eq(TjOrderRemark::getTjNumber, orderRemark.getTjNumber()); wq1.eq(TjOrderRemark::getProId, orderRemark.getProId()); TjOrderRemark one = remarkService.getOne(wq1); if (one == null) { TjOrderRemark remark = new TjOrderRemark(); BeanUtils.copyBeanProp(orderRemark, remark); remarkService.save(remark); } else { one.setRemark(orderRemark.getRemark()); if (null != summaryList && summaryList.size()>0 && !summaryList.contains(null)) { one.setSummary(Joiner.on(";").join(orderRemark.getSummaryList())); } // one.setDeptId(orderRemark.getDeptId()); one.setDoctorName(orderRemark.getDoctorName()); one.setType(1); remarkService.updateById(one); } asyncService.updateCheckType(orderRemark.getTjNumber()); asyncService.getOrderDetailByProParentId(orderRemark.getTjNumber(),null, String.valueOf(orderRemark.getProId())); return AjaxResult.success("操作成功"); } asyncService.updateCheckType(orderRemark.getTjNumber()); asyncService.getOrderDetailByProParentId(orderRemark.getTjNumber(),null, String.valueOf(orderRemark.getProId())); } return AjaxResult.success("操作成功"); } /** * 医生点击体检信息详情(只显示父项目列表) * * @param tjNumber * @return */ // @Transactional @GetMapping("/getParentList") @ApiOperation(value = "医生点击体检信息详情(只显示父项目列表)") public AjaxResult getParentList(@ApiParam(value = "客户体检号") @RequestParam String tjNumber) { String userId = SecurityUtils.getLoginUser().getUserId(); Integer ksId = null; SysUser sysUser = null; if (null != userId) { sysUser = userService.getById(Long.valueOf(userId)); if (null == sysUser) { return AjaxResult.error(); } ksId = Math.toIntExact(sysUser.getDeptId()); } String configByKey = configService.selectConfigByKey("sfkqdyhis"); if (configByKey.equals("Y")){ // 判断是否收费 请求接口 LambdaQueryWrapper tjOrderLambdaQueryWrapper = new LambdaQueryWrapper<>(); tjOrderLambdaQueryWrapper.eq(TjOrder::getTjNumber,tjNumber); TjOrder tjOrder = orderService.getOne(tjOrderLambdaQueryWrapper); LambdaQueryWrapper tjFlowingWaterLambdaQueryWrapper = new LambdaQueryWrapper<>(); tjFlowingWaterLambdaQueryWrapper.eq(TjFlowingWater::getOrderId,tjOrder.getOrderId()); tjFlowingWaterLambdaQueryWrapper.ne(TjFlowingWater::getPayStasus,2); tjFlowingWaterLambdaQueryWrapper.eq(TjFlowingWater::getIsAddition,"N"); TjFlowingWater tjFlowingWater = tjFlowingWaterService.getOne(tjFlowingWaterLambdaQueryWrapper); HashMap hisRequestParams = new HashMap<>(); // 不在需要身份证号 hisRequestParams.put("patientId",tjOrder.getCardId()); log.info("ltkj--- "+DateUtil.date()+"操作人id: "+userId+"操作科室: "+sysUser.getDeptId()+"操作的体检人: "+tjNumber); AjaxResult queryPay = hisApiGetMethodService.getHISDataNew("QueryPay", hisRequestParams); if (Integer.parseInt(queryPay.get("code").toString()) == 200) { // List> data = (List>) queryPay.get("data"); // BigDecimal cateFeeAll = BigDecimal.ZERO; // for (Map datum : data) { // BigDecimal cateFee = new BigDecimal(datum.get("CateFee")); // cateFeeAll = cateFeeAll.add(cateFee); // } // BigDecimal fyhj = ltkjJianchajianyanTreeService.getLtkjJianchajianyanTreeFyhjByCardId(tjOrder.getCardId()); // if (cateFeeAll.compareTo(fyhj) != 0){ // return AjaxResult.error("存在未缴费项目"); // } int sfsf = ltkjJianchajianyanTreeService.getSfsfByCardId(tjOrder.getCardId()); if (sfsf > 0){ log.error("路泰科技--- "+DateUtil.date()+" 存在未缴费项目的 就单数 "+sfsf); log.error("路泰科技--- "+DateUtil.date()+" 存在未缴费项目的 就诊号 "+tjOrder.getCardId()+" 体检号 "+tjOrder.getTjNumber()); return AjaxResult.error("存在未缴费项目"); } extracted(tjOrder, tjFlowingWater); }else { log.error("路泰科技--- "+DateUtil.date()+" 未查询到缴费记录的 就诊号 "+tjOrder.getCardId()+" 体检号 "+tjOrder.getTjNumber()); return AjaxResult.error("未查询到缴费记录"); } // } } String config = configService.selectConfigByKey("qt_open_xdt"); String byKey = configService.selectConfigByKey("qt_kjksid"); List split = new ArrayList<>(); // 存放转换后的integer类型结果 if("Y".equals(config)){ List roles = SecurityUtils.getLoginUser().getUser().getRoles(); if(null !=roles && roles.size()>0){ List list = roles.stream().filter(item -> item.getRoleName().contains("前台")).collect(Collectors.toList()); if(list.size()>0){ if(null !=ksId && ksId==100){ ksId=999; } if(null !=byKey && !"".equals(byKey)){ String[] arr = byKey.split(","); // 根据逗号进行切割 for (String s : arr) { int num = Integer.parseInt(s); // 将每个子字符串转换为integer类型 split.add(num); // 添加到列表中 } } }else { split.add(ksId); } }else { split.add(ksId); } }else { split.add(ksId); } //判断当前登陆的人是不是管理员。管理员可以看当前体检号下所有项目 // if (sysUser.getUserName().equals("10001")) { // QueryWrapper wqq = new QueryWrapper<>(); // wqq.eq("tj_number", tjNumber); // List listq = remarkService.list(wqq); // if (listq.size() == 0) { // return AjaxResult.error("该科室下无项目！"); // } // for (TjOrderRemark tjOrderRemark : listq) { // TjProject tjProjectq = projectService.getById(tjOrderRemark.getProId()); // if (null != tjProjectq) { // tjOrderRemark.setProName(tjProjectq.getProName()); // } // } // return AjaxResult.success(listq); // } LambdaQueryWrapper wq2 = new LambdaQueryWrapper<>(); if ((null != sysUser && !sysUser.getUserName().equals("10001")) && 100!=ksId) { wq2.in(TjProject::getDeptId,split); } //判断该项目是否需要打印报告 wq2.eq(TjProject::getNeedReport,"Y"); List Deptlist = projectService.list(wq2); List proIdList = Deptlist.stream().map(TjProject::getProId).collect(Collectors.toList()); if (Deptlist.size() == 0 || proIdList.size() == 0) { return AjaxResult.error("该科室下无项目！"); } LambdaQueryWrapper wqqq = new LambdaQueryWrapper<>(); wqqq.eq(TjOrder::getTjNumber, tjNumber); TjOrder one = orderService.getOne(wqqq); if (null != one) { LambdaQueryWrapper wqq = new LambdaQueryWrapper<>(); wqq.eq(TjOrderDetail::getOrderId, one.getOrderId()); wqq.isNotNull(TjOrderDetail::getFlowingWaterId); wqq.in(TjOrderDetail::getProId, proIdList); wqq.notIn(TjOrderDetail::getProId, proIdList,projectService.getNneedReprotProId()); List detailList = detailService.list(wqq); if (detailList != null && detailList.size() > 0) { List collect = detailList.stream().map(TjOrderDetail::getProId).collect(Collectors.toList()); QueryWrapper wq = new QueryWrapper<>(); wq.eq("tj_number", tjNumber); wq.in("pro_id", collect); wq.ne("type", 2); wq.ne("dept_id",241); wq.notIn("pro_id", proIdList,projectService.getNneedReprotProId()); List list = remarkService.list(wq); if (list.size() == 0) { return AjaxResult.success("该科室下无项目！"); } for (TjOrderRemark tjOrderRemark : list) { TjProject tjProject = projectService.getById(tjOrderRemark.getProId()); if (null != tjProject) { tjOrderRemark.setProName(tjProject.getProName()); } } return AjaxResult.success(list); } return AjaxResult.success(); } return AjaxResult.error(); } @Transactional public void extracted(TjOrder tjOrder, TjFlowingWater tjFlowingWater) { tjFlowingWater.setPayStasus(1L); tjFlowingWater.setPayType(0L); tjFlowingWater.setTollCollectorId("148"); tjFlowingWaterService.updateById(tjFlowingWater); Long tjSerialNumber = tjFlowingWater.getTjSerialNumber(); LambdaQueryWrapper tjOrderDetailLambdaQueryWrapper = new LambdaQueryWrapper<>(); tjOrderDetailLambdaQueryWrapper.eq(TjOrderDetail::getOrderId, tjOrder.getOrderId()); List tjOrderDetails = detailService.list(tjOrderDetailLambdaQueryWrapper); List detailIds = tjOrderDetails.stream().map(TjOrderDetail::getOrderDetailId).collect(Collectors.toList()); LambdaUpdateWrapper tjOrderDetailLambdaUpdateWrapper = new LambdaUpdateWrapper<>(); tjOrderDetailLambdaUpdateWrapper.set(TjOrderDetail::getFlowingWaterId,tjSerialNumber); tjOrderDetailLambdaUpdateWrapper.in(TjOrderDetail::getOrderDetailId,detailIds); detailService.update(tjOrderDetailLambdaUpdateWrapper); } /** * 点击父项目显示子项目详情 * * @return */ @GetMapping("/getOrderDetailByProParentId") @ApiOperation("点击父项目显示子项目详情") public AjaxResult getOrderDetailByProParentId(@ApiParam(value = "父项目id") @RequestParam String proParentId, @ApiParam(value = "体检号") @RequestParam String tjNumber) { if (null == SecurityUtils.getLoginUser().getUserId() || null == userService.getById(SecurityUtils.getLoginUser().getUserId())) { return AjaxResult.error("获取用户信息错误"); } // if(redisCache.hasHKey("getOrderDetailByProParentId"+tjNumber,proParentId)){ // Map mapValue = redisCache.getCacheMapValue("getOrderDetailByProParentId" + tjNumber, proParentId); // return AjaxResult.success(mapValue); // } TjOrderRemark remark = remarkService.getTjOrderRemarkByTjNumAndProParentId(tjNumber, proParentId); // List proParentList = projectService.getTjProjectListBySoneId(proParentId); List proParentList = projectService.getTjProjectListByTbTransition(proParentId,tjNumber); if (null == proParentList || proParentList.size()==0) { Map map = new HashMap<>(); map.put("xiaoJieIds", null); map.put("sons", projectService.list(new LambdaQueryWrapper().eq(TjProject::getProId,proParentId))); map.put("xiaoJie", null); map.put("remark", remark.getRemark()); return AjaxResult.success(map); } List proParentIdList = proParentList.stream().map(TjProject::getProId).collect(Collectors.toList()); TjOrder one = orderService.getOrderByTjNum(tjNumber); if (null == one) { return AjaxResult.success("该用户暂时没有体检数据"); } List tjOrderDetails = detailService.getTjOrderDetailListInProParentIdList(String.valueOf(one.getOrderId()), proParentIdList); List tjOrderDetailList=new ArrayList<>(); TjCustomer customer = tjCustomerService.getById(one.getUserId()); if (null != tjOrderDetails && tjOrderDetails.size() > 0) { for (TjOrderDetail tjOrderDetail : tjOrderDetails) { TjProject project = projectService.getById(tjOrderDetail.getProId()); //判断该项目是否需要打印报告 if ("N".equals(project.getNeedReport())){ continue; } //病种回显 // LambdaQueryWrapper wq=new LambdaQueryWrapper<>(); // wq.eq(TjOrderDetailRules::getProId,project.getProId()); // wq.eq(TjOrderDetailRules::getTjNumber,tjNumber); // List list = tjOrderDetailRulesService.list(wq); // List res=new ArrayList<>(); // for (TjOrderDetailRules orderDetailRules : list) { // final TjRules byId = tjRulesService.getById(orderDetailRules.getAid()); // res.add(byId); // } List rulesList = tjRulesService.getTjRulesListByTjNumAndProId(tjNumber, tjOrderDetail.getProId()); tjOrderDetail.setRulesList(rulesList); //查标准和单位----start // List list26 = tjStandardService.getTjStandardListByProId(String.valueOf(tjOrderDetail.getProId())); // if (list26.size() == 0) { // project.setProMetering("/"); // project.setProScope("/"); // } else if (list26.size() == 1) { // project.setProMetering(list26.get(0).getCompany() == null ? " " : list26.get(0).getCompany()); // project.setProScope((list26.get(0).getTjStandardLtValue() == null ? " " : list26.get(0).getTjStandardLtValue()) + "-" + (list26.get(0).getTjStandardGtValue() == null ? " " : list26.get(0).getTjStandardGtValue())); // } else { // Long cusSex = customer.getCusSex(); // Date cusBrithday = customer.getCusBrithday(); // int age = DateUtil.ageOfNow(cusBrithday); // for (TjStandard tjStandard : list26) { // LambdaQueryWrapper wq8 = new LambdaQueryWrapper<>(); // if (tjStandard.getTjSex() != null) { // wq8.eq(TjStandard::getTjSex, cusSex); // } // if (tjStandard.getTjType() != null) { // wq8.eq(TjStandard::getTjType, StringUtils.getAgeType(age)); // } // TjStandard standard = tjStandardService.getOne(wq8); // project.setProMetering(standard.getCompany()); // project.setProScope((standard.getTjStandardLtValue() == null ? " " : standard.getTjStandardLtValue()) + "-" + (standard.getTjStandardGtValue() == null ? " " : standard.getTjStandardGtValue())); // } // } //查标准和单位-----end tjOrderDetail.setProject(project); // List list2 = tjStandardService.getTjStandardListByProId(String.valueOf(project.getProId())); // if (list2.size() == 0) { // tjOrderDetail.setStandard(null); // } else if (list2.size() == 1) { // tjOrderDetail.setStandard(list2.get(0)); // } else { // for (TjStandard tjStandard : list2) { // LambdaQueryWrapper wq8 = new LambdaQueryWrapper<>(); // if (tjStandard.getTjSex() != null) { // wq8.eq(TjStandard::getTjSex, customer.getCusSex()); // } // if (tjStandard.getTjType() != null) { // wq8.eq(TjStandard::getTjType, StringUtils.getAgeType(DateUtil.ageOfNow(customer.getCusBrithday()))); // } // TjStandard standard = tjStandardService.getOne(wq8); // tjOrderDetail.setStandard(standard); // } // } if (null != remark.getDoctorName()) { //lg0412 SysUser byId = userService.getById(remark.getDoctorName()); if (byId != null) { tjOrderDetail.setDoctorName(userService.getById(remark.getDoctorName()).getNickName()); } } else { tjOrderDetail.setDoctorName(null); } tjOrderDetailList.add(tjOrderDetail); } } Map map = new HashMap<>(); List adviceList = new ArrayList<>(); if (null != remark) { String[] strings = StringUtils.split(remark.getSummary(), ";"); // if (null != strings && strings.length > 0) { // for (String string : strings) { // adviceList.add(tjAdviceService.getById(string)); // } // } if(null !=strings && strings.length>0){ List list = tjAdviceService.getAdviceStringByIds(strings); adviceList.addAll(list); } map.put("xiaoJieIds", StringUtils.split(remark.getSummary(), ";")); } else { map.put("xiaoJieIds", null); } map.put("sons", tjOrderDetailList); map.put("xiaoJie", adviceList); map.put("remark", remark.getRemark()); // asyncService.getOrderDetailByProParentId(tjNumber,map,proParentId); return AjaxResult.success(map); } /** * 状态修改 */ @PutMapping("/changeStatus") @ApiOperation("部门状态修改") public AjaxResult changeStatus(@RequestBody SysDept dept) { //判断是启用还是 if ("1".equals(dept.getStatus())) { //判断用户表中有没有人在该科室下 LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); wq.eq(SysUser::getDeptId, dept.getDeptId()); List list = userService.list(wq); if (list.size() != 0) { return AjaxResult.error("该科室下有工作人员，不能停用！"); } } dept.setUpdateBy(getUsername()); int i = deptService.updateDeptStatus(dept); if (i == 0) { return AjaxResult.error("修改失败"); } return AjaxResult.success("修改成功"); } /** * 根据项目id获取建议 */ @GetMapping("/getDeptAdvice/{proId}") @ApiOperation(value = "根据项目id获取建议") public AjaxResult getDeptAdvice(@ApiParam(value = "父项目项目id") @PathVariable String proId) { List list = new ArrayList<>(); LambdaQueryWrapper wq1 = new LambdaQueryWrapper<>(); wq1.eq(TjAdvice::getProId, proId); List list1 = tjAdviceService.list(wq1); //如果没有项目id 就返回所有的建议集合 if (list1.size() == 0) { return AjaxResult.success(tjAdviceService.list()); } for (TjAdvice tjAdvice : list1) { list.add(tjAdvice); } return AjaxResult.success(list); } /** * 获取部门树列表 */ //@PreAuthorize("@ss.hasPermi('system:dept:list')") @GetMapping("/deptTree") @ApiOperation("获取部门树列表") public AjaxResult deptTree(SysDept dept) { return success(deptService.selectDeptTreeList(dept)); } @GetMapping("/deptTree111") @ApiOperation("获取部门树列表1111111111") public AjaxResult deptTree111(SysDept dept) { final List treeSelects = deptService.selectDeptTreeList1(dept); return success(treeSelects); } /** * 获取子科室部门列表 */ @GetMapping("/getChildList") @ApiOperation(value = "获取子科室部门列表") public AjaxResult getChildList(String deptName) { LambdaQueryWrapper wq=new LambdaQueryWrapper<>(); wq.ne(SysDept::getParentId,0); if (deptName!=null){ wq.like(SysDept::getDeptName,deptName); } List depts = deptService.list(wq); return success(depts); } }