report_approve.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531
  1. package report_approve
  2. import (
  3. "eta_gn/eta_api/global"
  4. "eta_gn/eta_api/utils"
  5. "fmt"
  6. "strings"
  7. "time"
  8. "github.com/rdlucklib/rdluck_tools/paging"
  9. )
  10. // ReportApprove 报告审批表
  11. //type ReportApprove struct {
  12. // ReportApproveId int `orm:"column(report_approve_id);pk" description:"审批ID"`
  13. // ReportType int `description:"报告类型:1-中文研报;2-英文研报;3-智能研报"`
  14. // ReportId int `description:"报告ID"`
  15. // ReportTitle string `description:"报告标题"`
  16. // ClassifyFirstId int `description:"一级分类ID"`
  17. // ClassifySecondId int `description:"二级分类ID"`
  18. // ClassifyThirdId int `description:"三级分类ID"`
  19. // State int `description:"审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回"`
  20. // FlowId int `description:"审批流ID"`
  21. // FlowVersion int `description:"审批流版本"`
  22. // StartNodeId int `description:"开始节点ID"`
  23. // CurrNodeId int `description:"当前节点ID"`
  24. // ApplyUserId int `description:"申请人ID"`
  25. // ApplyUserName string `description:"申请人姓名"`
  26. // ApproveRemark string `description:"审批备注"`
  27. // ApproveTime time.Time `description:"审批时间"`
  28. // CreateTime time.Time `description:"创建时间"`
  29. // ModifyTime time.Time `description:"修改时间"`
  30. //}
  31. type ReportApprove struct {
  32. ReportApproveId int `gorm:"primaryKey;column:report_approve_id;type:int(10) unsigned;not null"` // 审批ID
  33. ReportType int `gorm:"column:report_type;type:tinyint(4) unsigned;not null;default:0"` // 报告类型:1-中文研报;2-英文研报;3-智能研报
  34. ReportId int `gorm:"index:idx_report_id;column:report_id;type:int(10) unsigned;not null;default:0"` // 报告Id
  35. ReportTitle string `gorm:"column:report_title;type:varchar(255);not null;default:''"` // 报告标题
  36. ClassifyFirstId int `gorm:"column:classify_first_id;type:int(10) unsigned;not null;default:0"` // 一级分类Id
  37. ClassifySecondId int `gorm:"column:classify_second_id;type:int(10) unsigned;not null;default:0"` // 二级分类Id
  38. State int `gorm:"column:state;type:tinyint(4) unsigned;not null;default:0"` // 审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回
  39. FlowId int `gorm:"column:flow_id;type:int(10) unsigned;not null;default:0"` // 审批流Id
  40. FlowVersion int `gorm:"column:flow_version;type:int(10) unsigned;not null;default:0"` // 审批流版本
  41. StartNodeId int `gorm:"column:start_node_id;type:int(10) unsigned;not null;default:0"` // 开始节点Id
  42. CurrNodeId int `gorm:"column:curr_node_id;type:int(10) unsigned;not null;default:0"` // 当前节点Id
  43. ApplyUserId int `gorm:"index:idx_approve_user_id;column:apply_user_id;type:int(10) unsigned;not null;default:0"` // 申请人Id
  44. ApplyUserName string `gorm:"column:apply_user_name;type:varchar(128);not null;default:''"` // 申请人姓名
  45. ApproveRemark string `gorm:"column:approve_remark;type:varchar(255);not null;default:''"` // 审批备注
  46. ApproveTime time.Time `gorm:"column:approve_time;type:datetime"` // 审批时间
  47. CreateTime time.Time `gorm:"column:create_time;type:datetime"` // 创建时间
  48. ModifyTime time.Time `gorm:"column:modify_time;type:datetime"` // 更新时间
  49. ClassifyThirdId int `gorm:"column:classify_third_id;type:int(10) unsigned;default:0"` // 三级分类Id
  50. }
  51. var ReportApproveCols = struct {
  52. ReportApproveId string
  53. ReportType string
  54. ReportId string
  55. ReportTitle string `description:"报告标题"`
  56. ClassifyFirstId string `description:"一级分类ID"`
  57. ClassifySecondId string `description:"二级分类ID"`
  58. ClassifyThirdId string `description:"三级分类ID"`
  59. State string
  60. FlowId string
  61. FlowVersion string
  62. StartNodeId string
  63. CurrNodeId string
  64. ApplyUserId string `description:"申请人ID"`
  65. ApplyUserName string `description:"申请人姓名"`
  66. ApproveRemark string `description:"审批备注"`
  67. ApproveTime string `description:"审批时间"`
  68. CreateTime string
  69. ModifyTime string
  70. }{
  71. ReportApproveId: "report_approve_id",
  72. ReportType: "report_type",
  73. ReportId: "report_id",
  74. ReportTitle: "report_title",
  75. ClassifyFirstId: "classify_first_id",
  76. ClassifySecondId: "classify_second_id",
  77. ClassifyThirdId: "classify_third_id",
  78. State: "state",
  79. FlowId: "flow_id",
  80. FlowVersion: "flow_version",
  81. StartNodeId: "start_node_id",
  82. CurrNodeId: "curr_node_id",
  83. ApplyUserId: "apply_user_id",
  84. ApplyUserName: "apply_user_name",
  85. ApproveRemark: "approve_remark",
  86. ApproveTime: "approve_time",
  87. CreateTime: "create_time",
  88. ModifyTime: "modify_time",
  89. }
  90. func (m *ReportApprove) TableName() string {
  91. return "report_approve"
  92. }
  93. func (m *ReportApprove) PrimaryId() string {
  94. return ReportApproveCols.ReportApproveId
  95. }
  96. func (m *ReportApprove) Create() (err error) {
  97. //o := orm.NewOrmUsingDB("rddp")
  98. //id, err := o.Insert(m)
  99. //if err != nil {
  100. // return
  101. //}
  102. //m.ReportApproveId = int(id)
  103. err = global.DmSQL["rddp"].Create(m).Error
  104. return
  105. }
  106. func (m *ReportApprove) CreateMulti(items []*ReportApprove) (err error) {
  107. if len(items) == 0 {
  108. return
  109. }
  110. //o := orm.NewOrmUsingDB("rddp")
  111. //_, err = o.InsertMulti(len(items), items)
  112. err = global.DmSQL["rddp"].CreateInBatches(items, utils.MultiAddNum).Error
  113. return
  114. }
  115. func (m *ReportApprove) Update(cols []string) (err error) {
  116. //o := orm.NewOrmUsingDB("rddp")
  117. //_, err = o.Update(m, cols...)
  118. err = global.DmSQL["rddp"].Select(cols).Updates(m).Error
  119. return
  120. }
  121. func (m *ReportApprove) Del() (err error) {
  122. //o := orm.NewOrmUsingDB("rddp")
  123. sql := fmt.Sprintf(`DELETE FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  124. //_, err = o.Raw(sql, m.ReportApproveId).Exec()
  125. err = global.DmSQL["rddp"].Exec(sql, m.ReportApproveId).Error
  126. return
  127. }
  128. func (m *ReportApprove) MultiDel(menuIds []int) (err error) {
  129. if len(menuIds) == 0 {
  130. return
  131. }
  132. //o := orm.NewOrmUsingDB("rddp")
  133. sql := fmt.Sprintf(`DELETE FROM %s WHERE %s IN (%s)`, m.TableName(), m.PrimaryId(), utils.GetOrmInReplace(len(menuIds)))
  134. //_, err = o.Raw(sql, menuIds).Exec()
  135. err = global.DmSQL["rddp"].Exec(sql, menuIds).Error
  136. return
  137. }
  138. func (m *ReportApprove) GetItemById(id int) (item *ReportApprove, err error) {
  139. //o := orm.NewOrmUsingDB("rddp")
  140. sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  141. //err = o.Raw(sql, id).QueryRow(&item)
  142. err = global.DmSQL["rddp"].Raw(sql, id).First(&item).Error
  143. return
  144. }
  145. func (m *ReportApprove) GetItemByCondition(condition string, pars []interface{}, orderRule string) (item *ReportApprove, err error) {
  146. //o := orm.NewOrmUsingDB("rddp")
  147. order := ``
  148. if orderRule != "" {
  149. order = ` ORDER BY ` + orderRule
  150. }
  151. sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s %s LIMIT 1`, m.TableName(), condition, order)
  152. //err = o.Raw(sql, pars).QueryRow(&item)
  153. err = global.DmSQL["rddp"].Raw(sql, pars).First(&item).Error
  154. return
  155. }
  156. func (m *ReportApprove) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
  157. //o := orm.NewOrmUsingDB("rddp")
  158. sql := fmt.Sprintf(`SELECT COUNT(1) FROM %s WHERE 1=1 %s`, m.TableName(), condition)
  159. //err = o.Raw(sql, pars).QueryRow(&count)
  160. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  161. return
  162. }
  163. func (m *ReportApprove) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*ReportApprove, err error) {
  164. //o := orm.NewOrmUsingDB("rddp")
  165. fields := strings.Join(fieldArr, ",")
  166. if len(fieldArr) == 0 {
  167. fields = `*`
  168. }
  169. order := `ORDER BY create_time DESC`
  170. if orderRule != "" {
  171. order = ` ORDER BY ` + orderRule
  172. }
  173. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
  174. //_, err = o.Raw(sql, pars).QueryRows(&items)
  175. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  176. return
  177. }
  178. func (m *ReportApprove) GetPageItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, startSize, pageSize int) (items []*ReportApprove, err error) {
  179. //o := orm.NewOrmUsingDB("rddp")
  180. fields := strings.Join(fieldArr, ",")
  181. if len(fieldArr) == 0 {
  182. fields = `*`
  183. }
  184. order := `ORDER BY create_time DESC`
  185. if orderRule != "" {
  186. order = ` ORDER BY ` + orderRule
  187. }
  188. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s LIMIT ?,?`, fields, m.TableName(), condition, order)
  189. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  190. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  191. return
  192. }
  193. // ReportApproveItem 报告审批信息
  194. type ReportApproveItem struct {
  195. ReportApproveId int `description:"审批ID"`
  196. ReportApproveRecordId int `description:"审批记录ID"`
  197. ReportType int `description:"报告类型:1-中文研报;2-英文研报;3-智能研报"`
  198. ReportId int `description:"报告ID"`
  199. ReportTitle string `description:"报告标题"`
  200. ReportClassify string `description:"报告分类"`
  201. ClassifyFirstId int `description:"一级分类ID"`
  202. ClassifySecondId int `description:"二级分类ID"`
  203. ClassifyThirdId int `description:"三级级分类ID"`
  204. State int `description:"审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回"`
  205. RecordState int `description:"审批记录状态:1-待审批;2-已通过;3-已驳回"`
  206. FlowId int `description:"审批流ID"`
  207. FlowVersion int `description:"审批流版本"`
  208. StartNodeId int `description:"开始节点ID"`
  209. CurrNodeId int `description:"当前节点ID"`
  210. ApplyUserId int `description:"申请人ID"`
  211. ApplyUserName string `description:"申请人姓名"`
  212. ApproveRemark string `description:"审批备注"`
  213. ApproveTime string `description:"审批时间"`
  214. HandleTime string `description:"处理时间"`
  215. CreateTime string `description:"创建时间"`
  216. ModifyTime string `description:"修改时间"`
  217. DetailImgUrl string `description:"报告详情长图地址"`
  218. DetailPdfUrl string `description:"报告详情PDF地址"`
  219. }
  220. // FormatReportApproveOrm2Item 格式化报告审批
  221. func FormatReportApproveOrm2Item(origin *ReportApproveItemOrm) (item *ReportApproveItem) {
  222. item = new(ReportApproveItem)
  223. if origin == nil {
  224. return
  225. }
  226. item.ReportApproveId = origin.ReportApproveId
  227. item.ReportApproveRecordId = origin.ReportApproveRecordId
  228. item.ReportType = origin.ReportType
  229. item.ReportId = origin.ReportId
  230. item.ReportTitle = origin.ReportTitle
  231. item.ClassifyFirstId = origin.ClassifyFirstId
  232. item.ClassifySecondId = origin.ClassifySecondId
  233. item.ClassifyThirdId = origin.ClassifyThirdId
  234. item.State = origin.State
  235. item.RecordState = origin.RecordState
  236. item.FlowId = origin.FlowId
  237. item.FlowVersion = origin.FlowVersion
  238. item.StartNodeId = origin.StartNodeId
  239. item.CurrNodeId = origin.CurrNodeId
  240. item.ApplyUserId = origin.ApplyUserId
  241. item.ApplyUserName = origin.ApplyUserName
  242. item.ApproveRemark = origin.ApproveRemark
  243. item.ApproveTime = utils.TimeTransferString(utils.FormatDateTime, origin.ApproveTime)
  244. item.HandleTime = utils.TimeTransferString(utils.FormatDateTime, origin.HandleTime)
  245. item.CreateTime = utils.TimeTransferString(utils.FormatDateTime, origin.CreateTime)
  246. item.ModifyTime = utils.TimeTransferString(utils.FormatDateTime, origin.ModifyTime)
  247. return
  248. }
  249. // ReportApproveListReq 审批列表请求体
  250. type ReportApproveListReq struct {
  251. PageSize int `form:"PageSize"`
  252. CurrentIndex int `form:"CurrentIndex"`
  253. ListType int `form:"ListType" description:"列表类型:1-待处理;2-已处理;3-我发起的"`
  254. ReportType int `form:"ReportType" description:"报告类型:1-中文研报;2-英文研报;3-智能研报"`
  255. ClassifyFirstId int `form:"ClassifyFirstId" description:"一级分类ID"`
  256. ClassifySecondId int `form:"ClassifySecondId" description:"二级分类ID"`
  257. ClassifyThirdId int `form:"ClassifyThirdId" description:"三级级分类ID"`
  258. Keyword string `form:"Keyword" description:"关键词:报告标题"`
  259. ApproveState int `form:"ApproveState" description:"审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回"`
  260. TimeType int `form:"TimeType" description:"时间类型:1-提交时间;2-处理时间;3-审批时间"`
  261. StartTime string `form:"StartTime" description:"开始时间"`
  262. EndTime string `form:"EndTime" description:"结束时间"`
  263. SortField int `form:"SortField" description:"排序字段:1-提交时间;2-处理时间;3-审批时间"`
  264. SortRule int `form:"SortRule" description:"排序方式: 1-正序; 2-倒序(默认)"`
  265. }
  266. // ReportApproveListResp 审批列表响应体
  267. type ReportApproveListResp struct {
  268. List []*ReportApproveItem
  269. Paging *paging.PagingItem `description:"分页数据"`
  270. }
  271. type ReportApproveItemOrm struct {
  272. ReportApproveId int `description:"审批ID"`
  273. ReportApproveRecordId int `description:"审批记录ID"`
  274. ReportType int `description:"报告类型:1-中文研报;2-英文研报;3-智能研报"`
  275. ReportId int `description:"报告ID"`
  276. ReportTitle string `description:"报告标题"`
  277. ClassifyFirstId int `description:"一级分类ID"`
  278. ClassifySecondId int `description:"二级分类ID"`
  279. ClassifyThirdId int `description:"三级级分类ID"`
  280. State int `description:"审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回"`
  281. RecordState int `description:"审批记录状态:1-待审批;2-已通过;3-已驳回"`
  282. FlowId int `description:"审批流ID"`
  283. FlowVersion int `description:"审批流版本"`
  284. StartNodeId int `description:"开始节点ID"`
  285. CurrNodeId int `description:"当前节点ID"`
  286. ApplyUserId int `description:"申请人ID"`
  287. ApplyUserName string `description:"申请人姓名"`
  288. ApproveRemark string `description:"审批备注"`
  289. ApproveTime time.Time `description:"审批时间"`
  290. HandleTime time.Time `description:"处理时间"`
  291. CreateTime time.Time `description:"创建时间"`
  292. ModifyTime time.Time `description:"修改时间"`
  293. NodeState int `description:"当前节点审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回" json:"-"`
  294. NodeApproveTime time.Time `description:"当前节点审批时间" json:"-"`
  295. }
  296. // GetApprovingReportApproveCount 获取待处理的审批分页列表总数
  297. func GetApprovingReportApproveCount(cond string, pars []interface{}) (count int, err error) {
  298. //o := orm.NewOrmUsingDB("rddp")
  299. base := fmt.Sprintf(`SELECT a.report_approve_record_id
  300. FROM report_approve_record AS a
  301. JOIN report_approve AS b ON a.report_approve_id = b.report_approve_id AND a.node_id = b.curr_node_id
  302. WHERE 1 = 1 %s`, cond)
  303. sql := fmt.Sprintf(`SELECT COUNT(1) FROM (%s) t`, base)
  304. //err = o.Raw(sql, pars).QueryRow(&count)
  305. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  306. return
  307. }
  308. // GetApprovingReportApprovePageList 获取待处理的审批列表-分页
  309. func GetApprovingReportApprovePageList(cond string, pars []interface{}, orderRule string, startSize, pageSize int) (items []*ReportApproveItemOrm, err error) {
  310. //o := orm.NewOrmUsingDB("rddp")
  311. order := `ORDER BY a.create_time DESC`
  312. if orderRule != "" {
  313. order = ` ORDER BY ` + orderRule
  314. }
  315. sql := fmt.Sprintf(`SELECT a.report_approve_record_id, a.state AS record_state, b.*
  316. FROM report_approve_record AS a
  317. JOIN report_approve AS b ON a.report_approve_id = b.report_approve_id AND a.node_id = b.curr_node_id
  318. WHERE 1 = 1 %s %s
  319. LIMIT ?,?`, cond, order)
  320. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  321. pars = append(pars, startSize, pageSize)
  322. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  323. return
  324. }
  325. // GetApprovedReportApproveCount 获取已处理的审批分页列表总数
  326. func GetApprovedReportApproveCount(cond string, pars []interface{}) (count int, err error) {
  327. //o := orm.NewOrmUsingDB("rddp")
  328. base := fmt.Sprintf(`SELECT a.report_approve_record_id
  329. FROM report_approve_record AS a
  330. JOIN report_approve AS b ON a.report_approve_id = b.report_approve_id
  331. WHERE 1 = 1 %s`, cond)
  332. sql := fmt.Sprintf(`SELECT COUNT(1) FROM (%s) t`, base)
  333. //err = o.Raw(sql, pars).QueryRow(&count)
  334. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  335. return
  336. }
  337. // GetApprovedReportApprovePageList 获取已处理的审批列表-分页
  338. func GetApprovedReportApprovePageList(cond string, pars []interface{}, orderRule string, startSize, pageSize int) (items []*ReportApproveItemOrm, err error) {
  339. //o := orm.NewOrmUsingDB("rddp")
  340. order := `ORDER BY a.create_time DESC`
  341. if orderRule != "" {
  342. order = ` ORDER BY ` + orderRule
  343. }
  344. sql := fmt.Sprintf(`SELECT a.report_approve_record_id, a.node_state AS record_state,a.node_state,a.node_approve_time, a.node_approve_time AS handle_time, b.*
  345. FROM report_approve_record AS a
  346. JOIN report_approve AS b ON a.report_approve_id = b.report_approve_id
  347. WHERE 1 = 1 %s %s
  348. LIMIT ?,?`, cond, order)
  349. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  350. pars = append(pars, startSize, pageSize)
  351. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  352. return
  353. }
  354. // GetApplyReportApproveCount 获取我发起的审批分页列表总数
  355. func GetApplyReportApproveCount(cond string, pars []interface{}) (count int, err error) {
  356. //o := orm.NewOrmUsingDB("rddp")
  357. base := fmt.Sprintf(`SELECT a.* FROM report_approve AS a WHERE 1 = 1 %s`, cond)
  358. sql := fmt.Sprintf(`SELECT COUNT(1) FROM (%s) t`, base)
  359. //err = o.Raw(sql, pars).QueryRow(&count)
  360. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  361. return
  362. }
  363. // GetApplyReportApprovePageList 获取我发起的审批列表-分页
  364. func GetApplyReportApprovePageList(cond string, pars []interface{}, orderRule string, startSize, pageSize int) (items []*ReportApproveItemOrm, err error) {
  365. //o := orm.NewOrmUsingDB("rddp")
  366. order := `ORDER BY a.create_time DESC`
  367. if orderRule != "" {
  368. order = ` ORDER BY ` + orderRule
  369. }
  370. sql := fmt.Sprintf(`SELECT a.* FROM report_approve AS a WHERE 1 = 1 %s %s LIMIT ?,?`, cond, order)
  371. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  372. pars = append(pars, startSize)
  373. pars = append(pars, pageSize)
  374. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  375. return
  376. }
  377. // ReportApproveDetail 审批详情信息
  378. type ReportApproveDetail struct {
  379. Report *ReportApproveDetailReport `description:"报告信息"`
  380. Approve *ReportApproveDetailItem `description:"审批信息"`
  381. ApproveFlowNodes []*ReportApproveDetailNodes `description:"审批节点信息"`
  382. //ApproveFlow *ReportApproveFlowItem `description:"审批流信息"`
  383. }
  384. // ReportApproveDetailItem 审批详情-审批信息
  385. type ReportApproveDetailItem struct {
  386. ReportApproveId int `description:"审批ID"`
  387. State int `description:"审批状态:1-待审批;2-已审批;3-已驳回;4-已撤回"`
  388. FlowId int `description:"审批流ID"`
  389. FlowVersion int `description:"审批流版本"`
  390. StartNodeId int `description:"开始节点ID"`
  391. CurrNodeId int `description:"当前节点ID"`
  392. ApplyUserId int `description:"申请人ID"`
  393. ApplyUserName string `description:"申请人姓名"`
  394. ApproveTime string `description:"审批时间"`
  395. CreateTime string `description:"创建时间"`
  396. ModifyTime string `description:"修改时间"`
  397. }
  398. // ReportApproveDetailReport 审批详情-报告信息
  399. type ReportApproveDetailReport struct {
  400. ReportType int `description:"报告类型:1-中文研报;2-英文研报;3-智能研报"`
  401. ReportId int `description:"报告ID"`
  402. ReportTitle string `description:"报告标题"`
  403. ReportCode string `description:"报告code"`
  404. ReportClassify string `description:"报告分类"`
  405. ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  406. //ClassifyFirstId int `description:"一级分类ID"`
  407. //ClassifySecondId int `description:"二级分类ID"`
  408. //Content string `description:"报告内容"`
  409. }
  410. // CreateApproveAndRecord 新增审批和记录
  411. func (m *ReportApprove) CreateApproveAndRecord(approveItem *ReportApprove, recordItems []*ReportApproveRecord) (err error) {
  412. if approveItem == nil {
  413. err = fmt.Errorf("approve is nil")
  414. return
  415. }
  416. //o := orm.NewOrmUsingDB("rddp")
  417. //tx, e := o.Begin()
  418. //if e != nil {
  419. // err = fmt.Errorf("orm begin err: %s", e.Error())
  420. // return
  421. //}
  422. //defer func() {
  423. // if err != nil {
  424. // _ = tx.Rollback()
  425. // return
  426. // }
  427. // _ = tx.Commit()
  428. //}()
  429. //
  430. //lastId, e := tx.Insert(approveItem)
  431. //if e != nil {
  432. // err = fmt.Errorf("insert approve err: %s", e.Error())
  433. // return
  434. //}
  435. //approveItem.ReportApproveId = int(lastId)
  436. //
  437. //if len(recordItems) > 0 {
  438. // for _, v := range recordItems {
  439. // v.ReportApproveId = approveItem.ReportApproveId
  440. // }
  441. // _, e = tx.InsertMulti(len(recordItems), recordItems)
  442. // if e != nil {
  443. // err = fmt.Errorf("insert records err: %s", e.Error())
  444. // return
  445. // }
  446. //}
  447. tx := global.DmSQL["data"].Begin()
  448. defer func() {
  449. if err != nil {
  450. _ = tx.Rollback()
  451. return
  452. }
  453. _ = tx.Commit()
  454. }()
  455. e := tx.Create(approveItem).Error
  456. if e != nil {
  457. err = fmt.Errorf("insert approve err: %v", e)
  458. return
  459. }
  460. if len(recordItems) > 0 {
  461. for _, v := range recordItems {
  462. v.ReportApproveId = approveItem.ReportApproveId
  463. }
  464. e = tx.CreateInBatches(recordItems, utils.MultiAddNum).Error
  465. if e != nil {
  466. err = fmt.Errorf("insert records err: %v", e)
  467. return
  468. }
  469. }
  470. return
  471. }
  472. // ReportApprovePassReq 审批通过请求体
  473. type ReportApprovePassReq struct {
  474. ReportApproveId int `description:"审批ID"`
  475. ReportUrl string `description:"报告URL"`
  476. }
  477. // ReportApproveRefuseReq 审批驳回请求体
  478. type ReportApproveRefuseReq struct {
  479. ReportApproveId int `description:"审批ID"`
  480. ApproveRemark string `description:"驳回理由"`
  481. }
  482. // ReportApproveCancelReq 撤销审批请求体
  483. type ReportApproveCancelReq struct {
  484. ReportApproveId int `description:"审批ID"`
  485. }
  486. // ReportApproveCheckApproveOpenReq 校验分类是否打开审批请求体
  487. type ReportApproveCheckApproveOpenReq struct {
  488. ReportType int `description:"报告类型:1-中文研报;2-英文研报;3-智能研报"`
  489. ClassifyFirstId int `description:"一级分类ID"`
  490. ClassifySecondId int `description:"二级分类ID"`
  491. ClassifyThirdId int `description:"三级分类ID"`
  492. }