支付

src/main/java/com/yunzhi/niucai/common/CommConstants.java

     /**
      * 重新置为有效状态
      */
-    public final static Integer SRTATUS_EFFECTIVE = 3;
+    public final static Integer SRTATUS_EFFECTIVE = 1;
 
     /**
      * 支付成功

src/main/java/com/yunzhi/niucai/controller/AliPayController.java

 import javax.servlet.http.HttpServletRequest;
 import java.math.BigInteger;
 import java.security.SecureRandom;
+import java.time.LocalDateTime;
 import java.util.Date;
 import java.util.Iterator;
 import java.util.Map;
         // 更新商户订单号并改为支付中
         taOrder.setOutTradeNo(outTradeNo);
         taOrder.setStatus(CommConstants.SRTATUS_PAYING);
+        taOrder.setUpdateDate(LocalDateTime.now());
         taOrderService.updateById(taOrder);
         return ResponseBean.success(pay);
     }
         String outTradeNo = request.getParameter("out_trade_no");
         String tradeStatus = request.getParameter("trade_status");
         TaOrder taOrder = taOrderService.getOne(new QueryWrapper<TaOrder>().eq("out_trade_no", outTradeNo));
+        taOrder.setUpdateDate(LocalDateTime.now());
         // 支付失败
         if (!tradeStatus.equals(CommConstants.TRADE_STATUS_SUCCESS)){
             taOrder.setStatus(CommConstants.SRTATUS_EFFECTIVE);
         //支付成功 更新为已支付状态
         taOrder.setIsPayed(true);
         taOrder.setStatus(CommConstants.SRTATUS_EFFECTIVE);
+        taOrder.setTradeNo(tradeNo);
         taOrderService.updateById(taOrder);
     }
 }

src/main/java/com/yunzhi/niucai/entity/TaOrder.java

 
     @ApiModelProperty(value = "商户网站唯一订单号")
     private String outTradeNo;
+
+    @ApiModelProperty(value = "支付平台流水")
+    private String tradeNo;
+
+    @ApiModelProperty(value = "更新时间")
+    private LocalDateTime updateDate;
 }

src/main/java/com/yunzhi/niucai/task/OrderTask.java

+package com.yunzhi.niucai.task;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yunzhi.niucai.common.CommConstants;
+import com.yunzhi.niucai.entity.TaOrder;
+import com.yunzhi.niucai.service.ITaOrderService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Component
+public class OrderTask {
+
+    @Autowired
+    private ITaOrderService taOrderService;
+    /**
+     * 改变支付中的状态为有效状态
+     */
+    @Scheduled(cron = "* 0/30 * * * ? ")
+    public void changeOrderStatus(){
+        QueryWrapper<TaOrder> taOrderQueryWrapper = new QueryWrapper<>();
+        taOrderQueryWrapper.eq("status", CommConstants.SRTATUS_PAYING);
+        taOrderQueryWrapper.isNotNull("out_trade_no");
+        taOrderQueryWrapper.gt("update_date", LocalDateTime.now().plusMinutes(30));
+        List<TaOrder> list = taOrderService.list(taOrderQueryWrapper);
+        list.forEach(e -> e.setStatus(CommConstants.SRTATUS_EFFECTIVE));
+        taOrderService.updateBatchById(list);
+    }
+}