package com.ld.igds.protocol.quantity.shuhan.command;

import com.ld.igds.constant.RedisConst;

import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.request.QuantityRequest;
import com.ld.igds.io.response.BaseResponse;
import com.ld.igds.protocol.quantity.shuhan.QueryStatusTask;
import com.ld.igds.protocol.quantity.shuhan.ShuHanUtils;
import com.ld.igds.protocol.snap.SnapPluginService;
import com.ld.igds.quantity.io.RemoteQuantityService;
import com.ld.igds.quantity.service.CoreQuantityService;
import com.ld.igds.util.RedisUtil;
import com.ld.io.api.InvokeResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

/**
 * 蜀汉粮油协议
 *
 * @author vince
 */
@Slf4j
@Component(RemoteQuantityServiceImpl.BEAN_ID)
public class RemoteQuantityServiceImpl extends BaseRemoteImpl implements RemoteQuantityService {

    public static final String BEAN_ID = "shly.remoteQuantityService";
    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private CoreQuantityService coreQuantityService;
    @Autowired
    private SnapPluginService snapService;

    @Override
    public BaseResponse checkStart(QuantityRequest request) {
        try {
            String key = RedisConst.buildKey(request.getCompanyId(), request.getYtIp());

            String msg = CommandBuilder.getCheckMsg(request);
            log.info("发起数量检测采集命令： " + msg);
            InvokeResult result = super.send(request.getIp(), request.getPort(), msg.getBytes(ShuHanUtils.CHARSET));
            // 封装返回信息
            if (InvokeResult.SUCCESS == result) {
                //最长保存一个小时
                redisUtil.set(key, request, 60 * 60);

                //将采集信息放缓存，收到结果后删除

                //启动子任务定时查询进度和结果

                // 创建子任务
                FutureTask<String> futureTask = new FutureTask<>(new QueryStatusTask(redisUtil, this, coreQuantityService, snapService, key, CommandBuilder.getQueryStatusMsg(request)));
                ExecutorService executorService = Executors.newCachedThreadPool();
                executorService.submit(futureTask);
                executorService.shutdown();

                return new BaseResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
                        "数量检测采集命令发送成功");
            } else {
                log.info("分机" + request.getSerName() + "数量检测采集命令发送失败：" + result.getMessage());
                return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), result.getMessage());
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), e.getMessage());
        }
    }

    @Override
    public BaseResponse remoteConf(QuantityRequest request) {
        return new BaseResponse(OrderRespEnum.NO_FUNCTION);
    }

    @Override
    public BaseResponse checkStop(QuantityRequest request) {
        return new BaseResponse(OrderRespEnum.NO_FUNCTION);
    }

    @Override
    public BaseResponse snapImg(QuantityRequest request) {
        return new BaseResponse(OrderRespEnum.NO_FUNCTION);
    }

    @Override
    public BaseResponse closeWarn(QuantityRequest request) {
        return new BaseResponse(OrderRespEnum.NO_FUNCTION);
    }

    @Override
    public BaseResponse ptz(QuantityRequest Request) {
        return new BaseResponse(OrderRespEnum.NO_FUNCTION);
    }
}