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

package com.galaxis.manatee.service;

import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.galaxis.manatee.dao.ChuanyunGroupProjectDao;
import com.galaxis.manatee.entity.chuanyun.data.object.ChuanyunDevelopProjectDO;
import com.galaxis.manatee.entity.chuanyun.data.object.ChuanyunGroupProjectDO;
import com.galaxis.manatee.entity.chuanyun.data.object.ChuanyunManagerProjectDO;
import com.galaxis.manatee.entity.chuanyun.data.object.ChuanyunSaleProjectDO;
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 {

    private final ChuanyunBasicDataScheduledTask chuanyunBasicDataScheduledTask;
    private final ChuanYunManager chuanYunManager;
    private final ChuanyunGroupProjectDao chuanyunGroupProjectDao;

    public ProjectMemberService(ChuanyunBasicDataScheduledTask chuanyunBasicDataScheduledTask, ChuanYunManager chuanYunManager, ChuanyunGroupProjectDao chuanyunGroupProjectDao) {
        this.chuanyunBasicDataScheduledTask = chuanyunBasicDataScheduledTask;
        this.chuanYunManager = chuanYunManager;
        this.chuanyunGroupProjectDao = chuanyunGroupProjectDao;
    }

    @Async
    public void updateManagerMember(String param){
        var objectMapper=new ObjectMapper();
        param=param.substring(14,param.length()-2);
        log.info(param);
        boolean updateFlag=false;
        while (!updateFlag){
            var chuanyunFindResponse =  chuanYunManager.find(ChuanyunManagerProjectDO.SCHEMA_CODE,param);
            ChuanyunManagerProjectDO chuanyunManagerProjectDO = objectMapper.convertValue(chuanyunFindResponse.getReturnData().getBizObject(), new TypeReference<>(){});
            if (chuanyunManagerProjectDO!=null){
                updateFlag=true;
                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("管理项目更新项目组成员成功");
            }
        }
    }

    @Async
    public void updateSaleMember(String param){
        var objectMapper=new ObjectMapper();
        param=param.substring(14,param.length()-2);
        log.info(param);
        boolean updateFlag=false;
        while (!updateFlag){
            var chuanyunFindResponse =  chuanYunManager.find(ChuanyunSaleProjectDO.SCHEMA_CODE,param);
            ChuanyunSaleProjectDO chuanyunSaleProjectDO = objectMapper.convertValue(chuanyunFindResponse.getReturnData().getBizObject(), new TypeReference<>(){});
            log.info("销售项目"+chuanyunSaleProjectDO);
            if (chuanyunSaleProjectDO!=null){
                updateFlag=true;
                try {
                    List<String> matchers = new ArrayList<>();
                    matchers.add("F0000002_2,"+chuanyunSaleProjectDO.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("销售项目更新项目组成员成功");
            }
        }
    }

    @Async
    public void updateDevelopMember(String param){
        var objectMapper=new ObjectMapper();
        param=param.substring(14,param.length()-2);
        log.info(param);
        boolean updateFlag=false;
        while (!updateFlag){
            var chuanyunFindResponse =  chuanYunManager.find(ChuanyunDevelopProjectDO.SCHEMA_CODE,param);
            ChuanyunDevelopProjectDO chuanyunDevelopProjectDO = objectMapper.convertValue(chuanyunFindResponse.getReturnData().getBizObject(), new TypeReference<>(){});
            log.info("研发项目"+chuanyunDevelopProjectDO);
            if (chuanyunDevelopProjectDO!=null){
                updateFlag=true;
                try {
                    List<String> matchers = new ArrayList<>();
                    matchers.add("F0000002_2,"+chuanyunDevelopProjectDO.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("研发项目更新项目组成员成功");
            }
        }
    }
}