package org.jeecg.modules.system.service.impl;

import java.util.*;
import java.util.stream.Collectors;

import javax.annotation.Resource;

import org.apache.commons.compress.utils.Lists;
import org.apache.commons.lang3.StringUtils;
import org.jeecg.common.constant.CommonConstant;
import org.jeecg.modules.system.entity.SysAnnouncementSend;
import org.jeecg.modules.system.mapper.SysAnnouncementSendMapper;
import org.jeecg.modules.system.model.AnnouncementSendModel;
import org.jeecg.modules.system.service.ISysAnnouncementSendService;
import org.jeecg.modules.system.vo.OptionsVo;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

/**
 * @Description: 用户通告阅读标记表
 * @Author: jeecg-boot
 * @Date:  2019-02-21
 * @Version: V1.0
 */
@Service
public class SysAnnouncementSendServiceImpl extends ServiceImpl<SysAnnouncementSendMapper, SysAnnouncementSend> implements ISysAnnouncementSendService {

	@Resource
	private SysAnnouncementSendMapper sysAnnouncementSendMapper;

	@Override
	public List<String> queryByUserId(String userId) {
		return sysAnnouncementSendMapper.queryByUserId(userId);
	}

	@Override
	public Page<AnnouncementSendModel> getMyAnnouncementSendPage(Page<AnnouncementSendModel> page,
			AnnouncementSendModel announcementSendModel) {

		List<String> msgCategory = Lists.newArrayList();
		if ("系统消息".equals(announcementSendModel.getMsgCategory())) {
			msgCategory.addAll(Arrays.asList("系统消息", "2"));
		}else if ("通知公告".equals(announcementSendModel.getMsgCategory())) {
			msgCategory.addAll(Arrays.asList("通知公告", "1"));
		}else if (StringUtils.isNotBlank(announcementSendModel.getMsgCategory())){
			msgCategory.addAll(Arrays.asList(announcementSendModel.getMsgCategory()));
		}
		announcementSendModel.setMsgCategoryList(msgCategory);
		 return page.setRecords(sysAnnouncementSendMapper.getMyAnnouncementSendList(page, announcementSendModel));
	}

	@Override
	public AnnouncementSendModel getOne(String sendId) {
		return sysAnnouncementSendMapper.getOne(sendId);
	}

	@Override
	public List<SysAnnouncementSend> getPrimaryInfo(String userId, List<String> msgCategoryList) {
		return baseMapper.getPrimaryInfo(userId,msgCategoryList);
	}

	@Override
	public List<OptionsVo> getMessageType() {
		Set<OptionsVo> result = new HashSet<>();
        List<String> messageTypeList = this.baseMapper.getMessageType();
        if (messageTypeList != null && !messageTypeList.isEmpty()) {
            for (String messageType : messageTypeList) {
				OptionsVo optionsVo = new OptionsVo();
				String label = messageType;
				String value = messageType;
				if (CommonConstant.MSG_CATEGORY_2.equals(messageType)) {
					label = "系统消息";
					value = "系统消息";
				} else if (CommonConstant.MSG_CATEGORY_1.equals(messageType)) {
					label = "通知公告";
					value = "通知公告";
				}
				optionsVo.setLabel(label);
				optionsVo.setValue(value);
                result.add(optionsVo);
            }
        }
        return new ArrayList<>(result);
	}

}