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 XinHMRecvDataL2 extends XinHandleDataL2 {
	
	public XinHMRecvDataL2() {
	}
	
	public String runActivity(PosContext ctx) {
		logger.logDebug("XinHMRecvDataL2 runActivity START...");
		PosRowSet recvDataVO = getDao().find("RecvDataL2_H_RECV_DATA.Select");
		if (recvDataVO.hasNext())
			ctx.put("_hasRec_", "true");
		while (recvDataVO.hasNext()) {
			PosRow sndDataROW = recvDataVO.next();
			String TC_ID = (String) sndDataROW.getAttribute("TC_ID");
			String TRAN_DTIME = (String) sndDataROW.getAttribute("TRANS_DTIME");
			String MSG_DATA = (String) sndDataROW.getAttribute("TC_MSG");
			if (TC_ID == null || TC_ID.equals("")) {
				logger.logError("XinRecvDataL2 Data format error!!!\n" + MSG_DATA);
				continue;
			}
			MSG_DATA = TC_ID + TRAN_DTIME + MSG_DATA;
			try {
				if (!UpdateRec("RecvDataL2_H_RECV_DATA.Update", new Object[] {"C", sndDataROW.getAttribute("SEQ_NO"), TRAN_DTIME }))
					continue;
				TC_SEND(MSG_DATA, TC_ID);
				logger.logDebug(getMessage(MSG_DATA, TC_ID));
			} catch (Exception e) {
				logger.logError("XinRecvDataL2 Data format error!!!\n" + getMessage(MSG_DATA, TC_ID) + '\n' + e.getMessage());
				UpdateRec("RecvDataL2_H_RECV_DATA.Update", new Object[] {"E", sndDataROW.getAttribute("SEQ_NO"), TRAN_DTIME });
			}
		}

/*
		recvDataVO = getDao().find("RecvDataL2_UH_RECV_DATA.Select");
		if (recvDataVO.hasNext())
			ctx.put("_hasRec_", "true");
		while (recvDataVO.hasNext()) {
			PosRow recvDataROW = recvDataVO.next();
			UpdateRec("RecvDataL2_H_RECV_DATA.Update", new Object[] {"U",
					recvDataROW.getAttribute("SEQ_NO"), recvDataROW.getAttribute("TRANS_DTIME") });
		}
*/
		if (getDao().update("RecvDataL2_UH_RECV_DATA.Update") > 0)
			ctx.put("_hasRec_", "true");
		return PosBizControlConstants.SUCCESS;
	}
}