添加 update_fspkg_master.tpl

goutils/proto_build/tpls/auto_grpc_nacos.tpl

@@ -30,7 +30,6 @@ func AutoGrpcInit(obj any) {
 
 	for i := 0; i < value.NumField(); i++ {
 		v := value.Field(i)
-
 		if v.IsValid() {
 			_namingClient, ok := v.Interface().(naming_client.INamingClient)
 			if ok {
@@ -42,7 +41,6 @@ func AutoGrpcInit(obj any) {
 
 {{range .ClientParams}} 
 
- 
 func Auto{{.ClientName}}Client(ctx context.Context) {{.ClientName}}Client {
 	if namingClient == nil {
 		log.Println("nameClient must be init. call")
@@ -54,52 +52,54 @@ func Auto{{.ClientName}}Client(ctx context.Context) {{.ClientName}}Client {
 		GroupName:   groupName,
 	}
 
-	for i := 0; i < 10; i++ {
+	for i := 0; i < 3; i++ {
 		insService, err := namingClient.SelectOneHealthyInstance(sel)
 		if err != nil {
 			log.Println(err)
-			return nil
+			continue
 		}
 		if insService.Enable && insService.Healthy {
-
 			conn, err := grpc.DialContext(ctx, fmt.Sprintf("%s:%d", insService.Ip, insService.Port), grpc.WithTransportCredentials(insecure.NewCredentials()))
 			if err != nil {
 				log.Println(err)
-				return nil
+				continue
 			}
 			return New{{.ClientName}}Client(conn)
 		}
 	}
+	log.Println(fmt.Errorf("no healthy with times 3"))
 	return nil
 }
 
-
-
 func Auto{{.ClientName}}ClientEx(ctx context.Context, opts ...grpc.DialOption) ({{.ClientName}}Client,error) {
     if namingClient == nil {
 		return nil, fmt.Errorf("nameClient must be init. call")
     }
 
+	opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()))
+
 	sel := vo.SelectOneHealthInstanceParam{
 		ServiceName: "{{.GrpcServiceName}}",
 		GroupName:   groupName,
 	}
 
-	for i := 0; i < 10; i++ {
+	for i := 0; i < 3; i++ {
 		insService, err := namingClient.SelectOneHealthyInstance(sel)
 		if err != nil {
-			return nil, err
+			log.Println(err)
+			continue
 		}
 		if insService.Enable && insService.Healthy {
 			conn, err := grpc.DialContext(ctx, fmt.Sprintf("%s:%d", insService.Ip, insService.Port), opts...)
 			if err != nil {
-				return nil, err
+				log.Println(err)
+				continue
 			}
     		return New{{.ClientName}}Client(conn), nil
 		}
 	}
 
-	return nil, fmt.Errorf("no healthy with times 10")
+	return nil, fmt.Errorf("no healthy with times 3")
 }
 
 {{end}}

goutils/proto_build/tpls/logic_grpc_struct.tpl

@@ -5,8 +5,10 @@ import (
 	"context"
 	"sync"
 	"fmt"
+	"runtime/debug"
 
 	"fusen-basic/env"
+	"fusen-basic/utils/log"
    
     "{{.ProjectName}}/gen/go/service"
 	"{{.ProjectName}}/server/config"
@@ -53,6 +55,7 @@ func (lgrpc *{{.StructName}}Grpc) {{.MethodName}}({{range $index, $param := .Par
 		if _recoverErr := recover(); _recoverErr != nil {
 			_resp = nil
 			_err = fmt.Errorf("%v", _recoverErr)
+			log.Printf("recovered from panic: %v\n%s", _err, string(debug.Stack()))
 		}
 	}()
     return New{{.StructName}}(ctx).{{.MethodName}}Logic({{range $index, $param := .ParamsName}}{{if $index}}, {{end}}{{$param}}{{end}}) 
@@ -64,6 +67,7 @@ func (lgrpc *{{.StructName}}Grpc) {{.MethodName}}(stream {{range $index, $param
     defer func() {
 		if _recoverErr := recover(); _recoverErr != nil {
 			_err = fmt.Errorf("%v", _recoverErr)
+			log.Printf("recovered from panic: %v\n%s", _err, string(debug.Stack()))
 		}
 	}()
 	return New{{.StructName}}(stream.Context()).{{.MethodName}}Logic(stream) 

goutils/proto_build/tpls/update_fspkg_master.tpl

@@ -1,25 +1,38 @@
-#! /bin/bash
+#! /bin/env bash
 
 input_string=$(cat go.mod)
 
 # 使用sed命令提取参数并替换输出格式
 output=$(echo "$input_string" | sed -nE 's/[[:space:]]{0,}(replace[[:space:]]+)?([[:alnum:]-]+)[[:space:]]+([[:alnum:].-]+)[[:space:]]+=>[[:space:]]+([[:alnum:]/.-]+)[[:space:]]+([[:alnum:].-]+)/\2 \3 \4 \5/p')
  
+# echo $output
+ischange="no"
+
 IFS=$'\n' # 设置分隔符为换行符
 for out in $output; do
     IFS=$' '
     read -r fsname fsversion fsfullname fslatest_master <<< "$out"
+    if [ "$fsname" != "fusen-basic" ]; then
+        continue
+    fi
+    
     laster_master=`echo $(GOPROXY=direct go get $fsfullname@master 2>&1) | grep -oE '@v[^:"]+'`
+    if [ "@$fslatest_master" == "$laster_master" ]; then
+        continue
+    fi
+   
     echo "go mod edit -replace $fsname@$fsversion=$fsfullname$laster_master"
     go mod edit -replace $fsname@$fsversion=$fsfullname$laster_master
+    echo "当前 $fsname $fsfullname $fslatest_master (更新)-> $laster_master"
+    go get $fsname@$fsversion
+    ischange="yes"
 done
  
-IFS=$'\n' # 设置分隔符为换行符
+ 
-for out in $output; do
+if [ "$ischange" == "yes" ]; then
-    IFS=$' '
+    echo "go tidy and vendor"
-    read -r fsname fsversion fsfullname fslatest_master <<< "$out"
+    go mod tidy
-    go get $fsname@$fsversion
+    go mod vendor
-done
+else
-
+    echo "$fsname $fslatest_master 当前最新"
-go mod tidy
+fi
-go mod vendor

service/auth.proto

@@ -10,7 +10,7 @@ import "service/basic.proto";
 //定义服务
 service auth {
 
-  // 登录接口
+  // 检验接口
   rpc ValidToken(ValidTokenRequest) returns (ValidTokenResponse) {}
 
   // Cookie 接受接口

service/basic.proto

@@ -27,12 +27,41 @@ message ResourceInfo{
     string bucket_name = 8;
     string source = 9;
     string uploaded_at = 10;
-    google.protobuf.Struct metadata = 11;
+    bytes metadata = 11;
+    string trace_id = 12;
 }
 
 message Meta {
-    int64 total_count =1;
+    int64 total_count =1; // 总数
-    int64 page_count=2;
+    int64 page_count=2; // 总页数
-    int64 current_page=3;
+    int64 current_page=3; // 当前页码
-    int64 per_page=4;
+    int64 per_page=4; // 每页数量
+}
+
+
+// 用户信息
+message FsUser {
+    int64 user_id = 7;//用户ID
+    string email = 1; // 邮箱
+    string first_name = 2; // 名
+    string last_name = 3; // 姓
+    string username = 4; // 用户名称
+    string company = 5; // 公司
+    string mobile = 6; // 电话号码
+}
+
+message LdapUser {
+    int64   user_id = 1;        //用户id
+    string  user_dn = 2;        //用户dn
+    string  user_name = 3;      //用户名
+    string  email = 4;          //邮箱
+    string  mobile = 5;         //手机号
+    string  avatar = 6;         //头像地址
+    int64   employee_type = 7;  //雇佣类型 1正式 2实习 3外包
+    int64   gender = 8;         //性别 1男 2女 3未知
+    string  birthday = 9;       //生日
+    repeated string belong_organizations = 10 ;//属于哪些部门
+    repeated string manage_organizations = 11 ;//管理哪些部门
+    int64   status = 12 ;   //状态 1正常0离职
+    int64   group_id = 13;  //权限分组id
 }

service/ldap.proto

@@ -26,8 +26,12 @@ service ldap {
     rpc UpdateLdapUserPwd(UpdateLdapUserPwdReq) returns(basic.Response){}
     //禁用ldap用户帐号
     rpc DisableLdapUser(DisableLdapUserReq) returns(basic.Response){}
+    //删除ldap用户帐号
+    rpc DeleteLdapUser(DeleteLdapUserReq) returns(basic.Response){}
     //获取用户信息
     rpc GetLdapUserInfo(GetLdapUserInfoReq) returns(GetLdapUserInfoRsp){}
+    //获取用户信息--批量
+    rpc GetLdapUsersByUserIds(GetLdapUsersByUserIdsReq) returns(GetLdapUsersRsp){}
     //ldap部门添加成员
     rpc AddLdapOrganizationMember(AddLdapOrganizationMemberReq) returns(basic.Response){}
     //ldap部门移除成员
@@ -55,7 +59,21 @@ service ldap {
     rpc SetLdapGroupAuth(SetLdapGroupAuthReq) returns (SetLdapGroupAuthRsp);
     //权限组授权--移除
     rpc RemoveLdapGroupAuth(RemoveLdapGroupAuthReq) returns (RemoveLdapGroupAuthRsp);
+
+    //验证权限组
+    rpc VerifyAuthorityGroup(VerifyAuthorityGroupReq) returns (VerifyAuthorityGroupRsp);
 }
+message VerifyAuthorityGroupReq {
+    string path = 1;
+    string method = 2;
+    string category = 3;
+    int64 group_id = 4;
+}
+
+message VerifyAuthorityGroupRsp {
+
+}
+
 message GetLdapGroupsReq {
     LdapGroupFilter filter = 1;
 
@@ -73,6 +91,7 @@ message GetLdapGroupDetailReq {
 }
 message GetLdapGroupDetailRsp {
     LdapGroup info = 1;
+    repeated int64 apis =2;
 }
 
 message SaveLdapGroupReq {
@@ -209,10 +228,25 @@ message UpdateLdapUserPwdReq{
 message DisableLdapUserReq{
     string user_dn = 1;//用户dn
 }
+//删除ldap用户帐号
+message DeleteLdapUserReq{
+    string user_dn = 1;//用户dn
+}
 //获取用户信息
 message GetLdapUserInfoReq{
     string user_dn = 1;//用户dn
 }
+
+//获取用户信息--批量
+message GetLdapUsersByUserIdsReq{
+    repeated int64 user_ids = 1;//用户ID
+}
+//获取用户信息--批量
+message GetLdapUsersByUserIdsRsp{
+    repeated GetLdapUsersItem list = 1;
+    string   paging_cookie = 2;
+}
+
 message GetLdapUserInfoRsp{
     int64  user_id = 1;     //用户id
     string user_dn = 2;     //用户dn
@@ -302,4 +336,12 @@ message LdapParseTokenRsp{
     string UserDn = 1;
     int64  UserId = 2;
     string UserEmail = 3;
+    int64 group_id = 4;
+    int64 gender = 5;//性别
+    string birthday = 6;//生日
+    repeated string belong_to_organizations = 7;//属于部门DN集合
+    repeated string belong_to_organization_names = 8;//属于部门名字集合
+    repeated string manage_organizations = 9;//管理的部门dn集合
+    repeated string manage_organization_names = 10;//管理的部门名字集合
+    int64 status = 11; //状态 1正常0离职
 }

service/notify.proto

@@ -12,10 +12,10 @@ import "google/protobuf/timestamp.proto";
 service notify { 
     
    // 心跳 必要 用来启动邮件
-   rpc Ping(basic.Request) returns (basic.Response) {}
+   rpc Ping( basic.Request) returns (basic.Response) {}
 
    // 邮件发送基础版本
-   rpc EmailSend(EmailSendReq) returns (EmailSendRes) {}
+   rpc EmailSend( EmailSendReq) returns (EmailSendResp) {}
  
    // 通过邮件通知 注册确认
    rpc EmailRegisterConfirm( EmailRegisterReq) returns (  EmailRegisterResp) {}
@@ -64,12 +64,13 @@ message EmailNotifyBasic {
     optional string notify_id = 1; // 用于处理唯一的任务,重发都会被利用到 256字节, 如果不写自动生成一个uuid
     string sender = 2; // 发送者
     string target_email = 3; // 发送的目标email
+    string subject_title = 4; // 子标题
 }
 
 
 // 默认是 type email
 message EmailSendReq {
-    EmailNotifyBasic basic_email = 1;
+    EmailNotifyBasic basic_email = 1; // 邮件基础要素
     string title = 2; // 邮件标题
     string content = 3;                 // 邮件内容 
     Operator operator = 4; // 操作类型
@@ -80,10 +81,9 @@ message EmailSendReq {
 enum NotifyType {
     email = 0;  // email
     feishu = 1; // 飞书
-    wechat = 2; // 微信
+    // wechat = 2; // 微信
 }
 
-
 // 操作类型
 enum EmailStatus {
     ok = 0;  // 成功
@@ -93,16 +93,14 @@ enum EmailStatus {
     finish = 4;      // 结束
 }
 
-
+message EmailSendResp {
-
+    EmailStatus status = 1; // 邮件的状态
-message EmailSendRes {
+    string msg = 2;  // 通知信息
-    EmailStatus status = 1; 
-    string msg = 2; 
 }
 
 message EmailRegisterReq {
-    EmailNotifyBasic basic_email = 1;
+    EmailNotifyBasic basic_email = 1; // 邮件基础要素
-    string confirmation_link = 2;
+    string confirmation_link = 2; // 邮件确认链接
 }
 
 message EmailRegisterResp {
@@ -112,8 +110,8 @@ message EmailRegisterResp {
 
 
 message EmailResetHtmlReq {
-    EmailNotifyBasic basic_email = 1;
+    EmailNotifyBasic basic_email = 1; // 邮件基础要素
-    string confirmation_link = 4;
+    string confirmation_link = 2; // 确认链接
 }
 
 message EmailResetHtmlResp {
@@ -121,6 +119,7 @@ message EmailResetHtmlResp {
     string notify_id = 2; // 通知id
 }
 
+// 这个不会接在rpc服务里
 message EmailResetConfirmReq {
     string reset_password_link = 1;
     string reset_token = 2;
@@ -133,8 +132,8 @@ message EmailResetConfirmResp {
 
 
 message OrderPaymentDetailsReq {
-    EmailNotifyBasic basic_email = 1;
+    EmailNotifyBasic basic_email = 1; // 邮件基础要素
-    string payment_details_link = 2; 
+    string payment_details_link = 2; // 支付详情链接
 }
 
 message OrderPaymentDetailsResp {
@@ -143,10 +142,11 @@ message OrderPaymentDetailsResp {
 }
 
 message OrderStatusTransitionReq {
-    EmailNotifyBasic basic_email = 1;
+    EmailNotifyBasic basic_email = 1; // 邮件基础要素
     string last_status = 2; // 上个状态
     string current_status = 3; // 当前状态
     string check_status_link = 4; // 检查状态
+    bool is_show_click_text = 5; // 展示 开始生产 到 生产完成时 的特殊显示语句 
 }
 
 message OrderStatusTransitionResp {
@@ -156,7 +156,7 @@ message OrderStatusTransitionResp {
 
 
 message OrderPayArrearsReq {
-    EmailNotifyBasic basic_email = 1;
+    EmailNotifyBasic basic_email = 1; // 邮件基础要素
     string pay_arrears_link = 2; // 检查状态
 }
 

service/order.proto

@@ -0,0 +1,141 @@
+syntax = "proto3"; //版本声明，使用v3版本
+
+package order;
+option go_package = "gitlab.fusenpack.com/backend/order;service";
+
+// 导入google/api/annotations.proto 注释依赖
+import "google/api/annotations.proto";
+import "service/basic.proto";
+import "google/protobuf/struct.proto";
+import "google/protobuf/any.proto";
+
+//定义服务
+service order {
+    // 更新详情
+    rpc OrderSave(OrderSaveReq) returns (OrderSaveRes) {}
+
+    // 获取详情
+    rpc OrderInfo(OrderInfoReq) returns (OrderInfoRes) {}
+
+    // 获取列表
+    rpc OrderList(OrderListReq) returns (OrderListRes) {}
+
+    // 详情处理
+    rpc DetailHandler(DetailHandlerReq) returns (DetailHandlerRes) {}
+}
+/* 详情处理 */
+message DetailHandlerReq{
+    bytes order_db = 1;// 订单数据库数据
+    int64 handle_type = 2; // 处理类型：0=原数据，1=返回处理数据
+    int64 channle_type = 3; // 处理类型：0=后台，1=前台
+}
+message DetailHandlerRes{
+    bytes order_detail = 1; // 处理后数据
+}
+/* 详情处理 */
+
+/* 更新详情 */
+message OrderSaveReq{
+    OrderFilter filter = 1; // 筛选条件
+    OrderDetailDb save = 2; // 更新数据
+}
+message OrderSaveRes{
+    OrderInfo info = 1; // 详情数据
+}
+/* 更新详情 */
+
+/* 获取详情 */
+message OrderInfoReq{
+    OrderFilter filter = 1;// 筛选条件
+    int64 handle_type = 2; // 处理类型：0=原数据，1=返回处理数据
+    int64 channle_type = 3; // 处理类型：0=后台，1=前台
+    repeated int64 related = 4; // 关联数据：1=用户信息，2=支付记录
+}
+message OrderInfoRes{
+    OrderInfo info = 1; // 详情数据
+}
+/* 获取详情 */
+
+/* 获取列表 */
+message OrderListReq{
+    OrderFilter filter = 1; // 筛选条件
+    int64 handle_type = 2; // 处理类型：0=原数据，1=返回处理数据
+    int64 channle_type = 3; // 处理类型：0=后台，1=前台
+    repeated int64 related = 4; // 关联数据：1=用户信息，2=支付记录，3=销售信息，4=设计信息，5=供应链信息
+
+
+    bool select_whole = 100; // 查询类型：false=分页 true=全部数据
+    int64 current_page = 101; // 当前页码
+    int64 per_page = 102; // 每页数量
+    string order_by = 103; // 排序条件： 如 id desc,ctime desc
+    string select_fields = 104; // 查询字段
+}
+message OrderListRes{
+    repeated  OrderInfo list = 1;// 列表数据
+    basic.Meta meta = 2; // 列表参数
+}
+/* 获取列表 */
+
+/* 过滤条件 */
+message OrderFilter {
+    optional int64 id = 1;// 主键ID
+    optional int64 user_id = 2; // 用户ID
+    optional int64 delivery_method = 3; // 物流类型
+    optional string order_sn = 4; // 订单编号
+    optional string order_source = 5; // 订单来源
+    optional int64 status = 6; // 订单状态
+    optional int64 is_del = 7; // 是否删除：0=否，1=是
+    optional int64 pay_status = 8; // 支付状态
+    optional int64 sale_gerent_id = 9; // 销售负责人
+    optional int64 design_gerent_id = 10; // 设计负责人
+    optional string ctime = 11; // 创建时间
+    optional string utime = 12; // 更新时间
+
+    optional bytes other_filter = 101; // 其他筛选条件
+    repeated int64 ids = 102; // 主键IDS
+}
+
+/* 详情数据 */
+message OrderInfo {
+    OrderDetailDb order_detail_db = 1; // 原数据
+    bytes order_detail = 2; // 处理后数据
+    basic.FsUser user_info = 3; // 用户数据
+    basic.LdapUser sale_info = 4; // 销售负责人
+    basic.LdapUser design_info = 5; // 设计负责人
+    OrderScm scm_info = 6;
+}
+message OrderScm {
+    repeated basic.LdapUser scm_info = 1; // 供应链信息
+    repeated int64 scm_ids = 2; // 供应链信息
+}
+
+/* 数据库 */
+message OrderDetailDb {
+    int64      id = 1; // 主键ID
+    optional int64      user_id = 2; // 用户ID
+    optional int64      delivery_method = 3; // 物流类型
+    optional string     order_sn = 4; // 订单编号
+    optional string     order_source = 5; // 订单来源
+    optional int64      status = 6; // 订单状态
+    optional bytes      metadata = 7; // 额外参数
+    optional string     ctime = 8; // 创建时间
+    optional string     utime = 9; // 更新时间
+    optional int64      is_del = 10; // 是否删除：0 = 否，1 = 是
+    optional int64      pay_status = 11; // 支付状态
+    optional bytes      status_link = 12; // 订单状态链路
+    optional bytes      order_product = 13; // 订单商品
+    optional bytes      order_address = 14; // 订单地址
+    optional bytes      order_amount = 15; // 订单金额
+    optional bytes      pay_status_link = 16; // 支付状态链路
+    optional bytes      shopping_cart_snapshot = 17; // 购物车快照
+    optional bytes      shopping_product_snapshot = 18; // 购物车商品快照
+    optional int64      sale_gerent_id = 19; // 销售负责人
+    optional int64      design_gerent_id = 20; // 设计负责人
+    optional bytes      scm = 21; // 供应链管理
+    optional int64      order_type = 22; // 订单类型：1=平台，2=线下
+    optional string     pay_deposit_ctime = 23; // 支付时间--定金
+    optional string     pay_final_ctime = 24; // 支付时间--尾款
+}
+
+
+

service/resource.proto

@@ -45,7 +45,47 @@ service resource {
     // 设置示例logo
     rpc SetExampleLogo(SetExampleLogoReq) returns (SetExampleLogoRes) {}
 
+    // 导出文件--CSV
+    rpc ExportCsv(ExportCsvReq) returns (ExportCsvRes) {} 
+
+    // 导出文件--Excel
+    rpc ExportExcel(ExportExcelReq) returns (ExportExcelRes) {} 
+
+    // 导出文件--zip
+    rpc ExportZip(ExportZipReq) returns (ExportZipRes) {} 
+
 }
+message ExportData {
+    repeated string child = 1;
+}
+
+message ExportCsvReq {
+    repeated ExportData file_data = 1; // 文件数据
+    string file_name = 2;// 文件名称
+    int64 total = 3; // 数据量
+}
+message ExportCsvRes {
+    string export_file_path = 1; // 下载链接
+}
+
+message ExportExcelReq {
+    repeated ExportData file_data = 1; // 文件数据
+    string file_name = 2;// 文件名称
+}
+message ExportExcelRes {
+    string export_file_path = 1; // 下载链接
+}
+
+message ExportZipReq {
+    string file_type = 1;// 文件类型
+    string file_name = 2;// 文件名称
+    bytes file_bytes = 3;// 文件流
+}
+message ExportZipRes {
+    string export_file_path = 1; // 下载链接
+}
+
+
 /* 设置示例logo */
 message SetExampleLogoReq {
     int64 is_example = 1;
@@ -304,4 +344,5 @@ message ResourceIds {
     repeated string resource_ids = 1;
 }
 
-/* 获取资源详情 */
+/* 获取资源详情 */
+