#include "clog.h"
#include "cgi.h"
#include "input.h"
#include "wrenchboard_api.h"
#include "reco_engine.h"  //error in file name
#include "email.h"
#include "safestring.h"
#include <string>
#include "pgsql.h"
#include "pgsql_wrapper.h"
#include <curl/curl.h>
#include "account.h"
#include "cards.h"
#include "twilo.h"
#include "mobile.h"
#include "jobs_manager.h"
#include "family_acc.h"
#include "common_tool.h"

long  WrenchFamilyList(CVars in, CVars &out);
long  WrenchFamilyAdd(CVars in, CVars &out);
long  WrenchFamilyUpdate(CVars in, CVars &out);
long  WrenchFamilyManage(CVars in, CVars &out);
long  WrenchSampleTasks(CVars in, CVars &out);
long  WrenchSuggestTasks(CVars in, CVars &out);
long  WrenchSuggestList(CVars in, CVars &out);
long  WrenchSuggestWaitingList(CVars in, CVars &out);

long family_calls(CVars in, CVars &out){
    logfmt(logINFO, "family_calls()");
    out["result"] = "YES I GET TO BACK END";
    long action = REQ_LONG(in, "action", 0, -1);
    CVars x;
    long ret = 0;
    const char * loc = getenv("REMOTE_ADDR");
    const PGresult *res;
    logfmt(logINFO, "action = %ld", action);

    switch (action) {
        case WRENCHBOARD_FAMILY_LIST:
            return WrenchFamilyList(in, out);
            break;

        case WRENCHBOARD_FAMILY_SAMPLETASKS:
            return WrenchSampleTasks(in, out);
            break;

        case WRENCHBOARD_FAMILY_ADD:
            return WrenchFamilyAdd(in, out);
            break;

        case WRENCHBOARD_FAMILY_UPDATE:
            return WrenchFamilyUpdate(in, out);
            break;

        case WRENCHBOARD_FAMILY_MANAGE:
            return WrenchFamilyManage(in, out);
            break;

        case WRENCHBOARD_FAMILY_SGGESTTASKS:
             logfmt(logINFO, "ENTER CALL long WRENCHBOARD_FAMILY_SGGESTTASKS");
               return WrenchSuggestTasks(in, out);
            break;

        case WRENCHBOARD_FAMILY_SGGESTLIST:
             logfmt(logINFO, "ENTER CALL long WRENCHBOARD_FAMILY_SGGESTLIST");
              return WrenchSuggestList(in, out);
            break;
//long  WrenchSuggestWaitingList(CVars in, CVars &out)
        case WRENCHBOARD_FAMILY_SGGESTWAITING:
             logfmt(logINFO, "ENTER CALL long WRENCHBOARD_FAMILY_SGGESTWAITING");
               return WrenchSuggestWaitingList(in, out); // this now the parent
            break;
    }
return 0;
}


long  WrenchSuggestWaitingList(CVars in, CVars &out){ // this is the parent now
  logfmt(logINFO, "ENTER CALL long WrenchSuggestWaitingList");
    char vname[30];
    long ret = PHP_API_BAD_PARAM;
    const PGresult *res;
    try{
        long member_id = REQ_LONG(in, "member_id", 1, -1);
        long offset = REQ_LONG(in, "offset", 1, -1);
        long limit = REQ_LONG(in, "limit", 1, -1);

        out["total_record"] = "0";
     //   res = pgsql_query("SELECT id FROM family_task_suggestion WHERE  status=1 ");
      //  out["total_record"] = pgsql_num_rows(res);

        res = pgsql_query(" SELECT * FROM members_family_suggesttask WHERE family_uid IN (SELECT uid FROM members_family WHERE member_id = %lu) AND status IN ( 1,2,3,4,5)   "
                            " ORDER BY created DESC LIMIT %lu OFFSET %lu", member_id, limit, offset);

          if (res != NULL && pgsql_num_rows(res) > 0) {
              out["total_record"] = pgsql_num_rows(res);

              for (int i = 0, n = pgsql_num_rows(res); i < n; i++) {
                  map<const char*, const char*>f = pgsql_fetch_assoc(res, i);
                  if (f.empty()) continue;
                  CVars rec;
                  map_to_cvars(f, rec);

                    snprintf(vname, sizeof (vname), "uid_%05d", i);
                    out[vname] = rec["uid"];

                    snprintf(vname, sizeof (vname), "family_uid_%05d", i);
                    out[vname] = rec["family_uid"];

                    snprintf(vname, sizeof (vname), "title_%05d", i);
                    out[vname] = rec["title"];

                    snprintf(vname, sizeof (vname), "description_%05d", i);
                    out[vname] = rec["description"];

                    snprintf(vname, sizeof (vname), "added_%05d", i);
                    out[vname] = rec["created"];

                    snprintf(vname, sizeof (vname), "status_%05d", i);
                    out[vname] = rec["status"];

              }
          }
          ret = PHP_API_OK;
          out["status"] = "OK";

    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchSuggestWaitingList");
    }

 logfmt(logINFO, "WrenchSuggestList()");
 return ret;
}

long  WrenchSuggestList(CVars in, CVars &out){
  logfmt(logINFO, "ENTER CALL long WrenchSuggestList");
    char vname[30];
    long ret = PHP_API_BAD_PARAM;
    const PGresult *res;
    try{
        long member_id = REQ_LONG(in, "member_id", 1, -1);
        long offset = REQ_LONG(in, "offset", 1, -1);
        long limit = REQ_LONG(in, "limit", 1, -1);

        out["total_record"] = "0";
     //   res = pgsql_query("SELECT id FROM family_task_suggestion WHERE  status=1 ");
      //  out["total_record"] = pgsql_num_rows(res);

        res = pgsql_query(" SELECT * FROM members_family_suggesttask WHERE member_id = %lu AND status IN ( 1,2,3,4,5)   "
                            " ORDER BY created DESC LIMIT %lu OFFSET %lu", member_id, limit, offset);

          if (res != NULL && pgsql_num_rows(res) > 0) {
              out["total_record"] = pgsql_num_rows(res);

              for (int i = 0, n = pgsql_num_rows(res); i < n; i++) {
                  map<const char*, const char*>f = pgsql_fetch_assoc(res, i);
                  if (f.empty()) continue;
                  CVars rec;
                  map_to_cvars(f, rec);

                    snprintf(vname, sizeof (vname), "uid_%05d", i);
                    out[vname] = rec["uid"];

                    snprintf(vname, sizeof (vname), "title_%05d", i);
                    out[vname] = rec["title"];

                    snprintf(vname, sizeof (vname), "description_%05d", i);
                    out[vname] = rec["description"];

                    snprintf(vname, sizeof (vname), "added_%05d", i);
                    out[vname] = rec["created"];

                    snprintf(vname, sizeof (vname), "status_%05d", i);
                    out[vname] = rec["status"];

              }
          }
          ret = PHP_API_OK;
          out["status"] = "OK";

    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchSuggestList");
    }

 logfmt(logINFO, "WrenchSuggestList()");
 return ret;
}


long  WrenchSuggestTasks(CVars in, CVars &out){
    long ret = PHP_API_BAD_PARAM;
   // const PGresult *res;
    try{
        long member_id = REQ_LONG(in, "member_id", 1, -1);
        REQ_STRING(in, "uid", 3, 150, "(.*)");
        REQ_STRING(in, "title", 3, 150, "(.*)");
        REQ_STRING(in, "description", 3, 299, "(.*)");
        out["suggested_task_id"] ="0";// we will set if all okay
        const PGresult *res = pgsql_query("SELECT m.*,mf.uid AS family_uid FROM members m "
                                          " LEFT JOIN members_family mf ON mf.family_member_id = m.id "
                                          " WHERE m.id=%lu AND m.uid='%s'", member_id, in["uid"].c_str());
        if (res != NULL && pgsql_num_rows(res) > 0) {
            map<const char*, const char*>f = pgsql_fetch_assoc(res, 0);
            CVars rec;
            map_to_cvars(f, rec);
            ret = PHP_API_OK;
            out["status"] = "ACCOUNT FOUND";
            //out = rec;
            if (rec["family_uid"] != ""){ // we are sure you are a family now

            CVars xx;
            xx["member_id"] = member_id;
            xx["member_id"].set_valid(true);
            xx["title"] = in["title"];
            xx["title"].set_valid(true);
            xx["description"] = in["description"];
            xx["description"].set_valid(true);
            xx["family_uid"] = rec["family_uid"];
            xx["family_uid"].set_valid(true);
            out["suggested_task_id"] = insert_db_record(DBS_VALID, "members_family_suggesttask", "members_family_suggesttask_id_seq", xx);
            ret = PHP_API_OK;
            out["status"] = "OK";
            }
        }
    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchSuggestTasks");
    }

 logfmt(logINFO, "WrenchSuggestTasks()");
 return ret;
}

