cow.go 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837
  1. package model
  2. import (
  3. "fmt"
  4. "math"
  5. "time"
  6. pasturePb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/cow"
  7. )
  8. type Cow struct {
  9. Id int64 `json:"id"`
  10. PastureId int64 `json:"pastureId"` // 牧场id
  11. Sex pasturePb.Genders_Kind `json:"sex"` // 性别
  12. NeckRingNumber string `json:"neckRingNumber"` // 脖环号
  13. EarNumber string `json:"earNumber"` // 耳标号
  14. EleEarNumber string `json:"eleEarNumber"` // 电子耳标号
  15. EarOldNumber string `json:"earOldNumber"` // 旧耳标号
  16. PenId int32 `json:"penId"` // 栏舍id
  17. PenName string `json:"penName"` // 栏舍名称
  18. Lact int32 `json:"lact"` // 胎次
  19. DayAge int32 `json:"dayAge"` // 日龄
  20. CalvingAge int32 `json:"calvingAge"` // 产后天使
  21. PregnancyAge int32 `json:"pregnancyAge"` // 怀孕天数 孕检结果有阳性更新,产犊后至0
  22. MatingAge int32 `json:"matingAge"` // 配种天数
  23. AdmissionAge int32 `json:"admissionAge"` // 入场日龄
  24. AbortionAge int32 `json:"abortionAge"` // 流产天数
  25. LactationAge int32 `json:"lactationAge"` // 泌乳天数
  26. DryMilkAge int32 `json:"dryMilkAge"` // 干奶天数
  27. CowType pasturePb.CowType_Kind `json:"cowType"` // 牛只类型
  28. MilkKind pasturePb.CowMilk_Kind `json:"milkKind"` // 牛只奶属性
  29. BreedStatus pasturePb.BreedStatus_Kind `json:"breedStatus"` // 繁殖状态
  30. CowKind pasturePb.CowKind_Kind `json:"cowKind"` // 牛只品种
  31. BirthWeight int64 `json:"birthWeight"` // 出生体重
  32. CurrentWeight int64 `json:"currentWeight"` // 当前体重
  33. CurrentHeight int64 `json:"currentHeight"` // 当前身高
  34. AdmissionWeight int64 `json:"admissionWeight"` // 入场体重
  35. AdmissionPrice float32 `json:"admissionPrice"` // 入场价格
  36. SourceKind pasturePb.CowSource_Kind `json:"sourceKind"` // 来源哪里
  37. PurposeKind pasturePb.Purpose_Kind `json:"purposeKind"` // 用途
  38. FatherNumber string `json:"fatherNumber"` // 父号
  39. MotherNumber string `json:"motherNumber"` // 母号
  40. AdmissionStatus pasturePb.AdmissionStatus_Kind `json:"admissionStatus"` // 在场状态
  41. IsPregnant pasturePb.IsShow_Kind `json:"isPregnant"` // 是否怀孕
  42. IsForbiddenMating pasturePb.IsShow_Kind `json:"isForbiddenMating"` // 是否禁配 1 是 2 否
  43. HealthStatus pasturePb.HealthStatus_Kind `json:"healthStatus"` // 健康状态
  44. WeaningAt int64 `json:"weaningAt"` // 断奶时间
  45. BirthAt int64 `json:"birthAt"` // 出生时间
  46. AdmissionAt int64 `json:"admissionAt"` // 入场时间
  47. DepartureAt int64 `json:"departureAt"` // 离场时间
  48. DeparturePrice float32 `json:"departurePrice"` // 离场价格
  49. DepartureAvgWeight int32 `json:"departureAvgWeight"` // 离场平均体重
  50. FirstMatingAt int64 `json:"firstMatingAt"` // 首次配种时间
  51. AllMatingTimes int32 `json:"allMatingTimes"` // 总配次
  52. AllAbortionTimes int32 `json:"allAbortionTimes"` // 总流产次数
  53. MatingTimes int32 `json:"matingTimes"` // 配种次数
  54. AbortionTimes int32 `json:"abortionTimes"` // 流产次数
  55. PregnancyCheckName string `json:"pregnancyCheckName"` // 孕检名称
  56. WeeklyActive int32 `json:"weeklyActive"` // 每周活跃度
  57. LastEstrusAt int64 `json:"lastEstrusAt"` // 最后一次发情时间
  58. LastCalvingAt int64 `json:"lastCalvingAt"` // 最后一次产犊时间
  59. LastMatingAt int64 `json:"lastMatingAt"` // 最后一次配种时间
  60. LastBullNumber string `json:"lastBullNumber"` // 最后一次配种牛号
  61. LastPregnantCheckAt int64 `json:"lastPregnantCheckAt"` // 最后一次孕检时间
  62. LastDryMilkAt int64 `json:"lastDryMilkAt"` // 最近一次干奶日期
  63. LastForbiddenMatingAt int64 `json:"lastForbiddenMatingAt"` // 最近一次禁配时间
  64. LastSecondWeight int64 `json:"lastSecondWeight"` // 最后第二次称重
  65. LastSecondWeightAt int64 `json:"lastSecondWeightAt"` // 最后第二次称重时间
  66. LastAbortionAt int64 `json:"lastAbortionAt"` // 最近一次流产时间
  67. LastWeightAt int64 `json:"lastWeightAt"` // 最近一次称重时间
  68. BatchNumber string `json:"batchNumber"` // 批次号
  69. CreatedAt int64 `json:"createdAt"`
  70. UpdatedAt int64 `json:"updatedAt"`
  71. }
  72. func (c *Cow) TableName() string {
  73. return "cow"
  74. }
  75. // EventUpdate 牛只基本信息维护
  76. func (c *Cow) EventUpdate(weeklyActive int32) {
  77. c.DayAge = c.GetDayAge() // 日龄
  78. c.CalvingAge = c.GetCalvingAge() // 产后天数
  79. c.PregnancyAge = c.GetDaysPregnant() // 怀孕天数
  80. c.AdmissionAge = c.GetAdmissionAge() // 入场天数
  81. c.AbortionAge = c.GetAbortionAge() // 流产天数
  82. c.WeeklyActive = weeklyActive // 周活动量
  83. c.LactationAge = c.GetLactationAge() // 泌乳天数
  84. c.DryMilkAge = c.GetDryMilkAge() // 干奶天数
  85. c.MatingAge = c.GetMatingAge() // 配后天数
  86. if c.DayAge == 60 {
  87. c.CowType = pasturePb.CowType_Weaned_Calf
  88. }
  89. }
  90. // EventCalvingUpdate 产犊更新
  91. func (c *Cow) EventCalvingUpdate(calvingAt int64) {
  92. c.Lact += 1
  93. c.MatingTimes = 0
  94. c.PregnancyAge = 0
  95. c.AbortionTimes = 0
  96. c.BreedStatus = pasturePb.BreedStatus_Calving
  97. c.IsPregnant = pasturePb.IsShow_No
  98. c.LastCalvingAt = calvingAt
  99. c.CalvingAge = c.GetCalvingAge()
  100. c.CowType = pasturePb.CowType_Breeding_Calf
  101. c.MilkKind = pasturePb.CowMilk_Lactation
  102. }
  103. // EventWeaningUpdate 断奶更新
  104. func (c *Cow) EventWeaningUpdate(weaningAt int64, penId int32, currentWeight int64) {
  105. c.PenId = penId
  106. c.WeaningAt = weaningAt
  107. c.CurrentWeight = currentWeight
  108. c.LastWeightAt = weaningAt
  109. }
  110. // EventPregnantCheckUpdate 孕检更新
  111. func (c *Cow) EventPregnantCheckUpdate(breedStatus pasturePb.BreedStatus_Kind, pregnantCheckAt int64,
  112. isPregnant pasturePb.IsShow_Kind, pregnancyCheckName string) {
  113. c.BreedStatus = breedStatus
  114. c.LastPregnantCheckAt = pregnantCheckAt
  115. c.IsPregnant = isPregnant
  116. c.PregnancyCheckName = pregnancyCheckName
  117. }
  118. // EventAbortionUpdate 流产更新
  119. func (c *Cow) EventAbortionUpdate(abortionAt int64, isLact pasturePb.IsShow_Kind) {
  120. c.IsPregnant = pasturePb.IsShow_No
  121. c.LastAbortionAt = abortionAt
  122. c.BreedStatus = pasturePb.BreedStatus_Abort
  123. c.AbortionTimes += 1
  124. c.AllAbortionTimes += 1
  125. if isLact == pasturePb.IsShow_Ok {
  126. c.Lact += 1
  127. }
  128. }
  129. // EventWeightUpdate 称重更新
  130. func (c *Cow) EventWeightUpdate(weight, height, weightAt int64) {
  131. c.LastSecondWeight = c.CurrentWeight
  132. c.LastSecondWeightAt = c.LastWeightAt
  133. c.LastWeightAt = weightAt
  134. c.CurrentWeight = weight
  135. c.CurrentHeight = height
  136. }
  137. // EventHealthStatusUpdate 健康状态更新
  138. func (c *Cow) EventHealthStatusUpdate(healthStatus pasturePb.HealthStatus_Kind) {
  139. c.HealthStatus = healthStatus
  140. }
  141. // EventPenUpdate 更新栏舍
  142. func (c *Cow) EventPenUpdate(pen *Pen) {
  143. c.PenId = pen.Id
  144. c.PenName = pen.Name
  145. }
  146. // EventEarNumberUpdate 更新耳标号
  147. func (c *Cow) EventEarNumberUpdate(newEarNumber string) {
  148. c.EarOldNumber = c.EarNumber
  149. c.EarNumber = newEarNumber
  150. }
  151. // EventDeathUpdate 更新牛只死亡信息
  152. func (c *Cow) EventDeathUpdate(eventAt int64) {
  153. c.AdmissionStatus = pasturePb.AdmissionStatus_Die
  154. c.HealthStatus = pasturePb.HealthStatus_Dead
  155. c.DepartureAt = eventAt
  156. c.NeckRingNumber = ""
  157. }
  158. // EventSaleUpdate 更新牛只销售信息
  159. func (c *Cow) EventSaleUpdate(eventSale *EventSale) {
  160. c.DepartureAt = eventSale.SaleAt
  161. c.NeckRingNumber = ""
  162. c.DeparturePrice = float32(eventSale.SalePrice)
  163. if eventSale.SaleKind == pasturePb.SalesType_Out {
  164. c.HealthStatus = pasturePb.HealthStatus_Out
  165. c.AdmissionStatus = pasturePb.AdmissionStatus_Out
  166. }
  167. if eventSale.SaleKind == pasturePb.SalesType_Sales {
  168. c.AdmissionStatus = pasturePb.AdmissionStatus_Sale
  169. }
  170. if eventSale.SaleCowCount > 0 {
  171. c.DepartureAvgWeight = eventSale.SaleAllWeight / eventSale.SaleCowCount
  172. }
  173. }
  174. // EventMatingUpdate 配种更新
  175. func (c *Cow) EventMatingUpdate(matingAt int64, bullNumber string, isReMating bool) {
  176. c.LastMatingAt = matingAt
  177. c.LastBullNumber = bullNumber
  178. c.IsPregnant = pasturePb.IsShow_No
  179. c.BreedStatus = pasturePb.BreedStatus_Breeding
  180. if c.FirstMatingAt <= 0 {
  181. c.FirstMatingAt = matingAt
  182. }
  183. if !isReMating {
  184. c.MatingTimes += 1
  185. c.AllMatingTimes += 1
  186. }
  187. if c.Lact == 0 {
  188. c.CowType = pasturePb.CowType_Reserve_Calf
  189. }
  190. }
  191. // EstrusUpdate 发情更新
  192. func (c *Cow) EstrusUpdate(estrusAt int64) {
  193. c.LastEstrusAt = estrusAt
  194. }
  195. // EventDryMilkUpdate 干奶更新
  196. func (c *Cow) EventDryMilkUpdate(dryMilkAt int64, pen *Pen) {
  197. c.LastDryMilkAt = dryMilkAt
  198. c.MilkKind = pasturePb.CowMilk_Dry_Milk
  199. c.PenId = pen.Id
  200. c.PenName = pen.Name
  201. }
  202. // ForbiddenMatingUpdate 禁配更新
  203. func (c *Cow) ForbiddenMatingUpdate(forbiddenMatingAt int64) {
  204. c.IsForbiddenMating = pasturePb.IsShow_Ok
  205. c.LastForbiddenMatingAt = forbiddenMatingAt
  206. c.BreedStatus = pasturePb.BreedStatus_No_Mating
  207. }
  208. // UnForbiddenMatingUpdate 解禁配更新
  209. func (c *Cow) UnForbiddenMatingUpdate() {
  210. c.IsForbiddenMating = pasturePb.IsShow_No
  211. c.LastForbiddenMatingAt = 0
  212. c.BreedStatus = pasturePb.BreedStatus_UnBreed
  213. }
  214. // GetAvgDailyWeight 牛只平均日增重
  215. func (c *Cow) GetAvgDailyWeight() float32 {
  216. if c.AdmissionAge <= 0 {
  217. c.AdmissionAge = c.GetAdmissionAge()
  218. }
  219. if c.AdmissionAge <= 0 {
  220. return 0
  221. }
  222. return float32(c.CurrentWeight-c.AdmissionWeight) / 1000 / float32(c.AdmissionAge)
  223. }
  224. // GetDayAge 日龄
  225. func (c *Cow) GetDayAge() int32 {
  226. if c.BirthAt <= 0 {
  227. return 0
  228. }
  229. return int32(math.Floor(float64(time.Now().Local().Unix()-c.BirthAt) / 86400))
  230. }
  231. // GetEventDayAge 获取事件发生的日龄
  232. func (c *Cow) GetEventDayAge(eventAt int64) int32 {
  233. if c.BirthAt <= 0 {
  234. return 0
  235. }
  236. return int32(math.Floor(float64(eventAt-c.BirthAt) / 86400))
  237. }
  238. // GetCalvingAge 产后天数
  239. func (c *Cow) GetCalvingAge() int32 {
  240. if c.LastCalvingAt <= 0 {
  241. return 0
  242. }
  243. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastCalvingAt) / 86400))
  244. }
  245. // GetDaysPregnant 怀孕天数
  246. func (c *Cow) GetDaysPregnant() int32 {
  247. if c.BreedStatus == pasturePb.BreedStatus_Pregnant &&
  248. c.AdmissionStatus == pasturePb.AdmissionStatus_Admission &&
  249. c.IsPregnant == pasturePb.IsShow_Ok {
  250. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastMatingAt) / 86400))
  251. }
  252. return 0
  253. }
  254. // GetDaysPregnancy 牛只预产日期
  255. func (c *Cow) GetDaysPregnancy(pregnancyAgeValue int32) int32 {
  256. if c.BreedStatus == pasturePb.BreedStatus_Pregnant &&
  257. c.AdmissionStatus == pasturePb.AdmissionStatus_Admission &&
  258. c.IsPregnant == pasturePb.IsShow_Ok {
  259. return int32(math.Floor(float64(c.LastMatingAt + int64(pregnancyAgeValue)*86400)))
  260. }
  261. return 0
  262. }
  263. // GetLactationDays 泌乳天数
  264. func (c *Cow) GetLactationDays() int32 {
  265. if c.BreedStatus == pasturePb.BreedStatus_Calving && c.AdmissionStatus == pasturePb.AdmissionStatus_Admission {
  266. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastCalvingAt) / 86400))
  267. }
  268. return 0
  269. }
  270. // GetAdmissionAge 入场天数
  271. func (c *Cow) GetAdmissionAge() int32 {
  272. if c.AdmissionAt > 0 && c.AdmissionStatus == pasturePb.AdmissionStatus_Admission {
  273. return int32(math.Floor(float64(time.Now().Local().Unix()-c.AdmissionAt) / 86400))
  274. }
  275. return 0
  276. }
  277. // GetAverageDailyWeight 平均日增重(最后一次称重 - 入场体重)÷在群天数
  278. func (c *Cow) GetAverageDailyWeight() float64 {
  279. if c.AdmissionAge <= 0 {
  280. c.AdmissionAge = c.GetAdmissionAge()
  281. }
  282. if c.AdmissionAge <= 0 {
  283. return 0
  284. }
  285. if c.CurrentWeight-c.AdmissionWeight <= 0 {
  286. return 0
  287. }
  288. return float64(c.CurrentWeight-c.AdmissionWeight) / 1000 / float64(c.AdmissionAge)
  289. }
  290. // GetPreviousStageDailyWeight 上一个阶段日增重
  291. func (c *Cow) GetPreviousStageDailyWeight() float64 {
  292. if c.CurrentWeight-c.LastSecondWeight > 0 && c.LastWeightAt-c.LastSecondWeightAt > 0 {
  293. days := int32(math.Floor(float64(c.LastWeightAt-c.LastSecondWeightAt) / 86400))
  294. if days <= 0 {
  295. return float64(c.CurrentWeight - c.LastSecondWeight)
  296. }
  297. dayWeight := math.Round(1.0 * float64(c.CurrentWeight-c.LastSecondWeight) / float64(days))
  298. return dayWeight / 1000
  299. }
  300. return 0
  301. }
  302. // GetAbortionAge 流产天数
  303. func (c *Cow) GetAbortionAge() int32 {
  304. if c.LastAbortionAt > 0 && c.AdmissionStatus == pasturePb.AdmissionStatus_Admission {
  305. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastAbortionAt) / 86400))
  306. }
  307. return 0
  308. }
  309. // GetLactationAge 泌乳天数
  310. func (c *Cow) GetLactationAge() int32 {
  311. if c.LastCalvingAt <= 0 {
  312. return 0
  313. }
  314. if c.MilkKind == pasturePb.CowMilk_Lactation ||
  315. c.BreedStatus == pasturePb.BreedStatus_Calving ||
  316. c.BreedStatus == pasturePb.BreedStatus_Abort {
  317. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastCalvingAt) / 86400))
  318. }
  319. return c.LactationAge
  320. }
  321. // GetDryMilkAge 干奶天数
  322. func (c *Cow) GetDryMilkAge() int32 {
  323. if c.MilkKind == pasturePb.CowMilk_Dry_Milk {
  324. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastDryMilkAt) / 86400))
  325. }
  326. return c.DryMilkAge
  327. }
  328. func (c *Cow) GetMatingAge() int32 {
  329. if c.LastMatingAt <= 0 {
  330. return 0
  331. }
  332. return int32(math.Floor(float64(time.Now().Local().Unix()-c.LastMatingAt) / 86400))
  333. }
  334. type CowSlice []*Cow
  335. func (c CowSlice) ToPB(
  336. cowTypeMap map[pasturePb.CowType_Kind]string,
  337. breedStatusMap map[pasturePb.BreedStatus_Kind]string,
  338. cowKindMap map[pasturePb.CowKind_Kind]string,
  339. cowSourceMap map[pasturePb.CowSource_Kind]string,
  340. admissionStatusMap map[pasturePb.AdmissionStatus_Kind]string,
  341. healthStatusMap map[pasturePb.HealthStatus_Kind]string,
  342. purposeMap map[pasturePb.Purpose_Kind]string,
  343. pregnancyAge int32,
  344. ) []*pasturePb.CowDetails {
  345. res := make([]*pasturePb.CowDetails, len(c))
  346. for i, v := range c {
  347. sex := "公"
  348. if v.Sex == pasturePb.Genders_Female {
  349. sex = "母"
  350. }
  351. lastWeightAtFormat := ""
  352. if v.LastWeightAt > 0 {
  353. lastWeightAtFormat = time.Unix(v.LastWeightAt, 0).Local().Format(LayoutDate2)
  354. }
  355. isPregnantName := ""
  356. if v.IsPregnant == pasturePb.IsShow_Ok {
  357. isPregnantName = "已孕"
  358. } else {
  359. isPregnantName = "未孕"
  360. }
  361. admissionAtFormat := ""
  362. if v.AdmissionAt > 0 {
  363. admissionAtFormat = time.Unix(v.AdmissionAt, 0).Local().Format(LayoutDate2)
  364. }
  365. birthAtFormat := ""
  366. if v.BirthAt > 0 {
  367. birthAtFormat = time.Unix(v.BirthAt, 0).Local().Format(LayoutDate2)
  368. }
  369. weaningAtFormat := ""
  370. if v.WeaningAt > 0 {
  371. weaningAtFormat = time.Unix(v.WeaningAt, 0).Local().Format(LayoutDate2)
  372. }
  373. firstMatingAtFormat := ""
  374. if v.FirstMatingAt > 0 {
  375. firstMatingAtFormat = time.Unix(v.FirstMatingAt, 0).Local().Format(LayoutDate2)
  376. }
  377. lastMatingAtFormat := ""
  378. if v.LastMatingAt > 0 {
  379. lastMatingAtFormat = time.Unix(v.LastMatingAt, 0).Local().Format(LayoutDate2)
  380. }
  381. lastPregnantCheckAtFormat := ""
  382. if v.LastPregnantCheckAt > 0 {
  383. lastPregnantCheckAtFormat = time.Unix(v.LastPregnantCheckAt, 0).Local().Format(LayoutDate2)
  384. }
  385. lastCalvingAtFormat := ""
  386. if v.LastCalvingAt > 0 {
  387. lastCalvingAtFormat = time.Unix(v.LastCalvingAt, 0).Local().Format(LayoutDate2)
  388. }
  389. lastAbortionAtFormat := ""
  390. if v.LastAbortionAt > 0 {
  391. lastAbortionAtFormat = time.Unix(v.LastAbortionAt, 0).Local().Format(LayoutDate2)
  392. }
  393. lastSecondWeightAtFormat := ""
  394. if v.LastSecondWeightAt > 0 {
  395. lastSecondWeightAtFormat = time.Unix(v.LastSecondWeightAt, 0).Local().Format(LayoutDate2)
  396. }
  397. departureAtFormat := ""
  398. if v.DepartureAt > 0 {
  399. departureAtFormat = time.Unix(v.DepartureAt, 0).Local().Format(LayoutDate2)
  400. }
  401. lastForbiddenMatingAtFormat := ""
  402. if v.LastForbiddenMatingAt > 0 {
  403. lastForbiddenMatingAtFormat = time.Unix(v.LastForbiddenMatingAt, 0).Local().Format(LayoutDate2)
  404. }
  405. lastEstrusAtFormat := ""
  406. if v.LastEstrusAt > 0 {
  407. lastEstrusAtFormat = time.Unix(v.LastEstrusAt, 0).Local().Format(LayoutDate2)
  408. }
  409. cowTypeName := ""
  410. if cn, ok := cowTypeMap[v.CowType]; ok {
  411. cowTypeName = cn
  412. }
  413. breedStatusName := ""
  414. if bs, ok := breedStatusMap[v.BreedStatus]; ok {
  415. breedStatusName = bs
  416. }
  417. cowKindName := ""
  418. if ck, ok := cowKindMap[v.CowKind]; ok {
  419. cowKindName = ck
  420. }
  421. sourceName := ""
  422. if sn, ok := cowSourceMap[v.SourceKind]; ok {
  423. sourceName = sn
  424. }
  425. admissionStatusName := ""
  426. if as, ok := admissionStatusMap[v.AdmissionStatus]; ok {
  427. admissionStatusName = as
  428. }
  429. healthStatusName := ""
  430. if hs, ok := healthStatusMap[v.HealthStatus]; ok {
  431. healthStatusName = hs
  432. }
  433. pregnancyDate := ""
  434. if pregnancyAgeAt := v.GetDaysPregnancy(pregnancyAge); pregnancyAgeAt > 0 {
  435. pregnancyDate = time.Unix(int64(pregnancyAge), 0).Local().Format(LayoutDate2)
  436. }
  437. purposeName := ""
  438. if pn, ok := purposeMap[v.PurposeKind]; ok {
  439. purposeName = pn
  440. }
  441. pregnancyCheckTimes := "初检"
  442. if v.PregnancyCheckName == PregnantCheckForSecond {
  443. pregnancyCheckTimes = "复检"
  444. }
  445. res[i] = &pasturePb.CowDetails{
  446. CowId: int32(v.Id),
  447. Sex: sex,
  448. NeckRingNumber: v.NeckRingNumber,
  449. PenName: v.PenName,
  450. Lact: v.Lact,
  451. CowTypeName: cowTypeName,
  452. CowType: v.CowType,
  453. BreedStatusName: breedStatusName,
  454. BreedStatus: v.BreedStatus,
  455. CowKindName: cowKindName,
  456. EarNumber: v.EarNumber,
  457. BirthWeight: float32(v.BirthWeight) / 1000,
  458. CurrentWeight: float32(v.CurrentWeight) / 1000,
  459. CurrentHeight: int32(v.CurrentHeight),
  460. DayAge: v.DayAge,
  461. AdmissionAge: v.AdmissionAge,
  462. SourceName: sourceName,
  463. MotherNumber: v.MotherNumber,
  464. FatherNumber: v.FatherNumber,
  465. AdmissionStatusName: admissionStatusName,
  466. HealthStatusName: healthStatusName,
  467. IsPregnantName: isPregnantName,
  468. AdmissionAtFormat: admissionAtFormat,
  469. BirthAtFormat: birthAtFormat,
  470. WeaningAtFormat: weaningAtFormat,
  471. CalvingAge: v.GetCalvingAge(),
  472. AbortionAge: v.AbortionAge,
  473. MatingTimes: v.MatingTimes,
  474. AbortionTimes: v.AbortionTimes,
  475. FirstMatingAtFormat: firstMatingAtFormat,
  476. LastMatingAtFormat: lastMatingAtFormat,
  477. LastBullNumber: v.LastBullNumber,
  478. LastPregnantCheckAtFormat: lastPregnantCheckAtFormat,
  479. LastWeightAtFormat: lastWeightAtFormat,
  480. LastCalvingAtFormat: lastCalvingAtFormat,
  481. LastAbortionAtFormat: lastAbortionAtFormat,
  482. LastSecondWeight: float32(v.LastSecondWeight) / 1000,
  483. LastSecondWeightAtFormat: lastSecondWeightAtFormat,
  484. DepartureAtFormat: departureAtFormat,
  485. DeparturePrice: v.DeparturePrice,
  486. DepartureWeight: float32(v.DepartureAvgWeight / 1000),
  487. LastForbiddenMatingAtFormat: lastForbiddenMatingAtFormat,
  488. LastEstrusAtFormat: lastEstrusAtFormat,
  489. PregnancyDate: pregnancyDate,
  490. PregnancyCheckTimes: pregnancyCheckTimes,
  491. AvgDailyWeight: float32(v.GetAverageDailyWeight()),
  492. EleEarNumber: v.EleEarNumber,
  493. AdmissionPrice: v.AdmissionPrice,
  494. PurposeName: purposeName,
  495. }
  496. }
  497. return res
  498. }
  499. func (c CowSlice) ToPB2(penWeightSlice PenWeightSlice) []*pasturePb.CowList {
  500. res := make([]*pasturePb.CowList, len(c))
  501. for i, v := range c {
  502. penWeight := penWeightSlice.GetPenWeight(v.PenId)
  503. penAvgWeight := float32(0)
  504. cowPenAvgWeightDiffValue := float32(0)
  505. if penWeight != nil {
  506. penAvgWeight = float32(penWeight.AvgWeight) / 1000
  507. cowPenAvgWeightDiffValue = float32(v.CurrentWeight-int64(penWeight.AvgWeight)) / 1000
  508. }
  509. res[i] = &pasturePb.CowList{
  510. CowId: int32(v.Id),
  511. DayAge: v.DayAge,
  512. AverageDailyWeightGain: float32(v.GetAverageDailyWeight()),
  513. EarNumber: v.EarNumber,
  514. PenName: v.PenName,
  515. BirthAt: int32(v.BirthAt),
  516. BirthWeight: float32(v.BirthWeight) / 1000,
  517. CurrentWeight: float32(v.CurrentWeight) / 1000,
  518. LastWeightAt: int32(v.LastWeightAt),
  519. AdmissionAge: v.AdmissionAge,
  520. AdmissionWeight: float32(v.AbortionAge) / 1000,
  521. PreviousStageDailyWeight: float32(v.GetPreviousStageDailyWeight()),
  522. PenAvgWeight: penAvgWeight,
  523. CowPenAvgWeightDiffValue: cowPenAvgWeightDiffValue,
  524. }
  525. }
  526. return res
  527. }
  528. // NewEnterCow 入场新增牛只
  529. func NewEnterCow(pastureId int64, req *pasturePb.EventEnterRequest, penMap map[int32]*Pen) *Cow {
  530. var isPregnant = pasturePb.IsShow_No
  531. if req.BreedStatus == pasturePb.BreedStatus_Pregnant {
  532. isPregnant = pasturePb.IsShow_Ok
  533. }
  534. admissionAt := int64(0)
  535. switch req.CowSource {
  536. case pasturePb.CowSource_Calving:
  537. admissionAt = int64(req.BirthAt)
  538. case pasturePb.CowSource_Transfer_In:
  539. admissionAt = int64(req.EnterAt)
  540. case pasturePb.CowSource_Buy:
  541. admissionAt = int64(req.EnterAt)
  542. }
  543. breedStatus := pasturePb.BreedStatus_Invalid
  544. isForbiddenMating := pasturePb.IsShow_No
  545. cowType := pasturePb.CowType_Invalid
  546. if req.Sex == pasturePb.Genders_Female {
  547. if req.Lact == 0 && req.MatingAt <= 0 {
  548. breedStatus = pasturePb.BreedStatus_UnBreed
  549. cowType = pasturePb.CowType_Reserve_Calf
  550. }
  551. if req.MatingAt > 0 && (req.PregnantCheckResult != pasturePb.PregnantCheckResult_Pregnant &&
  552. req.PregnantCheckResult != pasturePb.PregnantCheckResult_UnPregnant) &&
  553. req.MatingAt >= req.CalvingAt && req.MatingAt >= req.AbortionAt {
  554. breedStatus = pasturePb.BreedStatus_Breeding
  555. if req.Lact == 0 {
  556. cowType = pasturePb.CowType_Reserve_Calf
  557. } else {
  558. cowType = pasturePb.CowType_Breeding_Calf
  559. }
  560. }
  561. if req.MatingAt > 0 && req.PregnantCheckResult == pasturePb.PregnantCheckResult_Pregnant &&
  562. req.MatingAt >= req.CalvingAt && req.MatingAt >= req.AbortionAt {
  563. breedStatus = pasturePb.BreedStatus_Pregnant
  564. if req.Lact == 0 {
  565. cowType = pasturePb.CowType_Reserve_Calf
  566. } else {
  567. cowType = pasturePb.CowType_Breeding_Calf
  568. }
  569. }
  570. if req.MatingAt > 0 && req.PregnantCheckResult == pasturePb.PregnantCheckResult_UnPregnant &&
  571. req.MatingAt >= req.CalvingAt && req.MatingAt >= req.AbortionAt {
  572. breedStatus = pasturePb.BreedStatus_Empty
  573. if req.Lact == 0 {
  574. cowType = pasturePb.CowType_Reserve_Calf
  575. } else {
  576. cowType = pasturePb.CowType_Breeding_Calf
  577. }
  578. }
  579. if req.CalvingAt > 0 && req.CalvingAt >= req.MatingAt && req.CalvingAt >= req.AbortionAt {
  580. breedStatus = pasturePb.BreedStatus_Calving
  581. cowType = pasturePb.CowType_Breeding_Calf
  582. }
  583. if req.AbortionAt > 0 && req.AbortionAt >= req.CalvingAt && req.AbortionAt >= req.MatingAt {
  584. breedStatus = pasturePb.BreedStatus_Abort
  585. cowType = pasturePb.CowType_Breeding_Calf
  586. }
  587. }
  588. if breedStatus == pasturePb.BreedStatus_No_Mating {
  589. isForbiddenMating = pasturePb.IsShow_Ok
  590. }
  591. cow := &Cow{
  592. PastureId: pastureId,
  593. Sex: req.Sex,
  594. EarNumber: req.EarNumber,
  595. PenId: req.PenId,
  596. PenName: penMap[req.PenId].Name,
  597. Lact: req.Lact,
  598. CowType: cowType,
  599. BreedStatus: breedStatus,
  600. CowKind: req.CowKind,
  601. SourceKind: req.CowSource,
  602. FatherNumber: req.FatherNumber,
  603. MotherNumber: req.MotherNumber,
  604. AdmissionStatus: pasturePb.AdmissionStatus_Admission,
  605. HealthStatus: pasturePb.HealthStatus_Health,
  606. PurposeKind: req.PurposeKind,
  607. EleEarNumber: req.EleEarNumber,
  608. IsPregnant: isPregnant,
  609. IsForbiddenMating: isForbiddenMating,
  610. WeaningAt: int64(req.WeaningAt),
  611. BirthAt: int64(req.BirthAt),
  612. AdmissionWeight: int64(req.Weight * 1000),
  613. FirstMatingAt: int64(req.MatingAt),
  614. LastMatingAt: int64(req.MatingAt),
  615. LastPregnantCheckAt: int64(req.PregnancyCheckAt),
  616. AdmissionAt: admissionAt,
  617. BirthWeight: int64(req.Weight * 1000),
  618. LastWeightAt: int64(req.EstrusAt),
  619. CurrentWeight: int64(req.Weight * 1000),
  620. LastDryMilkAt: int64(req.DryMilkAt),
  621. MatingTimes: req.MatingTimes,
  622. LastCalvingAt: int64(req.CalvingAt),
  623. LastBullNumber: req.BullNumber,
  624. LastAbortionAt: int64(req.AbortionAt),
  625. AdmissionPrice: req.Price,
  626. BatchNumber: req.BatchNumber,
  627. }
  628. cow.AdmissionAge = cow.GetAdmissionAge()
  629. cow.DayAge = cow.GetDayAge()
  630. return cow
  631. }
  632. // NewCalfCow 产犊新增
  633. func NewCalfCow(matherInfo *Cow, calf *CalvingCalf) *Cow {
  634. return &Cow{
  635. PastureId: calf.PastureId,
  636. Sex: calf.Sex,
  637. EarNumber: calf.EarNumber,
  638. PenId: calf.PenId,
  639. PenName: calf.PenName,
  640. CowType: pasturePb.CowType_Lactating_Calf, // 哺乳犊牛
  641. BreedStatus: pasturePb.BreedStatus_UnBreed, // 未配
  642. CowKind: matherInfo.CowKind, // 牛只品种
  643. BirthWeight: calf.BirthWeight,
  644. BirthAt: calf.BirthAt,
  645. SourceKind: pasturePb.CowSource_Calving, // 产犊方式
  646. FatherNumber: matherInfo.LastBullNumber,
  647. MotherNumber: matherInfo.EarNumber,
  648. AdmissionStatus: pasturePb.AdmissionStatus_Admission,
  649. IsPregnant: pasturePb.IsShow_No,
  650. AdmissionAt: calf.BirthAt,
  651. }
  652. }
  653. type BarCowStruct struct {
  654. Number int32 `json:"number"`
  655. TypeId pasturePb.CowType_Kind `json:"type_id"`
  656. }
  657. // BarCowStructSlice 首页牛群结构
  658. type BarCowStructSlice []*BarCowStruct
  659. func (b BarCowStructSlice) ToPB(cowTypeMap map[pasturePb.CowType_Kind]string, count int32) []*pasturePb.BarCowStruct {
  660. var pb []*pasturePb.BarCowStruct
  661. for _, v := range b {
  662. name := fmt.Sprintf("%s", cowTypeMap[v.TypeId])
  663. pb = append(pb, &pasturePb.BarCowStruct{Name: name, Value: v.Number})
  664. }
  665. return pb
  666. }
  667. type CowWeightRange struct {
  668. WeightRange string `json:"weight_range"`
  669. Count int32 `json:"count"`
  670. }
  671. func (c CowSlice) WeightRangeToPB(penMap map[int32]*Pen) []*pasturePb.CowList {
  672. res := make([]*pasturePb.CowList, len(c))
  673. for i, v := range c {
  674. penName := ""
  675. if pen, ok := penMap[v.PenId]; ok {
  676. penName = pen.Name
  677. }
  678. res[i] = &pasturePb.CowList{
  679. CowId: int32(v.Id),
  680. DayAge: v.DayAge,
  681. AverageDailyWeightGain: float32(v.GetAverageDailyWeight()),
  682. PreviousStageDailyWeight: float32(v.GetPreviousStageDailyWeight()),
  683. EarNumber: v.EarNumber,
  684. PenName: penName,
  685. BirthAt: int32(v.BirthAt),
  686. BirthWeight: float32(v.BirthWeight) / 1000,
  687. CurrentWeight: float32(v.CurrentWeight) / 1000,
  688. LastWeightAt: int32(v.LastWeightAt),
  689. }
  690. }
  691. return res
  692. }
  693. func (c CowSlice) LongTermInfertilityToPB(breedStatusMap map[pasturePb.BreedStatus_Kind]string) []*pasturePb.LongTermInfertility {
  694. res := make([]*pasturePb.LongTermInfertility, len(c))
  695. for i, v := range c {
  696. breedStatusName := ""
  697. if breedStatus, ok := breedStatusMap[v.BreedStatus]; ok {
  698. breedStatusName = breedStatus
  699. }
  700. lastCalvingAtFormat := ""
  701. if v.LastCalvingAt > 0 {
  702. lastCalvingAtFormat = time.Unix(v.LastCalvingAt, 0).Local().Format(LayoutDate2)
  703. }
  704. lastAbortionAtFormat := ""
  705. if v.LastAbortionAt > 0 {
  706. lastAbortionAtFormat = time.Unix(v.LastAbortionAt, 0).Local().Format(LayoutDate2)
  707. }
  708. lastMatingAtFormat := ""
  709. if v.LastMatingAt > 0 {
  710. lastMatingAtFormat = time.Unix(v.LastMatingAt, 0).Local().Format(LayoutDate2)
  711. }
  712. res[i] = &pasturePb.LongTermInfertility{
  713. CowId: int32(v.Id),
  714. EarNumber: v.EarNumber,
  715. Lact: v.Lact,
  716. PenId: v.PenId,
  717. CalvingAge: v.CalvingAge,
  718. PenName: v.PenName,
  719. BreedStatusName: breedStatusName,
  720. BreedStatus: v.BreedStatus,
  721. LastCalvingAtFormat: lastCalvingAtFormat,
  722. LastAbortionAtFormat: lastAbortionAtFormat,
  723. LastMatingAtFormat: lastMatingAtFormat,
  724. MatingTimes: v.MatingTimes,
  725. LastBullNumber: v.LastBullNumber,
  726. AbortionTimes: v.AbortionTimes,
  727. }
  728. }
  729. return res
  730. }
  731. // CowBehaviorCurveResponse 脖环行为数据
  732. type CowBehaviorCurveResponse struct {
  733. Code int32 `json:"code"`
  734. Msg string `json:"msg"`
  735. Data *CowBehaviorCurveData `json:"data"`
  736. }
  737. type CowBehaviorCurveData struct {
  738. OriginalDateList []int32 `json:"originalDateList"` // 原始行为数据
  739. ChangeDateList []int32 `json:"changeDateList"` // 变化数据
  740. SumDateList []int32 `json:"sumDateList"` // 累计24小时数据
  741. SumChewList []int32 `json:"sumChewList"` // 累计24小时咀嚼
  742. DateTimeList []string `json:"dateTimeList"` // 时间数据
  743. EstrusList map[pasturePb.EstrusLevel_Kind][]string `json:"estrusList"` // 发情预警
  744. EventList []*pasturePb.CowEvent `json:"eventList"` // 事件数据
  745. EventMap map[pasturePb.EventType_Kind]string `json:"eventMap"` // 所有事件
  746. RuminaChange []int32 `json:"ruminaChange"` // 反刍变化
  747. LowActivity int32 `json:"lowActivity"` // 低活动量参数
  748. MiddleActivity int32 `json:"middleActivity"` // 中活动量行数
  749. IQR1 []int32 `json:"IQR1"`
  750. IQR3 []int32 `json:"IQR3"`
  751. }