#include "MarketDB.h"

Inheritance diagram for MarketDB:

Collaboration diagram for MarketDB:

Public Member Functions
PyRep *	GetMarketGroups ()

PyRep *	GetOrders (uint32 regionID, uint16 typeID)

PyRep *	GetOrderRow (uint32 orderID)

PyRep *	GetRegionBest (uint32 regionID)

PyRep *	GetSystemAsks (uint32 solarSystemID)

PyRep *	GetStationAsks (uint32 stationID)

PyRep *	GetOrdersForOwner (uint32 ownerID)

PyRep *	GetTransactions (uint32 ownerID, Market::TxData &data)

bool	DeleteOrder (uint32 orderID)

bool	GetOrderInfo (uint32 orderID, Market::OrderInfo &oInfo)

bool	AlterOrderPrice (uint32 orderID, double new_price)

bool	RecordTransaction (Market::TxData &data)

bool	AlterOrderQuantity (uint32 orderID, uint32 new_qty)

uint32	FindBuyOrder (Call_PlaceCharOrder &call)

uint32	FindSellOrder (Call_PlaceCharOrder &call)

uint32	StoreOrder (Market::SaveData &data)

Public Member Functions inherited from ServiceDB
uint32	GetStationOwner (uint32 stationID)

Static Public Member Functions
static void	GetShipIDs (std::map< uint16, Inv::TypeData > &data)

static void	GetMineralPrices (std::map< uint16, Market::matlData > &data)

static void	GetMaterialPrices (std::map< uint16, Market::matlData > &data)

static void	GetManufacturedItems (std::map< uint16, Inv::TypeData > &data)

static void	UpdateInvPrice (std::map< uint16, Inv::TypeData > &data)

static void	UpdateMktPrice (std::map< uint16, Market::matlData > &data)

static void	GetCruPriceAvg (std::map< uint16, Inv::TypeData > &data)

static int64	GetUpdateTime ()

static void	SetUpdateTime (int64 setTime)

static void	UpdateHistory ()

Static Public Member Functions inherited from ServiceDB
static bool	GetAccountInformation (CryptoChallengePacket &ccp, AccountData &aData, std::string &failMsg)

static bool	UpdateAccountHash (const char *username, std::string &hash)

static bool	IncrementLoginCount (uint32 accountID)

static void	UpdatePassword (uint32 accountID, const char *pass)

static void	SaveKillOrLoss (CharKillData &data)

static bool	GetConstant (const char *name, uint32 &into)

static void	SetServerOnlineStatus (bool online=false)

static void	SetCharacterOnlineStatus (uint32 char_id, bool online=false)

static void	SetAccountOnlineStatus (uint32 accountID, bool online=false)

static void	SetAccountBanStatus (uint32 accountID, bool banned=false)

static void	SaveServerStats (double threads, float rss, float vm, float user, float kernel, uint32 items, uint32 bubbles)

static uint32	SetClientSeed ()

static PyRep *	LookupChars (const char *match, bool exact=false)

static PyRep *	LookupOwners (const char *match, bool exact=false)

static PyRep *	LookupCorporations (const std::string &)

static PyRep *	LookupFactions (const std::string &)

static PyRep *	LookupCorporationTickers (const std::string &)

static PyRep *	LookupStations (const std::string &)

static PyRep *	LookupKnownLocationsByGroup (const std::string &, uint32)

static PyRep *	PrimeOwners (std::vector< int32 > &itemIDs)

static bool	ValidateAccountName (CryptoChallengePacket &ccp, std::string &failMsg)

static void	GetCorpHangarNames (uint32 corpID, std::map< uint8, std::string > &hangarNames)

Additional Inherited Members
Protected Member Functions inherited from ServiceDB
void	ProcessStringChange (const char key, const std::string &oldValue, std::string newValue, PyDict notif, std::vector< std::string > &dbQ)

void	ProcessRealChange (const char key, double oldValue, double newValue, PyDict notif, std::vector< std::string > &dbQ)

void	ProcessIntChange (const char key, uint32 oldValue, uint32 newValue, PyDict notif, std::vector< std::string > &dbQ)

