~vcs-imports/helix/helix

« back to all changes in this revision

Viewing changes to trunk/modules/Business/Generated/Objects/BusinessTable.php

  • Committer: damianobrien
  • Date: 2015-06-12 05:13:06 UTC
  • Revision ID: svn-v4:05b9009a-c606-4cef-bdc0-1359a4facf5f::417

Show diffs side-by-side

added added

removed removed

Lines of Context:
31
31
                $this->id = $id;
32
32
                $this->description = null;
33
33
                $this->entityTypeId = null;
 
34
                $this->createdById = null;
34
35
                $this->name = $name;
35
36
                $this->abbreviation = $abbreviation;
36
37
                $this->businessTypeId = null;
49
50
 
50
51
                if (isset($condition)) {
51
52
                        $query = implode(NL, array(
52
 
                                "SELECT {$db->le}entity{$db->re}.{$db->le}id{$db->re}, {$db->le}entity{$db->re}.{$db->le}description{$db->re}, {$db->le}entity{$db->re}.{$db->le}entity_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}name{$db->re}, {$db->le}business{$db->re}.{$db->le}abbreviation{$db->re}, {$db->le}business{$db->re}.{$db->le}business_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}mdate{$db->re}, {$db->le}business{$db->re}.{$db->le}cdate{$db->re}, {$db->le}business{$db->re}.{$db->le}deleted{$db->re}",
 
53
                                "SELECT {$db->le}entity{$db->re}.{$db->le}id{$db->re}, {$db->le}entity{$db->re}.{$db->le}description{$db->re}, {$db->le}entity{$db->re}.{$db->le}entity_type_id{$db->re}, {$db->le}entity{$db->re}.{$db->le}created_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}name{$db->re}, {$db->le}business{$db->re}.{$db->le}abbreviation{$db->re}, {$db->le}business{$db->re}.{$db->le}business_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}mdate{$db->re}, {$db->le}business{$db->re}.{$db->le}cdate{$db->re}, {$db->le}business{$db->re}.{$db->le}deleted{$db->re}",
53
54
                                "FROM {$db->le}business{$db->re}",
54
55
                        "INNER JOIN {$db->le}entity{$db->re} ON {$db->le}business{$db->re}.{$db->le}entity_id{$db->re}={$db->le}entity{$db->re}.{$db->le}id{$db->re} AND {$condition}"
55
56
                        ));
60
61
                                $this->id = $db->record["id"];
61
62
                                $this->description = $db->record["description"];
62
63
                                $this->entityTypeId = $db->record["entity_type_id"];
 
64
                                $this->createdById = $db->record["created_by_id"];
63
65
                                $this->name = $db->record["name"];
64
66
                                $this->abbreviation = $db->record["abbreviation"];
65
67
                                $this->businessTypeId = $db->record["business_type_id"];
75
77
                $this->_initial["id"] = $this->id;
76
78
                $this->_initial["description"] = $this->description;
77
79
                $this->_initial["entityTypeId"] = $this->entityTypeId;
 
80
                $this->_initial["createdById"] = $this->createdById;
78
81
                $this->_initial["name"] = $this->name;
79
82
                $this->_initial["abbreviation"] = $this->abbreviation;
80
83
                $this->_initial["businessTypeId"] = $this->businessTypeId;
85
88
                $object = new Business();
86
89
                $object->_snapshot = $date;
87
90
                $db = Database::getInstance();
88
 
                $db->changeDatabase($db->getDatabase() . "_log");
 
91
                $database = $db->getDatabase();
 
92
                $db->changeDatabase($database . "_log");
89
93
 
90
94
                if (isset($id)) {
91
95
                        $condition = "{$db->le}business{$db->re}.{$db->le}entity_id{$db->re}={$db->queryValue($id)}";
99
103
                        $condition .= " AND ({$db->le}business{$db->re}.{$db->le}tdate{$db->re} IS NOT NULL AND {$db->le}business{$db->re}.{$db->le}fdate{$db->re}<={$db->queryValue($date)} AND {$db->queryValue($date)}<={$db->le}business{$db->re}.{$db->le}tdate{$db->re}) ";
100
104
                        $condition .= " AND ({$db->le}entity{$db->re}.{$db->le}tdate{$db->re} IS NOT NULL AND {$db->le}entity{$db->re}.{$db->le}fdate{$db->re}<={$db->queryValue($date)} AND {$db->queryValue($date)}<={$db->le}entity{$db->re}.{$db->le}tdate{$db->re}) ";
101
105
                        $query = implode(NL, array(
102
 
                                "SELECT {$db->le}business{$db->re}.{$db->le}log_sequence{$db->re}, {$db->le}business{$db->re}.{$db->le}fdate{$db->re}, {$db->le}business{$db->re}.{$db->le}tdate{$db->re}, {$db->le}entity{$db->re}.{$db->le}id{$db->re}, {$db->le}entity{$db->re}.{$db->le}description{$db->re}, {$db->le}entity{$db->re}.{$db->le}entity_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}name{$db->re}, {$db->le}business{$db->re}.{$db->le}abbreviation{$db->re}, {$db->le}business{$db->re}.{$db->le}business_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}mdate{$db->re}, {$db->le}business{$db->re}.{$db->le}cdate{$db->re}, {$db->le}business{$db->re}.{$db->le}deleted{$db->re}",
 
106
                                "SELECT {$db->le}business{$db->re}.{$db->le}log_sequence{$db->re}, {$db->le}business{$db->re}.{$db->le}fdate{$db->re}, {$db->le}business{$db->re}.{$db->le}tdate{$db->re}, {$db->le}entity{$db->re}.{$db->le}id{$db->re}, {$db->le}entity{$db->re}.{$db->le}description{$db->re}, {$db->le}entity{$db->re}.{$db->le}entity_type_id{$db->re}, {$db->le}entity{$db->re}.{$db->le}created_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}name{$db->re}, {$db->le}business{$db->re}.{$db->le}abbreviation{$db->re}, {$db->le}business{$db->re}.{$db->le}business_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}mdate{$db->re}, {$db->le}business{$db->re}.{$db->le}cdate{$db->re}, {$db->le}business{$db->re}.{$db->le}deleted{$db->re}",
103
107
                                "FROM {$db->le}business{$db->re}",
104
108
                        "INNER JOIN {$db->le}entity{$db->re} ON {$db->le}business{$db->re}.{$db->le}entity_id{$db->re}={$db->le}entity{$db->re}.{$db->le}id{$db->re} AND {$condition}"
105
109
                        ));
106
110
 
 
111
                        $query .= "ORDER BY {$db->le}business{$db->re}.log_sequence desc limit 1";
107
112
                        $db->query($query);
108
113
 
109
114
                        if ($db->getRecord() && $db->getNumRows()===1) {
113
118
                                $object->id = $db->record["id"];
114
119
                                $object->description = $db->record["description"];
115
120
                                $object->entityTypeId = $db->record["entity_type_id"];
 
121
                                $object->createdById = $db->record["created_by_id"];
116
122
                                $object->name = $db->record["name"];
117
123
                                $object->abbreviation = $db->record["abbreviation"];
118
124
                                $object->businessTypeId = $db->record["business_type_id"];
125
131
                        }
126
132
                }
127
133
                
 
134
                $db->changeDatabase($database);
128
135
                return $object;
129
136
        }
