english_report.go 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707
  1. package tables
  2. import (
  3. "errors"
  4. "github.com/beego/beego/v2/client/orm"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hongze_open_api/utils"
  7. "strings"
  8. "time"
  9. )
  10. type EnglishReport struct {
  11. Id int `orm:"column(id)" description:"报告Id"`
  12. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  13. ClassifyIdFirst int `description:"一级分类id"`
  14. ClassifyNameFirst string `description:"一级分类名称"`
  15. ClassifyIdSecond int `description:"二级分类id"`
  16. ClassifyNameSecond string `description:"二级分类名称"`
  17. Title string `description:"标题"`
  18. Abstract string `description:"摘要"`
  19. Author string `description:"作者"`
  20. Frequency string `description:"频度"`
  21. CreateTime string `description:"创建时间"`
  22. ModifyTime time.Time `description:"修改时间"`
  23. State int `description:"1:未发布,2:已发布"`
  24. PublishTime time.Time `description:"发布时间"`
  25. Stage int `description:"期数"`
  26. Content string `description:"内容"`
  27. VideoUrl string `description:"音频文件URL"`
  28. VideoName string `description:"音频文件名称"`
  29. VideoPlaySeconds string `description:"音频播放时长"`
  30. VideoSize string `description:"音频文件大小,单位M"`
  31. ContentSub string `description:"内容前两个章节"`
  32. ReportCode string `description:"报告唯一编码"`
  33. Pv int `description:"Pv"`
  34. PvEmail int `description:"邮箱PV"`
  35. EmailState int `description:"群发邮件状态: 0-未发送; 1-已发送"`
  36. Overview string `description:"英文概述部分"`
  37. KeyTakeaways string `description:"关键点"`
  38. FromReportId int `description:"继承的报告ID(英文策略报告ID)"`
  39. }
  40. func GetEnglishReportStage(classifyIdFirst, classifyIdSecond int) (count int, err error) {
  41. o := orm.NewOrmUsingDB("rddp")
  42. sql := ``
  43. if classifyIdSecond > 0 {
  44. sql = "SELECT MAX(stage) AS max_stage FROM english_report WHERE classify_id_second=? "
  45. o.Raw(sql, classifyIdSecond).QueryRow(&count)
  46. } else {
  47. sql = "SELECT MAX(stage) AS max_stage FROM english_report WHERE classify_id_first=? "
  48. o.Raw(sql, classifyIdFirst).QueryRow(&count)
  49. }
  50. return
  51. }
  52. func GetEnglishReportStageEdit(classifyIdFirst, classifyIdSecond, reportId int) (count int, err error) {
  53. o := orm.NewOrmUsingDB("rddp")
  54. sql := ``
  55. if classifyIdSecond > 0 {
  56. sql = "SELECT MAX(stage) AS max_stage FROM english_report WHERE classify_id_second=? AND id<>? "
  57. o.Raw(sql, classifyIdSecond, reportId).QueryRow(&count)
  58. } else {
  59. sql = "SELECT MAX(stage) AS max_stage FROM english_report WHERE classify_id_first=? AND id<>? "
  60. o.Raw(sql, classifyIdFirst, reportId).QueryRow(&count)
  61. }
  62. return
  63. }
  64. func AddEnglishReport(item *EnglishReport) (lastId int64, err error) {
  65. o := orm.NewOrmUsingDB("rddp")
  66. lastId, err = o.Insert(item)
  67. return
  68. }
  69. func ModifyEnglishReportCode(reportId int64, reportCode string) (err error) {
  70. o := orm.NewOrmUsingDB("rddp")
  71. sql := `UPDATE english_report SET report_code=? WHERE id=? `
  72. _, err = o.Raw(sql, reportCode, reportId).Exec()
  73. return
  74. }
  75. type AddEnglishReportReq struct {
  76. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  77. ClassifyIdFirst int `description:"一级分类id"`
  78. ClassifyNameFirst string `description:"一级分类名称"`
  79. ClassifyIdSecond int `description:"二级分类id"`
  80. ClassifyNameSecond string `description:"二级分类名称"`
  81. Title string `description:"标题"`
  82. Abstract string `description:"摘要"`
  83. Author string `description:"作者"`
  84. Frequency string `description:"频度"`
  85. State int `description:"状态:1:未发布,2:已发布"`
  86. Content string `description:"内容"`
  87. CreateTime string `description:"创建时间"`
  88. Overview string `description:"英文概述部分"`
  89. }
  90. type AddEnglishReportResp struct {
  91. ReportId int64 `description:"报告id"`
  92. ReportCode string `description:"报告code"`
  93. }
  94. type EditEnglishReportReq struct {
  95. ReportId int64 `description:"报告id"`
  96. ClassifyIdFirst int `description:"一级分类id"`
  97. ClassifyNameFirst string `description:"一级分类名称"`
  98. ClassifyIdSecond int `description:"二级分类id"`
  99. ClassifyNameSecond string `description:"二级分类名称"`
  100. Title string `description:"标题"`
  101. Abstract string `description:"摘要"`
  102. Author string `description:"作者"`
  103. Frequency string `description:"频度"`
  104. State int `description:"状态:1:未发布,2:已发布"`
  105. Content string `description:"内容"`
  106. CreateTime string `description:"创建时间"`
  107. Overview string `description:"英文概述部分"`
  108. }
  109. type EditEnglishReportFromPolicyReq struct {
  110. ReportId int64 `description:"报告id"`
  111. Title string `description:"标题"`
  112. Abstract string `description:"摘要"`
  113. Author string `description:"作者"`
  114. Frequency string `description:"频度"`
  115. CreateTime string `description:"创建时间"`
  116. //Overview string `description:"英文概述部分"`
  117. }
  118. type EditEnglishReportResp struct {
  119. ReportId int64 `description:"报告id"`
  120. ReportCode string `description:"报告code"`
  121. }
  122. type ElasticEnglishReportDetail struct {
  123. Id string `description:"报告id或者线上路演Id"`
  124. ReportId int `description:"报告id"`
  125. VideoId int `description:"线上路演Id"`
  126. ClassifyIdFirst int `description:"一级分类id"`
  127. ClassifyNameFirst string `description:"一级分类名称"`
  128. ClassifyIdSecond int `description:"二级分类id"`
  129. ClassifyNameSecond string `description:"二级分类名称"`
  130. StageStr string `description:"报告期数"`
  131. Title string `description:"标题"`
  132. Abstract string `description:"摘要"`
  133. Author string `description:"作者"`
  134. Frequency string `description:"频度"`
  135. PublishState int `description:"状态:1:未发布,2:已发布"`
  136. BodyContent string `description:"内容"`
  137. ContentSub string `description:"前两段内容"`
  138. CreateTime string `description:"创建时间"`
  139. PublishTime string `description:"发布时间"`
  140. ReportCode string `description:"报告唯一编码"`
  141. Overview string `description:"英文概述部分"`
  142. }
  143. func EditEnglishReport(item *EnglishReport, reportId int64) (err error) {
  144. o := orm.NewOrmUsingDB("rddp")
  145. sql := `UPDATE english_report
  146. SET
  147. classify_id_first =?,
  148. classify_name_first = ?,
  149. classify_id_second = ?,
  150. classify_name_second = ?,
  151. title = ?,
  152. abstract = ?,
  153. author = ?,
  154. frequency = ?,
  155. state = ?,
  156. content = ?,
  157. content_sub = ?,
  158. stage =?,
  159. create_time = ?,
  160. modify_time = ?,
  161. overview = ?
  162. WHERE id = ? `
  163. _, err = o.Raw(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
  164. item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), item.Overview, reportId).Exec()
  165. return
  166. }
  167. type EnglishReportDetail struct {
  168. Id int `orm:"column(id)" description:"报告Id"`
  169. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  170. ClassifyIdFirst int `description:"一级分类id"`
  171. ClassifyNameFirst string `description:"一级分类名称"`
  172. ClassifyIdSecond int `description:"二级分类id"`
  173. ClassifyNameSecond string `description:"二级分类名称"`
  174. Title string `description:"标题"`
  175. Abstract string `description:"摘要"`
  176. Author string `description:"作者"`
  177. Frequency string `description:"频度"`
  178. CreateTime string `description:"创建时间"`
  179. ModifyTime string `description:"修改时间"`
  180. State int `description:"1:未发布,2:已发布"`
  181. PublishTime string `description:"发布时间"`
  182. Stage int `description:"期数"`
  183. MsgIsSend int `description:"消息是否已发送,0:否,1:是"`
  184. ReportCode string `description:"报告唯一编码"`
  185. Content string `description:"内容"`
  186. VideoUrl string `description:"音频文件URL"`
  187. VideoName string `description:"音频文件名称"`
  188. VideoPlaySeconds string `description:"音频播放时长"`
  189. ContentSub string `description:"内容前两个章节"`
  190. Pv int `description:"Pv"`
  191. Overview string `description:"英文概述部分"`
  192. FromReportId int `description:"继承的报告ID(英文策略报告ID)"`
  193. KeyTakeaways string `description:"关键点"`
  194. }
  195. func GetEnglishReportById(reportId int) (item *EnglishReportDetail, err error) {
  196. o := orm.NewOrmUsingDB("rddp")
  197. sql := `SELECT * FROM english_report WHERE id=?`
  198. err = o.Raw(sql, reportId).QueryRow(&item)
  199. return
  200. }
  201. func GetEnglishReportItemById(reportId int) (item *EnglishReport, err error) {
  202. o := orm.NewOrmUsingDB("rddp")
  203. sql := `SELECT * FROM english_report WHERE id = ? LIMIT 1`
  204. err = o.Raw(sql, reportId).QueryRow(&item)
  205. return
  206. }
  207. type EnglishReportList struct {
  208. Id int `description:"报告Id"`
  209. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  210. ClassifyIdFirst int `description:"一级分类id"`
  211. ClassifyNameFirst string `description:"一级分类名称"`
  212. ClassifyIdSecond int `description:"二级分类id"`
  213. ClassifyNameSecond string `description:"二级分类名称"`
  214. Title string `description:"标题"`
  215. Abstract string `description:"摘要"`
  216. Author string `description:"作者"`
  217. Frequency string `description:"频度"`
  218. CreateTime string `description:"创建时间"`
  219. ModifyTime time.Time `description:"修改时间"`
  220. State int `description:"1:未发布,2:已发布"`
  221. PublishTime string `description:"发布时间"`
  222. Stage int `description:"期数"`
  223. Content string `description:"内容"`
  224. VideoUrl string `description:"音频文件URL"`
  225. VideoName string `description:"音频文件名称"`
  226. VideoPlaySeconds string `description:"音频播放时长"`
  227. ContentSub string `description:"内容前两个章节"`
  228. ReportCode string `description:"报告唯一编码"`
  229. Pv int `description:"Pv"`
  230. ShareUrl string `description:"分享url"`
  231. PvEmail int `description:"邮箱PV"`
  232. EmailState int `description:"群发邮件状态: 0-未发送; 1-已发送"`
  233. EmailAuth bool `description:"是否有权限群发邮件"`
  234. EmailHasFail bool `description:"是否存在邮件发送失败的记录"`
  235. CanEdit bool `description:"是否可编辑"`
  236. Editor string `description:"编辑人"`
  237. FromReportId int `description:"继承的报告ID(英文策略报告ID)"`
  238. }
  239. type EnglishReportListResp struct {
  240. List []*EnglishReportList
  241. Paging *paging.PagingItem `description:"分页数据"`
  242. }
  243. func GetEnglishReportListCount(condition string, pars []interface{}, companyType string) (count int, err error) {
  244. //产品权限
  245. companyTypeSqlStr := ``
  246. if companyType == "ficc" {
  247. companyTypeSqlStr = " AND classify_id_first != 40 "
  248. } else if companyType == "权益" {
  249. companyTypeSqlStr = " AND classify_id_first = 40 "
  250. }
  251. oRddp := orm.NewOrmUsingDB("rddp")
  252. sql := `SELECT COUNT(1) AS count FROM english_report WHERE 1=1 ` + companyTypeSqlStr
  253. if condition != "" {
  254. sql += condition
  255. }
  256. err = oRddp.Raw(sql, pars).QueryRow(&count)
  257. return
  258. }
  259. func GetEnglishReportList(condition string, pars []interface{}, companyType string, startSize, pageSize int) (items []*EnglishReportList, err error) {
  260. o := orm.NewOrmUsingDB("rddp")
  261. //产品权限
  262. companyTypeSqlStr := ``
  263. if companyType == "ficc" {
  264. companyTypeSqlStr = " AND classify_id_first != 40 "
  265. } else if companyType == "权益" {
  266. companyTypeSqlStr = " AND classify_id_first = 40 "
  267. }
  268. sql := `SELECT *
  269. FROM english_report WHERE 1=1 ` + companyTypeSqlStr
  270. if condition != "" {
  271. sql += condition
  272. }
  273. sql += `ORDER BY state ASC, modify_time DESC LIMIT ?,?`
  274. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  275. return
  276. }
  277. func GetEnglishReportByCondition(condition string, pars []interface{}) (items []*EnglishReport, err error) {
  278. o := orm.NewOrmUsingDB("rddp")
  279. sql := `SELECT *
  280. FROM english_report WHERE 1=1 `
  281. if condition != "" {
  282. sql += condition
  283. }
  284. _, err = o.Raw(sql, pars).QueryRows(&items)
  285. return
  286. }
  287. // 发布报告
  288. func PublishEnglishReportById(reportId int) (err error) {
  289. o := orm.NewOrmUsingDB("rddp")
  290. sql := `UPDATE english_report SET state=2,publish_time=now(),modify_time=NOW() WHERE id = ? `
  291. _, err = o.Raw(sql, reportId).Exec()
  292. return
  293. }
  294. //取消发布报告
  295. func PublishCancelEnglishReport(reportIds int) (err error) {
  296. o := orm.NewOrmUsingDB("rddp")
  297. sql := ` UPDATE english_report SET state=1,publish_time=null WHERE id =? `
  298. _, err = o.Raw(sql, reportIds).Exec()
  299. return
  300. }
  301. // DeleteEnglishReportAndChapter 删除报告及章节
  302. func DeleteEnglishReportAndChapter(reportInfo *EnglishReportDetail) (err error) {
  303. reportId := reportInfo.Id
  304. if reportInfo.State == 2 {
  305. err = errors.New("报告已发布,不可删除")
  306. return
  307. }
  308. err = DeleteEnglishReport(reportId)
  309. if err != nil {
  310. err = errors.New("删除失败, Err: " + err.Error())
  311. return
  312. }
  313. return
  314. }
  315. //删除报告
  316. func DeleteEnglishReport(reportIds int) (err error) {
  317. o := orm.NewOrmUsingDB("rddp")
  318. sql := ` DELETE FROM english_report WHERE id =? `
  319. _, err = o.Raw(sql, reportIds).Exec()
  320. return
  321. }
  322. func EditEnglishReportContent(reportId int, content, contentSub string) (err error) {
  323. o := orm.NewOrmUsingDB("rddp")
  324. sql := ` UPDATE english_report SET content=?,content_sub=?,modify_time=NOW() WHERE id=? `
  325. _, err = o.Raw(sql, content, contentSub, reportId).Exec()
  326. return
  327. }
  328. func AddEnglishReportSaveLog(reportId, adminId int, content, contentSub, adminName string) (err error) {
  329. o := orm.NewOrmUsingDB("rddp")
  330. sql := ` INSERT INTO english_report_save_log(report_id, content,content_sub,admin_id,admin_name) VALUES (?,?,?,?,?) `
  331. _, err = o.Raw(sql, reportId, content, contentSub, adminId, adminName).Exec()
  332. return
  333. }
  334. type EnglishClassifyList struct {
  335. Id int `orm:"column(id);pk"`
  336. ClassifyName string `description:"分类名称"`
  337. Sort int `description:"排序"`
  338. ParentId int `description:"父级分类id"`
  339. CreateTime time.Time `description:"创建时间"`
  340. ModifyTime time.Time `description:"修改时间"`
  341. ClassifyLabel string `description:"分类标签"`
  342. ShowType int `description:"展示类型:1-列表 2-专栏"`
  343. IsShow int `description:"是否在小程序显示:1-显示 0-隐藏"`
  344. ClassifyType int `description:"分类类型:0英文报告,1英文线上路演"`
  345. Child []*EnglishClassify
  346. }
  347. type EnglishClassifyListResp struct {
  348. List []*EnglishClassifyList
  349. Paging *paging.PagingItem `description:"分页数据"`
  350. }
  351. //获取分类列表
  352. func GetEnglishClassifyList(startSize, pageSize int, keyWord string, classifyType int) (items []*EnglishClassifyList, err error) {
  353. sql := ``
  354. o := orm.NewOrmUsingDB("rddp")
  355. if keyWord != "" {
  356. sql = `SELECT * FROM (
  357. SELECT * FROM english_classify
  358. WHERE parent_id=0 AND classify_name LIKE '%` + keyWord + `%' AND classify_type = ?
  359. UNION
  360. SELECT * FROM english_classify
  361. WHERE id IN(SELECT parent_id FROM english_classify
  362. WHERE parent_id>0 AND classify_name LIKE '%` + keyWord + `%') AND classify_type = ?
  363. )AS t
  364. ORDER BY sort ASC,create_time ASC
  365. LIMIT ?,? `
  366. _, err = o.Raw(sql, classifyType, classifyType, startSize, pageSize).QueryRows(&items)
  367. } else {
  368. sql = `SELECT * FROM english_classify WHERE parent_id=0 AND classify_type = ? ORDER BY sort ASC,create_time ASC LIMIT ?,? `
  369. _, err = o.Raw(sql, classifyType, startSize, pageSize).QueryRows(&items)
  370. }
  371. return
  372. }
  373. func GetEnglishClassifyListCount(keyWord string, classifyType int) (count int, err error) {
  374. sqlCount := ``
  375. o := orm.NewOrmUsingDB("rddp")
  376. if keyWord != "" {
  377. sqlCount = `SELECT COUNT(1) AS count FROM (
  378. SELECT * FROM english_classify
  379. WHERE parent_id=0 AND classify_name LIKE '%` + keyWord + `%' AND classify_type = ?
  380. UNION
  381. SELECT * FROM english_classify
  382. WHERE id IN(SELECT parent_id FROM english_classify
  383. WHERE parent_id>0 AND classify_name LIKE '%` + keyWord + `%' AND classify_type = ?)
  384. )AS t `
  385. err = o.Raw(sqlCount, classifyType, classifyType).QueryRow(&count)
  386. } else {
  387. sqlCount = `SELECT COUNT(1) AS count FROM english_classify WHERE parent_id=0 AND classify_type = ?`
  388. err = o.Raw(sqlCount, classifyType).QueryRow(&count)
  389. }
  390. return
  391. }
  392. func GetEnglishClassifyChild(parentId int, keyWord string, classifyType int) (items []*EnglishClassify, err error) {
  393. o := orm.NewOrmUsingDB("rddp")
  394. sql := ``
  395. if keyWord != "" {
  396. sql = `SELECT * FROM english_classify WHERE parent_id=? AND classify_type = ? AND classify_name LIKE '%` + keyWord + `%' ORDER BY create_time ASC `
  397. } else {
  398. sql = `SELECT * FROM english_classify WHERE parent_id=? AND classify_type = ? ORDER BY create_time ASC `
  399. }
  400. _, err = o.Raw(sql, parentId, classifyType).QueryRows(&items)
  401. return
  402. }
  403. func GetEnglishClassifyChildByParentIds(parentIds []int, keyWord string, classifyType int) (items []*EnglishClassify, err error) {
  404. o := orm.NewOrmUsingDB("rddp")
  405. sql := ``
  406. if keyWord != "" {
  407. sql = `SELECT * FROM english_classify WHERE parent_id IN (` + utils.GetOrmInReplace(len(parentIds)) + `) AND classify_type = ? AND classify_name LIKE '%` + keyWord + `%' ORDER BY create_time ASC `
  408. } else {
  409. sql = `SELECT * FROM english_classify WHERE parent_id IN (` + utils.GetOrmInReplace(len(parentIds)) + `) AND classify_type = ? ORDER BY create_time ASC `
  410. }
  411. _, err = o.Raw(sql, parentIds, classifyType).QueryRows(&items)
  412. return
  413. }
  414. func GetEnglishReportDetailByClassifyId(classifyIdFirst, classifyIdSecond int) (item *EnglishReport, err error) {
  415. o := orm.NewOrmUsingDB("rddp")
  416. sql := ` SELECT * FROM english_report WHERE 1=1 `
  417. if classifyIdSecond > 0 {
  418. sql = sql + ` AND classify_id_second=? ORDER BY stage DESC LIMIT 1`
  419. err = o.Raw(sql, classifyIdSecond).QueryRow(&item)
  420. } else {
  421. sql = sql + ` AND classify_id_first=? ORDER BY stage DESC LIMIT 1`
  422. err = o.Raw(sql, classifyIdFirst).QueryRow(&item)
  423. }
  424. return
  425. }
  426. // Update 更新
  427. func (item *EnglishReport) Update(cols []string) (err error) {
  428. o := orm.NewOrmUsingDB("rddp")
  429. _, err = o.Update(item, cols...)
  430. return
  431. }
  432. // ModifyEnglishReportAuthor 更改英文报告作者
  433. func ModifyEnglishReportAuthor(condition string, pars []interface{}, authorName string) (count int, err error) {
  434. //产品权限
  435. oRddp := orm.NewOrmUsingDB("rddp")
  436. sql := `UPDATE english_report set author = ? WHERE 1=1 `
  437. if condition != "" {
  438. sql += condition
  439. }
  440. err = oRddp.Raw(sql, authorName, pars).QueryRow(&count)
  441. return
  442. }
  443. type EnglishClassify struct {
  444. Id int `orm:"column(id);pk"`
  445. ClassifyName string `description:"分类名称"`
  446. Sort int `description:"排序"`
  447. ParentId int `description:"父级分类id"`
  448. CreateTime time.Time `description:"创建时间"`
  449. ModifyTime time.Time `description:"修改时间"`
  450. ClassifyLabel string `description:"分类标签"`
  451. ShowType int `description:"展示类型:1-列表 2-专栏"`
  452. IsShow int `description:"是否在小程序显示:1-显示 0-隐藏"`
  453. ClassifyType int `description:"分类类型:0英文报告,1英文线上路演"`
  454. }
  455. func AddEnglishClassify(item *EnglishClassify) (lastId int64, err error) {
  456. o := orm.NewOrmUsingDB("rddp")
  457. lastId, err = o.Insert(item)
  458. return
  459. }
  460. func ModifyEnglishClassify(item *EnglishClassify) (err error) {
  461. o := orm.NewOrmUsingDB("rddp")
  462. sql := `UPDATE english_classify
  463. SET
  464. classify_name = ?,
  465. sort = ?,
  466. parent_id = ?,
  467. modify_time = ?
  468. WHERE id = ? `
  469. _, err = o.Raw(sql, item.ClassifyName, item.Sort, item.ParentId, item.ModifyTime, item.Id).Exec()
  470. return
  471. }
  472. // UpdateClassify 更新分类
  473. func (classifyInfo *EnglishClassify) UpdateEnglishClassify(cols []string) (err error) {
  474. o := orm.NewOrmUsingDB("rddp")
  475. _, err = o.Update(classifyInfo, cols...)
  476. return
  477. }
  478. // DeleteEnglishClassify 删除英文分类
  479. func DeleteEnglishClassify(classifyId int) (err error) {
  480. o := orm.NewOrmUsingDB("rddp")
  481. sql := ` DELETE FROM english_classify WHERE id =? `
  482. _, err = o.Raw(sql, classifyId).Exec()
  483. return
  484. }
  485. func GetEnglishClassifyChildCounts(parentId int) (count int, err error) {
  486. o := orm.NewOrmUsingDB("rddp")
  487. sql := `SELECT COUNT(1) AS count FROM english_classify WHERE parent_id=? `
  488. err = o.Raw(sql, parentId).QueryRow(&count)
  489. return
  490. }
  491. func GetEnglishReportCounts(classifyId, parentId int) (count int, err error) {
  492. o := orm.NewOrmUsingDB("rddp")
  493. sql := ``
  494. if parentId == 0 {
  495. sql = `SELECT COUNT(1) AS count FROM english_report WHERE classify_id_first=? `
  496. } else {
  497. sql = `SELECT COUNT(1) AS count FROM english_report WHERE classify_id_second=? `
  498. }
  499. err = o.Raw(sql, classifyId).QueryRow(&count)
  500. return
  501. }
  502. func GetEnglishClassifyCountsByName(name string, parentId int, classifyType int) (count int, err error) {
  503. o := orm.NewOrmUsingDB("rddp")
  504. sql := `SELECT COUNT(1) AS count FROM english_classify WHERE classify_name=? AND parent_id = ? AND classify_type = ? `
  505. err = o.Raw(sql, name, parentId, classifyType).QueryRow(&count)
  506. return
  507. }
  508. //获取分类列表
  509. func GetEnglishFirstClassifyList(classifyType, startSize, pageSize int) (items []*EnglishClassifyList, err error) {
  510. sql := ``
  511. sql = `SELECT * FROM english_classify WHERE parent_id=0 AND classify_type = ? ORDER BY sort ASC,create_time ASC LIMIT ?,? `
  512. o := orm.NewOrmUsingDB("rddp")
  513. _, err = o.Raw(sql, classifyType, startSize, pageSize).QueryRows(&items)
  514. return
  515. }
  516. func GetEnglishFirstClassifyListCount(classifyType int) (count int, err error) {
  517. sqlCount := ``
  518. sqlCount = `SELECT COUNT(1) AS count FROM english_classify WHERE parent_id=0 AND classify_type = ? `
  519. o := orm.NewOrmUsingDB("rddp")
  520. err = o.Raw(sqlCount, classifyType).QueryRow(&count)
  521. return
  522. }
  523. func GetEnglishReportClassifyById(classifyId int) (item *EnglishClassify, err error) {
  524. sql := `SELECT * FROM english_classify WHERE id=?`
  525. o := orm.NewOrmUsingDB("rddp")
  526. err = o.Raw(sql, classifyId).QueryRow(&item)
  527. return
  528. }
  529. func GetEnglishReportClassifyByIds(classifyIds []int) (list []*EnglishClassify, err error) {
  530. o := orm.NewOrmUsingDB("rddp")
  531. sql := `SELECT * FROM english_classify WHERE id IN (` + utils.GetOrmInReplace(len(classifyIds)) + `)`
  532. _, err = o.Raw(sql, classifyIds).QueryRows(&list)
  533. return
  534. }
  535. // UpdateEnglishReportSecondClassifyNameByClassifyId 更新报告分类名称字段
  536. func UpdateEnglishReportSecondClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  537. o := orm.NewOrmUsingDB("rddp")
  538. sql := " UPDATE english_report SET classify_name_second = ? WHERE classify_id_second = ? "
  539. _, err = o.Raw(sql, classifyName, classifyId).Exec()
  540. return
  541. }
  542. // UpdateEnglishReportFirstClassifyNameByClassifyId 更新报告分类名称字段
  543. func UpdateEnglishReportFirstClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  544. o := orm.NewOrmUsingDB("rddp")
  545. sql := " UPDATE english_report SET classify_name_first = ? WHERE classify_id_first = ? "
  546. _, err = o.Raw(sql, classifyName, classifyId).Exec()
  547. return
  548. }
  549. // UpdateEnglishReportFirstClassifyNameByClassifyId 更新报告分类名称字段
  550. func UpdateEnglishReportByClassifyId(classifyFirstName, classifySecondName string, firstClassifyId, secondClassifyId int, ids string) (err error) {
  551. o := orm.NewOrmUsingDB("rddp")
  552. sql := " UPDATE english_report SET classify_name_first = ?,classify_name_second = ?,classify_id_first=?, classify_id_second =? WHERE id IN ("+ids+") "
  553. _, err = o.Raw(sql, classifyFirstName, classifySecondName, firstClassifyId, secondClassifyId).Exec()
  554. return
  555. }
  556. // FetchEnglishReportById 主键获取英文报告
  557. func FetchEnglishReportById(reportId int) (item *EnglishReport, err error) {
  558. o := orm.NewOrmUsingDB("rddp")
  559. sql := `SELECT * FROM english_report WHERE id=?`
  560. err = o.Raw(sql, reportId).QueryRow(&item)
  561. return
  562. }
  563. // UpdateReport 更新英文报告
  564. func (reportInfo *EnglishReport) UpdateReport(cols []string) (err error) {
  565. o := orm.NewOrmUsingDB("rddp")
  566. _, err = o.Update(reportInfo, cols...)
  567. return
  568. }
  569. // GetAllEnglishClassify 获取所有英文分类
  570. func GetAllEnglishClassify(classifyType int) (list []*EnglishClassify, err error) {
  571. o := orm.NewOrmUsingDB("rddp")
  572. sql := ` SELECT * FROM english_classify where classify_type = ? `
  573. _, err = o.Raw(sql, classifyType).QueryRows(&list)
  574. return
  575. }
  576. // GetEnglishReportByIds 根据IDs获取英文报告列表
  577. func GetEnglishReportByIds(reportIds []int, fieldArr []string) (list []*EnglishReport, err error) {
  578. listLen := len(reportIds)
  579. if listLen == 0 {
  580. return
  581. }
  582. fields := ` * `
  583. if len(fieldArr) > 0 {
  584. fields = strings.Join(fieldArr, ",")
  585. }
  586. o := orm.NewOrmUsingDB("rddp")
  587. sql := `SELECT ` + fields + ` FROM english_report WHERE id IN (` + utils.GetOrmInReplace(listLen) + `)`
  588. _, err = o.Raw(sql, reportIds).QueryRows(&list)
  589. return
  590. }
  591. // MarkEditEnReport 标记编辑英文研报的请求数据
  592. type MarkEditEnReport struct {
  593. ReportId int `description:"研报id"`
  594. Status int `description:"标记状态,1:编辑中,2:编辑完成"`
  595. }
  596. type EnglishClassifyNameParentName struct {
  597. Id int `description:"分类ID"`
  598. ClassifyName string `description:"分类名称"`
  599. Sort int `description:"排序"`
  600. ParentId int `description:"父级分类id"`
  601. CreateTime time.Time `description:"创建时间"`
  602. ModifyTime time.Time `description:"修改时间"`
  603. ClassifyLabel string `description:"分类标签"`
  604. ShowType int `description:"展示类型:1-列表 2-专栏"`
  605. IsShow int `description:"是否在小程序显示:1-显示 0-隐藏"`
  606. ParentClassifyName string `description:"父级分类名称"`
  607. }
  608. func GetEnglishClassifyByClassifyNameAndParentName(parentClassiyName, classifyName string) (item EnglishClassifyNameParentName, err error) {
  609. o := orm.NewOrmUsingDB("rddp")
  610. sql := "SELECT c1.*, c2.classify_name as parent_classify_name FROM english_classify c1 LEFT JOIN english_classify c2 on c1.parent_id = c2.id where c1.parent_id > 0 and c2.classify_name = ? and c1.classify_name= ?"
  611. err = o.Raw(sql, parentClassiyName, classifyName).QueryRow(&item)
  612. return
  613. }
  614. type RSClassifyList []*EnglishClassifyList
  615. func (m RSClassifyList) Len() int {
  616. return len(m)
  617. }
  618. func (m RSClassifyList) Less(i, j int) bool {
  619. return m[i].Sort < m[j].Sort
  620. }
  621. func (m RSClassifyList) Swap(i, j int) {
  622. m[i], m[j] = m[j], m[i]
  623. }
  624. type RSChildClassifyList []*EnglishClassify
  625. func (m RSChildClassifyList) Len() int {
  626. return len(m)
  627. }
  628. func (m RSChildClassifyList) Less(i, j int) bool {
  629. return m[i].Sort < m[j].Sort
  630. }
  631. func (m RSChildClassifyList) Swap(i, j int) {
  632. m[i], m[j] = m[j], m[i]
  633. }