Files
crm.clientright.ru/modules/Workflow2/tasks/WfTaskCampaign_result.php
Fedor ac7467f0b4 Major CRM updates: AI Assistant, Court Status API, S3 integration improvements, and extensive file storage system
- Added comprehensive AI Assistant system (aiassist/ directory):
  * Vector search and embedding capabilities
  * Typebot proxy integration
  * Elastic search functionality
  * Message classification and chat history
  * MCP proxy for external integrations

- Implemented Court Status API (GetCourtStatus.php):
  * Real-time court document status checking
  * Integration with external court systems
  * Comprehensive error handling and logging

- Enhanced S3 integration:
  * Improved file backup system with metadata
  * Batch processing capabilities
  * Enhanced error logging and recovery
  * Copy operations with URL fixing

- Added Telegram contact creation API
- Improved error logging across all modules
- Enhanced callback system for AI responses
- Extensive backup file storage with timestamps
- Updated documentation and README files

- File storage improvements:
  * Thousands of backup files with proper metadata
  * Fix operations for broken file references
  * Project-specific backup and recovery systems
  * Comprehensive file integrity checking

Total: 26,461+ files added/modified including AWS SDK, vendor dependencies, and extensive backup system.
2025-10-16 11:17:21 +03:00

114 lines
3.7 KiB
PHP

<?php
require_once(realpath(dirname(__FILE__).'/../autoload_wf.php'));
class WfTaskCampaign_result extends \Workflow\Task
{
protected $_internalConfiguration = true;
protected $_configFields = array(
"Configuration" => array(
array(
"key" => 'recordids',
"label" => '$env Variable der RecordIDs',
"type" => "templatefield"
),
),
"OUTPUT" => array(
array(
"key" => "env_output",
"label" => 'HTML Output $env Variable',
"type" => "envvar"
),
)
);
public function handleTask(&$context) {
/* Insert here source code to execute the task */
$available_status = array(
'1' => 'verfügbar',
'0' => 'unbrauchbar',
'4' => 'kein Interesse',
'3' => 'Information Versand',
'5' => 'Info Versand KI',
'2' => 'Termin vereinbart',
'6' => 'Termin KI',
'7' => 'Angebot',
);
// load values from request values popup
$env = $context->getEnvironment('value');
// security check to only query dates
$date_from = date('Y-m-d', strtotime($env['date_from']));
$date_to = date('Y-m-d', strtotime($env['date_to']));
$envVar = $this->get('recordids');
$recordids = $context->getEnvironment($envVar);
if(empty($recordids)) {
$recordids = $context->getId();
}
$recordids = preg_replace('/[^0-9,]/', '', $recordids);
$recordids = explode(',', $recordids);
$adb = \PearDatabase::getInstance();
$tableName = 'vtiger_campaigncontrel';
$sql = 'SELECT campaignid, '.$tableName.'.campaignrelstatusid, COUNT(*) as num
FROM '.$tableName.'
WHERE ((calldate >= ? AND calldate <= ?) OR campaignrelstatusid = 1) AND campaignid IN ('.generateQuestionMarks($recordids).') GROUP BY campaignid, '.$tableName.'.campaignrelstatusid';
$params = $adb->flatten_array(array($date_from, $date_to, $recordids));
$this->addStat($adb->convert2Sql($sql, $params));
$result = $adb->pquery($sql, $params, true);
$campaigns = array();
while($row = $adb->fetchByAssoc($result)) {
$campaigns[$row['campaignid']][$row['campaignrelstatusid']] = $row['num'];
}
$table = '<table border="0" cellpadding="5">';
$table .= '<tr>';
$table .= '<td>Kampagne</td>';
foreach($available_status as $id => $label) {
$ids[] = $id;
$table .= '<td style="padding:5px 10px;"><strong>'.vtranslate($label, 'Campaigns').'</strong></td>';
}
/*
$sql = 'SELECT * FROM vtiger_campaignrelstatus ORDER BY sortorderid';
$result = $adb->query($sql, true);
$ids = array();
while($row = $adb->fetchByAssoc($result)) {
$ids[] = $row['campaignrelstatusid'];
}
*/
$table .= '</tr>';
foreach($campaigns as $campaignid => $status) {
$campaign = \Workflow\VTEntity::getForId($campaignid, 'Campaigns');
$table .= '<tr>';
$table .= '<td style="padding:5px 10px 5px 5px;">'.$campaign->get('campaignname').'</td>';
foreach($ids as $statusid) {
$table .= '<td align="right">'.(!isset($status[$statusid])?0:intval($status[$statusid])).'</td>';
}
$table .= '</tr>';
}
$table .= '</table>';
$newEnvId = $this->get('env_output');
$context->setEnvironment($newEnvId, $table);
return "yes";
}
}