| | |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import lombok.AllArgsConstructor; |
| | | import org.springblade.common.utils.arg; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springblade.core.log.exception.ServiceException; |
| | | import org.springblade.core.mp.support.Condition; |
| | | import org.springblade.modules.FTP.FtpUtil; |
| | |
| | | import org.springblade.modules.exam.vo.ExamResultVO; |
| | | import org.springblade.modules.exam.vo.ExamScoreVO; |
| | | import org.springblade.modules.exam.vo.UpdateParamVo; |
| | | import org.springblade.modules.system.entity.Role; |
| | | import org.springblade.modules.system.entity.User; |
| | | import org.springblade.modules.system.service.IRoleService; |
| | | import org.springblade.modules.system.service.IUserService; |
| | |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | |
| | | import static com.bstek.ureport.expression.model.condition.Join.and; |
| | | import java.util.concurrent.atomic.AtomicBoolean; |
| | | import java.util.concurrent.atomic.AtomicInteger; |
| | | |
| | | /** |
| | | * 考试成绩服务实现类 |
| | |
| | | @Override |
| | | public void importExamScore(List<ExamScoreExcel> examScoreExcelList, Boolean isCovered) { |
| | | if (examScoreExcelList.size()>0){ |
| | | List<Object> errorList = new ArrayList<>(); |
| | | //导入状态,默认为true ,如果有一个出现问题则为 false |
| | | AtomicBoolean status = new AtomicBoolean(true); |
| | | //遍历 |
| | | examScoreExcelList.forEach(examScoreExcel -> { |
| | | if (null!=examScoreExcel.getLearnGrade() && null!=examScoreExcel.getIdCardNo() && examScoreExcel.getIdCardNo()!=""){ |
| | | //使用考试名称匹配考试信息 |
| | |
| | | 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(); |
| | | //查询当前年份已有的保安证编号 |
| | |
| | | } |
| | | user.setSecuritynumber(result); |
| | | //发证日期 |
| | | user.setPaperTime(new Date()); |
| | | // user.setPaperTime(new Date()); |
| | | //修改为持证保安 |
| | | user.setHold("1"); |
| | | //分配保安角色 |
| | | // Role role = new Role(); |
| | | // role.setRoleAlias("保安"); |
| | | // Role oneRole = roleService.getOne(Condition.getQueryWrapper(role)); |
| | | // user.setRoleId(oneRole.getId().toString()); |
| | | //更新保安数据 |
| | | userService.updateById(user); |
| | | |
| | | String s1 = |
| | | "update blade_user set hold = " + "'" + user.getHold() + "'" + |
| | | "update blade_user set hold = " + "'" + user.getHold() + "'" + |
| | | ",securitynumber = " + "'" + user.getSecuritynumber() + "'" + |
| | | ",paper_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd").format(user.getPaperTime()) + "'" + |
| | | " " +"where id = " + "'" + user.getId() + "'"; |
| | | ",user_type = " + "'" + user.getUserType() + "'" + |
| | | " " + "where id = " + "'" + user.getId() + "'"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | } |
| | | //分配保安角色 |
| | | // Role role = new Role(); |
| | | // role.setRoleAlias("保安"); |
| | | // Role oneRole = roleService.getOne(Condition.getQueryWrapper(role)); |
| | | // user.setRoleId(oneRole.getId().toString()); |
| | | // } |
| | | } else { |
| | | //不合格 |
| | | examScore.setQualified(1); |
| | | } |
| | | //总成绩 |
| | | if (user.getAge()<=50) { |
| | | examScore.setAllGrade(Math.round((examScore.getTheoryGrade()+examScoreExcel.getLearnGrade())/2)); |
| | | if (user.getAge() <= 50) { |
| | | if (null!=examScore.getTheoryGrade()) { |
| | | examScore.setAllGrade(Math.round((examScore.getTheoryGrade() + examScoreExcel.getLearnGrade()) / 2)); |
| | | }else { |
| | | examScore.setAllGrade(Math.round(examScoreExcel.getLearnGrade() / 2)); |
| | | } |
| | | } |
| | | if (user.getAge()>50) { |
| | | examScore.setAllGrade(Integer.parseInt(String.valueOf(Math.round(examScore.getTheoryGrade()*0.5))) |
| | | + Integer.parseInt(String.valueOf(Math.round(examScoreExcel.getLearnGrade()*0.5)))); |
| | | if (user.getAge() > 50) { |
| | | if (null!=examScore.getTheoryGrade()) { |
| | | examScore.setAllGrade(Integer.parseInt(String.valueOf(Math.round(examScore.getTheoryGrade() * 0.5))) |
| | | + Integer.parseInt(String.valueOf(Math.round(examScoreExcel.getLearnGrade() * 0.5)))); |
| | | }else { |
| | | examScore.setAllGrade(Math.round(examScoreExcel.getLearnGrade() / 2)); |
| | | } |
| | | } |
| | | |
| | | //内网同步 |
| | |
| | | "update exam_score set learn_grade = " + "'" + examScore.getLearnGrade() + "'" + |
| | | ",all_grade = " + "'" + examScore.getAllGrade() + "'" + |
| | | ",qualified = " + "'" + examScore.getQualified() + "'" + |
| | | " " +"where id = " + "'" + examScore.getId() + "'"; |
| | | " " + "where id = " + "'" + examScore.getId() + "'"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | //更新成绩数据 |
| | | baseMapper.updateById(examScore); |
| | | }else { |
| | | errorList.add(examScoreExcel.getIdCardNo()); |
| | | status.set(false); |
| | | } |
| | | } |
| | | }); |
| | | //如果所有数据导入有一个异常 |
| | | if (!status.get()){ |
| | | String errorAccount = StringUtils.join(errorList, "\\\n"); |
| | | throw new ServiceException("用户:["+errorAccount+"]实操成绩导入失败!账号与准考证号不匹配!"); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | // /** |
| | | // * 导入实操成绩--测试 |
| | | // * @param examScoreExcelList |
| | | // * @param isCovered 是否覆盖 |
| | | // */ |
| | | // @Override |
| | | // public void importExamScore(List<ExamScoreExcel> examScoreExcelList, Boolean isCovered) { |
| | | // if (examScoreExcelList.size()>0){ |
| | | // List<Object> errorList = new ArrayList<>(); |
| | | // //导入状态,默认为true ,如果有一个出现问题则为 false |
| | | // AtomicBoolean status = new AtomicBoolean(true); |
| | | // AtomicInteger num = new AtomicInteger(); |
| | | // //遍历 |
| | | // examScoreExcelList.forEach(examScoreExcel -> { |
| | | // //根据身份证号查询培训信息 |
| | | // User user = userService.getUserInfoByIdCardNo(examScoreExcel.getIdCardNo()); |
| | | //// TrainingRegistration registration = new TrainingRegistration(); |
| | | //// registration.setCandidateNo(examScoreExcel.getCandidateNo()); |
| | | //// TrainingRegistration one1 = trainingRegistrationService.getOne(Condition.getQueryWrapper(registration)); |
| | | //// 测试生成考试成绩 |
| | | // ExamScore examScore1 = new ExamScore(); |
| | | // examScore1.setCandidateNo(examScoreExcel.getCandidateNo()); |
| | | // examScore1.setUserId(user.getId().toString()); |
| | | // //根据准考证号和用户id查询考试成绩 |
| | | // ExamScore examScore = this.getOne(Condition.getQueryWrapper(examScore1)); |
| | | // examScore.setQualified(0); |
| | | // //根据身份证号查询用户 |
| | | // examScore.setTheoryGrade(examScoreExcel.getTheoryGrade()); |
| | | // examScore.setAllGrade((examScore.getLearnGrade()+examScore.getTheoryGrade())/2); |
| | | // |
| | | // //新增 |
| | | // this.updateById(examScore); |
| | | // |
| | | // //生成准考证号 |
| | | // 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.setRegistered(examScoreExcel.getExamName()); |
| | | // //更新保安数据 |
| | | // userService.updateById(user); |
| | | // num.getAndIncrement(); |
| | | // } |
| | | // }); |
| | | // //如果所有数据导入有一个异常 |
| | | // if (!status.get()){ |
| | | // String errorAccount = StringUtils.join(errorList, "\\\n"); |
| | | // throw new ServiceException("用户:["+errorAccount+"]实操成绩导入失败!账号与准考证号不匹配!"); |
| | | // } |
| | | // if (status.get()){ |
| | | // throw new ServiceException("更新成功:"+ num.get()); |
| | | // } |
| | | // } |
| | | // } |
| | | |
| | | @Override |
| | | public List<Map<String, Object>> scoreStatistics(String deptid,String jurisdiction) { |
| | | return baseMapper.scoreStatistics(deptid,jurisdiction); |