注释补全

in-cloud/src/main/java/com/jiayue/insu/incloud/compermisson/QNHLComPermisson.java

@@ -84,10 +84,6 @@ public class QNHLComPermisson implements GeneratePermisson{
                             log.info("========== 一体化token请求成功: {} token="+token+"  ==========",station.getStationCode());
                             station.setComKey(token);
                             station.setKeyTime(LocalDateTime.now().plusDays(1));
-                  /*          LambdaUpdateWrapper<Station> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
-                            lambdaUpdateWrapper.eq(Station::getId, station.getId())
-                                    .set(Station::getComKey, token)
-                                    .set(Station::getKeyTime,LocalDateTime.now().plusDays(1));*/
                             stationService.updateById(station);
                             record.setState(QNHLEnum.REQUEST_SUCCESS.getSign());
                             result = true;

in-cloud/src/main/java/com/jiayue/insu/incloud/config/MyBatisPlusConfig.java

@@ -4,10 +4,20 @@ import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
 import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-
+/**
+ * mybatis-plus 配置类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Configuration
 public class MyBatisPlusConfig {
 
+    /**
+     * 分页插件
+     * @return
+     */
     @Bean
     public MybatisPlusInterceptor mybatisPlusInterceptor() {
         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();

in-cloud/src/main/java/com/jiayue/insu/incloud/config/MyMetaObjectHandler.java

@@ -8,7 +8,13 @@ import org.apache.ibatis.reflection.MetaObject;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
-
+/**
+ * mybatis-plus 字段自动填充
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Slf4j
 @Component
 public class MyMetaObjectHandler implements MetaObjectHandler {

in-cloud/src/main/java/com/jiayue/insu/incloud/config/RedisConfig.java

@@ -10,7 +10,13 @@ import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
-
+/**
+ * redis 配置类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Configuration
 public class RedisConfig {
     @Bean

in-cloud/src/main/java/com/jiayue/insu/incloud/config/SaTokenConfigure.java

@@ -6,7 +6,13 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.EnableWebMvc;
 import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
-
+/**
+ * sa-token 配置类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Configuration
 @EnableWebMvc
 public class SaTokenConfigure implements WebMvcConfigurer {

in-cloud/src/main/java/com/jiayue/insu/incloud/config/VelocityConfig.java

@@ -8,10 +8,11 @@ import org.springframework.context.annotation.Configuration;
 import java.util.Properties;
 
 /**
- * @description:
- * @author: yuanhao
- * @createDate: 2021/9/29
- * @version: 1.0
+ * 模板  配置类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
  */
 @Configuration
 public class VelocityConfig {

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/CommonStant.java

@@ -1,5 +1,12 @@
 package com.jiayue.insu.incloud.constants;
 
+/**
+ * 通用常量
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface CommonStant {
 
     /**

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/CompanyConstant.java

@@ -1,5 +1,12 @@
 package com.jiayue.insu.incloud.constants;
 
+/**
+ * 公司常量
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface CompanyConstant {
 
     /**

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/enums/QNHLEnum.java

@@ -1,5 +1,11 @@
 package com.jiayue.insu.incloud.constants.enums;
-
+/**
+ * 清能互联 ENUM
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public enum QNHLEnum {
 
     REQUEST_SUCCESS("T200","success","请求成功"),

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/enums/StatusEnum.java

@@ -1,5 +1,11 @@
 package com.jiayue.insu.incloud.constants.enums;
-
+/**
+ * 通用状态  StatusEnum
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 
 public enum StatusEnum {
     SUCCESS("success","success","成功"),

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/vo/FileCreateLog.java

@@ -2,11 +2,13 @@ package com.jiayue.insu.incloud.constants.vo;
 
 import lombok.Data;
 
+
 /**
  * 文件生成列表
  *
- * @author bizy
- * @version 3.0
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
  */
 @Data
 public class FileCreateLog {

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/vo/RequestVo.java

@@ -5,11 +5,14 @@ import lombok.Data;
 import lombok.NoArgsConstructor;
 import lombok.experimental.SuperBuilder;
 
+
+
 /**
- * @description: 一体化请求VO
- * @author: yuanhao
- * @createDate: 2021/8/24
- * @version: 1.0
+ * 一体化请求VO
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
  */
 @Data
 @SuperBuilder

in-cloud/src/main/java/com/jiayue/insu/incloud/constants/vo/ResponseVo.java

@@ -5,11 +5,13 @@ import lombok.Data;
 import lombok.NoArgsConstructor;
 import lombok.experimental.SuperBuilder;
 
+
 /**
- * @description: 清能一体化响应VO
- * @author: yuanhao
- * @createDate: 2021/8/24
- * @version: 1.0
+ * 一体化响应VO
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
  */
 @Data
 @SuperBuilder

in-cloud/src/main/java/com/jiayue/insu/incloud/controller/TestController.java

@@ -1,95 +0,0 @@
-package com.jiayue.insu.incloud.controller;
-
-import cn.hutool.core.date.DateUtil;
-import com.jiayue.insu.common.core.util.R;
-import com.jiayue.insu.incloud.compermisson.QNHLComPermisson;
-import com.jiayue.insu.incloud.entity.Quartz;
-import com.jiayue.insu.incloud.entity.Station;
-import com.jiayue.insu.incloud.pulldata.PullCorrectDataForQNHL;
-import com.jiayue.insu.incloud.pulldata.PullInitData;
-import com.jiayue.insu.incloud.pushdata.PushDataForQNHL;
-import com.jiayue.insu.incloud.quartz.ScheduledTask;
-import com.jiayue.insu.incloud.service.StationService;
-import org.quartz.SchedulerException;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.text.ParseException;
-
-@RestController
-@RequestMapping("/test")
-public class TestController {
-   @GetMapping
-    public R test(){
-       return R.ok("ok");
-   }
-
-    @Autowired
-    ScheduledTask scheduledTask;
-    @Autowired
-    PullInitData pullInitData;
-
-    @Autowired
-    PushDataForQNHL pushDataForQNHL;
-    @Autowired
-    StationService stationService;
-    @Autowired
-    PullCorrectDataForQNHL pullCorrectDataForQNHL;
-
-    @GetMapping("/job")
-    public R testJob() throws ClassNotFoundException, SchedulerException, ParseException {
-        scheduledTask.deleteJob("testJob2");
-        Quartz quartz = new Quartz();
-        quartz.setExecuteClass("com.jiayue.insu.incloud.job.data.pull.ZGHpullDataJob");
-        quartz.setCronExpression("0 37 9 * * ?");
-        quartz.setJobName("testJob2");
-        quartz.setStartTime(DateUtil.current());
-        Class c = Class.forName(quartz.getExecuteClass());
-        scheduledTask.scheduleJob(c,quartz.getJobName(),quartz.getStartTime(),quartz.getCronExpression(),null);
-        return R.ok();
-    }
-
-
-
-    @GetMapping("/job1")
-    public R testJob1() throws ClassNotFoundException, SchedulerException, ParseException {
-        Station station = new Station();
-        station.setStationCode("J00219");
-        station.setInCode("QNHL");
-        pullInitData.pullDQAndNWPData(station);
-        return R.ok();
-    }
-
-
-
-    @GetMapping("/init")
-    public R testInit() {
-        Station j00243 = stationService.findByStationCode("J00243");
-        pullInitData.pullDQAndNWPData(j00243);
-        return R.ok();
-    }
-
-    @GetMapping("/push")
-    public R testPush()  {
-        Station j00243 = stationService.findByStationCode("J00243");
-        pushDataForQNHL.pushDQAndNWPData(j00243);
-        return R.ok();
-    }
-
-    @GetMapping("/pull")
-    public R testPull(){
-        Station j00243 = stationService.findByStationCode("J00243");
-        pullCorrectDataForQNHL.pullDQAndNWPData(j00243);
-        return R.ok();
-    }
-    @Autowired
-    QNHLComPermisson qnhlComPermisson;
-    @GetMapping("/token")
-    public R testToken(){
-        Station j00243 = stationService.findByStationCode("J00243");
-        qnhlComPermisson.generateKey(j00243);
-        return R.ok();
-    }
-}

in-cloud/src/main/java/com/jiayue/insu/incloud/entity/BaseEntity.java

@@ -5,7 +5,13 @@ import com.baomidou.mybatisplus.annotation.TableField;
 import lombok.Data;
 
 import java.time.LocalDateTime;
-
+/**
+ * 实体类基类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2020/7/8 10:56
+ */
 @Data
 public class BaseEntity {
 

in-cloud/src/main/java/com/jiayue/insu/incloud/entity/ForecastData.java

@@ -14,12 +14,13 @@ import java.time.LocalDateTime;
 
 
 /**
- * 短期
+ * 预测数据实体
  *
  * @author yh
  * @version 1.0
  * @since 2020/7/8 10:56
  */
+
 @TableName(value = "in_forecast_data")
 @Data
 public class ForecastData {

in-cloud/src/main/java/com/jiayue/insu/incloud/entity/IntegrationCompany.java

@@ -6,11 +6,11 @@ import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.Data;
 
 /**
- * IntegrationCompany一体化公司
+ * 一体化公司实体类
  *
  * @author yh
  * @version 1.0
- * @since 2022/5/25 16:22
+ * @since 2020/7/8 10:56
  */
 @TableName(value = "in_company")
 @Data

in-cloud/src/main/java/com/jiayue/insu/incloud/entity/QuartzBase.java

@@ -9,7 +9,7 @@ import lombok.Data;
 import java.util.Date;
 
 /**
- * Quartz 定时任务基础信息
+ * Quartz 定时任务初始化信息
  *
  * @author yh
  * @version 1.0

in-cloud/src/main/java/com/jiayue/insu/incloud/entity/Record.java

@@ -8,7 +8,7 @@ import org.springframework.format.annotation.DateTimeFormat;
 import java.time.LocalDateTime;
 
 /**
- * PushRecord 上送数据记录
+ * Record 数据记录
  *
  * @author yh
  * @version 1.0

in-cloud/src/main/java/com/jiayue/insu/incloud/exception/GlobalException.java

@@ -16,7 +16,7 @@ import cn.dev33.satoken.exception.NotPermissionException;
 import cn.dev33.satoken.exception.NotRoleException;
 
 /**
- * 全局异常处理
+ * sa-token全局异常处理
  */
 @ControllerAdvice
 public class GlobalException {

in-cloud/src/main/java/com/jiayue/insu/incloud/job/data/pull/PullInitDataJob.java

@@ -9,13 +9,20 @@ import com.jiayue.insu.incloud.pulldata.PullInitData;
 import com.jiayue.insu.incloud.service.RecordService;
 import com.jiayue.insu.incloud.service.StationService;
 import org.quartz.Job;
-import org.quartz.JobDataMap;
 import org.quartz.JobExecutionContext;
 import org.quartz.JobExecutionException;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.time.LocalDateTime;
 
+
+/**
+ * 清能互联 拉取原始预测数据
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public class PullInitDataJob implements Job {
 
     @Autowired

in-cloud/src/main/java/com/jiayue/insu/incloud/job/data/pull/QNHLPullCorrectDataJob.java

@@ -16,7 +16,13 @@ import org.quartz.JobExecutionException;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.time.LocalDateTime;
-
+/**
+ * 清能互联 拉取修正数据定时任务
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public class QNHLPullCorrectDataJob implements Job {
 
     @Autowired

in-cloud/src/main/java/com/jiayue/insu/incloud/permisson/Login.java

@@ -7,6 +7,13 @@ import com.jiayue.insu.incloud.service.UserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+/**
+ * 系统权限业务类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/6/1 10:56
+ */
 @RestController
 @RequestMapping("/login")
 public class Login {

in-cloud/src/main/java/com/jiayue/insu/incloud/pulldata/PullCorrectDataForQNHL.java

@@ -47,7 +47,13 @@ import java.util.*;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
-
+/**
+ * 清能互联 拉取修正数据业务
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Component
 @Slf4j
 public class PullCorrectDataForQNHL implements IPullInitCorrectData{
@@ -81,6 +87,11 @@ public class PullCorrectDataForQNHL implements IPullInitCorrectData{
     @Value("${minio.pwd}")
     private String minloPwd;
 
+    /**
+     * 拉取修正预测数据并生成文件上送minio服务器
+     * @param station 场站信息
+     * @return 是否成功
+     */
     @Override
     public Boolean pullDQAndNWPData(Station station) {
 

in-cloud/src/main/java/com/jiayue/insu/incloud/pulldata/PullInitData.java

@@ -32,7 +32,13 @@ import java.util.Comparator;
 import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
-
+/**
+ * 拉取原始预测数据业务
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Component
 @Slf4j
 public class PullInitData implements IPullInitForecastData{
@@ -47,6 +53,12 @@ public class PullInitData implements IPullInitForecastData{
     String fileurl;
     @Value("${minio.pull.fileDir}")
     String fileDir;
+
+    /**
+     * 拉取原始预测数据
+     * @param station 场站信息
+     * @return 是否成功
+     */
     @Override
     public Boolean pullDQAndNWPData(Station station) {
         boolean result = false;

in-cloud/src/main/java/com/jiayue/insu/incloud/pushdata/PushDataForQNHL.java

@@ -52,10 +52,15 @@ public class PushDataForQNHL implements IPushInitForecastData {
     private IntegrationCompanyService integrationCompanyService;
     @Autowired
     private QNHLComPermisson qNHLComPermisson;
-
     @Autowired
     private RecordService recordService;
 
+    /**
+     * 推送原始预测数据
+     * @param station 场站信息
+     * @return 是否成功
+     */
+    @Override
     public Boolean pushDQAndNWPData(Station station) {
 
         Record record = new Record();

in-cloud/src/main/java/com/jiayue/insu/incloud/quartz/ScheduledTask.java

@@ -11,7 +11,13 @@ import org.springframework.stereotype.Component;
 import java.text.ParseException;
 import java.util.Date;
 import java.util.Map;
-
+/**
+ * 定时任务业务类
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Component
 public class ScheduledTask {
 

in-cloud/src/main/java/com/jiayue/insu/incloud/service/ForecastDataService.java

@@ -5,10 +5,28 @@ import com.jiayue.insu.incloud.entity.ForecastData;
 import com.jiayue.insu.incloud.entity.IntegrationCompany;
 
 import java.util.List;
-
+/**
+ * 预测数据业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface ForecastDataService extends IService<ForecastData> {
-
+    /**
+     * 删除数据 通过场站编码和时间
+     * @param station 场站编码
+     * @param startTime 开始时间
+     * @param endTime 结束时间
+     * @return 结果
+     */
     boolean removeBetweenTimeByStation(String station,Long startTime,Long endTime);
-
+    /**
+     * 查询数据 通过场站编码和时间
+     * @param station 场站编码
+     * @param startTime 开始时间
+     * @param endTime 结束时间
+     * @return 结果
+     */
     List<ForecastData>  findTimeByStation(String station,Long startTime,Long endTime);
 }

in-cloud/src/main/java/com/jiayue/insu/incloud/service/IntegrationCompanyService.java

@@ -3,9 +3,20 @@ package com.jiayue.insu.incloud.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.jiayue.insu.incloud.entity.IntegrationCompany;
 import com.jiayue.insu.incloud.entity.Station;
-
+/**
+ * 预测数据业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface IntegrationCompanyService extends IService<IntegrationCompany> {
 
+    /**
+     *  通过code查询公司
+     * @param code
+     * @return 结果
+     */
     IntegrationCompany findByCode(String code);
 
 }

in-cloud/src/main/java/com/jiayue/insu/incloud/service/QuartzBaseService.java

@@ -5,17 +5,44 @@ import com.jiayue.insu.incloud.entity.QuartzBase;
 
 import java.util.List;
 
+/**
+ * 定时任务初始业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface QuartzBaseService extends IService<QuartzBase> {
 
-
+    /**
+     * 通过执行类查询
+     * @param executeClass 执行类路径
+     * @return 结果
+     */
     QuartzBase findByExecuteClass(String executeClass);
-
+    /**
+     * 通过定时任务编码查询
+     * @param code 定时任务编码
+     * @return 结果
+     */
     QuartzBase findByCode(String code);
-
+    /**
+     * 通过公司编码查询
+     * @param inCode 公司编码
+     * @return 结果
+     */
     List<QuartzBase> findByIncode(String inCode);
 
-
+    /**
+     * 通过类型查询
+     * @param type 类型
+     * @return 结果
+     */
     List<QuartzBase> findByType(String type);
-
+    /**
+     * 返回场站下可选择定时任务 （所属公司私有类型定时任务和公共类型定时任务）
+     * @param inCode 公司编码
+     * @return 结果
+     */
     List<QuartzBase> getChooseQuartz(String inCode);
 }

in-cloud/src/main/java/com/jiayue/insu/incloud/service/QuartzService.java

@@ -5,7 +5,13 @@ import com.jiayue.insu.incloud.entity.Quartz;
 import org.quartz.SchedulerException;
 
 import java.text.ParseException;
-
+/**
+ * 定时任务业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface QuartzService extends IService<Quartz> {
 
     Quartz findByJobName(String jobName);

in-cloud/src/main/java/com/jiayue/insu/incloud/service/RecordService.java

@@ -4,9 +4,23 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.jiayue.insu.incloud.entity.Record;
 
 import java.time.LocalDateTime;
-
+/**
+ * 数据记录业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface RecordService extends IService<Record> {
 
+    /**
+     *  查询记录
+     * @param time 时间
+     * @param type 日志类型
+     * @param state 状态
+     * @param station 场站编码
+     * @return
+     */
     Record findTimeAndTypeAndStateAndStation(LocalDateTime time,String type,String state,String station);
 
 

in-cloud/src/main/java/com/jiayue/insu/incloud/service/StationService.java

@@ -2,7 +2,13 @@ package com.jiayue.insu.incloud.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.jiayue.insu.incloud.entity.Station;
-
+/**
+ * 场站信息业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface StationService extends IService<Station> {
 
     Station findByStationCode(String stationCode);

in-cloud/src/main/java/com/jiayue/insu/incloud/service/UserService.java

@@ -2,7 +2,13 @@ package com.jiayue.insu.incloud.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.jiayue.insu.incloud.entity.User;
-
+/**
+ * 用户登录业务接口
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 public interface UserService extends IService<User> {
 
     User findByNameAndPwd(String name,String pwd);

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/ForecastDataServiceImpl.java

@@ -9,10 +9,23 @@ import org.springframework.stereotype.Service;
 
 import java.util.List;
 
+/**
+ * 预测数据业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class ForecastDataServiceImpl extends ServiceImpl<ForecastDataMapper, ForecastData> implements ForecastDataService {
 
-
+    /**
+     * 删除数据 通过场站编码和时间
+     * @param station 场站编码
+     * @param startTime 开始时间
+     * @param endTime 结束时间
+     * @return 结果
+     */
     @Override
     public boolean removeBetweenTimeByStation(String station, Long startTime, Long endTime) {
         LambdaQueryWrapper<ForecastData> lambdaQueryWrapper = new LambdaQueryWrapper<>();
@@ -22,6 +35,13 @@ public class ForecastDataServiceImpl extends ServiceImpl<ForecastDataMapper, For
         return Boolean.TRUE;
     }
 
+    /**
+     * 查询数据 通过场站编码和时间
+     * @param station 场站编码
+     * @param startTime 开始时间
+     * @param endTime 结束时间
+     * @return 结果
+     */
     @Override
     public List<ForecastData> findTimeByStation(String station, Long startTime, Long endTime) {
         LambdaQueryWrapper<ForecastData> lambdaQueryWrapper = new LambdaQueryWrapper<>();

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/IntegrationCompanyServiceImpl.java

@@ -6,11 +6,21 @@ import com.jiayue.insu.incloud.entity.IntegrationCompany;
 import com.jiayue.insu.incloud.mapper.IntegrationCompanyMapper;
 import com.jiayue.insu.incloud.service.IntegrationCompanyService;
 import org.springframework.stereotype.Service;
-
+/**
+ * 预测数据业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class IntegrationCompanyServiceImpl extends ServiceImpl<IntegrationCompanyMapper, IntegrationCompany> implements IntegrationCompanyService {
 
-
+    /**
+     *  通过code查询公司
+     * @param code
+     * @return 结果
+     */
     @Override
     public IntegrationCompany findByCode(String code) {
         LambdaQueryWrapper<IntegrationCompany> lambdaQueryWrapper = new LambdaQueryWrapper<>();

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/QuartzBaseServiceImpl.java

@@ -12,10 +12,22 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.List;
-
+/**
+ * 定时任务初始业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class QuartzBaseServiceImpl extends ServiceImpl<QuartzBaseMapper, QuartzBase> implements QuartzBaseService {
 
+
+    /**
+     * 通过执行类查询
+     * @param executeClass 执行类路径
+     * @return 结果
+     */
     @Override
     public QuartzBase findByExecuteClass(String executeClass) {
         LambdaQueryWrapper<QuartzBase> lambdaQueryWrapper = new LambdaQueryWrapper<>();
@@ -23,6 +35,12 @@ public class QuartzBaseServiceImpl extends ServiceImpl<QuartzBaseMapper, QuartzB
         return this.getOne(lambdaQueryWrapper);
     }
 
+
+    /**
+     * 通过定时任务编码查询
+     * @param code 定时任务编码
+     * @return 结果
+     */
     @Override
     public QuartzBase findByCode(String code) {
         LambdaQueryWrapper<QuartzBase> lambdaQueryWrapper = new LambdaQueryWrapper<>();
@@ -30,6 +48,11 @@ public class QuartzBaseServiceImpl extends ServiceImpl<QuartzBaseMapper, QuartzB
         return this.getOne(lambdaQueryWrapper);
     }
 
+    /**
+     * 通过公司编码查询
+     * @param inCode 公司编码
+     * @return 结果
+     */
     @Override
     public List<QuartzBase> findByIncode(String inCode) {
         LambdaQueryWrapper<QuartzBase> lambdaQueryWrapper = new LambdaQueryWrapper<>();
@@ -37,6 +60,11 @@ public class QuartzBaseServiceImpl extends ServiceImpl<QuartzBaseMapper, QuartzB
         return this.list(lambdaQueryWrapper);
     }
 
+    /**
+     * 通过类型查询
+     * @param type 类型
+     * @return 结果
+     */
     @Override
     public List<QuartzBase> findByType(String type) {
         LambdaQueryWrapper<QuartzBase> lambdaQueryWrapper = new LambdaQueryWrapper<>();
@@ -45,6 +73,11 @@ public class QuartzBaseServiceImpl extends ServiceImpl<QuartzBaseMapper, QuartzB
 
     }
 
+    /**
+     * 返回场站下可选择定时任务 （所属公司私有类型定时任务和公共类型定时任务）
+     * @param inCode 公司编码
+     * @return 结果
+     */
     @Override
     public List<QuartzBase> getChooseQuartz(String inCode){
         List<QuartzBase> result = new ArrayList<>();

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/QuartzServiceImpl.java

@@ -11,7 +11,13 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.text.ParseException;
-
+/**
+ * 定时任务业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class QuartzServiceImpl extends ServiceImpl<QuartzMapper, Quartz> implements QuartzService {
 

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/RecordServiceImpl.java

@@ -11,11 +11,24 @@ import com.jiayue.insu.incloud.service.RecordService;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
-
+/**
+ * 数据记录业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class RecordServiceImpl extends ServiceImpl<RecordMapper, Record> implements RecordService {
 
-
+    /**
+     *  查询记录
+     * @param time 时间
+     * @param type 日志类型
+     * @param state 状态
+     * @param station 场站编码
+     * @return
+     */
     @Override
     public Record findTimeAndTypeAndStateAndStation(LocalDateTime time, String type, String state,String station) {
         LambdaQueryWrapper<Record> lambdaQueryWrapper = new LambdaQueryWrapper<>();

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/StationServiceImpl.java

@@ -6,7 +6,13 @@ import com.jiayue.insu.incloud.entity.Station;
 import com.jiayue.insu.incloud.mapper.StationMapper;
 import com.jiayue.insu.incloud.service.StationService;
 import org.springframework.stereotype.Service;
-
+/**
+ * 场站信息业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class StationServiceImpl extends ServiceImpl<StationMapper, Station> implements StationService {
 

in-cloud/src/main/java/com/jiayue/insu/incloud/service/impl/UserServiceImpl.java

@@ -6,7 +6,13 @@ import com.jiayue.insu.incloud.entity.User;
 import com.jiayue.insu.incloud.mapper.UserMapper;
 import com.jiayue.insu.incloud.service.UserService;
 import org.springframework.stereotype.Service;
-
+/**
+ * 用户登录业务实现
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2022/5/22 11:29
+ */
 @Service
 public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {