| row.Valid = valid | row.Valid = valid | ||||
| row.Ip4 = ip4 | row.Ip4 = ip4 | ||||
| row.MD5Key = md5key | row.MD5Key = md5key | ||||
| log.Println("INSERT[" + strconv.FormatInt(row.Id, 10) + "]: customerId: " + customerId + " | orderAmount: " + orderCurrency + " " + orderAmount) | |||||
| m.logNewLeanworkIn(row) | |||||
| return row, err | return row, err | ||||
| } | } | ||||
| func (m *TransactionDB) logNewLeanworkIn(row LeanworkIn) { | |||||
| var insert_type string | |||||
| if row.MD5Key == Config.LeanWork.MD5P2P { | |||||
| insert_type = "P2P" | |||||
| } else { | |||||
| insert_type = "FAT" | |||||
| } | |||||
| log.Println(insert_type + " INSERT[" + strconv.FormatInt(row.Id, 10) + "]: customerId: " + row.CustomerId + " | orderAmount: " + row.OrderCurrency + " " + row.OrderAmount) | |||||
| } | |||||
| func (m *TransactionDB) addRpnOut(r RpnOut) (row RpnOut, err error) { | func (m *TransactionDB) addRpnOut(r RpnOut) (row RpnOut, err error) { | ||||
| if err = m.conn(Config); err != nil { | if err = m.conn(Config); err != nil { | ||||
| return row, err | return row, err |