Merge branch 'develop' of gitee.com:fusenpack/fusenapi into develop

.gitignore

@@ -4,7 +4,7 @@
 *.dll
 *.so
 *.dylib
-
+bin/
 # Test binary, built with `go test -c`
 *.test
 
@@ -13,3 +13,37 @@
 
 # Dependency directories (remove the comment below to include it)
 # vendor/
+
+#vscode 
+
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+!.vscode/*.code-snippets
+
+# Local History for Visual Studio Code
+.history/
+
+# Built Visual Studio Code Extensions
+*.vsix
+
+__debug_bin
+__debug_bin*
+
+.idea
+.vscode
+
+screenlog.*
+*.txt
+
+proxyserver/proxyserver
+
+shared-state
+
+*.zip
+
+vendor
+
+grpc_server/gen

README.md

@@ -3,9 +3,36 @@
 #### 介绍
 新版fusenapi,golang语言，go-zero框架
 
-#### 软件架构
-软件架构说明
+* 首页-登录-注册 
+    + Home 首页 
+    + Sign In 登录
+    + Sign Up 注册
+* 产品列表 - Products 产品列表
+* 产品详情 - Product Details 产品详情
+* 购物车-确认订单-支付成功: 
+    + Cart 购物车  
+    + Order Confirmation 确认订单 
+    + Payment Success 支付成功
+* 设计存储 - saved designs 已保存设计
+* 我的订单 - My Orders 我的订单
+* 我的云仓 - My Cloud Storage 我的云仓
+* 个人中心 - Profile 个人中心
+* 关于我们 - About Us 关于我们
+* 联系我们 - Contact Us 联系我们
+* 常见问题 - FAQ 常见问题
 
+#### 软件架构
+ 
+* 首页-登录-注册: home-user-auth.api
+* 产品列表-产品详情:  product.api  
+* 购物车-确认订单-支付成功: shopping-cart-confirmation.api
+* 设计存储 - designs.api
+* 我的订单 - orders.api
+* 我的云仓 - cloud-storage.api
+* 个人中心 - profile.api
+* 关于我们 - about-us.api
+* 联系我们 - contact-us.api
+* 常见问题 - faq.api
 
 #### 安装教程
 
@@ -15,9 +42,16 @@
 
 #### 使用说明
 
-1.  xxxx
-2.  xxxx
-3.  xxxx
+1.  sh fs_gen_api.sh home-user-auth # 序列化api
+2.  sh fs_gen_mysql_model.sh fs_canteen_type # 根据ddl序列化mysql model
+3.  生成后就是go-zero框架的实现. 主要在logic目录下实现代码.
+4.  Response.Data的结构体 在api文件下定义. 方便rpc以后的接入. 参考现有的例子
+
+#### 规范
+
+sql 的值只能用 ?, 传入. 不能自己拼接. 涉及到sql安全和防注入.
+例子: QueryRow("SELECT * FROM userinfo WHERE username = ? AND password = ?", sename, partname).Scan(&uid, &username, &password)
+
 
 #### 参与贡献
 

about-us.api

@@ -1,23 +0,0 @@
-syntax = "v1"
-
-info (
-	title: // TODO: add title
-	desc: // TODO: add description
-	author: ""
-	email: ""
-)
-
-type request {
-	// TODO: add members here and delete this comment
-	Name string `path:"name,options=you|me"` // parameters are auto validated
-}
-
-type response {
-	// TODO: add members here and delete this comment
-	Message string `json:"message"`
-}
-
-service user-auth {
-	@handler GreetHandler
-	get /greet/from/:name(request) returns (response);
-}

change_port.sh

@@ -0,0 +1,29 @@
+#!/bin/bash
+
+# 定义一个函数来修改每个服务器的配置文件中的端口
+change_port() {
+  server_name=$1
+  port=$2
+  config_file="server/${server_name}/etc/${server_name}.yaml"
+
+  echo "Changing port for $server_name to $port"
+
+  if [ -f "$config_file" ]; then
+    # 使用 sed 将 Port 替换为新的端口
+    sed -i "s/^Port: .*$/Port: $port/" "$config_file"
+  else
+    echo "Configuration file $config_file not found"
+  fi
+}
+
+# 列出所有服务器目录
+server_dirs=("backend" "canteen" "data-transfer" "home-user-auth" "inventory" "map-library" "orders" "product" "product-model" "product-template" "shopping-cart-confirmation" "upload" "webset")
+
+# 初始化端口为 9901
+port=9901
+
+# 遍历服务器目录，修改每个服务器的配置文件中的端口
+for server_dir in "${server_dirs[@]}"; do
+  change_port $server_dir $port
+  port=$((port + 1))
+done

cloud-storage.api

@@ -1,23 +0,0 @@
-syntax = "v1"
-
-info (
-	title: // TODO: add title
-	desc: // TODO: add description
-	author: ""
-	email: ""
-)
-
-type request {
-	// TODO: add members here and delete this comment
-	Name string `path:"name,options=you|me"` // parameters are auto validated
-}
-
-type response {
-	// TODO: add members here and delete this comment
-	Message string `json:"message"`
-}
-
-service user-auth {
-	@handler GreetHandler
-	get /greet/from/:name(request) returns (response);
-}

config_replica_id.sh

@@ -0,0 +1,33 @@
+#!/bin/bash
+
+replica_id=5
+
+change_config(){
+
+  server_name=$1
+  config_file="server/${server_name}/etc/${server_name}.yaml"
+
+  # 无论ReplicaId存在与否,都重置replica_id
+  ((replica_id+=5))
+
+  if ! grep -q "ReplicaId:" "$config_file"; then
+
+    sed -i "s/^Port:.*$/&\nReplicaId: $replica_id/" "$config_file"  
+    echo "Added ReplicaId: $replica_id to $config_file"
+
+  else
+
+    exist_id=$(grep -oP "ReplicaId:\s*\K[0-9]+" "$config_file")
+    sed -i "s/^ReplicaId:.*$/ReplicaId: $replica_id/" "$config_file"
+    echo "Updated ReplicaId to $replica_id in $config_file" 
+
+  fi
+
+}
+
+# 读取server目录,忽略指定的三个目录
+server_dirs=($(cd server && ls | grep -vE "backend|product-model"))
+
+for server_dir in "${server_dirs[@]}"; do
+  change_config $server_dir  
+done

constants/blm_service.go

@@ -0,0 +1,13 @@
+package constants
+
+const (
+	BLMServiceUrlLogoCombine           string = "/LogoCombine"
+	BLMServiceUrlLogoRemovebg          string = "/removebg"
+	BLMServiceUrlLogoFeatureExtraction string = "/FeatureExtraction"
+)
+
+type BLMServiceUrlResult struct {
+	Code string      `json:"code"`
+	Msg  string      `json:"msg"`
+	Data interface{} `json:"data"`
+}

constants/cart.go

@@ -0,0 +1,3 @@
+package constants
+
+const CART_EXPIRE_TIME = 60 //购物车过期时间

constants/cloud_order.go

@@ -0,0 +1,26 @@
+package constants
+
+type cloud int64
+
+// 已下单
+const STATUS_ORDERD cloud = 1
+
+// 运输中
+const STATUS_SHIPPING cloud = 2
+
+// ups待提货
+const STATUS_PICK_UP cloud = 3
+
+// 已到达
+const STATUS_ARRIVAL cloud = 4
+
+/**
+ * 状态对应中文
+ * @var string[]
+ */
+var CloudOrderMap = map[cloud]string{
+	STATUS_ORDERD:   "已下单",
+	STATUS_SHIPPING: "运输中",
+	STATUS_PICK_UP:  "UPS已发货",
+	STATUS_ARRIVAL:  "已到达",
+}

constants/concact_service.go

@@ -0,0 +1,6 @@
+package constants
+
+type ConcactService string
+
+const TYPE_DEFAULT ConcactService = "default"
+const TYPE_ORDER ConcactService = "order"

constants/delivery.go

@@ -0,0 +1,9 @@
+package constants
+
+type DeliveryMethod int64
+
+const (
+	// 配送方式
+	DELIVERY_METHOD_ADDRESS DeliveryMethod = 1 // 直接发货到收获地址
+	DELIVERY_METHOD_CLOUD   DeliveryMethod = 2 // 云仓
+)

constants/domain.go

@@ -0,0 +1,19 @@
+package constants
+
+// api域名
+const API_URL = "https://fusenapi.kayue.cn:8010"
+
+// 后台域名
+const BACK_URL = "http://fusenadmin.kayue.cn:8009"
+
+// h5域名
+const H5_URL = "https://fusenh5.kayue.cn:8011"
+
+// vue域名
+const VUE_URL = "https://fusenh5.kayue.cn:8011"
+
+// 后台v2域名
+const BACKEND_URL = "https://fusenv2admin.kayue.cn:8014/#/"
+
+// 二维码域名
+const QRCODE_URL = "http://qrcode.fusenpack.com/site/go/"

constants/faq.go

@@ -0,0 +1,14 @@
+package constants
+
+type TypeFaq int64
+
+const FAQ_STATUS_ON TypeFaq = 1
+const FAQ_STATUS_OFF TypeFaq = 0
+
+/**
+ * 定义类型
+ */
+const FAQ_TAG_ORDER TypeFaq = 1
+const FAQ_TAG_SHIPPING TypeFaq = 2
+const FAQ_TAG_PAYMENT TypeFaq = 3
+const FAQ_TAG_RETURN TypeFaq = 4

constants/image_cropping.go

@@ -0,0 +1,4 @@
+package constants
+
+// 裁剪尺寸阶梯
+var IMAGE_CROPPING_STEP_SIZE = []int{200, 400, 600, 800}

constants/invoice_html.go

@@ -0,0 +1,301 @@
+package constants
+
+const INVOICE_TEMPLATE_01 = `      
+<!DOCTYPE html>
+<html lang="en">
+
+<head>
+    <meta charset="UTF-8">
+    <meta http-equiv="X-UA-Compatible" content="IE=edge">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Invoice</title>
+    <style>
+        @font-face {
+            font-family: "Montserrat-SemiBold";
+            src: url("https://s3.us-west-1.amazonaws.com/storage.fusenpack.com/b808164b4f7ecc19f560d235db5b1f5b99fe8ab218b606f15debab2b9c4230e2");
+        }
+
+        @font-face {
+            font-family: "Montserrat-Medium";
+            src: url("https://s3.us-west-1.amazonaws.com/storage.fusenpack.com/3d91bbd91ba6fac26b8460a078742b61bfd1e2976311c065f8ac9c5270be6901");
+        }
+
+        @font-face {
+            font-family: "Montserrat-Light";
+            src: url("https://s3.us-west-1.amazonaws.com/storage.fusenpack.com/24e580a4a5afebf94596ec7b6c8d9c8d57f75a5429ee757217da552d5f03e5d1");
+        }
+
+        @font-face {
+            font-family: "Montserrat-Regular";
+            src: url("https://s3.us-west-1.amazonaws.com/storage.fusenpack.com/78072d2cbce0a3f88c01ab2830ba3a453f0968b516388e45e9a6fb5e970450b8");
+        }
+
+        body {
+            margin: 0;
+        }
+
+        .header_warp {
+            background-color: #F8F8FA;
+            padding: 40px 5% 40px 6%;
+        }
+
+        .header_td {
+            width: 50%;
+            font-family: Montserrat-SemiBold;
+        }
+
+        .header_td.logo {
+            vertical-align: top;
+        }
+
+        .header_logo {
+            max-height: 30px;
+            max-width: 100%;
+            margin-top: 10px;
+        }
+
+        .header_td.title {
+            color: #212121;
+            font-weight: 600;
+            font-size: 72px;
+        }
+
+        .information_warp {
+            padding: 60px 5% 60px 6%;
+        }
+
+        .information_td {
+            width: 50%;
+            font-size: 26px;
+            line-height: 39px;
+            font-weight: 300;
+            font-family: Montserrat-Light;
+        }
+
+        .information_td.bill {
+            color: #212121;
+            font-weight: 500;
+            font-family: Montserrat-Medium;
+        }
+
+        .information_td.right {
+            color: #212121;
+        }
+
+        .information_td.info {
+            color: #666666;
+            line-height: 34px;
+        }
+
+        .bill_warp {
+            padding: 0 5% 0 6%;
+        }
+
+        .bill_td {
+            font-size: 26px;
+        }
+
+        .bill_td:first-child {
+            width: 47.59%;
+        }
+
+        .bill_td.title {
+            border-top: 4px solid #333;
+            padding: 26px 0 14px;
+            font-weight: 500;
+            color: #212121;
+            font-family: Montserrat-Medium;
+        }
+
+        .bill_td.info {
+            color: #666;
+            border-bottom: 2px solid #ccc;
+            padding: 16px 0;
+            font-weight: 400;
+            font-family: Montserrat-Light;
+        }
+
+        .bill_td.info:first-child {
+            font-family: Montserrat-Regular;
+        }
+
+        .bill_warp tr:last-child .bill_td.info {
+            border-bottom: none;
+        }
+
+        .total_warp {
+            padding: 28px 5% 48px 0;
+        }
+
+        .total_td {
+            color: #212121;
+            padding: 16px 0 14px;
+            font-size: 24px;
+            font-weight: 500;
+            font-family: Montserrat-Medium;
+        }
+
+        .total_td.info {
+            color: #666;
+            font-weight: 400;
+            font-family: Montserrat-Regular;
+        }
+
+        .total_td.border-dashed {
+            border-bottom: 2px dashed #ccc;
+        }
+
+        .total_td.border-solid {
+            border-bottom: 4px solid #333;
+            padding-bottom: 24px;
+        }
+
+        .total_td.total {
+            padding-top: 24px;
+            font-size: 26px;
+            font-weight: 600;
+            font-family: Montserrat-SemiBold;
+        }
+
+        .notes_warp {
+            padding: 0 5% 0 6%;
+        }
+
+        .notes_td {
+            font-size: 26px;
+            color: #666;
+            font-weight: 300;
+            width: 50%;
+            line-height: 42px;
+            font-family: Montserrat-Light;
+        }
+
+        .notes_td.title {
+            color: #212121;
+            font-weight: 500;
+            font-family: Montserrat-Medium;
+        }
+
+        .notes_td.notes {
+            vertical-align: top;
+        }
+    </style>
+</head>
+
+<body>
+    <!-- header -->
+    <table class="header_warp" border="0" align="center" cellpadding="0" cellspacing="0" width="100%">
+        <tr>
+            <td class="header_td logo" align="left">
+                <img class="header_logo" src="https://fusenapi.kayue.cn:8010/storage/email/logo.png" alt="logo">
+            </td>
+            <td class="header_td title" align="right">Invoice</td>
+        </tr>
+    </table>
+`
+
+const INVOICE_TEMPLATE_02 = `
+    <!-- information -->
+    <table class="information_warp width100" border="0" align="center" cellpadding="0" cellspacing="0">
+        <tr>
+            <td class="information_td bill" align="left">Bill To:</td>
+            <td class="information_td right" align="right">Invoice No. #%v</td>
+        </tr>
+        <tr>
+            <td class="information_td info" align="left">%v</td>
+            <td class="information_td right" align="right">Date: %v</td>
+        </tr>
+        <tr>
+            <td class="information_td info" align="left">%v</td>
+            <td class="information_td" align="right"></td>
+        </tr>
+        <tr>
+            <td class="information_td info" align="left">%v</td>
+            <td class="information_td" align="right"></td>
+        </tr>
+        <tr>
+            <td class="information_td info" align="left">%v</td>
+            <td class="information_td" align="right"></td>
+        </tr>
+    </table>
+`
+const INVOICE_TEMPLATE_03 = `
+    <!-- bill -->
+    <table class="bill_warp width100" border="0" align="center" cellpadding="0" cellspacing="0">
+        <tr>
+            <td class="bill_td title" align="left">Product Name</td>
+            <td class="bill_td title" align="right">Price</td>
+            <td class="bill_td title" align="right">Quantity</td>
+            <td class="bill_td title" align="right">Total</td>
+        </tr>
+        %v
+    </table>
+`
+
+const INVOICE_TEMPLATE_0301 = `
+    <tr>
+        <td class="bill_td info" align="left">%v</td>
+        <td class="bill_td info" align="right">%v</td>
+        <td class="bill_td info" align="right">%v %v</td>
+        <td class="bill_td info" align="right">%v</td>
+    </tr>
+`
+const INVOICE_TEMPLATE_04 = `
+    <!-- total -->
+    <table class="total_warp width50" border="0" align="right" cellpadding="0" cellspacing="0">
+        <tr>
+            <td class="total_td" align="right">Subtotal</td>
+            <td class="total_td info" align="right">%v</td>
+        </tr>
+        <tr>
+            <td class="total_td" align="right">Shipping Fee</td>
+            <td class="total_td info" align="right">Free</td>
+        </tr>
+        <tr>
+            <td class="total_td border-dashed" align="right">Tax</td>
+            <td class="total_td info border-dashed" align="right">%v</td>
+        </tr>
+        <tr>
+            <td class="total_td" align="right">Total</td>
+            <td class="total_td info" align="right">%v</td>
+        </tr>
+        <tr>
+            <td class="total_td border-solid" align="right">%v</td>
+            <td class="total_td info border-solid" align="right">%v</td>
+        </tr>
+        <tr>
+            <td class="total_td total" align="right">%v</td>
+            <td class="total_td total" align="right">%v</td>
+        </tr>
+    </table>
+`
+const INVOICE_TEMPLATE_05 = `
+    <!-- notes -->
+    <table class="notes_warp width100" border="0" align="center" cellpadding="0" cellspacing="0">
+        <tr>
+            <td class="notes_td title" align="left">Payment Method:</td>
+            <td class="notes_td title" align="left">Notes:</td>
+        </tr>
+        <tr>
+            <td class="notes_td" align="left">%v</td>
+            <td class="notes_td notes" align="left" rowspan="2">Thank you for your business !</td>
+        </tr>
+        <tr>
+            <td class="notes_td" align="left">Account No. :%v</td>
+        </tr>
+    </table>
+    `
+const INVOICE_TEMPLATE_06 = `
+</body>
+<style>
+.width50 {
+    width: 50%;
+}
+.width100 {
+    width: 100%;
+}
+</style>
+</html>
+
+
+`

