package com.tievd.cube.modules.system.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.tievd.cube.commons.annotations.DictMethod;
import com.tievd.cube.commons.base.CubeController;
import com.tievd.cube.commons.base.Result;
import com.tievd.cube.commons.utils.SystemContextUtil;
import com.tievd.cube.modules.system.entity.SysAnnouncementSend;
import com.tievd.cube.modules.system.model.AnnouncementSendModel;
import com.tievd.cube.modules.system.model.LoginUser;
import com.tievd.cube.modules.system.model.api.request.GetMyNewsRequest;
import com.tievd.cube.modules.system.model.api.request.HaveReadRequest;
import com.tievd.cube.modules.system.service.ISysAnnouncementSendService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Parameters;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

/**
 * 用户通告发送与阅读标记
 *
 * @author 杨欣武
 * @version 2.5.3
 * @since 2022-08-12
 */
@Tag(name = "通告阅读标记相关接口")
@RestController
@RequestMapping("/sys/announcement/send")
public class SysAnnouncementSendController extends CubeController<SysAnnouncementSend, ISysAnnouncementSendService> {

    /**
     * 标记用户系统消息已读
     */
    @PutMapping("/haveRead")
    @Operation(summary = "系统消息已读")
    public Result<?> haveRead(@Validated @RequestBody HaveReadRequest request) {
        service.haveRead(request.getAnntId());
        return Result.ok();
    }

    /**
     * 获取我的消息
     */
    @DictMethod
    @GetMapping("/getMyAnnouncementSend")
    @Operation(summary = "获取我的消息")
    @Parameters({
            @Parameter(name = "title", description = "标题"),
            @Parameter(name = "sender", description = "发布人"),
            @Parameter(name = "readFlag", description = "阅读状态"),
            @Parameter(name = "msgCategory", description = "消息类型（1:通知公告、2:系统消息）"),
            @Parameter(name = "busType", description = "业务类型"),
            @Parameter(name = "pageNo", description = "页码"),
            @Parameter(name = "pageSize", description = "每页数量")
    })
    public Result<IPage<AnnouncementSendModel>> getMyAnnouncementSend(@Parameter(hidden = true) GetMyNewsRequest request) {
        LoginUser sysUser = SystemContextUtil.currentLoginUser();
        String userId = sysUser.getId();
        AnnouncementSendModel announcementSend = new AnnouncementSendModel();
        announcementSend.setUserId(userId);
        announcementSend.setMsgCategory(request.getMsgCategory());
        announcementSend.setTitle(request.getTitle());
        announcementSend.setSender(request.getSender());
        announcementSend.setReadFlag(request.getReadFlag());
        announcementSend.setBusType(request.getBusType());
        announcementSend.setPageNo((request.getPageNo() - 1) * request.getPageSize());
        announcementSend.setPageSize(request.getPageSize());
        Page<AnnouncementSendModel> pageList = new Page<>(request.getPageNo(), request.getPageSize());
        pageList = service.getMyAnnouncementSendPage(pageList, announcementSend);
        return Result.ok(pageList);
    }

    /**
     * 一键已读
     */
    @PutMapping("/readAll")
    @Operation(summary = "一键已读")
    public Result<?> readAll() {
        service.readAll();
        return Result.ok();
    }
}