版权声明:免费免费 请勿收费 欢迎传播 https://blog.csdn.net/m0_37987402/article/details/86003433
package com.emms.comp.BDS;
import java.util.ArrayList;
import java.util.List;
import com.emms.comp.entity.bds.T_T_BDS_DATAMININGSHOWPOINT;
import com.emms.util.StringUtils;
import com.haiyisoft.common.exception.ServiceExceptionUtil;
import com.haiyisoft.persist.exception.DBException;
import com.haiyisoft.persist.jdbc.DBTool;
public class DATAMININGSHOWPOINTCom {
public List<T_T_BDS_DATAMININGSHOWPOINT> query(T_T_BDS_DATAMININGSHOWPOINT t) {
List<Object> params = new ArrayList<Object>();
DBTool tool = new DBTool();
List<T_T_BDS_DATAMININGSHOWPOINT> data = null;
try {
StringBuffer sql = new StringBuffer(
"SELECT * FROM T_BDS_DATAMININGSHOWPOINT WHERE 1 = 1");
if (StringUtils.isNotEmpty(t.getDataminingpointflowid())) {
sql.append(" AND DATAMININGPOINTFLOWID = ?");
params.add(t.getDataminingpointflowid());
}
if (StringUtils.isNotEmpty(t.getDataminingpointid())) {
sql.append(" AND DATAMININGPOINTID = ?");
params.add(t.getDataminingpointid());
}
if (StringUtils.isNotEmpty(t.getDataminingpointtype())) {
sql.append(" AND DATAMININGPOINTTYPE = ?");
params.add(t.getDataminingpointtype());
}
if (StringUtils.isNotEmpty(t.getDataminingpointname())) {
sql.append(" AND DATAMININGPOINTNAME = ?");
params.add(t.getDataminingpointname());
}
data = tool.executeQuery(sql.toString(), params,
T_T_BDS_DATAMININGSHOWPOINT.class);
} catch (Exception e) {
throw ServiceExceptionUtil.generateSOAServiceException(e, "查询菜单异常");
}
return data;
}
public void add(List<T_T_BDS_DATAMININGSHOWPOINT> insertList) {
DBTool dbtool = new DBTool();
StringBuffer sql = new StringBuffer(
"SELECT * FROM T_BDS_DATAMININGSHOWPOINT WHERE 1 = 1");
for (T_T_BDS_DATAMININGSHOWPOINT t : insertList) {
StringBuffer newsql = sql;
List<Object> params = new ArrayList<Object>();
if (StringUtils.isNotEmpty(t.getDataminingpointid())) {
newsql.append(" AND DATAMININGPOINTID = ?");
params.add(t.getDataminingpointid());
}
List<T_T_BDS_DATAMININGSHOWPOINT> data = dbtool.executeQuery(
newsql.toString(), params,
T_T_BDS_DATAMININGSHOWPOINT.class);
if (data == null || data.size() == 0) {
List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>();
insertList2.add(t);
try {
dbtool.batchInsertEntity(insertList2);
} catch (Exception e) {
throw ServiceExceptionUtil.generateSOAServiceException(e,
"插入数据异常");
}
} else {
List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>();
insertList2.add(t);
try {
dbtool.batchUpdateEntity(insertList2);
} catch (Exception e) {
throw ServiceExceptionUtil.generateSOAServiceException(e,
"更新数据异常");
}
}
}
}
public void save(List<T_T_BDS_DATAMININGSHOWPOINT> insertList) {
DBTool dbtool = new DBTool();
StringBuffer sql = new StringBuffer(
"SELECT * FROM T_BDS_DATAMININGSHOWPOINT WHERE 1 = 1");
for (T_T_BDS_DATAMININGSHOWPOINT t : insertList) {
StringBuffer newsql = sql;
List<Object> params = new ArrayList<Object>();
if (StringUtils.isNotEmpty(t.getDataminingpointflowid())) {
newsql.append(" AND DATAMININGPOINTFLOWID = ?");
params.add(t.getDataminingpointflowid());
}
List<T_T_BDS_DATAMININGSHOWPOINT> data = dbtool.executeQuery(
newsql.toString(), params,
T_T_BDS_DATAMININGSHOWPOINT.class);
if (data == null || data.size() == 0) {
List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>();
insertList2.add(t);
try {
dbtool.batchInsertEntity(insertList2);
} catch (Exception e) {
throw ServiceExceptionUtil.generateSOAServiceException(e,
"插入数据异常");
}
} else {
List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>();
insertList2.add(t);
try {
dbtool.batchUpdateEntity(insertList2);
} catch (Exception e) {
throw ServiceExceptionUtil.generateSOAServiceException(e,
"更新数据异常");
}
}
}
}
public void delete(List<T_T_BDS_DATAMININGSHOWPOINT> deleteList) {
DBTool tool = new DBTool();
try {
tool.batchDeleteEntity(deleteList);
} catch (DBException e) {
throw ServiceExceptionUtil.generateSOAServiceException("服务数据删除异常");
}
}
public void delete(List<T_DSJWJ_SFRW> deleteList) {
DBTool tool = new DBTool();
try {
// tool.batchDeleteEntity(deleteList);
for (int i = 0; i < deleteList.size(); i++) {
String slid = deleteList.get(i).getRwbh();
tool.executeUpdate("DELETE FROM DSJWJ_SFRW WHERE RWBH ='"
+ slid + "'", null);
}
} catch (DBException e) {
throw ServiceExceptionUtil.generateSOAServiceException("服务数据删除异常");
}
}
}