流式询问

curl --location --globoff 'http://127.0.0.1:8014/test/ai/flux/simple?message=%E5%B8%AE%E6%88%91%20%E4%BC%98%E5%8C%96%E4%B8%80%E4%B8%8B%20%E4%BB%A3%E7%A0%81%20%E5%90%8C%E6%97%B6%E8%BE%93%E5%87%BA%20%E4%BC%98%E5%8C%96%E5%90%8E%E7%9A%84%E4%BB%A3%E7%A0%81%20%0D%0A%0D%0A%40Override%20%20%20%20public%20void%20runTask()%20{%20%20%20%20%20%20%20%20log.info(%22IotDeviceAlarmTask%20device%20run%20status%20task%20.......%20%22)%3B%20%20%20%20%20%20%20%20LambdaQueryWrapper%3CDeviceIot%3E%20chainWrapper%20%3D%20new%20LambdaQueryWrapper%3C%3E()%3B%20%20%20%20%20%20%20%20chainWrapper.eq(DeviceIot%3A%3AgetDelFlag%2C0)%3B%20%20%20%20%20%20%20%20List%3CDeviceIot%3E%20deviceIotList%20%3D%20deviceIotService.list(chainWrapper)%3B%20%20%20%20%20%20%20%20if%20(CollectionUtils.isEmpty(deviceIotList))%20{%20%20%20%20%20%20%20%20%20%20%20%20return%3B%20%20%20%20%20%20%20%20}%20%20%20%20%20%20%20%20deviceIotList.forEach(deviceInfo%20-%3E%20{%20%20%20%20%20%20%20%20%20%20%20%20Long%20deviceId%20%3D%20deviceInfo.getDeviceId()%3B%20%20%20%20%20%20%20%20%20%20%20%20IotRecordParamReq%20iotRecordParamReq%20%3D%20new%20IotRecordParamReq()%3B%20%20%20%20%20%20%20%20%20%20%20%20iotRecordParamReq.setDeviceId(deviceId)%3B%20%20%20%20%20%20%20%20%20%20%20%20%2F%2F%20%E8%AE%BE%E5%A4%87%20%E7%AC%AC%E4%B8%80%E6%AC%A1%20%E4%B8%8A%E6%8A%A5%E6%97%B6%E9%97%B4%20%20%20%20%20%20%20%20%20%20%20%20if%20(ObjectUtils.isEmpty(deviceInfo.getFirstGatherTime()))%20{%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20Date%20firstGatherTime%20%3D%20getFirstGatherTime(deviceId)%3B%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20if%20(firstGatherTime%20!%3D%20null)%20{%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20deviceInfo.setFirstGatherTime(firstGatherTime)%3B%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20}%20%20%20%20%20%20%20%20%20%20%20%20}%20%20%20%20%20%20%20%20%20%20%20%20%2F%2F%20%E5%88%A4%E6%96%AD%E5%BD%93%E5%89%8D%E6%97%B6%E9%97%B4%E6%98%AF%E5%90%A6%E5%B0%8F%E4%BA%8E%E6%8C%87%E5%AE%9A%E6%97%B6%E9%97%B4%E7%BD%91%E5%85%B3%20%20%20%20%20%20%20%20%20%20%20%20Integer%20gatewayStatus%20%3D%200%3B%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20Long%20gatherRate%20%3D%20gatherRate(deviceId)%3B%20%20%20%20%20%20%20%20%20%20%20%20if%20(gatherRate%20!%3D%20null%20%26%26%20gatherRate%20%3E%200L%20%26%26%20gatherRate%20%3C%3D%20deviceInfo.getGatherRate()){%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20gatewayStatus%20%3D%201%3B%20%20%20%20%20%20%20%20%20%20%20%20}%20%20%20%20%20%20%20%20%20%20%20%20deviceInfo.setGatewayStatus(gatewayStatus)%3B%20%20%20%20%20%20%20%20%20%20%20%20%2F%2F%20%E5%88%A4%E6%96%AD%E5%BD%93%E5%89%8D%E6%97%B6%E9%97%B4%E6%98%AF%E5%90%A6%E5%9C%A8%E7%BA%BF%20%20%20%20%20%20%20%20%20%20%20%20Integer%20devStatus%20%3D%200%3B%20%20%20%20%20%20%20%20%20%20%20%20IotRecordParamDto%20deviceRecord%20%3D%20iotRecordParamService.getDeviceRecord(iotRecordParamReq)%3B%20%20%20%20%20%20%20%20%20%20%20%20if%20(deviceRecord%20!%3D%20null%20%26%26%20gatherRate%20!%3D%20null%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%26%26%20gatherRate%20%3E%200L%20%26%26%20gatherRate%20%3C%3D%20deviceInfo.getGatherRate()){%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20devStatus%20%3D%20deviceRecord.getDevStatus()%3B%20%20%20%20%20%20%20%20%20%20%20%20}%20%20%20%20%20%20%20%20%20%20%20%20deviceInfo.setStatus(devStatus)%3B%20%20%20%20%20%20%20%20%20%20%20%20deviceIotService.updateById(deviceInfo)%3B%20%20%20%20%20%20%20%20})%3B%20%20%20%20%20%20%20%20log.info(%22IotDeviceAlarmTask%20device%20run%20status%20task%20end%20.......%20%22)%3B%20%20%20%20}' \
--header 'Token: {{TOKEN}}'