Commit ede647c3 by 王祖波

数据导出消息

parent e362a1cc
...@@ -99,7 +99,9 @@ public enum NoticeMessageTypeEnum { ...@@ -99,7 +99,9 @@ public enum NoticeMessageTypeEnum {
CASH_APPLY_OFFLINE_SUCCESS_NOTIFY(7003,"提现通知", NoticeMessageCategoryTypeEnum.OTHER.getType(),"cash_apply_offline_success_notify","/pages/route/index?pageType=","hbapp_withdraw_list","cashApplyOfflineSuccessNotify","haobanNotice"), CASH_APPLY_OFFLINE_SUCCESS_NOTIFY(7003,"提现通知", NoticeMessageCategoryTypeEnum.OTHER.getType(),"cash_apply_offline_success_notify","/pages/route/index?pageType=","hbapp_withdraw_list","cashApplyOfflineSuccessNotify","haobanNotice"),
AUTHORIZED_LOGIN_NOTIFY(8001,"账号授权通知", NoticeMessageCategoryTypeEnum.AUTHORIZED.getType(),"authorized_login_notify","/pages/route/index?pageType=","hbapp_video_auth","authorizedLoginNotify","haobanNotice"), AUTHORIZED_LOGIN_NOTIFY(8001,"账号授权通知", NoticeMessageCategoryTypeEnum.AUTHORIZED.getType(),"authorized_login_notify","/pages/route/index?pageType=","hbapp_video_auth","authorizedLoginNotify","haobanNotice"),
AUTHORIZED_LOGOUT_NOTIFY(8002,"账号异常退出登录通知", NoticeMessageCategoryTypeEnum.AUTHORIZED.getType(),"authorized_logout_notify","/pages/route/index?pageType=","hbapp_video_auth","authorizedLogoutNotify","haobanNotice"); AUTHORIZED_LOGOUT_NOTIFY(8002,"账号异常退出登录通知", NoticeMessageCategoryTypeEnum.AUTHORIZED.getType(),"authorized_logout_notify","/pages/route/index?pageType=","hbapp_video_auth","authorizedLogoutNotify","haobanNotice"),
DATA_EXPORT_NOTIFY(9001,"数据导出通知", NoticeMessageCategoryTypeEnum.OTHER.getType(),"data_export_notify","/pages/route/index?pageType=","hbapp_data_export","dataExportNotify","haobanNotice");
/** /**
* 消息类型 * 消息类型
......
package com.gic.haoban.manage.api.util.notify; package com.gic.haoban.manage.api.util.notify;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.gic.commons.util.GICMQClientUtil; import com.gic.commons.util.GICMQClientUtil;
import com.gic.haoban.manage.api.dto.notify.qdto.NoticeMessageQDTO; import com.gic.haoban.manage.api.dto.notify.qdto.NoticeMessageQDTO;
...@@ -12,9 +13,7 @@ import org.slf4j.Logger; ...@@ -12,9 +13,7 @@ import org.slf4j.Logger;
import java.io.UnsupportedEncodingException; import java.io.UnsupportedEncodingException;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.ArrayList; import java.util.*;
import java.util.List;
import java.util.Map;
import static org.slf4j.LoggerFactory.getLogger; import static org.slf4j.LoggerFactory.getLogger;
...@@ -145,6 +144,15 @@ public class NoticeMessageUtil { ...@@ -145,6 +144,15 @@ public class NoticeMessageUtil {
} }
} }
public static void sendDataExportNotify(String enterpriseId, String clerkId, String taskName, Date exportTime) {
Map<String, String> contentMap = new HashMap<String, String>();
contentMap.put("taskName", taskName);
contentMap.put("exportTime", DateUtil.formatDateTime(exportTime));
Map<String, Object> extendContent = new HashMap<>();
NoticeMessageUtil.sendNoticeMessage(enterpriseId,clerkId,NoticeMessageTypeEnum.DATA_EXPORT_NOTIFY.getType(),null,
contentMap,extendContent);
}
/** /**
* 构建小程序跳转url * 构建小程序跳转url
* @param messageTypeEnum * @param messageTypeEnum
......
...@@ -3,6 +3,8 @@ package com.gic.haoban.manage.service.service.message; ...@@ -3,6 +3,8 @@ package com.gic.haoban.manage.service.service.message;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.gic.commons.util.GICMQClientUtil; import com.gic.commons.util.GICMQClientUtil;
import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum;
import com.gic.haoban.manage.api.util.notify.NoticeMessageUtil;
import com.gic.message.center.api.subscribe.model.NoticeMessageForm; import com.gic.message.center.api.subscribe.model.NoticeMessageForm;
import com.gic.mq.sdk.GicMQClient; import com.gic.mq.sdk.GicMQClient;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -11,6 +13,9 @@ import org.springframework.stereotype.Service; ...@@ -11,6 +13,9 @@ import org.springframework.stereotype.Service;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.LocalTime; import java.time.LocalTime;
import java.time.temporal.ChronoUnit; import java.time.temporal.ChronoUnit;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import static org.slf4j.LoggerFactory.getLogger; import static org.slf4j.LoggerFactory.getLogger;
......
...@@ -10,6 +10,7 @@ import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum; ...@@ -10,6 +10,7 @@ import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum;
import com.gic.haoban.manage.api.service.CheckQywxSettingApiService; import com.gic.haoban.manage.api.service.CheckQywxSettingApiService;
import com.gic.haoban.manage.api.service.QywxTagApiService; import com.gic.haoban.manage.api.service.QywxTagApiService;
import com.gic.haoban.manage.api.service.notify.NoticeMessageApiService; import com.gic.haoban.manage.api.service.notify.NoticeMessageApiService;
import com.gic.haoban.manage.api.util.notify.NoticeMessageUtil;
import com.gic.haoban.manage.service.config.Config; import com.gic.haoban.manage.service.config.Config;
import com.gic.haoban.manage.service.service.WxEnterpriseService; import com.gic.haoban.manage.service.service.WxEnterpriseService;
import com.gic.wechat.api.dto.qdto.group.QywxGroupMessageQDTO; import com.gic.wechat.api.dto.qdto.group.QywxGroupMessageQDTO;
...@@ -79,7 +80,7 @@ public class NotityTest { ...@@ -79,7 +80,7 @@ public class NotityTest {
@Test @Test
public void test2() { public void test2() {
NoticeMessageUtil.sendDataExportNotify("ff8080815dacd3a2015dacd3ef5c0000", "26efaa8144e14f60b2f4d48ffe9f708c", "导出测试", DateUtil.date());
} }
......
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