package net.foucry.pilldroid;

import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;


/**
 * Created by jfoucry on 5/25/16.
 */
class DBMedoc  extends SQLiteOpenHelper {

    private static final int DATABASE_VERSION = 1;

    private static final String dbName = "medicaments.db";
    private final Context myContext;
    private final SQLiteDatabase myDataBase = null;

    private static final String TABLE_NAME = "medicaments";
    private static final String MEDOC_CIS = "cis";
    private static final String MEDOC_CIP13 = "cip13";
    private static final String MEDOC_ADMIN = "mode_administration";
    private static final String MEDOC_NOM = "nom";
    private static final String MEDOC_PRES = "presentation";

    private static final String[] COLUMNS_NAMES = {MEDOC_CIS, MEDOC_CIP13, MEDOC_ADMIN, MEDOC_NOM, MEDOC_PRES};

    private static final String TAG = DBMedoc.class.getName();


    DBMedoc(Context context) {
        super(context, dbName, null, DATABASE_VERSION);
        this.myContext = context;
    }

    @Override
    public synchronized SQLiteDatabase getWritableDatabase() {

        File dbFile = myContext.getDatabasePath(dbName);

        if (!dbFile.exists()) {
            copyDatabase(dbFile.getPath());
        }

        return super.getWritableDatabase();
    }

    @Override
    public synchronized SQLiteDatabase getReadableDatabase() {
        File dbFile = myContext.getDatabasePath(dbName);

        if (dbFile.exists()) return super.getReadableDatabase();

        copyDatabase(dbFile.getPath());
        return super.getReadableDatabase();
    }

    @Override
    public void onCreate(SQLiteDatabase db) {
    }

    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
    }

    private void copyDatabase(String dbPath) {
        Log.d(TAG, "try to copy database");
        try {
            InputStream assetDB = myContext.getAssets().open(dbName);
            OutputStream appDB = new FileOutputStream(dbPath, false);

            byte[] buffer = new byte[1024];
            int length;
            while ((length = assetDB.read(buffer)) > 0) {
                appDB.write(buffer, 0, length);
            }

            appDB.flush();
            appDB.close();
            assetDB.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

/*    void openDatabase() throws SQLiteException {
        Log.e(TAG, "openDatabase called");
        String myPath = myContext.getDatabasePath(dbName).getPath();

        myDataBase = SQLiteDatabase.openDatabase(myPath, null, SQLiteDatabase.OPEN_READONLY);
    }*/

    @Override
    public synchronized void close() {
        if (myDataBase != null) {
            myDataBase.close();
        }
    }

    /**
     * Lookup in the DB for a record corresponding to cip13
     *
     * @param cip13 string representing the object we're looking for
     * @return return a medicament object
     */
    Medicament getMedocByCIP13(String cip13) {
        Log.e(TAG, "CIP13 - " + cip13);

        SQLiteDatabase db = this.getReadableDatabase();

        // Build query
        Cursor cursor = db.query(TABLE_NAME,               // Which table
                COLUMNS_NAMES,                             // column names
                " cip13 =?",                       // selections
                new String[]{cip13},                       // selections args
                null,                              // group by
                null,                               // having
                null,                              // order by
                null);                                // limits
        //Cursor cursor = db.rawQuery("SELECT * FROM " + TABLE_NAME + " where cip13 = " + cip13, null);
        if (cursor.getCount() != 0) {

            cursor.moveToFirst();

            // Build medicament object
            Medicament medicament = new Medicament();
            // medicament.setId(Integer.parseInt(cursor.getString(0)));
            medicament.setCis(cursor.getString(0));
            medicament.setCip13(cursor.getString(1));
            medicament.setMode_administration(cursor.getString(2));
            medicament.setNom(cursor.getString(3));
            medicament.setPresentation(cursor.getString(4));

            // Set default values
            medicament.setStock(0);
            medicament.setPrise(0);
            medicament.setWarnThreshold(14);
            medicament.setAlertThreshold(7);

            // Log
            Log.d(TAG, "getDrug(" + cip13 + ")" + medicament.toString());

            // Return medicament

            cursor.close();
            return medicament;
        } else
            return null;
    }
}