import("system.datetime");
import("system.result");
import("system.vars");
import("system.entities");
import("system.db");
import("system.logging");
import("system.util");
import("Util_lib");

var res = [];

var currId = null;
var alias = vars.get("$local.indexgroupAlias");
if(vars.exists("$local.idvalue"))
{
    
    currId = vars.get("$local.idvalue");
    
    addAddressIds(res, currId);
    addCommunicationIds(res, currId);
 
}

result.object(res);

function addIds(pRes, pConsumerName, pIds)
{
   var elem = [];
   elem[0]=pConsumerName;
   
   if(pIds == undefined || pIds == null || pIds.length <= 0) {
       elem[1] = "";
   }
   else {
       elem[1] = StringUtils.concat(",", pIds);
   }
   
   logging.log(elem);
   pRes.push(elem);
}

function addAddressIds(pRes, pCurrId)
{
    var sql, ids;
    sql = "select ADDRESS.ADDRESSID from ADDRESS left join CONTACT on CONTACT.CONTACTID = ADDRESS.CONTACT_ID where CONTACT.ORGANISATION_ID = '" + pCurrId + "'";
    ids = db.array(db.COLUMN, sql, alias, 0 , 1 * datetime.ONE_MINUTE);
    
    logging.log("Addresses: " + ids);
    addIds(pRes, "Addresses", ids);
}

function addCommunicationIds(pRes, pCurrId)
{
    var sql, ids;
    sql = "select COMMUNICATION.COMMUNICATIONID from COMMUNICATION left join CONTACT on CONTACT.CONTACTID = COMMUNICATION.CONTACT_ID where CONTACT.ORGANISATION_ID = '" + pCurrId + "'";
    ids = db.array(db.COLUMN, sql, alias, 0 , 1 * datetime.ONE_MINUTE);
    
    logging.log("Communications: " + ids);
    addIds(pRes, "Communications", ids);
}