Skip to content

Y
YeeAmosFireAutoSysRoot
Commit 6d13cee1 authored by 单奇雲's avatar 单奇雲
Browse files
Options

Merge branch 'dev_upgrade' of http://172.16.10.76/station/YeeAmosFireAutoSysRoot into dev_upgrade

parents 4477efa1 baf46507
Hide whitespace changes
Inline Side-by-side
Showing with 1144 additions and 1258 deletions
YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/MessageRo.java 0 → 100644
View file @ 6d13cee1
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/ContingencyAction.java
View file @ 6d13cee1
//package com.yeejoin.amos.fas.business.action; package com.yeejoin.amos.fas.business.action;
//
//
//import java.io.IOException; import java.io.IOException;
//import java.lang.reflect.Constructor; import java.lang.reflect.Constructor;
//import java.lang.reflect.Field; import java.lang.reflect.Field;
//import java.lang.reflect.Method; import java.lang.reflect.Method;
//import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
//import java.util.Date; import java.util.Date;
//import java.util.HashMap; import java.util.HashMap;
//import java.util.List; import java.util.List;
//import java.util.Map; import java.util.Map;
//
//import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
//
//import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
//import com.yeejoin.amos.fas.business.action.result.ActionResult; import com.yeejoin.amos.fas.business.action.result.ActionResult;
//import com.yeejoin.amos.fas.business.action.result.BubbleTipResult; import com.yeejoin.amos.fas.business.action.result.BubbleTipResult;
//import com.yeejoin.amos.fas.business.action.result.message.ActionResultMessage; import com.yeejoin.amos.fas.business.action.result.message.ActionResultMessage;
//import com.yeejoin.amos.fas.business.service.impl.RuleRunigSnapshotServiceImpl; import com.yeejoin.amos.fas.business.service.impl.RuleRunigSnapshotServiceImpl;
//import com.yeejoin.amos.fas.business.service.intfc.FireStengthService; import com.yeejoin.amos.fas.business.service.intfc.FireStengthService;
//import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance; import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance;
//import com.yeejoin.amos.fas.business.service.intfc.IRiskSourceService; import com.yeejoin.amos.fas.business.service.intfc.IRiskSourceService;
//import com.yeejoin.amos.fas.business.service.model.ContingencyDeviceStatus; import com.yeejoin.amos.fas.business.service.model.ContingencyDeviceStatus;
//import com.yeejoin.amos.fas.business.service.model.ContingencyRo; import com.yeejoin.amos.fas.business.service.model.ContingencyRo;
//import com.yeejoin.amos.fas.business.util.StringUtil; import com.yeejoin.amos.fas.business.util.StringUtil;
//import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance; import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
//import com.yeejoin.amos.fas.dao.entity.FireStrength; import com.yeejoin.amos.fas.dao.entity.FireStrength;
//
//@Component @Component
//public class ContingencyAction implements CustomerAction { public class ContingencyAction implements CustomerAction {
//
//
// private static String PACKAGEURL = "com.yeejoin.amos.fas.business.action.result.message."; private static String PACKAGEURL = "com.yeejoin.amos.fas.business.action.result.message.";
//
// @Autowired @Autowired
// private IContingencyInstance iContingencyInstance; private IContingencyInstance iContingencyInstance;
//
// @Autowired @Autowired
// private FireStengthService fireStrengthService; private FireStengthService fireStrengthService;
//
// // private RestTemplate restTemplate = new RestTemplate(); // private RestTemplate restTemplate = new RestTemplate();
//
// // @Value("${bussunis.domain}") // @Value("${bussunis.domain}")
// // private String bussunisDomain ; // private String bussunisDomain ;
//
// @Autowired @Autowired
// private IRiskSourceService riskSourceService; private IRiskSourceService riskSourceService;
//
// private static Map<String, String> OPERATE_RECORD_ID = new HashMap<>(); private static Map<String, String> OPERATE_RECORD_ID = new HashMap<>();
//
// private static Map<String, Map<String,String>> stringStringMap = new HashMap<>(); private static Map<String, Map<String,String>> stringStringMap = new HashMap<>();
// static SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss"); static SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
//
// //当值值班长（S1）、副值班长(S2)、值班员(A1,A2,A3)、白班值班员、保安人员、驻站消防队长(F1) //当值值班长（S1）、副值班长(S2)、值班员(A1,A2,A3)、白班值班员、保安人员、驻站消防队长(F1)
// /* private static Map<String, String> positionMap = new HashMap<String, String>() {{ /* private static Map<String, String> positionMap = new HashMap<String, String>() {{
// put("S1", "S1"); put("S1", "S1");
// put("S2", "S2"); put("S2", "S2");
// put("A1", "A1"); put("A1", "A1");
// put("A2", "A2"); put("A2", "A2");
// put("A3", "A3"); put("A3", "A3");
// put("F1", "F1"); put("F1", "F1");
// }}; }};
//*/ */
//
// private Map<String, String> getStrengthMap(String batchNo) { private Map<String, String> getStrengthMap(String batchNo) {
//
// Map<String,String> returnMap = stringStringMap.get(batchNo); Map<String,String> returnMap = stringStringMap.get(batchNo);
// if (CollectionUtils.isEmpty(returnMap)) { if (CollectionUtils.isEmpty(returnMap)) {
// stringStringMap = new HashMap<>(); stringStringMap = new HashMap<>();
// returnMap = new HashMap<>(); returnMap = new HashMap<>();
//
//
//
// Date now = new Date(); Date now = new Date();
// String time = sdf.format(now); String time = sdf.format(now);
//
//
// List<FireStrength> strengths = fireStrengthService.queryForStrengthList(time); List<FireStrength> strengths = fireStrengthService.queryForStrengthList(time);
// // List<FireStrength> strengths = iStrengthRepository.queryForStrengthList(time); // List<FireStrength> strengths = iStrengthRepository.queryForStrengthList(time);
//
// if (!CollectionUtils.isEmpty(strengths)) if (!CollectionUtils.isEmpty(strengths))
// { {
// for (FireStrength fireStrength : strengths) for (FireStrength fireStrength : strengths)
// { {
// String name = returnMap.get(fireStrength.getPosition()); String name = returnMap.get(fireStrength.getPosition());
// if (StringUtil.isNotEmpty(name)) if (StringUtil.isNotEmpty(name))
// { {
// returnMap.put(fireStrength.getPosition(), name + "、" + fireStrength.getUsername()); returnMap.put(fireStrength.getPosition(), name + "、" + fireStrength.getUsername());
// }else }else
// { {
// returnMap.put(fireStrength.getPosition(), fireStrength.getUsername()); returnMap.put(fireStrength.getPosition(), fireStrength.getUsername());
// } }
// } }
// } }
// stringStringMap.put(batchNo,returnMap); stringStringMap.put(batchNo,returnMap);
// } }
// return returnMap; return returnMap;
// } }
//
//
// public static void sendcmd(String firstStr, String secondStr, String thirdStr, BubbleTipResult result) { public static void sendcmd(String firstStr, String secondStr, String thirdStr, BubbleTipResult result) {
//
// Constructor<?> constructor; Constructor<?> constructor;
// try { try {
// constructor = Class.forName( constructor = Class.forName(
// PACKAGEURL + result.getClass().getSimpleName() + "Message") PACKAGEURL + result.getClass().getSimpleName() + "Message")
// .getConstructor(ActionResult.class); .getConstructor(ActionResult.class);
// ActionResultMessage<?> action = (ActionResultMessage<?>) constructor.newInstance(result); ActionResultMessage<?> action = (ActionResultMessage<?>) constructor.newInstance(result);
// action.execute(firstStr, secondStr, thirdStr); action.execute(firstStr, secondStr, thirdStr);
// } catch (Exception e) { } catch (Exception e) {
// e.printStackTrace(); e.printStackTrace();
// } }
// } }
//
//
// /** /**
// * @param stepCode 当前步骤编号 * @param stepCode 当前步骤编号
// * @param stepName 当前步骤名称 * @param stepName 当前步骤名称
// * @param state 当前步骤状态 * @param state 当前步骤状态
// * @param nextStepCode 下一步编号 * @param nextStepCode 下一步编号
// * @param nextStepName 下一步名称 * @param nextStepName 下一步名称
// * @param stepType 步骤类型，总览步骤、详细步骤 * @param stepType 步骤类型，总览步骤、详细步骤
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void stepInfo(String stepCode, String stepName, String state, String nextStepCode, String nextStepName, String stepType, Object paramObj) { public void stepInfo(String stepCode, String stepName, String state, String nextStepCode, String nextStepName, String stepType, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
//
//
// BubbleTipResult result = new BubbleTipResult(); BubbleTipResult result = new BubbleTipResult();
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
//
// tempmap1.put("stepCode", stepCode); tempmap1.put("stepCode", stepCode);
// tempmap1.put("stepName", stepName); tempmap1.put("stepName", stepName);
// tempmap1.put("state", state); tempmap1.put("state", state);
// tempmap1.put("nextStepCode", nextStepCode); tempmap1.put("nextStepCode", nextStepCode);
// tempmap1.put("nextStepName", nextStepName); tempmap1.put("nextStepName", nextStepName);
// tempmap1.put("batchNo", contingencyRo.getBatchNo()); tempmap1.put("batchNo", contingencyRo.getBatchNo());
// tempmap1.put("contingencyRo", contingencyRo); tempmap1.put("contingencyRo", contingencyRo);
// result.add(tempmap1); result.add(tempmap1);
//
// this.sendcmd("fromws", "stepArea", stepType, result); this.sendcmd("fromws", "stepArea", stepType, result);
// } }
//
// /** /**
// * @param stepCode 当前步骤编号 * @param stepCode 当前步骤编号
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void saveStepInfo(String stepCode, Object paramObj) { public void saveStepInfo(String stepCode, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// iContingencyInstance.updateStep(stepCode, contingencyRo.getBatchNo()); iContingencyInstance.updateStep(stepCode, contingencyRo.getBatchNo());
// } }
//
//
// /** /**
// * @param content 消息内容 * @param content 消息内容
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void messageRecord(String content, Object paramObj) { public void messageRecord(String content, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
// //转换content中的变量 //转换content中的变量
// content = instedParams(content,contingencyRo); content = instedParams(content,contingencyRo);
//
// BubbleTipResult result = new BubbleTipResult(); BubbleTipResult result = new BubbleTipResult();
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
//
// tempmap1.put("refresh", "refresh"); tempmap1.put("refresh", "refresh");
// tempmap1.put("batchNo", contingencyRo.getBatchNo()); tempmap1.put("batchNo", contingencyRo.getBatchNo());
// result.add(tempmap1); result.add(tempmap1);
// iContingencyInstance.createInstanceRecord(contingencyRo.getBatchNo(), "", "DEFAULT", content, "MESSAGE", ""); iContingencyInstance.createInstanceRecord(contingencyRo.getBatchNo(), "", "DEFAULT", content, "MESSAGE", "");
// this.sendcmd("fromws", "recordArea", "refresh", result); this.sendcmd("fromws", "recordArea", "refresh", result);
// } }
//
// /** /**
// * <pre> * <pre>
// * 智能辅助 * 智能辅助
// * </pre> * </pre>
// * *
// * @param step 当前步骤 * @param step 当前步骤
// * @param icon 图标 * @param icon 图标
// * @param title 标题 * @param title 标题
// * @param image 图片集合 * @param image 图片集合
// * @param table 表格 * @param table 表格
// * @param content 内容 * @param content 内容
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void help(String step, String icon, String title, String image, String table, String content, Object paramObj) { public void help(String step, String icon, String title, String image, String table, String content, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
//
//
// //转换智能辅助中的变量 //转换智能辅助中的变量
// content = instedParams(content,contingencyRo); content = instedParams(content,contingencyRo);
//
// BubbleTipResult result = new BubbleTipResult(); BubbleTipResult result = new BubbleTipResult();
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
//
// tempmap1.put("icon", icon); tempmap1.put("icon", icon);
// tempmap1.put("step", step); tempmap1.put("step", step);
// tempmap1.put("title", title); tempmap1.put("title", title);
// tempmap1.put("content", content); tempmap1.put("content", content);
// tempmap1.put("image", image); tempmap1.put("image", image);
// tempmap1.put("table", table); tempmap1.put("table", table);
// tempmap1.put("batchNo", contingencyRo.getBatchNo()); tempmap1.put("batchNo", contingencyRo.getBatchNo());
// tempmap1.put("contingencyRo", contingencyRo); tempmap1.put("contingencyRo", contingencyRo);
// result.add(tempmap1); result.add(tempmap1);
//
// this.sendcmd("fromws", "helpArea", "", result); this.sendcmd("fromws", "helpArea", "", result);
// } }
//
//
// private String instedParams(String content, ContingencyRo contingencyRo) { private String instedParams(String content, ContingencyRo contingencyRo) {
//
// Map<String, String> strengthMap = this.getStrengthMap(contingencyRo.getBatchNo()); Map<String, String> strengthMap = this.getStrengthMap(contingencyRo.getBatchNo());
// for (String key : strengthMap.keySet()) for (String key : strengthMap.keySet())
// content = content.replaceAll("\\$\\{" + key + "}", strengthMap.get(key)); content = content.replaceAll("\\$\\{" + key + "}", strengthMap.get(key));
//
//
// /* for (String key : positionMap.keySet()) /* for (String key : positionMap.keySet())
// c ontent = content.replaceAll("\\$\\{" + key + "}", positionMap.get(key)); c ontent = content.replaceAll("\\$\\{" + key + "}", positionMap.get(key));
//*/ */
//
// Field[] fields = contingencyRo.getClass().getDeclaredFields(); Field[] fields = contingencyRo.getClass().getDeclaredFields();
// Method getMethod = null; Method getMethod = null;
// try { try {
// for (Field field : fields) { for (Field field : fields) {
// if(field.getName().equals("serialVersionUID")) if(field.getName().equals("serialVersionUID"))
// continue; continue;
// String fileNameInMethod = String.valueOf(field.getName().charAt(0)).toUpperCase() + field.getName().substring(1); String fileNameInMethod = String.valueOf(field.getName().charAt(0)).toUpperCase() + field.getName().substring(1);
// getMethod = contingencyRo.getClass().getMethod("get" + fileNameInMethod); getMethod = contingencyRo.getClass().getMethod("get" + fileNameInMethod);
// String value = String.valueOf(getMethod.invoke(contingencyRo)); String value = String.valueOf(getMethod.invoke(contingencyRo));
// content = content.replaceAll("\\$\\{" + field.getName() + "}", value); content = content.replaceAll("\\$\\{" + field.getName() + "}", value);
// } }
//
// content = content.replaceAll("\\$\\{", ""); content = content.replaceAll("\\$\\{", "");
// content = content.replaceAll("}", ""); content = content.replaceAll("}", "");
// } catch (Exception e) { } catch (Exception e) {
// e.printStackTrace(); e.printStackTrace();
// } }
// return content; return content;
// } }
//
//
// /** /**
// * 交互动作 * 交互动作
// * *
// * @param actionName 动作名称 * @param actionName 动作名称
// * @param icon 图标 * @param icon 图标
// * @param tips 提示信息 * @param tips 提示信息
// * @param buttonJson 按钮json字符串 * @param buttonJson 按钮json字符串
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void operation(String actionName, String icon, String tips, String buttonJson, Object paramObj) { public void operation(String actionName, String icon, String tips, String buttonJson, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
//
// //转换content中的变量 //转换content中的变量
// tips = instedParams(tips,contingencyRo); tips = instedParams(tips,contingencyRo);
//
//
// BubbleTipResult result = new BubbleTipResult(); BubbleTipResult result = new BubbleTipResult();
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
//
//
// String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson); String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
//
//
// tempmap1.put("actionName", actionName); tempmap1.put("actionName", actionName);
// tempmap1.put("icon", icon); tempmap1.put("icon", icon);
// tempmap1.put("tips", tips); tempmap1.put("tips", tips);
// tempmap1.put("buttonJson", buttonJson); tempmap1.put("buttonJson", buttonJson);
// tempmap1.put("batchNo", contingencyRo.getBatchNo()); tempmap1.put("batchNo", contingencyRo.getBatchNo());
// tempmap1.put("contingencyRo", contingencyRo); tempmap1.put("contingencyRo", contingencyRo);
// tempmap1.put("contingencyPlanId", contingencyPlanId); tempmap1.put("contingencyPlanId", contingencyPlanId);
// result.add(tempmap1); result.add(tempmap1);
//
//
// this.sendcmd("fromws", "optionArea", "", result); this.sendcmd("fromws", "optionArea", "", result);
//
//
// sendButton(contingencyRo.getBatchNo(),contingencyPlanId,contingencyRo.getEquipmentId(),actionName,buttonJson); sendButton(contingencyRo.getBatchNo(),contingencyPlanId,contingencyRo.getEquipmentId(),actionName,buttonJson);
//
// } }
//
//
// private boolean sendButton(String batchNo,String contingencyPlanId,String equipmentId,String actionName,String buttonJson) { private boolean sendButton(String batchNo,String contingencyPlanId,String equipmentId,String actionName,String buttonJson) {
//
// // String url = bussunisDomain+ "/api/risksource/contingency/setup"; // String url = bussunisDomain+ "/api/risksource/contingency/setup";
//
// ObjectMapper objectMapper = new ObjectMapper(); ObjectMapper objectMapper = new ObjectMapper();
// //Map<String,Object> map = new HashMap<>(); //Map<String,Object> map = new HashMap<>();
//
// /** /**
// * batchNo * batchNo
// * stepCode * stepCode
// * buttonCode * buttonCode
// * confirm * confirm
// * contingencyPlanId * contingencyPlanId
// * stepState * stepState
// */ */
//
// try { try {
// Map button = objectMapper.readValue(buttonJson,Map.class); Map button = objectMapper.readValue(buttonJson,Map.class);
// Map operateInstance = (Map)((List)button.get("operate")).get(0); Map operateInstance = (Map)((List)button.get("operate")).get(0);
//// map.put("batchNo",batchNo); // map.put("batchNo",batchNo);
//// map.put("actionName",actionName); // map.put("actionName",actionName);
//// map.put("equipmentId",equipmentId); // map.put("equipmentId",equipmentId);
//// map.put("stepCode",button.get("stepCode")); // map.put("stepCode",button.get("stepCode"));
//// map.put("buttonCode",operateInstance.get("code")); // map.put("buttonCode",operateInstance.get("code"));
//// map.put("confirm","CONFIRM"); // map.put("confirm","CONFIRM");
//// map.put("stepState",operateInstance.get("stepState")); // map.put("stepState",operateInstance.get("stepState"));
//// map.put("contingencyPlanId",contingencyPlanId); // map.put("contingencyPlanId",contingencyPlanId);
// ContingencyDeviceStatus contingencyDeviceStatus = new ContingencyDeviceStatus(); ContingencyDeviceStatus contingencyDeviceStatus = new ContingencyDeviceStatus();
// contingencyDeviceStatus.setActionName(actionName); contingencyDeviceStatus.setActionName(actionName);
// contingencyDeviceStatus.setButtonCode(String.valueOf(operateInstance.get("code"))); contingencyDeviceStatus.setButtonCode(String.valueOf(operateInstance.get("code")));
// contingencyDeviceStatus.setConfirm("CONFIRM"); contingencyDeviceStatus.setConfirm("CONFIRM");
// contingencyDeviceStatus.setContingencyPlanId(contingencyPlanId); contingencyDeviceStatus.setContingencyPlanId(contingencyPlanId);
// contingencyDeviceStatus.setEquipmentId(equipmentId); contingencyDeviceStatus.setEquipmentId(equipmentId);
// contingencyDeviceStatus.setStepCode(String.valueOf(button.get("stepCode"))); contingencyDeviceStatus.setStepCode(String.valueOf(button.get("stepCode")));
// contingencyDeviceStatus.setStepState(String.valueOf(operateInstance.get("stepState"))); contingencyDeviceStatus.setStepState(String.valueOf(operateInstance.get("stepState")));
// riskSourceService.queryContingencyDeviceStatus(contingencyDeviceStatus); riskSourceService.queryContingencyDeviceStatus(contingencyDeviceStatus);
// //HttpEntity<Map> entity = new HttpEntity<>(map); //HttpEntity<Map> entity = new HttpEntity<>(map);
// // restTemplate.exchange(url, HttpMethod.POST,entity,Map.class); // restTemplate.exchange(url, HttpMethod.POST,entity,Map.class);
//
// } catch (IOException e) { } catch (IOException e) {
// e.printStackTrace(); e.printStackTrace();
// } }
//
// return false; return false;
// } }
//
//
// /** /**
// * 保存交互动作 * 保存交互动作
// * *
// * @param actionName 动作名称 * @param actionName 动作名称
// * @param icon 图标 * @param icon 图标
// * @param tips 提示信息 * @param tips 提示信息
// * @param buttonJson 按钮json字符串 * @param buttonJson 按钮json字符串
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void saveOperation(String actionName, String icon, String tips, String buttonJson, Object paramObj) { public void saveOperation(String actionName, String icon, String tips, String buttonJson, Object paramObj) {
//
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
//
// //转换content中的变量 //转换content中的变量
// tips = instedParams(tips,contingencyRo); tips = instedParams(tips,contingencyRo);
//
// BubbleTipResult result1 = new BubbleTipResult(); BubbleTipResult result1 = new BubbleTipResult();
// Map<String, Object> tempmap2 = new HashMap<>(); Map<String, Object> tempmap2 = new HashMap<>();
// tempmap2.put("refresh", "refresh"); tempmap2.put("refresh", "refresh");
// tempmap2.put("batchNo", contingencyRo.getBatchNo()); tempmap2.put("batchNo", contingencyRo.getBatchNo());
// result1.add(tempmap2); result1.add(tempmap2);
//
// String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson); String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
//
// this.sendcmd("fromws", "recordArea", "refresh", result1); this.sendcmd("fromws", "recordArea", "refresh", result1);
//
// } }
//
// private String getContingencyPlanId(String batchNo, String actionName, String icon, String tips, String buttonJson) { private String getContingencyPlanId(String batchNo, String actionName, String icon, String tips, String buttonJson) {
// String cacheKey = batchNo + actionName; String cacheKey = batchNo + actionName;
// String contingencyPlanId = null; String contingencyPlanId = null;
// ContingencyPlanInstance contingencyPlanInstance = null; ContingencyPlanInstance contingencyPlanInstance = null;
// if (OPERATE_RECORD_ID.get(cacheKey) == null) { if (OPERATE_RECORD_ID.get(cacheKey) == null) {
// contingencyPlanInstance = iContingencyInstance.createInstanceRecord(batchNo, actionName, "DEFAULT", buttonJson, "OPERATE", icon); contingencyPlanInstance = iContingencyInstance.createInstanceRecord(batchNo, actionName, "DEFAULT", buttonJson, "OPERATE", icon);
// contingencyPlanId = contingencyPlanInstance.getId(); contingencyPlanId = contingencyPlanInstance.getId();
// OPERATE_RECORD_ID.put(cacheKey, contingencyPlanId); OPERATE_RECORD_ID.put(cacheKey, contingencyPlanId);
// } else { } else {
// contingencyPlanId = OPERATE_RECORD_ID.get(cacheKey); contingencyPlanId = OPERATE_RECORD_ID.get(cacheKey);
// OPERATE_RECORD_ID.remove(cacheKey); OPERATE_RECORD_ID.remove(cacheKey);
// } }
// return contingencyPlanId; return contingencyPlanId;
// } }
//
//
// /** /**
// * 地图动作推送 * 地图动作推送
// * *
// * @param actionName 动作名称标识 * @param actionName 动作名称标识
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void mapAction(String actionName, Object paramObj) { public void mapAction(String actionName, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
//
//
// BubbleTipResult result = new BubbleTipResult(); BubbleTipResult result = new BubbleTipResult();
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
//
// tempmap1.put("actionName", actionName); tempmap1.put("actionName", actionName);
// tempmap1.put("batchNo", contingencyRo.getBatchNo()); tempmap1.put("batchNo", contingencyRo.getBatchNo());
// tempmap1.put("contingencyRo", contingencyRo); tempmap1.put("contingencyRo", contingencyRo);
// result.add(tempmap1); result.add(tempmap1);
//
// this.sendcmd("fromws", "mapArea", actionName, result); this.sendcmd("fromws", "mapArea", actionName, result);
// } }
//
//
// /** /**
// * 顶部消息提示 * 顶部消息提示
// * *
// * @param content 消息内容 * @param content 消息内容
// * @param messageType 消息类型 messageType 黑色框消息类型CONTINGENCY,，滚动消息：CURRENTMESSAGE * @param messageType 消息类型 messageType 黑色框消息类型CONTINGENCY,，滚动消息：CURRENTMESSAGE
// * @param paramObj 预案对象 * @param paramObj 预案对象
// */ */
// public void topMessage(String content, String messageType, Object paramObj) { public void topMessage(String content, String messageType, Object paramObj) {
// ContingencyRo contingencyRo = (ContingencyRo) paramObj; ContingencyRo contingencyRo = (ContingencyRo) paramObj;
// stopSnapshop(contingencyRo); stopSnapshop(contingencyRo);
//
//
// BubbleTipResult result = new BubbleTipResult(); BubbleTipResult result = new BubbleTipResult();
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
// //转换content中的变量 //转换content中的变量
// content = instedParams(content,contingencyRo); content = instedParams(content,contingencyRo);
//
// tempmap1.put("content", content); tempmap1.put("content", content);
// tempmap1.put("messageType", messageType);//消息类型 messageType 黑色框消息类型 CONTINGENCY,，滚动消息：CURRENTMESSAGE tempmap1.put("messageType", messageType);//消息类型 messageType 黑色框消息类型 CONTINGENCY,，滚动消息：CURRENTMESSAGE
// tempmap1.put("batchNo", contingencyRo.getBatchNo()); tempmap1.put("batchNo", contingencyRo.getBatchNo());
// tempmap1.put("contingencyRo", contingencyRo); tempmap1.put("contingencyRo", contingencyRo);
// result.add(tempmap1); result.add(tempmap1);
//
// this.sendcmd("fromws", "topArea", messageType, result); this.sendcmd("fromws", "topArea", messageType, result);
// } }
//
//
// private void stopSnapshop(ContingencyRo contingencyRo) { private void stopSnapshop(ContingencyRo contingencyRo) {
// if (RuleRunigSnapshotServiceImpl.getReplayBatchNo() != null && !RuleRunigSnapshotServiceImpl.getReplayBatchNo().equals(contingencyRo.getBatchNo())) if (RuleRunigSnapshotServiceImpl.getReplayBatchNo() != null && !RuleRunigSnapshotServiceImpl.getReplayBatchNo().equals(contingencyRo.getBatchNo()))
// RuleRunigSnapshotServiceImpl.setReplayBatchNoToNull(); RuleRunigSnapshotServiceImpl.setReplayBatchNoToNull();
// } }
//
//} }
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/action/SimpleTipAction.java
View file @ 6d13cee1
...@@ -14,10 +14,11 @@ import com.yeejoin.amos.fas.business.action.result.ActionResult; ...@@ -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.TipResult;
import com.yeejoin.amos.fas.business.action.result.message.ActionResultMessage; 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.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.business.service.model.ToipResponse;
import com.yeejoin.amos.fas.dao.entity.BusinessEntity; import com.yeejoin.amos.fas.dao.entity.BusinessEntity;
import com.yeejoin.amos.fas.dao.entity.Message; import com.yeejoin.amos.fas.dao.entity.Message;
import com.yeejoin.amos.fas.dao.entity.MessageRo;
/** /**
* *
* <pre> * <pre>
...@@ -30,71 +31,73 @@ import com.yeejoin.amos.fas.dao.entity.Message; ...@@ -30,71 +31,73 @@ import com.yeejoin.amos.fas.dao.entity.Message;
@Component @Component
public class SimpleTipAction implements CustomerAction public class SimpleTipAction implements CustomerAction
{ {
private static String PACKAGEURL = "com.yeejoin.amos.rule.map.action.result.message."; private static String PACKAGEURL = "com.yeejoin.amos.fas.business.action.result.message.";
// @Autowired
// private IMessageService messageService; @Autowired
private IMessageService messageService;
//@ExposeAction("消息提示") //@ExposeAction("消息提示")
// public void sendMessageTip(Object bizobj, String title, String content,String type) public void sendMessageTip(Object bizobj, String title, String content,String type)
// { {
//
// try try
// { {
//
// ELEvaluationContext.setVariable("bizobj",bizobj); ELEvaluationContext.setVariable("bizobj",bizobj);
// TipResult result = new TipResult(); TipResult result = new TipResult();
// result.add(bizobj); result.add(bizobj);
// Map<String, Object> tempmap1 = new HashMap<>(); Map<String, Object> tempmap1 = new HashMap<>();
// tempmap1.put("title", title); tempmap1.put("title", title);
// result.add(tempmap1); result.add(tempmap1);
// Map<String, Object> tempmap2 = new HashMap<>(); Map<String, Object> tempmap2 = new HashMap<>();
// content =DataItemUtil.getNative(content); content =DataItemUtil.getNative(content);
// tempmap2.put("content", content); tempmap2.put("content", content);
// result.add(tempmap2); result.add(tempmap2);
//
//
// Constructor<?> constructor; Constructor<?> constructor;
//
// constructor = Class.forName( constructor = Class.forName(
// PACKAGEURL + result.getClass().getSimpleName() + "Message") PACKAGEURL + result.getClass().getSimpleName() + "Message")
// .getConstructor(ActionResult.class); .getConstructor(ActionResult.class);
// ActionResultMessage<?> action = (ActionResultMessage<?>) constructor.newInstance(result); ActionResultMessage<?> action = (ActionResultMessage<?>) constructor.newInstance(result);
// String firstStr = "fromws"; String firstStr = "fromws";
// String secondStr = "global"; String secondStr = "global";
// String thirdStr = "msg"; String thirdStr = "msg";
// result.setBizObj((BusinessEntity)bizobj); result.setBizObj((BusinessEntity)bizobj);
// Object obj = action.execute(firstStr, secondStr, thirdStr); Object obj = action.execute(firstStr, secondStr, thirdStr);
// result.setToipResponse((ToipResponse) obj); result.setToipResponse((ToipResponse) obj);
// saveMessageAction(result,type); saveMessageAction(result,type);
// } }
// catch (Exception e) catch (Exception e)
// { {
// // TODO Auto-generated catch block // TODO Auto-generated catch block
// e.printStackTrace(); e.printStackTrace();
// } }
// } }
// @SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
// private void saveMessageAction(AbstractActionResult abstractActionResult,String type) private void saveMessageAction(AbstractActionResult abstractActionResult,String type)
// { {
// Message message = new Message(); Message message = new Message();
// List<Map<String, Object>> list = (List<Map<String, Object>>) abstractActionResult.getData(); List<Map<String, Object>> list = (List<Map<String, Object>>) abstractActionResult.getData();
// for(Map<String, Object> map : list) { for(Map<String, Object> map : list) {
// for(String str: map.keySet()) { for(String str: map.keySet()) {
// if(str.equals("content")) { if(str.equals("content")) {
// message.setContent(map.get("content").toString()); message.setContent(map.get("content").toString());
// }else }else
// if (str.equals("title")) if (str.equals("title"))
// { {
// message.setTitle(map.get("title").toString()); message.setTitle(map.get("title").toString());
// } }
// } }
// BasicsRo basicsRo = (BasicsRo)abstractActionResult.getToipResponse().getBizObj(); MessageRo messageRo = (MessageRo)abstractActionResult.getToipResponse().getBizObj();
// message.setTime(basicsRo.getDateTime()); message.setTime(messageRo.getCreateDate());
// message.setBizId(basicsRo.getId()); //目前获取不到id
// message.setBizclassName(abstractActionResult.getToipResponse().getBizObj().getClass().toString()); message.setBizId(messageRo.getId());
// message.setType(type); message.setBizclassName(abstractActionResult.getToipResponse().getBizObj().getClass().toString());
// messageService.save(message); message.setType(type);
// } messageService.save(message);
// } }
}
} }
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/controller/TimeLineController.java
View file @ 6d13cee1
//package com.yeejoin.amos.fas.business.controller; package com.yeejoin.amos.fas.business.controller;
//
//
//import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance; import com.yeejoin.amos.fas.business.service.impl.ContingencyInstanceImpl;
//import com.yeejoin.amos.fas.business.service.intfc.IContingencyOriginalDataService; import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance;
//import com.yeejoin.amos.fas.core.common.request.CommonPageable; import com.yeejoin.amos.fas.business.service.intfc.IContingencyOriginalDataService;
//import com.yeejoin.amos.fas.core.common.request.CommonRequest; import com.yeejoin.amos.fas.core.common.request.CommonPageable;
//import com.yeejoin.amos.fas.core.util.CommonResponse; import com.yeejoin.amos.fas.core.common.request.CommonRequest;
//import com.yeejoin.amos.fas.core.util.CommonResponseUtil; import com.yeejoin.amos.fas.core.util.CommonResponse;
//import io.swagger.annotations.Api; import com.yeejoin.amos.fas.core.util.CommonResponseUtil;
//import io.swagger.annotations.ApiOperation;
//import io.swagger.annotations.ApiParam; import io.swagger.annotations.Api;
//import org.slf4j.Logger; import io.swagger.annotations.ApiOperation;
//import org.slf4j.LoggerFactory; import io.swagger.annotations.ApiParam;
//import org.springframework.beans.factory.annotation.Autowired; import org.slf4j.Logger;
//import org.springframework.scheduling.annotation.Scheduled; import org.slf4j.LoggerFactory;
//import org.springframework.util.CollectionUtils; import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.*; import org.springframework.scheduling.annotation.Scheduled;
// import org.springframework.util.CollectionUtils;
//import java.util.HashMap; import org.springframework.web.bind.annotation.*;
//import java.util.LinkedList;
//import java.util.List; import javax.xml.bind.ValidationEvent;
//import java.util.Map; import java.util.*;
//
//@RestController @RestController
//@RequestMapping(value = "/api/timeline") @RequestMapping(value = "/api/timeline")
//@Api(tags="时间轴") @Api(tags="时间轴")
//public class TimeLineController extends BaseController{ public class TimeLineController extends BaseController{
//
// private static final Logger log = LoggerFactory.getLogger(TimeLineController.class); private static final Logger log = LoggerFactory.getLogger(TimeLineController.class);
// @Autowired
// @Autowired IContingencyInstance iContingencyInstance;
// IContingencyOriginalDataService iContingencyOriginalDataService;
// @Autowired
// static LinkedList<Map<String,String >> fireQueue = new LinkedList<>(); IContingencyOriginalDataService iContingencyOriginalDataService;
//
// static LinkedList<Map<String,String >> fireQueue = new LinkedList<>();
// //@Authorization(ingore = true)
// @ApiOperation(httpMethod = "GET",value = "根据批次号查询时间轴", notes = "根据批次号查询时间轴")
// @RequestMapping(value = "/{instanceNo}", produces = "application/json;charset=UTF-8", method = RequestMethod.GET) //@Authorization(ingore = true)
// public CommonResponse queryPoint(@PathVariable String instanceNo,@RequestParam("recordType") String recordType) throws Exception{ @ApiOperation(httpMethod = "GET",value = "根据批次号查询时间轴", notes = "根据批次号查询时间轴")
// return CommonResponseUtil.success(); @RequestMapping(value = "/{instanceNo}", produces = "application/json;charset=UTF-8", method = RequestMethod.GET)
//// return CommonResponseUtil.success(iContingencyInstance.queryForTimeLine(instanceNo,recordType)); public CommonResponse queryPoint(@PathVariable String instanceNo,@RequestParam("recordType") String recordType) throws Exception{
// }
// return CommonResponseUtil.success(iContingencyInstance.queryForTimeLine(instanceNo,recordType));
// }
// //@Authorization(ingore = true)
// @ApiOperation(httpMethod = "PUT",value = "点击按钮", notes = "点击按钮")
// @RequestMapping(value = "/fire", produces = "application/json;charset=UTF-8", method = RequestMethod.PUT) //@Authorization(ingore = true)
// public CommonResponse fire(@RequestParam("batchNo") String batchNo, @ApiOperation(httpMethod = "PUT",value = "点击按钮", notes = "点击按钮")
// @RequestParam("stepCode") String stepCode, @RequestMapping(value = "/fire", produces = "application/json;charset=UTF-8", method = RequestMethod.PUT)
// @RequestParam("buttonCode") String buttonCode, public CommonResponse fire(@RequestParam("batchNo") String batchNo,
// @RequestParam("confirm") String confirm, @RequestParam("stepCode") String stepCode,
// @RequestParam("contingencyPlanId") String contingencyPlanId, @RequestParam("buttonCode") String buttonCode,
// @RequestParam("stepState") String stepState) throws Exception{ @RequestParam("confirm") String confirm,
// @RequestParam("contingencyPlanId") String contingencyPlanId,
// @RequestParam("stepState") String stepState) throws Exception{
// Map<String,String> map = new HashMap<>();
// map.put("batchNo",batchNo);
// map.put("stepCode",stepCode); Map<String,String> map = new HashMap<>();
// map.put("buttonCode",buttonCode); map.put("batchNo",batchNo);
// map.put("confirm",confirm); map.put("stepCode",stepCode);
// map.put("contingencyPlanId",contingencyPlanId); map.put("buttonCode",buttonCode);
// map.put("stepState",stepState); map.put("confirm",confirm);
// fireQueue.addLast(map); map.put("contingencyPlanId",contingencyPlanId);
// map.put("stepState",stepState);
// return CommonResponseUtil.success("SUCCESS"); fireQueue.addLast(map);
// }
// return CommonResponseUtil.success("SUCCESS");
// }
// @Scheduled(cron = "*/2 * * * * ?")
// private void runFireQueue() throws Exception
// { @Scheduled(cron = "*/2 * * * * ?")
// private void runFireQueue() throws Exception
// if(fireQueue.size() == 0) {
// return;
// if(fireQueue.size() == 0)
// Map<String,String> map = fireQueue.getFirst(); return;
//
// String batchNo = map.get("batchNo"); Map<String,String> map = fireQueue.getFirst();
// String stepCode = map.get("stepCode");
// String buttonCode = map.get("buttonCode"); String batchNo = map.get("batchNo");
// String confirm = map.get("confirm"); String stepCode = map.get("stepCode");
// String contingencyPlanId = map.get("contingencyPlanId"); String buttonCode = map.get("buttonCode");
// String stepState = map.get("stepState"); String confirm = map.get("confirm");
// try String contingencyPlanId = map.get("contingencyPlanId");
// { String stepState = map.get("stepState");
// log.info("fireQueue-size:"+fireQueue.size()); try
// log.info("stepCode:" + map.get("stepCode")); {
// log.info("buttonCode:" + map.get("buttonCode")); log.info("fireQueue-size:"+fireQueue.size());
// log.info("confirm:" + map.get("confirm")); log.info("stepCode:" + map.get("stepCode"));
// log.info("stepState:" + map.get("stepState")); log.info("buttonCode:" + map.get("buttonCode"));
// log.info("confirm:" + map.get("confirm"));
//// iContingencyInstance.setButtonExecuted(batchNo,contingencyPlanId,buttonCode,confirm); log.info("stepState:" + map.get("stepState"));
//// iContingencyInstance.fire(batchNo,stepCode,contingencyPlanId,buttonCode,confirm,stepState);
// }catch (Exception e) iContingencyInstance.setButtonExecuted(batchNo,contingencyPlanId,buttonCode,confirm);
// { iContingencyInstance.fire(batchNo,stepCode,contingencyPlanId,buttonCode,confirm,stepState);
// //iContingencyInstance.setButtonWait(batchNo,contingencyPlanId,confirm); }catch (Exception e)
// throw e; {
// }finally { //iContingencyInstance.setButtonWait(batchNo,contingencyPlanId,confirm);
// fireQueue.removeFirst(); throw e;
// } }finally {
// } fireQueue.removeFirst();
// }
// }
//
//
//
//
//
//
//
// // @Authorization(ingore = true)
// @ApiOperation(httpMethod = "POST",value = "查询预案记录", notes = "查询预案记录")
// @RequestMapping(value = "/contingency/page", produces = "application/json;charset=UTF-8", method = RequestMethod.POST) // @Authorization(ingore = true)
// public CommonResponse contingencyRecord( @ApiOperation(httpMethod = "POST",value = "查询预案记录", notes = "查询预案记录")
// @ApiParam(value = "查询条件", required = false) @RequestBody(required = false) List<CommonRequest> queryRequests, @RequestMapping(value = "/contingency/page", produces = "application/json;charset=UTF-8", method = RequestMethod.POST)
// @ApiParam(value = "分页参数", required = true) CommonPageable commonPageable public CommonResponse contingencyRecord(
// ) { @ApiParam(value = "查询条件", required = false) @RequestBody(required = false) List<CommonRequest> queryRequests,
// //CommonPageable commonPageable = new CommonPageable(pageNumber,pageSize); @ApiParam(value = "分页参数", required = true) CommonPageable commonPageable
// ) {
// String contingencyName = null; //CommonPageable commonPageable = new CommonPageable(pageNumber,pageSize);
// String equipmentId = null;
// String createTime = null; String contingencyName = null;
// if(!CollectionUtils.isEmpty(queryRequests)) String equipmentId = null;
// { String createTime = null;
// for(CommonRequest request:queryRequests) if(!CollectionUtils.isEmpty(queryRequests))
// { {
// if("contingencyName".equals(request.getName())) for(CommonRequest request:queryRequests)
// { {
// contingencyName = String.valueOf(request.getValue()); if("contingencyName".equals(request.getName()))
// } {
// if("equipmentId".equals(request.getName())) contingencyName = String.valueOf(request.getValue());
// { }
// equipmentId = String.valueOf(request.getValue()); if("equipmentId".equals(request.getName()))
// } {
// if("createTime".equals(request.getName())) equipmentId = String.valueOf(request.getValue());
// { }
// createTime = String.valueOf(request.getValue()); if("createTime".equals(request.getName()))
// } {
// } createTime = String.valueOf(request.getValue());
// } }
// }
// return CommonResponseUtil.success(iContingencyOriginalDataService.queryForPage(contingencyName,equipmentId,createTime,commonPageable)); }
// }
// return CommonResponseUtil.success(iContingencyOriginalDataService.queryForPage(contingencyName,equipmentId,createTime,commonPageable));
// }
//
//
//
//
//
//
//
//
//
// String operate = "{" +
// " \"type\": \"button\"," +
// " \"operate\": [" + String operate = "{" +
// " {" + " \"type\": \"button\"," +
// " \"title\": \"确认着火\"," + " \"operate\": [" +
// " \"paramName\": \"batchNo\"," + " {" +
// " \"paramValue\": \"11\"," + " \"title\": \"确认着火\"," +
// " \"requestUrl\": \"url\"," + " \"paramName\": \"batchNo\"," +
// " \"icon\": \"querenzhuohuo\"," + " \"paramValue\": \"11\"," +
// " \"confirm\": true," + " \"requestUrl\": \"url\"," +
// " \"state\": \"executed\"" + " \"icon\": \"querenzhuohuo\"," +
// " }," + " \"confirm\": true," +
// " {" + " \"state\": \"executed\"" +
// " \"title\": \"消除误报\"," + " }," +
// " \"paramName\": \"batchNo\"," + " {" +
// " \"paramValue\": \"11\"," + " \"title\": \"消除误报\"," +
// " \"requestUrl\": \"url\"," + " \"paramName\": \"batchNo\"," +
// " \"icon\": \"xiaochuwubao\"," + " \"paramValue\": \"11\"," +
// " \"confirm\": true," + " \"requestUrl\": \"url\"," +
// " \"state\": \"wait\"" + " \"icon\": \"xiaochuwubao\"," +
// " }" + " \"confirm\": true," +
// " ]" + " \"state\": \"wait\"" +
// "}"; " }" +
// " ]" +
//} "}";
}
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/repository/IContingencyOriginalDataDao.java
View file @ 6d13cee1
...@@ -25,6 +25,12 @@ public interface IContingencyOriginalDataDao extends BaseDao<ContingencyOrigina ...@@ -25,6 +25,12 @@ public interface IContingencyOriginalDataDao extends BaseDao<ContingencyOrigina
@Modifying(clearAutomatically = true) @Modifying(clearAutomatically = true)
@Query(value = "update contingency_original_data c set c.confirm = ?1,c.runstep=?2 ,c.step_state=?3 where c.batch_No = ?4",nativeQuery = true) @Query(value = "update contingency_original_data c set c.confirm = ?1,c.runstep=?2 ,c.step_state=?3 where c.batch_No = ?4",nativeQuery = true)
int updateByButton(String confirm,Boolean runstep,String stepState,String batchNo); int updateByButton(String confirm,Boolean runstep,String stepState,String batchNo);
@Transactional
@Modifying(clearAutomatically = true)
@Query(value = "update contingency_original_data c set c.step = ?1 where c.batch_No = ?2",nativeQuery = true)
int updateByButtonStep(String step,String batchNo);
} }
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/repository/IMessageDao.java 0 → 100644
View file @ 6d13cee1
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
View file @ 6d13cee1
//<<<<<<< HEAD package com.yeejoin.amos.fas.business.service.impl;
////package com.yeejoin.amos.fas.business.service.impl;
//// import java.util.HashMap;
//// import java.util.List;
////import com.yeejoin.amos.fas.business.action.ContingencyAction; import java.util.Map;
////import com.yeejoin.amos.fas.business.action.result.BubbleTipResult; import java.util.Optional;
////import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper;
////import com.yeejoin.amos.fas.business.dao.repository.IContingencyOriginalDataDao; import org.apache.commons.lang3.ArrayUtils;
////import com.yeejoin.amos.fas.business.dao.repository.IContingencyPlanInstanceRepository; import org.codehaus.jackson.map.ObjectMapper;
////import com.yeejoin.amos.fas.business.feign.RemoteRuleServer; import org.slf4j.Logger;
////import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance; import org.slf4j.LoggerFactory;
////import com.yeejoin.amos.fas.business.service.model.ContingencyRo; import org.springframework.beans.BeanUtils;
////import com.yeejoin.amos.fas.business.service.model.Operate; import org.springframework.beans.factory.annotation.Autowired;
////import com.yeejoin.amos.fas.business.service.model.OperateGroup; import org.springframework.beans.factory.annotation.Value;
////import com.yeejoin.amos.fas.dao.entity.ContingencyOriginalData; import org.springframework.data.redis.core.RedisTemplate;
////import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance; import org.springframework.stereotype.Service;
////import com.yeejoin.amos.fas.dao.entity.Equipment; import org.springframework.util.CollectionUtils;
//// import org.springframework.web.client.RestTemplate;
////import org.codehaus.jackson.map.ObjectMapper;
////import org.slf4j.Logger; import com.yeejoin.amos.component.rule.RuleTrigger;
////import org.slf4j.LoggerFactory; import com.yeejoin.amos.fas.business.action.ContingencyAction;
////import org.springframework.beans.BeanUtils; import com.yeejoin.amos.fas.business.action.result.BubbleTipResult;
////import org.springframework.beans.factory.annotation.Autowired; import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper;
////import org.springframework.beans.factory.annotation.Value; import com.yeejoin.amos.fas.business.dao.repository.IContingencyOriginalDataDao;
////import org.springframework.data.redis.core.RedisTemplate; import com.yeejoin.amos.fas.business.dao.repository.IContingencyPlanInstanceRepository;
////import org.springframework.http.HttpEntity; import com.yeejoin.amos.fas.business.feign.RemoteRuleServer;
////import org.springframework.http.HttpMethod; import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance;
////import org.springframework.scheduling.annotation.Async; import com.yeejoin.amos.fas.business.service.model.ContingencyRo;
////import org.springframework.stereotype.Service; import com.yeejoin.amos.fas.business.service.model.Operate;
////import org.springframework.util.CollectionUtils; import com.yeejoin.amos.fas.business.service.model.OperateGroup;
////import org.springframework.web.client.RestTemplate; import com.yeejoin.amos.fas.dao.entity.ContingencyOriginalData;
////import org.typroject.tyboot.component.cache.Redis; import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
//// import com.yeejoin.amos.fas.dao.entity.Equipment;
////import java.util.HashMap;
////import java.util.List; @Service
////import java.util.Map; public class ContingencyInstanceImpl /*extends GenericManagerImpl<ContingencyPlanInstance, String>*/ implements IContingencyInstance {
////import java.util.Optional;
//// private static final Logger log = LoggerFactory.getLogger(ContingencyInstanceImpl.class);
////@Service
////public class ContingencyInstanceImpl { @Autowired
//// private IContingencyPlanInstanceRepository repository;
//// private static final Logger log = LoggerFactory.getLogger(ContingencyInstanceImpl.class);
////// @Autowired
////// @Autowired IContingencyOriginalDataDao iContingencyOriginalDataDao;
////// private IContingencyPlanInstanceRepository repository;
////// @Autowired
////// private RemoteRuleServer remoteRuleServer;
////// @Autowired
////// IContingencyOriginalDataDao iContingencyOriginalDataDao; @Autowired
////// private RestTemplate restTemplate;
//////
////// @Autowired @Autowired
////// private RemoteRuleServer remoteRuleServer; private ImpAndFireEquipMapper impAndFireEquipMapper;
//////
////// @Autowired @Autowired
////// private RestTemplate restTemplate; private RedisTemplate redisTemplate;
//////
////// @Autowired
////// private ImpAndFireEquipMapper impAndFireEquipMapper; @Value("${params.remoteRuleUrl}")
////// private String remoteRuleUrl;
////// @Autowired
////// private RedisTemplate redisTemplate;
////// private static Map<String, String> stepMap = new HashMap<>();
//////
////// @Value("${params.remoteRuleUrl}") @Autowired
////// private String remoteRuleUrl; private RuleTrigger ruleTrigger;
//////
////// /* public ContingencyInstanceImpl(IContingencyPlanInstanceRepository repository) {
////// private static Map<String, String> stepMap = new HashMap<>(); super(repository);
////// this.repository = repository;
////// @Autowired }*/
////// private RuleTrigger ruleTrigger;
//////
////// /* public ContingencyInstanceImpl(IContingencyPlanInstanceRepository repository) { /**
////// super(repository); * 创建预案执行记录
////// this.repository = repository; *
////// }*/ * @param category 一级分类
////// * @param subCategory 二级分类
////// * @param content 信息内容
////// /** * @param recordType 信息分类
////// * 创建预案执行记录 * @param icon 信息显示图标
////// * */
////// * @param category 一级分类 public ContingencyPlanInstance createInstanceRecord(String instanceNo, String category, String subCategory, String content, String recordType, String icon) {
////// * @param subCategory 二级分类 ContingencyPlanInstance planInstance = new ContingencyPlanInstance();
////// * @param content 信息内容
////// * @param recordType 信息分类 planInstance.setContent(content);
////// * @param icon 信息显示图标 planInstance.setIcon(icon);
////// */ planInstance.setRecordType(recordType);
////// public ContingencyPlanInstance createInstanceRecord(String instanceNo, String category, String subCategory, String content, String recordType, String icon) { planInstance.setCategory(category);
////// ContingencyPlanInstance planInstance = new ContingencyPlanInstance(); planInstance.setBatchNo(instanceNo);
//////
////// planInstance.setContent(content); //计算序号
////// planInstance.setIcon(icon); int count = repository.countByBatchNo(instanceNo);
////// planInstance.setRecordType(recordType); planInstance.setSort(++count);
////// planInstance.setCategory(category); return this.repository.save(planInstance);
////// planInstance.setBatchNo(instanceNo); }
//////
////// //计算序号
////// int count = repository.countByBatchNo(instanceNo); /**
////// planInstance.setSort(++count); * 查询时间轴
////// return this.repository.save(planInstance); *
////// } * @param instanceNo
////// * @return
////// * @throws Exception
////// /** */
////// * 查询时间轴 public List<ContingencyPlanInstance> queryForTimeLine(String instanceNo, String recordType) throws Exception {
////// * List<ContingencyPlanInstance> categorys = repository.queryForCategory(instanceNo, recordType);
////// * @param instanceNo return categorys;
////// * @return }
////// * @throws Exception
////// */
////// public List<ContingencyPlanInstance> queryForTimeLine(String instanceNo, String recordType) throws Exception { public void fire(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton) throws Exception {
////// List<ContingencyPlanInstance> categorys = repository.queryForCategory(instanceNo, recordType); //火灾误报
////// return categorys;
////// } ContingencyOriginalData contingencyOriginalData = iContingencyOriginalDataDao.findByBatchNo(batchNo);
////// if("FIRE_CANCEL".equals(buttonCode) || "END_EMERGENCY".equals(buttonCode)){
////// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
////// public void fire(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton) throws Exception { }else{
////// //火灾误报 redisTemplate.opsForValue().setIfAbsent(RiskSourceServiceImpl.cacheKeyForCanBeRunning(),"CONTINGENCYRUNING");
////// }
////// ContingencyOriginalData contingencyOriginalData = iContingencyOriginalDataDao.findByBatchNo(batchNo); String stepKey = batchNo + "_" + stepCode;
////// if("FIRE_CANCEL".equals(buttonCode) || "END_EMERGENCY".equals(buttonCode)){ if (stepMap.get(stepKey) == null)
////// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning()); stepMap.put(stepKey, "");
////// }else{ if (contingencyOriginalData != null) {
////// redisTemplate.opsForValue().setIfAbsent(RiskSourceServiceImpl.cacheKeyForCanBeRunning(),"CONTINGENCYRUNING"); log.info("数据库中的stepcode:" + contingencyOriginalData.getStep());
////// } contingencyOriginalData.setConfirm(buttonState);
////// String stepKey = batchNo + "_" + stepCode; contingencyOriginalData.setRunstep(false);
////// if (stepMap.get(stepKey) == null) if (contingencyOriginalData.getStepState() == null)
////// stepMap.put(stepKey, ""); contingencyOriginalData.setStepState("");
////// if (contingencyOriginalData != null) {
////// log.info("数据库中的stepcode:" + contingencyOriginalData.getStep()); if ("CONFIRM".equals(buttonState)
////// contingencyOriginalData.setConfirm(buttonState); && !contingencyOriginalData.getStepState().contains(stepStateOnbutton)
////// contingencyOriginalData.setRunstep(false); && stepCode.equals(contingencyOriginalData.getStep()))
////// if (contingencyOriginalData.getStepState() == null) contingencyOriginalData.setStepState(contingencyOriginalData.getStepState() + stepStateOnbutton);
////// contingencyOriginalData.setStepState("");
//////
////// if ("CONFIRM".equals(buttonState) //请求中的步骤小于以保存的步骤
////// && !contingencyOriginalData.getStepState().contains(stepStateOnbutton) if (Integer.parseInt(stepCode) < Integer.parseInt(contingencyOriginalData.getStep())) {
////// && stepCode.equals(contingencyOriginalData.getStep())) contingencyOriginalData.setRunstep(true);
////// contingencyOriginalData.setStepState(contingencyOriginalData.getStepState() + stepStateOnbutton); }
//////
//////
////// //请求中的步骤小于以保存的步骤 if (Integer.parseInt(stepCode) > Integer.parseInt(contingencyOriginalData.getStep())) {
////// if (Integer.parseInt(stepCode) < Integer.parseInt(contingencyOriginalData.getStep())) { //contingencyOriginalData.setStep(stepCode);
////// contingencyOriginalData.setRunstep(true); contingencyOriginalData.setStepState(stepStateOnbutton);
////// } }
//////
//////
////// if (Integer.parseInt(stepCode) > Integer.parseInt(contingencyOriginalData.getStep())) { iContingencyOriginalDataDao.updateByButton(
////// //contingencyOriginalData.setStep(stepCode); contingencyOriginalData.getConfirm(),
////// contingencyOriginalData.setStepState(stepStateOnbutton); contingencyOriginalData.getRunstep(),
////// } contingencyOriginalData.getStepState(),
////// contingencyOriginalData.getBatchNo());
////// // setButtonExecuted(batchNo,contingencyPlanId, buttonCode,buttonState);
////// iContingencyOriginalDataDao.updateByButton(
////// contingencyOriginalData.getConfirm(), //使用原始数据触发规则
////// contingencyOriginalData.getRunstep(),
////// contingencyOriginalData.getStepState(),
////// contingencyOriginalData.getBatchNo()); if ("CONFIRM".equals(buttonState)
////// //setButtonExecuted(batchNo,contingencyPlanId, buttonCode,buttonState); && !stepMap.get(stepKey).contains(stepStateOnbutton))
////// stepMap.put(stepKey, stepMap.get(stepKey) + stepStateOnbutton);
////// //使用原始数据触发规则
////// ContingencyRo contingencyRo = new ContingencyRo();
////// contingencyRo.setButtonCode(buttonCode);
////// if ("CONFIRM".equals(buttonState) contingencyRo.setButtonState(buttonState);
////// && !stepMap.get(stepKey).contains(stepStateOnbutton)) BeanUtils.copyProperties(contingencyOriginalData, contingencyRo);
////// stepMap.put(stepKey, stepMap.get(stepKey) + stepStateOnbutton); contingencyRo.setStep(stepCode);
////// contingencyRo.setStepState(stepMap.get(stepKey));
////// ContingencyRo contingencyRo = new ContingencyRo(); log.info("stepstate:" + contingencyRo.getStepState());
////// contingencyRo.setButtonCode(buttonCode);
////// contingencyRo.setButtonState(buttonState);
////// BeanUtils.copyProperties(contingencyOriginalData, contingencyRo); Equipment equipment = impAndFireEquipMapper.queryImpEqumtByFireEquipmt(Long.parseLong(contingencyRo.getFireEquipmentId()));
////// contingencyRo.setStep(stepCode); //Object result = remoteRuleServer.fireRuleFlow(contingencyRo, equipment.getReservePlan(),equipment.getName());
////// contingencyRo.setStepState(stepMap.get(stepKey)); ruleTrigger.publish(contingencyRo, equipment.getReservePlan(), ArrayUtils.toArray(equipment.getName()));
////// log.info("stepstate:" + contingencyRo.getStepState());
////// BubbleTipResult result1 = new BubbleTipResult();
////// Map<String, Object> tempmap2 = new HashMap<>();
////// Equipment equipment = impAndFireEquipMapper.queryImpEqumtByFireEquipmt(Long.parseLong(contingencyRo.getFireEquipmentId())); tempmap2.put("refresh","refresh");
////// //Object result = remoteRuleServer.fireRuleFlow(contingencyRo, equipment.getReservePlan(),equipment.getName()); tempmap2.put("batchNo",batchNo);
////// ruleTrigger.publish(contingencyRo, equipment.getReservePlan()); ContingencyAction.sendcmd("fromws","recordArea","refresh",result1);
////// // String url = remoteRuleUrl + "/urule/rule/refreshTimeline?batchNo=" + batchNo;
////// BubbleTipResult result1 = new BubbleTipResult(); //restTemplate.exchange(url, HttpMethod.GET, HttpEntity.EMPTY, Object.class);
////// Map<String, Object> tempmap2 = new HashMap<>(); } else {
////// tempmap2.put("refresh","refresh"); throw new Exception("数据异常,请联系管理员.");
////// tempmap2.put("batchNo",batchNo); }
////// ContingencyAction.sendcmd("fromws","recordArea","refresh",result1); }
////// // String url = remoteRuleUrl + "/urule/rule/refreshTimeline?batchNo=" + batchNo;
////// //restTemplate.exchange(url, HttpMethod.GET, HttpEntity.EMPTY, Object.class);
////// } else { public void setButtonExecuted(String batchNo, String contingencyPlanId, String code, String buttonState) throws Exception {
////// throw new Exception("数据异常,请联系管理员."); ObjectMapper objectMapper = new ObjectMapper();
////// } Optional<ContingencyPlanInstance> contingencyPlanInstance1 = repository.findById(contingencyPlanId);
////// }
////// ContingencyPlanInstance contingencyPlanInstance=contingencyPlanInstance1.get();
//////
////// public void setButtonExecuted(String batchNo, String contingencyPlanId, String code, String buttonState) throws Exception { if(contingencyPlanInstance1.isPresent()){
////// ObjectMapper objectMapper = new ObjectMapper(); if (contingencyPlanInstance != null && "OPERATE".equals(contingencyPlanInstance.getRecordType())) {
////// Optional<ContingencyPlanInstance> contingencyPlanInstance1 = repository.findById(contingencyPlanId); String operateJson = contingencyPlanInstance.getContent();
////// OperateGroup operateGroup = objectMapper.readValue(operateJson, OperateGroup.class);
////// ContingencyPlanInstance contingencyPlanInstance=contingencyPlanInstance1.get();
////// List<Operate> operates = operateGroup.getOperate();
////// if(contingencyPlanInstance1.isPresent()){ if (!CollectionUtils.isEmpty(operates)) {
////// if (contingencyPlanInstance != null && "OPERATE".equals(contingencyPlanInstance.getRecordType())) { for (Operate operate : operates) {
////// String operateJson = contingencyPlanInstance.getContent();
////// OperateGroup operateGroup = objectMapper.readValue(operateJson, OperateGroup.class); if (code.equals(operate.getCode()) && ("executed".equals(operate.getState()) || "disable".equals(operate.getState()))){
////// if("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code)){
////// List<Operate> operates = operateGroup.getOperate(); redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
////// if (!CollectionUtils.isEmpty(operates)) { }
////// for (Operate operate : operates) { throw new Exception("请勿重复操作.");
////// }
////// if (code.equals(operate.getCode()) && ("executed".equals(operate.getState()) || "disable".equals(operate.getState()))){
////// if("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code)){
////// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning()); if ("CONFIRM".equals(buttonState)) {
////// } if (code.equals(operate.getCode())) {
////// throw new Exception("请勿重复操作."); operate.setState("executed");
////// } if("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code))
////// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
////// } else {
////// if ("CONFIRM".equals(buttonState)) { operate.setState("disable");
////// if (code.equals(operate.getCode())) { }
////// operate.setState("executed"); }
////// if("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code)) }
////// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning()); }
////// } else {
////// operate.setState("disable");
////// } if (buttonState.equals("CONFIRM"))
////// } contingencyPlanInstance.setRunstate(true);
////// } operateJson = objectMapper.writeValueAsString(operateGroup);
////// } contingencyPlanInstance.setContent(operateJson);
////// repository.save(contingencyPlanInstance);
////// }
////// if (buttonState.equals("CONFIRM")) }
////// contingencyPlanInstance.setRunstate(true);
////// operateJson = objectMapper.writeValueAsString(operateGroup); }
////// contingencyPlanInstance.setContent(operateJson);
////// repository.save(contingencyPlanInstance); public void setButtonWait(String batchNo, String contingencyPlanId, String buttonState) throws Exception {
////// } ObjectMapper objectMapper = new ObjectMapper();
////// } Optional<ContingencyPlanInstance> contingencyPlanInstance1 = repository.findById(contingencyPlanId);
////// ContingencyPlanInstance contingencyPlanInstance=null;
////// } if(contingencyPlanInstance1.isPresent()){
////// contingencyPlanInstance=contingencyPlanInstance1.get();
////// public void setButtonWait(String batchNo, String contingencyPlanId, String buttonState) throws Exception { }
////// ObjectMapper objectMapper = new ObjectMapper();
////// Optional<ContingencyPlanInstance> contingencyPlanInstance1 = repository.findById(contingencyPlanId); if (contingencyPlanInstance != null && "OPERATE".equals(contingencyPlanInstance.getRecordType())) {
////// ContingencyPlanInstance contingencyPlanInstance=null; String operateJson = contingencyPlanInstance.getContent();
////// if(contingencyPlanInstance1.isPresent()){ OperateGroup operateGroup = objectMapper.readValue(operateJson, OperateGroup.class);
////// contingencyPlanInstance=contingencyPlanInstance1.get();
////// } List<Operate> operates = operateGroup.getOperate();
////// if (!CollectionUtils.isEmpty(operates)) {
////// if (contingencyPlanInstance != null && "OPERATE".equals(contingencyPlanInstance.getRecordType())) { for (Operate operate : operates) {
////// String operateJson = contingencyPlanInstance.getContent();
////// OperateGroup operateGroup = objectMapper.readValue(operateJson, OperateGroup.class); if ("CONFIRM".equals(buttonState)) {
////// operate.setState("executed");
////// List<Operate> operates = operateGroup.getOperate(); }
////// if (!CollectionUtils.isEmpty(operates)) { }
////// for (Operate operate : operates) { }
//////
////// if ("CONFIRM".equals(buttonState)) {
////// operate.setState("executed"); if (buttonState.equals("CONFIRM"))
////// } contingencyPlanInstance.setRunstate(true);
////// } operateJson = objectMapper.writeValueAsString(operateGroup);
////// } contingencyPlanInstance.setContent(operateJson);
////// repository.save(contingencyPlanInstance);
////// }
////// if (buttonState.equals("CONFIRM")) }
////// contingencyPlanInstance.setRunstate(true);
////// operateJson = objectMapper.writeValueAsString(operateGroup);
////// contingencyPlanInstance.setContent(operateJson); @Override
////// repository.save(contingencyPlanInstance); public void updateStep(String step, String batchNo) {
////// } iContingencyOriginalDataDao.updateByButtonStep(step,batchNo);
////// } }
////// }
//////
////// @Override
////// public void updateStep(String step, String batchNo) {
////// // TODO Auto-generated method stub
//////
////// }
////}
//=======
//package com.yeejoin.amos.fas.business.service.impl;
//
//import com.yeejoin.amos.component.rule.RuleTrigger;
//import com.yeejoin.amos.fas.business.action.ContingencyAction;
//import com.yeejoin.amos.fas.business.action.result.BubbleTipResult;
//import com.yeejoin.amos.fas.business.dao.mapper.ImpAndFireEquipMapper;
//import com.yeejoin.amos.fas.business.dao.repository.IContingencyOriginalDataDao;
//import com.yeejoin.amos.fas.business.dao.repository.IContingencyPlanInstanceRepository;
//import com.yeejoin.amos.fas.business.feign.RemoteRuleServer;
//import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance;
//import com.yeejoin.amos.fas.business.service.model.ContingencyRo;
//import com.yeejoin.amos.fas.business.service.model.Operate;
//import com.yeejoin.amos.fas.business.service.model.OperateGroup;
//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 {
//
// private static final Logger log = LoggerFactory.getLogger(ContingencyInstanceImpl.class);
//
// @Autowired
// private IContingencyPlanInstanceRepository repository;
//
//
// @Autowired
// IContingencyOriginalDataDao iContingencyOriginalDataDao;
//
//
// @Autowired
// private RemoteRuleServer remoteRuleServer;
//
// @Autowired
// private RestTemplate restTemplate;
//
// @Autowired
// private ImpAndFireEquipMapper impAndFireEquipMapper;
//
// @Autowired
// private RedisTemplate redisTemplate;
//
//
// @Value("${params.remoteRuleUrl}")
// private String remoteRuleUrl;
//
//
// private static Map<String, String> stepMap = new HashMap<>();
//
// @Autowired
// private RuleTrigger ruleTrigger;
//
// /* public ContingencyInstanceImpl(IContingencyPlanInstanceRepository repository) {
// super(repository);
// this.repository = repository;
// }*/
//
//
// /**
// * 创建预案执行记录
// *
// * @param category 一级分类
// * @param subCategory 二级分类
// * @param content 信息内容
// * @param recordType 信息分类
// * @param icon 信息显示图标
// */
// public ContingencyPlanInstance createInstanceRecord(String instanceNo, String category, String subCategory, String content, String recordType, String icon) {
// ContingencyPlanInstance planInstance = new ContingencyPlanInstance();
//
// planInstance.setContent(content);
// planInstance.setIcon(icon);
// planInstance.setRecordType(recordType);
// planInstance.setCategory(category);
// planInstance.setBatchNo(instanceNo);
//
// //计算序号
// int count = repository.countByBatchNo(instanceNo);
// planInstance.setSort(++count);
// return this.repository.save(planInstance);
// }
//
//
// /**
// * 查询时间轴
// *
// * @param instanceNo
// * @return
// * @throws Exception
// */
// public List<ContingencyPlanInstance> queryForTimeLine(String instanceNo, String recordType) throws Exception {
// List<ContingencyPlanInstance> categorys = repository.queryForCategory(instanceNo, recordType);
// return categorys;
// }
//
//
// public void fire(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton) throws Exception {
// //火灾误报
//
// ContingencyOriginalData contingencyOriginalData = iContingencyOriginalDataDao.findByBatchNo(batchNo);
// if("FIRE_CANCEL".equals(buttonCode) || "END_EMERGENCY".equals(buttonCode)){
// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
// }else{
// redisTemplate.opsForValue().setIfAbsent(RiskSourceServiceImpl.cacheKeyForCanBeRunning(),"CONTINGENCYRUNING");
// }
// String stepKey = batchNo + "_" + stepCode;
// if (stepMap.get(stepKey) == null)
// stepMap.put(stepKey, "");
// if (contingencyOriginalData != null) {
// log.info("数据库中的stepcode:" + contingencyOriginalData.getStep());
// contingencyOriginalData.setConfirm(buttonState);
// contingencyOriginalData.setRunstep(false);
// if (contingencyOriginalData.getStepState() == null)
// contingencyOriginalData.setStepState("");
//
// if ("CONFIRM".equals(buttonState)
// && !contingencyOriginalData.getStepState().contains(stepStateOnbutton)
// && stepCode.equals(contingencyOriginalData.getStep()))
// contingencyOriginalData.setStepState(contingencyOriginalData.getStepState() + stepStateOnbutton);
//
//
// //请求中的步骤小于以保存的步骤
// if (Integer.parseInt(stepCode) < Integer.parseInt(contingencyOriginalData.getStep())) {
// contingencyOriginalData.setRunstep(true);
// }
//
//
// if (Integer.parseInt(stepCode) > Integer.parseInt(contingencyOriginalData.getStep())) {
// //contingencyOriginalData.setStep(stepCode);
// contingencyOriginalData.setStepState(stepStateOnbutton);
// }
//
//
// iContingencyOriginalDataDao.updateByButton(
// contingencyOriginalData.getConfirm(),
// contingencyOriginalData.getRunstep(),
// contingencyOriginalData.getStepState(),
// contingencyOriginalData.getBatchNo());
// //setButtonExecuted(batchNo,contingencyPlanId, buttonCode,buttonState);
//
// //使用原始数据触发规则
//
//
// if ("CONFIRM".equals(buttonState)
// && !stepMap.get(stepKey).contains(stepStateOnbutton))
// stepMap.put(stepKey, stepMap.get(stepKey) + stepStateOnbutton);
//
// ContingencyRo contingencyRo = new ContingencyRo();
// contingencyRo.setButtonCode(buttonCode);
// contingencyRo.setButtonState(buttonState);
// BeanUtils.copyProperties(contingencyOriginalData, contingencyRo);
// contingencyRo.setStep(stepCode);
// contingencyRo.setStepState(stepMap.get(stepKey));
// log.info("stepstate:" + contingencyRo.getStepState());
//
//
// Equipment equipment = impAndFireEquipMapper.queryImpEqumtByFireEquipmt(Long.parseLong(contingencyRo.getFireEquipmentId()));
// //Object result = remoteRuleServer.fireRuleFlow(contingencyRo, equipment.getReservePlan(),equipment.getName());
// equipment.setName("极Ⅰ高端YY换流变A相");
// ruleTrigger.publish(contingencyRo, equipment.getReservePlan(), ArrayUtils.toArray(equipment.getName()));
//
// BubbleTipResult result1 = new BubbleTipResult();
// Map<String, Object> tempmap2 = new HashMap<>();
// tempmap2.put("refresh","refresh");
// tempmap2.put("batchNo",batchNo);
// ContingencyAction.sendcmd("fromws","recordArea","refresh",result1);
// // String url = remoteRuleUrl + "/urule/rule/refreshTimeline?batchNo=" + batchNo;
// //restTemplate.exchange(url, HttpMethod.GET, HttpEntity.EMPTY, Object.class);
// } else {
// throw new Exception("数据异常,请联系管理员.");
// }
// }
//
//
// public void setButtonExecuted(String batchNo, String contingencyPlanId, String code, String buttonState) throws Exception {
// ObjectMapper objectMapper = new ObjectMapper();
// Optional<ContingencyPlanInstance> contingencyPlanInstance1 = repository.findById(contingencyPlanId);
//
// ContingencyPlanInstance contingencyPlanInstance=contingencyPlanInstance1.get();
//
// if(contingencyPlanInstance1.isPresent()){
// if (contingencyPlanInstance != null && "OPERATE".equals(contingencyPlanInstance.getRecordType())) {
// String operateJson = contingencyPlanInstance.getContent();
// OperateGroup operateGroup = objectMapper.readValue(operateJson, OperateGroup.class);
//
// List<Operate> operates = operateGroup.getOperate();
// if (!CollectionUtils.isEmpty(operates)) {
// for (Operate operate : operates) {
//
// if (code.equals(operate.getCode()) && ("executed".equals(operate.getState()) || "disable".equals(operate.getState()))){
// if("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code)){
// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
// }
// throw new Exception("请勿重复操作.");
// }
//
//
// if ("CONFIRM".equals(buttonState)) {
// if (code.equals(operate.getCode())) {
// operate.setState("executed");
// if("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code))
// redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
// } else {
// operate.setState("disable");
// }
// }
// }
// }
//
//
// if (buttonState.equals("CONFIRM"))
// contingencyPlanInstance.setRunstate(true);
// operateJson = objectMapper.writeValueAsString(operateGroup);
// contingencyPlanInstance.setContent(operateJson);
// repository.save(contingencyPlanInstance);
// }
// }
//
// }
//
// public void setButtonWait(String batchNo, String contingencyPlanId, String buttonState) throws Exception {
// ObjectMapper objectMapper = new ObjectMapper();
// Optional<ContingencyPlanInstance> contingencyPlanInstance1 = repository.findById(contingencyPlanId);
// ContingencyPlanInstance contingencyPlanInstance=null;
// if(contingencyPlanInstance1.isPresent()){
// contingencyPlanInstance=contingencyPlanInstance1.get();
// }
//
// if (contingencyPlanInstance != null && "OPERATE".equals(contingencyPlanInstance.getRecordType())) {
// String operateJson = contingencyPlanInstance.getContent();
// OperateGroup operateGroup = objectMapper.readValue(operateJson, OperateGroup.class);
//
// List<Operate> operates = operateGroup.getOperate();
// if (!CollectionUtils.isEmpty(operates)) {
// for (Operate operate : operates) {
//
// if ("CONFIRM".equals(buttonState)) {
// operate.setState("executed");
// }
// }
// }
//
//
// if (buttonState.equals("CONFIRM"))
// contingencyPlanInstance.setRunstate(true);
// operateJson = objectMapper.writeValueAsString(operateGroup);
// contingencyPlanInstance.setContent(operateJson);
// repository.save(contingencyPlanInstance);
// }
// }
//
//
// @Override
// public void updateStep(String step, String batchNo) {
// // TODO Auto-generated method stub
//
// }
//}
//>>>>>>> 28409f79427e917f31bc936696f98f961a5dd24d
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/MessageServiceImpl.java 0 → 100644
View file @ 6d13cee1
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/impl/RiskSourceServiceImpl.java
View file @ 6d13cee1
...@@ -7,6 +7,7 @@ import com.google.common.base.Joiner; ...@@ -7,6 +7,7 @@ import com.google.common.base.Joiner;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
import com.yeejoin.amos.component.rule.RuleTrigger;
import com.yeejoin.amos.fas.business.bo.*; import com.yeejoin.amos.fas.business.bo.*;
import com.yeejoin.amos.fas.business.constants.FasConstant; import com.yeejoin.amos.fas.business.constants.FasConstant;
import com.yeejoin.amos.fas.business.dao.mapper.*; import com.yeejoin.amos.fas.business.dao.mapper.*;
...@@ -40,6 +41,8 @@ import com.yeejoin.amos.fas.dao.entity.*; ...@@ -40,6 +41,8 @@ import com.yeejoin.amos.fas.dao.entity.*;
import com.yeejoin.amos.fas.exception.YeeException; import com.yeejoin.amos.fas.exception.YeeException;
import com.yeejoin.amos.feign.privilege.model.AgencyUserModel; import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
import com.yeejoin.amos.feign.privilege.model.DepartmentModel; import com.yeejoin.amos.feign.privilege.model.DepartmentModel;
import org.apache.commons.lang3.ArrayUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
...@@ -147,6 +150,9 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -147,6 +150,9 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
private IDictDao dictDao; private IDictDao dictDao;
@Autowired @Autowired
private RedisTemplate redisTemplate; private RedisTemplate redisTemplate;
@Autowired
private RuleTrigger ruleTrigger;
@Autowired @Autowired
private FmeaEquipmentPointMapper fmeaEquipmentPointMapper; private FmeaEquipmentPointMapper fmeaEquipmentPointMapper;
...@@ -485,7 +491,7 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -485,7 +491,7 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
} }
//Object result = remoteRuleServer.fireRuleFlow(contingencyRo, equipment.getReservePlan(), equipment.getName()); //Object result = remoteRuleServer.fireRuleFlow(contingencyRo, equipment.getReservePlan(), equipment.getName());
// ruleTrigger.publish(contingencyRo, equipment.getReservePlan()); ruleTrigger.publish(contingencyRo, equipment.getReservePlan(),ArrayUtils.toArray( equipment.getName()));
ContingencyOriginalData contingencyOriginalData = new ContingencyOriginalData(); ContingencyOriginalData contingencyOriginalData = new ContingencyOriginalData();
BeanUtils.copyProperties(contingencyRo, contingencyOriginalData); BeanUtils.copyProperties(contingencyRo, contingencyOriginalData);
iContingencyOriginalDataDao.save(contingencyOriginalData); iContingencyOriginalDataDao.save(contingencyOriginalData);
......
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IContingencyInstance.java
View file @ 6d13cee1
package com.yeejoin.amos.fas.business.service.intfc; package com.yeejoin.amos.fas.business.service.intfc;
import java.util.List;
import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
public interface IContingencyInstance { public interface IContingencyInstance {
//
// ContingencyPlanInstance createInstanceRecord(String instanceNo, String category, String subCategory, String content, String recordType, String icon); ContingencyPlanInstance createInstanceRecord(String instanceNo, String category, String subCategory, String content, String recordType, String icon);
//
//
//
// List<ContingencyPlanInstance> queryForTimeLine(String instanceNo,String recordType) throws Exception; List<ContingencyPlanInstance> queryForTimeLine(String instanceNo,String recordType) throws Exception;
//
//
// void setButtonExecuted(String batchNo,String contingencyPlanId,String code,String buttonState) throws Exception; void setButtonExecuted(String batchNo,String contingencyPlanId,String code,String buttonState) throws Exception;
// void setButtonWait(String batchNo,String contingencyPlanId,String buttonState) throws Exception; void setButtonWait(String batchNo,String contingencyPlanId,String buttonState) throws Exception;
//
//
// void fire(String batchNo,String stepCode, String contingencyPlanId, String buttonCode,String buttonState,String stepStateOnbutton) throws Exception; void fire(String batchNo,String stepCode, String contingencyPlanId, String buttonCode,String buttonState,String stepStateOnbutton) throws Exception;
//
// void updateStep(String step, String batchNo); void updateStep(String step, String batchNo);
} }
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IMessageService.java 0 → 100644
View file @ 6d13cee1
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);
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment