评论

从0到1:理发店预约剪发小程序开发笔记(上)

# 功能规划 - 首页展示:展示最新的公告通知、理发师推荐等内容,吸引用户关注。 - 理发师列表:列出所有在班的理发师信息,包括个人简介、星级、理发价格等,方便用户选择合适的理发师。 - 预约功能:用

# 背景


理发师可以在小程序上设置自己的可预约时间,价格,自我介绍,顾客可以根据理发师的日程安排选择合适的时间进行预约和支付。这样可以提高预约的效率,减少沟通成本,方便双方的安排。


# 功能规划

- 首页展示:展示最新的公告通知、理发师推荐等内容,吸引用户关注。

- 理发师列表:列出所有在班的理发师信息,包括个人简介、星级、理发价格等,方便用户选择合适的理发师。

- 预约功能:用户可以根据自己的需求选择理发师,进行预约并支付费用。

- 预约管理:用户可以查看自己的预约记录,包括已完成的预约和待核销的预约,也可以取消预约(所支付费用原路退回)。


# 功能图

# 数据库设计

```

MeetModel.DB_STRUCTURE = {

_pid: 'string|true',

MEET_ID: 'string|true',

MEET_ADMIN_ID: 'string|true|comment=添加的管理员',

MEET_TITLE: 'string|true|comment=标题',


MEET_JOIN_FORMS: 'array|true|default=[]|comment=表单字段设置',

MEET_DAYS: 'array|true|default=[]|comment=最近一次修改保存的可用日期',


MEET_CATE_ID: 'string|true|comment=分类编号',

MEET_CATE_NAME: 'string|true|comment=分类冗余',


MEET_FORMS: 'array|true|default=[]',

MEET_OBJ: 'object|true|default={}',


MEET_CANCEL_SET: 'int|true|default=1|comment=取消设置 0=不允,1=允许,2=仅开始前可取消',


MEET_STATUS: 'int|true|default=1|comment=状态 0=未启用,1=使用中,9=停止预约,10=已关闭',

MEET_ORDER: 'int|true|default=9999',

MEET_VOUCH: 'int|true|default=0',


MEET_QR: 'string|false',



MEET_FEE: 'int|false|comment=支付金额 分',

MEET_PAY_CNT: 'int|true|default=0|comment=支付数',

MEET_PAY_FEE: 'int|true|default=0|comment=支付额',

MEET_JOIN_CNT: 'int|true|default=0|comment=预约数',


MEET_PHONE: 'string|false|comment=登录手机',

MEET_PASSWORD: 'string|false|comment=登录密码',

MEET_TOKEN: 'string|false|comment=当前登录token',

MEET_TOKEN_TIME: 'int|true|default=0|comment=当前登录token time',

MEET_MINI_OPENID: 'string|false|comment=小程序openid',

MEET_LOGIN_CNT: 'int|true|default=0|comment=登陆次数',

MEET_LOGIN_TIME: 'int|false|comment=最近登录时间',


MEET_VIEW_CNT: 'int|true|default=0',


MEET_ADD_TIME: 'int|true',

MEET_EDIT_TIME: 'int|true',

MEET_ADD_IP: 'string|false',

MEET_EDIT_IP: 'string|false',

};


ProductModel.DB_STRUCTURE = {

_pid: 'string|true',

PRODUCT_ID: 'string|true',


PRODUCT_TITLE: 'string|true|comment=标题', 

PRODUCT_STATUS: 'int|true|default=1|comment=状态 0=未启用,1=使用中',


PRODUCT_CATE_ID: 'string|true|default=0|comment=分类',

PRODUCT_CATE_NAME: 'string|false|comment=分类冗余',


PRODUCT_ORDER: 'int|true|default=9999',

PRODUCT_VOUCH: 'int|true|default=0',


PRODUCT_FORMS: 'array|true|default=[]',

PRODUCT_OBJ: 'object|true|default={}',


PRODUCT_QR: 'string|false',

PRODUCT_VIEW_CNT: 'int|true|default=0',


PRODUCT_ADD_TIME: 'int|true',

PRODUCT_EDIT_TIME: 'int|true',

PRODUCT_ADD_IP: 'string|false',

PRODUCT_EDIT_IP: 'string|false',

};

```

#  核心实现


```

class MeetService extends BaseProjectService {


constructor() {

super();

this._log = new LogUtil(projectConfig.MEET_LOG_LEVEL);

}


/**

* 抛出异常

* @param {*} msg 

* @param {*} code 

*/

AppError(msg) {

this._log.error(msg);

super.AppError(msg);

}


_meetLog(meet, func = '', msg = '') {

let str = '';

str = `[MEET=${meet.MEET_TITLE}][${func}] ${msg}`;

this._log.debug(str);

}


async minuteJob() {

console.log('### minuteJob >>>>>');



// 未支付的成功订单取消  

let time = this._timestamp - 6 * 60 * 1000;

console.log('###### Begin>>> 未支付订单6分钟后取消, time<=' + time + ', ' + timeUtil.timestamp2Time(time));



let where = {

JOIN_STATUS: ['in', [JoinModel.STATUS.SUCC]],

JOIN_PAY_STATUS: 0,

JOIN_ADD_TIME: ['<=', time],

}

let rows = await JoinModel.getAll(where, '*', {}, 3000, false);

console.log('未支付订单6分钟后取消, count=', rows.length);


for (let k in rows) {

let join = rows[k];


let tradeNo = join.JOIN_PAY_TRADE_NO;


if (!await this.fixMeetJoinPay(tradeNo, join.JOIN_MEET_ID, join.JOIN_MEET_TIME_MARK)) {

console.log('该报名记录未支付,已取消并删除!', join);

}


}


console.log('###### END. 未支付订单6分钟后取消');

}



/** 统一获取Meet(某天) */

async getMeetOneDay(meetId, day, where, fields = '*') {


let meet = await MeetModel.getOne(where, fields);

if (!meet) return meet;


meet.MEET_DAYS_SET = await this.getDaysSet(meetId, day, day);

return meet;

}


/** 获取日期设置 */

async getDaysSet(meetId, startDay, endDay = null) {

let where = {

DAY_MEET_ID: meetId

}

if (startDay && endDay && endDay == startDay)

where.day = startDay;

else if (startDay && endDay)

where.day = ['between', startDay, endDay];

else if (!startDay && endDay)

where.day = ['<=', endDay];

else if (startDay && !endDay)

where.day = ['>=', startDay];


let orderBy = {

'day': 'asc'

}

let list = await DayModel.getAllBig(where, 'day,dayDesc,times', orderBy, 1000);


for (let k = 0; k < list.length; k++) {

delete list[k]._id;

}


return list;

}


// 按时段统计某时段报名情况

async statJoinCnt(meetId, timeMark) {

let whereDay = {

DAY_MEET_ID: meetId,

day: this.getDayByTimeMark(timeMark)

};

let day = await DayModel.getOne(whereDay, 'times');

if (!day) return;


let whereJoin = {

JOIN_MEET_TIME_MARK: timeMark,

JOIN_MEET_ID: meetId

};

let ret = await JoinModel.groupCount(whereJoin, 'JOIN_STATUS');


let stat = { //统计数据

succCnt: ret['JOIN_STATUS_1'] || 0, //1=预约成功,

cancelCnt: ret['JOIN_STATUS_10'] || 0, //10=已取消, 

adminCancelCnt: ret['JOIN_STATUS_99'] || 0, //99=后台取消

};


let times = day.times;

for (let j in times) {

if (times[j].mark === timeMark) {

let data = {

['times.' + j + '.stat']: stat

}

await DayModel.edit(whereDay, data);

return;

}

}


}



// 预约前检测

async beforeJoin(userId, meetId, timeMark) {

await this.checkMeetRules(userId, meetId, timeMark);

}


// 修正某用户所有未支付的成功订单状态,无须支付的不用处理

async fixUserMeetJoinPayRecord(userId) {

let where = {

JOIN_USER_ID: userId,

JOIN_PAY_STATUS: 0,

JOIN_STATUS: ['in', [JoinModel.STATUS.SUCC]],

}

let list = await JoinModel.getAll(where);


for (let k = 0; k < list.length; k++) {

await this.fixMeetJoinPay(list[k].JOIN_PAY_TRADE_NO, list[k].JOIN_MEET_ID, list[k].JOIN_MEET_TIME_MARK);

}

}


// 修正某订单状态 (仅需支付订单)

async fixMeetJoinPay(tradeNo, meetId, timeMark) {


if (!tradeNo) {

// 无支付号空单 删除

await JoinModel.del({ JOIN_PAY_TRADE_NO: tradeNo });


// 重新统计

this.statJoinCnt(meetId, timeMark);


return false;

}


let payService = new PayService();

if (!await payService.fixPayResult(tradeNo)) {

// 关闭未支付单

payService.closePay(tradeNo);


// 未支付 

await JoinModel.del({ JOIN_PAY_TRADE_NO: tradeNo });


// 重新统计

this.statJoinCnt(meetId, timeMark);


return false;

}


// 已支付

let pay = await PayModel.getOne({ PAY_TRADE_NO: tradeNo });

if (!pay) this.AppError('支付流水异常,请核查');


// 更新支付信息

let data = {

JOIN_PAY_STATUS: 1,

JOIN_PAY_TRADE_NO: tradeNo,

JOIN_PAY_FEE: pay.PAY_TOTAL_FEE,

JOIN_PAY_TIME: pay.PAY_END_TIME,

}

await JoinModel.edit({ JOIN_PAY_TRADE_NO: tradeNo }, data);



// 重新统计

this.statJoinCnt(meetId, timeMark);

return true;

}


// 用户预约逻辑

async prepay(userId, meetId, timeMark, formsList) {

 

}




// 根据日期获取其所在天设置

getDaySetByDay(meet, day) {

for (let k = 0; k < meet.MEET_DAYS_SET.length; k++) {

if (meet.MEET_DAYS_SET[k].day == day)

return dataUtil.deepClone(meet.MEET_DAYS_SET[k]);

}

return null;

}


// 根据时段标识获取其所在天 

getDayByTimeMark(timeMark) {

return timeMark.substr(1, 4) + '-' + timeMark.substr(5, 2) + '-' + timeMark.substr(7, 2);

}


// 根据时段标识获取其所在天设置

getDaySetByTimeMark(meet, timeMark) {

let day = this.getDayByTimeMark(timeMark);


for (let k = 0; k < meet.MEET_DAYS_SET.length; k++) {

if (meet.MEET_DAYS_SET[k].day == day)

return dataUtil.deepClone(meet.MEET_DAYS_SET[k]);

}

return null;

}


// 根据时段标识获取其所在时段设置

getTimeSetByTimeMark(meet, timeMark) {

let day = this.getDayByTimeMark(timeMark);


for (let k = 0; k < meet.MEET_DAYS_SET.length; k++) {

if (meet.MEET_DAYS_SET[k].day != day) continue;


for (let j in meet.MEET_DAYS_SET[k].times) {

if (meet.MEET_DAYS_SET[k].times[j].mark == timeMark)

return dataUtil.deepClone(meet.MEET_DAYS_SET[k].times[j]);

}

}

return null;

}


// 预约时段人数和状态控制校验

async checkMeetTimeControll(meet, timeMark, meetPeopleCnt = 1) {

if (!meet) this.AppError('预约时段设置错误, 预约项目不存在');


let daySet = this.getDaySetByTimeMark(meet, timeMark); // 当天设置

let timeSet = this.getTimeSetByTimeMark(meet, timeMark); // 预约时段设置


if (!daySet || !timeSet) this.AppError('预约时段设置错误day&time');


let statusDesc = timeSet.status == 1 ? '开启' : '关闭';

let limitDesc = '';

if (timeSet.isLimit) {

limitDesc = '人数上限MAX=' + timeSet.limit;

} else

limitDesc = '人数不限制NO';


this._meetLog(meet, `------------------------------`);

this._meetLog(meet, `#预约时段控制,预约日期=<${daySet.day}>`, `预约时段=[${timeSet.start}-${timeSet.end}],状态=${statusDesc}, ${limitDesc} 当前预约成功人数=${timeSet.stat.succCnt}`);


if (timeSet.status == 0) this.AppError('该时段预约已经关闭,请选择其他');


// 时段总人数限制

if (timeSet.isLimit) {

if (timeSet.stat.succCnt >= timeSet.limit) {

this.AppError('该时段预约人员已满,请选择其他');

}


let maxCnt = timeSet.limit - timeSet.stat.succCnt;


if (maxCnt < meetPeopleCnt) {

this.AppError('本时段最多还可以预约' + (maxCnt) + '人,您当前提交了' + meetPeopleCnt + '人,请调整后再提交');

}

}


}



/** 报名规则校验 */

async checkMeetRules(userId, meetId, timeMark, formsList = null) {


// 预约时段是否存在

let meetWhere = {

_id: meetId

};

let day = this.getDayByTimeMark(timeMark);

let meet = await this.getMeetOneDay(meetId, day, meetWhere);

if (!meet) {

this.AppError('预约时段选择错误,请重新选择');

}


// 预约时段人数和状态控制校验

let meetPeopleCnt = formsList ? formsList.length : 1;


await this.checkMeetTimeControll(meet, timeMark, meetPeopleCnt);


// 截止规则  

await this.checkMeetEndSet(meet, timeMark);



// 针对用户的次数限制

await this.checkMeetLimitSet(userId, meet, timeMark, meetPeopleCnt);


}



// 预约次数限制校验

async checkMeetLimitSet(userId, meet, timeMark, nowCnt) {

if (!meet) this.AppError('预约次数规则错误, 预约项目不存在');

let meetId = meet._id;


let daySet = this.getDaySetByTimeMark(meet, timeMark); // 当天设置

let timeSet = this.getTimeSetByTimeMark(meet, timeMark); // 预约时段设置


this._meetLog(meet, `------------------------------`);

this._meetLog(meet, `#预约次数规则,预约日期=<${daySet.day}>`, `预约时段=[${timeSet.start}~${timeSet.end}]`);


let where = {

JOIN_MEET_ID: meetId,

JOIN_MEET_TIME_MARK: timeMark,

JOIN_USER_ID: userId,

JOIN_STATUS: JoinModel.STATUS.SUCC

}

let cnt = await JoinModel.count(where);

let maxCnt = projectConfig.MEET_MAX_JOIN_CNT;

this._meetLog(meet, `预约次数规则,mode=本时段可预约${maxCnt}次`, `当前已预约=${cnt}次`);


if (cnt >= maxCnt)

this.AppError(`您本时段已经预约,不能继续预约`);


}




// 预约截止设置校验

async checkMeetEndSet(meet, timeMark) {

if (!meet) this.AppError('预约截止规则错误, 预约项目不存在');



this._meetLog(meet, `------------------------------`);

let daySet = this.getDaySetByTimeMark(meet, timeMark); // 当天设置

let timeSet = this.getTimeSetByTimeMark(meet, timeMark); // 预约时段设置


this._meetLog(meet, `#预约截止规则,预约日期=<${daySet.day}>`, `预约时段=[${timeSet.start}-${timeSet.end}]`);


let nowTime = timeUtil.time('Y-M-D h:m:s');


/*

let startTime = daySet.day + ' ' + timeSet.start + ':00';

this._meetLog(meet, `预约开始规则,mode=<时段过期判定>`, `预约开始时段=${startTime},当前时段=${nowTime}`);

if (nowTime > startTime) {

this.AppError('该时段已开始,无法预约,请选择其他');

}*/


let endTime = daySet.day + ' ' + timeSet.end + ':59';

this._meetLog(meet, `预约开始规则,mode=<时段过期判定>`, `预约结束时段=${endTime},当前时段=${nowTime}`);

if (nowTime > endTime) {

this.AppError('该时段已结束,无法预约,请选择其他');

}


}



/**  预约详情 */

async viewMeet(userId, meetId) {

await this.fixUserMeetJoinPayRecord(userId);


let fields = '*';


let where = {

_id: meetId,

MEET_STATUS: ['in', [MeetModel.STATUS.COMM, MeetModel.STATUS.OVER]]

}

let meet = await MeetModel.getOne(where, fields);

if (!meet) return null;


MeetModel.inc(meetId, 'MEET_VIEW_CNT', 1);


let getDaysSet = [];

meet.MEET_DAYS_SET = await this.getDaysSet(meetId, timeUtil.time('Y-M-D')); //今天及以后

let daysSet = meet.MEET_DAYS_SET;


let now = timeUtil.time('Y-M-D');

for (let k = 0; k < daysSet.length; k++) {

let dayNode = daysSet[k];


if (dayNode.day < now) continue; // 排除过期


let getTimes = [];


for (let j in dayNode.times) {

let timeNode = dayNode.times[j];


// 排除状态关闭的时段

if (timeNode.status != 1) continue;


// 判断数量是否已满

if (timeNode.isLimit && timeNode.stat.succCnt >= timeNode.limit)

timeNode.error = '预约已满';


// 截止规则

if (!timeNode.error) {

try {

await this.checkMeetEndSet(meet, timeNode.mark);

} catch (ex) {

if (ex.name == 'AppError')

timeNode.error = '预约结束';

else

throw ex;

}

}


getTimes.push(timeNode);

}

dayNode.times = getTimes;


getDaysSet.push(dayNode);

}



// 预约人数

let whereJoin = {

JOIN_MEET_ID: meetId,

JOIN_STATUS: JoinModel.STATUS.SUCC

}

let cntJoin = await JoinModel.count(whereJoin);


// 收藏人数

let FavModel = require('../model/fav_model.js');

let whereFav = {

FAV_OID: meetId,

}

let cntFav = await FavModel.count(whereFav);


// 只返回需要的字段

let ret = {};


ret.cntJoin = cntJoin;

ret.cntFav = cntFav;


ret.MEET_DAYS_SET = getDaysSet;


ret.MEET_FEE = meet.MEET_FEE;

ret.MEET_QR = meet.MEET_QR;

ret.MEET_TITLE = meet.MEET_TITLE;

ret.MEET_CATE_NAME = meet.MEET_CATE_NAME;

ret.MEET_CATE_ID = meet.MEET_CATE_ID;

ret.MEET_OBJ = meet.MEET_OBJ;

ret.MEET_VIEW_CNT = meet.MEET_VIEW_CNT;

ret.cover = await cloudUtil.getTempFileURLOne(meet.MEET_OBJ.cover[0]);

 

return ret;

}