constants/material.go

@@ -0,0 +1,16 @@
+package constants
+
+// 材料类型
+var MAP_MATERIAL = map[int64]string{
+	1:  "paper",
+	2:  "glass",
+	3:  "塑料",
+	4:  "牛皮纸",
+	5:  "单层牛皮纸",
+	6:  "双层牛皮纸",
+	7:  "PET",
+	8:  "瓦楞纸",
+	9:  "厚牛皮纸",
+	10: "卡纸",
+	11: "PP",
+}

constants/min_purchase_box.go

@@ -0,0 +1,6 @@
+package constants
+
+type Purchase int64
+
+// 最低购买箱数
+const MIN_PURCHASE_QUANTITY Purchase = 3

constants/order.go

@@ -0,0 +1,147 @@
+package constants
+
+// 新版订单状态-后台所有
+// 未支付
+// const STATUS_NEW_NOT_PAY = 0
+
+// // 首款已付，尾款待付
+// const STATUS_NEW_PART_PAY = 1
+
+// // 全款已付
+// const STATUS_NEW_PAY_COMPLETED = 2
+
+// // 订单已确认
+// const STATUS_NEW_SURE = 3
+
+// // 订单生产中
+// const STATUS_NEW_PRODUTING = 4
+
+// // 订单生产完成
+// const STATUS_NEW_PRODUT_COMPLETED = 5
+
+// // 订单已到库
+// const STATUS_NEW_ARRIVAL = 6
+
+// // 已发货
+// const STATUS_NEW_DELIVER = 7
+
+// // UPS提货
+// const STATUS_NEW_UPS = 8
+
+// // 已完成
+// const STATUS_NEW_COMPLETED = 9
+
+// // 取消订单
+// const STATUS_NEW_CANCEL = 10
+
+// // 退款中
+// const STATUS_NEW_REFUNDING = 11
+
+// // 退款完成
+// const STATUS_NEW_REFUNDED = 12
+
+// // 订单删除
+// const STATUS_NEW_DELETE = 13
+
+// // 订单关闭
+// const STATUS_NEW_CLOSE = 14
+
+// // 前台订单
+// // 已支付
+// const STATUS_FONT_PAID = 1
+
+// // 生产中
+// const STATUS_FONT_PRODUCTION = 2
+
+// // 运输中
+// const STATUS_FONT_SHIPPED = 3
+
+// // 到达云仓
+// const STATUS_FONT_INVENTORY = 4
+
+// // 订单完成
+// const STATUS_FONT_COMPLETED = 5
+
+// // 订单关闭
+// const STATUS_FONT_CLOSED = 7
+
+// // 云仓完成
+// const STATUS_FONT_COMPLETED_CLOUD = 8
+
+type Order int64
+
+// 订单状态
+const (
+	// 未支付
+	STATUS_NEW_NOT_PAY Order = 0
+	// 首款已付,尾款待付
+	STATUS_NEW_PART_PAY Order = 1
+	// 全款已付
+	STATUS_NEW_PAY_COMPLETED Order = 2
+	// 订单已确认
+	STATUS_NEW_SURE Order = 3
+	// 订单生产中
+	STATUS_NEW_PRODUTING Order = 4
+	// 订单生产完成
+	STATUS_NEW_PRODUT_COMPLETED Order = 5
+	// 订单已到库
+	STATUS_NEW_ARRIVAL Order = 6
+	// 已发货
+	STATUS_NEW_DELIVER Order = 7
+	// UPS提货
+	STATUS_NEW_UPS Order = 8
+	// 已完成
+	STATUS_NEW_COMPLETED Order = 9
+	// 取消订单
+	STATUS_NEW_CANCEL Order = 10
+	// 退款中
+	STATUS_NEW_REFUNDING Order = 11
+	// 退款完成
+	STATUS_NEW_REFUNDED Order = 12
+	// 订单删除
+	STATUS_NEW_DELETE Order = 13
+	// 订单关闭
+	STATUS_NEW_CLOSE Order = 14
+)
+
+// 前台订单状态
+const (
+	// 已支付
+	STATUS_FONT_PAID Order = 1
+	// 生产中
+	STATUS_FONT_PRODUCTION Order = 2
+	// 运输中
+	STATUS_FONT_SHIPPED Order = 3
+	// 到达云仓
+	STATUS_FONT_INVENTORY Order = 4
+	// 订单完成
+	STATUS_FONT_COMPLETED Order = 5
+	// 订单关闭
+	STATUS_FONT_CLOSED Order = 7
+	// 云仓完成
+	STATUS_FONT_COMPLETED_CLOUD Order = 8
+)
+
+type Day int64
+
+// 订单取消时间
+const (
+	CANCLE_ORDER_EXPIRE     Day = 48 * 3600
+	CANCLE_ORDER_EXPIRE_DAY Day = 2 // 2天
+)
+
+// 订单时间配置
+const (
+	ORDER_PRODUCT_DAY         Day = 25 //产品制作周期(天)
+	ORDER_FACTORY_DELIVER_DAY Day = 2  //厂家发货到货代周期(天)
+	ORDER_DELIVER_UPS_DAY     Day = 35 //货代发货至UPS周期(天)
+	ORDER_UPS_TRANS_DAY       Day = 5  //UPS运输周期(天)
+)
+
+const (
+	LOGISTICS_STATUS_DRAW        Order = 1
+	LOGISTICS_STATUS_SHIPPING    Order = 2
+	LOGISTICS_STATUS_UPS         Order = 3
+	LOGISTICS_STATUS_UPS_ARRIVAL Order = 4
+	LOGISTICS_STATUS_ARRIVAL     Order = 5
+)

constants/orders.go

@@ -0,0 +1,149 @@
+package constants
+
+// 订单类型
+const (
+	DELIVERYMETHODDIRECTMAIL   int64 = 1 // 直邮
+	DELIVERYMETHODDSCLOUDSTORE int64 = 2 // 云仓
+)
+
+// 货币
+type Currency string
+
+const (
+	CURRENCYUSD Currency = "usd" // 美金
+)
+
+// 金额单位
+type AmountUnit interface{}
+
+// 汇率单位
+type ExchangeRateUnit interface{}
+
+// 交易方式
+type PayMethods string
+
+const (
+	PAY_METHOD_CARD PayMethods = "CARD" //card
+	PAY_METHOD_VISA PayMethods = "VISA" //visa
+)
+
+// 支付状态
+type PayStatusCode int64
+
+const (
+	PAY_STATUS_UNPAID   PayStatusCode = 10 //10,未支付
+	PAY_STATUS_PAID     PayStatusCode = 20 //20,已支付
+	PAY_STATUS_REFUNDED PayStatusCode = 30 //30,已退款
+)
+
+// 订单支付状态
+type OrderPayStatusCode int64
+
+// 0,未付首款
+// 10,已付首款
+// 20,已退首款
+// 30,已付尾款
+// 40,已退尾款
+const (
+	ORDER_PAY_STATUS_UNPAIDDEPOSIT     OrderPayStatusCode = 0  // 0,未付首款
+	ORDER_PAY_STATUS_PAIDDEPOSIT       OrderPayStatusCode = 10 // 10,已付首款
+	ORDER_PAY_STATUS_REFUNDEDDEPOSIT   OrderPayStatusCode = 20 // 20,已退首款
+	ORDER_PAY_STATUS_PAIDDREMAINING    OrderPayStatusCode = 30 // 30,已付尾款
+	ORDER_PAY_STATUS_REFUNDEDREMAINING OrderPayStatusCode = 40 // 40,已退尾款
+)
+
+// 订单状态
+type OrderStatusCode int64
+
+const (
+	ORDER_STATUS_UNPAIDDEPOSIT OrderStatusCode = 0  // 0,未支付定金
+	ORDER_STATUS_CLOSE         OrderStatusCode = 10 // 10,订单已关闭
+	ORDER_STATUS_COMPLETE      OrderStatusCode = 20 // 20,订单已完成
+	ORDER_STATUS_DELETE        OrderStatusCode = 30 // 20,订单已删除
+
+	ORDER_STATUS_DIRECTMAIL_ORDERED            OrderStatusCode = 10100    // 10100,直邮单--已下单
+	ORDER_STATUS_DIRECTMAIL_ORDEREDMAINING     OrderStatusCode = 10100001 // 10100001,直邮单--已下单--尾款
+	ORDER_STATUS_DIRECTMAIL_CANCEL             OrderStatusCode = 10101    // 10101,直邮单--已取消
+	ORDER_STATUS_DIRECTMAIL_STARTPRODUCTION    OrderStatusCode = 10200    // 10200,直邮单--开始生产
+	ORDER_STATUS_DIRECTMAIL_COMPLETEPRODUCTION OrderStatusCode = 10300    // 10300,直邮单--生产完成
+	ORDER_STATUS_DIRECTMAIL_SHIPPED            OrderStatusCode = 10400    // 10400,直邮单--已发货
+	ORDER_STATUS_DIRECTMAIL_ARRIVED            OrderStatusCode = 10500    // 10500,直邮单--已到达
+
+	ORDER_STATUS_CLOUDSTORE_ORDERED            OrderStatusCode = 20100    // 20100,云仓单--已下单
+	ORDER_STATUS_CLOUDSTORE_ORDEREDMAINING     OrderStatusCode = 20100001 // 20100001,云仓单--已下单-尾款
+	ORDER_STATUS_CLOUDSTORE_CANCEL             OrderStatusCode = 20101    // 20101,云仓单--已取消
+	ORDER_STATUS_CLOUDSTORE_STARTPRODUCTION    OrderStatusCode = 20200    // 20200,云仓单--开始生产
+	ORDER_STATUS_CLOUDSTORE_COMPLETEPRODUCTION OrderStatusCode = 20300    // 20300,云仓单--生产完成
+	ORDER_STATUS_CLOUDSTORE_ARRIVEDWAREHOUSE   OrderStatusCode = 20400    // 20400,云仓单--直达仓库
+)
+
+// 订单状态名称
+var OrderStatusMessage map[OrderStatusCode]string
+
+// 支付状态名称
+var PayStatusMessage map[PayStatusCode]string
+
+// 支付状态名称
+var OrderPayStatusMessage map[OrderPayStatusCode]string
+
+// 订单状态--用户可见--直邮
+var OrderStatusUserDIRECTMAIL []OrderStatusCode
+
+// 订单状态--用户可见--云仓
+var OrderStatusUserCLOUDSTORE []OrderStatusCode
+
+// 订单货币
+var OrderCurrencyMessage map[Currency]string
+
+func init() {
+	// 订单货币
+	OrderCurrencyMessage = make(map[Currency]string, 1)
+	OrderCurrencyMessage[CURRENCYUSD] = "$"
+
+	// 订单状态名称
+	OrderPayStatusMessage = make(map[OrderPayStatusCode]string)
+	OrderPayStatusMessage[ORDER_PAY_STATUS_UNPAIDDEPOSIT] = "Deposit Payment Unpaid"     // 未支付首款
+	OrderPayStatusMessage[ORDER_PAY_STATUS_PAIDDEPOSIT] = "Deposit Payment Paid"         // 已支付首款
+	OrderPayStatusMessage[ORDER_PAY_STATUS_REFUNDEDDEPOSIT] = "Deposit Payment Refunded" // 首款已回退
+	OrderPayStatusMessage[ORDER_PAY_STATUS_PAIDDREMAINING] = "Final Payment Paid"        // 尾款未支付
+	OrderPayStatusMessage[ORDER_PAY_STATUS_REFUNDEDREMAINING] = "Final Payment Refunded" // 已退款
+
+	// 订单状态名称
+	PayStatusMessage = make(map[PayStatusCode]string)
+	PayStatusMessage[PAY_STATUS_UNPAID] = "Unpaid"     // 未支付
+	PayStatusMessage[PAY_STATUS_PAID] = "Paid"         // 已支付
+	PayStatusMessage[PAY_STATUS_REFUNDED] = "Refunded" // 已退款
+
+	// 订单状态名称
+	OrderStatusMessage = make(map[OrderStatusCode]string)
+	OrderStatusMessage[ORDER_STATUS_UNPAIDDEPOSIT] = "Deposit Payment Unpaid" // 首款未支付
+	OrderStatusMessage[ORDER_STATUS_CLOSE] = "Closed"                         // 已关闭
+	OrderStatusMessage[ORDER_STATUS_COMPLETE] = "Completed"                   // 已完成
+	OrderStatusMessage[ORDER_STATUS_DELETE] = "Deleted"                       // 已删除
+
+	OrderStatusMessage[ORDER_STATUS_DIRECTMAIL_ORDERED] = "Ordered"                        // 直邮单--已下单
+	OrderStatusMessage[ORDER_STATUS_DIRECTMAIL_ORDEREDMAINING] = "Final Payment Paid"      // 直邮单--已下单--尾款
+	OrderStatusMessage[ORDER_STATUS_DIRECTMAIL_STARTPRODUCTION] = "Start Production"       // 直邮单--开始生产
+	OrderStatusMessage[ORDER_STATUS_DIRECTMAIL_COMPLETEPRODUCTION] = "Production Complete" // 直邮单--生产完成
+	OrderStatusMessage[ORDER_STATUS_DIRECTMAIL_SHIPPED] = "Shipped"                        // 直邮单--已发货
+	OrderStatusMessage[ORDER_STATUS_DIRECTMAIL_ARRIVED] = "Delivered"                      // 直邮单--已到达
+
+	OrderStatusMessage[ORDER_STATUS_CLOUDSTORE_ORDERED] = "Ordered"                        // 云仓单--已下单
+	OrderStatusMessage[ORDER_STATUS_CLOUDSTORE_ORDEREDMAINING] = "Final Payment Paid"      // 云仓单--已下单-尾款
+	OrderStatusMessage[ORDER_STATUS_CLOUDSTORE_STARTPRODUCTION] = "Start Production"       // 云仓单--开始生产
+	OrderStatusMessage[ORDER_STATUS_CLOUDSTORE_COMPLETEPRODUCTION] = "Production Complete" // 云仓单--生产完成
+	OrderStatusMessage[ORDER_STATUS_CLOUDSTORE_ARRIVEDWAREHOUSE] = "Arrived Inventory"     // 云仓单--直达仓库
+
+	// 订单状态--用户可见--直邮
+	OrderStatusUserDIRECTMAIL = []OrderStatusCode{
+		ORDER_STATUS_UNPAIDDEPOSIT,
+		ORDER_STATUS_DIRECTMAIL_ORDERED, ORDER_STATUS_DIRECTMAIL_STARTPRODUCTION, ORDER_STATUS_DIRECTMAIL_COMPLETEPRODUCTION, ORDER_STATUS_DIRECTMAIL_SHIPPED, ORDER_STATUS_DIRECTMAIL_ARRIVED,
+		ORDER_STATUS_COMPLETE, ORDER_STATUS_CLOSE,
+	}
+	// 订单状态--用户可见--云仓
+	OrderStatusUserCLOUDSTORE = []OrderStatusCode{
+		ORDER_STATUS_UNPAIDDEPOSIT,
+		ORDER_STATUS_CLOUDSTORE_ORDERED, ORDER_STATUS_CLOUDSTORE_STARTPRODUCTION, ORDER_STATUS_CLOUDSTORE_COMPLETEPRODUCTION, ORDER_STATUS_CLOUDSTORE_ARRIVEDWAREHOUSE,
+		ORDER_STATUS_COMPLETE, ORDER_STATUS_CLOSE,
+	}
+}

constants/paging.go

@@ -0,0 +1,13 @@
+package constants
+
+// 分页默认当前页
+const DEFAULT_PAGE = 1
+
+// 默认每页数量
+const DEFAULT_PAGE_SIZE = 20
+
+// 最大每页显示数量
+const MAX_PAGE_SIZE = 300
+
+// 最大分页
+const MAX_PAGE = 100

constants/pay.go

@@ -0,0 +1,22 @@
+package constants
+
+type PayMethod int64
+
+const (
+	PAYMETHOD_STRIPE PayMethod = 1
+	PAYMETHOD_PAYPAL PayMethod = 2
+)
+
+type PayStatus int64
+
+const (
+	PAYSTATUS_SUCCESS   PayStatus = 1
+	PAYSTATUS_UNSUCCESS PayStatus = 0
+)
+
+type PayStage int64
+
+const (
+	PAYSTAGE_DEPOSIT   PayStage = 1 // 首付
+	PAYSTAGE_REMAINING PayStage = 2 // 尾款
+)

constants/product_list_demo.go

@@ -0,0 +1,271 @@
+package constants
+
+// 产品列表demo
+const PRODUCT_LIST_DEMO = `{
+        "ob": {
+            "items": [
+                {
+                    "id": 25,
+                    "sn": "P1ELZGHU",
+                    "title": "Packing box",
+                    "cover": "/icon/icon_25_800.png",
+                    "intro": "打包盒卡纸",
+                    "cover_img": "/uploads/ognhdc6q_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 5,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 28,
+                    "sn": "P9KVYAUS",
+                    "title": "Pizza box",
+                    "cover": "/icon/9dmom0g7_800.png",
+                    "intro": "披萨盒 瓦楞纸",
+                    "cover_img": "/uploads/9xf1olkl_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 1,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 30,
+                    "sn": "PZWDSROX",
+                    "title": "Paper bag with handle",
+                    "cover": "/icon/iz44vraw_800.png",
+                    "intro": "有提手纸袋牛皮纸",
+                    "cover_img": "/uploads/rpwntxcq_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 4,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 20,
+                    "sn": "PNACHNUK",
+                    "title": "Four cups of milk tea cup",
+                    "cover": "/icon/plz43wpo_800.png",
+                    "intro": "卡纸",
+                    "cover_img": "/uploads/9tqgsjqi_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 2,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 19,
+                    "sn": "PHHVEXRW",
+                    "title": "Milk tea cup holder double cup",
+                    "cover": "/icon/ipohmmcj_800.png",
+                    "intro": "奶茶杯托奶茶杯托两杯袋",
+                    "cover_img": "/uploads/57ogzeq5_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 5,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 11,
+                    "sn": "P7N4D0MK",
+                    "title": "Cup double layer",
+                    "cover": "/icon/nrmzz4du_800.png",
+                    "intro": "牛皮纸双层",
+                    "cover_img": "/uploads/oqjm5own_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 5,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 33,
+                    "sn": "P0NFP19Y",
+                    "title": "High paper bowl",
+                    "cover": "/icon/cla4k6om_800.png",
+                    "intro": "牛皮纸",
+                    "cover_img": "/uploads/dt1qjkzg_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 4,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 32,
+                    "sn": "PDZ3HIUL",
+                    "title": "Flat paper bowl",
+                    "cover": "/icon/jy14adqz_800.png",
+                    "intro": "牛皮纸",
+                    "cover_img": "/uploads/bzwbxduc_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 3,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 31,
+                    "sn": "PEVSMU7I",
+                    "title": "Paper bag without handle",
+                    "cover": "/icon/osdsegor_800.png",
+                    "intro": "牛皮纸",
+                    "cover_img": "/uploads/ouvayny7_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 2,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 29,
+                    "sn": "P58ZZOTI",
+                    "title": "plastic bag",
+                    "cover": "/icon/dvsvddks_800.png",
+                    "intro": "塑料袋",
+                    "cover_img": "/uploads/qvvuzkzx_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 1,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 24,
+                    "sn": "PG7XIXII",
+                    "title": "Hamburger box",
+                    "cover": "/icon/icon_24_800.png",
+                    "intro": "汉堡盒 卡纸",
+                    "cover_img": "/uploads/fm1itgge_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 4,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 23,
+                    "sn": "PIJ2OVUE",
+                    "title": "Milk tea ring portable double cup",
+                    "cover": "/icon/nxb6hjln_800.png",
+                    "intro": "卡纸",
+                    "cover_img": "/uploads/52fash1n_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 4,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 21,
+                    "sn": "PMHXGUL6",
+                    "title": "Milk tea ring portable single cup",
+                    "cover": "/icon/qoaf5mtp_800.png",
+                    "intro": "卡纸",
+                    "cover_img": "/uploads/epvkzvyf_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 5,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 18,
+                    "sn": "PFCM8KNF",
+                    "title": "Tableware set chopsticks",
+                    "cover": "/icon/tcspod4b_800.png",
+                    "intro": "餐具套装筷子厚牛皮纸包装",
+                    "cover_img": "/uploads/5jgrgzvh_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 3,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 17,
+                    "sn": "PQKIQMIK",
+                    "title": "Tableware set four piece set",
+                    "cover": "/icon/mdo0vu1u_800.png",
+                    "intro": "牛皮纸包装",
+                    "cover_img": "/uploads/szsekvbw_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 4,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 16,
+                    "sn": "PBFOIOFH",
+                    "title": "Tableware set four piece set",
+                    "cover": "/icon/dzrf59cp_800.png",
+                    "intro": "餐具套装",
+                    "cover_img": "/uploads/svfoebf1_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 1,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 15,
+                    "sn": "P02V10AB",
+                    "title": "  Hot drink cup holder",
+                    "cover": "/icon/icon_15_800.png",
+                    "intro": "杯托、瓦楞纸",
+                    "cover_img": "/uploads/4qbdid7i_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 5,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 13,
+                    "sn": "PER6WLAV",
+                    "title": "  Cup pet",
+                    "cover": "/icon/icon_13_800.png",
+                    "intro": "pet",
+                    "cover_img": "/uploads/kfxehwjd_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 1,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 12,
+                    "sn": "PGFWRMAU",
+                    "title": "  Cup PP",
+                    "cover": "/icon/icon_12_800.png",
+                    "intro": "pp",
+                    "cover_img": "/uploads/azp8uwhz_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 2,
+                    "miniPrice": 2
+                },
+                {
+                    "id": 10,
+                    "sn": "P4ZXDVHS",
+                    "title": "Cup monolayer",
+                    "cover": "/icon/icon_10_800.png",
+                    "intro": "牛皮纸单层",
+                    "cover_img": "/uploads/onuzax6l_800.png",
+                    "isEnv": 1,
+                    "isMicro": 1,
+                    "sizeNum": 1,
+                    "miniPrice": 2
+                }
+            ],
+            "_links": {
+                "self": {
+                    "href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=1&is_demo=1"
+                },
+                "first": {
+                    "href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=1&is_demo=1"
+                },
+                "last": {
+                    "href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=2&is_demo=1"
+                },
+                "next": {
+                    "href": "https://fusenapi.kayue.cn:8010/product/list?cid=13&size=620&page=2&is_demo=1"
+                }
+            },
+            "_meta": {
+                "totalCount": 21,
+                "pageCount": 2,
+                "currentPage": 1,
+                "perPage": 20
+            }
+        },
+        "typeName": "Boxes",
+        "description": ""
+    }`

constants/product_model3d.go

@@ -0,0 +1,5 @@
+package constants
+
+const TAG_MODEL = 1 //模型
+const TAG_PARTS = 2 //配件
+const TAG_SCENE = 3 //场景

constants/queue.go

@@ -0,0 +1,5 @@
+package constants
+
+const (
+	QUEUE_NAME_ORDER = "queue_order"
+)

constants/rabbitmq.go

@@ -0,0 +1,19 @@
+package constants
+
+type RABBIT_MQ string
+
+// 消息队列队列名
+const (
+//组装渲染数据队列
+/*RABBIT_MQ_ASSEMBLE_RENDER_DATA RABBIT_MQ = "RABBIT_MQ_ASSEMBLE_RENDER_DATA"
+//渲染结果数据队列
+RABBIT_MQ_RENDER_RESULT_DATA RABBIT_MQ = "RABBIT_MQ_RENDER_RESULT_DATA"*/
+)
+
+// 队列列表
+var MqQueueArr = []RABBIT_MQ{
+	/*
+	   RABBIT_MQ_ASSEMBLE_RENDER_DATA,
+	   RABBIT_MQ_RENDER_RESULT_DATA,
+	*/
+}

constants/render.go

@@ -0,0 +1,203 @@
+package constants
+
+// 渲染要用到的面片模板(以前的模板)
+const RENDER_FACE_SLICE_TEMPLATE_JSON = `[ 
+  { 
+    "id": "", 
+    "tag": "MainColor", 
+    "title": "", 
+    "type": "color", 
+    "text": "", 
+    "fill": "{{MainColorFill}}", 
+    "fontSize": 20, 
+    "fontFamily": "Aqum2SmallCaps3", 
+    "ifBr": false, 
+    "ifShow": true, 
+    "ifGroup": false, 
+    "maxNum": 50, 
+    "rotation": 0, 
+    "lineHeight": 1, 
+    "align": "center", 
+    "verticalAlign": "middle", 
+    "material": "", 
+    "materialTime": "", 
+    "materialName": "", 
+    "QRcodeType": "", 
+    "width": 1024, 
+    "height": 1024, 
+    "proportion": 60, 
+    "x": 0, 
+    "y": 0, 
+    "opacity": 1, 
+    "optionalColor": [ 
+      { 
+        "color": "#000000", 
+        "name": "Black", 
+        "default": true 
+      } 
+    ], 
+    "zIndex": 1, 
+    "svgPath": "", 
+    "follow": { 
+      "fill": "", 
+      "ifShow": "", 
+      "content": "" 
+    }, 
+    "group": [], 
+    "cameraStand": { 
+      "x": 0, 
+      "y": 0, 
+      "z": 0 
+    } 
+  }, 
+  { 
+    "id": "", 
+    "tag": "SecondaryColor", 
+    "title": "贴图3", 
+    "type": "color", 
+    "text": "", 
+    "fill": "{{SecondaryColorFill}}", 
+    "fontSize": 20, 
+    "fontFamily": "Aqum2SmallCaps3", 
+    "ifBr": false, 
+    "ifShow": true, 
+    "ifGroup": false, 
+    "maxNum": 50, 
+    "rotation": 0, 
+    "lineHeight": 1, 
+    "align": "center", 
+    "verticalAlign": "middle", 
+    "material": "", 
+    "materialTime": "", 
+    "materialName": "", 
+    "QRcodeType": "", 
+    "width": 1024, 
+    "height": 1024, 
+    "proportion": 60, 
+    "x": 0, 
+    "y": 0, 
+    "opacity": 1, 
+    "optionalColor": [ 
+      { 
+        "color": "#000000", 
+        "name": "Black", 
+        "default": true 
+      } 
+    ], 
+    "zIndex": 2, 
+    "svgPath": "", 
+    "follow": { 
+      "fill": "", 
+      "ifShow": "", 
+      "content": "" 
+    }, 
+    "group": [], 
+    "cameraStand": { 
+      "x": 0, 
+      "y": 0, 
+      "z": 0 
+    } 
+  }, 
+  { 
+    "id": "569d7981-25c3-3c03-0e7e-800c14800362", 
+    "tag": "Slogan", 
+    "title": "贴图4", 
+    "type": "text", 
+    "text": "", 
+    "fill": "", 
+    "fontSize": 13, 
+    "fontFamily": "MontserratBold3", 
+    "ifBr": false, 
+    "ifShow": true, 
+    "ifGroup": false, 
+    "maxNum": 50, 
+    "rotation": 0, 
+    "lineHeight": 1, 
+    "align": "center", 
+    "verticalAlign": "middle", 
+    "material": "", 
+    "materialTime": "", 
+    "materialName": "", 
+    "QRcodeType": "", 
+    "width": 309.9999999999993, 
+    "height": 11.999265664648076, 
+    "proportion": 60, 
+    "x": 97.0015259021898, 
+    "y": 575.300725990631, 
+    "opacity": 1, 
+    "optionalColor": [ 
+      { 
+        "color": "#000000", 
+        "name": "Black", 
+        "default": true 
+      } 
+    ], 
+    "zIndex": 3, 
+    "svgPath": "", 
+    "follow": { 
+      "fill": "38c09538-937d-510c-bf32-bfb1ce90cafa", 
+      "ifShow": "", 
+      "content": "" 
+    }, 
+    "group": [], 
+    "cameraStand": { 
+      "x": 0, 
+      "y": 0, 
+      "z": 45 
+    } 
+  }, 
+  { 
+    "id": "c466e27c-d48f-db86-b85f-3c4c51114046", 
+    "tag": "Logo", 
+    "title": "贴图8", 
+    "type": "image", 
+    "text": "", 
+    "fill": "#0082ca", 
+    "fontSize": 20, 
+    "fontFamily": "Aqum2SmallCaps3", 
+    "ifBr": false, 
+    "ifShow": true, 
+    "ifGroup": false, 
+    "maxNum": 50, 
+    "rotation": 0, 
+    "lineHeight": 1, 
+    "align": "center", 
+    "verticalAlign": "middle", 
+    "material": "{{LogoMaterial}}", 
+    "materialTime": "", 
+    "materialName": "", 
+    "QRcodeType": "", 
+    "width": 282.9999999999999, 
+    "height": 95.99999999999933, 
+    "proportion": 60, 
+    "x": 110.99999999999982, 
+    "y": 438.7192999999991, 
+    "opacity": 1, 
+    "optionalColor": [ 
+      { 
+        "color": "#000000", 
+        "name": "Black", 
+        "default": false 
+      }, 
+      { 
+        "name": "MainColor", 
+        "color": "#0082ca", 
+        "default": true 
+      } 
+    ], 
+    "zIndex": 7, 
+    "svgPath": "", 
+    "follow": { 
+      "fill": "", 
+      "ifShow": "", 
+      "content": "" 
+    }, 
+    "group": [], 
+    "cameraStand": { 
+      "x": 0, 
+      "y": 0, 
+      "z": 0 
+    } 
+  } 
+]
+`

constants/tag_level.go

@@ -0,0 +1,14 @@
+package constants
+
+// tag分类等级
+const (
+	TYPE_QRCODE      = iota + 1 //1
+	TYPE_WEBSITE                //2
+	TYPE_DESIGN_TOOL            //3
+)
+
+var MAP_TAG_LEVEL = map[int]string{
+	TYPE_QRCODE:      "二维码分类",
+	TYPE_WEBSITE:     "网站目录",
+	TYPE_DESIGN_TOOL: "设计工具",
+}

constants/webset.go

@@ -0,0 +1,28 @@
+package constants
+
+type TypeWebSet string
+
+const (
+	FONT_CONFIG   TypeWebSet = "font_config" //字体
+	POLICY_CONFIG TypeWebSet = "policy"      //政策
+	CLAUSE_CONFIG TypeWebSet = "clause"      //条款
+	FAQ_CONFIG    TypeWebSet = "faq"         //问答
+
+	RECOMMEND_DETAIL_PRODUCT TypeWebSet = "recommend_detail_" //详情页推荐-后街pid
+	RENDER_DESIGN            TypeWebSet = "render_design_"    //云渲染 后接client_no
+	LAST_DESIGN              TypeWebSet = "last_design_"      //最后设计 后接uid
+	OTHER_LIST               TypeWebSet = "other_list_"       //列表页其他列表 后接type 分类id
+	PRODUCT_INFO             TypeWebSet = "product_info_"     //详情数据 后接sn
+	MODEL_DATA               TypeWebSet = "model_data"        //所有模型数据
+	TEMPLATE_PRODUCT         TypeWebSet = "product_template_" //模板数据 后接产品id
+	CART_NUM                 TypeWebSet = "cart_num_"         //购物车数量 后接uid
+	USER_ORDERNO             TypeWebSet = "order_no_"         //用户最新订单编号
+
+	WEBSET_TIME_INFO TypeWebSet = "time_info" //配置时间
+
+	WEBSET_TIME_INFO_PRODUCT_DAY         TypeWebSet = "product_day"         //配置时间--产品制作周期(天)
+	WEBSET_TIME_INFO_FACTORY_DELIVER_DAY TypeWebSet = "factory_deliver_day" //配置时间--厂家发货到货代周期(天)
+	WEBSET_TIME_INFO_DELIVER_UPS_DAY     TypeWebSet = "deliver_ups_day"     //配置时间--货代发货至UPS周期(天)
+	WEBSET_TIME_INFO_UPS_TRANS_DAY       TypeWebSet = "ups_trans_day"       //配置时间--UPS运输周期(天)
+
+)

constants/websocket.go

@@ -0,0 +1,35 @@
+package constants
+
+type Websocket string
+
+// websocket消息类型(主类别)
+const (
+	WEBSOCKET_UNAUTH          Websocket = "WEBSOCKET_UNAUTH"          //鉴权失败 （1级消息，单向通信）
+	WEBSOCKET_CONNECT_ERR     Websocket = "WEBSOCKET_CONNECT_ERR"     //ws连接错误 （1级消息，单向通信）
+	WEBSOCKET_CONNECT_SUCCESS Websocket = "WEBSOCKET_CONNECT_SUCCESS" //ws连接成功 （1级消息，单向通信）
+)
+
+// websocket消息类型(通用通知类别)
+const (
+	WEBSOCKET_COMMON_NOTIFY Websocket = "WEBSOCKET_COMMON_NOTIFY" //通用回调通知（1级消息，单向通信）
+)
+
+// websocket消息类型(基本传输结构类别)
+const (
+	WEBSOCKET_ERR_DATA_FORMAT Websocket = "WEBSOCKET_ERR_DATA_FORMAT" //传入数据格式错误（1级消息，单向通信）
+)
+
+// websocket消息类型(云渲染类别)
+const (
+	WEBSOCKET_RENDER_IMAGE                  Websocket = "WEBSOCKET_RENDER_IMAGE"                  //图片渲染消息(1级消息，双向通信)
+	WEBSOCKET_RENDER_IMAGE_ERR              Websocket = "WEBSOCKET_RENDER_IMAGE_ERR"              //图片渲染失败消息（1级消息，单向通信）
+	WEBSOCKET_COMBINE_IMAGE                 Websocket = "WEBSOCKET_COMBINE_IMAGE"                 //反回合成刀版图消息（2级消息，单向通信，属于 WEBSOCKET_RENDER_IMAGE 消息的子流程）
+	WEBSOCKET_ASSEMBLE_RENDER_DATA          Websocket = "WEBSOCKET_ASSEMBLE_RENDER_DATA"          //组装unity需要的数据 （2级消息，单向通信，属于 WEBSOCKET_RENDER_IMAGE 消息的子流程）
+	WEBSOCKET_SEND_DATA_TO_UNITY            Websocket = "WEBSOCKET_SEND_DATA_TO_UNITY"            //发送到unity进行渲染 （2级消息，单向通信，属于 WEBSOCKET_RENDER_IMAGE 消息的子流程）
+	WEBSOCKET_REQUIRE_BROWSER_RESEND_RENDER Websocket = "WEBSOCKET_REQUIRE_BROWSER_RESEND_RENDER" //后端请求前端去重发渲染任务事件（2级消息，单向通信，属于 WEBSOCKET_RENDER_IMAGE 消息的子流程）
+)
+
+// websocket消息类型（系统数据变更通知）
+const (
+	WEBSOCKET_SYSTEM_DATA_UPDATE_NOTIFY Websocket = "WEBSOCKET_SYSTEM_DATA_UPDATE_NOTIFY" //系统数据更新(1级消息，单向通信)
+)

