外卖CPS红包小程序源码分享

外卖cps带分销返利源码

饿了么红包、美团优惠券开发(外卖cps,三级裂变源码)

源代码地址

http://y.mybei.cn

搭建步骤

• 下载以上源代码到本地
  http://y.mybei.cn

截图

步骤

• 下载以上源代码到本地
  http://www.mybei.cn

• 修改为你自己的微信小程序，打开 /dist/pages/ele/index.js
  

• 微信小程序->开发管理->开发设置 添加 request的域名： 地址：
  https://mp.weixin.qq.com/wxamp/devprofile/get_profile?token=271531762&lang=zh_CN
  

• 小程序管理后台配置你的链接
  后台地址： http://q.mybei.cn

• 进去之后选择小程序管理->无裂变小程序管理->添加小程序->填入你自己的链接
  

• 微信开发者工具，导入项目，提交审核
  
  const Base = require(’./base.js’);
  const moment = require(‘moment’);
  const _ = require(‘lodash’);
  // const Jushuitan = require(‘jushuitan’);
  module.exports = class extends Base {
  /**

  • index action

  • @return {Promise} []
    */
    async indexAction() {
    const page = this.get(‘page’) || 1;
    const size = this.get(‘size’) || 10;
    const orderSn = this.get(‘orderSn’) || ‘’;
    const status = this.get(‘status’) || ‘’;
    const userid = this.get(‘userid’) || ‘’;
    let wxapps = []
    let miniapps = await this.model(‘miniapps’).where({sys_userid: userid}).select();
    for(const item of miniapps){
    wxapps.push(item.wx_appid);
    }
    let data = {}
    const model = this.model(‘tb_orders’);
    data = await model.where({
    trade_id: [‘like’, %${orderSn}%],
    status: [‘IN’, status],
    wxappid: [‘IN’, wxapps]
    }).order([‘id DESC’]).page(page, size).countSelect();
    for (const item of data.data) {
    let order_user = await this.model(‘user’).where({
    weixin_openid: item.wx_openid
    }).field(‘nickname,avatar,id’).find()
    item.order_user = order_user;
    if(item.order_user.nickname){
    item.order_user.nickname = Buffer.from(item.order_user.nickname , ‘base64’).toString();
    }

    let arrangement_fees = await this.model(‘tb_orders_arrangement’).where({
    trade_id: item.trade_id
    }).field(‘arrangement_fee, agent_type’).select();

    item.arrangement_fees = arrangement_fees;

    if(item.status == 3)
    item.order_status_text = “已结算”
    if(item.status == 12)
    item.order_status_text = “已付款”
    if(item.status == 13)
    item.order_status_text = “已失效”
    if(item.status == 14)
    item.order_status_text = “已收货”

    // let express = await this.model(‘order_express’).where({
    // order_id: item.id
    // }).find();
    // if (!think.isEmpty(express)) {
    // item.expressInfo = express.shipper_name + express.logistic_code;
    // } else {
    // item.expressInfo = ‘’
    // }
    // // item.button_text = await this.model(‘order’).getOrderBtnText(item.id);
    }
    return this.success(data);
    }

  async meituanOrderAction() {
  const page = this.get(‘page’) || 1;
  const size = this.get(‘size’) || 10;
  const orderSn = this.get(‘orderSn’) || ‘’;
  const status = this.get(‘status’) || ‘’;
  const userid = this.get(‘userid’) || ‘’;
  let wxapps = []
  let miniapps = await this.model(‘miniapps’).where({sys_userid: userid}).select();
  for(const item of miniapps){
  wxapps.push(item.wx_appid);
  }
  let data = {}
  const model = this.model(‘meituan_orders’);
  data = await model.where({
  orderid: [‘like’, %${orderSn}%],
  status: [‘IN’, status],
  wxappid: [‘IN’, wxapps]
  }).order([‘id DESC’]).page(page, size).countSelect();
  for (const item of data.data) {
  let order_user = await this.model(‘user’).where({
  weixin_openid: item.wx_openid
  }).field(‘nickname,avatar,id’).find()
  item.order_user = order_user;
  if(item.order_user.nickname){
  item.order_user.nickname = Buffer.from(item.order_user.nickname , ‘base64’).toString();
  }
  let arrangement_fees = await this.model(‘meituan_orders_arrangement’).where({
  orderid: item.orderid
  }).field(‘arrangement_fee, agent_type’).select();

             item.arrangement_fees = arrangement_fees;//     item.goodsList = await this.model('order_goods').field('goods_name,goods_aka,list_pic_url,number,goods_specifition_name_value,retail_price').where({//         order_id: item.id,//         is_delete: 0//     }).select();//     item.goodsCount = 0;//     item.goodsList.forEach(v => {//         item.goodsCount += v.number;//     });//     let user = await this.model('user').where({//         id: item.user_id//     }).field('nickname,name,mobile,avatar').find();//     if (!think.isEmpty(user)) {//         user.nickname = Buffer.from(user.nickname, 'base64').toString();//     } else {//         user.nickname = '已删除'//     }//     item.userInfo = user;//     let province_name = await this.model('region').where({//         id: item.province//     }).getField('name', true);//     let city_name = await this.model('region').where({//         id: item.city//     }).getField('name', true);//     let district_name = await this.model('region').where({//         id: item.district//     }).getField('name', true);//     item.full_region = province_name + city_name + district_name;//     item.postscript = Buffer.from(item.postscript, 'base64').toString();//     item.add_time = moment.unix(item.add_time).format('YYYY-MM-DD HH:mm:ss');//     if (item.pay_time != 0) {item.paytime = moment.unix(item.paytime).format('YYYY-MM-DD HH:mm:ss');//     } else {//         item.pay_time = 0;//     }if(item.status == 1)item.order_status_text = "已付款"if(item.status == 8)item.order_status_text = "已结算"if(item.status == 9)item.order_status_text = "已失效"//     let express = await this.model('order_express').where({//         order_id: item.id//     }).find();//     if (!think.isEmpty(express)) {//         item.expressInfo = express.shipper_name + express.logistic_code;//     } else {//         item.expressInfo = ''//     }//     // item.button_text = await this.model('order').getOrderBtnText(item.id);}return this.success(data);
  

  }

  async getAutoStatusAction() {
  let status = await this.model(‘settings’).where({
  id: 1
  }).field(‘autoDelivery’).find();
  let info = status.autoDelivery;
  return this.success(info);
  }
  async toDeliveryAction() {
  const page = this.get(‘page’) || 1;
  const size = this.get(‘size’) || 10;
  const status = this.get(‘status’) || ‘’;
  const model = this.model(‘order’);
  const data = await model.where({
  order_status: status,
  }).order([‘id DESC’]).page(page, size).countSelect();
  for (const item of data.data) {
  item.goodsList = await this.model(‘order_goods’).field(‘goods_name,list_pic_url,number,goods_specifition_name_value,retail_price’).where({
  order_id: item.id
  }).select();
  item.goodsCount = 0;
  item.goodsList.forEach(v => {
  item.goodsCount += v.number;
  });
  let province_name = await this.model(‘region’).where({
  id: item.province
  }).getField(‘name’, true);
  let city_name = await this.model(‘region’).where({
  id: item.city
  }).getField(‘name’, true);
  let district_name = await this.model(‘region’).where({
  id: item.district
  }).getField(‘name’, true);
  item.address = province_name + city_name + district_name + item.address;
  item.postscript = Buffer.from(item.postscript, ‘base64’).toString();
  item.add_time = moment.unix(item.add_time).format(‘YYYY-MM-DD HH:mm:ss’);
  item.order_status_text = await this.model(‘order’).getOrderStatusText(item.id);
  item.button_text = await this.model(‘order’).getOrderBtnText(item.id);
  }
  return this.success(data);
  }
  async saveGoodsListAction() {
  // think.logger.info(typeof(data));
  let id = this.post(‘id’);
  let order_id = this.post(‘order_id’);
  let number = this.post(‘number’);
  let price = this.post(‘retail_price’);
  let addOrMinus = this.post(‘addOrMinus’);
  let changePrice = Number(number) * Number(price);
  think.logger.info(order_id);
  think.logger.info(changePrice);
  if (addOrMinus == 0) {
  await this.model(‘order_goods’).where({
  id: id
  }).decrement(‘number’, number);
  await this.model(‘order’).where({
  id: order_id
  }).decrement({
  actual_price: changePrice,
  order_price: changePrice,
  goods_price: changePrice
  });
  let order_sn = this.model(‘order’).generateOrderNumber();
  await this.model(‘order’).where({
  id: order_id
  }).update({
  order_sn: order_sn
  });
  return this.success(order_sn);
  } else if (addOrMinus == 1) {
  await this.model(‘order_goods’).where({
  id: id
  }).increment(‘number’, number);
  await this.model(‘order’).where({
  id: order_id
  }).increment({
  actual_price: changePrice,
  order_price: changePrice,
  goods_price: changePrice
  });
  let order_sn = this.model(‘order’).generateOrderNumber();
  await this.model(‘order’).where({
  id: order_id
  }).update({
  order_sn: order_sn
  });
  return this.success(order_sn);
  }
  }
  async goodsListDeleteAction() {
  think.logger.info(this.post(‘id’));
  let id = this.post(‘id’);
  let order_id = this.post(‘order_id’);
  let number = this.post(‘number’);
  let price = this.post(‘retail_price’);
  let addOrMinus = this.post(‘addOrMinus’);
  let changePrice = Number(number) * Number(price);
  think.logger.info(order_id);
  think.logger.info(changePrice);
  await this.model(‘order_goods’).where({
  id: id
  }).update({
  is_delete: 1
  });
  await this.model(‘order’).where({
  id: order_id
  }).decrement({
  actual_price: changePrice,
  order_price: changePrice,
  goods_price: changePrice
  });
  let order_sn = this.model(‘order’).generateOrderNumber();
  await this.model(‘order’).where({
  id: order_id
  }).update({
  order_sn: order_sn
  });
  return this.success(order_sn);
  }
  async saveAdminMemoAction() {
  const id = this.post(‘id’);
  const text = this.post(‘text’);
  const model = this.model(‘order’);
  let info = {
  admin_memo: text
  }
  let data = await model.where({
  id: id
  }).update(info);
  let orderInfo = await this.model(‘order’).where({
  id: id
  }).find();
  let goods = await this.model(‘order_goods’).where({
  order_id: id
  }).field(‘id,product_id,number,retail_price,list_pic_url’).select();
  let order_goods = [];
  for (const item of goods) {
  let product = await this.model(‘product’).where({
  id: item.product_id
  }).find();
  let data = {
  name: product.goods_name,
  sku_id: product.goods_sn,
  amount: item.retail_price,
  qty: item.number,
  outer_oi_id: item.id,
  pic: item.list_pic_url
  };
  order_goods.push(data);
  }
  return this.success(data);
  }
  async savePrintInfoAction() {
  const id = this.post(‘id’);
  const print_info = this.post(‘print_info’);
  const model = this.model(‘order’);
  let info = {
  print_info: print_info
  };
  let data = await model.where({
  id: id
  }).update(info);
  return this.success(data);
  }
  async saveExpressValueInfoAction() {
  const id = this.post(‘id’);
  const express_value = this.post(‘express_value’);
  const model = this.model(‘order’);
  let info = {
  express_value: express_value
  };
  let data = await model.where({
  id: id
  }).update(info);
  return this.success(data);
  }
  async saveRemarkInfoAction() {
  const id = this.post(‘id’);
  const remark = this.post(‘remark’);
  const model = this.model(‘order’);
  let info = {
  remark: remark
  };
  let data = await model.where({
  id: id
  }).update(info);
  return this.success(data);
  }
  async detailAction() {
  const id = this.get(‘orderId’);
  const model = this.model(‘order’);
  let data = await model.where({
  id: id
  }).find();
  data.goodsList = await this.model(‘order_goods’).field(‘id,product_id,goods_name,goods_aka,list_pic_url,number,goods_specifition_name_value,retail_price,goods_id’).where({
  order_id: data.id,
  is_delete: 0
  }).select();
  data.goodsCount = 0;
  data.goodsList.forEach(v => {
  data.goodsCount += v.number;
  });
  for (const item of data.goodsList) {
  let info = await this.model(‘product’).where({
  id: item.product_id
  }).field(‘goods_sn’).find();
  item.goods_sn = info.goods_sn;
  }
  think.logger.info(data.goodsList);
  let userInfo = await this.model(‘user’).where({
  id: data.user_id
  }).find();
  let _nickname = Buffer.from(userInfo.nickname, ‘base64’).toString();
  data.user_name = _nickname;
  data.avatar = userInfo.avatar;
  let province_name = await this.model(‘region’).where({
  id: data.province
  }).getField(‘name’, true);
  let city_name = await this.model(‘region’).where({
  id: data.city
  }).getField(‘name’, true);
  let district_name = await this.model(‘region’).where({
  id: data.district
  }).getField(‘name’, true);
  data.full_region = province_name + city_name + district_name;
  data.postscript = Buffer.from(data.postscript, ‘base64’).toString();
  data.order_status_text = await this.model(‘order’).getOrderStatusText(data.id);
  data.add_time = moment.unix(data.add_time).format(‘YYYY-MM-DD HH:mm:ss’);
  data.allAddress = data.full_region + data.address;
  if (data.pay_time != 0) {
  data.pay_time = moment.unix(data.pay_time).format(‘YYYY-MM-DD HH:mm:ss’);
  }
  if (data.shipping_time != 0) {
  data.shipping_time = moment.unix(data.shipping_time).format(‘YYYY-MM-DD HH:mm:ss’);
  }
  if (data.confirm_time != 0) {
  data.confirm_time = moment.unix(data.confirm_time).format(‘YYYY-MM-DD HH:mm:ss’);
  }
  if (data.dealdone_time != 0) {
  data.dealdone_time = moment.unix(data.dealdone_time).format(‘YYYY-MM-DD HH:mm:ss’);
  }
  let def = await this.model(‘settings’).where({
  id: 1
  }).find();
  let senderInfo = {}
  let receiveInfo = {}
  receiveInfo = {
  name: data.consignee,
  mobile: data.mobile,
  province: province_name,
  province_id: data.province,
  city: city_name,
  city_id: data.city,
  district: district_name,
  district_id: data.district,
  address: data.address
  }
  senderInfo = {
  name: def.Name,
  mobile: def.Tel,
  province: def.ProvinceName,
  city: def.CityName,
  district: def.ExpAreaName,
  province_id: def.province_id,
  city_id: def.city_id,
  district_id: def.district_id,
  address: def.Address,
  }
  return this.success({
  orderInfo: data,
  receiver: receiveInfo,
  sender: senderInfo
  });
  }
  async getAllRegionAction() { // 我写的算法
  const model = this.model(‘region’);
  const aData = await model.where({
  type: 1
  }).select();
  const bData = await model.where({
  type: 2
  }).select();
  const cData = await model.where({
  type: 3
  }).select();
  let newData = [];
  for (const item of aData) {
  let children = [];
  for (const bitem of bData) {
  let innerChildren = [];
  for (const citem of cData) {
  if (citem.parent_id == bitem.id) {
  innerChildren.push({
  value: citem.id,
  label: citem.name
  })
  }
  }
  if (bitem.parent_id == item.id) {
  children.push({
  value: bitem.id,
  label: bitem.name,
  children: innerChildren
  })
  }
  }
  newData.push({
  value: item.id,
  label: item.name,
  children: children
  });
  }
  return this.success(newData);
  }
  async orderpackAction() {
  const id = this.get(‘orderId’);
  const model = this.model(‘order’);
  const data = await model.where({
  id: id
  }).update({
  order_status: 300
  });
  }
  async orderReceiveAction() {
  const id = this.get(‘orderId’);
  let currentTime = parseInt(new Date().getTime() / 1000);
  const model = this.model(‘order’);
  const data = await model.where({
  id: id
  }).update({
  order_status: 302,
  shipping_time: currentTime
  });
  }
  async orderPriceAction() {
  const id = this.get(‘orderId’);
  const goodsPrice = this.get(‘goodsPrice’);
  const freightPrice = this.get(‘freightPrice’);
  const actualPrice = this.get(‘actualPrice’);
  const model = this.model(‘order’);
  const data = await model.where({
  id: id
  }).find();
  let newData = {
  actual_price: actualPrice,
  freight_price: freightPrice,
  goods_price: goodsPrice,
  order_sn: model.generateOrderNumber()
  }
  await model.where({
  id: id
  }).update(newData);
  }
  async getOrderExpressAction() {
  const orderId = this.post(‘orderId’);
  const latestExpressInfo = await this.model(‘order_express’).getLatestOrderExpressByAli(orderId);
  return this.success(latestExpressInfo);
  }
  async getPrintTestAction() {
  const latestExpressInfo = await this.model(‘order_express’).printExpress();
  return this.success(latestExpressInfo);
  }
  async getMianExpressAction() {
  const orderId = this.post(‘orderId’);
  const sender = this.post(‘sender’);
  const receiver = this.post(‘receiver’);
  think.logger.info(orderId);
  think.logger.info(sender);
  think.logger.info(receiver);
  let senderOptions = sender.senderOptions;
  let receiveOptions = receiver.receiveOptions;
  let senderInfo = {
  Name: sender.name,
  Tel: sender.mobile,
  ProvinceName: await this.model(‘region’).where({
  id: senderOptions[0]
  }).getField(‘name’, true),
  CityName: await this.model(‘region’).where({
  id: senderOptions[1]
  }).getField(‘name’, true),
  ExpAreaName: await this.model(‘region’).where({
  id: senderOptions[2]
  }).getField(‘name’, true),
  Address: sender.address
  };
  let receiverInfo = {
  Name: receiver.name,
  Tel: receiver.mobile,
  ProvinceName: await this.model(‘region’).where({
  id: receiveOptions[0]
  }).getField(‘name’, true),
  CityName: await this.model(‘region’).where({
  id: receiveOptions[1]
  }).getField(‘name’, true),
  ExpAreaName: await this.model(‘region’).where({
  id: receiveOptions[2]
  }).getField(‘name’, true),
  Address: receiver.address
  };
  // 每次重新生成一次订单号，这样，不会出现已经下过单的情况了。
  const expressType = this.post(‘expressType’);
  const latestExpressInfo = await this.model(‘order_express’).getMianExpress(orderId, senderInfo, receiverInfo, expressType);
  think.logger.info(‘lastExpressInfo++++++++++++++++++++++’);
  think.logger.info(latestExpressInfo);
  if (latestExpressInfo.ResultCode == 100) {
  // 获取快递单号成功，然后存入order_express中
  this.orderExpressAdd(latestExpressInfo, orderId)
  }
  return this.success({
  latestExpressInfo: latestExpressInfo,
  sender: senderInfo,
  receiver: receiverInfo
  });
  }
  async rePrintExpressAction() {
  const date = new Date();
  let orderId = this.get(‘orderId’)
  let order_sn = date.getFullYear() + _.padStart(date.getMonth(), 2, ‘0’) + _.padStart(date.getDay(), 2, ‘0’) + _.padStart(date.getHours(), 2, ‘0’) + _.padStart(date.getMinutes(), 2, ‘0’) + _.padStart(date.getSeconds(), 2, ‘0’) + _.random(100000, 999999);
  let info = await this.model(‘order’).where({
  id: orderId
  }).update({
  order_sn: order_sn
  });
  return this.success(info);
  }
  async directPrintExpressAction() {
  let orderId = this.get(‘orderId’)
  let express = await this.model(‘order_express’).where({
  order_id: orderId
  }).find();
  let info = {};
  if (express.express_type < 4) {
  info = await this.model(‘shipper’).where({
  code: ‘SF’
  }).find();
  } else {
  info = await this.model(‘shipper’).where({
  code: ‘YTO’
  }).find();
  }
  express.MonthCode = info.MonthCode;
  express.send_time = moment.unix(express.add_time).format(‘YYYY-MM-DD’);
  return this.success(express);
  }
  async orderExpressAdd(ele, orderId) {
  let currentTime = parseInt(new Date().getTime() / 1000);
  let info = await this.model(‘order_express’).where({
  order_id: orderId
  }).find();
  if (think.isEmpty(info)) {
  let orderInfo = ele.Order;
  let ShipperCode = orderInfo.ShipperCode;
  let logistic_code = orderInfo.LogisticCode;
  let expressType = ele.expressType;
  let region_code = orderInfo.DestinatioCode;
  if (expressType == 4) {
  region_code = orderInfo.MarkDestination;
  }
  const model = this.model(‘order’);
  let kdInfo = await this.model(‘shipper’).where({
  code: ShipperCode
  }).find();
  let kdData = {
  order_id: orderId,
  shipper_id: kdInfo.id,
  shipper_name: kdInfo.name,
  shipper_code: ShipperCode,
  logistic_code: logistic_code,
  region_code: region_code,
  express_type: expressType,
  add_time: currentTime
  };
  await this.model(‘order_express’).add(kdData);
  } else {
  let orderInfo = ele.Order;
  await this.model(‘order_express’).where({
  order_id: orderId
  }).update({
  logistic_code: orderInfo.LogisticCode
  });
  }
  // 如果生成快递单号了。然后又最后没有使用，又去生成快递单号，那么应该重新生成下订单号，用新订单号去生成快递单号，然后update掉旧的order_express
  }
  // 点击打印并发货按钮后，就将订单的状态改成已发货
  async goDeliveryAction() {
  let orderId = this.post(‘order_id’);
  let currentTime = parseInt(new Date().getTime() / 1000);
  let updateData = {
  order_status: 301,
  print_status: 1,
  shipping_status: 1,
  shipping_time: currentTime
  };
  let data = await this.model(‘order’).where({
  id: orderId
  }).update(updateData);
  // 发送服务消息
  let orderInfo = await this.model(‘order’).where({
  id: orderId
  }).field(‘user_id’).find();

    let user = await this.model('user').where({id: orderInfo.user_id}).find();let openId = user.weixin_openid;// 物品名称// 快递单号// 快递公司// 发货时间// 温馨提示let goodsInfo = await this.model('order_goods').where({order_id: orderId}).field('goods_name').select();let express = await this.model('order_express').where({order_id: orderId}).find();// 物品名称let goodsName = '';if (goodsInfo.length == 1) {goodsName = goodsInfo[0].goods_name} else {goodsName = goodsInfo[0].goods_name + '等' + goodsInfo.length + '件商品'}// 支付时间let shippingTime = moment.unix(currentTime).format('YYYY-MM-DD HH:mm:ss');// 订单金额// 订阅消息 请先在微信小程序的官方后台设置好订阅消息模板，然后根据自己的data的字段信息，设置好datalet TEMPLATE_ID = '7mxiXDUG1eDxqq92CgaRDNsXHpeUf9aQ-ar2LbfLvU8'let message = {"touser": openId,"template_id": TEMPLATE_ID,"page": '/pages/ucenter/index/index',"miniprogram_state":"developer","lang":"zh_CN","data": {"thing1": {"value": goodsName},"time6": {"value": shippingTime},"thing3": {"value": express.shipper_name},"character_string4": {"value": express.logistic_code} ,"thing2": {"value": '祝您性福，期待您的再次光临！'}}}const tokenServer = think.service('weixin', 'api');const token = await tokenServer.getAccessToken();const res = await tokenServer.sendMessage(token,message);return this.success();
  

  }
  async goPrintOnlyAction() {
  let orderId = this.post(‘order_id’);
  let updateData = {
  print_status: 1
  };
  let data = await this.model(‘order’).where({
  id: orderId
  }).update(updateData);
  return this.success(data);
  }
  async orderDeliveryAction() {
  const orderId = this.get(‘orderId’);
  const method = this.get(‘method’);
  const deliveryId = this.get(‘shipper’) || 0;
  const logistic_code = this.get(‘logistic_code’) || 0;
  const model = this.model(‘order’);
  let currentTime = parseInt(new Date().getTime() / 1000);
  let expressName = ‘’;
  if (method == 2) {
  let ele = await this.model(‘order_express’).where({
  order_id: orderId
  }).find();
  if (think.isEmpty(ele)) {
  let kdInfo = await this.model(‘shipper’).where({
  id: deliveryId
  }).find();
  expressName = kdInfo.name;
  let kdData = {
  order_id: orderId,
  shipper_id: deliveryId,
  shipper_name: kdInfo.name,
  shipper_code: kdInfo.code,
  logistic_code: logistic_code,
  add_time: currentTime
  };
  await this.model(‘order_express’).add(kdData);
  let updateData = {
  order_status: 301,
  shipping_status: 1,
  shipping_time: currentTime
  };
  await this.model(‘order’).where({
  id: orderId
  }).update(updateData);
  // 发送服务消息
  } else {
  let kdInfo = await this.model(‘shipper’).where({
  id: deliveryId
  }).find();
  expressName = kdInfo.name;
  let kdData = {
  order_id: orderId,
  shipper_id: deliveryId,
  shipper_name: kdInfo.name,
  shipper_code: kdInfo.code,
  logistic_code: logistic_code,
  add_time: currentTime
  }
  await this.model(‘order_express’).where({
  order_id: orderId
  }).update(kdData);
  }
  } else if (method == 3) {
  let updateData = {
  order_status: 301,
  shipping_time: currentTime
  };
  await this.model(‘order’).where({
  id: orderId
  }).update(updateData);
  expressName = ‘自提件’;
  }
  let orderInfo = await this.model(‘order’).where({
  id: orderId
  }).field(‘user_id’).find();
  let user = await this.model(‘user’).where({
  id: orderInfo.user_id
  }).find();
  let openId = user.weixin_openid;
  // 物品名称
  // 快递单号
  // 快递公司
  // 发货时间
  // 温馨提示
  let goodsInfo = await this.model(‘order_goods’).where({
  order_id: orderId
  }).field(‘goods_name’).select();
  // 物品名称
  let goodsName = ‘’;
  if (goodsInfo.length == 1) {
  goodsName = goodsInfo[0].goods_name
  } else {
  goodsName = goodsInfo[0].goods_name + ‘等’ + goodsInfo.length + ‘件商品’
  }
  // 支付时间
  let shippingTime = moment.unix(currentTime).format(‘YYYY-MM-DD HH:mm:ss’);
  // 订单金额
  // 订阅消息 请先在微信小程序的官方后台设置好订阅消息模板，然后根据自己的data的字段信息，设置好data
  let TEMPLATE_ID = ‘7mxiXDUG1eDxqq92CgaRDNsXHpeUf9aQ-ar2LbfLvU8’
  let message = {
  “touser”: openId,
  “template_id”: TEMPLATE_ID,
  “page”: ‘/pages/ucenter/index/index’,
  “miniprogram_state”:“developer”,
  “lang”:“zh_CN”,
  “data”: {
  “thing1”: {
  “value”: goodsName
  },
  “time6”: {
  “value”: shippingTime
  },
  “thing3”: {
  “value”: expressName
  },
  “character_string4”: {
  “value”: logistic_code
  } ,
  “thing2”: {
  “value”: ‘祝您性福，期待您的光临！’
  }
  }
  }
  const tokenServer = think.service(‘weixin’, ‘api’);
  const token = await tokenServer.getAccessToken();
  const res = await tokenServer.sendMessage(token,message);
  }
  async checkExpressAction() {
  const id = this.get(‘orderId’);
  let info = await this.model(‘order_express’).where({
  order_id: id
  }).find();
  if (!think.isEmpty(info)) {
  return this.success(info);
  } else {
  return this.fail(100, ‘没找到’);
  }
  }
  async saveAddressAction() {
  const sn = this.post(‘order_sn’);
  const name = this.post(‘name’);
  const mobile = this.post(‘mobile’);
  const cAddress = this.post(‘cAddress’);
  const addOptions = this.post(‘addOptions’);
  const province = addOptions[0];
  const city = addOptions[1];
  const district = addOptions[2];
  let info = {
  consignee: name,
  mobile: mobile,
  address: cAddress,
  province: province,
  city: city,
  district: district
  }
  const model = this.model(‘order’);
  const data = await model.where({
  order_sn: sn
  }).update(info);
  return this.success(data);
  }
  async storeAction() {
  if (!this.isPost) {
  return false;
  }
  const values = this.post();
  const id = this.post(‘id’);
  const model = this.model(‘order’);
  values.is_show = values.is_show ? 1 : 0;
  values.is_new = values.is_new ? 1 : 0;
  if (id > 0) {
  await model.where({
  id: id
  }).update(values);
  } else {
  delete values.id;
  await model.add(values);
  }
  return this.success(values);
  }
  async changeStatusAction() {
  const orderSn = this.post(‘orderSn’);
  const value = this.post(‘status’);
  const info = await this.model(‘order’).where({
  order_sn: orderSn
  }).update({
  order_status: value
  });
  return this.success(info);
  }
  async destoryAction() {
  const id = this.post(‘id’);
  await this.model(‘order’).where({
  id: id
  }).limit(1).delete();
  // 删除订单商品
  await this.model(‘order_goods’).where({
  order_id: id
  }).delete();
  // TODO 事务，验证订单是否可删除（只有失效的订单才可以删除）
  return this.success();
  }
  async getGoodsSpecificationAction() {
  const goods_id = this.post(‘goods_id’);
  let data = await this.model(‘goods_specification’).where({
  goods_id: goods_id,
  is_delete: 0
  }).field(‘id,value’).select();
  return this.success(data);
  }
  };

外卖优惠券返利分销系统saas系统相关推荐

1. 外卖优惠券返利分销系统外卖返利系统公众号小程序源码saas系统

   外卖优惠券返利分销系统外卖返利系统公众号小程序源码saas系统 外卖优惠券返利分销系统外卖返利系统公众号小程序源码saas系统 我们都知道,目前两家巨头饿了么和美团点外卖都可以获得返现,其中饿了么是返 ...

2. 外卖优惠券返利系统外卖返利公众号搭建cps系统小程序SaaS源码

   外卖优惠券返利系统外卖返利公众号搭建cps系统小程序SaaS源码 美团/饿了么外卖CPS联盟返利公众号小程序裂变核心源码 源代码地址 https://gitee.com/caonima008/coup ...

3. 外卖分销返佣分佣程序外卖cps小程序返利系统外卖项目优惠券返利

   外卖CPS红包小程序源码分享 外卖券外卖省省外卖探探美团饿了么外卖联盟优惠券小程序系统软件开发源码 美团/饿了么外卖CPS联盟返利公众号小程序裂变核心源码 今天和大家分享下外卖CPS项目,这个其实和做 ...

4. 外卖优惠券小程序搭建天天领券返利分销系统公众号返利机器人模式

   外卖分销返佣分佣程序外卖cps小程序返利系统外卖项目优惠券返利 外卖cps带分销返利源码# 源代码地址 http://www.mybei.cn 部署搭建步骤 下载以上源代码到本地 http://www ...

5. 外卖返利系统电影吃喝玩乐团购返利系统外卖探探外卖券儿外卖cps系统saas源码

   外卖返利系统电影吃喝玩乐团购返利系统外卖探探外卖券儿外卖cps系统saas源码 下面是无裂变版本的搭建教程. 源码地址:http://y.mybei.cn 部署步骤 部署后台,填资料 登录后台 htt ...

6. 美团饿了么外卖返利小程序公众号搭建外卖返利分销系统代cps源码

   美团饿了么外卖返利小程序公众号搭建外卖返利分销系统代cps源码 外卖CPS小程序源码分享 饿了么.美团优惠开发(外卖cps,三级裂变源码) 源码或搭建 http://y.mybei.cn/ 截图 功能 ...

7. 惠 每日餐领外卖券外卖优惠券cps系统外卖券CPS系统公众号小程序源码

   外卖cps带分销返利源码 怎么推广"外卖CPS项目"赚佣金? 惠 每日餐领外卖券外卖优惠券cps系统外卖券CPS系统公众号小程序源码 饿了么美团外卖红包小程序搭建教程 源代码地址 ...

8. 专业外卖CPS返利系统-专业外卖CPS返利系统-外卖返利系统-美团饿了么返利系统

   专业外卖CPS返利系统-专业外卖CPS返利系统-外卖返利系统-美团饿了么返利系统 外卖券外卖省省外卖探探美团饿了么外卖联盟优惠券小程序系统软件开发源码 美团/饿了么外卖CPS联盟返利公众号小程序裂变核 ...

9. 【官方正版】2021外卖cps返利系统/外卖小程序公众号/外卖红包裂变系统/美团/饿了么

   分享一个外卖红包小程序小程序源代码,搭建简单. 收益非常可观[滑稽] 错过了淘客联盟,不如抓住外卖的红利期 不会的多看几遍文档教程,这个很容易搭建 电影票+外卖CPS返利项目实操 美团/饿了么外卖CP ...

最新文章

1. 自然语言处理好的 实体分词 及BERT
2. latex教程详细笔记
3. BZOJ 2118: 墨墨的等式（最短路dijkstra+堆）
4. 盘点物联网的4个认知误区
5. 在ASP.NET中对于SESSION的简略说明
6. 【75位联合作者Nature重磅】AI药神：机器学习模型有望提前五年预测白血病！
7. 如何让apache支持php,Apache怎么才能支持PHP程序？
8. active-class属于Vue哪一个modules,有什么作用
9. POJ 1014 Dividing【多重背包+二进制优化】
10. 单元测试框架TestableMock快速入门(三)：校验Mock调用
11. 短视频无水印解析网站源码
12. Excel去掉下划线首字母小写的公式
13. redis实现的分布式锁为啥要设置过期时间？
14. Go 语言开发工具 LiteIDE x22 发布
15. 华为云OBS究竟是什么？
16. C++容器 vector(附代码实例讲解)
17. zabbix之 zabbix server 跟 agent 更换ip地址
18. jsp mysql购物网站a_海来福家具商品交易购物网站的设计(JSP,MySQL)(附答辩记录)
19. sql 2008 数据库每天增量备份，每周完整备份
20. html中常用的三种列表,在html语言中，常用的列表有哪三种

热门文章

1. react配置生产环境和测试环境地址
2. ubuntu14.04 刚安装完成后汉语拼音输入法出错问题的解决办法
3. uni-app HBuilderX 工程转换 vue-cli 工程
4. RobotFramework安装记录
5. 湖南大学与四川大学计算机,四川大学和湖南大学哪个更好一点？都是高校吗？...
6. 在Git中，origin / master与origin master之间有什么区别？
7. R语言如何实现Excel中的数据筛选功能
8. FPGA中亚稳态、异步信号处理、建立和保持时间违例及题目合集
9. maven中archetype(原型)的使用及创建
10. 服务器的创意工坊文件,Steam 创意工坊实现指南