定时30s审批通过

src/main/java/com/yingxin/beijingvehicleflow/config/AsyncConfig.java

+package com.yingxin.beijingvehicleflow.config;
+
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.task.AsyncTaskExecutor;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+
+/**
+ * 异步相关定义
+ *
+ * @author zhangzhenbang
+ * @version 1.0
+ * @date 2020/1/8
+ */
+@Configuration
+public class AsyncConfig implements AsyncConfigurer {
+
+    @Value("${async-Config.MAX-POOL-SIZE}")
+    private int maxPoolSize;
+
+    @Value("${async-Config.CORE-POOL-SIZE}")
+    private int corePoolSize;
+
+    @Bean("asyncTaskExecutor")
+    public AsyncTaskExecutor asyncTaskExecutor() {
+        ThreadPoolTaskExecutor asyncTaskExecutor = new ThreadPoolTaskExecutor();
+        asyncTaskExecutor.setMaxPoolSize(maxPoolSize);
+        asyncTaskExecutor.setCorePoolSize(corePoolSize);
+        asyncTaskExecutor.setThreadNamePrefix("async-task-thread-pool-");
+        asyncTaskExecutor.initialize();
+        return asyncTaskExecutor;
+    }
+}

src/main/java/com/yingxin/beijingvehicleflow/controller/FloatingPopulationController.java

@@ -19,7 +19,7 @@ import java.util.Date;
  */
 @RestController
 @CrossOrigin
-@RequestMapping("/api/v1")
+@RequestMapping("/bjapi/v1")
 public class FloatingPopulationController {
 
     @Autowired

src/main/java/com/yingxin/beijingvehicleflow/controller/IdentityInfoController.java

@@ -33,7 +33,7 @@ import java.util.List;
  */
 @RestController
 @CrossOrigin
-@RequestMapping("/api/v1")
+@RequestMapping("/bjapi/v1")
 public class IdentityInfoController {
 
     private static Logger LOGGER = LoggerFactory.getLogger(IdentityInfoController.class);

src/main/java/com/yingxin/beijingvehicleflow/controller/ReservationController.java

@@ -21,7 +21,7 @@ import java.util.List;
  */
 @RestController
 @CrossOrigin
-@RequestMapping("/api/v1")
+@RequestMapping("/bjapi/v1")
 public class ReservationController {
 
     private static Logger LOGGER = LoggerFactory.getLogger(ReservationController.class);

src/main/java/com/yingxin/beijingvehicleflow/mapper/ReservationMapper.java

@@ -42,4 +42,8 @@ public interface ReservationMapper {
 
     @Select("select * from reservation where verify_state=0 and identity_id=#{id}")
     List<Reservation> selectNotVerifyReservatinsByIdentityId(IdentityInformation info);
+
+    @Update("update reservation set verify_state=1")
+    int updateAllVerifyState();
 }
+

src/main/java/com/yingxin/beijingvehicleflow/service/ReservationService.java

@@ -23,4 +23,6 @@ public interface ReservationService {
     boolean isUpdateAuthInfoSucc(Reservation reservation);
 
     List<Reservation> selectNotVerifyReservatinsByIdentityId(IdentityInformation info);
+
+    int updateAllVerifyState();
 }

src/main/java/com/yingxin/beijingvehicleflow/service/ScheduleTask.java

+package com.yingxin.beijingvehicleflow.service;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+
+/**
+ * 月初更新信息修改次数
+ *
+ * @author 226
+ * @version 1.0
+ * @date 2020/2/19
+ */
+@Component
+@EnableScheduling
+@EnableAsync
+public class ScheduleTask {
+
+    private static Logger LOGGER = LoggerFactory.getLogger(ScheduleTask.class);
+
+
+    @Autowired
+    private ReservationService reservationService;
+
+    /**
+     *  定时任务
+     *
+     *  表达式有六位，秒、分、时、日、月、星期
+     *  下面表示每个月的一号执行定时任务
+     *
+     * @date 2020/2/19
+     */
+    @Async("asyncTaskExecutor")
+    @Scheduled(cron = "*/30 * * * * ?")
+    public void tasks() {
+        try {
+            reservationService.updateAllVerifyState();
+        } catch (Exception e) {
+            LOGGER.error("异步认证次数发放异常：", e);
+        }
+    }
+
+}
\ No newline at end of file

src/main/java/com/yingxin/beijingvehicleflow/service/impl/ReservationServiceImpl.java

@@ -83,4 +83,9 @@ public class ReservationServiceImpl implements ReservationService {
     public List<Reservation> selectNotVerifyReservatinsByIdentityId(IdentityInformation info) {
         return reservationMapper.selectNotVerifyReservatinsByIdentityId(info);
     }
+
+    @Override
+    public int updateAllVerifyState() {
+        return reservationMapper.updateAllVerifyState();
+    }
 }