package com.netsdk.demo.frame;

import java.awt.*;
import java.awt.event.*;
import java.text.SimpleDateFormat;
import java.util.*;

import javax.swing.*;
import javax.swing.table.*;

import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;

import com.netsdk.common.BorderEx;
import com.netsdk.common.FunctionList;
import com.netsdk.common.LoginPanel;
import com.netsdk.common.Res;
import com.netsdk.demo.module.AlarmListenModule;
import com.netsdk.demo.module.LoginModule;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.LLong;
import com.netsdk.lib.ToolKits;

/**
 * Alarm Listen Demo
 */
class AlarmListenFrame extends JFrame{
	private static final long serialVersionUID = 1L;
	
	// device disconnect callback instance
	private  DisConnect disConnect  = new DisConnect(); 
	
	// device reconnect callback instance
	private static HaveReConnect haveReConnect = new HaveReConnect(); 
	
	// alarm listen frame (this)
	private static JFrame frame = new JFrame();
	
	private Component  target = this;
	
	// alarm event info list 
    Vector<AlarmEventInfo> data = new Vector<AlarmEventInfo>();

    public AlarmListenFrame() { 	
    	setTitle(Res.string().getAlarmListen());
 	    setLayout(new BorderLayout());
 	    pack();
 	    setSize(800, 530);
 	    setResizable(false);
 	    setLocationRelativeTo(null);
 		LoginModule.init(disConnect, haveReConnect);
 	 
 		try {
            UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
        } catch (Exception e) {
        	e.printStackTrace();
        }
 		
 	    loginPanel = new LoginPanel();
 	    alarmListenPanel = new AlarmListenPanel();
	    showAlarmPanel = new ShowAlarmEventPanel();
	    
	    JSplitPane splitPane = new JSplitPane(JSplitPane.VERTICAL_SPLIT, loginPanel, alarmListenPanel);
	    splitPane.setDividerSize(0);
 	    add(splitPane, BorderLayout.NORTH);
	    add(showAlarmPanel, BorderLayout.CENTER);
        
	    loginPanel.addLoginBtnActionListener(new ActionListener() {
			@Override
			public void actionPerformed(ActionEvent e) {	   	    
				if(loginPanel.checkLoginText()) {
					if(login()) {
						frame = ToolKits.getFrame(e);
						frame.setTitle(Res.string().getAlarmListen() + " : " + Res.string().getOnline());
					}
				}
			}
		});
	    
	    loginPanel.addLogoutBtnActionListener(new ActionListener() {		
			@Override
			public void actionPerformed(ActionEvent e) {
				frame.setTitle(Res.string().getAlarmListen());
				logout();	
			}
		});
        
	    addWindowListener(new WindowAdapter() {
	    	public void windowClosing(WindowEvent e) {
	    		AlarmListenModule.stopListen();
	    		LoginModule.logout();
	    		LoginModule.cleanup();
	    		dispose();	
	    		
	    		SwingUtilities.invokeLater(new Runnable() {
	    			public void run() {
	    				FunctionList demo = new FunctionList();
	    				demo.setVisible(true);
	    			}
	    		});
	    	}
	    });
    }
    
	/////////////////function///////////////////
	// device disconnect callback class 
	// set it's instance by call CLIENT_Init, when device disconnect sdk will call it.
	private class DisConnect implements NetSDKLib.fDisConnect {
		public DisConnect() { }
		
		public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
			System.out.printf("Device[%s] Port[%d] DisConnect!\n", pchDVRIP, nDVRPort);

