Tip

package th.in.oneauthen.client;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.URISyntaxException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.text.SimpleDateFormat;
import java.util.Base64;
import java.util.Date;
import java.util.Locale;

import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClientBuilder;
import org.boris.winrun4j.AbstractService;
import org.boris.winrun4j.ServiceException;

import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.stream.JsonReader;

public class FolderMonitoring extends AbstractService {
    public static final String CONFIG_FILE = "config.json";

    private volatile boolean shutdown = false;

    public int doRequest(int request) throws ServiceException {
        switch (request) {
        case SERVICE_CONTROL_STOP:
        case SERVICE_CONTROL_SHUTDOWN:
            shutdown = true;
            break;
        }
        return 0;
    }

    public int getControlsAccepted() {
        return 0;
    }

    public String getName() {
        return "One Authen Signing Application Client";
    }

    public String getDescription() {
        return "One Authen Signing Application Client.";
    }

    public static void main(String[] args) {
        try {
            new FolderMonitoring().serviceMain(args);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public int serviceMain(String[] args) throws ServiceException {
        ServiceConfiguration serviceConfig = new ServiceConfiguration();
        File monitorFolder = null;
        File logFile = null;
        try {
            Gson gsonUtil = new Gson();
            JsonReader reader = new JsonReader(new FileReader(new File(CONFIG_FILE)));

            serviceConfig = gsonUtil.fromJson(reader, ServiceConfiguration.class);
            if (serviceConfig == null)
                throw new Exception("Invalid service configuration");

            monitorFolder = new File(serviceConfig.getMonitoringFolder());
            if ((!monitorFolder.exists()) || (!monitorFolder.isDirectory())) {
                throw new Exception("Invalid monitoring folder configuration:" + monitorFolder.getAbsolutePath());
            }

            if (!new File(serviceConfig.getLogFolder()).exists()) {
                throw new Exception("Invalid log folder configuration");
            } else {
                logFile = new File(serviceConfig.getLogFolder(), "service.log");
            }
        } catch (Exception e) {
            e.printStackTrace();
            return -1;
        }

        System.out.println(serviceConfig.getMonitoringFolder());
        while (!shutdown) {
            // at this step, monitoring folder already validate that it is exist and it is a
            // folder.
            // do file list inside folder
            // System.out.println(serviceConfig.getOutputFolder());
            File[] fileList = monitorFolder.listFiles();
            long start = System.currentTimeMillis();
            System.out.println(start);
            if (fileList.length > 0) {

                for (File file : fileList) {
                    if (file.isFile()) {
                        System.out.println(file.getName());

                        byte[] input_file;
                        try {
                            input_file = Files.readAllBytes(Paths.get(file.getPath()));

                            byte[] encodedBytes = Base64.getEncoder().encode(input_file);
                            String encodedStringPdf = new String(encodedBytes);

                            // read config file and get value
                            String conFig = readFile(CONFIG_FILE);// filename is file config

                            JsonObject jsonObject = new JsonParser().parse(conFig).getAsJsonObject();
                            String access_token = jsonObject.get("accessToken").getAsString();
                            String profileIdStr = jsonObject.get("profileId").getAsString();
                            int profileId = Integer.parseInt(profileIdStr);

                            System.out.println(access_token);
                            System.out.println(profileId);

                            JsonObject json = new JsonObject();
                            json.addProperty("profileId", profileId);
                            json.addProperty("accessToken", access_token);
                            json.addProperty("pdfData", encodedStringPdf);
                            ////////////////////////////////////////////////////////////////

                            // send to api p'pae

                            BufferedReader br = null;
                            String output;
                            StringBuilder responseBuilder = null;

                            HttpClient httpClient = HttpClientBuilder.create().build();
                            URIBuilder uriBuilder;

                            long end = System.currentTimeMillis();
                            System.out.println(end-start);

                            try {
                                uriBuilder = new URIBuilder("http://localhost:8080/OneESign/api/service/signing");
                                HttpPost postMethod = new HttpPost(uriBuilder.build());
                                StringEntity params = new StringEntity(json.toString());

                                postMethod.addHeader("content-type", "application/json");
                                postMethod.setEntity(params);

                                HttpResponse httpResponse = httpClient.execute(postMethod);
                                int responseCode = httpResponse.getStatusLine().getStatusCode();
                                if (responseCode == 201 || responseCode == 200) {
                                    br = new BufferedReader(
                                            new InputStreamReader((httpResponse.getEntity().getContent())));
                                    responseBuilder = new StringBuilder();
                                    while ((output = br.readLine()) != null) {
                                        responseBuilder.append(output);
                                    }

                                } else {
                                    System.out.println("Failed : HTTP error code : "
                                            + httpResponse.getStatusLine().getStatusCode());
                                }

                                // get response from api p'pae
                                System.out.println(responseBuilder.toString());
                                String get_response = responseBuilder.toString();
                                JsonObject json_response = new JsonParser().parse(get_response).getAsJsonObject();
                                String pdfDataResponse = json_response.get("pdfData").getAsString();
                                String responseMessage = json_response.get("responseMessage").getAsString();

                                // decoder pdf from response
                                byte[] decodedBytes = Base64.getDecoder().decode(pdfDataResponse.getBytes());
                                FileOutputStream fos = new FileOutputStream(
                                        serviceConfig.getOutputFolder() + file.getName());
                                fos.write(decodedBytes);
                                fos.flush();
                                fos.close();

                                // create .txt for log
                                String STATUS = responseMessage;
                                String log = STATUS + ":" + file.getName();
                                logServer(log, serviceConfig.getLogFolder());

                                // delete old file
                                // String Del = PATH_INPUT + file.getName();
                                Files.delete(Paths.get(serviceConfig.getMonitoringFolder() + file.getName()));

                            } catch (URISyntaxException e1) {
                                System.out.println("http://localhost:8080/OneESign/api/service/signing");
                                e1.printStackTrace();
                            }
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }



                    } else {
                        System.out.println("Empty");
                    }

                }

                // for ( File fileItem : fileList ) {
                // try {
                // String logStr = "";
                // logStr="["+new Date().toString()+"] File \""+fileItem.getName()+ "\" found.
                // Process and delete "+(fileItem.delete()?"success.\n":"fail.\n");
                // Files.write(Paths.get(logFile.getPath()), logStr.getBytes(),
                // StandardOpenOption.APPEND);
                // }catch (IOException e) {
                // //exception handling left as an exercise for the reader
                // System.err.println("Write Log
                // Failed."+e.getMessage()==null?"":e.getMessage());
                // }
                // }
                try {
                    Files.write(Paths.get(logFile.getPath()),
                            ("Service execute complete at " + new Date() + ", Total file process = " + fileList.length
                                    + ", Total time consume =" + (System.currentTimeMillis() - start)).getBytes(),
                            StandardOpenOption.APPEND);
                    Files.write(Paths.get(logFile.getPath()),
                            ("-------------------------------------------------------------------------------------------------------------------------------------------------------\n")
                                    .getBytes(),
                            StandardOpenOption.APPEND);
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }
            try {
                Thread.sleep(serviceConfig.getMonitorInterval());
                monitorFolder = new File(serviceConfig.getMonitoringFolder());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        return 0;
    }

    public static String readFile(String filename) throws IOException {
        String content = null;
        File file = new File(filename); // For example, foo.txt
        FileReader reader = null;
        try {
            reader = new FileReader(file);
            char[] chars = new char[(int) file.length()];
            reader.read(chars);
            content = new String(chars);
            reader.close();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (reader != null) {
                reader.close();
            }
        }
        return content;
    }

    private static void logServer(String str, String path) {
        Date dNow = new Date();
        SimpleDateFormat ft = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss ", Locale.ENGLISH);
        SimpleDateFormat daily = new SimpleDateFormat("dd-MM-yyyy", Locale.ENGLISH);

        System.out.println("Current Date: " + ft.format(dNow));

        try (FileWriter fw = new FileWriter(path + daily.format(dNow) + ".txt", true);
                BufferedWriter bw = new BufferedWriter(fw);
                PrintWriter out = new PrintWriter(bw)) {
            out.println("[" + ft.format(dNow) + "]" + " [API Resful service]" + str);
            // more code
        } catch (IOException e) {

        }
    }

}