package cn.ksource.web.service.message;

import cn.ksource.beans.GG_MESSAGE;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.spring.SpringBeanUtil;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.EmailUtil;
import cn.ksource.core.util.SMSUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.entity.SysMessage;
import cn.ksource.web.Constants;
import cn.ksource.web.service.wechat.WechatService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.context.ContextLoader;
import org.springframework.web.context.request.async.DeferredResult;

import javax.servlet.ServletContext;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;

/**
 * Created by chenlong
 * Date：2017/8/4
 * time：14:29
 */
public class MessageRunable implements Runnable {

    private Logger log = LoggerFactory.getLogger(MessageRunable.class);

    private BaseDao baseDao;

    private GG_MESSAGE message;
    private List<Map> msgs;

    private WechatService wechatService;

    public MessageRunable(GG_MESSAGE message,List<Map> msgs ) {
        this.wechatService = SpringBeanUtil.getBean(WechatService.class);
        this.message = message;
        this.msgs = msgs;
    }

    @Override
    public void run() {
            //系统内消息推送对象
            SysMessage sysMessage = new SysMessage(message.getTitle(),message.getWeb_url());
            List<String> emails = new ArrayList<String>();
            List<String> openIds = new ArrayList<String>();
            List<String> userIds = new ArrayList<String>();
            //手机号码字符串
            String mobile = "";
            System.out.println("msgs--------------------->"+msgs);
            for(Map msg : msgs) {
                String userId = ConvertUtil.obj2StrBlank(msg.get("USER_ID"));
                // 推送系统内消息
                /**
                ServletContext servletContext = ContextLoader.getCurrentWebApplicationContext().getServletContext();
                Map<String,DeferredResult<SysMessage>> messageContext = (Map<String,DeferredResult<SysMessage>>)servletContext.getAttribute("messageContext");
                if (messageContext != null && !messageContext.isEmpty() && messageContext.keySet() != null) {
                    System.out.println("connection size" + messageContext.size());
                    for (String key : messageContext.keySet()) {
                        try {
                            if (key.indexOf(userId) == 0) {//需要发送
                                if (messageContext.get(key) != null) {
                                    if (!messageContext.get(key).isSetOrExpired()) {
                                        messageContext.get(key).setResult(sysMessage);
                                    }
                                }
                            }
                        }catch (Exception e){
                            e.printStackTrace();
                        }
                    }

                }
                **/
                //系统内消息推送完毕

                userIds.add(userId);
                String remindType = ConvertUtil.obj2StrBlank(msg.get("REMIND_TYPE"));
                String isWechat = ConvertUtil.obj2StrBlank(msg.get("ISWECHAT"));
                if(isWechat.equals("2") && ((StringUtil.notEmpty(remindType) && remindType.substring(2, 3).equals("1"))||!StringUtil.notEmpty(remindType))) {
                    openIds.add(ConvertUtil.obj2StrBlank(msg.get("OPEN_ID")));
                }
                if(StringUtil.notEmpty(remindType)) {
                    String isEmail = ConvertUtil.obj2StrBlank(msg.get("ISEMAIL"));
                    if(isEmail.equals("2") && remindType.substring(1, 2).equals("1")) {
                        emails.add(ConvertUtil.obj2StrBlank(msg.get("EMAIL")));
                    }

                    String isPhone = ConvertUtil.obj2StrBlank(msg.get("ISPHONE"));
                    if(isPhone.equals("2") && remindType.substring(0, 1).equals("1")) {
                        //组装手机号码
                        String telphoneNum = ConvertUtil.obj2StrBlank(msg.get("SJHM"));
                        if(StringUtil.isNotBlank(telphoneNum)){
                            if(mobile.equals("")){
                                mobile = mobile + telphoneNum;
                            }else{
                                mobile = mobile + "," + telphoneNum;
                            }
                        }
                    }
                }

            }
            //System.out.print("mobile------------->"+mobile);
            //发送短信
            /**
            try {
                SMSUtil.sendSMS(SMSUtil.getOrderTipMsg(Constants.mapSC_MESSAGE_TYPE.get(String.valueOf(message.getType())),message.getTitle()),mobile);
                System.out.println("------------------------>发送短信异常");
            } catch (Exception e) {
                System.out.println("------------------------>发送短信异常");
            }

            if(emails.size()>0) {
                String[] email = (String[])emails.toArray(new String[emails.size()]);
                try {
                    EmailUtil.sendEmail(email, message.getTitle(), message.getContent(), null);
                    System.out.println("------------------------>发送邮件异常");
                } catch (Exception e) {
                    System.out.println("------------------------>发送邮件异常");
                }
            }
            **/
            if(openIds.size()>0) {
                String[] openId = (String[])openIds.toArray(new String[openIds.size()]);
                try {
                    wechatService.sendSysMsg(openId, message);
                    System.out.println("------------------------>发送微信信息异常");
                } catch (Exception e) {
                    System.out.println("------------------------>发送微信信息异常");
                }
            }

        }

}