save

v2.0/compileServer/generate.js

 /** @format */
 
 const fs = require('fs-extra')
-const CodeGenerateConfig = require('./config')
-const Model = CodeGenerateConfig.model
+const config = require('./config.json')
+const serverTemplatePath = 'templates'
 
 const run = async (gulp, nunjucksRender, rename, nunjucksRenderConfig) => {
-  nunjucksRenderConfig.data = {
-    model: {},
-    config: 111
+  //编译controller.common
+  for (let commonController in config.controllers.common) {
+    await gulp
+      .src(`${serverTemplatePath}/controllers/common/${commonController}.controller.njk`)
+      .pipe(
+        nunjucksRender({
+          ...nunjucksRenderConfig,
+          data: {
+            model: config.controllers.common[commonController]
+          }
+        })
+      )
+      .pipe(rename(`${commonController}.controller.ts`))
+      .pipe(gulp.dest(nunjucksRenderConfig.ServerFullPath + '/controller/common'))
   }
 }
 
-export default {
+module.exports = {
   run
 }
 // module.exports = {

v2.0/compileServer/gulpfile.js

@@ -14,16 +14,6 @@ const ServerFullPath = '../src'
 
 const nunjucksRenderConfig = {
   path: 'templates',
-  envOptions: {
-    tags: {
-      blockStart: '<%',
-      blockEnd: '%>',
-      variableStart: '<$',
-      variableEnd: '$>',
-      commentStart: '<#',
-      commentEnd: '#>'
-    }
-  },
   ext: '.ts',
   ServerFullPath
 }

v2.0/compileServer/templates/controllers/common/awards.controller.njk

+/** @format */
+
+import commonDecorator, { services } from '../../decorator/common'
+import { resultsModel } from '../../sdk'
+import { AwardsService } from '../../service'
+import { PRIZE_TYPE, DRAW_STATUS, CODE_TYPES } from '../../constants'
+import { getToday } from '../../utils/'
+import { CodeType } from 'taobao-mini-sdk/lib/utils/codetypes'
+import { preCheck } from '../../decorator/common/preCheck'
+import { checkActivityTime } from '../../utils/common/check/checkActivityTime'
+
+export interface IPrizeListParams {
+  activityId: string
+}
+
+export interface IReceiveOjectParams {
+  activityId: string
+  id: string
+  name: string
+  phone: string
+  province: string
+  city: string
+  area: string
+  addressDetail: string
+  streetName: string
+}
+
+export interface IReceiveEnameParams {
+  activityId: string
+  id: string
+}
+
+export default class AwardsController {
+  /**
+   *  我的奖品列表
+   */
+  {%- for decorator in model.getMyPrizeList.decorators %}
+  @{{ decorator.type }}Decorator.{{ decorator.name }}([{% for param in decorator.params -%}'{{ param }}',{%- endfor %}])
+  {%- endfor %}
+  @services([AwardsService])
+  async getMyPrizeList(
+    context: IContext<IPrizeListParams>,
+    [awardSer]: [AwardsService]
+  ): Promise<IResult<{ list: IAwards[] }>> {
+    const {
+      openId,
+      data: { activityId }
+    } = context
+
+    const { awardReceiveExpiredTime } = activityInfo
+
+    const myPrizeList = await awardSer.getAwardsInfoList(
+      {
+        openId,
+        activityId,
+        type: { $ne: PRIZE_TYPE.THANKS }
+      },
+      {
+        projection: {
+          _id: 1,
+          name: 1,
+          image: 1,
+          type: 1,
+          drawStatus: 1,
+          shipStatus: 1,
+          receiveName: 1,
+          phone: 1,
+          address: 1,
+          provice: 1,
+          city: 1,
+          area: 1,
+          remark: 1,
+          useUrk: 1,
+          shipCompany: 1,
+          shipNum: 1
+        },
+        sort: {
+          createTime: -1
+        }
+      }
+    )
+
+    return resultsModel.success({
+      list: awardSer.formateMyPrizeList(myPrizeList, awardReceiveExpiredTime)
+    })
+  }
+
+  /**
+   *  领取实物
+   */
+  @checkParams(['activityId', 'id', 'name', 'phone', 'province', 'city', 'area', 'addressDetail', 'streetName'])
+  @services([AwardsService])
+  async receiveObjectPrize(
+    context: IContext<IReceiveOjectParams>,
+    { activityInfo }: IControllerInfos,
+    [awardSer]: [AwardsService]
+  ): Promise<IResult<boolean>> {
+    let { province, city, area, streetName, addressDetail, id, name, phone, activityId } = context.data
+
+    // 若有过期时间，且已过期
+    let { awardReceiveExpiredTime } = activityInfo
+    if (awardReceiveExpiredTime && Date.now() > awardReceiveExpiredTime) {
+      return resultsModel.error(CODE_TYPES.ERROR_PRIZE_EXPIRED)
+    }
+
+    let result = await awardSer.recieveObjectPrize(id, {
+      activityId,
+      province,
+      city,
+      area,
+      streetName,
+      addressDetail,
+      name,
+      phone
+    })
+
+    if ((result as CodeType).code) {
+      return resultsModel.error(result as CodeType)
+    }
+    return resultsModel.success(result as true)
+  }
+
+  /**
+   *  权益重新领取
+   */
+  @checkParams(['activityId', 'id'])
+  @services([AwardsService])
+  async receiveEnamePrize(context: IContext<IReceiveEnameParams>, {}, [awardSer]: [AwardsService]) {
+    let { id, activityId } = context.data
+
+    let result = await awardSer.recieveEnamePrize(id, activityId)
+    if ((result as CodeType).code) {
+      return resultsModel.error(result as CodeType)
+    }
+    if ((result as IAwards).remark) {
+      return resultsModel.error(CODE_TYPES.SYSTEM_ERROR, (result as IAwards).remark)
+    }
+    return resultsModel.success(result)
+  }
+
+  /**
+   *  概率抽奖
+   */
+  @checkParams(['activityId', 'prizeDataType'])
+  @services([AwardsService])
+  @preCheck([checkActivityTime])
+  async drawLotteryPrize(context: IContext<IParams>, { userInfo }: IControllerInfos, [awardSer]: [AwardsService]) {
+    const { openId } = context
+    const { activityId, prizeDataType } = context.data
+
+    // 获取奖池配置
+    const prizesPool = await awardSer.getPrizeConfig({
+      activityId,
+      // 根据需求配置筛选条件
+      prizeDataType
+    })
+
+    const thanksPrize = prizesPool.find(v => v.type === PRIZE_TYPE.THANKS) || {
+      type: PRIZE_TYPE.THANKS,
+      prizeDataType,
+      name: '谢谢参与'
+    }
+
+    // 根据概率获取
+    let prize = await awardSer.getPrizeByProbability(prizesPool)
+
+    // 未找到奖品,降级到谢谢参与
+    if (!prize) {
+      prize = thanksPrize
+    }
+
+    let reduceResult: ICodeType | number = 1
+
+    // 不是积分奖品, 检查是否扣库存
+    if (prize.type !== PRIZE_TYPE.CREDITS && prize.type !== PRIZE_TYPE.THANKS) {
+      reduceResult = await awardSer.reduceStock(prize._id)
+    }
+
+    // 扣库存失败降级到谢谢参与
+    if ((reduceResult as ICodeType)?.code || !reduceResult) {
+      prize = thanksPrize
+    }
+
+    const { type, _id, ename, image, name, useUrl } = prize
+
+    const { userNick } = userInfo
+    let record = {
+      openId,
+      prizeId: _id,
+      activityId,
+      drawStatus: DRAW_STATUS.WAITAWARD,
+      prizeDataType,
+      remark: '',
+      useUrl,
+      type,
+      ename,
+      name,
+      image,
+      userNick,
+      createDay: getToday()
+    }
+
+    // 奖品信息 insert c_awards表
+    const result = await awardSer.addAward(record)
+
+    return resultsModel.success({
+      id: result,
+      type,
+      name,
+      image
+    })
+  }
+}
\ No newline at end of file