package com.ltkj.web.controller.system;
|
|
import java.io.*;
|
import java.math.BigDecimal;
|
import java.sql.Struct;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.extra.pinyin.PinyinUtil;
|
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.db.DataSourceContextHolder;
|
import com.ltkj.framework.config.MatchUtils;
|
import com.ltkj.framework.datasource.DynamicDataSourceContextHolder;
|
import com.ltkj.hosp.domain.*;
|
import com.ltkj.hosp.mapper.TestMapper;
|
import com.ltkj.hosp.service.*;
|
import com.ltkj.hosp.vodomain.CsProVo;
|
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 com.ltkj.web.wxUtils.HttpClientUtils;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiParam;
|
import jodd.util.StringUtil;
|
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<Object, Object> redisTemplate;
|
@Resource
|
private TestMapper testMapper;
|
@Autowired
|
private ISysConfigService configService;
|
@Autowired
|
private ITjFlowingWaterService tjFlowingWaterService;
|
@Autowired
|
private HisApiGetMethodService hisApiGetMethodService;
|
@Autowired
|
private LtkjJianchajianyanTreeService ltkjJianchajianyanTreeService;
|
|
|
@GetMapping("/getdangqiandengluyuanqu")
|
@ApiOperation("获取当前登录人对应的院区名")
|
public AjaxResult getdangqiandengluyuanqu() {
|
Long deptId = SecurityUtils.getDeptId();
|
if (null != deptId) {
|
SysDept dept = deptService.getById(deptId);
|
if (null != dept) {
|
String hospName = dept.getHospName();
|
return AjaxResult.success(hospName);
|
}
|
}
|
|
|
return AjaxResult.success();
|
}
|
|
/**
|
* 该体检科室下客户列表显示接口
|
*/
|
@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<Long> postIds = sysUser.getPostIds();
|
List<Long> ksproList = null;
|
if (postIds != null) {
|
for (Long postId : postIds) {
|
LambdaQueryWrapper<SysUserPost> 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.isEmpty()) {
|
return AjaxResult.error("请完善科室项目信息");
|
}
|
List<TjCustomer> customerLis = new ArrayList<>();
|
if (null == name) name = "";
|
if (null == tjNumber) tjNumber = "";
|
Map<String, Object> map = null;
|
if (type == 0) {
|
map = deptService.getSysDeptYjWjCustomerList13(String.valueOf(ksId), name, tjNumber, 0, page, pageSize);
|
}
|
if (type == 1) {
|
map = deptService.getSysDeptYjWjCustomerList13(String.valueOf(ksId), name, tjNumber, 1, page, pageSize);
|
}
|
return AjaxResult.success(map);
|
|
}
|
|
/**
|
* 化验检查页面列表
|
*/
|
@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) {
|
List<Long> ksproList = null;
|
|
ksproList = projectService.getHuaYanProId();
|
|
if (ksproList == null || ksproList.isEmpty()) {
|
return AjaxResult.error("请完善科室项目信息");
|
}
|
|
Map<String, Object> map = null;
|
if (type == 0) {
|
map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A30", name, tjNumber, 0, page, pageSize);
|
}
|
if (type == 1) {
|
map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A30", name, tjNumber, 1, page, pageSize);
|
}
|
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) {
|
|
Map<String, Object> map = null;
|
if (type == 0) {
|
|
map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A32", name, tjNumber, 0, page, pageSize);
|
}
|
if (type == 1) {
|
map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A32", name, tjNumber, 1, page, pageSize);
|
}
|
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) {
|
|
|
List<Map<String, Object>> tjYxjcList = testMapper.getTjYxjcList(patname, sex, 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<TjProject> wq0 = new LambdaQueryWrapper<>();
|
if (!sysUser.getUserName().equals("10001")) {
|
wq0.eq(TjProject::getDeptId, ksId);
|
}
|
wq0.in(TjProject::getDeleted, 0, 1);
|
List<TjProject> projectList = projectService.list(wq0);
|
if (projectList == null || projectList.size() <= 0) {
|
return AjaxResult.error("请完善科室项目信息");
|
}
|
List<Long> ksproList = projectList.stream().map(TjProject::getProId).collect(Collectors.toList());
|
LambdaQueryWrapper<TjOrder> wq1 = new LambdaQueryWrapper<>();
|
wq1.eq(TjOrder::getUserId, cusId);
|
List<TjOrder> orderList = orderService.list(wq1);
|
if (null != orderList && orderList.size() > 0) {
|
List<TjOrder> orderList0 = new ArrayList<>();
|
for (TjOrder tjOrder : orderList) {
|
LambdaQueryWrapper<TjOrderDetail> wq2 = new LambdaQueryWrapper<>();
|
wq2.eq(TjOrderDetail::getOrderId, tjOrder.getOrderId());
|
wq2.eq(TjOrderDetail::getTjStatus, 1);
|
wq2.in(TjOrderDetail::getProId, ksproList);
|
List<TjOrderDetail> 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<TjProject> wq0 = new LambdaQueryWrapper<>();
|
if (!sysUser.getUserName().equals("10001")) {
|
wq0.eq(TjProject::getDeptId, ksId);
|
}
|
List<TjProject> projectList = projectService.list(wq0);
|
List<Long> ksproList = projectList.stream().map(TjProject::getProId).collect(Collectors.toList());
|
if (projectList == null) {
|
return AjaxResult.error("请完善科室项目信息");
|
}
|
LambdaQueryWrapper<TjOrderDetail> wq1 = new LambdaQueryWrapper<>();
|
wq1.eq(TjOrderDetail::getOrderId, orderId);
|
wq1.in(TjOrderDetail::getProId, ksproList);
|
wq1.eq(TjOrderDetail::getTjStatus, 1);
|
List<TjOrderDetail> detailList = detailService.list(wq1);
|
return AjaxResult.success(detailList);
|
}
|
|
|
/**
|
* 获取科室部门列表
|
*/
|
//@PreAuthorize("@ss.hasPermi('system:dept:list')")
|
@GetMapping("/list")
|
@ApiOperation(value = "获取科室部门列表")
|
public AjaxResult list(SysDept dept) {
|
List<SysDept> 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<SysDept> 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<TjOrderRemark> remarklList) {
|
Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId());
|
SysUser sysUser = userService.getById(userId);
|
if (remarklList == null || remarklList.isEmpty()) {
|
return AjaxResult.success("操作失败");
|
}
|
for (TjOrderRemark orderRemark : remarklList) {
|
List<String> summaryList = orderRemark.getSummaryList();
|
if (null != summaryList && !summaryList.isEmpty() && !summaryList.contains(null)) {
|
orderRemark.setSummary(Joiner.on(";").join(orderRemark.getSummaryList()));
|
} else {
|
orderRemark.setSummary(null);
|
}
|
if (StringUtils.isBlank(orderRemark.getRemark())) orderRemark.setRemark(null);
|
LambdaQueryWrapper<TjOrder> 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<TjOrderDetail> tjOrderDetailList = orderRemark.getTjOrderDetailList();
|
|
// final TjCustomer byId1 = customerService.getById(order.getUserId());
|
if (null != tjOrderDetailList && !tjOrderDetailList.isEmpty()) {
|
//----------------------------------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);
|
// }
|
// }
|
// }
|
logger.info("接口 DataSourceContextHolder ->{}", DataSourceContextHolder.getDataSourceKey());
|
logger.info("接口 DynamicDataSourceContextHolder ->{}", DynamicDataSourceContextHolder.getDataSourceType());
|
asyncService.updateOrdeltile(tjOrderDetailList, sysUser, order,orderRemark);
|
LambdaQueryWrapper<TjOrderDetail> 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<TjOrderRemark> 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.isEmpty() && !summaryList.contains(null)) {
|
one.setSummary(Joiner.on(";").join(orderRemark.getSummaryList()));
|
} else {
|
one.setSummary(null);
|
}
|
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()));
|
}
|
remarkService.tjYishengjianchajianyi(null, null, null, null);
|
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");
|
// 判断是否收费 请求接口
|
TjOrder tjOrder = orderService.getOrderByTjNum(tjNumber);
|
if (null == tjOrder) {
|
return AjaxResult.error("未找到体检记录");
|
}
|
LambdaQueryWrapper<TjFlowingWater> tjFlowingWaterLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
tjFlowingWaterLambdaQueryWrapper.eq(TjFlowingWater::getOrderId, tjOrder.getOrderId());
|
tjFlowingWaterLambdaQueryWrapper.eq(TjFlowingWater::getIsAddition, "N");
|
TjFlowingWater tjFlowingWater = tjFlowingWaterService.getOne(tjFlowingWaterLambdaQueryWrapper);
|
if (null != tjFlowingWater) {
|
if (tjFlowingWater.getPayStasus() != 1 && tjFlowingWater.getPayStasus() != 3) {
|
if (configByKey.equals("Y")) {
|
HashMap<String, Object> 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) {
|
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 s = configService.selectConfigByKey("is_request_common_his_api");
|
// if (null != s && s.equals("Y")) {
|
// LambdaQueryWrapper<TjFlowingWater> wrapper1 = new LambdaQueryWrapper<>();
|
// wrapper1.eq(TjFlowingWater::getOrderId, tjOrder.getOrderId());
|
// wrapper1.eq(TjFlowingWater::getPayStasus, 0L);
|
// List<TjFlowingWater> list = tjFlowingWaterService.list(wrapper1);
|
// if (!list.isEmpty()) {
|
// return AjaxResult.error("存在未缴费项目");
|
// }
|
// }
|
}
|
} else {
|
log.error("路泰科技--- " + DateUtil.date() + " 未对接his接口 " + " 体检号 " + tjOrder.getTjNumber());
|
return AjaxResult.error("未查询到缴费记录");
|
}
|
|
String config = configService.selectConfigByKey("qt_open_xdt");
|
String byKey = configService.selectConfigByKey("qt_kjksid");
|
Set<Integer> split = new HashSet<>(); // 存放转换后的integer类型结果
|
split.add(ksId);
|
if ("Y".equals(config)) {
|
List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();
|
if (null != roles && !roles.isEmpty()) {
|
List<SysRole> list = roles.stream().filter(item -> item.getRoleName().contains("前台")).collect(Collectors.toList());
|
if (!list.isEmpty()) {
|
if (null != byKey && !byKey.isEmpty()) {
|
String[] arr = byKey.split(","); // 根据逗号进行切割
|
for (String s : arr) {
|
int num = Integer.parseInt(s); // 将每个子字符串转换为integer类型
|
split.add(num); // 添加到列表中
|
}
|
}
|
}
|
}
|
}
|
List<TjOrderRemark> list;
|
if(null != sysUser && sysUser.getUserName().equals("10001")){
|
list=remarkService.yiShengJianChaGetPrentProCJGLY(tjNumber);
|
}else {
|
list= remarkService.yiShengJianChaGetPrentPro(tjNumber, split);
|
}
|
if (null ==list || list.isEmpty()) {
|
return AjaxResult.error("该科室下无项目！");
|
}
|
for (TjOrderRemark tjOrderRemark : list) {
|
TjProject tjProject = projectService.getById(tjOrderRemark.getProId());
|
if (null != tjProject) {
|
tjOrderRemark.setProName(tjProject.getProName());
|
}
|
}
|
return AjaxResult.success(list);
|
}
|
|
@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<TjOrderDetail> tjOrderDetailLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
tjOrderDetailLambdaQueryWrapper.eq(TjOrderDetail::getOrderId, tjOrder.getOrderId());
|
List<TjOrderDetail> tjOrderDetails = detailService.list(tjOrderDetailLambdaQueryWrapper);
|
List<Long> detailIds = tjOrderDetails.stream().map(TjOrderDetail::getOrderDetailId).collect(Collectors.toList());
|
LambdaUpdateWrapper<TjOrderDetail> tjOrderDetailLambdaUpdateWrapper = new LambdaUpdateWrapper<>();
|
tjOrderDetailLambdaUpdateWrapper.set(TjOrderDetail::getFlowingWaterId, tjSerialNumber);
|
tjOrderDetailLambdaUpdateWrapper.in(TjOrderDetail::getOrderDetailId, detailIds);
|
detailService.update(tjOrderDetailLambdaUpdateWrapper);
|
remarkService.updateTjOrderRemarkSfbzByJxbzisnull(tjOrder.getOrderId().toString(),tjFlowingWater.getTjSerialNumber().toString());
|
}
|
|
/**
|
* 点击父项目显示子项目详情
|
*
|
* @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("获取用户信息错误");
|
}
|
|
TjOrderRemark remark = remarkService.getTjOrderRemarkByTjNumAndProParentId(tjNumber, proParentId);
|
|
List<TjProject> proParentList = projectService.getTjProjectListByTbTransition(proParentId, tjNumber);
|
|
if (null == proParentList || proParentList.isEmpty()) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("xiaoJieIds", null);
|
map.put("sons", projectService.list(new LambdaQueryWrapper<TjProject>().eq(TjProject::getProId, proParentId)));
|
map.put("xiaoJie", null);
|
map.put("remark", remark.getRemark());
|
return AjaxResult.success(map);
|
}
|
List<Long> proParentIdList = proParentList.stream().map(TjProject::getProId).collect(Collectors.toList());
|
TjOrder one = orderService.getOrderByTjNum(tjNumber);
|
if (null == one) {
|
return AjaxResult.success("该用户暂时没有体检数据");
|
}
|
List<TjOrderDetail> tjOrderDetails = detailService.getTjOrderDetailListInProParentIdList(String.valueOf(one.getOrderId()), proParentIdList);
|
List<TjOrderDetail> tjOrderDetailList = new ArrayList<>();
|
if (null != tjOrderDetails && !tjOrderDetails.isEmpty()) {
|
for (TjOrderDetail tjOrderDetail : tjOrderDetails) {
|
TjProject project = projectService.getById(tjOrderDetail.getProId());
|
if(null != project){
|
//判断该项目是否需要打印报告
|
if ("N".equals(project.getNeedReport())) {
|
continue;
|
}
|
List<TjRules> rulesList = tjRulesService.getTjRulesListByTjNumAndProId(tjNumber, tjOrderDetail.getProId());
|
tjOrderDetail.setRulesList(rulesList);
|
tjOrderDetail.setProject(project);
|
tjOrderDetail.setResultType(project.getResultType());
|
if (null != remark.getDoctorName()) {
|
SysUser byId = userService.getById(remark.getDoctorName());
|
if (byId != null) {
|
tjOrderDetail.setDoctorName(userService.getById(remark.getDoctorName()).getNickName());
|
}
|
} else {
|
tjOrderDetail.setDoctorName(null);
|
}
|
if(StringUtil.isBlank(tjOrderDetail.getProResult())){
|
tjOrderDetail.setProResult(project.getProDefault());
|
}
|
tjOrderDetailList.add(tjOrderDetail);
|
}
|
}
|
}
|
Map<String, Object> map = new HashMap<>();
|
List<TjAdvice> adviceList = new ArrayList<>();
|
if (null != remark) {
|
String[] strings = StringUtils.split(remark.getSummary(), ";");
|
if (null != strings && strings.length > 0) {
|
List<TjAdvice> 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());
|
return AjaxResult.success(map);
|
}
|
|
/**
|
* 状态修改
|
*/
|
@PutMapping("/changeStatus")
|
@ApiOperation("部门状态修改")
|
public AjaxResult changeStatus(@RequestBody SysDept dept) {
|
//判断是启用还是
|
if ("1".equals(dept.getStatus())) {
|
//判断用户表中有没有人在该科室下
|
LambdaQueryWrapper<SysUser> wq = new LambdaQueryWrapper<>();
|
wq.eq(SysUser::getDeptId, dept.getDeptId());
|
List<SysUser> list = userService.list(wq);
|
if (!list.isEmpty()) {
|
return AjaxResult.error("该科室下有工作人员，不能停用！");
|
}
|
}
|
dept.setUpdateBy(getUsername());
|
int i = deptService.updateDeptStatus(dept);
|
if (i == 0) {
|
return AjaxResult.error("修改失败");
|
}
|
return AjaxResult.success("修改成功");
|
|
}
|
|
|
/**
|
* 根据项目id获取建议
|
*/
|
@GetMapping("/getDeptAdvice")
|
@ApiOperation(value = "根据项目id获取建议")
|
public AjaxResult getDeptAdvice(@ApiParam(value = "父项目项目id") @RequestParam(required = false) String proId,
|
@ApiParam(value = "内容") @RequestParam(required = false) String nr,
|
@ApiParam(value = "拼音码") @RequestParam(required = false) String pym,
|
@ApiParam(value = "页码") @RequestParam(defaultValue = "1") int page,
|
@ApiParam(value = "每页展示条数") @RequestParam(defaultValue = "10") int pageSize) {
|
LambdaQueryWrapper<TjAdvice> wq1 = new LambdaQueryWrapper<>();
|
if (null != proId) {
|
wq1.eq(TjAdvice::getProId, proId);
|
}
|
if (null != nr && !nr.isEmpty()) {
|
wq1.like(TjAdvice::getTitle, nr);
|
} else if (null != pym && !pym.isEmpty()) {
|
wq1.like(TjAdvice::getTitle, pym);
|
}
|
// else {
|
// wq1.last("limit 20");
|
// }
|
Page<TjAdvice> pages = new Page<>(page, pageSize);
|
Page<TjAdvice> advicePage = tjAdviceService.page(pages, wq1);
|
Map<String, Object> map = new HashMap<>();
|
map.put("list", advicePage.getRecords());
|
map.put("total", advicePage.getTotal());
|
// List<TjAdvice> list = tjAdviceService.list(wq1);
|
return AjaxResult.success(map);
|
}
|
|
|
@GetMapping("/getAdviceByTjNumAndPro")
|
@ApiOperation(value = "根据项目id和体检号获取建议")
|
public AjaxResult getAdviceByTjNumAndPro(@ApiParam(value = "父项目项目id") @RequestParam String proId,
|
@ApiParam(value = "体检号") @RequestParam String tjNum) {
|
LambdaQueryWrapper<TjOrderRemark> wq = new LambdaQueryWrapper<>();
|
wq.eq(TjOrderRemark::getProId, proId);
|
wq.eq(TjOrderRemark::getTjNumber, tjNum);
|
TjOrderRemark remark = remarkService.getOne(wq);
|
List<TjAdvice> list = null;
|
if (null != remark && !StringUtils.isBlank(remark.getSummary())) {
|
String[] strings = StringUtils.split(remark.getSummary(), ";");
|
if (null != strings && strings.length > 0) {
|
list = tjAdviceService.getAdviceStringByIds(strings);
|
}
|
}
|
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<TreeSelect> treeSelects = deptService.selectDeptTreeList1(dept);
|
return success(treeSelects);
|
}
|
|
|
/**
|
* 获取子科室部门列表
|
*/
|
@GetMapping("/getChildList")
|
@ApiOperation(value = "获取子科室部门列表")
|
public AjaxResult getChildList(String deptName) {
|
LambdaQueryWrapper<SysDept> wq = new LambdaQueryWrapper<>();
|
wq.ne(SysDept::getParentId, 0);
|
if (deptName != null) {
|
wq.like(SysDept::getDeptName, deptName);
|
}
|
List<SysDept> depts = deptService.list(wq);
|
return success(depts);
|
}
|
|
@GetMapping("/getxmjgz")
|
@ApiOperation(value = "医生检查处获取项目规则值")
|
public AjaxResult getxmjgz(@RequestParam String proId,@RequestParam(required = false) String xmgz) {
|
LambdaQueryWrapper<TjRules> wq = new LambdaQueryWrapper<>();
|
wq.eq(TjRules::getProId, proId);
|
if(StringUtil.isNotBlank(xmgz))wq.like(TjRules::getRuleStr,xmgz);
|
List<TjRules> list = tjRulesService.list(wq);
|
if(null !=list && !list.isEmpty()){
|
for (TjRules tjRules : list) {
|
if(null !=tjRules){
|
tjRules.setJm(PinyinUtil.getFirstLetter(tjRules.getRuleStr(),""));
|
}
|
}
|
}
|
return AjaxResult.success(list);
|
}
|
|
|
@GetMapping ("/ysjcbGetProByTjNumAndOrderId")
|
@ApiOperation (value = "医生检查页面查询检验检查项目接口")
|
public AjaxResult ysjcbGetProByTjNumAndOrderId(@ApiParam (value = "体检号") @RequestParam String tjNumber) {
|
// List<TjOrderRemark> orderRemarkList = orderRemarkService.getTjOrderRemarkListByTjNum(tjNumber);
|
// List<CsProVo> list = new ArrayList<>();
|
// if (null != orderRemarkList && orderRemarkList.size() > 0) {
|
// for (TjOrderRemark remark : orderRemarkList) {
|
// CsProVo vo = new CsProVo();
|
// vo.setDeptName(deptService.getById(remark.getDeptId()).getDeptName());
|
// vo.setProName(projectService.getById(remark.getProId()).getProName());
|
// vo.setType(remark.getType());
|
// if (null != remark.getDoctorName()) {
|
// vo.setDoctorName(userService.getById(remark.getDoctorName()).getNickName());
|
// vo.setBcdoctorName(userService.getById(remark.getDoctorName()).getNickName());
|
// }
|
// vo.setSffs("统收");
|
// vo.setIsPay("已收费");
|
// vo.setQdcreateTime(remark.getCreateTime());
|
// vo.setBcupdateTime(remark.getUpdateTime());
|
// vo.setZhupdateTime(remark.getUpdateTime());
|
// list.add(vo);
|
// }
|
// List<CsProVo> list1 = orderRemarkService.cSWebGetProByTjNumAndOrderId(tjNumber);
|
// Collections.sort(list, new Comparator<CsProVo>() {
|
// @Override
|
// public int compare(CsProVo o1, CsProVo o2) {
|
// return o1.getType() - o2.getType();
|
// }
|
// });
|
// }
|
|
List<CsProVo> list = getysjcProVos(tjNumber);
|
return AjaxResult.success(list);
|
}
|
|
public List<CsProVo> getysjcProVos(String tjNumber) {
|
List<CsProVo> list = remarkService.ysjcGetProByTjNumAndOrderId(tjNumber);
|
if (null != list && !list.isEmpty()) {
|
list.sort(new Comparator<CsProVo>() {
|
@Override
|
public int compare(CsProVo o1, CsProVo o2) {
|
return o1.getType() - o2.getType();
|
}
|
});
|
}
|
return list;
|
}
|
|
}
|