/**  预约前获取关键信息 */

async detailForJoin(userId, meetId, timeMark) {


await this.fixUserMeetJoinPayRecord(userId);


let fields = 'MEET_FEE,MEET_DAYS_SET,MEET_JOIN_FORMS, MEET_TITLE';


let where = {

_id: meetId,

MEET_STATUS: ['in', [MeetModel.STATUS.COMM, MeetModel.STATUS.OVER]]

}

let day = this.getDayByTimeMark(timeMark);

let meet = await this.getMeetOneDay(meetId, day, where, fields);

if (!meet) return null;


let dayDesc = timeUtil.fmtDateCHN(this.getDaySetByTimeMark(meet, timeMark).day);


let timeSet = this.getTimeSetByTimeMark(meet, timeMark);

let timeDesc = timeSet.start + '~' + timeSet.end;

meet.dayDesc = dayDesc + ' ' + timeDesc;


// 取出本人最近一次本时段填写表单

let whereMy = {

JOIN_USER_ID: userId,

}

let orderByMy = {

JOIN_ADD_TIME: 'desc'

}

let joinMy = await JoinModel.getOne(whereMy, 'JOIN_FORMS', orderByMy);



if (joinMy)

meet.myForms = joinMy.JOIN_FORMS;

else

meet.myForms = [];


meet.MEET_FEE = Number(dataUtil.fmtMoney(meet.MEET_FEE / 100));


return meet;

}


/** 获取某天可用时段 */

async getUsefulTimesByDaysSet(meetId, day) {

let where = {

DAY_MEET_ID: meetId,

day

}

let daysSet = await DayModel.getAll(where, 'day,times');

let usefulTimes = [];

for (let k = 0; k < daysSet.length; k++) {

if (daysSet[k].day != day)

continue;


let times = daysSet[k].times;

for (let j in times) {

if (times[j].status != 1) continue;

usefulTimes.push(times[j]);

}

break;


}

return usefulTimes;

}


/** 按天获取预约项目 */

async getMeetListByDay(day) {

let where = {

MEET_STATUS: MeetModel.STATUS.COMM,

};


let orderBy = {

'MEET_ORDER': 'asc',

'MEET_ADD_TIME': 'desc'

};


let fields = 'MEET_TITLE,MEET_DAYS_SET,MEET_OBJ.cover';


let list = await MeetModel.getAll(where, fields, orderBy);


let retList = [];


for (let k = 0; k < list.length; k++) {

let usefulTimes = await this.getUsefulTimesByDaysSet(list[k]._id, day);


if (usefulTimes.length == 0) continue;


let node = {};

node.timeDesc = usefulTimes.length > 1 ? usefulTimes.length + '个时段' : usefulTimes[0].start;

node.title = list[k].MEET_TITLE;

node.pic = list[k].MEET_OBJ.cover;

node._id = list[k]._id;

retList.push(node);


}

return retList;

}


/** 获取从某天开始可预约的日期 */

