VerifyTemplate.go 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029
  1. package controllers
  2. import (
  3. "ColdVerify_server/conf"
  4. "ColdVerify_server/lib"
  5. "ColdVerify_server/logs"
  6. "ColdVerify_server/models/Account"
  7. "ColdVerify_server/models/Distributor"
  8. "ColdVerify_server/models/System"
  9. "ColdVerify_server/models/Task"
  10. "ColdVerify_server/models/VerifyTemplate"
  11. "encoding/json"
  12. "errors"
  13. "fmt"
  14. "math"
  15. "os"
  16. "sort"
  17. "strconv"
  18. "strings"
  19. "time"
  20. beego "github.com/beego/beego/v2/server/web"
  21. "github.com/xuri/excelize/v2"
  22. )
  23. type VerifyTemplateController struct {
  24. beego.Controller
  25. User_r Account.Admin // 登陆的用户
  26. }
  27. func (c *VerifyTemplateController) Prepare() {
  28. GetCookie := c.Ctx.GetCookie("User_tokey")
  29. GetString := c.GetString("User_tokey")
  30. fmt.Println(c.Ctx.Request.URL.Path)
  31. if strings.Contains(c.Ctx.Request.URL.Path, "/VerifyTemplateMapData/Pu") ||
  32. strings.Contains(c.Ctx.Request.URL.Path, "/VerifyTemplateMapData/Batch_Update") {
  33. return
  34. }
  35. // 验证登录 User_is, User_r
  36. User_r, User_is := Account.Verification_Admin(GetCookie, GetString)
  37. if !User_is {
  38. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  39. c.ServeJSON()
  40. return
  41. }
  42. // 经销商只能访问列表接口,不能操作
  43. //if len(User_r.T_Distributor_id) > 0 {
  44. // checkUrl := []string{"Add", "Up", "Del"}
  45. // for _, v := range checkUrl {
  46. // if strings.Contains(c.Ctx.Request.URL.Path, v) {
  47. // c.Data["json"] = lib.JSONS{Code: 202, Msg: "没有操作权限!"}
  48. // c.ServeJSON()
  49. // return
  50. // }
  51. // }
  52. //}
  53. c.User_r = User_r
  54. }
  55. // 列表 -
  56. func (c *VerifyTemplateController) List() {
  57. // 验证登录 User_is, User_r
  58. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  59. if !User_is {
  60. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  61. c.ServeJSON()
  62. return
  63. }
  64. var r_jsons lib.R_JSONS
  65. page, _ := c.GetInt("page")
  66. if page < 1 {
  67. page = 1
  68. }
  69. page_z, _ := c.GetInt("page_z")
  70. if page_z < 1 {
  71. page_z = conf.Page_size
  72. }
  73. T_class, _ := c.GetInt("T_class")
  74. if T_class <= 0 {
  75. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_class Err!"}
  76. c.ServeJSON()
  77. return
  78. }
  79. T_name := c.GetString("T_name")
  80. logs.Debug("经销商id", User_r.T_Distributor_id)
  81. if len(User_r.T_Distributor_id) > 0 {
  82. var cnt int64
  83. List, cnt := Distributor.Read_DistributorVerifyTemplate_List(User_r.T_Distributor_id, T_class, T_name, page, page_z)
  84. page_size := math.Ceil(float64(cnt) / float64(page_z))
  85. r_jsons.List = List
  86. r_jsons.Page = page
  87. r_jsons.Page_size = int(page_size)
  88. r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
  89. r_jsons.Num = int(cnt)
  90. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  91. c.ServeJSON()
  92. return
  93. }
  94. var cnt int64
  95. List, cnt := VerifyTemplate.Read_VerifyTemplate_List(T_class, T_name, page, page_z)
  96. page_size := math.Ceil(float64(cnt) / float64(page_z))
  97. r_jsons.List = List
  98. r_jsons.Page = page
  99. r_jsons.Page_size = int(page_size)
  100. r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
  101. r_jsons.Num = int(cnt)
  102. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  103. c.ServeJSON()
  104. return
  105. }
  106. // 添加-
  107. func (c *VerifyTemplateController) Add() {
  108. // 验证登录 User_is, User_r
  109. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  110. if !User_is {
  111. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  112. c.ServeJSON()
  113. return
  114. }
  115. T_name := c.GetString("T_name")
  116. T_sort, _ := c.GetInt("T_sort")
  117. T_class, _ := c.GetInt("T_class")
  118. var_ := VerifyTemplate.VerifyTemplate{
  119. T_class: T_class,
  120. T_name: T_name,
  121. T_sort: T_sort,
  122. }
  123. Id, is := VerifyTemplate.Add_VerifyTemplate(var_)
  124. if !is {
  125. c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
  126. c.ServeJSON()
  127. return
  128. }
  129. System.Add_UserLogs_T(User_r.T_uuid, "验证模版", "添加", var_)
  130. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
  131. c.ServeJSON()
  132. return
  133. }
  134. // 修改-
  135. func (c *VerifyTemplateController) Up() {
  136. // 验证登录 User_is, User_r
  137. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  138. if !User_is {
  139. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  140. c.ServeJSON()
  141. return
  142. }
  143. T_name := c.GetString("T_name")
  144. T_sort, T_sort_err := c.GetInt("T_sort")
  145. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  146. T_scheme := c.GetString("T_scheme")
  147. T_reporting := c.GetString("T_reporting")
  148. T_inspect := c.GetString("T_inspect")
  149. T_marking := c.GetString("T_marking")
  150. T_cover := c.GetString("T_cover")
  151. T_deploy := c.GetString("T_deploy")
  152. T_examining_report := c.GetString("T_examining_report")
  153. T_original_record := c.GetString("T_original_record")
  154. r, is := VerifyTemplate.Read_VerifyTemplate(T_VerifyTemplate_id)
  155. if !is {
  156. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
  157. c.ServeJSON()
  158. return
  159. }
  160. // .......
  161. if len(T_name) > 0 {
  162. r.T_name = T_name
  163. }
  164. if len(T_scheme) > 0 {
  165. r.T_scheme = T_scheme
  166. }
  167. if len(T_reporting) > 0 {
  168. r.T_reporting = T_reporting
  169. }
  170. if len(T_inspect) > 0 {
  171. r.T_inspect = T_inspect
  172. }
  173. if len(T_marking) > 0 {
  174. r.T_marking = T_marking
  175. }
  176. if len(T_cover) > 0 {
  177. r.T_cover = T_cover
  178. }
  179. if len(T_examining_report) > 0 {
  180. r.T_examining_report = T_examining_report
  181. }
  182. if len(T_original_record) > 0 {
  183. r.T_original_record = T_original_record
  184. }
  185. if len(T_deploy) > 0 {
  186. var deployList []VerifyTemplate.VerifyTemplateDeploy
  187. // 将 布点1|布点2|布点3| 格式替换为 [{"T_name":"布点1","T_scope":"布点范围1"},{"T_name":"布点2","T_scope":"布点范围2"}]
  188. if strings.Contains(T_deploy, "|") {
  189. deploys := strings.Split(strings.Trim(T_deploy, "|"), "|")
  190. for _, v := range deploys {
  191. deployList = append(deployList, VerifyTemplate.VerifyTemplateDeploy{T_name: v})
  192. }
  193. deploy, err := json.Marshal(deployList)
  194. if err != nil {
  195. logs.Error("JSON 序列化失败:", err)
  196. return
  197. }
  198. T_deploy = string(deploy)
  199. } else {
  200. err := json.Unmarshal([]byte(T_deploy), &deployList)
  201. if err != nil {
  202. logs.Error("JSON 反序列化失败:", err)
  203. return
  204. }
  205. }
  206. r.T_deploy = T_deploy
  207. }
  208. if T_sort_err == nil {
  209. r.T_sort = T_sort
  210. }
  211. // .......
  212. if !VerifyTemplate.Update_VerifyTemplate(r, "T_name", "T_sort", "T_scheme", "T_reporting", "T_inspect", "T_marking", "T_cover", "T_deploy", "T_examining_report", "T_original_record") {
  213. c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
  214. c.ServeJSON()
  215. return
  216. }
  217. System.Add_UserLogs_T(User_r.T_uuid, "验证模版", "修改", r)
  218. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  219. c.ServeJSON()
  220. return
  221. }
  222. // 删除-
  223. func (c *VerifyTemplateController) Del() {
  224. // 验证登录 User_is, User_r
  225. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  226. if !User_is {
  227. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  228. c.ServeJSON()
  229. return
  230. }
  231. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  232. r, is := VerifyTemplate.Read_VerifyTemplate(T_VerifyTemplate_id)
  233. if !is {
  234. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
  235. c.ServeJSON()
  236. return
  237. }
  238. if !VerifyTemplate.Delete_VerifyTemplate(r) {
  239. c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
  240. c.ServeJSON()
  241. return
  242. }
  243. mapList, _ := VerifyTemplate.Read_VerifyTemplateMap_List(T_VerifyTemplate_id, 0, 0)
  244. for _, v := range mapList {
  245. if vtm, is := VerifyTemplate.Read_VerifyTemplateMap(v.T_id); is {
  246. VerifyTemplate.Delete_VerifyTemplateMap(vtm)
  247. }
  248. }
  249. System.Add_UserLogs_T(User_r.T_uuid, "验证模版", "删除", r)
  250. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  251. c.ServeJSON()
  252. return
  253. }
  254. // 删除-
  255. func (c *VerifyTemplateController) Get() {
  256. // 验证登录 User_is, User_r
  257. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  258. if !User_is {
  259. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  260. c.ServeJSON()
  261. return
  262. }
  263. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  264. r, is := VerifyTemplate.Read_VerifyTemplate(T_VerifyTemplate_id)
  265. if !is {
  266. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
  267. c.ServeJSON()
  268. return
  269. }
  270. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: VerifyTemplate.VerifyTemplateToVerifyTemplate_R(r)}
  271. c.ServeJSON()
  272. return
  273. }
  274. // 复制-
  275. func (c *VerifyTemplateController) Copy() {
  276. // 验证登录 User_is, User_r
  277. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  278. if !User_is {
  279. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  280. c.ServeJSON()
  281. return
  282. }
  283. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  284. T_name := c.GetString("T_name")
  285. r, is := VerifyTemplate.Read_VerifyTemplate(T_VerifyTemplate_id)
  286. if !is {
  287. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
  288. c.ServeJSON()
  289. return
  290. }
  291. var_ := VerifyTemplate.VerifyTemplate{
  292. T_class: r.T_class,
  293. T_name: T_name,
  294. T_sort: r.T_sort,
  295. T_deploy: r.T_deploy,
  296. }
  297. new_id, is := VerifyTemplate.Add_VerifyTemplate(var_)
  298. if !is {
  299. c.Data["json"] = lib.JSONS{Code: 202, Msg: "复制失败!"}
  300. c.ServeJSON()
  301. return
  302. }
  303. mapList, _ := VerifyTemplate.Read_VerifyTemplateMap_List(T_VerifyTemplate_id, 0, 0)
  304. tempMap := make(map[string]struct{})
  305. idList := make([]string, len(mapList))
  306. // 生成mapList长度的T_id
  307. for i := 0; i < len(mapList); i++ {
  308. // 生成编号
  309. rand_x := 0
  310. T_id := ""
  311. for true {
  312. T_id = lib.GetRandstring(4, "", int64(rand_x))
  313. _, is = VerifyTemplate.Read_VerifyTemplateMap(T_id)
  314. if !is {
  315. if _, ok := tempMap[T_id]; !ok {
  316. break
  317. }
  318. }
  319. rand_x += 1
  320. }
  321. tempMap[T_id] = struct{}{}
  322. idList[i] = T_id
  323. }
  324. mapInsertList := make([]VerifyTemplate.VerifyTemplateMap, 0)
  325. for i, v := range mapList {
  326. vtm := VerifyTemplate.VerifyTemplateMap{
  327. T_id: idList[i],
  328. T_VerifyTemplate_id: new_id,
  329. T_name: v.T_name,
  330. T_text: v.T_text,
  331. T_label: v.T_label,
  332. T_source: v.T_source,
  333. T_sort: v.T_sort,
  334. T_Required: v.T_Required,
  335. T_Construction: v.T_Construction,
  336. T_flow_sort: v.T_flow_sort,
  337. T_max_time: v.T_max_time,
  338. T_min_time: v.T_min_time,
  339. }
  340. mapInsertList = append(mapInsertList, vtm)
  341. }
  342. _, is = VerifyTemplate.Add_VerifyTemplateMapMulti(mapInsertList)
  343. if !is {
  344. c.Data["json"] = lib.JSONS{Code: 202, Msg: "复制失败!"}
  345. c.ServeJSON()
  346. return
  347. }
  348. System.Add_UserLogs_T(User_r.T_uuid, "验证模版", "复制", var_)
  349. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: new_id}
  350. c.ServeJSON()
  351. return
  352. }
  353. /// -----------------------------------------------------------------------------
  354. // 标签列表 -
  355. func (c *VerifyTemplateController) Map_List() {
  356. // 验证登录 User_is, User_r
  357. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  358. if !User_is {
  359. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  360. c.ServeJSON()
  361. return
  362. }
  363. var r_jsons lib.R_JSONS
  364. // page, _ := c.GetInt("page")
  365. //
  366. // if page < 1 {
  367. // page = 1
  368. // }
  369. //
  370. // page_z, _ := c.GetInt("page_z")
  371. //
  372. // if page_z < 1 {
  373. // page_z = conf.Page_size
  374. // }
  375. T_sort, _ := c.GetInt("T_sort") // 排序
  376. T_flow_sort, _ := c.GetInt("T_flow_sort") // 验证流程排序
  377. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  378. var cnt int64
  379. List, cnt := VerifyTemplate.Read_VerifyTemplateMap_List(T_VerifyTemplate_id, T_sort, T_flow_sort)
  380. r_jsons.List = List
  381. r_jsons.Num = int(cnt)
  382. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  383. c.ServeJSON()
  384. return
  385. }
  386. // 多任务获取标签列表 -
  387. func (c *VerifyTemplateController) Map_List_By_TaskIds() {
  388. // 验证登录
  389. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  390. if !User_is {
  391. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  392. c.ServeJSON()
  393. return
  394. }
  395. type requestBody struct {
  396. TaskIds []string `json:"task_ids"`
  397. }
  398. var body requestBody
  399. taskIdsParam := c.GetString("task_ids")
  400. if len(taskIdsParam) > 0 {
  401. body.TaskIds = lib.SplitStringSeparator(taskIdsParam, ",")
  402. }
  403. T_source, _ := c.GetInt("T_source")
  404. if len(body.TaskIds) == 0 {
  405. c.Data["json"] = lib.JSONS{Code: 202, Msg: "任务id不能为空!"}
  406. c.ServeJSON()
  407. return
  408. }
  409. if T_source == 0 {
  410. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  411. c.ServeJSON()
  412. return
  413. }
  414. cleanTaskIds := make([]string, 0, len(body.TaskIds))
  415. seenTaskIds := make(map[string]struct{}, len(body.TaskIds))
  416. for _, id := range body.TaskIds {
  417. id = strings.TrimSpace(id)
  418. if len(id) == 0 {
  419. continue
  420. }
  421. if _, ok := seenTaskIds[id]; ok {
  422. continue
  423. }
  424. seenTaskIds[id] = struct{}{}
  425. cleanTaskIds = append(cleanTaskIds, id)
  426. }
  427. if len(cleanTaskIds) == 0 {
  428. c.Data["json"] = lib.JSONS{Code: 202, Msg: "有效任务id不能为空!"}
  429. c.ServeJSON()
  430. return
  431. }
  432. tasks, err := Task.Read_Task_List_By_TaskIds(cleanTaskIds)
  433. if err != nil {
  434. c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询任务失败!"}
  435. c.ServeJSON()
  436. return
  437. }
  438. if len(tasks) == 0 {
  439. c.Data["json"] = lib.JSONS{Code: 202, Msg: "未查询到任务!"}
  440. c.ServeJSON()
  441. return
  442. }
  443. foundTaskIds := make(map[string]struct{}, len(tasks))
  444. templateIdList := make([]string, 0)
  445. templateIdSet := make(map[string]struct{})
  446. for _, task := range tasks {
  447. foundTaskIds[task.T_task_id] = struct{}{}
  448. if len(task.T_VerifyTemplate_id) == 0 {
  449. continue
  450. }
  451. if _, ok := templateIdSet[task.T_VerifyTemplate_id]; ok {
  452. continue
  453. }
  454. templateIdSet[task.T_VerifyTemplate_id] = struct{}{}
  455. templateIdList = append(templateIdList, task.T_VerifyTemplate_id)
  456. }
  457. missingTaskIds := make([]string, 0)
  458. for _, id := range cleanTaskIds {
  459. if _, ok := foundTaskIds[id]; !ok {
  460. missingTaskIds = append(missingTaskIds, id)
  461. }
  462. }
  463. if len(missingTaskIds) > 0 {
  464. c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("任务不存在: %s", strings.Join(missingTaskIds, ","))}
  465. c.ServeJSON()
  466. return
  467. }
  468. if len(templateIdList) == 0 {
  469. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: []interface{}{}}
  470. c.ServeJSON()
  471. return
  472. }
  473. type templateTag struct {
  474. VerifyTemplate.VerifyTemplateMap_R
  475. T_value string `json:"T_value"`
  476. T_VerifyTemplate_id string `json:"T_VerifyTemplate_id"`
  477. }
  478. tagMap := make(map[string]templateTag)
  479. for _, templateId := range templateIdList {
  480. tagList := VerifyTemplate.Read_VerifyTemplateMap_List_For_Data(templateId, T_source, 0)
  481. for _, tag := range tagList {
  482. if tag.T_label == 3 || tag.T_label == 4 {
  483. continue
  484. }
  485. if len(tag.T_id) == 0 {
  486. continue
  487. }
  488. if _, ok := tagMap[tag.T_id]; ok {
  489. continue
  490. }
  491. tagMap[tag.T_id] = templateTag{
  492. VerifyTemplateMap_R: VerifyTemplate.VerifyTemplateMapToVerifyTemplateMap_R(tag),
  493. T_VerifyTemplate_id: templateId,
  494. }
  495. }
  496. }
  497. if len(tagMap) == 0 {
  498. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: []interface{}{}}
  499. c.ServeJSON()
  500. return
  501. }
  502. tagIds := make([]string, 0, len(tagMap))
  503. for id := range tagMap {
  504. tagIds = append(tagIds, id)
  505. }
  506. sort.Strings(tagIds)
  507. result := make([]templateTag, 0, len(tagIds))
  508. for _, id := range tagIds {
  509. result = append(result, tagMap[id])
  510. }
  511. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: result}
  512. c.ServeJSON()
  513. }
  514. // 标签添加-
  515. func (c *VerifyTemplateController) Map_Add() {
  516. // 验证登录 User_is, User_r
  517. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  518. if !User_is {
  519. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  520. c.ServeJSON()
  521. return
  522. }
  523. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  524. T_name := c.GetString("T_name")
  525. T_text := c.GetString("T_text")
  526. T_label, _ := c.GetInt("T_label")
  527. T_source, _ := c.GetInt("T_source")
  528. T_sort, _ := c.GetInt("T_sort")
  529. T_Required, _ := c.GetInt("T_Required")
  530. T_Construction, _ := c.GetInt("T_Construction")
  531. T_flow_sort, _ := c.GetInt("T_flow_sort")
  532. T_max_time, _ := c.GetInt("T_max_time")
  533. T_min_time, _ := c.GetInt("T_min_time")
  534. var_ := VerifyTemplate.VerifyTemplateMap{
  535. T_VerifyTemplate_id: T_VerifyTemplate_id,
  536. T_name: T_name,
  537. T_text: T_text,
  538. T_label: T_label,
  539. T_source: T_source,
  540. T_sort: T_sort,
  541. T_Required: T_Required,
  542. T_Construction: T_Construction,
  543. T_flow_sort: T_flow_sort,
  544. T_max_time: T_max_time,
  545. T_min_time: T_min_time,
  546. }
  547. Id, is := VerifyTemplate.Add_VerifyTemplateMap(var_)
  548. if !is {
  549. c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
  550. c.ServeJSON()
  551. return
  552. }
  553. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签", "添加", var_)
  554. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
  555. c.ServeJSON()
  556. return
  557. }
  558. // 标签修改-
  559. func (c *VerifyTemplateController) Map_Up() {
  560. // 验证登录 User_is, User_r
  561. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  562. if !User_is {
  563. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  564. c.ServeJSON()
  565. return
  566. }
  567. T_name := c.GetString("T_name")
  568. T_text := c.GetString("T_text")
  569. T_label, T_label_err := c.GetInt("T_label")
  570. T_sort, T_sort_err := c.GetInt("T_sort")
  571. T_source, T_source_err := c.GetInt("T_source")
  572. T_Required, _ := c.GetInt("T_Required")
  573. T_Construction, _ := c.GetInt("T_Construction")
  574. T_min_time, T_min_time_err := c.GetInt("T_min_time")
  575. T_max_time, T_max_time_err := c.GetInt("T_max_time")
  576. T_flow_sort, T_flow_sort_err := c.GetInt("T_flow_sort")
  577. T_id := c.GetString("T_id")
  578. r, is := VerifyTemplate.Read_VerifyTemplateMap(T_id)
  579. if !is {
  580. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
  581. c.ServeJSON()
  582. return
  583. }
  584. // .......
  585. if len(T_name) > 0 {
  586. r.T_name = T_name
  587. }
  588. if len(T_text) > 0 {
  589. r.T_text = T_text
  590. }
  591. if T_label_err == nil {
  592. r.T_label = T_label
  593. }
  594. if T_sort_err == nil {
  595. r.T_sort = T_sort
  596. }
  597. if T_source_err == nil {
  598. r.T_source = T_source
  599. }
  600. if T_min_time_err == nil {
  601. r.T_min_time = T_min_time
  602. }
  603. if T_max_time_err == nil {
  604. r.T_max_time = T_max_time
  605. }
  606. if T_flow_sort_err == nil {
  607. r.T_flow_sort = T_flow_sort
  608. }
  609. r.T_Required = T_Required
  610. r.T_Construction = T_Construction
  611. if !VerifyTemplate.Update_VerifyTemplateMap(r, "T_name", "T_label", "T_text", "T_sort", "T_source", "T_min_time", "T_max_time", "T_flow_sort", "T_Required", "T_Construction") {
  612. c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
  613. c.ServeJSON()
  614. return
  615. }
  616. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签", "修改", r)
  617. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  618. c.ServeJSON()
  619. return
  620. }
  621. // 标签删除-
  622. func (c *VerifyTemplateController) Map_Del() {
  623. // 验证登录 User_is, User_r
  624. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  625. if !User_is {
  626. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  627. c.ServeJSON()
  628. return
  629. }
  630. T_id := c.GetString("T_id")
  631. if r, is := VerifyTemplate.Read_VerifyTemplateMap(T_id); is {
  632. if !VerifyTemplate.Delete_VerifyTemplateMap(r) {
  633. c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
  634. c.ServeJSON()
  635. return
  636. }
  637. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签", "删除", r)
  638. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  639. c.ServeJSON()
  640. return
  641. }
  642. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
  643. c.ServeJSON()
  644. return
  645. }
  646. /// -----------------------------------------------------------------------------
  647. // 标签数据列表 -
  648. func (c *VerifyTemplateController) Map_Data_List() {
  649. // 验证登录 User_is, User_r
  650. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  651. if !User_is {
  652. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  653. c.ServeJSON()
  654. return
  655. }
  656. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  657. T_source, _ := c.GetInt("T_source")
  658. T_flow, _ := c.GetInt("T_flow") // app 时间流程
  659. if T_flow == 0 && T_source == 0 {
  660. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  661. c.ServeJSON()
  662. return
  663. }
  664. T_task_id := c.GetString("T_task_id")
  665. task, is := Task.Read_Task(T_task_id)
  666. if !is {
  667. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  668. c.ServeJSON()
  669. return
  670. }
  671. Map_List := VerifyTemplate.Read_VerifyTemplateMap_List_For_Data(T_VerifyTemplate_id, T_source, T_flow)
  672. Data := VerifyTemplate.Read_VerifyTemplateMapData_List(T_source, T_task_id, T_VerifyTemplate_id, Map_List)
  673. type JSONS struct {
  674. //必须的大写开头
  675. Code int16
  676. Msg string
  677. Data interface{} // 泛型
  678. T_step int
  679. }
  680. c.Data["json"] = JSONS{Code: 200, Msg: "ok!", Data: Data, T_step: task.T_step}
  681. c.ServeJSON()
  682. return
  683. }
  684. // 添加标签数据
  685. func (c *VerifyTemplateController) Map_Data_Pu() {
  686. var err error
  687. type RequestBody struct {
  688. User_tokey string
  689. T_source int
  690. T_task_id string
  691. T_VerifyTemplate_id string
  692. T_step int // 进行步骤下标
  693. T_submit int // 1-app 2-报告生成
  694. T_history int // 0不保存历史 1保存历史
  695. VerifyTemplateMapData []VerifyTemplate.VerifyTemplateMapData_R
  696. }
  697. var body RequestBody
  698. data := c.Ctx.Input.RequestBody
  699. err = json.Unmarshal(data, &body)
  700. if err != nil {
  701. c.Data["json"] = lib.JSONS{Code: 202, Msg: "json返序列化失败:" + err.Error()}
  702. c.ServeJSON()
  703. }
  704. logs.Println(fmt.Sprintf("%+v", body))
  705. User_r, User_is := Account.Verification_Admin(body.User_tokey, "")
  706. if !User_is {
  707. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "未登录-保存", body)
  708. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  709. c.ServeJSON()
  710. return
  711. }
  712. task, is := Task.Read_Task(body.T_task_id)
  713. if !is {
  714. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  715. c.ServeJSON()
  716. return
  717. }
  718. T_reporting_state := task.T_reporting_state
  719. task.T_step = body.T_step
  720. // 点击报告生成时保存
  721. if body.T_submit == 2 && T_reporting_state == 0 {
  722. task.T_reporting_state = Task.TaskExaminingReportStateClickGenerate
  723. }
  724. // app 提交
  725. if body.T_submit == 1 && task.T_collection_state == Task.TaskCollectionStateWaitSubmit {
  726. // 手机app提交修改采集状态为已提交
  727. task.T_collection_state = Task.TaskCollectionStateSubmitted
  728. task.T_collection_submit_time = time.Now().Format("2006-01-02 15:04:05")
  729. }
  730. if !Task.Update_Task(task, "T_step", "T_reporting_state", "T_collection_state", "T_collection_submit_time") {
  731. c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改任务步骤失败!"}
  732. c.ServeJSON()
  733. return
  734. }
  735. // 判断旧的模版id与任务id的模版是否一致,如果不一致则复制旧模板数据到新模板
  736. if task.T_VerifyTemplate_id != body.T_VerifyTemplate_id {
  737. copy_task := task
  738. copy_task.T_VerifyTemplate_id = body.T_VerifyTemplate_id
  739. _, err = CopyMapData(copy_task, task, 0)
  740. if err != nil {
  741. logs.Error("复制旧模板数据到新模板失败", err)
  742. }
  743. }
  744. MapDataList := make([]VerifyTemplate.VerifyTemplateMapData, 0)
  745. for _, v := range body.VerifyTemplateMapData {
  746. val := VerifyTemplate.VerifyTemplateMapData{
  747. T_source: v.T_source,
  748. T_task_id: body.T_task_id,
  749. T_VerifyTemplate_id: body.T_VerifyTemplate_id,
  750. T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,
  751. T_Required: v.T_Required,
  752. T_Construction: v.T_Construction,
  753. T_flow_sort: v.T_flow_sort,
  754. T_max_time: v.T_max_time,
  755. T_min_time: v.T_min_time,
  756. T_value: v.T_value,
  757. T_start_time: v.T_start_time,
  758. }
  759. MapDataList = append(MapDataList, val)
  760. if v.T_label == 16 && len(v.T_value) > 0 {
  761. // 判断验证模版标签-描述是否存在该值,不存在则添加
  762. verifyTemplateMap, exist := VerifyTemplate.Read_VerifyTemplateMap(v.T_VerifyTemplateMap_id)
  763. if exist {
  764. // 用|分割成列表
  765. options := lib.SplitStringSeparator(verifyTemplateMap.T_text, "|")
  766. // 检查是否存在
  767. found := false
  768. for _, opt := range options {
  769. if opt == v.T_value {
  770. found = true
  771. break
  772. }
  773. }
  774. if !found {
  775. verifyTemplateMap.T_text = verifyTemplateMap.T_text + "|" + v.T_value
  776. VerifyTemplate.Update_VerifyTemplateMap(verifyTemplateMap, "T_text")
  777. }
  778. }
  779. }
  780. }
  781. var T_cover int
  782. if body.T_submit == 1 && T_reporting_state > 0 {
  783. T_cover = 1
  784. }
  785. ids, is := VerifyTemplate.AddOrUpdate_VerifyTemplateMapData_ADD_History(MapDataList, body.T_source, User_r.T_uuid, body.T_submit, T_cover, body.T_history)
  786. if !is {
  787. c.Data["json"] = lib.JSONS{Code: 202, Msg: "保存失败"}
  788. c.ServeJSON()
  789. return
  790. }
  791. // 手机app提交,发送消息通知
  792. if body.T_submit == 1 {
  793. _, company_r := Account.Read_User_ByT_uuid(task.T_uuid)
  794. _, admin_r := Account.Read_Admin_ByT_uuid(task.T_collection)
  795. System.Add_App_News(task.T_reporting, fmt.Sprintf("【%s-%s】数据采集工程师 %s 已提交", company_r.T_name, task.T_name, admin_r.T_name), "")
  796. }
  797. // 报告生成,备份数据
  798. if body.T_submit == 2 {
  799. var_ := Task.TaskCopy{
  800. T_task_id: task.T_task_id,
  801. T_time: "报告生成数据",
  802. T_State: 2,
  803. }
  804. T_copy_id, is2 := Task.Add_TaskCopy(var_)
  805. if !is2 {
  806. c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
  807. c.ServeJSON()
  808. return
  809. }
  810. // 创建数据表
  811. Task.CREATE_TaskDataCopy("default", T_copy_id)
  812. // 将数据表存档
  813. Task.TaskData_Arhiving(task.T_task_id, T_copy_id)
  814. }
  815. VerifyTemplate.Check_RequiredFields_HaveValue(body.T_task_id)
  816. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "保存", body)
  817. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: ids}
  818. c.ServeJSON()
  819. return
  820. }
  821. // 批量修改多个任务的标签数据
  822. func (c *VerifyTemplateController) Map_Data_Batch_Update() {
  823. var err error
  824. type VerifyTemplateMapData_R struct {
  825. T_id string
  826. T_VerifyTemplateMap_id string // 标签id
  827. T_source int
  828. T_label int //
  829. T_name string // 标题
  830. T_value string //
  831. T_Required int //
  832. T_Construction int //
  833. // 验证流程
  834. T_flow_sort int // 验证流程排序
  835. T_max_time int // 验证流程最大时间
  836. T_min_time int // 验证流程最小时间
  837. }
  838. type RequestBody struct {
  839. User_tokey string
  840. T_source int
  841. T_task_ids []string // 多个任务ID
  842. VerifyTemplateMapData []VerifyTemplateMapData_R
  843. }
  844. var body RequestBody
  845. data := c.Ctx.Input.RequestBody
  846. err = json.Unmarshal(data, &body)
  847. if err != nil {
  848. c.Data["json"] = lib.JSONS{Code: 202, Msg: "json返序列化失败:" + err.Error()}
  849. c.ServeJSON()
  850. return
  851. }
  852. logs.Println(fmt.Sprintf("%+v", body))
  853. User_r, User_is := Account.Verification_Admin(body.User_tokey, "")
  854. if !User_is {
  855. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "未登录-批量修改", body)
  856. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  857. c.ServeJSON()
  858. return
  859. }
  860. // 验证任务ID列表
  861. if len(body.T_task_ids) == 0 {
  862. c.Data["json"] = lib.JSONS{Code: 202, Msg: "任务ID列表不能为空!"}
  863. c.ServeJSON()
  864. return
  865. }
  866. // 验证标签数据
  867. if len(body.VerifyTemplateMapData) == 0 {
  868. c.Data["json"] = lib.JSONS{Code: 202, Msg: "标签数据不能为空!"}
  869. c.ServeJSON()
  870. return
  871. }
  872. // 验证所有任务是否存在
  873. tasks, err := Task.Read_Task_List_By_TaskIds(body.T_task_ids)
  874. if err != nil {
  875. c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询任务失败:" + err.Error()}
  876. c.ServeJSON()
  877. return
  878. }
  879. if len(tasks) == 0 {
  880. c.Data["json"] = lib.JSONS{Code: 202, Msg: "未找到任何任务!"}
  881. c.ServeJSON()
  882. return
  883. }
  884. // 检查是否有任务不存在
  885. foundTaskIds := make(map[string]bool)
  886. for _, task := range tasks {
  887. foundTaskIds[task.T_task_id] = true
  888. }
  889. missingTaskIds := make([]string, 0)
  890. for _, taskId := range body.T_task_ids {
  891. if !foundTaskIds[taskId] {
  892. missingTaskIds = append(missingTaskIds, taskId)
  893. }
  894. }
  895. if len(missingTaskIds) > 0 {
  896. c.Data["json"] = lib.JSONS{Code: 202, Msg: fmt.Sprintf("以下任务不存在: %s", strings.Join(missingTaskIds, ","))}
  897. c.ServeJSON()
  898. return
  899. }
  900. // 为每个任务批量更新标签数据
  901. successCount := 0
  902. failedTasks := make([]string, 0)
  903. skippedTasks := make([]string, 0) // 标签名称不匹配的任务
  904. for _, task := range tasks {
  905. // 根据任务的模版ID查询该模版下的所有标签
  906. templateMaps, _ := VerifyTemplate.Read_VerifyTemplateMap_List(task.T_VerifyTemplate_id, 0, 0)
  907. if len(templateMaps) == 0 {
  908. failedTasks = append(failedTasks, task.T_task_id)
  909. logs.Error(fmt.Sprintf("任务 %s 的模版ID %s 下没有标签", task.T_task_id, task.T_VerifyTemplate_id))
  910. continue
  911. }
  912. // 创建标签名称到标签ID的映射
  913. nameToMapId := make(map[string]string)
  914. for _, tm := range templateMaps {
  915. nameToMapId[tm.T_name] = tm.T_id
  916. }
  917. // 构建该任务的标签数据列表
  918. MapDataList := make([]VerifyTemplate.VerifyTemplateMapData, 0)
  919. matchedCount := 0
  920. unmatchedLabels := make([]string, 0)
  921. for _, v := range body.VerifyTemplateMapData {
  922. // 通过标签名称查找对应的标签ID
  923. mapId, exists := nameToMapId[v.T_name]
  924. if !exists {
  925. unmatchedLabels = append(unmatchedLabels, v.T_name)
  926. logs.Info(fmt.Sprintf("任务 %s 的模版中不存在标签名称: %s", task.T_task_id, v.T_name))
  927. continue
  928. }
  929. // 查找对应的标签信息以获取标签类型(用于特殊逻辑处理)
  930. var templateMap VerifyTemplate.VerifyTemplateMap_R
  931. for _, tm := range templateMaps {
  932. if tm.T_id == mapId {
  933. templateMap = tm
  934. break
  935. }
  936. }
  937. val := VerifyTemplate.VerifyTemplateMapData{
  938. T_source: v.T_source,
  939. T_task_id: task.T_task_id,
  940. T_VerifyTemplate_id: task.T_VerifyTemplate_id, // 使用任务自己的模版ID
  941. T_VerifyTemplateMap_id: mapId, // 使用通过名称匹配到的标签ID
  942. T_Required: v.T_Required, // 使用传入的值
  943. T_Construction: v.T_Construction, // 使用传入的值
  944. T_flow_sort: v.T_flow_sort, // 使用传入的值
  945. T_max_time: v.T_max_time, // 使用传入的值
  946. T_min_time: v.T_min_time, // 使用传入的值
  947. T_value: v.T_value, // 使用传入的值
  948. }
  949. MapDataList = append(MapDataList, val)
  950. matchedCount++
  951. // 处理标签类型16的特殊逻辑
  952. if templateMap.T_label == 16 && len(v.T_value) > 0 {
  953. verifyTemplateMap, exist := VerifyTemplate.Read_VerifyTemplateMap(mapId)
  954. if exist {
  955. options := lib.SplitStringSeparator(verifyTemplateMap.T_text, "|")
  956. found := false
  957. for _, opt := range options {
  958. if opt == v.T_value {
  959. found = true
  960. break
  961. }
  962. }
  963. if !found {
  964. verifyTemplateMap.T_text = verifyTemplateMap.T_text + "|" + v.T_value
  965. VerifyTemplate.Update_VerifyTemplateMap(verifyTemplateMap, "T_text")
  966. }
  967. }
  968. }
  969. }
  970. // 如果没有任何标签匹配,跳过该任务
  971. if matchedCount == 0 {
  972. skippedTasks = append(skippedTasks, task.T_task_id)
  973. logs.Info(fmt.Sprintf("任务 %s 没有匹配的标签,跳过。未匹配的标签: %s", task.T_task_id, strings.Join(unmatchedLabels, ",")))
  974. continue
  975. }
  976. // 批量更新该任务的标签数据(不保存历史,不覆盖)
  977. _, is := VerifyTemplate.AddOrUpdate_VerifyTemplateMapData_ADD_History(MapDataList, body.T_source, User_r.T_uuid, 2, 1, 0)
  978. if !is {
  979. failedTasks = append(failedTasks, task.T_task_id)
  980. logs.Error(fmt.Sprintf("任务 %s 标签数据更新失败", task.T_task_id))
  981. continue
  982. }
  983. // 检查必填项
  984. VerifyTemplate.Check_RequiredFields_HaveValue(task.T_task_id)
  985. successCount++
  986. }
  987. // 记录操作日志
  988. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "批量修改", fmt.Sprintf("任务数量:%d, 成功:%d, 失败:%d, 跳过:%d", len(body.T_task_ids), successCount, len(failedTasks), len(skippedTasks)))
  989. // 返回结果
  990. result := map[string]interface{}{
  991. "total": len(body.T_task_ids),
  992. "success": successCount,
  993. "failed": len(failedTasks),
  994. "skipped": len(skippedTasks),
  995. "failedTasks": failedTasks,
  996. "skippedTasks": skippedTasks,
  997. }
  998. msg := fmt.Sprintf("成功:%d, 失败:%d, 跳过:%d", successCount, len(failedTasks), len(skippedTasks))
  999. if len(failedTasks) > 0 {
  1000. msg += fmt.Sprintf(" (失败任务: %s)", strings.Join(failedTasks, ","))
  1001. }
  1002. if len(skippedTasks) > 0 {
  1003. msg += fmt.Sprintf(" (跳过任务: %s)", strings.Join(skippedTasks, ","))
  1004. }
  1005. if len(failedTasks) > 0 || successCount == 0 {
  1006. c.Data["json"] = lib.JSONS{Code: 202, Msg: msg, Data: result}
  1007. } else {
  1008. c.Data["json"] = lib.JSONS{Code: 200, Msg: msg, Data: result}
  1009. }
  1010. c.ServeJSON()
  1011. return
  1012. }
  1013. // 相同模版id复制标签数据
  1014. func (c *VerifyTemplateController) Map_Data_Copy2() {
  1015. // 验证登录 User_is, User_r
  1016. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1017. if !User_is {
  1018. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1019. c.ServeJSON()
  1020. return
  1021. }
  1022. T_source, _ := c.GetInt("T_source")
  1023. T_flow, _ := c.GetInt("T_flow")
  1024. if T_flow == 0 && T_source == 0 {
  1025. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  1026. c.ServeJSON()
  1027. return
  1028. }
  1029. T_copy_task_id := c.GetString("T_copy_task_id")
  1030. copy_task, is := Task.Read_Task(T_copy_task_id)
  1031. if !is {
  1032. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_copy_task_id 错误!"}
  1033. c.ServeJSON()
  1034. return
  1035. }
  1036. T_paste_task_id := c.GetString("T_paste_task_id")
  1037. paste_task, is := Task.Read_Task(T_paste_task_id)
  1038. if !is {
  1039. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_paste_task_id 错误!"}
  1040. c.ServeJSON()
  1041. return
  1042. }
  1043. if copy_task.T_VerifyTemplate_id != paste_task.T_VerifyTemplate_id {
  1044. c.Data["json"] = lib.JSONS{Code: 202, Msg: "仅支持相同模版间复制!"}
  1045. c.ServeJSON()
  1046. return
  1047. }
  1048. list := VerifyTemplate.Read_MapData_List(T_source, T_copy_task_id, copy_task.T_VerifyTemplate_id)
  1049. MapDataList := make([]VerifyTemplate.VerifyTemplateMapData, 0)
  1050. for _, v := range list {
  1051. val := VerifyTemplate.VerifyTemplateMapData{
  1052. T_source: T_source,
  1053. T_task_id: paste_task.T_task_id,
  1054. T_VerifyTemplate_id: paste_task.T_VerifyTemplate_id,
  1055. T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,
  1056. T_Required: v.T_Required,
  1057. T_Construction: v.T_Construction,
  1058. T_flow_sort: v.T_flow_sort,
  1059. T_max_time: v.T_max_time,
  1060. T_min_time: v.T_min_time,
  1061. T_value: v.T_value,
  1062. }
  1063. MapDataList = append(MapDataList, val)
  1064. }
  1065. var ids []int64
  1066. ids, is = VerifyTemplate.AddOrUpdate_VerifyTemplateMapData_ADD_History(MapDataList, T_source, User_r.T_uuid, 0, 0, 0)
  1067. if !is {
  1068. c.Data["json"] = lib.JSONS{Code: 202, Msg: "保存失败"}
  1069. c.ServeJSON()
  1070. return
  1071. }
  1072. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "复制", MapDataList)
  1073. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: ids}
  1074. c.ServeJSON()
  1075. return
  1076. }
  1077. // 通过标签名称复制标签数据
  1078. func (c *VerifyTemplateController) Map_Data_Copy() {
  1079. // 验证登录 User_is, User_r
  1080. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1081. if !User_is {
  1082. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1083. c.ServeJSON()
  1084. return
  1085. }
  1086. T_source, _ := c.GetInt("T_source")
  1087. T_flow, _ := c.GetInt("T_flow")
  1088. if T_flow == 0 && T_source == 0 {
  1089. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  1090. c.ServeJSON()
  1091. return
  1092. }
  1093. T_copy_task_id := c.GetString("T_copy_task_id")
  1094. copy_task, is := Task.Read_Task(T_copy_task_id)
  1095. if !is {
  1096. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_copy_task_id 错误!"}
  1097. c.ServeJSON()
  1098. return
  1099. }
  1100. T_paste_task_id := c.GetString("T_paste_task_id")
  1101. paste_task, is := Task.Read_Task(T_paste_task_id)
  1102. if !is {
  1103. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_paste_task_id 错误!"}
  1104. c.ServeJSON()
  1105. return
  1106. }
  1107. ids, err := CopyMapData(copy_task, paste_task, T_source)
  1108. if err != nil {
  1109. c.Data["json"] = lib.JSONS{Code: 202, Msg: err.Error()}
  1110. c.ServeJSON()
  1111. return
  1112. }
  1113. VerifyTemplate.Check_RequiredFields_HaveValue(T_paste_task_id)
  1114. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "通过标签名称复制", fmt.Sprintf("copy_task_id:%s | paste_task_id:%s", T_copy_task_id, T_paste_task_id))
  1115. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: ids}
  1116. c.ServeJSON()
  1117. return
  1118. }
  1119. // 添加标签数据
  1120. func (c *VerifyTemplateController) Map_Data_History_List() {
  1121. // 验证登录 User_is, User_r
  1122. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1123. if !User_is {
  1124. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1125. c.ServeJSON()
  1126. return
  1127. }
  1128. T_task_id := c.GetString("T_task_id")
  1129. T_source, _ := c.GetInt("T_source")
  1130. task, is := Task.Read_Task(T_task_id)
  1131. if !is {
  1132. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  1133. c.ServeJSON()
  1134. return
  1135. }
  1136. AdminMap := Account.AdminListToMap(Account.Read_Admin_List_ALL_1())
  1137. UseVerifyTemplateMapDataHistoryTime, _ := lib.TimeStrToTime(conf.UseVerifyTemplateMapDataHistoryTime)
  1138. var Data []VerifyTemplate.VerifyTemplateMapDataHistory_History_List_Res
  1139. if len(conf.UseVerifyTemplateMapDataHistoryTime) > 0 && task.CreateTime.After(UseVerifyTemplateMapDataHistoryTime) {
  1140. Data = VerifyTemplate.Read_VerifyTemplateMapDataHistory_History_List2(T_task_id, T_source, AdminMap)
  1141. } else {
  1142. Data = VerifyTemplate.Read_VerifyTemplateMapDataHistory_History_List(T_task_id, T_source, AdminMap)
  1143. }
  1144. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Data}
  1145. c.ServeJSON()
  1146. return
  1147. }
  1148. // 标签数据列表 -
  1149. func (c *VerifyTemplateController) Map_Data_History_Data_List() {
  1150. // 验证登录 User_is, User_r
  1151. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1152. if !User_is {
  1153. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1154. c.ServeJSON()
  1155. return
  1156. }
  1157. T_time := c.GetString("T_time")
  1158. if len(T_time) == 0 {
  1159. c.Data["json"] = lib.JSONS{Code: 202, Msg: "请选择时间点!"}
  1160. c.ServeJSON()
  1161. return
  1162. }
  1163. T_source, _ := c.GetInt("T_source")
  1164. if T_source == 0 {
  1165. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  1166. c.ServeJSON()
  1167. return
  1168. }
  1169. T_task_id := c.GetString("T_task_id")
  1170. task, is := Task.Read_Task(T_task_id)
  1171. if !is {
  1172. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  1173. c.ServeJSON()
  1174. return
  1175. }
  1176. Map_List := VerifyTemplate.Read_VerifyTemplateMap_List_For_Data(task.T_VerifyTemplate_id, T_source, 0)
  1177. Data := VerifyTemplate.Read_VerifyTemplateMapDataHistory_List(T_source, T_task_id, task.T_VerifyTemplate_id, T_time, Map_List)
  1178. type JSONS struct {
  1179. //必须的大写开头
  1180. Code int16
  1181. Msg string
  1182. Data interface{} // 泛型
  1183. T_step int
  1184. }
  1185. c.Data["json"] = JSONS{Code: 200, Msg: "ok!", Data: Data, T_step: task.T_step}
  1186. c.ServeJSON()
  1187. return
  1188. }
  1189. // 清除数据
  1190. func (c *VerifyTemplateController) Map_Data_Clear_Value() {
  1191. // 验证登录 User_is, User_r
  1192. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1193. if !User_is {
  1194. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1195. c.ServeJSON()
  1196. return
  1197. }
  1198. T_VerifyTemplate_id := c.GetString("T_VerifyTemplate_id")
  1199. T_VerifyTemplateMap_id := c.GetString("T_VerifyTemplateMap_id")
  1200. T_task_id := c.GetString("T_task_id")
  1201. _, is := Task.Read_Task(T_task_id)
  1202. if !is {
  1203. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  1204. c.ServeJSON()
  1205. return
  1206. }
  1207. VerifyTemplate.Clear_VerifyTemplateMapData_T_value(T_task_id, T_VerifyTemplate_id, T_VerifyTemplateMap_id)
  1208. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "清除数据", fmt.Sprintf("T_task_id:%s T_VerifyTemplate_id:%s T_VerifyTemplateMap_id:%s", T_task_id, T_VerifyTemplate_id, T_VerifyTemplateMap_id))
  1209. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  1210. c.ServeJSON()
  1211. return
  1212. }
  1213. // 历史数据恢复
  1214. func (c *VerifyTemplateController) Map_Data_History_Recover() {
  1215. // 验证登录 User_is, User_r
  1216. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1217. if !User_is {
  1218. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1219. c.ServeJSON()
  1220. return
  1221. }
  1222. T_time := c.GetString("T_time")
  1223. if len(T_time) == 0 {
  1224. c.Data["json"] = lib.JSONS{Code: 202, Msg: "请选择时间点!"}
  1225. c.ServeJSON()
  1226. return
  1227. }
  1228. T_source, _ := c.GetInt("T_source")
  1229. if T_source == 0 {
  1230. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  1231. c.ServeJSON()
  1232. return
  1233. }
  1234. T_task_id := c.GetString("T_task_id")
  1235. task, is := Task.Read_Task(T_task_id)
  1236. if !is {
  1237. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  1238. c.ServeJSON()
  1239. return
  1240. }
  1241. HistoryList := VerifyTemplate.Read_MapDataHistory_List(T_source, T_task_id, task.T_VerifyTemplate_id, T_time)
  1242. list := VerifyTemplate.Read_MapData_List(T_source, T_task_id, task.T_VerifyTemplate_id)
  1243. HistoryListMap := make(map[string]VerifyTemplate.VerifyTemplateMapDataHistory)
  1244. for _, data := range HistoryList {
  1245. HistoryListMap[data.T_VerifyTemplateMap_id] = data
  1246. }
  1247. MapDataList := make([]VerifyTemplate.VerifyTemplateMapData, 0)
  1248. for _, v := range list {
  1249. if len(v.T_value) > 0 {
  1250. continue
  1251. }
  1252. if HistoryListMap[v.T_VerifyTemplateMap_id].T_value == "" {
  1253. continue
  1254. }
  1255. val := VerifyTemplate.VerifyTemplateMapData{
  1256. T_source: T_source,
  1257. T_task_id: task.T_task_id,
  1258. T_VerifyTemplate_id: task.T_VerifyTemplate_id,
  1259. T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,
  1260. T_Required: v.T_Required,
  1261. T_Construction: v.T_Construction,
  1262. T_flow_sort: v.T_flow_sort,
  1263. T_max_time: v.T_max_time,
  1264. T_min_time: v.T_min_time,
  1265. T_value: HistoryListMap[v.T_VerifyTemplateMap_id].T_value,
  1266. }
  1267. MapDataList = append(MapDataList, val)
  1268. }
  1269. var ids []int64
  1270. ids, is = VerifyTemplate.AddOrUpdate_VerifyTemplateMapData(MapDataList)
  1271. if !is {
  1272. c.Data["json"] = lib.JSONS{Code: 202, Msg: "保存失败"}
  1273. c.ServeJSON()
  1274. return
  1275. }
  1276. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "恢复", MapDataList)
  1277. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: ids}
  1278. c.ServeJSON()
  1279. return
  1280. }
  1281. // 覆盖数据
  1282. func (c *VerifyTemplateController) Map_Data_Cover() {
  1283. // 验证登录 User_is, User_r
  1284. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1285. if !User_is {
  1286. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1287. c.ServeJSON()
  1288. return
  1289. }
  1290. T_cover, _ := c.GetInt("T_cover") // 1覆盖 0不覆盖
  1291. T_time := c.GetString("T_time")
  1292. if len(T_time) == 0 {
  1293. c.Data["json"] = lib.JSONS{Code: 202, Msg: "请选择时间点!"}
  1294. c.ServeJSON()
  1295. return
  1296. }
  1297. T_source, _ := c.GetInt("T_source")
  1298. if T_source == 0 {
  1299. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_source Err!"}
  1300. c.ServeJSON()
  1301. return
  1302. }
  1303. T_task_id := c.GetString("T_task_id")
  1304. task, is := Task.Read_Task(T_task_id)
  1305. if !is {
  1306. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_task_id 错误!"}
  1307. c.ServeJSON()
  1308. return
  1309. }
  1310. var ids []int64
  1311. if T_cover == 1 {
  1312. HistoryList := VerifyTemplate.Read_MapDataHistory_List(T_source, T_task_id, task.T_VerifyTemplate_id, T_time)
  1313. list := VerifyTemplate.Read_MapData_List(T_source, T_task_id, task.T_VerifyTemplate_id)
  1314. HistoryListMap := make(map[string]VerifyTemplate.VerifyTemplateMapDataHistory)
  1315. for _, data := range HistoryList {
  1316. HistoryListMap[data.T_VerifyTemplateMap_id] = data
  1317. }
  1318. MapDataList := make([]VerifyTemplate.VerifyTemplateMapData, 0)
  1319. for _, v := range list {
  1320. if len(v.T_value) > 0 {
  1321. continue
  1322. }
  1323. if HistoryListMap[v.T_VerifyTemplateMap_id].T_value == "" {
  1324. continue
  1325. }
  1326. val := VerifyTemplate.VerifyTemplateMapData{
  1327. T_source: T_source,
  1328. T_task_id: task.T_task_id,
  1329. T_VerifyTemplate_id: task.T_VerifyTemplate_id,
  1330. T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,
  1331. T_Required: v.T_Required,
  1332. T_Construction: v.T_Construction,
  1333. T_flow_sort: v.T_flow_sort,
  1334. T_max_time: v.T_max_time,
  1335. T_min_time: v.T_min_time,
  1336. T_value: HistoryListMap[v.T_VerifyTemplateMap_id].T_value,
  1337. }
  1338. MapDataList = append(MapDataList, val)
  1339. }
  1340. ids, is = VerifyTemplate.AddOrUpdate_VerifyTemplateMapData(MapDataList)
  1341. if !is {
  1342. c.Data["json"] = lib.JSONS{Code: 202, Msg: "保存失败"}
  1343. c.ServeJSON()
  1344. return
  1345. }
  1346. System.Add_UserLogs_T(User_r.T_uuid, "验证模版标签数据", "覆盖", MapDataList)
  1347. }
  1348. task.T_cover = 0
  1349. task.T_backup = ""
  1350. Task.Update_Task(task, "T_cover", "T_backup")
  1351. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: ids}
  1352. c.ServeJSON()
  1353. return
  1354. }
  1355. func (c *VerifyTemplateController) Class_List() {
  1356. // 验证登录 User_is, User_r
  1357. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1358. if !User_is {
  1359. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1360. c.ServeJSON()
  1361. return
  1362. }
  1363. logs.Debug("经销商id", User_r.T_Distributor_id)
  1364. if len(User_r.T_Distributor_id) > 0 {
  1365. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Distributor.Read_DistributorVerifyTemplateClass_List(User_r.T_Distributor_id)}
  1366. c.ServeJSON()
  1367. return
  1368. }
  1369. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: VerifyTemplate.Read_VerifyTemplateClass_List()}
  1370. c.ServeJSON()
  1371. return
  1372. }
  1373. func (c *VerifyTemplateController) Class_Add() {
  1374. // 验证登录 User_is, User_r
  1375. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1376. if !User_is {
  1377. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1378. c.ServeJSON()
  1379. return
  1380. }
  1381. T_name := c.GetString("T_name")
  1382. T_fid, _ := c.GetInt("T_fid")
  1383. var_ := VerifyTemplate.VerifyTemplateClass{
  1384. T_name: T_name,
  1385. T_fid: T_fid,
  1386. T_State: 1,
  1387. }
  1388. Id, err := VerifyTemplate.Add_VerifyTemplateClass(var_)
  1389. if err != nil {
  1390. c.Data["json"] = lib.JSONS{Code: 203, Msg: "添加失败"}
  1391. c.ServeJSON()
  1392. return
  1393. }
  1394. System.Add_UserLogs_T(User_r.T_uuid, "模版分类", "添加", var_)
  1395. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
  1396. c.ServeJSON()
  1397. return
  1398. }
  1399. func (c *VerifyTemplateController) Class_Up() {
  1400. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1401. if !User_is {
  1402. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1403. c.ServeJSON()
  1404. return
  1405. }
  1406. T_id, _ := c.GetInt("T_id")
  1407. T_name := c.GetString("T_name")
  1408. R_VerifyTemplateToolClass, err := VerifyTemplate.Read_VerifyTemplateClass_ById(T_id)
  1409. if err != nil {
  1410. c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
  1411. c.ServeJSON()
  1412. return
  1413. }
  1414. if len(T_name) > 0 {
  1415. R_VerifyTemplateToolClass.T_name = T_name
  1416. }
  1417. if is := VerifyTemplate.Update_VerifyTemplateClass(R_VerifyTemplateToolClass, "T_name"); !is {
  1418. c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改失败"}
  1419. c.ServeJSON()
  1420. return
  1421. }
  1422. System.Add_UserLogs_T(User_r.T_uuid, "模版分类", "修改", R_VerifyTemplateToolClass)
  1423. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  1424. c.ServeJSON()
  1425. return
  1426. }
  1427. func (c *VerifyTemplateController) Class_Del() {
  1428. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1429. if !User_is {
  1430. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1431. c.ServeJSON()
  1432. return
  1433. }
  1434. T_id, _ := c.GetInt("T_id")
  1435. R_VerifyTemplateToolClass, err := VerifyTemplate.Read_VerifyTemplateClass_ById(T_id)
  1436. if err != nil {
  1437. c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
  1438. c.ServeJSON()
  1439. return
  1440. }
  1441. ids := VerifyTemplate.ReadVerifyTemplateClassIds_T_path(R_VerifyTemplateToolClass.T_path)
  1442. if is := VerifyTemplate.Delete_VerifyTemplateClass_ByIds(ids); !is {
  1443. c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
  1444. c.ServeJSON()
  1445. return
  1446. }
  1447. System.Add_UserLogs(User_r.T_uuid, "模版分类", "删除", strconv.Itoa(T_id))
  1448. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  1449. c.ServeJSON()
  1450. return
  1451. }
  1452. // 复制验证模版-分类-标签
  1453. func (c *VerifyTemplateController) Class_Copy() {
  1454. // 验证登录 User_is, User_r
  1455. User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1456. if !User_is {
  1457. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1458. c.ServeJSON()
  1459. return
  1460. }
  1461. T_id, _ := c.GetInt("T_id") // 要复制的信息采集分类id
  1462. T_name := c.GetString("T_name")
  1463. // 查询要复制的信息采集分类id
  1464. R_VerifyTemplateClass, err := VerifyTemplate.Read_VerifyTemplateClass_ById(T_id)
  1465. if err != nil {
  1466. c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
  1467. c.ServeJSON()
  1468. return
  1469. }
  1470. if len(T_name) > 0 && T_name != R_VerifyTemplateClass.T_name {
  1471. R_VerifyTemplateClass.T_name = T_name
  1472. } else {
  1473. R_VerifyTemplateClass.T_name = R_VerifyTemplateClass.T_name + "_副本"
  1474. }
  1475. _, err = VerifyTemplate.CopyVerifyTemplateClassTree(R_VerifyTemplateClass.T_path, R_VerifyTemplateClass.T_fid, R_VerifyTemplateClass.T_name)
  1476. if err != nil {
  1477. c.Data["json"] = lib.JSONS{Code: 202, Msg: "复制验证模版分类失败"}
  1478. c.ServeJSON()
  1479. return
  1480. }
  1481. System.Add_UserLogs_T(User_r.T_uuid, "验证模版分类", "复制", T_id)
  1482. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  1483. c.ServeJSON()
  1484. return
  1485. }
  1486. func CopyMapData(copy_task, paste_task Task.Task, T_source int) (ids []int64, err error) {
  1487. copy_task_Map_List := VerifyTemplate.Read_VerifyTemplateMap_List_For_Data(copy_task.T_VerifyTemplate_id, T_source, 0)
  1488. copy_task_Data := VerifyTemplate.Read_VerifyTemplateMapData_List(T_source, copy_task.T_task_id, copy_task.T_VerifyTemplate_id, copy_task_Map_List)
  1489. Map_List := VerifyTemplate.Read_VerifyTemplateMap_List_For_Data(paste_task.T_VerifyTemplate_id, T_source, 0)
  1490. Data := VerifyTemplate.Read_VerifyTemplateMapData_List(T_source, paste_task.T_task_id, paste_task.T_VerifyTemplate_id, Map_List)
  1491. copyDataMap := make(map[string]string)
  1492. for _, data := range copy_task_Data {
  1493. copyDataMap[data.T_name] = data.T_value
  1494. }
  1495. MapDataList := make([]VerifyTemplate.VerifyTemplateMapData, 0)
  1496. for _, v := range Data {
  1497. // 已有值则不复制
  1498. if len(v.T_value) > 0 {
  1499. continue
  1500. }
  1501. if copyDataMap[v.T_name] == "" {
  1502. continue
  1503. }
  1504. val := VerifyTemplate.VerifyTemplateMapData{
  1505. T_source: v.T_source,
  1506. T_task_id: paste_task.T_task_id,
  1507. T_VerifyTemplate_id: paste_task.T_VerifyTemplate_id,
  1508. T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,
  1509. T_Required: v.T_Required,
  1510. T_Construction: v.T_Construction,
  1511. T_flow_sort: v.T_flow_sort,
  1512. T_max_time: v.T_max_time,
  1513. T_min_time: v.T_min_time,
  1514. T_value: copyDataMap[v.T_name],
  1515. }
  1516. MapDataList = append(MapDataList, val)
  1517. }
  1518. ids, is := VerifyTemplate.AddOrUpdate_VerifyTemplateMapData_ADD_History(MapDataList, 0, "", 0, 0, 0)
  1519. if !is {
  1520. return ids, errors.New("保存复制数据失败")
  1521. }
  1522. return nil, err
  1523. }
  1524. // 导出所有模板的标签名称 - 每个模板一个Sheet
  1525. func (c *VerifyTemplateController) Export_Labels() {
  1526. // 验证登录
  1527. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1528. if !User_is {
  1529. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1530. c.ServeJSON()
  1531. return
  1532. }
  1533. // 读取所有模板分类
  1534. classList := VerifyTemplate.Read_VerifyTemplateClass_List()
  1535. // 收集所有模板
  1536. type tpl struct {
  1537. Id string
  1538. Name string
  1539. TemplateId string
  1540. ClassName string
  1541. }
  1542. var tplList []tpl
  1543. var collectTpl func(list []VerifyTemplate.VerifyTemplateClass)
  1544. collectTpl = func(list []VerifyTemplate.VerifyTemplateClass) {
  1545. for _, cls := range list {
  1546. // 当前分类下的模板
  1547. vlist, _ := VerifyTemplate.Read_VerifyTemplate_List(cls.Id, "", 0, 9999)
  1548. for _, v := range vlist {
  1549. tplList = append(tplList, tpl{Id: v.T_VerifyTemplate_id, Name: v.T_name, TemplateId: v.T_VerifyTemplate_id, ClassName: cls.T_name})
  1550. }
  1551. // 递归子分类
  1552. if len(cls.Children) > 0 {
  1553. collectTpl(cls.Children)
  1554. }
  1555. }
  1556. }
  1557. collectTpl(classList)
  1558. // 创建excel
  1559. f := excelize.NewFile()
  1560. sheetName := "Sheet1"
  1561. idx, _ := f.GetSheetIndex(sheetName)
  1562. f.SetActiveSheet(idx)
  1563. // 表头
  1564. f.SetCellValue(sheetName, "A1", "分类名称")
  1565. f.SetCellValue(sheetName, "B1", "模版名称")
  1566. f.SetCellValue(sheetName, "C1", "标签名称")
  1567. // 设置列宽
  1568. f.SetColWidth(sheetName, "A", "A", 30)
  1569. f.SetColWidth(sheetName, "B", "B", 40)
  1570. f.SetColWidth(sheetName, "C", "C", 40)
  1571. line := 1
  1572. // 写入模板与对应标签
  1573. for _, t := range tplList {
  1574. mapList, _ := VerifyTemplate.Read_VerifyTemplateMap_List(t.Id, 0, 0)
  1575. if len(mapList) == 0 {
  1576. line++
  1577. row := line
  1578. f.SetCellValue(sheetName, fmt.Sprintf("A%d", row), t.ClassName)
  1579. f.SetCellValue(sheetName, fmt.Sprintf("B%d", row), t.Name+fmt.Sprintf("[%s]", t.TemplateId))
  1580. continue
  1581. }
  1582. startRow := line + 1
  1583. for idxLabel, m := range mapList {
  1584. line++
  1585. row := line
  1586. if idxLabel == 0 {
  1587. f.SetCellValue(sheetName, fmt.Sprintf("A%d", row), t.ClassName)
  1588. f.SetCellValue(sheetName, fmt.Sprintf("B%d", row), t.Name)
  1589. }
  1590. f.SetCellValue(sheetName, fmt.Sprintf("C%d", row), m.T_name)
  1591. }
  1592. if len(mapList) > 1 {
  1593. f.MergeCell(sheetName, fmt.Sprintf("A%d", startRow), fmt.Sprintf("A%d", line))
  1594. f.MergeCell(sheetName, fmt.Sprintf("B%d", startRow), fmt.Sprintf("B%d", line))
  1595. }
  1596. }
  1597. // 设置居中样式
  1598. styleCenter, styleErr := f.NewStyle(&excelize.Style{
  1599. Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"},
  1600. })
  1601. if styleErr != nil {
  1602. logs.Error("NewStyle Err:", styleErr)
  1603. } else {
  1604. f.SetCellStyle(sheetName, "A1", fmt.Sprintf("C%d", line), styleCenter)
  1605. }
  1606. // 生成文件
  1607. lib.Create_Dir("./ofile")
  1608. timeStr := time.Now().Format("20060102150405")
  1609. filePath := "ofile/" + timeStr + ".xlsx"
  1610. if err := f.SaveAs(filePath); err != nil {
  1611. logs.Error(lib.FuncName(), err)
  1612. c.Data["json"] = lib.JSONS{Code: 203, Msg: "文件保存失败!"}
  1613. c.ServeJSON()
  1614. return
  1615. }
  1616. // 上传到七牛
  1617. if !lib.Pload_qiniu(filePath, filePath) {
  1618. c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
  1619. c.ServeJSON()
  1620. return
  1621. }
  1622. // 删除本地文件
  1623. err := os.Remove(filePath)
  1624. if err != nil {
  1625. logs.Error(lib.FuncName(), err)
  1626. }
  1627. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: "https://bzdcoldverifyoss.baozhida.cn/" + filePath}
  1628. c.ServeJSON()
  1629. return
  1630. }
  1631. // 导出分类和模版名称(带T_VerifyTemplate_id)
  1632. func (c *VerifyTemplateController) Export_Class_Template() {
  1633. // 验证登录
  1634. _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  1635. if !User_is {
  1636. c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
  1637. c.ServeJSON()
  1638. return
  1639. }
  1640. // 读取所有模板分类
  1641. classList := VerifyTemplate.Read_VerifyTemplateClass_List()
  1642. // 按分类收集模板,使用map存储:分类名称 -> 模板列表
  1643. type tpl struct {
  1644. Name string
  1645. TemplateId string
  1646. }
  1647. classTemplates := make(map[string][]tpl)
  1648. var collectTpl func(list []VerifyTemplate.VerifyTemplateClass)
  1649. collectTpl = func(list []VerifyTemplate.VerifyTemplateClass) {
  1650. for _, cls := range list {
  1651. // 当前分类下的模板
  1652. vlist, _ := VerifyTemplate.Read_VerifyTemplate_List(cls.Id, "", 0, 9999)
  1653. if len(vlist) > 0 {
  1654. var templates []tpl
  1655. for _, v := range vlist {
  1656. templates = append(templates, tpl{
  1657. Name: v.T_name,
  1658. TemplateId: v.T_VerifyTemplate_id,
  1659. })
  1660. }
  1661. classTemplates[cls.T_name] = templates
  1662. }
  1663. // 递归子分类
  1664. if len(cls.Children) > 0 {
  1665. collectTpl(cls.Children)
  1666. }
  1667. }
  1668. }
  1669. collectTpl(classList)
  1670. // 创建excel
  1671. f := excelize.NewFile()
  1672. sheetName := "Sheet1"
  1673. idx, _ := f.GetSheetIndex(sheetName)
  1674. f.SetActiveSheet(idx)
  1675. // 找到所有分类中模板数量最多的,作为最大行数
  1676. maxRows := 1 // 至少有一行表头
  1677. classNames := make([]string, 0, len(classTemplates))
  1678. for className, templates := range classTemplates {
  1679. classNames = append(classNames, className)
  1680. if len(templates)+1 > maxRows {
  1681. maxRows = len(templates) + 1
  1682. }
  1683. }
  1684. // Excel列名转换函数:1->A, 2->B, ..., 26->Z, 27->AA, 28->AB, ...
  1685. toExcelColumn := func(n int) string {
  1686. result := ""
  1687. for n > 0 {
  1688. n--
  1689. result = string(rune('A'+n%26)) + result
  1690. n /= 26
  1691. }
  1692. return result
  1693. }
  1694. // 第一行写入分类名称
  1695. for colIndex, className := range classNames {
  1696. colName := toExcelColumn(colIndex + 1)
  1697. cell := fmt.Sprintf("%s1", colName)
  1698. f.SetCellValue(sheetName, cell, className)
  1699. // 设置列宽
  1700. f.SetColWidth(sheetName, colName, colName, 40)
  1701. }
  1702. // 从第二行开始,按列写入每个分类下的模版
  1703. for row := 2; row <= maxRows; row++ {
  1704. for colIndex, className := range classNames {
  1705. templates := classTemplates[className]
  1706. colName := toExcelColumn(colIndex + 1)
  1707. cell := fmt.Sprintf("%s%d", colName, row)
  1708. // 如果该分类还有模版,则写入
  1709. templateIndex := row - 2
  1710. if templateIndex < len(templates) {
  1711. t := templates[templateIndex]
  1712. f.SetCellValue(sheetName, cell, t.Name+fmt.Sprintf("[%s]", t.TemplateId))
  1713. }
  1714. }
  1715. }
  1716. // 设置居中样式
  1717. styleCenter, styleErr := f.NewStyle(&excelize.Style{
  1718. Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"},
  1719. })
  1720. if styleErr != nil {
  1721. logs.Error("NewStyle Err:", styleErr)
  1722. } else {
  1723. lastCol := toExcelColumn(len(classNames))
  1724. f.SetCellStyle(sheetName, "A1", fmt.Sprintf("%s%d", lastCol, maxRows), styleCenter)
  1725. }
  1726. // 生成文件
  1727. lib.Create_Dir("./ofile")
  1728. timeStr := time.Now().Format("20060102150405")
  1729. filePath := "ofile/" + timeStr + "_class_template.xlsx"
  1730. if err := f.SaveAs(filePath); err != nil {
  1731. logs.Error(lib.FuncName(), err)
  1732. c.Data["json"] = lib.JSONS{Code: 203, Msg: "文件保存失败!"}
  1733. c.ServeJSON()
  1734. return
  1735. }
  1736. // 上传到七牛
  1737. if !lib.Pload_qiniu(filePath, filePath) {
  1738. c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
  1739. c.ServeJSON()
  1740. return
  1741. }
  1742. // 删除本地文件
  1743. err := os.Remove(filePath)
  1744. if err != nil {
  1745. logs.Error(lib.FuncName(), err)
  1746. }
  1747. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: "https://bzdcoldverifyoss.baozhida.cn/" + filePath}
  1748. c.ServeJSON()
  1749. return
  1750. }