msgexchange-api/src/main/java/com/gzzn/omms/msgexchangeapi/runner/AppRunner.java

package com.gzzn.omms.msgexchangeapi.runner;

import java.util.Date;
import java.util.Locale;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;

import com.gzzn.omms.msgexchangeapi.dao.CmoutmsgDao;
import com.gzzn.omms.msgexchangeapi.entity.Cmoutmsg;
import com.gzzn.omms.msgexchangeapi.entity.msg.rqfd.RefdMsg;
import com.gzzn.omms.msgexchangeapi.entity.msg.rqfd.RefdMsgBody;
import com.gzzn.omms.msgexchangeapi.redis.dao.ContextDao;
import com.gzzn.omms.msgexchangeapi.redis.entity.Context;
import com.gzzn.omms.msgexchangeapi.service.IExchangeService;
import com.gzzn.omms.msgexchangeapi.utils.DateTimeUtil;


public class AppRunner implements CommandLineRunner  {

	private static Logger logger = LoggerFactory.getLogger(AppRunner.class);
	
	
	@Autowired
	private CmoutmsgDao cmoutmsgDao;
	
	@Autowired
	private ContextDao contextDao;
	
	@Autowired
	private IExchangeService exchangeService;
	
	@Override
	public void run(String... args) throws Exception {
		//构造消息
		Date nowDate = new Date();
		Cmoutmsg cmoutmsg = new Cmoutmsg();
		RefdMsgBody body = new RefdMsgBody();
		body.setStdb(
				      DateTimeUtil.gtFormatStr(
				      nowDate, 
				      "ddMMMyyHHmm",
				      Locale.ENGLISH)
				      .toUpperCase()
				      );
		RefdMsg msg = new RefdMsg();
		msg.setRefd(body);
		cmoutmsg.setCminmsgsClobMsg(exchangeService.objectToXmlstr(msg));
		cmoutmsg.setCminmsgsStatus("VALID");
		
		cmoutmsgDao.save(cmoutmsg);
		
		
		// 
		Context isWaitSchd = new Context();
		isWaitSchd.setKey(Context.KEY_ISWAITSCHD); //等待返回日计划状态
		isWaitSchd.setValue("true");
		contextDao.save(isWaitSchd);

		//初始化消息进度
		Context msgProgress = new Context();
		msgProgress.setKey(Context.KEY_MSGPROGRESS);
		msgProgress.setValue( DateTimeUtil.gtFormatStr(
			      nowDate, 
			      "yyyy-MM-dd hh:mm:ss",
			      Locale.ENGLISH)
				);
		contextDao.save(msgProgress);
	}//end function run
}