PatientService.java 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555
  1. package thyyxxk.webserver.service.inpatient;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.baomidou.mybatisplus.core.metadata.IPage;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.jetbrains.annotations.NotNull;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Transactional;
  11. import thyyxxk.webserver.config.exception.BizException;
  12. import thyyxxk.webserver.config.exception.ExceptionEnum;
  13. import thyyxxk.webserver.constants.Capacity;
  14. import thyyxxk.webserver.constants.sidicts.*;
  15. import thyyxxk.webserver.dao.his.inpatient.PatientDao;
  16. import thyyxxk.webserver.dao.his.inpatient.Routines;
  17. import thyyxxk.webserver.dao.his.zhuyuanyisheng.YiZhuLuRuDao;
  18. import thyyxxk.webserver.entity.ResultVo;
  19. import thyyxxk.webserver.entity.dictionary.CodeName;
  20. import thyyxxk.webserver.entity.drg.BaseInfo;
  21. import thyyxxk.webserver.entity.drg.DiseInfoList;
  22. import thyyxxk.webserver.entity.drg.OprtInfoList;
  23. import thyyxxk.webserver.entity.inpatient.dismiss.ZyDisYbDiag;
  24. import thyyxxk.webserver.entity.inpatient.patient.*;
  25. import thyyxxk.webserver.entity.zhuyuanyisheng.yizhuluru.HuanZheFeiYong;
  26. import thyyxxk.webserver.entity.zhuyuanyisheng.yizhuluru.XinZhenYiZhu;
  27. import thyyxxk.webserver.http.drg.DrgWebApi;
  28. import thyyxxk.webserver.service.hutoolcache.UserCache;
  29. import thyyxxk.webserver.service.zhuyuanyisheng.emr.EmrServer;
  30. import thyyxxk.webserver.utils.*;
  31. import java.text.SimpleDateFormat;
  32. import java.util.*;
  33. /**
  34. * @author dj
  35. */
  36. @Slf4j
  37. @Service
  38. public class PatientService {
  39. private static final String ZD_MEDCN = "yp_zd_dict";
  40. private final PatientDao dao;
  41. private final Routines routines;
  42. private final YiZhuLuRuDao yiZhuLuRuDao;
  43. private final EmrServer emrServer;
  44. private final DrgWebApi drgWebApi;
  45. private final UserCache userCache;
  46. @Autowired
  47. public PatientService(PatientDao dao, Routines routines, YiZhuLuRuDao yiZhuLuRuDao, EmrServer emrServer, DrgWebApi drgWebApi, UserCache userCache) {
  48. this.dao = dao;
  49. this.routines = routines;
  50. this.yiZhuLuRuDao = yiZhuLuRuDao;
  51. this.emrServer = emrServer;
  52. this.drgWebApi = drgWebApi;
  53. this.userCache = userCache;
  54. }
  55. public ResultVo<List<Overview>> getOverView(String ward, Boolean viewBabies) {
  56. ward = "%" + ward + "%";
  57. String sql = "";
  58. if (!viewBabies) {
  59. sql = "and charindex('$',a.inpatient_no)=0 ";
  60. }
  61. return ResultVoUtil.success(dao.getOverView(ward, TokenUtil.getInstance().getTokenUserId(), sql));
  62. }
  63. public ResultVo<Patient> getPatientInfo(String inpatientNo) {
  64. Patient data = dao.getPatientInfo(inpatientNo, "zy_actpatient", 0);
  65. if (null == data) {
  66. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有住院号【" + inpatientNo + "】的在院业务!");
  67. }
  68. if (null == data.getAdmdvs()) {
  69. data.setAdmdvs(dao.getPatAdmdvs(data.getInpatientNo(), data.getAdmissTimes(), data.getLedgerSn()));
  70. }
  71. if (null != data.getAdmdvs()) {
  72. Integer parentRegion = dao.selectParentRegion(data.getAdmdvs());
  73. if (null != parentRegion) {
  74. if (parentRegion == 100000) {
  75. parentRegion = data.getAdmdvs();
  76. }
  77. data.setAdmdvsCascader(new Integer[]{parentRegion, data.getAdmdvs()});
  78. }
  79. }
  80. setExpenseInformation(data);
  81. return ResultVoUtil.success(data);
  82. }
  83. public ResultVo<Patient> getDisPatient(String inpatientNo, Integer times) {
  84. Patient data = dao.getPatientInfo(inpatientNo, "zy_inactpatient", times);
  85. if (null == data) {
  86. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有住院号【" + inpatientNo + "】的出院业务!");
  87. }
  88. setExpenseInformation(data);
  89. return ResultVoUtil.success(data);
  90. }
  91. public ResultVo<Patient> getPatientAll(String inpatientNo, Integer times) {
  92. Patient data = dao.getPatientInfo(inpatientNo, "view_zy_patient_all", times);
  93. if (null == data) {
  94. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有住院号【" + inpatientNo + "】住院业务!");
  95. }
  96. setExpenseInformation(data);
  97. return ResultVoUtil.success(data);
  98. }
  99. public Patient getPatientBaseInfo(String inpatientNo, Integer times, String inOutStatusFlag) {
  100. Patient data = dao.getPatientInfo(inpatientNo, "1".equals(inOutStatusFlag) ? "zy_inactpatient" : "zy_actpatient", times);
  101. String msg = "1".equals(inOutStatusFlag) ? "出院" : "在院";
  102. if (null == data) {
  103. throw new BizException(ExceptionEnum.LOGICAL_ERROR, "没有住院号【" + inpatientNo + "】的" + msg + "业务!");
  104. }
  105. setExpenseInformation(data);
  106. return data;
  107. }
  108. public ResultVo<JSONObject> getDrgPatInfo(Patient p) {
  109. BaseInfo bf = new BaseInfo();
  110. bf.setVisitId(p.getInpatientNo() + "_" + p.getAdmissTimes() + "_" + p.getLedgerSn())
  111. .setGend(p.getSex().toString())
  112. .setBrdy(p.getBirthDate())
  113. .setAge(p.getAge().toString())
  114. .setNwbAge("")
  115. .setNwbBirWt("")
  116. .setNwbAdmWt("")
  117. .setAdmTime(p.getAdmissDate())
  118. .setActIptDays(String.valueOf(DateUtil.daysBetween(new Date(), p.getAdmissDate())))
  119. .setTotalFee(p.getTotalCharge())
  120. .setCdntnPay("")
  121. .setIllPay("");
  122. JSONObject upload = new JSONObject();
  123. upload.put("base_info", bf);
  124. upload.put("dise_info_list", setDrgDisList(p));
  125. upload.put("oprt_info_list", setOprtInfoList(p));
  126. JSONObject res = drgWebApi.getDrgCaseQualityControlGroup(upload);
  127. if (res.getInteger("code") == 0) {
  128. if (res.getJSONObject("result") != null) {
  129. JSONArray groupInfo = res.getJSONObject("result").getJSONArray("group_info");
  130. if (groupInfo != null) {
  131. JSONObject item = groupInfo.getJSONObject(0);
  132. return ResultVoUtil.success(item);
  133. }
  134. }
  135. }
  136. return ResultVoUtil.success();
  137. }
  138. private List<DiseInfoList> setDrgDisList(Patient p) {
  139. List<DiseInfoList> list = new ArrayList<>();
  140. JSONObject emrJs = emrServer.getEmrPatientData(p.getInpatientNo(), p.getAdmissTimes());
  141. String id = p.getInpatientNo() + "_" + p.getAdmissTimes() + "_" + p.getLedgerSn();
  142. try {
  143. JSONArray disList = emrJs.getJSONArray("入院诊断");
  144. for (int i = 0; i < disList.size(); i++) {
  145. DiseInfoList temp = new DiseInfoList();
  146. JSONObject item = disList.getJSONObject(i);
  147. try {
  148. temp.setVisitId(id)
  149. .setDiagCode(item.getString("code"))
  150. .setDiagName(item.getString("name"))
  151. .setMaindiagFlag(i == 0 ? "1" : "0")
  152. .setSortNo(String.valueOf(i + 1));
  153. list.add(temp);
  154. } catch (Exception ignored) {
  155. }
  156. }
  157. } catch (Exception ignored) {
  158. }
  159. return list;
  160. }
  161. private List<OprtInfoList> setOprtInfoList(Patient p) {
  162. String id = p.getInpatientNo() + "_" + p.getAdmissTimes() + "_" + p.getLedgerSn();
  163. List<OprtInfoList> list = new ArrayList<>();
  164. JSONArray emrList = emrServer.getPatientSurgery(p.getInpatientNo(), p.getAdmissTimes());
  165. for (int i = 0; i < emrList.size(); i++) {
  166. JSONObject item = emrList.getJSONObject(i);
  167. JSONObject oprtName;
  168. try {
  169. oprtName = item.getJSONObject("手术名称");
  170. } catch (Exception e) {
  171. continue;
  172. }
  173. if (oprtName == null) {
  174. continue;
  175. }
  176. JSONArray oprtNameVals = null;
  177. try {
  178. oprtNameVals = oprtName.getJSONArray("value");
  179. } catch (Exception ignored) {
  180. }
  181. if (null == oprtNameVals) {
  182. continue;
  183. }
  184. for (int j = 0; j < oprtNameVals.size(); j++) {
  185. JSONObject opList = oprtNameVals.getJSONObject(j);
  186. OprtInfoList op = new OprtInfoList();
  187. op.setVisitId(id)
  188. .setOprnOprtType((i + j) == 0 ? "1" : "2")
  189. .setOprnOprtCode(opList.getString("code"))
  190. .setOprnOprtName(opList.getString("name"))
  191. .setSortNo(String.valueOf((i + j) + 1));
  192. list.add(op);
  193. }
  194. }
  195. return list;
  196. }
  197. /**
  198. * 设置患者费用信息
  199. *
  200. * @param data 患者数据
  201. */
  202. private void setExpenseInformation(@NotNull Patient data) {
  203. data.setMedTypeName(MedType.getName(data.getMedType()));
  204. data.setInsutypeName(Insutype.getName(data.getInsutype()));
  205. data.setPsnTypeName(PsnType.getName(data.getPsnType()));
  206. data.setPsnIdetTypeName(PsnIdetType.getName(data.getPsnIdetType()));
  207. data.setDutyNurseName(userCache.getEmployeeName(data.getDutyNurse()));
  208. HuanZheFeiYong feiYongZhanBi = yiZhuLuRuDao.feiYongXinXi(data.getInpatientNo(), data.getAdmissTimes(), data.getLedgerSn());
  209. if (feiYongZhanBi != null) {
  210. // 余额
  211. data.setBalance(feiYongZhanBi.getBalance());
  212. // 总费用
  213. data.setTotalCharge(feiYongZhanBi.getTotalCharge());
  214. // 药品 百分比
  215. data.setYp(DecimalUtil.getPercent(Double.parseDouble(feiYongZhanBi.getYp()), Double.parseDouble(feiYongZhanBi.getTotalCharge())));
  216. // 检验检查 百分比
  217. data.setJyjc(DecimalUtil.getPercent(Double.parseDouble(feiYongZhanBi.getJyjc()), Double.parseDouble(feiYongZhanBi.getTotalCharge())));
  218. // 医保 费用
  219. data.setChargeYb(feiYongZhanBi.getChargeYb());
  220. // 医保百分比
  221. data.setYb(DecimalUtil.getPercent(Double.parseDouble(feiYongZhanBi.getChargeYb()), Double.parseDouble(feiYongZhanBi.getTotalCharge())));
  222. }
  223. XinZhenYiZhu xinZhenYiZhu = yiZhuLuRuDao.queryPatientInfo(data.getInpatientNo(), data.getAdmissTimes());
  224. if (xinZhenYiZhu != null) {
  225. // 是否出纳
  226. data.setTimesBilled(xinZhenYiZhu.getTimesBilled());
  227. }
  228. if (null != data.getSocialNo() && data.getSocialNo().trim().length() == 18 && !data.getSocialNo().startsWith("K")) {
  229. try {
  230. // 根据身份证计算出生年龄
  231. data.setBirthDate(getBirthdayFromSocialNo(data.getSocialNo()));
  232. } catch (Exception e) {
  233. log.error("设置出生日期出错");
  234. }
  235. }
  236. data.setCrmName(getCrm(data.getSocialNo()));
  237. try {
  238. // 年龄
  239. data.setAge(DateUtil.calculateAge(new SimpleDateFormat("yyyy-MM-dd").parse(data.getBirthDate()), data.getAdmissDate()));
  240. } catch (Exception e) {
  241. log.error("计算年龄出错");
  242. }
  243. }
  244. private @NotNull String getCrm(String socialNo) {
  245. String chronicDiseaseTypes = dao.getCrmBySocialNo(socialNo);
  246. if (StringUtil.isBlank(chronicDiseaseTypes)) {
  247. return "";
  248. }
  249. String[] types = chronicDiseaseTypes.split(",");
  250. StringBuilder sb = new StringBuilder();
  251. for (String type : types) {
  252. sb.append(",'").append(type).append("'");
  253. }
  254. List<String> typeList = dao.getCrmTypeName(sb.substring(1));
  255. if (ListUtil.isBlank(typeList)) {
  256. return "";
  257. }
  258. return String.join(",", typeList);
  259. }
  260. private String getBirthdayFromSocialNo(String socialNo) {
  261. String birth = socialNo.substring(6, 14);
  262. String year = birth.substring(0, 4);
  263. String month = birth.substring(4, 6);
  264. String day = birth.substring(6, 8);
  265. return year + "-" + month + "-" + day;
  266. }
  267. public ResultVo<HashMap<String, Object>> getDisDiag(String inpatientNo, Integer admissTimes) {
  268. HashMap<String, Object> map = new HashMap<>(Capacity.TWO);
  269. map.put("yb", dao.getYibaoDisDiags(inpatientNo, admissTimes));
  270. map.put("bl", dao.getBingliDisDiags(inpatientNo, admissTimes));
  271. return ResultVoUtil.success(map);
  272. }
  273. public ResultVo<Map<String, Object>> getNotUploadedFees(GetFeesParam param) {
  274. Integer ledgerSn = routines.selectMaxLedgerSn(param.getPatNo(), param.getTimes());
  275. if (null == ledgerSn) {
  276. ledgerSn = 1;
  277. }
  278. IPage<NotUploadedFee> iPage = new Page<>(param.getCurrentPage(), param.getPageSize());
  279. Map<String, Object> map = new HashMap<>(Capacity.THREE);
  280. String serial1 = "00";
  281. String serial2 = "";
  282. if (param.getZdTable().equals(ZD_MEDCN)) {
  283. serial1 = "01";
  284. serial2 = "99";
  285. }
  286. if (param.getInjuryMode()) {
  287. iPage = routines.selectInjuryNotUploadedFees(iPage, param.getZdTable(), param.getPatNo(),
  288. param.getTimes(), ledgerSn, DateUtil.getTodayEndTime(), serial1, serial2);
  289. } else {
  290. iPage = param.getZdTable().equals("yp_zd_dict") ?
  291. routines.selectNotUploadedYpFees(iPage, param.getPatNo(),
  292. param.getTimes(), ledgerSn, DateUtil.getTodayEndTime(), serial1, serial2)
  293. :routines.selectNotUploadedXmFees(iPage, param.getPatNo(),
  294. param.getTimes(), ledgerSn, DateUtil.getTodayEndTime(), serial1, serial2);
  295. }
  296. map.put("totalSize", iPage.getTotal());
  297. map.put("list", iPage.getRecords());
  298. map.put("sum", routines.selectSumChargeFee(param.getPatNo(), param.getTimes(), ledgerSn,
  299. DateUtil.getTodayEndTime(), serial1, serial2));
  300. return ResultVoUtil.success(map);
  301. }
  302. public ResultVo<Map<String, Object>> getIdCardInfo(String inpatientNo, Integer admissTimes) {
  303. Patient patient = dao.getPatientInfo(inpatientNo, "zy_actpatient", 0);
  304. if (null == patient) {
  305. patient = dao.getPatientInfo(inpatientNo, "zy_inactpatient", admissTimes);
  306. }
  307. String birthDate = DateUtil.calculateBirthDateFromIdNumber(patient.getSocialNo());
  308. if (null != birthDate) {
  309. patient.setBirthDate(birthDate);
  310. }
  311. List<IdCard> idCard = dao.selectIdCard(patient.getSocialNo());
  312. if (idCard.isEmpty()) {
  313. idCard = dao.getIdCard(inpatientNo, admissTimes);
  314. if (idCard.isEmpty()) {
  315. idCard = dao.getScanFile(inpatientNo, admissTimes);
  316. }
  317. }
  318. if (idCard.isEmpty()) {
  319. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有查询到此患者的身份证或扫描件,请检查身份证号是否有误。");
  320. }
  321. Map<String, Object> map = new HashMap<>();
  322. map.put("idCard", idCard.get(0));
  323. map.put("patient", patient);
  324. return ResultVoUtil.success(map);
  325. }
  326. /**
  327. * requestType: 1 - 取消医保登记申请 2 - 出院结算申请
  328. */
  329. public ResultVo<List<ToYbkRequest>> getCancelRegisterRequests(String inpatientNo, Integer admissTimes, Integer requestType) {
  330. // settleType: 0-其他, 1-已结算未出纳, 4-已出纳, 3-中间结算
  331. Integer settleType = dao.getSettleType(inpatientNo, admissTimes);
  332. if (settleType > 1) {
  333. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者已经出纳,不可进行取消医保登记的操作。");
  334. } else {
  335. return ResultVoUtil.success(dao.getRetractRequests(inpatientNo, admissTimes, requestType));
  336. }
  337. }
  338. public ResultVo<String> submitCancelRegisterRequest(ToYbkRequest param) {
  339. param.setInputId(TokenUtil.getInstance().getTokenUserId());
  340. Integer count = dao.getRequestCount(param.getInpatientNo(),
  341. param.getAdmissTimes(), param.getRequestType());
  342. param.setInputTimes(++count);
  343. log.info("提交取消医保登记请求>>> {}", param);
  344. dao.submitNewRequest(param);
  345. return ResultVoUtil.success();
  346. }
  347. @Transactional(rollbackFor = Exception.class)
  348. public ResultVo<String> submitSiPatientYbInfo(SubmitSiPtnt param) {
  349. Patient patient = param.getPatient();
  350. patient.setStaffId(TokenUtil.getInstance().getTokenUserId());
  351. MedType medType = MedType.get(patient.getMedType());
  352. if (null == medType) {
  353. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "请选择患者的医疗类别!");
  354. }
  355. if (medType == MedType.MATERNITY_HOSPITALIZATION) {
  356. if (StringUtil.isBlank(patient.getMatnType())) {
  357. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "生育类别不能为空!");
  358. }
  359. if (StringUtil.isBlank(patient.getLatechbFlag())) {
  360. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "是否晚育不能为空!");
  361. }
  362. if (StringUtil.isBlank(patient.getPretFlag())) {
  363. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "是否早产不能为空!");
  364. }
  365. }
  366. if (medType == MedType.MATERNITY_HOSPITALIZATION || medType == MedType.SINGLE_DISEASE_HOSPITALIZATION) {
  367. if (StringUtil.isBlank(patient.getDiseCode())) {
  368. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者病种不能为空!");
  369. }
  370. }
  371. if (StringUtil.isBlank(patient.getPsnCertType())) {
  372. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "证件类型不能为空!");
  373. }
  374. if (StringUtil.isBlank(patient.getDutyNurse())) {
  375. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "责任护士不能为空!");
  376. }
  377. if (StringUtil.isBlank(patient.getReferPhysician())) {
  378. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "管床医生不能为空!");
  379. }
  380. if (StringUtil.isBlank(patient.getCountry())) {
  381. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "国籍不能为空!");
  382. }
  383. if (StringUtil.isBlank(patient.getNation())) {
  384. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "民族不能为空!");
  385. }
  386. if (StringUtil.isBlank(patient.getContactName())) {
  387. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "联系人不能为空!");
  388. }
  389. if (StringUtil.isBlank(patient.getContactRelation())) {
  390. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "联系人关系不能为空!");
  391. }
  392. if (StringUtil.isBlank(patient.getContactAddrName())) {
  393. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "联系人地址不能为空!");
  394. }
  395. if (StringUtil.isBlank(patient.getContactPhone())) {
  396. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "联系人电话不能为空!");
  397. }
  398. Integer age = patient.getAge();
  399. if (patient.getPsnCertType().equals(PsnCertType.RESIDENT_IDENTITY_CARD.getCode())) {
  400. if (!IdCardUtil.isValidatedIdCard(patient.getSocialNo())) {
  401. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "身份证不合法!");
  402. }
  403. age = IdCardUtil.getAgeByIdCard(patient.getSocialNo());
  404. patient.setSocialNo(patient.getSocialNo().toUpperCase());
  405. }
  406. if (null != age && (age < 16 || age > 60)) {
  407. if (patient.getName().equals(patient.getContactName()) ||
  408. patient.getContactRelation().equals("0")) {
  409. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "16岁以下或60岁以上的患者,联系人不能填写本人。");
  410. }
  411. }
  412. String zyh = patient.getInpatientNo();
  413. int times = patient.getAdmissTimes();
  414. for (int i = 0; i < param.getDiags().size(); i++) {
  415. ZyInYbDiag diag = param.getDiags().get(i);
  416. diag.setInpatientNo(zyh);
  417. diag.setAdmissTimes(times);
  418. }
  419. patient.setResponceType(medType.getResponceType());
  420. log.info("【操作员:{}】保存患者信息:{} ", patient.getStaffId(), param);
  421. if (dao.isBatjBa2Exist(patient.getInpatientNo(), patient.getAdmissTimes()) == 0) {
  422. dao.createBatjBa2(patient.getInpatientNo(), patient.getAdmissTimes(), patient.getDutyNurse());
  423. } else {
  424. dao.updateBatjBa2(patient.getInpatientNo(), patient.getAdmissTimes(), patient.getDutyNurse());
  425. }
  426. dao.updateZyActpatient(patient);
  427. dao.updateAPatientMi(patient);
  428. dao.deleteOldZyInYbDiag(zyh, times);
  429. if (ListUtil.notBlank(param.getDiags())) {
  430. for (ZyInYbDiag diag : param.getDiags()) {
  431. if (null == diag.getOpDate()) {
  432. diag.setOpDate(new Date());
  433. }
  434. }
  435. dao.insertNewZyInYbDiag(patient.getStaffId(), param.getDiags());
  436. }
  437. return ResultVoUtil.success();
  438. }
  439. public ResultVo<List<ZyInYbDiag>> getZyInYbDiags(String inpatientNo, int admissTimes) {
  440. return ResultVoUtil.success(dao.getZyInYbDiag(inpatientNo, admissTimes));
  441. }
  442. public ResultVo<List<ZyDisYbDiag>> getZyDisYbDiags(String inpatientNo, int admissTimes) {
  443. return ResultVoUtil.success(dao.getZyDisYbDiags(inpatientNo, admissTimes));
  444. }
  445. @Transactional(rollbackFor = Exception.class)
  446. public ResultVo<String> saveZyInYbDiags(List<ZyInYbDiag> list) {
  447. final String opId = TokenUtil.getInstance().getTokenUserId();
  448. log.info("保存医保诊断表:操作员:{},诊断:{}", opId, list);
  449. if (list == null || list.isEmpty()) {
  450. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有要保存的数据。");
  451. }
  452. final String inpatientNo = list.get(0).getInpatientNo();
  453. final Integer times = list.get(0).getAdmissTimes();
  454. dao.deleteOldZyInYbDiag(inpatientNo, times);
  455. dao.insertNewZyInYbDiag(opId, list);
  456. return ResultVoUtil.success();
  457. }
  458. @Transactional(rollbackFor = Exception.class)
  459. public ResultVo<String> saveSiZyInDiags(SaveSiZyDiags param) {
  460. param.setStaffId(TokenUtil.getInstance().getTokenUserId());
  461. log.info("保存医保诊断表:操作员:{},诊断:{}", param.getStaffId(), param);
  462. if (param.getDiags() == null || param.getDiags().isEmpty()) {
  463. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有要保存的数据。");
  464. }
  465. dao.deleteOldZyInYbDiag(param.getInpatientNo(), param.getAdmissTimes());
  466. dao.insertSiZyInYbDiag(param);
  467. return ResultVoUtil.success();
  468. }
  469. public ResultVo<String> genDismissActOrder(Patient param) {
  470. String disdate = dao.getActOrderDisDate(param.getInpatientNo(), param.getAdmissTimes());
  471. if (null != disdate) {
  472. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者【" + param.getName() + "】已经存在出院医嘱!");
  473. }
  474. String staffId = TokenUtil.getInstance().getTokenUserId();
  475. float orderNo = dao.getActOrderNo();
  476. dao.updateActorOrderNo(orderNo + 1);
  477. dao.insertNewDismissActOrder(orderNo, param.getInpatientNo(), param.getAdmissTimes(),
  478. param.getDismissOrderDate(), staffId, param.getAdmissWard());
  479. List<ZyDisYbDiag> zyDisYbDiags = dao.getDisDiags(param.getInpatientNo(), param.getAdmissTimes());
  480. if (null == zyDisYbDiags || zyDisYbDiags.isEmpty()) {
  481. List<ZyInYbDiag> inYbDiags = dao.getZyInYbDiag(param.getInpatientNo(), param.getAdmissTimes());
  482. if (null == inYbDiags || inYbDiags.isEmpty()) {
  483. CodeName diag = dao.getAdmissDiag(param.getInpatientNo(), param.getAdmissTimes());
  484. dao.insertDisDiag(param.getInpatientNo(), param.getAdmissTimes(), diag.getCode(),
  485. diag.getName(), staffId);
  486. } else {
  487. inYbDiags.forEach(itm -> {
  488. itm.setSiDiagType(1);
  489. });
  490. dao.insertDisDiags(staffId, inYbDiags);
  491. }
  492. }
  493. return ResultVoUtil.success(String.valueOf(orderNo));
  494. }
  495. public ResultVo<Patient> receiveAndRecalculateCost(Patient p) {
  496. String zyh = p.getInpatientNo();
  497. int times = p.getAdmissTimes();
  498. int infant = zyh.startsWith("$") ? 1 : 0;
  499. int ledger = p.getLedgerSn();
  500. dao.correctFeeChargeTimeBeforeAdmiss(zyh, times, p.getAdmissDate(), DateUtil.timePlusSecond(p.getAdmissDate(), 60));
  501. Date disdate = dao.selectActOrderDisDate(zyh, times);
  502. if (null != disdate) {
  503. // 如果费用发生时间小于入院时间那么就加一分钟。
  504. dao.correctFeeChargeTimeAfterDismiss(zyh, times, disdate);
  505. }
  506. dao.recountDeposit(zyh, times, ledger);
  507. dao.zyReceiveDrug(zyh, times, infant);
  508. dao.zyReceiveOne(zyh, times, infant);
  509. dao.zyCnglFyjsListYz(zyh, times);
  510. dao.updateZyDetailCharge(zyh, times, ledger);
  511. dao.zyCalcDetailAgainNew(zyh, times, ledger);
  512. dao.updateBalance(zyh, times, ledger);
  513. String balance = dao.selectLedgerBalance(zyh, times, ledger);
  514. if (StringUtil.isBlank(balance)) {
  515. balance = "0";
  516. }
  517. dao.updateZyActPatientBalance(zyh, balance);
  518. return getPatientInfo(zyh);
  519. }
  520. }