find_need_charged_card_by_imsi.py 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. # -*- coding: utf-8 -*-
  2. #!/usr/bin/env python
  3. import os, sys
  4. import threading
  5. import uuid
  6. import xlrd
  7. from xlrd import xldate_as_tuple
  8. import simplejson as json
  9. import datetime
  10. from django.conf import settings
  11. PROJECT_ROOT = os.path.join(os.path.abspath(os.path.split(os.path.realpath(__file__))[0] + "/.."), '..')
  12. sys.path.insert(0, PROJECT_ROOT)
  13. os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'configs.production')
  14. from script.base import init_env
  15. init_env(interactive = False)
  16. from apps.web.device.models import SIMCard,Device
  17. from apps.web.constant import Const
  18. from apilib.utils_datetime import to_datetime
  19. from apps.web.user.models import RechargeRecord
  20. # 只把那种没有iccid的,但是又充值了的设备,单独找出来
  21. supplier = sys.argv[1]
  22. excelFile = sys.argv[2]
  23. if supplier not in ['qiben','hezhou','jieyang','tianyu']:
  24. print u'卡供应商必须是qiben、hezhou'
  25. exit(0)
  26. book = xlrd.open_workbook(excelFile)
  27. try:
  28. sheet = book.sheet_by_name("sheet1")
  29. except Exception,e:
  30. print 'open excel file error =%s' % e
  31. exit(0)
  32. nrows = sheet.nrows
  33. rows = []
  34. iccids = []
  35. dxIccids = [] # 电信的iccid,不一样哟。设备报上来的比excel的多一位
  36. imsiDict = {}
  37. for i in range(1, nrows):
  38. row = sheet.row_values(i)
  39. try:
  40. iccids.append(row[1].replace('\t','').upper())
  41. iccids.append(row[1].replace('\t','').lower())
  42. tempStr = row[3].replace('\t','')
  43. if tempStr:
  44. imsiDict[tempStr] = row[1].replace('\t','')
  45. if row[7] == u'电信':
  46. dxIccids.append(row[1].replace('\t','').upper())
  47. dxIccids.append(row[1].replace('\t','').lower())
  48. except Exception,e:
  49. print 'some error when update iccid=%s,e=%s' % (row[1],e)
  50. devIccids = []
  51. devList= []
  52. count = 0
  53. devObjs = Device.objects.filter(iccid__in = iccids,ownerId__ne = None)
  54. for devObj in devObjs:
  55. if devObj.simStatus == 'updated':
  56. continue
  57. print str(devObj.iccid).upper()
  58. count = count + 1
  59. # 单独处理电信的数据
  60. dxIccids = list(set(dxIccids))
  61. for iccid in dxIccids:
  62. devObj = Device.objects(iccid__in = iccid).first()
  63. if devObj is None:
  64. continue
  65. if devObj.simStatus == 'updated':
  66. continue
  67. print iccid
  68. count = count + 1
  69. print "-----------------------------------------------------------------"
  70. devObjs = Device.objects.filter(imsi__in = imsiDict.keys(),ownerId__ne = None)
  71. for devObj in devObjs:
  72. if devObj.simStatus == 'updated':
  73. continue
  74. if devObj.iccid : # 如果有iccid,前面就会打印过,这里没有必要再打印
  75. continue
  76. print imsiDict[devObj.imsi]
  77. count = count + 1
  78. print 'finished. %s' % count