#4433482 - Pastie

Embed
Download
Raw
A A A
Ruby on Rails August 09, 2012
12:44PM EDT Report abuse
public class FTPUploaderActivity extends Activity 
{

  FTPClient ftpClient = new FTPClient();
  String path="";
  File file=new File(path);  
  String filename=file.getName();
  ArrayList<EditText> dynaFields = null;
  ArrayList <Response> WebData= new ArrayList<Response>();
  public static final int SELECT_VIDEO=1;
  public static final String TAG="UploadActivity";
  final String NAMESPACE = "http://tempuri.org/";
    final String SERVICEURL = "xxxxxxxxxxxxxxxxxxxxxxxxx";
    final String METHOD_NAME="KullaniciGiris";
    final String METHOD_NAME1="OzelVeriAlanlariniGetir";
    final String METHOD_NAME2="VideoKaydet";
    Object response = null;
    /** Called when the activity is first created. */
    @Override
    public void onCreate(Bundle savedInstanceState) 
    {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        Button enter=(Button)findViewById(R.id.enter);
        enter.setFocusable(true);
        final EditText username=(EditText)findViewById(R.id.username);
        final EditText password=(EditText)findViewById(R.id.password);
        final  AlertDialog ad=new AlertDialog.Builder(this).create();
        enter.setOnClickListener(new View.OnClickListener() 
        {
      @Override
      public void onClick(View arg0) 
      {
        // TODO Auto-generated method stub
        //request code for Webservice
        SoapObject request = new SoapObject(NAMESPACE, METHOD_NAME);
        //sending the username to the webservice
        request.addProperty("kullaniciAdi",username.getText().toString());
        //sending the password to the webservice
        request.addProperty("password",password.getText().toString());
        SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(SoapEnvelope.VER11);
        envelope.dotNet = true;
            //Putting the request in an envelope
            envelope.setOutputSoapObject(request);
            HttpTransportSE transport = new HttpTransportSE(SERVICEURL);
            
            try
            {
               transport.call("http://tempuri.org/"+METHOD_NAME, envelope);
               //getting the response from the webservice
               response= envelope.getResponse();
            }//end of try
        catch(Exception exception)
        {
          exception.printStackTrace();
        }//end of catch
        if(response!=null && Integer.parseInt(response.toString()) != 0)
        {
          openGaleryVideo();
        }//end of if
        else
        {
          ad.setCancelable(true);
          ad.setMessage("Lütfen Kullanıcı Adınızı ve Şifrenizi Kontrol Ediniz.");
              ad.show();
              ad.setCanceledOnTouchOutside(true);
              
        }//end of else
      }//end of onClick method  
    });//end of OnclickListener method
    }//end of onCreate method
    public void openGaleryVideo()
    {
      Intent intent=new Intent();
      intent.setType("video/*");
      intent.setAction(Intent.ACTION_GET_CONTENT);
      startActivityForResult(Intent.createChooser(intent, "Select Video"),SELECT_VIDEO);
    }//end of openGaleryVideo method
    
    public String getPath(Uri uri)
    {  
      String[] projection = { MediaStore.Video.Media.DATA};
      Cursor cursor = managedQuery(uri, projection, null, null, null);
      int column_index = cursor.getColumnIndexOrThrow(MediaStore.Video.Media.DATA);
      cursor.moveToFirst();
      return cursor.getString(column_index);
    }//end of getPath method
    
    //Response Class
    public class Response
    {
      int Id;
      String Name;
      String Type;
      String Value;
      String DefaultValue;
      int Flag;
      int Index;
    }//end of Response class
    
