BM.rar_单据_单据管理系统_收费

package com.anyi.ps.db; import java.sql.Connection; import java.sql.Date; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.HashMap; import java.util.Map; import javax.naming.InitialContext; import javax.naming.NamingException; import javax.sql.DataSource; import com.anyi.erp.pub.BusinessException; import com.anyi.gp.pub.DataTools; import com.anyi.ps.bean.PsD; import com.anyi.ps.bean.PsM; import com.anyi.ps.bean.Pzflmx; import com.anyi.ps.bean.Pzml; import com.anyi.ps.bean.Pznr; import com.anyi.ps.bean.VoucherDetail; import com.anyi.ps.util.AssistMethod; import com.anyi.pubInterface.IVoucherItem; public class PSDBHelper { /** *获取连接池连接 * @param s * @return * @throws BusinessException */ public static Connection getConnection() throws BusinessException{ // Hashtable hashtable = new Hashtable(); // hashtable.put("java.naming.factory.initial", "weblogic.jndi.WLInitialContextFactory"); // hashtable.put("java.naming.provider.url", "t3://127.0.0.1:7011"); InitialContext initialcontext = null; DataSource datasource = null; Connection connection1; try { initialcontext = new InitialContext(); datasource = (DataSource)initialcontext.lookup("webglDS"); Connection connection = datasource.getConnection(); connection1 = connection; }catch(NamingException namingexception){ throw new BusinessException(namingexception.getMessage()); }catch(SQLException sqlexception){ sqlexception.printStackTrace(); throw new BusinessException(sqlexception.getMessage()); }catch(Exception e){ throw new BusinessException(e.getMessage()); }finally{ if(initialcontext != null)try{initialcontext.close();}catch(Exception e){} } return connection1; } /** * 资源回收器 * @param o */ public static void closeResource(Connection conn) { if(conn != null) try{conn.close();}catch(Exception e){} } public static void closeResource(PreparedStatement pstm) { if(pstm != null) try{pstm.close();}catch(Exception e){} } public static void closeResource(ResultSet rs){ if(rs != null) try{rs.close();}catch(Exception e){} } /** * 根据录入批次获取一个Pzml对象 * @param conn * @param inputGroupId * @param kjqj * @param srId * @param sr * @param kjzg * @return * @throws BusinessException */ public static Pzml getPzmlByID(Connection conn, String assRelationId, String accountId, String psVoucherHeadId, String srId, String sr, String kjzg ) throws BusinessException { Pzml pzml = null; String sqlMain = "select * from PS_VOUCHER_HEAD where PS_VOUCHER_HEAD_ID = '"+psVoucherHeadId+"'"; String sqlChild = "select * from PS_VOUCHER_DETAIL where PS_VOUCHER_HEAD_ID = '"+psVoucherHeadId+"'"; PreparedStatement pstmMain = null; PreparedStatement pstmChild = null; ResultSet rsMain = null; ResultSet rsChild = null; // String coCode = null; try{ pstmMain = conn.prepareStatement(sqlMain); pstmChild = conn.prepareStatement(sqlChild); rsMain = pstmMain.executeQuery(); while(rsMain.next()){ pzml = new Pzml(); // coCode = rsMain.getString("CO_CODE"); Date kjqjMain = rsMain.getDate("PROC_DATE"); pzml.setKjqj(AssistMethod.getProcDateString(kjqjMain,"yyyyMM")); pzml.setPzrq(AssistMethod.getSysDataString("")); pzml.setFjzs("0"); pzml.setSrID(srId); pzml.setSr(sr); pzml.setShID("-1"); pzml.setJzrID("-1"); pzml.setSrrq(AssistMethod.getSysDataString("")); pzml.setPzhzkmdy("0"); pzml.setPzhzbz("0"); pzml.setZt("1"); pzml.setKjzg(kjzg); pzml.setPzzy(AssistMethod.NVL(rsMain.getString("REMARK"))); pzml.setPzje(AssistMethod.NVZ(String.valueOf(rsMain.getDouble("TOTAL_MONEY")))); } rsChild = pstmChild.executeQuery(); int childNum = 1; while(rsChild.next()){ String bfkm = AssistMethod.NVL(rsChild.getString("ORIG_ACC_CODE")); String dfkm = AssistMethod.NVL(rsChild.getString("OPP_ACC_CODE")); Pznr pznrJ = new Pznr(); Pznr pznrD = new Pznr(); // Date kjqj = rsChild.getDate("PROC_DATE"); // pznrJ.setKjqj(AssistMethod.getProcDateString(kjqj,"yyyyMM")); // pznrD.setKjqj(AssistMethod.getProcDateString(kjqj,"yyyyMM")); pznrJ.setKjqj(pzml.getKjqj()); pznrD.setKjqj(pzml.getKjqj()); pznrJ.setFlh(String.valueOf(childNum++)); pznrD.setFlh(String.valueOf(childNum++)); pznrJ.setHl("1"); pznrD.setHl("1"); pznrJ.setZy(AssistMethod.NVL(rsChild.getString("REMARK"))); pznrD.setZy(AssistMethod.NVL(rsChild.getString("REMARK"))); pznrJ.setKmdm(bfkm); pznrD.setKmdm(dfkm); pznrJ.setJdbz("借"); pznrD.setJdbz("贷"); pznrJ.setWbje("0"); pznrD.setWbje("0"); pznrJ.setJe(AssistMethod.NVZ(String.valueOf(rsChild.getDouble("CUR_MONEY")))); pznrD.setJe(AssistMethod.NVZ(String.valueOf(rsChild.getDouble("CUR_MONEY")))); pznrJ.setSl("0"); pznrD.setSl("0"); pznrJ.setDj("0"); pznrD.setDj("0"); pznrJ.setCess("0"); pznrD.setCess("0"); pznrJ.setFphfw1("0"); pznrD.setFphfw1("0"); pznrJ.setFphfw2("0"); pznrD.setFphfw2("0"); String subCoCode = AssistMethod.NVL(rsChild.getString("SUB_CO_CODE")); pznrJ.setBmdm(subCoCode); pznrD.setBmdm(subCoCode); // String projectCode = AssistMethod.NVL(rsChild.getString("PROJECT_CODE")); // pznrJ.setXmdm(projectCode); // pznrD.setXmdm(projectCode); String bAccCode = AssistMethod.NVL(rsChild.getString("B_ACC_CODE")); pznrJ.setXmdm(bAccCode); pznrD.setXmdm(bAccCode); pzml.addPznrJ(pznrJ); pzml.addPznrD(pznrD); } }catch(SQLException se){ se.printStackTrace(); throw new BusinessException(se.getMessage()); }catch(Exception e){ e.printStackTrace(); throw new BusinessException(e.getMessage()); }finally{ closeResource(rsChild); closeResource(rsMain); closeResource(pstmChild); closeResource(pstmMain); closeResource(conn); } return pzml; } /** * 凭证导出判断内部单位辅助核算项是否启用 * @param pznr * @param assRelationId * @param accountId * @param bfkm * @param coCode * @param subCoCode * @return * @throws BusinessException */ public static Pzflmx checkPznrChild(Pznr pznr, String assRelationId, String accountId, String bfkm, String coCode, String subCoCode) throws BusinessException{ String[] status = PSDBHelper.getAccStatus(PSDBHelper.getConnection(), bfkm, coCode, accountId); Map itemRelation = PSDBHelper.getItemNRelation(PSDBHelper.getConnection(), assRelationId); for(int i = 0; i < status.length; i++){ if(status[i] != null && status[i].length() > 0 && status[i].equalsIgnoreCase("y")){ String elementCode = (String)itemRelation.get("ACC_ITEM"+i); if(elementCode.equalsIgnoreCase("SUB_CO_CODE")){ if(subCoCode != null && subCoCode.length() > 0){ Pzflmx pzflmx = new Pzflmx(); pzflmx.setGsdm(""); pzflmx.setKjqj(pznr.getKjqj()); pzflmx.setPzly(""); pzflmx.setPzh(""); pzflmx.setFlh(pznr.getFlh()); pzflmx.setFzdm(subCoCode); pzflmx.setJe(pznr.getJe()); return pzflmx; } } } } return null; } /** * 获取Account_ID * @param conn * @param coCode * @return * @throws BusinessException */ public static String getAccountID(Connection conn, String coCode) throws BusinessException { String accountID = ""; String sql = "select ACCOUNT_ID from MA_CO_ACC where co_code = '" + coCode + "' and is_default = 'Y'"; PreparedStatement pstm = null; ResultSet rs = null; try { pstm = conn.prepareStatement(sql); rs = pstm.executeQuery(); while (rs.next()) { accountID = rs.getString("ACCOUNT_ID"); } } catch (