package com.vci.client.omd.linktype;

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.FlowLayout;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.table.DefaultTableModel;
import javax.swing.table.JTableHeader;
import org.jdesktop.swingx.JXTable;
import org.jdesktop.swingx.decorator.HighlighterFactory;

import com.vci.corba.common.VCIError;
import com.vci.corba.omd.ltm.LinkType;

public class ConsistencyCheckDialog extends JDialog{

	/**
	 * 
	 */
	private static final long serialVersionUID = 6997597482667501498L;
	Map<String, String> dbCheckMap;
	Map<String, List<String>> btmCheckMap;
	private JPanel centerPanel;
	private JPanel southPanel;
	private JButton btnRepair;
	private JButton btnCancel;
	private JXTable table;
	private DefaultTableModel model;
	private final int TABLE_HEADER_HEIGHT = 25;
	private final int ROW_HEIGHT = 30;
	
	public ConsistencyCheckDialog(Map<String, String> dbCheckMap, Map<String, List<String>> btmCheckMap){
		this.dbCheckMap = dbCheckMap;
		this.btmCheckMap = btmCheckMap;
		initUI();
		addListener();
		initData();
	}

	private void initUI(){
		this.setTitle("修复对话框");
		Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize();
		this.setSize(screenSize.width/2, screenSize.height/2);
		this.setModal(true);
		this.setLocationRelativeTo(null);
		this.setResizable(false);
		this.setLayout(new BorderLayout());
		
		centerPanel = new JPanel();
		centerPanel.setLayout(new BorderLayout());
		southPanel = new JPanel();
		southPanel.setLayout(new FlowLayout(FlowLayout.RIGHT));
		this.add(centerPanel, BorderLayout.CENTER);
		this.add(southPanel, BorderLayout.SOUTH);
		
		table = new JXTable();
		model = new DefaultTableModel();
		model.setColumnCount(3);
		model.setColumnIdentifiers(new String[]{"类型名 ", "操作", "状态"});
		table.setModel(model);
		table.setHorizontalScrollEnabled(true);
		table.setAutoscrolls(true);
		table.setSortable(false);
		table.setHighlighters(HighlighterFactory.createAlternateStriping());
		table.setRowHeight(ROW_HEIGHT);
		//设置表头高度
		JTableHeader tableHeader = table.getTableHeader();
		Dimension size = tableHeader.getPreferredSize();
		size.height = TABLE_HEADER_HEIGHT;
		tableHeader.setPreferredSize(size);
		
		centerPanel.add(new JScrollPane(table), BorderLayout.CENTER);
		
		btnRepair = new JButton("修复");
		btnCancel = new JButton("关闭");
		southPanel.add(btnRepair);
		southPanel.add(btnCancel);
	}
	
	private void initData(){
		table.setEditable(true);
		model.setRowCount(dbCheckMap.size() + btmCheckMap.size());
		int i = 0;
		for(Iterator<String> ite = dbCheckMap.keySet().iterator(); ite.hasNext();){
			String typeName = ite.next();
			String dml = dbCheckMap.get(typeName);
			table.setValueAt(typeName, i, 0);
			String dml_ = dml.replace("_CREATE", "创建表");
			dml_ = dml_.replace("_ADD", "增加列");
			dml_ = dml_.replace("_DROP", "移除列");
			table.setValueAt(dml_, i, 1);
			table.setValueAt("未修复", i, 2);
			i++;
		}
		
		for(Iterator<String> ite = btmCheckMap.keySet().iterator(); ite.hasNext();){
			String typeName = ite.next();
			List<String> btms = btmCheckMap.get(typeName);
			StringBuilder stb = new StringBuilder("移除form端业务类型:");
			StringBuilder stb_ = new StringBuilder("移除to端业务类型:");
			for(int k = 0; k < btms.size(); k++){
				String btm = btms.get(k);
				String btm_ = btm.substring(2);
				if(btm.contains("F_")){
					stb.append(btm_);
					stb.append(",");
				}else{
					stb_.append(btm_);
					stb_.append(",");
				}
			}
			StringBuilder result = new StringBuilder("");
			String stbString = stb.toString();
			if(stbString.contains(",")){
				stbString = stb.substring(0, stbString.lastIndexOf(","));
				result.append(stbString);
			}
			
			String stbString_ = stb_.toString();
			if(stbString_.contains(",")){
				stbString_ = stb_.substring(0, stbString_.lastIndexOf(","));
				if(!result.equals("")){
					result.append(";");
				}
				result.append(stbString_);
			}
			table.setValueAt(typeName, i, 0);
			table.setValueAt(result.toString(), i, 1);
			table.setValueAt("未修复", i, 2);
			i++;
		}
		table.setEditable(false);
	}
	
