From d6a0c57043e8cc20694a3c678bf8e3a8f28f6499 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期四, 29 五月 2025 11:20:14 +0800
Subject: [PATCH] 新增加用户端接口

---
 ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java |   37 +++++++++++++++++++++++++++++++++----
 1 files changed, 33 insertions(+), 4 deletions(-)

diff --git a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
index 2d03862..1161275 100644
--- a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
+++ b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
@@ -1,5 +1,4 @@
 package com.ruoyi.member.service.impl.member;
-import com.google.common.collect.Lists;
 import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
 import com.alibaba.fastjson.JSONObject;
@@ -8,6 +7,7 @@
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.google.common.collect.Lists;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.exception.ServiceException;
 import com.ruoyi.common.core.utils.DateUtils;
@@ -21,7 +21,6 @@
 import com.ruoyi.member.domain.pojo.member.IntegralRecord;
 import com.ruoyi.member.domain.pojo.member.MemberArchive;
 import com.ruoyi.member.domain.pojo.member.MemberTotal;
-import com.ruoyi.member.domain.vo.MerMemberTotalVo;
 import com.ruoyi.member.domain.vo.*;
 import com.ruoyi.member.mapper.member.MemberMapper;
 import com.ruoyi.member.service.member.IntegralRecordService;
@@ -637,6 +636,7 @@
         if (oldMember != null && oldMember.getBindingFlag() == 0) {
             oldMember.setRelationShopId(merMemberAddDto.getShopId());
             oldMember.setBindingFlag(1);
+            oldMember.setBindingType(8);
             this.updateById(oldMember);
             return oldMember.getUserId();
         }
@@ -2256,14 +2256,43 @@
         List<Member> mobileList = memberMapper.listTodayBirthday();
         if(mobileList!=null&&!mobileList.isEmpty()){
             log.info("生日祝福发送短信---"+mobileList.toString());
-            for(Member member : mobileList){
+            for (Member member : mobileList) {
                 try {
                     String msg = "{\"name\":\"" + (StringUtils.isEmpty(member.getRealName()) ? member.getNickName() : member.getRealName()) + "\"}";
-                    MsgUtils.sendMsg(member.getMobile(),null, msg);
+                    MsgUtils.sendMsg(member.getMobile(), null, msg);
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }
             }
         }
     }
+    
+    
+    /**
+     * 手动添加用户积分
+     *
+     * @param integral
+     * @param userId
+     * @return
+     */
+    @Override
+    public R addIntegralRecord(Integer integral, Long userId, String orderId) {
+        Member member = this.getByUserId(userId);
+        MemberTotal memberTotal = memberTotalService.getById(member.getMemberId());
+        IntegralRecord integralRecord = new IntegralRecord();
+        integralRecord.setDelFlag(0);
+        integralRecord.setUserId(userId);
+        integralRecord.setChangeType(6);
+        integralRecord.setChangeIntegral(integral);
+        integralRecord.setSurpIntegral(memberTotal.getUseableIntegral() + integral);
+        integralRecord.setCreateTime(new Date());
+        integralRecord.setOrderId(orderId);
+        integralRecord.setChangeReason("抽奖活动获得");
+        integralRecordService.save(integralRecord);
+        memberTotal.setTotalIntegral(memberTotal.getTotalIntegral() + integral);
+        memberTotal.setUseableIntegral(memberTotal.getUseableIntegral() + integral);
+        memberTotal.setPlSuggestFlag(1);
+        memberTotalService.saveOrUpdate(memberTotal);
+        return R.ok();
+    }
 }

--
Gitblit v1.7.1