package org.jeecg.modules.activiti.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.activiti.bpmn.converter.BpmnXMLConverter;
import org.activiti.bpmn.model.BpmnModel;
import org.activiti.editor.constants.ModelDataJsonConstants;
import org.activiti.editor.language.json.converter.BpmnJsonConverter;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.Model;
import org.activiti.engine.repository.ModelQuery;
import org.activiti.engine.repository.ProcessDefinition;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.jeecg.common.base.entity.ActZprocess;
import org.jeecg.modules.activiti.mapper.ReModelMapper;
import org.jeecg.modules.activiti.model.entity.ReModelEntity;
import org.jeecg.modules.activiti.service.IActZprocessService;
import org.jeecg.modules.activiti.service.ReModelService;
import org.jeecg.common.Constant;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.exception.CustomException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayInputStream;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.List;
import java.util.Map;

/**
 * 模型实现类
 *
 * @author len
 * @date 2019/06/12
 */
@Service
public class ReModelServiceImpl extends ServiceImpl<ReModelMapper, ReModelEntity> implements ReModelService {
    @Autowired
    private RepositoryService repositoryService;

    @Autowired
    private ActZprocessServiceImpl actZprocessService;

    @Override
    public IPage queryPage(Integer pageNo, Integer pageSize, HttpServletRequest req) {

//        String tenantId = req.getHeader("tenant-id");
//        .modelTenantId(tenantId)
        ModelQuery modelQuery = repositoryService.createModelQuery()
                .orderByLastUpdateTime()
                .desc()
                .orderByModelVersion().desc();
        String[] keys = req.getParameterMap().get("key");
        if (!"".equals(keys) && keys != null) {
            String key = keys[0];
            modelQuery.modelKey(key);
        }
        String[] names = req.getParameterMap().get("name");
        if (!"".equals(names) && names != null) {
            String name = names[0];
            modelQuery.modelName(name);
        }
        List<Model> list = modelQuery.listPage((pageNo - 1) * pageSize, pageSize);
        IPage<Model> page = new Page<>(pageNo, pageSize);
        page.setTotal((int) modelQuery.count());

        return page.setRecords(list);
    }

    @Override
    public Model add(ReModelEntity actReModel) throws UnsupportedEncodingException {
        String description = actReModel.getDescription();
        String key = actReModel.getKey();
        String name = actReModel.getName();
        String tenantId = actReModel.getTenantId();
        ObjectMapper objectMapper = new ObjectMapper();
        ObjectNode editorNode = objectMapper.createObjectNode();
        editorNode.put("id", "canvas");
        editorNode.put("resourceId", "canvas");
        ObjectNode stencilSetNode = objectMapper.createObjectNode();
        stencilSetNode.put("namespace", "http://b3mn.org/stencilset/bpmn2.0#");
        editorNode.set("stencilset", stencilSetNode);
        Model modelData = repositoryService.newModel();

        description = StringUtils.defaultString(description);
        modelData.setKey(StringUtils.defaultString(key));
        modelData.setName(name);
        modelData.setVersion(Integer
                .parseInt(String.valueOf(repositoryService.createModelQuery().modelKey(modelData.getKey()).count() + 1)));

        ObjectNode modelObjectNode = objectMapper.createObjectNode();
        modelObjectNode.put(ModelDataJsonConstants.MODEL_NAME, name);
        modelObjectNode.put(ModelDataJsonConstants.MODEL_REVISION, modelData.getVersion());
        modelObjectNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description);
        modelData.setMetaInfo(modelObjectNode.toString());
        modelData.setTenantId(tenantId);
        repositoryService.saveModel(modelData);
        repositoryService.addModelEditorSource(modelData.getId(), editorNode.toString().getBytes("utf-8"));

        return modelData;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Result deploy(String id,HttpServletRequest request) {
        String message = "";
        try {
            Model modelData = repositoryService.getModel(id);
            if(StringUtils.isEmpty(modelData.getTenantId())){
                String tenantId = request.getHeader("tenant-id");
                modelData.setTenantId(tenantId);
            }
            byte[] bytes = repositoryService.getModelEditorSource(modelData.getId());
            if (bytes == null) {
                return Result.error("模型为空");
            }
            BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
            JsonNode editor = new ObjectMapper().readTree(bytes);
            BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editor);
            if (bpmnModel.getProcesses().size() == 0) {
                return Result.error("部署失败，没有设计流程");
            }
            BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
            byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);

            String processName = modelData.getName();
            if (!StringUtils.endsWith(processName, Constant.ACT_BPMN20)) {
                processName += Constant.ACT_BPMN20;
            }
            ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
            Deployment deployment =
                    repositoryService.createDeployment()
                       .name(modelData.getName())
                       .addInputStream(processName, in)
                       .tenantId(modelData.getTenantId())
                       .deploy();
            // 设置流程分类
            modelData.setDeploymentId(deployment.getId());
            repositoryService.saveModel(modelData);
            String metaInfo = modelData.getMetaInfo();
            JSONObject metaInfoMap = JSON.parseObject(metaInfo);
            List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).list();
            for(ProcessDefinition pd : list) {
                ActZprocess actZprocess = new ActZprocess();
                actZprocess.setId(pd.getId());
                actZprocess.setName(modelData.getName());
                actZprocess.setProcessKey(modelData.getKey());
                actZprocess.setDeploymentId(deployment.getId());
                actZprocess.setDescription(metaInfoMap.getString(ModelDataJsonConstants.MODEL_DESCRIPTION));
                actZprocess.setVersion(pd.getVersion());
                actZprocess.setDiagramName(pd.getDiagramResourceName());
                actZprocessService.setAllOldByProcessKey(modelData.getKey());
                actZprocess.setLatest(true);
                actZprocessService.save(actZprocess);
            }
            return Result.OK("部署成功，流程ID=" + modelData.getId());
        } catch (Exception e) {
            throw new CustomException("部署失败", e);
        }
    }

    @Override
    public void export(String id, HttpServletResponse response) {
        try {
            Model modelData = repositoryService.getModel(id);
            BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
            JsonNode editor = new ObjectMapper().readTree(repositoryService.getModelEditorSource(modelData.getId()));
            BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editor);
            BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
            byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);

            ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
            IOUtils.copy(in, response.getOutputStream());
            String filename = URLEncoder.encode(modelData.getName() + ".bpmn20.xml", "UTF-8");
            response.setHeader("Content-Disposition", "attachment; filename=" + filename);
            response.flushBuffer();
        } catch (Exception e) {
            throw new CustomException("导出model的xml文件失败，模型ID=" + id, e);
        }

    }

    @Override
    public void delete(String id) {
        repositoryService.deleteModel(id);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteBatch(String[] ids) {
        for (String id : ids) {
            repositoryService.deleteModel(id);
        }
    }
}