From 1b7ed7edb09aaecf68ddf3396ee007bc6eadf52a Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期一, 30 十二月 2024 17:04:09 +0800
Subject: [PATCH] zjh202412030
---
ltkj-admin/src/main/java/com/ltkj/web/controller/dongfanghis/DfHisApiMethodService.java | 247 ++++++++++++++++++++++++++++++++++++-------------
1 files changed, 182 insertions(+), 65 deletions(-)
diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/dongfanghis/DfHisApiMethodService.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/dongfanghis/DfHisApiMethodService.java
index 0644767..b6c82bc 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/dongfanghis/DfHisApiMethodService.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/dongfanghis/DfHisApiMethodService.java
@@ -1,6 +1,10 @@
package com.ltkj.web.controller.dongfanghis;
import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSON;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
import com.ltkj.common.core.domain.AjaxResult;
import com.ltkj.hosp.dfDto.CheXiaoMzFyDto;
import com.ltkj.hosp.dfDto.CreateMenZhenFyDto;
@@ -15,10 +19,9 @@
import java.io.FileInputStream;
import java.io.IOException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
+import java.time.Instant;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
/**
* ClassName: DfHisApiMethodService <br/>
@@ -34,18 +37,22 @@
@Autowired
private ISysConfigService configService;
+// @Autowired
+ private RedisTemplate<String ,Object> redisTemplate;
- private static String HIS_URL = "";
+ private static String HIS_URL = "http://oapi.pbkwyy.com/OAPI";
private static String CONFIG_PATH;
- private static String GRANT_TYPE = "";
- private static String CLIENT_ID = "";
- private static String CLIENT_SECRET = "";
- private static String SCOP = "";
+ private static String GRANT_TYPE = "client_credentials";
+ private static String CLIENT_ID = "XFZZQEfXTZ7exhhi";
+ private static String CLIENT_SECRET = "05a192176c21edfcc9cf5fa26fc5a9e0c5b131ad";
+// private static String SCOP = "";
-// @Autowired
-// private RedisTemplate<String,Object> redisTemplate;
+// http://oapi.pbkwyy.com/OAPI/oauth/token
+// grant_type:client_credentials
+// client_id:XFZZQEfXTZ7exhhi
+// client_secret:05a192176c21edfcc9cf5fa26fc5a9e0c5b131ad
@Value("${config.properties}")
public void setConfigPath(String configPath) {
@@ -59,7 +66,7 @@
GRANT_TYPE = props.getProperty("grant_type");
CLIENT_ID= props.getProperty("client_id");
CLIENT_SECRET = props.getProperty("client_secret");
- SCOP = props.getProperty("scope");
+// SCOP = props.getProperty("scope");
HIS_URL=url+":"+port+"/OAPI/";
} catch (IOException throwables) {
throwables.printStackTrace();
@@ -68,18 +75,26 @@
//鑾峰彇token
- public AjaxResult getToken () {
+ private JSONObject getToken () {
Map<String, Object> map = new HashMap<>();
map.put("grant_type",GRANT_TYPE);
map.put("client_id",CLIENT_ID);
map.put("client_secret",CLIENT_SECRET);
- map.put("scope",SCOP);
- String post = HttpClientUtils.sendPost (HIS_URL+"/oauth/token", map);
- return AjaxResult.success ().put ("data", post);
+// map.put("scope",SCOP);
+ String post = sendPost (HIS_URL+"/oauth/token", map);
+ if (StrUtil.isBlank(post)) return null;
+ JSONObject parseObj = JSONUtil.parseObj(post);
+// 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);
+// }
+ return parseObj;
}
//寤烘。
- public AjaxResult jianDang (TjCustomer customer) {
+ public JSON jianDang (TjCustomer customer) {
String czy = configService.selectConfigByKey("dfhisczybm");
Map<String, Object> map = new HashMap<> ();
@@ -115,24 +130,24 @@
map.put ("minZuDm","");
map.put ("minZuMc","");
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/menZhenJz/jianDang", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/menZhenJz/jianDang", map);
+ return JSONUtil.parseObj(post);
}
//楠岃瘉韬唤璇佹槸鍚﹀缓杩囨。
- public AjaxResult getBingRenXxByShengFenZheng (TjCustomer customer) {
+ public JSON 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","");
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/menZhenJz/getBingRenXxByShengFenZheng", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/menZhenJz/getBingRenXxByShengFenZheng", map);
+ return JSONUtil.parseObj(post);
}
//鐥呬汉鍩烘湰淇℃伅鍙樻洿
- public AjaxResult saveBingRenXx (TjCustomer customer) {
+ public JSON saveBingRenXx (TjCustomer customer) {
String czy = configService.selectConfigByKey("dfhisczybm");
Map<String, Object> map = new HashMap<> ();
map.put ("jiuZhenKh", customer.getPationId ());
@@ -156,24 +171,24 @@
map.put ("jiLuLy","3");
map.put ("caoZuoYuan",czy);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/menZhenJz/saveBingRenXx", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/menZhenJz/saveBingRenXx", map);
+ return JSONUtil.parseObj(post);
}
//寰呮敹璐硅垂鐢ㄦ煡璇�
- public AjaxResult getListDaiShouFei (String bingRenId,String jiuZhenKh,String yuanQuId) {
+ public JSON getListDaiShouFei (String bingRenId,String jiuZhenKh,String yuanQuId) {
Map<String, Object> map = new HashMap<> ();
map.put ("bingRenId",bingRenId);
map.put ("jiuZhenKh",jiuZhenKh);
map.put ("yuanQuId",yuanQuId);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/shouFei/getListDaiShouFei", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/shouFei/getListDaiShouFei", map);
+ return JSONUtil.parseObj(post);
}
- //寰呮敹璐硅垂鐢ㄦ煡璇�
- public AjaxResult createMenZhenFy (CreateMenZhenFyDto dto) {
+ //鐢熸垚寰呮敹璐�/寰呴��璐� 璐圭敤
+ public JSON createMenZhenFy (CreateMenZhenFyDto dto) {
String czy = configService.selectConfigByKey("dfhisczybm");
Map<String, Object> map = new HashMap<> ();
map.put ("bingRenId",dto.getBingRenId());
@@ -186,48 +201,48 @@
map.put ("shouTuiBz",dto.getShouTuiBz());
map.put ("feiYongMxList",dto.getFeiYongMxList());
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/shouFei/createMenZhenFy", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/shouFei/createMenZhenFy", map);
+ return JSONUtil.parseObj(post);
}
//闂ㄨ瘖鏈敹璐硅垂鐢ㄦ挙閿�
- public AjaxResult cheXiaoMzFy (CheXiaoMzFyDto dto) {
+ public JSON cheXiaoMzFy (CheXiaoMzFyDto dto) {
Map<String, Object> map = new HashMap<> ();
map.put ("bingRenId",dto.getBingRenId());
map.put ("jiuZhenKh",dto.getJiuZhenKh());
map.put ("feiYongIdList",dto.getFeiYongIdList());
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/shouFei/cheXiaoMzFy", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/shouFei/cheXiaoMzFy", map);
+ return JSONUtil.parseObj(post);
}
//鏀惰垂/閫�璐瑰畬鎴愰�氱煡绗笁鏂�
- public AjaxResult pushZhiFuMsg (String feiYongId,int yeWuLx ) {
+ public JSON pushZhiFuMsg (String feiYongId,int yeWuLx ) {
Map<String, Object> map = new HashMap<> ();
map.put ("feiYongId",feiYongId);
map.put ("yeWuLx",yeWuLx);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/shouFei/pushZhiFuMsg", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/shouFei/pushZhiFuMsg", map);
+ return JSONUtil.parseObj(post);
}
//绉戝淇℃伅鏌ヨ
- public AjaxResult getKeShi (String yuanQuId,String keShiMc,int pageIndex,int pageSize ) {
+ public JSON getKeShi (String yuanQuId,String keShiMc,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("yuanQuId",yuanQuId);
map.put ("keShiMc",keShiMc);
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getKeShi", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getKeShi", map);
+ return JSONUtil.parseObj(post);
}
//鍖荤敓淇℃伅鏌ヨ
- public AjaxResult getListYiShengZd (String yuanQuId,String keShiMc,int pageIndex,int pageSize ) {
+ public JSON getListYiShengZd (String yuanQuId,String keShiMc,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("yuanQuId",yuanQuId);
map.put ("keShiMc",keShiMc);
@@ -235,21 +250,21 @@
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getListYiShengZd", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getListYiShengZd", map);
+ return JSONUtil.parseObj(post);
}
//鑾峰彇鏀惰垂椤圭洰鍒嗛〉
- public AjaxResult getShouFeiXm (String queryString,String bianGengSj,int pageIndex,int pageSize ) {
+ public JSON getShouFeiXm (String queryString,String bianGengSj,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("queryString",queryString);
map.put ("bianGengSj",bianGengSj);
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getShouFeiXm", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getShouFeiXm", map);
+ return JSONUtil.parseObj(post);
}
@@ -269,7 +284,7 @@
* @param ifPlus 鏄惁鏌ヨplus灞炴��
* @return
*/
- public AjaxResult getKeShiByConditions (int xingZhiSx, String queryString, int zuoFeiBz, String yuanQuId, List<String>keShiIds,int ifPlus) {
+ public JSON getKeShiByConditions (int xingZhiSx, String queryString, int zuoFeiBz, String yuanQuId, List<String>keShiIds,int ifPlus) {
Map<String, Object> map = new HashMap<> ();
map.put ("xingZhiSx",xingZhiSx);
map.put ("queryString",queryString);
@@ -278,47 +293,47 @@
map.put ("keShiIds",keShiIds);
map.put ("ifPlus",ifPlus);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getKeShiByConditions", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getKeShiByConditions", map);
+ return JSONUtil.parseObj(post);
}
/**
- * //鍙栨牱鏈瓧鍏�
+ * 鍙栨牱鏈瓧鍏�
* @param queryString 鏍锋湰绫诲瀷鍚嶇О(鏍锋湰鍚嶇О/鏍锋湰绫诲瀷id)
* @param pageIndex
* @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
* @return
*/
- public AjaxResult getYangBen (String queryString,int pageIndex,int pageSize ) {
+ public JSON getYangBen (String queryString,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("queryString",queryString);
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getYangBen", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getYangBen", map);
+ return JSONUtil.parseObj(post);
}
/**
- * //鐥呭尯淇℃伅鎺ㄩ��
+ * 鐥呭尯淇℃伅鎺ㄩ��
* @param yuanQuId 闄㈠尯Id
* @param keShiId 绉戝Id
* @param pageIndex 褰撳墠饣�
* @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
* @return
*/
- public AjaxResult getListBingQuZd (String yuanQuId,String keShiId,int pageIndex,int pageSize ) {
+ public JSON getListBingQuZd (String yuanQuId,String keShiId,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("yuanQuId",yuanQuId);
map.put ("keShiId",keShiId);
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getListBingQuZd", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getListBingQuZd", map);
+ return JSONUtil.parseObj(post);
}
/**
@@ -328,34 +343,136 @@
* @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
* @return
*/
- public AjaxResult getZhiGongPage (String bianGengSj,int pageIndex,int pageSize ) {
+ public JSON getZhiGongPage (String bianGengSj,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("bianGengSj",bianGengSj);
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getZhiGongPage", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getZhiGongPage", map);
+ return JSONUtil.parseObj(post);
}
/**
- *
+ * 妫�鏌ラ」鐩�
* @param queryString
* @param bianGengSj
* @param pageIndex
* @param pageSize
* @return
*/
- public AjaxResult getJianChaXm (String queryString,String bianGengSj,int pageIndex,int pageSize ) {
+ public JSON getJianChaXm (String queryString,String bianGengSj,int pageIndex,int pageSize ) {
Map<String, Object> map = new HashMap<> ();
map.put ("queryString",queryString);
map.put ("bianGengSj",bianGengSj);
map.put ("pageIndex",pageIndex);
map.put ("pageSize",pageSize);
//鑱屼笟缂栫爜
- String post = HttpClientUtils.sendPost (HIS_URL+"/zhuShuJu/getJianChaXm", map);
- return AjaxResult.success ().put ("data", post);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getJianChaXm", map);
+ return JSONUtil.parseObj(post);
+ }
+
+ /**
+ * 妫�楠岄」饨帹閫�
+ * @param queryCode 鏌ヨ鐮�(椤光浆缂栫爜/鎷尖境鐮�
+ * @param page 褰撳墠饣�
+ * @param size 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100
+ * @return
+ */
+ public JSON getJianYanXm(String queryCode,Integer page,Integer size){
+ HashMap<String, Object> hashMap = new HashMap<>();
+ hashMap.put("queryCode",queryCode);
+ hashMap.put("page",page);
+ hashMap.put("size",size);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getJianYanXm", hashMap);
+ return JSONUtil.parse(post);
+ }
+
+ /**
+ * 妫�楠岄」饨敹璐规帹閫�
+ * @param shouFeiXmId 鏀惰垂椤光浆id
+ * @param jiaGeTx 浠锋牸浣撶郴
+ * @return
+ */
+ public JSON getShouFeiXmJg(String shouFeiXmId,String jiaGeTx){
+ HashMap<String, Object> hashMap = new HashMap<>();
+ hashMap.put("shouFeiXmId",shouFeiXmId);
+ hashMap.put("jiaGeTx",jiaGeTx);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getShouFeiXmJg", hashMap);
+ return JSONUtil.parse(post);
+ }
+
+ /**
+ * 妫�楠屽鍣�
+ * @param queryString 瀹瑰櫒鍚嶇О(瀹瑰櫒鍚嶇О/杈撯紛鐮�1)
+ * @param pageIndex 褰撳墠饣�
+ * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
+ * @return
+ */
+ public JSON getRongQi(String queryString,Integer pageIndex,Integer pageSize){
+ HashMap<String, Object> hashMap = new HashMap<>();
+ hashMap.put("queryString",queryString);
+ hashMap.put("pageIndex",pageIndex);
+ hashMap.put("pageSize",pageSize);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getRongQi", hashMap);
+ return JSONUtil.parse(post);
+ }
+
+ /**
+ * 妫�楠屾牱鏈�
+ * @param queryString 鏍锋湰绫诲瀷鍚嶇О(鏍锋湰鍚嶇О/鏍锋湰绫诲瀷id)
+ * @param pageIndex 褰撳墠饣�
+ * @param pageSize 姣忊粴鏉℃暟锛堟渶饧や笉鑳借秴杩�100锛�
+ * @return
+ */
+ public JSON getYangBen(String queryString,Integer pageIndex,Integer pageSize){
+ HashMap<String, Object> hashMap = new HashMap<>();
+ hashMap.put("queryString",queryString);
+ hashMap.put("pageIndex",pageIndex);
+ hashMap.put("pageSize",pageSize);
+ String post = sendPost (HIS_URL+"/zhuShuJu/getYangBen", hashMap);
+ return JSONUtil.parse(post);
+ }
+
+ private String sendPost(String url,Map<String, Object> hashMap){
+ Map<Object, Object> entries = redisTemplate.opsForHash().entries("token:his:df");
+ 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);
+ }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();
+ }
+ }else {
+ return refreshToken(url, hashMap);
+ }
+ }
+
+ private String refreshToken(String url, Map<String, Object> hashMap) {
+ 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);
+
+ 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();
+ }
+ }
+ return JSONUtil.createObj().toString();
}
--
Gitblit v1.8.0