| | |
| | | if(commandCode.equals("92") || commandCode.equals("97")) { |
| | | JSONObject job_response = (JSONObject) JSON.toJSON(response_CallBack); |
| | | JSONObject job_param = (JSONObject) JSON.toJSON(param); |
| | | |
| | | JSONObject job_data = job_response.getJSONObject("content").getJSONObject("data"); |
| | | job_data.remove("success"); |
| | | job_data.put("intakeId", intakeId); |
| | | job_data.put("rtuAddr", rtuAddr); |
| | | job_data.put("vcNum", job_param.getString("icCardNo")); |
| | | job_data.put("orderNo", job_param.getString("orderNo")); |
| | | if(!job_data.getBoolean("success")) { |
| | | // 开关阀失败 |
| | | response_CallBack.setCode("10003"); |
| | | response_CallBack.setMsg(CommandResultCode.OPEN_CLOSE_FAIL.getMessage()); |
| | | response_CallBack.setSuccess(false); |
| | | }else { |
| | | // 开关阀成功 |
| | | job_data.remove("success"); |
| | | job_data.put("intakeId", intakeId); |
| | | job_data.put("rtuAddr", rtuAddr); |
| | | job_data.put("vcNum", job_param.getString("icCardNo")); |
| | | job_data.put("orderNo", job_param.getString("orderNo")); |
| | | |
| | | response_CallBack = JSON.parseObject(job_response.toJSONString(), BaseResponse.class); |
| | | response_CallBack = JSON.parseObject(job_response.toJSONString(), BaseResponse.class); |
| | | } |
| | | } |
| | | |
| | | // 回调返回的内容,回调结果写入命令日志表的任务由中间件完成 |