From cc057177b2fb17aee9a173a6adbabdc578fd74c7 Mon Sep 17 00:00:00 2001
From: tangzy <tangzy123456>
Date: Mon, 06 Dec 2021 10:30:44 +0800
Subject: [PATCH] 1.许可

---
 src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java |  533 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 518 insertions(+), 15 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 abefd1d..23d3698 100644
--- a/src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java
+++ b/src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java
@@ -4,17 +4,43 @@
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import lombok.AllArgsConstructor;
+import net.sourceforge.pinyin4j.PinyinHelper;
+import net.sourceforge.pinyin4j.format.HanyuPinyinCaseType;
+import net.sourceforge.pinyin4j.format.HanyuPinyinOutputFormat;
+import net.sourceforge.pinyin4j.format.HanyuPinyinToneType;
+import net.sourceforge.pinyin4j.format.exception.BadHanyuPinyinOutputFormatCombination;
 import org.springblade.common.utils.arg;
+import org.springblade.core.excel.util.ExcelUtil;
 import org.springblade.core.mp.support.Condition;
 import org.springblade.core.mp.support.Query;
 import org.springblade.core.tool.api.R;
+import org.springblade.core.tool.utils.DateUtil;
 import org.springblade.core.tool.utils.Func;
+import org.springblade.modules.FTP.FtpUtil;
+import org.springblade.modules.apply.entity.Apply;
+import org.springblade.modules.apply.excel.ApplyImporter;
+import org.springblade.modules.apply.excel.ApplyInfoExcel;
+import org.springblade.modules.apply.vo.ApplyVO;
+import org.springblade.modules.exam.entity.ExamPaper;
+import org.springblade.modules.exam.entity.ExamScore;
+import org.springblade.modules.exam.excel.ExamScoreExcel;
+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.training.entity.TrainExam;
 import org.springblade.modules.training.entity.TrainingRegistration;
+import org.springblade.modules.training.excel.TrainingRegistrationExcel;
+import org.springblade.modules.training.excel.TrainingRegistrationImporter;
+import org.springblade.modules.training.service.TrainExamService;
 import org.springblade.modules.training.service.TrainingRegistrationService;
 import org.springblade.modules.training.vo.TrainingRegistrationVo;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
-import java.util.Date;
+import javax.servlet.http.HttpServletResponse;
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
 
 /**
  * @author zhongrj
@@ -27,6 +53,10 @@
 public class TrainingRegistrationController {
 
 	private final TrainingRegistrationService trainingRegistrationService;
+
+	private final IUserService userService;
+
+	private final ExamPaperService examPaperService;
 
 	/**
 	 * 自定义分页
@@ -45,8 +75,257 @@
 	 */
 	@PostMapping("/save")
 	@ApiOperation(value = "新增", notes = "传入trainingRegistration")
