package com.java110.event.listener.cust;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.common.util.Assert;
import com.java110.common.util.ProtocolUtil;
import com.java110.config.properties.OrderProperties;
import com.java110.event.app.cust.AppDeleteCustEvent;
import com.java110.event.app.AppListener;
import com.java110.event.app.order.Ordered;
import com.java110.feign.user.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 客户信息调度，主要用客户信息作废用，撤单用
 *
 *
 * Created by wuxw on 2017/4/14.
 */
@Component
public class DeleteCustDispatchListener implements AppListener<AppDeleteCustEvent> ,Ordered{

    @Autowired
    IUserService iUserService;

    @Autowired
    OrderProperties orderProperties;

    private final static int order = Ordered.dafultValue+2;
    @Override
    public void soDataService(AppDeleteCustEvent event) {

        //这里写 客户信息处理逻辑

        // AppContext context = event.getContext();

        JSONArray dataCustInfos = event.getData();

        JSONObject custInfoJson = new JSONObject();
        custInfoJson.put("data", dataCustInfos.toJSONString());

        String custInfo = custInfoJson.toJSONString();


        Assert.hasLength(custInfo, "没有需要处理的信息[custInfo=" + custInfo + "]");
        processSynchronous(custInfo);

    }

    @Override
    public JSONObject queryDataInfo(AppDeleteCustEvent event) {
        return null;
    }

    @Override
    public JSONObject queryNeedDeleteDataInfo(AppDeleteCustEvent event) {
        return null;
    }

    /**
     * 同步方式处理
     * @param custInfo
     */
    private void processSynchronous(String custInfo){
        //调用用户服务处理,正常返回 {'RESULT_CODE':'0000','RESULT_MSG':'成功','RESULT_INFO':{}}
        String returnUser = iUserService.soDeleteCustService(custInfo);

        JSONObject returnUserTmp = JSONObject.parseObject(returnUser);

        Assert.notNull(returnUserTmp,"用户服务没有相应，请检查服务是否正常，请求报文："+returnUser);
        //受理不成功
        if(!returnUserTmp.containsKey(ProtocolUtil.RESULT_CODE)
                || !ProtocolUtil.RETURN_MSG_SUCCESS.equals(returnUserTmp.getString(ProtocolUtil.RESULT_CODE))){
            throw new IllegalArgumentException("客户受理失败，失败原因：" + (returnUserTmp.containsKey(ProtocolUtil.RESULT_MSG)
                    ?"未知原因":returnUserTmp.getString(ProtocolUtil.RESULT_MSG)) + "请求报文："+returnUser);
        }
    }

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