message.go 8.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "hongze/hongze_mobile_admin/models/response/message"
  6. "hongze/hongze_mobile_admin/models/tables/company_approval"
  7. "hongze/hongze_mobile_admin/models/tables/company_approval_message"
  8. "hongze/hongze_mobile_admin/models/tables/contract_approval"
  9. "hongze/hongze_mobile_admin/models/tables/contract_approval_record"
  10. "hongze/hongze_mobile_admin/utils"
  11. "rdluck_tools/paging"
  12. "strconv"
  13. "strings"
  14. )
  15. //消息模块
  16. type MessageCommon struct {
  17. BaseAuth
  18. }
  19. // @Title 消息列表汇总页
  20. // @Description 消息列表汇总页接口
  21. // @Success 200 {object} message.SummaryMessageListResp
  22. // @router /summaryMessageList [get]
  23. func (this *MessageCommon) SummaryMessageList() {
  24. sysUser := this.AdminWx
  25. sysUserId := sysUser.AdminId
  26. SummaryMessageListResp := message.SummaryMessageListResp{}
  27. sourceTypeList := [...]int{1, 2, 3}
  28. for _, sourceType := range sourceTypeList {
  29. //最近一条消息
  30. tmpMessage := ``
  31. messageInfo, err := company_approval_message.GetLastMessage(sysUserId, sourceType)
  32. if err != nil {
  33. if err.Error() != utils.ErrNoRow() {
  34. this.FailWithMessage("获取失败", "获取消息失败,Err:"+err.Error())
  35. return
  36. }
  37. } else {
  38. tmpMessage = fmt.Sprint(messageInfo.RealName, messageInfo.CreateTime, messageInfo.Content)
  39. }
  40. notReadTotal, err := company_approval_message.GetNotReadMessageTotal(sysUserId, sourceType)
  41. if err != nil {
  42. this.FailWithMessage("获取失败", "获取未读消息数失败,Err:"+err.Error())
  43. return
  44. }
  45. switch sourceType {
  46. case 1:
  47. SummaryMessageListResp.CompanyMessage.Message = tmpMessage
  48. SummaryMessageListResp.CompanyMessage.Total = int(notReadTotal)
  49. case 2:
  50. SummaryMessageListResp.ContractMessage.Message = tmpMessage
  51. SummaryMessageListResp.ContractMessage.Total = int(notReadTotal)
  52. case 3:
  53. SummaryMessageListResp.SealMessage.Message = tmpMessage
  54. SummaryMessageListResp.SealMessage.Total = int(notReadTotal)
  55. }
  56. }
  57. this.OkDetailed(SummaryMessageListResp, "获取成功")
  58. }
  59. // @Title 消息列表
  60. // @Description 消息列表接口
  61. // @Param SourceType query int true "消息类型"
  62. // @Param CurrentIndex query int true "当前页码"
  63. // @Param pageSize query int true "每页数量"
  64. // @Success 200 {object} message.CompanyApprovalMessageListResp
  65. // @router /list [get]
  66. func (this *MessageCommon) MessageList() {
  67. sysUser := this.AdminWx
  68. sysUserId := sysUser.AdminId
  69. sourceType, err := this.GetInt("SourceType", 1)
  70. if err != nil {
  71. this.FailWithMessage("获取失败", "获取消息类型失败,Err:"+err.Error())
  72. return
  73. }
  74. pageSize, _ := this.GetInt("PageSize")
  75. currentIndex, _ := this.GetInt("CurrentIndex")
  76. var startSize int
  77. if pageSize <= 0 {
  78. pageSize = utils.PageSize20
  79. }
  80. if currentIndex <= 0 {
  81. currentIndex = 1
  82. }
  83. startSize = paging.StartIndex(currentIndex, pageSize)
  84. total, err := company_approval_message.GetCompanyApprovalMessageCount(sysUserId, sourceType)
  85. if err != nil {
  86. this.FailWithMessage("获取失败", "获取消息总数失败,Err:"+err.Error())
  87. return
  88. }
  89. list, err := company_approval_message.GetCompanyApprovalMessageList(sysUserId, sourceType, startSize, pageSize)
  90. if err != nil {
  91. this.FailWithMessage("获取失败", "获取消息列表失败,Err:"+err.Error())
  92. return
  93. }
  94. companyApprovalIds := make([]string, 0)
  95. newApprovalRecordIds := make([]string, 0)
  96. companyApprovalMap := make(map[int]*company_approval.CompanyApproval)
  97. newApprovalMap := make(map[int]*contract_approval.ContractApproval)
  98. for _, message := range list {
  99. if message.SourceType == 1 {
  100. companyApprovalIds = append(companyApprovalIds, strconv.Itoa(message.CompanyApprovalId))
  101. } else {
  102. //如果不是文字消息
  103. if message.MessageType != 3 {
  104. newApprovalRecordIds = append(newApprovalRecordIds, strconv.Itoa(message.CompanyApprovalId))
  105. }
  106. }
  107. }
  108. //客户信息
  109. if len(companyApprovalIds) > 0 {
  110. companyApprovalList, err := company_approval.GetApprovalListByApprovalIds(strings.Join(companyApprovalIds, ","))
  111. if err != nil {
  112. this.FailWithMessage("获取失败", "获取申请列表信息失败,Err:"+err.Error())
  113. }
  114. for _, companyApproval := range companyApprovalList {
  115. companyApprovalMap[companyApproval.CompanyApprovalId] = companyApproval
  116. }
  117. }
  118. //新的审批单信息
  119. if len(newApprovalRecordIds) > 0 {
  120. //审批流程单信息
  121. contractApprovalRecordList, err := contract_approval_record.GetContractApprovalRecordByIds(strings.Join(newApprovalRecordIds, ","))
  122. if err != nil {
  123. this.FailWithMessage("获取失败", "获取申请列表信息失败,Err:"+err.Error())
  124. }
  125. newApprovalIds := make([]string, 0)
  126. approvalRecordMap := make(map[int][]int)
  127. for _, contractApprovalRecord := range contractApprovalRecordList {
  128. newApprovalIds = append(newApprovalIds, strconv.Itoa(contractApprovalRecord.ContractApprovalId))
  129. if _, ok := approvalRecordMap[contractApprovalRecord.ContractApprovalId]; ok {
  130. approvalRecordMap[contractApprovalRecord.ContractApprovalId] = append(approvalRecordMap[contractApprovalRecord.ContractApprovalId], contractApprovalRecord.ContractApprovalRecordId)
  131. } else {
  132. tmpContractApprovalRecordIdList := make([]int, 0)
  133. tmpContractApprovalRecordIdList = append(tmpContractApprovalRecordIdList, contractApprovalRecord.ContractApprovalRecordId)
  134. approvalRecordMap[contractApprovalRecord.ContractApprovalId] = tmpContractApprovalRecordIdList
  135. }
  136. }
  137. //审批单信息
  138. if len(newApprovalIds) > 0 {
  139. contractApprovalList, err := contract_approval.GetContractApprovalByIds(strings.Join(newApprovalIds, ","))
  140. if err != nil {
  141. this.FailWithMessage("获取失败", "获取申请列表信息失败,Err:"+err.Error())
  142. }
  143. for _, contractApproval := range contractApprovalList {
  144. if _, ok := approvalRecordMap[contractApproval.ContractApprovalId]; ok {
  145. for _, contractApprovalRecordId := range approvalRecordMap[contractApproval.ContractApprovalId] {
  146. newApprovalMap[contractApprovalRecordId] = contractApproval
  147. }
  148. }
  149. }
  150. }
  151. }
  152. for _, message := range list {
  153. approvalInfo := company_approval_message.ApprovalInfo{}
  154. if message.SourceType == 1 {
  155. if companyApproval, ok := companyApprovalMap[message.CompanyApprovalId]; ok {
  156. switch companyApproval.ApplyMethod {
  157. case 1:
  158. approvalInfo.Type = "申请转正"
  159. case 2:
  160. approvalInfo.Type = "冻结转试用"
  161. case 3:
  162. approvalInfo.Type = "流失转正式"
  163. case 4:
  164. approvalInfo.Type = "申请延期"
  165. case 5:
  166. approvalInfo.Type = "原销售申请领取流失客户"
  167. case 6:
  168. approvalInfo.Type = "服务更新"
  169. }
  170. approvalInfo.ApplyName = companyApproval.ApplyRealName
  171. approvalInfo.ApplyTime = companyApproval.CreateTime.Format(utils.FormatDateTime)
  172. approvalInfo.ApprovalTime = companyApproval.ApproveTime.Format(utils.FormatDateTime)
  173. }
  174. } else {
  175. if message.MessageType != 3 {
  176. if newApproval, ok := newApprovalMap[message.CompanyApprovalId]; ok {
  177. approvalInfo.Type = newApproval.ApplyContent
  178. approvalInfo.ApplyName = newApproval.ApplyUserName
  179. approvalInfo.ApplyTime = newApproval.CreateTime.Format(utils.FormatDateTime)
  180. approvalInfo.ApprovalTime = newApproval.ModifyTime.Format(utils.FormatDateTime)
  181. }
  182. }
  183. }
  184. message.ApprovalInfo = approvalInfo
  185. }
  186. //
  187. resp := message.CompanyApprovalMessageListResp{
  188. List: list,
  189. Total: total,
  190. }
  191. this.OkDetailed(resp, "获取成功")
  192. }
  193. // @Title 消息已读
  194. // @Description 消息已读接口
  195. // @Param request body company.CompanyApprovalMessageReadReq true "type json string"
  196. // @Success Ret=200 申请成功
  197. // @router /read [post]
  198. func (this *MessageCommon) MessageRead() {
  199. //sysUser := this.AdminWx
  200. var req company_approval_message.CompanyApprovalMessageReadReq
  201. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  202. if err != nil {
  203. this.FailWithMessage("参数解析异常!", "参数解析失败,Err:"+err.Error())
  204. return
  205. }
  206. if req.Id <= 0 {
  207. this.FailWithMessage("参数错误", "参数错误,客户id小于等于0")
  208. return
  209. }
  210. err = company_approval_message.ModifyCompanyApprovalMessageStatus(req.Id)
  211. if err != nil {
  212. this.FailWithMessage("修改失败!", "修改已读失败,Err:"+err.Error())
  213. return
  214. }
  215. this.OkWithMessage("已读成功")
  216. }