修改包机组根据设备插入

lxw

2020-06-16 23cb58a347b8dcbbff612eddcf3112c388e78967

修改包机组根据设备插入

 zijing/src/com/fgkj/actions/User_battgroup_baojigroup_battgroupAction.java

@@ -65,6 +65,15 @@
        result=ActionUtil.tojson(model);

        return SUCCESS;

    }

    //包机组重做（穿梭框）查询所有的用户
    public String addPro_CS(){
        ServiceModel model=new ServiceModel();
        List<User_battgroup_baojigroup_battgroup> list=ActionUtil.getGson("yyyy-MM-dd").fromJson(result,new TypeToken<List<User_battgroup_baojigroup_battgroup>>(){}.getType());
        model=service.addPro_CS(list);					
        result=ActionUtil.tojson(model);
        return SUCCESS;
    }
	
    

    /**

     * 查询当前用户所属包机组中的所有的电池组


 zijing/src/com/fgkj/dao/impl/User_battgroup_baojigroup_battgroupImpl.java

@@ -72,6 +72,29 @@
        (new User_logService()).addPro(listU);//将用户的操作记录下来

        return bl;

    }

	
    //包机组重做（穿梭框）查询所有的用户
    public boolean addPro_CS(Object obj){
        List<User_battgroup_baojigroup_battgroup> list=(List) obj;
        ArrayList sql_strs=new ArrayList();
        List<User_log> listU=new ArrayList<User_log>();//存放user_log
        if(list!=null&&list.size()>0){
            for (User_battgroup_baojigroup_battgroup ugroup : list) {
                String sql="REPLACE into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) "
                        + " SELECT "+ugroup.getBaoji_group_id()+",StationId,BattGroupId from db_battinf.tb_battinf where FBSDeviceId="+ugroup.getDev_id() ;
                sql_strs.add(sql);
                {
                    String msg="添加"+ugroup.getNote()+"至"+ugroup.getBaoji_group_name()+"包机组中";
                    User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
                    listU.add(ulog);
                 }
            }
        }
        boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs);
        (new User_logService()).addPro(listU);//将用户的操作记录下来
        return bl;
    }

    public boolean update(Object obj) {

        User_battgroup_baojigroup_battgroup ugroup=(User_battgroup_baojigroup_battgroup) obj;

        String sql="update db_user.tb_user_battgroup_baojigroup_battgroup set baoji_group_id=?,StationId=?,BattGroupId=? where num=?";


 zijing/src/com/fgkj/dto/User_battgroup_baojigroup_battgroup.java

@@ -7,6 +7,7 @@
    private String baoji_group_name;

    private Integer StationId;

    private Integer BattGroupId;

    private Integer dev_id;
    private String note;

    

    

@@ -51,12 +52,19 @@
        this.note = note;

    }

    

    public Integer getDev_id() {
        return dev_id;
    }
    public void setDev_id(Integer dev_id) {
        this.dev_id = dev_id;
    }
    @Override

    public String toString() {

        return "User_battgroup_baojigroup_battgroup [num=" + num

                + ", baoji_group_id=" + baoji_group_id + ", baoji_group_name="

                + baoji_group_name + ", StationId=" + StationId

                + ", BattGroupId=" + BattGroupId + ", note=" + note + "]";

                + ", BattGroupId=" + BattGroupId + ", dev_id=" + dev_id
                + ", note=" + note + "]";
    }    

    

}


 zijing/src/com/fgkj/services/User_battgroup_baojigroup_battgroupService.java

@@ -55,6 +55,18 @@
        }

        return model;

    }

    //包机组重做（穿梭框）查询所有的用户
    public ServiceModel addPro_CS(Object obj) {
        Boolean bl=((User_battgroup_baojigroup_battgroupImpl)dao).addPro_CS(obj);
        if(bl){
            model.setCode(1);
            model.setMsg("添加成功!");
        }
        else{
            model.setMsg("添加失败!");
        }
        return model;
    }
    public ServiceModel update(Object obj) {

        Boolean bl=dao.update(obj);

        if(bl){