package hu.bluesystem.ddc.services;

import javax.jws.WebParam;
import javax.jws.WebService;

/**
 *
 * @author sfeher
 */
@WebService
public interface DdcService {

    public String TestIt(String WhoAmI);
    public  void uploadFile(@WebParam(name="Dfile") FileUploader Dfile,@WebParam(name="Ugyfel") String Ukod);
}



package hu.bluesystem.ddc.services;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import javax.activation.DataHandler;
import javax.jws.WebService;
import javax.xml.ws.soap.MTOM;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Repository;

/**
 *
 * @author sfeher
 */
@MTOM
@WebService(endpointInterface = "hu.bluesystem.ddc.services.DdcService")
@Repository("DdcService")
//@Secured("ROLE_WS")
public class DdcServiceImpl implements DdcService {

    private final static Logger logger = Logger.getLogger(DdcServiceImpl.class);

    @Override
    public String TestIt(String WhoAmI) {
        return "OK: " + WhoAmI;
    }

    @Override
    public void uploadFile(FileUploader Dfile, String Ukod) {
        logger.info(Dfile.getName());
        DataHandler handler = Dfile.getDfile();
        try {
            InputStream is = handler.getInputStream();

            OutputStream os = new FileOutputStream(new File("//tmp//"
                    + Dfile.getName() + "."
                    + Dfile.getFileType()));
            byte[] b = new byte[100000];
            int bytesRead = 0;
            while ((bytesRead = is.read(b)) != -1) {
                os.write(b, 0, bytesRead);
            }
            os.flush();
            os.close();
            is.close();

        } catch (IOException e) {
            logger.error(e.getLocalizedMessage());
        }

    }
}