64 public $element =
'emailcollector';
69 public $table_element =
'emailcollector_emailcollector';
74 public $picto =
'email';
79 public $fk_element =
'fk_emailcollector';
84 protected $childtables = array();
89 protected $childtablesoncascade = array(
'emailcollector_emailcollectorfilter',
'emailcollector_emailcollectoraction');
115 public $fields = array(
116 'rowid' => array(
'type' =>
'integer',
'label' =>
'TechnicalID',
'visible' => 2,
'enabled' => 1,
'position' => 1,
'notnull' => 1,
'index' => 1),
117 'entity' => array(
'type' =>
'integer',
'label' =>
'Entity',
'enabled' => 1,
'visible' => 0,
'default' => 1,
'notnull' => 1,
'index' => 1,
'position' => 20),
118 'ref' => array(
'type' =>
'varchar(128)',
'label' =>
'Ref',
'enabled' => 1,
'visible' => 1,
'notnull' => 1,
'showoncombobox' => 1,
'index' => 1,
'position' => 10,
'searchall' => 1,
'help' =>
'Example: MyCollector1',
'csslist' =>
'tdoverflowmax200'),
119 'label' => array(
'type' =>
'varchar(255)',
'label' =>
'Label',
'visible' => 1,
'enabled' => 1,
'position' => 30,
'notnull' => -1,
'searchall' => 1,
'help' =>
'Example: My Email collector',
'csslist' =>
'tdoverflowmax150',
'tdcss' =>
'titlefieldmiddle'),
120 'description' => array(
'type' =>
'text',
'label' =>
'Description',
'visible' => -1,
'enabled' => 1,
'position' => 60,
'notnull' => -1,
'cssview' =>
'small',
'csslist' =>
'small tdoverflowmax200'),
121 'host' => array(
'type' =>
'varchar(255)',
'label' =>
'EMailHost',
'visible' => 1,
'enabled' => 1,
'position' => 90,
'notnull' => 1,
'searchall' => 1,
'comment' =>
"IMAP server",
'help' =>
'Example: imap.gmail.com',
'csslist' =>
'tdoverflowmax125'),
122 'port' => array(
'type' =>
'varchar(10)',
'label' =>
'EMailHostPort',
'visible' => 1,
'enabled' => 1,
'position' => 91,
'notnull' => 1,
'searchall' => 0,
'comment' =>
"IMAP server port",
'help' =>
'Example: 993',
'csslist' =>
'tdoverflowmax50',
'default' =>
'993'),
123 'imap_encryption' => array(
'type' =>
'varchar(16)',
'label' =>
'ImapEncryption',
'visible' => -1,
'enabled' => 1,
'position' => 92,
'searchall' => 0,
'comment' =>
"IMAP encryption",
'help' =>
'ImapEncryptionHelp',
'arrayofkeyval' => array(
'ssl' =>
'SSL',
'tls' =>
'TLS',
'notls' =>
'NOTLS'),
'default' =>
'ssl'),
124 'hostcharset' => array(
'type' =>
'varchar(16)',
'label' =>
'HostCharset',
'visible' => -1,
'enabled' => 1,
'position' => 93,
'notnull' => 0,
'searchall' => 0,
'comment' =>
"IMAP server charset",
'help' =>
'Example: "UTF-8" (May be "US-ASCII" with some Office365)',
'default' =>
'UTF-8'),
125 'norsh' => array(
'type' =>
'integer',
'label' =>
'NoRSH',
'visible' => -1,
'enabled' =>
"!getDolGlobalInt('MAIN_IMAP_USE_PHPIMAP')",
'position' => 94,
'searchall' => 0,
'help' =>
'NoRSHHelp',
'arrayofkeyval' => array(0 =>
'No', 1 =>
'Yes'),
'default' => 0),
126 'acces_type' => array(
'type' =>
'integer',
'label' =>
'AuthenticationMethod',
'visible' => -1,
'enabled' =>
"getDolGlobalInt('MAIN_IMAP_USE_PHPIMAP')",
'position' => 101,
'notnull' => 1,
'index' => 1,
'comment' =>
"IMAP login type",
'arrayofkeyval' => array(
'0' =>
'loginPassword',
'1' =>
'oauthToken'),
'default' =>
'0',
'help' =>
''),
127 'login' => array(
'type' =>
'varchar(128)',
'label' =>
'Login',
'visible' => -1,
'enabled' => 1,
'position' => 102,
'notnull' => -1,
'index' => 1,
'comment' =>
"IMAP login",
'help' =>
'Example: myaccount@gmail.com'),
128 'password' => array(
'type' =>
'password',
'label' =>
'Password',
'visible' => -1,
'enabled' =>
"1",
'position' => 103,
'notnull' => -1,
'comment' =>
"IMAP password",
'help' =>
'WithGMailYouCanCreateADedicatedPassword'),
129 'oauth_service' => array(
'type' =>
'varchar(128)',
'label' =>
'oauthService',
'visible' => -1,
'enabled' =>
"getDolGlobalInt('MAIN_IMAP_USE_PHPIMAP')",
'position' => 104,
'notnull' => 0,
'index' => 1,
'comment' =>
"IMAP login oauthService",
'arrayofkeyval' => array(),
'help' =>
'TokenMustHaveBeenCreated'),
130 'source_directory' => array(
'type' =>
'varchar(255)',
'label' =>
'MailboxSourceDirectory',
'visible' => -1,
'enabled' => 1,
'position' => 109,
'notnull' => 1,
'default' =>
'Inbox',
'csslist' =>
'tdoverflowmax100',
'help' =>
'Example: INBOX, [Gmail]/Spam, [Gmail]/Draft, [Gmail]/Brouillons, [Gmail]/Sent Mail, [Gmail]/Messages envoyés, ...'),
131 'target_directory' => array(
'type' =>
'varchar(255)',
'label' =>
'MailboxTargetDirectory',
'visible' => 1,
'enabled' => 1,
'position' => 110,
'notnull' => 0,
'csslist' =>
'tdoverflowmax100',
'help' =>
"EmailCollectorTargetDir"),
132 'maxemailpercollect' => array(
'type' =>
'integer',
'label' =>
'MaxEmailCollectPerCollect',
'visible' => -1,
'enabled' => 1,
'position' => 111,
'default' => 50),
133 'datelastresult' => array(
'type' =>
'datetime',
'label' =>
'DateLastCollectResult',
'visible' => 1,
'enabled' =>
'$action != "create" && $action != "edit"',
'position' => 121,
'notnull' => -1,
'csslist' =>
'nowraponall'),
134 'codelastresult' => array(
'type' =>
'varchar(16)',
'label' =>
'CodeLastResult',
'visible' => 1,
'enabled' =>
'$action != "create" && $action != "edit"',
'position' => 122,
'notnull' => -1,),
135 'lastresult' => array(
'type' =>
'varchar(255)',
'label' =>
'LastResult',
'visible' => 1,
'enabled' =>
'$action != "create" && $action != "edit"',
'position' => 123,
'notnull' => -1,
'cssview' =>
'small',
'csslist' =>
'small tdoverflowmax200'),
136 'datelastok' => array(
'type' =>
'datetime',
'label' =>
'DateLastcollectResultOk',
'visible' => 1,
'enabled' =>
'$action != "create"',
'position' => 125,
'notnull' => -1,
'csslist' =>
'nowraponall'),
137 'note_public' => array(
'type' =>
'html',
'label' =>
'NotePublic',
'visible' => 0,
'enabled' => 1,
'position' => 61,
'notnull' => -1,),
138 'note_private' => array(
'type' =>
'html',
'label' =>
'NotePrivate',
'visible' => 0,
'enabled' => 1,
'position' => 62,
'notnull' => -1,),
139 'date_creation' => array(
'type' =>
'datetime',
'label' =>
'DateCreation',
'visible' => -2,
'enabled' => 1,
'position' => 500,
'notnull' => 1,),
140 'tms' => array(
'type' =>
'timestamp',
'label' =>
'DateModification',
'visible' => -2,
'enabled' => 1,
'position' => 501,
'notnull' => 1,),
142 'fk_user_creat' => array(
'type' =>
'integer:User:user/class/user.class.php',
'label' =>
'UserAuthor',
'visible' => -2,
'enabled' => 1,
'position' => 510,
'notnull' => 1,),
143 'fk_user_modif' => array(
'type' =>
'integer:User:user/class/user.class.php',
'label' =>
'UserModif',
'visible' => -2,
'enabled' => 1,
'position' => 511,
'notnull' => -1,),
145 'import_key' => array(
'type' =>
'varchar(14)',
'label' =>
'ImportId',
'visible' => -2,
'enabled' => 1,
'position' => 1000,
'notnull' => -1,),
146 'status' => array(
'type' =>
'integer',
'label' =>
'Status',
'visible' => 1,
'enabled' => 1,
'position' => 1000,
'notnull' => 1,
'default' =>
'0',
'index' => 1,
'arrayofkeyval' => array(
'0' =>
'Inactive',
'1' =>
'Active'))
183 public $fk_user_creat;
188 public $fk_user_modif;
222 public $oauth_service;
226 public $imap_encryption;
234 public $source_directory;
238 public $target_directory;
242 public $maxemailpercollect;
247 public $datelastresult;
252 public $codelastresult;
277 const STATUS_DISABLED = 0;
278 const STATUS_ENABLED = 1;
288 global $conf, $langs;
292 $this->ismultientitymanaged = 1;
293 $this->isextrafieldmanaged = 0;
296 $this->fields[
'rowid'][
'visible'] = 0;
298 if (!isModEnabled(
'multicompany') && isset($this->fields[
'entity'])) {
299 $this->fields[
'entity'][
'enabled'] = 0;
303 $oauthservices = array();
305 foreach ($conf->global as $key => $val) {
306 if (!empty($val) && preg_match(
'/^OAUTH_.*_ID$/', $key)) {
307 $key = preg_replace(
'/^OAUTH_/',
'', $key);
308 $key = preg_replace(
'/_ID$/',
'', $key);
309 if (preg_match(
'/^.*-/', $key)) {
310 $name = preg_replace(
'/^.*-/',
'', $key);
312 $name = $langs->trans(
"NoName");
314 $provider = preg_replace(
'/-.*$/',
'', $key);
315 $provider = ucfirst(strtolower($provider));
317 $oauthservices[$key] = $name.
" (".$provider.
")";
321 $this->fields[
'oauth_service'][
'arrayofkeyval'] = $oauthservices;
324 foreach ($this->fields as $key => $val) {
325 if (isset($val[
'enabled']) && empty($val[
'enabled'])) {
326 unset($this->fields[$key]);
331 foreach ($this->fields as $key => $val) {
332 if (!empty($val[
'arrayofkeyval']) && is_array($val[
'arrayofkeyval'])) {
333 foreach ($val[
'arrayofkeyval'] as $key2 => $val2) {
334 $this->fields[$key][
'arrayofkeyval'][$key2] = $langs->trans($val2);
352 if ($this->host && preg_match(
'/^http:/i', trim($this->host))) {
353 $langs->load(
"errors");
354 $this->error = $langs->trans(
"ErrorHostMustNotStartWithHttp", $this->host);
358 include_once DOL_DOCUMENT_ROOT.
'/core/lib/security.lib.php';
359 $this->password =
dolEncrypt($this->password);
363 $this->password =
dolDecrypt($this->password);
365 if (is_array($this->filters) && count($this->filters)) {
368 foreach ($this->filters as $filter) {
369 $emailcollectorfilter->type = $filter[
'type'];
370 $emailcollectorfilter->rulevalue = $filter[
'rulevalue'];
371 $emailcollectorfilter->fk_emailcollector = $this->id;
372 $emailcollectorfilter->status = $filter[
'status'];
374 $emailcollectorfilter->create($user);
378 if (is_array($this->actions) && count($this->actions)) {
381 foreach ($this->actions as $operation) {
382 $emailcollectoroperation->type = $operation[
'type'];
383 $emailcollectoroperation->actionparam = $operation[
'actionparam'];
384 $emailcollectoroperation->fk_emailcollector = $this->id;
385 $emailcollectoroperation->status = $operation[
'status'];
386 $emailcollectoroperation->position = $operation[
'position'];
388 $emailcollectoroperation->create($user);
404 global $langs, $extrafields;
425 unset(
$object->codelastresult);
426 unset(
$object->datelastresult);
431 $object->ref =
"copy_of_".$object->ref;
434 $object->host =
'imap.example.com';
437 if (is_array(
$object->array_options) && count(
$object->array_options) > 0) {
438 $extrafields->fetch_name_optionals_label($this->table_element);
439 foreach (
$object->array_options as $key => $option) {
440 $shortkey = preg_replace(
'/options_/',
'', $key);
441 if (!empty($extrafields->attributes[$this->element][
'unique'][$shortkey])) {
443 unset(
$object->array_options[$key]);
449 $object->context[
'createfromclone'] =
'createfromclone';
450 $result =
$object->create($user);
454 $this->errors =
$object->errors;
457 unset(
$object->context[
'createfromclone']);
464 $this->db->rollback();
476 public function fetch($id, $ref =
null)
480 include_once DOL_DOCUMENT_ROOT.
'/core/lib/security.lib.php';
481 $this->password =
dolDecrypt($this->password);
514 public function fetchAll(
User $user, $activeOnly = 0, $sortfield =
's.rowid', $sortorder =
'ASC', $limit = 100, $page = 0)
520 $sql =
"SELECT s.rowid";
521 $sql .=
" FROM ".MAIN_DB_PREFIX.
"emailcollector_emailcollector as s";
522 $sql .=
' WHERE s.entity IN ('.getEntity(
'emailcollector').
')';
524 $sql .=
" AND s.status = 1";
526 $sql .= $this->db->order($sortfield, $sortorder);
531 $offset = $limit * $page;
533 $sql .= $this->db->plimit($limit + 1, $offset);
536 $result = $this->db->query($sql);
538 $num = $this->db->num_rows($result);
541 $obj = $this->db->fetch_object($result);
543 if ($emailcollector_static->fetch($obj->rowid)) {
544 $obj_ret[] = $emailcollector_static;
549 $this->errors[] =
'EmailCollector::fetchAll Error when retrieve emailcollector list';
550 dol_syslog(
'EmailCollector::fetchAll Error when retrieve emailcollector list', LOG_ERR);
553 if (!count($obj_ret)) {
554 dol_syslog(
'EmailCollector::fetchAll No emailcollector found', LOG_DEBUG);
572 if ($this->host && preg_match(
'/^http:/i', trim($this->host))) {
573 $langs->load(
"errors");
574 $this->error = $langs->trans(
"ErrorHostMustNotStartWithHttp", $this->host);
578 include_once DOL_DOCUMENT_ROOT.
'/core/lib/security.lib.php';
579 $this->password =
dolEncrypt($this->password);
583 $this->password =
dolDecrypt($this->password);
595 public function delete(
User $user, $notrigger = 0)
610 public function getNomUrl($withpicto = 0, $option =
'', $notooltip = 0, $morecss =
'', $save_lastsearch_value = -1)
612 global $conf, $langs, $action, $hookmanager;
614 if (!empty($conf->dol_no_mouse_hover)) {
620 $label =
'<u>'.$langs->trans(
"EmailCollector").
'</u>';
622 $label .=
'<b>'.$langs->trans(
'Ref').
':</b> '.$this->ref;
624 $url = DOL_URL_ROOT.
'/admin/emailcollector_card.php?id='.$this->id;
626 if ($option !=
'nolink') {
628 $add_save_lastsearch_values = ($save_lastsearch_value == 1 ? 1 : 0);
629 if ($save_lastsearch_value == -1 && isset($_SERVER[
"PHP_SELF"]) && preg_match(
'/list\.php/', $_SERVER[
"PHP_SELF"])) {
630 $add_save_lastsearch_values = 1;
632 if ($add_save_lastsearch_values) {
633 $url .=
'&save_lastsearch_values=1';
638 if (empty($notooltip)) {
640 $label = $langs->trans(
"ShowEmailCollector");
641 $linkclose .=
' alt="'.dol_escape_htmltag($label, 1).
'"';
643 $linkclose .=
' title="'.dol_escape_htmltag($label, 1).
'"';
644 $linkclose .=
' class="classfortooltip'.($morecss ?
' '.$morecss :
'').
'"';
646 $linkclose = ($morecss ?
' class="'.$morecss.
'"' :
'');
649 $linkstart =
'<a href="'.$url.
'"';
650 $linkstart .= $linkclose.
'>';
653 $result .= $linkstart;
655 $result .=
img_object(($notooltip ?
'' : $label), ($this->picto ? $this->picto :
'generic'), ($notooltip ? (($withpicto != 2) ?
'class="paddingright"' :
'') :
'class="'.(($withpicto != 2) ?
'paddingright ' :
'').
'classfortooltip"'), 0, 0, $notooltip ? 0 : 1);
657 if ($withpicto != 2) {
658 $result .= $this->ref;
663 $hookmanager->initHooks(array(
'emailcollectordao'));
664 $parameters = array(
'id' => $this->
id,
'getnomurl' => &$result);
665 $reshook = $hookmanager->executeHooks(
'getNomUrl', $parameters, $this, $action);
667 $result = $hookmanager->resPrint;
669 $result .= $hookmanager->resPrint;
697 if (empty($this->labelStatus) || empty($this->labelStatusShort)) {
700 $this->labelStatus[self::STATUS_ENABLED] = $langs->transnoentitiesnoconv(
'Enabled');
701 $this->labelStatus[self::STATUS_DISABLED] = $langs->transnoentitiesnoconv(
'Disabled');
702 $this->labelStatusShort[self::STATUS_ENABLED] = $langs->transnoentitiesnoconv(
'Enabled');
703 $this->labelStatusShort[self::STATUS_DISABLED] = $langs->transnoentitiesnoconv(
'Disabled');
706 $statusType =
'status5';
707 if ($status == self::STATUS_ENABLED) {
708 $statusType =
'status4';
711 return dolGetStatus($this->labelStatus[$status], $this->labelStatusShort[$status],
'', $statusType, $mode);
722 $sql =
'SELECT rowid, date_creation as datec, tms as datem,';
723 $sql .=
' fk_user_creat, fk_user_modif';
724 $sql .=
' FROM '.MAIN_DB_PREFIX.$this->table_element.
' as t';
725 $sql .=
' WHERE t.rowid = '.((int) $id);
726 $result = $this->db->query($sql);
728 if ($this->db->num_rows($result)) {
729 $obj = $this->db->fetch_object($result);
731 $this->
id = $obj->rowid;
733 $this->user_creation_id = $obj->fk_user_creat;
734 $this->user_modification_id = $obj->fk_user_modif;
735 $this->date_creation = $this->db->jdate($obj->datec);
736 $this->date_modification = empty($obj->datem) ?
'' : $this->db->jdate($obj->datem);
739 $this->db->free($result);
753 $this->host =
'localhost';
754 $this->login =
'alogin';
767 $this->filters = array();
769 $sql =
'SELECT rowid, type, rulevalue, status';
770 $sql .=
' FROM '.MAIN_DB_PREFIX.
'emailcollector_emailcollectorfilter';
771 $sql .=
' WHERE fk_emailcollector = '.((int) $this->
id);
774 $resql = $this->db->query($sql);
776 $num = $this->db->num_rows($resql);
779 $obj = $this->db->fetch_object($resql);
780 $this->filters[$obj->rowid] = array(
'id' => $obj->rowid,
'type' => $obj->type,
'rulevalue' => $obj->rulevalue,
'status' => $obj->status);
783 $this->db->free($resql);
799 $this->actions = array();
801 $sql =
'SELECT rowid, type, actionparam, status';
802 $sql .=
' FROM '.MAIN_DB_PREFIX.
'emailcollector_emailcollectoraction';
803 $sql .=
' WHERE fk_emailcollector = '.((int) $this->
id);
804 $sql .=
' ORDER BY position';
806 $resql = $this->db->query($sql);
808 $num = $this->db->num_rows($resql);
811 $obj = $this->db->fetch_object($resql);
812 $this->actions[$obj->rowid] = array(
'id' => $obj->rowid,
'type' => $obj->type,
'actionparam' => $obj->actionparam,
'status' => $obj->status);
815 $this->db->free($resql);
834 $flags =
'/service=imap';
837 } elseif (empty($this->imap_encryption) || ($this->imap_encryption ==
'ssl' &&
getDolGlobalString(
'IMAP_FORCE_NOSSL'))) {
840 $flags .=
'/' . $this->imap_encryption;
843 $flags .=
'/novalidate-cert';
850 if (!empty($this->login) && strpos($this->login,
'/') !=
false) {
851 $partofauth = explode(
'/', $this->login);
852 $flags .=
'/authuser='.$partofauth[0].
'/user='.$partofauth[1];
855 $connectstringserver =
'{'.$this->host.
':'.$this->port.$flags.
'}';
857 return $connectstringserver;
868 if (function_exists(
'mb_convert_encoding')) {
870 $str = preg_replace(
"/ /",
"xxxSPACExxx", $str);
871 $str = preg_replace(
"/\[Gmail\]/",
"xxxGMAILxxx", $str);
873 if ($str = mb_convert_encoding($str,
"UTF-7")) {
875 $str = preg_replace(
"/\+A/",
"&A", $str);
877 $str = preg_replace(
"/xxxSPACExxx/",
" ", $str);
879 $str = preg_replace(
"/xxxGMAILxxx/",
"[Gmail]", $str);
883 $this->error =
"error: is not possible to encode this string '".$str.
"'";
903 $arrayofcollectors = $this->
fetchAll($user, 1);
906 foreach ($arrayofcollectors as $emailcollector) {
907 $result = $emailcollector->doCollectOneCollector(0);
908 dol_syslog(
"doCollect result = ".$result.
" for emailcollector->id = ".$emailcollector->id);
910 $this->error .=
'EmailCollector ID '.$emailcollector->id.
':'.$emailcollector->error.
'<br>';
911 if (!empty($emailcollector->errors)) {
912 $this->error .= implode(
'<br>', $emailcollector->errors);
914 $this->output .=
'EmailCollector ID '.$emailcollector->id.
': '.$emailcollector->lastresult.
'<br>';
933 global $conf, $langs;
935 $errorforthisaction = 0;
938 $outputlangs = $langs;
941 $newlang =
GETPOST(
'lang_id',
'aZ09');
944 $newlang = !empty(
$object->thirdparty->default_lang) ?
$object->thirdparty->default_lang : $newlang;
946 if (!empty($newlang)) {
948 $outputlangs->setDefaultLang($newlang);
958 foreach ($arrayvaluetouse as $propertytooverwrite => $valueforproperty) {
961 $tmparray = explode(
'.', $propertytooverwrite);
962 if (count($tmparray) == 2) {
963 $tmpclass = $tmparray[0];
964 $tmpproperty = $tmparray[1];
966 $tmpproperty = $tmparray[0];
968 if ($tmpclass && ($tmpclass !=
$object->element)) {
978 $regforregex = array();
979 if (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*):([^:])$/', $valueforproperty, $regforregex)) {
980 $sourcefield = $regforregex[1];
981 $regexstring = $regforregex[2];
983 } elseif (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*)$/', $valueforproperty, $regforregex)) {
984 $sourcefield = $regforregex[1];
985 $regexstring = $regforregex[2];
988 if (!empty($sourcefield) && !empty($regexstring)) {
989 if (strtolower($sourcefield) ==
'body') {
990 $sourcestring = $messagetext;
991 } elseif (strtolower($sourcefield) ==
'subject') {
992 $sourcestring = $subject;
993 } elseif (strtolower($sourcefield) ==
'header') {
994 $sourcestring = $header;
998 $regforval = array();
1000 if (strtolower($sourcefield) ==
'body') {
1001 $regexoptions =
'ms';
1003 if (strtolower($sourcefield) ==
'header') {
1004 $regexoptions =
'm';
1008 if (preg_match(
'/'.$regexstring.
'/'.$regexoptions, $sourcestring, $regforval)) {
1010 $valueextracted = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) :
null;
1011 if (strtolower($sourcefield) ==
'header') {
1012 if (preg_match(
'/^options_/', $tmpproperty)) {
1015 if (property_exists(
$object, $tmpproperty)) {
1022 if (preg_match(
'/^options_/', $tmpproperty)) {
1025 if (property_exists(
$object, $tmpproperty)) {
1032 if (preg_match(
'/^options_/', $tmpproperty)) {
1033 $operationslog .=
'<br>Regex /'.dol_escape_htmltag($regexstring).
'/'.
dol_escape_htmltag($regexoptions).
' into '.strtolower($sourcefield).
' -> found '.
dol_escape_htmltag(
dol_trunc(
$object->array_options[preg_replace(
'/^options_/',
'', $tmpproperty)], 128));
1035 if (property_exists(
$object, $tmpproperty)) {
1043 if (property_exists(
$object, $tmpproperty)) {
1046 $tmp[$tmpproperty] =
null;
1049 $operationslog .=
'<br>Regex /'.dol_escape_htmltag($regexstring).
'/'.
dol_escape_htmltag($regexoptions).
' into '.strtolower($sourcefield).
' -> not found, so property '.
dol_escape_htmltag($tmpproperty).
' is set to null.';
1053 $errorforthisaction++;
1054 $this->error =
'The extract rule to use to overwrite properties has on an unknown source (must be HEADER, SUBJECT or BODY)';
1055 $this->errors[] = $this->error;
1057 $operationslog .=
'<br>'.$this->error;
1059 } elseif (preg_match(
'/^(SET|SETIFEMPTY):(.*)$/', $valueforproperty, $regforregex)) {
1061 if (preg_match(
'/^options_/', $tmpproperty)) {
1062 $valuecurrent =
$object->array_options[preg_replace(
'/^options_/',
'', $tmpproperty)];
1064 if (property_exists(
$object, $tmpproperty)) {
1065 $valuecurrent =
$object->$tmpproperty;
1068 $valuecurrent = $tmp[$tmpproperty];
1072 if ($regforregex[1] ==
'SET' || empty($valuecurrent)) {
1073 $valuetouse = $regforregex[2];
1076 $matcharray = array();
1077 preg_match_all(
'/__([a-z0-9]+(?:_[a-z0-9]+)?)__/i', $valuetouse, $matcharray);
1079 if (is_array($matcharray[1])) {
1080 foreach ($matcharray[1] as $keytoreplace) {
1081 if ($keytoreplace) {
1082 if (preg_match(
'/^options_/', $keytoreplace)) {
1083 $substitutionarray[
'__'.$keytoreplace.
'__'] =
$object->array_options[preg_replace(
'/^options_/',
'', $keytoreplace)];
1085 if (property_exists(
$object, $keytoreplace)) {
1086 $substitutionarray[
'__'.$keytoreplace.
'__'] =
$object->$keytoreplace;
1089 $substitutionarray[
'__'.$keytoreplace.
'__'] = $tmp[$keytoreplace];
1099 if (preg_match(
'/^options_/', $tmpproperty)) {
1100 $object->array_options[preg_replace(
'/^options_/',
'', $tmpproperty)] = $valuetouse;
1102 $operationslog .=
'<br>Set value '.dol_escape_htmltag($valuetouse).
' into object->array_options['.
dol_escape_htmltag(preg_replace(
'/^options_/',
'', $tmpproperty)).
']';
1104 if (property_exists(
$object, $tmpproperty)) {
1105 $object->$tmpproperty = $valuetouse;
1107 $tmp[$tmpproperty] = $valuetouse;
1110 $operationslog .=
'<br>Set value '.dol_escape_htmltag($valuetouse).
' into object->'.
dol_escape_htmltag($tmpproperty);
1114 $errorforthisaction++;
1115 $this->error =
'Bad syntax for description of action parameters: '.$actionparam;
1116 $this->errors[] = $this->error;
1121 return $errorforthisaction;
1130 public function doCollectOneCollector($mode = 0)
1132 global $db, $conf, $langs, $user;
1133 global $hookmanager;
1137 require_once DOL_DOCUMENT_ROOT.
'/comm/action/class/actioncomm.class.php';
1139 require_once DOL_DOCUMENT_ROOT.
'/includes/webklex/php-imap/vendor/autoload.php';
1142 dol_syslog(
"EmailCollector::doCollectOneCollector start for id=".$this->
id.
" - ".$this->
ref, LOG_INFO);
1144 $langs->loadLangs(array(
"project",
"companies",
"mails",
"errors",
"ticket",
"agenda",
"commercial"));
1149 $this->debuginfo =
'';
1153 $searchfilterdoltrackid = 0;
1154 $searchfilternodoltrackid = 0;
1155 $searchfilterisanswer = 0;
1156 $searchfilterisnotanswer = 0;
1157 $searchfilterreplyto = 0;
1158 $searchfilterexcludebodyarray = array();
1159 $searchfilterexcludesubjectarray = array();
1160 $operationslog =
'';
1161 $rulesreplyto = array();
1162 $connectstringsource =
'';
1163 $connectstringtarget =
'';
1164 $connection =
false;
1165 $arrayofemail = array();
1169 if (empty($this->host)) {
1170 $this->error = $langs->trans(
'ErrorFieldRequired', $langs->transnoentitiesnoconv(
'EMailHost'));
1173 if (empty($this->login)) {
1174 $this->error = $langs->trans(
'ErrorFieldRequired', $langs->transnoentitiesnoconv(
'Login'));
1177 if (empty($this->source_directory)) {
1178 $this->error = $langs->trans(
'ErrorFieldRequired', $langs->transnoentitiesnoconv(
'MailboxSourceDirectory'));
1182 $sourcedir = $this->source_directory;
1183 $targetdir = ($this->target_directory ? $this->target_directory :
'');
1188 $sourcedir = $this->source_directory;
1189 $targetdir = ($this->target_directory ? $this->target_directory :
'');
1192 if ($this->acces_type == 1) {
1194 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=1, access_type=1 (OAUTH2)<br>';
1196 require_once DOL_DOCUMENT_ROOT.
'/core/lib/oauth.lib.php';
1200 $keyforsupportedoauth2array = $this->oauth_service;
1201 if (preg_match(
'/^.*-/', $keyforsupportedoauth2array)) {
1202 $keyforprovider = preg_replace(
'/^.*-/',
'', $keyforsupportedoauth2array);
1204 $keyforprovider =
'';
1206 $keyforsupportedoauth2array = preg_replace(
'/-.*$/',
'', $keyforsupportedoauth2array);
1207 $keyforsupportedoauth2array =
'OAUTH_'.$keyforsupportedoauth2array.
'_NAME';
1209 $OAUTH_SERVICENAME =
'Unknown';
1210 if (array_key_exists($keyforsupportedoauth2array, $supportedoauth2array)
1211 && array_key_exists(
'name', $supportedoauth2array[$keyforsupportedoauth2array])
1212 && !empty($supportedoauth2array[$keyforsupportedoauth2array][
'name'])) {
1213 $OAUTH_SERVICENAME = $supportedoauth2array[$keyforsupportedoauth2array][
'name'].(!empty($keyforprovider) ?
'-'.$keyforprovider :
'');
1216 require_once DOL_DOCUMENT_ROOT.
'/includes/OAuth/bootstrap.php';
1222 $storage =
new DoliStorage($db, $conf, $keyforprovider);
1225 $tokenobj = $storage->retrieveAccessToken($OAUTH_SERVICENAME);
1234 if (is_object($tokenobj) && $expire) {
1235 $this->debuginfo .=
'Refresh token '.$OAUTH_SERVICENAME.
'<br>';
1236 $credentials =
new Credentials(
1241 $serviceFactory = new \OAuth\ServiceFactory();
1242 $oauthname = explode(
'-', $OAUTH_SERVICENAME);
1244 $apiService = $serviceFactory->createService($oauthname[0], $credentials, $storage, array());
1245 '@phan-var-force OAuth\OAuth2\Service\AbstractService|OAuth\OAuth1\Service\AbstractService $apiService';
1247 $refreshtoken = $tokenobj->getRefreshToken();
1248 $tokenobj = $apiService->refreshAccessToken($tokenobj);
1249 $tokenobj->setRefreshToken($refreshtoken);
1250 $storage->storeAccessToken($OAUTH_SERVICENAME, $tokenobj);
1252 $tokenobj = $storage->retrieveAccessToken($OAUTH_SERVICENAME);
1253 if (is_object($tokenobj)) {
1254 $token = $tokenobj->getAccessToken();
1256 $this->error =
"Token not found";
1261 $this->error = $e->getMessage();
1262 dol_syslog(
"CMailFile::sendfile: mail end error=".$this->error, LOG_ERR);
1266 $cm =
new ClientManager();
1267 $client = $cm->make([
1268 'host' => $this->host,
1269 'port' => $this->port,
1270 'encryption' => !empty($this->imap_encryption) ? $this->imap_encryption : false,
1271 'validate_cert' => true,
1272 'protocol' =>
'imap',
1273 'username' => $this->login,
1274 'password' => $token,
1275 'authentication' =>
"oauth",
1279 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=1, access_type=0 (LOGIN)<br>';
1281 $cm =
new ClientManager();
1282 $client = $cm->make([
1283 'host' => $this->host,
1284 'port' => $this->port,
1285 'encryption' => !empty($this->imap_encryption) ? $this->imap_encryption : false,
1286 'validate_cert' => true,
1287 'protocol' =>
'imap',
1288 'username' => $this->login,
1289 'password' => $this->password,
1290 'authentication' =>
"login",
1296 }
catch (ConnectionFailedException $e) {
1297 $this->error = $e->getMessage();
1298 $this->errors[] = $this->error;
1299 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1303 $host = dol_getprefix(
'email');
1306 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=0 (native PHP imap, LOGIN)<br>';
1308 if (!function_exists(
'imap_open')) {
1309 $this->error =
'IMAP function not enabled on your PHP';
1315 $connectstringsource = $connectstringserver.$this->getEncodedUtf7($sourcedir);
1316 $connectstringtarget = $connectstringserver.$this->getEncodedUtf7($targetdir);
1318 $connectstringsource = $connectstringserver.$sourcedir;
1319 $connectstringtarget = $connectstringserver.$targetdir;
1322 $this->debuginfo .=
'connectstringsource = '.$connectstringsource.
', $connectstringtarget='.$connectstringtarget.
'<br>';
1324 $connection = imap_open($connectstringsource, $this->login, $this->password);
1325 if ($connection ===
false) {
1326 $this->error =
'Failed to open IMAP connection '.$connectstringsource.
' '.imap_last_error();
1331 $host = dol_getprefix(
'email');
1340 $criteria = array();
1343 $criteria = array(array(
'UNDELETED'));
1344 foreach ($this->filters as $rule) {
1345 if (empty($rule[
'status'])) {
1350 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1354 $rule[
'rulevalue'] = substr($rule[
'rulevalue'], 1);
1357 if ($rule[
'type'] ==
'from') {
1358 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1359 if (count($tmprulevaluearray) >= 2) {
1360 foreach ($tmprulevaluearray as $tmprulevalue) {
1361 array_push($criteria, array($not.
"FROM" => $tmprulevalue));
1364 array_push($criteria, array($not.
"FROM" => $rule[
'rulevalue']));
1367 if ($rule[
'type'] ==
'to') {
1368 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1369 if (count($tmprulevaluearray) >= 2) {
1370 foreach ($tmprulevaluearray as $tmprulevalue) {
1371 array_push($criteria, array($not.
"TO" => $tmprulevalue));
1374 array_push($criteria, array($not.
"TO" => $rule[
'rulevalue']));
1377 if ($rule[
'type'] ==
'bcc') {
1378 array_push($criteria, array($not.
"BCC" => $rule[
'rulevalue']));
1380 if ($rule[
'type'] ==
'cc') {
1381 array_push($criteria, array($not.
"CC" => $rule[
'rulevalue']));
1383 if ($rule[
'type'] ==
'subject') {
1384 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1386 $searchfilterexcludesubjectarray[] = preg_replace(
'/^!/',
'', $rule[
'rulevalue']);
1388 array_push($criteria, array(
"SUBJECT" => $rule[
'rulevalue']));
1391 if ($rule[
'type'] ==
'body') {
1392 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1394 $searchfilterexcludebodyarray[] = preg_replace(
'/^!/',
'', $rule[
'rulevalue']);
1396 array_push($criteria, array(
"BODY" => $rule[
'rulevalue']));
1399 if ($rule[
'type'] ==
'header') {
1400 array_push($criteria, array($not.
"HEADER" => $rule[
'rulevalue']));
1412 if ($rule[
'type'] ==
'seen') {
1413 array_push($criteria, array($not.
"SEEN"));
1415 if ($rule[
'type'] ==
'unseen') {
1416 array_push($criteria, array($not.
"UNSEEN"));
1418 if ($rule[
'type'] ==
'unanswered') {
1419 array_push($criteria, array($not.
"UNANSWERED"));
1421 if ($rule[
'type'] ==
'answered') {
1422 array_push($criteria, array($not.
"ANSWERED"));
1424 if ($rule[
'type'] ==
'smaller') {
1425 array_push($criteria, array($not.
"SMALLER"));
1427 if ($rule[
'type'] ==
'larger') {
1428 array_push($criteria, array($not.
"LARGER"));
1432 if ($rule[
'type'] ==
'withtrackingidinmsgid') {
1433 $searchfilterdoltrackid++;
1434 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1436 if ($rule[
'type'] ==
'withouttrackingidinmsgid') {
1437 $searchfilterdoltrackid++;
1438 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1440 if ($rule[
'type'] ==
'withtrackingid') {
1441 $searchfilterdoltrackid++;
1442 $searchhead .=
'/References.*@'.preg_quote($host,
'/').
'/';
1444 if ($rule[
'type'] ==
'withouttrackingid') {
1445 $searchfilternodoltrackid++;
1446 $searchhead .=
'! /References.*@'.preg_quote($host,
'/').
'/';
1449 if ($rule[
'type'] ==
'isanswer') {
1450 $searchfilterisanswer++;
1451 $searchhead .=
'/References.*@.*/';
1453 if ($rule[
'type'] ==
'isnotanswer') {
1454 $searchfilterisnotanswer++;
1455 $searchhead .=
'! /References.*@.*/';
1458 if ($rule[
'type'] ==
'replyto') {
1459 $searchfilterreplyto++;
1460 $rulesreplyto[] = $rule[
'rulevalue'];
1461 $searchhead .=
'/Reply-To.*'.preg_quote($rule[
'rulevalue'],
'/').
'/';
1465 if (empty($targetdir) || !
getDolGlobalString(
'EMAILCOLLECTOR_NO_FILTER_ON_DATE_IF_THERE_IS_A_TARGETDIR')) {
1467 if ($this->datelastok) {
1468 $fromdate = $this->datelastok;
1470 if ($fromdate > 0) {
1472 array_push($criteria, array(
"SINCE" => date(
'j-M-Y', $fromdate - 1)));
1477 dol_syslog(
"IMAP search string = ".var_export($criteria,
true));
1478 $search = var_export($criteria,
true);
1481 $search =
'UNDELETED';
1482 foreach ($this->filters as $rule) {
1483 if (empty($rule[
'status'])) {
1491 if (!empty($rule[
'rulevalue']) && strpos($rule[
'rulevalue'],
'!') === 0) {
1495 $rule[
'rulevalue'] = substr($rule[
'rulevalue'], 1);
1498 if ($rule[
'type'] ==
'from') {
1499 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1500 if (count($tmprulevaluearray) >= 2) {
1501 foreach ($tmprulevaluearray as $tmprulevalue) {
1502 $search .= ($search ?
' ' :
'').$not.
'FROM "'.str_replace(
'"',
'', $tmprulevalue).
'"';
1505 $search .= ($search ?
' ' :
'').$not.
'FROM "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1508 if ($rule[
'type'] ==
'to') {
1509 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1510 if (count($tmprulevaluearray) >= 2) {
1511 foreach ($tmprulevaluearray as $tmprulevalue) {
1512 $search .= ($search ?
' ' :
'').$not.
'TO "'.str_replace(
'"',
'', $tmprulevalue).
'"';
1515 $search .= ($search ?
' ' :
'').$not.
'TO "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1518 if ($rule[
'type'] ==
'bcc') {
1519 $search .= ($search ?
' ' :
'').$not.
'BCC';
1521 if ($rule[
'type'] ==
'cc') {
1522 $search .= ($search ?
' ' :
'').$not.
'CC';
1524 if ($rule[
'type'] ==
'subject') {
1527 $searchfilterexcludesubjectarray[] = $rule[
'rulevalue'];
1529 $search .= ($search ?
' ' :
'').
'SUBJECT "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1532 if ($rule[
'type'] ==
'body') {
1535 $searchfilterexcludebodyarray[] = $rule[
'rulevalue'];
1538 $search .= ($search ?
' ' :
'').
'BODY "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1541 if ($rule[
'type'] ==
'header') {
1542 $search .= ($search ?
' ' :
'').$not.
'HEADER '.$rule[
'rulevalue'];
1554 if ($rule[
'type'] ==
'seen') {
1555 $search .= ($search ?
' ' :
'').$not.
'SEEN';
1557 if ($rule[
'type'] ==
'unseen') {
1558 $search .= ($search ?
' ' :
'').$not.
'UNSEEN';
1560 if ($rule[
'type'] ==
'unanswered') {
1561 $search .= ($search ?
' ' :
'').$not.
'UNANSWERED';
1563 if ($rule[
'type'] ==
'answered') {
1564 $search .= ($search ?
' ' :
'').$not.
'ANSWERED';
1566 if ($rule[
'type'] ==
'smaller') {
1567 $search .= ($search ?
' ' :
'').$not.
'SMALLER "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1569 if ($rule[
'type'] ==
'larger') {
1570 $search .= ($search ?
' ' :
'').$not.
'LARGER "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1574 if ($rule[
'type'] ==
'withtrackingidinmsgid') {
1575 $searchfilterdoltrackid++;
1576 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1578 if ($rule[
'type'] ==
'withouttrackingidinmsgid') {
1579 $searchfilterdoltrackid++;
1580 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1582 if ($rule[
'type'] ==
'withtrackingid') {
1583 $searchfilterdoltrackid++;
1584 $searchhead .=
'/References.*@'.preg_quote($host,
'/').
'/';
1586 if ($rule[
'type'] ==
'withouttrackingid') {
1587 $searchfilternodoltrackid++;
1588 $searchhead .=
'! /References.*@'.preg_quote($host,
'/').
'/';
1591 if ($rule[
'type'] ==
'isanswer') {
1592 $searchfilterisanswer++;
1593 $searchhead .=
'/References.*@.*/';
1595 if ($rule[
'type'] ==
'isnotanswer') {
1596 $searchfilterisnotanswer++;
1597 $searchhead .=
'! /References.*@.*/';
1600 if ($rule[
'type'] ==
'replyto') {
1601 $searchfilterreplyto++;
1602 $rulesreplyto[] = $rule[
'rulevalue'];
1603 $searchhead .=
'/Reply-To.*'.preg_quote($rule[
'rulevalue'],
'/').
'/';
1607 if (empty($targetdir)) {
1609 if ($this->datelastok) {
1610 $fromdate = $this->datelastok;
1612 if ($fromdate > 0) {
1613 $search .= ($search ?
' ' :
'').
'SINCE '.date(
'j-M-Y', $fromdate - 1);
1622 $nbemailprocessed = 0;
1625 $charset = ($this->hostcharset ? $this->hostcharset :
"UTF-8");
1626 $arrayofemail = array();
1633 $tmpsourcedir = $sourcedir;
1638 $f = $client->getFolders(
false, $tmpsourcedir);
1641 if ($folder instanceof Webklex\PHPIMAP\Folder) {
1642 $Query = $folder->messages()->where($criteria);
1645 $this->error =
"Source directory ".$sourcedir.
" not found";
1646 $this->errors[] = $this->error;
1647 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_WARNING);
1652 $this->error =
"Failed to execute getfolders";
1653 $this->errors[] = $this->error;
1654 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1657 }
catch (InvalidWhereQueryCriteriaException $e) {
1658 $this->error = $e->getMessage();
1659 $this->errors[] = $this->error;
1660 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1663 $this->error = $e->getMessage();
1664 $this->errors[] = $this->error;
1665 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1669 '@phan-var-force Webklex\PHPIMAP\Query\Query $Query';
1673 $Query->leaveUnread();
1675 $arrayofemail = $Query->limit($this->maxemailpercollect)->setFetchOrder(
"asc")->get();
1678 $this->error = $e->getMessage();
1679 $this->errors[] = $this->error;
1680 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1683 } elseif ($connection !==
false) {
1685 $arrayofemail = imap_search($connection, $search, SE_UID, $charset);
1687 if ($arrayofemail ===
false) {
1689 $mapoferrrors = imap_errors();
1690 if ($mapoferrrors !==
false) {
1692 $this->error =
"Search string not understood - ".implode(
',', $mapoferrrors);
1693 $this->errors[] = $this->error;
1698 $arrayofemailtodelete = array();
1701 if (!$error && !empty($arrayofemail) && count($arrayofemail) > 0 && $connection !==
false) {
1718 dol_syslog(
"Start of loop on email", LOG_INFO, 1);
1720 $richarrayofemail = array();
1722 foreach ($arrayofemail as $imapemail) {
1723 if ($nbemailprocessed > 1000) {
1729 '@phan-var-force Webklex\PHPIMAP\Message $imapemail';
1730 $header = $imapemail->getHeader()->raw;
1731 $overview = $imapemail->getAttributes();
1733 $header = imap_fetchheader($connection, $imapemail, FT_UID);
1734 $overview = imap_fetch_overview($connection, $imapemail, FT_UID);
1737 $header = preg_replace(
'/\r\n\s+/m',
' ', $header);
1740 preg_match_all(
'/([^: ]+): (.+?(?:\r\n\s(?:.+?))*)(\r\n|\s$)/m', $header, $matches);
1741 $headers = array_combine($matches[1], $matches[2]);
1744 $richarrayofemail[] = array(
'imapemail' => $imapemail,
'header' => $header,
'headers' => $headers,
'overview' => $overview,
'date' => strtotime($headers[
'Date']));
1749 $richarrayofemail =
dol_sort_array($richarrayofemail,
'date',
'asc');
1753 foreach ($richarrayofemail as $tmpval) {
1756 $imapemail = $tmpval[
'imapemail'];
1757 $header = $tmpval[
'header'];
1758 $overview = $tmpval[
'overview'];
1759 $headers = $tmpval[
'headers'];
1761 if (!empty($headers[
'in-reply-to']) && empty($headers[
'In-Reply-To'])) {
1762 $headers[
'In-Reply-To'] = $headers[
'in-reply-to'];
1764 if (!empty($headers[
'references']) && empty($headers[
'References'])) {
1765 $headers[
'References'] = $headers[
'references'];
1767 if (!empty($headers[
'message-id']) && empty($headers[
'Message-ID'])) {
1768 $headers[
'Message-ID'] = $headers[
'message-id'];
1770 if (!empty($headers[
'subject']) && empty($headers[
'Subject'])) {
1771 $headers[
'Subject'] = $headers[
'subject'];
1777 $emailto = (string) $overview[
'to'];
1784 $operationslog .=
'<br>** Process email #'.dol_escape_htmltag((
string) $iforemailloop);
1788 '@phan-var-force Webklex\PHPIMAP\Message $imapemail';
1790 $msgid = str_replace(array(
'<',
'>'),
'', $overview[
'message_id']);
1792 $operationslog .=
" - ".dol_escape_htmltag((
string) $imapemail);
1793 $msgid = str_replace(array(
'<',
'>'),
'', $overview[0]->message_id);
1795 $operationslog .=
" - MsgId: ".$msgid;
1796 $operationslog .=
" - Date: ".($headers[
'Date'] ?? $langs->transnoentitiesnoconv(
"NotFound"));
1797 $operationslog .=
" - References: ".dol_escape_htmltag($headers[
'References'] ?? $langs->transnoentitiesnoconv(
"NotFound")).
" - Subject: ".
dol_escape_htmltag($headers[
'Subject']);
1799 dol_syslog(
"-- Process email #".$iforemailloop.
", MsgId: ".$msgid.
", Date: ".($headers[
'Date'] ??
'').
", References: ".($headers[
'References'] ??
'').
", Subject: ".$headers[
'Subject']);
1802 $trackidfoundintorecipienttype =
'';
1803 $trackidfoundintorecipientid = 0;
1808 if (preg_match(
'/\+(th[i]|ctc|use|mem|sub|proj|tas|con|tic|pro|ord|inv|spro|sor|sin|leav|stockinv|job|surv|salary)([0-9]+)@/', $emailto, $reg)) {
1809 $trackidfoundintorecipienttype = $reg[1];
1810 $trackidfoundintorecipientid = $reg[2];
1811 } elseif (preg_match(
'/\+emailing-(\w+)@/', $emailto, $reg)) {
1812 $trackidfoundintorecipienttype =
'emailing';
1813 $trackidfoundintorecipientid = $reg[1];
1816 $trackidfoundintomsgidtype =
'';
1817 $trackidfoundintomsgidid = 0;
1822 if (preg_match(
'/(?:[\+\-])(th[i]|ctc|use|mem|sub|proj|tas|con|tic|pro|ord|inv|spro|sor|sin|leav|stockinv|job|surv|salary)([0-9]+)@/', $msgid, $reg)) {
1823 $trackidfoundintomsgidtype = $reg[1];
1824 $trackidfoundintomsgidid = $reg[2];
1825 } elseif (preg_match(
'/(?:[\+\-])emailing-(\w+)@/', $msgid, $reg)) {
1826 $trackidfoundintomsgidtype =
'emailing';
1827 $trackidfoundintomsgidid = $reg[1];
1831 if ($searchfilterdoltrackid > 0) {
1832 if (empty($trackidfoundintorecipienttype) && empty($trackidfoundintomsgidtype)) {
1833 if (empty($headers[
'References']) || !preg_match(
'/@'.preg_quote($host,
'/').
'/', $headers[
'References'])) {
1834 $nbemailprocessed++;
1835 dol_syslog(
" Discarded - No suffix in email recipient and no Header References found matching the signature of the application, so with a trackid coming from the application");
1840 if ($searchfilternodoltrackid > 0) {
1841 if (!empty($trackidfoundintorecipienttype) || !empty($trackidfoundintomsgidtype) || (!empty($headers[
'References']) && preg_match(
'/@'.preg_quote($host,
'/').
'/', $headers[
'References']))) {
1842 $nbemailprocessed++;
1843 dol_syslog(
" Discarded - Suffix found into email or Header References found and matching signature of application so with a trackid");
1848 if ($searchfilterisanswer > 0) {
1849 if (empty($headers[
'In-Reply-To'])) {
1850 $nbemailprocessed++;
1851 dol_syslog(
" Discarded - Email is not an answer (no In-Reply-To header)");
1855 if (preg_match(
'/^(Re|AW)\s*:\s+/i', $headers[
'Subject'])) {
1861 if (!empty($headers[
'In-Reply-To'])) {
1869 $nbemailprocessed++;
1870 dol_syslog(
" Discarded - Email is not an answer (no RE prefix in subject)");
1874 if ($searchfilterisnotanswer > 0) {
1875 if (!empty($headers[
'In-Reply-To'])) {
1879 if (preg_match(
'/Re\s*:\s+/i', $headers[
'Subject'])) {
1885 $nbemailprocessed++;
1886 dol_syslog(
" Discarded - Email is an answer");
1891 if ($searchfilterreplyto > 0) {
1892 if (!empty($headers[
'Reply-To'])) {
1894 foreach ($rulesreplyto as $key => $rulereplyto) {
1895 if (preg_match(
'/'.preg_quote($rulereplyto,
'/').
'/', $headers[
'Reply-To'])) {
1900 if (!$isreplytook || $isreplytook != count($rulesreplyto)) {
1901 $nbemailprocessed++;
1902 dol_syslog(
" Discarded - Reply-to does not match");
1910 $thirdpartystatic =
new Societe($this->db);
1911 $contactstatic =
new Contact($this->db);
1912 $projectstatic =
new Project($this->db);
1914 $nbactiondoneforemail = 0;
1916 $errorforactions = 0;
1917 $thirdpartyfoundby =
'';
1918 $contactfoundby =
'';
1919 $projectfoundby =
'';
1920 $ticketfoundby =
'';
1921 $candidaturefoundby =
'';
1925 dol_syslog(
"msgid=".$overview[
'message_id'].
" date=".
dol_print_date($overview[
'date'],
'dayrfc',
'gmt').
" from=".$overview[
'from'].
" to=".$overview[
'to'].
" subject=".$overview[
'subject']);
1930 dol_syslog(
"msgid=".$overview[0]->message_id.
" date=".
dol_print_date($overview[0]->udate,
'dayrfc',
'gmt').
" from=".$overview[0]->from.
" to=".$overview[0]->to.
" subject=".$overview[0]->subject);
1940 global $htmlmsg, $plainmsg, $charset, $attachments;
1944 '@phan-var-force Webklex\PHPIMAP\Message $imapemail';
1945 if ($imapemail->hasHTMLBody()) {
1946 $htmlmsg = $imapemail->getHTMLBody();
1948 if ($imapemail->hasTextBody()) {
1949 $plainmsg = $imapemail->getTextBody();
1951 if ($imapemail->hasAttachments()) {
1952 $attachments = $imapemail->getAttachments()->all();
1957 $this->
getmsg($connection, $imapemail);
1959 '@phan-var-force Webklex\PHPIMAP\Attachment[] $attachments';
1971 $operationslog .=
'<br>Discarded - Email body is not valid utf8';
1972 dol_syslog(
" Discarded - Email body is not valid utf8");
1976 if (!empty($searchfilterexcludebodyarray)) {
1977 foreach ($searchfilterexcludebodyarray as $searchfilterexcludebody) {
1978 if (preg_match(
'/'.preg_quote($searchfilterexcludebody,
'/').
'/ms', $messagetext)) {
1979 $nbemailprocessed++;
1980 $operationslog .=
'<br>Discarded - Email body contains string '.$searchfilterexcludebody;
1981 dol_syslog(
" Discarded - Email body contains string ".$searchfilterexcludebody);
2043 $replytostring =
'';
2046 $fromstring = $overview[
'from'];
2047 $replytostring = empty($overview[
'in_reply-to']) ? $headers[
'Reply-To'] : $overview[
'in_reply-to'];
2049 $sender = $overview[
'sender'];
2050 $to = $overview[
'to'];
2051 $sendtocc = empty($overview[
'cc']) ?
'' : $overview[
'cc'];
2052 $sendtobcc = empty($overview[
'bcc']) ?
'' : $overview[
'bcc'];
2054 $tmpdate = $overview[
'date']->toDate();
2055 $tmptimezone = $tmpdate->getTimezone()->getName();
2058 if (preg_match(
'/^([+\-])(\d\d):(\d\d)/', $tmptimezone, $reg)) {
2059 if ($reg[1] ==
'+' && ($reg[2] !=
'00' || $reg[3] !=
'00')) {
2060 $dateemail -= (3600 * (int) $reg[2]);
2061 $dateemail -= (60 * (int) $reg[3]);
2063 if ($reg[1] ==
'-' && ($reg[2] !=
'00' || $reg[3] !=
'00')) {
2064 $dateemail += (3600 * (int) $reg[2]);
2065 $dateemail += (60 * (int) $reg[3]);
2068 $subject = $overview[
'subject'];
2070 $fromstring = $overview[0]->from;
2071 $replytostring = (!empty($overview[
'in_reply-to']) ? $overview[
'in_reply-to'] : (!empty($headers[
'Reply-To']) ? $headers[
'Reply-To'] :
"")) ;
2073 $sender = !empty($overview[0]->sender) ? $overview[0]->sender :
'';
2074 $to = $overview[0]->to;
2075 $sendtocc = !empty($overview[0]->cc) ? $overview[0]->cc :
'';
2076 $sendtobcc = !empty($overview[0]->bcc) ? $overview[0]->bcc :
'';
2078 $subject = $overview[0]->subject;
2082 if (!empty($searchfilterexcludesubjectarray)) {
2083 foreach ($searchfilterexcludesubjectarray as $searchfilterexcludesubject) {
2084 if (preg_match(
'/'.preg_quote($searchfilterexcludesubject,
'/').
'/ms', $subject)) {
2085 $nbemailprocessed++;
2086 $operationslog .=
'<br>Discarded - Email subject contains string '.$searchfilterexcludesubject;
2087 dol_syslog(
" Discarded - Email subject contains string ".$searchfilterexcludesubject);
2094 if (preg_match(
'/^(.*)<(.*)>$/', $fromstring, $reg)) {
2096 $fromtext = $reg[1];
2098 $from = $fromstring;
2101 if (preg_match(
'/^(.*)<(.*)>$/', $replytostring, $reg)) {
2103 $replytotext = $reg[1];
2105 $replyto = $replytostring;
2109 $fk_element_type =
'';
2126 $objectemail =
null;
2129 $arrayofreferences = array();
2130 if (!empty($headers[
'References'])) {
2131 $arrayofreferences = preg_split(
'/(,|\s+)/', $headers[
'References']);
2133 if (!in_array(
'<'.$msgid.
'>', $arrayofreferences)) {
2134 $arrayofreferences = array_merge($arrayofreferences, array(
'<'.$msgid.
'>'));
2139 foreach ($arrayofreferences as $reference) {
2141 if (!empty($trackidfoundintorecipienttype)) {
2142 $resultsearchtrackid = -1;
2143 $reg[1] = $trackidfoundintorecipienttype;
2144 $reg[2] = $trackidfoundintorecipientid;
2145 } elseif (!empty($trackidfoundintomsgidtype)) {
2146 $resultsearchtrackid = -1;
2147 $reg[1] = $trackidfoundintomsgidtype;
2148 $reg[2] = $trackidfoundintomsgidid;
2150 $resultsearchtrackid = preg_match(
'/dolibarr-([a-z]+)([0-9]+)@'.preg_quote($host,
'/').
'/', $reference, $reg);
2151 if (empty($resultsearchtrackid) &&
getDolGlobalString(
'EMAIL_ALTERNATIVE_HOST_SIGNATURE')) {
2152 $resultsearchtrackid = preg_match(
'/dolibarr-([a-z]+)([0-9]+)@'.preg_quote(
getDolGlobalString(
'EMAIL_ALTERNATIVE_HOST_SIGNATURE'),
'/').
'/', $reference, $reg);
2156 if (!empty($resultsearchtrackid)) {
2158 $trackid = $reg[1].$reg[2];
2160 $objectid = $reg[2];
2162 if ($reg[1] ==
'thi') {
2163 $objectemail =
new Societe($this->db);
2165 if ($reg[1] ==
'ctc') {
2166 $objectemail =
new Contact($this->db);
2168 if ($reg[1] ==
'inv') {
2169 $objectemail =
new Facture($this->db);
2171 if ($reg[1] ==
'sinv') {
2174 if ($reg[1] ==
'pro') {
2175 $objectemail =
new Propal($this->db);
2177 if ($reg[1] ==
'ord') {
2178 $objectemail =
new Commande($this->db);
2180 if ($reg[1] ==
'shi') {
2183 if ($reg[1] ==
'spro') {
2186 if ($reg[1] ==
'sord') {
2189 if ($reg[1] ==
'rec') {
2190 $objectemail =
new Reception($this->db);
2192 if ($reg[1] ==
'proj') {
2193 $objectemail =
new Project($this->db);
2194 $projectfoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2196 if ($reg[1] ==
'tas') {
2197 $objectemail =
new Task($this->db);
2199 if ($reg[1] ==
'con') {
2200 $objectemail =
new Contact($this->db);
2202 if ($reg[1] ==
'use') {
2203 $objectemail =
new User($this->db);
2205 if ($reg[1] ==
'tic') {
2206 $objectemail =
new Ticket($this->db);
2207 $ticketfoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2209 if ($reg[1] ==
'recruitmentcandidature') {
2211 $candidaturefoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2213 if ($reg[1] ==
'mem') {
2214 $objectemail =
new Adherent($this->db);
2222 } elseif (preg_match(
'/<(.*@.*)>/', $reference, $reg)) {
2224 if (is_null($objectemail) && isModEnabled(
'ticket')) {
2225 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"ticket";
2226 $sql .=
" WHERE email_msgid = '".$this->db->escape($reg[1]).
"' OR origin_references like '%".$this->db->escape($this->db->escapeforlike($reg[1])).
"%'";
2227 $resql = $this->db->query($sql);
2229 $obj = $this->db->fetch_object($resql);
2231 $objectid = $obj->rowid;
2232 $objectemail =
new Ticket($this->db);
2233 $ticketfoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2240 if (!is_object($objectemail) && isModEnabled(
'project')) {
2241 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"projet where email_msgid = '".$this->db->escape($reg[1]).
"'";
2242 $resql = $this->db->query($sql);
2244 $obj = $this->db->fetch_object($resql);
2246 $objectid = $obj->rowid;
2247 $objectemail =
new Project($this->db);
2248 $projectfoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2255 if (!is_object($objectemail) && isModEnabled(
'recruitment')) {
2256 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"recruitment_recruitmentcandidature where email_msgid = '".$this->db->escape($reg[1]).
"'";
2257 $resql = $this->db->query($sql);
2259 $obj = $this->db->fetch_object($resql);
2261 $objectid = $obj->rowid;
2263 $candidaturefoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2272 if (is_object($objectemail)) {
2273 $result = $objectemail->fetch($objectid);
2275 $fk_element_id = $objectemail->id;
2276 $fk_element_type = $objectemail->element;
2278 if ($fk_element_type ==
'facture') {
2279 $fk_element_type =
'invoice';
2282 if (get_class($objectemail) !=
'Societe') {
2283 $thirdpartyid = $objectemail->fk_soc ?? $objectemail->socid;
2285 $thirdpartyid = $objectemail->id;
2288 if (get_class($objectemail) !=
'Contact') {
2289 $contactid = $objectemail->fk_socpeople;
2291 $contactid = $objectemail->id;
2294 if (get_class($objectemail) !=
'Project') {
2295 $projectid = isset($objectemail->fk_project) ? $objectemail->fk_project : $objectemail->fk_projet;
2297 $projectid = $objectemail->id;
2300 if ($objectemail instanceof
Ticket) {
2301 $ticketid = $objectemail->id;
2303 $changeonticket_references =
false;
2304 if (empty($trackid)) {
2305 $trackid = $objectemail->track_id;
2307 if (empty($objectemail->origin_references)) {
2308 $objectemail->origin_references = $headers[
'References'];
2309 $changeonticket_references =
true;
2311 foreach ($arrayofreferences as $key => $referencetmp) {
2312 if (!str_contains($objectemail->origin_references, $referencetmp)) {
2313 $objectemail->origin_references .=
" ".$referencetmp;
2314 $changeonticket_references =
true;
2318 if ($changeonticket_references) {
2319 $objectemail->update($user, 1);
2326 if ($projectid > 0) {
2327 $result = $projectstatic->fetch($projectid);
2329 $projectstatic->id = 0;
2331 $projectid = $projectstatic->id;
2333 $projectfoundby =
'trackid ('.$trackid.
')';
2335 if (empty($contactid)) {
2336 $contactid = $projectstatic->fk_contact;
2338 if (empty($thirdpartyid)) {
2339 $thirdpartyid = $projectstatic->fk_soc;
2344 if ($contactid > 0) {
2345 $result = $contactstatic->fetch($contactid);
2347 $contactstatic->id = 0;
2349 $contactid = $contactstatic->id;
2351 $contactfoundby =
'trackid ('.$trackid.
')';
2353 if (empty($thirdpartyid)) {
2354 $thirdpartyid = $contactstatic->fk_soc;
2359 if ($thirdpartyid > 0) {
2360 $result = $thirdpartystatic->fetch($thirdpartyid);
2362 $thirdpartystatic->id = 0;
2364 $thirdpartyid = $thirdpartystatic->id;
2366 $thirdpartyfoundby =
'trackid ('.$trackid.
')';
2371 if (is_object($objectemail)) {
2376 if (empty($contactid)) {
2377 $result = $contactstatic->fetch(0,
null,
'', $from);
2380 dol_syslog(
"We found a contact with the email ".$from);
2381 $contactid = $contactstatic->id;
2382 $contactfoundby =
'email of contact ('.$from.
')';
2383 if (empty($thirdpartyid) && $contactstatic->socid > 0) {
2384 $result = $thirdpartystatic->fetch($contactstatic->socid);
2386 $thirdpartyid = $thirdpartystatic->id;
2387 $thirdpartyfoundby =
'email of contact ('.$from.
')';
2393 if (empty($thirdpartyid)) {
2394 $result = $thirdpartystatic->fetch(0,
'',
'',
'',
'',
'',
'',
'',
'',
'', $from);
2396 dol_syslog(
"We found a thirdparty with the email ".$from);
2397 $thirdpartyid = $thirdpartystatic->id;
2398 $thirdpartyfoundby =
'email ('.$from.
')';
2434 foreach ($this->actions as $operation) {
2435 $errorforthisaction = 0;
2436 $ticketalreadyexists = 0;
2437 if ($errorforactions) {
2440 if (empty($operation[
'status'])) {
2444 $operationslog .=
'<br>* Process operation '.$operation[
'type'];
2447 dol_syslog(
"Execute action ".$operation[
'type'].
" actionparam=".$operation[
'actionparam'].
' thirdpartystatic->id='.$thirdpartystatic->id.
' contactstatic->id='.$contactstatic->id.
' projectstatic->id='.$projectstatic->id);
2448 dol_syslog(
"Execute action fk_element_id=".$fk_element_id.
" fk_element_type=".$fk_element_type);
2451 $actioncode =
'EMAIL_IN';
2453 if (preg_match(
'/Sent$/', $sourcedir) || preg_match(
'/envoyés$/i', $sourcedir)) {
2454 $actioncode =
'EMAIL';
2457 $arrayofemailtoconsideresender = explode(
',',
getDolGlobalString(
'MAIL_FROM_EMAILS_TO_CONSIDER_SENDING'));
2458 foreach ($arrayofemailtoconsideresender as $emailtoconsidersender) {
2459 if (preg_match(
'/'.preg_quote($emailtoconsidersender,
'/').
'/', $fromstring)) {
2460 $actioncode =
'EMAIL';
2463 $operationslog .=
'<br>Email will have actioncode='.$actioncode;
2465 $description = $descriptiontitle = $descriptionmeta = $descriptionfull =
'';
2467 $descriptiontitle = $langs->transnoentitiesnoconv(
"RecordCreatedByEmailCollector", $this->
ref);
2472 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailFrom").($langs->trans(
"MailFrom") !=
'From' ?
' (From)' :
'').
' : '.
dol_escape_htmltag($fromstring));
2474 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"Sender").($langs->trans(
"Sender") !=
'Sender' ?
' (Sender)' :
'').
' : '.
dol_escape_htmltag($sender));
2476 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailTo").($langs->trans(
"MailTo") !=
'To' ?
' (To)' :
'').
' : '.
dol_escape_htmltag($to));
2478 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailReply").($langs->trans(
"MailReply") !=
'Reply to' ?
' (Reply to)' :
'').
' : '.
dol_escape_htmltag($replyto));
2481 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailCC").($langs->trans(
"MailCC") !=
'CC' ?
' (CC)' :
'').
' : '.
dol_escape_htmltag($sendtocc));
2484 if ($operation[
'type'] ==
'ticket') {
2486 $tickettocreate =
new Ticket($this->db);
2487 $errorfetchticket = 0;
2488 $alreadycreated = 0;
2489 if (!empty($trackid)) {
2490 $alreadycreated = $tickettocreate->fetch(0,
'', $trackid);
2492 if ($alreadycreated == 0 && !empty($msgid)) {
2493 $alreadycreated = $tickettocreate->fetch(0,
'',
'', $msgid);
2495 if ($alreadycreated < 0) {
2496 $errorfetchticket++;
2498 if (empty($errorfetchticket)) {
2499 if ($alreadycreated == 0) {
2500 $operationslog .=
'<br>Ticket not found using trackid='.$trackid.
' or msgid='.$msgid;
2501 $ticketalreadyexists = 0;
2503 $operationslog .=
'<br>Ticket already found using trackid='.$trackid.
' or msgid='.$msgid;
2504 $ticketalreadyexists = 1;
2505 $operation[
'type'] =
'recordevent';
2508 $ticketalreadyexists = -1;
2515 if ($operation[
'type'] ==
'loadthirdparty' || $operation[
'type'] ==
'loadandcreatethirdparty') {
2516 if (empty($operation[
'actionparam'])) {
2518 $this->error =
"Action loadthirdparty or loadandcreatethirdparty has empty parameter. Must be a rule like 'name=HEADER:^From:(.*);' or 'name=SET:xxx' or 'name=EXTRACT:(body|subject):regex where 'name' can be replaced with 'id' or 'email' to define how to set or extract data. More properties can also be set, for example client=SET:2;";
2519 $this->errors[] = $this->error;
2521 $actionparam = $operation[
'actionparam'];
2522 $idtouseforthirdparty =
'';
2523 $nametouseforthirdparty =
'';
2524 $emailtouseforthirdparty =
'';
2525 $namealiastouseforthirdparty =
'';
2527 $operationslog .=
'<br>Loop on each property to set into actionparam';
2531 foreach ($arrayvaluetouse as $propertytooverwrite => $valueforproperty) {
2535 $regforregex = array();
2537 if (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*)$/', $valueforproperty, $regforregex)) {
2538 $sourcefield = $regforregex[1];
2539 $regexstring = $regforregex[2];
2542 if (!empty($sourcefield) && !empty($regexstring)) {
2543 if (strtolower($sourcefield) ==
'body') {
2544 $sourcestring = $messagetext;
2545 } elseif (strtolower($sourcefield) ==
'subject') {
2546 $sourcestring = $subject;
2547 } elseif (strtolower($sourcefield) ==
'header') {
2548 $sourcestring = $header;
2551 if ($sourcestring) {
2552 $regforval = array();
2554 if (preg_match(
'/'.$regexstring.
'/ms', $sourcestring, $regforval)) {
2557 if ($propertytooverwrite ==
'id') {
2558 $idtouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2560 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found idtouseforthirdparty='.
dol_escape_htmltag($idtouseforthirdparty);
2561 } elseif ($propertytooverwrite ==
'email') {
2562 $emailtouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2564 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found emailtouseforthirdparty='.
dol_escape_htmltag($emailtouseforthirdparty);
2565 } elseif ($propertytooverwrite ==
'name') {
2566 $nametouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2568 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found nametouseforthirdparty='.
dol_escape_htmltag($nametouseforthirdparty);
2569 } elseif ($propertytooverwrite ==
'name_alias') {
2570 $namealiastouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2572 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found namealiastouseforthirdparty='.
dol_escape_htmltag($namealiastouseforthirdparty);
2574 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> We discard this, not a field used to search an existing thirdparty';
2578 if (in_array($propertytooverwrite, array(
'id',
'email',
'name',
'name_alias'))) {
2579 $idtouseforthirdparty =
null;
2580 $nametouseforthirdparty =
null;
2581 $emailtouseforthirdparty =
null;
2582 $namealiastouseforthirdparty =
null;
2584 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Not found. Property searched is critical so we cancel the search.';
2586 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Not found';
2593 $this->error =
'The extract rule to use to load thirdparty for email '.$msgid.
' has an unknown source (must be HEADER, SUBJECT or BODY)';
2594 $this->errors[] = $this->error;
2596 $operationslog .=
'<br>'.$this->error;
2598 } elseif (preg_match(
'/^(SET|SETIFEMPTY):(.*)$/', $valueforproperty, $reg)) {
2602 if ($propertytooverwrite ==
'id') {
2603 $idtouseforthirdparty = $reg[2];
2605 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property idtouseforthrdparty='.
dol_escape_htmltag($idtouseforthirdparty);
2606 } elseif ($propertytooverwrite ==
'email') {
2607 $emailtouseforthirdparty = $reg[2];
2609 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property emailtouseforthrdparty='.
dol_escape_htmltag($emailtouseforthirdparty);
2610 } elseif ($propertytooverwrite ==
'name') {
2611 $nametouseforthirdparty = $reg[2];
2613 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property nametouseforthirdparty='.
dol_escape_htmltag($nametouseforthirdparty);
2614 } elseif ($propertytooverwrite ==
'name_alias') {
2615 $namealiastouseforthirdparty = $reg[2];
2617 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property namealiastouseforthirdparty='.
dol_escape_htmltag($namealiastouseforthirdparty);
2621 $this->error =
'Bad syntax for description of action parameters: '.$actionparam;
2622 $this->errors[] = $this->error;
2627 if (!$errorforactions && ($idtouseforthirdparty || $emailtouseforthirdparty || $nametouseforthirdparty || $namealiastouseforthirdparty)) {
2629 $operationslog .=
'<br>We have this initial main data to search thirdparty: id='.$idtouseforthirdparty.
', email='.$emailtouseforthirdparty.
', name='.$nametouseforthirdparty.
', name_alias='.$namealiastouseforthirdparty.
'.';
2632 $tmpobject->element =
'generic';
2633 $tmpobject->id = $idtouseforthirdparty;
2634 $tmpobject->name = $nametouseforthirdparty;
2635 $tmpobject->name_alias = $namealiastouseforthirdparty;
2636 $tmpobject->email = $emailtouseforthirdparty;
2640 $idtouseforthirdparty = $tmpobject->id;
2641 $nametouseforthirdparty = $tmpobject->name;
2642 $namealiastouseforthirdparty = $tmpobject->name_alias;
2643 $emailtouseforthirdparty = $tmpobject->email;
2645 $operationslog .=
'<br>We try to search existing thirdparty with idtouseforthirdparty='.$idtouseforthirdparty.
' emailtouseforthirdparty='.$emailtouseforthirdparty.
' nametouseforthirdparty='.$nametouseforthirdparty.
' namealiastouseforthirdparty='.$namealiastouseforthirdparty;
2648 $result = $thirdpartystatic->findNearest($idtouseforthirdparty, $nametouseforthirdparty,
'',
'',
'',
'',
'',
'',
'',
'', $emailtouseforthirdparty, $namealiastouseforthirdparty);
2652 $this->error =
'Error when getting thirdparty with name '.$nametouseforthirdparty.
' (may be 2 record exists with same name ?)';
2653 $this->errors[] = $this->error;
2655 } elseif ($result == 0) {
2656 if ($operation[
'type'] ==
'loadthirdparty') {
2657 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was not found");
2660 $resultContact = $contactstatic->findNearest(0,
'',
'',
'', $emailtouseforthirdparty,
'', 0);
2661 if ($resultContact > 0) {
2662 $idtouseforthirdparty = $contactstatic->socid;
2663 $result = $thirdpartystatic->fetch($idtouseforthirdparty);
2665 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was found thanks to linked contact search");
2668 $langs->load(
"errors");
2669 $this->error = $langs->trans(
'ErrorFailedToLoadThirdParty', $idtouseforthirdparty, $emailtouseforthirdparty, $nametouseforthirdparty, $namealiastouseforthirdparty);
2670 $this->errors[] = $this->error;
2674 $langs->load(
"errors");
2675 $this->error = $langs->trans(
'ErrorFailedToLoadThirdParty', $idtouseforthirdparty, $emailtouseforthirdparty, $nametouseforthirdparty, $namealiastouseforthirdparty);
2676 $this->errors[] = $this->error;
2678 } elseif ($operation[
'type'] ==
'loadandcreatethirdparty') {
2679 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was not found. We try to create it.");
2682 $thirdpartystatic =
new Societe($db);
2683 $thirdpartystatic->name = (string) $nametouseforthirdparty;
2684 if (!empty($namealiastouseforthirdparty)) {
2685 if ($namealiastouseforthirdparty != $nametouseforthirdparty) {
2686 $thirdpartystatic->name_alias = $namealiastouseforthirdparty;
2689 $thirdpartystatic->name_alias = (empty($replytostring) ? (empty($fromtext) ?
'' : $fromtext) : $replytostring);
2691 $thirdpartystatic->email = (empty($emailtouseforthirdparty) ? (empty($replyto) ? (empty($from) ?
'' : $from) : $replyto) : $emailtouseforthirdparty);
2694 $errorforthisaction = $this->
overwritePropertiesOfObject($thirdpartystatic, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2696 if ($thirdpartystatic->client && empty($thirdpartystatic->code_client)) {
2697 $thirdpartystatic->code_client =
'auto';
2699 if ($thirdpartystatic->fournisseur && empty($thirdpartystatic->code_fournisseur)) {
2700 $thirdpartystatic->code_fournisseur =
'auto';
2703 if ($errorforthisaction) {
2706 $result = $thirdpartystatic->create($user);
2709 $this->error = $thirdpartystatic->error;
2710 $this->errors = $thirdpartystatic->errors;
2712 $operationslog .=
'<br>Thirdparty created -> id = '.dol_escape_htmltag($thirdpartystatic->id);
2717 dol_syslog(
"One and only one existing third party has been found");
2719 $thirdpartystatic->fetch($result);
2721 $operationslog .=
'<br>Thirdparty already exists with id = '.dol_escape_htmltag($thirdpartystatic->id);
2725 } elseif ($operation[
'type'] ==
'loadandcreatecontact') {
2726 if (empty($operation[
'actionparam'])) {
2728 $this->error =
"Action loadandcreatecontact has empty parameter. Must be 'SET:xxx' or 'EXTRACT:(body|subject):regex' to define how to extract data";
2729 $this->errors[] = $this->error;
2731 $contact_static =
new Contact($this->db);
2733 $errorforthisaction = $this->
overwritePropertiesOfObject($contact_static, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2734 if ($errorforthisaction) {
2737 if (!empty($contact_static->email) && $contact_static->email != $from) {
2738 $from = $contact_static->email;
2741 $result = $contactstatic->fetch(0,
null,
'', $from);
2744 $this->error =
'Error when getting contact with email ' . $from;
2745 $this->errors[] = $this->error;
2747 } elseif ($result == 0) {
2748 dol_syslog(
"Contact with email " . $from .
" was not found. We try to create it.");
2749 $contactstatic =
new Contact($this->db);
2752 $contactstatic->email = $from;
2753 $operationslog .=
'<br>We set property email='.dol_escape_htmltag($from);
2756 $errorforthisaction = $this->
overwritePropertiesOfObject($contactstatic, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2758 if ($errorforthisaction) {
2762 if (!empty($contactstatic->country)) {
2763 require_once DOL_DOCUMENT_ROOT .
'/core/lib/company.lib.php';
2764 $result =
getCountry(
'',
'3', $this->db,
null, 1, $contactstatic->country);
2765 if ($result ==
'NotDefined') {
2767 $this->error =
"Error country not found by this name '" . $contactstatic->country .
"'";
2768 } elseif (!($result > 0)) {
2770 $this->error =
"Error when search country by this name '" . $contactstatic->country .
"'";
2771 $this->errors[] = $this->db->lasterror();
2773 $contactstatic->country_id = $result;
2774 $operationslog .=
'<br>We set property country_id='.dol_escape_htmltag($result);
2776 } elseif (!empty($contactstatic->country_code)) {
2777 require_once DOL_DOCUMENT_ROOT .
'/core/lib/company.lib.php';
2778 $result =
getCountry($contactstatic->country_code,
'3', $this->db);
2779 if ($result ==
'NotDefined') {
2781 $this->error =
"Error country not found by this code '" . $contactstatic->country_code .
"'";
2782 } elseif (!($result > 0)) {
2784 $this->error =
"Error when search country by this code '" . $contactstatic->country_code .
"'";
2785 $this->errors[] = $this->db->lasterror();
2787 $contactstatic->country_id = $result;
2788 $operationslog .=
'<br>We set property country_id='.dol_escape_htmltag($result);
2792 if (!$errorforactions) {
2794 if (!empty($contactstatic->state)) {
2795 require_once DOL_DOCUMENT_ROOT .
'/core/lib/functions.lib.php';
2796 $result =
dol_getIdFromCode($this->db, $contactstatic->state,
'c_departements',
'nom',
'rowid');
2797 if (empty($result)) {
2799 $this->error =
"Error state not found by this name '" . $contactstatic->state .
"'";
2800 } elseif (!($result > 0)) {
2802 $this->error =
"Error when search state by this name '" . $contactstatic->state .
"'";
2803 $this->errors[] = $this->db->lasterror();
2805 $contactstatic->state_id = $result;
2806 $operationslog .=
'<br>We set property state_id='.dol_escape_htmltag($result);
2808 } elseif (!empty($contactstatic->state_code)) {
2809 require_once DOL_DOCUMENT_ROOT .
'/core/lib/functions.lib.php';
2810 $result =
dol_getIdFromCode($this->db, $contactstatic->state_code,
'c_departements',
'code_departement',
'rowid');
2811 if (empty($result)) {
2813 $this->error =
"Error state not found by this code '" . $contactstatic->state_code .
"'";
2814 } elseif (!($result > 0)) {
2816 $this->error =
"Error when search state by this code '" . $contactstatic->state_code .
"'";
2817 $this->errors[] = $this->db->lasterror();
2819 $contactstatic->state_id = $result;
2820 $operationslog .=
'<br>We set property state_id='.dol_escape_htmltag($result);
2825 if (!$errorforactions) {
2826 $result = $contactstatic->create($user);
2829 $this->error = $contactstatic->error;
2830 $this->errors = $contactstatic->errors;
2832 $operationslog .=
'<br>Contact created -> id = '.dol_escape_htmltag($contactstatic->id);
2839 } elseif ($operation[
'type'] ==
'recordevent') {
2843 $alreadycreated = $actioncomm->fetch(0,
'',
'', $msgid);
2844 if ($alreadycreated == 0) {
2845 $operationslog .=
'<br>We did not find existing actionmail with msgid='.$msgid;
2847 if ($projectstatic->id > 0) {
2848 if ($projectfoundby) {
2849 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Project found from '.$projectfoundby);
2852 if ($thirdpartystatic->id > 0) {
2853 if ($thirdpartyfoundby) {
2854 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
2857 if ($contactstatic->id > 0) {
2858 if ($contactfoundby) {
2859 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
2863 $description = $descriptiontitle;
2869 $descriptionfull = $description;
2871 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
2876 $actioncomm->type_code =
'AC_OTH_AUTO';
2877 $actioncomm->code =
'AC_'.$actioncode;
2878 $actioncomm->label = $langs->trans(
"ActionAC_".$actioncode).
' - '.$langs->trans(
"MailFrom").
' '.$from;
2879 $actioncomm->note_private = $descriptionfull;
2880 $actioncomm->fk_project = $projectstatic->id;
2881 $actioncomm->datep = $dateemail;
2882 $actioncomm->datef = $dateemail;
2883 $actioncomm->percentage = -1;
2884 $actioncomm->socid = $thirdpartystatic->id;
2885 $actioncomm->contact_id = $contactstatic->id;
2886 $actioncomm->socpeopleassigned = (!empty($contactstatic->id) ? array($contactstatic->id) : array());
2887 $actioncomm->authorid = $user->id;
2888 $actioncomm->userownerid = $user->id;
2890 $actioncomm->email_msgid = $msgid;
2891 $actioncomm->email_from = $fromstring;
2892 $actioncomm->email_sender = $sender;
2893 $actioncomm->email_to = $to;
2894 $actioncomm->email_tocc = $sendtocc;
2895 $actioncomm->email_tobcc = $sendtobcc;
2896 $actioncomm->email_subject = $subject;
2897 $actioncomm->errors_to =
'';
2899 if (!in_array($fk_element_type, array(
'societe',
'contact',
'project',
'user'))) {
2900 $actioncomm->fk_element = $fk_element_id;
2901 $actioncomm->elementid = $fk_element_id;
2902 $actioncomm->elementtype = $fk_element_type;
2903 if (is_object($objectemail) && $objectemail->module) {
2904 $actioncomm->elementtype .=
'@'.$objectemail->module;
2911 $errorforthisaction = $this->
overwritePropertiesOfObject($actioncomm, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2913 if ($errorforthisaction) {
2916 $result = $actioncomm->create($user);
2919 $this->errors = $actioncomm->errors;
2921 if ($fk_element_type ==
"ticket" && is_object($objectemail)) {
2922 if ($objectemail->status == Ticket::STATUS_CLOSED || $objectemail->status == Ticket::STATUS_CANCELED) {
2923 if ($objectemail->fk_user_assign !=
null) {
2924 $res = $objectemail->setStatut(Ticket::STATUS_ASSIGNED);
2926 $res = $objectemail->setStatut(Ticket::STATUS_NOT_READ);
2930 $operationslog .=
'<br>Ticket Re-Opened successfully -> ref='.$objectemail->ref;
2933 $this->error =
'Error while changing the ticket status -> ref='.$objectemail->ref;
2934 $this->errors[] = $this->error;
2937 if (!empty($attachments)) {
2939 $ticket =
new Ticket($this->db);
2940 $ticket->fetch($fk_element_id);
2941 $destdir = $conf->ticket->dir_output.
'/'.$ticket->ref;
2946 foreach ($attachments as $attachment) {
2947 $attachment->save($destdir.
'/');
2950 $this->
getmsg($connection, $imapemail, $destdir);
2955 $operationslog .=
'<br>Event created -> id='.dol_escape_htmltag($actioncomm->id);
2959 } elseif ($operation[
'type'] ==
'recordjoinpiece') {
2962 foreach ($attachments as $attachment) {
2963 if ($attachment->getName() ===
'undefined') {
2966 $data[$attachment->getName()] = $attachment->getContent();
2970 foreach ($pj as $key => $val) {
2971 $data[$val[
'filename']] =
getFileData($imapemail, (
string) $val[
'pos'], $val[
'type'], $connection);
2974 if (count($data) > 0) {
2975 $sql =
"SELECT rowid as id FROM ".MAIN_DB_PREFIX.
"user WHERE email LIKE '%".$this->db->escape($from).
"%'";
2976 $resql = $this->db->query($sql);
2977 if ($this->db->num_rows($resql) == 0) {
2978 $this->errors[] =
"User Not allowed to add documents ({$from})";
2980 $arrayobject = array(
2981 'propale' => array(
'table' =>
'propal',
2982 'fields' => array(
'ref'),
2983 'class' =>
'comm/propal/class/propal.class.php',
2984 'object' =>
'Propal'),
2985 'holiday' => array(
'table' =>
'holiday',
2986 'fields' => array(
'ref'),
2987 'class' =>
'holiday/class/holiday.class.php',
2988 'object' =>
'Holiday'),
2989 'expensereport' => array(
'table' =>
'expensereport',
2990 'fields' => array(
'ref'),
2991 'class' =>
'expensereport/class/expensereport.class.php',
2992 'object' =>
'ExpenseReport'),
2993 'recruitment/recruitmentjobposition' => array(
'table' =>
'recruitment_recruitmentjobposition',
2994 'fields' => array(
'ref'),
2995 'class' =>
'recruitment/class/recruitmentjobposition.class.php',
2996 'object' =>
'RecruitmentJobPosition'),
2997 'recruitment/recruitmentcandidature' => array(
'table' =>
'recruitment_recruitmentcandidature',
2998 'fields' => array(
'ref'),
2999 'class' =>
'recruitment/class/recruitmentcandidature.class.php',
3000 'object' =>
'RecruitmentCandidature'),
3001 'societe' => array(
'table' =>
'societe',
3002 'fields' => array(
'code_client',
'code_fournisseur'),
3003 'class' =>
'societe/class/societe.class.php',
3004 'object' =>
'Societe'),
3005 'commande' => array(
'table' =>
'commande',
3006 'fields' => array(
'ref'),
3007 'class' =>
'commande/class/commande.class.php',
3008 'object' =>
'Commande'),
3009 'expedition' => array(
'table' =>
'expedition',
3010 'fields' => array(
'ref'),
3011 'class' =>
'expedition/class/expedition.class.php',
3012 'object' =>
'Expedition'),
3013 'contract' => array(
'table' =>
'contrat',
3014 'fields' => array(
'ref'),
3015 'class' =>
'contrat/class/contrat.class.php',
3016 'object' =>
'Contrat'),
3017 'fichinter' => array(
'table' =>
'fichinter',
3018 'fields' => array(
'ref'),
3019 'class' =>
'fichinter/class/fichinter.class.php',
3020 'object' =>
'Fichinter'),
3021 'ticket' => array(
'table' =>
'ticket',
3022 'fields' => array(
'ref'),
3023 'class' =>
'ticket/class/ticket.class.php',
3024 'object' =>
'Ticket'),
3025 'knowledgemanagement' => array(
'table' =>
'knowledgemanagement_knowledgerecord',
3026 'fields' => array(
'ref'),
3027 'class' =>
'knowledgemanagement/class/knowledgemanagement.class.php',
3028 'object' =>
'KnowledgeRecord'),
3029 'supplier_proposal' => array(
'table' =>
'supplier_proposal',
3030 'fields' => array(
'ref'),
3031 'class' =>
'supplier_proposal/class/supplier_proposal.class.php',
3032 'object' =>
'SupplierProposal'),
3033 'fournisseur/commande' => array(
'table' =>
'commande_fournisseur',
3034 'fields' => array(
'ref',
'ref_supplier'),
3035 'class' =>
'fourn/class/fournisseur.commande.class.php',
3036 'object' =>
'SupplierProposal'),
3037 'facture' => array(
'table' =>
'facture',
3038 'fields' => array(
'ref'),
3039 'class' =>
'compta/facture/class/facture.class.php',
3040 'object' =>
'Facture'),
3041 'fournisseur/facture' => array(
'table' =>
'facture_fourn',
3042 'fields' => array(
'ref',
'ref_client'),
3043 'class' =>
'fourn/class/fournisseur.facture.class.php',
3044 'object' =>
'FactureFournisseur'),
3045 'produit' => array(
'table' =>
'product',
3046 'fields' => array(
'ref'),
3047 'class' =>
'product/class/product.class.php',
3048 'object' =>
'Product'),
3049 'productlot' => array(
'table' =>
'product_lot',
3050 'fields' => array(
'batch'),
3051 'class' =>
'product/stock/class/productlot.class.php',
3052 'object' =>
'Productlot'),
3053 'projet' => array(
'table' =>
'projet',
3054 'fields' => array(
'ref'),
3055 'class' =>
'projet/class/projet.class.php',
3056 'object' =>
'Project'),
3057 'projet_task' => array(
'table' =>
'projet_task',
3058 'fields' => array(
'ref'),
3059 'class' =>
'projet/class/task.class.php',
3060 'object' =>
'Task'),
3061 'ressource' => array(
'table' =>
'resource',
3062 'fields' => array(
'ref'),
3063 'class' =>
'ressource/class/dolressource.class.php',
3064 'object' =>
'Dolresource'),
3065 'bom' => array(
'table' =>
'bom_bom',
3066 'fields' => array(
'ref'),
3067 'class' =>
'bom/class/bom.class.php',
3069 'mrp' => array(
'table' =>
'mrp_mo',
3070 'fields' => array(
'ref'),
3071 'class' =>
'mrp/class/mo.class.php',
3075 if (!is_object($hookmanager)) {
3076 include_once DOL_DOCUMENT_ROOT.
'/core/class/hookmanager.class.php';
3079 $hookmanager->initHooks(array(
'emailcolector'));
3080 $parameters = array(
'arrayobject' => $arrayobject);
3081 $reshook = $hookmanager->executeHooks(
'addmoduletoeamailcollectorjoinpiece', $parameters);
3083 $arrayobject = $hookmanager->resArray;
3086 $resultobj = array();
3088 foreach ($arrayobject as $key => $objectdesc) {
3089 $sql =
'SELECT DISTINCT t.rowid ';
3090 $sql .=
' FROM ' . MAIN_DB_PREFIX . $this->db->sanitize($objectdesc[
'table']) .
' AS t';
3092 foreach ($objectdesc[
'fields'] as $field) {
3093 $sql .=
"('" .$this->db->escape($subject) .
"' LIKE CONCAT('%', t." . $this->db->sanitize($field) .
", '%') AND t." . $this->db->sanitize($field) .
" <> '') OR ";
3095 $sql = substr($sql, 0, -4);
3097 $ressqlobj = $this->db->query($sql);
3099 while ($obj = $this->db->fetch_object($ressqlobj)) {
3100 $resultobj[$key][] = $obj->rowid;
3105 foreach ($resultobj as $mod => $ids) {
3106 $moddesc = $arrayobject[$mod];
3107 $elementpath = $mod;
3109 $objectmanaged =
new $moddesc[
'object']($this->db);
3110 '@phan-var-force CommonObject $objectmanaged';
3111 foreach ($ids as $val) {
3112 $res = $objectmanaged->fetch($val);
3114 $path = ($objectmanaged->entity > 1 ?
"/" . $objectmanaged->entity :
'');
3115 $dirs[] = DOL_DATA_ROOT . $path .
"/" . $elementpath .
'/' .
dol_sanitizeFileName($objectmanaged->ref) .
'/';
3117 $this->errors[] =
'object not found';
3121 foreach ($dirs as $target) {
3122 $prefix = $this->actions[$this->id][
'actionparam'];
3123 foreach ($data as $filename => $content) {
3124 $resr =
saveAttachment($target, $prefix .
'_' . $filename, $content);
3126 $this->errors[] =
'Doc not saved';
3131 $operationslog .=
'<br>Save attachment files on disk';
3133 $this->errors[] =
'no joined piece';
3135 $operationslog .=
'<br>No joinded files';
3137 } elseif ($operation[
'type'] ==
'project') {
3139 $projecttocreate =
new Project($this->db);
3140 $alreadycreated = $projecttocreate->fetch(0,
'',
'', $msgid);
3141 if ($alreadycreated == 0) {
3142 if ($thirdpartystatic->id > 0) {
3143 $projecttocreate->socid = $thirdpartystatic->id;
3144 if ($thirdpartyfoundby) {
3145 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
3148 if ($contactstatic->id > 0) {
3149 $projecttocreate->contact_id = $contactstatic->id;
3150 if ($contactfoundby) {
3151 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
3155 $description = $descriptiontitle;
3161 $descriptionfull = $description;
3163 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3167 $id_opp_status =
dol_getIdFromCode($this->db,
'PROSP',
'c_lead_status',
'code',
'rowid');
3168 $percent_opp_status =
dol_getIdFromCode($this->db,
'PROSP',
'c_lead_status',
'code',
'percent');
3170 $projecttocreate->title = $subject;
3171 $projecttocreate->date_start = $dateemail;
3172 $projecttocreate->date_end = 0;
3173 $projecttocreate->opp_status = $id_opp_status;
3174 $projecttocreate->opp_percent = $percent_opp_status;
3176 $projecttocreate->note_private = $descriptionfull;
3177 $projecttocreate->entity = $conf->entity;
3179 $projecttocreate->email_date = $dateemail;
3180 $projecttocreate->email_msgid = $msgid;
3181 $projecttocreate->email_from = $fromstring;
3182 $projecttocreate->email_sender = $sender;
3183 $projecttocreate->email_to = $to;
3184 $projecttocreate->email_tocc = $sendtocc;
3185 $projecttocreate->email_tobcc = $sendtobcc;
3186 $projecttocreate->email_subject = $subject;
3187 $projecttocreate->errors_to =
'';
3189 $savesocid = $projecttocreate->socid;
3193 $errorforthisaction = $this->
overwritePropertiesOfObject($projecttocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3197 if (empty($projecttocreate->ref)) {
3206 $dirmodels = array_merge(array(
'/'), (array) $conf->modules_parts[
'models']);
3207 foreach ($dirmodels as $reldir) {
3208 $file =
dol_buildpath($reldir.
"core/modules/project/".$modele.
'.php', 0);
3209 if (file_exists($file)) {
3210 $classname = $modele;
3215 if ($classname !==
'') {
3216 if ($savesocid > 0) {
3217 if ($savesocid != $projecttocreate->socid) {
3219 setEventMessages(
'You loaded a thirdparty (id='.$savesocid.
') and you force another thirdparty id (id='.$projecttocreate->socid.
') by setting socid in operation with a different value',
null,
'errors');
3222 if ($projecttocreate->socid > 0) {
3223 $thirdpartystatic->fetch($projecttocreate->socid);
3227 $result =
dol_include_once($reldir.
"core/modules/project/".$modele.
'.php');
3228 $modModuleToUseForNextValue =
new $classname();
3229 '@phan-var-force ModeleNumRefProjects $modModuleToUseForNextValue';
3230 $defaultref = $modModuleToUseForNextValue->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $projecttocreate);
3232 $projecttocreate->ref = $defaultref;
3236 if ($errorforthisaction) {
3239 if (empty($projecttocreate->ref) || (is_numeric($projecttocreate->ref) && $projecttocreate->ref <= 0)) {
3241 $this->error =
'Failed to create project: Can\'t get a valid value for the field ref with numbering template = '.$modele.
', thirdparty id = '.$thirdpartystatic->id;
3243 $operationslog .=
'<br>'.$this->error;
3246 $result = $projecttocreate->create($user);
3249 $this->error =
'Failed to create project: '.$langs->trans($projecttocreate->error);
3250 $this->errors = $projecttocreate->errors;
3252 $operationslog .=
'<br>'.$this->error;
3255 $destdir = $conf->project->dir_output.
'/'.$projecttocreate->ref;
3260 foreach ($attachments as $attachment) {
3262 $typeattachment = (string) $attachment->getDisposition();
3263 $filename = $attachment->getFilename();
3264 $content = $attachment->getContent();
3268 $this->
getmsg($connection, $imapemail, $destdir);
3271 $operationslog .=
'<br>Project created with attachments -> id='.dol_escape_htmltag($projecttocreate->id);
3273 $operationslog .=
'<br>Project created without attachments -> id='.dol_escape_htmltag($projecttocreate->id);
3281 $operationslog .=
'<br>Project already exists for msgid ='.dol_escape_htmltag($msgid);
3283 } elseif ($operation[
'type'] ==
'ticket') {
3285 $tickettocreate =
new Ticket($this->db);
3286 if ($ticketalreadyexists == 0) {
3287 if ($thirdpartystatic->id > 0) {
3288 $tickettocreate->socid = $thirdpartystatic->id;
3289 $tickettocreate->fk_soc = $thirdpartystatic->id;
3290 if ($thirdpartyfoundby) {
3291 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
3294 if ($contactstatic->id > 0) {
3295 $tickettocreate->contact_id = $contactstatic->id;
3296 if ($contactfoundby) {
3297 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
3301 $description = $descriptiontitle;
3307 $descriptionfull = $description;
3309 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3313 $tickettocreate->subject = $subject;
3314 $tickettocreate->message = $description;
3316 $tickettocreate->category_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_CATEGORY_CODE',
dol_getIdFromCode($this->db, 1,
'c_ticket_category',
'use_default',
'code', 1)));
3317 $tickettocreate->severity_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_SEVERITY_CODE',
dol_getIdFromCode($this->db, 1,
'c_ticket_severity',
'use_default',
'code', 1)));
3318 $tickettocreate->origin_email = $from;
3319 $tickettocreate->origin_replyto = (!empty($replyto) ? $replyto :
null);
3320 $tickettocreate->origin_references = (!empty($headers[
'References']) ? $headers[
'References'] :
null);
3321 $tickettocreate->fk_user_create = $user->id;
3322 $tickettocreate->datec =
dol_now();
3323 $tickettocreate->fk_project = $projectstatic->id;
3324 $tickettocreate->notify_tiers_at_create =
getDolGlobalInt(
'TICKET_CHECK_NOTIFY_THIRDPARTY_AT_CREATION');
3325 $tickettocreate->note_private = $descriptionfull;
3326 $tickettocreate->entity = $conf->entity;
3328 $tickettocreate->email_date = $dateemail;
3329 $tickettocreate->email_msgid = $msgid;
3330 $tickettocreate->email_from = $fromstring;
3331 $tickettocreate->email_sender = $sender;
3332 $tickettocreate->email_to = $to;
3333 $tickettocreate->email_tocc = $sendtocc;
3334 $tickettocreate->email_tobcc = $sendtobcc;
3335 $tickettocreate->email_subject = $subject;
3336 $tickettocreate->errors_to =
'';
3340 $savesocid = $tickettocreate->socid;
3344 $errorforthisaction = $this->
overwritePropertiesOfObject($tickettocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3346 $modele =
'UNDEFINED';
3348 if (empty($tickettocreate->ref)) {
3357 $dirmodels = array_merge(array(
'/'), (array) $conf->modules_parts[
'models']);
3358 foreach ($dirmodels as $reldir) {
3359 $file =
dol_buildpath($reldir.
"core/modules/ticket/".$modele.
'.php', 0);
3360 if (file_exists($file)) {
3361 $classname = $modele;
3366 if ($classname !==
'') {
3367 if ($savesocid > 0) {
3368 if ($savesocid != $tickettocreate->socid) {
3370 setEventMessages(
'You loaded a thirdparty (id='.$savesocid.
') and you force another thirdparty id (id='.$tickettocreate->socid.
') by setting socid in operation with a different value',
null,
'errors');
3373 if ($tickettocreate->socid > 0) {
3374 $thirdpartystatic->fetch($tickettocreate->socid);
3379 $modModuleToUseForNextValue =
new $classname();
3380 '@phan-var-force ModeleNumRefTicket $modModuleToUseForNextValue';
3381 $defaultref = $modModuleToUseForNextValue->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $tickettocreate);
3383 $tickettocreate->ref = $defaultref;
3386 if ($errorforthisaction) {
3389 if (is_numeric($tickettocreate->ref) && $tickettocreate->ref <= 0) {
3391 $this->error =
'Failed to create ticket: Can\'t get a valid value for the field ref with numbering template = '.$modele.
', thirdparty id = '.$thirdpartystatic->id;
3394 $tickettocreate->context[
'actionmsg2'] = $langs->trans(
"ActionAC_EMAIL_IN").
' - '.$langs->trans(
"TICKET_CREATEInDolibarr");
3395 $tickettocreate->context[
'actionmsg'] = $langs->trans(
"ActionAC_EMAIL_IN").
' - '.$langs->trans(
"TICKET_CREATEInDolibarr");
3398 $result = $tickettocreate->create($user);
3401 $this->error =
'Failed to create ticket: '.$langs->trans($tickettocreate->error);
3402 $this->errors = $tickettocreate->errors;
3405 $destdir = $conf->ticket->dir_output.
'/'.$tickettocreate->ref;
3410 foreach ($attachments as $attachment) {
3412 $typeattachment = (string) $attachment->getDisposition();
3413 $filename = $attachment->getFilename();
3414 $content = $attachment->getContent();
3418 $this->
getmsg($connection, $imapemail, $destdir);
3421 $operationslog .=
'<br>Ticket created with attachments -> id='.dol_escape_htmltag($tickettocreate->id);
3423 $operationslog .=
'<br>Ticket created without attachments -> id='.dol_escape_htmltag($tickettocreate->id);
3429 } elseif ($operation[
'type'] ==
'candidature') {
3433 $alreadycreated = $candidaturetocreate->fetch(0,
'', $msgid);
3434 if ($alreadycreated == 0) {
3435 $description = $descriptiontitle;
3441 $descriptionfull = $description;
3442 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3445 $candidaturetocreate->subject = $subject;
3446 $candidaturetocreate->message = $description;
3447 $candidaturetocreate->type_code = 0;
3448 $candidaturetocreate->category_code =
null;
3449 $candidaturetocreate->severity_code =
null;
3450 $candidaturetocreate->email = $from;
3452 $candidaturetocreate->fk_user_creat = $user->id;
3453 $candidaturetocreate->date_creation =
dol_now();
3454 $candidaturetocreate->fk_project = $projectstatic->id;
3455 $candidaturetocreate->description = $description;
3456 $candidaturetocreate->note_private = $descriptionfull;
3457 $candidaturetocreate->entity = $conf->entity;
3458 $candidaturetocreate->email_msgid = $msgid;
3459 $candidaturetocreate->email_date = $dateemail;
3460 $candidaturetocreate->status = $candidaturetocreate::STATUS_DRAFT;
3465 $errorforthisaction = $this->
overwritePropertiesOfObject($candidaturetocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3508 if ($errorforthisaction) {
3512 $result = $candidaturetocreate->create($user);
3515 $this->error =
'Failed to create candidature: '.implode(
', ', $candidaturetocreate->errors);
3516 $this->errors = $candidaturetocreate->errors;
3519 $operationslog .=
'<br>Candidature created without attachments -> id='.dol_escape_htmltag($candidaturetocreate->id);
3522 } elseif (substr($operation[
'type'], 0, 4) ==
'hook') {
3525 if (!is_object($hookmanager)) {
3526 include_once DOL_DOCUMENT_ROOT.
'/core/class/hookmanager.class.php';
3528 $hookmanager->initHooks([
'emailcolector']);
3531 $parameters = array(
3532 'connection' => $connection,
3533 'imapemail' => $imapemail,
3534 'overview' => $overview,
3537 'fromtext' => $fromtext,
3539 'actionparam' => $operation[
'actionparam'],
3541 'thirdpartyid' => $thirdpartyid,
3542 'objectid' => $objectid,
3543 'objectemail' => $objectemail,
3545 'messagetext' => $messagetext,
3546 'subject' => $subject,
3547 'header' => $header,
3548 'attachments' => $attachments,
3550 $reshook = $hookmanager->executeHooks(
'doCollectImapOneCollector', $parameters, $this, $operation[
'type']);
3553 $errorforthisaction++;
3554 $this->error = $hookmanager->resPrint;
3556 if ($errorforthisaction) {
3558 $operationslog .=
'<br>Hook doCollectImapOneCollector executed with error';
3560 $operationslog .=
'<br>Hook doCollectImapOneCollector executed without error';
3564 if (!$errorforactions) {
3565 $nbactiondoneforemail++;
3571 if (!$errorforactions) {
3572 if (!empty($targetdir)) {
3575 dol_syslog(
"EmailCollector::doCollectOneCollector move message ".($imapemail->getHeader()->get(
'subject')).
" to ".$targetdir, LOG_DEBUG);
3576 $operationslog .=
'<br>Move mail '.($this->uidAsString($imapemail)).
' - '.$msgid.
' - '.$imapemail->getHeader()->get(
'subject').
' to '.$targetdir;
3578 $arrayofemailtodelete[$this->
uidAsString($imapemail)] = $imapemail;
3581 dol_syslog(
"EmailCollector::doCollectOneCollector move message ".($this->
uidAsString($imapemail)).
" to ".$connectstringtarget, LOG_DEBUG);
3582 $operationslog .=
'<br>Move mail '.($this->uidAsString($imapemail)).
' - '.$msgid;
3584 $arrayofemailtodelete[$imapemail] = $msgid;
3589 dol_syslog(
"EmailCollector::doCollectOneCollector message ".($this->
uidAsString($imapemail)).
" '".($imapemail->getHeader()->get(
'subject')).
"' using this->host=".$this->host.
", this->access_type=".$this->acces_type.
" was set to read", LOG_DEBUG);
3591 dol_syslog(
"EmailCollector::doCollectOneCollector message ".($this->
uidAsString($imapemail)).
" to ".$connectstringtarget.
" was set to read", LOG_DEBUG);
3599 unset($objectemail);
3600 unset($projectstatic);
3601 unset($thirdpartystatic);
3602 unset($contactstatic);
3604 $nbemailprocessed++;
3606 if (!$errorforemail) {
3607 $nbactiondone += $nbactiondoneforemail;
3611 $this->db->commit();
3613 $this->db->rollback();
3617 if ($this->maxemailpercollect > 0 && $nbemailok >= $this->maxemailpercollect) {
3618 dol_syslog(
"EmailCollect::doCollectOneCollector We reach maximum of ".$nbemailok.
" collected with success, so we stop this collector now.");
3624 $this->db->rollback();
3628 $output = $langs->trans(
'XEmailsDoneYActionsDone', $nbemailprocessed, $nbemailok, $nbactiondone);
3630 dol_syslog(
"End of loop on emails", LOG_INFO, -1);
3632 $langs->load(
"admin");
3633 $output = $langs->trans(
'NoNewEmailToProcess');
3634 $output .=
' (defaultlang='.$langs->defaultlang.
')';
3640 krsort($arrayofemailtodelete, SORT_NUMERIC);
3642 foreach ($arrayofemailtodelete as $imapemailnum => $imapemail) {
3643 dol_syslog(
"EmailCollect::doCollectOneCollector delete email ".$imapemailnum);
3645 $operationslog .=
"<br> move email ".$imapemailnum.($mode > 0 ?
' (test)' :
'');
3647 if (empty($mode) && empty($error)) {
3648 $tmptargetdir = $targetdir;
3655 $result = $imapemail->move($tmptargetdir,
false);
3658 $operationslog .=
'<br>Exception !!!! '.$e->getMessage();
3660 if (empty($result)) {
3661 dol_syslog(
"Failed to move email into target directory ".$targetdir);
3662 $operationslog .=
'<br>Failed to move email into target directory '.$targetdir;
3668 if (empty($mode) && empty($error)) {
3670 $operationslog .=
"<br>Expunge";
3675 $client->disconnect();
3677 foreach ($arrayofemailtodelete as $imapemail => $msgid) {
3678 dol_syslog(
"EmailCollect::doCollectOneCollector delete email ".$imapemail.
" ".$msgid);
3680 $operationslog .=
"<br> delete email ".$imapemail.
" ".$msgid.($mode > 0 ?
' (test)' :
'');
3682 if (empty($mode) && empty($error)) {
3683 $res = imap_mail_move($connection, $imapemail, $targetdir, CP_UID);
3686 $this->error = imap_last_error();
3687 $this->errors[] = $this->error;
3689 $operationslog .=
'<br>Error in move '.$this->error;
3696 if (empty($mode) && empty($error)) {
3698 $operationslog .=
"<br>Expunge";
3700 imap_expunge($connection);
3702 imap_close($connection);
3705 $this->datelastresult = $now;
3706 $this->lastresult = $output;
3708 $this->debuginfo .=
'IMAP search array used : '.$search;
3710 $this->debuginfo .=
'IMAP search string used : '.$search;
3713 $this->debuginfo .=
'<br>Then search string into email header : '.dol_escape_htmltag($searchhead);
3715 if ($operationslog) {
3716 $this->debuginfo .= $operationslog;
3719 if (empty($error) && empty($mode)) {
3720 $this->datelastok = $now;
3723 if (!empty($this->errors)) {
3724 $this->lastresult .=
"<br>".implode(
"<br>", $this->errors);
3726 $this->codelastresult = ($error ?
'KO' :
'OK');
3732 dol_syslog(
"EmailCollector::doCollectOneCollector end", LOG_INFO);
3734 return $error ? -1 : 1;
3749 private function getmsg($mbox, $mid, $destdir =
'')
3753 global $charset, $htmlmsg, $plainmsg, $attachments;
3754 $htmlmsg = $plainmsg = $charset =
'';
3755 $attachments = array();
3762 $s = imap_fetchstructure($mbox, $mid, FT_UID);
3767 $this->
getpart($mbox, $mid, $s,
'0');
3770 foreach ($s->parts as $partno0 => $p) {
3771 $this->
getpart($mbox, $mid, $p, $partno0 + 1, $destdir);
3802 private function getpart($mbox, $mid, $p, $partno, $destdir =
'')
3805 global $htmlmsg, $plainmsg, $charset, $attachments;
3809 imap_fetchbody($mbox, $mid, $partno, FT_UID) :
3810 imap_body($mbox, $mid, FT_UID);
3812 if ($p->encoding == 4) {
3813 $data = quoted_printable_decode($data);
3814 } elseif ($p->encoding == 3) {
3815 $data = base64_decode($data);
3821 if ($p->parameters) {
3822 foreach ($p->parameters as $x) {
3823 $params[strtolower($x->attribute)] = $x->value;
3826 if (!empty($p->dparameters)) {
3827 foreach ($p->dparameters as $x) {
3828 $params[strtolower($x->attribute)] = $x->value;
3831 '@phan-var-force array{filename?:string,name?:string,charset?:string} $params';
3836 if (!empty($params[
'filename']) || !empty($params[
'name'])) {
3838 $filename = $params[
'filename'] ?? $params[
'name'];
3840 $attachments[$filename] = $data;
3842 if (strlen($destdir)) {
3843 if (substr($destdir, -1) !=
'/') {
3848 $file_name_complete = $filename;
3849 $destination = $destdir.$file_name_complete;
3852 $extension = pathinfo($file_name_complete, PATHINFO_EXTENSION);
3855 $file_name = pathinfo($file_name_complete, PATHINFO_FILENAME);
3858 $file_name_original = $file_name;
3867 while (file_exists($destdir.$file_name.
".".$extension)) {
3868 $file_name = $file_name_original .
' (' . $num .
')';
3869 $file_name_complete = $file_name .
"." . $extension;
3870 $destination = $destdir.$file_name_complete;
3876 file_put_contents($destination, $data);
3881 if ($p->type == 0 && $data) {
3882 if (!empty($params[
'charset'])) {
3887 if (strtolower($p->subtype) ==
'plain') {
3888 $plainmsg .= trim($data).
"\n\n";
3890 $htmlmsg .= $data.
"<br><br>";
3892 $charset = $params[
'charset'];
3893 } elseif ($p->type == 2 && $data) {
3899 if (!empty($params[
'charset'])) {
3902 $plainmsg .= $data.
"\n\n";
3906 if (!empty($p->parts)) {
3907 foreach ($p->parts as $partno0 => $p2) {
3908 $this->
getpart($mbox, $mid, $p2, $partno.
'.'.($partno0 + 1), $destdir);
3924 if (!$string || $fromEncoding == $toEncoding) {
3927 $convertedString = function_exists(
'iconv') ? @iconv($fromEncoding, $toEncoding.
'//IGNORE', $string) :
null;
3928 if (!$convertedString && extension_loaded(
'mbstring')) {
3929 $convertedString = @mb_convert_encoding($string, $toEncoding, $fromEncoding);
3931 if (!$convertedString) {
3932 throw new Exception(
'Mime string encoding conversion failed');
3934 return $convertedString;
3953 if (function_exists(
'imap_mime_header_decode') && function_exists(
'iconv_mime_decode')) {
3954 $elements = imap_mime_header_decode($subject);
3956 if (!empty($elements)) {
3957 $num = count($elements);
3958 for ($i = 0; $i < $num; $i++) {
3959 $stringinutf8 = (in_array(strtoupper($elements[$i]->charset), array(
'DEFAULT',
'UTF-8')) ? $elements[$i]->text : iconv_mime_decode($elements[$i]->text, ICONV_MIME_DECODE_CONTINUE_ON_ERROR, $elements[$i]->charset));
3960 $newstring .= $stringinutf8;
3962 $subject = $newstring;
3964 } elseif (!function_exists(
'mb_decode_mimeheader')) {
3965 $subject = mb_decode_mimeheader($subject);
3966 } elseif (function_exists(
'iconv_mime_decode')) {
3967 $subject = iconv_mime_decode($subject, ICONV_MIME_DECODE_CONTINUE_ON_ERROR,
'UTF-8');
3983 require_once DOL_DOCUMENT_ROOT .
'/core/lib/images.lib.php';
3986 $maxwidthsmall = $tmparraysize[
'maxwidthsmall'];
3987 $maxheightsmall = $tmparraysize[
'maxheightsmall'];
3988 $maxwidthmini = $tmparraysize[
'maxwidthmini'];
3989 $maxheightmini = $tmparraysize[
'maxheightmini'];
3990 $quality = $tmparraysize[
'quality'];
3992 file_put_contents($destdir.
'/'.$filename, $content);
3995 vignette($destdir.
'/'.$filename, $maxwidthsmall, $maxheightsmall,
'_small', $quality,
"thumbs");
3997 vignette($destdir.
'/'.$filename, $maxwidthmini, $maxheightmini,
'_mini', $quality,
"thumbs");
4010 if (is_object($imapemail)) {
4011 return $imapemail->getAttributes()[
"uid"];
4013 return (
string) $imapemail;