package com.matrix.system.hiveErp.action;

import com.matrix.core.anotations.RemoveRequestToken;
import com.matrix.core.anotations.SaveRequestToken;
import com.matrix.core.constance.MatrixConstance;
import com.matrix.core.constance.SystemErrorCode;
import com.matrix.core.constance.SystemMessageCode;
import com.matrix.core.exception.GlobleException;
import com.matrix.core.pojo.AjaxResult;
import com.matrix.core.pojo.PaginationVO;
import com.matrix.core.tools.*;
import com.matrix.system.common.bean.SysUsers;
import com.matrix.system.hive.bean.SysSmsSendRecord;
import com.matrix.system.hive.bean.SysSmsShop;
import com.matrix.system.hive.bean.SysSmsTemplate;
import com.matrix.system.hive.dao.SysSmsSendRecordDao;
import com.matrix.system.hive.dao.SysSmsShopDao;
import com.matrix.system.hive.dao.SysSmsTemplateDao;
import com.matrix.system.hive.dao.SysVipInfoDao;
import com.matrix.system.hive.plugin.util.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * @author wzy
 * @description 短信模板表
 * @date 2020-03-15 18:42
 */
@Controller
@RequestMapping(value = "admin/smsSendRecord")
public class SysSmsSendRecordAction {

    @Autowired
    private SysSmsSendRecordDao sysSmsSendRecordDao;

    @Autowired
    private SysVipInfoDao vipInfoDao;

    @Autowired
    private SysSmsTemplateDao sysSmsTemplateDao;

    @Autowired
    private SysSmsShopDao sysSmsShopDao;

    @Autowired
    private SmsUtils smsUtils;

    //记录编辑前的值Before_Edit_Value
    public static final String BEV = "SysSmsTemplate_BEV";


