package com.wasteinformationserver.website.datarequests;

import com.wasteinformationserver.basicutils.Log;
import com.wasteinformationserver.db.JDBC;
import com.wasteinformationserver.website.basicrequest.PostRequest;

import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;

public class DeviceRequest extends PostRequest {
    @Override
    public String request(HashMap<String, String> params) {

        JDBC jdbc = null;
        try {
            jdbc = JDBC.getInstance();
        } catch (IOException e) {
            e.printStackTrace();
        }

        StringBuilder sb = new StringBuilder();
        switch (params.get("action")) {
            case "getdevices":
                ResultSet setunconfigured = jdbc.executeQuery("SELECT * FROM `devices` WHERE `CityID`=-1");
                ResultSet setconfigured = jdbc.executeQuery("SELECT * FROM `devices`  INNER JOIN `cities` ON devices.CityID = cities.id");

                sb.append("{\"data\":[");
                try {
                    setconfigured.last();
                    int configsize = setconfigured.getRow();
                    setconfigured.first();
                    setconfigured.previous();

                    while (setunconfigured.next()) {
                        int deviceid = setunconfigured.getInt("DeviceID");
                        int cityid = setunconfigured.getInt("CityID");

                        sb.append("{\"deviceid\":\"").append(deviceid).append("\",\"cityid\":\"").append(cityid).append("\"}");

                        if (!(setunconfigured.isLast() && configsize == 0)) {
                            sb.append(",");
                        }
                    }

                    while (setconfigured.next()) {
                        int deviceid = setconfigured.getInt("DeviceID");
                        int cityid = setconfigured.getInt("CityID");

                        String devicename = setconfigured.getString("DeviceName");
                        String devicelocation = setconfigured.getString("DeviceLocation");

                        String cityname = setconfigured.getString("name");
                        String wastetype = setconfigured.getString("wastetype");
                        String zone = setconfigured.getString("zone");

                        sb.append("{\"deviceid\":\"").append(deviceid).append("\",\"cityid\":\"").append(cityid).append("\",\"devicename\":\"").append(devicename).append("\",\"devicelocation\":\"").append(devicelocation).append("\",\"cityname\":\"").append(cityname).append("\",\"wastetype\":\"").append(wastetype).append("\",\"zone\":\"").append(zone).append("\"}");

                        if (!setconfigured.isLast()) {
                            sb.append(",");
                        }
                    }
                    sb.append("]}");
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                break;
            case "getCitynames":
                setunconfigured = jdbc.executeQuery("select * from cities");
                Log.debug(setunconfigured.toString());
                sb.append("{");
                try {
                    String prev = "";
                    while (setunconfigured.next()) {
                        if (!prev.equals(setunconfigured.getString("name"))) {
                            if (!setunconfigured.isFirst()) {
                                sb.append(",");
                            }
                            sb.append("\"").append(setunconfigured.getString("name")).append("\":\"").append(setunconfigured.getString("name")).append("\"");
                        }
                        prev = setunconfigured.getString("name");
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                sb.append("}");
                Log.debug(sb.toString());
                break;
            case "getzones":
                setunconfigured = jdbc.executeQuery("select * from cities WHERE `name`='" + params.get("cityname") + "' ORDER BY zone ASC");
                Log.debug(setunconfigured.toString());
                sb.append("{");
                try {
                    int prev = 42;
                    while (setunconfigured.next()) {
                        if (prev != setunconfigured.getInt("zone")) {
                            sb.append("\"").append(setunconfigured.getInt("zone")).append("\":\"").append(setunconfigured.getInt("zone")).append("\"");
                            if (!setunconfigured.isLast()) {
                                sb.append(",");
                            }
                        }
                        prev = setunconfigured.getInt("zone");
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                sb.append("}");
                break;
            case "gettypes":
                setunconfigured = jdbc.executeQuery("select * from cities WHERE `name`='" + params.get("cityname") + "' AND `zone`='" + params.get("zonename") + "' ORDER BY zone ASC");
                Log.debug(setunconfigured.toString());
                sb.append("{");
                try {
                    String prev = "42";
                    while (setunconfigured.next()) {
                        if (!prev.equals(setunconfigured.getString("wastetype"))) {
                            sb.append("\"" + setunconfigured.getString("wastetype") + "\":\"" + setunconfigured.getString("wastetype") + "\"");
                            if (!setunconfigured.isLast()) {
                                sb.append(",");
                            }
                        }
                        prev = setunconfigured.getString("wastetype");
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                sb.append("}");
                break;
            case "savetodb":
                setunconfigured = jdbc.executeQuery("select * from cities WHERE `name`='" + params.get("cityname") + "' AND `zone`='" + params.get("zonename") + "' AND `wastetype`='" + params.get("wastetype") + "'");
                try {
                    setunconfigured.last();
                    if (setunconfigured.getRow() != 1) {
                        // TODO: 17.01.20 error handling
                    } else {
                        int id = setunconfigured.getInt("id");
                        jdbc.executeUpdate("UPDATE devices SET `CityID`='" + id + "',`DeviceName`='" + params.get("devicename") + "',`DeviceLocation`='" + params.get("devicelocation") + "' WHERE `DeviceID`='" + params.get("deviceid") + "'");
                        sb.append("{\"success\":\"true\"}");
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                break;
            case "deleteDevice":
                try {
                    jdbc.executeUpdate("DELETE FROM devices WHERE `DeviceID`='" + params.get("id") + "'");
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                sb.append("{\"status\":\"success\"}");
                break;
            case "getDeviceNumber":
                // TODO: 18.01.20
                break;
            case "addtodb":
                // TODO: 18.01.20
                //ResultSet seti = jdbc.executeUpdate("UPDATE devices SET `CityID`='" + id + "',`DeviceName`='" + params.get("devicename") + "',`DeviceLocation`='" + params.get("devicelocation") + "' WHERE `DeviceID`='" + params.get("deviceid") + "'"); ");
                break;
        }
        return sb.toString();
    }
}