| | |
|---|
| | | AtomicInteger atomicInteger = new AtomicInteger(0); |
|---|
| | | for (int i = 0; i < list.size(); i++) { |
|---|
| | | CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i); |
|---|
| | | if (cloudInverterDeviceBean == null || !cloudInverterDeviceBean.isActivate()) { |
|---|
| | | //未激活设备 |
|---|
| | | atomicInteger.set(atomicInteger.get() + 1); |
|---|
| | | //注意:这个逆变器只能本地控制(因为拿不到mqtt通讯秘钥以及GatewayID,无法远程控制) |
|---|
| | | //更新逆变器本地缓存信息 |
|---|
| | | refreshGatewayCacheData(false, cloudInverterDeviceBean, null, homeId); |
|---|
| | | //到最后一条，才处理回调 |
|---|
| | | if (atomicInteger.get() == list.size()) { |
|---|
| | | if (cloudCallBeak != null) { |
|---|
| | | cloudCallBeak.onSuccess(IntegrateCloudAndLocalData(homeId, list, false)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | HdlLogLogic.print("设备未激活(mac:" + cloudInverterDeviceBean.getOsn() + "))", true); |
|---|
| | | } |
|---|
| | | //获取远程设备通讯信息(拿到网关ID，mqtt通讯秘钥) |
|---|
| | | getDeviceRemoteInfo(homeId, cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() { |
|---|
| | | @Override |
|---|
| | |
|---|
| | | gatewayBean.setDevice_model(cloudInverterDeviceBean.getOmodel());//设备型号 |
|---|
| | | } |
|---|
| | | gatewayBean.setSpk(cloudInverterDeviceBean.getSpk());//设备spk |
|---|
| | | gatewayBean.setActivate(cloudInverterDeviceBean.isActivate());//是否激活设备(true：激活；false：未激活) |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
