📄 message.java
字号:
// Decompiled by Jad v1.5.7g. Copyright 2000 Pavel Kouznetsov.
// Jad home page: http://www.geocities.com/SiliconValley/Bridge/8617/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi
// Source File Name: message.java
import com.aspire.cmppApi.*;
import java.io.PrintStream;
import database.*;
public class message
{
static int nConnFlag = 0;
public int code;
public Apis cm;
int sends;
boolean debugMode;
SendMessage SendMessage1;
public message()
{
sends = 0;
cm = new Apis();
SendMessage1 = new SendMessage();
}
public String getPath()
{
return "c:/wtbs/";
//return System.getProperty("user.dir")+"\\";
}
public int sendActive()
{
int i =0;
if(code >= 0)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
RecCActiveTest reccactivetest = new RecCActiveTest();
recccmpppacket.nCmdId = 8;
recccmpppacket.recActiveTest = reccactivetest;
i = cm.nCMPP_SendPacket(recccmpppacket);
System.out.println("nCMPP_SendActive:" + i);
}
return i;
}
public void sendActiveRep()
{
if(code >= 0)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
RecCActiveTestRep reccactivetestrep = new RecCActiveTestRep();
recccmpppacket.nCmdId = 0x80000008;
reccactivetestrep.nSeqId = 100;
reccactivetestrep.ucSuccId = 0;
recccmpppacket.recActiveTestRep = reccactivetestrep;
cm.nCMPP_SendPacket(recccmpppacket);
System.out.println("nCMPP_SendActiveRep:" + code);
}
}
public void sendCancel()
{
if(code >= 0)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
RecCCancel recccancel = new RecCCancel();
recccmpppacket.nCmdId = 7;
recccancel.usMsgId = 100L;
recccmpppacket.recCancel = recccancel;
int i = cm.nCMPP_SendPacket(recccmpppacket);
System.out.println("nCMPP_SendCancel:" + i);
}
}
public int sendConnect()
{
int code1 =0;
if(nConnFlag == 1)
return 0;
nConnFlag = 1;
String filePath = String.valueOf(String.valueOf(getPath())).concat("api.ini");
code = cm.nCMPP_Init(filePath);
sends = 0;
if(code >= 0)
{
for(int i = 0; i < 1; i++)
{
System.out.println(cm.SPID);
System.out.println(cm.SPPassword);
System.out.println(cm.hostIp);
System.out.println(cm.port);
code1 = cm.nCMPP_Connect();
System.out.println("nCMPP_Connect:" +i);
if(code1 >= 0)
{
nConnFlag = 0;
}
try
{
Thread.sleep(100L);
}
catch(InterruptedException ie)
{
System.out.println("sleep fail");
}
}
return code1;
}
else
{
System.out.println(" Initial failed...");
return -1;
}
}
public int sendDeliverRep(long l,int k)
{
int i =0;
if(code >= 0)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
RecCDeliverRep reccdeliverrep = new RecCDeliverRep();
recccmpppacket.nCmdId = 0x80000005;
reccdeliverrep.nSeqId = k;
reccdeliverrep.usMsgId = l;
reccdeliverrep.ucResult = 0;
recccmpppacket.recDeliverRep = reccdeliverrep;
i = cm.nCMPP_SendPacket(recccmpppacket);
System.out.println("nCMPP_SendPacket:" + i);
}
return i;
}
public void sendQuery()
{
if(code >= 0)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
RecCQuery reccquery = new RecCQuery();
reccquery.sTime = "20020318";
reccquery.ucQueryType = 1;
reccquery.sQueryCode = "0011";
reccquery.usReserve = "tian";
recccmpppacket.nCmdId = 6;
recccmpppacket.recQuery = reccquery;
int i = cm.nCMPP_SendPacket(recccmpppacket);
System.out.println("nCMPP_SendPacket:" + i);
}
}
public int sendSubmit()
{
int j =0;
//System.out.println("sendSubmit call:" + sends);
if(code >= 0)
{
database.SmsDetails details =new SmsDetails();
database.OperDatabase opdata2 =new database.OperDatabase();
details =opdata2.GetMT();
if(details.Sms_ID!=-1)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
// String s = "Deliver test !!heysgf";
//String s="welcome to hsh21!!";
byte tmp[] = new byte[8];
for(int i = 0; i < 8; i++)
tmp[i] = 0;
tmp[5] = 1;
if(details.Sms_FeeType.Equals("03"))
{
String s ="8001 "+details.Sms_MsgID+" 0";
try
{
byte[] q =s.getBytes("Unicode");
byte[] w=new byte[q.length];
//byte[] w = s.getBytes("GB2321");
//byte[] e = s.getBytes("GBK");
//byte[] r = s.getBytes("ASCII");
for(int a=0;a<q.length;a+=2)
{
w[a]=q[a+1];
w[a+1]=q[a];
}
RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit = reccsubmit;
recccmpppacket.recSubmit.nSeqId = details.Sms_SeqID;
// int ucFeeUserType, String sFeeTerminalId, int ucFeeTermType, int ucTpPid, int ucTpUdhi, int ucMsgFmt,
//usMsgId信息标识//ucPkTotal//ucPkNumber//ucRegister求返回状态确认报告//ucMsgLevel//sServiceId业务类型//ucFeeUserType计费用户类型字段//sFeeTermId计费用户的号码//ucTpPid//ucTpUdhi//ucMsgFmt信息格式//sMsgSrc(SP_ID)//sFeeType资费类别//sFeeCode资费代码//sAtTime定时发送时间//sSrcTermId源终端MSISDN号码//usReserve
int i = cm.nCMPP_PrepSubmit(recccmpppacket.recSubmit, tmp, 1, 1, 1, 1,details.Sms_ServiceID, details.Sms_Fee_UserType, "", 0, 0, 8, "903152", details.Sms_FeeType, details.Sms_FeeCode, "", details.Sms_SPCode, "");
System.out.println("nCMPP_PrepSubmit:" + i);
j = cm.nCMPP_SendSubmit(recccmpppacket.recSubmit, "", "01862",w.length, w);
System.out.println("nCMPP_SendSubmit:" + j);
//自定义群发语
// String s = "Deliver test !!heysgf";
//String s="welcome to hsh21!!";
details =opdata2.GetMT();
if(details.Sms_ID!=-1)
{
// RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit = reccsubmit;
recccmpppacket.recSubmit.nSeqId = details.Sms_SeqID;
//usMsgId信息标识//ucPkTotal//ucPkNumber//ucRegister求返回状态确认报告//ucMsgLevel//sServiceId业务类型//ucFeeUserType计费用户类型字段//sFeeTermId计费用户的号码//ucTpPid//ucTpUdhi//ucMsgFmt信息格式//sMsgSrc(SP_ID)//sFeeType资费类别//sFeeCode资费代码//sAtTime定时发送时间//sSrcTermId源终端MSISDN号码//usReserve
int f = cm.nCMPP_PrepSubmit(recccmpppacket.recSubmit, tmp, 1, 1, 1, 1,details.Sms_ServiceID, details.Sms_Fee_UserType, "", 0, 0, 15, "903152", details.Sms_FeeType, details.Sms_FeeCode, "", details.Sms_SPCode, "");
System.out.println("nCMPP_PrepSubmit:" + f);
j = cm.nCMPP_SendSubmit(recccmpppacket.recSubmit, "", details.Sms_Dest_Terminal_ID,details.Sms_Msg_Content.getBytes().length, details.Sms_Msg_Content.getBytes());
System.out.println("nCMPP_SendSubmit:" + j);
if(j > 0)
sends++;
}
}
catch(Exception ee)
{
System.out.println(ee.getMessage());
SendMessage1.SendMessage("发送定制业务消息失败"+ee.getMessage());
}
}
else
{
try
{
RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit = reccsubmit;// RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit.nSeqId = details.Sms_SeqID;
//usMsgId信息标识//ucPkTotal//ucPkNumber//ucRegister求返回状态确认报告//ucMsgLevel//sServiceId业务类型//ucFeeUserType计费用户类型字段//sFeeTermId计费用户的号码//ucTpPid//ucTpUdhi//ucMsgFmt信息格式//sMsgSrc(SP_ID)//sFeeType资费类别//sFeeCode资费代码//sAtTime定时发送时间//sSrcTermId源终端MSISDN号码//usReserve
int i = cm.nCMPP_PrepSubmit(recccmpppacket.recSubmit, tmp, 1, 1, 1, 1,details.Sms_ServiceID, details.Sms_Fee_UserType, "", 0, 0, 15, "903152", details.Sms_FeeType, details.Sms_FeeCode, "", details.Sms_SPCode, "");
System.out.println("nCMPP_PrepSubmit:" + i);
j = cm.nCMPP_SendSubmit(recccmpppacket.recSubmit, "", details.Sms_Dest_Terminal_ID,details.Sms_Msg_Content.getBytes().length, details.Sms_Msg_Content.getBytes());
System.out.println("nCMPP_SendSubmit:" + j);
}
catch(Exception ea)
{
SendMessage1.SendMessage("发送点播消息失败"+ea.getMessage());
}
}
}
else
{
j=-1;
}
}
return j;
}
/*
public int sendSubmit()
{
int j =0;
int f =0;
//System.out.println("sendSubmit call:" + sends);
if(code >= 0)
{
RecCCMPPPacket recccmpppacket = new RecCCMPPPacket();
// String s = "Deliver test !!heysgf";
//String s="welcome to hsh21!!";
byte tmp[] = new byte[8];
for(int i = 0; i < 8; i++)
{
tmp[i] = 0;
tmp[5] = 1;
}
/*
database.SmsDetails details =new SmsDetails();
database.OperDatabase opdata2 =new database.OperDatabase();
details =opdata2.GetMT();
if(details.Sms_FeeType.Equals("03"))
{
String s ="8001 "+usMsgId+" 0";
try
{
byte[] q =s.getBytes("Unicode");
byte[] w=new byte[q.length];
//byte[] w = s.getBytes("GB2321");
//byte[] e = s.getBytes("GBK");
//byte[] r = s.getBytes("ASCII");
for(int a=0;a<q.length;a+=2)
{
w[a]=q[a+1];
w[a+1]=q[a];
}
RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit = reccsubmit;// int ucFeeUserType, String sFeeTerminalId, int ucFeeTermType, int ucTpPid, int ucTpUdhi, int ucMsgFmt,
//usMsgId信息标识//ucPkTotal//ucPkNumber//ucRegister求返回状态确认报告//ucMsgLevel//sServiceId业务类型//ucFeeUserType计费用户类型字段//sFeeTermId计费用户的号码//ucTpPid//ucTpUdhi//ucMsgFmt信息格式//sMsgSrc(SP_ID)//sFeeType资费类别//sFeeCode资费代码//sAtTime定时发送时间//sSrcTermId源终端MSISDN号码//usReserve
int i = cm.nCMPP_PrepSubmit(recccmpppacket.recSubmit, tmp, 1, 1, 1, 1,details.Sms_ServiceID, details.Sms_Fee_UserType, "", 0, 0, 8, "903152", details.Sms_FeeType, details.Sms_FeeCode, "", details.Sms_SPCode, "");
System.out.println("nCMPP_PrepSubmit:" + i);
j = cm.nCMPP_SendSubmit(recccmpppacket.recSubmit, "", "01862",w.length, w);
System.out.println("nCMPP_SendSubmit:" + j);
}
catch(Exception ee)
{
System.out.println(ee.getMessage());
}
}
// else if(details.Sms_SPCode!=null)
//{
RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit = reccsubmit;// RecCSubmit reccsubmit = new RecCSubmit();
recccmpppacket.recSubmit = reccsubmit;
//usMsgId信息标识//ucPkTotal//ucPkNumber//ucRegister求返回状态确认报告//ucMsgLevel//sServiceId业务类型//ucFeeUserType计费用户类型字段//sFeeTermId计费用户的号码//ucTpPid//ucTpUdhi//ucMsgFmt信息格式//sMsgSrc(SP_ID)//sFeeType资费类别//sFeeCode资费代码//sAtTime定时发送时间//sSrcTermId源终端MSISDN号码//usReserve
int i = cm.nCMPP_PrepSubmit(recccmpppacket.recSubmit, tmp, 1, 1, 1, 1,"TBY", 0, "", 0, 0, 15, "903152","01", "000000", "", "0211103", "");
System.out.println("nCMPP_PrepSubmit:" + sends);
String s ="华神信息公司移动平台压力测试，50条";
j = cm.nCMPP_SendSubmit(recccmpppacket.recSubmit, "", "8613931863141",s.getBytes().length, s.getBytes());
System.out.println("nCMPP_SendSubmit:" + sends);
if(j > 0)
sends++;
}
return j;
}
*/
public void sendTermiante()
{
if(code >= 0)
{
code = cm.nCMPP_Terminate();
System.out.println("nCMPP_Terminate:" + code);
}
else
{
System.out.println(" Initial failed...");
}
}
public void sendTermianteRep()
{
if(code >= 0)
{
RecCTerminateRep reccterminaterep = new RecCTerminateRep();
reccterminaterep.nSeqId = 100;
int i = cm.nCMPP_ReplyTerminate(reccterminaterep);
System.out.println("nCMPP_Terminate:" + i);
}
else
{
System.out.println(" Initial failed...");
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -