Bläddra i källkod

合并:合并数据迁移功能代码

lijie 3 år sedan
förälder
incheckning
095e8cf4de

+ 4 - 1
dmp-business/dmp-rwd/src/main/java/com/persagy/dmp/rwd/migrate/controller/DigitalMigrateLogController.java

@@ -84,13 +84,16 @@ public class DigitalMigrateLogController {
      * @param voList
      */
     private void ensureDefaultValue(List<SyncData> voList,String projectId) {
-        for (SyncData vo : voList) {;
+        for (SyncData vo : voList) {
             if(StrUtil.isBlank(vo.getId())) {
                 vo.setId(IdUtil.fastSimpleUUID());
             }
             if(StrUtil.isBlank(vo.getProjectId())) {
                 vo.setProjectId(projectId);
             }
+            if(vo.getValid() == null) {
+                vo.setValid(1);
+            }
         }
     }
 }

+ 4 - 1
dmp-business/dmp-rwd/src/main/java/com/persagy/dmp/rwd/migrate/service/impl/SyncDataServiceImpl.java

@@ -37,7 +37,10 @@ public class SyncDataServiceImpl extends ServiceImpl<SyncDataMapper, SyncData> i
     @Override
     public List<SyncData> save(List<SyncData> voList) throws Exception {
         //修改采集信息点
-        syncDataMapper.save(voList);
+        //syncDataMapper.save(voList);
+        voList.forEach(vo -> {
+            syncDataMapper.insert(vo);
+        });
         return voList;
     }