|  |  |  | 
|---|
|  |  |  | info.ugRtuStateList = info.ugRtuStateList.stream().sorted(comparator).collect(Collectors.toList()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //通信中间件传过来的机构tag,以用于查找数据源 | 
|---|
|  |  |  | String token = req.getHeader(Constant.UserTokenKeyInHeader); | 
|---|
|  |  |  | String token = req.getHeader(Constant.TokenKeyInHeader); | 
|---|
|  |  |  | DataSourceContext.set(token); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(cache == null){ | 
|---|
|  |  |  | 
|---|
|  |  |  | rtu.currentPackage = 0 ; | 
|---|
|  |  |  | rtu.currentRamAddr = 0x00 ; | 
|---|
|  |  |  | rtu.lastDownDt = "" ; | 
|---|
|  |  |  | rtu.lastDownDtAt = 0L ; | 
|---|
|  |  |  | rtu.reTryTimes = 0 ; | 
|---|
|  |  |  | rtu.isOver = false ; | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | 
|---|
|  |  |  | rtu.currentPackage = 1 ; | 
|---|
|  |  |  | rtu.currentRamAddr = 0x00 ; | 
|---|
|  |  |  | rtu.lastDownDt = DateTime.yyyy_MM_dd_HH_mm_ss() ; | 
|---|
|  |  |  | rtu.lastDownDtAt = System.currentTimeMillis() ; | 
|---|
|  |  |  | rtu.reTryTimes = 0 ; | 
|---|
|  |  |  | rtu.isOver = false ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | rtu.currentPackage = 1 ; | 
|---|
|  |  |  | rtu.currentRamAddr = 0x00 ; | 
|---|
|  |  |  | rtu.lastDownDt = DateTime.yyyy_MM_dd_HH_mm_ss() ; | 
|---|
|  |  |  | rtu.lastDownDtAt = System.currentTimeMillis() ; | 
|---|
|  |  |  | rtu.reTryTimes++ ; | 
|---|
|  |  |  | rtu.isOver = false ; | 
|---|
|  |  |  | return ; | 
|---|
|  |  |  | 
|---|
|  |  |  | rtu.currentPackage += 1 ; | 
|---|
|  |  |  | rtu.currentRamAddr = 0x00 + UpgradeRtu.RAMADDRADD ; | 
|---|
|  |  |  | rtu.lastDownDt = DateTime.yyyy_MM_dd_HH_mm_ss() ; | 
|---|
|  |  |  | rtu.lastDownDtAt = System.currentTimeMillis() ; | 
|---|
|  |  |  | rtu.isOver = false ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|