Файловый менеджер

Файловый менеджер - Редактировать - /var/www/axolotl/data/www/axolotls.ru/www/bitrix/modules/crm/lib/volume.php

Назад
<?php namespace Bitrix\Crm; use Bitrix\Crm; use Bitrix\Main; use Bitrix\Main\ORM; use Bitrix\Crm\Volume; use Bitrix\Main\Type\DateTime; use Bitrix\Main\Entity; /** * Class VolumeTable * * Fields: * <ul> * <li> ID int mandatory * <li> INDICATOR_TYPE string(255) mandatory * <li> OWNER_ID int mandatory * <li> TIMESTAMP_X datetime optional * <li> DATE_CREATE date optional * <li> STAGE_SEMANTIC_ID string(3) optional * <li> ENTITY_SIZE float optional * <li> ENTITY_COUNT float optional * <li> FILE_SIZE float optional * <li> FILE_COUNT float optional * <li> DISK_SIZE float optional * <li> DISK_COUNT float optional * <li> EVENT_SIZE float optional * <li> EVENT_COUNT float optional * <li> ACTIVITY_SIZE float optional * <li> ACTIVITY_COUNT float optional * <li> AGENT_LOCK int optional * <li> DROP_ENTITY int optional * <li> DROP_FILE int optional * <li> DROP_EVENT int optional * <li> DROP_ACTIVITY int optional * <li> DROPPED_ENTITY_COUNT float optional * <li> DROPPED_FILE_COUNT float optional * <li> DROPPED_EVENT_COUNT float optional * <li> DROPPED_ACTIVITY_COUNT float optional * <li> LAST_ID int optional * <li> FAIL_COUNT int optional * <li> LAST_ERROR string(255) optional * <li> FILTER string(255) optional * </ul> * * @package Bitrix\Crm / class VolumeTable extends ORM\Data\DataManager { / * Returns DB table name for entity * @return string / public static function getTableName() { return 'b_crm_volume'; } /* * Returns entity map definition. * @return array / public static function getMap() { return array( 'ID' => array( 'data_type' => 'integer', 'primary' => true, 'autocomplete' => true, ), 'INDICATOR_TYPE' => array( 'data_type' => 'string', ), 'OWNER_ID' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'TIMESTAMP_X' => array( 'data_type' => 'datetime', 'default_value' => function() { return new DateTime(); }, ), 'DATE_CREATE' => array( 'data_type' => 'date', ), 'STAGE_SEMANTIC_ID' => array( 'data_type' => 'enum', 'values' => array( Crm\PhaseSemantics::UNDEFINED, Crm\PhaseSemantics::PROCESS, Crm\PhaseSemantics::SUCCESS, Crm\PhaseSemantics::FAILURE, ), 'default_value' => Crm\PhaseSemantics::UNDEFINED, ), 'ENTITY_SIZE' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'ENTITY_COUNT' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'FILE_SIZE' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'FILE_COUNT' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'DISK_SIZE' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'DISK_COUNT' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'EVENT_SIZE' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'EVENT_COUNT' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'ACTIVITY_SIZE' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'ACTIVITY_COUNT' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'AGENT_LOCK' => array( 'data_type' => 'enum', 'values' => array( Volume\Cleaner::TASK_STATUS_NONE, Volume\Cleaner::TASK_STATUS_WAIT, Volume\Cleaner::TASK_STATUS_RUNNING, Volume\Cleaner::TASK_STATUS_DONE, Volume\Cleaner::TASK_STATUS_CANCEL, ), 'default_value' => Volume\Cleaner::TASK_STATUS_NONE, ), 'DROP_ENTITY' => array( 'data_type' => 'enum', 'values' => array( Volume\Cleaner::TASK_STATUS_NONE, Volume\Cleaner::TASK_STATUS_WAIT, Volume\Cleaner::TASK_STATUS_RUNNING, Volume\Cleaner::TASK_STATUS_DONE, Volume\Cleaner::TASK_STATUS_CANCEL, ), 'default_value' => Volume\Cleaner::TASK_STATUS_NONE, ), 'DROP_FILE' => array( 'data_type' => 'enum', 'values' => array( Volume\Cleaner::TASK_STATUS_NONE, Volume\Cleaner::TASK_STATUS_WAIT, Volume\Cleaner::TASK_STATUS_RUNNING, Volume\Cleaner::TASK_STATUS_DONE, Volume\Cleaner::TASK_STATUS_CANCEL, ), 'default_value' => Volume\Cleaner::TASK_STATUS_NONE, ), 'DROP_EVENT' => array( 'data_type' => 'enum', 'values' => array( Volume\Cleaner::TASK_STATUS_NONE, Volume\Cleaner::TASK_STATUS_WAIT, Volume\Cleaner::TASK_STATUS_RUNNING, Volume\Cleaner::TASK_STATUS_DONE, Volume\Cleaner::TASK_STATUS_CANCEL, ), 'default_value' => Volume\Cleaner::TASK_STATUS_NONE, ), 'DROP_ACTIVITY' => array( 'data_type' => 'enum', 'values' => array( Volume\Cleaner::TASK_STATUS_NONE, Volume\Cleaner::TASK_STATUS_WAIT, Volume\Cleaner::TASK_STATUS_RUNNING, Volume\Cleaner::TASK_STATUS_DONE, Volume\Cleaner::TASK_STATUS_CANCEL, ), 'default_value' => Volume\Cleaner::TASK_STATUS_NONE, ), 'DROPPED_ENTITY_COUNT' => array( 'data_type' => 'integer', ), 'DROPPED_FILE_COUNT' => array( 'data_type' => 'integer', ), 'DROPPED_EVENT_COUNT' => array( 'data_type' => 'integer', ), 'DROPPED_ACTIVITY_COUNT' => array( 'data_type' => 'integer', ), 'LAST_ID' => array( 'data_type' => 'integer', ), 'FAIL_COUNT' => array( 'data_type' => 'integer', 'default_value' => 0, ), 'LAST_ERROR' => array( 'data_type' => 'string', ), 'FILTER' => array( 'data_type' => 'string', ), ); } /* * Deletes rows by filter. * @param array $filter Filter does not look like filter in getList. It depends by current implementation. * @return void / public static function deleteBatch(array $filter) { $whereSql = Entity\Query::buildFilterSql(static::getEntity(), $filter); if (strlen($whereSql) > 0) { $tableName = static::getTableName(); $connection = Main\Application::getConnection(); $connection->queryExecute("DELETE FROM {$tableName} WHERE {$whereSql}"); } } /* * Deletes rows by filter. * @param Entity\Query\|string $query Query. * @param array $updateField Field list to update. * @param array $compareField Field list to compare in where statement. * @return void / public static function updateFromSelect($query, array $updateField, array $compareField) { if ($query instanceof Entity\Query) { $querySql = $query->getQuery(); } else { $querySql = $query; } $updateStatement = array(); foreach ($updateField as $destinationField => $sourceField) { $sourceField = str_replace( array('source', 'destination'), array('sourceQuery', 'destinationTbl'), $sourceField ); $updateStatement[] = "destinationTbl.{$destinationField} = {$sourceField}"; } $updateSql = implode(', ', $updateStatement); $whereStatement = array(); foreach ($compareField as $destinationField => $sourceField) { if (is_numeric($destinationField)) { $destinationField = $sourceField; } $whereStatement[] = "( (destinationTbl.{$destinationField} = sourceQuery.{$sourceField}) OR (destinationTbl.{$destinationField} IS NULL AND sourceQuery.{$sourceField} IS NULL) )"; } $whereSql = implode(' AND ', $whereStatement); if ($whereSql != '') { $tableName = static::getTableName(); $connection = Main\Application::getConnection(); $connection->queryExecute("UPDATE {$tableName} destinationTbl, ( {$querySql} ) sourceQuery SET {$updateSql} WHERE {$whereSql}"); } } /* * Removes all data * @return void */ public static function purify() { $connection = Main\Application::getConnection(); $connection->truncateTable(self::getTableName()); } }

| ver. 1.4 | Github | . | PHP 7.4.8 | Генерация страницы: 0 | proxy | phpinfo | Настройка