canceluser.java

短信定制软件

package smstimer;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */
import java.util.*;
public class CancelUser extends Engine{
    public static DBConnection db =  null;//new DBConnection();
    public CancelUser( DBConnection d){
        super("CancelUser");
        setDaemon(true);
        this.db = d;
    }
    public void run(){
        String getUser = "select * from sms_deliver where TO_DAYS(NOW())-TO_DAYS(arrive_time) <= 3 and deal_result = 0 and redeal >  0 and (LOWER(msg_content) like "+
                                 "'"+Config.cancel_text+"%' )" ;
        while(true){
            Vector v = new Vector();
           v = (Vector)db.execute(getUser);
           System.out.println(v+getUser);
           for(int i = 0;i<v.size() ;i++){
               Order oneOrder = new Order((String)((Vector)v.get(i)).get(0),
                                           (String)((Vector)v.get(i)).get(1),
                                           (String)((Vector)v.get(i)).get(2),
                                           (String)((Vector)v.get(i)).get(3),
                                           (String)((Vector)v.get(i)).get(4),
                                           (String)((Vector)v.get(i)).get(5),
                                           (String)((Vector)v.get(i)).get(6));
               String id = oneOrder.msg_id;
               String mainOrderText = "";
               String period = "";
               String fee_terminal_id = "";
               String forWho = "";
               fee_terminal_id = oneOrder.src_terminal_id ;
               StringTokenizer st = new StringTokenizer(oneOrder.msg_content," " );
               if(st.hasMoreElements()){
                   mainOrderText = ((String)st.nextElement()).trim()  ;//获得退订命令
                }
                if(st.hasMoreElements()){
                   forWho = ((String)st.nextElement()).trim()  ;//获得forWho
                }
                if(forWho.startsWith("13") && forWho.length() == 11){

                }else{
                        forWho = oneOrder.src_terminal_id ;//如果forWho不正确,将forWho制为oneOrder.src_terminal_id
                }
               if(mainOrderText.indexOf("024") != -1 || mainOrderText.indexOf("24") != -1){
                   period = "24";
               }else if(mainOrderText.indexOf("048") != -1 || mainOrderText.indexOf("48") != -1){
                   period = "48";
               }else{
                   period = "48";
               }
               CancelUser(fee_terminal_id,forWho,period);
               SetDone(id);

        }
        try{
                sleep(1000);
            }catch(Exception e){

        }
        }
    }
    public void CancelUser(String fee_terminal_id,String forWho,String period){
        String sql = "update sms_forecast_time set status = 0 where fee_terminal_id = '"+fee_terminal_id+"' and dest_terminal_id = '"+forWho+"' and period <= "+period;
        int i = Integer.parseInt(String.valueOf(db.executeUpdate(sql)));
        if(i >= 1){
          SubmitPackageAlert submit = new SubmitPackageAlert(Config.free_service_code ,
              "3",fee_terminal_id,"15","01","00",Config.sp_id,fee_terminal_id,"成功取消短信预报定制,华风集团http://www.weathercn.com");
          Config.SubmitAlertV.push(submit);

        }
    }
    public void SetDone(String msg_id){
        String updateSql = "update sms_deliver set deal_result = 1 ,redeal = redeal-1 where msg_id = "+msg_id;
        db.executeUpdate(updateSql);
    }
    public static void main(String[] args) {
       // CancelUser cancelUser1 = new CancelUser();
    }
}