📄 changebusinessdaoimpl.java
字号:
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>setMoveMarker]exception:" + e.toString());
}
}
}
//设置企业原登记机关
public void setOldDepartment(String SN,String OLDSN) throws Exception{
String sql = null;
String field120 = null;
try{
sql = " select field120 from " + TableNameUtil.GSGSJOUT_BASIS01 + " where field001='" + SN + "'";
sqlExecProxy.openProxy();
sqlExecProxy.setAutoCommit(false);
sqlExecProxy.executeQuery(sql);
if(sqlExecProxy.nextRow()){
field120 = sqlExecProxy.getFieldString("field120");
}
sql = " update " + TableNameUtil.GSGSJIN_BASIS02 + " set field120='" + field120 + "' where field001='" + OLDSN + "'";
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->setOldDepartment]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>setOldDepartment]exception:" + e.toString());
}
}
}
/**
*@author xiedejin
*@date 20040313
*@param SN(String)
*@return ArrayList
*/
public ArrayList getChangeItemList(String BID,String SN) throws Exception{
ArrayList getChangeItemList = new ArrayList();
String sql = null;
try{
sql = " select distinct * from (select change_item.field004 from " + TableNameUtil.CHANGE_ITEM + " inner join " +
TableNameUtil.GSGSJOUT_CODING_PAGE_USING
+ " on change_item.showpage=gsgsjout_coding_page_using.pagenumber and change_item.field001='" + BID +
"' and gsgsjout_coding_page_using.sn='" + SN + "' order by change_item.showpage) a ";
sqlExecProxy.openProxy();
Debug.print(sql);
sqlExecProxy.executeQuery(sql);
while(sqlExecProxy.nextRow()){
getChangeItemList.add(sqlExecProxy.getFieldString("field004"));
}
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->getChangeItemList]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>getChangeItemList]exception:" + e.toString());
}
return getChangeItemList;
}
}
//得到变化字段列表
public ArrayList getChangeFieldName(String SN) throws Exception{
String sql = null;
ArrayList al = new ArrayList();
ChangeRecordModel model = null;
try{
sql = " select field007,field008,field009 from " + TableNameUtil.OUT_CHANGE + " where field001='" + SN + "'";
sqlExecProxy.openProxy();
sqlExecProxy.executeQuery(sql);
while(sqlExecProxy.nextRow()){
model= new ChangeRecordModel();
model.setChangeItem(sqlExecProxy.getFieldString("field007"));
model.setOldValue(sqlExecProxy.getFieldString("field008"));
model.setNewValue(sqlExecProxy.getFieldString("field009"));
al.add(model);
}
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->getChangeFieldName]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>getChangeFieldName]exception:" + e.toString());
}
return al;
}
}
//集团公司业务处理
public void groupBusinessDo(String SN,String OLDSN,String SUB) throws Exception{
String sql = null;
String OLDSUB = null;
try{
OLDSUB = "sub02" + SUB.substring(SUB.indexOf("sub01") + 5);
sqlExecProxy.openProxy();
sqlExecProxy.setAutoCommit(false);
//导basis01表记录
sql = " insert into " + TableNameUtil.GSGSJIN_BASIS02 +
" (field001,field002,field046,field047,field052) select field001,field002,field046,field047,field052 from " +
TableNameUtil.GSGSJOUT_BASIS01 + " where field001 = '" + SN + "'";
//sqlExecProxy.executeUpdate(sql);
//将集团公司的变更记录存入日志数据表
sql = " insert into " + TableNameUtil.IN_SUB_INSDEL + " select * from " + TableNameUtil.GSGSJIN_SUB02 + " where field001='" + OLDSN +
"' and field002='" + OLDSUB + "'";
Debug.println("[ChangeBusinessDAOImpl-->groupBusinessDo]sql=" + sql);
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
//删除sub02表中的记录
sql = " delete from " + TableNameUtil.GSGSJIN_SUB02 + " where field001='" + OLDSN + "' and field002='" + OLDSUB + "'";
Debug.println("[ChangeBusinessDAOImpl-->groupBusinessDo]sql=" + sql);
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
//将sub01表中的记录导入sub02表中(field008为变化后的值，field095为变化前的值)
sql = " insert into " + TableNameUtil.GSGSJIN_SUB02 +
" (field001,field002,field003,field103,field095) select field001,field002,field003,field103,field008 from " +
TableNameUtil.GSGSJOUT_SUB01 + " where field001='" + SN + "' and field002='" + SUB + "' and field008 is not null";
Debug.println("[ChangeBusinessDAOImpl-->groupBusinessDo]sql=" + sql);
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
sql = " insert into " + TableNameUtil.GSGSJIN_SUB02 +
" (field001,field002,field003,field103,field095) select field001,field002,field003,field103,field095 from " +
TableNameUtil.GSGSJOUT_SUB01 + " where field001='" + SN + "' and field002='" + SUB + "' and field008 is null";
Debug.println("[ChangeBusinessDAOImpl-->groupBusinessDo]sql=" + sql);
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
//更新数据
sql = " update " + TableNameUtil.GSGSJIN_SUB02 + " set field001='" + OLDSN + "',field002='" + OLDSUB + "' where field001='" + SN +
"' and field002='" + SUB + "'";
Debug.println("[ChangeBusinessDAOImpl-->groupBusinessDo]sql=" + sql);
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
//删除申请表信息
sql = "delete from " + TableNameUtil.GSGSJOUT_SUB01 + " where field001='" + SN + "' and field002='" + SUB + "'";
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->groupBusinessDo]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>groupBusinessDo]exception:" + e.toString());
}
}
}
//根据企业申请信息的SN，得到企业的开业BID
public String getEnterpriseOLDBID(String SN) throws Exception{
String sql = null;
String INNERID = "";
String OLDBID = "";
try{
//得到申请业务的内部序号
sql = " select field003 from " + TableNameUtil.GSGSJOUT_BASIS01 + " where field001='" + SN + "'";
sqlExecProxy.openProxy();
sqlExecProxy.executeQuery(sql);
if(sqlExecProxy.nextRow()){
INNERID = sqlExecProxy.getFieldString("field003");
//得到企业开业的BID
}
sql = " select field002 from " + TableNameUtil.GSGSJIN_BASIS02 + " where field003='" + INNERID + "'";
sqlExecProxy.executeQuery(sql);
if(sqlExecProxy.nextRow()){
OLDBID = sqlExecProxy.getFieldString("field002");
}
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->getEnterpriseOLDBID]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>getEnterpriseOLDBID]exception:" + e.toString());
}
return OLDBID;
}
}
//提交申请时，将basis01表中的field101置为注册号，field004置为企业名称
public void setSubmitBusinessInfo(String SN,String OLDSN,String fieldName,String oldFieldName) throws Exception{
String sql = null;
String oldValue = null;
try{
//得到开业的字段的值
sql = " select " + oldFieldName + " from " + TableNameUtil.GSGSJIN_BASIS02 + " where field001='" + OLDSN + "'";
sqlExecProxy.openProxy();
sqlExecProxy.setAutoCommit(false);
sqlExecProxy.executeQuery(sql);
if(sqlExecProxy.nextRow()){
oldValue = sqlExecProxy.getFieldString(oldFieldName);
//更新申请表(basis01)字段的信息
}
sql = " update " + TableNameUtil.GSGSJOUT_BASIS01 + " set " + fieldName + "='" + oldValue + "' where field001='" + SN + "'";
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->setSubmitBusinessInfo]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>setSubmitBusinessInfo]exception:" + e.toString());
}
}
}
//变更、改制为名称核准置状态位
public void setNameMarket(String SN) throws Exception{
String sql = null;
try{
sqlExecProxy.openProxy();
sqlExecProxy.setAutoCommit(false);
//取出名称保留期限
sql = "select valuee from gsgsj_dict_parameter where id='mcbgblq'";
Debug.println("[ChangeBusinessDAOImpl.setNameMarket]sql=" + sql);
sqlExecProxy.executeQuery(sql);
int saveDays = 0;
if(sqlExecProxy.nextRow()){
saveDays = Integer.parseInt(sqlExecProxy.getFieldString("VALUEE"));
}
//查询变化记录
sql = "select field004,field008 from in_change where field001='" + SN + "' and field007='field009'";
Debug.println("[ChangeBusinessDAOImpl.setNameMarket]sql=" + sql);
sqlExecProxy.executeQuery(sql);
if(sqlExecProxy.nextRow()){
String oldName = sqlExecProxy.getFieldString("FIELD008");
String tableName = sqlExecProxy.getFieldString("FIELD004");
if(tableName.indexOf("basis02") != -1){
String currentTime = ChangeUtil.getCurrentTime2();
String endTime = ChangeUtil.addDays(saveDays);
//更新名称核准标志位
sql = "update " + TableNameUtil.GSGSJIN_BASIS02 + " set field122='" + currentTime + "' ,field123='" + endTime +
"' where field002='0102' and field009='" + oldName + "'";
Debug.println("[ChangeBusinessDAOImpl.setNameMarket]sql=" + sql);
sqlExecProxy.executeUpdate(sql);
}
}
sqlExecProxy.commitProxy();
} catch(Exception e){
throw new Exception("[ChangeBusinessDAOImpl-->setNameMarket]exception:" + e.toString());
} finally{
try{
sqlExecProxy.closeProxy();
} catch(Exception e){
Debug.println("[ChangeBusinessDAOImpl-->>setNameMarket]exception:" + e.toString());
}
}
}
//更新核准日期
public void updateDoneDate(String SN) throws Exception{
String sql = "update " + TableNameUtil.GSGSJIN_BASIS02 + " set field099='" + ChangeUtil.getCurrentTime2() + "' where field001='" + SN + "'";
try{
sqlExecProxy.openProxy();
sqlExecProxy.setAutoCommit(false);
sqlExecProxy.executeUpdate(sql);
sqlExecProxy.commitProxy();
} catch(Exception e){
Debug.println⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -