feats

bin/start.sh

@@ -1,5 +1,6 @@
 #! /bin/sh
 #
+# 本文件放置到任务进程的根目录下
 #
 
 # 项目名称
@@ -8,7 +9,7 @@ APPLICATION="niucai-task"
 # 项目启动jar包名称
 PROCESS_SIGN="java -jar .*${APPLICATION}.*.jar"
 
-PID=$(ps -ef | grep ${PROCESS_SIGN} | grep -v grep | awk '{ print $2 }')
+PID=$(ps -ef | grep "${PROCESS_SIGN}"| grep -v grep | awk '{ print $2 }')
 
 if [[ -n $PID ]]; then
     echo "Origin pid: $PID"
@@ -17,13 +18,13 @@ if [[ -n $PID ]]; then
     echo
 fi
 
-BASE_PATH=$(cd `dirname $0`; cd ..; pwd)
+BASE_PATH=$(cd `dirname $0`; pwd)
 APPLICATION_FILE="${BASE_PATH}/$1"
 echo "Ready to start ${APPLICATION_FILE}"
 
 nohup java -jar $APPLICATION_FILE >> server.log 2>&1 &
 
-newPID=$(ps -ef|grep ${PROCESS_SIGN}|grep -v grep|awk '{ print $2 }')
+newPID=$(ps -ef|grep "${PROCESS_SIGN}"|grep -v grep|awk '{ print $2 }')
 
 if [[ -z $newPID ]]; then
     echo "${APPLICATION} start fail"

bin/stop.sh

@@ -1,19 +0,0 @@
-#! /bin/sh
-#
-#
-
-# 项目名称
-APPLICATION="niucai-task"
-
-# 项目启动jar包名称
-PROCESS_SIGN="java -jar .*${APPLICATION}.*.jar"
-
-PID=$(ps -ef | grep ${PROCESS_SIGN} | grep -v grep | awk '{ print $2 }')
-if [ -z "$PID" ]
-then
-    echo ${APPLICATION} is already stopped
-else
-    echo kill  ${PID}
-    kill -9 ${PID}
-    echo ${APPLICATION} stopped successfully
-fi

pom.xml

@@ -9,8 +9,8 @@
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.xiaoniu.niucai</groupId>
-	<artifactId>task</artifactId>
-	<version>0.0.1</version>
+	<artifactId>niucai-task</artifactId>
+	<version>1.0.0</version>
 	<name>niucai-task</name>
 	<description>Task of niucai</description>
 

src/main/java/com/xiaoniu/niucai/config/JobCronConfig.java

@@ -9,12 +9,4 @@ import org.springframework.stereotype.Component;
 @ConfigurationProperties(prefix = "job-cron")
 public class JobCronConfig {
     private Integer poolSize;
-    private String crawlFootball;
-    private String crawlBasketball;
-    private String crawlLottery;
-    private String cleanCrawlSpam;
-    private String orderExpire;
-    private String sportPrize;
-    private String lotteryPrize;
-    private String matchException;
 }

src/main/java/com/xiaoniu/niucai/config/ScheduledConfig.java

@@ -1,41 +1,28 @@
 package com.xiaoniu.niucai.config;
 
-import com.xiaoniu.niucai.task.*;
+import com.xiaoniu.niucai.entity.SysCrontab;
+import com.xiaoniu.niucai.service.ISysCrontabService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.SchedulingConfigurer;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.scheduling.config.ScheduledTaskRegistrar;
 
+import java.util.List;
+
+@Slf4j
 @Configuration
 public class ScheduledConfig implements SchedulingConfigurer {
-
-    @Autowired
-    JobCronConfig jobCronConfig;
-
-    @Autowired
-    CrawlFootball crawlFootball;
-
-    @Autowired
-    CrawlBasketball crawlBasketball;
-
-    @Autowired
-    CrawlLottery crawlLottery;
-
-    @Autowired
-    CleanCrawlSpam cleanCrawlSpam;
-
-    @Autowired
-    OrderExpire orderExpire;
-
     @Autowired
-    SportPrize sportPrize;
+    private ApplicationContext context;
 
     @Autowired
-    LotteryPrize lotteryPrize;
+    JobCronConfig jobCronConfig;
 
     @Autowired
-    MatchException matchException;
+    ISysCrontabService iSysCrontabService;
 
     @Override
     public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
@@ -45,13 +32,17 @@ public class ScheduledConfig implements SchedulingConfigurer {
         taskScheduler.initialize();
         scheduledTaskRegistrar.setTaskScheduler(taskScheduler);
 
-        scheduledTaskRegistrar.addCronTask(crawlFootball, jobCronConfig.getCrawlFootball());
-        scheduledTaskRegistrar.addCronTask(crawlBasketball, jobCronConfig.getCrawlBasketball());
-        scheduledTaskRegistrar.addCronTask(crawlLottery, jobCronConfig.getCrawlLottery());
-        scheduledTaskRegistrar.addCronTask(cleanCrawlSpam, jobCronConfig.getCleanCrawlSpam());
-        scheduledTaskRegistrar.addCronTask(orderExpire, jobCronConfig.getOrderExpire());
-        scheduledTaskRegistrar.addCronTask(sportPrize, jobCronConfig.getSportPrize());
-        scheduledTaskRegistrar.addCronTask(lotteryPrize, jobCronConfig.getLotteryPrize());
-        scheduledTaskRegistrar.addCronTask(matchException, jobCronConfig.getMatchException());
+        List<SysCrontab> jobList = iSysCrontabService.list();
+        for (SysCrontab job : jobList) {
+            try {
+                Runnable task = (Runnable) context.getBean(Class.forName(job.getClassName()));
+                scheduledTaskRegistrar.addCronTask(task, job.getCronSetting().trim());
+
+                log.info("任务【{}】: 启动成功", job.getTitle());
+            } catch (ClassNotFoundException e) {
+                log.error("{} 任务类不存在", job.getClassName());
+                e.printStackTrace();
+            }
+        }
     }
 }

