增加java_task对照类

byit-myth-core/myth-dto-core/src/main/java/com/byit/dto/plugin/JavaTask.java

+package com.byit.dto.plugin;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * java执行节点
+ * @author huangfu
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class JavaTask {
+    /**
+     * 主键
+     */
+    private Integer id;
+    /**
+     * 任务名称
+     */
+    private String jobName;
+    /**
+     * 调度名称
+     */
+    private String taskName;
+
+    /**
+     * 调度次数  默认周期性调度
+     */
+    private String schedulingCount;
+    /**
+     * 调度参数
+     */
+    private String param;
+    /**
+     * 本次的执行时间
+     */
+    private Long triggerTime;
+    /**
+     * cron表达式
+     */
+    private String cron;
+    /**
+     * 剩余执行词素
+     */
+    private Integer remainingCount;
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+    /**
+     * 告警时机
+     */
+    private String alarmlAction;
+    /**
+     * 邮件接收人
+     */
+    private String sendEmail;
+}

byit-plugin-core/byit-plugin-rpc-common/src/main/java/com/byit/task/annotations/TaskHandler.java

@@ -17,14 +17,39 @@ public @interface TaskHandler {
     String cron() default "";
 
     /**
-     * 任务名称
+     * 调度名称 这个名称是任务体的key 需要保持唯一性
      * @return 任务名称
      */
     String taskName();
 
     /**
+     * 这个是任务名称 调度中心的唯一key值 需要保证唯一性  默认与 taskName 保持一致
+     * 任务名称
+     */
+    String jobName() default "";
+
+
+    /**
      * 是否自动发布
      * @return 是否自动发布
      */
     boolean autoPublish() default false;
+
+    /**
+     * 自动发布的地址
+     * @return
+     */
+    String publishUrl() default "";
+
+    /**
+     * 调度次数  默认为-1 周期不间断调度
+     * @return
+     */
+    int schedulingCount() default -1;
+    /**
+     * 当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)
+     */
+    String alarmlAction() default "1";
+
+    String sendEmail() default "";
 }

byit-plugin-core/myth-plugin-rpc-server/src/main/java/com/byit/callback/DefaultRemainingOperationsCallBack.java

 package com.byit.callback;
 
+import com.byit.task.annotations.TaskHandler;
+import com.byit.task.handler.interfaces.IJobHandler;
+
 import java.util.Map;
 
 /**
@@ -9,6 +12,19 @@ import java.util.Map;
 public class DefaultRemainingOperationsCallBack implements RemainingOperationsCallBack {
     @Override
     public void serverRemainingOperations(Map<String, Object> map) {
-        System.out.println(map);
+        //注册方法数据
+        new Thread(() ->{
+            map.forEach((key,value) ->{
+                Class<?> nodeClass = value.getClass();
+                if (nodeClass.isAnnotationPresent(TaskHandler.class)) {
+                    TaskHandler annotation = nodeClass.getAnnotation(TaskHandler.class);
+                    //如果是自动注册 就实现自动注册
+                    if (annotation.autoPublish()) {
+
+                    }
                 }
+            });
+        });
+    }
+
 }

byit-plugin-core/myth-plugin-rpc-server/src/main/java/com/byit/factory/PluginServerFactory.java

@@ -153,7 +153,7 @@ public abstract class PluginServerFactory {
             pluginServiceRegistry.stop();
             pluginServiceRegistry = null;
         });
-        //调用剩余方法的回调
+        //调用自定义实现
         remainingOperationsCallBackObj.serverRemainingOperations(serverPoll);
         //启动服务器
         pluginServer.start(this);