merci pour vos retours
bonne journée
par merguez07 » 29 Jan 2021 11:37
<?php
// script créé par Connected Object pour eedomus
// les données sont mises à jour 1x par jour entre 7h et 8h
// Enedis nous demande d'être raisonnable et de ne réaliser qu'un appel par jour
// merci de ne pas modifier les valeurs de fréquences et de cache pour le maintien du service
$api_url = 'https://gw.prd.api.enedis.fr/';
$prev_code = loadVariable('code');
// on reprend le dernier refresh_token seulement s'il correspond au même code
$refresh_token = loadVariable('refresh_token');
$expire_time = loadVariable('expire_time');
// s'il n'a pas expiré, on peut reprendre l'access_token
if (time() < $expire_time)
{
$access_token = loadVariable('access_token');
}
// on a déjà un token d'accés non expiré pour le code demandée
if ($access_token == '' || $_GET['oauth_code'] != '')
{
if ($_GET['oauth_code'] != '')
{
$code = $_GET['oauth_code'];
}
else
{
$code = $prev_code;
}
if (strlen($refresh_token) > 1 && $_GET['oauth_code'] == '')
{
// on peut juste rafraichir le token
$grant_type = 'refresh_token';
$postdata = 'grant_type='.$grant_type.'&refresh_token='.$refresh_token;
}
else
{
if ($code == '')
{
echo "## ERROR: Empty code for grant_type=".$grant_type;
die();
}
// 1ère utilisation aprés obtention du code
$grant_type = 'authorization_code';
$redirect_uri = 'https://secure.eedomus.com/sdk/plugins/enedis_app/callback';
$postdata = 'grant_type='.$grant_type.'&code='.$code.'&redirect_uri='.($redirect_uri);
}
$url = $api_url.'v1/oauth2/token';
$response = httpQuery($url, 'POST', $postdata, 'enedis_oauth');
//var_dump($url, $postdata, $response);
$params = sdk_json_decode($response);
if ($params['error'] != '')
{
die("Erreur lors de l'authentification:"." [".$params['error'].'] (grant_type='.$grant_type.'),<br>vous pouvez lier à nouveau votre compte en cliquant sur [Lier à nouveau] depuis la configuration de votre périphérique<br><br>'.$response);
}
// on sauvegarde l'access_token et le refresh_token pour les authentifications suivantes
if (isset($params['refresh_token']))
{
$access_token = $params['access_token'];
saveVariable('access_token', $access_token);
saveVariable('refresh_token', $params['refresh_token']);
saveVariable('expire_time', time()+$params['expires_in']);
if ($code != '')
{
saveVariable('code', $code);
}
}
else if ($access_token == '')
{
die("Erreur lors de l'authentification,<br>vous pouvez lier à nouveau votre compte en cliquant sur [Lier à nouveau] depuis la configuration de votre périphérique\n\n".$response);
}
}
if ($_GET['mode'] == 'verify')
{
?><!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<title>eedomus</title>
<style type="text/css">
body,td,th {
font-family: Arial, Helvetica, sans-serif;
font-size: 14px;
}
</style>
<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1" />
</head><?
$usage_point_id = $_GET['usage_point_id'];
saveVariable('last_daily_consumption_'.$usage_point_id, '');
saveVariable('last_consumption_load_curve_'.$usage_point_id, '');
echo '<br>';
echo "Voici votre identifiant de point d'usage Enedis, à copier/coller dans votre périphérique eedomus :";
echo '<br>';
echo '<br>';
echo '<input type="text" name="usage_point_id" value="'.$usage_point_id.'" onclick="this.select();" readonly>';
die();
}
$headers = array("Accept: application/json", "Authorization: Bearer $access_token");
$usage_point_id = getArg('usage_point_id');
$last_xml_success = loadVariable('last_xml_success_'.$usage_point_id);
if ((date('G') >= 8 && date('G') <= 23 && date('Ymd') != date('Ymd', $last_xml_success))||($_GET['mode'] == 'test'))
{
$is_cache = 0;
// sinon à minuit : "The end date parameter must be earlier than the current date."
$tms = mktime() - 60 * 60;
$today = date('Y-m-d', $tms);
$yesterday = $today;
while ($yesterday == $today)
{
$tms -= 24*60*60;
$yesterday = date('Y-m-d', $tms);
}
$url = $api_url.'v3/customers/usage_points/contracts?usage_point_id='.$usage_point_id;
$response = httpQuery($url, 'GET', NULL, NULL, $headers);
//var_dump($url, $response);
$xml .= jsonToXML($response);
saveVariable('contracts_'.$usage_point_id, $response);
$url = $api_url.'v3/metering_data/daily_consumption?start='.$yesterday.'&end='.$today.'&usage_point_id='.$usage_point_id;
$response = httpQuery($url, 'GET', NULL, NULL, $headers);
saveVariable('response_daily_consumption_'.$usage_point_id, $response);
//var_dump($url, $response);
$xml .= jsonToXML($response);
}
else
{
$is_cache = 1;
$response = loadVariable('contracts_'.$usage_point_id);
$xml .= jsonToXML($response);
$response = loadVariable('response_daily_consumption_'.$usage_point_id);
$xml .= jsonToXML($response);
}
$json = sdk_json_decode($response);
$consumption_date = $json['usage_point'][0]['meter_reading']['end'];
$consumption_value = $json['usage_point'][0]['meter_reading']['interval_reading'][0]['value'];
$last_daily_consumption = loadVariable('last_daily_consumption_'.$usage_point_id);
$daily_consumption_count = 0;
if ($consumption_date != '' && $last_daily_consumption != $consumption_date)
{
$list = getPeriphList($show_notes = false, $filter_device_id = $_GET['eedomus_controller_module_id']);
foreach ($list as $device)
{
if ($device['unit'] == 'Wh')
{
$daily_consumption_controller_module_id = $device['device_id'];
}
}
if ($daily_consumption_controller_module_id > 0)
{
$cur_consumption_time = strtotime($consumption_date);
$cur_consumption_time_txt = date('Y-m-d H:i:s', $cur_consumption_time);
if ($consumption_value !== '')
{
setValue($daily_consumption_controller_module_id, $consumption_value, $verify_value_list = false, $update_only = false, $cur_consumption_time_txt);
saveVariable('last_daily_consumption_'.$usage_point_id, $consumption_date);
$daily_consumption_count++;
}
}
}
//$is_cache=0;
if ($is_cache)
{
$response = loadVariable('consumption_load_curve_'.$usage_point_id);
}
else
{
$url = $api_url.'v4/metering_data/consumption_load_curve?start='.$yesterday.'&end='.$today.'&usage_point_id='.$usage_point_id;
$response = httpQuery($url, 'GET', NULL, NULL, $headers);
$json = sdk_json_decode($response);
if ($json['error']!=NULL) {
$xml .= jsonToXML($response);
echo $xml;
die;
}
saveVariable('consumption_load_curve_'.$usage_point_id, $response);
}
//var_dump($url, $response);
$xml .= jsonToXML($response);
$json = sdk_json_decode($response);
if ($json['error']!=NULL) {
echo $xml;
die;
}
//var_dump($json);die;
//$consumption_date = $json['usage_point'][0]['meter_reading']['start'];
$consumption_date = $json['meter_reading']['start'];
$last_consumption_load_curve = loadVariable('last_consumption_load_curve_'.$usage_point_id);
$consumption_load_count = 0;
if ($consumption_date != '' && $last_consumption_load_curve != $consumption_date)
{
$list = getPeriphList($show_notes = false, $filter_device_id = $_GET['eedomus_controller_module_id']);
foreach ($list as $device)
{
if ($device['unit'] == 'W')
{
$consumption_load_curve_controller_module_id = $device['device_id'];
}
}
if ($consumption_load_curve_controller_module_id > 0)
{
foreach($json['meter_reading']['interval_reading'] as $reading)
{
//$consumption_rank = $reading['rank'];
//$cur_consumption_time = strtotime($consumption_date) + $consumption_rank * 30 * 60;
//$cur_consumption_time_txt = date('Y-m-d H:i:s', $cur_consumption_time);
$cur_consumption_time_txt = $reading['date'];
if ($consumption_value !== '')
{
$consumption_value = $reading['value'];
setValue($consumption_load_curve_controller_module_id, $consumption_value, $verify_value_list = false, $update_only = false, $cur_consumption_time_txt);
$consumption_load_count++;
}
}
if ($consumption_load_count > 0)
{
saveVariable('last_consumption_load_curve_'.$usage_point_id, $consumption_date);
}
}
}
$debug = "\ndaily_consumption_controller_module_id = $daily_consumption_controller_module_id,
daily_consumption_count = $daily_consumption_count,
consumption_load_curve_controller_module_id = $consumption_load_curve_controller_module_id,
consumption_date = $consumption_date,
consumption_load_count = $consumption_load_count\n";
sdk_header('text/xml');
$xml = str_replace("</root><?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n<root>", '', $xml);
$xml = str_replace('</root>', "<debug>".$debug."</debug>\n</root>", $xml);
if ($is_cache)
{
$xml = str_replace('<root>', "<root><cached>1</cached>", $xml);
}
else
{
$xml = str_replace('<root>', "<root><cached>0</cached>", $xml);
if ($xml != '' && strpos($xml, 'Invalid_request') === false) // non vide
{
saveVariable('cached_xml_'.$usage_point_id, $xml);
saveVariable('last_xml_success_'.$usage_point_id, time());
}
}
echo $xml;
?>par dommarion » 29 Jan 2021 12:27
par ThierryStrad » 29 Jan 2021 15:20
ThierryStrad a écrit:J'ai installé hier soir la modif du script (merci à Dommarion et Merguez07)
Je récupère les 3 infos souhaitées :L'historique horaire sur 24h (consommation Linky)
La conso veille Linky
Puissance souscrite
Bref ça fonctionne !
Merci !
par Fab_Rice » 29 Jan 2021 15:48
par merguez07 » 29 Jan 2021 17:10
ThierryStrad a écrit:Je corrige : je récupère bien des données, pas en totalité. Je retrouve le bug que j'avais en 2020 : je ne récupère que les données ENEDIS de la seconde partie de la journée : de 14jh à 24h.
par merguez07 » 29 Jan 2021 18:48
Fab_Rice a écrit:Bon, pour moi ça reste "ERREUR: Valeur lue vide", on verra plus tard hein
. par Fab_Rice » 29 Jan 2021 19:15
par merguez07 » 29 Jan 2021 20:19
Fab_Rice a écrit:Bon, pour moi ça reste "ERREUR: Valeur lue vide", on verra plus tard hein
par Fab_Rice » 29 Jan 2021 20:44
par Fab_Rice » 29 Jan 2021 20:52
par merguez07 » 29 Jan 2021 23:15
Fab_Rice a écrit:C'est bon ça marche, faut dire aussi que je n'avais pas pigé qu'il fallait ajouter le "&mode=test" dans l'URL de la requête et non dans le test comme je le faisais en mode "bourrin".
par surgeon84fr » 30 Jan 2021 07:17
par Fab_Rice » 30 Jan 2021 07:38
merguez07 a écrit:Fab_Rice a écrit:C'est bon ça marche, faut dire aussi que je n'avais pas pigé qu'il fallait ajouter le "&mode=test" dans l'URL de la requête et non dans le test comme je le faisais en mode "bourrin".
non, non il ne faut pas mettre "&mode=test" dans l'URL de la requête (sinon tu vas avoir une requête chaque heure et tu vas te faire blacklister)
c'est juste quand tu fais un test dans l'URL du test que tu peux le faire si la mise à jour n'a pas marché
par dommarion » 30 Jan 2021 08:13
par Fab_Rice » 30 Jan 2021 08:27
par merguez07 » 30 Jan 2021 09:45
Fab_Rice a écrit:Mouaip, ça marchait hier, puis pas de MAJ aujourd'hui, dernière valeur 29/01 00h00.
Fab_Rice a écrit:Par contre le script du "2021-01-29 10:19" contient la dernière MAJ ou pas ?
par Fab_Rice » 30 Jan 2021 10:49
par ThierryStrad » 30 Jan 2021 18:44
merguez07 a écrit:ThierryStrad a écrit:Je corrige : je récupère bien des données, pas en totalité. Je retrouve le bug que j'avais en 2020 : je ne récupère que les données ENEDIS de la seconde partie de la journée : de 14jh à 24h.
tu as quoi comme xml quand tu lances un test ?
CONTENU ANALYSE PAR MERGUEZ07, j'efface pour alléger la lecture de ce forum>
par merguez07 » 30 Jan 2021 19:11
Retour vers Scripts & Périphériques du store
Utilisateurs parcourant ce forum : Aucun utilisateur inscrit et 28 invité(s)