long  WrenchSampleTasks(CVars in, CVars &out){
  logfmt(logINFO, "ENTER CALL long WrenchSampleTasks");
    char vname[30];
    long ret = PHP_API_BAD_PARAM;
    const PGresult *res;
    try{
        long member_id = REQ_LONG(in, "member_id", 1, -1);
        long offset = REQ_LONG(in, "offset", 1, -1);
        long limit = REQ_LONG(in, "limit", 1, -1);

        out["total_record"] = "0";
     //   res = pgsql_query("SELECT id FROM family_task_suggestion WHERE  status=1 ");
      //  out["total_record"] = pgsql_num_rows(res);

        res = pgsql_query(" SELECT * FROM family_task_suggestion WHERE status = 1  "
                            " ORDER BY title DESC LIMIT %lu OFFSET %lu", limit, offset);

          if (res != NULL && pgsql_num_rows(res) > 0) {
              out["total_record"] = pgsql_num_rows(res);

              for (int i = 0, n = pgsql_num_rows(res); i < n; i++) {
                  map<const char*, const char*>f = pgsql_fetch_assoc(res, i);
                  if (f.empty()) continue;
                  CVars rec;
                  map_to_cvars(f, rec);

                    snprintf(vname, sizeof (vname), "uid_%05d", i);
                    out[vname] = rec["uid"];

                    snprintf(vname, sizeof (vname), "title_%05d", i);
                    out[vname] = rec["title"];

                    snprintf(vname, sizeof (vname), "description_%05d", i);
                    out[vname] = rec["description"];

                    snprintf(vname, sizeof (vname), "added_%05d", i);
                    out[vname] = rec["added"];

                    snprintf(vname, sizeof (vname), "age_%05d", i);
                    out[vname] = rec["age"];

                    snprintf(vname, sizeof (vname), "banner_%05d", i);
                    out[vname] = rec["banner"];

              }
          }
          ret = PHP_API_OK;
          out["status"] = "OK";

    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchSampleTasks");
    }

 logfmt(logINFO, "WrenchSampleTasks()");
 return ret;
}


long  WrenchFamilyList(CVars in, CVars &out){
    logfmt(logINFO, "ENTER CALL long WrenchFamilyList");
    char vname[30];
    long ret = PHP_API_BAD_PARAM;
    const PGresult *res;
    try{
        long member_id = REQ_LONG(in, "member_id", 1, -1);
        long offset = REQ_LONG(in, "offset", 1, -1);
        long limit = REQ_LONG(in, "limit", 1, -1);

        out["total_record"] = "0";
        res = pgsql_query("SELECT id FROM members_family WHERE member_id = %lu AND status=1 ", in["member_id"].Long());
        out["total_record"] = pgsql_num_rows(res);

        res = pgsql_query(" SELECT * FROM members_family WHERE member_id = %lu AND status=1 "
                            " ORDER BY id DESC LIMIT %lu OFFSET %lu", in["member_id"].Long(), limit, offset);

          if (res != NULL && pgsql_num_rows(res) > 0) {
              out["total_record"] = pgsql_num_rows(res);

              for (int i = 0, n = pgsql_num_rows(res); i < n; i++) {
                  map<const char*, const char*>f = pgsql_fetch_assoc(res, i);
                  if (f.empty()) continue;
                  CVars rec;
                  map_to_cvars(f, rec);

                 snprintf(vname, sizeof (vname), "uid_%05d", i);
                 out[vname] = rec["uid"];

                  snprintf(vname, sizeof (vname), "firstname_%05d", i);
                  out[vname] = rec["firstname"];

                  snprintf(vname, sizeof (vname), "lastname_%05d", i);
                  out[vname] = rec["lastname"];

                  snprintf(vname, sizeof (vname), "added_%05d", i);
                  out[vname] = rec["added"];

                  snprintf(vname, sizeof (vname), "age_%05d", i);
                  out[vname] = rec["age"];

                 snprintf(vname, sizeof (vname), "last_login_%05d", i);
                 out[vname] = rec["last_login"];

                 snprintf(vname, sizeof (vname), "task_count_%05d", i);
                 out[vname] = rec["task_count"];

              }
          }
          ret = PHP_API_OK;
          out["status"] = "OK";

    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchFamilyList");
    }

 logfmt(logINFO, "WrenchFamilyList()");
return ret;
}

long  WrenchFamilyAdd(CVars in, CVars &out){
 logfmt(logINFO, "WrenchFamilyAdd()");
  long family_id = 0;

  try {
		REQ_LONG(in, "member_id", 1, -1);
		REQ_LONG(in, "age", 1, -1);
		REQ_STRING(in, "firstname", 2, 34, "(.*)");
		REQ_STRING(in, "lastname", 2, 34, "(.*)");
        CVars x;
        x["member_id"] = in["member_id"];
        x["member_id"].set_valid(true);
        x["age"] = in["age"];
        x["age"].set_valid(true);
        x["firstname"] = in["firstname"];
        x["firstname"].set_valid(true);
        x["lastname"] = in["lastname"];
        x["lastname"].set_valid(true);
        x["status"] = "1";
        x["status"].set_valid(true);
        family_id = insert_db_record(DBS_VALID, "members_family", "members_family_id_seq", x);
        if (family_id > 0) {
         load_db_record(out, "SELECT * FROM members_family WHERE id =%lu",family_id);
          // send notice here
		}
		out["status"] = "OK";
    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchFamilyAdd(CVars in, CVars &out)");
    }
  logfmt(logINFO, "WrenchFamilyAdd()");
return family_id;
}

long  WrenchFamilyUpdate(CVars in, CVars &out){
 long ret = PHP_API_BAD_PARAM;
  logfmt(logINFO, "WrenchFamilyUpdate()");
  long family_id = 0;
  try {
		long member_id = REQ_LONG(in, "member_id", 1, -1);
		REQ_STRING(in, "firstname", 2, 34, "(.*)");
		REQ_STRING(in, "lastname", 2, 34, "(.*)");
		REQ_STRING(in, "family_uid", 2, 50, "(.*)");
        CVars x;
        x["firstname"] = in["firstname"];
        x["firstname"].set_valid(true);
        x["lastname"] = in["lastname"];
        x["lastname"].set_valid(true);

        const PGresult *res = pgsql_query(" SELECT id AS family_id FROM members_family "
                                          " WHERE member_id=%lu AND uid='%s' ", member_id,in["family_uid"].c_str());
        if (res != NULL && pgsql_num_rows(res) > 0) {
            map<const char*, const char*>f = pgsql_fetch_assoc(res, 0);
            CVars rec;
            map_to_cvars(f, rec);
            update_db_record(DBS_VALID, "members_family", x, rec["family_id"].Long());
            ret = PHP_API_OK;
        }
		out["status"] = "OK";
    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchFamilyUpdate(CVars in, CVars &out)");
    }
 logfmt(logINFO, "WrenchFamilyUpdate()");
return ret;
}

long  WrenchFamilyInitializeAccount(CVars in, CVars &out);
long  WrenchFamilyManage(CVars in, CVars &out){
/*
wrenchboard=> select * from members_family;
 id | member_id | firstname | lastname | age | active | status | added | updated
----+-----------+-----------+----------+-----+--------+--------+-------+---------
(0 rows)
*/
 long ret = PHP_API_BAD_PARAM;
  logfmt(logINFO, "WrenchFamilyManage()");
  long family_id = 0;
  try {
		long member_id = REQ_LONG(in, "member_id", 1, -1);
		REQ_STRING(in, "uid", 2, 45, "(.*)");
		REQ_STRING(in, "family_uid", 2, 45, "(.*)");

        const PGresult *res = pgsql_query(" SELECT id AS family_id,* FROM members_family "
                                          " WHERE member_id=%lu AND uid='%s' ", member_id,in["family_uid"].c_str());
        if (res != NULL && pgsql_num_rows(res) > 0) {
            map<const char*, const char*>f = pgsql_fetch_assoc(res, 0);
            CVars rec;
            map_to_cvars(f, rec);
            if( rec["username"]=="" || rec["pin"]==""){
              logfmt(logINFO, "WrenchFamilyManage()- NEED TI INITIALIZE  USERNAME PIN");
              WrenchFamilyInitializeAccount(rec,out);
            }
            out = rec;
            ret = PHP_API_OK;
        }
		out["status"] = "OK";
    } catch (bad_parameter) {
        logfmt(logINFO, "ERROR CALL long WrenchFamilyUpdate(CVars in, CVars &out)");
    }

  logfmt(logINFO, "/WrenchFamilyManage()");
return ret;
}

long  WrenchFamilyInitializeAccount(CVars in, CVars &out){
const PGresult *res;
char username[7] = "";
    logfmt(logINFO, "WrenchFamilyInitializeAccount()");
    try {

            SetFamilyUsername(in["family_id"].Long(), username, 6);
             } catch (bad_parameter) {
                logfmt(logINFO, "ERROR CALL void SetFamilyUsername(CVars in, CVars &out)");
        }
/*
    int r1;
    //srand(time(NULL));
    r1 = 1000+(rand()%9000);
    pgsql_exec("UPDATE members_family SET pin='%s' WHERE id=%lu", r1, in["family_id"].Long() );
  */

     pgsql_exec("UPDATE members_family SET pin='1234' WHERE id=%lu", in["family_id"].Long() );

    load_db_record(out, "SELECT * FROM members_family WHERE id = %lu", in["family_id"].Long());

return 0;
}



/*

#define WRENCHBOARD_FAMILY_LIST           22010
#define WRENCHBOARD_FAMILY_ADD            22015
#define WRENCHBOARD_FAMILY_UPDATE         22020
#define WRENCHBOARD_FAMILY_MANAGE         22025
*/