			SwingUtilities.invokeLater(new Runnable() {
				public void run() {
					frame.setTitle(Res.string().getAlarmListen() + " : " + Res.string().getDisConnectReconnecting());
				}
			});
		}
	}
	
	// device reconnect(success) callback class
	// set it's instance by call CLIENT_SetAutoReconnect, when device reconnect success sdk will call it.
	private static class HaveReConnect implements NetSDKLib.fHaveReConnect {
		public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
			System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
			
			SwingUtilities.invokeLater(new Runnable() {
				public void run() {
					frame.setTitle(Res.string().getAlarmListen() + " : " + Res.string().getOnline());
				}
			});
		}
	}
	
	public boolean login() {
		if(LoginModule.login(loginPanel.ipTextArea.getText(), 
						Integer.parseInt(loginPanel.portTextArea.getText()), 
						loginPanel.nameTextArea.getText(), 
						new String(loginPanel.passwordTextArea.getPassword()))) {
	
			loginPanel.setButtonEnable(true);
			alarmListenPanel.setButtonEnable(true);
			
		} else {
			JOptionPane.showMessageDialog(null, Res.string().getLoginFailed() + ", " + ToolKits.getErrorCodeShow(), Res.string().getErrorMessage(), JOptionPane.ERROR_MESSAGE);
			return false;
		}
		return true;
	}
	
	public void logout() {
		AlarmListenModule.stopListen();
		LoginModule.logout();
		
		loginPanel.setButtonEnable(false);
		alarmListenPanel.initButtonEnable();
		showAlarmPanel.clean();
	}

    public Vector<String> convertAlarmEventInfo(AlarmEventInfo alarmEventInfo) {
        Vector<String> vector = new Vector<String>();
        
        vector.add(String.valueOf(alarmEventInfo.id));
        vector.add(formatDate(alarmEventInfo.date));
        vector.add(String.valueOf(alarmEventInfo.chn));
        String status = null;
        if (alarmEventInfo.status == AlarmStatus.ALARM_START) {
        	status = Res.string().getStart();
        }else {
        	status = Res.string().getStop();
        }
        vector.add(alarmMessageMap.get(alarmEventInfo.type) + status);

        return vector;
    }
    
    private String formatDate(Date date) {
		final SimpleDateFormat simpleDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return simpleDate.format(date);
	}
    
    private fAlarmDataCB cbMessage = new fAlarmDataCB();
    // alarm listen data callback
    private class fAlarmDataCB implements NetSDKLib.fMessCallBack{
    	private final EventQueue eventQueue = Toolkit.getDefaultToolkit().getSystemEventQueue();
         
		@Override
		public boolean invoke(int lCommand, LLong lLoginID,
				Pointer pStuEvent, int dwBufLen, String strDeviceIP,
				NativeLong nDevicePort, Pointer dwUser) {
			 	
			switch (lCommand) {
	                case NetSDKLib.NET_ALARM_ALARM_EX:
	                case NetSDKLib.NET_MOTION_ALARM_EX:
	                case NetSDKLib.NET_VIDEOLOST_ALARM_EX:
	                case NetSDKLib.NET_SHELTER_ALARM_EX:
	                case NetSDKLib.NET_DISKFULL_ALARM_EX:
	                case NetSDKLib.NET_DISKERROR_ALARM_EX: {
	                	byte []alarm = new byte[dwBufLen];
	                	pStuEvent.read(0, alarm, 0, dwBufLen);
	                	for (int i = 0; i < dwBufLen; i++) {
	                		if (alarm[i] == 1) {
                				AlarmEventInfo alarmEventInfo = new AlarmEventInfo(i, lCommand, AlarmStatus.ALARM_START);
                				if (!data.contains(alarmEventInfo)) {
                		            data.add(alarmEventInfo);
	                				eventQueue.postEvent(new AlarmListenEvent(target, alarmEventInfo));
	                			}
	                		}else {
	                			AlarmEventInfo alarmEventInfo = new AlarmEventInfo(i, lCommand, AlarmStatus.ALARM_STOP);
	                			if (data.remove(alarmEventInfo)) {
	                				eventQueue.postEvent(new AlarmListenEvent(target, alarmEventInfo));
	                			}
	                		}
	                	}
	                	break;
	                }
	                default:
	                	break;
	                	
	            }
			
				return true;
		}
    	
    }

    // alarm listen event
	class AlarmListenEvent extends AWTEvent {
		private static final long serialVersionUID = 1L;
		public static final int EVENT_ID = AWTEvent.RESERVED_ID_MAX + 1;
		
		private AlarmEventInfo alarmEventInfo;
		
		public AlarmListenEvent(Object target,
				AlarmEventInfo alarmEventInfo) {
			super(target,EVENT_ID);
			
			this.alarmEventInfo = alarmEventInfo;
			++AlarmEventInfo.index;
			this.alarmEventInfo.id = AlarmEventInfo.index;
		}
		
		public AlarmEventInfo getAlarmEventInfo() {
			return alarmEventInfo;
		}	
	}
	
	@Override
    protected void processEvent( AWTEvent event) {
        if ( event instanceof AlarmListenEvent) {
        	AlarmEventInfo alarmEventInfo = ((AlarmListenEvent)event).getAlarmEventInfo();
        	showAlarmPanel.insert(alarmEventInfo);
		} else {
            super.processEvent(event);   
        }
    } 
    
	// alarm listen control panel
    private class AlarmListenPanel extends JPanel {
    	private static final long serialVersionUID = 1L;
		
		public AlarmListenPanel() {
			BorderEx.set(this, Res.string().getAlarmListen(), 2);
			setLayout(new FlowLayout());
			
			btnStartListen = new JButton(Res.string().getStartListen());
		    btnStopListen = new JButton(Res.string().getStopListen());
		    
		    btnStartListen.setPreferredSize(new Dimension(150, 20));
		    btnStopListen.setPreferredSize(new Dimension(150, 20));
		    
		    add(btnStartListen);
		    add(new JLabel("                  "));
		    add(btnStopListen);
		    
		    initButtonEnable();
		    
		    btnStartListen.addActionListener(new ActionListener(){
				@Override
				public void actionPerformed(ActionEvent e) {
					if (AlarmListenModule.startListen(cbMessage)) {
						setButtonEnable(false);
					}else {
						JOptionPane.showMessageDialog(null, Res.string().getAlarmListenFailed() + "," + ToolKits.getErrorCodeShow(), Res.string().getErrorMessage(), JOptionPane.ERROR_MESSAGE);
					}
				}
		    });
		    
		    btnStopListen.addActionListener(new ActionListener(){
				@Override
				public void actionPerformed(ActionEvent e) {
					if (AlarmListenModule.stopListen()) {
						showAlarmPanel.clean();
						setButtonEnable(true);
					}else {
						JOptionPane.showMessageDialog(null, ToolKits.getErrorCodeShow(), Res.string().getErrorMessage(), JOptionPane.ERROR_MESSAGE);
					}
				}	
		    });
		}
	    
	    public void setButtonEnable(boolean b) {
	    	btnStartListen.setEnabled(b);
	    	btnStopListen.setEnabled(!b);
	    }
	    
	    public void initButtonEnable() {
	    	btnStartListen.setEnabled(false);
	    	btnStopListen.setEnabled(false);
	    }
		
	    private JButton btnStartListen;
	    private JButton btnStopListen;
    }
    
    // alarm listen event show panel
    private class ShowAlarmEventPanel extends JPanel {
    	private static final long serialVersionUID = 1L;
        private final static int MIN_SHOW_LINES = 20;
        private final static int MAX_SHOW_LINES = 100;
        private int currentRowNums = 0;
		
		public ShowAlarmEventPanel() {
			BorderEx.set(this, Res.string().getShowAlarmEvent(), 2);
			setLayout(new BorderLayout());
			
			Vector<String> columnNames =  new Vector<String>();
			columnNames.add(Res.string().getIndex()); 			// index
			columnNames.add(Res.string().getEventTime()); 		// event time
			columnNames.add(Res.string().getChannel()); 		// channel
			columnNames.add(Res.string().getAlarmMessage()); 	// alarm message
			
			tableModel = new DefaultTableModel(null, columnNames);
	        table = new JTable(tableModel) {
				private static final long serialVersionUID = 1L;

				public boolean isCellEditable(int rowIndex, int columnIndex) {
	                return false;
	            }
	        };

	        tableModel.setRowCount(MIN_SHOW_LINES);	// set min show lines
	        
	        table.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);
			
			table.getColumnModel().getColumn(0).setPreferredWidth(90);
			table.getColumnModel().getColumn(1).setPreferredWidth(200);
			table.getColumnModel().getColumn(2).setPreferredWidth(80);
			table.getColumnModel().getColumn(3).setPreferredWidth(400);
			
			table.setAutoResizeMode(JTable.AUTO_RESIZE_OFF);
			table.setAutoscrolls(false);
			
			table.getTableHeader().setReorderingAllowed(false);
//			table.getTableHeader().setResizingAllowed(false);
	
			JScrollPane scrollPane = new JScrollPane(table);
			scrollPane.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
			scrollPane.setHorizontalScrollBarPolicy(JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
			add(scrollPane, BorderLayout.CENTER);
		}
		
		public void insert(AlarmEventInfo alarmEventInfo) {
			tableModel.insertRow(0,convertAlarmEventInfo(alarmEventInfo));
			if (currentRowNums < MAX_SHOW_LINES) {
				++currentRowNums;
			}
			
			if (currentRowNums <= MIN_SHOW_LINES) {
				tableModel.setRowCount(MIN_SHOW_LINES);
			}else if (currentRowNums == MAX_SHOW_LINES) {
				tableModel.setRowCount(MAX_SHOW_LINES);
			}
			
			table.updateUI();
		}
		
		public void clean() {
			currentRowNums = 0;
			data.clear();
			AlarmEventInfo.index=0;
			tableModel.setRowCount(0);
			tableModel.setRowCount(MIN_SHOW_LINES);
			table.updateUI();
		}
		
		private JTable table = null;
		private DefaultTableModel tableModel = null;
    }
    
    private static HashMap<Integer, String> alarmMessageMap = new HashMap<Integer, String>() {
    	
		private static final long serialVersionUID = 1L;

		{
    		put(NetSDKLib.NET_ALARM_ALARM_EX, Res.string().getExternalAlarm());
    		put(NetSDKLib.NET_MOTION_ALARM_EX, Res.string().getMotionAlarm());
    		put(NetSDKLib.NET_VIDEOLOST_ALARM_EX, Res.string().getVideoLostAlarm());
    		put(NetSDKLib.NET_SHELTER_ALARM_EX, Res.string().getShelterAlarm());
    		put(NetSDKLib.NET_DISKFULL_ALARM_EX, Res.string().getDiskFullAlarm());
    		put(NetSDKLib.NET_DISKERROR_ALARM_EX, Res.string().getDiskErrorAlarm());
    	}
    };
    
    private LoginPanel loginPanel;
    private AlarmListenPanel alarmListenPanel;
    private ShowAlarmEventPanel showAlarmPanel;
    
    enum AlarmStatus {
    	ALARM_START, ALARM_STOP
    }
    
    // struct of alarm event
    static class AlarmEventInfo {
    	public static long index = 0;
    	public long id;
    	public int chn;
    	public int type;
    	public Date date;
    	public AlarmStatus status;
        
        public AlarmEventInfo(int chn, int type, AlarmStatus status) {
        	this.chn = chn;
        	this.type = type;
        	this.status = status;
        	this.date = new Date();
        }

        @Override
        public boolean equals(Object o) {
            if (this == o) return true;
            if (o == null || getClass() != o.getClass()) return false;
            AlarmEventInfo showInfo = (AlarmEventInfo) o;
            return chn == showInfo.chn && type == showInfo.type;
        }
    }
    
}

public class AlarmListen {  
	public static void main(String[] args) {	
		SwingUtilities.invokeLater(new Runnable() {
			public void run() {
				AlarmListenFrame demo = new AlarmListenFrame();
				demo.setVisible(true);
			}
		});		
	}
};