package cn.stylefeng.rest.modular.im.controller;

import cn.hutool.core.date.DateUtil;
import cn.stylefeng.guns.modular.business.entity.ImUserStatus;
import cn.stylefeng.guns.modular.business.service.IImUserStatusService;
import cn.stylefeng.roses.kernel.auth.api.expander.AuthConfigExpander;
import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi;
import cn.stylefeng.roses.kernel.im.api.pojo.ImMessageRoutingDTO;
import cn.stylefeng.roses.kernel.rule.constants.RuleConstants;
import cn.stylefeng.roses.kernel.scanner.api.annotation.ApiResource;
import cn.stylefeng.roses.kernel.scanner.api.annotation.PostResource;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.util.List;

@Slf4j
@Api(tags = "IM接口")
@RestController
@ApiResource(name = "IM接口")
@RequestMapping("/im")
public class ImNotifyController {

    @Resource
    private CacheOperatorApi<Object> objectCacheOperatorApi;

    @Resource
    private CacheOperatorApi<ImMessageRoutingDTO> imMessageRoutingDTOCacheOperatorApi;

    @Resource
    IImUserStatusService imUserStatusService;

    @SneakyThrows
    @ApiOperation(value = "用户在线状态回调")
    @PostResource(name = "用户在线状态回调", path = RuleConstants.NOT_LOGIN + "/userStatusNotify")
    public String userStatusNotify(@RequestBody List<ImUserStatus> list) {
        // 回调地址：http://1.95.0.51:8081/rest/im/notLogin/userStatusNotify
        log.info("IM-用户在线状态回调：{}", list);
        list.forEach(o -> {
            boolean update = imUserStatusService.update(o,
                    Wrappers.<ImUserStatus>lambdaUpdate()
                            .eq(ImUserStatus::getUserid, o.getUserid())
                            .eq(ImUserStatus::getOs, o.getOs())
            );
            if (!update) {
                imUserStatusService.save(o);
            }
        });
        return "success";
    }

    @SneakyThrows
    @ApiOperation(value = "全量消息路由")
    @PostResource(name = "全量消息路由", path = RuleConstants.NOT_LOGIN + "/messageRouting")
    public String messageRouting(ImMessageRoutingDTO dto) {
        // 全量消息路由Api文档：https://doc.rongcloud.cn/imserver/server/v1/message/sync
        log.info("IM-全量消息路由：{}", dto);

        if (dto != null && "GROUP".equals(dto.getChannelType())) {
            // 更新群组消息时间
            objectCacheOperatorApi.put("ImGroupTime:" + dto.getToUserId(), DateUtil.date().toString(), 60L * 60 * 24 * 30);
        }

        // IM消息缓存失效时间（秒），0不缓存，-1不过期
        Long timeOutSecond = AuthConfigExpander.getsImMessageCacheTimeOutSecond();
        if (timeOutSecond != 0) {
            // 缓存消息（10天：60L * 60 * 24 * 10）
            imMessageRoutingDTOCacheOperatorApi.put(dto.getChannelType() + ":" + dto.getToUserId() + ":" + dto.getMsgUID(), dto, timeOutSecond);
        }

        return "success";
    }

}