nseermoduletreedb.java

ERO系统.针对生产型、分销型、服务型企业等不同的行业特点

package include.nseerTree;
import java.text.SimpleDateFormat;
import java.util.Iterator;
import java.util.List;
import java.sql.*;

import javax.servlet.http.*;
import javax.servlet.jsp.*;
import javax.servlet.*;
import java.io.*;
import java.util.*;
import java.text.*;
import include.nseer_cookie.*;
import uk.ltd.getahead.dwr.WebContext;
import uk.ltd.getahead.dwr.WebContextFactory;
import include.nseer_cookie.copyFile;
import include.nseer_db.*;
import include.tree_index.Nseer;
import include.get_sql.getInsertSql;

public class NseerModuleTreeDB{
WebContext ctx = WebContextFactory.get();
HttpServletRequest request = ctx.getHttpServletRequest();//用DWR的对象创建request.
HttpSession session = ctx.getSession();//用DWR的对象创建session.
ServletContext application = session.getServletContext();//用session的对象创建application.
ServletContext context=session.getServletContext();//用session的对象创建context.
nseer_db db=new nseer_db((String)session.getAttribute("unit_db_name"));
Nseer n=new Nseer();
private String path=application.getRealPath("/");//得路径.

	public List getNodeInf(String pid,String tableName,String[] required_array,String[] field_array){//根据传入的节点id，表名，列名，以list形式返回所有子节点信息
		List nameList = (List)new java.util.ArrayList();
		String column_group="";
		for(int i=0;i<field_array.length;i++){
			column_group+=","+field_array[i];
		}
		String sql="select "+required_array[0]+","+required_array[3]+","+required_array[2]+column_group+" from "+tableName+" where "+required_array[1]+"='"+pid+"' order by id";
		try{		
		ResultSet rs =db.executeQuery(sql);
		String value_group="";
		while(rs.next()){
			for(int i=0;i<field_array.length;i++){
				value_group+="◎"+rs.getString(field_array[i]);
			}
			nameList.add(rs.getString(required_array[0])+"◎"+rs.getString(required_array[2])+"◎"+rs.getString(required_array[3])+"☆"+value_group.substring(1));
		}
		db.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		return nameList;
	}
	public List getNodeInfBySearch(String key_word,String tableName,String[] required_array,String[] field_array){//根据传入的节点id，表名，列名，以list形式返回所有子节点信息
		List nameList = (List)new java.util.ArrayList();
		String column_group="";
		for(int i=0;i<field_array.length;i++){
			column_group+=","+field_array[i];
		}
		String sql="select "+required_array[0]+","+required_array[3]+","+required_array[2]+column_group+" from "+tableName+" order by id";
		try{
		ResultSet rs =db.executeQuery(sql);
		String value_group="";
		while(rs.next()){
			if(rs.getString(required_array[2]).indexOf(key_word)!=-1){
			for(int i=0;i<field_array.length;i++){
				value_group+="◎"+rs.getString(field_array[i]);
			}
			nameList.add(rs.getString(required_array[0])+"◎"+rs.getString(required_array[2])+"◎"+rs.getString(required_array[3])+"☆"+value_group.substring(1));
			}
		}
		db.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		return nameList;
	}
	public String getNodeName(String tableName,String category_id){
		String sql = "select max("+category_id+") from "+tableName;
		String nodeName="";
		try{		
			ResultSet rs =db.executeQuery(sql);
			if(rs.next()){
				nodeName=(rs.getInt("max("+category_id+")")+1)+"";
			}
			db.close();
			}catch(Exception ex){
				ex.printStackTrace();
			}
		return nodeName;

	}
	
public String insertNodeInf(String tableName,String category_id,String parent_id,String category_name,String[] data_array,String[] field_array,String[] chief_array,String reason,String hreflink,String picture) throws SQLException{//插入方法
String main_kind_name=tableName.substring(0,tableName.length()-5);
String onlyfile="";
		String data_group="";
		String field_group="";
		String finished_tag="";
		for(int i=0;i<chief_array.length-3;i++){
			field_group+=chief_array[i]+",";
		}
		data_group+="'"+category_id+"','"+parent_id+"','"+category_name+"',";
		for(int i=0;i<data_array.length;i++){
			if(i==0){data_group+="'"+data_array[i]+"',";}
			else{data_group+="'"+data_array[i]+"',";}
			field_group+=field_array[i]+",";
		}
/******为操作erp_update_d表做准备**********/
java.util.Date now = new java.util.Date();
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String time=formatter.format(now);
Double c_ver=0.00;
String sql_update="select ver from erp_update_t order by ver desc";
ResultSet rs_update=db.executeQuery(sql_update);
if(rs_update.next()){c_ver=rs_update.getDouble("ver");}
int update_tag=0;
String file_path="";
/****************/
String filePath="";
String sql="";
String chain_name="";
String sql13="select * from "+tableName+" where "+chief_array[0]+"='"+parent_id+"'";
ResultSet rs3=db.executeQuery(sql13);//查询父节点。
if(rs3.next()){
 chain_name=rs3.getString("chain_name")+"--"+category_name.substring(category_name.indexOf(" ")+1);
if(rs3.getString("file_path").equals("")){

filePath=main_kind_name+"/"+reason;//得路径
onlyfile=main_kind_name;//得单个文件的路径

sql = "insert into "+tableName+"("+field_group.substring(0,field_group.length()-1)+",file_path,chain_name,picture)values("+data_group.substring(0,data_group.length()-1)+",'"+main_kind_name+"/"+reason+"','"+chain_name+"','"+picture+"')";//执行sql语句
update_tag=1;
}else{
filePath=rs3.getString("file_path")+"/"+reason;
onlyfile=rs3.getString("file_path");
sql = "insert into "+tableName+"("+field_group.substring(0,field_group.length()-1)+",file_path,chain_name,picture)values("+data_group.substring(0,data_group.length()-1)+",'"+rs3.getString("file_path")+"/"+reason+"','"+chain_name+"','"+picture+"')";
file_path=rs3.getString("file_path");
update_tag=2;
}
}else{
filePath=main_kind_name+"/"+reason;
onlyfile=main_kind_name;
chain_name=category_name.substring(category_name.indexOf(" ")+1);
sql = "insert into "+tableName+"("+field_group.substring(0,field_group.length()-1)+",file_path,chain_name,picture)values("+data_group.substring(0,data_group.length()-1)+",'"+main_kind_name+"/"+reason+"','"+chain_name+"','"+picture+"')";
update_tag=3;
}
try{
finished_tag="200";
db.executeUpdate(sql);
/*****在erp_update_d表中插入一条记录********/
String[] fields=field_group.substring(0,field_group.length()-1).split(",");
String[] fields_value=data_group.substring(0,data_group.length()-1).split(",");
String fields_temp="";
for(int a=0;a<fields.length;a++){
	fields_temp+=" and "+fields[a]+"="+fields_value[a];
}
fields_temp=fields_temp.substring(4);
switch(update_tag){
	case 1:
	{		
		sql_update="select id from "+tableName+" where "+fields_temp+" and file_path='"+main_kind_name+"/"+reason+"' and chain_name='"+chain_name+"' and picture='"+picture+"' order by id desc";
		rs_update=db.executeQuery(sql_update);
		if(rs_update.next()){
		sql_update = "insert into erp_update_d(t_name,cols_name,cols_value,ver,register_time,row_id) values('"+tableName+"','㊣"+field_group.substring(0,field_group.length()-1).replaceAll(",", "㊣")+"㊣file_path㊣chain_name㊣picture','㊣"+data_group.substring(0,data_group.length()-1).replaceAll("'", "").replaceAll(",", "㊣")+"㊣"+main_kind_name+"/"+reason+"㊣"+chain_name+"㊣"+picture+"','"+c_ver+"','"+time+"','"+rs_update.getString("id")+"')";
		db.executeUpdate(sql_update);
		}
		break;
	}
	case 2:
	{
		sql_update="select id from "+tableName+" where "+fields_temp+" and file_path='"+file_path+"/"+reason+"' and chain_name='"+chain_name+"' and picture='"+picture+"' order by id desc";
		rs_update=db.executeQuery(sql_update);
		if(rs_update.next()){
		sql_update = "insert into erp_update_d(t_name,cols_name,cols_value,ver,register_time,row_id) values('"+tableName+"','㊣"+field_group.substring(0,field_group.length()-1).replaceAll(",", "㊣")+"㊣file_path㊣chain_name㊣picture','㊣"+data_group.substring(0,data_group.length()-1).replaceAll("'", "").replaceAll(",", "㊣")+"㊣"+file_path+"/"+reason+"㊣"+chain_name+"㊣"+picture+"','"+c_ver+"','"+time+"','"+rs_update.getString("id")+"')";
		db.executeUpdate(sql_update);
		}
		break;
	}
	case 3:
	{
		sql_update="select id from "+tableName+" where "+fields_temp+" and file_path='"+file_path+"/"+reason+"' and chain_name='"+chain_name+"' and picture='"+picture+"' order by id desc";
		rs_update=db.executeQuery(sql_update);
		if(rs_update.next()){
		sql_update = "insert into erp_update_d(t_name,cols_name,cols_value,ver,register_time,row_id) values('"+tableName+"','㊣"+field_group.substring(0,field_group.length()-1).replaceAll(",", "㊣")+"㊣file_path㊣chain_name㊣picture','㊣"+data_group.substring(0,data_group.length()-1).replaceAll("'", "").replaceAll(",", "㊣")+"㊣"+main_kind_name+"/"+reason+"㊣"+chain_name+"㊣"+picture+"','"+c_ver+"','"+time+"','"+rs_update.getString("id")+"')";
		db.executeUpdate(sql_update);
		}
		break;
	}
}
/*****************************************/
}catch(Exception ex){
ex.printStackTrace();	
}
			
String sql1="select "+chief_array[3]+" from "+tableName+" where "+chief_array[0]+"='"+parent_id+"'";
try{
ResultSet rs=db.executeQuery(sql1);//查询节点
if(rs.next()){
if(rs.getString(chief_array[3]).equals("0")){
String sql2="update "+tableName+" set "+chief_array[3]+"='1' where "+chief_array[0]+"='"+parent_id+"'";//更改标志位
db.executeUpdate(sql2);
/*****更新erp_update_d表条记录********/
sql_update="select id from "+tableName+" where "+chief_array[0]+"='"+parent_id+"' and "+chief_array[3]+"='1' order by id desc";
rs_update=db.executeQuery(sql_update);
if(rs_update.next()){
	String row_id=rs_update.getString("id");
	sql_update="select * from erp_update_d where t_name='"+tableName+"' and row_id='"+row_id+"'";
	rs_update=db.executeQuery(sql_update);
	if(rs_update.next()){
		String[] cols_name=rs_update.getString("cols_name").split("㊣");
		String[] cols_value=rs_update.getString("cols_value").split("㊣");
		String cols_temp="";
		int a=0;
		for(int i=0;i<cols_value.length;i++){
			if(cols_name[i].equals(chief_array[3])){
				cols_value[i]="1";
				a++;
			}
			cols_temp+="㊣"+cols_value[i];
		}
		if(a>0){
		sql_update="update erp_update_d set cols_value='"+cols_temp.substring(1)+"' where t_name='"+tableName+"' and row_id='"+row_id+"'";
		}else{
			sql_update="update erp_update_d set cols_name='"+rs_update.getString("cols_name")+"㊣"+chief_array[3]+"',cols_value='"+cols_temp.substring(1)+"㊣1' where t_name='"+tableName+"' and row_id='"+row_id+"'";			
		}
		db.executeUpdate(sql_update);
	}
}
/*****************************************/
}
}
db.close();
}catch(Exception ex){ex.printStackTrace();}						
if(reason.equals("")){
copyFile cp = new copyFile(path+"extend_src/nseer_extend2.jsp",path+onlyfile+"/"+hreflink);//执行文件拷贝
cp.setMakeDirs(false);
cp.copy();
String head_path="";
for(int i=0;i<onlyfile.split("/").length-1;i++){

head_path+="../";//遍历路径

}
CreateFile newfile=new CreateFile();
newfile.toFile(path+onlyfile+"/"+hreflink,"<%@include file=\"../include/head.jsp\"%>","<%@include file=\""+head_path+"include/head.jsp\"%>");
}else{
java.io.File file=new java.io.File(path+filePath);
java.io.File file1=new java.io.File(path+"WEB-INF/src/"+main_kind_name+"/"+reason);
java.io.File fileb=new java.io.File(path+main_kind_name+"/help/"+reason);
finished_tag=main_kind_name+"/"+reason;
if(file.exists()){
finished_tag="该模块已完成初始，请返回确认！";