mangroveorg/datawinners

View on GitHub
datawinners/custom_reports/crs/test_data.py

Summary

Maintainability
B
5 hrs
Test Coverage
from datetime import date
import random
import string
from dateutil.relativedelta import relativedelta
from datawinners.custom_reports.crs.models import ContainerSent, PackingList, BillOfLading, BreakBulkSent, WayBillReceivedPort, WayBillSent, WayBillReceived, Distribution, BAV, NumberOfRecipientServed, PhysicalInventorySheet, Warehouse, SiteActivities

def generate_id(id_length):
    return ''.join([random.choice(string.digits + string.letters) for i in range(id_length)])

class PackingListBuilder():
    def build(self):
        packing_list = PackingList()
        packing_list.q1 = 'PL' + generate_id(8)
        packing_list.q2 = 100
        packing_list.q3 = 100
        packing_list.q4 = 100
        packing_list.q5 = 100
        return packing_list

class BillOfLadingBuilder():
    def build(self, pl_code, issue_date, food_type, shipment_type):
        bill_of_lading = BillOfLading()
        bill_of_lading.q1 = pl_code
        bill_of_lading.q2 = shipment_type
        bill_of_lading.q3 = issue_date
        bill_of_lading.q4 = food_type
        bill_of_lading.q5 = 'BL' + generate_id(8)
        bill_of_lading.q6 = total_shipment
        bill_of_lading.q7 = total_shipment
        bill_of_lading.q8 = 'ccc'
        bill_of_lading.q9 = 100
        return bill_of_lading

class ContainerSentBuilder():
    def build(self, bl_code):
        container_sent = ContainerSent()
        container_sent.q1 = bl_code
        container_sent.q2 = container_capacity
        container_sent.q3 = generate_id(4)
        return container_sent

class BreakBulkSentBuilder():
    def build(self, sent_date, pl_code, food_type):
        break_bulk_sent = BreakBulkSent()
        break_bulk_sent.q1 = sent_date
        break_bulk_sent.q2 = break_bulk_capacity
        break_bulk_sent.q3 = 'BB' + generate_id(8)
        break_bulk_sent.q4 = pl_code
        break_bulk_sent.q5 = food_type
        return break_bulk_sent


class WayBillReceivedPortBuilder():
    def build(self, waybill_code, received_date, weight, container_code):
        way_bill_received_port = WayBillReceivedPort()
        way_bill_received_port.q1 = waybill_code
        way_bill_received_port.q2 = received_date
        way_bill_received_port.q3 = weight
        way_bill_received_port.q4 = 0
        way_bill_received_port.q5 = container_code
        way_bill_received_port.q6 = random.choice(Warehouse.objects.all()).q5
        return way_bill_received_port

class WayBillSentBuilder():
    def build(self,pl_code,sent_date,source_warehouse,food_type,waybill_code=None):
        way_bill_sent = WayBillSent()
        way_bill_sent.q1 = pl_code
        way_bill_sent.q2 =  waybill_code or "WB"+generate_id(5)
        way_bill_sent.q3 = sent_date
        way_bill_sent.q4 = 'Transfert aux magasins de CRS'
        way_bill_sent.q5 = source_warehouse
        way_bill_sent.q6 = "Sender"
        way_bill_sent.q7 = "TruckID"
        way_bill_sent.q8 = food_type
        way_bill_sent.q9 = container_capacity
        way_bill_sent.q10 = random.choice(Warehouse.objects.all()).q5
        return way_bill_sent

    def _trnx_type(self, food_type):
        csb_types = ['Livraisons pour SFM','Livraisons pour SFE']
        sorgho_type = 'Livraisons pour FFA'
        oil_types = ['Livraisons pour SFM','Livraisons pour SFE', sorgho_type]
        if food_type == 'SORGHO' :
            return sorgho_type
        if food_type == 'HUILE':
            return random.choice(oil_types)
        return random.choice(csb_types)

    def build_sent_to_site(self, pl_code, sent_date, source_warehouse, food_type,way_bill_code=None):
        way_bill = self.build(pl_code, sent_date, source_warehouse, food_type,waybill_code=way_bill_code)
        way_bill.q4 = self._trnx_type(food_type)
        way_bill.q10 = random.choice(SiteActivities.objects.all()).q7
        return way_bill

