📄 guimsg.java.svn-base
字号:
CollectorDefine.warnmsgArray.clear();
CollectorDefine.statusmsgArray.clear();
CollectorDefine.parammsgArray.clear();
return 1;
}
private int sendmsgarray() {
int count = 0;
count = CollectorDefine.titalmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 titalmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.titalmsgArray.remove(0));
}
count = CollectorDefine.reportmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 reportmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.reportmsgArray.remove(0));
}
count = CollectorDefine.explainmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 explainmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.explainmsgArray.remove(0));
}
count = CollectorDefine.upmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 upmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.upmsgArray.remove(0));
}
count = CollectorDefine.taskwarnmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 taskwarnmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.taskwarnmsgArray.remove(0));
}
count = CollectorDefine.warnmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 warnmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.warnmsgArray.remove(0));
}
count = CollectorDefine.statusmsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 statusmsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.statusmsgArray.remove(0));
}
count = CollectorDefine.parammsgArray.size();
for (int i = 0; i < count; i++) {
System.out.println(" 发送 parammsgArray 到界面！");
writeObject( (JmsObject) CollectorDefine.parammsgArray.remove(0));
}
return 1;
}
private int resetFlag1() {
CollectorDefine.m_ReportTerminal = -1;
CollectorDefine.m_ExplainTerminal = -1;
CollectorDefine.m_ChannelTerminal = -1;
CollectorDefine.m_DataTerminal = -1;
return 1;
}
private int recMsgFromGui() {
int num = 0;
num = this.m_jmsgui.getJmsFront().getCollectorQueueNum();
if (num > 0) {
int i = 0;
JmsObject m_JmsObject = null;
int m_JmsReportType = 0;
for (i = 0; i < num; i++) {
m_JmsObject = (JmsObject)this.m_jmsgui.getJmsFront().getCollectorQueue();
if (m_JmsObject == null) {
continue;
}
recMsgProcess(m_JmsObject);
// m_JmsObject = null;
}
}
// wj add
getNotifyProcess_2();
//
return 1;
}
public int getNotifyProcess_2() {
int num = 0;
ParamModify m_param_modify = null;
try {
//System.out.println( " ready rec jmsfront2 ");
if (this.m_jmsswitch.getJmsFront() != null) {
num = this.m_jmsswitch.getJmsFront().getNotifyQueueNum();
int func_no = 0;
long table_no = 0;
int j = 0;
int flag = -1;
// ArrayList m_arraylist = null;
if (num > 0) {
//System.out.println ("Get a message from AppServer ( jms front )...");
int i = 0;
for (i = 0; i < num; i++) {
m_param_modify = (ParamModify)this.m_jmsswitch.getJmsFront().
getNotifyQueue();
if (m_param_modify == null) {
continue;
}
func_no = m_param_modify.m_func_no;
table_no = m_param_modify.m_table_no;
// m_arraylist = new ArrayList();
CFunction.writeLog("guirec",
" get a message from appserver1 ,id :" +
m_param_modify.toString(), null);
for (int k = 0; k < m_param_modify.m_ids.length; k++) {
//System.out.println ("id=====" + (new Long (m_param_modify.m_ids[i])).toString ());
/* flag = -1;
for (j = 0; j < m_arraylist.size(); j++) {
if (m_param_modify.m_ids[k] ==
( (Long) m_arraylist.get(j)).longValue()) {
flag = 1;
break;
}
}
if (flag == 1) {
continue;
}
*/
if ( ( (ArrayList) m_param_modify.vos).size() < k) {
CFunction.writeLog("guirec",
" getNotifyProcess In AutoCollector Error #1", null);
continue;
}
// m_arraylist.add(new Long(m_param_modify.m_ids[k]));
CFunction.writeLog("guirec",
" get a message from appserver1---1 ,k :" +
k +
"func_no:" + func_no +
"table_no:" + table_no +
"m_param_modify.m_ids[k]:" +
m_param_modify.m_ids[k]
/*(vo)(((ArrayList)m_param_modify.vos).get(k)).toString()*/, null);
this.m_downparam = new DownParam();
this.m_downparam.modiHashTable(func_no, table_no,
m_param_modify.m_ids[k],
m_param_modify.m_nos[k],
(Object) ( (ArrayList)
m_param_modify.vos).get(k),
m_param_modify, k);
}
// m_arraylist = null;
}
}
}
}
catch (Exception e) {
CFunction.writeLog("guirec", "getNotifyProcess In AutoCollector Error 2 ",
e);
}
return 1;
}
private int recMsgProcess(JmsObject m_jmsobject) {
Object object = null;
int report_type = 0;
long reccomputerid = 0;
long sendcomputerid = 0;
long terminalid = -1;
if (m_jmsobject == null) {
return -1;
}
try {
System.out.println("recmsg");
report_type = m_jmsobject.getJmsReportType();
reccomputerid = m_jmsobject.getRecComputerId();
sendcomputerid = m_jmsobject.getSendComputerId();
terminalid = m_jmsobject.getTerminalId();
object = m_jmsobject.getObject();
m_jmsobject.getReportNo();
if (reccomputerid != CollectorDefine.GUI_COMPUTER) {
return -1;
}
MsgProcess(report_type, terminalid, sendcomputerid, object);
m_jmsobject = null;
}
catch (Exception ee) {
return -1;
}
return 1;
}
private int MsgProcess(int report_type, long terminalid, long sendcomputerid,
Object object) {
try {
if (report_type == CollectorDefine.LOGIN_JMS_TYPE) {
System.out.println("*********** 收到 LOGIN_JMS_TYPE ！！！");
CFunction.writeLog("guirec",
"*********** 收到 LOGIN_JMS_TYPE,terminal_id = " +
terminalid +
"object --user count = " +
( (ArrayList) object).size(), null);
if (CollectorDefine.LOGIN_FLAG != true) {
CFunction.writeLog("guirec",
"CollectorDefine.LOGIN_FLAG != true, return ", null);
return -1;
}
if (terminalid == 1) {
//不能登陆
//显示一下已经有的所有用户
Object[] name = new Object[] {
"确定", "注销重名用户"};
Object[] initvalue = new Object[] {
new Integer(1), new Integer(2)};
JOptionPane m_JOptionPane = new JOptionPane();
int value = JOptionPane.showOptionDialog(FrontGuiDefine.m_FrontFrame,
"已经有该用户登陆", "option",
JOptionPane.YES_NO_OPTION,
JOptionPane.QUESTION_MESSAGE,
null, name, null);
if (value == 0) {
CFunction.writeLog("guirec", "已经有该用户登陆, 不再发送Login report ", null);
return -1;
}
else {
CFunction.writeLog("guirec", "已经有该用户登陆, 再发送Login report ", null);
sendLoginMsg(1);
return -1;
}
}
if (terminalid == -1) {
ArrayList m_list = (ArrayList) (object);
CollectorDefine.GuiArray = m_list;
CFunction.writeLog("guirec", "@@@@@@@@@@@@@@@@@@@@@@@@@用户列表", null);
for (int i = 0; i < CollectorDefine.GuiArray.size(); i++) {
GuiObject m_GuiObject = (GuiObject) (CollectorDefine.GuiArray.get(i));
if (m_GuiObject!=null)
System.out.print(m_GuiObject.getUserName() + " ; ");
}
System.out.println();
CFunction.writeLog("guirec", "&&&&&&用户列表", null);
CFunction.writeLog("guirec", "*********** 马上初始化主界面！！！！！", null);
CollectorDefine.LOGIN_FLAG = false;
if (FrontGuiDefine.m_FrontFrame != null) {
FrontGuiDefine.m_FrontFrame.EnableComponents();
FrontGuiDefine.m_FrontFrame.initComputersPanel(false);
this.InitFinished = true;
CFunction.writeLog("guirec",
"*********** 马上初始化主界面 ,this.InitFinished = true ", null);
CollectorDefine.m_InitFinished = true;
}
}
}
else if (report_type == CollectorDefine.GET_LOGIN_USER) {
CFunction.writeLog("guirec",
"收到 GET_LOGIN_USER ！！！," + "*********** user count = " +
( (ArrayList) (object)).size(), null);
ArrayList m_list = (ArrayList) (object);
CollectorDefine.GuiArray = m_list;
FrontGuiDefine.m_UserListDispDialog = null;
FrontGuiDefine.m_UserListDispDialog = new UserListDispDialog(
FrontGuiDefine.m_FrontFrame, false);
FrontGuiDefine.m_UserListDispDialog.show();
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_H) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_H", null);
CollectorDefine.m_h_tasklist = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_M) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_M", null);
CollectorDefine.m_m_tasklist = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_L) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_L", null);
CollectorDefine.m_l_tasklist = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_PURSUE_T) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_PURSUE_T", null);
CollectorDefine.m_pursue_tasklist = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_D) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_D", null);
CollectorDefine.m_dial_tasklist = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_S) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_S", null);
CollectorDefine.m_switchtasks = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_PURSUE_L) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_PURSUE_L", null);
CollectorDefine.m_PursueLinkedList = (LinkedList) object;
}
else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_O) {
if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
return -1;
}
CollectorDefine.m_OntimePursueLinkedList = (LinkedList) object;
if (FrontGuiDefine.m_TaskAssignFrame != null) {
CFunction.writeLog("guirec",
"report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_O", null);
FrontGuiDefine.m_TaskAssignFrame.initTaskList();
}
else
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -