Commit b43ca2aa by 孙亚楠

dd

parent 3207e98e
......@@ -60,7 +60,9 @@ class ActionAPI extends APIBase {
case "assignDeliver": //分配交付商
opResult = await this.oorderSve.assignDeliver(action_body);
break;
case "orderDelivers": //分配交付商
opResult = await this.oorderdeliverSve.orderDelivers(action_body);
break;
//******************************************************************** */
// 订单
......
......@@ -49,6 +49,9 @@ class OorderDao extends Dao {
if (params.end) {
sql.push(`AND created_at <= :end`);
}
if (params.deliver_id) {
sql.push(`AND deliver_id = :deliver_id`);
}
}
}
......
......@@ -5,7 +5,7 @@ class OorderdeliverDao extends Dao {
super(Dao.getModelName(OorderdeliverDao));
}
/**
/**
* 条件查询所有符合条件的产品
* @param {*} params
*/
......
......@@ -16,12 +16,15 @@ module.exports = function (db, DataTypes) {
deliver_content: {type: DataTypes.STRING, field: 'deliver_content', allowNull: true, defaultValue:'', comment:'交付内容' },
deliver_mail_no: {type: DataTypes.STRING, field: 'deliver_mail_no', allowNull: true, defaultValue:'', comment:'交付商交付快递单号' },
deliver_mail_img: {type: DataTypes.STRING, field: 'deliver_mail_img', allowNull: true, defaultValue:'', comment:'交付商交付快递单号图片' },
completed_at: { type: DataTypes.DATE, field: 'completed_at', allowNull: true, comment:'订单的完成时间' },
operator_id: { type: DataTypes.DATE, field: 'operator_id', allowNull: true, comment:'业务员id' },
created_at: { type: DataTypes.DATE, field: 'created_at', allowNull: false, defaultValue: DataTypes.NOW },
updated_at: { type: DataTypes.DATE, field: 'updated_at', allowNull: false, defaultValue: DataTypes.NOW },
deleted_at: { type: DataTypes.DATE, field: 'deleted_at', allowNull: true }
},
{
timestamps: true,
timestamps: false,
underscore: true,
paranoid: true,
version: true,
......
......@@ -181,8 +181,8 @@ class OorderService extends ServiceBase {
if(params.id){
where.id = this.trim(params.id);
}
if(params.progress){
where.progress = this.trim(params.progress);
if(params.status){
where.status = this.trim(params.status);
}
if(params.beginDate && params.endDate){
where.beginDate = this.trim(params.beginDate);
......@@ -279,14 +279,27 @@ class OorderService extends ServiceBase {
* @param {*} params
* @id String 订单ID
* @bd_id String 业务员ID
* @status String 下一个状态码
* @bd_path String 业务员权限
*/
async assignSalesman (params){
if(!params.bd_id){
return system.getResult(null,`参数错误 业务员ID不能为空`);
}
try {
//更新订单业务员
let _order= await this.findById(params.id);
if(!_order){
return system.getResult(null,`订单不存在`);
}
//to do ... 验证下一个状态
_order.bd_id = this.trim(params.bd_id);
_order.status = this.trim(params.status);
_order.bd_path = this.trim(params.bd_path);
let res = await _order.save();
return system.getResult(res);
} catch (error) {
......@@ -300,9 +313,10 @@ class OorderService extends ServiceBase {
* 分配交付商
* @param {*} params
* @id String 订单ID
*
*
*
* @deliver_id String 交付商ID
* @deliver_name String 交付商名称
* @deliver_deliver String 交付商分成
* @status String 下一个状态码
*/
async assignDeliver(params){
//参数验证
......@@ -315,10 +329,39 @@ class OorderService extends ServiceBase {
if(!params.hasOwnProperty(`deliver_divide`)){
return system.getResult(null, `参数错误 交付商分成不能为空`);
}
//创建orderdeliver记录
//更新oorder订单记录
try {
//todo ... 验证状态
let _order= await this.findById(params.id);
if(!_order){
return system.getResult(null,`订单不存在`);
}
let self = this;
let res = await this.db.transaction(t => {
//创建orderdeliver记录
await this.oorderdeliverDao.create({
order_id: self.trim(params.id),
deliver_id:self.trim(self.deliver_id),
deliver_name:self.trim(self.deliver_name),
deliver_divide:self.trim(self.deliver_divide),
}, t);
//更新oorder订单记录
await self.dao.update({
deliver_id:self.trim(self.deliver_id),
id:self.trim(params.id),
status:self.trim(params.status)
},t);
});
return system.getResult(res);
} catch (error) {
console.log(error);
return system.getResult(null,`系统错误 错误信息 ${error}`);
}
}
......
......@@ -6,8 +6,64 @@ const ServiceBase = require("../../sve.base")
class OorderdeliverService extends ServiceBase {
constructor() {
super("order", ServiceBase.getDaoName(OorderdeliverService));
this.oorderinforegDao = system.getObject("db.order.oorderinforegDao");
this.oorderDao = system.getObject("db.order.oorderDao");
this.oorderprocessDao = system.getObject("db.order.oorderprocessDao");
this.osourceDao = system.getObject("db.common.osourceDao");
this.oproductDao = system.getObject("db.product.oproductDao");
this.oprocessDao = system.getObject("db.product.oprocessDao");
this.oproductprocessDao = system.getObject("db.product.oproductprocessDao");
}
/**
* 交付商订单管理列表
* @param {*} params
*/
// async orderDelivers(params){
// let where = {};
// if(params.deliver_id){
// where.deliver_id = this.trim(params.deliver_id);
// }else{
// return system.getResult(null,`参数错误 交付商ID不能为空`);
// }
// if(params.id){
// where.id = this.trim(params.id);
// }
// if(params.status){
// where.status = this.trim(params.status);
// }
// if(params.beginDate && params.endDate){
// where.beginDate = this.trim(params.beginDate);
// where.endDate = this.trim(params.endDate);
// }
// where.currentPage = Number(params.currentPage || 1);
// where.pageSize = Number(params.pageSize || 10);
// where.startRow = (where.currentPage-1)*where.pageSize;
// try {
// let ordersCountRes = await this.oorderDao.ordersCount(where);
// let count = ordersCountRes[0]['orderCount'];
// let rows = await this.dao.findAll(where);
// //格式化交付商
// this.formateDeliver(rows);
// let res = {
// count,rows
// };
// return system.getResult(res);
// } catch (error) {
// console.log(error);
// return system.getResult(null,`系统错误 错误信息 ${error}`);
// }
// }
}
......
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