async getHasDaysFromDay(day) {

let where = {

day: ['>=', day],

};


let fields = 'times,day';

let list = await DayModel.getAllBig(where, fields);


let retList = [];

for (let k = 0; k < list.length; k++) {

for (let n in list[k].times) {

if (list[k].times[n].status == 1) {

retList.push(list[k].day);

break;

}

}

}

return retList;

}


/** 取得预约分页列表 */

async getMeetList({

search, // 搜索条件

sortType, // 搜索菜单

sortVal, // 搜索菜单

orderBy, // 排序 

cateId, //分类查询条件

page,

size,

isTotal = true,

oldTotal

}) {


orderBy = orderBy || {

'MEET_ORDER': 'asc',

'MEET_ADD_TIME': 'desc'

};

let fields = 'MEET_TITLE,MEET_OBJ,MEET_DAYS,MEET_CATE_NAME,MEET_CATE_ID,MEET_FEE';


let where = {};

where.and = {

_pid: this.getProjectId() //复杂的查询在此处标注PID

};


if (cateId && cateId !== '0') where.and.MEET_CATE_ID = cateId;


where.and.MEET_STATUS = ['in', [MeetModel.STATUS.COMM, MeetModel.STATUS.OVER]]; // 状态  


if (util.isDefined(search) && search) {

where.or = [

{ MEET_TITLE: ['like', search] },

];


} else if (sortType && util.isDefined(sortVal)) {

// 搜索菜单

switch (sortType) {

case 'sort': {

orderBy = this.fmtOrderBySort(sortVal, 'NEWS_ADD_TIME');

break;

}

case 'cateId': {

if (sortVal) where.and.MEET_CATE_ID = String(sortVal);

break;

}

}

}

let result = await MeetModel.getList(where, fields, orderBy, page, size, isTotal, oldTotal);


return result;

}




/** 取消我的预约 只有成功可以取消 */

async cancelMyJoin(userId, joinId) {


let where = {

JOIN_USER_ID: userId,

_id: joinId,

JOIN_IS_CHECKIN: 0, // 核销不能取消

JOIN_STATUS: JoinModel.STATUS.SUCC

};

let join = await JoinModel.getOne(where);


if (!join) {

this.AppError('未找到可取消的预约记录');

}


// 取消规则判定

let whereMeet = {

_id: join.JOIN_MEET_ID,

MEET_STATUS: ['in', [MeetModel.STATUS.COMM, MeetModel.STATUS.OVER]]

}

let meet = await this.getMeetOneDay(join.JOIN_MEET_ID, join.JOIN_MEET_DAY, whereMeet);

if (!meet) this.AppError('预约项目不存在或者已关闭');


let daySet = this.getDaySetByTimeMark(meet, join.JOIN_MEET_TIME_MARK);

let timeSet = this.getTimeSetByTimeMark(meet, join.JOIN_MEET_TIME_MARK);

if (!timeSet) this.AppError('被取消的时段不存在');



if (meet.MEET_CANCEL_SET == 0)

this.AppError('该预约不能取消');



let startT = daySet.day + ' ' + timeSet.start + ':00';

let startTime = timeUtil.time2Timestamp(startT);

let now = timeUtil.time();

if (meet.MEET_CANCEL_SET == 2 && now > startTime)

this.AppError('该预约时段已经开始,无法取消');


// TODO 已过期不能取消


if (join.JOIN_PAY_STATUS == 99) {

// 无须支付

// 更新记录 

let data = {

JOIN_STATUS: JoinModel.STATUS.CANCEL,

JOIN_CANCEL_TIME: this._timestamp,

}

await JoinModel.edit(joinId, data);

}

else {

let tradeNo = join.JOIN_PAY_TRADE_NO;

if (!await this.fixMeetJoinPay(tradeNo, join.JOIN_MEET_ID, join.JOIN_MEET_TIME_MARK)) {

this.AppError('该预约记录未支付,已取消并删除!');

}

let payService = new PayService();

await payService.refundPay(tradeNo, '用户取消预约');


// 更新记录 

let data = {

JOIN_STATUS: JoinModel.STATUS.CANCEL,

JOIN_CANCEL_TIME: this._timestamp,

JOIN_PAY_STATUS: 8,

}

await JoinModel.edit(joinId, data);

}


// await JoinModel.del(where); 以前是删除,现在改为取消



// 统计

this.statJoinCnt(join.JOIN_MEET_ID, join.JOIN_MEET_TIME_MARK);


}


/** 取得我的预约详情 */

async getMyJoinDetail(userId, joinId) {


let fields = 'JOIN_PAY_STATUS,JOIN_PAY_FEE,JOIN_COMPLETE_END_TIME,JOIN_IS_CHECKIN,JOIN_CHECKIN_TIME,JOIN_REASON,JOIN_MEET_ID,JOIN_MEET_TITLE,JOIN_MEET_DAY,JOIN_MEET_TIME_START,JOIN_MEET_TIME_END,JOIN_STATUS,JOIN_ADD_TIME,JOIN_CODE,JOIN_FORMS';


let where = {

_id: joinId,

JOIN_USER_ID: userId

};

return await JoinModel.getOne(where, fields);

}


/** 取得我的预约分页列表 */

async getMyJoinList(userId, {

search, // 搜索条件

sortType, // 搜索菜单

sortVal, // 搜索菜单

orderBy, // 排序 

page,

size,

isTotal = true,

oldTotal

}) {


await this.fixUserMeetJoinPayRecord(userId);


orderBy = orderBy || {

// 'JOIN_MEET_DAY': 'desc',

// 'JOIN_MEET_TIME_START': 'desc',

'JOIN_ADD_TIME': 'desc'

};

let fields = 'JOIN_COMPLETE_END_TIME,JOIN_IS_CHECKIN,JOIN_REASON,JOIN_MEET_ID,JOIN_MEET_TITLE,JOIN_MEET_DAY,JOIN_MEET_TIME_START,JOIN_MEET_TIME_END,JOIN_STATUS,JOIN_ADD_TIME,JOIN_OBJ';


let where = {

JOIN_USER_ID: userId

};

//where.MEET_STATUS = ['in', [MeetModel.STATUS.COMM, MeetModel.STATUS.OVER]]; // 状态  


if (util.isDefined(search) && search) {

where['JOIN_MEET_TITLE'] = {

$regex: '.*' + search,

$options: 'i'

};

} else if (sortType) {

// 搜索菜单

switch (sortType) {


case 'cateId': {

if (sortVal) where.JOIN_MEET_CATE_ID = String(sortVal);

break;

}

case 'all': { //所有 

break;

}

case 'use': { //可用未过期

where.JOIN_STATUS = JoinModel.STATUS.SUCC;

where.JOIN_COMPLETE_END_TIME = ['>=', timeUtil.time('Y-M-D h:m')];

break;

}

case 'check': { //已核销

where.JOIN_STATUS = JoinModel.STATUS.SUCC;

where.JOIN_IS_CHECKIN = 1;

break;

}

case 'timeout': { //已过期未核销

where.JOIN_STATUS = JoinModel.STATUS.SUCC;

where.JOIN_IS_CHECKIN = 0;

where.JOIN_COMPLETE_END_TIME = ['<', timeUtil.time('Y-M-D h:m')];

break;

}

case 'succ': { //预约成功

where.JOIN_STATUS = JoinModel.STATUS.SUCC;

//where.JOIN_MEET_DAY = ['>=', timeUtil.time('Y-M-D h:m')];

//where.JOIN_MEET_TIME_START = ['>=', timeUtil.time('h:m')];

break;

}

case 'cancel': { //系统已取消

where.JOIN_STATUS = ['in', [JoinModel.STATUS.ADMIN_CANCEL]];

break;

}

case 'usercancel': { //用户已取消

where.JOIN_STATUS = ['in', [JoinModel.STATUS.CANCEL]];

break;

}

}

}

let result = await JoinModel.getList(where, fields, orderBy, page, size, isTotal, oldTotal);


return result;

}


/** 取得我的某日预约列表 */

async getMyJoinSomeday(userId, day) {


let fields = 'JOIN_IS_CHECKIN,JOIN_MEET_ID,JOIN_MEET_TITLE,JOIN_MEET_DAY,JOIN_MEET_TIME_START,JOIN_MEET_TIME_END,JOIN_STATUS,JOIN_ADD_TIME';


let where = {

JOIN_USER_ID: userId,

JOIN_MEET_DAY: day

};

//where.MEET_STATUS = ['in', [MeetModel.STATUS.COMM, MeetModel.STATUS.OVER]]; // 状态  


let orderBy = {

'JOIN_MEET_TIME_START': 'asc',

'JOIN_ADD_TIME': 'desc'

}


return await JoinModel.getAll(where, fields, orderBy);



}

}


```

#  UI设计





点赞 0
收藏
评论

1 个评论

登录 后发表内容