退款

cash-service/market-service/src/main/java/com/czg/service/market/service/impl/GbWareServiceImpl.java

@@ -3,7 +3,6 @@ package com.czg.service.market.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
 import com.czg.account.service.ShopInfoService;
-import com.czg.exception.CzgException;
 import com.czg.market.dto.GbWareDTO;
 import com.czg.market.dto.GbWareQueryParamDTO;
 import com.czg.market.entity.GbWare;
@@ -11,11 +10,11 @@ import com.czg.market.service.GbWareService;
 import com.czg.sa.StpKit;
 import com.czg.service.market.mapper.GbWareMapper;
 import com.czg.utils.AssertUtil;
-import com.czg.utils.CzgStrUtils;
 import com.mybatisflex.core.paginate.Page;
 import com.mybatisflex.core.query.QueryWrapper;
 import com.mybatisflex.spring.service.impl.ServiceImpl;
 import org.apache.dubbo.config.annotation.DubboReference;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.stereotype.Service;
 
 /**
@@ -29,6 +28,14 @@ public class GbWareServiceImpl extends ServiceImpl<GbWareMapper, GbWare> impleme
     @DubboReference
     private ShopInfoService shopInfoService;
 
+
+    @CacheEvict(cacheNames = "shopInfo", key = "#shopId")
+    @Override
+    public boolean upShopConfig(Integer status, Long shopId) {
+        
+        return false;
+    }
+
     @Override
     public Page<GbWare> getGbWarePage(GbWareQueryParamDTO param, Long shopId) {
         Long mainShopId = shopInfoService.getMainIdByShopId(shopId);
@@ -62,13 +69,6 @@ public class GbWareServiceImpl extends ServiceImpl<GbWareMapper, GbWare> impleme
         return save(gbWare);
     }
 
-    @Override
-    public boolean editGbWareOnlineStatus(Long id, Integer onlineStatus) {
-        GbWare gbWare = new GbWare();
-        gbWare.setOnlineStatus(onlineStatus);
-        return update(gbWare, query().eq(GbWare::getId, id).eq(GbWare::getShopId, StpKit.USER.getShopId()));
-    }
-
 
     @Override
     public boolean updateGbWareById(GbWareDTO param) {
@@ -88,8 +88,6 @@ public class GbWareServiceImpl extends ServiceImpl<GbWareMapper, GbWare> impleme
 
     private void checkStatus(Long id) {
         GbWare ware = getById(id);
-        if (ware.getOnlineStatus() == 1) {
-            throw new CzgException("操作失败,请下架后,重试");
-        }
+        AssertUtil.isNotEqual(ware.getOnlineStatus(), 1, "操作失败,请下架后,重试");
     }
 }

cash-service/order-service/src/main/java/com/czg/service/order/service/impl/GbOrderServiceImpl.java

@@ -10,7 +10,6 @@ import com.czg.enums.OrderNoPrefixEnum;
 import com.czg.enums.YesNoEnum;
 import com.czg.exception.CzgException;
 import com.czg.market.entity.GbWare;
-import com.czg.market.entity.MkPointsGoodsRecord;
 import com.czg.market.service.GbWareService;
 import com.czg.order.dto.CommonRefundDTO;
 import com.czg.order.dto.GbOrderQueryParam;
@@ -25,6 +24,7 @@ import com.czg.order.vo.GbOrderUserVO;
 import com.czg.order.vo.GbWareOrderVO;
 import com.czg.order.vo.GbWareVO;
 import com.czg.resp.CzgResult;
+import com.czg.sa.StpKit;
 import com.czg.service.order.mapper.GbOrderMapper;
 import com.czg.service.order.service.PayService;
 import com.czg.utils.AssertUtil;
@@ -273,7 +273,7 @@ public class GbOrderServiceImpl extends ServiceImpl<GbOrderMapper, GbOrder> impl
             throw new CzgException("申请失败，该商品不可申请退款");
         }
         if ("待成团".equals(record.getStatus())) {
-            return refundAmount(record, "");
+            return refundAmount(record, param.getReason());
         }
         GbOrderDetail upRecord = new GbOrderDetail();
         record.setStatus("退款中");
@@ -338,16 +338,66 @@ public class GbOrderServiceImpl extends ServiceImpl<GbOrderMapper, GbOrder> impl
         return refundAmount(record, param.getReason());
     }
 
+    @Override
+    public boolean editGbWareOnlineStatus(Long id, Integer onlineStatus) {
+        GbWare gbWare = new GbWare();
+        gbWare.setOnlineStatus(onlineStatus);
+        boolean update = wareService.update(gbWare, query().eq(GbWare::getId, id).eq(GbWare::getShopId, StpKit.USER.getShopId()));
+        if (update && onlineStatus == 0) {
+            //退钱
+            wareDownRefund(id);
+        }
+        return update;
+    }
+
+    @Override
+    public boolean expireRefund(Long gbOrderId) {
+        GbOrder order = getOne(query().eq(GbOrder::getId, gbOrderId).eq(GbOrder::getStatus, "ing"));
+        return refundByGbOrder(order, "成团期限超时");
+    }
+
+    @Override
+    public boolean wareDownRefund(Long wareId) {
+        List<GbOrder> list = list(query().eq(GbOrder::getWareId, wareId).eq(GbOrder::getStatus, "ing"));
+        for (GbOrder gbOrder : list) {
+            refundByGbOrder(gbOrder, "所属活动变更为下架状态");
+        }
+        return true;
+    }
+
+    @Override
+    public boolean shopDownRefund(Long shopId) {
+        List<GbOrder> list = list(query().eq(GbOrder::getShopId, shopId).eq(GbOrder::getStatus, "ing"));
+        for (GbOrder gbOrder : list) {
+            refundByGbOrder(gbOrder, "商品拼团功能关闭");
+        }
+        return true;
+    }
+
+    public boolean refundByGbOrder(GbOrder gbOrder, String reason) {
+        if (gbOrder == null) {
+            return false;
+        }
+        List<GbOrderDetail> details = detailService.list(query()
+                .ne(GbOrderDetail::getShopId, gbOrder.getShopId())
+                .eq(GbOrderDetail::getGroupOrderNo, gbOrder.getGroupOrderNo())
+                .ne(GbOrderDetail::getStatus, "已退款")
+                .eq(GbOrderDetail::getIsDel, YesNoEnum.NO.value()));
+        details.forEach(item -> refundAmount(item, reason));
+        return true;
+    }
+
+
     private boolean refundAmount(GbOrderDetail record, String reason) {
         //退钱
         String refPayOrderNo = CzgRandomUtils.snowflake(OrderNoPrefixEnum.REP);
         payService.unifyRefund(record.getShopId(), record.getId(), record.getPayOrderId(), refPayOrderNo,
                 StrUtil.isBlankIfStr(reason) ? "拼团退款" : reason, record.getPayAmount());
-
         //回退 人数
         GbOrder gbOrder = getOne(query().eq(GbOrder::getGroupOrderNo, record.getGroupOrderNo()).eq(GbOrder::getShopId, record.getShopId()));
         if (gbOrder != null) {
             GbOrder upOrder = new GbOrder();
+            upOrder.setId(gbOrder.getId());
             upOrder.setCurrentPeopleNum(gbOrder.getCurrentPeopleNum() - 1);
             if (upOrder.getCurrentPeopleNum() == 0) {
                 upOrder.setStatus("fail");
@@ -357,6 +407,7 @@ public class GbOrderServiceImpl extends ServiceImpl<GbOrderMapper, GbOrder> impl
         }
         GbOrderDetail upRecord = new GbOrderDetail();
         upRecord.setStatus("已退款");
+        upRecord.setCancelReason(reason);
         return detailService.update(upRecord, query().eq(GbOrderDetail::getId, record.getId()));
     }
 }