takai-system/src/main/java/com/takai/system/service/impl/JkApiServiceImpl.java

@@ -248,6 +248,8 @@ public class JkApiServiceImpl implements IJkApiService {
         try {
             // ========== 核心解析：JSON数组 → List<Project> ==========
             List<ProjectWebApiBo> projectList = JSON.parseArray(String.valueOf(jsonArray), ProjectWebApiBo.class);
+            int projectNum = 0;
+            int projectStaffNum = 0;
             // 遍历解析结果，验证数据
             for (ProjectWebApiBo project : projectList) {
                 SysProject sysProject = new SysProject();
@@ -257,6 +259,7 @@ public class JkApiServiceImpl implements IJkApiService {
                 SysProject dbProject = projectService.selectSysProjectByProjectPid(project.getProCode());
                 if(null == dbProject) {
                     projectService.insertSysProject(sysProject);
+                    projectNum++;
                 }
 
                 for (Member member : project.getMemberList()) {
@@ -269,10 +272,18 @@ public class JkApiServiceImpl implements IJkApiService {
                     SysProjectStaff dbStaff = projectStaffService.selectSysProjectStaff(sysProjectStaff);
                     if(null == dbStaff) {
                         projectStaffService.insertSysProjectStaff(sysProjectStaff);
+                        projectStaffNum++;
                     }
 
                 }
             }
+            if(sourceFrom.equals(HJL)){
+                logger.info("项目同步任务同步慧监理项目数据"+projectNum+"条");
+                logger.info("项目同步任务同步慧监理项目成员数据"+projectStaffNum+"条");
+            } else {
+                logger.info("项目同步任务同步慧项管项目数据"+projectNum+"条");
+                logger.info("项目同步任务同步慧项管项目成员数据"+projectStaffNum+"条");
+            }
         } catch (Exception e) {
             System.err.println("FastJSON2 解析失败：" + e.getMessage());
             e.printStackTrace();