smsdeliverthread.java

WAP PUSH后台源码,WAP PUSH后台源码

                              pays=rs.getDouble("pays");
                              serverType=rs.getString("serverType");
                              if(rs.getString("orderCustomize").equals(m_messageContent)){
                                   bj1=1;//定制
                              }else{
                                   if(rs.getString("orderGuide").equals(m_messageContent)){
                                        bj1=2;//点播
                                   }else{
                                        bj1=3;//取消
                                   }
                              }
                         }else{
                              bj1=0;//不存在服务
                         }
                         stmt.close();

                         long queueID=0;
                         String destination="";
                         //String sourceAddr="";
                         //String destinationAddr=mobileNo;
                         //String content="";
                         content="";
                         short submitMulti=0;
                         int fileNum=0;
                         //long userID=myMember.getUserID();
                         String corpID="";
                         String serviceType="";
                         String spNumber="";
                         int feeType=1;//0 1免费 2收费 3包月费 4sp实现收费
                         String feeValue="0";
                         String givenValue="0";
                         int morelatetoMTFlag=0;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                         int reportFlag=1;//0出错返回 1一定返回 2不返回 3报月

                         SMSQueue smsqueue=null;
                         switch(bj1){
                              case 0:
                                   queueID=KeyContainer.getNewSequence(m_dbConn,"tsmsqueuid");
                                   destination=m_userNumber;
                                   //String sourceAddr="";
                                   //String destinationAddr=mobileNo;
                                   //String content="";
                                   content="您定制的服务不存在，请参考www.165xj.com";
                                   submitMulti=0;
                                   fileNum=0;
                                   //long userID=myMember.getUserID();
                                   spNumber=SysConfig.getParamValue(m_dbConn,"ASMS","spNumber");
                                   serviceType=SysConfig.getParamValue(m_dbConn,"ASMS","serviceType");//mf
                                   corpID=SysConfig.getParamValue(m_dbConn,"ASMS","corpID");
                                   feeType=1;//0 1免费 2收费 3包月费 4sp实现收费
                                   feeValue="0";
                                   givenValue="0";
                                   morelatetoMTFlag=0;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                                   reportFlag=1;//0出错返回 1一定返回 2不返回 3报月

                                   smsqueue=new SMSQueue();
                                   smsqueue.insert(m_dbConn,queueID,"86"+spNumber,"86"+destination,content,submitMulti,fileNum,
                                            spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);
                                   break;
                              case 1:
                                   sql="select mobileNo from tsmscust where mobileNo=? and serverID=? and statusID=0";
                                   stmt=m_dbConn.prepareStatement(sql);
                                   stmt.setString(1,m_userNumber);
                                   stmt.setInt(2,serverID);
                                   rs=stmt.executeQuery();
                                   bj2=0;
                                   if(rs.next()){
                                        bj2=1;
                                   }
                                   stmt.close();
                                   if(bj2!=1){
                                        int customizeID=(int)KeyContainer.getNewSequence(m_dbConn,"TSMSCUSTID");
                                        sql="insert into tsmscust (customizeID,serverID,mobileNo,statusID,lTStatusID,confirmAdvise,LASTDATE,FIRSTDATE) values (?,?,?,?,?,?,SYSDATE,SYSDATE)";
                                        stmt=m_dbConn.prepareStatement(sql);
                                        stmt.setInt(1,customizeID);
                                        stmt.setInt(2,serverID);
                                        stmt.setString(3,m_userNumber);
                                        stmt.setInt(4,0);
                                        stmt.setInt(5,0);
                                        stmt.setString(6,"");
                                        bj3=stmt.executeUpdate();
                                        stmt.close();
                                        if(bj3==0){
                                             content="您定制信息没有成功，请参考www.165xj.com";
                                        }else{
                                             if(payType==0){

                                             queueID=KeyContainer.getNewSequence(m_dbConn,"tsmsqueuid");
                                             destination=m_userNumber;
                                             //String sourceAddr="";
                                             //String destinationAddr=mobileNo;
                                             //String content="";
                                             content="包月信息";
                                             submitMulti=0;
                                             fileNum=0;
                                             //long userID=myMember.getUserID();
                                             spNumber=SysConfig.getParamValue(m_dbConn,"ASMS","spNumber");
                                             serviceType=serverType;
                                             corpID=SysConfig.getParamValue(m_dbConn,"ASMS","corpID");
                                             //if(payType==0){
                                                  feeType=3;//0 1免费 2收费 3包月费 4sp实现收费
                                             //}else{
                                             //     feeType=2;
                                             //}
                                             feeValue=Double.toString(pays*100);
                                             givenValue="0";
                                             morelatetoMTFlag=3;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                                             //if(payType==0){
                                                  reportFlag=3;//0出错返回 1一定返回 2不返回 3报月
                                             //}else{
                                             //     reportFlag=1;
                                             //}
                                             smsqueue=new SMSQueue();
                                             smsqueue.insert(m_dbConn,queueID,"86"+spNumber,"86"+destination,content,submitMulti,fileNum,
                                                      spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);
                                             }

                                             content="您定制信息成功，欢迎您使用www.165xj.com服务";
                                        }
                                   }else{
                                        content="您已经定制过该信息，欢迎您使用www.165xj.com服务";
                                   }
                                   queueID=KeyContainer.getNewSequence(m_dbConn,"tsmsqueuid");
                                   destination=m_userNumber;
                                   //String sourceAddr="";
                                   //String destinationAddr=mobileNo;
                                   //String content="";
                                   submitMulti=0;
                                   fileNum=0;
                                   //long userID=myMember.getUserID();
                                   spNumber=SysConfig.getParamValue(m_dbConn,"ASMS","spNumber");
                                   serviceType=SysConfig.getParamValue(m_dbConn,"ASMS","serviceType");//mf
                                   corpID=SysConfig.getParamValue(m_dbConn,"ASMS","corpID");
                                   feeType=1;//0 1免费 2收费 3包月费 4sp实现收费
                                   feeValue="0";
                                   givenValue="0";
                                   morelatetoMTFlag=0;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                                   reportFlag=1;//0出错返回 1一定返回 2不返回 3报月

                                   smsqueue=new SMSQueue();
                                   smsqueue.insert(m_dbConn,queueID,"86"+spNumber,"86"+destination,content,submitMulti,fileNum,
                                            spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);

                                   break;
                              case 2:
                                   sql="select sendContent from tsrvsend where serverID=?";
                                   stmt=m_dbConn.prepareStatement(sql);
                                   stmt.setInt(1,serverID);
                                   rs=stmt.executeQuery();
                                   Vector v=new Vector();
                                   while(rs.next()){
                                        v.add(rs.getString("sendContent"));
                                   }
                                   stmt.close();
                                   if(v.size()>0){
                                        if(payType==0){
                                             feeValue="10";
                                        }else{
                                             feeValue=Double.toString(pays*100);
                                        }
                                        i=0;
                                        while(i<v.size()){
                                             queueID=KeyContainer.getNewSequence(m_dbConn,"tsmsqueuid");
                                             destination=m_userNumber;
                                             //String sourceAddr="";
                                             //String destinationAddr=mobileNo;
                                             //String content="";
                                             content=(String)v.get(i);
                                             submitMulti=0;
                                             fileNum=0;
                                             //long userID=myMember.getUserID();
                                             spNumber=SysConfig.getParamValue(m_dbConn,"ASMS","spNumber");
                                             serviceType=SysConfig.getParamValue(m_dbConn,"ASMS","serviceType1");//webdx
                                             corpID=SysConfig.getParamValue(m_dbConn,"ASMS","corpID");
                                             feeType=2;//0 1免费 2收费 3包月费 4sp实现收费
                                             //feeValue=Double.toString(pays*100);
                                             givenValue="0";
                                             morelatetoMTFlag=2;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                                             reportFlag=1;//0出错返回 1一定返回 2不返回 3报月

                                             smsqueue=new SMSQueue();
                                             smsqueue.insert(m_dbConn,queueID,"86"+spNumber,"86"+destination,content,submitMulti,fileNum,
                                                      spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);
                                             i++;
                                        }

                                   }else{
                                        queueID=KeyContainer.getNewSequence(m_dbConn,"tsmsqueuid");
                                        destination=m_userNumber;
                                        //String sourceAddr="";
                                        //String destinationAddr=mobileNo;
                                        //String content="";
                                        content="您点播服务暂时没有信息，欢迎您使用www.165xj.com服务";
                                        submitMulti=0;
                                        fileNum=0;
                                        //long userID=myMember.getUserID();
                                        spNumber=SysConfig.getParamValue(m_dbConn,"ASMS","spNumber");
                                        serviceType=SysConfig.getParamValue(m_dbConn,"ASMS","serviceType");//mf
                                        corpID=SysConfig.getParamValue(m_dbConn,"ASMS","corpID");
                                        feeType=1;//0 1免费 2收费 3包月费 4sp实现收费
                                        feeValue="0";
                                        givenValue="0";
                                        morelatetoMTFlag=0;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                                        reportFlag=1;//0出错返回 1一定返回 2不返回 3报月

                                        smsqueue=new SMSQueue();
                                        smsqueue.insert(m_dbConn,queueID,"86"+spNumber,"86"+destination,content,submitMulti,fileNum,
                                                 spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);
                                   }

                                   break;
                              case 3:
                                   sql="update tsmscust set "+
                                       "statusID=?,LASTDATE=sysdate where statusID=0 and mobileNo=?";
                                   stmt = m_dbConn.prepareStatement(sql);
                                   stmt.setInt(1,8);
                                   stmt.setString(2,m_userNumber);
                                   bj2=stmt.executeUpdate();
                                   stmt.close();
                                   if(bj2==0){
                                        content="您没有定制任何信息，请参考www.165xj.com";
                                   }else{
                                        content="您已经取消您在www.165xj.com的定制服务，欢迎您下次再次使用";
                                   }

                                   queueID=KeyContainer.getNewSequence(m_dbConn,"tsmsqueuid");
                                   destination=m_userNumber;
                                   //String sourceAddr="";
                                   //String destinationAddr=mobileNo;
                                   //String content="";
                                   //content="您定制的服务不存在，请参考www.165xj.com";
                                   submitMulti=0;
                                   fileNum=0;
                                   //long userID=myMember.getUserID();
                                   spNumber=SysConfig.getParamValue(m_dbConn,"ASMS","spNumber");
                                   serviceType=SysConfig.getParamValue(m_dbConn,"ASMS","serviceType");//mf
                                   corpID=SysConfig.getParamValue(m_dbConn,"ASMS","corpID");
                                   feeType=1;//0 1免费 2收费 3包月费 4sp实现收费
                                   feeValue="0";
                                   givenValue="0";
                                   morelatetoMTFlag=0;//0mo的第一条 1mo引起的不是第一条 2普通mt 3系统mt
                                   reportFlag=1;//0出错返回 1一定返回 2不返回 3报月

                                   smsqueue=new SMSQueue();
                                   smsqueue.insert(m_dbConn,queueID,"86"+spNumber,"86"+destination,content,submitMulti,fileNum,
                                            spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);
                                   break;
                         }

                    }
               }
          }catch(Exception e){
               System.out.println("SMSDeliverThread error:"+e);
          }finally{
               try {
                    if (stmt != null) {
                         stmt.close();
                    }
                    if (m_dbConn != null) {
                         m_dbConn.close();
                    }
               } catch (Exception ee) {
                    System.out.println(ee);
               }
          }

     }
}