package com.netsdk.demo.example;

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Dimension;
import java.awt.FlowLayout;
import java.awt.Graphics;
import java.awt.Image;
import java.awt.Panel;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.File;

import javax.swing.BorderFactory;
import javax.swing.JButton;
import javax.swing.JComponent;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JPasswordField;
import javax.swing.JTextField;
import javax.swing.border.Border;

import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.LLong;
import com.sun.jna.Native;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

/**
 * 实时预览
 */
class Preview extends JFrame {
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
    static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
    
	private SDKEnvironment sdkEnv;
	
	// 登录参数	
	private String m_strIp             = "172.31.12.139";
	private Integer m_nPort            = new Integer("37777");
	private String m_strUser           = "admin";
	private String m_strPassword       = "admin";
	// 设备信息
    private NetSDKLib.NET_DEVICEINFO deviceInfo = new NetSDKLib.NET_DEVICEINFO();
	
	private LLong loginHandle = new LLong(0); 	// 登录句柄
	private LLong m_lOperateHandle1 = new LLong(0);    // 监控句柄
	private LLong m_lOperateHandle2 = new LLong(0);    // 监控句柄
    
	/**
	 * Preview 构造
	 */
	public Preview() {
		sdkEnv = new SDKEnvironment();
		sdkEnv.init();
		setTitle("实时监控");
		setSize(850, 550);
		setLayout(new BorderLayout());
		setLocationRelativeTo(null);
		setVisible(true);
		
		loginPanel  = new LoginPanel();           // 登录面板
		realPlayPanel1 	 = new RealPlayPanel1();   // 播放面板1		
		realPlayPanel2 	 = new RealPlayPanel2();   // 播放面板2
		
		add(loginPanel, BorderLayout.NORTH);
		add(realPlayPanel1, BorderLayout.WEST);
		add(realPlayPanel2, BorderLayout.EAST);	
		
		addWindowListener(new WindowAdapter() {
			public void windowClosing(WindowEvent e) {
				System.out.println("RealPlay Window Closing");			
				LoginOutButtonPerformed();
				stopRealPlay1();
				stopRealPlay2();
	    		sdkEnv.cleanup();
				dispose();
			}
		});
	}
	
	/**
	 * NetSDK 库初始化
	 */
	private class SDKEnvironment { 
	    private boolean bInit = false;
	    private boolean bLogopen = false;
	    
	    private DisConnect 		 disConnect    = new DisConnect();    // 设备断线通知回调
	    private HaveReConnect    haveReConnect = new HaveReConnect(); // 网络连接恢复
	    
	    // 初始化
	    public boolean init() {    	
			// SDK 库初始化, 并设置断线回调
			bInit = netsdkApi.CLIENT_Init(disConnect, null);
			if (!bInit) {
				System.err.println("Initialize SDK failed");
				return false;
			}
			
			// 打开日志，可选
			NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
			
			File path = new File(".");			
			String logPath = path.getAbsoluteFile().getParent() + "\\sdk_log\\RealPlay_" + System.currentTimeMillis() + ".log";
			
			setLog.bSetFilePath = 1;
			System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
			
			setLog.bSetPrintStrategy = 1;
			setLog.nPrintStrategy = 0;
			bLogopen = netsdkApi.CLIENT_LogOpen(setLog);
			if (!bLogopen) {
				System.err.println("Failed to open NetSDK log !!!");
			}
			
			// 获取版本, 可选操作
			System.out.printf("NetSDK Version [%d]\n", netsdkApi.CLIENT_GetSDKVersion());		
			
			// 设置断线重连回调接口，设置过断线重连成功回调函数后，当设备出现断线情况，SDK内部会自动进行重连操作
			// 此操作为可选操作，但建议用户进行设置
			netsdkApi.CLIENT_SetAutoReconnect(haveReConnect, null);
			
			// 设置登录超时时间和尝试次数 , 此操作为可选操作	   
			int waitTime = 5000;   // 登录请求响应超时时间设置为 5s
			int tryTimes = 3;      // 登录时尝试建立链接3次
			netsdkApi.CLIENT_SetConnectTime(waitTime, tryTimes);
			
			// 设置更多网络参数，NET_PARAM的nWaittime，nConnectTryNum成员与CLIENT_SetConnectTime 
			// 接口设置的登录设备超时时间和尝试次数意义相同
			// 此操作为可选操作
			NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
			netParam.nConnectTime = 10000; // 登录时尝试建立链接的超时时间
			netsdkApi.CLIENT_SetNetworkParam(netParam);
	    	
	    	return true;
	    }
	    
