ActivityStatisticsTable::upsert

static function upsert(array $data)
{
	$fields = array(
		'OWNER_TYPE_ID' => isset($data['OWNER_TYPE_ID']) ? (int)$data['OWNER_TYPE_ID'] : 0,
		'RESPONSIBLE_ID' => isset($data['RESPONSIBLE_ID']) ? (int)$data['RESPONSIBLE_ID'] : 0,
		'COMPLETED' => isset($data['COMPLETED']) && $data['COMPLETED'] === 'Y' ? 'Y' : 'N',
		'STATUS_ID' => isset($data['STATUS_ID']) ? (int)$data['STATUS_ID'] : 0,
		'MARK_ID' => isset($data['MARK_ID']) ? (int)$data['MARK_ID'] : 0,
		'SOURCE_ID' => isset($data['SOURCE_ID']) ? $data['SOURCE_ID'] : '',
		'STREAM_ID' => isset($data['STREAM_ID']) ? (int)$data['STREAM_ID'] : 0,
		'CURRENCY_ID' => isset($data['CURRENCY_ID']) ? $data['CURRENCY_ID'] : '',
		'SUM_TOTAL' => isset($data['SUM_TOTAL']) ? (float)$data['SUM_TOTAL'] : 0.0
	);

	$connection = Main\Application::getConnection();
	$queries = $connection->getSqlHelper()->prepareMerge(
		'b_crm_act_stat',
		array('OWNER_ID', 'DEADLINE_DATE', 'PROVIDER_ID', 'PROVIDER_TYPE_ID'),
		array_merge(
			$fields,
			array(
				'OWNER_ID' => isset($data['OWNER_ID']) ? $data['OWNER_ID'] : 0,
				'DEADLINE_DATE' => isset($data['DEADLINE_DATE']) ? $data['DEADLINE_DATE'] : null,
				'PROVIDER_ID' => isset($data['PROVIDER_ID']) ? $data['PROVIDER_ID'] : null,
				'PROVIDER_TYPE_ID' => isset($data['PROVIDER_TYPE_ID']) ? $data['PROVIDER_TYPE_ID'] : null,
			)
		),
		$fields
	);

	foreach($queries as $query)
	{
		$connection->queryExecute($query);
	}
}