XinYu_RZMES/.svn/pristine/60/60ec1127fbc10a38227a1c30dad46fb51af20f2c.svn-base

package xin.glue.ui.G.G02;

import com.posdata.glue.biz.activity.PosActivity;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.PosGenericDao;
import com.posdata.glue.dao.vo.PosPageSet;
import com.posdata.glue.dao.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;
import com.posdata.glue.web.control.PosGenericAction;
/**
 * 成分参数插入、删除、修改（对应界面ID:UIG020062）
 * @author 
 * @date   2014-11-26
 */
public class PosSaveSlabCutting_1 extends PosActivity
{
	public String runActivity(PosContext context)
	{
		 PosGenericDao dao = this.getDao("mesdao");
		// String		INFID  =  "UIG020062";
			PosRowSet	 rowset 	= null;
			PosRow		 row 		= null;
		 
		 String[]CHK  			= (String[])context.get("CHK");//标识
		 String[]CHARGE_NO      = (String[])context.get("CHARGE_NO");    //炉号
		 String[]SLAB_NO        = (String[])context.get("SLAB_NO");       //板坯号
		 String[]CC_DEVNO  		= (String[])context.get("CC_DEVNO");	//铸机号
         String[]STL_GRD  		= (String[])context.get("STL_GRD");			//钢种
        
         String[]STATE     		= (String[])context.get("STATE");   //发送标识
         String[]FLAG           = (String[])context.get("FLAG");         //板坯状态
         String[]SLAB_THK       = (String[])context.get("PLY");      //板坯厚度
         String[]SLAB_WTH     	= (String[])context.get("WIDTH");
         String[]SLAB_LEN       = (String[])context.get("LEN");
         String[]rowStuts		= (String[])context.get("rowStuts");//行状态
         
         String[]QUANTITY     	= (String[])context.get("QUANTITY");   //支数  板坯为1 方坯为实际支数
         String[]THEOR_WGT      = (String[])context.get("THEOR_WGT");         //理论重量
         String[]WGT_SEQ       	= (String[])context.get("WGT_SEQ");      //称重序号
         String[]REAL_WGT     	= (String[])context.get("REAL_WGT");	//称重重量
         String[]SEDN_TIME      = (String[])context.get("SEDN_TIME");	//最后一次发送时间
         String[]REVERT_TIME	= (String[])context.get("REVERT_TIME");   //自动化返回时间
         
         String[]LAST_UPDATETIME = (String[])context.get("LAST_UPDATETIME");   //最后更新时间
         String[]HEATOVERFLAG    = (String[])context.get("HEATOVERFLAG");   //炉次结束标志
         String[]CUTTIME		 = (String[])context.get("CUTTIME");	//切割时间
         if(rowStuts != null)
         {
        	 int len = rowStuts.length;
        	 //int j = 0;
        	 PosParameter param =  null;
        	 for(int i=0; i < len; i++)
        	 {
        		 //j = 0;
        		// if("Y".equals(CHK[i]))//只对勾选的数据进行更新
        		// {
        		//	 continue;
        		// }
        		 
        		param = new PosParameter();  
     		    param.setWhereClauseParameter(0, CHARGE_NO[i]);
     		    param.setWhereClauseParameter(1, SLAB_NO[i]);
  
     		    String ccDrvNoSql = "select CHARGE_NO,SLAB_NO,CC_DEVNO,STL_GRD from tb_slab_wgt_send where  CHARGE_NO = ?  and   SLAB_NO = ? ";
     		    rowset = this.getDao("mesdao").findByQueryStatement(ccDrvNoSql, param);
     		    //有数据则更新，没有则插入
     		   if(rowset.hasNext()){
     			   param = new PosParameter(); 
     			   param.setWhereClauseParameter(0, CHARGE_NO[i]);   //根据炉号和板坯号获取自动化返回数据
     			   param.setWhereClauseParameter(1, SLAB_NO[i]);
     			   //查询接收表未处理的数据
     			   String recsql = "select wgt_seq,CHARGE_NO,SLAB_NO,real_wgt,revert_time from tb_slab_wgt_rec where CHARGE_NO = ?  and   SLAB_NO = ? and flag = '0'";
     			   PosRowSet	 	rowset1 = this.getDao("mesdao").findByQueryStatement(recsql, param);
     			   if(rowset1.hasNext()){
     			   PosRow row1 = rowset1.next();
     			   
     			   String tempwgt = (String)row1.getAttribute("real_wgt").toString();
     			   String tempslabno = (String)row1.getAttribute("SLAB_NO");
     			   String tempchargeno = (String)row1.getAttribute("CHARGE_NO");
     			   String tempwgtseq = (String)row1.getAttribute("wgt_seq");
     			   String temprevertime = (String)row1.getAttribute("revert_time");
     			   
     			   PosParameter param1 = new PosParameter();    			  
    			   param1.setWhereClauseParameter(0, tempwgt);
    			   param1.setWhereClauseParameter(1, tempwgtseq);
    			   param1.setWhereClauseParameter(2, temprevertime);
    			   param1.setWhereClauseParameter(3, tempchargeno);   
    			   param1.setWhereClauseParameter(4, tempslabno);

    			   //String recupdsql = "update tb_slab_wgt_send a set a.state = '2',a.real_wgt = ? ,a.wgt_seq = ? ,a.revert_time = ?,a.last_updatetime = to_char(sysdate,'yyyymmddhh24miss')  where heatno = ? and billetno = ?";
    			   //更新实际重量
    			   this.getDao("mesdao").update("UIG020060_104.update", param1);
    			   
    			   
    			   PosParameter param2 = new PosParameter();    			  
    			   param2.setWhereClauseParameter(0, CHARGE_NO[i]);   //根据炉号和板坯号获取自动化返回数据
    			   param2.setWhereClauseParameter(1, SLAB_NO[i]);
    			  // update tb_slab_wgt_rec set flag = '1'  where heatno = ?  and billetno = ? and WGT_SEQ = ? and REVERT_TIME = ? and flag = '0' 
    			   //更新接收表状态
    			   this.getDao("mesdao").update("UIG020060_105.update", param2); 
	        		
     			   }
     		   
     			//SlabNo[i] = tempNo.substring(10, 13);

     		   }else{
	        		param = new PosParameter(); 
        			param.setWhereClauseParameter(0, CHARGE_NO[i]);//表示序号
         			param.setWhereClauseParameter(1, SLAB_NO[i]);//成分
         			param.setWhereClauseParameter(2, CC_DEVNO[i]);//保留位数
         			param.setWhereClauseParameter(3, STL_GRD[i]);//详细内容
         			param.setWhereClauseParameter(4, '0');//录入者或者修改者  			
         			param.setWhereClauseParameter(5, FLAG[i]);//详细内容
         			param.setWhereClauseParameter(6, SLAB_THK[i]);//成分        			
         			param.setWhereClauseParameter(7, SLAB_WTH[i]);//表示序号
         			param.setWhereClauseParameter(8, SLAB_LEN[i]);//成分
         			param.setWhereClauseParameter(9, QUANTITY[i]);//保留位数
         			param.setWhereClauseParameter(10, THEOR_WGT[i]);//详细内容
         			param.setWhereClauseParameter(11, HEATOVERFLAG[i]);//详细内容

         			param.setWhereClauseParameter(12, CUTTIME[i]);//录入者或者修改者  			

        			 
        			 dao.insert("UIG020060_101.insert", param);   
	        	}
        	
        		/* if("d".equals(row Stuts[i]))
        		 {
        			 param = new PosParameter(); 
        			 param.setWhereClauseParameter(j++, CHEM_CD[i]);
        			 dao.delete("UIB010070_01.DELETE", param);
        			 //记录删除信息
        			 SaveModifyHistory.writeLog(dao, INFID, "D", "UIB010070_01.DELETE", param.getWhereClauseParamters(), "", REG_NM[0]);
        		 }*/
        	 }
         }
         
         return PosBizControlConstants.SUCCESS;
	}

}