|
@@ -8,6 +8,7 @@ import com.cooleshow.base.data.net.BaseResponse;
|
|
|
import com.cooleshow.base.data.net.RetrofitClientNoToken;
|
|
|
import com.cooleshow.base.data.net.RetrofitFactory;
|
|
|
import com.cooleshow.base.rx.BaseObserver;
|
|
|
+import com.cooleshow.base.utils.DateUtil;
|
|
|
import com.cooleshow.base.utils.FileUtils;
|
|
|
import com.cooleshow.base.utils.SystemUtils;
|
|
|
import com.daya.live_teaching.api.LiveTeachingApi;
|
|
@@ -83,6 +84,17 @@ public class ClassRepository extends BaseRepository {
|
|
|
private static final String PARAM_ROOM_ID = "roomId";
|
|
|
private static final String PARAM_USER_ID = "userId";
|
|
|
private static final String PARAM_CAMERA_ON = "cameraOn";
|
|
|
+
|
|
|
+
|
|
|
+ public static final String PARAM_CAMERA_TYPE = "CAMERA";
|
|
|
+ public static final String PARAM_MICROPHONE_TYPE = "MICROPHONE";
|
|
|
+ public static final String PARAM_MUSIC_MODE_TYPE = "MUSIC_MODE";
|
|
|
+ public static final String PARAM_HAND_UP_TYPE = "HAND_UP";
|
|
|
+ public static final String PARAM_EXAM_SONG_TYPE = "EXAM_SONG";
|
|
|
+ public static final String PARAM_MUSIC_SHEET_TYPE = "MUSIC_SHEET";
|
|
|
+ public static final String PARAM_ACCOMPANIMENT_TYPE = "ACCOMPANIMENT";
|
|
|
+
|
|
|
+
|
|
|
// 5 原音6 伴奏
|
|
|
private static final String PARAM_DEVICE_TYPE = "deviceType";
|
|
|
private static final String PARAM_SOUND_VOLUME = "soundVolume";
|
|
@@ -139,7 +151,8 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(PARAM_CAMERA_ON, cameraOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_CAMERA_TYPE);
|
|
|
+ bodyMap.put("enable", cameraOn);
|
|
|
sealClassService.deviceControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -147,9 +160,9 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(PARAM_CAMERA_ON, cameraOn);
|
|
|
- bodyMap.put(PARAM_DEVICE_TYPE, deviceType);
|
|
|
bodyMap.put(PARAM_SOUND_VOLUME, soundVolume);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MICROPHONE_TYPE);
|
|
|
+ bodyMap.put("enable", cameraOn);
|
|
|
sealClassService.deviceControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -173,7 +186,8 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(PARAM_MIC_ON, microphone);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MICROPHONE_TYPE);
|
|
|
+ bodyMap.put("enable", microphone);
|
|
|
sealClassService.deviceControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -181,7 +195,8 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(HAND_UP_ON, handUpOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_HAND_UP_TYPE);
|
|
|
+ bodyMap.put("enable", handUpOn);
|
|
|
sealClassService.deviceControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -189,7 +204,8 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(MUSIC_MODE_ON, musicModeOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_MODE_TYPE);
|
|
|
+ bodyMap.put("enable", musicModeOn);
|
|
|
sealClassService.deviceControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
|
|
|
}
|
|
@@ -197,23 +213,26 @@ public class ClassRepository extends BaseRepository {
|
|
|
public void batchControlCamera(String roomId, boolean cameraOn, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(PARAM_CAMERA_ON, cameraOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_CAMERA_TYPE);
|
|
|
+ bodyMap.put("enable", cameraOn);
|
|
|
sealClassService.deviceBatchControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
|
|
|
- public void batchControlMusicMode(String roomId, boolean microphone, ResultCallback<Boolean> callBack) {
|
|
|
+ public void batchControlMusicMode(String roomId, boolean musicMode, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(MUSIC_MODE_ON, microphone);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_MODE_TYPE);
|
|
|
+ bodyMap.put("enable", musicMode);
|
|
|
sealClassService.deviceBatchControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
- public void batchControlMicrophone(String roomId, String userId, boolean musicModeOn, ResultCallback<Boolean> callBack) {
|
|
|
+ public void batchControlMicrophone(String roomId, String userId, boolean microphone, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(PARAM_MIC_ON, musicModeOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MICROPHONE_TYPE);
|
|
|
+ bodyMap.put("enable", microphone);
|
|
|
sealClassService.deviceBatchControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
|
|
|
}
|
|
@@ -221,12 +240,24 @@ public class ClassRepository extends BaseRepository {
|
|
|
//伴奏
|
|
|
public void batchControlExamSong(String roomId, String userId, String musicScoreOn, String accompanimentOn, String musicScoreAccompanimentId, String soudnValue, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
+
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(MUSIC_SCORE_ON, musicScoreOn);
|
|
|
- bodyMap.put(ACCOMPANIMENT_ON, accompanimentOn);
|
|
|
bodyMap.put(EXAM_SONG_ID, musicScoreAccompanimentId);
|
|
|
bodyMap.put(PARAM_SOUND_VOLUME, soudnValue);
|
|
|
+ if (TextUtils.equals("true", musicScoreOn)) {
|
|
|
+ bodyMap.put("enable", true);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_SHEET_TYPE);
|
|
|
+ } else if (TextUtils.equals("false", musicScoreOn)) {
|
|
|
+ bodyMap.put("enable", false);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_SHEET_TYPE);
|
|
|
+ } else if (TextUtils.equals("true", accompanimentOn)) {
|
|
|
+ bodyMap.put("enable", true);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_ACCOMPANIMENT_TYPE);
|
|
|
+ } else if (TextUtils.equals("false", accompanimentOn)) {
|
|
|
+ bodyMap.put("enable", false);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_ACCOMPANIMENT_TYPE);
|
|
|
+ }
|
|
|
sealClassService.deviceBatchControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
|
|
|
}
|
|
@@ -235,31 +266,44 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
- bodyMap.put(MUSIC_SCORE_ON, musicScoreOn);
|
|
|
- bodyMap.put(ACCOMPANIMENT_ON, accompanimentOn);
|
|
|
bodyMap.put(EXAM_SONG_ID, musicScoreAccompanimentId);
|
|
|
+
|
|
|
+ if (TextUtils.equals("true", musicScoreOn)) {
|
|
|
+ bodyMap.put("enable", true);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_SHEET_TYPE);
|
|
|
+ } else if (TextUtils.equals("false", musicScoreOn)) {
|
|
|
+ bodyMap.put("enable", false);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_SHEET_TYPE);
|
|
|
+ } else if (TextUtils.equals("true", accompanimentOn)) {
|
|
|
+ bodyMap.put("enable", true);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_ACCOMPANIMENT_TYPE);
|
|
|
+ } else if (TextUtils.equals("false", accompanimentOn)) {
|
|
|
+ bodyMap.put("enable", false);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_ACCOMPANIMENT_TYPE);
|
|
|
+ }
|
|
|
sealClassService.deviceControl(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
- public void deviceApprove(String roomId, String ticket, ResultCallback<Boolean> callBack) {
|
|
|
+ public void deviceApprove(String roomId, String deviceType, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(PARAM_TICKET, ticket);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, deviceType);
|
|
|
sealClassService.deviceApprove(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
- public void deviceReject(String roomId, String ticket, ResultCallback<Boolean> callBack) {
|
|
|
+ public void deviceReject(String roomId, String deviceType, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(PARAM_TICKET, ticket);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, deviceType);
|
|
|
sealClassService.deviceReject(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
public void deviceSyncHandUpOn(String roomId, String userId, boolean handUpOn, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(HAND_UP_ON, handUpOn);
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_HAND_UP_TYPE);
|
|
|
+ bodyMap.put("enable", handUpOn);
|
|
|
sealClassService.deviceSync(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -267,6 +311,8 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(MUSIC_MODE_ON, musicModeOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_MODE_TYPE);
|
|
|
+ bodyMap.put("enable", musicModeOn);
|
|
|
sealClassService.deviceSync(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -274,20 +320,24 @@ public class ClassRepository extends BaseRepository {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
bodyMap.put(PARAM_CAMERA_ON, cameraOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_CAMERA_TYPE);
|
|
|
+ bodyMap.put("enable", cameraOn);
|
|
|
sealClassService.deviceSync(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
public void deviceSyncMic(String roomId, boolean microphoneOn, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(PARAM_MIC_ON, microphoneOn);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MICROPHONE_TYPE);
|
|
|
+ bodyMap.put("enable", microphoneOn);
|
|
|
sealClassService.deviceSync(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
|
public void deviceSyncExamSong(String roomId, boolean examSong, ResultCallback<Boolean> callBack) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(MUSIC_SCORE_ON, examSong);
|
|
|
+ bodyMap.put(PARAM_DEVICE_TYPE, PARAM_MUSIC_SHEET_TYPE);
|
|
|
+ bodyMap.put("enable", examSong);
|
|
|
sealClassService.deviceSync(RetrofitUtil.createJsonRequest(bodyMap)).enqueue(new CallBackWrapper<Boolean>(callBack));
|
|
|
}
|
|
|
|
|
@@ -467,7 +517,19 @@ public class ClassRepository extends BaseRepository {
|
|
|
public void switchDisplay(String roomId, int type, String userId, String uri, ResultCallback<Boolean> callback) {
|
|
|
HashMap<String, Object> bodyMap = new HashMap<>();
|
|
|
bodyMap.put(PARAM_ROOM_ID, roomId);
|
|
|
- bodyMap.put(PARAM_TYPE, type);
|
|
|
+ String typeParams;
|
|
|
+ if (type == ScreenDisplay.Display.LECTURER.getType()) {
|
|
|
+ typeParams = "TEACHER";
|
|
|
+ } else if (type == ScreenDisplay.Display.WHITEBOARD.getType()) {
|
|
|
+ typeParams = "WHITE_BOARD";
|
|
|
+ } else if (type == ScreenDisplay.Display.SCREEN.getType()) {
|
|
|
+ typeParams = "SCREEN";
|
|
|
+ } else if (type == ScreenDisplay.Display.NONE.getType()) {
|
|
|
+ typeParams = "NONE";
|
|
|
+ } else {
|
|
|
+ typeParams = "STUDENT";
|
|
|
+ }
|
|
|
+ bodyMap.put(PARAM_TYPE, typeParams);
|
|
|
if (userId != null) {
|
|
|
bodyMap.put(PARAM_USER_ID, userId);
|
|
|
}
|
|
@@ -524,7 +586,13 @@ public class ClassRepository extends BaseRepository {
|
|
|
classMember.setRole(memberChangedMessage.getRole().getValue());
|
|
|
classMember.setUserId(memberChangedMessage.getUserId());
|
|
|
classMember.setUserName(memberChangedMessage.getUserName());
|
|
|
- classMember.setJoinTime(memberChangedMessage.getTimestamp());
|
|
|
+ try {
|
|
|
+ long timestamp = memberChangedMessage.getTimestamp();
|
|
|
+ String millon = DateUtil.getMillon(timestamp);
|
|
|
+ classMember.setJoinTime(millon);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
classMember.setHandUpOn(memberChangedMessage.isHandUpOn());
|
|
|
ClassMember.PlayMidiJsonBean playMidiJsonBean = new ClassMember.PlayMidiJsonBean();
|
|
|
playMidiJsonBean.setEnable(memberChangedMessage.isMetronomeSwitch());
|
|
@@ -611,34 +679,6 @@ public class ClassRepository extends BaseRepository {
|
|
|
result.setAccept(speechResultMessage.isAccept());
|
|
|
eventListener.onRequestSpeechResult(result);
|
|
|
return true;
|
|
|
- } else if (content instanceof AssistantTransferMessage) { // 转让助教
|
|
|
- AssistantTransferMessage assistantTransferMessage = (AssistantTransferMessage) content;
|
|
|
-
|
|
|
- List<RoleChangedUser> roleChangedUserList = new ArrayList<>();
|
|
|
- RoleChangedUser assistant = new RoleChangedUser();
|
|
|
- assistant.setRole(Role.ASSISTANT.getValue());
|
|
|
- assistant.setUserId(assistantTransferMessage.getToUserId());
|
|
|
- roleChangedUserList.add(assistant);
|
|
|
-
|
|
|
- // 操作者
|
|
|
- RoleChangedUser oldAssistant = new RoleChangedUser();
|
|
|
- oldAssistant.setRole(Role.STUDENT.getValue());
|
|
|
- oldAssistant.setUserId(assistantTransferMessage.getOpUserId());
|
|
|
- roleChangedUserList.add(oldAssistant);
|
|
|
-
|
|
|
- eventListener.onRoleChanged(roleChangedUserList, assistantTransferMessage.getOpUserId());
|
|
|
- return true;
|
|
|
-
|
|
|
- } else if (content instanceof UpgradeRoleMessage) { // 邀请升级
|
|
|
- UpgradeRoleMessage upgradeRoleMessage = (UpgradeRoleMessage) content;
|
|
|
- UpgradeRoleInvite upgradeRoleInvite = new UpgradeRoleInvite();
|
|
|
- upgradeRoleInvite.setOpUserId(upgradeRoleMessage.getOpUserId());
|
|
|
- upgradeRoleInvite.setOpUserName(upgradeRoleMessage.getOpUserName());
|
|
|
- upgradeRoleInvite.setAction(upgradeRoleMessage.getAction());
|
|
|
- upgradeRoleInvite.setRole(upgradeRoleMessage.getRole());
|
|
|
- upgradeRoleInvite.setTicket(upgradeRoleMessage.getTicket());
|
|
|
- eventListener.onInviteUpgradeRole(upgradeRoleInvite);
|
|
|
- return true;
|
|
|
} else if (content instanceof PlayMidiMessage) { // 播放节拍器
|
|
|
PlayMidiMessage playMidiMessage = (PlayMidiMessage) content;
|
|
|
PlayMidi playMidi = new PlayMidi();
|