saveSimCardInfo

Adhidarma Hadiwinoto
1 parent 550625955e
Showing 1 changed file with 23 additions and 0 deletions Side-by-side Diff
main.py
@@ -564,6 +564,7 @@ def main():
     logger.info('MSISDN: {0} -- IMSI: {1}'.format(msisdn, imsi))
  
     updateChipInfo(msisdn)
+    saveSimCardInfoToRedis(imsi, msisdn)
  
     sleep(2)
  
@@ -598,5 +599,27 @@ def main():
     finally:
         modem.close();
  
+def saveSimCardInfoToRedis(imsi, msisdn):
+    data = {
+        'imsi': imsi,
+        'msisdn': msisdn
+    }
+    
+    map_data = {
+        BASE_CHIPINFO + '.simcardinfo': json.dumps(data)
+        'simcardinfo.gw:' + BASE_CHIPINFO: json.dumps(data)
+    }
+
+    try:
+        redis_pipe.mset(map_data)
+        
+        for k in data:
+            redis_pipe.expire(k, 3600 * 24 * 60)
+            
+    except:
+        logger.warning('Failed to save simcardinfo to redis')
+    finally:
+        redis_pipe.execute()        
+    
 if __name__ == '__main__':
     main()
...	...	@@ -564,6 +564,7 @@ def main():
564	564	logger.info('MSISDN: {0} -- IMSI: {1}'.format(msisdn, imsi))
565	565
566	566	updateChipInfo(msisdn)
	567	+ saveSimCardInfoToRedis(imsi, msisdn)
567	568
568	569	sleep(2)
569	570
...	...	@@ -598,5 +599,27 @@ def main():
598	599	finally:
599	600	modem.close();
600	601
	602	+def saveSimCardInfoToRedis(imsi, msisdn):
	603	+ data = {
	604	+ 'imsi': imsi,
	605	+ 'msisdn': msisdn
	606	+ }
	607	+
	608	+ map_data = {
	609	+ BASE_CHIPINFO + '.simcardinfo': json.dumps(data)
	610	+ 'simcardinfo.gw:' + BASE_CHIPINFO: json.dumps(data)
	611	+ }
	612	+
	613	+ try:
	614	+ redis_pipe.mset(map_data)
	615	+
	616	+ for k in data:
	617	+ redis_pipe.expire(k, 3600 * 24 * 60)
	618	+
	619	+ except:
	620	+ logger.warning('Failed to save simcardinfo to redis')
	621	+ finally:
	622	+ redis_pipe.execute()
	623	+
601	624	if __name__ == '__main__':
602	625	main()