package com.ld.igds.wms.controller;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.wms.constant.WmsCodeEnum;
import com.ld.igds.wms.data.WmsRequest;
import com.ld.igds.wms.data.WmsResponse;
import com.ld.igds.wms.manager.WmsManager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 武汉黄陂军粮-立体库接口
 *
 * @author czt
 */
@Slf4j
@RestController
@RequestMapping("api/wms/v1")
public class WmsController {

    @Autowired
    private WmsManager wmsManager;

    /**
     * 业务入口
     * @param request
     * @return
     */
    @ResponseBody
    @RequestMapping("/gateway")
    public WmsResponse gateway(@RequestBody WmsRequest<JSONObject> request) {

        log.info("-----立体库-----收到的消息={}-----", request);

        //判断参数
        if (null == request) {
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1002.getCode(), WmsCodeEnum.WMS_CODE_1002.getMsg());
        }

        //判断接口编码
        if (null == request.getInterfaceId()) {
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1002.getCode(), WmsCodeEnum.WMS_CODE_1002.getMsg());
        }

        //判断数据
        if (null == request.getData()) {
            return new WmsResponse(WmsCodeEnum.WMS_CODE_1002.getCode(), WmsCodeEnum.WMS_CODE_1002.getMsg());
        }

        WmsResponse result;
        try{
            //异步处理，子线程解析事件
            final ExecutorService exec = Executors.newFixedThreadPool(1);
            Callable<String> call = new Callable<String>() {
                public String call() throws Exception {

                    //执行业务操作
                    WmsResponse wmsResponse =  wmsManager.execute(request);
                    return wmsResponse.getMsg();
                }
            };
            exec.submit(call);
            exec.shutdown();
            result = new WmsResponse(WmsCodeEnum.WMS_CODE_0000.getCode(), WmsCodeEnum.WMS_CODE_0000.getMsg());

        }catch (Exception e){

            log.error("----立体库信息解析异常={}-----", e.getLocalizedMessage());

            //后端异常
            result = new WmsResponse(WmsCodeEnum.WMS_CODE_1111.getCode(), WmsCodeEnum.WMS_CODE_1111.getMsg());
        }
        return result;
    }
}