package ru.provider.bgbilling.modules.inet.dyn.device;

import java.lang.reflect.Field;

import javax.naming.NamingException;

import org.apache.log4j.Logger;

import ru.bitel.bgbilling.modules.inet.access.Access;
import ru.bitel.bgbilling.modules.inet.access.manage.event.InetDeviceManageEvent;
import ru.bitel.bgbilling.modules.inet.api.common.bean.InetServ;
import ru.bitel.bgbilling.modules.inet.runtime.InetInterfaceMap;
import ru.bitel.bgbilling.modules.inet.runtime.InetServRuntime;
import ru.bitel.bgbilling.server.util.Setup;
import ru.bitel.common.ParameterMap;
import ru.bitel.oss.systems.inventory.resource.common.DeviceManagerMethodType;
import ru.bitel.oss.systems.inventory.resource.common.bean.Device;
import ru.bitel.oss.systems.inventory.resource.common.bean.DeviceType;
import ru.bitel.oss.systems.inventory.resource.server.DeviceManagerMethod;

public class SnmpDeviceManager
   extends ru.bitel.bgbilling.modules.inet.dyn.device.snmp.SnmpDeviceManager
{
   private static final Logger logger = Logger.getLogger( SnmpDeviceManager.class );

   protected Access access;
   protected int moduleId;

   protected ParameterMap deviceConfig;

   @Override
   public Object init( Setup setup, int moduleId, Device<?, ?> device, DeviceType deviceType, ParameterMap deviceConfig )
   {
      super.init( setup, moduleId, device, deviceType, deviceConfig );

      this.moduleId = moduleId;
      this.deviceConfig = deviceConfig;

      try
      {
         // <bean name="access" class="ru.bitel.bgbilling.modules.inet.access.Access" />
         access = (Access)Setup.getEnvironment().lookup( "access" );
      }
      catch( NamingException ex )
      {
         logger.error( ex.getMessage(), ex );
      }

      return null;
   }

   @DeviceManagerMethod(title = "Монитор", types = { DeviceManagerMethodType.DEVICE, DeviceManagerMethodType.ACCOUNT })
   public Object monitor()
   {
      return "browse:" + deviceConfig.get( "monitor.url", "http://zabbix.intranet.provider.ru/latest.php?hostid=$monitorHostId" ).replaceAll( "\\$monitorHostId", deviceConfig.get( "monitor.hostId", "" ) );
   }

   @DeviceManagerMethod(title = "Telnet")
   public Object telnet()
   {
      return "telnet:" + deviceConfig.get( "telnet.host", this.host ) + " " + deviceConfig.getInt( "telnet.port", 23 );
   }

   @DeviceManagerMethod(title = "Информация по интерфейсу", types = { DeviceManagerMethodType.ACCOUNT })
   public Object ifaceInfo( InetDeviceManageEvent e )
      throws Exception
   {
      final int invDeviceId = e.getDeviceId();
      final int servId = getInetServId( e );

      final InetServRuntime servRuntime = access.getInetServRuntimeMap().get( servId );
      final InetServ inetServ = servRuntime.getInetServ();

      final InetInterfaceMap ifaceMap = InetInterfaceMap.getInstance( access.moduleId );

      String ifaceTitle = ifaceMap.getInterfaceTitle( invDeviceId, inetServ.getInterfaceId() );

      return "ifaceId: " + inetServ.getInterfaceId() + ", ifaceTitle: " + ifaceTitle;
   }

   private int getInetServId( final InetDeviceManageEvent e )
      throws Exception
   {
      Field f = InetDeviceManageEvent.class.getDeclaredField( "servId" );
      f.setAccessible( true );
      return f.getInt( e );
   }
}

    @DeviceManagerMethod(title = "TestMAC", types = { DeviceManagerMethodType.DEVICE })
    public String testMac()
            throws Exception
    {
        final StringBuffer report = new StringBuffer();
        OID testOid = new OID("1.3.6.1.2.1.17.4.3.1.1");
        snmpClient.walk(testOid, String.class, new Walker<String>() {
            @Override
            public void walk(OID oid, String value) {
                report.append(value+"\n");
            }
        });

        return report.toString();
    }
   
    @DeviceManagerMethod(title = "TestPORT", types = { DeviceManagerMethodType.DEVICE })
    public String testPort()
            throws Exception
    {
        final StringBuffer report = new StringBuffer();
        OID testOid = new OID("1.3.6.1.2.1.17.4.3.1.2");
        snmpClient.walk(testOid, String.class, new Walker<String>() {
            @Override
            public void walk(OID oid, String value) {
                report.append(value);
            }
        });

        return report.toString();
    }

