From bfbfe7d5fd6c90d5f7359762223ce4bd1cc7cfa1 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期一, 15 八月 2022 09:56:49 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/lyq_battery_shop' into diandongche
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java | 384 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 384 insertions(+), 0 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
new file mode 100644
index 0000000..09350d3
--- /dev/null
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComBatteryCommodityOrderCollageTeamServiceImpl.java
@@ -0,0 +1,384 @@
+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;
+import com.panzhihua.common.utlis.Snowflake;
+import com.panzhihua.common.utlis.WxPayUtils;
+import com.panzhihua.service_community.dao.*;
+import com.panzhihua.service_community.entity.*;
+import com.panzhihua.service_community.service.ComBatteryCommodityOrderCollageTeamService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.panzhihua.service_community.service.ComBatteryTradeOrderService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import com.panzhihua.common.model.dtos.common.*;
+import com.panzhihua.common.model.vos.R;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * title: 电动车商城-拼团订单团队表表服务实现类
+ * <p>
+ * projectName 成都呐喊信息技术有限公司-智慧社区项目
+ * <p>
+ * description: 电动车商城-拼团订单团队表表服务实现类
+ *
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+@Slf4j
+@Service("comBatteryCommodityOrderCollageTeamService")
+public class ComBatteryCommodityOrderCollageTeamServiceImpl extends ServiceImpl<ComBatteryCommodityOrderCollageTeamMapper, ComBatteryCommodityOrderCollageTeam> implements ComBatteryCommodityOrderCollageTeamService {
+
+ @Resource
+ private ComBatteryCommodityActivityMapper commodityActivityMapper;
+ @Resource
+ private ComBatteryCommodityOrderCollageTeamMapper orderCollageTeamMapper;
+ @Resource
+ private ComBatteryCommodityOrderCollageTeamPeopleMapper orderCollageTeamPeopleMapper;
+ @Resource
+ private ComBatteryUserAddressMapper userAddressMapper;
+ @Resource
+ private SysUserMapper userMapper;
+ @Resource
+ 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;
+ @Resource
+ private ComBatteryCommodityMapper commodityMapper;
+ @Resource
+ private ComBatteryCommoditySpecsMapper commoditySpecsMapper;
+ @Resource
+ private ComBatteryCommodityOrderMapper commodityOrderMapper;
+
+ /**
+ * description queryByPage 分页查询
+ *
+ * @param comBatteryCommodityOrderCollageTeam 请求参数
+ * @return 分页查询列表数据
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+ @Override
+ public R queryByPage(PageComBatteryCommodityOrderCollageTeamDto comBatteryCommodityOrderCollageTeam) {
+ 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);
+ }
+
+ /**
+ * description insert 新增数据
+ *
+ * @param comBatteryCommodityOrderCollageTeam 请求参数
+ * @return 新增结果
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+ @Override
+ public R insert(AddComBatteryCommodityOrderCollageTeamDto comBatteryCommodityOrderCollageTeam) {
+ ComBatteryCommodityOrderCollageTeam entity = new ComBatteryCommodityOrderCollageTeam();
+ BeanUtils.copyProperties(comBatteryCommodityOrderCollageTeam, entity);
+ if (this.baseMapper.insert(entity) > 0) {
+ return R.ok();
+ }
+ return R.fail("添加失败");
+ }
+
+ /**
+ * description update 修改数据
+ *
+ * @param editDto 请求参数
+ * @return 修改结果
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+ @Override
+ public R update(EditComBatteryCommodityOrderCollageTeamDto editDto) {
+ ComBatteryCommodityOrderCollageTeam entity = this.baseMapper.selectById(editDto.getId());
+ if (entity == null) {
+ return R.fail("未查询到该记录");
+ }
+ BeanUtils.copyProperties(editDto, entity);
+ if (this.baseMapper.updateById(entity) > 0) {
+ return R.ok();
+ }
+ return R.fail("修改失败");
+ }
+
+ /**
+ * description deleteById 通过主键删除数据
+ *
+ * @param id 主键id
+ * @return 删除结果
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+ @Override
+ public R deleteById(Long id) {
+ if (this.baseMapper.deleteById(id) > 0) {
+ return R.ok();
+ }
+ return R.fail("删除失败");
+ }
+
+ /**
+ * description detailById 查询详情
+ *
+ * @param id 主键id
+ * @return 详情数据
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+ @Override
+ 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);
+ }
+
+ /**
+ * description queryByPage 查询列表
+ *
+ * @param comBatteryCommodityOrderCollageTeam 请求参数
+ * @return 列表数据
+ * @author lyq
+ * @date 2022-03-29 16:06:58
+ */
+ @Override
+ public R queryByList(PageComBatteryCommodityOrderCollageTeamDto comBatteryCommodityOrderCollageTeam) {
+ return R.ok(this.baseMapper.queryAllByList(comBatteryCommodityOrderCollageTeam));
+ }
+
+ /**
+ * 创建拼团订单
+ * @param orderDto 请求参数
+ * @return 创建订单结果
+ */
+ @Override
+ public synchronized R startFight(StartFightOrderDto orderDto) {
+ //查询拼团活动
+ ComBatteryCommodityActivity commodityActivity = commodityActivityMapper.selectById(orderDto.getActivityId());
+ if(commodityActivity == null){
+ return R.fail("未查询到拼团活动");
+ }
+ if(commodityActivity.getStatus().equals(ComBatteryCommodityActivity.Status.YXJ)){
+ return R.fail("该活动已下架");
+ }
+ if(commodityActivity.getEndTime().getTime() - System.currentTimeMillis() <= 0
+ || commodityActivity.getStatus().equals(ComBatteryCommodityActivity.Status.YJS)){
+ return R.fail("该活动已结束");
+ }
+ if(orderDto.getType().equals(StartFightOrderDto.Type.PT)){
+ //判断该团队人数是否已满
+ Integer count = orderCollageTeamPeopleMapper.selectCount(new QueryWrapper<ComBatteryCommodityOrderCollageTeamPeople>().lambda()
+ .eq(ComBatteryCommodityOrderCollageTeamPeople::getTeamId,orderDto.getTeamId()));
+ 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("该拼团已成功");
+ }
+ }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(maxCount >= commodityActivity.getCollageNum()){
+ return R.fail("当前正在拼团的数量已达到最大值，不可在开团");
+ }
+ }
+ //查询商品
+ ComBatteryCommodity commodity = commodityMapper.selectById(orderDto.getCommodityId());
+ if(commodity == null){
+ return R.fail("未查询到商品信息");
+ }
+ //查询用户信息
+ SysUser user = userMapper.selectById(orderDto.getUserId());
+ if(user == null){
+ return R.fail("未查询到用户信息");
+ }
+ //查询商品规格信息
+ ComBatteryCommoditySpecs commoditySpecs = commoditySpecsMapper.selectById(commodityActivity.getSpecsId());
+ if(commoditySpecs == null){
+ return R.fail("未查询到商品规格信息");
+ }
+ if(commoditySpecs.getStock() < orderDto.getCount()){
+ return R.fail("该商品库存不足，无法下单");
+ }
+ //查询用户收货地址
+ ComBatteryUserAddress userAddress = userAddressMapper.selectById(orderDto.getAddressId());
+ if(userAddress == null){
+ return R.fail("未查询到用户收货地址");
+ }
+ Date nowDate = new Date();
+ //初始化订单数据
+ ComBatteryCommodityOrder commodityOrder = getCreateOrder(commodity,userAddress,user,commoditySpecs,orderDto,nowDate,commodityActivity);
+ Map<String,Object> resultMap = new HashMap<>(2);
+ if(commodityOrderMapper.insert(commodityOrder) > 0){
+ //更新商品库存
+ commoditySpecs.setStock(commoditySpecs.getStock() - orderDto.getCount());
+ commoditySpecsMapper.updateById(commoditySpecs);
+
+ //微信支付需要调取小程序微信支付
+ String result = getWxPayResult(commodityOrder.getFinalAmount(),commodityOrder.getOpenId()
+ ,commodityOrder.getOrderNo(),"购买商品",orderDto.getType().toString());
+ resultMap.put("payResult",result);
+ resultMap.put("orderId",commodityOrder.getId());
+ // 添加微信支付交易流水
+ String wxTradeOrderNo = "wx" + Snowflake.getId();
+ tradeOrderService.addOrderTradeRecord(user.getUserId(), user.getOpenid(), wxTradeOrderNo, ComBatteryTradeOrder.PayType.WX,
+ commodityOrder.getFinalAmount(), ComBatteryTradeOrder.TradeType.DDC_SHOP, commodityOrder.getId(),
+ commodityOrder.getOrderNo(), user.getUserId(), nowDate);
+ }
+ return R.ok(resultMap);
+ }
+
+ /**
+ * 小程序唤起微信支付
+ *
+ * @param money
+ * 需要支付的金额
+ * @param openId
+ * 用户唤起微信支付的openid
+ * @param orderNo
+ * 业务订单号
+ * @param remark
+ * 交易备注
+ * @return 小程序支付参数
+ */
+ private String getWxPayResult(BigDecimal money, String openId, String orderNo, String remark,String type) {
+ String result = "";
+ // 将剩余金额调起微信支付
+ if (isTest) {
+ 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);
+ log.info("用户购买商品微信支付返回参数:" + result);
+ return result;
+ }
+
+ /**
+ * 初始化订单数据
+ * @param commodity 商品数据
+ * @param userAddress 用户收货地址信息
+ * @param user 用户数据
+ * @param commoditySpecs 商品规格数据
+ * @param orderDto 用户请求参数
+ * @param nowDate 操作时间
+ * @param commodityActivity 拼团活动数据
+ * @return 初始化订单数据
+ */
+ public static ComBatteryCommodityOrder getCreateOrder(ComBatteryCommodity commodity, ComBatteryUserAddress userAddress
+ , SysUser user, ComBatteryCommoditySpecs commoditySpecs, StartFightOrderDto orderDto, Date nowDate
+ ,ComBatteryCommodityActivity commodityActivity){
+ ComBatteryCommodityOrder commodityOrder = new ComBatteryCommodityOrder();
+ commodityOrder.setUserId(user.getUserId());
+ commodityOrder.setOpenId(user.getOpenid());
+ commodityOrder.setStoreId(commodity.getStoreId());
+ commodityOrder.setActivityId(commodityActivity.getId());
+ commodityOrder.setCommodityId(commodity.getId());
+ commodityOrder.setSpecsId(commoditySpecs.getId());
+ commodityOrder.setOrderNo("PT" + Snowflake.getId());
+ commodityOrder.setActivityType(commodityActivity.getType());
+ commodityOrder.setStatus(ComBatteryCommodityOrder.Status.DFK);
+ commodityOrder.setPayStatus(ComBatteryCommodityOrder.PayStatus.WZF);
+ commodityOrder.setIsDel(ComBatteryCommodityOrder.IsDel.NO);
+ commodityOrder.setPayType(ComBatteryCommodityOrder.PayType.WX);
+ commodityOrder.setCount(orderDto.getCount());
+ commodityOrder.setPrice(commodityActivity.getPrice());
+ commodityOrder.setAmount(commodityActivity.getPrice().multiply(BigDecimal.valueOf(orderDto.getCount())));
+ commodityOrder.setFreight(commodity.getPostage());
+ commodityOrder.setFinalAmount(commodityOrder.getAmount().add(commodityOrder.getFreight()));
+ commodityOrder.setCreateAt(nowDate);
+ commodityOrder.setCreateBy(user.getUserId());
+ commodityOrder.setRemark(orderDto.getRemark());
+ //收货地址
+ commodityOrder.setAddressId(userAddress.getId());
+ commodityOrder.setReceivingName(userAddress.getName());
+ commodityOrder.setReceivingPhone(userAddress.getPhone());
+ commodityOrder.setReceivingRegionCode(userAddress.getProvinceAdcode() + "-" + userAddress.getCityAdcode() + "-" + userAddress.getDistrictAdcode());
+ commodityOrder.setReceivingRegion(userAddress.getProvinceName() + userAddress.getCityName() + userAddress.getDistrictName());
+ commodityOrder.setReceivingAddress(userAddress.getAddress());
+ if(orderDto.getTeamId() != null){
+ commodityOrder.setTeamId(orderDto.getTeamId());
+ }
+ return commodityOrder;
+ }
+
+
+}
--
Gitblit v1.7.1