123

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;
     }

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);
 }

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);
 }

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;
     }
 

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);
+        }
+    }
 }

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