From 3bf782ceb9411b81e5c03cadb73751f429e4051a Mon Sep 17 00:00:00 2001 From: “djh” <“3298565835@qq.com”> Date: 星期二, 18 二月 2025 16:28:33 +0800 Subject: [PATCH] 煤矿缴费修改 --- exam-system/src/main/java/com/gkhy/exam/pay/service/impl/CoalPayServiceImpl.java | 170 ++++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 152 insertions(+), 18 deletions(-) diff --git a/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/CoalPayServiceImpl.java b/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/CoalPayServiceImpl.java index 2c86c26..bfd4605 100644 --- a/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/CoalPayServiceImpl.java +++ b/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/CoalPayServiceImpl.java @@ -1,5 +1,10 @@ package com.gkhy.exam.pay.service.impl; +import cn.com.jit.mof.bean.MOFVerifyResult; +import cn.com.jit.new_vstk.Bean.EnvelopResult; +import cn.com.jit.new_vstk.Bean.SignResult; +import cn.com.jit.new_vstk.Bean.VerifyResult; +import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.exam.pay.dto.rep.CoalPayRepDto; import com.gkhy.exam.pay.dto.rep.CoalPayStudentRep; @@ -10,8 +15,7 @@ import com.gkhy.exam.pay.mapper.CoalPayMapper; import com.gkhy.exam.pay.service.CoalPayService; import com.gkhy.exam.pay.service.CoalPayStudentService; -import com.gkhy.exam.pay.utils.PayUtils; -import com.gkhy.exam.pay.utils.ResultVo; +import com.gkhy.exam.pay.utils.*; import com.ruoyi.common.constant.ResultConstants; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.domain.entity.SysDept; @@ -20,6 +24,11 @@ import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.system.mapper.SysDeptMapper; +import lombok.extern.slf4j.Slf4j; +import org.dom4j.Document; +import org.dom4j.DocumentException; +import org.dom4j.DocumentHelper; +import org.dom4j.Element; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.beans.BeanUtils; @@ -28,15 +37,20 @@ import org.springframework.util.CollectionUtils; import javax.annotation.Resource; +import java.io.BufferedReader; +import java.io.File; +import java.io.FileReader; import java.io.IOException; import java.math.BigDecimal; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; +import java.nio.charset.StandardCharsets; +import java.util.*; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; +import static com.gkhy.exam.pay.utils.DemoUtils.generateBase64StringToFile; + @Service +@Slf4j public class CoalPayServiceImpl extends ServiceImpl<CoalPayMapper, CoalPay> implements CoalPayService { @Resource @@ -80,7 +94,7 @@ //学员数据 List<CoalPayStudent> coalPayStudents = coalPayStudentService.selectByCoalPayId(pay.getId()); List<CoalPayStudent> havePay = coalPayStudents.stream() - .filter(stu -> stu.getPayStatus() != null && stu.getPayStatus().equals(1)) + .filter(stu -> stu.getPayStatus() != null && stu.getPayStatus()==1) .collect(Collectors.toList()); coalPayRepDto.setTotalNum(coalPayStudents.size()); coalPayRepDto.setHavePayNum(havePay.size()); @@ -184,10 +198,13 @@ for (CoalPayStudent payStudent : coalPayStudents) { //封装学生基础信息 CoalPayStudentRep coalPayStudentRep = new CoalPayStudentRep(); + coalPayStudentRep.setId(payStudent.getId()); coalPayStudentRep.setName(payStudent.getName()); coalPayStudentRep.setIdCard(payStudent.getIdCard()); coalPayStudentRep.setPhone(payStudent.getPhone()); coalPayStudentRep.setSex(payStudent.getSex()); + coalPayStudentRep.setPayType(payStudent.getPayType()); + coalPayStudentRep.setPayCode(payStudent.getPayCode()); coalPayStudentRep.setPayStatus(payStudent.getPayStatus()); //查询对应批次以及批次包含工种类别 @@ -244,14 +261,23 @@ 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); if (resultVo.getRespcode().equals("BUS0000")) { + //进行票据签名并校验 +// ResultVo resultVo1 = payUtils.uploadXml(resultVo.getRespdata().getOrderNo(), resultVo.getRespdata().getFileData()); +// if (!resultVo1.getRespcode().equals("BUS0000")){ +// throw new BusinessException(this.getClass(), ResultConstants.BUSINESS_ERROR, "签名验证错误"); +// } payStudent.setId(studentId); - 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.updateByCoalPayStudent(payStudent); return resultVo.getRespdata().getOrderId(); @@ -290,8 +316,9 @@ ResultVo resultVo = payUtils.sendApiPost(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(); @@ -307,11 +334,120 @@ } } + @Override + public ResultVo topay() throws IOException, BillSignException { + PayReqData payReqData = new PayReqData(); + PayReqData.Feedata feedatas = new PayReqData.Feedata(); + + + //订单编号 + payReqData.setOrderNo("CO202502180328549421"); + //订单总金额 + payReqData.setMoney(BigDecimal.valueOf(159)); + //子订单数目 + payReqData.setAmount(2); + //缴费人姓名(单位填单位名称)阿克苏地区博安煤矿安全技术服务中心 + payReqData.setPayerName("闵强明"); + //缴费人证件号(单位填同一信用代码)52652900789893140A + payReqData.setCertNo("321023197209184616"); + //缴款人类型(1个人 2单位) + payReqData.setPayerType(1); + //开票单位社会信用代码12650000MB1A9612XD + payReqData.setInvoiceSocialCode("65000023000000172848"); + //开票人 + payReqData.setHandlingPerson("张三"); + //复核人 + payReqData.setChecker("李四"); + //单位编码547185129 + payReqData.setEnterCode("547185129"); + //订单描述(非必填) + payReqData.setDesc("单位业务"); + //订单明细 + List<PayReqData.Feedata> feedatas1 = new ArrayList<>(); + //数量 + feedatas.setAmount(1); + //业务代码 + feedatas.setBusCode("DZ011573"); + //单价 + feedatas.setPrice(BigDecimal.valueOf(56)); + PayReqData.Feedata feedata = new PayReqData.Feedata(); + feedata.setBusCode("DZ011574"); + feedata.setAmount(1); + feedata.setPrice(BigDecimal.valueOf(103)); + feedatas1.add(feedatas); + feedatas1.add(feedata); + payReqData.setFeeDatas(feedatas1); + log.info("请求参数:"+ JSONObject.toJSONString(payReqData)); + + + PayUtils payUtils = new PayUtils(); + ResultVo resultVo = payUtils.sendApiPost(payReqData); + + String fileData = resultVo.getRespdata().getFileData(); +// String orderNo = resultVo.getRespdata().getOrderNo(); +// String xmlFilePath = "F:\\text/" + orderNo + ".xml"; +// generateBase64StringToFile(fileData, xmlFilePath); +// String trr2 = ""; +// try { +// File file2 = new File(xmlFilePath); +// FileReader reader1 = new FileReader(file2); +// BufferedReader bReader = new BufferedReader(reader1); +// StringBuilder sb = new StringBuilder(); +// String s = ""; +// while ((s = bReader.readLine()) != null) { +// sb.append(s); +// } +// bReader.close(); +// trr2 = sb.toString(); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// log.info("拼接原文为trr2:"+trr2); +// +// BillSign billSign = new BillSign(); +// String signData=""; +// try { +// signData = billSign.signBill(trr2); +// } catch (BillSignException e) { +// throw new RuntimeException(e); +// } catch (Exception e) { +// throw new RuntimeException(e); +// } + //票据原文转为byte字节文件 + byte[] decode = Base64.getDecoder().decode(fileData); + //byte字节文件转为xml字符串 + String xmlString = new String(decode, StandardCharsets.UTF_8); + Document document = null; + try { + document = DocumentHelper.parseText(xmlString); + } catch (DocumentException e) { + throw new RuntimeException(e); + } + log.info("票据原文为:"+document.asXML()); + BillSign billSign = new BillSign(); + String s = billSign.readRefSignDto(document); + Element rootElement = document.getRootElement(); + SignResult sign = payUtils.sign(s); + MOFVerifyResult verify = payUtils.verify(sign.getSignData(),s); + SignDto signDto = new SignDto(verify.getSignTime(), new String(Base64.getEncoder().encode(sign.getSignData())), verify.getIssure(),verify.getSn()); + log.info("拼接对象为:"+JSONObject.toJSONString(signDto)); + Sign sign1 = new Sign(); + Document signature = sign1.getSignature(signDto); +// Element rootElement1 = signature.getRootElement(); + log.info("拼接结果为:"+signature.asXML()); + rootElement.add(signature.getRootElement()); +// EnvelopResult envelopResult = payUtils.encryptEnvelop(document.asXML().getBytes()); +// log.info("制作数字信封为:"+ Arrays.toString(envelopResult.getEnvelopData())); + log.info("签名后票据为:"+document.asXML()); + ResultVo resultVo1 = payUtils.uploadXml(resultVo.getRespdata().getOrderNo(), document.asXML()); + return resultVo1; + } + private PayReqData fillData(List<CoalPayStudent> coalPayStudent, CoalPay coalPay, List<CoalCategory> coalCategories, CoalTicket coalTicket,Integer payType,CoalTeamPayReq coalTeamPayReq) { PayReqData payReqData = new PayReqData(); payReqData.setOrderNo(RandomUtil.generateOrderNumber(coalPay.getId(), "CO")); payReqData.setMoney(coalPay.getAmount().multiply(BigDecimal.valueOf(coalPayStudent.size()))); - payReqData.setAmount(coalCategories.size()*coalPayStudent.size()); + payReqData.setAmount(coalCategories.size()); payReqData.setInvoiceSocialCode(coalTicket.getTicketCompanyCode()); payReqData.setHandlingPerson(coalTicket.getDrawer()); payReqData.setChecker(coalTicket.getCheck()); @@ -321,13 +457,11 @@ List<PayReqData.Feedata> feedatas = new ArrayList<>(); for (CoalCategory coalCategory : coalCategories) { - for (CoalPayStudent payStudent : coalPayStudent) { - PayReqData.Feedata feedata = new PayReqData.Feedata(); - feedata.setAmount(1); - feedata.setPrice(coalCategory.getAmount()); - feedata.setBusCode(coalCategory.getBusinessCode()); - feedatas.add(feedata); - } + PayReqData.Feedata feedata = new PayReqData.Feedata(); + feedata.setAmount(coalPayStudent.size()); + feedata.setPrice(coalCategory.getAmount().multiply(BigDecimal.valueOf(coalPayStudent.size()))); + feedata.setBusCode(coalCategory.getBusinessCode()); + feedatas.add(feedata); } payReqData.setFeeDatas(feedatas); -- Gitblit v1.9.2