绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
peng
17 小时以前 c5a203cd94117eb87fa4ff7df974a4aaee5ed83b 
 framework/src/main/java/cn/lili/modules/order/order/serviceimpl/OrderServiceImpl.java


@@ -85,17 +85,21 @@


import org.apache.poi.ss.util.CellRangeAddressList;


import org.apache.poi.xssf.usermodel.XSSFWorkbook;


import org.apache.rocketmq.spring.core.RocketMQTemplate;


import org.redisson.api.RedissonClient;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.context.ApplicationEventPublisher;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import javax.annotation.Resource;


import javax.servlet.ServletOutputStream;


import javax.servlet.http.HttpServletResponse;


import java.io.InputStream;


import java.net.URLEncoder;


import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;


import cn.lili.modules.permission.entity.dos.Role;


/**


@@ -189,7 +193,10 @@


    @Autowired


    private AdminUserService adminUserService;




    @Resource


    private RedisTemplate<Object,Object> redisTemplate;




    private final static  String LOCK_ORDER_NO_MQ="lock_order_no_mq:";


    @Override


    @Transactional(rollbackFor = Exception.class)


    public void intoDB(TradeDTO tradeDTO) {


@@ -458,6 +465,11 @@


    @Override


    @Transactional


    public String sendMqMessage(String snNo) {


        //限制30秒只能请求一次避免出现重新提交问题


        Boolean b = redisTemplate.opsForValue().setIfAbsent(LOCK_ORDER_NO_MQ + snNo, snNo,30, TimeUnit.SECONDS);


        if ( Boolean.FALSE.equals(b)){


            throw new ServiceException("请在30秒后重试");


        }


        Order order = this.getBySn(snNo);


        if (order == null) {


            throw new ServiceException(ResultCode.ORDER_NOT_EXIST);