    /**
     * 列表显示
     */
    @RequestMapping(value = "/showList")
    public @ResponseBody
    AjaxResult showList(SysSmsSendRecord sysSmsSendRecord, PaginationVO pageVo) {
        if (pageVo == null) {
            pageVo = new PaginationVO();
        }

        SysUsers loginUser = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
        sysSmsSendRecord.setCompanyId(loginUser.getCompanyId());
        List<SysSmsSendRecord> dataList = sysSmsSendRecordDao.selectInPage(sysSmsSendRecord, pageVo);
        AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList,
                sysSmsSendRecordDao.selectTotalRecord(sysSmsSendRecord));
        return result;
    }

    /**
     * 新增
     */
    @RemoveRequestToken
    @RequestMapping(value = "/add")
    public @ResponseBody
    AjaxResult addSysSmsTemplate(SysSmsSendRecord sysSmsTemplate) {
        return sendSms(sysSmsTemplate);
    }

    private AjaxResult sendSms(SysSmsSendRecord sysSmsTemplate) {
        SysUsers loginUser = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
        SysSmsTemplate smsTemplate = sysSmsTemplateDao.selectById(sysSmsTemplate.getStId());

        sysSmsTemplate.setCompanyId(loginUser.getCompanyId());
        if (SysSmsSendRecord.IS_ALL_N.equals(sysSmsTemplate.getSsrIsAll())) {
            if (StringUtils.isNotBlank(sysSmsTemplate.getSsrObject())) {
                List<String> ids = StringUtils.strToColl(sysSmsTemplate.getSsrObject(), ",");
                List<String> phones = vipInfoDao.selectVipTelphoneByIds(ids);
                sysSmsTemplate.setSsrCnt(phones.size());
                String result = smsUtils.sendBatchSms(StringUtils.collToStr(phones, ","), smsTemplate.getStCode());
                sysSmsSendRecordDao.insert(sysSmsTemplate);
                // 店铺发送短信则分配数量-1
                reduceShopSmsCnt(sysSmsTemplate);
                if ("OK".equals(result)) {
                    return AjaxResult.buildSuccessInstance("发送成功");
                }
            }
        } else {
            List<String> phones = new ArrayList<>();
            if (sysSmsTemplate.getShopId() != null) {
                phones.addAll(vipInfoDao.selectVipPhoneWithShop(sysSmsTemplate.getShopId()));
            } else {
                phones.addAll(vipInfoDao.selectAllVipPhone(loginUser.getCompanyId()));
            }
            if (CollectionUtils.isNotEmpty(phones)) {
                sysSmsTemplate.setSsrCnt(phones.size());
                if (phones.size() > 1000) {
                    int cnt = phones.size() % 1000;
                    LogUtil.info("#列表模取值：{}, {}", cnt, phones.size());

                    int fromIndex = 0;
                    int endIndex = 0;
                    for (int i = 0; i < cnt; i++) {
                        fromIndex += endIndex;
                        endIndex += 1000;

                        if (endIndex > phones.size()) {
                            endIndex = phones.size();
                        }

                        List<String> toPhones = phones.subList(fromIndex, endIndex);

                        LogUtil.info("----->{}", toPhones.size());
                        smsUtils.sendBatchSms(StringUtils.collToStr(toPhones, ","), smsTemplate.getStCode());
                    }

                    sysSmsSendRecordDao.insert(sysSmsTemplate);
                    // 店铺发送短信则分配数量-1
                    reduceShopSmsCnt(sysSmsTemplate);
                } else {
                    String result = smsUtils.sendBatchSms(StringUtils.collToStr(phones, ","), smsTemplate.getStCode());
                    sysSmsSendRecordDao.insert(sysSmsTemplate);
                    // 店铺发送短信则分配数量-1
                    reduceShopSmsCnt(sysSmsTemplate);
                    if ("OK".equals(result)) {
                        return AjaxResult.buildSuccessInstance("发送成功");
                    }
                }
            }

        }


        return AjaxResult.buildFailInstance("发送失败");
    }

    private void reduceShopSmsCnt(SysSmsSendRecord sysSmsSendRecord) {
        if (sysSmsSendRecord.getShopId() != null) {
            SysSmsShop hasExist = sysSmsShopDao.selectByShopId(sysSmsSendRecord.getShopId());
            hasExist.setRemainingCnt(hasExist.getRemainingCnt() - 1);
            sysSmsShopDao.updateByModel(hasExist);
        }
    }


    /**
     * 修改
     */
    @RemoveRequestToken
    @RequestMapping(value = "/modify")
    public @ResponseBody
    AjaxResult modifySysSmsTemplate(SysSmsTemplate newSysSmsTemplate) {
        return null;
    }


    /**
     * 进入修改界面
     */
    @SaveRequestToken
    @RequestMapping(value = "/editForm")
    public ModelAndView editForm(Long id) {
        SysSmsSendRecord sysSmsSendRecord = new SysSmsSendRecord();
        ModelAndView modelAndView = new ModelAndView("admin/hive-erp/sms/sysSmsSendRecord-form");
        if (id != null) {
            sysSmsSendRecord = sysSmsSendRecordDao.selectById(id);
            WebUtil.setSessionAttribute(BEV, sysSmsSendRecord);
        }
        modelAndView.addObject("obj", sysSmsSendRecord);
        return modelAndView;
    }


    /**
     * 删除
     */
    @RequestMapping(value = "/del")
    public @ResponseBody
    AjaxResult del(String keys) {
        return null;
    }


    @RequestMapping(value = "/addWithShop")
    @ResponseBody
    public AjaxResult addWithShop(SysSmsSendRecord sysSmsSendRecord) {
        SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
        sysSmsSendRecord.setShopId(users.getShopId());

        SysSmsShop hasExist = sysSmsShopDao.selectByShopId(sysSmsSendRecord.getShopId());
        if (hasExist == null || hasExist.getRemainingCnt() <= 0) {
            return new AjaxResult(AjaxResult.STATUS_FAIL, "没有短信剩余");
        }
        return sendSms(sysSmsSendRecord);
    }

    @SaveRequestToken
    @RequestMapping(value = "/editFormWithShop")
    public ModelAndView editFormWithShop(Long id) {
        SysSmsSendRecord sysSmsSendRecord = new SysSmsSendRecord();
        ModelAndView modelAndView = new ModelAndView("admin/hive/sms/sysSmsSendRecord-form");
        if (id != null) {
            sysSmsSendRecord = sysSmsSendRecordDao.selectById(id);
            WebUtil.setSessionAttribute(BEV, sysSmsSendRecord);
        }
        modelAndView.addObject("obj", sysSmsSendRecord);
        return modelAndView;
    }

    @RequestMapping(value = "/showListWithShop")
    public @ResponseBody
    AjaxResult showListWithShop(SysSmsSendRecord sysSmsSendRecord, PaginationVO pageVo) {
        if (pageVo == null) {
            pageVo = new PaginationVO();
        }
        SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
        sysSmsSendRecord.setShopId(users.getShopId());
        List<SysSmsSendRecord> dataList = sysSmsSendRecordDao.selectInPage(sysSmsSendRecord, pageVo);
        AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList,
                sysSmsSendRecordDao.selectTotalRecord(sysSmsSendRecord));
        return result;
    }

}