sendthread.java

短信定制软件

package smstimer;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */

public class SendThread extends Engine {
    public static DBConnection db = null;//ew DBConnection();
    public SendThread( DBConnection d)  {
        super("SendThread");
        setDaemon(true);
        this.db = d;
    }
    public void run(){
        while(true){
            SubmitPackage submitPackage = null;
            if(Config.SubmitV .getSize() >0){
                submitPackage = (SubmitPackage)Config.SubmitV.pop() ;
                System.out.println("pop "+submitPackage.forecast_weather_time_id+submitPackage.dest_terminal_id+
                                   submitPackage.fee_terminal_id+submitPackage.serviced_id);
                boolean insertOk = insert(submitPackage);
                if(insertOk){
                    update(submitPackage.forecast_weather_time_id,submitPackage.period );
                }
            }
            try{
                sleep(1000);
            }catch(Exception e){

            }
        }
    }
    public boolean insert(SubmitPackage submitPackage){
        boolean insertOk = false;
           String sql = "insert sms_submit (service_id,fee_user_type,fee_terminal_id,"+
                        "msg_fmt,msg_src,fee_type,fee_code,src_terminal_id,dest_terminal_id,"+
                        "msg_content,create_time)values('"+submitPackage.serviced_id +"',"+submitPackage.fee_user_type +
                        ",'"+submitPackage.fee_terminal_id+"',"+submitPackage.msg_fmt+",'"+Config.sp_id +"','"+
                        submitPackage.fee_type+"','"+submitPackage.fee_code +"','"+submitPackage.src_terminal_id +
                        "','"+submitPackage.dest_terminal_id+"','"+submitPackage.msg_content+"','"+Utility.getDateString()+"')";//submitPackage.msg_content
           System.out.println(sql);
           int i = Integer.parseInt(String.valueOf(db.executeUpdate(sql)));
           if(i == 1){
               insertOk = true;
           }
        return insertOk;
    }
    public void update(String id,String period){
        String updateSql = "";
        if(period.equals("24") ){
             updateSql = "update sms_forecast_time set deal_result = 0,done_time_24 = '"+Utility.getDateString()+"' where id ="+id;
        }else if(period.equals("48") ){
             updateSql = "update sms_forecast_time set deal_result = 0,done_time_48 = '"+Utility.getDateString()+"' where id ="+id;
        }
        System.out.println(updateSql);
        db.executeUpdate(updateSql) ;
    }
    public static void main(String[] args) {
       // SendThread sendThread1 = new SendThread();
    }
}