JAVA商城系统推三返一商城系统源码支持小程序+公众号+H5

-- 订单表CREATE TABLE t_order (  id BIGINT PRIMARY KEY AUTO_INCREMENT,  order_no VARCHAR(32) NOT NULL,  member_id BIGINT NOT NULL,  amt DECIMAL(10,2) NOT NULL,  status TINYINT NOT NULL DEFAULT 0,  request_no VARCHAR(64) NOT NULL,  version INT NOT NULL DEFAULT 0,  create_time DATETIME DEFAULT CURRENT_TIMESTAMP,  UNIQUE KEY uk_no (order_no),  UNIQUE KEY uk_req (member_id, request_no),  KEY idx_m (member_id, status)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;-- 推荐关系:一人只绑一个上级CREATE TABLE t_bind (  id BIGINT PRIMARY KEY AUTO_INCREMENT,  member_id BIGINT NOT NULL,  inviter_id BIGINT NOT NULL,  bind_time DATETIME DEFAULT CURRENT_TIMESTAMP,  UNIQUE KEY uk_m (member_id),  KEY idx_i (inviter_id)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;-- 返利流水:同单同人只记一条CREATE TABLE t_rebate (  id BIGINT PRIMARY KEY AUTO_INCREMENT,  order_no VARCHAR(32) NOT NULL,  inviter_id BIGINT NOT NULL,  amt DECIMAL(10,2) NOT NULL,  status TINYINT NOT NULL DEFAULT 0,  create_time DATETIME DEFAULT CURRENT_TIMESTAMP,  UNIQUE KEY uk_ou (order_no, inviter_id),  KEY idx_i (inviter_id, status)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

@Servicepublic class OrderService {  @Resource OrderMapper orderMapper;  @Resource BindMapper bindMapper;  @Resource StockMapper stockMapper;  /** 建单 + 扣库存 + 绑推荐,任一失败全回滚 */  @Transactional(rollbackFor = Exception.class)  public Long create(OrderDTO o) {    int n = stockMapper.deduct(o.getSkuId(),        o.getQty());    if (n == 0) {      throw new BizException("库存不足");    }    OrderPO p = new OrderPO();    p.setOrderNo(Snowflake.next("SO"));    p.setMemberId(o.getMemberId());    p.setAmt(o.getAmt());    p.setRequestNo(o.getRequestNo());    p.setStatus(0);    orderMapper.insert(p);    String inv = o.getInviterId();    if (inv != null && inv.length() > 0) {      bindMapper.bindOnce(o.getMemberId(),          Long.parseLong(inv));    }    return p.getId();  }}

@Mapperpublic interface StockMapper {  /** 库存不足时影响行数为 0 */  @Update("UPDATE t_sku "      + "SET stock = stock - #{qty} "      + "WHERE id = #{id} AND stock >= #{qty}")  int deduct(@Param("id") Long id,             @Param("qty") int qty);  /** 带版本号:防并发覆盖 */  @Update("UPDATE t_sku "      + "SET stock = stock - #{qty}, "      + "version = version + 1 "      + "WHERE id = #{id} AND stock >= #{qty} "      + "AND version = #{ver}")  int deductWithVer(@Param("id") Long id,                    @Param("qty") int qty,                    @Param("ver") int ver);}

/** 幂等:请求号查重 -> Redis 占位 -> 唯一键兜底 */public Long submit(OrderDTO o) {  Long uid = o.getMemberId();  String req = o.getRequestNo();  OrderPO old = orderMapper.findByReq(uid, req);  if (old != null) {    return old.getId();   // 已处理  }  String key = "order:req:" + uid + ":" + req;  Boolean ok = redis.opsForValue()      .setIfAbsent(key, "1", 10, MINUTES);  if (Boolean.FALSE.equals(ok)) {    throw new BizException("请勿重复提交");  }  try {    return orderService.create(o);  } catch (DuplicateKeyException e) {    String m = e.getMessage();    if (m != null && m.contains("uk_req")) {      return orderMapper          .findByReq(uid, req).getId();    }    throw e;   // 订单号撞了  }}

@RestController@RequestMapping("/admin/rebate")public class RebateAdminController {  /** 提现审核:只有财务能改状态 */  @PreAuthorize("hasRole('FINANCE')")  @PostMapping("/audit/{id}")  public R audit(@PathVariable Long id,                 @RequestParam Integer pass) {    RebatePO r = rebateService.get(id);    if (r == null || r.getStatus() != 0) {      return R.fail("已处理");    }    rebateService.audit(id, pass, currentUser());    return R.ok();  }  /** 商品上下架:运营只能动本店 */  @PreAuthorize("hasAnyRole('ADMIN','OP')")  @PostMapping("/goods/{id}/status")  public R shelf(@PathVariable Long id,                 @RequestParam Integer st) {    GoodsPO g = goodsService.get(id);    Long shop = g.getShopId();    if (!perm.canTouch(currentUser(), shop)) {      return R.fail("无权操作该店商品");    }    goodsService.updateStatus(id, st);    return R.ok();  }}

// uni-app 统一请求:带 token 与请求号const BASE = 'https://demo.example.com/api';export function req(url, data, method) {  method = method || 'POST';  const token = uni.getStorageSync('token');  return new Promise((resolve, reject) => {    uni.request({      url: BASE + url,      method,      data,      header: {        'Content-Type': 'application/json',        'Authorization': token || '',        'X-Request-No': reqNo(),        'X-Client': 'mp-weixin'      },      success: (res) => {        const r = res.data || {};        if (r.code === 0) return resolve(r.data);        if (r.code === 401) {          uni.removeStorageSync('token');          uni.reLaunch({ url: '/pages/login' });          return reject(new Error('未登录'));        }        toast(r.msg);        reject(new Error(r.msg));      },      fail: (e) => {        toast('网络异常');        reject(e);      }    });  });}function toast(t) {  uni.showToast({ title: t, icon: 'none' });}function reqNo() {  const r = Math.random().toString(36);  return Date.now() + '-' + r.slice(2, 8);}

<template>  <div>    <el-input v-model="q.no" placeholder="订单号"              clearable />    <el-select v-model="q.status" clearable>      <el-option label="冻结中" :value="0" />      <el-option label="已入账" :value="1" />    </el-select>    <el-button type="primary" @click="load">      查询    </el-button>    <el-table :data="rows" border size="small">      <el-table-column prop="no" label="订单号" />    <el-table-column prop="user" label="推广人" />      <el-table-column prop="amt" label="返利" />      <el-table-column label="状态">        <template slot-scope="s">          <el-tag :type="tag(s.row.status)">            {{ text(s.row.status) }}          </el-tag>        </template>      </el-table-column>      <el-table-column label="操作">        <template slot-scope="s">          <el-button type="text" v-if="!s.row.st"                     @click="ok(s.row)">            审核          </el-button>          <span v-else>-</span>        </template>      </el-table-column>    </el-table>    <el-pagination :total="total" :page-size="10"                   layout="prev,pager,next"                   @current-change="onPage" />  </div></template>

上线前建议逐项打勾