From 1f250ebddca2e954887186614c403ae6701c63de Mon Sep 17 00:00:00 2001
From: cjl <276999030@qq.com>
Date: Fri, 07 Jul 2023 15:22:20 +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