From ab2d22012aaa723d3265432c9ef725006ef3b641 Mon Sep 17 00:00:00 2001 From: qijirenjian Date: Fri, 3 Jan 2025 14:47:10 +0800 Subject: [PATCH] message --- .../configcenter/RemindforweixinConfig.java | 18 ++ .../com/weaver/seconddev/htpoex/msgRecv.java | 211 +++++++++++++++ .../interfaces/eipoa/AccountService.java | 18 +- .../seconddev/interfaces/prop/ConfigProp.java | 4 + .../interfaces/prop/MessageUtil.java | 51 ++++ .../action/AddVenMatExtsToSrmAction.java | 2 +- .../workflow/action/CustomTeAction.java | 24 +- .../workflow/action/OperateAccountAction.java | 4 +- .../workflow/action/RemindForCarAction.java | 245 +++++++++++------- 9 files changed, 462 insertions(+), 115 deletions(-) create mode 100644 secondev-history-action/src/main/java/com/weaver/custom/configcenter/RemindforweixinConfig.java create mode 100644 secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java create mode 100644 secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/MessageUtil.java diff --git a/secondev-history-action/src/main/java/com/weaver/custom/configcenter/RemindforweixinConfig.java b/secondev-history-action/src/main/java/com/weaver/custom/configcenter/RemindforweixinConfig.java new file mode 100644 index 0000000..acc77fd --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/custom/configcenter/RemindforweixinConfig.java @@ -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 { + + +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java b/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java new file mode 100644 index 0000000..c65f9bc --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java @@ -0,0 +1,211 @@ +//// +//// Source code recreated from a .class file by IntelliJ IDEA +//// (powered by Fernflower decompiler) +//// +//package com.weaver.seconddev.htpoex; +// +//import com.alibaba.fastjson.JSONArray; +//import com.cloudstore.dev.api.bean.MessageBean; +//import com.weaver.base.msgcenter.channel.IMessageReceive; +//import java.net.URLEncoder; +//import java.text.SimpleDateFormat; +//import java.util.Date; +//import java.util.Hashtable; +//import java.util.Iterator; +//import java.util.List; +//import java.util.Map; +//import java.util.Set; +//import javax.xml.namespace.QName; +//import javax.xml.rpc.ParameterMode; +//import javax.xml.rpc.encoding.XMLType; +//import org.apache.axis.client.Call; +//import org.apache.axis.client.Service; +//import com.weaver.common.i18n.tool.util.I18nContextUtil; +//import org.springframework.core.env.Environment; +//import java.lang.*; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; +//import com.weaver.verupgrade.general.BaseBean; +//import com.weaver.verupgrade.hrm.resource.ResourceComInfo; +// +///** +// * eip消息推送 门户消息推送 +// * WeaReceiveManager 消息推送类 加载ECOLOGY_MESSAGE_SUBSCRIBE 表的实现类 WeaReceiveAQ调 队列调用实现类的 +// * onMessage方法 +// */ +//public class msgRecv implements IMessageReceive { +// +// public static final org.slf4j.Logger logger_d01caf55 = LoggerFactory.getLogger(msgRecv.class); +// +// public msgRecv() { +// } +// +// public void onMessage(String paramString) { +// BaseBean log = new BaseBean(); +// logger_d01caf55.info(String.valueOf(">---onMessage---\n")); +// logger_d01caf55.info(String.valueOf(paramString + "\n")); +// List localList = JSONArray.parseArray(paramString, MessageBean.class); +// if (localList != null) { +// Iterator var4 = localList.iterator(); +// while (var4.hasNext()) { +// MessageBean messageBean = (MessageBean) var4.next(); +// this.sendMsg(messageBean, log); +// } +// } +// } +// +// public void onStart() { +// } +// +// public void onEnd() { +// } +// +// public void setProp(Map paramMap) { +// } +// +// public void setList(List paramList) { +// } +// +// private void sendMsg(MessageBean msg, BaseBean log) { +// try { +// String systemId = "SYS006"; +// String password = "123456"; +// String moudule = "流程待办"; +// String messages = ""; +// logger_d01caf55.info(String.valueOf("code:" + msg.getMessageType().getCode())); +// int code = msg.getMessageType().getCode(); +// String meetingmsg = ""; +// switch(code) { +// case 19: +// case 20: +// case 21: +// case 22: +// case 23: +// case 24: +// case 25: +// break; +// case 60: +// moudule = "通知公告"; +// break; +// case 124: +// moudule = "会议"; +// meetingmsg = "您有一个新的会议，会议名称："; +// break; +// case 125: +// moudule = "会议"; +// meetingmsg = "您有一个会议即将开始，会议名称："; +// break; +// case 127: +// moudule = "会议"; +// meetingmsg = "您有一个会议已取消，会议名称："; +// break; +// case 137: +// moudule = "会议"; +// meetingmsg = "您有一个会议已变更，会议名称："; +// break; +// case 579: +// moudule = "接待日历"; +// break; +// default: +// return; +// } +// logger_d01caf55.info(String.valueOf(moudule)); +// String content = msg.getContext(); +// String url = msg.getLinkUrl(); +// String mobileurl = msg.getLinkMobileUrl(); +// // TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.pc_url 维护到weaver-secondev-service.properties中 +// String pcurl = I18nContextUtil.getBean(Environment.class).getProperty("htportaloaUrl.pc_url") + URLEncoder.encode(url); +// // TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.pc_url 维护到weaver-secondev-service.properties中 +// String msgurl = I18nContextUtil.getBean(Environment.class).getProperty("htportaloaUrl.pc_url") + URLEncoder.encode(mobileurl); +// String m_msgtitle = msg.getTitle(); +// int sendid = msg.getCreater(); +// String sendname = "系统管理员"; +// ResourceComInfo rc = I18nContextUtil.getBean(ResourceComInfo.class); +// String userid = "1"; +// if (sendid != 1) { +// sendname = rc.getLastname(sendid + ""); +// userid = rc.getWorkcode(sendid + ""); +// } +// String pre = ""; +// String msgtt = m_msgtitle; +// if (m_msgtitle.contains("~`~`7")) { +// msgtt = m_msgtitle.substring(m_msgtitle.indexOf("~`~`7") + 6, m_msgtitle.indexOf("`~`8")); +// } +// if ("会议".equals(moudule)) { +// content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("
", " "); +// msgtt = meetingmsg + msgtt + " " + content; +// } +// if ("通知公告".equals(moudule)) { +// content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("
", " "); +// msgtt = "您有新的待阅文档：" + msgtt; +// } +// String refurl; +// if ("流程待办".equals(moudule)) { +// refurl = msg.getDetailTitle(); +// if (refurl.contains("~`~`7")) { +// refurl = refurl.substring(refurl.indexOf("~`~`7") + 6, refurl.indexOf("`~`8")); +// msgtt = refurl + "：" + msgtt; +// } +// } +// logger_d01caf55.info(String.valueOf(content)); +// logger_d01caf55.info(String.valueOf(msgtt)); +// refurl = msgurl; +// SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); +// String msgtime = df.format(new Date()); +// String target = "2"; +// String extdata = ""; +// Set useridset = msg.getUserList(); +// Object[] arr = useridset.toArray(); +// for (int i = 0; i < arr.length; i += 100) { +// StringBuilder sb = new StringBuilder(); +// for (int j = i; j < i + 100 && j < arr.length; ++j) { +// sb.append(rc.getWorkcode(arr[j] + "") + ","); +// } +// String user = sb.toString().substring(0, sb.length() - 1); +// String msgid = "MsgSYS006" + userid + (new Date()).getTime(); +// messages = messages + ""; +// messages = messages + "" + msgid + "" + pre + "" + user + "" + msgtt + "" + msgtt + "" + sendname + "" + refurl + "" + msgtime + "" + target + "" + extdata + ""; +// messages = messages + ""; +// if (!"流程待办".equals(moudule)) { +// String pctarget = "1"; +// pre = msgid; +// msgid = "MsgPCSYS006" + userid + (new Date()).getTime(); +// messages = messages + ""; +// messages = messages + "" + msgid + "" + pre + "" + user + "" + msgtt + "" + msgtt + "" + sendname + "" + pcurl + "" + msgtime + "" + pctarget + "" + extdata + ""; +// messages = messages + ""; +// } +// } +// messages = messages + ""; +// logger_d01caf55.info(String.valueOf(messages)); +// String typeNamespace = "http://message.ht_portal_webservice.com"; +// String endpoint = "https://sappop.htgd.com.cn:50001/XISOAPAdapter/MessageServlet?senderParty=&senderService=BS_HTU_POP&receiverParty=&receiverService=&interface=SI_HTPortalMessage_OUT&interfaceNamespace=http%3A%2F%2Fhengtong.com%2FHTU%2FHTPortalMessage"; +// Service service = new Service(); +// Call call = (Call) service.createCall(); +// call.setTimeout(300000); +// call.setTargetEndpointAddress(endpoint); +// call.setOperationName(new QName(typeNamespace, "message")); +// call.addParameter(new QName(typeNamespace, "systemId"), XMLType.XSD_STRING, ParameterMode.IN); +// call.addParameter(new QName(typeNamespace, "password"), XMLType.XSD_STRING, ParameterMode.IN); +// call.addParameter(new QName(typeNamespace, "moudule"), XMLType.XSD_STRING, ParameterMode.IN); +// call.addParameter(new QName(typeNamespace, "messages"), XMLType.XSD_STRING, ParameterMode.IN); +// call.setReturnClass(String.class); +// call.setReturnQName(new QName(typeNamespace, "messageResponse")); +// call.setUseSOAPAction(true); +// call.setSOAPActionURI("http://sap.com/xi/WebService/soap1.1"); +// Hashtable headers = (Hashtable) call.getProperty("HTTP-Request-Headers"); +// if (headers == null) { +// headers = new Hashtable(); +// call.setProperty("HTTP-Request-Headers", headers); +// } +// // TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.url_password 维护到weaver-secondev-service.properties中 +// headers.put("Authorization", I18nContextUtil.getBean(Environment.class).getProperty("htportaloaUrl.url_password")); +// Object[] val = new Object[] { systemId, password, moudule, messages }; +// String obj = (String) call.invoke(val); +// logger_d01caf55.info(String.valueOf(obj)); +// logger_d01caf55.info(String.valueOf("----onMessage--<\n")); +// } catch (Exception var35) { +// var35.printStackTrace(); +// logger_d01caf55.info(String.valueOf("推送流程消息出错：" + var35.toString())); +// } +// } +//} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/eipoa/AccountService.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/eipoa/AccountService.java index 69f5768..4e95131 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/eipoa/AccountService.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/eipoa/AccountService.java @@ -22,9 +22,9 @@ public class AccountService extends BaseBean { public String[] account(String sendid, UserSyncInfo[] arr) { String[] array = new String[2]; // String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("htportaloaUrl.accountUrl")).trim(); -// TODO custom config error -// String url = configProp.getAccountUrl(); - String url = "http://sappod.hengtong.com:50000/XISOAPAdapter/MessageServlet?senderParty=&senderService=BS_CRM&"; + String url = configProp.getAccountUrl(); + + logger_18cc50ce.info("url == " + url); try { logger_18cc50ce.info(String.valueOf("开始调用批量开户销户接口")); SI_HTPortalUAMGMT2_OUTServiceStub stub = new SI_HTPortalUAMGMT2_OUTServiceStub(url); @@ -34,11 +34,13 @@ public class AccountService extends BaseBean { // auth.setUsername(Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("htportaloaUrl.po_user")).trim()); // auth.setPassword(Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("htportaloaUrl.po_password")).trim()); HttpTransportPropertiesImpl.Authenticator auth = new HttpTransportPropertiesImpl.Authenticator(); - // TODO custom config error -// auth.setUsername(configProp.getPo_user()); -// auth.setPassword(configProp.getPo_password()); - auth.setUsername("pouser"); - auth.setPassword("654321"); + auth.setUsername(configProp.getPo_user()); + auth.setPassword(configProp.getPo_password()); + + logger_18cc50ce.info("getPo_user == " + configProp.getPo_user()); + + logger_18cc50ce.info("getPo_password == " + configProp.getPo_password()); + stub._getServiceClient().getOptions().setProperty(org.apache.axis2.kernel.http.HTTPConstants.AUTHENTICATE,auth); SI_HTPortalUAMGMT2_OUTServiceStub.UserAccount request = new SI_HTPortalUAMGMT2_OUTServiceStub.UserAccount(); request.setSendid(sendid); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java index 09c2c42..b8c79da 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java @@ -274,5 +274,9 @@ public class ConfigProp { + @Value("${carmessage}") + private String carmessage; + + } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/MessageUtil.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/MessageUtil.java new file mode 100644 index 0000000..04d3f95 --- /dev/null +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/MessageUtil.java @@ -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 longWeaResult = systemMessageRest.sendMsg(smg); + + } + + +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java index 150e177..63250d8 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java @@ -221,7 +221,7 @@ public class AddVenMatExtsToSrmAction extends BaseBean implements Action, EsbSer if (!isTat.equals("S")) { request.getRequestManager().setMessageid("error"); request.getRequestManager().setMessagecontent(msg); - return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, request.getRequestManager())); + return WeaResult.fail(500, "执行失败，调用接口报错", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, request.getRequestManager())); } // RecordSet rs = new RecordSet(); String sql = "update e10_core_business.dbo." + tablename + " set state='" + isTat + "',message='" + msg + "' where requestId=" + requestId; diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java index e5caa0e..ec87f40 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java @@ -77,13 +77,27 @@ public class CustomTeAction extends BaseBean implements Action, EsbServerlessRpc RecordSet rs = I18nContextUtil.getBean(RecordSet.class); - String sql = "select ID,EMPLOYEEID,SHOULDDATE,SHOULDTIME,CARDCOUNT,CARDORDER from ATDPERSONCARDEXVIEW where extype='未刷卡' and SHOULDDATE>='2024-10-01' and SHOULDDATE<='2024-12-30'"; - + String sql = "select count(1) sl from ATDPERSONCARDEXVIEW where extype='未刷卡' and SHOULDDATE>='2024-10-01' and SHOULDDATE<='2024-12-30'"; + logger.error("sql == " + sql ); + boolean count = rs.executeQuery(sql, "hr"); + logger.error("count == " + count ); + if(rs.next()){ + String sl = rs.getString("sl"); + logger.error("sl == " + sl ); + } - boolean b11 = rs.executeQuery(sql, "hr"); - logger.error("b11 == " + b11 ); +// String sql1 = "select ID,EMPLOYEEID,SHOULDDATE,SHOULDTIME,CARDCOUNT,CARDORDER from ATDPERSONCARDEXVIEW where extype='未刷卡' and SHOULDDATE>='2024-10-01' and SHOULDDATE<='2024-12-30'"; + String sql1 = "select top 50000 * " + + "from ( " + + "select row_number() over(order by id asc) as rownumber ,ID,EMPLOYEEID,SHOULDDATE,SHOULDTIME,CARDCOUNT,CARDORDER from ATDPERSONCARDEXVIEW where extype='未刷卡' and SHOULDDATE>='2024-10-01' and SHOULDDATE<='2024-12-30' " + + " ) temp_row "+ + "where rownumber>1000;"; + logger.error("sql1 == " + sql1 ); + boolean detail = rs.executeQuery(sql1, "hr"); + logger.error("detail == " + detail ); +// logger.error("rs.getExecuteResult == " + rs.getExecuteResult() ); if (rs.next()){ logger.error("EMPLOYEEID == " + rs.getString("EMPLOYEEID") ); } @@ -104,7 +118,7 @@ public class CustomTeAction extends BaseBean implements Action, EsbServerlessRpc // String sql1 = "select field1 from e10_common.dbo.uf_CustomFlow where field1 = 5 and delete_type = 0"; - String sql1 = "select id,field3 from eteams.dbo.hrmemployeedefined where FORM_DATA_ID= '100005650000063120' "; + sql1 = "select id,field3 from eteams.dbo.hrmemployeedefined where FORM_DATA_ID= '100005650000063120' "; // String sql1 = "select field3 from eteams.dbo.hrmemployeedefined where FORM_DATA_ID= '100005650000000052'"; String poolname = CONN_TYPE.hrm.getType(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java index d27163e..c736bc8 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java @@ -31,6 +31,8 @@ public class OperateAccountAction extends BaseBean implements Action, EsbServerl @Autowired private RequestInfo requestInfoTemp; + @Autowired + private AccountService service; private static final Logger logger_9c33175e = LoggerFactory.getLogger(OperateAccountAction.class); public OperateAccountAction() { @@ -96,7 +98,7 @@ public class OperateAccountAction extends BaseBean implements Action, EsbServerl paramInfo.setSystemid(sysid); paramInfo.setUserid(gh); param[0] = paramInfo; - AccountService service = new AccountService(); +// AccountService service = new AccountService(); String[] array = service.account("HT01EIP006", param); if ("E".equals(array[0])) { stat = "E"; diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/RemindForCarAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/RemindForCarAction.java index bc47097..e24b34d 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/RemindForCarAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/RemindForCarAction.java @@ -1,106 +1,151 @@ -//package com.weaver.seconddev.interfaces.workflow.action; -// -////import com.cloudstore.dev.api.bean.MessageBean; -////import com.cloudstore.dev.api.bean.MessageType; -////import com.cloudstore.dev.api.util.Util_Message; -//import java.util.ArrayList; -//import java.util.HashSet; -//import java.util.List; -//import com.weaver.common.i18n.tool.util.I18nContextUtil; -//import org.springframework.core.env.Environment; -//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; -// +package com.weaver.seconddev.interfaces.workflow.action; + +//import com.cloudstore.dev.api.bean.MessageBean; +//import com.cloudstore.dev.api.bean.MessageType; +//import com.cloudstore.dev.api.util.Util_Message; +import java.util.ArrayList; +import java.util.HashSet; +import java.util.List; + +import com.alibaba.fastjson.JSONObject; +import com.weaver.common.i18n.tool.util.I18nContextUtil; +import com.weaver.mc.api.async.AsyncSystemMessageRest; +import com.weaver.mc.api.entity.MessageEvent; +import com.weaver.mc.api.entity.MessageModule; +import com.weaver.mc.api.entity.SendMessageEntity; +import com.weaver.mc.api.entity.UserEntity; +import com.weaver.openapi.pojo.ApiResult; +import com.weaver.openapi.pojo.message.params.MessageVo; +import com.weaver.openapi.pojo.message.params.vo.MessageEntity; +import com.weaver.openapi.pojo.message.params.vo.MessageReciver; +import com.weaver.openapi.pojo.message.params.vo.MessageSender; +import com.weaver.openapi.service.MessageService; +import com.weaver.seconddev.interfaces.prop.ConfigProp; +import org.springframework.core.env.Environment; +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 -//@org.springframework.stereotype.Service("workflow_action_RemindForCarAction") -//public class RemindForCarAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { -// -// // 对应E9的请求信息对象 -// @Autowired -// private RequestInfo requestInfoTemp; -// -// private static final Logger logger_9618d585 = LoggerFactory.getLogger(RemindForCarAction.class); -// -// public WeaResult> execute(Map requestInfoMap) { -// Map weaverResultMap = new HashMap<>(); -// Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1))); -// 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 ")); +@org.springframework.stereotype.Service("workflow_action_RemindForCarAction") +public class RemindForCarAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { + + // 对应E9的请求信息对象 + @Autowired + private RequestInfo requestInfoTemp; + @Autowired + private ConfigProp configProp; + + @Autowired + private AsyncSystemMessageRest systemMessageRest; + + private static final Logger logger_9618d585 = LoggerFactory.getLogger(RemindForCarAction.class); + + public WeaResult> execute(Map requestInfoMap) { + Map weaverResultMap = new HashMap<>(); + Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1))); + 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 requestId = request.getRequestid(); -// List list = new ArrayList(); -// // 获取主表数据 -// Property[] aproperty = request.getMainTableInfo().getProperty(); -// for (int i = 0; i < aproperty.length; i++) { -// String name = aproperty[i].getName().toUpperCase(); -// String value = Util.null2String(aproperty[i].getValue()); -// if (name.equals("SQR")) { -// // 申请人 -// if (!"".equals(value)) { -// list.add(value); -// } -// } -// /*if(name.equals("CCRY")){//乘车人员 -// if(!"".equals(value)){ -// String[] array = value.split(","); -// for(int k=0;k 0){ -// HashSet h = new HashSet(list); -// list.clear(); -// list.addAll(h); -// }*/ -// // InterfaceUtil.sendMsg(list, ",28ffc89713a64541891276edc32131cc,", requestId, content, 1); + String content = configProp.getCarmessage(); + String requestId = request.getRequestid(); + List list = new ArrayList(); + // 获取主表数据 + Property[] aproperty = request.getMainTableInfo().getProperty(); + for (int i = 0; i < aproperty.length; i++) { + String name = aproperty[i].getName().toUpperCase(); + String value = Util.null2String(aproperty[i].getValue()); + if (name.equals("SQR")) { + // 申请人 + if (!"".equals(value)) { + list.add(value); + } + } + /*if(name.equals("CCRY")){//乘车人员 + if(!"".equals(value)){ + String[] array = value.split(","); + for(int k=0;k 0){ + HashSet h = new HashSet(list); + list.clear(); + list.addAll(h); + }*/ + + // InterfaceUtil.sendMsg(list, ",28ffc89713a64541891276edc32131cc,", requestId, content, 1); + + //TODO config // MessageType messageType = MessageType.newInstance(506); // MessageBean messageBean = Util_Message.createMessage(messageType, new HashSet(list), content, content, "", ""); // messageBean.setCreater(1); // Util_Message.store(messageBean); -// logger_9618d585.info(String.valueOf("do RemindForCarAction success ")); -// } catch (Exception e) { -// 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(), requestInfo.getRequestManager())), request.getRequestManager())); -// } -// } -// -// Map getResultMapForAction(Map 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; -// } -//} + + list.forEach(item->{ + + }); + + List receivers = new ArrayList<>(); +// receivers.add() + + 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("");//可以为空 + smg.setAppUrl("");//可以为空 + smg.setTitle("任务提醒"); + smg.setContent(content); + WeaResult longWeaResult = systemMessageRest.sendMsg(smg); + + + + logger_9618d585.info(String.valueOf("do RemindForCarAction success ")); + } catch (Exception e) { + 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 getResultMapForAction(Map 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; + } +}