attendchat.java

sp最新短信API(综合网关)

package com.wayout.wayoutsp.operation.attendChat;
import java.sql.*;
import com.wayout.wayoutsp.publics.*;
//import com.wayout.wayoutsp.operation.OperManager;

/**


 * Title:        公司运营项目
 * Description: 每日3点钟定时从数据库中列表新题目和用户获奖信息
 * Copyright:    Copyright (c) 2003.1
 * Company:      wayout
 * @author wayout Software
 * @version 1.01
 */
public  class AttendChat extends Thread{
  //private static Vector waitAttendUserV=new Vector(50,10);
  private  static Connection conn=null;
  private static  PreparedStatement getAttendUserpstmt=null;
  private static PreparedStatement saveUserToAttendpstmt=null;
  private static  PreparedStatement deleteAlreadyAttendUserpstmt=null;

  private String  getAttendUserSQL="select id, src_mobile_num,dest_addr,msg_content from "
                                 +" t_chat_to_operation where section_num=? and readed=0 and rownum<11";
  private String  saveUserToAttendSQL="insert into  t_chat_from_operation values(SEQ_CHAT_TO_OPERATION_ID.Nextval,?,?,?,?,sysdate,0,1)";

  /*
  ID             NUMBER,
  SRC_MOBILE_NUM VARCHAR2(21),
  DEST_ADDR      VARCHAR2(21),
  MSG_CONTENT    VARCHAR2(200),
  SECTION_NUM    VARCHAR2(6),
  INSERT_TIME    DATE,
  READED         NUMBER,
  GAME_ID        NUMBER
  */
  private String  deleteAlreadyAttendUser="delete from t_chat_to_operation  where id=? ";
  private static AttendChat attendChat=null;
  private static final String SECTIONNUM=PublicConstants.DealerType+PublicConstants.SectionNum;


 public static AttendChat getInstanceAttendChat(){
   if(attendChat==null)
     attendChat=new AttendChat();
     return  attendChat;
 }
private   AttendChat() {
       connectDatabase();
       try{
       getAttendUserpstmt=conn.prepareStatement(getAttendUserSQL);
       saveUserToAttendpstmt=conn.prepareStatement(saveUserToAttendSQL);
       deleteAlreadyAttendUserpstmt=conn.prepareStatement(deleteAlreadyAttendUser);
       }catch(Exception e){}
       }

protected static void connectDatabase(){
     conn=DatabaseAccess.connectDatabase(PublicConstants.CONNECTION_URL,PublicConstants.DB_USER,PublicConstants.DB_PASS);
}


public static  void saveUserToAttendDB(SendDataBean send){
  try{
      saveUserToAttendpstmt.setString(1,send.getDestAddrs()[0]) ;//手机号
      saveUserToAttendpstmt.setString(2,send.srcAddr) ;//目地网关号
      saveUserToAttendpstmt.setString(3,send.sendData) ;//sms content
      saveUserToAttendpstmt.setString(4,SECTIONNUM) ;//section number
      saveUserToAttendpstmt.executeUpdate() ;
     }catch(Exception e){System.out.println(" static  void saveUserToAttendDB error!: "+e) ;}
   }

    public void run() {
      while(true) {
         int messageID=0;
        com.wayout.wayoutsp.publics.PublicFuction.threadSleep(20000);
        try{
          getAttendUserpstmt=conn.prepareStatement(getAttendUserSQL);
          getAttendUserpstmt.setString(1,SECTIONNUM);//SECTIONNUM);
          ResultSet rst=getAttendUserpstmt.executeQuery();
          while(rst.next()){
            AttendUser attendUser=new AttendUser();
           messageID =rst.getInt(1) ;
            attendUser.id    =messageID;
            attendUser.src_mobile_num  =rst.getString(2) ;
            attendUser.dest_addr         =rst.getString(3) ;
            attendUser.msg_content      =rst.getString(4) ;
            System.out.println(" attendUser.id"+attendUser.id);
            System.out.println(" attendUser.src_mobile_num"+attendUser.src_mobile_num);
            System.out.println(" attendUser.dest_addr"+attendUser.dest_addr);
            System.out.println(" attendUser.msg_content"+attendUser.msg_content);
            if(null!=attendUser.src_mobile_num){
              sendUserToAttend(attendUser);
            }
            deleteAlreadyAttendUser(attendUser.id );
            //id, src_mobile_num,dest_addr,msg_content
            //com.wayout.wayoutsp.publics.PublicFuction.threadSleep(1000);
          }
          rst.close();
          getAttendUserpstmt.close();
          }catch(NullPointerException ex)
          {
            System.out.println(" getAttendUserpstmt NullPointerException!: "+ex) ;
            deleteAlreadyAttendUser(messageID);

          }catch(Exception e)
          {
            System.out.println(" getAttendUserpstmt error!: "+e) ;
            //rst.close();
           //getAttendUserpstmt.close();
          }
          //com.wayout.wayoutsp.publics.PublicFuction.threadSleep(50000);
      }
      }



 //删除己处理过的需要陪聊的用户
private boolean deleteAlreadyAttendUser(int waitAttendUserID){
  try{
   deleteAlreadyAttendUserpstmt.setInt(1,waitAttendUserID);
   if(deleteAlreadyAttendUserpstmt.executeUpdate()>1)
     return true;
  }catch(Exception e){System.out.println(" deleteAlreadyAttendUser error!: "+e) ;}
  return true;
}
//将陪聊记录发给Chat
private void sendUserToAttend(AttendUser tAttendUser){
  ReceiveDataBean recvData = new ReceiveDataBean();
                recvData.ismgMsgId = Integer.toString(tAttendUser.id);
                recvData.destAddr = tAttendUser.dest_addr;
                recvData.srcAddr = tAttendUser.src_mobile_num ;
                recvData.msgContent = tAttendUser.msg_content ;
                recvData.registeredDelivery=0;
                com.wayout.wayoutsp.operation.OperManager.getInstance().handReceiverData(recvData);
         }
}

 class AttendUser{
   public AttendUser(){
   }
       int     id;
      String     src_mobile_num;
      String     dest_addr ;
      String     msg_content;
      //id,dest_mobile_num,src_addr,msg_content,section_num
}