ltkj_peis.git - gitblit

			@@ -465,15 +465,22 @@
			//同步检验
			if (null != baoGaoDans && baoGaoDans.size() > 0) {
			Date dates = new Date();
			Map<String, Object> map = new HashMap<>();
			map.put("his_registration_id", order.getCardId());
			map.put("ksbm", "");
			map.put("pationid", "");
			map.put("ksrq", DateUtil.format(DateUtil.beginOfDay(order.getCreateTime()), "yyyy-MM-dd HH:mm:ss"));
			map.put("jsrq", DateUtil.format(DateUtil.endOfDay(dates), "yyyy-MM-dd HH:mm:ss"));
			map.put("pagecount", 10);
			map.put("page", 1);
			AjaxResult result = controller.Getlabreportinfo(map);
			String jytbfs = configService.selectConfigByKey("jytbfs");
			AjaxResult result;
			if (StrUtil.isBlank(jytbfs) \|\| jytbfs.equalsIgnoreCase("Y")){
			Map<String, Object> map = new HashMap<>();
			map.put("his_registration_id", order.getCardId());
			map.put("ksbm", "");
			map.put("pationid", "");
			map.put("ksrq", DateUtil.format(DateUtil.beginOfDay(order.getCreateTime()), "yyyy-MM-dd HH:mm:ss"));
			map.put("jsrq", DateUtil.format(DateUtil.endOfDay(dates), "yyyy-MM-dd HH:mm:ss"));
			map.put("pagecount", 10);
			map.put("page", 1);
			result = controller.Getlabreportinfo(map);
			}else{
			result = ltkjHysqdService.getAsyncDataByPro("体检中心", order.getCardId(), "''", 100, 1);
			}

			String result1 = getAjaxResult(result);
			JSONObject object = getJSONObject(result1);
			String code = object.getStr("ResultCode");
			@@ -505,68 +512,71 @@
			hysqd.setShrxm(jsonObject.getStr("JYYSQM"));
			hysqd.setJybgjg(jsonObject.getStr("JYBGJG"));
			if (ltkjHysqdService.save(hysqd)) {
			Map<String, Object> hashMap = new HashMap<>();
			hashMap.put("jybgid", hysqd.getTmh());
			AjaxResult bgdres = controller.Getlabdetailinfo(hashMap);
			String result2 = getAjaxResult(bgdres);
			JSONObject object1 = getJSONObject(result2);
			String code1 = object1.getStr("ResultCode");
			if (null != code1 && code1.equals("0")) {
			JSONArray datas = object1.getJSONArray("ResultData");
			for (Object o : datas) {
			JSONObject js = (JSONObject) o;
			if(StrUtil.isBlank(jytbfs) \|\| jytbfs.equalsIgnoreCase("Y")){
			Map<String, Object> hashMap = new HashMap<>();
			hashMap.put("jybgid", hysqd.getTmh());
			AjaxResult bgdres = controller.Getlabdetailinfo(hashMap);
			String result2 = getAjaxResult(bgdres);
			JSONObject object1 = getJSONObject(result2);
			String code1 = object1.getStr("ResultCode");
			if (null != code1 && code1.equals("0")) {
			JSONArray datas = object1.getJSONArray("ResultData");
			for (Object o : datas) {
			JSONObject js = (JSONObject) o;
			// ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(jsonObject.getStr("JYBGID"));
			LtkjHybgd bgd = new LtkjHybgd();
			bgd.setTmh(hysqd.getTmh());
			bgd.setJcxmid(js.getStr("JCZBDM"));
			bgd.setJcxm(js.getStr("JCZBMC"));
			bgd.setTdh(js.getStr(""));
			bgd.setJyjg(js.getStr("JCZBJG"));
			bgd.setJgdw(js.getStr("JLDW"));
			bgd.setFwzdz(js.getStr(""));
			bgd.setFwzgz(js.getStr(""));
			bgd.setFwz(js.getStr("CKZFW"));
			bgd.setJysj(js.getStr("BGRQ"));
			bgd.setJyys(js.getStr("JCRBH"));
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShys(js.getStr("SHRBH"));
			bgd.setShysmc(js.getStr("SHRXM"));
			bgd.setYcbz(js.getStr("YCTS"));
			LtkjHybgd bgd = new LtkjHybgd();
			bgd.setTmh(hysqd.getTmh());
			bgd.setJcxmid(js.getStr("JCZBDM"));
			bgd.setJcxm(js.getStr("JCZBMC"));
			bgd.setTdh(js.getStr(""));
			bgd.setJyjg(js.getStr("JCZBJG"));
			bgd.setJgdw(js.getStr("JLDW"));
			bgd.setFwzdz(js.getStr(""));
			bgd.setFwzgz(js.getStr(""));
			bgd.setFwz(js.getStr("CKZFW"));
			bgd.setJysj(js.getStr("BGRQ"));
			bgd.setJyys(js.getStr("JCRBH"));
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShys(js.getStr("SHRBH"));
			bgd.setShysmc(js.getStr("SHRXM"));
			bgd.setYcbz(js.getStr("YCTS"));
			// bgd.setTpurl(js.getStr(""));
			ltkjHybgdService.save(bgd);
			ltkjHybgdService.save(bgd);
			}
			}
			}

			Map<String, Object> fbhashMap = new HashMap<>();
			fbhashMap.put("jybgid", hysqd.getTmh());
			AjaxResult fbres = controller.Getlabgermrepinfo(fbhashMap);
			String ajaxResult = getAjaxResult(fbres);
			JSONObject fbobject = getJSONObject(ajaxResult);
			String fbcode = fbobject.getStr("ResultCode");
			if (null != fbcode && fbcode.equals("0")) {
			JSONArray datas = fbobject.getJSONArray("ResultData");
			for (Object o : datas) {
			JSONObject js = (JSONObject) o;
			LtkjHybgd bgd = new LtkjHybgd();
			bgd.setTmh(hysqd.getTmh());
			bgd.setJcxmid(hysqd.getXmid());
			bgd.setJcxm(hysqd.getXmmc());
			bgd.setTdh(js.getStr(""));
			bgd.setJyjg(js.getStr("JCJG"));
			bgd.setJgdw("/");
			bgd.setFwzdz("/");
			bgd.setFwzgz("/");
			bgd.setFwz("/");
			bgd.setJysj(js.getStr("BGRQ"));
			bgd.setJyys(hysqd.getSqrxm());
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShys(hysqd.getShrdm());
			bgd.setShysmc(hysqd.getShrxm());
			ltkjHybgdService.save(bgd);
			Map<String, Object> fbhashMap = new HashMap<>();
			fbhashMap.put("jybgid", hysqd.getTmh());
			AjaxResult fbres = controller.Getlabgermrepinfo(fbhashMap);
			String ajaxResult = getAjaxResult(fbres);
			JSONObject fbobject = getJSONObject(ajaxResult);
			String fbcode = fbobject.getStr("ResultCode");
			if (null != fbcode && fbcode.equals("0")) {
			JSONArray datas = fbobject.getJSONArray("ResultData");
			for (Object o : datas) {
			JSONObject js = (JSONObject) o;
			LtkjHybgd bgd = new LtkjHybgd();
			bgd.setTmh(hysqd.getTmh());
			bgd.setJcxmid(hysqd.getXmid());
			bgd.setJcxm(hysqd.getXmmc());
			bgd.setTdh(js.getStr(""));
			bgd.setJyjg(js.getStr("JCJG"));
			bgd.setJgdw("/");
			bgd.setFwzdz("/");
			bgd.setFwzgz("/");
			bgd.setFwz("/");
			bgd.setJysj(js.getStr("BGRQ"));
			bgd.setJyys(hysqd.getSqrxm());
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShys(hysqd.getShrdm());
			bgd.setShysmc(hysqd.getShrxm());
			ltkjHybgdService.save(bgd);
			}
			}
			}else {
			saveHybgdPro(hysqd);
			}

			}
			}
			//同步化验项目
			@@ -779,7 +789,7 @@
			map.put("page", 1);
			result = controller.Getlabreportinfo(map);
			}else {
			result = ltkjHysqdService.getAsyncDataByPro("体检中心", order.getCardId(), "''", 100, 1, "'1'");
			result = ltkjHysqdService.getAsyncDataByPro("体检中心", order.getCardId(), "''", 100, 1);
			}
			log.info("检验项目查询返回值: " + JSONUtil.toJsonStr(result));

			@@ -816,10 +826,18 @@
			List<LtkjHysqd> list = ltkjHysqdService.list(queryWrapper);
			if (list.isEmpty())
			isInsertHysqd = true;
			if (isInsertHysqd) {
			saveHysqd(hysqd);
			} else {
			saveHybgd(hysqd);
			if(StrUtil.isBlank(jytbfs) \|\| jytbfs.equalsIgnoreCase("Y")){
			if (isInsertHysqd) {
			saveHysqd(hysqd);
			} else {
			saveHybgd(hysqd);
			}
			}else {
			if (isInsertHysqd) {
			saveHysqdPro(hysqd);
			} else {
			saveHybgdPro(hysqd);
			}
			}
			}
			} else {
			@@ -946,6 +964,12 @@
			}
			}

			private void saveHysqdPro(LtkjHysqd hysqd) {
			if (ltkjHysqdService.save(hysqd)) {
			saveHybgdPro(hysqd);
			}
			}

			private void saveHybgd(LtkjHysqd hysqd) {
			Map<String, Object> hashMap = new HashMap<>();
			hashMap.put("jybgid", hysqd.getTmh());
			@@ -1017,6 +1041,60 @@
			}
			}

			private void saveHybgdPro(LtkjHysqd hysqd) {
			List<Map<String, Object>> mapList = ltkjHysqdService.getAsyncJybgdByPro(hysqd.getTmh());
			log.info("usp_his_getlabdetailinfolttj 返回->\n{}",JSONUtil.toJsonStr(mapList));
			for (Map<String, Object> map : mapList) {
			JSONObject js = JSONUtil.parseObj(map);
			LtkjHybgd bgd = new LtkjHybgd();
			bgd.setTmh(hysqd.getTmh());
			bgd.setJcxmid(js.getStr("JCZBDM"));
			bgd.setJcxm(js.getStr("JCZBMC"));
			bgd.setTdh(js.getStr(""));
			bgd.setJyjg(js.getStr("JCZBJG"));
			bgd.setJgdw(js.getStr("JLDW"));
			bgd.setFwzdz(js.getStr(""));
			bgd.setFwzgz(js.getStr(""));
			bgd.setFwz(js.getStr("CKZFW"));
			bgd.setJysj(js.getStr("BGRQ"));
			bgd.setJyys(js.getStr("JCRBH"));
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShys(js.getStr("SHRBH"));
			bgd.setShysmc(js.getStr("SHRXM"));
			bgd.setYcbz(js.getStr("YCTS"));
			bgd.setCreateTime(new Date());
			QueryWrapper<LtkjHybgd> queryWrapper = new QueryWrapper<>(bgd);
			List<LtkjHybgd> list = ltkjHybgdService.list(queryWrapper);
			if (list.isEmpty())
			ltkjHybgdService.save(bgd);
			}
			List<Map<String, Object>> mapList1 = ltkjHysqdService.getAsyncJybgdWswByPro(hysqd.getTmh());
			log.info("usp_his_getlabgermrepinfolttj 返回->\n{}",JSONUtil.toJsonStr(mapList1));
			for (Map<String, Object> map : mapList1) {
			JSONObject js = JSONUtil.parseObj(map);
			LtkjHybgd bgd = new LtkjHybgd();
			bgd.setTmh(hysqd.getTmh());
			bgd.setJcxmid(hysqd.getXmid());
			bgd.setJcxm(hysqd.getXmmc());
			bgd.setTdh(js.getStr(""));
			bgd.setJyjg(js.getStr("JCJG"));
			bgd.setJgdw("/");
			bgd.setFwzdz("/");
			bgd.setFwzgz("/");
			bgd.setFwz("/");
			bgd.setJysj(js.getStr("BGRQ"));
			bgd.setJyys(hysqd.getSqrxm());
			bgd.setShsj(js.getStr("BGRQ"));
			bgd.setShys(hysqd.getShrdm());
			bgd.setShysmc(hysqd.getShrxm());
			QueryWrapper<LtkjHybgd> queryWrapper = new QueryWrapper<>(bgd);
			List<LtkjHybgd> list = ltkjHybgdService.list(queryWrapper);
			if (list.isEmpty())
			ltkjHybgdService.save(bgd);
			}
			}

			//将方法返回值解析成json格式
			public JSONObject getJSONObject(String builder) {
			String Response = JSONUtil.parseObj(builder).getStr("Response");