	private void addListener() {
		btnRepair.addActionListener(new ActionListener() {
			
			@Override
			public void actionPerformed(ActionEvent e) {
				if(dbCheckMap.size() < 1 && btmCheckMap.size() < 1){
					JOptionPane.showMessageDialog(getDialog(), "已经全部成功修复", "已经全部成功修复", JOptionPane.INFORMATION_MESSAGE);
					return;
				}
				if(JOptionPane.YES_OPTION != JOptionPane.showConfirmDialog(
						getDialog(), "修复将改变数据库或类型数据文件的结构", "修复确认框", JOptionPane.YES_NO_OPTION )){
					return;
				}
				if(dbCheckMap.size() > 0){
					List<String> list = getRepairDML();
					if(list.size() < 1){
						return;
					}
					try {
						String[] result = LinkTypeStart.getService().executeRepair(list.toArray(new String[0]));
						updateStatus(result);
					} catch (VCIError e1) {
						e1.printStackTrace();
					}
				}
				
				if(btmCheckMap.size() > 0){
					List<String> result = repairXml();
					updateStatus_(result);
				}
			}

		});
		
		btnCancel.addActionListener(new ActionListener() {
			
			@Override
			public void actionPerformed(ActionEvent e) {
				dipose_();
			}
		});
	}
	
	private void dipose_(){
		this.dispose();
	}
	
	/**
	 * 获取需要修复的伪sql
	 * @return
	 */
	private List<String> getRepairDML() {
		List<String> list = new ArrayList<String>();
		for(Iterator<String> ite = dbCheckMap.keySet().iterator(); ite.hasNext();){
			String type = ite.next();
			String dml = dbCheckMap.get(type);
			list.add(type + "/DML" + dml);
		}
		return list;
	}
	
	/**
	 * 根据修复的结果, 更新table中的状态
	 * 并且将已成功的type, 从 map中移除
	 * 部分成功的, 移除map中value的成功部分
	 * @param result
	 */
	private void updateStatus(String[] result) {
		table.setEditable(true);
		List<String> list = Arrays.asList(result);// LinkTypeProvider.getInstance().parseArrayToList(result);
		for(int i = 0; i < table.getRowCount(); i++){
			String typeName = (String) table.getValueAt(i, 0);
			String operation = (String) table.getValueAt(i, 1);
			//第二列包含"移除业务类型"的需要修改的是链接类型的xml文件
			if(operation.contains("业务类型")){
				continue;
			}
			if(list.contains(typeName)){
				table.setValueAt("已修复", i, 2);
				dbCheckMap.remove(typeName);
			}else if(list.contains(typeName + "_ADD")){
				table.setValueAt("增加已修复", i, 2);
				String sql = dbCheckMap.get(typeName);
				sql = sql.substring(sql.indexOf(";") + 1, sql.length());
				dbCheckMap.put(typeName, sql);
			}else if(list.contains(typeName + "_DROP")){
				table.setValueAt("移除已修复", i, 2);
				String sql = dbCheckMap.get(typeName);
				sql = sql.substring(0, sql.indexOf(";"));
				dbCheckMap.put(typeName, sql);
			}else{
				if(!((String) table.getValueAt(i, 2)).equals("已修复")){
					table.setValueAt("修复失败", i, 2);
				}
			}
		}
		table.updateUI();
		table.setEditable(false);
	}
	
	/**
	 * 根据修复的结果, 更新table中的状态
	 * 并且将已成功的type, 从 map中移除
	 * 部分成功的, 移除map中value的成功部分
	 * @param result
	 */
	private void updateStatus_(List<String> result) {
		table.setEditable(true);
		for(int i = 0; i < table.getRowCount(); i++){
			String typeName = (String) table.getValueAt(i, 0);
			String operation = (String) table.getValueAt(i, 1);
			//第二列包含"移除业务类型"的需要修改的是链接类型的xml文件
			if(operation.contains("业务类型")){
				if(result.contains(typeName)){
					table.setValueAt("已修复", i, 2);
					btmCheckMap.remove(typeName);
				}
			}
		}
		table.updateUI();
		table.setEditable(false);
	}
	
	private JDialog getDialog(){
		return this;
	}
	
	/**
	 * 修复链接类型的xml文件
	 * @return
	 */
	private List<String> repairXml(){
		List<String> result = new ArrayList<String>();
		for(Iterator<String> ite = btmCheckMap.keySet().iterator(); ite.hasNext();){
			String linkName = ite.next();
			List<String> list = btmCheckMap.get(linkName);
			LinkType link = null;
			try {
				link = LinkTypeStart.getService().getLinkType(linkName);
			} catch (VCIError e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
				continue;
			}
			//将list中包含的F_btm移除, 重新设置btmItemsFrom
			String[] btms_ = link.btmItemsFrom;
			List<String> btms = new ArrayList<String>();
			for(int i = 0; i < btms_.length; i++){
				if(!list.contains("F_" + btms_[i])){
					btms.add(btms_[i]);
				}else{
					if(link.primitivesFrom.equals(btms_[i])){
						link.primitivesFrom = "";
					}
				}
			}
			link.btmItemsFrom = btms.toArray(new String[0]);
			
			//将list中包含的T_btm移除, 重新设置btmItemsTo
			btms_ = link.btmItemsTo;
			btms = new ArrayList<String>();
			for(int i = 0; i < btms_.length; i++){
				if(!list.contains("T_" + btms_[i])){
					btms.add(btms_[i]);
				}else{
					if(link.primitivesTo.equals(btms_[i])){
						link.primitivesTo = "";
					}
				}
			}
			link.btmItemsTo = btms.toArray(new String[0]);
			link.id = link.name;
			try {
				if(LinkTypeStart.getService().modifyLinkType(link)){
					result.add(linkName);
				}
			} catch (VCIError e) {
				e.printStackTrace();
			}
		}
		return result;
	}
}