queries.py 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. from collections import defaultdict
  2. import operator
  3. import db
  4. def search(q):
  5. like_str = '{}%'.format(q)
  6. with db.cursor() as c:
  7. alliances = db.query(c, '''
  8. SELECT DISTINCT alliance_id, alliance_name FROM characters
  9. WHERE alliance_name LIKE ? LIMIT 25
  10. ''', like_str)
  11. corps = db.query(c, '''
  12. SELECT DISTINCT corporation_id, corporation_name FROM characters
  13. WHERE corporation_name LIKE ? LIMIT 25
  14. ''', like_str)
  15. chars = db.query(c, '''
  16. SELECT DISTINCT character_id, character_name FROM characters
  17. WHERE character_name LIKE ? LIMIT 25
  18. ''', like_str)
  19. return {'alliances': alliances, 'corporations': corps, 'characters': chars}
  20. def kill_list(entity_type, entity_id):
  21. with db.cursor() as c:
  22. kills = db.query(c, '''
  23. SELECT DISTINCT(kills.kill_id), kill_time, cost,
  24. solarSystemName as system_name, security, regionName as region
  25. FROM kills
  26. JOIN characters ON characters.kill_id = kills.kill_id
  27. JOIN kill_costs ON kill_costs.kill_id = kills.kill_id
  28. JOIN eve.mapSolarSystems ON solar_system_id = solarSystemID
  29. JOIN eve.mapRegions ON mapSolarSystems.regionID = mapRegions.regionID
  30. WHERE {}_id = ? LIMIT 100
  31. '''.format(entity_type), entity_id)
  32. kill_ids = list(map(operator.itemgetter('kill_id'), kills))
  33. char_rows = db.query(c, '''
  34. SELECT
  35. kill_id, victim, final_blow,
  36. character_id, character_name, corporation_id, corporation_name, alliance_id, alliance_name, faction_id, faction_name,
  37. ship_type_id, typeName AS ship_name
  38. FROM characters
  39. JOIN eve.invTypes ON ship_type_id = typeID
  40. WHERE kill_id IN ({})
  41. '''.format(','.join(map(str, kill_ids))))
  42. characters = defaultdict(dict)
  43. entity_name = None
  44. for kill_id in kill_ids:
  45. characters[kill_id]['attackers'] = 1 # count final_blow now
  46. for char in char_rows:
  47. kill_id = char['kill_id']
  48. if char['victim']:
  49. characters[kill_id]['victim'] = char
  50. elif char['final_blow']:
  51. characters[kill_id]['final_blow'] = char
  52. else:
  53. characters[kill_id]['attackers'] += 1
  54. if entity_name is None and char[entity_type + '_id'] == entity_id:
  55. entity_name = char[entity_type + '_name']
  56. for kill in kills:
  57. kill['kill_time'] = _format_kill_time(kill['kill_time'])
  58. chars = characters[kill['kill_id']]
  59. kill['victim'] = chars['victim']
  60. kill['final_blow'] = chars['final_blow']
  61. kill['attackers'] = chars['attackers']
  62. return {'entity_name': entity_name, 'kills': kills}
  63. def kill(kill_id):
  64. with db.cursor() as c:
  65. kill = db.get(c, '''
  66. SELECT kill_time, cost, solarSystemName, security FROM kills
  67. JOIN kill_costs ON kill_costs.kill_id = kills.kill_id
  68. JOIN eve.mapSolarSystems ON solar_system_id = solarSystemID
  69. WHERE kills.kill_id = ?
  70. ''', kill_id)
  71. kill['kill_time'] = _format_kill_time(kill['kill_time'])
  72. characters = db.query(c, '''
  73. SELECT character_id, character_name, damage, victim, final_blow,
  74. corporation_id, corporation_name, alliance_id, alliance_name, faction_id, faction_name,
  75. ship_type_id, weapon_type_id,
  76. ship.typeName AS ship_name, weapon.typeName AS weapon_name
  77. FROM characters
  78. JOIN eve.invTypes AS ship ON ship_type_id = ship.typeID
  79. LEFT JOIN eve.invTypes AS weapon ON weapon_type_id = weapon.typeID
  80. WHERE kill_id = ?
  81. ''', kill_id)
  82. attackers = []
  83. for char in characters:
  84. if char['victim']:
  85. victim = char
  86. elif char['final_blow']:
  87. final_blow = char
  88. else:
  89. attackers.append(char)
  90. item_rows = db.query(c, '''
  91. SELECT items.type_id, flag, dropped, destroyed, singleton,
  92. cost, typeName AS item_name, capacity
  93. FROM items
  94. JOIN item_costs ON item_costs.type_id = items.type_id
  95. JOIN eve.invTypes ON items.type_id = typeID
  96. WHERE kill_id = ? ORDER BY flag ASC
  97. ''', kill_id)
  98. items = defaultdict(list)
  99. for item in item_rows:
  100. flag = item['flag']
  101. if 125 <= flag <= 132:
  102. slot = 'subsystem'
  103. elif 27 <= flag <= 34:
  104. slot = 'high'
  105. elif 19 <= flag <= 26:
  106. slot = 'medium'
  107. elif 11 <= flag <= 18:
  108. slot = 'low'
  109. elif 92 <= flag <= 99:
  110. slot = 'rig'
  111. elif flag == 87:
  112. slot = 'drone bay'
  113. elif flag == 5:
  114. slot = 'cargo'
  115. elif 133 <= flag <= 143:
  116. slot = 'special hold'
  117. elif flag == 89:
  118. slot = 'implant'
  119. else:
  120. slot = '???'
  121. items[slot].append(item)
  122. slot_rows = db.query(c, '''
  123. SELECT attributeID, valueInt, valueFloat FROM eve.dgmTypeAttributes
  124. WHERE typeID = ? AND attributeID IN (12, 13, 14, 1137, 1367)
  125. AND (valueInt != 0 OR valueFloat != 0.0)
  126. ''', victim['ship_type_id'])
  127. slot_mapping = {12: 'low', 13: 'medium', 14: 'high', 1137: 'rig', 1367: 'subsystem'}
  128. slots = dict.fromkeys(slot_mapping.values(), 0)
  129. for attr in slot_rows:
  130. slot = slot_mapping[attr['attributeID']]
  131. slots[slot] = attr['valueInt'] or int(attr['valueFloat']) # wtf CCP
  132. if slots['subsystem']:
  133. sub_ids = map(lambda s: str(s['type_id']), items['subsystem'])
  134. modifier_rows = db.query(c, '''
  135. SELECT attributeID, valueFloat FROM eve.dgmTypeAttributes
  136. WHERE typeID IN ({}) AND attributeID in (1374, 1375, 1376) and valueFloat != 0.0
  137. '''.format(','.join(sub_ids)))
  138. slot_mapping = {1374: 'high', 1375: 'medium', 1376: 'low'} # that's right, it's backwards for subs!
  139. for modifier in modifier_rows:
  140. slot = slot_mapping[modifier['attributeID']]
  141. slots[slot] += int(modifier['valueFloat']) # strangely, an improvement
  142. return {
  143. 'kill': kill,
  144. 'victim': victim,
  145. 'final_blow': final_blow,
  146. 'attackers': attackers,
  147. 'items': items,
  148. 'slots': slots,
  149. }
  150. def _format_kill_time(kill_time):
  151. return kill_time.strftime('%Y-%m-%d %H:%m')