    //onActivityResult
    public void onActivityResult(int requestCode, int resultCode, Intent data) 
    {
      final AlertDialog ad=new AlertDialog.Builder(this).create();
        super.onActivityResult(requestCode, resultCode, data);
        if (resultCode == RESULT_OK)
        {
            if (requestCode == SELECT_VIDEO) 
            {
              Uri videoUri = data.getData();
                path=getPath(videoUri);
                
                //adding scroll view property
                ScrollView scroll = new ScrollView(this);
                LinearLayout layout=new LinearLayout(this);
                layout.setOrientation(LinearLayout.VERTICAL);
                layout.setLayoutParams(new LayoutParams(LayoutParams.WRAP_CONTENT, LayoutParams.WRAP_CONTENT)); 
                scroll.addView(layout,new LayoutParams(LayoutParams.FILL_PARENT, LayoutParams.WRAP_CONTENT));
                setContentView(scroll);  
                
                
                //Connecting to the web service
        SoapObject request = new SoapObject(NAMESPACE, METHOD_NAME1);
        SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(SoapEnvelope.VER11);
        envelope.dotNet = true;
            //put what we want into the envelope
            envelope.setOutputSoapObject(request);
            HttpTransportSE transport = new HttpTransportSE(SERVICEURL);
            Object response1=null;
            try
            {
               transport.call("http://tempuri.org/"+METHOD_NAME1, envelope);
               //getting the response from the webservice
               response1 =envelope.getResponse();
               JSONArray jArray= new JSONArray(response1.toString());
               for(int i=0;i<jArray.length();i++)
               {
                 JSONObject json_data= jArray.getJSONObject(i);
                 Response result= new Response();
                 result.Id= json_data.getInt("Id");
                 result.Name= json_data.getString("Name");
                 result.Type= json_data.getString("Type");
                 result.Value=json_data.getString("Value");
                 result.DefaultValue=json_data.getString("DefaultValue");
                 result.Flag=json_data.getInt("Flag");
                 result.Index=json_data.getInt("Index");
                 WebData.add(i,result);
               }//end of for loop   
            }//end of try 
        catch(Exception exception)
        {
          exception.printStackTrace();
        }//end of catch
        
        this.dynaFields = new ArrayList<EditText>(WebData.size());
        for(int j=0;j<WebData.size();j++)
        {  
            TextView t= new TextView(this);
            t.setText(WebData.get(j).Name);
            layout.addView(t);
            
            EditText newField = new EditText(this);
                this.dynaFields.add (newField);
                layout.addView(newField);

        }//end of for loop
        Button upload= new Button(this);
        Button back2=new Button(this);
        Button exit1=new Button(this);
        
        //Upload Button
        upload.setClickable(true);
        upload.setFocusable(true);
                upload.setText("Yükle");
                layout.addView(upload);
        
                //Back Button
        back2.setClickable(true);
        back2.setFocusable(true);
        back2.setText("Geri");
        layout.addView(back2);
        
        //Exit button
        exit1.setClickable(true);
        exit1.setFocusable(true);
        exit1.setText("Çıkış");
        layout.addView(exit1);
        
        exit1.setOnClickListener(new View.OnClickListener() {
          
          @Override
          public void onClick(View arg0) 
          {
            // TODO Auto-generated method stub
            finish();
          }
        });
        
        back2.setOnClickListener(new View.OnClickListener() {
          
          @Override
          public void onClick(View arg0) {
            // TODO Auto-generated method stub
            openGaleryVideo();
          }
        });

                upload.setOnClickListener(new View.OnClickListener() 
                {    
          @Override
          public void onClick(View arg0)
          {
            // TODO Auto-generated method stub
            int a=dynaFields.size();
            JSONArray j_array= new JSONArray();
               for(int k=0;k<a;k++)
            {
                 JSONObject json = new JSONObject();  
                 String json_name= dynaFields.get(k).getText().toString();
                 Response r= WebData.get(k);
              try 
              {
                j_array.put(k,json.put("Id",r.Id));
                j_array.put(k,json.put("Name",r.Name));
                j_array.put(k,json.put("Type",r.Type));
                j_array.put(k,json.put("Value",json_name));
                j_array.put(k,json.put("DefaultValue",r.DefaultValue));
                j_array.put(k,json.put("Flag",r.Flag));
                j_array.put(k,json.put("Index",r.Index));
              } //end of try
              catch (Exception e) 
              {
                // TODO Auto-generated catch block
                e.printStackTrace();
                ad.setMessage(e.toString());
                ad.show();
                ad.setCanceledOnTouchOutside(true);
              }//end of catch
            }//end of for loop        
                   
            SoapObject request = new SoapObject(NAMESPACE, METHOD_NAME2);
            request.addProperty("serializedKolonList",j_array.toString());
            request.addProperty("idUser",Integer.parseInt(response.toString()));
            request.addProperty("mediaName",filename.toString());
            SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(SoapEnvelope.VER11);
            envelope.dotNet = true;
                //putting the request into the envelope
                envelope.setOutputSoapObject(request);
                HttpTransportSE transport = new HttpTransportSE(SERVICEURL);
                Object response2 = null;
                try
                {
                   transport.call("http://tempuri.org/"+METHOD_NAME2, envelope);
                   //getting the response from the webservice
                   response2= envelope.getResponse();
                }
            catch(Exception exception)
            {
              exception.printStackTrace();
            }//end of catch
            if(response2!=null && Integer.parseInt(response2.toString()) != 0)
            {
              upload upload = new upload();
                      upload.execute();
            }//end of if
            else
            {
              ad.setMessage("Bilgiler kaydedilemedi lütfen tekrar deneyin.");
                  ad.show();
                  ad.setCanceledOnTouchOutside(true);
            }//end of else
          }//end of onClick Method
        });//end of Listener
            }//end of If request code
        }//end of If result code
    }//end of onActivityResult
  //ASYNC TASK Upload Class which uploads the file and shows the progress via a dialog
    public class upload extends AsyncTask<Object, Integer, Void> 
    {
       //Initializations
       public ProgressDialog dialog;
      int progress=0;
        
