s_project_dao.go 2.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. package dao
  2. import (
  3. "youngee_b_api/app/entity"
  4. )
  5. type SProjectDao struct{}
  6. // 插入数据
  7. func (d SProjectDao) Insert(record *entity.SProjectInfo) error {
  8. result := Db.Debug().Model(&entity.SProjectInfo{}).Create(&record)
  9. return result.Error
  10. }
  11. // 根据种草id、邀约状态返回数据列表
  12. func (d SProjectDao) GetSProjectByStatus(projectId string, status int64, page int, pageSize int) ([]*entity.SProjectInfo, int64, error) {
  13. var sProjectInfos []*entity.SProjectInfo
  14. var total int64
  15. offset := (page - 1) * pageSize
  16. query := Db.Debug().Model(&entity.SProjectInfo{}).Where("project_id = ? AND s_project_status = ?", projectId, status)
  17. query.Count(&total)
  18. query = query.Select("supplier_id, b_operator, b_operator_type")
  19. err := query.Order("create_time desc").Offset(offset).Limit(pageSize).Find(&sProjectInfos).Error
  20. if err != nil {
  21. return nil, 0, err
  22. }
  23. return sProjectInfos, total, nil
  24. }
  25. //// 检查给定的服务商是否在该商家库中
  26. //func (d SupplierDao) EnterpriseDatabaseCheck(enterpriseId string, supplierId int64) (bool, error) {
  27. // var count int64
  28. // err := Db.Debug().Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND supplier_id = ? AND cooperate_status != 2", enterpriseId, supplierId).Count(&count).Error
  29. // if err != nil {
  30. // return false, err
  31. // }
  32. // return count > 0, nil
  33. //}
  34. //
  35. //// 获取指定商家的服务商库
  36. //func (d SupplierDao) GetSupplierByEnterprise(enterpriseId string, page int, pageSize int) ([]*entity.EnterpriseSupplierCooperate, int64, error) {
  37. // var enterpriseSupplierCooperates []*entity.EnterpriseSupplierCooperate
  38. // var total int64
  39. // offset := (page - 1) * pageSize
  40. // query := Db.Debug().Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND cooperate_status = 2", enterpriseId)
  41. // query.Count(&total)
  42. // query = query.Select("supplier_id, cooperate_num, upload_talent_num, cooperate_talent_num, b_operator, b_operator_type, agree_time")
  43. // err := query.Order("agree_time desc").Offset(offset).Limit(pageSize).Find(&enterpriseSupplierCooperates).Error
  44. // if err != nil {
  45. // return nil, 0, err
  46. // }
  47. //
  48. // return enterpriseSupplierCooperates, total, nil
  49. //}
  50. //
  51. //// 获取邀请待确认的服务商
  52. //func (d SupplierDao) GetSupplierConfirmingList(enterpriseId string, page int, pageSize int) ([]*entity.EnterpriseSupplierCooperate, int64, error) {
  53. // var enterpriseSupplierCooperates []*entity.EnterpriseSupplierCooperate
  54. // var total int64
  55. // offset := (page - 1) * pageSize
  56. // query := Db.Debug().Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND cooperate_status = 1", enterpriseId)
  57. // query.Count(&total)
  58. // query = query.Select("supplier_id, b_operator, b_operator_type, cooperate_status, create_time")
  59. // err := query.Order("create_time desc").Offset(offset).Limit(pageSize).Find(&enterpriseSupplierCooperates).Error
  60. // if err != nil {
  61. // return nil, 0, err
  62. // }
  63. //
  64. // return enterpriseSupplierCooperates, total, nil
  65. //}