易乾不存在的订单5分钟关闭

src/main/java/com/ym/mec/collectfee/controller/YqPayController.java

@@ -78,6 +78,11 @@ public class YqPayController extends BaseController {
         //计划招生人数有更新，更新
         orderService.getSchoolDetail(school.getSchoolId());
 
+        //判断用户是否已存在订单
+        Order userOrder = orderService.findOrderByStatus(order.getUserId(), 1);
+        if (userOrder != null) {
+            return failed("您有待支付的订单，请完成支付");
+        }
         //1、判断已报名人数
         CourseGroupInfo courseGroupInfo = CourseGroupInfoService.get(order.getCourseId());
         if (courseGroupInfo.getRegNum().compareTo(courseGroupInfo.getPlanNum()) >= 0) {
@@ -406,6 +411,7 @@ public class YqPayController extends BaseController {
         resultMap.put("merOrderNoList", merOrderNos);
         Map<String, Object> requestMap = new YqPayUtil(notifyUrl, resultMap).getRequestMap();
         Msg queryRs = yqQueryService.orderQuery(requestMap);
+        logger.info("查询易乾结果" + queryRs.toString());
         if (queryRs.getCode().equals("88")) {
             //更新订单状态
             String[] statusArr = {"0", "1", "7"};

src/main/java/com/ym/mec/collectfee/service/OrderService.java

@@ -6,6 +6,7 @@ import com.ym.mec.collectfee.entity.Account;
 import com.ym.mec.collectfee.entity.Order;
 import com.ym.mec.collectfee.entity.School;
 import com.ym.mec.collectfee.utils.yqpay.YqPayUtil;
+import org.apache.ibatis.annotations.Param;
 
 import javax.xml.bind.JAXBException;
 import java.math.BigDecimal;
@@ -101,4 +102,6 @@ public interface OrderService extends BaseService<Integer, Order> {
     List<Order> findPayingOrdersOver(Map<String,Object> map);
 
     Integer getPayingOrderNums(int groupId);
+
+    Order findOrderByStatus(Integer userId,Integer status);
 }

src/main/java/com/ym/mec/collectfee/service/impl/OrderServiceImpl.java

@@ -207,5 +207,9 @@ public class OrderServiceImpl extends BaseServiceImpl<Integer, Order> implements
         return orderDao.getPayingOrderNums(groupId);
     }
 
+    @Override
+    public Order findOrderByStatus(Integer userId, Integer status) {
+        return orderDao.findOrderByStatus(userId, status);
+    }
 
 }