人事系统对接

zhuo

2025-03-16 32bdae73e49c51b6835ef0a5c7b82c4a83a521df

 inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsReportServiceImpl.java

@@ -1,1163 +1,1159 @@
//package com.ruoyi.inspect.service.impl;
//
//import cn.hutool.core.util.StrUtil;
//import cn.hutool.json.JSONUtil;
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
//import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
//import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
//import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
//import com.baomidou.mybatisplus.core.toolkit.StringUtils;
//import com.baomidou.mybatisplus.core.toolkit.Wrappers;
//import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
//import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
//import com.deepoove.poi.XWPFTemplate;
//import com.deepoove.poi.data.Pictures;
//import com.ruoyi.common.properties.WechatProperty;
//import com.ruoyi.common.utils.QueryWrappers;
//import com.ruoyi.inspect.dto.ReportPageDto;
//import com.ruoyi.inspect.mapper.InsOrderStateMapper;
//import com.ruoyi.inspect.mapper.InsProductMapper;
//import com.ruoyi.inspect.mapper.InsReportMapper;
//import com.ruoyi.inspect.mapper.InsUnqualifiedRetestProductMapper;
//import com.ruoyi.inspect.pojo.InsReport;
//import com.ruoyi.inspect.service.InsOrderService;
//import com.ruoyi.inspect.service.InsReportService;
//import com.ruoyi.system.mapper.UserMapper;
//import org.apache.poi.xwpf.usermodel.*;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
//import org.springframework.stereotype.Service;
//import org.springframework.transaction.annotation.Transactional;
//import org.springframework.web.multipart.MultipartFile;
//
//import javax.annotation.Resource;
//import javax.imageio.ImageIO;
//import java.awt.image.BufferedImage;
//import java.io.*;
//import java.nio.file.Files;
//import java.nio.file.Path;
//import java.nio.file.Paths;
//import java.nio.file.StandardCopyOption;
//import java.time.LocalDateTime;
//import java.time.format.DateTimeFormatter;
//import java.util.*;
//import java.util.stream.Collectors;
//import java.util.zip.ZipEntry;
//import java.util.zip.ZipFile;
//import java.util.zip.ZipOutputStream;
//
///**
// * @author Administrator
// * @description 针对表【ins_report(检验报告)】的数据库操作Service实现
// * @createDate 2024-03-17 22:10:02
// */
//@Service
//public class InsReportServiceImpl extends ServiceImpl<InsReportMapper, InsReport>
//        implements InsReportService {
//
//    @Resource
//    private GetLook getLook;
//    @Resource
//    private UserMapper userMapper;
//    @Resource
//    private InsReportMapper insReportMapper;
//    @Resource
//    private InsOrderStateMapper insOrderStateMapper;
//    @Resource
//    private InsProductMapper insProductMapper;
//    @Resource
//    private InformationNotificationService informationNotificationService;
//    @Value("${wordUrl}")
//    private String wordUrl;
//    @Value("${file.path}")
//    private String imgUrl;
//    @Value("${file.licenseUrl}")
//    private String licenseUrl;
//    @Resource
//    private InsOrderMapper insOrderMapper;
//    @Resource
//    private IfsInventoryQuantityMapper ifsInventoryQuantityMapper;
//    @Resource
//    private InsUnqualifiedHandlerMapper insUnqualifiedHandlerMapper;
//    @Resource
//    private InsSampleMapper insSampleMapper;
//    @Resource
//    private ThreadPoolTaskExecutor threadPoolTaskExecutor;
//    @Resource
//    private InsOrderService insOrderService;
//    @Resource
//    private WechatProperty wechatProperty;
//    @Resource
//    private InsUnqualifiedRetestProductMapper insUnqualifiedRetestProductMapper;
//    @Resource
//    private IfsApiUtils ifsApiUtils;
//    @Resource
//    private InsSampleUserMapper insSampleUserMapper;
//
//
//    @Override
//    public Map<String, Object> pageInsReport(Page page, ReportPageDto reportPageDto) {
//        Map<String, Object> map = new HashMap<>();
//        map.put("head", PrintChina.printChina(ReportPageDto.class));
//        Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("pageInsReport");
//        User user = userMapper.selectById(map1.get("userId"));//当前登录的人
//        //获取当前人所属实验室id
//        String departLimsId = user.getDepartLimsId();
//        String laboratory = null;
////        if (ObjectUtils.isNotEmpty(departLimsId) && !departLimsId.equals("")) {
////            String[] split = departLimsId.split(",");
////            //查询对应架构名称(通信实验室,电力实验室,检测办)
////            String departLims = insOrderMapper.seldepLimsId(Integer.parseInt(split[split.length - 1]));
////            if (departLims.contains("实验室")) {
////                laboratory = departLims;
////            }
////        }
//
//        Integer createOrderUser = null;
//        if (map1.get("look") == 1) {
//            //个人
//            createOrderUser = map1.get("userId");
//        }
//        String queryStatus = reportPageDto.getQueryStatus();
//        reportPageDto.setQueryStatus(null);
//
//        map.put("body", insReportMapper.pageInsReport(page,
//                QueryWrappers.queryWrappers(reportPageDto),
//                laboratory,
//                map1.get("userId"),
//                queryStatus,
//                createOrderUser));
//        return map;
//    }
//
//    @Override
//    public int inReport(String url, Integer id) {
//        InsReport insReport = new InsReport();
//        insReport.setId(id);
//        insReport.setUrlS(url);
//        // 还原pdf
//        String tempUrlPdf = wordToPdfTemp(insReport.getUrlS().replace("/word", wordUrl));
//        insReport.setTempUrlPdf("/word/" + tempUrlPdf);
//        return insReportMapper.updateById(insReport);
//    }
//
//    @Override
//    public int upReportUrl(Integer id) {
//        InsReport report = insReportMapper.selectById(id);
//        // 还原pdf
//        String tempUrlPdf = wordToPdfTemp(report.getUrl().replace("/word", wordUrl));
//
//        return insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
//                .eq(InsReport::getId, id)
//                .set(InsReport::getUrlS, null)
//                .set(InsReport::getTempUrlPdf, "/word/" + tempUrlPdf));
//    }
//
//    //提交
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public int writeReport(Integer id, Integer userId, Integer submitUserId) {
//        submitUserId = submitUserId == null ? getLook.selectPowerByMethodAndUserId(null).get("userId") : submitUserId;
//        InsReport insReport = insReportMapper.selectById(id);
//        insReport.setId(id);
//        insReport.setState(1);
//        insReport.setWriteUserId(submitUserId);//提交人
//        if (userId == null) {
//            throw new ErrorException("缺少审核人");
//        }
//        insReport.setExamineUserId(userId);//审核人
//        insReport.setWriteTime(LocalDateTime.now());//提交时间
//        //获取提交人的签名地址
//        String signatureUrl;
//        try {
//            signatureUrl = userMapper.selectById(insReport.getWriteUserId()).getSignatureUrl();
//        } catch (Exception e) {
//            throw new ErrorException("找不到编制人的签名");
//        }
//        if (ObjectUtils.isEmpty(signatureUrl) || signatureUrl.equals("")) {
//            throw new ErrorException("找不到检验人的签名");
//        }
//
//        Integer insOrderId = insReportMapper.selectById(id).getInsOrderId();
//        InsOrder order = insOrderMapper.selectById(insOrderId);
//        boolean isRawMater = order.getTypeSource() != null && order.getTypeSource().equals(1);
//
//        //发送消息
//        InformationNotification info = new InformationNotification();
//        info.setCreateUser(insProductMapper.selectUserById(userId).get("name"));
//        info.setMessageType("3");
//        info.setTheme("审核通知");
//        info.setContent("您有一条报告编制待审核消息, 编号:" + insReport.getCode());
//        info.setSenderId(submitUserId);    //发送人
//        info.setConsigneeId(userId);     //收件人
//        info.setViewStatus(false);
//        info.setJumpPath("b1-report-preparation");
//        informationNotificationService.addInformationNotification(info);
//        //系统生成报告地址
//        String url = insReport.getUrl();
//        //手动上传报告地址
//        String urlS = insReport.getUrlS();
//
//        // 判断是否是原材料  需要替换****成供应商
//        IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper<IfsInventoryQuantity>()
//                .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId()));
//        if (one != null) {
//            if (isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) {
//                changeText(new HashMap<String, String>() {{
//                    put("**********", one.getSupplierName());
//                }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
//            }
//        }
//
//        wordInsertUrl(new HashMap<String, Object>() {{
//            put("writeUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
//            put("writeDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create());
//            put("insUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
//        }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
//
//        // 修改临时pdf
//        String tempUrlPdf = wordToPdfTemp((StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
//        insReport.setTempUrlPdf("/word/" + tempUrlPdf);
//
//        insReportMapper.updateById(insReport);
//
//        // 清空审核时间, 审核状态
//        insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
//                .eq(InsReport::getId, insReport.getId())
//                .set(InsReport::getRatifyTime, null)
//                .set(InsReport::getIsRatify, null)
//                .set(InsReport::getExamineTime, null)
//                .set(InsReport::getIsExamine, null));
//
//        return 1;
//    }
//
//    //审核
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public int examineReport(Integer id, Integer isExamine, String examineTell, Integer userId) {
//        InsReport insReport = insReportMapper.selectById(id);
//        insReport.setIsExamine(isExamine);
//        if (ObjectUtils.isNotEmpty(examineTell)) {
//            insReport.setExamineTell(examineTell);
//        }
//
//        // 检验人
//        String userName = insProductMapper.selectUserById(insReport.getWriteUserId()).get("name");
//        String userAccount = insProductMapper.selectUserById(insReport.getWriteUserId()).get("account");
//
//        // 审核人
//        Integer checkUserId = getLook.selectPowerByMethodAndUserId(null).get("userId");
//        String checkUserName = insProductMapper.selectUserById(checkUserId).get("name");
//
//        insReport.setExamineTime(LocalDateTime.now());//审核时间
//        if (isExamine == 0) {
//            // 发送企业微信通知(审核退回)
//            threadPoolTaskExecutor.execute(() -> {
//                // 查询订单
//                InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId());
//                InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery()
//                        .eq(InsSample::getInsOrderId, insReport.getInsOrderId())
//                        .last("limit 1"));
//                // 查询原材料
//                IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId());
//
//                String message = "";
//                message += "报告编制审核退回通知";
//                message += "\n审核人: " + checkUserName;
//                message += "\n委托编号: " + order.getEntrustCode();
//                message += "\n样品名称: " + insSample.getModel();
//                message += "\n规格型号: " + order.getPartDetail();
//                if (ifsInventoryQuantity != null) {
//                    message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo();
//                }
//                message += "\n退回原因: " + examineTell;
//                //发送企业微信消息通知  提交复核
//                try {
//                    WxCpUtils.inform(userAccount, message, null);
//                } catch (Exception e) {
//                    throw new RuntimeException(e);
//                }
//            });
//
//            //如果审核不通过
//            insReport.setState(0);//提交状态改为待提交
//            return insReportMapper.updateById(insReport);
//        } else {
//            if (userId == null) {
//                throw new ErrorException("缺少批准人");
//            }
//        }
//        insReport.setRatifyUserId(userId);//批准人
//        //获取审核人的签名地址
//        String signatureUrl;
//        try {
//            signatureUrl = userMapper.selectById(insReport.getExamineUserId()).getSignatureUrl();
//        } catch (Exception e) {
//            throw new ErrorException("找不到审核人的签名");
//        }
//        if (StringUtils.isBlank(signatureUrl)) {
//            throw new ErrorException("找不到审核人的签名");
//        }
//
//        // 批准人
//        String sendUserAccount = insProductMapper.selectUserById(userId).get("account");
//
//        //发送消息
//        //当前用户
//        Integer currentUser = getLook.selectPowerByMethodAndUserId(null).get("userId");
//        InformationNotification info = new InformationNotification();
//        info.setCreateUser(insProductMapper.selectUserById(userId).get("name"));
//        info.setMessageType("3");
//        info.setTheme("批准通知");
//        info.setContent("您有一条报告编制待批准消息, 编号:" + insReport.getCode());
//        info.setSenderId(currentUser);    //发送人
//        info.setConsigneeId(userId);     //收件人
//        info.setViewStatus(false);
//        info.setJumpPath("b1-report-preparation");
//        informationNotificationService.addInformationNotification(info);
//        //系统生成报告地址
//        String url = insReport.getUrl();
//        //手动上传报告地址
//        String urlS = insReport.getUrlS();
//        wordInsertUrl(new HashMap<String, Object>() {{
//            put("examineUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
//            put("examineDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create());
//        }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
//
//        // 修改临时pdf
//        String tempUrlPdf = wordToPdfTemp((StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
//        insReport.setTempUrlPdf("/word/" + tempUrlPdf);
//
//        // 发送企业微信通知(通知批准人审批)
//        threadPoolTaskExecutor.execute(() -> {
//            // 查询订单
//            InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId());
//            InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery()
//                    .eq(InsSample::getInsOrderId, insReport.getInsOrderId())
//                    .last("limit 1"));
//            // 查询原材料
//            IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId());
//
//            String message = "";
//            message += "报告编制批准通知";
//            message += "\n检验人: " + userName;
//            message += "\n复核人: " + checkUserName;
//            message += "\n委托编号: " + order.getEntrustCode();
//            message += "\n样品名称: " + insSample.getModel();
//            message += "\n规格型号: " + order.getPartDetail();
//            if (ifsInventoryQuantity != null) {
//                message += "\n生产厂家: " + ifsInventoryQuantity.getSupplierName();
//                message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo();
//            }
//            //发送企业微信消息通知  提交复核
//            try {
//                WxCpUtils.inform(sendUserAccount, message, null);
//            } catch (Exception e) {
//                throw new RuntimeException(e);
//            }
//        });
//        insReportMapper.updateById(insReport);
//
//        // 清空批准备注, 批准时间, 批准状态
//        insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
//                .eq(InsReport::getId, insReport.getId())
//                .set(InsReport::getExamineTell, null)
//                .set(InsReport::getRatifyTime, null)
//                .set(InsReport::getIsRatify, null));
//        return 1;
//    }
//
//    //批准
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public int ratifyReport(Integer id, Integer isRatify, String ratifyTell) {
//        InsReport insReport = insReportMapper.selectById(id);
//        insReport.setIsRatify(isRatify);
//        if (ObjectUtils.isNotEmpty(ratifyTell)) {
//            insReport.setRatifyTell(ratifyTell);
//        }
//        insReport.setRatifyTime(LocalDateTime.now());//批准时间
//        if (isRatify == 0) {
//
//            // 批准人
//            Integer ratifyUserId = getLook.selectPowerByMethodAndUserId(null).get("userId");
//            String ratifyUserName = insProductMapper.selectUserById(ratifyUserId).get("name");
//
//            // 发送人(审核人)(检验人)
//            // 检验人
//            String userAccount = insProductMapper.selectUserById(insReport.getWriteUserId()).get("account");
//            // 审核人
//            String checkUserAccount = insProductMapper.selectUserById(insReport.getExamineUserId()).get("account");
//
//
//            // 发送企业微信通知(批准退回)
//            threadPoolTaskExecutor.execute(() -> {
//                // 查询订单
//                InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId());
//                InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery()
//                        .eq(InsSample::getInsOrderId, insReport.getInsOrderId())
//                        .last("limit 1"));
//                // 查询原材料
//                IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId());
//
//                String message = "";
//                message += "报告编制批准退回通知";
//                message += "\n批准人: " + ratifyUserName;
//                message += "\n委托编号: " + order.getEntrustCode();
//                message += "\n样品名称: " + insSample.getModel();
//                message += "\n规格型号: " + order.getPartDetail();
//                if (ifsInventoryQuantity != null) {
//                    message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo();
//                }
//                message += "\n退回原因: " + ratifyTell;
//                //发送企业微信消息通知  提交复核
//                try {
//                    // 审批人
//                    WxCpUtils.inform(checkUserAccount, message, null);
//
//                    // 检验人
//                    WxCpUtils.inform(userAccount, message, null);
//                } catch (Exception e) {
//                    throw new RuntimeException(e);
//                }
//            });
//
//            //如果批准不通过 直接退回到提交人那边去
//            insReport.setState(0);
//            insReport.setIsExamine(0);
//            return insReportMapper.updateById(insReport);
//        }
//        //获取批准人的签名地址
//        String signatureUrl;
//        try {
//            signatureUrl = userMapper.selectById(insReport.getRatifyUserId()).getSignatureUrl();
//        } catch (Exception e) {
//            throw new ErrorException("找不到批准人的签名");
//        }
//        if (StringUtils.isBlank(signatureUrl)) {
//            throw new ErrorException("找不到批准人的签名");
//        }
//        Integer insOrderId = insReportMapper.selectById(id).getInsOrderId();
//        InsOrder order = insOrderMapper.selectById(insOrderId);
//        boolean isRawMater = order.getTypeSource() != null && order.getTypeSource().equals(1);
//
//        //获取场所的报告专用章
//        String sealUrl;
//        String laboratory = insOrderMapper.selectById(insReport.getInsOrderId()).getLaboratory();
//        try {
//            String type = "";
//            if (isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) {
//                type = "进厂报告";
//            } else {
//                type = "委托报告";
//            }
//            sealUrl = insReportMapper.getLaboratoryByName(laboratory, type);
//        } catch (Exception e) {
//            throw new ErrorException(laboratory + "找不到报告专用章");
//        }
//        if (StringUtils.isBlank(sealUrl)) {
//            throw new ErrorException(laboratory + "找不到报告专用章");
//        }
//        //系统生成报告地址
//        String url = insReport.getUrl();
//        //手动上传报告地址
//        String urlS = insReport.getUrlS();
//        String finalUrl = (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl);
//
//        wordInsertUrl(new HashMap<String, Object>() {{
//            put("ratifyUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
//            put("ratifyDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create());
//            put("seal1", Pictures.ofLocal(imgUrl + "/" + sealUrl).create());
//            put("seal2", Pictures.ofLocal(imgUrl + "/" + sealUrl).create());
//        }}, finalUrl);
//
//        // 修改临时pdf
//        insReport.setTempUrlPdf((StrUtil.isBlank(urlS) ? url : urlS).replace(".docx", ".pdf"));
//
//        InsOrder insOrder = new InsOrder();
//        insOrder.setId(insOrderId);
//        insOrder.setState(4);
//        insOrderMapper.updateById(insOrder);
//
//        wordToPdf(finalUrl, sealUrl, isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY));
//
//        // 判断是否为原材料
//        if (isRawMater) {
//            // 修改ifs库存状态
//            ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper<IfsInventoryQuantity>()
//                    .set(IfsInventoryQuantity::getState, 2)
//                    .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId()));
//        }
//        insReport.setRatifyTell("");
//
//        // 发送文件到委托人
//        if (StringUtils.isNotBlank(order.getPrepareCode())) {
//            threadPoolTaskExecutor.execute(() -> {
//                String message = "";
//                message += "委托编号: " + order.getEntrustCode();
//                message += "委托样品: " + order.getSampleView();
//                message += "已检测结束, 请接收";
//                try {
//                    WxCpUtils.inform(order.getPrepareCode(), message, new File(finalUrl.replace(".docx", ".pdf")));
//                } catch (Exception e) {
//                    throw new RuntimeException(e);
//                }
//            });
//        }
//
//        return insReportMapper.updateById(insReport);
//    }
//
//    @Override
//    public int wordInsertUrl(Map<String, Object> map, String url) {
//        XWPFTemplate template = XWPFTemplate.compile(url).render(map);
//        try {
//            template.writeAndClose(Files.newOutputStream(Paths.get(url)));
//        } catch (IOException e) {
//            throw new RuntimeException(e);
//        }
//        return 1;
//    }
//
//
//    //报告批量下载
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public String downAll(String ids) {
//        List<Long> list = Arrays.stream(ids.split(",")).map(Long::parseLong).collect(Collectors.toList());
//        List<InsReport> insReports = insReportMapper.selectBatchIds(list);
//        String zipFilePath = null;
//        // 临时文件夹路径
//        try {
//            String tempFolderPath = wordUrl + "/tempFolder";
//            File tempFolder = new File(tempFolderPath);
//            if (tempFolder.exists()) {
//                deleteDirectory(tempFolder); // 删除旧的临时文件夹
//            }
//            tempFolder.mkdirs(); // 创建新的临时文件夹
//            for (InsReport insReport : insReports) {
//                File sourceFile = new File((ObjectUtils.isNotEmpty(insReport.getUrlS()) ? insReport.getUrlS() : insReport.getUrl()).replace("/word", wordUrl));
//                File destinationFile = new File(tempFolder, sourceFile.getName());
//                Files.copy(sourceFile.toPath(), destinationFile.toPath(), StandardCopyOption.REPLACE_EXISTING);
//            }
//            // 压缩临时文件夹
//            zipFilePath = wordUrl + "/zip/output.zip";
//            zipDirectory(tempFolderPath, zipFilePath);
//
//            // 清理临时文件夹
//            deleteDirectory(tempFolder);
//
//            System.out.println("ZIP文件创建完成！");
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        return "/word/zip/output.zip";
//    }
//
//    //批量上传
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public int upAll(MultipartFile file) throws IOException {
//        File tempFile = null;
//        File unzipDir = null;
//        try {
//            tempFile = File.createTempFile(wordUrl, ".zip");
//            file.transferTo(tempFile);
//
//            unzipDir = new File("uploaded_files");
//            if (!unzipDir.exists()) {
//                unzipDir.mkdir();
//            }
//            unzip(tempFile, unzipDir);
//            // 处理解压后的文件
//            File[] files = unzipDir.listFiles();
//            if (files != null) {
//                for (File f : files) {
//                    // 根据文件名查询id
//                    String name = f.getName();
//                    InsReport insReport = insReportMapper.selectOne(Wrappers.<InsReport>lambdaQuery().like(InsReport::getCode, f.getName().replace(".docx", "").replace("JCZX", "JCZX/")));
//                    if (ObjectUtils.isEmpty(insReport)) {
//                        throw new ErrorException("没有找到 " + f.getName() + " 这个文件对应的报告数据");
//                    }
//                    String urlString;
//                    String pathName;
//                    try {
//                        String path = wordUrl;
//                        File realpath = new File(path);
//                        if (!realpath.exists()) {
//                            realpath.mkdirs();
//                        }
//                        pathName = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyMMddHHmmss")) + "_" + f.getName();
//                        urlString = realpath + "/" + pathName;
//                        // 复制文件到指定路径
//                        Files.copy(f.toPath(), new File(urlString).toPath(), StandardCopyOption.REPLACE_EXISTING);
//                        inReport("/word/" + pathName, insReport.getId());
//                    } catch (IOException e) {
//                        throw new ErrorException("文件上传失败");
//                    }
//                }
//            }
//        } catch (IOException e) {
//            throw new ErrorException("文件处理失败");
//        } finally {
//            if (tempFile != null && tempFile.exists()) {
//                tempFile.delete();
//            }
//            // 递归删除解压目录及其中的文件
//            if (unzipDir.exists()) {
//                deleteDirectory(unzipDir); // 删除旧的临时文件夹
//            }
//        }
//        return 0;
//    }
//
//
//    //解压文件夹
//    private void unzip(File zipFile, File destDir) throws IOException {
//        try (ZipFile zip = new ZipFile(zipFile)) {
//            Enumeration<? extends ZipEntry> entries = zip.entries();
//            while (entries.hasMoreElements()) {
//                ZipEntry entry = entries.nextElement();
//                File file = new File(destDir, entry.getName());
//                if (entry.isDirectory()) {
//                    file.mkdirs();
//                } else {
//                    file.getParentFile().mkdirs();
//                    try (InputStream in = zip.getInputStream(entry);
//                         OutputStream out = new FileOutputStream(file)) {
//                        byte[] buffer = new byte[1024];
//                        int len;
//                        while ((len = in.read(buffer)) > 0) {
//                            out.write(buffer, 0, len);
//                        }
//                    }
//                }
//            }
//        }
//    }
//
//    // 压缩文件夹
//    public static void zipDirectory(String sourceDirPath, String zipFilePath) throws IOException {
//        try (ZipOutputStream zipOut = new ZipOutputStream(new FileOutputStream(zipFilePath))) {
//            Path sourceDir = Paths.get(sourceDirPath);
//            Files.walk(sourceDir)
//                    .filter(path -> !Files.isDirectory(path))
//                    .forEach(path -> {
//                        ZipEntry zipEntry = new ZipEntry(sourceDir.relativize(path).toString());
//                        try {
//                            zipOut.putNextEntry(zipEntry);
//                            Files.copy(path, zipOut);
//                            zipOut.closeEntry();
//                        } catch (IOException e) {
//                            e.printStackTrace();
//                        }
//                    });
//        }
//    }
//
//    // 删除文件夹及其内容
//    public static void deleteDirectory(File directory) throws IOException {
//        if (directory.isDirectory()) {
//            File[] files = directory.listFiles();
//            if (files != null) {
//                for (File file : files) {
//                    deleteDirectory(file);
//                }
//            }
//        }
//        Files.delete(directory.toPath());
//    }
//
//    @Override
//    public void wordToPdf(String path, String sealUrl, boolean isRawMater) {
//        try {
//            wordToPdf(path, path.replace(".docx", ".pdf"), sealUrl, isRawMater);
//        } catch (Exception e) {
//            throw new ErrorException("转换失败");
//        }
//    }
//
//
//    public String wordToPdf(String wordPath, String pdfPath, String sealUrl, boolean isRawMater) {
//        FileOutputStream os = null;
//        try {
//            //凭证 不然切换后有水印
////            InputStream is = this.getClass().getResourceAsStream("/lib/license.xml");
////            InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("license.xml");
//            InputStream is = Files.newInputStream(new File(licenseUrl).toPath());
//            License license = new License();
//            license.setLicense(is);
//            if (!license.getIsLicensed()) {
//                System.out.println("License验证不通过...");
//                return null;
//            }
//            //生成一个空的PDF文件
//            File file;
//            //判断是否是进厂报告
//            if (!isRawMater) {
//                file = new File(pdfPath.replace(".pdf", "-1.pdf"));
//            } else {
//                file = new File(pdfPath.replace(".pdf", ".pdf"));
//            }
//            os = new FileOutputStream(file);
//            //要转换的word文件
//            com.aspose.words.Document doc = new com.aspose.words.Document(wordPath);
//            doc.save(os, SaveFormat.PDF);
//
//            //添加骑缝章
//            if (!isRawMater) {
//                stamperCheckMarkPDF(pdfPath.replace(".pdf", "-1.pdf"), pdfPath, imgUrl + "/" + sealUrl);
//            }
//
//
//        } catch (Exception e) {
//            e.printStackTrace();
//        } finally {
//            if (os != null) {
//                try {
//                    os.close();
//                } catch (IOException e) {
//                    e.printStackTrace();
//                }
//            }
//        }
//        return null;
//    }
//
//    /**
//     * 切割图片
//     *
//     * @param Path 图片路径
//     * @param n    切割份数
//     */
//    public static com.itextpdf.text.Image[] slicingImages(String Path, int n) throws IOException, BadElementException {
//        com.itextpdf.text.Image[] nImage = new com.itextpdf.text.Image[n];
//        BufferedImage img = ImageIO.read(new File(Path));
//
//        int h = img.getHeight();
//        int w = img.getWidth();
//
//        int sw = w / n;
//        for (int i = 0; i < n; i++) {
//            BufferedImage subImg;
//            if (i == n - 1) {//最后剩余部分
//                subImg = img.getSubimage(i * sw, 0, w - i * sw, h);
//            } else {//前n-1块均匀切
//                subImg = img.getSubimage(i * sw, 0, sw, h);
//            }
//            ByteArrayOutputStream out = new ByteArrayOutputStream();
//            ImageIO.write(subImg, Path.substring(Path.lastIndexOf('.') + 1), out);
//            nImage[i] = com.itextpdf.text.Image.getInstance(out.toByteArray());
//
//        }
//        return nImage;
//    }
//
//    /**
//     * 盖骑缝章
//     *
//     * @param infilePath  原PDF路径
//     * @param outFilePath 输出PDF路径
//     */
//    public static void stamperCheckMarkPDF(String infilePath, String outFilePath, String picPath) throws IOException, DocumentException {
//        PdfReader reader = new PdfReader(infilePath);//选择需要印章的pdf
//        PdfStamper stamp = new PdfStamper(reader, new FileOutputStream(outFilePath));//加完印章后的pdf
//
//
//        com.itextpdf.text.Rectangle pageSize = reader.getPageSize(1);//获得第一页
//        float height = pageSize.getHeight();
//        float width = pageSize.getWidth();
//
//        int nums = reader.getNumberOfPages();
//        com.itextpdf.text.Image[] nImage = slicingImages(picPath, nums);//生成骑缝章切割图片
//
//        for (int n = 1; n <= nums; n++) {
//            PdfContentByte over = stamp.getOverContent(n);//设置在第几页打印印章
//            com.itextpdf.text.Image img = nImage[n - 1];//选择图片
//            float newHeight = 100f;
//            float newWidth = img.getWidth() / (img.getHeight() / 100);
//            img.scaleAbsolute(newWidth, newHeight);//控制图片大小
//            img.setAbsolutePosition(width - newWidth, height / 2 - newHeight / 2);//控制图片位置
//            over.addImage(img);
//        }
//        stamp.close();
//    }
//
//    @Transactional(rollbackFor = Exception.class)
//    public void isRawMaterial(InsOrder insOrder) {
//        IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper<IfsInventoryQuantity>()
//                .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()));
//        if (Objects.isNull(one)) {
//            throw new ErrorException("找不到原材料信息");
//        }
//        // 判断是否有不合格信息
//        Long count = insUnqualifiedHandlerMapper.selectCount(Wrappers.<InsUnqualifiedHandler>lambdaQuery()
//                .eq(InsUnqualifiedHandler::getInventoryQuantityId, one.getId()));
//        String toLocation = null;
//
//        // 判断是否有不合格
//        Long unqualifiedCount = getUnqualifiedCount(insOrder);
//
//        if (count.equals(0L) && unqualifiedCount.equals(0L) && one.getIsFinish().equals(0) && one.getIsSource().equals(1)) {
//            // 原材料移库
//            toLocation = this.moveRawMaterial(one);
//        }
//
//        // 判断结束状态修改合格状态
//        int inspectStatus = (count == 0 && unqualifiedCount == 0) ? 1 : 2;
//        insOrderMapper.update(null, Wrappers.<InsOrder>lambdaUpdate()
//                .eq(InsOrder::getId, insOrder.getId())
//                .set(InsOrder::getInsResult, inspectStatus));
//
//        if (one.getIsFinish().equals(0)) {
//            ifsInventoryQuantityMapper.update(null, Wrappers.<IfsInventoryQuantity>lambdaUpdate()
//                    .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())
//                    .set(IfsInventoryQuantity::getInspectStatus, inspectStatus));
//
//            // 修改ifs库存状态
//            if (StringUtils.isBlank(toLocation)) {
//                ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper<IfsInventoryQuantity>()
//                        .set(IfsInventoryQuantity::getIsFinish, 1)
//                        .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()));
//            } else {
//                ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper<IfsInventoryQuantity>()
//                        .set(IfsInventoryQuantity::getIsFinish, 1)
//                        .set(IfsInventoryQuantity::getToLocation, toLocation)
//                        .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()));
//            }
//
//            threadPoolTaskExecutor.execute(() -> {
//                // 企业微信通知
//                String message = "";
//                message += "检测结果提交通知";
//                message += "\n批次号: " + one.getUpdateBatchNo();
//                message += "\n零件号: " + one.getPartNo();
//                message += "\n零件描述: " + one.getPartDesc();
//                message += "\n供应商名称: " + one.getSupplierName();
//                message += "\n抵达数量: " + one.getQtyArrived().stripTrailingZeros().toPlainString() + one.getBuyUnitMeas();
//                // 发送企业inspectStatus信通知
//                if (inspectStatus == 1) {
//                    message += "\n检测结果: 合格";
//                } else {
//                    message += "\n检测结果: 不合格";
//                }
//                WxCpUtils.informWebHook(wechatProperty.getExaminingUrl(), message);
//            });
//
//        }
//
//
//    }
//
//    /**
//     * 判断是否有不合格
//     * @param insOrder
//     * @return
//     */
//    @Override
//    public Long getUnqualifiedCount(InsOrder insOrder) {
//        Long unqualifiedCount = 0L;
//        List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery()
//                .eq(InsSample::getInsOrderId, insOrder.getId()));
//        if (CollectionUtils.isNotEmpty(insSamples)) {
//            unqualifiedCount = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery()
//                    .in(InsProduct::getInsSampleId, insSamples.stream().map(InsSample::getId).collect(Collectors.toList()))
//                    .eq(InsProduct::getInsResult, 0));
//
//            // 判断如果有不合格的检验项, 判断有没有检验项复测, 复核合格也算合格通过
//            if (!unqualifiedCount.equals(0L)) {
//                List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()
//                        .in(InsProduct::getInsSampleId, insSamples.stream().map(InsSample::getId).collect(Collectors.toList()))
//                        .eq(InsProduct::getInsResult, 0));
//
//                boolean flag = true;
//                for (InsProduct insProduct : insProducts) {
//                    Long unqualifiedProductCount = insUnqualifiedRetestProductMapper.selectCount(Wrappers.<InsUnqualifiedRetestProduct>lambdaQuery()
//                            .eq(InsUnqualifiedRetestProduct::getInsProductId, insProduct.getId())
//                            .ne(InsUnqualifiedRetestProduct::getInsResult, 0));
//                    if (unqualifiedProductCount != 2) {
//                        flag = false;
//                    }
//                }
//                if (flag) {
//                    unqualifiedCount = 0L;
//                }
//            }
//        }
//        return unqualifiedCount;
//    }
//
//    /**
//     * ifs移库操作
//     * @param one
//     * @return
//     */
//    @Override
//    public String moveRawMaterial(IfsInventoryQuantity one) {
//        String toLocation;
//        // 登记采购检验结果STD
//        if (one.getIsRegister().equals(0)) {
//            Map<String, Object> resultMap = new HashMap<>();
//            List<Map<String, Object>> resultList = new ArrayList<>();
//            Map<String, Object> map = new HashMap<>();
//            map.put("ORDER_NO", one.getOrderNo()); // 采购订单号
//            map.put("LINE_NO", one.getLineNo()); // 行号
//            map.put("RELEASE_NO", one.getReleaseNo()); // 下达号
//            map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号
//            map.put("PURCH_QTY", one.getQtyToInspect()); // 要检验的采购数量
//            resultList.add(map);
//            resultMap.put("RECORD_ID", UUID.randomUUID().toString());
//            resultMap.put("SYSCODE", "LIMS");
//            resultMap.put("SYSMODEL", "登记采购检验结果");
//            resultMap.put("BATCH_INFO", resultList);
//            Result result = ifsApiUtils.getProcurementResults(JSONUtil.toJsonStr(resultMap));
//            if (result.getCode() != 200) {
//                throw new ErrorException("IFS登记采购检验结果失败: " + result.getMessage());
//            }
//        }
//        insOrderService.updateIfsInventoryQuantity(one.getId());
//        /**
//         * TODO 后续需要调用IFS的接口 移入的库位号 toLocation
//         */
//        // 检验后移库
//        toLocation = "1301";
//        Map<String, Object> moveResultMap = new HashMap<>();
//        List<Map<String, Object>> moveResultList = new ArrayList<>();
//        Map<String, Object> moveMap = new HashMap<>();
//        moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号
//        moveMap.put("LINE_NO", one.getLineNo());
//        moveMap.put("RELEASE_NO", one.getReleaseNo());
//        moveMap.put("RECEIPT_NO", one.getReceiptNo());
//        moveMap.put("PART_NO", one.getPartNo());
//        moveMap.put("QTY", one.getQtyArrived());
//        moveMap.put("LOCATION_NO", one.getLocationNo());
//        moveMap.put("TO_LOCATION_NO", toLocation);
//        moveMap.put("LOT_BATCH_NO", one.getLotBatchNo());
//        moveMap.put("SERIAL_NO", one.getSerialNo());
//        moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo());
//        moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel());
//        moveMap.put("ACTIVITY_SEQ", one.getActivitySeq());
//        moveResultList.add(moveMap);
//        moveResultMap.put("RECORD_ID", UUID.randomUUID().toString());
//        moveResultMap.put("SYSCODE", "LIMS");
//        moveResultMap.put("SYSMODEL", "检验后移库");
//        moveResultMap.put("BATCH_INFO", moveResultList);
//
//        Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap));
//        // 如果有必须为零件指定批号报错需要重新提交移库信息去指定批号
//        if (result1.getCode() != 200) {
//            String message = result1.getMessage();
//            if (message.contains("必须为零件") && message.contains("指定批号")) {
//                updaeBatch(one, toLocation);
//            } else {
//                throw new ErrorException("IFS检验后移库失败: " + result1.getMessage());
//            }
//        }
//        return toLocation;
//    }
//
//    /**
//     * 退回到检验任务
//     * @param id
//     * @return
//     */
//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public boolean sendBackTask(Integer id) {
//        InsReport report = insReportMapper.selectById(id);
//        // 根据订单查询试验室
//        String laboratory = insOrderMapper.selectLaboratoryByOrderId(report.getInsOrderId());
//
//        // 修改订单状态
//        insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate()
//                .eq(InsOrderState::getInsOrderId, report.getInsOrderId())
//                .eq(InsOrderState::getLaboratory, laboratory)
//                .set(InsOrderState::getInsState, 4));
//
//        Integer insSampleId = insSampleUserMapper.selectOne(Wrappers.<InsSampleUser>lambdaQuery()
//                .eq(InsSampleUser::getInsSampleId, report.getInsOrderId())
//                .orderByDesc(InsSampleUser::getId)
//                .last("limit 1")).getId();
//        insSampleUserMapper.deleteById(insSampleId);
//
//        // 修改报告行为未显示
//        insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
//                .eq(InsReport::getId, id)
//                .set(InsReport::getIsPass, 0));
//
//        return false;
//    }
//
//
//    /**
//     * 先修改采购订单批次号, 后进行移库操作
//     * @param one
//     * @param toLocation
//     */
//    private void updaeBatch(IfsInventoryQuantity one, String toLocation) {
//        if (one.getIsUpdateBatch().equals(0)) {
//            // 先修改批次号后进行移库
//            Map<String, Object> resultMap = new HashMap<>();
//            List<Map<String, Object>> resultList = new ArrayList<>();
//            Map<String, Object> map = new HashMap<>();
//            map.put("ORDER_NO", one.getOrderNo()); // 采购订单号
//            map.put("LINE_NO", one.getLineNo()); // 行号
//            map.put("RELEASE_NO", one.getReleaseNo()); // 下达号
//            map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号
//            map.put("PART_NO", one.getPartNo()); //零件号
//            map.put("CONFIGURATION_ID", one.getConfigurationId()); // 配置标识
//            map.put("LOCATION_NO", one.getLocationNo()); // 库位号
//            map.put("LOT_BATCH_NO", one.getLotBatchNo());// 批次号
//            map.put("NEW_LOT_BATCH_NO", one.getUpdateBatchNo()); // 目标批次号
//            map.put("SERIAL_NO", one.getSerialNo()); // 序列号
//            map.put("ENG_CHG_LEVEL", one.getEngChgLevel()); // 版本号
//            map.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); // wdr号
//            map.put("ACTIVITY_SEQ", one.getActivitySeq()); // 活动序号
//            map.put("QTY_TO_CHANGE", one.getQtyArrived()); // 变更数量
//            resultList.add(map);
//            resultMap.put("RECORD_ID", UUID.randomUUID().toString());
//            resultMap.put("SYSCODE", "LIMS");
//            resultMap.put("SYSMODEL", "修改采购订单批次号");
//            resultMap.put("BATCH_INFO", resultList);
//
//            Result result = ifsApiUtils.updateMoveReceiptLot(JSONUtil.toJsonStr(resultMap));
//
//            if (result.getCode() != 200) {
//                throw new ErrorException("IFS修改批次号失败: " + result.getMessage());
//            }
//            ifsInventoryQuantityMapper.update(null, Wrappers.<IfsInventoryQuantity>lambdaUpdate()
//                    .set(IfsInventoryQuantity::getIsUpdateBatch, 1)
//                    .eq(IfsInventoryQuantity::getId, one.getId()));
//        }
//
//        Map<String, Object> moveResultMap = new HashMap<>();
//        List<Map<String, Object>> moveResultList = new ArrayList<>();
//        Map<String, Object> moveMap = new HashMap<>();
//        moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号
//        moveMap.put("LINE_NO", one.getLineNo());
//        moveMap.put("RELEASE_NO", one.getReleaseNo());
//        moveMap.put("RECEIPT_NO", one.getReceiptNo());
//        moveMap.put("PART_NO", one.getPartNo());
//        moveMap.put("QTY", one.getQtyArrived());
//        moveMap.put("LOCATION_NO", one.getLocationNo());
//        moveMap.put("TO_LOCATION_NO", toLocation);
//        moveMap.put("LOT_BATCH_NO", one.getUpdateBatchNo());
//        moveMap.put("SERIAL_NO", one.getSerialNo());
//        moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo());
//        moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel());
//        moveMap.put("ACTIVITY_SEQ", one.getActivitySeq());
//        moveResultList.add(moveMap);
//        moveResultMap.put("RECORD_ID", UUID.randomUUID().toString());
//        moveResultMap.put("SYSCODE", "LIMS");
//        moveResultMap.put("SYSMODEL", "检验后移库");
//        moveResultMap.put("BATCH_INFO", moveResultList);
//
//        Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap));
//        if (result1.getCode() != 200) {
//            throw new ErrorException("IFS检验后移库失败: " + result1.getMessage());
//        }
//
//    }
//
//    /**
//     * 替换段落文本
//     * @param filePath docx解析对象
//     * @param textMap 需要替换的信息集合
//     */
//    public static void changeText(Map<String, String> textMap, String filePath) {
//        try {
//            FileInputStream stream = new FileInputStream(filePath);
//            XWPFDocument document = new XWPFDocument(stream);
//            List<XWPFTable> tables = document.getTables();
//            for (XWPFTable table : tables) {
//                for (XWPFTableRow row : table.getRows()) {
//                    for (XWPFTableCell cell : row.getTableCells()) {
//
//                        textMap.forEach((s, s2) -> {
//                            if (cell.getText().equals(s)) {
//                                XWPFParagraph paragraph = cell.getParagraphs().get(0);
//                                XWPFRun oldRun = paragraph.getRuns().get(0);
//                                // 保存原样式
//                                String fontFamily = oldRun.getFontFamily();
//                                int fontSize = oldRun.getFontSize();
//                                String color = oldRun.getColor();
//                                ParagraphAlignment alignment = paragraph.getAlignment();
//                                // 替换内容
//                                paragraph.removeRun(0); // 移除原有的 run
//                                XWPFRun newRun = paragraph.createRun();
//                                newRun.setText(s2);
//                                // 应用原样式
//                                newRun.setFontFamily(fontFamily);
//                                newRun.setFontSize(fontSize);
//                                newRun.setColor(color);
//                                paragraph.setAlignment(alignment);
//                            }
//                        });
//                    }
//                }
//            }
//            FileOutputStream fileOutputStream = new FileOutputStream(filePath);
//            document.write(fileOutputStream);
//            fileOutputStream.close();
//
//        } catch (Exception e) {
//            e.printStackTrace();
//            throw new ErrorException(e.getMessage());
//        }
//    }
//
//    /**
//     * word转换pdf
//     * @param path
//     * @return
//     */
//    private String wordToPdfTemp(String path) {
//        try {
//            return wordToPdf(path, path.replace(".docx", "-临时.pdf"));
//        } catch (Exception e) {
//            throw new ErrorException("转换失败");
//        }
//    }
//
//    private String wordToPdf(String wordPath, String pdfPath) {
//        FileOutputStream os = null;
//        try {
//            //凭证 不然切换后有水印
//            InputStream is = Files.newInputStream(new File(licenseUrl).toPath());
//            License license = new License();
//            license.setLicense(is);
//            if (!license.getIsLicensed()) {
//                System.out.println("License验证不通过...");
//                return null;
//            }
//            //生成一个空的PDF文件
//            File file;
//            //判断是否是进厂报告
//            file = new File(pdfPath);
//            os = new FileOutputStream(file);
//            //要转换的word文件
//            com.aspose.words.Document doc = new com.aspose.words.Document(wordPath);
//            doc.save(os, SaveFormat.PDF);
//            String name = file.getName();
//            return file.getName();
//        } catch (Exception e) {
//            e.printStackTrace();
//        } finally {
//            if (os != null) {
//                try {
//                    os.close();
//                } catch (IOException e) {
//                    e.printStackTrace();
//                }
//            }
//        }
//        return null;
//    }
//}
//
//
//
//
//
//
package com.ruoyi.inspect.service.impl;

import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.aspose.words.License;
import com.aspose.words.SaveFormat;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.deepoove.poi.XWPFTemplate;
import com.deepoove.poi.data.Pictures;
import com.itextpdf.text.BadElementException;
import com.itextpdf.text.DocumentException;
import com.itextpdf.text.pdf.PdfContentByte;
import com.itextpdf.text.pdf.PdfReader;
import com.itextpdf.text.pdf.PdfStamper;
import com.ruoyi.basic.mapper.IfsInventoryQuantityMapper;
import com.ruoyi.basic.pojo.IfsInventoryQuantity;
import com.ruoyi.common.constant.InsOrderTypeConstants;
import com.ruoyi.common.constant.MenuJumpPathConstants;
import com.ruoyi.common.core.domain.Result;
import com.ruoyi.common.core.domain.entity.InformationNotification;
import com.ruoyi.common.config.WechatProperty;
import com.ruoyi.common.utils.*;
import com.ruoyi.common.utils.api.IfsApiUtils;
import com.ruoyi.framework.exception.ErrorException;
import com.ruoyi.inspect.dto.ReportPageDto;
import com.ruoyi.inspect.mapper.*;
import com.ruoyi.inspect.pojo.*;
import com.ruoyi.inspect.service.InsOrderService;
import com.ruoyi.inspect.service.InsReportService;
import com.ruoyi.inspect.mapper.InsUnqualifiedHandlerMapper;
import com.ruoyi.system.mapper.UserMapper;
import com.ruoyi.system.service.InformationNotificationService;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.xwpf.usermodel.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.ClassPathResource;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.*;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardCopyOption;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.stream.Collectors;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
import java.util.zip.ZipOutputStream;

/**
 * @author Administrator
 * @description 针对表【ins_report(检验报告)】的数据库操作Service实现
 * @createDate 2024-03-17 22:10:02
 */
@Service
@Slf4j
public class InsReportServiceImpl extends ServiceImpl<InsReportMapper, InsReport>
        implements InsReportService {
    @Resource
    private UserMapper userMapper;
    @Resource
    private InsReportMapper insReportMapper;
    @Resource
    private InsOrderStateMapper insOrderStateMapper;
    @Resource
    private InsProductMapper insProductMapper;
    @Resource
    private InformationNotificationService informationNotificationService;
    @Value("${wordUrl}")
    private String wordUrl;
    @Value("${file.path}")
    private String imgUrl;

    @Resource
    private InsOrderMapper insOrderMapper;
    @Resource
    private IfsInventoryQuantityMapper ifsInventoryQuantityMapper;
    @Resource
    private InsUnqualifiedHandlerMapper insUnqualifiedHandlerMapper;
    @Resource
    private InsSampleMapper insSampleMapper;
    @Resource
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;
    @Resource
    private InsOrderService insOrderService;
    @Resource
    private WechatProperty wechatProperty;
    @Resource
    private InsUnqualifiedRetestProductMapper insUnqualifiedRetestProductMapper;
    @Resource
    private IfsApiUtils ifsApiUtils;
    @Resource
    private InsSampleUserMapper insSampleUserMapper;


    @Override
    public Map<String, Object> pageInsReport(Page page, ReportPageDto reportPageDto) {
        Map<String, Object> map = new HashMap<>();
        // todo: 仅看自己
        //获取当前人所属实验室id
        String laboratory = null;
        Integer createOrderUser = null;
        String queryStatus = reportPageDto.getQueryStatus();
        reportPageDto.setQueryStatus(null);

        map.put("body", insReportMapper.pageInsReport(page,
                QueryWrappers.queryWrappers(reportPageDto),
                laboratory,
                SecurityUtils.getUserId().intValue(),
                queryStatus,
                createOrderUser));
        return map;
    }

    @Override
    public int inReport(String url, Integer id) {
        InsReport insReport = new InsReport();
        insReport.setId(id);
        insReport.setUrlS(url);
        // 还原pdf
        String tempUrlPdf = wordToPdfTemp(insReport.getUrlS().replace("/word", wordUrl));
        insReport.setTempUrlPdf("/word/" + tempUrlPdf);
        return insReportMapper.updateById(insReport);
    }

    @Override
    public int upReportUrl(Integer id) {
        InsReport report = insReportMapper.selectById(id);
        // 还原pdf
        String tempUrlPdf = wordToPdfTemp(report.getUrl().replace("/word", wordUrl));

        return insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
                .eq(InsReport::getId, id)
                .set(InsReport::getUrlS, null)
                .set(InsReport::getTempUrlPdf, "/word/" + tempUrlPdf));
    }

    //提交
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int writeReport(Integer id, Integer userId, Integer submitUserId) {
        submitUserId = submitUserId == null ? SecurityUtils.getUserId().intValue() : submitUserId;
        InsReport insReport = insReportMapper.selectById(id);
        insReport.setId(id);
        insReport.setState(1);
        insReport.setWriteUserId(submitUserId);//提交人
        if (userId == null) {
            throw new ErrorException("缺少审核人");
        }
        insReport.setExamineUserId(userId);//审核人
        insReport.setWriteTime(LocalDateTime.now());//提交时间
        //获取提交人的签名地址
        String signatureUrl;
        try {
            signatureUrl = userMapper.selectById(insReport.getWriteUserId()).getSignatureUrl();
        } catch (Exception e) {
            throw new ErrorException("找不到编制人的签名");
        }
        if (ObjectUtils.isEmpty(signatureUrl) || signatureUrl.equals("")) {
            throw new ErrorException("找不到检验人的签名");
        }

        Integer insOrderId = insReportMapper.selectById(id).getInsOrderId();
        InsOrder order = insOrderMapper.selectById(insOrderId);
        boolean isRawMater = order.getTypeSource() != null && order.getTypeSource().equals(1);

        //发送消息
        InformationNotification info = new InformationNotification();
        info.setCreateUser(insProductMapper.selectUserById(userId).get("name"));
        info.setMessageType("3");
        info.setTheme("审核通知");
        info.setContent("您有一条报告编制待审核消息, 编号:" + insReport.getCode());
        info.setSenderId(submitUserId);    //发送人
        info.setConsigneeId(userId);     //收件人
        info.setViewStatus(false);
        info.setJumpPath(MenuJumpPathConstants.REPORT_PREPARATION);
        informationNotificationService.addInformationNotification(info);
        //系统生成报告地址
        String url = insReport.getUrl();
        //手动上传报告地址
        String urlS = insReport.getUrlS();

        // 判断是否是原材料  需要替换****成供应商
        IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper<IfsInventoryQuantity>()
                .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId()));
        if (one != null) {
            if (isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) {
                changeText(new HashMap<String, String>() {{
                    put("**********", one.getSupplierName());
                }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
            }
        }

        wordInsertUrl(new HashMap<String, Object>() {{
            put("writeUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
            put("writeDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create());
            put("insUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
        }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));

        // 修改临时pdf
        String tempUrlPdf = wordToPdfTemp((StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
        insReport.setTempUrlPdf("/word/" + tempUrlPdf);

        insReportMapper.updateById(insReport);

        // 清空审核时间, 审核状态
        insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
                .eq(InsReport::getId, insReport.getId())
                .set(InsReport::getRatifyTime, null)
                .set(InsReport::getIsRatify, null)
                .set(InsReport::getExamineTime, null)
                .set(InsReport::getIsExamine, null));

        return 1;
    }

    //审核
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int examineReport(Integer id, Integer isExamine, String examineTell, Integer userId) {
        InsReport insReport = insReportMapper.selectById(id);
        insReport.setIsExamine(isExamine);
        if (ObjectUtils.isNotEmpty(examineTell)) {
            insReport.setExamineTell(examineTell);
        }

        // 检验人
        String userName = insProductMapper.selectUserById(insReport.getWriteUserId()).get("name");
        String userAccount = insProductMapper.selectUserById(insReport.getWriteUserId()).get("account");

        // 审核人
        Integer checkUserId = SecurityUtils.getUserId().intValue();
        String checkUserName = insProductMapper.selectUserById(checkUserId).get("name");

        insReport.setExamineTime(LocalDateTime.now());//审核时间
        if (isExamine == 0) {
            // 发送企业微信通知(审核退回)
            threadPoolTaskExecutor.execute(() -> {
                // 查询订单
                InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId());
                InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery()
                        .eq(InsSample::getInsOrderId, insReport.getInsOrderId())
                        .last("limit 1"));
                // 查询原材料
                IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId());

                String message = "";
                message += "报告编制审核退回通知";
                message += "\n审核人: " + checkUserName;
                message += "\n委托编号: " + order.getEntrustCode();
                message += "\n样品名称: " + insSample.getModel();
                message += "\n规格型号: " + order.getPartDetail();
                if (ifsInventoryQuantity != null) {
                    message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo();
                }
                message += "\n退回原因: " + examineTell;
                //发送企业微信消息通知  提交复核
                try {
                    WxCpUtils.inform(userAccount, message, null);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });

            //如果审核不通过
            insReport.setState(0);//提交状态改为待提交
            return insReportMapper.updateById(insReport);
        } else {
            if (userId == null) {
                throw new ErrorException("缺少批准人");
            }
        }
        insReport.setRatifyUserId(userId);//批准人
        //获取审核人的签名地址
        String signatureUrl;
        try {
            signatureUrl = userMapper.selectById(insReport.getExamineUserId()).getSignatureUrl();
        } catch (Exception e) {
            throw new ErrorException("找不到审核人的签名");
        }
        if (StringUtils.isBlank(signatureUrl)) {
            throw new ErrorException("找不到审核人的签名");
        }

        // 批准人
        String sendUserAccount = insProductMapper.selectUserById(userId).get("account");

        //发送消息
        InformationNotification info = new InformationNotification();
        info.setCreateUser(insProductMapper.selectUserById(userId).get("name"));
        info.setMessageType("3");
        info.setTheme("批准通知");
        info.setContent("您有一条报告编制待批准消息, 编号:" + insReport.getCode());
        info.setSenderId(checkUserId);    //发送人
        info.setConsigneeId(userId);     //收件人
        info.setViewStatus(false);
        info.setJumpPath(MenuJumpPathConstants.REPORT_PREPARATION);
        informationNotificationService.addInformationNotification(info);
        //系统生成报告地址
        String url = insReport.getUrl();
        //手动上传报告地址
        String urlS = insReport.getUrlS();
        wordInsertUrl(new HashMap<String, Object>() {{
            put("examineUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
            put("examineDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create());
        }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));

        // 修改临时pdf
        String tempUrlPdf = wordToPdfTemp((StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl));
        insReport.setTempUrlPdf("/word/" + tempUrlPdf);

        // 发送企业微信通知(通知批准人审批)
        threadPoolTaskExecutor.execute(() -> {
            // 查询订单
            InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId());
            InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery()
                    .eq(InsSample::getInsOrderId, insReport.getInsOrderId())
                    .last("limit 1"));
            // 查询原材料
            IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId());

            String message = "";
            message += "报告编制批准通知";
            message += "\n检验人: " + userName;
            message += "\n复核人: " + checkUserName;
            message += "\n委托编号: " + order.getEntrustCode();
            message += "\n样品名称: " + insSample.getModel();
            message += "\n规格型号: " + order.getPartDetail();
            if (ifsInventoryQuantity != null) {
                message += "\n生产厂家: " + ifsInventoryQuantity.getSupplierName();
                message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo();
            }
            //发送企业微信消息通知  提交复核
            try {
                WxCpUtils.inform(sendUserAccount, message, null);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        });
        insReportMapper.updateById(insReport);

        // 清空批准备注, 批准时间, 批准状态
        insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
                .eq(InsReport::getId, insReport.getId())
                .set(InsReport::getExamineTell, null)
                .set(InsReport::getRatifyTime, null)
                .set(InsReport::getIsRatify, null));
        return 1;
    }

    //批准
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int ratifyReport(Integer id, Integer isRatify, String ratifyTell) {
        InsReport insReport = insReportMapper.selectById(id);
        insReport.setIsRatify(isRatify);
        if (ObjectUtils.isNotEmpty(ratifyTell)) {
            insReport.setRatifyTell(ratifyTell);
        }
        insReport.setRatifyTime(LocalDateTime.now());//批准时间
        if (isRatify == 0) {

            // 批准人
            Integer ratifyUserId = SecurityUtils.getUserId().intValue();
            String ratifyUserName = insProductMapper.selectUserById(ratifyUserId).get("name");

            // 发送人(审核人)(检验人)
            // 检验人
            String userAccount = insProductMapper.selectUserById(insReport.getWriteUserId()).get("account");
            // 审核人
            String checkUserAccount = insProductMapper.selectUserById(insReport.getExamineUserId()).get("account");


            // 发送企业微信通知(批准退回)
            threadPoolTaskExecutor.execute(() -> {
                // 查询订单
                InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId());
                InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery()
                        .eq(InsSample::getInsOrderId, insReport.getInsOrderId())
                        .last("limit 1"));
                // 查询原材料
                IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId());

                String message = "";
                message += "报告编制批准退回通知";
                message += "\n批准人: " + ratifyUserName;
                message += "\n委托编号: " + order.getEntrustCode();
                message += "\n样品名称: " + insSample.getModel();
                message += "\n规格型号: " + order.getPartDetail();
                if (ifsInventoryQuantity != null) {
                    message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo();
                }
                message += "\n退回原因: " + ratifyTell;
                //发送企业微信消息通知  提交复核
                try {
                    // 审批人
                    WxCpUtils.inform(checkUserAccount, message, null);

                    // 检验人
                    WxCpUtils.inform(userAccount, message, null);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });

            //如果批准不通过 直接退回到提交人那边去
            insReport.setState(0);
            insReport.setIsExamine(0);
            return insReportMapper.updateById(insReport);
        }
        //获取批准人的签名地址
        String signatureUrl;
        try {
            signatureUrl = userMapper.selectById(insReport.getRatifyUserId()).getSignatureUrl();
        } catch (Exception e) {
            throw new ErrorException("找不到批准人的签名");
        }
        if (StringUtils.isBlank(signatureUrl)) {
            throw new ErrorException("找不到批准人的签名");
        }
        Integer insOrderId = insReportMapper.selectById(id).getInsOrderId();
        InsOrder order = insOrderMapper.selectById(insOrderId);
        boolean isRawMater = order.getTypeSource() != null && order.getTypeSource().equals(1);

        //获取场所的报告专用章
        String sealUrl;
        String laboratory = insOrderMapper.selectById(insReport.getInsOrderId()).getLaboratory();
        try {
            String type = "";
            if (isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) {
                type = "进厂报告";
            } else {
                type = "委托报告";
            }
            sealUrl = insReportMapper.getLaboratoryByName(laboratory, type);
        } catch (Exception e) {
            throw new ErrorException(laboratory + "找不到报告专用章");
        }
        if (StringUtils.isBlank(sealUrl)) {
            throw new ErrorException(laboratory + "找不到报告专用章");
        }
        //系统生成报告地址
        String url = insReport.getUrl();
        //手动上传报告地址
        String urlS = insReport.getUrlS();
        String finalUrl = (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl);

        wordInsertUrl(new HashMap<String, Object>() {{
            put("ratifyUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create());
            put("ratifyDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create());
            put("seal1", Pictures.ofLocal(imgUrl + "/" + sealUrl).create());
            put("seal2", Pictures.ofLocal(imgUrl + "/" + sealUrl).create());
        }}, finalUrl);

        // 修改临时pdf
        insReport.setTempUrlPdf((StrUtil.isBlank(urlS) ? url : urlS).replace(".docx", ".pdf"));

        InsOrder insOrder = new InsOrder();
        insOrder.setId(insOrderId);
        insOrder.setState(4);
        insOrderMapper.updateById(insOrder);

        wordToPdf(finalUrl, sealUrl, isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY));

        // 判断是否为原材料
        if (isRawMater) {
            // 修改ifs库存状态
            ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper<IfsInventoryQuantity>()
                    .set(IfsInventoryQuantity::getState, 2)
                    .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId()));
        }
        insReport.setRatifyTell("");

        // 发送文件到委托人
        if (StringUtils.isNotBlank(order.getPrepareCode())) {
            threadPoolTaskExecutor.execute(() -> {
                String message = "";
                message += "委托编号: " + order.getEntrustCode();
                message += "委托样品: " + order.getSampleView();
                message += "已检测结束, 请接收";
                try {
                    WxCpUtils.inform(order.getPrepareCode(), message, new File(finalUrl.replace(".docx", ".pdf")));
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });
        }

        return insReportMapper.updateById(insReport);
    }

    @Override
    public int wordInsertUrl(Map<String, Object> map, String url) {
        XWPFTemplate template = XWPFTemplate.compile(url).render(map);
        try {
            template.writeAndClose(Files.newOutputStream(Paths.get(url)));
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return 1;
    }


    //报告批量下载
    @Override
    @Transactional(rollbackFor = Exception.class)
    public String downAll(String ids) {
        List<Long> list = Arrays.stream(ids.split(",")).map(Long::parseLong).collect(Collectors.toList());
        List<InsReport> insReports = insReportMapper.selectBatchIds(list);
        String zipFilePath = null;
        // 临时文件夹路径
        try {
            String tempFolderPath = wordUrl + "/tempFolder";
            File tempFolder = new File(tempFolderPath);
            if (tempFolder.exists()) {
                deleteDirectory(tempFolder); // 删除旧的临时文件夹
            }
            tempFolder.mkdirs(); // 创建新的临时文件夹
            for (InsReport insReport : insReports) {
                File sourceFile = new File((ObjectUtils.isNotEmpty(insReport.getUrlS()) ? insReport.getUrlS() : insReport.getUrl()).replace("/word", wordUrl));
                File destinationFile = new File(tempFolder, sourceFile.getName());
                Files.copy(sourceFile.toPath(), destinationFile.toPath(), StandardCopyOption.REPLACE_EXISTING);
            }
            // 压缩临时文件夹
            zipFilePath = wordUrl + "/zip/output.zip";
            // 判断zip路径是否存在
            File zipDir = new File(wordUrl + "/zip");
            if(!zipDir.isDirectory()){
                zipDir.mkdirs();
            }
            zipDirectory(tempFolderPath, zipFilePath);

            // 清理临时文件夹
            deleteDirectory(tempFolder);

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "/word/zip/output.zip";
    }

    //批量上传
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int upAll(MultipartFile file) throws IOException {
        File tempFile = null;
        File unzipDir = null;
        try {
            tempFile = File.createTempFile(wordUrl, ".zip");
            file.transferTo(tempFile);

            unzipDir = new File("uploaded_files");
            if (!unzipDir.exists()) {
                unzipDir.mkdir();
            }
            unzip(tempFile, unzipDir);
            // 处理解压后的文件
            File[] files = unzipDir.listFiles();
            if (files != null) {
                for (File f : files) {
                    // 根据文件名查询id
                    String name = f.getName();
                    InsReport insReport = insReportMapper.selectOne(Wrappers.<InsReport>lambdaQuery().like(InsReport::getCode, f.getName().replace(".docx", "").replace("JCZX", "JCZX/")));
                    if (ObjectUtils.isEmpty(insReport)) {
                        throw new ErrorException("没有找到 " + f.getName() + " 这个文件对应的报告数据");
                    }
                    String urlString;
                    String pathName;
                    try {
                        String path = wordUrl;
                        File realpath = new File(path);
                        if (!realpath.exists()) {
                            realpath.mkdirs();
                        }
                        pathName = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyMMddHHmmss")) + "_" + f.getName();
                        urlString = realpath + "/" + pathName;
                        // 复制文件到指定路径
                        Files.copy(f.toPath(), new File(urlString).toPath(), StandardCopyOption.REPLACE_EXISTING);
                        inReport("/word/" + pathName, insReport.getId());
                    } catch (IOException e) {
                        throw new ErrorException("文件上传失败");
                    }
                }
            }
        } catch (IOException e) {
            throw new ErrorException("文件处理失败");
        } finally {
            if (tempFile != null && tempFile.exists()) {
                tempFile.delete();
            }
            // 递归删除解压目录及其中的文件
            if (unzipDir.exists()) {
                deleteDirectory(unzipDir); // 删除旧的临时文件夹
            }
        }
        return 0;
    }


    //解压文件夹
    private void unzip(File zipFile, File destDir) throws IOException {
        try (ZipFile zip = new ZipFile(zipFile)) {
            Enumeration<? extends ZipEntry> entries = zip.entries();
            while (entries.hasMoreElements()) {
                ZipEntry entry = entries.nextElement();
                File file = new File(destDir, entry.getName());
                if (entry.isDirectory()) {
                    file.mkdirs();
                } else {
                    file.getParentFile().mkdirs();
                    try (InputStream in = zip.getInputStream(entry);
                         OutputStream out = new FileOutputStream(file)) {
                        byte[] buffer = new byte[1024];
                        int len;
                        while ((len = in.read(buffer)) > 0) {
                            out.write(buffer, 0, len);
                        }
                    }
                }
            }
        }
    }

    // 压缩文件夹
    public static void zipDirectory(String sourceDirPath, String zipFilePath) throws IOException {
        try (ZipOutputStream zipOut = new ZipOutputStream(new FileOutputStream(zipFilePath))) {
            Path sourceDir = Paths.get(sourceDirPath);
            Files.walk(sourceDir)
                    .filter(path -> !Files.isDirectory(path))
                    .forEach(path -> {
                        ZipEntry zipEntry = new ZipEntry(sourceDir.relativize(path).toString());
                        try {
                            zipOut.putNextEntry(zipEntry);
                            Files.copy(path, zipOut);
                            zipOut.closeEntry();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    });
        }
    }

    // 删除文件夹及其内容
    public static void deleteDirectory(File directory) throws IOException {
        if (directory.isDirectory()) {
            File[] files = directory.listFiles();
            if (files != null) {
                for (File file : files) {
                    deleteDirectory(file);
                }
            }
        }
        Files.delete(directory.toPath());
    }

    @Override
    public void wordToPdf(String path, String sealUrl, boolean isRawMater) {
        try {
            wordToPdf(path, path.replace(".docx", ".pdf"), sealUrl, isRawMater);
        } catch (Exception e) {
            throw new ErrorException("转换失败");
        }
    }


    public String wordToPdf(String wordPath, String pdfPath, String sealUrl, boolean isRawMater) {
        FileOutputStream os = null;
        try {
            //凭证 不然切换后有水印
            InputStream is = new ClassPathResource("/lib/license.xml").getInputStream();
            License license = new License();
            license.setLicense(is);
            if (!license.getIsLicensed()) {
                log.info("License验证不通过...");
                return null;
            }
            //生成一个空的PDF文件
            File file;
            //判断是否是进厂报告
            if (!isRawMater) {
                file = new File(pdfPath.replace(".pdf", "-1.pdf"));
            } else {
                file = new File(pdfPath.replace(".pdf", ".pdf"));
            }
            os = new FileOutputStream(file);
            //要转换的word文件
            com.aspose.words.Document doc = new com.aspose.words.Document(wordPath);
            doc.save(os, SaveFormat.PDF);

            //添加骑缝章
            if (!isRawMater) {
                stamperCheckMarkPDF(pdfPath.replace(".pdf", "-1.pdf"), pdfPath, imgUrl + "/" + sealUrl);
            }


        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (os != null) {
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return null;
    }

    /**
     * 切割图片
     *
     * @param Path 图片路径
     * @param n    切割份数
     */
    public static com.itextpdf.text.Image[] slicingImages(String Path, int n) throws IOException, BadElementException {
        com.itextpdf.text.Image[] nImage = new com.itextpdf.text.Image[n];
        BufferedImage img = ImageIO.read(new File(Path));

        int h = img.getHeight();
        int w = img.getWidth();

        int sw = w / n;
        for (int i = 0; i < n; i++) {
            BufferedImage subImg;
            if (i == n - 1) {//最后剩余部分
                subImg = img.getSubimage(i * sw, 0, w - i * sw, h);
            } else {//前n-1块均匀切
                subImg = img.getSubimage(i * sw, 0, sw, h);
            }
            ByteArrayOutputStream out = new ByteArrayOutputStream();
            ImageIO.write(subImg, Path.substring(Path.lastIndexOf('.') + 1), out);
            nImage[i] = com.itextpdf.text.Image.getInstance(out.toByteArray());

        }
        return nImage;
    }

    /**
     * 盖骑缝章
     *
     * @param infilePath  原PDF路径
     * @param outFilePath 输出PDF路径
     */
    public static void stamperCheckMarkPDF(String infilePath, String outFilePath, String picPath) throws IOException, DocumentException {
        PdfReader reader = new PdfReader(infilePath);//选择需要印章的pdf
        PdfStamper stamp = new PdfStamper(reader, new FileOutputStream(outFilePath));//加完印章后的pdf


        com.itextpdf.text.Rectangle pageSize = reader.getPageSize(1);//获得第一页
        float height = pageSize.getHeight();
        float width = pageSize.getWidth();

        int nums = reader.getNumberOfPages();
        com.itextpdf.text.Image[] nImage = slicingImages(picPath, nums);//生成骑缝章切割图片

        for (int n = 1; n <= nums; n++) {
            PdfContentByte over = stamp.getOverContent(n);//设置在第几页打印印章
            com.itextpdf.text.Image img = nImage[n - 1];//选择图片
            float newHeight = 100f;
            float newWidth = img.getWidth() / (img.getHeight() / 100);
            img.scaleAbsolute(newWidth, newHeight);//控制图片大小
            img.setAbsolutePosition(width - newWidth, height / 2 - newHeight / 2);//控制图片位置
            over.addImage(img);
        }
        stamp.close();
    }

    @Transactional(rollbackFor = Exception.class)
    public void isRawMaterial(InsOrder insOrder) {
        IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper<IfsInventoryQuantity>()
                .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()));
        if (Objects.isNull(one)) {
            throw new ErrorException("找不到原材料信息");
        }
        // 判断是否有不合格信息
        Long count = insUnqualifiedHandlerMapper.selectCount(Wrappers.<InsUnqualifiedHandler>lambdaQuery()
                .eq(InsUnqualifiedHandler::getInventoryQuantityId, one.getId()));
        String toLocation = null;

        // 判断是否有不合格
        Long unqualifiedCount = getUnqualifiedCount(insOrder);

        if (count.equals(0L) && unqualifiedCount.equals(0L) && one.getIsFinish().equals(0) && one.getIsSource().equals(1)) {
            // 原材料移库
            toLocation = this.moveRawMaterial(one);
        }

        // 判断结束状态修改合格状态
        int inspectStatus = (count == 0 && unqualifiedCount == 0) ? 1 : 2;
        insOrderMapper.update(null, Wrappers.<InsOrder>lambdaUpdate()
                .eq(InsOrder::getId, insOrder.getId())
                .set(InsOrder::getInsResult, inspectStatus));

        if (one.getIsFinish().equals(0)) {
            ifsInventoryQuantityMapper.update(null, Wrappers.<IfsInventoryQuantity>lambdaUpdate()
                    .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())
                    .set(IfsInventoryQuantity::getInspectStatus, inspectStatus));

            // 修改ifs库存状态
            if (StringUtils.isBlank(toLocation)) {
                ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper<IfsInventoryQuantity>()
                        .set(IfsInventoryQuantity::getIsFinish, 1)
                        .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()));
            } else {
                ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper<IfsInventoryQuantity>()
                        .set(IfsInventoryQuantity::getIsFinish, 1)
                        .set(IfsInventoryQuantity::getToLocation, toLocation)
                        .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()));
            }

            threadPoolTaskExecutor.execute(() -> {
                // 企业微信通知
                String message = "";
                message += "检测结果提交通知";
                message += "\n批次号: " + one.getUpdateBatchNo();
                message += "\n零件号: " + one.getPartNo();
                message += "\n零件描述: " + one.getPartDesc();
                message += "\n供应商名称: " + one.getSupplierName();
                message += "\n抵达数量: " + one.getQtyArrived().stripTrailingZeros().toPlainString() + one.getBuyUnitMeas();
                // 发送企业inspectStatus信通知
                if (inspectStatus == 1) {
                    message += "\n检测结果: 合格";
                } else {
                    message += "\n检测结果: 不合格";
                }
                WxCpUtils.informWebHook(wechatProperty.getExaminingUrl(), message);
            });

        }


    }

    /**
     * 判断是否有不合格
     * @param insOrder
     * @return
     */
    @Override
    public Long getUnqualifiedCount(InsOrder insOrder) {
        Long unqualifiedCount = 0L;
        List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery()
                .eq(InsSample::getInsOrderId, insOrder.getId()));
        if (CollectionUtils.isNotEmpty(insSamples)) {
            unqualifiedCount = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery()
                    .in(InsProduct::getInsSampleId, insSamples.stream().map(InsSample::getId).collect(Collectors.toList()))
                    .eq(InsProduct::getInsResult, 0));

            // 判断如果有不合格的检验项, 判断有没有检验项复测, 复核合格也算合格通过
            if (!unqualifiedCount.equals(0L)) {
                List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()
                        .in(InsProduct::getInsSampleId, insSamples.stream().map(InsSample::getId).collect(Collectors.toList()))
                        .eq(InsProduct::getInsResult, 0));

                boolean flag = true;
                for (InsProduct insProduct : insProducts) {
                    Long unqualifiedProductCount = insUnqualifiedRetestProductMapper.selectCount(Wrappers.<InsUnqualifiedRetestProduct>lambdaQuery()
                            .eq(InsUnqualifiedRetestProduct::getInsProductId, insProduct.getId())
                            .ne(InsUnqualifiedRetestProduct::getInsResult, 0));
                    if (unqualifiedProductCount != 2) {
                        flag = false;
                    }
                }
                if (flag) {
                    unqualifiedCount = 0L;
                }
            }
        }
        return unqualifiedCount;
    }

    /**
     * ifs移库操作
     * @param one
     * @return
     */
    @Override
    public String moveRawMaterial(IfsInventoryQuantity one) {
        String toLocation;
        // 登记采购检验结果STD
        if (one.getIsRegister().equals(0)) {
            Map<String, Object> resultMap = new HashMap<>();
            List<Map<String, Object>> resultList = new ArrayList<>();
            Map<String, Object> map = new HashMap<>();
            map.put("ORDER_NO", one.getOrderNo()); // 采购订单号
            map.put("LINE_NO", one.getLineNo()); // 行号
            map.put("RELEASE_NO", one.getReleaseNo()); // 下达号
            map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号
            map.put("PURCH_QTY", one.getQtyToInspect()); // 要检验的采购数量
            resultList.add(map);
            resultMap.put("RECORD_ID", UUID.randomUUID().toString());
            resultMap.put("SYSCODE", "LIMS");
            resultMap.put("SYSMODEL", "登记采购检验结果");
            resultMap.put("BATCH_INFO", resultList);
            Result result = ifsApiUtils.getProcurementResults(JSONUtil.toJsonStr(resultMap));
            if (result.getCode() != 200) {
                throw new ErrorException("IFS登记采购检验结果失败: " + result.getMessage());
            }
        }
        insOrderService.updateIfsInventoryQuantity(one.getId());
        /**
         * TODO 后续需要调用IFS的接口 移入的库位号 toLocation
         */
        // 检验后移库
        toLocation = "1301";
        Map<String, Object> moveResultMap = new HashMap<>();
        List<Map<String, Object>> moveResultList = new ArrayList<>();
        Map<String, Object> moveMap = new HashMap<>();
        moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号
        moveMap.put("LINE_NO", one.getLineNo());
        moveMap.put("RELEASE_NO", one.getReleaseNo());
        moveMap.put("RECEIPT_NO", one.getReceiptNo());
        moveMap.put("PART_NO", one.getPartNo());
        moveMap.put("QTY", one.getQtyArrived());
        moveMap.put("LOCATION_NO", one.getLocationNo());
        moveMap.put("TO_LOCATION_NO", toLocation);
        moveMap.put("LOT_BATCH_NO", one.getLotBatchNo());
        moveMap.put("SERIAL_NO", one.getSerialNo());
        moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo());
        moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel());
        moveMap.put("ACTIVITY_SEQ", one.getActivitySeq());
        moveResultList.add(moveMap);
        moveResultMap.put("RECORD_ID", UUID.randomUUID().toString());
        moveResultMap.put("SYSCODE", "LIMS");
        moveResultMap.put("SYSMODEL", "检验后移库");
        moveResultMap.put("BATCH_INFO", moveResultList);

        Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap));
        // 如果有必须为零件指定批号报错需要重新提交移库信息去指定批号
        if (result1.getCode() != 200) {
            String message = result1.getMessage();
            if (message.contains("必须为零件") && message.contains("指定批号")) {
                updaeBatch(one, toLocation);
            } else {
                throw new ErrorException("IFS检验后移库失败: " + result1.getMessage());
            }
        }
        return toLocation;
    }

    /**
     * 退回到检验任务
     * @param id
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean sendBackTask(Integer id) {
        InsReport report = insReportMapper.selectById(id);
        // 根据订单查询试验室
        String laboratory = insOrderMapper.selectLaboratoryByOrderId(report.getInsOrderId());

        // 修改订单状态
        insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate()
                .eq(InsOrderState::getInsOrderId, report.getInsOrderId())
                .eq(InsOrderState::getLaboratory, laboratory)
                .set(InsOrderState::getInsState, 4));

        Integer insSampleId = insSampleUserMapper.selectOne(Wrappers.<InsSampleUser>lambdaQuery()
                .eq(InsSampleUser::getInsSampleId, report.getInsOrderId())
                .orderByDesc(InsSampleUser::getId)
                .last("limit 1")).getId();
        insSampleUserMapper.deleteById(insSampleId);

        // 修改报告行为未显示
        insReportMapper.update(null, Wrappers.<InsReport>lambdaUpdate()
                .eq(InsReport::getId, id)
                .set(InsReport::getIsPass, 0));

        return false;
    }


    /**
     * 先修改采购订单批次号, 后进行移库操作
     * @param one
     * @param toLocation
     */
    private void updaeBatch(IfsInventoryQuantity one, String toLocation) {
        if (one.getIsUpdateBatch().equals(0)) {
            // 先修改批次号后进行移库
            Map<String, Object> resultMap = new HashMap<>();
            List<Map<String, Object>> resultList = new ArrayList<>();
            Map<String, Object> map = new HashMap<>();
            map.put("ORDER_NO", one.getOrderNo()); // 采购订单号
            map.put("LINE_NO", one.getLineNo()); // 行号
            map.put("RELEASE_NO", one.getReleaseNo()); // 下达号
            map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号
            map.put("PART_NO", one.getPartNo()); //零件号
            map.put("CONFIGURATION_ID", one.getConfigurationId()); // 配置标识
            map.put("LOCATION_NO", one.getLocationNo()); // 库位号
            map.put("LOT_BATCH_NO", one.getLotBatchNo());// 批次号
            map.put("NEW_LOT_BATCH_NO", one.getUpdateBatchNo()); // 目标批次号
            map.put("SERIAL_NO", one.getSerialNo()); // 序列号
            map.put("ENG_CHG_LEVEL", one.getEngChgLevel()); // 版本号
            map.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); // wdr号
            map.put("ACTIVITY_SEQ", one.getActivitySeq()); // 活动序号
            map.put("QTY_TO_CHANGE", one.getQtyArrived()); // 变更数量
            resultList.add(map);
            resultMap.put("RECORD_ID", UUID.randomUUID().toString());
            resultMap.put("SYSCODE", "LIMS");
            resultMap.put("SYSMODEL", "修改采购订单批次号");
            resultMap.put("BATCH_INFO", resultList);

            Result result = ifsApiUtils.updateMoveReceiptLot(JSONUtil.toJsonStr(resultMap));

            if (result.getCode() != 200) {
                throw new ErrorException("IFS修改批次号失败: " + result.getMessage());
            }
            ifsInventoryQuantityMapper.update(null, Wrappers.<IfsInventoryQuantity>lambdaUpdate()
                    .set(IfsInventoryQuantity::getIsUpdateBatch, 1)
                    .eq(IfsInventoryQuantity::getId, one.getId()));
        }

        Map<String, Object> moveResultMap = new HashMap<>();
        List<Map<String, Object>> moveResultList = new ArrayList<>();
        Map<String, Object> moveMap = new HashMap<>();
        moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号
        moveMap.put("LINE_NO", one.getLineNo());
        moveMap.put("RELEASE_NO", one.getReleaseNo());
        moveMap.put("RECEIPT_NO", one.getReceiptNo());
        moveMap.put("PART_NO", one.getPartNo());
        moveMap.put("QTY", one.getQtyArrived());
        moveMap.put("LOCATION_NO", one.getLocationNo());
        moveMap.put("TO_LOCATION_NO", toLocation);
        moveMap.put("LOT_BATCH_NO", one.getUpdateBatchNo());
        moveMap.put("SERIAL_NO", one.getSerialNo());
        moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo());
        moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel());
        moveMap.put("ACTIVITY_SEQ", one.getActivitySeq());
        moveResultList.add(moveMap);
        moveResultMap.put("RECORD_ID", UUID.randomUUID().toString());
        moveResultMap.put("SYSCODE", "LIMS");
        moveResultMap.put("SYSMODEL", "检验后移库");
        moveResultMap.put("BATCH_INFO", moveResultList);

        Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap));
        if (result1.getCode() != 200) {
            throw new ErrorException("IFS检验后移库失败: " + result1.getMessage());
        }

    }

    /**
     * 替换段落文本
     * @param filePath docx解析对象
     * @param textMap 需要替换的信息集合
     */
    public static void changeText(Map<String, String> textMap, String filePath) {
        try {
            FileInputStream stream = new FileInputStream(filePath);
            XWPFDocument document = new XWPFDocument(stream);
            List<XWPFTable> tables = document.getTables();
            for (XWPFTable table : tables) {
                for (XWPFTableRow row : table.getRows()) {
                    for (XWPFTableCell cell : row.getTableCells()) {

                        textMap.forEach((s, s2) -> {
                            if (cell.getText().equals(s)) {
                                XWPFParagraph paragraph = cell.getParagraphs().get(0);
                                XWPFRun oldRun = paragraph.getRuns().get(0);
                                // 保存原样式
                                String fontFamily = oldRun.getFontFamily();
                                int fontSize = oldRun.getFontSize();
                                String color = oldRun.getColor();
                                ParagraphAlignment alignment = paragraph.getAlignment();
                                // 替换内容
                                paragraph.removeRun(0); // 移除原有的 run
                                XWPFRun newRun = paragraph.createRun();
                                newRun.setText(s2);
                                // 应用原样式
                                newRun.setFontFamily(fontFamily);
                                newRun.setFontSize(fontSize);
                                newRun.setColor(color);
                                paragraph.setAlignment(alignment);
                            }
                        });
                    }
                }
            }
            FileOutputStream fileOutputStream = new FileOutputStream(filePath);
            document.write(fileOutputStream);
            fileOutputStream.close();

        } catch (Exception e) {
            e.printStackTrace();
            throw new ErrorException(e.getMessage());
        }
    }

    /**
     * word转换pdf
     * @param path
     * @return
     */
    private String wordToPdfTemp(String path) {
        try {
            return wordToPdf(path, path.replace(".docx", "-临时.pdf"));
        } catch (Exception e) {
            throw new ErrorException("转换失败");
        }
    }

    private String wordToPdf(String wordPath, String pdfPath) {
        FileOutputStream os = null;
        try {
            //凭证 不然切换后有水印
            InputStream is = new ClassPathResource("/lib/license.xml").getInputStream();
            License license = new License();
            license.setLicense(is);
            if (!license.getIsLicensed()) {
                log.info("License验证不通过...");
                return null;
            }
            //生成一个空的PDF文件
            File file;
            //判断是否是进厂报告
            file = new File(pdfPath);
            os = new FileOutputStream(file);
            //要转换的word文件
            com.aspose.words.Document doc = new com.aspose.words.Document(wordPath);
            doc.save(os, SaveFormat.PDF);
            return file.getName();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (os != null) {
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return null;
    }
}