package com.nq.service.impl;

import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.common.lanage.MessageLocaleResolver;
import com.nq.dao.SiteMessageMapper;
import com.nq.pojo.SiteMessage;
import com.nq.pojo.User;
import com.nq.service.ISiteMessageService;
import com.nq.service.IUserService;
import com.nq.vo.agent.AgentAgencyFeeVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.List;

/**
 * site_message
 * @author lr
 * @date 2020/07/16
 */
@Service("ISiteMessageService")
public class SiteMessageServiceImpl implements ISiteMessageService {

    @Resource
    private SiteMessageMapper siteMessageMapper;

    @Autowired
    IUserService iUserService;

    @Override
    public int insert(SiteMessage siteMessage) {
        int ret = 0;
        if (siteMessage == null) {
            return 0;
        }

        ret = siteMessageMapper.insert(siteMessage);
        return ret;
    }

    @Override
    public int update(SiteMessage siteMessage) {
        int ret = siteMessageMapper.update(siteMessage);
        return ret>0 ? ret: 0;
    }

    @Override
    public int delete(int id) {
        int ret = siteMessageMapper.delete(id);
        return ret>0 ? ret: 0;
    }

    /*查询用户站内消息列表
     * */
    @Override
    public ServerResponse<PageInfo> getSiteMessageByUserIdList(int pageNum, int pageSize, int userId, HttpServletRequest request) {
        Page<AgentAgencyFeeVO> page = PageHelper.startPage(pageNum, pageSize);
        int uid = 0;
        //总后台查所有,其他人走登录信息userid
        if(userId != 999){
            User user = this.iUserService.getCurrentRefreshUser(request);
            if (user == null){
                return ServerResponse.createBySuccessMsg("Please log in first",request.getHeader(MessageLocaleResolver.LANG));
            }
            uid = user.getId();
        }
        User user = this.iUserService.getCurrentRefreshUser(request);
        List<SiteMessage> siteMessageList = this.siteMessageMapper.getSiteMessageByUserIdList(uid);
        PageInfo pageInfo = new PageInfo(page);
        pageInfo.setList(siteMessageList);
        return ServerResponse.createBySuccess(pageInfo);
    }

    @Override
    public int getIsDayCount(Integer userId, String typeName) {
        int ret = siteMessageMapper.getIsDayCount(userId, typeName);
        return ret>0 ? ret: 0;
    }

    @Override
    public int updateMessageStatus(HttpServletRequest request) {
        User user = this.iUserService.getCurrentRefreshUser(request);
        if (user == null){
            return 0;
        }
        int ret = siteMessageMapper.updateMessageStatus(user.getId());
        return ret>0 ? ret: 0;
    }

    @Override
    public int getUnreadCount(HttpServletRequest request) {
        User user = this.iUserService.getCurrentRefreshUser(request);
       if (user == null){
           return 0;
       }
        int ret = siteMessageMapper.getUnreadCount(user.getId());
        return ret>0 ? ret: 0;
    }

    public ServerResponse del(Integer id, HttpServletRequest request) {
        if (id == null) {
            return ServerResponse.createByErrorMsg("id cannot be empty",request.getHeader(MessageLocaleResolver.LANG));
        }

        int updateCount = this.siteMessageMapper.delete(id);
        if (updateCount > 0) {
            return ServerResponse.createBySuccessMsg("successfully deleted",request.getHeader(MessageLocaleResolver.LANG));
        }
        return ServerResponse.createByErrorMsg("failed to delete",request.getHeader(MessageLocaleResolver.LANG));
    }

}