message
parent
a383a6c5df
commit
ab2d22012a
@ -0,0 +1,18 @@
|
|||||||
|
package com.weaver.custom.configcenter;
|
||||||
|
|
||||||
|
import com.weaver.framework.client.annotation.WeaverConfigCenter;
|
||||||
|
import lombok.Data;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
@Data
|
||||||
|
@Component
|
||||||
|
@WeaverConfigCenter(sources = {
|
||||||
|
@WeaverConfigCenter.ConfigProperty(
|
||||||
|
dataId = "weaver-secondev-remindforweixin.properties",
|
||||||
|
group = "DEFAULT_GROUP",
|
||||||
|
refresh = "true")
|
||||||
|
})
|
||||||
|
public class RemindforweixinConfig {
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,51 @@
|
|||||||
|
package com.weaver.seconddev.interfaces.prop;
|
||||||
|
|
||||||
|
import com.weaver.common.base.entity.result.WeaResult;
|
||||||
|
import com.weaver.mc.api.async.AsyncSystemMessageRest;
|
||||||
|
import com.weaver.mc.api.entity.*;
|
||||||
|
import io.swagger.annotations.ApiOperation;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.web.bind.annotation.GetMapping;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
|
||||||
|
@Component
|
||||||
|
public class MessageUtil {
|
||||||
|
@Autowired
|
||||||
|
private AsyncSystemMessageRest systemMessageRest;
|
||||||
|
|
||||||
|
|
||||||
|
private static final long EMPLOYEE_ID = 3905800511444409505L;
|
||||||
|
private static final String TENANT_KEY = "ty0tu018gk";
|
||||||
|
|
||||||
|
private static final UserEntity DEFAULT_RECIVER = new UserEntity(EMPLOYEE_ID).setTenantKey(TENANT_KEY);
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 基本消息
|
||||||
|
*
|
||||||
|
* @returnxit
|
||||||
|
*/
|
||||||
|
private SendMessageEntity getBaseMsg() {
|
||||||
|
SendMessageEntity smg = new SendMessageEntity();
|
||||||
|
smg.setModule(MessageModule.TASK);
|
||||||
|
smg.setEvent(MessageEvent.NOTIFY);
|
||||||
|
smg.setSender(UserEntity.SYSTEM_USER);
|
||||||
|
smg.setReceivers(Collections.singletonList(DEFAULT_RECIVER));
|
||||||
|
smg.setText("任务提醒");
|
||||||
|
smg.setPcUrl(" 云桥pc打开事项地址");//可以为空
|
||||||
|
smg.setAppUrl("云桥app打开事项地址");//可以为空
|
||||||
|
smg.setTitle("云桥任务提醒标题");
|
||||||
|
smg.setContent("云桥消息内容");
|
||||||
|
return smg;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void sendMes(SendMessageEntity smg){
|
||||||
|
WeaResult<Long> longWeaResult = systemMessageRest.sendMsg(smg);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -1,106 +1,151 @@
|
|||||||
//package com.weaver.seconddev.interfaces.workflow.action;
|
package com.weaver.seconddev.interfaces.workflow.action;
|
||||||
//
|
|
||||||
////import com.cloudstore.dev.api.bean.MessageBean;
|
//import com.cloudstore.dev.api.bean.MessageBean;
|
||||||
////import com.cloudstore.dev.api.bean.MessageType;
|
//import com.cloudstore.dev.api.bean.MessageType;
|
||||||
////import com.cloudstore.dev.api.util.Util_Message;
|
//import com.cloudstore.dev.api.util.Util_Message;
|
||||||
//import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
//import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
//import java.util.List;
|
import java.util.List;
|
||||||
//import com.weaver.common.i18n.tool.util.I18nContextUtil;
|
|
||||||
//import org.springframework.core.env.Environment;
|
import com.alibaba.fastjson.JSONObject;
|
||||||
//import java.lang.*;
|
import com.weaver.common.i18n.tool.util.I18nContextUtil;
|
||||||
//import java.util.*;
|
import com.weaver.mc.api.async.AsyncSystemMessageRest;
|
||||||
//import com.weaver.verupgrade.workflow.request.RequestManager;
|
import com.weaver.mc.api.entity.MessageEvent;
|
||||||
//import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface;
|
import com.weaver.mc.api.entity.MessageModule;
|
||||||
//import com.weaver.common.base.entity.result.WeaResult;
|
import com.weaver.mc.api.entity.SendMessageEntity;
|
||||||
//import org.slf4j.Logger;
|
import com.weaver.mc.api.entity.UserEntity;
|
||||||
//import org.slf4j.LoggerFactory;
|
import com.weaver.openapi.pojo.ApiResult;
|
||||||
//import org.springframework.beans.factory.annotation.Autowired;
|
import com.weaver.openapi.pojo.message.params.MessageVo;
|
||||||
//import com.weaver.verupgrade.soa.workflow.request.RequestInfo;
|
import com.weaver.openapi.pojo.message.params.vo.MessageEntity;
|
||||||
//import java.util.Map;
|
import com.weaver.openapi.pojo.message.params.vo.MessageReciver;
|
||||||
//import java.util.HashMap;
|
import com.weaver.openapi.pojo.message.params.vo.MessageSender;
|
||||||
//import com.weaver.verupgrade.general.BaseBean;
|
import com.weaver.openapi.service.MessageService;
|
||||||
//import com.weaver.verupgrade.general.Util;
|
import com.weaver.seconddev.interfaces.prop.ConfigProp;
|
||||||
//import com.weaver.verupgrade.soa.workflow.request.Property;
|
import org.springframework.core.env.Environment;
|
||||||
//import com.weaver.verupgrade.interfaces.workflow.action.Action;
|
import java.lang.*;
|
||||||
//
|
import java.util.*;
|
||||||
|
import com.weaver.verupgrade.workflow.request.RequestManager;
|
||||||
|
import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface;
|
||||||
|
import com.weaver.common.base.entity.result.WeaResult;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import com.weaver.verupgrade.soa.workflow.request.RequestInfo;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import com.weaver.verupgrade.general.BaseBean;
|
||||||
|
import com.weaver.verupgrade.general.Util;
|
||||||
|
import com.weaver.verupgrade.soa.workflow.request.Property;
|
||||||
|
import com.weaver.verupgrade.interfaces.workflow.action.Action;
|
||||||
|
|
||||||
//TODO config
|
//TODO config
|
||||||
//@org.springframework.stereotype.Service("workflow_action_RemindForCarAction")
|
@org.springframework.stereotype.Service("workflow_action_RemindForCarAction")
|
||||||
//public class RemindForCarAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
|
public class RemindForCarAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
|
||||||
//
|
|
||||||
// // 对应E9的请求信息对象
|
// 对应E9的请求信息对象
|
||||||
// @Autowired
|
@Autowired
|
||||||
// private RequestInfo requestInfoTemp;
|
private RequestInfo requestInfoTemp;
|
||||||
//
|
@Autowired
|
||||||
// private static final Logger logger_9618d585 = LoggerFactory.getLogger(RemindForCarAction.class);
|
private ConfigProp configProp;
|
||||||
//
|
|
||||||
// public WeaResult<Map<String, Object>> execute(Map<String, Object> requestInfoMap) {
|
@Autowired
|
||||||
// Map<String, Object> weaverResultMap = new HashMap<>();
|
private AsyncSystemMessageRest systemMessageRest;
|
||||||
// Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1)));
|
|
||||||
// Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
|
private static final Logger logger_9618d585 = LoggerFactory.getLogger(RemindForCarAction.class);
|
||||||
// RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
|
|
||||||
// try {
|
public WeaResult<Map<String, Object>> execute(Map<String, Object> requestInfoMap) {
|
||||||
// try {
|
Map<String, Object> weaverResultMap = new HashMap<>();
|
||||||
// BaseBean basebean = new BaseBean();
|
Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1)));
|
||||||
// logger_9618d585.info(String.valueOf("do RemindForCarAction start "));
|
Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
|
||||||
|
RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
|
||||||
|
try {
|
||||||
|
try {
|
||||||
|
BaseBean basebean = new BaseBean();
|
||||||
|
logger_9618d585.info(String.valueOf("do RemindForCarAction start "));
|
||||||
// String content = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("remindforweixin.carmessage")).trim();
|
// String content = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("remindforweixin.carmessage")).trim();
|
||||||
// String requestId = request.getRequestid();
|
String content = configProp.getCarmessage();
|
||||||
// List<String> list = new ArrayList<String>();
|
String requestId = request.getRequestid();
|
||||||
// // 获取主表数据
|
List<String> list = new ArrayList<String>();
|
||||||
// Property[] aproperty = request.getMainTableInfo().getProperty();
|
// 获取主表数据
|
||||||
// for (int i = 0; i < aproperty.length; i++) {
|
Property[] aproperty = request.getMainTableInfo().getProperty();
|
||||||
// String name = aproperty[i].getName().toUpperCase();
|
for (int i = 0; i < aproperty.length; i++) {
|
||||||
// String value = Util.null2String(aproperty[i].getValue());
|
String name = aproperty[i].getName().toUpperCase();
|
||||||
// if (name.equals("SQR")) {
|
String value = Util.null2String(aproperty[i].getValue());
|
||||||
// // 申请人
|
if (name.equals("SQR")) {
|
||||||
// if (!"".equals(value)) {
|
// 申请人
|
||||||
// list.add(value);
|
if (!"".equals(value)) {
|
||||||
// }
|
list.add(value);
|
||||||
// }
|
}
|
||||||
// /*if(name.equals("CCRY")){//乘车人员
|
}
|
||||||
// if(!"".equals(value)){
|
/*if(name.equals("CCRY")){//乘车人员
|
||||||
// String[] array = value.split(",");
|
if(!"".equals(value)){
|
||||||
// for(int k=0;k<array.length;k++){
|
String[] array = value.split(",");
|
||||||
// list.add(array[k]);
|
for(int k=0;k<array.length;k++){
|
||||||
// }
|
list.add(array[k]);
|
||||||
// }
|
}
|
||||||
// }*/
|
}
|
||||||
// }
|
}*/
|
||||||
// // 去除重复的数据
|
}
|
||||||
// /*if(list!= null && list.size() > 0){
|
// 去除重复的数据
|
||||||
// HashSet<String> h = new HashSet<String>(list);
|
/*if(list!= null && list.size() > 0){
|
||||||
// list.clear();
|
HashSet<String> h = new HashSet<String>(list);
|
||||||
// list.addAll(h);
|
list.clear();
|
||||||
// }*/
|
list.addAll(h);
|
||||||
// // InterfaceUtil.sendMsg(list, ",28ffc89713a64541891276edc32131cc,", requestId, content, 1);
|
}*/
|
||||||
|
|
||||||
|
// InterfaceUtil.sendMsg(list, ",28ffc89713a64541891276edc32131cc,", requestId, content, 1);
|
||||||
|
|
||||||
|
//TODO config
|
||||||
// MessageType messageType = MessageType.newInstance(506);
|
// MessageType messageType = MessageType.newInstance(506);
|
||||||
// MessageBean messageBean = Util_Message.createMessage(messageType, new HashSet(list), content, content, "", "");
|
// MessageBean messageBean = Util_Message.createMessage(messageType, new HashSet(list), content, content, "", "");
|
||||||
// messageBean.setCreater(1);
|
// messageBean.setCreater(1);
|
||||||
// Util_Message.store(messageBean);
|
// Util_Message.store(messageBean);
|
||||||
// logger_9618d585.info(String.valueOf("do RemindForCarAction success "));
|
|
||||||
// } catch (Exception e) {
|
list.forEach(item->{
|
||||||
// System.err.println(e.toString());
|
|
||||||
// }
|
});
|
||||||
// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
|
|
||||||
// } catch (Exception e) {
|
List<UserEntity> receivers = new ArrayList<>();
|
||||||
// e.printStackTrace();
|
// receivers.add()
|
||||||
// logger_9618d585.error("RemindForCarAction e: {}", e.getMessage());
|
|
||||||
// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestInfo.getRequestManager())), request.getRequestManager()));
|
SendMessageEntity smg = new SendMessageEntity();
|
||||||
// }
|
smg.setModule(MessageModule.TASK);
|
||||||
// }
|
smg.setEvent(MessageEvent.NOTIFY);
|
||||||
//
|
smg.setSender(UserEntity.SYSTEM_USER);
|
||||||
// Map<String, Object> getResultMapForAction(Map<String, Object> map, String key, Object value, RequestManager requestManager) {
|
// smg.setReceivers(Collections.singletonList(DEFAULT_RECIVER));
|
||||||
// if (key != null && !key.isEmpty()) {
|
smg.setText("任务提醒");
|
||||||
// map.put(key, value);
|
smg.setPcUrl("");//可以为空
|
||||||
// }
|
smg.setAppUrl("");//可以为空
|
||||||
// String msgContent = requestManager.getMessagecontent();
|
smg.setTitle("任务提醒");
|
||||||
// if (msgContent != null && !msgContent.isEmpty()) {
|
smg.setContent(content);
|
||||||
// map.put("msgContent", msgContent);
|
WeaResult<Long> longWeaResult = systemMessageRest.sendMsg(smg);
|
||||||
// }
|
|
||||||
// String msgId = requestManager.getMessageid();
|
|
||||||
// if (msgId != null && !msgId.isEmpty()) {
|
|
||||||
// map.put("msgId", msgId);
|
logger_9618d585.info(String.valueOf("do RemindForCarAction success "));
|
||||||
// }
|
} catch (Exception e) {
|
||||||
// return map;
|
System.err.println(e.toString());
|
||||||
// }
|
}
|
||||||
//}
|
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
logger_9618d585.error("RemindForCarAction e: {}", e.getMessage());
|
||||||
|
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), request.getRequestManager())), request.getRequestManager()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Map<String, Object> getResultMapForAction(Map<String, Object> map, String key, Object value, RequestManager requestManager) {
|
||||||
|
if (key != null && !key.isEmpty()) {
|
||||||
|
map.put(key, value);
|
||||||
|
}
|
||||||
|
String msgContent = requestManager.getMessagecontent();
|
||||||
|
if (msgContent != null && !msgContent.isEmpty()) {
|
||||||
|
map.put("msgContent", msgContent);
|
||||||
|
}
|
||||||
|
String msgId = requestManager.getMessageid();
|
||||||
|
if (msgId != null && !msgId.isEmpty()) {
|
||||||
|
map.put("msgId", msgId);
|
||||||
|
}
|
||||||
|
return map;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue