Update 刪除powerjob模块

SERVER/VberAdminPlusV3/vber-extend/pom.xml

@@ -10,7 +10,6 @@
     </parent>
     <packaging>pom</packaging>
     <modules>
-        <module>vber-powerjob-server</module>
         <module>vber-monitor-admin</module>
         <module>vber-job-admin</module>
     </modules>

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/Dockerfile

@@ -1,17 +0,0 @@
-#FROM findepi/graalvm:java17-native
-FROM openjdk:17.0.2-oraclelinux8
-
-MAINTAINER IwbY
-
-RUN mkdir -p /vber/powerjob/logs
-
-WORKDIR /vber/powerjob
-
-ENV LANG=C.UTF-8 LC_ALL=C.UTF-8 JAVA_OPTS="-Xms512m -Xmx1024m"
-
-EXPOSE 6076
-
-ADD ./target/vber-powerjob-server.jar ./app.jar
-
-ENTRYPOINT java -Djava.security.egd=file:/dev/./urandom -jar app.jar \
-           -XX:+HeapDumpOnOutOfMemoryError -Xlog:gc*,:time,tags,level -XX:+UseZGC ${JAVA_OPTS}

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/pom.xml

@@ -1,74 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xmlns="http://maven.apache.org/POM/4.0.0"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <packaging>jar</packaging>
-    <parent>
-        <groupId>com.vap</groupId>
-        <artifactId>vber-extend</artifactId>
-        <version>${revision}</version>
-    </parent>
-
-    <artifactId>vber-powerjob-server</artifactId>
-    <name>${project.artifactId}</name>
-    <description>任务调度 Server</description>
-
-    <properties>
-        <spring-boot.version>2.7.18</spring-boot.version>
-        <spring-boot-admin.version>2.7.11</spring-boot-admin.version>
-    </properties>
-
-    <dependencyManagement>
-        <dependencies>
-            <dependency>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-starter-parent</artifactId>
-                <version>${spring-boot.version}</version>
-                <type>pom</type>
-                <scope>import</scope>
-            </dependency>
-        </dependencies>
-    </dependencyManagement>
-
-    <dependencies>
-        <!-- PowerJob server-->
-        <dependency>
-            <groupId>tech.powerjob</groupId>
-            <artifactId>powerjob-server-starter</artifactId>
-            <version>${powerjob.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>de.codecentric</groupId>
-            <artifactId>spring-boot-admin-starter-client</artifactId>
-            <version>${spring-boot-admin.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-        </dependency>
-
-    </dependencies>
-
-    <build>
-        <finalName>${project.artifactId}</finalName>
-        <plugins>
-            <plugin>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-maven-plugin</artifactId>
-                <version>${spring-boot.version}</version>
-                <executions>
-                    <execution>
-                        <goals>
-                            <goal>repackage</goal>
-                        </goals>
-                    </execution>
-                </executions>
-            </plugin>
-        </plugins>
-    </build>
-
-
-</project>

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/src/main/java/com/vber/powerjob/PowerJobServerApplication.java

@@ -1,25 +0,0 @@
-package com.vber.powerjob;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.scheduling.annotation.EnableScheduling;
-import tech.powerjob.server.common.utils.PropertyUtils;
-
-/**
- * powerjob 启动程序
- *
- * @author yhan219
- */
-@Slf4j
-@EnableScheduling
-@SpringBootApplication(scanBasePackages = "tech.powerjob.server")
-public class PowerJobServerApplication {
-
-    public static void main(String[] args) {
-        PropertyUtils.init();
-        SpringApplication.run(tech.powerjob.server.PowerJobServerApplication.class, args);
-        log.info("文档地址: https://www.yuque.com/powerjob/guidence/problem");
-    }
-
-}

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/src/main/resources/application-dev.properties

@@ -1,42 +0,0 @@
-oms.env=dev
-####### Database properties(Configure according to the the environment) #######
-spring.datasource.core.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.core.jdbc-url=jdbc:mysql://192.168.0.104:3316/VberAdminPlusV3?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
-spring.datasource.core.username=root
-spring.datasource.core.password=123456
-spring.datasource.core.maximum-pool-size=20
-spring.datasource.core.minimum-idle=5
-# 监控配置
-# 客户端开关
-spring.boot.admin.client.enabled=true
-# 设置 Spring Boot Admin Server 地址
-spring.boot.admin.client.url:http://localhost:6075
-spring.boot.admin.client.instance.service-host-type=IP
-spring.boot.admin.client.username=vber
-spring.boot.admin.client.password=123456
-####### MongoDB properties(Non-core configuration properties)  #######
-####### delete mongodb config to disable mongodb #######
-oms.mongodb.enable=false
-#spring.data.mongodb.uri=mongodb+srv://zqq:No1Bug2Please3!@cluster0.wie54.gcp.mongodb.net/powerjob_daily?retryWrites=true&w=majority
-####### Email properties(Non-core configuration properties) #######
-####### Delete the following code to disable the mail #######
-#spring.mail.host=smtp.163.com
-#spring.mail.username=zqq@163.com
-#spring.mail.password=GOFZPNARMVKCGONV
-#spring.mail.properties.mail.smtp.auth=true
-#spring.mail.properties.mail.smtp.starttls.enable=true
-#spring.mail.properties.mail.smtp.starttls.required=true
-####### DingTalk properties(Non-core configuration properties) #######
-####### Delete the following code to disable the DingTalk #######
-#oms.alarm.ding.app-key=dingauqwkvxxnqskknfv
-#oms.alarm.ding.app-secret=XWrEPdAZMPgJeFtHuL0LH73LRj-74umF2_0BFcoXMfvnX0pCQvt0rpb1JOJU_HLl
-#oms.alarm.ding.agent-id=847044348
-####### Resource cleaning properties #######
-oms.instanceinfo.retention=1
-oms.container.retention.local=1
-oms.container.retention.remote=-1
-####### Cache properties #######
-oms.instance.metadata.cache.size=1024
-####### Threshold in precise fetching server(0~100). 100 means full detection of server, in which #######
-####### split-brain could be avoided while performance overhead would increase. #######
-oms.accurate.select.server.percentage=50

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/src/main/resources/application-prod.properties

@@ -1,42 +0,0 @@
-oms.env=prod
-####### Database properties(Configure according to the the environment) #######
-spring.datasource.core.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.core.jdbc-url=jdbc:mysql://192.168.0.104:3316/VberAdminPlusV3?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
-spring.datasource.core.username=root
-spring.datasource.core.password=123456
-spring.datasource.core.maximum-pool-size=20
-spring.datasource.core.minimum-idle=5
-# 监控配置
-# 客户端开关
-spring.boot.admin.client.enabled=true
-# 设置 Spring Boot Admin Server 地址
-spring.boot.admin.client.url:http://localhost:6075
-spring.boot.admin.client.instance.service-host-type=IP
-spring.boot.admin.client.username=vber
-spring.boot.admin.client.password=123456
-####### MongoDB properties(Non-core configuration properties)  #######
-####### delete mongodb config to disable mongodb #######
-oms.mongodb.enable=false
-#spring.data.mongodb.uri=mongodb+srv://zqq:No1Bug2Please3!@cluster0.wie54.gcp.mongodb.net/powerjob_daily?retryWrites=true&w=majority
-####### Email properties(Non-core configuration properties) #######
-####### Delete the following code to disable the mail #######
-#spring.mail.host=smtp.163.com
-#spring.mail.username=zqq@163.com
-#spring.mail.password=GOFZPNARMVKCGONV
-#spring.mail.properties.mail.smtp.auth=true
-#spring.mail.properties.mail.smtp.starttls.enable=true
-#spring.mail.properties.mail.smtp.starttls.required=true
-####### DingTalk properties(Non-core configuration properties) #######
-####### Delete the following code to disable the DingTalk #######
-#oms.alarm.ding.app-key=dingauqwkvxxnqskknfv
-#oms.alarm.ding.app-secret=XWrEPdAZMPgJeFtHuL0LH73LRj-74umF2_0BFcoXMfvnX0pCQvt0rpb1JOJU_HLl
-#oms.alarm.ding.agent-id=847044348
-####### Resource cleaning properties #######
-oms.instanceinfo.retention=7
-oms.container.retention.local=7
-oms.container.retention.remote=-1
-####### Cache properties #######
-oms.instance.metadata.cache.size=2048
-####### Threshold in precise fetching server(0~100). 100 means full detection of server, in which #######
-####### split-brain could be avoided while performance overhead would increase. #######
-oms.accurate.select.server.percentage=50

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/src/main/resources/application.properties

@@ -1,29 +0,0 @@
-# Http server port
-server.port=6076
-spring.profiles.active=@profiles.active@
-spring.main.banner-mode=log
-spring.jpa.open-in-view=false
-spring.data.mongodb.repositories.type=none
-logging.level.org.mongodb=warn
-logging.level.tech.powerjob.server=warn
-logging.level.MONITOR_LOGGER_DB_OPERATION=warn
-logging.level.MONITOR_LOGGER_WORKER_HEART_BEAT=warn
-logging.config:classpath:logback-plus.xml
-# Configuration for uploading files.
-spring.servlet.multipart.enabled=true
-spring.servlet.multipart.file-size-threshold=0
-spring.servlet.multipart.max-file-size=209715200
-spring.servlet.multipart.max-request-size=209715200
-###### PowerJob transporter configuration  ######
-oms.transporter.active.protocols=AKKA,HTTP
-oms.transporter.main.protocol=HTTP
-oms.akka.port=10086
-oms.http.port=10010
-# Prefix for all tables. Default empty string. Config if you have needs, i.e. pj_
-oms.table-prefix=pj_
-# Actuator 监控端点的配置项
-spring.application.name:vber-powerjob-server
-management.endpoints.web.exposure.include=*
-management.endpoint.health.show-details=ALWAYS
-management.endpoint.logfile.external-file=./logs/vber-powerjob-server.log
-management.health.mongo.enabled=${oms.mongodb.enable}

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/src/main/resources/banner.txt

@@ -1,11 +0,0 @@
-Application Version: ${revision}
-Spring Boot Version: ${spring-boot.version}
-                              _       _
-                             (_)     | |
- _ __   _____      _____ _ __ _  ___ | |__ ______ ___  ___ _ ____   _____ _ __
-| '_ \ / _ \ \ /\ / / _ \ '__| |/ _ \| '_ \______/ __|/ _ \ '__\ \ / / _ \ '__|
-| |_) | (_) \ V  V /  __/ |  | | (_) | |_) |     \__ \  __/ |   \ V /  __/ |
-| .__/ \___/ \_/\_/ \___|_|  | |\___/|_.__/      |___/\___|_|    \_/ \___|_|
-| |                         _/ |
-|_|                        |__/
-

