@RequestMapping(path = "/index",method = RequestMethod.GET)

//刷新帖子分数任务
@Bean
public JobDetailFactoryBean postScoreRefreshJobDetail(){
    JobDetailFactoryBean factoryBean=new JobDetailFactoryBean();
    factoryBean.setJobClass(PostScoreRefreshJob.class);
    factoryBean.setName("postScoreRefreshJob");
    factoryBean.setGroup("postScoreRefreshJobGroup");
    factoryBean.setDurability(true);
    factoryBean.setRequestsRecovery(true);
    return factoryBean;
}

@Bean
public SimpleTriggerFactoryBean postScoreRefreshTrigger(JobDetail postScoreRefreshJobDetail){
    SimpleTriggerFactoryBean factoryBean=new SimpleTriggerFactoryBean();
    factoryBean.setJobDetail(postScoreRefreshJobDetail);
    factoryBean.setName("postScoreRefreshTrigger");
    factoryBean.setGroup("communityTriggerGroup");
    factoryBean.setRepeatInterval(1000*60*5);
    factoryBean.setJobDataMap(new JobDataMap());
    return factoryBean;
}

@RequestMapping(path = "/register",method = RequestMethod.GET)

@RequestMapping(path = "/register",method = RequestMethod.POST)

@RequestMapping(path = "/login",method = RequestMethod.GET)

@RequestMapping(path = "/kaptcha",method = RequestMethod.GET)

@RequestMapping(path = "/login",method = RequestMethod.POST)

.antMatchers(
        "/user/setting",
        "/user/upload",
        "/discuss/add",
        "/comment/add/**",
        "/letter/**",
        "/notice/**",
        "/like",
        "/follow",
        "/unfollow",
        "/profile/**"
).
hasAnyAuthority(
        AUTHORITY_USER, //普通用户
        AUTHORITY_ADMIN, //管理员
        AUTHORITY_MODERATOR //版主
)
.antMatchers(
        "/discuss/top",
        "/discuss/wonderful"
).
hasAnyAuthority(
        AUTHORITY_MODERATOR
)
.antMatchers(
        "/discuss/delete",
        "/data/**",
        "/actuator/**"
).
hasAnyAuthority(
        AUTHORITY_ADMIN
)
.anyRequest().permitAll() // 其他路径未登录用户也可以访问

.authenticationEntryPoint(new AuthenticationEntryPoint() {
    // 没有登录
    @Override
    public void commence(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, AuthenticationException e) throws IOException, ServletException {
        // 根据请求是否为 AJAX 请求，以不同的方式响应未经身份验证的用户。对于 AJAX 请求，它发送JSON响应；对于非 AJAX 请求，它将用户重定向到登录页面
        String xRequestWith = httpServletRequest.getHeader("x-requested-with");
        if("XMLHttpRequest".equals(xRequestWith)){
            httpServletResponse.setContentType("application/plain;charset=utf-8");
            PrintWriter writer = httpServletResponse.getWriter();
            writer.write(CommunityUtil.getJSONString(403,"您还没有登录!"));
        }else{
            httpServletResponse.sendRedirect(httpServletRequest.getContextPath()+"/login");
        }
    }
})
.accessDeniedHandler(new AccessDeniedHandler() {
    // 权限不足
    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, AccessDeniedException e) throws IOException, ServletException {
        // 根据请求是否为 AJAX 请求，以不同的方式响应用户没有访问权限的情况。对于 AJAX 请求，它发送JSON响应；对于非 AJAX 请求，它将用户重定向到错误页面
        String xRequestWith = httpServletRequest.getHeader("x-requested-with");
        if("XMLHttpRequest".equals(xRequestWith)){
            httpServletResponse.setContentType("application/plain;charset=utf-8");
            PrintWriter writer = httpServletResponse.getWriter();
            writer.write(CommunityUtil.getJSONString(403,"你没有访问此功能的权限!"));
        }else{
            httpServletResponse.sendRedirect(httpServletRequest.getContextPath()+"/denied");
        }
    }
});

http.logout().logoutUrl("/securitylogout");

@RequestMapping(path = "/setting",method = RequestMethod.GET)

# 七牛云
qiniu.key.access=密钥AK
qiniu.key.secret=密钥SK
qiniu.bucket.header.name=自己存放头像的云空间
qiniu.bucket.header.url=自己存放头像的云空间url

@RequestMapping(path = "/add",method = RequestMethod.POST)
@ResponseBody

Event event=new Event()
        .setTopic(TOPIC_PUBLISH)
        .setUserId(user.getId())
        .setEntityType(ENTITY_TYPE_COMMENT)
        .setEntityId(discussPost.getId());
eventProducer.fireEvent(event);

//生产者
//处理事件
public void fireEvent(Event event){
    //将事件发送到指定的主题
    kafkaTemplate.send(event.getTopic(), JSONObject.toJSONString(event));
}

//消费者
//监听TOPIC_PUBLISH事件
@KafkaListener(topics = TOPIC_PUBLISH)
public void HandlePublish(ConsumerRecord record){
    if(record==null||record.value()==null){
        logger.error("消息内容为空！");
        return;
    }
    Event event = JSONObject.parseObject(record.value().toString(), Event.class);
    if (event==null) {
        logger.error("消息格式错误！");
        return;
    }

    //通过实体类id查询帖子
    DiscussPost post = discussPostService.findDiscussPostById(event.getEntityId());
	//发送到ES中
    elasticsearchService.saveDiscussPost(post);
}

