规则修改适配

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/MessageRo.java

+package com.yeejoin.amos.fas.dao.entity;
+
+import java.util.Date;
+
+import com.yeejoin.amos.fas.core.common.request.DateUtil;
+
+/**
+ * 
+ * <pre>
+ * RO基础信息
+ * </pre>
+ *
+ * @author amos
+ * @version $Id: BasicsRo.java, v 0.1 2019年5月22日 上午10:44:22 amos Exp $
+ */
+public class MessageRo extends BusinessEntity
+{
+
+
+	//TODO 添加批次号字段
+
+
+
+	/**
+	 * 批次号，标记规则执行批次
+	 */
+	private String batchNo;
+
+	/**
+	 * 所要执行的规则包id
+	 */
+	private String packageId;
+
+
+	/**
+	 * <pre>
+	 * 
+	 * </pre>
+	 */
+	private static final long serialVersionUID = -2678718393223476996L;
+	/**
+	 * id
+	 */
+	private String id;
+	/**
+     * 当前时间
+     */
+    private Date dateTime = DateUtil.getNow();
+    /**
+     * 当前时间
+     */
+	private String currTime;
+    
+	public String getId()
+	{
+		return id;
+	}
+	public void setId(String id)
+	{
+		this.id = id;
+	}
+	public Date getDateTime()
+	{
+		if (dateTime == null)
+		{
+			return DateUtil.getNow();
+		}
+		return dateTime;
+	}
+	public void setDateTime(Date dateTime)
+	{
+		this.dateTime = dateTime;
+	}
+	public String getCurrTime()
+	{
+		if (currTime == null)
+		{
+			return DateUtil.getDateTimeFormat(dateTime);
+		}
+		return currTime;
+	}
+	public void setCurrTime(String currTime)
+	{
+		this.currTime = currTime;
+	}
+
+
+	public String getBatchNo() {
+		return batchNo;
+	}
+
+	public void setBatchNo(String batchNo) {
+		this.batchNo = batchNo;
+	}
+
+
+	public String getPackageId() {
+		return packageId;
+	}
+
+	public void setPackageId(String packageId) {
+		this.packageId = packageId;
+	}
+}
\ No newline at end of file

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/action/SimpleTipAction.java

@@ -14,10 +14,11 @@ import com.yeejoin.amos.fas.business.action.result.ActionResult;
 import com.yeejoin.amos.fas.business.action.result.TipResult;
 import com.yeejoin.amos.fas.business.action.result.message.ActionResultMessage;
 import com.yeejoin.amos.fas.business.action.util.DataItemUtil;
-import com.yeejoin.amos.fas.business.service.model.BasicsRo;
+import com.yeejoin.amos.fas.business.service.intfc.IMessageService;
 import com.yeejoin.amos.fas.business.service.model.ToipResponse;
 import com.yeejoin.amos.fas.dao.entity.BusinessEntity;
 import com.yeejoin.amos.fas.dao.entity.Message;
