| 123456789101112131415161718192021222324252627282930 |
- def getsales(self, message):
- #print len(self.sales)
- event1 = json.loads(message.value)
- prod_id = event1['product_id'].encode('ascii', 'ignore')
- units= event1['unit_sold'].encode('ascii', 'ignore')
- sales_rep = event1['sales_rep_id'].encode('ascii', 'ignore')
- tstamp = event1['timestamp'].encode('ascii','ignore')
- territory = self.reps[sales_rep]['TerritoryId']
- gallons = float(self.prods[prod_id]['Gallons'])*float(units)
- self.sales[territory]['Tstamp'] = tstamp
- actual = self.sales[territory]['Act'] + gallons
- self.sales[territory]['Act'] = actual
- ave = (self.sales[territory]['Ave'] + gallons)/2
- self.sales[territory]['Ave'] = ave
-
- plan = float(self.sales[territory]['Plan'])
-
- if actual > plan:
- self.sales[territory]['Stat'] = 1
- elif actual == plan:
- self.sales[territory]['Stat'] = 0
- elif actual < plan:
- self.sales[territory]['Stat'] = -1
-
-
|
