ai_summary.go 53 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606
  1. package ai
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/models"
  5. "eta/eta_api/models/ai_summary"
  6. "eta/eta_api/models/aimod"
  7. "eta/eta_api/models/sandbox"
  8. saModel "eta/eta_api/models/semantic_analysis"
  9. aiSummaryService "eta/eta_api/services/ai_summary"
  10. "eta/eta_api/services/aiser"
  11. "eta/eta_api/utils"
  12. "fmt"
  13. "github.com/rdlucklib/rdluck_tools/paging"
  14. "strconv"
  15. "time"
  16. )
  17. // AiSummaryClassifyItems
  18. // @Title 获取所有ai纪要分类接口
  19. // @Description 获取所有ai纪要分类接口
  20. // @Param IsShowMe query bool true "是否只看我的,true、false"
  21. // @Success 200 {object} data_manage.ChartClassifyListResp
  22. // @router /summary/classify/list [get]
  23. func (this *AiController) AiSummaryClassifyItems() {
  24. br := new(models.BaseResponse).Init()
  25. defer func() {
  26. this.Data["json"] = br
  27. this.ServeJSON()
  28. }()
  29. resp := new(ai_summary.AiSummaryClassifyListResp)
  30. aiSummaryClassifyId, _ := this.GetInt("AiSummaryClassifyId")
  31. isShowMe, _ := this.GetBool("IsShowMe")
  32. if isShowMe {
  33. errMsg, err := aiSummaryService.GetAiSummaryClassifyListForMe(*this.SysUser, resp, aiSummaryClassifyId)
  34. if err != nil {
  35. br.Msg = errMsg
  36. br.ErrMsg = err.Error()
  37. return
  38. }
  39. br.Ret = 200
  40. br.Success = true
  41. br.Msg = "获取成功"
  42. br.Data = resp
  43. fmt.Println("source my classify")
  44. return
  45. }
  46. rootList, err := ai_summary.GetAiSummaryClassifyAndInfoByParentId(aiSummaryClassifyId)
  47. if err != nil && err.Error() != utils.ErrNoRow() {
  48. br.Msg = "获取失败"
  49. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  50. return
  51. }
  52. for k := range rootList {
  53. rootList[k].UniqueCode = strconv.Itoa(rootList[k].AiSummaryClassifyId) + "_" + strconv.Itoa(rootList[k].AiSummaryId)
  54. }
  55. classifyAll, err := ai_summary.GetAiSummaryClassifyAndInfoByParentId(aiSummaryClassifyId)
  56. if err != nil && err.Error() != utils.ErrNoRow() {
  57. br.Msg = "获取失败"
  58. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  59. return
  60. }
  61. for k := range classifyAll {
  62. classifyAll[k].UniqueCode = strconv.Itoa(classifyAll[k].AiSummaryClassifyId) + "_" + strconv.Itoa(classifyAll[k].AiSummaryId)
  63. }
  64. nodeAll := make([]*ai_summary.AiSummaryClassifyItems, 0)
  65. for k := range rootList {
  66. rootNode := rootList[k]
  67. aiSummaryService.AiSummaryClassifyItemsMakeTreeV2(this.SysUser, classifyAll, rootNode)
  68. nodeAll = append(nodeAll, rootNode)
  69. }
  70. resp.AllNodes = nodeAll
  71. br.Ret = 200
  72. br.Success = true
  73. br.Msg = "获取成功"
  74. br.Data = resp
  75. }
  76. // @Title 新增ai纪要分类
  77. // @Description 新增ai纪要分类接口
  78. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  79. // @Success 200 Ret=200 保存成功
  80. // @router /summary/classify/add [post]
  81. func (this *AiController) AddAiSummaryClassify() {
  82. br := new(models.BaseResponse).Init()
  83. defer func() {
  84. this.Data["json"] = br
  85. this.ServeJSON()
  86. }()
  87. var req ai_summary.AddAiSummaryClassifyReq
  88. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  89. if err != nil {
  90. br.Msg = "参数解析异常!"
  91. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  92. return
  93. }
  94. if req.ClassifyName == "" {
  95. br.Msg = "请输入分类名称"
  96. br.IsSendEmail = false
  97. return
  98. }
  99. if req.ParentId < 0 {
  100. br.Msg = "参数错误"
  101. br.IsSendEmail = false
  102. return
  103. }
  104. count, err := ai_summary.GetAiSummaryClassifyCount(req.ClassifyName, req.ParentId)
  105. if err != nil {
  106. br.Msg = "判断名称是否已存在失败"
  107. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  108. return
  109. }
  110. if count > 0 {
  111. br.Msg = "分类名称已存在,请重新输入"
  112. br.IsSendEmail = false
  113. return
  114. }
  115. //获取该层级下最大的排序数
  116. maxSort, err := ai_summary.GetAiSummaryClassifyMaxSort(req.ParentId)
  117. classify := new(ai_summary.AiSummaryClassify)
  118. classify.ParentId = req.ParentId
  119. classify.ClassifyName = req.ClassifyName
  120. classify.HasData = 0
  121. classify.CreateTime = time.Now()
  122. classify.ModifyTime = time.Now()
  123. classify.SysUserId = this.SysUser.AdminId
  124. classify.SysUserRealName = this.SysUser.RealName
  125. classify.Level = req.Level + 1
  126. classify.Sort = maxSort + 1
  127. _, err = ai_summary.AddAiSummaryClassify(classify)
  128. if err != nil {
  129. br.Msg = "保存分类失败"
  130. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  131. return
  132. }
  133. br.Ret = 200
  134. br.Msg = "保存成功"
  135. br.Success = true
  136. }
  137. // @Title 修改ai纪要分类
  138. // @Description 修改ai纪要分类接口
  139. // @Param request body data_manage.EditChartClassifyReq true "type json string"
  140. // @Success 200 Ret=200 修改成功
  141. // @router /summary/classify/edit [post]
  142. func (this *AiController) EditAiSummaryClassify() {
  143. br := new(models.BaseResponse).Init()
  144. defer func() {
  145. this.Data["json"] = br
  146. this.ServeJSON()
  147. }()
  148. var req ai_summary.EditAiSummaryClassifyReq
  149. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  150. if err != nil {
  151. br.Msg = "参数解析异常!"
  152. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  153. return
  154. }
  155. if req.ClassifyName == "" {
  156. br.Msg = "请输入分类名称"
  157. br.IsSendEmail = false
  158. return
  159. }
  160. if req.AiSummaryClassifyId <= 0 {
  161. br.Msg = "参数错误"
  162. br.IsSendEmail = false
  163. return
  164. }
  165. err = ai_summary.EditSandboxClassify(req.AiSummaryClassifyId, req.ClassifyName)
  166. if err != nil {
  167. br.Msg = "保存失败"
  168. br.ErrMsg = "保存失败,Err:" + err.Error()
  169. return
  170. }
  171. br.Ret = 200
  172. br.Msg = "保存成功"
  173. br.Success = true
  174. br.IsAddLog = true
  175. }
  176. // @Title 删除纪要分类检测接口
  177. // @Description 删除纪要分类检测接口
  178. // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
  179. // @Success 200 Ret=200 检测成功
  180. // @router /summary/classify/delete/check [post]
  181. func (this *AiController) DeleteSandboxClassifyCheck() {
  182. br := new(models.BaseResponse).Init()
  183. defer func() {
  184. this.Data["json"] = br
  185. this.ServeJSON()
  186. }()
  187. var req ai_summary.AiSummaryClassifyDeleteCheckReq
  188. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  189. if err != nil {
  190. br.Msg = "参数解析异常!"
  191. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  192. return
  193. }
  194. if req.AiSummaryClassifyId < 0 {
  195. br.Msg = "参数错误"
  196. br.IsSendEmail = false
  197. return
  198. }
  199. var deleteStatus int
  200. var tipsMsg string
  201. //删除分类
  202. if req.AiSummaryClassifyId > 0 {
  203. //判断分类下,是否含有纪要
  204. count, err := ai_summary.GetAiSummaryInfoCountByClassifyId(req.AiSummaryClassifyId)
  205. if err != nil {
  206. br.Msg = "删除失败"
  207. br.ErrMsg = "分类下是否含有指标失败,Err:" + err.Error()
  208. return
  209. }
  210. if count > 0 {
  211. deleteStatus = 1
  212. tipsMsg = "该分类下关联沙盘不可删除"
  213. }
  214. }
  215. if deleteStatus != 1 {
  216. classifyCount, err := ai_summary.GetAiSummaryInfoCountByClassifyId(req.AiSummaryClassifyId)
  217. if err != nil && err.Error() != utils.ErrNoRow() {
  218. br.Msg = "删除失败"
  219. br.ErrMsg = "分类下是否含有沙盘失败,Err:" + err.Error()
  220. return
  221. }
  222. if classifyCount > 0 {
  223. deleteStatus = 2
  224. tipsMsg = "确认删除当前目录及包含的子目录吗"
  225. }
  226. }
  227. if deleteStatus == 0 {
  228. tipsMsg = "可删除,进行删除操作"
  229. }
  230. resp := new(sandbox.SandboxClassifyDeleteCheckResp)
  231. resp.DeleteStatus = deleteStatus
  232. resp.TipsMsg = tipsMsg
  233. br.Ret = 200
  234. br.Msg = "检测成功"
  235. br.Success = true
  236. br.Data = resp
  237. }
  238. // @Title 删除纪要分类/纪要
  239. // @Description 删除纪要分类/纪要接口
  240. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  241. // @Success 200 Ret=200 删除成功
  242. // @router /summary/classify/delete [post]
  243. func (this *AiController) DeleteAiSummaryClassify() {
  244. br := new(models.BaseResponse).Init()
  245. defer func() {
  246. this.Data["json"] = br
  247. this.ServeJSON()
  248. }()
  249. sysUser := this.SysUser
  250. if sysUser == nil {
  251. br.Msg = "请登录"
  252. br.ErrMsg = "请登录,SysUser Is Empty"
  253. br.Ret = 408
  254. return
  255. }
  256. var req ai_summary.DeleteAiSummaryClassifyReq
  257. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  258. if err != nil {
  259. br.Msg = "参数解析异常!"
  260. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  261. return
  262. }
  263. if req.AiSummaryClassifyId < 0 && req.AiSummaryId <= 0 {
  264. br.Msg = "参数错误"
  265. br.IsSendEmail = false
  266. return
  267. }
  268. //删除分类
  269. if req.AiSummaryClassifyId > 0 && req.AiSummaryId == 0 {
  270. //判断是否含有纪要
  271. count, err := ai_summary.GetAiSummaryInfoCountByClassifyId(req.AiSummaryClassifyId)
  272. if err != nil && err.Error() != utils.ErrNoRow() {
  273. br.Msg = "删除失败"
  274. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  275. return
  276. }
  277. if count > 0 {
  278. br.Msg = "该目录下存在纪要,不可删除"
  279. br.IsSendEmail = false
  280. return
  281. }
  282. err = ai_summary.DeleteAiSummaryClassify(req.AiSummaryClassifyId)
  283. if err != nil {
  284. br.Msg = "删除失败"
  285. br.ErrMsg = "删除失败,Err:" + err.Error()
  286. return
  287. }
  288. }
  289. //删除纪要
  290. if req.AiSummaryId > 0 {
  291. summaryInfo, err := ai_summary.GetAiSummaryById(req.AiSummaryId)
  292. if err != nil {
  293. if err.Error() == utils.ErrNoRow() {
  294. br.Msg = "沙盘已删除,请刷新页面"
  295. br.ErrMsg = "指标不存在,Err:" + err.Error()
  296. return
  297. } else {
  298. br.Msg = "删除失败"
  299. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  300. return
  301. }
  302. }
  303. if summaryInfo == nil {
  304. br.Msg = "纪要已删除,请刷新页面"
  305. return
  306. }
  307. if summaryInfo.SysUserId != sysUser.AdminId {
  308. br.Msg = "仅纪要创建人可以删除"
  309. return
  310. }
  311. err = ai_summary.DelAiSummaryById(req.AiSummaryId)
  312. if err != nil {
  313. br.Msg = err.Error()
  314. return
  315. }
  316. }
  317. br.Ret = 200
  318. br.Msg = "删除成功"
  319. br.Success = true
  320. br.IsAddLog = true
  321. }
  322. // AiSummaryClassifyMove
  323. // @Title 纪要分类移动接口
  324. // @Description 纪要分类移动接口
  325. // @Success 200 {object} data_manage.MoveChartClassifyReq
  326. // @router /summary/classify/move [post]
  327. func (this *AiController) AiSummaryClassifyMove() {
  328. br := new(models.BaseResponse).Init()
  329. defer func() {
  330. this.Data["json"] = br
  331. this.ServeJSON()
  332. }()
  333. sysUser := this.SysUser
  334. if sysUser == nil {
  335. br.Msg = "请登录"
  336. br.ErrMsg = "请登录,SysUser Is Empty"
  337. br.Ret = 408
  338. return
  339. }
  340. var req ai_summary.MoveAiSummaryClassifyReq
  341. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  342. if err != nil {
  343. br.Msg = "参数解析异常!"
  344. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  345. return
  346. }
  347. if req.AiSummaryClassifyId <= 0 {
  348. br.Msg = "参数错误"
  349. br.ErrMsg = "分类id小于等于0"
  350. return
  351. }
  352. //判断分类是否存在
  353. aiSummaryClassifyInfo, err := ai_summary.GetAiSummaryClassifyById(req.AiSummaryClassifyId)
  354. if err != nil {
  355. br.Msg = "移动失败"
  356. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  357. return
  358. }
  359. updateCol := make([]string, 0)
  360. // 判断移动的是分类还是沙盘
  361. if req.AiSummaryId > 0 {
  362. //判断分类是否存在
  363. count, _ := ai_summary.GetAiSummaryClassifyCountById(req.AiSummaryClassifyId)
  364. if count <= 0 {
  365. br.Msg = "分类已被删除,不可移动,请刷新页面"
  366. return
  367. }
  368. aiSummaryInfo, err := ai_summary.GetAiSummaryById(req.AiSummaryId)
  369. if err != nil {
  370. br.Msg = "移动失败"
  371. br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  372. return
  373. }
  374. //如果改变了分类,那么移动该图表数据
  375. // 11/22 ETA逻辑优化去除名称重复限制
  376. if aiSummaryInfo.ClassifyId != req.ParentClassifyId {
  377. ////查询需要修改的分类下是否存在同一个图表名称
  378. //tmpSandboxInfo, tmpErr := sandbox.GetSandboxByClassifyIdAndName(req.ParentClassifyId, aiSummaryInfo.Name)
  379. //if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
  380. // br.Msg = "移动失败"
  381. // br.ErrMsg = "移动失败,Err:" + tmpErr.Error()
  382. // return
  383. //}
  384. //if tmpSandboxInfo != nil {
  385. // br.Msg = "移动失败,同一个分类下沙盘名称不允许重复"
  386. // br.ErrMsg = "移动失败,同一个分类下沙盘名称不允许重复"
  387. // return
  388. //}
  389. err = ai_summary.MoveAiSummary(req.AiSummaryId, req.ParentClassifyId)
  390. if err != nil {
  391. br.Msg = "移动失败"
  392. br.ErrMsg = "移动失败,Err:" + err.Error()
  393. return
  394. }
  395. }
  396. //移动排序
  397. updateCol := make([]string, 0)
  398. //如果有传入 上一个兄弟节点分类id
  399. if req.PrevId > 0 {
  400. if req.PrevType == 1 {
  401. //上一个兄弟节点
  402. prevClassify, err := ai_summary.GetAiSummaryClassifyById(req.PrevId)
  403. if err != nil {
  404. br.Msg = "移动失败"
  405. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  406. return
  407. }
  408. //如果是移动在两个兄弟节点之间
  409. if req.NextId > 0 {
  410. if req.NextType == 1 {
  411. //上一个节点是分类 下一个节点是分类的情况
  412. //下一个兄弟节点
  413. nextClassify, err := ai_summary.GetAiSummaryClassifyById(req.NextId)
  414. if err != nil {
  415. br.Msg = "移动失败"
  416. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  417. return
  418. }
  419. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  420. if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == aiSummaryClassifyInfo.Sort {
  421. //变更兄弟节点的排序
  422. updateSortStr := `sort + 2`
  423. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, prevClassify.AiSummaryClassifyId, prevClassify.Sort, updateSortStr)
  424. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  425. } else {
  426. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  427. if nextClassify.Sort-prevClassify.Sort == 1 {
  428. //变更兄弟节点的排序
  429. updateSortStr := `sort + 1`
  430. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  431. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  432. }
  433. }
  434. } else {
  435. //上一个节点是分类 下一个节点是沙盘的情况
  436. //下一个兄弟节点
  437. nextChartInfo, err := ai_summary.GetAiSummaryById(req.NextId)
  438. if err != nil {
  439. br.Msg = "移动失败"
  440. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  441. return
  442. }
  443. //如果上一个兄弟(分类)与下一个兄弟(沙盘)的排序权重是一致的,那么需要将下一个兄弟(沙盘)(以及下个兄弟(沙盘)的同样排序权重)的排序权重+2,自己变成上一个兄弟(分类)的排序权重+1
  444. if prevClassify.Sort == nextChartInfo.Sort || prevClassify.Sort == aiSummaryInfo.Sort {
  445. //变更兄弟节点的排序
  446. updateSortStr := `sort + 2`
  447. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, prevClassify.AiSummaryClassifyId, prevClassify.Sort, updateSortStr)
  448. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  449. } else {
  450. //如果下一个兄弟(沙盘)的排序权重正好是上个兄弟节点(分类)的下一层,那么需要再加一层了
  451. if nextChartInfo.Sort-prevClassify.Sort == 1 {
  452. //变更兄弟节点的排序
  453. updateSortStr := `sort + 1`
  454. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.AiSummaryClassifyId, updateSortStr)
  455. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  456. }
  457. }
  458. }
  459. }
  460. aiSummaryInfo.Sort = prevClassify.Sort + 1
  461. aiSummaryInfo.ModifyTime = time.Now()
  462. updateCol = append(updateCol, "Sort", "ModifyTime")
  463. } else {
  464. prevAiSumary, err := ai_summary.GetAiSummaryById(req.PrevId)
  465. if err != nil {
  466. br.Msg = "移动失败"
  467. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  468. return
  469. }
  470. //如果是移动在两个兄弟节点之间
  471. if req.NextId > 0 {
  472. if req.NextType == 1 {
  473. //上一个节点是沙盘 下一个节点是分类的情况
  474. //下一个兄弟节点
  475. nextClassify, err := ai_summary.GetAiSummaryClassifyById(req.NextId)
  476. if err != nil {
  477. br.Msg = "移动失败"
  478. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  479. return
  480. }
  481. //如果上一个兄弟(沙盘)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(沙盘)的排序权重+1
  482. if prevAiSumary.Sort == nextClassify.Sort || prevAiSumary.Sort == aiSummaryClassifyInfo.Sort {
  483. //变更兄弟节点的排序
  484. updateSortStr := `sort + 2`
  485. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  486. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  487. } else {
  488. //如果下一个兄弟(分类)的排序权重正好是上个兄弟(沙盘)节点的下一层,那么需要再加一层了
  489. if nextClassify.Sort-prevAiSumary.Sort == 1 {
  490. //变更兄弟节点的排序
  491. updateSortStr := `sort + 1`
  492. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  493. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  494. }
  495. }
  496. } else {
  497. //上一个节点是沙盘 下一个节点是沙盘的情况
  498. //下一个兄弟节点
  499. nextChartInfo, err := ai_summary.GetAiSummaryById(req.NextId)
  500. if err != nil {
  501. br.Msg = "移动失败"
  502. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  503. return
  504. }
  505. //如果上一个兄弟(沙盘)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(沙盘)的排序权重+1
  506. if prevAiSumary.Sort == nextChartInfo.Sort || prevAiSumary.Sort == aiSummaryInfo.Sort {
  507. //变更兄弟节点的排序
  508. updateSortStr := `sort + 2`
  509. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  510. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  511. } else {
  512. //如果下一个兄弟(分类)的排序权重正好是上个兄弟(沙盘)节点的下一层,那么需要再加一层了
  513. if nextChartInfo.Sort-prevAiSumary.Sort == 1 {
  514. //变更兄弟节点的排序
  515. updateSortStr := `sort + 1`
  516. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  517. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  518. }
  519. }
  520. }
  521. }
  522. aiSummaryInfo.Sort = prevAiSumary.Sort + 1
  523. aiSummaryInfo.ModifyTime = time.Now()
  524. updateCol = append(updateCol, "Sort", "ModifyTime")
  525. }
  526. } else {
  527. // prevId为0,也就是沙盘移到最前端
  528. firstClassify, err := ai_summary.GetFirstAiSummaryByClassifyId(req.AiSummaryClassifyId)
  529. if err != nil && err.Error() != utils.ErrNoRow() {
  530. br.Msg = "移动失败"
  531. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  532. return
  533. }
  534. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  535. if firstClassify != nil && firstClassify.Sort == 0 {
  536. updateSortStr := ` sort + 1 `
  537. _ = ai_summary.UpdateAiSummarySortByClassifyId(firstClassify.ClassifyId, 0, firstClassify.AiSummaryId-1, updateSortStr)
  538. }
  539. aiSummaryInfo.Sort = 0 //那就是排在第一位
  540. aiSummaryInfo.ModifyTime = time.Now()
  541. updateCol = append(updateCol, "Sort", "ModifyTime")
  542. }
  543. //更新
  544. if len(updateCol) > 0 {
  545. err = aiSummaryInfo.Update(updateCol)
  546. if err != nil {
  547. br.Msg = "移动失败"
  548. br.ErrMsg = "修改失败,Err:" + err.Error()
  549. return
  550. }
  551. }
  552. } else {
  553. //移动的是分类
  554. //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  555. if aiSummaryClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  556. parentChartClassifyInfo, err := ai_summary.GetAiSummaryClassifyById(req.ParentClassifyId)
  557. if err != nil {
  558. br.Msg = "移动失败"
  559. br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  560. return
  561. }
  562. aiSummaryClassifyInfo.ParentId = parentChartClassifyInfo.AiSummaryClassifyId
  563. aiSummaryClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  564. aiSummaryClassifyInfo.ModifyTime = time.Now()
  565. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  566. } else if aiSummaryClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId == 0 {
  567. //改为一级分类
  568. aiSummaryClassifyInfo.ParentId = req.ParentClassifyId
  569. aiSummaryClassifyInfo.Level = 1
  570. aiSummaryClassifyInfo.ModifyTime = time.Now()
  571. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  572. }
  573. //如果有传入 上一个兄弟节点分类id
  574. if req.PrevId > 0 {
  575. if req.PrevType == 1 {
  576. //上一个节点是分类
  577. //上一个兄弟节点
  578. prevClassify, err := ai_summary.GetAiSummaryClassifyById(req.PrevId)
  579. if err != nil {
  580. br.Msg = "移动失败"
  581. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  582. return
  583. }
  584. //如果是移动在两个兄弟节点之间
  585. if req.NextId > 0 {
  586. if req.NextType == 1 {
  587. //上一个节点是分类 下一个节点是分类的情况
  588. //下一个兄弟节点
  589. nextClassify, err := ai_summary.GetAiSummaryClassifyById(req.NextId)
  590. if err != nil {
  591. br.Msg = "移动失败"
  592. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  593. return
  594. }
  595. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  596. if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == aiSummaryClassifyInfo.Sort {
  597. //变更兄弟节点的排序
  598. updateSortStr := `sort + 2`
  599. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, prevClassify.AiSummaryClassifyId, prevClassify.Sort, updateSortStr)
  600. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  601. } else {
  602. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  603. if nextClassify.Sort-prevClassify.Sort == 1 {
  604. //变更兄弟节点的排序
  605. updateSortStr := `sort + 1`
  606. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  607. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  608. }
  609. }
  610. } else {
  611. //上一个节点是分类 下一个节点是沙盘的情况
  612. //下一个兄弟节点
  613. nextChartInfo, err := ai_summary.GetAiSummaryById(req.NextId)
  614. if err != nil {
  615. br.Msg = "移动失败"
  616. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  617. return
  618. }
  619. //如果上一个兄弟(分类)与下一个兄弟(沙盘)的排序权重是一致的,那么需要将下一个兄弟(沙盘)(以及下个兄弟(沙盘)的同样排序权重)的排序权重+2,自己变成上一个兄弟(分类)的排序权重+1
  620. if prevClassify.Sort == nextChartInfo.Sort || prevClassify.Sort == aiSummaryClassifyInfo.Sort {
  621. //变更兄弟节点的排序
  622. updateSortStr := `sort + 2`
  623. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, prevClassify.AiSummaryClassifyId, prevClassify.Sort, updateSortStr)
  624. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  625. } else {
  626. //如果下一个兄弟(沙盘)的排序权重正好是上个兄弟节点(分类)的下一层,那么需要再加一层了
  627. if nextChartInfo.Sort-prevClassify.Sort == 1 {
  628. //变更兄弟节点的排序
  629. updateSortStr := `sort + 1`
  630. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.AiSummaryClassifyId, updateSortStr)
  631. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevClassify.AiSummaryClassifyId, prevClassify.Sort, 0, updateSortStr)
  632. }
  633. }
  634. }
  635. }
  636. aiSummaryClassifyInfo.Sort = prevClassify.Sort + 1
  637. aiSummaryClassifyInfo.ModifyTime = time.Now()
  638. updateCol = append(updateCol, "Sort", "ModifyTime")
  639. } else {
  640. //上一个节点是沙盘
  641. prevAiSumary, err := ai_summary.GetAiSummaryById(req.PrevId)
  642. if err != nil {
  643. br.Msg = "移动失败"
  644. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  645. return
  646. }
  647. //如果是移动在两个兄弟节点之间
  648. if req.NextId > 0 {
  649. if req.NextType == 1 {
  650. //上一个节点是沙盘 下一个节点是分类的情况
  651. //下一个兄弟节点
  652. nextClassify, err := ai_summary.GetAiSummaryClassifyById(req.NextId)
  653. if err != nil {
  654. br.Msg = "移动失败"
  655. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  656. return
  657. }
  658. //如果上一个兄弟(沙盘)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(沙盘)的排序权重+1
  659. if prevAiSumary.Sort == nextClassify.Sort || prevAiSumary.Sort == aiSummaryClassifyInfo.Sort {
  660. //变更兄弟节点的排序
  661. updateSortStr := `sort + 2`
  662. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  663. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  664. } else {
  665. //如果下一个兄弟(分类)的排序权重正好是上个兄弟(沙盘)节点的下一层,那么需要再加一层了
  666. if nextClassify.Sort-prevAiSumary.Sort == 1 {
  667. //变更兄弟节点的排序
  668. updateSortStr := `sort + 1`
  669. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  670. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  671. }
  672. }
  673. } else {
  674. //上一个节点是沙盘 下一个节点是沙盘的情况
  675. //下一个兄弟节点
  676. nextChartInfo, err := ai_summary.GetAiSummaryById(req.NextId)
  677. if err != nil {
  678. br.Msg = "移动失败"
  679. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  680. return
  681. }
  682. //如果上一个兄弟(沙盘)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(沙盘)的排序权重+1
  683. if prevAiSumary.Sort == nextChartInfo.Sort || prevAiSumary.Sort == aiSummaryClassifyInfo.Sort {
  684. //变更兄弟节点的排序
  685. updateSortStr := `sort + 2`
  686. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  687. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  688. } else {
  689. //如果下一个兄弟(分类)的排序权重正好是上个兄弟(沙盘)节点的下一层,那么需要再加一层了
  690. if nextChartInfo.Sort-prevAiSumary.Sort == 1 {
  691. //变更兄弟节点的排序
  692. updateSortStr := `sort + 1`
  693. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(prevAiSumary.ClassifyId, 0, prevAiSumary.Sort, updateSortStr)
  694. _ = ai_summary.UpdateAiSummarySortByClassifyId(prevAiSumary.ClassifyId, prevAiSumary.Sort, prevAiSumary.AiSummaryId, updateSortStr)
  695. }
  696. }
  697. }
  698. }
  699. aiSummaryClassifyInfo.Sort = prevAiSumary.Sort + 1
  700. aiSummaryClassifyInfo.ModifyTime = time.Now()
  701. updateCol = append(updateCol, "Sort", "ModifyTime")
  702. }
  703. } else {
  704. firstClassify, err := ai_summary.GetFirstAiSummaryClassifyByParentId(aiSummaryClassifyInfo.ParentId)
  705. if err != nil && err.Error() != utils.ErrNoRow() {
  706. br.Msg = "移动失败"
  707. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  708. return
  709. }
  710. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  711. if firstClassify != nil && firstClassify.Sort == 0 {
  712. updateSortStr := ` sort + 1 `
  713. _ = ai_summary.UpdateAiSummaryClassifySortByParentId(firstClassify.ParentId, firstClassify.AiSummaryClassifyId-1, 0, updateSortStr)
  714. }
  715. aiSummaryClassifyInfo.Sort = 0 //那就是排在第一位
  716. aiSummaryClassifyInfo.ModifyTime = time.Now()
  717. updateCol = append(updateCol, "Sort", "ModifyTime")
  718. }
  719. //更新
  720. if len(updateCol) > 0 {
  721. err = aiSummaryClassifyInfo.Update(updateCol)
  722. if err != nil {
  723. br.Msg = "移动失败"
  724. br.ErrMsg = "修改失败,Err:" + err.Error()
  725. return
  726. }
  727. }
  728. }
  729. br.Ret = 200
  730. br.Success = true
  731. br.Msg = "移动成功"
  732. }
  733. // @Title Ai纪要列表接口
  734. // @Description Ai纪要列表接口
  735. // @Param PageSize query int true "每页数据条数"
  736. // @Param CurrentIndex query int true "当前页页码,从1开始"
  737. // @Param AiSummaryClassifyId query int true "分类id"
  738. // @Param KeyWord query string true "搜索关键词"
  739. // @Param IsShowMe query bool true "是否只看我的,true、false"
  740. // @Success 200 {object} data_manage.ChartListResp
  741. // @router /summary/list [get]
  742. func (this *AiController) AiSummaryList() {
  743. br := new(models.BaseResponse).Init()
  744. defer func() {
  745. this.Data["json"] = br
  746. this.ServeJSON()
  747. }()
  748. sysUser := this.SysUser
  749. if sysUser == nil {
  750. br.Msg = "请登录"
  751. br.ErrMsg = "请登录,SysUser Is Empty"
  752. br.Ret = 408
  753. return
  754. }
  755. aiSummaryClassifyId, _ := this.GetInt("AiSummaryClassifyId")
  756. pageSize, _ := this.GetInt("PageSize")
  757. currentIndex, _ := this.GetInt("CurrentIndex")
  758. keyWord := this.GetString("KeyWord")
  759. var total int
  760. page := paging.GetPaging(currentIndex, pageSize, total)
  761. var startSize int
  762. if pageSize <= 0 {
  763. pageSize = utils.PageSize20
  764. }
  765. if currentIndex <= 0 {
  766. currentIndex = 1
  767. }
  768. startSize = paging.StartIndex(currentIndex, pageSize)
  769. var condition string
  770. var pars []interface{}
  771. if aiSummaryClassifyId > 0 {
  772. sandboxClassifyIds, err := ai_summary.GetAiSummaryClassify(aiSummaryClassifyId)
  773. if err != nil && err.Error() != utils.ErrNoRow() {
  774. br.Msg = "获取图表信息失败"
  775. br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
  776. return
  777. }
  778. condition += " AND ai_summary_classify_id IN(" + sandboxClassifyIds + ") "
  779. //pars = append(pars, chartClassifyId)
  780. }
  781. if keyWord != "" {
  782. condition += ` AND ( title LIKE '%` + keyWord + `%' )`
  783. }
  784. //只看我的
  785. isShowMe, _ := this.GetBool("IsShowMe")
  786. if isShowMe {
  787. condition += ` AND sys_user_id = ? `
  788. pars = append(pars, sysUser.AdminId)
  789. }
  790. //获取图表信息
  791. list, err := ai_summary.GetAiSummaryListByCondition(condition, pars, startSize, pageSize)
  792. if err != nil && err.Error() != utils.ErrNoRow() {
  793. br.Success = true
  794. br.Msg = "获取纪要信息失败"
  795. br.ErrMsg = "获取纪要信息失败,Err:" + err.Error()
  796. return
  797. }
  798. for i, v := range list {
  799. ids, err := ai_summary.GetAiSummaryAllParentByClassifyId(v.ClassifyId)
  800. if err != nil {
  801. br.Msg = "获取父级信息错误!"
  802. br.ErrMsg = "获取父级信息错误,Err:" + err.Error()
  803. return
  804. }
  805. list[i].ParentIds = ids
  806. }
  807. resp := new(ai_summary.AiSummaryListResp)
  808. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  809. items := make([]*ai_summary.AiSummaryItems, 0)
  810. resp.Paging = page
  811. resp.List = items
  812. br.Ret = 200
  813. br.Success = true
  814. br.Msg = "获取成功"
  815. return
  816. }
  817. dataCount, err := ai_summary.GetAiSummaryListCountByCondition(condition, pars)
  818. if err != nil && err.Error() != utils.ErrNoRow() {
  819. br.Msg = "获取指标信息失败"
  820. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  821. return
  822. }
  823. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  824. resp.Paging = page
  825. resp.List = list
  826. br.Ret = 200
  827. br.Success = true
  828. br.Msg = "获取成功"
  829. br.Data = resp
  830. }
  831. // @Title Ai纪要详情接口
  832. // @Description Ai纪要详情接口
  833. // @Param AiSummaryId query int true "详情id"
  834. // @Success 200 {object} data_manage.ChartListResp
  835. // @router /summary/detail [get]
  836. func (this *AiController) AiSummaryDetail() {
  837. br := new(models.BaseResponse).Init()
  838. defer func() {
  839. this.Data["json"] = br
  840. this.ServeJSON()
  841. }()
  842. sysUser := this.SysUser
  843. if sysUser == nil {
  844. br.Msg = "请登录"
  845. br.ErrMsg = "请登录,SysUser Is Empty"
  846. br.Ret = 408
  847. return
  848. }
  849. aiSummaryId, _ := this.GetInt("AiSummaryId")
  850. detail, err := ai_summary.GetAiSummaryItemById(aiSummaryId)
  851. if err != nil && err.Error() != utils.ErrNoRow() {
  852. br.Success = true
  853. br.Msg = "获取沙盘信息失败"
  854. br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  855. return
  856. }
  857. resp := ai_summary.AiSummaryDetailResp{
  858. AiSummaryItems: detail,
  859. }
  860. if detail.SaDocId >0 {
  861. item := new(saModel.SaDoc)
  862. e := item.GetItemById(detail.SaDocId)
  863. if e != nil {
  864. if e.Error() == utils.ErrNoRow() {
  865. br.Msg = "文档已被删除, 请刷新页面"
  866. return
  867. }
  868. br.Msg = "获取失败"
  869. br.ErrMsg = "获取文档信息失败, Err: " + e.Error()
  870. return
  871. }
  872. resp.SaDocTitle = item.Title
  873. }
  874. br.Data = resp
  875. br.Ret = 200
  876. br.Success = true
  877. br.Msg = "获取成功"
  878. }
  879. // @Title 新增ai纪要
  880. // @Description 新增ai纪要接口
  881. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  882. // @Success 200 Ret=200 保存成功
  883. // @router /summary/add [post]
  884. func (this *AiController) AddAiSummary() {
  885. br := new(models.BaseResponse).Init()
  886. defer func() {
  887. this.Data["json"] = br
  888. this.ServeJSON()
  889. }()
  890. var req ai_summary.AddAiSummaryReq
  891. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  892. if err != nil {
  893. br.Msg = "参数解析异常!"
  894. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  895. return
  896. }
  897. if req.Title == "" {
  898. br.Msg = "请输入名称"
  899. br.IsSendEmail = false
  900. return
  901. }
  902. if req.SummaryContent == "" {
  903. br.Msg = "纪要内容为空"
  904. br.IsSendEmail = false
  905. return
  906. }
  907. if req.ClassifyId < 0 {
  908. br.Msg = "分类id错误"
  909. br.IsSendEmail = false
  910. return
  911. }
  912. //获取该层级下最大的排序数
  913. maxSort, err := ai_summary.GetAiSummaryMaxSort(req.ClassifyId)
  914. summary := &ai_summary.AiSummary{
  915. SaDocId: req.SaDocId,
  916. OriginContent: req.OriginContent,
  917. SummaryContent: req.SummaryContent,
  918. ClassifyId: req.ClassifyId,
  919. SysUserId: this.SysUser.AdminId,
  920. SysUserRealName: this.SysUser.RealName,
  921. Title: req.Title,
  922. CreateTime: time.Now(),
  923. ModifyTime: time.Now(),
  924. OpenaiFileName: req.OpenaiFileName,
  925. OpenaiFilePath: req.OpenaiFilePath,
  926. OriginTitle: req.OriginTitle,
  927. Sort: maxSort + 1,
  928. }
  929. id, err := ai_summary.AddAiSummary(summary)
  930. if err != nil {
  931. br.Msg = "保存分类失败"
  932. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  933. return
  934. }
  935. classify ,err := ai_summary.GetAiSummaryClassifyById(req.ClassifyId)
  936. if err != nil {
  937. br.Msg = "获取分类信息失败"
  938. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  939. return
  940. }
  941. resp := ai_summary.AiSummaryAddResp{
  942. AiSummaryId: int(id),
  943. UniqueCode: strconv.Itoa(req.ClassifyId) + "_" + strconv.Itoa(int(id)),
  944. ParentId: classify.ParentId,
  945. }
  946. br.Ret = 200
  947. br.Msg = "保存成功"
  948. br.Success = true
  949. br.Data = resp
  950. }
  951. // @Title 生成ai纪要
  952. // @Description 生成ai纪要接口
  953. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  954. // @Success 200 Ret=200 保存成功
  955. // @router /summary/generate [post]
  956. func (this *AiController) GenerateAiSummary() {
  957. br := new(models.BaseResponse).Init()
  958. defer func() {
  959. this.Data["json"] = br
  960. this.ServeJSON()
  961. }()
  962. var req ai_summary.GenerateAiSummaryReq
  963. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  964. if err != nil {
  965. br.Msg = "参数解析异常!"
  966. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  967. return
  968. }
  969. if req.Prompt == "" {
  970. br.Msg = "请输入提示词"
  971. br.IsSendEmail = false
  972. return
  973. }
  974. if req.OriginContent == "" && len(req.OpenaiFileId) == 0 && req.SaDocId <= 0 {
  975. br.Msg = "参数错误"
  976. br.IsSendEmail = false
  977. return
  978. }
  979. if req.SaDocId > 0 {
  980. // 获取段落
  981. sectionOB := new(saModel.SaDocSection)
  982. sectionCond := fmt.Sprintf(` AND %s = ?`, saModel.SaDocSectionColumns.DocId)
  983. sectionPars := make([]interface{}, 0)
  984. sectionPars = append(sectionPars, req.SaDocId)
  985. sectionList, e := sectionOB.GetItemsByCondition(sectionCond, sectionPars, []string{}, "")
  986. if e != nil {
  987. br.Msg = "获取失败"
  988. br.ErrMsg = "获取段落信息失败, Err: " + e.Error()
  989. return
  990. }
  991. secIds := make([]int, 0)
  992. for _, s := range sectionList {
  993. secIds = append(secIds, s.SaDocSectionId)
  994. }
  995. for _, v := range sectionList {
  996. req.OriginContent += v.Content + "<br>"
  997. }
  998. }
  999. if utils.Re == nil {
  1000. key := "CACHE_CHAT_" + strconv.Itoa(this.SysUser.AdminId)
  1001. cacheVal, err := utils.Rc.RedisInt(key)
  1002. fmt.Println("RedisString:", cacheVal, "err:", err)
  1003. if err != nil && (err.Error() != "redigo: nil returned" && err.Error() != "redis: nil") {
  1004. br.Msg = "获取数据失败!"
  1005. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1006. return
  1007. }
  1008. putVal := 0
  1009. if cacheVal <= 0 {
  1010. putVal = utils.AiChatLimit
  1011. } else {
  1012. putVal = cacheVal - 1
  1013. }
  1014. if putVal <= 0 {
  1015. br.Msg = "您今日" + strconv.Itoa(utils.AiChatLimit) + "次问答已达上限,请明天再来!"
  1016. br.ErrMsg = "您今日" + strconv.Itoa(utils.AiChatLimit) + "次问答已达上限,请明天再来!"
  1017. return
  1018. }
  1019. lastSecond := utils.GetTodayLastSecond()
  1020. utils.Rc.Put(key, putVal, lastSecond)
  1021. }
  1022. resp := new(aimod.ChatResp)
  1023. if req.OriginContent != "" {
  1024. // 直接提问的方式
  1025. //根据提问,获取信息
  1026. ask := req.Prompt + req.OriginContent
  1027. var answer string
  1028. //answerArr := []string{
  1029. // "周度数据显示,成品油现货市场价格跟随原油下跌,但近期相对抗跌,裂解价差走扩。批零价差方面汽油收窄,柴油走扩",
  1030. // "出口利润在原油下跌海外成品油矛盾更大的情况下汽柴油出口窗口完全关闭",
  1031. // "汽油需求在经历五一假期的一段高峰后将回归平稳,总体没有明显矛盾,后期我们担心更多的还是柴油。"}
  1032. //获取主题下的所有信息
  1033. //AiChatTopicId
  1034. //获取主题下的所有信息
  1035. //AiChatTopicId
  1036. historyList, err := aimod.GetAiChatList(req.AiChatTopicId)
  1037. if err != nil && err.Error() != utils.ErrNoRow() {
  1038. br.Msg = "获取主题历史数据失败!"
  1039. br.ErrMsg = "获取主题历史数据失败,Err:" + err.Error()
  1040. return
  1041. }
  1042. historyChatList := make([]aimod.HistoryChat, 0)
  1043. for _, v := range historyList {
  1044. historyChat := new(aimod.HistoryChat)
  1045. historyChat.Ask = v.Ask
  1046. historyChat.Answer = v.Answer
  1047. historyChatList = append(historyChatList, *historyChat)
  1048. }
  1049. answer, err = aiser.ChatAutoMsg(ask, historyChatList, req.Model)
  1050. if err != nil {
  1051. br.Msg = "获取数据失败!"
  1052. br.ErrMsg = "获取数据失败,ChatAutoMsg,Err:" + err.Error()
  1053. return
  1054. }
  1055. resp.Ask = ask
  1056. resp.Answer = answer
  1057. resp.Model = req.Model
  1058. if req.AiChatTopicId <= 0 { //新增
  1059. topic := new(aimod.AiChatTopic)
  1060. topic.TopicName = ask
  1061. topic.SysUserId = this.SysUser.AdminId
  1062. topic.SysUserRealName = this.SysUser.RealName
  1063. topic.CreateTime = time.Now()
  1064. topic.ModifyTime = time.Now()
  1065. topicId, err := aimod.AddAiChatTopic(topic)
  1066. if err != nil {
  1067. br.Msg = "获取数据失败!"
  1068. br.ErrMsg = "生成话题失败,Err:" + err.Error()
  1069. return
  1070. }
  1071. resp.AiChatTopicId = int(topicId)
  1072. chatItem := new(aimod.AiChat)
  1073. chatItem.AiChatTopicId = resp.AiChatTopicId
  1074. chatItem.Ask = ask
  1075. chatItem.AskUuid = utils.MD5(ask)
  1076. chatItem.Answer = answer
  1077. chatItem.Model = EnabledModelsForMap[req.Model]
  1078. chatItem.SysUserId = this.SysUser.AdminId
  1079. chatItem.SysUserRealName = this.SysUser.RealName
  1080. chatItem.CreateTime = time.Now()
  1081. chatItem.ModifyTime = time.Now()
  1082. _, err = aimod.AddAiChat(chatItem)
  1083. if err != nil {
  1084. br.Msg = "获取数据失败!"
  1085. br.ErrMsg = "生成话题记录失败,Err:" + err.Error()
  1086. return
  1087. }
  1088. } else {
  1089. resp.AiChatTopicId = req.AiChatTopicId
  1090. chatItem := new(aimod.AiChat)
  1091. chatItem.AiChatTopicId = resp.AiChatTopicId
  1092. chatItem.Ask = ask
  1093. chatItem.AskUuid = utils.MD5(ask)
  1094. chatItem.Answer = answer
  1095. chatItem.Model = EnabledModelsForMap[req.Model]
  1096. chatItem.SysUserId = this.SysUser.AdminId
  1097. chatItem.SysUserRealName = this.SysUser.RealName
  1098. chatItem.CreateTime = time.Now()
  1099. chatItem.ModifyTime = time.Now()
  1100. _, err = aimod.AddAiChat(chatItem)
  1101. if err != nil {
  1102. br.Msg = "获取数据失败!"
  1103. br.ErrMsg = "生成话题记录失败,Err:" + err.Error()
  1104. return
  1105. }
  1106. }
  1107. } else if len(req.OpenaiFileId) > 0 {
  1108. // 走文件上传的方式
  1109. //根据提问,获取信息
  1110. ask := req.Prompt
  1111. askUuid := utils.MD5(ask)
  1112. var assistantId, threadId string
  1113. if req.AiChatTopicId > 0 {
  1114. aiChatTopicObj := new(aimod.AiChatTopic)
  1115. aiChatTopicObj.AiChatTopicId = req.AiChatTopicId
  1116. topic, err := aiChatTopicObj.GetAiChatTopicById()
  1117. if err != nil {
  1118. if err.Error() == utils.ErrNoRow() {
  1119. br.Msg = "获取数据失败!"
  1120. br.ErrMsg = "获取数据失败,主题不存在,Err:" + err.Error()
  1121. return
  1122. }
  1123. br.Msg = "获取数据失败!"
  1124. br.ErrMsg = "获取数据失败,GetAiChatTopicById,Err:" + err.Error()
  1125. return
  1126. }
  1127. assistantId = topic.AssistantId
  1128. threadId = topic.ThreadId
  1129. }
  1130. var answer string
  1131. //获取主题下的所有信息
  1132. //AiChatTopicId
  1133. //historyList, err := aimod.GetAiChatList(req.AiChatTopicId)
  1134. //if err != nil && err.Error() != utils.ErrNoRow() {
  1135. // br.Msg = "获取主题历史数据失败!"
  1136. // br.ErrMsg = "获取主题历史数据失败,Err:" + err.Error()
  1137. // return
  1138. //}
  1139. frList := make([]aimod.HistoryChat, 0)
  1140. tmpFileIdList := make([]string, 0)
  1141. tmpFileIdList = append(tmpFileIdList, req.OpenaiFileId...)
  1142. //// 历史消息
  1143. //for _, v := range historyList {
  1144. // if v.OpenaiFileId != "" {
  1145. // tmpFileIdList = append(tmpFileIdList, v.OpenaiFileId)
  1146. // } else {
  1147. // historyFr := new(aimod.HistoryChat)
  1148. // historyFr.Ask = v.Ask
  1149. // historyFr.Answer = v.Answer
  1150. // historyFr.OpenaiFileId = tmpFileIdList
  1151. // frList = append(frList, *historyFr)
  1152. // tmpFileIdList = []string{}
  1153. // }
  1154. //}
  1155. // 当前的消息
  1156. {
  1157. frItem := new(aimod.HistoryChat)
  1158. frItem.Ask = ask
  1159. frItem.Answer = ""
  1160. frItem.OpenaiFileId = tmpFileIdList
  1161. frList = append(frList, *frItem)
  1162. }
  1163. fileRetrieveResp, err := aiser.FileRetrieve(assistantId, threadId, req.Model, frList, req.OpenaiFileId)
  1164. if err != nil {
  1165. br.Msg = "获取数据失败!"
  1166. br.ErrMsg = "获取数据失败,FileRetrieve,Err:" + err.Error()
  1167. return
  1168. }
  1169. if fileRetrieveResp != nil {
  1170. if fileRetrieveResp.Ret == 200 {
  1171. assistantId = fileRetrieveResp.Data.AssistantId
  1172. threadId = fileRetrieveResp.Data.ThreadId
  1173. answer = fileRetrieveResp.Data.Answer
  1174. } else {
  1175. br.Msg = "获取数据失败!"
  1176. br.ErrMsg = fileRetrieveResp.Msg
  1177. return
  1178. }
  1179. }
  1180. if req.AiChatTopicId <= 0 { //新增
  1181. topic := new(aimod.AiChatTopic)
  1182. topic.TopicName = ask
  1183. topic.SysUserId = this.SysUser.AdminId
  1184. topic.SysUserRealName = this.SysUser.RealName
  1185. topic.CreateTime = time.Now()
  1186. topic.ModifyTime = time.Now()
  1187. topic.AssistantId = assistantId
  1188. topic.ThreadId = threadId
  1189. topicId, err := aimod.AddAiChatTopic(topic)
  1190. if err != nil {
  1191. br.Msg = "获取数据失败!"
  1192. br.ErrMsg = "生成话题失败,Err:" + err.Error()
  1193. return
  1194. }
  1195. chatItem := new(aimod.AiChat)
  1196. chatItem.AiChatTopicId = int(topicId)
  1197. chatItem.Ask = ask
  1198. chatItem.AskUuid = utils.MD5(ask)
  1199. chatItem.Answer = answer
  1200. chatItem.Model = EnabledModelsForMap[req.Model]
  1201. chatItem.SysUserId = this.SysUser.AdminId
  1202. chatItem.SysUserRealName = this.SysUser.RealName
  1203. chatItem.CreateTime = time.Now()
  1204. chatItem.ModifyTime = time.Now()
  1205. _, err = aimod.AddAiChat(chatItem)
  1206. if err != nil {
  1207. br.Msg = "获取数据失败!"
  1208. br.ErrMsg = "生成话题记录失败,Err:" + err.Error()
  1209. return
  1210. }
  1211. req.AiChatTopicId = int(topicId)
  1212. } else {
  1213. chatItem := new(aimod.AiChat)
  1214. chatItem.AiChatTopicId = req.AiChatTopicId
  1215. chatItem.Ask = ask
  1216. chatItem.AskUuid = askUuid
  1217. chatItem.Answer = answer
  1218. chatItem.Model = EnabledModelsForMap[req.Model]
  1219. chatItem.SysUserId = this.SysUser.AdminId
  1220. chatItem.SysUserRealName = this.SysUser.RealName
  1221. chatItem.CreateTime = time.Now()
  1222. chatItem.ModifyTime = time.Now()
  1223. _, err = aimod.AddAiChat(chatItem)
  1224. if err != nil {
  1225. br.Msg = "获取数据失败!"
  1226. br.ErrMsg = "生成话题记录失败,Err:" + err.Error()
  1227. return
  1228. }
  1229. //更新 assistantId,threadId
  1230. aiChatTopicObj := new(aimod.AiChatTopic)
  1231. updateParams := make(map[string]interface{})
  1232. updateParams["assistant_id"] = assistantId
  1233. updateParams["thread_id"] = threadId
  1234. updateParams["modify_time"] = time.Now()
  1235. whereParam := make(map[string]interface{})
  1236. whereParam["ai_chat_topic_id"] = req.AiChatTopicId
  1237. err = aiChatTopicObj.Update(updateParams, whereParam)
  1238. if err != nil {
  1239. br.Msg = "获取失败!"
  1240. br.ErrMsg = "修改助手标识失败,Err:" + err.Error()
  1241. return
  1242. }
  1243. }
  1244. resp.Model = aimod.ModelViewMap[req.Model]
  1245. resp.AiChatTopicId = req.AiChatTopicId
  1246. resp.Ask = ask
  1247. resp.Answer = answer
  1248. }
  1249. br.Ret = 200
  1250. br.Success = true
  1251. br.Msg = "获取成功"
  1252. br.Data = resp
  1253. }
  1254. //// @Title 文件上传
  1255. //// @Description 文件上传接口
  1256. //// @Param File query file true "文件"
  1257. //// @Param AiChatTopicId query int true "主题id"
  1258. //// @Success 200 {object} models.ResourceResp
  1259. //// @router /file/upload [post]
  1260. //func (this *AiFileController) FileUpload2() {
  1261. // br := new(models.BaseResponse).Init()
  1262. // defer func() {
  1263. // this.Data["json"] = br
  1264. // this.ServeJSON()
  1265. // }()
  1266. //
  1267. // f, h, err := this.GetFile("File")
  1268. // if err != nil {
  1269. // br.Msg = "获取资源信息失败"
  1270. // br.ErrMsg = "获取资源信息失败,Err:" + err.Error()
  1271. // return
  1272. // }
  1273. // model := this.GetString("Model")
  1274. //
  1275. // aiChatTopicId, _ := this.GetInt("AiChatTopicId")
  1276. //
  1277. // uploadFileName := h.Filename //上传的文件名
  1278. // ext := path.Ext(h.Filename)
  1279. // dateDir := time.Now().Format("20060102")
  1280. // uploadDir := utils.STATIC_DIR + "ai/" + dateDir
  1281. // err = os.MkdirAll(uploadDir, utils.DIR_MOD)
  1282. // if err != nil {
  1283. // br.Msg = "存储目录创建失败"
  1284. // br.ErrMsg = "存储目录创建失败,Err:" + err.Error()
  1285. // return
  1286. // }
  1287. // randStr := utils.GetRandStringNoSpecialChar(28)
  1288. // fileName := randStr + ext
  1289. // fpath := uploadDir + "/" + fileName
  1290. // defer f.Close() //关闭上传文件
  1291. // err = this.SaveToFile("File", fpath)
  1292. // if err != nil {
  1293. // br.Msg = "文件上传失败"
  1294. // br.ErrMsg = "文件上传失败,Err:" + err.Error()
  1295. // return
  1296. // }
  1297. // resourceUrl := ``
  1298. // ossClient := services.NewOssClient()
  1299. // if ossClient == nil {
  1300. // br.Msg = "上传失败"
  1301. // br.ErrMsg = "初始化OSS服务失败"
  1302. // return
  1303. // }
  1304. // resourceUrl, err = ossClient.UploadFile(fileName, fpath, "")
  1305. // if err != nil {
  1306. // br.Msg = "文件上传失败"
  1307. // br.ErrMsg = "文件上传失败,Err:" + err.Error()
  1308. // return
  1309. // }
  1310. //
  1311. // defer func() {
  1312. // os.Remove(fpath)
  1313. // }()
  1314. //
  1315. // item := new(models.Resource)
  1316. // item.ResourceUrl = resourceUrl
  1317. // item.ResourceType = 1
  1318. // item.CreateTime = time.Now()
  1319. // newId, err := models.AddResource(item)
  1320. // if err != nil {
  1321. // br.Msg = "资源上传失败"
  1322. // br.ErrMsg = "资源上传失败,Err:" + err.Error()
  1323. // return
  1324. // }
  1325. // //调用AI接口,上传文件
  1326. // resp := models.ResourceResp{
  1327. // Id: newId,
  1328. // ResourceUrl: resourceUrl,
  1329. // ResourceName: uploadFileName,
  1330. // }
  1331. // uploadResult, err := aiser.OpenAiFileUpload(resourceUrl, uploadFileName, model)
  1332. // if err != nil {
  1333. // br.Msg = "文件上传失败"
  1334. // br.ErrMsg = "文件上传失败,Err:" + err.Error()
  1335. // return
  1336. // }
  1337. //
  1338. // var assistantId, threadId string
  1339. // if aiChatTopicId > 0 {
  1340. // aiChatTopicObj := new(aimod.AiChatTopic)
  1341. // aiChatTopicObj.AiChatTopicId = aiChatTopicId
  1342. // topic, err := aiChatTopicObj.GetAiChatTopicById()
  1343. // if err != nil {
  1344. // if err.Error() == utils.ErrNoRow() {
  1345. // br.Msg = "获取数据失败!"
  1346. // br.ErrMsg = "获取数据失败,主题不存在,Err:" + err.Error()
  1347. // return
  1348. // }
  1349. // br.Msg = "获取数据失败!"
  1350. // br.ErrMsg = "获取数据失败,GetAiChatTopicById,Err:" + err.Error()
  1351. // return
  1352. // }
  1353. // assistantId = topic.AssistantId
  1354. // threadId = topic.ThreadId
  1355. // }
  1356. //
  1357. // if aiChatTopicId <= 0 { //新增
  1358. // topic := new(aimod.AiChatTopic)
  1359. // var filenameWithSuffix string
  1360. // filenameWithSuffix = path.Base(uploadFileName)
  1361. // var fileSuffix string
  1362. // fileSuffix = path.Ext(filenameWithSuffix)
  1363. // var filenameOnly string
  1364. // filenameOnly = strings.TrimSuffix(filenameWithSuffix, fileSuffix)
  1365. // topic.TopicName = filenameOnly
  1366. // topic.SysUserId = this.SysUser.AdminId
  1367. // topic.SysUserRealName = this.SysUser.RealName
  1368. // topic.CreateTime = time.Now()
  1369. // topic.ModifyTime = time.Now()
  1370. // topic.AssistantId = assistantId
  1371. // topic.ThreadId = threadId
  1372. // topicId, err := aimod.AddAiChatTopic(topic)
  1373. // if err != nil {
  1374. // br.Msg = "获取数据失败!"
  1375. // br.ErrMsg = "生成话题失败,Err:" + err.Error()
  1376. // return
  1377. // }
  1378. // aiChatTopicId = int(topicId)
  1379. // chatItem := new(aimod.AiChat)
  1380. // chatItem.AiChatTopicId = aiChatTopicId
  1381. // chatItem.Ask = uploadFileName
  1382. // chatItem.AskUuid = utils.MD5(uploadFileName)
  1383. // chatItem.Model = EnabledModelsForMap[model]
  1384. // chatItem.SysUserId = this.SysUser.AdminId
  1385. // chatItem.SysUserRealName = this.SysUser.RealName
  1386. // if uploadResult != nil && uploadResult.Data != nil {
  1387. // chatItem.OpenaiFileId = uploadResult.Data.ID
  1388. // chatItem.OpenaiFileName = uploadFileName
  1389. // }
  1390. // chatItem.OpenaiFilePath = resourceUrl
  1391. // chatItem.CreateTime = time.Now()
  1392. // chatItem.ModifyTime = time.Now()
  1393. // _, err = aimod.AddAiChat(chatItem)
  1394. // if err != nil {
  1395. // br.Msg = "获取数据失败!"
  1396. // br.ErrMsg = "生成话题记录失败,Err:" + err.Error()
  1397. // return
  1398. // }
  1399. // } else {
  1400. // chatItem := new(aimod.AiChat)
  1401. // chatItem.AiChatTopicId = aiChatTopicId
  1402. // chatItem.Ask = uploadFileName
  1403. // chatItem.AskUuid = utils.MD5(fileName)
  1404. // chatItem.Model = EnabledModelsForMap[model]
  1405. // chatItem.SysUserId = this.SysUser.AdminId
  1406. // chatItem.SysUserRealName = this.SysUser.RealName
  1407. // if uploadResult != nil && uploadResult.Data != nil {
  1408. // chatItem.OpenaiFileId = uploadResult.Data.ID
  1409. // chatItem.OpenaiFileName = uploadFileName
  1410. // }
  1411. // chatItem.OpenaiFilePath = resourceUrl
  1412. // chatItem.CreateTime = time.Now()
  1413. // chatItem.ModifyTime = time.Now()
  1414. // _, err = aimod.AddAiChat(chatItem)
  1415. // if err != nil {
  1416. // br.Msg = "获取数据失败!"
  1417. // br.ErrMsg = "生成话题记录失败,Err:" + err.Error()
  1418. // return
  1419. // }
  1420. // }
  1421. //
  1422. // if uploadResult != nil && uploadResult.Data != nil && uploadResult.Data.ID != "" {
  1423. // uploadObj := new(aimod.FileUploadRecord)
  1424. // uploadObj.AdminId = this.SysUser.AdminId
  1425. // uploadObj.FileUrl = resourceUrl
  1426. // uploadObj.FileName = uploadFileName
  1427. // uploadObj.OpenaiFileId = uploadResult.Data.ID
  1428. // uploadObj.OpenaiFileName = uploadResult.Data.FileName
  1429. // uploadObj.OpenaiObject = uploadResult.Data.Object
  1430. // uploadObj.OpenaiStatus = uploadResult.Data.Status
  1431. // uploadObj.OpenaiPurpose = uploadResult.Data.Purpose
  1432. // uploadObj.OpenaiStatusDetails = uploadResult.Data.StatusDetails
  1433. // uploadObj.OpenaiCreatedAt = uploadResult.Data.CreatedAt
  1434. // uploadObj.CreateTime = time.Now()
  1435. // uploadObj.ModifyTime = time.Now()
  1436. // _, err = uploadObj.AddFileUploadRecord()
  1437. // if err != nil {
  1438. // br.Msg = "上传失败"
  1439. // br.ErrMsg = "上传失败,Err:" + err.Error()
  1440. // return
  1441. // }
  1442. // resp.OpenaiFileId = uploadObj.OpenaiFileId
  1443. // }
  1444. // resp.AiChatTopicId = aiChatTopicId
  1445. // br.Msg = "上传成功"
  1446. // br.Ret = 200
  1447. // br.Success = true
  1448. // br.Data = resp
  1449. // return
  1450. //}
  1451. // AiSummaryClassifyList
  1452. // @Title 获取所有纪要分类接口-不包含沙盘
  1453. // @Description 获取所有纪要分类接口-不包含沙盘
  1454. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1455. // @Success 200 {object} data_manage.ChartClassifyListResp
  1456. // @router /summary/classifyList [get]
  1457. func (this *AiController) AiSummaryClassifyList() {
  1458. br := new(models.BaseResponse).Init()
  1459. defer func() {
  1460. this.Data["json"] = br
  1461. this.ServeJSON()
  1462. }()
  1463. resp := new(ai_summary.AiSummaryClassifyListResp)
  1464. rootList, err := ai_summary.GetAiSummaryClassifyByParentId(0)
  1465. if err != nil && err.Error() != utils.ErrNoRow() {
  1466. br.Msg = "获取失败"
  1467. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1468. return
  1469. }
  1470. classifyAll, err := ai_summary.GetAiSummaryClassifyAll()
  1471. if err != nil && err.Error() != utils.ErrNoRow() {
  1472. br.Msg = "获取失败"
  1473. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1474. return
  1475. }
  1476. nodeAll := make([]*ai_summary.AiSummaryClassifyItems, 0)
  1477. for k := range rootList {
  1478. rootNode := rootList[k]
  1479. aiSummaryService.AiSummaryClassifyItemsMakeTree(this.SysUser, classifyAll, rootNode)
  1480. nodeAll = append(nodeAll, rootNode)
  1481. }
  1482. resp.AllNodes = nodeAll
  1483. br.Ret = 200
  1484. br.Success = true
  1485. br.Msg = "获取成功"
  1486. br.Data = resp
  1487. }