File size: 2,732 Bytes
07c3cdd
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
<?php
require_once 'classes/model/om/BaseAbeResponses.php';


/**
 * Skeleton subclass for representing a row from the 'ABE_RESPONSES' table.
 *
 *
 *
 * You should add additional methods to this class to meet the
 * application requirements.  This class will only be generated as
 * long as it does not already exist in the output directory.
 *
 * @package    classes.model
 */
class AbeResponses extends BaseAbeResponses
{

    private $filterThisFields = array('ABE_RES_UID', 'ABE_REQ_UID', 'ABE_RES_CLIENT_IP', 'ABE_RES_DATA',
                                      'ABE_RES_DATE', 'ABE_RES_STATUS', 'ABE_RES_MESSAGE');

    public function load($abeResponsesUid)
    {
        try {
            $abeResponsesInstance = AbeResponsesPeer::retrieveByPK($abeResponsesUid);
            $fields = $abeResponsesInstance->toArray(BasePeer::TYPE_FIELDNAME);

            return $fields;
        } catch (Exception $error) {
            throw $error;
        }
    }

    public function createOrUpdate($data)
    {
        $additionalFields = array();

        foreach ($data as $field => $value) {
            if (!in_array($field, $this->filterThisFields)) {
                $additionalFields[$field] = $value;
                unset($data[$field]);
            }
        }

        $connection = Propel::getConnection(AbeResponsesPeer::DATABASE_NAME);

        try {
            if (!isset($data['ABE_RES_UID'])) {
                $data['ABE_RES_UID'] = '';
            }

            if ($data['ABE_RES_UID'] == '') {
                $data['ABE_RES_UID'] = G::generateUniqueID();
                $data['ABE_RES_DATE'] = date('Y-m-d H:i:s');
                $AbeResponsesInstance = new AbeResponses();
            } else {
                $AbeResponsesInstance = AbeResponsesPeer::retrieveByPK($data['ABE_RES_UID']);
            }

            //$data['ABE_RES_UPDATE'] = date('Y-m-d H:i:s');
            $AbeResponsesInstance->fromArray($data, BasePeer::TYPE_FIELDNAME);

            if ($AbeResponsesInstance->validate()) {
                $connection->begin();
                $result = $AbeResponsesInstance->save();
                $connection->commit();

                return $data['ABE_RES_UID'];
            } else {
                $message = '';
                $validationFailures = $AbeResponsesInstance->getValidationFailures();

                foreach ($validationFailures as $validationFailure) {
                    $message .= $validationFailure->getMessage() . '. ';
                }

                throw(new Exception('Error trying to update: ' . $message));
            }
        } catch (Exception $error) {
            $connection->rollback();

            throw $error;
        }
    }
}

// AbeResponses