package com.netsdk.module;

import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.enumeration.*;
import com.netsdk.lib.structure.NET_CFG_BGY_CUSTOMERCFG;
import com.netsdk.lib.structure.NET_CFG_FORBIDDEN_ADVERT_PLAY;
import com.netsdk.lib.structure.NET_CFG_HEALTH_CODE_INFO;
import com.netsdk.module.entity.ForbiddenAdvertPlayInfoConfig;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;
import java.util.List;

/**
 * @author 47081
 * @version 1.0
 * @description 设备配置的获取与设置二次封装
 * @date 2020/9/14
 */
public class ConfigModule extends BaseModule {
  private final NetSDKLib configApi;

  public ConfigModule(NetSDKLib netSdkApi) {
    super(netSdkApi);
    this.configApi = NetSDKLib.CONFIG_INSTANCE;
  }

  public ConfigModule(NetSDKLib netSDKApi, NetSDKLib configApi) {
    super(netSDKApi);
    this.configApi = configApi;
  }

  public ConfigModule() {
    this(NetSDKLib.NETSDK_INSTANCE, NetSDKLib.CONFIG_INSTANCE);
  }

  public NetSDKLib getConfigApi() {
    return configApi;
  }

  /**
   * 全屏广告模式配置
   *
   * @return
   */
  public boolean bgyCustomerCfg(long loginHandler, NET_CFG_BGY_CUSTOMERCFG config) {
    Pointer pointer = new Memory(config.size());
    ToolKits.SetStructDataToPointer(config, pointer, 0);
    return getNetsdkApi()
        .CLIENT_SetConfig(
            new NetSDKLib.LLong(loginHandler),
            NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_BGY_CUSTOMERCFG,
            -1,
            pointer,
            config.size(),
            5000,
            new IntByReference(0),
            null);
  }

  /**
   * 获取全屏广告配置
   *
   * @param loginHandler
   * @return
   */
  public NET_CFG_BGY_CUSTOMERCFG getBgyCustomerCfg(long loginHandler) {
    NET_CFG_BGY_CUSTOMERCFG config = new NET_CFG_BGY_CUSTOMERCFG();
    Pointer pointer = new Memory(config.size());
    ToolKits.SetStructDataToPointer(config, pointer, 0);
    boolean result =
        getNetsdkApi()
            .CLIENT_GetConfig(
                new NetSDKLib.LLong(loginHandler),
                NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_BGY_CUSTOMERCFG,
                -1,
                pointer,
                config.size(),
                5000,
                null);
    if (!result) {
      System.out.println("获取全屏广告配置失败." + ENUMERROR.getErrorMessage());
      return null;
    }
    ToolKits.GetPointerData(pointer, config);
    return config;
  }

  /**
   * 配置广告禁播时间段
   *
   * @return
   */
  public boolean forbiddenAdvertPlayConfig(
      long loginHandler, List<ForbiddenAdvertPlayInfoConfig> configs) {
    NET_CFG_FORBIDDEN_ADVERT_PLAY config = new NET_CFG_FORBIDDEN_ADVERT_PLAY();
    if (configs.size() > config.stuAdvertInfo.length) {
      System.out.println("超出最大时间段设置");
      return false;
    }
    config.nAdvertNum = configs.size();
    ForbiddenAdvertPlayInfoConfig fb;
    for (int i = 0; i < configs.size(); i++) {
      fb = configs.get(i);
      config.stuAdvertInfo[i].bEnable = fb.isbEnable();
      config.stuAdvertInfo[i].stuBeginTime = fb.stuBeginTime;
      config.stuAdvertInfo[i].stuEndTime = fb.stuEndTime;
    }
    Pointer pointer = new Memory(config.size());
    ToolKits.SetStructDataToPointer(config, pointer, 0);
    return getNetsdkApi()
        .CLIENT_SetConfig(
            new NetSDKLib.LLong(loginHandler),
            NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_FORBIDDEN_ADVERT_PLAY,
            -1,
            pointer,
            config.size(),
            5000,
            new IntByReference(0),
            null);
  }

