ftpdown.java~47~

电信ISAG的服务连接和服务

package test.smsTest;

import sun.net.ftp.FtpClient;
import java.io.*;
import sun.net.*;
import java.util.Properties;
import java.net.URL;
import cn.com.chinatelecom.www.wsdl.ctcc.sms.send.v2_1.service.SendSmsServiceLocator;
import cn.com.chinatelecom.www.wsdl.ctcc.sms.send.v2_1._interface.SendSms;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.ChargingInformation;
import cn.com.chinatelecom.www.schema.ctcc.common.v2_1.SimpleReference;


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

public class ftpDown
{
    public ftpDown()
    {
    }
    public static void main(String[] args)
    {
      getFtpFile g = new getFtpFile();
      new Thread(g).start();
    }
}
class getFtpFile implements Runnable
  {
    public static int temp = 0;
    FtpClient fc= null;
    DataInputStream dis = null;
    public void run()
    {
      try
       {
           //fc=new FtpClient("10.40.43.129");
           //fc.login("ftpUser","ftpUser");
           //fc.cd("/home/zxin10/log");
          //fc.ascii();

           while(true)
           {
              fc=new FtpClient("10.40.97.155");
              fc.login("zxin10","zxin10");
              fc.cd("/home/zxin10/log");
              fc.ascii();
              fc.list();
              dis = new DataInputStream(fc.list());
              int readCount;
              String s = "";
              while ( (s = dis.readLine()) != null) {
                System.out.println("Getting:   " + s);
                if(s.indexOf("lottery.properties")>0)
                {
                  temp = s.indexOf("lottery.properties");
                  Thread.sleep(6000);
                  SendMsg();
                  fc.closeServer();
                  break;
                }
              }
              Thread.sleep(5000);
            }

       }
       catch (Exception ex)
      {
           ex.printStackTrace();
       }
    }
    private void SendMsg()
    {
      File fi = new File("c:\\1.txt");
      FileInputStream fis = null;
      Properties pro = null;
      String msg = "";
      float rate = 0.0f; //培率
      int number = 0; //下注金额
      String mdn = ""; //用户号码
      float money = 0.0f;
      String type = "";//中獎類型
      try {
        int ch;
        RandomAccessFile getFile = new RandomAccessFile(fi, "rw");
        getFile.seek(0);
        TelnetInputStream fget=fc.get("lottery.properties");
        DataInputStream puts = new DataInputStream(fget);
        while ((ch = puts.read()) >= 0) {
           getFile.write(ch);
         }
        fget.close();
        getFile.close();
      }
       catch (Exception ex1) {
      }
      try {
       fis = new FileInputStream(fi);
       pro = new Properties();
       pro.load(fis);
       rate = new Float(pro.getProperty("rate")).floatValue();
       number = new Integer(pro.getProperty("number")).intValue();
       mdn = pro.getProperty("mdn");
       money = rate*number;  //奖金
       type = pro.getProperty("type");
       msg = "恭喜中獎"+type+".您下注了"+number+"元,"+"獲得獎金"+money+"元,"
           +"即日起15天內請携帶有效證件到澳門xxx街xx號領取獎金,逾期將視爲自動放弃,咨詢電話853108888.";
       URL url = new URL("http://localhost:8086/spWeb/services/SendSms");
       SendSmsServiceLocator locator = new SendSmsServiceLocator();
       SendSms service = locator.getSendSms(url);
       org.apache.axis.types.URI[] addresses = new org.apache.axis.types.URI[1];
       addresses[0] = new org.apache.axis.types.URI("tel:" + pro.getProperty("mdn"));
      //RouteSoapHeader.fileName = "D:\\cpsp\\spConfig\\downsoap_sms.properties";
       String senderName = "930006";//02762308185  8341
       ChargingInformation charging = new ChargingInformation("haha", "yes", new java.math.BigDecimal("100"), "88888");
       SimpleReference receiptRequest = null;
       receiptRequest = new SimpleReference(new org.apache.axis.types.URI("tel:66666"), "1", "333");
       String reqId = service.sendSms(addresses, senderName,charging, msg, receiptRequest);
       fis.close();
       fi.delete();
       System.out.println("reqId:" + reqId);
   //    fc.sendServer("DELE lottery.properties\r\n");
       System.out.println("readServerResponse:"+fc.readServerResponse());
       dis.close();

     }
     catch (Exception ex) {
       ex.printStackTrace();
     }
    }
  }