From 7869fa712c19c351a48bfb0af11b0fe87b17c184 Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期三, 14 一月 2026 15:14:00 +0800
Subject: [PATCH] 小程序 用户端接口开发

---
 server/dmmall_service/src/main/java/com/doumee/service/business/impl/IntegralServiceImpl.java |   31 +++++++++++++++++++++++++++++++
 1 files changed, 31 insertions(+), 0 deletions(-)

diff --git a/server/dmmall_service/src/main/java/com/doumee/service/business/impl/IntegralServiceImpl.java b/server/dmmall_service/src/main/java/com/doumee/service/business/impl/IntegralServiceImpl.java
index d53622a..bd8aeb3 100644
--- a/server/dmmall_service/src/main/java/com/doumee/service/business/impl/IntegralServiceImpl.java
+++ b/server/dmmall_service/src/main/java/com/doumee/service/business/impl/IntegralServiceImpl.java
@@ -198,6 +198,37 @@
 
 
     @Override
+    @Transactional(rollbackFor = {Exception.class, BusinessException.class})
+    public Integer dealShopAmount(DealIntegralRequest dealIntegralRequest) {
+        Shop shop = shopMapper.selectById(dealIntegralRequest.getMemberId());
+        if(Objects.isNull(shop)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍟嗘埛淇℃伅");
+        }
+        Integral integral = new Integral();
+        integral.setMemberId(shop.getId());
+        integral.setCreateDate(new Date());
+        integral.setIsdeleted(Constants.ZERO);
+        integral.setTitle(dealIntegralRequest.getIntegralObjType().getName());
+        integral.setContent(dealIntegralRequest.getIntegralObjType().getNoteinfo());
+        integral.setObjId(dealIntegralRequest.getObjId());
+        integral.setObjType(dealIntegralRequest.getIntegralObjType().getKey());
+        integral.setType(dealIntegralRequest.getDealType());
+        integral.setNum(dealIntegralRequest.getIntegralNum());
+        integral.setTotalNum(dealIntegralRequest.getDealType().equals(Constants.ZERO)? shop.getAmount().add(integral.getNum()):shop.getAmount().subtract(integral.getNum()));
+        integral.setOrderCode(dealIntegralRequest.getOrderCode());
+        integral.setUserType(Constants.TWO);
+        integralMapper.insert(integral);
+        if(dealIntegralRequest.getDealType().equals(Constants.ZERO)){
+            shopMapper.addAmount(shop.getId(),dealIntegralRequest.getIntegralNum(),
+                    dealIntegralRequest.getIntegralObjType().getAddTitle()==Constants.ZERO?dealIntegralRequest.getIntegralNum():BigDecimal.ZERO);
+        }else{
+            shopMapper.subtractAmount(shop.getId(),dealIntegralRequest.getIntegralNum());
+        }
+        return integral.getId();
+    }
+
+
+    @Override
     public void deleteById(Integer id) {
         integralMapper.deleteById(id);
     }

--
Gitblit v1.9.3