SiQueryService.java 91 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786
  1. package thyyxxk.webserver.service.medicalinsurance;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Service;
  7. import thyyxxk.webserver.config.exception.ExceptionEnum;
  8. import thyyxxk.webserver.constants.YesOrNo;
  9. import thyyxxk.webserver.constants.sidicts.*;
  10. import thyyxxk.webserver.dao.his.medicalinsurance.SiQueryDao;
  11. import thyyxxk.webserver.dao.his.medicalinsurance.SiSetlinfoDao;
  12. import thyyxxk.webserver.entity.ResultVo;
  13. import thyyxxk.webserver.entity.dictionary.PureCodeName;
  14. import thyyxxk.webserver.entity.medicalinsurance.inpatient.InHspPsnInfo;
  15. import thyyxxk.webserver.entity.medicalinsurance.outpatient.SpcChrDiseAcct;
  16. import thyyxxk.webserver.entity.medicalinsurance.query.*;
  17. import thyyxxk.webserver.entity.medicalinsurance.setlinfo.SiSetldetail;
  18. import thyyxxk.webserver.entity.medicalinsurance.setlinfo.SiSetlinfo;
  19. import thyyxxk.webserver.entity.medicalinsurance.setlinfo.TimesList;
  20. import thyyxxk.webserver.entity.medicalinsurance.setllist.*;
  21. import thyyxxk.webserver.entity.inpatient.ZyActpatient;
  22. import thyyxxk.webserver.service.redislike.RedisLikeService;
  23. import thyyxxk.webserver.service.wxapi.SendWxInfoService;
  24. import thyyxxk.webserver.utils.*;
  25. import java.math.BigDecimal;
  26. import java.time.LocalDate;
  27. import java.util.*;
  28. /**
  29. * @description: 医保查询服务
  30. * @author: DingJie
  31. * @create: 2021-06-23 16:35:23
  32. **/
  33. @Slf4j
  34. @Service
  35. public class SiQueryService {
  36. private static final String RESULT_CODE = "infcode";
  37. private static final String ERROR_MESSAGE = "err_msg";
  38. private static final String OUTPUT = "output";
  39. private final ExecService exec;
  40. private final SiQueryDao dao;
  41. private final SendWxInfoService wxsrvc;
  42. private final SiSetlinfoDao setlinfoDao;
  43. private final RedisLikeService redis;
  44. @Autowired
  45. public SiQueryService(ExecService exec, SiQueryDao dao, SendWxInfoService wxsrvc, SiSetlinfoDao setlinfoDao, RedisLikeService redis) {
  46. this.exec = exec;
  47. this.dao = dao;
  48. this.wxsrvc = wxsrvc;
  49. this.setlinfoDao = setlinfoDao;
  50. this.redis = redis;
  51. }
  52. public ResultVo<SiPatInfo> getSiPatInfo(QryPsnBsInfo qryPsnBsInfo) {
  53. SiPatInfo siPatInfo = dao.selectSiPatInfoForZy(qryPsnBsInfo.getPatNo(), qryPsnBsInfo.getTimes(), qryPsnBsInfo.getLedgerSn());
  54. if (null == siPatInfo) {
  55. siPatInfo = new SiPatInfo();
  56. }
  57. return ResultVoUtil.success(siPatInfo);
  58. }
  59. public ResultVo<String> fetchPsnNo(String socialNo, String admdvs) {
  60. if (StringUtil.isBlank(socialNo)) {
  61. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者的身份证不能为空,请补充!");
  62. }
  63. if (StringUtil.isBlank(admdvs)) {
  64. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者的参保地区不能为空,请补充!");
  65. }
  66. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.OBTAIN_BASIC_PERSON_INFO, admdvs);
  67. JSONObject data = new JSONObject();
  68. data.put("mdtrt_cert_type", MdtrtCertType.RESIDENT_IDENTITY_CARD.getCode());
  69. data.put("psn_cert_type", "01");
  70. data.put("mdtrt_cert_no", socialNo);
  71. data.put("certno", socialNo);
  72. input.getJSONObject("input").put("data", data);
  73. JSONObject result = exec.executeTrade(input, SiFunction.OBTAIN_BASIC_PERSON_INFO);
  74. log.info("【操作员:{}】,人员基本信息获取:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  75. if (null == result) {
  76. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  77. }
  78. if (null == result.getInteger(RESULT_CODE)) {
  79. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  80. }
  81. if (result.getIntValue(RESULT_CODE) == 0) {
  82. JSONObject output = result.getJSONObject(OUTPUT);
  83. JSONObject baseinfo = output.getJSONObject("baseinfo");
  84. String psnNo = baseinfo.getString("psn_no");
  85. if (StringUtil.notBlank(psnNo)) {
  86. return ResultVoUtil.success(psnNo);
  87. }
  88. }
  89. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "无法查询到患者的医保个人编码。");
  90. }
  91. public ResultVo<PsnBaseInfo> obtainBasicPersonInfo(QryPsnBsInfo qryPsnBsInfo) {
  92. if (null == qryPsnBsInfo.getOnlyQry() && StringUtil.isBlank(qryPsnBsInfo.getMedType())) {
  93. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "请选择患者的医疗类别!");
  94. }
  95. if (StringUtil.isBlank(qryPsnBsInfo.getSocialNo()) && StringUtil.notBlank(qryPsnBsInfo.getPatNo()) && qryPsnBsInfo.getPatNo().length() >= 15) {
  96. qryPsnBsInfo.setSocialNo(qryPsnBsInfo.getPatNo());
  97. }
  98. if (StringUtil.isBlank(qryPsnBsInfo.getSocialNo())) {
  99. QryPsnBsInfo qpbi = dao.selectMzSocialAndName(qryPsnBsInfo.getPatNo());
  100. if (StringUtil.isBlank(qpbi.getSocialNo())) {
  101. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "患者的身份证不能为空,请补充!");
  102. }
  103. if (null == qryPsnBsInfo.getTimes()) {
  104. qryPsnBsInfo.setTimes(qpbi.getTimes());
  105. }
  106. qryPsnBsInfo.setName(qpbi.getName());
  107. qryPsnBsInfo.setSocialNo(qpbi.getSocialNo());
  108. qryPsnBsInfo.setLedgerSn(0);
  109. }
  110. if (null != qryPsnBsInfo.getLedgerSn() && qryPsnBsInfo.getLedgerSn() != 0) {
  111. qryPsnBsInfo.setLedgerSn(dao.selectMaxLedgerSn(qryPsnBsInfo.getPatNo(), qryPsnBsInfo.getTimes()));
  112. }
  113. if (StringUtil.isBlank(qryPsnBsInfo.getStaffId())) {
  114. qryPsnBsInfo.setStaffId(TokenUtil.getTokenUserId());
  115. }
  116. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.OBTAIN_BASIC_PERSON_INFO, qryPsnBsInfo.getAdmdvs());
  117. JSONObject data = new JSONObject();
  118. if (qryPsnBsInfo.getSocialNo().length() < 15) {
  119. data.put("mdtrt_cert_type", MdtrtCertType.OTHER.getCode());
  120. data.put("psn_cert_type", PsnCertType.RESIDENCE_PERMIT_FOR_HMT.getCode());
  121. } else {
  122. data.put("mdtrt_cert_type", MdtrtCertType.RESIDENT_IDENTITY_CARD.getCode());
  123. data.put("psn_cert_type", "01");
  124. }
  125. data.put("mdtrt_cert_no", qryPsnBsInfo.getSocialNo());
  126. data.put("certno", qryPsnBsInfo.getSocialNo());
  127. if (StringUtil.notBlank(qryPsnBsInfo.getName())) {
  128. data.put("psn_name", qryPsnBsInfo.getName());
  129. }
  130. input.getJSONObject("input").put("data", data);
  131. JSONObject result = exec.executeTrade(input, SiFunction.OBTAIN_BASIC_PERSON_INFO);
  132. log.info("【操作员:{}】,人员基本信息获取:\n参数:{},\n结果:{}", qryPsnBsInfo.getStaffId(), input, result);
  133. if (null == result) {
  134. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  135. }
  136. if (null == result.getInteger(RESULT_CODE)) {
  137. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  138. }
  139. if (result.getIntValue(RESULT_CODE) == 0) {
  140. JSONObject output = result.getJSONObject(OUTPUT);
  141. JSONObject baseinfo = output.getJSONObject("baseinfo");
  142. PsnBaseInfo psnBaseinfo = JSONObject.parseObject(baseinfo.toJSONString(), PsnBaseInfo.class);
  143. psnBaseinfo.setPatNo(qryPsnBsInfo.getPatNo());
  144. psnBaseinfo.setTimes(qryPsnBsInfo.getTimes());
  145. psnBaseinfo.setLedgerSn(qryPsnBsInfo.getLedgerSn());
  146. psnBaseinfo.setMedType(qryPsnBsInfo.getMedType());
  147. psnBaseinfo.setGendName(Gend.get(psnBaseinfo.getGend()).getName());
  148. psnBaseinfo.setPsnCertTypeName(PsnCertType.get(psnBaseinfo.getPsnCertType()).getName());
  149. Naty naty = Naty.get(psnBaseinfo.getNaty());
  150. if (null != naty) {
  151. psnBaseinfo.setNatyName(naty.getName());
  152. }
  153. List<IdetInfo> idetInfos = new ArrayList<>();
  154. JSONArray idet = output.getJSONArray("idetinfo");
  155. for (int i = 0; i < idet.size(); i++) {
  156. JSONObject item = idet.getJSONObject(i);
  157. IdetInfo info = JSONObject.parseObject(item.toJSONString(), IdetInfo.class);
  158. PsnIdetType psnIdetType = PsnIdetType.get(info.getPsnIdetType());
  159. if (null != psnIdetType) {
  160. psnBaseinfo.setPsnIdetType(psnIdetType.getCode());
  161. info.setPsnIdetTypeName(psnIdetType.getName());
  162. }
  163. idetInfos.add(info);
  164. }
  165. if (StringUtil.notBlank(psnBaseinfo.getPsnIdetType())) {
  166. dao.updatePsnIdetType(psnBaseinfo.getPsnIdetType(), psnBaseinfo.getPsnNo());
  167. }
  168. psnBaseinfo.setIdetinfo(idetInfos);
  169. if (new Integer(1).equals(qryPsnBsInfo.getNeedSaving())) {
  170. dao.updateZyActpatient(psnBaseinfo);
  171. psnBaseinfo.setBalc("0");
  172. int saved = dao.selectSiZyInfoCount(qryPsnBsInfo.getPatNo(), qryPsnBsInfo.getTimes(), qryPsnBsInfo.getLedgerSn());
  173. if (saved == 0) {
  174. dao.insertSiZyInfoPsnNo(psnBaseinfo);
  175. } else {
  176. dao.updateSiZyInfoPsnNo(psnBaseinfo);
  177. }
  178. log.info("患者基本信息已更新:{}", psnBaseinfo);
  179. output.put("times", qryPsnBsInfo.getTimes());
  180. }
  181. List<InsuInfo> list = new ArrayList<>();
  182. JSONArray insuinfo = output.getJSONArray("insuinfo");
  183. for (int i = 0; i < insuinfo.size(); i++) {
  184. JSONObject item = insuinfo.getJSONObject(i);
  185. InsuInfo info = JSONObject.parseObject(item.toJSONString(), InsuInfo.class);
  186. Insutype insutype = Insutype.get(info.getInsutype());
  187. if (null != insutype) {
  188. info.setInsutypeName(insutype.getName());
  189. }
  190. PsnType psnType = PsnType.get(info.getPsnType());
  191. if (null != psnType) {
  192. info.setPsnTypeName(psnType.getName());
  193. }
  194. if (null != info.getPsnInsuStas()) {
  195. if (info.getPsnInsuStas().equals(YesOrNo.YES.getCodeStr())) {
  196. info.setPsnInsuStasName("正常参保");
  197. } else {
  198. info.setPsnInsuStasName("暂停参保");
  199. }
  200. }
  201. if (null != info.getCvlservFlag()) {
  202. if (info.getCvlservFlag().equals(YesOrNo.YES.getCodeStr())) {
  203. info.setCvlservFlagName("是");
  204. } else {
  205. info.setCvlservFlagName("否");
  206. }
  207. }
  208. info.setInsuplcAdmdvsName(redis.getRegionName(info.getInsuplcAdmdvs()));
  209. list.add(info);
  210. }
  211. psnBaseinfo.setInsuinfo(list);
  212. return ResultVoUtil.success(psnBaseinfo);
  213. }
  214. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  215. }
  216. public ResultVo<List<MedInsInfo>> obtainMedicalInstitutionInfo(String type, String fuzzyName) {
  217. JSONObject input = exec.makeTradeHeader(SiFunction.OBTAIN_MEDICAL_INSTITUTION_INFO);
  218. JSONObject medinsinfo = new JSONObject();
  219. medinsinfo.put("fixmedins_type", type);
  220. medinsinfo.put("fixmedins_name", fuzzyName);
  221. input.getJSONObject("input").put("medinsinfo", medinsinfo);
  222. JSONObject result = exec.executeTrade(input, SiFunction.OBTAIN_MEDICAL_INSTITUTION_INFO);
  223. log.info("【操作员:{}】,获取定点医药机构信息:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  224. if (null == result) {
  225. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  226. }
  227. if (null == result.getInteger(RESULT_CODE)) {
  228. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  229. }
  230. if (result.getIntValue(RESULT_CODE) == 0) {
  231. JSONArray output = result.getJSONObject(OUTPUT).getJSONArray("medinsinfo");
  232. List<MedInsInfo> list = new ArrayList<>();
  233. for (int i = 0; i < output.size(); i++) {
  234. JSONObject item = output.getJSONObject(i);
  235. MedInsInfo info = JSONObject.parseObject(item.toJSONString(), MedInsInfo.class);
  236. info.setFixmedinsAdmdvs(info.getFixmedinsCode().substring(1, 7));
  237. info.setFixmedinsAdmdvsName(redis.getRegionName(info.getFixmedinsAdmdvs()));
  238. FixmedinsType fixmedinsType = FixmedinsType.get(info.getFixmedinsType());
  239. if (null != fixmedinsType) {
  240. info.setFixmedinsTypeName(fixmedinsType.getName());
  241. }
  242. HospLv hospLv = HospLv.get(info.getHospLv());
  243. if (null != hospLv) {
  244. info.setHospLvName(hospLv.getName());
  245. }
  246. list.add(info);
  247. }
  248. return ResultVoUtil.success(list);
  249. }
  250. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  251. }
  252. public ResultVo<List<MdtrtInfo>> queryVisitInfo(BscQryPrm q) {
  253. PureCodeName codeName = dao.selectPsnNoByPatNoAndMedType(q.getPatNo(), q.getMedType());
  254. if (null == codeName) {
  255. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有找到患者该医疗类别的我院就诊记录。");
  256. }
  257. q.setPsnNo(codeName.getName());
  258. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_VISIT_INFO, codeName.getCode());
  259. String ref = JSONObject.toJSONStringWithDateFormat(q, "yyyy-MM-dd HH:mm:ss");
  260. input.getJSONObject("input").put("data", JSONObject.parseObject(ref));
  261. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_VISIT_INFO);
  262. log.info("【操作员:{}】,查询就诊信息:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  263. if (null == result) {
  264. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  265. }
  266. if (null == result.getInteger(RESULT_CODE)) {
  267. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  268. }
  269. if (result.getIntValue(RESULT_CODE) == 0) {
  270. JSONObject output = result.getJSONObject(OUTPUT);
  271. JSONArray mdts = output.getJSONArray("mdtrtinfo");
  272. List<MdtrtInfo> list = new ArrayList<>();
  273. for (int i = 0; i < mdts.size(); i++) {
  274. JSONObject item = mdts.getJSONObject(i);
  275. MdtrtInfo mdtrtInfo = JSONObject.parseObject(item.toJSONString(), MdtrtInfo.class);
  276. if (null != mdtrtInfo.getInsuOptins()) {
  277. mdtrtInfo.setInsuOptinsName(redis.getRegionName(mdtrtInfo.getInsuOptins()));
  278. }
  279. SiEnumReflectUtil.mdtrtInfoReflect(mdtrtInfo);
  280. list.add(mdtrtInfo);
  281. }
  282. return ResultVoUtil.success(list);
  283. }
  284. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  285. }
  286. public ResultVo<List<DiseInfo>> queryDiagnosisInfo(BscQryPrm q) {
  287. String admdvs = dao.selectAdmdvsByPsnNo(q.getPsnNo());
  288. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_DIAGNOSIS_INFO, admdvs);
  289. JSONObject data = new JSONObject();
  290. data.put("psn_no", q.getPsnNo());
  291. data.put("mdtrt_id", q.getMdtrtId());
  292. input.getJSONObject("input").put("data", data);
  293. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_DIAGNOSIS_INFO);
  294. log.info("【操作员:{}】,查询诊断信息:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  295. if (null == result) {
  296. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  297. }
  298. if (null == result.getInteger(RESULT_CODE)) {
  299. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  300. }
  301. if (result.getIntValue(RESULT_CODE) == 0) {
  302. JSONObject output = result.getJSONObject(OUTPUT);
  303. List<DiseInfo> list = new ArrayList<>();
  304. JSONArray diseInfos = output.getJSONArray("diseinfo");
  305. for (int i = 0; i < diseInfos.size(); i++) {
  306. JSONObject item = diseInfos.getJSONObject(i);
  307. DiseInfo diseInfo = JSONObject.parseObject(item.toJSONString(), DiseInfo.class);
  308. SiEnumReflectUtil.diseInfoReflect(diseInfo);
  309. list.add(diseInfo);
  310. }
  311. return ResultVoUtil.success(list);
  312. }
  313. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  314. }
  315. public ResultVo<SetlInfo> querySettlementInfo(BscQryPrm q) {
  316. SiPatInfo siPatInfo;
  317. if (null == q.getMdtrtId()) {
  318. if (null == q.getLedgerSn()) {
  319. q.setLedgerSn(0);
  320. }
  321. siPatInfo = dao.selectSiPatInfoForZy(q.getPatNo(), q.getTimes(), q.getLedgerSn());
  322. } else {
  323. siPatInfo = dao.selectSiPatInfoByMdtrtId(q.getMdtrtId());
  324. }
  325. if (null == siPatInfo) {
  326. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "该次就诊尚未结算,无法查询结算信息。");
  327. }
  328. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_SETTLEMENT_INFO, siPatInfo.getInsuplcAdmdvs());
  329. JSONObject data = new JSONObject();
  330. data.put("psn_no", siPatInfo.getPsnNo());
  331. data.put("setl_id", siPatInfo.getSetlId());
  332. data.put("mdtrt_id", siPatInfo.getMdtrtId());
  333. input.getJSONObject("input").put("data", data);
  334. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_SETTLEMENT_INFO);
  335. log.info("【操作员:{}】,查询结算信息:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  336. if (null == result) {
  337. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  338. }
  339. if (null == result.getInteger(RESULT_CODE)) {
  340. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  341. }
  342. if (result.getIntValue(RESULT_CODE) == 0) {
  343. JSONObject output = result.getJSONObject(OUTPUT);
  344. JSONObject obj = output.getJSONObject("setlinfo");
  345. if (null == obj) {
  346. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到该次就诊的结算明细。");
  347. }
  348. SetlInfo setlInfo = JSONObject.parseObject(obj.toJSONString(), SetlInfo.class);
  349. ClrType clrType = ClrType.get(setlInfo.getClrType());
  350. if (null != clrType) {
  351. setlInfo.setClrTypeName(clrType.getName());
  352. }
  353. MedType medType = MedType.get(setlInfo.getMedType());
  354. if (null != medType) {
  355. setlInfo.setMedTypeName(medType.getName());
  356. }
  357. Insutype insutype = Insutype.get(setlInfo.getInsutype());
  358. if (null != insutype) {
  359. setlInfo.setInsutypeName(insutype.getName());
  360. }
  361. PsnType psnType = PsnType.get(setlInfo.getPsnType());
  362. if (null != psnType) {
  363. setlInfo.setPsnTypeName(psnType.getName());
  364. }
  365. JSONArray setldetail = output.getJSONArray("setldetail");
  366. if (null != setldetail && setldetail.size() > 0) {
  367. List<SiSetldetail> list = new ArrayList<>();
  368. for (int i = 0; i < setldetail.size(); i++) {
  369. SiSetldetail setldtel = JSONObject.parseObject(setldetail.getJSONObject(i).toJSONString(), SiSetldetail.class);
  370. FundPayType fundPayType = FundPayType.get(setldtel.getFundPayType());
  371. if (null != fundPayType) {
  372. setldtel.setFundPayTypeName(fundPayType.getName());
  373. }
  374. list.add(setldtel);
  375. }
  376. setlInfo.setSetldetail(list);
  377. }
  378. return ResultVoUtil.success(setlInfo);
  379. }
  380. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  381. }
  382. public ResultVo<Map<String, Object>> queryFeeDetails(QryFeeDetl q) {
  383. SiPatInfo psninfo = dao.selectSiPatInfoByMdtrtId(q.getMdtrtId());
  384. if (null == psninfo) {
  385. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的医保登记信息。");
  386. }
  387. Map<String, Object> map = new HashMap<>();
  388. map.put("psninfo", psninfo);
  389. if (!q.getType().equals("settled")) {
  390. List<SiSetlFeeDetl> list = dao.selectTempCharge(psninfo.getPatNo(), psninfo.getTimes(), psninfo.getLedgerSn());
  391. if (null == list || list.isEmpty()) {
  392. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者没有已经上传的医保费用。");
  393. }
  394. map.put("feedtle", list);
  395. map.put("analyse", analyseFeedtle(list));
  396. return ResultVoUtil.success(map);
  397. }
  398. List<SiSetlFeeDetl> list = dao.selectFeeDetlList(psninfo.getMdtrtId(), psninfo.getPatNo(), psninfo.getTimes(), psninfo.getLedgerSn());
  399. if (list.size() > 0) {
  400. map.put("feedtle", list);
  401. map.put("analyse", analyseFeedtle(list));
  402. return ResultVoUtil.success(map);
  403. }
  404. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_FEE_DETAILS, psninfo.getInsuplcAdmdvs());
  405. JSONObject data = new JSONObject();
  406. data.put("psn_no", psninfo.getPsnNo());
  407. data.put("setl_id", psninfo.getSetlId());
  408. data.put("mdtrt_id", psninfo.getMdtrtId());
  409. input.getJSONObject("input").put("data", data);
  410. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_FEE_DETAILS);
  411. log.info("【操作员:{}】,【就诊信息查询】查询费用明细:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  412. if (null == result) {
  413. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  414. }
  415. if (null == result.getInteger(RESULT_CODE)) {
  416. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  417. }
  418. if (result.getIntValue(RESULT_CODE) == 0) {
  419. JSONArray output = result.getJSONArray(OUTPUT);
  420. if (null == output || output.size() == 0) {
  421. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到费用明细。");
  422. }
  423. for (int i = 0; i < output.size(); i++) {
  424. list.add(JSONObject.parseObject(output.getJSONObject(i).toJSONString(), SiSetlFeeDetl.class));
  425. if (list.size() == 30) {
  426. dao.insertSetlFeeDetlBatch(list);
  427. list.clear();
  428. }
  429. }
  430. if (list.size() > 0) {
  431. dao.insertSetlFeeDetlBatch(list);
  432. }
  433. list = dao.selectFeeDetlList(psninfo.getMdtrtId(), psninfo.getPatNo(), psninfo.getTimes(), psninfo.getLedgerSn());
  434. map.put("feedtle", list);
  435. map.put("analyse", analyseFeedtle(list));
  436. return ResultVoUtil.success(map);
  437. }
  438. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  439. }
  440. private Map<String, String[]> analyseFeedtle(List<SiSetlFeeDetl> fees) {
  441. Map<String, String[]> map = new HashMap<>();
  442. map.put("zhj", new String[]{"合计", "0.00", "0.00", "0.00", "0.00"});
  443. fees.forEach(itm -> {
  444. ChrgitmLv chrgitmLv = ChrgitmLv.get(itm.getChrgitmLv());
  445. if (null == chrgitmLv) {
  446. chrgitmLv = ChrgitmLv.SELF_PAY;
  447. itm.setChrgitmLvName(chrgitmLv.getName());
  448. }
  449. String[] all = map.get("zhj");
  450. sumChargeFeeByType(itm, chrgitmLv, all);
  451. if (map.containsKey(itm.getMedChrgitmType())) {
  452. String[] dtle = map.get(itm.getMedChrgitmType());
  453. sumChargeFeeByType(itm, chrgitmLv, dtle);
  454. } else {
  455. String[] dtle = new String[5];
  456. MedChrgitmType type = MedChrgitmType.get(itm.getMedChrgitmType());
  457. if (type == null) {
  458. type = MedChrgitmType.OTH;
  459. itm.setMedChrgitmType(type.getCode());
  460. }
  461. dtle[0] = type.getName();
  462. dtle[1] = itm.getDetItemFeeSumamt();
  463. switch (chrgitmLv) {
  464. case FIRST_CLASS:
  465. dtle[2] = itm.getDetItemFeeSumamt();
  466. dtle[3] = "0.00";
  467. dtle[4] = "0.00";
  468. break;
  469. case SECOND_CLASS:
  470. dtle[3] = itm.getDetItemFeeSumamt();
  471. dtle[2] = "0.00";
  472. dtle[4] = "0.00";
  473. break;
  474. case SELF_PAY:
  475. dtle[4] = itm.getDetItemFeeSumamt();
  476. dtle[3] = "0.00";
  477. dtle[2] = "0.00";
  478. break;
  479. }
  480. map.put(type.getCode(), dtle);
  481. }
  482. });
  483. String total = map.get("zhj")[1];
  484. for (Map.Entry<String, String[]> entry : map.entrySet()) {
  485. if (!entry.getKey().equals("zhj")) {
  486. String percentage = DecimalUtil.percentage(entry.getValue()[1], total);
  487. entry.getValue()[0] = entry.getValue()[0] + "(" + percentage + ")";
  488. }
  489. }
  490. return map;
  491. }
  492. private void sumChargeFeeByType(SiSetlFeeDetl itm, ChrgitmLv chrgitmLv, String[] dtle) {
  493. dtle[1] = DecimalUtil.add(dtle[1], itm.getDetItemFeeSumamt());
  494. switch (chrgitmLv) {
  495. case FIRST_CLASS:
  496. dtle[2] = DecimalUtil.add(dtle[2], itm.getDetItemFeeSumamt());
  497. break;
  498. case SECOND_CLASS:
  499. dtle[3] = DecimalUtil.add(dtle[3], itm.getDetItemFeeSumamt());
  500. break;
  501. case SELF_PAY:
  502. dtle[4] = DecimalUtil.add(dtle[4], itm.getDetItemFeeSumamt());
  503. break;
  504. }
  505. }
  506. public ResultVo<List<TrtInfo>> checkPersonTreatment(BscQryPrm q) {
  507. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.CHECK_PERSON_TREATMENT, dao.selectAdmdvs(q.getPatNo(), q.getTimes()));
  508. JSONObject data = new JSONObject();
  509. data.put("psn_no", q.getPsnNo());
  510. data.put("insutype", q.getInsutype());
  511. data.put("fixmedins_code", SiUtil.INSTITUTION_ID);
  512. data.put("med_type", q.getMedType());
  513. data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
  514. input.getJSONObject("input").put("data", data);
  515. JSONObject result = exec.executeTrade(input, SiFunction.CHECK_PERSON_TREATMENT);
  516. log.info("【操作员:{}】,人员待遇享受检查:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  517. if (null == result) {
  518. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  519. }
  520. if (null == result.getInteger(RESULT_CODE)) {
  521. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  522. }
  523. if (result.getIntValue(RESULT_CODE) == 0) {
  524. List<TrtInfo> list = new ArrayList<>();
  525. JSONObject output = result.getJSONObject(OUTPUT);
  526. JSONArray trtinfo = output.getJSONArray("trtinfo");
  527. for (int i = 0; i < trtinfo.size(); i++) {
  528. JSONObject obj = trtinfo.getJSONObject(i);
  529. TrtInfo item = JSONObject.parseObject(obj.toJSONString(), TrtInfo.class);
  530. TrtChkType trtChkType = TrtChkType.get(item.getTrtChkType());
  531. if (null != trtChkType) {
  532. item.setTrtChkTypeName(trtChkType.getName());
  533. }
  534. FundPayType fundPayType = FundPayType.get(item.getFundPayType());
  535. if (null != fundPayType) {
  536. item.setFundPayTypeName(fundPayType.getName());
  537. }
  538. if (null != item.getTrtEnjymntFlag()) {
  539. if (item.getTrtEnjymntFlag().equals(YesOrNo.YES.getCodeStr())) {
  540. item.setTrtEnjymntFlagName("是");
  541. } else {
  542. item.setTrtEnjymntFlagName("否");
  543. }
  544. }
  545. list.add(item);
  546. }
  547. return ResultVoUtil.success(list);
  548. }
  549. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  550. }
  551. public ResultVo<List<InHspPsnInfo>> queryInHospitalPatientsInfo(BscQryPrm q) {
  552. if (StringUtil.notBlank(q.getPatNo())) {
  553. String psnNo = dao.selectPsnNo(q.getPatNo());
  554. if (null == psnNo) {
  555. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【住院号/门诊号:" + q.getPatNo() + "】没有找到此患者在我院的医保在院信息,请核实。");
  556. }
  557. q.setPsnNo(psnNo);
  558. }
  559. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_IN_HOSPITAL_PATIENTS_INFO,
  560. dao.selectAdmdvsByPatNoAndPsnNo(q.getPatNo(), q.getPsnNo()));
  561. JSONObject data = new JSONObject();
  562. data.put("psn_no", q.getPsnNo());
  563. data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
  564. data.put("endtime", null == q.getEndtime() ? DateUtil.now() : DateUtil.formatDatetime(q.getEndtime()));
  565. input.getJSONObject("input").put("data", data);
  566. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_IN_HOSPITAL_PATIENTS_INFO);
  567. log.info("【操作员:{}】,在院信息查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  568. if (null == result) {
  569. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  570. }
  571. if (null == result.getInteger(RESULT_CODE)) {
  572. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  573. }
  574. if (result.getIntValue(RESULT_CODE) == 0) {
  575. JSONObject output = result.getJSONObject(OUTPUT);
  576. JSONArray pts = output.getJSONArray("data");
  577. if (pts.size() == 0) {
  578. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到医保在院的患者信息。");
  579. }
  580. List<InHspPsnInfo> list = new ArrayList<>();
  581. for (int i = 0; i < pts.size(); i++) {
  582. JSONObject item = pts.getJSONObject(i);
  583. InHspPsnInfo inHspPsnInfo = JSONObject.parseObject(item.toJSONString(), InHspPsnInfo.class);
  584. SiEnumReflectUtil.inHspPsnInfoReflect(inHspPsnInfo);
  585. list.add(inHspPsnInfo);
  586. }
  587. if (list.size() == 1 && null != q.getTimes()) {
  588. InHspPsnInfo info = list.get(0);
  589. dao.updateInhospInfo(q.getPatNo(), q.getTimes(), q.getLedgerSn(), info.getMdtrtId(), info.getInsutype());
  590. }
  591. return ResultVoUtil.success(list);
  592. }
  593. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  594. }
  595. public ResultVo<List<RefMedin>> queryPersonnelTransferHospitalInfo(BscQryPrm q) {
  596. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_TRANSFER_HOSPITAL_INFO, dao.selectAdmdvsByPatNoAndPsnNo(q.getPatNo(), q.getPsnNo()));
  597. JSONObject data = new JSONObject();
  598. data.put("psn_no", q.getPsnNo());
  599. data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
  600. data.put("endtime", DateUtil.formatDatetime(q.getEndtime()));
  601. input.getJSONObject("input").put("data", data);
  602. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_TRANSFER_HOSPITAL_INFO);
  603. log.info("【操作员:{}】,转院信息查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  604. if (null == result) {
  605. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  606. }
  607. if (null == result.getInteger(RESULT_CODE)) {
  608. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  609. }
  610. if (result.getIntValue(RESULT_CODE) == 0) {
  611. JSONObject output = result.getJSONObject(OUTPUT);
  612. JSONArray array = output.getJSONArray("refmedin");
  613. if (null == array || array.size() == 0) {
  614. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到符合条件的转院信息。");
  615. }
  616. List<RefMedin> list = new ArrayList<>();
  617. for (int i = 0; i < array.size(); i++) {
  618. JSONObject obj = array.getJSONObject(i);
  619. RefMedin item = JSONObject.parseObject(obj.toJSONString(), RefMedin.class);
  620. Insutype insutype = Insutype.get(item.getInsutype());
  621. if (null != insutype) {
  622. item.setInsutypeName(insutype.getName());
  623. }
  624. DclaSouc dclaSouc = DclaSouc.get(item.getDclaSouc());
  625. if (null != dclaSouc) {
  626. item.setDclaSoucName(dclaSouc.getName());
  627. }
  628. PsnCertType psnCertType = PsnCertType.get(item.getPsnCertType());
  629. if (null != psnCertType) {
  630. item.setPsnCertTypeName(psnCertType.getName());
  631. }
  632. item.setGendName(Gend.get(item.getGend()).getName());
  633. if (null != item.getInsuOptins()) {
  634. item.setInsuOptinsName(redis.getRegionName(item.getInsuOptins()));
  635. }
  636. if (null != item.getOutFlag()) {
  637. if (item.getOutFlag().equals(YesOrNo.YES.getCodeStr())) {
  638. item.setOutFlagName("是");
  639. } else {
  640. item.setOutFlagName("否");
  641. }
  642. }
  643. if (null != item.getHospAgreReflFlag()) {
  644. if (item.getHospAgreReflFlag().equals(YesOrNo.YES.getCodeStr())) {
  645. item.setHospAgreReflFlagName("是");
  646. } else {
  647. item.setHospAgreReflFlagName("否");
  648. }
  649. }
  650. list.add(item);
  651. }
  652. return ResultVoUtil.success(list);
  653. }
  654. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  655. }
  656. public ResultVo<List<MedUseRcd>> querySpecialChronicDiseasesMedicalRecord(BscQryPrm q) {
  657. if (null == q.getPsnNo()) {
  658. String psnNo = dao.selectPsnNo(q.getPatNo());
  659. if (null == psnNo) {
  660. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【住院号/门诊号:" + q.getPatNo() + "】未找到此患者的医保参保信息,请核实。");
  661. }
  662. q.setPsnNo(psnNo);
  663. }
  664. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_MEDICAL_RECORD, dao.selectAdmdvsByPsnNo(q.getPsnNo()));
  665. JSONObject data = new JSONObject();
  666. data.put("psn_no", q.getPsnNo());
  667. data.put("begntime", DateUtil.formatDatetime(q.getBegntime()));
  668. data.put("endtime", DateUtil.formatDatetime(q.getEndtime()));
  669. input.getJSONObject("input").put("data", data);
  670. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_MEDICAL_RECORD);
  671. log.info("【操作员:{}】,人员慢特病用药记录查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  672. if (null == result) {
  673. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  674. }
  675. if (null == result.getInteger(RESULT_CODE)) {
  676. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  677. }
  678. if (result.getIntValue(RESULT_CODE) == 0) {
  679. JSONObject output = result.getJSONObject(OUTPUT);
  680. JSONArray array = output.getJSONArray("feedetail");
  681. if (null == array || array.size() == 0) {
  682. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到此人的慢特病用药记录。");
  683. }
  684. List<MedUseRcd> list = new ArrayList<>();
  685. for (int i = 0; i < array.size(); i++) {
  686. JSONObject obj = array.getJSONObject(i);
  687. MedUseRcd item = JSONObject.parseObject(obj.toJSONString(), MedUseRcd.class);
  688. list.add(item);
  689. }
  690. return ResultVoUtil.success(list);
  691. }
  692. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  693. }
  694. public ResultVo<List<CumInfo>> queryPersonnelCumulativeInfo(BscQryPrm q) {
  695. String admdvs = q.getAdmdvs();
  696. if (StringUtil.isBlank(admdvs)) {
  697. admdvs = dao.selectAdmdvsByPsnNo(q.getPsnNo());
  698. }
  699. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO, admdvs);
  700. JSONObject data = new JSONObject();
  701. data.put("psn_no", q.getPsnNo());
  702. data.put("cum_ym", q.getCumYm());
  703. input.getJSONObject("input").put("data", data);
  704. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO);
  705. log.info("【操作员:{}】,人员累计信息查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  706. if (null == result) {
  707. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  708. }
  709. if (null == result.getInteger(RESULT_CODE)) {
  710. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  711. }
  712. if (result.getIntValue(RESULT_CODE) == 0) {
  713. JSONObject output = result.getJSONObject(OUTPUT);
  714. JSONArray array = output.getJSONArray("cuminfo");
  715. List<CumInfo> list = new ArrayList<>();
  716. for (int i = 0; i < array.size(); i++) {
  717. JSONObject obj = array.getJSONObject(i);
  718. CumInfo item = JSONObject.parseObject(obj.toJSONString(), CumInfo.class);
  719. Insutype insutype = Insutype.get(item.getInsutype());
  720. if (null != insutype) {
  721. item.setInsutypeName(insutype.getName());
  722. }
  723. list.add(item);
  724. }
  725. return ResultVoUtil.success(list);
  726. }
  727. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  728. }
  729. public ResultVo<List<SpcChrDiseAcct>> querySpecialChronicDiseasesAccreditation(BscQryPrm q) {
  730. if (null == q.getPsnNo()) {
  731. String psnNo = dao.selectPsnNo(q.getPatNo());
  732. if (null == psnNo) {
  733. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "【住院号/门诊号:" + q.getPatNo() + "】未找到此患者的医保参保信息,请核实。");
  734. }
  735. q.setPsnNo(psnNo);
  736. }
  737. if (StringUtil.isBlank(q.getAdmdvs())) {
  738. String admdvs = StringUtil.isBlank(q.getPatNo()) ? dao.selectAdmdvsByPsnNo(q.getPsnNo()) : dao.selectAdmdvsByPatNo(q.getPatNo());
  739. q.setAdmdvs(admdvs);
  740. }
  741. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_ACCREDITATION, q.getAdmdvs());
  742. JSONObject data = new JSONObject();
  743. data.put("psn_no", q.getPsnNo());
  744. input.getJSONObject("input").put("data", data);
  745. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_SPECIAL_CHRONIC_DISEASES_ACCREDITATION);
  746. log.info("【操作员:{}】,人员慢特病备案查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  747. if (null == result) {
  748. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  749. }
  750. if (null == result.getInteger(RESULT_CODE)) {
  751. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  752. }
  753. if (result.getIntValue(RESULT_CODE) == 0) {
  754. JSONObject output = result.getJSONObject(OUTPUT);
  755. JSONArray details = output.getJSONArray("feedetail");
  756. if (null == details || details.size() == 0) {
  757. return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "没有查询到此患者的慢特病备案信息。");
  758. }
  759. List<SpcChrDiseAcct> list = new ArrayList<>();
  760. Date now = new Date();
  761. for (int i = 0; i < details.size(); i++) {
  762. JSONObject detail = details.getJSONObject(i);
  763. SpcChrDiseAcct spcChrDiseAcct = JSONObject.parseObject(detail.toJSONString(), SpcChrDiseAcct.class);
  764. if (null != q.getNeedAllRcd() && 1 == q.getNeedAllRcd()) {
  765. list.add(spcChrDiseAcct);
  766. } else {
  767. if (now.before(spcChrDiseAcct.getEnddate())) {
  768. spcChrDiseAcct.setPatNo(q.getPatNo());
  769. spcChrDiseAcct.setTimes(q.getTimes());
  770. list.add(spcChrDiseAcct);
  771. }
  772. }
  773. }
  774. if (list.size() > 0) {
  775. return ResultVoUtil.success(list);
  776. }
  777. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "此患者没有有效的慢特病备案,或慢特病备案已过期!");
  778. }
  779. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  780. }
  781. public ResultVo<List<PsnFixMedin>> queryPersonnelAssignmentInfo(BscQryPrm q) {
  782. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_ASSIGNMENT_INFO, q.getAdmdvs());
  783. JSONObject data = new JSONObject();
  784. data.put("psn_no", q.getPsnNo());
  785. data.put("biz_appy_type", q.getBizAppyType());
  786. input.getJSONObject("input").put("data", data);
  787. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_ASSIGNMENT_INFO);
  788. log.info("【操作员:{}】,人员定点信息查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  789. if (null == result) {
  790. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  791. }
  792. if (null == result.getInteger(RESULT_CODE)) {
  793. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  794. }
  795. if (result.getIntValue(RESULT_CODE) == 0) {
  796. JSONObject output = result.getJSONObject(OUTPUT);
  797. JSONArray array = output.getJSONArray("psnfixmedin");
  798. if (null == array || array.size() == 0) {
  799. return ResultVoUtil.fail(ExceptionEnum.NULL_POINTER, "没有查询到对应的点定信息。");
  800. }
  801. List<PsnFixMedin> list = new ArrayList<>();
  802. for (int i = 0; i < array.size(); i++) {
  803. JSONObject obj = array.getJSONObject(i);
  804. PsnFixMedin item = JSONObject.parseObject(obj.toJSONString(), PsnFixMedin.class);
  805. Insutype insutype = Insutype.get(item.getInsutype());
  806. if (null != insutype) {
  807. item.setInsutypeName(insutype.getName());
  808. }
  809. list.add(item);
  810. }
  811. return ResultVoUtil.success(list);
  812. }
  813. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));
  814. }
  815. public ResultVo<List<TimesList>> fetchSiTimesList(String patNo, Integer type) {
  816. List<TimesList> list = dao.fetchSiTimesList(patNo, type);
  817. if (null == list || list.isEmpty()) {
  818. return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "此患者没有有效的结算信息。");
  819. }
  820. return ResultVoUtil.success(list);
  821. }
  822. public ResultVo<String> queryInsuplcAdmdvsByMdtrtId(String mdtrtId) {
  823. return ResultVoUtil.success(dao.selectInsuplcAdmdvsByMdtrtId(mdtrtId));
  824. }
  825. public ResultVo<InptntSetlmtLst> queryInpatientSetlList(SetlIndex index) {
  826. if (null == index.getTimes() && StringUtil.isBlank(index.getLabel())) {
  827. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "结算条目不能为空!");
  828. }
  829. if (StringUtil.notBlank(index.getLabel())) {
  830. String[] arr = index.getLabel().split("_");
  831. index.setSetlId(arr[0]);
  832. index.setTimes(Integer.parseInt(arr[1]));
  833. index.setLedgerSn(Integer.parseInt(arr[2]));
  834. } else {
  835. index.setLedgerSn(0);
  836. index.setSetlId(dao.selectSetlId(index.getPatNo(), index.getTimes(), index.getLedgerSn()));
  837. }
  838. SiPatInfo siPatInfo = dao.selectSiPatInfo(index.getPatNo(), index.getTimes(), index.getLedgerSn());
  839. if (null == siPatInfo) {
  840. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息!");
  841. }
  842. CuminfoInYear cuminfo = getYearCuminfo(siPatInfo.getPsnNo(), siPatInfo.getInsuplcAdmdvs());
  843. if (cuminfo.getCode() != ExceptionEnum.SUCCESS.getCode()) {
  844. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, cuminfo.getMessage());
  845. }
  846. InptntSetlmtLst lst = dao.selectZySetlinfo(index.getSetlId(), "zy_inactpatient");
  847. if (null == lst) {
  848. lst = dao.selectZySetlinfo(index.getSetlId(), "zy_actpatient");
  849. if (null == lst) {
  850. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息!");
  851. }
  852. }
  853. lst.setInHospdays(DateUtil.daysBetween(lst.getEndtime(), lst.getBegntime()));
  854. PsnIdetType psnIdetType = PsnIdetType.get(lst.getPsnIdetType());
  855. if (null != psnIdetType) {
  856. lst.setPsnIdetTypeName(psnIdetType.getName());
  857. }
  858. Admdvs admdvs = Admdvs.get(lst.getInsuplcAdmdvs());
  859. if (null == admdvs) {
  860. lst.setInsuplcAdmdvsName(redis.getRegionName(lst.getInsuplcAdmdvs()));
  861. } else {
  862. lst.setInsuplcAdmdvsName(admdvs.getName());
  863. }
  864. lst.setFixmedinsName(SiUtil.INSTITUTION_NAME);
  865. lst.setGendName(Gend.get(lst.getGend()).getName());
  866. SiEnumReflectUtil.inptntSetlmtLstReflect(lst);
  867. ResultVo<List<SiSetlFeeDetl>> chrgrsvo = getChrgitems(lst.getPsnNo(), lst.getSetlId(), lst.getMdtrtId(), lst.getInsuplcAdmdvs());
  868. if (!chrgrsvo.getCode().equals(ExceptionEnum.SUCCESS.getCode())) {
  869. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, chrgrsvo.getMessage());
  870. }
  871. ChrgItemLvInfo chrgItemLvInfo = analyzeParticularChrgitmLv(chrgrsvo.getData());
  872. lst.setChrgItemLvInfo(chrgItemLvInfo);
  873. lst.setCuminfo(cuminfo);
  874. ResultVo<PolItemInfo> polItemRes = listPolItemCodePayInfo(lst.getPsnNo(), lst.getMdtrtId(), lst.getSetlId(), lst.getInsuplcAdmdvs());
  875. if (polItemRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
  876. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, polItemRes.getMessage());
  877. }
  878. lst.setPolItemInfo(polItemRes.getData());
  879. return ResultVoUtil.success(lst);
  880. }
  881. public ResultVo<OtptntSetlmtLst> queryOutpatientSetlList(SetlIndex index) {
  882. if (null == index.getTimes() && StringUtil.isBlank(index.getLabel())) {
  883. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "结算条目不能为空!");
  884. }
  885. if (StringUtil.notBlank(index.getLabel())) {
  886. String[] arr = index.getLabel().split("_");
  887. index.setSetlId(arr[0]);
  888. index.setTimes(Integer.parseInt(arr[1]));
  889. index.setLedgerSn(0);
  890. } else {
  891. index.setLedgerSn(0);
  892. index.setSetlId(dao.selectSetlId(index.getPatNo(), index.getTimes(), index.getLedgerSn()));
  893. }
  894. SiPatInfo siPatInfo = dao.selectSiPatInfo(index.getPatNo(), index.getTimes(), index.getLedgerSn());
  895. if (null == siPatInfo) {
  896. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息!");
  897. }
  898. CuminfoInYear cuminfo = getYearCuminfo(siPatInfo.getPsnNo(), siPatInfo.getInsuplcAdmdvs());
  899. if (cuminfo.getCode() != ExceptionEnum.SUCCESS.getCode()) {
  900. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, cuminfo.getMessage());
  901. }
  902. index.setLedgerSn(0);
  903. OtptntSetlmtLst lst = dao.selectMzSetlifo(index.getPatNo(), index.getTimes());
  904. if (null == lst) {
  905. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "没有找到此患者的结算信息!");
  906. }
  907. lst.setPsnCertTypeName(PsnCertType.get(lst.getPsnCertType()).getName());
  908. lst.setPsnIdetTypeName(PsnIdetType.getName(lst.getPsnIdetType()));
  909. Admdvs admdvs = Admdvs.get(lst.getInsuplcAdmdvs());
  910. if (null == admdvs) {
  911. lst.setInsuplcAdmdvsName(redis.getRegionName(lst.getInsuplcAdmdvs()));
  912. } else {
  913. lst.setInsuplcAdmdvsName(admdvs.getName());
  914. }
  915. SiEnumReflectUtil.outptntSetlmtLstReflect(lst);
  916. List<BrfChrgitm> chrgitms = dao.selectMzBrfChrgitms(index.getPatNo(), index.getTimes());
  917. lst.setCuminfo(cuminfo);
  918. lst.setFixmedinsName(SiUtil.INSTITUTION_NAME);
  919. Insutype insutype = Insutype.get(lst.getInsutype());
  920. if (insutype == Insutype.BASIC_MEDICAL_INSURANCE_FOR_EMPLOYEES) {
  921. ResultVo<List<SiSetlFeeDetl>> chrgrsvo = getChrgitems(lst.getPsnNo(), lst.getSetlId(), lst.getMdtrtId(), lst.getInsuplcAdmdvs());
  922. if (!chrgrsvo.getCode().equals(ExceptionEnum.SUCCESS.getCode())) {
  923. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, chrgrsvo.getMessage());
  924. }
  925. ChrgItemLvInfo chrgItemLvInfo = analyzeParticularChrgitmLv(chrgrsvo.getData());
  926. lst.setChrgItemLvInfo(chrgItemLvInfo);
  927. ResultVo<PolItemInfo> polItemRes = listPolItemCodePayInfo(lst.getPsnNo(), lst.getMdtrtId(), lst.getSetlId(), lst.getInsuplcAdmdvs());
  928. if (polItemRes.getCode() != ExceptionEnum.SUCCESS.getCode()) {
  929. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, polItemRes.getMessage());
  930. }
  931. lst.setPolItemInfo(polItemRes.getData());
  932. } else {
  933. analyzeMzChrgitm(lst, chrgitms);
  934. }
  935. return ResultVoUtil.success(lst);
  936. }
  937. private ResultVo<PolItemInfo> listPolItemCodePayInfo(String psnNo, String mdtrtId, String setlId, String insuplc) {
  938. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.LIST_POL_ITEM_CODE_PAY_INFO, insuplc);
  939. JSONObject data = new JSONObject();
  940. data.put("psn_no", psnNo);
  941. data.put("mdtrt_id", mdtrtId);
  942. data.put("setl_id", setlId);
  943. input.getJSONObject("input").put("data", data);
  944. JSONObject result = exec.executeTrade(input, SiFunction.LIST_POL_ITEM_CODE_PAY_INFO);
  945. log.info("【操作员:{}】,政策信息查询:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  946. if (null == result) {
  947. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  948. }
  949. if (null == result.getInteger("code")) {
  950. String message = result.getString("message");
  951. if (null == message) {
  952. message = result.getString(ERROR_MESSAGE);
  953. }
  954. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + message);
  955. }
  956. if (result.getIntValue("code") != 0) {
  957. String message = result.getString("message");
  958. if (null == message) {
  959. message = result.getString(ERROR_MESSAGE);
  960. }
  961. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心出错:" + message);
  962. }
  963. PolItemInfo polItemInfo = new PolItemInfo();
  964. JSONArray array = result.getJSONArray("data");
  965. BigDecimal selfPaySum = new BigDecimal(0);
  966. BigDecimal fundPaySum = new BigDecimal(0);
  967. for (int i = 0; i < array.size(); i++) {
  968. JSONObject itm = array.getJSONObject(i);
  969. BigDecimal selfPayAmt = BigDecimal.valueOf(itm.getDouble("selfPayAmt"));
  970. String selfPayProp = itm.getString("selfPayProp");
  971. BigDecimal fundPayAmt = BigDecimal.valueOf(itm.getDouble("fundPayAmt"));
  972. String fundPayProp = itm.getString("fundPayProp");
  973. BigDecimal polItemPaySum = BigDecimal.valueOf(itm.getDouble("polItemPaySum"));
  974. selfPaySum = selfPaySum.add(selfPayAmt);
  975. fundPaySum = fundPaySum.add(fundPayAmt);
  976. PolItemCode polItemCode = PolItemCode.get(itm.getString("polItemCode"));
  977. if (null == polItemCode) {
  978. String message = String.format("找到了字典缺失的政策项:%s", itm);
  979. log.info(message);
  980. wxsrvc.sendCorpWxMsg("2801", message);
  981. continue;
  982. }
  983. switch (polItemCode) {
  984. case QZF:
  985. polItemInfo.setSelfPayPsnAmt(selfPayAmt);
  986. polItemInfo.setSelfPayPsnProp(selfPayProp);
  987. polItemInfo.setSelfPayFundAmt(fundPayAmt);
  988. polItemInfo.setSelfPayFundProp(fundPayProp);
  989. polItemInfo.setSelfPaySum(polItemPaySum);
  990. break;
  991. case YLXZF:
  992. polItemInfo.setScndPrePayPsnAmt(selfPayAmt);
  993. polItemInfo.setScndPrePayPsnProp(selfPayProp);
  994. polItemInfo.setScndPrePayFundAmt(fundPayAmt);
  995. polItemInfo.setScndPrePayFundProp(fundPayProp);
  996. polItemInfo.setScndPrePaySum(polItemPaySum);
  997. break;
  998. case CXEZF:
  999. polItemInfo.setOvrlmtSelfPayPsnAmt(selfPayAmt);
  1000. polItemInfo.setOvrlmtSelfPayPsnProp(selfPayProp);
  1001. polItemInfo.setOvrlmtSelfPayFundAmt(fundPayAmt);
  1002. polItemInfo.setOvrlmtSelfPayFundProp(fundPayProp);
  1003. polItemInfo.setOvrlmtSelfPaySum(polItemPaySum);
  1004. break;
  1005. case BCYFQFBZ:
  1006. polItemInfo.setBegnlinePsnAmt(selfPayAmt);
  1007. polItemInfo.setBegnlinePsnProp(selfPayProp);
  1008. polItemInfo.setBegnlineFundAmt(fundPayAmt);
  1009. polItemInfo.setBegnlineFundProp(fundPayProp);
  1010. polItemInfo.setBegnlineSum(polItemPaySum);
  1011. break;
  1012. case TCYD:
  1013. polItemInfo.setFundFrstLvPsnAmt(selfPayAmt);
  1014. polItemInfo.setFundFrstLvPsnProp(selfPayProp);
  1015. polItemInfo.setFundFrstLvFundAmt(fundPayAmt);
  1016. polItemInfo.setFundFrstLvFundProp(fundPayProp);
  1017. polItemInfo.setFundFrstLvSum(polItemPaySum);
  1018. break;
  1019. case TCED:
  1020. polItemInfo.setFundScndLvPsnAmt(selfPayAmt);
  1021. polItemInfo.setFundScndLvPsnProp(selfPayProp);
  1022. polItemInfo.setFundScndLvFundAmt(fundPayAmt);
  1023. polItemInfo.setFundScndLvFundProp(fundPayProp);
  1024. polItemInfo.setFundScndLvSum(polItemPaySum);
  1025. break;
  1026. case TCSD:
  1027. polItemInfo.setFundThrdLvPsnAmt(selfPayAmt);
  1028. polItemInfo.setFundThrdLvPsnProp(selfPayProp);
  1029. polItemInfo.setFundThrdLvFundAmt(fundPayAmt);
  1030. polItemInfo.setFundThrdLvFundProp(fundPayProp);
  1031. polItemInfo.setFundThrdLvSum(polItemPaySum);
  1032. break;
  1033. case DEYD:
  1034. polItemInfo.setBigAmtFrstLvPsnAmt(selfPayAmt);
  1035. polItemInfo.setBigAmtFrstLvPsnProp(selfPayProp);
  1036. polItemInfo.setBigAmtFrstLvFundAmt(fundPayAmt);
  1037. polItemInfo.setBigAmtFrstLvFundProp(fundPayProp);
  1038. polItemInfo.setBigAmtFrstLvSum(polItemPaySum);
  1039. break;
  1040. case STDTCZF:
  1041. polItemInfo.setDualChannelFundPsnAmt(selfPayAmt);
  1042. polItemInfo.setDualChannelFundPsnProp(selfPayProp);
  1043. polItemInfo.setDualChannelFundFundAmt(fundPayAmt);
  1044. polItemInfo.setDualChannelFundFundProp(fundPayProp);
  1045. polItemInfo.setDualChannelFundSum(polItemPaySum);
  1046. break;
  1047. case STDDEZF:
  1048. polItemInfo.setDualChannelBigAmtPsnAmt(selfPayAmt);
  1049. polItemInfo.setDualChannelBigAmtPsnProp(selfPayProp);
  1050. polItemInfo.setDualChannelBigAmtFundAmt(fundPayAmt);
  1051. polItemInfo.setDualChannelBigAmtFundProp(fundPayProp);
  1052. polItemInfo.setDualChannelBigAmtSum(polItemPaySum);
  1053. break;
  1054. case ZWZL:
  1055. polItemInfo.setExternalSelfHandlePsnAmt(selfPayAmt);
  1056. polItemInfo.setExternalSelfHandlePsnProp(selfPayProp);
  1057. polItemInfo.setExternalSelfHandleFundAmt(fundPayAmt);
  1058. polItemInfo.setExternalSelfHandleFundProp(fundPayProp);
  1059. polItemInfo.setExternalSelfHandleSum(polItemPaySum);
  1060. break;
  1061. }
  1062. }
  1063. polItemInfo.setAllPsnAmt(selfPaySum);
  1064. polItemInfo.setAllFundAmt(fundPaySum);
  1065. polItemInfo.setAllSum(fundPaySum.add(selfPaySum));
  1066. return ResultVoUtil.success(polItemInfo);
  1067. }
  1068. private CuminfoInYear getYearCuminfo(String psnNo, String admdvs) {
  1069. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO, admdvs);
  1070. JSONObject data = new JSONObject();
  1071. data.put("psn_no", psnNo);
  1072. data.put("cum_ym", "");
  1073. input.getJSONObject("input").put("data", data);
  1074. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_PERSONNEL_CUMULATIVE_INFO);
  1075. CuminfoInYear cuminfo = new CuminfoInYear();
  1076. if (null == result) {
  1077. cuminfo.setCode(ExceptionEnum.NETWORK_ERROR.getCode());
  1078. cuminfo.setMessage(ExceptionEnum.NETWORK_ERROR.getMessage());
  1079. return cuminfo;
  1080. }
  1081. if (null == result.getInteger(RESULT_CODE)) {
  1082. cuminfo.setCode(ExceptionEnum.LOGICAL_ERROR.getCode());
  1083. cuminfo.setMessage("医保中心报错:" + result.getString("message"));
  1084. return cuminfo;
  1085. }
  1086. if (result.getIntValue(RESULT_CODE) != 0) {
  1087. cuminfo.setCode(ExceptionEnum.NETWORK_ERROR.getCode());
  1088. cuminfo.setMessage("医保中心出错:" + result.getString("message"));
  1089. return cuminfo;
  1090. }
  1091. cuminfo.setCode(ExceptionEnum.SUCCESS.getCode());
  1092. String year = String.valueOf(LocalDate.now().getYear());
  1093. JSONArray cuminfos = result.getJSONObject(OUTPUT).getJSONArray("cuminfo");
  1094. log.info("累计信息:{}", cuminfos);
  1095. for (int i = 0; i < cuminfos.size(); i++) {
  1096. JSONObject itm = cuminfos.getJSONObject(i);
  1097. if (itm.getString("year").equals(year)) {
  1098. switch (itm.getString("cum_type_code")) {
  1099. // 本年住院次数
  1100. case "C0000_BIZ2101":
  1101. case "C0000_BIZ2102":
  1102. case "C0000_BIZ2106":
  1103. case "C0000_BIZ2107":
  1104. case "C0000_BIZ22":
  1105. case "C0000_BIZ52":
  1106. cuminfo.addYearAdmtimesZy(itm.getDoubleValue("cum"));
  1107. break;
  1108. // 本年门诊次数
  1109. case "C0000_BIZ11":
  1110. case "C0000_BIZ13":
  1111. case "C0000_BIZ14":
  1112. case "C0000_BIZ51":
  1113. case "C0000_BIZ9901":
  1114. case "C0000_BIZ9903":
  1115. case "C0000_BIZ9904":
  1116. cuminfo.addYearAdmtimesMz(itm.getDoubleValue("cum"));
  1117. break;
  1118. // 本年度住院分段计算费用累计
  1119. case "S0000_BIZ2101":
  1120. case "S0000_BIZ2102":
  1121. case "S0000_BIZ2106":
  1122. case "S0000_BIZ2107":
  1123. case "S0000_BIZ22":
  1124. case "S0000_BIZ52":
  1125. cuminfo.addYearPeriodFeeSumZy(itm.getDoubleValue("cum"));
  1126. break;
  1127. // 本年度门诊分段计算费用累计
  1128. case "S0000_BIZ11":
  1129. case "S0000_BIZ13":
  1130. case "S0000_BIZ14":
  1131. case "S0000_BIZ51":
  1132. case "S0000_BIZ9901":
  1133. case "S0000_BIZ9903":
  1134. case "S0000_BIZ9904":
  1135. cuminfo.addYearPeriodFeeSumMz(itm.getDoubleValue("cum"));
  1136. break;
  1137. // 住院医疗费合计
  1138. case "F0000_BIZ2101":
  1139. case "F0000_BIZ2102":
  1140. case "F0000_BIZ2106":
  1141. case "F0000_BIZ2107":
  1142. case "F0000_BIZ22":
  1143. case "F0000_BIZ52":
  1144. cuminfo.addYearFeesumZy(itm.getDoubleValue("cum"));
  1145. break;
  1146. // 门诊医疗费合计
  1147. case "F0000_BIZ11":
  1148. case "F0000_BIZ13":
  1149. case "F0000_BIZ14":
  1150. case "F0000_BIZ51":
  1151. case "F0000_BIZ9901":
  1152. case "F0000_BIZ9903":
  1153. case "F0000_BIZ9904":
  1154. cuminfo.addYearFeesumMz(itm.getDoubleValue("cum"));
  1155. break;
  1156. // 住院已付起付线
  1157. case "Q0000_BIZ2101":
  1158. case "Q0000_BIZ2102":
  1159. case "Q0000_BIZ2106":
  1160. case "Q0000_BIZ2107":
  1161. case "Q0000_BIZ22":
  1162. case "Q0000_BIZ52":
  1163. cuminfo.addYearPayedbegnlineZy(itm.getDoubleValue("cum"));
  1164. break;
  1165. // 门诊已付起付线
  1166. case "Q0000_BIZ11":
  1167. case "Q0000_BIZ13":
  1168. case "Q0000_BIZ14":
  1169. case "Q0000_BIZ51":
  1170. case "Q0000_BIZ9901":
  1171. case "Q0000_BIZ9903":
  1172. case "Q0000_BIZ9904":
  1173. cuminfo.addYearPayedbegnlineMz(itm.getDoubleValue("cum"));
  1174. break;
  1175. // 住院统筹支付
  1176. case "D310101_BIZ2101":
  1177. case "D310101_BIZ2102":
  1178. case "D310101_BIZ2106":
  1179. case "D310101_BIZ2107":
  1180. case "D310101_BIZ22":
  1181. case "D310101_BIZ52":
  1182. case "D390101_BIZ2101":
  1183. case "D390101_BIZ2102":
  1184. case "D390101_BIZ2106":
  1185. case "D390101_BIZ2107":
  1186. case "D390101_BIZ22":
  1187. case "D390101_BIZ52":
  1188. cuminfo.addYearFundpaysZy(itm.getDoubleValue("cum"));
  1189. break;
  1190. // 门诊统筹支付
  1191. case "D310101_BIZ11":
  1192. case "D310101_BIZ13":
  1193. case "D310101_BIZ14":
  1194. case "D310101_BIZ51":
  1195. case "D310101_BIZ9901":
  1196. case "D310101_BIZ9903":
  1197. case "D310101_BIZ9904":
  1198. case "D390101_BIZ11":
  1199. case "D390101_BIZ13":
  1200. case "D390101_BIZ14":
  1201. case "D390101_BIZ51":
  1202. case "D390101_BIZ9901":
  1203. case "D390101_BIZ9903":
  1204. case "D390101_BIZ9904":
  1205. cuminfo.addYearFundpaysMz(itm.getDoubleValue("cum"));
  1206. break;
  1207. // 住院政策自费
  1208. case "Z0000_BIZ2101_LAB101":
  1209. case "Z0000_BIZ2102_LAB101":
  1210. case "Z0000_BIZ22_LAB101":
  1211. case "Z0000_BIZ2106_LAB101":
  1212. case "Z0000_BIZ2107_LAB101":
  1213. case "Z0000_BIZ52_LAB101":
  1214. case "Z0000_BIZ2101_LAB103":
  1215. case "Z0000_BIZ2102_LAB103":
  1216. case "Z0000_BIZ22_LAB103":
  1217. case "Z0000_BIZ2106_LAB103":
  1218. case "Z0000_BIZ2107_LAB103":
  1219. case "Z0000_BIZ52_LAB103":
  1220. cuminfo.addYearPolicySelfpayZy(itm.getDoubleValue("cum"));
  1221. break;
  1222. // 住院政策自付
  1223. case "Z0000_BIZ2101_LAB102":
  1224. case "Z0000_BIZ2102_LAB102":
  1225. case "Z0000_BIZ22_LAB102":
  1226. case "Z0000_BIZ2106_LAB102":
  1227. case "Z0000_BIZ2107_LAB102":
  1228. case "Z0000_BIZ52_LAB102":
  1229. cuminfo.addYearPreSelfpayZy(itm.getDoubleValue("cum"));
  1230. break;
  1231. // 门诊政策自费
  1232. case "Z0000_BIZ11_LAB101":
  1233. case "Z0000_BIZ13_LAB101":
  1234. case "Z0000_BIZ14_LAB101":
  1235. case "Z0000_BIZ51_LAB101":
  1236. case "Z0000_BIZ9901_LAB101":
  1237. case "Z0000_BIZ9903_LAB101":
  1238. case "Z0000_BIZ9904_LAB101":
  1239. case "Z0000_BIZ11_LAB103":
  1240. case "Z0000_BIZ13_LAB103":
  1241. case "Z0000_BIZ14_LAB103":
  1242. case "Z0000_BIZ51_LAB103":
  1243. case "Z0000_BIZ9901_LAB103":
  1244. case "Z0000_BIZ9903_LAB103":
  1245. case "Z0000_BIZ9904_LAB103":
  1246. cuminfo.addYearPolicySelfpayMz(itm.getDoubleValue("cum"));
  1247. break;
  1248. // 门诊政策自付
  1249. case "Z0000_BIZ11_LAB102":
  1250. case "Z0000_BIZ13_LAB102":
  1251. case "Z0000_BIZ14_LAB102":
  1252. case "Z0000_BIZ51_LAB102":
  1253. case "Z0000_BIZ9901_LAB102":
  1254. case "Z0000_BIZ9903_LAB102":
  1255. case "Z0000_BIZ9904_LAB102":
  1256. cuminfo.addYearPreSelfpayMz(itm.getDoubleValue("cum"));
  1257. break;
  1258. // 住院大额基金支付
  1259. case "D330101_BIZ2101":
  1260. case "D330101_BIZ2102":
  1261. case "D330101_BIZ2106":
  1262. case "D330101_BIZ2107":
  1263. case "D330101_BIZ22":
  1264. case "D330101_BIZ52":
  1265. cuminfo.addYearBigAmtpaysZy(itm.getDoubleValue("cum"));
  1266. break;
  1267. // 门诊大额基金支付
  1268. case "D330101_BIZ11":
  1269. case "D330101_BIZ13":
  1270. case "D330101_BIZ14":
  1271. case "D330101_BIZ51":
  1272. case "D330101_BIZ9901":
  1273. case "D330101_BIZ9903":
  1274. case "D330101_BIZ9904":
  1275. cuminfo.addYearBigAmtpaysMz(itm.getDoubleValue("cum"));
  1276. break;
  1277. // 住院大病保险支付
  1278. case "D390201_BIZ2101":
  1279. case "D390201_BIZ2102":
  1280. case "D390201_BIZ2106":
  1281. case "D390201_BIZ2107":
  1282. case "D390201_BIZ22":
  1283. case "D390201_BIZ52":
  1284. cuminfo.addYearBigdssInspaysZy(itm.getDoubleValue("cum"));
  1285. break;
  1286. // 门诊大病保险支付
  1287. case "D390201_BIZ11":
  1288. case "D390201_BIZ13":
  1289. case "D390201_BIZ14":
  1290. case "D390201_BIZ51":
  1291. case "D390201_BIZ9901":
  1292. case "D390201_BIZ9903":
  1293. case "D390201_BIZ9904":
  1294. cuminfo.addYearBigdssInspaysMz(itm.getDoubleValue("cum"));
  1295. break;
  1296. // 住院医疗救助支付
  1297. case "D610101_BIZ2101":
  1298. case "D610101_BIZ2102":
  1299. case "D610101_BIZ2106":
  1300. case "D610101_BIZ2107":
  1301. case "D610101_BIZ22":
  1302. case "D610101_BIZ52":
  1303. cuminfo.addYearMafpaysZy(itm.getDoubleValue("cum"));
  1304. break;
  1305. // 门诊医疗救助支付
  1306. case "D610101_BIZ11":
  1307. case "D610101_BIZ13":
  1308. case "D610101_BIZ14":
  1309. case "D610101_BIZ51":
  1310. case "D610101_BIZ9901":
  1311. case "D610101_BIZ9903":
  1312. case "D610101_BIZ9904":
  1313. cuminfo.addYearMafpaysMz(itm.getDoubleValue("cum"));
  1314. break;
  1315. // 门诊个人账户支付
  1316. case "D310201_BIZ11":
  1317. case "D310201_BIZ13":
  1318. case "D310201_BIZ14":
  1319. case "D310201_BIZ51":
  1320. case "D310201_BIZ9901":
  1321. case "D310201_BIZ9903":
  1322. case "D310201_BIZ9904":
  1323. cuminfo.addYearAcctPayMz(itm.getDoubleValue("cum"));
  1324. break;
  1325. // 大病保险合规费用
  1326. case "TS390201":
  1327. cuminfo.addYearBigdssLegalFee(itm.getDoubleValue("cum"));
  1328. break;
  1329. }
  1330. }
  1331. }
  1332. return cuminfo;
  1333. }
  1334. public ResultVo<List<SiSetlFeeDetl>> getChrgitems(SiSetlinfo setlinfo) {
  1335. return getChrgitems(setlinfo.getPsnNo(), setlinfo.getSetlId(), setlinfo.getMdtrtId(), setlinfo.getInsuplcAdmdvs());
  1336. }
  1337. private ResultVo<List<SiSetlFeeDetl>> getChrgitems(String psnNo, String setlId, String mdtrtId, String admdvs) {
  1338. List<SiSetlFeeDetl> list = dao.selectAllSetlFeeDtle(mdtrtId);
  1339. if (list.size() > 0) {
  1340. return ResultVoUtil.success(list);
  1341. }
  1342. JSONObject input = exec.makeTradeHeaderWithInsureArea(SiFunction.QUERY_FEE_DETAILS, admdvs);
  1343. JSONObject data = new JSONObject();
  1344. data.put("psn_no", psnNo);
  1345. data.put("setl_id", setlId);
  1346. data.put("mdtrt_id", mdtrtId);
  1347. input.getJSONObject("input").put("data", data);
  1348. JSONObject result = exec.executeTrade(input, SiFunction.QUERY_FEE_DETAILS);
  1349. log.info("【操作员:{}】,【结算单查询】查询费用明细:\n参数:{},\n结果:{}", TokenUtil.getTokenUserId(), input, result);
  1350. if (null == result) {
  1351. return ResultVoUtil.fail(ExceptionEnum.NETWORK_ERROR);
  1352. }
  1353. if (null == result.getInteger(RESULT_CODE)) {
  1354. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保中心报错:" + result.getString("message"));
  1355. }
  1356. if (0 == result.getInteger(RESULT_CODE)) {
  1357. JSONArray output = result.getJSONArray(OUTPUT);
  1358. if (null == output || output.size() == 0) {
  1359. return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST, "没有查询到费用明细。");
  1360. }
  1361. for (int i = 0; i < output.size(); i++) {
  1362. JSONObject feeItem = output.getJSONObject(i);
  1363. String[] mzFeeDetlSn = feeItem.getString("feedetl_sn").split("_");
  1364. feeItem.replace("feedetl_sn", Integer.parseInt(mzFeeDetlSn[mzFeeDetlSn.length - 1]));
  1365. SiSetlFeeDetl fee = JSONObject.parseObject(feeItem.toJSONString(), SiSetlFeeDetl.class);
  1366. if (StringUtil.isBlank(fee.getSetlId())) {
  1367. fee.setSetlId(setlId);
  1368. }
  1369. list.add(fee);
  1370. if (list.size() == 30) {
  1371. dao.insertSetlFeeDetlBatch(list);
  1372. list.clear();
  1373. }
  1374. }
  1375. if (list.size() > 0) {
  1376. dao.insertSetlFeeDetlBatch(list);
  1377. }
  1378. return ResultVoUtil.success(dao.selectAllSetlFeeDtle(mdtrtId));
  1379. }
  1380. return ResultVoUtil.fail(ExceptionEnum.INTERNAL_SERVER_ERROR, result.getString(ERROR_MESSAGE));
  1381. }
  1382. private ChrgItemLvInfo analyzeParticularChrgitmLv(List<SiSetlFeeDetl> chrgitms) {
  1383. Map<String, BigDecimal> map = new HashMap<>();
  1384. map.put("allfeeSum", new BigDecimal(0));
  1385. map.put("totalFrst", new BigDecimal(0));
  1386. map.put("totalScnd", new BigDecimal(0));
  1387. map.put("totalThrd", new BigDecimal(0));
  1388. chrgitms.forEach(itm -> {
  1389. BigDecimal itmfeeSum = new BigDecimal(itm.getDetItemFeeSumamt());
  1390. map.replace("allfeeSum", map.get("allfeeSum").add(itmfeeSum));
  1391. if (itm.getChrgitmLv().equals(ChrgitmLv.FIRST_CLASS.getCode())) {
  1392. map.replace("totalFrst", map.get("totalFrst").add(itmfeeSum));
  1393. } else if (itm.getChrgitmLv().equals(ChrgitmLv.SECOND_CLASS.getCode())) {
  1394. map.replace("totalScnd", map.get("totalScnd").add(itmfeeSum));
  1395. } else {
  1396. map.replace("totalThrd", map.get("totalThrd").add(itmfeeSum));
  1397. }
  1398. String typeKey = itm.getMedChrgitmType();
  1399. String lvKey = typeKey + "-" + itm.getChrgitmLv();
  1400. if (map.containsKey(typeKey)) {
  1401. map.replace(typeKey, map.get(typeKey).add(itmfeeSum));
  1402. } else {
  1403. map.put(typeKey, itmfeeSum);
  1404. }
  1405. if (map.containsKey(lvKey)) {
  1406. map.replace(lvKey, map.get(lvKey).add(itmfeeSum));
  1407. } else {
  1408. map.put(lvKey, itmfeeSum);
  1409. }
  1410. });
  1411. ChrgItemLvInfo chrgItemLvInfo = new ChrgItemLvInfo();
  1412. chrgItemLvInfo.setAllfeeSum(map.get("allfeeSum"));
  1413. chrgItemLvInfo.setAllfeeFrst(map.get("totalFrst"));
  1414. chrgItemLvInfo.setAllfeeScnd(map.get("totalScnd"));
  1415. chrgItemLvInfo.setAllfeeThrd(map.get("totalThrd"));
  1416. chrgItemLvInfo.setWestMedFeeSum(map.get("09"));
  1417. chrgItemLvInfo.setWestMedFeeFrst(map.get("09-01"));
  1418. chrgItemLvInfo.setWestMedFeeScnd(map.get("09-02"));
  1419. chrgItemLvInfo.setWestMedFeeThrd(map.get("09-03"));
  1420. chrgItemLvInfo.setHerbalSum(map.get("10"));
  1421. chrgItemLvInfo.setHerbalFrst(map.get("10-01"));
  1422. chrgItemLvInfo.setHerbalScnd(map.get("10-02"));
  1423. chrgItemLvInfo.setHerbalThrd(map.get("10-03"));
  1424. chrgItemLvInfo.setChnsPtntSum(map.get("11"));
  1425. chrgItemLvInfo.setChnsPtntFrst(map.get("11-01"));
  1426. chrgItemLvInfo.setChnsPtntScnd(map.get("11-02"));
  1427. chrgItemLvInfo.setChnsPtntThrd(map.get("11-03"));
  1428. chrgItemLvInfo.setClinicSum(map.get("02"));
  1429. chrgItemLvInfo.setClinicFrst(map.get("02-01"));
  1430. chrgItemLvInfo.setClinicScnd(map.get("02-02"));
  1431. chrgItemLvInfo.setClinicThrd(map.get("02-03"));
  1432. chrgItemLvInfo.setTreatSum(map.get("05"));
  1433. chrgItemLvInfo.setTreatFrst(map.get("05-01"));
  1434. chrgItemLvInfo.setTreatScnd(map.get("05-02"));
  1435. chrgItemLvInfo.setTreatThrd(map.get("05-03"));
  1436. chrgItemLvInfo.setSurgerySum(map.get("06"));
  1437. chrgItemLvInfo.setSurgeryFrst(map.get("06-01"));
  1438. chrgItemLvInfo.setSurgeryScnd(map.get("06-02"));
  1439. chrgItemLvInfo.setSurgeryThrd(map.get("06-03"));
  1440. chrgItemLvInfo.setNursingSum(map.get("07"));
  1441. chrgItemLvInfo.setNursingFrst(map.get("07-01"));
  1442. chrgItemLvInfo.setNursingScnd(map.get("07-02"));
  1443. chrgItemLvInfo.setNursingThrd(map.get("07-03"));
  1444. chrgItemLvInfo.setSntryMtrlsSum(map.get("08"));
  1445. chrgItemLvInfo.setSntryMtrlsFrst(map.get("08-01"));
  1446. chrgItemLvInfo.setSntryMtrlsScnd(map.get("08-02"));
  1447. chrgItemLvInfo.setSntryMtrlsThrd(map.get("08-03"));
  1448. chrgItemLvInfo.setExamSum(map.get("04"));
  1449. chrgItemLvInfo.setExamFrst(map.get("04-01"));
  1450. chrgItemLvInfo.setExamScnd(map.get("04-02"));
  1451. chrgItemLvInfo.setExamThrd(map.get("04-03"));
  1452. chrgItemLvInfo.setNrmlTrtmtSum(map.get("12"));
  1453. chrgItemLvInfo.setNrmlTrtmtFrst(map.get("12-01"));
  1454. chrgItemLvInfo.setNrmlTrtmtScnd(map.get("12-02"));
  1455. chrgItemLvInfo.setNrmlTrtmtThrd(map.get("12-03"));
  1456. chrgItemLvInfo.setInspectSum(map.get("03"));
  1457. chrgItemLvInfo.setInspectFrst(map.get("03-01"));
  1458. chrgItemLvInfo.setInspectScnd(map.get("03-02"));
  1459. chrgItemLvInfo.setInspectThrd(map.get("03-03"));
  1460. chrgItemLvInfo.setRegisterSum(map.get("13"));
  1461. chrgItemLvInfo.setRegisterFrst(map.get("13-01"));
  1462. chrgItemLvInfo.setRegisterScnd(map.get("13-02"));
  1463. chrgItemLvInfo.setRegisterThrd(map.get("13-03"));
  1464. chrgItemLvInfo.setBedfeeSum(map.get("01"));
  1465. chrgItemLvInfo.setBedfeeFrst(map.get("01-01"));
  1466. chrgItemLvInfo.setBedfeeScnd(map.get("01-02"));
  1467. chrgItemLvInfo.setBedfeeThrd(map.get("01-03"));
  1468. chrgItemLvInfo.setOthfeeSum(map.get("14"));
  1469. chrgItemLvInfo.setOthfeeFrst(map.get("14-01"));
  1470. chrgItemLvInfo.setOthfeeScnd(map.get("14-02"));
  1471. chrgItemLvInfo.setOthfeeThrd(map.get("14-03"));
  1472. return chrgItemLvInfo;
  1473. }
  1474. private void analyzeMzChrgitm(OtptntSetlmtLst lst, List<BrfChrgitm> chrgitms) {
  1475. Map<String, BigDecimal> map = new HashMap<>();
  1476. map.put("allfeeSum", BigDecimal.valueOf(0));
  1477. map.put("totalThrd", BigDecimal.valueOf(0));
  1478. map.put("totalScnd", BigDecimal.valueOf(0));
  1479. map.put("othSum", BigDecimal.valueOf(0));
  1480. map.put("othThrd", BigDecimal.valueOf(0));
  1481. map.put("othScnd", BigDecimal.valueOf(0));
  1482. chrgitms.forEach(itm -> {
  1483. map.replace("allfeeSum", map.get("allfeeSum").add(BigDecimal.valueOf(itm.getChargeFee())));
  1484. if (itm.getChrgitmLv().equals(ChrgitmLv.SELF_PAY.getCode())) {
  1485. map.replace("totalThrd", map.get("totalThrd").add(BigDecimal.valueOf(itm.getChargeFee())));
  1486. } else if (itm.getChrgitmLv().equals(ChrgitmLv.SECOND_CLASS.getCode())) {
  1487. map.replace("totalScnd", map.get("totalScnd").add(BigDecimal.valueOf(itm.getChargeFee())));
  1488. }
  1489. String typeKey = itm.getMedChrgitmType();
  1490. if (!typeKey.equals("09") && !typeKey.equals("11")) {
  1491. map.replace("othSum", map.get("othSum").add(BigDecimal.valueOf(itm.getChargeFee())));
  1492. if (itm.getChrgitmLv().equals(ChrgitmLv.SELF_PAY.getCode())) {
  1493. map.replace("othThrd", map.get("othThrd").add(BigDecimal.valueOf(itm.getChargeFee())));
  1494. } else if (itm.getChrgitmLv().equals(ChrgitmLv.SECOND_CLASS.getCode())) {
  1495. map.replace("othScnd", map.get("othScnd").add(BigDecimal.valueOf(itm.getChargeFee())));
  1496. }
  1497. } else {
  1498. String lvKey = typeKey + "-" + itm.getChrgitmLv();
  1499. if (map.containsKey(typeKey)) {
  1500. map.replace(typeKey, map.get(typeKey).add(BigDecimal.valueOf(itm.getChargeFee())));
  1501. } else {
  1502. map.put(typeKey, BigDecimal.valueOf(itm.getChargeFee()));
  1503. }
  1504. if (map.containsKey(lvKey)) {
  1505. map.replace(lvKey, map.get(lvKey).add(BigDecimal.valueOf(itm.getChargeFee())));
  1506. } else {
  1507. map.put(lvKey, BigDecimal.valueOf(itm.getChargeFee()));
  1508. }
  1509. }
  1510. });
  1511. lst.setAllfeeSum(map.get("allfeeSum"));
  1512. lst.setAllfeeThrd(map.get("totalThrd"));
  1513. lst.setAllfeeScnd(map.get("totalScnd"));
  1514. lst.setWestMedFeeSum(map.get("09"));
  1515. lst.setWestMedFeeThrd(map.get("09-03"));
  1516. lst.setWestMedFeeScnd(map.get("09-02"));
  1517. lst.setChnsPtntSum(map.get("11"));
  1518. lst.setChnsPtntThrd(map.get("11-03"));
  1519. lst.setChnsPtntScnd(map.get("11-02"));
  1520. lst.setMedsrvcSum(map.get("othSum"));
  1521. lst.setMedsrvcThrd(map.get("othThrd"));
  1522. lst.setMedsrvcScnd(map.get("othScnd"));
  1523. }
  1524. public ResultVo<List<SiMzMatnDise>> queryMzMatnDises() {
  1525. return ResultVoUtil.success(dao.selectAllMzMatnDises());
  1526. }
  1527. public ResultVo<List<SetlStatisticResult>> selectSetlinfoStatistics(SetlCondition condition) {
  1528. String begntime = condition.getMonth() + "-01 00:00:00.000";
  1529. String endtime = DateUtil.getMonthEndtime(condition.getMonth());
  1530. String insutype = condition.getInsutype();
  1531. if (StringUtil.isBlank(insutype)) {
  1532. insutype = "%%";
  1533. }
  1534. List<BaseSetlStatistics> baseStatistics;
  1535. switch (condition.getAdmdvsType()) {
  1536. case 1:
  1537. baseStatistics = dao.selectBaseSetlStatisticsInProvinceLevel(begntime, endtime, insutype, condition.getSetlType());
  1538. break;
  1539. case 2:
  1540. baseStatistics = dao.selectBaseSetlStatisticsInChangshaCity(begntime, endtime, insutype, condition.getSetlType());
  1541. break;
  1542. case 3:
  1543. baseStatistics = dao.selectBaseSetlStatisticsInProvinceOtherCities(begntime, endtime, insutype, condition.getSetlType());
  1544. break;
  1545. case 4:
  1546. baseStatistics = dao.selectBaseSetlStatisticsOutProvince(begntime, endtime, insutype, condition.getSetlType());
  1547. break;
  1548. case 5:
  1549. baseStatistics = dao.selectBaseSetlStatisticsInChangshaCounty(begntime, endtime, insutype, condition.getSetlType());
  1550. break;
  1551. case 6:
  1552. baseStatistics = dao.selectBaseSetlStatisticsInLiuYangCity(begntime, endtime, insutype, condition.getSetlType());
  1553. break;
  1554. default:
  1555. baseStatistics = dao.selectBaseSetlStatisticsInAllPlaces(begntime, endtime, insutype, condition.getSetlType());
  1556. break;
  1557. }
  1558. if (null == baseStatistics || baseStatistics.isEmpty()) {
  1559. return ResultVoUtil.fail(ExceptionEnum.NO_DATA_EXIST);
  1560. }
  1561. Map<String, String> regionMap = new HashMap<>();
  1562. Map<String, List<BaseSetlStatistics>> admdvsSetldataMap = new HashMap<>();
  1563. List<BaseSetlStatistics> shangChuanJieSuanDan = new ArrayList<>();
  1564. baseStatistics.forEach(itm -> {
  1565. itm.setInsutypeName(Insutype.getName(itm.getInsutype()));
  1566. if (null != itm.getHospPay()) {
  1567. itm.setFundPaySumamt(DecimalUtil.minus(itm.getFundPaySumamt(), itm.getHospPay()));
  1568. }
  1569. itm.setInsuplcAdmdvsName(redis.getRegionName(itm.getInsuplcAdmdvs()));
  1570. String key;
  1571. if (condition.getAdmdvsType() == 5 || condition.getAdmdvsType() == 6) {
  1572. key = itm.getInsuplcAdmdvs();
  1573. } else {
  1574. key = itm.getInsuplcAdmdvs().substring(0, 4) + "00";
  1575. }
  1576. String admdvsName = regionMap.get(key);
  1577. if (null == admdvsName) {
  1578. PureCodeName region = dao.selectAdmdvsNameAndParentName(key);
  1579. if (null == region) {
  1580. region = dao.selectAdmdvsName(key);
  1581. }
  1582. admdvsName = region.getCode() + region.getName();
  1583. regionMap.put(key, admdvsName);
  1584. }
  1585. if (admdvsSetldataMap.containsKey(admdvsName)) {
  1586. admdvsSetldataMap.get(admdvsName).add(itm);
  1587. } else {
  1588. List<BaseSetlStatistics> tempList = new ArrayList<>();
  1589. tempList.add(itm);
  1590. admdvsSetldataMap.put(admdvsName, tempList);
  1591. }
  1592. itm.setMedTypeName(MedType.getName(itm.getMedType()));
  1593. shangChuanJieSuanDan.add(itm);
  1594. });
  1595. List<SetlStatisticResult> resultList = new ArrayList<>();
  1596. for (Map.Entry<String, List<BaseSetlStatistics>> entry : admdvsSetldataMap.entrySet()) {
  1597. List<BaseSetlStatistics> admdvsSetldataList = entry.getValue();
  1598. SetlStatisticResult resultItem = new SetlStatisticResult();
  1599. resultItem.setAdmdvsName(entry.getKey());
  1600. resultItem.setInsuplcAdmdvs(entry.getValue().get(0).getInsuplcAdmdvs().substring(0, 4) + "00");
  1601. resultItem.setPsnSumamt(admdvsSetldataList.size());
  1602. if (StringUtil.notBlank(condition.getInsutype())) {
  1603. resultItem.setInsutype(condition.getInsutype());
  1604. resultItem.setInsutypeName(Insutype.getName(condition.getInsutype()));
  1605. resultItem.setChildKey(entry.getKey() + "-" + resultItem.getInsutypeName());
  1606. } else {
  1607. resultItem.setInsutypeName("-");
  1608. resultItem.setChildKey(entry.getKey());
  1609. }
  1610. fillSetlStatisticResult(resultList, admdvsSetldataList, resultItem);
  1611. }
  1612. if (StringUtil.isBlank(condition.getInsutype())) {
  1613. for (SetlStatisticResult resultItem : resultList) {
  1614. Map<String, List<BaseSetlStatistics>> insutypeSetldataMap = new HashMap<>();
  1615. String admdvsName = resultItem.getAdmdvsName();
  1616. List<BaseSetlStatistics> admdvsSetldataList = admdvsSetldataMap.get(admdvsName);
  1617. for (BaseSetlStatistics baseSetlStatistics : admdvsSetldataList) {
  1618. if (insutypeSetldataMap.containsKey(baseSetlStatistics.getInsutypeName())) {
  1619. insutypeSetldataMap.get(baseSetlStatistics.getInsutypeName()).add(baseSetlStatistics);
  1620. } else {
  1621. List<BaseSetlStatistics> tmpList = new ArrayList<>();
  1622. tmpList.add(baseSetlStatistics);
  1623. insutypeSetldataMap.put(baseSetlStatistics.getInsutypeName(), tmpList);
  1624. }
  1625. }
  1626. if (insutypeSetldataMap.size() == 1) {
  1627. resultItem.setInsutype(admdvsSetldataList.get(0).getInsutype());
  1628. resultItem.setInsutypeName(admdvsSetldataList.get(0).getInsutypeName());
  1629. continue;
  1630. }
  1631. List<SetlStatisticResult> children = new ArrayList<>();
  1632. for (Map.Entry<String, List<BaseSetlStatistics>> entry : insutypeSetldataMap.entrySet()) {
  1633. List<BaseSetlStatistics> insutypeSetldataList = entry.getValue();
  1634. SetlStatisticResult result = new SetlStatisticResult();
  1635. result.setAdmdvsName(resultItem.getAdmdvsName());
  1636. result.setInsuplcAdmdvs(resultItem.getInsuplcAdmdvs());
  1637. result.setPsnSumamt(insutypeSetldataList.size());
  1638. result.setInsutype(entry.getValue().get(0).getInsutype());
  1639. result.setInsutypeName(entry.getValue().get(0).getInsutypeName());
  1640. result.setChildKey(resultItem.getAdmdvsName() + "-" + result.getInsutypeName());
  1641. result.setIsChildren(true);
  1642. fillSetlStatisticResult(children, insutypeSetldataList, result);
  1643. }
  1644. resultItem.setChildren(children);
  1645. }
  1646. }
  1647. resultList.get(0).setShangChuanJieSuanDan(shangChuanJieSuanDan);
  1648. return ResultVoUtil.success(resultList);
  1649. }
  1650. private void fillSetlStatisticResult(List<SetlStatisticResult> resultList, List<BaseSetlStatistics> admdvsSetldataList, SetlStatisticResult resultItem) {
  1651. String medfeeSumamt = "0";
  1652. String baseMedFundpaySumamt = "0";
  1653. String bigDssFundpaySumamt = "0";
  1654. String clvFundpaySumamt = "0";
  1655. String acctpaySumamt = "0";
  1656. String othFundpaySumamt = "0";
  1657. String fundpaySumamt = "0";
  1658. for (BaseSetlStatistics itm : admdvsSetldataList) {
  1659. medfeeSumamt = DecimalUtil.add(medfeeSumamt, itm.getMedfeeSumamt());
  1660. baseMedFundpaySumamt = DecimalUtil.add(baseMedFundpaySumamt, itm.getHifpPay());
  1661. bigDssFundpaySumamt = DecimalUtil.add(bigDssFundpaySumamt, itm.getHifmiPay());
  1662. clvFundpaySumamt = DecimalUtil.add(clvFundpaySumamt, itm.getCvlservPay());
  1663. acctpaySumamt = DecimalUtil.add(acctpaySumamt, itm.getAcctPay());
  1664. fundpaySumamt = DecimalUtil.add(fundpaySumamt, itm.getFundPaySumamt(), itm.getAcctPay());
  1665. String othpay = DecimalUtil.minusLink(itm.getFundPaySumamt(), itm.getHifpPay(), itm.getHifmiPay(), itm.getCvlservPay());
  1666. othFundpaySumamt = DecimalUtil.add(othFundpaySumamt, othpay);
  1667. }
  1668. resultItem.setMedfeeSumamt(medfeeSumamt);
  1669. resultItem.setBaseMedFundpaySumamt(baseMedFundpaySumamt);
  1670. resultItem.setBigDssFundpaySumamt(bigDssFundpaySumamt);
  1671. resultItem.setClvFundpaySumamt(clvFundpaySumamt);
  1672. resultItem.setAcctpaySumamt(acctpaySumamt);
  1673. resultItem.setOthFundpaySumamt(othFundpaySumamt);
  1674. resultItem.setFundpaySumamt(fundpaySumamt);
  1675. resultList.add(resultItem);
  1676. }
  1677. public ResultVo<List<SiSetlinfo>> selectSetldetailStatistics(SetlCondition condition) {
  1678. String begntime = condition.getMonth() + "-01 00:00:00.000";
  1679. String endtime = DateUtil.getMonthEndtime(condition.getMonth());
  1680. String insuplcAdmdvs;
  1681. if (condition.getAdmdvsType() == 5) {
  1682. insuplcAdmdvs = "430121";
  1683. } else if (condition.getAdmdvsType() == 6) {
  1684. insuplcAdmdvs = "430181";
  1685. } else {
  1686. insuplcAdmdvs = condition.getInsuplcAdmdvs().substring(0, 4) + "%";
  1687. }
  1688. String insutype = condition.getInsutype();
  1689. if (StringUtil.isBlank(insutype)) {
  1690. insutype = "%%";
  1691. }
  1692. List<SiSetlinfo> list = setlinfoDao.selectMyList(insutype, insuplcAdmdvs, begntime, endtime);
  1693. list.forEach(item -> {
  1694. if (null != item.getHospPay()) {
  1695. log.info("hosp: {}", item.getHospPay());
  1696. item.setFundPaySumamt(DecimalUtil.minusDouble(item.getFundPaySumamt(), item.getHospPay()));
  1697. }
  1698. item.setInsuplcAdmdvsName(redis.getRegionName(item.getInsuplcAdmdvs()));
  1699. FilterUtil.filterCodeToName(item);
  1700. });
  1701. return ResultVoUtil.success(list);
  1702. }
  1703. public ResultVo<List<ZyActpatient>> weiJieSuanZaiYuanHuanZhe(String patNo, String startTime, String endTime, String name, String certno) {
  1704. List<ZyActpatient> actpatients = dao.zaiYuanHuanZheXinXi(patNo, startTime, endTime, StringUtil.isContainChinese(name), certno);
  1705. Map<String, String> insuplcAdmdvs = new HashMap<>();
  1706. for (ZyActpatient actpatient : actpatients) {
  1707. if (StringUtil.isBlank(actpatient.getInsuplcAdmdvsName())) {
  1708. String key = actpatient.getInsuplcAdmdvs().substring(0, 4) + "00";
  1709. if (insuplcAdmdvs.containsKey(key)) {
  1710. actpatient.setInsuplcAdmdvsName(insuplcAdmdvs.get(key));
  1711. } else {
  1712. String insuplcAdmdvsName = redis.getRegionName(key);
  1713. insuplcAdmdvs.put(key, insuplcAdmdvsName);
  1714. actpatient.setInsuplcAdmdvsName(insuplcAdmdvsName);
  1715. }
  1716. }
  1717. }
  1718. return ResultVoUtil.success(actpatients);
  1719. }
  1720. public ResultVo<String> checkRegisterDate(String patNo, Integer times) {
  1721. Date ledgerAccountDate = dao.selectMaxLedgerAccountDate(patNo, times);
  1722. if (null == ledgerAccountDate) {
  1723. return ResultVoUtil.success();
  1724. }
  1725. Date registerDate = dao.selectRegisterDate(patNo);
  1726. if (null == registerDate) {
  1727. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, "医保登记日期不能为空。");
  1728. }
  1729. Calendar ledgerCalendar = Calendar.getInstance();
  1730. ledgerCalendar.setTime(ledgerAccountDate);
  1731. Calendar registerCalendar = Calendar.getInstance();
  1732. registerCalendar.setTime(registerDate);
  1733. if (registerCalendar.after(ledgerCalendar)) {
  1734. return ResultVoUtil.success();
  1735. }
  1736. return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, String.format("医保登记日期【%s】不能小于断账日期【%s】,请修改。", DateUtil.formatDatetime(registerDate), DateUtil.formatDatetime(ledgerAccountDate)));
  1737. }
  1738. }