update

audio-analysis/src/main/java/com/yonge/nettty/dto/UserChannelContext.java

@@ -32,7 +32,7 @@ public class UserChannelContext {
 	
 	private final static Logger LOGGER = LoggerFactory.getLogger(UserChannelContext.class);
 	
-	private final double offsetMS = 300;
+	private int offsetMS = 300;
 	
 	private Long recordId;
 	
@@ -97,6 +97,10 @@ public class UserChannelContext {
 		this.recordId = recordId;
 	}
 
+	public void setOffsetMS(int offsetMS) {
+		this.offsetMS = offsetMS;
+	}
+
 	public ConcurrentHashMap<Integer, MusicXmlBasicInfo> getSongMusicXmlMap() {
 		return songMusicXmlMap;
 	}
@@ -137,6 +141,7 @@ public class UserChannelContext {
 		recordId = null;
 		playTime = 0;
 		receivedTime = 0;
+		offsetMS = 0;
 		lastChunkAnalysisList = new ArrayList<ChunkAnalysis>();
 	}
 	

audio-analysis/src/main/java/com/yonge/netty/server/service/AudioCompareHandler.java

@@ -221,7 +221,12 @@ public class AudioCompareHandler implements MessageHandler {
 			channelContext.resetUserInfo();
 
 			break;
-		case "proxyMessage": // ???
+		case "audioPlayStart": // ???
+			
+			Integer offsetTime = dataObj.getInteger("offsetTime");
+			if(offsetTime != null){
+				channelContext.setOffsetMS(offsetTime);
+			}
 
 			break;
 		case "videoUpload": // 上传音频