feishu_lib.py 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638
  1. # -*- coding: utf-8 -*-
  2. # @Author: wangkun
  3. # @Time: 2022/8/9
  4. import json
  5. import requests
  6. import urllib3
  7. from main.common import Common
  8. proxies = {"http": None, "https": None}
  9. class Feishu:
  10. """
  11. 编辑飞书云文档
  12. """
  13. # 看一看爬虫数据表
  14. kanyikan_url = "https://w42nne6hzg.feishu.cn/sheets/shtcngRPoDYAi24x52j2nDuHMih?"
  15. # 快手爬虫数据表
  16. kuaishou_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnICEfaw9llDNQkKgdymM1xf?"
  17. # 微视爬虫数据表
  18. weishi_url = "https://w42nne6hzg.feishu.cn/sheets/shtcn5YSWg91JfVGzj0SFZIRRPh?"
  19. # 小年糕爬虫数据表
  20. xiaoniangao_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnYxiyQ1wLklo1W5Kdqc9cGh?"
  21. # 音乐相册
  22. music_album = "https://w42nne6hzg.feishu.cn/sheets/shtcnT6zvmfsYe1g0iv4pt7855g?"
  23. # 本山祝福数据表
  24. crawler_benshanzhufu = "https://w42nne6hzg.feishu.cn/sheets/shtcnGh2rrsPYM4iVNEBO7OqWrb?"
  25. # 公众号爬虫表
  26. gzh_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnexNXnpDLHhARw0QdiwbYuA?"
  27. # 数据监控表
  28. crawler_monitor = "https://w42nne6hzg.feishu.cn/sheets/shtcnlZWYazInhf7Z60jkbLRJyd?"
  29. # 微群视频爬虫表
  30. crawler_weiqun_video = "https://w42nne6hzg.feishu.cn/sheets/shtcnoKThNquYRweaylMFVyo9Hc?"
  31. # 视频号爬虫表
  32. crawler_shipinhao = 'https://w42nne6hzg.feishu.cn/sheets/shtcn9rOdZRAGFbRkWpn7hqEHGc?'
  33. # 西瓜视频
  34. crawler_xigua = 'https://w42nne6hzg.feishu.cn/sheets/shtcnvOpx2P8vBXiV91Ot1MKIw8?'
  35. # 知乎 PC 端
  36. crawler_zhihu = 'https://w42nne6hzg.feishu.cn/sheets/shtcnkGPBmGsjaqapgzouuj8MXe?'
  37. # 吉祥幸福
  38. crawler_jixiangxingfu = 'https://w42nne6hzg.feishu.cn/sheets/shtcnSx4nafMbLTq7xl7RHBwHBf?'
  39. # 众妙音信
  40. crawler_zmyx = 'https://w42nne6hzg.feishu.cn/sheets/shtcnbZIxstPeM0xshW07b26sve?'
  41. # 岁岁年年迎福气
  42. crawler_ssnnyfq = 'https://w42nne6hzg.feishu.cn/sheets/shtcnyJmJSJynHDLLbLTkySfvZe?'
  43. # 祝福猫视频
  44. crawler_zhufumao = 'https://w42nne6hzg.feishu.cn/sheets/shtcnXfIJthvkjhI5zlEJq84i6g?'
  45. # 宗教公众号
  46. crawler_zongjiao = 'https://w42nne6hzg.feishu.cn/sheets/shtcn73NW0CyoOeF21HWO15KBsb?'
  47. # 好看视频
  48. crawler_haokan = 'https://w42nne6hzg.feishu.cn/sheets/shtcnaYz8Nhv8q6DbWtlL6rMEBd'
  49. # 看到就是福气
  50. crawler_kandaojiushifuqi = 'https://w42nne6hzg.feishu.cn/sheets/shtcnEokBkIjOUPAk8vbbPKnXgb'
  51. # 胜胜影音
  52. crawler_shengshengyingyin = 'https://w42nne6hzg.feishu.cn/sheets/shtcnz1ymxHL1u8WHblfqfys7qe'
  53. # 刚刚都传
  54. crawler_ganggangdouchuan = 'https://w42nne6hzg.feishu.cn/sheets/shtcnTuJgeZU2bc7VaesAqk3QJx'
  55. # 公众号_信欣
  56. crawler_gongzhonghao = 'https://w42nne6hzg.feishu.cn/sheets/shtcna98M2mX7TbivTj9Sb7WKBN?'
  57. # youtube
  58. crawler_youtube = 'https://w42nne6hzg.feishu.cn/sheets/shtcnrLyr1zbYbhhZyqpN7Xrd5f?'
  59. # 飞书路径token
  60. @classmethod
  61. def spreadsheettoken(cls, crawler):
  62. """
  63. :param crawler: 哪个爬虫
  64. """
  65. if crawler == "kanyikan":
  66. return "shtcngRPoDYAi24x52j2nDuHMih"
  67. elif crawler == "kuaishou":
  68. return "shtcnICEfaw9llDNQkKgdymM1xf"
  69. elif crawler == "weishi":
  70. return "shtcn5YSWg91JfVGzj0SFZIRRPh"
  71. elif crawler == "xiaoniangao":
  72. return "shtcnYxiyQ1wLklo1W5Kdqc9cGh"
  73. elif crawler == "monitor":
  74. return "shtcnlZWYazInhf7Z60jkbLRJyd"
  75. elif crawler == "music_album":
  76. return "shtcnT6zvmfsYe1g0iv4pt7855g"
  77. elif crawler == "bszf":
  78. return "shtcnGh2rrsPYM4iVNEBO7OqWrb"
  79. elif crawler == "gzh":
  80. return "shtcnexNXnpDLHhARw0QdiwbYuA"
  81. elif crawler == "weiqun":
  82. return "shtcnoKThNquYRweaylMFVyo9Hc"
  83. elif crawler == 'shipinhao':
  84. return 'shtcn9rOdZRAGFbRkWpn7hqEHGc'
  85. elif crawler == 'xigua':
  86. return 'shtcnvOpx2P8vBXiV91Ot1MKIw8'
  87. elif crawler == 'zhihu':
  88. return 'shtcnkGPBmGsjaqapgzouuj8MXe'
  89. elif crawler == 'jxxf':
  90. return 'shtcnSx4nafMbLTq7xl7RHBwHBf'
  91. elif crawler == 'zmyx':
  92. return 'shtcnbZIxstPeM0xshW07b26sve'
  93. elif crawler == 'ssnnyfq':
  94. return 'shtcnyJmJSJynHDLLbLTkySfvZe'
  95. elif crawler == 'zhufumao':
  96. return 'shtcnXfIJthvkjhI5zlEJq84i6g'
  97. elif crawler == 'zongjiao':
  98. return 'shtcn73NW0CyoOeF21HWO15KBsb'
  99. elif crawler == 'haokan':
  100. return 'shtcnaYz8Nhv8q6DbWtlL6rMEBd'
  101. elif crawler == 'kdjsfq':
  102. return 'shtcnEokBkIjOUPAk8vbbPKnXgb'
  103. elif crawler == 'ssyy':
  104. return 'shtcnz1ymxHL1u8WHblfqfys7qe'
  105. elif crawler == 'ggdc':
  106. return 'shtcnTuJgeZU2bc7VaesAqk3QJx'
  107. elif crawler == 'gongzhonghao_xinxin':
  108. return 'shtcna98M2mX7TbivTj9Sb7WKBN'
  109. elif crawler == 'youtube':
  110. return 'shtcnrLyr1zbYbhhZyqpN7Xrd5f'
  111. # 获取飞书api token
  112. @classmethod
  113. def get_token(cls, log_type):
  114. """
  115. 获取飞书api token
  116. :return:
  117. """
  118. url = "https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal/"
  119. post_data = {"app_id": "cli_a13ad2afa438d00b", # 这里账号密码是发布应用的后台账号及密码
  120. "app_secret": "4tK9LY9VbiQlY5umhE42dclBFo6t4p5O"}
  121. try:
  122. urllib3.disable_warnings()
  123. response = requests.post(url=url, data=post_data, proxies=proxies, verify=False)
  124. tenant_access_token = response.json()["tenant_access_token"]
  125. return tenant_access_token
  126. except Exception as e:
  127. Common.logger(log_type).error("获取飞书 api token 异常:{}", e)
  128. # 获取表格元数据
  129. @classmethod
  130. def get_metainfo(cls, log_type, crawler):
  131. """
  132. 获取表格元数据
  133. :return:
  134. """
  135. get_metainfo_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  136. + cls.spreadsheettoken(crawler) + "/metainfo"
  137. headers = {
  138. "Authorization": "Bearer " + cls.get_token(log_type),
  139. "Content-Type": "application/json; charset=utf-8"
  140. }
  141. params = {
  142. "extFields": "protectedRange", # 额外返回的字段,extFields=protectedRange时返回保护行列信息
  143. "user_id_type": "open_id" # 返回的用户id类型,可选open_id,union_id
  144. }
  145. try:
  146. urllib3.disable_warnings()
  147. r = requests.get(url=get_metainfo_url, headers=headers, params=params, proxies=proxies, verify=False)
  148. response = json.loads(r.content.decode("utf8"))
  149. return response
  150. except Exception as e:
  151. Common.logger(log_type).error("获取表格元数据异常:{}", e)
  152. # 读取工作表中所有数据
  153. @classmethod
  154. def get_values_batch(cls, log_type, crawler, sheetid):
  155. """
  156. 读取工作表中所有数据
  157. :param log_type: 启用哪个 log
  158. :param crawler: 哪个爬虫
  159. :param sheetid: 哪张表
  160. :return: 所有数据
  161. """
  162. get_values_batch_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  163. + cls.spreadsheettoken(crawler) + "/values_batch_get"
  164. headers = {
  165. "Authorization": "Bearer " + cls.get_token(log_type),
  166. "Content-Type": "application/json; charset=utf-8"
  167. }
  168. params = {
  169. # 多个查询范围 如 url?ranges=range1,range2 ,其中 range 包含 sheetId 与单元格范围两部分
  170. "ranges": sheetid,
  171. # valueRenderOption=ToString 可返回纯文本的值(数值类型除外);
  172. # valueRenderOption=FormattedValue 计算并格式化单元格;
  173. # valueRenderOption=Formula单元格中含有公式时返回公式本身;
  174. # valueRenderOption=UnformattedValue计算但不对单元格进行格式化
  175. "valueRenderOption": "ToString",
  176. # dateTimeRenderOption=FormattedString 计算并将时间日期按照其格式进行格式化,但不会对数字进行格式化,返回格式化后的字符串。
  177. "dateTimeRenderOption": "",
  178. # 返回的用户id类型,可选open_id,union_id
  179. "user_id_type": "open_id"
  180. }
  181. try:
  182. urllib3.disable_warnings()
  183. r = requests.get(url=get_values_batch_url, headers=headers, params=params, proxies=proxies, verify=False)
  184. # print(r.text)
  185. response = json.loads(r.content.decode("utf8"))
  186. values = response["data"]["valueRanges"][0]["values"]
  187. return values
  188. except Exception as e:
  189. Common.logger(log_type).error("读取工作表所有数据异常:{}", e)
  190. # 工作表,插入行或列
  191. @classmethod
  192. def insert_columns(cls, log_type, crawler, sheetid, majordimension, startindex, endindex):
  193. """
  194. 工作表插入行或列
  195. :param log_type: 日志路径
  196. :param crawler: 哪个爬虫的云文档
  197. :param sheetid:哪张工作表
  198. :param majordimension:行或者列, ROWS、COLUMNS
  199. :param startindex:开始位置
  200. :param endindex:结束位置
  201. """
  202. insert_columns_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  203. + cls.spreadsheettoken(crawler) + "/insert_dimension_range"
  204. headers = {
  205. "Authorization": "Bearer " + cls.get_token(log_type),
  206. "Content-Type": "application/json; charset=utf-8"
  207. }
  208. body = {
  209. "dimension": {
  210. "sheetId": sheetid,
  211. "majorDimension": majordimension, # 默认 ROWS ,可选 ROWS、COLUMNS
  212. "startIndex": startindex, # 开始的位置
  213. "endIndex": endindex # 结束的位置
  214. },
  215. "inheritStyle": "AFTER" # BEFORE 或 AFTER,不填为不继承 style
  216. }
  217. try:
  218. urllib3.disable_warnings()
  219. r = requests.post(url=insert_columns_url, headers=headers, json=body, proxies=proxies, verify=False)
  220. Common.logger(log_type).info("插入行或列:{}", r.json()["msg"])
  221. except Exception as e:
  222. Common.logger(log_type).error("插入行或列异常:{}", e)
  223. # 写入数据
  224. @classmethod
  225. def update_values(cls, log_type, crawler, sheetid, ranges, values):
  226. """
  227. 写入数据
  228. :param log_type: 日志路径
  229. :param crawler: 哪个爬虫的云文档
  230. :param sheetid:哪张工作表
  231. :param ranges:单元格范围
  232. :param values:写入的具体数据,list
  233. """
  234. update_values_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  235. + cls.spreadsheettoken(crawler) + "/values_batch_update"
  236. headers = {
  237. "Authorization": "Bearer " + cls.get_token(log_type),
  238. "Content-Type": "application/json; charset=utf-8"
  239. }
  240. body = {
  241. "valueRanges": [
  242. {
  243. "range": sheetid + "!" + ranges,
  244. "values": values
  245. },
  246. ],
  247. }
  248. try:
  249. urllib3.disable_warnings()
  250. r = requests.post(url=update_values_url, headers=headers, json=body, proxies=proxies, verify=False)
  251. Common.logger(log_type).info("写入数据:{}", r.json()["msg"])
  252. except Exception as e:
  253. Common.logger(log_type).error("写入数据异常:{}", e)
  254. # 合并单元格
  255. @classmethod
  256. def merge_cells(cls, log_type, crawler, sheetid, ranges):
  257. """
  258. 合并单元格
  259. :param log_type: 日志路径
  260. :param crawler: 哪个爬虫
  261. :param sheetid:哪张工作表
  262. :param ranges:需要合并的单元格范围
  263. """
  264. merge_cells_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  265. + cls.spreadsheettoken(crawler) + "/merge_cells"
  266. headers = {
  267. "Authorization": "Bearer " + cls.get_token(log_type),
  268. "Content-Type": "application/json; charset=utf-8"
  269. }
  270. body = {
  271. "range": sheetid + "!" + ranges,
  272. "mergeType": "MERGE_ROWS"
  273. }
  274. try:
  275. urllib3.disable_warnings()
  276. r = requests.post(url=merge_cells_url, headers=headers, json=body, proxies=proxies, verify=False)
  277. Common.logger(log_type).info("合并单元格:{}", r.json()["msg"])
  278. except Exception as e:
  279. Common.logger(log_type).error("合并单元格异常:{}", e)
  280. # 读取单元格数据
  281. @classmethod
  282. def get_range_value(cls, log_type, crawler, sheetid, cell):
  283. """
  284. 读取单元格内容
  285. :param log_type: 日志路径
  286. :param crawler: 哪个爬虫
  287. :param sheetid: 哪张工作表
  288. :param cell: 哪个单元格
  289. :return: 单元格内容
  290. """
  291. get_range_value_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  292. + cls.spreadsheettoken(crawler) + "/values/" + sheetid + "!" + cell
  293. headers = {
  294. "Authorization": "Bearer " + cls.get_token(log_type),
  295. "Content-Type": "application/json; charset=utf-8"
  296. }
  297. params = {
  298. # valueRenderOption=ToString 可返回纯文本的值(数值类型除外);
  299. # valueRenderOption=FormattedValue 计算并格式化单元格;
  300. # valueRenderOption=Formula 单元格中含有公式时返回公式本身;
  301. # valueRenderOption=UnformattedValue 计算但不对单元格进行格式化。
  302. "valueRenderOption": "FormattedValue",
  303. # dateTimeRenderOption=FormattedString 计算并对时间日期按照其格式进行格式化,但不会对数字进行格式化,返回格式化后的字符串。
  304. "dateTimeRenderOption": "",
  305. # 返回的用户id类型,可选open_id,union_id
  306. "user_id_type": "open_id"
  307. }
  308. try:
  309. urllib3.disable_warnings()
  310. r = requests.get(url=get_range_value_url, headers=headers, params=params, proxies=proxies, verify=False)
  311. # print(r.text)
  312. return r.json()["data"]["valueRange"]["values"][0]
  313. except Exception as e:
  314. Common.logger(log_type).error("读取单元格数据异常:{}", e)
  315. # 删除行或列,可选 ROWS、COLUMNS
  316. @classmethod
  317. def dimension_range(cls, log_type, crawler, sheetid, major_dimension, startindex, endindex):
  318. """
  319. 删除行或列
  320. :param log_type: 日志路径
  321. :param crawler: 哪个爬虫
  322. :param sheetid:工作表
  323. :param major_dimension:默认 ROWS ,可选 ROWS、COLUMNS
  324. :param startindex:开始的位置
  325. :param endindex:结束的位置
  326. :return:
  327. """
  328. dimension_range_url = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/" \
  329. + cls.spreadsheettoken(crawler) + "/dimension_range"
  330. headers = {
  331. "Authorization": "Bearer " + cls.get_token(log_type),
  332. "Content-Type": "application/json; charset=utf-8"
  333. }
  334. body = {
  335. "dimension": {
  336. "sheetId": sheetid,
  337. "majorDimension": major_dimension,
  338. "startIndex": startindex,
  339. "endIndex": endindex
  340. }
  341. }
  342. try:
  343. urllib3.disable_warnings()
  344. r = requests.delete(url=dimension_range_url, headers=headers, json=body, proxies=proxies, verify=False)
  345. Common.logger(log_type).info("删除视频数据:{}", r.json()["msg"])
  346. except Exception as e:
  347. Common.logger(log_type).error(f"删除视频数据异常:{e}\n")
  348. # 获取用户 ID
  349. @classmethod
  350. def get_userid(cls, log_type, username):
  351. try:
  352. url = "https://open.feishu.cn/open-apis/user/v1/batch_get_id?"
  353. headers = {
  354. "Authorization": "Bearer " + cls.get_token(log_type),
  355. "Content-Type": "application/json; charset=utf-8"
  356. }
  357. # 手机号
  358. wangkun = "13426262515"
  359. gaonannan = "18501180073"
  360. xinxin = "15546206651"
  361. huxinxue = "18832292015"
  362. wuchaoyue = "15712941385"
  363. lijinchao = '18524120540'
  364. lierqiang = '13260325783'
  365. if username == "wangkun":
  366. username = wangkun
  367. elif username == "gaonannan":
  368. username = gaonannan
  369. elif username == "xinxin":
  370. username = xinxin
  371. elif username == "huxinxue":
  372. username = huxinxue
  373. elif username == "wuchaoyue":
  374. username = wuchaoyue
  375. elif username == "lijinchao":
  376. username = lijinchao
  377. elif username == "lierqiang":
  378. username = lierqiang
  379. data = {"mobiles": [username]}
  380. urllib3.disable_warnings()
  381. r = requests.get(url=url, headers=headers, params=data, verify=False, proxies=proxies)
  382. open_id = r.json()["data"]["mobile_users"][username][0]["open_id"]
  383. Common.logger(log_type).info(f"{username}:{open_id}")
  384. # print(f"{username}:{open_id}")
  385. return open_id
  386. except Exception as e:
  387. Common.logger(log_type).error(f"get_userid异常:{e}\n")
  388. # 飞书机器人
  389. @classmethod
  390. def bot(cls, log_type, crawler, text):
  391. try:
  392. url = "https://open.feishu.cn/open-apis/bot/v2/hook/96989577-50e7-4653-9ec2-308fe3f2c5fe"
  393. headers = {
  394. 'Content-Type': 'application/json'
  395. }
  396. if crawler == "kanyikan":
  397. content = "看一看爬虫表"
  398. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcngRPoDYAi24x52j2nDuHMih"
  399. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  400. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  401. elif crawler == "xiaoniangao_hour":
  402. content = "小年糕_小时级_已下载表"
  403. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnYxiyQ1wLklo1W5Kdqc9cGh?sheet=yatRv2"
  404. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  405. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  406. elif crawler == "xiaoniangao_person":
  407. content = "小年糕_用户主页_已下载表"
  408. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnYxiyQ1wLklo1W5Kdqc9cGh?sheet=Wu0CeL"
  409. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  410. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  411. elif crawler == "xiaoniangao_play":
  412. content = "小年糕_播放量_已下载表"
  413. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnYxiyQ1wLklo1W5Kdqc9cGh?sheet=c85k1C"
  414. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  415. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  416. elif crawler == 'xigua_video':
  417. content = '西瓜视频_用户主页_已下载表'
  418. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnvOpx2P8vBXiV91Ot1MKIw8?sheet=e075e9'
  419. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  420. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  421. elif crawler == 'xigua_little_video':
  422. content = '西瓜视频_小视频_已下载表'
  423. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnvOpx2P8vBXiV91Ot1MKIw8?sheet=hDSDnv'
  424. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  425. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  426. elif crawler == 'zhihu_hot':
  427. content = '知乎_热门_已下载表'
  428. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnkGPBmGsjaqapgzouuj8MXe?sheet=8871e3'
  429. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  430. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  431. elif crawler == 'zhihu_follow':
  432. content = '知乎_定向_已下载表'
  433. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnkGPBmGsjaqapgzouuj8MXe?sheet=4MGuux'
  434. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  435. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  436. elif crawler == 'haokan_hot':
  437. content = '好看_热榜_已下载表'
  438. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnaYz8Nhv8q6DbWtlL6rMEBd?sheet=5pWipX'
  439. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  440. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  441. elif crawler == 'haokan_channel':
  442. content = '好看_频道_已下载表'
  443. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnaYz8Nhv8q6DbWtlL6rMEBd?sheet=7f05d8'
  444. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  445. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  446. elif crawler == 'haokan_follow':
  447. content = '好看_定向_已下载表'
  448. sheet_url = 'https://w42nne6hzg.feishu.cn/sheets/shtcnaYz8Nhv8q6DbWtlL6rMEBd?sheet=kVaSjf'
  449. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  450. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  451. elif crawler == "music_album":
  452. content = "音乐相册爬虫表"
  453. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnT6zvmfsYe1g0iv4pt7855g"
  454. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  455. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  456. elif crawler == "ssyy":
  457. content = "胜胜影音爬虫表"
  458. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnz1ymxHL1u8WHblfqfys7qe"
  459. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  460. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  461. elif crawler == "ggdc":
  462. content = "刚刚都传爬虫表"
  463. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnTuJgeZU2bc7VaesAqk3QJx"
  464. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  465. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  466. elif crawler == "bszf":
  467. content = "本山祝福爬虫表"
  468. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnGh2rrsPYM4iVNEBO7OqWrb"
  469. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  470. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  471. elif crawler == "jxxf":
  472. content = "吉祥幸福爬虫表"
  473. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnSx4nafMbLTq7xl7RHBwHBf"
  474. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  475. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  476. elif crawler == "zmyx":
  477. content = "众妙音信爬虫表"
  478. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnbZIxstPeM0xshW07b26sve"
  479. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  480. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  481. elif crawler == "zhufumao":
  482. content = "祝福猫视频爬虫表"
  483. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnXfIJthvkjhI5zlEJq84i6g"
  484. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  485. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  486. elif crawler == "kuaishou_follow":
  487. content = "快手_用户主页_已下载表"
  488. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnICEfaw9llDNQkKgdymM1xf?sheet=fYdA8F"
  489. users = "\n<at id=" + str(cls.get_userid(log_type, "lierqiang")) + "></at> <at id=" + str(
  490. cls.get_userid(log_type, "xinxin")) + "></at>\n"
  491. elif crawler == "kuaishou_recommend":
  492. content = "快手_推荐榜_已下载表"
  493. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnICEfaw9llDNQkKgdymM1xf?sheet=3cd128"
  494. users = "\n<at id=" + str(cls.get_userid(log_type, "lierqiang")) + "></at> <at id=" + str(
  495. cls.get_userid(log_type, "xinxin")) + "></at>\n"
  496. elif crawler == "ssnnyfq":
  497. content = "岁岁年年迎福气_已下载表"
  498. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnyJmJSJynHDLLbLTkySfvZe?sheet=290bae"
  499. users = f'\n<at id={str(cls.get_userid(log_type, "wangkun"))}></at> \n<at id={str(cls.get_userid(log_type, "lierqiang"))}></at> <at id={str(cls.get_userid(log_type, "xinxin"))}></at>\n'
  500. elif crawler == "kdjsfq":
  501. content = "看到就是福气_已下载表"
  502. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnEokBkIjOUPAk8vbbPKnXgb?sheet=ad3b6d"
  503. users = f'\n<at id={str(cls.get_userid(log_type, "wangkun"))}></at> \n<at id={str(cls.get_userid(log_type, "lierqiang"))}></at> <at id={str(cls.get_userid(log_type, "xinxin"))}></at>\n'
  504. elif crawler == "gzh":
  505. content = "公众号爬虫表"
  506. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnexNXnpDLHhARw0QdiwbYuA"
  507. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  508. cls.get_userid(log_type, "lierqiang")) + "></at>\n"
  509. elif crawler == "gongzhonghao_xinxin":
  510. content = "公众号_信欣_爬虫表"
  511. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcna98M2mX7TbivTj9Sb7WKBN?"
  512. users = f'\n<at id={str(cls.get_userid(log_type, "wangkun"))}></at> \n<at id={str(cls.get_userid(log_type, "lierqiang"))}></at> <at id={str(cls.get_userid(log_type, "xinxin"))}></at>\n'
  513. elif crawler == "weiqun":
  514. content = "微群爬虫表"
  515. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnoKThNquYRweaylMFVyo9Hc"
  516. users = f'\n<at id={str(cls.get_userid(log_type, "wangkun"))}></at> \n<at id={str(cls.get_userid(log_type, "lierqiang"))}></at> <at id={str(cls.get_userid(log_type, "xinxin"))}></at>\n'
  517. elif crawler == "weishi":
  518. content = "微视爬虫表"
  519. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcn5YSWg91JfVGzj0SFZIRRPh"
  520. users = f'\n<at id={str(cls.get_userid(log_type, "wangkun"))}></at> \n<at id={str(cls.get_userid(log_type, "lierqiang"))}></at> <at id={str(cls.get_userid(log_type, "xinxin"))}></at>\n'
  521. elif crawler == "shipinhao_recommend":
  522. content = "视频号_推荐_已下载表"
  523. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcn9rOdZRAGFbRkWpn7hqEHGc?sheet=c77cf9"
  524. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  525. cls.get_userid(log_type, "wuchaoyue")) + "></at>\n"
  526. elif crawler == "shipinhao_follow":
  527. content = "视频号_定向_已下载表"
  528. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcn9rOdZRAGFbRkWpn7hqEHGc?sheet=KsVtLe"
  529. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  530. cls.get_userid(log_type, "wuchaoyue")) + "></at>\n"
  531. elif crawler == "youtube":
  532. content = "youtube_定向_已下载表"
  533. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnrLyr1zbYbhhZyqpN7Xrd5f?sheet=GVxlYk"
  534. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  535. cls.get_userid(log_type, "wuchaoyue")) + "></at>\n"
  536. elif crawler == "zongjiao":
  537. content = "宗教公众号爬虫表"
  538. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcn73NW0CyoOeF21HWO15KBsb"
  539. users = "\n<at id=" + str(cls.get_userid(log_type, "wangkun")) + "></at> <at id=" + str(
  540. cls.get_userid(log_type, "huxinxue")) + "></at>\n"
  541. else:
  542. content = "小年糕爬虫表"
  543. sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcnYxiyQ1wLklo1W5Kdqc9cGh"
  544. users = f'\n<at id={str(cls.get_userid(log_type, "wangkun"))}></at> \n<at id={str(cls.get_userid(log_type, "lierqiang"))}></at>\n'
  545. data = json.dumps({
  546. "msg_type": "interactive",
  547. "card": {
  548. "config": {
  549. "wide_screen_mode": True,
  550. "enable_forward": True
  551. },
  552. "elements": [{
  553. "tag": "div",
  554. "text": {
  555. "content": users + text,
  556. "tag": "lark_md"
  557. }
  558. }, {
  559. "actions": [{
  560. "tag": "button",
  561. "text": {
  562. "content": content,
  563. "tag": "lark_md"
  564. },
  565. "url": sheet_url,
  566. "type": "default",
  567. "value": {}
  568. }],
  569. "tag": "action"
  570. }],
  571. "header": {
  572. "title": {
  573. "content": "📣您有新的报警,请注意查收",
  574. "tag": "plain_text"
  575. }
  576. }
  577. }
  578. })
  579. urllib3.disable_warnings()
  580. r = requests.post(url, headers=headers, data=data, verify=False, proxies=proxies)
  581. Common.logger(log_type).info(f'触发机器人消息:{r}, {r.json()["StatusMessage"]}')
  582. except Exception as e:
  583. Common.logger(log_type).error(f"bot异常:{e}\n")
  584. if __name__ == "__main__":
  585. Feishu.bot("bot", "ssnnyfq", "别紧张,还是我,测试一下")
  586. # print(Feishu.get_userid("shipinhao", "lijinchao"))
  587. pass