diff options
author | redmatrix <redmatrix@redmatrix.me> | 2015-09-07 21:01:49 -0700 |
---|---|---|
committer | redmatrix <redmatrix@redmatrix.me> | 2015-09-07 21:01:49 -0700 |
commit | 650e98b2a9aff2f54be84782ac48cc57badbf76f (patch) | |
tree | 4992bd3083726c5bc8f570a250321f7ccbf573de /include/import.php | |
parent | 508969a183669b0f1f9cf60b06a68d5b51b501d1 (diff) | |
download | volse-hubzilla-650e98b2a9aff2f54be84782ac48cc57badbf76f.tar.gz volse-hubzilla-650e98b2a9aff2f54be84782ac48cc57badbf76f.tar.bz2 volse-hubzilla-650e98b2a9aff2f54be84782ac48cc57badbf76f.zip |
work on event sync
Diffstat (limited to 'include/import.php')
-rw-r--r-- | include/import.php | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/include/import.php b/include/import.php index a81ade791..616ee4987 100644 --- a/include/import.php +++ b/include/import.php @@ -540,6 +540,81 @@ function import_item_ids($channel,$itemids) { } } +function import_events($channel,$events) { + + if($channel && $events) { + foreach($events as $event) { + unset($event['id']); + $event['aid'] = $channel['channel_account_id']; + $event['uid'] = $channel['channel_id']; + + dbesc_array($event); + $r = dbq("INSERT INTO event (`" + . implode("`, `", array_keys($event)) + . "`) VALUES ('" + . implode("', '", array_values($event)) + . "')" + ); + } + } +} + + +function sync_events($channel,$events) { + + if($channel && $events) { + foreach($events as $event) { + + if((! $event['event_hash']) || (! $event['start'])) + continue; + + if($event['event_deleted']) { + $r = q("delete from event where event_hash = '%s' and uid = %d limit 1", + dbesc($event['event_hash']), + intval($channel['channel_id']) + ); + continue; + } + + unset($event['id']); + $event['aid'] = $channel['channel_account_id']; + $event['uid'] = $channel['channel_id']; + + $exists = false; + + $x = q("select * from event where event_hash = '%s' and uid = %d limit 1", + dbesc($event['event_hash']), + intval($channel['channel_id']) + ); + if($x) { + if($x[0]['edited'] >= $event['edited']) + continue; + $exists = true; + } + + if($exists) { + foreach($event as $k => $v) { + $r = q("UPDATE event SET `%s` = '%s' WHERE event_hash = '%s' AND uid = %d", + dbesc($k), + dbesc($v), + dbesc($event['event_hash']), + intval($channel['channel_id']) + ); + } + } + else { + dbesc_array($event); + $r = dbq("INSERT INTO event (`" + . implode("`, `", array_keys($event)) + . "`) VALUES ('" + . implode("', '", array_values($event)) + . "')" + ); + } + } + } +} + |