- 01
- 02
- 03
- 04
- 05
- 06
- 07
- 08
- 09
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
boolean loadPPOGroupCompleted(string customerRef, string competence, string marketArea) {
int i = 0;
table sceData = getPPOPODGroupSCEs(customerRef, competence, marketArea);
table dceData = getPPOPODGroupDCEs(customerRef, competence, marketArea);
table sbilData = getPPOPODGroupSbil(customerRef, competence, marketArea);
while (i < tableRowCount(sceData)) {
EventRec sce = convertStoredSCRtoEventRec(false, sceData, i, "", competence);
if ((string)tableGet(sceData, i, "ACTION_TYPE") == ACTION_REP) {
udrRoute(sce, "toSE_Agg_rer");
isReplaceAction = true;
} else {
udrRoute(sce, "toSE_Agg_evt");
}
i = i+ 1;
}
i = 0;
while (i < tableRowCount(dceData)) {
EventRec dce = convertStoredDCRtoEventRec(false, dceData, i, "", competence);
if ((string)tableGet(dceData, i, "ACTION_TYPE") == ACTION_REP) {
udrRoute(dce, "toSE_Agg_rer");
isReplaceAction = true;
} else {
udrRoute(dce, "toSE_Agg_evt");
}
i = i+ 1;
}
i = 0;
while (i < tableRowCount(sbilData)) {
EventRec sbilEvent = convertStoredSbiltoEventRec(sbilData, i, PPO_ZONALE, competence);
if ((string)tableGet(sbilData, i, "ACTION_TYPE") == ACTION_REP) {
udrRoute(sbilEvent, "toSE_Agg_rer");
isReplaceAction = true;
} else {
udrRoute(sbilEvent, "toSE_Agg_evt");
}
i = i + 1;
}
return true;
}
boolean loadGroupCompleted(string customerRef, string competence, date minStartDate) {
table sceData = getGroupSCEs(customerRef, competence);
table dceData = getGroupDCEs(customerRef, competence);
int i = 0;
string extPODCode, hour_date, hour_value, eventDTM, hourlyConsumption, totalF0GroupConsumption, treatmentType, consumptionType, actionType, edmID;
while (i < tableRowCount(sceData)) {
EventRec sce = convertStoredSCRtoEventRec(true, sceData, i, "", competence);
if ((string)tableGet(sceData, i, "ACTION_TYPE") == ACTION_REP) {
udrRoute(sce, "toSE_Agg_rer");
isReplaceAction = true;
} else {
udrRoute(sce, "toSE_Agg_evt");
}
i = i + 1;
}
i = 0;
while (i < tableRowCount(dceData)) {
EventRec dce = convertStoredDCRtoEventRec(true, dceData, i, "", competence);
if ((string)tableGet(dceData, i, "ACTION_TYPE") == ACTION_REP) {
udrRoute(dce, "toSE_Agg_rer");
isReplaceAction = true;
} else {
udrRoute(dce, "toSE_Agg_evt");
}
i = i + 1;
}
if (isGroupHasPPO(customerRef, minStartDate)) {
table sbilData = getPPOGroupSbil(customerRef, competence);
i = 0;
while (i < tableRowCount(sbilData)) {
EventRec sbilEvent = convertStoredSbiltoEventRec(sbilData, i, PPO_ZONALE, competence);
if ((string)tableGet(sbilData, i, "ACTION_TYPE") == ACTION_REP) {
udrRoute(sbilEvent, "toSE_Agg_rer");
isReplaceAction = true;
} else {
udrRoute(sbilEvent, "toSE_Agg_evt");
}
i = i + 1;
}
}
return true;
}