Compare commits

..

No commits in common. 'e538d497f629cfa623d56472685c626588ba1cce' and '8e78307efccb255f9a83b1b215ea813f63373e2f' have entirely different histories.

  1. 7
      model/device.go
  2. 34
      parser/devicePrsInternal.go

7
model/device.go

@ -60,13 +60,6 @@ const (
CMD_RUP_GARMD_RESP = 131 CMD_RUP_GARMD_RESP = 131
CMD_RUP_CONN_PARM = 105 CMD_RUP_CONN_PARM = 105
CMD_RUP_ODO = 106 CMD_RUP_ODO = 106
// add
CMD_RUP_FUEL_LEVEL = 205
CMD_RUP_ENGINE_SPEED = 197
CMD_RUP_HIGH_RESOL_ENGINE_TOTAL_FUEL_USED = 92
CMD_RUP_HIGH_RESOL_TOTAL_VEHICLE_DISTANCE = 114
CMD_FUEL_LEVEL1 = 207
) )
// Device and standard Tag type // Device and standard Tag type

34
parser/devicePrsInternal.go

@ -9,7 +9,6 @@ import (
"encoding/binary" "encoding/binary"
"fmt" "fmt"
"time" "time"
"math"
//"encoding/hex" //"encoding/hex"
"strconv" "strconv"
"sort" "sort"
@ -18,10 +17,6 @@ import (
"../model" "../model"
) )
const (
ALLOWED_TIME_MINUTES = -5
)
type ruptelaTchHeader struct { type ruptelaTchHeader struct {
Length uint16 Length uint16
IMEI uint64 IMEI uint64
@ -224,12 +219,9 @@ func parseData(data []byte, imei uint64, tagOption *opt.Options) (rec DeviceReco
ioVal := convBinaryToUint16(addOneByteInTwoByte(data[currByte:plusByte]),2,"io1Val") ioVal := convBinaryToUint16(addOneByteInTwoByte(data[currByte:plusByte]),2,"io1Val")
//fmt.Printf("io1Val %d\n",ioVal) //fmt.Printf("io1Val %d\n",ioVal)
strVal := fmt.Sprintf("%v",int16(ioVal))
//fmt.Printf("strVal %v\n",strVal)
tagDevice_ := tags_[strconv.Itoa(int(ioID))] tagDevice_ := tags_[strconv.Itoa(int(ioID))]
tagDevice_.TagId = strconv.Itoa(int(ioID)) tagDevice_.TagId = strconv.Itoa(int(ioID))
tagDevice_.TagVal = strVal tagDevice_.TagVal = strconv.Itoa(int(ioVal))
if tagDevice_.TagName != ""{ if tagDevice_.TagName != ""{
//tags_[strconv.Itoa(int(ioID))] = tagDevice_ //tags_[strconv.Itoa(int(ioID))] = tagDevice_
tags_[tagDevice_.TagName] = tagDevice_ tags_[tagDevice_.TagName] = tagDevice_
@ -257,13 +249,9 @@ func parseData(data []byte, imei uint64, tagOption *opt.Options) (rec DeviceReco
plusByte = currByte + 2 plusByte = currByte + 2
ioVal := convBinaryToUint16(data[currByte:plusByte],2,"io2Val") ioVal := convBinaryToUint16(data[currByte:plusByte],2,"io2Val")
//fmt.Printf("io2Val %d\n",ioVal) //fmt.Printf("io2Val %d\n",ioVal)
// fmt.Printf("io2Val INT %d\n",int16(ioVal))
strVal := fmt.Sprintf("%v",int16(ioVal))
//fmt.Printf("strVal %v\n",strVal)
tagDevice_ := tags_[strconv.Itoa(int(ioID))] tagDevice_ := tags_[strconv.Itoa(int(ioID))]
tagDevice_.TagVal = strVal tagDevice_.TagVal = strconv.Itoa(int(ioVal))
if tagDevice_.TagName != ""{ if tagDevice_.TagName != ""{
tags_[tagDevice_.TagName] = tagDevice_ tags_[tagDevice_.TagName] = tagDevice_
} }
@ -289,11 +277,8 @@ func parseData(data []byte, imei uint64, tagOption *opt.Options) (rec DeviceReco
ioVal := convBinaryToInt32(data[currByte:plusByte],4,"io4Val") ioVal := convBinaryToInt32(data[currByte:plusByte],4,"io4Val")
//fmt.Printf("io4Val %d\n",ioVal) //fmt.Printf("io4Val %d\n",ioVal)
strVal := fmt.Sprintf("%v",int32(ioVal))
//fmt.Printf("strVal %v\n",strVal)
tagDevice_ := tags_[strconv.Itoa(int(ioID))] tagDevice_ := tags_[strconv.Itoa(int(ioID))]
tagDevice_.TagVal = strVal tagDevice_.TagVal = strconv.FormatInt(int64(ioVal), 10)
if tagDevice_.TagName != ""{ if tagDevice_.TagName != ""{
tags_[tagDevice_.TagName] = tagDevice_ tags_[tagDevice_.TagName] = tagDevice_
} }
@ -319,11 +304,8 @@ func parseData(data []byte, imei uint64, tagOption *opt.Options) (rec DeviceReco
ioVal := convBinaryToInt64(data[currByte:plusByte],8,"io8Val") ioVal := convBinaryToInt64(data[currByte:plusByte],8,"io8Val")
//fmt.Printf("io8Val %d\n",ioVal) //fmt.Printf("io8Val %d\n",ioVal)
strVal := fmt.Sprintf("%v",int64(ioVal))
//fmt.Printf("strVal %v\n",strVal)
tagDevice_ := tags_[strconv.Itoa(int(ioID))] tagDevice_ := tags_[strconv.Itoa(int(ioID))]
tagDevice_.TagVal = strVal tagDevice_.TagVal = strconv.FormatInt(int64(ioVal), 10)
if tagDevice_.TagName != ""{ if tagDevice_.TagName != ""{
tags_[tagDevice_.TagName] = tagDevice_ tags_[tagDevice_.TagName] = tagDevice_
} }
@ -338,18 +320,10 @@ func parseData(data []byte, imei uint64, tagOption *opt.Options) (rec DeviceReco
} }
deviceRecord.TagDevices = tags_ deviceRecord.TagDevices = tags_
tstampToNow := time.Since(deviceRecord.Tstamp)
hCurr := math.Round(tstampToNow.Minutes()*100)/100
if hCurr >= ALLOWED_TIME_MINUTES {
deviceRecords = append(deviceRecords, deviceRecord) deviceRecords = append(deviceRecords, deviceRecord)
}
} }
rec.NumRec = uint16(len(deviceRecords))
//sort ascending by date //sort ascending by date
sort.Sort(ByTstamp(deviceRecords)) sort.Sort(ByTstamp(deviceRecords))

Loading…
Cancel
Save