modifs.mineures sans commentaires
This commit is contained in:
parent
4254e2ca44
commit
5490c78458
|
@ -189,8 +189,8 @@ class CapacitorChannel {
|
||||||
*
|
*
|
||||||
* cette méthode doit être utilisée dans {@link self::onUpdate()}
|
* cette méthode doit être utilisée dans {@link self::onUpdate()}
|
||||||
*/
|
*/
|
||||||
function wasRowModified(array $rowValues): bool {
|
function wasRowModified(array $values): bool {
|
||||||
return array_key_exists("modified_", $rowValues);
|
return array_key_exists("modified_", $values);
|
||||||
}
|
}
|
||||||
|
|
||||||
final function serialize($item): ?string {
|
final function serialize($item): ?string {
|
||||||
|
@ -224,10 +224,10 @@ class CapacitorChannel {
|
||||||
return array_combine($sumCols, [$serial, $sum]);
|
return array_combine($sumCols, [$serial, $sum]);
|
||||||
}
|
}
|
||||||
|
|
||||||
function wasSumModified(string $key, $value, array $prowValues): bool {
|
function wasSumModified(string $key, $value, array $pvalues): bool {
|
||||||
$sumCol = $this->getSumCols($key)[1];
|
$sumCol = $this->getSumCols($key)[1];
|
||||||
$sum = $this->sum(null, $value);
|
$sum = $this->sum(null, $value);
|
||||||
$psum = $prowValues[$sumCol] ?? $this->sum(null, $prowValues[$key] ?? null);
|
$psum = $pvalues[$sumCol] ?? $this->sum(null, $pvalues[$key] ?? null);
|
||||||
return $sum !== $psum;
|
return $sum !== $psum;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -243,10 +243,10 @@ class CapacitorChannel {
|
||||||
* créer un nouvel élément
|
* créer un nouvel élément
|
||||||
*
|
*
|
||||||
* @param mixed $item l'élément à charger
|
* @param mixed $item l'élément à charger
|
||||||
* @param array $rowValues la ligne à créer, calculée à partir de $item et des
|
* @param array $values la ligne à créer, calculée à partir de $item et des
|
||||||
* valeurs retournées par {@link getItemValues()}
|
* valeurs retournées par {@link getItemValues()}
|
||||||
* @return ?array le cas échéant, un tableau non null à merger dans $rowValues
|
* @return ?array le cas échéant, un tableau non null à merger dans $values et
|
||||||
* et utilisé pour provisionner la ligne nouvellement créée
|
* utilisé pour provisionner la ligne nouvellement créée
|
||||||
*
|
*
|
||||||
* Si $item est modifié dans cette méthode, il est possible de le retourner
|
* Si $item est modifié dans cette méthode, il est possible de le retourner
|
||||||
* avec la clé "item" pour mettre à jour la ligne correspondante.
|
* avec la clé "item" pour mettre à jour la ligne correspondante.
|
||||||
|
@ -256,7 +256,7 @@ class CapacitorChannel {
|
||||||
* peut techniquement retourner de nouvelles valeurs pour la clé primaire, ça
|
* peut techniquement retourner de nouvelles valeurs pour la clé primaire, ça
|
||||||
* risque de créer des doublons
|
* risque de créer des doublons
|
||||||
*/
|
*/
|
||||||
function onCreate($item, array $rowValues, ?array $alwaysNull): ?array {
|
function onCreate($item, array $values, ?array $alwaysNull): ?array {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -265,9 +265,9 @@ class CapacitorChannel {
|
||||||
* mettre à jour un élément existant
|
* mettre à jour un élément existant
|
||||||
*
|
*
|
||||||
* @param mixed $item l'élément à charger
|
* @param mixed $item l'élément à charger
|
||||||
* @param array $rowValues la nouvelle ligne, calculée à partir de $item et
|
* @param array $values la nouvelle ligne, calculée à partir de $item et
|
||||||
* des valeurs retournées par {@link getItemValues()}
|
* des valeurs retournées par {@link getItemValues()}
|
||||||
* @param array $prowValues la précédente ligne, chargée depuis la base de
|
* @param array $pvalues la précédente ligne, chargée depuis la base de
|
||||||
* données
|
* données
|
||||||
* @return ?array null s'il ne faut pas mettre à jour la ligne. sinon, ce
|
* @return ?array null s'il ne faut pas mettre à jour la ligne. sinon, ce
|
||||||
* tableau est mergé dans $values puis utilisé pour mettre à jour la ligne
|
* tableau est mergé dans $values puis utilisé pour mettre à jour la ligne
|
||||||
|
@ -277,7 +277,7 @@ class CapacitorChannel {
|
||||||
* - La clé primaire (il s'agit généralement de "id_") ne peut pas être
|
* - La clé primaire (il s'agit généralement de "id_") ne peut pas être
|
||||||
* modifiée. si elle est retournée, elle est ignorée
|
* modifiée. si elle est retournée, elle est ignorée
|
||||||
*/
|
*/
|
||||||
function onUpdate($item, array $rowValues, array $prowValues): ?array {
|
function onUpdate($item, array $values, array $pvalues): ?array {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -286,7 +286,7 @@ class CapacitorChannel {
|
||||||
* {@link Capacitor::each()}
|
* {@link Capacitor::each()}
|
||||||
*
|
*
|
||||||
* @param mixed $item l'élément courant
|
* @param mixed $item l'élément courant
|
||||||
* @param ?array $rowValues la ligne courante
|
* @param ?array $values la ligne courante
|
||||||
* @return ?array le cas échéant, un tableau non null utilisé pour mettre à
|
* @return ?array le cas échéant, un tableau non null utilisé pour mettre à
|
||||||
* jour la ligne courante
|
* jour la ligne courante
|
||||||
*
|
*
|
||||||
|
@ -294,7 +294,7 @@ class CapacitorChannel {
|
||||||
* - La clé primaire (il s'agit généralement de "id_") ne peut pas être
|
* - La clé primaire (il s'agit généralement de "id_") ne peut pas être
|
||||||
* modifiée. si elle est retournée, elle est ignorée
|
* modifiée. si elle est retournée, elle est ignorée
|
||||||
*/
|
*/
|
||||||
function onEach($item, array $rowValues): ?array {
|
function onEach($item, array $values): ?array {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -303,10 +303,10 @@ class CapacitorChannel {
|
||||||
* {@link Capacitor::delete()}
|
* {@link Capacitor::delete()}
|
||||||
*
|
*
|
||||||
* @param mixed $item l'élément courant
|
* @param mixed $item l'élément courant
|
||||||
* @param ?array $rowValues la ligne courante
|
* @param ?array $values la ligne courante
|
||||||
* @return bool true s'il faut supprimer la ligne, false sinon
|
* @return bool true s'il faut supprimer la ligne, false sinon
|
||||||
*/
|
*/
|
||||||
function onDelete($item, array $rowValues): bool {
|
function onDelete($item, array $values): bool {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -209,11 +209,11 @@ EOT;
|
||||||
$initFunc = [$channel, "getItemValues"];
|
$initFunc = [$channel, "getItemValues"];
|
||||||
$initArgs = $args;
|
$initArgs = $args;
|
||||||
func::ensure_func($initFunc, null, $initArgs);
|
func::ensure_func($initFunc, null, $initArgs);
|
||||||
$itemValues = func::call($initFunc, $item, ...$initArgs);
|
$values = func::call($initFunc, $item, ...$initArgs);
|
||||||
|
|
||||||
$row = cl::merge(
|
$row = cl::merge(
|
||||||
$channel->getSum("item", $item),
|
$channel->getSum("item", $item),
|
||||||
$this->serialize($channel, $itemValues));
|
$this->serialize($channel, $values));
|
||||||
$prow = null;
|
$prow = null;
|
||||||
$rowIds = $this->getRowIds($channel, $row, $primaryKeys);
|
$rowIds = $this->getRowIds($channel, $row, $primaryKeys);
|
||||||
if ($rowIds !== null) {
|
if ($rowIds !== null) {
|
||||||
|
@ -412,9 +412,9 @@ EOT;
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
$args ??= [];
|
$args ??= [];
|
||||||
foreach ($this->_all($channel, $filter) as $rowValues) {
|
foreach ($this->_all($channel, $filter) as $values) {
|
||||||
$rowIds = $this->getRowIds($channel, $rowValues);
|
$rowIds = $this->getRowIds($channel, $values);
|
||||||
$updates = func::_call($onEach, [$rowValues["item"], $rowValues, ...$args]);
|
$updates = func::_call($onEach, [$values["item"], $values, ...$args]);
|
||||||
if (is_array($updates) && $updates) {
|
if (is_array($updates) && $updates) {
|
||||||
if (!array_key_exists("modified_", $updates)) {
|
if (!array_key_exists("modified_", $updates)) {
|
||||||
$updates["modified_"] = date("Y-m-d H:i:s");
|
$updates["modified_"] = date("Y-m-d H:i:s");
|
||||||
|
@ -478,9 +478,9 @@ EOT;
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
$args ??= [];
|
$args ??= [];
|
||||||
foreach ($this->_all($channel, $filter) as $rowValues) {
|
foreach ($this->_all($channel, $filter) as $values) {
|
||||||
$rowIds = $this->getRowIds($channel, $rowValues);
|
$rowIds = $this->getRowIds($channel, $values);
|
||||||
$delete = boolval(func::_call($onEach, [$rowValues["item"], $rowValues, ...$args]));
|
$delete = boolval(func::_call($onEach, [$values["item"], $values, ...$args]));
|
||||||
if ($delete) {
|
if ($delete) {
|
||||||
$db->exec([
|
$db->exec([
|
||||||
"delete",
|
"delete",
|
||||||
|
|
Loading…
Reference in New Issue