commit | author | age
|
0594ac
|
1 |
#include "bom.hpp" |
JG |
2 |
|
|
3 |
#include "book.hpp" |
611ad7
|
4 |
#include "ftplibpp/ftplib.h" |
ae7d00
|
5 |
#include "rapidxml/rapidxml.hpp" |
0594ac
|
6 |
#include <cstddef> |
JG |
7 |
#include <cstdio> |
ae7d00
|
8 |
#include <fstream> |
JG |
9 |
#include <iterator> |
0594ac
|
10 |
#include <string> |
JG |
11 |
#include <unordered_map> |
ae7d00
|
12 |
#include <vector> |
0594ac
|
13 |
|
JG |
14 |
namespace bom |
|
15 |
{ |
611ad7
|
16 |
ftplib* ftp; |
ae7d00
|
17 |
|
JG |
18 |
void initialise() |
0594ac
|
19 |
{ |
611ad7
|
20 |
ftp = new ftplib(); |
JG |
21 |
ftp->Connect("ftp.bom.gov.au:21"); |
|
22 |
ftp->Login("anonymous", ""); |
ae7d00
|
23 |
} |
JG |
24 |
|
611ad7
|
25 |
void destroy() |
JG |
26 |
{ |
|
27 |
ftp->Quit(); |
|
28 |
delete ftp; |
|
29 |
} |
ae7d00
|
30 |
|
JG |
31 |
void updateBom(std::unordered_map<std::string, book::Book>& bs) |
|
32 |
{ |
611ad7
|
33 |
ftp->Get("bom_data.xml", "/anon/gen/fwo/IDN60920.xml", |
JG |
34 |
ftplib::transfermode::ascii); |
|
35 |
std::ifstream fs("bom_data.xml"); |
|
36 |
std::vector<char> buffer{std::istreambuf_iterator<char>(fs), |
|
37 |
istreambuf_iterator<char>()}; |
|
38 |
buffer.push_back('\0'); |
ae7d00
|
39 |
rapidxml::xml_document<> d; |
611ad7
|
40 |
d.parse<0>(&buffer[0]); |
JG |
41 |
// Walk stations |
|
42 |
for (rapidxml::xml_node<>* n = d.first_node()->last_node()->first_node(); n; |
|
43 |
n = n->next_sibling()) { |
|
44 |
int bom_id = std::stoi(n->first_attribute()->next_attribute()->value()); |
|
45 |
for (auto &i : bs) { |
|
46 |
if (i.second.stationId == bom_id) { |
|
47 |
// Should be apparent temp |
|
48 |
i.second.bomPrice = std::stod(n->first_node()->first_node()->first_node()->first_node()->value()); |
|
49 |
std::cout << i.second.product << ", " << i.second.stationId << ", " << i.second.bomPrice << std::endl; |
|
50 |
break; |
|
51 |
} |
|
52 |
} |
|
53 |
} |
0594ac
|
54 |
} |
JG |
55 |
} // namespace bom |