void	ProcessLongChange (const char key, int64 oldValue, int64 newValue, PyDict notif, std::vector< std::string > &dbQ)

Static Protected Member Functions inherited from ServiceDB
static uint32	CreateNewAccount (const char login, const char pass, const char *passHash, int64 role)

Detailed Description

Definition at line 38 of file MarketDB.h.

Member Function Documentation

bool MarketDB::AlterOrderPrice	(	uint32	orderID,
		double	new_price
	)

Definition at line 307 of file MarketDB.cpp.

References _log, DBerror::c_str(), and sDatabase.

                                                                {
     DBerror err;
     if (!sDatabase.RunQuery(err, "UPDATE mktOrders SET price = %.2f WHERE orderID = %u", new_price, orderID)) {
         _log(MARKET__DB_ERROR, "Error in query: %s.", err.c_str());
         return false;
     }
     return true;
 }

Here is the call graph for this function:

bool MarketDB::AlterOrderQuantity	(	uint32	orderID,
		uint32	new_qty
	)

Definition at line 298 of file MarketDB.cpp.

References _log, DBerror::c_str(), and sDatabase.

Referenced by MarketMgr::ExecuteBuyOrder(), and MarketMgr::ExecuteSellOrder().

                                                                 {
     DBerror err;
     if (!sDatabase.RunQuery(err, "UPDATE mktOrders SET volRemaining = %u WHERE orderID = %u",  new_qty, orderID)) {
         _log(MARKET__DB_ERROR, "Error in query: %s.", err.c_str());
         return false;
     }
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool MarketDB::DeleteOrder ( uint32 orderID )

Definition at line 316 of file MarketDB.cpp.

References _log, DBerror::c_str(), and sDatabase.

Referenced by MarketMgr::ExecuteBuyOrder(), and MarketMgr::ExecuteSellOrder().

                                          {
     DBerror err;
     if (!sDatabase.RunQuery(err, "DELETE FROM mktOrders WHERE orderID = %u", orderID)) {
         _log(MARKET__DB_ERROR, "Error in query: %s.", err.c_str());
         return false;
     }
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

uint32 MarketDB::FindBuyOrder ( Call_PlaceCharOrder & call )

Definition at line 196 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBQueryResult::error, DBQueryResult::GetRow(), DBResultRow::GetUInt(), and sDatabase.

                                                        {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT orderID"
         " FROM mktOrders"
         " WHERE bid=1"
         "  AND typeID=%u"
         "  AND stationID=%u"
         "  AND volRemaining >= %u"
         "  AND price > %.2f"
         " ORDER BY price DESC"
         " LIMIT 1;",
         call.typeID,
         call.stationID,
         call.quantity,
         call.price - 0.1/*, sConfig.market.FindBuyOrder*/))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return 0;
     }
 
     DBResultRow row;
     if (res.GetRow(row))
         return row.GetUInt(0);
 
     return 0;    //no order found.
 }

Here is the call graph for this function:

uint32 MarketDB::FindSellOrder ( Call_PlaceCharOrder & call )

Definition at line 224 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBQueryResult::error, DBQueryResult::GetRow(), DBResultRow::GetUInt(), and sDatabase.

 {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT orderID"
         " FROM mktOrders"
         " WHERE bid=0"
         "  AND typeID=%u"
         "  AND stationID=%u"
         "  AND volRemaining >= %u"
         "  AND price < %.2f"
         " ORDER BY price ASC"
         " LIMIT 1;",
         call.typeID,
         call.stationID,
         call.quantity,
         call.price + 0.1/*, sConfig.market.FindSellOrder*/))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return 0;
     }
 
     DBResultRow row;
     if (res.GetRow(row))
         return row.GetUInt(0);
 
     return 0;
 }

Here is the call graph for this function:

void MarketDB::GetCruPriceAvg ( std::map< uint16, Inv::TypeData > & data )

static

Definition at line 590 of file MarketDB.cpp.

References DBResultRow::GetFloat(), DBQueryResult::GetRow(), DBResultRow::IsNull(), and sDatabase.

Referenced by MarketMgr::GetCruPrices(), and MarketMgr::SetBasePrice().

 {
     DBQueryResult res;
     DBResultRow row;
     std::map< uint16, Inv::TypeData>::iterator itr;
     for (itr = data.begin(); itr != data.end(); ++itr) {
         sDatabase.RunQuery(res, "SELECT AVG(avgPrice) FROM CruciblePriceHistory WHERE typeID = %u", itr->first);
         if (res.GetRow(row))
             itr->second.basePrice = (row.IsNull(0) ? 0 : row.GetFloat(0));
     }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void MarketDB::GetManufacturedItems ( std::map< uint16, Inv::TypeData > & data )

static

Definition at line 519 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBQueryResult::error, DBResultRow::GetInt(), DBQueryResult::GetRow(), and sDatabase.

Referenced by MarketMgr::SetBasePrice().

 {
     DBQueryResult res;
     DBResultRow row;
     //6602 items in this query
     if (!sDatabase.RunQuery(res, "SELECT DISTINCT typeID FROM invTypeMaterials"))
         codelog(DATABASE__ERROR, "Error in GetRAMMaterials query: %s", res.error.c_str());
 
     while (res.GetRow(row))
         data[row.GetInt(0)] = Inv::TypeData();
 }

Here is the call graph for this function:

Here is the caller graph for this function:

PyRep * MarketDB::GetMarketGroups ( )

Definition at line 401 of file MarketDB.cpp.

References _log, DBerror::c_str(), codelog, DBRowDescriptor::ColumnCount(), DBQueryResult::error, DBResultRow::GetBool(), DBQueryResult::GetRow(), DBResultRow::GetText(), DBResultRow::GetUInt(), is_log_enabled, DBResultRow::IsNull(), CRowSet::NewRow(), PyStatic, sDatabase, PyPackedRow::SetField(), and PyDict::SetItemString().

Referenced by MarketMgr::Populate().

                                  {
 
     DBQueryResult res;
     if (!sDatabase.RunQuery(res, "SELECT parentGroupID, marketGroupID, marketGroupName,"
         " description, graphicID, hasTypes, iconID, dataID, marketGroupNameID, descriptionID"
         " FROM invMarketGroups"))  {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     DBRowDescriptor *header = new DBRowDescriptor(res);
 
     _log(MARKET__DB_TRACE, "GetMarketGroups header has %u columns.", header->ColumnCount());
 
     CFilterRowSet *filterRowset = new CFilterRowSet(&header);
     PyDict *keywords = filterRowset->GetKeywords();
     keywords->SetItemString("allowDuplicateCompoundKeys", PyStatic.NewFalse());
     keywords->SetItemString("indexName", PyStatic.NewNone());
     keywords->SetItemString("columnName", new PyString("parentGroupID"));
 
     DBResultRow row;
     std::map< int, PyRep* > tt;
     while( res.GetRow(row) ) {
         int parentGroupID(row.IsNull(0) ? -1 : row.GetUInt(0));
         PyRep* pid(nullptr);
         CRowSet*rowset(nullptr);
         if (tt.count(parentGroupID)) {
             pid = tt[parentGroupID];
             rowset = filterRowset->GetRowset(pid);
         } else {
             pid = parentGroupID != -1 ? (PyRep*)new PyInt(parentGroupID) : PyStatic.NewNone();
             tt[parentGroupID] = pid;
             rowset = filterRowset->NewRowset(pid);
         }
 
         PyPackedRow* pyrow = rowset->NewRow();
         pyrow->SetField((uint32)0, pid); //parentGroupID
         pyrow->SetField(1, new PyInt(row.GetUInt(1))); //marketGroupID
         pyrow->SetField(2, new PyString(row.GetText(2))); //marketGroupName
         pyrow->SetField(3, new PyString(row.GetText(3))); //description
         pyrow->SetField(4, row.IsNull(4) ? PyStatic.NewNone() : new PyInt(row.GetUInt(4))); //graphicID
         pyrow->SetField(5, new PyBool(row.GetBool(5))); //hasTypes
         pyrow->SetField(6, row.IsNull(6) ? PyStatic.NewNone() : new PyInt(row.GetUInt(6))); // iconID
         pyrow->SetField(7, new PyInt(row.GetUInt(7))); //dataID
         pyrow->SetField(8, new PyInt(row.GetUInt(8))); //marketGroupNameID
         pyrow->SetField(9, new PyInt(row.GetUInt(9))); //descriptionID
     }
 
     _log(MARKET__DB_TRACE, "GetMarketGroups returned %u keys.", filterRowset->GetKeyCount());
     if (is_log_enabled(MARKET__DB_TRACE))
         filterRowset->Dump(MARKET__DB_TRACE, "    ");
 
     return filterRowset;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void MarketDB::GetMaterialPrices ( std::map< uint16, Market::matlData > & data )

static

Definition at line 531 of file MarketDB.cpp.

References DBResultRow::GetFloat(), DBQueryResult::GetRow(), and sDatabase.

Referenced by MarketMgr::SetBasePrice().

 {
     DBQueryResult res;
     DBResultRow row;
     std::map< uint16, Market::matlData >::iterator itr;
     for (itr = data.begin(); itr != data.end(); ++itr) {
         sDatabase.RunQuery(res, "SELECT basePrice FROM invTypes WHERE typeID = %u", itr->first);
         if (res.GetRow(row))
             itr->second.price = (row.GetFloat(0) * 1.05);
     }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void MarketDB::GetMineralPrices ( std::map< uint16, Market::matlData > & data )

static

Definition at line 543 of file MarketDB.cpp.

References DBResultRow::GetFloat(), DBQueryResult::GetRow(), and sDatabase.

Referenced by MarketMgr::SetBasePrice().

 {
     DBQueryResult res;
     DBResultRow row;
     std::map< uint16, Market::matlData >::iterator itr;
     for (itr = data.begin(); itr != data.end(); ++itr) {
         sDatabase.RunQuery(res, "SELECT basePrice FROM invTypes WHERE typeID = %u", itr->first);
         if (res.GetRow(row))
             itr->second.price = (row.GetFloat(0) * 1.15);
     }
 
     /*  mineral prices in first column from rens 31/5/2010 @ 17:30  logged by me from IGB
      * second price column is from Grismar 16/2/07
      * third price column is from ccp market dump, filtered and averaged for Crucible era from all regions
      * typeID   Name            2010        2007       2012
      * 34      Tritanium        2.70        2.37        2.72315
      * 35      Pyerite          5.80        4.00        4.90957
      * 36      Mexallon        26.90       21.93       29.7163
      * 37      Isogen          49.16       64.06       59.1943
      * 38      Nocxium         99.02       93.76       94.227
      * 39      Zydrine       1315.03     2347.36     1290.39
      * 40      Megacyte      2650.00     3989.06     2707.67
      * 11399   Morphite      5407.68    14291.00     4943.2
      *
      */
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool MarketDB::GetOrderInfo	(	uint32	orderID,
		Market::OrderInfo &	oInfo
	)

Definition at line 253 of file MarketDB.cpp.

References _log, Market::OrderInfo::accountKey, DBerror::c_str(), DBQueryResult::error, DBResultRow::GetBool(), DBResultRow::GetFloat(), DBQueryResult::GetRow(), DBResultRow::GetUInt(), Market::OrderInfo::isBuy, Market::OrderInfo::isCorp, Market::OrderInfo::memberID, Market::OrderInfo::ownerID, Market::OrderInfo::price, Market::OrderInfo::quantity, Market::OrderInfo::regionID, sDatabase, Market::OrderInfo::stationID, and Market::OrderInfo::typeID.

Referenced by MarketMgr::ExecuteBuyOrder(), and MarketMgr::ExecuteSellOrder().

                                                                   {
     //orderID, typeID, ownerID, regionID, stationID, orderRange, bid, price, escrow,
     // minVolume, volEntered, volRemaining, issued, contraband, duration, jumps, isCorp, accountKey, memberID
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         " volRemaining,"
         " price,"
         " typeID,"
         " stationID,"
         " regionID,"
         " ownerID,"
         " bid,"
         " isCorp,"
         " memberID,"
         " accountKey"
         " FROM mktOrders"
         " WHERE orderID=%u",
         orderID))
     {
         _log(MARKET__DB_ERROR, "Error in query: %s.", res.error.c_str());
         return false;
     }
 
     DBResultRow row;
     if (!res.GetRow(row)) {
         _log(MARKET__WARNING, "Order %u not found.", orderID);
         return false;
     }
 
     oInfo.quantity   = row.GetUInt(0);
     oInfo.price      = row.GetFloat(1);
     oInfo.typeID     = row.GetUInt(2);
     oInfo.stationID  = row.GetUInt(3);
     oInfo.regionID   = row.GetUInt(4);
     oInfo.ownerID    = row.GetUInt(5);
     oInfo.isBuy      = row.GetBool(6);
     oInfo.isCorp     = row.GetBool(7);
     oInfo.memberID   = row.GetUInt(8);
     oInfo.accountKey = row.GetUInt(9);
 
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

PyRep * MarketDB::GetOrderRow ( uint32 orderID )

Definition at line 172 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBRowToPackedRow(), DBQueryResult::error, DBQueryResult::GetRow(), and sDatabase.

Referenced by MarketMgr::ExecuteBuyOrder(), MarketMgr::ExecuteSellOrder(), and MarketMgr::SendOnOwnOrderChanged().

                                            {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "   price, volRemaining, typeID, orderRange AS `range`, orderID,"
         "   volEntered, minVolume, bid, issued as issueDate, duration,"
         "   stationID, regionID, solarSystemID, jumps"
         " FROM mktOrders"
         " WHERE orderID=%u", orderID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     DBResultRow row;
     if (!res.GetRow(row)) {
         codelog(MARKET__ERROR, "Order %u not found.", orderID);
         return nullptr;
     }
 
     return DBRowToPackedRow(row);
 }

Here is the call graph for this function:

Here is the caller graph for this function:

PyRep * MarketDB::GetOrders	(	uint32	regionID,
		uint16	typeID
	)

Definition at line 109 of file MarketDB.cpp.

References _log, Market::Type::Buy, DBerror::c_str(), codelog, DBResultToCRowset(), PyRep::Dump(), DBQueryResult::error, DBQueryResult::GetRowCount(), is_log_enabled, PyDecRef, sDatabase, Market::Type::Sell, and PyTuple::SetItem().

 {
     // returns a tuple (sell, buy) of PyObjectEx with data in PyPackedRows
 
     PyTuple* tup = new PyTuple(2);
     DBQueryResult res;
     //query sell orders
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "    price, volRemaining, typeID, orderRange AS `range`, orderID,"
         "   volEntered, minVolume, bid, issued as issueDate, duration,"
         "   stationID, regionID, solarSystemID, jumps"
         " FROM mktOrders "
         " WHERE regionID=%u AND typeID=%u AND bid=%u", regionID, typeID, Market::Type::Sell))
     {
         codelog( MARKET__DB_ERROR, "Error in query: %s", res.error.c_str() );
         return nullptr;
     }
     _log(MARKET__DB_TRACE, "GetOrders() - Fetched %u sell orders for type %u", res.GetRowCount(), typeID);
     tup->SetItem(0, DBResultToCRowset( res ) );
 
     //query buy orders
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "    price, volRemaining, typeID, orderRange AS `range`, orderID,"
         "   volEntered, minVolume, bid, issued as issueDate, duration,"
         "   stationID, regionID, solarSystemID, jumps"
         " FROM mktOrders "
         " WHERE regionID=%u AND typeID=%u AND bid=%u", regionID, typeID, Market::Type::Buy))
     {
         codelog( MARKET__DB_ERROR, "Error in query: %s", res.error.c_str() );
         PyDecRef( tup );
         return nullptr;
     }
     _log(MARKET__DB_TRACE, "GetOrders() - Fetched %u buy orders for type %u", res.GetRowCount(), typeID);
     tup->SetItem(1, DBResultToCRowset( res ) );
 
     if (is_log_enabled(MARKET__DUMP))
         tup->Dump(MARKET__DUMP, "    ");
     return tup;
 }

