123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169 |
- const express = require('express');
- const moment = require('moment');
- const _ = require('lodash');
- const { query, body } = require('express-validator');
- const { onSuccess, fill, createTradeNo, onError } = require('../../../utils');
- const { limit, ORDER_STATUS } = require('../../config');
- const check = require('../../../middleware/check');
- const Order = require('../../../db/models/order');
- const SysUser = require('../../../db/fuxi/sys_user');
- const Teacher = require('../../../db/models/teacher');
- const Course = require('../../../db/models/course');
- const Channel = require('../../../db/models/channel');
- const { Op } = require('sequelize');
- const router = express.Router();
- const _ORDER_STATUS = _.invert(ORDER_STATUS);
- async function fillSingle(data) {
- const { uid, recordId, channel } = data;
- const tdata = await Promise.all([
- SysUser.findOne({ where: { id: uid } }),
- // Teacher.findOne({ where: { id: recordId } }),
- ]);
- data.channelName = '在线支付';
- if (channel) {
- const cdata = await Channel.findOne({ where: { id: channel } });
- data.channelName = cdata.name;
- }
- Object.assign(data, _.pick(tdata[0], ['login', 'phoneNumber']));
- // data.recordName = tdata[1].name;
- // data.recordPhone = tdata[1].phone;
- data.statusStr = _ORDER_STATUS[data.status];
- return data;
- }
- /**
- * showdoc
- * @catalog v1/订单
- * @title 订单列表
- * @description 订单列表接口
- * @method GET
- * @url /master/order/
- * @param page 0 Int 页码: 不传默认取第1页数据,每页20条数据
- * @param id 0 string 订单id
- * @param title 0 string 课程名
- * @param uname 0 string 用户名
- * @param stime 0 string 支付开始时间
- * @param etime 0 string 支付结束时间
- * @param status 0 string 订单状态
- * @param channel 0 string 来源
- * @return {"code":0, "count":1, "data": []}
- * @return_param id string id
- * @return_param cid integer 课程id
- * @return_param title string 课程名
- * @return_param price decimal 支付价格
- * @return_param uid integer 用户id
- * @return_param payAt date 支付时间
- * @return_param channel integer 1在线支付2渠道
- * @return_param createdAt date -
- * @return_param updatedAt date -
- * @remark
- * @number
- */
- router.get('/', async (req, res) => {
- const { page = 0, title, uname, stime, etime, channel } = req.query;
- const where = _.omit(req.query, ['page', 'uname', 'stime', 'etime']);
- if (title) {
- where.title = { [Op.like]: `%${title}` };
- }
- if (stime || etime) {
- where.payAt = {};
- stime && (where.payAt[Op.gte] = moment(stime).startOf('d'));
- etime && (where.payAt[Op.lte] = moment(etime).endOf('d'));
- }
- if (uname) {
- const uList = await SysUser.findAll({
- where: { login: { [Op.like]: `%${uname}` } },
- attributes: ['id'],
- });
- where.uid = { [Op.in]: uList.map(item => item.id) };
- }
- const info = onSuccess();
- info.data = await Order.findAll({ where, limit, offset: page * limit });
- info.data = await fill(info.data, fillSingle);
- if (!page) {
- info.count = await Order.count({ where });
- }
- res.send(info);
- });
- /**
- * showdoc
- * @catalog v1/订单
- * @title 订单详情
- * @description
- * @method GET
- * @url /master/order/:id
- * @param :id 1 STRING 详情ID
- * @return {"code":0, "data": {}}
- * @return_param id string id
- * @return_param cid integer 课程id
- * @return_param price decimal 支付价格
- * @return_param uid integer 用户id
- * @return_param payAt date 支付时间
- * @return_param channel integer 1在线支付2渠道
- * @return_param createdAt date -
- * @return_param updatedAt date -
- * @remark
- * @number
- */
- router.get('/:id', async (req, res) => {
- let data = await Order.findOne({ where: req.params });
- data = await fill(data, fillSingle);
- res.send(onSuccess(data));
- });
- /**
- * showdoc
- * @catalog v1/订单
- * @title 订单添加
- * @description
- * @method POST
- * @url /master/order/
- * @param cid integer 课程id
- * @param uid integer 用户id
- * @param channel integer 1在线支付2渠道
- * @return {"code":0, "data": {}}
- * @remark
- * @number
- */
- router.post('/', check([body([]).notEmpty()]), async (req, res) => {
- const { channel, uid, cid } = req.body;
- const cdata = await Course.findOne({ where: { id: cid } });
- if (!cdata) {
- return onError('课程不存在');
- }
- const { title, price, detailimg, recordId } = cdata;
- const id = createTradeNo();
- const odata = await Order.create({
- id,
- cid,
- uid,
- title,
- detailimg,
- price: 0,
- recordId,
- channel,
- status: ORDER_STATUS.渠道,
- });
- res.send(onSuccess(odata));
- });
- /**
- * showdoc
- * @catalog v1/订单
- * @title 订单删除
- * @description
- * @method DELETE
- * @url /master/order/:id
- * @param :id 1 STRING 详情ID
- * @return {"status":0, "msg": "删除成功"}
- * @remark
- * @number
- */
- router.delete('/:id', async (req, res) => {
- const odata = await Order.findOne({ where: req.params });
- if (odata && odata.channel === 0) {
- return res.send(onError('在线支付订单不可删除'));
- }
- const data = await Order.destroy({ where: req.params, limit: 1 });
- res.send(onSuccess(null, '删除成功'));
- });
- module.exports = router;
|