package com.panzhihua.service_community.service.impl;

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

import javax.annotation.Resource;

import com.panzhihua.common.model.vos.community.ComActDpcVO;
import com.panzhihua.common.model.vos.user.SysTemplateConfigVO;
import com.panzhihua.common.service.user.UserService;
import com.panzhihua.service_community.dao.ComActDAO;
import com.panzhihua.service_community.dao.ComActDpcDAO;
import com.panzhihua.service_community.model.dos.ComActDO;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActMessageBackVO;
import com.panzhihua.common.model.vos.community.ComActMessageVO;
import com.panzhihua.common.model.vos.community.PageComActMessageVO;
import com.panzhihua.common.model.vos.community.ResetComActMessageVO;
import com.panzhihua.common.model.vos.partybuilding.ComPbServiceTeamVO;
import com.panzhihua.common.model.vos.partybuilding.PartyCommitteeVO;
import com.panzhihua.common.utlis.DateUtils;
import com.panzhihua.common.utlis.WxUtil;
import com.panzhihua.common.utlis.WxXCXTempSend;
import com.panzhihua.service_community.dao.ComActActSignDAO;
import com.panzhihua.service_community.dao.ComActMessageBackDAO;
import com.panzhihua.service_community.dao.ComActMessageDAO;
import com.panzhihua.service_community.model.dos.ComActMessageBackDO;
import com.panzhihua.service_community.model.dos.ComActMessageDO;
import com.panzhihua.service_community.service.ComActMessageService;

import static java.util.Objects.isNull;

