From f168f7760569676f812c3176376cda081d546606 Mon Sep 17 00:00:00 2001 From: qiuyt Date: Sat, 4 Jan 2025 19:27:51 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=B7=E8=B4=9D=E9=98=BF=E9=87=8C=E8=B0=83?= =?UTF-8?q?=E7=94=A8=E8=8D=AF=E5=93=81=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E5=88=B0=E5=9B=BD=E5=AE=B6=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../udidl/admin/constant/AliConstants.java | 66 ++++ .../udidl/admin/dao/auth/AuthAliUserDao.java | 9 + .../udidl/admin/entity/auth/AuthAliUser.java | 40 +++ .../AlihealthKytCommonParametersReqeust.java | 53 +++ .../AlihealthKytDrugrescodeReqeust.java | 23 ++ .../AlihealthThirdAliDrugInsertReqeust.java | 14 + .../AlihealthKytCommonParametersResponse.java | 21 ++ .../AlihealthKytDrugrescodeResponse.java | 135 ++++++++ .../service/auth/AuthAliUserService.java | 26 ++ .../service/collect/ThirdAliDrugService.java | 25 +- .../udidl/admin/util/ResultVOAliUtils.java | 129 ++++++++ .../admin/util/alihealth/AlihealthUtils.java | 311 ++++++++++++++++++ src/main/resources/application-dev.yml | 2 +- .../mybatis/mapper/auth/AuthAliUserDao.xml | 10 + src/main/resources/schemas/schema_v2.1.sql | 17 + 15 files changed, 879 insertions(+), 2 deletions(-) create mode 100644 src/main/java/com/glxp/udidl/admin/constant/AliConstants.java create mode 100644 src/main/java/com/glxp/udidl/admin/dao/auth/AuthAliUserDao.java create mode 100644 src/main/java/com/glxp/udidl/admin/entity/auth/AuthAliUser.java create mode 100644 src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytCommonParametersReqeust.java create mode 100644 src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytDrugrescodeReqeust.java create mode 100644 src/main/java/com/glxp/udidl/admin/req/alihealth/local/AlihealthThirdAliDrugInsertReqeust.java create mode 100644 src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytCommonParametersResponse.java create mode 100644 src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytDrugrescodeResponse.java create mode 100644 src/main/java/com/glxp/udidl/admin/service/auth/AuthAliUserService.java create mode 100644 src/main/java/com/glxp/udidl/admin/util/ResultVOAliUtils.java create mode 100644 src/main/java/com/glxp/udidl/admin/util/alihealth/AlihealthUtils.java create mode 100644 src/main/resources/mybatis/mapper/auth/AuthAliUserDao.xml diff --git a/src/main/java/com/glxp/udidl/admin/constant/AliConstants.java b/src/main/java/com/glxp/udidl/admin/constant/AliConstants.java new file mode 100644 index 0000000..70ac94a --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/constant/AliConstants.java @@ -0,0 +1,66 @@ +package com.glxp.udidl.admin.constant; + +public class AliConstants { + public static final String APP_KEY = "app_key"; + public static final String FORMAT = "format"; + public static final String METHOD = "method"; + public static final String TIMESTAMP = "timestamp"; + public static final String VERSION = "v"; + public static final String SIGN = "sign"; + public static final String SIGN_METHOD = "sign_method"; + public static final String PARTNER_ID = "partner_id"; + public static final String SESSION = "session"; + public static final String SIMPLIFY = "simplify"; + public static final String TARGET_APP_KEY = "target_app_key"; + public static final String ERROR_RESPONSE = "error_response"; + public static final String ERROR_CODE = "code"; + public static final String ERROR_MSG = "msg"; + public static final String ERROR_SUB_CODE = "sub_code"; + public static final String ERROR_SUB_MSG = "sub_msg"; + public static final String QIMEN_CLOUD_ERROR_RESPONSE = "response"; + public static final String QM_ROOT_TAG = "request"; + public static final String QM_CUSTOMER_ID = "customerId"; + public static final String QM_CONTENT_TYPE = "text/xml;charset=utf-8"; + public static final String QM_CONTENT_TYPE_JSON = "application/json;charset=utf-8"; + public static final String DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss"; + public static final String DATE_TIMEZONE = "GMT+8"; + public static final String CHARSET_UTF8 = "UTF-8"; + public static final String METHOD_POST = "POST"; + public static final String METHOD_GET = "GET"; + public static final String CTYPE_FORM_DATA = "application/x-www-form-urlencoded"; + public static final String CTYPE_FILE_UPLOAD = "multipart/form-data"; + public static final String CTYPE_TEXT_XML = "text/xml"; + public static final String CTYPE_APPLICATION_XML = "application/xml"; + public static final String CTYPE_TEXT_PLAIN = "text/plain"; + public static final String CTYPE_APP_JSON = "application/json"; + public static final String CHARSET_GBK = "GBK"; + public static final String FORMAT_JSON = "json"; + public static final String FORMAT_XML = "xml"; + public static final String FORMAT_JSON2 = "json2"; + public static final String FORMAT_XML2 = "xml2"; + public static final String SIGN_METHOD_MD5 = "md5"; + public static final String SIGN_METHOD_HMAC = "hmac"; + public static final String SIGN_METHOD_HMAC_SHA256 = "hmac-sha256"; + public static final String SDK_VERSION = "top-sdk-java-20201231"; + public static final String SDK_VERSION_CLUSTER = "top-sdk-java-cluster-20201231"; + public static final String SDK_VERSION_HTTPDNS = "top-sdk-java-httpdns-20201231"; + public static final String QIMEN_SDK_VERSION_HTTPDNS = "top-qimen-sdk-java-httpdns"; + public static final String ACCEPT_ENCODING = "Accept-Encoding"; + public static final String CONTENT_ENCODING = "Content-Encoding"; + public static final String CONTENT_ENCODING_GZIP = "gzip"; + public static final String MIME_TYPE_DEFAULT = "application/octet-stream"; + public static final int READ_BUFFER_SIZE = 4096; + public static final String TOP_HTTP_DNS_HOST = "TOP_HTTP_DNS_HOST"; + public static final String CONTENT_TYPE_XML = "xml"; + public static final String CONTENT_TYPE_JSON = "json"; + public static final String CONTENT_TYPE_FORM = "form"; + public static final String RESPONSE_TYPE_TOP = "top"; + public static final String RESPONSE_TYPE_QIMEN = "qimen1"; + public static final String RESPONSE_TYPE_QIMEN2 = "qimen2"; + public static final String RESPONSE_TYPE_DINGTALK_OAPI = "dingtalk"; + public static final String CALL_TYPE_TOP = "top"; + public static final String CALL_TYPE_OAPI = "oapi"; + + public AliConstants() { + } +} diff --git a/src/main/java/com/glxp/udidl/admin/dao/auth/AuthAliUserDao.java b/src/main/java/com/glxp/udidl/admin/dao/auth/AuthAliUserDao.java new file mode 100644 index 0000000..5e97294 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/dao/auth/AuthAliUserDao.java @@ -0,0 +1,9 @@ +package com.glxp.udidl.admin.dao.auth; + + +import com.glxp.udidl.admin.dao.BaseMapperPlus; +import com.glxp.udidl.admin.entity.auth.AuthAliUser; + +public interface AuthAliUserDao extends BaseMapperPlus { + +} diff --git a/src/main/java/com/glxp/udidl/admin/entity/auth/AuthAliUser.java b/src/main/java/com/glxp/udidl/admin/entity/auth/AuthAliUser.java new file mode 100644 index 0000000..dfea7ff --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/entity/auth/AuthAliUser.java @@ -0,0 +1,40 @@ +package com.glxp.udidl.admin.entity.auth; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +@TableName("auth_ali_user") +@Data +public class AuthAliUser { + private Long id; + + /** + * 第三方ID + */ + @TableField(value = "erpid") + private String erpid; + + /** + * 阿里KEY + */ + @TableField(value = "appkey") + private String appkey; + /** + * 阿里密钥 + */ + @TableField(value = "appsecret") + private String appsecret; + /** + * 厂家标识 + */ + @TableField(value = "refentid") + private String refentid; + + /** + * 1 为生成企业 2为零售药店 + */ + @TableField(value = "type") + private String type; +} diff --git a/src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytCommonParametersReqeust.java b/src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytCommonParametersReqeust.java new file mode 100644 index 0000000..bb1fe09 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytCommonParametersReqeust.java @@ -0,0 +1,53 @@ +package com.glxp.udidl.admin.req.alihealth; + +import lombok.Data; + +/** + * 基础参数 + */ +@Data +public class AlihealthKytCommonParametersReqeust { + /** + * API接口名称 + */ + private String method; + /** + * key + */ + private String app_key; + /** + * 授权 + */ + private String session; + /** + * 时间 + */ + private String timestamp; + /** + * 版本号 + */ + private String v; + /** + * 签名的摘要算法 + */ + private String sign_method; + /** + * 签名的摘要算法 + */ + private String sign; + /** + * 响应格式 + */ + private String format; +// /** +// * 精简开关 +// */ +// private boolean simplify; + public AlihealthKytCommonParametersReqeust(){ + this.v = "2.0"; + this.sign_method = "md5"; + this.format = "json"; + + } + +} diff --git a/src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytDrugrescodeReqeust.java b/src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytDrugrescodeReqeust.java new file mode 100644 index 0000000..1ba5e34 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/req/alihealth/AlihealthKytDrugrescodeReqeust.java @@ -0,0 +1,23 @@ +package com.glxp.udidl.admin.req.alihealth; + +import lombok.Data; + +@Data +public class AlihealthKytDrugrescodeReqeust extends AlihealthKytCommonParametersReqeust { + private String ref_ent_id; + private String physic_name; + private String approval_licence_no; + private String start_date; + private String end_date; + private String ent_name; + private String package_spec; + + private String prepn_spec; + private Integer page_size; + private Integer page; + + + public AlihealthKytDrugrescodeReqeust(){ + this.setMethod("alibaba.alihealth.drug.kyt.drugrescode"); + } +} diff --git a/src/main/java/com/glxp/udidl/admin/req/alihealth/local/AlihealthThirdAliDrugInsertReqeust.java b/src/main/java/com/glxp/udidl/admin/req/alihealth/local/AlihealthThirdAliDrugInsertReqeust.java new file mode 100644 index 0000000..e8f00d8 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/req/alihealth/local/AlihealthThirdAliDrugInsertReqeust.java @@ -0,0 +1,14 @@ +package com.glxp.udidl.admin.req.alihealth.local; + +import com.glxp.udidl.admin.req.alihealth.AlihealthKytDrugrescodeReqeust; +import lombok.Data; + +@Data +public class AlihealthThirdAliDrugInsertReqeust { + private String erpId; + private String appSecret; + private String manufactory; + private Boolean gjkSwitch = true; + + private AlihealthKytDrugrescodeReqeust alihealthKytDrugrescodeReqeust; +} diff --git a/src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytCommonParametersResponse.java b/src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytCommonParametersResponse.java new file mode 100644 index 0000000..528b3d7 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytCommonParametersResponse.java @@ -0,0 +1,21 @@ +package com.glxp.udidl.admin.res.alihealth; + +import lombok.Data; +import org.apache.commons.lang3.StringUtils; + +@Data +public class AlihealthKytCommonParametersResponse { + + private String msg_code; + private String msg_info; + private String response_success; + + + public boolean judgeCall(){ + if(StringUtils.isNotEmpty(this.getMsg_info()) && this.getMsg_info().equals("调用成功")){ + return true; + } + return false; + } + +} diff --git a/src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytDrugrescodeResponse.java b/src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytDrugrescodeResponse.java new file mode 100644 index 0000000..2a4ffce --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/res/alihealth/AlihealthKytDrugrescodeResponse.java @@ -0,0 +1,135 @@ +package com.glxp.udidl.admin.res.alihealth; + +import cn.hutool.json.JSONArray; +import cn.hutool.json.JSONObject; +import cn.hutool.json.JSONUtil; +import com.glxp.udidl.admin.entity.collect.ThirdAliDrug; +import lombok.Data; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.BeanUtils; + +import java.util.ArrayList; +import java.util.Date; +import java.util.List; +import java.util.Objects; + +@Data +public class AlihealthKytDrugrescodeResponse extends AlihealthKytCommonParametersResponse { + private Integer total_num; + private JSONArray drug_table_dto; + private Integer page; + private Integer page_size; + public boolean judgeCall(String manufactory){ + boolean bo = false; + + if(StringUtils.isNotEmpty(manufactory)){ + List jsonArray = (List) this.getDrug_table_dto(); + if (jsonArray != null && jsonArray.size() > 0) { + for (JSONObject jsonObject : jsonArray) { + String entName = jsonObject.getStr("ent_name"); + if(manufactory.replaceAll("\\(", "（").replace(")", "）") + .equals(entName.replaceAll("\\(", "（").replace(")", "）"))){ + bo = true; + } + } + } + }else { + bo = true; + } + + if(StringUtils.isNotEmpty(this.getMsg_info()) && this.getMsg_info().equals("调用成功") && bo){ + return true; + } + return false; + } + public AlihealthKytDrugrescodeResponse(String json) { + // 初始化请求的值 + JSONObject jsonObject = JSONUtil.parseObj(json); + JSONObject jsonObjectResult = null; + for (String s : jsonObject.keySet()) { + jsonObjectResult = jsonObject.getJSONObject(s).getJSONObject("result"); + + } + + AlihealthKytCommonParametersResponse alihealthKytCommonParametersResponse = JSONUtil.toBean(jsonObjectResult.toString(), + AlihealthKytCommonParametersResponse.class); + BeanUtils.copyProperties(alihealthKytCommonParametersResponse, this); + if (StringUtils.isNotEmpty(this.getMsg_info()) + && this.getMsg_info().equals("调用成功") + ) { + this.disposeResult(jsonObjectResult); + } + + } + + public void disposeResult(JSONObject jsonObjectResult) { + JSONObject jsonObjectModel = jsonObjectResult.getJSONObject("model"); + if (!Objects.isNull(jsonObjectModel)) { + this.setTotal_num(jsonObjectModel.getInt("total_num")); + this.setDrug_table_dto(jsonObjectModel.getJSONObject("result_list").getJSONArray("drug_table_dto")); + this.setPage(jsonObjectModel.getInt("page")); + this.setPage_size(jsonObjectModel.getInt("page_size")); + + } + } + + public List disposeThirdAliDrugList(String erpId) { + List list = new ArrayList<>(); + List jsonArray = (List) this.getDrug_table_dto(); + if (jsonArray != null && jsonArray.size() > 0) { + for (JSONObject jsonObject : jsonArray) { + if (!Objects.isNull(jsonObject)) { + ThirdAliDrug thirdAliDrugShare = new ThirdAliDrug(); +// thirdAliDrug.setId(); + thirdAliDrugShare.setType(jsonObject.getStr("physic_type")); + thirdAliDrugShare.setManufacturer(jsonObject.getStr("ent_name")); + thirdAliDrugShare.setCpmctymc(jsonObject.getStr("physic_name").trim()); + thirdAliDrugShare.setForm(jsonObject.getStr("prepn_type_desc")); + thirdAliDrugShare.setSpmc(jsonObject.getStr("prod_name")); + thirdAliDrugShare.setErpId(erpId); + thirdAliDrugShare.setCreateTime(new Date()); + thirdAliDrugShare.setUpdateTime(new Date()); + + thirdAliDrugShare.setPhysicDetailType(jsonObject.getStr("physic_detail_type")); + thirdAliDrugShare.setPhysicDetailTypeDesc(jsonObject.getStr("physic_detail_type_desc")); + thirdAliDrugShare.setPhysicTypeDesc(jsonObject.getStr("physic_type_desc")); + // 阿里额外的字段 prepn_unit prepn_unit_name physic_detail_type physic_detail_type_desc physic_type_desc + ; + List jsonArraySubType = (List) jsonObject.getJSONObject("sub_type_list").getJSONArray("sub_type_list"); + if (jsonArraySubType != null && jsonArraySubType.size() > 0) { + for (JSONObject oubType : jsonArraySubType) { + ThirdAliDrug thirdAliDrugShareTwo = new ThirdAliDrug(); + BeanUtils.copyProperties(thirdAliDrugShare,thirdAliDrugShareTwo); + thirdAliDrugShareTwo.setFormSpec(oubType.getStr("prepn_spec")); + thirdAliDrugShareTwo.setBzgg(oubType.getStr("package_spec")); + thirdAliDrugShareTwo.setApprovalNum(oubType.getStr("approve_no").trim()); + + thirdAliDrugShareTwo.setPrepnUnit(oubType.getStr("prepn_unit")); + thirdAliDrugShareTwo.setPrepnUnitName(oubType.getStr("prepn_unit_name")); + thirdAliDrugShareTwo.setPackUnitName(oubType.getStr("pack_unit_name")); + + + if (oubType.containsKey("code_res_list")) { + JSONObject jsonObjectCodeRes = oubType.getJSONObject("code_res_list"); + if(jsonObjectCodeRes.containsKey("code_res_list")){ + List codeReslist = (List) jsonObjectCodeRes.getJSONArray("code_res_list"); + for (JSONObject codeRes : codeReslist) { + ThirdAliDrug thirdAliDrug = new ThirdAliDrug(); + BeanUtils.copyProperties(thirdAliDrugShareTwo,thirdAliDrug); + // 码有值才加入 + thirdAliDrug.setNameCode(codeRes.getStr("res_code")); + thirdAliDrug.setPackRatio(codeRes.getStr("pkg_ratio")); + thirdAliDrug.setPackLevel(StringUtils.isEmpty(codeRes.getStr("code_level")) ? null: codeRes.getStr("code_level")); + list.add(thirdAliDrug); + } + } + + } + } + } + } + } + } + return list; + } +} diff --git a/src/main/java/com/glxp/udidl/admin/service/auth/AuthAliUserService.java b/src/main/java/com/glxp/udidl/admin/service/auth/AuthAliUserService.java new file mode 100644 index 0000000..4a7e826 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/service/auth/AuthAliUserService.java @@ -0,0 +1,26 @@ +package com.glxp.udidl.admin.service.auth; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; + +import com.glxp.udidl.admin.dao.auth.AuthAliUserDao; +import com.glxp.udidl.admin.entity.auth.AuthAliUser; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +@Service +public class AuthAliUserService extends ServiceImpl { + @Resource + private AuthAliUserDao authAliUserDao; + public AuthAliUser getOne(){ + AuthAliUser authAliUser = this.getOne(new QueryWrapper() + .last("limit 1") + ); + if(authAliUser == null){ + authAliUser = new AuthAliUser(); + } + return authAliUser; + } + +} diff --git a/src/main/java/com/glxp/udidl/admin/service/collect/ThirdAliDrugService.java b/src/main/java/com/glxp/udidl/admin/service/collect/ThirdAliDrugService.java index c526fdd..7dd5826 100644 --- a/src/main/java/com/glxp/udidl/admin/service/collect/ThirdAliDrugService.java +++ b/src/main/java/com/glxp/udidl/admin/service/collect/ThirdAliDrugService.java @@ -8,10 +8,16 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.pagehelper.PageHelper; import com.glxp.udidl.admin.dao.collect.ThirdAliDrugMapper; import com.glxp.udidl.admin.entity.collect.ThirdAliDrug; +import com.glxp.udidl.admin.req.alihealth.AlihealthKytDrugrescodeReqeust; +import com.glxp.udidl.admin.req.alihealth.local.AlihealthThirdAliDrugInsertReqeust; import com.glxp.udidl.admin.req.collect.ThirdAliDrugAddRequest; import com.glxp.udidl.admin.req.collect.ThirdAliDrugRequest; +import com.glxp.udidl.admin.res.BaseResponse; +import com.glxp.udidl.admin.util.alihealth.AlihealthUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; + +import javax.annotation.Resource; import java.util.*; import java.util.stream.Collectors; @@ -66,6 +72,8 @@ public class ThirdAliDrugService extends ServiceImpl groupedByCpmctymc = this.baseMapper.groupByCpmctymc(); @@ -76,7 +84,22 @@ public class ThirdAliDrugService extends ServiceImpl add = new ArrayList<>(); + List add = null; + AlihealthThirdAliDrugInsertReqeust request = new AlihealthThirdAliDrugInsertReqeust(); + AlihealthKytDrugrescodeReqeust alihealthKytDrugrescodeReqeust = new AlihealthKytDrugrescodeReqeust(); + alihealthKytDrugrescodeReqeust.setPhysic_name(cpmctymc); + request.setAlihealthKytDrugrescodeReqeust(alihealthKytDrugrescodeReqeust); + try { + BaseResponse> baseResponse = alihealthUtils.thirdAliDrugInsertAll(request); + if(baseResponse.getCode() == 20000){ + add = baseResponse.getData(); + }else { + log.error("阿里访问失败==="+baseResponse.getMessage()); + } + }catch (Exception e){ + log.error("阿里访问失败==="+e.getMessage()); + } + thirdAliDrugAddRequest.setList(add); this.addThirdAliDrug(thirdAliDrugAddRequest); diff --git a/src/main/java/com/glxp/udidl/admin/util/ResultVOAliUtils.java b/src/main/java/com/glxp/udidl/admin/util/ResultVOAliUtils.java new file mode 100644 index 0000000..87a207f --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/util/ResultVOAliUtils.java @@ -0,0 +1,129 @@ +package com.glxp.udidl.admin.util; + +import com.github.pagehelper.PageInfo; +import com.glxp.udidl.admin.enums.ResultEnum; +import com.glxp.udidl.admin.res.BaseResponse; +import com.glxp.udidl.admin.res.PageSimpleResponse; + +import java.util.HashMap; +import java.util.Map; + +/** + * 返回结果的操作类 + */ +public class ResultVOAliUtils { + + /** + * 成功时返回 + * + * @param data 返回的data对象 + * @return {@link BaseResponse} + */ + public static BaseResponse success(Object data) { + BaseResponse baseResponse = new BaseResponse<>(); + baseResponse.setCode(20000); + baseResponse.setMessage("success"); + baseResponse.setData(data); + return baseResponse; + } + + /** + * 成功时返回 + * + * @return {@link BaseResponse} + */ + public static BaseResponse success() { + Map data = new HashMap(); + return success(data); + } + + /** + * 成功时返回 + * + * @param data 返回的data对象 + * @return {@link BaseResponse} + */ + public static BaseResponse success(String msg, Object data) { + BaseResponse baseResponse = new BaseResponse<>(); + baseResponse.setCode(20000); + baseResponse.setMessage(msg); + baseResponse.setData(data); + return baseResponse; + } + + /** + * 成功时返回 + * + * @return {@link BaseResponse} + */ + public static BaseResponse successMsg(String message) { + BaseResponse baseResponse = new BaseResponse<>(); + baseResponse.setCode(20000); + baseResponse.setMessage(message); + Map data = new HashMap(); + baseResponse.setData(data); + return baseResponse; + } + + /** + * 错误时返回 + * + * @param code 错误码 + * @param message 错误信息 + * @return {@link BaseResponse} + */ + public static BaseResponse error(Integer code, String message) { + BaseResponse baseResponse = new BaseResponse<>(); + baseResponse.setCode(code); + baseResponse.setMessage(message); + Map data = new HashMap(); + baseResponse.setData(data); + return baseResponse; + } + + /** + * 错误时返回 + * + * @param resultEnum 错误枚举类 + * @return {@link BaseResponse} + */ + public static BaseResponse error(ResultEnum resultEnum) { + return error(resultEnum.getCode(), resultEnum.getMessage()); + } + + /** + * 错误时返回 + * + * @param resultEnum 错误枚举类 + * @param message 错误的信息 + * @return {@link BaseResponse} + */ + public static BaseResponse error(ResultEnum resultEnum, String message) { + return error(resultEnum.getCode(), message); + } + + /** + * 错误时返回 + * + * @param message 错误的信息 + * @return {@link BaseResponse} + */ + public static BaseResponse error(String message) { + return error(ResultEnum.NOT_NETWORK.getCode(), message); + } + + + /** + * 根据PageHelper分页对象，直接返回分页结果 + * + * @param pageInfo + * @return + */ + public static BaseResponse page(PageInfo pageInfo) { + PageSimpleResponse pageSimpleResponse = new PageSimpleResponse(); + pageSimpleResponse.setList(pageInfo.getList()); + pageSimpleResponse.setTotal(pageInfo.getTotal()); + return success(pageSimpleResponse); + } + +} diff --git a/src/main/java/com/glxp/udidl/admin/util/alihealth/AlihealthUtils.java b/src/main/java/com/glxp/udidl/admin/util/alihealth/AlihealthUtils.java new file mode 100644 index 0000000..1013ac4 --- /dev/null +++ b/src/main/java/com/glxp/udidl/admin/util/alihealth/AlihealthUtils.java @@ -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> thirdAliDrugInsertAll(AlihealthThirdAliDrugInsertReqeust request) { + // 初始化变量 + List resultList = new ArrayList<>(); + AlihealthKytDrugrescodeReqeust drugRequest = request.getAlihealthKytDrugrescodeReqeust(); + String originalName = drugRequest.getPhysic_name(); + + // 尝试原始名称 + BaseResponse> 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> tryInsertAndCollect( + AlihealthThirdAliDrugInsertReqeust request, + List resultList) { + AlihealthThirdAliDrugInsertReqeust alihealthThirdAliDrugInsertReqeust = new AlihealthThirdAliDrugInsertReqeust(); + BeanUtil.copyProperties(request, alihealthThirdAliDrugInsertReqeust); + BaseResponse> response = thirdAliDrugInsert(alihealthThirdAliDrugInsertReqeust); + if (response.getCode() == 20000 && response.getData() != null) { + resultList.addAll(response.getData()); + } + return response; + } + @Resource + private AuthAliUserService authAliUserService; + /** + * 查询药品码段信息 + * + * @param alihealthThirdAliDrugInsertReqeust + */ + public BaseResponse> 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 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 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 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; + } + + +} diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index 235f750..a7dea2e 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -4,7 +4,7 @@ spring: matching-strategy: ant_path_matcher datasource: driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://127.0.0.1:3306/udidl_test?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true + url: jdbc:mysql://192.168.0.43:3306/udidl_test?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true username: root password: 123456 hikari: diff --git a/src/main/resources/mybatis/mapper/auth/AuthAliUserDao.xml b/src/main/resources/mybatis/mapper/auth/AuthAliUserDao.xml new file mode 100644 index 0000000..d98110f --- /dev/null +++ b/src/main/resources/mybatis/mapper/auth/AuthAliUserDao.xml @@ -0,0 +1,10 @@ + + + + + + + id, erpId, appKey, appSecret, refEntId, `type` + + + diff --git a/src/main/resources/schemas/schema_v2.1.sql b/src/main/resources/schemas/schema_v2.1.sql index 407ec09..6e2225c 100644 --- a/src/main/resources/schemas/schema_v2.1.sql +++ b/src/main/resources/schemas/schema_v2.1.sql @@ -332,3 +332,20 @@ CALL Pro_Temp_ColumnWork('third_ali_drug', 'packUnitName', 1); INSERT IGNORE INTO `scheduled` (`id`, `cronName`, `cron`, `customerId`) VALUES (11, 'thirdAliDrugTask', '0 0 */2 * * ?', NULL); + +CREATE TABLE IF NOT EXISTS `auth_ali_user` +( + `id` bigint NOT NULL, + `erpId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '第三方ID', + `appKey` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '阿里KEY', + `appSecret` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '阿里密钥', + `refEntId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '厂家标识', + `type` varchar(255) DEFAULT NULL COMMENT '1 为生成企业 2为零售药店', + PRIMARY KEY (`id`) + ) ENGINE = InnoDB + DEFAULT CHARSET = utf8mb4 + COLLATE = utf8mb4_0900_ai_ci; + +INSERT IGNORE INTO `auth_ali_user` ( `id`, `erpId`, `appKey`, `appSecret`, `refEntId`, `type` ) +VALUES + ( 1, NULL, '31721223', '5231c601505706a9d49823c3dfe2cb01', 'ef99b78bd9c54c1284f813149c858fb0', NULL );