130
137
 
166
173
                $isDirty = $isDirty || ((int)$this->id !== (int)$this->_initial["id"]);
167
174
                $isDirty = $isDirty || ((string)$this->description !== (string)$this->_initial["description"]);
168
175
                $isDirty = $isDirty || ((int)$this->entityTypeId !== (int)$this->_initial["entityTypeId"]);
 
176
                $isDirty = $isDirty || ((int)$this->createdById !== (int)$this->_initial["createdById"]);
169
177
                $isDirty = $isDirty || ((string)$this->name !== (string)$this->_initial["name"]);
170
178
                $isDirty = $isDirty || ((string)$this->abbreviation !== (string)$this->_initial["abbreviation"]);
171
179
                $isDirty = $isDirty || ((int)$this->businessTypeId !== (int)$this->_initial["businessTypeId"]);
251
259
 
252
260
        protected function log() {
253
261
                if (isset($this->_snapshot)) {return false;}
 
262
                parent::log();
254
263
                $db = Database::getInstance();
255
264
                $database = $db->getDatabase();
 
265
                $record = Business::select($db->encapsulate("business") . ".mdate as fdate,null as tdate,{$db->encapsulate("business")}.*",null,$db->encapsulate("business").".entity_id={$this->id}")->first();
256
266
                $log = "{$database}_log";
257
 
                $db->changeDatabase($log);
 
267
                $dbLog = Database::getInstance(null,null,null,null,$log);
 
268
                foreach($record as $k=>$v){
 
269
                    if(!is_int($v)){
 
270
                        $record[$k] = $dbLog->queryValue($v);
 
271
                    }
 
272
                }
 
273
                $insertColumns = $dbLog->le.implode("{$dbLog->le},{$dbLog->re}",array_keys($record)).$dbLog->re;
 
274
                $insertValues = implode(",",$record);
258
275
                $query = implode(NL, array(
259
 
                        "INSERT INTO {$db->le}{$log}{$db->re}.{$db->le}business{$db->re} (",
260
 
                        "SELECT",
261
 
                        "       NULL,",
262
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}mdate{$db->re},",
263
 
                        "       NULL,",
264
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}_id{$db->re},",
265
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}entity_id{$db->re},",
266
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}name{$db->re},",
267
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}abbreviation{$db->re},",
268
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}business_type_id{$db->re},",
269
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re},",
270
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}mdate{$db->re},",
271
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}cdate{$db->re},",
272
 
                        "       {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}deleted{$db->re}",
