Skip to content

X
xyqb-user2
Commit c995610e authored by 李健华's avatar 李健华
Browse files
Options

Merge branch 'feature/risk-2022-03-23' into 'master' 

去掉lkb上报

See merge request !54
parents 4b28d3b2 5ad2e97e
Hide whitespace changes
Inline Side-by-side
Showing with 94 additions and 94 deletions
src/main/java/cn/quantgroup/xyqb/event/KinesisRegisteredEventListener.java
View file @ c995610e
//package cn.quantgroup.xyqb.event;
//
//import java.io.UnsupportedEncodingException;
//
//import org.apache.commons.lang3.exception.ExceptionUtils;
//import org.springframework.context.ApplicationListener;
//import org.springframework.stereotype.Component;
//
//import com.amazonaws.services.kinesis.producer.UserRecordResult;
//import com.fasterxml.jackson.core.JsonProcessingException;
//import com.google.common.util.concurrent.FutureCallback;
//import com.google.common.util.concurrent.Futures;
//import com.google.common.util.concurrent.ListenableFuture;
//
//import cn.qg.ec.kinesis.EnvironmentConfig;
//import cn.qg.ec.kinesis.KinesisProducerClient;
//import cn.qg.ec.model.user.base.UserBaseDetailEvent;
//import cn.quantgroup.tech.util.TechEnvironment;
//import cn.quantgroup.xyqb.entity.User;
//import cn.quantgroup.xyqb.exception.PushUserToLkbException;
//import cn.quantgroup.xyqb.model.UserRegisterParam;
//import cn.quantgroup.xyqb.util.JsonUtil;
//import lombok.extern.slf4j.Slf4j;
//
///**
// * 注册成功之后，用户分群数据上报
// * http://confluence.quantgroup.cn/pages/viewpage.action?pageId=34832018
// * http://confluence.quantgroup.cn/pages/viewpage.action?pageId=41784208
// * http://confluence.quantgroup.cn/pages/viewpage.action?pageId=34818640
// * @author yutong
// */
//@Slf4j
//@Component
//public class KinesisRegisteredEventListener implements ApplicationListener<RegisterEvent> {
//
// @Override
// public void onApplicationEvent(RegisterEvent event) {
// UserRegisterParam userRegisterParam = event.getUserRegisterParam();
// User user = userRegisterParam.getUser();
//
// log.info("[KinesisRegistered] 用户分群数据上报准备, userId:{}, registeredFrom:{}", user.getId(), user.getRegisteredFrom());
// sendRecord(user);
// }
//
// private void sendRecord(User user) {
// // EnvironmentConfig.DEV 环境变量配置
// KinesisProducerClient kinesisProducerClient = new KinesisProducerClient(
// TechEnvironment.isPro() ? EnvironmentConfig.PROD : EnvironmentConfig.DEV);
//
// // 用户登录事件发送
//// UserBaseDetailEvent regEvent = UserBaseDetailEvent
//// .builder()
//// .channel(1L)
//// .hashPhoneNo("*********")
//// .businessEventBaseInfo(BusinessEventBaseInfo
//// .builder()
//// .channel("***")
//// .deviceId("***")
//// .ip("***")
//// .userUuid("***")
//// .build())
//// .subEventType(UserBaseDetailEvent.SubEventType.REGISTER)
//// .build();
package cn.quantgroup.xyqb.event;
import java.io.UnsupportedEncodingException;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
import com.amazonaws.services.kinesis.producer.UserRecordResult;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import cn.qg.ec.kinesis.EnvironmentConfig;
import cn.qg.ec.kinesis.KinesisProducerClient;
import cn.qg.ec.model.user.base.UserBaseDetailEvent;
import cn.quantgroup.tech.util.TechEnvironment;
import cn.quantgroup.xyqb.entity.User;
import cn.quantgroup.xyqb.exception.PushUserToLkbException;
import cn.quantgroup.xyqb.model.UserRegisterParam;
import cn.quantgroup.xyqb.util.JsonUtil;
import lombok.extern.slf4j.Slf4j;
/**
* 注册成功之后，用户分群数据上报
* http://confluence.quantgroup.cn/pages/viewpage.action?pageId=34832018
* http://confluence.quantgroup.cn/pages/viewpage.action?pageId=41784208
* http://confluence.quantgroup.cn/pages/viewpage.action?pageId=34818640
* @author yutong
*/
@Slf4j
@Component
public class KinesisRegisteredEventListener implements ApplicationListener<RegisterEvent> {
@Override
public void onApplicationEvent(RegisterEvent event) {
UserRegisterParam userRegisterParam = event.getUserRegisterParam();
User user = userRegisterParam.getUser();
log.info("[KinesisRegistered] 用户分群数据上报准备, userId:{}, registeredFrom:{}", user.getId(), user.getRegisteredFrom());
sendRecord(user);
}
private void sendRecord(User user) {
// EnvironmentConfig.DEV 环境变量配置
KinesisProducerClient kinesisProducerClient = new KinesisProducerClient(
TechEnvironment.isPro() ? EnvironmentConfig.PROD : EnvironmentConfig.DEV);
// 用户登录事件发送
// UserBaseDetailEvent regEvent = UserBaseDetailEvent
// .builder()
// .userId(String.valueOf(user.getId()))
// .userUuid(user.getUuid())
// .channel(1L)
// .hashPhoneNo("*********")
// .businessEventBaseInfo(BusinessEventBaseInfo
// .builder()
// .channel("***")
// .deviceId("***")
// .ip("***")
// .userUuid("***")
// .build())
// .subEventType(UserBaseDetailEvent.SubEventType.REGISTER)
// .build();
// regEvent.setRegisterChannel(user.getRegisteredFrom().intValue());
// regEvent.setRegisterTime(user.getCreatedAt().getTime());
//
// try {
// ListenableFuture<UserRecordResult> listenableFuture = kinesisProducerClient.SendRecord(regEvent);
// Futures.addCallback(listenableFuture, Callback);
// log.info("[KinesisRegistered] 用户分群数据上报发送, regEvent:{}", JsonUtil.toJson(regEvent));
// } catch (UnsupportedEncodingException | JsonProcessingException e) {
// log.error("[KinesisRegistered]用户分群数据上报出错, e:{}", e);
// throw new PushUserToLkbException("用户分群数据上报出错");
// }
// }
//
// // 异步响应结果 如果发送失败，发送方需要进行重试发送
// FutureCallback<UserRecordResult> Callback = new FutureCallback<UserRecordResult>() {
// @Override
// public void onFailure(Throwable t) {
// /* Analyze and respond to the failure */
// log.error(t.getMessage(), t);
// log.error("[KinesisRegistered] 用户分群数据上报失败, Throwable:{}", ExceptionUtils.getStackTrace(t));
// }
//
// @Override
// public void onSuccess(UserRecordResult result) {
// log.info("[KinesisRegistered] 用户分群数据上报成功, result:{}", result.toString());
// }
// };
//}
UserBaseDetailEvent regEvent = UserBaseDetailEvent
.builder()
.userId(String.valueOf(user.getId()))
.userUuid(user.getUuid())
.subEventType(UserBaseDetailEvent.SubEventType.REGISTER)
.build();
regEvent.setRegisterChannel(user.getRegisteredFrom().intValue());
regEvent.setRegisterTime(user.getCreatedAt().getTime());
try {
ListenableFuture<UserRecordResult> listenableFuture = kinesisProducerClient.SendRecord(regEvent);
Futures.addCallback(listenableFuture, Callback);
log.info("[KinesisRegistered] 用户分群数据上报发送, regEvent:{}", JsonUtil.toJson(regEvent));
} catch (UnsupportedEncodingException | JsonProcessingException e) {
log.error("[KinesisRegistered]用户分群数据上报出错, e:{}", e);
throw new PushUserToLkbException("用户分群数据上报出错");
}
}
// 异步响应结果 如果发送失败，发送方需要进行重试发送
FutureCallback<UserRecordResult> Callback = new FutureCallback<UserRecordResult>() {
@Override
public void onFailure(Throwable t) {
/* Analyze and respond to the failure */
log.error(t.getMessage(), t);
log.error("[KinesisRegistered] 用户分群数据上报失败, Throwable:{}", ExceptionUtils.getStackTrace(t));
}
@Override
public void onSuccess(UserRecordResult result) {
log.info("[KinesisRegistered] 用户分群数据上报成功, result:{}", result.toString());
}
};
}
src/main/java/cn/quantgroup/xyqb/event/LkbRegisteredEventListener.java
View file @ c995610e
......@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component;
* @author ag
*/
@Slf4j
@Component
//@Component
public class LkbRegisteredEventListener implements ApplicationListener<RegisterEvent> {
@Autowired
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment