path: root/Dozentenmodulserver/src/server/ServerHandler.java

package server;

import java.io.File;
import java.io.IOException;
import java.math.BigInteger;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.TransformerException;

import org.apache.commons.io.FileUtils;
import org.apache.thrift.TException;

import sql.SQL;
import util.XMLCreator;


public class ServerHandler implements Server.Iface {

    static SQL sql=new SQL();
    static Connection con=sql.getConnection();
	/**
	 * @param args
	 */
	/*public static void main(String[] args) {
		// TODO Auto-generated method stub

	}*/

	@Override
	public User getFtpUser() throws TException {
		User user=new User();
		user.setUserName(UUID.randomUUID().toString().substring(0, 8));
		user.setPassword(getEncodedSha1Sum(UUID.randomUUID().toString().substring(0, 8)));
		user.setPath("/srv/openslx/nfs/temp");
		SQL sql=new SQL();
		Connection con=sql.getConnection();
		sql.writeFTPUser(con, user.getUserName(), user.getPassword());
		return user;
	}
	

	public String getEncodedSha1Sum(String key) {
	    try {
	        MessageDigest md = MessageDigest.getInstance( "SHA1" );
	        md.update( key.getBytes() );
	        return new BigInteger(1, md.digest()).toString(16);
	    }
	    catch (NoSuchAlgorithmException e) {
	        // handle error case to taste
	    }
		return null;
	}

	@Override
	public long DeleteFtpUser(String user) throws TException {
		int ret = sql.DeleteUser(con, user);
		return ret;
	}

