定时删除数据及配置文件更新

basic/src/main/java/com/liangjiang/basic/mapper/DealRecordsMapper.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.liangjiang.basic.domain.bo.QueryDealRecordsParams;
 import com.liangjiang.basic.domain.entity.DealRecords;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -18,7 +19,6 @@ public interface DealRecordsMapper extends BaseMapper<DealRecords> {
     List<DealRecords> queryDealRecords(QueryDealRecordsParams params);
     List<DealRecords> queryDealRecordsByRef(QueryDealRecordsParams params);
     List<DealRecords> queryDealRecordsByReg(QueryDealRecordsParams params);
-
-
+    void deleteInfo(@Param("time") Long time);
 
 }

basic/src/main/java/com/liangjiang/basic/service/IDealRecordsService.java

@@ -10,4 +10,5 @@ public interface IDealRecordsService extends IService<DealRecords> {
     List<DealRecords> queryDealRecords(QueryDealRecordsParams params);
     List<DealRecords> queryDealRecordsByRef(QueryDealRecordsParams params);
     List<DealRecords> queryDealRecordsByReg(QueryDealRecordsParams params);
+    void deleteInfo(Long time);
 }

basic/src/main/java/com/liangjiang/basic/service/impl/DealRecordsServiceImpl.java

@@ -35,4 +35,9 @@ public class DealRecordsServiceImpl extends ServiceImpl<DealRecordsMapper, DealR
         List<DealRecords> records = dealRecordsMapper.queryDealRecordsByReg(params);
         return records;
     }
+
+    @Override
+    public void deleteInfo(Long time){
+        dealRecordsMapper.deleteInfo(time);
+    }
 }

basic/src/main/java/com/liangjiang/basic/task/DataTask.java

@@ -0,0 +1,22 @@
+package com.liangjiang.basic.task;
+
+import com.liangjiang.basic.service.IDealRecordsService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class DataTask {
+
+    private final IDealRecordsService dealRecordsService;
+    // 每天1点30
+    @Scheduled(cron="0 0 0 * * ? ")
+    public void deleteData() {
+        long time = System.currentTimeMillis();
+        // 72小时前的数据删除
+        time -= 259200000L;
+        // 清除数据
+        dealRecordsService.deleteInfo(time);
+    }
+}

basic/src/main/resources/mapper/DealRecordsMapper.xml

@@ -58,4 +58,8 @@
         </if>
         order by d.id asc
     </select>
+
+    <delete id="deleteInfo" parameterType="java.lang.Long">
+        delete from deal_records s where s.trigger_time &lt; ${time}
+    </delete>
 </mapper>

price_collection/Dockerfile

@@ -3,8 +3,8 @@ FROM openjdk:8
 # 作者
 #MAINTAINER zbdemo <zbdemo@163.com>
 # 添加jar到镜像并命名为user.jar
-ADD price_collection.jar /app/price_collection.jar
+ADD price.jar /4l/java/price/price.jar
 # 镜像启动后暴露的端口
-EXPOSE 8848
+EXPOSE 82
 # jar运行命令，参数使用逗号隔开
-ENTRYPOINT ["java","-jar","/app/price_collection.jar"]
+ENTRYPOINT ["java","-jar","/4l/java/price/price.jar"]

price_collection/src/main/java/com/liangjiang/price_collection/filter/BasicFilter.java

@@ -17,7 +17,7 @@ import java.util.Map;
 @Component
 public class BasicFilter implements Filter {
 
-    private static final String AUTH_STR = "43626546liangjiang";
+    private static final String AUTH_STR = "4L";
 
     @Override
     public void init(FilterConfig filterConfig) {

price_collection/src/main/java/com/liangjiang/price_collection/filter/CoreFilter.java

@@ -32,7 +32,7 @@ public class CoreFilter implements Filter {
         // Access-Control-Max-Age 用于 CORS 相关配置的缓存
         rep.setHeader("Access-Control-Max-Age", "3600");
         // 允许前端发送的请求头
-        rep.setHeader("Access-Control-Allow-Headers", "auth, Origin, X-Requested-With, Content-Type, Accept");
+        rep.setHeader("Access-Control-Allow-Headers", "auth, token, Origin, X-Requested-With, Content-Type, Accept, Content-Encoding");
         //若要返回cookie、携带seesion等信息则将此项设置我true
         rep.setHeader("Access-Control-Allow-Credentials", "true");
         if ("OPTIONS".equals(req.getMethod())){

price_collection/src/main/resources/application.yml

@@ -4,6 +4,13 @@ server:
   port: 82
   tomcat:
     uri-encoding: UTF-8
+  compression:
+    # 开启响应数据的压缩功能
+    enabled: true
+    # 设置可以被压缩的MIME类型列表
+    mime-types: application/json,application/xml,text/html,text/xml,text/plain
+    # 设置触发压缩的最小响应大小 2kb
+    min-response-size: 2048
 logging:
   config: classpath:log.xml
 spring:
@@ -43,6 +50,7 @@ spring:
 
   activemq:
     broker-url: tcp://kline.skyfffire.com:61616
+#    broker-url: tcp://localhost:61616
     packages:
       # 配置信任所有包 为了支持发送对象消息
       trust-all: true

price_collection/src/main/resources/basic_application.yml.simple

@@ -4,6 +4,13 @@ server:
   port: 82
   tomcat:
     uri-encoding: UTF-8
+  compression:
+    # 开启响应数据的压缩功能
+    enabled: true
+    # 设置可以被压缩的MIME类型列表
+    mime-types: application/json,application/xml,text/html,text/xml,text/plain
+    # 设置触发压缩的最小响应大小 2kb
+    min-response-size: 2048
 logging:
   config: classpath:log.xml
 spring:
@@ -39,10 +46,11 @@ spring:
             none-base-statement-allow: true
             multi-statement-allow: true
       # 配置监控统计拦截的filters，去掉后监控界面sql无法统计。‘wall’用于防火墙
-#      filters: stat,wall
+  #      filters: stat,wall
 
   activemq:
     broker-url: tcp://kline.skyfffire.com:61616
+#    broker-url: tcp://localhost:61616
     packages:
       # 配置信任所有包 为了支持发送对象消息
       trust-all: true