From 6bc9521b545058d0f296b2ec2dd5aaa972ac99c4 Mon Sep 17 00:00:00 2001 From: Jakub Zacek Date: Thu, 9 Dec 2021 15:12:28 +0100 Subject: [PATCH] working_final_latest --- vdgdsp.py | 181 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 181 insertions(+) create mode 100644 vdgdsp.py diff --git a/vdgdsp.py b/vdgdsp.py new file mode 100644 index 0000000..2074553 --- /dev/null +++ b/vdgdsp.py @@ -0,0 +1,181 @@ +# coding: utf8 + +import time +import csv +from datetime import datetime +import sys +from pprint import pprint + +FILE = 'VFGDSP202110_Summarised_data_usage_per_ICCID.CSV' +FILE2 = 'Standard_Pairing_File___2021-11-15T93331674Z.CSV' +FILE3 = 'VFGDSP202110_Summarised_SMS_usage_per_IMSI.CSV' + +#usrmonth = input("Month to be processed: ") +#usrmonth = int(usrmonth) +usrmonth = int(5) + +dictionary = {} + + +def add_dict(ICCID, IMSI): + + dict = dictionary.get(ICCID) + print("Dict: ",dict) + print("Got IMSI: ", IMSI,"to add to dict: ",ICCID) + + print("OK") + dict[ICCID] += IMSI + +def add_dict2(ICCID, IMSI): + dict = dictionary.get(ICCID) + print("Dict: ",dict) + print("Got IMSI: ", IMSI,"to add to dict: ",ICCID) + + print("OK") + dict['IMSI'] = IMSI + print('updated', dict) + +def add_dictsms(id, key, value): + dict = dictionary.get(id) + value_ = float(value) + if key in dict: + dict[key] == value_ + else: + print("Never should happen", id) + +def add_dictsmsprice(ICCID3, pricesms): + dict2 = dictionary.get(ICCID3) + print("section 3, add to sms") + print(dict2) + print("increasing sms dict key for dict: ",dict2 , " for :", pricesms) + dict["x"] == pricesms + + +# MAIN + +print("Start") +with open(FILE, newline='', encoding="utf-8") as csvfile: + reader = csv.DictReader(csvfile, delimiter=',') + for row in reader: + + # print(row) + #if row['Telefonní číslo'] == '': + #continue # skip empty MSISDN + + #if row['Začátek fakturačního období'] == '': + #continue + + #my_string = row['Začátek fakturačního období'] + # my_string = '2021-09-06' + #print("start date: ", my_string) + + #try: + #my_date = datetime.strptime(my_string, "%d.%m.%Y") + #except: + #print("An exception occurred, current my_string is: ", my_string) + #sys.exit(1) + + # print(row['BILLED_PERIOD_START']) + # print(my_date.month) + + #if usrmonth != my_date.month: + #print("skipping bad date") + #continue # skip bad dates + + #MSISDN = int(row['Telefonní číslo']) + print(row['ICCID']) + ICCID = int(row['ICCID']) + price = row['Sum Total Kbytes'].replace(',', '.') + price = price.replace(' ', '') + print(price) + price = (2.23*float(price))/1024 + + + # only if not exist create new record in dictionary for ID + if not ICCID in dictionary: + print("Creating dictionary: ", ICCID) + dictionary[ICCID] = {'IMSI': 0,'data': price, 'sms': 0.00000, 'other': 0.00000, 'smscount': 0} + +xxx = [] +print("Start section 2") +with open(FILE2, newline='', encoding="utf-8") as csvfile2: + reader2 = csv.DictReader(csvfile2, delimiter=',') + for row in reader2: + print(row['IMSI']) + IMSI = int(row['IMSI']) + ICCID2 = ICCID3 = int(row['ICCID']) + ICCID3 = int(ICCID2) + print("Je to jeste ok? ",ICCID3) + xxx.append(int(row['ICCID'])) + + if ICCID2 in dictionary: + print("Adding IMSI: ",IMSI ,"to dictionary: ", ICCID2) + add_dict2(ICCID2, IMSI) + + +# print("Start section 3") +# with open(FILE3, newline='', encoding="utf-8") as csvfile3: +# reader3 = csv.DictReader(csvfile3, delimiter=',') +# for row in reader3: +# print(xxx[1]) +# print("we got bad ICCIDfinal from section 2! :",xxx[5]) +# IMSI2 = int(row['IMSI']) +# print(row['Nr. of SMS payload']) +# print(row['Nr. of SMS MO']) +# smspay = int(row['Nr. of SMS payload']) +# smsmo = int(row['Nr. of SMS MO']) +# +# +# price = smspay * smsmo * 1.28 +# +# +# print("Dict: ", dict) +# for x in xxx: +# +# print("Adding SMSprice: ",price ,"to dictionary: ", x) +# +# add_dictsmsprice(x, price) + + + +# print("Start section 3") +# with open(FILE3, newline='', encoding="utf-8") as csvfile3: +# reader3 = csv.DictReader(csvfile3, delimiter=',') +# for row in reader3: +# print(row['ICCID']) + + + + + # try: + # print(dictionary[436761890319959]) #one with both types + # except: + # print("Required unit is not in our set") + # sys.exit(1) + +# print(len(dictionary.keys())) + +# for key, value in dictionary.items(): +# print(key, ' : ', value) + + +print("Count of units: ", len(dictionary.keys())) + +with open('export_vfgdsp202110v1.csv', 'w') as f: + for key in dictionary.keys(): + f.write("%s,%s\n" % (key, dictionary[key])) + +csv_columns = ['takhleuztoneudelam', 'IMSI','data', 'sms', 'other', 'smscount'] +try: + with open('export_vfgdsp_202110v1.csv', 'w') as csvfile: + w = csv.DictWriter(sys.stdout, csv_columns) + for key, val in sorted(dictionary.items()): + row = {'takhleuztoneudelam': key} + row.update(val) + + writer = csv.DictWriter(csvfile, fieldnames=csv_columns) + writer.writerow(row) + +except IOError: + print(f"I/O error: {IOError}") +