package xin.glue.scheduling;

import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;

public class XinG2RecvDataL2 extends XinHandleDataL2 {
	public String runActivity(PosContext ctx) {
		logger.logDebug("XinG2RecvDataL2 runActivity START...");
		PosRowSet recvDataVO = getDao().find("RecvDataL2_G_RECV_DATA.Select");
		if (recvDataVO.hasNext())
			ctx.put("_hasRec_", "true");
		while (recvDataVO.hasNext()) {
			PosRow recvDataROW = recvDataVO.next();
			String MSG_ID = (String) recvDataROW.getAttribute("MSG_ID");
			String TRAN_DTIME = (String) recvDataROW.getAttribute("TRAN_DTIME");
			String MSG_DATA = (String) recvDataROW.getAttribute("MSG_DATA");
			String TC_DATA = MSG_ID + TRAN_DTIME + MSG_DATA;
			try {
				if (!UpdateRec("RecvDataL2_G_RECV_DATA.Update", new Object[] {"C", recvDataROW.getAttribute("SEQ_NO"), TRAN_DTIME }))
					continue;
				TC_SEND(TC_DATA, MSG_ID);
				logger.logDebug(getMessage(TC_DATA, MSG_ID));
			} catch (Exception e) {
				logger.logError("XinG2RecvDataL2 Data format error!!!\n" + getMessage(TC_DATA, MSG_ID) + '\n' + e.getMessage());
				UpdateRec("RecvDataL2_G_RECV_DATA.Update", new Object[] {"E", recvDataROW.getAttribute("SEQ_NO"), TRAN_DTIME });
			}
		}
		
/*
		recvDataVO = getDao().find("RecvDataL2_UG_RECV_DATA.Select");
		if (recvDataVO.hasNext())
			ctx.put("_hasRec_", "true");
		while (recvDataVO.hasNext()) {
			PosRow recvDataROW = recvDataVO.next();
			UpdateRec("RecvDataL2_G_RECV_DATA.Update", new Object[] {"U",
					recvDataROW.getAttribute("SEQ_NO"), recvDataROW.getAttribute("TRAN_DTIME") });
		}
*/
		if (getDao().update("RecvDataL2_UG_RECV_DATA.Update") > 0)
			ctx.put("_hasRec_", "true");
		return PosBizControlConstants.SUCCESS;
	}
}