package com.qxueyou.scc.admin.notice.service.impl;

import java.util.Collection;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.qxueyou.scc.admin.notice.dao.NoticeDAO;
import com.qxueyou.scc.admin.notice.service.INoticeService;
import com.qxueyou.scc.base.model.Pager;
import com.qxueyou.scc.base.model.Result;
import com.qxueyou.scc.base.service.impl.CommonAppService;
import com.qxueyou.scc.base.util.CollectionUtils;
import com.qxueyou.scc.base.util.TraceUtils;
import com.qxueyou.scc.msg.model.MsgInfo;
import com.qxueyou.scc.msg.service.IMsgInfoService;
import com.qxueyou.scc.notice.model.Notice;

@Service
public class NoticeService extends CommonAppService implements INoticeService {

    @Autowired
    NoticeDAO dao;
    
	@Autowired
	IMsgInfoService msgInfoService;

    @Override
    public Result add(String name, String content, String type, List<String> classIds) {

        Notice notice = new Notice();
        TraceUtils.setCreateTrace(notice);

        notice.setTitle(name);
        notice.setContent(content);
        notice.setNoticeTypeName(type);
        notice.setStatus(Notice.STATUS_DRAFT);

        save(notice);

        dao.saveNoticeClasses(notice.getNoticeId(), classIds);

        return new  Result(true,"",notice.getNoticeId());
    }

    @Override
    public Result update(String noticeId, String name, String content, String type, List<String> classIds) {

        Notice notice = read(noticeId);
        TraceUtils.setUpdateTrace(notice);

        notice.setTitle(name);
        notice.setContent(content);
        notice.setNoticeTypeName(type);

        save(notice);

        dao.saveNoticeClasses(notice.getNoticeId(), classIds);

        return Result.SUCCESS;
    }

    @Override
    public Notice read(String noticeId) {
        return read(Notice.class, noticeId);
    }

    @Override
    public List<Notice> readByStatus(Collection<String> noticeIdLst, short status) {
        if (noticeIdLst.isEmpty()) {
            noticeIdLst.add("noticeId");
        }
        String hql = "from Notice where  noticeId in (:noticeId) and status =:status order by createTime desc";
        return findByComplexHql(hql, CollectionUtils.newObjectMap("noticeId", noticeIdLst, "status", status),
                Notice.class);
    }

    @Override
    public List<Notice> list(String keyword, Integer pageNum, Integer pageSize, String createId, String sort) {
        String hql = "from Notice where deleteFlag is false and title like ? and createId=? ";
        if (sort.equals("desc")) {
            hql = hql.concat("order by createTime desc");
        } else {
            hql = hql.concat("order by createTime asc");
        }

        return findList(hql, new Pager(pageSize, pageNum), CollectionUtils.newList(keyword + "%", createId),
                Notice.class);
    }

    @Override
    public int listCount(String keyword, String createId) {
        String hql = "from Notice where deleteFlag is false and title like ? and createId=?";

        return findCount(hql, CollectionUtils.newList(keyword + "%", createId));
    }

    @SuppressWarnings("unchecked")
    @Override
    public Result delete(String noticeId) {
        Notice notice = read(noticeId);
        TraceUtils.setUpdateTrace(notice);
        notice.setDeleteFlag(true);
        save(notice);

        dao.saveNoticeClasses(noticeId, Collections.EMPTY_LIST);

        return Result.SUCCESS;
    }

    @Override
    public Result delete(String[] noticeIds) {
        for (String noticeId : noticeIds) {
            delete(noticeId);
            dao.deleteNoticeForCache(noticeId);
        }
        return Result.SUCCESS;
    }

    @Override
    public Result doIssue(String noticeId) {
        Notice notice = read(noticeId);

        TraceUtils.setUpdateTrace(notice);
        notice.setStatus(Notice.STATUS_ISSUED);
        notice.setIssuedTime(new Date());

        save(notice);
        return Result.SUCCESS;
    }

    @Override
    public Result doIssue(String[] noticeIds) {
        for (String noticeId : noticeIds) {
            doIssue(noticeId);
            doSendhMsg(noticeId);
        }
        return Result.SUCCESS;
    }
    
    
    private void doSendhMsg(String noticeId){
    	Notice  notice = this.read(noticeId);
    	List<String> lstClassIds= dao.getLiveClasses(noticeId);
    	
    	if(lstClassIds == null || lstClassIds.size()==0){
    		return ;
    	}
		//查询直播关联的班级
		String hql = "select userId from StuStudent  where classId in (:classIds) and deleteFlag is false ";
		
		List<String> lstUserIds = this.findByComplexHql(hql, CollectionUtils.newObjectMap("classIds",lstClassIds.toArray(new String[lstClassIds.size()])), String.class);
		
		if(lstUserIds!=null && lstUserIds.size()>0){
			Map<String,String> attrs = CollectionUtils.newStringMap("noticeId",notice.getNoticeId(),"title",notice.getTitle(),
					"creator",notice.getCreator(),"noticeTypeName",notice.getNoticeTypeName());
				
			msgInfoService.doSendTextMsgToUsers(lstUserIds.toArray(new String[lstUserIds.size()]), 
											MsgInfo.TYPE_NOTICE," 发布了公告", attrs);
		}
	}
    
    @Override
    public Result doCancel(String noticeId) {
        return status(noticeId, Notice.STATUS_DRAFT);
    }

    @Override
    public Result doCancel(String[] noticeIds) {
        for (String noticeId : noticeIds) {
            doCancel(noticeId);
        }
        return Result.SUCCESS;
    }

    @Override
    public List<String> getNoticeClasses(String noticeId) {
        return dao.getLiveClasses(noticeId);
    }

    private Result status(String noticeId, short status) {
        Notice notice = read(noticeId);
        TraceUtils.setUpdateTrace(notice);
        notice.setStatus(status);
        save(notice);
        return Result.SUCCESS;
    }

    @Override
    public Result view(String noticeId) {
        return Result.SUCCESS;
    }

}