From 8b375fe00a241b3a769b82fe3dac8d1c9dce8a02 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Thu, 16 Jun 2022 14:36:07 +0800
Subject: [PATCH] 模拟考试修改
---
src/main/java/org/springblade/modules/apply/controller/ApplyController.java | 533 ++++++++++++++++++++++++++++++++++++++++++----------------
1 files changed, 385 insertions(+), 148 deletions(-)
diff --git a/src/main/java/org/springblade/modules/apply/controller/ApplyController.java b/src/main/java/org/springblade/modules/apply/controller/ApplyController.java
index 0adada7..8c65234 100644
--- a/src/main/java/org/springblade/modules/apply/controller/ApplyController.java
+++ b/src/main/java/org/springblade/modules/apply/controller/ApplyController.java
@@ -1,5 +1,6 @@
package org.springblade.modules.apply.controller;
+import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
@@ -9,13 +10,14 @@
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.FTP.OutJson;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyExcel;
import org.springblade.modules.apply.excel.ApplyImporter;
@@ -24,16 +26,26 @@
import org.springblade.modules.apply.vo.ApplyPaPerVO;
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.service.ExamPaperService;
+import org.springblade.modules.exam.service.ExamScoreService;
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.training.vo.TrainingRegistrationVo;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
+
+import static org.springblade.common.config.FtpConfig.*;
/**
* @author zhongrj
@@ -45,14 +57,22 @@
@RequestMapping("/apply")
public class ApplyController {
+ // @Autowired
private final ApplyService applyService;
+ // @Autowired
private final ExamPaperService examPaperService;
+ // @Autowired
private final IUserService userService;
+
+ // @Autowired
+ private final ExamScoreService examScoreService;
+ private final MyAsyncService myAsyncService;
/**
* 自定义分页
+ *
* @param query page,size
* @param apply 考试报名信息对象
*/
@@ -73,6 +93,7 @@
/**
* 新增报名
+ *
* @param apply 考试报名信息对象
*/
@PostMapping("/save")
@@ -80,7 +101,7 @@
public R save(@RequestBody Apply apply) {
//查询人员是否已报名
User user = userService.getById(apply.getUserId());
- if (null==user.getIsApply()){
+ if (null == user.getIsApply()) {
//默认通过
apply.setApplyStatus(2);
//默认为未考试状态
@@ -93,12 +114,16 @@
user1.setId(apply.getUserId());
user1.setIsApply(1);
userService.updateById(user1);
- return R.data(200,"报名成功");
- }else {
- if (1==user.getIsApply()){
- return R.data(201,"已报名，不能重复报名");
+
+ //内网数据同步
+ saveApply(apply, user1);
+
+ return R.data(200, "报名成功");
+ } else {
+ if (1 == user.getIsApply()) {
+ return R.data(201, "已报名，不能重复报名");
}
- if (2==user.getIsApply()){
+ if (1 != user.getIsApply()) {
//默认通过
apply.setApplyStatus(2);
//默认为未考试状态
@@ -110,15 +135,34 @@
user1.setId(apply.getUserId());
user1.setIsApply(1);
userService.updateById(user1);
- return R.data(200,"报名成功");
+
+ //内网数据同步
+ saveApply(apply, user1);
+
+ return R.data(200, "报名成功");
}
}
- return R.data(202,"报名失败");
+ return R.data(202, "报名失败");
+ }
+
+ /**
+ * 报名
+ */
+ private void saveApply(Apply apply, User user1) {
+ String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
+ Long id = apply.getId();
+ String s = "insert into sys_apply(id,user_id,apply_time,apply_status,is_exam) " +
+ "values(" + "'" + id + "'" + "," + "'" + apply.getUserId() + "'" + "," + "'" + formatStr +
+ "'" + "," + "'" + apply.getApplyStatus() + "'" + "," + "'" + apply.getIsExam() + "'" + ");" +
+ "update blade_user set is_apply = " + user1.getIsApply() + " " + "where id = " + "'" + user1.getId() + "'";
+ //FtpUtil.sqlFileUpload(s);
+ myAsyncService.FTP(s);
}
/**
* 修改
+ *
* @param apply 考试报名信息对象
*/
@PostMapping("/update")
@@ -128,10 +172,11 @@
/**
* 新增或修改
+ *
* @param apply 考试报名信息对象
*/
@PostMapping("/submit")
- public R submit(@RequestBody Apply apply){
+ public R submit(@RequestBody Apply apply) {
return R.data(applyService.saveOrUpdate(apply));
}
@@ -142,7 +187,18 @@
@PostMapping("import-apply")
@ApiOperation(value = "导入报名考试数据", notes = "传入excel")
public R importUser(MultipartFile file, Integer isCovered) {
- ApplyImporter applyImporter = new ApplyImporter(applyService, false);
+ ApplyImporter applyImporter = new ApplyImporter(applyService, false, null);
+ ExcelUtil.save(file, applyImporter, ApplyExcel.class);
+ return R.success("操作成功");
+ }
+
+ /**
+ * 导入报名考试数据(已生成考试)
+ */
+ @PostMapping("import-applys")
+ @ApiOperation(value = "导入报名考试数据", notes = "传入excel")
+ public R importUser(MultipartFile file, Integer isCovered, Long examId) {
+ ApplyImporter applyImporter = new ApplyImporter(applyService, false, examId);
ExcelUtil.save(file, applyImporter, ApplyExcel.class);
return R.success("操作成功");
}
@@ -160,61 +216,63 @@
/**
* 导出报名数数据
+ *
* @param response
- * @param apply 报名对象
+ * @param apply 报名对象
*/
@GetMapping("export-apply")
@ApiOperation(value = "导出报名清册")
- public void exportApply(HttpServletResponse response,Apply apply) {
+ public void exportApply(HttpServletResponse response, Apply apply) {
List<ApplyInfoExcel> list = applyService.getApplyExcelList(apply);
- ExcelUtil.export(response, "考试报名清册数据"+ DateUtil.time(), "考试报名清册数据表", list, ApplyInfoExcel.class);
+ ExcelUtil.export(response, "考试报名清册数据" + DateUtil.time(), "考试报名清册数据表", list, ApplyInfoExcel.class);
}
/**
* 生成准考证号码
+ *
* @param apply 考试报名信息对象
*/
private String getCandidateNo(Apply apply) {
//获取考试信息
ExamPaper examPaper = examPaperService.getById(apply.getExamId());
- if (null!=examPaper.getStartTime()){
+ if (null != examPaper.getStartTime()) {
String format = new SimpleDateFormat("yyyy-MM-dd").format(examPaper.getStartTime());
- String year = format.substring(2,4);
- String quarter = null;
+ String year = format.substring(2, 4);
+ String quarter = null;
String months = null;
- int month = Integer.parseInt(format.substring(5,7));
- int day = Integer.parseInt(format.substring(8,10));
+ int month = Integer.parseInt(format.substring(5, 7));
+ int day = Integer.parseInt(format.substring(8, 10));
String days = null;
- if (month>0 && month<=3){
+ if (month > 0 && month <= 3) {
quarter = "C";
}
- if (month>3 && month<=6){
+ if (month > 3 && month <= 6) {
quarter = "X";
}
- if (month>6 && month<=9){
+ if (month > 6 && month <= 9) {
quarter = "Q";
}
- if (month>9 && month<=12){
+ if (month > 9 && month <= 12) {
quarter = "D";
}
- if (month<=9){
+ if (month <= 9) {
months = "0" + month;
}
- if (day<=9){
+ if (day <= 9) {
days = "0" + day;
- }else {
- days = ""+day;
+ } else {
+ days = "" + day;
}
String type = null;
- if (examPaper.getExamType()==1){
+ if (examPaper.getExamType() == 1) {
type = "z";
}
- if (examPaper.getExamType()==2){
+ if (examPaper.getExamType() == 2) {
type = "m";
}
//获取考试名称前缀,去除数字，字母
String examName
- = examPaper.getExamName().replaceAll("\\s*", "").replaceAll("[^(\\u4e00-\\u9fa5)]", "").substring(0,1);
+ = examPaper.getExamName().replaceAll("\\s*", "").replaceAll("[^(\\u4e00-\\u9fa5)]", "").substring(0, 1);
//前缀 = 年的最后两位 + 月份（两位） + 考试名称（中文拼音）首字母（去除数字，字母） + 考试类型 + 季度拼音首字母大写（春季就是 C）
// String result = year
@@ -225,12 +283,12 @@
//前缀 = 年的最后两位 + 月份（两位） + 日 （两位） + 考试类型 正式考试 z 模拟考试 m
String result = year
- + months
- + days
- + type;
+ + months
+ + days
+ + type;
//查询是当前前缀已生成的数量
int count = applyService.getCandidateNoCount(result);
- if (count==0){
+ if (count == 0) {
return result + "0000";
}
//格式化
@@ -244,61 +302,63 @@
/**
* 生成报名编号
+ *
* @param apply 考试报名信息对象
*/
private String getApplyCode(Apply apply) {
//获取考试信息
ExamPaper examPaper = examPaperService.getById(apply.getExamId());
- if (null!=examPaper.getStartTime()){
+ if (null != examPaper.getStartTime()) {
String format = new SimpleDateFormat("yyyy-MM-dd").format(examPaper.getStartTime());
- String year = format.substring(2,4);
- String quarter = null;
+ 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){
+ 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){
+ if (month > 3 && month <= 6) {
quarter = "X";
}
- if (month>6 && month<=9){
+ if (month > 6 && month <= 9) {
quarter = "Q";
}
- if (month>9 && month<=12){
+ if (month > 9 && month <= 12) {
quarter = "D";
}
- if (month<=9){
+ if (month <= 9) {
months = "0" + month;
}
- if (day<=9){
+ if (day <= 9) {
days = "0" + day;
}
//获取考试名称前缀,去除数字，字母
String examName
- = examPaper.getExamName().replaceAll("\\s*", "").replaceAll("[^(\\u4e00-\\u9fa5)]", "").substring(0,1);
+ = examPaper.getExamName().replaceAll("\\s*", "").replaceAll("[^(\\u4e00-\\u9fa5)]", "").substring(0, 1);
//前缀 = 年的最后两位 + 月份（两位） + 考试名称（中文拼音）首字母（去除数字，字母） + 考试类型 + 季度拼音首字母大写（春季就是 C）
String result = year
- + months
- + toFirstChar(examName).toUpperCase()
- + examPaper.getExamType()
- + quarter;
+ + months
+ + toFirstChar(examName).toUpperCase()
+ + examPaper.getExamType()
+ + quarter;
//生成随机数
UUID uuid = UUID.randomUUID();
//返回
- return result + uuid.toString().replaceAll("\\-","");
+ return result + uuid.toString().replaceAll("\\-", "");
}
return null;
}
/**
* 获取字符串拼音的第一个字母
+ *
* @param chinese
* @return
*/
- private String toFirstChar(String chinese){
+ private String toFirstChar(String chinese) {
String pinyinStr = "";
char[] newChar = chinese.toCharArray();
//转为单个字符
@@ -312,7 +372,7 @@
} catch (BadHanyuPinyinOutputFormatCombination e) {
e.printStackTrace();
}
- }else{
+ } else {
pinyinStr += newChar[i];
}
}
@@ -321,16 +381,24 @@
/**
* 删除
+ *
* @param ids 考试报名信息ids 数组
*/
@PostMapping("/remove")
public R remove(@ApiParam(value = "主键集合") @RequestParam String ids) {
- //arg.sendPostRemoveByIds(arg.url+"/apply/remove",ids);
+ List<String> list = Arrays.asList(ids.split(","));
+ list.forEach(id -> {
+ //内网同步
+ String s1 = "delete from sys_apply where id = " + "'" + id + "'";
+ //FtpUtil.sqlFileUpload(s1);
+ myAsyncService.FTP(s1);
+ });
return R.status(applyService.removeByIds(Func.toLongList(ids)));
}
/**
* 查询用户详情
+ *
* @param user
*/
@GetMapping("/userDetail")
@@ -344,6 +412,7 @@
/**
* 详情
+ *
* @param apply 考试报名信息对象
*/
@GetMapping("/detail")
@@ -357,11 +426,12 @@
/**
* 获取准考证信息
+ *
* @param apply
* @return
*/
@GetMapping("/getApplyInfo")
- public R<ApplyPaPerVO> getApplyInfo(Apply apply,HttpServletResponse response) {
+ public R<ApplyPaPerVO> getApplyInfo(Apply apply, HttpServletResponse response) {
response.setHeader("Access-Control-Allow-Origin", "*");
response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");
response.setHeader("Access-Control-Allow-Credentials", "true");
@@ -373,63 +443,120 @@
/**
* 取消报名
+ *
* @param apply 考试报名信息对象
*/
@PostMapping("/cancelApply")
- public R cancelApply(@RequestBody Apply apply){
+ public R cancelApply(@RequestBody Apply apply) {
//查询人员是否已报名
User user = userService.getById(apply.getUserId());
- if(null==user.getIsApply()){
+ if (null == user.getIsApply()) {
apply.setApplyStatus(4);
boolean status = applyService.updateById(apply);
//修改保安报名状态
user.setIsApply(2);
userService.updateById(user);
- if (status){
- return R.data(200,"取消报名成功");
+
+ //取消报名同步
+ cancelApplySync(apply, user);
+
+ if (status) {
+ return R.data(200, "取消报名成功");
}
- }else {
- if (user.getIsApply()==2) {
- return R.data(201,"尚未报名");
- }
- if(user.getIsApply()==1){
+
+ } else {
+ if (user.getIsApply() == 1) {
apply.setApplyStatus(4);
boolean status = applyService.updateById(apply);
//修改保安报名状态
user.setIsApply(2);
userService.updateById(user);
- if (status){
- return R.data(200,"取消报名成功");
+
+ //取消报名同步
+ cancelApplySync(apply, user);
+
+ if (status) {
+ return R.data(200, "取消报名成功");
+ }
+ } else {
+ return R.data(201, "尚未报名");
+ }
+ }
+ return R.data(202, "取消报名失败");
+ }
+
+ /**
+ * 取消报名同步
+ */
+ private void cancelApplySync(Apply apply, User user) {
+ String s =
+ "update sys_apply set apply_status = " + apply.getApplyStatus() + " " + "where id = " + "'" + apply.getId() + "';" +
+ "update blade_user set is_apply = " + user.getIsApply() + " " + "where id = " + "'" + user.getId() + "'";
+ //FtpUtil.sqlFileUpload(s);
+ myAsyncService.FTP(s);
+ }
+
+
+ /**
+ * 公司报名列表取消报名，无applyId
+ *
+ * @param apply 考试报名信息对象
+ */
+ @PostMapping("/cancelApplyNotApplyId")
+ public R cancelApplyNotApplyId(@RequestBody Apply apply) {
+ //查询人员是否已报名
+ User user = userService.getById(apply.getUserId());
+ //查询报名信息，取最新的一条（即当前userId,）applyId最大的一条记录
+ Apply apply1 = applyService.getMaxApplyIdByUserIdInfo(apply.getUserId());
+ if (null == user.getIsApply()) {
+ apply1.setApplyStatus(4);
+ boolean status = applyService.updateById(apply1);
+ //修改保安报名状态
+ user.setIsApply(2);
+ userService.updateById(user);
+
+ //取消报名同步
+ cancelApplySync(apply1, user);
+
+ if (status) {
+ return R.data(200, "取消报名成功");
+ }
+ } else {
+ if (user.getIsApply() != 1) {
+ return R.data(201, "尚未报名");
+ }
+ if (user.getIsApply() == 1) {
+ apply1.setApplyStatus(4);
+ boolean status = applyService.updateById(apply1);
+ //修改保安报名状态
+ user.setIsApply(2);
+ userService.updateById(user);
+
+ //取消报名同步
+ cancelApplySync(apply1, user);
+
+ if (status) {
+ return R.data(200, "取消报名成功");
}
}
}
- return R.data(202,"取消报名失败");
+ return R.data(202, "取消报名失败");
}
/**
* 批量报名
- * @param apply 考试报名信息对象
+ *
+ * @param ids userIds 人员
*/
@PostMapping("/batchApply")
- public R batchApply(@RequestBody ApplyVO apply){
- List<String> list = Arrays.asList(apply.getUserIds().split(","));
- list.forEach(userId ->{
- User user = userService.getById(userId);
- //未报名的新增，已报名的不做处理
- if (null==user.getIsApply()) {
- Apply apply1 = new Apply();
- apply1.setApplyStatus(2);
- //默认为未考试状态
- apply1.setIsExam(1);
- apply1.setApplyTime(new Date());
- apply1.setUserId(Long.parseLong(userId));
- applyService.save(apply1);
- //修改保安报名状态
- user.setIsApply(1);
- userService.updateById(user);
- }else {
- if (user.getIsApply()==2) {
+ public R batchApply(@RequestParam String ids, @RequestParam String deptId) {
+ if (!ids.equals("")) {
+ List<String> list = Arrays.asList(ids.split(","));
+ list.forEach(userId -> {
+ User user = userService.getById(userId);
+ //未报名的新增，已报名的不做处理
+ if (null == user.getIsApply()) {
Apply apply1 = new Apply();
apply1.setApplyStatus(2);
//默认为未考试状态
@@ -440,78 +567,123 @@
//修改保安报名状态
user.setIsApply(1);
userService.updateById(user);
+
+ //内网数据同步
+ saveApply(apply1, user);
+ } else {
+ if (user.getIsApply() != 1) {
+ Apply apply1 = new Apply();
+ apply1.setApplyStatus(2);
+ //默认为未考试状态
+ apply1.setIsExam(1);
+ apply1.setApplyTime(new Date());
+ apply1.setUserId(Long.parseLong(userId));
+ applyService.save(apply1);
+ //修改保安报名状态
+ user.setIsApply(1);
+ userService.updateById(user);
+
+ //内网数据同步
+ saveApply(apply1, user);
+ }
}
+ });
+ } else {
+ //查询所有未报名的人员
+ List<User> users = userService.getNotApplyIdList(deptId);
+ if (users.size() > 0) {
+ users.forEach(user -> {
+ //未报名的新增，已报名的不做处理
+ if (null == user.getIsApply()) {
+ Apply apply1 = new Apply();
+ apply1.setApplyStatus(2);
+ //默认为未考试状态
+ apply1.setIsExam(1);
+ apply1.setApplyTime(new Date());
+ apply1.setUserId(user.getId());
+ applyService.save(apply1);
+ //修改保安报名状态
+ user.setIsApply(1);
+ userService.updateById(user);
+
+ //内网数据同步
+ saveApply(apply1, user);
+ } else {
+ if (user.getIsApply() != 1) {
+ Apply apply1 = new Apply();
+ apply1.setApplyStatus(2);
+ //默认为未考试状态
+ apply1.setIsExam(1);
+ apply1.setApplyTime(new Date());
+ apply1.setUserId(user.getId());
+ applyService.save(apply1);
+ //修改保安报名状态
+ user.setIsApply(1);
+ userService.updateById(user);
+
+ //内网数据同步
+ saveApply(apply1, user);
+ }
+ }
+ });
}
- });
- return R.data(200,"报名成功");
+ }
+ return R.data(200, "报名成功");
}
-
/**
- * 生成试卷,报名
- * @param ids 报名ids
+ * 生成考试,报名
+ *
+ * @param applyVO 报名info
*/
@PostMapping("/batchExam")
- public R batchExam(@RequestParam String ids,
- @RequestParam String examTime,
- @RequestParam Date startTime,
- @RequestParam Date endTime){
- if (!ids.equals("")){
- List<String> list = Arrays.asList(ids.split(","));
- if (list.size()>0){
- ExamPaper examPaper = new ExamPaper();
- examPaper.setExamTime(examTime);
- examPaper.setExamType(1);
- examPaper.setStartTime(startTime);
- examPaper.setEndTime(endTime);
- Calendar instance = Calendar.getInstance();
- instance.setTime(startTime);
- 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);
- //生成考试
- examPaperService.save(examPaper);
- //修改报名信息
- list.forEach(id ->{
- Apply apply = new Apply();
- apply.setId(Long.parseLong(id));
- apply.setExamId(examPaper.getId());
- apply.setCandidateNo(getCandidateNo(apply));
- applyService.updateById(apply);
- });
- }
+ public R batchExam(@RequestBody ApplyVO applyVO) {
+ //查询已报名未关联试卷的人员
+ List<Apply> applyIds = applyService.getApplyIds(applyVO);
+ if (applyIds.size() > 0) {
+ //生成考试
+ ExamPaper examPaper = new ExamPaper();
+ examPaper.setExamType(1);
+ examPaper.setStartTime(applyVO.getStartTime());
+ examPaper.setEndTime(applyVO.getEndTime());
+ Calendar instance = Calendar.getInstance();
+ instance.setTime(applyVO.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);
+ //生成考试
+ examPaperService.save(examPaper);
- }else {
- //查询已报名未关联试卷的人员
- List<Long> applyIds = applyService.getApplyIds();
- if (applyIds.size()>0){
- //生成考试
- ExamPaper examPaper = new ExamPaper();
- examPaper.setExamTime(examTime);
- examPaper.setExamType(1);
- examPaper.setStartTime(startTime);
- examPaper.setEndTime(endTime);
- Calendar instance = Calendar.getInstance();
- instance.setTime(startTime);
- 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);
- //生成考试
- examPaperService.save(examPaper);
- //修改报名信息
- applyIds.forEach(id ->{
- Apply apply = new Apply();
- apply.setId(id);
+ 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.getStartTime());
+ String s = "insert into ksxt_exam(id,exam_name,exam_type,start_time,end_time) " +
+ "values(" + "'" + sid + "'" +
+ "," + "'" + examPaper.getExamName() + "'" +
+ "," + "'" + examPaper.getExamType() + "'" +
+ "," + "'" + format + "'" +
+ "," + "'" + endTimeFormat + "'" + ")";
+ //FtpUtil.sqlFileUpload(s);
+ myAsyncService.FTP(s);
+
+ //修改报名信息
+ applyIds.forEach(apply -> {
+ //如果查出来的是已存在考试信息数据，则跳过
+ if (null == apply.getExamId()) {
apply.setExamId(examPaper.getId());
apply.setCandidateNo(getCandidateNo(apply));
applyService.updateById(apply);
- });
- }
+
+ String s1 =
+ "update sys_apply set exam_id = " + apply.getExamId() + ",candidate_no = " + "'" + apply.getCandidateNo() + "'" +
+ " " + "where id = " + "'" + apply.getId() + "'";
+ //FtpUtil.sqlFileUpload(s1);
+ myAsyncService.FTP(s1);
+ }
+ });
}
return null;
}
@@ -519,23 +691,88 @@
/**
* 查询报名清册信息
+ *
* @param apply 报名信息
* @return
*/
@GetMapping("/getApplyDetailList")
- public Map<String,Object> getApplyDetailList(ApplyVO apply){
+ public Map<String, Object> getApplyDetailList(ApplyVO apply) {
return applyService.getApplyDetailList(apply);
}
/**
* 查询保安员个人报名信息
+ *
* @param apply 报名信息，包含userId
* @return
*/
@GetMapping("/getSecurityApplyDetail")
- public ApplyVO getSecurityApplyDetail(ApplyVO apply){
+ public ApplyVO getSecurityApplyDetail(ApplyVO apply) {
return applyService.getSecurityApplyDetail(apply);
}
+
+ /**
+ * 修改考试状态
+ *
+ * @param apply 报名信息，包含userId，applyid
+ * @return
+ */
+ @PostMapping("/updateApplyStatus")
+ public ExamScore updateApplyStatus(@RequestBody ApplyVO apply) {
+ applyService.updateApplyStatus(apply);
+ //新增考试成绩，没有成绩数据，待提交答题后更新数据
+ ExamScore examScore = new ExamScore();
+ examScore.setExamId(apply.getExamId().toString());
+ examScore.setUserId(apply.getUserId().toString());
+ examScore.setApplyId(apply.getId());
+ examScore.setCandidateNo(apply.getCandidateNo());
+ examScore.setExamTime(new Date());
+ //新增考试成绩
+ boolean save = examScoreService.save(examScore);
+ if (save) {
+ //内网同步
+ Long sid = examScore.getId();
+ String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examScore.getExamTime());
+ String s = "insert into exam_score(id,candidate_no,exam_time,user_id,exam_id,apply_id) " +
+ "values(" + "'" + sid + "'" +
+ "," + "'" + examScore.getCandidateNo() + "'" +
+ "," + "'" + format + "'" +
+ "," + "'" + examScore.getUserId() + "'" +
+ "," + "'" + examScore.getExamId() + "'" +
+ "," + "'" + examScore.getApplyId() + "'" + ")";
+ myAsyncService.FTP(s);
+ }
+ return examScore;
+ }
+
+
+ /**
+ * test
+ *
+ * @return
+ */
+ @GetMapping("/test")
+ public Object test() {
+ String s1 = "insert into exam_score(id,exam_id,apply_id) values(223,88,315)";
+ String s2 = "111222333";
+ String s3 = "select * from ksxt_exam";
+ FtpUtil.sqlFileUpload(s1);
+ FtpUtil.sqlFileUpload(s2);
+// FtpUtil.sqlFileUpload(s3);
+ String json1 = JSON.toJSONString(s3);
+ String response1 = String.valueOf((new Date()).getTime());
+ OutJson.createJsonFile(json1, localPath, "f" + response1);
+ FileInputStream in1 = null;
+ try {
+ in1 = new FileInputStream(new File(localPath + "f" + response1 + ".json"));
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ }
+ FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, "/", "f" + response1 + ".json", in1);
+ return "成功";
+ }
+
+
}
--
Gitblit v1.9.3