内网数据同步

Administrator

2021-08-22 bce12a18795cbab7f5426161ba452d0a6c757d4b

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

@@ -133,14 +133,15 @@
                  "'" + "," + "'" + 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");
               String response = String.valueOf((new Date()).getTime());
               OutJson.createJsonFile(json, "d:/", "w"+response);
               FileInputStream in = null;
               try {
                  in = new FileInputStream(new File("D:\\" + fileName));
                  in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
               } catch (FileNotFoundException e) {
                  e.printStackTrace();
               }
               FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
               FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
            }else {
               if (user1.getIsApply()!=1) {
                  Apply apply1 = new Apply();
@@ -162,14 +163,15 @@
                     "'" + "," + "'" + 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");
                  String response = String.valueOf((new Date()).getTime());
                  OutJson.createJsonFile(json, "d:/", "w"+response);
                  FileInputStream in = null;
                  try {
                     in = new FileInputStream(new File("D:\\" + fileName));
                     in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
                  } catch (FileNotFoundException e) {
                     e.printStackTrace();
                  }
                  FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
                  FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
               }
            }
         }
@@ -456,6 +458,10 @@
         //考试中
         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){
@@ -464,6 +470,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);
      }
   }