obix协议在java中的配置和使用详解

public class ObixFetcher implements JobInterface{  //这个是接口的抽象方法 public void cycleOnce() {  //从数据库中取出项目信息  List<Project> ps = dao.selectByExample(new ProjectExample());  //遍历项目信息，如果项目信息的关键信息不为null  for(Project p : ps){   if(p.getObixBaseAddress() != null && p.getObixUsername() != null      && p.getObixPassword() != null){    //开启探索工具 （应该还是一个内部类），将关键项目信息传入探索工具，    DiscoverEngine de = new DiscoverEngine(p.getObixBaseAddress(),      p.getObixUsername(), p.getObixPassword());    //从build数据库中将数据取出，存入bulidNameToId（同样还是构造方法）    //从device数据库中将数据取出，存入deviceNumberToId（同样还是构造方法）    de.setNewValueInterface(new NewValueInterfaceImpl(p.getId(), deviceService, deviceDao, deviceTypeDao, buildDao));    //return回来一个FactorInfo    de.setFactorNameDecoderInterface(new FactorNameDecoderObixUrlImpl());    de.run();   }  } }}

public class DiscoverEngine {  public DiscoverEngine(String baseUrl, String username, String password){    this.baseUrl = baseUrl;    obixClient = new ObixClient(baseUrl, username, password);  }}

public class ObixClient {  public ObixClient(String baseUrl, String userName, String password){        this.baseUrl = baseUrl;    this.userName = userName;    this.password = password;        init();  }  //uri中存放着路由地址，然后传给session，session会在后面用到  private void init() {    Uri uri = new Uri(baseUrl);     session = new ObixSession (uri, userName, password);  }}

public class NewValueInterfaceImpl implements NewValueInterface{  HashMap<String, Integer> buildNameToId = new HashMap<String, Integer>();  HashMap<String, Integer> deviceNumberToId = new HashMap<String, Integer>();  public NewValueInterfaceImpl(Integer projectId, IDeviceManagementService deviceService, DeviceMapper deviceDao, DeviceTypeMapper deviceTypeDao,BuildMapper buildDao) {    this.deviceDao = deviceDao;    this.deviceTypeDao = deviceTypeDao;    this.buildDao = buildDao;    this.projectId = projectId;    this.deviceService = deviceService;    //遍历数据库中的建筑，存入map    List<Build> bs = buildDao.selectByExample(new BuildExample());    for(Build b : bs){      buildNameToId.put(b.getName(), b.getId());    }    //遍历数据库中的设备，存入map    List<Device> ds = deviceDao.selectByExample(new DeviceExample());    for(Device d : ds){      deviceNumberToId.put(d.getNumber(), d.getId());    }  }}

public class DiscoverEngine {  //此处一直用内部类来实现，上面定义了一个匿名内部类，此处给匿名内部类赋值  public void setNewValueInterface(NewValueInterface inft){    newValueInterface = inft;  }  //同上  public void setFactorNameDecoderInterface(FactorNameDecoderInterface inft){    factorNameDecoderInterface = inft;  }}

public class DiscoverEngine {  //首先传进来url地址  public void run(){    readUrl(baseUrl);  }    public void readUrl(String url){//    System.out.println("processing url " + url);    //此处用到session方法    Obj obj = obixClient.read(url);    if(obj == null){      return;    }    //新建一个Obj，用于储存 out 所对应的 value    Obj outObj = obj.get("out");//此处的out是储存的值（理解成标签的ID）    if(outObj != null){      //如果****那么就新建一个fi 将项目信息分项保存      if(this.factorNameDecoderInterface != null){        FactorInfo fi = factorNameDecoderInterface.decode(obj.getHref().get());        if(newValueInterface != null && fi != null){          //如果信息不为空，我们就要准备存读出来的数了          newValueInterface.onNewValue(fi, outObj.toString());        }      }    }    else{      for(Obj o : obj.list()){        readUrl(url + o.getHref());       }    }  }}

public class ObixClient {    public Obj read(String url){    try {      //根据我们传进去的url中读出一个obj,这个obj如果有value，就返回一个数，否则就返回地址 href="http://115.28.2.201:28088/obix/config/Drivers/NiagaraNetwork/Himalayas_PC/points/Himalayas_301/points/JF/"/>      Obj obj = session.read(new Uri(url));      return obj;    } catch (Exception e) {      e.printStackTrace();            return null;    }  }}

public class FactorNameDecoderObixUrlImpl implements FactorNameDecoderInterface{  @Override  public FactorInfo decode(String url) {        String[] tokens = url.split(":")[2].split("///");    //新建一个 对象 将url中解析出的信息分享保存到这个对象中    FactorInfo fi = new FactorInfo();    fi.setDeviceName(tokens[tokens.length - 2]);    fi.setDeviceTypeName(tokens[tokens.length - 3]);    fi.setFactorName(tokens[tokens.length - 1]);            fi.setBuildName("");    fi.setFloorName("");    fi.setProjectName("");        return fi;  }}

public class NewValueInterfaceImpl implements NewValueInterface{  static ConcurrentHashMap<String, Long> dataInfluxTime = new ConcurrentHashMap<String, Long>();  DeviceMapper deviceDao;   IDeviceManagementService deviceService;  DeviceTypeMapper deviceTypeDao;  BuildMapper buildDao;  Integer projectId;    HashMap<String, Integer> buildNameToId = new HashMap<String, Integer>();  HashMap<String, Integer> deviceNumberToId = new HashMap<String, Integer>();    public NewValueInterfaceImpl(Integer projectId, IDeviceManagementService deviceService, DeviceMapper deviceDao, DeviceTypeMapper deviceTypeDao,BuildMapper buildDao) {    this.deviceDao = deviceDao;    this.deviceTypeDao = deviceTypeDao;    this.buildDao = buildDao;    this.projectId = projectId;    this.deviceService = deviceService;        List<Build> bs = buildDao.selectByExample(new BuildExample());    for(Build b : bs){      buildNameToId.put(b.getName(), b.getId());    }        List<Device> ds = deviceDao.selectByExample(new DeviceExample());    for(Device d : ds){      deviceNumberToId.put(d.getNumber(), d.getId());    }  }  @Override  public void onNewValue(FactorInfo fi, String value) {        //先将URL中的设备名称信息取出来，然后再取出对应的ID    String number = fi.getDeviceName();    Integer deviceId = deviceNumberToId.get(number);    if(deviceId == null){      number = fi.getDeviceName();      Device record = new Device();      record.setName(number);      record.setNumber(number);      record.setProjectId(projectId);      record.setTypeId(fi.getDeviceTypeId());      deviceService.insert(record );      deviceId = record.getId();      System.out.println("found new device id=" + deviceId + ", name=" + number);      deviceNumberToId.put(number, deviceId);    }    Double val = null;    //然后将ID存入device中    Device updateRecord = new Device();    updateRecord.setId(deviceId);    //将取出的值也存入device    try{      Double d = Double.parseDouble(value);      updateRecord.setCurrentValue(d.intValue());      val = d;    }    catch(Exception e){      if(value.equalsIgnoreCase("true")){        updateRecord.setCurrentValue(1);        val = 1.0;      }      else if(value.equalsIgnoreCase("false")){        updateRecord.setCurrentValue(0);        val = 0.0;      }    }        if(updateRecord.getCurrentValue() != null){      deviceDao.updateByPrimaryKeySelective(updateRecord );    }        //将所得所得数据存入influxDB    try{      String timeKey = projectId+"_"+deviceId+"_"+fi.getFactorName();      Long t = dataInfluxTime.get(timeKey);      if(t == null) t = new Long(0);      Long now = System.currentTimeMillis();      if(now - t > 10 * 60 * 1000){        InfluxDBUtil.insert(projectId, deviceId, convert10Minutes(now), fi.getFactorName(), val);        dataInfluxTime.put(timeKey, now);      }    }    catch(Exception e){      e.printStackTrace();    }  }