-	public R save(@RequestBody TrainingRegistration trainingRegistration) throws Exception {
-		return R.status(trainingRegistrationService.save(trainingRegistration));
+	public R save(@RequestBody TrainingRegistration trainingRegistration){
+		//查询人员是否已报名
+		User user = userService.getById(trainingRegistration.getUserId());
+		if (null==user.getIsTrain()){
+			//已报名
+			trainingRegistration.setCancel(1);
+			//默认为未考试状态
+			trainingRegistration.setIsExam(1);
+			//未提交考试审核
+			trainingRegistration.setAuditStatus(4);
+			trainingRegistration.setTrainingTime(new Date());
+			//报名
+			trainingRegistrationService.save(trainingRegistration);
+			//修改保安报名状态
+			User user1 = new User();
+			user1.setId(Long.parseLong(trainingRegistration.getUserId()));
+			user1.setIsTrain(1);
+			userService.updateById(user1);
+
+			//内网数据同步
+			saveTrainingRegistration(trainingRegistration,user1);
+
+			return R.data(200,"报名成功");
+		}else {
+			if (1==user.getIsTrain()){
+				return R.data(201,"已报名,不能重复报名");
+			}
+			if (1!=user.getIsTrain()){
+				//已报名
+				trainingRegistration.setCancel(1);
+				//默认为未考试状态
+				trainingRegistration.setIsExam(1);
+				//未提交考试审核
+				trainingRegistration.setAuditStatus(4);
+				trainingRegistration.setTrainingTime(new Date());
+				//报名
+				trainingRegistrationService.save(trainingRegistration);
+				//修改保安报名状态
+				User user1 = new User();
+				user1.setId(Long.parseLong(trainingRegistration.getUserId()));
+				user1.setIsTrain(1);
+				userService.updateById(user1);
+
+				//内网数据同步
+				saveTrainingRegistration(trainingRegistration,user1);
+
+				return R.data(200,"报名成功");
+			}
+		}
+		return R.data(202,"报名失败");
+	}
+
+	/**
+	 * 报名
+	 */
+	private void saveTrainingRegistration(TrainingRegistration trainingRegistration,User user1){
+		String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
+		Long id = trainingRegistration.getId();
+		String s = "insert into sys_training_registration(id,training_unit_id,training_time,cancel,user_id,is_exam,audit_status) " +
+			"values(" + "'" + id + "'"
+			+ "," + "'" + trainingRegistration.getTrainingUnitId() +"'"
+			+ "," + "'" + formatStr +"'"
+			+ "," + "'" + trainingRegistration.getCancel() + "'"
+			+ "," + "'" + trainingRegistration.getUserId() + "'"
+			+ "," + "'" + trainingRegistration.getIsExam() + "'"
+			+ "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" +
+			"update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
+		FtpUtil.sqlFileUpload(s);
+	}
+
+
+	/**
+	 * 取消报名
+	 * @param trainingRegistration 考试报名信息对象
+	 */
+	@PostMapping("/cancelTrain")
+	public R cancelApply(@RequestBody TrainingRegistration trainingRegistration){
+		//查询人员是否已报名
+		User user = userService.getById(trainingRegistration.getUserId());
+		if(null==user.getIsTrain()){
+			trainingRegistration.setCancel(2);
+			boolean status = trainingRegistrationService.updateById(trainingRegistration);
+			//修改保安报名状态
+			user.setIsTrain(2);
+			userService.updateById(user);
+
+			//数据同步
+			cancelTrainingRegistrationSync(trainingRegistration,user);
+
+			if (status){
+				return R.data(200,"取消报名成功");
+			}
+		}else {
+			if(user.getIsTrain()==1){
+				trainingRegistration.setCancel(2);
+				boolean status = trainingRegistrationService.updateById(trainingRegistration);
+				//修改保安报名状态
+				user.setIsTrain(2);
+				userService.updateById(user);
+
+				//数据同步
+				cancelTrainingRegistrationSync(trainingRegistration,user);
+
+				if (status){
+					return R.data(200,"取消报名成功");
+				}
+
+
+
+			}else {
+				return R.data(201,"尚未报名");
+			}
+
+		}
+		return R.data(202,"取消报名失败");
+	}
+
+
+	/**
+	 * 审核通过
+	 * @param trainingRegistration 考试报名信息对象
+	 */
+	@PostMapping("/auditSucess")
+	public R auditSucess(@RequestBody TrainingRegistration trainingRegistration){
+		//查询人员信息
+		User user = userService.getById(trainingRegistration.getUserId());
+		boolean status = false;
+		if (null!=user){
+			//修改为已报名状态
+			user.setIsTrain(1);
+			userService.updateById(user);
+
+			trainingRegistration.setAuditStatus(1);
+			trainingRegistration.setCancel(1);
+			status = trainingRegistrationService.updateById(trainingRegistration);
+
+			//数据同步
+			cancelTrainingRegistrationSync(trainingRegistration,user);
+		}
+		return R.data(status);
+	}
+
+
+	/**
+	 * 取消报名,并设置为审核不通过
+	 * @param trainingRegistration 考试报名信息对象
+	 */
+	@PostMapping("/cancelTrainAudit")
+	public R cancelApplyAudit(@RequestBody TrainingRegistration trainingRegistration){
+		//查询人员是否已报名
+		User user = userService.getById(trainingRegistration.getUserId());
+		if(null==user.getIsTrain()){
+			trainingRegistration.setCancel(2);
+			trainingRegistration.setAuditStatus(2);
+			boolean status = trainingRegistrationService.updateById(trainingRegistration);
+			//修改保安报名状态
+			user.setIsTrain(2);
+			userService.updateById(user);
+
+			//数据同步
+			cancelTrainingRegistrationSync(trainingRegistration,user);
+
+			if (status){
+				return R.data(200,"取消报名成功");
+			}
+		}else {
+			if(user.getIsTrain()==1){
+				trainingRegistration.setCancel(2);
+				trainingRegistration.setAuditStatus(2);
+				boolean status = trainingRegistrationService.updateById(trainingRegistration);
+				//修改保安报名状态
+				user.setIsTrain(2);
+				userService.updateById(user);
+
+				//数据同步
+				cancelTrainingRegistrationSync(trainingRegistration,user);
+
+				if (status){
+					return R.data(200,"取消报名成功");
+				}
+
+			}else {
+				return R.data(201,"尚未报名");
+			}
+
+		}
+		return R.data(202,"取消报名失败");
+	}
+
+
+	/**
+	 * 取消报名同步
+	 */
+	private void cancelTrainingRegistrationSync(TrainingRegistration trainingRegistration,User user){
+		String s =
+			"update sys_training_registration set cancel = " + trainingRegistration.getCancel() +
+				",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'" +
+				" " +"where id = " + "'" + trainingRegistration.getId() + "';" +
+				"update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
+		FtpUtil.sqlFileUpload(s);
+	}
+
+	/**
+	 * 批量报名
+	 * @param trainingRegistration 考试报名信息对象
+	 */
+	@PostMapping("/batchTrain")
+	public R batchApply(@RequestBody TrainingRegistrationVo trainingRegistration){
+		List<String> list = Arrays.asList(trainingRegistration.getUserIds().split(","));
+		list.forEach(userId ->{
+			User user = userService.getById(userId);
+			//未报名的新增,已报名的不做处理
+			if (null==user.getIsTrain()) {
+				TrainingRegistration trainingRegistration1 = new TrainingRegistration();
+				trainingRegistration1.setCancel(1);
+				//默认为未考试状态
+				trainingRegistration1.setIsExam(1);
+				//未提交考试审核
+				trainingRegistration.setAuditStatus(4);
+				trainingRegistration1.setTrainingTime(new Date());
+				trainingRegistration1.setUserId(userId);
+				trainingRegistration1.setTrainingUnitId(trainingRegistration.getTrainingUnitId());
+				trainingRegistrationService.save(trainingRegistration1);
+				//修改保安报名状态
+				user.setIsTrain(1);
+				userService.updateById(user);
+
+				//数据同步
+				saveTrainingRegistration(trainingRegistration1,user);
+			}else {
+				if (user.getIsTrain()!=1) {
+					TrainingRegistration trainingRegistration1 = new TrainingRegistration();
+					trainingRegistration1.setCancel(1);
+					//默认为未考试状态
+					trainingRegistration1.setIsExam(1);
+					//未提交考试审核
+					trainingRegistration.setAuditStatus(4);
+					trainingRegistration1.setTrainingTime(new Date());
+					trainingRegistration1.setUserId(userId);
+					trainingRegistration1.setTrainingUnitId(trainingRegistration.getTrainingUnitId());
+					trainingRegistrationService.save(trainingRegistration1);
+					//修改保安报名状态
+					user.setIsTrain(1);
+					userService.updateById(user);
+
+					//数据同步
+					saveTrainingRegistration(trainingRegistration1,user);
+				}
+			}
+		});
+		return R.data(200,"报名成功");
 	}
 
 	/**
@@ -54,8 +333,7 @@
 	 * @param trainingRegistration 报名培训信息对象
 	 */
 	@PostMapping("/update")
-	public R update(@RequestBody TrainingRegistration trainingRegistration) throws Exception {
-		arg.test01(arg.url+"/trainingRegistration/update",trainingRegistration);
+	public R update(@RequestBody TrainingRegistration trainingRegistration){
 		return R.status(trainingRegistrationService.updateById(trainingRegistration));
 	}
 
@@ -64,15 +342,8 @@
 	 * @param trainingRegistration 报名培训信息对象
 	 */
 	@PostMapping("/submit")
-	public R submit(@RequestBody TrainingRegistration trainingRegistration) throws Exception {
-		if (null!=trainingRegistration.getId()){
-			trainingRegistration.setTrainingTime(new Date());
-			trainingRegistration.setCancel(1);
-			//默认报名未考试状态
-			trainingRegistration.setIsExam(1);
-		}
-		arg.test01(arg.url+"/trainingRegistration/submit",trainingRegistration);
-		return R.status(trainingRegistrationService.saveOrUpdate(trainingRegistration));
+	public R submit(@RequestBody TrainingRegistration trainingRegistration){
+		return R.data(trainingRegistrationService.saveOrUpdate(trainingRegistration));
 	}
 
 	/**
@@ -81,7 +352,6 @@
 	 */
 	@PostMapping("/remove")
 	public R remove(@ApiParam(value = "主键集合") @RequestParam String ids) {
-		arg.sendPostRemoveByIds(arg.url+"/trainingRegistration/remove",ids);
 		return R.status(trainingRegistrationService.removeByIds(Func.toLongList(ids)));
 	}
 
@@ -96,4 +366,237 @@
 		return R.data(detail);
 	}
 
+//	/**
+//	 * 导出报名数数据
+//	 * @param response
+//	 * @param trainingRegistration 培训报名对象
+//	 */
+//	@GetMapping("export-apply")
+//	@ApiOperation(value = "导出报名清册")
+//	public void exportApply(HttpServletResponse response,TrainingRegistrationVo trainingRegistration) {
+//		List<TrainingRegistrationExcel> list = trainingRegistrationService.getTrainingRegistrationExcelList(trainingRegistration);
+//		ExcelUtil.export(response, "培训报名清册数据"+ DateUtil.time(), "培训报名清册数据表", list, TrainingRegistrationExcel.class);
+//	}
+
+
+
+	/**
+	 * 导入报名考试数据
+	 */
+	@PostMapping("import-trainingRegistration")
+	@ApiOperation(value = "导入培训报名数据", notes = "传入excel")
+	public R importUser(MultipartFile file, Integer isCovered,Long examId) {
+		TrainingRegistrationImporter trainingRegistrationImporter = new TrainingRegistrationImporter(trainingRegistrationService, false,examId);
+		ExcelUtil.save(file, trainingRegistrationImporter, TrainingRegistrationExcel.class);
+		return R.success("操作成功");
+	}
+
+	/**
+	 * 导出模板
+	 */
+	@GetMapping("export-template")
+	@ApiOperation(value = "导出模板")
+	public void exportUser(HttpServletResponse response) {
+		List<TrainingRegistrationExcel> list = new ArrayList<>();
+		ExcelUtil.export(response, "培训报名数据模板", "培训报名数据表", list, TrainingRegistrationExcel.class);
+	}
+
+
+	/**
+	 * 生成准考证号码
+	 * @param trainingRegistration 考试报名信息对象
+	 */
+	private String getCandidateNo(TrainingRegistration trainingRegistration) {
+		//获取考试信息
+		ExamPaper examPaper = examPaperService.getById(trainingRegistration.getTrainExamId());
+		if (null!=examPaper.getStartTime()){
+			String format = new SimpleDateFormat("yyyy-MM-dd").format(examPaper.getStartTime());
+			String year = format.substring(2,4);
+			String quarter  = null;
+			String months = null;
+			String days = null;
+			int month = Integer.parseInt(format.substring(5,7));
+			int day = Integer.parseInt(format.substring(8,10));
+			if (month>0 && month<=3){
+				quarter = "C";
+			}
+			if (month>3 && month<=6){
+				quarter = "X";
+			}
+			if (month>6 && month<=9){
+				quarter = "Q";
+			}
+			if (month>9 && month<=12){
+				quarter = "D";
+			}
+			if (month<=9){
+				months = "0" + month;
+			}
+			if (day<=9){
+				days = "0" + day;
+			}
+			//获取考试名称前缀,去除数字,字母
+			String examName
+				= examPaper.getExamName().replaceAll("\\s*", "").replaceAll("[^(\\u4e00-\\u9fa5)]", "").substring(0,1);
+
+			//前缀 = 年的最后两位  + 月份(两位) + 考试名称(中文拼音)首字母(去除数字,字母) + 考试类型 + 季度拼音首字母大写(春季就是 C)
+			String result = year
+				+ months
+				+ toFirstChar(examName).toUpperCase()
+				+ examPaper.getExamType()
+				+ quarter;
+			//查询是当前前缀已生成的数量
+			int count = trainingRegistrationService.getCandidateNoCount(result);
+			if (count==0){
+				return result + "0000";
+			}
+			//格式化
+			DecimalFormat decimalFormat = new DecimalFormat("0000");
+			//返回
+			return result + (decimalFormat.format(count++));
+		}
+		return null;
+	}
+
+
+	/**
+	 * 生成报名编号
+	 * @param apply 考试报名信息对象
+	 */
+	private String getApplyCode(Apply apply) {
+		//获取考试信息
+		ExamPaper examPaper = examPaperService.getById(apply.getExamId());
+		if (null!=examPaper.getStartTime()){
+			String format = new SimpleDateFormat("yyyy-MM-dd").format(examPaper.getStartTime());
+			String year = format.substring(2,4);
+			String quarter  = null;
+			String months = null;
+			String days = null;
+			int month = Integer.parseInt(format.substring(5,7));
+			int day = Integer.parseInt(format.substring(8,10));
+			if (month>0 && month<=3){
+				quarter = "C";
+			}
+			if (month>3 && month<=6){
+				quarter = "X";
+			}
+			if (month>6 && month<=9){
+				quarter = "Q";
+			}
+			if (month>9 && month<=12){
+				quarter = "D";
+			}
+			if (month<=9){
+				months = "0" + month;
+			}
+			if (day<=9){
+				days = "0" + day;
+			}
+			//获取考试名称前缀,去除数字,字母
+			String examName
+				= examPaper.getExamName().replaceAll("\\s*", "").replaceAll("[^(\\u4e00-\\u9fa5)]", "").substring(0,1);
+
+			//前缀 = 年的最后两位  + 月份(两位) + 考试名称(中文拼音)首字母(去除数字,字母) + 考试类型 + 季度拼音首字母大写(春季就是 C)
+			String result = year
+				+ months
+				+ toFirstChar(examName).toUpperCase()
+				+ examPaper.getExamType()
+				+ quarter;
+			//生成随机数
+			UUID uuid = UUID.randomUUID();
+			//返回
+			return result + uuid.toString().replaceAll("\\-","");
+		}
+		return null;
+	}
+
+	/**
+	 * 获取字符串拼音的第一个字母
+	 * @param chinese
+	 * @return
+	 */
+	private String toFirstChar(String chinese){
+		String pinyinStr = "";
+		char[] newChar = chinese.toCharArray();
+		//转为单个字符
+		HanyuPinyinOutputFormat defaultFormat = new HanyuPinyinOutputFormat();
+		defaultFormat.setCaseType(HanyuPinyinCaseType.LOWERCASE);
+		defaultFormat.setToneType(HanyuPinyinToneType.WITHOUT_TONE);
+		for (int i = 0; i < newChar.length; i++) {
+			if (newChar[i] > 128) {
+				try {
+					pinyinStr += PinyinHelper.toHanyuPinyinStringArray(newChar[i], defaultFormat)[0].charAt(0);
+				} catch (BadHanyuPinyinOutputFormatCombination e) {
+					e.printStackTrace();
+				}
+			}else{
+				pinyinStr += newChar[i];
+			}
+		}
+		return pinyinStr;
+	}
+
+
+	/**
+	 * 生成试卷,报名
+	 * @param trainingRegistrationVo 考试开始时
+	 */
+	@PostMapping("/batchExam")
+	public R batchExam(@RequestBody TrainingRegistrationVo trainingRegistrationVo){
+		if (trainingRegistrationVo.getNumber()==0){
+			return R.data("报名人数不能小于1人");
+		}else {
+			//查询已报名的人员前 number 个
+			//查询已报名未关联试卷的人员,同步报名列表
+			List<TrainingRegistration> applyIds = trainingRegistrationService.getTrainIds(trainingRegistrationVo);
+			if (applyIds.size()>0){
+				//生成考试
+				ExamPaper examPaper = new ExamPaper();
+				examPaper.setExamType(2);
+				examPaper.setStartTime(trainingRegistrationVo.getStartTime());
+				examPaper.setEndTime(trainingRegistrationVo.getEndTime());
+				Calendar instance = Calendar.getInstance();
+				instance.setTime(trainingRegistrationVo.getStartTime());
+				int year = instance.get(Calendar.YEAR);
+				int month = instance.get(Calendar.MONTH)+1;
+				int day = instance.get(Calendar.DAY_OF_MONTH);
+				String examName = year + "年" + month+ "月"+ day +"日" +"保安员证培训考试";
+				examPaper.setExamName(examName);
+				//待审核
+				examPaper.setAuditStatus(3);
+				//生成考试
+				examPaperService.save(examPaper);
+
+				Long sid = examPaper.getId();
+				String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examPaper.getStartTime());
+				String endTimeFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examPaper.getEndTime());
+				String s = "insert into ksxt_exam(id,exam_name,exam_type,start_time,end_time,audit_status) " +
+					"values(" + "'" + sid + "'" +
+					"," + "'" + examPaper.getExamName() + "'" +
+					"," + "'" + examPaper.getExamType() +"'" +
+					"," + "'" + format +"'" +
+					"," + "'" + endTimeFormat +"'" +
+					","  +"'" + examPaper.getAuditStatus() + "'" + ")";
+				FtpUtil.sqlFileUpload(s);
+
+
+				//修改报名信息
+				applyIds.forEach(trainingRegistration ->{
+					if(null==trainingRegistration.getTrainExamId() || trainingRegistration.getTrainExamId()=="") {
+						trainingRegistration.setTrainExamId(examPaper.getId().toString());
+						//提交考试审核
+						trainingRegistration.setAuditStatus(3);
+						trainingRegistrationService.updateById(trainingRegistration);
+
+						String s1 =
+							"update sys_training_registration set train_exam_id = " + "'" + trainingRegistration.getTrainExamId() + "'"
+								+ ",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'"
+								+ " " + "where id = " + "'" + trainingRegistration.getId() + "'";
+						FtpUtil.sqlFileUpload(s1);
+					}
+				});
+			}
+		}
+		return null;
+	}
 }

--
Gitblit v1.9.3