1、新增旧货市场
2、新增用户等级
This commit is contained in:
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/add 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.add({
|
||||
dbName: 'jjx-album',
|
||||
dataJson: data
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/delete 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.deleteById({
|
||||
dbName: 'jjx-album',
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/list 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-album',
|
||||
sortArr: [
|
||||
{ name: "sort", type: "asc" },
|
||||
{ name: "_id", type: "desc" },
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/update 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: 'jjx-album',
|
||||
dataJson: data,
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,29 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/add 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.add({
|
||||
dbName: 'jjx-notice',
|
||||
dataJson: {
|
||||
...data, ...{
|
||||
viewNum: 0
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/delete 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.deleteById({
|
||||
dbName: 'jjx-notice',
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,24 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/list 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-notice'
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/update 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: 'jjx-notice',
|
||||
dataJson: data,
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/add 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.add({
|
||||
dbName: 'jjx-other-article-category',
|
||||
dataJson: data
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
+25
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/delete 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.deleteById({
|
||||
dbName: 'jjx-other-article-category',
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/list 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-other-article-category',
|
||||
sortArr: [
|
||||
{ name: "sort", type: "asc" },
|
||||
{ name: "_id", type: "desc" },
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
+26
@@ -0,0 +1,26 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/update 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: 'jjx-other-article-category',
|
||||
dataJson: data,
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,30 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/add 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.add({
|
||||
dbName: 'jjx-other-article',
|
||||
dataJson: {
|
||||
...data, ...{
|
||||
viewNum: 0,
|
||||
downloadNum: 0,
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/delete 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.deleteById({
|
||||
dbName: 'jjx-other-article',
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/list 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-other-article',
|
||||
foreignDB: [
|
||||
{
|
||||
dbName: "jjx-other-article-category",
|
||||
localKey: "parentId",
|
||||
foreignKey: "_id",
|
||||
as: "category",
|
||||
limit: 1,
|
||||
},
|
||||
|
||||
]
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url admin/article/category/sys/update 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: 'jjx-other-article',
|
||||
dataJson: data,
|
||||
id: data._id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -16,8 +16,7 @@ module.exports = {
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-user-level',
|
||||
sortArr: [
|
||||
{ name: "sort", type: "asc" },
|
||||
{ name: "_id", type: "desc" },
|
||||
{ name: "level", type: "asc" },
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/article/list/pub/addDownload 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "jwvdp-app-public",
|
||||
id: data.id,
|
||||
dataJson: {
|
||||
downloadNum: _.inc(1)
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -12,12 +12,12 @@ module.exports = {
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
console.log(data.ids)
|
||||
await vk.baseDao.del({
|
||||
dbName: "jjx-cart",
|
||||
whereJson:{
|
||||
whereJSON: {
|
||||
uid,
|
||||
goodsId: data.goodsId
|
||||
_id: _.in(data.ids)
|
||||
}
|
||||
})
|
||||
|
||||
|
||||
@@ -24,6 +24,11 @@ module.exports = {
|
||||
msg: '该用户不存在'
|
||||
}
|
||||
|
||||
if (!otherUser.fadadaConfirm) return {
|
||||
code: -1,
|
||||
msg: '该用户未通过法大大认证,无法签约'
|
||||
}
|
||||
|
||||
data.transactionId = vk.pubfn.createOrderNo("C", 20)
|
||||
const uploaddocs = await pubFun.fadada('uploaddocs.api', {
|
||||
contract_id: data.transactionId,
|
||||
|
||||
@@ -53,7 +53,7 @@ module.exports = {
|
||||
_id: data.sheetId,
|
||||
},
|
||||
dataJson: {
|
||||
answerNumber: _.inc(1)
|
||||
quoteNum: _.inc(1)
|
||||
}
|
||||
})
|
||||
|
||||
|
||||
@@ -23,12 +23,37 @@ module.exports = {
|
||||
...{
|
||||
answerNumber: 0,
|
||||
userId: uid,
|
||||
status: 0
|
||||
status: 0,
|
||||
quoteNum: 0
|
||||
}
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
const messageUserList = await vk.baseDao.select({
|
||||
dbName: "jjx-message-config",
|
||||
whereJson: {
|
||||
enquiry: true
|
||||
}
|
||||
})
|
||||
const messageList = []
|
||||
for (let i = 0; i < messageUserList.rows.length; i++) {
|
||||
if (messageUserList.rows[i].uid !== uid) {
|
||||
messageList.push({
|
||||
uid: messageUserList.rows[i].uid,
|
||||
title: `询价:${data.title}`,
|
||||
content: `新的询价信息发布，赶紧去看看吧`,
|
||||
type: 'old',
|
||||
hasRead: false,
|
||||
pk: res.id
|
||||
})
|
||||
}
|
||||
}
|
||||
await vk.baseDao.adds({
|
||||
dbName: "jjx-message",
|
||||
dataJson: messageList
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
|
||||
+28
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/enquiry/sheet/kh/changeToOnlineSign 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "jjx-enquiry-sheet",
|
||||
id: data.id,
|
||||
dataJson: {
|
||||
signMethod: 0,
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -9,7 +9,7 @@ module.exports = {
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid, pageIndex, pageSize, keyword, categoryIds, provinceCodes, formData} = data;
|
||||
let {uid, pageIndex, pageSize, keyword, categoryIds, provinceCodes, formData, status} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
let dbName = "jjx-enquiry-sheet";
|
||||
@@ -23,14 +23,14 @@ module.exports = {
|
||||
|
||||
if (data.userId && vk.pubfn.isNotNull(data.userId)) {
|
||||
whereJson.userId = data.userId
|
||||
}else {
|
||||
} else {
|
||||
whereJson.status = 0
|
||||
}
|
||||
|
||||
if (formData && formData.hasOwnProperty('userId') && vk.pubfn.isNotNull(formData.userId)) {
|
||||
whereJson.userId = formData.userId
|
||||
}else {
|
||||
whereJson.status = 0
|
||||
if (vk.pubfn.isNotNull(status) && status !== 'all') {
|
||||
if (status === 'noQuote') whereJson.quoteNum = 0
|
||||
else if (status === 'notPick') whereJson.status = 0
|
||||
else if (status === 'picked') whereJson.status = 1
|
||||
}
|
||||
|
||||
if (formData && formData.hasOwnProperty('companyList') && vk.pubfn.isNotNull(formData.companyList)) {
|
||||
@@ -70,7 +70,13 @@ module.exports = {
|
||||
accountType: true,
|
||||
},
|
||||
},
|
||||
|
||||
{
|
||||
dbName: "jjx-enquiry-quote",
|
||||
localKey: "_id",
|
||||
foreignKey: "sheetId",
|
||||
as: "quoteList",
|
||||
limit: 500, // limit=1则以对象形式返回
|
||||
}
|
||||
]
|
||||
});
|
||||
|
||||
@@ -85,15 +91,38 @@ module.exports = {
|
||||
});
|
||||
})
|
||||
})
|
||||
for (const item of res.rows) {
|
||||
const index = res.rows.indexOf(item);
|
||||
res.rows[index].quoteNum = await vk.baseDao.count({
|
||||
dbName: 'jjx-enquiry-quote',
|
||||
whereJson: {
|
||||
sheetId: item._id
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
res.notPickNum = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
status: 0
|
||||
},
|
||||
});
|
||||
|
||||
res.pickedNum = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
status: 1
|
||||
},
|
||||
});
|
||||
|
||||
res.noQuoteNum = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
quoteNum: 0
|
||||
},
|
||||
});
|
||||
|
||||
res.all = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
},
|
||||
});
|
||||
|
||||
res.rows = rows
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
|
||||
@@ -12,13 +12,16 @@ module.exports = {
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
const {pageIndex, pageSize, parentId, keyword, city} = data
|
||||
const whereJson = {parentId}
|
||||
const {pageIndex, pageSize, parentId, keyword, city, } = data
|
||||
const whereJson = {}
|
||||
if (vk.pubfn.isNotNull(keyword)) {
|
||||
whereJson.name = new RegExp(keyword)
|
||||
}
|
||||
if (vk.pubfn.isNotNull(city)) {
|
||||
whereJson.address.city.code = city
|
||||
whereJson['address.city.code'] = city
|
||||
}
|
||||
if (vk.pubfn.isNotNull(parentId)) {
|
||||
whereJson.parentId = parentId
|
||||
}
|
||||
|
||||
res = await vk.baseDao.select({
|
||||
|
||||
@@ -0,0 +1,47 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/config/kh/getConfig 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
const messageConfig = await vk.baseDao.findByWhereJson({
|
||||
dbName: "jjx-message-config",
|
||||
whereJson: {
|
||||
uid
|
||||
}
|
||||
});
|
||||
|
||||
if (!messageConfig) {
|
||||
const id = await vk.baseDao.add({
|
||||
dbName: "jjx-message-config",
|
||||
dataJson: {
|
||||
uid,
|
||||
article: true,
|
||||
process: true,
|
||||
old: true,
|
||||
enquiry: true,
|
||||
productList: [],
|
||||
addressRegion: {}
|
||||
}
|
||||
})
|
||||
|
||||
res = await vk.baseDao.findById({
|
||||
dbName: "jjx-message-config",
|
||||
id: id
|
||||
});
|
||||
} else res = messageConfig
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,22 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/config/kh/setConfig 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/config/kh/update 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid, article, process, old, enquiry, productList, addressRegion} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.update({
|
||||
dbName: "jjx-message-config",
|
||||
whereJson: {uid},
|
||||
dataJson: {
|
||||
article,
|
||||
process,
|
||||
old,
|
||||
enquiry,
|
||||
productList,
|
||||
addressRegion
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,32 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/kh/add 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
console.log('here is message', data)
|
||||
await vk.baseDao.add({
|
||||
dbName: "jjx-message",
|
||||
dataJson: {
|
||||
uid,
|
||||
title: data.title,
|
||||
content: data.content,
|
||||
type: data.type,
|
||||
hasRead: false
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/kh/delete 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.deleteById({
|
||||
dbName: "jjx-message",
|
||||
id: data.id
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,30 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/kh/getList 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid, pageIndex, pageSize} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.select({
|
||||
dbName: "jjx-message",
|
||||
whereJson: {
|
||||
uid,
|
||||
},
|
||||
sortArr: [{"name": "_id", "type": "desc"}],
|
||||
pageIndex,
|
||||
pageSize
|
||||
})
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,32 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/kh/setRead 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.update({
|
||||
dbName: "jjx-message",
|
||||
whereJson: {
|
||||
uid: uid,
|
||||
hasRead: false
|
||||
},
|
||||
dataJson: {
|
||||
hasRead: true
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/message/kh/setRead 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "jjx-message",
|
||||
id: data.id,
|
||||
dataJson: {
|
||||
hasRead: true
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/notice/list/pub/getDetail 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.findById({
|
||||
dbName: "jjx-notice",
|
||||
id: data.id,
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,35 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/notice/list/pub/getList 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
const {pageIndex, pageSize, parentId, keyword} = data
|
||||
const whereJson = {parentId}
|
||||
if (vk.pubfn.isNotNull(keyword)) {
|
||||
whereJson.name = new RegExp(keyword)
|
||||
}
|
||||
res = await vk.baseDao.select({
|
||||
dbName: 'jjx-notice',
|
||||
getCount: true,
|
||||
pageIndex,
|
||||
pageSize: 12,
|
||||
whereJson,
|
||||
sortArr: [
|
||||
{name: "_id", type: "desc"}
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -13,11 +13,35 @@ module.exports = {
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.add({
|
||||
const pk = await vk.baseDao.add({
|
||||
dbName: "jjx-old",
|
||||
dataJson: data
|
||||
})
|
||||
|
||||
const messageUserList = await vk.baseDao.select({
|
||||
dbName: "jjx-message-config",
|
||||
whereJson: {
|
||||
old: true
|
||||
}
|
||||
})
|
||||
const messageList = []
|
||||
for (let i = 0; i < messageUserList.rows.length; i++) {
|
||||
if (messageUserList.rows[i].uid !== uid) {
|
||||
messageList.push({
|
||||
uid: messageUserList.rows[i].uid,
|
||||
title: `旧货:${data.title}`,
|
||||
content: `新的旧货信息发布，赶紧去看看吧`,
|
||||
type: 'old',
|
||||
hasRead: false,
|
||||
pk
|
||||
})
|
||||
}
|
||||
}
|
||||
await vk.baseDao.adds({
|
||||
dbName: "jjx-message",
|
||||
dataJson: messageList
|
||||
});
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,27 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/enquiry/sheet/kh/delete 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
let {id} = data;
|
||||
if (vk.pubfn.isNull(id)) {
|
||||
return {code: -1, msg: 'id不能为空'};
|
||||
}
|
||||
await vk.baseDao.deleteById({
|
||||
dbName: 'jjx-old',
|
||||
id
|
||||
});
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -13,7 +13,7 @@ module.exports = {
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vl.baseDao.select({
|
||||
res = await vk.baseDao.select({
|
||||
dbName: "jjx-old",
|
||||
whereJson: {
|
||||
uid
|
||||
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/old/pub/getDetail 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.findById({
|
||||
dbName: "jjx-old",
|
||||
id: data.id,
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -13,10 +13,23 @@ module.exports = {
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
const whereJson = {}
|
||||
if (vk.pubfn.isNotNull(data.keyword)) {
|
||||
whereJson.name = new RegExp(data.keyword)
|
||||
}
|
||||
if (vk.pubfn.isNotNull(data.categoryIds)) {
|
||||
whereJson.category = _.in(data.categoryIds)
|
||||
}
|
||||
if (vk.pubfn.isNotNull(data.provinceCodes)) {
|
||||
whereJson['address[0].code'] = _.in(data.provinceCodes)
|
||||
}
|
||||
|
||||
|
||||
res = await vk.baseDao.select({
|
||||
dbName: "jjx-old",
|
||||
pageIndex,
|
||||
pageSize,
|
||||
sortArr: [{"name": "_id", "type": "desc"}],
|
||||
whereJson: {
|
||||
type: type
|
||||
},
|
||||
|
||||
@@ -12,14 +12,20 @@ module.exports = {
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
const goods = await vk.baseDao.findById({
|
||||
dbName: "jjx-goods",
|
||||
id: data.goodsId
|
||||
})
|
||||
let goods
|
||||
if (data.type === 0) {
|
||||
goods = await vk.baseDao.findById({
|
||||
dbName: "jjx-goods",
|
||||
id: data.goodsId
|
||||
})
|
||||
} else {
|
||||
goods = data.goods
|
||||
}
|
||||
|
||||
// type 0: 商品
|
||||
// type 1: 自营
|
||||
// type 2: 保证金
|
||||
// type 3: 会员升级
|
||||
const orderId = await vk.baseDao.add({
|
||||
dbName: "jjx-order",
|
||||
dataJson: {
|
||||
@@ -34,7 +40,7 @@ module.exports = {
|
||||
await vk.baseDao.add({
|
||||
dbName: "jjx-order-goods",
|
||||
dataJson: {
|
||||
orderId: orderId,
|
||||
orderId,
|
||||
goodsId: data.goodsId,
|
||||
num: data.num,
|
||||
goodsName: goods.name,
|
||||
|
||||
@@ -9,17 +9,16 @@ module.exports = {
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let {uid, type, pageIndex, pageSize} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
const whereJson = {uid}
|
||||
if(!vk.pubfn.isNull(type)) whereJson.type = type
|
||||
res = await vk.baseDao.selects({
|
||||
dbName: "jjx-order",
|
||||
whereJson: {
|
||||
uid
|
||||
},
|
||||
pageIndex: 1,
|
||||
pageSize: 500,
|
||||
whereJson,
|
||||
pageIndex,
|
||||
pageSize,
|
||||
sortArr:[{ "name":"_id", "type":"desc" }],
|
||||
foreignDB: [
|
||||
{
|
||||
|
||||
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/order/kh/resetOrderNo 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "jjx-order",
|
||||
id: data.id,
|
||||
dataJson: {
|
||||
orderNo: vk.pubfn.createOrderNo("O", 20),
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
+28
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/otherArticle/category/pub/getList 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-other-article-category',
|
||||
sortArr: [
|
||||
{ name: "sort", type: "asc" },
|
||||
{ name: "_id", type: "desc" },
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
+25
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/otherArticle/list/pub/getDetail 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.findById({
|
||||
dbName: "jjx-other-article",
|
||||
id: data.id,
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,32 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/otherArticle/list/pub/getList 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
const {pageIndex, pageSize, parentId} = data
|
||||
const whereJson = {parentId}
|
||||
res = await vk.baseDao.select({
|
||||
dbName: 'jjx-other-article',
|
||||
getCount: true,
|
||||
pageIndex,
|
||||
pageSize,
|
||||
whereJson,
|
||||
sortArr: [
|
||||
{name: "_id", type: "desc"}
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -41,14 +41,18 @@ var cloudObject = {
|
||||
let res = {code: 0, msg: ''};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
console.log('pay notify res', data)
|
||||
const order = await vk.baseDao.findByWhereJson({
|
||||
dbName: "jjx-order",
|
||||
whereJson: {
|
||||
orderNo: data.billNo,
|
||||
}
|
||||
});
|
||||
console.log('order', order)
|
||||
|
||||
// type 0: 商品
|
||||
// type 1: 自营
|
||||
// type 2: 保证金
|
||||
// type 3: 会员升级
|
||||
|
||||
if (order && order.orderStatus === 0 && data.billStatus === 'PAID') {
|
||||
const billPayment = JSON.parse(data.billPayment)
|
||||
await vk.baseDao.updateById({
|
||||
@@ -61,6 +65,65 @@ var cloudObject = {
|
||||
payNo: billPayment.paySeqId,
|
||||
}
|
||||
});
|
||||
|
||||
if (order.type === 2) {
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "uni-id-users",
|
||||
id: order.uid,
|
||||
dataJson: {
|
||||
paidEnsure: _.inc(parseFloat(billPayment.receiptAmount) / 100),
|
||||
}
|
||||
});
|
||||
} else if (order.type === 3) {
|
||||
const goods = await vk.baseDao.findByWhereJson({
|
||||
dbName: "jjx-goods",
|
||||
whereJson: {
|
||||
orderId: order._id,
|
||||
}
|
||||
});
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "uni-id-users",
|
||||
id: order.uid,
|
||||
dataJson: {
|
||||
userLevel: goods.goodsId,
|
||||
userGrade: 0
|
||||
}
|
||||
});
|
||||
const user = await vk.baseDao.findById({
|
||||
dbName: "uni-id-users",
|
||||
id: order.uid
|
||||
});
|
||||
if (user.inviter_uid && user.inviter_uid.length > 0) {
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "uni-id-users",
|
||||
id: user.inviter_uid[0],
|
||||
dataJson: {
|
||||
inviteNum: _.inc(1)
|
||||
}
|
||||
});
|
||||
}
|
||||
const messageConfig = await vk.baseDao.find({
|
||||
dbName: "jjx-message-config",
|
||||
dataJson: {
|
||||
uid: order.uid
|
||||
}
|
||||
});
|
||||
|
||||
if (!messageConfig) {
|
||||
await vk.baseDao.add({
|
||||
dbName: "jjx-message-config",
|
||||
dataJson: {
|
||||
uid: order.uid,
|
||||
article: true,
|
||||
process: true,
|
||||
old: true,
|
||||
enquiry: true,
|
||||
productList: [],
|
||||
addressRegion: {}
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
}
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
|
||||
@@ -69,6 +69,8 @@ module.exports = {
|
||||
userId: uid
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -31,10 +31,34 @@ module.exports = {
|
||||
_id: data.sheetId,
|
||||
},
|
||||
dataJson: {
|
||||
answerNumber: _.inc(1)
|
||||
quoteNum: _.inc(1)
|
||||
}
|
||||
})
|
||||
|
||||
const messageUserList = await vk.baseDao.select({
|
||||
dbName: "jjx-message-config",
|
||||
whereJson: {
|
||||
process: true
|
||||
}
|
||||
})
|
||||
const messageList = []
|
||||
for (let i = 0; i < messageUserList.rows.length; i++) {
|
||||
if (messageUserList.rows[i].uid !== uid) {
|
||||
messageList.push({
|
||||
uid: messageUserList.rows[i].uid,
|
||||
title: `加工:${data.title}`,
|
||||
content: `新的加工信息发布，赶紧去看看吧`,
|
||||
type: 'old',
|
||||
hasRead: false,
|
||||
pk: res.id
|
||||
})
|
||||
}
|
||||
}
|
||||
await vk.baseDao.adds({
|
||||
dbName: "jjx-message",
|
||||
dataJson: messageList
|
||||
});
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -19,7 +19,7 @@ module.exports = {
|
||||
...data,
|
||||
...{
|
||||
userId: data.uid,
|
||||
answerNumber: 0,
|
||||
quoteNum: 0,
|
||||
status: 0,
|
||||
}
|
||||
}
|
||||
|
||||
+28
@@ -0,0 +1,28 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/enquiry/sheet/kh/changeToOnlineSign 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "jjx-process-sheet",
|
||||
id: data.id,
|
||||
dataJson: {
|
||||
signMethod: 0,
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -10,7 +10,7 @@ module.exports = {
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid, userId, pageIndex, pageSize, keyword, categoryIds, provinceCodes, formData} = data;
|
||||
let {uid, userId, pageIndex, pageSize, keyword, categoryIds, provinceCodes, formData, status} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
const dbName = "jjx-process-sheet";
|
||||
@@ -30,17 +30,19 @@ module.exports = {
|
||||
}
|
||||
|
||||
if (formData && formData.hasOwnProperty('categoryIds') && vk.pubfn.isNotNull(formData.categoryIds)) {
|
||||
whereJson.categoryIds = _.in(formData.categoryIds)
|
||||
}
|
||||
|
||||
if (vk.pubfn.isNotNull(categoryIds)) {
|
||||
whereJson.categoryIds = _.in(categoryIds)
|
||||
whereJson.productList = _.in(formData.categoryIds)
|
||||
}
|
||||
|
||||
if (vk.pubfn.isNotNull(provinceCodes)) {
|
||||
whereJson['address.province.code'] = _.in(provinceCodes)
|
||||
}
|
||||
|
||||
if (vk.pubfn.isNotNull(status) && status !== 'all') {
|
||||
if (status === 'noQuote') whereJson.quoteNum = 0
|
||||
else if (status === 'notPick') whereJson.status = 0
|
||||
else if (status === 'picked') whereJson.status = 1
|
||||
}
|
||||
|
||||
res = await vk.baseDao.selects({
|
||||
dbName,
|
||||
pageIndex,
|
||||
@@ -70,15 +72,68 @@ module.exports = {
|
||||
});
|
||||
|
||||
for (const item of res.rows) {
|
||||
const index = res.rows.indexOf(item);
|
||||
res.rows[index].quoteNum = await vk.baseDao.count({
|
||||
item.quoteList = await vk.baseDao.selects({
|
||||
dbName: 'jjx-process-quote',
|
||||
whereJson:{
|
||||
sheetId: item._id
|
||||
}
|
||||
whereJson: {
|
||||
sheetId: item._id,
|
||||
},
|
||||
foreignDB: [
|
||||
{
|
||||
dbName: "uni-id-users",
|
||||
localKey: "userId",
|
||||
foreignKey: "_id",
|
||||
as: "user",
|
||||
limit: 1, // limit=1则以对象形式返回
|
||||
fieldJson: {
|
||||
_id: true,
|
||||
company: {
|
||||
companyName: true,
|
||||
mobile: true,
|
||||
},
|
||||
person: {
|
||||
personName: true,
|
||||
mobile: true,
|
||||
},
|
||||
businessCard: true,
|
||||
accountType: true,
|
||||
},
|
||||
}
|
||||
]
|
||||
})
|
||||
}
|
||||
|
||||
res.notPickNum = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
status: 0
|
||||
},
|
||||
});
|
||||
|
||||
res.pickedNum = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
status: 1
|
||||
},
|
||||
});
|
||||
|
||||
|
||||
res.noQuoteNum = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
quoteNum: 0
|
||||
},
|
||||
});
|
||||
|
||||
res.all = await vk.baseDao.count({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
},
|
||||
});
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,25 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/selfSupport/kh/add 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
await vk.baseDao.add({
|
||||
dbName: "jjx-self-support",
|
||||
dataJson: data
|
||||
})
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,80 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/selfSupport/kh/addOrder 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, userInfo, util, filterResponse, originalParam} = event;
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid, contentList, amountList, type} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
const configList = await vk.baseDao.select({
|
||||
dbName: "jjx-coop-config",
|
||||
whereJson: {
|
||||
type
|
||||
}
|
||||
})
|
||||
|
||||
const goodsList = []
|
||||
let amount = 0
|
||||
configList.rows.forEach(config => {
|
||||
config.contents.forEach(content => {
|
||||
if (content.amountList) {
|
||||
content.amountList.forEach(amountItem => {
|
||||
if (amountList.includes(amountItem._index)) {
|
||||
amount += amountItem.amount
|
||||
goodsList.push({
|
||||
goodsName: `${config.name}-${content.title}-${amountItem.title}`,
|
||||
num: 1,
|
||||
goodsPrice: amountItem.amount,
|
||||
goodsCover: null,
|
||||
goodsId: null,
|
||||
})
|
||||
}
|
||||
})
|
||||
}
|
||||
})
|
||||
})
|
||||
|
||||
const orderId = await vk.baseDao.add({
|
||||
dbName: "jjx-order",
|
||||
dataJson: {
|
||||
orderNo: vk.pubfn.createOrderNo("SP", 20),
|
||||
uid,
|
||||
orderStatus: 0,
|
||||
type: 1,
|
||||
amount: amount * contentList.length,
|
||||
}
|
||||
})
|
||||
|
||||
goodsList.forEach((item, index) => {
|
||||
goodsList[index].orderId = orderId
|
||||
})
|
||||
|
||||
await vk.baseDao.adds({
|
||||
dbName: "jjx-order-goods",
|
||||
dataJson: goodsList
|
||||
})
|
||||
|
||||
contentList.forEach((item, index) => {
|
||||
contentList[index].orderId = orderId
|
||||
})
|
||||
|
||||
console.log('contentList', contentList)
|
||||
|
||||
await vk.baseDao.adds({
|
||||
dbName: "jjx-order-self-product",
|
||||
dataJson: contentList
|
||||
})
|
||||
|
||||
res.data = orderId
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -13,12 +13,39 @@ module.exports = {
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
res = await vk.baseDao.select({
|
||||
res = await vk.baseDao.selects({
|
||||
dbName,
|
||||
whereJson: {
|
||||
userId: uid,
|
||||
},
|
||||
limit: 1
|
||||
limit: 1,
|
||||
foreignDB: [
|
||||
{
|
||||
dbName: "jjx-goods-cooperate",
|
||||
localKey: "_id",
|
||||
foreignKey: "goodsId",
|
||||
as: "cooperateList",
|
||||
limit: 500, // limit=1则以对象形式返回
|
||||
foreignDB: [{
|
||||
dbName: "uni-id-users",
|
||||
localKey: "userId",
|
||||
foreignKey: "_id",
|
||||
as: "user",
|
||||
limit: 1, // limit=1则以对象形式返回
|
||||
fieldJson: {
|
||||
_id: true,
|
||||
company: {
|
||||
companyName: true
|
||||
},
|
||||
person: {
|
||||
personName: true
|
||||
},
|
||||
businessCard: true,
|
||||
accountType: true,
|
||||
},
|
||||
},
|
||||
]
|
||||
}]
|
||||
});
|
||||
|
||||
|
||||
|
||||
@@ -0,0 +1,35 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/user/kh/exchangeUpgrade 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
const userLevelConfig = await vk.baseDao.findById({
|
||||
dbName: "jjx-user-level",
|
||||
id: data.id
|
||||
});
|
||||
|
||||
if(parseInt(userInfo.userLevel) < userLevelConfig.level) {
|
||||
await vk.baseDao.updateById({
|
||||
dbName: "uni-id-users",
|
||||
id: uid,
|
||||
dataJson: {
|
||||
userLevel: userLevelConfig.level
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -12,22 +12,27 @@ module.exports = {
|
||||
let {customUtil, uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {code: 0, msg: ""};
|
||||
const whereJson = {
|
||||
const whereJson = {
|
||||
accountType: 2
|
||||
}
|
||||
if (!vk.pubfn.isNull(data.keyword)) whereJson['company.companyName'] = new RegExp(data.keyword);
|
||||
if (!vk.pubfn.isNull(data.isCoop)) whereJson.isCoop = data.isCoop;
|
||||
if (vk.pubfn.isNull(data.province) && data.province && data.province.length > 0) {
|
||||
if (!vk.pubfn.isNull(data.province) && data.province && data.province.length > 0) {
|
||||
whereJson['businessCard.address.province.code'] = _.in(data.province);
|
||||
}
|
||||
if (vk.pubfn.isNull(data.mainSpotCategoryIds) && data.mainSpotCategoryIds && data.mainSpotCategoryIds.length > 0) {
|
||||
if (!vk.pubfn.isNull(data.city) && data.city && data.city.length > 0) {
|
||||
whereJson['businessCard.address.city.code'] = _.in(data.city);
|
||||
}
|
||||
if (!vk.pubfn.isNull(data.mainSpotCategoryIds) && data.mainSpotCategoryIds && data.mainSpotCategoryIds.length > 0) {
|
||||
whereJson['businessCard.mainSpotCategoryIds'] = _.in(data.mainSpotCategoryIds);
|
||||
}
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
res = await vk.baseDao.select({
|
||||
dbName: dbName.user,
|
||||
whereJson,
|
||||
pageSize: -1
|
||||
pageSize: -1,
|
||||
pageIndex: 1,
|
||||
sortArr: [{"name": "_id", "type": "desc"}],
|
||||
});
|
||||
console.log('whereJson', whereJson)
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
|
||||
@@ -0,0 +1,27 @@
|
||||
'use strict';
|
||||
module.exports = {
|
||||
/**
|
||||
* XXXnameXXX
|
||||
* @url client/userLevel/pub/getList 前端调用的url参数地址
|
||||
* data 请求参数
|
||||
* @param {String} params1 参数1
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, userInfo, util, filterResponse, originalParam } = event;
|
||||
let { customUtil, uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = { code: 0, msg: "" };
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
|
||||
res = await vk.baseDao.getTableData({
|
||||
dbName: 'jjx-user-level',
|
||||
sortArr: [
|
||||
{ name: "level", type: "asc" },
|
||||
],
|
||||
});
|
||||
|
||||
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
@@ -1,102 +1,119 @@
|
||||
module.exports = {
|
||||
/**
|
||||
* 手机号登陆(手机号+手机验证码)
|
||||
* @url user/pub/loginBySms 前端调用的url参数地址
|
||||
* @description 手机号登陆(手机号+手机验证码)
|
||||
* data 请求参数 说明
|
||||
* @param {String} mobile 手机号
|
||||
* @param {String} code 验证码
|
||||
* @param {String} type 指定操作类型，不传：存在则登录不存在则注册 login：只能登录 register：只能注册
|
||||
* @param {String} password 密码，当前用户为新注册时生效
|
||||
* @param {String} inviteCode 邀请人的邀请码，当前用户为新注册时生效
|
||||
* @param {String} myInviteCode 设置当前注册用户自己的邀请码，当前用户为新注册时生效（不传会自动生成）
|
||||
* @param {Boolean} needPermission 设置为true时会在checkToken时返回用户权限（permission），如果是在admin端，需传true
|
||||
* res 返回参数说明
|
||||
* @param {Number} code 错误码，0表示成功
|
||||
* @param {String} msg 详细信息
|
||||
* @param {String} token 登录成功之后返回的token信息
|
||||
* @param {String} tokenExpired token过期时间
|
||||
*/
|
||||
main: async (event) => {
|
||||
let { data = {}, util, originalParam } = event;
|
||||
let { uniID, config, pubFun, vk, db, _ } = util;
|
||||
let { uid } = data;
|
||||
let res = {};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
let {
|
||||
mobile,
|
||||
code,
|
||||
type,
|
||||
password,
|
||||
inviteCode,
|
||||
myInviteCode,
|
||||
needPermission,
|
||||
accountType,
|
||||
company,
|
||||
person
|
||||
} = data;
|
||||
res = await uniID.loginBySms({
|
||||
mobile,
|
||||
code,
|
||||
type,
|
||||
password,
|
||||
inviteCode,
|
||||
myInviteCode,
|
||||
needPermission
|
||||
});
|
||||
// 修改用户昵称为:手机尾号xxxx用户
|
||||
if (res.token) {
|
||||
if (!res.msg) {
|
||||
res.msg = res.type === "register" ? "注册成功" : "登录成功";
|
||||
}
|
||||
// 注册法大大
|
||||
if(res.type === "register") {
|
||||
const fadadaRes = await pubFun.fadada('account_register.api', {
|
||||
open_id: res.uid + 'fdd',
|
||||
account_type: accountType + '',
|
||||
})
|
||||
console.log('fadadaRes: ',{
|
||||
open_id: res.uid + 'fdd',
|
||||
account_type: accountType + '',
|
||||
});
|
||||
console.log('fadadaRes: ',fadadaRes);
|
||||
if(fadadaRes.code == 1) {
|
||||
await vk.baseDao.update({
|
||||
dbName: "uni-id-users",
|
||||
whereJson: {
|
||||
_id: res.uid
|
||||
},
|
||||
dataJson: {
|
||||
fadadaCustomerId: fadadaRes.data,
|
||||
quoteTimes: 0,
|
||||
person,
|
||||
company,
|
||||
accountType: accountType,
|
||||
nickname: accountType == 1 ? person.personName: company.companyName,
|
||||
/**
|
||||
* 手机号登陆(手机号+手机验证码)
|
||||
* @url user/pub/loginBySms 前端调用的url参数地址
|
||||
* @description 手机号登陆(手机号+手机验证码)
|
||||
* data 请求参数 说明
|
||||
* @param {String} mobile 手机号
|
||||
* @param {String} code 验证码
|
||||
* @param {String} type 指定操作类型，不传：存在则登录不存在则注册 login：只能登录 register：只能注册
|
||||
* @param {String} password 密码，当前用户为新注册时生效
|
||||
* @param {String} inviteCode 邀请人的邀请码，当前用户为新注册时生效
|
||||
* @param {String} myInviteCode 设置当前注册用户自己的邀请码，当前用户为新注册时生效（不传会自动生成）
|
||||
* @param {Boolean} needPermission 设置为true时会在checkToken时返回用户权限（permission），如果是在admin端，需传true
|
||||
* res 返回参数说明
|
||||
* @param {Number} code 错误码，0表示成功
|
||||
* @param {String} msg 详细信息
|
||||
* @param {String} token 登录成功之后返回的token信息
|
||||
* @param {String} tokenExpired token过期时间
|
||||
*/
|
||||
main: async (event) => {
|
||||
let {data = {}, util, originalParam} = event;
|
||||
let {uniID, config, pubFun, vk, db, _} = util;
|
||||
let {uid} = data;
|
||||
let res = {};
|
||||
// 业务逻辑开始-----------------------------------------------------------
|
||||
let {
|
||||
mobile,
|
||||
code,
|
||||
type,
|
||||
password,
|
||||
inviteCode,
|
||||
myInviteCode,
|
||||
needPermission,
|
||||
accountType,
|
||||
company,
|
||||
person
|
||||
} = data;
|
||||
res = await uniID.loginBySms({
|
||||
mobile,
|
||||
code,
|
||||
type,
|
||||
password,
|
||||
inviteCode,
|
||||
myInviteCode,
|
||||
needPermission
|
||||
});
|
||||
// 修改用户昵称为:手机尾号xxxx用户
|
||||
if (res.token) {
|
||||
if (!res.msg) {
|
||||
res.msg = res.type === "register" ? "注册成功" : "登录成功";
|
||||
}
|
||||
// 注册法大大
|
||||
if (res.type === "register") {
|
||||
const fadadaRes = await pubFun.fadada('account_register.api', {
|
||||
open_id: res.uid + 'fdd',
|
||||
account_type: accountType + '',
|
||||
})
|
||||
console.log('fadadaRes: ', {
|
||||
open_id: res.uid + 'fdd',
|
||||
account_type: accountType + '',
|
||||
});
|
||||
console.log('fadadaRes: ', fadadaRes);
|
||||
if (fadadaRes.code == 1) {
|
||||
await vk.baseDao.update({
|
||||
dbName: "uni-id-users",
|
||||
whereJson: {
|
||||
_id: res.uid
|
||||
},
|
||||
dataJson: {
|
||||
fadadaCustomerId: fadadaRes.data,
|
||||
quoteTimes: 0,
|
||||
person,
|
||||
company,
|
||||
accountType: accountType,
|
||||
nickname: accountType == 1 ? person.personName : company.companyName,
|
||||
authStatus: -1,
|
||||
userLevel: -1,
|
||||
}
|
||||
});
|
||||
}else {
|
||||
vk.baseDao.del({
|
||||
dbName: "uni-id-users",
|
||||
whereJson: {
|
||||
_id: res.uid
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
}
|
||||
// 日志服务
|
||||
const loginLogService = vk.require("service/user/util/login_log");
|
||||
await loginLogService.add({
|
||||
type: "login",
|
||||
login_type: "sms",
|
||||
user_id: res.uid,
|
||||
context: originalParam.context
|
||||
}, util);
|
||||
}
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
userGrade: 0,
|
||||
paidEnsure: 0,
|
||||
// 累计交易
|
||||
transactionAmount: 0,
|
||||
inviteNum: 0,
|
||||
}
|
||||
});
|
||||
|
||||
} else {
|
||||
vk.baseDao.del({
|
||||
dbName: "uni-id-users",
|
||||
whereJson: {
|
||||
_id: res.uid
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
await vk.baseDao.add({
|
||||
dbName: "jjx-message",
|
||||
dataJson: {
|
||||
uid: res.uid,
|
||||
title: '恭喜！您已注册成功！',
|
||||
content: '尊敬的用户，恭喜您已经注册金久信钢铁交易平台，感谢您的支持！',
|
||||
type: 'reg',
|
||||
hasRead: false
|
||||
}
|
||||
});
|
||||
|
||||
}
|
||||
// 日志服务
|
||||
const loginLogService = vk.require("service/user/util/login_log");
|
||||
await loginLogService.add({
|
||||
type: "login",
|
||||
login_type: "sms",
|
||||
user_id: res.uid,
|
||||
context: originalParam.context
|
||||
}, util);
|
||||
}
|
||||
// 业务逻辑结束-----------------------------------------------------------
|
||||
return res;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user