contact-us.api

@@ -1,23 +0,0 @@
-syntax = "v1"
-
-info (
-	title: // TODO: add title
-	desc: // TODO: add description
-	author: ""
-	email: ""
-)
-
-type request {
-	// TODO: add members here and delete this comment
-	Name string `path:"name,options=you|me"` // parameters are auto validated
-}
-
-type response {
-	// TODO: add members here and delete this comment
-	Message string `json:"message"`
-}
-
-service user-auth {
-	@handler GreetHandler
-	get /greet/from/:name(request) returns (response);
-}

data-transfer.api

@@ -1,23 +0,0 @@
-syntax = "v1"
-
-info (
-	title: // 个人文件传输
-	desc: // 图片,pdf,设计logo等
-	author: ""
-	email: ""
-)
-
-type request {
-	// TODO: add members here and delete this comment
-	Name string `path:"name,options=you|me"` // parameters are auto validated
-}
-
-type response {
-	// TODO: add members here and delete this comment
-	Message string `json:"message"`
-}
-
-service user-auth {
-	@handler GreetHandler
-	get /greet/from/:name(request) returns (response);
-}

designs.api

@@ -1,23 +0,0 @@
-syntax = "v1"
-
-info (
-	title: // TODO: add title
-	desc: // TODO: add description
-	author: ""
-	email: ""
-)
-
-type request {
-	// TODO: add members here and delete this comment
-	Name string `path:"name,options=you|me"` // parameters are auto validated
-}
-
-type response {
-	// TODO: add members here and delete this comment
-	Message string `json:"message"`
-}
-
-service user-auth {
-	@handler GreetHandler
-	get /greet/from/:name(request) returns (response);
-}

env.yaml

@@ -0,0 +1,15 @@
+nacos:
+  - server.fusen.3718.cn:8848
+  - server.fusen.3718.cn:8849
+username: ...
+password: ...
+namespace: fs_server_api_dev
+group: FS-SERVER-API
+
+proxyserver:
+  key: /opt/server.dev.fusenpack.com.key
+  pem: /opt/server.dev.fusenpack.com.pem
+
+serverbackend:
+  key: /opt/serverbackend.dev.fusenpack.com.key
+  pem: /opt/serverbackend.dev.fusenpack.com.pem

faq.api

@@ -1,23 +0,0 @@
-syntax = "v1"
-
-info (
-	title: // TODO: add title
-	desc: // TODO: add description
-	author: ""
-	email: ""
-)
-
-type request {
-	// TODO: add members here and delete this comment
-	Name string `path:"name,options=you|me"` // parameters are auto validated
-}
-
-type response {
-	// TODO: add members here and delete this comment
-	Message string `json:"message"`
-}
-
-service user-auth {
-	@handler GreetHandler
-	get /greet/from/:name(request) returns (response);
-}

fs_gen_api.sh

@@ -0,0 +1,36 @@
+#!/bin/bash
+name=${1%%\\*}
+
+excluded_names=("backend" "product-template" "product-model" "basic")
+
+for excluded_name in "${excluded_names[@]}"; do
+    if [ "$name" = "$excluded_name" ]; then
+        echo "不能在$name里使用"
+        exit
+    fi
+done
+
+echo $name
+goctl api go -api server_api/$name.api -dir server/$name --home ./goctl_template/
+
+# # List of API filenames without the '.api' extension
+# api_names=("backend" "canteen" "home-user-auth" "map-library" "product" "product-template" "shopping-cart-confirmation" "webset" "data-transfer" "inventory" "orders" "product-model" "render" "upload" "assistant")
+
+# # Iterate over API filenames and generate Go code, excluding certain names
+# for api_name in "${api_names[@]}"; do
+#     skip=false
+
+#     for excluded_name in "${excluded_names[@]}"; do
+#         if [ "$api_name" = "$excluded_name" ]; then
+#             skip=true
+#             break
+#         fi
+#     done
+
+#     if [ "$skip" = true ]; then
+#         continue
+#     fi
+
+#     echo "Generating Go code for $api_name"
+#     goctl api go -api server_api/"$api_name".api -dir server/"$api_name" --home ./goctl_template/
+# done

fs_gen_api_backend.sh

@@ -0,0 +1,14 @@
+#! /bin/bash
+name=${1%%\\*}
+options=("backend" "product-template" "product-template-tag" "product-model")
+for option in "${options[@]}"; do
+    if [ "$name" = "$option" ]; then 
+        echo $name 
+        goctl api go -api server_api/$name.api -dir server/$name --home ./goctl_template_backend/
+        exit
+    fi 
+done
+
+for option in "${options[@]}"; do
+    echo "只支持 $option"
+done

fs_gen_mysql_model.sh

@@ -0,0 +1,9 @@
+#! /bin/bash
+# goctl model mysql ddl --src ./ddl/$1.sql --dir model/ --home ./goctl_template
+if [ $# -gt 0 ]  
+then
+  name=${1%%\\*}
+  go run generator/main.go -name $name
+else
+  echo "输入: - 表示所有表. 或者 单表名"
+fi

fs_nacos_etc_pack.sh

@@ -0,0 +1,25 @@
+#!/bin/bash
+
+CURRENT_DIR=`pwd`
+SOURCE_DIR="server"
+TEMP_DIR="/tmp"
+DEST_DIR="FS-SERVER-API"
+ZIP_FILE="FS-SERVER-API.zip"
+
+mkdir -p $TEMP_DIR/$DEST_DIR
+
+# 查找并复制文件
+find "$SOURCE_DIR" -type d -name "etc" -exec sh -c 'cp "$0"/*.yaml "$1"' {} "$TEMP_DIR/$DEST_DIR" \;
+
+cd $TEMP_DIR
+# 打包目标文件夹
+zip -r "$ZIP_FILE" "$DEST_DIR"
+
+#返回当前目录
+cd $CURRENT_DIR
+
+# 移动到当前目录
+mv "$TEMP_DIR/$ZIP_FILE" .
+
+# 清理临时文件夹
+rm "$TEMP_DIR/$DEST_DIR" -rf

fs_package_docker_image.sh

@@ -0,0 +1,23 @@
+#!/bin/bash
+name=${1%%\\*}
+#进入对应服务目录
+cd server/$name
+#把https加密密钥对复制进来
+cp /opt/env.yaml ./
+cp /opt/server.fusen.3718.cn.pem ./
+cp /opt/server.fusen.3718.cn.key ./
+#构建二进制文件
+CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -ldflags="-s -w" -o ./bin/api-$name-srv  ./$name.go
+#打包docker镜像
+docker build -t api-$name-srv:latest .
+#删除临时复制进来的文件
+rm ./env.yaml
+rm ./server.fusen.3718.cn.pem
+rm ./server.fusen.3718.cn.key
+#打tag(测试环境，正式把命名空间fusentest改成fusen)
+docker tag api-$name-srv:latest  registry.cn-hangzhou.aliyuncs.com/fusen-test/$name:latest
+#推送到阿里云镜像库(测试环境，正式把命名空间fusentest改成fusen)
+docker push registry.cn-hangzhou.aliyuncs.com/fusen-test/$name:latest
+#上传了的镜像
+docker rmi -f api-$name-srv:latest
+docker rmi -f registry.cn-hangzhou.aliyuncs.com/fusen-test/$name:latest

fs_template/email_register.tpl

@@ -0,0 +1,29 @@
+Subject: Please confirm your {{ .CompanyName }} account;
+MIME-version: 1.0;
+Content-Type: text/html; charset="UTF-8";
+From: "Fusen Support";
+
+
+<html>
+<body>
+
+<p>Dear <span style="color: red;">{{.UserName}}</span>,</p>
+
+<p>Thank you for registering an account with {{ .CompanyName }}. We are thrilled to have you join our community!</p> 
+
+<p>Please take a moment to confirm your email address by clicking the button below so we can activate your account:</p>
+
+<a href="{{ .ConfirmationLink }}" target="_blank" style="background-color: #008CBA; color: #FFFFFF; text-decoration: none; padding: 10px 15px; border-radius: 3px; display:inline-block; font-weight: bold;">Confirm Account: {{ .UserName }}</a>
+
+<p>Confirming your email ensures your account is properly secured. This also lets you access member-only tools and content.</p> 
+
+<p>If you did not register for {{ .CompanyName }}, please disregard this email. Let us know if you have any other questions!</p>
+
+Regards,
+
+<p><span>{{.SenderName}}</span><br>
+<span>{{.SenderTitle}}</span><br>
+<span>{{.CompanyName}}</span></p>
+
+<body>
+<html>

fs_template/email_register_oauth2.tpl

@@ -0,0 +1,27 @@
+Subject: Confirm Email Address for {{ .CompanyName }} Account
+MIME-version: 1.0
+Content-Type: text/html; charset="UTF-8"
+From: "Fusen Support"
+
+
+<html>
+<body>
+
+<p>Dear <span style="color: red;">{{.UserName}}</span>,</p>
+
+<p>Thank you for choosing to associate your email address with your {{ .CompanyName }} account({{ .PlatformAndID }}). To complete the process, please click the button below to confirm your email:</p>
+
+<a href="{{ .ConfirmationLink }}" target="_blank" style="background-color: #008CBA; color: #FFFFFF; text-decoration: none; padding: 10px 15px; border-radius: 3px; display:inline-block; font-weight: bold;">Confirm Email: {{ .Email }}</a>
+
+<p>By confirming your email, you will be able to access additional features and receive important notifications related to your {{ .CompanyName }} account.</p>
+
+<p>If you did not initiate this request or have any questions, please disregard this email. Your email address will not be associated with any account.</p>
+
+Regards,
+
+<p><span>{{.SenderName}}</span><br>
+<span>{{.SenderTitle}}</span><br>
+<span>{{.CompanyName}}</span></p>
+
+</body>
+</html>

fs_template/get_reset_password_html.tpl

@@ -0,0 +1,32 @@
+Subject: Password Reset Request for Your {{ .CompanyName }} Account
+MIME-version: 1.0;
+Content-Type: text/html; charset="UTF-8";
+From: "Fusen Support";
+
+
+<html>
+<body>
+
+<p>Dear <span style="color: red;">{{.UserName}}</span>,</p>
+
+<p>We have received your request to reset the password for your {{.CompanyName}} account.</p> 
+
+<p>To proceed with the password reset, please click the button below to open the Reset Password page:</p>
+
+<div style="margin: 1em 0;">
+ <a href="{{.ConfirmationLink}}" target="_blank" 
+    style="background-color: #008CBA; color: #FFFFFF; text-decoration: none; padding: 10px 15px; border-radius: 3px; display:inline-block;">
+   Reset Password
+ </a>
+</div>
+
+<p>Please note that this password reset confirmation link will expire in 60 minutes. If you have any further questions, feel free to reach out to us.</p>
+
+<p>Regards,</p>
+
+<p><span>{{.SenderName}}</span><br>
+<span>{{.SenderTitle}}</span><br>
+<span>{{.CompanyName}}</span></p>
+
+</body>
+</html>

fs_template/reset_confirm.tpl

@@ -0,0 +1,179 @@
+<!DOCTYPE html>
+<html>
+<head>
+<meta name="viewport" content="width=device-width, initial-scale=1">
+<style>
+
+body {
+  font-family: Arial, sans-serif;
+  background-color: #f5f5f5;  
+}
+
+.container {
+  margin: 0 auto;
+  max-width: 400px;
+  margin: 50px auto;
+  background-color: #fff;
+  padding: 20px;
+  border-radius: 5px;
+  box-shadow: 0 2px 5px rgba(0, 0, 0, 0.3);  
+}
+
+h2 {
+  text-align: center;
+  margin-bottom: 20px;
+} 
+
+.form-group {
+  margin-bottom: 15px;
+  display: flex;
+}
+
+input[type="password"] {
+  flex: 1; 
+}
+
+label {
+  display: block;
+  margin-bottom: 5px;
+  width: 9rem;
+}
+
+input[type="password"] {
+  padding: 1rem;
+  border: 1px solid #ccc;
+  border-radius: 3px;
+}
+
+button {
+  width: 100%;  
+  padding: 10px;
+  background-color: #007bff;
+  color: #fff;
+  border: none;
+  border-radius: 5px;
+  cursor: pointer; 
+}
+
+button:hover {
+  background-color: #0056b3;
+}
+
+/* Mobile */
+@media screen and (max-width: 767px) {
+  .container {
+    padding: 10px;
+  }
+   
+  h2 {
+    font-size: 1.5rem; 
+  }
+   
+  .form-group {
+    flex-direction: column;
+    box-sizing: border-box;
+  }
+   
+  label {
+    margin-bottom: 10px;
+  }
+}
+
+/* Tablet */
+@media screen and (min-width: 768px) and (max-width: 1023px) {
+  .container {
+    padding: 30px;
+  }
+   
+  .form-group {
+    flex-direction: row;
+  }
+}
+
+/* Desktop */
+@media screen and (min-width: 1024px) {
+  .container {
+    max-width: 600px;  
+  }
+}
+
+</style>
+</head>
+
+<body>
+
+<div class="container">
+<h2>Reset Password</h2>
+
+<form id="resetForm">
+  <div class="form-group">
+    <label for="new_password">New Password</label>
+    <input id="new_password" type="password" placeholder="New Password" required pattern="^(?=.*\d)(?=.*[a-z])(?=.*[A-Z]).{8,}$" title="The password must be at least 8 characters in length, and contain at least 1 number, 1 lowercase letter and 1 uppercase letter."/>
+  </div>
+
+  <div class="form-group">  
+    <label for="confirm_password">Confirm Password</label>
+    <input id="confirm_password" type="password" placeholder="Confirm Password" required pattern="^(?=.*\d)(?=.*[a-z])(?=.*[A-Z]).{8,}$" title="The password must be at least 8 characters in length, and contain at least 1 number, 1 lowercase letter and 1 uppercase letter."/>
+  </div>
+  <button type="button" onclick="resetPassword()">Reset Password</button>
+</form>
+</div>
+
+<script>
+
+
+function resetPassword() {
+  const new_password = document.getElementById("new_password").value;
+  const confirm_password = document.getElementById("confirm_password").value;
+
+  if (!/^(?=.*\d)(?=.*[a-z])(?=.*[A-Z]).{8,}$/.test(new_password)) {
+  alert("The password must be at least 8 characters in length, and contain at least 1 number, 1 lowercase letter and 1 uppercase letter.");
+  return;
+  }
+
+  if (new_password !== confirm_password) {
+    alert("Passwords do not match");
+    return;
+  }
+  sha256ToBase64(new_password).then((hash) => {
+    const data = {
+      new_password: hash,
+      reset_token: "{{.ResetToken}}",
+    };
+
+    fetch('{{.ResetPasswordLink}}', {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json'
+      },
+      body: JSON.stringify(data)
+    })
+    .then(response => response.json())
+    .then(data => {
+      if (data.code == 200 ) {
+        alert("reset password success");
+        window.location.href = "{{.HomePage}}";
+        {{/* setTimeout(function() {
+          window.location.href = "{{.HomePage}}";
+        }, 1000); */}}
+      } else {
+        alert(data.msg);
+      }
+    })
+    .catch(error => {
+      console.error('Error:', error);
+    });
+  });
+}
+
+function sha256ToBase64(message) {
+  const msgBuffer = new TextEncoder().encode(message);
+  return crypto.subtle.digest('SHA-256', msgBuffer).then((hashBuffer) => {
+    const hashArray = Array.from(new Uint8Array(hashBuffer));
+    const hashBase64 = btoa(hashArray.reduce((str, byte) => str + String.fromCharCode(byte), ''));
+    return hashBase64;
+  });
+}
+</script>
+</body>
+</html>

fs_template/test.tpl

