电池组参考线

whycxzp

2022-06-13 3439547162311fc4e96defa3730865c30b1af20e

电池组参考线

 src/com/fgkj/actions/BattGroupGuidesAction.java

New file
@@ -0,0 +1,37 @@
package com.fgkj.actions;

import com.fgkj.dto.BattGroupGuides;
import com.fgkj.dto.ServiceModel;
import com.fgkj.services.BattGroupGuidesService;
import org.apache.struts2.json.annotations.JSON;

public class BattGroupGuidesAction extends ActionUtil {

    private BattGroupGuidesService service = new BattGroupGuidesService();

    private String json;
    private String result;

    @JSON(serialize = false)
    public String getAll(){
        int battGroupId = getGson().fromJson(json, BattGroupGuides.class).getBattGroupId();
        ServiceModel model = service.getAll(battGroupId);
        result = getGson().toJson(model);
        return SUCCESS;
    }

    public String update(){
        BattGroupGuides guides = getGson().fromJson(json, BattGroupGuides.class);
        ServiceModel model = service.update(guides);
        result = getGson().toJson(model);
        return SUCCESS;
    }

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

    public String getResult() {
        return result;
    }
}

 src/com/fgkj/dao/impl/BattGroupGuidesDao.java

New file
@@ -0,0 +1,98 @@
package com.fgkj.dao.impl;

import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.BattGroupGuides;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;

public class BattGroupGuidesDao {

    public BattGroupGuides getAll(int battGroupId) {
        String sql = "select * from db_battinf.tb_battinf_guides where batt_group_id = ? limit 1";
        List<BattGroupGuides> guidesList = DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{battGroupId}, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BattGroupGuides> list = new LinkedList<>();
                if(rs.next()){
                    BattGroupGuides guides = new BattGroupGuides();
                    guides.setId(rs.getInt("id"));
                    guides.setBattGroupId(rs.getInt("batt_group_id"));
                    guides.setCurr(rs.getFloat("curr"));
                    guides.setLeakVol(rs.getFloat("leak_vol"));
                    guides.setMonConduct(rs.getFloat("mon_conduct"));
                    guides.setMonConnRes(rs.getFloat("mon_conn_res"));
                    guides.setMonRes(rs.getFloat("mon_res"));
                    guides.setMonTemp(rs.getFloat("mon_temp"));
                    guides.setMonVol(rs.getFloat("mon_vol"));

                    list.add(guides);
                }
                return list;
            }
        });
        if(guidesList.size()==0){
           return null;
        }
        return guidesList.get(0);
    }

    public void insert(BattGroupGuides guides) {
        String sql = "insert into db_battinf.tb_battinf_guides(batt_group_id,mon_vol,mon_temp,mon_res,leak_vol,curr,mon_conn_res,mon_conduct) values (?,?,?,?,?,?,?,?)";
        DAOHelper.executeUpdate(DBUtil.getConn(),sql,new Object[]{
                guides.getBattGroupId(),
                guides.getMonVol(),
                guides.getMonTemp(),
                guides.getMonRes(),
                guides.getLeakVol(),
                guides.getCurr(),
                guides.getMonConnRes(),
                guides.getMonConduct()
        });
    }

    public void updateById(BattGroupGuides guides) {
        List<Object> params = new LinkedList<>();
        String sql = "update db_battinf.tb_battinf_guides ";
        {
            String sqlSet = null;
            if(guides.getMonVol()!=null){
                sqlSet = " set mon_vol = ?";
                params.add(guides.getMonVol());
            }
            if(guides.getMonTemp()!=null){
                sqlSet = " set mon_temp = ?";
                params.add(guides.getMonTemp());
            }
            if(guides.getMonRes()!=null){
                sqlSet = " set mon_res = ?";
                params.add(guides.getMonRes());
            }
            if(guides.getLeakVol()!=null){
                sqlSet = " set leak_vol = ?";
                params.add(guides.getLeakVol());
            }
            if(guides.getCurr()!=null){
                sqlSet = " set curr = ?";
                params.add(guides.getCurr());
            }
            if(guides.getMonConnRes()!=null){
                sqlSet = " set mon_conn_res = ?";
                params.add(guides.getMonConnRes());
            }
            if(guides.getMonConduct()!=null){
                sqlSet = " set mon_conduct = ?";
                params.add(guides.getMonConduct());
            }
            sql+=sqlSet;
            sql+=" where id = ?";
            params.add(guides.getId());
        }
        DAOHelper.executeUpdate(DBUtil.getConn(),sql,params.toArray());
    }
}

 src/com/fgkj/dto/BattGroupGuides.java

