package com.glxp.mipsdl.client.ptxhyy; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.exceptions.ExceptionUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.TypeReference; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; 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.ptxhyy.entity.HisProductEntity; import com.glxp.mipsdl.client.ptxhyy.entity.OrderUploadResponse; import com.glxp.mipsdl.client.ptxhyy.entity.ThrHslbEntity; import com.glxp.mipsdl.client.ptxhyy.entity.ThrHslbService; import com.glxp.mipsdl.config.ThirdSysConfig; import com.glxp.mipsdl.constant.ConstantType; import com.glxp.mipsdl.constant.Constants; import com.glxp.mipsdl.dao.auth.AuthUserDao; import com.glxp.mipsdl.dao.auth.AuthWarehouseDao; import com.glxp.mipsdl.dao.auth.AuthWarehouseUserMapper; import com.glxp.mipsdl.dao.basic.*; import com.glxp.mipsdl.dao.inout.IoCodeDao; import com.glxp.mipsdl.dao.inout.IoOrderDao; import com.glxp.mipsdl.dao.inout.IoOrderDetailBizDao; import com.glxp.mipsdl.dao.inout.IoOrderUploadLogDao; import com.glxp.mipsdl.dao.thrsys.ThrDeptDao; import com.glxp.mipsdl.dao.thrsys.ThrInvWarehouseDao; import com.glxp.mipsdl.dao.thrsys.ThrProductsDao; 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.auth.AuthWarehouseUser; import com.glxp.mipsdl.entity.basic.BasicBussinessTypeEntity; import com.glxp.mipsdl.entity.basic.BasicCorpEntity; import com.glxp.mipsdl.entity.basic.BasicSkProjectEntity; import com.glxp.mipsdl.entity.inout.*; import com.glxp.mipsdl.entity.ptxhyy.SickerEntity; import com.glxp.mipsdl.entity.thrsys.ThrInvWarehouseEntity; import com.glxp.mipsdl.entity.thrsys.ThrSystemBusApiEntity; import com.glxp.mipsdl.http.HttpClient; import com.glxp.mipsdl.req.base.UdiwmsInvProductsRequest; import com.glxp.mipsdl.req.base.UdiwmsOrderDetailRequest; import com.glxp.mipsdl.req.base.UdiwmsOrderRequest; import com.glxp.mipsdl.req.ctqyy.DlThirdProjectRequest; import com.glxp.mipsdl.req.ctqyy.GetSickRequest; import com.glxp.mipsdl.req.ptxhyy.PtxhyyInvRequest; import com.glxp.mipsdl.req.ptxhyy.PtxhyyOrderDetailRequest; import com.glxp.mipsdl.req.ptxhyy.PtxhyyOrderRequest; import com.glxp.mipsdl.res.BaseResponse; import com.glxp.mipsdl.res.PageSimpleResponse; import com.glxp.mipsdl.res.ptxhyy.PtxhInvResponse; import com.glxp.mipsdl.res.udiwms.BasicSkSickerResponse; import com.glxp.mipsdl.res.udiwms.ThrInvResultResponse; import com.glxp.mipsdl.service.auth.AuthWarehouseService; import com.glxp.mipsdl.service.order.OrderUploadLogService; import com.glxp.mipsdl.service.thrsys.ThrCorpService; import com.glxp.mipsdl.service.thrsys.ThrSystemDetailService; import com.glxp.mipsdl.thirddao.ptxhyy.PtxhyySickerMapper; import com.glxp.mipsdl.util.*; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.IOException; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; /** * 平潭协和医院接口 */ @Slf4j @Service(value = "100008HttpClient") @RequiredArgsConstructor public class PtxhyyClient extends CommonHttpClient { private final ThirdSysConfig thirdSysConfig; private final IoOrderDao orderDao; private final ThrSystemBusApiDao thrSystemBusApiDao; private final BasicBussinessTypeDao basicBussinessTypeDao; private final BasicCorpDao basicCorpDao; private final AuthWarehouseDao authWarehouseDao; private final ThrInvWarehouseDao thrInvWarehouseDao; private final AuthWarehouseService authWarehouseService; private final IoCodeDao codeDao; private final IoOrderDetailBizDao orderDetailBizDao; private final SubmitOrderUtil submitOrderUtil; @Resource ThrHslbService thrHslbService; @Resource PtxhyySickerMapper ptxhyySickerMapper; @Override public BaseResponse submitOrders(UdiwmsOrderRequest udiwmsOrderRequest) { if (StrUtil.isBlank(udiwmsOrderRequest.getBillNo())) { return ResultVOUtils.error(500, "单据号不能为空"); } //查询单据和详情信息，组装第三方系统接口参数 IoOrderEntity orderEntity = orderDao.selectOne(new LambdaQueryWrapper().eq(IoOrderEntity::getBillNo, udiwmsOrderRequest.getBillNo())); Date billDate = orderEntity.getConfirmTime() == null ? orderEntity.getUpdateTime() : orderEntity.getConfirmTime(); udiwmsOrderRequest.setBillDate(DateUtil.formatDateTime(billDate)); //查询对应的第三方单据类型 ThrSystemBusApiEntity thrSystemBusApiEntity = thrSystemBusApiDao.selectOne(new LambdaQueryWrapper().eq(ThrSystemBusApiEntity::getCode, udiwmsOrderRequest.getBillType())); if (StrUtil.isBlank(thrSystemBusApiEntity.getUrl())) { String errMsg = "接口未配置，无法提交！"; updateLocalErr(orderEntity, errMsg); return ResultVOUtils.error(500, errMsg); } udiwmsOrderRequest.setBillType(thrSystemBusApiEntity.getThirdBuyCode()); //查询单据类型，设置往来单位信息 BasicBussinessTypeEntity basicBussinessTypeEntity = basicBussinessTypeDao.selectByAction(orderEntity.getAction()); if (basicBussinessTypeEntity.getCorpType().equals(Constants.CORP_HOSPTIAL)) { //医院客户 udiwmsOrderRequest.setCorpId(orderEntity.getFromCorp()); //查询客户名称 String corpName = basicCorpDao.selectNameByErpId(orderEntity.getFromCorp()); udiwmsOrderRequest.setCorpName(corpName); } else if (basicBussinessTypeEntity.getCorpType().equals(Constants.CORP_INTTERNAL)) { BasicCorpEntity basicCorpEntity = null; if (StrUtil.isNotEmpty(orderEntity.getFromCorp())) { basicCorpEntity = basicCorpDao.selectByErpId(orderEntity.getFromCorp()); if (null != basicCorpEntity) { udiwmsOrderRequest.setCorpId(basicCorpEntity.getThirdId()); udiwmsOrderRequest.setCorpName(basicCorpEntity.getName()); } else { String msg = "查询单据对应的第三方往来单位信息异常"; updateLocalErr(orderEntity, msg); log.error("----单据提交-----" + orderEntity.getBillNo() + msg); return ResultVOUtils.error(500, msg); } } else { //内部科室 AuthWarehouseEntity warehouseEntity = authWarehouseDao.selectOne(new LambdaQueryWrapper().eq(AuthWarehouseEntity::getCode, orderEntity.getFromInvCode())); try { //根据第三方系统标识，获取对应字段的值 ThrInvWarehouseEntity thrInvWarehouseEntity = thrInvWarehouseDao.selectOne(new LambdaQueryWrapper() .eq(ThrInvWarehouseEntity::getCode, authWarehouseService.getThirdInvCode(warehouseEntity)) .eq(ThrInvWarehouseEntity::getThirdSysFk, thirdSysConfig.getThirdId())); udiwmsOrderRequest.setCorpId(thrInvWarehouseEntity.getCode()); udiwmsOrderRequest.setCorpName(thrInvWarehouseEntity.getName()); } catch (Exception e) { String msg = "查询单据对应往来单位的第三方仓库信息异常"; updateLocalErr(orderEntity, msg); log.error("----单据提交-----" + orderEntity.getBillNo() + msg + ExceptionUtil.stacktraceToString(e)); return ResultVOUtils.error(500, msg); } } } else if (basicBussinessTypeEntity.getCorpType().equals(Constants.CORP_SP)) { //供应商 BasicCorpEntity basicCorpEntity = basicCorpDao.selectByErpId(orderEntity.getFromCorp()); if (null != basicCorpEntity) { udiwmsOrderRequest.setCorpId(basicCorpEntity.getThirdId()); udiwmsOrderRequest.setCorpName(basicCorpEntity.getName()); } else { String msg = "查询单据对应的第三方往来单位信息异常"; updateLocalErr(orderEntity, msg); log.error("----单据提交-----" + orderEntity.getBillNo() + msg); return ResultVOUtils.error(500, msg); } } //查询仓库信息 AuthWarehouseEntity warehouseEntity = authWarehouseDao.selectOne(new LambdaQueryWrapper().eq(AuthWarehouseEntity::getCode, orderEntity.getInvCode())); try { List thrInvWarehouseEntitys = thrInvWarehouseDao.selectList(new LambdaQueryWrapper() .eq(ThrInvWarehouseEntity::getCode, authWarehouseService.getThirdInvCode(warehouseEntity)) .eq(ThrInvWarehouseEntity::getThirdSysFk, thirdSysConfig.getThirdId())); if (CollUtil.isNotEmpty(thrInvWarehouseEntitys)) { udiwmsOrderRequest.setLocInvCode(thrInvWarehouseEntitys.get(0).getCode()); udiwmsOrderRequest.setLocInvName(thrInvWarehouseEntitys.get(0).getName()); } } catch (Exception e) { log.error("查询第三方系统仓库信息异常", ExceptionUtil.stacktraceToString(e)); updateLocalErr(orderEntity, "查询第三方系统仓库信息异常" + ExceptionUtil.stacktraceToString(e)); return ResultVOUtils.error(500, "查询第三方系统仓库信息异常"); } udiwmsOrderRequest.setBillFlag("1"); //设置单据出入库类型 if (basicBussinessTypeEntity.getMainAction().equals(ConstantType.TYPE_PUT)) { udiwmsOrderRequest.setInoutType(1); //入库 } else if (basicBussinessTypeEntity.getMainAction().equals(ConstantType.TYPE_OUT)) { udiwmsOrderRequest.setInoutType(2); //出库 } udiwmsOrderRequest.setRemark("udi管理系统提交单据:" + orderEntity.getBillNo()); //组装单据明细数据 List ioCodeEntities = codeDao.selectList(new LambdaQueryWrapper() .eq(IoCodeEntity::getOrderId, orderEntity.getBillNo()) .ne(IoCodeEntity::getAction, "StockCheck") ); List items = new ArrayList<>(); //查询业务单据详情 List detailBizEntities = orderDetailBizDao.selectList(new LambdaQueryWrapper().eq(IoOrderDetailBizEntity::getOrderIdFk, orderEntity.getBillNo())); //单据金额 BigDecimal djje = detailBizEntities.stream() .filter(x -> x.getPrice() != null). map(IoOrderDetailBizEntity::getPrice).reduce(BigDecimal.ZERO, BigDecimal::add); List ioOrderInvoiceEntities = IoOrderInvoiceEntity.builder().build() .selectList(Wrappers.lambdaQuery(IoOrderInvoiceEntity.class).eq(IoOrderInvoiceEntity::getOrderIdFk, orderEntity.getBillNo()).groupBy(IoOrderInvoiceEntity::getInvoiceEncode)); int fbbz = 0; if (CollectionUtil.isNotEmpty(ioOrderInvoiceEntities) && ioOrderInvoiceEntities.size() > 0) { fbbz = 1; } String userName; try { userName = getUserName(orderEntity); if (StrUtil.isEmpty(userName)) { updateLocalErr(orderEntity, "该单据无创建人！"); return ResultVOUtils.error(500, "该单据无创建人！"); } } catch (Exception e) { log.error("----单据提交-----" + orderEntity.getBillNo() + "查询操作人异常", ExceptionUtil.stacktraceToString(e)); userName = getUserName(orderEntity); } PtxhyyOrderRequest ptxhyyOrderRequest = PtxhyyOrderRequest .builder() .kfxh(udiwmsOrderRequest.getLocInvCode()) .czgh(userName) .lzfs(udiwmsOrderRequest.getBillType()) .dwxh(udiwmsOrderRequest.getCorpId()) .rkrq(udiwmsOrderRequest.getBillDate()) .djje(djje) .fpbz(fbbz) .zdrq(udiwmsOrderRequest.getBillDate()) .lsje(djje) .fpzs(CollectionUtil.isNotEmpty(ioOrderInvoiceEntities) ? ioOrderInvoiceEntities.size() : 0) .udixh(udiwmsOrderRequest.getBillNo()) .lzdh(udiwmsOrderRequest.getBillNo()) .build(); ptxhyyOrderRequest.setDetailList(new ArrayList<>()); String errMs = setOrderDetailList(ioCodeEntities, items, detailBizEntities); if (errMs != null) { updateLocalErr(orderEntity, errMs); log.error(errMs); return ResultVOUtils.error(500, errMs); } Collections.reverse(items); for (UdiwmsOrderDetailRequest i : items) { // String udim = ""; // if (CollectionUtil.isNotEmpty(i.getCodeList())) { // udim = i.getCodeList().stream().map(UdiwmsOrderDetailRequest.CodeDetailEntity::getCode).collect(Collectors.joining(",")); // } String fphm = ""; String fprq = null; List invoiceList = IoOrderInvoiceEntity.builder().build() .selectList(Wrappers.lambdaQuery(IoOrderInvoiceEntity.class).eq(IoOrderInvoiceEntity::getOrderIdFk, orderEntity.getBillNo()) .eq(IoOrderInvoiceEntity::getBindRlFk, i.getBindRlFk()) .eq(StrUtil.isNotEmpty(i.getBatchNo()), IoOrderInvoiceEntity::getBatchNo, i.getBatchNo()). groupBy(IoOrderInvoiceEntity::getInvoiceEncode)); if (CollectionUtil.isNotEmpty(invoiceList)) { fphm = invoiceList.stream().map(IoOrderInvoiceEntity::getInvoiceEncode).collect(Collectors.joining(",")); if (invoiceList.get(0).getInvoiceDate() != null) fprq = DateUtil.formatDateTime(invoiceList.get(0).getInvoiceDate()); } String hsfl = ""; if (StrUtil.isNotEmpty(i.getHslb())) { ThrHslbEntity thrHslbEntity = thrHslbService.getOne(new QueryWrapper().eq("hslb", i.getHslb()), false); if (thrHslbEntity != null) { hsfl = thrHslbEntity.getHsbm(); } } // .udim(udim) BigDecimal wzje = null; if (i.getPrice() != null) wzje = i.getPrice().multiply(BigDecimal.valueOf(i.getCount().intValue())); PtxhyyOrderDetailRequest detailRequest = PtxhyyOrderDetailRequest.builder() .wzxh(i.getProductId()) .cjxh(i.getManufactoryCode()) .bzdw(i.getMeasname()) .bzsl(i.getCount()) .wzjg(i.getPrice()) .lsjg(i.getPrice() + "") .lsje(wzje) .wzje(wzje + "") .hsfl(i.getHslb()) // .hsfl(hsfl) .wzph(i.getBatchNo()) .fphm(fphm) .fprq(fprq) .djrq(DateUtil.formatDate(orderEntity.getCreateTime(), "yyyy-MM-dd")) .producedDate(i.getProductDate()) .expireDate(i.getExpireDate()) .registerNo(i.getRegisterNo()) .build(); ptxhyyOrderRequest.getDetailList().add(detailRequest); } return submitOrder(orderEntity, ptxhyyOrderRequest); } /** * 本地提交错误 * * @param orderEntity * @param errMsg */ public void updateLocalErr(IoOrderEntity orderEntity, String errMsg) { IoOrderUploadLogEntity uploadLog = new IoOrderUploadLogEntity(); uploadLog.setBillDate(orderEntity.getCreateTime()); uploadLog.setBillType(orderEntity.getAction()); uploadLog.setSubmitTime(new Date()); uploadLog.setBillNo(orderEntity.getBillNo()); uploadLog.setFromType(Constants.THIRD_ORDER_UPLOAD); orderDao.updateById(orderEntity); uploadLog.setStatus(4); uploadLog.setResult("单据数据异常：" + errMsg); orderUploadLogService.insertOrUpdate(uploadLog); } /** * 封装单据详情参数 * * @param ioCodeEntities 单据码明细 * @param orderDetailRequests 单据详情参数 * @param detailBizEntities 单据业务详情 */ private String setOrderDetailList(List ioCodeEntities, List orderDetailRequests, List detailBizEntities) { for (IoOrderDetailBizEntity detailBizEntity : detailBizEntities) { UdiwmsOrderDetailRequest item = submitOrderUtil.buildProductInfo(detailBizEntity); if (item == null) { return detailBizEntity.getNameCode() + "第三方产品编码未关联"; } //封装条码信息 submitOrderUtil.setCodeList(ioCodeEntities, detailBizEntity, item); orderDetailRequests.add(item); } return null; } @Resource AuthUserDao authUserDao; @Resource AuthWarehouseUserMapper authWarehouseUserMapper; @Resource private HttpClient httpClient; @Resource private ThrSystemDetailService thrSystemDetailService; @Resource private OrderUploadLogService orderUploadLogService; public String getUserName(IoOrderEntity orderEntity) { //创建人非供应商 if (StrUtil.isNotEmpty(orderEntity.getConfirmUser())) { AuthUserEntity authUserEntity = authUserDao.selectById(orderEntity.getConfirmUser()); return authUserEntity.getUserName(); } else if (StrUtil.isNotEmpty(orderEntity.getReviewUser())) { AuthUserEntity authUserEntity = authUserDao.selectById(orderEntity.getReviewUser()); return authUserEntity.getUserName(); } else { List authWarehouseUsers = authWarehouseUserMapper.selectList(new QueryWrapper().eq("code", orderEntity.getInvCode())); if (CollUtil.isNotEmpty(authWarehouseUsers)) { return authWarehouseUsers.get(0).getUserName(); } } return null; } public String getDefaultUserName(IoOrderEntity orderEntity) { List authWarehouseUsers = authWarehouseUserMapper.selectList(new QueryWrapper().eq("code", orderEntity.getInvCode())); if (CollUtil.isNotEmpty(authWarehouseUsers)) { return authWarehouseUsers.get(0).getUserName(); } return null; } /** * 提交单据 * * @param orderEntity * @param udiwmsOrderRequest * @return */ public BaseResponse submitOrder(IoOrderEntity orderEntity, Object udiwmsOrderRequest) { //记录日志 IoOrderUploadLogEntity uploadLog = new IoOrderUploadLogEntity(); uploadLog.setBillDate(orderEntity.getCreateTime()); uploadLog.setBillType(orderEntity.getAction()); uploadLog.setSubmitTime(new Date()); uploadLog.setBillNo(orderEntity.getBillNo()); uploadLog.setFromType(Constants.THIRD_ORDER_UPLOAD); String response = httpClient.postJson(thrSystemDetailService.getUrl(Constants.URL_NAME_ORDER_SUBMIT_URL), udiwmsOrderRequest); if (StrUtil.isNotBlank(response)) { try { BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference>() { }); if (baseResponse.getCode() == 20000) { String thirdBillNo = baseResponse.getData().getDjxh(); orderEntity.setThirdBillNo(thirdBillNo); orderEntity.setExportStatus(1); //上传成功 uploadLog.setStatus(2); uploadLog.setThrBillNo(thirdBillNo); uploadLog.setResult("提交成功"); orderDao.updateById(orderEntity); orderUploadLogService.insertOrUpdate(uploadLog); return ResultVOUtils.success("提交成功"); } orderEntity.setExportStatus(2); //上传失败 orderDao.updateById(orderEntity); uploadLog.setStatus(3); uploadLog.setResult("提交失败，错误信息：" + baseResponse.getMessage()); orderUploadLogService.insertOrUpdate(uploadLog); return baseResponse; } catch (Exception e) { log.error("解析提交单据返回结果异常，结果信息：{}", response); log.error("异常信息：{}", e); uploadLog.setStatus(3); uploadLog.setResult("提交失败，错误信息：" + response); orderEntity.setExportStatus(2); //上传失败 orderDao.updateById(orderEntity); orderUploadLogService.insertOrUpdate(uploadLog); return ResultVOUtils.error(500, "提交失败"); } } else { uploadLog.setStatus(3); uploadLog.setResult("提交失败，调用接口返回为空"); orderEntity.setExportStatus(2); //上传失败 orderDao.updateById(orderEntity); orderUploadLogService.insertOrUpdate(uploadLog); return ResultVOUtils.error(500, "提交失败"); } } /** * 获取库存/出入库明细信息 */ @Override public BaseResponse getInvFeeResult(UdiwmsInvProductsRequest udiwmsInvProductsRequest) { PtxhyyInvRequest ptxhyyInvRequest = new PtxhyyInvRequest(); ptxhyyInvRequest.setKssj(DateUtil.formatDate(udiwmsInvProductsRequest.getStartDate(), "yyyy-MM-dd")); ptxhyyInvRequest.setJssj(DateUtil.formatDate(udiwmsInvProductsRequest.getEndDate(), "yyyy-MM-dd")); String response = null; try { response = FileUtils.getFileContent("E://response.json"); } catch (IOException e) { e.printStackTrace(); } // String response = httpClient.postJson(thrSystemDetailService.getUrlExclude(null) + "/CKCX", ptxhyyInvRequest); // String response = "{\"code\": 20000,\"data\": {\"list\": [{\"zsl\": 1,\"fyxh\": 30274,\"dw\": \"根\",\"lb\": \"住院\",\"fymc\": \"一次性使用避光压力延长管/根\",\"fydj\": 13,\"rq\": 1709222400000,\"zxks\": \"新10区\"},{\"zsl\": 3,\"fyxh\": 35550,\"dw\": \"个\",\"lb\": \"住院\",\"fymc\": \"静脉林华留置针（苏州林华）/个\",\"fydj\": 3.12,\"rq\": 1709222400000,\"zxks\": \"精神科病区\"},{\"zsl\": 2,\"fyxh\": 29290,\"dw\": \"支\",\"lb\": \"住院\",\"fymc\": \"一次性采血针/支 (100.000%)\",\"fydj\": 0.28,\"rq\": 1709222400000,\"zxks\": \"精神科病区\"},{\"zsl\": 6,\"fyxh\": 29976,\"dw\": \"个\",\"lb\": \"住院\",\"fymc\": \"雾化面罩（口含式）/个 (100.000%)\",\"fydj\": 14.4,\"rq\": 1709222400000,\"zxks\": \"新11区\"},{\"zsl\": 1,\"fyxh\": 29298,\"dw\": \"支\",\"lb\": \"住院\",\"fymc\": \"一次性无菌注射器(1ml 带针)/支\",\"fydj\": 0.27,\"rq\": 1709222400000,\"zxks\": \"03区\"},{\"zsl\": 1,\"fyxh\": 29291,\"dw\": \"支\",\"lb\": \"住院\",\"fymc\": \"一次性使用静脉输液针（头皮针）/支 (100.000%)\",\"fydj\": 0.14,\"rq\": 1709222400000,\"zxks\": \"03区\"},{\"zsl\": 62,\"fyxh\": 29292,\"dw\": \"副\",\"lb\": \"住院\",\"fymc\": \"一次性使用代贴输液器（带针）/副 (100.000%)\",\"fydj\": 0.95,\"rq\": 1709222400000,\"zxks\": \"16区\"},{\"zsl\": 9,\"fyxh\": 30621,\"dw\": \"个\",\"lb\": \"住院\",\"fymc\": \"一次性使用真空采血管（促凝剂）/个\",\"fydj\": 0.58,\"rq\": 1709222400000,\"zxks\": \"05区\"},{\"zsl\": 66,\"fyxh\": 29294,\"dw\": \"支\",\"lb\": \"住院\",\"fymc\": \"一次性无菌注射器（5ml 带针)/支\",\"fydj\": 0.28,\"rq\": 1709222400000,\"zxks\": \"16区\"},{\"zsl\": 4,\"fyxh\": 29278,\"dw\": \"个\",\"lb\": \"住院\",\"fymc\": \"一次性使用负压引流袋/个\",\"fydj\": 5.8,\"rq\": 1709222400000,\"zxks\": \"04区\"}]}}"; BaseResponse> baseResponse = JSONObject.parseObject(response, new TypeReference>>() { }); if (baseResponse.getCode() == 20000) { List ptxhInvResponses = baseResponse.getData().getList(); List thrInvResultResponses = new ArrayList<>(); Set seenNames = new HashSet<>(); List itemData = new ArrayList<>(); if (CollUtil.isNotEmpty(ptxhInvResponses)) { for (PtxhInvResponse ptxhInvResponse : ptxhInvResponses) { ThrInvResultResponse thrInvResultResponse = new ThrInvResultResponse(); thrInvResultResponse.setBillType("SC71021292871198"); //科室收费出库 thrInvResultResponse.setMainAction(ConstantType.TYPE_OUT); List thrInvWarehouseEntitys = thrInvWarehouseDao.selectList(new QueryWrapper().eq("code", ptxhInvResponse.getZxksdm())); if (CollUtil.isNotEmpty(thrInvWarehouseEntitys)) { for (ThrInvWarehouseEntity thrInvWarehouseEntity : thrInvWarehouseEntitys) { AuthWarehouseEntity authWarehouseEntity = authWarehouseDao.selectOne(new QueryWrapper().eq("thirdId", thrInvWarehouseEntity.getCode()).last("limit 1")); if (authWarehouseEntity != null) { thrInvResultResponse.setInvCode(authWarehouseEntity.getCode()); thrInvResultResponse.setDeptCode(authWarehouseEntity.getParentId()); thrInvResultResponse.setDeptName(ptxhInvResponse.getZxks()); thrInvResultResponse.setInvName(ptxhInvResponse.getZxks()); thrInvResultResponse.setThrCode(ptxhInvResponse.getFyxh()); thrInvResultResponse.setCpmctymc(ptxhInvResponse.getFymc()); thrInvResultResponse.setPrice(BigDecimal.valueOf(Double.parseDouble(ptxhInvResponse.getFydj()))); thrInvResultResponse.setMeasname(ptxhInvResponse.getDw()); thrInvResultResponse.setType(ptxhInvResponse.getLb()); thrInvResultResponse.setOutCount(ptxhInvResponse.getZsl()); thrInvResultResponse.setReCount(ptxhInvResponse.getZsl()); thrInvResultResponse.setBatchNo("/"); thrInvResultResponse.setSickerName(ptxhInvResponse.getBrxm()); thrInvResultResponse.setSickerCode(ptxhInvResponse.getJzhm()); if (StrUtil.isNotEmpty(ptxhInvResponse.getRq())) { thrInvResultResponse.setChargeTime(ptxhInvResponse.getRq()); } thrInvResultResponses.add(thrInvResultResponse); if (seenNames.add(ptxhInvResponse.getFyxh())) { itemData.add(ptxhInvResponse); break; } } else { // thrInvWarehouseEntity.setCode(CustomUtil.getId()); // thrInvWarehouseEntity.setName(ptxhInvResponse.getZxks()); // thrInvWarehouseEntity.setThirdSysFk("thirdId"); // thrInvWarehouseEntity.setId(IdUtil.getSnowflakeNextId() + ""); // thrInvWarehouseEntity.setParentId(thrInvWarehouseEntity.getCode()); // thrInvWarehouseEntity.setRemark("收费出库自动生成"); // thrInvWarehouseEntity.setUpdateTime(new Date()); // thrInvWarehouseDao.insert(thrInvWarehouseEntity); // // ThrDeptEntity thrDeptEntity = new ThrDeptEntity(); // thrDeptEntity.setCode(thrInvWarehouseEntity.getCode()); // thrDeptEntity.setName(thrInvWarehouseEntity.getName()); // thrDeptEntity.setPId(0); // thrDeptEntity.setId(IdUtil.getSnowflakeNextId()); // thrDeptEntity.setStatus(1); // thrDeptEntity.setRemark("收费出库自动生成"); // thrInvWarehouseEntity.setUpdateTime(new Date()); // thrDeptEntity.setThirdSysFk(thrDeptEntity.getThirdSysFk()); // thrDeptDao.insert(thrDeptEntity); // return ResultVOUtils.error(500, ptxhInvResponse.getZxks() + "第三方科室仓库未创建！"); log.error(ptxhInvResponse.getZxks() + "--科室仓库未对照！"); } } } else { log.error(ptxhInvResponse.getZxks() + "第三方科室仓库未创建！"); } } } // for (PtxhInvResponse invProjectResultEntity : itemData) { // if (!basicSkProjectMapper.exists(new QueryWrapper().eq("code", invProjectResultEntity.getFyxh()))) { // BasicSkProjectEntity basicSkProjectEntity = new BasicSkProjectEntity(); // basicSkProjectEntity.setCode(invProjectResultEntity.getFyxh()); // basicSkProjectEntity.setName(invProjectResultEntity.getFymc()); // basicSkProjectEntity.setType(2); // basicSkProjectEntity.setCreateTime(new Date()); // basicSkProjectEntity.setUpdateTime(new Date()); // basicSkProjectEntity.setRemark("出入库明细自动生成"); // basicSkProjectEntity.setId(IdUtil.getSnowflakeNextId()); // basicSkProjectMapper.insert(basicSkProjectEntity); // } // } PageSimpleResponse pageSimpleResponse = new PageSimpleResponse<>(); pageSimpleResponse.setTotal(thrInvResultResponses.size() + 0l); pageSimpleResponse.setList(thrInvResultResponses); return ResultVOUtils.success(pageSimpleResponse); } return baseResponse; } // public void getHslb() { // String response = httpClient.postJson(thrSystemDetailService.getUrl(null), udiwmsUnitRequest); // BaseResponse baseResponse = JSONObject.parseObject(response, BaseResponse.class); // return baseResponse; // } /** * 获取项目组套字典 * * @param dlThirdProjectRequest * @return */ @Override public BaseResponse getBasicProject(DlThirdProjectRequest dlThirdProjectRequest) { dlThirdProjectRequest.setFygb("14"); dlThirdProjectRequest.setPage(1); dlThirdProjectRequest.setLimit(10000); String response = httpClient.postJson(thrSystemDetailService.getUrlExclude(null) + "/YLSF", dlThirdProjectRequest); BaseResponse> baseResponse = JSONObject.parseObject(response, new TypeReference>>() { }); if (baseResponse.getCode() == 20000) { PageSimpleResponse pageSimpleResponse = baseResponse.getData(); List list = pageSimpleResponse.getList(); List basicSkProjectEntities = new ArrayList<>(); int index = 1; int index2 = 1; log.info("总数：" + list.size()); for (HisProductEntity hisProductEntity : list) { BasicSkProjectEntity basicSkProjectEntity = new BasicSkProjectEntity(); basicSkProjectEntity.setCode(hisProductEntity.getFyxh()); basicSkProjectEntity.setName(hisProductEntity.getFymc()); basicSkProjectEntity.setType(2); basicSkProjectEntity.setCreateTime(new Date()); basicSkProjectEntity.setUpdateTime(new Date()); basicSkProjectEntity.setRemark("自动下载"); basicSkProjectEntity.setCategory(hisProductEntity.getFydw()); basicSkProjectEntity.setGgxh(hisProductEntity.getSm()); basicSkProjectEntity.setUnit(hisProductEntity.getFydw()); basicSkProjectEntity.setPrice(hisProductEntity.getFydj()); if (hisProductEntity.getZfpb().equals("0")) { log.info("在用" + index++ + ""); basicSkProjectEntities.add(basicSkProjectEntity); } else { log.info("作废" + index2++ + ""); } } PageSimpleResponse dataResponse = new PageSimpleResponse<>(); dataResponse.setTotal(-666l); dataResponse.setList(basicSkProjectEntities); return ResultVOUtils.success(dataResponse); } return ResultVOUtils.error(500, "获取项目组套字典失败！"); } @Override public BaseResponse getSickInfo(GetSickRequest getSickRequest) { IPage page = new Page<>(getSickRequest.getPage(), getSickRequest.getLimit()); IPage productEntityIPage = ptxhyySickerMapper.selectPage(page, new QueryWrapper() .lambda() .like(StringUtils.isNotBlank(getSickRequest.getCode()), SickerEntity::getZYHM, getSickRequest.getCode()) .like(StringUtils.isNotBlank(getSickRequest.getName()), SickerEntity::getBRXM, getSickRequest.getName())); List basicSkSickerResponses = new ArrayList<>(); productEntityIPage.getRecords().forEach(sickerEntity -> { basicSkSickerResponses.add(BasicSkSickerResponse.builder() .sickerId(sickerEntity.getZYH()) .code(sickerEntity.getZYH()) .name(sickerEntity.getBRXM()) .adNum(sickerEntity.getZYHM()) .inHospTime(sickerEntity.getRYRQ()) .outHospTime(sickerEntity.getCYRQ()) .build()); }); PageSimpleResponse pageSimpleResponse = new PageSimpleResponse<>(); pageSimpleResponse.setTotal(productEntityIPage.getTotal()); pageSimpleResponse.setList(basicSkSickerResponses); return ResultVOUtils.success(pageSimpleResponse); } }