package xin.glue.nui.E.E03;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import xin.glue.ui.common.PosDBEngine;

import com.posdata.glue.PosException;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.biz.control.PosBizProvider;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.vo.PosRowSet;
import com.posdata.glue.msg.PosMESMessageImpl;
import com.posdata.glue.msg.PosMessage;

public class OrdRepSave2 extends PosDBEngine {
	
	String V_ORD_NO;
	String V_ORD_SEQ;
	
	public String runActivity(PosContext ctx) {
		Initialize();
		// 2. Get Parameter( 各语句参数名获取 )
		setParamMap(ctx, "sqlkey0", "param0");	// 充当订单及其余量查询
		setParamMap(ctx, "sqlkey1", "param1");	// 充当物料及其重量查询
		setParamMap(ctx, "sqlkey2", "param2");	// NIE012070 接口参数查询

		setParamMap(ctx, "sqlkey-h", "param-h");// 历史插入
		setParamMap(ctx, "sqlkey-u", "param-u");// XXXX_COMM
		setParamMap(ctx, "sqlkey-d", "param-d");// 删除 XXXX_COMM_D
		setParamMap(ctx, "sqlkey-i", "param-i");// 插入 XXXX_COMM_D
		setParamMap(ctx, "sqlkey-ud", "param-ud");// 更新 XXXX_COMM_D

		String SERVICE_POSTFIX = "-service";
		PosMessage message = new PosMESMessageImpl();
//		message.setTCID("NIE012070");
		ctx.setMessage(message);
//		processComponent(PosConstants.CREATE_MESSAGE, ctx);

		List list = new ArrayList();
		PosRowSet rowSet1 = (PosRowSet) super.Execute(ctx, "sqlkey0", "param0");
		while (rowSet1 == null || rowSet1.hasNext()) {
			if (rowSet1 != null) {
				Map fields = rowSet1.next().getAttributes();
				for (Iterator iterator = fields.entrySet().iterator(); iterator.hasNext();) {
					Map.Entry entry = (Map.Entry) iterator.next();
					ctx.put(entry.getKey().toString(), entry.getValue());
					message.setObject(entry.getKey().toString(), entry.getValue());
					list.add(entry.getKey());
				}
			}

			PosRowSet rowSet2 = (PosRowSet) super.Execute(ctx, "sqlkey1", "param1");
			while (rowSet2.hasNext()) {
				Map fields = rowSet2.next().getAttributes();
				for (Iterator iterator = fields.entrySet().iterator(); iterator.hasNext();) {
					Map.Entry entry = (Map.Entry) iterator.next();
					ctx.put(entry.getKey(), entry.getValue());
					message.setObject(entry.getKey().toString(), entry.getValue());
					list.add(entry.getKey());
				}
				PosRowSet rowSet = (PosRowSet)Execute(ctx, "sqlkey2", "param2");

				Execute(ctx, "sqlkey-h", "param-h", 'i');
				Execute(ctx, "sqlkey-u", "param-u", 'u');

				Execute(ctx, "sqlkey-d", "param-d", 'd');
				Execute(ctx, "sqlkey-i", "param-i", 'i');
				Execute(ctx, "sqlkey-ud", "param-ud", 'u');

				
					
			}
			if (rowSet1 == null) break;
		}
		return PosBizControlConstants.SUCCESS;
	}
}