秒杀商品怎样才能秒杀到(怎样秒杀商品成功)

    
    



    
        

            
                
                    秒杀活动时间:
                    
                        
                    
                    
                        
                            保 存
                        
                    
                
            
        
    
    
        
    

seckillGoodsOperate.js:

layui.define(()=>{
    let table=layui.table
    let laydate = layui.laydate
    let $=layui.jquery
    let layer=layui.layer

    // 读取普通商品
    table.render({
        elem: '#tb_goods'
        ,height: 500
        ,url: '/goods/queryAll' //数据接口
        ,page: true //开启分页
        ,parseData(res){ //res 即为原始返回的数据
            return {
                "code": res.code===200?0:1, //解析接口状态
                "msg": res.message, //解析提示文本
                "count": res.total, //解析数据长度
                "data": res.data //解析数据列表
            };
        },
        //用于对分页请求的参数：page、limit重新设定名称
        request: {
            pageName: 'page' //页码的参数名称，默认：page
            ,limitName: 'rows' //每页数据量的参数名，默认：limit
        }
        ,cols: [[ //表头
            // 全选按钮
             {field: '', type:"checkbox"}
            ,{field: 'gid', title: '商品编号', width:80}
            ,{field: 'goodsName', title: '商品名字'}
            ,{field: 'goodsTitle', title: '商品标题'}
            ,{field: 'goodsDetail', title: '商品详情'}
            ,{field: 'goodsPrice', title: '商品价格', sort: true}
            ,{field: 'goodsStock', title: '商品库存', sort: true}
        ]]
    });

    // 构建时间选择器
        //执行一个laydate实例
    laydate.render({
        elem: '#dt', //指定元素
        type: "datetime",
        range: "~"
    });

        $("#btn_save").click(()=>{
            // 获取时间
            let val=$("#dt").val()
            if(!val){
                layer.msg("请选择时间")
                return
            }
            // 解析时间2022-2-2 ~2022-5-2
            let startDate=new Date(val.split("~")[0]).getTime()
            let endDate=new Date(val.split("~")[1]).getTime()
            // 获得选中的普通商品,获取选中行的数据
            let rows= table.checkStatus('tb_goods').data; //idTest 即为基础参数 id 对应的值
            if(!rows||rows.length===0){
                layer.msg("请选择数据")
                return
            }

            layer.prompt(function(value, index, elem){
                // 修改每个商品的数量
                rows.forEach(e=>{
                    e.goodsStock=value
                })
                let data={
                    startDate,
                    endDate,
                    goods:rows
                }
                // 访问后台的秒杀商品的接口
                $.ajax({
                    url: "/seckillGoods/add",
                    contentType:'application/json',
                    data: JSON.stringify(data),
                    datatype:"json",//返回类型
                    type:"post",
                    success(res){
                        parent.seckill_reload()
                        layer.closeAll()
                        parent.layer.closeAll()
                        layer.msg(res.message)
                    }
                })
            });


        })

})

 增加成功：

SeckillGoodsMapper：

    Map querySeckillGoodsById(Long id);

mapper.xml文件：SeckillGoodsMapper.xml

    
        select sg.id,
               sg.goods_id,
               sg.seckill_price,
               sg.stock_count,
               sg.start_date,
               sg.end_date,
               g.goods_img,
               g.goods_title,
               g.goods_detail,
               g.goods_name,
               (
                   case
                       when current_timestamp < sg.start_date then 0
                       when (current_timestamp between sg.start_date and sg.end_date) then 1
                       when current_timestamp > sg.end_date then 2
                       end
                   ) goods_status
        from t_goods g,
             t_seckill_goods sg
        where g.gid = sg.goods_id
          and sg.id = #{0}
    

ISeckillGoodsService：

    Map querySeckillGoodsById(Long id);

SeckillGoodsServiceImpl：

    @Override
    public Map querySeckillGoodsById(Long id) {
        return seckillGoodsMapper.querySeckillGoodsById(id);
    }

package com.example.seckill.controller;

import com.example.seckill.service.ISeckillGoodsService;
import com.example.seckill.util.response.ResponseResult;
import com.example.seckill.vo.SeckillGoodsVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;

import java.util.List;


@Controller
@RequestMapping("/seckillGoods")
public class SeckillGoodsController {

    @Autowired
    private ISeckillGoodsService seckillGoodsService;

//    返回json
    @ResponseBody
    @RequestMapping("/queryAll")
    public ResponseResult> queryAll(){
        return seckillGoodsService.queryAll();
    }

    @ResponseBody
    @RequestMapping("/add")
    public ResponseResult> add(@RequestBody SeckillGoodsVo seckillGoodsVo){
        return seckillGoodsService.addGoods(seckillGoodsVo);
    }

//    正常跳转界面
@RequestMapping("/query/{id}")
public ModelAndView querySeckillGoodsById(@PathVariable("id") Long id) {
    ModelAndView mv = new ModelAndView("/goods/goodsSeckill");
    mv.addObject("goods", seckillGoodsService.querySeckillGoodsById(id));
    return mv;
}

}

{
                field: '', title: '操作', width: 140,
                templet: function (d) {
                    return `
                    删除
                    秒杀
                    `;
                }
            }

    <#include "../common/head.ftl"/>



    

        
商品图片
        

            
        
    
    

        
商品名称
        

            ${goods['goods_name']}
        
    
    

        
商品标题
        

            ${goods['goods_title']}
        
    
    

        
商品价格
        

            ${goods['seckill_price']}
        
    
    

        
开始时间
        

            
                ${goods['start_date']?string("yyyy-MM-dd HH:mm:ss")}
                -
                ${goods['end_date']?string("yyyy-MM-dd HH:mm:ss")}
                <#if goods['goods_status']==0>
                    活动未开始
                <#elseif goods['goods_status']==1>
                    活动热卖中
                    
                        
                        立即抢购
                    
                <#else>
                    活动已结束
                
            
        
    

let layer, form, $;

layui.define(() => {
    layer = layui.layer
    form = layui.form
    $ = layui.jquery

    $('#buy').click(() => {
        $.ajax({
            url: '/seckillOrder/addOrder',
            data: {goodsId: $('#goodsId').val()},
            dataType: 'json',
            type: 'post',
            async: false,
            success: function (rs) {
                if (rs.code === 200)
                    layer.msg(rs.message)
                else
                    layer.msg(rs.message)
            }
        })
    });

})

点击秒杀： 

package com.example.seckill.util;

@SuppressWarnings("all")
public class SnowFlake {

    
    private final static long START_STMP = 1480166465631L;

    
    private final static long SEQUENCE_BIT = 12; //序列号占用的位数
    private final static long MACHINE_BIT = 5;   //机器标识占用的位数
    private final static long DATACENTER_BIT = 5;//数据中心占用的位数

    
    private final static long MAX_DATACENTER_NUM = -1L ^ (-1L << DATACENTER_BIT);
    private final static long MAX_MACHINE_NUM = -1L ^ (-1L << MACHINE_BIT);
    private final static long MAX_SEQUENCE = -1L ^ (-1L << SEQUENCE_BIT);

    
    private final static long MACHINE_LEFT = SEQUENCE_BIT;
    private final static long DATACENTER_LEFT = SEQUENCE_BIT + MACHINE_BIT;
    private final static long TIMESTMP_LEFT = DATACENTER_LEFT + DATACENTER_BIT;

    private long datacenterId;  //数据中心
    private long machineId;     //机器标识
    private long sequence = 0L; //序列号
    private long lastStmp = -1L;//上一次时间戳

    public SnowFlake(long datacenterId, long machineId) {
        if (datacenterId > MAX_DATACENTER_NUM || datacenterId < 0) {
            throw new IllegalArgumentException("datacenterId can't be greater than MAX_DATACENTER_NUM or less than 0");
        }
        if (machineId > MAX_MACHINE_NUM || machineId < 0) {
            throw new IllegalArgumentException("machineId can't be greater than MAX_MACHINE_NUM or less than 0");
        }
        this.datacenterId = datacenterId;
        this.machineId = machineId;
    }

    public static void main(String[] args) {
        SnowFlake snowFlake = new SnowFlake(2, 3);
        long start = System.currentTimeMillis();
        for (int i = 0; i < 1000000; i++) {
            System.out.println(snowFlake.nextId());
        }
        System.out.println(System.currentTimeMillis() - start);
    }

    
    public synchronized long nextId() {
        long currStmp = getNewstmp();
        if (currStmp < lastStmp) {
            throw new RuntimeException("Clock moved backwards.  Refusing to generate id");
        }

        if (currStmp == lastStmp) {
            //相同毫秒内，序列号自增
            sequence = (sequence + 1) & MAX_SEQUENCE;
            //同一毫秒的序列数已经达到最大
            if (sequence == 0L) {
                currStmp = getNextMill();
            }
        } else {
            //不同毫秒内，序列号置为0
            sequence = 0L;
        }

        lastStmp = currStmp;

        return (currStmp - START_STMP) << TIMESTMP_LEFT //时间戳部分
                | datacenterId << DATACENTER_LEFT       //数据中心部分
                | machineId << MACHINE_LEFT             //机器标识部分
                | sequence;                             //序列号部分
    }

