update last_state_values: average

src/libs/routes/cub.js

@@ -134,24 +134,39 @@ rqf.addField({
 
 cubApp.get('/last_state_values', rqf.parse(), rqf.build(), (req, res, next) => {
 
-    var table_b = squel.select().from('cub')
+    var sub_table = squel.select().from('cub')
     .field('estado_id')
     .field('MAX(ano_censo*100 + mes_censo)', 'ano_censo')
     .group('estado_id')
 
-    req.sql.from('cub', 'a')
-    .field('a.ano_censo', 'ano')
-    .field('a.mes_censo', 'mes')
-    .field('a.estado_id', 'cod_uf')
+    var states = squel.select().from('cub')
+    .field('cub.ano_censo', 'ano')
+    .field('cub.mes_censo', 'mes')
+    .field('cub.estado_id', 'cod_uf')
     .field('estado.sigla', 'sigla_uf')
-    .field('a.tipo_preco', 'tipo_preco')
-    .field('a.preco', 'preco')
+    .field('cub.tipo_preco', 'tipo_preco')
+    .field('cub.preco', 'preco')
     .join(
-        table_b, 
-        'b', 
-        'a.estado_id = b.estado_id AND a.ano_censo = (b.ano_censo/100)'
+        sub_table, 
+        'sub', 
+        'cub.estado_id = sub.estado_id AND cub.ano_censo = (sub.ano_censo/100)'
     )
-    .join('estado', null, 'a.estado_id = estado.id')
+    .join('estado', null, 'cub.estado_id = estado.id')
+
+    var average = squel.select().from(states, "states")
+    .field('AVG(states.preco)', 'preco')
+    .field("'BR'", 'sigla_uf')
+    .field('states.tipo_preco')
+    .group('states.tipo_preco')
+
+    if (req.filter.size || req.dims.size){
+        if ('state' in req.filter || 'state' in req.dims){
+            req.sql = states
+        }
+    }
+    else{
+        req.sql = average
+    }
     next();
 }, query, id2str.transform(), response('last_state_values'))