| | |
| | | */ |
| | | @Override |
| | | public List<CoalPayRepDto> selectCoalPayList(CoalPayReq coalPay) { |
| | | List<CoalPayRepDto> coalPayRepDtos = new ArrayList<>(); |
| | | List<CoalPay> coalPays = coalPayMapper.selectCoalPayList(coalPay); |
| | | for (CoalPay pay : coalPays) { |
| | | CoalPayRepDto coalPayRepDto = new CoalPayRepDto(); |
| | | BeanUtils.copyProperties(pay, coalPayRepDto); |
| | | // List<CoalPayRepDto> coalPayRepDtos = new ArrayList<>(); |
| | | List<CoalPayRepDto> coalPays = coalPayMapper.selectCoalPayList(coalPay); |
| | | for (CoalPayRepDto pay : coalPays) { |
| | | // CoalPayRepDto coalPayRepDto = new CoalPayRepDto(); |
| | | // BeanUtils.copyProperties(pay, coalPayRepDto); |
| | | //部门数据 |
| | | SysDept sysDept = sysDeptMapper.selectDeptById(pay.getDeptId()); |
| | | coalPayRepDto.setDeptName(sysDept.getDeptName()); |
| | | pay.setDeptName(sysDept.getDeptName()); |
| | | //工种数据 |
| | | List<CoalCategory> coalCategories = coalCategoryMapper.selectByCoalPayId(pay.getId()); |
| | | coalPayRepDto.setCoalCategoryList(coalCategories); |
| | | pay.setCoalCategoryList(coalCategories); |
| | | //学员数据 |
| | | List<CoalPayStudent> coalPayStudents = coalPayStudentService.selectByCoalPayId(pay.getId()); |
| | | List<CoalPayStudent> havePay = coalPayStudents.stream() |
| | | .filter(stu -> stu.getPayStatus() != null && stu.getPayStatus() == 1) |
| | | .collect(Collectors.toList()); |
| | | coalPayRepDto.setTotalNum(coalPayStudents.size()); |
| | | coalPayRepDto.setHavePayNum(havePay.size()); |
| | | coalPayRepDtos.add(coalPayRepDto); |
| | | pay.setTotalNum(coalPayStudents.size()); |
| | | pay.setHavePayNum(havePay.size()); |
| | | // coalPayRepDtos.add(coalPayRepDto); |
| | | } |
| | | return coalPayRepDtos; |
| | | return coalPays; |
| | | } |
| | | |
| | | @Override |
| | |
| | | if (student.getPayStatus() == 1) { |
| | | throw new BusinessException(this.getClass(), ResultConstants.BUSINESS_ERROR, "请勿重新缴费"); |
| | | } |
| | | if (student.getGovPayStatus() == 2){ |
| | | return student.getOrderId(); |
| | | } |
| | | |
| | | PayReqData payReqData = fillData(coalPayStudent, coalPay, coalCategories, coalTicket, 1, null); |
| | | |
| | | ResultVo resultVo = payUtils.sendApiPost(payReqData); |
| | | ResultVo resultVo = payUtils.faqiV2(payReqData); |
| | | if (resultVo.getRespcode().equals("BUS0000")) { |
| | | //进行票据签名并校验 |
| | | // ResultVo resultVo1 = payUtils.uploadXml(resultVo.getRespdata().getOrderNo(), resultVo.getRespdata().getFileData()); |
| | |
| | | // throw new BusinessException(this.getClass(), ResultConstants.BUSINESS_ERROR, "签名验证错误"); |
| | | // } |
| | | payStudent.setId(studentId); |
| | | payStudent.setOrderId(resultVo.getRespdata().getOrderNo()); |
| | | payStudent.setGovPayStatus(1); |
| | | payStudent.setOrderNo(resultVo.getRespdata().getOrderNo()); |
| | | payStudent.setOrderId(resultVo.getRespdata().getOrderId()); |
| | | payStudent.setGovPayStatus(2); |
| | | payStudent.setPayCode(resultVo.getRespdata().getBillNo()); |
| | | coalPayStudentService.updateByCoalPayStudent(payStudent); |
| | | coalPayStudentService.updateByIdAndPayType(payStudent); |
| | | return resultVo.getRespdata().getOrderId(); |
| | | } else { |
| | | throw new BusinessException(this.getClass(), ResultConstants.BUSINESS_ERROR, resultVo.getRespmsg()); |
| | | } |
| | | } catch (BusinessException e) { |
| | | throw new RuntimeException(e); |
| | | } catch (IOException e) { |
| | | throw new RuntimeException(e); |
| | | } finally { |
| | | if (lock.isLocked()) { |
| | |
| | | if (coalPay == null) { |
| | | throw new BusinessException(this.getClass(), ResultConstants.BUSINESS_ERROR, "未找到相关缴费信息"); |
| | | } |
| | | if (coalPayStudents.get(0).getGovPayStatus() == 2){ |
| | | return coalPayStudents.get(0).getOrderId(); |
| | | } |
| | | |
| | | CoalPayStudent payStudent = new CoalPayStudent(); |
| | | PayReqData payReqData = fillData(coalPayStudents, coalPay, coalCategories, coalTicket, 2, coalTeamPayReq); |
| | | ResultVo resultVo = payUtils.sendApiPost(payReqData); |
| | | ResultVo resultVo = payUtils.faqiV2(payReqData); |
| | | if (resultVo.getRespcode().equals("BUS0000")) { |
| | | payStudent.setCoalPayId(coalPay.getId()); |
| | | payStudent.setOrderId(resultVo.getRespdata().getOrderNo()); |
| | | payStudent.setGovPayStatus(1); |
| | | payStudent.setOrderId(resultVo.getRespdata().getOrderId()); |
| | | payStudent.setOrderNo(resultVo.getRespdata().getOrderNo()); |
| | | payStudent.setGovPayStatus(2); |
| | | payStudent.setPayCode(resultVo.getRespdata().getBillNo()); |
| | | coalPayStudentService.updateByCoalPayIdAndStatus(payStudent); |
| | | return resultVo.getRespdata().getOrderId(); |
| | |
| | | |
| | | PayUtils payUtils = new PayUtils(); |
| | | ResultVo resultVo = payUtils.faqiV2(payReqData); |
| | | if (!resultVo.getRespcode().equals("BUS0000")) { |
| | | throw new BusinessException(this.getClass(), ResultConstants.BUSINESS_ERROR, "签名验证错误"); |
| | | } else { |
| | | //todo 业务处理 |
| | | } |
| | | log.info("请求结果:" + JSONObject.toJSONString(resultVo)); |
| | | // String fileData = resultVo.getRespdata().getFileData(); |
| | | // //票据原文转为byte字节文件 |