保安员新增同步编号问题

Administrator

2022-06-16 2ebca060a47784db76369a4aa84f63293da9be33

 src/main/java/org/springblade/modules/quartz/task/Task.java

@@ -78,22 +78,20 @@
                  String sql = OutJson.stringReplace(s);
                  String[] split = sql.split(";");//以逗号分割
                  for (String sqls : split) {
                     if (sqls.length()>1) {
                        //判断是否是新增，删除，修改
                        String substring = sqls.substring(0, 2);
                        //新增
                        if (substring.equals("in")) {
                           //运行sql语句
                           MysqlCenlint.inster(sqls);
                        }
                        //修改
                        else if (substring.equals("up")) {
                           MysqlCenlint.update(sqls);
                        }
                        //删除
                        else {
                           MysqlCenlint.delete(sqls);
                        }
                     //判断是否是新增，删除，修改
                     String substring = sqls.substring(0, 2);
                     //新增
                     if (substring.equals("in")) {
                        //运行sql语句
                        MysqlCenlint.inster(sqls);
                     }
                     //修改
                     else if (substring.equals("up")) {
                        MysqlCenlint.update(sqls);
                     }
                     //删除
                     else {
                        MysqlCenlint.delete(sqls);
                     }
                  }
                  //删除本地文件
@@ -170,13 +168,26 @@
                  FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
               }
               //考试实操成绩导入
               if(substring1.equals("e")){
//               if(substring1.equals("e")){
//                  //把文件下载到本地
//                  FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
//                  //获取对象字符串
//                  String json = OutJson.TestJson(fileName);
//                  //考试实操成绩数据处理
//                  DataHanlder.handlerUserExamScore(json);
//                  //删除本地文件
//                  MysqlCenlint.deletess(fileName);
//                  //删除 ftp 文件
//                  FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
//               }
               //管理人员保安员导入并生成保安证编号
               if(substring1.equals("p")){
                  //把文件下载到本地
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
                  //获取对象字符串
                  String json = OutJson.TestJson(fileName);
                  //考试实操成绩数据处理
                  DataHanlder.handlerUserExamScore(json);
                  DataHanlder.handlerSecurityPaperList(json);
                  //删除本地文件
                  MysqlCenlint.deletess(fileName);
                  //删除 ftp 文件
@@ -198,14 +209,14 @@
         FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
         e.printStackTrace();
      } finally {
         try {
            ftp.logout();
         } catch (IOException e) {
            e.printStackTrace();
         }
         //如果ftp 没有关闭,则关闭ftp
         if (ftp.isConnected()) {
            try {
               ftp.logout();
            } catch (IOException e) {
               e.printStackTrace();
            }
            try {
               ftp.disconnect();
            } catch (IOException io) {
               io.printStackTrace();