From 8c73a9ff2bf3c88b17a1279f51c1ae3993effdcf Mon Sep 17 00:00:00 2001
From: “djh” <“3298565835@qq.com”>
Date: 星期二, 19 八月 2025 10:53:37 +0800
Subject: [PATCH] 修改

---
 exam-system/src/main/java/com/gkhy/exam/pay/service/impl/PaymentServiceImpl.java |   23 ++++++++++++++++++-----
 1 files changed, 18 insertions(+), 5 deletions(-)

diff --git a/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/PaymentServiceImpl.java b/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/PaymentServiceImpl.java
index bbe9588..f5f6cd4 100644
--- a/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/PaymentServiceImpl.java
+++ b/exam-system/src/main/java/com/gkhy/exam/pay/service/impl/PaymentServiceImpl.java
@@ -1,6 +1,5 @@
 package com.gkhy.exam.pay.service.impl;
 
-import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.gkhy.exam.pay.entity.CoalPayStudent;
 import com.gkhy.exam.pay.entity.NonCoalPayStudent;
@@ -29,9 +28,23 @@
     @Override
     public void notifyConfirm(String orderNo) {
         try {
-            String resultStr1 = payUtils.affirmPost(orderNo);
-            JSONObject result1 = JSONObject.parseObject(resultStr1);
-            log.info("通知确定回参===" + result1);
+            JSONObject result = payUtils.query(orderNo);
+            log.info("查询财政订单返回结果:" + result);
+            String respcode = result.getString("respcode");
+            if (CaiZhengConstans.CAI_ZHENG_SUCCESS.equals(respcode)) {
+                JSONObject respdata = result.getJSONObject("respdata");
+                if (respdata != null && "1".equals(respdata.getString("status"))) {
+                    nonCoalPayStudentMapper.update(null, Wrappers.<NonCoalPayStudent>lambdaUpdate()
+                            .set(NonCoalPayStudent::getPayStatus, 1)
+                            .set(NonCoalPayStudent::getPayTime, respdata.getDate("payTime"))
+                            .eq(NonCoalPayStudent::getOrderNo, orderNo).eq(NonCoalPayStudent::getDelFlag, 0)
+                            .eq(NonCoalPayStudent::getPayStatus, 0));
+                    payUtils.affirmPost(orderNo);
+                }else {
+                    log.error("查询财政订单失败:" + result.getString("respmsg") + ",错误编码:" + result.getString("respcode"));
+                }
+            }
+
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -55,7 +68,7 @@
                     .eq(CoalPayStudent::getOrderNo, orderNo).eq(CoalPayStudent::getDelFlag, 0)
                     .eq(CoalPayStudent::getPayStatus, 0));
         }
-        notifyConfirm(orderNo);
+        payUtils.asyncNotrify(orderNo);
 
     }
 

--
Gitblit v1.9.2