updateservicelogic.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351
  1. // Code scaffolded by goctl. Safe to edit.
  2. // goctl 1.10.2
  3. package logic
  4. import (
  5. "bytes"
  6. "context"
  7. "encoding/json"
  8. "fmt"
  9. "io"
  10. "net/http"
  11. "net/url"
  12. "path"
  13. "strings"
  14. "udeServer/internal/apierr"
  15. "udeServer/internal/audit"
  16. "udeServer/internal/model"
  17. "udeServer/internal/svc"
  18. "udeServer/internal/types"
  19. "github.com/zeromicro/go-zero/core/logx"
  20. "github.com/zeromicro/go-zero/core/stores/sqlx"
  21. )
  22. type UpdateServiceLogic struct {
  23. logx.Logger
  24. ctx context.Context
  25. svcCtx *svc.ServiceContext
  26. }
  27. func NewUpdateServiceLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateServiceLogic {
  28. return &UpdateServiceLogic{
  29. Logger: logx.WithContext(ctx),
  30. ctx: ctx,
  31. svcCtx: svcCtx,
  32. }
  33. }
  34. func (l *UpdateServiceLogic) UpdateService(req *types.UpdateServiceReq) (*types.ServiceResp, error) {
  35. if err := checkId(req.Id); err != nil {
  36. return nil, err
  37. }
  38. // 查旧实体:换密钥校验需要旧的 mount_status/key_iden;
  39. // 目录联动需要旧目录清单(算差集,决定哪些目录要去外挂程序卸载)
  40. svc, err := findService(l.ctx, l.svcCtx.ServiceModel, req.Id)
  41. if err != nil {
  42. return nil, err
  43. }
  44. // B 方案硬校验:挂载中的服务禁止更换密钥。
  45. // 原因:FUSE 实际挂载仍用【旧密钥】解密,库里 keyIden 换成新的会形成"记新挂旧"的
  46. // 脏状态,后续任何按库里 keyIden 进行的重挂/刷库都会用错密钥 → 旧密文读成乱码。
  47. // 正规路径:卸载 → 用旧密钥解密存量 → 新密钥重加密(刷库) → 新密钥重新挂载。
  48. if svc.MountStatus.String == "mounted" && req.KeyIden != svc.KeyIden.String {
  49. return nil, apierr.BadRequest("服务正在挂载中,禁止更换密钥;请先卸载后再操作")
  50. }
  51. // 旧目录清单:联动卸载的依据(哪些目录被移除了,才需要去外挂程序卸载)
  52. oldDirs, err := l.svcCtx.DirectoryModel.FindDirsByServiceId(l.ctx, req.Id)
  53. if err != nil {
  54. l.Errorf("query old directories of service %d failed: %v", req.Id, err)
  55. return nil, err
  56. }
  57. // 新目录清单规范化:trim 去空白 + path.Clean(发给 Linux 外挂必须保持 / 分隔符) + 去重
  58. newDirs := make([]string, 0, len(req.Directories))
  59. for _, dir := range req.Directories {
  60. dir = strings.TrimSpace(dir)
  61. if dir == "" {
  62. continue
  63. }
  64. newDirs = append(newDirs, path.Clean(dir))
  65. }
  66. newDirs = dedupStrings(newDirs)
  67. // 挂载联动(事务前软处理):只有带 directories 字段的请求(编辑弹窗)才触发;
  68. // changeStatus 状态开关等不传 directories 的调用方完全不受影响,状态保持原值。
  69. // 联动失败绝不阻塞保存,失败信息聚合成 mountWarning 由前端弹黄色警告。
  70. mountWarning := ""
  71. mountStatus := svc.MountStatus.String // 无联动动作时,Update 原样写回旧值
  72. if req.Directories != nil {
  73. mountWarning, mountStatus = l.applyMountChanges(svc, oldDirs, newDirs, req)
  74. }
  75. // 编辑联动时,服务状态与挂载结果强绑定(与新增/启用服务同规则):
  76. // 联动挂载成功 → mount_status=mounted 且 status 同步置"启用"
  77. // (否则挂载状态变了、服务状态没变,好端端挂上的服务在列表里仍显示停用);
  78. // 联动任一失败 → mount_status=failed 且 status 同步置"停用",避免"启用+failed"错位;
  79. // 没有挂载动作(unmounted:已挂载服务换机全卸 / 未挂载服务清空目录) → status 保持原值。
  80. // req.Directories==nil 的调用方(状态开关)不受影响。
  81. finalStatus := req.Status
  82. if req.Directories != nil {
  83. if mountStatus == "mounted" {
  84. finalStatus = "启用"
  85. } else if mountStatus == "failed" {
  86. finalStatus = "停用"
  87. }
  88. }
  89. // 事务:更新服务 + 目录全删全插(与新增服务同款后端收口模式,任一步失败整体回滚)
  90. err = l.svcCtx.DB.Transact(func(session sqlx.Session) error {
  91. svcModel := l.svcCtx.ServiceModel.WithSession(session)
  92. dirModel := l.svcCtx.DirectoryModel.WithSession(session)
  93. data := &model.TService{
  94. Id: req.Id,
  95. Name: nullString(req.Name),
  96. Ip: nullString(req.Ip),
  97. Port: req.Port, // 端口 int 类型,int64 直传(0=未配置)
  98. Iden: nullString(req.Iden),
  99. KeyIden: nullString(req.KeyIden),
  100. KeyAlgo: nullString(req.KeyAlgo),
  101. Status: nullString(finalStatus),
  102. MountStatus: nullString(mountStatus), // 联动算出的新状态(没联动就是旧值)
  103. Brush: req.Brush, // 一键刷库配置:编辑只落库改配置,不追溯触发刷库(刷库编排仅在创建流程)
  104. }
  105. if err := svcModel.Update(l.ctx, data); err != nil {
  106. return fmt.Errorf("update t_service %d: %w", req.Id, err)
  107. }
  108. // 目录三态:nil = 不动目录(状态开关等场景);空数组 = 清空;非空 = 全量重写
  109. if req.Directories != nil {
  110. if err := dirModel.DeleteByServiceId(l.ctx, req.Id); err != nil {
  111. return fmt.Errorf("delete old directories of service %d: %w", req.Id, err)
  112. }
  113. for _, dir := range newDirs {
  114. if _, err := dirModel.Insert(l.ctx, &model.TDirectory{
  115. ServiceId: nullInt64(req.Id),
  116. Directory: nullString(dir),
  117. }); err != nil {
  118. return fmt.Errorf("insert t_directory[%s]: %w", dir, err)
  119. }
  120. }
  121. }
  122. return nil
  123. })
  124. if err != nil {
  125. l.Errorf("update service tx failed: %v", err)
  126. return nil, err
  127. }
  128. updated, err := findService(l.ctx, l.svcCtx.ServiceModel, req.Id)
  129. if err != nil {
  130. return nil, err
  131. }
  132. resp := toServiceResp(updated)
  133. if mountWarning != "" {
  134. resp.MountWarning = mountWarning // 联动有失败时前端弹黄色警告
  135. }
  136. return resp, nil
  137. }
  138. // ======== 编辑联动挂载的辅助方法 ========
  139. // applyMountChanges 编辑保存时的挂载联动:对比新旧目录,该卸的卸、该挂的挂。
  140. // 联动在【事务之前】执行且全程软处理:任何失败只聚合成警告文案,绝不阻塞保存。
  141. // 幂等复用:新目录全量下发挂载,外挂的幂等决策表会自动跳过"已挂且同密钥"的目录,
  142. // 顺带把 failed 服务漏挂的目录也补挂上(自愈)。
  143. // 返回:warning(空串 = 联动全部成功), newStatus(联动后应写入库的 mount_status)。
  144. func (l *UpdateServiceLogic) applyMountChanges(svc *model.TService, oldDirs, newDirs []string, req *types.UpdateServiceReq) (string, string) {
  145. // IP/端口变了 = 外挂换机器了:旧机器上的挂载全部要卸,新机器全量重挂
  146. ipChanged := req.Ip != svc.Ip.String || req.Port != svc.Port // port 已是 int64,直接数值比较
  147. // 该卸载的清单:换 IP → 全卸;没换 IP → 只卸"被移除"的目录(差集 old-new)
  148. var toUnmount []string
  149. if ipChanged {
  150. toUnmount = oldDirs
  151. } else {
  152. toUnmount = diffStrings(oldDirs, newDirs)
  153. }
  154. // 已挂载(mounted)的服务编辑时不重新触发挂载:剩余目录仍挂在外挂上, 先挂载也可以
  155. needMount := true
  156. var msgs []string
  157. // 1. 先卸载(清理动作,已挂载服务也保留):发往【旧】IP(挂载记录登记在旧机器的外挂程序进程里)
  158. if len(toUnmount) > 0 {
  159. oldIp, oldPort := svc.Ip.String, svc.Port // port 已是 int64
  160. if oldIp == "" || oldPort == 0 {
  161. msgs = append(msgs, "原外挂 IP/端口为空,无法联动卸载,旧目录可能仍处于挂载状态")
  162. } else {
  163. for _, dir := range toUnmount {
  164. // 卸载发往旧机器,用旧 iden 作 X-TOKEN(旧机器的外挂 TOKEN 按旧值配置)
  165. if w := l.fuseUnmountOne(svc.Iden.String, oldIp, oldPort, dir); w != "" {
  166. msgs = append(msgs, w)
  167. }
  168. }
  169. }
  170. }
  171. // 2. 再挂载:仅未挂载(unmounted/failed)的服务才全量下发,
  172. // 幂等表自动跳过已挂的目录,顺带把 failed 服务漏挂的目录补挂上(自愈)。
  173. if needMount && len(newDirs) > 0 {
  174. if req.Ip == "" || req.Port == 0 {
  175. msgs = append(msgs, "新外挂 IP/端口为空,无法联动挂载")
  176. } else {
  177. ikey, err := l.lookupIkey(req.KeyIden)
  178. if err != nil {
  179. msgs = append(msgs, fmt.Sprintf("联动挂载失败: %v", err))
  180. } else {
  181. for _, dir := range newDirs {
  182. // 挂载发往新机器,用新 iden 作 X-TOKEN(新机器的外挂 TOKEN 按新值配置)
  183. if w := l.fuseMountOne(req.Iden, req.Ip, req.Port, dir, ikey); w != "" {
  184. msgs = append(msgs, w)
  185. }
  186. }
  187. }
  188. }
  189. }
  190. // 3. mount_status 重算:
  191. // 任一动作失败 → failed(同时返回聚合警告,主流程会把 status 一并置"停用");
  192. // 未挂载服务走了挂载 → 全成功有目录 = mounted,清空目录 = unmounted;
  193. // 已挂载服务(未重新挂载)→ 换机全卸了 = unmounted,否则剩余目录仍挂着 = 保持 mounted。
  194. if len(msgs) > 0 {
  195. return "编辑已保存,但挂载联动存在失败: " + strings.Join(msgs, "; "), "failed"
  196. }
  197. if needMount {
  198. if len(newDirs) > 0 {
  199. return "", "mounted"
  200. }
  201. return "", "unmounted"
  202. }
  203. if ipChanged && len(toUnmount) > 0 {
  204. return "", "unmounted" // 换机把旧挂载全卸了,新机器上没有挂载
  205. }
  206. return "", svc.MountStatus.String
  207. }
  208. // fuseMountOne 通知外挂程序挂载单个目录。成功返回空串,失败返回警告文案。
  209. // 请求体与新增服务完全同款:{backing: 目录+"-cipher", mount: 目录, ikey: 密钥内容}
  210. func (l *UpdateServiceLogic) fuseMountOne(iden, ip string, port int64, mount, ikey string) string {
  211. // path.Clean(非 filepath!):路径要发给远程 Linux 外挂程序,必须保持 / 分隔符
  212. dirLinuxPath := path.Clean(mount)
  213. payload := map[string]interface{}{
  214. "backing": dirLinuxPath + "-cipher", // 密文目录 = 保护目录 + "-cipher" 后缀
  215. "mount": dirLinuxPath, // 挂载点 = 保护目录本身
  216. "ikey": ikey,
  217. }
  218. body, err := json.Marshal(payload)
  219. if err != nil {
  220. return fmt.Sprintf("序列化挂载请求失败: %v", err)
  221. }
  222. baseURL := fmt.Sprintf("http://%s:%d/api/fuseMount", ip, port) // %d:port 是 int64
  223. // DoSimple 记录 type=2 接口日志,父 Span 指向本次入站请求
  224. if _, callErr := audit.DoSimple(l.svcCtx.SpanRecorder, l.ctx, "FuseMount", baseURL, body,
  225. func() (map[string]interface{}, int64, error) {
  226. // doFuseRequest 注入 X-TOKEN(按 iden 换算的 apiSecret);client.Post 快捷方式带不了自定义头,裸发会被外挂 401 拒绝
  227. resp, rerr := doFuseRequest(l.ctx, l.svcCtx, fuseMountClient, iden, http.MethodPost, baseURL, bytes.NewReader(body), "application/json")
  228. if rerr != nil {
  229. return nil, 0, fmt.Errorf("挂载目录 %s 失败(外挂程序未启动?): %w", dirLinuxPath, rerr)
  230. }
  231. raw, _ := io.ReadAll(resp.Body) // 读到 EOF 保证 TCP 连接复用 Keep-Alive
  232. resp.Body.Close()
  233. status := int64(resp.StatusCode)
  234. if status >= http.StatusBadRequest {
  235. return nil, status, fmt.Errorf("挂载目录 %s 失败,外挂程序返回 HTTP %d: %s", dirLinuxPath, status, string(raw))
  236. }
  237. return map[string]interface{}{"status": status, "body": string(raw)}, status, nil
  238. }); callErr != nil {
  239. return callErr.Error()
  240. }
  241. l.Infof("fuse mount ok: %s -> %s", dirLinuxPath, dirLinuxPath+"-cipher")
  242. return ""
  243. }
  244. // fuseUnmountOne 通知外挂程序卸载单个挂载点。成功返回空串,失败返回警告文案。
  245. // 卸载接口幂等:挂载点不在外挂注册表中也返回成功,所以重存/多卸都零成本。
  246. func (l *UpdateServiceLogic) fuseUnmountOne(iden, ip string, port int64, mount string) string {
  247. cleanMount := path.Clean(mount) // 同上,发给 Linux 必须保持 / 分隔符
  248. baseURL := fmt.Sprintf("http://%s:%d/api/fuseUnMount", ip, port) // %d:port 是 int64
  249. reqURL, uerr := url.Parse(baseURL)
  250. if uerr != nil {
  251. return fmt.Sprintf("解析 URL 失败: %v", uerr)
  252. }
  253. q := reqURL.Query()
  254. q.Set("mount", cleanMount) // q.Encode() 自动做 URL 编码(/ → %2F),外挂侧 Query().Get 自动解码还原
  255. reqURL.RawQuery = q.Encode() // 关键:Query() 返回的是副本,Set 只改副本;必须写回 RawQuery 才真正拼进 URL(停用/删除卸载同款写法)
  256. finalURL := reqURL.String()
  257. // DoSimple 记录 type=2 接口日志,父 Span 指向本次入站请求(GET 请求用 url 描述请求原文)
  258. if _, callErr := audit.DoSimple(l.svcCtx.SpanRecorder, l.ctx, "FuseUnMount", finalURL,
  259. audit.BuildRemoteGetRequest(http.MethodGet, finalURL),
  260. func() (map[string]interface{}, int64, error) {
  261. // doFuseRequest 注入 X-TOKEN(按 iden 换算的 apiSecret);client.Get 快捷方式带不了自定义头,裸发会被外挂 401 拒绝
  262. resp, rerr := doFuseRequest(l.ctx, l.svcCtx, fuseMountClient, iden, http.MethodGet, finalURL, nil, "")
  263. if rerr != nil {
  264. return nil, 0, fmt.Errorf("卸载目录 %s 失败(外挂程序未启动?): %w", cleanMount, rerr)
  265. }
  266. raw, _ := io.ReadAll(resp.Body) // 读到 EOF 保证 TCP 连接复用 Keep-Alive
  267. resp.Body.Close()
  268. status := int64(resp.StatusCode)
  269. if status >= http.StatusBadRequest {
  270. return nil, status, fmt.Errorf("卸载目录 %s 失败,外挂程序返回 HTTP %d: %s", cleanMount, status, string(raw))
  271. }
  272. return map[string]interface{}{"status": status, "body": string(raw)}, status, nil
  273. }); callErr != nil {
  274. return callErr.Error()
  275. }
  276. l.Infof("fuse unmount ok: %s", cleanMount)
  277. return ""
  278. }
  279. // lookupIkey 按密钥标识(keyIden)查密钥内容,下发挂载时作为 ikey 使用。
  280. // 独立成方法供编辑联动复用,不动 createservicelogic.go 的原有实现。
  281. func (l *UpdateServiceLogic) lookupIkey(keyIden string) (string, error) {
  282. if keyIden == "" {
  283. return "", fmt.Errorf("服务未配置密钥标识(keyIden),无法下发挂载")
  284. }
  285. key, err := l.svcCtx.KeyModel.FindOneByIden(l.ctx, keyIden)
  286. if err != nil {
  287. return "", fmt.Errorf("查询密钥(%s)失败: %w", keyIden, err)
  288. }
  289. ikey := key.Content.String
  290. if ikey == "" {
  291. return "", fmt.Errorf("密钥(%s)内容为空,无法下发挂载", keyIden)
  292. }
  293. return ikey, nil
  294. }
  295. // diffStrings 集合差集:返回"在 oldDirs 中但不在 newDirs 中"的元素(被移除的目录)。
  296. func diffStrings(oldDirs, newDirs []string) []string {
  297. // map[string]bool 当集合用:value 只存 true/false,判断"存在性"是 O(1)
  298. newSet := make(map[string]bool, len(newDirs))
  299. for _, v := range newDirs {
  300. newSet[v] = true
  301. }
  302. out := make([]string, 0, len(oldDirs))
  303. for _, v := range oldDirs {
  304. if !newSet[v] {
  305. out = append(out, v)
  306. }
  307. }
  308. return out
  309. }
  310. // dedupStrings 保序去重:同一路径提交两次只落库/下发一次。
  311. func dedupStrings(in []string) []string {
  312. seen := make(map[string]bool, len(in))
  313. out := make([]string, 0, len(in))
  314. for _, v := range in {
  315. if seen[v] {
  316. continue // 已见过,跳过
  317. }
  318. seen[v] = true
  319. out = append(out, v)
  320. }
  321. return out
  322. }