resource.go 33 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103
  1. package knowledge
  2. import (
  3. "errors"
  4. "eta_gn/eta_api/models/knowledge"
  5. "eta_gn/eta_api/models/system"
  6. "eta_gn/eta_api/services"
  7. "eta_gn/eta_api/services/alarm_msg"
  8. "eta_gn/eta_api/services/knowledge_approve"
  9. "eta_gn/eta_api/utils"
  10. "fmt"
  11. "html"
  12. "strconv"
  13. "strings"
  14. "time"
  15. "github.com/tealeg/xlsx"
  16. )
  17. func AddResource(req *knowledge.AddReq, sysUser *system.Admin) (item *knowledge.KnowledgeResource, err error, errMsg string) {
  18. var startTime time.Time
  19. var endTime time.Time
  20. if req.StartTime != "" {
  21. if req.ResourceType == knowledge.KnowledgeResourceTypeEvent || req.ResourceType == knowledge.KnowledgeResourceTypePolicy {
  22. startTime, err = time.ParseInLocation(utils.FormatDateTime, req.StartTime, time.Local)
  23. if err != nil { // 如果时间格式不正确,则返回错误信息
  24. errMsg = "开始时间格式不正确"
  25. err = fmt.Errorf("开始时间格式不正确,Err:" + err.Error())
  26. return
  27. }
  28. } else {
  29. startTime, err = time.ParseInLocation(utils.FormatDate, req.StartTime, time.Local)
  30. if err != nil { // 如果时间格式不正确,则返回错误信息
  31. errMsg = "开始时间格式不正确"
  32. err = fmt.Errorf("开始时间格式不正确,Err:" + err.Error())
  33. return
  34. }
  35. }
  36. }
  37. if req.EndTime != "" {
  38. if req.ResourceType == knowledge.KnowledgeResourceTypeEvent || req.ResourceType == knowledge.KnowledgeResourceTypePolicy {
  39. endTime, err = time.ParseInLocation(utils.FormatDateTime, req.EndTime, time.Local)
  40. if err != nil { // 如果时间格式不正确,则返回错误信息
  41. errMsg = "结束时间格式不正确"
  42. err = fmt.Errorf("结束时间格式不正确,Err:" + err.Error())
  43. return
  44. }
  45. }
  46. }
  47. isFile := 0
  48. if req.Content != "" {
  49. e := utils.ContentXssCheck(req.Content)
  50. if e != nil {
  51. errMsg = "存在非法标签"
  52. err = fmt.Errorf("存在非法标签, Err: " + e.Error())
  53. return
  54. }
  55. content, e := services.FilterReportContentBr(req.Content)
  56. if e != nil {
  57. errMsg = "内容去除前后空格失败"
  58. err = fmt.Errorf("内容去除前后空格失败, Err: " + e.Error())
  59. return
  60. }
  61. req.Content = content
  62. /*contentSub, err = services.GetReportContentSub(req.Content)
  63. if err != nil {
  64. go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+err.Error(), 3)
  65. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  66. return
  67. }*/
  68. } else {
  69. if req.FileUrl == "" {
  70. errMsg = "内容或文件不能为空"
  71. err = fmt.Errorf("内容或文件不能为空")
  72. return
  73. }
  74. isFile = 1
  75. }
  76. classifyObj := new(knowledge.KnowledgeClassify)
  77. classifyItem, err := classifyObj.GetClassifyById(req.ClassifyId)
  78. if err != nil {
  79. if utils.IsErrNoRow(err) {
  80. err = fmt.Errorf("分类不存在,Err:" + err.Error())
  81. errMsg = "分类不存在"
  82. return
  83. }
  84. errMsg = "获取分类失败"
  85. err = fmt.Errorf("获取分类失败,Err:" + err.Error())
  86. return
  87. }
  88. if req.ClassifyId != classifyItem.ClassifyId { // 如果传进来的分类id和数据库中查到的分类id不一致,说明传进来的分类id是错误的
  89. errMsg = "错误分类"
  90. err = fmt.Errorf("错误分类")
  91. return
  92. }
  93. // 校验标签
  94. if req.TagId > 0 {
  95. tagObj := new(knowledge.KnowledgeTag)
  96. _, e := tagObj.GetTagById(req.TagId)
  97. if e != nil {
  98. if utils.IsErrNoRow(e) {
  99. err = fmt.Errorf("标签不存在,Err:" + e.Error())
  100. errMsg = "标签不存在"
  101. return
  102. }
  103. err = fmt.Errorf("获取标签失败,Err:" + e.Error())
  104. return
  105. }
  106. }
  107. item = new(knowledge.KnowledgeResource)
  108. item.ClassifyId = req.ClassifyId
  109. item.TagId = req.TagId
  110. item.SourceFrom = req.SourceFrom
  111. item.ResourceType = req.ResourceType
  112. item.Title = req.Title
  113. item.State = knowledge.KnowledgeResourceStateUnpublished
  114. item.Content = html.EscapeString(req.Content)
  115. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  116. item.ResourceCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp)
  117. item.IsFile = isFile
  118. item.FileUrl = req.FileUrl
  119. //todo 内容前5行
  120. //item.ContentSub = html.EscapeString(contentSub)
  121. if !startTime.IsZero() {
  122. item.StartTime = &startTime
  123. } else {
  124. item.StartTime = nil
  125. }
  126. if !endTime.IsZero() {
  127. item.EndTime = &endTime
  128. } else {
  129. item.EndTime = nil
  130. }
  131. item.ModifyTime = time.Now()
  132. item.AdminId = sysUser.AdminId
  133. item.AdminRealName = sysUser.RealName
  134. //item.LastModifyAdminId = sysUser.AdminId
  135. //item.LastModifyAdminName = sysUser.RealName
  136. item.ModifyTime = time.Now()
  137. item.CreateTime = time.Now()
  138. err = item.Add(item)
  139. if err != nil {
  140. errMsg = "保存失败"
  141. err = fmt.Errorf("保存失败,Err:" + err.Error())
  142. return
  143. }
  144. //todo 是否需要保存到es中
  145. return
  146. }
  147. func EditResource(resourceInfo *knowledge.KnowledgeResource, req knowledge.EditReq, sysUser *system.Admin) (err error, errMsg string) {
  148. errMsg = `保存失败`
  149. var startTime time.Time
  150. var endTime time.Time
  151. if req.StartTime != "" {
  152. if req.ResourceType == knowledge.KnowledgeResourceTypeEvent || req.ResourceType == knowledge.KnowledgeResourceTypePolicy {
  153. startTime, err = time.ParseInLocation(utils.FormatDateTime, req.StartTime, time.Local)
  154. if err != nil { // 如果时间格式不正确,则返回错误信息
  155. errMsg = "开始时间格式不正确"
  156. err = fmt.Errorf("开始时间格式不正确,Err:" + err.Error())
  157. return
  158. }
  159. } else {
  160. startTime, err = time.ParseInLocation(utils.FormatDate, req.StartTime, time.Local)
  161. if err != nil { // 如果时间格式不正确,则返回错误信息
  162. errMsg = "开始时间格式不正确"
  163. err = fmt.Errorf("开始时间格式不正确,Err:" + err.Error())
  164. return
  165. }
  166. }
  167. }
  168. if req.EndTime != "" {
  169. if req.ResourceType == knowledge.KnowledgeResourceTypeEvent || req.ResourceType == knowledge.KnowledgeResourceTypePolicy {
  170. endTime, err = time.ParseInLocation(utils.FormatDateTime, req.EndTime, time.Local)
  171. if err != nil { // 如果时间格式不正确,则返回错误信息
  172. errMsg = "结束时间格式不正确"
  173. err = fmt.Errorf("结束时间格式不正确,Err:" + err.Error())
  174. return
  175. }
  176. }
  177. }
  178. if resourceInfo.IsFile == 0 {
  179. if req.Content == "" {
  180. errMsg = "内容不能为空"
  181. err = fmt.Errorf("内容不能为空")
  182. return
  183. }
  184. } else if resourceInfo.IsFile == 1 {
  185. if req.FileUrl == "" {
  186. errMsg = "文件地址不能为空"
  187. err = fmt.Errorf("文件地址不能为空")
  188. return
  189. }
  190. }
  191. if req.Content != "" {
  192. e := utils.ContentXssCheck(req.Content)
  193. if e != nil {
  194. errMsg = "存在非法标签"
  195. err = fmt.Errorf("存在非法标签, Err: " + e.Error())
  196. return
  197. }
  198. content, e := services.FilterReportContentBr(req.Content)
  199. if e != nil {
  200. errMsg = "内容去除前后空格失败"
  201. err = fmt.Errorf("内容去除前后空格失败, Err: " + e.Error())
  202. return
  203. }
  204. req.Content = content
  205. /*contentSub, err = services.GetReportContentSub(req.Content)
  206. if err != nil {
  207. go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+err.Error(), 3)
  208. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  209. return
  210. }*/
  211. }
  212. classifyObj := new(knowledge.KnowledgeClassify)
  213. classifyItem, err := classifyObj.GetClassifyById(req.ClassifyId)
  214. if err != nil {
  215. if utils.IsErrNoRow(err) {
  216. err = fmt.Errorf("分类不存在,Err:" + err.Error())
  217. errMsg = "分类不存在"
  218. return
  219. }
  220. errMsg = "获取分类失败"
  221. err = fmt.Errorf("获取分类失败,Err:" + err.Error())
  222. return
  223. }
  224. if req.ClassifyId != classifyItem.ClassifyId { // 如果传进来的分类id和数据库中查到的分类id不一致,说明传进来的分类id是错误的
  225. errMsg = "错误分类"
  226. err = fmt.Errorf("错误分类")
  227. return
  228. }
  229. if req.TagId > 0 {
  230. tagObj := new(knowledge.KnowledgeTag)
  231. _, e := tagObj.GetTagById(req.TagId)
  232. if e != nil {
  233. if utils.IsErrNoRow(e) {
  234. err = fmt.Errorf("标签不存在,Err:" + e.Error())
  235. errMsg = "标签不存在"
  236. return
  237. }
  238. err = fmt.Errorf("获取标签失败,Err:" + e.Error())
  239. return
  240. }
  241. }
  242. resourceInfo.ClassifyId = req.ClassifyId
  243. resourceInfo.SourceFrom = req.SourceFrom
  244. resourceInfo.TagId = req.TagId
  245. resourceInfo.Title = req.Title
  246. if req.Content != "" {
  247. resourceInfo.Content = html.EscapeString(req.Content)
  248. }
  249. if !startTime.IsZero() {
  250. resourceInfo.StartTime = &startTime
  251. }
  252. if !endTime.IsZero() {
  253. resourceInfo.EndTime = &endTime
  254. }
  255. resourceInfo.FileUrl = req.FileUrl
  256. //resourceInfo.LastModifyAdminId = sysUser.AdminId
  257. //resourceInfo.LastModifyAdminName = sysUser.RealName
  258. resourceInfo.ModifyTime = time.Now()
  259. updateCols := []string{"ClassifyId", "SourceFrom", "TagId", "Title", "Content", "StartTime", "EndTime", "ModifyTime", "FileUrl"}
  260. // 修改报告的基本信息,以及报告的授权用户
  261. err = resourceInfo.Update(updateCols)
  262. if err != nil {
  263. return
  264. }
  265. return
  266. }
  267. // ImportResourceData
  268. // @Description: 数据导入
  269. // @author: Roc
  270. // @datetime 2024-08-01 11:27:21
  271. // @param path string
  272. // @param sysUser *system.Admin
  273. // @return successCount int
  274. // @return failCount int
  275. // @return err error
  276. // @return errMsg string
  277. func ImportResourceData(path string, resourceType int, sysUser *system.Admin) (successCount, failCount int, err error, errMsg string) {
  278. // 错误信息
  279. errMsgList := make([]string, 0)
  280. defer func() {
  281. // 错误信息记录
  282. if len(errMsgList) > 0 {
  283. utils.FileLog.Info("导入失败, errMsgList: %v", strings.Join(errMsgList, "\n"))
  284. }
  285. }()
  286. errMsg = `导入失败`
  287. xlFile, err := xlsx.OpenFile(path)
  288. if err != nil {
  289. fmt.Println(err.Error())
  290. return
  291. }
  292. if len(xlFile.Sheets) <= 0 {
  293. errMsg = "导入模板异常"
  294. err = errors.New(errMsg)
  295. return
  296. }
  297. //导入失败数据
  298. failDataList := make([]*knowledge.KnowledgeImportFail, 0)
  299. var indexDataList []knowledge.ResourceImportData
  300. tagObj := new(knowledge.KnowledgeTag)
  301. // 模板校验,然后处理成标准化格式
  302. for _, sheet := range xlFile.Sheets {
  303. var tmpFailDataList []*knowledge.KnowledgeImportFail
  304. var tmpIndexDataList []knowledge.ResourceImportData
  305. rowList := sheet.Rows
  306. if len(rowList) <= 0 {
  307. errMsg = sheet.Name + "页异常"
  308. err = errors.New(errMsg)
  309. return
  310. }
  311. if resourceType == knowledge.KnowledgeResourceTypeEvent || resourceType == knowledge.KnowledgeResourceTypePolicy {
  312. tmpIndexDataList, tmpFailDataList, err, errMsg = getDataByTemplateEvent(sheet, sysUser.AdminId, resourceType)
  313. } else {
  314. tmpIndexDataList, tmpFailDataList, err, errMsg = getDataByTemplatePoint(sheet, sysUser.AdminId, resourceType)
  315. }
  316. if err != nil {
  317. return
  318. }
  319. fmt.Println("tmpIndexDataList: ", tmpIndexDataList)
  320. for _, v := range tmpFailDataList {
  321. fmt.Println("tmpFailDataList: ", v)
  322. }
  323. indexDataList = append(indexDataList, tmpIndexDataList...)
  324. failDataList = append(failDataList, tmpFailDataList...)
  325. }
  326. if len(indexDataList) <= 0 {
  327. if len(failDataList) > 0 {
  328. errMsg = failDataList[0].Remark
  329. err = errors.New(errMsg)
  330. }
  331. return
  332. }
  333. // 遍历获取所有分类
  334. classifyNames := make([]string, 0)
  335. for _, v := range indexDataList {
  336. if v.ClassifyFirstName != "" {
  337. classifyNames = append(classifyNames, v.ClassifyFirstName)
  338. }
  339. if v.ClassifySecondName != "" {
  340. classifyNames = append(classifyNames, v.ClassifySecondName)
  341. }
  342. if v.ClassifyThirdName != "" {
  343. classifyNames = append(classifyNames, v.ClassifyThirdName)
  344. }
  345. }
  346. fmt.Println(classifyNames)
  347. classifyList, err := knowledge.GetFullClassifyListByName(classifyNames, resourceType)
  348. if err != nil {
  349. err = fmt.Errorf("获取分类数据失败 Err: %s", err.Error())
  350. errMsg = "获取分类数据失败"
  351. return
  352. }
  353. classifyObj := new(knowledge.KnowledgeClassify)
  354. classifyAllList, err := classifyObj.GetAllClassify(resourceType)
  355. if err != nil {
  356. err = fmt.Errorf("获取分类数据失败 Err: %s", err.Error())
  357. errMsg = "获取分类数据失败"
  358. return
  359. }
  360. classifyNameMap := make(map[string]int)
  361. classifyHasChildMap := make(map[int]bool)
  362. for _, v := range classifyAllList {
  363. if v.ParentId > 0 {
  364. classifyHasChildMap[v.ParentId] = true
  365. }
  366. }
  367. for _, v := range classifyList {
  368. name := fmt.Sprintf("%s/%s/%s", v.RootName, v.ParentName, v.ClassifyName)
  369. fmt.Println("name", name)
  370. if v.RootName == "" && v.ParentName == "" { //一级分类
  371. name = fmt.Sprintf("%s/%s/%s", v.ClassifyName, "", "")
  372. if _, ok := classifyHasChildMap[v.ClassifyId]; ok {
  373. continue
  374. }
  375. } else if v.RootName == "" { //二级分类
  376. name = fmt.Sprintf("%s/%s/%s", v.ParentName, v.ClassifyName, "")
  377. if _, ok := classifyHasChildMap[v.ClassifyId]; ok {
  378. continue
  379. }
  380. }
  381. classifyNameMap[name] = v.ClassifyId
  382. }
  383. tagNameMap := make(map[string]int)
  384. tagList, err := tagObj.GetAllTag(resourceType)
  385. for _, v := range tagList {
  386. tagNameMap[v.TagName] = v.TagId
  387. }
  388. for _, v := range indexDataList {
  389. errTip := ""
  390. classifyId := 0
  391. if successCount > 100 {
  392. errTip = "导入数量超过100条"
  393. } else if v.Title == "" {
  394. errTip = "标题未填"
  395. } else if len(v.Title) > 600 {
  396. errTip = "标题过长"
  397. } else if v.Content == "" {
  398. errTip = "正文未填"
  399. } else if v.SourceFrom == "" {
  400. errTip = "来源未填"
  401. } else if v.ClassifyFirstName == "" {
  402. errTip = "分类未填"
  403. } else if v.StartDate == "" || v.StartTime == "" {
  404. if resourceType == knowledge.KnowledgeResourceTypeEvent || resourceType == knowledge.KnowledgeResourceTypePolicy {
  405. errTip = "开始时间未填"
  406. } else if v.StartDate == "" {
  407. errTip = "时间未填"
  408. }
  409. }
  410. if errTip == "" {
  411. // 判断分类是否存在
  412. classifyName := fmt.Sprintf("%s/%s/%s", v.ClassifyFirstName, v.ClassifySecondName, v.ClassifyThirdName)
  413. fmt.Println("classifyName: ", classifyName)
  414. classifyIdTmp, ok := classifyNameMap[classifyName]
  415. if !ok {
  416. errTip = "分类不存在"
  417. }
  418. classifyId = classifyIdTmp
  419. }
  420. if errTip != "" {
  421. failItem := &knowledge.KnowledgeImportFail{
  422. Title: v.Title,
  423. Content: v.Content,
  424. SourceFrom: v.SourceFrom,
  425. ClassifyFirst: v.ClassifyFirstName,
  426. ClassifySecond: v.ClassifySecondName,
  427. ClassifyThird: v.ClassifyThirdName,
  428. ResourceType: resourceType,
  429. StartDate: v.StartDate,
  430. EndDate: v.EndDate,
  431. StartTime: v.StartTime,
  432. EndTime: v.EndTime,
  433. Remark: errTip,
  434. SysUserId: fmt.Sprint(sysUser.AdminId),
  435. CreateTime: time.Now(),
  436. }
  437. failDataList = append(failDataList, failItem)
  438. continue
  439. }
  440. tagId, _ := tagNameMap[v.Tag]
  441. req := new(knowledge.AddReq)
  442. req.Title = v.Title
  443. req.Content = v.Content
  444. req.SourceFrom = v.SourceFrom
  445. req.ClassifyId = classifyId
  446. req.TagId = tagId
  447. req.ResourceType = resourceType
  448. if v.StartDate != "" {
  449. if resourceType == knowledge.KnowledgeResourceTypeEvent || resourceType == knowledge.KnowledgeResourceTypePolicy {
  450. req.StartTime = fmt.Sprintf("%s %s", v.StartDate, v.StartTime)
  451. } else {
  452. req.StartTime = v.StartDate
  453. }
  454. }
  455. if v.EndDate != "" {
  456. if resourceType == knowledge.KnowledgeResourceTypeEvent || resourceType == knowledge.KnowledgeResourceTypePolicy {
  457. req.EndTime = fmt.Sprintf("%s %s", v.EndDate, v.EndTime)
  458. }
  459. }
  460. tmpErr, msg := addExcelResource(req, sysUser)
  461. if tmpErr != nil {
  462. failItem := &knowledge.KnowledgeImportFail{
  463. Title: v.Title,
  464. Content: v.Content,
  465. SourceFrom: v.SourceFrom,
  466. ClassifyFirst: v.ClassifyFirstName,
  467. ClassifySecond: v.ClassifySecondName,
  468. ClassifyThird: v.ClassifyThirdName,
  469. ResourceType: resourceType,
  470. StartDate: v.StartDate,
  471. EndDate: v.EndDate,
  472. StartTime: v.StartTime,
  473. EndTime: v.EndTime,
  474. Remark: "新增事件失败:" + msg,
  475. SysUserId: fmt.Sprint(sysUser.AdminId),
  476. CreateTime: time.Now(),
  477. }
  478. failDataList = append(failDataList, failItem)
  479. continue
  480. } else {
  481. successCount++
  482. }
  483. }
  484. // 失败数量
  485. failCount = len(failDataList)
  486. //fmt.Println("failDataList:", len(failDataList))
  487. if failCount > 0 {
  488. failObj := new(knowledge.KnowledgeImportFail)
  489. //先删除导入失败记录
  490. _ = failObj.Delete(sysUser.AdminId, resourceType)
  491. // 批量添加导入失败记录
  492. err = failObj.MultiAdd(failDataList)
  493. if err != nil {
  494. go alarm_msg.SendAlarmMsg("导入数据 新增失败记录失败,Err:"+err.Error(), 3)
  495. }
  496. {
  497. //错误信息字符串切片,最后作为发送邮件通知使用
  498. failContents := make([]string, 0)
  499. for _, v := range failDataList {
  500. failContents = append(failContents, fmt.Sprint(v.Title, "导入失败:", v.Remark))
  501. }
  502. utils.FileLog.Info("导入数据 存在部分数据导入失败:" + strings.Join(failContents, ";"))
  503. //导入失败的话,最后统一邮件提醒就好啦,不需要每次都去提醒
  504. go alarm_msg.SendAlarmMsg("导入数据 存在部分数据导入失败:"+strings.Join(failContents, ";"), 3)
  505. }
  506. }
  507. return
  508. }
  509. // getDataByTemplateEvent
  510. func getDataByTemplateEvent(sheet *xlsx.Sheet, sysUserId, resourceType int) (indexDataList []knowledge.ResourceImportData, failDataList []*knowledge.KnowledgeImportFail, err error, errMsg string) {
  511. fmt.Println("sheet name: ", sheet.Name)
  512. indexDataList = make([]knowledge.ResourceImportData, 0)
  513. failDataList = make([]*knowledge.KnowledgeImportFail, 0)
  514. //遍历行读取
  515. maxRow := sheet.MaxRow
  516. fmt.Println("maxRow:", maxRow)
  517. // 表头信息
  518. if maxRow <= 3 {
  519. errMsg = "模板异常1"
  520. err = errors.New(errMsg)
  521. return
  522. }
  523. // 表头校验
  524. {
  525. headerRow := sheet.Row(1)
  526. cells := headerRow.Cells
  527. fmt.Println("cells:", len(cells))
  528. if len(cells) < 11 {
  529. errMsg = "导入文件异常,请下载最新导入模板文件"
  530. err = errors.New(errMsg)
  531. return
  532. }
  533. // 循环打印每个单元格
  534. for k, v := range cells {
  535. fmt.Println("第", k, "个单元格", v.Value)
  536. }
  537. templateFail := false
  538. if cells[0].Value != "开始时间" {
  539. templateFail = true
  540. }
  541. if cells[2].Value != "结束时间(非必填)" {
  542. templateFail = true
  543. }
  544. if cells[4].Value != "标题" {
  545. templateFail = true
  546. }
  547. if cells[5].Value != "正文" {
  548. templateFail = true
  549. }
  550. if cells[6].Value != "来源" {
  551. templateFail = true
  552. }
  553. if cells[7].Value != "一级分类" {
  554. templateFail = true
  555. }
  556. if cells[8].Value != "二级分类" {
  557. templateFail = true
  558. }
  559. if cells[9].Value != "三级分类" {
  560. templateFail = true
  561. }
  562. if cells[10].Value != "标签" {
  563. templateFail = true
  564. }
  565. headerRow2 := sheet.Row(2)
  566. cells2 := headerRow2.Cells
  567. for k, v := range cells2 {
  568. fmt.Println("2第", k, "个单元格", v.Value)
  569. }
  570. if len(cells2) < 11 {
  571. templateFail = true
  572. } else {
  573. if cells2[0].Value != "日期" {
  574. templateFail = true
  575. }
  576. if cells2[1].Value != "时间" {
  577. templateFail = true
  578. }
  579. if cells2[2].Value != "日期" {
  580. templateFail = true
  581. }
  582. if cells2[3].Value != "时间" {
  583. templateFail = true
  584. }
  585. }
  586. if templateFail {
  587. fmt.Println("头部信息校验失败")
  588. errMsg = "导入文件异常,请下载最新导入模板文件"
  589. err = errors.New(errMsg)
  590. return
  591. }
  592. }
  593. for i := 3; i < maxRow; i++ {
  594. row := sheet.Row(i)
  595. cells := row.Cells
  596. lenCell := len(cells)
  597. // 过滤空白行
  598. if lenCell <= 0 {
  599. continue
  600. }
  601. var startDateO, endDateO, startTimeO, endTimeO string
  602. var startDate, startTime, endDate, endTime string
  603. var title, content, sourceFrom, classifyName1, classifyName2, classifyName3, tag string
  604. for k, v := range cells {
  605. fmt.Println("数据第行", i, "第", k, "个单元格", v.Value)
  606. if k == 0 {
  607. startDate = strings.TrimSpace(cells[0].Value) //开始时间
  608. startDateO = startDate
  609. } else if k == 1 {
  610. startTime = strings.TrimSpace(cells[1].Value) //开始时间
  611. startTimeO = startTime
  612. } else if k == 2 {
  613. endDate = strings.TrimSpace(cells[2].Value) //结束时间
  614. endDateO = endDate
  615. } else if k == 3 {
  616. endTime = strings.TrimSpace(cells[3].Value) //结束时间
  617. endTimeO = endTime
  618. } else if k == 4 {
  619. title = strings.TrimSpace(cells[4].Value) //标题
  620. } else if k == 5 {
  621. content = strings.TrimSpace(cells[5].Value) //正文
  622. } else if k == 6 {
  623. sourceFrom = strings.TrimSpace(cells[6].Value) //来源
  624. } else if k == 7 {
  625. classifyName1 = strings.TrimSpace(cells[7].Value) //一级分类
  626. } else if k == 8 {
  627. classifyName2 = strings.TrimSpace(cells[8].Value) //二级分类
  628. } else if k == 9 {
  629. classifyName3 = strings.TrimSpace(cells[9].Value) //三级分类
  630. } else if k == 10 {
  631. tag = strings.TrimSpace(cells[10].Value) //标签
  632. }
  633. }
  634. if title == "" && startDate == "" && startTime == "" && endTime == "" && endDate == "" && content == "" && tag == "" && sourceFrom == "" && classifyName1 == "" && classifyName2 == "" && classifyName3 == "" { //过滤空白行
  635. continue
  636. }
  637. fmt.Println("lenCell:", lenCell)
  638. // 校验日期格式
  639. var startDateVal, endDateVal, startTimeVal float64
  640. var tmpErr error
  641. if startDate != "" {
  642. // 判断9:09:14日期格式是否正确
  643. // 判断是否是数字
  644. startDateVal, tmpErr = strconv.ParseFloat(startDate, 64)
  645. if tmpErr == nil {
  646. startDate = xlsx.TimeFromExcelTime(startDateVal, false).Format(utils.FormatDate)
  647. fmt.Println(startDate)
  648. } else {
  649. startDate, tmpErr = getExcelDate(startDate)
  650. if tmpErr != nil {
  651. failDataList = append(failDataList, &knowledge.KnowledgeImportFail{
  652. //Id: 0,
  653. Title: title,
  654. Content: content,
  655. SourceFrom: sourceFrom,
  656. ClassifyFirst: classifyName1,
  657. ClassifySecond: classifyName2,
  658. ClassifyThird: classifyName3,
  659. ResourceType: resourceType,
  660. StartDate: startDateO,
  661. EndDate: endDateO,
  662. StartTime: startTimeO,
  663. EndTime: endTimeO,
  664. Remark: "日期格式异常",
  665. SysUserId: strconv.Itoa(sysUserId),
  666. CreateTime: time.Now(),
  667. })
  668. continue
  669. }
  670. }
  671. if startTime != "" {
  672. // 判断9:09:14日期格式是否正确
  673. startTimeVal, tmpErr = strconv.ParseFloat(startTime, 64)
  674. if tmpErr == nil {
  675. startTimeVal = startDateVal + startTimeVal
  676. startTime = xlsx.TimeFromExcelTime(startTimeVal, false).Format(utils.FormatTime)
  677. fmt.Println(startTime)
  678. } else {
  679. _, tmpErr = time.Parse(utils.FormatDateTime, startDate+" "+startTime)
  680. if tmpErr != nil {
  681. failDataList = append(failDataList, &knowledge.KnowledgeImportFail{
  682. //Id: 0,
  683. Title: title,
  684. Content: content,
  685. SourceFrom: sourceFrom,
  686. ClassifyFirst: classifyName1,
  687. ClassifySecond: classifyName2,
  688. ClassifyThird: classifyName3,
  689. ResourceType: resourceType,
  690. StartDate: startDateO,
  691. EndDate: endDateO,
  692. StartTime: startTimeO,
  693. EndTime: endTimeO,
  694. Remark: "日期格式异常",
  695. SysUserId: strconv.Itoa(sysUserId),
  696. CreateTime: time.Now(),
  697. })
  698. continue
  699. }
  700. }
  701. }
  702. }
  703. if endDate != "" {
  704. endDateVal, tmpErr = strconv.ParseFloat(endDate, 64)
  705. if tmpErr == nil {
  706. endDate = xlsx.TimeFromExcelTime(endDateVal, false).Format(utils.FormatDate)
  707. fmt.Println(endDate)
  708. } else {
  709. endDate, tmpErr = getExcelDate(endDate)
  710. if tmpErr != nil {
  711. failDataList = append(failDataList, &knowledge.KnowledgeImportFail{
  712. //Id: 0,
  713. Title: title,
  714. Content: content,
  715. SourceFrom: sourceFrom,
  716. ClassifyFirst: classifyName1,
  717. ClassifySecond: classifyName2,
  718. ClassifyThird: classifyName3,
  719. ResourceType: resourceType,
  720. StartDate: startDateO,
  721. EndDate: endDateO,
  722. StartTime: startTimeO,
  723. EndTime: endTimeO,
  724. Remark: "日期格式异常",
  725. SysUserId: strconv.Itoa(sysUserId),
  726. CreateTime: time.Now(),
  727. })
  728. continue
  729. }
  730. }
  731. if endTime != "" {
  732. // 判断9:09:14日期格式是否正确
  733. endTimeVal, e := strconv.ParseFloat(endTime, 64)
  734. if e == nil {
  735. endTimeVal = endDateVal + endTimeVal
  736. endTime = xlsx.TimeFromExcelTime(endTimeVal, false).Format(utils.FormatTime)
  737. fmt.Println(endTime)
  738. } else {
  739. _, e = time.Parse(utils.FormatDateTime, endDate+" "+endTime)
  740. if e != nil {
  741. failDataList = append(failDataList, &knowledge.KnowledgeImportFail{
  742. //Id: 0,
  743. Title: title,
  744. Content: content,
  745. SourceFrom: sourceFrom,
  746. ClassifyFirst: classifyName1,
  747. ClassifySecond: classifyName2,
  748. ClassifyThird: classifyName3,
  749. ResourceType: resourceType,
  750. StartDate: startDate,
  751. EndDate: endDate,
  752. StartTime: startTimeO,
  753. EndTime: endTimeO,
  754. Remark: "日期格式异常",
  755. SysUserId: strconv.Itoa(sysUserId),
  756. CreateTime: time.Now(),
  757. })
  758. continue
  759. }
  760. }
  761. }
  762. }
  763. resourceItem := knowledge.ResourceImportData{
  764. Title: title,
  765. StartDate: startDate,
  766. EndDate: endDate,
  767. StartTime: startTime,
  768. EndTime: endTime,
  769. Content: content,
  770. Tag: tag,
  771. SourceFrom: sourceFrom,
  772. ClassifyFirstName: classifyName1,
  773. ClassifySecondName: classifyName2,
  774. ClassifyThirdName: classifyName3,
  775. }
  776. indexDataList = append(indexDataList, resourceItem)
  777. }
  778. return
  779. }
  780. // getDataByTemplatePoint
  781. func getDataByTemplatePoint(sheet *xlsx.Sheet, sysUserId, resourceType int) (indexDataList []knowledge.ResourceImportData, failDataList []*knowledge.KnowledgeImportFail, err error, errMsg string) {
  782. fmt.Println("sheet name: ", sheet.Name)
  783. indexDataList = make([]knowledge.ResourceImportData, 0)
  784. failDataList = make([]*knowledge.KnowledgeImportFail, 0)
  785. //遍历行读取
  786. maxRow := sheet.MaxRow
  787. fmt.Println("maxRow:", maxRow)
  788. // 表头信息
  789. if maxRow <= 3 {
  790. errMsg = "模板异常1"
  791. err = errors.New(errMsg)
  792. return
  793. }
  794. // 表头校验
  795. {
  796. headerRow := sheet.Row(1)
  797. cells := headerRow.Cells
  798. fmt.Println("cells:", len(cells))
  799. if len(cells) < 5 {
  800. errMsg = "导入文件异常,请下载最新导入模板文件"
  801. err = errors.New(errMsg)
  802. return
  803. }
  804. // 循环打印每个单元格
  805. for k, v := range cells {
  806. fmt.Println("第", k, "个单元格", v.Value)
  807. }
  808. templateFail := false
  809. if cells[0].Value != "时间" {
  810. templateFail = true
  811. }
  812. if cells[1].Value != "标题" {
  813. templateFail = true
  814. }
  815. if cells[2].Value != "正文" {
  816. templateFail = true
  817. }
  818. if cells[3].Value != "来源" {
  819. templateFail = true
  820. }
  821. if cells[4].Value != "一级分类" {
  822. templateFail = true
  823. }
  824. if cells[5].Value != "二级分类" {
  825. templateFail = true
  826. }
  827. if cells[6].Value != "三级分类" {
  828. templateFail = true
  829. }
  830. if cells[7].Value != "标签" {
  831. templateFail = true
  832. }
  833. if templateFail {
  834. fmt.Println("头部信息校验失败")
  835. errMsg = "导入文件异常,请下载最新导入模板文件"
  836. err = errors.New(errMsg)
  837. return
  838. }
  839. }
  840. for i := 2; i < maxRow; i++ {
  841. row := sheet.Row(i)
  842. cells := row.Cells
  843. lenCell := len(cells)
  844. // 过滤空白行
  845. if lenCell <= 0 {
  846. continue
  847. }
  848. var startDateO string
  849. var startDate string
  850. var title, content, sourceFrom, classifyName1, classifyName2, classifyName3, tag string
  851. for k, v := range cells {
  852. fmt.Println("数据第行", i, "第", k, "个单元格", v.Value)
  853. if k == 0 {
  854. startDate = strings.TrimSpace(cells[0].Value) //开始时间
  855. startDateO = startDate
  856. } else if k == 1 {
  857. title = strings.TrimSpace(cells[1].Value) //标题
  858. } else if k == 2 {
  859. content = strings.TrimSpace(cells[2].Value) //正文
  860. } else if k == 3 {
  861. sourceFrom = strings.TrimSpace(cells[3].Value) //来源
  862. } else if k == 4 {
  863. classifyName1 = strings.TrimSpace(cells[4].Value) //一级分类
  864. } else if k == 5 {
  865. classifyName2 = strings.TrimSpace(cells[5].Value) //二级分类
  866. } else if k == 6 {
  867. classifyName3 = strings.TrimSpace(cells[6].Value) //三级分类
  868. } else if k == 7 {
  869. tag = strings.TrimSpace(cells[7].Value) //标签
  870. }
  871. }
  872. if title == "" && startDate == "" && content == "" && tag == "" && sourceFrom == "" && classifyName1 == "" && classifyName2 == "" && classifyName3 == "" { //过滤空白行
  873. continue
  874. }
  875. // 校验日期格式
  876. if startDate != "" {
  877. // 判断9:09:14日期格式是否正确
  878. // 判断是否是数字
  879. startDateVal, tmpErr := strconv.ParseFloat(startDate, 64)
  880. if tmpErr == nil {
  881. startDate = xlsx.TimeFromExcelTime(startDateVal, false).Format(utils.FormatDate)
  882. fmt.Println(startDate)
  883. } else {
  884. startDate, tmpErr = getExcelDate(startDate)
  885. if tmpErr != nil {
  886. failDataList = append(failDataList, &knowledge.KnowledgeImportFail{
  887. //Id: 0,
  888. Title: title,
  889. Content: content,
  890. SourceFrom: sourceFrom,
  891. ClassifyFirst: classifyName1,
  892. ClassifySecond: classifyName2,
  893. ClassifyThird: classifyName3,
  894. ResourceType: resourceType,
  895. StartDate: startDateO,
  896. Remark: "日期格式异常",
  897. SysUserId: strconv.Itoa(sysUserId),
  898. CreateTime: time.Now(),
  899. })
  900. continue
  901. }
  902. }
  903. }
  904. resourceItem := knowledge.ResourceImportData{
  905. Title: title,
  906. StartDate: startDate,
  907. Content: content,
  908. Tag: tag,
  909. SourceFrom: sourceFrom,
  910. ClassifyFirstName: classifyName1,
  911. ClassifySecondName: classifyName2,
  912. ClassifyThirdName: classifyName3,
  913. }
  914. indexDataList = append(indexDataList, resourceItem)
  915. }
  916. return
  917. }
  918. func getExcelDate(createDate string) (newCreateDate string, err error) {
  919. if strings.Contains(createDate, "-") {
  920. //如果是带有 - 的普通日期格式文本
  921. _, err = time.Parse("2006-1-2", createDate)
  922. if err == nil {
  923. newCreateDate = createDate
  924. }
  925. } else if strings.Contains(createDate, "/") {
  926. //如果是带有 / 的普通日期格式文本
  927. createDateTime, timeErr := time.Parse("2006/1/2", createDate)
  928. if timeErr != nil {
  929. err = timeErr
  930. } else {
  931. newCreateDate = createDateTime.Format("2006-01-02")
  932. }
  933. } else {
  934. //可能是excel的日期格式
  935. _, tmpErr := strconv.Atoi(createDate)
  936. if tmpErr != nil {
  937. err = tmpErr
  938. } else {
  939. newCreateDate = utils.ConvertToFormatDay(createDate) //录入日期
  940. }
  941. }
  942. return
  943. }
  944. func addExcelResource(req *knowledge.AddReq, sysUser *system.Admin) (err error, errMsg string) {
  945. var startTime time.Time
  946. var endTime time.Time
  947. if req.StartTime != "" {
  948. if req.ResourceType == knowledge.KnowledgeResourceTypeEvent || req.ResourceType == knowledge.KnowledgeResourceTypePolicy {
  949. startTime, err = time.ParseInLocation(utils.FormatDateTime, req.StartTime, time.Local)
  950. if err != nil { // 如果时间格式不正确,则返回错误信息
  951. errMsg = "开始时间格式不正确"
  952. err = fmt.Errorf("开始时间格式不正确,Err:" + err.Error())
  953. return
  954. }
  955. } else {
  956. startTime, err = time.ParseInLocation(utils.FormatDate, req.StartTime, time.Local)
  957. if err != nil { // 如果时间格式不正确,则返回错误信息
  958. errMsg = "开始时间格式不正确"
  959. err = fmt.Errorf("开始时间格式不正确,Err:" + err.Error())
  960. return
  961. }
  962. }
  963. }
  964. if req.EndTime != "" {
  965. if req.ResourceType == knowledge.KnowledgeResourceTypeEvent || req.ResourceType == knowledge.KnowledgeResourceTypePolicy {
  966. endTime, err = time.ParseInLocation(utils.FormatDateTime, req.EndTime, time.Local)
  967. if err != nil { // 如果时间格式不正确,则返回错误信息
  968. errMsg = "结束时间格式不正确"
  969. err = fmt.Errorf("结束时间格式不正确,Err:" + err.Error())
  970. return
  971. }
  972. }
  973. }
  974. item := new(knowledge.KnowledgeResource)
  975. item.ClassifyId = req.ClassifyId
  976. item.TagId = req.TagId
  977. item.SourceFrom = req.SourceFrom
  978. item.ResourceType = req.ResourceType
  979. item.Title = req.Title
  980. item.State = knowledge.KnowledgeResourceStateUnpublished
  981. item.Content = html.EscapeString(req.Content)
  982. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  983. item.ResourceCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp)
  984. //todo 内容前5行
  985. //item.ContentSub = html.EscapeString(contentSub)
  986. if !startTime.IsZero() {
  987. item.StartTime = &startTime
  988. }
  989. if !endTime.IsZero() {
  990. item.EndTime = &endTime
  991. }
  992. item.ModifyTime = time.Now()
  993. item.AdminId = sysUser.AdminId
  994. item.AdminRealName = sysUser.RealName
  995. //item.LastModifyAdminId = sysUser.AdminId
  996. //item.LastModifyAdminName = sysUser.RealName
  997. item.ModifyTime = time.Now()
  998. item.CreateTime = time.Now()
  999. err = item.Add(item)
  1000. if err != nil {
  1001. errMsg = "保存失败"
  1002. err = fmt.Errorf("保存失败,Err:" + err.Error())
  1003. return
  1004. }
  1005. //todo 是否需要保存到es中
  1006. return
  1007. }
  1008. func SetKnowledgeResourcePublic(knowledgeId int) (errMsg string, err error) {
  1009. obj := new(knowledge.KnowledgeResource)
  1010. obj, err = obj.GetById(knowledgeId)
  1011. if err != nil {
  1012. if utils.IsErrNoRow(err) {
  1013. errMsg = "资源不存在"
  1014. return
  1015. }
  1016. errMsg = "获取资源失败"
  1017. err = fmt.Errorf("获取资源失败,Err:%v", err.Error())
  1018. return
  1019. }
  1020. if !(obj.State == knowledge.KnowledgeResourceStateUnpublished || obj.State == knowledge.KnowledgeResourceStateRejected) {
  1021. errMsg = "不能重复设置公共"
  1022. err = fmt.Errorf("不能重复设置公共")
  1023. return
  1024. }
  1025. if obj.ResourceType != knowledge.KnowledgeResourceTypeOpinion {
  1026. errMsg = "非法操作"
  1027. err = fmt.Errorf("非法操作")
  1028. return
  1029. }
  1030. ok, err := knowledge_approve.CheckKnowledgeOpenApprove(obj.ClassifyId)
  1031. if err != nil {
  1032. errMsg = "分类校验失败"
  1033. err = fmt.Errorf("分类校验失败,Err:%v", err)
  1034. return
  1035. }
  1036. if !ok {
  1037. errMsg = "分类未开启审批流"
  1038. err = fmt.Errorf("分类未开启审批流")
  1039. return
  1040. }
  1041. obj.State = knowledge.KnowledgeResourceStatePending
  1042. obj.ModifyTime = time.Now()
  1043. err = obj.Update([]string{"state", "modify_time"})
  1044. if err != nil {
  1045. errMsg = "设置失败"
  1046. err = fmt.Errorf("设置失败,Err:" + err.Error())
  1047. return
  1048. }
  1049. return
  1050. }