| | |
|---|
| | | import com.dy.pipIrrGlobal.voPr.VoOnLineIntake; |
|---|
| | | import com.dy.pipIrrGlobal.voRm.VoUnclosedValve; |
|---|
| | | import com.dy.pipIrrGlobal.voSe.VoVirtualCard; |
|---|
| | | import com.dy.pipIrrWechat.command.qo.OnLineIntakesQO; |
|---|
| | | import lombok.RequiredArgsConstructor; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.dubbo.common.utils.PojoUtils; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | |
|---|
| | | */ |
|---|
| | | public Integer update(RmCommandHistory po) { |
|---|
| | | return rmCommandHistoryMapper.updateByPrimaryKeySelective(po); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取取水口列表 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public QueryResultVo<List<VoOnLineIntake>> selectOnLineIntakes(OnLineIntakesQO qo) { |
|---|
| | | Command com = new Command() ; |
|---|
| | | com.id = Command.defaultId; |
|---|
| | | com.code = "LCD0001"; |
|---|
| | | com.type = "innerCommand"; |
|---|
| | | |
|---|
| | | JSONObject response = (JSONObject) JSON.toJSON(sendCom2Mw(com)); |
|---|
| | | |
|---|
| | | if(response != null && response.getString("code").equals("0001")) { |
|---|
| | | JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment").getJSONObject("onLineMap"); |
|---|
| | | HashMap<String, Boolean> onLineMap = JSON.parseObject(attachment.toJSONString(), HashMap.class); |
|---|
| | | |
|---|
| | | JSONArray jsonArray = new JSONArray(); |
|---|
| | | for (Map.Entry<String, Boolean> entry : onLineMap.entrySet()) { |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | jsonObject.put("rtuAddr", entry.getKey()); |
|---|
| | | jsonObject.put("isOnLine", entry.getValue()); |
|---|
| | | jsonArray.add(jsonObject); |
|---|
| | | } |
|---|
| | | |
|---|
| | | qo.setOnLineMap(jsonArray.toJSONString()); |
|---|
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ; |
|---|
| | | Long itemTotal = prIntakeMapper.getOnLineIntakesCount(params); |
|---|
| | | |
|---|
| | | QueryResultVo<List<VoOnLineIntake>> rsVo = new QueryResultVo<>() ; |
|---|
| | | rsVo.pageSize = qo.pageSize ; |
|---|
| | | rsVo.pageCurr = qo.pageCurr ; |
|---|
| | | rsVo.calculateAndSet(itemTotal, params); |
|---|
| | | rsVo.obj = prIntakeMapper.getOnLineIntakes(params); |
|---|
| | | return rsVo; |
|---|
| | | } else { |
|---|
| | | QueryResultVo<List<VoOnLineIntake>> rsVo = new QueryResultVo<>(); |
|---|
| | | return rsVo; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据操作员获取常用取水口 |
|---|
| | | * @param operator |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public List<VoOnLineIntake> getUsedIntakes(Long operator) { |
|---|
| | | Command com = new Command() ; |
|---|
| | | com.id = Command.defaultId; |
|---|
| | | com.code = "LCD0001"; |
|---|
| | | com.type = "innerCommand"; |
|---|
| | | JSONObject response = (JSONObject) JSON.toJSON(sendCom2Mw(com)); |
|---|
| | | |
|---|
| | | if(response != null && response.getString("code").equals("0001")) { |
|---|
| | | JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment").getJSONObject("onLineMap"); |
|---|
| | | HashMap<String, Boolean> onLineMap = JSON.parseObject(attachment.toJSONString(), HashMap.class); |
|---|
| | | |
|---|
| | | JSONArray jsonArray = new JSONArray(); |
|---|
| | | for (Map.Entry<String, Boolean> entry : onLineMap.entrySet()) { |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | jsonObject.put("rtuAddr", entry.getKey()); |
|---|
| | | jsonObject.put("isOnLine", entry.getValue()); |
|---|
| | | jsonArray.add(jsonObject); |
|---|
| | | } |
|---|
| | | return prIntakeMapper.getUsedIntakes(jsonArray.toJSONString(), operator); |
|---|
| | | } else { |
|---|
| | | return new ArrayList<>(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
