From 383e093c828b8238cad3b5d7fa8b63ed402801a6 Mon Sep 17 00:00:00 2001 From: chenlinghy Date: Tue, 14 Apr 2020 17:04:16 +0800 Subject: [PATCH] =?UTF-8?q?OCT=20REM:=201.=20=E6=B7=BB=E5=8A=A0=E5=81=9C?= =?UTF-8?q?=E6=AD=A2=E6=8C=87=E5=AE=9A=E5=A4=84=E7=BD=AE=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=202.=20=E6=B7=BB=E5=8A=A0=E5=81=9C=E6=AD=A2?= =?UTF-8?q?=E6=9F=90=E5=A4=84=E7=BD=AEIP=E7=9A=84=E5=A4=84=E7=BD=AE?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=8E=A5=E5=8F=A3=203.=20=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E5=81=9C=E6=AD=A2=E6=8C=87=E5=AE=9A=E8=83=BD=E5=8A=9B=E8=8A=82?= =?UTF-8?q?=E7=82=B9=E5=85=A8=E9=83=A8=E5=A4=84=E7=BD=AE=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=204.=20=E6=B7=BB=E5=8A=A0=E5=81=9C=E6=AD=A2?= =?UTF-8?q?=E5=85=A8=E9=83=A8=E5=A4=84=E7=BD=AE=E4=BB=BB=E5=8A=A1=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cmcc/hy/phoenix/common/ConstValue.java | 2 +- .../hy/phoenix/controller/taskController.java | 335 ++++++++++++++++-- .../hy/phoenix/dispose/DisposeProcess.java | 5 + .../cmcc/hy/phoenix/dispose/DptechUMC.java | 6 + .../hy/phoenix/pojo/vo/StopTaskAllReq.java | 10 + .../hy/phoenix/pojo/vo/StopTaskByIpReq.java | 12 + .../phoenix/pojo/vo/StopTaskByIpReqMsg.java | 15 + .../phoenix/pojo/vo/StopTaskByPonitReq.java | 12 + .../pojo/vo/StopTaskByPonitReqMsg.java | 12 + .../cmcc/hy/phoenix/pojo/vo/StopTaskReq.java | 11 + .../hy/phoenix/pojo/vo/StopTaskResult.java | 15 + .../cmcc/hy/phoenix/pojo/vo/StopTaskRsp.java | 16 + 12 files changed, 424 insertions(+), 27 deletions(-) create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskAllReq.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReq.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReqMsg.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReq.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReqMsg.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskReq.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskResult.java create mode 100644 src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskRsp.java diff --git a/src/main/java/com/cmcc/hy/phoenix/common/ConstValue.java b/src/main/java/com/cmcc/hy/phoenix/common/ConstValue.java index fefa3c4d..3820d953 100644 --- a/src/main/java/com/cmcc/hy/phoenix/common/ConstValue.java +++ b/src/main/java/com/cmcc/hy/phoenix/common/ConstValue.java @@ -40,7 +40,7 @@ public class ConstValue { public static final int START_DISPOSE_CMD = 400; - public static final int STOP_DISPOSE_CMD = 401; + public static final int STOP_DISPOSE_CMD_BY_TASKID = 401; public static final int STOP_DISPOSE_CMD_BY_IP = 402; public static final int STOP_DISPOSE_CMD_BY_POINT = 403; public static final int STOP_DISPOSE_CMD_ALL = 404; diff --git a/src/main/java/com/cmcc/hy/phoenix/controller/taskController.java b/src/main/java/com/cmcc/hy/phoenix/controller/taskController.java index 2415c2ec..17c6d42a 100644 --- a/src/main/java/com/cmcc/hy/phoenix/controller/taskController.java +++ b/src/main/java/com/cmcc/hy/phoenix/controller/taskController.java @@ -3,9 +3,12 @@ package com.cmcc.hy.phoenix.controller; import com.cmcc.hy.phoenix.annotation.bodyencdec.ReqDec; import com.cmcc.hy.phoenix.common.ConstValue; import com.cmcc.hy.phoenix.common.ErrorCode; +import com.cmcc.hy.phoenix.dispose.DisposeProcess; +import com.cmcc.hy.phoenix.dispose.DptechUMC; import com.cmcc.hy.phoenix.pojo.dto.ProtocolDTO; -import com.cmcc.hy.phoenix.pojo.vo.ProtocolResp; +import com.cmcc.hy.phoenix.pojo.vo.*; import com.cmcc.hy.phoenix.service.LoginService; +import com.dptech.umc.NtcRequestResultInfo; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import io.swagger.annotations.Api; @@ -19,11 +22,12 @@ import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; -import java.security.NoSuchAlgorithmException; +import java.util.ArrayList; +import java.util.EnumMap; +import java.util.List; import java.util.Objects; import static com.cmcc.hy.phoenix.common.ErrorCode.ERR_OK; -import static com.cmcc.hy.phoenix.common.ErrorCode.ERR_UNKNOWNCMD; @Controller @RequestMapping(value = "/handle") @@ -44,7 +48,7 @@ public class taskController { @ReqDec @Builder public ProtocolResp disposeTaskCommand(@RequestBody(required = true) ProtocolDTO mr, - @RequestHeader HttpHeaders headers) { + @RequestHeader HttpHeaders headers) throws JsonProcessingException { // 存放返回信息Json字符串 String msgCtx = ""; ErrorCode err = ERR_OK; @@ -59,33 +63,312 @@ public class taskController { } else if (mr.IsRequestTimeout()) { err = ErrorCode.ERR_REQTIMEOUT; } else { - //try{ - // 获取 Token - String token = Objects. - requireNonNull(headers.get("Authorization")) - .get(0).replaceFirst("Bearer ", ""); + try { + // 获取 Token + String token = Objects. + requireNonNull(headers.get("Authorization")) + .get(0).replaceFirst("Bearer ", ""); - // 判断Head头是否存在 - if (headers.get("Authorization") == null) { - err = ErrorCode.ERR_MISSAUTHHEAD; - } else if ((err = loginService.authTokenCheck(token)) == ERR_OK) { - // Token 正确则处理业务 - switch (mr.getCmdId()) { - case ConstValue.ProtocolCmdId.START_DISPOSE_CMD: - break; - case ConstValue.ProtocolCmdId.STOP_DISPOSE_CMD: - break; - - default: - err = ErrorCode.ERR_UNKNOWNCMD; + // 判断Head头是否存在 + if (headers.get("Authorization") == null) { + err = ErrorCode.ERR_MISSAUTHHEAD; + } else if ((err = loginService.authTokenCheck(token)) == ERR_OK) { + // Token 正确则处理业务 + switch (mr.getCmdId()) { + case ConstValue.ProtocolCmdId.START_DISPOSE_CMD: + break; + //停止清洗任务 + case ConstValue.ProtocolCmdId.STOP_DISPOSE_CMD_BY_TASKID: + EnumMap stopMap = StopTaskByTaskId(mr); + err = stopMap.keySet().iterator().next(); + msgCtx = stopMap.get(err); + break; + case ConstValue.ProtocolCmdId.STOP_DISPOSE_CMD_BY_IP: + EnumMap stopMapByIp = StopTaskByIp(mr); + err = stopMapByIp.keySet().iterator().next(); + msgCtx = stopMapByIp.get(err); + break; + case ConstValue.ProtocolCmdId.STOP_DISPOSE_CMD_BY_POINT: + EnumMap stopMapByPoint = StopTaskByPoint(mr); + err = stopMapByPoint.keySet().iterator().next(); + msgCtx = stopMapByPoint.get(err); + break; + case ConstValue.ProtocolCmdId.STOP_DISPOSE_CMD_ALL: + EnumMap stopMapByAll = StopTaskAll(mr); + err = stopMapByAll.keySet().iterator().next(); + msgCtx = stopMapByAll.get(err); + break; + default: + err = ErrorCode.ERR_UNKNOWNCMD; + } } + } catch (JsonProcessingException ex) { + log.error(ex.getMessage()); + err = ErrorCode.ERR_EXCEPTION; } -// } catch (JsonProcessingException | NoSuchAlgorithmException ex) { -// log.error(ex.getMessage()); -// err = ErrorCode.ERR_EXCEPTION; -// } } return ProtocolResp.result(err, mr.getCmdId(), msgCtx); } + + private EnumMap StopTaskByTaskId(ProtocolDTO mr) throws JsonProcessingException { + String ipAddr = "10.88.77.15"; + EnumMap retMap = new EnumMap<>(ErrorCode.class); + ErrorCode err = ErrorCode.ERR_OK; + + List results = new ArrayList<>(); + StopTaskRsp repInfo = StopTaskRsp.builder().result(results).build(); + + StopTaskReq reqInfo = objectMapper.readValue(mr.getMsgContent(), StopTaskReq.class); + //遍历处置任务唯一编号taskId + if (reqInfo.getTaskId().size() == 0) { + System.out.println("无指定TaskId的清洗任务"); + err = ErrorCode.ERR_INPUTMISS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + + for (String v : reqInfo.getTaskId()) { + System.out.println(v); + //每个taskId对应保护IP disposeIp,通过taskId获取disposeIp + String disposeIp = "192.168.5.2"; + int attackType = 1; + int direction = 0; + + DisposeProcess dp = new DptechUMC(ipAddr); + NtcRequestResultInfo ntc_result = dp.stopAbnormalTask(disposeIp, attackType, direction); + + StopTaskResult sig_results = new StopTaskResult(); + sig_results.setTaskId(v); + sig_results.setType(0); //目前只有清洗设备 + sig_results.setDisposeIp(disposeIp); + if (ntc_result.getResultRetVal().equals(0)) { + sig_results.setStatus(ntc_result.getResultRetVal()); + } + + //把每一次遍历的结果都存入results + results.add(sig_results); + repInfo.setResult(results); + } + + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + + private EnumMap StopTaskByIp(ProtocolDTO mr) throws JsonProcessingException { + String ipAddr = "10.88.77.15"; + EnumMap retMap = new EnumMap<>(ErrorCode.class); + ErrorCode err = ErrorCode.ERR_OK; + + List results = new ArrayList<>(); + StopTaskRsp repInfo = StopTaskRsp.builder().result(results).build(); + + StopTaskByIpReq reqInfo = objectMapper.readValue(mr.getMsgContent(), StopTaskByIpReq.class); + if (reqInfo.getItems().size() == 0) { + System.out.println("无该处置IP的清洗任务"); + err = ErrorCode.ERR_INPUTMISS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } else { + for (StopTaskByIpReqMsg v : reqInfo.getItems() + ) { + if ((v.getType() < -1) || (v.getType() > 3)) { + System.out.println("任务类型输入错误"); + err = ErrorCode.ERR_PARAMS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } else if ((v.getId().length() == 0) || (String.valueOf(v.getType()).length() == 0) || (v.getDisposeIP().length() == 0)) { + System.out.println("缺少必要输入信息"); + err = ErrorCode.ERR_INPUTMISS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + } + } + + + for (StopTaskByIpReqMsg v : reqInfo.getItems() + ) { + //输出指定IP + System.out.println(v.getDisposeIP()); + int attackType = 1; + int direction = 0; + + DisposeProcess dp = new DptechUMC(ipAddr); + NtcRequestResultInfo ntc_result = dp.stopAbnormalTask(v.getDisposeIP(), attackType, direction); + + StopTaskResult result = new StopTaskResult(); + result.setId(v.getId()); + result.setType(v.getType()); + result.setDisposeIp(v.getDisposeIP()); + if (ntc_result.getResultRetVal().equals(0)) { + result.setStatus(ntc_result.getResultRetVal()); + } + + //数据库中对应设备Id（deviceId）找到taskId,测试情况假设deviceId与找到taskId相同 + String taskId = v.getId(); + result.setTaskId(taskId); + + //把每一次遍历的结果都存入results + results.add(result); + repInfo.setResult(results); + } + + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + + private EnumMap StopTaskByPoint(ProtocolDTO mr) throws JsonProcessingException { + String ipAddr = "10.88.77.15"; + EnumMap retMap = new EnumMap<>(ErrorCode.class); + ErrorCode err = ErrorCode.ERR_OK; + + List results = new ArrayList<>(); + StopTaskRsp repInfo = StopTaskRsp.builder().result(results).build(); + + StopTaskByPonitReq reqInfo = objectMapper.readValue(mr.getMsgContent(), StopTaskByPonitReq.class); + + if (reqInfo.getItems().size() == 0) { + System.out.println("无该指定能力节点的清洗任务"); + err = ErrorCode.ERR_INPUTMISS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } else { + for (StopTaskByPonitReqMsg v : reqInfo.getItems() + ) { + if ((v.getType() < -1) || (v.getType() > 3)) { + System.out.println("任务类型输入错误"); + err = ErrorCode.ERR_PARAMS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } else if ((v.getId().length() == 0) || (String.valueOf(v.getType()).length() == 0)) { + System.out.println("缺少必要输入信息"); + err = ErrorCode.ERR_INPUTMISS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + } + } + + for (StopTaskByPonitReqMsg v : reqInfo.getItems() + ) { + //通过能力节点唯一标识符id找到对应的清洗IP，清洗IP以列表形式保存，一能力节点会对应多个IP + //foreach嵌套-List getDisposeIP + List getDisposeIps = new ArrayList<>(); + getDisposeIps.add("192.168.1.1"); + getDisposeIps.add("192.168.2.1"); + int attackType = 1; + int direction = 0; + int taskid = 0; + + DisposeProcess dp = new DptechUMC(ipAddr); + for (String getDisposeIp : getDisposeIps + ) { + NtcRequestResultInfo ntc_result = dp.stopAbnormalTask(getDisposeIp, attackType, direction); + StopTaskResult result = new StopTaskResult(); + result.setId(v.getId()); + result.setType(v.getType()); + result.setDisposeIp(getDisposeIp); + if (ntc_result.getResultRetVal().equals(0)) { + result.setStatus(ntc_result.getResultRetVal()); + } + + //数据库中对应设备Id（deviceId）找到taskId + //test taskId自增1 + String taskId = String.valueOf(taskid); + result.setTaskId(taskId); + + //把每一次遍历的结果都存入results + results.add(result); + repInfo.setResult(results); + taskid++; + } + } + + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + + private EnumMap StopTaskAll(ProtocolDTO mr) throws JsonProcessingException { + String ipAddr = "10.88.77.15"; + EnumMap retMap = new EnumMap<>(ErrorCode.class); + ErrorCode err = ErrorCode.ERR_OK; + + List results = new ArrayList<>(); + StopTaskRsp repInfo = StopTaskRsp.builder().result(results).build(); + + StopTaskAllReq reqInfo = objectMapper.readValue(mr.getMsgContent(), StopTaskAllReq.class); + + if (String.valueOf(reqInfo.getType()).length() == 0) { + System.out.println("缺少必要输入参数"); + err = ErrorCode.ERR_INPUTMISS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } else if ((reqInfo.getType() < -1) || (reqInfo.getType() > 3)) { + System.out.println("任务类型输入错误"); + err = ErrorCode.ERR_PARAMS; + repInfo = null; + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } + + int type = reqInfo.getType(); + if (type == 0) { + //任务类型为清洗，清洗所有清洗任务 + //MySql获取所有taskId,遍历执行清洗任务,测试添加多个taskId + List taskIds = new ArrayList<>(); + taskIds.add("1"); + taskIds.add("2"); + taskIds.add("3"); + taskIds.add("4"); + + String disposeIp = ""; + for (String v : taskIds + ) { + //每个taskId对应disposeIp,通过taskId获取disposeIp + //test 不同的taskId对应不同disposeIp + if (v.equals("1")) { + disposeIp = "192.168.10.1"; + } else if (v.equals("2")) { + disposeIp = "192.168.10.2"; + } else if (v.equals("3")) { + disposeIp = "192.168.10.3"; + } else { + disposeIp = "192.168.10.4"; + } + + int attackType = 1; + int direction = 0; + + DisposeProcess dp = new DptechUMC(ipAddr); + NtcRequestResultInfo ntc_result = dp.stopAbnormalTask(disposeIp, attackType, direction); + + StopTaskResult result = new StopTaskResult(); + result.setTaskId(v); + result.setType(0); //目前只有清洗设备 + result.setDisposeIp(disposeIp); + if (ntc_result.getResultRetVal().equals(0)) { + result.setStatus(ntc_result.getResultRetVal()); + } + + //数据库中对应设备taskId（deviceId）找到Id,测试情况假设deviceId与找到taskId相同 + result.setId(v); + + //把每一次遍历的结果都存入results + results.add(result); + repInfo.setResult(results); + } + } + + retMap.put(err, objectMapper.writeValueAsString(repInfo)); + return retMap; + } } diff --git a/src/main/java/com/cmcc/hy/phoenix/dispose/DisposeProcess.java b/src/main/java/com/cmcc/hy/phoenix/dispose/DisposeProcess.java index 7ecb43fd..339f2436 100644 --- a/src/main/java/com/cmcc/hy/phoenix/dispose/DisposeProcess.java +++ b/src/main/java/com/cmcc/hy/phoenix/dispose/DisposeProcess.java @@ -1,5 +1,7 @@ package com.cmcc.hy.phoenix.dispose; +import com.dptech.umc.NtcRequestResultInfo; + public interface DisposeProcess { public int runDispose(String ip); @@ -10,4 +12,7 @@ public interface DisposeProcess { public String getDetectionDevices(); public String getProtectDevices(); + + public NtcRequestResultInfo stopAbnormalTask(String abnormalIp, int attackType, int direction); + } diff --git a/src/main/java/com/cmcc/hy/phoenix/dispose/DptechUMC.java b/src/main/java/com/cmcc/hy/phoenix/dispose/DptechUMC.java index 4cadcefc..193528b0 100644 --- a/src/main/java/com/cmcc/hy/phoenix/dispose/DptechUMC.java +++ b/src/main/java/com/cmcc/hy/phoenix/dispose/DptechUMC.java @@ -4,6 +4,7 @@ import com.cmcc.hy.phoenix.Interceptor.SoapPasswordCallbackHandler; import com.cmcc.hy.phoenix.common.ConstValue; import com.dptech.umc.AbnormalFlowCleaningServicePortType; import com.dptech.umc.ArrayOfDetectionObjectDataForService; +import com.dptech.umc.NtcRequestResultInfo; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.cxf.jaxws.JaxWsProxyFactoryBean; @@ -67,4 +68,9 @@ public class DptechUMC implements DisposeProcess { this.cleanTypePort = (AbnormalFlowCleaningServicePortType)jaxWsProxyFactoryBean.create(); } + + @Override + public NtcRequestResultInfo stopAbnormalTask(String abnormalIp, int attackType, int direction){ + return cleanTypePort.stopAbnormalTaskForUMC(abnormalIp, attackType, direction); + } } diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskAllReq.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskAllReq.java new file mode 100644 index 00000000..4b7369cb --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskAllReq.java @@ -0,0 +1,10 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter +public class StopTaskAllReq { + int type; +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReq.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReq.java new file mode 100644 index 00000000..811e9d12 --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReq.java @@ -0,0 +1,12 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; + +import java.util.List; + +@Getter +@Setter +public class StopTaskByIpReq { + public List items; +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReqMsg.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReqMsg.java new file mode 100644 index 00000000..ac55aba8 --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByIpReqMsg.java @@ -0,0 +1,15 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter +public class StopTaskByIpReqMsg { + private String id; + //任务类型 0：清洗 1：高防 2：黑洞 3：检测 -1: 所有类型 + private int type; + //处置IP + private String disposeIP; + +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReq.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReq.java new file mode 100644 index 00000000..7bfe6b5d --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReq.java @@ -0,0 +1,12 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; + +import java.util.List; + +@Getter +@Setter +public class StopTaskByPonitReq { + public List items; +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReqMsg.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReqMsg.java new file mode 100644 index 00000000..9aac64b6 --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskByPonitReqMsg.java @@ -0,0 +1,12 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter +public class StopTaskByPonitReqMsg { + private String id; + //任务类型 0：清洗 1：高防 2：黑洞 3：检测 -1: 所有类型 + private int type; +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskReq.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskReq.java new file mode 100644 index 00000000..f98a27de --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskReq.java @@ -0,0 +1,11 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; +import java.util.List; + +@Getter +@Setter +public class StopTaskReq { + public List taskId; +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskResult.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskResult.java new file mode 100644 index 00000000..6052ed9d --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskResult.java @@ -0,0 +1,15 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter +public class StopTaskResult { + private String id; + private String taskId; + private int type; + private String disposeIp; + private int leftTime; + private int status; +} diff --git a/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskRsp.java b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskRsp.java new file mode 100644 index 00000000..a9e49b42 --- /dev/null +++ b/src/main/java/com/cmcc/hy/phoenix/pojo/vo/StopTaskRsp.java @@ -0,0 +1,16 @@ +package com.cmcc.hy.phoenix.pojo.vo; + +import lombok.Builder; +import lombok.Getter; +import lombok.Setter; +import lombok.ToString; + +import java.util.List; + +@Getter +@Setter +@ToString +@Builder +public class StopTaskRsp { + public List result; +}