+import com.yeejoin.amos.fas.dao.entity.MessageRo;
 /**
  * 
  * <pre>
@@ -30,71 +31,73 @@ import com.yeejoin.amos.fas.dao.entity.Message;
 @Component
 public class SimpleTipAction implements CustomerAction
 {
-	private static String PACKAGEURL = "com.yeejoin.amos.rule.map.action.result.message.";
-//	@Autowired
-//	private IMessageService messageService;
+	private static String PACKAGEURL = "com.yeejoin.amos.fas.business.action.result.message.";
+	
+	@Autowired
+	private IMessageService messageService;
 
 	//@ExposeAction("消息提示")
-//	public void sendMessageTip(Object bizobj, String title, String content,String type)
-//	{
-//
-//		try
-//		{
-//
-//			ELEvaluationContext.setVariable("bizobj",bizobj);
-//			TipResult result = new TipResult();
-//			result.add(bizobj);
-//			Map<String, Object> tempmap1 = new HashMap<>();
-//			tempmap1.put("title", title);
-//			result.add(tempmap1);
-//			Map<String, Object> tempmap2 = new HashMap<>();
-//			content =DataItemUtil.getNative(content);
-//			tempmap2.put("content", content);
-//			result.add(tempmap2);
-//
-//
-//			Constructor<?> constructor;
-//
-//			constructor = Class.forName(
-//					PACKAGEURL + result.getClass().getSimpleName() + "Message")
-//					.getConstructor(ActionResult.class);
-//			ActionResultMessage<?> action = (ActionResultMessage<?>) constructor.newInstance(result);
-//			String firstStr = "fromws";
-//			String secondStr = "global";
-//			String thirdStr = "msg";
-//			result.setBizObj((BusinessEntity)bizobj);
-//			Object obj = action.execute(firstStr, secondStr, thirdStr);
-//			result.setToipResponse((ToipResponse) obj);
-//			saveMessageAction(result,type);
-//		}
-//		catch (Exception e)
-//		{
-//			// TODO Auto-generated catch block
-//			e.printStackTrace();
-//		}
-//	}
+	public void sendMessageTip(Object bizobj, String title, String content,String type)
+	{
+
+		try
+		{
+
+			ELEvaluationContext.setVariable("bizobj",bizobj);
+			TipResult result = new TipResult();
+			result.add(bizobj);
+			Map<String, Object> tempmap1 = new HashMap<>();
+			tempmap1.put("title", title);
+			result.add(tempmap1);
+			Map<String, Object> tempmap2 = new HashMap<>();
+			content =DataItemUtil.getNative(content);
+			tempmap2.put("content", content);
+			result.add(tempmap2);
+
+
+			Constructor<?> constructor;
+
+			constructor = Class.forName(
+					PACKAGEURL + result.getClass().getSimpleName() + "Message")
+					.getConstructor(ActionResult.class);
+			ActionResultMessage<?> action = (ActionResultMessage<?>) constructor.newInstance(result);
+			String firstStr = "fromws";
+			String secondStr = "global";
+			String thirdStr = "msg";
+			result.setBizObj((BusinessEntity)bizobj);
+			Object obj = action.execute(firstStr, secondStr, thirdStr);
+			result.setToipResponse((ToipResponse) obj);
+			saveMessageAction(result,type);
+		}
+		catch (Exception e)
+		{
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
 	
-//	@SuppressWarnings("unchecked")
-//	private void saveMessageAction(AbstractActionResult abstractActionResult,String type)
-//	{
-//		Message message = new Message();
-//		List<Map<String, Object>> list = (List<Map<String, Object>>) abstractActionResult.getData();
-//		for(Map<String, Object> map : list) {
-//			for(String str: map.keySet()) {
-//				if(str.equals("content")) {
-//					message.setContent(map.get("content").toString());
-//				}else 
-//					if (str.equals("title"))
-//					{
-//						message.setTitle(map.get("title").toString());
-//					}
-//			}
-//			BasicsRo basicsRo = (BasicsRo)abstractActionResult.getToipResponse().getBizObj();
-//			message.setTime(basicsRo.getDateTime());
-//			message.setBizId(basicsRo.getId());
-//			message.setBizclassName(abstractActionResult.getToipResponse().getBizObj().getClass().toString());
-//			message.setType(type);
-//			messageService.save(message);
-//		}
-//	}
+	@SuppressWarnings("unchecked")
+	private void saveMessageAction(AbstractActionResult abstractActionResult,String type)
+	{
+		Message message = new Message();
+		List<Map<String, Object>> list = (List<Map<String, Object>>) abstractActionResult.getData();
+		for(Map<String, Object> map : list) {
+			for(String str: map.keySet()) {
+				if(str.equals("content")) {
+					message.setContent(map.get("content").toString());
+				}else 
+					if (str.equals("title"))
+					{
+						message.setTitle(map.get("title").toString());
+					}
+			}
+			MessageRo messageRo = (MessageRo)abstractActionResult.getToipResponse().getBizObj();
+			message.setTime(messageRo.getCreateDate());
+			//目前获取不到id
+			message.setBizId(messageRo.getId());
+			message.setBizclassName(abstractActionResult.getToipResponse().getBizObj().getClass().toString());
+			message.setType(type);
+			messageService.save(message);
+		}
+	}
 }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/repository/IMessageDao.java

+package com.yeejoin.amos.fas.business.dao.repository;
+
+import com.yeejoin.amos.fas.dao.entity.ContingencyOriginalData;
+
+public interface IMessageDao extends BaseDao<ContingencyOriginalData, String> {
+
+}

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/ContingencyInstanceImpl.java

 package com.yeejoin.amos.fas.business.service.impl;
 
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+import org.apache.commons.lang3.ArrayUtils;
+import org.codehaus.jackson.map.ObjectMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.client.RestTemplate;
+
 import com.yeejoin.amos.component.rule.RuleTrigger;
 import com.yeejoin.amos.fas.business.action.ContingencyAction;
 import com.yeejoin.amos.fas.business.action.result.BubbleTipResult;
@@ -15,27 +32,6 @@ import com.yeejoin.amos.fas.dao.entity.ContingencyOriginalData;
 import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
 import com.yeejoin.amos.fas.dao.entity.Equipment;
 
-import org.apache.commons.lang3.ArrayUtils;
-import org.codehaus.jackson.map.ObjectMapper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.BeanUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.http.HttpEntity;
-import org.springframework.http.HttpMethod;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
-import org.springframework.web.client.RestTemplate;
-import org.typroject.tyboot.component.cache.Redis;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-
 @Service
 public class ContingencyInstanceImpl /*extends GenericManagerImpl<ContingencyPlanInstance, String>*/ implements IContingencyInstance {
 
@@ -44,11 +40,9 @@ public class ContingencyInstanceImpl /*extends GenericManagerImpl<ContingencyPla
     @Autowired
     private IContingencyPlanInstanceRepository repository;
 
-
     @Autowired
     IContingencyOriginalDataDao iContingencyOriginalDataDao;
 
-
     @Autowired
     private RemoteRuleServer remoteRuleServer;
 

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/MessageServiceImpl.java

+package com.yeejoin.amos.fas.business.service.impl;
+
+import java.util.List;
+
+import org.springframework.stereotype.Service;
+
+import com.yeejoin.amos.fas.business.service.intfc.IMessageService;
+import com.yeejoin.amos.fas.dao.entity.Message;
+
+
+
+@Service
+public class MessageServiceImpl  implements IMessageService  {
+	//MessageMapper messageMapper;
+		
+	@Override
+	public List<Message> findMessageByBizId(String bizId) {
+		return null;
+		// TODO Auto-generated method stub
+		// messageRepository.findMessageByBizId(bizId);
+	}
+
+	@Override
+	public void save(Message msg) {
+		// TODO Auto-generated method stub
+		
+	}
+}

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IMessageService.java

+package com.yeejoin.amos.fas.business.service.intfc;
+
+import java.util.List;
+
+import com.yeejoin.amos.fas.dao.entity.Message;
+
+public interface IMessageService 
+{
+
+	List<Message> findMessageByBizId(String bizId);
+	
+	void save(Message msg);
+}