New file
@@ -0,0 +1,97 @@
package com.fgkj.dto;

/**
 * 电池组属性参考线
 */
public class BattGroupGuides {

    private Integer id;

    private Integer battGroupId;

    private Float monVol;

    private Float monTemp;

    private Float monRes;

    private Float leakVol;

    private Float curr;

    private Float monConnRes;

    private Float monConduct;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public Integer getBattGroupId() {
        return battGroupId;
    }

    public void setBattGroupId(Integer battGroupId) {
        this.battGroupId = battGroupId;
    }

    public Float getMonVol() {
        return monVol;
    }

    public void setMonVol(Float monVol) {
        this.monVol = monVol;
    }

    public Float getMonTemp() {
        return monTemp;
    }

    public void setMonTemp(Float monTemp) {
        this.monTemp = monTemp;
    }

    public Float getMonRes() {
        return monRes;
    }

    public void setMonRes(Float monRes) {
        this.monRes = monRes;
    }

    public Float getLeakVol() {
        return leakVol;
    }

    public void setLeakVol(Float leakVol) {
        this.leakVol = leakVol;
    }

    public Float getCurr() {
        return curr;
    }

    public void setCurr(Float curr) {
        this.curr = curr;
    }

    public Float getMonConnRes() {
        return monConnRes;
    }

    public void setMonConnRes(Float monConnRes) {
        this.monConnRes = monConnRes;
    }

    public Float getMonConduct() {
        return monConduct;
    }

    public void setMonConduct(Float monConduct) {
        this.monConduct = monConduct;
    }
}

 src/com/fgkj/services/BattGroupGuidesService.java

New file
@@ -0,0 +1,44 @@
package com.fgkj.services;

import com.fgkj.dao.impl.BattGroupGuidesDao;
import com.fgkj.dto.BattGroupGuides;
import com.fgkj.dto.ServiceModel;

public class BattGroupGuidesService {

    private BattGroupGuidesDao dao = new BattGroupGuidesDao();

    public ServiceModel getAll(int battGroupId) {
        ServiceModel model = new ServiceModel();
        BattGroupGuides guides = dao.getAll(battGroupId);
        //不存在,赋予默认值
        if(guides == null){
            BattGroupGuides guidesDefault = new BattGroupGuides();
            guidesDefault.setCurr(1.0f);
            guidesDefault.setLeakVol(1.0f);
            guidesDefault.setMonConduct(1.0f);
            guidesDefault.setMonConnRes(1.0f);
            guidesDefault.setMonTemp(1.0f);
            guidesDefault.setMonVol(1.0f);
            guidesDefault.setMonRes(1.0f);
            guides = guidesDefault;
        }
        return model.set(1,guides);
    }

    public ServiceModel update(BattGroupGuides guides) {
        ServiceModel model = new ServiceModel();
        //数据库不存在电池组参考线
        try {
            if (guides.getId() == null) {
                dao.insert(guides);
            } else {
                dao.updateById(guides);
            }
            model.set(1, true);
        }catch (Exception e){
            model.setMsg("接口调用异常,异常信息:"+e.toString());
        }
        return model;
    }
}