From a1bd652e0207d7cb363798af55e2bec9dcf3cd3b Mon Sep 17 00:00:00 2001
From: 77 <77@77.com>
Date: Sun, 31 Mar 2024 20:03:53 +0800
Subject: [PATCH] 123

---
 .../com/ruoyi/cai/manager/ConsumerManager.java    |  7 +++++++
 .../java/com/ruoyi/cai/mapper/AnchorMapper.java   |  2 ++
 .../java/com/ruoyi/cai/service/AnchorService.java |  2 ++
 .../cai/service/impl/AccountServiceImpl.java      |  1 +
 .../ruoyi/cai/service/impl/AnchorServiceImpl.java | 15 +++++++++++++++
 .../main/resources/mapper/cai/AnchorMapper.xml    |  6 ++++++
 6 files changed, 33 insertions(+)

diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/manager/ConsumerManager.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/manager/ConsumerManager.java
index dad0946a..68641f2d 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/manager/ConsumerManager.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/manager/ConsumerManager.java
@@ -50,6 +50,8 @@ public class ConsumerManager {
     private SystemConfigManager systemConfigManager;
     @Autowired
     private UserService userService;
+    @Autowired
+    private AnchorService anchorService;
 
     public GuardConsumerResp sendGuard(GiveGuardReq query){
         GuardConsumerResp resp = guardTotalService.giveGuard(query);
@@ -123,6 +125,11 @@ public class ConsumerManager {
         }catch (Exception e){
             log.error("RabbitMq 发送失败, 视频分销流程流转失败！",e);
         }
+        try {
+            anchorService.incsServiceTimeAndCount(room.getRoomId());
+        }catch (Exception e){
+            log.error("处理主播自增服务次数和时间失败!",e);
+        }
         rankManager.sendLoveRankMq(consumeLog.getTargetUserId(),consumeLog.getAnchorAmount(),consumeLog.getTraceId());
         return resp;
     }
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/mapper/AnchorMapper.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/mapper/AnchorMapper.java
index 025bf29c..523d73af 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/mapper/AnchorMapper.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/mapper/AnchorMapper.java
@@ -19,4 +19,6 @@ public interface AnchorMapper extends BaseMapper<Anchor> {
     Page<AnchorAdminVo> pageAdmin(@Param("build") Page<Object> build, @Param("bo") AnchorAdminVo bo);
 
     Page<AnchorListVo> pageApp(@Param("build") Page<Object> build, @Param("query") AnchorListQuery query);
+
+    boolean incsServiceTimeAndCount(@Param("toUid") Long toUid, @Param("callTime") Long callTime, @Param("count") int count);
 }
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AnchorService.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AnchorService.java
index a9f4fa54..b6d92302 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AnchorService.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AnchorService.java
@@ -27,4 +27,6 @@ public interface AnchorService extends IService<Anchor> {
     Anchor getByUserId(Long userId);
 
     void updateVideoStatus(Long userId, int videoStatus);
+
+    void incsServiceTimeAndCount(Long roomId);
 }
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java
index f33cfe22..6311f226 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java
@@ -413,6 +413,7 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
         resp.setPayIncome(payIncome);
         resp.setPayCoin(payCoin);
         resp.setAnchorIncome(anchorAmount);
+        resp.setRoomId(userCall.getId());
         return resp;
     }
 
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorServiceImpl.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorServiceImpl.java
index 31505e82..e653ea67 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorServiceImpl.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorServiceImpl.java
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.cai.domain.Anchor;
 import com.ruoyi.cai.domain.User;
+import com.ruoyi.cai.domain.UserCall;
 import com.ruoyi.cai.dto.admin.vo.AnchorAdminVo;
 import com.ruoyi.cai.dto.app.query.index.AnchorListQuery;
 import com.ruoyi.cai.dto.app.vo.AnchorListVo;
@@ -14,6 +15,7 @@ import com.ruoyi.cai.manager.SystemConfigManager;
 import com.ruoyi.cai.mapper.AnchorMapper;
 import com.ruoyi.cai.notice.YunxinHttpService;
 import com.ruoyi.cai.service.AnchorService;
+import com.ruoyi.cai.service.UserCallService;
 import com.ruoyi.cai.service.UserService;
 import com.ruoyi.common.core.domain.PageQuery;
 import com.ruoyi.common.exception.ServiceException;
@@ -38,6 +40,8 @@ public class AnchorServiceImpl extends ServiceImpl<AnchorMapper, Anchor> impleme
     private SystemConfigManager systemConfigManager;
     @Autowired
     private YunxinHttpService yunxinHttpService;
+    @Autowired
+    private UserCallService userCallService;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -124,4 +128,15 @@ public class AnchorServiceImpl extends ServiceImpl<AnchorMapper, Anchor> impleme
                 .eq(Anchor::getUserId,userId)
                 .set(Anchor::getVideoStatus,videoStatus));
     }
+
+    @Override
+    public void incsServiceTimeAndCount(Long roomId) {
+        UserCall userCall = userCallService.getById(roomId);
+        if(userCall == null){
+            return;
+        }
+        if(userCall.getCallTime() != null && userCall.getCallTime() > 0){
+            baseMapper.incsServiceTimeAndCount(userCall.getToUid(), userCall.getCallTime(), 1);
+        }
+    }
 }
diff --git a/ruoyi-cai/src/main/resources/mapper/cai/AnchorMapper.xml b/ruoyi-cai/src/main/resources/mapper/cai/AnchorMapper.xml
index 15dc924d..ac28b221 100644
--- a/ruoyi-cai/src/main/resources/mapper/cai/AnchorMapper.xml
+++ b/ruoyi-cai/src/main/resources/mapper/cai/AnchorMapper.xml
@@ -20,6 +20,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="createTime" column="create_time"/>
         <result property="status" column="status"/>
     </resultMap>
+    <update id="incsServiceTimeAndCount">
+        update cai_anchor
+        set service_count = service_count + #{count},
+            service_time = service_time + #{callTime}
+        where user_id = #{toUid}
+    </update>
     <select id="pageAdmin" resultType="com.ruoyi.cai.dto.admin.vo.AnchorAdminVo">
         select
             t1.*,t2.age,t2.avatar,t2.usercode,t2.nickname,t2.mobile,t2.gender,t2.age,t2.city