XinYu_RZMES/.svn/pristine/20/20d2255a25e85eec0f5e8067f46ed6fe33533a8d.svn-base

package xin.glue.nui.G.G02;

import java.math.BigDecimal;

import xin.glue.ui.common.PosMessageInfo;
import xin.glue.user.common.GlobalConstants;
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.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;

public class XinRecvDataL2 extends PosActivity implements GlobalConstants {
	public String runActivity(PosContext context) {
		//System.out.println("####################################################################");
		logger.logDebug("XinRecvDataL2 runActivity START...");
		PosRowSet recvDataVO = getDao("mesdao").find("UIG060010_RECV_DATA.select");
		if (recvDataVO.hasNext()) {
			PosParameter param = new PosParameter();
			param.setWhereClauseParameter(0, (recvDataVO.count() + 1) + "");
			getDao("mesdao").update("UIG060010_RECV_DATA.update", param);
			while (recvDataVO.hasNext()) {
				PosRow recvDataROW = recvDataVO.next();
//				Number SEQ_NO = (Number) recvDataROW.getAttribute("SEQ_NO");
//				Number MSG_LEN = (Number) recvDataROW.getAttribute("MSG_LEN");
				String TRAN_DTIME = (String) recvDataROW.getAttribute("TRAN_DTIME");
				String MSG_ID = (String) recvDataROW.getAttribute("MSG_ID");
				String MSG_DATA = (String) recvDataROW.getAttribute("MSG_DATA");
				//System.out.println("####################################################################");
				String TC_DATA = MSG_ID + TRAN_DTIME + MSG_DATA;
				try {
					PosMessageInfo.TC_SEND(TC_DATA, MSG_ID);
					logger.logDebug("XinRecvDataL2 TC_SEND call\nTcid: " + MSG_ID + "\nMessage:" + TC_DATA);
				} catch (Exception e) {
					logger.logError("XinRecvDataL2 Data format error!!!\n" + PosMessageInfo.getMessage(TC_DATA, MSG_ID));
				}
			}
		}

		String[] CHEM_CD = new String[35];
		String[] CHEM_VAL = new String[35];
		PosRowSet chemVO = getDao("mesdao").find("NIG060100_L2_CHEM_RST.select");
		if (chemVO.hasNext()) {
			PosParameter param = new PosParameter();
			param.setWhereClauseParameter(0, (chemVO.count() + 1) + "");
			getDao("mesdao").update("NIG060100_L2_CHEM_RST.update", param);
			while (chemVO.hasNext()) {
				PosRow chemROW = chemVO.next();
//				Number SEQ_NO1 = (Number) chemROW.getAttribute("SEQ_NO");
				String PLAN_CHARGE_NO = (String) chemROW.getAttribute("PLAN_CHARGE_NO");
				String RT_CD = ((String) chemROW.getAttribute("RT_CD")).substring(0,2);
				String TRAN_DTIME = (String) chemROW.getAttribute("TRAN_DTIME");
				BigDecimal EXAMINE_SEQ = (BigDecimal) chemROW.getAttribute("EXAMINE_SEQ");
				for (int i = 0; i < 35; i++) {
					CHEM_CD[i] = (String) chemROW.getAttribute("ELE_CD_" + (i+1));
					CHEM_VAL[i] = (String) chemROW.getAttribute("ELE_" + (i+1));
				}
	
				String PROC_CD = null;
				if (PLAN_CHARGE_NO.substring(0, 1).equals("J")
						&& (RT_CD.equals("LD") || RT_CD.equals("YQ")
								|| RT_CD.equals("LF") || RT_CD.equals("YH")
								|| RT_CD.equals("CP") || RT_CD.equals("RH"))
								|| RT_CD.equals("YC")) {
					if (RT_CD.equals("LD")) PROC_CD = "JB";
					else if (RT_CD.equals("YQ")) PROC_CD = "J1";
					else if (RT_CD.equals("YH")) PROC_CD = "J2";
					else if (RT_CD.equals("LF")) PROC_CD = "JL";
					else if (RT_CD.equals("CP")) PROC_CD = "JJ";
					else if (RT_CD.equals("RH")) PROC_CD = "JR";
					else if (RT_CD.equals("YC")) PROC_CD = "SL";
	
					String TcId = "NIB027080";
					StringBuffer sMsg = new StringBuffer();		int iLen = 0;
					sMsg.append(TcId);							iLen += 9;	//sMsg.setLength(iLen);
					sMsg.append(TRAN_DTIME);					iLen += 14;	sMsg.setLength(iLen);
					sMsg.append(PLAN_CHARGE_NO).append('A');	iLen += 10;	sMsg.setLength(iLen);
					sMsg.append(PROC_CD);						iLen += 2;	sMsg.setLength(iLen);
					sMsg.append(EXAMINE_SEQ);					iLen += 2;	sMsg.setLength(iLen);
					for (int j = 0; j < 35; j++) {
						if (CHEM_CD[j] != null) {
							sMsg.append(CHEM_CD[j]);			iLen += 3;	sMsg.setLength(iLen);
							sMsg.append(CHEM_VAL[j]);			iLen += 7;	sMsg.setLength(iLen);
						} else {
							for (int i = 0; i < 10; i++)
								sMsg.append(' ');
						}
					}
	
					try {
						PosMessageInfo.TC_SEND(sMsg.toString(), TcId);
						logger.logDebug("XinRecvDataL2 CHEM_TC_SEND call\nTcid: " + TcId + "\nMessage:" + sMsg.toString());
					} catch (Exception e) {
						logger.logError("XinRecvDataL2 Chem Data format error!!!\n" + PosMessageInfo.getMessage(sMsg.toString(), TcId));
					}
				}
			}
		}
		return PosBizControlConstants.SUCCESS;
	}
}