package com.vci.client.omd.btm.ui;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
import javax.swing.JOptionPane;

import com.vci.corba.common.VCIError;
import com.vci.mw.InvocationUtility;

@Deprecated 	
public class Xml2DBActionListener implements ActionListener{
	public static final String SP = "sp";
	public static final String BT = "bt";
	public static final String LT = "lt";
	public static final String LC = "lc";
	public static final String VR = "vr";
	public static final String ATT = "att";
	public static final String ENUM = "enum";
	
	public static final String LTSQL = "create table pllinktype (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),description varchar2(256), ts timestamp(6),creator varchar2(64), createtime timestamp(6),modifier varchar2(64),modifytime timestamp(6),content xmltype,CONSTRAINT PK_linktype PRIMARY KEY (oid),CONSTRAINT IDX_linktype_NAME unique (NAME))";
	public static final String BTSQL = "create table plbtmtype (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),description varchar2(256),ts timestamp(6),creator varchar2(64),createtime timestamp(6),modifier varchar2(64),modifytime timestamp(6),content xmltype,CONSTRAINT PK_btmtype PRIMARY KEY (oid),CONSTRAINT IDX_BTMTYPE_NAME unique (NAME))";
	public static final String ATTSQL = "create table plattribute (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),description varchar2(256),ts timestamp(6),creator varchar2(64),createtime timestamp(6),modifier varchar2(64), modifytime timestamp(6),content xmltype,CONSTRAINT PK_attribute PRIMARY KEY (oid),CONSTRAINT IDX_attribute_NAME unique (NAME))";
	public static final String ENUMSQL = "create table plenum (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),ts timestamp(6),creator varchar2(64),createtime timestamp(6),modifier varchar2(64),modifytime timestamp(6),content xmltype,CONSTRAINT PK_enum PRIMARY KEY (oid),CONSTRAINT IDX_enum_NAME unique (NAME))";
	public static final String LCSQL = "create table pllifecycle (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),description varchar2(256),ts timestamp(6),creator varchar2(64),createtime timestamp(6),modifier varchar2(64),modifytime timestamp(6),content xmltype,CONSTRAINT PK_lifecycle PRIMARY KEY (oid),CONSTRAINT IDX_lifecycle_NAME unique (NAME))";
	public static final String VRSQL = "create table plversionrule (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),description varchar2(256),ts timestamp(6),creator varchar2(64),createtime timestamp(6),modifier varchar2(64),modifytime timestamp(6),content xmltype,CONSTRAINT PK_versionrule PRIMARY KEY (oid),CONSTRAINT IDX_versionrule_NAME unique (NAME))";
	public static final String SPSQL = "create table plstatepool (oid varchar2(64) not null,name varchar2(128) not null,label varchar2(256),description varchar2(256),ts timestamp(6),creator varchar2(64),createtime timestamp(6),modifier varchar2(64),modifytime timestamp(6),content xmltype,CONSTRAINT PK_statepool PRIMARY KEY (oid),CONSTRAINT IDX_statepool_NAME unique (NAME))";
	@Override
	public void actionPerformed(ActionEvent e) {
		if(JOptionPane.OK_OPTION != JOptionPane.showConfirmDialog(null, "迁移将覆盖原有数据", "迁移将覆盖原有数据", JOptionPane.OK_CANCEL_OPTION)){
			return;
		}
		try {
			BtmClient.getService().checkTable("pllinktype", LTSQL);
			BtmClient.getService().checkTable("plbtmtype", BTSQL);
			BtmClient.getService().checkTable("plattribute", ATTSQL);
			BtmClient.getService().checkTable("plenum", ENUMSQL);
			BtmClient.getService().checkTable("pllifecycle", LCSQL);
			BtmClient.getService().checkTable("plversionrule", VRSQL);
			BtmClient.getService().checkTable("plstatepool", SPSQL);
			
			BtmClient.getService().truncateTable("pllinktype");
			BtmClient.getService().truncateTable("plbtmtype");
			BtmClient.getService().truncateTable("pllifecycle");
			BtmClient.getService().truncateTable("plstatepool");
			BtmClient.getService().truncateTable("plversionrule");
			BtmClient.getService().truncateTable("plattribute");
			BtmClient.getService().truncateTable("plenum");
		} catch (VCIError e2) {
			e2.printStackTrace();
		}
		Map<String, Boolean> rs = new HashMap<String, Boolean>();
		String userName = InvocationUtility.getInvocation().userName;
		CountDownLatch countDown = new CountDownLatch(7);
		new Thread(new Xml2DBRunnableSP(userName, rs, countDown)).start();
		new Thread(new Xml2DBRunnableVR(userName, rs, countDown)).start();
		new Thread(new Xml2DBRunnableLC(userName, rs, countDown)).start();
		new Thread(new Xml2DBRunnableEnum(userName, rs, countDown)).start();
		new Thread(new Xml2DBRunnableAtt(userName, rs, countDown)).start();
		new Thread(new Xml2DBRunnableBtm(userName, rs, countDown)).start();
		new Thread(new Xml2DBRunnableLT(userName, rs, countDown)).start();
		try {
			countDown.await();
			Boolean spFlag = rs.get(SP);
			Boolean btFlag = rs.get(BT);
			Boolean ltFlag = rs.get(LT);
			Boolean lcFlag = rs.get(LC);
			Boolean vrFlag = rs.get(VR);
			Boolean attFlag = rs.get(ATT);
			Boolean eFlag = rs.get(ENUM);
			StringBuilder stb = new StringBuilder();
			stb.append("业务类型:" + (btFlag ? "成功" : "失败") + "\n");
			stb.append("链接类型:" + (ltFlag ? "成功" : "失败") + "\n");
			stb.append("属性池:" + (attFlag ? "成功" : "失败") + "\n");
			stb.append("枚举:" + (eFlag ? "成功" : "失败") + "\n");
			stb.append("状态池:" + (spFlag ? "成功" : "失败") + "\n");
			stb.append("生命周期:" + (lcFlag ? "成功" : "失败") + "\n");
			stb.append("版本规则:" + (vrFlag ? "成功" : "失败") + "\n");
			JOptionPane.showMessageDialog(null, stb.toString(), "迁移结果", JOptionPane.INFORMATION_MESSAGE);
		} catch (InterruptedException e1) {
			e1.printStackTrace();
		}
	}

}

