gbs_mmifdetail_db.java

对日软件外包 为东芝做的一个全球商业管理系统

				if ( conn != null ){
					conn.close();	
				}
			} catch (SQLException se) {
				System.out.println("[Error Happen!]");
				System.out.println("[Start Trace]");
				se.printStackTrace();
				System.out.println("[End Trace]");
				throw se;
			}
		}
		return returnValue ;
	
	}			
			
	/**
	 * delete *  from M_MIF_DETAIL
	 * @return		GBS_MMif_stBean in
	 * @exception	Exception    Exception for information of other errors
	 * @since		2004/08/09
	 */
	public int deleteMifEntryDetail(GBS_MMif_stBean in, Connection conn)throws Exception{
		//Add by Gxk 2004/09/10 Start
		in.setAtchFileName(BaseCommonCheck.convertSql(in.getAtchFileName()));
		in.setCountryCode(BaseCommonCheck.convertSql(in.getCountryCode()));
		in.setCreateUser(BaseCommonCheck.convertSql(in.getCreateUser()));
		in.setCustomerId(BaseCommonCheck.convertSql(in.getCustomerId()));
		in.setCustomerName(BaseCommonCheck.convertSql(in.getCustomerName()));
		in.setProductCategory(BaseCommonCheck.convertSql(in.getProductCategory()));
		in.setRemarks(BaseCommonCheck.convertSql(in.getRemarks()));
		in.setSubsidiaryCode(BaseCommonCheck.convertSql(in.getSubsidiaryCode()));
		in.setUpdateUser(BaseCommonCheck.convertSql(in.getUpdateUser()));
		//Add by Gxk 2004/09/10 End

		ReturnValue returnValue = new ReturnValue();
		MessageList messageList = new MessageList();
		returnValue.setMessageList( messageList );

		StringBuffer sql =  new StringBuffer();
		
		/////////////////////////////////////////////////////////////////////////////
		//EDIT SQL
		sql.append( " SELECT ");
		sql.append( " 			CUSTOMER_ID ");
		sql.append( " FROM ");
		sql.append( " 			M_MIF_DETAIL ");
		sql.append( " WHERE " );
		sql.append( " 			M_MIF_DETAIL.CUSTOMER_ID 	  = '" + in.getCustomerId() + "'" );
		sql.append( " AND 		M_MIF_DETAIL.PRODUCT_CATEGORY = '" + in.getProductCategory() + "'" );
		sql.append( " AND 		M_MIF_DETAIL.SUBSIDIARY_CODE  = '" + in.getSubsidiaryCode() + "'" );
		sql.append( " AND 		M_MIF_DETAIL.COUNTRY_CODE     = '" + in.getCountryCode() + "'" );
		sql.append( " FOR UPDATE " );
		//END EDIT SQL
		///////////////////////////////////////////////////////////////////////////////
		//print sql
		System.out.println( "[INFO] sql = " + sql.toString() );
		ResultSet rset = null;
		Statement st = null;
		String strSql = "";
		PreparedStatement pstmt = null;
		int bresult = 0;
		try{
			strSql = sql.toString();
			st = conn.createStatement();
			rset = st.executeQuery(strSql);
			if(!rset.next()){
				bresult = 1;
			}
			if ( bresult == 0 ){
				sql = new StringBuffer();
				strSql = "";
				//start sql edit   ================================
				
				sql.append( "  DELETE FROM M_MIF_DETAIL" );
				sql.append( "  WHERE" );
				sql.append( "   		CUSTOMER_ID 	 = '"+ in.getCustomerId() + "'" );	
				sql.append( "  AND 		PRODUCT_CATEGORY = '" + in.getProductCategory() + "'" );
				sql.append( "  AND 		COUNTRY_CODE     = '" + in.getCountryCode() + "'" );
				sql.append( "  AND 		SUBSIDIARY_CODE  = '" + in.getSubsidiaryCode() + "'" );
				
				//end sql edit   ================================
				
				//print sql				
				System.out.println( "[INFO] sql = " + sql.toString() );	
					
				strSql = sql.toString();
				//st = conn.createStatement();
				pstmt = conn.prepareStatement(strSql);
				//bresult= st.execute(strSql);
				bresult = pstmt.executeUpdate();
			}	
		}catch (Exception exception) {
			System.out.println("[Error Happen!]");
			System.out.println("[Start Trace]");
			exception.printStackTrace();
			System.out.println("[End Trace]");
			throw exception;
		}finally {
			//release db
			try {
				if ( rset != null ) {
					rset.close();
				}
				if ( pstmt != null ){
					pstmt.close();
				}
				if ( st != null ) {
					st.close();
				}
			} catch (SQLException se) {
				System.out.println("[Error Happen!]");
				System.out.println("[Start Trace]");
				se.printStackTrace();
				System.out.println("[End Trace]");
				throw se;
			}
		}
		return bresult ;
	
	}
	
	/**
	 * delete *  from M_MIF_DETAIL by PK
	 * @return		GBS_MMif_stBean in
	 * @exception	Exception    Exception for information of other errors
	 * @since		2004/08/09
	 */
	public int deleteEntryDetail(GBS_MifEntryList_stBean MifIn, GBS_MMifDetail_stBean detail_st, Connection conn)
		throws Exception {
		//Add by Gxk 2004/09/10 Start
		MifIn.setCountryCode(BaseCommonCheck.convertSql(MifIn.getCountryCode()));
		MifIn.setCustomerId(BaseCommonCheck.convertSql(MifIn.getCustomerId()));
		MifIn.setProductCategory(BaseCommonCheck.convertSql(MifIn.getProductCategory()));
		MifIn.setRemarks(BaseCommonCheck.convertSql(MifIn.getRemarks()));
		MifIn.setSubsidiaryCode(BaseCommonCheck.convertSql(MifIn.getSubsidiaryCode()));
		MifIn.setUser(BaseCommonCheck.convertSql(MifIn.getUser()));
		
		detail_st.setCpcPrice(BaseCommonCheck.convertSql(detail_st.getCpcPrice()));
		detail_st.setCreateUser(BaseCommonCheck.convertSql(detail_st.getCreateUser()));
		detail_st.setCurrency(BaseCommonCheck.convertSql(detail_st.getCurrency()));
		detail_st.setHardPrice(BaseCommonCheck.convertSql(detail_st.getHardPrice()));
		detail_st.setInstallDate(BaseCommonCheck.convertSql(detail_st.getInstallDate()));
		detail_st.setMcv(BaseCommonCheck.convertSql(detail_st.getMcv()));
		detail_st.setModel(BaseCommonCheck.convertSql(detail_st.getModel()));
		detail_st.setModelOld(BaseCommonCheck.convertSql(detail_st.getModelOld()));
		detail_st.setPerson(BaseCommonCheck.convertSql(detail_st.getPerson()));
		detail_st.setQty(BaseCommonCheck.convertSql(detail_st.getQty()));
		detail_st.setRfpDate(BaseCommonCheck.convertSql(detail_st.getRfpDate()));
		detail_st.setUpdateUser(BaseCommonCheck.convertSql(detail_st.getUpdateUser()));
		detail_st.setUserId(BaseCommonCheck.convertSql(detail_st.getUserId()));
		detail_st.setUserName(BaseCommonCheck.convertSql(detail_st.getUserName()));
		//Add by Gxk 2004/09/10 End

		ReturnValue returnValue = new ReturnValue();
		MessageList messageList = new MessageList();
		returnValue.setMessageList(messageList);

		StringBuffer sql = new StringBuffer();

		/////////////////////////////////////////////////////////////////////////////
		//EDIT SQL
		sql.append(" SELECT ");
		sql.append(" 			CUSTOMER_ID ");
		sql.append(" FROM ");
		sql.append(" 			M_MIF_DETAIL ");
		sql.append(" WHERE ");
		sql.append(" 			M_MIF_DETAIL.CUSTOMER_ID      = '" + MifIn.getCustomerId() + "'");
		sql.append(" AND 		M_MIF_DETAIL.PRODUCT_CATEGORY = '" + MifIn.getProductCategory() + "'");
		sql.append(" AND 		M_MIF_DETAIL.SUBSIDIARY_CODE  = '" + MifIn.getSubsidiaryCode() + "'");
		sql.append(" AND 		M_MIF_DETAIL.COUNTRY_CODE     = '" + MifIn.getCountryCode() + "'");
		sql.append(" AND 		M_MIF_DETAIL.MODEL 			  = '" + detail_st.getModelOld() + "'");
		sql.append(" FOR UPDATE ");

		//EDIT SQL	
		/////////////////////////////////////////////////////////////////////////////

		//print sql
		System.out.println("[INFO] sql = " + sql.toString());
		ResultSet rset = null;
		Statement st = null;
		PreparedStatement pstmt = null;
		String strSql = "";
		int bresult = 0;
		try {
			st = conn.createStatement();
			strSql = sql.toString();
			rset = st.executeQuery(strSql);
			if (!rset.next()) {
				bresult = -1;
				messageList.setMessage("", "", "10000002", Integer.MIN_VALUE);
				returnValue.setBussinessError();
			}
			if (bresult == 0) {
				sql = new StringBuffer();
				strSql = "";
				//start sql edit   ================================
				sql.append("  DELETE FROM M_MIF_DETAIL");
				sql.append("  WHERE");
				sql.append("   		CUSTOMER_ID 	 = '" + MifIn.getCustomerId() + "'");
				sql.append("  AND 		PRODUCT_CATEGORY = '" + MifIn.getProductCategory() + "'");
				sql.append("  AND 		COUNTRY_CODE     = '" + MifIn.getCountryCode() + "'");
				sql.append("  AND 		SUBSIDIARY_CODE  = '" + MifIn.getSubsidiaryCode() + "'");
				sql.append("  AND 		MODEL 			 = '" + detail_st.getModelOld() + "'");

				//end sql edit   ================================

				//print sql				
				System.out.println("[INFO] sql = " + sql.toString());

				strSql = sql.toString();
				//st = conn.createStatement();
				pstmt = conn.prepareStatement(strSql);
				//bresult= st.execute(strSql);
				bresult = pstmt.executeUpdate();
			}
		} catch (Exception exception) {
			System.out.println("[Error Happen!]");
			System.out.println("[Start Trace]");
			exception.printStackTrace();
			System.out.println("[End Trace]");
			throw exception;
		} finally {
			//release db
			try {
				if (rset != null) {
					rset.close();
				}
				if (pstmt != null) {
					pstmt.close();
				}
				if (st != null) {
					st.close();
				}
			} catch (SQLException se) {
				System.out.println("[Error Happen!]");
				System.out.println("[Start Trace]");
				se.printStackTrace();
				System.out.println("[End Trace]");
				throw se;
			}
		}
		return bresult;

	}		

	/**
	 * method deleteAttachmentFile  
	 * @param String Seqno
	 * @param FormFile AttachmentFile
	 * @param Connection conn 
	 * @return ReturnValue
	 * @throws Exception
	 */		
	public ReturnValue deleteAttachmentFile( GBS_MifEntryList_stBean in,
											  Connection conn  )throws Exception{

			StringBuffer sql = new StringBuffer();
			ReturnValue returnValueD = new ReturnValue();
			MessageList messageList = new MessageList();
			returnValueD.setMessageList( messageList );

			sql.append( " SELECT" );
			sql.append( "       ATCH_FILE, ATCH_FILE_NAME" );//
			sql.append( " FROM " );
			sql.append( "       M_MIF " );
			sql.append( " WHERE " );
			sql.append( " 		CUSTOMER_ID      = '" + BaseCommonCheck.convertSql(in.getCustomerId()) + "'" );
			sql.append( " AND	PRODUCT_CATEGORY = '" + BaseCommonCheck.convertSql(in.getProductCategory()) + "'" );
			sql.append( " AND	SUBSIDIARY_CODE  = '" + BaseCommonCheck.convertSql(in.getSubsidiaryCode()) + "'" );
			sql.append( " AND	COUNTRY_CODE     = '" + BaseCommonCheck.convertSql(in.getCountryCode()) + "'" );
			sql.append( " 		FOR UPDATE " );
			System.out.println("[INFO] SQL = " + sql.toString());
		
			int ret = 0;
	
			ResultSet rset = null;
			Statement st = null;
			PreparedStatement pstmt = null;
		
			try{		
				st = conn.createStatement();
				rset = st.executeQuery(sql.toString());
				if(rset.next()){
				}else{
					ret = -1;
				}
				if ( ret == 0 ){
					sql = new StringBuffer();
					sql.append( " UPDATE M_MIF SET ATCH_FILE = EMPTY_BLOB() ," );
					sql.append( "        ATCH_FILE_NAME = ''");
					sql.append( " WHERE " );
					sql.append( " 		CUSTOMER_ID      = '" + BaseCommonCheck.convertSql(in.getCustomerId()) + "'" );
					sql.append( " AND	PRODUCT_CATEGORY = '" + BaseCommonCheck.convertSql(in.getProductCategory()) + "'" );
					sql.append( " AND	SUBSIDIARY_CODE  = '" + BaseCommonCheck.convertSql(in.getSubsidiaryCode()) + "'" );
					sql.append( " AND	COUNTRY_CODE     = '" + BaseCommonCheck.convertSql(in.getCountryCode()) + "'" );

					System.out.println("[INFO] SQL = " + sql.toString());
					pstmt = conn.prepareStatement( sql.toString() );				
					ret = pstmt.executeUpdate();
				}
						
			 }catch (Exception exception) {
				System.out.println("[Error Happen!]");
				System.out.println("[Start Trace]");
				exception.printStackTrace();
				System.out.println("[End Trace]");
				throw exception;
			 }finally {
				returnValueD.setDataValue(new Integer(ret));
					//release db
			try {
			  if (rset != null) {
				rset.close();
			  }
			  if ( pstmt != null ){
				pstmt.close();
			  }
			  if (st != null) {
				st.close();
			  }
		  
			} catch (SQLException se) {
				System.out.println("[Error Happen!]");
				System.out.println("[Start Trace]");
				se.printStackTrace();
				System.out.println("[End Trace]");
				throw se;
			}
		  }
		  return returnValueD ;
		}
}