优化修改功能

java110-utils/src/main/java/com/java110/utils/constant/ServiceCodeTaskConstant.java

@@ -36,4 +36,15 @@ public class ServiceCodeTaskConstant {
      */
     public static final String LIST_TASK_TEMPLATE_SPEC = "task.listTaskTemplateSpec";
 
+
+    /**
+     * 启动定时任务
+     */
+    public static final String START_TASK = "task.startTask";
+
+    /**
+     * 停止定时任务
+     */
+    public static final String STOP_TASK = "task.stopTask";
+
 }

service-api/src/main/java/com/java110/api/bmo/task/impl/TaskBMOImpl.java

@@ -67,14 +67,13 @@ public class TaskBMOImpl extends ApiBaseBMO implements ITaskBMO {
      */
     public void updateTask(JSONObject paramInJson, DataFlowContext dataFlowContext) {
 
-        TaskDto taskDto = new TaskDto();
-        taskDto.setTaskId(paramInJson.getString("taskId"));
-        //taskDto.setJobId(paramInJson.getString("jobId"));
-        List<TaskDto> taskDtos = taskInnerServiceSMOImpl.queryTasks(taskDto);
-
-        Assert.listOnlyOne(taskDtos, "未找到需要修改的活动 或多条数据");
-
-        paramInJson.putAll(BeanConvertUtil.beanCovertMap(taskDtos.get(0)));
+//        TaskDto taskDto = new TaskDto();
+//        taskDto.setTaskId(paramInJson.getString("taskId"));
+//        //taskDto.setJobId(paramInJson.getString("jobId"));
+//        List<TaskDto> taskDtos = taskInnerServiceSMOImpl.queryTasks(taskDto);
+//
+//        Assert.listOnlyOne(taskDtos, "未找到需要修改的活动 或多条数据");
+//        paramInJson.putAll(BeanConvertUtil.beanCovertMap(taskDtos.get(0)));
         TaskPo taskPo = BeanConvertUtil.covertBean(paramInJson, TaskPo.class);
         super.update(dataFlowContext, taskPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK);
 

service-api/src/main/java/com/java110/api/listener/task/StartTaskListener.java

@@ -0,0 +1,73 @@
+package com.java110.api.listener.task;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.listener.AbstractServiceApiPlusListener;
+import com.java110.core.annotation.Java110Listener;
+import com.java110.core.context.DataFlowContext;
+import com.java110.core.event.service.api.ServiceDataFlowEvent;
+import com.java110.core.smo.task.ITaskInnerServiceSMO;
+import com.java110.dto.task.TaskDto;
+import com.java110.result.ResultVo;
+import com.java110.utils.constant.ServiceCodeTaskConstant;
+import com.java110.utils.util.Assert;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+import java.util.List;
+
+/**
+ * 保存商户侦听
+ * add by wuxw 2019-06-30
+ */
+@Java110Listener("startTaskListener")
+public class StartTaskListener extends AbstractServiceApiPlusListener {
+
+    @Autowired
+    private ITaskInnerServiceSMO taskInnerServiceSMOImpl;
+
+    @Override
+    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
+        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
+
+        Assert.hasKeyAndValue(reqJson, "taskId", "请求报文中未包含taskName");
+
+    }
+
+    @Override
+    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+        TaskDto taskDto = new TaskDto();
+        taskDto.setTaskId(reqJson.getString("taskId"));
+        List<TaskDto> taskDtos = taskInnerServiceSMOImpl.queryTasks(taskDto);
+        ResultVo resultVo = null;
+        if (taskDtos == null || taskDtos.size() < 1) {
+            resultVo = new ResultVo(ResultVo.ORDER_ERROR, "传入任务ID错误");
+            ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+            context.setResponseEntity(responseEntity);
+            return;
+        }
+        int state = taskInnerServiceSMOImpl.startTask(taskDtos.get(0));
+
+        if(state >0){
+            resultVo = new ResultVo(ResultVo.CODE_OK, "启动成功");
+        }else{
+            resultVo = new ResultVo(ResultVo.ORDER_ERROR, "启动失败");
+        }
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+        context.setResponseEntity(responseEntity);
+        return;
+    }
+
+    @Override
+    public String getServiceCode() {
+        return ServiceCodeTaskConstant.START_TASK;
+    }
+
+    @Override
+    public HttpMethod getHttpMethod() {
+        return HttpMethod.POST;
+    }
+
+}

service-job/src/main/java/com/java110/job/task/TranslateOwnerPhotoToMachine.java

@@ -2,6 +2,7 @@ package com.java110.job.task;
 
 import com.java110.dto.task.TaskDto;
 import com.java110.job.quartz.TaskSystemQuartz;
+import org.springframework.stereotype.Component;
 
 /**
  * @ClassName TransalateOwnerPhotoToMachine
@@ -11,6 +12,7 @@ import com.java110.job.quartz.TaskSystemQuartz;
  * @Version 1.0
  * add by wuxw 2020/6/3
  **/
+@Component
 public class TranslateOwnerPhotoToMachine extends TaskSystemQuartz {
     @Override
     protected void process(TaskDto taskDto) throws Exception {