SERVER/VberAdminPlusV3/vber-extend/vber-powerjob-server/src/main/resources/logback-plus.xml

@@ -1,34 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration debug="false" scan="true" scanPeriod="1 seconds">
-
-    <contextName>logback</contextName>
-    <property name="log.path" value="./logs/vber-powerjob-server"/>
-    <property name="console.log.pattern"
-              value="%red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta(%logger{36}%n) - %msg%n"/>
-    <property name="log.pattern" value="%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n"/>
-
-    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
-        <encoder>
-            <pattern>${console.log.pattern}</pattern>
-            <charset>utf-8</charset>
-        </encoder>
-    </appender>
-
-    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
-        <file>${log.path}.log</file>
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-            <fileNamePattern>${log.path}.%d{yyyy-MM-dd}.log</fileNamePattern>
-            <!-- 日志最大的历史 60天 -->
-            <maxHistory>60</maxHistory>
-        </rollingPolicy>
-        <encoder>
-            <pattern>${log.pattern}</pattern>
-        </encoder>
-    </appender>
-
-    <root level="info">
-        <appender-ref ref="console"/>
-        <appender-ref ref="file"/>
-    </root>
-
-</configuration>

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/package-info.java

@@ -1,6 +0,0 @@
-/**
- * 演示用例
- * copy from https://github.com/PowerJob/PowerJob/tree/master/powerjob-worker-samples/src/main/java/tech/powerjob/samples
- */
-
-package com.vber.job.powerjob;

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/BroadcastProcessorDemo.java

