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