|  |  | 
 |  |  | import com.dy.pipIrrGlobal.daoSe.SeVirtualCardMapper; | 
 |  |  | import com.dy.pipIrrGlobal.pojoRm.RmCommandHistory; | 
 |  |  | import com.dy.pipIrrGlobal.pojoSe.SeClientCard; | 
 |  |  | import com.dy.pipIrrGlobal.voPr.VoOnLineIntake; | 
 |  |  | import com.dy.pipIrrGlobal.voRm.VoIrrigaterProfile; | 
 |  |  | import com.dy.pipIrrGlobal.voRm.VoUnclosedValve; | 
 |  |  | import com.dy.pipIrrGlobal.voSe.VoVirtualCard; | 
 |  |  | 
 |  |  |         comSendUrl = env.getProperty(pro_mw + "." + DataSourceContext.get() + "." + key_mw); | 
 |  |  |  | 
 |  |  |         JSONObject response = (JSONObject) JSON.toJSON(sendCom2Mw(com)); | 
 |  |  |  | 
 |  |  |         JSONArray jsonArray = new JSONArray(); | 
 |  |  |         if(response != null && response.getString("code").equals("0001")) { | 
 |  |  |             JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment"); | 
 |  |  |  | 
 |  |  |             JSONArray jsonArray = new JSONArray(); | 
 |  |  |             if(attachment != null) { | 
 |  |  |                 attachment.forEach((key, value) -> { | 
 |  |  |                     JSONObject jsonObject = new JSONObject(); | 
 |  |  |                     jsonObject.put("rtuAddr", key); | 
 |  |  |                     jsonObject.put("isOnLine", value); | 
 |  |  |                     jsonArray.add(jsonObject); | 
 |  |  |  | 
 |  |  |                 }); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             System.out.println(jsonArray.toJSONString()); | 
 |  |  |             List<VoUnclosedValve> res = rmCommandHistoryMapper.getUnclosedValves(jsonArray.toJSONString(), operator); | 
 |  |  |             if(res != null) { | 
 |  |  |                 return res; | 
 |  |  |             } else { | 
 |  |  |                 return new ArrayList<>(); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         List<VoUnclosedValve> res = rmCommandHistoryMapper.getUnclosedValves(jsonArray.toJSONString(), operator); | 
 |  |  |         if(res != null) { | 
 |  |  |             return res; | 
 |  |  |         } else { | 
 |  |  |             QueryResultVo<List<VoOnLineIntake>> rsVo = new QueryResultVo<>(); | 
 |  |  |             return new ArrayList<>(); | 
 |  |  |         } | 
 |  |  |     } |