"; $html .= ''; $html .= ': *  '; $html .= "'; $html .= ':'; $html .= ""; $html .= ""; $html .= ''.translate("LBL_COPY_EMAIL_ADDRESSES_WORKFLOW", "AOW_Actions").':  '; $html .= ""; $html .= ""; $html .= ''; $html .= ''; $html .= '
'; $html .= ''; $html .= ''; $html .= ''; $html .= ''; $html .= ''; $html .= '
'; $html .= ''; $html .= ''; $html .= ''; $html .= ''; if (isset($params['record_type']) && $params['record_type'] != '') { require_once 'modules/AOW_WorkFlow/aow_utils.php'; $html .= "'; } return $html; } /** * @param SugarBean $bean * @param array $params * @param bool $in_save * @return bool */ public function run_action(SugarBean $bean, $params = array(), $in_save = false) { global $beanList; if (isset($params['record_type']) && $params['record_type'] != '') { if ($beanList[$params['record_type']]) { $record = new $beanList[$params['record_type']](); $this->set_record($record, $bean, $params); $this->set_relationships($record, $bean, $params); $invalidEmails = $this->copyEmailAddresses($record, $bean, $params); if ($invalidEmails > 0) { LoggerManager::getLogger()->warn("Given bean contains $invalidEmails invalid Email address(es)."); } if ($invalidEmails < 0) { LoggerManager::getLogger()->error("Email address copy error occured, bean was: $bean->module_name"); } if (isset($params['relate_to_workflow']) && $params['relate_to_workflow']) { require_once 'modules/Relationships/Relationship.php'; $dbManager = DBManagerFactory::getInstance(); $key = Relationship::retrieve_by_modules($bean->module_dir, $record->module_dir, $dbManager); if (!empty($key)) { foreach ($bean->field_defs as $field=>$def) { if ($def['type'] == 'link' && !empty($def['relationship']) && $def['relationship'] == $key) { $bean->load_relationship($field); $bean->$field->add($record->id); break; } } } } return true; } } return false; } /** * @param SugarBean $record * @param SugarBean $bean * @param array $params * @param bool $in_save */ public function set_record(SugarBean $record, SugarBean $bean, $params = array(), $in_save = false) { global $app_list_strings, $timedate; $record_vardefs = $record->getFieldDefinitions(); if (isset($params['field'])) { foreach ($params['field'] as $key => $field) { if ($field === '') { continue; } $value = ''; switch ($params['value_type'][$key]) { case 'Field': if ($params['value'][$key] === '') { continue 2; } $fieldName = $params['value'][$key]; $data = $bean->field_defs[$fieldName]; switch ($data['type']) { case 'double': case 'decimal': case 'currency': case 'float': case 'uint': case 'ulong': case 'long': case 'short': case 'tinyint': case 'int': $value = format_number($bean->$fieldName); break; case 'relate': if (isset($data['id_name']) && $record_vardefs[$field]['type'] === 'relate') { $idName = $data['id_name']; $value = $bean->$idName; } else { $value = $bean->$fieldName; } break; default: $value = $bean->$fieldName; break; } break; case 'Date': $dformat = 'Y-m-d H:i:s'; if ($record_vardefs[$field]['type'] === 'date') { $dformat = 'Y-m-d'; } switch ($params['value'][$key][3]) { case 'business_hours': require_once 'modules/AOBH_BusinessHours/AOBH_BusinessHours.php'; $businessHours = BeanFactory::newBean('AOBH_BusinessHours'); $dateToUse = $params['value'][$key][0]; $sign = $params['value'][$key][1]; $amount = $params['value'][$key][2]; if ($sign !== 'plus') { $amount = 0-$amount; } if ($dateToUse === 'now') { $value = $businessHours->addBusinessHours($amount); } elseif ($dateToUse === 'field') { $dateToUse = $params['field'][$key]; $value = $businessHours->addBusinessHours($amount, $timedate->fromDb($bean->$dateToUse)); } else { $value = $businessHours->addBusinessHours($amount, $timedate->fromDb($bean->$dateToUse)); } $value = $timedate->asDb($value); break; default: if ($params['value'][$key][0] === 'now') { $date = gmdate($dformat); } elseif ($params['value'][$key][0] === 'field') { $dateToUse = $params['field'][$key]; $date = $record->$dateToUse; } elseif ($params['value'][$key][0] === 'today') { $date = $params['value'][$key][0]; } else { $dateToUse = $params['value'][$key][0]; $date = $bean->$dateToUse; } if ($params['value'][$key][1] !== 'now') { $value = date($dformat, strtotime($date . ' '.$app_list_strings['aow_date_operator'][$params['value'][$key][1]].$params['value'][$key][2].' '.$params['value'][$key][3])); } else { $value = date($dformat, strtotime($date)); } break; } break; case 'Round_Robin': case 'Least_Busy': case 'Random': switch ($params['value'][$key][0]) { case 'security_group': require_once 'modules/SecurityGroups/SecurityGroup.php'; $security_group = BeanFactory::newBean('SecurityGroups'); $security_group->retrieve($params['value'][$key][1]); $group_users = $security_group->get_linked_beans('users', 'User'); $users = array(); $r_users = array(); if ($params['value'][$key][2] != '') { require_once 'modules/ACLRoles/ACLRole.php'; $role = BeanFactory::newBean('ACLRoles'); $role->retrieve($params['value'][$key][2]); $role_users = $role->get_linked_beans('users', 'User'); foreach ($role_users as $role_user) { $r_users[$role_user->id] = $role_user->name; } } foreach ($group_users as $group_user) { if ($params['value'][$key][2] != '' && !isset($r_users[$group_user->id])) { continue; } $users[$group_user->id] = $group_user->name; } break; case 'role': require_once 'modules/ACLRoles/ACLRole.php'; $role = BeanFactory::newBean('ACLRoles'); $role->retrieve($params['value'][$key][2]); $role_users = $role->get_linked_beans('users', 'User'); $users = array(); foreach ($role_users as $role_user) { $users[$role_user->id] = $role_user->name; } break; case 'all': default: $users = get_user_array(false); break; } // format the users array $users = array_values(array_flip($users)); if (empty($users)) { $value = ''; } elseif (count($users) == 1) { $value = $users[0]; } else { switch ($params['value_type'][$key]) { case 'Round_Robin': $value = getRoundRobinUser($users, $this->id); break; case 'Least_Busy': $user_id = 'assigned_user_id'; if (isset($record_vardefs[$field]['id_name']) && $record_vardefs[$field]['id_name'] != '') { $user_id = $record_vardefs[$field]['id_name']; } $value = getLeastBusyUser($users, $user_id, $record); break; case 'Random': default: shuffle($users); $value = $users[0]; break; } } setLastUser($value, $this->id); break; case 'Value': default: $value = $params['value'][$key]; break; } if ($record_vardefs[$field]['type'] === 'relate' && isset($record_vardefs[$field]['id_name'])) { $field = $record_vardefs[$field]['id_name']; } $record->$field = $value; } } $bean_processed = isset($record->processed) ? $record->processed : false; $assignedUserId = $record->fetched_row['assigned_user_id'] ?? ''; if ($in_save) { global $current_user; $record->processed = true; $check_notify = $record->assigned_user_id != $current_user->id && $record->assigned_user_id != $assignedUserId; } else { $check_notify = $record->assigned_user_id != $assignedUserId; } $record->process_save_dates =false; $record->new_with_id = false; /* Since we only work on non-deleted records this means the delete field * was set during this action. * Complete the deletion process by calling mark_deleted() after save() */ $was_deleted = false; if ($record->deleted) { $record->deleted = 0; $was_deleted = true; } $record->save($check_notify); if ($was_deleted) { $record->mark_deleted($record->id); } $record->processed = $bean_processed; } /** * @param SugarBean $record * @param SugarBean $bean * @param array $params */ public function set_relationships(SugarBean $record, SugarBean $bean, $params = array()) { $record_vardefs = $record->getFieldDefinitions(); require_once 'modules/Relationships/Relationship.php'; if (isset($params['rel'])) { foreach ($params['rel'] as $key => $field) { if ($field == '' || $params['rel_value'][$key] == '') { continue; } $relField = $params['rel_value'][$key]; switch ($params['rel_value_type'][$key]) { case 'Field': $data = $bean->field_defs[$relField]; if ($data['type'] == 'relate' && isset($data['id_name'])) { $relField = $data['id_name']; } $rel_id = $bean->$relField; break; default: $rel_id = $relField; break; } $def = $record_vardefs[$field]; if ($def['type'] == 'link' && !empty($def['relationship'])) { $record->load_relationship($field); $record->$field->add($rel_id); } } } } /** * * @param SugarBean $toBean * @param SugarBean $fromBean * @param array $params * @return int Number of invalid email addresses found in $fromBean's email addresses argument. Negative numbers are error code */ protected function copyEmailAddresses(SugarBean $toBean, SugarBean $fromBean, $params = array()) { $ret = 0; if (isset($params['copy_email_addresses']) && $params['copy_email_addresses']) { $toBean->addresses = $fromBean->addresses; $toBean->email1 = $fromBean->email1; $toBean->email2 = $fromBean->email2; if (isset($fromBean->emailAddress) && $fromBean->emailAddress instanceof SugarEmailAddress) { $tmp_sea2 = new SugarEmailAddress(); foreach ($fromBean->emailAddress->addresses as $currentEmailAddress) { if ($this->validateCurrentEmailAddress($currentEmailAddress)) { $ret++; } $tmp_sea2->addAddress( $currentEmailAddress['email_address'], $currentEmailAddress['primary_address'], $currentEmailAddress['reply_to_address'], $currentEmailAddress['invalid_email'], $currentEmailAddress['opt_out'], $currentEmailAddress['email_address_id'] ); } $tmp_sea2->saveEmail($toBean->id, $toBean->module_name); } else { // exception LoggerManager::getLogger()->error('From-bean should implement emailAddress. Given bean is ' . $fromBean->module_name); return -1; } } else { // exception LoggerManager::getLogger()->error('Given parameter should contains index "copy_email_addresses"'); return -2; } return $ret; } /** * * @param arra $currentEmailAddress * @return bool Returns TRUE if it's a valid email address parameter, FALSE otherwise. */ protected function validateCurrentEmailAddress($currentEmailAddress) { $ret = true; if (!isset($currentEmailAddress['email_address'])) { LoggerManager::getLogger()->warn('Index "email_address" is not set.'); $ret = false; } if (!isset($currentEmailAddress['primary_address'])) { LoggerManager::getLogger()->warn('Index "primary_address" is not set.'); $ret = false; } if (!isset($currentEmailAddress['reply_to_address'])) { LoggerManager::getLogger()->warn('Index "reply_to_address" is not set.'); $ret = false; } if (!isset($currentEmailAddress['invalid_email'])) { LoggerManager::getLogger()->warn('Index "invalid_email" is not set.'); $ret = false; } if (!isset($currentEmailAddress['opt_out'])) { LoggerManager::getLogger()->warn('Index "opt_out" is not set.'); $ret = false; } if (!isset($currentEmailAddress['email_address_id'])) { LoggerManager::getLogger()->warn('Index "email_address_id" is not set.'); $ret = false; } return $ret; } }