parse_income.py 2.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394
  1. # -*- coding: utf-8 -*-
  2. # !/usr/bin/env python
  3. execl_file = [
  4. '113348986_202106_1.csv',
  5. '113348986_202106_02.csv',
  6. '113348986_202106_03.csv',
  7. '113348986_202106_04.csv',
  8. '113348986_202106_05.csv',
  9. '113348986_202106_06.csv'
  10. ]
  11. # total_count = 0
  12. # for i in execl_file:
  13. # pay_count = 0
  14. # if i < 10:
  15. # day = '0{}'.format(i)
  16. # else:
  17. # day = str(i)
  18. # 列求和
  19. # print ttt.iloc[:,1:2].sum()
  20. # for i in ttt.index.values:
  21. # gateway = ttt.ix[i, 1]
  22. # if 'wechat-6417d4456f29257125ebf705-wxea00d7496605a3be-1480791292-agent' in gateway:
  23. # lines.append(ttt.ix[i, 0])
  24. # s_bool = ttt[u'商户订单号'] == u'支付'
  25. # total_count += s_bool.sum()
  26. #
  27. # total = 0
  28. # from os import path
  29. #
  30. # if path.exists(u'f:\\refund_withdraw.csv'):
  31. # ttt = pd.read_csv(u'f:\\refund_withdraw.csv')
  32. # groups = ttt.groupby('ownerId')
  33. # for name, group in groups:
  34. # print name, len(group)
  35. # result = {}
  36. #
  37. # ttt = pd.read_csv(u'E:\\code\\washpayer\\script\\transaction\\DealerIncomeProxy_his_5a561e9a8732d64c8181e406.csv')
  38. # for i in ttt.index.values:
  39. # _time = ttt.ix[i, 9][0:10]
  40. # if _time in result:
  41. # result[_time] += float(ttt.ix[i,4])
  42. # else:
  43. # result[_time] = float(ttt.ix[i,4])
  44. #
  45. # for _time, _value in result.iteritems():
  46. # print '{},{}'.format(_time, _value)
  47. import pandas as pd
  48. import simplejson as json
  49. import os
  50. total = 0
  51. split = {}
  52. file_type_list = ['csv']
  53. def get_file_list(folder):
  54. filelist = [] #存储要copy的文件全名
  55. for dirpath,dirnames,filenames in os.walk(folder):
  56. for file in filenames:
  57. file_type = file.split('.')[-1]
  58. if(file_type in file_type_list):
  59. file_fullname = os.path.join(dirpath, file) #文件全名
  60. filelist.append(file_fullname)
  61. return filelist
  62. filelist = get_file_list(u'E:\\微弗智通\\年底对账\\京东\\12')
  63. # for i in ttt.index.values:
  64. # gateway = ttt.ix[i, 1]
  65. # if 'wechat-6417d4456f29257125ebf705-wxea00d7496605a3be-1480791292-agent' in gateway:
  66. # lines.append(ttt.ix[i, 0])
  67. total = 0
  68. for file in filelist:
  69. print file
  70. ttt = pd.read_csv(file)
  71. for i in ttt.index.values:
  72. order_no = str(ttt.ix[i, 6]).replace('="','').replace('""','')
  73. money = float(ttt.ix[i, 14])
  74. if order_no[14:16] == 'PS' or order_no.startswith('WF4801') or order_no.startswith('PS'):
  75. print '{} = {}'.format(order_no, money)
  76. total += money