package com.javaweb.applicationEvent;


import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.javaweb.common.utils.spring.SpringUtils;
import com.javaweb.framework.util.ShiroUtils;
import com.javaweb.system.domain.EventLog;
import com.javaweb.system.domain.SysUser;
import com.javaweb.system.service.IEventLogService;
import org.apache.commons.collections.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.annotation.PostConstruct;
import java.util.*;

/**
 * 事件管理器
 * Created by zengchao on 2017-03-09.
 */
public class ApplicationEventManager {
    private Logger logger = LoggerFactory.getLogger(this.getClass());

    private Map<ApplicationEventDefined, List<IApplicationEvent>> eventMap = new HashMap<>();//按照系事件分组

    List<IApplicationEvent> applicationEventList;//所有实现系统事件类

    IEventLogService eventLogService;

    public void setApplicationEventList(List<IApplicationEvent> applicationEventList) {
        this.applicationEventList = applicationEventList;
    }

    public void setEventLogService(IEventLogService eventLogService) {
        this.eventLogService = eventLogService;
    }

    /**
     * 绑定事件
     *
     * @param applicationEventDefineds 系统自定义事件数组
     * @param applicationEvent     事件处理程序
     */
    public synchronized void bind(ApplicationEventDefined[] applicationEventDefineds, IApplicationEvent applicationEvent) {
        for(ApplicationEventDefined applicationEventDefined:applicationEventDefineds){
            List<IApplicationEvent> eventList = eventMap.get(applicationEventDefined);
            if (eventList == null) {
                eventList = new ArrayList<>();
            }
            eventList.add(applicationEvent);
            eventMap.put(applicationEventDefined, eventList);

            logger.debug("Bind Event : " + applicationEventDefined.name());
        }

    }

    /**
     * 解绑事件
     *
     * @param applicationEventDefined 事件名称
     * @param applicationEvent     事件处理程序
     */
    public synchronized void unbind(ApplicationEventDefined applicationEventDefined, IApplicationEvent applicationEvent) {
        List<IApplicationEvent> eventList = eventMap.get(applicationEventDefined);
        if (eventList == null) {
            return;
        }
        eventList.remove(applicationEvent);
        logger.debug("UnBind Event : " + applicationEventDefined.name());
    }

    /**
     * 触发事件
     *
     * @param applicationEventDefined 事件名称
     * @param source    来源
     * @param params    参数
     */
    public synchronized void trigger(ApplicationEventDefined applicationEventDefined, Object source, Object params) {
        List<IApplicationEvent> eventList = eventMap.get(applicationEventDefined);
        if (eventList == null) {
            return;
        }
        for (IApplicationEvent event : eventList) {
            try {
                event.onTrigger(source, params);
                saveLog(applicationEventDefined,source,params);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    private void saveLog(ApplicationEventDefined applicationEventDefined, Object source, Object params){
            String clsName="";
            if(source instanceof String){
                clsName=source.toString();
            }else{
                clsName=source.getClass().getTypeName();
            }
            JSONObject jsonObject=JSONObject.parseObject(JSON.toJSONString(params));
            String orgid=(String)jsonObject.get("orgid");
            EventLog log= new EventLog();
            SysUser user= ShiroUtils.getSysUser();
            log.setUserId(user.getUserId().toString());
            log.setUserName(user.getUserName());
            log.setEventCode(applicationEventDefined.getValue());
            log.setEventName(applicationEventDefined.getDescription());
            log.setCreateTime(new Date());
            log.setSource(clsName);
            log.setDatas(JSON.toJSONString(params));
            eventLogService.insertEventLog(log);
    }
    /**
     * 初始化
     * 扫描系统中注解形式的事件
     */
    @PostConstruct
    public void init() {
        if(CollectionUtils.isNotEmpty(applicationEventList)){
            for(IApplicationEvent event:applicationEventList){
                 Class cls =   event.getClass();
                Object instance = null;
                if(!cls.getName().contains("proxy")){
                    instance= SpringUtils.getBean(cls);
                    if (instance instanceof IApplicationEvent) {
                        ApplicationEvent eventAnno =(ApplicationEvent) cls.getAnnotation(ApplicationEvent.class);
                        this.bind(eventAnno.value(), (IApplicationEvent) instance);
                    }
                }
            }
            logger.info("系统事件总计注册数量：" + this.eventMap.size());
            //遍历自定义系统内置事件列出各个事件注册数量
            ApplicationEventDefined[] applicationEventDefineds= ApplicationEventDefined.values();
            for(ApplicationEventDefined applicationEventDefined:applicationEventDefineds){
                List<IApplicationEvent> eventList = eventMap.get(applicationEventDefined);
                if(CollectionUtils.isNotEmpty(eventList)){
                    logger.info("系统事件"+applicationEventDefined.getValue()+"["+applicationEventDefined.getDescription()+"]注册数量：" + eventList.size());
                }else{
                    logger.info("系统事件"+applicationEventDefined.getValue()+"["+applicationEventDefined.getDescription()+"]注册数量：0");
                }
            }

        }
        /*Set<Class<?>> classes = ClassKit.getClassesByAnnotation("com.jrelax", ApplicationEvent.class);
        for (Class<?> cls : classes) {
            Object instance = null;
            Map<String, ?> beanMap = ApplicationContextHelper.getInstance().getBeansOfType(cls);
            if (beanMap.size() == 0) {
                instance = ApplicationContextHelper.getInstance().createBean(cls);
            } else {
                for (Map.Entry<String, ?> map : beanMap.entrySet()) {
                    instance = map.getValue();

                    if (instance != null) break;
                }
            }
            if (instance instanceof IApplicationEvent) {
                ApplicationEvent event = cls.getAnnotation(ApplicationEvent.class);

                this.bind(event.value(), (IApplicationEvent) instance);
            }
        }

        logger.info("系统事件注册数量：" + this.eventMap.size());*/
    }
}