65 public $element =
'emailcollector';
70 public $table_element =
'emailcollector_emailcollector';
75 public $picto =
'email';
80 public $fk_element =
'fk_emailcollector';
85 protected $childtables = array();
90 protected $childtablesoncascade = array(
'emailcollector_emailcollectorfilter',
'emailcollector_emailcollectoraction');
116 public $fields = array(
117 'rowid' => array(
'type' =>
'integer',
'label' =>
'TechnicalID',
'visible' => 2,
'enabled' => 1,
'position' => 1,
'notnull' => 1,
'index' => 1),
118 'entity' => array(
'type' =>
'integer',
'label' =>
'Entity',
'enabled' => 1,
'visible' => 0,
'default' => 1,
'notnull' => 1,
'index' => 1,
'position' => 20),
119 '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'),
120 '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'),
121 'description' => array(
'type' =>
'text',
'label' =>
'Description',
'visible' => -1,
'enabled' => 1,
'position' => 60,
'notnull' => -1,
'cssview' =>
'small',
'csslist' =>
'small tdoverflowmax200'),
122 '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'),
123 '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'),
124 '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'),
125 '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'),
126 '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),
127 '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' =>
''),
128 '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'),
129 'password' => array(
'type' =>
'password',
'label' =>
'Password',
'visible' => -1,
'enabled' =>
"1",
'position' => 103,
'notnull' => -1,
'comment' =>
"IMAP password",
'help' =>
'WithGMailYouCanCreateADedicatedPassword'),
130 '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'),
131 '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, ...'),
132 'target_directory' => array(
'type' =>
'varchar(255)',
'label' =>
'MailboxTargetDirectory',
'visible' => 1,
'enabled' => 1,
'position' => 110,
'notnull' => 0,
'csslist' =>
'tdoverflowmax100',
'help' =>
"EmailCollectorTargetDir"),
133 'maxemailpercollect' => array(
'type' =>
'integer',
'label' =>
'MaxEmailCollectPerCollect',
'visible' => -1,
'enabled' => 1,
'position' => 111,
'default' => 50),
134 'datelastresult' => array(
'type' =>
'datetime',
'label' =>
'DateLastCollectResult',
'visible' => 1,
'enabled' =>
'$action != "create" && $action != "edit"',
'position' => 121,
'notnull' => -1,
'csslist' =>
'nowraponall'),
135 'codelastresult' => array(
'type' =>
'varchar(16)',
'label' =>
'CodeLastResult',
'visible' => 1,
'enabled' =>
'$action != "create" && $action != "edit"',
'position' => 122,
'notnull' => -1,),
136 'lastresult' => array(
'type' =>
'varchar(255)',
'label' =>
'LastResult',
'visible' => 1,
'enabled' =>
'$action != "create" && $action != "edit"',
'position' => 123,
'notnull' => -1,
'cssview' =>
'small',
'csslist' =>
'small tdoverflowmax200'),
137 'datelastok' => array(
'type' =>
'datetime',
'label' =>
'DateLastcollectResultOk',
'visible' => 1,
'enabled' =>
'$action != "create"',
'position' => 125,
'notnull' => -1,
'csslist' =>
'nowraponall'),
138 'note_public' => array(
'type' =>
'html',
'label' =>
'NotePublic',
'visible' => 0,
'enabled' => 1,
'position' => 61,
'notnull' => -1,),
139 'note_private' => array(
'type' =>
'html',
'label' =>
'NotePrivate',
'visible' => 0,
'enabled' => 1,
'position' => 62,
'notnull' => -1,),
140 'date_creation' => array(
'type' =>
'datetime',
'label' =>
'DateCreation',
'visible' => -2,
'enabled' => 1,
'position' => 500,
'notnull' => 1,),
141 'tms' => array(
'type' =>
'timestamp',
'label' =>
'DateModification',
'visible' => -2,
'enabled' => 1,
'position' => 501,
'notnull' => 1,),
143 'fk_user_creat' => array(
'type' =>
'integer:User:user/class/user.class.php',
'label' =>
'UserAuthor',
'visible' => -2,
'enabled' => 1,
'position' => 510,
'notnull' => 1,),
144 'fk_user_modif' => array(
'type' =>
'integer:User:user/class/user.class.php',
'label' =>
'UserModif',
'visible' => -2,
'enabled' => 1,
'position' => 511,
'notnull' => -1,),
146 'import_key' => array(
'type' =>
'varchar(14)',
'label' =>
'ImportId',
'visible' => -2,
'enabled' => 1,
'position' => 1000,
'notnull' => -1,),
147 'status' => array(
'type' =>
'integer',
'label' =>
'Status',
'visible' => 1,
'enabled' => 1,
'position' => 1000,
'notnull' => 1,
'default' =>
'0',
'index' => 1,
'arrayofkeyval' => array(
'0' =>
'Inactive',
'1' =>
'Active'))
184 public $fk_user_creat;
189 public $fk_user_modif;
202 public $oauth_service;
203 public $imap_encryption;
205 public $source_directory;
206 public $target_directory;
207 public $maxemailpercollect;
212 public $datelastresult;
214 public $codelastresult;
224 const STATUS_DISABLED = 0;
225 const STATUS_ENABLED = 1;
235 global $conf, $langs;
239 $this->ismultientitymanaged = 1;
240 $this->isextrafieldmanaged = 0;
243 $this->fields[
'rowid'][
'visible'] = 0;
245 if (!isModEnabled(
'multicompany') && isset($this->fields[
'entity'])) {
246 $this->fields[
'entity'][
'enabled'] = 0;
250 $oauthservices = array();
252 foreach ($conf->global as $key => $val) {
253 if (!empty($val) && preg_match(
'/^OAUTH_.*_ID$/', $key)) {
254 $key = preg_replace(
'/^OAUTH_/',
'', $key);
255 $key = preg_replace(
'/_ID$/',
'', $key);
256 if (preg_match(
'/^.*-/', $key)) {
257 $name = preg_replace(
'/^.*-/',
'', $key);
259 $name = $langs->trans(
"NoName");
261 $provider = preg_replace(
'/-.*$/',
'', $key);
262 $provider = ucfirst(strtolower($provider));
264 $oauthservices[$key] = $name.
" (".$provider.
")";
268 $this->fields[
'oauth_service'][
'arrayofkeyval'] = $oauthservices;
271 foreach ($this->fields as $key => $val) {
272 if (isset($val[
'enabled']) && empty($val[
'enabled'])) {
273 unset($this->fields[$key]);
278 foreach ($this->fields as $key => $val) {
279 if (!empty($val[
'arrayofkeyval']) && is_array($val[
'arrayofkeyval'])) {
280 foreach ($val[
'arrayofkeyval'] as $key2 => $val2) {
281 $this->fields[$key][
'arrayofkeyval'][$key2] = $langs->trans($val2);
299 if ($this->host && preg_match(
'/^http:/i', trim($this->host))) {
300 $langs->load(
"errors");
301 $this->error = $langs->trans(
"ErrorHostMustNotStartWithHttp", $this->host);
305 include_once DOL_DOCUMENT_ROOT.
'/core/lib/security.lib.php';
306 $this->password =
dolEncrypt($this->password);
310 $this->password =
dolDecrypt($this->password);
312 if (is_array($this->filters) && count($this->filters)) {
315 foreach ($this->filters as $filter) {
316 $emailcollectorfilter->type = $filter[
'type'];
317 $emailcollectorfilter->rulevalue = $filter[
'rulevalue'];
318 $emailcollectorfilter->fk_emailcollector = $this->id;
319 $emailcollectorfilter->status = $filter[
'status'];
321 $emailcollectorfilter->create($user);
325 if (is_array($this->actions) && count($this->actions)) {
328 foreach ($this->actions as $operation) {
329 $emailcollectoroperation->type = $operation[
'type'];
330 $emailcollectoroperation->actionparam = $operation[
'actionparam'];
331 $emailcollectoroperation->fk_emailcollector = $this->id;
332 $emailcollectoroperation->status = $operation[
'status'];
333 $emailcollectoroperation->position = $operation[
'position'];
335 $emailcollectoroperation->create($user);
351 global $langs, $extrafields;
372 unset(
$object->codelastresult);
373 unset(
$object->datelastresult);
378 $object->ref =
"copy_of_".$object->ref;
381 $object->host =
'imap.example.com';
384 if (is_array(
$object->array_options) && count(
$object->array_options) > 0) {
385 $extrafields->fetch_name_optionals_label($this->table_element);
386 foreach (
$object->array_options as $key => $option) {
387 $shortkey = preg_replace(
'/options_/',
'', $key);
388 if (!empty($extrafields->attributes[$this->element][
'unique'][$shortkey])) {
390 unset(
$object->array_options[$key]);
396 $object->context[
'createfromclone'] =
'createfromclone';
397 $result =
$object->create($user);
401 $this->errors =
$object->errors;
404 unset(
$object->context[
'createfromclone']);
411 $this->db->rollback();
423 public function fetch($id, $ref =
null)
427 include_once DOL_DOCUMENT_ROOT.
'/core/lib/security.lib.php';
428 $this->password =
dolDecrypt($this->password);
461 public function fetchAll(
User $user, $activeOnly = 0, $sortfield =
's.rowid', $sortorder =
'ASC', $limit = 100, $page = 0)
467 $sql =
"SELECT s.rowid";
468 $sql .=
" FROM ".MAIN_DB_PREFIX.
"emailcollector_emailcollector as s";
469 $sql .=
' WHERE s.entity IN ('.getEntity(
'emailcollector').
')';
471 $sql .=
" AND s.status = 1";
473 $sql .= $this->db->order($sortfield, $sortorder);
478 $offset = $limit * $page;
480 $sql .= $this->db->plimit($limit + 1, $offset);
483 $result = $this->db->query($sql);
485 $num = $this->db->num_rows($result);
488 $obj = $this->db->fetch_object($result);
490 if ($emailcollector_static->fetch($obj->rowid)) {
491 $obj_ret[] = $emailcollector_static;
496 $this->errors[] =
'EmailCollector::fetchAll Error when retrieve emailcollector list';
497 dol_syslog(
'EmailCollector::fetchAll Error when retrieve emailcollector list', LOG_ERR);
500 if (!count($obj_ret)) {
501 dol_syslog(
'EmailCollector::fetchAll No emailcollector found', LOG_DEBUG);
519 if ($this->host && preg_match(
'/^http:/i', trim($this->host))) {
520 $langs->load(
"errors");
521 $this->error = $langs->trans(
"ErrorHostMustNotStartWithHttp", $this->host);
525 include_once DOL_DOCUMENT_ROOT.
'/core/lib/security.lib.php';
526 $this->password =
dolEncrypt($this->password);
530 $this->password =
dolDecrypt($this->password);
542 public function delete(
User $user, $notrigger = 0)
557 public function getNomUrl($withpicto = 0, $option =
'', $notooltip = 0, $morecss =
'', $save_lastsearch_value = -1)
559 global $conf, $langs, $action, $hookmanager;
561 if (!empty($conf->dol_no_mouse_hover)) {
567 $label =
'<u>'.$langs->trans(
"EmailCollector").
'</u>';
569 $label .=
'<b>'.$langs->trans(
'Ref').
':</b> '.$this->ref;
571 $url = DOL_URL_ROOT.
'/admin/emailcollector_card.php?id='.$this->id;
573 if ($option !=
'nolink') {
575 $add_save_lastsearch_values = ($save_lastsearch_value == 1 ? 1 : 0);
576 if ($save_lastsearch_value == -1 && isset($_SERVER[
"PHP_SELF"]) && preg_match(
'/list\.php/', $_SERVER[
"PHP_SELF"])) {
577 $add_save_lastsearch_values = 1;
579 if ($add_save_lastsearch_values) {
580 $url .=
'&save_lastsearch_values=1';
585 if (empty($notooltip)) {
587 $label = $langs->trans(
"ShowEmailCollector");
588 $linkclose .=
' alt="'.dol_escape_htmltag($label, 1).
'"';
590 $linkclose .=
' title="'.dol_escape_htmltag($label, 1).
'"';
591 $linkclose .=
' class="classfortooltip'.($morecss ?
' '.$morecss :
'').
'"';
593 $linkclose = ($morecss ?
' class="'.$morecss.
'"' :
'');
596 $linkstart =
'<a href="'.$url.
'"';
597 $linkstart .= $linkclose.
'>';
600 $result .= $linkstart;
602 $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);
604 if ($withpicto != 2) {
605 $result .= $this->ref;
610 $hookmanager->initHooks(array(
'emailcollectordao'));
611 $parameters = array(
'id' => $this->
id,
'getnomurl' => &$result);
612 $reshook = $hookmanager->executeHooks(
'getNomUrl', $parameters, $this, $action);
614 $result = $hookmanager->resPrint;
616 $result .= $hookmanager->resPrint;
644 if (empty($this->labelStatus) || empty($this->labelStatusShort)) {
647 $this->labelStatus[self::STATUS_ENABLED] = $langs->transnoentitiesnoconv(
'Enabled');
648 $this->labelStatus[self::STATUS_DISABLED] = $langs->transnoentitiesnoconv(
'Disabled');
649 $this->labelStatusShort[self::STATUS_ENABLED] = $langs->transnoentitiesnoconv(
'Enabled');
650 $this->labelStatusShort[self::STATUS_DISABLED] = $langs->transnoentitiesnoconv(
'Disabled');
653 $statusType =
'status5';
654 if ($status == self::STATUS_ENABLED) {
655 $statusType =
'status4';
658 return dolGetStatus($this->labelStatus[$status], $this->labelStatusShort[$status],
'', $statusType, $mode);
669 $sql =
'SELECT rowid, date_creation as datec, tms as datem,';
670 $sql .=
' fk_user_creat, fk_user_modif';
671 $sql .=
' FROM '.MAIN_DB_PREFIX.$this->table_element.
' as t';
672 $sql .=
' WHERE t.rowid = '.((int) $id);
673 $result = $this->db->query($sql);
675 if ($this->db->num_rows($result)) {
676 $obj = $this->db->fetch_object($result);
678 $this->
id = $obj->rowid;
680 $this->user_creation_id = $obj->fk_user_creat;
681 $this->user_modification_id = $obj->fk_user_modif;
682 $this->date_creation = $this->db->jdate($obj->datec);
683 $this->date_modification = empty($obj->datem) ?
'' : $this->db->jdate($obj->datem);
686 $this->db->free($result);
700 $this->host =
'localhost';
701 $this->login =
'alogin';
714 $this->filters = array();
716 $sql =
'SELECT rowid, type, rulevalue, status';
717 $sql .=
' FROM '.MAIN_DB_PREFIX.
'emailcollector_emailcollectorfilter';
718 $sql .=
' WHERE fk_emailcollector = '.((int) $this->
id);
721 $resql = $this->db->query($sql);
723 $num = $this->db->num_rows($resql);
726 $obj = $this->db->fetch_object($resql);
727 $this->filters[$obj->rowid] = array(
'id' => $obj->rowid,
'type' => $obj->type,
'rulevalue' => $obj->rulevalue,
'status' => $obj->status);
730 $this->db->free($resql);
746 $this->actions = array();
748 $sql =
'SELECT rowid, type, actionparam, status';
749 $sql .=
' FROM '.MAIN_DB_PREFIX.
'emailcollector_emailcollectoraction';
750 $sql .=
' WHERE fk_emailcollector = '.((int) $this->
id);
751 $sql .=
' ORDER BY position';
753 $resql = $this->db->query($sql);
755 $num = $this->db->num_rows($resql);
758 $obj = $this->db->fetch_object($resql);
759 $this->actions[$obj->rowid] = array(
'id' => $obj->rowid,
'type' => $obj->type,
'actionparam' => $obj->actionparam,
'status' => $obj->status);
762 $this->db->free($resql);
781 $flags =
'/service=imap';
784 } elseif (empty($this->imap_encryption) || ($this->imap_encryption ==
'ssl' &&
getDolGlobalString(
'IMAP_FORCE_NOSSL'))) {
787 $flags .=
'/' . $this->imap_encryption;
790 $flags .=
'/novalidate-cert';
797 if (!empty($this->login) && strpos($this->login,
'/') !=
false) {
798 $partofauth = explode(
'/', $this->login);
799 $flags .=
'/authuser='.$partofauth[0].
'/user='.$partofauth[1];
802 $connectstringserver =
'{'.$this->host.
':'.$this->port.$flags.
'}';
804 return $connectstringserver;
815 if (function_exists(
'mb_convert_encoding')) {
817 $str = preg_replace(
"/ /",
"xxxSPACExxx", $str);
818 $str = preg_replace(
"/\[Gmail\]/",
"xxxGMAILxxx", $str);
820 if ($str = mb_convert_encoding($str,
"UTF-7")) {
822 $str = preg_replace(
"/\+A/",
"&A", $str);
824 $str = preg_replace(
"/xxxSPACExxx/",
" ", $str);
826 $str = preg_replace(
"/xxxGMAILxxx/",
"[Gmail]", $str);
830 $this->error =
"error: is not possible to encode this string '".$str.
"'";
850 $arrayofcollectors = $this->
fetchAll($user, 1);
853 foreach ($arrayofcollectors as $emailcollector) {
854 $result = $emailcollector->doCollectOneCollector(0);
855 dol_syslog(
"doCollect result = ".$result.
" for emailcollector->id = ".$emailcollector->id);
857 $this->error .=
'EmailCollector ID '.$emailcollector->id.
':'.$emailcollector->error.
'<br>';
858 if (!empty($emailcollector->errors)) {
859 $this->error .= implode(
'<br>', $emailcollector->errors);
861 $this->output .=
'EmailCollector ID '.$emailcollector->id.
': '.$emailcollector->lastresult.
'<br>';
880 global $conf, $langs;
882 $errorforthisaction = 0;
885 $outputlangs = $langs;
888 $newlang =
GETPOST(
'lang_id',
'aZ09');
891 $newlang = !empty(
$object->thirdparty->default_lang) ?
$object->thirdparty->default_lang : $newlang;
893 if (!empty($newlang)) {
895 $outputlangs->setDefaultLang($newlang);
905 foreach ($arrayvaluetouse as $propertytooverwrite => $valueforproperty) {
908 $tmparray = explode(
'.', $propertytooverwrite);
909 if (count($tmparray) == 2) {
910 $tmpclass = $tmparray[0];
911 $tmpproperty = $tmparray[1];
913 $tmpproperty = $tmparray[0];
915 if ($tmpclass && ($tmpclass !=
$object->element)) {
925 $regforregex = array();
926 if (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*):([^:])$/', $valueforproperty, $regforregex)) {
927 $sourcefield = $regforregex[1];
928 $regexstring = $regforregex[2];
930 } elseif (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*)$/', $valueforproperty, $regforregex)) {
931 $sourcefield = $regforregex[1];
932 $regexstring = $regforregex[2];
935 if (!empty($sourcefield) && !empty($regexstring)) {
936 if (strtolower($sourcefield) ==
'body') {
937 $sourcestring = $messagetext;
938 } elseif (strtolower($sourcefield) ==
'subject') {
939 $sourcestring = $subject;
940 } elseif (strtolower($sourcefield) ==
'header') {
941 $sourcestring = $header;
945 $regforval = array();
947 if (strtolower($sourcefield) ==
'body') {
948 $regexoptions =
'ms';
950 if (strtolower($sourcefield) ==
'header') {
955 if (preg_match(
'/'.$regexstring.
'/'.$regexoptions, $sourcestring, $regforval)) {
957 $valueextracted = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) :
null;
958 if (strtolower($sourcefield) ==
'header') {
959 if (preg_match(
'/^options_/', $tmpproperty)) {
962 if (property_exists(
$object, $tmpproperty)) {
969 if (preg_match(
'/^options_/', $tmpproperty)) {
972 if (property_exists(
$object, $tmpproperty)) {
979 if (preg_match(
'/^options_/', $tmpproperty)) {
980 $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));
982 if (property_exists(
$object, $tmpproperty)) {
990 if (property_exists(
$object, $tmpproperty)) {
993 $tmp[$tmpproperty] =
null;
996 $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.';
1000 $errorforthisaction++;
1001 $this->error =
'The extract rule to use to overwrite properties has on an unknown source (must be HEADER, SUBJECT or BODY)';
1002 $this->errors[] = $this->error;
1004 $operationslog .=
'<br>'.$this->error;
1006 } elseif (preg_match(
'/^(SET|SETIFEMPTY):(.*)$/', $valueforproperty, $regforregex)) {
1008 if (preg_match(
'/^options_/', $tmpproperty)) {
1009 $valuecurrent =
$object->array_options[preg_replace(
'/^options_/',
'', $tmpproperty)];
1011 if (property_exists(
$object, $tmpproperty)) {
1012 $valuecurrent =
$object->$tmpproperty;
1014 $valuecurrent = $tmp[$tmpproperty];
1018 if ($regforregex[1] ==
'SET' || empty($valuecurrent)) {
1019 $valuetouse = $regforregex[2];
1022 $matcharray = array();
1023 preg_match_all(
'/__([a-z0-9]+(?:_[a-z0-9]+)?)__/i', $valuetouse, $matcharray);
1025 if (is_array($matcharray[1])) {
1026 foreach ($matcharray[1] as $keytoreplace) {
1027 if ($keytoreplace) {
1028 if (preg_match(
'/^options_/', $keytoreplace)) {
1029 $substitutionarray[
'__'.$keytoreplace.
'__'] =
$object->array_options[preg_replace(
'/^options_/',
'', $keytoreplace)];
1031 if (property_exists(
$object, $keytoreplace)) {
1032 $substitutionarray[
'__'.$keytoreplace.
'__'] =
$object->$keytoreplace;
1034 $substitutionarray[
'__'.$keytoreplace.
'__'] = $tmp[$keytoreplace];
1044 if (preg_match(
'/^options_/', $tmpproperty)) {
1045 $object->array_options[preg_replace(
'/^options_/',
'', $tmpproperty)] = $valuetouse;
1047 $operationslog .=
'<br>Set value '.dol_escape_htmltag($valuetouse).
' into object->array_options['.
dol_escape_htmltag(preg_replace(
'/^options_/',
'', $tmpproperty)).
']';
1049 if (property_exists(
$object, $tmpproperty)) {
1050 $object->$tmpproperty = $valuetouse;
1052 $tmp[$tmpproperty] = $valuetouse;
1055 $operationslog .=
'<br>Set value '.dol_escape_htmltag($valuetouse).
' into object->'.
dol_escape_htmltag($tmpproperty);
1059 $errorforthisaction++;
1060 $this->error =
'Bad syntax for description of action parameters: '.$actionparam;
1061 $this->errors[] = $this->error;
1066 return $errorforthisaction;
1075 public function doCollectOneCollector($mode = 0)
1077 global $db, $conf, $langs, $user;
1078 global $hookmanager;
1082 require_once DOL_DOCUMENT_ROOT.
'/comm/action/class/actioncomm.class.php';
1084 require_once DOL_DOCUMENT_ROOT.
'/includes/webklex/php-imap/vendor/autoload.php';
1087 dol_syslog(
"EmailCollector::doCollectOneCollector start for id=".$this->
id.
" - ".$this->
ref, LOG_INFO);
1089 $langs->loadLangs(array(
"project",
"companies",
"mails",
"errors",
"ticket",
"agenda",
"commercial"));
1094 $this->debuginfo =
'';
1098 $searchfilterdoltrackid = 0;
1099 $searchfilternodoltrackid = 0;
1100 $searchfilterisanswer = 0;
1101 $searchfilterisnotanswer = 0;
1102 $searchfilterreplyto = 0;
1103 $searchfilterexcludebodyarray = array();
1104 $searchfilterexcludesubjectarray = array();
1105 $operationslog =
'';
1106 $rulesreplyto = array();
1110 if (empty($this->host)) {
1111 $this->error = $langs->trans(
'ErrorFieldRequired', $langs->transnoentitiesnoconv(
'EMailHost'));
1114 if (empty($this->login)) {
1115 $this->error = $langs->trans(
'ErrorFieldRequired', $langs->transnoentitiesnoconv(
'Login'));
1118 if (empty($this->source_directory)) {
1119 $this->error = $langs->trans(
'ErrorFieldRequired', $langs->transnoentitiesnoconv(
'MailboxSourceDirectory'));
1123 $sourcedir = $this->source_directory;
1124 $targetdir = ($this->target_directory ? $this->target_directory :
'');
1129 $sourcedir = $this->source_directory;
1130 $targetdir = ($this->target_directory ? $this->target_directory :
'');
1133 if ($this->acces_type == 1) {
1135 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=1, access_type=1 (OAUTH2)<br>';
1137 require_once DOL_DOCUMENT_ROOT.
'/core/lib/oauth.lib.php';
1141 $keyforsupportedoauth2array = $this->oauth_service;
1142 if (preg_match(
'/^.*-/', $keyforsupportedoauth2array)) {
1143 $keyforprovider = preg_replace(
'/^.*-/',
'', $keyforsupportedoauth2array);
1145 $keyforprovider =
'';
1147 $keyforsupportedoauth2array = preg_replace(
'/-.*$/',
'', $keyforsupportedoauth2array);
1148 $keyforsupportedoauth2array =
'OAUTH_'.$keyforsupportedoauth2array.
'_NAME';
1150 $OAUTH_SERVICENAME =
'Unknown';
1151 if (array_key_exists($keyforsupportedoauth2array, $supportedoauth2array)
1152 && array_key_exists(
'name', $supportedoauth2array[$keyforsupportedoauth2array])
1153 && !empty($supportedoauth2array[$keyforsupportedoauth2array][
'name'])) {
1154 $OAUTH_SERVICENAME = $supportedoauth2array[$keyforsupportedoauth2array][
'name'].(!empty($keyforprovider) ?
'-'.$keyforprovider :
'');
1157 require_once DOL_DOCUMENT_ROOT.
'/includes/OAuth/bootstrap.php';
1163 $storage =
new DoliStorage($db, $conf, $keyforprovider);
1166 $tokenobj = $storage->retrieveAccessToken($OAUTH_SERVICENAME);
1175 if (is_object($tokenobj) && $expire) {
1176 $this->debuginfo .=
'Refresh token '.$OAUTH_SERVICENAME.
'<br>';
1177 $credentials =
new Credentials(
1182 $serviceFactory = new \OAuth\ServiceFactory();
1183 $oauthname = explode(
'-', $OAUTH_SERVICENAME);
1185 $apiService = $serviceFactory->createService($oauthname[0], $credentials, $storage, array());
1186 '@phan-var-force OAuth\OAuth2\Service\AbstractService|OAuth\OAuth1\Service\AbstractService $apiService';
1188 $refreshtoken = $tokenobj->getRefreshToken();
1189 $tokenobj = $apiService->refreshAccessToken($tokenobj);
1190 $tokenobj->setRefreshToken($refreshtoken);
1191 $storage->storeAccessToken($OAUTH_SERVICENAME, $tokenobj);
1193 $tokenobj = $storage->retrieveAccessToken($OAUTH_SERVICENAME);
1194 if (is_object($tokenobj)) {
1195 $token = $tokenobj->getAccessToken();
1197 $this->error =
"Token not found";
1202 $this->error = $e->getMessage();
1203 dol_syslog(
"CMailFile::sendfile: mail end error=".$this->error, LOG_ERR);
1207 $cm =
new ClientManager();
1208 $client = $cm->make([
1209 'host' => $this->host,
1210 'port' => $this->port,
1211 'encryption' => !empty($this->imap_encryption) ? $this->imap_encryption : false,
1212 'validate_cert' => true,
1213 'protocol' =>
'imap',
1214 'username' => $this->login,
1215 'password' => $token,
1216 'authentication' =>
"oauth",
1220 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=1, access_type=0 (LOGIN)<br>';
1222 $cm =
new ClientManager();
1223 $client = $cm->make([
1224 'host' => $this->host,
1225 'port' => $this->port,
1226 'encryption' => !empty($this->imap_encryption) ? $this->imap_encryption : false,
1227 'validate_cert' => true,
1228 'protocol' =>
'imap',
1229 'username' => $this->login,
1230 'password' => $this->password,
1231 'authentication' =>
"login",
1237 }
catch (ConnectionFailedException $e) {
1238 $this->error = $e->getMessage();
1239 $this->errors[] = $this->error;
1240 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1244 $host = dol_getprefix(
'email');
1247 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=0 (native PHP imap, LOGIN)<br>';
1249 if (!function_exists(
'imap_open')) {
1250 $this->error =
'IMAP function not enabled on your PHP';
1256 $connectstringsource = $connectstringserver.$this->getEncodedUtf7($sourcedir);
1257 $connectstringtarget = $connectstringserver.$this->getEncodedUtf7($targetdir);
1259 $connectstringsource = $connectstringserver.$sourcedir;
1260 $connectstringtarget = $connectstringserver.$targetdir;
1263 $this->debuginfo .=
'connectstringsource = '.$connectstringsource.
', $connectstringtarget='.$connectstringtarget.
'<br>';
1265 $connection = imap_open($connectstringsource, $this->login, $this->password);
1267 $this->error =
'Failed to open IMAP connection '.$connectstringsource.
' '.imap_last_error();
1272 $host = dol_getprefix(
'email');
1283 $criteria = array(array(
'UNDELETED'));
1284 foreach ($this->filters as $rule) {
1285 if (empty($rule[
'status'])) {
1290 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1294 $rule[
'rulevalue'] = substr($rule[
'rulevalue'], 1);
1297 if ($rule[
'type'] ==
'from') {
1298 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1299 if (count($tmprulevaluearray) >= 2) {
1300 foreach ($tmprulevaluearray as $tmprulevalue) {
1301 array_push($criteria, array($not.
"FROM" => $tmprulevalue));
1304 array_push($criteria, array($not.
"FROM" => $rule[
'rulevalue']));
1307 if ($rule[
'type'] ==
'to') {
1308 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1309 if (count($tmprulevaluearray) >= 2) {
1310 foreach ($tmprulevaluearray as $tmprulevalue) {
1311 array_push($criteria, array($not.
"TO" => $tmprulevalue));
1314 array_push($criteria, array($not.
"TO" => $rule[
'rulevalue']));
1317 if ($rule[
'type'] ==
'bcc') {
1318 array_push($criteria, array($not.
"BCC" => $rule[
'rulevalue']));
1320 if ($rule[
'type'] ==
'cc') {
1321 array_push($criteria, array($not.
"CC" => $rule[
'rulevalue']));
1323 if ($rule[
'type'] ==
'subject') {
1324 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1326 $searchfilterexcludesubjectarray[] = preg_replace(
'/^!/',
'', $rule[
'rulevalue']);
1328 array_push($criteria, array(
"SUBJECT" => $rule[
'rulevalue']));
1331 if ($rule[
'type'] ==
'body') {
1332 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1334 $searchfilterexcludebodyarray[] = preg_replace(
'/^!/',
'', $rule[
'rulevalue']);
1336 array_push($criteria, array(
"BODY" => $rule[
'rulevalue']));
1339 if ($rule[
'type'] ==
'header') {
1340 array_push($criteria, array($not.
"HEADER" => $rule[
'rulevalue']));
1352 if ($rule[
'type'] ==
'seen') {
1353 array_push($criteria, array($not.
"SEEN"));
1355 if ($rule[
'type'] ==
'unseen') {
1356 array_push($criteria, array($not.
"UNSEEN"));
1358 if ($rule[
'type'] ==
'unanswered') {
1359 array_push($criteria, array($not.
"UNANSWERED"));
1361 if ($rule[
'type'] ==
'answered') {
1362 array_push($criteria, array($not.
"ANSWERED"));
1364 if ($rule[
'type'] ==
'smaller') {
1365 array_push($criteria, array($not.
"SMALLER"));
1367 if ($rule[
'type'] ==
'larger') {
1368 array_push($criteria, array($not.
"LARGER"));
1372 if ($rule[
'type'] ==
'withtrackingidinmsgid') {
1373 $searchfilterdoltrackid++;
1374 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1376 if ($rule[
'type'] ==
'withouttrackingidinmsgid') {
1377 $searchfilterdoltrackid++;
1378 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1380 if ($rule[
'type'] ==
'withtrackingid') {
1381 $searchfilterdoltrackid++;
1382 $searchhead .=
'/References.*@'.preg_quote($host,
'/').
'/';
1384 if ($rule[
'type'] ==
'withouttrackingid') {
1385 $searchfilternodoltrackid++;
1386 $searchhead .=
'! /References.*@'.preg_quote($host,
'/').
'/';
1389 if ($rule[
'type'] ==
'isanswer') {
1390 $searchfilterisanswer++;
1391 $searchhead .=
'/References.*@.*/';
1393 if ($rule[
'type'] ==
'isnotanswer') {
1394 $searchfilterisnotanswer++;
1395 $searchhead .=
'! /References.*@.*/';
1398 if ($rule[
'type'] ==
'replyto') {
1399 $searchfilterreplyto++;
1400 $rulesreplyto[] = $rule[
'rulevalue'];
1401 $searchhead .=
'/Reply-To.*'.preg_quote($rule[
'rulevalue'],
'/').
'/';
1405 if (empty($targetdir) || !
getDolGlobalString(
'EMAILCOLLECTOR_NO_FILTER_ON_DATE_IF_THERE_IS_A_TARGETDIR')) {
1407 if ($this->datelastok) {
1408 $fromdate = $this->datelastok;
1410 if ($fromdate > 0) {
1412 array_push($criteria, array(
"SINCE" => date(
'j-M-Y', $fromdate - 1)));
1417 dol_syslog(
"IMAP search string = ".var_export($criteria,
true));
1418 $search = var_export($criteria,
true);
1421 $search =
'UNDELETED';
1422 foreach ($this->filters as $rule) {
1423 if (empty($rule[
'status'])) {
1431 if (!empty($rule[
'rulevalue']) && strpos($rule[
'rulevalue'],
'!') === 0) {
1435 $rule[
'rulevalue'] = substr($rule[
'rulevalue'], 1);
1438 if ($rule[
'type'] ==
'from') {
1439 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1440 if (count($tmprulevaluearray) >= 2) {
1441 foreach ($tmprulevaluearray as $tmprulevalue) {
1442 $search .= ($search ?
' ' :
'').$not.
'FROM "'.str_replace(
'"',
'', $tmprulevalue).
'"';
1445 $search .= ($search ?
' ' :
'').$not.
'FROM "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1448 if ($rule[
'type'] ==
'to') {
1449 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1450 if (count($tmprulevaluearray) >= 2) {
1451 foreach ($tmprulevaluearray as $tmprulevalue) {
1452 $search .= ($search ?
' ' :
'').$not.
'TO "'.str_replace(
'"',
'', $tmprulevalue).
'"';
1455 $search .= ($search ?
' ' :
'').$not.
'TO "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1458 if ($rule[
'type'] ==
'bcc') {
1459 $search .= ($search ?
' ' :
'').$not.
'BCC';
1461 if ($rule[
'type'] ==
'cc') {
1462 $search .= ($search ?
' ' :
'').$not.
'CC';
1464 if ($rule[
'type'] ==
'subject') {
1467 $searchfilterexcludesubjectarray[] = $rule[
'rulevalue'];
1469 $search .= ($search ?
' ' :
'').
'SUBJECT "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1472 if ($rule[
'type'] ==
'body') {
1475 $searchfilterexcludebodyarray[] = $rule[
'rulevalue'];
1478 $search .= ($search ?
' ' :
'').
'BODY "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1481 if ($rule[
'type'] ==
'header') {
1482 $search .= ($search ?
' ' :
'').$not.
'HEADER '.$rule[
'rulevalue'];
1494 if ($rule[
'type'] ==
'seen') {
1495 $search .= ($search ?
' ' :
'').$not.
'SEEN';
1497 if ($rule[
'type'] ==
'unseen') {
1498 $search .= ($search ?
' ' :
'').$not.
'UNSEEN';
1500 if ($rule[
'type'] ==
'unanswered') {
1501 $search .= ($search ?
' ' :
'').$not.
'UNANSWERED';
1503 if ($rule[
'type'] ==
'answered') {
1504 $search .= ($search ?
' ' :
'').$not.
'ANSWERED';
1506 if ($rule[
'type'] ==
'smaller') {
1507 $search .= ($search ?
' ' :
'').$not.
'SMALLER "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1509 if ($rule[
'type'] ==
'larger') {
1510 $search .= ($search ?
' ' :
'').$not.
'LARGER "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1514 if ($rule[
'type'] ==
'withtrackingidinmsgid') {
1515 $searchfilterdoltrackid++;
1516 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1518 if ($rule[
'type'] ==
'withouttrackingidinmsgid') {
1519 $searchfilterdoltrackid++;
1520 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1522 if ($rule[
'type'] ==
'withtrackingid') {
1523 $searchfilterdoltrackid++;
1524 $searchhead .=
'/References.*@'.preg_quote($host,
'/').
'/';
1526 if ($rule[
'type'] ==
'withouttrackingid') {
1527 $searchfilternodoltrackid++;
1528 $searchhead .=
'! /References.*@'.preg_quote($host,
'/').
'/';
1531 if ($rule[
'type'] ==
'isanswer') {
1532 $searchfilterisanswer++;
1533 $searchhead .=
'/References.*@.*/';
1535 if ($rule[
'type'] ==
'isnotanswer') {
1536 $searchfilterisnotanswer++;
1537 $searchhead .=
'! /References.*@.*/';
1540 if ($rule[
'type'] ==
'replyto') {
1541 $searchfilterreplyto++;
1542 $rulesreplyto[] = $rule[
'rulevalue'];
1543 $searchhead .=
'/Reply-To.*'.preg_quote($rule[
'rulevalue'],
'/').
'/';
1547 if (empty($targetdir)) {
1549 if ($this->datelastok) {
1550 $fromdate = $this->datelastok;
1552 if ($fromdate > 0) {
1553 $search .= ($search ?
' ' :
'').
'SINCE '.date(
'j-M-Y', $fromdate - 1);
1562 $nbemailprocessed = 0;
1565 $charset = ($this->hostcharset ? $this->hostcharset :
"UTF-8");
1572 $tmpsourcedir = $sourcedir;
1577 $f = $client->getFolders(
false, $tmpsourcedir);
1580 if ($folder instanceof Webklex\PHPIMAP\Folder) {
1581 $Query = $folder->messages()->where($criteria);
1584 $this->error =
"Source directory ".$sourcedir.
" not found";
1585 $this->errors[] = $this->error;
1586 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_WARNING);
1591 $this->error =
"Failed to execute getfolders";
1592 $this->errors[] = $this->error;
1593 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1596 }
catch (InvalidWhereQueryCriteriaException $e) {
1597 $this->error = $e->getMessage();
1598 $this->errors[] = $this->error;
1599 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1602 $this->error = $e->getMessage();
1603 $this->errors[] = $this->error;
1604 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1608 '@phan-var-force Webklex\PHPIMAP\Query\Query $Query';
1612 $Query->leaveUnread();
1614 $arrayofemail = $Query->limit($this->maxemailpercollect)->setFetchOrder(
"asc")->get();
1617 $this->error = $e->getMessage();
1618 $this->errors[] = $this->error;
1619 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1624 $arrayofemail = imap_search($connection, $search, SE_UID, $charset);
1626 if ($arrayofemail ===
false) {
1628 $mapoferrrors = imap_errors();
1629 if ($mapoferrrors !==
false) {
1631 $this->error =
"Search string not understood - ".implode(
',', $mapoferrrors);
1632 $this->errors[] = $this->error;
1637 $arrayofemailtodelete = array();
1640 if (!$error && !empty($arrayofemail) && count($arrayofemail) > 0) {
1657 dol_syslog(
"Start of loop on email", LOG_INFO, 1);
1659 $richarrayofemail = array();
1661 foreach ($arrayofemail as $imapemail) {
1662 if ($nbemailprocessed > 1000) {
1668 '@phan-var-force Webklex\PHPIMAP\Message $imapemail';
1669 $header = $imapemail->getHeader()->raw;
1670 $overview = $imapemail->getAttributes();
1672 $header = imap_fetchheader($connection, $imapemail, FT_UID);
1673 $overview = imap_fetch_overview($connection, $imapemail, FT_UID);
1676 $header = preg_replace(
'/\r\n\s+/m',
' ', $header);
1679 preg_match_all(
'/([^: ]+): (.+?(?:\r\n\s(?:.+?))*)\r\n/m', $header, $matches);
1680 $headers = array_combine($matches[1], $matches[2]);
1683 $richarrayofemail[] = array(
'imapemail' => $imapemail,
'header' => $header,
'headers' => $headers,
'overview' => $overview,
'date' => strtotime($headers[
'Date']));
1688 $richarrayofemail =
dol_sort_array($richarrayofemail,
'date',
'asc');
1692 foreach ($richarrayofemail as $tmpval) {
1695 $imapemail = $tmpval[
'imapemail'];
1696 $header = $tmpval[
'header'];
1697 $overview = $tmpval[
'overview'];
1698 $headers = $tmpval[
'headers'];
1700 if (!empty($headers[
'in-reply-to']) && empty($headers[
'In-Reply-To'])) {
1701 $headers[
'In-Reply-To'] = $headers[
'in-reply-to'];
1703 if (!empty($headers[
'references']) && empty($headers[
'References'])) {
1704 $headers[
'References'] = $headers[
'references'];
1706 if (!empty($headers[
'message-id']) && empty($headers[
'Message-ID'])) {
1707 $headers[
'Message-ID'] = $headers[
'message-id'];
1709 if (!empty($headers[
'subject']) && empty($headers[
'Subject'])) {
1710 $headers[
'Subject'] = $headers[
'subject'];
1716 $emailto = (string) $overview[
'to'];
1723 $operationslog .=
'<br>** Process email #'.dol_escape_htmltag($iforemailloop);
1727 '@phan-var-force Webklex\PHPIMAP\Message $imapemail';
1729 $msgid = str_replace(array(
'<',
'>'),
'', $overview[
'message_id']);
1731 $operationslog .=
" - ".dol_escape_htmltag((
string) $imapemail);
1732 $msgid = str_replace(array(
'<',
'>'),
'', $overview[0]->message_id);
1734 $operationslog .=
" - MsgId: ".$msgid;
1735 $operationslog .=
" - Date: ".($headers[
'Date'] ??
'');
1736 $operationslog .=
" - References: ".dol_escape_htmltag($headers[
'References'] ??
'').
" - Subject: ".
dol_escape_htmltag($headers[
'Subject']);
1738 dol_syslog(
"-- Process email #".$iforemailloop.
" MsgId: ".$msgid.
" Date: ".($headers[
'Date'] ??
'').
" References: ".($headers[
'References'] ??
'').
" Subject: ".$headers[
'Subject']);
1741 $trackidfoundintorecipienttype =
'';
1742 $trackidfoundintorecipientid = 0;
1747 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)) {
1748 $trackidfoundintorecipienttype = $reg[1];
1749 $trackidfoundintorecipientid = $reg[2];
1750 } elseif (preg_match(
'/\+emailing-(\w+)@/', $emailto, $reg)) {
1751 $trackidfoundintorecipienttype =
'emailing';
1752 $trackidfoundintorecipientid = $reg[1];
1755 $trackidfoundintomsgidtype =
'';
1756 $trackidfoundintomsgidid = 0;
1761 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)) {
1762 $trackidfoundintomsgidtype = $reg[1];
1763 $trackidfoundintomsgidid = $reg[2];
1764 } elseif (preg_match(
'/(?:[\+\-])emailing-(\w+)@/', $msgid, $reg)) {
1765 $trackidfoundintomsgidtype =
'emailing';
1766 $trackidfoundintomsgidid = $reg[1];
1770 if ($searchfilterdoltrackid > 0) {
1771 if (empty($trackidfoundintorecipienttype) && empty($trackidfoundintomsgidtype)) {
1772 if (empty($headers[
'References']) || !preg_match(
'/@'.preg_quote($host,
'/').
'/', $headers[
'References'])) {
1773 $nbemailprocessed++;
1774 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");
1779 if ($searchfilternodoltrackid > 0) {
1780 if (!empty($trackidfoundintorecipienttype) || !empty($trackidfoundintomsgidtype) || (!empty($headers[
'References']) && preg_match(
'/@'.preg_quote($host,
'/').
'/', $headers[
'References']))) {
1781 $nbemailprocessed++;
1782 dol_syslog(
" Discarded - Suffix found into email or Header References found and matching signature of application so with a trackid");
1787 if ($searchfilterisanswer > 0) {
1788 if (empty($headers[
'In-Reply-To'])) {
1789 $nbemailprocessed++;
1790 dol_syslog(
" Discarded - Email is not an answer (no In-Reply-To header)");
1794 if (preg_match(
'/^(Re|AW)\s*:\s+/i', $headers[
'Subject'])) {
1800 if (!empty($headers[
'In-Reply-To'])) {
1808 $nbemailprocessed++;
1809 dol_syslog(
" Discarded - Email is not an answer (no RE prefix in subject)");
1813 if ($searchfilterisnotanswer > 0) {
1814 if (!empty($headers[
'In-Reply-To'])) {
1818 if (preg_match(
'/Re\s*:\s+/i', $headers[
'Subject'])) {
1824 $nbemailprocessed++;
1825 dol_syslog(
" Discarded - Email is an answer");
1830 if ($searchfilterreplyto > 0) {
1831 if (!empty($headers[
'Reply-To'])) {
1833 foreach ($rulesreplyto as $key => $rulereplyto) {
1834 if (preg_match(
'/'.preg_quote($rulereplyto,
'/').
'/', $headers[
'Reply-To'])) {
1839 if (!$isreplytook || $isreplytook != count($rulesreplyto)) {
1840 $nbemailprocessed++;
1841 dol_syslog(
" Discarded - Reply-to does not match");
1849 $thirdpartystatic =
new Societe($this->db);
1850 $contactstatic =
new Contact($this->db);
1851 $projectstatic =
new Project($this->db);
1853 $nbactiondoneforemail = 0;
1855 $errorforactions = 0;
1856 $thirdpartyfoundby =
'';
1857 $contactfoundby =
'';
1858 $projectfoundby =
'';
1859 $ticketfoundby =
'';
1860 $candidaturefoundby =
'';
1864 dol_syslog(
"msgid=".$overview[
'message_id'].
" date=".
dol_print_date($overview[
'date'],
'dayrfc',
'gmt').
" from=".$overview[
'from'].
" to=".$overview[
'to'].
" subject=".$overview[
'subject']);
1869 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);
1879 global $htmlmsg, $plainmsg, $charset, $attachments;
1883 '@phan-var-force Webklex\PHPIMAP\Message $imapemail';
1884 if ($imapemail->hasHTMLBody()) {
1885 $htmlmsg = $imapemail->getHTMLBody();
1887 if ($imapemail->hasTextBody()) {
1888 $plainmsg = $imapemail->getTextBody();
1890 if ($imapemail->hasAttachments()) {
1891 $attachments = $imapemail->getAttachments()->all();
1896 $this->
getmsg($connection, $imapemail);
1898 '@phan-var-force Webklex\PHPIMAP\Attachment[] $attachments';
1910 $operationslog .=
'<br>Discarded - Email body is not valid utf8';
1911 dol_syslog(
" Discarded - Email body is not valid utf8");
1915 if (!empty($searchfilterexcludebodyarray)) {
1916 foreach ($searchfilterexcludebodyarray as $searchfilterexcludebody) {
1917 if (preg_match(
'/'.preg_quote($searchfilterexcludebody,
'/').
'/ms', $messagetext)) {
1918 $nbemailprocessed++;
1919 $operationslog .=
'<br>Discarded - Email body contains string '.$searchfilterexcludebody;
1920 dol_syslog(
" Discarded - Email body contains string ".$searchfilterexcludebody);
1982 $replytostring =
'';
1985 $fromstring = $overview[
'from'];
1986 $replytostring = empty($overview[
'in_reply-to']) ? $headers[
'Reply-To'] : $overview[
'in_reply-to'];
1988 $sender = $overview[
'sender'];
1989 $to = $overview[
'to'];
1990 $sendtocc = empty($overview[
'cc']) ?
'' : $overview[
'cc'];
1991 $sendtobcc = empty($overview[
'bcc']) ?
'' : $overview[
'bcc'];
1993 $tmpdate = $overview[
'date']->toDate();
1994 $tmptimezone = $tmpdate->getTimezone()->getName();
1997 if (preg_match(
'/^([+\-])(\d\d):(\d\d)/', $tmptimezone, $reg)) {
1998 if ($reg[1] ==
'+' && ($reg[2] !=
'00' || $reg[3] !=
'00')) {
1999 $dateemail -= (3600 * (int) $reg[2]);
2000 $dateemail -= (60 * (int) $reg[3]);
2002 if ($reg[1] ==
'-' && ($reg[2] !=
'00' || $reg[3] !=
'00')) {
2003 $dateemail += (3600 * (int) $reg[2]);
2004 $dateemail += (60 * (int) $reg[3]);
2007 $subject = $overview[
'subject'];
2009 $fromstring = $overview[0]->from;
2010 $replytostring = (!empty($overview[
'in_reply-to']) ? $overview[
'in_reply-to'] : (!empty($headers[
'Reply-To']) ? $headers[
'Reply-To'] :
"")) ;
2012 $sender = !empty($overview[0]->sender) ? $overview[0]->sender :
'';
2013 $to = $overview[0]->to;
2014 $sendtocc = !empty($overview[0]->cc) ? $overview[0]->cc :
'';
2015 $sendtobcc = !empty($overview[0]->bcc) ? $overview[0]->bcc :
'';
2017 $subject = $overview[0]->subject;
2021 if (!empty($searchfilterexcludesubjectarray)) {
2022 foreach ($searchfilterexcludesubjectarray as $searchfilterexcludesubject) {
2023 if (preg_match(
'/'.preg_quote($searchfilterexcludesubject,
'/').
'/ms', $subject)) {
2024 $nbemailprocessed++;
2025 $operationslog .=
'<br>Discarded - Email subject contains string '.$searchfilterexcludesubject;
2026 dol_syslog(
" Discarded - Email subject contains string ".$searchfilterexcludesubject);
2033 if (preg_match(
'/^(.*)<(.*)>$/', $fromstring, $reg)) {
2035 $fromtext = $reg[1];
2037 $from = $fromstring;
2040 if (preg_match(
'/^(.*)<(.*)>$/', $replytostring, $reg)) {
2042 $replytotext = $reg[1];
2044 $replyto = $replytostring;
2048 $fk_element_type =
'';
2065 $objectemail =
null;
2068 $arrayofreferences = array();
2069 if (!empty($headers[
'References'])) {
2070 $arrayofreferences = preg_split(
'/(,|\s+)/', $headers[
'References']);
2072 if (!in_array(
'<'.$msgid.
'>', $arrayofreferences)) {
2073 $arrayofreferences = array_merge($arrayofreferences, array(
'<'.$msgid.
'>'));
2078 foreach ($arrayofreferences as $reference) {
2080 if (!empty($trackidfoundintorecipienttype)) {
2081 $resultsearchtrackid = -1;
2082 $reg[1] = $trackidfoundintorecipienttype;
2083 $reg[2] = $trackidfoundintorecipientid;
2084 } elseif (!empty($trackidfoundintomsgidtype)) {
2085 $resultsearchtrackid = -1;
2086 $reg[1] = $trackidfoundintomsgidtype;
2087 $reg[2] = $trackidfoundintomsgidid;
2089 $resultsearchtrackid = preg_match(
'/dolibarr-([a-z]+)([0-9]+)@'.preg_quote($host,
'/').
'/', $reference, $reg);
2090 if (empty($resultsearchtrackid) &&
getDolGlobalString(
'EMAIL_ALTERNATIVE_HOST_SIGNATURE')) {
2091 $resultsearchtrackid = preg_match(
'/dolibarr-([a-z]+)([0-9]+)@'.preg_quote(
getDolGlobalString(
'EMAIL_ALTERNATIVE_HOST_SIGNATURE'),
'/').
'/', $reference, $reg);
2095 if (!empty($resultsearchtrackid)) {
2097 $trackid = $reg[1].$reg[2];
2099 $objectid = $reg[2];
2101 if ($reg[1] ==
'thi') {
2102 $objectemail =
new Societe($this->db);
2104 if ($reg[1] ==
'ctc') {
2105 $objectemail =
new Contact($this->db);
2107 if ($reg[1] ==
'inv') {
2108 $objectemail =
new Facture($this->db);
2110 if ($reg[1] ==
'sinv') {
2113 if ($reg[1] ==
'pro') {
2114 $objectemail =
new Propal($this->db);
2116 if ($reg[1] ==
'ord') {
2117 $objectemail =
new Commande($this->db);
2119 if ($reg[1] ==
'shi') {
2122 if ($reg[1] ==
'spro') {
2125 if ($reg[1] ==
'sord') {
2128 if ($reg[1] ==
'rec') {
2129 $objectemail =
new Reception($this->db);
2131 if ($reg[1] ==
'proj') {
2132 $objectemail =
new Project($this->db);
2133 $projectfoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2135 if ($reg[1] ==
'tas') {
2136 $objectemail =
new Task($this->db);
2138 if ($reg[1] ==
'con') {
2139 $objectemail =
new Contact($this->db);
2141 if ($reg[1] ==
'use') {
2142 $objectemail =
new User($this->db);
2144 if ($reg[1] ==
'tic') {
2145 $objectemail =
new Ticket($this->db);
2146 $ticketfoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2148 if ($reg[1] ==
'recruitmentcandidature') {
2150 $candidaturefoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2152 if ($reg[1] ==
'mem') {
2153 $objectemail =
new Adherent($this->db);
2161 } elseif (preg_match(
'/<(.*@.*)>/', $reference, $reg)) {
2163 if (is_null($objectemail) && isModEnabled(
'ticket')) {
2164 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"ticket";
2165 $sql .=
" WHERE email_msgid = '".$this->db->escape($reg[1]).
"' OR origin_references like '%".$this->db->escape($this->db->escapeforlike($reg[1])).
"%'";
2166 $resql = $this->db->query($sql);
2168 $obj = $this->db->fetch_object($resql);
2170 $objectid = $obj->rowid;
2171 $objectemail =
new Ticket($this->db);
2172 $ticketfoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2179 if (!is_object($objectemail) && isModEnabled(
'project')) {
2180 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"projet where email_msgid = '".$this->db->escape($reg[1]).
"'";
2181 $resql = $this->db->query($sql);
2183 $obj = $this->db->fetch_object($resql);
2185 $objectid = $obj->rowid;
2186 $objectemail =
new Project($this->db);
2187 $projectfoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2194 if (!is_object($objectemail) && isModEnabled(
'recruitment')) {
2195 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"recruitment_recruitmentcandidature where email_msgid = '".$this->db->escape($reg[1]).
"'";
2196 $resql = $this->db->query($sql);
2198 $obj = $this->db->fetch_object($resql);
2200 $objectid = $obj->rowid;
2202 $candidaturefoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2211 if (is_object($objectemail)) {
2212 $result = $objectemail->fetch($objectid);
2214 $fk_element_id = $objectemail->id;
2215 $fk_element_type = $objectemail->element;
2217 if ($fk_element_type ==
'facture') {
2218 $fk_element_type =
'invoice';
2221 if (get_class($objectemail) !=
'Societe') {
2222 $thirdpartyid = $objectemail->fk_soc ?? $objectemail->socid;
2224 $thirdpartyid = $objectemail->id;
2227 if (get_class($objectemail) !=
'Contact') {
2228 $contactid = $objectemail->fk_socpeople;
2230 $contactid = $objectemail->id;
2233 if (get_class($objectemail) !=
'Project') {
2234 $projectid = isset($objectemail->fk_project) ? $objectemail->fk_project : $objectemail->fk_projet;
2236 $projectid = $objectemail->id;
2239 if ($objectemail instanceof
Ticket) {
2240 $ticketid = $objectemail->id;
2242 $changeonticket_references =
false;
2243 if (empty($trackid)) {
2244 $trackid = $objectemail->track_id;
2246 if (empty($objectemail->origin_references)) {
2247 $objectemail->origin_references = $headers[
'References'];
2248 $changeonticket_references =
true;
2250 foreach ($arrayofreferences as $key => $referencetmp) {
2251 if (!str_contains($objectemail->origin_references, $referencetmp)) {
2252 $objectemail->origin_references .=
" ".$referencetmp;
2253 $changeonticket_references =
true;
2257 if ($changeonticket_references) {
2258 $objectemail->update($user, 1);
2265 if ($projectid > 0) {
2266 $result = $projectstatic->fetch($projectid);
2268 $projectstatic->id = 0;
2270 $projectid = $projectstatic->id;
2272 $projectfoundby =
'trackid ('.$trackid.
')';
2274 if (empty($contactid)) {
2275 $contactid = $projectstatic->fk_contact;
2277 if (empty($thirdpartyid)) {
2278 $thirdpartyid = $projectstatic->fk_soc;
2283 if ($contactid > 0) {
2284 $result = $contactstatic->fetch($contactid);
2286 $contactstatic->id = 0;
2288 $contactid = $contactstatic->id;
2290 $contactfoundby =
'trackid ('.$trackid.
')';
2292 if (empty($thirdpartyid)) {
2293 $thirdpartyid = $contactstatic->fk_soc;
2298 if ($thirdpartyid > 0) {
2299 $result = $thirdpartystatic->fetch($thirdpartyid);
2301 $thirdpartystatic->id = 0;
2303 $thirdpartyid = $thirdpartystatic->id;
2305 $thirdpartyfoundby =
'trackid ('.$trackid.
')';
2310 if (is_object($objectemail)) {
2315 if (empty($contactid)) {
2316 $result = $contactstatic->fetch(0,
null,
'', $from);
2319 dol_syslog(
"We found a contact with the email ".$from);
2320 $contactid = $contactstatic->id;
2321 $contactfoundby =
'email of contact ('.$from.
')';
2322 if (empty($thirdpartyid) && $contactstatic->socid > 0) {
2323 $result = $thirdpartystatic->fetch($contactstatic->socid);
2325 $thirdpartyid = $thirdpartystatic->id;
2326 $thirdpartyfoundby =
'email of contact ('.$from.
')';
2332 if (empty($thirdpartyid)) {
2333 $result = $thirdpartystatic->fetch(0,
'',
'',
'',
'',
'',
'',
'',
'',
'', $from);
2335 dol_syslog(
"We found a thirdparty with the email ".$from);
2336 $thirdpartyid = $thirdpartystatic->id;
2337 $thirdpartyfoundby =
'email ('.$from.
')';
2373 foreach ($this->actions as $operation) {
2374 $errorforthisaction = 0;
2375 $ticketalreadyexists = 0;
2376 if ($errorforactions) {
2379 if (empty($operation[
'status'])) {
2383 $operationslog .=
'<br>* Process operation '.$operation[
'type'];
2386 dol_syslog(
"Execute action ".$operation[
'type'].
" actionparam=".$operation[
'actionparam'].
' thirdpartystatic->id='.$thirdpartystatic->id.
' contactstatic->id='.$contactstatic->id.
' projectstatic->id='.$projectstatic->id);
2387 dol_syslog(
"Execute action fk_element_id=".$fk_element_id.
" fk_element_type=".$fk_element_type);
2390 $actioncode =
'EMAIL_IN';
2392 if (preg_match(
'/Sent$/', $sourcedir) || preg_match(
'/envoyés$/i', $sourcedir)) {
2393 $actioncode =
'EMAIL';
2396 $arrayofemailtoconsideresender = explode(
',',
getDolGlobalString(
'MAIL_FROM_EMAILS_TO_CONSIDER_SENDING'));
2397 foreach ($arrayofemailtoconsideresender as $emailtoconsidersender) {
2398 if (preg_match(
'/'.preg_quote($emailtoconsidersender,
'/').
'/', $fromstring)) {
2399 $actioncode =
'EMAIL';
2402 $operationslog .=
'<br>Email will have actioncode='.$actioncode;
2404 $description = $descriptiontitle = $descriptionmeta = $descriptionfull =
'';
2406 $descriptiontitle = $langs->transnoentitiesnoconv(
"RecordCreatedByEmailCollector", $this->
ref);
2411 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailFrom").($langs->trans(
"MailFrom") !=
'From' ?
' (From)' :
'').
' : '.
dol_escape_htmltag($fromstring));
2413 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"Sender").($langs->trans(
"Sender") !=
'Sender' ?
' (Sender)' :
'').
' : '.
dol_escape_htmltag($sender));
2415 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailTo").($langs->trans(
"MailTo") !=
'To' ?
' (To)' :
'').
' : '.
dol_escape_htmltag($to));
2417 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailReply").($langs->trans(
"MailReply") !=
'Reply to' ?
' (Reply to)' :
'').
' : '.
dol_escape_htmltag($replyto));
2420 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailCC").($langs->trans(
"MailCC") !=
'CC' ?
' (CC)' :
'').
' : '.
dol_escape_htmltag($sendtocc));
2423 if ($operation[
'type'] ==
'ticket') {
2425 $tickettocreate =
new Ticket($this->db);
2426 $errorfetchticket = 0;
2427 $alreadycreated = 0;
2428 if (!empty($trackid)) {
2429 $alreadycreated = $tickettocreate->fetch(0,
'', $trackid);
2431 if ($alreadycreated == 0 && !empty($msgid)) {
2432 $alreadycreated = $tickettocreate->fetch(0,
'',
'', $msgid);
2434 if ($alreadycreated < 0) {
2435 $errorfetchticket++;
2437 if (empty($errorfetchticket)) {
2438 if ($alreadycreated == 0) {
2439 $operationslog .=
'<br>Ticket not found using trackid='.$trackid.
' or msgid='.$msgid;
2440 $ticketalreadyexists = 0;
2442 $operationslog .=
'<br>Ticket already found using trackid='.$trackid.
' or msgid='.$msgid;
2443 $ticketalreadyexists = 1;
2444 $operation[
'type'] =
'recordevent';
2447 $ticketalreadyexists = -1;
2454 if ($operation[
'type'] ==
'loadthirdparty' || $operation[
'type'] ==
'loadandcreatethirdparty') {
2455 if (empty($operation[
'actionparam'])) {
2457 $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;";
2458 $this->errors[] = $this->error;
2460 $actionparam = $operation[
'actionparam'];
2461 $idtouseforthirdparty =
'';
2462 $nametouseforthirdparty =
'';
2463 $emailtouseforthirdparty =
'';
2464 $namealiastouseforthirdparty =
'';
2466 $operationslog .=
'<br>Loop on each property to set into actionparam';
2470 foreach ($arrayvaluetouse as $propertytooverwrite => $valueforproperty) {
2474 $regforregex = array();
2476 if (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*)$/', $valueforproperty, $regforregex)) {
2477 $sourcefield = $regforregex[1];
2478 $regexstring = $regforregex[2];
2481 if (!empty($sourcefield) && !empty($regexstring)) {
2482 if (strtolower($sourcefield) ==
'body') {
2483 $sourcestring = $messagetext;
2484 } elseif (strtolower($sourcefield) ==
'subject') {
2485 $sourcestring = $subject;
2486 } elseif (strtolower($sourcefield) ==
'header') {
2487 $sourcestring = $header;
2490 if ($sourcestring) {
2491 $regforval = array();
2493 if (preg_match(
'/'.$regexstring.
'/ms', $sourcestring, $regforval)) {
2496 if ($propertytooverwrite ==
'id') {
2497 $idtouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2499 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found idtouseforthirdparty='.
dol_escape_htmltag($idtouseforthirdparty);
2500 } elseif ($propertytooverwrite ==
'email') {
2501 $emailtouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2503 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found emailtouseforthirdparty='.
dol_escape_htmltag($emailtouseforthirdparty);
2504 } elseif ($propertytooverwrite ==
'name') {
2505 $nametouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2507 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found nametouseforthirdparty='.
dol_escape_htmltag($nametouseforthirdparty);
2508 } elseif ($propertytooverwrite ==
'name_alias') {
2509 $namealiastouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2511 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found namealiastouseforthirdparty='.
dol_escape_htmltag($namealiastouseforthirdparty);
2513 $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';
2517 if (in_array($propertytooverwrite, array(
'id',
'email',
'name',
'name_alias'))) {
2518 $idtouseforthirdparty =
null;
2519 $nametouseforthirdparty =
null;
2520 $emailtouseforthirdparty =
null;
2521 $namealiastouseforthirdparty =
null;
2523 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Not found. Property searched is critical so we cancel the search.';
2525 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Not found';
2532 $this->error =
'The extract rule to use to load thirdparty for email '.$msgid.
' has an unknown source (must be HEADER, SUBJECT or BODY)';
2533 $this->errors[] = $this->error;
2535 $operationslog .=
'<br>'.$this->error;
2537 } elseif (preg_match(
'/^(SET|SETIFEMPTY):(.*)$/', $valueforproperty, $reg)) {
2541 if ($propertytooverwrite ==
'id') {
2542 $idtouseforthirdparty = $reg[2];
2544 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property idtouseforthrdparty='.
dol_escape_htmltag($idtouseforthirdparty);
2545 } elseif ($propertytooverwrite ==
'email') {
2546 $emailtouseforthirdparty = $reg[2];
2548 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property emailtouseforthrdparty='.
dol_escape_htmltag($emailtouseforthirdparty);
2549 } elseif ($propertytooverwrite ==
'name') {
2550 $nametouseforthirdparty = $reg[2];
2552 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property nametouseforthirdparty='.
dol_escape_htmltag($nametouseforthirdparty);
2553 } elseif ($propertytooverwrite ==
'name_alias') {
2554 $namealiastouseforthirdparty = $reg[2];
2556 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property namealiastouseforthirdparty='.
dol_escape_htmltag($namealiastouseforthirdparty);
2560 $this->error =
'Bad syntax for description of action parameters: '.$actionparam;
2561 $this->errors[] = $this->error;
2566 if (!$errorforactions && ($idtouseforthirdparty || $emailtouseforthirdparty || $nametouseforthirdparty || $namealiastouseforthirdparty)) {
2568 $operationslog .=
'<br>We have this data to search thirdparty: id='.$idtouseforthirdparty.
', email='.$emailtouseforthirdparty.
', name='.$nametouseforthirdparty.
', name_alias='.$namealiastouseforthirdparty;
2571 $tmpobject->element =
'generic';
2572 $tmpobject->id = $idtouseforthirdparty;
2573 $tmpobject->name = $nametouseforthirdparty;
2574 $tmpobject->name_alias = $namealiastouseforthirdparty;
2575 $tmpobject->email = $emailtouseforthirdparty;
2579 $idtouseforthirdparty = $tmpobject->id;
2580 $nametouseforthirdparty = $tmpobject->name;
2581 $namealiastouseforthirdparty = $tmpobject->name_alias;
2582 $emailtouseforthirdparty = $tmpobject->email;
2584 $operationslog .=
'<br>We try to search existing thirdparty with '.$idtouseforthirdparty.
' '.$emailtouseforthirdparty.
' '.$nametouseforthirdparty.
' '.$namealiastouseforthirdparty;
2587 $result = $thirdpartystatic->findNearest($idtouseforthirdparty, $nametouseforthirdparty,
'',
'',
'',
'',
'',
'',
'',
'', $emailtouseforthirdparty, $namealiastouseforthirdparty);
2591 $this->error =
'Error when getting thirdparty with name '.$nametouseforthirdparty.
' (may be 2 record exists with same name ?)';
2592 $this->errors[] = $this->error;
2594 } elseif ($result == 0) {
2595 if ($operation[
'type'] ==
'loadthirdparty') {
2596 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was not found");
2599 $resultContact = $contactstatic->fetch(0,
'',
'', $emailtouseforthirdparty);
2600 if ($resultContact > 0) {
2601 $idtouseforthirdparty = $contactstatic->socid;
2602 $result = $thirdpartystatic->fetch($idtouseforthirdparty);
2604 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was found thanks to linked contact search");
2607 $langs->load(
"errors");
2608 $this->error = $langs->trans(
'ErrorFailedToLoadThirdParty', $idtouseforthirdparty, $emailtouseforthirdparty, $nametouseforthirdparty, $namealiastouseforthirdparty);
2609 $this->errors[] = $this->error;
2613 $langs->load(
"errors");
2614 $this->error = $langs->trans(
'ErrorFailedToLoadThirdParty', $idtouseforthirdparty, $emailtouseforthirdparty, $nametouseforthirdparty, $namealiastouseforthirdparty);
2615 $this->errors[] = $this->error;
2617 } elseif ($operation[
'type'] ==
'loadandcreatethirdparty') {
2618 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was not found. We try to create it.");
2621 $thirdpartystatic =
new Societe($db);
2622 $thirdpartystatic->name = $nametouseforthirdparty;
2623 if (!empty($namealiastouseforthirdparty)) {
2624 if ($namealiastouseforthirdparty != $nametouseforthirdparty) {
2625 $thirdpartystatic->name_alias = $namealiastouseforthirdparty;
2628 $thirdpartystatic->name_alias = (empty($replytostring) ? (empty($fromtext) ?
'' : $fromtext) : $replytostring);
2630 $thirdpartystatic->email = (empty($emailtouseforthirdparty) ? (empty($replyto) ? (empty($from) ?
'' : $from) : $replyto) : $emailtouseforthirdparty);
2633 $errorforthisaction = $this->
overwritePropertiesOfObject($thirdpartystatic, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2635 if ($thirdpartystatic->client && empty($thirdpartystatic->code_client)) {
2636 $thirdpartystatic->code_client =
'auto';
2638 if ($thirdpartystatic->fournisseur && empty($thirdpartystatic->code_fournisseur)) {
2639 $thirdpartystatic->code_fournisseur =
'auto';
2642 if ($errorforthisaction) {
2645 $result = $thirdpartystatic->create($user);
2648 $this->error = $thirdpartystatic->error;
2649 $this->errors = $thirdpartystatic->errors;
2651 $operationslog .=
'<br>Thirdparty created -> id = '.dol_escape_htmltag($thirdpartystatic->id);
2656 dol_syslog(
"One and only one existing third party has been found");
2658 $thirdpartystatic->fetch($result);
2660 $operationslog .=
'<br>Thirdparty already exists with id = '.dol_escape_htmltag($thirdpartystatic->id);
2664 } elseif ($operation[
'type'] ==
'loadandcreatecontact') {
2665 if (empty($operation[
'actionparam'])) {
2667 $this->error =
"Action loadandcreatecontact has empty parameter. Must be 'SET:xxx' or 'EXTRACT:(body|subject):regex' to define how to extract data";
2668 $this->errors[] = $this->error;
2670 $contact_static =
new Contact($this->db);
2672 $errorforthisaction = $this->
overwritePropertiesOfObject($contact_static, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2673 if ($errorforthisaction) {
2676 if (!empty($contact_static->email) && $contact_static->email != $from) {
2677 $from = $contact_static->email;
2680 $result = $contactstatic->fetch(0,
null,
'', $from);
2683 $this->error =
'Error when getting contact with email ' . $from;
2684 $this->errors[] = $this->error;
2686 } elseif ($result == 0) {
2687 dol_syslog(
"Contact with email " . $from .
" was not found. We try to create it.");
2688 $contactstatic =
new Contact($this->db);
2691 $contactstatic->email = $from;
2692 $operationslog .=
'<br>We set property email='.dol_escape_htmltag($from);
2695 $errorforthisaction = $this->
overwritePropertiesOfObject($contactstatic, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2697 if ($errorforthisaction) {
2701 if (!empty($contactstatic->country)) {
2702 require_once DOL_DOCUMENT_ROOT .
'/core/lib/company.lib.php';
2703 $result =
getCountry(
'', 3, $this->db,
null, 1, $contactstatic->country);
2704 if ($result ==
'NotDefined') {
2706 $this->error =
"Error country not found by this name '" . $contactstatic->country .
"'";
2707 } elseif (!($result > 0)) {
2709 $this->error =
"Error when search country by this name '" . $contactstatic->country .
"'";
2710 $this->errors[] = $this->db->lasterror();
2712 $contactstatic->country_id = $result;
2713 $operationslog .=
'<br>We set property country_id='.dol_escape_htmltag($result);
2715 } elseif (!empty($contactstatic->country_code)) {
2716 require_once DOL_DOCUMENT_ROOT .
'/core/lib/company.lib.php';
2717 $result =
getCountry($contactstatic->country_code, 3, $this->db);
2718 if ($result ==
'NotDefined') {
2720 $this->error =
"Error country not found by this code '" . $contactstatic->country_code .
"'";
2721 } elseif (!($result > 0)) {
2723 $this->error =
"Error when search country by this code '" . $contactstatic->country_code .
"'";
2724 $this->errors[] = $this->db->lasterror();
2726 $contactstatic->country_id = $result;
2727 $operationslog .=
'<br>We set property country_id='.dol_escape_htmltag($result);
2731 if (!$errorforactions) {
2733 if (!empty($contactstatic->state)) {
2734 require_once DOL_DOCUMENT_ROOT .
'/core/lib/functions.lib.php';
2735 $result =
dol_getIdFromCode($this->db, $contactstatic->state,
'c_departements',
'nom',
'rowid');
2736 if (empty($result)) {
2738 $this->error =
"Error state not found by this name '" . $contactstatic->state .
"'";
2739 } elseif (!($result > 0)) {
2741 $this->error =
"Error when search state by this name '" . $contactstatic->state .
"'";
2742 $this->errors[] = $this->db->lasterror();
2744 $contactstatic->state_id = $result;
2745 $operationslog .=
'<br>We set property state_id='.dol_escape_htmltag($result);
2747 } elseif (!empty($contactstatic->state_code)) {
2748 require_once DOL_DOCUMENT_ROOT .
'/core/lib/functions.lib.php';
2749 $result =
dol_getIdFromCode($this->db, $contactstatic->state_code,
'c_departements',
'code_departement',
'rowid');
2750 if (empty($result)) {
2752 $this->error =
"Error state not found by this code '" . $contactstatic->state_code .
"'";
2753 } elseif (!($result > 0)) {
2755 $this->error =
"Error when search state by this code '" . $contactstatic->state_code .
"'";
2756 $this->errors[] = $this->db->lasterror();
2758 $contactstatic->state_id = $result;
2759 $operationslog .=
'<br>We set property state_id='.dol_escape_htmltag($result);
2764 if (!$errorforactions) {
2765 $result = $contactstatic->create($user);
2768 $this->error = $contactstatic->error;
2769 $this->errors = $contactstatic->errors;
2771 $operationslog .=
'<br>Contact created -> id = '.dol_escape_htmltag($contactstatic->id);
2778 } elseif ($operation[
'type'] ==
'recordevent') {
2782 $alreadycreated = $actioncomm->fetch(0,
'',
'', $msgid);
2783 if ($alreadycreated == 0) {
2784 $operationslog .=
'<br>We did not find existing actionmail with msgid='.$msgid;
2786 if ($projectstatic->id > 0) {
2787 if ($projectfoundby) {
2788 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Project found from '.$projectfoundby);
2791 if ($thirdpartystatic->id > 0) {
2792 if ($thirdpartyfoundby) {
2793 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
2796 if ($contactstatic->id > 0) {
2797 if ($contactfoundby) {
2798 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
2802 $description = $descriptiontitle;
2808 $descriptionfull = $description;
2810 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
2815 $actioncomm->type_code =
'AC_OTH_AUTO';
2816 $actioncomm->code =
'AC_'.$actioncode;
2817 $actioncomm->label = $langs->trans(
"ActionAC_".$actioncode).
' - '.$langs->trans(
"MailFrom").
' '.$from;
2818 $actioncomm->note_private = $descriptionfull;
2819 $actioncomm->fk_project = $projectstatic->id;
2820 $actioncomm->datep = $dateemail;
2821 $actioncomm->datef = $dateemail;
2822 $actioncomm->percentage = -1;
2823 $actioncomm->socid = $thirdpartystatic->id;
2824 $actioncomm->contact_id = $contactstatic->id;
2825 $actioncomm->socpeopleassigned = (!empty($contactstatic->id) ? array($contactstatic->id) : array());
2826 $actioncomm->authorid = $user->id;
2827 $actioncomm->userownerid = $user->id;
2829 $actioncomm->email_msgid = $msgid;
2830 $actioncomm->email_from = $fromstring;
2831 $actioncomm->email_sender = $sender;
2832 $actioncomm->email_to = $to;
2833 $actioncomm->email_tocc = $sendtocc;
2834 $actioncomm->email_tobcc = $sendtobcc;
2835 $actioncomm->email_subject = $subject;
2836 $actioncomm->errors_to =
'';
2838 if (!in_array($fk_element_type, array(
'societe',
'contact',
'project',
'user'))) {
2839 $actioncomm->fk_element = $fk_element_id;
2840 $actioncomm->elementid = $fk_element_id;
2841 $actioncomm->elementtype = $fk_element_type;
2842 if (is_object($objectemail) && $objectemail->module) {
2843 $actioncomm->elementtype .=
'@'.$objectemail->module;
2850 $errorforthisaction = $this->
overwritePropertiesOfObject($actioncomm, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2852 if ($errorforthisaction) {
2855 $result = $actioncomm->create($user);
2858 $this->errors = $actioncomm->errors;
2860 if ($fk_element_type ==
"ticket" && is_object($objectemail)) {
2861 if ($objectemail->status == Ticket::STATUS_CLOSED || $objectemail->status == Ticket::STATUS_CANCELED) {
2862 if ($objectemail->fk_user_assign !=
null) {
2863 $res = $objectemail->setStatut(Ticket::STATUS_ASSIGNED);
2865 $res = $objectemail->setStatut(Ticket::STATUS_NOT_READ);
2869 $operationslog .=
'<br>Ticket Re-Opened successfully -> ref='.$objectemail->ref;
2872 $this->error =
'Error while changing the ticket status -> ref='.$objectemail->ref;
2873 $this->errors[] = $this->error;
2876 if (!empty($attachments)) {
2878 $ticket =
new Ticket($this->db);
2879 $ticket->fetch($fk_element_id);
2880 $destdir = $conf->ticket->dir_output.
'/'.$ticket->ref;
2885 foreach ($attachments as $attachment) {
2886 $attachment->save($destdir.
'/');
2889 $this->
getmsg($connection, $imapemail, $destdir);
2894 $operationslog .=
'<br>Event created -> id='.dol_escape_htmltag($actioncomm->id);
2898 } elseif ($operation[
'type'] ==
'recordjoinpiece') {
2901 foreach ($attachments as $attachment) {
2902 if ($attachment->getName() ===
'undefined') {
2905 $data[$attachment->getName()] = $attachment->getContent();
2909 foreach ($pj as $key => $val) {
2910 $data[$val[
'filename']] =
getFileData($imapemail, $val[
'pos'], $val[
'type'], $connection);
2913 if (count($data) > 0) {
2914 $sql =
"SELECT rowid as id FROM ".MAIN_DB_PREFIX.
"user WHERE email LIKE '%".$this->db->escape($from).
"%'";
2915 $resql = $this->db->query($sql);
2916 if ($this->db->num_rows($resql) == 0) {
2917 $this->errors[] =
"User Not allowed to add documents ({$from})";
2919 $arrayobject = array(
2920 'propale' => array(
'table' =>
'propal',
2921 'fields' => array(
'ref'),
2922 'class' =>
'comm/propal/class/propal.class.php',
2923 'object' =>
'Propal'),
2924 'holiday' => array(
'table' =>
'holiday',
2925 'fields' => array(
'ref'),
2926 'class' =>
'holiday/class/holiday.class.php',
2927 'object' =>
'Holiday'),
2928 'expensereport' => array(
'table' =>
'expensereport',
2929 'fields' => array(
'ref'),
2930 'class' =>
'expensereport/class/expensereport.class.php',
2931 'object' =>
'ExpenseReport'),
2932 'recruitment/recruitmentjobposition' => array(
'table' =>
'recruitment_recruitmentjobposition',
2933 'fields' => array(
'ref'),
2934 'class' =>
'recruitment/class/recruitmentjobposition.class.php',
2935 'object' =>
'RecruitmentJobPosition'),
2936 'recruitment/recruitmentcandidature' => array(
'table' =>
'recruitment_recruitmentcandidature',
2937 'fields' => array(
'ref'),
2938 'class' =>
'recruitment/class/recruitmentcandidature.class.php',
2939 'object' =>
' RecruitmentCandidature'),
2940 'societe' => array(
'table' =>
'societe',
2941 'fields' => array(
'code_client',
'code_fournisseur'),
2942 'class' =>
'societe/class/societe.class.php',
2943 'object' =>
'Societe'),
2944 'commande' => array(
'table' =>
'commande',
2945 'fields' => array(
'ref'),
2946 'class' =>
'commande/class/commande.class.php',
2947 'object' =>
'Commande'),
2948 'expedition' => array(
'table' =>
'expedition',
2949 'fields' => array(
'ref'),
2950 'class' =>
'expedition/class/expedition.class.php',
2951 'object' =>
'Expedition'),
2952 'contract' => array(
'table' =>
'contrat',
2953 'fields' => array(
'ref'),
2954 'class' =>
'contrat/class/contrat.class.php',
2955 'object' =>
'Contrat'),
2956 'fichinter' => array(
'table' =>
'fichinter',
2957 'fields' => array(
'ref'),
2958 'class' =>
'fichinter/class/fichinter.class.php',
2959 'object' =>
'Fichinter'),
2960 'ticket' => array(
'table' =>
'ticket',
2961 'fields' => array(
'ref'),
2962 'class' =>
'ticket/class/ticket.class.php',
2963 'object' =>
'Ticket'),
2964 'knowledgemanagement' => array(
'table' =>
'knowledgemanagement_knowledgerecord',
2965 'fields' => array(
'ref'),
2966 'class' =>
'knowledgemanagement/class/knowledgemanagement.class.php',
2967 'object' =>
'KnowledgeRecord'),
2968 'supplier_proposal' => array(
'table' =>
'supplier_proposal',
2969 'fields' => array(
'ref'),
2970 'class' =>
'supplier_proposal/class/supplier_proposal.class.php',
2971 'object' =>
'SupplierProposal'),
2972 'fournisseur/commande' => array(
'table' =>
'commande_fournisseur',
2973 'fields' => array(
'ref',
'ref_supplier'),
2974 'class' =>
'fourn/class/fournisseur.commande.class.php',
2975 'object' =>
'SupplierProposal'),
2976 'facture' => array(
'table' =>
'facture',
2977 'fields' => array(
'ref'),
2978 'class' =>
'compta/facture/class/facture.class.php',
2979 'object' =>
'Facture'),
2980 'fournisseur/facture' => array(
'table' =>
'facture_fourn',
2981 'fields' => array(
'ref',
'ref_client'),
2982 'class' =>
'fourn/class/fournisseur.facture.class.php',
2983 'object' =>
'FactureFournisseur'),
2984 'produit' => array(
'table' =>
'product',
2985 'fields' => array(
'ref'),
2986 'class' =>
'product/class/product.class.php',
2987 'object' =>
'Product'),
2988 'productlot' => array(
'table' =>
'product_lot',
2989 'fields' => array(
'batch'),
2990 'class' =>
'product/stock/class/productlot.class.php',
2991 'object' =>
'Productlot'),
2992 'projet' => array(
'table' =>
'projet',
2993 'fields' => array(
'ref'),
2994 'class' =>
'projet/class/projet.class.php',
2995 'object' =>
'Project'),
2996 'projet_task' => array(
'table' =>
'projet_task',
2997 'fields' => array(
'ref'),
2998 'class' =>
'projet/class/task.class.php',
2999 'object' =>
'Task'),
3000 'ressource' => array(
'table' =>
'resource',
3001 'fields' => array(
'ref'),
3002 'class' =>
'ressource/class/dolressource.class.php',
3003 'object' =>
'Dolresource'),
3004 'bom' => array(
'table' =>
'bom_bom',
3005 'fields' => array(
'ref'),
3006 'class' =>
'bom/class/bom.class.php',
3008 'mrp' => array(
'table' =>
'mrp_mo',
3009 'fields' => array(
'ref'),
3010 'class' =>
'mrp/class/mo.class.php',
3014 if (!is_object($hookmanager)) {
3015 include_once DOL_DOCUMENT_ROOT.
'/core/class/hookmanager.class.php';
3018 $hookmanager->initHooks(array(
'emailcolector'));
3019 $parameters = array(
'arrayobject' => $arrayobject);
3020 $reshook = $hookmanager->executeHooks(
'addmoduletoeamailcollectorjoinpiece', $parameters);
3022 $arrayobject = $hookmanager->resArray;
3025 $resultobj = array();
3027 foreach ($arrayobject as $key => $objectdesc) {
3028 $sql =
'SELECT DISTINCT t.rowid ';
3029 $sql .=
' FROM ' . MAIN_DB_PREFIX . $this->db->sanitize($objectdesc[
'table']) .
' AS t';
3031 foreach ($objectdesc[
'fields'] as $field) {
3032 $sql .=
"('" .$this->db->escape($subject) .
"' LIKE CONCAT('%', t." . $this->db->sanitize($field) .
", '%') AND t." . $this->db->sanitize($field) .
" <> '') OR ";
3034 $sql = substr($sql, 0, -4);
3036 $ressqlobj = $this->db->query($sql);
3038 while ($obj = $this->db->fetch_object($ressqlobj)) {
3039 $resultobj[$key][] = $obj->rowid;
3044 foreach ($resultobj as $mod => $ids) {
3045 $moddesc = $arrayobject[$mod];
3046 $elementpath = $mod;
3048 $objectmanaged =
new $moddesc[
'object']($this->db);
3049 foreach ($ids as $val) {
3050 $res = $objectmanaged->fetch($val);
3052 $path = ($objectmanaged->entity > 1 ?
"/" . $objectmanaged->entity :
'');
3053 $dirs[] = DOL_DATA_ROOT . $path .
"/" . $elementpath .
'/' .
dol_sanitizeFileName($objectmanaged->ref) .
'/';
3055 $this->errors[] =
'object not found';
3059 foreach ($dirs as $target) {
3060 $prefix = $this->actions[$this->id][
'actionparam'];
3061 foreach ($data as $filename => $content) {
3062 $resr =
saveAttachment($target, $prefix .
'_' . $filename, $content);
3064 $this->errors[] =
'Doc not saved';
3069 $operationslog .=
'<br>Save attachment files on disk';
3071 $this->errors[] =
'no joined piece';
3073 $operationslog .=
'<br>No joinded files';
3075 } elseif ($operation[
'type'] ==
'project') {
3077 $projecttocreate =
new Project($this->db);
3078 $alreadycreated = $projecttocreate->fetch(0,
'',
'', $msgid);
3079 if ($alreadycreated == 0) {
3080 if ($thirdpartystatic->id > 0) {
3081 $projecttocreate->socid = $thirdpartystatic->id;
3082 if ($thirdpartyfoundby) {
3083 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
3086 if ($contactstatic->id > 0) {
3087 $projecttocreate->contact_id = $contactstatic->id;
3088 if ($contactfoundby) {
3089 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
3093 $description = $descriptiontitle;
3099 $descriptionfull = $description;
3101 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3105 $id_opp_status =
dol_getIdFromCode($this->db,
'PROSP',
'c_lead_status',
'code',
'rowid');
3106 $percent_opp_status =
dol_getIdFromCode($this->db,
'PROSP',
'c_lead_status',
'code',
'percent');
3108 $projecttocreate->title = $subject;
3109 $projecttocreate->date_start = $dateemail;
3110 $projecttocreate->date_end = 0;
3111 $projecttocreate->opp_status = $id_opp_status;
3112 $projecttocreate->opp_percent = $percent_opp_status;
3114 $projecttocreate->note_private = $descriptionfull;
3115 $projecttocreate->entity = $conf->entity;
3117 $projecttocreate->email_date = $dateemail;
3118 $projecttocreate->email_msgid = $msgid;
3119 $projecttocreate->email_from = $fromstring;
3120 $projecttocreate->email_sender = $sender;
3121 $projecttocreate->email_to = $to;
3122 $projecttocreate->email_tocc = $sendtocc;
3123 $projecttocreate->email_tobcc = $sendtobcc;
3124 $projecttocreate->email_subject = $subject;
3125 $projecttocreate->errors_to =
'';
3127 $savesocid = $projecttocreate->socid;
3131 $errorforthisaction = $this->
overwritePropertiesOfObject($projecttocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3134 if (empty($projecttocreate->ref)) {
3143 $dirmodels = array_merge(array(
'/'), (array) $conf->modules_parts[
'models']);
3144 foreach ($dirmodels as $reldir) {
3145 $file =
dol_buildpath($reldir.
"core/modules/project/".$modele.
'.php', 0);
3146 if (file_exists($file)) {
3147 $classname = $modele;
3152 if ($classname !==
'') {
3153 if ($savesocid > 0) {
3154 if ($savesocid != $projecttocreate->socid) {
3156 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');
3159 if ($projecttocreate->socid > 0) {
3160 $thirdpartystatic->fetch($projecttocreate->socid);
3164 $result =
dol_include_once($reldir.
"core/modules/project/".$modele.
'.php');
3165 $modModuleToUseForNextValue =
new $classname();
3166 '@phan-var-force ModeleNumRefProjects $modModuleToUseForNextValue';
3167 $defaultref = $modModuleToUseForNextValue->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $projecttocreate);
3169 $projecttocreate->ref = $defaultref;
3173 if ($errorforthisaction) {
3176 if (empty($projecttocreate->ref) || (is_numeric($projecttocreate->ref) && $projecttocreate->ref <= 0)) {
3178 $this->error =
'Failed to create project: Can\'t get a valid value for the field ref with numbering template = '.$modele.
', thirdparty id = '.$thirdpartystatic->id;
3180 $operationslog .=
'<br>'.$this->error;
3183 $result = $projecttocreate->create($user);
3186 $this->error =
'Failed to create project: '.$langs->trans($projecttocreate->error);
3187 $this->errors = $projecttocreate->errors;
3189 $operationslog .=
'<br>'.$this->error;
3192 $destdir = $conf->project->dir_output.
'/'.$projecttocreate->ref;
3197 foreach ($attachments as $attachment) {
3199 $typeattachment = (string) $attachment->getDisposition();
3200 $filename = $attachment->getFilename();
3201 $content = $attachment->getContent();
3205 $this->
getmsg($connection, $imapemail, $destdir);
3208 $operationslog .=
'<br>Project created with attachments -> id='.dol_escape_htmltag($projecttocreate->id);
3210 $operationslog .=
'<br>Project created without attachments -> id='.dol_escape_htmltag($projecttocreate->id);
3218 $operationslog .=
'<br>Project already exists for msgid ='.dol_escape_htmltag($msgid);
3220 } elseif ($operation[
'type'] ==
'ticket') {
3222 $tickettocreate =
new Ticket($this->db);
3223 if ($ticketalreadyexists == 0) {
3224 if ($thirdpartystatic->id > 0) {
3225 $tickettocreate->socid = $thirdpartystatic->id;
3226 $tickettocreate->fk_soc = $thirdpartystatic->id;
3227 if ($thirdpartyfoundby) {
3228 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
3231 if ($contactstatic->id > 0) {
3232 $tickettocreate->contact_id = $contactstatic->id;
3233 if ($contactfoundby) {
3234 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
3238 $description = $descriptiontitle;
3244 $descriptionfull = $description;
3246 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3250 $tickettocreate->subject = $subject;
3251 $tickettocreate->message = $description;
3253 $tickettocreate->category_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_CATEGORY_CODE',
dol_getIdFromCode($this->db, 1,
'c_ticket_category',
'use_default',
'code', 1)));
3254 $tickettocreate->severity_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_SEVERITY_CODE',
dol_getIdFromCode($this->db, 1,
'c_ticket_severity',
'use_default',
'code', 1)));
3255 $tickettocreate->origin_email = $from;
3256 $tickettocreate->origin_replyto = (!empty($replyto) ? $replyto :
null);
3257 $tickettocreate->origin_references = (!empty($headers[
'References']) ? $headers[
'References'] :
null);
3258 $tickettocreate->fk_user_create = $user->id;
3259 $tickettocreate->datec =
dol_now();
3260 $tickettocreate->fk_project = $projectstatic->id;
3261 $tickettocreate->notify_tiers_at_create =
getDolGlobalInt(
'TICKET_CHECK_NOTIFY_THIRDPARTY_AT_CREATION');
3262 $tickettocreate->note_private = $descriptionfull;
3263 $tickettocreate->entity = $conf->entity;
3265 $tickettocreate->email_date = $dateemail;
3266 $tickettocreate->email_msgid = $msgid;
3267 $tickettocreate->email_from = $fromstring;
3268 $tickettocreate->email_sender = $sender;
3269 $tickettocreate->email_to = $to;
3270 $tickettocreate->email_tocc = $sendtocc;
3271 $tickettocreate->email_tobcc = $sendtobcc;
3272 $tickettocreate->email_subject = $subject;
3273 $tickettocreate->errors_to =
'';
3277 $savesocid = $tickettocreate->socid;
3281 $errorforthisaction = $this->
overwritePropertiesOfObject($tickettocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3284 if (empty($tickettocreate->ref)) {
3293 $dirmodels = array_merge(array(
'/'), (array) $conf->modules_parts[
'models']);
3294 foreach ($dirmodels as $reldir) {
3295 $file =
dol_buildpath($reldir.
"core/modules/ticket/".$modele.
'.php', 0);
3296 if (file_exists($file)) {
3297 $classname = $modele;
3302 if ($classname !==
'') {
3303 if ($savesocid > 0) {
3304 if ($savesocid != $tickettocreate->socid) {
3306 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');
3309 if ($tickettocreate->socid > 0) {
3310 $thirdpartystatic->fetch($tickettocreate->socid);
3315 $modModuleToUseForNextValue =
new $classname();
3316 '@phan-var-force ModeleNumRefTicket $modModuleToUseForNextValue';
3317 $defaultref = $modModuleToUseForNextValue->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $tickettocreate);
3319 $tickettocreate->ref = $defaultref;
3322 if ($errorforthisaction) {
3325 if (is_numeric($tickettocreate->ref) && $tickettocreate->ref <= 0) {
3327 $this->error =
'Failed to create ticket: Can\'t get a valid value for the field ref with numbering template = '.$modele.
', thirdparty id = '.$thirdpartystatic->id;
3330 $tickettocreate->context[
'actionmsg2'] = $langs->trans(
"ActionAC_EMAIL_IN").
' - '.$langs->trans(
"TICKET_CREATEInDolibarr");
3331 $tickettocreate->context[
'actionmsg'] = $langs->trans(
"ActionAC_EMAIL_IN").
' - '.$langs->trans(
"TICKET_CREATEInDolibarr");
3334 $result = $tickettocreate->create($user);
3337 $this->error =
'Failed to create ticket: '.$langs->trans($tickettocreate->error);
3338 $this->errors = $tickettocreate->errors;
3341 $destdir = $conf->ticket->dir_output.
'/'.$tickettocreate->ref;
3346 foreach ($attachments as $attachment) {
3348 $typeattachment = (string) $attachment->getDisposition();
3349 $filename = $attachment->getFilename();
3350 $content = $attachment->getContent();
3354 $this->
getmsg($connection, $imapemail, $destdir);
3357 $operationslog .=
'<br>Ticket created with attachments -> id='.dol_escape_htmltag($tickettocreate->id);
3359 $operationslog .=
'<br>Ticket created without attachments -> id='.dol_escape_htmltag($tickettocreate->id);
3365 } elseif ($operation[
'type'] ==
'candidature') {
3369 $alreadycreated = $candidaturetocreate->fetch(0,
'', $msgid);
3370 if ($alreadycreated == 0) {
3371 $description = $descriptiontitle;
3377 $descriptionfull = $description;
3378 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3381 $candidaturetocreate->subject = $subject;
3382 $candidaturetocreate->message = $description;
3383 $candidaturetocreate->type_code = 0;
3384 $candidaturetocreate->category_code =
null;
3385 $candidaturetocreate->severity_code =
null;
3386 $candidaturetocreate->email = $from;
3388 $candidaturetocreate->fk_user_creat = $user->id;
3389 $candidaturetocreate->date_creation =
dol_now();
3390 $candidaturetocreate->fk_project = $projectstatic->id;
3391 $candidaturetocreate->description = $description;
3392 $candidaturetocreate->note_private = $descriptionfull;
3393 $candidaturetocreate->entity = $conf->entity;
3394 $candidaturetocreate->email_msgid = $msgid;
3395 $candidaturetocreate->email_date = $dateemail;
3396 $candidaturetocreate->status = $candidaturetocreate::STATUS_DRAFT;
3401 $errorforthisaction = $this->
overwritePropertiesOfObject($candidaturetocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3443 if ($errorforthisaction) {
3447 $result = $candidaturetocreate->create($user);
3450 $this->error =
'Failed to create candidature: '.implode(
', ', $candidaturetocreate->errors);
3451 $this->errors = $candidaturetocreate->errors;
3454 $operationslog .=
'<br>Candidature created without attachments -> id='.dol_escape_htmltag($candidaturetocreate->id);
3457 } elseif (substr($operation[
'type'], 0, 4) ==
'hook') {
3460 if (!is_object($hookmanager)) {
3461 include_once DOL_DOCUMENT_ROOT.
'/core/class/hookmanager.class.php';
3463 $hookmanager->initHooks([
'emailcolector']);
3466 $parameters = array(
3467 'connection' => $connection,
3468 'imapemail' => $imapemail,
3469 'overview' => $overview,
3472 'fromtext' => $fromtext,
3474 'actionparam' => $operation[
'actionparam'],
3476 'thirdpartyid' => $thirdpartyid,
3477 'objectid' => $objectid,
3478 'objectemail' => $objectemail,
3480 'messagetext' => $messagetext,
3481 'subject' => $subject,
3482 'header' => $header,
3483 'attachments' => $attachments,
3485 $reshook = $hookmanager->executeHooks(
'doCollectImapOneCollector', $parameters, $this, $operation[
'type']);
3488 $errorforthisaction++;
3489 $this->error = $hookmanager->resPrint;
3491 if ($errorforthisaction) {
3493 $operationslog .=
'<br>Hook doCollectImapOneCollector executed with error';
3495 $operationslog .=
'<br>Hook doCollectImapOneCollector executed without error';
3499 if (!$errorforactions) {
3500 $nbactiondoneforemail++;
3506 if (!$errorforactions) {
3507 if (!empty($targetdir)) {
3510 dol_syslog(
"EmailCollector::doCollectOneCollector move message ".($imapemail->getHeader()->get(
'subject')).
" to ".$targetdir, LOG_DEBUG);
3511 $operationslog .=
'<br>Move mail '.($this->uidAsString($imapemail)).
' - '.$msgid.
' - '.$imapemail->getHeader()->get(
'subject').
' to '.$targetdir;
3513 $arrayofemailtodelete[$this->
uidAsString($imapemail)] = $imapemail;
3516 dol_syslog(
"EmailCollector::doCollectOneCollector move message ".($this->
uidAsString($imapemail)).
" to ".$connectstringtarget, LOG_DEBUG);
3517 $operationslog .=
'<br>Move mail '.($this->uidAsString($imapemail)).
' - '.$msgid;
3519 $arrayofemailtodelete[$imapemail] = $msgid;
3524 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);
3526 dol_syslog(
"EmailCollector::doCollectOneCollector message ".($this->
uidAsString($imapemail)).
" to ".$connectstringtarget.
" was set to read", LOG_DEBUG);
3534 unset($objectemail);
3535 unset($projectstatic);
3536 unset($thirdpartystatic);
3537 unset($contactstatic);
3539 $nbemailprocessed++;
3541 if (!$errorforemail) {
3542 $nbactiondone += $nbactiondoneforemail;
3546 $this->db->commit();
3548 $this->db->rollback();
3552 if ($this->maxemailpercollect > 0 && $nbemailok >= $this->maxemailpercollect) {
3553 dol_syslog(
"EmailCollect::doCollectOneCollector We reach maximum of ".$nbemailok.
" collected with success, so we stop this collector now.");
3559 $this->db->rollback();
3563 $output = $langs->trans(
'XEmailsDoneYActionsDone', $nbemailprocessed, $nbemailok, $nbactiondone);
3565 dol_syslog(
"End of loop on emails", LOG_INFO, -1);
3567 $langs->load(
"admin");
3568 $output = $langs->trans(
'NoNewEmailToProcess');
3569 $output .=
' (defaultlang='.$langs->defaultlang.
')';
3575 krsort($arrayofemailtodelete, SORT_NUMERIC);
3577 foreach ($arrayofemailtodelete as $imapemailnum => $imapemail) {
3578 dol_syslog(
"EmailCollect::doCollectOneCollector delete email ".$imapemailnum);
3580 $operationslog .=
"<br> move email ".$imapemailnum.($mode> 0 ?
' (test)' :
'');
3582 if (empty($mode) && empty($error)) {
3583 $tmptargetdir = $targetdir;
3590 $result = $imapemail->move($tmptargetdir,
false);
3593 $operationslog .=
'<br>Exception !!!! '.$e->getMessage();
3595 if (empty($result)) {
3596 dol_syslog(
"Failed to move email into target directory ".$targetdir);
3597 $operationslog .=
'<br>Failed to move email into target directory '.$targetdir;
3603 if (empty($mode) && empty($error)) {
3605 $operationslog .=
"<br>Expunge";
3610 $client->disconnect();
3612 foreach ($arrayofemailtodelete as $imapemail => $msgid) {
3613 dol_syslog(
"EmailCollect::doCollectOneCollector delete email ".$imapemail.
" ".$msgid);
3615 $operationslog .=
"<br> delete email ".$imapemail.
" ".$msgid.($mode> 0 ?
' (test)' :
'');
3617 if (empty($mode) && empty($error)) {
3618 $res = imap_mail_move($connection, $imapemail, $targetdir, CP_UID);
3621 $this->error = imap_last_error();
3622 $this->errors[] = $this->error;
3624 $operationslog .=
'<br>Error in move '.$this->error;
3631 if (empty($mode) && empty($error)) {
3633 $operationslog .=
"<br>Expunge";
3635 imap_expunge($connection);
3637 imap_close($connection);
3640 $this->datelastresult = $now;
3641 $this->lastresult = $output;
3643 $this->debuginfo .=
'IMAP search array used : '.$search;
3645 $this->debuginfo .=
'IMAP search string used : '.$search;
3648 $this->debuginfo .=
'<br>Then search string into email header : '.dol_escape_htmltag($searchhead);
3650 if ($operationslog) {
3651 $this->debuginfo .= $operationslog;
3654 if (empty($error) && empty($mode)) {
3655 $this->datelastok = $now;
3658 if (!empty($this->errors)) {
3659 $this->lastresult .=
"<br>".implode(
"<br>", $this->errors);
3661 $this->codelastresult = ($error ?
'KO' :
'OK');
3667 dol_syslog(
"EmailCollector::doCollectOneCollector end", LOG_INFO);
3669 return $error ? -1 : 1;
3684 private function getmsg($mbox, $mid, $destdir =
'')
3688 global $charset, $htmlmsg, $plainmsg, $attachments;
3689 $htmlmsg = $plainmsg = $charset =
'';
3690 $attachments = array();
3697 $s = imap_fetchstructure($mbox, $mid, FT_UID);
3702 $this->
getpart($mbox, $mid, $s, 0);
3705 foreach ($s->parts as $partno0 => $p) {
3706 $this->
getpart($mbox, $mid, $p, $partno0 + 1, $destdir);
3737 private function getpart($mbox, $mid, $p, $partno, $destdir =
'')
3740 global $htmlmsg, $plainmsg, $charset, $attachments;
3744 imap_fetchbody($mbox, $mid, $partno, FT_UID) :
3745 imap_body($mbox, $mid, FT_UID);
3747 if ($p->encoding == 4) {
3748 $data = quoted_printable_decode($data);
3749 } elseif ($p->encoding == 3) {
3750 $data = base64_decode($data);
3756 if ($p->parameters) {
3757 foreach ($p->parameters as $x) {
3758 $params[strtolower($x->attribute)] = $x->value;
3761 if (!empty($p->dparameters)) {
3762 foreach ($p->dparameters as $x) {
3763 $params[strtolower($x->attribute)] = $x->value;
3766 '@phan-var-force array{filename?:string,name?:string,charset?:string} $params';
3771 if (!empty($params[
'filename']) || !empty($params[
'name'])) {
3773 $filename = $params[
'filename'] ?? $params[
'name'];
3775 $attachments[$filename] = $data;
3777 if (strlen($destdir)) {
3778 if (substr($destdir, -1) !=
'/') {
3783 $file_name_complete = $filename;
3784 $destination = $destdir.$file_name_complete;
3787 $extension = pathinfo($file_name_complete, PATHINFO_EXTENSION);
3790 $file_name = pathinfo($file_name_complete, PATHINFO_FILENAME);
3793 $file_name_original = $file_name;
3802 while (file_exists($destdir.$file_name.
".".$extension)) {
3803 $file_name = $file_name_original .
' (' . $num .
')';
3804 $file_name_complete = $file_name .
"." . $extension;
3805 $destination = $destdir.$file_name_complete;
3811 file_put_contents($destination, $data);
3816 if ($p->type == 0 && $data) {
3817 if (!empty($params[
'charset'])) {
3822 if (strtolower($p->subtype) ==
'plain') {
3823 $plainmsg .= trim($data).
"\n\n";
3825 $htmlmsg .= $data.
"<br><br>";
3827 $charset = $params[
'charset'];
3828 } elseif ($p->type == 2 && $data) {
3834 if (!empty($params[
'charset'])) {
3837 $plainmsg .= $data.
"\n\n";
3841 if (!empty($p->parts)) {
3842 foreach ($p->parts as $partno0 => $p2) {
3843 $this->
getpart($mbox, $mid, $p2, $partno.
'.'.($partno0 + 1), $destdir);
3859 if (!$string || $fromEncoding == $toEncoding) {
3862 $convertedString = function_exists(
'iconv') ? @iconv($fromEncoding, $toEncoding.
'//IGNORE', $string) :
null;
3863 if (!$convertedString && extension_loaded(
'mbstring')) {
3864 $convertedString = @mb_convert_encoding($string, $toEncoding, $fromEncoding);
3866 if (!$convertedString) {
3867 throw new Exception(
'Mime string encoding conversion failed');
3869 return $convertedString;
3888 if (function_exists(
'imap_mime_header_decode') && function_exists(
'iconv_mime_decode')) {
3889 $elements = imap_mime_header_decode($subject);
3891 if (!empty($elements)) {
3892 $num = count($elements);
3893 for ($i = 0; $i < $num; $i++) {
3894 $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));
3895 $newstring .= $stringinutf8;
3897 $subject = $newstring;
3899 } elseif (!function_exists(
'mb_decode_mimeheader')) {
3900 $subject = mb_decode_mimeheader($subject);
3901 } elseif (function_exists(
'iconv_mime_decode')) {
3902 $subject = iconv_mime_decode($subject, ICONV_MIME_DECODE_CONTINUE_ON_ERROR,
'UTF-8');
3918 require_once DOL_DOCUMENT_ROOT .
'/core/lib/images.lib.php';
3921 $maxwidthsmall = $tmparraysize[
'maxwidthsmall'];
3922 $maxheightsmall = $tmparraysize[
'maxheightsmall'];
3923 $maxwidthmini = $tmparraysize[
'maxwidthmini'];
3924 $maxheightmini = $tmparraysize[
'maxheightmini'];
3925 $quality = $tmparraysize[
'quality'];
3927 file_put_contents($destdir.
'/'.$filename, $content);
3930 vignette($destdir.
'/'.$filename, $maxwidthsmall, $maxheightsmall,
'_small', $quality,
"thumbs");
3932 vignette($destdir.
'/'.$filename, $maxwidthmini, $maxheightmini,
'_mini', $quality,
"thumbs");
3945 if (is_object($imapemail)) {
3946 return $imapemail->getAttributes()[
"uid"];
3948 return (
string) $imapemail;