JianYanJianChaShenQingService.java 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672
  1. package thyyxxk.webserver.service.zhuyuanyisheng;
  2. import cn.hutool.extra.spring.SpringUtil;
  3. import com.alibaba.fastjson.JSON;
  4. import com.baomidou.dynamic.datasource.annotation.DS;
  5. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  6. import com.baomidou.mybatisplus.core.metadata.IPage;
  7. import com.baomidou.mybatisplus.core.metadata.OrderItem;
  8. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.stereotype.Service;
  11. import org.springframework.transaction.annotation.Transactional;
  12. import thyyxxk.webserver.config.exception.BizException;
  13. import thyyxxk.webserver.config.exception.ExceptionEnum;
  14. import thyyxxk.webserver.constants.Capacity;
  15. import thyyxxk.webserver.dao.his.zhuyuanyisheng.JianYanJianChaDao;
  16. import thyyxxk.webserver.dao.his.zhuyuanyisheng.YiZhuLuRuDao;
  17. import thyyxxk.webserver.entity.ResultVo;
  18. import thyyxxk.webserver.entity.datamodify.GetDropdownBox;
  19. import thyyxxk.webserver.entity.login.UserInfo;
  20. import thyyxxk.webserver.entity.zhuyuanyisheng.jianyanjiancha.*;
  21. import thyyxxk.webserver.entity.zhuyuanyisheng.query.ChaXunJianChaHeJianYan;
  22. import thyyxxk.webserver.entity.zhuyuanyisheng.yizhuluru.PatientTemp;
  23. import thyyxxk.webserver.entity.zhuyuanyisheng.yizhuluru.XinZhenYiZhu;
  24. import thyyxxk.webserver.service.PublicServer;
  25. import thyyxxk.webserver.service.redislike.RedisLikeService;
  26. import thyyxxk.webserver.utils.*;
  27. import java.lang.reflect.Field;
  28. import java.nio.channels.NonWritableChannelException;
  29. import java.util.*;
  30. import java.util.stream.Collectors;
  31. /**
  32. * <p>
  33. * 描述: 住院医生,检查申请
  34. * </p>
  35. *
  36. * @author xc
  37. * @date 2022-02-10 15:37
  38. */
  39. @Service
  40. @Slf4j
  41. public class JianYanJianChaShenQingService {
  42. private final JianYanJianChaDao dao;
  43. private final PublicServer publicServer;
  44. private final YiZhuLuRuDao yiZhuLuRuDao;
  45. private final RedisLikeService realtimeService;
  46. private JianYanJianChaShenQingService getThis() {
  47. return SpringUtil.getBean(this.getClass());
  48. }
  49. public JianYanJianChaShenQingService(JianYanJianChaDao dao, PublicServer publicServer, YiZhuLuRuDao yiZhuLuRuDao, RedisLikeService realtimeService) {
  50. this.dao = dao;
  51. this.publicServer = publicServer;
  52. this.yiZhuLuRuDao = yiZhuLuRuDao;
  53. this.realtimeService = realtimeService;
  54. }
  55. /*-------------------------------------------------------------- 下面是检查的逻辑 -----------------------------------------------------------------------------------------------------*/
  56. /**
  57. * 获取检验检查的名字
  58. *
  59. * @param name 姓名
  60. * @param patNo 住院号
  61. * @param times 住院次数
  62. * @param bedNo 床位
  63. * @param reqType 2-检验 3-检查
  64. * @return 返回数据
  65. */
  66. public ResultVo<List<Map<String, String>>> huoQuJianYanJianChaMing(String name, String patNo, Integer times, String bedNo, String reqType) {
  67. return ResultVoUtil.success(dao.huoQuJianJianChaMing(patNo, times, bedNo, StringUtil.isContainChinese(name), reqType));
  68. }
  69. /**
  70. * 获取检查申请
  71. *
  72. * @param param 检查申请
  73. * @return 返回数据
  74. */
  75. public ResultVo<List<YshYjReq>> huoQuJianChaShenQing(ChaXunJianChaHeJianYan param) {
  76. QueryWrapper<?> qw = new QueryWrapper<>();
  77. qw.eq("inpatient_no", param.getPatNo());
  78. qw.eq("admiss_times", param.getTimes());
  79. qw.eq("req_type", "3");
  80. if (StringUtil.notBlank(param.getOrderName())) {
  81. qw.like("order_name", param.getOrderName());
  82. }
  83. if (StringUtil.notBlank(param.getStartTime())) {
  84. qw.ge("start_time", param.getStartTime())
  85. .le("start_time", param.getEndTime());
  86. }
  87. qw.orderByDesc("req_date");
  88. List<YshYjReq> list = dao.huoQuJianChaShenQingV2(qw);
  89. return ResultVoUtil.success(list);
  90. }
  91. public ResultVo<Map<String, Object>> huoQuShengQingXiangQing(Integer reqNo) {
  92. YshYjReq req = dao.huoQuShengQingXiangQing(reqNo);
  93. if (req == null) {
  94. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_HTML_ERROR, "没有查询到有效信息,可能已经被删除了。");
  95. }
  96. Map<String, Object> map = new HashMap<>();
  97. StringBuilder zhuYiShiXiang = new StringBuilder();
  98. JcZdClass jc = dao.daYingXiangQing(req.getOrderType());
  99. // 获取患者的住址和性别
  100. PatientTemp patient = dao.huoQuHuanZheXinXi(req.getInpatientNo());
  101. req.setSex(patient.getSex());
  102. // 地址
  103. req.setHomeStreet(patient.getHomeStreet());
  104. //联系电话
  105. req.setHomeTel(patient.getHomeTel());
  106. // 医保身份
  107. req.setResponceTypeName(dao.huoQuHuanZheShenFen(req.getInpatientNo()));
  108. map.put("title", jc.getComm());
  109. Field[] fields = jc.getClass().getDeclaredFields();
  110. for (Field field : fields) {
  111. field.setAccessible(true);
  112. // 输出属性名和属性值
  113. try {
  114. String key = field.getName();
  115. Object value = EntityStringTrim.getFieldValue(jc, key);
  116. if (key.startsWith("comment") && StringUtil.notBlank((String) value)) {
  117. zhuYiShiXiang.append(((String) value).trim()).append("\n");
  118. }
  119. } catch (Exception e) {
  120. e.printStackTrace();
  121. }
  122. }
  123. map.put("mattersNeedingAttention", zhuYiShiXiang.toString());
  124. map.put("data", req);
  125. return ResultVoUtil.success(map);
  126. }
  127. /**
  128. * 获取检查
  129. *
  130. * @return
  131. */
  132. public ResultVo<List<JcZdClass>> getCheckNewApplication() {
  133. return ResultVoUtil.success(dao.getCheckNewApplication());
  134. }
  135. /**
  136. * @param itemType 3-检查 2-检验
  137. * @param templateType 2 个人 3 科室模板
  138. * @return
  139. */
  140. public ResultVo<List<JcZdClass>> getTemplate(Integer itemType, Integer templateType) {
  141. QueryWrapper<?> qw = new QueryWrapper<>();
  142. qw.eq("c.req_type", itemType);
  143. if (templateType == 2) {
  144. qw.eq("c.op_id", TokenUtil.getTokenUserId());
  145. } else {
  146. UserInfo info = realtimeService.getUserInfoByToken();
  147. qw.eq("c.tc_exec", info.getDeptCode());
  148. }
  149. List<JcZdClass> parentNode = dao.getTemplate(qw);
  150. Map<String, JcZdClass> map = parentNode
  151. .stream()
  152. .collect(Collectors.toMap(JcZdClass::getCode, a -> a, (k1, k2) -> k1));
  153. List<Map<String, String>> tempContent = dao.selectTemplateContent(qw);
  154. tempContent.forEach(item -> {
  155. JcZdClass jcZdClass = map.get(item.get("tc_no"));
  156. if (jcZdClass != null) {
  157. if (jcZdClass.getList() == null) {
  158. jcZdClass.setList(new ArrayList<>());
  159. }
  160. jcZdClass.getList().add(item);
  161. }
  162. });
  163. return ResultVoUtil.success(parentNode);
  164. }
  165. /**
  166. * 查询检查检验分类
  167. *
  168. * @param total 总条数
  169. * @param currentPage 当前页
  170. * @param leiXing 类型 1-新申请 2-个人 3-科室
  171. * @param jianCha true 检查 false 检验
  172. * @return 返回分页数据
  173. */
  174. @Deprecated
  175. public ResultVo<IPage<JcZdClass>> jianChaJianYanFenLei(long total, long currentPage, Integer leiXing, Boolean jianCha) {
  176. IPage<JcZdClass> page = new Page<>();
  177. if (leiXing == 1) {
  178. if (jianCha) {
  179. if (total == 0) {
  180. page.setTotal(dao.jianChaMingTiaoShu());
  181. }
  182. page.setRecords(dao.jianChaMing(currentPage));
  183. } else {
  184. page = new Page<>(currentPage, 20, total == 0);
  185. page = dao.jianYanFenLei(page);
  186. return ResultVoUtil.success(page);
  187. }
  188. } else {
  189. page = new Page<>(currentPage, 20, total == 0);
  190. page = dao.jianChaJianYanMuBan(page, leiXing, TokenUtil.getTokenUserId(), jianCha ? "3" : "2");
  191. }
  192. return ResultVoUtil.success(page);
  193. }
  194. /**
  195. * 删除检查或检验模板
  196. *
  197. * @param code 要删除的模板 code
  198. * @param deptCode 当前患者的科室编码
  199. * @return 返回提示
  200. */
  201. public ResultVo<String> shanShuJianChaMuBan(String code, String deptCode) {
  202. ZyTcYj yj = dao.jianChaLuRuRen(code);
  203. if (yj == null) {
  204. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找对应的记录可能已经被删除了。");
  205. }
  206. if (jianChaMuBanPanDuan(yj.getOpId(), yj.getTcExec(), deptCode)) {
  207. dao.shanChuJianChaMuBan(code);
  208. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  209. }
  210. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "您没有权限执行这个操作。");
  211. }
  212. /**
  213. * 检查模板的判断
  214. *
  215. * @param opId 录入人
  216. * @param tcExec 模板的科室
  217. * @param deptCode 当前用户的科室
  218. * @return boolean
  219. */
  220. public boolean jianChaMuBanPanDuan(String opId, String tcExec, String deptCode) {
  221. List<Integer> userRole = publicServer.getRoleCode().getData();
  222. // 医务部
  223. if (userRole.contains(38)) {
  224. return true;
  225. }
  226. // 科主任 可以删除自己科室任意模板
  227. if (userRole.contains(11) && tcExec.trim().equals(deptCode)) {
  228. return true;
  229. }
  230. // 普通的只能删除自己的
  231. return opId.trim().equals(TokenUtil.getTokenUserId());
  232. }
  233. /**
  234. * 获取说明,模板的一下信息
  235. *
  236. * @param name 根据说明模板来 搜索
  237. * @param fenLei 分类
  238. * @param total 总数
  239. * @param currentPage 当前页
  240. * @return 返回提示
  241. */
  242. public ResultVo<IPage<YshZdYjTemplate>> huoMuShuoMingMuBan(String name, Integer fenLei, long total, long currentPage) {
  243. Page<YshZdYjTemplate> page = new Page<>(currentPage, 20, total == 0);
  244. page = dao.huoQuShuoMingMuBan(page, StringUtil.isContainChinese(name), fenLei, TokenUtil.getTokenUserId());
  245. return ResultVoUtil.success(page);
  246. }
  247. /**
  248. * 对于说明模板的操作
  249. *
  250. * @param param 说明模板的内容
  251. * @return 返回提示
  252. */
  253. @Transactional(rollbackFor = Exception.class)
  254. public ResultVo<String> shouMingMuBanChaoZuo(YshZdYjTemplate param) {
  255. switch (param.getLeiXing()) {
  256. case "修改":
  257. return xiuGaiMuBan(param, dao.muBanShuJu(param.getCode()));
  258. case "删除":
  259. return shanChuMuBan(dao.muBanShuJu(param.getCode()));
  260. case "新增":
  261. return xinZengShouMingMuBan(param);
  262. default:
  263. return ResultVoUtil.success();
  264. }
  265. }
  266. /**
  267. * 修改说明模板
  268. *
  269. * @param param 修改的数据
  270. * @param mb 原来的数据
  271. * @return 返回提示
  272. */
  273. private ResultVo<String> xiuGaiMuBan(YshZdYjTemplate param, YshZdYjTemplate mb) {
  274. if (publicServer.noNeedRule(38)) {
  275. if (!TokenUtil.getTokenUserId().equals(mb.getOpId().trim())) {
  276. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "该模板创建人不是你,无法操作。");
  277. }
  278. }
  279. dao.genXingShouMingMuBan(param.getJcText(), param.getName(),
  280. PingYinUtils.pyShouZiMuDaXie(param.getName()),
  281. PingYinUtils.getWBCode(param.getName()), param.getCode());
  282. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  283. }
  284. /**
  285. * 删除说明模板
  286. *
  287. * @param mb 通过数据库查找 原来的模板
  288. * @return 返回提示
  289. */
  290. private ResultVo<String> shanChuMuBan(YshZdYjTemplate mb) {
  291. List<Integer> userRole = publicServer.getRoleCode().getData();
  292. if (publicServer.noNeedRule(userRole, 38)) {
  293. if (TokenUtil.getTokenUserId().equals(mb.getOpId().trim()) || (userRole.contains(11) && mb.getDeptCode().trim().equals(mb.getUserDeptCode().trim()))) {
  294. dao.shanChuShouMingMuBan(mb.getCode());
  295. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  296. } else {
  297. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "您没有权限修改。");
  298. }
  299. }
  300. dao.shanChuShouMingMuBan(mb.getCode());
  301. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  302. }
  303. /**
  304. * 新增说明模板
  305. *
  306. * @param param 新增的数据
  307. * @return 返回提示
  308. */
  309. private ResultVo<String> xinZengShouMingMuBan(YshZdYjTemplate param) {
  310. if (param.getWhFlag().trim().equals("3") && publicServer.noNeedRule(38)) {
  311. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "您没有权限创建全院模板。");
  312. }
  313. param.setCode(publicServer.getYjTemplateNo().toString());
  314. param.setPyCode(PingYinUtils.pyShouZiMuDaXie(param.getName(), 8));
  315. param.setDCode(PingYinUtils.getWBCode(param.getName(), 8));
  316. param.setOpId(TokenUtil.getTokenUserId());
  317. dao.xinZengShouMingMuBan(param);
  318. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  319. }
  320. /**
  321. * 搜索临床诊断
  322. *
  323. * @param name 搜索的名字
  324. * @return 返回搜索的数据
  325. */
  326. @DS("his")
  327. public ResultVo<List<GetDropdownBox>> diagnosisInOurHospital(String name) {
  328. return ResultVoUtil.success(dao.diagnosisInOurHospital(StringUtil.isContainChinese(name)));
  329. }
  330. /**
  331. * 判断检查模板是否有重复的
  332. *
  333. * @param name 名称
  334. * @return 返回有没有
  335. */
  336. public ResultVo<Boolean> jianChaJianYanMuBanMing(String name, String reqType) {
  337. return ResultVoUtil.success(dao.huoQuJianChaJianYanChongFuMuBanMing(name, TokenUtil.getTokenUserId(), reqType).size() > 0);
  338. }
  339. /**
  340. * 保存检查或检验模板
  341. *
  342. * @param param 数据
  343. * @return 返回提示
  344. */
  345. @Transactional(rollbackFor = Exception.class)
  346. public ResultVo<String> baoCunJianChaJianYanMuBan(ZyTcYj param) {
  347. param.setOpId(TokenUtil.getTokenUserId());
  348. param.setTcNo(publicServer.huoQuJianYanJianChaXuHao().toString());
  349. param.setPyCode(PingYinUtils.pyShouZiMuDaXie(param.getTcName(), 8));
  350. param.setDCode(PingYinUtils.getWBCode(param.getTcName(), 8));
  351. List<String> yuanShuJu = dao.huoQuJianChaJianYanChongFuMuBanMing(param.getTcName(), param.getOpId(), param.getReqType());
  352. if (ListUtil.notBlank(yuanShuJu)) {
  353. for (String s : yuanShuJu) {
  354. dao.shanChuJianChaMuBan(s);
  355. }
  356. }
  357. dao.chaRuJCJYMuBan(param);
  358. dao.chaRuJCJYMuBanNeiRong(param.getList(), param.getTcNo(), param.getReqType().trim());
  359. log.info("模板数据:{}", JSON.toJSONString(param.getList()));
  360. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  361. }
  362. public ResultVo<String> baoCunJianYanJianCha(TianJiaJianChaJianYan param) {
  363. if (ListUtil.isBlank(param.getList())) {
  364. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "请选择需要保存的数据。");
  365. }
  366. XinZhenYiZhu huanZheXinXi = yiZhuLuRuDao.queryPatientInfo(param.getInpatientNo(), param.getAdmissTimes());
  367. publicServer.huanZheJieSuan(param.getInpatientNo(), param.getAdmissTimes());
  368. List<String> xm = new ArrayList<>();
  369. int index = 1;
  370. List<String> content = new ArrayList<>();
  371. StringBuilder cuoWuXinXi = new StringBuilder();
  372. for (YshYjReq item : param.getList()) {
  373. if (StringUtil.notBlank(item.getJzFlag()) && "0".equals(item.getJzFlag())) {
  374. item.setJzFlag(null);
  375. }
  376. if (StringUtil.notBlank(item.getYbSelfFlag()) && "0".equals(item.getYbSelfFlag())) {
  377. item.setYbSelfFlag(null);
  378. }
  379. if (StringUtil.isBlank(item.getOrderCode())) {
  380. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "项目编码不能为空"));
  381. }
  382. if (StringUtil.isBlank(item.getOrderName())) {
  383. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "项目名称不能为空"));
  384. }
  385. if (item.getStartTime() == null) {
  386. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "检查时间不能为空"));
  387. } else if (DateUtil.shiJianDaXiao(huanZheXinXi.getAdmissDate(), item.getStartTime(), ">")) {
  388. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "检查时间不能在入院时间之前。"));
  389. }
  390. if (StringUtil.isBlank(item.getExecDept())) {
  391. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "执行科室不能为空。"));
  392. }
  393. if ("3".equals(param.getReqType())) {
  394. if (StringUtil.isBlank(item.getReqComment())) {
  395. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "病室摘要不能为空。"));
  396. }
  397. if (StringUtil.isBlank(item.getReqTzComment())) {
  398. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "体征信息不能为空。"));
  399. }
  400. if (StringUtil.isBlank(item.getReqOtherResult())) {
  401. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "相关辅检结果不能为空。"));
  402. }
  403. if (StringUtil.isBlank(item.getDiagCode())) {
  404. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "临床诊断不能为空。"));
  405. }
  406. } else {
  407. if (StringUtil.isBlank(item.getInspectStuff())) {
  408. cuoWuXinXi.append(baoCunCuoWuXinXi(index, "标本不能为空。"));
  409. }
  410. }
  411. if (cuoWuXinXi.length() > 0) {
  412. cuoWuXinXi.append("<br>");
  413. }
  414. xm.add(item.getOrderCode().trim());
  415. content.add(String.format("%s:<span style='color:#409eff'>【%s】</span><br>" +
  416. "患者姓名:<span style='color:#409eff'>【%s】</span><br>" +
  417. "床位:<span style='color:#409eff'>【%s】</span>", "2".equals(param.getReqType()) ? "检查名" : "检验名",
  418. item.getOrderName(), huanZheXinXi.getName(), huanZheXinXi.getBedNo()));
  419. index++;
  420. }
  421. // 先判断是不是停用了
  422. String tingYong = publicServer.xiangMuXianZhi(xm, true);
  423. if (StringUtil.notBlank(tingYong)) {
  424. throw new BizException(ExceptionEnum.LOGICAL_HTML_ERROR, tingYong);
  425. }
  426. if (StringUtil.notBlank(cuoWuXinXi.toString())) {
  427. throw new BizException(ExceptionEnum.LOGICAL_HTML_ERROR, String.valueOf(cuoWuXinXi));
  428. }
  429. // 生成 医嘱号和申请号
  430. for (YshYjReq item : param.getList()) {
  431. item.setActOrderNo(publicServer.getActOrderNo());
  432. item.setReqNo(publicServer.getReqPageNo());
  433. }
  434. String userCode = TokenUtil.getTokenUserId();
  435. getThis().insertData(param, huanZheXinXi, userCode);
  436. try {
  437. publicServer.faSongXiaoXi(huanZheXinXi, content, "2".equals(param.getReqType()) ? "新增检查" : "新增检验", TokenUtil.getTokenUserId());
  438. } catch (Exception e) {
  439. e.printStackTrace();
  440. }
  441. log.info("数据:{}", JSON.toJSONString(param.getList()));
  442. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  443. }
  444. @Transactional(rollbackFor = Exception.class)
  445. public void insertData(TianJiaJianChaJianYan param, XinZhenYiZhu huanZheXinXi, String userCode) {
  446. Date reqDate = new Date();
  447. dao.chaRuShenQing(param.getList(), param.getInpatientNo(), param.getName(), param.getAge() + "岁", param.getAdmissTimes(),
  448. param.getBedNo(), userCode, huanZheXinXi.getDeptCode(), huanZheXinXi.getDeptCode(), param.getReqType(),
  449. "3".equals(param.getReqType()) ? "jc_zd_item" : "jy_zd_item", reqDate);
  450. dao.chaRuShenQingYiZhu(param.getList(), param.getInpatientNo(), param.getAdmissTimes(), userCode, huanZheXinXi.getDeptCode(), huanZheXinXi.getDeptCode(),
  451. PublicServer.getInfantFlag(param.getInpatientNo()), reqDate);
  452. }
  453. public String baoCunCuoWuXinXi(int index, String xinXi) {
  454. return String.format("第【%d】个%s<br>", index, xinXi);
  455. }
  456. /*-------------------------------------------------------------- 下面是检验的逻辑 -----------------------------------------------------------------------------------------------------*/
  457. public ResultVo<List<YshYjReq>> huoQuJianYan(ChaXunJianChaHeJianYan param) {
  458. QueryWrapper<?> qw = new QueryWrapper<>();
  459. qw.eq("inpatient_no", param.getPatNo());
  460. qw.eq("admiss_times", param.getTimes());
  461. qw.eq("req_type", "2");
  462. if (StringUtil.notBlank(param.getStartTime())) {
  463. qw.ge("start_time", param.getStartTime())
  464. .le("start_time", param.getEndTime());
  465. }
  466. if (StringUtil.notBlank(param.getOrderName())) {
  467. qw.like("order_name", param.getOrderName());
  468. }
  469. List<YshYjReq> list = dao.huoQuJianYanV2(qw);
  470. return ResultVoUtil.success(list);
  471. }
  472. public ResultVo<IPage<JcZdClass>> huoQuJianYanMing(long total, long currentPage, Integer leiXing) {
  473. IPage<JcZdClass> page = new Page<>(currentPage, 20, total == 0);
  474. if (leiXing == 1) {
  475. page = dao.jianYanFenLei(page);
  476. return ResultVoUtil.success(page);
  477. }
  478. return ResultVoUtil.success();
  479. }
  480. public ResultVo<List<GetDropdownBox>> biaoBenShuJu(String name) {
  481. return ResultVoUtil.success(dao.biaoBenLeiXing(StringUtil.isContainChinese(name)));
  482. }
  483. @DS("his")
  484. public ResultVo<List<JianYanFeiYongXiangQing>> viewInspectionItemDetails(String orderCode) {
  485. return ResultVoUtil.success(dao.viewInspectionItemDetails(orderCode));
  486. }
  487. public ResultVo<String> shanChuJianChaJianYan(Integer reqNo, String patNo, Integer times) {
  488. if (StringUtil.isBlank(patNo)) {
  489. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "住院号不能为空。");
  490. }
  491. YshYjReq yj = dao.huoQuJianYanJianCha(reqNo, patNo, times);
  492. if (yj == null) {
  493. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有查询到该数据的具体信息,已经被删除了。");
  494. }
  495. String jcId = dao.getJcIdByPatNo(patNo);
  496. if (StringUtil.notBlank(jcId)) {
  497. YjJcRecord yjJcRecord = dao.getJcRecord(String.valueOf(reqNo), jcId);
  498. if (yjJcRecord != null) {
  499. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "结果已返回无法删除。");
  500. }
  501. }
  502. if (!"1".equals(yj.getReceiveFlag().trim())) {
  503. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "当前不是申请状态无法删除,无法删除。");
  504. }
  505. dao.shanChuJianYanJianCha(reqNo, patNo, times);
  506. dao.shanChuYiZhu(yj.getActOrderNo());
  507. log.info("删除医技申请==》操作人:{},医技数据:{}", TokenUtil.getTokenUserId(), JSON.toJSONString(yj));
  508. return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
  509. }
  510. public ResultVo<Map<String, Object>> queryCheckTextResults(String patNo, String reqNo) {
  511. String jcId = dao.getJcIdByPatNo(patNo);
  512. if (StringUtil.isBlank(jcId)) {
  513. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有获取到患者的检查id");
  514. }
  515. YjJcRecord yjJcRecord = dao.getJcRecord(reqNo, jcId);
  516. if (yjJcRecord == null) {
  517. return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "没有查询到检查结果。");
  518. }
  519. Map<String, String> textJc = dao.selectTextJc(yjJcRecord.getReportNo());
  520. if (textJc != null) {
  521. yjJcRecord.setDiagnosticOpinion(textJc.get("text_zd"));
  522. yjJcRecord.setCheckWhatYouSee(textJc.get("text_jc"));
  523. }
  524. Map<String, Object> map = new HashMap<>(Capacity.TWO);
  525. map.put("record", yjJcRecord);
  526. return ResultVoUtil.success(map);
  527. }
  528. /**
  529. * 检验检查 树状图
  530. *
  531. * @return 返回树
  532. */
  533. @DS("his")
  534. public ResultVo<Map<String, List<JyJcItem>>> getJyJcZdTree() {
  535. Map<String, List<JyJcItem>> map = new HashMap<>(Capacity.TWO);
  536. // 把 检验 项目大类做map的key
  537. Map<String, JyJcItem> jyMap = dao.queryInspectionClassification().stream().collect(
  538. Collectors.toMap(JyJcItem::getCode, a -> a, (k1, k2) -> k1)
  539. );
  540. // 获取检验的详细项目
  541. List<JyJcItem> jyDetailedItems = dao.getJyDetailedItems();
  542. grouping(jyMap, jyDetailedItems);
  543. // 把 检查 项目大类做map的key
  544. Map<String, JyJcItem> jcMap = dao.queryCheckClassification().stream().collect(
  545. Collectors.toMap(JyJcItem::getCode, a -> a, (k1, k2) -> k1)
  546. );
  547. // 获取检查的详细项目
  548. List<JyJcItem> jcDetailedItems = dao.selectJcDetailItems();
  549. grouping(jcMap, jcDetailedItems);
  550. // 检查项目还需要根据部位细分
  551. List<JyJcItem> jcTree = new ArrayList<>();
  552. for (Map.Entry<String, JyJcItem> item : jcMap.entrySet()) {
  553. // 没有节点就不要添加
  554. if (item.getValue().getChildren() != null) {
  555. JyJcItem temp = new JyJcItem();
  556. temp.setName(item.getValue().getName());
  557. temp.setChildren(new ArrayList<>());
  558. // 通过部位进行详细的区分
  559. Map<String, List<JyJcItem>> tempMap = item.getValue().getChildren().stream().collect(
  560. Collectors.groupingBy(JyJcItem::getBw)
  561. );
  562. for (Map.Entry<String, List<JyJcItem>> entry : tempMap.entrySet()) {
  563. // 如果部位是空的就直接添加到父节点
  564. if (StringUtil.isBlank(entry.getKey())) {
  565. temp.setChildren(entry.getValue());
  566. } else {
  567. // 添加到指定的部位
  568. JyJcItem temp1 = new JyJcItem();
  569. temp1.setName(entry.getKey());
  570. temp1.setChildren(entry.getValue());
  571. temp.getChildren().add(temp1);
  572. }
  573. }
  574. jcTree.add(temp);
  575. }
  576. }
  577. map.put("jy", new ArrayList<>(jyMap.values()));
  578. map.put("jc", jcTree);
  579. return ResultVoUtil.success(map);
  580. }
  581. private void grouping(Map<String, JyJcItem> jyMap, List<JyJcItem> jyDetailedItems) {
  582. for (JyJcItem item : jyDetailedItems) {
  583. if (jyMap.containsKey(item.getClasses())) {
  584. JyJcItem tempMap = jyMap.get(item.getClasses());
  585. if (tempMap.getChildren() == null) {
  586. tempMap.setChildren(new ArrayList<>());
  587. }
  588. tempMap.getChildren().add(item);
  589. }
  590. }
  591. }
  592. @DS("his")
  593. public ResultVo<List<JyJcItem>> getJcItem(String code) {
  594. return ResultVoUtil.success(dao.getJcItem(StringUtil.isContainChinese(code)));
  595. }
  596. @DS("his")
  597. public ResultVo<List<JyJcItem>> getJyItem(String code) {
  598. return ResultVoUtil.success(dao.getJyItem(StringUtil.isContainChinese(code)));
  599. }
  600. }