drp.rar_DRP

package com.yoin.drp.flowcard.dao; import java.sql.*; import java.util.*; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.Iterator; import java.util.List; import com.yoin.drp.basedata.AimClient; import com.yoin.drp.basedata.Client; import com.yoin.drp.basedata.manager.ItemManager; import com.yoin.drp.basedata.model.Item; import com.yoin.drp.exceptions.AppException; import com.yoin.drp.flowcard.model.FlowCard; import com.yoin.drp.flowcard.model.FlowCardDetail; import com.yoin.drp.sysmgr.User; import com.yoin.drp.util.DB; import com.yoin.drp.util.PageModel; import com.yoin.drp.util.datadict.ItemCategory; import com.yoin.drp.util.datadict.ItemUnit; /** * 流向单MySql实现 * @author Administrator * */ public class FlowCardDao4MySqlImp implements FlowCardDao { /** * 添加流向单 * @param conn * @param flowCard 流向单对象 */ public void addFlowCard(Connection conn,FlowCard flowCard){ //保存主表 String vouNo = addFlowCardMester(conn,flowCard); System.out.println(vouNo); //保存明细表 addFlowCardDetail(conn,vouNo,flowCard.getFlowCardDetailList()); } /** * 保存流向单主表信息 * @param conn * @param flowCard 流向单对象 * @param流向单号 */ public String addFlowCardMester(Connection conn,FlowCard flowCard) { System.out.println("addFlowCardMester>>" + flowCard); String sql = "insert into t_flow_card (vou_no,fiscal_year,fiscal_period,client_id, " + "opr_type,record_date,recorder_id,vou_sts,spot_flag) " + "value (?,?,?,?,?,?,?,?,?)"; String vouNo = ""; PreparedStatement pstmt = null; try { vouNo = getVouNo(conn); pstmt = conn.prepareStatement(sql); pstmt.setString(1, vouNo); pstmt.setInt(2, flowCard.getFiscalYear()); pstmt.setInt(3, flowCard.getFiscalperiod()); pstmt.setString(4, flowCard.getClient().getClientId()); pstmt.setString(5, flowCard.getOptType()); pstmt.setTimestamp(6, new Timestamp(flowCard.getRecordDate().getTime())); pstmt.setString(7, flowCard.getUser().getUserId()); pstmt.setString(8, flowCard.getVouSts()); pstmt.setString(9, flowCard.getSpotFlag()); pstmt.executeUpdate(); }catch(SQLException e) { System.out.println("保存流向单出错!" + e); throw new AppException("保存流向单出错!"); }finally { DB.close(pstmt); } return vouNo; } /** * 保存流向单明细信息 * @param conn * @param vouNo 流向单号 * @param flowCardDetailList FlowCardDetail对象的集合 */ private void addFlowCardDetail(Connection conn,String vouNo,List flowCardDetailList) { String sql = "insert into t_flow_card_detail (vou_no,aim_id,item_no,qty,adjust_flag) values " + "(?, ?, ?, ?, ?)"; System.out.println("addFlowCardDetail>>" + sql); PreparedStatement pstmt = null; try { pstmt = conn.prepareStatement(sql); for(Iterator<FlowCardDetail> it = flowCardDetailList.iterator(); it.hasNext();) { FlowCardDetail flowCardDetail = it.next(); pstmt.setString(1, vouNo); pstmt.setString(2, flowCardDetail.getAimClient().getId()); pstmt.setString(3, flowCardDetail.getItem().getItemNo()); pstmt.setDouble(4, flowCardDetail.getQry()); pstmt.setString(5, flowCardDetail.getAdjustFlag()); pstmt.addBatch(); } pstmt.executeBatch(); }catch(SQLException e) { System.out.println("添加流向单明细出错!" + e); throw new AppException("添加流向单明细出错"); }finally { DB.close(pstmt); } } /** * 取得流向单号 * @param conn * @return yyyymmdd0000 */ private String getVouNo(Connection conn) throws SQLException{ String currentDate = new SimpleDateFormat("yyyyMMdd").format(new Date()); String sql = "select MAX(vou_no) from t_flow_card"; Statement stmt = null; ResultSet rs = null; String vouNo = currentDate + "0001"; try { stmt = conn.createStatement(); rs = stmt.executeQuery(sql); rs.next(); if(rs.getLong(1) != 0) { vouNo = String.valueOf(rs.getLong(1) + 1); } }catch(SQLException e) { System.out.println("取得流向单号出错!" + e); throw new AppException("取得流向单号出错!"); }finally { DB.close(stmt); } System.out.println("getVouNo()>>" + vouNo); return vouNo; } /** * 通过vouNo ，送审流向单 * @param conn * @param vouNos 流向单号数组 */ public void auditFlowCard(Connection conn,String[] vouNos){ StringBuffer str = new StringBuffer(); for(int i=0; i<vouNos.length; i++) { str.append("'").append(vouNos[i]).append("',"); } String vouNoStr = str.substring(0, str.length()-1); String sql= "update t_flow_card set vou_sts = 'S' where vou_no in (" + vouNoStr + ")"; Statement stmt = null; System.out.println("auditFlowCard>> "+ sql); try { stmt = conn.createStatement(); stmt.executeUpdate(sql); }catch(AppException e) { e.printStackTrace(); throw e; }catch(SQLException e) { throw new AppException("流向单送审出错!"); } } /** * 修改流向单 * @param conn * @param flowCard流向单对象 */ public void modifyFlowCard(Connection conn,FlowCard flowCard){ modifyFlowCardMester(conn,flowCard); modifyFlowCardDetail(conn,flowCard.getVouNo(),flowCard.getFlowCardDetailList()); } /** * 修改流向单主表 * @param conn * @param flowCard flowCard 流向单对象 */ private void modifyFlowCardMester(Connection conn, FlowCard flowCard) { String sql = "update t_flow_card set fiscal_year = ? ,fiscal_period = ? ,client_id = ? ,record_date = ? ," + "recorder_id = ? where vou_no = ? "; PreparedStatement pstmt = null; System.out.println(flowCard.getVouNo()); try { pstmt = conn.prepareStatement(sql); pstmt.setInt(1, flowCard.getFiscalYear()); pstmt.setInt(2, flowCard.getFiscalperiod()); pstmt.setString(3, flowCard.getClient().getClientId()); pstmt.setTimestamp(4, new Timestamp(flowCard.getRecordDate().getTime())); pstmt.setString(5, flowCard.getUser().getUserId()); pstmt.setString(6, flowCard.getVouNo()); pstmt.executeUpdate(); }catch(SQLException e) { System.out.println("修改流向单主表出错!" + e); throw new AppException("修改流向单主表出错!"); }finally { DB.close(pstmt); } } /** * 修改流向单明细表 * @param conn Connection * @param vouNo 流向单号 * @param flowCardDetailList FlowCardDetail对象的集合 */ private void modifyFlowCardDetail(Connection conn, String vouNo, List flowCardDetailList) { String sql = "update t_flow_card_detail set aim_id = ?,item_no = ?,qty = ? where vou_no = ?"; System.out.println("modifyFlowCardDetail>>" + sql); PreparedStatement pstmt = null; try { pstmt = conn.prepareStatement(sql); for(Iterator<FlowCardDetail> it = flowCardDetailList.iterator(); it.hasNext();) { FlowCardDetail flowCardDetail = it.next(); pstmt.setString(1, flowCardDetail.getAimClient().getId()); pstmt.setString(2, flowCardDetail.getItem().getItemNo()); pstmt.setDouble(3, flowCardDetail.getQry()); pstmt.setString(4, vouNo); pstmt.addBatch(); } pstmt.executeBatch(); }catch(SQLException e) { System.out.println("修改流向单明细出错!" + e); throw new AppException("修改流向单明细出错"); }finally { DB.close(pstmt); } } /** * 删除流向单 * @param conn * @param vouNos流向单号数组 */ public void deleteFlowCard(Connection conn,String[] vouNos){ StringBuffer str = new StringBuffer(); for(int i=0; i<vouNos.length; i++) { str.append("'").append(vouNos[i]).append("',"); } String vouNoStr = str.substring(0, str.length()-1); try { deleteFlowCardMester(conn,vouNoStr); deleteFlowCardDetail(conn,vouNoStr); }catch(AppException e) { throw e; }catch(SQLException e) { throw new AppException("删除流向单出错!"); } } /** * 删除流向单主表 * @param conn * @param vouNoStr 流向单号字符串 */ priva