package com.java110.order.listener;

import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.IOrderDataFlowContext;
import com.java110.event.app.order.Ordered;
import com.java110.event.center.event.InvokeBusinessSystemEvent;
import com.java110.event.center.listener.DataFlowListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 用户ID处理 侦听
 * Created by wuxw on 2018/7/2.
 */
//@Component
@Java110Listener(name="dealUserIdListener")
public class DealUserIdListener implements DataFlowListener<InvokeBusinessSystemEvent>,Ordered {

    private final static Logger logger = LoggerFactory.getLogger(DealUserIdListener.class);

    @Override
    public void soService(InvokeBusinessSystemEvent event) {
       IOrderDataFlowContext dataFlow = event.getDataFlow();
       if (dataFlow == null || dataFlow.getBusinessList() == null || dataFlow.getBusinessList().size() == 0){
           throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"用户ID处理侦听执行异常，没有可处理的business");
       }

       //判断是否存在 "serviceCode": "save.user.info", 业务，如果存在则处理
    }

    @Override
    public int getOrder() {
        return 1;
    }
}