📄 transact.java
字号:
// mytest.GetStatus(1)+","+
// Mytest.GetStatus(2)+","+
// Mytest.GetStatus(3)+","+
// Mytest.GetStatus(4)+","+
// Mytest.GetStatus(5)+","+
// Mytest.GetStatus(6)+","+
// Mytest.GetStatus(7)+
// "...."
// );
try{Thread.sleep(5000);}catch(InterruptedException e){} //延时等待
}
}else{
rc=mytest.SendMsg(-1,Phone,"您有需要处理的车辆预约，请注意查收！");
while(flasg) //循环等待发送成功,并显示接收信息, Ctrl-C 退出循环
{
String [] s = mytest.ReadMsgEx(-1);
if(s[0].equals("-1")) {
// System.out.println("-无信息-----");
} else {
System.out.println(s[0]);
System.out.println(s[1]);
String [] ss=s[1].split(",");
//System.out.println("ss---------------"+ss[0]);
if(ss[0].equals("1")){
flasg=false;
//if(k==0){
// out.println("<Script Language='javaScript'>");
// out.println("alert('发送成功！');");
// out.println("history.go(-1);");
// out.println("</Script>");
//}
}else{
rc=mytest.SendMsg(-1,ss[3],"您有需要处理的车辆预约，请注意查收！");
if(ss[0].equals("1")){
flasg=false;
//if(k==0){
// out.println("<Script Language='javaScript'>");
// out.println("alert('发送成功！');");
//out.println("history.go(-1);");
// out.println("</Script>");
//}
}else if(ss[0].equals("2")){
flasg=false;
//if(j==1){
///out.println("<Script Language='javaScript'>");
//out.println("alert('发送失败！');");
// out.println("history.go(-1);");
// out.println("</Script>");
//}
}else if(ss[0].equals("3")||ss[0].equals("4")){
flasg=false;
//if(l==1){
// out.println("<Script Language='javaScript'>");
// out.println("alert('发送超时！');");
// out.println("history.go(-1);");
// out.println("</Script>");
//}
}
}
// n=j+l;
// if(n!=0){
// //for(int o=0;o<n;o++){
// k=0;
// }
//}
System.out.println(s[2]);
}
// System.out.println("...."+ //显示各个端口的状态
// mytest.GetStatus(0)+","+
// mytest.GetStatus(1)+","+
// Mytest.GetStatus(2)+","+
// Mytest.GetStatus(3)+","+
// Mytest.GetStatus(4)+","+
// Mytest.GetStatus(5)+","+
// Mytest.GetStatus(6)+","+
// Mytest.GetStatus(7)+
// "...."
// );
try{Thread.sleep(5000);}catch(InterruptedException e){} //延时等待
}
}
//发送一条信息,从可以使用的任意端口
//rc=Mytest.SendMsg(0,"13691000000","测试信息，恭喜发财!"); //发送一条信息,指定第一个端口
//rc=Mytest.SendMsg(1,"13691000000","测试信息，恭喜发财!"); //发送一条信息,制定第二个端口
//--Wap Push 测试------------------------
//wapResult=Mytest.WapPushCvt("测试网站发送", "http://wap.mbook.cn"); //生产Push编码
//rc=Mytest.SendMsg(-1,"13691000000,001,2,123321,1,0",wapResult[1]); //发送push信息
//mytest.CloseModem(-1);
if(rc>=0){
System.out.println("提交成功, rc="+rc);
} else {
System.out.println("提交错误, rc="+rc);
}
} else {
System.out.println("初始化错误!"+rc);
}
}
}
else
super.strMessage = dataAction.getMessage();
}
catch(Exception e)
{
throw e;
}
}
public void flowNodePassMultipart(Request rq, String SWLB, int iXXID, String sXXBM, int iBLID, UserInfor userInfor)
{
try
{
String str_today = Convert.dateToString(new java.util.Date());
String opinion = Convert.uploadGBK(rq.getParameter("opinion_flow"));
String current_branch = "0";
current_branch = getBLFZ(iBLID);
// System.out.println("current_branch================="+current_branch);
String flow_begin = str_today;
int iBLGRZT = 1;
setCurrentNode(iBLID, iBLGRZT, opinion, flow_begin);
String template_id = rq.getParameter("template_id_flow");
String node_id = rq.getParameter("node_id_flow");
String node_id_pre = rq.getParameter("node_id_pre_flow");
String node_sign_count = rq.getParameter("node_sign_count_flow");
String meet_sign_count = rq.getParameter("meet_sign_flow");
DataAction dataAction = new DataAction(super.dataConn);
if (!template_id.equals("0")) {
super.sCond = String.valueOf(String.valueOf((new StringBuffer(
"SWLB='")).append(SWLB).append("' and BLXXID=").append(
iXXID).append(" and XXBM='").append(sXXBM).
append(
"' and BLLCID=").append(template_id).append(
" and BLFZ='").append(current_branch).
append("'")));
dataAction.update("LC_BL", "BLSYRS = BLSYRS -1", super.sCond);
}
FactNode factNode = null;
factNode = new FactNode(super.dataConn);
int iMeetSign = 0;
if (!template_id.equals("0"))
iMeetSign = factNode.getMeetSign(Integer.parseInt(node_id_pre));
// if (iMeetSign == 0) {
// super.sCond = String.valueOf(String.valueOf((new StringBuffer(
// "BLGRZT=0 AND SWLB='")).append(SWLB).append(
// "' and BLXXID=").append(iXXID).append(" and XXBM='").
// append(sXXBM).append("' and BLLCID=").append(
// template_id).append(" and BLID<>").append(iBLID)));
// dataAction.update("LC_BL", "BLGRZT=4", super.sCond);
// }
int iTransactNum = 0;
iTransactNum = getTransactNum(iBLID);
mondem mytest = new mondem();
if (iTransactNum == 0)
genNextNodeMultipart(rq, SWLB, iXXID, sXXBM, iBLID);
int rc;
//String[] wapResult=new String[3];
boolean flasg = true;
rc = mytest.SetThreadMode(1); //开启线程模式
if (rc == 0) {
System.out.println("设置线程模式成功");
} else {
System.out.println("设置线程模式失败");
return;
}
mytest.SetModemType(0, 0);
mytest.SetModemType(1, 0);
mytest.SetModemType(2, 0);
mytest.SetModemType(3, 0);
mytest.SetModemType(4, 0);
mytest.SetModemType(5, 0);
mytest.SetModemType(6, 0);
mytest.SetModemType(7, 0);
if ((rc = (mytest.InitModem( -1))) == 0) { //初始化短信猫
// System.out.println("初始化成功");
// if(sXXBM.equals("OA_FWWZ")){
//--------普通短信测试-------------
super.sSQL = String.valueOf(String.valueOf((new StringBuffer("select WZSJ from OA_TXWZ where WZID in (select BLRY from LC_BL where BLGRZT!=1 and BLQQ=").
append(iBLID).append(
" and BLXXID = (select BLXXID from LC_BL where BLID=").
append(iBLID).append("))"))));
// System.out.println("sql======="+super.sSQL);
super.stmt = super.conn.createStatement();
super.rs = super.stmt.executeQuery(super.sSQL);
// super.arrayList = new ArrayList();
for (; super.rs.next(); ) {
String Phone = rs.getString(1);
//System.out.println("Phone------------" + Phone);
if(sXXBM.equals("OA_FWWZ")){
rc = mytest.SendMsg( -1, Phone,
userInfor.getYGXM() + "向您转交了公文，请及时处理！");
}else if(sXXBM.equals("OA_HY_JBB")){
rc = mytest.SendMsg( -1, Phone,"您有需审批的会议计划，请及时处理！");
}else{
rc = mytest.SendMsg( -1, Phone,"您有需要处理的车辆预约，请注意查收！");
}
// flasg=false;
while (flasg) { //循环等待发送成功,并显示接收信息, Ctrl-C 退出循环
String[] s = mytest.ReadMsgEx( -1);
if (s[0].equals("-1")) {
// System.out.println("-无信息-----");
} else {
System.out.println(s[0]);
System.out.println(s[1]);
String[] ss = s[1].split(",");
//System.out.println("ss---------------"+ss[0]);
if (ss[0].equals("1")) {
flasg = false;
//if(k==0){
// out.println("<Script Language='javaScript'>");
// out.println("alert('发送成功！');");
// out.println("history.go(-1);");
// out.println("</Script>");
//}
} else {
if(sXXBM.equals("OA_FWWZ")){
rc = mytest.SendMsg( -1,ss[3],
userInfor.getYGXM() + "向您转交了公文，请及时处理！");
}else if(sXXBM.equals("OA_HY_JBB")){
rc = mytest.SendMsg( -1, ss[3],"您有需审批的会议计划，请及时处理！");
}else{
rc = mytest.SendMsg( -1, ss[3],"您有需要处理的车辆预约，请注意查收！");
}
if (ss[0].equals("1")) {
flasg = false;
//if(k==0){
// out.println("<Script Language='javaScript'>");
// out.println("alert('发送成功！');");
//out.println("history.go(-1);");
// out.println("</Script>");
//}
} else if (ss[0].equals("2")) {
flasg = false;
//if(j==1){
///out.println("<Script Language='javaScript'>");
//out.println("alert('发送失败！');");
// out.println("history.go(-1);");
// out.println("</Script>");
//}
} else if (ss[0].equals("3") ||
ss[0].equals("4")) {
flasg = false;
//if(l==1){
// out.println("<Script Language='javaScript'>");
// out.println("alert('发送超时！');");
// out.println("history.go(-1);");
// out.println("</Script>");
//}
}
}
// n=j+l;
// if(n!=0){
// //for(int o=0;o<n;o++){
// k=0;
// }
//}
System.out.println(s[2]);
}
// System.out.println("...."+ //显示各个端口的状态
// mytest.GetStatus(0)+","+
// mytest.GetStatus(1)+","+
// Mytest.GetStatus(2)+","+
// Mytest.GetStatus(3)+","+
// Mytest.GetStatus(4)+","+
// Mytest.GetStatus(5)+","+
// Mytest.GetStatus(6)+","+
// Mytest.GetStatus(7)+
// "...."
// );
try {
Thread.sleep(5000);
} catch (InterruptedException e) {} //延时等待
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -