Skip to content

5
51business
Commit 874bbb2c authored by Hsinli's avatar Hsinli
Browse files
Options

add

parent b1c85cc5
Hide whitespace changes
Inline Side-by-side
Showing with 107 additions and 67 deletions
app/controller/house/v2/Export190619.js
View file @ 874bbb2c
......@@ -129,23 +129,29 @@ class Export20190425 extends Controller {
//收藏
async moveCollection() {
const { ctx } = this;
let data = {
pageIndex: 1,
pageSize: 99999,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const retList = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/collection/list', data, { method: 'POST' });
if (retList.status !== 200) {
ctx.failed('error');
}
let res = retList.data;
let ret = {
id: [],
};
if (res.rowCount > 0) {
let k = 0;
for (k = 1; k < 999; k++) {
let data = {
pageIndex: k,
pageSize: 500,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const result = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/collection/list', data, { method: 'POST' });
if (result.status !== 200) {
ctx.failed('error');
}
let res = result.data;
if (res.results.length === 0) {
break;
}
ret.org_count = res.rowCount;
let taskList = [];
let list = res.results;
for (let i in list) {
let addData = {
......@@ -157,12 +163,18 @@ class Export20190425 extends Controller {
remark: list[i].remark,
created_at: list[i].createdAt,
updated_at: list[i].updatedAt || null,
deleted_at: list[i].xxx,
// deleted_at: list[i].xxx,
}
let id = await ctx.realestateModel.Collection.add(addData);
ret.id.push(id);
taskList[i] = ctx.realestateModel.Collection.add(addData);
}
const retList = await Promise.all(taskList).then(result => {
return result;
}).catch(error => {
ctx.failed(error);
});
ret.id = ret.id.concat(retList);
}
ret.count = ret.id.length;
ctx.success(ret);
}
......@@ -170,23 +182,29 @@ class Export20190425 extends Controller {
//预约
async moveOrder() {
const { ctx } = this;
let data = {
pageIndex: 1,
pageSize: 99999,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const retList = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/order/list', data, { method: 'POST' });
if (retList.status !== 200) {
ctx.failed('error');
}
let res = retList.data;
let ret = {
id: [],
};
if (res.rowCount > 0) {
let k = 0;
for (k = 1; k < 999; k++) {
let data = {
pageIndex: k,
pageSize: 500,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const result = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/order/list', data, { method: 'POST' });
if (result.status !== 200) {
ctx.failed('error');
}
let res = result.data;
if (res.results.length === 0) {
break;
}
ret.org_count = res.rowCount;
let taskList = [];
let list = res.results;
for (let i in list) {
let addData = {
......@@ -203,35 +221,47 @@ class Export20190425 extends Controller {
updated_at: list[i].updatedAt || null,
// deleted_at:list[i].xxx,
}
let id = await ctx.realestateModel.Order.add(addData);
ret.id.push(id);
taskList[i] = ctx.realestateModel.Order.add(addData);
}
const retList = await Promise.all(taskList).then(result => {
return result;
}).catch(error => {
ctx.failed(error);
});
ret.id = ret.id.concat(retList);
}
ret.count = ret.id.length;
ctx.success(ret);
}
//搜索历史
async moveHistory() {
const { ctx } = this;
let data = {
pageIndex: 1,
pageSize: 99999,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const retList = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/searchhistory/list', data, { method: 'POST' });
if (retList.status !== 200) {
ctx.failed('error');
}
let res = retList.data;
let ret = {
org_count: res.rowCount,
id: [],
};
if (res.rowCount > 0) {
let k = 0;
for (k = 1; k < 999; k++) {
let data = {
pageIndex: k,
pageSize: 500,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const result = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/searchhistory/list', data, { method: 'POST' });
if (result.status !== 200) {
ctx.failed('error');
}
let res = result.data;
if (res.results.length === 0) {
break;
}
ret.org_count = res.rowCount;
let taskList = [];
let list = res.results;
for (let i in list) {
let addData = {
......@@ -244,10 +274,16 @@ class Export20190425 extends Controller {
// updated_at: list[i].xxx,
// deleted_at: list[i].xxx,
}
let id = await ctx.realestateModel.SearchHistory.add(addData);
ret.id.push(id);
taskList[i] = ctx.realestateModel.SearchHistory.add(addData);
}
const retList = await Promise.all(taskList).then(result => {
return result;
}).catch(error => {
ctx.failed(error);
});
ret.id = ret.id.concat(retList);
}
ret.count = ret.id.length;
ctx.success(ret);
}
......@@ -255,25 +291,28 @@ class Export20190425 extends Controller {
//足迹
async moveFoot() {
const { ctx } = this;
let data = {
pageIndex: 1,
pageSize: 601,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const retList = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/footprint/list', data, { method: 'POST' });
if (retList.status !== 200) {
ctx.failed('error');
}
let res = retList.data;
let ret = {
org_count: res.rowCount,
org_length: res.results.length,
id: [],
};
if (res.rowCount > 0) {
let k = 0;
for (k = 1; k < 999; k++) {
let data = {
pageIndex: k,
pageSize: 500,
orderConditions: [{
key: 'id',
orderSequence: 'asc',
}]
}
const result = await ctx.helper.send_request(this.config.HOUSE_SERVICE_API + '/v1/footprint/list', data, { method: 'POST' });
if (result.status !== 200) {
ctx.failed('error');
}
let res = result.data;
if (res.results.length === 0) {
break;
}
ret.org_count = res.rowCount;
let taskList = [];
let list = res.results;
for (let i in list) {
......@@ -296,8 +335,9 @@ class Export20190425 extends Controller {
}).catch(error => {
ctx.failed(error);
});
ret.id = retList;
ret.id = ret.id.concat(retList);
}
ret.count = ret.id.length;
ctx.success(ret);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment