海康对接

wxr

2024-11-18 61df8ac3d298742b9023ae9e5258b2bb97099a94

 HDLLinphoneSDKDemoNew/HDLLinphoneSDK/src/main/java/com/hdl/hdllinphonesdk/HDLLinphoneKit.java

@@ -4,6 +4,8 @@
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.media.AudioManager;
import android.media.MediaPlayer;
import android.os.Build;
import android.os.IBinder;
import android.util.Log;
@@ -23,11 +25,17 @@
import org.linphone.core.Address;
import org.linphone.core.AudioDevice;
import org.linphone.core.AuthInfo;
import org.linphone.core.Buffer;
import org.linphone.core.Call;
import org.linphone.core.CallParams;
import org.linphone.core.ChatMessage;
import org.linphone.core.ChatMessageListener;
import org.linphone.core.ChatRoom;
import org.linphone.core.Content;
import org.linphone.core.Core;
import org.linphone.core.CoreException;
import org.linphone.core.Factory;
import org.linphone.core.ParticipantImdnState;
import org.linphone.core.ProxyConfig;
import org.linphone.core.TransportType;

@@ -67,13 +75,91 @@
    private volatile static HDLLinphoneKit instance;
    private Context viewContext;
    private ServiceWaitThread mServiceWaitThread;
    private String mUsername, mPassword, mServerIP;
    private String mUsername, mPassword, mServerIP,mTransportType;
    //    private TextureView mRenderingView, mPreviewView;
    private boolean isAutoJumpCallView;//是否自动跳转呼叫页面
    private String intercomeType;

    /**
     * 铃声播放器
     */
    private MediaPlayer mediaPlayer;

    /**
     * 未接事件触发时间
     */
    public int missedCallsTime = 30;

    public AudioManager audioManager;


    private HDLLinphoneKit() {

    }

    private void InitMediaPlayer(Context context) {
        if (mediaPlayer == null) {
            try {
                mediaPlayer = MediaPlayer.create(context, R.raw.oldphone_mono);
            } catch (Exception ex) {

            }
        }
    }

    private void initAudioManager(Context context){
        if(audioManager == null){
            try{
                audioManager = (AudioManager) context.getSystemService(Context.AUDIO_SERVICE);
            }catch (Exception exception){

            }
        }
    }

    public int getRingerMode()
    {
        return audioManager.getRingerMode();
    }

    public boolean getMediaPlayerPlayingStatus(){
        if (mediaPlayer != null){
            return mediaPlayer.isPlaying();
        }
        return false;
    }


    // 播放铃声
    public void playRingtone() {
        if (mediaPlayer != null && !mediaPlayer.isPlaying()) {
            mediaPlayer.start(); // 开始播放
        }
    }

    /**
     * 是否循环播放铃声
     * @param isLooping
     */
    public void setMediaPlayerLooping(boolean isLooping) {
        mediaPlayer.setLooping(isLooping);
    }

    // 停止铃声
    public void stopRingtone() {
        if (mediaPlayer != null && mediaPlayer.isPlaying()) {
            mediaPlayer.stop(); // 停止播放
//            mediaPlayer.reset(); // 重置 MediaPlayer
//            mediaPlayer.release(); // 释放资源
//            mediaPlayer = null;
        }
    }

    public void releaseRingtone(){
        if (mediaPlayer != null ) {
            mediaPlayer.release(); // 释放资源
            mediaPlayer = null;
        }
    }

    /**
@@ -106,6 +192,8 @@
        }
    }



    /**
     * 初始化Linphone
     *
@@ -115,6 +203,8 @@
        viewContext = context.getApplicationContext();
        if (!HDLLinphoneService.isReady()) {
            CheckIfNeedstartService();
            InitMediaPlayer(context);
            initAudioManager(context);
        } else {
        }
    }
@@ -271,6 +361,16 @@
        mPassword = password;
        mServerIP = serverIP;
        intercomeType = inter_type;
        mTransportType = "UDP";
        login(inter_type);
    }

    public void setAccountAndLogin(String username, String password, String serverIP, String inter_type, String transportType) {
        mUsername = username;
        mPassword = password;
        mServerIP = serverIP;
        mTransportType = transportType;
        intercomeType = inter_type;
        login(inter_type);
    }

@@ -384,10 +484,10 @@
            }
            if (inter_type.equals(INTER_PHONE_TYPE_FREEVIEW)) {
                // 全视通可视对讲注册
                freeViewRegisterUserAuth(mUsername, mPassword, mServerIP);
                freeViewRegisterUserAuth(mUsername, mPassword, mServerIP,mTransportType);
            } else {
                // 其他可视对讲注册
                registerUserAuth(mUsername, mPassword, mServerIP);
                registerUserAuth(mUsername, mPassword, mServerIP,mTransportType);
            }
        } catch (CoreException e) {
            e.printStackTrace();
@@ -402,7 +502,7 @@
     * @param host
     * @throws CoreException
     */
    public void registerUserAuth(String name, String password, String host) throws CoreException {
    public void registerUserAuth(String name, String password, String host,String transportType) throws CoreException {
        Core mLinphoneCore = HDLLinphoneService.getCore();
        if (mLinphoneCore == null) return;

@@ -411,7 +511,20 @@
        mAccountCreator.setUsername(name);
        mAccountCreator.setDomain(host);
        mAccountCreator.setPassword(password);
        mAccountCreator.setTransport(TransportType.Udp);
        switch (transportType.toUpperCase()){
            case "UDP":
                mAccountCreator.setTransport(TransportType.Udp);
                Log.i("linphone", "setting : TransportType.Udp");
                break;
            case "TCP":
                mAccountCreator.setTransport(TransportType.Tcp);
                Log.i("linphone", "setting : TransportType.Tcp");
                break;
            default:
                mAccountCreator.setTransport(TransportType.Udp);
                Log.i("linphone", "default : TransportType.Udp");
                break;
        }
        ProxyConfig prxCfg = mAccountCreator.createProxyConfig();

        prxCfg.enableQualityReporting(false);
@@ -421,14 +534,90 @@
        mLinphoneCore.addProxyConfig(prxCfg);//添加代理配置。如果启用了注册，这将开始在代理上注册。
        mLinphoneCore.addAuthInfo(authInfo);//添加认证信息到,该信息片段将在所有需要的SIP事务中使用身份验证
        mLinphoneCore.setDefaultProxyConfig(prxCfg);//设置默认代理。

    }

    public void sendSipMessage(String sipAddress, String message) {
        try {
            Core mLinphoneCore = HDLLinphoneService.getCore();
            if (mLinphoneCore == null) {
                Log.e("Linphone", "Linphone Core 未初始化");
                return;
            }

            // 解析对方的SIP地址
            Address address = mLinphoneCore.interpretUrl(sipAddress);

            // 建立对话
            ChatRoom chatRoom = mLinphoneCore.getChatRoom(address);

            // 创建消息
            ChatMessage chatMessage = chatRoom.createMessageFromUtf8(message);

            // 监听消息状态
            chatMessage.addListener(new ChatMessageListener() {
                @Override
                public void onFileTransferSendChunk(ChatMessage message, Content content, int offset, int size, Buffer buffer) {
                    // 文件传输的分块发送回调，未使用
                }

                @Override
                public void onMsgStateChanged(ChatMessage message, ChatMessage.State state) {
                    Log.d("Linphone", "消息状态更新：" + state.toString());
                    if (state == ChatMessage.State.Delivered) {
                        Log.d("Linphone", "消息已成功发送");
                    } else if (state == ChatMessage.State.NotDelivered) {
                        Log.d("Linphone", "消息发送失败");
                    }
                }

                @Override
                public Buffer onFileTransferSend(ChatMessage message, Content content, int offset, int size) {
                    return null;  // 文件传输回调，未使用
                }

                @Override
                public void onEphemeralMessageDeleted(ChatMessage message) {
                    // 临时消息删除回调，未使用
                }

                @Override
                public void onEphemeralMessageTimerStarted(ChatMessage message) {
                    // 临时消息计时器开始回调，未使用
                }

                @Override
                public void onParticipantImdnStateChanged(ChatMessage message, ParticipantImdnState state) {
                    // 参与者消息通知状态改变回调，未使用
                }

                @Override
                public void onFileTransferRecv(ChatMessage message, Content content, Buffer buffer) {
                    // 文件传输接收回调，未使用
                }

                @Override
                public void onFileTransferProgressIndication(ChatMessage message, Content content, int offset, int total) {
                    // 文件传输进度回调，未使用
                }
            });
            // 发送消息
            chatMessage.send();

        } catch (Exception e) {
            Log.e("Linphone", "消息发送失败", e);
            e.printStackTrace();
        }
    }



    /**
     * 提交账号和密码注册到全视通服务器
     *
     * @throws CoreException
     */
    public void freeViewRegisterUserAuth(String userName, String password, String domain) throws CoreException {
    public void freeViewRegisterUserAuth(String userName, String password, String domain,String transportType) throws CoreException {
        Core mLinphoneCore = HDLLinphoneService.getCore();
        if (mLinphoneCore == null) return;

@@ -438,7 +627,21 @@
        mAccountCreator.setUsername(userName);
        mAccountCreator.setDomain("yun");
        mAccountCreator.setPassword(password);
        mAccountCreator.setTransport(TransportType.Udp);

        switch (transportType.toUpperCase()){
            case "UDP":
                mAccountCreator.setTransport(TransportType.Udp);
                Log.i("linphone", "setting : TransportType.Udp");
                break;
            case "TCP":
                mAccountCreator.setTransport(TransportType.Tcp);
                Log.i("linphone", "setting : TransportType.Tcp");
                break;
            default:
                mAccountCreator.setTransport(TransportType.Udp);
                Log.i("linphone", "default : TransportType.Udp");
                break;
        }

        ProxyConfig prxCfg = mAccountCreator.createProxyConfig();
        prxCfg.enableQualityReporting(false);
@@ -479,10 +682,14 @@
            if (addressToCall != null) {
                call = core.inviteAddressWithParams(addressToCall, params);
                // 设置外放
                for (AudioDevice audioDevice : HDLLinphoneService.getCore().getAudioDevices()) {
                    if (audioDevice.getType() == AudioDevice.Type.Speaker) {
                        call.setOutputAudioDevice(audioDevice);
                try {
                    for (AudioDevice audioDevice : HDLLinphoneService.getCore().getAudioDevices()) {
                        if (audioDevice.getType() == AudioDevice.Type.Speaker) {
                            call.setOutputAudioDevice(audioDevice);
                        }
                    }
                }catch (Exception exception){
                    Log.e("LinphoneError",exception.getMessage());
                }
            }
        }