合并代码

puzhibing

3 天以前 6598b47440f5be4adc1c793bbfc9f187be50a179

 user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/OrderServiceImpl.java

@@ -15,10 +15,8 @@
import com.supersavedriving.user.modular.system.util.MallBook.model.*;
import com.supersavedriving.user.modular.system.util.MallBook.util.Transfer;
import com.supersavedriving.user.modular.system.util.MallBook.util.TrhRequest;
import com.supersavedriving.user.modular.system.util.juhe.WeatherUtil;
import com.supersavedriving.user.modular.system.util.mongodb.model.Location;
import com.supersavedriving.user.modular.system.warpper.*;
import io.swagger.models.auth.In;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
@@ -35,9 +33,7 @@

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.MathContext;
import java.math.RoundingMode;
import java.net.InetAddress;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.*;
@@ -77,6 +73,9 @@

    @Autowired
    private RedisUtil redisUtil;

//    @Autowired
//    private RedissonClient redissonClient;

    @Autowired
    private MongoTemplate mongoTemplate;
@@ -433,10 +432,11 @@
     */
    @Override
    public ResultUtil travelOrder(Integer uid, TravelOrder travelOrder) throws Exception {
        boolean lock = redisUtil.lock(uid + "_travelOrder");
        if(!lock){
            return ResultUtil.error("系统繁忙，请稍后重试");
        }
//        RLock lock1 = redissonClient.getLock("travelOrder:" + uid);
//        boolean lock2 = lock1.tryLock(5, 10, TimeUnit.SECONDS);
//        if(!lock2){
//            return ResultUtil.error("系统繁忙，请稍后重试");
//        }
        try {
            List<Integer> state = Arrays.asList(101, 102, 103, 104, 105, 106, 107, 201, 401);
            Order order = this.selectOne(new EntityWrapper<Order>().eq("userId", uid).eq("status", 1).in("state", state));
@@ -549,7 +549,7 @@
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            redisUtil.unlock(uid + "_travelOrder");
//            lock1.unlock();
        }
        return ResultUtil.error("系统异常");
    }