我们是如何从零到一搭建直播小程序的

import { serviceFetch } from 'config/api-roots'
export interface resData<T = any> {
  data: T
  error_msg: string
  dm_error: number
}
/**
 * 获取关注状态接口返回值
 */
interface getFollowStatusApiRes {
  /**
   * 关注状态,0为未关注,1已关注
   */
  follow_status: number
  /**
   * 关注公众号状态，0为未关注，1为已关注
   */
  subscribe_status: number
  /**
   * 是否展示关注按钮,1展示,0不展示
   */
  is_show_follow: number
  /**
   * 头像框
   */
  resource_frame_img: string
}
/**
 * 获取关注状态接口
 */
export const getFollowStatusApi: (params: { target_uid?: number }) => resData<getFollowStatusApiRes> = serviceFetch({
  url: '/api/relation/follow/get_follow_status',
  method: 'POST',
  errorTips: true
})

const ora = require('ora')
const { exec, execSync } = require('child_process')
const inquirer = require('inquirer')
let colors = require('colors')
const ChatBot = require('dingtalk-robot-sender')
const spinner = ora('正在构建...')
const ci = require('miniprogram-ci')
const robot = new ChatBot({
  webhook:
    'https://oapi.dingtalk.com/robot/send?access_token=xxx'
})
spinner.color = 'yellow'
colors.setTheme({
  silly: 'rainbow',
  input: 'grey',
  verbose: 'cyan',
  prompt: 'grey',
  info: 'green',
  data: 'grey',
  help: 'cyan',
  warn: 'yellow',
  debug: 'blue',
  error: 'red'
})
const verMap = {
  '补丁版本递增0.0.1': 'patch',
  '小版本递增0.1.0': 'minor',
  '大版本递增1.0.0': 'major'
}
let selectVersion = ''
const openUrl = 'https://code.inke.cn/xxx'
/**
 * 获取提交人
 */
const lastCommitAuthor = execSync(`git config user.name`).toString().trim()
/**
 * 获取当前分支
 */
const currentBranch = execSync(`git symbolic-ref --short -q HEAD`).toString().trim()
/**
 * git diff
 */
function gitDiff(option, tips) {
  const diff = execSync(`git diff ${option}`).toString().trim() // 获取新增文件
  const arrDiff = diff.split('\n').filter(Boolean)
  if (arrDiff.length) {
    console.log(
      `📛 当前分支 ${currentBranch} 有${tips}，请提交后再执行该命令`.error,
      `📦 ${tips}文件如下: ${arrDiff}`.error
    )
    process.exit(0)
  }
}
/**
 * 检查当前分支是否还有未提交代码
 */
function checkUnCommitedCode() {
  gitDiff('--name-only', '未提交的代码') // diff 是否有新增文件
  gitDiff('--name-only --cached', '未提交的代码') // diff 已添加到缓存区的文件
}
async function buildEnv() {
  checkUnCommitedCode()
  const { buildEnv } = await inquirer.prompt([
    {
      type: 'list',
      name: 'buildEnv',
      message: '请选择构建环境',
      choices: ['test', 'beta', 'online']
    }
  ])
  if (buildEnv === 'online') {
    try {
      execSync(`bash .bin/check.sh`)
    } catch (e) {
      console.log(`有未合并的请求，请先完成合并请求`.red, e.status)
      robot.text('存在未合并的请求，打包失败，请先合并', {
        atMobiles: ['18310536322'],
        isAtAll: false
      })
      process.exit(1)
    }
    const { version } = await inquirer.prompt({
      type: 'list',
      name: 'version',
      default: '补丁版本递增0.0.1',
      message: '选择构建版本类型',
      choices: ['none', '补丁版本递增0.0.1', '小版本递增0.1.0', '大版本递增1.0.0']
    })
    selectVersion = version
    if (version !== 'none') {
      try {
        execSync(`npm version ${verMap[version]} --no-git-tag`)
        console.log(`更新版本号完成`.info)
        execSync('npm run changelog')
        console.log(`生成changelog完成`.info)
      } catch (error) {
        console.log(`更新版本号失败${error}`.error)
      }
    }
  }
  spinner.start()
  exec(`npm run build:weapp:${buildEnv}`, (e, sdtout, sdterr) => {
    const { version: currentVersion } = require('../package.json')
    let noMergeDingContent = `
              打包完成✅
              构建人: ${lastCommitAuthor}
              构建版本: ${currentVersion}
              构建环境: ${buildEnv}
              构建分支: ${currentBranch}
              该版本已自动上传，请在小程序后台选为体验版
            `
    let hasMergeDingContent = `
              打包完成✅
              构建人: ${lastCommitAuthor}
              构建版本: ${currentVersion}
              构建环境: ${buildEnv}
              构建分支: ${currentBranch}
              合并地址: ${openUrl}
              合并请求已创建，辛苦大佬合并～
            `
    spinner.stop()
    if (e) {
      console.log(`构建失败：${e}`.error)
    } else {
      console.log(sdtout)
      console.log(sdterr)
      let content = noMergeDingContent
      let at = {}
      if (buildEnv === 'online') {
        try {
          if (selectVersion !== 'none') {
            content = hasMergeDingContent
            at = {
              atMobiles: ['18310536322'],
              isAtAll: false
            }
          } else {
            content = noMergeDingContent
          }
          if (selectVersion !== 'none') {
            try {
              execSync(`bash .bin/mr.sh`)
              console.log(`创建合并请求完成`.info)
            } catch (e) {
              console.log(`创建合并请求失败`.red, e.status)
            }
          }
        } catch (error) {
          if (selectVersion !== 'none') {
            console.log(`创建合并请求失败${error}`.error)
          }
        }
      }
      robot.text(content, at).then(async res => {
        if (!res.data.errcode) {
          console.log(`钉钉通知完成`.info)
          const project = new ci.Project({
            appid: 'xxxx',
            type: 'miniProgram',
            projectPath: 'build/weapp',
            privateKeyPath: '.bin/private.xxxx.key',
            ignores: ['node_modules/**/*']
          })
          const uploadResult = await ci.upload({
            project,
            version: currentVersion,
            desc: `构建人：${lastCommitAuthor}`,
            setting: {
              es6: false,
              minifyJS: true,
              minifyWXML: true
            },
            onProgressUpdate: console.log
          })
          console.log('自动上传已完成'.green)
        } else {
          console.log(`钉钉通知失败${res.data.errmsg}`.error)
        }
      })
    }
  })
}
buildEnv()

#!/usr/bin

# 提交MR

PROJECT_ID=xxx
PRIVATE_TOKEN="xxx"
# CURRENT_BRANCH=`git symbolic-ref --short -q HEAD`
CURRENT_BRANCH=`git rev-parse HEAD`

echo ${CURRENT_BRANCH}
TIME=$(date "+%Y%m%d%H%M%S")
NEW_BRANCH="TaroBuild-${TIME}"
GITLAB_HOST="https://code.inke.cn"

# 创建分支
curl --request POST --header "PRIVATE-TOKEN: ${PRIVATE_TOKEN}" "${GITLAB_HOST}/api/v4/projects/${PROJECT_ID}/repository/branches?branch=${NEW_BRANCH}&ref=${CURRENT_BRANCH}"
echo "\n提交MR: 添加「${NEW_BRANCH}」分支完成！"

# MR data
DATA="{\"id\":\"${PROJECT_ID}\",\"source_branch\":\"${NEW_BRANCH}\",\"target_branch\":\"master\",\"private_token\":\"${PRIVATE_TOKEN}\",\"title\":\"Script Build Auto Submit Merge Resquest\",\"description\":\"构建自动提交merge request\"}"
# 创建MR
curl -X POST -d "${DATA}" -H "Content-Type: application/json, PRIVATE-TOKEN: ${PRIVATE_TOKEN}" "${GITLAB_HOST}/api/v4/projects/${PROJECT_ID}/merge_requests"
echo "\n提交MR: 提交MR完成！"

#!/usr/bin

PRIVATE_TOKEN="xxx"
GITLAB_HOST="https://code.gitlab.cn"
PROJECT_ID=xxx

MR_LIST=`curl -X GET --header "PRIVATE-TOKEN: ${PRIVATE_TOKEN}" "${GITLAB_HOST}/api/v4/projects/${PROJECT_ID}/merge_requests?state=opened"`
if [ ${MR_LIST} != '[]' ];then
  echo '存在未合并的请求'
  exit 1
else
  echo '继续执行'
fi

/*
 * @Date: 2022-05-30 15:27:36
 * @LastEditors: 王大伟
 * @LastEditTime: 2022-06-15 22:00:21
 */
import Taro from '@tarojs/taro'
export const updateWeapp = (isForce?: boolean): void => {
  function tipModal(updateManager) {
    Taro.showModal({
      title: '更新提示',
      content: '新版本已经准备好，是否马上重启小程序？',
      showCancel: false,
      success: function (res) {
        if (res.confirm) {
          // 新的版本已经下载好，调用 applyUpdate 应用新版本并重启
          updateManager.applyUpdate()
        } else {
          if (isForce) {
            // 新版本的小程序需要等下一次冷启动才会使用，所以让用户强制更新
            tipModal(updateManager)
          }
        }
      }
    })
  }
  if (process.env.TARO_ENV === 'weapp') {
    const updateManager = Taro.getUpdateManager()
    updateManager.onCheckForUpdate(function (res) {
      // 请求完新版本信息的回调
      console.log('是否有新版本: ', res)
      if (res.hasUpdate) {
        updateManager.onUpdateReady(function () {
          console.log('准备好更新')
          tipModal(updateManager)
        })

        updateManager.onUpdateFailed(function () {
          // 新的版本下载失败
          console.log('新的版本下载失败,走自动异步更新')
        })
      }
    })
  }
}

/**
 * webp图片支持检测
 * @returns support 是否支持webp图片
 */
function detectWebp() {
  if (_webpSupport === undefined) {
    let support = false

    try {
      let _wx$getSystemInfoSync = wx.getSystemInfoSync(),
        platform = _wx$getSystemInfoSync.platform,
        system = _wx$getSystemInfoSync.system
      // 检测IOS系统webp支持
      let versionResult = /[0-9.]*$/.exec(system)
      let systemVersion = versionResult ? versionResult[0] : ''
      let iosSystemSupport = platform === 'ios' && !!systemVersion && compareVersion(systemVersion, '14.0') >= 0

      support = platform === 'devtools' || platform === 'android' || iosSystemSupport

      _webpSupport = support
    } catch (e) {
      console.log(e)
      _webpSupport = false
    }
  }
  return _webpSupport
}
function compareVersion(v1, v2) {
  v1 = v1.split('.')
  v2 = v2.split('.')
  const len = Math.max(v1.length, v2.length)
  while (v1.length < len) {
    v1.push('0')
  }
  while (v2.length < len) {
    v2.push('0')
  }
  for (let i = 0; i < len; i++) {
    const num1 = parseInt(v1[i])
    const num2 = parseInt(v2[i])
    if (num1 > num2) {
      return 1
    } else if (num1 < num2) {
      return -1
    }
  }
  return 0
}