商品更新下架

zhongzheng-system/src/main/java/com/zhongzheng/modules/schedule/service/impl/ScheduleServiceImpl.java

@@ -71,10 +71,7 @@ import com.zhongzheng.modules.polyv.vo.PolyvVideoVo;
 import com.zhongzheng.modules.polyv.vo.PolyvVo;
 import com.zhongzheng.modules.schedule.service.IScheduleService;
 import com.zhongzheng.modules.user.bo.*;
-import com.zhongzheng.modules.user.domain.UserExamGoods;
-import com.zhongzheng.modules.user.domain.UserPlan;
-import com.zhongzheng.modules.user.domain.UserPlanGoods;
-import com.zhongzheng.modules.user.domain.UserSubscribe;
+import com.zhongzheng.modules.user.domain.*;
 import com.zhongzheng.modules.user.mapper.UserPlanMapper;
 import com.zhongzheng.modules.user.service.*;
 import com.zhongzheng.modules.user.vo.*;
@@ -741,6 +738,7 @@ public class ScheduleServiceImpl extends ServiceImpl<PolyvVideoMapper, PolyvVide
 
     @Override
     public void UpExamNum(UserQueryBo bo) {
+        //查询购买后未添加考试次数的商品，添加考试次数
         List<ExamNumberVo> examNumbers = examNumberMapper.selectUpExamNum();
         for (ExamNumberVo examNumber : examNumbers) {
             UserExamGoods add = new UserExamGoods();
@@ -759,6 +757,41 @@ public class ScheduleServiceImpl extends ServiceImpl<PolyvVideoMapper, PolyvVide
             userExamGoodsSupplementAddBo.setStatus(3);
             userExamGoodsSupplementService.insertByAddBo(userExamGoodsSupplementAddBo);
         }
+
+        //查询变更考试次数的商品进行更改
+        List<ExamNumberVo> examNumberVos =examNumberMapper.selectUpExam();
+        for (ExamNumberVo examNumberVo : examNumberVos) {
+            UserExamGoodsQueryBo userExamGoodsQueryBo = new UserExamGoodsQueryBo();
+            userExamGoodsQueryBo.setUserId(examNumberVo.getUserId());
+            userExamGoodsQueryBo.setGoodsId(examNumberVo.getGoodsIds());
+            List<UserExamGoodsVo> userExamGoodsVos = userExamGoodsService.listUserExam(userExamGoodsQueryBo);
+            if (CollectionUtils.isEmpty(userExamGoodsVos)){
+                 continue;
+            }
+            UserExamGoodsVo userExamGoodsVo = userExamGoodsVos.get(0);
+            UserExamGoodsSupplementQueryBo userExamGoodsSupplementQueryBo = new UserExamGoodsSupplementQueryBo();
+            userExamGoodsSupplementQueryBo.setGoodsId(userExamGoodsVo.getGoodsId());
+            userExamGoodsSupplementQueryBo.setUserExamGoodsId(userExamGoodsVo.getUserExamGoodsId());
+            List<UserExamGoodsSupplementVo> userExamGoodsSupplementVos = userExamGoodsSupplementService.queryList(userExamGoodsSupplementQueryBo);
+            if (CollectionUtils.isEmpty(userExamGoodsSupplementVos)){
+                continue;
+            }
+            UserExamGoodsSupplementVo userExamGoodsSupplementVo = userExamGoodsSupplementVos.get(0);
+
+            //增加相应次数
+            Long examNum =  examNumberVo.getExamNumber() - userExamGoodsSupplementVo.getExamNumber();
+            Long doNum = examNumberVo.getDoNumber() - userExamGoodsSupplementVo.getDoNumber();
+            UserExamGoods userExamGoods = new UserExamGoods();
+            userExamGoods.setUserExamGoodsId(userExamGoodsVo.getUserExamGoodsId());
+            userExamGoods.setExpendNumber(userExamGoodsVo.getExpendNumber()+examNum);
+            userExamGoods.setDoNumber(userExamGoodsVo.getDoNumber()+doNum);
+            userExamGoodsService.updateById(userExamGoods);
+            UserExamGoodsSupplement userExamGoodsSupplement = new UserExamGoodsSupplement();
+            userExamGoodsSupplement.setId(userExamGoodsSupplementVo.getId());
+            userExamGoodsSupplement.setExamNumber(userExamGoodsSupplementVo.getExamNumber()+examNum);
+            userExamGoodsSupplement.setDoNumber(userExamGoodsSupplementVo.getDoNumber()+doNum);
+            userExamGoodsSupplementService.updateById(userExamGoodsSupplement);
+        }
     }
 
     //获得可用学习天数