修改测试bug

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 -> {
+                        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);
-                            return target;
-                        }).collect(Collectors.toList());
+                                siteMatterEntities.add(target);
+                            }
+                        });
 
                         if (!ObjectUtils.isEmpty(siteMatterEntities)) {
                             // sheetMatterService.getDao().delete(new SheetMatterQuery().siteId(site.getId()));