From aa4240db23f89b71455f547a00bb637108021410 Mon Sep 17 00:00:00 2001 From: bynt Date: Wed, 5 Jul 2023 09:19:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=A0=BC=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adcallback/service/impl/BdBackDataServiceImpl.java | 3 +-- .../adcallback/service/impl/JlV1BackDataServiceImpl.java | 6 +----- .../adcallback/service/impl/JlV2BackDataServiceImpl.java | 4 +--- .../adcallback/service/impl/KsBackDataServiceImpl.java | 2 +- .../adcallback/service/impl/UcBackDataServiceImpl.java | 2 +- .../com/baiyee/adcallback/task/DeleteDeliveryDataTask.java | 4 ++-- 6 files changed, 7 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/baiyee/adcallback/service/impl/BdBackDataServiceImpl.java b/src/main/java/com/baiyee/adcallback/service/impl/BdBackDataServiceImpl.java index d266be5..784050b 100644 --- a/src/main/java/com/baiyee/adcallback/service/impl/BdBackDataServiceImpl.java +++ b/src/main/java/com/baiyee/adcallback/service/impl/BdBackDataServiceImpl.java @@ -41,9 +41,8 @@ public class BdBackDataServiceImpl extends AbstractService tagList, Integer flag) { return this.applyJPA(query -> { - StringPath t3 = Expressions.stringPath("t3"); StringTemplate dateExpr; - + StringPath t3 = Expressions.stringPath("t3"); if (flag == 1) { dateExpr = Expressions.stringTemplate(SqlConstant.DATE_EXPR, bdNewBackdata.gmtCreate); SimpleTemplate t3Tag = Expressions.template(String.class, "t3.tag"); diff --git a/src/main/java/com/baiyee/adcallback/service/impl/JlV1BackDataServiceImpl.java b/src/main/java/com/baiyee/adcallback/service/impl/JlV1BackDataServiceImpl.java index 88e573f..3aaa8b7 100644 --- a/src/main/java/com/baiyee/adcallback/service/impl/JlV1BackDataServiceImpl.java +++ b/src/main/java/com/baiyee/adcallback/service/impl/JlV1BackDataServiceImpl.java @@ -39,18 +39,14 @@ import java.util.List; @RequiredArgsConstructor public class JlV1BackDataServiceImpl extends AbstractService implements JlV1BackDataService { - - @PersistenceContext - protected EntityManager entityManager; QTbJLBackDataV1Entity v1Entity = QTbJLBackDataV1Entity.tbJLBackDataV1Entity; @Override public List queryByTagAndTimeAndFlag (Date startTime, Date endTime, List tagList, Integer flag) { return this.applyJPA(query -> { - StringPath t3 = Expressions.stringPath("t3"); StringTemplate dateExpr; - + StringPath t3 = Expressions.stringPath("t3"); if (flag == 1) { dateExpr = Expressions.stringTemplate(SqlConstant.DATE_EXPR, v1Entity.gmtCreate); SimpleTemplate t3Tag = Expressions.template(String.class, "t3.tag"); diff --git a/src/main/java/com/baiyee/adcallback/service/impl/JlV2BackDataServiceImpl.java b/src/main/java/com/baiyee/adcallback/service/impl/JlV2BackDataServiceImpl.java index 598051b..048a990 100644 --- a/src/main/java/com/baiyee/adcallback/service/impl/JlV2BackDataServiceImpl.java +++ b/src/main/java/com/baiyee/adcallback/service/impl/JlV2BackDataServiceImpl.java @@ -37,11 +37,9 @@ public class JlV2BackDataServiceImpl extends AbstractService queryByTagAndTimeAndFlag (Date startTime, Date endTime, List tagList, Integer flag) { - return this.applyJPA(query -> { - StringPath t3 = Expressions.stringPath("t3"); StringTemplate dateExpr; - + StringPath t3 = Expressions.stringPath("t3"); if (flag == 1) { dateExpr = Expressions.stringTemplate(SqlConstant.DATE_EXPR, v2Entity.gmtCreate); SimpleTemplate t3Tag = Expressions.template(String.class, "t3.tag"); diff --git a/src/main/java/com/baiyee/adcallback/service/impl/KsBackDataServiceImpl.java b/src/main/java/com/baiyee/adcallback/service/impl/KsBackDataServiceImpl.java index 961bf86..0034bec 100644 --- a/src/main/java/com/baiyee/adcallback/service/impl/KsBackDataServiceImpl.java +++ b/src/main/java/com/baiyee/adcallback/service/impl/KsBackDataServiceImpl.java @@ -41,8 +41,8 @@ public class KsBackDataServiceImpl extends AbstractService tagList, Integer flag) { return this.applyJPA(query -> { - StringPath t3 = Expressions.stringPath("t3"); StringTemplate dateExpr; + StringPath t3 = Expressions.stringPath("t3"); if (flag == 1) { dateExpr = Expressions.stringTemplate(SqlConstant.DATE_EXPR, ksNewBackdata.gmtCreate); diff --git a/src/main/java/com/baiyee/adcallback/service/impl/UcBackDataServiceImpl.java b/src/main/java/com/baiyee/adcallback/service/impl/UcBackDataServiceImpl.java index fd959b2..f16858f 100644 --- a/src/main/java/com/baiyee/adcallback/service/impl/UcBackDataServiceImpl.java +++ b/src/main/java/com/baiyee/adcallback/service/impl/UcBackDataServiceImpl.java @@ -41,8 +41,8 @@ public class UcBackDataServiceImpl extends AbstractService tagList, Integer flag) { return this.applyJPA(query -> { - StringPath t3 = Expressions.stringPath("t3"); StringTemplate dateExpr; + StringPath t3 = Expressions.stringPath("t3"); if (flag == 1) { dateExpr = Expressions.stringTemplate(SqlConstant.DATE_EXPR, ucBackdata.gmtCreate); diff --git a/src/main/java/com/baiyee/adcallback/task/DeleteDeliveryDataTask.java b/src/main/java/com/baiyee/adcallback/task/DeleteDeliveryDataTask.java index 9b97b86..e89b1ac 100644 --- a/src/main/java/com/baiyee/adcallback/task/DeleteDeliveryDataTask.java +++ b/src/main/java/com/baiyee/adcallback/task/DeleteDeliveryDataTask.java @@ -55,7 +55,7 @@ public class DeleteDeliveryDataTask { Query deleteTagByQuery = entityManager.createNativeQuery (SqlConstant.DELETE_STR .concat(tableName) - .concat(SqlConstant.WHERE_STR) + .concat(SqlConstant.WHERE_STR) .concat(" limit 50000")); deleteTagByQuery.setParameter("DATE", date.toDateStr()); int executeUpdate = deleteTagByQuery.executeUpdate(); @@ -84,7 +84,7 @@ public class DeleteDeliveryDataTask { /** * 每六个小时删除一批数据 - * XXX 大数据应该修改代码逻辑 + * XXX 大数据应该修改代码逻辑 */ @Scheduled(cron = "0 0 0/6 * * ?") @Transactional(rollbackFor = Exception.class)