access 06-25/15:14:12 ERROR [dm-p-13-t-44] Consumer - java.lang.ClassCastException: Cannot cast java.lang.Integer to java.lang.String
ru.bitel.bgbilling.common.BGException: java.lang.ClassCastException: Cannot cast java.lang.Integer to java.lang.String
        at ru.bitel.bgbilling.modules.inet.access.manage.DeviceManageWorker.doTask(DeviceManageWorker.java:228)
        at ru.bitel.bgbilling.kernel.event.EventWorker.notify(EventWorker.java:259)
        at ru.bitel.bgbilling.kernel.event.Consumer.onMessage0(Consumer.java:112)
        at ru.bitel.bgbilling.kernel.event.EventWorker.internalDoTask(EventWorker.java:229)
        at ru.bitel.bgbilling.kernel.event.EventWorker.doTasks(EventWorker.java:208)
        at ru.bitel.bgbilling.modules.inet.access.manage.DeviceManageWorker.runWorker(DeviceManageWorker.java:170)
        at ru.bitel.bgbilling.kernel.event.EventWorker.internalRunWorker(EventWorker.java:139)
        at ru.bitel.bgbilling.modules.inet.access.manage.DeviceManageWorker.runImpl(DeviceManageWorker.java:110)
        at ru.bitel.common.worker.WorkerTask.run(WorkerTask.java:86)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
        at ru.bitel.common.worker.WorkerThread.run(WorkerThread.java:46)
Caused by: java.lang.ClassCastException: Cannot cast java.lang.Integer to java.lang.String
        at java.lang.Class.cast(Class.java:3361)
        at ru.ellcom.modules.inet.snmp.SnmpClient.castVariable(SnmpClient.java:171)
        at ru.ellcom.modules.inet.snmp.SnmpClient.walk(SnmpClient.java:103)
        at ru.ellcom.modules.inet.snmp.SnmpDeviceManager.testPort(SnmpDeviceManager.java:123)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:483)
        at ru.bitel.bgbilling.modules.inet.access.manage.DeviceManageWorker.doCommand(DeviceManageWorker.java:275)
        at ru.bitel.bgbilling.modules.inet.access.manage.DeviceManageWorker.doTask(DeviceManageWorker.java:217)
        ... 16 more

at ru.bitel.bgbilling.modules.inet.access.manage.DeviceManageWorker.doTask(DeviceManageWorker.java:228)

        if(var instanceof Integer32){
            if(clazz == String.class){
                return clazz.cast(var.toString());
            }
            return clazz.cast(var.toInt());
        }

666.666.666.333#sh mac-address-table | inc Ethernet1/1
88   00-0a-cd-28-1e-d1           SECURED PSecure  Ethernet1/1
88   08-00-27-a7-94-1f           SECURED PSecure  Ethernet1/1

Сервер: вер. 6.2.914 / 09.07.2015 21:39:19
    os: Linux; java: Java HotSpot(TM) 64-Bit Server VM, v.1.8.0_31

  inet: вер. 6.2.527 / 09.07.2015 21:39:32

    @DeviceManagerMethod(title = "Test MAC", types = { DeviceManagerMethodType.ACCOUNT })
    public String testMac(InetDeviceManageEvent e)
            throws Exception
    {
        int servId = e.getServId();
        System.out.print("\nservId = " + servId + "\n");
        InetServDao servDao = new InetServDao(this.con, this.mid);
        int interfaceId = servDao.get(servId).getInterfaceId();
        System.out.print("interfaceId = " + interfaceId + "\n");

        return null;
    }

servId = 1
interfaceId = 1

servId = 1
interfaceId = 1

@DeviceManagerMethod(title = "ping", types = { DeviceManagerMethodType.DEVICE, DeviceManagerMethodType.ACCOUNT })
public Object ping()
    throws Exception
{
    return "ping:" + host;
}