	@Override
	public String getPathOfImage(String image_id, String version) throws TException {
		
		try {
			ResultSet rs=sql.getPathOfImage(con, image_id, version);
			System.out.println("Path SQL erfolgreich");
			rs.next();
			System.out.println(rs.getString("image_path"));
			return rs.getString("image_path");
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return null;
	}

	@Override
	public boolean writeVLdata(String imagename, String firstname,
			String lastname, String university, String Mail, String Tel,
			String Fak, boolean license, boolean internet, long ram, long cpu, String imagePath)
			throws TException {
		String login="tete";
		
		int pk_institution=sql.setInstitution(con, university);
		
		int pk_person=sql.setPerson(con, login, lastname, firstname, Mail, new Date(), pk_institution);
		
		sql.setImageData(con, pk_person, license, internet, cpu, ram, imagename, imagePath);

		// TODO Auto-generated method stub
		return true;
	}

	@Override
	public List<Image> getImageList() throws TException {
		ResultSet res=sql.getImageList(con);
		
		List<Image> list = new ArrayList<Image>();

		try {
			
			while(res.next())
			{
				
				list.add(new Image(res.getString("GUID_imageID"),res.getString("imageVersion"),res.getString("image_name"),res.getString("cond_hasLicenseRestriction"),res.getString("name"),res.getString("lecture"),res.getString("image_update_time"),res.getString("user")));
				
			}
			

			return list;
		} catch (SQLException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}

		return null;
	}
	

	@Override
	public List<String> getAllOS() throws TException {
		List<String> list=new ArrayList<>();
		ResultSet rs=sql.getAllOS(con);
		try {
			while(rs.next())
			{
				list.add(rs.getString("name"));
			}
			return list;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}

	@Override
	public Map<String, String> getPersonData(String Vorname, String Nachname)
			throws TException {
		Map<String,String> map=new HashMap<String, String>();
		
		ResultSet rs=sql.getPersonData(con, Vorname, Nachname);
		try {
			while(rs.next())
			{
				
				map.put("mail", rs.getString("mail"));
				map.put("Nachname", rs.getString("Nachname"));
				map.put("Vorname", rs.getString("Vorname"));
				map.put("Hochschule", rs.getString("name"));

				
			}
			return map;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}

	@Override
	public boolean writeLecturedata(String name, String shortdesc, String desc,
			String startDate, String endDate, boolean isActive,
			String imagename, String firstname, String lastname,
			String university, String Mail, String Tel, String Fak)
			throws TException {
		int pk_image = 0;
		String login="tete";
		int imageversion = 0;
		int pk_institution=sql.setInstitution(con, university);
		int pk_person=sql.setPerson(con, login, lastname, firstname, Mail, new Date(), pk_institution);
		
		ResultSet image=sql.getImageIDandVersion(con, imagename);

			try {
				while(image.next())
				{
				pk_image=image.getInt("GUID_imageID");
				imageversion=image.getInt("imageVersion");
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
			
			System.out.println(startDate);
			sql.setLectureData(con, pk_person, pk_image, imageversion, name, desc, shortdesc, startDate, endDate, isActive);
			XMLCreator xml=new XMLCreator(con, name);
			try {
				xml.create(name);
				System.out.println(new Date() + " - Creator beendet");
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (ParserConfigurationException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (TransformerException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		return false;
	}

	@Override
	public boolean startFileCopy(String file) throws TException {
		File tmpFile=new File(file);

		System.out.println("Vor Move" +new Date());
		try {
			//der übergebene Filename ist falsch - hier muss der generierte name geholt werden, nicht der ursprüngliche name. wo wird dieser eingelesen?
			FileUtils.moveFile(tmpFile, new File("141.79.128.103:/srv/nfs4slx/"+tmpFile.getName()));
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		System.out.println("Nach Move"+new Date());
		return true;
	}


	@Override
	public Map<String, String> getImageData(String imageid, String imageversion) throws TException {
		
		ResultSet data=sql.getImageData(con, imageid, imageversion);
		
		Map<String,String> map=new HashMap<String, String>();
		try {
			while(data.next())
			{
				System.out.println(data.getString("cond_hasInternetRestriction")+data.getString("cond_hasLicenseRestriction")+data.getString("cond_minCPUs")+data.getString("cond_minRAM"));
				map.put("name",data.getString("image_name"));
				map.put("internet", data.getString("cond_hasInternetRestriction"));
				map.put("license", data.getString("cond_hasLicenseRestriction"));
				map.put("cpu", data.getString("cond_minCPUs"));
				map.put("ram", data.getString("cond_minRAM"));
				
			}
			System.out.println("return success");
			return map;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;

	}


	@Override
	public boolean updateImageData(String name, String newName,boolean license,
			boolean internet, long ram, long cpu,String id, String version) throws TException {
		System.out.println("Server: Vor Update");
		sql.UpdateImageData(con, name, newName ,license, internet, cpu, ram, id, version);
		System.out.println("Update erfolgreich");
		return false;
	}


	@Override
	public Map<String, String> getLectureData(String lecturename)
			throws TException {
		// TODO Auto-generated method stub
		return null;
	}


	@Override
	public List<Lecture> getLectureList() throws TException {
		ResultSet res=sql.getLectureList(con);
		
		List<Lecture> list = new ArrayList<Lecture>();

		try {
			
			while(res.next())
			{
				
				list.add(new Lecture(res.getString("lectureID"), res.getString("name"), res.getString("isActive"), res.getString("startTime"), res.getString("endTime"), res.getString("lastUsed"), res.getString("description"), res.getString("image_name"), res.getString("user")));
				
			}
			

			return list;
		} catch (SQLException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}

		return null;
	}


	@Override
	public boolean updateLecturedata(String name, String newName,
			String shortdesc, String desc, String startDate, String endDate,
			boolean isActive, String imagename, String firstname,
			String lastname, String university, String Mail, String Tel,
			String Fak, String id) throws TException {
		int pk_image=0;
		int imageversion=0;
		ResultSet image=sql.getImageIDandVersion(con, imagename);

		try {
			while(image.next())
			{
			pk_image=image.getInt("GUID_imageID");
			imageversion=image.getInt("imageVersion");
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		sql.updateLectureData(con, pk_image, imageversion, lastname, newName, desc, shortdesc, startDate, endDate, isActive, id);
		return false;
	}

}