FIX add autofix of count of email target when data is corrupted
This commit is contained in:
parent
8658f903fa
commit
360a85cbbc
@ -481,11 +481,27 @@ if ($object->fetch($id) >= 0)
|
|||||||
$sql .= " mc.source_url, mc.source_id, mc.source_type, mc.error_text";
|
$sql .= " mc.source_url, mc.source_id, mc.source_type, mc.error_text";
|
||||||
$sql .= " FROM ".MAIN_DB_PREFIX."mailing_cibles as mc";
|
$sql .= " FROM ".MAIN_DB_PREFIX."mailing_cibles as mc";
|
||||||
$sql .= " WHERE mc.fk_mailing=".$object->id;
|
$sql .= " WHERE mc.fk_mailing=".$object->id;
|
||||||
if ($search_lastname) $sql .= natural_search("mc.lastname", $search_lastname);
|
$asearchcriteriahasbeenset = 0;
|
||||||
if ($search_firstname) $sql .= natural_search("mc.firstname", $search_firstname);
|
if ($search_lastname) {
|
||||||
if ($search_email) $sql .= natural_search("mc.email", $search_email);
|
$sql .= natural_search("mc.lastname", $search_lastname);
|
||||||
if ($search_other) $sql .= natural_search("mc.other", $search_other);
|
$asearchcriteriahasbeenset++;
|
||||||
if ($search_dest_status != '' && $search_dest_status >= -1) $sql .= " AND mc.statut=".$db->escape($search_dest_status)." ";
|
}
|
||||||
|
if ($search_firstname) {
|
||||||
|
$sql .= natural_search("mc.firstname", $search_firstname);
|
||||||
|
$asearchcriteriahasbeenset++;
|
||||||
|
}
|
||||||
|
if ($search_email) {
|
||||||
|
$sql .= natural_search("mc.email", $search_email);
|
||||||
|
$asearchcriteriahasbeenset++;
|
||||||
|
}
|
||||||
|
if ($search_other) {
|
||||||
|
$sql .= natural_search("mc.other", $search_other);
|
||||||
|
$asearchcriteriahasbeenset++;
|
||||||
|
}
|
||||||
|
if ($search_dest_status != '' && $search_dest_status >= -1) {
|
||||||
|
$sql .= " AND mc.statut=".$db->escape($search_dest_status)." ";
|
||||||
|
$asearchcriteriahasbeenset++;
|
||||||
|
}
|
||||||
$sql .= $db->order($sortfield, $sortorder);
|
$sql .= $db->order($sortfield, $sortorder);
|
||||||
|
|
||||||
// Count total nb of records
|
// Count total nb of records
|
||||||
@ -499,6 +515,18 @@ if ($object->fetch($id) >= 0)
|
|||||||
$page = 0;
|
$page = 0;
|
||||||
$offset = 0;
|
$offset = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Fix/update nbemail on emailing record if it differs (may happen if user edit lines from database directly)
|
||||||
|
if (empty($asearchcriteriahasbeenset)) {
|
||||||
|
if ($nbtotalofrecords != $object->email) {
|
||||||
|
dol_syslog("We found a difference in nb of record in target table and the property ->nbemail, we fix ->nbemail");
|
||||||
|
//print "nbemail=".$object->nbemail." nbtotalofrecords=".$nbtotalofrecords;
|
||||||
|
$resultrefresh = $object->refreshNbOfTargets();
|
||||||
|
if ($resultrefresh < 0) {
|
||||||
|
dol_print_error($db, $object->error, $object->errors);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//$nbtotalofrecords=$object->nbemail; // nbemail is a denormalized field storing nb of targets
|
//$nbtotalofrecords=$object->nbemail; // nbemail is a denormalized field storing nb of targets
|
||||||
|
|||||||
@ -461,6 +461,8 @@ class Mailing extends CommonObject
|
|||||||
$resql = $this->db->query($sql);
|
$resql = $this->db->query($sql);
|
||||||
if ($resql)
|
if ($resql)
|
||||||
{
|
{
|
||||||
|
$this->refreshNbOfTargets();
|
||||||
|
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@ -532,6 +534,38 @@ class Mailing extends CommonObject
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Refresh denormalized value ->nbemail into emailing record
|
||||||
|
* Note: There is also the method update_nb into modules_mailings that is used for this.
|
||||||
|
*
|
||||||
|
* @return int <0 if KO, >0 if OK
|
||||||
|
*/
|
||||||
|
public function refreshNbOfTargets()
|
||||||
|
{
|
||||||
|
$sql = "SELECT COUNT(rowid) as nb FROM ".MAIN_DB_PREFIX."mailing_cibles";
|
||||||
|
$sql .= " WHERE fk_mailing = ".$this->id;
|
||||||
|
|
||||||
|
$resql = $this->db->query($sql);
|
||||||
|
if ($resql) {
|
||||||
|
$obj = $this->db->fetch_object($resql);
|
||||||
|
if ($obj) {
|
||||||
|
$nbforupdate = $obj->nb;
|
||||||
|
|
||||||
|
$sql = 'UPDATE '.MAIN_DB_PREFIX.'mailing SET nbemail = '.((int) $nbforupdate);
|
||||||
|
$sql .= ' WHERE rowid = '.$this->id;
|
||||||
|
|
||||||
|
$resqlupdate = $this->db->query($sql);
|
||||||
|
if (! $resqlupdate) {
|
||||||
|
$this->error = $this->db->lasterror();
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
$this->error = $this->db->lasterror();
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Return a link to the object card (with optionally the picto)
|
* Return a link to the object card (with optionally the picto)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user