Commit 375d2de5 authored by hanfeng's avatar hanfeng

Merge remote-tracking branch 'origin/dev' into dev

parents c2f54609 7f5a996c
...@@ -17,6 +17,8 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -17,6 +17,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.github.wxiaoqi.security.admin.mapper.AppUserSellingWaterMapper; import com.github.wxiaoqi.security.admin.mapper.AppUserSellingWaterMapper;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example; import tk.mybatis.mapper.entity.Example;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.*; import java.util.*;
...@@ -59,7 +61,7 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A ...@@ -59,7 +61,7 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A
//计算用户拥金 //计算用户拥金
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
public void orderWater(OrderWaterDTO orderWaterDTO) { public void orderWater(OrderWaterDTO orderWaterDTO) {
if (orderWaterDTO == null) { if (orderWaterDTO == null) {
log.info("计算用户拥金----orderWater----次数不能为空----"); log.info("计算用户拥金----orderWater----次数不能为空----");
...@@ -226,6 +228,7 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A ...@@ -226,6 +228,7 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A
sellingWater.setWaiting(1); sellingWater.setWaiting(1);
sellingWater.setStatus(1); sellingWater.setStatus(1);
sellingWater.setCommission(commission); sellingWater.setCommission(commission);
sellingWater.setId(null);
insertSelective(sellingWater); insertSelective(sellingWater);
log.info("租车订单完成计算用户拥成功----payOrderWater--------userId===" + userId); log.info("租车订单完成计算用户拥成功----payOrderWater--------userId===" + userId);
amount = amount.subtract(commission); amount = amount.subtract(commission);
......
...@@ -76,7 +76,8 @@ public class WaterMQHandler { ...@@ -76,7 +76,8 @@ public class WaterMQHandler {
case RENT_VEHICLE: case RENT_VEHICLE:
//租车订单finlish不处理,退还第一部分押金后再处理 //租车订单finlish不处理,退还第一部分押金后再处理
if(orderMQDTO.getSign().equals(ORDER_FINISH)) { if(orderMQDTO.getSign().equals(ORDER_FINISH)) {
break; //直接结束
return;
} }
orderMQDTO.getItemByTypeEnum(ItemTypeEnum.VEHICLE_MODEL); orderMQDTO.getItemByTypeEnum(ItemTypeEnum.VEHICLE_MODEL);
orderWaterDTO.setGoodsDTOList( orderWaterDTO.setGoodsDTOList(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment