数据同步修改

Administrator

2021-08-23 bf93d530532a5910dae6676d23e13aed607baef9

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

@@ -41,7 +41,6 @@
import java.util.*;

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

/**
 * 考试报名服务实现类
@@ -132,16 +131,7 @@
                  "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);
               String response = String.valueOf((new Date()).getTime());
               OutJson.createJsonFile(json, "d:/", "w"+response);
               FileInputStream in = null;
               try {
                  in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
               } catch (FileNotFoundException e) {
                  e.printStackTrace();
               }
               FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
               FtpUtil.sqlFileUpload(s);
            }else {
               if (user1.getIsApply()!=1) {
                  Apply apply1 = new Apply();
@@ -162,16 +152,7 @@
                     "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);
                  String response = String.valueOf((new Date()).getTime());
                  OutJson.createJsonFile(json, "d:/", "w"+response);
                  FileInputStream in = null;
                  try {
                     in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
                  } catch (FileNotFoundException e) {
                     e.printStackTrace();
                  }
                  FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
                  FtpUtil.sqlFileUpload(s);
               }
            }
         }