273
 
                        "FROM {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}",
274
 
                        "WHERE {$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}entity_id{$db->re}={$db->queryValue($this->id)}",
 
276
                        "INSERT INTO {$dbLog->le}business{$dbLog->re} (",
 
277
                        $insertColumns,
 
278
                        ") VALUES (",
 
279
                        $insertValues,
275
280
                        ")"
276
281
                ));
277
 
                $status = $db->query($query);
278
 
 
279
 
                $logSequence = $db->getInsertedId();
280
 
 
281
 
                $query = implode(NL, array(
282
 
                        "SELECT {$db->le}log_sequence{$db->re}",
283
 
                        "FROM {$db->le}business{$db->re}",
284
 
                        "WHERE {$db->le}business{$db->re}.{$db->le}entity_id{$db->re}={$db->queryValue($this->id)}",
285
 
                        "       AND {$db->le}log_sequence{$db->re}<'{$logSequence}'",
286
 
                        "ORDER BY {$db->le}log_sequence{$db->re} DESC",
287
 
                        "LIMIT 0,1"
288
 
                ));
289
 
                $db->query($query);
290
 
 
291
 
                if ($db->getRecord()) {
292
 
                        $updateSequence = (int)$db->record["log_sequence"];
 
282
                $status = $dbLog->query($query);
 
283
 
 
284
                $logSequence = $dbLog->getInsertedId();
 
285
 
 
286
                if ($logSequence){
293
287
                        $query = implode(NL, array(
294
 
                                "UPDATE {$db->le}{$log}{$db->re}.{$db->le}business{$db->re}",
295
 
                                "INNER JOIN {$db->le}{$database}{$db->re}.{$db->le}business{$db->re} ON {$db->le}{$log}{$db->re}.{$db->le}business{$db->re}.{$db->le}entity_id{$db->re}={$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}entity_id{$db->re}",
296
 
                                "       AND {$db->le}{$log}{$db->re}.{$db->le}business{$db->re}.{$db->le}log_sequence{$db->re}={$db->queryValue($updateSequence)}",
297
 
                                "SET {$db->le}{$log}{$db->re}.{$db->le}business{$db->re}.{$db->le}tdate{$db->re}={$db->le}{$database}{$db->re}.{$db->le}business{$db->re}.{$db->le}mdate{$db->re}"
 
288
                                "SELECT {$dbLog->le}log_sequence{$dbLog->re}",
 
289
                                "FROM {$dbLog->le}business{$dbLog->re}",
 
290
                                "WHERE {$dbLog->le}business{$dbLog->re}.{$dbLog->le}entity_id{$dbLog->re}={$this->id}",
 
291
                                "       AND {$dbLog->le}log_sequence{$dbLog->re}<{$logSequence}",
 
292
                                "ORDER BY {$dbLog->le}log_sequence{$dbLog->re} DESC",
 
293
                                $dbLog::limitOffsetString(1,0)
298
294
                        ));
299
 
                        $db->query($query);
 
295
                        $dbLog->query($query);
 
296
 
 
297
                        if ($dbLog->getRecord()) {
 
298
                                $updateSequence = (int)$dbLog->record["log_sequence"];
 
299
                                $query = implode(NL, array(
 
300
                                        "UPDATE {$dbLog->le}business{$dbLog->re}",
 
301
                                        "SET {$dbLog->le}tdate{$dbLog->re}={$record["mdate"]}",
 
302
                                        "where log_sequence={$updateSequence}"
 
303
                                ));
 
304
                                $dbLog->query($query);
 
305
                        }
300
306
                }
301
307
                $db->changeDatabase($database);
302
308
                return $status;
372
378
        public static function objects($order=null, $where=null, $limit=null, $offset=0) {
373
379
                $db = Database::getInstance();
374
380
                $objects = array();
375
 
                foreach (Business::select("{$db->le}entity{$db->re}.{$db->le}id{$db->re}, {$db->le}entity{$db->re}.{$db->le}description{$db->re}, {$db->le}entity{$db->re}.{$db->le}entity_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}name{$db->re}, {$db->le}business{$db->re}.{$db->le}abbreviation{$db->re}, {$db->le}business{$db->re}.{$db->le}business_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}mdate{$db->re}, {$db->le}business{$db->re}.{$db->le}cdate{$db->re}, {$db->le}business{$db->re}.{$db->le}deleted{$db->re}", $order, $where, $limit, $offset) as $record) {
 
381
                foreach (Business::select("{$db->le}entity{$db->re}.{$db->le}id{$db->re}, {$db->le}entity{$db->re}.{$db->le}description{$db->re}, {$db->le}entity{$db->re}.{$db->le}entity_type_id{$db->re}, {$db->le}entity{$db->re}.{$db->le}created_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}name{$db->re}, {$db->le}business{$db->re}.{$db->le}abbreviation{$db->re}, {$db->le}business{$db->re}.{$db->le}business_type_id{$db->re}, {$db->le}business{$db->re}.{$db->le}updated_by_id{$db->re}, {$db->le}business{$db->re}.{$db->le}mdate{$db->re}, {$db->le}business{$db->re}.{$db->le}cdate{$db->re}, {$db->le}business{$db->re}.{$db->le}deleted{$db->re}", $order, $where, $limit, $offset) as $record) {
376
382
                        $object = new Business();
377
383
                                $object->id = $record["id"];
378
384
                                $object->description = $record["description"];
379
385
                                $object->entityTypeId = $record["entity_type_id"];
 
386
                                $object->createdById = $record["created_by_id"];
380
387
                                $object->name = $record["name"];
381
388
                                $object->abbreviation = $record["abbreviation"];
382
389
                                $object->businessTypeId = $record["business_type_id"];