1.立项更新项目组成员

src/main/java/com/galaxis/manatee/service/ProjectMemberService.java

@@ -5,12 +5,17 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import com.galaxis.manatee.dao.ChuanyunGroupProjectDao;
 import com.galaxis.manatee.entity.chuanyun.data.object.ChuanyunGroupProjectDO;
 import com.galaxis.manatee.entity.chuanyun.data.object.ChuanyunManagerProjectDO;
+import com.galaxis.manatee.entity.chuanyun.dto.ChuanyunFindAllBizDTO;
+import com.galaxis.manatee.entity.chuanyun.dto.Filter;
 import com.galaxis.manatee.manager.ChuanYunManager;
 import com.galaxis.manatee.task.ChuanyunBasicDataScheduledTask;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
+import java.util.List;
+
 @Service
 @Slf4j
 public class ProjectMemberService {
@@ -33,9 +38,21 @@ public class ProjectMemberService {
         if (chuanyunFindResponse.getReturnData()!=null){
             ChuanyunManagerProjectDO chuanyunManagerProjectDO = objectMapper.convertValue(chuanyunFindResponse.getReturnData().getBizObject(), new TypeReference<>(){});
             log.info("管理项目"+chuanyunManagerProjectDO);
-            ChuanyunGroupProjectDO chuanyunGroupProjectDO = chuanyunGroupProjectDao.findByProjectCode(chuanyunManagerProjectDO.getSeqNo());
-            chuanyunBasicDataScheduledTask.chuanyunUpdateProjectMemberManually(chuanyunGroupProjectDO);
-            log.info("更新项目组成员成功"+chuanyunGroupProjectDO);
+            try {
+                List<String> matchers = new ArrayList<>();
+                matchers.add("F0000002_2,"+chuanyunManagerProjectDO.getSeqNo());
+                var filter= Filter.instance(0,1,true,"And",matchers);
+                ChuanyunFindAllBizDTO<Object> chuanyunFindAllResponse = chuanYunManager.findAll(ChuanyunGroupProjectDO.SCHEMA_CODE,filter);
+                if (chuanyunFindAllResponse.getReturnData()!=null){
+                    List<ChuanyunGroupProjectDO> result=objectMapper.convertValue(chuanyunFindAllResponse.getReturnData().getBizObjectArray(), new TypeReference<>(){});
+                    log.info("集团项目"+result.get(0));
+                    chuanyunBasicDataScheduledTask.chuanyunUpdateProjectMemberManually(result.get(0));
+                }
+            }catch (Exception e){
+                e.printStackTrace();
+                log.warn(e.getMessage());
+            }
+            log.info("更新项目组成员成功");
         }else {
             log.info("更新项目组成员失败");
         }