class WayBillReceivedBuilder():
     def build(self,site_code,pl_code,waybill_code,received_date):
        way_bill_received = WayBillReceived()
        way_bill_received.q1 = pl_code
        way_bill_received.q2 = waybill_code
        way_bill_received.q3 = site_code
        way_bill_received.q4 = "Receiver"
        way_bill_received.q5 = received_date
        way_bill_received.q6 = "TruckID"
        way_bill_received.q7 = container_capacity
        way_bill_received.q8 = 0
        way_bill_received.q9 = 'CRS received from stores'
        return way_bill_received


class DistributionBuilder():
    def build(self,site_code,dist_date,way_bill_code):
        distribution = Distribution()
        distribution.q1 = site_code
        distribution.q2 = dist_date
        distribution.q3 = way_bill_code
        distribution.q4 = 'WBret'+generate_id(5)
        distribution.q5 = container_capacity - container_capacity / 10
        distribution.q6 = container_capacity - container_capacity / 10
        distribution.q7 = container_capacity - container_capacity / 10
        distribution.q8 = container_capacity - container_capacity / 10
        distribution.distribution_type = SiteActivities.objects.get(q7=site_code).q6
        return distribution

class BAVBuilder():
    def build(self, year, program_type):
        bav = BAV()
        bav.q1 = program_type
        bav.q2 = date(year,12,31)
        bav.q3 = container_capacity
        bav.q4 = total_shipment
        bav.q5 = total_shipment
        bav.q6 = total_shipment
        bav.q7 = total_shipment
        return bav

class NumberOfRecipientServedBuilder():
    def build(self, received_date, program_type):
        recipient_served = NumberOfRecipientServed()
        recipient_served.q1 = program_type
        recipient_served.q2 = received_date
        recipient_served.q3 = 100
        recipient_served.q4 = 100
        recipient_served.q5 = 100
        recipient_served.q6 = 100
        return recipient_served

def one_hop(food_type, pl_code, shipping_date, way_bill_received_port):
    way_bill_sent = WayBillSentBuilder().build(pl_code, shipping_date, way_bill_received_port.q6, food_type)
    way_bill_sent.save()
    way_bill_received = WayBillReceivedBuilder().build(way_bill_sent.q10,pl_code, way_bill_sent.q2, shipping_date)
    way_bill_received.save()
    return way_bill_received


def distribute(food_type, pl_code, shipping_date, way_bill_received):
    distribution_shipping_date = shipping_date + relativedelta(days=+2)
    way_bill_sent_to_site = WayBillSentBuilder().build_sent_to_site(pl_code, distribution_shipping_date,
        way_bill_received.q3, food_type)
    way_bill_sent_to_site.save()
    way_bill_received_by_site = WayBillReceivedBuilder().build(way_bill_sent_to_site.q10, pl_code,
        way_bill_sent_to_site.q2, distribution_shipping_date)
    way_bill_received_by_site.save()
    distribution = DistributionBuilder().build(way_bill_received_by_site.q3, distribution_shipping_date,
        way_bill_received_by_site.q2)
    distribution.save()

    for program_type in program_types :
        NumberOfRecipientServedBuilder().build(distribution_shipping_date, program_type).save()

    return distribution, distribution_shipping_date


def return_remaining(distribution, distribution_shipping_date, food_type, pl_code, way_bill_received):
    way_bill_sent_return = WayBillSentBuilder().build(pl_code, distribution_shipping_date, way_bill_received.q3,
        food_type, waybill_code=distribution.q4)
    way_bill_sent_return.save()
    way_bill_received_back_from_site = WayBillReceivedBuilder().build(way_bill_sent_return.q10, pl_code,
        way_bill_sent_return.q2, distribution_shipping_date)
    way_bill_received_back_from_site.save()


def send_containers_to_warehouse(food_type, pl_code, shipping_date):
        bill_of_lading = BillOfLadingBuilder().build(pl_code, shipping_date, food_type, 'CONTAINER')
        bill_of_lading.save()
        for i in range(total_shipment / container_capacity):
            if not i % 100:
                print i
            container_sent = ContainerSentBuilder().build(bill_of_lading.q5)
            container_sent.save()
            way_bill_received_port = WayBillReceivedPortBuilder().build('', shipping_date, container_sent.q2, container_sent.q3)
            way_bill_received_port.save()

            way_bill_received = one_hop(food_type, pl_code, shipping_date, way_bill_received_port)

            distribution, distribution_shipping_date = distribute(food_type, pl_code, shipping_date, way_bill_received)

            return_remaining(distribution, distribution_shipping_date, food_type, pl_code, way_bill_received)

