|
|
|
|
@ -0,0 +1,311 @@
|
|
|
|
|
package com.glxp.udidl.admin.util.alihealth;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
|
import cn.hutool.http.HttpUtil;
|
|
|
|
|
|
|
|
|
|
import com.glxp.udidl.admin.constant.AliConstants;
|
|
|
|
|
import com.glxp.udidl.admin.entity.auth.AuthAliUser;
|
|
|
|
|
import com.glxp.udidl.admin.entity.collect.ThirdAliDrug;
|
|
|
|
|
import com.glxp.udidl.admin.req.alihealth.AlihealthKytCommonParametersReqeust;
|
|
|
|
|
import com.glxp.udidl.admin.req.alihealth.AlihealthKytDrugrescodeReqeust;
|
|
|
|
|
import com.glxp.udidl.admin.req.alihealth.local.AlihealthThirdAliDrugInsertReqeust;
|
|
|
|
|
import com.glxp.udidl.admin.res.BaseResponse;
|
|
|
|
|
import com.glxp.udidl.admin.res.alihealth.AlihealthKytDrugrescodeResponse;
|
|
|
|
|
import com.glxp.udidl.admin.service.auth.AuthAliUserService;
|
|
|
|
|
import com.glxp.udidl.admin.util.ResultVOAliUtils;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
import javax.crypto.Mac;
|
|
|
|
|
import javax.crypto.SecretKey;
|
|
|
|
|
import javax.crypto.spec.SecretKeySpec;
|
|
|
|
|
import java.io.IOException;
|
|
|
|
|
import java.security.GeneralSecurityException;
|
|
|
|
|
import java.security.MessageDigest;
|
|
|
|
|
import java.text.SimpleDateFormat;
|
|
|
|
|
import java.util.*;
|
|
|
|
|
|
|
|
|
|
//import static com.taobao.api.internal.util.TaobaoUtils.byte2hex;
|
|
|
|
|
|
|
|
|
|
@Slf4j
|
|
|
|
|
@Component
|
|
|
|
|
public class AlihealthUtils {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Value("${ALIHEALTH_URL:http://gw.api.taobao.com/router/rest}")
|
|
|
|
|
private String alihealthUrl;
|
|
|
|
|
|
|
|
|
|
// public static void main(String[] args) {
|
|
|
|
|
//
|
|
|
|
|
// alihealthKytSinglerelationReqeust.setSign(sign);
|
|
|
|
|
// String ss = HttpUtil.get("http://gw.api.taobao.com/router/rest",BeanUtil.beanToMap(alihealthKytSinglerelationReqeust));
|
|
|
|
|
// AlihealthKytSinglerelationResponse alihealthKytSinglerelationResponse = new AlihealthKytSinglerelationResponse(ss);
|
|
|
|
|
// System.out.println(ss);
|
|
|
|
|
// System.out.println(alihealthKytSinglerelationResponse);
|
|
|
|
|
//
|
|
|
|
|
//// AlibabaAlihealthDrugtraceTopLsydQueryRelationResponse alibabaAlihealthDrugtraceTopLsydQueryRelationResponse
|
|
|
|
|
//
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public BaseResponse<List<ThirdAliDrug>> thirdAliDrugInsertAll(AlihealthThirdAliDrugInsertReqeust request) {
|
|
|
|
|
// 初始化变量
|
|
|
|
|
List<ThirdAliDrug> resultList = new ArrayList<>();
|
|
|
|
|
AlihealthKytDrugrescodeReqeust drugRequest = request.getAlihealthKytDrugrescodeReqeust();
|
|
|
|
|
String originalName = drugRequest.getPhysic_name();
|
|
|
|
|
|
|
|
|
|
// 尝试原始名称
|
|
|
|
|
BaseResponse<List<ThirdAliDrug>> listBaseResponse = tryInsertAndCollect(request, resultList);
|
|
|
|
|
|
|
|
|
|
// 处理括号转换
|
|
|
|
|
if (containsBrackets(originalName)) {
|
|
|
|
|
String convertedName = convertBrackets(originalName);
|
|
|
|
|
drugRequest.setPhysic_name(convertedName);
|
|
|
|
|
AlihealthThirdAliDrugInsertReqeust tempRequest = new AlihealthThirdAliDrugInsertReqeust();
|
|
|
|
|
BeanUtils.copyProperties(request, tempRequest);
|
|
|
|
|
tempRequest.getAlihealthKytDrugrescodeReqeust().setPhysic_name(convertedName);
|
|
|
|
|
listBaseResponse = tryInsertAndCollect(tempRequest, resultList);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理罗马数字转换
|
|
|
|
|
if (containsRomanNumerals(originalName)) {
|
|
|
|
|
String convertedName = convertRomanNumerals(originalName);
|
|
|
|
|
drugRequest.setPhysic_name(convertedName);
|
|
|
|
|
AlihealthThirdAliDrugInsertReqeust tempRequest = new AlihealthThirdAliDrugInsertReqeust();
|
|
|
|
|
BeanUtils.copyProperties(request, tempRequest);
|
|
|
|
|
tempRequest.getAlihealthKytDrugrescodeReqeust().setPhysic_name(convertedName);
|
|
|
|
|
listBaseResponse = tryInsertAndCollect(tempRequest, resultList);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 设置结果
|
|
|
|
|
if (!resultList.isEmpty()) {
|
|
|
|
|
ResultVOAliUtils.success(resultList);
|
|
|
|
|
}
|
|
|
|
|
return listBaseResponse;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 辅助方法
|
|
|
|
|
private boolean containsBrackets(String name) {
|
|
|
|
|
return name.contains("(") || name.contains("（");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private String convertBrackets(String name) {
|
|
|
|
|
if (name.contains("(")) {
|
|
|
|
|
return name.replace("(", "（").replace(")", "）");
|
|
|
|
|
} else {
|
|
|
|
|
return name.replace("（", "(").replace("）", ")");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private boolean containsRomanNumerals(String name) {
|
|
|
|
|
return name.contains("Ⅰ") || name.contains("I")
|
|
|
|
|
|| name.contains("Ⅱ") || name.contains("II")
|
|
|
|
|
|| name.contains("Ⅲ") || name.contains("III");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private String convertRomanNumerals(String name) {
|
|
|
|
|
if (name.contains("Ⅰ") || name.contains("Ⅱ") || name.contains("Ⅲ")) {
|
|
|
|
|
return name.replace("Ⅰ", "I")
|
|
|
|
|
.replace("Ⅱ", "II")
|
|
|
|
|
.replace("Ⅲ", "III");
|
|
|
|
|
} else {
|
|
|
|
|
return name.replace("I", "Ⅰ")
|
|
|
|
|
.replace("II", "Ⅱ")
|
|
|
|
|
.replace("III", "Ⅲ");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private BaseResponse<List<ThirdAliDrug>> tryInsertAndCollect(
|
|
|
|
|
AlihealthThirdAliDrugInsertReqeust request,
|
|
|
|
|
List<ThirdAliDrug> resultList) {
|
|
|
|
|
AlihealthThirdAliDrugInsertReqeust alihealthThirdAliDrugInsertReqeust = new AlihealthThirdAliDrugInsertReqeust();
|
|
|
|
|
BeanUtil.copyProperties(request, alihealthThirdAliDrugInsertReqeust);
|
|
|
|
|
BaseResponse<List<ThirdAliDrug>> response = thirdAliDrugInsert(alihealthThirdAliDrugInsertReqeust);
|
|
|
|
|
if (response.getCode() == 20000 && response.getData() != null) {
|
|
|
|
|
resultList.addAll(response.getData());
|
|
|
|
|
}
|
|
|
|
|
return response;
|
|
|
|
|
}
|
|
|
|
|
@Resource
|
|
|
|
|
private AuthAliUserService authAliUserService;
|
|
|
|
|
/**
|
|
|
|
|
* 查询药品码段信息
|
|
|
|
|
*
|
|
|
|
|
* @param alihealthThirdAliDrugInsertReqeust
|
|
|
|
|
*/
|
|
|
|
|
public BaseResponse<List<ThirdAliDrug>> thirdAliDrugInsert(AlihealthThirdAliDrugInsertReqeust alihealthThirdAliDrugInsertReqeust) {
|
|
|
|
|
if (alihealthThirdAliDrugInsertReqeust.getAlihealthKytDrugrescodeReqeust() == null) {
|
|
|
|
|
return ResultVOAliUtils.error("入参不能为空");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
AlihealthKytDrugrescodeResponse alihealthKytDrugrescodeResponse = null;
|
|
|
|
|
AlihealthKytDrugrescodeReqeust alihealthKytDrugrescodeReqeust = alihealthThirdAliDrugInsertReqeust.getAlihealthKytDrugrescodeReqeust();
|
|
|
|
|
// key组装
|
|
|
|
|
AuthAliUser authAliUser = authAliUserService.getOne();
|
|
|
|
|
alihealthThirdAliDrugInsertReqeust.setErpId(authAliUser.getErpid());
|
|
|
|
|
alihealthThirdAliDrugInsertReqeust.setAppSecret(authAliUser.getAppsecret());
|
|
|
|
|
alihealthKytDrugrescodeReqeust.setApp_key(authAliUser.getAppkey());
|
|
|
|
|
alihealthKytDrugrescodeReqeust.setRef_ent_id(authAliUser.getRefentid());
|
|
|
|
|
alihealthKytDrugrescodeReqeust.setPage_size(100);
|
|
|
|
|
alihealthKytDrugrescodeReqeust.setPage(1);
|
|
|
|
|
if (alihealthKytDrugrescodeReqeust != null
|
|
|
|
|
&& StringUtils.isNotEmpty(alihealthKytDrugrescodeReqeust.getApp_key())
|
|
|
|
|
&& StringUtils.isNotEmpty(alihealthThirdAliDrugInsertReqeust.getAppSecret())
|
|
|
|
|
) {
|
|
|
|
|
try {
|
|
|
|
|
Thread.sleep(600);
|
|
|
|
|
AlihealthKytDrugrescodeReqeust alihealthKytDrugrescodeReqeustNew = new AlihealthKytDrugrescodeReqeust();
|
|
|
|
|
BeanUtils.copyProperties(alihealthKytDrugrescodeReqeust,alihealthKytDrugrescodeReqeustNew);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Map map = disposeSign(alihealthKytDrugrescodeReqeustNew, alihealthThirdAliDrugInsertReqeust.getAppSecret());
|
|
|
|
|
String json = HttpUtil.get(alihealthUrl, map);
|
|
|
|
|
log.error("阿里健康接口调用结果===" + json);
|
|
|
|
|
alihealthKytDrugrescodeResponse = new AlihealthKytDrugrescodeResponse(json);
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
return ResultVOAliUtils.error("阿里健康接口调用失败===" + e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
return ResultVOAliUtils.error("阿里健康接口调用失败===用户找不到或者key和秘钥为空");
|
|
|
|
|
}
|
|
|
|
|
String physicName = alihealthKytDrugrescodeReqeust.getPhysic_name();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (alihealthKytDrugrescodeResponse.judgeCall()) {
|
|
|
|
|
List<ThirdAliDrug> listNew = alihealthKytDrugrescodeResponse.disposeThirdAliDrugList(alihealthThirdAliDrugInsertReqeust.getErpId());
|
|
|
|
|
return ResultVOAliUtils.success(listNew);
|
|
|
|
|
} else {
|
|
|
|
|
//
|
|
|
|
|
// // 重新上传标识为true就改变一下
|
|
|
|
|
// if ("未查询到相关信息".equals(alihealthKytDrugrescodeResponse.getMsg_info())
|
|
|
|
|
// && callBool && (physicName.contains("(") || physicName.contains("（"))) {
|
|
|
|
|
// if (physicName.contains("(")) {
|
|
|
|
|
// physicName = physicName.replace("(", "（").replace(")", "）");
|
|
|
|
|
//
|
|
|
|
|
// } else if (physicName.contains("（")) {
|
|
|
|
|
// physicName = physicName.replace("（", "(").replace("）", ")");
|
|
|
|
|
//
|
|
|
|
|
// }
|
|
|
|
|
// alihealthKytDrugrescodeReqeust.setPhysic_name(physicName);
|
|
|
|
|
// alihealthThirdAliDrugInsertReqeust.setAlihealthKytDrugrescodeReqeust(alihealthKytDrugrescodeReqeust);
|
|
|
|
|
// thirdAliDrugInsert(alihealthThirdAliDrugInsertReqeust, false);
|
|
|
|
|
// }
|
|
|
|
|
return ResultVOAliUtils.error("阿里健康接口调用失败===" + alihealthKytDrugrescodeResponse.getMsg_info());
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// if(physicName.equals("(")){
|
|
|
|
|
// thirdAliDrugInsert();
|
|
|
|
|
// }
|
|
|
|
|
// if(physicName.equals("")){
|
|
|
|
|
// thirdAliDrugInsert();
|
|
|
|
|
// }
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public Map disposeSign(AlihealthKytCommonParametersReqeust alihealthKytCommonParametersReqeust, String secret) {
|
|
|
|
|
alihealthKytCommonParametersReqeust.setTimestamp(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
|
|
|
|
Map<String, Object> map = BeanUtil.beanToMap(alihealthKytCommonParametersReqeust);
|
|
|
|
|
String sign;
|
|
|
|
|
try {
|
|
|
|
|
sign = this.signTopRequest(map, secret, "md5");
|
|
|
|
|
log.info("sign====" + sign);
|
|
|
|
|
alihealthKytCommonParametersReqeust.setSign(sign);
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
return BeanUtil.beanToMap(alihealthKytCommonParametersReqeust);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public String signTopRequest(Map<String, Object> params, String secret, String signMethod) throws IOException {
|
|
|
|
|
// 第一步：检查参数是否已经排序
|
|
|
|
|
String[] keys = params.keySet().toArray(new String[0]);
|
|
|
|
|
Arrays.sort(keys);
|
|
|
|
|
|
|
|
|
|
// 第二步：把所有参数名和参数值串在一起
|
|
|
|
|
StringBuilder query = new StringBuilder();
|
|
|
|
|
if (AliConstants.SIGN_METHOD_MD5.equals(signMethod)) { //签名的摘要算法，可选值为：hmac，md5，hmac-sha256
|
|
|
|
|
query.append(secret);
|
|
|
|
|
}
|
|
|
|
|
for (String key : keys) {
|
|
|
|
|
Object value = params.get(key);
|
|
|
|
|
if (value instanceof String) {
|
|
|
|
|
if (StringUtils.isNotEmpty(key) && StringUtils.isNotEmpty((CharSequence) value)) {
|
|
|
|
|
query.append(key).append(value);
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
if (StringUtils.isNotEmpty(key) && !Objects.isNull(value)) {
|
|
|
|
|
query.append(key).append(value);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// StringUtils.areNotEmpty(key, value)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 第三步：使用MD5/HMAC加密
|
|
|
|
|
byte[] bytes;
|
|
|
|
|
if (AliConstants.SIGN_METHOD_HMAC.equals(signMethod)) {
|
|
|
|
|
bytes = encryptHMAC(query.toString(), secret);
|
|
|
|
|
} else {
|
|
|
|
|
query.append(secret);
|
|
|
|
|
bytes = encryptMD5(query.toString());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 第四步：把二进制转化为大写的十六进制(正确签名应该为32大写字符串，此方法需要时使用)
|
|
|
|
|
return byte2hex(bytes);
|
|
|
|
|
}
|
|
|
|
|
public static String byte2hex(byte[] bytes) {
|
|
|
|
|
StringBuilder sign = new StringBuilder();
|
|
|
|
|
|
|
|
|
|
for(int i = 0; i < bytes.length; ++i) {
|
|
|
|
|
String hex = Integer.toHexString(bytes[i] & 255);
|
|
|
|
|
if (hex.length() == 1) {
|
|
|
|
|
sign.append("0");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
sign.append(hex.toUpperCase());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return sign.toString();
|
|
|
|
|
}
|
|
|
|
|
public byte[] encryptHMAC(String data, String secret) throws IOException {
|
|
|
|
|
byte[] bytes = null;
|
|
|
|
|
try {
|
|
|
|
|
SecretKey secretKey = new SecretKeySpec(secret.getBytes(AliConstants.CHARSET_UTF8), "HmacMD5");
|
|
|
|
|
Mac mac = Mac.getInstance(secretKey.getAlgorithm());
|
|
|
|
|
mac.init(secretKey);
|
|
|
|
|
bytes = mac.doFinal(data.getBytes(AliConstants.CHARSET_UTF8));
|
|
|
|
|
} catch (GeneralSecurityException gse) {
|
|
|
|
|
throw new IOException(gse.toString());
|
|
|
|
|
}
|
|
|
|
|
return bytes;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public byte[] encryptMD5(String data) throws IOException {
|
|
|
|
|
return encryptMD5(data.getBytes(AliConstants.CHARSET_UTF8));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public byte[] encryptMD5(byte[] data) throws IOException {
|
|
|
|
|
byte[] bytes = null;
|
|
|
|
|
try {
|
|
|
|
|
MessageDigest md = MessageDigest.getInstance("MD5");
|
|
|
|
|
bytes = md.digest(data);
|
|
|
|
|
} catch (GeneralSecurityException gse) {
|
|
|
|
|
throw new IOException(gse.toString());
|
|
|
|
|
}
|
|
|
|
|
return bytes;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
qiuyt
3 months ago