将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/service/inter/money/TeamEincomeRecordService.java

@@ -1,61 +1,69 @@
package com.yeshi.fanli.service.inter.money;



import java.math.BigDecimal;

import java.util.Date;

import java.util.List;



import com.yeshi.fanli.entity.money.TeamEincomeRecord;

import com.yeshi.fanli.exception.ParamsException;

import com.yeshi.fanli.exception.money.TeamEincomeRecordException;



/**

 * 团队收益记录服务

 * @author Administrator

 *

 */

public interface TeamEincomeRecordService {



   /**

    * 添加用户手团队收益记录

    * @Title: addTeamEincomeRecord

    * @Description: 
    * @param record

    * @throws ParamsException 
    * void 返回类型

    * @throws

    */

   public void addTeamEincomeRecord(TeamEincomeRecord record) throws TeamEincomeRecordException, ParamsException;



   public List<TeamEincomeRecord> listCanRecieveRecord(Date preRecieveTime, Long uid, List<Integer> typeList);



   /**

    * 获取可以结算的用户ID

    * @Title: listCanRecieveUid

    * @Description: 
    * @param preRecieveTime

    * @param typeList

    * @return 
    * List<Long> 返回类型

    * @throws

    */

   public List<Long> listCanRecieveUid(Date preRecieveTime, List<Integer> typeList,int page,int pageSize);

	
   public long countCanRecieveUid(Date preRecieveTime, List<Integer> typeList);

	


   public TeamEincomeRecord selectByPrimaryKeyForUpdate(Long id);



   public void setRecieved(Long id);



   /**

    * 获取预估分红

    * @Title: getEstimateDividents

    * @Description: 
    * @param preGetTime

    * @return 
    * BigDecimal 返回类型

    * @throws

    */

   public BigDecimal getEstimateDividents(Date preGetTime, Long uid);



}

package com.yeshi.fanli.service.inter.money;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;

import com.yeshi.fanli.entity.money.TeamEincomeRecord;
import com.yeshi.fanli.exception.ParamsException;
import com.yeshi.fanli.exception.money.TeamEincomeRecordException;

/**
 * 团队收益记录服务
 * @author Administrator
 *
 */
public interface TeamEincomeRecordService {

   /**
    * 添加用户手团队收益记录
    * @Title: addTeamEincomeRecord
    * @Description: 
    * @param record
    * @throws ParamsException 
    * void 返回类型
    * @throws
    */
   public void addTeamEincomeRecord(TeamEincomeRecord record) throws TeamEincomeRecordException, ParamsException;

   public List<TeamEincomeRecord> listCanRecieveRecord(Date preRecieveTime, Long uid, List<Integer> typeList);

   /**
    * 获取可以结算的用户ID
    * @Title: listCanRecieveUid
    * @Description: 
    * @param preRecieveTime
    * @param typeList
    * @return 
    * List<Long> 返回类型
    * @throws
    */
   public List<Long> listCanRecieveUid(Date preRecieveTime, List<Integer> typeList,int page,int pageSize);
	
   public long countCanRecieveUid(Date preRecieveTime, List<Integer> typeList);
	

   public TeamEincomeRecord selectByPrimaryKeyForUpdate(Long id);

   public void setRecieved(Long id);

   /**
    * 获取预估分红
    * @Title: getEstimateDividents
    * @Description: 
    * @param preGetTime
    * @return 
    * BigDecimal 返回类型
    * @throws
    */
   public BigDecimal getEstimateDividents(Date preGetTime, Long uid);

   /**
    * 统计已到账金额
    * @param uid
    * @param type
    * @return
    */
   public BigDecimal sumRecieveByType(Long uid, int type);

}