ftp sql 同步封装

Administrator

2021-12-15 8d43111bd0e598bc0b2014cbfa69a32e74959dff

 src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java

@@ -11,11 +11,13 @@
import net.sourceforge.pinyin4j.format.exception.BadHanyuPinyinOutputFormatCombination;
import org.apache.commons.lang3.StringUtils;
import org.springblade.common.constant.AgeUtil;
import org.springblade.common.utils.FtpSyncUtil;
import org.springblade.core.excel.util.ExcelUtil;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.apply.entity.Apply;
@@ -35,6 +37,7 @@
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

/**
 * @author zhongrj
@@ -124,10 +127,10 @@
   /**
    * 报名
    */
   private void saveTrainingRegistration(TrainingRegistration trainingRegistration,User user1){
   private StringBuilder batchSaveTrainingRegistration(TrainingRegistration trainingRegistration,User user1,StringBuilder builder){
      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,audit_status) " +
      String sql = "insert into sys_training_registration(id,training_unit_id,training_time,cancel,user_id,is_exam,audit_status) " +
         "values(" + "'" + id + "'"
         + "," + "'" + trainingRegistration.getTrainingUnitId() +"'"
         + "," + "'" + formatStr +"'"
@@ -136,7 +139,25 @@
         + "," + "'" + trainingRegistration.getIsExam() + "'"
         + "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" +
         "update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
      FtpUtil.sqlFileUpload(s);
      return FtpSyncUtil.sqlHandler(builder, sql);
   }

   /**
    * 报名
    */
   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 sql = "insert into sys_training_registration(id,training_unit_id,training_time,cancel,user_id,is_exam,audit_status) " +
         "values(" + "'" + id + "'"
         + "," + "'" + trainingRegistration.getTrainingUnitId() +"'"
         + "," + "'" + formatStr +"'"
         + "," + "'" + trainingRegistration.getCancel() + "'"
         + "," + "'" + trainingRegistration.getUserId() + "'"
         + "," + "'" + trainingRegistration.getIsExam() + "'"
         + "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" +
         "update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
      FtpUtil.sqlFileUpload(sql);
   }


@@ -281,6 +302,7 @@
      AtomicInteger count  = new AtomicInteger();
      //创建年龄部分对象集合
      List<String> errorList = new ArrayList<>();
      AtomicReference<StringBuilder> builder = new AtomicReference<>(new StringBuilder());
      //遍历
      list.forEach(userId ->{
         User user = userService.getById(userId);
@@ -304,7 +326,7 @@
               userService.updateById(user);

               //数据同步
               saveTrainingRegistration(trainingRegistration1, user);
               builder.set(batchSaveTrainingRegistration(trainingRegistration1, user, builder.get()));
            } else {
               if (user.getIsTrain() != 1) {
                  TrainingRegistration trainingRegistration1 = new TrainingRegistration();
@@ -322,7 +344,7 @@
                  userService.updateById(user);

                  //数据同步
                  saveTrainingRegistration(trainingRegistration1, user);
                  builder.set(batchSaveTrainingRegistration(trainingRegistration1, user, builder.get()));
               }
            }
         }else {
@@ -332,6 +354,10 @@
            errorList.add(user.getCardid());
         }
      });
      //同步
      if (builder.get().length()>0) {
         FtpSyncUtil.slqSync(builder.get());
      }
      //如果存在年龄不符的，则抛出异常
      if (count.get()>0){
         String errorAccount = StringUtils.join(errorList, "\\\n");
@@ -378,17 +404,16 @@
      return R.data(detail);
   }

//   /**
//    * 导出报名数数据
//    * @param response
//    * @param trainingRegistration 培训报名对象
//    */
//   @GetMapping("export-apply")
//   @ApiOperation(value = "导出报名清册")
//   public void exportApply(HttpServletResponse response,TrainingRegistrationVo trainingRegistration) {
//      List<TrainingRegistrationExcel> list = trainingRegistrationService.getTrainingRegistrationExcelList(trainingRegistration);
//      ExcelUtil.export(response, "培训报名清册数据"+ DateUtil.time(), "培训报名清册数据表", list, TrainingRegistrationExcel.class);
//   }
   /**
    * 导出报名数数据
    * @param response
    * @param trainingRegistration 培训报名对象
    */
   @GetMapping("export-apply-info")
   public void exportApplyInfo(HttpServletResponse response,TrainingRegistrationVo trainingRegistration) {
      List<TrainingRegistrationExcel> list = trainingRegistrationService.getTrainingRegistrationExcelList(trainingRegistration);
      ExcelUtil.export(response, "报名清册数据"+ DateUtil.time(), "报名清册数据表", list, TrainingRegistrationExcel.class);
   }