提交

src/main/java/com/dashitech/migration/task/uc/UserTask.java

@@ -5,6 +5,7 @@ import com.dashitech.migration.SqlTask;
 import com.dashitech.migration.core.DataMigrationter;
 import com.dashitech.migration.core.FieldMapper;
 import com.dashitech.migration.core.RowsWrap;
+import com.dashitech.migration.util.JdbcRow;
 import com.dashitech.migration.util.JdbcUtil;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -14,6 +15,7 @@ import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * Created by CX on 2024/10/10.
@@ -56,7 +58,10 @@ public class UserTask extends BaseTask {
         RowsWrap rw = DataMigrationter.getRowsWrap(mapper,userMapper);
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
         jdbcUtil.batchPageInsert("itsm_uc_user", rw.getInsertRows());
-        jdbcUtil.batchPageUpdate("itsm_uc_user", rw.getUpdateRows());
+        List<JdbcRow> updateRows = rw.getUpdateRows();
+        //过滤微信不为空的数据做更新处理
+        updateRows = updateRows.stream().filter(s -> s.getRow().get("WEIXIN") != null).collect(Collectors.toList());
+        jdbcUtil.batchPageUpdate("itsm_uc_user", updateRows);
 
         //clear释放内存
         mapper.clear();