       //Before start to upload the file creating a dialog
        @Override
        public void onPreExecute() 
        {
           dialog = new ProgressDialog(FTPUploaderActivity.this);
             dialog.setMessage("Lütfen Bekleyin...");
             dialog.setIndeterminate(false);
             dialog.setTitle("Videonuz Yükleniyor");
             dialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
             dialog.setProgress(0);
             dialog.setMax(100);
             //dialog.incrementProgressBy((int)((progress*100)/(file.length())));
             dialog.show();
          
        }
        
        //Uploading the file in background with showing the progress
    @Override
    public Void doInBackground(Object... arg0) 
    {  

      String server = "xx.xx.xx.xx";
      // TODO Auto-generated method stub
          try
          {
            
            ftpClient.connect(server,21);
            ftpClient.login("xxxxxxxxx", "xxxxxxx");
            ftpClient.changeWorkingDirectory("murat.alemdag\ftp");
            ftpClient.enterLocalPassiveMode();
            FileInputStream in=new FileInputStream(file);
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            ftpClient.storeFile(filename, in);
            try {
                InputStream stO = new BufferedInputStream(ftpClient.retrieveFileStream("foo.bar"),
                              ftpClient.getBufferSize());
                OutputStream stD = new FileOutputStream("bar.foo");

                org.apache.commons.net.io.Util.copyStream(stO, stD, ftpClient.getBufferSize(),
                              CopyStreamEvent.UNKNOWN_STREAM_SIZE,
                              new CopyStreamAdapter() {
                                  public void bytesTransferred(long totalBytesTransferred,
                                          int bytesTransferred,
                                          long streamSize) {
                                          // Your progress Control code here
                                      publishProgress((int) ((totalBytesTransferred/file.length())*100));
                                  }
                      });
                      ftpClient.completePendingCommand();
              } catch (Exception e) {  }
              publishProgress(100); 
            ftpClient.logout();
            
          }
          
          catch (Exception ex)
          {
              ex.printStackTrace();
          }    
      return null;
     }//end of doInBackground method
    
     //making an update on progress
     @Override
     public void onProgressUpdate(Integer... values)
       {
         super.onProgressUpdate(values);
            dialog.setProgress(values[0]);
        }//end of onProgressUpdate
     
     //After finishing the progress the dialog will disappear!
     @Override
     public void onPostExecute(Void result) 
       { 
       final AlertDialog ad = new AlertDialog.Builder(FTPUploaderActivity.this).create();
            try 
            {
                dialog.dismiss();
                setContentView(R.layout.select);
                Button select= (Button) findViewById(R.id.select);
                select.setFocusable(true);
                select.setOnClickListener(new View.OnClickListener()
                {
            
            @Override
            public void onClick(View arg0) 
            {
              // TODO Auto-generated method stub
              openGaleryVideo();
            }
          });
                
                Button disconnect= (Button) findViewById(R.id.disconnect);
                disconnect.setFocusable(true);
                disconnect.setOnClickListener(new View.OnClickListener() {
                
            @Override
            public void onClick(View arg0) 
            {
              // TODO Auto-generated method stub
              try {
                
                ftpClient.disconnect();
                ad.setMessage("Bağlantıyı Kestiniz.");
                ad.show();
                ad.setCanceledOnTouchOutside(true);
              } 
              catch (IOException e) 
              {
                // TODO Auto-generated catch block
                e.printStackTrace();
              }
            }
          });
                
                Button exit= (Button) findViewById(R.id.exit);
                exit.setFocusable(true);
                exit.setOnClickListener(new View.OnClickListener() 
                {
            
            @Override
            public void onClick(View arg0)
            {
              // TODO Auto-generated method stub
                finish();
            }
          });

            } //End of the second try body
            catch(Exception e) 
            {
              e.printStackTrace();
            }
        }//end of onPostExecute method
    }// end of asyncTask class 
}//end of main
14659 characters / 420 lines