积分兑换 添加开关

fs-service/src/main/java/com/fs/his/config/IntegralConfig.java

@@ -28,4 +28,5 @@ public class IntegralConfig implements Serializable {
     private Integer integralSubscriptCourse;//付费课程订阅积分比例
     private Integer downloadAppIntegral; // 首次下载app获取积分
     private Integer integralPlayGame; // 首次下载app获取积分
+    private Integer integralExchangeOpen; // 是否允许兑换商品 0=关闭 1=开启
 }

fs-service/src/main/java/com/fs/his/service/impl/FsIntegralOrderServiceImpl.java

@@ -35,6 +35,7 @@ import com.fs.erp.domain.ErpOrderPayment;
 import com.fs.erp.dto.ErpOrderResponse;
 import com.fs.erp.service.IErpOrderService;
 import com.fs.his.config.FsSysConfig;
+import com.fs.his.config.IntegralConfig;
 import com.fs.his.domain.*;
 import com.fs.his.dto.ErpRemarkDTO;
 import com.fs.his.enums.*;
@@ -45,6 +46,7 @@ import com.fs.his.utils.ConfigUtil;
 import com.fs.his.utils.PhoneUtil;
 import com.fs.his.utils.RedisCacheUtil;
 import com.fs.his.vo.*;
+import com.fs.system.service.ISysConfigService;
 import com.fs.qw.domain.QwUser;
 import com.fs.qw.mapper.QwUserMapper;
 import com.fs.tzBankPay.doman.PayType;
@@ -165,6 +167,9 @@ public class FsIntegralOrderServiceImpl implements IFsIntegralOrderService
 
     @Autowired
     private RedisCacheUtil redisCacheUtil;
+
+    @Autowired
+    private ISysConfigService configService;
     /**
      * 查询积分商品订单
      *
@@ -305,6 +310,16 @@ public class FsIntegralOrderServiceImpl implements IFsIntegralOrderService
         if (Objects.isNull(integralGoods)) {
             return R.error("商品不存在");
         }
+
+        // 检查兑换功能是否关闭
+        String integralJson = configService.selectConfigByKey("his.integral");
+        if (StringUtils.isNotEmpty(integralJson)) {
+            IntegralConfig integralConfig = JSONUtil.toBean(integralJson, IntegralConfig.class);
+            if (Integer.valueOf(0).equals(integralConfig.getIntegralExchangeOpen())) {
+                return R.error("兑换功能维护中，暂不支持兑换");
+            }
+        }
+
         if(integralGoods.getStock()<=0L){
             return R.error("库存不足");
         }
@@ -454,6 +469,15 @@ public class FsIntegralOrderServiceImpl implements IFsIntegralOrderService
             throw new CustomException("地址不存在");
         }
 
+        // 检查兑换功能是否关闭
+        String integralJson = configService.selectConfigByKey("his.integral");
+        if (StringUtils.isNotEmpty(integralJson)) {
+            IntegralConfig integralConfig = JSONUtil.toBean(integralJson, IntegralConfig.class);
+            if (Integer.valueOf(0).equals(integralConfig.getIntegralExchangeOpen())) {
+                throw new CustomException("兑换功能维护中，暂不支持兑换");
+            }
+        }
+
         Wrapper<FsIntegralCart> wrapper = Wrappers.<FsIntegralCart>lambdaQuery()
                 .eq(FsIntegralCart::getUserId, user.getUserId())
                 .in(FsIntegralCart::getId, param.getIds());

fs-service/src/main/java/com/fs/hisStore/service/impl/FsIntegralOrderScrmServiceImpl.java

@@ -6,6 +6,7 @@ import cn.hutool.json.JSONUtil;
 import com.fs.common.core.domain.R;
 import com.fs.common.exception.CustomException;
 import com.fs.common.utils.DateUtils;
+import com.fs.common.utils.StringUtils;
 import com.fs.hisStore.domain.*;
 import com.fs.hisStore.mapper.*;
 import com.fs.hisStore.param.FsIntegralOrderCreateParam;
@@ -16,6 +17,8 @@ import com.fs.hisStore.vo.FsIntegralOrderListUVO;
 import com.fs.hisStore.vo.FsIntegralOrderListVO;
 import com.fs.hisStore.vo.FsIntegralOrderPVO;
 import com.fs.hisStore.vo.FsStoreProductDeliverExcelVO;
+import com.fs.his.config.IntegralConfig;
+import com.fs.system.service.ISysConfigService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -46,6 +49,9 @@ public class FsIntegralOrderScrmServiceImpl implements IFsIntegralOrderScrmServi
     private FsIntegralGoodsScrmMapper fsIntegralGoodsMapper;
     @Autowired
     private FsUserIntegralLogsScrmMapper fsUserIntegralLogsMapper;
+
+    @Autowired
+    private ISysConfigService configService;
     /**
      * 查询积分商品订单
      *
@@ -159,6 +165,16 @@ public class FsIntegralOrderScrmServiceImpl implements IFsIntegralOrderScrmServi
         FsUserScrm user=fsUserMapper.selectFsUserByUserId(param.getUserId());
         FsUserAddressScrm address=fsUserAddressMapper.selectFsUserAddressById(param.getAddressId());
         FsIntegralGoodsScrm integralGoods=fsIntegralGoodsMapper.selectFsIntegralGoodsByGoodsId(param.getGoodsId());
+
+        // 检查兑换功能是否关闭
+        String integralJson = configService.selectConfigByKey("his.integral");
+        if (StringUtils.isNotEmpty(integralJson)) {
+            IntegralConfig integralConfig = JSONUtil.toBean(integralJson, IntegralConfig.class);
+            if (Integer.valueOf(0).equals(integralConfig.getIntegralExchangeOpen())) {
+                return R.error("兑换功能维护中，暂不支持兑换");
+            }
+        }
+
         if(integralGoods.getStock()<=0l){
             return R.error("库存不足");
         }