@@ -1,56 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-import tech.powerjob.common.utils.NetUtils;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.TaskResult;
-import tech.powerjob.worker.core.processor.sdk.BroadcastProcessor;
-import tech.powerjob.worker.log.OmsLogger;
-
-import java.util.List;
-
-/**
- * 广播处理器 示例
- *
- * @author tjq
- * @since 2020/4/17
- */
-@Slf4j
-@Component
-public class BroadcastProcessorDemo implements BroadcastProcessor {
-
-    @Override
-    public ProcessResult preProcess(TaskContext context) {
-        System.out.println("===== BroadcastProcessorDemo#preProcess ======");
-        context.getOmsLogger().info("BroadcastProcessorDemo#preProcess, current host: {}", NetUtils.getLocalHost());
-        if ("rootFailed".equals(context.getJobParams())) {
-            return new ProcessResult(false, "console need failed");
-        } else {
-            return new ProcessResult(true);
-        }
-    }
-
-    @Override
-    public ProcessResult process(TaskContext taskContext) throws Exception {
-        OmsLogger logger = taskContext.getOmsLogger();
-        System.out.println("===== BroadcastProcessorDemo#process ======");
-        logger.info("BroadcastProcessorDemo#process, current host: {}", NetUtils.getLocalHost());
-        long sleepTime = 1000;
-        try {
-            sleepTime = Long.parseLong(taskContext.getJobParams());
-        } catch (Exception e) {
-            logger.warn("[BroadcastProcessor] parse sleep time failed!", e);
-        }
-        Thread.sleep(Math.max(sleepTime, 1000));
-        return new ProcessResult(true);
-    }
-
-    @Override
-    public ProcessResult postProcess(TaskContext context, List<TaskResult> taskResults) {
-        System.out.println("===== BroadcastProcessorDemo#postProcess ======");
-        context.getOmsLogger().info("BroadcastProcessorDemo#postProcess, current host: {}, taskResult: {}", NetUtils.getLocalHost(), taskResults);
-        return new ProcessResult(true, "success");
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/LogTestProcessor.java

@@ -1,41 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import com.alibaba.fastjson.JSONObject;
-import org.springframework.stereotype.Component;
-import tech.powerjob.official.processors.util.CommonUtils;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
-import tech.powerjob.worker.log.OmsLogger;
-
-import java.util.Date;
-import java.util.Optional;
-
-/**
- * LogTestProcessor
- *
- * @author tjq
- * @since 2022/9/18
- */
-@Component
-public class LogTestProcessor implements BasicProcessor {
-
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-
-        final OmsLogger omsLogger = context.getOmsLogger();
-        final String parseParams = CommonUtils.parseParams(context);
-        final JSONObject config = Optional.ofNullable(JSONObject.parseObject(parseParams)).orElse(new JSONObject());
-
-        final long loopTimes = Optional.ofNullable(config.getLong("loopTimes")).orElse(1000L);
-
-        for (int i = 0; i < loopTimes; i++) {
-            omsLogger.debug("[DEBUG] one DEBUG log in {}", new Date());
-            omsLogger.info("[INFO] one INFO log in {}", new Date());
-            omsLogger.warn("[WARN] one WARN log in {}", new Date());
-            omsLogger.error("[ERROR] one ERROR log in {}", new Date());
-        }
-
-        return new ProcessResult(true);
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/MapProcessorDemo.java

@@ -1,93 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import com.google.common.collect.Lists;
-import com.vber.common.json.utils.JsonUtils;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import org.springframework.stereotype.Component;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.sdk.MapProcessor;
-
-import java.util.List;
-import java.util.concurrent.ThreadLocalRandom;
-
-/**
- * Map处理器 示例
- *
- * @author tjq
- * @since 2020/4/18
- */
-@Component
-public class MapProcessorDemo implements MapProcessor {
-
-
-    /**
-     * 每一批发送任务大小
-     */
-    private static final int BATCH_SIZE = 100;
-    /**
-     * 发送的批次
-     */
-    private static final int BATCH_NUM = 5;
-
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-
-        log.info("============== MapProcessorDemo#process ==============");
-        log.info("isRootTask:{}", isRootTask());
-        log.info("taskContext:{}", JsonUtils.toJsonString(context));
-
-        if (isRootTask()) {
-            log.info("==== MAP ====");
-            List<SubTask> subTasks = Lists.newLinkedList();
-            for (int j = 0; j < BATCH_NUM; j++) {
-                SubTask subTask = new SubTask();
-                subTask.siteId = j;
-                subTask.itemIds = Lists.newLinkedList();
-                subTasks.add(subTask);
-                for (int i = 0; i < BATCH_SIZE; i++) {
-                    subTask.itemIds.add(i + j * 100);
-                }
-            }
-            map(subTasks, "MAP_TEST_TASK");
-            return new ProcessResult(true, "map successfully");
-        } else {
-
-            log.info("==== PROCESS ====");
-            SubTask subTask = (SubTask) context.getSubTask();
-            for (Integer itemId : subTask.getItemIds()) {
-                if (Thread.interrupted()) {
-                    // 任务被中断
-                    log.info("job has been stop! so stop to process subTask: {} => {}", subTask.getSiteId(), itemId);
-                    break;
-                }
-                log.info("processing subTask: {} => {}", subTask.getSiteId(), itemId);
-                int max = Integer.MAX_VALUE >> 7;
-                for (int i = 0; ; i++) {
-                    // 模拟耗时操作
-                    if (i > max) {
-                        break;
-                    }
-                }
-            }
-            // 测试在 Map 任务中追加上下文
-            context.getWorkflowContext().appendData2WfContext("Yasuo", "A sword's poor company for a long road.");
-            boolean b = ThreadLocalRandom.current().nextBoolean();
-            if (context.getCurrentRetryTimes() >= 1) {
-                // 重试的话一定会成功
-                b = true;
-            }
-            return new ProcessResult(b, "RESULT:" + b);
-        }
-    }
-
-    @Getter
-    @NoArgsConstructor
-    @AllArgsConstructor
-    public static class SubTask {
-        private Integer siteId;
-        private List<Integer> itemIds;
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/MapReduceProcessorDemo.java

@@ -1,93 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import cn.hutool.core.lang.Dict;
-import com.google.common.collect.Lists;
-import com.vber.common.json.utils.JsonUtils;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import lombok.ToString;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.TaskResult;
-import tech.powerjob.worker.core.processor.sdk.MapReduceProcessor;
-import tech.powerjob.worker.log.OmsLogger;
-
-import java.util.List;
-import java.util.concurrent.ThreadLocalRandom;
-
-/**
- * MapReduce 处理器示例
- * 控制台参数：{"batchSize": 100, "batchNum": 2}
- *
- * @author tjq
- * @since 2020/4/17
- */
-@Slf4j
-@Component
-public class MapReduceProcessorDemo implements MapReduceProcessor {
-
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-
-        OmsLogger omsLogger = context.getOmsLogger();
-
-        log.info("============== TestMapReduceProcessor#process ==============");
-        log.info("isRootTask:{}", isRootTask());
-        log.info("taskContext:{}", JsonUtils.toJsonString(context));
-
-        // 根据控制台参数获取MR批次及子任务大小
-        final Dict jobParams = JsonUtils.parseMap(context.getJobParams());
-
-        Integer batchSize = (Integer) jobParams.getOrDefault("batchSize", 100);
-        Integer batchNum = (Integer) jobParams.getOrDefault("batchNum", 10);
-
-        if (isRootTask()) {
-            log.info("==== MAP ====");
-            omsLogger.info("[DemoMRProcessor] start root task~");
-            List<TestSubTask> subTasks = Lists.newLinkedList();
-            for (int j = 0; j < batchNum; j++) {
-                for (int i = 0; i < batchSize; i++) {
-                    int x = j * batchSize + i;
-                    subTasks.add(new TestSubTask("name" + x, x));
-                }
-                map(subTasks, "MAP_TEST_TASK");
-                subTasks.clear();
-            }
-            omsLogger.info("[DemoMRProcessor] map success~");
-            return new ProcessResult(true, "MAP_SUCCESS");
-        } else {
-            log.info("==== NORMAL_PROCESS ====");
-            omsLogger.info("[DemoMRProcessor] process subTask: {}.", JsonUtils.toJsonString(context.getSubTask()));
-            log.info("subTask: {}", JsonUtils.toJsonString(context.getSubTask()));
-            Thread.sleep(1000);
-            if (context.getCurrentRetryTimes() == 0) {
-                return new ProcessResult(false, "FIRST_FAILED");
-            } else {
-                return new ProcessResult(true, "PROCESS_SUCCESS");
-            }
-        }
-    }
-
-    @Override
-    public ProcessResult reduce(TaskContext context, List<TaskResult> taskResults) {
-        log.info("================ MapReduceProcessorDemo#reduce ================");
-        log.info("TaskContext: {}", JsonUtils.toJsonString(context));
-        log.info("List<TaskResult>: {}", JsonUtils.toJsonString(taskResults));
-        context.getOmsLogger().info("MapReduce job finished, result is {}.", taskResults);
-
-        boolean success = ThreadLocalRandom.current().nextBoolean();
-        return new ProcessResult(success, context + ": " + success);
-    }
-
-    @Getter
-    @ToString
-    @NoArgsConstructor
-    @AllArgsConstructor
-    public static class TestSubTask {
-        private String name;
-        private int age;
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/SimpleProcessor.java

@@ -1,35 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import org.springframework.stereotype.Component;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
-import tech.powerjob.worker.log.OmsLogger;
-
-import java.util.Optional;
-
-/**
- * @author Echo009
- * @since 2022/4/27
- */
-@Component
-public class SimpleProcessor implements BasicProcessor {
-
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-
-        OmsLogger logger = context.getOmsLogger();
-
-        String jobParams = Optional.ofNullable(context.getJobParams()).orElse("S");
-        logger.info("Current context:{}", context.getWorkflowContext());
-        logger.info("Current job params:{}", jobParams);
-
-        // 测试中文问题 #581
-        if (jobParams.contains("CN")) {
-            return new ProcessResult(true, "任务成功啦！！！");
-        }
-
-        return jobParams.contains("F") ? new ProcessResult(false) : new ProcessResult(true, "yeah!");
-
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/StandaloneProcessorDemo.java

@@ -1,51 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.stereotype.Component;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
-import tech.powerjob.worker.log.OmsLogger;
-
-import java.util.Collections;
-
-/**
- * 单机处理器 示例
- *
- * @author tjq
- * @since 2020/4/17
- */
-@Slf4j
-@Component
-public class StandaloneProcessorDemo implements BasicProcessor {
-
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-        OmsLogger omsLogger = context.getOmsLogger();
-        omsLogger.info("StandaloneProcessorDemo start process,context is {}.", context);
-        omsLogger.info("Notice! If you want this job process failed, your jobParams need to be 'failed'");
-        omsLogger.info("Let's test the exception~");
-        // 测试异常日志
-        try {
-            Collections.emptyList().add("277");
-        } catch (Exception e) {
-            omsLogger.error("oh~it seems that we have an exception~", e);
-        }
-        log.info("================ StandaloneProcessorDemo#process ================");
-        log.info("jobParam:{}", context.getJobParams());
-        log.info("instanceParams:{}", context.getInstanceParams());
-        String param;
-        // 解析参数，非处于工作流中时，优先取实例参数（允许动态[instanceParams]覆盖静态参数[jobParams]）
-        if (context.getWorkflowContext() == null) {
-            param = StringUtils.isBlank(context.getInstanceParams()) ? context.getJobParams() : context.getInstanceParams();
-        } else {
-            param = context.getJobParams();
-        }
-        // 根据参数判断是否成功
-        boolean success = !"failed".equals(param);
-        omsLogger.info("StandaloneProcessorDemo finished process,success: {}", success);
-        omsLogger.info("anyway, we finished the job successfully~Congratulations!");
-        return new ProcessResult(success, context + ": " + success);
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/processors/TimeoutProcessor.java

@@ -1,25 +0,0 @@
-package com.vber.job.powerjob.processors;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
-
-/**
- * 测试超时任务（可中断）
- *
- * @author tjq
- * @since 2020/4/20
- */
-@Component
-@Slf4j
-public class TimeoutProcessor implements BasicProcessor {
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-        long sleepTime = Long.parseLong(context.getJobParams());
-        log.info("TaskInstance({}) will sleep {} ms", context.getInstanceId(), sleepTime);
-        Thread.sleep(Long.parseLong(context.getJobParams()));
-        return new ProcessResult(true, "impossible~~~~QAQ~");
-    }
-}

SERVER/VberAdminPlusV3/vber-modules/vber-job/src/main/java/com/vber/job/powerjob/workflow/WorkflowStandaloneProcessor.java

@@ -1,36 +0,0 @@
-package com.vber.job.powerjob.workflow;
-
-import com.alibaba.fastjson.JSON;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-import tech.powerjob.worker.core.processor.ProcessResult;
-import tech.powerjob.worker.core.processor.TaskContext;
-import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
-import tech.powerjob.worker.log.OmsLogger;
-
-import java.util.Map;
-
-/**
- * 工作流测试
- *
- * @author tjq
- * @since 2020/6/2
- */
-@Component
-@Slf4j
-public class WorkflowStandaloneProcessor implements BasicProcessor {
-
-    @Override
-    public ProcessResult process(TaskContext context) throws Exception {
-        OmsLogger logger = context.getOmsLogger();
-        logger.info("current jobParams: {}", context.getJobParams());
-        logger.info("current context: {}", context.getWorkflowContext());
-        log.info("jobParams:{}", context.getJobParams());
-        log.info("currentContext:{}", JSON.toJSONString(context));
-
-        // 尝试获取上游任务
-        Map<String, String> workflowContext = context.getWorkflowContext().fetchWorkflowContext();
-        log.info("工作流上下文数据:{}", workflowContext);
-        return new ProcessResult(true, context.getJobId() + " process successfully.");
-    }
-}