DyEnvir_system/src/com/fgkj/actions/Battalarm_dataAction.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
DyEnvir_system/src/com/fgkj/dao/BaseDAO.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
DyEnvir_system/src/com/fgkj/dao/BaseDAOFactory.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
DyEnvir_system/src/com/fgkj/dao/impl/Battalarm_dataImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
DyEnvir_system/src/com/fgkj/services/Battalarm_dataService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
DyEnvir_system/src/com/fgkj/actions/Battalarm_dataAction.java
New file @@ -0,0 +1,32 @@ package com.fgkj.actions; import com.fgkj.dto.Batt_rtdata; import com.fgkj.dto.Battalarm_data; import com.fgkj.services.Battalarm_dataService; import com.fgkj.services.ServiceModel; public class Battalarm_dataAction extends ActionUtil{ private Battalarm_dataService service = new Battalarm_dataService(); private String result; private String json; //根据电池组id查询电池实时告警信息 public String serchByCondition(){ Battalarm_data balarm=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Battalarm_data.class); ServiceModel model = service.serchByCondition(balarm); result = tojson(model); return SUCCESS; } public String getResult() { return result; } public void setJson(String json) { this.json = json; } } DyEnvir_system/src/com/fgkj/dao/BaseDAO.java
@@ -124,6 +124,7 @@ public static final int PROPULSION_MOTOR=67; public static final int DCDISTRIBUTION=68; public static final int ACDISTRIBUTION=69; public static final int BATTALARM_DATA=70; public boolean add(Object obj); // 添加 DyEnvir_system/src/com/fgkj/dao/BaseDAOFactory.java
@@ -5,6 +5,7 @@ import com.fgkj.dao.impl.Batt_realdataImpl; import com.fgkj.dao.impl.Batt_rtdataDAOImpl; import com.fgkj.dao.impl.Batt_rtstateDAOImpl; import com.fgkj.dao.impl.Battalarm_dataImpl; import com.fgkj.dao.impl.BattcurrdataImpl; import com.fgkj.dao.impl.Battcurrdata_infImpl; import com.fgkj.dao.impl.BatttestdataDAOImpl; @@ -156,6 +157,7 @@ case 67:return new Propulsion_motorImpl(); case 68:return new DcDistributionImpl(); case 69:return new AcDistributionImpl(); case 70:return new Battalarm_dataImpl(); default :return null; } } DyEnvir_system/src/com/fgkj/dao/impl/Battalarm_dataImpl.java
@@ -70,11 +70,40 @@ }); return list; } //根据电池组id查询电池实时告警信息 @Override public List serchByCondition(Object obj) { // TODO Auto-generated method stub return null; Battalarm_data balarm=(Battalarm_data) obj; String sql=" select distinct tb_battalarm_data.BattGroupId,tb_battalarm_data.MonNum,alm_id,alm_start_time " + " ,tb_battinf.BattGroupName " + " from db_alarm.tb_battalarm_data,db_battinf.tb_battinf " + " where tb_battalarm_data.BattGroupId=tb_battinf.BattGroupId " + " and tb_battalarm_data.BattGroupId=? " + " order by tb_battalarm_data.BattGroupId asc "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{balarm.getBattGroupId()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Battalarm_data b=new Battalarm_data(); b.setBattGroupId(rs.getInt("battGroupId")); b.setBattGroupName(rs.getString("battGroupName")); b.setMonNum(rs.getInt("monNum")); b.setAlm_id(rs.getInt("alm_id")); b.setAlm_start_time(rs.getTimestamp("alm_start_time")); b.setAlm_name(AlarmDaoFactory.getBinfalarm_name(b.getAlm_id())); list.add(b); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } @Override DyEnvir_system/src/com/fgkj/services/Battalarm_dataService.java
New file @@ -0,0 +1,35 @@ package com.fgkj.services; import java.util.List; import com.fgkj.dao.BaseDAO; import com.fgkj.dao.BaseDAOFactory; public class Battalarm_dataService { private BaseDAO dao; private ServiceModel model; public Battalarm_dataService() { super(); this.model=new ServiceModel(); this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATTALARM_DATA); } //根据电池组id查询电池实时告警信息 public ServiceModel serchByCondition(Object obj) { List list=dao.serchByCondition(obj); if(list!=null&&list.size()>0){ model.setData(list); model.setCode(1); model.setMsg("查询成功!"); }else{ model.setCode(0); model.setMsg("查询失败!"); } return model; } }