新增流程节点进程查询接口

zhongrj

2023-09-17 8853292babb2ad94de4a3207966f1e83b767cd2d

 src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java

@@ -22,6 +22,7 @@
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserDeptService;
import org.springblade.modules.system.service.IUserService;
import org.springblade.modules.system.service.MyAsyncService;
import org.springblade.modules.training.entity.TrainingRegistration;
import org.springblade.modules.training.excel.TrainingRegistrationExcel;
import org.springblade.modules.training.mapper.TrainingRegistrationMapper;
@@ -56,6 +57,8 @@
   private final AbsentRecordsService absentRecordsService;

   private final ExamScoreService examScoreService;
   @Autowired
   private  MyAsyncService myAsyncService;

   @Autowired
   private ExamAnswerRecordService examAnswerRecordService;
@@ -292,7 +295,8 @@
         + "," + "'" + trainingRegistration.getIsExam() + "'"
         + "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" +
         "update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
      FtpUtil.sqlFileUpload(s);
      //FtpUtil.sqlFileUpload(s);
      myAsyncService.dataSync(s);
   }


@@ -405,7 +409,8 @@
                           + "'" + examScore.getUserId() + "'" + ","
                           + "'" + examScore.getApplyId() + "'" + ","
                           + "'" + examScore.getExamId() + "'" + ")";
                     FtpUtil.sqlFileUpload(s);
                     //FtpUtil.sqlFileUpload(s);
                     myAsyncService.dataSync(s);
                  }
               }
            }
@@ -468,16 +473,27 @@
                     "update exam_score set theory_grade = " + examScore1.getTheoryGrade() +
                        ",qualified = " + "'" + examScore1.getQualified() + "'" +
                        " " + "where id = " + "'" + examScore1.getId() + "'";
                  FtpUtil.sqlFileUpload(s);
                  //FtpUtil.sqlFileUpload(s);
                  myAsyncService.dataSync(s);
               });
            }else {
               //数据同步
               String s =
                  "update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() +
                     " " + "where id = " + "'" + trainingRegistration1.getId() + "'";
               FtpUtil.sqlFileUpload(s);
               //FtpUtil.sqlFileUpload(s);
               myAsyncService.dataSync(s);
            }
         });
      }
   }

   /**
    * 查看报名集合信息
    * @return
    */
   @Override
   public List<TrainingRegistration> getList(TrainingRegistrationVo trainingRegistration) {
      return baseMapper.getList(trainingRegistration);
   }
}