udi-wms-third-java/src/main/java/com/glxp/mipsdl/client/ptxhyy/PtxhyyClient.java

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.IdUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson2.JSON;
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.toolkit.BeanUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.glxp.mipsdl.client.CommonHttpClient;
import com.glxp.mipsdl.client.ctqyy.entity.InvProjectResultEntity;
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.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.dao.auth.AuthWarehouseUserMapper;
import com.glxp.mipsdl.entity.basic.BasicBussinessTypeEntity;
import com.glxp.mipsdl.entity.basic.BasicCorpEntity;
import com.glxp.mipsdl.entity.basic.BasicSkProjectDetailEntity;
import com.glxp.mipsdl.entity.basic.BasicSkProjectEntity;
import com.glxp.mipsdl.entity.inout.*;
import com.glxp.mipsdl.entity.thrsys.ThrDeptEntity;
import com.glxp.mipsdl.entity.thrsys.ThrInvWarehouseEntity;
import com.glxp.mipsdl.entity.thrsys.ThrProductsEntity;
import com.glxp.mipsdl.entity.thrsys.ThrSystemBusApiEntity;
import com.glxp.mipsdl.http.HttpClient;
import com.glxp.mipsdl.req.base.CompanyProductRelevanceRequest;
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.CtqyyRequest;
import com.glxp.mipsdl.req.ctqyy.DlThirdProjectRequest;
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.BasicSkProjectResponse;
import com.glxp.mipsdl.res.udiwms.InvProductRequest;
import com.glxp.mipsdl.res.udiwms.ThrInvResultResponse;
import com.glxp.mipsdl.res.udiwms.UdiRlSupResponse;
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.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.time.LocalDate;
import java.time.LocalDateTime;
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 ThrCorpService thrCorpService;
    private final IoCodeDao codeDao;
    private final IoOrderDetailBizDao orderDetailBizDao;
    private final SubmitOrderUtil submitOrderUtil;
    private final ThrProductsDao thrProductsDao;
    private final ThrDeptDao thrDeptDao;
    @Resource
    ThrHslbService thrHslbService;

    @Resource
    BasicSkProjectMapper basicSkProjectMapper;
    @Resource
    UdiRlSupDao udiRlSupDao;
    @Resource
    BasicDestinyRelMapper basicDestinyRelMapper;

    @Override
    public BaseResponse submitOrders(UdiwmsOrderRequest udiwmsOrderRequest) {
        if (StrUtil.isBlank(udiwmsOrderRequest.getBillNo())) {
            return ResultVOUtils.error(500, "单据号不能为空");
        }
        //查询单据和详情信息，组装第三方系统接口参数
        IoOrderEntity orderEntity = orderDao.selectOne(new LambdaQueryWrapper<IoOrderEntity>().eq(IoOrderEntity::getBillNo, udiwmsOrderRequest.getBillNo()));
        udiwmsOrderRequest.setBillDate(DateUtil.formatDateTime(orderEntity.getCreateTime()));
        //查询对应的第三方单据类型
        ThrSystemBusApiEntity thrSystemBusApiEntity = thrSystemBusApiDao.selectOne(new LambdaQueryWrapper<ThrSystemBusApiEntity>().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<AuthWarehouseEntity>().eq(AuthWarehouseEntity::getCode, orderEntity.getFromInvCode()));
                try {
                    //根据第三方系统标识，获取对应字段的值
                    ThrInvWarehouseEntity thrInvWarehouseEntity = thrInvWarehouseDao.selectOne(new LambdaQueryWrapper<ThrInvWarehouseEntity>()
                            .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<AuthWarehouseEntity>().eq(AuthWarehouseEntity::getCode, orderEntity.getInvCode()));
        try {
            List<ThrInvWarehouseEntity> thrInvWarehouseEntitys = thrInvWarehouseDao.selectList(new LambdaQueryWrapper<ThrInvWarehouseEntity>()
                    .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<IoCodeEntity> ioCodeEntities = codeDao.selectList(new LambdaQueryWrapper<IoCodeEntity>()
                .eq(IoCodeEntity::getOrderId, orderEntity.getBillNo())
                .ne(IoCodeEntity::getAction, "StockCheck")
        );

        List<UdiwmsOrderDetailRequest> items = new ArrayList<>();
        //查询业务单据详情
        List<IoOrderDetailBizEntity> detailBizEntities = orderDetailBizDao.selectList(new LambdaQueryWrapper<IoOrderDetailBizEntity>().eq(IoOrderDetailBizEntity::getOrderIdFk, orderEntity.getBillNo()));

        //单据金额
        BigDecimal djje = detailBizEntities.stream()
                .filter(x -> x.getPrice() != null).
                        map(IoOrderDetailBizEntity::getPrice).reduce(BigDecimal.ZERO, BigDecimal::add);
        List<IoOrderInvoiceEntity> 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<IoOrderInvoiceEntity> 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<ThrHslbEntity>().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<IoCodeEntity> ioCodeEntities, List<UdiwmsOrderDetailRequest> orderDetailRequests, List<IoOrderDetailBizEntity> 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 IoOrderUploadLogDao orderUploadLogDao;
    @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<AuthWarehouseUser> authWarehouseUsers = authWarehouseUserMapper.selectList(new QueryWrapper<AuthWarehouseUser>().eq("code", orderEntity.getInvCode()));
            if (CollUtil.isNotEmpty(authWarehouseUsers)) {
                return authWarehouseUsers.get(0).getUserName();
            }
        }
        return null;
    }


    public String getDefaultUserName(IoOrderEntity orderEntity) {
        List<AuthWarehouseUser> authWarehouseUsers = authWarehouseUserMapper.selectList(new QueryWrapper<AuthWarehouseUser>().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<OrderUploadResponse> baseResponse =
                        JSONObject.parseObject(response, new TypeReference<BaseResponse<OrderUploadResponse>>() {
                        });
                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<PageSimpleResponse<PtxhInvResponse>> baseResponse =
                JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<PtxhInvResponse>>>() {
                });
        if (baseResponse.getCode() == 20000) {
            List<PtxhInvResponse> ptxhInvResponses = baseResponse.getData().getList();
            List<ThrInvResultResponse> thrInvResultResponses = new ArrayList<>();

            Set<String> seenNames = new HashSet<>();
            List<PtxhInvResponse> itemData = new ArrayList<>();

            if (CollUtil.isNotEmpty(ptxhInvResponses)) {
                for (PtxhInvResponse ptxhInvResponse : ptxhInvResponses) {

                    ThrInvResultResponse thrInvResultResponse = new ThrInvResultResponse();
                    thrInvResultResponse.setBillType("SC71021292871198");       //科室收费出库
                    thrInvResultResponse.setMainAction(ConstantType.TYPE_OUT);

                    List<ThrInvWarehouseEntity> thrInvWarehouseEntitys = thrInvWarehouseDao.selectList(new QueryWrapper<ThrInvWarehouseEntity>().eq("name", ptxhInvResponse.getZxks()));
                    if (CollUtil.isNotEmpty(thrInvWarehouseEntitys)) {
                        for (ThrInvWarehouseEntity thrInvWarehouseEntity : thrInvWarehouseEntitys) {

                            AuthWarehouseEntity authWarehouseEntity = authWarehouseDao.selectOne(new QueryWrapper<AuthWarehouseEntity>().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());
                                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<BasicSkProjectEntity>().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<ThrInvResultResponse> 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");
        String response = httpClient.postJson(thrSystemDetailService.getUrlExclude(null) + "/YLSF", dlThirdProjectRequest);
        BaseResponse<PageSimpleResponse<HisProductEntity>> baseResponse =
                JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<HisProductEntity>>>() {
                });
        if (baseResponse.getCode() == 20000) {
            PageSimpleResponse<HisProductEntity> pageSimpleResponse = baseResponse.getData();
            List<HisProductEntity> list = pageSimpleResponse.getList();
            List<BasicSkProjectEntity> basicSkProjectEntities = new ArrayList<>();
            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());
                basicSkProjectEntities.add(basicSkProjectEntity);
            }
            PageSimpleResponse<BasicSkProjectEntity> dataResponse = new PageSimpleResponse<>();
            dataResponse.setTotal(basicSkProjectEntities.size() + 0l);
            dataResponse.setList(basicSkProjectEntities);
            return ResultVOUtils.success(dataResponse);
        }
        return ResultVOUtils.error(500, "获取项目组套字典失败！");


    }


}