ltkj_peis.git - gitblit

			@@ -320,8 +320,11 @@
			@GetMapping ("/dataSynchronization")
			@ApiOperation (value = "同步sql server数据到本地数据库数据接口")
			@RepeatSubmit
			@Transactional
			// @Transactional
			public AjaxResult dataSynchronization(@RequestParam String tjNumber) {



			//根据配置调取存储过程将临时表数据存入预约表2023.12.12
			final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData");

			@@ -377,10 +380,7 @@
			return AjaxResult.error("化验项目暂时无结果,请稍后同步!!!");
			}
			JSONArray data = object.getJSONArray("ResultData");
			// int size = data.size();
			// if(size>0){
			//
			// }

			for (Object datum : data) {
			JSONObject jsonObject = (JSONObject) datum;
			LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(order.getCardId(), jsonObject.getStr("JYBGID"));
			@@ -436,16 +436,54 @@
			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> maps = new HashMap<>();
			maps.put("his_registration_id", order.getCardId());
			maps.put("ksbm", "体检中心");
			maps.put("pagecount", 100);
			maps.put("page", 1);
			AjaxResult results = service.getHISDataNew("Getexamreportinfo", maps);
			/同步检查 his接口/

			// Map<String, Object> maps = new HashMap<>();
			// maps.put("his_registration_id", order.getCardId());
			// maps.put("ksbm", "体检中心");
			// maps.put("pagecount", 100);
			// maps.put("page", 1);
			// AjaxResult results = service.getHISDataNew("Getexamreportinfo", maps);


			/同步检查 his存储过程/
			AjaxResult results = jcsqdService.getTjJcProByHisCall("体检中心",order.getCardId(),"''",100,1,"'1'");
			DynamicDataSourceContextHolder.clearDataSourceType();


			if (Integer.parseInt(results.get("code").toString()) == 200) {
			List<Map<String, Object>> datas = (List<Map<String, Object>>) results.get("data");
			if(null !=datas && datas.size()>0){
			@@ -481,11 +519,21 @@
			if(null !=objectMap.get("YXZD") \|\| !objectMap.get("YXZD").equals(""))
			jcbgd.setYxzd(objectMap.get("YXZD").toString());

			if(null !=objectMap.get("YXBX") \|\| !objectMap.get("YXBX").equals(""))
			jcbgd.setYxbx(objectMap.get("YXBX").toString());

			if(null !=objectMap.get("YXBX") \|\| !objectMap.get("YXBX").equals("")){
			if(objectMap.get("YXBX").toString().equals("null")){
			jcbgd.setYxbx("未检异常");
			}else {
			jcbgd.setYxbx(objectMap.get("YXBX").toString());
			}
			}
			if(null !=objectMap.get("SJJLSJ") \|\| !objectMap.get("SJJLSJ").equals(""))
			jcbgd.setZdsj(objectMap.get("SJJLSJ").toString());

			if(null !=objectMap.get("JCBW") \|\| !objectMap.get("JCBW").equals(""))
			jcbgd.setJcbw(objectMap.get("JCBW").toString());

			if(null !=objectMap.get("SQRQSJ") \|\| !objectMap.get("SQRQSJ").equals(""))
			jcbgd.setSqsj(objectMap.get("SQRQSJ").toString());

			jcbgdService.save(jcbgd);
			}
			@@ -501,6 +549,7 @@
			asyncService.updateCheckType(order.getTjNumber());
			}
			return AjaxResult.success("同步成功");
			// return AjaxResult.error("化验项目暂时无结果,请稍后同步!!!");
			}
			return AjaxResult.error();
			}
			@@ -930,13 +979,15 @@
			Map<String, Object> parent = new HashMap<>();
			parent.put("checkAdvice", one.getCheckAdvice());
			parent.put("parent", remark.getProName());
			parent.put("parentId", remark.getProsId().toString());
			parent.put("parentId", remark.getProsId());
			parent.put("xmlb", remark.getXmlb());
			parent.put("", remark.getXmlb());
			List<TjOrderDetail> dels = new ArrayList<>();
			if (null != tjOrderDetails && tjOrderDetails.size() > 0) {
			for (TjOrderDetail tjOrderDetail : tjOrderDetails) {
			if (remark.getProsId().equals(tjOrderDetail.getProsId())) {
			String ckfw = tjOrderDetail.getStanId();
			if (StrUtil.isNotBlank(tjOrderDetail.getProAdvice())) {
			if (null !=ckfw && StrUtil.isNotBlank(tjOrderDetail.getProAdvice())) {
			ckfw = ckfw.replace(tjOrderDetail.getProAdvice().trim(), "");
			}
			if (StrUtil.isNotBlank(ckfw)) {
			@@ -957,10 +1008,13 @@
			} catch (NumberFormatException ignored) {
			ignored.printStackTrace();
			}
			if (null != tjOrderDetail.getYcbz() && !tjOrderDetail.getYcbz().equals("")) {
			tjOrderDetail.setProResult(tjOrderDetail.getProResult() + " [" + tjOrderDetail.getYcbz() + "]");
			}
			}else {
			tjOrderDetail.setProResult(tjOrderDetail.getProResult());
			}
			if (null != tjOrderDetail.getYcbz() && !tjOrderDetail.getYcbz().equals("")) {
			tjOrderDetail.setProResult(tjOrderDetail.getProResult() + " [" + tjOrderDetail.getYcbz() + "]");
			}

			dels.add(tjOrderDetail);
			}
			}
			@@ -976,6 +1030,7 @@
			}
			parent.put("sons", dels);
			parent.put("remark", remark.getRemark());
			parent.put("jgbx", remark.getJgbx());
			if (remark.getDoctorName() != null) {
			parent.put("doctorName", remark.getDoctorName());
			}