diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java index a5ce578..4b22d21 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsLineFeignClient.java @@ -27,7 +27,7 @@ import java.util.Map; public interface CsLineFeignClient { @PostMapping("/queryLineById") - HttpResult> queryLineById(@RequestParam("ids") List ids ); + HttpResult> queryLineById(@RequestBody List ids ); @PostMapping("/queryLineByDevId") HttpResult> queryLineByDevId(@RequestParam("id") String id); diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java index 78342c0..0eb54fa 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/line/CslineController.java @@ -53,7 +53,7 @@ public class CslineController extends BaseController { @PostMapping("/queryLineById") @ApiOperation("监测点查询通过id获取") @ApiImplicitParam(name = "ids", value = "设备id获集合", required = true) - public HttpResult> queryLineById(@RequestParam List ids){ + public HttpResult> queryLineById(@RequestBody List ids){ String methodDescribe = getMethodDescribe("queryLineById"); List csLinePOS = csLinePOService.listByIds(ids); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, csLinePOS, methodDescribe); diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java index d4e5a9d..d15da4c 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java @@ -1455,19 +1455,19 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl 50*1024) { lsBytes = Arrays.copyOfRange(bytes, (i - 1) * cap, i * cap); ReqAndResDto.Req req = getPojo(i,path,bytes.length,lsBytes,(i-1)*cap); - publisher.send("/Pfm/DevFileCmd/" + version + "/" + id, new Gson().toJson(req), 1, false); - logDto.setOperate(id + "设备上送文件,这是第" + i + "帧"); + publisher.send("/Pfm/DevFileCmd/" + version + "/" + nDid, new Gson().toJson(req), 1, false); + logDto.setOperate(nDid + "设备上送文件,这是第" + i + "帧"); logDto.setResult(1); length = length - cap; //判断是否重发 - sendNextStep(logDto,path,bytes.length,lsBytes,(i-1)*cap,version,id,i,false); - FileRedisDto fileRedisDto = (FileRedisDto) redisUtil.getObjectByKey(AppRedisKey.UPLOAD.concat(id).concat(String.valueOf(i))); + sendNextStep(logDto,path,bytes.length,lsBytes,(i-1)*cap,version,nDid,i,false); + FileRedisDto fileRedisDto = (FileRedisDto) redisUtil.getObjectByKey(AppRedisKey.UPLOAD.concat(nDid).concat(String.valueOf(i))); //重发之后判断继续循环还是跳出循环 if (!Objects.isNull(fileRedisDto) && !Objects.equals(fileRedisDto.getCode(),200)) { redisUtil.delete("uploading:" + nDid); @@ -1476,11 +1476,11 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl