pipelines.py 86 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466
  1. import datetime
  2. import time
  3. import hashlib
  4. import redis
  5. from twisted.enterprise import adbapi
  6. import psycopg2.extras
  7. # class MySnow:
  8. # def __init__(self,dataID):
  9. # self.start = int(time.mktime(time.strptime('2018-01-01 00:00:00', "%Y-%m-%d %H:%M:%S")))
  10. # self.last = int(time.time())
  11. # self.countID = 0
  12. # self.dataID = dataID # 数据ID,这个自定义或是映射
  13. #
  14. # def get_id(self):
  15. # # 时间差部分
  16. # now = int(time.time())
  17. # temp = now-self.start
  18. # if len(str(temp)) < 9: # 时间差不够9位的在前面补0
  19. # length = len(str(temp))
  20. # s = "0" * (9-length)
  21. # temp = s + str(temp)
  22. # if now == self.last:
  23. # self.countID += 1 # 同一时间差,序列号自增
  24. # else:
  25. # self.countID = 0 # 不同时间差,序列号重新置为0
  26. # self.last = now
  27. # # 标识ID部分
  28. # if len(str(self.dataID)) < 2:
  29. # length = len(str(self.dataID))
  30. # s = "0" * (2-length)
  31. # self.dataID = s + str(self.dataID)
  32. # # 自增序列号部分
  33. # if self.countID == 99999: # 序列号自增5位满了,睡眠一秒钟
  34. # time.sleep(1)
  35. # countIDdata = str(self.countID)
  36. # if len(countIDdata) < 5: # 序列号不够5位的在前面补0
  37. # length = len(countIDdata)
  38. # s = "0"*(5-length)
  39. # countIDdata = s + countIDdata
  40. # id = str(temp) + str(self.dataID) + countIDdata
  41. # return id
  42. # 生成哈希索引 sole
  43. def hash_func(match_id, odds_code, sort, p_id):
  44. m = hashlib.md5()
  45. a = str(match_id) + str(odds_code) + str(sort) + str(p_id)
  46. m.update(a.encode('utf-8'))
  47. c = m.hexdigest()
  48. return c
  49. # 生成odds_only哈希
  50. def r_func(match_id, odds_code, sort, p_id, odd):
  51. m = hashlib.md5()
  52. a = str(match_id) + str(odds_code) + str(sort) + str(p_id) + str(odd)
  53. m.update(a.encode('utf-8'))
  54. c = m.hexdigest()
  55. return c
  56. # 转换成本地时间
  57. def new_time(ctime):
  58. time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
  59. time2 = time.localtime(time1)
  60. time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
  61. time4 = time3
  62. data_time = str(time4).split(" ")
  63. match_date = data_time[0]
  64. match_time = data_time[1]
  65. return match_date, match_time, time3
  66. def out_time(ctime, i):
  67. ctime1 = datetime.datetime.strptime(ctime, "%Y-%m-%d %H:%M:%S")
  68. n_ctime = (ctime1 + datetime.timedelta(hours=i)).strftime("%Y-%m-%d %H:%M:%S")
  69. return n_ctime
  70. def fuhao(f):
  71. if f.startswith('+'):
  72. f = f.replace('+', '-')
  73. return f
  74. elif f.startswith('-'):
  75. f = f.replace('-', '+')
  76. return f
  77. else:
  78. return f
  79. # 篮球插入赔率 -----------------------------------------------------------------------------------------------------------
  80. def one_intodb(data1, data2, data3, cursor, redis_db):
  81. if data1:
  82. for key, value in data1.items():
  83. if value:
  84. for x, y in enumerate(value):
  85. new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=x, p_id=data2['p_id'])
  86. r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=x, p_id=data2['p_id'],odd=y)
  87. odds_only = r_hash
  88. l_f = fuhao(str(data3[key][x]))
  89. if redis_db.hexists("hg3535_lanqiu", r_hash):
  90. pass
  91. else:
  92. redis_db.hset("hg3535_lanqiu", r_hash, 0)
  93. sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
  94. cursor.execute(sql1, (
  95. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], y,
  96. data2['p_id'], data2["p_code"], x, data2["source"], new_hash,
  97. l_f, data2['expire_time'], odds_only,data2['utime'], y, data2['expire_time'],
  98. odds_only, l_f))
  99. # 更新主队st_zq_odds_record表
  100. sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s);"
  101. cursor.execute(sql2, (
  102. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], y,
  103. data2['p_id'], data2["p_code"], x, data2["source"], l_f, odds_only))
  104. def two_intodb(data1, data2, data3, cursor, redis_db):
  105. if data1:
  106. for key, value in data1.items():
  107. if value:
  108. new_hash = hash_func(match_id=data2['game_id'], odds_code=data3 + key, sort=data2['sort'], p_id=data2['p_id'])
  109. r_hash = r_func(match_id=data2['game_id'], odds_code=data3 + key, sort=data2['sort'], p_id=data2['p_id'],odd=value)
  110. odds_only = r_hash
  111. if redis_db.hexists("hg3535_lanqiu", r_hash):
  112. pass
  113. else:
  114. redis_db.hset("hg3535_lanqiu", r_hash, 0)
  115. sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
  116. cursor.execute(sql1, (
  117. int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
  118. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
  119. key, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'], odds_only,key))
  120. # 更新主队st_zq_odds_record表
  121. sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s);"
  122. cursor.execute(sql2, (
  123. int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
  124. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], key, odds_only))
  125. def three_intodb(data1, data2, cursor, redis_db):
  126. if data1:
  127. for key, value in data1.items():
  128. if value:
  129. new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
  130. r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'],odd=value)
  131. odds_only = r_hash
  132. if redis_db.hexists("hg3535_lanqiu", r_hash):
  133. pass
  134. else:
  135. redis_db.hset("hg3535_lanqiu", r_hash, 0)
  136. sql1 = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s;"
  137. cursor.execute(sql1, (
  138. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
  139. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash, data2['expire_time'],
  140. odds_only,data2['utime'], value, data2['expire_time'], odds_only))
  141. # 更新主队st_zq_odds_record表
  142. sql2 = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
  143. cursor.execute(sql2, (
  144. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
  145. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], odds_only))
  146. # 插入篮球赛事表
  147. def into_competition(data, cursor):
  148. Competition_sql = "insert into st_lq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag, type, source,expire_time,is_today,is_morningplate,is_stringscene) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s,%s, %s, %s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s,is_morningplate=%s,is_stringscene=%s;"
  149. cursor.execute(Competition_sql, (
  150. data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
  151. data['match_time'],
  152. data['utime'], data['utime'], data['number'], data['pt'], data["source"], data['expire_time'], data['is_today'],
  153. data['is_morningplate'], data['is_stringscene'], data['number'], data['expire_time'], data['is_today'],
  154. data['is_morningplate'], data['is_stringscene']))
  155. # 插入足球赛事表----------------------------------------------------------------------------------------------------------
  156. def zqone_competition(data, cursor):
  157. Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_today,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s,us_time=%s;"
  158. cursor.execute(Competition_sql, (
  159. data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
  160. data['match_time'],
  161. data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_today'],
  162. data['us_time'], data['number'], data['expire_time'], data['is_today'],data['us_time']))
  163. def zqtwo_competition(data, cursor):
  164. Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_morningplate,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s,%s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_morningplate=%s,us_time=%s;"
  165. cursor.execute(Competition_sql, (
  166. data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
  167. data['match_time'],
  168. data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_morningplate'],
  169. data['us_time'], data['number'], data['expire_time'], data['is_morningplate'],data['us_time']))
  170. def zqthree_competition(data, cursor):
  171. Competition_sql = "insert into st_zq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time, ctime, utime, tag,source, expire_time,is_stringscene,us_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s,%s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_stringscene=%s,us_time=%s;"
  172. cursor.execute(Competition_sql, (
  173. data['team_home'], data['team_guest'], data['league_id'], data['game_id'], data['match_date'],
  174. data['match_time'],
  175. data['utime'], data['utime'], data['number'], data["source"], data['expire_time'], data['is_stringscene'],
  176. data['us_time'], data['number'], data['expire_time'], data['is_stringscene'],data['us_time']))
  177. # 足球 插入赔率 让球 大小-------------------------------------------------------------------------------------------------
  178. def zqone_intodb(data1, data2, data3, data4, cursor, redis_db):
  179. if data1:
  180. for index, value in enumerate(data1):
  181. if value:
  182. new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'])
  183. r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=index, p_id=data2['p_id'], odd=value)
  184. odds_only = r_hash
  185. f1 = fuhao(str(data4[index]))
  186. if redis_db.hexists("hg3535_zuqiu", r_hash):
  187. pass
  188. else:
  189. redis_db.hset("hg3535_zuqiu", r_hash, 0)
  190. sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
  191. cursor.execute(sql1, (
  192. int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
  193. data2['p_id'], data2["p_code"], index, data2["source"], new_hash,
  194. f1, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'],
  195. odds_only, f1))
  196. # 更新主队st_zq_odds_record表
  197. sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
  198. cursor.execute(sql2, (
  199. int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], float(value),
  200. data2['p_id'], data2["p_code"], index, data2["source"], f1, odds_only))
  201. # 足球 插入赔率 独赢 单双
  202. def zqtwo_intodb(data1, data2, data3, data4, cursor, redis_db):
  203. if data1:
  204. new_hash = hash_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'])
  205. r_hash = r_func(match_id=data2['game_id'], odds_code=data3, sort=data2['sort'], p_id=data2['p_id'],
  206. odd=data1)
  207. odds_only = r_hash
  208. if redis_db.hexists("hg3535_zuqiu", r_hash):
  209. pass
  210. else:
  211. redis_db.hset("hg3535_zuqiu", r_hash, 0)
  212. sql1 = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time, odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
  213. cursor.execute(sql1, (
  214. int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
  215. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
  216. data4, data2['expire_time'], odds_only, data2['utime'], data1, data2['expire_time'], odds_only,data4))
  217. # 更新主队st_zq_odds_record表
  218. sql2 = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s,%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
  219. cursor.execute(sql2, (
  220. int(data2['league_id']), data3, int(data2['game_id']), data2['utime'], data2['utime'], data1,
  221. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], data4, odds_only))
  222. def gjz_into(data, cursor, r_hash, s_hash, redis_db):
  223. if redis_db.hexists('hg3535_guanjun', r_hash):
  224. pass
  225. else:
  226. redis_db.hset('hg3535_guanjun', r_hash, 0)
  227. # if pt == 1:
  228. sql = "insert into st_zq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
  229. cursor.execute(sql, (
  230. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  231. data['champion_team'], data['p_id'], data['new_league_name'],
  232. data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
  233. data['champion_team'], data['expire_time'], data['odds_only']))
  234. # 插入st_zq_odds_record表
  235. new_sql = "insert into st_zq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
  236. cursor.execute(new_sql, (
  237. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  238. data['champion_team'], data['p_id'], data['new_league_name'],
  239. data['tema_home'], 1, "hg3535", data['odds_only']))
  240. if redis_db.hexists('hg3535_liansai', s_hash):
  241. pass
  242. else:
  243. redis_db.hset('hg3535_liansai', s_hash, 0)
  244. league_sql = "insert into st_zq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
  245. cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
  246. def gjl_into(data, cursor, r_hash, s_hash, redis_db):
  247. if redis_db.hexists('hg3535_guanjun', r_hash):
  248. pass
  249. else:
  250. redis_db.hset('hg3535_guanjun', r_hash, 0)
  251. sql = "insert into st_lq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
  252. cursor.execute(sql, (
  253. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  254. data['champion_team'], data['p_id'], data['new_league_name'],
  255. data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
  256. data['champion_team'], data['expire_time'], data['odds_only']))
  257. # 插入st_zq_odds_record表
  258. new_sql = "insert into st_lq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
  259. cursor.execute(new_sql, (
  260. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  261. data['champion_team'], data['p_id'], data['new_league_name'],
  262. data['tema_home'], 1, "hg3535", data['odds_only']))
  263. # 插入st_zq_league表
  264. if redis_db.hexists('hg3535_liansai', s_hash):
  265. pass
  266. else:
  267. redis_db.hset('hg3535_liansai', s_hash, 0)
  268. league_sql = "insert into st_lq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
  269. cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
  270. def gjw_into(data, cursor, r_hash, s_hash, redis_db):
  271. if redis_db.hexists('hg3535_guanjun', r_hash):
  272. pass
  273. else:
  274. redis_db.hset('hg3535_guanjun', r_hash, 0)
  275. sql = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
  276. cursor.execute(sql, (
  277. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  278. data['champion_team'], data['p_id'], data['new_league_name'],
  279. data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
  280. data['champion_team'], data['expire_time'], data['odds_only']))
  281. # 插入st_zq_odds_record表
  282. new_sql = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s,%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s)"
  283. cursor.execute(new_sql, (
  284. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  285. data['champion_team'], data['p_id'], data['new_league_name'],
  286. data['tema_home'], 1, "hg3535", data['odds_only']))
  287. # 插入st_zq_league表
  288. if redis_db.hexists('hg3535_liansai', s_hash):
  289. pass
  290. else:
  291. redis_db.hset('hg3535_liansai', s_hash, 0)
  292. league_sql = "insert into st_wq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
  293. cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
  294. def gjb_into(data, cursor, r_hash, s_hash, redis_db):
  295. if redis_db.hexists('hg3535_guanjun', r_hash):
  296. pass
  297. else:
  298. redis_db.hset('hg3535_guanjun', r_hash, 0)
  299. sql = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, team, type, source, sole, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s,%s, %s, %s, %s) on conflict(sole) do update set utime = %s,odds = %s,expire_time=%s,odds_only=%s;"
  300. cursor.execute(sql, (
  301. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  302. data['champion_team'], data['p_id'], data['new_league_name'],
  303. data['tema_home'], 1, "hg3535", data['new_hash'], data['expire_time'], data['odds_only'],data['utime'],
  304. data['champion_team'], data['expire_time'], data['odds_only']))
  305. # 插入st_zq_odds_record表
  306. new_sql = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, team, type, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)"
  307. cursor.execute(new_sql, (
  308. int(data['league_id']), data['new_champion'], int(data['game_id']), data['utime'], data['utime'],
  309. data['champion_team'], data['p_id'], data['new_league_name'],
  310. data['tema_home'], 1, "hg3535", data['odds_only']))
  311. # 插入st_zq_league表
  312. if redis_db.hexists('hg3535_liansai', s_hash):
  313. pass
  314. else:
  315. redis_db.hset('hg3535_liansai', s_hash, 0)
  316. league_sql = "insert into st_bq_league(name_chinese, lg_id,last_time) values (%s, %s, %s) on conflict(lg_id) do update set last_time = %s,source=%s;"
  317. cursor.execute(league_sql, (data['league_name'], data['league_id'], data['time3'], data['time3'], "hg3535"))
  318. # 网球 插入赔率----------------------------------------------------------------------------------------------------------
  319. def wqone_intodb(data1, data2, data3, cursor, redis_db):
  320. if data1:
  321. for key, value in data1.items():
  322. if value:
  323. new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
  324. r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'], odd=value)
  325. odds_only = r_hash
  326. w_f = fuhao(str(data3[key]))
  327. if redis_db.hexists("hg3535_wangqiu", r_hash):
  328. pass
  329. else:
  330. redis_db.hset("hg3535_wangqiu", r_hash, 0)
  331. sql1 = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s;"
  332. cursor.execute(sql1, (
  333. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
  334. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
  335. w_f, data2['expire_time'], odds_only,data2['utime'], value, data2['expire_time'],
  336. odds_only, w_f))
  337. # 更新主队st_zq_odds_record表
  338. sql2 = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s);"
  339. cursor.execute(sql2, (
  340. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
  341. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], w_f, odds_only))
  342. # 棒球 插入赔率----------------------------------------------------------------------------------------------------------
  343. def bqone_intodb(data1, data2, data3, cursor, redis_db):
  344. if data1:
  345. for key, value in data1.items():
  346. if value:
  347. new_hash = hash_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'])
  348. r_hash = r_func(match_id=data2['game_id'], odds_code=key, sort=data2['sort'], p_id=data2['p_id'], odd=value)
  349. odds_only = r_hash
  350. b_f = fuhao(str(data3[key]))
  351. if redis_db.hexists("hg3535_bangqiu", r_hash):
  352. pass
  353. else:
  354. redis_db.hset("hg3535_bangqiu", r_hash, 0)
  355. sql1 = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s,condition=%s"
  356. cursor.execute(sql1, (
  357. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
  358. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], new_hash,
  359. b_f, data2['expire_time'], odds_only, data2['utime'], value,data2['expire_time'],
  360. odds_only, b_f))
  361. # 更新主队st_zq_odds_record表
  362. sql2 = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s, %s);"
  363. cursor.execute(sql2, (
  364. int(data2['league_id']), key, int(data2['game_id']), data2['utime'], data2['utime'], value,
  365. data2['p_id'], data2["p_code"], data2['sort'], data2["source"], b_f, odds_only))
  366. def get_pcode(corner_ball, code):
  367. code_dict = {'concede_size': 1, 'capot': 2, 'two_sides': 3, 'total_goal': 4, 'half_full': 5, 'bodan': 6,
  368. 'first_last_ball': 7, 'temaball': 11}
  369. if corner_ball == "角球":
  370. p_code = "corner_ball"
  371. p_id = 9
  372. elif corner_ball == "会晋级":
  373. p_code = "promotion"
  374. p_id = 10
  375. elif corner_ball == "罚牌数":
  376. p_code = "Penalty_card"
  377. p_id = 12
  378. else:
  379. p_code = code
  380. p_id = code_dict[code]
  381. return p_code, p_id
  382. # 足球 赔率 赛事---------------------------------------------------------------------------------------------------------
  383. class Zuqiupipeline(object):
  384. def __init__(self, dbpool, conn, cursor, redis_db):
  385. self.dbpool = dbpool
  386. self.conn = conn
  387. self.cursor = cursor
  388. self.redis_db = redis_db
  389. @classmethod
  390. def from_settings(cls, settings):
  391. dbparms = dict(
  392. host=settings["POST_HOST"],
  393. user=settings["POST_USER"],
  394. password=settings["POST_PASSWORD"],
  395. port=settings['POST_PORT'],
  396. )
  397. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  398. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  399. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  400. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  401. redis_db = redis.StrictRedis(connection_pool=pool)
  402. return cls(dbpool, conn, cursor, redis_db)
  403. def process_item(self, item, spider):
  404. # 使用twisted将mysql插入变成异步执行
  405. query = self.dbpool.runInteraction(self.do_insert, item)
  406. query.addErrback(self.handle_error, item, spider) # 处理异常
  407. # return item
  408. def handle_error(self, failure, item, spider):
  409. # 处理异步插入的异常
  410. print(failure)
  411. def do_insert(self, cursor, item):
  412. # 比赛日期
  413. data_game = item['data_game'].split("/")
  414. month = str(data_game[1].strip())
  415. day = str(data_game[0])
  416. # 比赛时间
  417. time_game = str(item['time_game'])
  418. # 比赛时间,时间戳
  419. ctime = "2019" + "-" + month + "-" + day + "" + time_game + ":00"
  420. r_ctime = "2019" + "-" + month + "-" + day
  421. # 现在时间,时间戳
  422. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  423. expire_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() + 60))
  424. # 比赛id
  425. competition_id = item['game_id']
  426. # 联赛id
  427. league_id = item['league_id']
  428. # 联赛name
  429. league_name = item['league_name']
  430. # 主队
  431. team_home = item['team_home']
  432. # 客队
  433. team_guest = item['team_guest']
  434. # number
  435. number = item['number']
  436. pt = item['pt']
  437. corner_ball = item['corner_ball']
  438. p_code, p_id = get_pcode(corner_ball, 'concede_size')
  439. # 构建唯一索引
  440. half_size_guest = item["half_size_guest"]
  441. half_size_guest_rule = item["half_size_guest_rule"]
  442. half_size_home = item["half_size_home"]
  443. half_size_home_rule = item["half_size_home_rule"]
  444. size_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id, 'p_code': p_code,
  445. 'source': "hg3535", 'expire_time': expire_time, 'pt': pt}
  446. # 让球 数据插入数据库
  447. # try:
  448. zqone_intodb(data1=half_size_home, data2=size_data, data3="half_size_home", data4=half_size_home_rule,
  449. cursor=cursor, redis_db=self.redis_db)
  450. # except:
  451. # print(item)
  452. # # 让球 数据插入数据库
  453. # try:
  454. zqone_intodb(data1=half_size_guest, data2=size_data, data3="half_size_guest", data4=half_size_guest_rule,
  455. cursor=cursor, redis_db=self.redis_db)
  456. # except:
  457. # print(item)
  458. # 全场场大小
  459. size_guest = item["size_guest"]
  460. size_guest_rule = item["size_guest_rule"]
  461. size_home = item["size_home"]
  462. size_home_rule = item["size_home_rule"]
  463. zqone_intodb(data1=size_guest, data2=size_data, data3="size_guest", data4=size_guest_rule,
  464. cursor=cursor, redis_db=self.redis_db)
  465. zqone_intodb(data1=size_home, data2=size_data, data3="size_home", data4=size_home_rule,
  466. cursor=cursor, redis_db=self.redis_db)
  467. # 上半场大小
  468. half_concede_home_rule = item["half_concede_home_rule"]
  469. half_concede_home = item["half_concede_home"]
  470. half_concede_guest_rule = item["half_concede_guest_rule"]
  471. half_concede_guest = item["half_concede_guest"]
  472. # 上半场让球
  473. try:
  474. zqone_intodb(data1=half_concede_home, data2=size_data, data3="half_concede_home", data4=half_concede_home_rule,
  475. cursor=cursor, redis_db=self.redis_db)
  476. except:
  477. print(item)
  478. try:
  479. zqone_intodb(data1=half_concede_guest, data2=size_data, data3="half_concede_guest", data4=half_concede_guest_rule, cursor=cursor, redis_db=self.redis_db)
  480. except:
  481. print(item)
  482. concede_guest = item["concede_guest"]
  483. concede_guest_rule = item["concede_guest_rule"]
  484. concede_home = item["concede_home"]
  485. concede_home_rule = item["concede_home_rule"]
  486. # 全场让球
  487. try:
  488. zqone_intodb(data1=concede_guest, data2=size_data, data3="concede_guest", data4=concede_guest_rule,
  489. cursor=cursor, redis_db=self.redis_db)
  490. except:
  491. print(item)
  492. try:
  493. zqone_intodb(data1=concede_home, data2=size_data, data3="concede_home", data4=concede_home_rule,
  494. cursor=cursor,redis_db=self.redis_db)
  495. except:
  496. print(item)
  497. #
  498. p_code, p_id = get_pcode(corner_ball, 'capot')
  499. # 独赢----------------------------------------------------------------------------------------------------------
  500. half_capot_home = item["half_capot_home"]
  501. half_capot_guest = item["half_capot_guest"]
  502. half_capot_dogfall = item["half_capot_dogfall"]
  503. capot_home = item["capot_home"]
  504. capot_guest = item["capot_guest"]
  505. capot_dogfall = item["capot_dogfall"]
  506. capot_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id, 'p_code': p_code,
  507. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  508. # 上半场独赢 主队
  509. zqtwo_intodb(data1=half_capot_home, data2=capot_data, data3="half_capot_home", data4='1', cursor=cursor,redis_db=self.redis_db)
  510. # 上半场独赢 客队
  511. zqtwo_intodb(data1=half_capot_guest, data2=capot_data, data3="half_capot_guest", data4='2', cursor=cursor,redis_db=self.redis_db)
  512. # 上半场独赢 和
  513. zqtwo_intodb(data1=half_capot_dogfall, data2=capot_data, data3="half_capot_dogfall", data4='x', cursor=cursor,redis_db=self.redis_db)
  514. #
  515. # 全场独赢 主队
  516. zqtwo_intodb(data1=capot_home, data2=capot_data, data3="capot_home", data4='1', cursor=cursor,redis_db=self.redis_db)
  517. # 全场独赢 客队
  518. zqtwo_intodb(data1=capot_guest, data2=capot_data, data3="capot_guest", data4='2', cursor=cursor,redis_db=self.redis_db)
  519. # 全场独赢 和
  520. zqtwo_intodb(data1=capot_dogfall, data2=capot_data, data3="capot_dogfall", data4='x', cursor=cursor,redis_db=self.redis_db)
  521. #
  522. # 入球数单双-------------------------------------------------------------------------------------------------------------
  523. p_code, p_id = get_pcode(corner_ball, 'two_sides')
  524. odd_even_odd = item["odd_even_odd"]
  525. odd_even_even = item["odd_even_even"]
  526. half_odd_even_odd = item["half_odd_even_odd"]
  527. half_odd_even_even = item["half_odd_even_even"]
  528. # 全场入球数 单双
  529. two_sides_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id,
  530. 'p_code': p_code,
  531. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  532. # 上半场入球数 单双
  533. zqtwo_intodb(data1=odd_even_odd, data2=two_sides_data, data3="two_sides_single", data4='单', cursor=cursor,redis_db=self.redis_db)
  534. zqtwo_intodb(data1=odd_even_even, data2=two_sides_data, data3="two_sides_double", data4='双', cursor=cursor,redis_db=self.redis_db)
  535. # 全场入球数 单双
  536. zqtwo_intodb(data1=half_odd_even_odd, data2=two_sides_data, data3="half_two_sides_single", data4='单',
  537. cursor=cursor, redis_db=self.redis_db)
  538. zqtwo_intodb(data1=half_odd_even_even, data2=two_sides_data, data3="half_two_sides_double", data4='双',
  539. cursor=cursor, redis_db=self.redis_db)
  540. # 总入球数 --------------------------------------------------------------------------------------------------------------
  541. p_code, p_id = get_pcode(corner_ball, 'total_goal')
  542. total_goals = item['total_goal']
  543. total_dict = {'total_goal_zero': '0-1', 'total_goal_two': '2-3', 'total_goal_four': '4-6',
  544. 'total_goal_seven': '7或以上', 'half_total_goal_zero': '0', "half_total_goal_one": '1',
  545. "half_total_goal_two": '2', "half_total_goal_three": '3或以上'}
  546. # 全场入球数 单双
  547. total_goal_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id,
  548. 'p_code': p_code,
  549. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  550. # 上半场入球数 单双
  551. for key, value in total_goals.items():
  552. if value:
  553. zqtwo_intodb(data1=value, data2=total_goal_data, data3=key, data4=total_dict[key], cursor=cursor, redis_db=self.redis_db)
  554. # 全场半场 --------------------------------------------------------------------------------------------------------------
  555. half_fulls = item['half_full']
  556. p_code, p_id = get_pcode(corner_ball, 'half_full')
  557. full_dict = {"half_full_home_home": "主主", "half_full_home_dogfall": "主和",
  558. "half_full_home_guest": "主客", "half_full_dogfall_home": "和主",
  559. "half_full_dogfall_dogfall": "和和", "half_full_dogfall_guest": "和客",
  560. "half_full_guest_home": "客主", "half_full_guest_dogfall": "客和",
  561. "half_full_guest_guest": "客客"}
  562. half_full_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id,
  563. 'p_code': p_code,
  564. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  565. if half_fulls:
  566. for key, value in half_fulls.items():
  567. if value:
  568. zqtwo_intodb(data1=value, data2=half_full_data, data3=key, data4=full_dict[key], cursor=cursor, redis_db=self.redis_db)
  569. # 波胆------------------------------------------------------------------------------------------------------------------
  570. bodan_datas = item['bodan_data']
  571. p_code, p_id = get_pcode(corner_ball, 'bodan')
  572. bodan_dict = {"bodanhome_one_zero": "1-0", "bodanhome_two_zero": "2-0",
  573. "bodanhome_two_one": "2-1", "bodanhome_three_zero": "3-0",
  574. "bodanhome_three_one": "3-1", "bodanhome_three_two": "3-2",
  575. "bodanhome_four_zero": "4-0", "bodanhome_four_one": "4-1",
  576. "bodanhome_four_two": "4-2", "bodanhome_four_three": "4-3",
  577. "bodanguest_one_zero": "0-1", "bodanguest_two_zero": "0-2",
  578. "bodanguest_two_one": "1-2", "bodanguest_three_zero": "0-3",
  579. "bodanguest_three_one": "1-3", "bodanguest_three_two": "2-3",
  580. "bodanguest_four_zero": "0-4", "bodanguest_four_one": "1-4",
  581. "bodanguest_four_two": "2-4", "bodanguest_four_three": "3-4",
  582. "bodandogfall_zero_zero": "0-0", "bodandogfall_one_one": "1-1",
  583. "bodandogfall_two_two": "2-2", "bodandogfall_three_three": "3-3",
  584. "bodandogfall_four_four": "4-4", "bodanother": "其他",
  585. "halfbodanhome_one_zero": "1-0", "halfbodanhome_two_zero": "2-0",
  586. "halfbodanhome_two_one": "2-1", "halfbodanhome_three_zero": "3-0",
  587. "halfbodanhome_three_one": "3-1", "halfbodanhome_three_two": "3-2",
  588. "halfbodanguest_one_zero": "0-1", "halfbodanguest_two_zero": "0-2",
  589. "halfbodanguest_two_one": "1-2", "halfbodanguest_three_zero": "0-3",
  590. "halfbodanguest_three_one": "1-3", "halfbodanguest_three_two": "2-3",
  591. "halfbodandogfall_zero_zero": "0-0", "halfbodandogfall_one_one": "1-1",
  592. "halfbodandogfall_two_two": "2-2", "halfbodandogfall_three_three": "3-3",
  593. "halfbodanother": "其他"}
  594. bodan_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id, 'p_code': p_code,
  595. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  596. if bodan_datas:
  597. for key, value in bodan_datas.items():
  598. zqtwo_intodb(data1=value, data2=bodan_data, data3=key, data4=bodan_dict[key], cursor=cursor, redis_db=self.redis_db)
  599. # 最先进球/最后进球 ------------------------------------------------------------------------------------------------------
  600. first_last_balls = item['first_last_ball']
  601. p_code, p_id = get_pcode(corner_ball, 'first_last_ball')
  602. first_last_dict = {"first_last_ball": "最先进球", "first_ball_home": "最先进球", "first_ball_guest": "最先进球",
  603. "last_ball_home": "最后进球", "last_ball_guest": "最后进球", "not_ball": "没有进球"}
  604. first_last_data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id,
  605. 'p_code': p_code,
  606. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  607. if first_last_balls:
  608. for key, value in first_last_balls.items():
  609. # 构建唯一索引
  610. zqtwo_intodb(data1=value, data2=first_last_data, data3=key, data4=first_last_dict[key], cursor=cursor, redis_db=self.redis_db)
  611. p_code, p_id = get_pcode(corner_ball, 'temaball')
  612. full_dicts = item['full_data']
  613. half_dicts = item['half_data']
  614. full_dict_rules = item['full_data_rule']
  615. half_dict_rules = item['half_data_rule']
  616. data = {'league_id': league_id, 'game_id': competition_id, 'utime': utime, 'p_id': p_id, 'p_code': p_code,
  617. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  618. if full_dicts:
  619. for key, value in full_dicts.items():
  620. zqtwo_intodb(data1=value, data2=data, data3=key, data4=full_dict_rules[key], cursor=cursor, redis_db=self.redis_db)
  621. if half_dicts:
  622. for key, value in half_dicts.items():
  623. zqtwo_intodb(data1=value, data2=data, data3=key, data4=half_dict_rules[key], cursor=cursor, redis_db=self.redis_db)
  624. match_date, match_time, time3 = new_time(ctime)
  625. n_time = out_time(time3, 1.5)
  626. # 插入st_zq_competition表
  627. if pt == 1:
  628. data_competition = {'team_home': team_home, 'team_guest': team_guest, 'league_id': league_id,
  629. 'game_id': competition_id,
  630. 'match_date': match_date, 'match_time': match_time, 'utime': utime, 'number': number,
  631. 'source': "hg3535", "expire_time": n_time, 'is_today': 1, "us_time": ctime}
  632. zqone_competition(data=data_competition, cursor=cursor)
  633. if pt == 2:
  634. data_competition = {'team_home': team_home, 'team_guest': team_guest, 'league_id': league_id,
  635. 'game_id': competition_id,
  636. 'match_date': match_date, 'match_time': match_time, 'utime': utime, 'number': number,
  637. 'source': "hg3535", "expire_time": n_time, 'is_morningplate': 1, "us_time": ctime}
  638. zqtwo_competition(data=data_competition, cursor=cursor)
  639. if pt == 3:
  640. data_competition = {'team_home': team_home, 'team_guest': team_guest, 'league_id': league_id,
  641. 'game_id': competition_id,
  642. 'match_date': match_date, 'match_time': match_time, 'utime': utime, 'number': number,
  643. 'source': "hg3535", "expire_time": n_time, "is_stringscene": 1, "us_time": ctime}
  644. zqthree_competition(data=data_competition, cursor=cursor)
  645. def close_spider(self, spider):
  646. self.conn.close()
  647. self.dbpool.close()
  648. # 篮球 让球大小----------------------------------------------------------------------------------------------------------
  649. class Lanqiupipeline(object):
  650. def __init__(self, dbpool, conn, cursor, redis_db):
  651. self.dbpool = dbpool
  652. self.conn = conn
  653. self.cursor = cursor
  654. self.redis_db = redis_db
  655. @classmethod
  656. def from_settings(cls, settings):
  657. dbparms = dict(
  658. host=settings["POST_HOST"],
  659. user=settings["POST_USER"],
  660. password=settings["POST_PASSWORD"],
  661. port=settings['POST_PORT'],
  662. )
  663. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  664. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  665. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  666. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  667. redis_db = redis.StrictRedis(connection_pool=pool)
  668. return cls(dbpool, conn, cursor, redis_db)
  669. def process_item(self, item, spider):
  670. # 使用twisted将mysql插入变成异步执行
  671. query = self.dbpool.runInteraction(self.do_insert, item)
  672. query.addErrback(self.handle_error, item, spider) # 处理异常
  673. # return item
  674. def handle_error(self, failure, item, spider):
  675. # 处理异步插入的异常
  676. print(failure)
  677. def do_insert(self, cursor, item):
  678. # 联赛id
  679. league_id = item['league_id']
  680. # 联赛名
  681. league_name = item['league_name']
  682. # result = item['result']
  683. # 比赛id
  684. game_id = item['game_id']
  685. # 球队1
  686. team_home = item['team_home']
  687. # 球队2
  688. team_guest = item['team_guest']
  689. # 数量(97>)
  690. number = item['number']
  691. # 比赛状态
  692. zhuangtai = item['zhuangtai']
  693. # 日期
  694. # data_game = item['data_game']
  695. data_game = item['data_game'].split("/")
  696. month = str(data_game[1].strip())
  697. day = str(data_game[0])
  698. # 比赛时间
  699. time_game = str(item['time_game'])
  700. # 比赛时间,时间戳
  701. ctime = "2019" + "-" + month + "-" + day + "" + time_game + ":00"
  702. r_ctime = "2019" + "-" + month + "-" + day
  703. # 现在时间,时间戳
  704. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  705. expire_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() + 60))
  706. # 队1分数
  707. score_home = item['score_home']
  708. # 队2分数
  709. score_guest = item['score_guest']
  710. # 第几节
  711. jijie = item['jijie']
  712. # 球队得分
  713. qiudui = item['qiudui']
  714. pt = item['pt']
  715. concedes_dict = item['concede']
  716. concedes_dict_rule = item['concede_rule']
  717. odd_evens_dict = item['odd_even']
  718. odd_evens_dict_rule = item['odd_even_rule']
  719. total_sizes_dict = item['total_size']
  720. total_sizes_dict_rule = item['total_size_rule']
  721. last_numbers_dict = item['last_number']
  722. capots_dict = item['capot']
  723. team_scores_dict = item['team_score']
  724. team_scores_dict_rule = item['team_score_rule']
  725. # 让球
  726. concede = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 1, 'p_code': "lq_concede",
  727. 'source': "hg3535", 'expire_time': expire_time}
  728. # 让球 数据插入数据库
  729. one_intodb(data1=concedes_dict, data2=concede, data3=concedes_dict_rule, cursor=cursor, redis_db=self.redis_db)
  730. two_sides = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 2, 'p_code': "lq_two_sides",
  731. 'source': "hg3535", 'expire_time': expire_time}
  732. # 总分单双 数据插入数据库
  733. one_intodb(data1=odd_evens_dict, data2=two_sides, data3=odd_evens_dict_rule, cursor=cursor, redis_db=self.redis_db)
  734. total_size = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 3, 'p_code': "lq_total_size",
  735. 'source': "hg3535", 'expire_time': expire_time}
  736. # 全场总分大小 数据插入数据库
  737. one_intodb(data1=total_sizes_dict, data2=total_size, data3=total_sizes_dict_rule, cursor=cursor, redis_db=self.redis_db)
  738. data4 = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 6, 'p_code': "lq_team_score",
  739. 'source': "hg3535", 'expire_time': expire_time}
  740. # 全场总分大小 数据插入数据库
  741. one_intodb(data1=team_scores_dict, data2=data4, data3=team_scores_dict_rule, cursor=cursor, redis_db=self.redis_db)
  742. # 主队进球最后一位数
  743. last_number_home = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 4,
  744. 'p_code': "lq_last_number",
  745. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  746. two_intodb(data1=last_numbers_dict['lq_last_home'], data2=last_number_home, data3="lq_last_home", cursor=cursor,redis_db=self.redis_db)
  747. # 客队进球最后一位数
  748. last_number_guest = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 4,
  749. 'p_code': "lq_last_number",
  750. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  751. two_intodb(data1=last_numbers_dict['lq_last_home'], data2=last_number_guest, data3="lq_last_guest",
  752. cursor=cursor, redis_db=self.redis_db)
  753. # 独赢
  754. capot_data = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 5, 'p_code': "lq_capot",
  755. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0}
  756. three_intodb(data1=capots_dict, data2=capot_data, cursor=cursor, redis_db=self.redis_db)
  757. match_date, match_time, time3 = new_time(ctime)
  758. n_time = out_time(time3, 1.5)
  759. us_time = ctime
  760. # 插入赛事表
  761. if pt == 1:
  762. Competition_sql = "insert into st_lq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_today,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s;"
  763. cursor.execute(Competition_sql, (
  764. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  765. n_time,1, us_time, number, n_time, 1))
  766. if pt == 2:
  767. Competition_sql = "insert into st_lq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_morningplate,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_morningplate=%s;"
  768. cursor.execute(Competition_sql, (
  769. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  770. n_time,1, us_time, number, n_time, 1))
  771. if pt == 3:
  772. Competition_sql = "insert into st_lq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_stringscene,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_stringscene=%s;"
  773. cursor.execute(Competition_sql, (
  774. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  775. n_time,1, us_time, number, n_time, 1))
  776. def close_spider(self, spider):
  777. self.conn.close()
  778. self.dbpool.close()
  779. # 网球 让球&大小盘--------------------------------------------------------------------------------------------------------
  780. class Wangqiupipeline(object):
  781. def __init__(self, dbpool, conn, cursor, redis_db):
  782. self.dbpool = dbpool
  783. self.conn = conn
  784. self.cursor = cursor
  785. self.redis_db = redis_db
  786. @classmethod
  787. def from_settings(cls, settings):
  788. dbparms = dict(
  789. host=settings["POST_HOST"],
  790. user=settings["POST_USER"],
  791. password=settings["POST_PASSWORD"],
  792. port=settings['POST_PORT'],
  793. )
  794. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  795. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  796. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  797. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  798. redis_db = redis.StrictRedis(connection_pool=pool)
  799. return cls(dbpool, conn, cursor, redis_db)
  800. def process_item(self, item, spider):
  801. # 使用twisted将mysql插入变成异步执行
  802. query = self.dbpool.runInteraction(self.do_insert, item)
  803. query.addErrback(self.handle_error, item, spider) # 处理异常
  804. # return item
  805. def handle_error(self, failure, item, spider):
  806. # 处理异步插入的异常
  807. print(failure)
  808. def do_insert(self, cursor, item):
  809. # 联赛id
  810. league_id = item['league_id']
  811. # 联赛名
  812. league_name = item['league_name']
  813. # result = item['result']
  814. # 比赛id
  815. game_id = item['game_id']
  816. # 球队1
  817. team_home = item['team_home']
  818. # 球队2
  819. team_guest = item['team_guest']
  820. # 数量(97>)
  821. number = item['number']
  822. # 比赛状态
  823. zhuangtai = item['zhuangtai']
  824. # 日期
  825. # data_game = item['data_game']
  826. data_game = item['data_game'].split("/")
  827. month = str(data_game[1].strip())
  828. day = str(data_game[0])
  829. # 比赛时间
  830. time_game = str(item['time_game'])
  831. # 比赛时间,时间戳
  832. ctime = "2019" + "-" + month + "-" + day + "" + time_game + ":00"
  833. r_ctime = "2019" + "-" + month + "-" + day
  834. # 现在时间,时间戳
  835. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  836. expire_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() + 60))
  837. # 队1分数
  838. score_home = item['score_home']
  839. # 队2分数
  840. score_guest = item['score_guest']
  841. # 第几节
  842. jijie = item['jijie']
  843. # 球队得分
  844. qiudui = item['qiudui']
  845. pt = item['pt']
  846. # 让盘
  847. concedes_dict = item['concedes_dict']
  848. concedes_dict_rule = item['concedes_dict_rule']
  849. # 冠军
  850. kemps_dict = item['kemps_dict']
  851. # 让局
  852. bureaus_dict = item['bureaus_dict']
  853. bureaus_dict_rule = item['bureaus_dict_rule']
  854. # 总局数大小
  855. total_number_dict = item['total_number_dict']
  856. total_number_dict_rule = item['total_number_dict_rule']
  857. # 总局数单双
  858. odd_evens_dict = item['odd_evens_dict']
  859. odd_evens_dict_rule = item['odd_evens_dict_rule']
  860. #
  861. # 让球
  862. concede = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 1, 'p_code': "wq_concede",
  863. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  864. wqone_intodb(data1=concedes_dict, data2=concede, data3=concedes_dict_rule, cursor=cursor, redis_db=self.redis_db)
  865. bureaus = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 3, 'p_code': "wq_bureau",
  866. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  867. wqone_intodb(data1=bureaus_dict, data2=bureaus, data3=bureaus_dict_rule, cursor=cursor, redis_db=self.redis_db)
  868. total_number = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 4,
  869. 'p_code': "wq_total_number", 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  870. wqone_intodb(data1=total_number_dict, data2=total_number, data3=total_number_dict_rule, cursor=cursor, redis_db=self.redis_db)
  871. odd_evens = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 5, 'p_code': "wq_two_sides",
  872. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  873. wqone_intodb(data1=odd_evens_dict, data2=odd_evens, data3=odd_evens_dict_rule, cursor=cursor, redis_db=self.redis_db)
  874. match_date, match_time, time3 = new_time(ctime)
  875. n_time = out_time(time3, 3)
  876. if kemps_dict:
  877. for key, value in kemps_dict.items():
  878. if value:
  879. new_hash = hash_func(match_id=game_id, odds_code=key, sort=0, p_id=2)
  880. r_hash = r_func(match_id=game_id, odds_code=key, sort=0, p_id=2, odd=value)
  881. odds_only = r_hash
  882. if self.redis_db.hexists("hg3535_wangqiu", r_hash):
  883. pass
  884. else:
  885. self.redis_db.hset("hg3535_wangqiu", r_hash, 0)
  886. sql1 = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole,odds_only,expire_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime = %s,odds = %s,odds_only=%s;"
  887. cursor.execute(sql1, (
  888. int(league_id), key, int(game_id), utime, utime, value, 2, "wq_kemp", 0, "hg3535", new_hash,
  889. odds_only,expire_time, utime, value, odds_only))
  890. # 更新主队st_zq_odds_record表
  891. sql2 = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s);"
  892. cursor.execute(sql2, (
  893. int(league_id), key, int(game_id), utime, utime, value, 2, "wq_kemp", 0, "hg3535", odds_only))
  894. us_time = ctime
  895. # 插入赛事表
  896. if pt is 1:
  897. Competition_sql = "insert into st_wq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_today,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s;"
  898. cursor.execute(Competition_sql, (
  899. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  900. n_time,1, us_time, number, n_time, 1))
  901. if pt is 2:
  902. Competition_sql = "insert into st_wq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_morningplate,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_morningplate=%s;"
  903. cursor.execute(Competition_sql, (
  904. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  905. n_time,1, us_time, number, n_time, 1))
  906. if pt is 3:
  907. Competition_sql = "insert into st_wq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_stringscene,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_stringscene=%s;"
  908. cursor.execute(Competition_sql, (
  909. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  910. n_time,1, us_time, number, n_time, 1))
  911. def close_spider(self, spider):
  912. self.conn.close()
  913. self.dbpool.close()
  914. # 网球 波胆--------------------------------------------------------------------------------------------------------------
  915. class Wqbodanpipeline(object):
  916. def __init__(self, dbpool, conn, cursor, redis_db):
  917. self.dbpool = dbpool
  918. self.conn = conn
  919. self.cursor = cursor
  920. self.redis_db = redis_db
  921. @classmethod
  922. def from_settings(cls, settings):
  923. dbparms = dict(
  924. host=settings["POST_HOST"],
  925. # db = settings["POST_DATABASE"],
  926. user=settings["POST_USER"],
  927. password=settings["POST_PASSWORD"],
  928. port=settings['POST_PORT'],
  929. )
  930. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  931. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  932. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  933. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  934. redis_db = redis.StrictRedis(connection_pool=pool)
  935. return cls(dbpool, conn, cursor, redis_db)
  936. def process_item(self, item, spider):
  937. # 使用twisted将mysql插入变成异步执行
  938. query = self.dbpool.runInteraction(self.do_insert, item)
  939. query.addErrback(self.handle_error, item, spider) # 处理异常
  940. # return item
  941. def handle_error(self, failure, item, spider):
  942. # 处理异步插入的异常
  943. print(failure)
  944. def do_insert(self, cursor, item):
  945. # 比赛日期
  946. data_game = item['data_game'].split("/")
  947. month = str(data_game[1].strip())
  948. day = str(data_game[0])
  949. # 比赛时间
  950. time_game = str(item['time_game'])
  951. # 比赛时间,时间戳
  952. ctime = "2019" + "-" + month + "-" + day + "" + time_game + ":00"
  953. r_ctime = "2019" + "-" + month + "-" + day
  954. # 现在时间,时间戳
  955. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  956. expire_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() + 60))
  957. # 比赛id
  958. competition_id = item['game_id']
  959. # 联赛id
  960. league_id = item['league_id']
  961. # 联赛name
  962. league_name = item['league_name']
  963. # 主队
  964. team_home = item['team_home']
  965. # 客队
  966. team_guest = item['team_guest']
  967. # 主队得分
  968. score_home = item['score_home']
  969. # 客队得分
  970. score_guest = item['score_guest']
  971. # number
  972. number = item['number']
  973. corner_ball = item['corner_ball']
  974. half_way = item['half_way']
  975. # 类型早盘,今日,滚球,串场
  976. pt = item['pt']
  977. bodan_datas = item['bodan_data']
  978. p_code = "wq_bodan"
  979. p_id = 7
  980. bodan_dict = {"wq_bodanhome_two_zero": "2-0", "wq_bodanhome_two_one": "2-1",
  981. "wq_bodanhome_three_zero": "3-0", "wq_bodanhome_three_one": "3-1",
  982. "wq_bodanhome_three_two": "3-2",
  983. "wq_bodanhome_four_zero": "4-0", "wq_bodanhome_four_one": "4-1",
  984. "wq_bodanhome_four_two": "4-2", "wq_bodanhome_four_three": "4-3",
  985. "wq_bodanguest_two_zero": "2-0", "wq_bodanguest_two_one": "2-1",
  986. "wq_bodanguest_three_zero": "3-0",
  987. "wq_bodanguest_three_one": "3-1", "wq_bodanguest_three_two": "3-2",
  988. "wq_bodanguest_four_zero": "4-0", "wq_bodanguest_four_one": "4-1",
  989. "wq_bodanguest_four_two": "4-2", "wq_bodanguest_four_three": "4-3"}
  990. if bodan_datas:
  991. for key, value in bodan_datas.items():
  992. if value:
  993. new_hash = hash_func(match_id=competition_id, odds_code=key, sort=0, p_id=7)
  994. r_hash = r_func(match_id=competition_id, odds_code=key, sort=0, p_id=7, odd=value)
  995. odds_only = r_hash
  996. if self.redis_db.hexists("hg3535_wangqiu", r_hash):
  997. pass
  998. else:
  999. self.redis_db.hset("hg3535_wangqiu", r_hash, 0)
  1000. sql1 = "insert into st_wq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole, condition, expire_time,odds_only) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime=%s,odds=%s,expire_time=%s,odds_only=%s;"
  1001. cursor.execute(sql1, (
  1002. int(league_id), key, int(competition_id), utime, utime, value, p_id, p_code, 0, "hg3535",
  1003. new_hash, bodan_dict[key], expire_time, odds_only,utime, value, expire_time, odds_only))
  1004. # 更新主队st_zq_odds_record表
  1005. sql2 = "insert into st_wq_odds_record(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, condition,odds_only) values (%s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s, %s);"
  1006. cursor.execute(sql2, (
  1007. int(league_id), key, int(competition_id), utime, utime, value, p_id, p_code, 0, "hg3535", key,odds_only))
  1008. def close_spider(self, spider):
  1009. self.conn.close()
  1010. self.dbpool.close()
  1011. # 棒球 让球&大小盘--------------------------------------------------------------------------------------------------------
  1012. class Bangqiupipeline(object):
  1013. def __init__(self, dbpool, conn, cursor, redis_db):
  1014. self.dbpool = dbpool
  1015. self.conn = conn
  1016. self.cursor = cursor
  1017. self.redis_db = redis_db
  1018. @classmethod
  1019. def from_settings(cls, settings):
  1020. dbparms = dict(
  1021. host=settings["POST_HOST"],
  1022. user=settings["POST_USER"],
  1023. password=settings["POST_PASSWORD"],
  1024. port=settings['POST_PORT'],
  1025. )
  1026. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  1027. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  1028. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  1029. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  1030. redis_db = redis.StrictRedis(connection_pool=pool)
  1031. return cls(dbpool, conn, cursor, redis_db)
  1032. def process_item(self, item, spider):
  1033. # 使用twisted将mysql插入变成异步执行
  1034. query = self.dbpool.runInteraction(self.do_insert, item)
  1035. query.addErrback(self.handle_error, item, spider) # 处理异常
  1036. # return item
  1037. def handle_error(self, failure, item, spider):
  1038. # 处理异步插入的异常
  1039. print(failure)
  1040. def do_insert(self, cursor, item):
  1041. # 联赛id
  1042. league_id = item['league_id']
  1043. # 联赛名
  1044. league_name = item['league_name']
  1045. # result = item['result']
  1046. # 比赛id
  1047. game_id = item['game_id']
  1048. # 球队1
  1049. team_home = item['team_home']
  1050. # 球队2
  1051. team_guest = item['team_guest']
  1052. # 数量(97>)
  1053. number = item['number']
  1054. # 比赛状态
  1055. zhuangtai = item['zhuangtai']
  1056. # 日期
  1057. # data_game = item['data_game']
  1058. data_game = item['data_game'].split("/")
  1059. month = str(data_game[1].strip())
  1060. day = str(data_game[0])
  1061. # 比赛时间
  1062. time_game = str(item['time_game'])
  1063. # 比赛时间,时间戳
  1064. ctime = "2019" + "-" + month + "-" + day + "" + time_game + ":00"
  1065. r_ctime = "2019" + "-" + month + "-" + day
  1066. # 现在时间,时间戳
  1067. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  1068. expire_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() + 60))
  1069. # 队1分数
  1070. score_home = item['score_home']
  1071. # 队2分数
  1072. score_guest = item['score_guest']
  1073. # 第几节
  1074. jijie = item['jijie']
  1075. # 球队得分
  1076. qiudui = item['qiudui']
  1077. pt = item['pt']
  1078. # 让球
  1079. concedes_dict = item['concedes_dict']
  1080. concedes_dict_rule = item['concedes_dict_rule']
  1081. # 独赢
  1082. capots_dict = item['capots_dict']
  1083. # 总得分大小
  1084. total_size_dict = item['total_size_dict']
  1085. total_size_dict_rule = item['total_size_dict_rule']
  1086. # 总得分单双
  1087. odd_evens_dict = item['odd_evens_dict']
  1088. odd_evens_dict_rule = item['odd_evens_dict_rule']
  1089. # 让球
  1090. concede = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 1, 'p_code': "bq_concede",
  1091. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  1092. bqone_intodb(data1=concedes_dict, data2=concede, data3=concedes_dict_rule, cursor=cursor, redis_db=self.redis_db)
  1093. # 总得分:大/小
  1094. total_size = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 2, 'p_code': "bq_total_size",
  1095. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  1096. bqone_intodb(data1=total_size_dict, data2=total_size, data3=total_size_dict_rule, cursor=cursor, redis_db=self.redis_db)
  1097. odd_even = {'league_id': league_id, 'game_id': game_id, 'utime': utime, 'p_id': 3, 'p_code': "bq_two_sides",
  1098. 'source': "hg3535", 'expire_time': expire_time, 'sort': 0, 'pt': pt}
  1099. bqone_intodb(data1=odd_evens_dict, data2=odd_even, data3=odd_evens_dict_rule, cursor=cursor, redis_db=self.redis_db)
  1100. # 赛事失效时间
  1101. match_date, match_time, time3 = new_time(ctime)
  1102. n_time = out_time(time3, 3.5)
  1103. # 插入独赢
  1104. if capots_dict:
  1105. for key, value in capots_dict.items():
  1106. if value:
  1107. new_hash = hash_func(match_id=game_id, odds_code=key, sort=0, p_id=4)
  1108. r_hash = r_func(match_id=game_id, odds_code=key, sort=0, p_id=4, odd=value)
  1109. odds_only = r_hash
  1110. if self.redis_db.hexists("hg3535_bangqiu", r_hash):
  1111. pass
  1112. else:
  1113. self.redis_db.hset("hg3535_bangqiu", r_hash, 0)
  1114. sql1 = "insert into st_bq_odds(lg_id, odds_code, match_id, ctime, utime, odds, p_id, p_code, sort, source, sole,odds_only,expire_time) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s,%s) on conflict(sole) do update set utime = %s,odds = %s,odds_only=%s,expire_time=%s;"
  1115. cursor.execute(sql1, (
  1116. int(league_id), key, int(game_id), utime, utime, value, 4, "bq_capot", 0, "hg3535", new_hash,
  1117. odds_only, expire_time,utime, value, odds_only, expire_time))
  1118. # 更新主队st_zq_odds_record表
  1119. sql2 = "insert into st_bq_odds_record(lg_id, odds_code, match_id, ctime, utime,odds, p_id, p_code, sort, source,odds_only) values (%s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s);"
  1120. cursor.execute(sql2, (
  1121. int(league_id), key, int(game_id), utime, utime, value, 4, "bq_capot", 0, "hg3535", odds_only))
  1122. us_time = ctime
  1123. # 插入赛事表
  1124. if pt == 1:
  1125. Competition_sql = "insert into st_bq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_today,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_today=%s;"
  1126. cursor.execute(Competition_sql, (
  1127. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  1128. n_time, 1, us_time, number, n_time, 1))
  1129. if pt == 2:
  1130. Competition_sql = "insert into st_bq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_morningplate,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_morningplate=%s;"
  1131. cursor.execute(Competition_sql, (
  1132. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  1133. n_time,1, us_time, number, n_time, 1))
  1134. if pt == 3:
  1135. Competition_sql = "insert into st_bq_competition(home_team, guest_team, lg_id, match_id, match_date, match_time,ctime, utime, tag,source,expire_time,is_stringscene,us_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s) on conflict(match_id) do update set tag = %s,expire_time=%s,is_stringscene=%s;"
  1136. cursor.execute(Competition_sql, (
  1137. team_home, team_guest, league_id, game_id, match_date, match_time, utime, utime, number, "hg3535",
  1138. n_time,1, us_time, number, n_time, 1))
  1139. def close_spider(self, spider):
  1140. self.conn.close()
  1141. self.dbpool.close()
  1142. # 足球 篮球 网球 棒球 冠军------------------------------------------------------------------------------------------------
  1143. class Guanjunpipeline(object):
  1144. def __init__(self, dbpool, conn, cursor, redis_db):
  1145. self.dbpool = dbpool
  1146. self.conn = conn
  1147. self.cursor = cursor
  1148. self.redis_db = redis_db
  1149. @classmethod
  1150. def from_settings(cls, settings):
  1151. dbparms = dict(
  1152. host=settings["POST_HOST"],
  1153. user=settings["POST_USER"],
  1154. password=settings["POST_PASSWORD"],
  1155. port=settings['POST_PORT'],
  1156. )
  1157. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  1158. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  1159. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  1160. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  1161. redis_db = redis.StrictRedis(connection_pool=pool)
  1162. return cls(dbpool, conn, cursor, redis_db)
  1163. def process_item(self, item, spider):
  1164. # 使用twisted将mysql插入变成异步执行
  1165. query = self.dbpool.runInteraction(self.do_insert, item)
  1166. query.addErrback(self.handle_error, item, spider) # 处理异常
  1167. # return item
  1168. def handle_error(self, failure, item, spider):
  1169. # 处理异步插入的异常
  1170. print(failure)
  1171. def do_insert(self, cursor, item):
  1172. # 执行具体的插入
  1173. # 根据不同的item 构建不同的sql语句并插入到mysql中
  1174. data_game = item['data_game'].replace('年', "-").replace('月', "-").replace('日', "")
  1175. time_game = item['time_game']
  1176. ctime = data_game + " " + time_game + ":00"
  1177. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  1178. expire_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() + 60))
  1179. league_name = item['league_name']
  1180. tema_home = item['tema_home']
  1181. league_id = item['league_id']
  1182. game_id = item['game_id']
  1183. new_league_name = item['new_league_name']
  1184. # 冠军赔率
  1185. champion_team = item['champion_team']
  1186. new_champion = item['new_champion']
  1187. # 构建唯一哈希索引
  1188. time1 = time.mktime(time.strptime(ctime, '%Y-%m-%d %H:%M:%S')) + 43200
  1189. time2 = time.localtime(time1)
  1190. time3 = time.strftime('%Y-%m-%d %H:%M:%S', time2)
  1191. # data_time = str(time3).split(" ")
  1192. # match_date,match_time = new_time(ctime)
  1193. pt = item['pt']
  1194. new_hash = hash_func(match_id=champion_team, odds_code=new_champion, sort=new_league_name, p_id=tema_home)
  1195. ball = item['ball']
  1196. # 插入st_zq_odds表
  1197. r_hash = hash_func(league_id, new_champion, tema_home, champion_team)
  1198. odds_only = r_hash
  1199. s_hash = hash_func(league_id, league_name, ball, 0)
  1200. if ball == "足球":
  1201. n_gameid = int('1' + str(league_id))
  1202. data_dict = {'league_id': league_id, 'new_champion': new_champion, 'utime': utime,
  1203. 'champion_team': champion_team, "p_id": 8, 'new_league_name': new_league_name,
  1204. 'tema_home': tema_home, 'new_hash': new_hash, 'expire_time': expire_time,
  1205. "odds_only": odds_only,
  1206. "league_name": league_name, 'time3': time3, 'game_id': n_gameid}
  1207. gjz_into(data_dict, cursor, r_hash, s_hash, self.redis_db)
  1208. Competition_sql = "insert into st_zq_competition(home_team, lg_id, match_id, ctime, utime, source, us_time) values (%s, %s, %s, %s, %s, %s, %s) on conflict(match_id) do update set utime=%s;"
  1209. cursor.execute(Competition_sql, (league_name, league_id, n_gameid, utime, utime, 'hg3535', data_game, utime))
  1210. if ball == "篮球":
  1211. n_gameid = int('2' + str(league_id))
  1212. data_dict = {'league_id': league_id, 'new_champion': new_champion, 'utime': utime,
  1213. 'champion_team': champion_team, "p_id": 7, 'new_league_name': new_league_name,
  1214. 'tema_home': tema_home, 'new_hash': new_hash, 'expire_time': expire_time,
  1215. "odds_only": odds_only,
  1216. "league_name": league_name, 'time3': time3, 'game_id': n_gameid}
  1217. gjl_into(data_dict, cursor, r_hash, s_hash, self.redis_db)
  1218. Competition_sql = "insert into st_lq_competition(home_team, lg_id, match_id, ctime, utime, source, us_time) values (%s, %s, %s, %s, %s, %s, %s) on conflict(match_id) do update set utime=%s;"
  1219. cursor.execute(Competition_sql, (league_name, league_id, n_gameid, utime, utime, 'hg3535', data_game, utime))
  1220. if ball == "网球":
  1221. n_gameid = int('3' + str(league_id))
  1222. data_dict = {'league_id': league_id, 'new_champion': new_champion, 'utime': utime,
  1223. 'champion_team': champion_team, "p_id": 6, 'new_league_name': new_league_name,
  1224. 'tema_home': tema_home, 'new_hash': new_hash, 'expire_time': expire_time,
  1225. "odds_only": odds_only,
  1226. "league_name": league_name, 'time3': time3, 'game_id': n_gameid}
  1227. gjw_into(data_dict, cursor, r_hash, s_hash, self.redis_db)
  1228. Competition_sql = "insert into st_wq_competition(home_team, lg_id, match_id, ctime, utime, source, us_time) values (%s, %s, %s, %s, %s, %s, %s) on conflict(match_id) do update set utime=%s;"
  1229. cursor.execute(Competition_sql, (league_name, league_id, n_gameid, utime, utime, 'hg3535', data_game, utime))
  1230. if ball == "棒球":
  1231. n_gameid = int('4' + str(league_id))
  1232. data_dict = {'league_id': league_id, 'new_champion': new_champion, 'utime': utime,
  1233. 'champion_team': champion_team, "p_id": 5, 'new_league_name': new_league_name,
  1234. 'tema_home': tema_home, 'new_hash': new_hash, 'expire_time': expire_time,
  1235. "odds_only": odds_only,
  1236. "league_name": league_name, 'time3': time3, 'game_id': n_gameid}
  1237. gjb_into(data_dict, cursor, r_hash, s_hash, self.redis_db)
  1238. Competition_sql = "insert into st_bq_competition(home_team, lg_id, match_id, ctime, utime, source, us_time) values (%s, %s, %s, %s, %s, %s, %s) on conflict(match_id) do update set utime=%s;"
  1239. cursor.execute(Competition_sql, (league_name, league_id, n_gameid, utime, utime, 'hg3535', data_game, utime))
  1240. def close_spider(self, spider):
  1241. self.conn.close()
  1242. self.dbpool.close()
  1243. # 足球 篮球 网球 棒球 联赛------------------------------------------------------------------------------------------------
  1244. class Liansaipipeline(object):
  1245. def __init__(self, dbpool, conn, cursor, redis_db):
  1246. self.dbpool = dbpool
  1247. self.conn = conn
  1248. self.cursor = cursor
  1249. self.redis_db = redis_db
  1250. @classmethod
  1251. def from_settings(cls, settings):
  1252. dbparms = dict(
  1253. host=settings["POST_HOST"],
  1254. user=settings["POST_USER"],
  1255. password=settings["POST_PASSWORD"],
  1256. port=settings['POST_PORT'],
  1257. )
  1258. dbpool = adbapi.ConnectionPool("psycopg2", **dbparms)
  1259. conn = psycopg2.connect(host=settings["POST_HOST"], port=settings['POST_PORT'], user=settings["POST_USER"], password=settings["POST_PASSWORD"], database=settings["POST_DATABASE"])
  1260. cursor = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
  1261. pool = redis.ConnectionPool(host=settings["R_HOST"], port=settings["R_POST"], password=settings["R_PASSWORD"])
  1262. redis_db = redis.StrictRedis(connection_pool=pool)
  1263. return cls(dbpool, conn, cursor, redis_db)
  1264. def process_item(self, item, spider):
  1265. # 使用twisted将mysql插入变成异步执行
  1266. query = self.dbpool.runInteraction(self.do_insert, item)
  1267. query.addErrback(self.handle_error, item, spider) # 处理异常
  1268. # return item
  1269. def handle_error(self, failure, item, spider):
  1270. # 处理异步插入的异常
  1271. print(failure)
  1272. def do_insert(self, cursor, item):
  1273. area_id = item["area_id"]
  1274. area_name = item["area_name"]
  1275. st_league = item["st_league"]
  1276. name_chinese = item["name_chinese"]
  1277. ball = item['ball']
  1278. utime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  1279. area_dict = {"南美洲": 3, "北美洲": 4, "欧洲": 5, "大洋洲": 6, "南极洲": 7, "非洲": 1, "世界": 8, "亚洲": 2}
  1280. redis_data_dict = "hg3535_liansai"
  1281. r_hash = hash_func(st_league, name_chinese, ball, 0)
  1282. if self.redis_db.hexists(redis_data_dict, r_hash):
  1283. pass
  1284. else:
  1285. self.redis_db.hset(redis_data_dict, r_hash, 0)
  1286. if ball == "足球":
  1287. if area_name in area_dict:
  1288. sql1 = "insert into st_zq_league(name_chinese, lg_id, area_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set area_id = %s,source=%s;"
  1289. cursor.execute(sql1, (name_chinese, st_league, area_dict[area_name], "hg3535",utime, area_dict[area_name], "hg3535"))
  1290. else:
  1291. if area_name == "足球":
  1292. sql2 = "insert into st_zq_league(name_chinese, lg_id, country_id,source) values (%s, %s, %s,%s) on conflict(lg_id) do update set source=%s;"
  1293. cursor.execute(sql2, (name_chinese, st_league, 0, "hg3535", "hg3535"))
  1294. else:
  1295. sql2 = "insert into st_zq_league(name_chinese, lg_id, country_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set country_id = %s,source=%s;"
  1296. cursor.execute(sql2, (name_chinese, st_league, area_id, "hg3535",utime, area_id, "hg3535"))
  1297. sql3 = "insert into st_country(country_id, name_chinese, country_area, country_order,recommend_order, update_time,source) values (%s, %s, %s,%s, %s, %s,%s) on conflict(country_id) do update set update_time =%s,source=%s;"
  1298. cursor.execute(sql3, (area_id, area_name, 0, 0, 0, utime, "hg3535", utime, "hg3535"))
  1299. elif ball == "篮球":
  1300. if area_name in area_dict:
  1301. sql1 = "insert into st_lq_league(name_chinese, lg_id, area_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set area_id = %s,source=%s;"
  1302. cursor.execute(sql1,
  1303. (name_chinese, st_league, area_dict[area_name], "hg3535",utime, area_dict[area_name],"hg3535"))
  1304. else:
  1305. if area_name == "篮球":
  1306. sql2 = "insert into st_lq_league(name_chinese, lg_id, country_id,source) values (%s, %s, %s,%s) on conflict(lg_id) do update set source=%s;"
  1307. cursor.execute(sql2, (name_chinese, st_league, 0, "hg3535", "hg3535"))
  1308. else:
  1309. sql2 = "insert into st_lq_league(name_chinese, lg_id, country_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set country_id = %s,source=%s;"
  1310. cursor.execute(sql2, (name_chinese, st_league, area_id, "hg3535",utime, area_id, "hg3535"))
  1311. sql3 = "insert into st_country(country_id, name_chinese, country_area, country_order,recommend_order, update_time,source) values (%s, %s, %s,%s, %s, %s,%s) on conflict(country_id) do update set update_time =%s,source=%s;"
  1312. cursor.execute(sql3, (area_id, area_name, 0, 0, 0, utime, "hg3535", utime, "hg3535"))
  1313. elif ball == "网球":
  1314. if area_name in area_dict:
  1315. sql1 = "insert into st_wq_league(name_chinese, lg_id, area_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set area_id = %s,source=%s;"
  1316. cursor.execute(sql1, (name_chinese, st_league, area_dict[area_name], "hg3535",utime, area_dict[area_name],"hg3535"))
  1317. else:
  1318. if area_name == "网球":
  1319. sql2 = "insert into st_wq_league(name_chinese, lg_id, country_id,source) values (%s, %s, %s,%s) on conflict(lg_id) do update set source=%s;"
  1320. cursor.execute(sql2, (name_chinese, st_league, 0, "hg3535", "hg3535"))
  1321. else:
  1322. sql2 = "insert into st_wq_league(name_chinese, lg_id, country_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set country_id = %s,source=%s;"
  1323. cursor.execute(sql2, (name_chinese, st_league, area_id, "hg3535",utime, area_id, "hg3535"))
  1324. sql3 = "insert into st_country(country_id, name_chinese, country_area, country_order,recommend_order, update_time,source) values (%s, %s, %s,%s, %s, %s,%s) on conflict(country_id) do update set update_time =%s,source=%s;"
  1325. cursor.execute(sql3, (area_id, area_name, 0, 0, 0, utime, "hg3535", utime, "hg3535"))
  1326. elif ball == "棒球":
  1327. if area_name in area_dict:
  1328. sql1 = "insert into st_bq_league(name_chinese, lg_id, area_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set area_id = %s,source=%s;"
  1329. cursor.execute(sql1,(name_chinese, st_league, area_dict[area_name], "hg3535",utime, area_dict[area_name],"hg3535"))
  1330. else:
  1331. if area_name == "棒球":
  1332. sql2 = "insert into st_bq_league(name_chinese, lg_id, country_id,source) values (%s, %s, %s,%s) on conflict(lg_id) do update set source=%s;"
  1333. cursor.execute(sql2, (name_chinese, st_league, 0, "hg3535", "hg3535"))
  1334. else:
  1335. sql2 = "insert into st_bq_league(name_chinese, lg_id, country_id,source,utime) values (%s, %s, %s,%s,%s) on conflict(lg_id) do update set country_id = %s,source=%s;"
  1336. cursor.execute(sql2, (name_chinese, st_league, area_id, "hg3535",utime, area_id, "hg3535"))
  1337. sql3 = "insert into st_country(country_id, name_chinese, country_area, country_order,recommend_order, update_time,source) values (%s, %s, %s,%s, %s, %s,%s) on conflict(country_id) do update set update_time =%s,source=%s;"
  1338. cursor.execute(sql3, (area_id, area_name, 0, 0, 0, utime, "hg3535", utime, "hg3535"))
  1339. def close_spider(self, spider):
  1340. self.conn.close()
  1341. self.dbpool.close()
  1342. # self.redis_db.disconnect()