|
@@ -9,6 +9,7 @@ import com.x.base.core.container.EntityManagerContainer;
|
|
|
import com.x.base.core.container.factory.EntityManagerContainerFactory;
|
|
import com.x.base.core.container.factory.EntityManagerContainerFactory;
|
|
|
import com.x.base.core.entity.annotation.CheckPersistType;
|
|
import com.x.base.core.entity.annotation.CheckPersistType;
|
|
|
import com.x.base.core.project.config.Config;
|
|
import com.x.base.core.project.config.Config;
|
|
|
|
|
+import com.x.base.core.project.gson.XGsonBuilder;
|
|
|
import com.x.base.core.project.http.ActionResult;
|
|
import com.x.base.core.project.http.ActionResult;
|
|
|
import com.x.base.core.project.http.EffectivePerson;
|
|
import com.x.base.core.project.http.EffectivePerson;
|
|
|
import com.x.base.core.project.jaxrs.WrapBoolean;
|
|
import com.x.base.core.project.jaxrs.WrapBoolean;
|
|
@@ -18,6 +19,7 @@ import com.x.base.core.project.message.MessageConnector;
|
|
|
import com.x.base.core.project.tools.ListTools;
|
|
import com.x.base.core.project.tools.ListTools;
|
|
|
import com.x.message.assemble.communicate.Business;
|
|
import com.x.message.assemble.communicate.Business;
|
|
|
import com.x.message.assemble.communicate.ThisApplication;
|
|
import com.x.message.assemble.communicate.ThisApplication;
|
|
|
|
|
+import com.x.message.core.entity.Instant;
|
|
|
import com.x.message.core.entity.Message;
|
|
import com.x.message.core.entity.Message;
|
|
|
|
|
|
|
|
class ActionCreate extends BaseAction {
|
|
class ActionCreate extends BaseAction {
|
|
@@ -30,71 +32,73 @@ class ActionCreate extends BaseAction {
|
|
|
ActionResult<Wo> result = new ActionResult<>();
|
|
ActionResult<Wo> result = new ActionResult<>();
|
|
|
Wi wi = this.convertToWrapIn(jsonElement, Wi.class);
|
|
Wi wi = this.convertToWrapIn(jsonElement, Wi.class);
|
|
|
List<String> consumers = Config.messages().getConsumers(wi.getType());
|
|
List<String> consumers = Config.messages().getConsumers(wi.getType());
|
|
|
|
|
+ Instant instant = this.instant(effectivePerson, business, wi, consumers);
|
|
|
|
|
+ List<Message> messages = new ArrayList<>();
|
|
|
if (ListTools.isNotEmpty(consumers)) {
|
|
if (ListTools.isNotEmpty(consumers)) {
|
|
|
- List<Message> messages = new ArrayList<>();
|
|
|
|
|
- emc.beginTransaction(Message.class);
|
|
|
|
|
for (String consumer : consumers) {
|
|
for (String consumer : consumers) {
|
|
|
Message message = null;
|
|
Message message = null;
|
|
|
switch (Objects.toString(consumer, "")) {
|
|
switch (Objects.toString(consumer, "")) {
|
|
|
- case MessageConnector.CONSUME_IM:
|
|
|
|
|
- message = this.imMessage(effectivePerson, business, wi);
|
|
|
|
|
|
|
+ case MessageConnector.CONSUME_WS:
|
|
|
|
|
+ message = this.wsMessage(effectivePerson, business, wi, instant);
|
|
|
break;
|
|
break;
|
|
|
case MessageConnector.CONSUME_PMS:
|
|
case MessageConnector.CONSUME_PMS:
|
|
|
- message = this.pmsMessage(effectivePerson, business, wi);
|
|
|
|
|
|
|
+ message = this.pmsMessage(effectivePerson, business, wi, instant);
|
|
|
break;
|
|
break;
|
|
|
case MessageConnector.CONSUME_DINGDING:
|
|
case MessageConnector.CONSUME_DINGDING:
|
|
|
- message = this.dingdingMessage(effectivePerson, business, wi);
|
|
|
|
|
|
|
+ message = this.dingdingMessage(effectivePerson, business, wi, instant);
|
|
|
break;
|
|
break;
|
|
|
case MessageConnector.CONSUME_ZHENGWUDINGDING:
|
|
case MessageConnector.CONSUME_ZHENGWUDINGDING:
|
|
|
- message = this.zhegnwudingdingMessage(effectivePerson, business, wi);
|
|
|
|
|
|
|
+ message = this.zhegnwudingdingMessage(effectivePerson, business, wi, instant);
|
|
|
break;
|
|
break;
|
|
|
case MessageConnector.CONSUME_QIYEWEIXIN:
|
|
case MessageConnector.CONSUME_QIYEWEIXIN:
|
|
|
- message = this.qiyeweixinMessage(effectivePerson, business, wi);
|
|
|
|
|
|
|
+ message = this.qiyeweixinMessage(effectivePerson, business, wi, instant);
|
|
|
break;
|
|
break;
|
|
|
case MessageConnector.CONSUME_CALENDAR:
|
|
case MessageConnector.CONSUME_CALENDAR:
|
|
|
- message = this.calendarMessage(effectivePerson, business, wi);
|
|
|
|
|
|
|
+ message = this.calendarMessage(effectivePerson, business, wi, instant);
|
|
|
break;
|
|
break;
|
|
|
default:
|
|
default:
|
|
|
- message = this.defaultMessage(effectivePerson, business, wi, consumer);
|
|
|
|
|
|
|
+ message = this.defaultMessage(effectivePerson, business, wi, consumer, instant);
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
- emc.persist(message, CheckPersistType.all);
|
|
|
|
|
messages.add(message);
|
|
messages.add(message);
|
|
|
}
|
|
}
|
|
|
- emc.commit();
|
|
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|
+ emc.beginTransaction(Instant.class);
|
|
|
|
|
+ emc.persist(instant, CheckPersistType.all);
|
|
|
|
|
+ if (ListTools.isNotEmpty(messages)) {
|
|
|
|
|
+ emc.beginTransaction(Message.class);
|
|
|
for (Message message : messages) {
|
|
for (Message message : messages) {
|
|
|
- switch (message.getConsumer()) {
|
|
|
|
|
- case MessageConnector.CONSUME_IM:
|
|
|
|
|
- ThisApplication.imConsumeQueue.send(message);
|
|
|
|
|
- break;
|
|
|
|
|
- case MessageConnector.CONSUME_PMS:
|
|
|
|
|
- ThisApplication.pmsConsumeQueue.send(message);
|
|
|
|
|
- break;
|
|
|
|
|
- case MessageConnector.CONSUME_DINGDING:
|
|
|
|
|
- ThisApplication.dingdingConsumeQueue.send(message);
|
|
|
|
|
- break;
|
|
|
|
|
- case MessageConnector.CONSUME_ZHENGWUDINGDING:
|
|
|
|
|
- ThisApplication.zhengwuDingdingConsumeQueue.send(message);
|
|
|
|
|
- break;
|
|
|
|
|
- case MessageConnector.CONSUME_QIYEWEIXIN:
|
|
|
|
|
- ThisApplication.qiyeweixinConsumeQueue.send(message);
|
|
|
|
|
- break;
|
|
|
|
|
- case MessageConnector.CONSUME_CALENDAR:
|
|
|
|
|
- ThisApplication.calendarConsumeQueue.send(message);
|
|
|
|
|
- break;
|
|
|
|
|
- default:
|
|
|
|
|
- break;
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ emc.persist(message, CheckPersistType.all);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ emc.commit();
|
|
|
|
|
+
|
|
|
|
|
+ /* 开始发送,由于要回写所以先要commit */
|
|
|
|
|
+ for (Message message : messages) {
|
|
|
|
|
+ switch (message.getConsumer()) {
|
|
|
|
|
+ case MessageConnector.CONSUME_WS:
|
|
|
|
|
+ ThisApplication.wsConsumeQueue.send(message);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case MessageConnector.CONSUME_PMS:
|
|
|
|
|
+ ThisApplication.pmsConsumeQueue.send(message);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case MessageConnector.CONSUME_DINGDING:
|
|
|
|
|
+ ThisApplication.dingdingConsumeQueue.send(message);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case MessageConnector.CONSUME_ZHENGWUDINGDING:
|
|
|
|
|
+ ThisApplication.zhengwuDingdingConsumeQueue.send(message);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case MessageConnector.CONSUME_QIYEWEIXIN:
|
|
|
|
|
+ ThisApplication.qiyeweixinConsumeQueue.send(message);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case MessageConnector.CONSUME_CALENDAR:
|
|
|
|
|
+ ThisApplication.calendarConsumeQueue.send(message);
|
|
|
|
|
+ break;
|
|
|
|
|
+ default:
|
|
|
|
|
+ break;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
-// this.im_consume(effectivePerson, business, message);
|
|
|
|
|
-// this.pms_consume(effectivePerson, business, message);
|
|
|
|
|
-// this.calendar_consume(effectivePerson, business, message);
|
|
|
|
|
-// this.dingding_consume(effectivePerson, business, message);
|
|
|
|
|
-// this.qiyeweixin_consume(effectivePerson, business, message);
|
|
|
|
|
-// this.zhengwudingding_consume(effectivePerson, business, message);
|
|
|
|
|
|
|
|
|
|
Wo wo = new Wo();
|
|
Wo wo = new Wo();
|
|
|
wo.setValue(true);
|
|
wo.setValue(true);
|
|
@@ -103,210 +107,102 @@ class ActionCreate extends BaseAction {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message imMessage(EffectivePerson effectivePerson, Business business, Wi wi) {
|
|
|
|
|
|
|
+ private Instant instant(EffectivePerson effectivePerson, Business business, Wi wi, List<String> consumers) {
|
|
|
|
|
+ Instant instant = new Instant();
|
|
|
|
|
+ instant.setBody(Objects.toString(wi.getBody()));
|
|
|
|
|
+ instant.setType(wi.getType());
|
|
|
|
|
+ instant.setPerson(wi.getPerson());
|
|
|
|
|
+ instant.setTitle(wi.getTitle());
|
|
|
|
|
+ instant.setConsumerList(consumers);
|
|
|
|
|
+ instant.setConsumed(false);
|
|
|
|
|
+ return instant;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ private Message wsMessage(EffectivePerson effectivePerson, Business business, Wi wi, Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
- message.setConsumer(MessageConnector.CONSUME_IM);
|
|
|
|
|
|
|
+ message.setConsumer(MessageConnector.CONSUME_WS);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message pmsMessage(EffectivePerson effectivePerson, Business business, Wi wi) {
|
|
|
|
|
|
|
+ private Message pmsMessage(EffectivePerson effectivePerson, Business business, Wi wi, Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
message.setConsumer(MessageConnector.CONSUME_PMS);
|
|
message.setConsumer(MessageConnector.CONSUME_PMS);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message dingdingMessage(EffectivePerson effectivePerson, Business business, Wi wi) {
|
|
|
|
|
|
|
+ private Message dingdingMessage(EffectivePerson effectivePerson, Business business, Wi wi, Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
message.setConsumer(MessageConnector.CONSUME_DINGDING);
|
|
message.setConsumer(MessageConnector.CONSUME_DINGDING);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message zhegnwudingdingMessage(EffectivePerson effectivePerson, Business business, Wi wi) {
|
|
|
|
|
|
|
+ private Message zhegnwudingdingMessage(EffectivePerson effectivePerson, Business business, Wi wi, Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
message.setConsumer(MessageConnector.CONSUME_ZHENGWUDINGDING);
|
|
message.setConsumer(MessageConnector.CONSUME_ZHENGWUDINGDING);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message qiyeweixinMessage(EffectivePerson effectivePerson, Business business, Wi wi) {
|
|
|
|
|
|
|
+ private Message qiyeweixinMessage(EffectivePerson effectivePerson, Business business, Wi wi, Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
message.setConsumer(MessageConnector.CONSUME_QIYEWEIXIN);
|
|
message.setConsumer(MessageConnector.CONSUME_QIYEWEIXIN);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message calendarMessage(EffectivePerson effectivePerson, Business business, Wi wi) {
|
|
|
|
|
|
|
+ private Message calendarMessage(EffectivePerson effectivePerson, Business business, Wi wi, Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
message.setConsumer(MessageConnector.CONSUME_CALENDAR);
|
|
message.setConsumer(MessageConnector.CONSUME_CALENDAR);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private Message defaultMessage(EffectivePerson effectivePerson, Business business, Wi wi, String consumer) {
|
|
|
|
|
|
|
+ private Message defaultMessage(EffectivePerson effectivePerson, Business business, Wi wi, String consumer,
|
|
|
|
|
+ Instant instant) {
|
|
|
Message message = new Message();
|
|
Message message = new Message();
|
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
message.setBody(Objects.toString(wi.getBody()));
|
|
|
message.setType(wi.getType());
|
|
message.setType(wi.getType());
|
|
|
message.setPerson(wi.getPerson());
|
|
message.setPerson(wi.getPerson());
|
|
|
message.setTitle(wi.getTitle());
|
|
message.setTitle(wi.getTitle());
|
|
|
message.setConsumer(consumer);
|
|
message.setConsumer(consumer);
|
|
|
|
|
+ message.setConsumed(false);
|
|
|
|
|
+ message.setInstant(instant.getId());
|
|
|
return message;
|
|
return message;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// private void dingding_consume(EffectivePerson effectivePerson, Business business, Message message) {
|
|
|
|
|
-// try {
|
|
|
|
|
-// if (ListTools.contains(message.getConsumerList(), MessageConnector.CONSUME_DINGDING)) {
|
|
|
|
|
-// message.getConsumerList().remove(MessageConnector.CONSUME_DINGDING);
|
|
|
|
|
-// if (Config.dingding().getEnable() && Config.dingding().getMessageEnable()) {
|
|
|
|
|
-// DingdingMessage m = new DingdingMessage();
|
|
|
|
|
-// m.setAgent_id(Long.parseLong(Config.dingding().getAgentId(), 10));
|
|
|
|
|
-// m.setUserid_list(business.organization().person().getObject(message.getPerson()).getDingdingId());
|
|
|
|
|
-// m.getMsg().getText().setContent(message.getTitle());
|
|
|
|
|
-// // https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2?access_token=ACCESS_TOKEN
|
|
|
|
|
-// String address = Config.dingding().getOapiAddress()
|
|
|
|
|
-// + "/topapi/message/corpconversation/asyncsend_v2?access_token="
|
|
|
|
|
-// + Config.dingding().corpAccessToken();
|
|
|
|
|
-// DingdingMessageResp resp = HttpConnection.postAsObject(address, null, m.toString(),
|
|
|
|
|
-// DingdingMessageResp.class);
|
|
|
|
|
-// if (resp.getErrcode() != 0) {
|
|
|
|
|
-// throw new ExceptionDingdingMessage(resp.getErrcode(), resp.getErrmsg());
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
|
-// logger.error(e);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// private void zhengwudingding_consume(EffectivePerson effectivePerson, Business business, Message message) {
|
|
|
|
|
-// try {
|
|
|
|
|
-// if (ListTools.contains(message.getConsumerList(), MessageConnector.CONSUME_ZHENGWUDINGDING)) {
|
|
|
|
|
-// message.getConsumerList().remove(MessageConnector.CONSUME_ZHENGWUDINGDING);
|
|
|
|
|
-// if (Config.zhengwuDingding().getEnable() && Config.zhengwuDingding().getMessageEnable()) {
|
|
|
|
|
-// ZhengwuDingdingMessage m = new ZhengwuDingdingMessage();
|
|
|
|
|
-// m.setAgentId(Long.parseLong(Config.zhengwuDingding().getAgentId(), 10));
|
|
|
|
|
-// m.setTouser(business.organization().person().getObject(message.getPerson()).getZhengwuDingdingId());
|
|
|
|
|
-// m.getMsg().getText().setContent(message.getTitle());
|
|
|
|
|
-// String address = Config.zhengwuDingding().getOapiAddress() + "/ent_message/send?access_token="
|
|
|
|
|
-// + Config.zhengwuDingding().appAccessToken();
|
|
|
|
|
-// ZhengwuDingdingMessageResp resp = HttpConnection.postAsObject(address, null, m.toString(),
|
|
|
|
|
-// ZhengwuDingdingMessageResp.class);
|
|
|
|
|
-// if (resp.getRetCode() != 0) {
|
|
|
|
|
-// throw new ExceptionZhengwuDingdingMessage(resp.getRetCode(), resp.getRetMessage());
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
|
-// logger.error(e);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// private void qiyeweixin_consume(EffectivePerson effectivePerson, Business business, Message message) {
|
|
|
|
|
-// try {
|
|
|
|
|
-// if (ListTools.contains(message.getConsumerList(), MessageConnector.CONSUME_QIYEWEIXIN)) {
|
|
|
|
|
-// message.getConsumerList().remove(MessageConnector.CONSUME_QIYEWEIXIN);
|
|
|
|
|
-// if (Config.qiyeweixin().getEnable() && Config.qiyeweixin().getMessageEnable()) {
|
|
|
|
|
-// QiyeweixinMessage m = new QiyeweixinMessage();
|
|
|
|
|
-// m.setAgentid(Long.parseLong(Config.qiyeweixin().getAgentId(), 10));
|
|
|
|
|
-// m.setTouser(business.organization().person().getObject(message.getPerson()).getQiyeweixinId());
|
|
|
|
|
-// m.getText().setContent(message.getTitle());
|
|
|
|
|
-// String address = Config.qiyeweixin().getApiAddress() + "/cgi-bin/message/send?access_token="
|
|
|
|
|
-// + Config.qiyeweixin().corpAccessToken();
|
|
|
|
|
-// QiyeweixinMessageResp resp = HttpConnection.postAsObject(address, null, m.toString(),
|
|
|
|
|
-// QiyeweixinMessageResp.class);
|
|
|
|
|
-// if (resp.getErrcode() != 0) {
|
|
|
|
|
-// throw new ExceptionQiyeweixinMessage(resp.getErrcode(), resp.getErrmsg());
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
|
-// logger.error(e);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// private void im_consume(EffectivePerson effectivePerson, Business business, Message message) {
|
|
|
|
|
-// try {
|
|
|
|
|
-// if (ListTools.contains(message.getConsumerList(), MessageConnector.CONSUME_IM)) {
|
|
|
|
|
-// ImMessage im = new ImMessage();
|
|
|
|
|
-// im.setType(message.getType());
|
|
|
|
|
-// im.setPerson(message.getPerson());
|
|
|
|
|
-// im.setTitle(message.getTitle());
|
|
|
|
|
-// im.setBody(gson.fromJson(message.getBody(), JsonElement.class));
|
|
|
|
|
-// for (Application app : ThisApplication.context().applications()
|
|
|
|
|
-// .get(x_message_assemble_communicate.class)) {
|
|
|
|
|
-// WrapBoolean wrapBoolean = ThisApplication.context().applications()
|
|
|
|
|
-// .postQuery(effectivePerson.getDebugger(), app, MessageConnector.CONSUME_IM, im)
|
|
|
|
|
-// .getData(WrapBoolean.class);
|
|
|
|
|
-// if (BooleanUtils.isTrue(wrapBoolean.getValue())) {
|
|
|
|
|
-// message.getConsumerList().remove(MessageConnector.CONSUME_IM);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
|
-// logger.error(e);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// private void pms_consume(EffectivePerson effectivePerson, Business business, Message message) {
|
|
|
|
|
-// try {
|
|
|
|
|
-// if (ListTools.contains(message.getConsumerList(), MessageConnector.CONSUME_PMS)) {
|
|
|
|
|
-// message.getConsumerList().remove(MessageConnector.CONSUME_PMS);
|
|
|
|
|
-// Person person = business.organization().person().getObject(message.getPerson());
|
|
|
|
|
-// if ((null != person) && StringUtils.isNotEmpty(person.getMobile())) {
|
|
|
|
|
-// PmsMessage pms = new PmsMessage();
|
|
|
|
|
-// pms.setAccount(person.getMobile());
|
|
|
|
|
-// pms.setTitle(message.getTitle());
|
|
|
|
|
-// pms.setText(message.getTitle());
|
|
|
|
|
-// String url = Config.x_program_centerUrlRoot() + MessageConnector.CONSUME_PMS;
|
|
|
|
|
-// CipherConnectionAction.post(effectivePerson.getDebugger(), url, pms);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
|
-// logger.error(e);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// private void calendar_consume(EffectivePerson effectivePerson, Business business, Message message) {
|
|
|
|
|
-// try {
|
|
|
|
|
-// if (ListTools.contains(message.getConsumerList(), MessageConnector.CONSUME_CALENDAR)) {
|
|
|
|
|
-// Application app = ThisApplication.context().applications()
|
|
|
|
|
-// .randomWithWeight(x_calendar_assemble_control.class.getName());
|
|
|
|
|
-// if (null != app) {
|
|
|
|
|
-// WrapBoolean wrapBoolean = ThisApplication.context().applications()
|
|
|
|
|
-// .postQuery(effectivePerson.getDebugger(), app, "message", message)
|
|
|
|
|
-// .getData(WrapBoolean.class);
|
|
|
|
|
-// if (BooleanUtils.isTrue(wrapBoolean.getValue())) {
|
|
|
|
|
-// message.getConsumerList().remove(MessageConnector.CONSUME_CALENDAR);
|
|
|
|
|
-// }
|
|
|
|
|
-// } else {
|
|
|
|
|
-// throw new ExceptionCalendarApplicationNotFound();
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
|
-// logger.error(e);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-
|
|
|
|
|
public static class Wi extends MessageConnector.Wrap {
|
|
public static class Wi extends MessageConnector.Wrap {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -314,166 +210,4 @@ class ActionCreate extends BaseAction {
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// public static class ZhengwuDingdingMessageResp {
|
|
|
|
|
-//
|
|
|
|
|
-// private Integer retCode;
|
|
|
|
|
-// private String retMessage;
|
|
|
|
|
-// private RetData retData;
|
|
|
|
|
-//
|
|
|
|
|
-// public static class RetData {
|
|
|
|
|
-// private String invaliduser;
|
|
|
|
|
-// private String invalidparty;
|
|
|
|
|
-// private String errorparty;
|
|
|
|
|
-// private String erroruser;
|
|
|
|
|
-//
|
|
|
|
|
-// public String getInvaliduser() {
|
|
|
|
|
-// return invaliduser;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setInvaliduser(String invaliduser) {
|
|
|
|
|
-// this.invaliduser = invaliduser;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getInvalidparty() {
|
|
|
|
|
-// return invalidparty;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setInvalidparty(String invalidparty) {
|
|
|
|
|
-// this.invalidparty = invalidparty;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getErrorparty() {
|
|
|
|
|
-// return errorparty;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setErrorparty(String errorparty) {
|
|
|
|
|
-// this.errorparty = errorparty;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getErroruser() {
|
|
|
|
|
-// return erroruser;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setErroruser(String erroruser) {
|
|
|
|
|
-// this.erroruser = erroruser;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public Integer getRetCode() {
|
|
|
|
|
-// return retCode;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setRetCode(Integer retCode) {
|
|
|
|
|
-// this.retCode = retCode;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getRetMessage() {
|
|
|
|
|
-// return retMessage;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setRetMessage(String retMessage) {
|
|
|
|
|
-// this.retMessage = retMessage;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public RetData getRetData() {
|
|
|
|
|
-// return retData;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setRetData(RetData retData) {
|
|
|
|
|
-// this.retData = retData;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// }
|
|
|
|
|
-
|
|
|
|
|
-// public static class DingdingMessageResp {
|
|
|
|
|
-//
|
|
|
|
|
-// private Integer errcode;
|
|
|
|
|
-// private String errmsg;
|
|
|
|
|
-// private Long task_id;
|
|
|
|
|
-//
|
|
|
|
|
-// public String getErrmsg() {
|
|
|
|
|
-// return errmsg;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setErrmsg(String errmsg) {
|
|
|
|
|
-// this.errmsg = errmsg;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public Long getTask_id() {
|
|
|
|
|
-// return task_id;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setTask_id(Long task_id) {
|
|
|
|
|
-// this.task_id = task_id;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public Integer getErrcode() {
|
|
|
|
|
-// return errcode;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setErrcode(Integer errcode) {
|
|
|
|
|
-// this.errcode = errcode;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// }
|
|
|
|
|
-
|
|
|
|
|
-// public static class QiyeweixinMessageResp {
|
|
|
|
|
-//
|
|
|
|
|
-// // {
|
|
|
|
|
-// // "errcode" : 0,
|
|
|
|
|
-// // "errmsg" : "ok",
|
|
|
|
|
-// // "invaliduser" : "userid1|userid2", // 不区分大小写,返回的列表都统一转为小写
|
|
|
|
|
-// // "invalidparty" : "partyid1|partyid2",
|
|
|
|
|
-// // "invalidtag":"tagid1|tagid2"
|
|
|
|
|
-// // }
|
|
|
|
|
-//
|
|
|
|
|
-// private Integer errcode;
|
|
|
|
|
-// private String errmsg;
|
|
|
|
|
-// private String invaliduser;
|
|
|
|
|
-// private String invalidparty;
|
|
|
|
|
-// private String invalidtag;
|
|
|
|
|
-//
|
|
|
|
|
-// public String getErrmsg() {
|
|
|
|
|
-// return errmsg;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setErrmsg(String errmsg) {
|
|
|
|
|
-// this.errmsg = errmsg;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getInvaliduser() {
|
|
|
|
|
-// return invaliduser;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setInvaliduser(String invaliduser) {
|
|
|
|
|
-// this.invaliduser = invaliduser;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getInvalidparty() {
|
|
|
|
|
-// return invalidparty;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setInvalidparty(String invalidparty) {
|
|
|
|
|
-// this.invalidparty = invalidparty;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public String getInvalidtag() {
|
|
|
|
|
-// return invalidtag;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setInvalidtag(String invalidtag) {
|
|
|
|
|
-// this.invalidtag = invalidtag;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public Integer getErrcode() {
|
|
|
|
|
-// return errcode;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// public void setErrcode(Integer errcode) {
|
|
|
|
|
-// this.errcode = errcode;
|
|
|
|
|
-// }
|
|
|
|
|
-//
|
|
|
|
|
-// }
|
|
|
|
|
-
|
|
|
|
|
}
|
|
}
|