From 73acd2a65a5dbab4573ef2a93a258c0da177bcd3 Mon Sep 17 00:00:00 2001
From: 张天森 <1292933220@qq.com>
Date: 星期四, 17 十一月 2022 11:58:38 +0800
Subject: [PATCH] 普达物业公司权限处理
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java | 69 ++++++++++++++++++++++++++++------
1 files changed, 56 insertions(+), 13 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..02877ce 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;
@@ -54,16 +55,14 @@
private ComBatteryTradeOrderService tradeOrderService;
@Value("${min.app.isTest}")
private Boolean isTest;
- @Value("${min.app.isRefundTest}")
- private Boolean isRefundTest;
@Value("${min.app.appid}")
private String appid;
@Value("${min.app.payKey}")
private String payKey;
@Value("${min.app.mchId}")
private String mchId;
- @Value("${min.app.currencyNotifyUrl}")
- private String currencyNotifyUrl;
+// @Value("${min.app.currencyNotifyUrl}")
+// private String currencyNotifyUrl;
@Resource
private ComBatteryCommodityMapper commodityMapper;
@Resource
@@ -81,7 +80,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 +164,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 +218,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 +225,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 +246,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 +264,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("未查询到用户信息");
}
@@ -281,8 +324,8 @@
money = BigDecimal.valueOf(0.01);
}
// 调用wx支付
- result = WxPayUtils.getUnifiedorder(appid, mchId, payKey, currencyNotifyUrl + PayCpmstant.BATTERY_STORE_ACTIVITY_PAY_NOTIFY_URL
- , remark, openId, orderNo, money,type);
+// result = WxPayUtils.getUnifiedorder(appid, mchId, payKey, currencyNotifyUrl + PayCpmstant.BATTERY_STORE_ACTIVITY_PAY_NOTIFY_URL
+// , remark, openId, orderNo, money,type);
log.info("用户购买商品微信支付返回参数:" + result);
return result;
}
--
Gitblit v1.7.1