src/main/java/com/xiaoniu/niucai/entity/SysCrontab.java

@@ -0,0 +1,40 @@
+package com.xiaoniu.niucai.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 投注方案
+ * </p>
+ *
+ * @author admin
+ * @since 2020-09-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class SysCrontab implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "serial_no", type = IdType.AUTO)
+    private Integer serialNo;
+
+    private String title;
+
+    private String className;
+
+    private String cronSetting;
+
+    private LocalDateTime createDate;
+
+}

src/main/java/com/xiaoniu/niucai/mapper/SysCrontabMapper.java

@@ -0,0 +1,18 @@
+package com.xiaoniu.niucai.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xiaoniu.niucai.entity.SysCrontab;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 方案条目 Mapper 接口
+ * </p>
+ *
+ * @author admin
+ * @since 2020-09-08
+ */
+@Mapper
+public interface SysCrontabMapper extends BaseMapper<SysCrontab> {
+
+}

src/main/java/com/xiaoniu/niucai/service/ISysCrontabService.java

@@ -0,0 +1,16 @@
+package com.xiaoniu.niucai.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xiaoniu.niucai.entity.SysCrontab;
+
+/**
+ * <p>
+ * 方案条目 服务类
+ * </p>
+ *
+ * @author admin
+ * @since 2020-09-08
+ */
+public interface ISysCrontabService extends IService<SysCrontab> {
+
+}

src/main/java/com/xiaoniu/niucai/service/impl/SysCrontabServiceImpl.java

@@ -0,0 +1,20 @@
+package com.xiaoniu.niucai.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xiaoniu.niucai.entity.SysCrontab;
+import com.xiaoniu.niucai.mapper.SysCrontabMapper;
+import com.xiaoniu.niucai.service.ISysCrontabService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 方案条目 服务实现类
+ * </p>
+ *
+ * @author admin
+ * @since 2020-09-08
+ */
+@Service
+public class SysCrontabServiceImpl extends ServiceImpl<SysCrontabMapper, SysCrontab> implements ISysCrontabService {
+
+}

src/main/java/com/xiaoniu/niucai/task/CloseMatch.java

@@ -0,0 +1,22 @@
+package com.xiaoniu.niucai.task;
+
+import com.xiaoniu.niucai.service.ITaMatchService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class CloseMatch implements Runnable {
+
+    @Autowired
+    ITaMatchService iTaMatchService;
+
+    @Override
+    public void run() {
+        log.info("开始处理体彩关闭场次");
+
+        // 体彩中奖
+        iTaMatchService.callProcedure("pro_close_match");
+    }
+}

src/main/java/com/xiaoniu/niucai/task/OpenMatch.java

@@ -0,0 +1,22 @@
+package com.xiaoniu.niucai.task;
+
+import com.xiaoniu.niucai.service.ITaMatchService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class OpenMatch implements Runnable {
+
+    @Autowired
+    ITaMatchService iTaMatchService;
+
+    @Override
+    public void run() {
+        log.info("开始处理体彩开赛场次");
+
+        // 体彩中奖
+        iTaMatchService.callProcedure("pro_open_match");
+    }
+}

src/main/resources/application.yml

@@ -18,20 +18,3 @@ logging:
 job-cron:
   # 线程池
   pool-size: 10
-
-  # 解析足球爬虫结果
-  crawl-football: 0 0/10 * * * ?
-  # 解析篮球爬虫结果
-  crawl-basketball: 0 0/10 * * * ?
-  # 解析竞彩爬虫结果
-  crawl-lottery: 0 0 0/2 * * ?
-  # 爬虫垃圾数据
-  clean-crawl-spam: 0 0 0/4 * * ?
-  # 处理超时订单
-  order-expire: 0 0/15 * * * ?
-  # 体彩中奖
-  sport-prize: 0 0/3 * * * ?
-  # 数字彩中奖
-  lottery-prize: 0 0/3 * * * ?
-  # 异常比赛
-  match-exception: 0 0/5 * * * ?