| | |
|---|
| | | Activity activity; |
|---|
| | | // 获取当前时间 |
|---|
| | | Date nowTime = new Date(); |
|---|
| | | if(mgtActivityEditDto.getActivityStartTime().compareTo(mgtActivityEditDto.getActivityEndTime())>0){ |
|---|
| | | throw new ServiceException(AppErrorConstant.ACTIVITY_SE_ERROR); |
|---|
| | | } |
|---|
| | | // 如果活动ID不为空，则表示修改活动信息 |
|---|
| | | if (StringUtils.isNotBlank(mgtActivityEditDto.getActivityId())) { |
|---|
| | | // 获取活动信息 |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void changeActivityTotal(ActivityTotalChangeDto activityTotalChangeDto){ |
|---|
| | | |
|---|
| | | log.debug("活动统计变化---"+activityTotalChangeDto.toString()); |
|---|
| | | RLock lock = redissonClient.getLock("activity_clock_"+activityTotalChangeDto.getActivityId()); |
|---|
| | | try { |
|---|
| | | lock.lock(30, TimeUnit.SECONDS); |
|---|
| | |
|---|
| | | try { |
|---|
| | | lock.lock(30, TimeUnit.SECONDS); |
|---|
| | | if(agStockChangeDto.getChangeType()==1){ |
|---|
| | | //减少销量增加库存 |
|---|
| | | activityMapper.addActivityGoodsStock(agStockChangeDto); |
|---|
| | | }else{ |
|---|
| | | //更新库存 |
|---|
| | | //增加销量减少库存 |
|---|
| | | activityMapper.subActivityGoodsStock(agStockChangeDto); |
|---|
| | | } |
|---|
| | | } finally { |
|---|
