[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Fmsystem-commits] [11605] Integration
|
From: |
Sigurd Nes |
|
Subject: |
[Fmsystem-commits] [11605] Integration |
|
Date: |
Fri, 17 Jan 2014 14:53:15 +0000 |
Revision: 11605
http://svn.sv.gnu.org/viewvc/?view=rev&root=fmsystem&revision=11605
Author: sigurdne
Date: 2014-01-17 14:53:15 +0000 (Fri, 17 Jan 2014)
Log Message:
-----------
Integration
Added Paths:
-----------
trunk/property/inc/cron/default/synkroniser_avdelinger_med_fellesdata.php
Added: trunk/property/inc/cron/default/synkroniser_avdelinger_med_fellesdata.php
===================================================================
--- trunk/property/inc/cron/default/synkroniser_avdelinger_med_fellesdata.php
(rev 0)
+++ trunk/property/inc/cron/default/synkroniser_avdelinger_med_fellesdata.php
2014-01-17 14:53:15 UTC (rev 11605)
@@ -0,0 +1,284 @@
+<?php
+ /**
+ * phpGroupWare - property: a Facilities Management System.
+ *
+ * @author Sigurd Nes <address@hidden>
+ * @copyright Copyright (C) 2003,2004,2005,2006,2007 Free Software
Foundation, Inc. http://www.fsf.org/
+ * This file is part of phpGroupWare.
+ *
+ * phpGroupWare is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * phpGroupWare is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with phpGroupWare; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301
USA
+ *
+ * @license http://www.gnu.org/licenses/gpl.html GNU General Public
License
+ * @internal Development of this application was funded by
http://www.bergen.kommune.no/bbb_/ekstern/
+ * @package property
+ * @subpackage cron
+ * @version $Id: synkroniser_avdelinger_med_fellesdata.php 11571
2013-12-27 08:26:40Z sigurdne $
+ */
+
+ /**
+ * Description
+ * example cron : /usr/local/bin/php -q
/var/www/html/phpgroupware/property/inc/cron/cron.php default
synkroniser_avdelinger_med_fellesdata
+ * @package property
+ */
+
+ include_class('property', 'cron_parent', 'inc/cron/');
+
+ class synkroniser_avdelinger_med_fellesdata extends property_cron_parent
+ {
+ public function __construct()
+ {
+ parent::__construct();
+
+ $this->function_name = get_class($this);
+ $this->sub_location = lang('catch');
+ $this->function_msg = 'Import info from files';
+
+ set_time_limit(1000);
+ }
+
+
+ function execute()
+ {
+ $fellesdata = new property_fellesdata();
+ $fellesdata->get_org_unit_ids_from_top();
+
+ // _debug_array($fellesdata->unit_ids);
+
+ try
+ {
+ $fellesdata->insert_values();
+ }
+ catch(Exception $e)
+ {
+
$this->receipt['error'][]=array('msg'=>$e->getMessage());
+ }
+
+ $messages = $fellesdata->messages;
+ foreach ($messages as $message)
+ {
+ $this->receipt['message'][] = $message;
+ }
+ }
+ }
+
+
+ class property_fellesdata
+ {
+ // Instance variable
+ protected static $bo;
+ protected $connected = false;
+ protected $status;
+ protected $db = null;
+ protected $unit_ids = array();
+ protected $names = array();
+ protected $messages = array();
+
+ /**
+ * Magic get method
+ *
+ * @param string $varname the variable to fetch
+ *
+ * @return mixed the value of the variable sought - null if not
found
+ */
+ public function __get($varname)
+ {
+ switch ($varname)
+ {
+ case 'unit_ids':
+ return $this->unit_ids;
+ break;
+ case 'names':
+ return $this->names;
+ break;
+ case 'messages':
+ return $this->messages;
+ break;
+ default:
+ return null;
+ }
+ }
+
+
+ /* our simple php ping function */
+ function ping($host)
+ {
+ exec(sprintf('ping -c 1 -W 5 %s', escapeshellarg($host)), $res,
$rval);
+ return $rval === 0;
+ }
+
+ public function get_db()
+ {
+ if($this->db && is_object($this->db))
+ {
+ return $this->db;
+ }
+
+ $config = CreateObject('phpgwapi.config','rental');
+ $config->read();
+
+ if(! $config->config_data['external_db_host'] ||
!$this->ping($config->config_data['external_db_host']))
+ {
+ $message ="Database server
{$config->config_data['external_db_host']} is not accessible";
+ phpgwapi_cache::message_set($message, 'error');
+ return false;
+ }
+
+ $db = createObject('phpgwapi.db', null, null, true);
+
+ $db->debug =
!!$config->config_data['external_db_debug'];
+ $db->Host = $config->config_data['external_db_host'];
+ $db->Port = $config->config_data['external_db_port'];
+ $db->Type = $config->config_data['external_db_type'];
+ $db->Database =
$config->config_data['external_db_name'];
+ $db->User = $config->config_data['external_db_user'];
+ $db->Password =
$config->config_data['external_db_password'];
+
+ try
+ {
+ $db->connect();
+ $this->connected = true;
+ }
+ catch(Exception $e)
+ {
+ $status = lang('unable_to_connect_to_database');
+ }
+
+ $this->db = $db;
+ return $db;
+ }
+
+
+ public function insert_values()
+ {
+
+ $db = & $GLOBALS['phpgw']->db;
+ $db->transaction_begin();
+
+ $units = $this->unit_ids;
+
+ foreach ($units as $unit)
+ {
+ $value_set = array
+ (
+ 'id' => $unit['id'],
+ 'parent_id' =>
$unit['parent'],
+ 'name' =>
$unit['name'],
+ 'created_on' => time(),
+ 'created_by' =>
$GLOBALS['phpgw_info']['user']['account_id'],
+ 'modified_by' =>
$GLOBALS['phpgw_info']['user']['account_id'],
+ 'modified_on' => time()
+ );
+
+ $table = 'fm_department';
+ $db->query("SELECT count(*) as cnt FROM
{$table} WHERE id =" . (int)$unit['id'],__LINE__,__FILE__);
+ $db->next_record();
+
+ if($db->f('cnt'))
+ {
+ unset($value_set['id']);
+
+ if($this->debug)
+ {
+ $this->messages[] = "ID finnes
fra før: {$unit['id']}, oppdaterer: {$unit['name']}";
+ }
+ $value_set =
$db->validate_update($value_set);
+ $sql = "UPDATE {$table} SET
{$value_set} WHERE id =" . (int)$unit['id'];
+ }
+ else
+ {
+ if($this->debug)
+ {
+ $this->messages[] = "ID fantes
ikke fra før: {$unit['id']}, legger til: {$unit['name']}";
+ }
+ $cols = implode(',',
array_keys($value_set));
+ $values =
$db->validate_insert(array_values($value_set));
+ $sql = "INSERT INTO {$table} ({$cols})
VALUES ({$values})";
+ }
+
+ $db->query($sql,__LINE__,__FILE__);
+
+ }
+
+ $db->transaction_commit();
+ }
+
+ function get_org_unit_ids_from_top()
+ {
+ if(!$db = $this->get_db())
+ {
+ return;
+ }
+
+ $sql = "SELECT ORG_ENHET_ID, V_ORG_ENHET.ORG_NAVN FROM
V_ORG_ENHET";
+// $sql = "SELECT * FROM V_ORG_ENHET";
+ $db->query($sql);
+ while($db->next_record())
+ {
+ $org_unit_id = $db->f('ORG_ENHET_ID');
+ $name = $db->f('ORG_NAVN');
+
+ $this->names[$org_unit_id] = $name;
+ }
+
+ $sql = "SELECT V_ORG_ENHET.ORG_ENHET_ID,
V_ORG_ENHET.ORG_NAVN FROM V_ORG_ENHET"
+ . " WHERE V_ORG_ENHET.ORG_NIVAA = 1 ORDER BY
V_ORG_ENHET.ORG_NAVN ASC";
+
+ $db->query($sql);
+
+ while($db->next_record())
+ {
+ $org_unit_id = $db->f('ORG_ENHET_ID');
+ $this->unit_ids[] = array
+ (
+ 'id' => $org_unit_id,
+ 'name' => $this->names[$org_unit_id],
+ 'parent'=>''
+ );
+
+ $this->get_org_unit_ids_children($org_unit_id);
+ }
+
+ return $this->unit_ids;
+ }
+
+
+ function get_org_unit_ids_children($org_unit_id)
+ {
+ $org_unit_id = (int)$org_unit_id;
+ $db = clone($this->db);
+
+ $q = "SELECT V_ORG_KNYTNING.*,
ANT_ENHETER_UNDER,V_ORG_ENHET.ORG_NAVN,ORG_NIVAA FROM V_ORG_KNYTNING"
+ . " JOIN V_ORG_ENHET ON (V_ORG_ENHET.ORG_ENHET_ID =
V_ORG_KNYTNING.ORG_ENHET_ID_KNYTNING ) WHERE
V_ORG_KNYTNING.ORG_ENHET_ID_KNYTNING=$org_unit_id";
+
+ $db->query($q);
+
+ while($db->next_record())
+ {
+ $child_org_unit_id = $db->f('ORG_ENHET_ID');
+ $this->unit_ids[] = array
+ (
+ 'id' => $child_org_unit_id,
+ 'name' =>
$this->names[$child_org_unit_id],
+ 'parent'=> $org_unit_id,
+ 'level' => $db->f('ORG_NIVAA')
+ );
+
+ if($db->f('ANT_ENHETER_UNDER'))
+ {
+
$this->get_org_unit_ids_children($child_org_unit_id);
+ }
+ }
+ }
+ }
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Fmsystem-commits] [11605] Integration,
Sigurd Nes <=