车型

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBiz.java

@@ -1334,4 +1334,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> {
         return list;
     }
 
+    public List<String> findExistVehicleIds() {
+         return mapper.findExistVehicleIds();
+    }
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBookInfoBiz.java

@@ -29,6 +29,7 @@ public class VehicleBookInfoBiz extends BaseBiz<VehicleBookInfoMapper, VehicleBo
     public static final DateTimeFormatter YEARMONTH_DATE_TIME_FORMATTER = DateTimeFormat.forPattern("yyyy-MM");
     public static final Integer DEL_BATCH_SIZE = 1000;
     public static final Integer COPY_BATCH_SIZE = 100;
+    public static final  int  MONTH_INTERVAL=2;
 
     @Autowired
     private RedisTemplate customRedisTemplate;
@@ -127,4 +128,7 @@ public class VehicleBookInfoBiz extends BaseBiz<VehicleBookInfoMapper, VehicleBo
         mapper.createTbIfNotExists(tbName);
     }
 
+    public void InsertBatch(List<VehicleBookInfo> bookInfos) {
+        mapper.insertBatch(bookInfos);
+    }
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/config/XxlJobConfig.java

+package com.xxfc.platform.vehicle.config;
+
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * xxl-job config
+ *
+ * @author xuxueli 2017-04-28
+ */
+@Slf4j
+@Configuration
+public class XxlJobConfig {
+
+    @Value("${xxl.job.admin.addresses}")
+    private String adminAddresses;
+
+    @Value("${xxl.job.executor.appname}")
+    private String appName;
+
+    @Value("${xxl.job.executor.ip}")
+    private String ip;
+
+    @Value("${xxl.job.executor.port}")
+    private int port;
+
+    @Value("${xxl.job.accessToken}")
+    private String accessToken;
+
+    @Value("${xxl.job.executor.logpath}")
+    private String logPath;
+
+    @Value("${xxl.job.executor.logretentiondays}")
+    private int logRetentionDays;
+
+
+    @Bean(initMethod = "start", destroyMethod = "destroy")
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        log.info(">>>>>>>>>>> xxl-job config init.");
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppName(appName);
+        xxlJobSpringExecutor.setIp(ip);
+        xxlJobSpringExecutor.setPort(port);
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogPath(logPath);
+        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+
+        return xxlJobSpringExecutor;
+    }
+
+    /**
+     * 针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP；
+     *
+     *      1、引入依赖：
+     *          <dependency>
+     *             <groupId>org.springframework.cloud</groupId>
+     *             <artifactId>spring-cloud-commons</artifactId>
+     *             <version>${version}</version>
+     *         </dependency>
+     *
+     *      2、配置文件，或者容器启动变量
+     *          spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'
+     *
+     *      3、获取IP
+     *          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
+     */
+
+
+}
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/jobhandler/VehicleJobHandler.java

+package com.xxfc.platform.vehicle.jobhandler;
+
+import com.xxfc.platform.vehicle.biz.VehicleBiz;
+import com.xxfc.platform.vehicle.biz.VehicleBookInfoBiz;
+import com.xxfc.platform.vehicle.entity.VehicleBookInfo;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.IJobHandler;
+import com.xxl.job.core.handler.annotation.JobHandler;
+import com.xxl.job.core.log.XxlJobLogger;
+import lombok.Data;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.collections.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.time.LocalDate;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/8/1 11:28
+ */
+@JobHandler(value = "vehicle_job_handler")
+@Component("vehicle_job_handler")
+public class VehicleJobHandler extends IJobHandler {
+
+       @Autowired
+       private VehicleBiz vehicleBiz;
+
+       @Autowired
+       private VehicleBookInfoBiz  vehicleBookInfoBiz;
+
+    @Override
+    public ReturnT<String> execute(String s) throws Exception {
+        try {
+            List<String> existVehicleIds = vehicleBiz.findExistVehicleIds();
+            LocalDate date = LocalDate.now();
+            int year = date.getYear();
+            int nowMonth = date.getMonthValue();
+            int month = nowMonth + VehicleBookInfoBiz.MONTH_INTERVAL > 12 ? (VehicleBookInfoBiz.MONTH_INTERVAL + nowMonth) - 12 : nowMonth + VehicleBookInfoBiz.MONTH_INTERVAL;
+            year = month > nowMonth ? year : year + 1;
+            String yearAndMonth = String.format("%d-%d", year, month);
+            if (CollectionUtils.isNotEmpty(existVehicleIds)) {
+                List<VehicleBookInfo> bookInfos = existVehicleIds.stream().map(vehicleId -> {
+                    VehicleBookInfo vehicleBookInfo = new VehicleBookInfo();
+                    vehicleBookInfo.setVehicle(vehicleId);
+                    vehicleBookInfo.setYearMonth(yearAndMonth);
+                    return vehicleBookInfo;
+                }).collect(Collectors.toList());
+                vehicleBookInfoBiz.InsertBatch(bookInfos);
+            }
+            ReturnT returnT = new ReturnT();
+            returnT.setCode(100);
+            returnT.setMsg("成功");
+            return returnT;
+        } catch (Exception ex) {
+            XxlJobLogger.log(ex);
+            return FAIL;
+        }
+    }
+}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/VehicleBookInfoMapper.java

 package com.xxfc.platform.vehicle.mapper;
 
 import com.xxfc.platform.vehicle.entity.VehicleBookInfo;
+import org.apache.ibatis.annotations.Param;
 import tk.mybatis.mapper.common.Mapper;
 
 import java.util.List;
@@ -43,4 +44,5 @@ public interface VehicleBookInfoMapper extends Mapper<VehicleBookInfo> {
 
     public Integer del4YearMoth(Map<String, Object> params);
 
+    void insertBatch(@Param("vbfs") List<VehicleBookInfo> bookInfos);
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/VehicleMapper.java

@@ -3,6 +3,7 @@ package com.xxfc.platform.vehicle.mapper;
 import com.xxfc.platform.vehicle.entity.Vehicle;
 import com.xxfc.platform.vehicle.pojo.*;
 import com.xxfc.platform.vehicle.pojo.dto.VehiclePlanDto;
+import org.apache.ibatis.annotations.Select;
 import org.springframework.data.repository.query.Param;
 import tk.mybatis.mapper.common.Mapper;
 
@@ -46,5 +47,6 @@ public interface VehicleMapper extends Mapper<Vehicle> {
     int upMileageByIdAndStatus(@Param("vehicleId") String vehicleId, @Param("status") Integer status,
                                @Param("lastStatus") Integer lastStatus,@Param("mileage") Integer mileage);
 
-
+    @Select("select `id` from `vehicle` where `is_del`=0")
+    List<String> findExistVehicleIds();
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/resources/mapper/VehicleBookInfoMapper.xml

@@ -87,5 +87,10 @@
 
   </insert>
 
-
+<insert id="insertBatch">
+    INSERT IGNORE INTO vehicle_book_info(`vehicle`,`year_month`,`booked_date`)VALUES
+    <foreach collection="vbfs" item="vbf" separator=",">
+        (#{vbf.vehicle} ,#{vbf.yearMonth} ,0)
+    </foreach>
+</insert>
 </mapper>
\ No newline at end of file