From 4fa181ff943b13f1ef90cef61dbdedee052cbb70 Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Fri, 07 Jul 2023 15:21:23 +0800 Subject: [PATCH] feat: 任务按照天补偿数据 --- screen-job/src/main/resources/application-qa.yml | 109 +++++++++++++++++++++++++++ screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java | 15 ++- screen-job/src/main/java/com/moral/api/service/HistoryDailyService.java | 4 screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java | 6 + screen-job/src/main/java/com/moral/api/controller/PubController.java | 52 +++++++++++++ 5 files changed, 180 insertions(+), 6 deletions(-) diff --git a/screen-job/src/main/java/com/moral/api/controller/PubController.java b/screen-job/src/main/java/com/moral/api/controller/PubController.java new file mode 100644 index 0000000..82550d4 --- /dev/null +++ b/screen-job/src/main/java/com/moral/api/controller/PubController.java @@ -0,0 +1,52 @@ +package com.moral.api.controller; + +import com.moral.api.service.HistoryDailyService; +import com.moral.constant.ResultMessage; +import com.moral.util.DateUtils; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +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.util.Date; + +/** + * @ClassName UserController + * @Description ������������ + * @Author ��������� + * @Date 2021/3/22 13:52 + * @Version TODO + **/ +@Slf4j +@Api(tags = {"������������"}) +@RestController +@RequestMapping("/pub") +public class PubController { + @Autowired + private HistoryDailyService historyDailyService; + + @GetMapping("insertHistoryDaily") + @ApiOperation(value = "���������������", notes = "���������������") + public ResultMessage insertHistoryDaily(String time) { + Date d = DateUtils.getDate(time,"yyyy-MM-dd"); + historyDailyService.insertHistoryDaily(time); + int i = 0; + return new ResultMessage(); + } + + public static void main(String[] args) { + String s = "2023-9-01"; + Date d = DateUtils.getDate(s,"yyyy-MM-dd"); + System.out.println(DateUtils.dateToDateFullString(d)); + //System.out.println( DateUtils.dateToDateFullString(DateUtils.getDateOfDay(d, -1), "yyyy-MM-dd")); + + + + } + +} diff --git a/screen-job/src/main/java/com/moral/api/service/HistoryDailyService.java b/screen-job/src/main/java/com/moral/api/service/HistoryDailyService.java index dccc6da..bda267f 100644 --- a/screen-job/src/main/java/com/moral/api/service/HistoryDailyService.java +++ b/screen-job/src/main/java/com/moral/api/service/HistoryDailyService.java @@ -6,6 +6,8 @@ import com.moral.api.entity.HistoryDaily; import com.baomidou.mybatisplus.extension.service.IService; +import javax.xml.crypto.Data; + /** * <p> * ��������� @@ -17,6 +19,6 @@ public interface HistoryDailyService extends IService<HistoryDaily> { //��������������� - void insertHistoryDaily(); + void insertHistoryDaily(String time); } diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java index 2dc5a04..bc817e4 100644 --- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java +++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java @@ -17,7 +17,9 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; +import org.springframework.util.StringUtils; +import javax.xml.crypto.Data; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; @@ -49,9 +51,14 @@ @Override @Transactional - public void insertHistoryDaily() { + public void insertHistoryDaily(String time) { String format = DateUtils.yyyy_MM_dd_EN; - Date now = new Date(); + Date now; + if(StringUtils.isEmpty(time)){ + now = new Date(); + } else { + now = DateUtils.getDate(time,"yyyy-MM-dd"); + } //��������������������� Date start = DateUtils.dataToTimeStampTime(DateUtils.getDateOfDay(now, -1), format); //��������������������� @@ -60,7 +67,6 @@ QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>(); sensorQueryWrapper.select("code", "lower", "upper").eq("is_delete", Constants.NOT_DELETE); List<Sensor> sensors = sensorService.list(sensorQueryWrapper); - //������������������������������ Map<String, Object> prop = new HashMap<>(); String timeUnits = DateUtils.dateToDateString(start, DateUtils.yyyyMM_EN); @@ -70,6 +76,7 @@ List<Map<String, Object>> dailyData = historyHourlyService.selectDailyData(prop); if (dailyData.size() == 0) { + System.out.println("������������������"+DateUtils.dateToDateString(start)); return; } @@ -179,8 +186,8 @@ dataMap.put("value", JSONObject.toJSONString(jsonMap)); insertData.add(dataMap); }); - //��������������� historyDailyMapper.insertHistoryDaily(insertData); + System.out.println("������������"); } } diff --git a/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java b/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java index 199f6ae..9f33024 100644 --- a/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java +++ b/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java @@ -12,6 +12,9 @@ import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; +import javax.xml.crypto.Data; +import java.util.Date; + @Component public class HistoryTableInsertTask { @@ -46,7 +49,8 @@ @XxlJob("insertHistoryDaily") public ReturnT insertHistoryDaily() { try { - historyDailyService.insertHistoryDaily(); + Date now = new Date(); + historyDailyService.insertHistoryDaily(null); } catch (Exception e) { XxlJobHelper.log(e.getMessage()); return ReturnT.FAIL; diff --git a/screen-job/src/main/resources/application-qa.yml b/screen-job/src/main/resources/application-qa.yml new file mode 100644 index 0000000..f12ffae --- /dev/null +++ b/screen-job/src/main/resources/application-qa.yml @@ -0,0 +1,109 @@ +server: + port: 8083 + tomcat: + uri-encoding: UTF-8 + #��������������� + min-spare-threads: 500 + #��������������� + max-threads: 2500 + #��������������� + max-connections: 6500 + #������������������������ + accept-count: 1000 +spring: + profiles: + active: dev + include: + moduleFormColumn + application: + name: screen-job + redis: + host: r-bp1hez4g7rkqjswpaypd1.redis.rds.aliyuncs.com + port: 6379 + password: moral_123456 + timeout: 30000 + jedis: + pool: + max-active: 256 + max-wait: 30000 + max-idle: 64 + min-idle: 32 + lettuce: + pool: + max-active: 256 + max-idle: 64 + max-wait: 30000 + min-idle: 32 + tokenRedis: + host: r-bp1hez4g7rkqjswpaypd1.redis.rds.aliyuncs.com + port: 6379 + password: moral_123456 + timeout: 30000 + database: 14 + pool: + max-active: 256 + max-wait: 30000 + max-idle: 64 + min-idle: 32 + + datasource: + minIdle: 1 + time-between-eviction-runs-millis: 60000 + max-active: 20 + test-while-idle: true + validation-query: select 'x' + filters: stat + type: com.alibaba.druid.pool.DruidDataSource + max-wait: 60000 + url: jdbc:mysql://121.199.44.85:3306/moral?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai + username: root + password: moral_123456 + test-on-borrow: false + sql-script-encoding: utf-8 + pool-prepared-statements: true + min-evictable-idle-time-millis: 300000 + initial-size: 1 + driver-class-name: com.mysql.cj.jdbc.Driver + max-conn-lifetime-millis: 20 + test-on-return: false + +mybatis-plus: + mapper-locations: classpath:mapper/*.xml + global-config: + db-config: + id-type: auto + field-strategy: NOT_EMPTY + db-type: MYSQL + configuration: + map-underscore-to-camel-case: true + call-setters-on-nulls: true + log-impl: org.apache.ibatis.logging.stdout.StdOutImpl + +logging: + config: classpath:logback.xml + +xxl: + job: + admin: + # ���������������������������������������������������������������������������������������������������������������������������������"���������������������"���"������������������" + addresses: http://127.0.0.1:8090/xxl-job-admin + + #���������������TOKEN������TOKEN��������������� + accessToken: + + #���������������,������������������ + executor: + # ������������������������������������������������������������������������������������ + #������������������"���������������������������������"���"���������������"��� + #������������������������9999������������IP������������������������������IP������������������������������������IP������IP������������Host������������������������ + #��������������������������������������������������������������������� + appname: xxl-job-executor-sample-springboot + ip: + port: 9999 + #��������������������������������������������������������������������������������������� + logpath: /data/applogs/xxl-job/jobhandler + #������������������������������������������������������������������������������������������������������3���������������������-1��������������� + logretentiondays: -1 + + + -- Gitblit v1.8.0