package com.yeshi.fanli.aspect;
|
|
import java.io.IOException;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.aspectj.lang.ProceedingJoinPoint;
|
import org.aspectj.lang.annotation.Around;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.springframework.core.annotation.Order;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.context.request.RequestContextHolder;
|
import org.springframework.web.context.request.ServletRequestAttributes;
|
|
import com.yeshi.fanli.entity.accept.AcceptData;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.ThreadUtil;
|
|
/**
|
* 活跃用户处理
|
*
|
* @author Administrator
|
*
|
*/
|
//@Component
|
//@Aspect
|
//@Order(6)
|
public class ActiveUserAspect {
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private UserSystemCouponService userSystemCouponService;
|
|
public static final String EDP = "execution(* com.yeshi.fanli.controller.client.*.*(..))";
|
|
@Around(EDP)
|
public Object activeAround(ProceedingJoinPoint joinPoint) throws Throwable {
|
|
Object[] args = joinPoint.getArgs();
|
if (!Constant.IS_OUTNET) {
|
return joinPoint.proceed(args); // 外网环境
|
}
|
|
try {
|
|
System.out.println("----------活跃验证---------------");
|
|
ServletRequestAttributes servletContainer = (ServletRequestAttributes) RequestContextHolder
|
.getRequestAttributes();
|
|
HttpServletRequest request = servletContainer.getRequest();
|
|
String strUid = request.getParameter("uid");
|
if (strUid == null || strUid.trim().length() == 0) {
|
return joinPoint.proceed(args);
|
}
|
|
Long uid = Long.parseLong(strUid);
|
|
String key = "activeUid_" + uid;
|
|
String cacheValue = redisManager.getCommonString(key);
|
if (cacheValue != null && cacheValue.trim().length() > 0) {
|
return joinPoint.proceed(args);
|
}
|
|
// 加入缓存
|
redisManager.cacheCommonString("activeUid_" + uid, strUid, 60);
|
|
AcceptData acceptData = null;
|
for (Object argsobj : args) {
|
if (argsobj instanceof AcceptData) {
|
acceptData = (AcceptData) argsobj;
|
}
|
}
|
|
if (acceptData == null) {
|
return joinPoint.proceed(args);
|
}
|
|
int platformType = 0;
|
String platform = acceptData.getPlatform();
|
if ("android".equals(platform)) {
|
platformType = 1;
|
} else if ("ios".equals(platform)) {
|
platformType = 2;
|
}
|
userSystemCouponService.copyLotteryPrize(uid, platformType, acceptData.getDevice());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
return joinPoint.proceed(args);
|
}
|
|
}
|
