From 7c2c09439da3dccf1e032e89e1cb950b8fa1cc26 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Tue, 01 Mar 2022 20:09:57 +0800
Subject: [PATCH] 健康证,合同基础接口编写

---
 src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java |   25 ++++++++++++++++++-------
 1 files changed, 18 insertions(+), 7 deletions(-)

diff --git a/src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java b/src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java
index 86a8c07..f16ad6e 100644
--- a/src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java
+++ b/src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java
@@ -25,6 +25,7 @@
 import org.springblade.modules.exam.service.ExamPaperService;
 import org.springblade.modules.system.entity.User;
 import org.springblade.modules.system.service.IUserService;
+import org.springblade.modules.system.service.MyAsyncService;
 import org.springblade.modules.system.vo.UserVO;
 import org.springblade.modules.training.entity.TrainingRegistration;
 import org.springblade.modules.training.excel.TrainingRegistrationExcel;
@@ -33,6 +34,7 @@
 import org.springblade.modules.training.vo.TrainingRegistrationVo;
 import org.springblade.modules.vip.service.UserVipService;
 import org.springblade.modules.vip.service.VipTopicService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
@@ -62,6 +64,8 @@
 	private final UserVipService userVipService;
 
 	private final VipTopicService vipTopicService;
+	private final MyAsyncService myAsyncService;
+
 
 	/**
 	 * 自定义分页
@@ -165,7 +169,8 @@
 			+ "," + "'" + trainingRegistration.getIsExam() + "'"
 			+ "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" +
 			"update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
-		FtpUtil.sqlFileUpload(sql);
+		//FtpUtil.sqlFileUpload(sql);
+		myAsyncService.FTP(sql);
 	}
 
 
@@ -293,7 +298,8 @@
 				",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'" +
 				" " +"where id = " + "'" + trainingRegistration.getId() + "';" +
 				"update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
-		FtpUtil.sqlFileUpload(s);
+		//FtpUtil.sqlFileUpload(s);
+		myAsyncService.FTP(s);
 	}
 
 	/**
@@ -626,7 +632,8 @@
 					"," + "'" + examPaper.getCreator() +"'" +
 					"," + "'" + creatorTimeFormat +"'" +
 					","  +"'" + examPaper.getAuditStatus() + "'" + ")";
-				FtpUtil.sqlFileUpload(s);
+				//FtpUtil.sqlFileUpload(s);
+				myAsyncService.FTP(s);
 
 
 				//修改报名信息
@@ -641,7 +648,8 @@
 							"update sys_training_registration set train_exam_id = " + "'" + trainingRegistration.getTrainExamId() + "'"
 								+ ",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'"
 								+ " " + "where id = " + "'" + trainingRegistration.getId() + "'";
-						FtpUtil.sqlFileUpload(s1);
+						//FtpUtil.sqlFileUpload(s1);
+						myAsyncService.FTP(s1);
 					}
 				});
 			}
@@ -697,7 +705,8 @@
 				"," + "'" + examPaper.getCreator() +"'" +
 				"," + "'" + creatorTimeFormat +"'" +
 				","  +"'" + examPaper.getAuditStatus() + "'" + ")";
-			FtpUtil.sqlFileUpload(s);
+			//FtpUtil.sqlFileUpload(s);
+			myAsyncService.FTP(s);
 
 			//修改报名信息
 			list.forEach(id ->{
@@ -714,7 +723,8 @@
 							"update sys_training_registration set train_exam_id = " + "'" + trainingRegistration.getTrainExamId() + "'"
 								+ ",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'"
 								+ " " + "where id = " + "'" + trainingRegistration.getId() + "'";
-						FtpUtil.sqlFileUpload(s1);
+						//FtpUtil.sqlFileUpload(s1);
+						myAsyncService.FTP(s1);
 					}
 				}
 			});
@@ -739,7 +749,8 @@
 		String s1 =
 			"update sys_training_registration set vip_status = " + "'" + trainingRegistration.getVipStatus() + "'"
 				+ " " + "where id = " + "'" + trainingRegistration.getId() + "'";
-		FtpUtil.sqlFileUpload(s1);
+		//FtpUtil.sqlFileUpload(s1);
+		myAsyncService.FTP(s1);
 		//更新并返回数据
 		return R.data(trainingRegistrationService.updateById(trainingRegistration));
 	}

--
Gitblit v1.9.3