Here is the call graph for this function:

PyRep * MarketDB::GetOrdersForOwner ( uint32 ownerID )

Definition at line 151 of file MarketDB.cpp.

References _log, DBerror::c_str(), codelog, DBResultToRowset(), DBQueryResult::error, DBQueryResult::GetRowCount(), and sDatabase.

 {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "   orderID, typeID, ownerID AS charID, regionID, stationID,"
         "   orderRange AS `range`, bid, price, volEntered, volRemaining,"
         "   issued as issueDate, minVolume, contraband,"
         "   duration, isCorp, solarSystemID, escrow"
         " FROM mktOrders"
         " WHERE ownerID=%u", ownerID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     _log(MARKET__DB_TRACE, "GetOrdersForOwner() - Fetched %u buy orders for %u", res.GetRowCount(), ownerID);
 
     return DBResultToRowset(res);
 }

Here is the call graph for this function:

PyRep * MarketDB::GetRegionBest ( uint32 regionID )

Definition at line 87 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBResultToIndexRowset(), DBQueryResult::error, sDatabase, and Market::Type::Sell.

                                               {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "    typeID, MIN(price) AS price, volRemaining, stationID "
         " FROM mktOrders "
         " WHERE regionID=%u AND bid=%u"
         " GROUP BY typeID",
         //" LIMIT %u",sConfig.market.RegionOrderLimit
         regionID, Market::Type::Sell))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     //NOTE: this SHOULD return a crazy dbutil.RowDict object which is
     //made up of packed blue.DBRow objects, but we do not understand
     //the marshalling of those well enough right now, and this object
     //provides the same interface. It is significantly bigger on the wire though.
     return DBResultToIndexRowset(res, "typeID");
 }

Here is the call graph for this function:

void MarketDB::GetShipIDs ( std::map< uint16, Inv::TypeData > & data )

static

Definition at line 500 of file MarketDB.cpp.

References DBResultRow::GetInt(), DBQueryResult::GetRow(), sDatabase, and EVEDB::invCategories::Ship.

 {
     DBQueryResult res;
     DBResultRow row;
     // 178 ships using this query
     sDatabase.RunQuery(res,
                 "SELECT t.typeID "
                 " FROM invTypes AS t "
                 " LEFT JOIN invGroups AS g USING (groupID)"
                 " WHERE g.categoryID = %u",
                 //" AND g.useBasePrice = 1"
                 //" AND t.published = 1",
                 EVEDB::invCategories::Ship);
 
     //sDatabase.RunQuery(res, "SELECT typeID FROM invTypes WHERE groupID = %u AND published = 1", EVEDB::invGroups::Frigate);
     while (res.GetRow(row))
         data[row.GetInt(0)] = Inv::TypeData();
 }

Here is the call graph for this function:

PyRep * MarketDB::GetStationAsks ( uint32 stationID )

Definition at line 43 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBResultToIndexRowset(), DBQueryResult::error, and sDatabase.

                                                 {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "    typeID, MIN(price) AS price, volRemaining, stationID "
         " FROM mktOrders "
         " WHERE stationID=%u"
         " GROUP BY typeID",
         //" LIMIT %u", sConfig.market.StationOrderLimit
         stationID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     //NOTE: this SHOULD return a crazy dbutil.RowDict object which is
     //made up of packed blue.DBRow objects, but we do not understand
     //the marshalling of those well enough right now, and this object
     //provides the same interface. It is significantly bigger on the wire though.
     return DBResultToIndexRowset(res, "typeID");
 }

