Notes

# -- Work load distribution calculation
import time


def calculate_work_load_distribution(num_users, work_load_distribution, thread_data):
TaxCaddy_Consumer_Ratio = work_load_distribution["CPA_Consumer_Ratio"]["TaxCaddy_Consumer"]
TaxCaddy_CPA_Ratio = work_load_distribution["CPA_Consumer_Ratio"]["TaxCaddy_CPA"]
work_load_distribution_ratio = {"TaxCaddy_Consumer": {}, "TaxCaddy_CPA": {}}
for key, value in work_load_distribution["TaxCaddy_Consumer"].items():
work_load_distribution_ratio["TaxCaddy_Consumer"][key] = int(round((value / 100) * TaxCaddy_Consumer_Ratio, 0))
for key, value in work_load_distribution["TaxCaddy_CPA"].items():
work_load_distribution_ratio["TaxCaddy_CPA"][key] = int(round((value / 100) * TaxCaddy_CPA_Ratio, 0))

users_distribution = {"TaxCaddy_Consumer": {}, "TaxCaddy_CPA": {}}
total_Consumers = 0
for key, value in work_load_distribution_ratio["TaxCaddy_Consumer"].items():
users_distribution["TaxCaddy_Consumer"][key] = int(round((num_users / 100) * value, 0))
if users_distribution["TaxCaddy_Consumer"][key] < 1:
users_distribution["TaxCaddy_Consumer"][key] = 1
total_Consumers += users_distribution["TaxCaddy_Consumer"][key]
total_CPAs = 0
for key, value in work_load_distribution_ratio["TaxCaddy_CPA"].items():
users_distribution["TaxCaddy_CPA"][key] = int(round((num_users / 100) * value, 0))
if users_distribution["TaxCaddy_CPA"][key] < 1:
users_distribution["TaxCaddy_CPA"][key] = 1
total_CPAs += users_distribution["TaxCaddy_CPA"][key]

print("* TOTAL USERS LOAD : ", num_users)

# expected_total_Consumers = int(round((num_users / 100) * TaxCaddy_Consumer_Ratio, 0))
# expected_total_CPAs = int(round((num_users / 100) * TaxCaddy_CPA_Ratio, 0))
if total_Consumers + total_CPAs > num_users:
diff = (total_Consumers + total_CPAs) - num_users
maxKeyConsumer = max(users_distribution["TaxCaddy_Consumer"], key=users_distribution["TaxCaddy_Consumer"].get)
maxKeyCPA = max(users_distribution["TaxCaddy_CPA"], key=users_distribution["TaxCaddy_CPA"].get)
users_distribution["TaxCaddy_CPA"][maxKeyCPA] = users_distribution["TaxCaddy_CPA"][maxKeyCPA] - round(diff / 2)
users_distribution["TaxCaddy_Consumer"][maxKeyConsumer] = users_distribution["TaxCaddy_Consumer"][
maxKeyConsumer] - round(diff / 2) + (
1 if diff % 2 > 0 else 0)

print("* CONSUMERS LOAD (", TaxCaddy_Consumer_Ratio, "%) : ", sum(users_distribution["TaxCaddy_Consumer"].values()))
print("* CPA LOAD (", TaxCaddy_CPA_Ratio, "%) : ", sum(users_distribution["TaxCaddy_CPA"].values()))
print("* ------------------------------------------------- *")
time.sleep(2)
for key, value in users_distribution["TaxCaddy_Consumer"].items():
print("Consumer : ", key, " - > ", value, " Users")
print("* ------------------------------------------------- *")
time.sleep(2)
for key, value in users_distribution["TaxCaddy_CPA"].items():
print("CPA : ", key, " - > ", value, " Users")
print("* ------------------------------------------------- *")
time.sleep(2)
Thread_Users = {}
for x in range(1, thread_data["Total_Threads"] + 1):
Thread_Users[x] = 1 # min

Thread_Usecases_Ratio = thread_data["Thread_Usecases_Ratio"]
Thread_Usecases_Consumer = Thread_Usecases_Ratio["TaxCaddy_Consumer"]
Thread_Usecases_CPA = Thread_Usecases_Ratio["TaxCaddy_CPA"]

for key, value in Thread_Usecases_Consumer.items():
users_count = 0
if isinstance(value, list):
for scenario in value:
users_count += users_distribution["TaxCaddy_Consumer"][scenario]
else:
users_count += users_distribution["TaxCaddy_Consumer"][value]
thread_numbers = key.split(",")
thread_count = len(thread_numbers)
for thread_number in thread_numbers:
thread_number = int(thread_number)
Thread_Users[thread_number] = round(users_count / thread_count)

for key, value in Thread_Usecases_CPA.items():
users_count = 0
if isinstance(value, list):
for scenario in value:
users_count += users_distribution["TaxCaddy_CPA"][scenario]
else:
users_count += users_distribution["TaxCaddy_CPA"][value]
thread_numbers = key.split(",")
thread_count = len(thread_numbers)
for thread_number in thread_numbers:
thread_number = int(thread_number)
Thread_Users[thread_number] = round(users_count / thread_count)

print("* THREAD WSIE LOAD *")
print("* ------------------------------------------------- *")

# print(Thread_Users)
# test_total_thread_users = 0
for key, value in Thread_Users.items():
print("THREAD_" + str(key) + ": " + str(value))
time.sleep(0.5)
# test_total_thread_users += value
# print("* ------------------------------------------------- *")
# print(test_total_thread_users)
return Thread_Users



CPA_Consumer_Ratio:
TaxCaddy_Consumer: 60
TaxCaddy_CPA: 40
TaxCaddy_Consumer:
Account_Setup: 1.776160376
Document_Management: 76.08155915
Invoice_Management: 1.412732104
Messaging: 8.218911316
Questionnaire_Management: 3.039581913
Tax_Payments_Management: 3.15579001
Tax_Returns_Delivery: 6.315265131
TaxCaddy_CPA:
Questionnaire_Management: 1.970902352
Client_Management: 25.74476582
Document_Management: 67.77526559
Firm_Access_Info_Update: 0.238187164
Invoice_Management: 0.073915167
Messaging: 2.232799747
Tax_Payments_Management: 0.572300111
Tax_Returns_Delivery: 1.241032271
Template_Creation: 0.150831781