From 939cfb168731e16b741421739cd4eb606e7568cc Mon Sep 17 00:00:00 2001
From: liaoxuwei <5789413@qq.com>
Date: Mon, 11 Mar 2024 11:51:09 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B5=8B=E8=AF=95bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../daemon/task/SyncSiteMatterTaskImpl.java | 25 +++++++++++--------
1 file changed, 15 insertions(+), 10 deletions(-)
diff --git a/single-matter/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java b/single-matter/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java
index 9e03e5b..d6f1d6e 100644
--- a/single-matter/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java
+++ b/single-matter/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java
@@ -21,6 +21,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
+import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
@@ -50,7 +51,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService {
List<SitePdu> siteList = JSONObject.parseArray(jsonObject.getString("data"),SitePdu.class);
log.info("鎬绘暟閲忥細{}",siteList.size());
siteList.forEach(site -> {
- siteMatterService.getDao().delete(new SiteMatterQuery().siteId(site.getId()));
+ //siteMatterService.getDao().delete(new SiteMatterQuery().siteId(site.getId()));
int page=100;
int pageNum=100;
for(int i=1;i<=page;i++){
@@ -67,15 +68,19 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService {
}
//鍒犻櫎鍚庢柊澧�
log.info("浜嬮」鎬绘暟閲忥細{}",siteMatterRest.getData().getData().size());
- List<SiteMatterEntity> siteMatterEntities = siteMatterRest.getData().getData().stream().map(siteMatter -> {
- SiteMatterEntity target = new SiteMatterEntity();
- target.initAttrValue();
- BeanUtils.copyProperties(siteMatter, target, BeanUtil.getNullPropertyNames(siteMatter));
- target.setCreateTime(new Date());
- target.setViewsCount(0l);
- target.setIsConvert(0);
- return target;
- }).collect(Collectors.toList());
+ List<SiteMatterEntity> siteMatterEntities = new ArrayList<>();
+ siteMatterRest.getData().getData().forEach(siteMatter ->{
+ SiteMatterEntity temp = siteMatterService.selectOne(new SiteMatterQuery().matterId(siteMatter.getMatterId()));
+ if(temp==null) {
+ SiteMatterEntity target = new SiteMatterEntity();
+ target.initAttrValue();
+ BeanUtils.copyProperties(siteMatter, target, BeanUtil.getNullPropertyNames(siteMatter));
+ target.setCreateTime(new Date());
+ target.setViewsCount(0l);
+ target.setIsConvert(0);
+ siteMatterEntities.add(target);
+ }
+ });
if (!ObjectUtils.isEmpty(siteMatterEntities)) {
// sheetMatterService.getDao().delete(new SheetMatterQuery().siteId(site.getId()));
--
2.24.3