Here is the call graph for this function:

PyRep * MarketDB::GetSystemAsks ( uint32 solarSystemID )

Definition at line 65 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBResultToIndexRowset(), DBQueryResult::error, and sDatabase.

                                                    {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "    typeID, MIN(price) AS price, volRemaining, stationID "
         " FROM mktOrders "
         " WHERE solarSystemID=%u"
         " GROUP BY typeID",
         //" LIMIT %u",sConfig.market.SystemOrderLimit
         solarSystemID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     //NOTE: this SHOULD return a crazy dbutil.RowDict object which is
     //made up of packed blue.DBRow objects, but we do not understand
     //the marshalling of those well enough right now, and this object
     //provides the same interface. It is significantly bigger on the wire though.
     return DBResultToIndexRowset(res, "typeID");
 }

Here is the call graph for this function:

PyRep * MarketDB::GetTransactions	(	uint32	ownerID,
		Market::TxData &	data
	)

Definition at line 349 of file MarketDB.cpp.

References Market::TxData::accountKey, DBerror::c_str(), codelog, DBResultToRowset(), DBQueryResult::error, Market::TxData::isBuy, Market::TxData::memberID, Market::TxData::price, Market::TxData::quantity, sDatabase, Market::TxData::time, and Market::TxData::typeID.

                                                                     {
     //transactionID, transactionDate, typeID, keyID, quantity, price,
     //  transactionType, clientID, regionID, stationID, corpTransaction, characterID
     std::string typeID = "";
     if (data.typeID) {
         typeID = "AND typeID=";
         typeID += std::to_string(data.typeID);
     }
     std::string buy = "";
     if (data.isBuy > -1) {
         buy = "AND transactionType=";
         buy += std::to_string(data.isBuy);
     }
     DBQueryResult res;
     if (!sDatabase.RunQuery(res,
         "SELECT"
         "   transactionID, transactionDate, typeID, keyID, quantity, price,"
         "   transactionType, clientID, regionID, stationID, corpTransaction, characterID"
         " FROM mktTransactions "
         " WHERE clientID=%u %s AND quantity>=%u AND price>=%.2f AND "
         " transactionDate>=%li %s AND keyID=%u AND characterID=%u",
         clientID, typeID.c_str(), data.quantity, data.price,
         data.time, buy.c_str(), data.accountKey, data.memberID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return nullptr;
     }
 
     return DBResultToRowset(res);
 }

Here is the call graph for this function:

int64 MarketDB::GetUpdateTime ( )

static

Definition at line 456 of file MarketDB.cpp.

References DBerror::c_str(), codelog, DBQueryResult::error, DBResultRow::GetInt64(), DBQueryResult::GetRow(), and sDatabase.

Referenced by MarketMgr::Initialize().

 {
     DBQueryResult res;
     if (!sDatabase.RunQuery(res, "SELECT timeStamp FROM mktUpdates WHERE server = 1"))  {
         codelog(MARKET__DB_ERROR, "Error in query: %s", res.error.c_str());
         return 0;
     }
     DBResultRow row;
     if (res.GetRow(row))
         return row.GetInt64(0);
 
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool MarketDB::RecordTransaction ( Market::TxData & data )

Definition at line 380 of file MarketDB.cpp.

References Market::TxData::accountKey, DBerror::c_str(), Market::TxData::clientID, codelog, GetFileTimeNow(), Market::TxData::isBuy, Market::TxData::isCorp, Market::TxData::memberID, Market::TxData::price, Market::TxData::quantity, Market::TxData::regionID, sDatabase, Market::TxData::stationID, and Market::TxData::typeID.

Referenced by MarketMgr::ExecuteBuyOrder(), and MarketMgr::ExecuteSellOrder().

                                                    {
     //transactionID, transactionDate, typeID, keyID, quantity, price,
     //  transactionType, clientID, regionID, stationID, corpTransaction, characterID
     DBerror err;
     if (!sDatabase.RunQuery(err,
         "INSERT INTO"
         " mktTransactions ("
         "    transactionDate, typeID, keyID, quantity, price,"
         "    transactionType, clientID, regionID, stationID, corpTransaction, characterID"
         " ) VALUES ("
         " %f, %u, %u, %u, %f,"
         " %u, %u, %u, %u, %u, %u)",
         GetFileTimeNow(), data.typeID, data.accountKey, data.quantity, data.price,
         data.isBuy > 0?1:0, data.clientID, data.regionID, data.stationID, data.isCorp?1:0, data.memberID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", err.c_str());
         return false;
     }
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void MarketDB::SetUpdateTime ( int64 setTime )

static

Definition at line 470 of file MarketDB.cpp.

References sDatabase.

Referenced by MarketMgr::UpdatePriceHistory().

 {
     DBerror err;
     sDatabase.RunQuery(err, "UPDATE mktUpdates SET timeStamp = %li WHERE server = 1", setTime);
 }

Here is the caller graph for this function:

uint32 MarketDB::StoreOrder ( Market::SaveData & data )

Definition at line 325 of file MarketDB.cpp.

                                                 {
     DBerror err;
     uint32 orderID(0);
     if (!sDatabase.RunQueryLID(err, orderID,
         "INSERT INTO mktOrders ("
         " typeID, ownerID, regionID, stationID, solarSystemID, orderRange,"
         " bid, price, escrow, minVolume, volEntered, volRemaining,"
         " issued, contraband, duration, jumps, isCorp, accountKey, memberID"
         " ) VALUES ("
         "    %u, %u, %u, %u, %u, %u,"
         "    %u, %.2f, %.2f, %u, %u, %u,"
         "    %li, %u, %u, %u, %u, %u, %u"
         " )",
         data.typeID, data.ownerID, data.regionID, data.stationID, data.solarSystemID, data.orderRange,
         data.bid?1:0, data.price, data.escrow, data.minVolume, data.volEntered, data.volRemaining,
         data.issued, data.contraband?1:0, data.duration, data.jumps, data.isCorp?1:0, data.accountKey, data.memberID))
     {
         codelog(MARKET__DB_ERROR, "Error in query: %s", err.c_str());
         return 0;
     }
 
     return orderID;
 }

Here is the call graph for this function:

void MarketDB::UpdateHistory ( )

static

Todo:: this needs work for better logic. may need to pull data from transactions

Definition at line 477 of file MarketDB.cpp.

References sDatabase.

 {
     //  'date'  needs to be an actual column to pull data from....
     DBerror err;
     sDatabase.RunQuery(err,
                    "INSERT INTO"
                    "    mktHistory"
                    "     (regionID, typeID, historyDate, lowPrice, highPrice, avgPrice, volume, orders)"
                    " SELECT"
                    "    regionID,"
                    "    typeID,"
                    "    ((UNIX_TIMESTAMP(date) + 11644473600) * 10000000),"
                    "    price,"
                    "    price,"
                    "    price,"
                    "    amtEntered,"
                    "    COUNT(DISTINCT typeID)"
                    " FROM mktData");
 }

void MarketDB::UpdateInvPrice ( std::map< uint16, Inv::TypeData > & data )

static

Definition at line 570 of file MarketDB.cpp.

References sDatabase, and sLog.

Referenced by MarketMgr::GetCruPrices(), and MarketMgr::SetBasePrice().

 {
     DBerror err;
     for (auto cur : data) {
         if (cur.second.basePrice < 0.01) {
             sLog.Error("     SetBasePrice", "Calculated price for %s(%u) is 0", \
                     cur.second.name.c_str(), cur.first);
         } else {
             sDatabase.RunQuery(err, "UPDATE invTypes SET basePrice=%f WHERE typeID= %u", cur.second.basePrice, cur.first);
         }
     }
 }

Here is the caller graph for this function:

void MarketDB::UpdateMktPrice ( std::map< uint16, Market::matlData > & data )

static

Definition at line 583 of file MarketDB.cpp.

References sDatabase.

Referenced by MarketMgr::UpdateMineralPrice().

 {
     DBerror err;
     for (auto cur : data)
         sDatabase.RunQuery(err, "UPDATE invTypes SET basePrice=%f WHERE typeID= %u", cur.second.price, cur.first);
 }

Here is the caller graph for this function:

The documentation for this class was generated from the following files:

/backups/local/src/eve/EvEmu_Crucible/src/eve-server/market/MarketDB.h
/backups/local/src/eve/EvEmu_Crucible/src/eve-server/market/MarketDB.cpp

Public Member Functions

Static Public Member Functions

Additional Inherited Members

Detailed Description

Member Function Documentation