前100笔

whyclxw

2021-05-20 4f814efff3e0a33c311cac6a36117e28224e14ed

前100笔

 DyEnvir_system/src/com/fgkj/dao/BaseDAO.java

@@ -127,6 +127,7 @@
    public static final int  BATTALARM_DATA=70;
    public static final int  DCINSULATION=71;
    public static final int  ACINSULATION=72;
    public static final int  PARTIN_ELEMONITOR=73;
    
        
    public boolean add(Object obj); // 添加

 DyEnvir_system/src/com/fgkj/dao/BaseDAOFactory.java

@@ -77,6 +77,7 @@
import com.fgkj.watersystem.Impl.Water_stateImpl;
import com.fgkj.watersystem.dto.Water_inf;
import com.fgkj.watersystem.dto.Water_rt;
import com.partinsystem.udpall.impl.Partin_elemonitorImpl;


public class BaseDAOFactory {    
@@ -162,6 +163,8 @@
        case 70:return new Battalarm_dataImpl();
        case 71:return new DcinsulationImpl();
        case 72:return new AcinsulationImpl();
        //UDP发包
        case 73:return new Partin_elemonitorImpl();
        default :return null;
        }
    }

 DyEnvir_system/src/com/partinsystem/udpall/action/Partin_elemonitorAction.java

New file
@@ -0,0 +1,34 @@
package com.partinsystem.udpall.action;

import java.util.Date;

import com.fgkj.actions.ActionUtil;
import com.fgkj.services.ServiceModel;
import com.partinsystem.udpall.service.Partin_elemonitorService;

public class Partin_elemonitorAction extends ActionUtil{
    private Partin_elemonitorService service=new Partin_elemonitorService();
    private String json;
    private String result;
	
	
    //实时界面查询前一百笔历史数据
    public String serchByCondition() {
        ServiceModel model=service.serchByCondition(new Date());
        result=tojson(model);
        return SUCCESS;
    }


    public String getResult() {
        return result;
    }


    public void setJson(String json) {
        this.json = json;
    }
    
    

}

 DyEnvir_system/src/com/partinsystem/udpall/impl/Partin_elemonitorImpl.java

@@ -3,6 +3,7 @@
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import javax.swing.plaf.synth.SynthScrollPaneUI;
@@ -231,11 +232,15 @@
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[] {}, new Partin_elemonitorImpl());
        return list;
    }

	
    //实时界面查询前一百笔历史数据
    @Override
    public List serchByCondition(Object obj) {
        // TODO Auto-generated method stub
        return null;
        Date date=(Date) obj;
        String dateString=DAOHelper.sdf_withOut.format(date);
        String sql=" select distinct * from db_partinsystem_history.tb_partin_elemonitor_"+dateString+" order by record_time asc limit 0,100";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[] {}, new Partin_elemonitorImpl());
        return list;
    }

    @Override
@@ -245,7 +250,12 @@
    }
    public static void main(String[] args) {
        Partin_elemonitorImpl pimpl=new Partin_elemonitorImpl();
        List<Partin_elemonitor> list=pimpl.searchAll();
        /*List<Partin_elemonitor> list=pimpl.searchAll();
        for (Partin_elemonitor p : list) {
            System.out.println(p);
        }*/
        Date date=new Date();
        List<Partin_elemonitor> list=pimpl.serchByCondition(date);
        for (Partin_elemonitor p : list) {
            System.out.println(p);
        }

 DyEnvir_system/src/com/partinsystem/udpall/service/Partin_elemonitorService.java

New file
@@ -0,0 +1,33 @@
package com.partinsystem.udpall.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Partin_elemonitorService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Partin_elemonitorService() {
        super();
        dao=BaseDAOFactory.getBaseDAO(BaseDAO.PARTIN_ELEMONITOR);
        model=new ServiceModel();
    }
    //实时界面查询前一百笔历史数据
    public ServiceModel serchByCondition(Object obj) {
        List list=dao.serchByCondition(obj);
        if(list!=null&&list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功");
        }else{
            model.setCode(0);
            model.setMsg("查询失败");
        }
        return model;
    }


}

 DyEnvir_system/src/struts.xml

@@ -13,6 +13,10 @@
    <constant name="struts.action.excludePattern" value="/ws/.*,ws://.*"></constant>
    
    <package name="default" namespace="/" extends="json-default" >
        <action name="*_udp_*" class="com.partinsystem.udpall.action.{1}" method="{2}">
            <result type="json"></result>
        </action> 
        
        <action name="*_prt_*" class="com.fgkj.actions.partinsystem.{1}" method="{2}">
            <result type="json"></result>
        </action>