From 8d43111bd0e598bc0b2014cbfa69a32e74959dff Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Wed, 15 Dec 2021 19:24:05 +0800
Subject: [PATCH] ftp sql 同步封装

---
 src/main/java/org/springblade/modules/exam/service/impl/ExamScoreServiceImpl.java |  156 +++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 118 insertions(+), 38 deletions(-)

diff --git a/src/main/java/org/springblade/modules/exam/service/impl/ExamScoreServiceImpl.java b/src/main/java/org/springblade/modules/exam/service/impl/ExamScoreServiceImpl.java
index c918736..35d1e7b 100644
--- a/src/main/java/org/springblade/modules/exam/service/impl/ExamScoreServiceImpl.java
+++ b/src/main/java/org/springblade/modules/exam/service/impl/ExamScoreServiceImpl.java
@@ -192,7 +192,7 @@
 				//数据同步
 				String s =
 					"update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() + " " +"where id = " + "'" + trainingRegistration1.getId() + "';" +
-						"update blade_user set is_apply = " + user.getIsApply() + " " +"where id = " + "'" + user.getId() + "'";
+						"update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
 				FtpUtil.sqlFileUpload(s);
 			}
 
@@ -273,45 +273,44 @@
 							if (null!=examScore) {
 								//查询当前保安信息
 								UserVO user = userService.getUserAgeById(Long.parseLong(examScore.getUserId()));
+								//设置实操成绩
 								examScore.setLearnGrade(examScoreExcel.getLearnGrade());
-								if (examScore.getTheoryGrade() >= 60 && examScore.getLearnGrade() >= 60) {
-									//合格
-									examScore.setQualified(0);
-									//修改制证状态为未制证
-									user.setUserType(7);
-									//正式考试通过生成保安证编号
-//							if (examPaper.getExamType()==1) {
-									//如果已有保安证编号,不更新用户信息
-									if (null==user.getSecuritynumber() || user.getSecuritynumber().equals("")) {
-										//去生成保安证编号
-										String pre = SecurityPaperUtil.getSecurityPaper();
-										//查询当前年份已有的保安证编号
-										int count = userService.getSecurityPaperCount(pre);
-										String result = null;
-										if (count == 0) {
-											result = pre + "00001";
-										} else {
-											//格式化
-											DecimalFormat decimalFormat = new DecimalFormat("00000");
-											count++;
-											result = pre + (decimalFormat.format(count));
-										}
-										user.setSecuritynumber(result);
-										//发证日期
-//								user.setPaperTime(new Date());
-										//修改为持证保安
-										user.setHold("1");
-										user.setUpdateTime(new Date());
-										//更新保安数据
-										userService.updateById(user);
+								if (null!=examScore.getTheoryGrade()){
+									if (examScore.getTheoryGrade() >= 60 && examScore.getLearnGrade() >= 60) {
+										//合格
+										examScore.setQualified(0);
+										//修改制证状态为未制证
+										user.setUserType(7);
+										//如果已有保安证编号,不更新用户信息
+										if (null == user.getSecuritynumber() || user.getSecuritynumber().equals("")) {
+											//去生成保安证编号
+											String pre = SecurityPaperUtil.getSecurityPaper();
+											//查询当前年份已有的保安证编号
+											int count = userService.getSecurityPaperCount(pre);
+											String result = null;
+											if (count == 0) {
+												result = pre + "00001";
+											} else {
+												//格式化
+												DecimalFormat decimalFormat = new DecimalFormat("00000");
+												count++;
+												result = pre + (decimalFormat.format(count));
+											}
+											user.setSecuritynumber(result);
+											//修改为持证保安
+											user.setHold("1");
+											user.setUpdateTime(new Date());
+											//更新保安数据
+											userService.updateById(user);
 
-										String s1 =
-											"update blade_user set hold = " + "'" + user.getHold() + "'" +
-												",securitynumber = " + "'" + user.getSecuritynumber() + "'" +
-												",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
-												",user_type = " + "'" + user.getUserType() + "'" +
-												" " + "where id = " + "'" + user.getId() + "'";
-										FtpUtil.sqlFileUpload(s1);
+											String s1 =
+												"update blade_user set hold = " + "'" + user.getHold() + "'" +
+													",securitynumber = " + "'" + user.getSecuritynumber() + "'" +
+													",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
+													",user_type = " + "'" + user.getUserType() + "'" +
+													" " + "where id = " + "'" + user.getId() + "'";
+											FtpUtil.sqlFileUpload(s1);
+										}
 									}
 								} else {
 									//不合格
@@ -716,4 +715,85 @@
 		});
 		return false;
 	}
+
+	/**
+	 * 点击了开始考试后超过60分钟后再考试的,计算之前的考试成绩
+	 * @param examScore
+	 * @return
+	 */
+	@Override
+	public boolean getExamScore(ExamScoreVO examScore) {
+		//查询考试成绩
+		ExamScore score = this.getById(examScore.getId());
+		//查询考试记录
+		ExamAnswerRecord examAnswerRecord = new ExamAnswerRecord();
+		examAnswerRecord.setScoreId(examScore.getId());
+		List<ExamAnswerRecord> list = examAnswerRecordService.list(Condition.getQueryWrapper(examAnswerRecord));
+		//设置默认理论成绩为0
+		int count = 0;
+		//计算成绩
+		if (list.size()>0){
+			//成绩相加
+			count = list.stream().mapToInt(ExamAnswerRecord::getAnswerScore).sum();
+
+		}else {
+			//没有考试记录,本次考试理论成绩为 0
+			count = 0;
+		}
+		int age = 0;
+		UserVO user = new UserVO();
+		//查询培训报名数据
+		TrainingRegistration trainingRegistration = new TrainingRegistration();
+		trainingRegistration.setCandidateNo(score.getCandidateNo());
+		trainingRegistration.setCancel(1);
+		TrainingRegistration trainingRegistration1 = trainingRegistrationService.getOne(Condition.getQueryWrapper(trainingRegistration));
+		//查询用户年龄,根据年龄计算总分
+		user = userService.getUserAgeById(Long.parseLong(trainingRegistration1.getUserId()));
+		//修改用户的培训状态,理论考试结束
+		user.setIsTrain(3);
+		age = user.getAge();
+		userService.updateById(user);
+		//修改为已考试
+		trainingRegistration1.setIsExam(2);
+		trainingRegistrationService.updateById(trainingRegistration1);
+
+		//数据同步
+		String s =
+			"update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() + " " +"where id = " + "'" + trainingRegistration1.getId() + "';" +
+				"update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
+		FtpUtil.sqlFileUpload(s);
+
+		//设置理论得分
+		score.setTheoryGrade(count);
+		//计算总成绩,此时没有实操成绩,总成绩为实操成绩和理论成绩和的一半
+		if (age<=50) {
+			score.setAllGrade(Math.round(count / 2));
+		}
+		if (age>50) {
+			score.setAllGrade(Integer.parseInt(String.valueOf(Math.round(count*0.5))));
+		}
+		//设置状态
+		if (count>=60){
+			score.setQualified(2);
+		}else {
+			score.setQualified(1);
+		}
+		//修改成绩数据
+		int i = baseMapper.updateById(score);
+
+		String s1 =
+			"update exam_score set exam_id = " + score.getExamId() +
+				",theory_grade = " + "'" + score.getTheoryGrade() + "'" +
+				",all_grade = " + "'" + score.getAllGrade() + "'" +
+				",exam_end_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:dd").format(new Date()) + "'" +
+				",qualified = " + "'" + score.getQualified() + "'" +
+				" " +"where id = " + "'" + score.getId() + "'";
+		FtpUtil.sqlFileUpload(s1);
+
+		if (i>0){
+			//返回结果
+			return true;
+		}
+		return false;
+	}
 }

--
Gitblit v1.9.3