interface.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367
  1. package backend
  2. import (
  3. "context"
  4. "kpt-pasture/config"
  5. "kpt-pasture/model"
  6. "kpt-pasture/service/asynqsvc"
  7. "kpt-pasture/service/wechat"
  8. "kpt-pasture/store/kptstore"
  9. "mime/multipart"
  10. pasturePb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/cow"
  11. "gitee.com/xuyiping_admin/pkg/di"
  12. "go.uber.org/dig"
  13. )
  14. var Module = di.Options(di.Provide(NewStore))
  15. type Hub struct {
  16. dig.In
  17. OpsService KptService
  18. }
  19. type StoreEntry struct {
  20. dig.In
  21. Cfg *config.AppConfig
  22. DB *kptstore.DB
  23. HttpClient *wechat.ClientService
  24. AsynqClient asynqsvc.Client
  25. }
  26. func NewStore(store StoreEntry) KptService {
  27. return &store
  28. }
  29. func NewStoreEntry(cfg *config.AppConfig, Db *kptstore.DB) *StoreEntry {
  30. return &StoreEntry{
  31. Cfg: cfg,
  32. DB: Db,
  33. HttpClient: nil,
  34. }
  35. }
  36. //go:generate mockgen -destination mock/kptservice.go -package kptservicemock kpt-pasture/module/backend KptService
  37. type KptService interface {
  38. SystemService // 系统相关操作
  39. PastureManageService // 牧场管理相关
  40. ConfigDataService // 配置数据相关
  41. EventService // 事件相关
  42. CowService // 牛只相关
  43. GoodsService // 牧场物品相关
  44. AnalyseService // 分析相关
  45. DashboardService // 牧场统计相关
  46. WorkService // 日常工作相关
  47. MilkHallService // 奶厅数据相关
  48. UploadService // 上传文件相关
  49. WarningService // 预警相关
  50. TestService // 测试相关
  51. }
  52. //go:generate mockgen -destination mock/SystemService.go -package kptservicemock kpt-pasture/module/backend SystemService
  53. type SystemService interface {
  54. // Login 系统用户相关
  55. Login(ctx context.Context, req *pasturePb.SearchUserRequest) (*pasturePb.SystemUserResponse, error)
  56. SearchSystemUserList(ctx context.Context, req *pasturePb.SearchUserRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchUserResponse, error)
  57. IsShowSystemUser(ctx context.Context, userId int64) error
  58. DeleteSystemUser(ctx context.Context, userId int64) error
  59. SystemUserCreateOrUpdate(ctx context.Context, req *pasturePb.SearchUserRequest) error
  60. ResetPasswordSystemUser(ctx context.Context, req *pasturePb.ResetUserPasswordRequest) error
  61. SystemUserRole(ctx context.Context, userId int64) (*pasturePb.SystemUserRoleResponse, error)
  62. SystemUserRoleSave(ctx context.Context, req *pasturePb.SystemUserRoleRequest) error
  63. // GetSystemUserMenu 当前登录用户菜单权限
  64. GetSystemUserMenu(ctx context.Context) (*pasturePb.SystemUserMenuTreeResponse, error)
  65. // SearchSystemRoleList 系统角色相关
  66. SearchSystemRoleList(ctx context.Context, req *pasturePb.SearchRoleRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchRoleResponse, error)
  67. DeleteSystemRole(ctx context.Context, roleId int64) error
  68. IsShowSystemRole(ctx context.Context, roleId int64) error
  69. SystemRoleCreateOrUpdate(ctx context.Context, req *pasturePb.SearchRoleRequest) error
  70. GetRoleMenuList(ctx context.Context, roleId int64) (*pasturePb.SystemRoleMenuResponse, error)
  71. RoleMenuSave(ctx context.Context, res *pasturePb.SystemRoleMenuRequest) error
  72. SystemRoleList(ctx context.Context) (*pasturePb.GetRoleListResponse, error)
  73. // SearchSystemMenuList 系统菜单权限
  74. SearchSystemMenuList(ctx context.Context, req *pasturePb.SearchMenuRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchMenuResponse, error)
  75. SystemMenuTree(ctx context.Context, req *pasturePb.SearchMenuRequest) (*pasturePb.SystemMenuTreeResponse, error)
  76. // SearchSystemDeptList 部门列表
  77. SearchSystemDeptList(ctx context.Context, req *pasturePb.SearchDeptRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDeptResponse, error)
  78. SystemDepthDelete(ctx context.Context, id int64) error
  79. SystemDeptCreateOrUpdate(ctx context.Context, req *pasturePb.SearchDeptRequest) error
  80. SystemDeptTree(ctx context.Context, req *pasturePb.SearchDeptRequest) (*pasturePb.DeptTreeResponse, error)
  81. // SearchUserPastureList 用户相关牧场列表
  82. SearchUserPastureList(ctx context.Context) (*pasturePb.SystemUserPastureListResponse, error)
  83. }
  84. //go:generate mockgen -destination mock/PastureManageService.go -package kptservicemock kpt-pasture/module/backend PastureManageService
  85. type PastureManageService interface {
  86. SearchBarnList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBarnResponse, error)
  87. CreateOrUpdateBarn(ctx context.Context, req *pasturePb.SearchBarnList) error
  88. SearchBarnTypeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  89. CreateOrUpdateBarnType(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  90. SearchBreedStatusList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  91. CreateOrUpdateBreedStatus(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  92. SearchCowKindList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  93. CreateOrUpdateCowKind(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  94. SearchCowStatusList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  95. CreateOrUpdateCowStatus(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  96. SearchCowTypeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  97. CreateOrUpdateCowType(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  98. SearchTransferPenReasonList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  99. CreateOrUpdateTransferPenReason(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  100. SearchCowSourceList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  101. CreateOrUpdateCowSource(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  102. CreateOrUpdateSameTime(ctx context.Context, req *pasturePb.SearchSameTimeList) error
  103. SearchSameTimeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SameTimeResponse, error)
  104. SameTimeIsShow(ctx context.Context, id int64) error
  105. SearchDiseaseTypeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  106. CreateOrUpdateDiseaseType(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  107. SearchDiseaseList(ctx context.Context, req *pasturePb.SearchDiseaseRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDiseaseResponse, error)
  108. CreateOrUpdateDisease(ctx context.Context, req *pasturePb.SearchDiseaseList) error
  109. SearchPrescriptionList(ctx context.Context, req *pasturePb.SearchPrescriptionRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchPrescriptionResponse, error)
  110. CreateOrUpdatePrescription(ctx context.Context, req *pasturePb.PrescriptionRequest) error
  111. PrescriptionDetail(ctx context.Context, id int64) (*pasturePb.PrescriptionDetailResponse, error)
  112. ImmunizationSetList(ctx context.Context, req *pasturePb.ImmunizationRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchImmunizationResponse, error)
  113. CreatedOrUpdateImmunization(ctx context.Context, req *pasturePb.ImmunizationRequest) error
  114. ImmunizationIsShow(ctx context.Context, id int64) error
  115. CreateOrUpdateDealer(crx context.Context, req *pasturePb.DealerItem) error
  116. SearchDealerList(crx context.Context, req *pasturePb.SearchNameRequest) (*pasturePb.SearchDealerResponse, error)
  117. DeleteDealer(crx context.Context, id int64) error
  118. SystemBasicEdit(ctx context.Context, req *pasturePb.BaseDataConfigBatch) error
  119. SystemBasicList(ctx context.Context) (*pasturePb.SearchBaseDataConfigResponse, error)
  120. }
  121. //go:generate mockgen -destination mock/ConfigDataService.go -package kptservicemock kpt-pasture/module/backend ConfigDataService
  122. type ConfigDataService interface {
  123. BarnTypeOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  124. BarnListOptions(ctx context.Context, penType int, isAll string) (*pasturePb.ConfigOptionsListResponse, error)
  125. BreedStatusOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  126. CowKindOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  127. CowSourceOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  128. CowTypeOptions(ctx context.Context, optionName, isAll string) (*pasturePb.ConfigOptionsListResponse, error)
  129. CowTransferPenReasonOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  130. SystemUserOptions(ctx context.Context, depName string) (*pasturePb.ConfigOptionsListResponse, error)
  131. BullOptions(ctx context.Context) (*pasturePb.BullOptionsListResponse, error)
  132. SystemBaseConfigOptions(ctx context.Context, optionName, isAll string) (*pasturePb.ConfigOptionsListResponse, error)
  133. DiseaseTypeOptions(ctx context.Context, isChildren string) (*pasturePb.ConfigOptionsListResponse, error)
  134. DiseaseOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  135. PrescriptionOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  136. FindCowHistoryBatchNumber(ctx context.Context) (*model.HistoryBatchNumberResponse, error)
  137. GenerateBatchNumber(ctx context.Context) (*model.GenerateBatchNumberResponse, error)
  138. }
  139. //go:generate mockgen -destination mock/EventService.go -package kptservicemock kpt-pasture/module/backend EventService
  140. type EventService interface {
  141. // EnterList 入场列表
  142. EnterList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchEnterEventResponse, error)
  143. CreateEnter(ctx context.Context, req *pasturePb.EventEnterRequest) error
  144. // GroupTransferList 转群
  145. GroupTransferList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchTransferGroupEventResponse, error)
  146. CreateGroupTransfer(ctx context.Context, req *pasturePb.TransferGroupEventRequest) error
  147. // BodyScoreList 体况评分
  148. BodyScoreList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBodyScoreEventResponse, error)
  149. CreateBodyScore(ctx context.Context, req *pasturePb.BodyScoreEventRequest) error
  150. // CalvingList 分娩
  151. CalvingList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchLavingEventResponse, error)
  152. CalvingCreate(ctx context.Context, req *pasturePb.EventCalving) error
  153. // PregnantCheckList 孕检
  154. PregnantCheckList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventPregnantCheckResponse, error)
  155. PregnantCheckCreateBatch(ctx context.Context, req *pasturePb.EventPregnantCheckBatch) error
  156. // MatingList 配种
  157. MatingList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventMatingResponse, error)
  158. MatingBatch(ctx context.Context, req *pasturePb.EventMatingBatch) error
  159. // EstrusBatchMating 发情批量处理配种
  160. EstrusBatchMating(ctx context.Context, req *pasturePb.EventEstrusBatch) error
  161. EstrusList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchEventEstrusResponse, error)
  162. // AbortionList 流产
  163. AbortionList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventAbortionResponse, error)
  164. AbortionCreateBatch(ctx context.Context, req *pasturePb.EventAbortionBatch) error
  165. // DryMilkList 干奶
  166. DryMilkList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventMilkResponse, error)
  167. DryMilkBatch(ctx context.Context, req *pasturePb.EventMilkBatch) error
  168. // ForbiddenMatingBatch 禁配
  169. ForbiddenMatingBatch(ctx context.Context, req *pasturePb.EventForbiddenMatingBatch) error
  170. ForbiddenMatingList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventForbiddenMatingResponse, error)
  171. UnForbiddenMating(ctx context.Context, req *pasturePb.EventUnForbiddenMatingRequest) error
  172. // WeaningBatch 断奶
  173. WeaningBatch(ctx context.Context, req *pasturePb.EventWeaningBatch) error
  174. // SameTimeCreate 同期
  175. SameTimeCreate(ctx context.Context, req *pasturePb.EventSameTime) error
  176. SameTimeBatch(ctx context.Context, req *pasturePb.EventSameTimeBatch) error
  177. SameTimeList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchSameTimeResponse, error)
  178. // WeightList 称重
  179. WeightList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchWeightEventResponse, error)
  180. WeightBatch(ctx context.Context, req *pasturePb.BatchEventWeight) error
  181. // CowDiseaseCreate 提交发病牛只
  182. CowDiseaseCreate(ctx context.Context, req *pasturePb.EventCowDiseaseRequest, source string) error
  183. // CowDiseaseDiagnose 诊断
  184. CowDiseaseDiagnose(ctx context.Context, req *pasturePb.CowDiagnosedRequest) error
  185. // CowDiseaseTreatment 治疗
  186. CowDiseaseTreatment(ctx context.Context, req *pasturePb.CowTreatmentRequest) error
  187. // DiseaseSuggestPrescription 疾病推荐处方
  188. DiseaseSuggestPrescription(ctx context.Context, diseaseId int64) (*pasturePb.ConfigOptionsListResponse, error)
  189. // CowDiseaseTreatmentDetail 治疗详情
  190. CowDiseaseTreatmentDetail(ctx context.Context, req *pasturePb.EventCowTreatmentDetailRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventCowTreatmentDetailResponse, error)
  191. // CowDiseaseCurable 治愈
  192. CowDiseaseCurable(ctx context.Context, req *pasturePb.EventCowCurableRequest) error
  193. // DeathBatch 死亡
  194. DeathBatch(ctx context.Context, req *pasturePb.EventDeathBatch) error
  195. DeathList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventDeathResponse, error)
  196. // CowEarNumberUpdate 修改耳号
  197. CowEarNumberUpdate(ctx context.Context, req *pasturePb.EventReplaceEarNumber) error
  198. // SubmitEventLog 记录提交事件结果日志
  199. SubmitEventLog(ctx context.Context, pastureId int64, cow *model.Cow, eventType pasturePb.EventType_Kind, req interface{}) *model.EventCowLog
  200. // CowSaleCreate 销售
  201. CowSaleCreate(ctx context.Context, req *pasturePb.EventCowSale) error
  202. CowSaleList(ctx context.Context, req *pasturePb.EventCowSaleRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventCowSaleResponse, error)
  203. // ImmunizationBatch 免疫事件相关
  204. ImmunizationBatch(ctx context.Context, req *pasturePb.ImmunizationItem) error
  205. ImmunizationList(ctx context.Context, req *pasturePb.SearchEventImmunizationRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchEventImmunizationResponse, error)
  206. }
  207. //go:generate mockgen -destination mock/CowService.go -package kptservicemock kpt-pasture/module/backend CowService
  208. type CowService interface {
  209. Detail(ctx context.Context, req *pasturePb.SearchEventRequest) (*pasturePb.CowInfoResponse, error)
  210. List(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchCowListResponse, error)
  211. EventList(ctx context.Context, req *pasturePb.SearchCowEventListRequest, pagination *pasturePb.PaginationModel) (*pasturePb.CowEventListResponse, error)
  212. BehaviorCurve(ctx context.Context, req *pasturePb.CowBehaviorCurveRequest) (*model.CowBehaviorCurveResponse, error)
  213. CowGrowthCurve(ctx context.Context, req *pasturePb.CowGrowthCurveRequest) (*pasturePb.CowGrowthCurveResponse, error)
  214. CowLactCurve(ctx context.Context, req *pasturePb.CowLactCurveRequest) (*pasturePb.CowLactCurveResponse, error)
  215. BehaviorRate(ctx context.Context, req *pasturePb.CowBehaviorRateRequest) (*pasturePb.CowBehaviorRateResponse, error)
  216. IndicatorsComparison(ctx context.Context, req *pasturePb.IndicatorsComparisonRequest) (*model.IndicatorsComparisonResponse, error)
  217. LongTermInfertility(ctx context.Context, req *pasturePb.LongTermInfertilityRequest, pagination *pasturePb.PaginationModel) (*pasturePb.LongTermInfertilityResponse, error)
  218. }
  219. //go:generate mockgen -destination mock/GoodsService.go -package kptservicemock kpt-pasture/module/backend GoodsService
  220. type GoodsService interface {
  221. // FrozenSemenList 冻精
  222. FrozenSemenList(ctx context.Context, req *pasturePb.FrozenSemenRequest, pagination *pasturePb.PaginationModel) (*pasturePb.FrozenSemenResponse, error)
  223. FrozenSemenCreate(ctx context.Context, req *pasturePb.SearchFrozenSemenList) error
  224. // DrugsList 药品
  225. DrugsList(ctx context.Context, req *pasturePb.SearchDrugsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDrugsResponse, error)
  226. DrugsCreateOrUpdate(ctx context.Context, req *pasturePb.SearchDrugsList) error
  227. // MedicalEquipmentList 医疗设备
  228. MedicalEquipmentList(ctx context.Context, req *pasturePb.SearchMedicalEquipmentRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchMedicalEquipmentResponse, error)
  229. MedicalEquipmentCreateOrUpdate(ctx context.Context, req *pasturePb.SearchMedicalEquipmentList) error
  230. // NeckRingList 脖环相关
  231. NeckRingList(ctx context.Context, req *pasturePb.SearchNeckRingRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchNeckRingResponse, error)
  232. NeckRingCreateOrUpdate(ctx context.Context, req *pasturePb.NeckRingCreateRequest) error
  233. // OutboundApply 出库申请
  234. OutboundApply(ctx context.Context, req *pasturePb.OutboundApplyItem) error
  235. OutboundList(ctx context.Context, req *pasturePb.SearchOutboundApplyRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchOutboundApplyResponse, error)
  236. OutboundAudit(ctx context.Context, req *pasturePb.OutboundApplyAuditRequest) error
  237. OutboundDetail(ctx context.Context, id int64) (*pasturePb.OutboundDetailResponse, error)
  238. OutboundDelete(ctx context.Context, id int64) error
  239. }
  240. //go:generate mockgen -destination mock/AnalyseService.go -package kptservicemock kpt-pasture/module/backend AnalyseService
  241. type AnalyseService interface {
  242. WeightScatterPlot(ctx context.Context, req *pasturePb.SearchGrowthCurvesRequest, pagination *pasturePb.PaginationModel) (*pasturePb.GrowthCurvesResponse, error)
  243. WeightRange(ctx context.Context, req *pasturePb.WeightRangeRequest, pagination *pasturePb.PaginationModel) (*pasturePb.WeightRangeResponse, error)
  244. MatingTimely(ctx context.Context, req *pasturePb.MatingTimelyRequest) (*model.MatingTimelyResponse, error)
  245. PenWeight(ctx context.Context, req *pasturePb.PenWeightRequest, pagination *pasturePb.PaginationModel) (*pasturePb.PenWeightResponse, error)
  246. AbortionRate(ctx context.Context, req *pasturePb.AbortionRateRequest) (*pasturePb.AbortionRateResponse, error)
  247. TwentyOnePregnantRate(ctx context.Context, req *pasturePb.TwentyOnePregnantRateRequest) (*pasturePb.TwentyOnePregnantRateResponse, error)
  248. TwentyOnePregnantDetail(ctx context.Context, req *pasturePb.TwentyOnePregnantDetailsRequest) (*pasturePb.TwentyOnePregnantDetailsResponse, error)
  249. PregnancyReport(ctx context.Context, req *pasturePb.PregnancyReportRequest, pagination *pasturePb.PaginationModel) (*pasturePb.PregnancyReportResponse, error)
  250. CalvingReport(ctx context.Context, req *pasturePb.CalvingReportRequest) (*pasturePb.CalvingReportResponse, error)
  251. DiseaseCureReport(ctx context.Context, req *pasturePb.DiseaseCureRateRequest) (*pasturePb.DiseaseCureRateResponse, error)
  252. SaleCowReport(ctx context.Context, req *pasturePb.SaleCowReportRequest) (*pasturePb.SaleCowReportResponse, error)
  253. SingleFactorInfantSurvivalRateAnalysis(ctx context.Context, req *pasturePb.SingleFactorPregnancyRateRequest) (*pasturePb.SingleFactorPregnancyRateResponse, error)
  254. MultipleFactorAnalysis(ctx context.Context, req *pasturePb.MultiFactorPregnancyRateRequest) (*model.MultiFactorPregnancyRateResponse, error)
  255. PenBehavior(ctx context.Context, req *pasturePb.BarnBehaviorCurveRequest) (*pasturePb.BarnBehaviorCurveResponse, error)
  256. PenBehaviorDaily(ctx context.Context, req *pasturePb.BarnMonitorRequest) (*model.BarnMonitorResponse, error)
  257. CowBehaviorDistribution(ctx context.Context, req *pasturePb.CowBehaviorDistributionRequest) (*pasturePb.CowBehaviorDistributionResponse, error)
  258. }
  259. //go:generate mockgen -destination mock/DashboardService.go -package kptservicemock kpt-pasture/module/backend DashboardService
  260. type DashboardService interface {
  261. NeckRingWarning(ctx context.Context) (*pasturePb.IndexNeckRingResponse, error)
  262. FocusIndicatorsList(ctx context.Context, dimension string) (*pasturePb.IndexFocusIndicatorsResponse, error)
  263. FocusIndicatorsSet(ctx context.Context, req *pasturePb.IndexFocusIndicatorsSetRequest) error
  264. DataWarningSet(ctx context.Context, req *pasturePb.IndexDataWarningSetRequest) error
  265. DataWarningList(ctx context.Context) (*pasturePb.IndexDataWarningResponse, error)
  266. DataWarningPop(ctx context.Context, req *pasturePb.WarningDataListRequest, pagination *pasturePb.PaginationModel) (*model.WarningDataPopResponse, error)
  267. CalendarToDoCount(ctx context.Context) (*pasturePb.TodoCountResponse, error)
  268. Equipment(ctx context.Context) (*pasturePb.EquipmentResponse, error)
  269. }
  270. //go:generate mockgen -destination mock/WorkService.go -package kptservicemock kpt-pasture/module/backend WorkService
  271. type WorkService interface {
  272. OrderList(ctx context.Context, req *pasturePb.SearchWorkOrderRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchWorkOrderResponse, error)
  273. OrderCreateOrUpdate(ctx context.Context, req *pasturePb.WorkOrderList) error
  274. OrderIsShow(ctx context.Context, id int64) error
  275. UserWorkOrderList(ctx context.Context, workOrderStatus pasturePb.WorkOrderStatus_Kind, pagination *pasturePb.PaginationModel) (*pasturePb.UserWorkOrderResponse, error)
  276. // CalendarList 日历相关
  277. CalendarList(ctx context.Context, req *pasturePb.CalendarRequest) (*pasturePb.CalendarResponse, error)
  278. CalendarToDoList(ctx context.Context, req *pasturePb.CalendarToDoRequest, pagination *pasturePb.PaginationModel) (*pasturePb.CalendarToDoResponse, error)
  279. CalendarTableDetail(ctx context.Context, req *pasturePb.CalendarTableRequest, pagination *pasturePb.PaginationModel) (interface{}, error)
  280. // SameTimeCowList 清单相关
  281. SameTimeCowList(ctx context.Context, req *pasturePb.ItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SameTimeItemResponse, error)
  282. ImmunisationCowList(ctx context.Context, req *pasturePb.ItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.ImmunizationItemsResponse, error)
  283. PregnancyCheckCowList(ctx context.Context, req *pasturePb.ItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.PregnancyCheckItemsResponse, error)
  284. WeaningCowList(ctx context.Context, req *pasturePb.ItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.WeaningItemsResponse, error)
  285. MatingCowList(ctx context.Context, req *pasturePb.ItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.MatingItemsResponse, error)
  286. CalvingCowList(ctx context.Context, req *pasturePb.ItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.CalvingItemsResponse, error)
  287. CowDiseaseList(ctx context.Context, req *pasturePb.SearchEventCowTreatmentRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventCowDiseaseResponse, error)
  288. }
  289. type WarningService interface {
  290. NeckRingWarningEstrusOrAbortionCowList(ctx context.Context, req *pasturePb.WarningItemsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EstrusResponse, error)
  291. NeckRingWarningHealthCowList(ctx context.Context, req *pasturePb.HealthWarningRequest, pagination *pasturePb.PaginationModel) (*pasturePb.HealthWarningResponse, error)
  292. NeckRingNoEstrusBatch(ctx context.Context, req *pasturePb.NeckRingNoEstrusBatchRequest) error
  293. NeckRingNoDiseaseBatch(ctx context.Context, req *pasturePb.NeckRingNoEstrusBatchRequest) error
  294. }
  295. type MilkHallService interface {
  296. MilkHallOriginal(ctx context.Context, req []byte) error
  297. }
  298. type UploadService interface {
  299. Photos(ctx context.Context, files []*multipart.FileHeader) ([]string, error)
  300. ImportExcel(ctx context.Context, data [][]string) error
  301. ImportExcel2(ctx context.Context, data [][]string, excelHeader []string) error
  302. }
  303. type TestService interface {
  304. CowNeckRingNumberBound(ctx context.Context, pagination *pasturePb.PaginationModel) error
  305. CowNeckRingNumberBound2(ctx context.Context, pagination *pasturePb.PaginationModel) error
  306. UpdateCowPen(ctx context.Context, pagination *pasturePb.PaginationModel) error
  307. TestDataWaring(ctx context.Context, userId int64) error
  308. NeckRingOriginalAsync(ctx context.Context, pastureId int64, pagination *pasturePb.PaginationModel) error
  309. PastureInit(ctx context.Context, pastureId int64) error
  310. AdmissionAge(ctx context.Context) error
  311. CalvingAge(ctx context.Context) error
  312. SystemMenuInit(ctx context.Context) error
  313. }