From aa93e512a60379c6373d10023f49dae4403b51c4 Mon Sep 17 00:00:00 2001
From: zhaowenxuan <chacca165@163.com>
Date: 星期五, 21 二月 2025 17:55:09 +0800
Subject: [PATCH] 金堆成同步字典服务
---
src/main/java/com/example/service/shanxiqin/xian/MeiJiHisService.java | 695 +++++++++++++++++++++++++++++++++++----------------------
1 files changed, 420 insertions(+), 275 deletions(-)
diff --git a/src/main/java/com/example/service/shanxiqin/xian/MeiJiHisService.java b/src/main/java/com/example/service/shanxiqin/xian/MeiJiHisService.java
index 2f44f35..5609acb 100644
--- a/src/main/java/com/example/service/shanxiqin/xian/MeiJiHisService.java
+++ b/src/main/java/com/example/service/shanxiqin/xian/MeiJiHisService.java
@@ -1,30 +1,31 @@
package com.example.service.shanxiqin.xian;
-import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSON;
+import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.example.config.ConfigValue;
-import com.example.domain.TjCustomer;
-import com.example.dto.xian.meiji.CheXiaoMzFyDto;
-import com.example.dto.xian.meiji.CreateMenZhenFyDto;
+import com.example.constant.ApiParamsConstants;
+import com.example.domain.HisSyncDict;
+import com.example.domain.TjFlowingWaterHis;
import com.example.service.HisService;
-import com.example.service.ISysConfigService;
+import com.example.service.HisSyncDictService;
+import com.example.service.TjFlowingWaterHisService;
+import com.example.utils.AjaxResult;
+import com.example.utils.FieldNameConverter;
import com.example.utils.HttpClientUtils;
+import com.example.utils.synczd.DictionaryUtilShanXiXiAnMeiJiYy;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationContext;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
-import java.io.FileInputStream;
-import java.io.IOException;
import java.time.Instant;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
+import java.util.*;
import java.util.concurrent.TimeUnit;
/**
@@ -32,31 +33,37 @@
* @Author: zhaowenxuan
* @Date: 2024/12/17 17:17
*/
+@Slf4j
@Service("ShanXiQinXiAnMeiJi")
public class MeiJiHisService implements HisService {
-// http://oapi.pbkwyy.com/OAPI/oauth/token
+ @Autowired
+ private DictionaryUtilShanXiXiAnMeiJiYy syncZd;
+ @Autowired
+ private ConfigValue configValue;
+
+// http://oapi.xamjyy.com/OAPI/oauth/token
// grant_type:client_credentials
// client_id:XFZZQEfXTZ7exhhi
// client_secret:05a192176c21edfcc9cf5fa26fc5a9e0c5b131ad
-// http://oapi.pbkwyy.com/OAPI
+// http://oapi.xamjyy.com/OAPI
@Autowired
public MeiJiHisService(ApplicationContext applicationContext, ConfigValue configValue) {
this.applicationContext = applicationContext;
this.configValue = configValue;
- HIS_URL = configValue.getConfigValue("his_api_url") + ":" + configValue.getConfigValue("his_api_port") +"/OAPI/";
+ HIS_URL = configValue.getConfigValue("ShanXi_Qin_XiAn_MeiJi.his_api_url") + ":" + configValue.getConfigValue("ShanXi_Qin_XiAn_MeiJi.his_api_port") + configValue.getConfigValue("ShanXi_Qin_XiAn_MeiJi.hisapiappend");
+ TJ_URL = configValue.getConfigValue("ShanXi_Qin_XiAn_MeiJi.tjUrl");
+ CZY = configValue.getConfigValue("ShanXi_Qin_XiAn_MeiJi.czy");
}
-
- @Autowired
- private ISysConfigService configService;
@Autowired
private RedisTemplate<Object ,Object> redisTemplate;
- private ConfigValue configValue;
private final ApplicationContext applicationContext;
private final String HIS_URL;
+ private final String TJ_URL;
+ private final String CZY;
//鑾峰彇token
private JSONObject getToken () {
@@ -69,20 +76,19 @@
map.put("client_id", CLIENT_ID);
map.put("client_secret", CLIENT_SECRET);
// map.put("scope",SCOP);
- String post = sendPost (HIS_URL+"/oauth/token", map);
+// String post = sendPostTokenFormUrlencoded (HIS_URL+"/oauth/token", map);
+ String post = HttpClientUtils.sendPostTokenFormUrlencoded(HIS_URL + "/oauth/token", map, null);
if (StrUtil.isBlank(post)) return null;
return JSONUtil.parseObj(post);
}
- //寤烘。
- public String jianDang (TjCustomer customer) {
- String czy = configService.selectConfigByKey("dfhisczybm");
-
+ @Override
+ public String jianDang(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("jiuZhenKh", customer.getPationId ());
+ map.put ("jiuZhenKh", params.get(ApiParamsConstants.CARD_ID));
map.put ("kaiLeiXing","4");
- map.put ("xingMing", customer.getCusName ());
- Long cusSex = customer.getCusSex();
+ map.put ("xingMing", params.get(ApiParamsConstants.CUS_NAME));
+ long cusSex = Long.parseLong(params.get(ApiParamsConstants.CUS_SEX).toString());
if(cusSex==0L){
map.put ("xingBie","鐢�");
}else if(cusSex==1L){
@@ -90,324 +96,338 @@
}else {
map.put ("xingBie","鏈煡");
}
- map.put ("shenFenZh", customer.getCusIdcard ());
- map.put ("danWeiBh","");
- map.put ("chuShengRq", DateUtil.format(customer.getCusBrithday(),"yyyy-MM-dd"));
- map.put ("lianXiDz", customer.getCusAddr());
- map.put ("lianXiDh", customer.getCusPhone ());
+ map.put ("shenFenZh", params.get(ApiParamsConstants.CUS_ID_CARD));
+ map.put ("danWeiBh",params.get(ApiParamsConstants.COMP_ID));
+ map.put ("chuShengRq", params.get(ApiParamsConstants.CUS_BRITHDAY));
+ map.put ("lianXiDz", params.get(ApiParamsConstants.CUS_ADDR));
+ map.put ("lianXiDh", params.get(ApiParamsConstants.CUS_PHONE));
map.put ("feiYongLb","");
map.put ("feiYongXz","");
map.put ("jiLuLy","3");
- map.put ("caoZuoYuan",czy);
+ map.put ("caoZuoYuan",CZY);
map.put ("chongZhiJe","");
map.put ("yiBaoKh","");
map.put ("geRenBh","");
map.put ("yiBaoBrXx","");
- map.put ("gongZuoDw",customer.getCompName());
+ map.put ("gongZuoDw",params.get(ApiParamsConstants.COMP_NAME));
map.put ("canBaoXzMc","");
map.put ("muLuBlLb","");
map.put ("kunNanJzDj","");
map.put ("yiLiaoLb","");
map.put ("minZuDm","");
map.put ("minZuMc","");
- //鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/menZhenJz/jianDang", map);
- }
-
- //楠岃瘉韬唤璇佹槸鍚﹀缓杩囨。
- public String getBingRenXxByShengFenZheng (TjCustomer customer) {
- String czy = configService.selectConfigByKey("dfhisczybm");
- Map<String, Object> map = new HashMap<> ();
- map.put ("caoZuoYuan",czy);
- map.put ("shenFenZh", customer.getCusIdcard ());
- map.put ("danWeiBh","");
- //鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/menZhenJz/getBingRenXxByShengFenZheng", map);
- }
-
- //鐥呬汉鍩烘湰淇℃伅鍙樻洿
- public String saveBingRenXx (TjCustomer customer) {
- String czy = configService.selectConfigByKey("dfhisczybm");
- Map<String, Object> map = new HashMap<> ();
- map.put ("jiuZhenKh", customer.getPationId ());
- map.put ("kaiLeiXing","4");
- map.put ("xingMing", customer.getCusName ());
- Long cusSex = customer.getCusSex();
- if(cusSex==0L){
- map.put ("xingBie","鐢�");
- }else if(cusSex==1L){
- map.put ("xingBie","濂�");
+// 鑱屼笟缂栫爜
+ String post = sendPost(HIS_URL + "/menZhenJz/jianDang", map);
+ JSONObject jsonObject = JSONUtil.parseObj(post);
+ if (jsonObject.getStr("returnCode").equals("1")) {
+ JSONObject obj = JSONUtil.createObj();
+ obj.putOpt("code","200");
+ obj.putOpt("data",jsonObject.getJSONObject("returnData"));
+ return JSONUtil.toJsonStr(obj);
}else {
- map.put ("xingBie","鏈煡");
+ JSONObject obj = JSONUtil.createObj();
+ obj.putOpt("code","500");
+ return JSONUtil.toJsonStr(obj);
}
- map.put ("shenFenZh", customer.getCusIdcard ());
+ }
+
+ @Override
+ public String getBingRenXxByShengFenZheng(Map<String, Object> params) {
+ Map<String, Object> map = new HashMap<> ();
+ map.put ("caoZuoYuan",CZY);
+ map.put ("shenFenZh", params.get(ApiParamsConstants.CUS_ID_CARD));
+ map.put ("danWeiBh",params.get(ApiParamsConstants.COMP_ID));
+ //鑱屼笟缂栫爜
+ String string = sendPostTokenFormUrlencoded(HIS_URL + "/menZhenJz/getBingRenXxByShengFenZheng", map);
+ JSONObject object = JSONUtil.createObj();
+ if (StrUtil.isBlank(string)){
+ object.putOpt("code",500);
+ return JSONUtil.toJsonStr(object);
+ }
+ JSONObject entries = JSONUtil.parseObj(string);
+ log.info("鑾峰彇鐥呬汉淇℃伅杩斿洖鏁版嵁 ->{}", entries);
+ Object returnData = entries.get("returnData");
+ if (null != returnData && !returnData.toString().equals("null")) {
+ HashMap<String, String> hashMap = new HashMap<>();
+ JSONArray returnData1 = entries.getJSONArray("returnData");
+ JSONObject jsonObject = (JSONObject) returnData1.get(0);
+ hashMap.put(ApiParamsConstants.CARD_ID,jsonObject.getStr("jiuZhenKh"));
+ hashMap.put(ApiParamsConstants.PATIONID,jsonObject.getStr("bingRenId"));
+ object.putOpt("code",200);
+ object.putOpt("data",hashMap);
+ return JSONUtil.toJsonStr(object);
+ }else {
+ object.putOpt("code",404);
+ }
+ return JSONUtil.toJsonStr(object);
+ }
+
+ @Override
+ public String saveBingRenXx(Map<String, Object> params) {
+ Map<String, Object> map = new HashMap<> ();
+ map.put ("bingRenId", params.get(ApiParamsConstants.PATIONID));
+ map.put ("kaiLeiXing","4");
+ map.put("jiuZhenKh",params.get(ApiParamsConstants.CARD_ID));
+ map.put ("xingMing", params.get(ApiParamsConstants.CUS_NAME));
+ Long cusSex = Long.parseLong(params.get(ApiParamsConstants.CUS_SEX).toString());
+ if (cusSex == 0L) {
+ map.put("xingBie", "鐢�");
+ } else if (cusSex == 1L) {
+ map.put("xingBie", "濂�");
+ } else {
+ map.put("xingBie", "鏈煡");
+ }
+
+ map.put ("shenFenZh", params.get(ApiParamsConstants.CUS_ID_CARD));
map.put ("danWeiBh","");
- map.put ("chuShengRq", DateUtil.format(customer.getCusBrithday(),"yyyy-MM-dd"));
- map.put ("lianXiDz", customer.getCusAddr());
- map.put ("lianXiDh", customer.getCusPhone ());
+ map.put ("chuShengRq", params.get(ApiParamsConstants.CUS_BRITHDAY));
+ map.put ("lianXiDz", params.get(ApiParamsConstants.CUS_ADDR));
+ map.put ("lianXiDh", params.get(ApiParamsConstants.CUS_PHONE));
map.put ("feiYongLb","");
map.put ("feiYongXz","");
map.put ("jiLuLy","3");
- map.put ("caoZuoYuan",czy);
+ map.put ("caoZuoYuan",CZY);
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/menZhenJz/saveBingRenXx", map);
+ return sendPost(HIS_URL+"/menZhenJz/saveBingRenXx", map);
}
- //寰呮敹璐硅垂鐢ㄦ煡璇�
- public String getListDaiShouFei (String bingRenId, String jiuZhenKh, String yuanQuId) {
+ @Override
+ public String getListDaiShouFei(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("bingRenId",bingRenId);
- map.put ("jiuZhenKh",jiuZhenKh);
- map.put ("yuanQuId",yuanQuId);
+ map.put ("bingRenId",params.get(ApiParamsConstants.PATIONID));
+ map.put ("jiuZhenKh",params.get(ApiParamsConstants.CARD_ID));
+ map.put ("yuanQuId","1");
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/shouFei/getListDaiShouFei", map);
+ String post = sendPost(HIS_URL + "/shouFei/getListDaiShouFei", map);
+ JSONObject jsonObject = JSONUtil.parseObj(post);
+ if (jsonObject.getStr("returnCode").equals("1")) {
+ JSONObject data = jsonObject.getJSONObject("returnData");
+ JSONArray list = data.getJSONArray("dtoMzFeiyong1List");
+ JSONArray list1 = data.getJSONArray("dtoMzFeiYong2List");
+ JSONObject result = JSONUtil.createObj();
+ result.putOpt("list1",list);
+ result.putOpt("list2",list1);
+ return AjaxResult.success(result);
+ }else {
+ return AjaxResult.error(post);
+ }
}
-
- //鐢熸垚寰呮敹璐�/寰呴��璐� 璐圭敤
- public String createMenZhenFy (CreateMenZhenFyDto dto) {
- String czy = configService.selectConfigByKey("dfhisczybm");
+ @Override
+ public String createMenZhenFy(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("bingRenId",dto.getBingRenId());
- map.put ("jiuZhenKh",dto.getJiuZhenKh());
- map.put ("caoZuoYuan",czy);
- map.put ("yuanQuId",dto.getYuanQuId());
- map.put ("yingYongId",dto.getYingYongId());
- map.put ("kaiDanKs",dto.getKaiDanKs());
- map.put ("dengJiLsh",dto.getDengJiLsh());
- map.put ("shouTuiBz",dto.getShouTuiBz());
- map.put ("feiYongMxList",dto.getFeiYongMxList());
+ map.put ("bingRenId",params.get(ApiParamsConstants.PATIONID));
+ map.put ("jiuZhenKh",params.get(ApiParamsConstants.CARD_ID));
+ map.put ("caoZuoYuan",CZY);
+ map.put ("yuanQuId","1");
+ map.put ("yingYongId","870101");
+ map.put ("kaiDanKs",params.get(ApiParamsConstants.kaiDanKeShi));
+ map.put ("dengJiLsh",params.get(ApiParamsConstants.Tj_NUM));
+ map.put ("shouTuiBz",params.get(ApiParamsConstants.SHOU_TUI_STATUS));
+ map.put ("feiYongMxList",params.get(ApiParamsConstants.FEI_YONG_INFO_LIST));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/shouFei/createMenZhenFy", map);
+ String post = sendPost(HIS_URL + "/shouFei/createMenZhenFy", map);
+ JSONObject jsonObject = JSONUtil.parseObj(post);
+ if (jsonObject.getInt("returnCode") != 1) return AjaxResult.error(post);
+ JSONObject data = jsonObject.getJSONObject("returnData");
+ JSONObject result = JSONUtil.createObj();
+ result.putOpt(ApiParamsConstants.PATIONID,data.getStr(ApiParamsConstants.PATIONID));
+ result.putOpt(ApiParamsConstants.FEI_YONG_ID,data.getStr(ApiParamsConstants.FEI_YONG_ID));
+
+ JSONArray feiYongMxList = data.getJSONArray("feiYongMxList");
+
+ ArrayList<TjFlowingWaterHis> tjFlowingWaterHis = new ArrayList<>();
+ for (Object o : feiYongMxList) {
+ JSONObject entries = (JSONObject) o;
+ TjFlowingWaterHis waterHis = new TjFlowingWaterHis();
+ waterHis.setId(IdUtil.getSnowflakeNextId());
+ waterHis.setParentId(data.getStr(ApiParamsConstants.FEI_YONG_ID));
+ waterHis.setCurrentId(entries.getStr("feiYongMxId"));
+ waterHis.setXmId(entries.getStr("xiangMuId"));
+ tjFlowingWaterHis.add(waterHis);
+ }
+ result.putOpt("mxList",tjFlowingWaterHis);
+ return AjaxResult.success(result);
}
-
- //闂ㄨ瘖鏈敹璐硅垂鐢ㄦ挙閿�
- public String cheXiaoMzFy (CheXiaoMzFyDto dto) {
+ @Override
+ public String cheXiaoMzFy(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("bingRenId",dto.getBingRenId());
- map.put ("jiuZhenKh",dto.getJiuZhenKh());
- map.put ("feiYongIdList",dto.getFeiYongIdList());
+ map.put ("bingRenId",params.get(ApiParamsConstants.PATIONID));
+ map.put ("jiuZhenKh",params.get(ApiParamsConstants.CARD_ID));
+ ArrayList<JSONObject> ids = new ArrayList<>();
+ String string = params.get(ApiParamsConstants.FEI_YONG_ID_LIST).toString();
+ String[] split = string.split(",");
+ Arrays.stream(split).forEach(i -> {
+ JSONObject object = JSONUtil.createObj();
+ object.putOpt("feiYongId",i);
+ ids.add(object);
+ });
+ map.put ("feiYongIdList",ids);
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/shouFei/cheXiaoMzFy", map);
+ String post = sendPost(HIS_URL + "/shouFei/cheXiaoMzFy", map);
+ JSONObject entries = JSONUtil.parseObj(post);
+ if (entries.getStr("returnCode").equals("1"))
+ return AjaxResult.success();
+ else return AjaxResult.error(post);
}
-
- //鏀惰垂/閫�璐瑰畬鎴愰�氱煡绗笁鏂�
- public String pushZhiFuMsg (String feiYongId, int yeWuLx ) {
+ @Override
+ public String getKeShi(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("feiYongId",feiYongId);
- map.put ("yeWuLx",yeWuLx);
+ map.put ("yuanQuId","1");
+ map.put ("keShiMc",params.get(ApiParamsConstants.DEPT_NAME));
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/shouFei/pushZhiFuMsg", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getKeShi", map);
}
-
- //绉戝淇℃伅鏌ヨ
- public String getKeShi (String yuanQuId, String keShiMc, int pageIndex, int pageSize ) {
+ @Override
+ public String getListYiShengZd(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("yuanQuId",yuanQuId);
- map.put ("keShiMc",keShiMc);
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
- //鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getKeShi", map);
- }
-
- //鍖荤敓淇℃伅鏌ヨ
- public String getListYiShengZd (String yuanQuId, String keShiMc, int pageIndex, int pageSize ) {
- Map<String, Object> map = new HashMap<> ();
- map.put ("yuanQuId",yuanQuId);
- map.put ("keShiMc",keShiMc);
+ map.put ("yuanQuId","1");
+ map.put ("keShiMc",params.get(ApiParamsConstants.DEPT_NAME));
map.put ("bianGengSj","");
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getListYiShengZd", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getListYiShengZd", map);
}
-
- //鑾峰彇鏀惰垂椤圭洰鍒嗛〉
- public String getShouFeiXm (String queryString, String bianGengSj, int pageIndex, int pageSize ) {
+ @Override
+ public String getShouFeiXm(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("queryString",queryString);
- map.put ("bianGengSj",bianGengSj);
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
+ map.put ("queryString",params.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ map.put ("bianGengSj","");
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getShouFeiXm", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getShouFeiXm", map);
}
-
-
- /**
- * 绉戝淇℃伅鎺ㄩ��
- *
- * @param xingZhiSx 缁勭粐灞炴�� 绗竴浣�1聽琛ㄧず 鎸傚彿
- * 绗簩浣� 1琛ㄧず涓村簥
- * 绗笁浣� 1琛ㄧず妫�鏌�
- * 绗洓浣� 1 琛ㄧず鎵嬫湳
- * 绗簲浣� 1 琛ㄧず娌荤枟
- * 绗叚浣� 1 琛ㄧず鎶ょ悊
- * @param queryString 妯＄硦鍖归厤杈撯紛鐮�1銆佺瀹ゅ悕绉�
- * @param zuoFeiBz 浣滃簾鏍囧織锛�0 姝ｅ父锛�1 浣滃簾
- * @param yuanQuId 闄㈠尯id
- * @param keShiIds 绉戝ID闆嗗悎
- * @param ifPlus 鏄惁鏌ヨplus灞炴��
- * @return
- */
- public String getKeShiByConditions (int xingZhiSx, String queryString, int zuoFeiBz, String yuanQuId, List<String> keShiIds, int ifPlus) {
+ @Override
+ public String getKeShiByConditions(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("xingZhiSx",xingZhiSx);
- map.put ("queryString",queryString);
- map.put ("zuoFeiBz",zuoFeiBz);
- map.put ("yuanQuId",yuanQuId);
- map.put ("keShiIds",keShiIds);
- map.put ("ifPlus",ifPlus);
+ map.put ("xingZhiSx","");
+ map.put ("queryString",params.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ map.put ("zuoFeiBz",params.get(ApiParamsConstants.DEPT_ZUOFEI_STATUS));
+ map.put ("yuanQuId","1");
+ map.put ("keShiIds",params.get(ApiParamsConstants.DEPT_IDS));
+ map.put ("ifPlus","");
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getKeShiByConditions", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getKeShiByConditions", map);
}
-
-
- /**
- * 鍙栨牱鏈瓧鍏�
- *
- * @param queryString 鏍锋湰绫诲瀷鍚嶇О(鏍锋湰鍚嶇О/鏍锋湰绫诲瀷id)
- * @param pageIndex
- * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
- * @return
- */
- public String getYangBen (String queryString, int pageIndex, int pageSize ) {
+ @Override
+ public String getYangBen(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("queryString",queryString);
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
+ map.put ("queryString",params.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getYangBen", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getYangBen", map);
}
-
- /**
- * 鐥呭尯淇℃伅鎺ㄩ��
- *
- * @param yuanQuId 闄㈠尯Id
- * @param keShiId 绉戝Id
- * @param pageIndex 褰撳墠饣�
- * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
- * @return
- */
- public String getListBingQuZd (String yuanQuId, String keShiId, int pageIndex, int pageSize ) {
+ @Override
+ public String getListBingQuZd(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("yuanQuId",yuanQuId);
- map.put ("keShiId",keShiId);
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
+ map.put ("yuanQuId",params.get(ApiParamsConstants.YUANQU_ID));
+ map.put ("keShiId",params.get(ApiParamsConstants.DEPT_ID));
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getListBingQuZd", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getListBingQuZd", map);
}
- /**
- * 鑱屸集淇℃伅
- *
- * @param bianGengSj 鍙樻洿鏃堕棿
- * @param pageIndex 褰撳墠饣�
- * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
- * @return
- */
- public String getZhiGongPage (String bianGengSj, int pageIndex, int pageSize ) {
+ @Override
+ public String getZhiGongPage(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("bianGengSj",bianGengSj);
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
+ map.put ("bianGengSj","");
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getZhiGongPage", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getZhiGongPage", map);
}
-
- /**
- * 妫�鏌ラ」鐩�
- *
- * @param queryString
- * @param bianGengSj
- * @param pageIndex
- * @param pageSize
- * @return
- */
- public String getJianChaXm (String queryString, String bianGengSj, int pageIndex, int pageSize ) {
+ @Override
+ public String getJianChaXm(Map<String, Object> params) {
Map<String, Object> map = new HashMap<> ();
- map.put ("queryString",queryString);
- map.put ("bianGengSj",bianGengSj);
- map.put ("pageIndex",pageIndex);
- map.put ("pageSize",pageSize);
+ map.put ("queryString",params.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ map.put ("bianGengSj","");
+ map.put ("pageIndex",params.get(ApiParamsConstants.PAGE_INDEX));
+ map.put ("pageSize",params.get(ApiParamsConstants.PAGE_SIZE));
//鑱屼笟缂栫爜
- return sendPost (HIS_URL+"/zhuShuJu/getJianChaXm", map);
+ return sendPost(HIS_URL+"/zhuShuJu/getJianChaXm", map);
}
- /**
- * 妫�楠岄」饨帹閫�
- *
- * @param queryCode 鏌ヨ鐮�(椤光浆缂栫爜/鎷尖境鐮�
- * @param page 褰撳墠饣�
- * @param size 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100
- * @return
- */
- public String getJianYanXm(String queryCode, Integer page, Integer size){
+ @Override
+ public String getJianYanXm(Map<String, Object> map) {
HashMap<String, Object> hashMap = new HashMap<>();
- hashMap.put("queryCode",queryCode);
- hashMap.put("page",page);
- hashMap.put("size",size);
- return sendPost (HIS_URL+"/zhuShuJu/getJianYanXm", hashMap);
+ hashMap.put("queryCode",map.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ hashMap.put("page",map.get(ApiParamsConstants.PAGE_INDEX));
+ hashMap.put("size",map.get(ApiParamsConstants.PAGE_SIZE));
+ return sendPost(HIS_URL+"/zhuShuJu/getJianYanXm", hashMap);
}
- /**
- * 妫�楠岄」饨敹璐规帹閫�
- *
- * @param shouFeiXmId 鏀惰垂椤光浆id
- * @param jiaGeTx 浠锋牸浣撶郴
- * @return
- */
- public String getShouFeiXmJg(String shouFeiXmId, String jiaGeTx){
+ @Override
+ public String getShouFeiXmJg(Map<String, Object> map) {
HashMap<String, Object> hashMap = new HashMap<>();
- hashMap.put("shouFeiXmId",shouFeiXmId);
- hashMap.put("jiaGeTx",jiaGeTx);
- return sendPost (HIS_URL+"/zhuShuJu/getShouFeiXmJg", hashMap);
+ hashMap.put("shouFeiXmId",map.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ hashMap.put("jiaGeTx",map.get(ApiParamsConstants.COMMON_QUERY_KEY2));
+ return sendPost(HIS_URL+"/zhuShuJu/getShouFeiXmJg", hashMap);
}
- /**
- * 妫�楠屽鍣�
- *
- * @param queryString 瀹瑰櫒鍚嶇О(瀹瑰櫒鍚嶇О/杈撯紛鐮�1)
- * @param pageIndex 褰撳墠饣�
- * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
- * @return
- */
- public String getRongQi(String queryString, Integer pageIndex, Integer pageSize){
+ @Override
+ public String getRongQi(Map<String, Object> map) {
HashMap<String, Object> hashMap = new HashMap<>();
- hashMap.put("queryString",queryString);
- hashMap.put("pageIndex",pageIndex);
- hashMap.put("pageSize",pageSize);
- return sendPost (HIS_URL+"/zhuShuJu/getRongQi", hashMap);
+ hashMap.put("queryString",map.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ hashMap.put("pageIndex",map.get(ApiParamsConstants.PAGE_INDEX));
+ hashMap.put("pageSize",map.get(ApiParamsConstants.PAGE_SIZE));
+ return sendPost(HIS_URL+"/zhuShuJu/getRongQi", hashMap);
}
- /**
- * 妫�楠屾牱鏈�
- *
- * @param queryString 鏍锋湰绫诲瀷鍚嶇О(鏍锋湰鍚嶇О/鏍锋湰绫诲瀷id)
- * @param pageIndex 褰撳墠饣�
- * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
- * @return
- */
- public String getJyYangBen(String queryString, Integer pageIndex, Integer pageSize){
+ @Override
+ public String getJyYangBen(Map<String, Object> map) {
HashMap<String, Object> hashMap = new HashMap<>();
- hashMap.put("queryString",queryString);
- hashMap.put("pageIndex",pageIndex);
- hashMap.put("pageSize",pageSize);
- return sendPost (HIS_URL+"/zhuShuJu/getYangBen", hashMap);
+ hashMap.put("queryString",map.get(ApiParamsConstants.COMMON_QUERY_KEY));
+ hashMap.put("pageIndex",map.get(ApiParamsConstants.PAGE_INDEX));
+ hashMap.put("pageSize",map.get(ApiParamsConstants.PAGE_SIZE));
+ return sendPost(HIS_URL+"/zhuShuJu/getYangBen", hashMap);
}
- private String sendPost(String url,Map<String, Object> hashMap){
- Map<Object, Object> entries = redisTemplate.opsForHash().entries("token:his:df");
+ @Override
+ public String pushZhiFuMsg(String hospName,Map<String, Object> params) {
+ log.info("鍥炶皟瑙﹀彂 ->{}",params);
+ configValue.refresh();
+ Map<String, Object> map = new HashMap<> ();
+ map.put ("feiYongId",params.get("feiyongid"));
+ String string = params.get("status").toString();
+ if (!string.equals("1"))
+ string = "2";
+ map.put ("yeWuLx",string);
+ // 鍙傛暟绫诲瀷鍖哄垎
+ map.put("type","1");
+ HashMap<String, Object> headers = new HashMap<>();
+ headers.put("hospId","xamjyy");
+ String post = HttpClientUtils.sendPost(TJ_URL + "/callBack/pushZhiFuMsg", map,headers);
+ JSONObject jsonObject = JSONUtil.parseObj(post);
+ JSONObject obj = JSONUtil.createObj();
+ if (jsonObject.getStr("code").equals("200")) {
+ obj.putOpt("returnCode",1);
+ obj.putOpt("exceptionContent","");
+ obj.putOpt("returnData",null);
+ }else {
+ obj.putOpt("returnCode",0);
+ obj.putOpt("exceptionContent",jsonObject.getStr("msg"));
+ obj.putOpt("returnData",null);
+ }
+ return JSONUtil.toJsonStr(obj);
+ }
+
+
+ private String sendPost(String url, Map<String, Object> hashMap){
+ Map<Object, Object> entries = redisTemplate.opsForHash().entries("token:his:shanxixamjyy");
if (entries != null && !entries.isEmpty()) {
String timeStr = entries.get("time").toString();
String expiresInStr = entries.get("expires_in").toString();
@@ -416,33 +436,158 @@
Instant tokenExpirationTime = Instant.ofEpochSecond(time).plusSeconds(expiresIn);
Instant now = Instant.now();
if (now.isAfter(tokenExpirationTime)){
- return refreshToken(url,hashMap);
+ return refreshToken(url,hashMap,"json");
}else {
String accessToken = entries.get("access_token").toString();
String tokenType = entries.get("token_type").toString();
String string = HttpClientUtils.sendPostToken(url, hashMap, tokenType + " " + accessToken);
- return StrUtil.isNotBlank(string) ? string : JSONUtil.createObj().toString();
+
+ if(StrUtil.isNotBlank(string)){
+ JSON json = FieldNameConverter.convertFieldNames(JSONUtil.parse(string));
+ return JSONUtil.toJsonStr(json);
+ } else return JSONUtil.createObj().toString();
}
}else {
- return refreshToken(url, hashMap);
+ return refreshToken(url, hashMap,"json");
}
}
- private String refreshToken(String url, Map<String, Object> hashMap) {
+ private String sendPostTokenFormUrlencoded(String url, Map<String, Object> hashMap){
+ Map<Object, Object> entries = redisTemplate.opsForHash().entries("token:his:shanxixamjyy");
+ if (!entries.isEmpty()) {
+ String timeStr = entries.get("time").toString();
+ String expiresInStr = entries.get("expires_in").toString();
+ long time = Long.parseLong(timeStr);
+ long expiresIn = Long.parseLong(expiresInStr);
+ Instant tokenExpirationTime = Instant.ofEpochSecond(time).plusSeconds(expiresIn);
+ Instant now = Instant.now();
+ if (now.isAfter(tokenExpirationTime)){
+ return refreshToken(url,hashMap,"url");
+ }else {
+ String accessToken = entries.get("access_token").toString();
+ String tokenType = entries.get("token_type").toString();
+ String string = HttpClientUtils.sendPostTokenFormUrlencoded(url, hashMap, tokenType + " " + accessToken);
+ return StrUtil.isNotBlank(string) ? string : JSONUtil.createObj().toString();
+ }
+ }else {
+ return refreshToken(url, hashMap,"url");
+ }
+ }
+
+ private String sendPostTokenFormData(String url, Map<String, Object> hashMap){
+ Map<Object, Object> entries = redisTemplate.opsForHash().entries("token:his:shanxixamjyy");
+ if (entries != null && !entries.isEmpty()) {
+ String timeStr = entries.get("time").toString();
+ String expiresInStr = entries.get("expires_in").toString();
+ long time = Long.parseLong(timeStr);
+ long expiresIn = Long.parseLong(expiresInStr);
+ Instant tokenExpirationTime = Instant.ofEpochSecond(time).plusSeconds(expiresIn);
+ Instant now = Instant.now();
+ if (now.isAfter(tokenExpirationTime)){
+ return refreshToken(url,hashMap,"form");
+ }else {
+ String accessToken = entries.get("access_token").toString();
+ String tokenType = entries.get("token_type").toString();
+ String string = HttpClientUtils.sendPostTokenFormData(url, hashMap, tokenType + " " + accessToken);
+ if(StrUtil.isNotBlank(string)){
+ JSON json = FieldNameConverter.convertFieldNames(JSONUtil.parse(string));
+ return JSONUtil.toJsonStr(json);
+ }else return JSONUtil.createObj().toString();
+ }
+ }else {
+ return refreshToken(url, hashMap,"form");
+ }
+ }
+
+ private String refreshToken(String url, Map<String, Object> hashMap,String type) {
JSONObject parseObj = getToken();
if (parseObj != null) {
Integer expiresIn = parseObj.getInt("expires_in");
if (expiresIn != null) {
parseObj.putOpt("time", Instant.now().getEpochSecond());
- redisTemplate.opsForHash().putAll("token:his:df", parseObj);
- redisTemplate.expire("token:his:df", expiresIn - 10, TimeUnit.SECONDS);
+ redisTemplate.opsForHash().putAll("token:his:shanxixamjyy", parseObj);
+ redisTemplate.expire("token:his:shanxixamjyy", expiresIn - 10, TimeUnit.SECONDS);
String accessToken = parseObj.getStr("access_token");
String tokenType = parseObj.getStr("token_type");
- String string = HttpClientUtils.sendPostToken(url, hashMap, tokenType + " " + accessToken);
- return StrUtil.isNotBlank(string) ? string : JSONUtil.createObj().toString();
+ switch (type){
+ case "json":
+ String string = HttpClientUtils.sendPostToken(url, hashMap, tokenType + " " + accessToken);
+ if(StrUtil.isNotBlank(string)){
+ JSON json = FieldNameConverter.convertFieldNames(JSONUtil.parse(string));
+ return JSONUtil.toJsonStr(json);
+ } else return JSONUtil.createObj().toString();
+ case "form":
+ String string1 = HttpClientUtils.sendPostTokenFormData(url, hashMap, tokenType + " " + accessToken);
+ if(StrUtil.isNotBlank(string1)){
+ JSON json = FieldNameConverter.convertFieldNames(JSONUtil.parse(string1));
+ return JSONUtil.toJsonStr(json);
+ } else return JSONUtil.createObj().toString();
+ case "url":
+ String string2 = HttpClientUtils.sendPostTokenFormUrlencoded(url, hashMap, tokenType + " " + accessToken);
+ if(StrUtil.isNotBlank(string2)){
+ JSON json = FieldNameConverter.convertFieldNames(JSONUtil.parse(string2));
+ return JSONUtil.toJsonStr(json);
+ } else return JSONUtil.createObj().toString();
+ }
}
}
return JSONUtil.createObj().toString();
}
+
+ @Override
+ public void syncDict(String hospName) {
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("hosp","shanxiqinxamjyy");
+ HashMap<String, Object> headers = new HashMap<>();
+ headers.put("hospId","xamjyy");
+ String post = HttpClientUtils.sendPost(TJ_URL + "/callBack/getZdList", map,headers);
+ JSONArray jsonArray = JSONUtil.parseObj(post).getJSONArray("data");
+ if (jsonArray != null && !jsonArray.isEmpty()) {
+ List<HisSyncDict> list = jsonArray.toList(HisSyncDict.class);
+ String token = "";
+ Map<Object, Object> entries = redisTemplate.opsForHash().entries("token:his:shanxixamjyy");
+ if (!entries.isEmpty()) {
+ String timeStr = entries.get("time").toString();
+ String expiresInStr = entries.get("expires_in").toString();
+ long time = Long.parseLong(timeStr);
+ Long expiresIn = Long.parseLong(expiresInStr);
+ Instant tokenExpirationTime = Instant.ofEpochSecond(time).plusSeconds(expiresIn);
+ Instant now = Instant.now();
+ if (now.isAfter(tokenExpirationTime)){
+ JSONObject parseObj = getToken();
+ if (parseObj != null) {
+ expiresIn = parseObj.getLong("expires_in");
+ if (expiresIn != null) {
+ parseObj.putOpt("time", Instant.now().getEpochSecond());
+ redisTemplate.opsForHash().putAll("token:his:shanxixamjyy", parseObj);
+ redisTemplate.expire("token:his:shanxixamjyy", expiresIn - 10, TimeUnit.SECONDS);
+ String accessToken = parseObj.getStr("access_token");
+ String tokenType = parseObj.getStr("token_type");
+ token = tokenType + " " + accessToken;
+ }
+ }
+ }else {
+ String accessToken = entries.get("access_token").toString();
+ String tokenType = entries.get("token_type").toString();
+ token = tokenType + " " + accessToken;
+ }
+ }else {
+ JSONObject parseObj = getToken();
+ if (parseObj != null) {
+ Integer expiresIn = parseObj.getInt("expires_in");
+ if (expiresIn != null) {
+ parseObj.putOpt("time", Instant.now().getEpochSecond());
+ redisTemplate.opsForHash().putAll("token:his:shanxixamjyy", parseObj);
+ redisTemplate.expire("token:his:shanxixamjyy", expiresIn - 10, TimeUnit.SECONDS);
+ String accessToken = parseObj.getStr("access_token");
+ String tokenType = parseObj.getStr("token_type");
+ token = tokenType + " " + accessToken;
+ }
+ }
+ }
+ if (StrUtil.isNotBlank(token))
+ syncZd.exec(list, token);
+ }
+ }
}
--
Gitblit v1.8.0