  /**
   * 配置健康码
   *
   * @return
   */
  public boolean healthCodeConfig(long loginHandler, NET_CFG_HEALTH_CODE_INFO config) {
    Pointer pointer = new Memory(config.size());
    ToolKits.SetStructDataToPointer(config, pointer, 0);
    return getNetsdkApi()
        .CLIENT_SetConfig(
            new NetSDKLib.LLong(loginHandler),
            NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_HEALTH_CODE,
            -1,
            pointer,
            config.size(),
            5000,
            new IntByReference(0),
            null);
  }

  /**
   * 下发配置
   *
   * @param loginHandler 登录句柄
   * @param emType 配置类型 枚举值参考{@link NET_EM_CFG_OPERATE_TYPE}
   * @param config 配置信息
   * @param channel 通道号
   * @param waitTime 超时时间
   * @return
   */
  public boolean setConfig(
      long loginHandler, int emType, NetSDKLib.SdkStructure config, int channel, int waitTime) {
    Pointer pointer = new Memory(config.size());
    ToolKits.SetStructDataToPointer(config, pointer, 0);
    boolean result =
        getNetsdkApi()
            .CLIENT_SetConfig(
                new NetSDKLib.LLong(loginHandler),
                emType,
                channel,
                pointer,
                config.size(),
                waitTime,
                new IntByReference(0),
                null);
    if (!result) {
      System.out.println("set config emType failed.error is " + ENUMERROR.getErrorMessage());
    }
    return result;
  }

  /**
   * @param loginHandler 登录句柄
   * @param emType 配置类型 枚举值参考{@link NET_EM_CFG_OPERATE_TYPE}
   * @param config 配置信息
   * @param channel 通道号
   * @return 下发配置是否成功
   */
  public boolean setConfig(
      long loginHandler, int emType, NetSDKLib.SdkStructure config, int channel) {
    return setConfig(loginHandler, emType, config, channel, 5000);
  }

  /**
   * 获取配置
   *
   * @param loginHandler 登录句柄
   * @param emType 配置类型 枚举值参考{@link NET_EM_CFG_OPERATE_TYPE}
   * @param config 配置信息
   * @param channel 通道号
   */
  public NetSDKLib.SdkStructure getConfig(
      long loginHandler, int emType, NetSDKLib.SdkStructure config, int channel, int waitTime) {
    config.write(); // 数据写入 native 内存
    if (!getNetsdkApi().CLIENT_GetConfig(
            new NetSDKLib.LLong(loginHandler),  // 登录句柄
            emType,                             // 配置枚举类型
            channel,                            // 通道号
            config.getPointer(),                // config 的指针
            config.size(),                      // Pointer 大小
            waitTime,
            null
    )) {
      System.out.println("get config failed emType:" + emType + "," + ENUMERROR.getErrorMessage());
      return null;
    }
    config.read(); // 从 native 内存读回数据
    return config;
  }

  /**
   * 获取配置
   *
   * @param loginHandler 登录句柄
   * @param emType 配置类型,枚举值参考{@link NET_EM_CFG_OPERATE_TYPE}
   * @param config 配置信息
   * @param channel 通道号
   * @return
   */
  public NetSDKLib.SdkStructure getConfig(
      long loginHandler, int emType, NetSDKLib.SdkStructure config, int channel) {
    return getConfig(loginHandler, emType, config, channel, 5000);
  }

  public NetSDKLib.SdkStructure[] getConfigs(
      long loginHandler, int emType, NetSDKLib.SdkStructure[] configs) {
    Pointer pointer = new Memory(configs[0].size() * configs.length);
    ToolKits.SetStructArrToPointerData(configs, pointer);
    if (!getNetsdkApi()
        .CLIENT_GetConfig(
            new NetSDKLib.LLong(loginHandler),
            emType,
            -1,
            pointer,
            configs[0].size() * configs.length,
            5000,
            null)) {
      System.out.println("get config failed emType:" + emType + "," + ENUMERROR.getErrorMessage());
      return null;
    }
    ToolKits.GetPointerDataToStructArr(pointer, configs);
    return configs;
  }

