|
|
|
|
@ -1,4 +1,4 @@
|
|
|
|
|
package com.glxp.mipsdl.client.ctqyy;
|
|
|
|
|
package com.glxp.mipsdl.client.yxfy;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
|
@ -12,15 +12,14 @@ import com.alibaba.fastjson.JSONObject;
|
|
|
|
|
import com.alibaba.fastjson.TypeReference;
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
|
import com.baomidou.mybatisplus.core.enums.SqlLike;
|
|
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
import com.glxp.mipsdl.client.CommonHttpClient;
|
|
|
|
|
import com.glxp.mipsdl.client.ctqyy.entity.InvCodeResultEntity;
|
|
|
|
|
import com.glxp.mipsdl.client.ctqyy.entity.InvProjectResultEntity;
|
|
|
|
|
import com.glxp.mipsdl.client.ctqyy.entity.InvResultEntity;
|
|
|
|
|
import com.glxp.mipsdl.client.yxfy.entity.InvCodeResultEntity;
|
|
|
|
|
import com.glxp.mipsdl.client.yxfy.entity.InvProjectResultEntity;
|
|
|
|
|
import com.glxp.mipsdl.client.yxfy.entity.InvResultEntity;
|
|
|
|
|
import com.glxp.mipsdl.config.ThirdSysConfig;
|
|
|
|
|
import com.glxp.mipsdl.constant.BusTypeConstant;
|
|
|
|
|
import com.glxp.mipsdl.constant.ConstantType;
|
|
|
|
|
@ -36,9 +35,8 @@ import com.glxp.mipsdl.dao.thrsys.ThrSystemBusApiDao;
|
|
|
|
|
import com.glxp.mipsdl.entity.auth.AuthUserEntity;
|
|
|
|
|
import com.glxp.mipsdl.entity.auth.AuthWarehouseEntity;
|
|
|
|
|
import com.glxp.mipsdl.entity.basic.*;
|
|
|
|
|
import com.glxp.mipsdl.entity.ctqyy.*;
|
|
|
|
|
import com.glxp.mipsdl.entity.hyfy.*;
|
|
|
|
|
import com.glxp.mipsdl.entity.inout.*;
|
|
|
|
|
import com.glxp.mipsdl.entity.system.UdiEntity;
|
|
|
|
|
import com.glxp.mipsdl.entity.thrsys.*;
|
|
|
|
|
import com.glxp.mipsdl.http.HttpClient;
|
|
|
|
|
import com.glxp.mipsdl.req.base.*;
|
|
|
|
|
@ -51,7 +49,6 @@ import com.glxp.mipsdl.req.zzzyy.ZzzyyRequest;
|
|
|
|
|
import com.glxp.mipsdl.res.BaseResponse;
|
|
|
|
|
import com.glxp.mipsdl.res.PageSimpleResponse;
|
|
|
|
|
import com.glxp.mipsdl.res.ctqyy.CtBaseResponse;
|
|
|
|
|
import com.glxp.mipsdl.res.ctqyy.ThrOrderResponse;
|
|
|
|
|
import com.glxp.mipsdl.res.udiwms.*;
|
|
|
|
|
import com.glxp.mipsdl.service.auth.AuthWarehouseService;
|
|
|
|
|
import com.glxp.mipsdl.service.basic.RelCodeDetailService;
|
|
|
|
|
@ -72,18 +69,20 @@ import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
|
|
import java.time.LocalDateTime;
|
|
|
|
|
import java.time.format.DateTimeFormatter;
|
|
|
|
|
import java.text.SimpleDateFormat;
|
|
|
|
|
import java.util.*;
|
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
@Slf4j
|
|
|
|
|
@Service(value = "100011HttpClient")
|
|
|
|
|
public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
public class yxfyClient extends CommonHttpClient {
|
|
|
|
|
// 目前只有3505调通过上传医保 其他先不配置怕自动上传出问题
|
|
|
|
|
private final String[] buyType_3501 = {};
|
|
|
|
|
private final String[] buyType_3502 = { };
|
|
|
|
|
private final String[] buyType_3504 = { };
|
|
|
|
|
|
|
|
|
|
private final String[] buyType_3505 = {"QXCF001", "YPCF002"};
|
|
|
|
|
private final String[] buyType_35051 = {"SC72197936495755"};
|
|
|
|
|
private final String[] buyType_3506 = {};
|
|
|
|
|
@Resource
|
|
|
|
|
AuthWarehouseUserMapper authWarehouseUserMapper;
|
|
|
|
|
@ -187,7 +186,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
String message = document.getRootElement().element("message").getText();
|
|
|
|
|
return message;
|
|
|
|
|
} catch (DocumentException e) {
|
|
|
|
|
log.info("解析长泰区医院智业接口返回结果异常, 返回结果：{}", response);
|
|
|
|
|
log.info("解析云霄妇幼医院智业接口返回结果异常, 返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：", e);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
@ -207,7 +206,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰区医院智业接口返回往来单位字典数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业接口返回往来单位字典数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -226,7 +225,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰区医院智业接口返回生产企业字典数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业接口返回生产企业字典数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -269,7 +268,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
baseResponse.setData(map);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰区医院智业接口返回产品信息字典数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业接口返回产品信息字典数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -332,7 +331,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
pageSimpleResponse.setList(listNew);
|
|
|
|
|
return ResultVOUtils.success(pageSimpleResponse);
|
|
|
|
|
}
|
|
|
|
|
log.error("解析长泰区医院医疗类型，返回结果：{}", udiwmsProductRequest.getProductType());
|
|
|
|
|
log.error("解析云霄妇幼医院医疗类型，返回结果：{}", udiwmsProductRequest.getProductType());
|
|
|
|
|
return ResultVOUtils.error(500, "医疗类型不正确，productType：" + udiwmsProductRequest.getProductType());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -347,7 +346,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰区医院智业接口返回单据类型数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业接口返回单据类型数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -451,7 +450,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
baseResponse.setData(map);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰医院智业返回病人信息数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业返回病人信息数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -488,7 +487,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
baseResponse.setData(map);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰医院智业返回处方信息数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业返回处方信息数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -532,7 +531,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
baseResponse.setData(map);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰医院智业返回项目信息数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业返回项目信息数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -569,7 +568,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
baseResponse.setData(map);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰医院智业返回物价类别信息异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业返回物价类别信息异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -1327,7 +1326,7 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class);
|
|
|
|
|
return baseResponse;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("解析长泰区医院智业接口提交单据返回数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("解析云霄妇幼医院智业接口提交单据返回数据异常，返回结果：{}", response);
|
|
|
|
|
log.error("异常信息：{}", e);
|
|
|
|
|
return ResultVOUtils.error(500, "网络错误，或远程服务器异常无法返回正确结果（" + response + ")");
|
|
|
|
|
}
|
|
|
|
|
@ -1695,6 +1694,8 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
return optionUploadCollectOrder3502(ioCollectOrder);
|
|
|
|
|
} else if (matchBusType(busType, buyType_3505)) {
|
|
|
|
|
return optionUploadCollectOrder3505(ioCollectOrder);
|
|
|
|
|
} else if (matchBusType(busType, buyType_35051)) {
|
|
|
|
|
return optionUploadCollectOrder35051(ioCollectOrder);
|
|
|
|
|
} else if (matchBusType(busType, buyType_3506)) {
|
|
|
|
|
optionUploadCollectOrder3506(ioCollectOrder);
|
|
|
|
|
} else {
|
|
|
|
|
@ -2159,7 +2160,112 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
return ResultVOUtils.error(500,"上传医保数据为空请核实");
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
public BaseResponse optionUploadCollectOrder35051(IoCollectOrder ioCollectOrder) {
|
|
|
|
|
List<CollectOrderBizResponse> bizList = ioCollectOrder.getCollectOrderBizResponseList();
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(bizList)) {
|
|
|
|
|
List<Xsck35051Request> xsck35051Requests = new ArrayList<>();
|
|
|
|
|
for (CollectOrderBizResponse item : bizList) {
|
|
|
|
|
BasicUdirelEntity basicUdirelEntity = basicUdirelDao.selectById(item.getRelId());
|
|
|
|
|
String itemCode = basicUdirelEntity.getMainId();
|
|
|
|
|
// for (CollectOrderBizResponse item : collectOrderBizResponseList) {
|
|
|
|
|
// if (item.getYbbm().equals(itemCode)) {
|
|
|
|
|
String[] codes = item.getFinishUdiCode().split(",");
|
|
|
|
|
|
|
|
|
|
String nameCode = item.getNameCode();
|
|
|
|
|
BasicProductsEntity basicProductsEntity = basicProductsDao.selectOne(
|
|
|
|
|
new QueryWrapper<BasicProductsEntity>().eq("nameCode", nameCode).last("limit 1")
|
|
|
|
|
);
|
|
|
|
|
if (Objects.isNull(basicProductsEntity)) {
|
|
|
|
|
return ResultVOUtils.error(500, "产品为空请检查");
|
|
|
|
|
}
|
|
|
|
|
Integer packLevel = Integer.valueOf(basicProductsEntity.getPackLevel());
|
|
|
|
|
List<DrugInfoRequest> drugTraceList = new ArrayList<>();
|
|
|
|
|
List<String> codeList = new ArrayList<>();
|
|
|
|
|
// 遍历fruits数组
|
|
|
|
|
for (String code : codes) {
|
|
|
|
|
if (StrUtil.isNotBlank(code)) {
|
|
|
|
|
List<RelCodeDetail> relCodeDetailList = relCodeDetailService.getAllNext(code);
|
|
|
|
|
if (relCodeDetailList != null && relCodeDetailList.size() > 0) {
|
|
|
|
|
for (RelCodeDetail relCodeDetail : relCodeDetailList) {
|
|
|
|
|
codeList.add(relCodeDetail.getCurCode());
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
// 级别为2的产品码不可能只有一个
|
|
|
|
|
if (packLevel > 1 && codeList.size() < 2) {
|
|
|
|
|
return ResultVOUtils.error(500, "大包装码关联关系拉取不到请检查" + code);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
Set<String> set = new HashSet(codeList);
|
|
|
|
|
for (String code : set) {
|
|
|
|
|
DrugInfoRequest request = new DrugInfoRequest();
|
|
|
|
|
request.setDrug_trac_codg(code);
|
|
|
|
|
drugTraceList.add(request);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isEmpty(drugTraceList)) {
|
|
|
|
|
return ResultVOUtils.error(500, "单据要传的码为空请检查");
|
|
|
|
|
}
|
|
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
String formattedDate = sdf.format(ioCollectOrder.getBillTime());
|
|
|
|
|
//todo 处方药标志先写死 后面要商量怎么获得
|
|
|
|
|
String rxFlag ="1";
|
|
|
|
|
log.error("optionUploadCollectOrder35051===item==="+item);
|
|
|
|
|
Xsck35051Request xsck35051Request = Xsck35051Request.builder()
|
|
|
|
|
.med_list_codg(item.getYbbm())
|
|
|
|
|
.fixmedins_hilist_id(item.getNameCode())
|
|
|
|
|
.fixmedins_hilist_name(item.getCpmctymc())
|
|
|
|
|
.fixmedins_bchno(item.getOrderIdFk())
|
|
|
|
|
.prsc_dr_cert_type(null)
|
|
|
|
|
.prsc_dr_certno(null)
|
|
|
|
|
.prsc_dr_name(null)
|
|
|
|
|
.phar_cert_type(null)
|
|
|
|
|
.phar_certno(null)
|
|
|
|
|
.phar_name(null)
|
|
|
|
|
.phar_prac_cert_no(null)
|
|
|
|
|
.hi_feesetl_type(null)
|
|
|
|
|
.setl_id(null)
|
|
|
|
|
.mdtrt_sn(null)
|
|
|
|
|
.psn_no(null)
|
|
|
|
|
.psn_cert_type(null)
|
|
|
|
|
.certno(null)
|
|
|
|
|
.psn_name(null)
|
|
|
|
|
.manu_lotnum(item.getBatchNo())
|
|
|
|
|
.manu_date(DateUtil.timeTransition(item.getProductDate()))
|
|
|
|
|
.expy_end(DateUtil.timeTransition(item.getExpireDate()))
|
|
|
|
|
.rx_flag(rxFlag)
|
|
|
|
|
.trdn_flag(item.getTrdnFlag())
|
|
|
|
|
.finl_trns_pric(null)
|
|
|
|
|
.rxno(null)
|
|
|
|
|
.rx_circ_flag(null)
|
|
|
|
|
.rtal_docno(null)
|
|
|
|
|
.stoout_no(null)
|
|
|
|
|
.bchno(null)
|
|
|
|
|
.drug_prod_barc(null)
|
|
|
|
|
.shelf_posi(null)
|
|
|
|
|
.sel_retn_cnt(item.getCount())
|
|
|
|
|
.sel_retn_time(formattedDate)
|
|
|
|
|
.sel_retn_opter_name(ioCollectOrder.getCreateUser())
|
|
|
|
|
.memo(null)
|
|
|
|
|
.mdtrt_setl_type(null)
|
|
|
|
|
.drugtracinfo(drugTraceList).build();
|
|
|
|
|
xsck35051Requests.add(xsck35051Request);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
}
|
|
|
|
|
BaseXsck35051Request baseXsck35051Request = new BaseXsck35051Request();
|
|
|
|
|
baseXsck35051Request.setSelinfoDetail(xsck35051Requests);
|
|
|
|
|
String jsonStr = JSONUtil.toJsonStr(baseXsck35051Request);
|
|
|
|
|
JSONObject dataJson = JSONObject.parseObject(jsonStr);
|
|
|
|
|
return ybClient.ybPost("35051", dataJson);
|
|
|
|
|
} else {
|
|
|
|
|
return ResultVOUtils.error(500, "上传医保数据为空请核实");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void optionUploadCollectOrder3501(IoCollectOrder ioCollectOrder) {
|
|
|
|
|
List<IoCollectOrderBiz> bizList = ioCollectOrder.getBizList();
|
|
|
|
|
@ -2370,10 +2476,11 @@ public class CtqyyClient extends CommonHttpClient {
|
|
|
|
|
@Override
|
|
|
|
|
public BaseResponse getBuyType() {
|
|
|
|
|
Map<String, String[]> buyTypeMap = new HashMap<>();
|
|
|
|
|
buyTypeMap.put("buyType_3501", buyType_3501);
|
|
|
|
|
buyTypeMap.put("buyType_3502", buyType_3502);
|
|
|
|
|
buyTypeMap.put("buyType_3504", buyType_3504);
|
|
|
|
|
buyTypeMap.put("buyType_3505", buyType_3505);
|
|
|
|
|
buyTypeMap.put("buyType_3506", buyType_3506);
|
|
|
|
|
buyTypeMap.put("buyType_35051", buyType_35051);
|
|
|
|
|
return ResultVOUtils.success(buyTypeMap);
|
|
|
|
|
}
|
|
|
|
|
}
|
qiuyt
2 weeks ago