Bläddra i källkod

getting values to appear in html

bobhk 9 år sedan
förälder
incheckning
3c2f3335e6
6 ändrade filer med 46 tillägg och 33 borttagningar
  1. 15 9
      src/rethink/portfolio_item.py
  2. 2 1
      src/rethink/table_model.py
  3. 2 2
      src/sh/ae.sh
  4. 1 1
      src/sh/pm.sh
  5. 1 3
      src/ws/client_g.html
  6. 25 17
      src/ws/ws_server.py

+ 15 - 9
src/rethink/portfolio_item.py

@@ -243,7 +243,7 @@ class Portfolio(AbstractTableModel):
         '''
             update the gtable contract_key to row number index
         '''
-        self.update_ckey_row_xref(contract_key)
+        self.update_ckey_row_xref(contract_key, port_item)
         
                 
     def is_oc_in_portfolio(self, oc_id):
@@ -290,7 +290,10 @@ class Portfolio(AbstractTableModel):
                   ('pos_delta', 'P. Delta', 'number'), ('pos_theta', 'P. Theta', 'number'), ('pos_gamma', 'P. Gamma', 'number'), 
                   ('unreal_pl', 'Unreal P/L', 'number'), ('percent_gain_loss', '% gain/loss', 'number')  
                   ]  
-    def update_ckey_row_xref(self, contract_key):
+    def update_ckey_row_xref(self, contract_key, port_item):
+        
+#         if port_item.get_symbol_id() in PortfolioRules.rule_map['interested_position_types']['symbol'] and \
+#            port_item.get_instrument_type() in  PortfolioRules.rule_map['interested_position_types']['instrument_type']:
         row_id = self.port['g_table']['row_index']
         self.port['g_table']['ckey_to_row_index'][contract_key] = row_id
         self.port['g_table']['row_to_ckey_index'][row_id] = contract_key
@@ -304,10 +307,12 @@ class Portfolio(AbstractTableModel):
     
     def get_row_count(self):
         p_items = [x for x in self.port['port_items'].iteritems()]
-        p1_items = filter(lambda x: x[1].get_symbol_id() in PortfolioRules.rule_map['interested_position_types']['symbol'], p_items)
-        p2_items = filter(lambda x: x[1].get_instrument_type() in  PortfolioRules.rule_map['interested_position_types']['instrument_type'], p1_items)
-        return len(p2_items)
-
+#         p1_items = filter(lambda x: x[1].get_symbol_id() in PortfolioRules.rule_map['interested_position_types']['symbol'], p_items)
+#         p2_items = filter(lambda x: x[1].get_instrument_type() in  PortfolioRules.rule_map['interested_position_types']['instrument_type'], p1_items)
+#         return len(p2_items)
+        return len(p_items)
+    
+    
     def get_column_name(self, col):
         return self.port['g_table']['header'][col][1]
 
@@ -375,9 +380,10 @@ class Portfolio(AbstractTableModel):
         map(lambda hf: dtj['cols'].append({'id': hf[0], 'label': hf[1], 'type': hf[2]}), self.port['g_table']['header'])
         
         p_items = sorted([x for x in self.port['port_items'].iteritems()])
-        p1_items = filter(lambda x: x[1].get_symbol_id() in PortfolioRules.rule_map['interested_position_types']['symbol'], p_items)
-        p2_items = filter(lambda x: x[1].get_instrument_type() in  PortfolioRules.rule_map['interested_position_types']['instrument_type'], p1_items)
-        map(lambda p: dtj['rows'].append({'c': self.port_item_to_row_fields(p)}), p2_items)
+        #p1_items = filter(lambda x: x[1].get_symbol_id() in PortfolioRules.rule_map['interested_position_types']['symbol'], p_items)
+        #p2_items = filter(lambda x: x[1].get_instrument_type() in  PortfolioRules.rule_map['interested_position_types']['instrument_type'], p1_items)
+        #map(lambda p: dtj['rows'].append({'c': self.port_item_to_row_fields(p)}), p2_items)
+        map(lambda p: dtj['rows'].append({'c': self.port_item_to_row_fields(p)}), p_items)
         
         
         return json.dumps(dtj) #, indent=4)            

+ 2 - 1
src/rethink/table_model.py

@@ -10,7 +10,8 @@ class AbstractTableModel(Publisher):
     EVENT_TM_TABLE_ROW_INSERTED = 'event_tm_table_row_inserted'
     EVENT_TM_TABLE_ROW_UPDATED = 'event_tm_table_row_updated'
     EVENT_TM_TABLE_STRUCTURE_CHANGED = 'event_tm_table_structure_changed'
-    TM_EVENTS = [EVENT_TM_TABLE_CELL_UPDATED, EVENT_TM_TABLE_ROW_INSERTED, EVENT_TM_TABLE_ROW_UPDATED]
+    TM_EVENTS = [EVENT_TM_TABLE_CELL_UPDATED, EVENT_TM_TABLE_ROW_INSERTED, EVENT_TM_TABLE_ROW_UPDATED, 
+                 EVENT_TM_TABLE_STRUCTURE_CHANGED]
     
     EVENT_TM_REQUEST_TABLE_STRUCTURE = "event_tm_request_table_structure"
     TM_REQUESTS = [EVENT_TM_REQUEST_TABLE_STRUCTURE]

+ 2 - 2
src/sh/ae.sh

@@ -11,5 +11,5 @@ else
 	FINOPT_HOME=~/l1304/workspace/finopt-ironfly/finopt/src
 fi
 export PYTHONPATH=$FINOPT_HOME:$PYTHONPATH
-#python $FINOPT_HOME/rethink/analytics_engine.py  -c -g AE1  
-python $FINOPT_HOME/rethink/analytics_engine.py   -g AE1  
+python $FINOPT_HOME/rethink/analytics_engine.py  -c -g AE1  
+#python $FINOPT_HOME/rethink/analytics_engine.py   -g AE1  

+ 1 - 1
src/sh/pm.sh

@@ -12,4 +12,4 @@ else
 fi
 export PYTHONPATH=$FINOPT_HOME:$PYTHONPATH
 #python $FINOPT_HOME/rethink/portfolio_monitor.py  -c -g PM1  
-python $FINOPT_HOME/rethink/portfolio_monitor.py -g PM2 
+python $FINOPT_HOME/rethink/portfolio_monitor.py -g PM1

Filskillnaden har hållts tillbaka eftersom den är för stor
+ 1 - 3
src/ws/client_g.html


Filskillnaden har hållts tillbaka eftersom den är för stor
+ 25 - 17
src/ws/ws_server.py


Vissa filer visades inte eftersom för många filer har ändrats