def send_break_bulk_to_warehouse(food_type, pl_code, shipping_date):
        bill_of_lading = BillOfLadingBuilder().build(pl_code, shipping_date, food_type, 'BREAK BULK')
        bill_of_lading.save()
        for i in range(total_shipment / break_bulk_capacity):
            if not i % 100:
                print i
            break_bulk_sent = BreakBulkSentBuilder().build(shipping_date, pl_code, food_type)
            break_bulk_sent.save()
            way_bill_received = WayBillReceivedPortBuilder().build(break_bulk_sent.q3, shipping_date, break_bulk_sent.q2, '')
            way_bill_received.save()

            distribution, distribution_shipping_date = distribute(food_type, pl_code, shipping_date, way_bill_received)

            return_remaining(distribution, distribution_shipping_date, food_type, pl_code, way_bill_received)


def tear_down():
    print 'deleting ...'
    models = [ContainerSent, PackingList, BillOfLading, BreakBulkSent, WayBillReceivedPort, WayBillSent, WayBillReceived, Distribution, BAV, NumberOfRecipientServed, PhysicalInventorySheet, Warehouse, SiteActivities]
    [model.objects.all().delete() for model in models]
    print 'delete done'


def container_shipment(commodities, base_date):
    shipping_date = base_date
    packing_list = PackingListBuilder().build()
    packing_list.save()
    pl_code = packing_list.q1
    for food_type in commodities:
        send_containers_to_warehouse(food_type, pl_code, shipping_date)


def break_bulk_shipment(commodities, base_date):
    shipping_date = base_date + relativedelta(months=+1)
    packing_list = PackingListBuilder().build()
    packing_list.save()
    pl_code = packing_list.q1
    for food_type in commodities:
        send_break_bulk_to_warehouse(food_type, pl_code, shipping_date)

container_capacity = 1000
break_bulk_capacity = 1000
total_shipment = 100000

def set_for_year(year, commodities):
    base_date = date(year, 1, 1)

    shipments = [base_date, base_date + relativedelta(months=3), base_date + relativedelta(months=6),
                 base_date + relativedelta(months=9)]
    for shipment_date in shipments:
        print "----     ----    ----\n"
        container_shipment(commodities, shipment_date)
        break_bulk_shipment(commodities, shipment_date)


def bav_data(program_types, year):
    for program_type in program_types:
        BAVBuilder().build(year, program_type).save()


program_types = ['SFM','SFE','FFA','CPS']

class PhysicalInventorySheetBuilder():
    def build(self, store_house_code, year, month, food, pl_code):
        sheet = PhysicalInventorySheet()
        sheet.q1 = store_house_code
        sheet.q2 = date(year,month,1)
        sheet.q3 = date(year,month,1)
        sheet.q4 = pl_code
        sheet.q5 = food
        sheet.q6 = 5000
        sheet.q7 = 2000
        return sheet

def create_stores():
    for i in range(100):
        warehouse = Warehouse()
        warehouse.q1 = 'name'
        warehouse.q2 = 'address'
        warehouse.q3 = 'gps'
        warehouse.q4 = 'tel_no'
        warehouse.q5 = 'WH'+generate_id(4)
        warehouse.save()

def create_sites():
    for i in range(100):
        site = SiteActivities()
        site.q1 = 'fiscal_year_with_initials'
        site.q2 = 'site_location'
        site.q3 = 'site_gps_coordinates'
        site.q4 = 'tel_no'
        site.q5 = 'site_person_responsible'
        site.q6 = random.choice(program_types)
        site.q7 = 'S'+generate_id(4)
        site.save()


def physical_inventory(year, commodities):
    for warehouse in Warehouse.objects.all():
        for food in commodities:
            for pl in PackingList.objects.all():
                PhysicalInventorySheetBuilder().build(warehouse.q5, year, 6, food, pl.q1).save()
                PhysicalInventorySheetBuilder().build(warehouse.q5, year, 12, food, pl.q1).save()


def create_one_set():
    tear_down()
    create_stores()
    create_sites()
    commodities = ['RIZ', 'HUILE', 'CSB', 'SORGHO']
    years=[2001]
    for year in years :
        set_for_year(year, commodities)
        bav_data(program_types, year)

    for year in years :
        physical_inventory(year, commodities)