Sun_Ev_Charging_Hogging_Latest/database.h at main · Jimmycheakc/Sun_Ev_Charging_Hogging_Latest · GitHub

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
#pragma once

#include <iostream>
#include <string>
#include <memory>
#include <vector>
#include "Poco/Data/Session.h"
#include "Poco/Mutex.h"

class Database{

public:
    typedef struct parking_lot
    {
        std::string location_code;
        std::string lot_no;
        std::string custom_park_lot_no;
        std::string lpn;
        std::string lot_in_image_path;
        std::string lot_out_image_path;
        std::string lot_in_dt;
        std::string lot_out_dt;
        std::string add_dt;
        std::string update_dt;
        std::string lot_in_central_sent_dt;
        std::string lot_out_central_sent_dt;
    } parking_lot_t;

    typedef struct parking_lot_info
    {
        bool start_up_flag;
        std::string status;
        parking_lot_t parking_lot_details;
    } parking_lot_info_t;

    static Database* getInstance();
    void FnDatabaseInit();
    void FnSetDatabaseStatus(bool status);
    bool FnGetDatabaseStatus();
    void FnDatabaseReconnect();
    void FnSetDatabaseRecoveryFlag(bool flag);
    bool FnGetDatabaseRecoveryFlag();

    // Table --> tbl_ev_lot_trans
    void FnInsertRecord(const std::string& tableName, parking_lot_t lot);
    void FnSelectAllRecord(const std::string& tableName, std::vector<parking_lot_t>& v_lot);
    bool FnIsTableEmpty(const std::string& tableName);
    void FnRemoveAllRecord(const std::string& tableName);

    void FnUpdateThreeLotParkingStatus(const std::string& tableName);
    const parking_lot_info_t& FnGetFirstParkingLot() const;
    void FnSetFirstParkingLotStartUpFlag(bool flag=true);
    const parking_lot_info_t& FnGetSecondParkingLot() const;
    void FnSetSecondParkingLotStartUpFlag(bool flag=true);
    const parking_lot_info_t& FnGetThirdParkingLot() const;
    void FnSetThirdParkingLotStartUpFlag(bool flag=true);

    void FnSendDBParkingLotStatusToCentral(const std::string& tableName);
    void FnSendOfflineDBParkingLotStatusToCentral(const std::string& tableName);

    // Table --> tbl_ev_lot_status
    void FnInsertStatusRecord(const std::string& tableName, const std::string& carpark_code, const std::string& device_ip, const std::string& error_code);
    void FnSendDBDeviceStatusToCentral(const std::string& tableName);

    Database(Database& database) = delete;

    void operator=(const Database&) = delete;

private:
    static Database* database_;
    static Poco::Mutex singletonDatabaseMutex_;
    std::unique_ptr<Poco::Data::Session> session_;
    Poco::Mutex databaseMutex_;
    parking_lot_info_t firstParkingLot_;
    parking_lot_info_t secondParkingLot_;
    parking_lot_info_t thirdParkingLot_;
    bool dbRecoveryFlag_;
    bool databaseStatus_;
    Database();
    ~Database();
};