package UIM.UIM07; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.CallableStatement; import java.sql.Connection; import java.util.ArrayList; import java.util.Map; import UIB.COM.XmlSqlParsersFactory; import CoreFS.SA01.CoreIComponent; import CoreFS.SA06.CoreReturnObject; /** * 酸轧上料管理 * * @author zsx * @date 2017-7-26 */ public class UIM070020 extends CoreIComponent { public CoreReturnObject deleteyard(ArrayList list) throws SQLException { CoreReturnObject cro = new CoreReturnObject(); StringBuffer sqlBuffer = null; Map result = this.getDao("KgDao").CoreBeginTranscation(); try { for (int i = 0; i < list.size(); i++) { // 判断是否全部选择的标志位 boolean flag = true; String[] param = list.get(i); // 查询钢卷公共表中的SHIP_PROG_CD状态 sqlBuffer = new StringBuffer(); // 更新钢卷公共表中的车辆号,排车顺序号 sqlBuffer = new StringBuffer(); sqlBuffer.append(" UPDATE MATAL_DETAIL_inACCOUNTING\n"); sqlBuffer.append(" SET \n"); sqlBuffer.append(" staus = 'D'\n"); sqlBuffer.append(" WHERE PRIGUID =?\n"); this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(), new Object[] { param[0]}); sqlBuffer = new StringBuffer(); sqlBuffer.append(" UPDATE MATAL_DETAIL_OUTACCOUNTING\n"); sqlBuffer.append(" SET \n"); sqlBuffer.append(" staus = 'D'\n"); sqlBuffer.append(" WHERE PRIGUID =?\n"); this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(), new Object[] { param[0]}); } this.getDao("KgDao").CoreCommit(result); } catch (Exception ex) { this.getDao("KgDao").CoreRollBack(result); cro.setV_errCode(-1); cro.setV_errMsg("删除交易失败!"); } return cro; } public CoreReturnObject returnyard(ArrayList list) throws SQLException { CoreReturnObject cro = new CoreReturnObject(); StringBuffer sqlBuffer = null; Map result = this.getDao("KgDao").CoreBeginTranscation(); try { for (int i = 0; i < list.size(); i++) { // 判断是否全部选择的标志位 boolean flag = true; String[] param = list.get(i); // 查询钢卷公共表中的SHIP_PROG_CD状态 sqlBuffer = new StringBuffer(); // 更新钢卷公共表中的车辆号,排车顺序号 sqlBuffer = new StringBuffer(); sqlBuffer.append(" UPDATE MATAL_DETAIL_inACCOUNTING\n"); sqlBuffer.append(" SET \n"); sqlBuffer.append(" staus = 'N'\n"); sqlBuffer.append(" WHERE PRIGUID =?\n"); this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(), new Object[] { param[0]}); sqlBuffer = new StringBuffer(); sqlBuffer.append(" UPDATE MATAL_DETAIL_OUTACCOUNTING\n"); sqlBuffer.append(" SET \n"); sqlBuffer.append(" staus = 'N'\n"); sqlBuffer.append(" WHERE PRIGUID =?\n"); this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(), new Object[] { param[0]}); } this.getDao("KgDao").CoreCommit(result); } catch (Exception ex) { this.getDao("KgDao").CoreRollBack(result); cro.setV_errCode(-1); cro.setV_errMsg("回退交易失败!"); } return cro; } }