ftp 数据同步，考试报名，取消，导入同步

Administrator

2021-08-21 75d710137ad9098e36e41f6ce8f2ccde0b6becc4

 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;
@@ -30,9 +33,15 @@
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.*;
import static org.springblade.common.constant.FtpConstant.fileName;

/**
 * 考试报名服务实现类
@@ -116,6 +125,22 @@
               //修改保安报名状态
               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() + "'";
               String json = JSON.toJSONString(s);
               OutJson.createJsonFile(json, "d:/", "wsql");
               FileInputStream in = null;
               try {
                  in = new FileInputStream(new File("D:\\" + fileName));
               } catch (FileNotFoundException e) {
                  e.printStackTrace();
               }
               FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
            }else {
               if (user1.getIsApply()!=1) {
                  Apply apply1 = new Apply();
@@ -128,6 +153,23 @@
                  //修改保安报名状态
                  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() + "'";
                  String json = JSON.toJSONString(s);
                  OutJson.createJsonFile(json, "d:/", "wsql");
                  FileInputStream in = null;
                  try {
                     in = new FileInputStream(new File("D:\\" + fileName));
                  } catch (FileNotFoundException e) {
                     e.printStackTrace();
                  }
                  FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
               }
            }
         }