|
diff --git a/htdocs/cashdesk/tpl/liste_articles.tpl.php b/htdocs/cashdesk/tpl/liste_articles.tpl.php
index 53209d735c4..c7bbfa329c2 100644
--- a/htdocs/cashdesk/tpl/liste_articles.tpl.php
+++ b/htdocs/cashdesk/tpl/liste_articles.tpl.php
@@ -45,8 +45,7 @@ $societe = new Societe($db);
$societe->fetch($thirdpartyid);
/** end add Ditto */
-$tab=array();
-$tab = $_SESSION['poscart'];
+$tab = (! empty($_SESSION['poscart'])?$_SESSION['poscart']:array());
$tab_size=count($tab);
if ($tab_size <= 0) print ' '.$langs->trans("NoArticle").'
';
diff --git a/htdocs/comm/action/class/actioncomm.class.php b/htdocs/comm/action/class/actioncomm.class.php
index a305130342a..05d5fa43c86 100644
--- a/htdocs/comm/action/class/actioncomm.class.php
+++ b/htdocs/comm/action/class/actioncomm.class.php
@@ -490,8 +490,6 @@ class ActionComm extends CommonObject
{
global $db, $user, $langs, $conf, $hookmanager;
- $this->context['createfromclone']='createfromclone';
-
$error=0;
$now=dol_now();
@@ -524,7 +522,8 @@ class ActionComm extends CommonObject
}
// Create clone
- $result=$this->create($fuser);
+ $this->context['createfromclone']='createfromclone';
+ $result=$this->create($fuser);
if ($result < 0) $error++;
if (! $error)
diff --git a/htdocs/comm/mailing/class/mailing.class.php b/htdocs/comm/mailing/class/mailing.class.php
index 11708c3b4ca..b807ea23334 100644
--- a/htdocs/comm/mailing/class/mailing.class.php
+++ b/htdocs/comm/mailing/class/mailing.class.php
@@ -279,8 +279,6 @@ class Mailing extends CommonObject
$object=new Mailing($this->db);
- $object->context['createfromclone']='createfromclone';
-
$this->db->begin();
// Load source object
@@ -314,6 +312,7 @@ class Mailing extends CommonObject
}
// Create clone
+ $object->context['createfromclone']='createfromclone';
$result=$object->create($user);
// Other options
@@ -345,7 +344,6 @@ class Mailing extends CommonObject
$sql.= " FROM ".MAIN_DB_PREFIX."mailing_cibles ";
$sql.= " WHERE fk_mailing = ".$fromid;
- dol_syslog(get_class($this)."::createFromClone", LOG_DEBUG);
$result=$this->db->query($sql);
if ($result)
{
diff --git a/htdocs/comm/propal/class/propal.class.php b/htdocs/comm/propal/class/propal.class.php
index 21caa0d4db8..55dd950abf2 100644
--- a/htdocs/comm/propal/class/propal.class.php
+++ b/htdocs/comm/propal/class/propal.class.php
@@ -1222,31 +1222,30 @@ class Propal extends CommonObject
dol_include_once('/projet/class/project.class.php');
- $this->context['createfromclone']='createfromclone';
-
$error=0;
$now=dol_now();
+ dol_syslog(__METHOD__, LOG_DEBUG);
+
+ $object = new self($this->db);
+
$this->db->begin();
- // get extrafields so they will be clone
- foreach($this->lines as $line)
- $line->fetch_optionals();
-
- // Load dest object
- $clonedObj = clone $this;
+ // Load source object
+ $object->fetch($this->id);
+ $object->fetch_lines();
$objsoc=new Societe($this->db);
// Change socid if needed
- if (! empty($socid) && $socid != $clonedObj->socid)
+ if (! empty($socid) && $socid != $object->socid)
{
if ($objsoc->fetch($socid) > 0)
{
- $clonedObj->socid = $objsoc->id;
- $clonedObj->cond_reglement_id = (! empty($objsoc->cond_reglement_id) ? $objsoc->cond_reglement_id : 0);
- $clonedObj->mode_reglement_id = (! empty($objsoc->mode_reglement_id) ? $objsoc->mode_reglement_id : 0);
- $clonedObj->fk_delivery_address = '';
+ $object->socid = $objsoc->id;
+ $object->cond_reglement_id = (! empty($objsoc->cond_reglement_id) ? $objsoc->cond_reglement_id : 0);
+ $object->mode_reglement_id = (! empty($objsoc->mode_reglement_id) ? $objsoc->mode_reglement_id : 0);
+ $object->fk_delivery_address = '';
/*if (!empty($conf->projet->enabled))
{
@@ -1258,44 +1257,51 @@ class Propal extends CommonObject
$clonedObj->fk_project = '';
}
}*/
- $clonedObj->fk_project = ''; // A cloned proposal is set by default to no project.
+ $object->fk_project = ''; // A cloned proposal is set by default to no project.
}
// reset ref_client
- $clonedObj->ref_client = '';
+ $object->ref_client = '';
// TODO Change product price if multi-prices
}
else
{
- $objsoc->fetch($clonedObj->socid);
+ $objsoc->fetch($object->socid);
}
- $clonedObj->id=0;
- $clonedObj->ref='';
- $clonedObj->statut=self::STATUS_DRAFT;
+ $object->id=0;
+ $object->ref='';
+ $object->statut=self::STATUS_DRAFT;
// Clear fields
- $clonedObj->user_author = $user->id;
- $clonedObj->user_valid = '';
- $clonedObj->date = $now;
- $clonedObj->datep = $now; // deprecated
- $clonedObj->fin_validite = $clonedObj->date + ($clonedObj->duree_validite * 24 * 3600);
- if (empty($conf->global->MAIN_KEEP_REF_CUSTOMER_ON_CLONING)) $clonedObj->ref_client = '';
+ $object->user_author = $user->id;
+ $object->user_valid = '';
+ $object->date = $now;
+ $object->datep = $now; // deprecated
+ $object->fin_validite = $object->date + ($object->duree_validite * 24 * 3600);
+ if (empty($conf->global->MAIN_KEEP_REF_CUSTOMER_ON_CLONING)) $object->ref_client = '';
// Create clone
- $result=$clonedObj->create($user);
+ $object->context['createfromclone']='createfromclone';
+ $result=$object->create($user);
if ($result < 0) $error++;
- else
+
+ if (! $error)
{
// copy internal contacts
- if ($clonedObj->copy_linked_contact($this, 'internal') < 0)
+ if ($object->copy_linked_contact($this, 'internal') < 0)
+ {
$error++;
+ }
+ }
+ if (! $error)
+ {
// copy external contacts if same company
- elseif ($this->socid == $clonedObj->socid)
+ if ($this->socid == $object->socid)
{
- if ($clonedObj->copy_linked_contact($this, 'external') < 0)
+ if ($object->copy_linked_contact($this, 'external') < 0)
$error++;
}
}
@@ -1312,13 +1318,13 @@ class Propal extends CommonObject
}
}
- unset($this->context['createfromclone']);
+ unset($object->context['createfromclone']);
// End
if (! $error)
{
$this->db->commit();
- return $clonedObj->id;
+ return $object->id;
}
else
{
diff --git a/htdocs/commande/class/commande.class.php b/htdocs/commande/class/commande.class.php
index 3292d8fc3e6..8934e293973 100644
--- a/htdocs/commande/class/commande.class.php
+++ b/htdocs/commande/class/commande.class.php
@@ -1066,8 +1066,6 @@ class Commande extends CommonOrder
$error=0;
- $this->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// get lines so they will be clone
@@ -1108,6 +1106,7 @@ class Commande extends CommonOrder
$this->ref_client = '';
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result=$this->create($user);
if ($result < 0) $error++;
diff --git a/htdocs/compta/bank/class/bankcateg.class.php b/htdocs/compta/bank/class/bankcateg.class.php
index 9efdf3932ff..dc9c1d242e8 100644
--- a/htdocs/compta/bank/class/bankcateg.class.php
+++ b/htdocs/compta/bank/class/bankcateg.class.php
@@ -280,8 +280,6 @@ class BankCateg // extends CommonObject
$object = new BankCateg($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -290,6 +288,7 @@ class BankCateg // extends CommonObject
$object->statut = 0;
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
diff --git a/htdocs/compta/facture/class/facture.class.php b/htdocs/compta/facture/class/facture.class.php
index bd3e87c8a43..3e4335774c9 100644
--- a/htdocs/compta/facture/class/facture.class.php
+++ b/htdocs/compta/facture/class/facture.class.php
@@ -951,8 +951,6 @@ class Facture extends CommonInvoice
$error=0;
- $this->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// get extrafields so they will be clone
@@ -962,8 +960,6 @@ class Facture extends CommonInvoice
// Load source object
$objFrom = clone $this;
-
-
// Change socid if needed
if (! empty($socid) && $socid != $this->socid)
{
@@ -1008,6 +1004,7 @@ class Facture extends CommonInvoice
}
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result=$this->create($user);
if ($result < 0) $error++;
else {
diff --git a/htdocs/compta/facture/class/paymentterm.class.php b/htdocs/compta/facture/class/paymentterm.class.php
index e7ea4779d10..55a3e40b55f 100644
--- a/htdocs/compta/facture/class/paymentterm.class.php
+++ b/htdocs/compta/facture/class/paymentterm.class.php
@@ -404,8 +404,6 @@ class PaymentTerm // extends CommonObject
$object=new PaymentTerm($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -417,6 +415,7 @@ class PaymentTerm // extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -430,7 +429,7 @@ class PaymentTerm // extends CommonObject
//{
//}
- unset($this->context['createfromclone']);
+ unset($object->context['createfromclone']);
// End
if (! $error)
diff --git a/htdocs/compta/sociales/class/cchargesociales.class.php b/htdocs/compta/sociales/class/cchargesociales.class.php
index 710bea7def2..9e13ffcd8a5 100644
--- a/htdocs/compta/sociales/class/cchargesociales.class.php
+++ b/htdocs/compta/sociales/class/cchargesociales.class.php
@@ -369,6 +369,7 @@ class Cchargesociales
// ...
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
@@ -378,6 +379,8 @@ class Cchargesociales
dol_syslog(__METHOD__ . ' ' . join(',', $this->errors), LOG_ERR);
}
+ unset($this->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
@@ -386,7 +389,7 @@ class Cchargesociales
} else {
$this->db->rollback();
- return - 1;
+ return -1;
}
}
diff --git a/htdocs/compta/sociales/class/paymentsocialcontribution.class.php b/htdocs/compta/sociales/class/paymentsocialcontribution.class.php
index d3c265150d4..74ddce68230 100644
--- a/htdocs/compta/sociales/class/paymentsocialcontribution.class.php
+++ b/htdocs/compta/sociales/class/paymentsocialcontribution.class.php
@@ -459,8 +459,6 @@ class PaymentSocialContribution extends CommonObject
$object=new PaymentSocialContribution($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -472,6 +470,7 @@ class PaymentSocialContribution extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -488,7 +487,7 @@ class PaymentSocialContribution extends CommonObject
}
- unset($this->context['createfromclone']);
+ unset($object->context['createfromclone']);
// End
if (! $error)
diff --git a/htdocs/contrat/class/contrat.class.php b/htdocs/contrat/class/contrat.class.php
index c543e8a0720..5929ec034d1 100644
--- a/htdocs/contrat/class/contrat.class.php
+++ b/htdocs/contrat/class/contrat.class.php
@@ -2388,8 +2388,6 @@ class Contrat extends CommonObject
dol_include_once('/projet/class/project.class.php');
- $this->context['createfromclone'] = 'createfromclone';
-
$error = 0;
$this->fetch($this->id);
@@ -2440,6 +2438,7 @@ class Contrat extends CommonObject
}
// Create clone
+ $clonedObj->context['createfromclone'] = 'createfromclone';
$result = $clonedObj->create($user);
if ($result < 0) {
$error ++;
@@ -2479,7 +2478,7 @@ class Contrat extends CommonObject
}
}
- unset($this->context['createfromclone']);
+ unset($clonedObj->context['createfromclone']);
// End
if (! $error) {
diff --git a/htdocs/core/actions_addupdatedelete.inc.php b/htdocs/core/actions_addupdatedelete.inc.php
index b8b4237cc93..63fc671d797 100644
--- a/htdocs/core/actions_addupdatedelete.inc.php
+++ b/htdocs/core/actions_addupdatedelete.inc.php
@@ -202,7 +202,7 @@ if ($action == 'confirm_clone' && $confirm == 'yes' && ! empty($permissiontoadd)
{
if ($object->id > 0)
{
- // Because createFromClone modifies the object, we must clone it so that we can restore it later
+ // Because createFromClone modifies the object, we must clone it so that we can restore it later if error
$orig = clone $object;
$result=$object->createFromClone($user, $object->id);
diff --git a/htdocs/core/class/ctyperesource.class.php b/htdocs/core/class/ctyperesource.class.php
index f4e74128747..95c642772e2 100644
--- a/htdocs/core/class/ctyperesource.class.php
+++ b/htdocs/core/class/ctyperesource.class.php
@@ -427,6 +427,7 @@ class Ctyperesource
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
@@ -436,6 +437,8 @@ class Ctyperesource
dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR);
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
@@ -444,7 +447,7 @@ class Ctyperesource
} else {
$this->db->rollback();
- return - 1;
+ return -1;
}
}
diff --git a/htdocs/core/class/emailsenderprofile.class.php b/htdocs/core/class/emailsenderprofile.class.php
index b30f79f0bba..3a1fba460c4 100644
--- a/htdocs/core/class/emailsenderprofile.class.php
+++ b/htdocs/core/class/emailsenderprofile.class.php
@@ -207,6 +207,8 @@ class EmailSenderProfile extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/cron/class/cronjob.class.php b/htdocs/cron/class/cronjob.class.php
index 6873bff157e..f619befab0d 100644
--- a/htdocs/cron/class/cronjob.class.php
+++ b/htdocs/cron/class/cronjob.class.php
@@ -757,8 +757,6 @@ class Cronjob extends CommonObject
$object=new Cronjob($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -770,6 +768,7 @@ class Cronjob extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -782,10 +781,9 @@ class Cronjob extends CommonObject
//if (! $error)
//{
-
//}
- unset($this->context['createfromclone']);
+ unset($object->context['createfromclone']);
// End
if (! $error)
diff --git a/htdocs/don/class/paymentdonation.class.php b/htdocs/don/class/paymentdonation.class.php
index b0e3a80b082..662b165ddf4 100644
--- a/htdocs/don/class/paymentdonation.class.php
+++ b/htdocs/don/class/paymentdonation.class.php
@@ -419,8 +419,6 @@ class PaymentDonation extends CommonObject
$object=new PaymentDonation($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -432,6 +430,7 @@ class PaymentDonation extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -444,11 +443,9 @@ class PaymentDonation extends CommonObject
if (! $error)
{
-
-
}
- unset($this->context['createfromclone']);
+ unset($object->context['createfromclone']);
// End
if (! $error)
diff --git a/htdocs/ecm/class/ecmfiles.class.php b/htdocs/ecm/class/ecmfiles.class.php
index 781833169dd..efc5af1310c 100644
--- a/htdocs/ecm/class/ecmfiles.class.php
+++ b/htdocs/ecm/class/ecmfiles.class.php
@@ -732,6 +732,7 @@ class EcmFiles extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
@@ -741,6 +742,8 @@ class EcmFiles extends CommonObject
dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR);
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/emailcollector/class/emailcollector.class.php b/htdocs/emailcollector/class/emailcollector.class.php
index fc0b8673332..e00adfad724 100644
--- a/htdocs/emailcollector/class/emailcollector.class.php
+++ b/htdocs/emailcollector/class/emailcollector.class.php
@@ -34,304 +34,306 @@ require_once DOL_DOCUMENT_ROOT . '/compta/facture/class/facture.class.php';
*/
class EmailCollector extends CommonObject
{
- /**
- * @var string ID to identify managed object
- */
- public $element = 'emailcollector';
- /**
- * @var string Name of table without prefix where object is stored
- */
- public $table_element = 'emailcollector_emailcollector';
- /**
- * @var int Does emailcollector support multicompany module ? 0=No test on entity, 1=Test with field entity, 2=Test with link by societe
- */
- public $ismultientitymanaged = 1;
- /**
- * @var int Does emailcollector support extrafields ? 0=No, 1=Yes
- */
- public $isextrafieldmanaged = 0;
- /**
- * @var string String with name of icon for emailcollector. Must be the part after the 'object_' into object_emailcollector.png
- */
- public $picto = 'generic';
+ /**
+ * @var string ID to identify managed object
+ */
+ public $element = 'emailcollector';
+ /**
+ * @var string Name of table without prefix where object is stored
+ */
+ public $table_element = 'emailcollector_emailcollector';
+ /**
+ * @var int Does emailcollector support multicompany module ? 0=No test on entity, 1=Test with field entity, 2=Test with link by societe
+ */
+ public $ismultientitymanaged = 1;
+ /**
+ * @var int Does emailcollector support extrafields ? 0=No, 1=Yes
+ */
+ public $isextrafieldmanaged = 0;
+ /**
+ * @var string String with name of icon for emailcollector. Must be the part after the 'object_' into object_emailcollector.png
+ */
+ public $picto = 'generic';
- /**
- * @var int Field with ID of parent key if this field has a parent
- */
- public $fk_element = 'fk_emailcollector';
+ /**
+ * @var int Field with ID of parent key if this field has a parent
+ */
+ public $fk_element = 'fk_emailcollector';
- /**
- * @var array Array of child tables (child tables to delete before deleting a record)
- */
- protected $childtables=array('emailcollector_emailcollectorfilter', 'emailcollector_emailcollectoraction');
+ /**
+ * @var array Array of child tables (child tables to delete before deleting a record)
+ */
+ protected $childtables=array('emailcollector_emailcollectorfilter', 'emailcollector_emailcollectoraction');
- /**
- * 'type' if the field format.
- * 'label' the translation key.
- * 'enabled' is a condition when the field must be managed.
- * 'visible' says if field is visible in list (Examples: 0=Not visible, 1=Visible on list and create/update/view forms, 2=Visible on list only. Using a negative value means field is not shown by default on list but can be selected for viewing)
- * 'notnull' is set to 1 if not null in database. Set to -1 if we must set data to null if empty ('' or 0).
- * 'default' is a default value for creation (can still be replaced by the global setup of default values)
- * 'index' if we want an index in database.
- * 'foreignkey'=>'tablename.field' if the field is a foreign key (it is recommanded to name the field fk_...).
- * 'position' is the sort order of field.
- * 'searchall' is 1 if we want to search in this field when making a search from the quick search button.
- * 'isameasure' must be set to 1 if you want to have a total on list for this field. Field type must be summable like integer or double(24,8).
- * 'css' is the CSS style to use on field. For example: 'maxwidth200'
- * 'help' is a string visible as a tooltip on field
- * 'comment' is not used. You can store here any text of your choice. It is not used by application.
- * 'showoncombobox' if value of the field must be visible into the label of the combobox that list record
- * 'arraykeyval' to set list of value if type is a list of predefined values. For example: array("0"=>"Draft","1"=>"Active","-1"=>"Cancel")
- */
+ /**
+ * 'type' if the field format.
+ * 'label' the translation key.
+ * 'enabled' is a condition when the field must be managed.
+ * 'visible' says if field is visible in list (Examples: 0=Not visible, 1=Visible on list and create/update/view forms, 2=Visible on list only. Using a negative value means field is not shown by default on list but can be selected for viewing)
+ * 'notnull' is set to 1 if not null in database. Set to -1 if we must set data to null if empty ('' or 0).
+ * 'default' is a default value for creation (can still be replaced by the global setup of default values)
+ * 'index' if we want an index in database.
+ * 'foreignkey'=>'tablename.field' if the field is a foreign key (it is recommanded to name the field fk_...).
+ * 'position' is the sort order of field.
+ * 'searchall' is 1 if we want to search in this field when making a search from the quick search button.
+ * 'isameasure' must be set to 1 if you want to have a total on list for this field. Field type must be summable like integer or double(24,8).
+ * 'css' is the CSS style to use on field. For example: 'maxwidth200'
+ * 'help' is a string visible as a tooltip on field
+ * 'comment' is not used. You can store here any text of your choice. It is not used by application.
+ * 'showoncombobox' if value of the field must be visible into the label of the combobox that list record
+ * 'arraykeyval' to set list of value if type is a list of predefined values. For example: array("0"=>"Draft","1"=>"Active","-1"=>"Cancel")
+ */
- // BEGIN MODULEBUILDER PROPERTIES
- /**
- * @var array Array with all fields and their property. Do not use it as a static var. It may be modified by constructor.
- */
- public $fields=array(
- 'rowid' => array('type'=>'integer', 'label'=>'TechnicalID','visible'=>2, 'enabled'=>1, 'position'=>1, 'notnull'=>1, 'index'=>1),
- 'entity' =>array('type'=>'integer', 'label'=>'Entity', 'enabled'=>1, 'visible'=>0, 'default'=>1, 'notnull'=>1, 'index'=>1, 'position'=>20),
- 'ref' =>array('type'=>'varchar(128)', 'label'=>'Ref', 'enabled'=>1, 'visible'=>1, 'notnull'=>1, 'showoncombobox'=>1, 'index'=>1, 'position'=>10, 'searchall'=>1, 'help'=>'Example: MyCollector1'),
- 'label' => array('type'=>'varchar(255)', 'label'=>'Label', 'visible'=>1, 'enabled'=>1, 'position'=>30, 'notnull'=>-1, 'searchall'=>1, 'help'=>'Example: My Email collector'),
- 'description' => array('type'=>'text', 'label'=>'Description', 'visible'=>-1, 'enabled'=>1, 'position'=>60, 'notnull'=>-1),
- 'host' => array('type'=>'varchar(255)', 'label'=>'EMailHost', 'visible'=>1, 'enabled'=>1, 'position'=>100, 'notnull'=>1, 'searchall'=>1, 'comment'=>"IMAP server", 'help'=>'Example: imap.gmail.com'),
- 'login' => array('type'=>'varchar(128)', 'label'=>'Login', 'visible'=>1, 'enabled'=>1, 'position'=>101, 'notnull'=>-1, 'index'=>1, 'comment'=>"IMAP login", 'help'=>'Example: myaccount@gmail.com'),
- 'password' => array('type'=>'password', 'label'=>'Password', 'visible'=>-1, 'enabled'=>1, 'position'=>102, 'notnull'=>-1, 'comment'=>"IMAP password"),
- 'source_directory' => array('type'=>'varchar(255)', 'label'=>'MailboxSourceDirectory', 'visible'=>-1, 'enabled'=>1, 'position'=>103, 'notnull'=>1, 'default' => 'Inbox', 'help'=>'Example: INBOX'),
- //'filter' => array('type'=>'text', 'label'=>'Filter', 'visible'=>1, 'enabled'=>1, 'position'=>105),
- //'actiontodo' => array('type'=>'varchar(255)', 'label'=>'ActionToDo', 'visible'=>1, 'enabled'=>1, 'position'=>106),
- 'target_directory' => array('type'=>'varchar(255)', 'label'=>'MailboxTargetDirectory', 'visible'=>1, 'enabled'=>1, 'position'=>110, 'notnull'=>0, 'comment'=>"Where to store messages once processed"),
- 'datelastresult' => array('type'=>'datetime', 'label'=>'DateLastResult', 'visible'=>1, 'enabled'=>'$action != "create" && $action != "edit"', 'position'=>121, 'notnull'=>-1,),
- 'codelastresult' => array('type'=>'varchar(16)', 'label'=>'CodeLastResult', 'visible'=>1, 'enabled'=>'$action != "create" && $action != "edit"', 'position'=>122, 'notnull'=>-1,),
- 'lastresult' => array('type'=>'varchar(255)', 'label'=>'LastResult', 'visible'=>1, 'enabled'=>'$action != "create" && $action != "edit"', 'position'=>123, 'notnull'=>-1,),
- 'note_public' => array('type'=>'html', 'label'=>'NotePublic', 'visible'=>0, 'enabled'=>1, 'position'=>61, 'notnull'=>-1,),
- 'note_private' => array('type'=>'html', 'label'=>'NotePrivate', 'visible'=>0, 'enabled'=>1, 'position'=>62, 'notnull'=>-1,),
- 'date_creation' => array('type'=>'datetime', 'label'=>'DateCreation', 'visible'=>-2, 'enabled'=>1, 'position'=>500, 'notnull'=>1,),
- 'tms' => array('type'=>'timestamp', 'label'=>'DateModification', 'visible'=>-2, 'enabled'=>1, 'position'=>501, 'notnull'=>1,),
- //'date_validation' =>array('type'=>'datetime', 'label'=>'DateCreation', 'enabled'=>1, 'visible'=>-2, 'position'=>502),
- 'fk_user_creat' => array('type'=>'integer:User:user/class/user.class.php', 'label'=>'UserAuthor', 'visible'=>-2, 'enabled'=>1, 'position'=>510, 'notnull'=>1,),
- 'fk_user_modif' => array('type'=>'integer:User:user/class/user.class.php', 'label'=>'UserModif', 'visible'=>-2, 'enabled'=>1, 'position'=>511, 'notnull'=>-1,),
- //'fk_user_valid' =>array('type'=>'integer', 'label'=>'UserValidation', 'enabled'=>1, 'visible'=>-1, 'position'=>512),
- 'import_key' => array('type'=>'varchar(14)', 'label'=>'ImportId', 'visible'=>-2, 'enabled'=>1, 'position'=>1000, 'notnull'=>-1,),
- 'status' => array('type'=>'integer', 'label'=>'Status', 'visible'=>1, 'enabled'=>1, 'position'=>1000, 'notnull'=>1, 'index'=>1, 'arrayofkeyval'=>array('0'=>'Inactive', '1'=>'Active'))
- );
+ // BEGIN MODULEBUILDER PROPERTIES
+ /**
+ * @var array Array with all fields and their property. Do not use it as a static var. It may be modified by constructor.
+ */
+ public $fields=array(
+ 'rowid' => array('type'=>'integer', 'label'=>'TechnicalID','visible'=>2, 'enabled'=>1, 'position'=>1, 'notnull'=>1, 'index'=>1),
+ 'entity' =>array('type'=>'integer', 'label'=>'Entity', 'enabled'=>1, 'visible'=>0, 'default'=>1, 'notnull'=>1, 'index'=>1, 'position'=>20),
+ 'ref' =>array('type'=>'varchar(128)', 'label'=>'Ref', 'enabled'=>1, 'visible'=>1, 'notnull'=>1, 'showoncombobox'=>1, 'index'=>1, 'position'=>10, 'searchall'=>1, 'help'=>'Example: MyCollector1'),
+ 'label' => array('type'=>'varchar(255)', 'label'=>'Label', 'visible'=>1, 'enabled'=>1, 'position'=>30, 'notnull'=>-1, 'searchall'=>1, 'help'=>'Example: My Email collector'),
+ 'description' => array('type'=>'text', 'label'=>'Description', 'visible'=>-1, 'enabled'=>1, 'position'=>60, 'notnull'=>-1),
+ 'host' => array('type'=>'varchar(255)', 'label'=>'EMailHost', 'visible'=>1, 'enabled'=>1, 'position'=>100, 'notnull'=>1, 'searchall'=>1, 'comment'=>"IMAP server", 'help'=>'Example: imap.gmail.com'),
+ 'login' => array('type'=>'varchar(128)', 'label'=>'Login', 'visible'=>1, 'enabled'=>1, 'position'=>101, 'notnull'=>-1, 'index'=>1, 'comment'=>"IMAP login", 'help'=>'Example: myaccount@gmail.com'),
+ 'password' => array('type'=>'password', 'label'=>'Password', 'visible'=>-1, 'enabled'=>1, 'position'=>102, 'notnull'=>-1, 'comment'=>"IMAP password"),
+ 'source_directory' => array('type'=>'varchar(255)', 'label'=>'MailboxSourceDirectory', 'visible'=>-1, 'enabled'=>1, 'position'=>103, 'notnull'=>1, 'default' => 'Inbox', 'help'=>'Example: INBOX'),
+ //'filter' => array('type'=>'text', 'label'=>'Filter', 'visible'=>1, 'enabled'=>1, 'position'=>105),
+ //'actiontodo' => array('type'=>'varchar(255)', 'label'=>'ActionToDo', 'visible'=>1, 'enabled'=>1, 'position'=>106),
+ 'target_directory' => array('type'=>'varchar(255)', 'label'=>'MailboxTargetDirectory', 'visible'=>1, 'enabled'=>1, 'position'=>110, 'notnull'=>0, 'comment'=>"Where to store messages once processed"),
+ 'datelastresult' => array('type'=>'datetime', 'label'=>'DateLastResult', 'visible'=>1, 'enabled'=>'$action != "create" && $action != "edit"', 'position'=>121, 'notnull'=>-1,),
+ 'codelastresult' => array('type'=>'varchar(16)', 'label'=>'CodeLastResult', 'visible'=>1, 'enabled'=>'$action != "create" && $action != "edit"', 'position'=>122, 'notnull'=>-1,),
+ 'lastresult' => array('type'=>'varchar(255)', 'label'=>'LastResult', 'visible'=>1, 'enabled'=>'$action != "create" && $action != "edit"', 'position'=>123, 'notnull'=>-1,),
+ 'note_public' => array('type'=>'html', 'label'=>'NotePublic', 'visible'=>0, 'enabled'=>1, 'position'=>61, 'notnull'=>-1,),
+ 'note_private' => array('type'=>'html', 'label'=>'NotePrivate', 'visible'=>0, 'enabled'=>1, 'position'=>62, 'notnull'=>-1,),
+ 'date_creation' => array('type'=>'datetime', 'label'=>'DateCreation', 'visible'=>-2, 'enabled'=>1, 'position'=>500, 'notnull'=>1,),
+ 'tms' => array('type'=>'timestamp', 'label'=>'DateModification', 'visible'=>-2, 'enabled'=>1, 'position'=>501, 'notnull'=>1,),
+ //'date_validation' =>array('type'=>'datetime', 'label'=>'DateCreation', 'enabled'=>1, 'visible'=>-2, 'position'=>502),
+ 'fk_user_creat' => array('type'=>'integer:User:user/class/user.class.php', 'label'=>'UserAuthor', 'visible'=>-2, 'enabled'=>1, 'position'=>510, 'notnull'=>1,),
+ 'fk_user_modif' => array('type'=>'integer:User:user/class/user.class.php', 'label'=>'UserModif', 'visible'=>-2, 'enabled'=>1, 'position'=>511, 'notnull'=>-1,),
+ //'fk_user_valid' =>array('type'=>'integer', 'label'=>'UserValidation', 'enabled'=>1, 'visible'=>-1, 'position'=>512),
+ 'import_key' => array('type'=>'varchar(14)', 'label'=>'ImportId', 'visible'=>-2, 'enabled'=>1, 'position'=>1000, 'notnull'=>-1,),
+ 'status' => array('type'=>'integer', 'label'=>'Status', 'visible'=>1, 'enabled'=>1, 'position'=>1000, 'notnull'=>1, 'index'=>1, 'arrayofkeyval'=>array('0'=>'Inactive', '1'=>'Active'))
+ );
- /**
- * @var int ID
- */
- public $rowid;
+ /**
+ * @var int ID
+ */
+ public $rowid;
- /**
- * @var string Ref
- */
- public $ref;
+ /**
+ * @var string Ref
+ */
+ public $ref;
- /**
- * @var int Entity
- */
- public $entity;
+ /**
+ * @var int Entity
+ */
+ public $entity;
- /**
- * @var string label
- */
- public $label;
+ /**
+ * @var string label
+ */
+ public $label;
- /**
- * @var int Status
- */
- public $status;
+ /**
+ * @var int Status
+ */
+ public $status;
- public $date_creation;
- public $tms;
+ public $date_creation;
+ public $tms;
- /**
- * @var int ID
- */
- public $fk_user_creat;
+ /**
+ * @var int ID
+ */
+ public $fk_user_creat;
- /**
- * @var int ID
- */
- public $fk_user_modif;
+ /**
+ * @var int ID
+ */
+ public $fk_user_modif;
- public $import_key;
+ public $import_key;
- public $host;
- public $login;
- public $password;
- public $source_directory;
+ public $host;
+ public $login;
+ public $password;
+ public $source_directory;
public $target_directory;
public $datelastresult;
- public $lastresult;
- // END MODULEBUILDER PROPERTIES
+ public $lastresult;
+ // END MODULEBUILDER PROPERTIES
- public $filters;
- public $actions;
+ public $filters;
+ public $actions;
- /**
- * Constructor
- *
- * @param DoliDb $db Database handler
- */
- public function __construct(DoliDB $db)
- {
- global $conf, $langs, $user;
-
- $this->db = $db;
-
- if (empty($conf->global->MAIN_SHOW_TECHNICAL_ID) && isset($this->fields['rowid'])) $this->fields['rowid']['visible']=0;
- if (empty($conf->multicompany->enabled) && isset($this->fields['entity'])) $this->fields['entity']['enabled']=0;
-
- // Unset fields that are disabled
- foreach($this->fields as $key => $val)
- {
- if (isset($val['enabled']) && empty($val['enabled']))
- {
- unset($this->fields[$key]);
- }
- }
-
- // Translate some data of arrayofkeyval
- foreach($this->fields as $key => $val)
- {
- if (is_array($this->fields['status']['arrayofkeyval']))
- {
- foreach($this->fields['status']['arrayofkeyval'] as $key2 => $val2)
- {
- $this->fields['status']['arrayofkeyval'][$key2]=$langs->trans($val2);
- }
- }
- }
- }
-
- /**
- * Create object into database
- *
- * @param User $user User that creates
- * @param bool $notrigger false=launch triggers after, true=disable triggers
- * @return int <0 if KO, Id of created object if OK
- */
- public function create(User $user, $notrigger = false)
- {
- return $this->createCommon($user, $notrigger);
- }
-
- /**
- * Clone and object into another one
- *
- * @param User $user User that creates
- * @param int $fromid Id of object to clone
- * @return mixed New object created, <0 if KO
- */
- public function createFromClone(User $user, $fromid)
- {
- global $langs, $hookmanager, $extrafields;
- $error = 0;
-
- dol_syslog(__METHOD__, LOG_DEBUG);
-
- $object = new self($this->db);
-
- $this->db->begin();
-
- // Load source object
- $object->fetchCommon($fromid);
- // Reset some properties
- unset($object->id);
- unset($object->fk_user_creat);
- unset($object->import_key);
-
- // Clear fields
- $object->ref = "copy_of_".$object->ref;
- $object->title = $langs->trans("CopyOf")." ".$object->title;
- // ...
- // Clear extrafields that are unique
- if (is_array($object->array_options) && count($object->array_options) > 0)
- {
- $extrafields->fetch_name_optionals_label($this->element);
- foreach($object->array_options as $key => $option)
- {
- $shortkey = preg_replace('/options_/', '', $key);
- if (! empty($extrafields->attributes[$this->element]['unique'][$shortkey]))
- {
- //var_dump($key); var_dump($clonedObj->array_options[$key]); exit;
- unset($object->array_options[$key]);
- }
- }
- }
-
- // Create clone
- $object->context['createfromclone'] = 'createfromclone';
- $result = $object->createCommon($user);
- if ($result < 0) {
- $error++;
- $this->error = $object->error;
- $this->errors = $object->errors;
- }
-
- // End
- if (!$error) {
- $this->db->commit();
- return $object;
- } else {
- $this->db->rollback();
- return -1;
- }
- }
-
- /**
- * Load object in memory from the database
- *
- * @param int $id Id object
- * @param string $ref Ref
- * @return int <0 if KO, 0 if not found, >0 if OK
- */
- public function fetch($id, $ref = null)
- {
- $result = $this->fetchCommon($id, $ref);
- //if ($result > 0 && ! empty($this->table_element_line)) $this->fetchLines();
- return $result;
- }
-
- /**
- * Load object lines in memory from the database
- *
- * @return int <0 if KO, 0 if not found, >0 if OK
- */
- /*public function fetchLines()
- {
- $this->lines=array();
-
- // Load lines with object EmailCollectorLine
-
- return count($this->lines)?1:0;
- }*/
-
- /**
- * Fetch all account and load objects into an array
- *
- * @param User $user User
- * @param int $activeOnly filter if active
- * @param string $sortfield field for sorting
- * @param string $sortorder sorting order
- * @param int $limit sort limit
- * @param int $page page to start on
- * @return array Array with key => EmailCollector object
- */
- public function fetchAll(User $user, $activeOnly = 0, $sortfield = 's.rowid', $sortorder = 'ASC', $limit = 100, $page = 0)
+ /**
+ * Constructor
+ *
+ * @param DoliDb $db Database handler
+ */
+ public function __construct(DoliDB $db)
{
- global $langs;
+ global $conf, $langs, $user;
- $obj_ret = array();
+ $this->db = $db;
+
+ if (empty($conf->global->MAIN_SHOW_TECHNICAL_ID) && isset($this->fields['rowid'])) $this->fields['rowid']['visible']=0;
+ if (empty($conf->multicompany->enabled) && isset($this->fields['entity'])) $this->fields['entity']['enabled']=0;
+
+ // Unset fields that are disabled
+ foreach($this->fields as $key => $val)
+ {
+ if (isset($val['enabled']) && empty($val['enabled']))
+ {
+ unset($this->fields[$key]);
+ }
+ }
+
+ // Translate some data of arrayofkeyval
+ foreach($this->fields as $key => $val)
+ {
+ if (is_array($this->fields['status']['arrayofkeyval']))
+ {
+ foreach($this->fields['status']['arrayofkeyval'] as $key2 => $val2)
+ {
+ $this->fields['status']['arrayofkeyval'][$key2]=$langs->trans($val2);
+ }
+ }
+ }
+ }
+
+ /**
+ * Create object into database
+ *
+ * @param User $user User that creates
+ * @param bool $notrigger false=launch triggers after, true=disable triggers
+ * @return int <0 if KO, Id of created object if OK
+ */
+ public function create(User $user, $notrigger = false)
+ {
+ return $this->createCommon($user, $notrigger);
+ }
+
+ /**
+ * Clone and object into another one
+ *
+ * @param User $user User that creates
+ * @param int $fromid Id of object to clone
+ * @return mixed New object created, <0 if KO
+ */
+ public function createFromClone(User $user, $fromid)
+ {
+ global $langs, $hookmanager, $extrafields;
+ $error = 0;
+
+ dol_syslog(__METHOD__, LOG_DEBUG);
+
+ $object = new self($this->db);
+
+ $this->db->begin();
+
+ // Load source object
+ $object->fetchCommon($fromid);
+ // Reset some properties
+ unset($object->id);
+ unset($object->fk_user_creat);
+ unset($object->import_key);
+
+ // Clear fields
+ $object->ref = "copy_of_".$object->ref;
+ $object->title = $langs->trans("CopyOf")." ".$object->title;
+ // ...
+ // Clear extrafields that are unique
+ if (is_array($object->array_options) && count($object->array_options) > 0)
+ {
+ $extrafields->fetch_name_optionals_label($this->element);
+ foreach($object->array_options as $key => $option)
+ {
+ $shortkey = preg_replace('/options_/', '', $key);
+ if (! empty($extrafields->attributes[$this->element]['unique'][$shortkey]))
+ {
+ //var_dump($key); var_dump($clonedObj->array_options[$key]); exit;
+ unset($object->array_options[$key]);
+ }
+ }
+ }
+
+ // Create clone
+ $object->context['createfromclone'] = 'createfromclone';
+ $result = $object->createCommon($user);
+ if ($result < 0) {
+ $error++;
+ $this->error = $object->error;
+ $this->errors = $object->errors;
+ }
+
+ unset($object->context['createfromclone']);
+
+ // End
+ if (!$error) {
+ $this->db->commit();
+ return $object;
+ } else {
+ $this->db->rollback();
+ return -1;
+ }
+ }
+
+ /**
+ * Load object in memory from the database
+ *
+ * @param int $id Id object
+ * @param string $ref Ref
+ * @return int <0 if KO, 0 if not found, >0 if OK
+ */
+ public function fetch($id, $ref = null)
+ {
+ $result = $this->fetchCommon($id, $ref);
+ //if ($result > 0 && ! empty($this->table_element_line)) $this->fetchLines();
+ return $result;
+ }
+
+ /**
+ * Load object lines in memory from the database
+ *
+ * @return int <0 if KO, 0 if not found, >0 if OK
+ */
+ /*public function fetchLines()
+ {
+ $this->lines=array();
+
+ // Load lines with object EmailCollectorLine
+
+ return count($this->lines)?1:0;
+ }*/
+
+ /**
+ * Fetch all account and load objects into an array
+ *
+ * @param User $user User
+ * @param int $activeOnly filter if active
+ * @param string $sortfield field for sorting
+ * @param string $sortorder sorting order
+ * @param int $limit sort limit
+ * @param int $page page to start on
+ * @return array Array with key => EmailCollector object
+ */
+ public function fetchAll(User $user, $activeOnly = 0, $sortfield = 's.rowid', $sortorder = 'ASC', $limit = 100, $page = 0)
+ {
+ global $langs;
+
+ $obj_ret = array();
$socid = $user->societe_id ? $user->societe_id : '';
- $sql = "SELECT s.rowid";
+ $sql = "SELECT s.rowid";
$sql.= " FROM ".MAIN_DB_PREFIX."emailcollector_emailcollector as s";
$sql.= ' WHERE s.entity IN ('.getEntity('emailcollector').')';
if ($activeOnly) {
@@ -360,54 +362,54 @@ class EmailCollector extends CommonObject
$i++;
}
} else {
- $this->errors[] = 'EmailCollector::fetchAll Error when retrieve emailcollector list';
+ $this->errors[] = 'EmailCollector::fetchAll Error when retrieve emailcollector list';
dol_syslog('EmailCollector::fetchAll Error when retrieve emailcollector list', LOG_ERR);
$ret = -1;
}
if (! count($obj_ret)) {
- dol_syslog('EmailCollector::fetchAll No emailcollector found', LOG_DEBUG);
+ dol_syslog('EmailCollector::fetchAll No emailcollector found', LOG_DEBUG);
}
return $obj_ret;
- }
+ }
- /**
- * Update object into database
- *
- * @param User $user User that modifies
- * @param bool $notrigger false=launch triggers after, true=disable triggers
- * @return int <0 if KO, >0 if OK
- */
- public function update(User $user, $notrigger = false)
- {
- return $this->updateCommon($user, $notrigger);
- }
+ /**
+ * Update object into database
+ *
+ * @param User $user User that modifies
+ * @param bool $notrigger false=launch triggers after, true=disable triggers
+ * @return int <0 if KO, >0 if OK
+ */
+ public function update(User $user, $notrigger = false)
+ {
+ return $this->updateCommon($user, $notrigger);
+ }
- /**
- * Delete object in database
- *
- * @param User $user User that deletes
- * @param bool $notrigger false=launch triggers after, true=disable triggers
- * @return int <0 if KO, >0 if OK
- */
- public function delete(User $user, $notrigger = false)
- {
- return $this->deleteCommon($user, $notrigger, 1);
- }
+ /**
+ * Delete object in database
+ *
+ * @param User $user User that deletes
+ * @param bool $notrigger false=launch triggers after, true=disable triggers
+ * @return int <0 if KO, >0 if OK
+ */
+ public function delete(User $user, $notrigger = false)
+ {
+ return $this->deleteCommon($user, $notrigger, 1);
+ }
- /**
- * Return a link to the object card (with optionaly the picto)
- *
- * @param int $withpicto Include picto in link (0=No picto, 1=Include picto into link, 2=Only picto)
- * @param string $option On what the link point to ('nolink', ...)
+ /**
+ * Return a link to the object card (with optionaly the picto)
+ *
+ * @param int $withpicto Include picto in link (0=No picto, 1=Include picto into link, 2=Only picto)
+ * @param string $option On what the link point to ('nolink', ...)
* @param int $notooltip 1=Disable tooltip
* @param string $morecss Add more css on link
* @param int $save_lastsearch_value -1=Auto, 0=No save of lastsearch_values when clicking, 1=Save lastsearch_values whenclicking
- * @return string String with URL
- */
- function getNomUrl($withpicto=0, $option='', $notooltip=0, $morecss='', $save_lastsearch_value=-1)
- {
- global $db, $conf, $langs, $hookmanager;
+ * @return string String with URL
+ */
+ function getNomUrl($withpicto=0, $option='', $notooltip=0, $morecss='', $save_lastsearch_value=-1)
+ {
+ global $db, $conf, $langs, $hookmanager;
global $dolibarr_main_authentication, $dolibarr_main_demo;
global $menumanager;
@@ -424,12 +426,12 @@ class EmailCollector extends CommonObject
if ($option != 'nolink')
{
- // Add param to save lastsearch_values or not
- $add_save_lastsearch_values=($save_lastsearch_value == 1 ? 1 : 0);
- if ($save_lastsearch_value == -1 && preg_match('/list\.php/', $_SERVER["PHP_SELF"])) {
+ // Add param to save lastsearch_values or not
+ $add_save_lastsearch_values=($save_lastsearch_value == 1 ? 1 : 0);
+ if ($save_lastsearch_value == -1 && preg_match('/list\.php/', $_SERVER["PHP_SELF"])) {
$add_save_lastsearch_values=1;
}
- if ($add_save_lastsearch_values) {
+ if ($add_save_lastsearch_values) {
$url.='&save_lastsearch_values=1';
}
}
@@ -454,1092 +456,1092 @@ class EmailCollector extends CommonObject
}
else $linkclose = ($morecss?' class="'.$morecss.'"':'');
- $linkstart = '';
- $linkend='';
-
- $result .= $linkstart;
- if ($withpicto) $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);
- if ($withpicto != 2) $result.= $this->ref;
- $result .= $linkend;
- //if ($withpicto != 2) $result.=(($addlabel && $this->label) ? $sep . dol_trunc($this->label, ($addlabel > 1 ? $addlabel : 0)) : '');
-
- global $action,$hookmanager;
- $hookmanager->initHooks(array('emailcollectordao'));
- $parameters=array('id'=>$this->id, 'getnomurl'=>$result);
- $reshook=$hookmanager->executeHooks('getNomUrl',$parameters,$this,$action); // Note that $action and $object may have been modified by some hooks
- if ($reshook > 0) $result = $hookmanager->resPrint;
- else $result .= $hookmanager->resPrint;
-
- return $result;
- }
-
- /**
- * Return label of the status
- *
- * @param int $mode 0=long label, 1=short label, 2=Picto + short label, 3=Picto, 4=Picto + long label, 5=Short label + Picto, 6=Long label + Picto
- * @return string Label of status
- */
- public function getLibStatut($mode=0)
- {
- return $this->LibStatut($this->status, $mode);
- }
-
- // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
- /**
- * Return the status
- *
- * @param int $status Id status
- * @param int $mode 0=long label, 1=short label, 2=Picto + short label, 3=Picto, 4=Picto + long label, 5=Short label + Picto, 6=Long label + Picto
- * @return string Label of status
- */
- public function LibStatut($status, $mode=0)
- {
- // phpcs:enable
- if (empty($this->labelstatus))
- {
- global $langs;
- //$langs->load("mymodule");
- $this->labelstatus[1] = $langs->trans('Enabled');
- $this->labelstatus[0] = $langs->trans('Disabled');
- }
-
- if ($mode == 0)
- {
- return $this->labelstatus[$status];
- }
- elseif ($mode == 1)
- {
- return $this->labelstatus[$status];
- }
- elseif ($mode == 2)
- {
- if ($status == 1) return img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
- elseif ($status == 0) return img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
- }
- elseif ($mode == 3)
- {
- if ($status == 1) return img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle');
- elseif ($status == 0) return img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle');
- }
- elseif ($mode == 4)
- {
- if ($status == 1) return img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
- elseif ($status == 0) return img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
- }
- elseif ($mode == 5)
- {
- if ($status == 1) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle');
- elseif ($status == 0) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle');
- }
- elseif ($mode == 6)
- {
- if ($status == 1) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle');
- elseif ($status == 0) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle');
- }
- }
-
- /**
- * Charge les informations d'ordre info dans l'objet commande
- *
- * @param int $id Id of order
- * @return void
- */
- public function info($id)
- {
- $sql = 'SELECT rowid, date_creation as datec, tms as datem,';
- $sql.= ' fk_user_creat, fk_user_modif';
- $sql.= ' FROM '.MAIN_DB_PREFIX.$this->table_element.' as t';
- $sql.= ' WHERE t.rowid = '.$id;
- $result=$this->db->query($sql);
- if ($result)
- {
- if ($this->db->num_rows($result))
- {
- $obj = $this->db->fetch_object($result);
- $this->id = $obj->rowid;
- if ($obj->fk_user_author)
- {
- $cuser = new User($this->db);
- $cuser->fetch($obj->fk_user_author);
- $this->user_creation = $cuser;
- }
-
- if ($obj->fk_user_valid)
- {
- $vuser = new User($this->db);
- $vuser->fetch($obj->fk_user_valid);
- $this->user_validation = $vuser;
- }
-
- if ($obj->fk_user_cloture)
- {
- $cluser = new User($this->db);
- $cluser->fetch($obj->fk_user_cloture);
- $this->user_cloture = $cluser;
- }
-
- $this->date_creation = $this->db->jdate($obj->datec);
- $this->date_modification = $this->db->jdate($obj->datem);
- $this->date_validation = $this->db->jdate($obj->datev);
- }
-
- $this->db->free($result);
- }
- else
- {
- dol_print_error($this->db);
- }
- }
-
- /**
- * Initialise object with example values
- * Id must be 0 if object instance is a specimen
- *
- * @return void
- */
- public function initAsSpecimen()
- {
- $this->initAsSpecimenCommon();
- }
-
- /**
- * Fetch filters
- *
- * @return int <0 if KO, >0 if OK
- */
- public function fetchFilters()
- {
- $this->filters = array();
-
- $sql = 'SELECT rowid, type, rulevalue, status';
- $sql.= ' FROM '.MAIN_DB_PREFIX.'emailcollector_emailcollectorfilter';
- $sql.= ' WHERE fk_emailcollector = '.$this->id;
- //$sql.= ' ORDER BY position';
-
- $resql = $this->db->query($sql);
- if ($resql)
- {
- $num=$this->db->num_rows($resql);
- $i = 0;
- while($i < $num)
- {
- $obj=$this->db->fetch_object($resql);
- $this->filters[$obj->rowid]=array('id'=>$obj->rowid, 'type'=>$obj->type, 'rulevalue'=>$obj->rulevalue, 'status'=>$obj->status);
- $i++;
- }
- $this->db->free($resql);
- }
- else dol_print_error($this->db);
-
- return 1;
- }
-
- /**
- * Fetch actions
- *
- * @return int <0 if KO, >0 if OK
- */
- public function fetchActions()
- {
- $this->actions = array();
-
- $sql = 'SELECT rowid, type, actionparam, status';
- $sql.= ' FROM '.MAIN_DB_PREFIX.'emailcollector_emailcollectoraction';
- $sql.= ' WHERE fk_emailcollector = '.$this->id;
- $sql.= ' ORDER BY position';
-
- $resql = $this->db->query($sql);
- if ($resql)
- {
- $num=$this->db->num_rows($resql);
- $i = 0;
- while($i < $num)
- {
- $obj=$this->db->fetch_object($resql);
- $this->actions[$obj->rowid]=array('id'=>$obj->rowid, 'type'=>$obj->type, 'actionparam'=>$obj->actionparam, 'status'=>$obj->status);
- $i++;
- }
- $this->db->free($resql);
- }
- else dol_print_error($this->db);
- }
-
-
- /**
- * Return the connectstring to use with IMAP connection function
- *
- * @return string
- */
- function getConnectStringIMAP()
- {
- // Connect to IMAP
- $flags ='/service=imap'; // IMAP
- $flags.='/ssl'; // '/tls'
- $flags.='/novalidate-cert';
- //$flags.='/readonly';
- //$flags.='/debug';
-
- $connectstringserver = '{'.$this->host.':993'.$flags.'}';
-
- return $connectstringserver;
- }
-
- /**
- * Action executed by scheduler
- * CAN BE A CRON TASK. In such a case, paramerts come from the schedule job setup field 'Parameters'
- *
- * @return int 0 if OK, <>0 if KO (this function is used also by cron so only 0 is OK)
- */
- public function doCollect()
- {
- global $user;
-
- $nberror = 0;
-
- $arrayofcollectors = $this->fetchAll($user, 1);
-
- // Loop on each collector
- foreach($arrayofcollectors as $emailcollector)
- {
- $result = $emailcollector->doCollectOneCollector();
- dol_syslog("doCollect result = ".$result." for emailcollector->id = ".$emailcollector->id);
-
- $this->error.='EmailCollector ID '.$emailcollector->id.':'.$emailcollector->error.'
';
- if (! empty($emailcollector->errors)) $this->error.=join('
', $emailcollector->errors);
- $this->output.='EmailCollector ID '.$emailcollector->id.': '.$emailcollector->lastresult.'
';
- }
-
- return $nberror;
- }
-
- /**
- * overwitePropertiesOfObject
- *
- * @return int 0=OK, Nb of error if error
- */
-
- /**
- * overwitePropertiesOfObject
- *
- * @param object $object Current object
- * @param string $actionparam Action parameters
- * @param string $messagetext Body
- * @param string $subject Subject
- * @return int 0=OK, Nb of error if error
- */
- private function overwritePropertiesOfObject(&$object, $actionparam, $messagetext, $subject)
- {
- $errorforthisaction = 0;
-
- // Overwrite values with values extracted from source email
- // $this->actionparam = 'opportunity_status=123;abc=REGEX:BODY:....'
- $arrayvaluetouse = dolExplodeIntoArray($actionparam, ';', '=');
- foreach($arrayvaluetouse as $propertytooverwrite => $valueforproperty)
- {
- $tmpclass=''; $tmpproperty='';
- $tmparray=explode('.', $propertytooverwrite);
- if (count($tmparray) == 2)
- {
- $tmpclass=$tmparray[0];
- $tmpproperty=$tmparray[1];
- }
- else
- {
- $tmpproperty=$tmparray[0];
- }
- if ($tmpclass && ($tmpclass != $object->element)) continue; // Property is for another type of object
-
- if (property_exists($object, $tmpproperty))
- {
- $sourcestring='';
- $sourcefield='';
- $regexstring='';
- //$transformationstring='';
- $regforregex=array();
- if (preg_match('/^REGEX:([a-zA-Z0-9]+):(.*):([^:])$/', $valueforproperty, $regforregex))
- {
- $sourcefield=$regforregex[1];
- $regexstring=$regforregex[2];
- //$transofrmationstring=$regforregex[3];
- }
- elseif (preg_match('/^REGEX:([a-zA-Z0-9]+):(.*)$/', $valueforproperty, $regforregex))
- {
- $sourcefield=$regforregex[1];
- $regexstring=$regforregex[2];
- }
-
- if (! empty($sourcefield) && ! empty($regexstring))
- {
- if (strtolower($sourcefield) == 'body') $sourcestring=$messagetext;
- elseif (strtolower($sourcefield) == 'subject') $sourcestring=$subject;
-
- $regforval=array();
- if (preg_match('/'.preg_quote($regexstring, '/').'/', $sourcestring, $regforval))
- {
- // Overwrite param $tmpproperty
- $object->$tmpproperty = $regforval[1];
- }
- else
- {
- // Nothing can be done for this param
- }
- }
- elseif (preg_match('/^VALUE:(.*)$/', $valueforproperty, $reg))
- {
- $object->$tmpproperty = $reg[1];
- }
- else
- {
- $errorforthisaction++;
- $this->error = 'Bad syntax for description of action parameters: '.$actionparam;
- $this->errors[] = $this->error;
- }
- }
- }
-
- return $errorforthisaction;
- }
-
- /**
- * Execute collect for current collector loaded previously with fetch.
- *
- * @return int <0 if KO, >0 if OK
- */
- public function doCollectOneCollector()
- {
- global $conf, $langs, $user;
-
- //$conf->global->SYSLOG_FILE = 'DOL_DATA_ROOT/dolibarr_mydedicatedlofile.log';
-
- require_once DOL_DOCUMENT_ROOT.'/comm/action/class/actioncomm.class.php';
-
- dol_syslog("EmailCollector::doCollectOneCollector start", LOG_DEBUG);
-
- $langs->loadLangs(array("project", "companies", "mails", "errors"));
-
- $error = 0;
- $this->output = '';
- $this->error='';
-
- $now = dol_now();
-
- if (empty($this->host))
- {
- $this->error=$langs->trans('ErrorFieldRequired', 'EMailHost');
- return -1;
- }
- if (empty($this->login))
- {
- $this->error=$langs->trans('ErrorFieldRequired', 'Login');
- return -1;
- }
- if (empty($this->source_directory))
- {
- $this->error=$langs->trans('ErrorFieldRequired', 'MailboxSourceDirectory');
- return -1;
- }
- if (! function_exists('imap_open'))
- {
- $this->error='IMAP function not enabled on your PHP';
- return -2;
- }
-
- $this->fetchFilters();
- $this->fetchActions();
-
- $sourcedir = $this->source_directory;
- $targetdir = ($this->target_directory ? $this->target_directory : ''); // Can be '[Gmail]/Trash' or 'mytag'
-
- $connectstringserver = $this->getConnectStringIMAP();
- $connectstringsource = $connectstringserver.imap_utf7_encode($sourcedir);
- $connectstringtarget = $connectstringserver.imap_utf7_encode($targetdir);
-
- $connection = imap_open($connectstringsource, $this->login, $this->password);
- if (! $connection)
- {
- $this->error = 'Failed to open IMAP connection '.$connectstringsource;
- return -3;
- }
-
- //$search='ALL';
- $search='UNDELETED';
- $searchfilterdoltrackid=0;
- $searchfilternodoltrackid=0;
- foreach($this->filters as $rule)
- {
- if (empty($rule['status'])) continue;
-
- if ($rule['type'] == 'to') $search.=($search?' ':'').'TO "'.str_replace('"', '', $rule['rulevalue']).'"';
- if ($rule['type'] == 'bcc') $search.=($search?' ':'').'BCC';
- if ($rule['type'] == 'cc') $search.=($search?' ':'').'CC';
- if ($rule['type'] == 'from') $search.=($search?' ':'').'FROM "'.str_replace('"', '', $rule['rulevalue']).'"';
- if ($rule['type'] == 'subject') $search.=($search?' ':'').'SUBJECT "'.str_replace('"', '', $rule['rulevalue']).'"';
- if ($rule['type'] == 'body') $search.=($search?' ':'').'BODY "'.str_replace('"', '', $rule['rulevalue']).'"';
- if ($rule['type'] == 'seen') $search.=($search?' ':'').'SEEN';
- if ($rule['type'] == 'unseen') $search.=($search?' ':'').'UNSEEN';
- if ($rule['type'] == 'withtrackingid') $searchfilterdoltrackid++;
- if ($rule['type'] == 'withouttrackingid') $searchfilternodoltrackid++;
- }
-
- if (empty($targetdir)) // Use last date as filter if there is no targetdir defined.
- {
- $fromdate=0;
- if ($this->datelastresult && $this->codelastresult == 'OK') $fromdate = $this->datelastresult;
- if ($fromdate > 0) $search.=($search?' ':'').'SINCE '.dol_print_date($fromdate - 1,'dayhourrfc');
- }
- dol_syslog("IMAP search string = ".$search);
- //var_dump($search);
-
- $nbemailprocessed=0;
- $nbemailok=0;
- $nbactiondone=0;
-
- // Scan IMAP inbox
- $arrayofemail= imap_search($connection, $search);
- //var_dump($arrayofemail);exit;
-
- // Loop on each email found
- if (! empty($arrayofemail) && count($arrayofemail) > 0)
- {
- foreach($arrayofemail as $imapemail)
- {
- if ($nbemailprocessed > 100) break; // Do not process more than 100 email per launch
-
- $header = imap_fetchheader($connection, $imapemail, 0);
- $matches=array();
- preg_match_all('/([^: ]+): (.+?(?:\r\n\s(?:.+?))*)\r\n/m', $header, $matches);
- $headers = array_combine($matches[1], $matches[2]);
- //var_dump($headers);
-
- // $conf->global->MAIL_PREFIX_FOR_EMAIL_ID must be defined
- $host=dol_getprefix('email');
-
- // If there is a filter on trackid
- //var_dump($host);exit;
- if ($searchfilterdoltrackid > 0)
- {
- //if (empty($headers['X-Dolibarr-TRACKID'])) continue;
- if (empty($headers['References']) || ! preg_match('/@'.preg_quote($host,'/').'/', $headers['References']))
- {
- $nbemailprocessed++;
- continue;
- }
- }
- if ($searchfilternodoltrackid > 0)
- {
- if (! empty($headers['References']) && preg_match('/@'.preg_quote($host,'/').'/', $headers['References']))
- {
- $nbemailprocessed++;
- continue;
- }
- //if (! empty($headers['X-Dolibarr-TRACKID']) continue;
- }
-
- $thirdpartystatic=new Societe($this->db);
- $contactstatic=new Contact($this->db);
- $projectstatic=new Project($this->db);
-
- $nbactiondoneforemail = 0;
- $errorforemail = 0;
- $errorforactions = 0;
- $thirdpartyfoundby = '';
- $contactfoundby = '';
- $projectfoundby = '';
-
- $this->db->begin();
-
- //$message = imap_body($connection, $imapemail, 0);
- $overview = imap_fetch_overview($connection, $imapemail, 0);
- $structure = imap_fetchstructure($connection, $imapemail, 0);
-
- $partplain = $parthtml = -1;
- // Loop to get part html and plain
- /*
- 0 multipart/mixed
- 1 multipart/alternative
- 1.1 text/plain
- 1.2 text/html
- 2 message/rfc822
- 2 multipart/mixed
- 2.1 multipart/alternative
- 2.1.1 text/plain
- 2.1.2 text/html
- 2.2 message/rfc822
- 2.2 multipart/alternative
- 2.2.1 text/plain
- 2.2.2 text/html
- */
- /**
- * create_part_array
- *
- * @param Object $structure Structure
- * @param string $prefix prefix
- * @return array Array with number and object
- */
- function createPartArray($structure, $prefix="")
- {
- //print_r($structure);
- if (count($structure->parts) > 0) { // There some sub parts
- foreach ($structure->parts as $count => $part) {
- add_part_to_array($part, $prefix.($count+1), $part_array);
- }
- }else{ // Email does not have a seperate mime attachment for text
- $part_array[] = array('part_number' => $prefix.'1', 'part_object' => $obj);
- }
- return $part_array;
- }
-
- /**
- * Sub function for createPartArray(). Only called by createPartArray() and itself.
- *
- * @param Object $obj Structure
- * @param string $partno Part no
- * @param array $part_array array
- * @return void
- */
- function addPartToArray($obj, $partno, &$part_array)
- {
- $part_array[] = array('part_number' => $partno, 'part_object' => $obj);
- if ($obj->type == 2) { // Check to see if the part is an attached email message, as in the RFC-822 type
- //print_r($obj);
- if (array_key_exists('parts',$obj)) { // Check to see if the email has parts
- foreach ($obj->parts as $count => $part) {
- // Iterate here again to compensate for the broken way that imap_fetchbody() handles attachments
- if (count($part->parts) > 0) {
- foreach ($part->parts as $count2 => $part2) {
- addPartToArray($part2, $partno.".".($count2+1), $part_array);
- }
- }else{ // Attached email does not have a seperate mime attachment for text
- $part_array[] = array('part_number' => $partno.'.'.($count+1), 'part_object' => $obj);
- }
- }
- }else{ // Not sure if this is possible
- $part_array[] = array('part_number' => $partno.'.1', 'part_object' => $obj);
- }
- }else{ // If there are more sub-parts, expand them out.
- if (array_key_exists('parts',$obj)) {
- foreach ($obj->parts as $count => $p) {
- addPartToArray($p, $partno.".".($count+1), $part_array);
- }
- }
- }
- }
-
- $result = createPartArray($structure, '');
- //var_dump($result);exit;
- foreach($result as $part)
- {
- if ($part['part_object']->subtype == 'HTML') $parthtml=$part['part_number'];
- if ($part['part_object']->subtype == 'PLAIN') $partplain=$part['part_number'];
- }
-
- /* OLD CODE to get parthtml and partplain
- if (count($structure->parts) > 0) { // There some sub parts
- foreach($structure->parts as $key => $part)
- {
- if ($part->subtype == 'HTML') $parthtml=($key+1); // For example: $parthtml = 1 or 2
- if ($part->subtype == 'PLAIN') $partplain=($key+1);
- if ($part->subtype == 'ALTERNATIVE')
- {
- if (count($part->parts) > 0)
- {
- foreach($part->parts as $key2 => $part2)
- {
- if ($part2->subtype == 'HTML') $parthtml=($key+1).'.'.($key2+1); // For example: $parthtml = 1.1 or 1.2
- if ($part2->subtype == 'PLAIN') $partplain=($key+1).'.'.($key2+1);
- }
- }
- else
- {
- $partplain=($key+1).'.1';
- }
- }
- }
- }
- else
- {
- $partplain=1;
- }*/
-
- //var_dump($structure);
- //var_dump($parthtml);var_dump($partplain);
-
- $messagetext = imap_fetchbody($connection, $imapemail, ($parthtml != '-1' ? $parthtml : ($partplain != '-1' ? $partplain : 0)), FT_PEEK);
-
- //var_dump($overview);
- //var_dump($header);
- //var_dump($message);
- //var_dump($structure->parts[0]->parts);
- //var_dump($messagetext);exit;
- $fromstring=$overview[0]->from;
- $sender=$overview[0]->sender;
- $to=$overview[0]->to;
- $sendtocc=$overview[0]->cc;
- $sendtobcc=$overview[0]->bcc;
- $date=$overview[0]->udate;
- $msgid=str_replace(array('<','>'), '', $overview[0]->message_id);
- $subject=$overview[0]->subject;
- //var_dump($msgid);exit;
-
- $reg=array();
- if (preg_match('/^(.*)<(.*)>$/', $fromstring, $reg))
- {
- $from=$reg[2];
- $fromtext=$reg[1];
- }
- else
- {
- $from = $fromstring;
- $fromtext='';
- }
- $fk_element_id = 0; $fk_element_type = '';
-
- $contactid = 0; $thirdpartyid = 0; $projectid = 0;
-
- // Analyze TrackId in field References
- // For example: References: <1542377954.SMTPs-dolibarr-thi649@8f6014fde11ec6cdec9a822234fc557e>
- $trackid = '';
- $reg=array();
- if (! empty($headers['References']) && preg_match('/dolibarr-([a-z]+)([0-9]+)@'.preg_quote($host,'/').'/', $headers['References'], $reg))
- {
- $trackid = $reg[1].$reg[2];
-
- $objectid = 0;
- $objectemail = null;
- if ($reg[0] == 'inv')
- {
- $objectid = $reg[1];
- $objectemail = new Facture($this->db);
- }
- if ($reg[0] == 'proj')
- {
- $objectid = $reg[1];
- $objectemail = new Project($this->db);
- }
- if ($reg[0] == 'con')
- {
- $objectid = $reg[1];
- $objectemail = new Contact($this->db);
- }
- if ($reg[0] == 'thi')
- {
- $objectid = $reg[1];
- $objectemail = new Societe($this->db);
- }
- if ($reg[0] == 'use')
- {
- $objectid = $reg[1];
- $objectemail = new User($this->db);
- }
-
- if (is_object($objectemail))
- {
- $result = $objectemail->fetch($objectid);
- if ($result > 0)
- {
- $fk_element_id = $objectemail->id;
- $fk_element_type = $objectemail->element;
- // Fix fk_element_type
- if ($fk_element_type == 'facture') $fk_element_type = 'invoice';
-
- $thirdpartyid = $objectemail->fk_soc;
- $contactid = $objectemail->fk_socpeople;
- $projectid = isset($objectemail->fk_project)?$objectemail->fk_project:$objectemail->fk_projet;
- }
- }
-
- // Project
- if ($projectid > 0)
- {
- $result = $projectstatic->fetch($projectid);
- if ($result <= 0) $projectstatic->id = 0;
- else
- {
- $projectid = $projectstatic->id;
- $projectfoundby = 'trackid ('.$trackid.')';
- if (empty($contactid)) $contactid = $projectstatic->fk_contact;
- if (empty($thirdpartyid)) $thirdpartyid = $projectstatic->fk_soc;
- }
- }
- // Contact
- if ($contactid > 0)
- {
- $result = $contactstatic->fetch($contactid);
- if ($result <= 0) $contactstatic->id = 0;
- else
- {
- $contactid = $contactstatic->id;
- $contactfoundby = 'trackid ('.$trackid.')';
- if (empty($thirdpartyid)) $thirdpartyid = $contactstatic->fk_soc;
- }
- }
- // Thirdparty
- if ($thirdpartyid > 0)
- {
- $result = $thirdpartystatic->fetch($thirdpartyid);
- if ($result <= 0) $thirdpartystatic->id = 0;
- else
- {
- $thirdpartyid = $thirdpartystatic->id;
- $thirdpartyfoundby = 'trackid ('.$trackid.')';
- }
- }
- }
-
- if (empty($contactid)) // Try to find contact using email
- {
- $result = $contactstatic->fetch(0, null, '', $from);
- if ($result > 0)
- {
- $contactid = $contactstatic->id;
- $contactfoundby = 'email of contact ('.$from.')';
- if ($contactstatic->fk_soc > 0)
- {
- $result = $thirdpartystatic->fetch($contactstatic->fk_soc);
- if ($result > 0)
- {
- $thirdpartyid = $thirdpartystatic->id;
- $thirdpartyfoundby = 'email of contact ('.$from.')';
- }
- }
- }
- }
-
- if (empty($thirdpartyid)) // Try to find thirdparty using email
- {
- $result = $thirdpartystatic->fetch(0, '', '', '', '', '', '', '', '', '', $from);
- if ($result > 0) $thirdpartyfoundby = 'email ('.$from.')';
- }
-
-
-
- // Do operations
- foreach($this->actions as $operation)
- {
- if ($errorforactions) break;
- if (empty($operation['status'])) continue;
-
- // Make Operation
- dol_syslog("Execute action ".$operation['type']." actionparam=".$operation['actionparam'].' thirdpartystatic->id='.$thirdpartystatic->id.' contactstatic->id='.$contactstatic->id.' projectstatic->id='.$projectstatic->id);
-
- // Search and create thirdparty
- if ($operation['type'] == 'loadthirdparty' || $operation['type'] == 'loadandcreatethirdparty')
- {
- if (empty($operation['actionparam']))
- {
- $errorforactions++;
- $this->error = "Action loadthirdparty or loadandcreatethirdparty has empty parameter. Must be 'VALUE:xxx' or 'REGEX:(body|subject):regex' to define how to extract data";
- $this->errors[] = $this->error;
- }
- else
- {
- $actionparam = $operation['actionparam'];
- $nametouseforthirdparty='';
-
- // $this->actionparam = 'VALUE:aaa' or 'REGEX:BODY:....'
- $arrayvaluetouse = dolExplodeIntoArray($actionparam, ';', '=');
- foreach($arrayvaluetouse as $propertytooverwrite => $valueforproperty)
- {
- $sourcestring='';
- $sourcefield='';
- $regexstring='';
- $regforregex=array();
-
- if (preg_match('/^REGEX:([a-zA-Z0-9]+):(.*)$/', $valueforproperty, $regforregex))
- {
- $sourcefield=$regforregex[1];
- $regexstring=$regforregex[2];
- }
-
- if (! empty($sourcefield) && ! empty($regexstring))
- {
- if (strtolower($sourcefield) == 'body') $sourcestring=$messagetext;
- elseif (strtolower($sourcefield) == 'subject') $sourcestring=$subject;
-
- $regforval=array();
- if (preg_match('/'.$regexstring.'/', $sourcestring, $regforval)) // Do not use preg_quote here, string is already a regex syntax, for example string is 'Name:\s([^\s]*)'
- {
- // Overwrite param $tmpproperty
- $nametouseforthirdparty = $regforval[1];
- }
- else
- {
- // Nothing can be done for this param
- }
- //var_dump($sourcestring); var_dump($regexstring);var_dump($nametouseforthirdparty);exit;
- }
- elseif (preg_match('/^VALUE:(.*)$/', $valueforproperty, $reg))
- {
- $nametouseforthirdparty = $reg[1];
- }
- else
- {
- $errorforactions++;
- $this->error = 'Bad syntax for description of action parameters: '.$actionparam;
- $this->errors[] = $this->error;
- break;
- }
- }
-
- if (! $errorforactions && $nametouseforthirdparty)
- {
- $result = $thirdpartystatic->fetch(0, $nametouseforthirdparty);
- if ($result < 0)
- {
- $errorforactions++;
- $this->error = 'Error when getting thirdparty with name '.$nametouseforthirdparty.' (may be 2 record exists with same name ?)';
- $this->errors[] = $this->error;
- break;
- }
- elseif ($result == 0)
- {
- if ($operation['type'] == 'loadandcreatethirdparty')
- {
- dol_syslog("Third party with name ".$nametouseforthirdparty." was not found. We try to create it.");
-
- // Create thirdparty
- $thirdpartystatic->name = $nametouseforthirdparty;
- if ($fromtext != $nametouseforthirdparty) $thirdpartystatic->name_alias = $fromtext;
- $thirdpartystatic->email = $from;
-
- // Overwrite values with values extracted from source email
- $errorforthisaction = $this->overwritePropertiesOfObject($thirdpartystatic, $operation['actionparam'], $messagetext, $subject);
-
- if ($errorforthisaction)
- {
- $errorforactions++;
- }
- else
- {
- $result = $thirdpartystatic->create($user);
- if ($result <= 0)
- {
- $errorforactions++;
- $this->error = $thirdpartystatic->error;
- $this->errors = $thirdpartystatic->errors;
- }
- }
- }
- else
- {
- dol_syslog("Third party with name ".$nametouseforthirdparty." was not found");
- }
- }
- }
- }
- }
- // Create event
- elseif ($operation['type'] == 'recordevent')
- {
- $actioncode = 'EMAIL_IN';
-
- // Insert record of emails sent
- $actioncomm = new ActionComm($this->db);
-
- $actioncomm->type_code = 'AC_OTH_AUTO'; // Type of event ('AC_OTH', 'AC_OTH_AUTO', 'AC_XXX'...)
- $actioncomm->code = 'AC_'.$actioncode;
- $actioncomm->label = $langs->trans("ActionAC_EMAIL_IN").' - '.$langs->trans("MailFrom").' '.$from;
- $actioncomm->note = $messagetext;
- $actioncomm->fk_project = $projectstatic->id;
- $actioncomm->datep = $date;
- $actioncomm->datef = $date;
- $actioncomm->percentage = -1; // Not applicable
- $actioncomm->socid = $thirdpartystatic->id;
- $actioncomm->contactid = $contactstatic->id;
- $actioncomm->authorid = $user->id; // User saving action
- $actioncomm->userownerid = $user->id; // Owner of action
- // Fields when action is an email (content should be added into note)
- $actioncomm->email_msgid = $msgid;
- $actioncomm->email_from = $fromstring;
- $actioncomm->email_sender= $sender;
- $actioncomm->email_to = $to;
- $actioncomm->email_tocc = $sendtocc;
- $actioncomm->email_tobcc = $sendtobcc;
- $actioncomm->email_subject = $subject;
- $actioncomm->errors_to = '';
-
- if (! in_array($fk_element_type, array('societe','contact','project','user')))
- {
- $actioncomm->fk_element = $fk_element_id;
- $actioncomm->elementtype = $fk_element_type;
- }
-
- //$actioncomm->extraparams = $extraparams;
-
- // Overwrite values with values extracted from source email
- $errorforthisaction = $this->overwritePropertiesOfObject($actioncommn, $operation['actionparam'], $messagetext, $subject);
-
- if ($errorforthisaction)
- {
- $errorforactions++;
- }
- else
- {
- $result = $actioncomm->create($user);
- if ($result <= 0)
- {
- $errorforactions++;
- $this->errors = $actioncomm->errors;
- }
- }
- }
- // Create event
- elseif ($operation['type'] == 'project')
- {
- $note_private = $langs->trans("ProjectCreatedByEmailCollector", $msgid);
- $projecttocreate = new Project($this->db);
- if ($thirdpartystatic->id > 0)
- {
- $projecttocreate->socid = $thirdpartystatic->id;
- if ($thirdpartyfoundby) $note_private .= ' - Third party found from '.$thirdpartyfoundby;
- }
- if ($contactstatic->id > 0)
- {
- $projecttocreate->contact_id = $contactstatic->id;
- if ($contactfoundby) $note_private .= ' - Contact/address found from '.$contactfoundby;
- }
-
- $id_opp_status = dol_getIdFromCode($this->db, 'PROSP', 'c_lead_status', 'code', 'rowid');
- $percent_opp_status = dol_getIdFromCode($this->db, 'PROSP', 'c_lead_status', 'code', 'percent');
-
- $projecttocreate->title = $subject;
- $projecttocreate->date_start = $now;
- $projecttocreate->date_end = '';
- $projecttocreate->opp_status = $id_opp_status;
- $projecttocreate->opp_percent = $percent_opp_status;
- $projecttocreate->description = ($note_private?$note_private."\n":'').dol_string_nohtmltag($messagetext, 2);
- $projecttocreate->note_private = $note_private;
- $projecttocreate->entity = $conf->entity;
-
- // Get next project Ref
- $defaultref='';
- $modele = empty($conf->global->PROJECT_ADDON)?'mod_project_simple':$conf->global->PROJECT_ADDON;
-
- // Search template files
- $file=''; $classname=''; $filefound=0; $reldir='';
- $dirmodels=array_merge(array('/'),(array) $conf->modules_parts['models']);
- foreach($dirmodels as $reldir)
- {
- $file=dol_buildpath($reldir."core/modules/project/".$modele.'.php',0);
- if (file_exists($file))
- {
- $filefound=1;
- $classname = $modele;
- break;
- }
- }
-
- if ($filefound)
- {
- $result=dol_include_once($reldir."core/modules/project/".$modele.'.php');
- $modProject = new $classname;
-
- $defaultref = $modProject->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $projecttocreate);
- }
-
- $projecttocreate->ref = $defaultref;
-
- // Overwrite values with values extracted from source email
- $errorforthisaction = $this->overwritePropertiesOfObject($projecttocreate, $operation['actionparam'], $messagetext, $subject);
-
- if ($errorforthisaction)
- {
- $errorforactions++;
- }
- else
- {
- if (is_numeric($projecttocreate->ref) && $projecttocreate->ref <= 0)
- {
- $errorforactions++;
- $this->error = 'Failed to create project: Can\'t get a valid value for project Ref';
- }
- else
- {
- // Create project
- $result = $projecttocreate->create($user);
- if ($result <= 0)
- {
- $errorforactions++;
- $this->error = 'Failed to create project: '.$langs->trans($projecttocreate->error);
- $this->errors = $projecttocreate->errors;
- }
- }
- }
- }
-
- if (! $errorforactions)
- {
- $nbactiondoneforemail++;
- }
- }
-
- // Error for email or not ?
- if (! $errorforactions)
- {
- if ($targetdir)
- {
- dol_syslog("EmailCollector::doCollectOneCollector move message ".$imapemail." to ".$connectstringtarget, LOG_DEBUG);
- $res = imap_mail_move($connection, $imapemail, $targetdir, 0);
- if ($res == false) {
- $errorforemail++;
- $this->error = imap_last_error();
- $this->errors[] = $this->error;
- dol_syslog(imap_last_error());
- }
- }
- else
- {
- dol_syslog("EmailCollector::doCollectOneCollector message ".$imapemail." to ".$connectstringtarget." was set to read", LOG_DEBUG);
- }
- }
- else
- {
- $errorforemail++;
- }
-
- if (! $errorforemail)
- {
- $nbactiondone += $nbactiondoneforemail;
- $nbemailok++;
-
- $this->db->commit();
- }
- else
- {
- $error++;
-
- $this->db->rollback();
- }
-
- $nbemailprocessed++;
-
- unset($objectemail);
- unset($projectstatic);
- unset($thirdpartystatic);
- unset($contactstatic);
- }
-
- $output=$langs->trans('XEmailsDoneYActionsDone', $nbemailprocessed, $nbemailok, $nbactiondone);
- }
- else
- {
- $output=$langs->trans('NoNewEmailToProcess');
- }
-
- imap_expunge($connection); // To validate any move
-
- imap_close($connection);
-
- $this->datelastresult = $now;
- $this->lastresult = $output;
-
- if (! empty($this->errors)) $this->lastresult.= " - ".join(" - ", $this->errors);
- $this->codelastresult = ($error ? 'KO' : 'OK');
- $this->update($user);
-
- dol_syslog("EmailCollector::doCollectOneCollector end", LOG_DEBUG);
-
- return $error?-1:1;
- }
+ $linkstart = '';
+ $linkend='';
+
+ $result .= $linkstart;
+ if ($withpicto) $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);
+ if ($withpicto != 2) $result.= $this->ref;
+ $result .= $linkend;
+ //if ($withpicto != 2) $result.=(($addlabel && $this->label) ? $sep . dol_trunc($this->label, ($addlabel > 1 ? $addlabel : 0)) : '');
+
+ global $action,$hookmanager;
+ $hookmanager->initHooks(array('emailcollectordao'));
+ $parameters=array('id'=>$this->id, 'getnomurl'=>$result);
+ $reshook=$hookmanager->executeHooks('getNomUrl',$parameters,$this,$action); // Note that $action and $object may have been modified by some hooks
+ if ($reshook > 0) $result = $hookmanager->resPrint;
+ else $result .= $hookmanager->resPrint;
+
+ return $result;
+ }
+
+ /**
+ * Return label of the status
+ *
+ * @param int $mode 0=long label, 1=short label, 2=Picto + short label, 3=Picto, 4=Picto + long label, 5=Short label + Picto, 6=Long label + Picto
+ * @return string Label of status
+ */
+ public function getLibStatut($mode=0)
+ {
+ return $this->LibStatut($this->status, $mode);
+ }
+
+ // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
+ /**
+ * Return the status
+ *
+ * @param int $status Id status
+ * @param int $mode 0=long label, 1=short label, 2=Picto + short label, 3=Picto, 4=Picto + long label, 5=Short label + Picto, 6=Long label + Picto
+ * @return string Label of status
+ */
+ public function LibStatut($status, $mode=0)
+ {
+ // phpcs:enable
+ if (empty($this->labelstatus))
+ {
+ global $langs;
+ //$langs->load("mymodule");
+ $this->labelstatus[1] = $langs->trans('Enabled');
+ $this->labelstatus[0] = $langs->trans('Disabled');
+ }
+
+ if ($mode == 0)
+ {
+ return $this->labelstatus[$status];
+ }
+ elseif ($mode == 1)
+ {
+ return $this->labelstatus[$status];
+ }
+ elseif ($mode == 2)
+ {
+ if ($status == 1) return img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
+ elseif ($status == 0) return img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
+ }
+ elseif ($mode == 3)
+ {
+ if ($status == 1) return img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle');
+ elseif ($status == 0) return img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle');
+ }
+ elseif ($mode == 4)
+ {
+ if ($status == 1) return img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
+ elseif ($status == 0) return img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle').' '.$this->labelstatus[$status];
+ }
+ elseif ($mode == 5)
+ {
+ if ($status == 1) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle');
+ elseif ($status == 0) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle');
+ }
+ elseif ($mode == 6)
+ {
+ if ($status == 1) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut4', '', false, 0, 0, '', 'valignmiddle');
+ elseif ($status == 0) return $this->labelstatus[$status].' '.img_picto($this->labelstatus[$status],'statut5', '', false, 0, 0, '', 'valignmiddle');
+ }
+ }
+
+ /**
+ * Charge les informations d'ordre info dans l'objet commande
+ *
+ * @param int $id Id of order
+ * @return void
+ */
+ public function info($id)
+ {
+ $sql = 'SELECT rowid, date_creation as datec, tms as datem,';
+ $sql.= ' fk_user_creat, fk_user_modif';
+ $sql.= ' FROM '.MAIN_DB_PREFIX.$this->table_element.' as t';
+ $sql.= ' WHERE t.rowid = '.$id;
+ $result=$this->db->query($sql);
+ if ($result)
+ {
+ if ($this->db->num_rows($result))
+ {
+ $obj = $this->db->fetch_object($result);
+ $this->id = $obj->rowid;
+ if ($obj->fk_user_author)
+ {
+ $cuser = new User($this->db);
+ $cuser->fetch($obj->fk_user_author);
+ $this->user_creation = $cuser;
+ }
+
+ if ($obj->fk_user_valid)
+ {
+ $vuser = new User($this->db);
+ $vuser->fetch($obj->fk_user_valid);
+ $this->user_validation = $vuser;
+ }
+
+ if ($obj->fk_user_cloture)
+ {
+ $cluser = new User($this->db);
+ $cluser->fetch($obj->fk_user_cloture);
+ $this->user_cloture = $cluser;
+ }
+
+ $this->date_creation = $this->db->jdate($obj->datec);
+ $this->date_modification = $this->db->jdate($obj->datem);
+ $this->date_validation = $this->db->jdate($obj->datev);
+ }
+
+ $this->db->free($result);
+ }
+ else
+ {
+ dol_print_error($this->db);
+ }
+ }
+
+ /**
+ * Initialise object with example values
+ * Id must be 0 if object instance is a specimen
+ *
+ * @return void
+ */
+ public function initAsSpecimen()
+ {
+ $this->initAsSpecimenCommon();
+ }
+
+ /**
+ * Fetch filters
+ *
+ * @return int <0 if KO, >0 if OK
+ */
+ public function fetchFilters()
+ {
+ $this->filters = array();
+
+ $sql = 'SELECT rowid, type, rulevalue, status';
+ $sql.= ' FROM '.MAIN_DB_PREFIX.'emailcollector_emailcollectorfilter';
+ $sql.= ' WHERE fk_emailcollector = '.$this->id;
+ //$sql.= ' ORDER BY position';
+
+ $resql = $this->db->query($sql);
+ if ($resql)
+ {
+ $num=$this->db->num_rows($resql);
+ $i = 0;
+ while($i < $num)
+ {
+ $obj=$this->db->fetch_object($resql);
+ $this->filters[$obj->rowid]=array('id'=>$obj->rowid, 'type'=>$obj->type, 'rulevalue'=>$obj->rulevalue, 'status'=>$obj->status);
+ $i++;
+ }
+ $this->db->free($resql);
+ }
+ else dol_print_error($this->db);
+
+ return 1;
+ }
+
+ /**
+ * Fetch actions
+ *
+ * @return int <0 if KO, >0 if OK
+ */
+ public function fetchActions()
+ {
+ $this->actions = array();
+
+ $sql = 'SELECT rowid, type, actionparam, status';
+ $sql.= ' FROM '.MAIN_DB_PREFIX.'emailcollector_emailcollectoraction';
+ $sql.= ' WHERE fk_emailcollector = '.$this->id;
+ $sql.= ' ORDER BY position';
+
+ $resql = $this->db->query($sql);
+ if ($resql)
+ {
+ $num=$this->db->num_rows($resql);
+ $i = 0;
+ while($i < $num)
+ {
+ $obj=$this->db->fetch_object($resql);
+ $this->actions[$obj->rowid]=array('id'=>$obj->rowid, 'type'=>$obj->type, 'actionparam'=>$obj->actionparam, 'status'=>$obj->status);
+ $i++;
+ }
+ $this->db->free($resql);
+ }
+ else dol_print_error($this->db);
+ }
+
+
+ /**
+ * Return the connectstring to use with IMAP connection function
+ *
+ * @return string
+ */
+ function getConnectStringIMAP()
+ {
+ // Connect to IMAP
+ $flags ='/service=imap'; // IMAP
+ $flags.='/ssl'; // '/tls'
+ $flags.='/novalidate-cert';
+ //$flags.='/readonly';
+ //$flags.='/debug';
+
+ $connectstringserver = '{'.$this->host.':993'.$flags.'}';
+
+ return $connectstringserver;
+ }
+
+ /**
+ * Action executed by scheduler
+ * CAN BE A CRON TASK. In such a case, paramerts come from the schedule job setup field 'Parameters'
+ *
+ * @return int 0 if OK, <>0 if KO (this function is used also by cron so only 0 is OK)
+ */
+ public function doCollect()
+ {
+ global $user;
+
+ $nberror = 0;
+
+ $arrayofcollectors = $this->fetchAll($user, 1);
+
+ // Loop on each collector
+ foreach($arrayofcollectors as $emailcollector)
+ {
+ $result = $emailcollector->doCollectOneCollector();
+ dol_syslog("doCollect result = ".$result." for emailcollector->id = ".$emailcollector->id);
+
+ $this->error.='EmailCollector ID '.$emailcollector->id.':'.$emailcollector->error.'
';
+ if (! empty($emailcollector->errors)) $this->error.=join('
', $emailcollector->errors);
+ $this->output.='EmailCollector ID '.$emailcollector->id.': '.$emailcollector->lastresult.'
';
+ }
+
+ return $nberror;
+ }
+
+ /**
+ * overwitePropertiesOfObject
+ *
+ * @return int 0=OK, Nb of error if error
+ */
+
+ /**
+ * overwitePropertiesOfObject
+ *
+ * @param object $object Current object
+ * @param string $actionparam Action parameters
+ * @param string $messagetext Body
+ * @param string $subject Subject
+ * @return int 0=OK, Nb of error if error
+ */
+ private function overwritePropertiesOfObject(&$object, $actionparam, $messagetext, $subject)
+ {
+ $errorforthisaction = 0;
+
+ // Overwrite values with values extracted from source email
+ // $this->actionparam = 'opportunity_status=123;abc=REGEX:BODY:....'
+ $arrayvaluetouse = dolExplodeIntoArray($actionparam, ';', '=');
+ foreach($arrayvaluetouse as $propertytooverwrite => $valueforproperty)
+ {
+ $tmpclass=''; $tmpproperty='';
+ $tmparray=explode('.', $propertytooverwrite);
+ if (count($tmparray) == 2)
+ {
+ $tmpclass=$tmparray[0];
+ $tmpproperty=$tmparray[1];
+ }
+ else
+ {
+ $tmpproperty=$tmparray[0];
+ }
+ if ($tmpclass && ($tmpclass != $object->element)) continue; // Property is for another type of object
+
+ if (property_exists($object, $tmpproperty))
+ {
+ $sourcestring='';
+ $sourcefield='';
+ $regexstring='';
+ //$transformationstring='';
+ $regforregex=array();
+ if (preg_match('/^REGEX:([a-zA-Z0-9]+):(.*):([^:])$/', $valueforproperty, $regforregex))
+ {
+ $sourcefield=$regforregex[1];
+ $regexstring=$regforregex[2];
+ //$transofrmationstring=$regforregex[3];
+ }
+ elseif (preg_match('/^REGEX:([a-zA-Z0-9]+):(.*)$/', $valueforproperty, $regforregex))
+ {
+ $sourcefield=$regforregex[1];
+ $regexstring=$regforregex[2];
+ }
+
+ if (! empty($sourcefield) && ! empty($regexstring))
+ {
+ if (strtolower($sourcefield) == 'body') $sourcestring=$messagetext;
+ elseif (strtolower($sourcefield) == 'subject') $sourcestring=$subject;
+
+ $regforval=array();
+ if (preg_match('/'.preg_quote($regexstring, '/').'/', $sourcestring, $regforval))
+ {
+ // Overwrite param $tmpproperty
+ $object->$tmpproperty = $regforval[1];
+ }
+ else
+ {
+ // Nothing can be done for this param
+ }
+ }
+ elseif (preg_match('/^VALUE:(.*)$/', $valueforproperty, $reg))
+ {
+ $object->$tmpproperty = $reg[1];
+ }
+ else
+ {
+ $errorforthisaction++;
+ $this->error = 'Bad syntax for description of action parameters: '.$actionparam;
+ $this->errors[] = $this->error;
+ }
+ }
+ }
+
+ return $errorforthisaction;
+ }
+
+ /**
+ * Execute collect for current collector loaded previously with fetch.
+ *
+ * @return int <0 if KO, >0 if OK
+ */
+ public function doCollectOneCollector()
+ {
+ global $conf, $langs, $user;
+
+ //$conf->global->SYSLOG_FILE = 'DOL_DATA_ROOT/dolibarr_mydedicatedlofile.log';
+
+ require_once DOL_DOCUMENT_ROOT.'/comm/action/class/actioncomm.class.php';
+
+ dol_syslog("EmailCollector::doCollectOneCollector start", LOG_DEBUG);
+
+ $langs->loadLangs(array("project", "companies", "mails", "errors"));
+
+ $error = 0;
+ $this->output = '';
+ $this->error='';
+
+ $now = dol_now();
+
+ if (empty($this->host))
+ {
+ $this->error=$langs->trans('ErrorFieldRequired', 'EMailHost');
+ return -1;
+ }
+ if (empty($this->login))
+ {
+ $this->error=$langs->trans('ErrorFieldRequired', 'Login');
+ return -1;
+ }
+ if (empty($this->source_directory))
+ {
+ $this->error=$langs->trans('ErrorFieldRequired', 'MailboxSourceDirectory');
+ return -1;
+ }
+ if (! function_exists('imap_open'))
+ {
+ $this->error='IMAP function not enabled on your PHP';
+ return -2;
+ }
+
+ $this->fetchFilters();
+ $this->fetchActions();
+
+ $sourcedir = $this->source_directory;
+ $targetdir = ($this->target_directory ? $this->target_directory : ''); // Can be '[Gmail]/Trash' or 'mytag'
+
+ $connectstringserver = $this->getConnectStringIMAP();
+ $connectstringsource = $connectstringserver.imap_utf7_encode($sourcedir);
+ $connectstringtarget = $connectstringserver.imap_utf7_encode($targetdir);
+
+ $connection = imap_open($connectstringsource, $this->login, $this->password);
+ if (! $connection)
+ {
+ $this->error = 'Failed to open IMAP connection '.$connectstringsource;
+ return -3;
+ }
+
+ //$search='ALL';
+ $search='UNDELETED';
+ $searchfilterdoltrackid=0;
+ $searchfilternodoltrackid=0;
+ foreach($this->filters as $rule)
+ {
+ if (empty($rule['status'])) continue;
+
+ if ($rule['type'] == 'to') $search.=($search?' ':'').'TO "'.str_replace('"', '', $rule['rulevalue']).'"';
+ if ($rule['type'] == 'bcc') $search.=($search?' ':'').'BCC';
+ if ($rule['type'] == 'cc') $search.=($search?' ':'').'CC';
+ if ($rule['type'] == 'from') $search.=($search?' ':'').'FROM "'.str_replace('"', '', $rule['rulevalue']).'"';
+ if ($rule['type'] == 'subject') $search.=($search?' ':'').'SUBJECT "'.str_replace('"', '', $rule['rulevalue']).'"';
+ if ($rule['type'] == 'body') $search.=($search?' ':'').'BODY "'.str_replace('"', '', $rule['rulevalue']).'"';
+ if ($rule['type'] == 'seen') $search.=($search?' ':'').'SEEN';
+ if ($rule['type'] == 'unseen') $search.=($search?' ':'').'UNSEEN';
+ if ($rule['type'] == 'withtrackingid') $searchfilterdoltrackid++;
+ if ($rule['type'] == 'withouttrackingid') $searchfilternodoltrackid++;
+ }
+
+ if (empty($targetdir)) // Use last date as filter if there is no targetdir defined.
+ {
+ $fromdate=0;
+ if ($this->datelastresult && $this->codelastresult == 'OK') $fromdate = $this->datelastresult;
+ if ($fromdate > 0) $search.=($search?' ':'').'SINCE '.dol_print_date($fromdate - 1,'dayhourrfc');
+ }
+ dol_syslog("IMAP search string = ".$search);
+ //var_dump($search);
+
+ $nbemailprocessed=0;
+ $nbemailok=0;
+ $nbactiondone=0;
+
+ // Scan IMAP inbox
+ $arrayofemail= imap_search($connection, $search);
+ //var_dump($arrayofemail);exit;
+
+ // Loop on each email found
+ if (! empty($arrayofemail) && count($arrayofemail) > 0)
+ {
+ foreach($arrayofemail as $imapemail)
+ {
+ if ($nbemailprocessed > 100) break; // Do not process more than 100 email per launch
+
+ $header = imap_fetchheader($connection, $imapemail, 0);
+ $matches=array();
+ preg_match_all('/([^: ]+): (.+?(?:\r\n\s(?:.+?))*)\r\n/m', $header, $matches);
+ $headers = array_combine($matches[1], $matches[2]);
+ //var_dump($headers);
+
+ // $conf->global->MAIL_PREFIX_FOR_EMAIL_ID must be defined
+ $host=dol_getprefix('email');
+
+ // If there is a filter on trackid
+ //var_dump($host);exit;
+ if ($searchfilterdoltrackid > 0)
+ {
+ //if (empty($headers['X-Dolibarr-TRACKID'])) continue;
+ if (empty($headers['References']) || ! preg_match('/@'.preg_quote($host,'/').'/', $headers['References']))
+ {
+ $nbemailprocessed++;
+ continue;
+ }
+ }
+ if ($searchfilternodoltrackid > 0)
+ {
+ if (! empty($headers['References']) && preg_match('/@'.preg_quote($host,'/').'/', $headers['References']))
+ {
+ $nbemailprocessed++;
+ continue;
+ }
+ //if (! empty($headers['X-Dolibarr-TRACKID']) continue;
+ }
+
+ $thirdpartystatic=new Societe($this->db);
+ $contactstatic=new Contact($this->db);
+ $projectstatic=new Project($this->db);
+
+ $nbactiondoneforemail = 0;
+ $errorforemail = 0;
+ $errorforactions = 0;
+ $thirdpartyfoundby = '';
+ $contactfoundby = '';
+ $projectfoundby = '';
+
+ $this->db->begin();
+
+ //$message = imap_body($connection, $imapemail, 0);
+ $overview = imap_fetch_overview($connection, $imapemail, 0);
+ $structure = imap_fetchstructure($connection, $imapemail, 0);
+
+ $partplain = $parthtml = -1;
+ // Loop to get part html and plain
+ /*
+ 0 multipart/mixed
+ 1 multipart/alternative
+ 1.1 text/plain
+ 1.2 text/html
+ 2 message/rfc822
+ 2 multipart/mixed
+ 2.1 multipart/alternative
+ 2.1.1 text/plain
+ 2.1.2 text/html
+ 2.2 message/rfc822
+ 2.2 multipart/alternative
+ 2.2.1 text/plain
+ 2.2.2 text/html
+ */
+ /**
+ * create_part_array
+ *
+ * @param Object $structure Structure
+ * @param string $prefix prefix
+ * @return array Array with number and object
+ */
+ function createPartArray($structure, $prefix="")
+ {
+ //print_r($structure);
+ if (count($structure->parts) > 0) { // There some sub parts
+ foreach ($structure->parts as $count => $part) {
+ add_part_to_array($part, $prefix.($count+1), $part_array);
+ }
+ }else{ // Email does not have a seperate mime attachment for text
+ $part_array[] = array('part_number' => $prefix.'1', 'part_object' => $obj);
+ }
+ return $part_array;
+ }
+
+ /**
+ * Sub function for createPartArray(). Only called by createPartArray() and itself.
+ *
+ * @param Object $obj Structure
+ * @param string $partno Part no
+ * @param array $part_array array
+ * @return void
+ */
+ function addPartToArray($obj, $partno, &$part_array)
+ {
+ $part_array[] = array('part_number' => $partno, 'part_object' => $obj);
+ if ($obj->type == 2) { // Check to see if the part is an attached email message, as in the RFC-822 type
+ //print_r($obj);
+ if (array_key_exists('parts',$obj)) { // Check to see if the email has parts
+ foreach ($obj->parts as $count => $part) {
+ // Iterate here again to compensate for the broken way that imap_fetchbody() handles attachments
+ if (count($part->parts) > 0) {
+ foreach ($part->parts as $count2 => $part2) {
+ addPartToArray($part2, $partno.".".($count2+1), $part_array);
+ }
+ }else{ // Attached email does not have a seperate mime attachment for text
+ $part_array[] = array('part_number' => $partno.'.'.($count+1), 'part_object' => $obj);
+ }
+ }
+ }else{ // Not sure if this is possible
+ $part_array[] = array('part_number' => $partno.'.1', 'part_object' => $obj);
+ }
+ }else{ // If there are more sub-parts, expand them out.
+ if (array_key_exists('parts',$obj)) {
+ foreach ($obj->parts as $count => $p) {
+ addPartToArray($p, $partno.".".($count+1), $part_array);
+ }
+ }
+ }
+ }
+
+ $result = createPartArray($structure, '');
+ //var_dump($result);exit;
+ foreach($result as $part)
+ {
+ if ($part['part_object']->subtype == 'HTML') $parthtml=$part['part_number'];
+ if ($part['part_object']->subtype == 'PLAIN') $partplain=$part['part_number'];
+ }
+
+ /* OLD CODE to get parthtml and partplain
+ if (count($structure->parts) > 0) { // There some sub parts
+ foreach($structure->parts as $key => $part)
+ {
+ if ($part->subtype == 'HTML') $parthtml=($key+1); // For example: $parthtml = 1 or 2
+ if ($part->subtype == 'PLAIN') $partplain=($key+1);
+ if ($part->subtype == 'ALTERNATIVE')
+ {
+ if (count($part->parts) > 0)
+ {
+ foreach($part->parts as $key2 => $part2)
+ {
+ if ($part2->subtype == 'HTML') $parthtml=($key+1).'.'.($key2+1); // For example: $parthtml = 1.1 or 1.2
+ if ($part2->subtype == 'PLAIN') $partplain=($key+1).'.'.($key2+1);
+ }
+ }
+ else
+ {
+ $partplain=($key+1).'.1';
+ }
+ }
+ }
+ }
+ else
+ {
+ $partplain=1;
+ }*/
+
+ //var_dump($structure);
+ //var_dump($parthtml);var_dump($partplain);
+
+ $messagetext = imap_fetchbody($connection, $imapemail, ($parthtml != '-1' ? $parthtml : ($partplain != '-1' ? $partplain : 0)), FT_PEEK);
+
+ //var_dump($overview);
+ //var_dump($header);
+ //var_dump($message);
+ //var_dump($structure->parts[0]->parts);
+ //var_dump($messagetext);exit;
+ $fromstring=$overview[0]->from;
+ $sender=$overview[0]->sender;
+ $to=$overview[0]->to;
+ $sendtocc=$overview[0]->cc;
+ $sendtobcc=$overview[0]->bcc;
+ $date=$overview[0]->udate;
+ $msgid=str_replace(array('<','>'), '', $overview[0]->message_id);
+ $subject=$overview[0]->subject;
+ //var_dump($msgid);exit;
+
+ $reg=array();
+ if (preg_match('/^(.*)<(.*)>$/', $fromstring, $reg))
+ {
+ $from=$reg[2];
+ $fromtext=$reg[1];
+ }
+ else
+ {
+ $from = $fromstring;
+ $fromtext='';
+ }
+ $fk_element_id = 0; $fk_element_type = '';
+
+ $contactid = 0; $thirdpartyid = 0; $projectid = 0;
+
+ // Analyze TrackId in field References
+ // For example: References: <1542377954.SMTPs-dolibarr-thi649@8f6014fde11ec6cdec9a822234fc557e>
+ $trackid = '';
+ $reg=array();
+ if (! empty($headers['References']) && preg_match('/dolibarr-([a-z]+)([0-9]+)@'.preg_quote($host,'/').'/', $headers['References'], $reg))
+ {
+ $trackid = $reg[1].$reg[2];
+
+ $objectid = 0;
+ $objectemail = null;
+ if ($reg[0] == 'inv')
+ {
+ $objectid = $reg[1];
+ $objectemail = new Facture($this->db);
+ }
+ if ($reg[0] == 'proj')
+ {
+ $objectid = $reg[1];
+ $objectemail = new Project($this->db);
+ }
+ if ($reg[0] == 'con')
+ {
+ $objectid = $reg[1];
+ $objectemail = new Contact($this->db);
+ }
+ if ($reg[0] == 'thi')
+ {
+ $objectid = $reg[1];
+ $objectemail = new Societe($this->db);
+ }
+ if ($reg[0] == 'use')
+ {
+ $objectid = $reg[1];
+ $objectemail = new User($this->db);
+ }
+
+ if (is_object($objectemail))
+ {
+ $result = $objectemail->fetch($objectid);
+ if ($result > 0)
+ {
+ $fk_element_id = $objectemail->id;
+ $fk_element_type = $objectemail->element;
+ // Fix fk_element_type
+ if ($fk_element_type == 'facture') $fk_element_type = 'invoice';
+
+ $thirdpartyid = $objectemail->fk_soc;
+ $contactid = $objectemail->fk_socpeople;
+ $projectid = isset($objectemail->fk_project)?$objectemail->fk_project:$objectemail->fk_projet;
+ }
+ }
+
+ // Project
+ if ($projectid > 0)
+ {
+ $result = $projectstatic->fetch($projectid);
+ if ($result <= 0) $projectstatic->id = 0;
+ else
+ {
+ $projectid = $projectstatic->id;
+ $projectfoundby = 'trackid ('.$trackid.')';
+ if (empty($contactid)) $contactid = $projectstatic->fk_contact;
+ if (empty($thirdpartyid)) $thirdpartyid = $projectstatic->fk_soc;
+ }
+ }
+ // Contact
+ if ($contactid > 0)
+ {
+ $result = $contactstatic->fetch($contactid);
+ if ($result <= 0) $contactstatic->id = 0;
+ else
+ {
+ $contactid = $contactstatic->id;
+ $contactfoundby = 'trackid ('.$trackid.')';
+ if (empty($thirdpartyid)) $thirdpartyid = $contactstatic->fk_soc;
+ }
+ }
+ // Thirdparty
+ if ($thirdpartyid > 0)
+ {
+ $result = $thirdpartystatic->fetch($thirdpartyid);
+ if ($result <= 0) $thirdpartystatic->id = 0;
+ else
+ {
+ $thirdpartyid = $thirdpartystatic->id;
+ $thirdpartyfoundby = 'trackid ('.$trackid.')';
+ }
+ }
+ }
+
+ if (empty($contactid)) // Try to find contact using email
+ {
+ $result = $contactstatic->fetch(0, null, '', $from);
+ if ($result > 0)
+ {
+ $contactid = $contactstatic->id;
+ $contactfoundby = 'email of contact ('.$from.')';
+ if ($contactstatic->fk_soc > 0)
+ {
+ $result = $thirdpartystatic->fetch($contactstatic->fk_soc);
+ if ($result > 0)
+ {
+ $thirdpartyid = $thirdpartystatic->id;
+ $thirdpartyfoundby = 'email of contact ('.$from.')';
+ }
+ }
+ }
+ }
+
+ if (empty($thirdpartyid)) // Try to find thirdparty using email
+ {
+ $result = $thirdpartystatic->fetch(0, '', '', '', '', '', '', '', '', '', $from);
+ if ($result > 0) $thirdpartyfoundby = 'email ('.$from.')';
+ }
+
+
+
+ // Do operations
+ foreach($this->actions as $operation)
+ {
+ if ($errorforactions) break;
+ if (empty($operation['status'])) continue;
+
+ // Make Operation
+ dol_syslog("Execute action ".$operation['type']." actionparam=".$operation['actionparam'].' thirdpartystatic->id='.$thirdpartystatic->id.' contactstatic->id='.$contactstatic->id.' projectstatic->id='.$projectstatic->id);
+
+ // Search and create thirdparty
+ if ($operation['type'] == 'loadthirdparty' || $operation['type'] == 'loadandcreatethirdparty')
+ {
+ if (empty($operation['actionparam']))
+ {
+ $errorforactions++;
+ $this->error = "Action loadthirdparty or loadandcreatethirdparty has empty parameter. Must be 'VALUE:xxx' or 'REGEX:(body|subject):regex' to define how to extract data";
+ $this->errors[] = $this->error;
+ }
+ else
+ {
+ $actionparam = $operation['actionparam'];
+ $nametouseforthirdparty='';
+
+ // $this->actionparam = 'VALUE:aaa' or 'REGEX:BODY:....'
+ $arrayvaluetouse = dolExplodeIntoArray($actionparam, ';', '=');
+ foreach($arrayvaluetouse as $propertytooverwrite => $valueforproperty)
+ {
+ $sourcestring='';
+ $sourcefield='';
+ $regexstring='';
+ $regforregex=array();
+
+ if (preg_match('/^REGEX:([a-zA-Z0-9]+):(.*)$/', $valueforproperty, $regforregex))
+ {
+ $sourcefield=$regforregex[1];
+ $regexstring=$regforregex[2];
+ }
+
+ if (! empty($sourcefield) && ! empty($regexstring))
+ {
+ if (strtolower($sourcefield) == 'body') $sourcestring=$messagetext;
+ elseif (strtolower($sourcefield) == 'subject') $sourcestring=$subject;
+
+ $regforval=array();
+ if (preg_match('/'.$regexstring.'/', $sourcestring, $regforval)) // Do not use preg_quote here, string is already a regex syntax, for example string is 'Name:\s([^\s]*)'
+ {
+ // Overwrite param $tmpproperty
+ $nametouseforthirdparty = $regforval[1];
+ }
+ else
+ {
+ // Nothing can be done for this param
+ }
+ //var_dump($sourcestring); var_dump($regexstring);var_dump($nametouseforthirdparty);exit;
+ }
+ elseif (preg_match('/^VALUE:(.*)$/', $valueforproperty, $reg))
+ {
+ $nametouseforthirdparty = $reg[1];
+ }
+ else
+ {
+ $errorforactions++;
+ $this->error = 'Bad syntax for description of action parameters: '.$actionparam;
+ $this->errors[] = $this->error;
+ break;
+ }
+ }
+
+ if (! $errorforactions && $nametouseforthirdparty)
+ {
+ $result = $thirdpartystatic->fetch(0, $nametouseforthirdparty);
+ if ($result < 0)
+ {
+ $errorforactions++;
+ $this->error = 'Error when getting thirdparty with name '.$nametouseforthirdparty.' (may be 2 record exists with same name ?)';
+ $this->errors[] = $this->error;
+ break;
+ }
+ elseif ($result == 0)
+ {
+ if ($operation['type'] == 'loadandcreatethirdparty')
+ {
+ dol_syslog("Third party with name ".$nametouseforthirdparty." was not found. We try to create it.");
+
+ // Create thirdparty
+ $thirdpartystatic->name = $nametouseforthirdparty;
+ if ($fromtext != $nametouseforthirdparty) $thirdpartystatic->name_alias = $fromtext;
+ $thirdpartystatic->email = $from;
+
+ // Overwrite values with values extracted from source email
+ $errorforthisaction = $this->overwritePropertiesOfObject($thirdpartystatic, $operation['actionparam'], $messagetext, $subject);
+
+ if ($errorforthisaction)
+ {
+ $errorforactions++;
+ }
+ else
+ {
+ $result = $thirdpartystatic->create($user);
+ if ($result <= 0)
+ {
+ $errorforactions++;
+ $this->error = $thirdpartystatic->error;
+ $this->errors = $thirdpartystatic->errors;
+ }
+ }
+ }
+ else
+ {
+ dol_syslog("Third party with name ".$nametouseforthirdparty." was not found");
+ }
+ }
+ }
+ }
+ }
+ // Create event
+ elseif ($operation['type'] == 'recordevent')
+ {
+ $actioncode = 'EMAIL_IN';
+
+ // Insert record of emails sent
+ $actioncomm = new ActionComm($this->db);
+
+ $actioncomm->type_code = 'AC_OTH_AUTO'; // Type of event ('AC_OTH', 'AC_OTH_AUTO', 'AC_XXX'...)
+ $actioncomm->code = 'AC_'.$actioncode;
+ $actioncomm->label = $langs->trans("ActionAC_EMAIL_IN").' - '.$langs->trans("MailFrom").' '.$from;
+ $actioncomm->note = $messagetext;
+ $actioncomm->fk_project = $projectstatic->id;
+ $actioncomm->datep = $date;
+ $actioncomm->datef = $date;
+ $actioncomm->percentage = -1; // Not applicable
+ $actioncomm->socid = $thirdpartystatic->id;
+ $actioncomm->contactid = $contactstatic->id;
+ $actioncomm->authorid = $user->id; // User saving action
+ $actioncomm->userownerid = $user->id; // Owner of action
+ // Fields when action is an email (content should be added into note)
+ $actioncomm->email_msgid = $msgid;
+ $actioncomm->email_from = $fromstring;
+ $actioncomm->email_sender= $sender;
+ $actioncomm->email_to = $to;
+ $actioncomm->email_tocc = $sendtocc;
+ $actioncomm->email_tobcc = $sendtobcc;
+ $actioncomm->email_subject = $subject;
+ $actioncomm->errors_to = '';
+
+ if (! in_array($fk_element_type, array('societe','contact','project','user')))
+ {
+ $actioncomm->fk_element = $fk_element_id;
+ $actioncomm->elementtype = $fk_element_type;
+ }
+
+ //$actioncomm->extraparams = $extraparams;
+
+ // Overwrite values with values extracted from source email
+ $errorforthisaction = $this->overwritePropertiesOfObject($actioncommn, $operation['actionparam'], $messagetext, $subject);
+
+ if ($errorforthisaction)
+ {
+ $errorforactions++;
+ }
+ else
+ {
+ $result = $actioncomm->create($user);
+ if ($result <= 0)
+ {
+ $errorforactions++;
+ $this->errors = $actioncomm->errors;
+ }
+ }
+ }
+ // Create event
+ elseif ($operation['type'] == 'project')
+ {
+ $note_private = $langs->trans("ProjectCreatedByEmailCollector", $msgid);
+ $projecttocreate = new Project($this->db);
+ if ($thirdpartystatic->id > 0)
+ {
+ $projecttocreate->socid = $thirdpartystatic->id;
+ if ($thirdpartyfoundby) $note_private .= ' - Third party found from '.$thirdpartyfoundby;
+ }
+ if ($contactstatic->id > 0)
+ {
+ $projecttocreate->contact_id = $contactstatic->id;
+ if ($contactfoundby) $note_private .= ' - Contact/address found from '.$contactfoundby;
+ }
+
+ $id_opp_status = dol_getIdFromCode($this->db, 'PROSP', 'c_lead_status', 'code', 'rowid');
+ $percent_opp_status = dol_getIdFromCode($this->db, 'PROSP', 'c_lead_status', 'code', 'percent');
+
+ $projecttocreate->title = $subject;
+ $projecttocreate->date_start = $now;
+ $projecttocreate->date_end = '';
+ $projecttocreate->opp_status = $id_opp_status;
+ $projecttocreate->opp_percent = $percent_opp_status;
+ $projecttocreate->description = dol_concatdesc(dol_concatdesc($note_private, dolGetFirstLineOfText(dol_string_nohtmltag($messagetext, 2), 3)), '...'.$langs->transnoentities("SeePrivateNote").'...');
+ $projecttocreate->note_private = dol_concatdesc($note_private, dol_string_nohtmltag($messagetext, 2));
+ $projecttocreate->entity = $conf->entity;
+
+ // Get next project Ref
+ $defaultref='';
+ $modele = empty($conf->global->PROJECT_ADDON)?'mod_project_simple':$conf->global->PROJECT_ADDON;
+
+ // Search template files
+ $file=''; $classname=''; $filefound=0; $reldir='';
+ $dirmodels=array_merge(array('/'),(array) $conf->modules_parts['models']);
+ foreach($dirmodels as $reldir)
+ {
+ $file=dol_buildpath($reldir."core/modules/project/".$modele.'.php',0);
+ if (file_exists($file))
+ {
+ $filefound=1;
+ $classname = $modele;
+ break;
+ }
+ }
+
+ if ($filefound)
+ {
+ $result=dol_include_once($reldir."core/modules/project/".$modele.'.php');
+ $modProject = new $classname;
+
+ $defaultref = $modProject->getNextValue(($thirdpartystatic->id > 0 ? $thirdpartystatic : null), $projecttocreate);
+ }
+
+ $projecttocreate->ref = $defaultref;
+
+ // Overwrite values with values extracted from source email
+ $errorforthisaction = $this->overwritePropertiesOfObject($projecttocreate, $operation['actionparam'], $messagetext, $subject);
+
+ if ($errorforthisaction)
+ {
+ $errorforactions++;
+ }
+ else
+ {
+ if (is_numeric($projecttocreate->ref) && $projecttocreate->ref <= 0)
+ {
+ $errorforactions++;
+ $this->error = 'Failed to create project: Can\'t get a valid value for project Ref';
+ }
+ else
+ {
+ // Create project
+ $result = $projecttocreate->create($user);
+ if ($result <= 0)
+ {
+ $errorforactions++;
+ $this->error = 'Failed to create project: '.$langs->trans($projecttocreate->error);
+ $this->errors = $projecttocreate->errors;
+ }
+ }
+ }
+ }
+
+ if (! $errorforactions)
+ {
+ $nbactiondoneforemail++;
+ }
+ }
+
+ // Error for email or not ?
+ if (! $errorforactions)
+ {
+ if ($targetdir)
+ {
+ dol_syslog("EmailCollector::doCollectOneCollector move message ".$imapemail." to ".$connectstringtarget, LOG_DEBUG);
+ $res = imap_mail_move($connection, $imapemail, $targetdir, 0);
+ if ($res == false) {
+ $errorforemail++;
+ $this->error = imap_last_error();
+ $this->errors[] = $this->error;
+ dol_syslog(imap_last_error());
+ }
+ }
+ else
+ {
+ dol_syslog("EmailCollector::doCollectOneCollector message ".$imapemail." to ".$connectstringtarget." was set to read", LOG_DEBUG);
+ }
+ }
+ else
+ {
+ $errorforemail++;
+ }
+
+ if (! $errorforemail)
+ {
+ $nbactiondone += $nbactiondoneforemail;
+ $nbemailok++;
+
+ $this->db->commit();
+ }
+ else
+ {
+ $error++;
+
+ $this->db->rollback();
+ }
+
+ $nbemailprocessed++;
+
+ unset($objectemail);
+ unset($projectstatic);
+ unset($thirdpartystatic);
+ unset($contactstatic);
+ }
+
+ $output=$langs->trans('XEmailsDoneYActionsDone', $nbemailprocessed, $nbemailok, $nbactiondone);
+ }
+ else
+ {
+ $output=$langs->trans('NoNewEmailToProcess');
+ }
+
+ imap_expunge($connection); // To validate any move
+
+ imap_close($connection);
+
+ $this->datelastresult = $now;
+ $this->lastresult = $output;
+
+ if (! empty($this->errors)) $this->lastresult.= " - ".join(" - ", $this->errors);
+ $this->codelastresult = ($error ? 'KO' : 'OK');
+ $this->update($user);
+
+ dol_syslog("EmailCollector::doCollectOneCollector end", LOG_DEBUG);
+
+ return $error?-1:1;
+ }
}
diff --git a/htdocs/emailcollector/class/emailcollectoraction.class.php b/htdocs/emailcollector/class/emailcollectoraction.class.php
index 620795870a0..ccf811f7607 100644
--- a/htdocs/emailcollector/class/emailcollectoraction.class.php
+++ b/htdocs/emailcollector/class/emailcollectoraction.class.php
@@ -247,6 +247,8 @@ class EmailCollectorAction extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/emailcollector/class/emailcollectorfilter.class.php b/htdocs/emailcollector/class/emailcollectorfilter.class.php
index ddf68ce9512..cafde3a820c 100644
--- a/htdocs/emailcollector/class/emailcollectorfilter.class.php
+++ b/htdocs/emailcollector/class/emailcollectorfilter.class.php
@@ -222,6 +222,8 @@ class EmailCollectorFilter extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/expensereport/class/expensereport.class.php b/htdocs/expensereport/class/expensereport.class.php
index 7f67420f97f..3b93cd0c0ff 100644
--- a/htdocs/expensereport/class/expensereport.class.php
+++ b/htdocs/expensereport/class/expensereport.class.php
@@ -315,8 +315,6 @@ class ExpenseReport extends CommonObject
if (empty($fk_user_author)) $fk_user_author = $user->id;
- $this->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// get extrafields so they will be clone
@@ -339,6 +337,7 @@ class ExpenseReport extends CommonObject
$this->date_validation = '';
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result=$this->create($user);
if ($result < 0) $error++;
diff --git a/htdocs/expensereport/class/paymentexpensereport.class.php b/htdocs/expensereport/class/paymentexpensereport.class.php
index 605affed253..3055984e6c7 100644
--- a/htdocs/expensereport/class/paymentexpensereport.class.php
+++ b/htdocs/expensereport/class/paymentexpensereport.class.php
@@ -421,8 +421,6 @@ class PaymentExpenseReport extends CommonObject
$object=new PaymentExpenseReport($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -434,6 +432,7 @@ class PaymentExpenseReport extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -446,11 +445,9 @@ class PaymentExpenseReport extends CommonObject
if (! $error)
{
-
-
}
- unset($this->context['createfromclone']);
+ unset($object->context['createfromclone']);
// End
if (! $error)
diff --git a/htdocs/fichinter/class/fichinter.class.php b/htdocs/fichinter/class/fichinter.class.php
index 32643b77811..e20d8e1da1a 100644
--- a/htdocs/fichinter/class/fichinter.class.php
+++ b/htdocs/fichinter/class/fichinter.class.php
@@ -1118,8 +1118,6 @@ class Fichinter extends CommonObject
$error=0;
- $this->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// get extrafields so they will be clone
@@ -1158,6 +1156,7 @@ class Fichinter extends CommonObject
$this->ref_client = '';
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result=$this->create($user);
if ($result < 0) $error++;
diff --git a/htdocs/fourn/class/fournisseur.commande.class.php b/htdocs/fourn/class/fournisseur.commande.class.php
index 8dc10d82b3b..d92159c3234 100644
--- a/htdocs/fourn/class/fournisseur.commande.class.php
+++ b/htdocs/fourn/class/fournisseur.commande.class.php
@@ -1417,8 +1417,6 @@ class CommandeFournisseur extends CommonOrder
$error=0;
- $this->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -1439,6 +1437,7 @@ class CommandeFournisseur extends CommonOrder
$this->date_approve2 = '';
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result=$this->create($user);
if ($result < 0) $error++;
diff --git a/htdocs/fourn/class/fournisseur.commande.dispatch.class.php b/htdocs/fourn/class/fournisseur.commande.dispatch.class.php
index 9bc6ec3fbc3..ee4602d7093 100644
--- a/htdocs/fourn/class/fournisseur.commande.dispatch.class.php
+++ b/htdocs/fourn/class/fournisseur.commande.dispatch.class.php
@@ -496,6 +496,7 @@ class CommandeFournisseurDispatch extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -508,9 +509,10 @@ class CommandeFournisseurDispatch extends CommonObject
if (! $error)
{
-
}
+ unset($object->context['createfromclone']);
+
// End
if (! $error)
{
diff --git a/htdocs/fourn/class/fournisseur.facture.class.php b/htdocs/fourn/class/fournisseur.facture.class.php
index 42189a30380..1dab0e9f82e 100644
--- a/htdocs/fourn/class/fournisseur.facture.class.php
+++ b/htdocs/fourn/class/fournisseur.facture.class.php
@@ -2489,8 +2489,6 @@ class FactureFournisseur extends CommonInvoice
$object=new FactureFournisseur($this->db);
- $object->context['createfromclone'] = 'createfromclone';
-
$this->db->begin();
// Load source object
@@ -2521,6 +2519,7 @@ class FactureFournisseur extends CommonInvoice
}
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result=$object->create($user);
// Other options
@@ -2533,8 +2532,6 @@ class FactureFournisseur extends CommonInvoice
if (! $error)
{
-
-
}
unset($object->context['createfromclone']);
diff --git a/htdocs/langs/en_US/admin.lang b/htdocs/langs/en_US/admin.lang
index 1a731e20b05..3540f3f9567 100644
--- a/htdocs/langs/en_US/admin.lang
+++ b/htdocs/langs/en_US/admin.lang
@@ -602,8 +602,6 @@ Module2700Desc=Use online Gravatar service (www.gravatar.com) to show photo of u
Module2800Desc=FTP Client
Module2900Name=GeoIPMaxmind
Module2900Desc=GeoIP Maxmind conversions capabilities
-Module3100Name=Skype
-Module3100Desc=Add a Skype button to cards for users/third parties/contacts/members
Module3200Name=Unalterable Archives
Module3200Desc=Enable an unalterable log of business events. Events are archived in real-time. The log is a read-only table of chained events that can be exported. This module may be mandatory for some countries.
Module4000Name=HRM
diff --git a/htdocs/modulebuilder/template/class/myobject.class.php b/htdocs/modulebuilder/template/class/myobject.class.php
index b102ab004a9..6f3b76a4f1b 100644
--- a/htdocs/modulebuilder/template/class/myobject.class.php
+++ b/htdocs/modulebuilder/template/class/myobject.class.php
@@ -289,6 +289,8 @@ class MyObject extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/product/class/productbatch.class.php b/htdocs/product/class/productbatch.class.php
index eb4fc32baed..d16c6ccc6ec 100644
--- a/htdocs/product/class/productbatch.class.php
+++ b/htdocs/product/class/productbatch.class.php
@@ -338,8 +338,6 @@ class Productbatch extends CommonObject
$object=new Productbatch($this->db);
- $object->context['createfromclone']='createfromclone';
-
$this->db->begin();
// Load source object
@@ -351,6 +349,7 @@ class Productbatch extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone']='createfromclone';
$result=$object->create($user);
// Other options
@@ -363,7 +362,6 @@ class Productbatch extends CommonObject
if (! $error)
{
-
}
unset($object->context['createfromclone']);
diff --git a/htdocs/product/class/productcustomerprice.class.php b/htdocs/product/class/productcustomerprice.class.php
index 3079fef5412..d39849780c1 100644
--- a/htdocs/product/class/productcustomerprice.class.php
+++ b/htdocs/product/class/productcustomerprice.class.php
@@ -907,8 +907,6 @@ class Productcustomerprice extends CommonObject
$object = new Productcustomerprice($this->db);
- $object->context['createfromclone']='createfromclone';
-
$this->db->begin();
// Load source object
@@ -920,6 +918,7 @@ class Productcustomerprice extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone']='createfromclone';
$result = $object->create($user);
// Other options
@@ -929,6 +928,7 @@ class Productcustomerprice extends CommonObject
}
if (! $error) {
+
}
unset($object->context['createfromclone']);
diff --git a/htdocs/product/class/propalmergepdfproduct.class.php b/htdocs/product/class/propalmergepdfproduct.class.php
index b5d2d639ae4..3aeae37249c 100644
--- a/htdocs/product/class/propalmergepdfproduct.class.php
+++ b/htdocs/product/class/propalmergepdfproduct.class.php
@@ -582,6 +582,7 @@ class Propalmergepdfproduct extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone']='createfromclone';
$result=$object->create($user);
// Other options
@@ -594,9 +595,10 @@ class Propalmergepdfproduct extends CommonObject
if (! $error)
{
-
}
+ unset($object->context['createfromclone']);
+
// End
if (! $error)
{
diff --git a/htdocs/product/inventory/class/inventory.class.php b/htdocs/product/inventory/class/inventory.class.php
index 1bc98d32d93..076e3392bc0 100644
--- a/htdocs/product/inventory/class/inventory.class.php
+++ b/htdocs/product/inventory/class/inventory.class.php
@@ -247,6 +247,8 @@ class Inventory extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/product/stock/class/productlot.class.php b/htdocs/product/stock/class/productlot.class.php
index d61630eb88e..60ce7bc02d2 100644
--- a/htdocs/product/stock/class/productlot.class.php
+++ b/htdocs/product/stock/class/productlot.class.php
@@ -454,6 +454,7 @@ class Productlot extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
@@ -463,6 +464,8 @@ class Productlot extends CommonObject
dol_syslog(__METHOD__ . ' ' . join(',', $this->errors), LOG_ERR);
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/product/stock/class/productstockentrepot.class.php b/htdocs/product/stock/class/productstockentrepot.class.php
index f76f5eeec9c..c5c66ad8d50 100644
--- a/htdocs/product/stock/class/productstockentrepot.class.php
+++ b/htdocs/product/stock/class/productstockentrepot.class.php
@@ -443,6 +443,7 @@ class ProductStockEntrepot extends CommonObject
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
@@ -452,6 +453,8 @@ class ProductStockEntrepot extends CommonObject
dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR);
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/societe/class/companypaymentmode.class.php b/htdocs/societe/class/companypaymentmode.class.php
index 73242c9aa32..3594773e7f8 100644
--- a/htdocs/societe/class/companypaymentmode.class.php
+++ b/htdocs/societe/class/companypaymentmode.class.php
@@ -269,6 +269,8 @@ class CompanyPaymentMode extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/societe/class/societeaccount.class.php b/htdocs/societe/class/societeaccount.class.php
index 78f934ecf2f..153959938e5 100644
--- a/htdocs/societe/class/societeaccount.class.php
+++ b/htdocs/societe/class/societeaccount.class.php
@@ -240,6 +240,8 @@ class SocieteAccount extends CommonObject
$this->errors = $object->errors;
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/supplier_proposal/class/supplier_proposal.class.php b/htdocs/supplier_proposal/class/supplier_proposal.class.php
index 82b8b09220d..5d4fbed5e72 100644
--- a/htdocs/supplier_proposal/class/supplier_proposal.class.php
+++ b/htdocs/supplier_proposal/class/supplier_proposal.class.php
@@ -1176,6 +1176,7 @@ class SupplierProposal extends CommonObject
$this->ref = $modSupplierProposal->getNextValue($objsoc,$this);
// Create clone
+ $this->context['createfromclone'] = 'createfromclone';
$result=$this->create($user);
if ($result < 0) $error++;
@@ -1191,6 +1192,8 @@ class SupplierProposal extends CommonObject
}
}
+ unset($this->context['createfromclone']);
+
// End
if (! $error)
{
diff --git a/htdocs/ticket/class/ticket.class.php b/htdocs/ticket/class/ticket.class.php
index 3bd35199d2f..dd3307a391c 100644
--- a/htdocs/ticket/class/ticket.class.php
+++ b/htdocs/ticket/class/ticket.class.php
@@ -971,6 +971,7 @@ class Ticket extends CommonObject
// Clear fields
// ...
// Create clone
+ $object->context['createfromclone'] = 'createfromclone';
$result = $object->create($user);
// Other options
@@ -982,6 +983,8 @@ class Ticket extends CommonObject
if (!$error) {
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/website/class/website.class.php b/htdocs/website/class/website.class.php
index 3e962eb9713..0e6ee83aa9d 100644
--- a/htdocs/website/class/website.class.php
+++ b/htdocs/website/class/website.class.php
@@ -593,11 +593,11 @@ class Website extends CommonObject
{
// Delete old file
$filetplold=$pathofwebsitenew.'/page'.$pageid.'.tpl.php';
- dol_syslog("We regenerate alias page new name=".$filealias.", old name=".$fileoldalias);
dol_delete_file($filetplold);
// Create new file
$objectpagenew = $objectpageold->createFromClone($user, $pageid, $objectpageold->pageurl, '', 0, $object->id, 1);
+
//print $pageid.' = '.$objectpageold->pageurl.' -> '.$objectpagenew->id.' = '.$objectpagenew->pageurl.'
';
if (is_object($objectpagenew) && $objectpagenew->pageurl)
{
@@ -632,7 +632,7 @@ class Website extends CommonObject
if (! $res > 0)
{
$error++;
- setEventMessages($objectpage->error, $objectpage->errors, 'errors');
+ setEventMessages($object->error, $object->errors, 'errors');
}
if (! $error)
@@ -646,6 +646,8 @@ class Website extends CommonObject
}
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
diff --git a/htdocs/website/class/websitepage.class.php b/htdocs/website/class/websitepage.class.php
index 3c166c1d1f8..ffa2176f142 100644
--- a/htdocs/website/class/websitepage.class.php
+++ b/htdocs/website/class/websitepage.class.php
@@ -447,6 +447,8 @@ class WebsitePage extends CommonObject
dol_syslog(__METHOD__ . ' ' . join(',', $this->errors), LOG_ERR);
}
+ unset($object->context['createfromclone']);
+
// End
if (!$error) {
$this->db->commit();
|