package com.xzx.gc.system.service;

import cn.hutool.core.codec.Base64;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.constant.SysEnum;
import com.xzx.gc.common.utils.DateUtils;
import com.xzx.gc.common.utils.ExceptionUtils;
import com.xzx.gc.common.utils.RedisUtil;
import com.xzx.gc.common.utils.StringUtils;
import com.xzx.gc.entity.CityPartner;
import com.xzx.gc.entity.SysNotice;
import com.xzx.gc.model.admin.SysNoticeModel;
import com.xzx.gc.model.system.SysNoticeReq;
import com.xzx.gc.model.system.SysNoticeVo;
import com.xzx.gc.system.mapper.SysNoticeMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
@Transactional
public class SysNoticeService {
    @Autowired
    private SysNoticeMapper sysNoticeMapper;
    @Autowired
    private CityPartnerService cityPartnerService;

    @Autowired
    private RedisUtil redisUtil;

    public PageInfo<SysNoticeModel> queryNoticeList(SysNoticeModel model) {

        if(null!=model.getStartTime()&&!"".equals(model.getStartTime())){
            model.setStartTime(model.getStartTime()+" 00:00:00");
        }
        if(null!=model.getEndTime()&&!"".equals(model.getEndTime())){
            model.setEndTime(model.getEndTime()+" 23:59:59");
        }
        PageHelper.startPage(model.getPage(),model.getLimit());
        List<SysNoticeModel> list = sysNoticeMapper.queryNoticeList(model);
        for (SysNoticeModel resModel:list) {
            String nickName = resModel.getNickName();
            if(nickName!=null&&!"".equals(nickName)){
                nickName = cn.hutool.core.codec.Base64.decodeStr(nickName);
            }
            if(null!=resModel.getContent()&&!"".equals(resModel.getContent())){
                if(StringUtils.isBase64(resModel.getContent())){
                    resModel.setContent(Base64.decodeStr(resModel.getContent()));
                }
            }
            resModel.setNickName(nickName);
            String upid = resModel.getPartnerId();
            StringBuffer partnerName=new StringBuffer();
            if(null!=upid&&!"".equals(upid)){
                String[] pIds = upid.split(",");
                for (String pid:pIds) {
                    CityPartner cityPartner = cityPartnerService.queryById(Long.parseLong(pid));
                    partnerName.append(cityPartner.getPartnerName()).append(",");
                }
                String ax = partnerName.toString();
                if(null!=ax&&!"".equals(ax)){
                    ax = ax.substring(0,ax.length()-1);
                    resModel.setPartnerName(ax);

                }else{
                    resModel.setPartnerName("-");
                }
            }else{
                resModel.setPartnerName("-");
            }
        }
        PageInfo<SysNoticeModel> pageInfo=new PageInfo<>(list);
        return pageInfo;
    }
    public List<SysNoticeVo> getSysNoticeByType(SysNoticeReq sysNoticeReq) {
        List<SysNoticeVo> noticeList = null;
        Map<String,Object> params = new HashMap<>(16);
        params.put("noticeType",sysNoticeReq.getNoticeType());
        noticeList = sysNoticeMapper.getSysNoticeByType(params);
        if(CollUtil.isNotEmpty(noticeList)){
            for (SysNoticeVo sysNoticeVo : noticeList) {
                String s = StringUtils.intChange2Str(Convert.toInt(sysNoticeVo.getReadNum()));
                sysNoticeVo.setReadNum(s);
            }
        }
        return noticeList;
    }

    
    public SysNoticeVo getSysNoticeById(SysNoticeReq sysNoticeReq) {
        Map<String,Object> params = new HashMap<>(16);
        params.put("noticeId",sysNoticeReq.getNoticeId());
        SysNoticeVo sysNoticeById = sysNoticeMapper.getSysNoticeById(params);
        int num=Convert.toInt(sysNoticeById.getReadNum());
        SysNotice sysNotice=new SysNotice();
        sysNotice.setNoticeId(sysNoticeById.getNoticeId());
        sysNotice.setReadNum(++num);
        sysNoticeMapper.updateByPrimaryKeySelective(sysNotice);
        return sysNoticeById;
    }

    
    public int addSysNotice(SysNoticeReq sysNoticeReq) {
        try {
            if(SysEnum.反馈建议.getValue().equals(sysNoticeReq.getNoticeType())){
                sysNoticeReq.setContent(Base64.encode(sysNoticeReq.getContent()));
            }
//            Map<String,Object> params = new HashMap<>(16);
//            params.put("title",sysNoticeReq.getTitle());
//            params.put("content",sysNoticeReq.getContent());
//            sysNoticeReq.setCreateTime(DateUtils.getCurDateTime());
//            params.put("createTime",sysNoticeReq.getCreateTime());
//            params.put("createUserId",sysNoticeReq.getCreateUserId());
//            params.put("picture",sysNoticeReq.getPicture());
//            params.put("noticeType",sysNoticeReq.getNoticeType());
//            params.put("complaintType",sysNoticeReq.getComplaintType());
            sysNoticeReq.setCreateTime(DateUtils.getCurDateTime());
            sysNoticeMapper.addSysNotice(sysNoticeReq);
        } catch (Exception e) {
            ExceptionUtils.err("新增公告失败",e);
        }
        return 0;
    }


}