@@ -0,0 +1,116 @@
+Subject: Please confirm your {{ .CompanyName }} account;
+MIME-version: 1.0;
+Content-Type: text/html; charset="UTF-8";
+From: "Fusen Support";
+
+
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>订单状态流转</title>
+</head>
+<style>
+* {
+    margin: 0;
+    padding: 0;
+}
+</style>
+<body>
+    <div style="    
+    width: 50%;
+    max-width: 600px;
+    min-width: 350px;
+    margin: 0 auto;
+    background-color: #FFFFFF;">
+        <div>
+            <h1><img style="    
+                width: 22%;
+                height: 6%;
+                padding: 50px 0 30px 8%;" src="https://fusenstorage.s3.us-east-2.amazonaws.com/2c3938702c52d46550fffae344f1619dd71c447f3b19882045205fcd8adbd6bf" alt=""></h1>
+        </div>
+        <div>
+            <h2 style="    
+            width: 84%;
+            font-size: 47px;
+            font-family: Gotham-Bold, Gotham;
+            font-weight: bold;
+            color: #212121;
+            line-height: 58px;
+            padding-bottom: 24px;
+            padding-left: 8%;">The status of your order has changed!</h2>
+            <p style="    
+            width: 84%;
+            font-size: 14px;
+            font-weight: normal;
+            color: #212121;
+            line-height: 21px;
+            padding-bottom: 40px;
+            padding-left: 8%;">
+                Your order has been changed from "原状态" to "现状态".</p>
+            <a href="" style="    
+            display: block;
+            text-align: center;
+            width: 80%;
+            height: 24px;
+            font-size: 16px;
+            font-family: Gotham-Bold, Gotham;
+            font-weight: bold;
+            color: #FFFFFF;
+            line-height: 24px;
+            margin: 0 auto;
+            background-color: #FF7F00;
+            padding: 15px 12px;
+            margin-bottom: 60px;
+            border-radius: 200px;
+            text-decoration: none;">Check Your Order</a>
+        </div>
+        <div>
+            <div style="    
+            width: 80%;
+            background-color: #F8F8F8;
+            padding: 20px 30px;
+            margin: 0 auto;">
+                <h3 style="    
+                height: 28px;
+                font-size: 16px;
+                font-family: Gotham-Bold, Gotham;
+                font-weight: bold;
+                color: #212121;
+                line-height: 28px;">Search Logo, Get Design</h3>
+                <p style="    height: 21px;
+                font-size: 12px;
+                font-family: Gotham-Medium, Gotham;
+                font-weight: 500;
+                color: #212121;
+                line-height: 21px;">Our products</p>
+                <p style="    height: 21px;
+                font-size: 12px;
+                font-family: Gotham-Medium, Gotham;
+                font-weight: 500;
+                color: #212121;
+                line-height: 21px;">Try it out</p>
+                <div style="  
+                width: 100%;
+                padding: 17px 0 10px 0 ;
+                border-bottom: 1px solid #CCCCCC;
+                margin-bottom: 10px;">
+                    <img style="width: 14px;height: 14px;" src="https://fusenstorage.s3.us-east-2.amazonaws.com/7d6e04f8a90762210f8b8fc307198776b8dc42998adc90bab41e178053552b2c" alt="">
+                    <span> support@fusenpack.com</span>
+                </div>
+                <span style="    
+                width: 74px;
+                height: 21px;
+                font-size: 12px;
+                    font-weight: normal;
+                color: #999999;
+                line-height: 21px;
+                display: block;
+                cursor: pointer;
+                text-decoration: none;">Unsubscribe</span>
+            </div>
+        </div>
+    </div>
+</body>
+</html>

generator/gen_test.go

@@ -0,0 +1,39 @@
+package main
+
+import (
+	"fmt"
+	"regexp"
+	"testing"
+)
+
+func TestA(t *testing.T) {
+	main3()
+}
+func main3() {
+	ddl := `CREATE TABLE fs_guest (
+  guest_id bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
+  auth_key varchar(512) NOT NULL DEFAULT '' COMMENT 'jwt token',
+  status tinyint(3) unsigned DEFAULT '1' COMMENT '1正常 0不正常',
+  is_del tinyint(1) NOT NULL DEFAULT '0' COMMENT '是否删除 1删除',
+  created_at int(11) NOT NULL DEFAULT '0' COMMENT '添加时间',
+  updated_at int(11) NOT NULL DEFAULT '0' COMMENT '更新时间',
+  is_open_render tinyint(1) NOT NULL DEFAULT '0' COMMENT '是否打开个性化渲染（1：开启，0：关闭）',
+  is_thousand_face tinyint(1) NOT NULL DEFAULT '0' COMMENT '是否已经存在千人千面（1：存在，0：不存在）',
+  is_low_rendering tinyint(1) unsigned zerofill NOT NULL DEFAULT '0' COMMENT '是否开启低渲染模型渲染',
+  is_remove_bg tinyint(1) NOT NULL DEFAULT '1' COMMENT '用户上传logo是否去除背景',
+  guid decimal(10,2) NOT NULL,
+  PRIMARY KEY (guest_id) USING BTREE,
+  UNIQUE KEY fs_guest_guid_IDX (guid) USING BTREE,
+  KEY fs_guest_is_del_IDX (is_del) USING BTREE,
+  KEY fs_guest_status_IDX (status) USING BTREE,
+  KEY fs_guest_created_at_IDX (created_at) USING BTREE
+) ENGINE=InnoDB AUTO_INCREMENT=13 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='游客表'`
+
+	// 正则表达式匹配
+	r, _ := regexp.Compile(`CREATE TABLE (\S+) \..*COMMENT='(.*)'`)
+	matches := r.FindStringSubmatch(ddl)
+
+	// 输出结果
+	fmt.Println("表名:", matches[1])
+	fmt.Println("注释:", matches[2])
+}

generator/gorm_gen_test.go

@@ -0,0 +1,25 @@
+package main
+
+import (
+	"log"
+	"regexp"
+	"testing"
+
+	_ "github.com/go-sql-driver/mysql"
+)
+
+func TestXMain(t *testing.T) {
+	a := "	FsAddress                 *FsAddressModel                 // fs_address 用户地址表"
+	re := regexp.MustCompile(`([A-Za-z0-9_]+) [^/]+ // ([^ ]+) (.+)$`)
+	for _, line := range re.FindStringSubmatch(a) {
+		log.Println(line)
+	}
+
+	log.Println(re.FindStringSubmatch(a))
+	// testGenDir = "../" + testGenDir
+	// GenAllModels(testGenDir, TableNameComment{
+	// 	Name:    "FsFont",
+	// 	Comment: "测试",
+	// })
+	// Now you can use the generated GORM model to interact with the database
+}

generator/main.go

@@ -0,0 +1,571 @@
+package main
+
+import (
+	"database/sql"
+	"flag"
+	"fmt"
+	"log"
+	"os"
+	"os/exec"
+	"regexp"
+	"sort"
+	"strconv"
+	"strings"
+
+	"golang.org/x/text/cases"
+	"golang.org/x/text/language"
+
+	_ "github.com/go-sql-driver/mysql"
+)
+
+var testName = "fs_auth_item"
+var testGenDir = "model/gmodel"
+
+func toPascalCase(s string) string {
+	words := strings.Split(s, "_")
+	for i, word := range words {
+		words[i] = cases.Title(language.English).String(strings.ToLower(word))
+	}
+	return strings.Join(words, "")
+}
+
+func GetAllTableNames(uri string) []string {
+	db, err := sql.Open("mysql", uri)
+	if err != nil {
+		panic(err)
+	}
+	defer db.Close()
+
+	rows, err := db.Query("SHOW TABLES")
+	if err != nil {
+		panic(err)
+	}
+
+	var tableNames []string
+	for rows.Next() {
+		var tableName string
+		if err := rows.Scan(&tableName); err != nil {
+			panic(err)
+		}
+		tableNames = append(tableNames, tableName)
+	}
+
+	return tableNames
+}
+
+// "fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen"
+func GetColsFromTable(tname string, db *sql.DB) (result []Column, tableName, tableComment string) {
+
+	var a, ddl string
+	err := db.QueryRow("SHOW CREATE TABLE "+tname).Scan(&a, &ddl)
+	// log.Println(ddl)
+	if err != nil {
+		panic(err)
+	}
+
+	return ParserDDL(ddl)
+}
+
+var gmodelVarStr = `
+package gmodel
+
+import "gorm.io/gorm"
+
+// AllModelsGen 所有Model集合,修改单行,只要不改字段名,不会根据新的内容修改,需要修改的话手动删除
+type AllModelsGen struct {
+}
+
+func NewAllModels(gdb *gorm.DB) *AllModelsGen {
+	models := &AllModelsGen{
+	}
+	return models
+}
+`
+
+var gmodelVarStrFormat = `
+package gmodel
+
+import "gorm.io/gorm"
+
+// AllModelsGen 所有Model集合,修改单行,只要不改字段名,不会根据新的内容修改,需要修改的话手动删除
+type AllModelsGen struct {
+	 %s
+}
+
+func NewAllModels(gdb *gorm.DB) *AllModelsGen {
+	models := &AllModelsGen{
+		%s
+	}
+	return models
+}
+`
+
+type TableNameComment struct {
+	Name    string
+	GoName  string
+	Comment string
+}
+
+type TMCS []TableNameComment
+
+func (u TMCS) Len() int {
+	return len(u)
+}
+
+func (u TMCS) Less(i, j int) bool {
+	return u[i].Name < u[j].Name
+}
+
+func (u TMCS) Swap(i, j int) {
+	u[i], u[j] = u[j], u[i]
+}
+
+func GenAllModels(filedir string, tmcs ...TableNameComment) {
+	fileName := filedir + "/var_gen.go"
+	var dupMap map[string]TableNameComment = make(map[string]TableNameComment)
+	for _, tmc := range tmcs {
+		dupMap[tmc.Name] = tmc
+	}
+
+	if _, err := os.Stat(fileName); err == nil {
+		log.Printf("%s exists!", fileName)
+		data, err := os.ReadFile(fileName)
+		if err != nil {
+			panic(err)
+		}
+		filestr := string(data)
+		filelines := strings.Split(filestr, "\n")
+		re := regexp.MustCompile(`([A-Za-z0-9_]+) [^/]+ // ([^ ]+) (.+)$`)
+		for _, line := range filelines {
+			result := re.FindStringSubmatch(line)
+			if len(result) > 0 {
+				// key := result[0]
+				if len(result) != 4 {
+					log.Println(result)
+				}
+				log.Println(result)
+
+				tmc := TableNameComment{
+					Name:    result[2],
+					GoName:  result[1],
+					Comment: result[3],
+				}
+
+				if newTmc, ok := dupMap[tmc.Name]; ok {
+					log.Printf("not change: (old)%v -> (new)%v", tmc, newTmc)
+				}
+
+				dupMap[tmc.Name] = tmc
+			}
+		}
+
+		tmcs = nil
+
+		for _, tmc := range dupMap {
+			tmcs = append(tmcs, tmc)
+		}
+
+		sort.Sort(TMCS(tmcs))
+
+		structStr := ""
+		newModelsStr := ""
+		for _, tmc := range tmcs {
+			fsline := fmt.Sprintf("%s *%sModel // %s %s\n", tmc.GoName, tmc.GoName, tmc.Name, tmc.Comment)
+			structStr += fsline
+			nmline := fmt.Sprintf("%s: New%sModel(gdb),\n", tmc.GoName, tmc.GoName)
+			newModelsStr += nmline
+		}
+
+		content := fmt.Sprintf(gmodelVarStrFormat, structStr, newModelsStr)
+		f, err := os.OpenFile(fileName, os.O_TRUNC|os.O_CREATE|os.O_WRONLY, 0644)
+		if err != nil {
+			panic(err)
+		}
+		_, err = f.WriteString(content)
+		if err != nil {
+			panic(err)
+		}
+
+	} else if os.IsExist(err) {
+		f, err := os.Create(fileName)
+		if err != nil {
+			panic(err)
+		}
+		_, err = f.WriteString(gmodelVarStr)
+		if err != nil {
+			panic(err)
+		}
+	} else {
+		panic(err)
+	}
+
+	err := exec.Command("gofmt", "-w", fileName).Run()
+	if err != nil {
+		panic(err)
+	}
+}
+
+func main() {
+	var mysqluri string
+	var name string // 需要序列化的单独文件名
+	var mdir string // 需要修改的序列化路径 model
+
+	flag.StringVar(&mysqluri, "uri", "fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen", "输入需要序列化的ddl文件名, 不需要后缀.ddl")
+	flag.StringVar(&name, "name", "", "输入需要序列化的ddl文件名, 不需要后缀.ddl")
+	flag.StringVar(&mdir, "mdir", "", "输入需要生成model的Go文件所在目录")
+
+	flag.Parse()
+
+	if mdir != "" {
+		testGenDir = mdir
+	}
+
+	db, err := sql.Open("mysql", mysqluri)
+	if err != nil {
+		panic(err)
+	}
+	defer db.Close()
+	var tmcs []TableNameComment
+	if name == "-" {
+		tablenames := GetAllTableNames(mysqluri)
+		for _, testName := range tablenames {
+			// if testName != "fs_user_info" {
+			// 	continue
+			// }
+
+			cols, tname, tcomment := GetColsFromTable(testName, db)
+			GenFromPath(testGenDir, cols, tname, tcomment)
+
+			tmcs = append(tmcs, TableNameComment{
+				Name:    tname,
+				GoName:  toPascalCase(tname),
+				Comment: tcomment,
+			})
+		}
+
+	} else {
+		if name != "" {
+			testName = name
+		}
+
+		// log.Println(testName)
+		cols, tname, tcomment := GetColsFromTable(testName, db)
+		GenFromPath(testGenDir, cols, tname, tcomment)
+
+		tmcs = append(tmcs, TableNameComment{
+			Name:    tname,
+			GoName:  toPascalCase(tname),
+			Comment: tcomment,
+		})
+	}
+
+	GenAllModels(testGenDir, tmcs...)
+
+	// tablenames := GetAllTableNames(mysqluri)
+	// log.Println(tablenames)
+
+	// name
+
+}
+
+func GenFromPath(mdir string, cols []Column, tableName string, tableComment string) {
+
+	var importstr = "import (\"gorm.io/gorm\"\n"
+
+	// 匹配到主键定义
+
+	fcontent := "package gmodel\n"
+
+	structstr := "// %s %s\ntype %s struct {%s\n}\n"
+
+	pTableName := toPascalCase(tableName)
+
+	fieldstr := ""
+	for _, col := range cols {
+		fieldName := toPascalCase(col.Name)
+		typeName := typeForMysqlToGo[col.GetType()]
+		var defaultString string
+		if col.DefaultValue != nil {
+			switch typeName {
+			case "*int64", "*uint64", "*float64", "*bool":
+				defaultString = "default:" + strings.Trim(*col.DefaultValue, "'") + ";"
+			default:
+				defaultString = "default:" + *col.DefaultValue + ";"
+			}
+		} else {
+
+			switch typeName {
+			case "*string":
+				defaultString = "default:'';"
+			case "*time.Time":
+				defaultString = "default:'0000-00-00 00:00:00';"
+			case "*[]byte":
+				defaultString = "default:'';"
+			case "*int64", "*uint64":
+				defaultString = "default:0;"
+			case "*float64":
+				defaultString = "default: 0.0;"
+			case "*bool":
+				defaultString = "default:0;"
+			default:
+				// if fieldName == "Metadata" {
+				// 	log.Println()
+				// }
+				fieldName = "// " + fieldName + " " + col.Type
+			}
+		}
+
+		if typeName == "*time.Time" {
+			importstr += "\"time\"\n"
+		}
+
+		if col.IndexType == "primary_key" {
+			typeName = typeName[1:]
+		}
+
+		tagstr := "`gorm:"
+
+		gormTag := ""
+		if col.IndexType != "" {
+			gormTag += col.IndexType + ";"
+		}
+
+		gormTag += defaultString
+
+		if col.AutoIncrement {
+			gormTag += "auto_increment;"
+		}
+
+		tagstr += fmt.Sprintf("\"%s\"", gormTag)
+
+		tagstr += fmt.Sprintf(" json:\"%s\"`", col.Name)
+
+		fieldColStr := fmt.Sprintf("\n%s %s %s// %s", fieldName, typeName, tagstr, col.Comment)
+
+		fieldstr += fieldColStr
+
+	}
+
+	fcontent += importstr + ")\n"
+	fcontent += fmt.Sprintf(structstr, tableName, tableComment, pTableName, fieldstr)
+	modelstr := fmt.Sprintf(`type %sModel struct {db *gorm.DB
+		name string}`, pTableName)
+	fcontent += modelstr
+	fcontent += "\n"
+
+	newfuncstr := fmt.Sprintf(`func New%sModel(db *gorm.DB) *%sModel {return &%sModel{db:db,name:"%s"}}`, pTableName, pTableName, pTableName, tableName)
+	fcontent += newfuncstr
+	fcontent += "\n"
+
+	genGoFileName := fmt.Sprintf("%s/%s_gen.go", mdir, tableName)
+	f, err := os.OpenFile(genGoFileName, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0644)
+	if err != nil {
+		panic(err)
+	}
+
+	f.WriteString(fcontent)
+	err = f.Close()
+	if err != nil {
+		panic(err)
+	}
+	err = exec.Command("gofmt", "-w", genGoFileName).Run()
+	if err != nil {
+		panic(err)
+	}
+
+	fcontent = "package gmodel\n// TODO: 使用model的属性做你想做的"
+	genGoLogicFileName := fmt.Sprintf("%s/%s_logic.go", mdir, tableName)
+
+	// 使用 os.Stat 函数获取文件信息
+	_, err = os.Stat(genGoLogicFileName)
+	// 判断文件是否存在并输出结果
+	if os.IsNotExist(err) {
+		f2, err := os.OpenFile(genGoLogicFileName, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0644)
+		if err != nil {
+			panic(err)
+		}
+		f2.WriteString(fcontent)
+		err = f2.Close()
+		if err != nil {
+			panic(err)
+		}
+		fmt.Println(genGoLogicFileName, "create!")
+	} else {
+		fmt.Println(genGoLogicFileName, "exists")
+	}
+
+}
+
+type Column struct {
+	Name          string
+	Type          string
+	DefaultValue  *string
+	Length        int
+	Decimal       int
+	Unsigned      bool
+	NotNull       bool
+	AutoIncrement bool
+	Comment       string
+
+	IndexType string
+}
+
+func (col *Column) GetType() string {
+	content := col.Type
+	if col.Unsigned {
+		return content + " unsigned"
+	}
+	return content
+}
+
+var typeForMysqlToGo = map[string]string{
+	// 整数
+	"int":       "*int64",
+	"integer":   "*int64",
+	"tinyint":   "*int64",
+	"smallint":  "*int64",
+	"mediumint": "*int64",
+	"bigint":    "*int64",
+	"year":      "*int64",
+
+	"int unsigned":       "*int64",
+	"integer unsigned":   "*int64",
+	"tinyint unsigned":   "*int64",
+	"smallint unsigned":  "*int64",
+	"mediumint unsigned": "*int64",
+	"bigint unsigned":    "*int64",
+	"bit":                "*int64",
+
+	// 布尔类型
+	"bool": "*bool",
+
+	// 字符串
+	"enum":       "*string",
+	"set":        "*string",
+	"varchar":    "*string",
+	"char":       "*string",
+	"tinytext":   "*string",
+	"mediumtext": "*string",
+	"text":       "*string",
+	"longtext":   "*string",
+
+	// 二进制
+	"binary":     "*[]byte",
+	"varbinary":  "*[]byte",
+	"blob":       "*[]byte",
+	"tinyblob":   "*[]byte",
+	"mediumblob": "*[]byte",
+	"longblob":   "*[]byte",
+
+	// 日期时间
+	"date":      "*time.Time",
+	"datetime":  "*time.Time",
+	"timestamp": "*time.Time",
+	"time":      "*time.Time",
+
+	// 浮点数
+	"float":   "*float64",
+	"double":  "*float64",
+	"decimal": "*float64",
+}
+
+func ParserDDL(ddl string) (result []Column, tableName, tableComment string) {
+
+	reTable := regexp.MustCompile(`CREATE TABLE +([^ ]+) +\(`)
+	reTableComment := regexp.MustCompile(`.+COMMENT='(.+)'$`)
+	reField := regexp.MustCompile("`([^`]+)` +([^ \n\\(\\,]+)(?:\\(([^)]+)\\))?( +unsigned| +UNSIGNED)?( +not +null| +NOT +NULL)?( +default +\\'[^\\']*'| +DEFAULT +\\'[^\\']*')?( +auto_increment| +AUTO_INCREMENT)?( comment '[^']*'| COMMENT '[^']*')?(,)?")
+	reIndex := regexp.MustCompile(`(?i)(PRIMARY|UNIQUE)?\s*(INDEX|KEY)\s*(` + "`([^`]*)`" + `)?\s*\(([^)]+)\)`)
+	reValue := regexp.MustCompile(` '(.+)'$`)
+	reDefaultValue := regexp.MustCompile(` ('.+')$`)
+
+	var fieldmap map[string]string = make(map[string]string)
+	indexMatches := reIndex.FindAllStringSubmatch(ddl, -1)
+	for _, m := range indexMatches {
+		idxAttr := strings.Trim(m[5], "`")
+		PrefixName := strings.ToUpper(m[1])
+		if PrefixName == "PRIMARY" {
+			fieldmap[idxAttr] = "primary_key"
+		} else if PrefixName == "UNIQUE" {
+			fieldmap[idxAttr] = "unique_key"
+		} else if PrefixName == "" {
+			fieldmap[idxAttr] = "index"
+		} else {
+			log.Fatal(PrefixName)
+		}
+	}
+
+	tableMatches := reTable.FindStringSubmatch(ddl)
+	tableName = strings.Trim(tableMatches[1], "`")
+
+	tableCommentMatches := reTableComment.FindStringSubmatch(ddl)
+	if len(tableCommentMatches) > 0 {
+		tableComment = strings.Trim(tableCommentMatches[1], "`")
+	}
+
+	// log.Println(tableName, tableComment)
+	fieldMatches := reField.FindAllStringSubmatch(ddl, -1)
+	for _, m := range fieldMatches {
+		if m[0] == "" {
+			continue
+		}
+
+		col := Column{
+			Name: m[1],
+			Type: strings.ToLower(m[2]),
+		}
+
+		if col.Type == "json" {
+			col.Type = "blob"
+		}
+
+		col.IndexType = fieldmap[col.Name]
+
+		if m[3] != "" {
+			maylen := strings.Split(m[3], ",")
+			if len(maylen) >= 1 {
+				clen, err := strconv.ParseInt(maylen[0], 10, 64)
+				if err != nil {
+					panic(err)
+				}
+				col.Length = int(clen)
+			}
+			if len(maylen) >= 2 {
+				clen, err := strconv.ParseInt(maylen[1], 10, 64)
+				if err != nil {
+					panic(err)
+				}
+				col.Decimal = int(clen)
+			}
+		}
+
+		if len(m[4]) > 0 {
+			col.Unsigned = true
+		}
+
+		if len(m[5]) > 0 {
+			col.NotNull = true
+		}
+
+		if len(m[6]) > 0 {
+			v := reDefaultValue.FindStringSubmatch(m[6])
+			if len(v) > 0 {
+				dv := string(v[1])
+				col.DefaultValue = &dv
+			}
+		}
+
+		if len(m[7]) > 0 {
+			col.AutoIncrement = true
+		}
+
+		if len(m[8]) > 0 {
+			v := reValue.FindStringSubmatch(m[8])
+			if len(v) > 0 {
+				col.Comment = v[1]
+			}
+		}
+		result = append(result, col)
+		// fmt.Println(col)
+	}
+	return result, tableName, tableComment
+}

generator/main_test.go

@@ -0,0 +1,14 @@
+package main
+
+import (
+	"os"
+	"testing"
+)
+
+func TestMain(t *testing.T) {
+	// args := []string{"-name", "fs_guest"}
+
+	testGenDir = "../" + testGenDir
+	os.Args = []string{"cmd", "-name=-"}
+	main()
+}

go.mod

@@ -0,0 +1,145 @@
+module fusenapi
+
+go 1.20
+
+require (
+	github.com/474420502/passer v0.0.1
+	github.com/SebastiaanKlippert/go-wkhtmltopdf v1.9.0
+	github.com/aliyun/aliyun-oss-go-sdk v3.0.1+incompatible
+	github.com/aws/aws-sdk-go v1.44.295
+	github.com/bwmarrin/snowflake v0.3.0
+	github.com/disintegration/imaging v1.6.2
+	github.com/go-ldap/ldap/v3 v3.4.6
+	github.com/go-resty/resty/v2 v2.7.0
+	github.com/golang-jwt/jwt v3.2.2+incompatible
+	github.com/google/uuid v1.3.1
+	github.com/gorilla/websocket v1.5.0
+	github.com/hashicorp/raft v1.5.0
+	github.com/lni/dragonboat/v4 v4.0.0-20230709075559-54497b9553be
+	github.com/mozillazg/go-pinyin v0.19.0
+	github.com/nacos-group/nacos-sdk-go/v2 v2.2.3
+	github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646
+	github.com/patrickmn/go-cache v2.1.0+incompatible
+	github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e
+	github.com/streadway/amqp v1.1.0
+	github.com/stripe/stripe-go/v75 v75.7.0
+	github.com/zeromicro/go-zero v1.5.4
+	golang.org/x/image v0.0.0-20191009234506-e7c1f5e7dbb8
+	golang.org/x/oauth2 v0.10.0
+	gorm.io/driver/mysql v1.5.1
+	gorm.io/gorm v1.25.1
+)
+
+require (
+	cloud.google.com/go/compute v1.20.1 // indirect
+	cloud.google.com/go/compute/metadata v0.2.3 // indirect
+	github.com/Azure/go-ntlmssp v0.0.0-20221128193559-754e69321358 // indirect
+	github.com/BurntSushi/toml v1.1.0 // indirect
+	github.com/DataDog/zstd v1.4.5 // indirect
+	github.com/HdrHistogram/hdrhistogram-go v1.1.2 // indirect
+	github.com/VictoriaMetrics/metrics v1.18.1 // indirect
+	github.com/aliyun/alibaba-cloud-sdk-go v1.61.1704 // indirect
+	github.com/andybalholm/brotli v1.0.5 // indirect
+	github.com/armon/go-metrics v0.4.1 // indirect
+	github.com/buger/jsonparser v1.1.1 // indirect
+	github.com/cockroachdb/errors v1.9.0 // indirect
+	github.com/cockroachdb/logtags v0.0.0-20211118104740-dabe8e521a4f // indirect
+	github.com/cockroachdb/pebble v0.0.0-20221207173255-0f086d933dac // indirect
+	github.com/cockroachdb/redact v1.1.3 // indirect
+	github.com/getsentry/sentry-go v0.12.0 // indirect
+	github.com/go-asn1-ber/asn1-ber v1.5.5 // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/golang/mock v1.6.0 // indirect
+	github.com/golang/snappy v0.0.4 // indirect
+	github.com/google/btree v1.0.0 // indirect
+	github.com/hashicorp/errwrap v1.1.0 // indirect
+	github.com/hashicorp/go-hclog v1.5.0 // indirect
+	github.com/hashicorp/go-immutable-radix v1.3.1 // indirect
+	github.com/hashicorp/go-msgpack v0.5.5 // indirect
+	github.com/hashicorp/go-multierror v1.1.1 // indirect
+	github.com/hashicorp/go-sockaddr v1.0.0 // indirect
+	github.com/hashicorp/golang-lru v0.5.4 // indirect
+	github.com/hashicorp/memberlist v0.3.1 // indirect
+	github.com/jmespath/go-jmespath v0.4.0 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/klauspost/compress v1.15.15 // indirect
+	github.com/kr/pretty v0.3.1 // indirect
+	github.com/kr/text v0.2.0 // indirect
+	github.com/lni/goutils v1.3.1-0.20220604063047-388d67b4dbc4 // indirect
+	github.com/lni/vfs v0.2.1-0.20220616104132-8852fd867376 // indirect
+	github.com/miekg/dns v1.1.26 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/pierrec/lz4/v4 v4.1.17 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/rogpeppe/go-internal v1.9.0 // indirect
+	github.com/schollz/progressbar v1.0.0 // indirect
+	github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529 // indirect
+	github.com/valyala/fastrand v1.1.0 // indirect
+	github.com/valyala/histogram v1.2.0 // indirect
+	go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.14.0 // indirect
+	go.uber.org/atomic v1.10.0 // indirect
+	go.uber.org/multierr v1.9.0 // indirect
+	go.uber.org/zap v1.24.0 // indirect
+	golang.org/x/crypto v0.13.0 // indirect
+	golang.org/x/exp v0.0.0-20230728194245-b0cb94b80691 // indirect
+	golang.org/x/sync v0.2.0 // indirect
+	golang.org/x/time v0.3.0 // indirect
+	google.golang.org/appengine v1.6.7 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20230530153820-e85fd2cbaebc // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20230530153820-e85fd2cbaebc // indirect
+	gopkg.in/ini.v1 v1.66.4 // indirect
+	gopkg.in/natefinch/lumberjack.v2 v2.0.0 // indirect
+)
+
+require (
+	github.com/474420502/requests v1.42.0
+	github.com/jinzhu/inflection v1.0.0 // indirect
+	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/tidwall/gjson v1.13.0
+	github.com/tidwall/match v1.1.1 // indirect
+	github.com/tidwall/pretty v1.2.0 // indirect
+)
+
+require (
+	github.com/beorn7/perks v1.0.1 // indirect
+	github.com/cenkalti/backoff/v4 v4.2.0 // indirect
+	github.com/cespare/xxhash/v2 v2.2.0 // indirect
+	github.com/fatih/color v1.15.0 // indirect
+	github.com/go-logr/logr v1.2.3 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/go-sql-driver/mysql v1.7.1
+	github.com/golang-jwt/jwt/v4 v4.5.0 // indirect
+	github.com/golang/protobuf v1.5.3 // indirect
+	github.com/gorilla/mux v1.8.0
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.15.0 // indirect
+	github.com/mattn/go-colorable v0.1.13 // indirect
+	github.com/mattn/go-isatty v0.0.17 // indirect
+	github.com/matttproud/golang_protobuf_extensions v1.0.4 // indirect
+	github.com/openzipkin/zipkin-go v0.4.1 // indirect
+	github.com/pelletier/go-toml/v2 v2.0.9 // indirect
+	github.com/prometheus/client_golang v1.16.0 // indirect
+	github.com/prometheus/client_model v0.3.0 // indirect
+	github.com/prometheus/common v0.42.0 // indirect
+	github.com/prometheus/procfs v0.10.1 // indirect
+	github.com/rs/cors v1.9.0
+	github.com/spaolacci/murmur3 v1.1.0 // indirect
+	go.opentelemetry.io/otel v1.14.0
+	go.opentelemetry.io/otel/exporters/jaeger v1.14.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.14.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.14.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.14.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.14.0 // indirect
+	go.opentelemetry.io/otel/exporters/zipkin v1.14.0 // indirect
+	go.opentelemetry.io/otel/sdk v1.14.0 // indirect
+	go.opentelemetry.io/otel/trace v1.14.0
+	go.opentelemetry.io/proto/otlp v0.19.0 // indirect
+	go.uber.org/automaxprocs v1.5.2 // indirect
+	golang.org/x/net v0.12.0 // indirect
+	golang.org/x/sys v0.12.0 // indirect
+	golang.org/x/text v0.13.0
+	google.golang.org/genproto v0.0.0-20230530153820-e85fd2cbaebc // indirect
+	google.golang.org/grpc v1.56.2 // indirect
+	google.golang.org/protobuf v1.31.0 // indirect
+	gopkg.in/yaml.v2 v2.4.0
+)

goctl_template/api/config.tpl

@@ -0,0 +1,12 @@
+package config
+
+import {{.authImport}}
+
+type Config struct {
+	rest.RestConf
+	SourceMysql	string
+	Auth    	types.Auth
+	SourceRabbitMq string
+	{{.auth}}
+	{{.jwtTrans}}
+}

goctl_template/api/context.tpl

@@ -0,0 +1,38 @@
+package svc
+
+import (
+	{{.configImport}}
+	"errors"
+	"fmt"
+	"net/http"
+	
+	"fusenapi/utils/autoconfig"
+	"fusenapi/initalize"
+	"fusenapi/model/gmodel"
+	
+	"gorm.io/gorm"
+	"github.com/golang-jwt/jwt"
+)
+
+type ServiceContext struct {
+	Config {{.config}}
+	{{.middleware}}
+
+	SharedState *fsm.StateCluster
+	MysqlConn *gorm.DB
+	AllModels *gmodel.AllModelsGen
+	RabbitMq  *initalize.RabbitMqHandle
+}
+
+func NewServiceContext(c {{.config}}) *ServiceContext {
+	conn := initalize.InitMysql(c.SourceMysql)
+
+	return &ServiceContext{
+		Config:      c,
+		MysqlConn:   conn,
+		SharedState: nil,
+		AllModels:   gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
+		RabbitMq:initalize.InitRabbitMq(c.SourceRabbitMq, nil),
+		{{.middlewareAssignment}}
+	}
+}

goctl_template/api/etc.tpl

@@ -0,0 +1,10 @@
+Name: {{.serviceName}}
+Host: {{.host}}
+Port: {{.port}}
+Timeout: 15000 #服务超时时间(毫秒)
+SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
+SourceRabbitMq: ""
+Auth:
+    AccessSecret: fusen2023
+    AccessExpire: 2592000
+    RefreshAfter: 1592000

goctl_template/api/handler.tpl

@@ -0,0 +1,33 @@
+package {{.PkgName}}
+
+import (
+	"net/http"
+	"reflect"
+	
+	"fusenapi/utils/basic"
+	
+	{{.ImportPackages}}
+)
+
+func {{.HandlerName}}(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+
+		{{if .HasRequest}}var req types.{{.RequestType}}
+		userinfo, err := basic.RequestParse(w, r, svcCtx, &req)
+		if err != nil {
+			return
+		}
+		
+		// 创建一个业务逻辑层实例
+		{{end}}l := {{.LogicName}}.New{{.LogicType}}(r.Context(), svcCtx)
+
+		rl := reflect.ValueOf(l)
+		basic.BeforeLogic(w, r, rl)
+
+		{{if .HasResp}}resp{{end}} := l.{{.Call}}({{if .HasRequest}}&req, {{end}}userinfo)
+
+		if !basic.AfterLogic(w, r, rl, resp) {
+			basic.NormalAfterLogic(w, r, resp)
+		}
+	}
+}

goctl_template/api/logic.tpl

@@ -0,0 +1,39 @@
+package {{.pkgName}}
+
+import (
+	"fusenapi/utils/auth"
+	"fusenapi/utils/basic"
+
+	{{.imports}}
+)
+
+type {{.logic}} struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func New{{.logic}}(ctx context.Context, svcCtx *svc.ServiceContext) *{{.logic}} {
+	return &{{.logic}}{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+// 处理进入前逻辑w,r
+// func (l *{{.logic}}) BeforeLogic(w http.ResponseWriter, r *http.Request) {
+// }
+
+func (l *{{.logic}}) {{.function}}({{.request}}, userinfo *auth.UserInfo) (resp *basic.Response) {
+	// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data) 
+	// userinfo 传入值时, 一定不为null
+
+ 	{{.returnString}} resp.SetStatus(basic.CodeOK)
+}
+
+// 处理逻辑后 w,r 如:重定向, resp 必须重新处理
+// func (l *{{.logic}}) AfterLogic(w http.ResponseWriter, r *http.Request, resp *basic.Response) {
+// // httpx.OkJsonCtx(r.Context(), w, resp)
+// }
+

goctl_template/api/main.tpl

@@ -0,0 +1,36 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"net/http"
+	"time"
+
+	"fusenapi/utils/auth"
+	"fusenapi/utils/fsconfig"
+
+	{{.importPackages}}
+)
+
+var configFile = flag.String("f", "etc/{{.serviceName}}.yaml", "the config file")
+
+func main() {
+	flag.Parse()
+
+	var c config.Config
+	fsconfig.StartNacosConfig(*configFile, &c, nil)
+ 	
+	c.Timeout = int64(time.Second * 15)
+	server := rest.MustNewServer(c.RestConf, rest.WithCustomCors(auth.FsCors, func(w http.ResponseWriter) {
+	}))
+	defer server.Stop()
+
+	ctx := svc.NewServiceContext(c)
+	handler.RegisterHandlers(server, ctx)
+
+	fmt.Printf("Starting server at %s:%d...\n", c.Host, c.Port)
+	server.Start()
+}
+
+
+ 

goctl_template/api/middleware.tpl

@@ -0,0 +1,19 @@
+package middleware
+
+import "net/http"
+
+type {{.name}} struct {
+}
+
+func New{{.name}}() *{{.name}} {
+	return &{{.name}}{}
+}
+
+func (m *{{.name}})Handle(next http.HandlerFunc) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		// TODO generate middleware implement function, delete after code implementation
+
+		// Passthrough to next handler if need
+		next(w, r)
+	}
+}

goctl_template/api/route-addition.tpl

@@ -0,0 +1,4 @@
+
+	server.AddRoutes(
+		{{.routes}} {{.jwt}}{{.signature}} {{.prefix}} {{.timeout}} {{.maxBytes}}
+	)

goctl_template/api/routes.tpl

@@ -0,0 +1,13 @@
+// Code generated by goctl. DO NOT EDIT.
+package handler
+
+import (
+	"net/http"{{if .hasTimeout}}
+	"time"{{end}}
+
+	{{.importPackages}}
+)
+
+func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
+	{{.routesAdditions}}
+}

goctl_template/api/template.tpl

@@ -0,0 +1,24 @@
+syntax = "v1"
+
+info (
+	title: // TODO: add title
+	desc: // TODO: add description
+	author: "{{.gitUser}}"
+	email: "{{.gitEmail}}"
+)
+
+type request {
+	// TODO: add members here and delete this comment
+}
+
+type response {
+	// TODO: add members here and delete this comment
+}
+
+service {{.serviceName}} {
+	@handler GetUser // TODO: set handler name and delete this comment
+	get /users/id/:userId(request) returns(response)
+
+	@handler CreateUser // TODO: set handler name and delete this comment
+	post /users/create(request)
+}

goctl_template/api/types.tpl

@@ -0,0 +1,50 @@
+// Code generated by goctl. DO NOT EDIT.
+package types
+import (
+	{{if .containsTime}}"time"{{end}}
+
+	"fusenapi/utils/basic"
+)
+{{.types}}
+ 
+
+// Set 设置Response的Code和Message值
+func (resp *Response) Set(Code int, Message string) *Response {
+	return &Response{
+		Code: Code,
+		Message: Message,
+	}
+}
+
+// Set 设置整个Response
+func (resp *Response) SetWithData(Code int, Message string, Data interface{}) *Response  {
+	return &Response{
+		Code: Code,
+		Message: Message,
+		Data: Data,
+	}
+}
+
+// SetStatus 设置默认StatusResponse(内部自定义) 默认msg, 可以带data, data只使用一个参数
+func (resp *Response) SetStatus(sr *basic.StatusResponse, data ...interface{}) *Response  {
+	newResp := &Response{
+		Code: sr.Code,
+	}
+	if len(data) == 1 {
+		newResp.Data = data[0]
+	}	
+	return newResp
+}
+
+// SetStatusWithMessage 设置默认StatusResponse(内部自定义) 非默认msg, 可以带data, data只使用一个参数
+func (resp *Response) SetStatusWithMessage(sr *basic.StatusResponse, msg string, data ...interface{}) *Response  {
+	newResp := &Response{
+		Code: sr.Code,
+		Message: msg,
+	}
+	if len(data) == 1 {
+		newResp.Data = data[0]
+	}	
+	return newResp
+}
+ 

goctl_template/docker/docker.tpl

@@ -0,0 +1,33 @@
+FROM golang:{{.Version}}alpine AS builder
+
+LABEL stage=gobuilder
+
+ENV CGO_ENABLED 0
+{{if .Chinese}}ENV GOPROXY https://goproxy.cn,direct
+RUN sed -i 's/dl-cdn.alpinelinux.org/mirrors.aliyun.com/g' /etc/apk/repositories
+{{end}}{{if .HasTimezone}}
+RUN apk update --no-cache && apk add --no-cache tzdata
+{{end}}
+WORKDIR /build
+
+ADD go.mod .
+ADD go.sum .
+RUN go mod download
+COPY . .
+{{if .Argument}}COPY {{.GoRelPath}}/etc /app/etc
+{{end}}RUN go build -ldflags="-s -w" -o /app/{{.ExeFile}} {{.GoMainFrom}}
+
+
+FROM {{.BaseImage}}
+
+COPY --from=builder /etc/ssl/certs/ca-certificates.crt /etc/ssl/certs/ca-certificates.crt
+{{if .HasTimezone}}COPY --from=builder /usr/share/zoneinfo/{{.Timezone}} /usr/share/zoneinfo/{{.Timezone}}
+ENV TZ {{.Timezone}}
+{{end}}
+WORKDIR /app
+COPY --from=builder /app/{{.ExeFile}} /app/{{.ExeFile}}{{if .Argument}}
+COPY --from=builder /app/etc /app/etc{{end}}
+{{if .HasPort}}
+EXPOSE {{.Port}}
+{{end}}
+CMD ["./{{.ExeFile}}"{{.Argument}}]

goctl_template/gateway/etc.tpl

@@ -0,0 +1,18 @@
+Name: gateway-example # gateway name
+Host: localhost # gateway host
+Port: 8888 # gateway port
+Upstreams: # upstreams
+  - Grpc: # grpc upstream
+      Target: 0.0.0.0:8080 # grpc target,the direct grpc server address,for only one node
+#      Endpoints: [0.0.0.0:8080,192.168.120.1:8080] # grpc endpoints, the grpc server address list, for multiple nodes
+#      Etcd: # etcd config, if you want to use etcd to discover the grpc server address
+#        Hosts: [127.0.0.1:2378,127.0.0.1:2379] # etcd hosts
+#        Key: greet.grpc # the discovery key
+    # protoset mode
+    ProtoSets:
+      - hello.pb
+    # Mappings can also be written in proto options
+#    Mappings: # routes mapping
+#      - Method: get
+#        Path: /ping
+#        RpcPath: hello.Hello/Ping

goctl_template/gateway/main.tpl

@@ -0,0 +1,21 @@
+package main
+
+import (
+	"flag"
+
+	"github.com/zeromicro/go-zero/core/conf"
+	"github.com/zeromicro/go-zero/gateway"
+)
+
+var configFile = flag.String("f", "etc/gateway.yaml", "config file")
+
+func main() {
+	flag.Parse()
+
+	var c gateway.GatewayConf
+ 	
+	c.Timeout = int64(time.Second * 15)
+	gw := gateway.MustNewServer(c)
+	defer gw.Stop()
+	gw.Start()
+}

goctl_template/kube/deployment.tpl

@@ -0,0 +1,117 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: {{.Name}}
+  namespace: {{.Namespace}}
+  labels:
+    app: {{.Name}}
+spec:
+  replicas: {{.Replicas}}
+  revisionHistoryLimit: {{.Revisions}}
+  selector:
+    matchLabels:
+      app: {{.Name}}
+  template:
+    metadata:
+      labels:
+        app: {{.Name}}
+    spec:{{if .ServiceAccount}}
+      serviceAccountName: {{.ServiceAccount}}{{end}}
+      containers:
+      - name: {{.Name}}
+        image: {{.Image}}
+        {{if .ImagePullPolicy}}imagePullPolicy: {{.ImagePullPolicy}}
+        {{end}}ports:
+        - containerPort: {{.Port}}
+        readinessProbe:
+          tcpSocket:
+            port: {{.Port}}
+          initialDelaySeconds: 5
+          periodSeconds: 10
+        livenessProbe:
+          tcpSocket:
+            port: {{.Port}}
+          initialDelaySeconds: 15
+          periodSeconds: 20
+        resources:
+          requests:
+            cpu: {{.RequestCpu}}m
+            memory: {{.RequestMem}}Mi
+          limits:
+            cpu: {{.LimitCpu}}m
+            memory: {{.LimitMem}}Mi
+        volumeMounts:
+        - name: timezone
+          mountPath: /etc/localtime
+      {{if .Secret}}imagePullSecrets:
+      - name: {{.Secret}}
+      {{end}}volumes:
+        - name: timezone
+          hostPath:
+            path: /usr/share/zoneinfo/Asia/Shanghai
+
+---
+
+apiVersion: v1
+kind: Service
+metadata:
+  name: {{.Name}}-svc
+  namespace: {{.Namespace}}
+spec:
+  ports:
+  {{if .UseNodePort}}- nodePort: {{.NodePort}}
+    port: {{.Port}}
+    protocol: TCP
+    targetPort: {{.TargetPort}}
+  type: NodePort{{else}}- port: {{.Port}}
+    targetPort: {{.TargetPort}}{{end}}
+  selector:
+    app: {{.Name}}
+
+---
+
+apiVersion: autoscaling/v2beta2
+kind: HorizontalPodAutoscaler
+metadata:
+  name: {{.Name}}-hpa-c
+  namespace: {{.Namespace}}
+  labels:
+    app: {{.Name}}-hpa-c
+spec:
+  scaleTargetRef:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: {{.Name}}
+  minReplicas: {{.MinReplicas}}
+  maxReplicas: {{.MaxReplicas}}
+  metrics:
+  - type: Resource
+    resource:
+      name: cpu
+      target:
+        type: Utilization
+        averageUtilization: 80
+
+---
+
+apiVersion: autoscaling/v2beta2
+kind: HorizontalPodAutoscaler
+metadata:
+  name: {{.Name}}-hpa-m
+  namespace: {{.Namespace}}
+  labels:
+    app: {{.Name}}-hpa-m
+spec:
+  scaleTargetRef:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: {{.Name}}
+  minReplicas: {{.MinReplicas}}
+  maxReplicas: {{.MaxReplicas}}
+  metrics:
+  - type: Resource
+    resource:
+      name: memory
+      target:
+        type: Utilization
+        averageUtilization: 80

goctl_template/kube/job.tpl

@@ -0,0 +1,37 @@
+apiVersion: batch/v1
+kind: CronJob
+metadata:
+  name: {{.Name}}
+  namespace: {{.Namespace}}
+spec:
+  successfulJobsHistoryLimit: {{.SuccessfulJobsHistoryLimit}}
+  schedule: "{{.Schedule}}"
+  jobTemplate:
+    spec:
+      template:
+        spec:{{if .ServiceAccount}}
+          serviceAccountName: {{.ServiceAccount}}{{end}}
+	      {{end}}containers:
+          - name: {{.Name}}
+            image: # todo image url
+            resources:
+              requests:
+                cpu: {{.RequestCpu}}m
+                memory: {{.RequestMem}}Mi
+              limits:
+                cpu: {{.LimitCpu}}m
+                memory: {{.LimitMem}}Mi
+            command:
+            - ./{{.ServiceName}}
+            - -f
+            - ./{{.Name}}.yaml
+            volumeMounts:
+            - name: timezone
+              mountPath: /etc/localtime
+          imagePullSecrets:
+          - name: # registry secret, if no, remove this
+          restartPolicy: OnFailure
+          volumes:
+          - name: timezone
+            hostPath:
+              path: /usr/share/zoneinfo/Asia/Shanghai

goctl_template/model/delete.tpl

@@ -0,0 +1,14 @@
+func (m *default{{.upperStartCamelObject}}Model) Delete(ctx context.Context, {{.lowerStartCamelPrimaryKey}} {{.dataType}}) error {
+	{{if .withCache}}{{if .containsIndexCache}}data, err:=m.FindOne(ctx, {{.lowerStartCamelPrimaryKey}})
+	if err!=nil{
+		return err
+	}
+
+{{end}}	{{.keys}}
+    _, err {{if .containsIndexCache}}={{else}}:={{end}} m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := fmt.Sprintf("delete from %s where {{.originalPrimaryKey}} = {{if .postgreSql}}$1{{else}}?{{end}}", m.table)
+		return conn.ExecCtx(ctx, query, {{.lowerStartCamelPrimaryKey}})
+	}, {{.keyValues}}){{else}}query := fmt.Sprintf("delete from %s where {{.originalPrimaryKey}} = {{if .postgreSql}}$1{{else}}?{{end}}", m.table)
+		_,err:=m.conn.ExecCtx(ctx, query, {{.lowerStartCamelPrimaryKey}}){{end}}
+	return err
+}

goctl_template/model/err.tpl

@@ -0,0 +1,5 @@
+package {{.pkg}}
+
+import "github.com/zeromicro/go-zero/core/stores/sqlx"
+
+var ErrNotFound = sqlx.ErrNotFound

goctl_template/model/field.tpl

@@ -0,0 +1 @@
+{{.name}} {{.type}} {{.tag}} {{if .hasComment}}// {{.comment}}{{end}}

goctl_template/model/find-one-by-field-extra-method.tpl

@@ -0,0 +1,8 @@
+func (m *default{{.upperStartCamelObject}}Model) formatPrimary(primary any) string {
+	return fmt.Sprintf("%s%v", {{.primaryKeyLeft}}, primary)
+}
+
+func (m *default{{.upperStartCamelObject}}Model) queryPrimary(ctx context.Context, conn sqlx.SqlConn, v, primary any) error {
+	query := fmt.Sprintf("select %s from %s where {{.originalPrimaryField}} = {{if .postgreSql}}$1{{else}}?{{end}} limit 1", {{.lowerStartCamelObject}}Rows, m.table )
+	return conn.QueryRowCtx(ctx, v, query, primary)
+}

goctl_template/model/find-one-by-field.tpl

@@ -0,0 +1,30 @@
+func (m *default{{.upperStartCamelObject}}Model) FindOneBy{{.upperField}}(ctx context.Context, {{.in}}) (*{{.upperStartCamelObject}}, error) {
+	{{if .withCache}}{{.cacheKey}}
+	var resp {{.upperStartCamelObject}}
+	err := m.QueryRowIndexCtx(ctx, &resp, {{.cacheKeyVariable}}, m.formatPrimary, func(ctx context.Context, conn sqlx.SqlConn, v any) (i any, e error) {
+		query := fmt.Sprintf("select %s from %s where {{.originalField}} limit 1", {{.lowerStartCamelObject}}Rows, m.table)
+		if err := conn.QueryRowCtx(ctx, &resp, query, {{.lowerStartCamelField}}); err != nil {
+			return nil, err
+		}
+		return resp.{{.upperStartCamelPrimaryKey}}, nil
+	}, m.queryPrimary)
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}
+}{{else}}var resp {{.upperStartCamelObject}}
+	query := fmt.Sprintf("select %s from %s where {{.originalField}} limit 1", {{.lowerStartCamelObject}}Rows, m.table )
+	err := m.conn.QueryRowCtx(ctx, &resp, query, {{.lowerStartCamelField}})
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}
+}{{end}}

goctl_template/model/find-one.tpl

@@ -0,0 +1,26 @@
+func (m *default{{.upperStartCamelObject}}Model) FindOne(ctx context.Context, {{.lowerStartCamelPrimaryKey}} {{.dataType}}) (*{{.upperStartCamelObject}}, error) {
+	{{if .withCache}}{{.cacheKey}}
+	var resp {{.upperStartCamelObject}}
+	err := m.QueryRowCtx(ctx, &resp, {{.cacheKeyVariable}}, func(ctx context.Context, conn sqlx.SqlConn, v any) error {
+		query :=  fmt.Sprintf("select %s from %s where {{.originalPrimaryKey}} = {{if .postgreSql}}$1{{else}}?{{end}} limit 1", {{.lowerStartCamelObject}}Rows, m.table)
+		return conn.QueryRowCtx(ctx, v, query, {{.lowerStartCamelPrimaryKey}})
+	})
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}{{else}}query := fmt.Sprintf("select %s from %s where {{.originalPrimaryKey}} = {{if .postgreSql}}$1{{else}}?{{end}} limit 1", {{.lowerStartCamelObject}}Rows, m.table)
+	var resp {{.upperStartCamelObject}}
+	err := m.conn.QueryRowCtx(ctx, &resp, query, {{.lowerStartCamelPrimaryKey}})
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}{{end}}
+}

goctl_template/model/import-no-cache.tpl

@@ -0,0 +1,13 @@
+import (
+	"context"
+	"database/sql"
+	"fmt"
+	"strings"
+	{{if .time}}"time"{{end}}
+
+    {{if .containsPQ}}"github.com/lib/pq"{{end}}
+	"github.com/zeromicro/go-zero/core/stores/builder"
+	"github.com/zeromicro/go-zero/core/stores/sqlc"
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
+	"github.com/zeromicro/go-zero/core/stringx"
+)

goctl_template/model/import.tpl

@@ -0,0 +1,14 @@
+import (
+	"context"
+	"database/sql"
+	"fmt"
+	"strings"
+	{{if .time}}"time"{{end}}
+
+	{{if .containsPQ}}"github.com/lib/pq"{{end}}
+	"github.com/zeromicro/go-zero/core/stores/builder"
+	"github.com/zeromicro/go-zero/core/stores/cache"
+	"github.com/zeromicro/go-zero/core/stores/sqlc"
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
+	"github.com/zeromicro/go-zero/core/stringx"
+)

goctl_template/model/insert.tpl

@@ -0,0 +1,9 @@
+func (m *default{{.upperStartCamelObject}}Model) Insert(ctx context.Context, data *{{.upperStartCamelObject}}) (sql.Result,error) {
+	{{if .withCache}}{{.keys}}
+    ret, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := fmt.Sprintf("insert into %s (%s) values ({{.expression}})", m.table, {{.lowerStartCamelObject}}RowsExpectAutoSet)
+		return conn.ExecCtx(ctx, query, {{.expressionValues}})
+	}, {{.keyValues}}){{else}}query := fmt.Sprintf("insert into %s (%s) values ({{.expression}})", m.table, {{.lowerStartCamelObject}}RowsExpectAutoSet)
+    ret,err:=m.conn.ExecCtx(ctx, query, {{.expressionValues}}){{end}}
+	return ret,err
+}

goctl_template/model/interface-delete.tpl

@@ -0,0 +1 @@
+Delete(ctx context.Context, {{.lowerStartCamelPrimaryKey}} {{.dataType}}) error

goctl_template/model/interface-find-one-by-field.tpl

@@ -0,0 +1 @@
+FindOneBy{{.upperField}}(ctx context.Context, {{.in}}) (*{{.upperStartCamelObject}}, error)

goctl_template/model/interface-find-one.tpl

@@ -0,0 +1 @@
+FindOne(ctx context.Context, {{.lowerStartCamelPrimaryKey}} {{.dataType}}) (*{{.upperStartCamelObject}}, error)

goctl_template/model/interface-insert.tpl

@@ -0,0 +1 @@
+Insert(ctx context.Context, data *{{.upperStartCamelObject}}) (sql.Result,error)

goctl_template/model/interface-update.tpl

@@ -0,0 +1 @@
+Update(ctx context.Context, {{if .containsIndexCache}}newData{{else}}data{{end}} *{{.upperStartCamelObject}}) error

goctl_template/model/model-gen.tpl

@@ -0,0 +1,13 @@
+// Code generated by goctl. DO NOT EDIT.
+
+package {{.pkg}}
+{{.imports}}
+{{.vars}}
+{{.types}}
+{{.new}}
+{{.delete}}
+{{.find}}
+{{.insert}}
+{{.update}}
+{{.extraMethod}}
+{{.tableName}}

goctl_template/model/model-new.tpl

@@ -0,0 +1,6 @@
+func new{{.upperStartCamelObject}}Model(conn sqlx.SqlConn{{if .withCache}}, c cache.CacheConf, opts ...cache.Option{{end}}) *default{{.upperStartCamelObject}}Model {
+	return &default{{.upperStartCamelObject}}Model{
+		{{if .withCache}}CachedConn: sqlc.NewConn(conn, c, opts...){{else}}conn:conn{{end}},
+		table:      {{.table}},
+	}
+}

goctl_template/model/model.tpl

@@ -0,0 +1,30 @@
+package {{.pkg}}
+{{if .withCache}}
+import (
+	"github.com/zeromicro/go-zero/core/stores/cache"
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
+)
+{{else}}
+
+import "github.com/zeromicro/go-zero/core/stores/sqlx"
+{{end}}
+var _ {{.upperStartCamelObject}}Model = (*custom{{.upperStartCamelObject}}Model)(nil)
+
+type (
+	// {{.upperStartCamelObject}}Model is an interface to be customized, add more methods here,
+	// and implement the added methods in custom{{.upperStartCamelObject}}Model.
+	{{.upperStartCamelObject}}Model interface {
+		{{.lowerStartCamelObject}}Model
+	}
+
+	custom{{.upperStartCamelObject}}Model struct {
+		*default{{.upperStartCamelObject}}Model
+	}
+)
+
+// New{{.upperStartCamelObject}}Model returns a model for the database table.
+func New{{.upperStartCamelObject}}Model(conn sqlx.SqlConn{{if .withCache}}, c cache.CacheConf, opts ...cache.Option{{end}}) {{.upperStartCamelObject}}Model {
+	return &custom{{.upperStartCamelObject}}Model{
+		default{{.upperStartCamelObject}}Model: new{{.upperStartCamelObject}}Model(conn{{if .withCache}}, c, opts...{{end}}),
+	}
+}

goctl_template/model/table-name.tpl

@@ -0,0 +1,3 @@
+func (m *default{{.upperStartCamelObject}}Model) tableName() string {
+	return m.table
+}

goctl_template/model/tag.tpl

@@ -0,0 +1 @@
+`db:"{{.field}}"`

goctl_template/model/types.tpl

@@ -0,0 +1,14 @@
+type (
+	{{.lowerStartCamelObject}}Model interface{
+		{{.method}}
+	}
+
+	default{{.upperStartCamelObject}}Model struct {
+		{{if .withCache}}sqlc.CachedConn{{else}}conn sqlx.SqlConn{{end}}
+		table string
+	}
+
+	{{.upperStartCamelObject}} struct {
+		{{.fields}}
+	}
+)

goctl_template/model/update.tpl

@@ -0,0 +1,14 @@
+func (m *default{{.upperStartCamelObject}}Model) Update(ctx context.Context, {{if .containsIndexCache}}newData{{else}}data{{end}} *{{.upperStartCamelObject}}) error {
+	{{if .withCache}}{{if .containsIndexCache}}data, err:=m.FindOne(ctx, newData.{{.upperStartCamelPrimaryKey}})
+	if err!=nil{
+		return err
+	}
+
+{{end}}	{{.keys}}
+    _, {{if .containsIndexCache}}err{{else}}err:{{end}}= m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := fmt.Sprintf("update %s set %s where {{.originalPrimaryKey}} = {{if .postgreSql}}$1{{else}}?{{end}}", m.table, {{.lowerStartCamelObject}}RowsWithPlaceHolder)
+		return conn.ExecCtx(ctx, query, {{.expressionValues}})
+	}, {{.keyValues}}){{else}}query := fmt.Sprintf("update %s set %s where {{.originalPrimaryKey}} = {{if .postgreSql}}$1{{else}}?{{end}}", m.table, {{.lowerStartCamelObject}}RowsWithPlaceHolder)
+    _,err:=m.conn.ExecCtx(ctx, query, {{.expressionValues}}){{end}}
+	return err
+}

goctl_template/model/var.tpl

@@ -0,0 +1,8 @@
+var (
+{{.lowerStartCamelObject}}FieldNames = builder.RawFieldNames(&{{.upperStartCamelObject}}{}{{if .postgreSql}}, true{{end}})
+{{.lowerStartCamelObject}}Rows = strings.Join({{.lowerStartCamelObject}}FieldNames, ",")
+{{.lowerStartCamelObject}}RowsExpectAutoSet = {{if .postgreSql}}strings.Join(stringx.Remove({{.lowerStartCamelObject}}FieldNames, {{if .autoIncrement}}"{{.originalPrimaryKey}}", {{end}} {{.ignoreColumns}}), ","){{else}}strings.Join(stringx.Remove({{.lowerStartCamelObject}}FieldNames, {{if .autoIncrement}}"{{.originalPrimaryKey}}", {{end}} {{.ignoreColumns}}), ","){{end}}
+{{.lowerStartCamelObject}}RowsWithPlaceHolder = {{if .postgreSql}}builder.PostgreSqlJoin(stringx.Remove({{.lowerStartCamelObject}}FieldNames, "{{.originalPrimaryKey}}", {{.ignoreColumns}})){{else}}strings.Join(stringx.Remove({{.lowerStartCamelObject}}FieldNames, "{{.originalPrimaryKey}}", {{.ignoreColumns}}), "=?,") + "=?"{{end}}
+
+{{if .withCache}}{{.cacheKeys}}{{end}}
+)

goctl_template/mongo/err.tpl

@@ -0,0 +1,12 @@
+package gmodel
+
+import (
+	"errors"
+
+	"github.com/zeromicro/go-zero/core/stores/mon"
+)
+
+var (
+	ErrNotFound        = mon.ErrNotFound
+	ErrInvalidObjectId = errors.New("invalid objectId")
+)

goctl_template/mongo/model.tpl

@@ -0,0 +1,78 @@
+// Code generated by goctl. DO NOT EDIT.
+package gmodel
+
+import (
+    "context"
+    "time"
+
+    {{if .Cache}}"github.com/zeromicro/go-zero/core/stores/monc"{{else}}"github.com/zeromicro/go-zero/core/stores/mon"{{end}}
+    "go.mongodb.org/mongo-driver/bson"
+    "go.mongodb.org/mongo-driver/bson/primitive"
+    "go.mongodb.org/mongo-driver/mongo"
+)
+
+{{if .Cache}}var prefix{{.Type}}CacheKey = "cache:{{.lowerType}}:"{{end}}
+
+type {{.lowerType}}Model interface{
+    Insert(ctx context.Context,data *{{.Type}}) error
+    FindOne(ctx context.Context,id string) (*{{.Type}}, error)
+    Update(ctx context.Context,data *{{.Type}}) (*mongo.UpdateResult, error)
+    Delete(ctx context.Context,id string) (int64, error)
+}
+
+type default{{.Type}}Model struct {
+    conn {{if .Cache}}*monc.Model{{else}}*mon.Model{{end}}
+}
+
+func newDefault{{.Type}}Model(conn {{if .Cache}}*monc.Model{{else}}*mon.Model{{end}}) *default{{.Type}}Model {
+    return &default{{.Type}}Model{conn: conn}
+}
+
+
+func (m *default{{.Type}}Model) Insert(ctx context.Context, data *{{.Type}}) error {
+    if data.ID.IsZero() {
+        data.ID = primitive.NewObjectID()
+        data.CreateAt = time.Now()
+        data.UpdateAt = time.Now()
+    }
+
+    {{if .Cache}}key := prefix{{.Type}}CacheKey + data.ID.Hex(){{end}}
+    _, err := m.conn.InsertOne(ctx, {{if .Cache}}key, {{end}} data)
+    return err
+}
+
+func (m *default{{.Type}}Model) FindOne(ctx context.Context, id string) (*{{.Type}}, error) {
+    oid, err := primitive.ObjectIDFromHex(id)
+    if err != nil {
+        return nil, ErrInvalidObjectId
+    }
+
+    var data {{.Type}}
+    {{if .Cache}}key := prefix{{.Type}}CacheKey + id{{end}}
+    err = m.conn.FindOne(ctx, {{if .Cache}}key, {{end}}&data, bson.M{"_id": oid})
+    switch err {
+    case nil:
+        return &data, nil
+    case {{if .Cache}}monc{{else}}mon{{end}}.ErrNotFound:
+        return nil, ErrNotFound
+    default:
+        return nil, err
+    }
+}
+
+func (m *default{{.Type}}Model) Update(ctx context.Context, data *{{.Type}}) (*mongo.UpdateResult, error) {
+    data.UpdateAt = time.Now()
+    {{if .Cache}}key := prefix{{.Type}}CacheKey + data.ID.Hex(){{end}}
+    res, err := m.conn.UpdateOne(ctx, {{if .Cache}}key, {{end}}bson.M{"_id": data.ID}, bson.M{"$set": data})
+    return res, err
+}
+
+func (m *default{{.Type}}Model) Delete(ctx context.Context, id string) (int64, error) {
+    oid, err := primitive.ObjectIDFromHex(id)
+    if err != nil {
+        return 0, ErrInvalidObjectId
+    }
+	{{if .Cache}}key := prefix{{.Type}}CacheKey +id{{end}}
+    res, err := m.conn.DeleteOne(ctx, {{if .Cache}}key, {{end}}bson.M{"_id": oid})
+	return res, err
+}

goctl_template/mongo/model_custom.tpl

@@ -0,0 +1,38 @@
+package gmodel
+
+{{if .Cache}}import (
+    "github.com/zeromicro/go-zero/core/stores/cache"
+    "github.com/zeromicro/go-zero/core/stores/monc"
+){{else}}import "github.com/zeromicro/go-zero/core/stores/mon"{{end}}
+
+{{if .Easy}}
+const {{.Type}}CollectionName = "{{.snakeType}}"
+{{end}}
+
+var _ {{.Type}}Model = (*custom{{.Type}}Model)(nil)
+
+type (
+    // {{.Type}}Model is an interface to be customized, add more methods here,
+    // and implement the added methods in custom{{.Type}}Model.
+    {{.Type}}Model interface {
+        {{.lowerType}}Model
+    }
+
+    custom{{.Type}}Model struct {
+        *default{{.Type}}Model
+    }
+)
+
+
+// New{{.Type}}Model returns a model for the mongo.
+{{if .Easy}}func New{{.Type}}Model(url, db string{{if .Cache}}, c cache.CacheConf{{end}}) {{.Type}}Model {
+    conn := {{if .Cache}}monc{{else}}mon{{end}}.MustNewModel(url, db, {{.Type}}CollectionName{{if .Cache}}, c{{end}})
+    return &custom{{.Type}}Model{
+        default{{.Type}}Model: newDefault{{.Type}}Model(conn),
+    }
+}{{else}}func New{{.Type}}Model(url, db, collection string{{if .Cache}}, c cache.CacheConf{{end}}) {{.Type}}Model {
+    conn := {{if .Cache}}monc{{else}}mon{{end}}.MustNewModel(url, db, collection{{if .Cache}}, c{{end}})
+    return &custom{{.Type}}Model{
+        default{{.Type}}Model: newDefault{{.Type}}Model(conn),
+    }
+}{{end}}

goctl_template/mongo/model_types.tpl

@@ -0,0 +1,14 @@
+package gmodel
+
+import (
+	"time"
+
+	"go.mongodb.org/mongo-driver/bson/primitive"
+)
+
+type {{.Type}} struct {
+	ID primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"`
+	// TODO: Fill your own fields
+	UpdateAt time.Time `bson:"updateAt,omitempty" json:"updateAt,omitempty"`
+	CreateAt time.Time `bson:"createAt,omitempty" json:"createAt,omitempty"`
+}

goctl_template/newapi/newtemplate.tpl

@@ -0,0 +1,12 @@
+type Request {
+  Name string `path:"name,options=you|me"`
+}
+
+type Response {
+  Message string `json:"message"`
+}
+
+service {{.name}}-api {
+  @handler {{.handler}}Handler
+  get /from/:name(Request) returns (Response)
+}

goctl_template/rpc/call.tpl

@@ -0,0 +1,33 @@
+{{.head}}
+
+package {{.filePackage}}
+
+import (
+	"context"
+
+	{{.pbPackage}}
+	{{if ne .pbPackage .protoGoPackage}}{{.protoGoPackage}}{{end}}
+
+	"github.com/zeromicro/go-zero/zrpc"
+	"google.golang.org/grpc"
+)
+
+type (
+	{{.alias}}
+
+	{{.serviceName}} interface {
+		{{.interface}}
+	}
+
+	default{{.serviceName}} struct {
+		cli zrpc.Client
+	}
+)
+
+func New{{.serviceName}}(cli zrpc.Client) {{.serviceName}} {
+	return &default{{.serviceName}}{
+		cli: cli,
+	}
+}
+
+{{.functions}}

goctl_template/rpc/config.tpl

@@ -0,0 +1,7 @@
+package config
+
+import "github.com/zeromicro/go-zero/zrpc"
+
+type Config struct {
+	zrpc.RpcServerConf
+}

goctl_template/rpc/etc.tpl

@@ -0,0 +1,6 @@
+Name: {{.serviceName}}.rpc
+ListenOn: 0.0.0.0:8080
+Etcd:
+  Hosts:
+  - 127.0.0.1:2379
+  Key: {{.serviceName}}.rpc

goctl_template/rpc/logic-func.tpl

@@ -0,0 +1,6 @@
+{{if .hasComment}}{{.comment}}{{end}}
+func (l *{{.logicName}}) {{.method}} ({{if .hasReq}}in {{.request}}{{if .stream}},stream {{.streamBody}}{{end}}{{else}}stream {{.streamBody}}{{end}}) ({{if .hasReply}}{{.response}},{{end}} error) {
+	// todo: add your logic here and delete this line
+	
+	return {{if .hasReply}}&{{.responseType}}{},{{end}} nil
+}

goctl_template/rpc/logic.tpl

@@ -0,0 +1,24 @@
+package {{.packageName}}
+
+import (
+	"context"
+
+	{{.imports}}
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type {{.logicName}} struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func New{{.logicName}}(ctx context.Context,svcCtx *svc.ServiceContext) *{{.logicName}} {
+	return &{{.logicName}}{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+{{.functions}}

goctl_template/rpc/main.tpl

@@ -0,0 +1,38 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+
+	{{.imports}}
+
+	"github.com/zeromicro/go-zero/core/conf"
+	"github.com/zeromicro/go-zero/core/service"
+	"github.com/zeromicro/go-zero/zrpc"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/reflection"
+)
+
+var configFile = flag.String("f", "etc/{{.serviceName}}.yaml", "the config file")
+
+func main() {
+	flag.Parse()
+
+	var c config.Config
+	fsconfig.StartNacosConfig(*configFile, &c, nil)
+ 	
+	c.Timeout = int64(time.Second * 15)
+	ctx := svc.NewServiceContext(c)
+
+	s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
+{{range .serviceNames}}       {{.Pkg}}.Register{{.Service}}Server(grpcServer, {{.ServerPkg}}.New{{.Service}}Server(ctx))
+{{end}}
+		if c.Mode == service.DevMode || c.Mode == service.TestMode {
+			reflection.Register(grpcServer)
+		}
+	})
+	defer s.Stop()
+
+	fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
+	s.Start()
+}

goctl_template/rpc/server-func.tpl

@@ -0,0 +1,6 @@
+
+{{if .hasComment}}{{.comment}}{{end}}
+func (s *{{.server}}Server) {{.method}} ({{if .notStream}}ctx context.Context,{{if .hasReq}} in {{.request}}{{end}}{{else}}{{if .hasReq}} in {{.request}},{{end}}stream {{.streamBody}}{{end}}) ({{if .notStream}}{{.response}},{{end}}error) {
+	l := {{.logicPkg}}.New{{.logicName}}({{if .notStream}}ctx,{{else}}stream.Context(),{{end}}s.svcCtx)
+	return l.{{.method}}({{if .hasReq}}in{{if .stream}} ,stream{{end}}{{else}}{{if .stream}}stream{{end}}{{end}})
+}