cow.go 31 KB

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