addd

app/controller/house/v2/Export190619.js

@@ -484,6 +484,44 @@ class Export20190425 extends Controller {
 
     }
 
+    async updateNewHouseTotalPrice() {
+        const { ctx } = this;
+        let query = 'SELECT aa.id,aa.`name`,aa.reference_avg_price,aa.reference_total_price,MIN(bb.area) min_area from new_house aa LEFT JOIN new_house_type bb ON (aa.id = bb.new_house_id AND bb.area IS NOT NULL AND bb.area != 0) WHERE aa.reference_total_price = 0 GROUP BY aa.id';
+        let queryFilter = {
+            type: ctx.realestateModel.QueryTypes.SELECT,
+            raw: true
+        }
+        let data = await ctx.realestateModel.query(query, queryFilter);
+        let taskList = [];
+        for (let i in data) {
+            if (data[i].min_area === null) {
+                continue;
+            }
+            if (Number(data[i].min_area) === 0) {
+                // ctx.logger.info(data[i]);
+                continue;
+            }
+            if (Number(data[i].reference_total_price) !== 0) {
+                continue;
+            }
+            if (Number(data[i].reference_avg_price) === 0) {
+                continue;
+            }
+            let totalPrice = Math.ceil(Number(data[i].reference_avg_price) * Number(data[i].min_area) / 10000);
+            let update = { reference_total_price: totalPrice };
+            let where = { where: { id: data[i].id } }
+            taskList[i] = ctx.realestateModel.NewHouse.update(update, where);
+        }
+
+        let retList = await Promise.all(taskList).then(result => {
+            return result;
+        }).catch(error => {
+            ctx.failed(error);
+        });
+        ctx.success(retList);
+
+    }
+
 }
 
 module.exports = Export20190425;

app/router/export.js

@@ -22,6 +22,8 @@ module.exports = app => {
     router.get('third', '/house_image', 'house.v2.export190619.moveHouseImage');
 
 
+    //用户新房数据的整理
+    router.get('third', '/update_new_house_total', 'house.v2.export190619.updateNewHouseTotalPrice');
 
 
 };