From 3c884ccd7b51edf3b36840bf99de5edaa41a38a7 Mon Sep 17 00:00:00 2001
From: 张天森 <1292933220@qq.com>
Date: 星期三, 12 十月 2022 19:05:28 +0800
Subject: [PATCH] 三说会堂事件流程处理
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java | 59 ++++++++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 52 insertions(+), 7 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java
index 4fa3e88..ae12092 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java
@@ -1,6 +1,7 @@
package com.panzhihua.service_community.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
import com.panzhihua.common.constants.PayCpmstant;
import com.panzhihua.common.model.vos.common.ComBatteryCommodityOrderCollageTeamPeopleVo;
import com.panzhihua.common.model.vos.common.ComBatteryCommodityOrderCollageTeamVo;
@@ -81,7 +82,24 @@
*/
@Override
public R queryByPage(PageComBatteryCommodityOrderCollageTeamDto comBatteryCommodityOrderCollageTeam) {
- return R.ok(this.baseMapper.queryAllByLimit(comBatteryCommodityOrderCollageTeam, new Page(comBatteryCommodityOrderCollageTeam.getPageNum(), comBatteryCommodityOrderCollageTeam.getPageSize())));
+ IPage<ComBatteryCommodityOrderCollageTeamVo> orderCollageTeamVoIPage = this.baseMapper.queryAllByLimit(comBatteryCommodityOrderCollageTeam
+ , new Page(comBatteryCommodityOrderCollageTeam.getPageNum(), comBatteryCommodityOrderCollageTeam.getPageSize()));
+ //判断该用户是否参与了以下拼团
+ if(comBatteryCommodityOrderCollageTeam.getUserId() != null && comBatteryCommodityOrderCollageTeam.getUserId() != 0L){
+ Long userId = comBatteryCommodityOrderCollageTeam.getUserId();
+ orderCollageTeamVoIPage.getRecords().forEach(orderCollageTeam -> {
+ Map<String,Object> resultMap = this.baseMapper.getUserCollageDetail(orderCollageTeam.getId(),userId);
+ if(resultMap != null){
+ if(Integer.parseInt(resultMap.get("ktCount").toString()) > 0){
+ orderCollageTeam.setIsPartake(2);
+ }
+ if(Integer.parseInt(resultMap.get("ptCount").toString()) > 0){
+ orderCollageTeam.setIsPartake(2);
+ }
+ }
+ });
+ }
+ return R.ok(orderCollageTeamVoIPage);
}
/**
@@ -148,11 +166,24 @@
* @date 2022-03-29 16:06:58
*/
@Override
- public R detailById(Long id) {
+ public R detailById(Long id,Long userId) {
ComBatteryCommodityOrderCollageTeamVo orderCollageTeamVo = this.baseMapper.queryById(id);
if(orderCollageTeamVo != null){
List<ComBatteryCommodityOrderCollageTeamPeopleVo> collageTeamPeopleList = orderCollageTeamPeopleMapper.queryAllByTeamId(id);
orderCollageTeamVo.setOrderCollageTeamPeopleList(collageTeamPeopleList);
+ //判断该用户是否参与了以下拼团
+ if(userId != null && userId != 0L){
+ Map<String,Object> resultMap = this.baseMapper.getUserCollageDetail(orderCollageTeamVo.getId(),userId);
+ if(resultMap != null){
+ if(Integer.parseInt(resultMap.get("ktCount").toString()) > 0){
+ orderCollageTeamVo.setIsPartake(2);
+ }
+ if(Integer.parseInt(resultMap.get("ptCount").toString()) > 0){
+ orderCollageTeamVo.setIsPartake(2);
+ }
+ }
+ }
+
}
return R.ok(orderCollageTeamVo);
}
@@ -189,9 +220,6 @@
|| commodityActivity.getStatus().equals(ComBatteryCommodityActivity.Status.YJS)){
return R.fail("该活动已结束");
}
- if(commodityActivity.getCommodityNum() <= commodityActivity.getCommoditySaleNum()){
- return R.fail("活动商品已售空");
- }
if(orderDto.getType().equals(StartFightOrderDto.Type.PT)){
//判断该团队人数是否已满
Integer count = orderCollageTeamPeopleMapper.selectCount(new QueryWrapper<ComBatteryCommodityOrderCollageTeamPeople>().lambda()
@@ -199,10 +227,20 @@
if(count >= commodityActivity.getCollagePeopleNum()){
return R.fail("拼团人数已满");
}
+ //判断该团是否已参与
+ Integer userCount = orderCollageTeamPeopleMapper.selectCount(new QueryWrapper<ComBatteryCommodityOrderCollageTeamPeople>().lambda()
+ .eq(ComBatteryCommodityOrderCollageTeamPeople::getTeamId,orderDto.getTeamId())
+ .eq(ComBatteryCommodityOrderCollageTeamPeople::getUserId,orderDto.getUserId()));
+ if(userCount >= commodityActivity.getCollagePeopleNum()){
+ return R.fail("您已参与该拼团，不可重复参与");
+ }
//查询拼团团队
ComBatteryCommodityOrderCollageTeam orderCollageTeam = orderCollageTeamMapper.selectById(orderDto.getTeamId());
if(orderCollageTeam == null){
return R.fail("该拼团不存在");
+ }
+ if(orderDto.getUserId().equals(orderCollageTeam.getUserId())){
+ return R.fail("您不可拼自己的团");
}
if(!orderCollageTeam.getStatus().equals(ComBatteryCommodityOrderCollageTeam.Status.DDPT)){
return R.fail("该拼团已成功");
@@ -210,8 +248,15 @@
}else{
Integer count = orderCollageTeamMapper.selectCount(new QueryWrapper<ComBatteryCommodityOrderCollageTeam>().lambda()
.eq(ComBatteryCommodityOrderCollageTeam::getActivityId,orderDto.getActivityId())
+ .eq(ComBatteryCommodityOrderCollageTeam::getStatus,ComBatteryCommodityOrderCollageTeam.Status.DDPT)
+ .eq(ComBatteryCommodityOrderCollageTeam::getUserId,orderDto.getUserId()));
+ if(count > 0){
+ return R.fail("当前活动商品您正在拼团中，不可重复开团");
+ }
+ Integer maxCount = orderCollageTeamMapper.selectCount(new QueryWrapper<ComBatteryCommodityOrderCollageTeam>().lambda()
+ .eq(ComBatteryCommodityOrderCollageTeam::getActivityId,orderDto.getActivityId())
.eq(ComBatteryCommodityOrderCollageTeam::getStatus,ComBatteryCommodityOrderCollageTeam.Status.DDPT));
- if(count >= commodityActivity.getCollageNum()){
+ if(maxCount >= commodityActivity.getCollageNum()){
return R.fail("当前正在拼团的数量已达到最大值，不可在开团");
}
}
@@ -221,7 +266,7 @@
return R.fail("未查询到商品信息");
}
//查询用户信息
- SysUser user = userMapper.selectById(orderDto.getUserId());
+ SysUser user = userMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,orderDto.getUserId()));
if(user == null){
return R.fail("未查询到用户信息");
}
--
Gitblit v1.7.1