更新解压

whycxzp

2024-01-03 d2ba7ed50955701234b1b50ceaf04fe36b86c61d

 src/main/java/com/whyc/service/WorksheetMainService.java

@@ -5,6 +5,7 @@
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.config.EnumWorksheetType;
import com.whyc.dto.MailDTO;
import com.whyc.dto.Response;
import com.whyc.dto.WorksheetMainDTO;
import com.whyc.dto.WorksheetMainDTO2;
@@ -13,8 +14,11 @@
import com.whyc.mapper.WorksheetMainMapper;
import com.whyc.pojo.*;
import com.whyc.util.CommonUtil;
import com.whyc.util.Word2PdfAsposeUtil;
import com.whyc.util.WordUtil;
import com.whyc.util.Zip4jUtil;
import org.aspectj.util.FileUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
@@ -22,6 +26,8 @@
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.mail.MessagingException;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.text.SimpleDateFormat;
@@ -77,6 +83,12 @@

    @Autowired
    private ProductHistoryService productHistoryService;

    @Autowired
    private MailService mailService;

    @Autowired
    private ProcedureDocApprovingService procedureDocApprovingService;

    @Transactional
    public boolean submit(WorksheetMain main, DocUser user) throws IOException {
@@ -725,4 +737,187 @@

    }

    public Response addProductProcedureAndSOP(ProcedureDocApproving approving, DocUser user) throws IOException, MessagingException {
        WorksheetMain main = new WorksheetMain();
         //存储上传信息到主表,节点表
        //文件保存在/doc_file/procedure_approving/xxx_时间戳.doc
        MultipartFile multipartFile = approving.getMultipartFile();
        String originalFilename = multipartFile.getOriginalFilename();
        String rootFile = CommonUtil.getRootFile();
        Date date = new Date();
        String filename = originalFilename.replace(".doc","_"+date.getTime()+".doc");
        String suffixFilePath = "procedure_approving" + File.separator + filename;
        String outFilePath = rootFile + suffixFilePath;
        File outFile = new File(outFilePath);
        multipartFile.transferTo(outFile);

        main.setTitle(approving.getName());
        main.setDescription(approving.getDescription());
        main.setCreateUserId(user.getId());
        main.setBeginTime(date);
        main.setStatus(1);
        if(approving.getType()==1){
            main.setType(EnumWorksheetType.ProductProcedure.getType());
        }else{
            main.setType(EnumWorksheetType.SOP.getType());
        }
        mainMapper.insert(main);

        List<WorksheetLink> links = new LinkedList<>();
        WorksheetLink baseLink = new WorksheetLink();
        WorksheetLink linkFzr = new WorksheetLink();
        WorksheetLink linkBz = new WorksheetLink();
        WorksheetLink linkZz = new WorksheetLink();
        WorksheetLink linkPb = new WorksheetLink();

        baseLink.setMainId(main.getId());
        baseLink.setLinkStatus(0);
        baseLink.setCreateTime(date);

        BeanUtils.copyProperties(baseLink,linkFzr);
        BeanUtils.copyProperties(baseLink,linkBz);
        BeanUtils.copyProperties(baseLink,linkZz);
        BeanUtils.copyProperties(baseLink,linkPb);

        linkFzr.setDealUserId(approving.getFzr());
        linkBz.setDealUserId(approving.getBz());
        linkZz.setDealUserId(approving.getZz());
        linkPb.setDealUserId(approving.getPb());
        links.add(linkFzr);
        links.add(linkBz);
        links.add(linkZz);
        links.add(linkPb);
        linkMapper.insertBatchSomeColumn(links);

        //流程文档审批子表存入
        approving.setFile("doc_file"+ File.separator + suffixFilePath);
        approving.setMainId(main.getId());
        procedureDocApprovingService.insert(approving);
        //发送邮件给四个确认人
        QueryWrapper<DocUser> query = Wrappers.query();
        query.select("mail").in("id",approving.getFzr(),approving.getBz(),approving.getZz(),approving.getPb());
        List<DocUser> docUsers = userMapper.selectList(query);
        List<String> userMailList = docUsers.stream().map(DocUser::getMail).collect(Collectors.toList());

        MailDTO mailDTO = new MailDTO();
        mailDTO.setMailList(userMailList);
        if(approving.getType()==1){
            mailDTO.setTitle("【流程卡确认】"+main.getTitle());
            mailDTO.setContent(user.getName()+"在文档管理平台上传了产品流程卡,请及时确认");
        }else{
            mailDTO.setTitle("【SOP确认】"+main.getTitle());
            mailDTO.setContent(user.getName()+"在文档管理平台上传了SOP,请及时确认");
        }
        mailService.sendMail(mailDTO);

        return new Response().setII(1,"上传完成");
    }

    /**
     * 统计数量:
     *  我的提交
     *  待处理
     *  已处理
     * @param user
     * @return
     */
    public Map<String, Integer> getProcedureDocApprovingStatusStatistic(DocUser user) {
        Map<String,Integer> map = new HashMap<>();

        //我的提交
        QueryWrapper<WorksheetMain> query = Wrappers.query();
        query.eq("create_user_id",user.getId()).in("type",EnumWorksheetType.ProductProcedure.getType(),EnumWorksheetType.SOP.getType());
        List<WorksheetMain> worksheetMains = mainMapper.selectList(query);
        map.put("mySubmit",worksheetMains.size());
        //待处理|已处理
        int handlingCount = 0;
        int handledCount = 0;
        List<WorksheetLink> links = linkMapper.getProcedureDocApprovingByUserId(user.getId());
        for (WorksheetLink link : links) {
            //dealType的值为主表的状态
            if(link.getDealType() == 1 && link.getLinkStatus() == 0){ //未处理且审批未结束
                handlingCount++;
            }else if(link.getLinkStatus() == 1 || link.getLinkStatus() ==2){ //已确认或已拒绝
                handledCount++;
            }
        }
        map.put("handling",handlingCount);
        map.put("handled",handledCount);
        return map;
    }

    public Response procedurePreview(HttpServletResponse response, int mainId) throws IOException {
        //查询当前单据审批人的确认状态
        ProcedureDocApproving approving = procedureDocApprovingService.getByMainId(mainId);
        List<WorksheetLink> linkList = linkMapper.getList(mainId);
        String fzr = linkList.get(0).getLinkStatus() == 1 ? linkList.get(0).getDealUsername():"";
        String bz = linkList.get(1).getLinkStatus() == 1 ? linkList.get(1).getDealUsername():"";
        String zz = linkList.get(2).getLinkStatus() == 1 ? linkList.get(2).getDealUsername():"";
        String pb = linkList.get(3).getLinkStatus() == 1 ? linkList.get(3).getDealUsername():"";
        List<String> list = new LinkedList();
        list.add(fzr);
        list.add(bz);
        list.add(zz);
        list.add(pb);
        //获取word模板具体文件

        long currentTimeMillis = System.currentTimeMillis();
        String projectDir = CommonUtil.getProjectDir();
        String fileRelativePath = approving.getFile();
        String inFilePath = projectDir + File.separator + fileRelativePath;
        String outFilePath = inFilePath.replace(".doc","_"+currentTimeMillis+".doc");
        WordUtil.fillValue(inFilePath,outFilePath,list);
        //pdf带水印的地址 /doc_file/procedure_approving/xxx.doc
        String suffixOutPdfFilePath = "doc_file" + File.separator + "procedure_approving" + File.separator + outFilePath.substring(outFilePath.lastIndexOf(File.separator)+1,outFilePath.lastIndexOf(".")) + ".pdf";
        String outPdfFilePath = projectDir + File.separator + suffixOutPdfFilePath;
        Word2PdfAsposeUtil.doc2pdfWithWaterMark(outFilePath,outPdfFilePath,true);
        return new Response().setII(1,suffixOutPdfFilePath);
        /*try {
            // 转码防止乱码
            //resp.addHeader("Content-Disposition", "attachment;filename=" + new String(softwareName.getBytes("UTF-8"), "ISO8859-1"));
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode ( fileRelativePath.substring(fileRelativePath.lastIndexOf(File.separator+1)), "utf-8"));
            OutputStream out = response.getOutputStream();
            FileInputStream in = new FileInputStream(outFilePath);
            int len=0;
            byte[] buffer =new byte[1024];
            //7. 将缓冲区中的数据输出
            while ((len=in.read(buffer))>0){
                out.write(buffer,0,len);
            }
            in.close();
            out.close();
        } catch (FileNotFoundException | UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }*/
    }

    /**
     * 查询所有的工单,所有人可见
     * @param param
     * @return
     */
    public Response getAllPage(WorksheetMain param) {
        Integer pageNum = param.getPageNum();
        Integer pageSize = param.getPageSize();
        PageHelper.startPage(pageNum,pageSize);

        int createUserId = param.getCreateUserId().intValue();
        Date beginTime = param.getBeginTime();
        Date endTime = param.getEndTime();
        Integer type = param.getType();
        QueryWrapper<WorksheetMain> query = Wrappers.query();
        if(createUserId>0){
            query.eq("create_user_id",createUserId);
        }
        query.ge("begin_time",beginTime);
        query.le("begin_time",endTime);
        if(type!=null && type>=0){
            query.eq("type",type);
        }
        List<WorksheetMain> worksheetMains = mainMapper.selectList(query);
        PageInfo pageInfo = new PageInfo(worksheetMains);
        return new Response().set(1,pageInfo);
    }
}