From e3b9ce496c6948825ec4af9c6d84a7202bb72e56 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Mon, 13 Jun 2022 14:46:36 +0800
Subject: [PATCH] 保安员证编号处理逻辑修改

---
 src/main/java/org/springblade/modules/quartz/task/Task.java |   33 +++++++++++++++++----------------
 1 files changed, 17 insertions(+), 16 deletions(-)

diff --git a/src/main/java/org/springblade/modules/quartz/task/Task.java b/src/main/java/org/springblade/modules/quartz/task/Task.java
index 78ae35f..f4ed301 100644
--- a/src/main/java/org/springblade/modules/quartz/task/Task.java
+++ b/src/main/java/org/springblade/modules/quartz/task/Task.java
@@ -78,20 +78,22 @@
 						String sql = OutJson.stringReplace(s);
 						String[] split = sql.split(";");//以逗号分割
 						for (String sqls : split) {
-							//判断是否是新增,删除,修改
-							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);
+							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);
+								}
 							}
 						}
 						//删除本地文件
@@ -152,7 +154,6 @@
 						//删除本地文件
 						MysqlCenlint.deletess(fileName);
 						//删除 ftp 文件
-//							ftp.dele(fileName);
 						FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
 					}
 					if(substring1.equals("u")){
@@ -194,7 +195,7 @@
 			}
 		} catch (Exception e) {
 			MysqlCenlint.deletess(fileName);
-//			FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
+			FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
 			e.printStackTrace();
 		} finally {
 			try {

--
Gitblit v1.9.3