📄 processormsgthread.java
字号:
}
}
catch (Exception ex) {
}
}
log.info("--------(xiao ling tong) str path:" + str);
return str;
}
public void smsprocessor() {
Connection conn = null, updateConn = null;
boolean success = false;
String svccode = "";
String helpservletname = "";
log.info("--------(xiao ling tong) start to deal thing!");
try {
helpservletname =
"http://localhost/xlttelephone/servlet/com.mdream.servlet.helpservletname"; //帮助处理的servlet名称
conn = DBMgr.getCon("qqqsms");
updateConn = DBMgr.getCon("qqqsms");
PreparedStatement stmt = conn.prepareStatement(
"select * from tdeliver where isdeal = 0");
PreparedStatement updateStmt = updateConn.prepareStatement(
"update tdeliver set isdeal = 1 where u_id = ?");
ResultSet rs = stmt.executeQuery(); //找到没有处理的记录条
log.info(
"--------(xiao ling tong) processor to start to deal add get data");
try {
rs.next();
rs.beforeFirst();
}
catch (SQLException e) {
log.info("--------(xiao ling tong) rs is null");
}
while (rs.next()) { //处理所有的条
log.info("--------(xiao ling tong) deal tiao/per");
String u_id = rs.getString("u_id");
String msgfrom = rs.getString("SrcTermID").trim();
String msgTo = rs.getString("DestTermID").trim();
String msgContent = rs.getString("MsgContent").trim();
msgContent = msgContent.trim();
log.info("--------(" + msgTo + ") Process SMS : " +
u_id);
log.info("--------(" + msgTo + ") sms_from : " +
msgfrom);
log.info("--------(" + msgTo + ") msgTo : " + msgTo);
log.info("--------(" + msgTo + ") msgContent : " +
msgContent);
if (msgContent != null) {
msgContent = msgContent.toUpperCase();
log.info(
"--------(xiao ling tong) processor smsprocessor msgContent : " +
msgContent);
if (IsCanDealCommand(msgContent, msgTo)) {
log.info("can deal");
if (msgfrom.equals("1188888")) {
if (GetSynCode(msgContent, 1).equals("1001")) {
savecancelmsg(GetSynCode(msgContent, 2), msgfrom, msgTo,
"1001 0 " + GetSynCode(msgContent, 2) + " " +
GetSynCode(msgContent, 3), 2);
}
else if (GetSynCode(msgContent, 1).equals("1002")) {
String unsubmsg = "";
if (GetSynCode(msgContent, 2).equalsIgnoreCase("WMQR")) {
unsubmsg = "QX1";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("GTBG")) {
unsubmsg = "QX2";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("MRXY")) {
unsubmsg = "QX3";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXJQ")) {
unsubmsg = "QX4";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("YXYX")) {
unsubmsg = "QX5";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("YXDQ")) {
unsubmsg = "QX6";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXQC")) {
unsubmsg = "QX7";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXAC")) {
unsubmsg = "QX8";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXXH")) {
unsubmsg = "QX9";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXKX")) {
unsubmsg = "QX10";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXQH")) {
unsubmsg = "QX11";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXZF")) {
unsubmsg = "QX12";
}
else if (GetSynCode(msgContent, 2).equalsIgnoreCase("YXJM")) {
unsubmsg = "QX13";
}
String cancelservletname =
"http://localhost/xlttelephone/servlet/com.mdream.servlet.DoUnSub";
sendrequest(cancelservletname, "FREE", GetSynCode(msgContent, 3),
msgTo, unsubmsg,
u_id + "");
Thread.sleep(1000);
if (doCheckSynStatus(GetSynCode(msgContent, 2),
GetSynCode(msgContent, 3), "1002")) {
savecancelmsg(GetSynCode(msgContent, 2), msgfrom, msgTo,
"1002 0 " + GetSynCode(msgContent, 2) + " " +
GetSynCode(msgContent, 3), 1);
InsertCenterData(GetSynCode(msgContent, 2),GetSynCode(msgContent, 3),3);
}
else {
savecancelmsg(GetSynCode(msgContent, 2), msgfrom, msgTo,
"1002 1 " + GetSynCode(msgContent, 2) + " " +
GetSynCode(msgContent, 3), 1);
}
}
else if (GetSynCode(msgContent, 1).equals("1003")) {
camceluserall(GetSynCode(msgContent, 2));
if (doCheckSynStatus("all", GetSynCode(msgContent, 2), "1003")) {
savecancelmsg("all", msgfrom, msgTo,
"1003 0 " + GetSynCode(msgContent, 2), 1);
}
else {
savecancelmsg("all", msgfrom, msgTo,
"1003 1 " + GetSynCode(msgContent, 2), 1);
}
}
if (GetSynCode(msgContent, 1).equals("1000")) {
log.info("RealReguser");
/*if (GetSynCode(msgContent, 2).equalsIgnoreCase("XXQH")) {
savecancelmsg(GetSynCode(msgContent, 2),
GetSynCode(msgContent, 3), msgTo,
"回复1上传你最想对爱人说的一句话2小小测试,测测你俩的爱情指数3下载最流行的甜言蜜语送给她/他");
}*/
RealReguser(GetSynCode(msgContent, 2), GetSynCode(msgContent, 3));
}
else if (GetSynCode(msgContent, 1).equals("2001")) {
log.info("SubRealReguser");
if (GetSynCode(msgContent, 2).equals("0")) {
RealReguser(GetSynCode(msgContent, 3),
GetSynCode(msgContent, 4));
}
else {
log.info("subregister failed ,retry it");
/*savecancelmsg(GetSynCode(msgContent, 3), msgfrom, msgTo,
"2001 " + GetSynCode(msgContent, 3)+" "+GetSynCode(msgContent, 4), 2);*/
}
}
else if (GetSynCode(msgContent, 1).equals("2002")) {
if (GetSynCode(msgContent, 2).equals("0")) {
log.info("the user has unregister the service " +
GetSynCode(msgContent, 3) +
" successfully");
}
else {
log.info("the user unregistered the service " +
GetSynCode(msgContent, 3) +
"failed,retry it");
/*savecancelmsg(GetSynCode(msgContent, 3), msgfrom, msgTo,
"2002 " + GetSynCode(msgContent, 3)+" "+GetSynCode(msgContent, 4), 1);*/
}
}
else if (GetSynCode(msgContent, 1).equals("2003")) {
if (GetSynCode(msgContent, 2).equals("0")) {
log.info(
"the user has unregister all service successfully!");
}
else {
log.info("unregister all service failed,retry it");
/*savecancelmsg("ALL", msgfrom, msgTo,
"2003 "+GetSynCode(msgContent, 4), 0);*/
}
}
else if (GetSynCode(msgContent, 1).equals("3001")) {
InsertMfee(GetSynCode(msgContent, 2), GetSynCode(msgContent, 3),
GetSynCode(msgContent, 4), GetSynCode(msgContent, 5));
}
}
else if (msgContent.equals("00000")) {
svccode = "HELP";
if (camceluserall(msgfrom)) {
String svcInfo =
"您已经取消了杭州联梦提供的所有小灵通业务，谢谢您的使用！客服：8008571837";
savecancelmsg(svccode, msgfrom, msgTo, svcInfo);
log.info(svcInfo);
}
else {
log.info(
"--------------(xiao ling tong) cancel operation to error!!!");
String svcInfo =
"您取消联梦小灵通业务的操作有误，确定要取消请回复00000";
savecancelmsg(svccode, msgfrom, msgTo, svcInfo);
}
}
else if (checkdailysend(msgTo)) {
log.info("checkdailysend(msgTo)");
String reply = "对不起，请直接回复数字1、或2、3、4。您还可以发送JQ到5888体验都市男女激情派对。";
//if(msgContent.equalsIgnoreCase("1")||msgContent.equalsIgnoreCase("2")||msgContent.equalsIgnoreCase("3")||msgContent.equalsIgnoreCase("4")){
reply = getanswer(msgContent, msgTo);
//}
doSendMessage(msgfrom, msgTo, "DXQQ", reply, "");
}
/*else if(msgTo.startsWith("5888")&&(msgContent.equalsIgnoreCase("1")||msgContent.equalsIgnoreCase("2")||msgContent.equalsIgnoreCase("3")||msgContent.equalsIgnoreCase("4"))){
svccode = "DXQQ";
if(msgContent.equalsIgnoreCase("1")){
doSendMessage(msgfrom, msgTo, svccode,
"眼睛是灵魂之窗，象徵着你的灵性。你是爱他的，你们之间的爱情十分纯洁，是那种纯纯的爱",
"");
}else if(msgContent.equalsIgnoreCase("2")){
doSendMessage(msgfrom, msgTo, svccode,
"嘴唇是一个敏感的地方，发展至极至便是“性”。因此，你们可能是为性爱而结合的伴侣",
"");
}else if(msgContent.equalsIgnoreCase("3")){
doSendMessage(msgfrom, msgTo, svccode,
"额头代表信赖与安全感，你们之间的感情，接近于相互信赖的朋友关系",
"");
}else if(msgContent.equalsIgnoreCase("4")){
doSendMessage(msgfrom, msgTo, svccode,
"脸颊是代表大部分人。但可能是为了钱才和他交往的，你们的感情是为经济，商业而结合的",
"");
}
}*/
/*else if (doChangeMsgContent(msgContent).toUpperCase().startsWith(
"JQ")) {
if (doChangeMsgContent(msgContent).substring(2).length() < 5) {
int wnumber = doGetNameNumber(doChangeMsgContent(msgContent).
substring(2));
doSendNameCipher(msgfrom, msgTo, "HELP", wnumber);
if (doCheckBallReg(msgfrom)) {
log.info(
"the user has alread registered the football service!!!");
}
else {
doregstep1(msgfrom);
}
}
else {
savecancelmsg("HELP", msgfrom, "5888",
"您的输入指令有误，透彻生日的玄机，把握人生的运程。直接回复JQ+您的“姓名”查看结果！");
}
}*/
else if (msgTo.equalsIgnoreCase("58888881")) {
//2005－12－06号活动，相爱不一定适合相处,在同一个屋檐下生活了,你一定想知道今后的日子是甜蜜幸福还是战火纷飞,回复KX做个测试你会找到答案
if (msgContent.equalsIgnoreCase("KX")) {
doSendMessage(msgfrom, msgTo, svccode,
"我们中有一个人对开支和收入了如指掌，而另一个人则对管钱不感兴趣。回复G加数字选择（例G1）",
"");
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -