resource.go 29 KB

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