兰宝车间质量管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
疯狂的狮子Li
2025-01-24 3bf26cd509f08e61e99d4a977fd37ff04f740458 
 ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/FlwDefinitionServiceImpl.java


@@ -3,22 +3,20 @@


import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.convert.Convert;


import cn.hutool.core.io.IoUtil;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import jakarta.servlet.http.HttpServletResponse;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.dom4j.Document;


import org.dom4j.io.OutputFormat;


import org.dom4j.io.XMLWriter;


import org.dromara.common.core.exception.ServiceException;


import org.dromara.common.core.utils.StreamUtils;


import org.dromara.common.core.utils.StringUtils;


import org.dromara.common.json.utils.JsonUtils;


import org.dromara.common.mybatis.core.page.PageQuery;


import org.dromara.common.mybatis.core.page.TableDataInfo;


import org.dromara.warm.flow.core.dto.FlowCombine;


import org.dromara.warm.flow.core.entity.Definition;


import org.dromara.warm.flow.core.dto.DefJson;


import org.dromara.warm.flow.core.enums.NodeType;


import org.dromara.warm.flow.core.enums.PublishStatus;


import org.dromara.warm.flow.core.service.DefService;


@@ -30,18 +28,19 @@


import org.dromara.warm.flow.orm.mapper.FlowHisTaskMapper;


import org.dromara.warm.flow.orm.mapper.FlowNodeMapper;


import org.dromara.warm.flow.orm.mapper.FlowSkipMapper;


import org.dromara.workflow.common.ConditionalOnEnable;


import org.dromara.workflow.common.constant.FlowConstant;


import org.dromara.workflow.domain.FlowCategory;


import org.dromara.workflow.domain.vo.FlowDefinitionVo;


import org.dromara.workflow.mapper.FlwCategoryMapper;


import org.dromara.workflow.service.IFlwDefinitionService;


import org.dromara.workflow.utils.WorkflowUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import java.io.IOException;


import java.nio.charset.StandardCharsets;


import java.util.ArrayList;


import java.util.Arrays;


import java.util.List;


@@ -53,22 +52,17 @@


 *


 * @author may


 */


@ConditionalOnEnable


@Slf4j


@RequiredArgsConstructor


@Service


public class FlwDefinitionServiceImpl implements IFlwDefinitionService {




    @Autowired(required = false)


    private DefService defService;


    @Autowired(required = false)


    private FlowDefinitionMapper flowDefinitionMapper;


    @Autowired(required = false)


    private FlowHisTaskMapper flowHisTaskMapper;


    @Autowired(required = false)


    private FlowNodeMapper flowNodeMapper;


    @Autowired(required = false)


    private FlowSkipMapper flowSkipMapper;




    private final DefService defService;


    private final FlowDefinitionMapper flowDefinitionMapper;


    private final FlowHisTaskMapper flowHisTaskMapper;


    private final FlowNodeMapper flowNodeMapper;


    private final FlowSkipMapper flowSkipMapper;


    private final FlwCategoryMapper flwCategoryMapper;




    /**


@@ -113,7 +107,7 @@


        wrapper.like(StringUtils.isNotBlank(flowDefinition.getFlowName()), FlowDefinition::getFlowName, flowDefinition.getFlowName());


        if (StringUtils.isNotBlank(flowDefinition.getCategory())) {


            List<Long> categoryIds = flwCategoryMapper.selectCategoryIdsByParentId(Convert.toLong(flowDefinition.getCategory()));


            wrapper.in(FlowDefinition::getCategory, categoryIds);


            wrapper.in(FlowDefinition::getCategory, StreamUtils.toList(categoryIds, Convert::toStr));


        }


        wrapper.orderByDesc(FlowDefinition::getCreateTime);


        return wrapper;


@@ -125,6 +119,7 @@


     * @param id 流程定义id


     */


    @Override


    @Transactional(rollbackFor = Exception.class)


    public boolean publish(Long id) {


        List<FlowNode> flowNodes = flowNodeMapper.selectList(new LambdaQueryWrapper<FlowNode>().eq(FlowNode::getDefinitionId, id));


        List<String> errorMsg = new ArrayList<>();


@@ -148,16 +143,15 @@


     * @param file 文件


     */


    @Override


    public boolean importXml(MultipartFile file, String category) {


    @Transactional(rollbackFor = Exception.class)


    public boolean importJson(MultipartFile file, String category) {


        try {


            FlowCombine combine = defService.readXml(file.getInputStream());


            // 流程定义


            Definition definition = combine.getDefinition();


            definition.setCategory(category);


            defService.importFlow(combine);


        } catch (Exception e) {


            log.error("导入流程定义错误: {}", e.getMessage(), e);


            throw new RuntimeException(e);


            DefJson defJson = JsonUtils.parseObject(file.getBytes(), DefJson.class);


            defJson.setCategory(category);


            defService.importDef(defJson);


        } catch (IOException e) {


            log.error("读取文件流错误: {}", e.getMessage(), e);


            throw new IllegalStateException("文件读取失败，请检查文件内容", e);


        }


        return true;


    }


@@ -171,24 +165,14 @@


     */


    @Override


    public void exportDef(Long id, HttpServletResponse response) throws IOException {


        Document document = defService.exportXml(id);


        // 设置生成xml的格式


        OutputFormat of = OutputFormat.createPrettyPrint();


        // 设置编码格式


        of.setEncoding("UTF-8");


        of.setIndent(true);


        of.setIndent("    ");


        of.setNewlines(true);




        // 创建一个xml文档编辑器


        XMLWriter writer = new XMLWriter(response.getOutputStream(), of);


        writer.setEscapeText(false);


        byte[] data = defService.exportJson(id).getBytes(StandardCharsets.UTF_8);


        // 设置响应头和内容类型


        response.reset();


        response.setCharacterEncoding("UTF-8");


        response.setContentType("application/x-msdownload");


        response.setCharacterEncoding(StandardCharsets.UTF_8.name());


        response.setContentType("application/text");


        response.setHeader("Content-Disposition", "attachment;");


        writer.write(document);


        writer.close();


        response.addHeader("Content-Length", "" + data.length);


        IoUtil.write(response.getOutputStream(), false, data);


    }




    /**