interface.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366
  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. DeleteSystemMenu(ctx context.Context, menuId int64) error
  76. SystemMenuTree(ctx context.Context) (*pasturePb.SystemMenuTreeResponse, error)
  77. // SearchSystemDeptList 部门列表
  78. SearchSystemDeptList(ctx context.Context, req *pasturePb.SearchDeptRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDeptResponse, error)
  79. SystemDepDelete(ctx context.Context, id int64) error
  80. SystemDeptCreateOrUpdate(ctx context.Context, req *pasturePb.SearchDeptRequest) error
  81. SystemDeptTree(ctx context.Context, req *pasturePb.SearchDeptRequest) (*pasturePb.DeptTreeResponse, error)
  82. // SearchUserPastureList 用户相关牧场列表
  83. SearchUserPastureList(ctx context.Context) (*pasturePb.SystemUserPastureListResponse, error)
  84. }
  85. //go:generate mockgen -destination mock/PastureManageService.go -package kptservicemock kpt-pasture/module/backend PastureManageService
  86. type PastureManageService interface {
  87. SearchBarnList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBarnResponse, error)
  88. CreateOrUpdateBarn(ctx context.Context, req *pasturePb.SearchBarnList) error
  89. SearchBarnTypeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  90. CreateOrUpdateBarnType(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  91. SearchBreedStatusList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  92. CreateOrUpdateBreedStatus(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  93. SearchCowKindList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  94. CreateOrUpdateCowKind(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  95. SearchCowStatusList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  96. CreateOrUpdateCowStatus(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  97. SearchCowTypeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  98. CreateOrUpdateCowType(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  99. SearchTransferPenReasonList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  100. CreateOrUpdateTransferPenReason(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  101. SearchCowSourceList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  102. CreateOrUpdateCowSource(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  103. CreateOrUpdateSameTime(ctx context.Context, req *pasturePb.SearchSameTimeList) error
  104. SearchSameTimeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SameTimeResponse, error)
  105. SameTimeIsShow(ctx context.Context, id int64) error
  106. SearchDiseaseTypeList(ctx context.Context, req *pasturePb.SearchNameRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBaseConfigResponse, error)
  107. CreateOrUpdateDiseaseType(ctx context.Context, req *pasturePb.SearchBaseConfigList) error
  108. SearchDiseaseList(ctx context.Context, req *pasturePb.SearchDiseaseRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDiseaseResponse, error)
  109. CreateOrUpdateDisease(ctx context.Context, req *pasturePb.SearchDiseaseList) error
  110. SearchPrescriptionList(ctx context.Context, req *pasturePb.SearchPrescriptionRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchPrescriptionResponse, error)
  111. CreateOrUpdatePrescription(ctx context.Context, req *pasturePb.PrescriptionRequest) error
  112. PrescriptionDetail(ctx context.Context, id int64) (*pasturePb.PrescriptionDetailResponse, error)
  113. ImmunizationSetList(ctx context.Context, req *pasturePb.ImmunizationRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchImmunizationResponse, error)
  114. CreatedOrUpdateImmunization(ctx context.Context, req *pasturePb.ImmunizationRequest) error
  115. ImmunizationIsShow(ctx context.Context, id int64) error
  116. CreateOrUpdateDealer(crx context.Context, req *pasturePb.DealerItem) error
  117. SearchDealerList(crx context.Context, req *pasturePb.SearchNameRequest) (*pasturePb.SearchDealerResponse, error)
  118. DeleteDealer(crx context.Context, id int64) error
  119. SystemBasicEdit(ctx context.Context, req *pasturePb.BaseDataConfigBatch) error
  120. SystemBasicList(ctx context.Context) (*pasturePb.SearchBaseDataConfigResponse, error)
  121. }
  122. //go:generate mockgen -destination mock/ConfigDataService.go -package kptservicemock kpt-pasture/module/backend ConfigDataService
  123. type ConfigDataService interface {
  124. BarnTypeOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  125. BarnListOptions(ctx context.Context, penType int, isAll string) (*pasturePb.ConfigOptionsListResponse, error)
  126. BreedStatusOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  127. CowKindOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  128. CowSourceOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  129. CowTypeOptions(ctx context.Context, optionName, isAll string) (*pasturePb.ConfigOptionsListResponse, error)
  130. CowTransferPenReasonOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  131. SystemUserOptions(ctx context.Context, depName string) (*pasturePb.ConfigOptionsListResponse, error)
  132. BullOptions(ctx context.Context) (*pasturePb.BullOptionsListResponse, error)
  133. SystemBaseConfigOptions(ctx context.Context, optionName, isAll string) (*pasturePb.ConfigOptionsListResponse, error)
  134. DiseaseTypeOptions(ctx context.Context, isChildren string) (*pasturePb.ConfigOptionsListResponse, error)
  135. DiseaseOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  136. PrescriptionOptions(ctx context.Context) (*pasturePb.ConfigOptionsListResponse, error)
  137. FindCowHistoryBatchNumber(ctx context.Context) (*model.HistoryBatchNumberResponse, error)
  138. GenerateBatchNumber(ctx context.Context) (*model.GenerateBatchNumberResponse, error)
  139. }
  140. //go:generate mockgen -destination mock/EventService.go -package kptservicemock kpt-pasture/module/backend EventService
  141. type EventService interface {
  142. // EnterList 入场列表
  143. EnterList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchEnterEventResponse, error)
  144. CreateEnter(ctx context.Context, req *pasturePb.EventEnterRequest) error
  145. // GroupTransferList 转群
  146. GroupTransferList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchTransferGroupEventResponse, error)
  147. CreateGroupTransfer(ctx context.Context, req *pasturePb.TransferGroupEventRequest) error
  148. // BodyScoreList 体况评分
  149. BodyScoreList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchBodyScoreEventResponse, error)
  150. CreateBodyScore(ctx context.Context, req *pasturePb.BodyScoreEventRequest) error
  151. // CalvingList 分娩
  152. CalvingList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchLavingEventResponse, error)
  153. CalvingCreate(ctx context.Context, req *pasturePb.EventCalving) error
  154. // PregnantCheckList 孕检
  155. PregnantCheckList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventPregnantCheckResponse, error)
  156. PregnantCheckCreateBatch(ctx context.Context, req *pasturePb.EventPregnantCheckBatch) error
  157. // MatingList 配种
  158. MatingList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventMatingResponse, error)
  159. MatingBatch(ctx context.Context, req *pasturePb.EventMatingBatch) error
  160. // EstrusBatchMating 发情批量处理配种
  161. EstrusBatchMating(ctx context.Context, req *pasturePb.EventEstrusBatch) error
  162. EstrusList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchEventEstrusResponse, error)
  163. // AbortionList 流产
  164. AbortionList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventAbortionResponse, error)
  165. AbortionCreateBatch(ctx context.Context, req *pasturePb.EventAbortionBatch) error
  166. // DryMilkList 干奶
  167. DryMilkList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventMilkResponse, error)
  168. DryMilkBatch(ctx context.Context, req *pasturePb.EventMilkBatch) error
  169. // ForbiddenMatingBatch 禁配
  170. ForbiddenMatingBatch(ctx context.Context, req *pasturePb.EventForbiddenMatingBatch) error
  171. ForbiddenMatingList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventForbiddenMatingResponse, error)
  172. UnForbiddenMating(ctx context.Context, req *pasturePb.EventUnForbiddenMatingRequest) error
  173. // WeaningBatch 断奶
  174. WeaningBatch(ctx context.Context, req *pasturePb.EventWeaningBatch) error
  175. // SameTimeCreate 同期
  176. SameTimeCreate(ctx context.Context, req *pasturePb.EventSameTime) error
  177. SameTimeBatch(ctx context.Context, req *pasturePb.EventSameTimeBatch) error
  178. SameTimeList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchSameTimeResponse, error)
  179. // WeightList 称重
  180. WeightList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchWeightEventResponse, error)
  181. WeightBatch(ctx context.Context, req *pasturePb.BatchEventWeight) error
  182. // CowDiseaseCreate 提交发病牛只
  183. CowDiseaseCreate(ctx context.Context, req *pasturePb.EventCowDiseaseRequest, source string) error
  184. // CowDiseaseDiagnose 诊断
  185. CowDiseaseDiagnose(ctx context.Context, req *pasturePb.CowDiagnosedRequest) error
  186. // CowDiseaseTreatment 治疗
  187. CowDiseaseTreatment(ctx context.Context, req *pasturePb.CowTreatmentRequest) error
  188. // DiseaseSuggestPrescription 疾病推荐处方
  189. DiseaseSuggestPrescription(ctx context.Context, diseaseId int64) (*pasturePb.ConfigOptionsListResponse, error)
  190. // CowDiseaseTreatmentDetail 治疗详情
  191. CowDiseaseTreatmentDetail(ctx context.Context, req *pasturePb.EventCowTreatmentDetailRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventCowTreatmentDetailResponse, error)
  192. // CowDiseaseCurable 治愈
  193. CowDiseaseCurable(ctx context.Context, req *pasturePb.EventCowCurableRequest) error
  194. // DeathBatch 死亡
  195. DeathBatch(ctx context.Context, req *pasturePb.EventDeathBatch) error
  196. DeathList(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventDeathResponse, error)
  197. // CowEarNumberUpdate 修改耳号
  198. CowEarNumberUpdate(ctx context.Context, req *pasturePb.EventReplaceEarNumber) error
  199. // SubmitEventLog 记录提交事件结果日志
  200. SubmitEventLog(ctx context.Context, pastureId int64, cow *model.Cow, eventType pasturePb.EventType_Kind, req interface{}) *model.EventCowLog
  201. // CowSaleCreate 销售
  202. CowSaleCreate(ctx context.Context, req *pasturePb.EventCowSale) error
  203. CowSaleList(ctx context.Context, req *pasturePb.EventCowSaleRequest, pagination *pasturePb.PaginationModel) (*pasturePb.EventCowSaleResponse, error)
  204. // ImmunizationBatch 免疫事件相关
  205. ImmunizationBatch(ctx context.Context, req *pasturePb.ImmunizationItem) error
  206. ImmunizationList(ctx context.Context, req *pasturePb.SearchEventImmunizationRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchEventImmunizationResponse, error)
  207. }
  208. //go:generate mockgen -destination mock/CowService.go -package kptservicemock kpt-pasture/module/backend CowService
  209. type CowService interface {
  210. Detail(ctx context.Context, req *pasturePb.SearchEventRequest) (*pasturePb.CowInfoResponse, error)
  211. List(ctx context.Context, req *pasturePb.SearchEventRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchCowListResponse, error)
  212. EventList(ctx context.Context, req *pasturePb.SearchCowEventListRequest, pagination *pasturePb.PaginationModel) (*pasturePb.CowEventListResponse, error)
  213. BehaviorCurve(ctx context.Context, req *pasturePb.CowBehaviorCurveRequest) (*model.CowBehaviorCurveResponse, error)
  214. CowGrowthCurve(ctx context.Context, req *pasturePb.CowGrowthCurveRequest) (*pasturePb.CowGrowthCurveResponse, error)
  215. CowLactCurve(ctx context.Context, req *pasturePb.CowLactCurveRequest) (*pasturePb.CowLactCurveResponse, error)
  216. BehaviorRate(ctx context.Context, req *pasturePb.CowBehaviorRateRequest) (*pasturePb.CowBehaviorRateResponse, error)
  217. IndicatorsComparison(ctx context.Context, req *pasturePb.IndicatorsComparisonRequest) (*model.IndicatorsComparisonResponse, error)
  218. LongTermInfertility(ctx context.Context, req *pasturePb.LongTermInfertilityRequest, pagination *pasturePb.PaginationModel) (*pasturePb.LongTermInfertilityResponse, error)
  219. }
  220. //go:generate mockgen -destination mock/GoodsService.go -package kptservicemock kpt-pasture/module/backend GoodsService
  221. type GoodsService interface {
  222. // FrozenSemenList 冻精
  223. FrozenSemenList(ctx context.Context, req *pasturePb.FrozenSemenRequest, pagination *pasturePb.PaginationModel) (*pasturePb.FrozenSemenResponse, error)
  224. FrozenSemenCreate(ctx context.Context, req *pasturePb.SearchFrozenSemenList) error
  225. // DrugsList 药品
  226. DrugsList(ctx context.Context, req *pasturePb.SearchDrugsRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDrugsResponse, error)
  227. DrugsCreateOrUpdate(ctx context.Context, req *pasturePb.SearchDrugsList) error
  228. // MedicalEquipmentList 医疗设备
  229. MedicalEquipmentList(ctx context.Context, req *pasturePb.SearchMedicalEquipmentRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchMedicalEquipmentResponse, error)
  230. MedicalEquipmentCreateOrUpdate(ctx context.Context, req *pasturePb.SearchMedicalEquipmentList) error
  231. // NeckRingList 脖环相关
  232. NeckRingList(ctx context.Context, req *pasturePb.SearchNeckRingRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchNeckRingResponse, error)
  233. NeckRingCreateOrUpdate(ctx context.Context, req *pasturePb.NeckRingCreateRequest) error
  234. // OutboundApply 出库申请
  235. OutboundApply(ctx context.Context, req *pasturePb.OutboundApplyItem) error
  236. OutboundList(ctx context.Context, req *pasturePb.SearchOutboundApplyRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchOutboundApplyResponse, error)
  237. OutboundAudit(ctx context.Context, req *pasturePb.OutboundApplyAuditRequest) error
  238. OutboundDetail(ctx context.Context, id int64) (*pasturePb.OutboundDetailResponse, error)
  239. OutboundDelete(ctx context.Context, id int64) error
  240. }
  241. //go:generate mockgen -destination mock/AnalyseService.go -package kptservicemock kpt-pasture/module/backend AnalyseService
  242. type AnalyseService interface {
  243. WeightScatterPlot(ctx context.Context, req *pasturePb.SearchGrowthCurvesRequest, pagination *pasturePb.PaginationModel) (*pasturePb.GrowthCurvesResponse, error)
  244. WeightRange(ctx context.Context, req *pasturePb.WeightRangeRequest, pagination *pasturePb.PaginationModel) (*pasturePb.WeightRangeResponse, error)
  245. MatingTimely(ctx context.Context, req *pasturePb.MatingTimelyRequest) (*model.MatingTimelyResponse, error)
  246. PenWeight(ctx context.Context, req *pasturePb.PenWeightRequest, pagination *pasturePb.PaginationModel) (*pasturePb.PenWeightResponse, error)
  247. AbortionRate(ctx context.Context, req *pasturePb.AbortionRateRequest) (*pasturePb.AbortionRateResponse, error)
  248. TwentyOnePregnantRate(ctx context.Context, req *pasturePb.TwentyOnePregnantRateRequest) (*pasturePb.TwentyOnePregnantRateResponse, error)
  249. TwentyOnePregnantDetail(ctx context.Context, req *pasturePb.TwentyOnePregnantDetailsRequest) (*pasturePb.TwentyOnePregnantDetailsResponse, error)
  250. PregnancyReport(ctx context.Context, req *pasturePb.PregnancyReportRequest, pagination *pasturePb.PaginationModel) (*pasturePb.PregnancyReportResponse, error)
  251. CalvingReport(ctx context.Context, req *pasturePb.CalvingReportRequest) (*pasturePb.CalvingReportResponse, error)
  252. DiseaseCureReport(ctx context.Context, req *pasturePb.DiseaseCureRateRequest) (*pasturePb.DiseaseCureRateResponse, error)
  253. SaleCowReport(ctx context.Context, req *pasturePb.SaleCowReportRequest) (*pasturePb.SaleCowReportResponse, error)
  254. SingleFactorInfantSurvivalRateAnalysis(ctx context.Context, req *pasturePb.SingleFactorPregnancyRateRequest) (*pasturePb.SingleFactorPregnancyRateResponse, error)
  255. MultipleFactorAnalysis(ctx context.Context, req *pasturePb.MultiFactorPregnancyRateRequest) (*model.MultiFactorPregnancyRateResponse, error)
  256. PenBehavior(ctx context.Context, req *pasturePb.BarnBehaviorCurveRequest) (*pasturePb.BarnBehaviorCurveResponse, error)
  257. PenBehaviorDaily(ctx context.Context, req *pasturePb.BarnMonitorRequest) (*model.BarnMonitorResponse, error)
  258. CowBehaviorDistribution(ctx context.Context, req *pasturePb.CowBehaviorDistributionRequest) (*pasturePb.CowBehaviorDistributionResponse, error)
  259. }
  260. //go:generate mockgen -destination mock/DashboardService.go -package kptservicemock kpt-pasture/module/backend DashboardService
  261. type DashboardService interface {
  262. NeckRingWarning(ctx context.Context) (*pasturePb.IndexNeckRingResponse, error)
  263. FocusIndicatorsList(ctx context.Context, dimension string) (*pasturePb.IndexFocusIndicatorsResponse, error)
  264. FocusIndicatorsSet(ctx context.Context, req *pasturePb.IndexFocusIndicatorsSetRequest) error
  265. DataWarningSet(ctx context.Context, req *pasturePb.IndexDataWarningSetRequest) error
  266. DataWarningList(ctx context.Context) (*pasturePb.IndexDataWarningResponse, error)
  267. DataWarningPop(ctx context.Context, req *pasturePb.WarningDataListRequest, pagination *pasturePb.PaginationModel) (*model.WarningDataPopResponse, error)
  268. CalendarToDoCount(ctx context.Context) (*pasturePb.TodoCountResponse, 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. }