Skip to content

D
data-server
Commit 084bc38f authored by licc's avatar licc
Browse files
Options

删除无用代码2

parent ce8a423b
Pipeline #365 canceled with stages
      Expand all Hide whitespace changes
      Inline Side-by-side
      Showing with 0 additions and 44138 deletions
      xxl-job/.gitignore deleted 100644 → 0
      View file @ ce8a423b
      HELP.md
      target/
      !.mvn/wrapper/maven-wrapper.jar
      !**/src/main/**
      !**/src/test/**
      ### STS ###
      .apt_generated
      .classpath
      .factorypath
      .project
      .settings
      .springBeans
      .sts4-cache
      ### IntelliJ IDEA ###
      .idea
      *.iws
      *.iml
      *.ipr
      ### NetBeans ###
      /nbproject/private/
      /nbbuild/
      /dist/
      /nbdist/
      /.nb-gradle/
      build/
      ### VS Code ###
      .vscode/
      \ No newline at end of file
      xxl-job/db/tables_xxl_job.sql deleted 100644 → 0
      View file @ ce8a423b
      #
      # XXL-JOB v2.3.0
      # Copyright (c) 2015-present, xuxueli.
      CREATE database if NOT EXISTS `xxl_job` default character set utf8mb4 collate utf8mb4_unicode_ci;
      use `xxl_job`;
      SET NAMES utf8mb4;
      CREATE TABLE `xxl_job_info` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `job_group` int(11) NOT NULL COMMENT '执行器主键ID',
      `job_desc` varchar(255) NOT NULL,
      `add_time` datetime DEFAULT NULL,
      `update_time` datetime DEFAULT NULL,
      `author` varchar(64) DEFAULT NULL COMMENT '作者',
      `alarm_email` varchar(255) DEFAULT NULL COMMENT '报警邮件',
      `schedule_type` varchar(50) NOT NULL DEFAULT 'NONE' COMMENT '调度类型',
      `schedule_conf` varchar(128) DEFAULT NULL COMMENT '调度配置，值含义取决于调度类型',
      `misfire_strategy` varchar(50) NOT NULL DEFAULT 'DO_NOTHING' COMMENT '调度过期策略',
      `executor_route_strategy` varchar(50) DEFAULT NULL COMMENT '执行器路由策略',
      `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
      `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
      `executor_block_strategy` varchar(50) DEFAULT NULL COMMENT '阻塞处理策略',
      `executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间，单位秒',
      `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
      `glue_type` varchar(50) NOT NULL COMMENT 'GLUE类型',
      `glue_source` mediumtext COMMENT 'GLUE源代码',
      `glue_remark` varchar(128) DEFAULT NULL COMMENT 'GLUE备注',
      `glue_updatetime` datetime DEFAULT NULL COMMENT 'GLUE更新时间',
      `child_jobid` varchar(255) DEFAULT NULL COMMENT '子任务ID，多个逗号分隔',
      `trigger_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '调度状态：0-停止，1-运行',
      `trigger_last_time` bigint(13) NOT NULL DEFAULT '0' COMMENT '上次调度时间',
      `trigger_next_time` bigint(13) NOT NULL DEFAULT '0' COMMENT '下次调度时间',
      PRIMARY KEY (`id`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_log` (
      `id` bigint(20) NOT NULL AUTO_INCREMENT,
      `job_group` int(11) NOT NULL COMMENT '执行器主键ID',
      `job_id` int(11) NOT NULL COMMENT '任务，主键ID',
      `executor_address` varchar(255) DEFAULT NULL COMMENT '执行器地址，本次执行的地址',
      `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
      `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
      `executor_sharding_param` varchar(20) DEFAULT NULL COMMENT '执行器任务分片参数，格式如 1/2',
      `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
      `trigger_time` datetime DEFAULT NULL COMMENT '调度-时间',
      `trigger_code` int(11) NOT NULL COMMENT '调度-结果',
      `trigger_msg` text COMMENT '调度-日志',
      `handle_time` datetime DEFAULT NULL COMMENT '执行-时间',
      `handle_code` int(11) NOT NULL COMMENT '执行-状态',
      `handle_msg` text COMMENT '执行-日志',
      `alarm_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '告警状态：0-默认、1-无需告警、2-告警成功、3-告警失败',
      PRIMARY KEY (`id`),
      KEY `I_trigger_time` (`trigger_time`),
      KEY `I_handle_code` (`handle_code`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_log_report` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `trigger_day` datetime DEFAULT NULL COMMENT '调度-时间',
      `running_count` int(11) NOT NULL DEFAULT '0' COMMENT '运行中-日志数量',
      `suc_count` int(11) NOT NULL DEFAULT '0' COMMENT '执行成功-日志数量',
      `fail_count` int(11) NOT NULL DEFAULT '0' COMMENT '执行失败-日志数量',
      `update_time` datetime DEFAULT NULL,
      PRIMARY KEY (`id`),
      UNIQUE KEY `i_trigger_day` (`trigger_day`) USING BTREE
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_logglue` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `job_id` int(11) NOT NULL COMMENT '任务，主键ID',
      `glue_type` varchar(50) DEFAULT NULL COMMENT 'GLUE类型',
      `glue_source` mediumtext COMMENT 'GLUE源代码',
      `glue_remark` varchar(128) NOT NULL COMMENT 'GLUE备注',
      `add_time` datetime DEFAULT NULL,
      `update_time` datetime DEFAULT NULL,
      PRIMARY KEY (`id`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_registry` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `registry_group` varchar(50) NOT NULL,
      `registry_key` varchar(255) NOT NULL,
      `registry_value` varchar(255) NOT NULL,
      `update_time` datetime DEFAULT NULL,
      PRIMARY KEY (`id`),
      KEY `i_g_k_v` (`registry_group`,`registry_key`,`registry_value`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_group` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `app_name` varchar(64) NOT NULL COMMENT '执行器AppName',
      `title` varchar(12) NOT NULL COMMENT '执行器名称',
      `address_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '执行器地址类型：0=自动注册、1=手动录入',
      `address_list` text COMMENT '执行器地址列表，多地址逗号分隔',
      `update_time` datetime DEFAULT NULL,
      PRIMARY KEY (`id`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_user` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `username` varchar(50) NOT NULL COMMENT '账号',
      `password` varchar(50) NOT NULL COMMENT '密码',
      `role` tinyint(4) NOT NULL COMMENT '角色：0-普通用户、1-管理员',
      `permission` varchar(255) DEFAULT NULL COMMENT '权限：执行器ID列表，多个逗号分割',
      PRIMARY KEY (`id`),
      UNIQUE KEY `i_username` (`username`) USING BTREE
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      CREATE TABLE `xxl_job_lock` (
      `lock_name` varchar(50) NOT NULL COMMENT '锁名称',
      PRIMARY KEY (`lock_name`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      INSERT INTO `xxl_job_group`(`id`, `app_name`, `title`, `address_type`, `address_list`, `update_time`) VALUES (1, 'xxl-job-executor-sample', '示例执行器', 0, NULL, '2018-11-03 22:21:31' );
      INSERT INTO `xxl_job_info`(`id`, `job_group`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `schedule_type`, `schedule_conf`, `misfire_strategy`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) VALUES (1, 1, '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'XXL', '', 'CRON', '0 0 0 * * ? *', 'DO_NOTHING', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2018-11-03 22:21:31', '');
      INSERT INTO `xxl_job_user`(`id`, `username`, `password`, `role`, `permission`) VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL);
      INSERT INTO `xxl_job_lock` ( `lock_name`) VALUES ( 'schedule_lock');
      commit;
      xxl-job/pom.xml deleted 100644 → 0
      View file @ ce8a423b
      <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      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>
      <groupId>com.xuxueli</groupId>
      <artifactId>xxl-job</artifactId>
      <version>2.3.0</version>
      <packaging>pom</packaging>
      <name>${project.artifactId}</name>
      <description>A distributed task scheduling framework.</description>
      <modules>
      <module>xxl-job-core</module>
      <module>xxl-job-admin</module>
      </modules>
      <properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
      <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
      <maven.compiler.source>1.8</maven.compiler.source>
      <maven.compiler.target>1.8</maven.compiler.target>
      <maven.test.skip>true</maven.test.skip>
      <netty-all.version>4.1.60.Final</netty-all.version>
      <gson.version>2.8.6</gson.version>
      <spring.version>5.3.5</spring.version>
      <spring-boot.version>2.4.4</spring-boot.version>
      <mybatis-spring-boot-starter.version>2.1.4</mybatis-spring-boot-starter.version>
      <mysql-connector-java.version>8.0.23</mysql-connector-java.version>
      <slf4j-api.version>1.7.30</slf4j-api.version>
      <junit.version>5.7.1</junit.version>
      <javax.annotation-api.version>1.3.2</javax.annotation-api.version>
      <groovy.version>3.0.7</groovy.version>
      </properties>
      </project>
      \ No newline at end of file
      xxl-job/xxl-job-admin/Dockerfile deleted 100644 → 0
      View file @ ce8a423b
      FROM openjdk:8-jre-slim
      MAINTAINER xuxueli
      ENV PARAMS=""
      ENV TZ=PRC
      RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
      ADD target/xxl-job-admin-*.jar /app.jar
      ENTRYPOINT ["sh","-c","java -jar $JAVA_OPTS /app.jar $PARAMS"]
      \ No newline at end of file
      xxl-job/xxl-job-admin/pom.xml deleted 100644 → 0
      View file @ ce8a423b
      <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      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>
      <parent>
      <groupId>com.xuxueli</groupId>
      <artifactId>xxl-job</artifactId>
      <version>2.3.0</version>
      </parent>
      <artifactId>xxl-job-admin</artifactId>
      <packaging>jar</packaging>
      <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>
      <!-- starter-web：spring-webmvc + autoconfigure + logback + yaml + tomcat -->
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
      </dependency>
      <!-- starter-test：junit + spring-test + mockito -->
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
      </dependency>
      <!-- freemarker-starter -->
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-freemarker</artifactId>
      </dependency>
      <!-- mail-starter -->
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-mail</artifactId>
      </dependency>
      <!-- starter-actuator -->
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
      </dependency>
      <!-- mybatis-starter：mybatis + mybatis-spring + hikari（default） -->
      <dependency>
      <groupId>org.mybatis.spring.boot</groupId>
      <artifactId>mybatis-spring-boot-starter</artifactId>
      <version>${mybatis-spring-boot-starter.version}</version>
      </dependency>
      <!-- mysql -->
      <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>${mysql-connector-java.version}</version>
      </dependency>
      <!-- xxl-job-core -->
      <dependency>
      <groupId>com.xuxueli</groupId>
      <artifactId>xxl-job-core</artifactId>
      <version>${project.parent.version}</version>
      </dependency>
      </dependencies>
      <build>
      <finalName>xxl-job-2.3.0</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>
      <!-- docker -->
      <plugin>
      <groupId>com.spotify</groupId>
      <artifactId>docker-maven-plugin</artifactId>
      <version>0.4.13</version>
      <configuration>
      <!-- made of '[a-z0-9-_.]' -->
      <imageName>${project.artifactId}:${project.version}</imageName>
      <dockerDirectory>${project.basedir}</dockerDirectory>
      <resources>
      <resource>
      <targetPath>/</targetPath>
      <directory>${project.build.directory}</directory>
      <include>${project.build.finalName}.jar</include>
      </resource>
      </resources>
      </configuration>
      </plugin>
      </plugins>
      </build>
      </project>
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/XxlJobAdminApplication.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin;
      import org.springframework.boot.SpringApplication;
      import org.springframework.boot.autoconfigure.SpringBootApplication;
      /**
      * @author xuxueli 2018-10-28 00:38:13
      */
      @SpringBootApplication
      public class XxlJobAdminApplication {
      public static void main(String[] args) {
      SpringApplication.run(XxlJobAdminApplication.class, args);
      }
      }
      \ No newline at end of file
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/IndexController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.controller.annotation.PermissionLimit;
      import com.xxl.job.admin.service.LoginService;
      import com.xxl.job.admin.service.XxlJobService;
      import com.xxl.job.core.biz.model.ReturnT;
      import org.springframework.beans.propertyeditors.CustomDateEditor;
      import org.springframework.stereotype.Controller;
      import org.springframework.ui.Model;
      import org.springframework.web.bind.WebDataBinder;
      import org.springframework.web.bind.annotation.InitBinder;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.RequestMethod;
      import org.springframework.web.bind.annotation.ResponseBody;
      import org.springframework.web.servlet.ModelAndView;
      import org.springframework.web.servlet.view.RedirectView;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import javax.servlet.http.HttpServletResponse;
      import java.text.SimpleDateFormat;
      import java.util.Date;
      import java.util.Map;
      /**
      * index controller
      * @author xuxueli 2015-12-19 16:13:16
      */
      @Controller
      public class IndexController {
      @Resource
      private XxlJobService xxlJobService;
      @Resource
      private LoginService loginService;
      @RequestMapping("/")
      public String index(Model model) {
      Map<String, Object> dashboardMap = xxlJobService.dashboardInfo();
      model.addAllAttributes(dashboardMap);
      return "index";
      }
      @RequestMapping("/chartInfo")
      @ResponseBody
      public ReturnT<Map<String, Object>> chartInfo(Date startDate, Date endDate) {
      ReturnT<Map<String, Object>> chartInfo = xxlJobService.chartInfo(startDate, endDate);
      return chartInfo;
      }
      @RequestMapping("/toLogin")
      @PermissionLimit(limit=false)
      public ModelAndView toLogin(HttpServletRequest request, HttpServletResponse response,ModelAndView modelAndView) {
      if (loginService.ifLogin(request, response) != null) {
      modelAndView.setView(new RedirectView("/",true,false));
      return modelAndView;
      }
      return new ModelAndView("login");
      }
      @RequestMapping(value="login", method=RequestMethod.POST)
      @ResponseBody
      @PermissionLimit(limit=false)
      public ReturnT<String> loginDo(HttpServletRequest request, HttpServletResponse response, String userName, String password, String ifRemember){
      boolean ifRem = (ifRemember!=null && ifRemember.trim().length()>0 && "on".equals(ifRemember))?true:false;
      return loginService.login(request, response, userName, password, ifRem);
      }
      @RequestMapping(value="logout", method=RequestMethod.POST)
      @ResponseBody
      @PermissionLimit(limit=false)
      public ReturnT<String> logout(HttpServletRequest request, HttpServletResponse response){
      return loginService.logout(request, response);
      }
      @RequestMapping("/help")
      public String help() {
      /*if (!PermissionInterceptor.ifLogin(request)) {
      return "redirect:/toLogin";
      }*/
      return "help";
      }
      @InitBinder
      public void initBinder(WebDataBinder binder) {
      SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      dateFormat.setLenient(false);
      binder.registerCustomEditor(Date.class, new CustomDateEditor(dateFormat, true));
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobApiController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.controller.annotation.PermissionLimit;
      import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
      import com.xxl.job.core.biz.AdminBiz;
      import com.xxl.job.core.biz.model.HandleCallbackParam;
      import com.xxl.job.core.biz.model.RegistryParam;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.core.util.GsonTool;
      import com.xxl.job.core.util.XxlJobRemotingUtil;
      import org.springframework.stereotype.Controller;
      import org.springframework.web.bind.annotation.PathVariable;
      import org.springframework.web.bind.annotation.RequestBody;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.ResponseBody;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import java.util.List;
      /**
      * Created by xuxueli on 17/5/10.
      */
      @Controller
      @RequestMapping("/api")
      public class JobApiController {
      @Resource
      private AdminBiz adminBiz;
      /**
      * api
      *
      * @param uri
      * @param data
      * @return
      */
      @RequestMapping("/{uri}")
      @ResponseBody
      @PermissionLimit(limit=false)
      public ReturnT<String> api(HttpServletRequest request, @PathVariable("uri") String uri, @RequestBody(required = false) String data) {
      // valid
      if (!"POST".equalsIgnoreCase(request.getMethod())) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, HttpMethod not support.");
      }
      if (uri==null || uri.trim().length()==0) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping empty.");
      }
      if (XxlJobAdminConfig.getAdminConfig().getAccessToken()!=null
      && XxlJobAdminConfig.getAdminConfig().getAccessToken().trim().length()>0
      && !XxlJobAdminConfig.getAdminConfig().getAccessToken().equals(request.getHeader(XxlJobRemotingUtil.XXL_JOB_ACCESS_TOKEN))) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, "The access token is wrong.");
      }
      // services mapping
      if ("callback".equals(uri)) {
      List<HandleCallbackParam> callbackParamList = GsonTool.fromJson(data, List.class, HandleCallbackParam.class);
      return adminBiz.callback(callbackParamList);
      } else if ("registry".equals(uri)) {
      RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
      return adminBiz.registry(registryParam);
      } else if ("registryRemove".equals(uri)) {
      RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
      return adminBiz.registryRemove(registryParam);
      } else {
      return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping("+ uri +") not found.");
      }
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobCodeController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobLogGlue;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.admin.dao.XxlJobInfoDao;
      import com.xxl.job.admin.dao.XxlJobLogGlueDao;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.core.glue.GlueTypeEnum;
      import org.springframework.stereotype.Controller;
      import org.springframework.ui.Model;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.ResponseBody;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import java.util.Date;
      import java.util.List;
      /**
      * job code controller
      * @author xuxueli 2015-12-19 16:13:16
      */
      @Controller
      @RequestMapping("/jobcode")
      public class JobCodeController {
      @Resource
      private XxlJobInfoDao xxlJobInfoDao;
      @Resource
      private XxlJobLogGlueDao xxlJobLogGlueDao;
      @RequestMapping
      public String index(HttpServletRequest request, Model model, int jobId) {
      XxlJobInfo jobInfo = xxlJobInfoDao.loadById(jobId);
      List<XxlJobLogGlue> jobLogGlues = xxlJobLogGlueDao.findByJobId(jobId);
      if (jobInfo == null) {
      throw new RuntimeException(I18nUtil.getString("jobinfo_glue_jobid_unvalid"));
      }
      if (GlueTypeEnum.BEAN == GlueTypeEnum.match(jobInfo.getGlueType())) {
      throw new RuntimeException(I18nUtil.getString("jobinfo_glue_gluetype_unvalid"));
      }
      // valid permission
      JobInfoController.validPermission(request, jobInfo.getJobGroup());
      // Glue类型-字典
      model.addAttribute("GlueTypeEnum", GlueTypeEnum.values());
      model.addAttribute("jobInfo", jobInfo);
      model.addAttribute("jobLogGlues", jobLogGlues);
      return "jobcode/jobcode.index";
      }
      @RequestMapping("/save")
      @ResponseBody
      public ReturnT<String> save(Model model, int id, String glueSource, String glueRemark) {
      // valid
      if (glueRemark==null) {
      return new ReturnT<String>(500, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_glue_remark")) );
      }
      if (glueRemark.length()<4 || glueRemark.length()>100) {
      return new ReturnT<String>(500, I18nUtil.getString("jobinfo_glue_remark_limit"));
      }
      XxlJobInfo exists_jobInfo = xxlJobInfoDao.loadById(id);
      if (exists_jobInfo == null) {
      return new ReturnT<String>(500, I18nUtil.getString("jobinfo_glue_jobid_unvalid"));
      }
      // update new code
      exists_jobInfo.setGlueSource(glueSource);
      exists_jobInfo.setGlueRemark(glueRemark);
      exists_jobInfo.setGlueUpdatetime(new Date());
      exists_jobInfo.setUpdateTime(new Date());
      xxlJobInfoDao.update(exists_jobInfo);
      // log old code
      XxlJobLogGlue xxlJobLogGlue = new XxlJobLogGlue();
      xxlJobLogGlue.setJobId(exists_jobInfo.getId());
      xxlJobLogGlue.setGlueType(exists_jobInfo.getGlueType());
      xxlJobLogGlue.setGlueSource(glueSource);
      xxlJobLogGlue.setGlueRemark(glueRemark);
      xxlJobLogGlue.setAddTime(new Date());
      xxlJobLogGlue.setUpdateTime(new Date());
      xxlJobLogGlueDao.save(xxlJobLogGlue);
      // remove code backup more than 30
      xxlJobLogGlueDao.removeOld(exists_jobInfo.getId(), 30);
      return ReturnT.SUCCESS;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobGroupController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.core.model.XxlJobGroup;
      import com.xxl.job.admin.core.model.XxlJobRegistry;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.admin.dao.XxlJobGroupDao;
      import com.xxl.job.admin.dao.XxlJobInfoDao;
      import com.xxl.job.admin.dao.XxlJobRegistryDao;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.core.enums.RegistryConfig;
      import org.springframework.stereotype.Controller;
      import org.springframework.ui.Model;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.RequestParam;
      import org.springframework.web.bind.annotation.ResponseBody;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import java.util.*;
      /**
      * job group controller
      * @author xuxueli 2016-10-02 20:52:56
      */
      @Controller
      @RequestMapping("/jobgroup")
      public class JobGroupController {
      @Resource
      public XxlJobInfoDao xxlJobInfoDao;
      @Resource
      public XxlJobGroupDao xxlJobGroupDao;
      @Resource
      private XxlJobRegistryDao xxlJobRegistryDao;
      @RequestMapping
      public String index(Model model) {
      return "jobgroup/jobgroup.index";
      }
      @RequestMapping("/pageList")
      @ResponseBody
      public Map<String, Object> pageList(HttpServletRequest request,
      @RequestParam(required = false, defaultValue = "0") int start,
      @RequestParam(required = false, defaultValue = "10") int length,
      String appname, String title) {
      // page query
      List<XxlJobGroup> list = xxlJobGroupDao.pageList(start, length, appname, title);
      int list_count = xxlJobGroupDao.pageListCount(start, length, appname, title);
      // package result
      Map<String, Object> maps = new HashMap<String, Object>();
      maps.put("recordsTotal", list_count); // 总记录数
      maps.put("recordsFiltered", list_count); // 过滤后的总记录数
      maps.put("data", list); // 分页列表
      return maps;
      }
      @RequestMapping("/save")
      @ResponseBody
      public ReturnT<String> save(XxlJobGroup xxlJobGroup){
      // valid
      if (xxlJobGroup.getAppname()==null || xxlJobGroup.getAppname().trim().length()==0) {
      return new ReturnT<String>(500, (I18nUtil.getString("system_please_input")+"AppName") );
      }
      if (xxlJobGroup.getAppname().length()<4 || xxlJobGroup.getAppname().length()>64) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_appname_length") );
      }
      if (xxlJobGroup.getAppname().contains(">") || xxlJobGroup.getAppname().contains("<")) {
      return new ReturnT<String>(500, "AppName"+I18nUtil.getString("system_unvalid") );
      }
      if (xxlJobGroup.getTitle()==null || xxlJobGroup.getTitle().trim().length()==0) {
      return new ReturnT<String>(500, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobgroup_field_title")) );
      }
      if (xxlJobGroup.getTitle().contains(">") || xxlJobGroup.getTitle().contains("<")) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_title")+I18nUtil.getString("system_unvalid") );
      }
      if (xxlJobGroup.getAddressType()!=0) {
      if (xxlJobGroup.getAddressList()==null || xxlJobGroup.getAddressList().trim().length()==0) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_addressType_limit") );
      }
      if (xxlJobGroup.getAddressList().contains(">") || xxlJobGroup.getAddressList().contains("<")) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_registryList")+I18nUtil.getString("system_unvalid") );
      }
      String[] addresss = xxlJobGroup.getAddressList().split(",");
      for (String item: addresss) {
      if (item==null || item.trim().length()==0) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_registryList_unvalid") );
      }
      }
      }
      // process
      xxlJobGroup.setUpdateTime(new Date());
      int ret = xxlJobGroupDao.save(xxlJobGroup);
      return (ret>0)?ReturnT.SUCCESS:ReturnT.FAIL;
      }
      @RequestMapping("/update")
      @ResponseBody
      public ReturnT<String> update(XxlJobGroup xxlJobGroup){
      // valid
      if (xxlJobGroup.getAppname()==null || xxlJobGroup.getAppname().trim().length()==0) {
      return new ReturnT<String>(500, (I18nUtil.getString("system_please_input")+"AppName") );
      }
      if (xxlJobGroup.getAppname().length()<4 || xxlJobGroup.getAppname().length()>64) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_appname_length") );
      }
      if (xxlJobGroup.getTitle()==null || xxlJobGroup.getTitle().trim().length()==0) {
      return new ReturnT<String>(500, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobgroup_field_title")) );
      }
      if (xxlJobGroup.getAddressType() == 0) {
      // 0=自动注册
      List<String> registryList = findRegistryByAppName(xxlJobGroup.getAppname());
      String addressListStr = null;
      if (registryList!=null && !registryList.isEmpty()) {
      Collections.sort(registryList);
      addressListStr = "";
      for (String item:registryList) {
      addressListStr += item + ",";
      }
      addressListStr = addressListStr.substring(0, addressListStr.length()-1);
      }
      xxlJobGroup.setAddressList(addressListStr);
      } else {
      // 1=手动录入
      if (xxlJobGroup.getAddressList()==null || xxlJobGroup.getAddressList().trim().length()==0) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_addressType_limit") );
      }
      String[] addresss = xxlJobGroup.getAddressList().split(",");
      for (String item: addresss) {
      if (item==null || item.trim().length()==0) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_field_registryList_unvalid") );
      }
      }
      }
      // process
      xxlJobGroup.setUpdateTime(new Date());
      int ret = xxlJobGroupDao.update(xxlJobGroup);
      return (ret>0)?ReturnT.SUCCESS:ReturnT.FAIL;
      }
      private List<String> findRegistryByAppName(String appnameParam){
      HashMap<String, List<String>> appAddressMap = new HashMap<String, List<String>>();
      List<XxlJobRegistry> list = xxlJobRegistryDao.findAll(RegistryConfig.DEAD_TIMEOUT, new Date());
      if (list != null) {
      for (XxlJobRegistry item: list) {
      if (RegistryConfig.RegistType.EXECUTOR.name().equals(item.getRegistryGroup())) {
      String appname = item.getRegistryKey();
      List<String> registryList = appAddressMap.get(appname);
      if (registryList == null) {
      registryList = new ArrayList<String>();
      }
      if (!registryList.contains(item.getRegistryValue())) {
      registryList.add(item.getRegistryValue());
      }
      appAddressMap.put(appname, registryList);
      }
      }
      }
      return appAddressMap.get(appnameParam);
      }
      @RequestMapping("/remove")
      @ResponseBody
      public ReturnT<String> remove(int id){
      // valid
      int count = xxlJobInfoDao.pageListCount(0, 10, id, -1, null, null, null);
      if (count > 0) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_del_limit_0") );
      }
      List<XxlJobGroup> allList = xxlJobGroupDao.findAll();
      if (allList.size() == 1) {
      return new ReturnT<String>(500, I18nUtil.getString("jobgroup_del_limit_1") );
      }
      int ret = xxlJobGroupDao.remove(id);
      return (ret>0)?ReturnT.SUCCESS:ReturnT.FAIL;
      }
      @RequestMapping("/loadById")
      @ResponseBody
      public ReturnT<XxlJobGroup> loadById(int id){
      XxlJobGroup jobGroup = xxlJobGroupDao.load(id);
      return jobGroup!=null?new ReturnT<XxlJobGroup>(jobGroup):new ReturnT<XxlJobGroup>(ReturnT.FAIL_CODE, null);
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobInfoController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.core.cron.CronExpression;
      import com.xxl.job.admin.core.exception.XxlJobException;
      import com.xxl.job.admin.core.model.XxlJobGroup;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobUser;
      import com.xxl.job.admin.core.route.ExecutorRouteStrategyEnum;
      import com.xxl.job.admin.core.scheduler.MisfireStrategyEnum;
      import com.xxl.job.admin.core.scheduler.ScheduleTypeEnum;
      import com.xxl.job.admin.core.thread.JobScheduleHelper;
      import com.xxl.job.admin.core.thread.JobTriggerPoolHelper;
      import com.xxl.job.admin.core.trigger.TriggerTypeEnum;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.admin.dao.XxlJobGroupDao;
      import com.xxl.job.admin.service.LoginService;
      import com.xxl.job.admin.service.XxlJobService;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.core.enums.ExecutorBlockStrategyEnum;
      import com.xxl.job.core.glue.GlueTypeEnum;
      import com.xxl.job.core.util.DateUtil;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      import org.springframework.stereotype.Controller;
      import org.springframework.ui.Model;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.RequestParam;
      import org.springframework.web.bind.annotation.ResponseBody;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import java.text.ParseException;
      import java.util.*;
      /**
      * index controller
      * @author xuxueli 2015-12-19 16:13:16
      */
      @Controller
      @RequestMapping("/jobinfo")
      public class JobInfoController {
      private static Logger logger = LoggerFactory.getLogger(JobInfoController.class);
      @Resource
      private XxlJobGroupDao xxlJobGroupDao;
      @Resource
      private XxlJobService xxlJobService;
      @RequestMapping
      public String index(HttpServletRequest request, Model model, @RequestParam(required = false, defaultValue = "-1") int jobGroup) {
      // 枚举-字典
      model.addAttribute("ExecutorRouteStrategyEnum", ExecutorRouteStrategyEnum.values()); // 路由策略-列表
      model.addAttribute("GlueTypeEnum", GlueTypeEnum.values()); // Glue类型-字典
      model.addAttribute("ExecutorBlockStrategyEnum", ExecutorBlockStrategyEnum.values()); // 阻塞处理策略-字典
      model.addAttribute("ScheduleTypeEnum", ScheduleTypeEnum.values()); // 调度类型
      model.addAttribute("MisfireStrategyEnum", MisfireStrategyEnum.values()); // 调度过期策略
      // 执行器列表
      List<XxlJobGroup> jobGroupList_all = xxlJobGroupDao.findAll();
      // filter group
      List<XxlJobGroup> jobGroupList = filterJobGroupByRole(request, jobGroupList_all);
      if (jobGroupList==null || jobGroupList.size()==0) {
      throw new XxlJobException(I18nUtil.getString("jobgroup_empty"));
      }
      model.addAttribute("JobGroupList", jobGroupList);
      model.addAttribute("jobGroup", jobGroup);
      return "jobinfo/jobinfo.index";
      }
      public static List<XxlJobGroup> filterJobGroupByRole(HttpServletRequest request, List<XxlJobGroup> jobGroupList_all){
      List<XxlJobGroup> jobGroupList = new ArrayList<>();
      if (jobGroupList_all!=null && jobGroupList_all.size()>0) {
      XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
      if (loginUser.getRole() == 1) {
      jobGroupList = jobGroupList_all;
      } else {
      List<String> groupIdStrs = new ArrayList<>();
      if (loginUser.getPermission()!=null && loginUser.getPermission().trim().length()>0) {
      groupIdStrs = Arrays.asList(loginUser.getPermission().trim().split(","));
      }
      for (XxlJobGroup groupItem:jobGroupList_all) {
      if (groupIdStrs.contains(String.valueOf(groupItem.getId()))) {
      jobGroupList.add(groupItem);
      }
      }
      }
      }
      return jobGroupList;
      }
      public static void validPermission(HttpServletRequest request, int jobGroup) {
      XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
      if (!loginUser.validPermission(jobGroup)) {
      throw new RuntimeException(I18nUtil.getString("system_permission_limit") + "[username="+ loginUser.getUsername() +"]");
      }
      }
      @RequestMapping("/pageList")
      @ResponseBody
      public Map<String, Object> pageList(@RequestParam(required = false, defaultValue = "0") int start,
      @RequestParam(required = false, defaultValue = "10") int length,
      int jobGroup, int triggerStatus, String jobDesc, String executorHandler, String author) {
      return xxlJobService.pageList(start, length, jobGroup, triggerStatus, jobDesc, executorHandler, author);
      }
      @RequestMapping("/add")
      @ResponseBody
      public ReturnT<String> add(XxlJobInfo jobInfo) {
      return xxlJobService.add(jobInfo);
      }
      @RequestMapping("/update")
      @ResponseBody
      public ReturnT<String> update(XxlJobInfo jobInfo) {
      return xxlJobService.update(jobInfo);
      }
      @RequestMapping("/remove")
      @ResponseBody
      public ReturnT<String> remove(int id) {
      return xxlJobService.remove(id);
      }
      @RequestMapping("/stop")
      @ResponseBody
      public ReturnT<String> pause(int id) {
      return xxlJobService.stop(id);
      }
      @RequestMapping("/start")
      @ResponseBody
      public ReturnT<String> start(int id) {
      return xxlJobService.start(id);
      }
      @RequestMapping("/trigger")
      @ResponseBody
      //@PermissionLimit(limit = false)
      public ReturnT<String> triggerJob(int id, String executorParam, String addressList) {
      // force cover job param
      if (executorParam == null) {
      executorParam = "";
      }
      JobTriggerPoolHelper.trigger(id, TriggerTypeEnum.MANUAL, -1, null, executorParam, addressList);
      return ReturnT.SUCCESS;
      }
      @RequestMapping("/nextTriggerTime")
      @ResponseBody
      public ReturnT<List<String>> nextTriggerTime(String scheduleType, String scheduleConf) {
      XxlJobInfo paramXxlJobInfo = new XxlJobInfo();
      paramXxlJobInfo.setScheduleType(scheduleType);
      paramXxlJobInfo.setScheduleConf(scheduleConf);
      List<String> result = new ArrayList<>();
      try {
      Date lastTime = new Date();
      for (int i = 0; i < 5; i++) {
      lastTime = JobScheduleHelper.generateNextValidTime(paramXxlJobInfo, lastTime);
      if (lastTime != null) {
      result.add(DateUtil.formatDateTime(lastTime));
      } else {
      break;
      }
      }
      } catch (Exception e) {
      logger.error(e.getMessage(), e);
      return new ReturnT<List<String>>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) + e.getMessage());
      }
      return new ReturnT<List<String>>(result);
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.core.exception.XxlJobException;
      import com.xxl.job.admin.core.complete.XxlJobCompleter;
      import com.xxl.job.admin.core.model.XxlJobGroup;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobLog;
      import com.xxl.job.admin.core.scheduler.XxlJobScheduler;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.admin.dao.XxlJobGroupDao;
      import com.xxl.job.admin.dao.XxlJobInfoDao;
      import com.xxl.job.admin.dao.XxlJobLogDao;
      import com.xxl.job.core.biz.ExecutorBiz;
      import com.xxl.job.core.biz.model.KillParam;
      import com.xxl.job.core.biz.model.LogParam;
      import com.xxl.job.core.biz.model.LogResult;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.core.util.DateUtil;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      import org.springframework.stereotype.Controller;
      import org.springframework.ui.Model;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.RequestParam;
      import org.springframework.web.bind.annotation.ResponseBody;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import java.util.Date;
      import java.util.HashMap;
      import java.util.List;
      import java.util.Map;
      /**
      * index controller
      * @author xuxueli 2015-12-19 16:13:16
      */
      @Controller
      @RequestMapping("/joblog")
      public class JobLogController {
      private static Logger logger = LoggerFactory.getLogger(JobLogController.class);
      @Resource
      private XxlJobGroupDao xxlJobGroupDao;
      @Resource
      public XxlJobInfoDao xxlJobInfoDao;
      @Resource
      public XxlJobLogDao xxlJobLogDao;
      @RequestMapping
      public String index(HttpServletRequest request, Model model, @RequestParam(required = false, defaultValue = "0") Integer jobId) {
      // 执行器列表
      List<XxlJobGroup> jobGroupList_all = xxlJobGroupDao.findAll();
      // filter group
      List<XxlJobGroup> jobGroupList = JobInfoController.filterJobGroupByRole(request, jobGroupList_all);
      if (jobGroupList==null || jobGroupList.size()==0) {
      throw new XxlJobException(I18nUtil.getString("jobgroup_empty"));
      }
      model.addAttribute("JobGroupList", jobGroupList);
      // 任务
      if (jobId > 0) {
      XxlJobInfo jobInfo = xxlJobInfoDao.loadById(jobId);
      if (jobInfo == null) {
      throw new RuntimeException(I18nUtil.getString("jobinfo_field_id") + I18nUtil.getString("system_unvalid"));
      }
      model.addAttribute("jobInfo", jobInfo);
      // valid permission
      JobInfoController.validPermission(request, jobInfo.getJobGroup());
      }
      return "joblog/joblog.index";
      }
      @RequestMapping("/getJobsByGroup")
      @ResponseBody
      public ReturnT<List<XxlJobInfo>> getJobsByGroup(int jobGroup){
      List<XxlJobInfo> list = xxlJobInfoDao.getJobsByGroup(jobGroup);
      return new ReturnT<List<XxlJobInfo>>(list);
      }
      @RequestMapping("/pageList")
      @ResponseBody
      public Map<String, Object> pageList(HttpServletRequest request,
      @RequestParam(required = false, defaultValue = "0") int start,
      @RequestParam(required = false, defaultValue = "10") int length,
      int jobGroup, int jobId, int logStatus, String filterTime) {
      // valid permission
      JobInfoController.validPermission(request, jobGroup); // 仅管理员支持查询全部；普通用户仅支持查询有权限的 jobGroup
      // parse param
      Date triggerTimeStart = null;
      Date triggerTimeEnd = null;
      if (filterTime!=null && filterTime.trim().length()>0) {
      String[] temp = filterTime.split(" - ");
      if (temp.length == 2) {
      triggerTimeStart = DateUtil.parseDateTime(temp[0]);
      triggerTimeEnd = DateUtil.parseDateTime(temp[1]);
      }
      }
      // page query
      List<XxlJobLog> list = xxlJobLogDao.pageList(start, length, jobGroup, jobId, triggerTimeStart, triggerTimeEnd, logStatus);
      int list_count = xxlJobLogDao.pageListCount(start, length, jobGroup, jobId, triggerTimeStart, triggerTimeEnd, logStatus);
      // package result
      Map<String, Object> maps = new HashMap<String, Object>();
      maps.put("recordsTotal", list_count); // 总记录数
      maps.put("recordsFiltered", list_count); // 过滤后的总记录数
      maps.put("data", list); // 分页列表
      return maps;
      }
      @RequestMapping("/logDetailPage")
      public String logDetailPage(int id, Model model){
      // base check
      ReturnT<String> logStatue = ReturnT.SUCCESS;
      XxlJobLog jobLog = xxlJobLogDao.load(id);
      if (jobLog == null) {
      throw new RuntimeException(I18nUtil.getString("joblog_logid_unvalid"));
      }
      model.addAttribute("triggerCode", jobLog.getTriggerCode());
      model.addAttribute("handleCode", jobLog.getHandleCode());
      model.addAttribute("executorAddress", jobLog.getExecutorAddress());
      model.addAttribute("triggerTime", jobLog.getTriggerTime().getTime());
      model.addAttribute("logId", jobLog.getId());
      return "joblog/joblog.detail";
      }
      @RequestMapping("/logDetailCat")
      @ResponseBody
      public ReturnT<LogResult> logDetailCat(String executorAddress, long triggerTime, long logId, int fromLineNum){
      try {
      ExecutorBiz executorBiz = XxlJobScheduler.getExecutorBiz(executorAddress);
      ReturnT<LogResult> logResult = executorBiz.log(new LogParam(triggerTime, logId, fromLineNum));
      // is end
      if (logResult.getContent()!=null && logResult.getContent().getFromLineNum() > logResult.getContent().getToLineNum()) {
      XxlJobLog jobLog = xxlJobLogDao.load(logId);
      if (jobLog.getHandleCode() > 0) {
      logResult.getContent().setEnd(true);
      }
      }
      return logResult;
      } catch (Exception e) {
      logger.error(e.getMessage(), e);
      return new ReturnT<LogResult>(ReturnT.FAIL_CODE, e.getMessage());
      }
      }
      @RequestMapping("/logKill")
      @ResponseBody
      public ReturnT<String> logKill(int id){
      // base check
      XxlJobLog log = xxlJobLogDao.load(id);
      XxlJobInfo jobInfo = xxlJobInfoDao.loadById(log.getJobId());
      if (jobInfo==null) {
      return new ReturnT<String>(500, I18nUtil.getString("jobinfo_glue_jobid_unvalid"));
      }
      if (ReturnT.SUCCESS_CODE != log.getTriggerCode()) {
      return new ReturnT<String>(500, I18nUtil.getString("joblog_kill_log_limit"));
      }
      // request of kill
      ReturnT<String> runResult = null;
      try {
      ExecutorBiz executorBiz = XxlJobScheduler.getExecutorBiz(log.getExecutorAddress());
      runResult = executorBiz.kill(new KillParam(jobInfo.getId()));
      } catch (Exception e) {
      logger.error(e.getMessage(), e);
      runResult = new ReturnT<String>(500, e.getMessage());
      }
      if (ReturnT.SUCCESS_CODE == runResult.getCode()) {
      log.setHandleCode(ReturnT.FAIL_CODE);
      log.setHandleMsg( I18nUtil.getString("joblog_kill_log_byman")+":" + (runResult.getMsg()!=null?runResult.getMsg():""));
      log.setHandleTime(new Date());
      XxlJobCompleter.updateHandleInfoAndFinish(log);
      return new ReturnT<String>(runResult.getMsg());
      } else {
      return new ReturnT<String>(500, runResult.getMsg());
      }
      }
      @RequestMapping("/clearLog")
      @ResponseBody
      public ReturnT<String> clearLog(int jobGroup, int jobId, int type){
      Date clearBeforeTime = null;
      int clearBeforeNum = 0;
      if (type == 1) {
      clearBeforeTime = DateUtil.addMonths(new Date(), -1); // 清理一个月之前日志数据
      } else if (type == 2) {
      clearBeforeTime = DateUtil.addMonths(new Date(), -3); // 清理三个月之前日志数据
      } else if (type == 3) {
      clearBeforeTime = DateUtil.addMonths(new Date(), -6); // 清理六个月之前日志数据
      } else if (type == 4) {
      clearBeforeTime = DateUtil.addYears(new Date(), -1); // 清理一年之前日志数据
      } else if (type == 5) {
      clearBeforeNum = 1000; // 清理一千条以前日志数据
      } else if (type == 6) {
      clearBeforeNum = 10000; // 清理一万条以前日志数据
      } else if (type == 7) {
      clearBeforeNum = 30000; // 清理三万条以前日志数据
      } else if (type == 8) {
      clearBeforeNum = 100000; // 清理十万条以前日志数据
      } else if (type == 9) {
      clearBeforeNum = 0; // 清理所有日志数据
      } else {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("joblog_clean_type_unvalid"));
      }
      List<Long> logIds = null;
      do {
      logIds = xxlJobLogDao.findClearLogIds(jobGroup, jobId, clearBeforeTime, clearBeforeNum, 1000);
      if (logIds!=null && logIds.size()>0) {
      xxlJobLogDao.clearLog(logIds);
      }
      } while (logIds!=null && logIds.size()>0);
      return ReturnT.SUCCESS;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/UserController.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller;
      import com.xxl.job.admin.controller.annotation.PermissionLimit;
      import com.xxl.job.admin.core.model.XxlJobGroup;
      import com.xxl.job.admin.core.model.XxlJobUser;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.admin.dao.XxlJobGroupDao;
      import com.xxl.job.admin.dao.XxlJobUserDao;
      import com.xxl.job.admin.service.LoginService;
      import com.xxl.job.core.biz.model.ReturnT;
      import org.springframework.stereotype.Controller;
      import org.springframework.ui.Model;
      import org.springframework.util.DigestUtils;
      import org.springframework.util.StringUtils;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.RequestParam;
      import org.springframework.web.bind.annotation.ResponseBody;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import java.util.HashMap;
      import java.util.List;
      import java.util.Map;
      /**
      * @author xuxueli 2019-05-04 16:39:50
      */
      @Controller
      @RequestMapping("/user")
      public class UserController {
      @Resource
      private XxlJobUserDao xxlJobUserDao;
      @Resource
      private XxlJobGroupDao xxlJobGroupDao;
      @RequestMapping
      @PermissionLimit(adminuser = true)
      public String index(Model model) {
      // 执行器列表
      List<XxlJobGroup> groupList = xxlJobGroupDao.findAll();
      model.addAttribute("groupList", groupList);
      return "user/user.index";
      }
      @RequestMapping("/pageList")
      @ResponseBody
      @PermissionLimit(adminuser = true)
      public Map<String, Object> pageList(@RequestParam(required = false, defaultValue = "0") int start,
      @RequestParam(required = false, defaultValue = "10") int length,
      String username, int role) {
      // page list
      List<XxlJobUser> list = xxlJobUserDao.pageList(start, length, username, role);
      int list_count = xxlJobUserDao.pageListCount(start, length, username, role);
      // filter
      if (list!=null && list.size()>0) {
      for (XxlJobUser item: list) {
      item.setPassword(null);
      }
      }
      // package result
      Map<String, Object> maps = new HashMap<String, Object>();
      maps.put("recordsTotal", list_count); // 总记录数
      maps.put("recordsFiltered", list_count); // 过滤后的总记录数
      maps.put("data", list); // 分页列表
      return maps;
      }
      @RequestMapping("/add")
      @ResponseBody
      @PermissionLimit(adminuser = true)
      public ReturnT<String> add(XxlJobUser xxlJobUser) {
      // valid username
      if (!StringUtils.hasText(xxlJobUser.getUsername())) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("system_please_input")+I18nUtil.getString("user_username") );
      }
      xxlJobUser.setUsername(xxlJobUser.getUsername().trim());
      if (!(xxlJobUser.getUsername().length()>=4 && xxlJobUser.getUsername().length()<=20)) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("system_lengh_limit")+"[4-20]" );
      }
      // valid password
      if (!StringUtils.hasText(xxlJobUser.getPassword())) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("system_please_input")+I18nUtil.getString("user_password") );
      }
      xxlJobUser.setPassword(xxlJobUser.getPassword().trim());
      if (!(xxlJobUser.getPassword().length()>=4 && xxlJobUser.getPassword().length()<=20)) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("system_lengh_limit")+"[4-20]" );
      }
      // md5 password
      xxlJobUser.setPassword(DigestUtils.md5DigestAsHex(xxlJobUser.getPassword().getBytes()));
      // check repeat
      XxlJobUser existUser = xxlJobUserDao.loadByUserName(xxlJobUser.getUsername());
      if (existUser != null) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("user_username_repeat") );
      }
      // write
      xxlJobUserDao.save(xxlJobUser);
      return ReturnT.SUCCESS;
      }
      @RequestMapping("/update")
      @ResponseBody
      @PermissionLimit(adminuser = true)
      public ReturnT<String> update(HttpServletRequest request, XxlJobUser xxlJobUser) {
      // avoid opt login seft
      XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
      if (loginUser.getUsername().equals(xxlJobUser.getUsername())) {
      return new ReturnT<String>(ReturnT.FAIL.getCode(), I18nUtil.getString("user_update_loginuser_limit"));
      }
      // valid password
      if (StringUtils.hasText(xxlJobUser.getPassword())) {
      xxlJobUser.setPassword(xxlJobUser.getPassword().trim());
      if (!(xxlJobUser.getPassword().length()>=4 && xxlJobUser.getPassword().length()<=20)) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("system_lengh_limit")+"[4-20]" );
      }
      // md5 password
      xxlJobUser.setPassword(DigestUtils.md5DigestAsHex(xxlJobUser.getPassword().getBytes()));
      } else {
      xxlJobUser.setPassword(null);
      }
      // write
      xxlJobUserDao.update(xxlJobUser);
      return ReturnT.SUCCESS;
      }
      @RequestMapping("/remove")
      @ResponseBody
      @PermissionLimit(adminuser = true)
      public ReturnT<String> remove(HttpServletRequest request, int id) {
      // avoid opt login seft
      XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
      if (loginUser.getId() == id) {
      return new ReturnT<String>(ReturnT.FAIL.getCode(), I18nUtil.getString("user_update_loginuser_limit"));
      }
      xxlJobUserDao.delete(id);
      return ReturnT.SUCCESS;
      }
      @RequestMapping("/updatePwd")
      @ResponseBody
      public ReturnT<String> updatePwd(HttpServletRequest request, String password){
      // valid password
      if (password==null || password.trim().length()==0){
      return new ReturnT<String>(ReturnT.FAIL.getCode(), "密码不可为空");
      }
      password = password.trim();
      if (!(password.length()>=4 && password.length()<=20)) {
      return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("system_lengh_limit")+"[4-20]" );
      }
      // md5 password
      String md5Password = DigestUtils.md5DigestAsHex(password.getBytes());
      // update pwd
      XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
      // do write
      XxlJobUser existUser = xxlJobUserDao.loadByUserName(loginUser.getUsername());
      existUser.setPassword(md5Password);
      xxlJobUserDao.update(existUser);
      return ReturnT.SUCCESS;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/annotation/PermissionLimit.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller.annotation;
      import java.lang.annotation.ElementType;
      import java.lang.annotation.Retention;
      import java.lang.annotation.RetentionPolicy;
      import java.lang.annotation.Target;
      /**
      * 权限限制
      * @author xuxueli 2015-12-12 18:29:02
      */
      @Target(ElementType.METHOD)
      @Retention(RetentionPolicy.RUNTIME)
      public @interface PermissionLimit {
      /**
      * 登录拦截 (默认拦截)
      */
      boolean limit() default true;
      /**
      * 要求管理员权限
      *
      * @return
      */
      boolean adminuser() default false;
      }
      \ No newline at end of file
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/interceptor/CookieInterceptor.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller.interceptor;
      import com.xxl.job.admin.core.util.FtlUtil;
      import com.xxl.job.admin.core.util.I18nUtil;
      import org.springframework.stereotype.Component;
      import org.springframework.web.servlet.ModelAndView;
      import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
      import javax.servlet.http.Cookie;
      import javax.servlet.http.HttpServletRequest;
      import javax.servlet.http.HttpServletResponse;
      import java.util.HashMap;
      /**
      * push cookies to model as cookieMap
      *
      * @author xuxueli 2015-12-12 18:09:04
      */
      @Component
      public class CookieInterceptor extends HandlerInterceptorAdapter {
      @Override
      public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
      ModelAndView modelAndView) throws Exception {
      // cookie
      if (modelAndView!=null && request.getCookies()!=null && request.getCookies().length>0) {
      HashMap<String, Cookie> cookieMap = new HashMap<String, Cookie>();
      for (Cookie ck : request.getCookies()) {
      cookieMap.put(ck.getName(), ck);
      }
      modelAndView.addObject("cookieMap", cookieMap);
      }
      // static method
      if (modelAndView != null) {
      modelAndView.addObject("I18nUtil", FtlUtil.generateStaticModel(I18nUtil.class.getName()));
      }
      super.postHandle(request, response, handler, modelAndView);
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/interceptor/PermissionInterceptor.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller.interceptor;
      import com.xxl.job.admin.controller.annotation.PermissionLimit;
      import com.xxl.job.admin.core.model.XxlJobUser;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.admin.service.LoginService;
      import org.springframework.stereotype.Component;
      import org.springframework.web.method.HandlerMethod;
      import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
      import javax.annotation.Resource;
      import javax.servlet.http.HttpServletRequest;
      import javax.servlet.http.HttpServletResponse;
      /**
      * 权限拦截
      *
      * @author xuxueli 2015-12-12 18:09:04
      */
      @Component
      public class PermissionInterceptor extends HandlerInterceptorAdapter {
      @Resource
      private LoginService loginService;
      @Override
      public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
      if (!(handler instanceof HandlerMethod)) {
      return super.preHandle(request, response, handler);
      }
      // if need login
      boolean needLogin = true;
      boolean needAdminuser = false;
      HandlerMethod method = (HandlerMethod)handler;
      PermissionLimit permission = method.getMethodAnnotation(PermissionLimit.class);
      if (permission!=null) {
      needLogin = permission.limit();
      needAdminuser = permission.adminuser();
      }
      if (needLogin) {
      XxlJobUser loginUser = loginService.ifLogin(request, response);
      if (loginUser == null) {
      response.setStatus(302);
      response.setHeader("location", request.getContextPath()+"/toLogin");
      return false;
      }
      if (needAdminuser && loginUser.getRole()!=1) {
      throw new RuntimeException(I18nUtil.getString("system_permission_limit"));
      }
      request.setAttribute(LoginService.LOGIN_IDENTITY_KEY, loginUser);
      }
      return super.preHandle(request, response, handler);
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/interceptor/WebMvcConfig.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller.interceptor;
      import org.springframework.context.annotation.Configuration;
      import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
      import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
      import javax.annotation.Resource;
      /**
      * web mvc config
      *
      * @author xuxueli 2018-04-02 20:48:20
      */
      @Configuration
      public class WebMvcConfig implements WebMvcConfigurer {
      @Resource
      private PermissionInterceptor permissionInterceptor;
      @Resource
      private CookieInterceptor cookieInterceptor;
      @Override
      public void addInterceptors(InterceptorRegistry registry) {
      registry.addInterceptor(permissionInterceptor).addPathPatterns("/**");
      registry.addInterceptor(cookieInterceptor).addPathPatterns("/**");
      }
      }
      \ No newline at end of file
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.controller.resolver;
      import com.xxl.job.admin.core.exception.XxlJobException;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.admin.core.util.JacksonUtil;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      import org.springframework.stereotype.Component;
      import org.springframework.web.bind.annotation.ResponseBody;
      import org.springframework.web.method.HandlerMethod;
      import org.springframework.web.servlet.HandlerExceptionResolver;
      import org.springframework.web.servlet.ModelAndView;
      import javax.servlet.http.HttpServletRequest;
      import javax.servlet.http.HttpServletResponse;
      import java.io.IOException;
      /**
      * common exception resolver
      *
      * @author xuxueli 2016-1-6 19:22:18
      */
      @Component
      public class WebExceptionResolver implements HandlerExceptionResolver {
      private static transient Logger logger = LoggerFactory.getLogger(WebExceptionResolver.class);
      @Override
      public ModelAndView resolveException(HttpServletRequest request,
      HttpServletResponse response, Object handler, Exception ex) {
      if (!(ex instanceof XxlJobException)) {
      logger.error("WebExceptionResolver:{}", ex);
      }
      // if json
      boolean isJson = false;
      if (handler instanceof HandlerMethod) {
      HandlerMethod method = (HandlerMethod)handler;
      ResponseBody responseBody = method.getMethodAnnotation(ResponseBody.class);
      if (responseBody != null) {
      isJson = true;
      }
      }
      // error result
      ReturnT<String> errorResult = new ReturnT<String>(ReturnT.FAIL_CODE, ex.toString().replaceAll("\n", "<br/>"));
      // response
      ModelAndView mv = new ModelAndView();
      if (isJson) {
      try {
      response.setContentType("application/json;charset=utf-8");
      response.getWriter().print(JacksonUtil.writeValueAsString(errorResult));
      } catch (IOException e) {
      logger.error(e.getMessage(), e);
      }
      return mv;
      } else {
      mv.addObject("exceptionMsg", errorResult.getMsg());
      mv.setViewName("/common/common.exception");
      return mv;
      }
      }
      }
      \ No newline at end of file
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/alarm/JobAlarm.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.alarm;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobLog;
      /**
      * @author xuxueli 2020-01-19
      */
      public interface JobAlarm {
      /**
      * job alarm
      *
      * @param info
      * @param jobLog
      * @return
      */
      public boolean doAlarm(XxlJobInfo info, XxlJobLog jobLog);
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/alarm/JobAlarmer.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.alarm;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobLog;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      import org.springframework.beans.BeansException;
      import org.springframework.beans.factory.InitializingBean;
      import org.springframework.context.ApplicationContext;
      import org.springframework.context.ApplicationContextAware;
      import org.springframework.stereotype.Component;
      import java.util.ArrayList;
      import java.util.List;
      import java.util.Map;
      @Component
      public class JobAlarmer implements ApplicationContextAware, InitializingBean {
      private static Logger logger = LoggerFactory.getLogger(JobAlarmer.class);
      private ApplicationContext applicationContext;
      private List<JobAlarm> jobAlarmList;
      @Override
      public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
      this.applicationContext = applicationContext;
      }
      @Override
      public void afterPropertiesSet() throws Exception {
      Map<String, JobAlarm> serviceBeanMap = applicationContext.getBeansOfType(JobAlarm.class);
      if (serviceBeanMap != null && serviceBeanMap.size() > 0) {
      jobAlarmList = new ArrayList<JobAlarm>(serviceBeanMap.values());
      }
      }
      /**
      * job alarm
      *
      * @param info
      * @param jobLog
      * @return
      */
      public boolean alarm(XxlJobInfo info, XxlJobLog jobLog) {
      boolean result = false;
      if (jobAlarmList!=null && jobAlarmList.size()>0) {
      result = true; // success means all-success
      for (JobAlarm alarm: jobAlarmList) {
      boolean resultItem = false;
      try {
      resultItem = alarm.doAlarm(info, jobLog);
      } catch (Exception e) {
      logger.error(e.getMessage(), e);
      }
      if (!resultItem) {
      result = false;
      }
      }
      }
      return result;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/alarm/impl/EmailJobAlarm.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.alarm.impl;
      import com.xxl.job.admin.core.alarm.JobAlarm;
      import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
      import com.xxl.job.admin.core.model.XxlJobGroup;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobLog;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.core.biz.model.ReturnT;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      import org.springframework.mail.javamail.MimeMessageHelper;
      import org.springframework.stereotype.Component;
      import javax.mail.internet.MimeMessage;
      import java.text.MessageFormat;
      import java.util.Arrays;
      import java.util.HashSet;
      import java.util.Set;
      /**
      * job alarm by email
      *
      * @author xuxueli 2020-01-19
      */
      @Component
      public class EmailJobAlarm implements JobAlarm {
      private static Logger logger = LoggerFactory.getLogger(EmailJobAlarm.class);
      /**
      * fail alarm
      *
      * @param jobLog
      */
      public boolean doAlarm(XxlJobInfo info, XxlJobLog jobLog){
      boolean alarmResult = true;
      // send monitor email
      if (info!=null && info.getAlarmEmail()!=null && info.getAlarmEmail().trim().length()>0) {
      // alarmContent
      String alarmContent = "Alarm Job LogId=" + jobLog.getId();
      if (jobLog.getTriggerCode() != ReturnT.SUCCESS_CODE) {
      alarmContent += "<br>TriggerMsg=<br>" + jobLog.getTriggerMsg();
      }
      if (jobLog.getHandleCode()>0 && jobLog.getHandleCode() != ReturnT.SUCCESS_CODE) {
      alarmContent += "<br>HandleCode=" + jobLog.getHandleMsg();
      }
      // email info
      XxlJobGroup group = XxlJobAdminConfig.getAdminConfig().getXxlJobGroupDao().load(Integer.valueOf(info.getJobGroup()));
      String personal = I18nUtil.getString("admin_name_full");
      String title = I18nUtil.getString("jobconf_monitor");
      String content = MessageFormat.format(loadEmailJobAlarmTemplate(),
      group!=null?group.getTitle():"null",
      info.getId(),
      info.getJobDesc(),
      alarmContent);
      Set<String> emailSet = new HashSet<String>(Arrays.asList(info.getAlarmEmail().split(",")));
      for (String email: emailSet) {
      // make mail
      try {
      MimeMessage mimeMessage = XxlJobAdminConfig.getAdminConfig().getMailSender().createMimeMessage();
      MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
      helper.setFrom(XxlJobAdminConfig.getAdminConfig().getEmailFrom(), personal);
      helper.setTo(email);
      helper.setSubject(title);
      helper.setText(content, true);
      XxlJobAdminConfig.getAdminConfig().getMailSender().send(mimeMessage);
      } catch (Exception e) {
      logger.error(">>>>>>>>>>> xxl-job, job fail alarm email send error, JobLogId:{}", jobLog.getId(), e);
      alarmResult = false;
      }
      }
      }
      return alarmResult;
      }
      /**
      * load email job alarm template
      *
      * @return
      */
      private static final String loadEmailJobAlarmTemplate(){
      String mailBodyTemplate = "<h5>" + I18nUtil.getString("jobconf_monitor_detail") + "：</span>" +
      "<table border=\"1\" cellpadding=\"3\" style=\"border-collapse:collapse; width:80%;\" >\n" +
      " <thead style=\"font-weight: bold;color: #ffffff;background-color: #ff8c00;\" >" +
      " <tr>\n" +
      " <td width=\"20%\" >"+ I18nUtil.getString("jobinfo_field_jobgroup") +"</td>\n" +
      " <td width=\"10%\" >"+ I18nUtil.getString("jobinfo_field_id") +"</td>\n" +
      " <td width=\"20%\" >"+ I18nUtil.getString("jobinfo_field_jobdesc") +"</td>\n" +
      " <td width=\"10%\" >"+ I18nUtil.getString("jobconf_monitor_alarm_title") +"</td>\n" +
      " <td width=\"40%\" >"+ I18nUtil.getString("jobconf_monitor_alarm_content") +"</td>\n" +
      " </tr>\n" +
      " </thead>\n" +
      " <tbody>\n" +
      " <tr>\n" +
      " <td>{0}</td>\n" +
      " <td>{1}</td>\n" +
      " <td>{2}</td>\n" +
      " <td>"+ I18nUtil.getString("jobconf_monitor_alarm_type") +"</td>\n" +
      " <td>{3}</td>\n" +
      " </tr>\n" +
      " </tbody>\n" +
      "</table>";
      return mailBodyTemplate;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/complete/XxlJobCompleter.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.complete;
      import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
      import com.xxl.job.admin.core.model.XxlJobInfo;
      import com.xxl.job.admin.core.model.XxlJobLog;
      import com.xxl.job.admin.core.thread.JobTriggerPoolHelper;
      import com.xxl.job.admin.core.trigger.TriggerTypeEnum;
      import com.xxl.job.admin.core.util.I18nUtil;
      import com.xxl.job.core.biz.model.ReturnT;
      import com.xxl.job.core.context.XxlJobContext;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      import java.text.MessageFormat;
      /**
      * @author xuxueli 2020-10-30 20:43:10
      */
      public class XxlJobCompleter {
      private static Logger logger = LoggerFactory.getLogger(XxlJobCompleter.class);
      /**
      * common fresh handle entrance (limit only once)
      *
      * @param xxlJobLog
      * @return
      */
      public static int updateHandleInfoAndFinish(XxlJobLog xxlJobLog) {
      // finish
      finishJob(xxlJobLog);
      // text最大64kb 避免长度过长
      if (xxlJobLog.getHandleMsg().length() > 15000) {
      xxlJobLog.setHandleMsg( xxlJobLog.getHandleMsg().substring(0, 15000) );
      }
      // fresh handle
      return XxlJobAdminConfig.getAdminConfig().getXxlJobLogDao().updateHandleInfo(xxlJobLog);
      }
      /**
      * do somethind to finish job
      */
      private static void finishJob(XxlJobLog xxlJobLog){
      // 1、handle success, to trigger child job
      String triggerChildMsg = null;
      if (XxlJobContext.HANDLE_COCE_SUCCESS == xxlJobLog.getHandleCode()) {
      XxlJobInfo xxlJobInfo = XxlJobAdminConfig.getAdminConfig().getXxlJobInfoDao().loadById(xxlJobLog.getJobId());
      if (xxlJobInfo!=null && xxlJobInfo.getChildJobId()!=null && xxlJobInfo.getChildJobId().trim().length()>0) {
      triggerChildMsg = "<br><br><span style=\"color:#00c0ef;\" > >>>>>>>>>>>"+ I18nUtil.getString("jobconf_trigger_child_run") +"<<<<<<<<<<< </span><br>";
      String[] childJobIds = xxlJobInfo.getChildJobId().split(",");
      for (int i = 0; i < childJobIds.length; i++) {
      int childJobId = (childJobIds[i]!=null && childJobIds[i].trim().length()>0 && isNumeric(childJobIds[i]))?Integer.valueOf(childJobIds[i]):-1;
      if (childJobId > 0) {
      JobTriggerPoolHelper.trigger(childJobId, TriggerTypeEnum.PARENT, -1, null, null, null);
      ReturnT<String> triggerChildResult = ReturnT.SUCCESS;
      // add msg
      triggerChildMsg += MessageFormat.format(I18nUtil.getString("jobconf_callback_child_msg1"),
      (i+1),
      childJobIds.length,
      childJobIds[i],
      (triggerChildResult.getCode()==ReturnT.SUCCESS_CODE?I18nUtil.getString("system_success"):I18nUtil.getString("system_fail")),
      triggerChildResult.getMsg());
      } else {
      triggerChildMsg += MessageFormat.format(I18nUtil.getString("jobconf_callback_child_msg2"),
      (i+1),
      childJobIds.length,
      childJobIds[i]);
      }
      }
      }
      }
      if (triggerChildMsg != null) {
      xxlJobLog.setHandleMsg( xxlJobLog.getHandleMsg() + triggerChildMsg );
      }
      // 2、fix_delay trigger next
      // on the way
      }
      private static boolean isNumeric(String str){
      try {
      int result = Integer.valueOf(str);
      return true;
      } catch (NumberFormatException e) {
      return false;
      }
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/conf/XxlJobAdminConfig.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.conf;
      import com.xxl.job.admin.core.alarm.JobAlarmer;
      import com.xxl.job.admin.core.scheduler.XxlJobScheduler;
      import com.xxl.job.admin.dao.*;
      import org.springframework.beans.factory.DisposableBean;
      import org.springframework.beans.factory.InitializingBean;
      import org.springframework.beans.factory.annotation.Value;
      import org.springframework.mail.javamail.JavaMailSender;
      import org.springframework.stereotype.Component;
      import javax.annotation.Resource;
      import javax.sql.DataSource;
      import java.util.Arrays;
      /**
      * xxl-job config
      *
      * @author xuxueli 2017-04-28
      */
      @Component
      public class XxlJobAdminConfig implements InitializingBean, DisposableBean {
      private static XxlJobAdminConfig adminConfig = null;
      public static XxlJobAdminConfig getAdminConfig() {
      return adminConfig;
      }
      // ---------------------- XxlJobScheduler ----------------------
      private XxlJobScheduler xxlJobScheduler;
      @Override
      public void afterPropertiesSet() throws Exception {
      adminConfig = this;
      xxlJobScheduler = new XxlJobScheduler();
      xxlJobScheduler.init();
      }
      @Override
      public void destroy() throws Exception {
      xxlJobScheduler.destroy();
      }
      // ---------------------- XxlJobScheduler ----------------------
      // conf
      @Value("${xxl.job.i18n}")
      private String i18n;
      @Value("${xxl.job.accessToken}")
      private String accessToken;
      @Value("${spring.mail.from}")
      private String emailFrom;
      @Value("${xxl.job.triggerpool.fast.max}")
      private int triggerPoolFastMax;
      @Value("${xxl.job.triggerpool.slow.max}")
      private int triggerPoolSlowMax;
      @Value("${xxl.job.logretentiondays}")
      private int logretentiondays;
      // dao, service
      @Resource
      private XxlJobLogDao xxlJobLogDao;
      @Resource
      private XxlJobInfoDao xxlJobInfoDao;
      @Resource
      private XxlJobRegistryDao xxlJobRegistryDao;
      @Resource
      private XxlJobGroupDao xxlJobGroupDao;
      @Resource
      private XxlJobLogReportDao xxlJobLogReportDao;
      @Resource
      private JavaMailSender mailSender;
      @Resource
      private DataSource dataSource;
      @Resource
      private JobAlarmer jobAlarmer;
      public String getI18n() {
      if (!Arrays.asList("zh_CN", "zh_TC", "en").contains(i18n)) {
      return "zh_CN";
      }
      return i18n;
      }
      public String getAccessToken() {
      return accessToken;
      }
      public String getEmailFrom() {
      return emailFrom;
      }
      public int getTriggerPoolFastMax() {
      if (triggerPoolFastMax < 200) {
      return 200;
      }
      return triggerPoolFastMax;
      }
      public int getTriggerPoolSlowMax() {
      if (triggerPoolSlowMax < 100) {
      return 100;
      }
      return triggerPoolSlowMax;
      }
      public int getLogretentiondays() {
      if (logretentiondays < 7) {
      return -1; // Limit greater than or equal to 7, otherwise close
      }
      return logretentiondays;
      }
      public XxlJobLogDao getXxlJobLogDao() {
      return xxlJobLogDao;
      }
      public XxlJobInfoDao getXxlJobInfoDao() {
      return xxlJobInfoDao;
      }
      public XxlJobRegistryDao getXxlJobRegistryDao() {
      return xxlJobRegistryDao;
      }
      public XxlJobGroupDao getXxlJobGroupDao() {
      return xxlJobGroupDao;
      }
      public XxlJobLogReportDao getXxlJobLogReportDao() {
      return xxlJobLogReportDao;
      }
      public JavaMailSender getMailSender() {
      return mailSender;
      }
      public DataSource getDataSource() {
      return dataSource;
      }
      public JobAlarmer getJobAlarmer() {
      return jobAlarmer;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/exception/XxlJobException.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.exception;
      /**
      * @author xuxueli 2019-05-04 23:19:29
      */
      public class XxlJobException extends RuntimeException {
      public XxlJobException() {
      }
      public XxlJobException(String message) {
      super(message);
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobGroup.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import java.util.ArrayList;
      import java.util.Arrays;
      import java.util.Date;
      import java.util.List;
      /**
      * Created by xuxueli on 16/9/30.
      */
      public class XxlJobGroup {
      private int id;
      private String appname;
      private String title;
      private int addressType; // 执行器地址类型：0=自动注册、1=手动录入
      private String addressList; // 执行器地址列表，多地址逗号分隔(手动录入)
      private Date updateTime;
      // registry list
      private List<String> registryList; // 执行器地址列表(系统注册)
      public List<String> getRegistryList() {
      if (addressList!=null && addressList.trim().length()>0) {
      registryList = new ArrayList<String>(Arrays.asList(addressList.split(",")));
      }
      return registryList;
      }
      public int getId() {
      return id;
      }
      public void setId(int id) {
      this.id = id;
      }
      public String getAppname() {
      return appname;
      }
      public void setAppname(String appname) {
      this.appname = appname;
      }
      public String getTitle() {
      return title;
      }
      public void setTitle(String title) {
      this.title = title;
      }
      public int getAddressType() {
      return addressType;
      }
      public void setAddressType(int addressType) {
      this.addressType = addressType;
      }
      public String getAddressList() {
      return addressList;
      }
      public Date getUpdateTime() {
      return updateTime;
      }
      public void setUpdateTime(Date updateTime) {
      this.updateTime = updateTime;
      }
      public void setAddressList(String addressList) {
      this.addressList = addressList;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobInfo.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import java.util.Date;
      /**
      * xxl-job info
      *
      * @author xuxueli 2016-1-12 18:25:49
      */
      public class XxlJobInfo {
      private int id; // 主键ID
      private int jobGroup; // 执行器主键ID
      private String jobDesc;
      private Date addTime;
      private Date updateTime;
      private String author; // 负责人
      private String alarmEmail; // 报警邮件
      private String scheduleType; // 调度类型
      private String scheduleConf; // 调度配置，值含义取决于调度类型
      private String misfireStrategy; // 调度过期策略
      private String executorRouteStrategy; // 执行器路由策略
      private String executorHandler; // 执行器，任务Handler名称
      private String executorParam; // 执行器，任务参数
      private String executorBlockStrategy; // 阻塞处理策略
      private int executorTimeout; // 任务执行超时时间，单位秒
      private int executorFailRetryCount; // 失败重试次数
      private String glueType; // GLUE类型 #com.xxl.job.core.glue.GlueTypeEnum
      private String glueSource; // GLUE源代码
      private String glueRemark; // GLUE备注
      private Date glueUpdatetime; // GLUE更新时间
      private String childJobId; // 子任务ID，多个逗号分隔
      private int triggerStatus; // 调度状态：0-停止，1-运行
      private long triggerLastTime; // 上次调度时间
      private long triggerNextTime; // 下次调度时间
      public int getId() {
      return id;
      }
      public void setId(int id) {
      this.id = id;
      }
      public int getJobGroup() {
      return jobGroup;
      }
      public void setJobGroup(int jobGroup) {
      this.jobGroup = jobGroup;
      }
      public String getJobDesc() {
      return jobDesc;
      }
      public void setJobDesc(String jobDesc) {
      this.jobDesc = jobDesc;
      }
      public Date getAddTime() {
      return addTime;
      }
      public void setAddTime(Date addTime) {
      this.addTime = addTime;
      }
      public Date getUpdateTime() {
      return updateTime;
      }
      public void setUpdateTime(Date updateTime) {
      this.updateTime = updateTime;
      }
      public String getAuthor() {
      return author;
      }
      public void setAuthor(String author) {
      this.author = author;
      }
      public String getAlarmEmail() {
      return alarmEmail;
      }
      public void setAlarmEmail(String alarmEmail) {
      this.alarmEmail = alarmEmail;
      }
      public String getScheduleType() {
      return scheduleType;
      }
      public void setScheduleType(String scheduleType) {
      this.scheduleType = scheduleType;
      }
      public String getScheduleConf() {
      return scheduleConf;
      }
      public void setScheduleConf(String scheduleConf) {
      this.scheduleConf = scheduleConf;
      }
      public String getMisfireStrategy() {
      return misfireStrategy;
      }
      public void setMisfireStrategy(String misfireStrategy) {
      this.misfireStrategy = misfireStrategy;
      }
      public String getExecutorRouteStrategy() {
      return executorRouteStrategy;
      }
      public void setExecutorRouteStrategy(String executorRouteStrategy) {
      this.executorRouteStrategy = executorRouteStrategy;
      }
      public String getExecutorHandler() {
      return executorHandler;
      }
      public void setExecutorHandler(String executorHandler) {
      this.executorHandler = executorHandler;
      }
      public String getExecutorParam() {
      return executorParam;
      }
      public void setExecutorParam(String executorParam) {
      this.executorParam = executorParam;
      }
      public String getExecutorBlockStrategy() {
      return executorBlockStrategy;
      }
      public void setExecutorBlockStrategy(String executorBlockStrategy) {
      this.executorBlockStrategy = executorBlockStrategy;
      }
      public int getExecutorTimeout() {
      return executorTimeout;
      }
      public void setExecutorTimeout(int executorTimeout) {
      this.executorTimeout = executorTimeout;
      }
      public int getExecutorFailRetryCount() {
      return executorFailRetryCount;
      }
      public void setExecutorFailRetryCount(int executorFailRetryCount) {
      this.executorFailRetryCount = executorFailRetryCount;
      }
      public String getGlueType() {
      return glueType;
      }
      public void setGlueType(String glueType) {
      this.glueType = glueType;
      }
      public String getGlueSource() {
      return glueSource;
      }
      public void setGlueSource(String glueSource) {
      this.glueSource = glueSource;
      }
      public String getGlueRemark() {
      return glueRemark;
      }
      public void setGlueRemark(String glueRemark) {
      this.glueRemark = glueRemark;
      }
      public Date getGlueUpdatetime() {
      return glueUpdatetime;
      }
      public void setGlueUpdatetime(Date glueUpdatetime) {
      this.glueUpdatetime = glueUpdatetime;
      }
      public String getChildJobId() {
      return childJobId;
      }
      public void setChildJobId(String childJobId) {
      this.childJobId = childJobId;
      }
      public int getTriggerStatus() {
      return triggerStatus;
      }
      public void setTriggerStatus(int triggerStatus) {
      this.triggerStatus = triggerStatus;
      }
      public long getTriggerLastTime() {
      return triggerLastTime;
      }
      public void setTriggerLastTime(long triggerLastTime) {
      this.triggerLastTime = triggerLastTime;
      }
      public long getTriggerNextTime() {
      return triggerNextTime;
      }
      public void setTriggerNextTime(long triggerNextTime) {
      this.triggerNextTime = triggerNextTime;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobLog.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import java.util.Date;
      /**
      * xxl-job log, used to track trigger process
      * @author xuxueli 2015-12-19 23:19:09
      */
      public class XxlJobLog {
      private long id;
      // job info
      private int jobGroup;
      private int jobId;
      // execute info
      private String executorAddress;
      private String executorHandler;
      private String executorParam;
      private String executorShardingParam;
      private int executorFailRetryCount;
      // trigger info
      private Date triggerTime;
      private int triggerCode;
      private String triggerMsg;
      // handle info
      private Date handleTime;
      private int handleCode;
      private String handleMsg;
      // alarm info
      private int alarmStatus;
      public long getId() {
      return id;
      }
      public void setId(long id) {
      this.id = id;
      }
      public int getJobGroup() {
      return jobGroup;
      }
      public void setJobGroup(int jobGroup) {
      this.jobGroup = jobGroup;
      }
      public int getJobId() {
      return jobId;
      }
      public void setJobId(int jobId) {
      this.jobId = jobId;
      }
      public String getExecutorAddress() {
      return executorAddress;
      }
      public void setExecutorAddress(String executorAddress) {
      this.executorAddress = executorAddress;
      }
      public String getExecutorHandler() {
      return executorHandler;
      }
      public void setExecutorHandler(String executorHandler) {
      this.executorHandler = executorHandler;
      }
      public String getExecutorParam() {
      return executorParam;
      }
      public void setExecutorParam(String executorParam) {
      this.executorParam = executorParam;
      }
      public String getExecutorShardingParam() {
      return executorShardingParam;
      }
      public void setExecutorShardingParam(String executorShardingParam) {
      this.executorShardingParam = executorShardingParam;
      }
      public int getExecutorFailRetryCount() {
      return executorFailRetryCount;
      }
      public void setExecutorFailRetryCount(int executorFailRetryCount) {
      this.executorFailRetryCount = executorFailRetryCount;
      }
      public Date getTriggerTime() {
      return triggerTime;
      }
      public void setTriggerTime(Date triggerTime) {
      this.triggerTime = triggerTime;
      }
      public int getTriggerCode() {
      return triggerCode;
      }
      public void setTriggerCode(int triggerCode) {
      this.triggerCode = triggerCode;
      }
      public String getTriggerMsg() {
      return triggerMsg;
      }
      public void setTriggerMsg(String triggerMsg) {
      this.triggerMsg = triggerMsg;
      }
      public Date getHandleTime() {
      return handleTime;
      }
      public void setHandleTime(Date handleTime) {
      this.handleTime = handleTime;
      }
      public int getHandleCode() {
      return handleCode;
      }
      public void setHandleCode(int handleCode) {
      this.handleCode = handleCode;
      }
      public String getHandleMsg() {
      return handleMsg;
      }
      public void setHandleMsg(String handleMsg) {
      this.handleMsg = handleMsg;
      }
      public int getAlarmStatus() {
      return alarmStatus;
      }
      public void setAlarmStatus(int alarmStatus) {
      this.alarmStatus = alarmStatus;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobLogGlue.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import java.util.Date;
      /**
      * xxl-job log for glue, used to track job code process
      * @author xuxueli 2016-5-19 17:57:46
      */
      public class XxlJobLogGlue {
      private int id;
      private int jobId; // 任务主键ID
      private String glueType; // GLUE类型 #com.xxl.job.core.glue.GlueTypeEnum
      private String glueSource;
      private String glueRemark;
      private Date addTime;
      private Date updateTime;
      public int getId() {
      return id;
      }
      public void setId(int id) {
      this.id = id;
      }
      public int getJobId() {
      return jobId;
      }
      public void setJobId(int jobId) {
      this.jobId = jobId;
      }
      public String getGlueType() {
      return glueType;
      }
      public void setGlueType(String glueType) {
      this.glueType = glueType;
      }
      public String getGlueSource() {
      return glueSource;
      }
      public void setGlueSource(String glueSource) {
      this.glueSource = glueSource;
      }
      public String getGlueRemark() {
      return glueRemark;
      }
      public void setGlueRemark(String glueRemark) {
      this.glueRemark = glueRemark;
      }
      public Date getAddTime() {
      return addTime;
      }
      public void setAddTime(Date addTime) {
      this.addTime = addTime;
      }
      public Date getUpdateTime() {
      return updateTime;
      }
      public void setUpdateTime(Date updateTime) {
      this.updateTime = updateTime;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobLogReport.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import java.util.Date;
      public class XxlJobLogReport {
      private int id;
      private Date triggerDay;
      private int runningCount;
      private int sucCount;
      private int failCount;
      public int getId() {
      return id;
      }
      public void setId(int id) {
      this.id = id;
      }
      public Date getTriggerDay() {
      return triggerDay;
      }
      public void setTriggerDay(Date triggerDay) {
      this.triggerDay = triggerDay;
      }
      public int getRunningCount() {
      return runningCount;
      }
      public void setRunningCount(int runningCount) {
      this.runningCount = runningCount;
      }
      public int getSucCount() {
      return sucCount;
      }
      public void setSucCount(int sucCount) {
      this.sucCount = sucCount;
      }
      public int getFailCount() {
      return failCount;
      }
      public void setFailCount(int failCount) {
      this.failCount = failCount;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobRegistry.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import java.util.Date;
      /**
      * Created by xuxueli on 16/9/30.
      */
      public class XxlJobRegistry {
      private int id;
      private String registryGroup;
      private String registryKey;
      private String registryValue;
      private Date updateTime;
      public int getId() {
      return id;
      }
      public void setId(int id) {
      this.id = id;
      }
      public String getRegistryGroup() {
      return registryGroup;
      }
      public void setRegistryGroup(String registryGroup) {
      this.registryGroup = registryGroup;
      }
      public String getRegistryKey() {
      return registryKey;
      }
      public void setRegistryKey(String registryKey) {
      this.registryKey = registryKey;
      }
      public String getRegistryValue() {
      return registryValue;
      }
      public void setRegistryValue(String registryValue) {
      this.registryValue = registryValue;
      }
      public Date getUpdateTime() {
      return updateTime;
      }
      public void setUpdateTime(Date updateTime) {
      this.updateTime = updateTime;
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobUser.java deleted 100644 → 0
      View file @ ce8a423b
      package com.xxl.job.admin.core.model;
      import org.springframework.util.StringUtils;
      /**
      * @author xuxueli 2019-05-04 16:43:12
      */
      public class XxlJobUser {
      private int id;
      private String username; // 账号
      private String password; // 密码
      private int role; // 角色：0-普通用户、1-管理员
      private String permission; // 权限：执行器ID列表，多个逗号分割
      public int getId() {
      return id;
      }
      public void setId(int id) {
      this.id = id;
      }
      public String getUsername() {
      return username;
      }
      public void setUsername(String username) {
      this.username = username;
      }
      public String getPassword() {
      return password;
      }
      public void setPassword(String password) {
      this.password = password;
      }
      public int getRole() {
      return role;
      }
      public void setRole(int role) {
      this.role = role;
      }
      public String getPermission() {
      return permission;
      }
      public void setPermission(String permission) {
      this.permission = permission;
      }
      // plugin
      public boolean validPermission(int jobGroup){
      if (this.role == 1) {
      return true;
      } else {
      if (StringUtils.hasText(this.permission)) {
      for (String permissionItem : this.permission.split(",")) {
      if (String.valueOf(jobGroup).equals(permissionItem)) {
      return true;
      }
      }
      }
      return false;
      }
      }
      }
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/old/RemoteHttpJobBean.java deleted 100644 → 0
      View file @ ce8a423b
      //package com.xxl.job.admin.core.jobbean;
      //
      //import com.xxl.job.admin.core.thread.JobTriggerPoolHelper;
      //import com.xxl.job.admin.core.trigger.TriggerTypeEnum;
      //import org.quartz.JobExecutionContext;
      //import org.quartz.JobExecutionException;
      //import org.quartz.JobKey;
      //import org.slf4j.Logger;
      //import org.slf4j.LoggerFactory;
      //import org.springframework.scheduling.quartz.QuartzJobBean;
      //
      ///**
      // * http job bean
      // * “@DisallowConcurrentExecution” disable concurrent, thread size can not be only one, better given more
      // * @author xuxueli 2015-12-17 18:20:34
      // */
      ////@DisallowConcurrentExecution
      //public class RemoteHttpJobBean extends QuartzJobBean {
      // private static Logger logger = LoggerFactory.getLogger(RemoteHttpJobBean.class);
      //
      // @Override
      // protected void executeInternal(JobExecutionContext context)
      // throws JobExecutionException {
      //
      // // load jobId
      // JobKey jobKey = context.getTrigger().getJobKey();
      // Integer jobId = Integer.valueOf(jobKey.getName());
      //
      //
      // }
      //
      //}
      \ No newline at end of file
      xxl-job/xxl-job-admin/src/main/java/com/xxl/job/admin/core/old/XxlJobThreadPool.java deleted 100644 → 0
      View file @ ce8a423b
      //package com.xxl.job.admin.core.quartz;
      //
      //import org.quartz.SchedulerConfigException;
      //import org.quartz.spi.ThreadPool;
      //
      ///**
      // * single thread pool, for async trigger
      // *
      // * @author xuxueli 2019-03-06
      // */
      //public class XxlJobThreadPool implements ThreadPool {
      //
      // @Override
      // public boolean runInThread(Runnable runnable) {
      //
      // // async run
      // runnable.run();
      // return true;
      //
      // //return false;
      // }
      //
      // @Override
      // public int blockForAvailableThreads() {
      // return 1;
      // }
      //
      // @Override
      // public void initialize() throws SchedulerConfigException {
      //
      // }
      //
      // @Override
      // public void shutdown(boolean waitForJobsToComplete) {
      //
      // }
      //
      // @Override
      // public int getPoolSize() {
      // return 1;
      // }
      //
      // @Override
      // public void setInstanceId(String schedInstId) {
      //
      // }
      //
      // @Override
      // public void setInstanceName(String schedName) {
      //
      // }
      //
      // // support
      // public void setThreadCount(int count) {
      // //
      // }
      //
      //}
      xxl-job/xxl-job-admin/src/main/resources/logback.xml deleted 100644 → 0
      View file @ ce8a423b
      This diff is collapsed.
      xxl-job/xxl-job-core/pom.xml deleted 100644 → 0
      View file @ ce8a423b
      This diff is collapsed.
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment