数据同步修改

Administrator

2021-08-23 bf93d530532a5910dae6676d23e13aed607baef9

 src/main/java/org/springblade/modules/apply/service/impl/ApplyServiceImpl.java

@@ -1,6 +1,7 @@

package org.springblade.modules.apply.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
@@ -12,6 +13,8 @@
import org.springblade.common.utils.arg;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.api.R;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.FTP.OutJson;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyExcel;
import org.springblade.modules.apply.excel.ApplyInfoExcel;
@@ -20,7 +23,9 @@
import org.springblade.modules.apply.vo.ApplyPaPerVO;
import org.springblade.modules.apply.vo.ApplyVO;
import org.springblade.modules.exam.entity.ExamPaper;
import org.springblade.modules.exam.entity.ExamScore;
import org.springblade.modules.exam.service.ExamPaperService;
import org.springblade.modules.exam.service.ExamScoreService;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springblade.modules.training.entity.TrainingRegistration;
@@ -28,9 +33,14 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;

import static org.springblade.common.constant.FtpConstant.*;

/**
 * 考试报名服务实现类
@@ -114,8 +124,16 @@
               //修改保安报名状态
               user1.setIsApply(1);
               userService.updateById(user1);

               String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
               Long id = apply1.getId();
               String s = "insert into sys_apply(id,user_id,apply_time,apply_status,is_exam) " +
                  "values(" + "'" + id + "'" + "," + "'" + apply1.getUserId() + "'" + "," + "'" + formatStr +
                  "'" + "," + "'" + apply1.getApplyStatus() + "'" + "," +"'" + apply1.getIsExam() + "'" + ");" +
                  "update blade_user set is_apply = " + "'" + user1.getIsApply() + "'" +"where id = " + "'" + user1.getId() + "'";
               FtpUtil.sqlFileUpload(s);
            }else {
               if (user1.getIsApply()==2 || -1==user.getIsApply() || 3==user.getIsApply()) {
               if (user1.getIsApply()!=1) {
                  Apply apply1 = new Apply();
                  apply1.setApplyStatus(2);
                  //默认为未考试状态
@@ -126,6 +144,15 @@
                  //修改保安报名状态
                  user1.setIsApply(1);
                  userService.updateById(user1);

                  //内网数据同步
                  String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
                  Long id = apply1.getId();
                  String s = "insert into sys_apply(id,user_id,apply_time,apply_status,is_exam) " +
                     "values(" + "'" + id + "'" + "," + "'" + apply1.getUserId() + "'" + "," + "'" + formatStr +
                     "'" + "," + "'" + apply1.getApplyStatus() + "'" + "," +"'" + apply1.getIsExam() + "'" + ");" +
                     "update blade_user set is_apply = " + "'" + user1.getIsApply() + "'" +"where id = " + "'" + user1.getId() + "'";
                  FtpUtil.sqlFileUpload(s);
               }
            }
         }
@@ -407,9 +434,15 @@
   public void updateApplyStatus(ApplyVO apply) {
      //正式考
      if (apply.getExamType()==1){
         Apply apply1 = new Apply();
         apply1.setId(apply.getId());
         //考试中
         apply.setIsExam(3);
         baseMapper.updateById(apply);
         apply1.setIsExam(3);
         baseMapper.updateById(apply1);

         String s1 =
            "update sys_apply set is_exam = " + apply1.getIsExam() + " " +"where id = " + "'" + apply1.getId() + "'";
         FtpUtil.sqlFileUpload(s1);
      }
      //模拟考
      if (apply.getExamType()==2){
@@ -418,6 +451,10 @@
         //考试中
         trainingRegistration.setIsExam(3);
         trainingRegistrationService.updateById(trainingRegistration);

         String s1 =
            "update sys_training_registration set is_exam = " + trainingRegistration.getIsExam() + " " +"where id = " + "'" + trainingRegistration.getId() + "'";
         FtpUtil.sqlFileUpload(s1);
      }
   }