  /**
   * 查询系统能力信息,对应接口 {@link NetSDKLib#CLIENT_QueryNewSystemInfo(NetSDKLib.LLong, String, int, byte[],
   * int, IntByReference, int)}
   *
   * @param loginHandler
   * @return
   */
  public NetSDKLib.SdkStructure queryConfig(
      long loginHandler,
      EM_NEW_QUERY_SYSTEM_INFO query,
      NetSDKLib.SdkStructure structure,
      int channelId,
      int waitTime) {
    byte[] data = new byte[structure.size()];
    IntByReference error = new IntByReference(0);
    boolean result =
        getNetsdkApi()
            .CLIENT_QueryNewSystemInfo(
                new NetSDKLib.LLong(loginHandler),
                query.getValue(),
                channelId,
                data,
                data.length,
                error,
                waitTime);
    if (!result) {
      System.out.println("query system info failed.error is" + ENUMERROR.getErrorMessage());
      return null;
    }
    // 解析能力信息
    structure.write();
    result =
        configApi.CLIENT_ParseData(
            query.getValue(), data, structure.getPointer(), structure.size(), null);
    if (!result) {
      System.out.println("parse system info failed.error is " + ENUMERROR.getErrorMessage());
      return null;
    }
    structure.read();
    return structure;
  }

  /**
   * 获取设备配置
   *
   * @param loginHandler 登录句柄
   * @param get 配置命令
   * @param structure 配置信息
   * @param channelId 通道号
   * @param waitTime 超时时间
   * @return
   */
  public NetSDKLib.SdkStructure getNewConfig(
      long loginHandler,
      EM_NEW_CONFIG get,
      NetSDKLib.SdkStructure structure,
      int channelId,
      int waitTime) {
    byte[] data = new byte[structure.size() * 8];
    IntByReference error = new IntByReference(0);
    boolean result =
        getNetsdkApi()
            .CLIENT_GetNewDevConfig(
                new NetSDKLib.LLong(loginHandler),
                get.getValue(),
                channelId,
                data,
                data.length,
                error,
                waitTime,null);
    if (!result) {
      System.out.println("query system info failed.error is" + ENUMERROR.getErrorMessage());
      return null;
    }
    // 解析能力信息
    result =
        configApi.CLIENT_ParseData(
            get.getValue(), data, structure.getPointer(), structure.size(), null);
    if (!result) {
      System.out.println("parse system info failed.error is " + ENUMERROR.getErrorMessage());
      return null;
    }
    structure.read();
    return structure;
  }

  public NetSDKLib.SdkStructure getDevCaps(
      long loginHandler,
      GetDevCaps_Type cap,
      NetSDKLib.SdkStructure inParam,
      NetSDKLib.SdkStructure outParam,
      int waitTime) {
    inParam.write();
    outParam.write();
    if (getNetsdkApi()
        .CLIENT_GetDevCaps(
            new NetSDKLib.LLong(loginHandler),
            cap.getType(),
            inParam.getPointer(),
            outParam.getPointer(),
            waitTime)) {
      outParam.read();
      return outParam;
    } else {
      System.out.println("GetDevCaps failed." + ENUMERROR.getErrorMessage());
      return null;
    }
  }
  /**
   * 下发设备配置
   *
   * @param loginHandler 登录句柄
   * @param set 配置命令
   * @param structure 下发的配置
   * @param channelId 通道号
   * @param waitTime 超时时间
   * @return
   */
  public boolean setNewConfig(
      long loginHandler,
      EM_NEW_CONFIG set,
      NetSDKLib.SdkStructure structure,
      int channelId,
      int waitTime) {
    byte[] data = new byte[structure.size() * 8];
    structure.write();
    boolean result =
        configApi.CLIENT_PacketData(
            set.getValue(), structure.getPointer(), structure.size(), data, data.length);
    if (!result) {
      System.out.println("packet data failed.error is " + ENUMERROR.getErrorMessage());
      return false;
    }
    IntByReference error = new IntByReference(0);
    IntByReference restart = new IntByReference(0);
    result =
        getNetsdkApi()
            .CLIENT_SetNewDevConfig(
                new NetSDKLib.LLong(loginHandler),
                set.getValue(),
                channelId,
                data,
                data.length,
                error,
                restart,
                waitTime);
    if (!result) {
      System.out.println("set NewDevConfig failed. error is " + ENUMERROR.getErrorMessage());
      return false;
    }
    return true;
  }
}