📄 zteforunconntemplet.java
字号:
package com.wireless.crbt.gwif.threadpool;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Add_Ring;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Add_Ring_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Bind_RC;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Bind_RC_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Bind_SR;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Bind_SR_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Close;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Close_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Del_Ring;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Del_Ring_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Enquire_Link;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Generic_Nack_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Get_Password;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Get_Password_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Login;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Login_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Name_Query;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Name_Query_Rsp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_On_Off;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_On_Off_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Open;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Open_Rsp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Password;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Password_Resp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Present;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Present_Rsp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Query2;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Query2_Rsp;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Unbind;
import com.wireless.crbt.gwif.ZTEforUN.Crbt_Unbind_Resp;
//import com.wireless.crbt.gwif.function.CrbtScanDB;
import com.wireless.crbt.gwif.global.CRBT;
import com.wireless.crbt.gwif.global.CrbtGWIFGlobal;
import com.wireless.crbt.gwif.global.GetCRBTGlobalForUsual;
import com.wireless.crbt.gwif.global.LoggerConstant;
import com.wireless.crbt.gwif.global.Util;
import com.wireless.crbt.gwif.netty2.CrbtGwifClientDefaultConnTemplet;
import com.wireless.crbt.gwif.workthread.CrbtClientController;
import com.wireless.crbt.gwif.workthread.CrbtSendMonitor;
public class ZTEforUNConnTemplet extends CrbtGwifClientDefaultConnTemplet{
// private static String testtype = null;
// private int cyclenum;
// private static int sendtype = 0;//标识下发的crbt类型
// private String sou_addr_6;//此域为消息源地址，表示消息发起的原始发起方地址描述字串。 同步方式下该域保留。
// private String des_addr_6;//此域为消息目的地址，表示消息希望到达的终端地址描述字串。 同步方式下该域保留
// private String seq_no_10;//此域表示一个序列号，使用在异步通信模式下，由消息发起者设定，应答者对应给回此序列号。
// //序列号范围：0000000000－9999999999，循环使用。 同步方式下该域保留
// /**Crbt配置**/
// String craccount_20;
// String crid_20;
// String ret1_10;
// String srcflag_1;
// String srcIpaddr_20;
// String srcPrice_4;
// String ringtype_4;
// String Old_pass_8;
// String New_pass_8;
// String Receiver_20;
// String mobile_number_20;
// String password_8;
// String Oper_id_1;
// String User_type_2;
// String ringName_40;
public void processSendConnect() {
LoggerConstant.log.info("------发送 CRBT_BIND_RC!------");
Crbt_Bind_RC CBR=new Crbt_Bind_RC();
CBR.setDes_addr_6("123456");//目的地址
CBR.setSou_addr_6("789101");//源发送地址
CBR.setSeq_no_10(Util.getSeq_no());//序列号
CBR.setVersion_flag_2("10");
CBR.setAuth_method_2("01");
this.write(CBR.getBytes());
LoggerConstant.printCrbt_Bind_RC(log, CBR);
LoggerConstant.log.info("------CRBT_BIND_RC 发送完毕！------");
this.setIdleFlag(true);//测试用，非测试时屏蔽
this.startSendT();//测试用，非测试时屏蔽
}//004208010101000000000000000000000000000000
public void processSend() {
CrbtSendMonitor.getInstance().setSendFlag(true);
try{
if(GetCRBTGlobalForUsual.crbtqueue.size()>0){
LoggerConstant.log.info("-------crbtqueue.size():"+GetCRBTGlobalForUsual.crbtqueue.size());
CRBT crbt = (CRBT)GetCRBTGlobalForUsual.crbtqueue.removeNoWait();
byte[] ba;
int sendtype =crbt.getSendtype();
LoggerConstant.log.info("-------sendtype:"+sendtype);
switch(sendtype){
case 1:
ba = processCrbt_Add_Ring(crbt);
break;
case 2:
ba = processCrbt_Close(crbt);
break;
case 3:
ba = processCrbt_Del_Ring(crbt);
break;
case 4:
ba = processCrbt_Get_Password(crbt);
break;
case 5:
ba = processCrbt_Login(crbt);
break;
case 6:
ba = processCrbt_Name_Query(crbt);
break;
case 7:
ba = processCrbt_On_Off(crbt);
break;
case 8:
ba = processCrbt_Open(crbt);
break;
case 9:
ba = processCrbt_Password(crbt);
break;
case 10:
ba = processCrbt_Present(crbt);
break;
case 11:
ba = processCrbt_Query2(crbt);
break;
default:
LoggerConstant.log.error("-------错误类型的sendType！");
ba = null;
}
if(ba!=null){
// LoggerConstant.log.info("-------ba != null");
// this.write(ba);
}else{
LoggerConstant.log.info("-------ba == null！");
}
}
}catch(Exception e){
}finally{
CrbtSendMonitor.getInstance().setSendFlag(false);
}
}
private byte[] processCrbt_Add_Ring(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Add_Ring");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("craccount_20:"+crbt.getCraccount_20());
LoggerConstant.log.info("crid_20:"+crbt.getCrid_20());
LoggerConstant.log.info("ret1_10:"+crbt.getRet1_10());
LoggerConstant.log.info("srcflag_1:"+crbt.getSrcflag_1());
LoggerConstant.log.info("srcIpaddr_20:"+crbt.getSrcIpaddr_20());
LoggerConstant.log.info("srcPrice_4:"+crbt.getSrcPrice_4());
LoggerConstant.log.info("ringtype_4:"+crbt.getRingtype_4());
Crbt_Add_Ring CAR = new Crbt_Add_Ring();
CAR.setSou_addr_6(crbt.getSou_addr_6());
CAR.setDes_addr_6(crbt.getDes_addr_6());
CAR.setSeq_no_10(crbt.getSeq_no_10());
CAR.setCraccount_20(crbt.getCraccount_20());
CAR.setCrid_20(crbt.getCrid_20());
CAR.setRet1_10(crbt.getRet1_10());
CAR.setSrcflag_1(crbt.getSrcflag_1());
CAR.setSrcIpaddr_20(crbt.getSrcIpaddr_20());
CAR.setSrcPrice_4(crbt.getSrcPrice_4());
CAR.setRingtype_4(crbt.getRingtype_4());
this.write(CAR.getBytes());
LoggerConstant.log.info("------Crbt_Add_Ring发送完毕！");
return CAR.getBytes();
}
private byte[] processCrbt_Close(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Close");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("mobile_number_20:"+crbt.getMobile_number_20());
LoggerConstant.log.info("password_8:"+crbt.getPassword_8());
Crbt_Close CC = new Crbt_Close();
CC.setSou_addr_6(crbt.getSou_addr_6());
CC.setDes_addr_6(crbt.getDes_addr_6());
CC.setSeq_no_10(crbt.getSeq_no_10());
CC.setMobile_number_20(crbt.getMobile_number_20());
CC.setPassword_8(crbt.getPassword_8());
this.write(CC.getBytes());
LoggerConstant.log.info("------Crbt_Close发送完毕！");
return CC.getBytes();
}
private byte[] processCrbt_Del_Ring(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Del_Ring");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("craccount_20:"+crbt.getCraccount_20());
LoggerConstant.log.info("crid_20:"+crbt.getCrid_20());
LoggerConstant.log.info("ret1_10:"+crbt.getRet1_10());
LoggerConstant.log.info("srcflag_1:"+crbt.getSrcflag_1());
LoggerConstant.log.info("srcIpaddr_20:"+crbt.getSrcIpaddr_20());
LoggerConstant.log.info("ringtype_4:"+crbt.getRingtype_4());
Crbt_Del_Ring CDR = new Crbt_Del_Ring();
CDR.setSou_addr_6(crbt.getSou_addr_6());
CDR.setDes_addr_6(crbt.getDes_addr_6());
CDR.setSeq_no_10(crbt.getSeq_no_10());
CDR.setCraccount_20(crbt.getCraccount_20());
CDR.setCrid_20(crbt.getCrid_20());
CDR.setRet1_10(crbt.getRet1_10());
CDR.setSrcflag_1(crbt.getSrcflag_1());
CDR.setSrcIpaddr_20(crbt.getSrcIpaddr_20());
CDR.setSrcRingIDType_4(crbt.getRingtype_4());
this.write(CDR.getBytes());
LoggerConstant.log.info("------Crbt_Del_Ring发送完毕！");
return CDR.getBytes();
}
private byte[] processCrbt_Get_Password(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Get_Password");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("craccount_20:"+crbt.getCraccount_20());
Crbt_Get_Password CGP = new Crbt_Get_Password();
CGP.setSou_addr_6(crbt.getSou_addr_6());
CGP.setDes_addr_6(crbt.getDes_addr_6());
CGP.setSeq_no_10(crbt.getSeq_no_10());
CGP.setCraccount_20(crbt.getCraccount_20());
this.write(CGP.getBytes());
LoggerConstant.log.info("------Crbt_Get_password发送完毕！");
return CGP.getBytes();
}
private byte[] processCrbt_Login(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Login");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("craccount_20:"+crbt.getCraccount_20());
LoggerConstant.log.info("password_8:"+crbt.getPassword_8());
Crbt_Login CL = new Crbt_Login();
CL.setSou_addr_6(crbt.getSou_addr_6());
CL.setDes_addr_6(crbt.getDes_addr_6());
CL.setSeq_no_10(crbt.getSeq_no_10());
CL.setCraccount_20(crbt.getCraccount_20());
CL.setPassword_8(crbt.getPassword_8());
this.write(CL.getBytes());
LoggerConstant.log.info("------Crbt_Login发送完毕！");
return CL.getBytes();
}
private byte[] processCrbt_Name_Query(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Name_Query");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("ringName_40:"+crbt.getRingName_40());
Crbt_Name_Query CNQ = new Crbt_Name_Query();
CNQ.setSou_addr_6(crbt.getSou_addr_6());
CNQ.setDes_addr_6(crbt.getDes_addr_6());
CNQ.setSeq_no_10(crbt.getSeq_no_10());
CNQ.setRingName_40(crbt.getRingName_40());
this.write(CNQ.getBytes());
LoggerConstant.log.info("------Crbt_Name_Query发送完毕！");
return CNQ.getBytes();
}
private byte[] processCrbt_On_Off(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_On_Off");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("mobile_number_20:"+crbt.getMobile_number_20());
LoggerConstant.log.info("password_8:"+crbt.getPassword_8());
LoggerConstant.log.info("Oper_id_1:"+crbt.getOper_id_1());
Crbt_On_Off COO = new Crbt_On_Off();
COO.setSou_addr_6(crbt.getSou_addr_6());
COO.setDes_addr_6(crbt.getDes_addr_6());
COO.setSeq_no_10(crbt.getSeq_no_10());
COO.setCraccount_20(crbt.getMobile_number_20());
COO.setPassword_8(crbt.getPassword_8());
COO.setOper_id_1(crbt.getOper_id_1());
this.write(COO.getBytes());
LoggerConstant.log.info("------Crbt_On_Off发送完毕！");
return COO.getBytes();
}
private byte[] processCrbt_Open(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Open");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("mobile_number_20:"+crbt.getMobile_number_20());
LoggerConstant.log.info("password_8:"+crbt.getPassword_8());
LoggerConstant.log.info("User_type_2:"+crbt.getUser_type_2());
Crbt_Open CO = new Crbt_Open();
CO.setSou_addr_6(crbt.getSou_addr_6());
CO.setDes_addr_6(crbt.getDes_addr_6());
CO.setSeq_no_10(crbt.getSeq_no_10());
CO.setMobile_number_20(crbt.getMobile_number_20());
CO.setPassword_8(crbt.getPassword_8());
CO.setUser_type_2(crbt.getUser_type_2());
this.write(CO.getBytes());
LoggerConstant.log.info("------Crbt_Open发送完毕！");
return CO.getBytes();
}
private byte[] processCrbt_Password(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Password");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("craccount_20:"+crbt.getCraccount_20());
LoggerConstant.log.info("Old_pass_8:"+crbt.getOld_pass_8());
LoggerConstant.log.info("New_pass_8:"+crbt.getNew_pass_8());
LoggerConstant.log.info("ret1_10:"+crbt.getRet1_10());
Crbt_Password CP = new Crbt_Password();
CP.setSou_addr_6(crbt.getSou_addr_6());
CP.setDes_addr_6(crbt.getDes_addr_6());
CP.setSeq_no_10(crbt.getSeq_no_10());
CP.setCraccount_20(crbt.getCraccount_20());
CP.setOld_pass_8(crbt.getOld_pass_8());
CP.setNew_pass_8(crbt.getNew_pass_8());
CP.setRet1_10(crbt.getRet1_10());
this.write(CP.getBytes());
LoggerConstant.log.info("------Crbt_Password发送完毕！");
return CP.getBytes();
}
private byte[] processCrbt_Present(CRBT crbt){
LoggerConstant.log.info("------发送Crbt_Present");
LoggerConstant.log.info("Sou_addr_6:"+crbt.getSou_addr_6());
LoggerConstant.log.info("Des_addr_6:"+crbt.getDes_addr_6());
LoggerConstant.log.info("Seq_no_10:"+crbt.getSeq_no_10());
LoggerConstant.log.info("craccount_20:"+crbt.getCraccount_20());
LoggerConstant.log.info("Receiver_20:"+crbt.getReceiver_20());
LoggerConstant.log.info("crid_20:"+crbt.getCrid_20());
Crbt_Present CP = new Crbt_Present();
CP.setSou_addr_6(crbt.getSou_addr_6());
CP.setDes_addr_6(crbt.getDes_addr_6());
CP.setSeq_no_10(crbt.getSeq_no_10());
CP.setCraccount_20(crbt.getCraccount_20());
CP.setReceiver_20(crbt.getReceiver_20());
CP.setCrid_20(crbt.getCrid_20());
this.write(CP.getBytes());
LoggerConstant.log.info("------Crbt_Present发送完毕！");
return CP.getBytes();
}
private byte[] processCrbt_Query2(CRBT crbt){
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -