| | |
| | | service.SendAlarm("月度统计创建本月失败", fmt.Sprintf("NewMonthStatsSearch Create err:%v, record: %+v", err, record)) |
| | | } |
| | | |
| | | if oldRecordsMap[productId] != nil && (!inputMap[productId].IsZero() || !outputMap[productId].IsZero()) { |
| | | record.InputAmount = inputMap[productId] |
| | | record.InputMoreUnits = inputMoreUnits |
| | | record.OutputAmount = outputMap[productId] |
| | | record.OutputMoreUnits = outputMoreUnits |
| | | if oldRecordsMap[productId] != nil { |
| | | m := map[string]interface{}{ |
| | | "input_amount": inputMap[productId], |
| | | "input_more_units": inputMoreUnits, |
| | | "output_amount": outputMap[productId], |
| | | "output_more_units": outputMoreUnits, |
| | | "end_more_units": moreUnits, |
| | | "end_amount": amount, |
| | | "end_more_units": moreUnits, |
| | | "end_amount": amount, |
| | | } |
| | | if !inputMap[productId].IsZero() || !outputMap[productId].IsZero() { |
| | | record.InputAmount = inputMap[productId] |
| | | record.InputMoreUnits = inputMoreUnits |
| | | record.OutputAmount = outputMap[productId] |
| | | record.OutputMoreUnits = outputMoreUnits |
| | | m["input_amount"] = inputMap[productId] |
| | | m["input_more_units"] = inputMoreUnits |
| | | m["output_amount"] = outputMap[productId] |
| | | m["output_more_units"] = outputMoreUnits |
| | | } |
| | | err = models.NewMonthStatsSearch().SetOrm(db).SetID(oldRecordsMap[productId].Id).UpdateByMap(m) |
| | | if err != nil { |