//刷新帖子分数
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    String redisKey = RedisKeyUtil.getPostScoreKey();
    BoundSetOperations operations=redisTemplate.boundSetOps(redisKey);

    if (operations.size()==0) {
        logger.info("[任务取消]，没有需要刷新的帖子!");
        return;
    }

    logger.info("[任务开始]，正在刷新帖子的分数："+operations.size());
    while (operations.size() > 0) {
        this.refresh((Integer)operations.pop());
    }

    logger.info("[任务结束]，帖子分数刷新完毕!");
}

private void refresh(int postId){
    DiscussPost post = discussPostService.findDiscussPostById(postId);
    if (post==null) {
        logger.error("该帖子不存在：id="+postId);
        return;
    }
    
    /*具体的的分数计算*/

    //更新帖子的分数
    discussPostService.updateScore(postId,score);

    //同步es中的数据
    post.setScore(score);
    elasticsearchService.saveDiscussPost(post);
}

@RequestMapping(path = "/detail/{disPostId}",method = RequestMethod.GET)

commentVoList
··commentVo
....comment				//评论
....user				//评论作者
....likeCount			//评论的点赞数量
....likeStatus			//评论的点赞状态
....replyCount			//评论的回复数量
....replyVoList
......replyVo
........reply			//回复
........user			//回复的作者
........target			//回复的目标（User）
........likeCount		//回复的点赞数量
........likeStatus		//回复的点赞状态

@RequestMapping(path = "/add/{discussPostId}",method = RequestMethod.POST)

@RequestMapping(path = "/notice/list",method = RequestMethod.GET)

messageVo
..message			//消息
..user				//用户
..entityType		//实体类型
..entityId			//实体id
..postId			//帖子的id
..count				//消息总数量
..unreadCount		//未读的数量

@RequestMapping(path = "/notice/detail/{topic}",method = RequestMethod.GET)

noticeVoList
..noticeVo
....notice			//通知
....user			//用户
....entityType		//实体类类型
....entityId		//实体类id
....postId			//帖子id
....fromUser		//通知作者

@RequestMapping(path = "/letter/list",method = RequestMethod.GET)

conversations
..map
....conversation		//最新的一条消息
....letterCount			//消息数量
....unreadCount			//未读消息的数量
....target				//目标用户

@RequestMapping(path = "/letter/detail/{conversationId}",method = RequestMethod.GET)

letters
..map
....letter			//消息
....fromUser		//消息的发送者
target				//消息的目标

@RequestMapping(path = "/letter/send",method = RequestMethod.POST)
@ResponseBody

@RequestMapping(path = "/like",method = RequestMethod.POST)
@ResponseBody

redisTemplate.execute(new SessionCallback() {
    @Override
    public Object execute(RedisOperations operations) throws DataAccessException {
        //谁给帖子点了赞的集合key
        String entityLikeKey = RedisKeyUtil.getEntityLikeKey(entityType, id);
        //用户的总点赞量的key
        String userLikeKey = RedisKeyUtil.getUserLikeKey(targetUserId);
        //判断用户是否点赞
        Boolean isMember = redisTemplate.opsForSet().isMember(entityLikeKey, userId);
        //开启事务
        operations.multi();
        if (isMember) {//已有点赞，就取消点赞
            redisTemplate.opsForSet().remove(entityLikeKey, userId);
            redisTemplate.opsForValue().decrement(userLikeKey);
        } else {//没有点赞，点赞成功
            redisTemplate.opsForSet().add(entityLikeKey, userId);
            redisTemplate.opsForValue().increment(userLikeKey);
        }
        return operations.exec();
    }
});

@RequestMapping(path = "/profile/{userId}",method = RequestMethod.GET)

@RequestMapping(path = "/followees/{userId}",method = RequestMethod.GET)

@ControllerAdvice(annotations = Controller.class)
public class ExceptionAdvice {
    private static Logger logger= LoggerFactory.getLogger(ExceptionAdvice.class);

    @ExceptionHandler({Exception.class})
    public void handleException(Exception e, HttpServletRequest request, HttpServletResponse response) throws IOException {
        logger.error("服务器发生异常："+e.getMessage());
        for (StackTraceElement element : e.getStackTrace()) {
            logger.error(element.toString());
        }

        //用于判断请求是否为异步请求
        String xRequestedWith = request.getHeader("x-requested-with");
        if ("XMLHttpRequest".equals(xRequestedWith)) {
            response.setContentType("application/plain;charset=utf-8");
            PrintWriter writer = response.getWriter();
            writer.write(CommunityUtil.getJSONString(1,"服务器异常！"));
        }else{
            response.sendRedirect(request.getContextPath()+"/error");
        }
    }
}

@Component
@Aspect
public class ServiceLogAspect {

    private static Logger logger= LoggerFactory.getLogger(ServiceLogAspect.class);

    @Pointcut("execution(* com.nowcoder.community.service.*.*(..))")
    public void pointcut(){

    }

    @Before("pointcut()")
    public void before(JoinPoint joinPoint){
        //用户[1.2.3.4]，在[XXX(时间)],访问了[com.nowcoder.community.service.xxx()].
        //获取用户ip
        ServletRequestAttributes attributes=(ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        if (attributes==null){//常规调用，不是前端调用
            return;
        }
        HttpServletRequest request = attributes.getRequest();
        String ip = request.getRemoteHost();
        //获取时间
        String now = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
        //获取访问的方法名
        String target=joinPoint.getSignature().getDeclaringTypeName()+"."+joinPoint.getSignature().getName();
        logger.info(String.format("用户[%s]，在[%s],访问了[%s].",ip,now,target));
    }
}

@RequestMapping(path = "/data",method = {RequestMethod.GET,RequestMethod.POST})

//统计网站UV
@RequestMapping(path = "/data/uv",method = RequestMethod.POST)

redisTemplate.opsForHyperLogLog().size(redisKey);

//统计网站DAU
@RequestMapping(path = "/data/dau",method = RequestMethod.POST)