|
@@ -136,27 +136,32 @@ public class ChuanyunBasicDataScheduledTask {
|
|
|
}
|
|
|
//通过更新集团项目中的EBG项目经理、IBG项目经理
|
|
|
//TODO 测试结束后需要扩大范围到所有项目
|
|
|
- if ("实施".equals(chuanyunGroupProjectDO.getProjectType())&&"EBG".equals(chuanyunGroupProjectDO.getBusinessGroup())){
|
|
|
- GroupProjectUpdateDTO groupProjectUpdateDTO=new GroupProjectUpdateDTO();
|
|
|
- try {
|
|
|
- chuanYunManager.update(ChuanyunGroupProjectDO.SCHEMA_CODE,chuanyunGroupProjectDO.getObjectId(),objectMapper.writeValueAsString(groupProjectUpdateDTO));
|
|
|
- } catch (JsonProcessingException e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- groupProjectUpdateDTO=new GroupProjectUpdateDTO(chuanyunGroupProjectDO);
|
|
|
+ GroupProjectUpdateDTO groupProjectUpdateDTO=new GroupProjectUpdateDTO();
|
|
|
+ try {
|
|
|
+ chuanYunManager.update(ChuanyunGroupProjectDO.SCHEMA_CODE,chuanyunGroupProjectDO.getObjectId(),objectMapper.writeValueAsString(groupProjectUpdateDTO));
|
|
|
+ } catch (JsonProcessingException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ groupProjectUpdateDTO=new GroupProjectUpdateDTO(chuanyunGroupProjectDO);
|
|
|
+ //保证项目经理信息更新成功
|
|
|
+ boolean updateFlag=false;
|
|
|
+ while (!updateFlag){
|
|
|
try {
|
|
|
var groupProjectUpdateString=objectMapper.writeValueAsString(groupProjectUpdateDTO);
|
|
|
ChuanyunSaveDTO chuanyunSaveDTO=chuanYunManager.update(ChuanyunGroupProjectDO.SCHEMA_CODE,chuanyunGroupProjectDO.getObjectId(),groupProjectUpdateString);
|
|
|
if(chuanyunSaveDTO.getSuccessful()){
|
|
|
log.info(chuanyunGroupProjectDO.getObjectId()+"更新项目经理成功"+groupProjectUpdateString);
|
|
|
+ updateFlag=true;
|
|
|
}else{
|
|
|
log.warn(chuanyunGroupProjectDO.getObjectId()+"更新项目经理失败"+groupProjectUpdateString);
|
|
|
log.warn(chuanyunGroupProjectDO+"");
|
|
|
+ Thread.sleep(5000L);
|
|
|
}
|
|
|
- } catch (JsonProcessingException e) {
|
|
|
+ } catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
});
|
|
|
chuanyunGroupProjectDao.saveAll(result);
|
|
|
}catch (Exception e){
|