package com.lxzn.activiti;

import com.lxzn.base.service.IDncPassLogService;
import com.lxzn.framework.domain.base.DncPassLog;
import com.lxzn.framework.domain.base.SysLogMessageDto;
import com.lxzn.framework.domain.base.SysLogTypeObjectDto;
import com.lxzn.framework.utils.FileClient;
import com.lxzn.framework.utils.SyslogClient;
import com.lxzn.framework.utils.date.DateUtil;
import com.lxzn.framework.utils.file.FileUtil;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.apache.commons.lang3.StringUtils;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.io.File;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class TestActiviti {
    @Autowired
    private RuntimeService runtimeService;
    @Autowired
    private TaskService taskService;
    @Autowired
    private ProcessEngine processEngine;

    @Autowired
    private IDncPassLogService dncPassLogService;

    @Test
    public void fileClientTxtOrNc() {
        dncPassLogService.fileClientTxtOrNc();
    }


    /**
     * 流程定义的部署
     * activiti表有哪些？
     * act_re_deployment  部署信息
     * act_re_procdef     流程定义的一些信息
     * act_ge_bytearray   流程定义的bpmn文件及png文件
     */
    @Test
    public void testDeployment() {
        //ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        Deployment deployment = repositoryService.createDeployment().addClasspathResource("processes/assign_nc_to_device.bpmn")  //添加bpmn资源
                .name("指派NC文档到设备")
                .deploy();
        System.out.println(deployment.getName());
        System.out.println(deployment.getId());
    }

    /**
     * 启动流程实例:
     *     前提是先已经完成流程定义的部署工作
     *
     *  背后影响的表：
     *  ACT_HI_ACTINST     已完成的活动信息
     *  ACT_HI_DETAIL      历史详情
     *  ACT_HI_IDENTITYLINK   参与者信息
     *  ACT_HI_PROCINST   流程实例
     *  ACT_HI_TASKINST   任务实例
     *  ACT_HI_VARINST   历史变量
     *  ACT_RU_IDENTITYLINK  执行时 参与者信息
     *  ACT_RU_EXECUTION     执行表
     *  ACT_RU_TASK  当前任务
     *  ACT_RU_VARIABLE  执行时 参数信息
     */
    @Test
    public void testStartInstance() {
        //3.创建流程实例  流程定义的key需要知道 holiday
        String applyUser = "1255172650880737281";
        //String[] approveUsers = {"1254773336467689474", "1254966905669160962"};
        String approveUsers = "1254773336467689474, 1254966905669160962";
        String businessKey = "111111";
        String key = "assign_nc_to_device";
        Map<String, Object> map = new HashMap<>();

        map.put("apply_user", applyUser);
        map.put("approve_users", approveUsers);
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(key, businessKey, map);

        //4.输出实例的相关信息
        System.out.println("流程部署ID"+processInstance.getDeploymentId());//null
        System.out.println("流程定义ID"+processInstance.getProcessDefinitionId());//holiday:1:4
        System.out.println("流程实例ID"+processInstance.getId());//2501
        System.out.println("活动ID"+processInstance.getActivityId());//null
    }

    /**
     * 从ACT_RU_TASK表中获取当前用户的任务列表
     * 从ACT_RU_TASK表中获取taskId的任务
     */
    @Test
    public void testCompleteTask() {
        //获取用户的任务列表
        //List<Task> taskList = taskService.createTaskQuery().taskAssignee("1255172650880737281").list();
        Task task = taskService.createTaskQuery().taskId("7509").singleResult();
        if(task != null) {
            //4.任务列表的展示
            System.out.println("流程实例ID:"+task.getProcessInstanceId());
            System.out.println("任务ID:"+task.getId());  //5002
            System.out.println("任务负责人:"+task.getAssignee());
            System.out.println("任务名称:"+task.getName());
            taskService.complete(task.getId());
        }
    }

    @Test
    public void testCandidateUser() {
        String key = "assign_nc_to_device";
        String candidate_user = "1254773336467689474";
//        List<Task> taskList = taskService.createTaskQuery().processDefinitionKey(key).taskCandidateUser(candidate_user)//设置候选用户
//                .list();
//        taskList.forEach(System.out::println);
        Task task = taskService.createTaskQuery().processDefinitionKey(key)
                .taskCandidateUser(candidate_user).singleResult();
        if(task != null) {
            taskService.claim(task.getId(), candidate_user);
            System.out.println("拾取任务成功");
            taskService.complete(task.getId());
            System.out.println("完成任务成功");
        }
    }

    @Value("${securedoc.serverIp}")
    private String serverIp;
    @Value("${securedoc.serverPort}")
    private String serverPort;
    @Value("${securedoc.username}")
    private String usernameService;
    @Value("${securedoc.pwd}")
    private String pwdService;
    @Value("${securedoc.addressToken}")
    private String addressToken;
    @Value("${securedoc.addressUploadFile}")
    private String addressUploadFile;
    @Value("${securedoc.localFilePath}")
    private String localFilePathC;
    @Value("${securedoc.servicePath}")
    private String servicePathS;
    @Value("${securedoc.copyFilePath}")
    private String newFilePathC;
    @Value("${securedoc.logIp}")
    private String logIp;
    @Value("${securedoc.logPort}")
    private String logPort;

    @Test
    public void fileClientTest() {
        /*SysLogMessageDto message = new SysLogMessageDto();
        message.setSystemName("DNC");
        message.setDatetime(DateUtil.format(DateUtil.getNow(),DateUtil.STR_DATE_TIME_SMALL));
        message.setLocation("成发工业园");
        message.setTypes("info");
        message.setAbstract1("abstract");
        message.setSourceAddress("");
       */
        String host = "127.0.0.1";
        if (StringUtils.isNotBlank(serverIp)) {
            host = serverIp;
        }

        String port = "8299";
        if (StringUtils.isNotBlank(serverPort)) {
            port = serverPort;
        }
        String username = "admin";
        if (StringUtils.isNotBlank(usernameService)) {
            username = usernameService;
        }
        String pwd = "123";
        if (StringUtils.isNotBlank(pwdService)) {
            pwd = pwdService;
        }
        //文件本地地址，根据地址找到文件，将文件解析成文件流
        String localFilePath = "E:\\test\\a\\";
        if (StringUtils.isNotBlank(localFilePathC)) {
            localFilePath = localFilePathC;
        }
        //文件上传目的地址，将文件上传到该地址
        String servicePath = "E:\\test\\b\\";
        if (StringUtils.isNotBlank(servicePathS)) {
            servicePath = servicePathS;
        }
        //第一步，获取token
        String token = null;
        try {
            token = FileClient.getToken(host,port,username,pwd,addressToken);
        } catch (Throwable throwable) {
            throwable.printStackTrace();
        }

        //若获取token成功，再进行上传文件接口调用
        if (!token.equals("")){
            try {
                File f3 = new File(localFilePath);
                File[] files = f3.listFiles();
                for (File fi : files){
                    if (fi.isFile()){
                        SysLogTypeObjectDto objectName = new SysLogTypeObjectDto();
                        objectName.setDateTime(DateUtil.format(DateUtil.getNow(),DateUtil.STR_DATE_TIME_SMALL));
                        objectName.setFileName(fi.getName());
                        objectName.setFileSize(FileUtil.changeFileFormatKb(String.valueOf(new File(localFilePath).length())));
                        objectName.setSourceAddress(localFilePath);
                        //顺序号
                        DncPassLog passLog = dncPassLogService.getById("num0001");
                        if (passLog == null) {
                            passLog = new DncPassLog();
                            passLog.setId("num0001");
                            passLog.setSequenceNumber(1);
                            objectName.setFileNum(Integer.toString(1));;
                            dncPassLogService.save(passLog);
                        } else {
                            Integer number = passLog.getSequenceNumber()+1;
                            dncPassLogService.removeById("num0001");
                            objectName.setFileNum(Integer.toString(number));

                            passLog = new DncPassLog();
                            passLog.setId("num0001");
                            passLog.setSequenceNumber(number);
                            dncPassLogService.save(passLog);
                        }

                        InetAddress address = null;
                        try {
                            address = InetAddress.getLocalHost();
                            String ip = address.getHostAddress();
                            objectName.setSourceAddress(ip);
                        } catch (UnknownHostException e) {
                            objectName.setSourceAddress("127.0.0.1");
                        }
                        objectName.setDestination(host);
                        objectName.setResult("失败");
                        //获取某个文件下的所有文件
                        String loFilePath = localFilePath + "\\" + fi.getName();
                        String servicePathName =servicePath + "\\" + fi.getName();
                        String b  = FileClient.uploadFile(host,port,token,fi.getName(),servicePathName,loFilePath,addressUploadFile);
                        //文件备份删除
                        if (b == null) {
                            try {
                                objectName.setResult("失败");
                                SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
                            }catch (Exception e) {
                                return;
                            }
                        }
                        else if ( b.equals("成功")) {
                            //备份数据
                            boolean fCopy = FileUtil.copyNcFile(loFilePath,newFilePathC + "/" + DateUtil.format(DateUtil.getNow(),
                                    DateUtil.STR_YEARMONTHDAY) + "/" +fi.getName());
                            if (fCopy) {
                                FileUtil.deleteNcFile(loFilePath);
                            }
                            try {
                                objectName.setResult("成功");
                                SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
                            }catch (Exception e) {
                                return;
                            }
                        } else {
                            try {
                                objectName.setResult("失败");
                                SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
                            }catch (Exception e) {
                                return;
                            }
                        }
                    }
                }

            } catch (Throwable throwable) {
                throwable.printStackTrace();
            }
        }
    }


}