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.dao.SiteMessageMapper;
import com.nq.dao.UserMapper;
import com.nq.pojo.SiteMessage;
import com.nq.pojo.User;
import com.nq.service.ISiteMessageService;
import com.nq.service.IUserService;
import com.nq.utils.DateTimeUtil;
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;

    @Autowired
    UserMapper userMapper;

    @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("請先登錄");
            }
            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不能为空");
        }

        int updateCount = this.siteMessageMapper.delete(id);
        if (updateCount > 0) {
            return ServerResponse.createBySuccessMsg("删除成功");
        }
        return ServerResponse.createByErrorMsg("删除失败");
    }

    @Override
    public ServerResponse sendMessage(Integer userId, String content, String typeName) {
        int ret = 0;
        if (content == null || content.trim().isEmpty()) {
            return ServerResponse.createByErrorMsg("消息内容不能为空");
        }

        try {
            // userId为0或null表示发送给所有用户
            if (userId == null || userId == 0) {
                List<User> users = this.userMapper.listByAdmin(null, null, null, null);
                for (User user : users) {
                    SiteMessage siteMessage = new SiteMessage();
                    siteMessage.setUserId(user.getId());
                    siteMessage.setUserName(user.getRealName() != null ? user.getRealName() : user.getPhone());
                    siteMessage.setTypeName(typeName != null ? typeName : "站内消息");
                    siteMessage.setStatus(1); // 1表示未读
                    siteMessage.setContent(content);
                    siteMessage.setAddTime(DateTimeUtil.getCurrentDate());
                    ret = siteMessageMapper.insert(siteMessage);
                }
            } else {
                // 发送给指定用户
                User user = userMapper.selectByPrimaryKey(userId);
                if (user == null) {
                    return ServerResponse.createByErrorMsg("用户不存在");
                }
                SiteMessage siteMessage = new SiteMessage();
                siteMessage.setUserId(user.getId());
                siteMessage.setUserName(user.getRealName() != null ? user.getRealName() : user.getPhone());
                siteMessage.setTypeName(typeName != null ? typeName : "站内消息");
                siteMessage.setStatus(1); // 1表示未读
                siteMessage.setContent(content);
                siteMessage.setAddTime(DateTimeUtil.getCurrentDate());
                ret = siteMessageMapper.insert(siteMessage);
            }

            if (ret > 0) {
                return ServerResponse.createBySuccessMsg("发送成功");
            }
            return ServerResponse.createByErrorMsg("发送失败");
        } catch (Exception e) {
            return ServerResponse.createByErrorMsg("发送失败：" + e.getMessage());
        }
    }

}