package com.emms.comp.BDS;

import java.util.ArrayList;
import java.util.List;

import com.emms.comp.entity.bds.T_T_BDS_DATAMININGFLOW;
import com.emms.util.StringUtils;
import com.haiyisoft.common.exception.ServiceExceptionUtil;
import com.haiyisoft.persist.jdbc.DBTool;

public class SOUDATAMININGFLOWCom {
	
	public List<Object> query(T_T_BDS_RESOURCELIB t) {
		DBTool dbtool = new DBTool();
		List<Object> data = null;
		String sql = " SELECT B.CTZ FROM JLZS_JLXX A,JLZS_CXX B WHERE A.JLBH = B.JLBH and A.RWBH = '"
				+ t.getDbuser() + "'order by sl asc, mc asc";
		data = dbtool.queryLOBObject(sql, null);
		return data;
	}

	public void saveOrUpdate(T_T_BDS_DATAMININGFLOW t, String content) {
		List<Object> params = new ArrayList<Object>();
		List<T_T_BDS_DATAMININGFLOW> data = null;
		DBTool tool = new DBTool();
		try {
			StringBuffer sql = new StringBuffer(
					"SELECT * FROM T_BDS_DATAMININGFLOW_HISTORY WHERE 1 = 1 ");
			if (StringUtils.isNotEmpty(t.getDataminingflowid())) {
				sql.append(" AND DATAMININGFLOWID = ?");
				params.add(t.getDataminingflowid());
			}
			data = tool.executeQuery(sql.toString(), params,
					T_T_BDS_DATAMININGFLOW.class);
			if (data.size() > 0) {
				update(t, content);
			} else {
				save(t, content);
			}
		} catch (Exception e) {
			throw ServiceExceptionUtil.generateSOAServiceException(e, "查询菜单异常");
		}
	}

	private void save(T_T_BDS_DATAMININGFLOW t, String content) {
		// TODO Auto-generated method stub
		DBTool tool = new DBTool();
		List<Object> queryParams = new ArrayList<Object>();
		List<T_T_BDS_DATAMININGFLOW> list = new ArrayList<T_T_BDS_DATAMININGFLOW>();
		list.add(t);
		queryParams.add(t.getDataminingflowid());
		List<Object> updateParams = new ArrayList<Object>();
		updateParams.add(content);
		try {
			tool.batchInsertEntity(list);
			tool.executeUpdate(
					"UPDATE T_BDS_DATAMININGFLOW SET DATAMININGFLOWCONTENT = EMPTY_CLOB() WHERE DATAMININGFLOWID = ? ",
					queryParams);
			tool.updateLOB(
					"SELECT DATAMININGFLOWCONTENT FROM T_BDS_DATAMININGFLOW WHERE DATAMININGFLOWID = ? ",
					queryParams, updateParams);
		} catch (Exception e) {
			throw ServiceExceptionUtil.generateSOAServiceException(e, "查询菜单异常");
		}
	}

	private void update(T_T_BDS_DATAMININGFLOW t, String content) {
		// TODO Auto-generated method stub
		DBTool tool = new DBTool();
		List<Object> queryParams = new ArrayList<Object>();
		List<T_T_BDS_DATAMININGFLOW> list = new ArrayList<T_T_BDS_DATAMININGFLOW>();
		list.add(t);
		queryParams.add(t.getDataminingflowid());
		List<Object> updateParams = new ArrayList<Object>();
		updateParams.add(content);
		try {
			tool.batchUpdateEntity(list);
			tool.executeUpdate(
					"UPDATE T_BDS_DATAMININGFLOW SET DATAMININGFLOWCONTENT = EMPTY_CLOB() WHERE DATAMININGFLOWID = ? ",
					queryParams);
			tool.updateLOB(
					"SELECT DATAMININGFLOWCONTENT FROM T_BDS_DATAMININGFLOW WHERE DATAMININGFLOWID = ? ",
					queryParams, updateParams);
		} catch (Exception e) {
			throw ServiceExceptionUtil.generateSOAServiceException(e, "查询菜单异常");
		}
	}

}