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<br>';
1177 $credentials =
new Credentials(
1182 $serviceFactory = new \OAuth\ServiceFactory();
1183 $oauthname = explode(
'-', $OAUTH_SERVICENAME);
1185 $apiService = $serviceFactory->createService($oauthname[0], $credentials, $storage, array());
1187 $refreshtoken = $tokenobj->getRefreshToken();
1188 $tokenobj = $apiService->refreshAccessToken($tokenobj);
1189 $tokenobj->setRefreshToken($refreshtoken);
1190 $storage->storeAccessToken($OAUTH_SERVICENAME, $tokenobj);
1192 $tokenobj = $storage->retrieveAccessToken($OAUTH_SERVICENAME);
1193 if (is_object($tokenobj)) {
1194 $token = $tokenobj->getAccessToken();
1196 $this->error =
"Token not found";
1201 $this->error = $e->getMessage();
1202 dol_syslog(
"CMailFile::sendfile: mail end error=".$this->error, LOG_ERR);
1206 $cm =
new ClientManager();
1207 $client = $cm->make([
1208 'host' => $this->host,
1209 'port' => $this->port,
1210 'encryption' => !empty($this->imap_encryption) ? $this->imap_encryption : false,
1211 'validate_cert' => true,
1212 'protocol' =>
'imap',
1213 'username' => $this->login,
1214 'password' => $token,
1215 'authentication' =>
"oauth",
1219 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=1, access_type=0 (LOGIN)<br>';
1221 $cm =
new ClientManager();
1222 $client = $cm->make([
1223 'host' => $this->host,
1224 'port' => $this->port,
1225 'encryption' => !empty($this->imap_encryption) ? $this->imap_encryption : false,
1226 'validate_cert' => true,
1227 'protocol' =>
'imap',
1228 'username' => $this->login,
1229 'password' => $this->password,
1230 'authentication' =>
"login",
1236 }
catch (ConnectionFailedException $e) {
1237 $this->error = $e->getMessage();
1238 $this->errors[] = $this->error;
1239 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1243 $host = dol_getprefix(
'email');
1246 $this->debuginfo .=
'doCollectOneCollector is using method MAIN_IMAP_USE_PHPIMAP=0 (native PHP imap, LOGIN)<br>';
1248 if (!function_exists(
'imap_open')) {
1249 $this->error =
'IMAP function not enabled on your PHP';
1255 $connectstringsource = $connectstringserver.$this->getEncodedUtf7($sourcedir);
1256 $connectstringtarget = $connectstringserver.$this->getEncodedUtf7($targetdir);
1258 $connectstringsource = $connectstringserver.$sourcedir;
1259 $connectstringtarget = $connectstringserver.$targetdir;
1262 $this->debuginfo .=
'connectstringsource = '.$connectstringsource.
', $connectstringtarget='.$connectstringtarget.
'<br>';
1264 $connection = imap_open($connectstringsource, $this->login, $this->password);
1266 $this->error =
'Failed to open IMAP connection '.$connectstringsource.
' '.imap_last_error();
1271 $host = dol_getprefix(
'email');
1282 $criteria = array(array(
'UNDELETED'));
1283 foreach ($this->filters as $rule) {
1284 if (empty($rule[
'status'])) {
1289 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1293 $rule[
'rulevalue'] = substr($rule[
'rulevalue'], 1);
1296 if ($rule[
'type'] ==
'from') {
1297 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1298 if (count($tmprulevaluearray) >= 2) {
1299 foreach ($tmprulevaluearray as $tmprulevalue) {
1300 array_push($criteria, array($not.
"FROM" => $tmprulevalue));
1303 array_push($criteria, array($not.
"FROM" => $rule[
'rulevalue']));
1306 if ($rule[
'type'] ==
'to') {
1307 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1308 if (count($tmprulevaluearray) >= 2) {
1309 foreach ($tmprulevaluearray as $tmprulevalue) {
1310 array_push($criteria, array($not.
"TO" => $tmprulevalue));
1313 array_push($criteria, array($not.
"TO" => $rule[
'rulevalue']));
1316 if ($rule[
'type'] ==
'bcc') {
1317 array_push($criteria, array($not.
"BCC" => $rule[
'rulevalue']));
1319 if ($rule[
'type'] ==
'cc') {
1320 array_push($criteria, array($not.
"CC" => $rule[
'rulevalue']));
1322 if ($rule[
'type'] ==
'subject') {
1323 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1325 $searchfilterexcludesubjectarray[] = preg_replace(
'/^!/',
'', $rule[
'rulevalue']);
1327 array_push($criteria, array(
"SUBJECT" => $rule[
'rulevalue']));
1330 if ($rule[
'type'] ==
'body') {
1331 if (strpos($rule[
'rulevalue'],
'!') === 0) {
1333 $searchfilterexcludebodyarray[] = preg_replace(
'/^!/',
'', $rule[
'rulevalue']);
1335 array_push($criteria, array(
"BODY" => $rule[
'rulevalue']));
1338 if ($rule[
'type'] ==
'header') {
1339 array_push($criteria, array($not.
"HEADER" => $rule[
'rulevalue']));
1351 if ($rule[
'type'] ==
'seen') {
1352 array_push($criteria, array($not.
"SEEN"));
1354 if ($rule[
'type'] ==
'unseen') {
1355 array_push($criteria, array($not.
"UNSEEN"));
1357 if ($rule[
'type'] ==
'unanswered') {
1358 array_push($criteria, array($not.
"UNANSWERED"));
1360 if ($rule[
'type'] ==
'answered') {
1361 array_push($criteria, array($not.
"ANSWERED"));
1363 if ($rule[
'type'] ==
'smaller') {
1364 array_push($criteria, array($not.
"SMALLER"));
1366 if ($rule[
'type'] ==
'larger') {
1367 array_push($criteria, array($not.
"LARGER"));
1371 if ($rule[
'type'] ==
'withtrackingidinmsgid') {
1372 $searchfilterdoltrackid++;
1373 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1375 if ($rule[
'type'] ==
'withouttrackingidinmsgid') {
1376 $searchfilterdoltrackid++;
1377 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1379 if ($rule[
'type'] ==
'withtrackingid') {
1380 $searchfilterdoltrackid++;
1381 $searchhead .=
'/References.*@'.preg_quote($host,
'/').
'/';
1383 if ($rule[
'type'] ==
'withouttrackingid') {
1384 $searchfilternodoltrackid++;
1385 $searchhead .=
'! /References.*@'.preg_quote($host,
'/').
'/';
1388 if ($rule[
'type'] ==
'isanswer') {
1389 $searchfilterisanswer++;
1390 $searchhead .=
'/References.*@.*/';
1392 if ($rule[
'type'] ==
'isnotanswer') {
1393 $searchfilterisnotanswer++;
1394 $searchhead .=
'! /References.*@.*/';
1397 if ($rule[
'type'] ==
'replyto') {
1398 $searchfilterreplyto++;
1399 $rulesreplyto[] = $rule[
'rulevalue'];
1400 $searchhead .=
'/Reply-To.*'.preg_quote($rule[
'rulevalue'],
'/').
'/';
1404 if (empty($targetdir)) {
1406 if ($this->datelastok) {
1407 $fromdate = $this->datelastok;
1409 if ($fromdate > 0) {
1411 array_push($criteria, array(
"SINCE" => date(
'j-M-Y', $fromdate - 1)));
1416 dol_syslog(
"IMAP search string = ".var_export($criteria,
true));
1417 $search = var_export($criteria,
true);
1420 $search =
'UNDELETED';
1421 foreach ($this->filters as $rule) {
1422 if (empty($rule[
'status'])) {
1430 if (!empty($rule[
'rulevalue']) && strpos($rule[
'rulevalue'],
'!') === 0) {
1434 $rule[
'rulevalue'] = substr($rule[
'rulevalue'], 1);
1437 if ($rule[
'type'] ==
'from') {
1438 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1439 if (count($tmprulevaluearray) >= 2) {
1440 foreach ($tmprulevaluearray as $tmprulevalue) {
1441 $search .= ($search ?
' ' :
'').$not.
'FROM "'.str_replace(
'"',
'', $tmprulevalue).
'"';
1444 $search .= ($search ?
' ' :
'').$not.
'FROM "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1447 if ($rule[
'type'] ==
'to') {
1448 $tmprulevaluearray = explode(
'*', $rule[
'rulevalue']);
1449 if (count($tmprulevaluearray) >= 2) {
1450 foreach ($tmprulevaluearray as $tmprulevalue) {
1451 $search .= ($search ?
' ' :
'').$not.
'TO "'.str_replace(
'"',
'', $tmprulevalue).
'"';
1454 $search .= ($search ?
' ' :
'').$not.
'TO "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1457 if ($rule[
'type'] ==
'bcc') {
1458 $search .= ($search ?
' ' :
'').$not.
'BCC';
1460 if ($rule[
'type'] ==
'cc') {
1461 $search .= ($search ?
' ' :
'').$not.
'CC';
1463 if ($rule[
'type'] ==
'subject') {
1466 $searchfilterexcludesubjectarray[] = $rule[
'rulevalue'];
1468 $search .= ($search ?
' ' :
'').
'SUBJECT "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1471 if ($rule[
'type'] ==
'body') {
1474 $searchfilterexcludebodyarray[] = $rule[
'rulevalue'];
1477 $search .= ($search ?
' ' :
'').
'BODY "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1480 if ($rule[
'type'] ==
'header') {
1481 $search .= ($search ?
' ' :
'').$not.
'HEADER '.$rule[
'rulevalue'];
1493 if ($rule[
'type'] ==
'seen') {
1494 $search .= ($search ?
' ' :
'').$not.
'SEEN';
1496 if ($rule[
'type'] ==
'unseen') {
1497 $search .= ($search ?
' ' :
'').$not.
'UNSEEN';
1499 if ($rule[
'type'] ==
'unanswered') {
1500 $search .= ($search ?
' ' :
'').$not.
'UNANSWERED';
1502 if ($rule[
'type'] ==
'answered') {
1503 $search .= ($search ?
' ' :
'').$not.
'ANSWERED';
1505 if ($rule[
'type'] ==
'smaller') {
1506 $search .= ($search ?
' ' :
'').$not.
'SMALLER "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1508 if ($rule[
'type'] ==
'larger') {
1509 $search .= ($search ?
' ' :
'').$not.
'LARGER "'.str_replace(
'"',
'', $rule[
'rulevalue']).
'"';
1513 if ($rule[
'type'] ==
'withtrackingidinmsgid') {
1514 $searchfilterdoltrackid++;
1515 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1517 if ($rule[
'type'] ==
'withouttrackingidinmsgid') {
1518 $searchfilterdoltrackid++;
1519 $searchhead .=
'/Message-ID.*@'.preg_quote($host,
'/').
'/';
1521 if ($rule[
'type'] ==
'withtrackingid') {
1522 $searchfilterdoltrackid++;
1523 $searchhead .=
'/References.*@'.preg_quote($host,
'/').
'/';
1525 if ($rule[
'type'] ==
'withouttrackingid') {
1526 $searchfilternodoltrackid++;
1527 $searchhead .=
'! /References.*@'.preg_quote($host,
'/').
'/';
1530 if ($rule[
'type'] ==
'isanswer') {
1531 $searchfilterisanswer++;
1532 $searchhead .=
'/References.*@.*/';
1534 if ($rule[
'type'] ==
'isnotanswer') {
1535 $searchfilterisnotanswer++;
1536 $searchhead .=
'! /References.*@.*/';
1539 if ($rule[
'type'] ==
'replyto') {
1540 $searchfilterreplyto++;
1541 $rulesreplyto[] = $rule[
'rulevalue'];
1542 $searchhead .=
'/Reply-To.*'.preg_quote($rule[
'rulevalue'],
'/').
'/';
1546 if (empty($targetdir)) {
1548 if ($this->datelastok) {
1549 $fromdate = $this->datelastok;
1551 if ($fromdate > 0) {
1552 $search .= ($search ?
' ' :
'').
'SINCE '.date(
'j-M-Y', $fromdate - 1);
1561 $nbemailprocessed = 0;
1564 $charset = ($this->hostcharset ? $this->hostcharset :
"UTF-8");
1571 $tmpsourcedir = $sourcedir;
1576 $f = $client->getFolders(
false, $tmpsourcedir);
1579 if ($folder instanceof Webklex\PHPIMAP\Folder) {
1580 $Query = $folder->messages()->where($criteria);
1583 $this->error =
"Source directory ".$sourcedir.
" not found";
1584 $this->errors[] = $this->error;
1585 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_WARNING);
1590 $this->error =
"Failed to execute getfolders";
1591 $this->errors[] = $this->error;
1592 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1595 }
catch (InvalidWhereQueryCriteriaException $e) {
1596 $this->error = $e->getMessage();
1597 $this->errors[] = $this->error;
1598 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1601 $this->error = $e->getMessage();
1602 $this->errors[] = $this->error;
1603 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1610 $Query->leaveUnread();
1612 $arrayofemail = $Query->limit($this->maxemailpercollect)->setFetchOrder(
"asc")->get();
1615 $this->error = $e->getMessage();
1616 $this->errors[] = $this->error;
1617 dol_syslog(
"EmailCollector::doCollectOneCollector ".$this->error, LOG_ERR);
1622 $arrayofemail = imap_search($connection, $search, SE_UID, $charset);
1624 if ($arrayofemail ===
false) {
1626 $mapoferrrors = imap_errors();
1627 if ($mapoferrrors !==
false) {
1629 $this->error =
"Search string not understood - ".implode(
',', $mapoferrrors);
1630 $this->errors[] = $this->error;
1635 $arrayofemailtodelete = array();
1638 if (!$error && !empty($arrayofemail) && count($arrayofemail) > 0) {
1655 dol_syslog(
"Start of loop on email", LOG_INFO, 1);
1658 foreach ($arrayofemail as $imapemail) {
1659 if ($nbemailprocessed > 1000) {
1667 $header = $imapemail->getHeader()->raw;
1668 $overview = $imapemail->getAttributes();
1670 $header = imap_fetchheader($connection, $imapemail, FT_UID);
1671 $overview = imap_fetch_overview($connection, $imapemail, FT_UID);
1674 $header = preg_replace(
'/\r\n\s+/m',
' ', $header);
1677 preg_match_all(
'/([^: ]+): (.+?(?:\r\n\s(?:.+?))*)\r\n/m', $header, $matches);
1678 $headers = array_combine($matches[1], $matches[2]);
1681 if (!empty($headers[
'in-reply-to']) && empty($headers[
'In-Reply-To'])) {
1682 $headers[
'In-Reply-To'] = $headers[
'in-reply-to'];
1684 if (!empty($headers[
'references']) && empty($headers[
'References'])) {
1685 $headers[
'References'] = $headers[
'references'];
1687 if (!empty($headers[
'message-id']) && empty($headers[
'Message-ID'])) {
1688 $headers[
'Message-ID'] = $headers[
'message-id'];
1690 if (!empty($headers[
'subject']) && empty($headers[
'Subject'])) {
1691 $headers[
'Subject'] = $headers[
'subject'];
1698 $operationslog .=
'<br>** Process email #'.dol_escape_htmltag($iforemailloop);
1703 $msgid = str_replace(array(
'<',
'>'),
'', $overview[
'message_id']);
1705 $operationslog .=
" - ".dol_escape_htmltag((
string) $imapemail);
1706 $msgid = str_replace(array(
'<',
'>'),
'', $overview[0]->message_id);
1710 dol_syslog(
"-- Process email ".$iforemailloop.
" References: ".($headers[
'References'] ??
'').
" Subject: ".$headers[
'Subject']);
1713 $trackidfoundintorecipienttype =
'';
1714 $trackidfoundintorecipientid = 0;
1719 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)) {
1720 $trackidfoundintorecipienttype = $reg[1];
1721 $trackidfoundintorecipientid = $reg[2];
1722 } elseif (preg_match(
'/\+emailing-(\w+)@/', $emailto, $reg)) {
1723 $trackidfoundintorecipienttype =
'emailing';
1724 $trackidfoundintorecipientid = $reg[1];
1727 $trackidfoundintomsgidtype =
'';
1728 $trackidfoundintomsgidid = 0;
1733 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)) {
1734 $trackidfoundintomsgidtype = $reg[1];
1735 $trackidfoundintomsgidid = $reg[2];
1736 } elseif (preg_match(
'/(?:[\+\-])emailing-(\w+)@/', $msgid, $reg)) {
1737 $trackidfoundintomsgidtype =
'emailing';
1738 $trackidfoundintomsgidid = $reg[1];
1742 if ($searchfilterdoltrackid > 0) {
1743 if (empty($trackidfoundintorecipienttype) && empty($trackidfoundintomsgidtype)) {
1744 if (empty($headers[
'References']) || !preg_match(
'/@'.preg_quote($host,
'/').
'/', $headers[
'References'])) {
1745 $nbemailprocessed++;
1746 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");
1751 if ($searchfilternodoltrackid > 0) {
1752 if (!empty($trackidfoundintorecipienttype) || !empty($trackidfoundintomsgidtype) || (!empty($headers[
'References']) && preg_match(
'/@'.preg_quote($host,
'/').
'/', $headers[
'References']))) {
1753 $nbemailprocessed++;
1754 dol_syslog(
" Discarded - Suffix found into email or Header References found and matching signature of application so with a trackid");
1759 if ($searchfilterisanswer > 0) {
1760 if (empty($headers[
'In-Reply-To'])) {
1761 $nbemailprocessed++;
1762 dol_syslog(
" Discarded - Email is not an answer (no In-Reply-To header)");
1766 if (preg_match(
'/^(Re|AW)\s*:\s+/i', $headers[
'Subject'])) {
1772 if (!empty($headers[
'In-Reply-To'])) {
1780 $nbemailprocessed++;
1781 dol_syslog(
" Discarded - Email is not an answer (no RE prefix in subject)");
1785 if ($searchfilterisnotanswer > 0) {
1786 if (!empty($headers[
'In-Reply-To'])) {
1790 if (preg_match(
'/Re\s*:\s+/i', $headers[
'Subject'])) {
1796 $nbemailprocessed++;
1797 dol_syslog(
" Discarded - Email is an answer");
1802 if ($searchfilterreplyto > 0) {
1803 if (!empty($headers[
'Reply-To'])) {
1805 foreach ($rulesreplyto as $key => $rulereplyto) {
1806 if (preg_match(
'/'.preg_quote($rulereplyto,
'/').
'/', $headers[
'Reply-To'])) {
1811 if (!$isreplytook || $isreplytook != count($rulesreplyto)) {
1812 $nbemailprocessed++;
1813 dol_syslog(
" Discarded - Reply-to does not match");
1821 $thirdpartystatic =
new Societe($this->db);
1822 $contactstatic =
new Contact($this->db);
1823 $projectstatic =
new Project($this->db);
1825 $nbactiondoneforemail = 0;
1827 $errorforactions = 0;
1828 $thirdpartyfoundby =
'';
1829 $contactfoundby =
'';
1830 $projectfoundby =
'';
1831 $ticketfoundby =
'';
1832 $candidaturefoundby =
'';
1836 dol_syslog(
"msgid=".$overview[
'message_id'].
" date=".
dol_print_date($overview[
'date'],
'dayrfc',
'gmt').
" from=".$overview[
'from'].
" to=".$overview[
'to'].
" subject=".$overview[
'subject']);
1841 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);
1851 global $htmlmsg, $plainmsg, $charset, $attachments;
1855 if ($imapemail->hasHTMLBody()) {
1856 $htmlmsg = $imapemail->getHTMLBody();
1858 if ($imapemail->hasTextBody()) {
1859 $plainmsg = $imapemail->getTextBody();
1861 if ($imapemail->hasAttachments()) {
1862 $attachments = $imapemail->getAttachments()->all();
1867 $this->
getmsg($connection, $imapemail);
1869 '@phan-var-force Webklex\PHPIMAP\Attachment[] $attachments';
1881 $operationslog .=
'<br>Discarded - Email body is not valid utf8';
1882 dol_syslog(
" Discarded - Email body is not valid utf8");
1886 if (!empty($searchfilterexcludebodyarray)) {
1887 foreach ($searchfilterexcludebodyarray as $searchfilterexcludebody) {
1888 if (preg_match(
'/'.preg_quote($searchfilterexcludebody,
'/').
'/ms', $messagetext)) {
1889 $nbemailprocessed++;
1890 $operationslog .=
'<br>Discarded - Email body contains string '.$searchfilterexcludebody;
1891 dol_syslog(
" Discarded - Email body contains string ".$searchfilterexcludebody);
1953 $replytostring =
'';
1956 $fromstring = $overview[
'from'];
1957 $replytostring = empty($overview[
'in_reply-to']) ? $headers[
'Reply-To'] : $overview[
'in_reply-to'];
1959 $sender = $overview[
'sender'];
1960 $to = $overview[
'to'];
1961 $sendtocc = empty($overview[
'cc']) ?
'' : $overview[
'cc'];
1962 $sendtobcc = empty($overview[
'bcc']) ?
'' : $overview[
'bcc'];
1964 $tmpdate = $overview[
'date']->toDate();
1965 $tmptimezone = $tmpdate->getTimezone()->getName();
1968 if (preg_match(
'/^([+\-])(\d\d):(\d\d)/', $tmptimezone, $reg)) {
1969 if ($reg[1] ==
'+' && ($reg[2] !=
'00' || $reg[3] !=
'00')) {
1970 $dateemail -= (3600 * (int) $reg[2]);
1971 $dateemail -= (60 * (int) $reg[3]);
1973 if ($reg[1] ==
'-' && ($reg[2] !=
'00' || $reg[3] !=
'00')) {
1974 $dateemail += (3600 * (int) $reg[2]);
1975 $dateemail += (60 * (int) $reg[3]);
1978 $subject = $overview[
'subject'];
1980 $fromstring = $overview[0]->from;
1981 $replytostring = (!empty($overview[
'in_reply-to']) ? $overview[
'in_reply-to'] : (!empty($headers[
'Reply-To']) ? $headers[
'Reply-To'] :
"")) ;
1983 $sender = !empty($overview[0]->sender) ? $overview[0]->sender :
'';
1984 $to = $overview[0]->to;
1985 $sendtocc = !empty($overview[0]->cc) ? $overview[0]->cc :
'';
1986 $sendtobcc = !empty($overview[0]->bcc) ? $overview[0]->bcc :
'';
1988 $subject = $overview[0]->subject;
1992 if (!empty($searchfilterexcludesubjectarray)) {
1993 foreach ($searchfilterexcludesubjectarray as $searchfilterexcludesubject) {
1994 if (preg_match(
'/'.preg_quote($searchfilterexcludesubject,
'/').
'/ms', $subject)) {
1995 $nbemailprocessed++;
1996 $operationslog .=
'<br>Discarded - Email subject contains string '.$searchfilterexcludesubject;
1997 dol_syslog(
" Discarded - Email subject contains string ".$searchfilterexcludesubject);
2004 if (preg_match(
'/^(.*)<(.*)>$/', $fromstring, $reg)) {
2006 $fromtext = $reg[1];
2008 $from = $fromstring;
2011 if (preg_match(
'/^(.*)<(.*)>$/', $replytostring, $reg)) {
2013 $replytotext = $reg[1];
2015 $replyto = $replytostring;
2019 $fk_element_type =
'';
2036 $objectemail =
null;
2039 $arrayofreferences = array();
2040 if (!empty($headers[
'References'])) {
2041 $arrayofreferences = preg_split(
'/(,|\s+)/', $headers[
'References']);
2043 if (!in_array(
'<'.$msgid.
'>', $arrayofreferences)) {
2044 $arrayofreferences = array_merge($arrayofreferences, array(
'<'.$msgid.
'>'));
2049 foreach ($arrayofreferences as $reference) {
2051 if (!empty($trackidfoundintorecipienttype)) {
2052 $resultsearchtrackid = -1;
2053 $reg[1] = $trackidfoundintorecipienttype;
2054 $reg[2] = $trackidfoundintorecipientid;
2055 } elseif (!empty($trackidfoundintomsgidtype)) {
2056 $resultsearchtrackid = -1;
2057 $reg[1] = $trackidfoundintomsgidtype;
2058 $reg[2] = $trackidfoundintomsgidid;
2060 $resultsearchtrackid = preg_match(
'/dolibarr-([a-z]+)([0-9]+)@'.preg_quote($host,
'/').
'/', $reference, $reg);
2061 if (empty($resultsearchtrackid) &&
getDolGlobalString(
'EMAIL_ALTERNATIVE_HOST_SIGNATURE')) {
2062 $resultsearchtrackid = preg_match(
'/dolibarr-([a-z]+)([0-9]+)@'.preg_quote(
getDolGlobalString(
'EMAIL_ALTERNATIVE_HOST_SIGNATURE'),
'/').
'/', $reference, $reg);
2066 if (!empty($resultsearchtrackid)) {
2068 $trackid = $reg[1].$reg[2];
2070 $objectid = $reg[2];
2072 if ($reg[1] ==
'thi') {
2073 $objectemail =
new Societe($this->db);
2075 if ($reg[1] ==
'ctc') {
2076 $objectemail =
new Contact($this->db);
2078 if ($reg[1] ==
'inv') {
2079 $objectemail =
new Facture($this->db);
2081 if ($reg[1] ==
'sinv') {
2084 if ($reg[1] ==
'pro') {
2085 $objectemail =
new Propal($this->db);
2087 if ($reg[1] ==
'ord') {
2088 $objectemail =
new Commande($this->db);
2090 if ($reg[1] ==
'shi') {
2093 if ($reg[1] ==
'spro') {
2096 if ($reg[1] ==
'sord') {
2099 if ($reg[1] ==
'rec') {
2100 $objectemail =
new Reception($this->db);
2102 if ($reg[1] ==
'proj') {
2103 $objectemail =
new Project($this->db);
2104 $projectfoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2106 if ($reg[1] ==
'tas') {
2107 $objectemail =
new Task($this->db);
2109 if ($reg[1] ==
'con') {
2110 $objectemail =
new Contact($this->db);
2112 if ($reg[1] ==
'use') {
2113 $objectemail =
new User($this->db);
2115 if ($reg[1] ==
'tic') {
2116 $objectemail =
new Ticket($this->db);
2117 $ticketfoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2119 if ($reg[1] ==
'recruitmentcandidature') {
2121 $candidaturefoundby =
'TrackID dolibarr-'.$trackid.
'@...';
2123 if ($reg[1] ==
'mem') {
2124 $objectemail =
new Adherent($this->db);
2132 } elseif (preg_match(
'/<(.*@.*)>/', $reference, $reg)) {
2134 if (is_null($objectemail) && isModEnabled(
'ticket')) {
2135 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"ticket";
2136 $sql .=
" WHERE email_msgid = '".$this->db->escape($reg[1]).
"' OR origin_references like '%".$this->db->escape($this->db->escapeforlike($reg[1])).
"%'";
2137 $resql = $this->db->query($sql);
2139 $obj = $this->db->fetch_object($resql);
2141 $objectid = $obj->rowid;
2142 $objectemail =
new Ticket($this->db);
2143 $ticketfoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2150 if (!is_object($objectemail) && isModEnabled(
'project')) {
2151 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"projet where email_msgid = '".$this->db->escape($reg[1]).
"'";
2152 $resql = $this->db->query($sql);
2154 $obj = $this->db->fetch_object($resql);
2156 $objectid = $obj->rowid;
2157 $objectemail =
new Project($this->db);
2158 $projectfoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2165 if (!is_object($objectemail) && isModEnabled(
'recruitment')) {
2166 $sql =
"SELECT rowid FROM ".MAIN_DB_PREFIX.
"recruitment_recruitmentcandidature where email_msgid = '".$this->db->escape($reg[1]).
"'";
2167 $resql = $this->db->query($sql);
2169 $obj = $this->db->fetch_object($resql);
2171 $objectid = $obj->rowid;
2173 $candidaturefoundby = $langs->transnoentitiesnoconv(
"EmailMsgID").
' ('.$reg[1].
')';
2182 if (is_object($objectemail)) {
2183 $result = $objectemail->fetch($objectid);
2185 $fk_element_id = $objectemail->id;
2186 $fk_element_type = $objectemail->element;
2188 if ($fk_element_type ==
'facture') {
2189 $fk_element_type =
'invoice';
2192 if (get_class($objectemail) !=
'Societe') {
2193 $thirdpartyid = $objectemail->fk_soc ?? $objectemail->socid;
2195 $thirdpartyid = $objectemail->id;
2198 if (get_class($objectemail) !=
'Contact') {
2199 $contactid = $objectemail->fk_socpeople;
2201 $contactid = $objectemail->id;
2204 if (get_class($objectemail) !=
'Project') {
2205 $projectid = isset($objectemail->fk_project) ? $objectemail->fk_project : $objectemail->fk_projet;
2207 $projectid = $objectemail->id;
2210 if (get_class($objectemail) ==
'Ticket') {
2211 $ticketid = $objectemail->id;
2213 $changeonticket_references =
false;
2214 if (empty($trackid)) {
2215 $trackid = $objectemail->track_id;
2217 if (empty($objectemail->origin_references)) {
2218 $objectemail->origin_references = $headers[
'References'];
2219 $changeonticket_references =
true;
2221 foreach ($arrayofreferences as $key => $referencetmp) {
2222 if (!str_contains($objectemail->origin_references, $referencetmp)) {
2223 $objectemail->origin_references.=
" ".$referencetmp;
2224 $changeonticket_references =
true;
2228 if ($changeonticket_references) {
2229 $objectemail->update($user);
2236 if ($projectid > 0) {
2237 $result = $projectstatic->fetch($projectid);
2239 $projectstatic->id = 0;
2241 $projectid = $projectstatic->id;
2243 $projectfoundby =
'trackid ('.$trackid.
')';
2245 if (empty($contactid)) {
2246 $contactid = $projectstatic->fk_contact;
2248 if (empty($thirdpartyid)) {
2249 $thirdpartyid = $projectstatic->fk_soc;
2254 if ($contactid > 0) {
2255 $result = $contactstatic->fetch($contactid);
2257 $contactstatic->id = 0;
2259 $contactid = $contactstatic->id;
2261 $contactfoundby =
'trackid ('.$trackid.
')';
2263 if (empty($thirdpartyid)) {
2264 $thirdpartyid = $contactstatic->fk_soc;
2269 if ($thirdpartyid > 0) {
2270 $result = $thirdpartystatic->fetch($thirdpartyid);
2272 $thirdpartystatic->id = 0;
2274 $thirdpartyid = $thirdpartystatic->id;
2276 $thirdpartyfoundby =
'trackid ('.$trackid.
')';
2281 if (is_object($objectemail)) {
2286 if (empty($contactid)) {
2287 $result = $contactstatic->fetch(0,
null,
'', $from);
2290 dol_syslog(
"We found a contact with the email ".$from);
2291 $contactid = $contactstatic->id;
2292 $contactfoundby =
'email of contact ('.$from.
')';
2293 if (empty($thirdpartyid) && $contactstatic->socid > 0) {
2294 $result = $thirdpartystatic->fetch($contactstatic->socid);
2296 $thirdpartyid = $thirdpartystatic->id;
2297 $thirdpartyfoundby =
'email of contact ('.$from.
')';
2303 if (empty($thirdpartyid)) {
2304 $result = $thirdpartystatic->fetch(0,
'',
'',
'',
'',
'',
'',
'',
'',
'', $from);
2306 dol_syslog(
"We found a thirdparty with the email ".$from);
2307 $thirdpartyid = $thirdpartystatic->id;
2308 $thirdpartyfoundby =
'email ('.$from.
')';
2344 foreach ($this->actions as $operation) {
2345 $errorforthisaction = 0;
2346 $ticketalreadyexists = 0;
2347 if ($errorforactions) {
2350 if (empty($operation[
'status'])) {
2354 $operationslog .=
'<br>* Process operation '.$operation[
'type'];
2357 dol_syslog(
"Execute action ".$operation[
'type'].
" actionparam=".$operation[
'actionparam'].
' thirdpartystatic->id='.$thirdpartystatic->id.
' contactstatic->id='.$contactstatic->id.
' projectstatic->id='.$projectstatic->id);
2358 dol_syslog(
"Execute action fk_element_id=".$fk_element_id.
" fk_element_type=".$fk_element_type);
2361 $actioncode =
'EMAIL_IN';
2363 if (preg_match(
'/Sent$/', $sourcedir) || preg_match(
'/envoyés$/i', $sourcedir)) {
2364 $actioncode =
'EMAIL';
2367 $arrayofemailtoconsideresender = explode(
',',
getDolGlobalString(
'MAIL_FROM_EMAILS_TO_CONSIDER_SENDING'));
2368 foreach ($arrayofemailtoconsideresender as $emailtoconsidersender) {
2369 if (preg_match(
'/'.preg_quote($emailtoconsidersender,
'/').
'/', $fromstring)) {
2370 $actioncode =
'EMAIL';
2373 $operationslog .=
'<br>Email will have actioncode='.$actioncode;
2375 $description = $descriptiontitle = $descriptionmeta = $descriptionfull =
'';
2377 $descriptiontitle = $langs->trans(
"RecordCreatedByEmailCollector", $this->
ref, $msgid);
2380 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailFrom").($langs->trans(
"MailFrom") !=
'From' ?
' (From)' :
'').
' : '.
dol_escape_htmltag($fromstring));
2382 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"Sender").($langs->trans(
"Sender") !=
'Sender' ?
' (Sender)' :
'').
' : '.
dol_escape_htmltag($sender));
2384 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailTo").($langs->trans(
"MailTo") !=
'To' ?
' (To)' :
'').
' : '.
dol_escape_htmltag($to));
2386 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailReply").($langs->trans(
"MailReply") !=
'Reply to' ?
' (Reply to)' :
'').
' : '.
dol_escape_htmltag($replyto));
2389 $descriptionmeta =
dol_concatdesc($descriptionmeta, $langs->trans(
"MailCC").($langs->trans(
"MailCC") !=
'CC' ?
' (CC)' :
'').
' : '.
dol_escape_htmltag($sendtocc));
2392 if ($operation[
'type'] ==
'ticket') {
2394 $tickettocreate =
new Ticket($this->db);
2395 $errorfetchticket = 0;
2396 $alreadycreated = 0;
2397 if (!empty($trackid)) {
2398 $alreadycreated = $tickettocreate->fetch(0,
'', $trackid);
2400 if ($alreadycreated == 0 && !empty($msgid)) {
2401 $alreadycreated = $tickettocreate->fetch(0,
'',
'', $msgid);
2403 if ($alreadycreated < 0) {
2404 $errorfetchticket++;
2406 if (empty($errorfetchticket)) {
2407 if ($alreadycreated == 0) {
2408 $operationslog .=
'<br>Ticket not found using trackid='.$trackid.
' or msgid='.$msgid;
2409 $ticketalreadyexists = 0;
2411 $operationslog .=
'<br>Ticket already found using trackid='.$trackid.
' or msgid='.$msgid;
2412 $ticketalreadyexists = 1;
2413 $operation[
'type'] =
'recordevent';
2416 $ticketalreadyexists = -1;
2423 if ($operation[
'type'] ==
'loadthirdparty' || $operation[
'type'] ==
'loadandcreatethirdparty') {
2424 if (empty($operation[
'actionparam'])) {
2426 $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;";
2427 $this->errors[] = $this->error;
2429 $actionparam = $operation[
'actionparam'];
2430 $idtouseforthirdparty =
'';
2431 $nametouseforthirdparty =
'';
2432 $emailtouseforthirdparty =
'';
2433 $namealiastouseforthirdparty =
'';
2435 $operationslog .=
'<br>Loop on each property to set into actionparam';
2439 foreach ($arrayvaluetouse as $propertytooverwrite => $valueforproperty) {
2443 $regforregex = array();
2445 if (preg_match(
'/^EXTRACT:([a-zA-Z0-9_]+):(.*)$/', $valueforproperty, $regforregex)) {
2446 $sourcefield = $regforregex[1];
2447 $regexstring = $regforregex[2];
2450 if (!empty($sourcefield) && !empty($regexstring)) {
2451 if (strtolower($sourcefield) ==
'body') {
2452 $sourcestring = $messagetext;
2453 } elseif (strtolower($sourcefield) ==
'subject') {
2454 $sourcestring = $subject;
2455 } elseif (strtolower($sourcefield) ==
'header') {
2456 $sourcestring = $header;
2459 if ($sourcestring) {
2460 $regforval = array();
2462 if (preg_match(
'/'.$regexstring.
'/ms', $sourcestring, $regforval)) {
2465 if ($propertytooverwrite ==
'id') {
2466 $idtouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2468 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found idtouseforthirdparty='.
dol_escape_htmltag($idtouseforthirdparty);
2469 } elseif ($propertytooverwrite ==
'email') {
2470 $emailtouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2472 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found emailtouseforthirdparty='.
dol_escape_htmltag($emailtouseforthirdparty);
2473 } elseif ($propertytooverwrite ==
'name') {
2474 $nametouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2476 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found nametouseforthirdparty='.
dol_escape_htmltag($nametouseforthirdparty);
2477 } elseif ($propertytooverwrite ==
'name_alias') {
2478 $namealiastouseforthirdparty = isset($regforval[count($regforval) - 1]) ? trim($regforval[count($regforval) - 1]) : null;
2480 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Found namealiastouseforthirdparty='.
dol_escape_htmltag($namealiastouseforthirdparty);
2482 $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';
2486 if (in_array($propertytooverwrite, array(
'id',
'email',
'name',
'name_alias'))) {
2487 $idtouseforthirdparty =
null;
2488 $nametouseforthirdparty =
null;
2489 $emailtouseforthirdparty =
null;
2490 $namealiastouseforthirdparty =
null;
2492 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Not found. Property searched is critical so we cancel the search.';
2494 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' Regex /'.
dol_escape_htmltag($regexstring).
'/ms into '.strtoupper($sourcefield).
' -> Not found';
2501 $this->error =
'The extract rule to use to load thirdparty for email '.$msgid.
' has an unknown source (must be HEADER, SUBJECT or BODY)';
2502 $this->errors[] = $this->error;
2504 $operationslog .=
'<br>'.$this->error;
2506 } elseif (preg_match(
'/^(SET|SETIFEMPTY):(.*)$/', $valueforproperty, $reg)) {
2510 if ($propertytooverwrite ==
'id') {
2511 $idtouseforthirdparty = $reg[2];
2513 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property idtouseforthrdparty='.
dol_escape_htmltag($idtouseforthirdparty);
2514 } elseif ($propertytooverwrite ==
'email') {
2515 $emailtouseforthirdparty = $reg[2];
2517 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property emailtouseforthrdparty='.
dol_escape_htmltag($emailtouseforthirdparty);
2518 } elseif ($propertytooverwrite ==
'name') {
2519 $nametouseforthirdparty = $reg[2];
2521 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property nametouseforthirdparty='.
dol_escape_htmltag($nametouseforthirdparty);
2522 } elseif ($propertytooverwrite ==
'name_alias') {
2523 $namealiastouseforthirdparty = $reg[2];
2525 $operationslog .=
'<br>propertytooverwrite='.$propertytooverwrite.
' We set property namealiastouseforthirdparty='.
dol_escape_htmltag($namealiastouseforthirdparty);
2529 $this->error =
'Bad syntax for description of action parameters: '.$actionparam;
2530 $this->errors[] = $this->error;
2535 if (!$errorforactions && ($idtouseforthirdparty || $emailtouseforthirdparty || $nametouseforthirdparty || $namealiastouseforthirdparty)) {
2537 $operationslog .=
'<br>We have this data to search thirdparty: id='.$idtouseforthirdparty.
', email='.$emailtouseforthirdparty.
', name='.$nametouseforthirdparty.
', name_alias='.$namealiastouseforthirdparty;
2540 $tmpobject->element =
'generic';
2541 $tmpobject->id = $idtouseforthirdparty;
2542 $tmpobject->name = $nametouseforthirdparty;
2543 $tmpobject->name_alias = $namealiastouseforthirdparty;
2544 $tmpobject->email = $emailtouseforthirdparty;
2548 $idtouseforthirdparty = $tmpobject->id;
2549 $nametouseforthirdparty = $tmpobject->name;
2550 $namealiastouseforthirdparty = $tmpobject->name_alias;
2551 $emailtouseforthirdparty = $tmpobject->email;
2553 $operationslog .=
'<br>We try to search existing thirdparty with '.$idtouseforthirdparty.
' '.$emailtouseforthirdparty.
' '.$nametouseforthirdparty.
' '.$namealiastouseforthirdparty;
2555 $result = $thirdpartystatic->fetch($idtouseforthirdparty, $nametouseforthirdparty,
'',
'',
'',
'',
'',
'',
'',
'', $emailtouseforthirdparty, $namealiastouseforthirdparty);
2558 $this->error =
'Error when getting thirdparty with name '.$nametouseforthirdparty.
' (may be 2 record exists with same name ?)';
2559 $this->errors[] = $this->error;
2561 } elseif ($result == 0) {
2562 if ($operation[
'type'] ==
'loadthirdparty') {
2563 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was not found");
2566 $resultContact = $contactstatic->fetch(
'',
'',
'', $emailtouseforthirdparty);
2567 if ($resultContact > 0) {
2568 $idtouseforthirdparty = $contactstatic->socid;
2569 $result = $thirdpartystatic->fetch($idtouseforthirdparty);
2571 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was found thanks to linked contact search");
2574 $langs->load(
"errors");
2575 $this->error = $langs->trans(
'ErrorFailedToLoadThirdParty', $idtouseforthirdparty, $emailtouseforthirdparty, $nametouseforthirdparty, $namealiastouseforthirdparty);
2576 $this->errors[] = $this->error;
2580 $langs->load(
"errors");
2581 $this->error = $langs->trans(
'ErrorFailedToLoadThirdParty', $idtouseforthirdparty, $emailtouseforthirdparty, $nametouseforthirdparty, $namealiastouseforthirdparty);
2582 $this->errors[] = $this->error;
2584 } elseif ($operation[
'type'] ==
'loadandcreatethirdparty') {
2585 dol_syslog(
"Third party with id=".$idtouseforthirdparty.
" email=".$emailtouseforthirdparty.
" name=".$nametouseforthirdparty.
" name_alias=".$namealiastouseforthirdparty.
" was not found. We try to create it.");
2588 $thirdpartystatic =
new Societe($db);
2589 $thirdpartystatic->name = $nametouseforthirdparty;
2590 if (!empty($namealiastouseforthirdparty)) {
2591 if ($namealiastouseforthirdparty != $nametouseforthirdparty) {
2592 $thirdpartystatic->name_alias = $namealiastouseforthirdparty;
2595 $thirdpartystatic->name_alias = (empty($replytostring) ? (empty($fromtext) ?
'' : $fromtext) : $replytostring);
2597 $thirdpartystatic->email = (empty($emailtouseforthirdparty) ? (empty($replyto) ? (empty($from) ?
'' : $from) : $replyto) : $emailtouseforthirdparty);
2600 $errorforthisaction = $this->
overwritePropertiesOfObject($thirdpartystatic, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2602 if ($thirdpartystatic->client && empty($thirdpartystatic->code_client)) {
2603 $thirdpartystatic->code_client =
'auto';
2605 if ($thirdpartystatic->fournisseur && empty($thirdpartystatic->code_fournisseur)) {
2606 $thirdpartystatic->code_fournisseur =
'auto';
2609 if ($errorforthisaction) {
2612 $result = $thirdpartystatic->create($user);
2615 $this->error = $thirdpartystatic->error;
2616 $this->errors = $thirdpartystatic->errors;
2618 $operationslog .=
'<br>Thirdparty created -> id = '.dol_escape_htmltag($thirdpartystatic->id);
2623 dol_syslog(
"One and only one existing third party has been found");
2625 $operationslog .=
'<br>Thirdparty already exists with id = '.dol_escape_htmltag($thirdpartystatic->id);
2629 } elseif ($operation[
'type'] ==
'loadandcreatecontact') {
2630 if (empty($operation[
'actionparam'])) {
2632 $this->error =
"Action loadandcreatecontact has empty parameter. Must be 'SET:xxx' or 'EXTRACT:(body|subject):regex' to define how to extract data";
2633 $this->errors[] = $this->error;
2635 $contact_static =
new Contact($this->db);
2637 $errorforthisaction = $this->
overwritePropertiesOfObject($contact_static, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2638 if ($errorforthisaction) {
2641 if (!empty($contact_static->email) && $contact_static->email != $from) {
2642 $from = $contact_static->email;
2645 $result = $contactstatic->fetch(0,
null,
'', $from);
2648 $this->error =
'Error when getting contact with email ' . $from;
2649 $this->errors[] = $this->error;
2651 } elseif ($result == 0) {
2652 dol_syslog(
"Contact with email " . $from .
" was not found. We try to create it.");
2653 $contactstatic =
new Contact($this->db);
2656 $contactstatic->email = $from;
2657 $operationslog .=
'<br>We set property email='.dol_escape_htmltag($from);
2660 $errorforthisaction = $this->
overwritePropertiesOfObject($contactstatic, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2662 if ($errorforthisaction) {
2666 if (!empty($contactstatic->country)) {
2667 require_once DOL_DOCUMENT_ROOT .
'/core/lib/company.lib.php';
2668 $result =
getCountry(
'', 3, $this->db,
null, 1, $contactstatic->country);
2669 if ($result ==
'NotDefined') {
2671 $this->error =
"Error country not found by this name '" . $contactstatic->country .
"'";
2672 } elseif (!($result > 0)) {
2674 $this->error =
"Error when search country by this name '" . $contactstatic->country .
"'";
2675 $this->errors[] = $this->db->lasterror();
2677 $contactstatic->country_id = $result;
2678 $operationslog .=
'<br>We set property country_id='.dol_escape_htmltag($result);
2680 } elseif (!empty($contactstatic->country_code)) {
2681 require_once DOL_DOCUMENT_ROOT .
'/core/lib/company.lib.php';
2682 $result =
getCountry($contactstatic->country_code, 3, $this->db);
2683 if ($result ==
'NotDefined') {
2685 $this->error =
"Error country not found by this code '" . $contactstatic->country_code .
"'";
2686 } elseif (!($result > 0)) {
2688 $this->error =
"Error when search country by this code '" . $contactstatic->country_code .
"'";
2689 $this->errors[] = $this->db->lasterror();
2691 $contactstatic->country_id = $result;
2692 $operationslog .=
'<br>We set property country_id='.dol_escape_htmltag($result);
2696 if (!$errorforactions) {
2698 if (!empty($contactstatic->state)) {
2699 require_once DOL_DOCUMENT_ROOT .
'/core/lib/functions.lib.php';
2700 $result =
dol_getIdFromCode($this->db, $contactstatic->state,
'c_departements',
'nom',
'rowid');
2701 if (empty($result)) {
2703 $this->error =
"Error state not found by this name '" . $contactstatic->state .
"'";
2704 } elseif (!($result > 0)) {
2706 $this->error =
"Error when search state by this name '" . $contactstatic->state .
"'";
2707 $this->errors[] = $this->db->lasterror();
2709 $contactstatic->state_id = $result;
2710 $operationslog .=
'<br>We set property state_id='.dol_escape_htmltag($result);
2712 } elseif (!empty($contactstatic->state_code)) {
2713 require_once DOL_DOCUMENT_ROOT .
'/core/lib/functions.lib.php';
2714 $result =
dol_getIdFromCode($this->db, $contactstatic->state_code,
'c_departements',
'code_departement',
'rowid');
2715 if (empty($result)) {
2717 $this->error =
"Error state not found by this code '" . $contactstatic->state_code .
"'";
2718 } elseif (!($result > 0)) {
2720 $this->error =
"Error when search state by this code '" . $contactstatic->state_code .
"'";
2721 $this->errors[] = $this->db->lasterror();
2723 $contactstatic->state_id = $result;
2724 $operationslog .=
'<br>We set property state_id='.dol_escape_htmltag($result);
2729 if (!$errorforactions) {
2730 $result = $contactstatic->create($user);
2733 $this->error = $contactstatic->error;
2734 $this->errors = $contactstatic->errors;
2736 $operationslog .=
'<br>Contact created -> id = '.dol_escape_htmltag($contactstatic->id);
2743 } elseif ($operation[
'type'] ==
'recordevent') {
2747 $alreadycreated = $actioncomm->fetch(0,
'',
'', $msgid);
2748 if ($alreadycreated == 0) {
2749 $operationslog .=
'<br>We did not find existing actionmail with msgid='.$msgid;
2751 if ($projectstatic->id > 0) {
2752 if ($projectfoundby) {
2753 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Project found from '.$projectfoundby);
2756 if ($thirdpartystatic->id > 0) {
2757 if ($thirdpartyfoundby) {
2758 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
2761 if ($contactstatic->id > 0) {
2762 if ($contactfoundby) {
2763 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
2767 $description = $descriptiontitle;
2773 $descriptionfull = $description;
2775 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
2780 $actioncomm->type_code =
'AC_OTH_AUTO';
2781 $actioncomm->code =
'AC_'.$actioncode;
2782 $actioncomm->label = $langs->trans(
"ActionAC_".$actioncode).
' - '.$langs->trans(
"MailFrom").
' '.$from;
2783 $actioncomm->note_private = $descriptionfull;
2784 $actioncomm->fk_project = $projectstatic->id;
2785 $actioncomm->datep = $dateemail;
2786 $actioncomm->datef = $dateemail;
2787 $actioncomm->percentage = -1;
2788 $actioncomm->socid = $thirdpartystatic->id;
2789 $actioncomm->contact_id = $contactstatic->id;
2790 $actioncomm->socpeopleassigned = (!empty($contactstatic->id) ? array($contactstatic->id) : array());
2791 $actioncomm->authorid = $user->id;
2792 $actioncomm->userownerid = $user->id;
2794 $actioncomm->email_msgid = $msgid;
2795 $actioncomm->email_from = $fromstring;
2796 $actioncomm->email_sender = $sender;
2797 $actioncomm->email_to = $to;
2798 $actioncomm->email_tocc = $sendtocc;
2799 $actioncomm->email_tobcc = $sendtobcc;
2800 $actioncomm->email_subject = $subject;
2801 $actioncomm->errors_to =
'';
2803 if (!in_array($fk_element_type, array(
'societe',
'contact',
'project',
'user'))) {
2804 $actioncomm->fk_element = $fk_element_id;
2805 $actioncomm->elementid = $fk_element_id;
2806 $actioncomm->elementtype = $fk_element_type;
2807 if (is_object($objectemail) && $objectemail->module) {
2808 $actioncomm->elementtype .=
'@'.$objectemail->module;
2815 $errorforthisaction = $this->
overwritePropertiesOfObject($actioncomm, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
2817 if ($errorforthisaction) {
2820 $result = $actioncomm->create($user);
2823 $this->errors = $actioncomm->errors;
2825 if ($fk_element_type ==
"ticket" && is_object($objectemail)) {
2826 if ($objectemail->status == Ticket::STATUS_CLOSED || $objectemail->status == Ticket::STATUS_CANCELED) {
2827 if ($objectemail->fk_user_assign !=
null) {
2828 $res = $objectemail->setStatut(Ticket::STATUS_ASSIGNED);
2830 $res = $objectemail->setStatut(Ticket::STATUS_NOT_READ);
2834 $operationslog .=
'<br>Ticket Re-Opened successfully -> ref='.$objectemail->ref;
2837 $this->error =
'Error while changing the ticket status -> ref='.$objectemail->ref;
2838 $this->errors[] = $this->error;
2841 if (!empty($attachments)) {
2843 $ticket =
new Ticket($this->db);
2844 $ticket->fetch($fk_element_id);
2845 $destdir = $conf->ticket->dir_output.
'/'.$ticket->ref;
2850 foreach ($attachments as $attachment) {
2851 $attachment->save($destdir.
'/');
2854 $this->
getmsg($connection, $imapemail, $destdir);
2859 $operationslog .=
'<br>Event created -> id='.dol_escape_htmltag($actioncomm->id);
2863 } elseif ($operation[
'type'] ==
'recordjoinpiece') {
2866 foreach ($attachments as $attachment) {
2867 if ($attachment->getName() ===
'undefined') {
2870 $data[$attachment->getName()] = $attachment->getContent();
2874 foreach ($pj as $key => $val) {
2875 $data[$val[
'filename']] =
getFileData($imapemail, $val[
'pos'], $val[
'type'], $connection);
2878 if (count($data) > 0) {
2879 $sql =
"SELECT rowid as id FROM ".MAIN_DB_PREFIX.
"user WHERE email LIKE '%".$this->db->escape($from).
"%'";
2880 $resql = $this->db->query($sql);
2881 if ($this->db->num_rows($resql) == 0) {
2882 $this->errors[] =
"User Not allowed to add documents ({$from})";
2884 $arrayobject = array(
2885 'propale' => array(
'table' =>
'propal',
2886 'fields' => array(
'ref'),
2887 'class' =>
'comm/propal/class/propal.class.php',
2888 'object' =>
'Propal'),
2889 'holiday' => array(
'table' =>
'holiday',
2890 'fields' => array(
'ref'),
2891 'class' =>
'holiday/class/holiday.class.php',
2892 'object' =>
'Holiday'),
2893 'expensereport' => array(
'table' =>
'expensereport',
2894 'fields' => array(
'ref'),
2895 'class' =>
'expensereport/class/expensereport.class.php',
2896 'object' =>
'ExpenseReport'),
2897 'recruitment/recruitmentjobposition' => array(
'table' =>
'recruitment_recruitmentjobposition',
2898 'fields' => array(
'ref'),
2899 'class' =>
'recruitment/class/recruitmentjobposition.class.php',
2900 'object' =>
'RecruitmentJobPosition'),
2901 'recruitment/recruitmentcandidature' => array(
'table' =>
'recruitment_recruitmentcandidature',
2902 'fields' => array(
'ref'),
2903 'class' =>
'recruitment/class/recruitmentcandidature.class.php',
2904 'object' =>
' RecruitmentCandidature'),
2905 'societe' => array(
'table' =>
'societe',
2906 'fields' => array(
'code_client',
'code_fournisseur'),
2907 'class' =>
'societe/class/societe.class.php',
2908 'object' =>
'Societe'),
2909 'commande' => array(
'table' =>
'commande',
2910 'fields' => array(
'ref'),
2911 'class' =>
'commande/class/commande.class.php',
2912 'object' =>
'Commande'),
2913 'expedition' => array(
'table' =>
'expedition',
2914 'fields' => array(
'ref'),
2915 'class' =>
'expedition/class/expedition.class.php',
2916 'object' =>
'Expedition'),
2917 'contract' => array(
'table' =>
'contrat',
2918 'fields' => array(
'ref'),
2919 'class' =>
'contrat/class/contrat.class.php',
2920 'object' =>
'Contrat'),
2921 'fichinter' => array(
'table' =>
'fichinter',
2922 'fields' => array(
'ref'),
2923 'class' =>
'fichinter/class/fichinter.class.php',
2924 'object' =>
'Fichinter'),
2925 'ticket' => array(
'table' =>
'ticket',
2926 'fields' => array(
'ref'),
2927 'class' =>
'ticket/class/ticket.class.php',
2928 'object' =>
'Ticket'),
2929 'knowledgemanagement' => array(
'table' =>
'knowledgemanagement_knowledgerecord',
2930 'fields' => array(
'ref'),
2931 'class' =>
'knowledgemanagement/class/knowledgemanagement.class.php',
2932 'object' =>
'KnowledgeRecord'),
2933 'supplier_proposal' => array(
'table' =>
'supplier_proposal',
2934 'fields' => array(
'ref'),
2935 'class' =>
'supplier_proposal/class/supplier_proposal.class.php',
2936 'object' =>
'SupplierProposal'),
2937 'fournisseur/commande' => array(
'table' =>
'commande_fournisseur',
2938 'fields' => array(
'ref',
'ref_supplier'),
2939 'class' =>
'fourn/class/fournisseur.commande.class.php',
2940 'object' =>
'SupplierProposal'),
2941 'facture' => array(
'table' =>
'facture',
2942 'fields' => array(
'ref'),
2943 'class' =>
'compta/facture/class/facture.class.php',
2944 'object' =>
'Facture'),
2945 'fournisseur/facture' => array(
'table' =>
'facture_fourn',
2946 'fields' => array(
'ref',
'ref_client'),
2947 'class' =>
'fourn/class/fournisseur.facture.class.php',
2948 'object' =>
'FactureFournisseur'),
2949 'produit' => array(
'table' =>
'product',
2950 'fields' => array(
'ref'),
2951 'class' =>
'product/class/product.class.php',
2952 'object' =>
'Product'),
2953 'productlot' => array(
'table' =>
'product_lot',
2954 'fields' => array(
'batch'),
2955 'class' =>
'product/stock/class/productlot.class.php',
2956 'object' =>
'Productlot'),
2957 'projet' => array(
'table' =>
'projet',
2958 'fields' => array(
'ref'),
2959 'class' =>
'projet/class/projet.class.php',
2960 'object' =>
'Project'),
2961 'projet_task' => array(
'table' =>
'projet_task',
2962 'fields' => array(
'ref'),
2963 'class' =>
'projet/class/task.class.php',
2964 'object' =>
'Task'),
2965 'ressource' => array(
'table' =>
'resource',
2966 'fields' => array(
'ref'),
2967 'class' =>
'ressource/class/dolressource.class.php',
2968 'object' =>
'Dolresource'),
2969 'bom' => array(
'table' =>
'bom_bom',
2970 'fields' => array(
'ref'),
2971 'class' =>
'bom/class/bom.class.php',
2973 'mrp' => array(
'table' =>
'mrp_mo',
2974 'fields' => array(
'ref'),
2975 'class' =>
'mrp/class/mo.class.php',
2979 if (!is_object($hookmanager)) {
2980 include_once DOL_DOCUMENT_ROOT.
'/core/class/hookmanager.class.php';
2983 $hookmanager->initHooks(array(
'emailcolector'));
2984 $parameters = array(
'arrayobject' => $arrayobject);
2985 $reshook = $hookmanager->executeHooks(
'addmoduletoeamailcollectorjoinpiece', $parameters);
2987 $arrayobject = $hookmanager->resArray;
2990 $resultobj = array();
2992 foreach ($arrayobject as $key => $objectdesc) {
2993 $sql =
'SELECT DISTINCT t.rowid ';
2994 $sql .=
' FROM ' . MAIN_DB_PREFIX . $this->db->sanitize($objectdesc[
'table']) .
' AS t';
2996 foreach ($objectdesc[
'fields'] as $field) {
2997 $sql .=
"('" .$this->db->escape($subject) .
"' LIKE CONCAT('%', t." . $this->db->sanitize($field) .
", '%') AND t." . $this->db->sanitize($field) .
" <> '') OR ";
2999 $sql = substr($sql, 0, -4);
3001 $ressqlobj = $this->db->query($sql);
3003 while ($obj = $this->db->fetch_object($ressqlobj)) {
3004 $resultobj[$key][] = $obj->rowid;
3009 foreach ($resultobj as $mod => $ids) {
3010 $moddesc = $arrayobject[$mod];
3011 $elementpath = $mod;
3013 $objectmanaged =
new $moddesc[
'object']($this->db);
3014 foreach ($ids as $val) {
3015 $res = $objectmanaged->fetch($val);
3017 $path = ($objectmanaged->entity > 1 ?
"/" . $objectmanaged->entity :
'');
3018 $dirs[] = DOL_DATA_ROOT . $path .
"/" . $elementpath .
'/' .
dol_sanitizeFileName($objectmanaged->ref) .
'/';
3020 $this->errors[] =
'object not found';
3024 foreach ($dirs as $target) {
3025 $prefix = $this->actions[$this->id][
'actionparam'];
3026 foreach ($data as $filename => $content) {
3027 $resr =
saveAttachment($target, $prefix .
'_' . $filename, $content);
3029 $this->errors[] =
'Doc not saved';
3034 $operationslog .=
'<br>Save attachment files on disk';
3036 $this->errors[] =
'no joined piece';
3038 $operationslog .=
'<br>No joinded files';
3040 } elseif ($operation[
'type'] ==
'project') {
3042 $projecttocreate =
new Project($this->db);
3043 $alreadycreated = $projecttocreate->fetch(0,
'',
'', $msgid);
3044 if ($alreadycreated == 0) {
3045 if ($thirdpartystatic->id > 0) {
3046 $projecttocreate->socid = $thirdpartystatic->id;
3047 if ($thirdpartyfoundby) {
3048 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
3051 if ($contactstatic->id > 0) {
3052 $projecttocreate->contact_id = $contactstatic->id;
3053 if ($contactfoundby) {
3054 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
3058 $description = $descriptiontitle;
3064 $descriptionfull = $description;
3066 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3070 $id_opp_status =
dol_getIdFromCode($this->db,
'PROSP',
'c_lead_status',
'code',
'rowid');
3071 $percent_opp_status =
dol_getIdFromCode($this->db,
'PROSP',
'c_lead_status',
'code',
'percent');
3073 $projecttocreate->title = $subject;
3074 $projecttocreate->date_start = $dateemail;
3075 $projecttocreate->date_end = 0;
3076 $projecttocreate->opp_status = $id_opp_status;
3077 $projecttocreate->opp_percent = $percent_opp_status;
3079 $projecttocreate->note_private = $descriptionfull;
3080 $projecttocreate->entity = $conf->entity;
3081 $projecttocreate->email_msgid = $msgid;
3083 $savesocid = $projecttocreate->socid;
3087 $errorforthisaction = $this->
overwritePropertiesOfObject($projecttocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3090 if (empty($projecttocreate->ref)) {
3093 $modele = !
getDolGlobalString(
'PROJECT_ADDON') ?
'mod_project_simple' : $conf->global->PROJECT_ADDON;
3099 $dirmodels = array_merge(array(
'/'), (array) $conf->modules_parts[
'models']);
3100 foreach ($dirmodels as $reldir) {
3101 $file =
dol_buildpath($reldir.
"core/modules/project/".$modele.
'.php', 0);
3102 if (file_exists($file)) {
3103 $classname = $modele;
3108 if ($classname !==
'') {
3109 if ($savesocid > 0) {
3110 if ($savesocid != $projecttocreate->socid) {
3112 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');
3115 if ($projecttocreate->socid > 0) {
3116 $thirdpartystatic->fetch($projecttocreate->socid);
3120 $result =
dol_include_once($reldir.
"core/modules/project/".$modele.
'.php');
3121 $modModuleToUseForNextValue =
new $classname();
3122 $defaultref = $modModuleToUseForNextValue->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $projecttocreate);
3124 $projecttocreate->ref = $defaultref;
3128 if ($errorforthisaction) {
3131 if (empty($projecttocreate->ref) || (is_numeric($projecttocreate->ref) && $projecttocreate->ref <= 0)) {
3133 $this->error =
'Failed to create project: Can\'t get a valid value for the field ref with numbering template = '.$modele.
', thirdparty id = '.$thirdpartystatic->id;
3135 $operationslog .=
'<br>'.$this->error;
3138 $result = $projecttocreate->create($user);
3141 $this->error =
'Failed to create project: '.$langs->trans($projecttocreate->error);
3142 $this->errors = $projecttocreate->errors;
3144 $operationslog .=
'<br>'.$this->error;
3147 $destdir = $conf->project->dir_output.
'/'.$projecttocreate->ref;
3152 foreach ($attachments as $attachment) {
3154 $typeattachment = (string) $attachment->getDisposition();
3155 $filename = $attachment->getFilename();
3156 $content = $attachment->getContent();
3160 $this->
getmsg($connection, $imapemail, $destdir);
3163 $operationslog .=
'<br>Project created with attachments -> id='.dol_escape_htmltag($projecttocreate->id);
3165 $operationslog .=
'<br>Project created without attachments -> id='.dol_escape_htmltag($projecttocreate->id);
3173 $operationslog .=
'<br>Project already exists for msgid ='.dol_escape_htmltag($msgid);
3175 } elseif ($operation[
'type'] ==
'ticket') {
3177 $tickettocreate =
new Ticket($this->db);
3178 if ($ticketalreadyexists == 0) {
3179 if ($thirdpartystatic->id > 0) {
3180 $tickettocreate->socid = $thirdpartystatic->id;
3181 $tickettocreate->fk_soc = $thirdpartystatic->id;
3182 if ($thirdpartyfoundby) {
3183 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Third party found from '.$thirdpartyfoundby);
3186 if ($contactstatic->id > 0) {
3187 $tickettocreate->contact_id = $contactstatic->id;
3188 if ($contactfoundby) {
3189 $descriptionmeta =
dol_concatdesc($descriptionmeta,
'Contact/address found from '.$contactfoundby);
3193 $description = $descriptiontitle;
3199 $descriptionfull = $description;
3201 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3205 $tickettocreate->subject = $subject;
3206 $tickettocreate->message = $description;
3207 $tickettocreate->type_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_TYPE_CODE') ? $conf->global->MAIN_EMAILCOLLECTOR_TICKET_TYPE_CODE :
dol_getIdFromCode($this->db, 1,
'c_ticket_type',
'use_default',
'code', 1));
3208 $tickettocreate->category_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_CATEGORY_CODE') ? $conf->global->MAIN_EMAILCOLLECTOR_TICKET_CATEGORY_CODE :
dol_getIdFromCode($this->db, 1,
'c_ticket_category',
'use_default',
'code', 1));
3209 $tickettocreate->severity_code = (
getDolGlobalString(
'MAIN_EMAILCOLLECTOR_TICKET_SEVERITY_CODE') ? $conf->global->MAIN_EMAILCOLLECTOR_TICKET_SEVERITY_CODE :
dol_getIdFromCode($this->db, 1,
'c_ticket_severity',
'use_default',
'code', 1));
3210 $tickettocreate->origin_email = $from;
3211 $tickettocreate->origin_replyto = (!empty($replyto) ? $replyto :
null);
3212 $tickettocreate->origin_references = (!empty($headers[
'References']) ? $headers[
'References'] :
null);
3213 $tickettocreate->fk_user_create = $user->id;
3214 $tickettocreate->datec =
dol_now();
3215 $tickettocreate->fk_project = $projectstatic->id;
3216 $tickettocreate->notify_tiers_at_create =
getDolGlobalInt(
'TICKET_CHECK_NOTIFY_THIRDPARTY_AT_CREATION');
3217 $tickettocreate->note_private = $descriptionfull;
3218 $tickettocreate->entity = $conf->entity;
3219 $tickettocreate->email_msgid = $msgid;
3220 $tickettocreate->email_date = $dateemail;
3223 $savesocid = $tickettocreate->socid;
3227 $errorforthisaction = $this->
overwritePropertiesOfObject($tickettocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3230 if (empty($tickettocreate->ref)) {
3239 $dirmodels = array_merge(array(
'/'), (array) $conf->modules_parts[
'models']);
3240 foreach ($dirmodels as $reldir) {
3241 $file =
dol_buildpath($reldir.
"core/modules/ticket/".$modele.
'.php', 0);
3242 if (file_exists($file)) {
3243 $classname = $modele;
3248 if ($classname !==
'') {
3249 if ($savesocid > 0) {
3250 if ($savesocid != $tickettocreate->socid) {
3252 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');
3255 if ($tickettocreate->socid > 0) {
3256 $thirdpartystatic->fetch($tickettocreate->socid);
3261 $modModuleToUseForNextValue =
new $classname();
3262 $defaultref = $modModuleToUseForNextValue->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $tickettocreate);
3264 $tickettocreate->ref = $defaultref;
3267 if ($errorforthisaction) {
3270 if (is_numeric($tickettocreate->ref) && $tickettocreate->ref <= 0) {
3272 $this->error =
'Failed to create ticket: Can\'t get a valid value for the field ref with numbering template = '.$modele.
', thirdparty id = '.$thirdpartystatic->id;
3275 $result = $tickettocreate->create($user);
3278 $this->error =
'Failed to create ticket: '.$langs->trans($tickettocreate->error);
3279 $this->errors = $tickettocreate->errors;
3282 $destdir = $conf->ticket->dir_output.
'/'.$tickettocreate->ref;
3287 foreach ($attachments as $attachment) {
3289 $typeattachment = (string) $attachment->getDisposition();
3290 $filename = $attachment->getFilename();
3291 $content = $attachment->getContent();
3295 $this->
getmsg($connection, $imapemail, $destdir);
3298 $operationslog .=
'<br>Ticket created with attachments -> id='.dol_escape_htmltag($tickettocreate->id);
3300 $operationslog .=
'<br>Ticket created without attachments -> id='.dol_escape_htmltag($tickettocreate->id);
3306 } elseif ($operation[
'type'] ==
'candidature') {
3310 $alreadycreated = $candidaturetocreate->fetch(0,
'', $msgid);
3311 if ($alreadycreated == 0) {
3312 $description = $descriptiontitle;
3318 $descriptionfull = $description;
3319 $descriptionfull =
dol_concatdesc($descriptionfull,
"----- Header");
3322 $candidaturetocreate->subject = $subject;
3323 $candidaturetocreate->message = $description;
3324 $candidaturetocreate->type_code = 0;
3325 $candidaturetocreate->category_code =
null;
3326 $candidaturetocreate->severity_code =
null;
3327 $candidaturetocreate->email = $from;
3329 $candidaturetocreate->fk_user_creat = $user->id;
3330 $candidaturetocreate->date_creation =
dol_now();
3331 $candidaturetocreate->fk_project = $projectstatic->id;
3332 $candidaturetocreate->description = $description;
3333 $candidaturetocreate->note_private = $descriptionfull;
3334 $candidaturetocreate->entity = $conf->entity;
3335 $candidaturetocreate->email_msgid = $msgid;
3336 $candidaturetocreate->email_date = $dateemail;
3337 $candidaturetocreate->status = $candidaturetocreate::STATUS_DRAFT;
3342 $errorforthisaction = $this->
overwritePropertiesOfObject($candidaturetocreate, $operation[
'actionparam'], $messagetext, $subject, $header, $operationslog);
3384 if ($errorforthisaction) {
3388 $result = $candidaturetocreate->create($user);
3391 $this->error =
'Failed to create candidature: '.implode(
', ', $candidaturetocreate->errors);
3392 $this->errors = $candidaturetocreate->errors;
3395 $operationslog .=
'<br>Candidature created without attachments -> id='.dol_escape_htmltag($candidaturetocreate->id);
3398 } elseif (substr($operation[
'type'], 0, 4) ==
'hook') {
3401 if (!is_object($hookmanager)) {
3402 include_once DOL_DOCUMENT_ROOT.
'/core/class/hookmanager.class.php';
3404 $hookmanager->initHooks([
'emailcolector']);
3407 $parameters = array(
3408 'connection' => $connection,
3409 'imapemail' => $imapemail,
3410 'overview' => $overview,
3413 'fromtext' => $fromtext,
3415 'actionparam' => $operation[
'actionparam'],
3417 'thirdpartyid' => $thirdpartyid,
3418 'objectid' => $objectid,
3419 'objectemail' => $objectemail,
3421 'messagetext' => $messagetext,
3422 'subject' => $subject,
3423 'header' => $header,
3424 'attachments' => $attachments,
3426 $reshook = $hookmanager->executeHooks(
'doCollectImapOneCollector', $parameters, $this, $operation[
'type']);
3429 $errorforthisaction++;
3430 $this->error = $hookmanager->resPrint;
3432 if ($errorforthisaction) {
3434 $operationslog .=
'<br>Hook doCollectImapOneCollector executed with error';
3436 $operationslog .=
'<br>Hook doCollectImapOneCollector executed without error';
3440 if (!$errorforactions) {
3441 $nbactiondoneforemail++;
3447 if (!$errorforactions) {
3448 if (!empty($targetdir)) {
3451 dol_syslog(
"EmailCollector::doCollectOneCollector move message ".($imapemail->getHeader()->get(
'subject')).
" to ".$targetdir, LOG_DEBUG);
3454 $operationslog .=
'<br>Move mail '.($this->uidAsString($imapemail)).
' - '.$msgid.
' to '.$targetdir;
3456 $tmptargetdir = $targetdir;
3462 $result = $imapemail->move($tmptargetdir);
3466 if (empty($result)) {
3467 dol_syslog(
"Failed to move email into target directory ".$targetdir);
3468 $operationslog .=
'<br>Failed to move email into target directory '.$targetdir;
3472 $operationslog .=
'<br>Do not move mail '.($this->uidAsString($imapemail)).
' - '.$msgid.
' (test mode)';
3475 dol_syslog(
"EmailCollector::doCollectOneCollector move message ".($this->
uidAsString($imapemail)).
" to ".$connectstringtarget, LOG_DEBUG);
3476 $operationslog .=
'<br>Move mail '.($this->uidAsString($imapemail)).
' - '.$msgid;
3478 $arrayofemailtodelete[$imapemail] = $msgid;
3483 dol_syslog(
"EmailCollector::doCollectOneCollector message '".($imapemail->getHeader()->get(
'subject')).
"' using this->host=".$this->host.
", this->access_type=".$this->acces_type.
" was set to read", LOG_DEBUG);
3485 dol_syslog(
"EmailCollector::doCollectOneCollector message ".($this->
uidAsString($imapemail)).
" to ".$connectstringtarget.
" was set to read", LOG_DEBUG);
3493 unset($objectemail);
3494 unset($projectstatic);
3495 unset($thirdpartystatic);
3496 unset($contactstatic);
3498 $nbemailprocessed++;
3500 if (!$errorforemail) {
3501 $nbactiondone += $nbactiondoneforemail;
3505 $this->db->commit();
3507 $this->db->rollback();
3511 if ($this->maxemailpercollect > 0 && $nbemailok >= $this->maxemailpercollect) {
3512 dol_syslog(
"EmailCollect::doCollectOneCollector We reach maximum of ".$nbemailok.
" collected with success, so we stop this collector now.");
3518 $this->db->rollback();
3522 $output = $langs->trans(
'XEmailsDoneYActionsDone', $nbemailprocessed, $nbemailok, $nbactiondone);
3524 dol_syslog(
"End of loop on emails", LOG_INFO, -1);
3526 $langs->load(
"admin");
3527 $output = $langs->trans(
'NoNewEmailToProcess');
3528 $output .=
' (defaultlang='.$langs->defaultlang.
')';
3533 $client->disconnect();
3535 foreach ($arrayofemailtodelete as $imapemail => $msgid) {
3536 dol_syslog(
"EmailCollect::doCollectOneCollector delete email ".$imapemail.
" ".$msgid);
3538 $operationslog .=
"<br> delete email ".$imapemail.
" ".$msgid;
3540 if (empty($mode) && empty($error)) {
3541 $res = imap_mail_move($connection, $imapemail, $targetdir, CP_UID);
3542 if ($res ==
false) {
3544 $this->error = imap_last_error();
3545 $this->errors[] = $this->error;
3547 $operationslog .=
'<br>Error in move '.$this->error;
3554 if (empty($mode) && empty($error)) {
3556 $operationslog .=
"<br>Expunge";
3558 imap_expunge($connection);
3560 imap_close($connection);
3563 $this->datelastresult = $now;
3564 $this->lastresult = $output;
3566 $this->debuginfo .=
'IMAP search array used : '.$search;
3568 $this->debuginfo .=
'IMAP search string used : '.$search;
3571 $this->debuginfo .=
'<br>Then search string into email header : '.dol_escape_htmltag($searchhead);
3573 if ($operationslog) {
3574 $this->debuginfo .= $operationslog;
3577 if (empty($error) && empty($mode)) {
3578 $this->datelastok = $now;
3581 if (!empty($this->errors)) {
3582 $this->lastresult .=
"<br>".implode(
"<br>", $this->errors);
3584 $this->codelastresult = ($error ?
'KO' :
'OK');
3590 dol_syslog(
"EmailCollector::doCollectOneCollector end", LOG_INFO);
3592 return $error ? -1 : 1;
3607 private function getmsg($mbox, $mid, $destdir =
'')
3611 global $charset, $htmlmsg, $plainmsg, $attachments;
3612 $htmlmsg = $plainmsg = $charset =
'';
3613 $attachments = array();
3620 $s = imap_fetchstructure($mbox, $mid, FT_UID);
3625 $this->
getpart($mbox, $mid, $s, 0);
3628 foreach ($s->parts as $partno0 => $p) {
3629 $this->
getpart($mbox, $mid, $p, $partno0 + 1, $destdir);
3660 private function getpart($mbox, $mid, $p, $partno, $destdir =
'')
3663 global $htmlmsg, $plainmsg, $charset, $attachments;
3667 imap_fetchbody($mbox, $mid, $partno, FT_UID) :
3668 imap_body($mbox, $mid, FT_UID);
3670 if ($p->encoding == 4) {
3671 $data = quoted_printable_decode($data);
3672 } elseif ($p->encoding == 3) {
3673 $data = base64_decode($data);
3679 if ($p->parameters) {
3680 foreach ($p->parameters as $x) {
3681 $params[strtolower($x->attribute)] = $x->value;
3684 if (!empty($p->dparameters)) {
3685 foreach ($p->dparameters as $x) {
3686 $params[strtolower($x->attribute)] = $x->value;
3689 '@phan-var-force array{filename?:string,name?:string,charset?:string} $params';
3694 if (!empty($params[
'filename']) || !empty($params[
'name'])) {
3696 $filename = $params[
'filename'] ?? $params[
'name'];
3698 $attachments[$filename] = $data;
3700 if (strlen($destdir)) {
3701 if (substr($destdir, -1) !=
'/') {
3706 $file_name_complete = $filename;
3707 $destination = $destdir.$file_name_complete;
3710 $extension = pathinfo($file_name_complete, PATHINFO_EXTENSION);
3713 $file_name = pathinfo($file_name_complete, PATHINFO_FILENAME);
3716 $file_name_original = $file_name;
3725 while (file_exists($destdir.$file_name.
".".$extension)) {
3726 $file_name = $file_name_original .
' (' . $num .
')';
3727 $file_name_complete = $file_name .
"." . $extension;
3728 $destination = $destdir.$file_name_complete;
3734 file_put_contents($destination, $data);
3739 if ($p->type == 0 && $data) {
3740 if (!empty($params[
'charset'])) {
3745 if (strtolower($p->subtype) ==
'plain') {
3746 $plainmsg .= trim($data).
"\n\n";
3748 $htmlmsg .= $data.
"<br><br>";
3750 $charset = $params[
'charset'];
3751 } elseif ($p->type == 2 && $data) {
3757 if (!empty($params[
'charset'])) {
3760 $plainmsg .= $data.
"\n\n";
3764 if (!empty($p->parts)) {
3765 foreach ($p->parts as $partno0 => $p2) {
3766 $this->
getpart($mbox, $mid, $p2, $partno.
'.'.($partno0 + 1), $destdir);
3782 if (!$string || $fromEncoding == $toEncoding) {
3785 $convertedString = function_exists(
'iconv') ? @iconv($fromEncoding, $toEncoding.
'//IGNORE', $string) :
null;
3786 if (!$convertedString && extension_loaded(
'mbstring')) {
3787 $convertedString = @mb_convert_encoding($string, $toEncoding, $fromEncoding);
3789 if (!$convertedString) {
3790 throw new Exception(
'Mime string encoding conversion failed');
3792 return $convertedString;
3811 if (function_exists(
'imap_mime_header_decode') && function_exists(
'iconv_mime_decode')) {
3812 $elements = imap_mime_header_decode($subject);
3814 if (!empty($elements)) {
3815 $num = count($elements);
3816 for ($i = 0; $i < $num; $i++) {
3817 $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));
3818 $newstring .= $stringinutf8;
3820 $subject = $newstring;
3822 } elseif (!function_exists(
'mb_decode_mimeheader')) {
3823 $subject = mb_decode_mimeheader($subject);
3824 } elseif (function_exists(
'iconv_mime_decode')) {
3825 $subject = iconv_mime_decode($subject, ICONV_MIME_DECODE_CONTINUE_ON_ERROR,
'UTF-8');
3841 require_once DOL_DOCUMENT_ROOT .
'/core/lib/images.lib.php';
3844 $maxwidthsmall = $tmparraysize[
'maxwidthsmall'];
3845 $maxheightsmall = $tmparraysize[
'maxheightsmall'];
3846 $maxwidthmini = $tmparraysize[
'maxwidthmini'];
3847 $maxheightmini = $tmparraysize[
'maxheightmini'];
3848 $quality = $tmparraysize[
'quality'];
3850 file_put_contents($destdir.
'/'.$filename, $content);
3853 vignette($destdir.
'/'.$filename, $maxwidthsmall, $maxheightsmall,
'_small', $quality,
"thumbs");
3855 vignette($destdir.
'/'.$filename, $maxwidthmini, $maxheightmini,
'_mini', $quality,
"thumbs");
3868 if (is_object($imapemail)) {
3869 return $imapemail->getAttributes()[
"uid"];
3871 return (
string) $imapemail;