定时读取数据适应分表逻辑代码

service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoExportDelJob.java

@@ -1,5 +1,6 @@
 package com.hchbox.job;
 
+import cn.hutool.core.date.DateUtil;
 import com.dangdang.ddframe.job.api.ShardingContext;
 import com.dangdang.ddframe.job.api.simple.SimpleJob;
 import com.example.autoconfig.ElasticSimpleJob;
@@ -34,7 +35,7 @@ public class ObtainInfoExportDelJob implements SimpleJob {
 
     @Override
     public void execute(ShardingContext shardingContext) {
-        log.info("===============ObtainInfoExportDelJob定时器触发执行================");
+        log.info("===============ObtainInfoExportDelJob备份数据到本地开始,{}================", DateUtil.date());
         obtainInfoExportDelJob.obtainInfoService.selectExportDel();
     }
 }

service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoJob.java

@@ -1,5 +1,6 @@
 package com.hchbox.job;
 
+import cn.hutool.core.date.DateUtil;
 import com.dangdang.ddframe.job.api.ShardingContext;
 import com.dangdang.ddframe.job.api.simple.SimpleJob;
 import com.example.autoconfig.ElasticSimpleJob;
@@ -33,6 +34,7 @@ public class ObtainInfoJob implements SimpleJob {
 
     @Override
     public void execute(ShardingContext shardingContext) {
+        log.info("===============ObtainInfoJob同步前一天数据开始,{}================", DateUtil.date());
         obtainInfoJob.obtainInfoService.selectAllSave();
     }
 }

service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/TopTradeRepository.java

@@ -27,6 +27,6 @@ public interface TopTradeRepository extends JpaRepository<TopTrade, Long>, JpaSp
      * 抽取前天数据
      * @return
      */
-    @Query(value = " from TopTrade where 1 = 1")
+    @Query(value = "select * from top_trade where date(gmt_sync) = date_sub(curdate(),interval 1 day)",nativeQuery = true)
     List<TopTrade> findAllByGmtSync();
 }

service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/entity/TopTrade.java

@@ -3,6 +3,8 @@ package com.hchbox.module.entity;
 import com.hchbox.model.entity.BaseTrade;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
 
 import javax.persistence.*;
 import java.io.Serializable;
@@ -13,13 +15,14 @@ import java.io.Serializable;
  * @description /
  * @date 2021-08-13
  **/
+@Getter
+@Setter
 @Entity
-@Data
 @Table(name = "top_trade")
 public class TopTrade extends BaseTrade implements Serializable {
-    private static final long serialVersionUID = -7591788824668705732L;
+
+    private static final long serialVersionUID = -6270860811404254046L;
     @Id
-    @GeneratedValue(strategy = GenerationType.IDENTITY)
     @Column(name = "id")
     @ApiModelProperty(value = "id")
     private Long id;