Feat/get consumption data

src/request.js

@@ -4,14 +4,14 @@ const { log } = require('cozy-konnector-libs')
 /**
  * Query SGE in order to get info
  * @param {number} pointId
- * @param {string} userLogin
+ * @param {string} appLogin
  * @param {string} startDt
  * @param {string} endDt
  * @returns {string}
  */
 function userMesureDetailles(
   pointId,
-  userLogin,
+  appLogin,
   startDt,
   endDt,
   mesureType = 'ENERGIE',
@@ -29,7 +29,7 @@ function userMesureDetailles(
      <soapenv:Body>
         <v2:consulterMesuresDetaillees>
            <demande>
-              <initiateurLogin>${userLogin}</initiateurLogin>
+              <initiateurLogin>${appLogin}</initiateurLogin>
               <pointId>${pointId}</pointId>
               <mesuresTypeCode>${mesureType}</mesuresTypeCode>
               <grandeurPhysique>${unit}</grandeurPhysique>
@@ -49,10 +49,10 @@ function userMesureDetailles(
 /**
  * Get user technical data
  * @param {number} pointId
- * @param {string} userLogin
+ * @param {string} appLogin
  * @returns {string}
  */
-function userTechnicalData(pointId, userLogin) {
+function userTechnicalData(pointId, appLogin) {
   log('info', `Query userMesureDetailles`)
   return `<?xml version='1.0' encoding='utf-8'?>
   <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
@@ -62,7 +62,7 @@ function userTechnicalData(pointId, userLogin) {
      <soapenv:Body>
         <v2:consulterDonneesTechniquesContractuelles>
            <pointId>${pointId}</pointId>
-           <loginUtilisateur>${userLogin}</loginUtilisateur>
+           <loginUtilisateur>${appLogin}</loginUtilisateur>
            <autorisationClient>true</autorisationClient>
         </v2:consulterDonneesTechniquesContractuelles>
      </soapenv:Body>
@@ -73,12 +73,12 @@ function userTechnicalData(pointId, userLogin) {
 /**
  * Get user max power
  * @param {number} pointId
- * @param {string} userLogin
+ * @param {string} appLogin
  * @param {string} startDt
  * @param {string} endDt
  * @returns {string}
  */
-function userMaxPower(pointId, userLogin, startDt, endDt) {
+function userMaxPower(pointId, appLogin, startDt, endDt) {
   log('info', `Query userMesureDetailles`)
   return `<?xml version='1.0' encoding='utf-8'?>
   <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
@@ -88,7 +88,7 @@ function userMaxPower(pointId, userLogin, startDt, endDt) {
       <soapenv:Body>
           <v2:consulterMesuresDetaillees>
               <demande>
-                  <initiateurLogin>${userLogin}</initiateurLogin>
+                  <initiateurLogin>${appLogin}</initiateurLogin>
                   <pointId>${pointId}</pointId>
                   <mesuresTypeCode>PMAX</mesuresTypeCode>
                   <grandeurPhysique>PMA</grandeurPhysique>
@@ -106,8 +106,158 @@ function userMaxPower(pointId, userLogin, startDt, endDt) {
   `
 }
 
+/**
+ * Use rechercherPoint to find user PDL if exist
+ * @param {string} name
+ * @param {string} postalCode
+ * @param {string} address
+ * @returns {string} PDL
+ */
+function searchUser(appLogin, name, postalCode, inseeCode, address) {
+  log('info', `Query searchUser`)
+  return `<?xml version='1.0' encoding='utf-8'?>
+  <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
+     xmlns:v2="http://www.enedis.fr/sge/b2b/services/rechercherpoint/v2.0"
+     xmlns:v1="http://www.enedis.fr/sge/b2b/technique/v1.0">
+     <soapenv:Header/>
+     <soapenv:Body>
+        <v2:rechercherPoint>
+           <criteres>
+              <adresseInstallation>
+                 <numeroEtNomVoie>${address}</numeroEtNomVoie>
+                 <codePostal>${postalCode}</codePostal>
+                 <codeInseeCommune>${inseeCode}</codeInseeCommune>
+              </adresseInstallation>
+              <nomClientFinalOuDenominationSociale>${name}</nomClientFinalOuDenominationSociale>
+              <rechercheHorsPerimetre>true</rechercheHorsPerimetre>
+           </criteres>
+           <loginUtilisateur>${appLogin}</loginUtilisateur>
+        </v2:rechercherPoint>
+     </soapenv:Body>
+  </soapenv:Envelope>`
+}
+
+/**
+ * Search if user as a service
+ * @param {string} appLogin
+ * @param {string} contractId
+ * @param {string} pointId
+ * @returns {*}
+ */
+function searchServiceSouscrit(appLogin, contractId, pointId) {
+  log('info', `Query activateDataCollect`)
+  return `<?xml version='1.0' encoding='utf-8'?>
+  <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
+     xmlns:v2="http://www.enedis.fr/sge/b2b/rechercherservicessouscritsmesures/v1.0"
+     xmlns:v1="http://www.enedis.fr/sge/b2b/technique/v1.0">
+      <soapenv:Header/>
+      <soapenv:Body>
+          <v2:rechercherServicesSouscritsMesures>
+            <criteres>
+              <pointId>${pointId}</pointId>
+              <contratId>${contractId}</contratId>
+            </criteres>
+            <loginUtilisateur>${appLogin}</loginUtilisateur>
+          </v2:rechercherServicesSouscritsMesures>
+      </soapenv:Body>
+  </soapenv:Envelope>`
+}
+
+/**
+ * Activate half hour data collect for user
+ * @param {string} appLogin
+ * @param {string} contractId
+ * @param {string} pointId
+ * @param {string} name
+ * @param {string} startDate
+ * @param {string} endDate
+ * @returns {*}
+ */
+function activateDataCollect(
+  appLogin,
+  contractId,
+  pointId,
+  name,
+  startDate,
+  endDate
+) {
+  log('info', `Query activateDataCollect`)
+  return `<?xml version='1.0' encoding='utf-8'?>
+  <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
+     xmlns:v2="http://www.enedis.fr/sge/b2b/commandercollectepublicationmesures/v3.0"
+     xmlns:v1="http://www.enedis.fr/sge/b2b/technique/v1.0">
+      <soapenv:Header/>
+      <soapenv:Body>
+          <v2:commanderCollectePublicationMesures>
+              <demande>
+                  <donneesGenerales>
+                      <objetCode>AME</objetCode>
+                      <pointId>${pointId}</pointId>
+                      <initiateurLogin>${appLogin}</initiateurLogin>
+                      <contratId>${contractId}</contratId>
+                  </donneesGenerales>
+                  <accesMesures>
+                      <dateDebut>${startDate}</dateDebut>
+                      <dateFin>${endDate}</dateFin>
+                      <declarationAccordClient>
+                          <accord>true</accord>
+                          <personnePhysique>
+                              <nom>${name}</nom>
+                          </personnePhysique>
+                      </declarationAccordClient>
+                      <mesuresTypeCode>CDC</mesuresTypeCode>
+                      <soutirage>true</soutirage>
+                      <injection>false</injection>
+                      <mesuresPas>PT30M</mesuresPas>
+                      <mesuresCorrigees>false</mesuresCorrigees>
+                      <transmissionRecurrente>true</transmissionRecurrente>
+                      <periodiciteTransmission>P1D</periodiciteTransmission>
+                  </accesMesures>
+              </demande>
+          </v2:commanderCollectePublicationMesures>
+      </soapenv:Body>
+  </soapenv:Envelope>`
+}
+
+/**
+ *
+ * @param {string} appLogin
+ * @param {string} contractId
+ * @param {string} pointId
+ * @param {string} serviceSouscritId
+ * @returns {*}
+ */
+function stopDataCollect(appLogin, contractId, pointId, serviceSouscritId) {
+  log('info', `Query stopDataCollect`)
+  return `<?xml version='1.0' encoding='utf-8'?>
+  <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
+     xmlns:v2="http://www.enedis.fr/sge/b2b/commanderarretservicesouscritmesures/v1.0"
+     xmlns:v1="http://www.enedis.fr/sge/b2b/technique/v1.0">
+      <soapenv:Header/>
+      <soapenv:Body>
+          <v2:commanderArretServiceSouscritMesures>
+              <demande>
+                  <donneesGenerales>
+                      <objetCode>ASS</objetCode>
+                      <pointId>${pointId}</pointId>
+                      <initiateurLogin>${appLogin}</initiateurLogin>
+                      <contratId>${contractId}</contratId>
+                  </donneesGenerales>
+                  <arretServiceSouscrit>
+                  <serviceSouscritId>${serviceSouscritId}</serviceSouscritId>
+                  </arretServiceSouscrit>
+              </demande>
+          </v2:commanderArretServiceSouscritMesures>
+      </soapenv:Body>
+  </soapenv:Envelope>`
+}
+
 module.exports = {
   userTechnicalData,
   userMaxPower,
   userMesureDetailles,
+  searchUser,
+  searchServiceSouscrit,
+  activateDataCollect,
+  stopDataCollect,
 }