    private long getNextMill() {
        long mill = getNewstmp();
        while (mill <= lastStmp) {
            mill = getNewstmp();
        }
        return mill;
    }

    private long getNewstmp() {
        return System.currentTimeMillis();
    }

}

ISeckillOrderService ：

package com.example.seckill.service;

import com.example.seckill.pojo.SeckillOrder;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.seckill.pojo.User;
import com.example.seckill.util.response.ResponseResult;


public interface ISeckillOrderService extends IService {

    ResponseResult addOrder(Long goodsId, User user);
}

SeckillOrderServiceImpl ：

package com.example.seckill.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.example.seckill.exception.BusinessException;
import com.example.seckill.mapper.GoodsMapper;
import com.example.seckill.mapper.OrderMapper;
import com.example.seckill.mapper.SeckillGoodsMapper;
import com.example.seckill.pojo.*;
import com.example.seckill.mapper.SeckillOrderMapper;
import com.example.seckill.service.ISeckillOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.seckill.util.SnowFlake;
import com.example.seckill.util.response.ResponseResult;
import com.example.seckill.util.response.ResponseResultCode;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;


@Service
public class SeckillOrderServiceImpl extends ServiceImpl implements ISeckillOrderService {
    @Autowired
    private SeckillGoodsMapper seckillGoodsMapper;

    @Autowired
    private GoodsMapper goodsMapper;

    @Autowired
    private OrderMapper orderMapper;

    @Transactional(rollbackFor = Exception.class)
    @Override
    public ResponseResult addOrder(Long goodsId, User user) {
//        下单前判断库存数
        SeckillGoods goods = seckillGoodsMapper.selectOne(new QueryWrapper().eq("goods_id", goodsId));
        if (goods == null) {
            throw new BusinessException(ResponseResultCode.SECKILL_ORDER_ERROR);
        }
        if (goods.getStockCount() < 1) {
            throw new BusinessException(ResponseResultCode.SECKILL_ORDER_ERROR);
        }
//         限购
        SeckillOrder one = this.getOne(new QueryWrapper().eq("user_id", user.getId()).eq("goods_id", goodsId));
        if (one != null) {
            throw new BusinessException(ResponseResultCode.SECKILL_ORDER_EXISTS_ERROR);
        }
//       库存减一
        int i = seckillGoodsMapper.update(null, new UpdateWrapper().eq("goods_id", goodsId).setSql("stock_count=stock_count-1"));
//       根据商品编号查询对应的商品（拿名字）
        Goods goodsInfo = goodsMapper.selectOne(new QueryWrapper().eq("gid", goodsId));
        //       生成订单
        //生成雪花id
        SnowFlake snowFlake = new SnowFlake(5, 9);
        long id = snowFlake.nextId();
        //生成对应的订单
        Order normalOrder = new Order();
        normalOrder.setOid(id);
        normalOrder.setUserId(user.getId());
        normalOrder.setGoodsId(goodsId);
        normalOrder.setGoodsName(goodsInfo.getGoodsName());
        normalOrder.setGoodsCount(1);
        normalOrder.setGoodsPrice(goods.getSeckillPrice());
        orderMapper.insert(normalOrder);
        //生成秒杀订单
        SeckillOrder seckillOrder = new SeckillOrder();
        seckillOrder.setUserId(user.getId());
        seckillOrder.setOrderId(normalOrder.getOid());
        seckillOrder.setGoodsId(goodsId);
        this.save(seckillOrder);
        return ResponseResult.success();
    }
}

SeckillOrderController ：

package com.example.seckill.controller;

import com.example.seckill.pojo.User;
import com.example.seckill.service.ISeckillOrderService;
import com.example.seckill.util.response.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;


@RestController
@RequestMapping("/seckillOrder")
public class SeckillOrderController {

    @Autowired
    private ISeckillOrderService seckillOrderService;

    @RequestMapping("/addOrder")
    public ResponseResult addOrder(Long goodsId, User user){
        return seckillOrderService.addOrder(goodsId,user);
    }


}

限购次数：