class Xml2DBRunnableBtm implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	
	public Xml2DBRunnableBtm(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
		try {
			boolean flag = false;//BtmClient.getService().xml2DB(userName);
			rs.put(Xml2DBActionListener.BT, flag);
			countDownLatch.countDown();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

class Xml2DBRunnableEnum implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	
	public Xml2DBRunnableEnum(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
		try {
			boolean flag = false;//EnumClient.getService().xml2DB(userName);
			rs.put(Xml2DBActionListener.ENUM, flag);
			countDownLatch.countDown();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

class Xml2DBRunnableAtt implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	public Xml2DBRunnableAtt(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
		try {
			boolean flag = false;//APClient.getService().xml2DB(userName);
			rs.put(Xml2DBActionListener.ATT, flag);
			countDownLatch.countDown();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

class Xml2DBRunnableSP implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	public Xml2DBRunnableSP(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
		try {
			boolean flag = false;//StatePoolStart.getService().xml2DB(userName);
			rs.put(Xml2DBActionListener.SP, flag);
			countDownLatch.countDown();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

class Xml2DBRunnableVR implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	
	public Xml2DBRunnableVR(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
		try {
			boolean flag = false;//VRClientStart.getService().xml2DB(userName);
			rs.put(Xml2DBActionListener.VR, flag);
			countDownLatch.countDown();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

class Xml2DBRunnableLC implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	
	public Xml2DBRunnableLC(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
		try {
			boolean flag = false;//LifeCycleStart.getService().xml2DB(userName);
			rs.put(Xml2DBActionListener.LC, flag);
			countDownLatch.countDown();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

class Xml2DBRunnableLT implements Runnable {
	private String userName;
	private Map<String, Boolean> rs;
	private CountDownLatch countDownLatch;
	
	public Xml2DBRunnableLT(String userName, Map<String, Boolean> rs, CountDownLatch countDown){
		this.userName = userName;
		this.rs = rs;
		this.countDownLatch = countDown;
	}
	public void run() {
//		try {
//			boolean flag = LinkTypeProvider.getInstance().getService().xml2DB(userName);
//			rs.put(Xml2DBActionListener.LT, flag);
//			countDownLatch.countDown();
//		} catch (VCIError e) {
//			e.printStackTrace();
//		}
	}
}