tangzy
2021-08-27 733edfcd6ad1c38dcf4aa761a417f4e4bfd754b2
src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java
@@ -3,16 +3,26 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.api.R;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyInfoExcel;
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.training.entity.TrainingRegistration;
import org.springblade.modules.training.excel.TrainingRegistrationExcel;
import org.springblade.modules.training.mapper.TrainingRegistrationMapper;
import org.springblade.modules.training.service.TrainingRegistrationService;
import org.springblade.modules.training.util.LongTimeUtil;
import org.springblade.modules.training.vo.TrainingRegistrationVo;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
@@ -20,7 +30,13 @@
 * @author zhongrj
 */
@Service
@AllArgsConstructor
public class TrainingRegistrationServiceImpl extends ServiceImpl<TrainingRegistrationMapper, TrainingRegistration> implements TrainingRegistrationService {
   private final IUserService userService;
   private final IUserDeptService userDeptService;
   @Override
   public IPage<TrainingRegistrationVo> selectTrainingRegistrationPage(IPage<TrainingRegistrationVo> page, TrainingRegistrationVo trainingRegistration) {
@@ -56,25 +72,67 @@
    * @param isCovered
    */
   @Override
   public void importTrainingRegistration(List<ApplyInfoExcel> data, Boolean isCovered) {
      data.forEach(applyInfoExcel -> {
         //通过准考证号
         if (null!=applyInfoExcel.getCandidateNo() && applyInfoExcel.getIdCardNo()!=""){
   @Transactional(rollbackFor = Exception.class)
   public void importTrainingRegistration(List<TrainingRegistrationExcel> data, Boolean isCovered) {
      if (data.size()>0){
         data.forEach(trainingRegistrationExcel -> {
            TrainingRegistration trainingRegistration = new TrainingRegistration();
            trainingRegistration.setCandidateNo(applyInfoExcel.getCandidateNo());
            //查询报名信息
            TrainingRegistration trainingRegistration1  = baseMapper.selectOne(Condition.getQueryWrapper(trainingRegistration));
            trainingRegistration1.setIsExam(2);
            baseMapper.updateById(trainingRegistration1);
            //内网新增
            try {
//               arg.test01(arg.url+"/apply/update",apply1);
            } catch (Exception e) {
               e.printStackTrace();
            }
         }
            //通过身份证号
            if (null!=trainingRegistrationExcel.getIdCardNo() && trainingRegistrationExcel.getIdCardNo()!=""){
               User user = userService.getUserInfoByIdCardNo(trainingRegistrationExcel.getIdCardNo());
               trainingRegistration.setUserId(user.getId().toString());
      });
               //通过培训公司查组织机构id
               if (null!=trainingRegistrationExcel.getDeptName() && trainingRegistrationExcel.getDeptName()!=""){
                  trainingRegistration.setTrainingUnitId(userDeptService.selectIn(trainingRegistrationExcel.getDeptName()));
               }
               if(null==user.getIsTrain()){
                  trainingRegistration.setIsExam(1);
                  trainingRegistration.setCancel(1);
                  trainingRegistration.setTrainingTime(new Date());
                  //新增报名
                  this.save(trainingRegistration);
                  //修改保安报名状态
                  user.setIsTrain(1);
                  userService.updateById(user);
                  //数据同步
                  saveTrainingRegistration(trainingRegistration,user);
               }else {
                  if (user.getIsTrain()!=1) {
                     trainingRegistration.setIsExam(1);
                     trainingRegistration.setCancel(1);
                     trainingRegistration.setTrainingTime(new Date());
                     //新增报名
                     this.save(trainingRegistration);
                     //修改保安报名状态
                     user.setIsTrain(1);
                     userService.updateById(user);
                     //数据同步
                     saveTrainingRegistration(trainingRegistration,user);
                  }
               }
            }
         });
      }
   }
   /**
    * 报名
    */
   private void saveTrainingRegistration(TrainingRegistration trainingRegistration,User user1){
      String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
      Long id = trainingRegistration.getId();
      String s = "insert into sys_training_registration(id,training_unit_id,training_time,cancel,user_id,is_exam) " +
         "values(" + "'" + id + "'"
         + "," + "'" + trainingRegistration.getTrainingUnitId() +"'"
         + "," + "'" + formatStr +"'"
         + "," + "'" + trainingRegistration.getCancel() + "'"
         + "," + "'" + trainingRegistration.getUserId() + "'"
         + "," +"'" + trainingRegistration.getIsExam() + "'" + ");" +
         "update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
      FtpUtil.sqlFileUpload(s);
   }