奇门遁甲协议补充

back_recharge
duhui 2021-06-15 11:22:06 +08:00
parent d6e2f5ffdd
commit 16a9d3ae45
2 changed files with 46 additions and 0 deletions

View File

@ -0,0 +1,44 @@
package com.ljsd.jieling.handler.activity;
import com.google.protobuf.GeneratedMessage;
import com.ljsd.jieling.exception.ErrorCode;
import com.ljsd.jieling.exception.ErrorCodeException;
import com.ljsd.jieling.handler.BaseHandler;
import com.ljsd.jieling.logic.activity.ActivityLogic;
import com.ljsd.jieling.logic.dao.UserManager;
import com.ljsd.jieling.logic.dao.root.User;
import org.springframework.stereotype.Component;
import rpc.protocols.ActivityProto;
import rpc.protocols.MessageTypeProto;
import java.util.*;
/**
* @Author hj
* @Date 2021/6/8 15:40
* @Description: /
* @Version 1.0
*/
@Component
public class GetQiMenDunJiaHitListHandler extends BaseHandler<ActivityProto.qiMenDunJiaHitListRequest> {
@Override
public MessageTypeProto.MessageType getMessageCode() {
return null;
}
public GeneratedMessage processWithProto(int uid, ActivityProto.qiMenDunJiaHitListRequest proto) throws Exception {
// 用户信息
User user = UserManager.getUser(uid);
if (user == null) {
throw new ErrorCodeException(ErrorCode.UNKNOWN);
}
// 获取全部已经抽中的id列表
Set<Integer> list = new HashSet<>();
Map<Integer, List<Integer>> poolInfo = user.getActivityManager().getDoubleRewardPoolInfo();
poolInfo.values().forEach(list::addAll);
return ActivityProto.qiMenDunJiaHitListResponse.newBuilder().addAllHitList(list).build();
}
}

View File

@ -7,6 +7,7 @@ import com.ljsd.jieling.handler.BaseHandler;
import com.ljsd.jieling.logic.activity.ActivityLogic;
import com.ljsd.jieling.logic.dao.UserManager;
import com.ljsd.jieling.logic.dao.root.User;
import org.springframework.stereotype.Component;
import rpc.protocols.ActivityProto;
import rpc.protocols.MessageTypeProto;
@ -16,6 +17,7 @@ import rpc.protocols.MessageTypeProto;
* @Description: /
* @Version 1.0
*/
@Component
public class QiMenDunJiaDrawHandler extends BaseHandler<ActivityProto.qiMenDunJiaDrawRequest> {
@Override