package com.ld.igds.n2.manager;

import com.ld.igds.common.CoreCommonService;
import com.ld.igds.common.CoreSerService;
import com.ld.igds.constant.BizType;
import com.ld.igds.constant.Constant;
import com.ld.igds.io.RemoteCommonService;
import com.ld.igds.io.RemoteManager;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.request.AccessRequest;
import com.ld.igds.io.request.BaseRequest;
import com.ld.igds.io.request.DepotStatusRequest;
import com.ld.igds.io.response.BaseResponse;
import com.ld.igds.models.DepotConf;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.order.ExeOrderService;
import com.ld.igds.order.data.ExeRequest;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class BasicSystemManager {

    @Autowired
    private RemoteManager remoteManager;
    @Autowired
    private CoreSerService coreSerService;
    @Autowired
    private ExeOrderService exeOrderService;
    @Autowired
    private CoreCommonService coreCommonService;

    /**
     * 远程获取设备信息
     *
     * @param companyId
     * @param serId
     * @return
     */
    public String pullDevice(String companyId, String serId) {
        DeviceSer ser = coreSerService.getCacheSer(companyId, serId);

        if (null == ser) {
            return "执行失败，系统中没有获取到当前分机信息。";
        }
        if (Constant.YN_N.equals(ser.getStatus())) {
            return "执行失败，当前分机已经掉线，不支持当前操作。";
        }

        BaseRequest request = new BaseRequest();
        request.setIp(ser.getIp());
        request.setSerName(ser.getName());
        request.setPort(ser.getPort());
        request.setCompanyId(ser.getCompanyId());
        request.setBizType(BizType.SYS.getCode());
        request.setSerId(ser.getId());


        RemoteCommonService remoteCommonService = remoteManager.getRemoteCommonService(ser.getProtocol());

        if (null == remoteCommonService) {
            return "执行失败，系统没有没有匹配到当前分机的实现协议，无法执行。";
        }

        ExeRequest exeRequest = new ExeRequest(request);
        exeRequest.setAddLogTag(true);
        exeRequest.setRepeatTag(true);
        exeRequest.setMsg("执行远程同步设备信息");

        BaseResponse response = remoteCommonService.pullDevice(request);
        if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(response.getCode())) {
            exeOrderService.checkExecute(exeRequest);
            return null;
        }
        return "执行失败，原因：" + response.getMsg();
    }

    /**
     * 平台获取控制柜仓房信息
     *
     * @param companyId
     * @param serId
     * @return
     */
    public String pullDepot(String companyId, String serId) {

        DeviceSer ser = coreSerService.getCacheSer(companyId, serId);

        if (null == ser) {
            return "执行失败，系统中没有获取到当前分机信息。";
        }
        if (Constant.YN_N.equals(ser.getStatus())) {
            return "执行失败，当前分机已经掉线，不支持当前操作。";
        }

        BaseRequest request = new BaseRequest();
        request.setIp(ser.getIp());
        request.setSerName(ser.getName());
        request.setPort(ser.getPort());
        request.setCompanyId(ser.getCompanyId());
        request.setBizType(BizType.SYS.getCode());
        request.setSerId(ser.getId());


        RemoteCommonService remoteCommonService = remoteManager.getRemoteCommonService(ser.getProtocol());

        if (null == remoteCommonService) {
            return "执行失败，系统没有没有匹配到当前分机的实现协议，无法执行。";
        }

        ExeRequest exeRequest = new ExeRequest(request);
        exeRequest.setAddLogTag(true);
        exeRequest.setRepeatTag(true);
        exeRequest.setMsg("执行远程同步仓库信息");

        BaseResponse response = remoteCommonService.pullDepot(request);
        if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(response.getCode())) {
            exeOrderService.checkExecute(exeRequest);
            return null;
        }
        return "执行失败，原因：" + response.getMsg();
    }


    public String pullAccess(String companyId, String serId, String accessCode) {
        DeviceSer ser = coreSerService.getCacheSer(companyId, serId);

        if (null == ser) {
            return "执行失败，系统中没有获取到当前分机信息。";
        }
        if (Constant.YN_N.equals(ser.getStatus())) {
            return "执行失败，当前分机已经掉线，不支持当前操作。";
        }

        AccessRequest request = new AccessRequest();
        request.setIp(ser.getIp());
        request.setSerName(ser.getName());
        request.setPort(ser.getPort());
        request.setCompanyId(ser.getCompanyId());
        request.setBizType(BizType.SYS.getCode());
        request.setSerId(ser.getId());
        request.setAccessCode(accessCode);


        RemoteCommonService remoteCommonService = remoteManager.getRemoteCommonService(ser.getProtocol());

        if (null == remoteCommonService) {
            return "执行失败，系统没有没有匹配到当前分机的实现协议，无法执行。";
        }

        ExeRequest exeRequest = new ExeRequest(request);
        exeRequest.setAddLogTag(true);
        exeRequest.setRepeatTag(true);
        exeRequest.setMsg("执行远程控制柜授权操作");

        BaseResponse response = remoteCommonService.pullAccess(request);
        if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(response.getCode())) {
            exeOrderService.checkExecute(exeRequest);
            return null;
        }
        return "执行失败，原因：" + response.getMsg();
    }

    /**
     * 更新 仓库状态，同时推送仓库状态
     * @return
     */
    public String updateDepotStatus(String companyId,String depotId,String status) {

        coreCommonService.updateDepotStatus(companyId,depotId,status);

        //执行推送
        DepotConf depotConf = coreCommonService.getCacheDepotConf(companyId,depotId);
        if(null == depotConf) return "状态更新成功，未同步远程控制柜！";

        DeviceSer ser = coreSerService.getCacheSer(depotConf.getCompanyId(), depotConf.getGrainSer());

        if (null == ser) {
            return  "状态更新成功，未同步远程控制柜！";
        }
        if (Constant.YN_N.equals(ser.getStatus())) {
            return "状态更新成功，风机不在线，未同步远程控制柜！";
        }

        DepotStatusRequest request = new DepotStatusRequest();
        request.setIp(ser.getIp());
        request.setSerName(ser.getName());
        request.setPort(ser.getPort());
        request.setCompanyId(ser.getCompanyId());
        request.setBizType(BizType.SYS.getCode());
        request.setSerId(ser.getId());
        request.setStatus(status);
        request.setDepotId(depotConf.getDepotId());
        request.setDepotName(depotConf.getDepotName());


        RemoteCommonService remoteCommonService = remoteManager.getRemoteCommonService(ser.getProtocol());

        if (null == remoteCommonService) {
            return "状态更新成功，未同步远程控制柜！";
        }

        ExeRequest exeRequest = new ExeRequest(request);
        exeRequest.setAddLogTag(true);
        exeRequest.setRepeatTag(true);
        exeRequest.setMsg("修改仓库状态，系统自动更新远程仓库状态");

        BaseResponse response = remoteCommonService.pullDepotStatus(request);

        if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(response.getCode())) {
            exeOrderService.checkExecute(exeRequest);
            return null;
        }

        return "状态更新成功，远程推送控制柜失败："+response.getMsg();
    }
}