	    // 清除环境
	    public void cleanup() {
	    	if (bLogopen) {
	    		netsdkApi.CLIENT_LogClose();
	    	}
	    	
	    	if (bInit) {
	    		netsdkApi.CLIENT_Cleanup();
	    	}
	    }
	    
	    // 设备断线回调: 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK会调用该函数
	    public class DisConnect implements NetSDKLib.fDisConnect  {
	        public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
	        	System.out.printf("Device[%s] Port[%d] Disconnect!\n" , pchDVRIP , nDVRPort);
	        }
	    }
		
		// 网络连接恢复，设备重连成功回调
		// 通过 CLIENT_SetAutoReconnect 设置该回调函数，当已断线的设备重连成功时，SDK会调用该函数
	    public class HaveReConnect implements NetSDKLib.fHaveReConnect {
	        public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
	        	System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
	        }
	    }
	}
	
	/**
	 * 登录面板
	 */
	private class LoginPanel extends JPanel {
		/**
		 * 
		 */
		private static final long serialVersionUID = 1L;

		public LoginPanel() {
			setLayout(new FlowLayout());
			setBorderEx(this, "登录", 2);
			
			loginBtn = new JButton("登入");
			logoutBtn = new JButton("登出");
			nameLabel = new JLabel("用户名");
			passwordLabel = new JLabel("密码");
			nameTextArea = new JTextField(m_strUser, 6);
			passwordTextArea = new JPasswordField(m_strPassword, 6);
			ipLabel = new JLabel("设备地址");
			portLabel = new JLabel("端口号");
			ipTextArea = new JTextField(m_strIp, 8);
			portTextArea = new JTextField(m_nPort.toString(), 4);
			
			add(ipLabel);
			add(ipTextArea);
			add(portLabel);
			add(portTextArea);		
			add(nameLabel);
			add(nameTextArea);		
			add(passwordLabel);
			add(passwordTextArea);		
			add(loginBtn);
			add(logoutBtn);	
			
			logoutBtn.setEnabled(false);
			// 登录按钮. 监听事件
			loginBtn.addActionListener(new ActionListener() {		
				public void actionPerformed(ActionEvent e) {
					LoginButtonPerformed();
				}
			});
			
			// 登出按钮. 监听事件
			logoutBtn.addActionListener(new ActionListener() {
				public void actionPerformed(ActionEvent e) {
					LoginOutButtonPerformed();
					stopRealPlay1();
					stopRealPlay2();
					sdkEnv.cleanup();
				}
			});	
		}
	}
	
	/**
	 * 播放面板 1
	 */
	private class RealPlayPanel1 extends PaintPanel {
		/**
		 * 
		 */
		private static final long serialVersionUID = 1L;

		public RealPlayPanel1() {
			setBorderEx(this, "播放窗口1", 2);
			setLayout(new BorderLayout());
			Dimension dim = getPreferredSize();
			dim.width = 410;
			setPreferredSize(dim);	
			
			JPanel jp1 = new JPanel();
			stBtn1 = new JButton("开始监控1");
			endBtn1 = new JButton("停止监控1");
			label1 = new JLabel("通道号:");
			textArea1 = new JTextField("0", 8);
        	stBtn1.setEnabled(false);
        	endBtn1.setEnabled(false);
			
			jp1.setLayout(new FlowLayout());
			jp1.add(stBtn1);
			jp1.add(endBtn1);
			jp1.add(label1);
			jp1.add(textArea1);
			
			realPlayWindow1 = new Panel();
			add(jp1, BorderLayout.NORTH);
			add(realPlayWindow1, BorderLayout.CENTER);
			
			stBtn1.addActionListener(new ActionListener() {
				public void actionPerformed(ActionEvent e) {
					startRealPlay1();					
				}
			});
			
			endBtn1.addActionListener(new ActionListener() {
				public void actionPerformed(ActionEvent e) {
					stopRealPlay1();			
				}
			});
		}
	}
	
	/**
	 * 播放面板2
	 */
	private class RealPlayPanel2 extends PaintPanel {		
		/**
		 * 
		 */
		private static final long serialVersionUID = 1L;

		public RealPlayPanel2() {		
			setLayout(new BorderLayout());
			setBorderEx(this, "播放窗口2", 2);
			Dimension dim = getPreferredSize();
			dim.width = 410;
			setPreferredSize(dim);
			
			JPanel jp2 = new JPanel();
			stBtn2 = new JButton("开始监控2");
			endBtn2 = new JButton("停止监控2");
			label2 = new JLabel("通道号:");
			textArea2 = new JTextField("1", 8);
        	stBtn2.setEnabled(false);
        	endBtn2.setEnabled(false);
			
			jp2.setLayout(new FlowLayout());
			jp2.add(stBtn2);
			jp2.add(endBtn2);
			jp2.add(label2);
			jp2.add(textArea2);
			
			realPlayWindow2 = new Panel();
			add(jp2, BorderLayout.NORTH);
			add(realPlayWindow2, BorderLayout.CENTER);
			
			stBtn2.addActionListener(new ActionListener() {
				public void actionPerformed(ActionEvent e) {
					startRealPlay2();					
				}
			});
			
			endBtn2.addActionListener(new ActionListener() {
				public void actionPerformed(ActionEvent e) {
					stopRealPlay2();				
				}
			});
		}
	}	
	
	//带背景的面板组件
	private class PaintPanel extends JPanel {
		/**
		 * 
		 */
		private static final long serialVersionUID = 1L;
		private Image image; //背景图片	
		
		public PaintPanel() {
			super();
			setOpaque(true); //非透明
			setLayout(null);
			setBackground(new Color(153, 240, 255));
			setForeground(new Color(0, 0, 0));
		}			
		
		protected void paintComponent(Graphics g) {    //重写绘制组件外观
			if(image != null) {
				g.drawImage(image, 0, 0, getWidth(), getHeight(), this);//绘制图片与组件大小相同
			}
			super.paintComponent(g); // 执行超类方法
		}	
	}

    //////////////////////// Border Extends //////////////////////
	/**
	 * 设置边框
	 */
	private void setBorderEx(JComponent object, String title, int width) {
		Border innerBorder = BorderFactory.createTitledBorder(title);
		Border outerBorder = BorderFactory.createEmptyBorder(width, width, width, width);	
		object.setBorder(BorderFactory.createCompoundBorder(outerBorder, innerBorder));
	}
	
	//////////////////////// Operations of PlayBackFrame ////////////////
	
	/**
	 * 登录按钮
	 */
	private void LoginButtonPerformed() {
		m_strIp = ipTextArea.getText();
		m_nPort = Integer.parseInt(portTextArea.getText());
		m_strUser = nameTextArea.getText();
		m_strPassword = new String(passwordTextArea.getPassword());
		
		System.out.println("设备地址：" + m_strIp
						+  "\n端口号：" + m_nPort
						+  "\n用户名：" + m_strUser
						+  "\n密码：" + m_strPassword);
		
		// 登录设备
		IntByReference nError = new IntByReference(0);
        loginHandle = netsdkApi.CLIENT_LoginEx(m_strIp, m_nPort.intValue(), m_strUser , m_strPassword , 0, null, deviceInfo, nError);
        if(loginHandle.longValue() == 0)
        {
            System.err.printf("Login Device[%s] Port[%d]Failed. Last Error[%x]\n" , m_strIp , m_nPort , netsdkApi.CLIENT_GetLastError());
            JOptionPane.showMessageDialog(this, "登录失败");
        }
        else
        {
        	System.out.println("Login Success [ " + m_strIp +" ]");
        	JOptionPane.showMessageDialog(this, "登录成功");
        	logoutBtn.setEnabled(true);
        	loginBtn.setEnabled(false);
        	stBtn1.setEnabled(true);
        	stBtn2.setEnabled(true);
        }
	}
		
	/**
	 * 登出按钮
	 */
	private void LoginOutButtonPerformed() {
		if (loginHandle.longValue() != 0) {
			System.out.println("LogOut Button Action");
  		
			stopRealPlay1();
			stopRealPlay2();
			
    		if (netsdkApi.CLIENT_Logout(loginHandle)) {
	    		System.out.println("Logout Success [ " + m_strIp +" ]");
    			loginHandle.setValue(0);
    			logoutBtn.setEnabled(false);
	        	loginBtn.setEnabled(true);
	        	stBtn1.setEnabled(false);
	        	endBtn1.setEnabled(false);
	        	stBtn2.setEnabled(false);
	        	endBtn2.setEnabled(false);
    		}    		
    	}
	}
	
	// 开始实时预览支持设置码流回调
    private void startRealPlay1() {
		int channel = Integer.parseInt(textArea1.getText()); // 预览通道号， 设备有多通道的情况，可手动更改
		int playType = NetSDKLib.NET_RealPlayType.NET_RType_Realplay; // 实时预览		
		
		m_lOperateHandle1 = netsdkApi.CLIENT_RealPlayEx(loginHandle, channel, Native.getComponentPointer(realPlayWindow1), playType);
		if (m_lOperateHandle1.longValue() == 0) {
			int error = netsdkApi.CLIENT_GetLastError();
			System.err.println("开始实时预览失败，错误码：" + String.format("[0x%x]", error));
		} else {
			System.out.println("Success to start realplay");
			realPlayWindow1.setVisible(true);
			realPlayPanel1.setOpaque(false);// 设置透明
			stBtn1.setEnabled(false);	
			endBtn1.setEnabled(true);
    	}
    }
    private void startRealPlay2() {
		int channel = Integer.parseInt(textArea2.getText()); // 预览通道号， 设备有多通道的情况，可手动更改
		int playType = NetSDKLib.NET_RealPlayType.NET_RType_Realplay; // 实时预览	
		
		m_lOperateHandle2 = netsdkApi.CLIENT_RealPlayEx(loginHandle, channel, Native.getComponentPointer(realPlayWindow2), playType);
		if (m_lOperateHandle2.longValue() == 0) {
			int error = netsdkApi.CLIENT_GetLastError();
			System.err.println("开始实时预览失败，错误码：" + String.format("[0x%x]", error));
		} else {
			System.out.println("Success to start realplay");
			realPlayWindow2.setVisible(true);
			realPlayPanel2.setOpaque(false);
			stBtn2.setEnabled(false);	
			endBtn2.setEnabled(true);
    	}
    }
	
	// 结束实时预览
	private void stopRealPlay1() {
		System.out.println("Stop Tasks!");

		if(!netsdkApi.CLIENT_StopRealPlayEx(m_lOperateHandle1)) {
			return;
		} else {
			System.out.println("StopRealPlay Succeed!");
			m_lOperateHandle1.setValue(0);
			realPlayWindow1.repaint();
			stBtn1.setEnabled(true);
			endBtn1.setEnabled(false);
		}		
	}
	private void stopRealPlay2() {
		System.out.println("Stop Tasks!");
	
		if(!netsdkApi.CLIENT_StopRealPlayEx(m_lOperateHandle2)) {
			return;
		} else {
			System.out.println("StopRealPlay Succeed!");
			m_lOperateHandle2.setValue(0);
			realPlayWindow2.repaint();
			stBtn2.setEnabled(true);
			endBtn2.setEnabled(false);
		}		
	}
	
	public void capturePicture() {
		File pathFile = new File(".");			
		String path = pathFile.getAbsoluteFile().getParent() + "\\RealPlay_" + System.currentTimeMillis() + ".jpg";
		if(netsdkApi.CLIENT_CapturePicture(m_lOperateHandle1, path)) {
			System.out.println(path);
		}
	}
	
	//////////////////////// Components of PlayBackFrame ///////////////
	/**
	 * 登录界面
	 */
	private LoginPanel loginPanel; 
	
	private JButton loginBtn;
	private JButton logoutBtn;
	
	private JLabel nameLabel;
	private JLabel passwordLabel;
	private JTextField nameTextArea;
	private JPasswordField passwordTextArea;
	private JLabel ipLabel;
	private JLabel portLabel;
	private JTextField ipTextArea;
	private JTextField portTextArea;
	
	/**
	 * 播放界面
	 */
	private RealPlayPanel1 realPlayPanel1;
	private RealPlayPanel2 realPlayPanel2;
	private Panel realPlayWindow1;
	private Panel realPlayWindow2;
	private JLabel label1;
	private JTextField textArea1;
	private JLabel label2;
	private JTextField textArea2;
	private JButton stBtn1;
	private JButton endBtn1;
	private JButton stBtn2;
	private JButton endBtn2;
	
	public static void main(String[] args) {
		Preview demo = new Preview();
		demo.setVisible(true);
	}
}