module.exports = app => {
const mongoose = app.mongoose;
const Schema = mongoose.Schema;
const { logger, helper } = app.createAnonymousContext();
const {
objToQuery
} = helper;
const conn = app.mongooseDB.get('mp');
const AccountUserAddressSchema = new Schema({
// 默认地址
default_id: {
type: Schema.Types.ObjectId,
default: null
},
// 用户id
_uid: {
type: Schema.Types.ObjectId
},
// 标签
tags: {
type: Array,
default: ['家', '公司', '学校']
},
// 地址列表
address: [{
// 收货人姓名
userName: {
type: String,
required: true
},
// 邮编
postalCode: {
type: String
},
// 省市
provinceName: {
type: String,
required: true
},
// 市
cityName: {
type: String,
required: true
},
// 区/县
countyName: {
type: String,
required: true
},
// 详细地址
detailInfo: {
type: String,
required: true
},
// 联系电话
telNumber: {
type: String,
required: true
},
// 状态 [[0,'删除'],[1,'正常']]
status: {
type: Number,
default: 1
},
// 标签
tag: String,
// 添加时间
addTime: {
type: Date,
default: new Date()
},
deleteTime: Date
}]
});
AccountUserAddressSchema.statics = {
// 添加
addOne: async function(_uid, BODYS) {
const { is_default } = BODYS;
const MODEL = this.findOneAndUpdate({
_uid
}, {
$push: {
'address': {...BODYS }
},
// ...isDefault && { default_id: _id }
}, {
new: true,
fields: 'cars default_id -_id'
});
try {
const RBD = await MODEL;
return !!RBD
} catch (error) {
console.log(error)
}
},
// 更新地址
updateOne: async function(_uid, _id, BODYS) {
// const { isDefault } = BODYS;
// delete BODYS.isDefault;
const MODEL = this.findOneAndUpdate({
_uid,
'address._id': _id
}, {
$set: {...objToQuery(BODYS, 'address') }
}, {
fields: 'address default_id -_id'
});
try {
// 修改数据
const DATAS = await MODEL;
// 修改默认
// !!isDefault && await this.setDefault(_uid, isDefault, _id);
return !!DATAS.address.length ? BODYS : { code: 211, message: '更新失败' }
} catch (error) {
return error
}
},
// 列表
list: async function(_uid) {
const MODEL = this.aggregate([{
$match: {
_uid: mongoose.Types.ObjectId(_uid)
}
}, {
$unwind: '$address'
}, {
$match: {
'address.deleteTime': { $exists: false }
}
}, {
$addFields: {
'address.isDefault': {
$eq: ['$default_id', '$address._id']
}
}
}, {
$replaceRoot: { newRoot: "$address" }
}]);
// const MODEL = this.find({ _uid })
try {
const RBD = await MODEL;
return RBD.length ? RBD : await this.initAddress(_uid)
} catch (error) {
console.log(error)
}
},
// 删除一个
delOne: async function(_uid, _id) {
const MODEL = this.findOneAndUpdate({
_uid,
'address._id': _id
}, {
'address.$.status': 0,
'address.$.deleteTime': new Date(),
});
try {
const RBD = await MODEL;
return { _id }
} catch (error) {
}
},
// 初始化用地址
initAddress: async function(_uid) {
const MODEL = this.create({ _uid: mongoose.Types.ObjectId(_uid) });
try {
const DATAS = await MODEL;
return DATAS
} catch (error) {
console.log(error)
}
},
// 获取单一数据
getOne: async function(_uid, _id) {
const MODEL = this.aggregate([{
$match: { _uid: mongoose.Types.ObjectId(_uid) }
}, {
$unwind: '$address'
}, {
$project: {
address: 1,
_id: 1,
default_id: 1,
}
}, {
$addFields: {
'address.isDefault': {
$eq: [{ $toString: '$default_id' }, _id]
}
}
}, {
$match: {
'address.deleteTime': { $exists: false },
'address._id': mongoose.Types.ObjectId(_id),
}
}, {
$replaceRoot: { newRoot: "$address" }
}]);
try {
if (_id !== "default") {
const DATAS = await MODEL;
return DATAS.length ? DATAS[0] : {}
}
} catch (error) {
console.log(error)
return error
}
},
// 获取默认地址
getDefault: async function(_uid) {
const MODEL = this.findOne({ _uid }, {}, {
fields: 'default_id -_id'
});
try {
const { default_id } = await MODEL;
return await this.getOne(_uid, default_id)
} catch (error) {
console.log(error);
return error
}
},
// 設置默認
setDefault: async function(_uid, default_id) {
// const default_id = !!isDefaults ? _id : '';
const MODEL = this.findOneAndUpdate({ _uid }, { default_id });
try {
const MB = await MODEL;
return { default_id }
} catch (error) {
console.log(error);
return error
}
},
};
return conn.model('account_mp_user_address', AccountUserAddressSchema)
}/**
* @name mongoDB update数组参数
*
*/
objToQuery(OBJ, KEY) {
return Object.keys(OBJ).reduce((a, b) => {
a[`${KEY}.$.${b}`] = OBJ[b];
return a
}, {});
},
