- 手写 MyBatis：渐进式源码实践 - 拼多多
- 
-
+
+
+
+
+
+
+
+
+
+
+
-
diff --git a/docs/dev-ops/nginx/html/js/index.js b/docs/dev-ops/nginx/html/js/index.js
new file mode 100644
index 0000000..691df20
--- /dev/null
+++ b/docs/dev-ops/nginx/html/js/index.js
@@ -0,0 +1,347 @@
+
+document.addEventListener('DOMContentLoaded', () => {
+
+ /* ========== 通用工具 ========== */
+ const getCookie = k =>
+ document.cookie
+ .split(';')
+ .map(c => c.trim())
+ .find(c => c.startsWith(k + '='))?.split('=')[1] || null;
+
+ const $ = id => document.getElementById(id);
+
+ /* ----------- 0. DOM 快捷引用 ----------- */
+ const currentPrice = $('currentPrice');
+ const originalPrice = $('originalPrice');
+ const dropPrice = $('dropPrice');
+ const soldBox = $('soldBox');
+ const groupTitle = $('groupTitle');
+ const userList = $('userList');
+ const singlePriceSpan = $('singlePrice');
+ const groupPriceSpan = $('groupPrice');
+ const btnSingle = $('btnSingle');
+ const btnGroup = $('btnGroup');
+
+ /* =====================================================
+ * 1. 取接口数据并渲染
+ * =================================================== */
+ const CFG_API = 'http://127.0.0.1:8091/api/v1/gbm/index/query_group_buy_market_config';
+
+ // 登录检查
+ const loginToken = getCookie('loginToken');
+ if (!loginToken) { location.href = 'login.html'; return; }
+ const username = loginToken;
+
+ // 保存活动 id（开团 / 参团时要用）
+ let activityId = null;
+
+ const POST_BODY = {
+ userId : username,
+ source : 's01',
+ channel: 'c01',
+ goodsId: '9890001'
+ };
+
+ fetch(CFG_API, {
+ method : 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body : JSON.stringify(POST_BODY)
+ })
+ .then(r => r.json())
+ .then(({ code, info, data }) => {
+ if (code !== '0000' || !data) { console.error(info); return; }
+
+ activityId = data.activityId;
+ renderGoods(data.goods);
+ renderStatistic(data.teamStatistic);
+ renderTeams(data.teamList, data.goods?.payPrice);
+ })
+ .catch(console.error);
+
+ /* ------------- 渲染商品信息 ------------- */
+ function renderGoods(g = {}) {
+ const { originalPrice: op = 0, payPrice = 0, deductionPrice = 0 } = g;
+ currentPrice.textContent = payPrice;
+ originalPrice.textContent = op;
+ dropPrice.textContent = `直降 ￥${deductionPrice}`;
+
+ singlePriceSpan.textContent = `￥${op}`;
+ groupPriceSpan.textContent = `￥${payPrice}`;
+ btnSingle.dataset.price = op;
+ btnGroup.dataset.price = payPrice;
+ }
+
+ /* ------------- 渲染统计信息 ------------- */
+ function renderStatistic(stat = {}) {
+ const { allTeamUserCount = 0 } = stat;
+ groupTitle.textContent = `${allTeamUserCount}人在抢，参与可立即拼成`;
+ soldBox.textContent = `${allTeamUserCount}人再抢`;
+ }
+
+ /* ------------- 渲染拼团列表 ------------- */
+ function renderTeams(list = [], groupPrice = 0) {
+ if (!list?.length) {
+ groupTitle.textContent = '小伙伴，赶紧去开团吧，做村里最靓的仔。';
+ return;
+ }
+ userList.innerHTML = '';
+ list.forEach(t => userList.appendChild(makeItem(t, groupPrice)));
+ initUserMarquee();
+ initCountdown();
+ }
+
+ // 把 teamId / activityId 写到 user-info 的 dataset 上，便于点击时读取
+ function makeItem(team, price) {
+ const { userId, targetCount, lockCount,
+ validTimeCountdown, teamId, activityId: tActId } = team;
+ const leftNum = Math.max(targetCount - lockCount, 0);
+ const timeText = validTimeCountdown || '00:00:00';
+
+ const div = document.createElement('div');
+ div.className = 'user-item';
+ div.innerHTML = `
+ 程序员 - 同款机械键盘
+ + +
- 价格：¥1.68
+ + + + + + + +
+
-
+
+ 
+ 
+ 
-
- 测试账号：jhmfgu7187@sandbox.com 密码：111111 支付：111111
+
+
+
+
+
+
+ `;
+ return div;
+ }
+
+ /* =====================================================
+ * 2. 拼单列表纵向轮播
+ * =================================================== */
+ function initUserMarquee() {
+ const items = userList.querySelectorAll('.user-item');
+ if (items.length <= 1) return;
+
+ const itemH = items[0].offsetHeight;
+ userList.appendChild(items[0].cloneNode(true));
+
+ let idx = 0;
+ userList.addEventListener('transitionend', () => {
+ if (idx >= items.length) {
+ userList.style.transition = 'none';
+ userList.style.transform = 'translateY(0)';
+ idx = 0;
+ void userList.offsetWidth;
+ }
+ });
+
+ setInterval(() => {
+ idx++;
+ userList.style.transition = 'transform .5s ease';
+ userList.style.transform = `translateY(${-idx * itemH}px)`;
+ }, 3000);
+ }
+
+ /* =====================================================
+ * 3. 倒计时
+ * =================================================== */
+ let countdownData = [];
+
+ function initCountdown() {
+ const els = document.querySelectorAll('.countdown');
+ countdownData = Array.from(els).map(el => ({
+ el,
+ remain: toSec(el.textContent.trim())
+ }));
+ setInterval(tick, 1000);
+ }
+
+ const toSec = t => {
+ if (!t.includes(':')) return 0;
+ const [h='00', m='00', s='00'] = t.split(':');
+ return +h*3600 + +m*60 + +s;
+ };
+ const fmt = n => String(n).padStart(2,'0');
+ const format = s => `${fmt(s/3600|0)}:${fmt((s%3600)/60|0)}:${fmt(s%60)}`;
+
+ function tick() {
+ countdownData.forEach(c=>{
+ if (c.remain > 0) {
+ c.remain--;
+ c.el.textContent = format(c.remain);
+ if(!c.remain) expire(c.el);
+ }
+ });
+ }
+ function expire(el){
+ el.textContent = '00:00:00';
+ const item = el.closest('.user-item');
+ item?.classList.add('expired');
+ item?.querySelector('.buy-btn')?.setAttribute('disabled','disabled');
+ }
+
+ /* =====================================================
+ * 4. 支付相关
+ * =================================================== */
+ const PAY_MALL_URL = 'http://127.0.0.1:8092';
+ const CREATE_PAY_API = `${PAY_MALL_URL}/api/v1/alipay/create_pay_order`;
+
+ // 4.1 支付确认弹窗
+ function showPaymentConfirm(price){
+ if(document.querySelector('.payment-overlay')) return;
+
+ const tpl = document.getElementById('tpl-payment');
+ const overlay = tpl.content.firstElementChild.cloneNode(true);
+
+ overlay.querySelector('#priceText').textContent = `￥${price}`;
+ overlay.querySelector('.copyable').onclick = function(){
+ navigator.clipboard.writeText(this.dataset.copy)
+ .then(()=>alert('买家账号已复制到剪贴板'));
+ };
+ overlay.querySelector('.cancel-btn').onclick = ()=>{
+ document.querySelectorAll('form').forEach(f=>f.remove());
+ overlay.remove();
+ };
+ overlay.querySelector('.confirm-btn').onclick = ()=>{
+ document.querySelector('form')?.submit();
+ overlay.remove();
+ };
+ overlay.addEventListener('click',e=>{
+ if(e.target===overlay) overlay.querySelector('.cancel-btn').click();
+ });
+
+ document.body.appendChild(overlay);
+ }
+
+ /* ---------- 4.2 单独购买 ---------- */
+ btnSingle.addEventListener('click', () => {
+ if (!getCookie('loginToken')) { location.href = 'login.html'; return; }
+
+ fetch(CREATE_PAY_API, {
+ method : 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body : JSON.stringify({
+ userId : username,
+ productId : POST_BODY.goodsId,
+ marketType: 0
+ })
+ })
+ .then(r=>r.json())
+ .then(json=>{
+ if (json.code!=='0000') return alert(json.info||'下单失败');
+ document.querySelectorAll('form').forEach(f=>f.remove());
+ document.body.insertAdjacentHTML('beforeend', json.data);
+ showPaymentConfirm(btnSingle.dataset.price);
+ })
+ .catch(console.error);
+ });
+
+ /* ---------- 4.3 开团购买 ---------- */
+ btnGroup.addEventListener('click', () => {
+ if (!getCookie('loginToken')) { location.href = 'login.html'; return; }
+
+ fetch(CREATE_PAY_API, {
+ method : 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body : JSON.stringify({
+ userId : username,
+ productId : POST_BODY.goodsId,
+ marketType: 1,
+ activityId: activityId
+ })
+ })
+ .then(r=>r.json())
+ .then(json=>{
+ if (json.code!=='0000') return alert(json.info||'下单失败');
+ document.querySelectorAll('form').forEach(f=>f.remove());
+ document.body.insertAdjacentHTML('beforeend', json.data);
+ showPaymentConfirm(btnGroup.dataset.price);
+ })
+ .catch(console.error);
+ });
+
+ /* ---------- 4.4 参与拼团（ buy-btn ）---------- */
+ document.body.addEventListener('click', e => {
+ const joinBtn = e.target.closest('.buy-btn');
+ if (!joinBtn) return;
+
+ if (!getCookie('loginToken')) { location.href = 'login.html'; return; }
+
+ // 获取 teamId、activityId
+ const userInfo = joinBtn.closest('.user-item')?.querySelector('.user-info');
+ const teamId = userInfo?.dataset.teamid;
+ const actId = userInfo?.dataset.activityid || activityId;
+
+ if (!teamId) { return alert('拼团信息已失效，请刷新页面'); }
+
+ fetch(CREATE_PAY_API, {
+ method : 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body : JSON.stringify({
+ userId : username,
+ productId : POST_BODY.goodsId,
+ teamId : teamId,
+ activityId: actId,
+ marketType: 1 // 参团
+ })
+ })
+ .then(r=>r.json())
+ .then(json=>{
+ if (json.code!=='0000') return alert(json.info||'参团失败');
+ document.querySelectorAll('form').forEach(f=>f.remove());
+ document.body.insertAdjacentHTML('beforeend', json.data);
+ showPaymentConfirm(joinBtn.dataset.price);
+ })
+ .catch(console.error);
+ });
+
+ /* =====================================================
+ * 5. 顶部横向轮播（原逻辑保留）
+ * =================================================== */
+ const wrapper = document.querySelector('.swiper-wrapper');
+ const slides = [...wrapper.children];
+ const pagination = document.querySelector('.swiper-pagination');
+ const count = slides.length;
+
+ let current = 0, startX = 0, dragging = false, timer;
+ for (let i = 0; i < count; i++) {
+ const dot = document.createElement('div');
+ dot.className = 'swiper-dot' + (i===0?' active':'');
+ dot.onclick = () => goTo(i);
+ pagination.appendChild(dot);
+ }
+ const dots = pagination.children;
+
+ const goTo = i => {
+ current = (i+count)%count;
+ wrapper.style.transition = 'transform .3s ease';
+ wrapper.style.transform = `translateX(-${current*100}%)`;
+ [...dots].forEach((d,j)=>d.classList.toggle('active',j===current));
+ };
+ const auto = () => { timer=setInterval(()=>goTo(current+1),3000); };
+ const stop = () => clearInterval(timer);
+ auto();
+
+ const getX = e => e.touches?e.touches[0].clientX:e.clientX;
+ wrapper.addEventListener('pointerdown', e=>{
+ stop(); dragging=true; startX=getX(e); wrapper.style.transition='none';
+ });
+ wrapper.addEventListener('pointermove', e=>{
+ if(!dragging) return;
+ const diff=getX(e)-startX;
+ wrapper.style.transform=`translateX(calc(${-current*100}% + ${diff}px))`;
+ });
+ wrapper.addEventListener('pointerup',endSwipe);
+ wrapper.addEventListener('pointercancel',endSwipe);
+ wrapper.addEventListener('pointerleave',endSwipe);
+
+ function endSwipe(e){
+ if(!dragging) return; dragging=false;
+ const diff=getX(e)-startX;
+ const limit=wrapper.offsetWidth*0.15;
+ if(diff> limit) goTo(current-1);
+ else if(diff<-limit) goTo(current+1);
+ else goTo(current);
+ auto();
+ }
+});
diff --git a/docs/dev-ops/nginx/html/js/login.js b/docs/dev-ops/nginx/html/js/login.js
new file mode 100644
index 0000000..501f585
--- /dev/null
+++ b/docs/dev-ops/nginx/html/js/login.js
@@ -0,0 +1,52 @@
+/* -------------------- 配置 -------------------- */
+const sPayMallUrl = "http://127.0.0.1:8092";
+
+/* -------------------- 工具函数 -------------------- */
+function setCookie(name, value, days) {
+ const date = new Date();
+ date.setTime(date.getTime() + days * 24 * 60 * 60 * 1000);
+ document.cookie = `${name}=${value};expires=${date.toUTCString()};path=/`;
+}
+
+/* -------------------- 主逻辑 -------------------- */
+document.addEventListener("DOMContentLoaded", () => {
+ // 1) 先拿二维码 ticket
+ fetch(`${sPayMallUrl}/api/v1/login/weixin_qrcode_ticket`)
+ .then(res => res.json())
+ .then(data => {
+ if (data.code !== "0000") {
+ console.error("获取二维码 ticket 失败:", data.info);
+ return;
+ }
+
+ const ticket = data.data;
+ const qrCodeImg = document.getElementById("qr-code-img");
+ qrCodeImg.src = `https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=${ticket}`;
+ qrCodeImg.classList.remove("pulse");
+
+ // 2) 轮询确认登录
+ const intervalId = setInterval(() => checkLoginStatus(ticket, intervalId), 3000);
+ })
+ .catch(err => console.error("请求失败:", err));
+});
+
+/* -------------------- 轮询检查登录 -------------------- */
+function checkLoginStatus(ticket, intervalId) {
+ fetch(`${sPayMallUrl}/api/v1/login/check_login?ticket=${ticket}`)
+ .then(res => res.json())
+ .then(data => {
+ if (data.code === "0000") {
+ // 登录成功，停轮询
+ clearInterval(intervalId);
+
+ // 把 token 写入 cookie（30 天）
+ setCookie("loginToken", data.data, 30);
+
+ // 跳转首页
+ window.location.href = "./index.html";
+ } else {
+ console.info("login wait");
+ }
+ })
+ .catch(err => console.error("请求失败:", err));
+}
diff --git a/docs/dev-ops/nginx/html/login.html b/docs/dev-ops/nginx/html/login.html
index a393a3f..488b2c1 100644
--- a/docs/dev-ops/nginx/html/login.html
+++ b/docs/dev-ops/nginx/html/login.html
@@ -1,105 +1,30 @@
-
-
-
- 
+
-
+
+
diff --git a/pay-mall-domain/src/main/java/edu/whut/domain/order/service/AbstractOrderService.java b/pay-mall-domain/src/main/java/edu/whut/domain/order/service/AbstractOrderService.java
index 0d38bad..b33d0f9 100644
--- a/pay-mall-domain/src/main/java/edu/whut/domain/order/service/AbstractOrderService.java
+++ b/pay-mall-domain/src/main/java/edu/whut/domain/order/service/AbstractOrderService.java
@@ -27,11 +27,12 @@ public abstract class AbstractOrderService implements IOrderService {
*/
@Override
public PayOrderEntity createOrder(ShopCartEntity shopCartEntity) throws Exception {
- // 1. 查询当前用户是否存在掉单和未支付订单
+ // 1. 查询当前用户是否存在掉单或未支付订单
OrderEntity unpaidOrderEntity = repository.queryUnPayOrder(shopCartEntity);
- // 如果已有未支付订单且状态为支付等待，则直接复用
- if (unpaidOrderEntity != null && OrderStatusVO.PAY_WAIT.equals(unpaidOrderEntity.getOrderStatusVO())) {
+ // 如果已有未支付订单且状态为“等待支付”，直接复用该订单
+ if (unpaidOrderEntity != null
+ && OrderStatusVO.PAY_WAIT.equals(unpaidOrderEntity.getOrderStatusVO())) {
log.info("创建订单-存在，已存在未支付订单。userId:{} productId:{} orderId:{}",
shopCartEntity.getUserId(), shopCartEntity.getProductId(), unpaidOrderEntity.getOrderId());
return PayOrderEntity.builder()
@@ -39,41 +40,64 @@ public abstract class AbstractOrderService implements IOrderService {
.payUrl(unpaidOrderEntity.getPayUrl())
.build();
- // 如果已有订单仅创建了记录但未生成支付单，则生成支付单
- } else if (unpaidOrderEntity != null && OrderStatusVO.CREATE.equals(unpaidOrderEntity.getOrderStatusVO())) {
+ // 如果已有订单仅创建了记录但未生成支付单，则进入支付单生成流程
+ } else if (unpaidOrderEntity != null
+ && OrderStatusVO.CREATE.equals(unpaidOrderEntity.getOrderStatusVO())) {
log.info("创建订单-存在，存在未创建支付单订单，创建支付单开始 userId:{} productId:{} orderId:{}",
shopCartEntity.getUserId(), shopCartEntity.getProductId(), unpaidOrderEntity.getOrderId());
+
Integer marketType = unpaidOrderEntity.getMarketType();
BigDecimal marketDeductionAmount = unpaidOrderEntity.getMarketDeductionAmount();
PayOrderEntity payOrderEntity;
- if (MarketTypeVO.GROUP_BUY_MARKET.getCode().equals(marketType) && marketDeductionAmount == null) {
+ // === marketType 分支处理 ===
+ if (MarketTypeVO.GROUP_BUY_MARKET.getCode().equals(marketType)
+ && marketDeductionAmount == null) {
+ // 1) 是拼团类型，且还未计算优惠（deductionAmount == null）时
+ // 先锁定优惠（如拼团满减），获取 discount 对象
MarketPayDiscountEntity discount = lockMarketPayOrder(
- shopCartEntity.getUserId(), shopCartEntity.getTeamId(),
- shopCartEntity.getActivityId(), shopCartEntity.getProductId(),
+ shopCartEntity.getUserId(),
+ shopCartEntity.getTeamId(),
+ shopCartEntity.getActivityId(),
+ shopCartEntity.getProductId(),
unpaidOrderEntity.getOrderId());
+ // 2) 再发起预支付，传入优惠后金额
payOrderEntity = doPrepayOrder(
- shopCartEntity.getUserId(), shopCartEntity.getProductId(),
- unpaidOrderEntity.getProductName(), unpaidOrderEntity.getOrderId(),
- unpaidOrderEntity.getTotalAmount(), discount);
+ shopCartEntity.getUserId(),
+ shopCartEntity.getProductId(),
+ unpaidOrderEntity.getProductName(),
+ unpaidOrderEntity.getOrderId(),
+ unpaidOrderEntity.getTotalAmount(),
+ discount);
+
} else if (MarketTypeVO.GROUP_BUY_MARKET.getCode().equals(marketType)) {
+ // 是拼团类型，但已经计算过优惠，直接使用 payAmount（已扣优惠）
payOrderEntity = doPrepayOrder(
- shopCartEntity.getUserId(), shopCartEntity.getProductId(),
- unpaidOrderEntity.getProductName(), unpaidOrderEntity.getOrderId(),
+ shopCartEntity.getUserId(),
+ shopCartEntity.getProductId(),
+ unpaidOrderEntity.getProductName(),
+ unpaidOrderEntity.getOrderId(),
unpaidOrderEntity.getPayAmount());
+
} else {
+ // 其他类型（如单独购买或普通下单），按总价全额下单
payOrderEntity = doPrepayOrder(
- shopCartEntity.getUserId(), shopCartEntity.getProductId(),
- unpaidOrderEntity.getProductName(), unpaidOrderEntity.getOrderId(),
+ shopCartEntity.getUserId(),
+ shopCartEntity.getProductId(),
+ unpaidOrderEntity.getProductName(),
+ unpaidOrderEntity.getOrderId(),
unpaidOrderEntity.getTotalAmount());
}
+ // 返回已生成支付单的订单信息
return PayOrderEntity.builder()
.orderId(payOrderEntity.getOrderId())
.payUrl(payOrderEntity.getPayUrl())
.build();
}
+ // ———— 以下为“全新下单”流程 ————
+
// 2. 查询商品信息
ProductEntity productEntity = port.queryProductByProductId(shopCartEntity.getProductId());
@@ -89,16 +113,18 @@ public abstract class AbstractOrderService implements IOrderService {
.build();
this.doSaveOrder(orderAggregate);
- // 4. 如果是拼团，发起营销锁单
+ // 4. 如果是拼团（marketType == GROUP_BUY_MARKET），先锁定营销优惠
MarketPayDiscountEntity marketPayDiscountEntity = null;
if (MarketTypeVO.GROUP_BUY_MARKET.equals(shopCartEntity.getMarketTypeVO())) {
- marketPayDiscountEntity = this.lockMarketPayOrder(
- shopCartEntity.getUserId(), shopCartEntity.getTeamId(),
- shopCartEntity.getActivityId(), shopCartEntity.getProductId(),
+ marketPayDiscountEntity = this.lockMarketPayOrder( //调用拼团交易系统的锁单逻辑
+ shopCartEntity.getUserId(),
+ shopCartEntity.getTeamId(),
+ shopCartEntity.getActivityId(),
+ shopCartEntity.getProductId(),
orderEntity.getOrderId());
}
- // 5. 创建支付订单
+ // 5. 创建支付订单（预支付），如果有拼团优惠则传入 discount，否则按原价下单
PayOrderEntity payOrderEntity = doPrepayOrder(
shopCartEntity.getUserId(),
productEntity.getProductId(),
@@ -110,12 +136,14 @@ public abstract class AbstractOrderService implements IOrderService {
log.info("创建订单-完成，生成支付单。userId: {} orderId: {} payUrl: {}",
shopCartEntity.getUserId(), orderEntity.getOrderId(), payOrderEntity.getPayUrl());
+ // 返回新订单的支付链接
return PayOrderEntity.builder()
.orderId(orderEntity.getOrderId())
.payUrl(payOrderEntity.getPayUrl())
.build();
}
+
/**
* 保存订单
*/
diff --git a/pay-mall-domain/src/main/java/edu/whut/domain/order/service/OrderService.java b/pay-mall-domain/src/main/java/edu/whut/domain/order/service/OrderService.java
index 0bf78a1..bf217a8 100644
--- a/pay-mall-domain/src/main/java/edu/whut/domain/order/service/OrderService.java
+++ b/pay-mall-domain/src/main/java/edu/whut/domain/order/service/OrderService.java
@@ -56,7 +56,7 @@ public class OrderService extends AbstractOrderService{
@Override
protected PayOrderEntity doPrepayOrder(String userId, String productId, String productName, String orderId, BigDecimal totalAmount, MarketPayDiscountEntity marketPayDiscountEntity) throws AlipayApiException {
- // 支付金额
+ // 支付金额，如果走拼团流程就取PayPrice，否则就是totalAmount
BigDecimal payAmount = null == marketPayDiscountEntity ? totalAmount : marketPayDiscountEntity.getPayPrice();
AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();
diff --git a/pay-mall-trigger/src/main/java/edu/whut/trigger/http/AliPayController.java b/pay-mall-trigger/src/main/java/edu/whut/trigger/http/AliPayController.java
index 594178b..10cdb6c 100644
--- a/pay-mall-trigger/src/main/java/edu/whut/trigger/http/AliPayController.java
+++ b/pay-mall-trigger/src/main/java/edu/whut/trigger/http/AliPayController.java
@@ -54,6 +54,7 @@ public class AliPayController implements IPayService {
.productId(productId)
.teamId(teamId)
.marketTypeVO(MarketTypeVO.valueOf(marketType))
+ .activityId(createPayRequestDTO.getActivityId())
.build());
log.info("商品下单，根据商品ID创建支付单完成 userId:{} productId:{} orderId:{}", userId, productId, payOrderEntity.getOrderId());
diff --git a/pay-mall-trigger/src/main/java/edu/whut/trigger/job/NoPayNotifyOrderJob.java b/pay-mall-trigger/src/main/java/edu/whut/trigger/job/NoPayNotifyOrderJob.java
index 4d60eca..0970ebb 100644
--- a/pay-mall-trigger/src/main/java/edu/whut/trigger/job/NoPayNotifyOrderJob.java
+++ b/pay-mall-trigger/src/main/java/edu/whut/trigger/job/NoPayNotifyOrderJob.java
@@ -25,12 +25,13 @@ public class NoPayNotifyOrderJob {
private final AlipayClient alipayClient;
/**
- * 每 3 秒执行一次，扫描超过1分钟未收到回调的待支付订单
+ * 每 10 秒执行一次，扫描超过1分钟未收到回调的待支付订单
*/
- @Scheduled(cron = "0/3 * * * * ?")
+ @Scheduled(cron = "0/10 * * * * ?")
public void exec() {
try {
log.info("任务：检测未接收到或未正确处理的支付回调通知");
+ //查找所有STATUS为PAY_WAIT的订单
ListS Pay Mall 商城登录页
+
+ 欢迎登录 - 拼团团
+
- 
+
+
-
+
+
请使用微信扫描二维码登录
+ +
+ 请使用微信扫描二维码登录
+ 扫码后自动登录商城
+