participateinfologic.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. package logic
  2. import (
  3. "app.yhyue.com/moapp/jybase/common"
  4. "context"
  5. IC "jyBXCore/rpc/init"
  6. "jyBXCore/rpc/model/es"
  7. "jyBXCore/rpc/model/mysql"
  8. "jyBXCore/rpc/service"
  9. "time"
  10. "jyBXCore/rpc/internal/svc"
  11. "jyBXCore/rpc/type/bxcore"
  12. "github.com/zeromicro/go-zero/core/logx"
  13. )
  14. type ParticipateInfoLogic struct {
  15. ctx context.Context
  16. svcCtx *svc.ServiceContext
  17. logx.Logger
  18. }
  19. func NewParticipateInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ParticipateInfoLogic {
  20. return &ParticipateInfoLogic{
  21. ctx: ctx,
  22. svcCtx: svcCtx,
  23. Logger: logx.WithContext(ctx),
  24. }
  25. }
  26. // 详情页参标信息接口
  27. func (l *ParticipateInfoLogic) ParticipateInfo(in *bxcore.ParticipateInfoReq) (*bxcore.ParticipateInfoRes, error) {
  28. format := &bxcore.ParticipateDetailInfo{}
  29. result := bxcore.ParticipateInfoRes{
  30. ErrMsg: "",
  31. ErrCode: -1,
  32. Data: format,
  33. }
  34. // 1. 判断身份是否有权限 不是超级订阅也不是大会员 则直接返回不展示
  35. userInfo := IC.Middleground.PowerCheckCenter.Check(in.AppId, in.UserId, in.NewUserId, in.AccountId, in.EntId, in.PositionType, in.PositionId)
  36. //不是超级订阅 也不是大会员
  37. if userInfo.Vip.Status <= 0 && userInfo.Member.Status <= 0 {
  38. result.ErrMsg = "没有权限"
  39. return &result, nil
  40. }
  41. participateService := service.NewParticipateBid(in.EntId, in.EntUserId, in.PositionType, in.PositionId)
  42. participateService.EntRoleId = userInfo.Ent.EntRoleId
  43. // 信息id解密
  44. infoList, infoSet := service.DecodeId(in.Sid)
  45. if len(infoList) == 0 {
  46. result.ErrMsg = "信息id无效"
  47. return &result, nil
  48. }
  49. // 2. 根据标讯id 查询项目信息
  50. projectInfos := es.GetProjectByInfoId(infoList)
  51. if projectInfos == nil || len(*projectInfos) == 0 {
  52. //result.ErrCode = 0
  53. result.ErrMsg = "未查到此项目信息"
  54. return &result, nil
  55. }
  56. // 判断是否已经过了开标时间
  57. var isValid bool
  58. bidopentime := common.Int64All((*projectInfos)[0]["bidopentime"])
  59. bidendtime := common.Int64All((*projectInfos)[0]["bidendtime"])
  60. if time.Now().Unix() < bidopentime || bidopentime == 0 {
  61. isValid = true
  62. }
  63. // 获取项目id
  64. _, projectIds := service.HandlerProjectId(*projectInfos, infoSet)
  65. //区分个人和企业
  66. var formatData *bxcore.ParticipateDetailInfo
  67. switch int(in.PositionType) {
  68. case service.PositionTypePersonal:
  69. existList := participateService.PersonalExistProject(projectIds)
  70. formatData = participateService.DetailPersonalFormat(existList, isValid, bidendtime)
  71. case service.PositionTypeEnt:
  72. isAllow := mysql.IsALLow(in.EntId)
  73. existList := participateService.EntExistProject(projectIds) // 查询出已经存在的
  74. formatData = participateService.DetailEntFormat(existList, isValid, isAllow, bidendtime) // 格式化数据
  75. }
  76. formatData.ProjectId = projectIds[0]
  77. result.ErrCode = 0
  78. result.Data = formatData
  79. return &result, nil
  80. }