@Service
public class ComActMessageServiceImpl extends ServiceImpl<ComActMessageDAO, ComActMessageDO>
    implements ComActMessageService {
    @Resource
    private ComActMessageDAO comActMessageDAO;
    @Resource
    private ComActMessageBackDAO comActMessageBackDAO;
    @Resource
    private ComActActSignDAO comActActSignDAO;
    @Resource
    private ComActDAO comActDAO;
    @Resource
    private UserService userService;
    @Resource
    private ComActDpcDAO comActDpcDAO;

    @Override
    public R addMessage(ComActMessageVO comActMessageVO) {
        Long type = comActMessageVO.getType();
        String phone = "";
        String sendtoUserName = "";

        if (type == 1) {
            ComPbServiceTeamVO team = comActMessageDAO.selectComPbServiceTeamById(comActMessageVO.getSendtoUserId());
            if (ObjectUtils.isEmpty(team))
                return R.fail();
            phone = team.getPhone();
            sendtoUserName = team.getName();
        } else if (type == 2) {
            PartyCommitteeVO party = comActMessageDAO.selectPartyCommitteeById(comActMessageVO.getSendtoUserId());
            if (ObjectUtils.isEmpty(party))
                return R.fail();
            phone = party.getPhone();
            sendtoUserName = party.getName();
        } else if (type == 3) {
            ComActDpcVO dpcVO = comActDpcDAO.detailDpc(comActMessageVO.getSendtoUserId());
            if (isNull(dpcVO)) {
                return R.fail();
            }
            phone = dpcVO.getPhone();
            sendtoUserName = dpcVO.getName();
        }
        if (ObjectUtils.isEmpty(phone))
            return R.fail("未找到联系方式");
        comActMessageVO.setPhone(phone);
        comActMessageVO.setSendtoUserName(sendtoUserName);
        ComActMessageDO comActMessageDO = new ComActMessageDO();
        BeanUtils.copyProperties(comActMessageVO, comActMessageDO);
        int insert = comActMessageDAO.insert(comActMessageDO);
        if (insert > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 我发的留言
     */
    @Override
    public R pageMyMessageApplets(ComActMessageVO comActMessageVO) {
        Page page = new Page<>();
        Long pageNum = comActMessageVO.getPageNum();
        Long pageSize = comActMessageVO.getPageSize();
        if (null == pageNum || 0 == pageNum) {
            pageNum = 1l;
        }
        if (null == pageSize || 0 == pageSize) {
            pageSize = 10l;
        }
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        IPage<PageComActMessageVO> iPage = comActMessageDAO.pageMyMessageApplets(page, comActMessageVO);
        List<PageComActMessageVO> records = iPage.getRecords();
        if (!ObjectUtils.isEmpty(records)) {
            records.forEach(comActMessageVO1 -> {
                Long id = comActMessageVO1.getId();
                List<ComActMessageBackVO> list = comActMessageDAO.selectMsgBackList(id);
                comActMessageVO1.setBackList(list);
            });
            iPage.setRecords(records);
        }
        return R.ok(iPage);
    }

    /**
     * 发给我的留言
     */
    @Override
    public R pageSendToMessageApplets(ComActMessageVO comActMessageVO) {
        Page page = new Page<>();
        Long pageNum = comActMessageVO.getPageNum();
        Long pageSize = comActMessageVO.getPageSize();
        if (null == pageNum || 0 == pageNum) {
            pageNum = 1l;
        }
        if (null == pageSize || 0 == pageSize) {
            pageSize = 10l;
        }
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        String phone = comActMessageVO.getPhone();
        if (ObjectUtils.isEmpty(phone)) {
            IPage<PageComActMessageVO> iPage = null;
            return R.ok(iPage);
        }
        IPage<PageComActMessageVO> iPage = comActMessageDAO.pageSendMeMessageApplets(page, comActMessageVO);
        List<PageComActMessageVO> records = iPage.getRecords();
        if (!ObjectUtils.isEmpty(records)) {
            records.forEach(comActMessageVO1 -> {
                Long id = comActMessageVO1.getId();
                List<ComActMessageBackVO> list = comActMessageDAO.selectMsgBackList(id);
                comActMessageVO1.setBackList(list);
            });
            iPage.setRecords(records);
        }
        return R.ok(iPage);
    }

    /**
     * 我的社区留言
     */

    @Override
    public R pageMyCommunityMessageApplets(ComActMessageVO comActMessageVO) {
        Page page = new Page<>();
        Long pageNum = comActMessageVO.getPageNum();
        Long pageSize = comActMessageVO.getPageSize();
        if (null == pageNum || 0 == pageNum) {
            pageNum = 1l;
        }
        if (null == pageSize || 0 == pageSize) {
            pageSize = 10l;
        }
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        IPage<PageComActMessageVO> iPage = comActMessageDAO.pageMyCommunityMessageApplets(page, comActMessageVO);
        List<PageComActMessageVO> records = iPage.getRecords();
        if (!ObjectUtils.isEmpty(records)) {
            records.forEach(comActMessageVO1 -> {
                Long id = comActMessageVO1.getId();
                List<ComActMessageBackVO> list = comActMessageDAO.selectMsgBackList(id);
                if (list != null && list.size() > 0) {
                    list.forEach(vo -> {
                        Long type = comActMessageVO1.getType();
                        if (type == 1) {
                            ComPbServiceTeamVO team =
                                comActMessageDAO.selectComPbServiceTeamById(comActMessageVO1.getSendtoUserId());
                            if (!ObjectUtils.isEmpty(team)) {
                                vo.setUserJob(team.getJob());
                            }
                        } else if (type == 2) {
                            PartyCommitteeVO party =
                                comActMessageDAO.selectPartyCommitteeById(comActMessageVO1.getSendtoUserId());
                            if (!ObjectUtils.isEmpty(party)) {
                                vo.setUserJob(party.getPosition());
                            }
                        }
                    });
                }
                comActMessageVO1.setBackList(list);
            });
            iPage.setRecords(records);
        }
        return R.ok(iPage);
    }

    @Override
    public R addMessageBack(ComActMessageBackVO comActMessageBackVO) {
        ComActMessageBackDO comActMessageBackDO = new ComActMessageBackDO();
        BeanUtils.copyProperties(comActMessageBackVO, comActMessageBackDO);
        int insert = comActMessageBackDAO.insert(comActMessageBackDO);
        if (insert > 0) {
            ComActMessageDO selectById = comActMessageDAO.selectById(comActMessageBackDO.getMsgId());
            selectById.setStatus(2);
            comActMessageDAO.updateById(selectById);

            // 回复成功给用户推送订阅消息
            Map<String, String> map = comActActSignDAO.getUserOpenId(selectById.getUserId());
            if (map != null) {
                String openid = map.get("openid");
                WxXCXTempSend util = new WxXCXTempSend();
                ComActDO comActDO=comActDAO.selectById(comActMessageBackVO.getCommunityId());
                R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),2);
                try {
                    WxUtil.sendSubscribeLYHF(openid, util.getAccessToken(), comActMessageBackVO.getUserName(),
                        DateUtils.format(new Date(), DateUtils.ymdhms_format), comActMessageBackVO.getMsgContent(),r.getData().getTemplateId());
                } catch (Exception e) {
                    log.error("消息推送失败，失败原因：" + e.getMessage());
                }
            }
            return R.ok();
        }
        return R.fail();
    }

    @Override
    public R pageMessageByUserApplets(ComActMessageVO comActMessageVO) {
        Page page = new Page<>();
        Long pageNum = comActMessageVO.getPageNum();
        Long pageSize = comActMessageVO.getPageSize();
        if (null == pageNum || 0 == pageNum) {
            pageNum = 1l;
        }
        if (null == pageSize || 0 == pageSize) {
            pageSize = 10l;
        }
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        IPage<PageComActMessageVO> iPage = comActMessageDAO.pageMessageByUserApplets(page, comActMessageVO);
        List<PageComActMessageVO> records = iPage.getRecords();
        if (!ObjectUtils.isEmpty(records)) {
            records.forEach(comActMessageVO1 -> {
                Long id = comActMessageVO1.getId();
                List<ComActMessageBackVO> list = comActMessageDAO.selectMsgBackList(id);

                comActMessageVO1.setBackList(list);
            });
            iPage.setRecords(records);
        }
        return R.ok(iPage);
    }

    @Override
    public R deleteMessage(ComActMessageVO comActMessageVO) {
        Long id = comActMessageVO.getId();
        comActMessageDAO.deleteById(id);
        comActMessageBackDAO.deleteMsgBackByMsgId(id);
        // List<ComActMessageBackVO> list = comActMessageDAO.selectMsgBackList(id);
        // for (ComActMessageBackVO comActMessageBackVO : list) {
        // comActMessageBackDAO.deleteById(comActMessageBackVO.getId());
        // }
        return R.ok();
    }

    @Override
    public R resetMessagePublic(ResetComActMessageVO resetComActMessageVO) {
        if (ObjectUtils.isEmpty(resetComActMessageVO))
            return R.fail();
        Integer ispublic = resetComActMessageVO.getIspublic();
        if (ispublic == null || (ispublic != 1 && ispublic != 2))
            return R.fail("状态错误");
        List<Long> list = resetComActMessageVO.getIds();
        for (Long id : list) {
            comActMessageDAO.updatePublic(ispublic, id);
        }
        return R.ok();
    }

    @Override
    public R detailMessage(Long id) {
        ComActMessageDO comActMessageDO = comActMessageDAO.selectById(id);
        PageComActMessageVO vo = new PageComActMessageVO();
        BeanUtils.copyProperties(comActMessageDO, vo);
        List<ComActMessageBackVO> list = comActMessageDAO.selectMsgBackList(id);
        vo.setBackList(list);
        // TODO Auto-generated method stub
        return R.ok(vo);
    }

}