package com.sandu.ximon.admin; import com.aliyuncs.iot.model.v20180120.QueryDeviceDetailResponse; import com.sandu.ximon.admin.manager.iot.frame.A1Frame; import com.sandu.ximon.admin.manager.iot.frame.A5Frame; import com.sandu.ximon.admin.manager.iot.frame.FrameBuilder; import com.sandu.ximon.admin.manager.iot.frame.IRequestFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.request.EmptyRequestInnerFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.request.LightBrightnessReqInnerFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.request.LightHeartbeatReqInnerFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.response.LightBrightnessRespInnerFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.response.LightHeartbeatRespInnerFrame; import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame; import com.sandu.ximon.admin.manager.iot.rrpc.dto.WrapResponseCommonFrame; import com.sandu.ximon.admin.manager.iot.rrpc.enums.A1OrderEnum; import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5LightDataEnum; import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum; import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; @SpringBootTest class BaseTopicTests { @Test void queryDeviceDetail() { QueryDeviceDetailResponse.Data data = MainBoardInvokeSyncService.getInstance().queryDeviceDetail("32313243305005ff0431ffff", null); System.out.println(data.toString()); } @Test void rrpcLightControl() { LightBrightnessReqInnerFrame lightControlFrame = new LightBrightnessReqInnerFrame(80); A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_LIGHT_DATA.getCode(), lightControlFrame); WrapResponseCommonFrame frame = MainBoardInvokeSyncService.getInstance() .sendRRPC("32313243305008ff1a06ffff", a5Frame, LightBrightnessRespInnerFrame.class); // LightControlResponseInnerFrame lightControlResponseInnerFrame = new LightControlResponseInnerFrame(); // LightControlResponseInnerFrame innerFrame = lightControlResponseInnerFrame.transformFrame(commonFrame.getPayload()); System.out.println(frame.toString()); } @Test void readDeviceUniqueMac() { A1Frame a1Frame = new A1Frame(A1OrderEnum.REQUEST_READ_DEVICE_UNIQUE_MAC.getCode(), new EmptyRequestInnerFrame()); CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance() .sendRRPC("baseDevice", a1Frame); System.out.println(commonFrame.toString()); } @Test void registerWithReturn() { String de = "baseDevice".toLowerCase(); QueryDeviceDetailResponse.Data data = MainBoardInvokeSyncService.getInstance().queryDeviceDetail("baseDevice", null); System.out.println(data.toString()); } @Test void LightHeartbeat() { IRequestFrame build = FrameBuilder.builderA5() .orderType(A5OrderEnum.REQUEST_LIGHT_DATA.getCode()) .innerFrame(new LightHeartbeatReqInnerFrame()) .build(); WrapResponseCommonFrame responseCommonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC("32313243305008ff1a06ffff", build, LightHeartbeatRespInnerFrame.class); System.out.println("responseCommonFrame.toString()"); System.out.println(responseCommonFrame.toString()); } }