VerifyTemplateMapData.go 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334
  1. package VerifyTemplate
  2. import (
  3. "ColdVerify_local/conf"
  4. "ColdVerify_local/lib"
  5. "ColdVerify_local/logs"
  6. "github.com/beego/beego/v2/adapter/orm"
  7. orm2 "github.com/beego/beego/v2/client/orm"
  8. _ "github.com/go-sql-driver/mysql"
  9. "time"
  10. )
  11. // 模板
  12. type VerifyTemplateMapData struct {
  13. Id int `orm:"column(ID);size(11);auto;pk"`
  14. T_source int `orm:"size(2);"` // 来源 0-所有 1-方案 2-报告 3-表单
  15. T_task_id string `orm:"index,size(256);null"` // 任务id
  16. T_VerifyTemplate_id string `orm:"index,size(256);null"` // 模板id
  17. T_VerifyTemplateMap_id string `orm:"index,size(256);null"` // 标签id
  18. T_value string `orm:"size(1024);null"` // 内容
  19. T_Required int `orm:"size(2);default(0)"` // 必填项 1 必填 0 非必填
  20. T_Construction int `orm:"size(2);default(0)"` // 实施(是否在APP 上显示) 1 显示 0 不显示
  21. // 验证流程
  22. T_flow_sort int `orm:"size(2);default(0)"` // 验证流程排序
  23. T_max_time int `orm:"size(256);null"` // 验证流程最大时间
  24. T_min_time int `orm:"size(256);null"` // 验证流程最小时间
  25. T_start_time int64 `orm:"size(256);null"` // 开始时间 app
  26. CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
  27. UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"` //auto_now 每次 model 保存时都会对时间自动更新
  28. }
  29. type VerifyTemplateMapData_R struct {
  30. T_id int
  31. T_VerifyTemplateMap_id string // 标签id
  32. T_source int
  33. T_label int //
  34. T_name string // 标题
  35. T_text string // 标题
  36. T_value string //
  37. T_Required int //
  38. T_Construction int //
  39. // 验证流程
  40. T_flow_sort int // 验证流程排序
  41. T_max_time int // 验证流程最大时间
  42. T_min_time int // 验证流程最小时间
  43. T_start_time int64 // 开始时间 app
  44. }
  45. func (t *VerifyTemplateMapData) TableName() string {
  46. return "verify_template_map_data" // 数据库名称 // ************** 替换 FormulaList **************
  47. }
  48. func init() {
  49. //注册模型
  50. orm.RegisterModel(new(VerifyTemplateMapData))
  51. }
  52. // -------------------------------------------------------------
  53. func VerifyTemplateMapToVerifyTemplateMapData_R(T VerifyTemplateMap) (T_r VerifyTemplateMapData_R) {
  54. T_r.T_VerifyTemplateMap_id = T.T_id
  55. T_r.T_source = T.T_source
  56. T_r.T_label = T.T_label
  57. T_r.T_name = T.T_name
  58. T_r.T_text = T.T_text
  59. T_r.T_Required = T.T_Required
  60. T_r.T_Construction = T.T_Construction
  61. T_r.T_flow_sort = T.T_flow_sort
  62. T_r.T_max_time = T.T_max_time
  63. T_r.T_min_time = T.T_min_time
  64. T_r.T_value = ""
  65. return T_r
  66. }
  67. func VerifyTemplateMapDataToVerifyTemplateMapData_R(T VerifyTemplateMap, VerifyTemplateMapData map[string]VerifyTemplateMapData) (T_r VerifyTemplateMapData_R) {
  68. T_r.T_VerifyTemplateMap_id = T.T_id
  69. T_r.T_source = T.T_source
  70. T_r.T_label = T.T_label
  71. T_r.T_name = T.T_name
  72. T_r.T_text = T.T_text
  73. T_r.T_Required = T.T_Required
  74. T_r.T_Construction = T.T_Construction
  75. T_r.T_flow_sort = T.T_flow_sort
  76. T_r.T_max_time = T.T_max_time
  77. T_r.T_min_time = T.T_min_time
  78. T_r.T_value = ""
  79. if v, ok := VerifyTemplateMapData[T.T_id]; ok {
  80. T_r.T_value = v.T_value
  81. T_r.T_start_time = v.T_start_time
  82. }
  83. return T_r
  84. }
  85. // 添加或更新模板数据 并添加历史数据
  86. func AddOrUpdate_VerifyTemplateMapData_ADD_History(List []VerifyTemplateMapData, T_source int, T_uuid string) (ids []int64, is bool) {
  87. o := orm.NewOrm()
  88. qs := o.QueryTable(new(VerifyTemplateMapData))
  89. o.Begin()
  90. T_time := time.Now().Format("2006-01-02 15:04:05")
  91. for _, v := range List {
  92. var r VerifyTemplateMapData
  93. // 创建验证模版数据,有则更新,没有则创建
  94. err := qs.Filter("T_task_id", v.T_task_id).Filter("T_VerifyTemplate_id", v.T_VerifyTemplate_id).Filter("T_VerifyTemplateMap_id", v.T_VerifyTemplateMap_id).One(&r)
  95. if err != nil {
  96. if err.Error() == orm.ErrNoRows.Error() {
  97. id, err := o.Insert(&v)
  98. if err != nil {
  99. logs.Error(lib.FuncName(), err)
  100. o.Rollback()
  101. return ids, false
  102. }
  103. ids = append(ids, id)
  104. } else {
  105. logs.Error(lib.FuncName(), err)
  106. o.Rollback()
  107. return ids, false
  108. }
  109. }
  110. // 更新验证模版数据
  111. if r.Id > 0 && (len(v.T_value) > 0 || v.T_start_time > 0) {
  112. if v.T_start_time == 1 {
  113. v.T_start_time = 0
  114. }
  115. v.Id = r.Id
  116. //_, err = o.Update(&v, "T_flow_sort", "T_max_time", "T_min_time", "T_value")
  117. _, err = o.QueryTable(new(VerifyTemplateMapData)).Filter("T_task_id", v.T_task_id).Filter("T_VerifyTemplate_id", v.T_VerifyTemplate_id).
  118. Filter("T_VerifyTemplateMap_id", v.T_VerifyTemplateMap_id).Update(orm2.Params{
  119. "T_flow_sort": v.T_flow_sort, "T_max_time": v.T_max_time, "T_min_time": v.T_min_time, "T_value": v.T_value, "T_start_time": v.T_start_time,
  120. })
  121. if err != nil {
  122. logs.Error(lib.FuncName(), err)
  123. o.Rollback()
  124. return ids, false
  125. }
  126. ids = append(ids, int64(r.Id))
  127. }
  128. // 添加历史记录
  129. _, err = o.Insert(&VerifyTemplateMapDataHistory{
  130. T_source: v.T_source,
  131. T_task_id: v.T_task_id,
  132. T_time: T_time,
  133. T_uuid: T_uuid,
  134. T_submit_source: T_source,
  135. T_VerifyTemplate_id: v.T_VerifyTemplate_id,
  136. T_VerifyTemplateMap_id: v.T_VerifyTemplateMap_id,
  137. T_value: v.T_value,
  138. T_Required: v.T_Required,
  139. T_flow_sort: v.T_flow_sort,
  140. T_max_time: v.T_max_time,
  141. T_min_time: v.T_min_time,
  142. })
  143. if err != nil {
  144. logs.Error(lib.FuncName(), err)
  145. o.Rollback()
  146. return ids, false
  147. }
  148. }
  149. o.Commit()
  150. return ids, true
  151. }
  152. // ---------------- 特殊方法 -------------------
  153. // 添加
  154. func AddOrUpdate_VerifyTemplateMapData(List []VerifyTemplateMapData) (ids []int64, is bool) {
  155. o := orm.NewOrm()
  156. qs := o.QueryTable(new(VerifyTemplateMapData))
  157. o.Begin()
  158. for _, v := range List {
  159. var r VerifyTemplateMapData
  160. // 创建验证模版数据,有则更新,没有则创建
  161. err := qs.Filter("T_task_id", v.T_task_id).Filter("T_VerifyTemplate_id", v.T_VerifyTemplate_id).Filter("T_VerifyTemplateMap_id", v.T_VerifyTemplateMap_id).One(&r)
  162. if err != nil {
  163. if err.Error() == orm.ErrNoRows.Error() {
  164. id, err := o.Insert(&v)
  165. if err != nil {
  166. logs.Error(lib.FuncName(), err)
  167. o.Rollback()
  168. return ids, false
  169. }
  170. ids = append(ids, id)
  171. } else {
  172. logs.Error(lib.FuncName(), err)
  173. o.Rollback()
  174. return ids, false
  175. }
  176. }
  177. // 更新验证模版数据
  178. if r.Id > 0 && (len(v.T_value) > 0 || v.T_start_time > 0) {
  179. if v.T_start_time == 1 {
  180. v.T_start_time = 0
  181. }
  182. v.Id = r.Id
  183. //_, err = o.Update(&v, "T_flow_sort", "T_max_time", "T_min_time", "T_value")
  184. _, err = o.QueryTable(new(VerifyTemplateMapData)).Filter("T_task_id", v.T_task_id).Filter("T_VerifyTemplate_id", v.T_VerifyTemplate_id).
  185. Filter("T_VerifyTemplateMap_id", v.T_VerifyTemplateMap_id).Update(orm2.Params{
  186. "T_flow_sort": v.T_flow_sort, "T_max_time": v.T_max_time, "T_min_time": v.T_min_time, "T_value": v.T_value, "T_start_time": v.T_start_time,
  187. })
  188. if err != nil {
  189. logs.Error(lib.FuncName(), err)
  190. o.Rollback()
  191. return ids, false
  192. }
  193. ids = append(ids, int64(r.Id))
  194. }
  195. }
  196. o.Commit()
  197. return ids, true
  198. }
  199. // 获取列表
  200. func Read_VerifyTemplateMapData_List(T_source int, T_task_id, T_VerifyTemplate_id string, Map_List []VerifyTemplateMap) []VerifyTemplateMapData_R {
  201. o := orm.NewOrm()
  202. // 也可以直接使用 Model 结构体作为表名
  203. var r []VerifyTemplateMapData
  204. qs := o.QueryTable(new(VerifyTemplateMapData))
  205. cond := orm.NewCondition()
  206. cond1 := cond.And("T_task_id", T_task_id).And("T_VerifyTemplate_id", T_VerifyTemplate_id)
  207. qs.SetCond((*orm2.Condition)(cond1)).All(&r)
  208. if len(r) == 0 {
  209. // 转换
  210. var VerifyTemplateMapData_r []VerifyTemplateMapData_R
  211. for k, v := range Map_List {
  212. Data_r := VerifyTemplateMapToVerifyTemplateMapData_R(v)
  213. Data_r.T_id = k
  214. VerifyTemplateMapData_r = append(VerifyTemplateMapData_r, Data_r)
  215. }
  216. return VerifyTemplateMapData_r
  217. }
  218. // 转换
  219. var VerifyTemplateMapData_r []VerifyTemplateMapData_R
  220. for k, v := range Map_List {
  221. Data_r := VerifyTemplateMapDataToVerifyTemplateMapData_R(v, VerifyTemplateMapDataToMap(r))
  222. Data_r.T_id = k
  223. VerifyTemplateMapData_r = append(VerifyTemplateMapData_r, Data_r)
  224. }
  225. return VerifyTemplateMapData_r
  226. }
  227. // 获取列表
  228. func Read_MapData_List(T_source int, T_task_id, T_VerifyTemplate_id string) []VerifyTemplateMapData {
  229. o := orm.NewOrm()
  230. // 也可以直接使用 Model 结构体作为表名
  231. var r []VerifyTemplateMapData
  232. qs := o.QueryTable(new(VerifyTemplateMapData))
  233. cond := orm.NewCondition()
  234. source := []int{T_source}
  235. if T_source == 2 {
  236. source = append(source, 3)
  237. }
  238. if T_source != 3 {
  239. source = append(source, 0)
  240. }
  241. cond1 := cond.And("T_source__in", source).And("T_task_id", T_task_id).And("T_VerifyTemplate_id", T_VerifyTemplate_id)
  242. qs.SetCond((*orm2.Condition)(cond1)).All(&r)
  243. return r
  244. }
  245. func VerifyTemplateMapDataToMap(T []VerifyTemplateMapData) map[string]VerifyTemplateMapData {
  246. maps := make(map[string]VerifyTemplateMapData, len(T))
  247. for _, v := range T {
  248. if _, ok := maps[v.T_VerifyTemplateMap_id]; ok {
  249. continue
  250. }
  251. maps[v.T_VerifyTemplateMap_id] = v
  252. }
  253. return maps
  254. }
  255. // 清除T_value数据
  256. func Clear_VerifyTemplateMapData_T_value(T_task_id, T_VerifyTemplate_id, T_VerifyTemplateMap_id string) (err error) {
  257. o := orm.NewOrm()
  258. qs := o.QueryTable(new(VerifyTemplateMapData))
  259. var r VerifyTemplateMapData
  260. // 创建验证模版数据,有则更新,没有则创建
  261. err = qs.Filter("T_task_id", T_task_id).Filter("T_VerifyTemplate_id", T_VerifyTemplate_id).Filter("T_VerifyTemplateMap_id", T_VerifyTemplateMap_id).One(&r)
  262. if err != nil {
  263. logs.Error(lib.FuncName(), err)
  264. return err
  265. }
  266. r.T_value = ""
  267. _, err = o.Update(&r, "T_value")
  268. if err != nil {
  269. logs.Error(lib.FuncName(), err)
  270. return err
  271. }
  272. return nil
  273. }
  274. func Read_VerifyTemplateMapData_T_name(T_task_id,T_VerifyTemplate_id, T_name string) string {
  275. a_time, err := Read_VerifyTemplateMap_T_name(T_VerifyTemplate_id, T_name)
  276. if err != nil {
  277. return ""
  278. }
  279. serverOrm := orm2.NewOrmUsingDB(conf.Server_AliasName)
  280. var r VerifyTemplateMapData
  281. qs := serverOrm.QueryTable(new(VerifyTemplateMapData))
  282. //err := qs.Filter("T_task_id", T_task_id).Filter("T_State", 1).One(&r)
  283. err = qs.Filter("T_VerifyTemplateMap_id", a_time.T_id).Filter("T_task_id", T_task_id).One(&r)
  284. if err != nil {
  285. return ""
  286. }
  287. return r.T_value
  288. }