Skip to content

H
haoban-manage3.0
Commit 7e7af3a0 by 徐高华
Options

企微托管

parent 6c3e50be
Showing with 1959 additions and 4 deletions
haoban-manage3-operation-web/src/main/java/com/gic/haoban/manage/web/controller/QywxCallbackController.java
...@@ -141,7 +141,8 @@ public class QywxCallbackController extends WebBaseController { ...@@ -141,7 +141,8 @@ public class QywxCallbackController extends WebBaseController {
// 14 101 图片 // 14 101 图片
// 23 103(微信) 视频消息 // 23 103(微信) 视频消息
// 15 102(微信) 文件消息 // 15 102(微信) 文件消息
List<String> msgList = Arrays.asList("0","2","101","6","41","40","14","16","23","103","15","102") ; //104 gif表情消息类型
List<String> msgList = Arrays.asList("0","2","101","6","41","40","14","16","23","103","15","102","104") ;
if(!msgList.contains(msgtype+"")) { if(!msgList.contains(msgtype+"")) {
logger.info("不处理的消息"); logger.info("不处理的消息");
return ; return ;
...@@ -176,15 +177,15 @@ public class QywxCallbackController extends WebBaseController { ...@@ -176,15 +177,15 @@ public class QywxCallbackController extends WebBaseController {
}else if(msgtype==23 || msgtype==103){ }else if(msgtype==23 || msgtype==103){
msg.setMsgtype(OpenQwMsgTypeEnum.VIDEO); msg.setMsgtype(OpenQwMsgTypeEnum.VIDEO);
msg.setAeskey(json.getString("aes_key")); msg.setAeskey(json.getString("aes_key"));
}else if(msgtype==15 || msgtype==102){
msg.setMsgtype(OpenQwMsgTypeEnum.FILE);
msg.setAeskey(json.getString("aes_key"));
}else if(msgtype==6) { }else if(msgtype==6) {
msg.setMsgtype(OpenQwMsgTypeEnum.LOCAL); msg.setMsgtype(OpenQwMsgTypeEnum.LOCAL);
msg.setContent(json.getString("address")); msg.setContent(json.getString("address"));
}else if (msgtype==41) { }else if (msgtype==41) {
msg.setMsgtype(OpenQwMsgTypeEnum.NAME_CARD); msg.setMsgtype(OpenQwMsgTypeEnum.NAME_CARD);
msg.setContent(json.getString("nickname")); msg.setContent(json.getString("nickname"));
}else if (msgtype==15) {
msg.setMsgtype(OpenQwMsgTypeEnum.VIDEO);
msg.setContent(json.getString("nickname"));
}else if (msgtype==16) { }else if (msgtype==16) {
msg.setMsgtype(OpenQwMsgTypeEnum.VOICE); msg.setMsgtype(OpenQwMsgTypeEnum.VOICE);
msg.setContent(json.getString("语音消息")); msg.setContent(json.getString("语音消息"));
......
haoban-manage3-service/src/test/java/FileUtils.java 0 → 100644
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import com.alibaba.fastjson.JSONArray;
import org.apache.commons.lang3.StringUtils;
public class FileUtils {
public static void main(String[] args) {
System.out.println(JSONArray.parseArray(getText().toString()));
}
public static StringBuilder getText(){
StringBuilder list = new StringBuilder() ;
return list ;
}
}
haoban-manage3-service/src/test/java/FileUtils2.java 0 → 100644
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import org.apache.commons.lang3.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import cn.hutool.crypto.SecureUtil;
public class FileUtils2 {
public static void main(String[] args) {
System.out.println(SecureUtil.md5("2af5e413ec4e44c29b4bab61021071ba" + "wmNYNmCgAA7AohTQh62UPdSKyr3m9bIg"));
/*String s = getText();
JSONArray jsonArr = JSONObject.parseObject(s).getJSONArray("value");
System.out.println(JSON.toJSONString(jsonArr));*/
}
public static String getText(){
try {
BufferedReader bw = new BufferedReader(new FileReader(new File("c:\\b.txt"))) ;
StringBuilder sb = new StringBuilder() ;
while(true) {
String s = bw.readLine() ;
if(StringUtils.isBlank(s)) {
break ;
}else {
String ss = new String(s.getBytes(),"UTF-8") ;
sb.append(ss) ;
}
}
bw.close();
return sb.toString() ;
}catch(Exception e) {
}
return null ;
}
}
haoban-manage3-service/src/test/java/FileUtils3.java 0 → 100644
import org.apache.commons.lang3.StringUtils;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.util.ArrayList;
import java.util.List;
public class FileUtils3 {
public static void main(String[] args) {
System.out.println(getText().get(0));
}
public static List<String> getText(){
List<String> list = new ArrayList<>();
try {
BufferedReader bw = new BufferedReader(new FileReader(new File("c:\\b.txt"))) ;
StringBuilder sb = new StringBuilder() ;
while(true) {
String s = bw.readLine() ;
if(StringUtils.isBlank(s)) {
break ;
}else {
String ss = new String(s.getBytes(),"UTF-8") ;
list.add(ss) ;
}
}
bw.close();
}catch(Exception e) {
}
return list ;
}
}
haoban-manage3-service/src/test/java/FileUtils4.java 0 → 100644
import org.apache.commons.lang3.StringUtils;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.util.ArrayList;
import java.util.List;
public class FileUtils4 {
public static String getText(){
try {
BufferedReader bw = new BufferedReader(new FileReader(new File("c:\\c.txt"))) ;
StringBuilder sb = new StringBuilder() ;
while(true) {
String s = bw.readLine() ;
if(StringUtils.isBlank(s)) {
break ;
}else {
String ss = new String(s.getBytes(),"UTF-8") ;
sb.append(ss) ;
}
}
bw.close();
return sb.toString() ;
}catch(Exception e) {
}
return null ;
}
}
haoban-manage3-service/src/test/java/HalfFriendTest.java 0 → 100644
import com.gic.api.base.commons.BasePageInfo;
import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum;
import com.gic.haoban.manage.api.qdto.OpenStaffPageQDTO;
import com.gic.haoban.manage.api.service.HaobanTimerApiService;
import com.gic.haoban.manage.api.service.notify.NoticeMessageApiService;
import com.gic.haoban.manage.api.service.role.HaobanRoleApiService;
import com.gic.haoban.manage.api.util.notify.NoticeMessageUtil;
import com.gic.haoban.manage.service.service.OpenStaffService;
import com.gic.weimob.common.Md5Util;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.lang.reflect.Array;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class HalfFriendTest {
@Autowired
private OpenStaffService openStaffService ;
@Autowired
private NoticeMessageApiService noticeMessageApiService ;
@Test
public void tt() {
Map<String,String> map = new HashMap<>() ;
map.put("accountName","111222333111K") ;
map.put("errorTime","2024年4月20日 22:22") ;
map.put("reason","异常断开") ;
this.noticeMessageApiService.sendMessageForOpenStaff("ff8080815dacd3a2015dacd3ef5c0000","xgh","首次托管，需要二次验证");
/*OpenStaffPageQDTO qdto = new OpenStaffPageQDTO() ;
qdto.setWxEnterpriseId("ca66a01b79474c40b3e7c7f93daf1a3b");
qdto.setEnterpriseId("ff8080815dacd3a2015dacd3ef5c0000");
qdto.setClerkId("b2ef17cce11f476b996d0b27ebadf7fb");
qdto.setStoreGroupIdList(Arrays.asList("ff8080815dacd3a2015dacd3f4fc0033"));
qdto.setStaffParams("徐高华");
BasePageInfo basePageInfo = new BasePageInfo() ;
basePageInfo.setPageSize(11);
basePageInfo.setPageNum(1);
this.openStaffService.page(qdto,basePageInfo) ;*/
int messageType = NoticeMessageTypeEnum.HAOBAN_OPEN_STAFF_LOGOUT.getType();
// NoticeMessageUtil.sendNoticeMessageByStaff("ff8080815dacd3a2015dacd3ef5c0000","52995ea8c81c4cc286a9b82bc36a7081","-1",messageType,null,map,null);
}
}
haoban-manage3-service/src/test/java/HalfFriendTest123.java 0 → 100644
import com.gic.haoban.manage.api.service.HaobanTimerApiService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.Arrays;
import java.util.List;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class HalfFriendTest123 {
@Autowired
private HaobanTimerApiService haobanTimerApiService ;
@Test
public void tt() {
List<String> list = Arrays.asList("27f6a5b4ed474c7889f9f35efdd90acb",
"c2a7904f682343efb9bc1cae026888a3",
"8477c149d8774f06ab841f042645832b") ;
for (String s : list) {
this.haobanTimerApiService.halfTimer(s);
}
}
}
haoban-manage3-service/src/test/java/HalfFriendTest333.java 0 → 100644
import com.gic.haoban.manage.api.service.HaobanTimerApiService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.Arrays;
import java.util.List;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class HalfFriendTest333 {
@Autowired
private HaobanTimerApiService haobanTimerApiService ;
@Test
public void tt() {
List<String> list = Arrays.asList("93416e3a92504683b5b13513477a840a","369038a3568b46a6898d635843b73dc6","7f8c0c0eedd546ed9c4b355bb9cc2f31","9a7a89d2d1534c47980ea0886a202d3c") ;
for (String s : list) {
this.haobanTimerApiService.halfTimer(s);
}
}
}
haoban-manage3-service/src/test/java/HalfFriendTest444.java 0 → 100644
import com.gic.haoban.manage.api.service.HaobanTimerApiService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.Arrays;
import java.util.List;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class HalfFriendTest444 {
@Autowired
private HaobanTimerApiService haobanTimerApiService ;
@Test
public void tt() {
List<String> list = Arrays.asList(
"727f05dbe66d48009719f63a189b9965",
"31060eb76d7a42969516c7ff12f9a1ea",
"703207906c5942b0937f8eda35036e9b",
"7a11c347030342eba50d188b96b646c0") ;
for (String s : list) {
this.haobanTimerApiService.halfTimer(s);
}
}
}
haoban-manage3-service/src/test/java/HalfFriendTest55.java 0 → 100644
import com.gic.haoban.manage.api.service.HaobanTimerApiService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.Arrays;
import java.util.List;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class HalfFriendTest55 {
@Autowired
private HaobanTimerApiService haobanTimerApiService ;
@Test
public void tt() {
List<String> list = Arrays.asList(
"a0e2b8466e554aa88fa25e6f3757aa06",
"a253a78e2f1349fb9e8727015e48cd2b",
"d672eda301b2499a899902a02e55041c",
"626a8fd134ea4b91a83d472e0aba4081",
"9b5eda19379f412eaf1c55477910b792",
"2834fc85368847fd9c9614993a7a31a0",
"16e40d9a63814668873e36fa3bdd2d2a",
"e03b7089bfbf46cba60479f147adf6eb",
"2fdb7927db174a8e9d68c975538364d5",
"ac451a350eed4a96958dd5c7377f8bd9",
"89fd6ad36b3f4d0f9b06c856e4d91441",
"e0e12e08d62b47ac823b7d8d99fb9495",
"7c140f63c6c14acab2eac5290ed0c59d",
"c05df62cd6f844cea55778321c5552e5",
"784b6d7711664b278d7d73f92940958f",
"8bb1442e0f5943989cf9e5513acb1f03",
"f47cf73c887c444a909eb60feac0e6b2",
"cd688b9b915b4c4d81a967abf5ce2399",
"c50a57f2a59042e9aa4ff8361f2d61f7",
"f04df76f35a14d819fc7192d8d75d33a",
"2e5db471800b4c529e52dc4f98f6651a",
"9aad8308f8524b6cac451519f6d65792",
"5fff1b5ff62149f8bad5b10b141bcc6b",
"4e801e4b9cd4489389a4c12c30b5595f",
"8af6367375d643f4adf0bd255349d52a",
"abcd03d17eb349d491b983b09d678a4a",
"1dac964159694e4d9a8f03a3e6d65d75",
"46a4b60dea4b4b83a6ff81108c1d0d17",
"bf0f8b4351754819984ce12fbc3a8a4f",
"9900848270d6422c891c8b674c729a04",
"4119c628c1ab42da9c7976f405a0d013",
"3807d1017a1544d3be888e6108494dd2",
"f079bd6c985a4b8296ce1ba5b7a4e41e",
"acbfeb379b5242d5b2e44ab50e1047a1",
"4b18675afa7e4dfaa7b9c66b11ca6474",
"1d1e13c75d314c1fb01b97f104baf74b",
"7d1a509a3ad94a9f8c001ead0394e199",
"0dd77eacc16d4499a7310d0d663a27f6",
"8ee3e7e1016142fba939460fb9098c08",
"e9254b614d6e43ffa7c74094be1f07f2",
"0e33e5b6c97b46d39d3502335f227fed",
"e125f933481749828eb3b8bf9bb03801",
"8824ef05d5394f7085cf909141ef6d4c",
"b4fa8b82902944778c740c7fc08fd7bc",
"6dccb1983a8e400987d8608fb63db7b1",
"1cc9bc27a7b5483f9191f1f930b15987",
"7df48a749ec1457594e85f80233ee4a3",
"d4210ec4393d4be9b75b79f7e4db4287",
"a238657d62c04ad2bb04b30d77552f6f",
"057b77b82e4349b59a8f6613c790b578",
"7d1e3ee9b5ed4751a9beb9193a263c8e",
"198413be4c614564acda9d05e1b845fd",
"2db544a8d44d429982d0fd1ad0cd81fe",
"7a6656b229db40b2b87719ad92dc6da9",
"213ee71a87184dddbbbceeb5b38fecde",
"eec55cf2133d48a6ab99292ca914798f",
"c44499b124c24b669c8185dce2001bcd",
"ee364e50f36b45c791b10568d61689f8",
"e34cf346f9ff4920ab186085f0f78527",
"8109cb858d174b7782280f61ec31f0a5",
"500f8256e232465da60adbe3a6e308fd",
"2eb11d95dc364ee79bef12a0a7c9048f",
"ab118565196540d9a0b6752b080c6a57",
"a8e33b39a1134fa28faf3090346ec298",
"3261f11ed58542ad903f753e4d7140f5",
"771859eba515470d80d7c99cad6de224",
"ec399cbc2b204863929070ae05ad373f",
"da15c53d69534f6db9238001fb7f4595",
"31ebe5173e6348718a525e8784b618cb",
"cad5cb747e154a1bb02ad13d1fc1cbbe",
"e78d7726ce75428aa16ad4a029ba2fbf",
"faf70a82e8db433ea58a3be12d6f31e0",
"47a76bacad474d95a8111756b7ba9b2d",
"d4d2ad3949314b93963c29a88bfcffae",
"ae8452c5ad8140e9ba39fd39a0452ea0",
"1e98842f50a545e8a74810f5685ac5c4",
"03921c5bcc8f471fbd341e0c1d532c4f",
"66d97c3272794dd79ff025bc48eadb00",
"3c881f84f5f743f2a03a79384e6a938a",
"e5b606108d294886a708555a080cf938",
"dace034955de48e89192e583379b36af",
"aec90d5293f949859f3cd05b86a561e3",
"3d2cb5eaa8744cb2ae9ea372a0cef9be",
"05b30f42a224488f9d064765b983e8cf",
"0051a2bbbfa442568d472e446244ddb6",
"4044dde9ad46432198452534f06ec6b5",
"58dc9f135c764e82a932a790bd0e519e",
"fbd75796d20541c2b998e6f36126b495",
"953299696d2b4eaebaeb52dd597d3f63",
"f550da66c436459ba4a7eb482aa63afb",
"9dd18b31dfa342e190d0001e764cd1a8",
"a899e618f5104813bf445a9e5175defb",
"e46d2eb33b4842c3b2348e5362353a3a",
"8d4a6f15b2684806956d8610db9e2578",
"ae6737b9ef234dc3be12922cdbe7a404",
"b6d49b95afa047c6a6f3009173a9c089",
"7515993f8afb46d6856c138f8236c372",
"3a86592d9c3f4aa39eb208eeb50dbbf3",
"ad6c4b35b4c54efabef8fde8ebf7d1ac",
"95d21303782e45cc99af09da5b819ab1",
"5f184bc85e614af6beb2e8f93b6809f4",
"b3fea34fe8ee435b87e9af61b34bb983",
"9698ba9e797b42b3ad924ba58b39f4c0",
"e72d6e4b44844abd95e7dc3a98c92628",
"cfc7dd59adf34dc88c4c714f55c40b53",
"4b954d56885d48c4a318d66f213006ef",
"f4e5c659e6f848749b8c25535263a8ad",
"028228f414164b5282755952f080ccfe",
"984fa35315b341e8894078d6aba930e3",
"28dacca98f804ad586b4fab4d89df91b",
"a9f344da556c4ef196fe7d19f3ec3a89",
"238f0503143441c189e791347daf2dd1",
"16c336c516fb42adb843d403f861cd0b",
"521edc4920bf43fa98caee105d297556",
"fcae29cc5d7d4739a353e777e5e77d82",
"edbc2a17e4e341999b625d2cd8d31b9b",
"692441406a9c41ce9e54afb495d1b536",
"d1bc85085ac34061a3be378ac3905279",
"2313e41b16d843ad8d45828f4b475643",
"de600085669b46149213f641c3768933",
"2cae93c93d594499be7afdef3999c187",
"bb55da16836540979dc83901b310ff7b",
"165d3fd1b452492f95f9c58380c344f3",
"c28402611777477780a29f237d4e7823",
"dcc57fbe466942fb9338e22c4f55a58d",
"376cece6904342b1a948b36c95ae8d3c",
"49896d89f00e45ee975100bdfba29c9e",
"59d8d6421d3044cfb1c87e15797219ca",
"0ee6d7931966427c9c12451ff9bb7f9a",
"d2c5f455738c4133a18f747c7b89382e",
"1d5a0540002049e997d7b71bc95029ba",
"05571082787c49498dd5facc9b97df3e",
"99cdf0fe5747447aa88e6249bce60a91",
"31a820018562417d9947f0f4771ddfc2",
"b516bdfeae5642b888a268f8e7de4e09",
"b585912573ce49d98e98b7ccc2c80292",
"1aad46766eae42c09de19ec5cedb004b",
"41203c07d05f494a82a633ed964d39d3",
"a833a4a4d3ee430b88847e427f5f548f",
"f299dee10f36493e821b192e25d2689a",
"207b879084324809be5810d70d287fd1",
"24d1ca5d21534ceaa8db841e10231681",
"faacb0a2dcad4db8909e1bbcf23f46bf",
"29369c6903fd4fedbf0dfb8260778765",
"7c0ecea6657a41f59da66a09f191705d",
"168fd30abe1d4bb683f7024331bf6d55",
"98857d4d88154249b3c17a7bde76127a",
"0a2e14b5535d490588314c288527ca12",
"6dd39faa087745d1bcd6de10b1175158",
"b18b5c361ae14528be9d4509c85bf378",
"1ccbf4b3646a4697969760bfe9879816",
"48348858663f4c4b8729cbf86919fb81",
"94080b033a204fbc8491b83b8ab1ebad",
"8d998a7656a148f0ac3eeff11339021f",
"b584cc828ca44594b83238ca7525c715",
"1d84dc1cd6ea43068c4640264fe9cf6c",
"771c4c6d5d9844ff85550f3764fe3741",
"bd833266bc0c40cdb34bd24a21a6f662",
"b724dd8c26684db4ba3993972c4f76ae",
"b0d73b83f534460ca6dc7f518f7745f1",
"aaeb11a19ebc49d0b9e05f4c6e0ee98e",
"b9bfccb9aacf47aab70871bf491bc80d",
"fb85fc977e1e462492307e868e7eef3d",
"0a265e8a78ce458989e32964d138da82",
"ac3ec79249a3495e92947c05034986a3",
"b9246e6d35854fb9816dcbf7f44a0e7e",
"a05c50e72a0945b9afe175d4ad3f258f",
"27ef74e052054cf3bccf15235abb0fb2",
"827041d9dd6a4a1a983585e590c93124",
"b95b164425204fe2baf1fa8cdb1be695",
"d7928daea8d344aaa5aa7b8d8debea04",
"8e4917cfd89b4170877db0dd186a2372",
"0e4819d814fc4c2698273a0f9e12ca24",
"e0e2e8c7f9a040759025b79094081640",
"68d1fa15838a4604a58af9c5dcff1a23",
"70ec36aa789f41ed9c8e11210e06fae2",
"0bd39f2386824e41a0a145cc4dcda29d",
"54bc94380dbe42d69feeeff7992da1f6",
"00ce3f9d57b041b3a8ab74cde731230b",
"29f5926b34c749c3a8b95739a963748d",
"64f807355a9f47378311466ad147b178",
"f7dea30408aa47a6aed0edcd801e1500",
"e0f02a8502a34be3b0003ab95b918359",
"d4516c84caf44742a4723e2ce84e6720",
"60dd1a7f176347ce993a2d0d5c7a3331",
"8167f2030c06456f91020f2ea62b231a",
"8e095672232f4a2a965606731b9f4b33",
"462995bc8bd44249a3abab182d583b4b",
"f7feddfa8a1e45e48468b8c618193a68",
"4ab90369954d4687b2f0e18ccd962ea2",
"2277c0c559bc4671bf2246905217136b",
"bf1df4c8e6314d4cab62a3f99eb6d942",
"533103b705d448f991edf24d2a244c10",
"94a8d2b32e4c494db3055cd39771e1d6",
"f482ab6f37d9401885acc7e7b07170ee",
"6c1b24df774d4b589629035de4c4ac34",
"d0f476b576ef4f84adb02486bad453eb",
"861e0e0d31ae477b9c3c5366b3f248f5",
"aff51a3b36e44beb9edc55a68de73f4d",
"b72b31ece29b4c6c984a1feefbe04665",
"cefee250b1e44d9ebbc13dac07bc8056",
"398fa1d1021c4ed6b40582d6c695a495",
"24e96b7c7a6e42a0bc26531aded9dde0",
"def740442c684ac18532a72f8eb15e31",
"457d80d1ac65483fb04d37fc4ef945a9",
"71ccfa9715f745d69d6c998ed02d7a05",
"23a5357cf9b94e808899e0bb7ac7309f",
"716fd0e5cc354cfd9cb1169d026d86db",
"9ac676478e6f44998a8b03f7b4791d0e",
"702a4ede9999412b917b15afd743c0a7",
"1221cea0a12840429a56d823489c4295",
"267c13c9a6f049bfacfc05b9419462a1",
"0e63727e35e14d69b86cd4e422a07663",
"66989aef012148af92869e3e833b9965",
"d734b9a19f52484db17fdee7ba4f1eda",
"b0bdf01506a346bf9ae64907082ced24",
"1debfbd39d4249ef9ccf6e2d5c1ee199",
"533a1ad1d4a1428fa3ea8a81a90ba975",
"939605cf70c5454692425ad99afd5259",
"18e66bd54f694399be7271befe2205bc",
"29b810cb1ad146e2a0bf9724c7f2b99e",
"249d8e02797b40fba8c38c88d01d2fcb",
"39fe8f2571594ea49c8e5ed18f88aafd",
"0cba15ff7ea84d60aeae3c9b2f50252a",
"40d1fab667f443b1b120373d01b31f2a",
"2d7d999184b74afdb1a421d79a67f1e0",
"6d1155b55c4147a1877f8a2d438b53fa",
"1382a56af61147e1917a78ef8e6cf000",
"4bb66817efe44cde8d5ca53fce61a1bd",
"c50dc2164f1e4a3b95dbfbc824278ce5",
"0fc1ef4f8f8f4f89bd09e9c5a9428961",
"25f358d8e8ad4feaa01d773fbbc30fef",
"f0301cf9ff34438baa168cc6b6ea7c13",
"45a039d8b56a4b78b4cd316b9485fc7a",
"602b72561d4d47aabf88897f754456f3",
"515b2222eea248f9b0c68864ab63bfb2",
"d0a9e3cd351e4c26a526082a8c210f03",
"7a11c347030342eba50d188b96b646c0",
"1ad8582021b148b8a1d30bf428afc84c",
"f88a91e0f38b4d819f4a352dc63e2f77",
"0abea1dfeb5a4b69999b397767766ff7",
"6f66f42fa55c4c27a63eb8cf07032a3d",
"ee4314d1f60546f38c7f51b97e2857d7",
"fd97e7eb254843d88f2d1493bed7c97d",
"e034e2bd5d0b44d3bf553c9f8204094c",
"25cda90a9530445ba5aa3e20155f930e",
"e8ed7566c9ef421895235b69b51d01fd",
"55902436994f4949a3f6e6b901510061",
"7c994af4c1724b2fa9a552c553b4da07",
"6404f37c4a4d4ab6ae20c9980575daa0",
"3a5f74cd7e254ae4a20c6aab4871ea30",
"3e98de1a1b61422f904f8128c71eab95",
"f1f32aea8eee4a15be09d8c755d906bc",
"513657bcaff3411b9a70200d4bce4826",
"0a19a96f7a7049c9aa4499a206512e94",
"0b149af4d61e4c2aaa2da768642f201b",
"f5492cd1489f4cbbb3934dca96fee20a",
"4a3b8f75ceee456cb6c7fa3ca645d587",
"d226a840168e435c9315b2e873ee73ad",
"a2537fd63e594221bfcdfaea9013c2a9",
"df254df0249f45bc9e4b1a4b4642e7a7",
"be71a7e3f725426f98dd8d58e4d2ec2e",
"8a3c64520eff477c8b1079bf528d8e9a",
"933f0b01d30742e88671dab2b45b50df",
"376884c2ef0842bab78a04445899b8ef",
"0243d0611e4742cbb79fe6015e594c4e",
"8dfe18d9077a4192bc6f76463052a8e3",
"dac3f98aa9d741d68d3d58f82c1abf05",
"1c5117d581724e3b88b8adedb0c5fa8d",
"91a7d4ce31e34163a7cd56d1487decb1",
"73e457a2ad364825b33c3212bba05128",
"ed93ec911008400c95d5f4193c050bbb",
"27c3a1376f0a4d93958cb61767f74772",
"232389f7ab2e4e529b6818ff0eeacd5c",
"5f72493993aa4ace92f6705156629669",
"fb40256db41142a196b21ccf03e58507",
"0147e8313a4547ac922231f12f9c556a",
"90456a871bf0410493fb33660f85cfc9",
"3226ba2b1e12464abae09a3d3adf8825",
"d41dc7d775f747aaa8e0b25e7d937b09",
"90d286dd72e34b8db5c92ad4045e38b4",
"9a2c0dadbaf24b97824a1d77bc86bf4d",
"f2b989f5dadb4f0091eabd3fd6397116",
"48d391befc8845368d79c6716c2aff4a",
"82f9dcb8378d4a06ae7124597a0eafde",
"fa41098cf7494eae875e3607a74bd677",
"09bcb860e59e4a0894db0db114ba0ec4",
"67608fa7be9649afb32705093179ac8b",
"6f279de1d6ff4769bebbad54189d1feb",
"bfb6977d8caf4b6baf44e464ab234d41",
"30f1875cc4e44a62b455da724a7497f7",
"0e163cb429b848c391a846e7363a1930",
"804de988ce48423584f0df6b52735fd9",
"85be128d963a4889a43a4efc2834fce5",
"67897dbb905d4720a4718a6c5539afa5",
"4483a850c6a94d248d81038f78c56eb8",
"b84b8f411cc445e983596589931fccd6",
"ef8607976407491fb5ff66611b1d57ea",
"1f29d6d940254005a805041a24684b1c",
"73858f5b9a1243bba2fb10c9c026fc34",
"8e4e3768c05048dfb286aca9e097c053",
"3b06ddfc9eed4e9ba4b7af13926402cc",
"a21fdabbde9a4245a8081bc02e96ab85",
"67346a682cc44ed09f983094a53c904b",
"8ec4350fbbba498789d78a757f4fd701",
"9b866258d1f24b44acf381b4df321ba8",
"d80500ce620642d7aee9aa526b5f8ae5",
"3e6813f9a13745beb743bc4f44629a80",
"c65be37e397d4f2fbd90b8e59b6b4e53",
"5c1a02dcd9b84bc2826a15513c92cc02",
"9a8d1aa99e8f478d8492d19053a84974",
"a8dabcc56bd0465f997c2ea3ade42864",
"bbf8e5d0aac64b0b982e3afd971b8ff0",
"2212298dd8ed40208f8bcfb1cf6932a7",
"c3ec4364f73c4959b84a6f01a9d806ef",
"6326baa3cb7a4ba6a9d75a85a2c07769",
"0069ccdd34cb4d4988786e012c2276f7",
"37331d01245d434896bc54bffc69dcf6",
"db6c58bc454c4a25bd0d8caed3c0959f",
"4e0506105a5e47f8913884c8a5059fd9",
"3b63712d97944996959b72c1df443491",
"2f33e0fe33924dd5866ec12821ec9ba3",
"ac7baaba195746f099bd7e10024f275d",
"ae362ff647154014ba6e376f6c57e045",
"fa88746dfe964acd8761d1de8ff7d139",
"37339f333a3a49f1bcc89e3b7999114a",
"1d6385d0541240ec93daea8930b63f37",
"6d52f722471343eeb7fbed87994cbdf8",
"0daeb2f5ceaf441f9b61d88ae80d1c7f",
"49800ac8431b420da8c82ae31dc96cbd",
"9648ba4ea629437e801794b6d06d97c0",
"14674e3df079419b867c8c9201b79097",
"b52cb724276e443ab07e8bfc8a3f24d9",
"b29a41a5518b45a6ace7e9703036c77d",
"13dea65945c84640a2560dd35b4a7ea9",
"b914c346d6344fd2a0fd68f7c5e24fe5",
"1dc6a4dca67f4711885d6058a722e743",
"0feac8068fef4736b03a57aeb0c03cb5",
"3c0b0cff087045e08c310005cc435ee0",
"b8e88fabdf0a4282b5b5ad641240e98f",
"c3e61531cf4f4d85a7e5ed7647f7520a",
"2310164457b4441db19548f0f3aeddc9",
"ffc6490b2a8144e4a8059fb604810987",
"c054c2bb07a04b6b83a3ecb1f1d2fea0",
"463045fde3ac4b4da2778b46f1c55155",
"28964c9168ec4e6bbc3aa072e3374b7e",
"d672389548dd4442b76f2aa07a1cb8b0",
"689c1cdf2d35435eb9065066bb41d028",
"902a34cf07784b08831cb490cfe6ce3f",
"12501f4b793343e6a5afd148112c5949",
"6d8130c450a74a498d773c4e2b46cb62",
"255903d9ba5c4aa1b7c5f81912dfbd37") ;
for (String s : list) {
this.haobanTimerApiService.halfTimer(s);
}
}
}
haoban-manage3-service/src/test/java/HaobanRoleTest.java 0 → 100644
import com.gic.commons.util.CollectionUtil;
import com.gic.commons.util.UniqueIdUtils;
import com.gic.haoban.manage.api.service.HaobanTimerApiService;
import com.gic.haoban.manage.service.dao.mapper.role.TabHaobanRoleMapper;
import com.gic.haoban.manage.service.dao.mapper.role.TabHaobanRoleMenuMapper;
import com.gic.haoban.manage.service.entity.role.TabHaobanRole;
import com.gic.haoban.manage.service.entity.role.TabHaobanRoleMenu;
import org.apache.commons.collections.CollectionUtils;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class HaobanRoleTest {
@Autowired
private TabHaobanRoleMenuMapper haobanRoleMenuMapper ;
@Autowired
private TabHaobanRoleMapper haobanRoleMapper ;
@Test
public void tt() {
List<String> list = Arrays.asList("a0e2b8466e554aa88fa25e6f3757aa06",
"a253a78e2f1349fb9e8727015e48cd2b",
"d672eda301b2499a899902a02e55041c",
"626a8fd134ea4b91a83d472e0aba4081",
"9b5eda19379f412eaf1c55477910b792",
"2834fc85368847fd9c9614993a7a31a0",
"16e40d9a63814668873e36fa3bdd2d2a",
"e03b7089bfbf46cba60479f147adf6eb",
"2fdb7927db174a8e9d68c975538364d5",
"89fd6ad36b3f4d0f9b06c856e4d91441",
"e0e12e08d62b47ac823b7d8d99fb9495",
"7c140f63c6c14acab2eac5290ed0c59d",
"c05df62cd6f844cea55778321c5552e5",
"784b6d7711664b278d7d73f92940958f",
"8bb1442e0f5943989cf9e5513acb1f03",
"f47cf73c887c444a909eb60feac0e6b2",
"cd688b9b915b4c4d81a967abf5ce2399",
"c50a57f2a59042e9aa4ff8361f2d61f7",
"f04df76f35a14d819fc7192d8d75d33a",
"2e5db471800b4c529e52dc4f98f6651a",
"9aad8308f8524b6cac451519f6d65792",
"5fff1b5ff62149f8bad5b10b141bcc6b",
"4e801e4b9cd4489389a4c12c30b5595f",
"8af6367375d643f4adf0bd255349d52a",
"abcd03d17eb349d491b983b09d678a4a",
"1dac964159694e4d9a8f03a3e6d65d75",
"46a4b60dea4b4b83a6ff81108c1d0d17",
"bf0f8b4351754819984ce12fbc3a8a4f",
"9900848270d6422c891c8b674c729a04",
"4119c628c1ab42da9c7976f405a0d013",
"3807d1017a1544d3be888e6108494dd2",
"f079bd6c985a4b8296ce1ba5b7a4e41e",
"acbfeb379b5242d5b2e44ab50e1047a1",
"4b18675afa7e4dfaa7b9c66b11ca6474",
"1d1e13c75d314c1fb01b97f104baf74b",
"7d1a509a3ad94a9f8c001ead0394e199",
"0dd77eacc16d4499a7310d0d663a27f6",
"8ee3e7e1016142fba939460fb9098c08",
"e9254b614d6e43ffa7c74094be1f07f2",
"0e33e5b6c97b46d39d3502335f227fed",
"e125f933481749828eb3b8bf9bb03801",
"8824ef05d5394f7085cf909141ef6d4c",
"b4fa8b82902944778c740c7fc08fd7bc",
"6dccb1983a8e400987d8608fb63db7b1",
"7df48a749ec1457594e85f80233ee4a3",
"d4210ec4393d4be9b75b79f7e4db4287",
"a238657d62c04ad2bb04b30d77552f6f",
"057b77b82e4349b59a8f6613c790b578",
"7d1e3ee9b5ed4751a9beb9193a263c8e",
"198413be4c614564acda9d05e1b845fd",
"2db544a8d44d429982d0fd1ad0cd81fe",
"7a6656b229db40b2b87719ad92dc6da9",
"213ee71a87184dddbbbceeb5b38fecde",
"eec55cf2133d48a6ab99292ca914798f",
"c44499b124c24b669c8185dce2001bcd",
"ee364e50f36b45c791b10568d61689f8",
"e34cf346f9ff4920ab186085f0f78527",
"8109cb858d174b7782280f61ec31f0a5",
"500f8256e232465da60adbe3a6e308fd",
"2eb11d95dc364ee79bef12a0a7c9048f",
"ab118565196540d9a0b6752b080c6a57",
"a8e33b39a1134fa28faf3090346ec298",
"3261f11ed58542ad903f753e4d7140f5",
"771859eba515470d80d7c99cad6de224",
"ec399cbc2b204863929070ae05ad373f",
"da15c53d69534f6db9238001fb7f4595",
"31ebe5173e6348718a525e8784b618cb",
"cad5cb747e154a1bb02ad13d1fc1cbbe",
"e78d7726ce75428aa16ad4a029ba2fbf",
"faf70a82e8db433ea58a3be12d6f31e0",
"47a76bacad474d95a8111756b7ba9b2d",
"d4d2ad3949314b93963c29a88bfcffae",
"ae8452c5ad8140e9ba39fd39a0452ea0",
"1e98842f50a545e8a74810f5685ac5c4",
"03921c5bcc8f471fbd341e0c1d532c4f",
"66d97c3272794dd79ff025bc48eadb00",
"3c881f84f5f743f2a03a79384e6a938a",
"e5b606108d294886a708555a080cf938",
"dace034955de48e89192e583379b36af",
"aec90d5293f949859f3cd05b86a561e3",
"3d2cb5eaa8744cb2ae9ea372a0cef9be",
"05b30f42a224488f9d064765b983e8cf",
"0051a2bbbfa442568d472e446244ddb6",
"58dc9f135c764e82a932a790bd0e519e",
"fbd75796d20541c2b998e6f36126b495",
"953299696d2b4eaebaeb52dd597d3f63",
"f550da66c436459ba4a7eb482aa63afb",
"9dd18b31dfa342e190d0001e764cd1a8",
"a899e618f5104813bf445a9e5175defb",
"e46d2eb33b4842c3b2348e5362353a3a",
"8d4a6f15b2684806956d8610db9e2578",
"ae6737b9ef234dc3be12922cdbe7a404",
"b6d49b95afa047c6a6f3009173a9c089",
"7515993f8afb46d6856c138f8236c372",
"3a86592d9c3f4aa39eb208eeb50dbbf3",
"ad6c4b35b4c54efabef8fde8ebf7d1ac",
"95d21303782e45cc99af09da5b819ab1",
"5f184bc85e614af6beb2e8f93b6809f4",
"b3fea34fe8ee435b87e9af61b34bb983",
"9698ba9e797b42b3ad924ba58b39f4c0",
"e72d6e4b44844abd95e7dc3a98c92628",
"cfc7dd59adf34dc88c4c714f55c40b53",
"4b954d56885d48c4a318d66f213006ef",
"f4e5c659e6f848749b8c25535263a8ad",
"93416e3a92504683b5b13513477a840a",
"369038a3568b46a6898d635843b73dc6",
"028228f414164b5282755952f080ccfe",
"984fa35315b341e8894078d6aba930e3",
"28dacca98f804ad586b4fab4d89df91b",
"a9f344da556c4ef196fe7d19f3ec3a89",
"238f0503143441c189e791347daf2dd1",
"16c336c516fb42adb843d403f861cd0b",
"eef50d95636c4821869ac3315efac814",
"521edc4920bf43fa98caee105d297556",
"27f6a5b4ed474c7889f9f35efdd90acb",
"fcae29cc5d7d4739a353e777e5e77d82",
"edbc2a17e4e341999b625d2cd8d31b9b",
"692441406a9c41ce9e54afb495d1b536",
"d1bc85085ac34061a3be378ac3905279",
"de600085669b46149213f641c3768933",
"2cae93c93d594499be7afdef3999c187",
"bb55da16836540979dc83901b310ff7b",
"165d3fd1b452492f95f9c58380c344f3",
"c28402611777477780a29f237d4e7823",
"dcc57fbe466942fb9338e22c4f55a58d",
"376cece6904342b1a948b36c95ae8d3c",
"49896d89f00e45ee975100bdfba29c9e",
"59d8d6421d3044cfb1c87e15797219ca",
"0ee6d7931966427c9c12451ff9bb7f9a",
"d2c5f455738c4133a18f747c7b89382e",
"9a7a89d2d1534c47980ea0886a202d3c",
"1d5a0540002049e997d7b71bc95029ba",
"05571082787c49498dd5facc9b97df3e",
"99cdf0fe5747447aa88e6249bce60a91",
"31a820018562417d9947f0f4771ddfc2",
"b516bdfeae5642b888a268f8e7de4e09",
"b585912573ce49d98e98b7ccc2c80292",
"1aad46766eae42c09de19ec5cedb004b",
"41203c07d05f494a82a633ed964d39d3",
"6a2ec77394e54d448f7de350ae0737cc",
"a833a4a4d3ee430b88847e427f5f548f",
"7f8c0c0eedd546ed9c4b355bb9cc2f31",
"74394d101c40405a9303d0d3fedc178f",
"f299dee10f36493e821b192e25d2689a",
"207b879084324809be5810d70d287fd1",
"24d1ca5d21534ceaa8db841e10231681",
"faacb0a2dcad4db8909e1bbcf23f46bf",
"29369c6903fd4fedbf0dfb8260778765",
"7c0ecea6657a41f59da66a09f191705d",
"168fd30abe1d4bb683f7024331bf6d55",
"98857d4d88154249b3c17a7bde76127a",
"0a2e14b5535d490588314c288527ca12",
"6dd39faa087745d1bcd6de10b1175158",
"b18b5c361ae14528be9d4509c85bf378",
"1ccbf4b3646a4697969760bfe9879816",
"48348858663f4c4b8729cbf86919fb81",
"94080b033a204fbc8491b83b8ab1ebad",
"8d998a7656a148f0ac3eeff11339021f",
"b584cc828ca44594b83238ca7525c715",
"1d84dc1cd6ea43068c4640264fe9cf6c",
"771c4c6d5d9844ff85550f3764fe3741",
"bd833266bc0c40cdb34bd24a21a6f662",
"b724dd8c26684db4ba3993972c4f76ae",
"b0d73b83f534460ca6dc7f518f7745f1",
"aaeb11a19ebc49d0b9e05f4c6e0ee98e",
"b9bfccb9aacf47aab70871bf491bc80d",
"fb85fc977e1e462492307e868e7eef3d",
"0a265e8a78ce458989e32964d138da82",
"ac3ec79249a3495e92947c05034986a3",
"b9246e6d35854fb9816dcbf7f44a0e7e",
"a05c50e72a0945b9afe175d4ad3f258f",
"27ef74e052054cf3bccf15235abb0fb2",
"827041d9dd6a4a1a983585e590c93124",
"b95b164425204fe2baf1fa8cdb1be695",
"d7928daea8d344aaa5aa7b8d8debea04",
"8e4917cfd89b4170877db0dd186a2372",
"0e4819d814fc4c2698273a0f9e12ca24",
"e0e2e8c7f9a040759025b79094081640",
"b8f2f238e73844219d8c1ac563cec0db",
"68d1fa15838a4604a58af9c5dcff1a23",
"70ec36aa789f41ed9c8e11210e06fae2",
"0bd39f2386824e41a0a145cc4dcda29d",
"54bc94380dbe42d69feeeff7992da1f6",
"00ce3f9d57b041b3a8ab74cde731230b",
"29f5926b34c749c3a8b95739a963748d",
"64f807355a9f47378311466ad147b178",
"f7dea30408aa47a6aed0edcd801e1500",
"e0f02a8502a34be3b0003ab95b918359",
"d4516c84caf44742a4723e2ce84e6720",
"60dd1a7f176347ce993a2d0d5c7a3331",
"8167f2030c06456f91020f2ea62b231a",
"8e095672232f4a2a965606731b9f4b33",
"462995bc8bd44249a3abab182d583b4b",
"f7feddfa8a1e45e48468b8c618193a68",
"8477c149d8774f06ab841f042645832b",
"4ab90369954d4687b2f0e18ccd962ea2",
"2277c0c559bc4671bf2246905217136b",
"bf1df4c8e6314d4cab62a3f99eb6d942",
"533103b705d448f991edf24d2a244c10",
"94a8d2b32e4c494db3055cd39771e1d6",
"f482ab6f37d9401885acc7e7b07170ee",
"6c1b24df774d4b589629035de4c4ac34",
"d0f476b576ef4f84adb02486bad453eb",
"861e0e0d31ae477b9c3c5366b3f248f5",
"aff51a3b36e44beb9edc55a68de73f4d",
"b72b31ece29b4c6c984a1feefbe04665",
"cefee250b1e44d9ebbc13dac07bc8056",
"398fa1d1021c4ed6b40582d6c695a495",
"24e96b7c7a6e42a0bc26531aded9dde0",
"def740442c684ac18532a72f8eb15e31",
"457d80d1ac65483fb04d37fc4ef945a9",
"71ccfa9715f745d69d6c998ed02d7a05",
"23a5357cf9b94e808899e0bb7ac7309f",
"716fd0e5cc354cfd9cb1169d026d86db",
"9ac676478e6f44998a8b03f7b4791d0e",
"702a4ede9999412b917b15afd743c0a7",
"1221cea0a12840429a56d823489c4295",
"267c13c9a6f049bfacfc05b9419462a1",
"0e63727e35e14d69b86cd4e422a07663",
"66989aef012148af92869e3e833b9965",
"d734b9a19f52484db17fdee7ba4f1eda",
"31060eb76d7a42969516c7ff12f9a1ea",
"b0bdf01506a346bf9ae64907082ced24",
"1debfbd39d4249ef9ccf6e2d5c1ee199",
"533a1ad1d4a1428fa3ea8a81a90ba975",
"939605cf70c5454692425ad99afd5259",
"18e66bd54f694399be7271befe2205bc",
"29b810cb1ad146e2a0bf9724c7f2b99e",
"249d8e02797b40fba8c38c88d01d2fcb",
"39fe8f2571594ea49c8e5ed18f88aafd",
"0cba15ff7ea84d60aeae3c9b2f50252a",
"40d1fab667f443b1b120373d01b31f2a",
"2d7d999184b74afdb1a421d79a67f1e0",
"6d1155b55c4147a1877f8a2d438b53fa",
"1382a56af61147e1917a78ef8e6cf000",
"4bb66817efe44cde8d5ca53fce61a1bd",
"c50dc2164f1e4a3b95dbfbc824278ce5",
"0fc1ef4f8f8f4f89bd09e9c5a9428961",
"25f358d8e8ad4feaa01d773fbbc30fef",
"f0301cf9ff34438baa168cc6b6ea7c13",
"45a039d8b56a4b78b4cd316b9485fc7a",
"602b72561d4d47aabf88897f754456f3",
"515b2222eea248f9b0c68864ab63bfb2",
"d0a9e3cd351e4c26a526082a8c210f03",
"7a11c347030342eba50d188b96b646c0",
"1ad8582021b148b8a1d30bf428afc84c",
"f88a91e0f38b4d819f4a352dc63e2f77",
"0abea1dfeb5a4b69999b397767766ff7",
"6f66f42fa55c4c27a63eb8cf07032a3d",
"ee4314d1f60546f38c7f51b97e2857d7",
"fd97e7eb254843d88f2d1493bed7c97d",
"e034e2bd5d0b44d3bf553c9f8204094c",
"25cda90a9530445ba5aa3e20155f930e",
"e8ed7566c9ef421895235b69b51d01fd",
"55902436994f4949a3f6e6b901510061",
"7c994af4c1724b2fa9a552c553b4da07",
"6404f37c4a4d4ab6ae20c9980575daa0",
"3a5f74cd7e254ae4a20c6aab4871ea30",
"3e98de1a1b61422f904f8128c71eab95",
"f1f32aea8eee4a15be09d8c755d906bc",
"513657bcaff3411b9a70200d4bce4826",
"0a19a96f7a7049c9aa4499a206512e94",
"0b149af4d61e4c2aaa2da768642f201b",
"f5492cd1489f4cbbb3934dca96fee20a",
"4a3b8f75ceee456cb6c7fa3ca645d587",
"d226a840168e435c9315b2e873ee73ad",
"a2537fd63e594221bfcdfaea9013c2a9",
"df254df0249f45bc9e4b1a4b4642e7a7",
"be71a7e3f725426f98dd8d58e4d2ec2e",
"8a3c64520eff477c8b1079bf528d8e9a",
"933f0b01d30742e88671dab2b45b50df",
"376884c2ef0842bab78a04445899b8ef",
"0243d0611e4742cbb79fe6015e594c4e",
"8dfe18d9077a4192bc6f76463052a8e3",
"dac3f98aa9d741d68d3d58f82c1abf05",
"1c5117d581724e3b88b8adedb0c5fa8d",
"91a7d4ce31e34163a7cd56d1487decb1",
"73e457a2ad364825b33c3212bba05128",
"ed93ec911008400c95d5f4193c050bbb",
"27c3a1376f0a4d93958cb61767f74772",
"232389f7ab2e4e529b6818ff0eeacd5c",
"5f72493993aa4ace92f6705156629669",
"fb40256db41142a196b21ccf03e58507",
"0147e8313a4547ac922231f12f9c556a",
"90456a871bf0410493fb33660f85cfc9",
"3226ba2b1e12464abae09a3d3adf8825",
"d41dc7d775f747aaa8e0b25e7d937b09",
"90d286dd72e34b8db5c92ad4045e38b4",
"9a2c0dadbaf24b97824a1d77bc86bf4d",
"f2b989f5dadb4f0091eabd3fd6397116",
"48d391befc8845368d79c6716c2aff4a",
"82f9dcb8378d4a06ae7124597a0eafde",
"fa41098cf7494eae875e3607a74bd677",
"09bcb860e59e4a0894db0db114ba0ec4",
"67608fa7be9649afb32705093179ac8b",
"6f279de1d6ff4769bebbad54189d1feb",
"bfb6977d8caf4b6baf44e464ab234d41",
"30f1875cc4e44a62b455da724a7497f7",
"0e163cb429b848c391a846e7363a1930",
"804de988ce48423584f0df6b52735fd9",
"85be128d963a4889a43a4efc2834fce5",
"67897dbb905d4720a4718a6c5539afa5",
"703207906c5942b0937f8eda35036e9b",
"4483a850c6a94d248d81038f78c56eb8",
"727f05dbe66d48009719f63a189b9965",
"b84b8f411cc445e983596589931fccd6",
"ef8607976407491fb5ff66611b1d57ea",
"1f29d6d940254005a805041a24684b1c",
"73858f5b9a1243bba2fb10c9c026fc34",
"8e4e3768c05048dfb286aca9e097c053",
"3b06ddfc9eed4e9ba4b7af13926402cc",
"a21fdabbde9a4245a8081bc02e96ab85",
"67346a682cc44ed09f983094a53c904b",
"8ec4350fbbba498789d78a757f4fd701",
"9b866258d1f24b44acf381b4df321ba8",
"d80500ce620642d7aee9aa526b5f8ae5",
"3e6813f9a13745beb743bc4f44629a80",
"c65be37e397d4f2fbd90b8e59b6b4e53",
"5c1a02dcd9b84bc2826a15513c92cc02",
"9a8d1aa99e8f478d8492d19053a84974",
"a8dabcc56bd0465f997c2ea3ade42864",
"bbf8e5d0aac64b0b982e3afd971b8ff0",
"2212298dd8ed40208f8bcfb1cf6932a7",
"c3ec4364f73c4959b84a6f01a9d806ef",
"6326baa3cb7a4ba6a9d75a85a2c07769",
"0069ccdd34cb4d4988786e012c2276f7",
"37331d01245d434896bc54bffc69dcf6",
"db6c58bc454c4a25bd0d8caed3c0959f",
"c2a7904f682343efb9bc1cae026888a3",
"4e0506105a5e47f8913884c8a5059fd9",
"3b63712d97944996959b72c1df443491",
"2f33e0fe33924dd5866ec12821ec9ba3",
"ac7baaba195746f099bd7e10024f275d",
"ae362ff647154014ba6e376f6c57e045",
"fa88746dfe964acd8761d1de8ff7d139",
"37339f333a3a49f1bcc89e3b7999114a",
"1d6385d0541240ec93daea8930b63f37",
"6d52f722471343eeb7fbed87994cbdf8",
"0daeb2f5ceaf441f9b61d88ae80d1c7f",
"49800ac8431b420da8c82ae31dc96cbd",
"9648ba4ea629437e801794b6d06d97c0",
"14674e3df079419b867c8c9201b79097",
"b52cb724276e443ab07e8bfc8a3f24d9",
"b29a41a5518b45a6ace7e9703036c77d",
"13dea65945c84640a2560dd35b4a7ea9",
"b914c346d6344fd2a0fd68f7c5e24fe5",
"1dc6a4dca67f4711885d6058a722e743",
"0feac8068fef4736b03a57aeb0c03cb5",
"3c0b0cff087045e08c310005cc435ee0",
"b8e88fabdf0a4282b5b5ad641240e98f",
"c3e61531cf4f4d85a7e5ed7647f7520a",
"2310164457b4441db19548f0f3aeddc9",
"ffc6490b2a8144e4a8059fb604810987",
"c054c2bb07a04b6b83a3ecb1f1d2fea0",
"463045fde3ac4b4da2778b46f1c55155",
"28964c9168ec4e6bbc3aa072e3374b7e",
"d672389548dd4442b76f2aa07a1cb8b0",
"689c1cdf2d35435eb9065066bb41d028",
"902a34cf07784b08831cb490cfe6ce3f",
"12501f4b793343e6a5afd148112c5949",
"6d8130c450a74a498d773c4e2b46cb62") ;
for(int i=0;i<list.size();i++) {
this.add(list.get(i));
}
}
private void add(String wxEnterpriseId) {
List<TabHaobanRoleMenu> addList = new ArrayList<>() ;
List<TabHaobanRole> list = this.haobanRoleMapper.getListByWxEnterpriseId(wxEnterpriseId,1) ;
for(TabHaobanRole role : list) {
if(role.getClerkType()==0 || role.getClerkType()==1) {
TabHaobanRoleMenu m = new TabHaobanRoleMenu() ;
m.setRoleMenuId(UniqueIdUtils.uniqueLong());
m.setMenuCode("singleFriends");
m.setStatusFlag(1);
m.setCreateTime(new Date());
m.setUpdateTime(new Date());
m.setWxEnterpriseId(wxEnterpriseId);
m.setRoleId(role.getRoleId());
addList.add(m);
}
}
if(CollectionUtils.isNotEmpty(addList)) {
this.haobanRoleMenuMapper.insertBatch(addList);
}
}
}
haoban-manage3-service/src/test/java/log/EsResult.java 0 → 100644
package log;
import lombok.Data;
import java.util.List;
@Data
public class EsResult {
private List<Hits> hits;
private String _scroll_id;
@Data
public static class Hits {
private List<Source> hits;
private Long total;
private Long totalNum;
}
@Data
public static class Total {
private Long value;
}
@Data
public static class Source {
private String _source;
}
@Data
public static class Message {
private String message;
}
}
haoban-manage3-service/src/test/java/log/HttpClientEnum.java 0 → 100644
package log;
import org.apache.http.impl.client.CloseableHttpClient;
/**
* 基于枚举的http单例
* @author jiaotianqi
* @date 2021/7/15 15:41
*/
public enum HttpClientEnum {
INITIALIZE;
private CloseableHttpClient httpClient = HttpClientInit.getHttpClient();
public CloseableHttpClient getHttpClient() {
return httpClient;
}
}
haoban-manage3-service/src/test/java/log/HttpClientInit.java 0 → 100644
package log;
import org.apache.http.HttpEntityEnclosingRequest;
import org.apache.http.HttpRequest;
import org.apache.http.NoHttpResponseException;
import org.apache.http.client.HttpRequestRetryHandler;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.protocol.HttpClientContext;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.conn.HttpHostConnectException;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.protocol.HttpContext;
import javax.net.ssl.SSLException;
import javax.net.ssl.SSLPeerUnverifiedException;
import java.io.IOException;
import java.io.InterruptedIOException;
import java.net.SocketTimeoutException;
import java.net.UnknownHostException;
import java.util.concurrent.TimeUnit;
public class HttpClientInit {
/**
* 最大连接数
*/
public final static int MAX_TOTAL_CONNECTIONS = 1200;
/**
* 获取连接的最大等待时间
*/
public final static int WAIT_TIMEOUT = 30000;
/**
* 每个路由最大连接数
*/
public final static int MAX_ROUTE_CONNECTIONS = 400;
/**
* 连接超时时间
*/
public final static int CONNECT_TIMEOUT = 10000;
public static CloseableHttpClient getHttpClient() {
HttpRequestRetryHandler retryHandler = new HttpRequestRetryHandler() {
@Override
public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
if (executionCount >= 3) {
// Do not retry if over max retry count
return false;
}
if (exception instanceof InterruptedIOException) {
// Timeout
return true;
}
if (exception instanceof UnknownHostException) {
// Unknown host
return false;
}
if (exception instanceof ConnectTimeoutException) {
return true;
}
if (exception instanceof SSLException) {
return true;
}
if (exception instanceof SSLPeerUnverifiedException) {
// SSL handshake exception
System.out.println("https证书异常");
return true;
}
if (exception instanceof SocketTimeoutException) {
// SSL handshake exception
System.out.println("socket超时异常");
return true;
}
if (exception instanceof NoHttpResponseException) {
// SSL handshake exception
System.out.println("http无响应异常");
return true;
}
if (exception instanceof HttpHostConnectException) {
// SSL handshake exception
System.out.println("http主机连接异常");
return true;
}
HttpClientContext clientContext = HttpClientContext.adapt(context);
HttpRequest request = clientContext.getRequest();
boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);
if (idempotent) {
return true;
}
return false;
}
};
RequestConfig requestConfig = RequestConfig.custom()
// 获取连接超时时间
.setConnectionRequestTimeout(CONNECT_TIMEOUT)
// 请求超时时间
.setConnectTimeout(CONNECT_TIMEOUT)
// 响应超时时间
.setSocketTimeout(CONNECT_TIMEOUT)
.build();
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
cm.setMaxTotal(MAX_TOTAL_CONNECTIONS);
cm.setDefaultMaxPerRoute(MAX_ROUTE_CONNECTIONS);
//单个路由设置其连接大小
//cm.setMaxPerRoute(new HttpRoute(new HttpHost("jd.com",80)), 100);
CloseableHttpClient httpClient = HttpClients.custom()
.setDefaultRequestConfig(requestConfig)
.setRetryHandler(retryHandler)
.setConnectionManager(cm)
//定期回收空闲连接
.evictExpiredConnections()
.setConnectionTimeToLive(1, TimeUnit.HOURS)
.build();
return httpClient;
}
}
haoban-manage3-service/src/test/java/log/HttpClientUtil.java 0 → 100644
package log;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.ByteArrayBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
/**
* http工具类
* @author jiaotianqi
*/
public class HttpClientUtil {
static Logger logger = LogManager.getLogger(HttpClientUtil.class);
/**
* 描述:form表单提交
*
* @param url
* @param param
* @param header
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:15
* @since v1.0.0
*/
public static String doPost(String url, Map<String, String> param, Map<String, String> header) {
return getHttpClientRetStr(doPostRetResp(url, param, header));
}
/**
* 描述:form表单提交
*
* @param url
* @param param
* @param header
* @return CloseableHttpResponse
* @author jiaotq
* @created 2019/5/29 9:15
* @since v1.0.0
*/
public static CloseableHttpResponse doPostRetResp(String url, Map<String, String> param, Map<String, String> header) {
HttpPost httppost = new HttpPost(url);
if (header != null) {
header.forEach(httppost::setHeader);
}
// 创建参数队列
List<NameValuePair> formparams = new ArrayList<NameValuePair>();
if (param != null) {
for (Entry<String, String> value : param.entrySet()) {
formparams.add(new BasicNameValuePair(value.getKey(), value.getValue()));
}
}
UrlEncodedFormEntity uefEntity = null;
try {
uefEntity = new UrlEncodedFormEntity(formparams, "UTF-8");
} catch (UnsupportedEncodingException e) {
logger.warn(e.getMessage(), e);
}
httppost.setEntity(uefEntity);
return getHttpResponse(httppost);
}
/**
* 描述:form表单提交
*
* @param url
* @param param
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:15
* @since v1.0.0
*/
public static String doPost(String url, Map<String, String> param) {
return doPost(url, param, null);
}
/**
* 描述:post传文件
* @param url
* @param fileName
* @param bytes
* @param param
* @param header
* @return String
* @author jiaotq
* @created 2019/5/29 9:16
* @since v1.0.0
*/
public static String postMultipart(String url, String fileName, byte[] bytes,
Map<String, String> param, Map<String, String> header) {
return getHttpClientRetStr(postMultiparRetResp(url, fileName, bytes, param, header));
}
/**
* 描述:post传多个文件
* @param url
* @param files key文件名称,value 文件流
* @param param
* @param header
* @return String
* @author jiaotq
* @created 2019/5/29 9:16
* @since v1.0.0
*/
public static String postMultiparts(String url,Map<String,byte[]> files,
Map<String, String> param, Map<String, String> header) {
return getHttpClientRetStr(postMultiparsRetResp(url, files, param, header));
}
/**
* 描述:post传文件
* 返回 CloseableHttpResponse 对象，需要手动将连接归还池中
* ，请调用 HttpClientUtil.close(CloseableHttpResponse) 方法
* @param url
* @param fileName
* @param bytes
* @param param
* @param header
* @return CloseableHttpResponse
* @author jiaotq
* @created 2019/5/29 9:16
* @since v1.0.0
*/
public static CloseableHttpResponse postMultiparRetResp(String url, String fileName, byte[] bytes,
Map<String, String> param, Map<String, String> header) {
return postMultiparRetResp(url,fileName,new ByteArrayBody(bytes,ContentType.MULTIPART_FORM_DATA,fileName),param,header);
}
/**
* 描述:post传文件
* 返回 CloseableHttpResponse 对象，需要手动将连接归还池中
* ，请调用 HttpClientUtil.close(CloseableHttpResponse) 方法
* @param url
* @param paramName
* @param data
* @param param
* @param header
* @return CloseableHttpResponse
* @author jiaotq
* @created 2019/5/29 9:16
* @since v1.0.0
*/
public static CloseableHttpResponse postMultiparRetResp(String url, String paramName, ByteArrayBody data,
Map<String, String> param, Map<String, String> header) {
HttpPost httppost = new HttpPost(url);
if (header != null) {
header.forEach((k, v) -> {
httppost.setHeader(k, v);
});
}
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
builder.addPart(paramName, data);
if (param != null) {
param.forEach((k, v) -> {
builder.addTextBody(k, v, ContentType.TEXT_PLAIN);
});
}
HttpEntity entity = builder.build();
httppost.setEntity(entity);
return getHttpResponse(httppost);
}
/**
* 描述:post多个传文件
* 返回 CloseableHttpResponse 对象，需要手动将连接归还池中
* ，请调用 HttpClientUtil.close(CloseableHttpResponse) 方法
* @param url
* @param files key文件名称,value 文件流
* @param param
* @param header
* @return CloseableHttpResponse
* @author jiaotq
* @created 2019/5/29 9:16
* @since v1.0.0
*/
public static CloseableHttpResponse postMultiparsRetResp(String url,Map<String,byte[]> files,
Map<String, String> param, Map<String, String> header) {
HttpPost httppost = new HttpPost(url);
if (header != null) {
header.forEach((k, v) -> {
httppost.setHeader(k, v);
});
}
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
if(files!=null){
files.forEach((k,v)->{
builder.addBinaryBody(k, v, ContentType.MULTIPART_FORM_DATA, k);
});
}
if (param != null) {
param.forEach((k, v) -> {
builder.addTextBody(k, v, ContentType.TEXT_PLAIN);
});
}
HttpEntity entity = builder.build();
httppost.setEntity(entity);
return getHttpResponse(httppost);
}
/**
* 描述:post传xml
*
* @param url
* @param xml
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String postXml(String url, String xml) {
return postXml(url, xml, null);
}
/**
* 描述:post传xml
*
* @param url
* @param xml
* @param header
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String postXml(String url, String xml, Map<String, String> header) {
return getHttpClientRetStr(postXmlRetResp(url, xml, header));
}
/**
* 描述:post提交xml
* 返回 CloseableHttpResponse 对象，需要手动将连接归还池中
* ，请调用 HttpClientUtil.close(CloseableHttpResponse) 方法
*
* @param url
* @param xml
* @param header
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static CloseableHttpResponse postXmlRetResp(String url, String xml, Map<String, String> header) {
HttpPost httppost = new HttpPost(url);
if (header != null) {
header.forEach((k, v) -> {
httppost.setHeader(k, v);
});
}
StringEntity postingString = new StringEntity(xml, "UTF-8");
httppost.setEntity(postingString);
httppost.setHeader("Content-type", "text/xml");
return getHttpResponse(httppost);
}
/**
* 描述:post传json
*
* @param url
* @param json
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String postJson(String url, String json) {
return postJson(url, json, null);
}
/**
* 描述:post传json
*
* @param url
* @param json
* @param header
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String postJson(String url, String json, Map<String, String> header) {
return getHttpClientRetStr(postJsonRetResp(url, json, header));
}
public static String postDelJson(String url, String json, Map<String, String> header) {
return getHttpClientRetStr(postDelJsonResp(url, json, header));
}
private static CloseableHttpResponse postDelJsonResp(String url, String json, Map<String, String> header) {
HttpDeleteWithBody deleteWithBody = new HttpDeleteWithBody(url);
if (header != null) {
header.forEach(deleteWithBody::setHeader);
}
StringEntity postingString = new StringEntity(json, "UTF-8");
deleteWithBody.setEntity(postingString);
deleteWithBody.setHeader("Content-type", "application/json");
return getHttpResponse(deleteWithBody);
}
/**
* 描述:post 提交json
* 返回 CloseableHttpResponse 对象，需要手动将连接归还池中
* ，请调用 HttpClientUtil.close(CloseableHttpResponse) 方法
*
* @param url
* @param json
* @param header
* @return org.apache.http.client.methods.CloseableHttpResponse
* @author jiaotq
* @created 2019/6/10 11:44
* @since v1.0.0
*/
public static CloseableHttpResponse postJsonRetResp(String url, String json, Map<String, String> header) {
HttpPost httppost = new HttpPost(url);
if (header != null) {
header.forEach(httppost::setHeader);
}
StringEntity postingString = new StringEntity(json, "UTF-8");
httppost.setEntity(postingString);
RequestConfig config = RequestConfig.custom().setConnectionRequestTimeout(10000).build() ;
httppost.setConfig(config);
httppost.setHeader("Content-type", "application/json");
return getHttpResponse(httppost);
}
/**
* 描述:get提交
*
* @param url
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String get(String url) {
return get(url, null, null);
}
/**
* 描述:get提交
*
* @param url
* @param param
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String get(String url, Map<String, String> param) {
return get(url, param, null);
}
/**
* 描述:get提交
*
* @param url
* @param param
* @param header
* @return java.lang.String
* @author jiaotq
* @created 2019/5/29 9:17
* @since v1.0.0
*/
public static String get(String url, Map<String, String> param, Map<String, String> header) {
return getHttpClientRetStr(getHttpResponse(url, param, header));
}
/**
* 描述: get 获取
* 返回 CloseableHttpResponse 对象，需要手动将连接归还池中
* ，请调用 HttpClientUtil.close(CloseableHttpResponse) 方法
*
* @param url
* @param param
* @param header
* @return org.apache.http.client.methods.CloseableHttpResponse
* @author jiaotq
* @created 2019/6/10 11:35
* @since v1.0.0
*/
public static CloseableHttpResponse getHttpResponse(String url, Map<String, String> param, Map<String, String> header) {
StringBuilder reqParamStr = new StringBuilder();
if (param != null) {
reqParamStr.append("?");
param.forEach((k, v) -> {
reqParamStr.append(k).append("=").append(v).append("&");
});
}
HttpGet httpGet = new HttpGet(url + reqParamStr.toString());
if (header != null) {
header.forEach((k, v) -> {
httpGet.setHeader(k, v);
});
}
return getHttpResponse(httpGet);
}
public static CloseableHttpResponse getHttpResponse(HttpRequestBase http) {
CloseableHttpClient httpClient = HttpClientEnum.INITIALIZE.getHttpClient();
CloseableHttpResponse response = null;
try {
response = httpClient.execute(http);
} catch (Exception e) {
logger.warn(e.getMessage(), e);
close(response);
}
return response;
}
/**
* 描述:归还连接池
*
* @param response
* @return void
* @author jiaotq
* @created 2019/6/10 12:41
* @since v1.0.0
*/
public static void close(CloseableHttpResponse response) {
if (response != null) {
try {
response.close();
} catch (IOException e) {
logger.warn(e.getMessage(), e);
}
}
}
/**
* 描述:以字符串形式返回响应的结果
*
* @param response
* @return java.lang.String
* @author jiaotq
* @created 2019/6/10 12:48
* @since v1.0.0
*/
public static String getHttpClientRetStr(CloseableHttpResponse response) {
if (response == null) {
return null;
}
HttpEntity responseEntity = response.getEntity();
if (responseEntity != null) {
try {
return EntityUtils.toString(responseEntity, "UTF-8");
} catch (Exception e) {
logger.warn(e.getMessage(), e);
} finally {
close(response);
}
}
return null;
}
/**
* 描述:将流转bytes数组 *
* @author jiaotq
* @created 2019/6/10 12:54
* @since v1.0.0
*/
public static final byte[] inputToByte(InputStream inStream) throws IOException {
ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
byte[] buff = new byte[1024];
int rc = 0;
while ((rc = inStream.read(buff, 0, 1024)) > 0) {
swapStream.write(buff, 0, rc);
}
byte[] in2b = swapStream.toByteArray();
swapStream.close();
return in2b;
}
}
haoban-manage3-service/src/test/java/log/HttpDeleteWithBody.java 0 → 100644
package log;
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
import java.net.URI;
public class HttpDeleteWithBody extends HttpEntityEnclosingRequestBase {
public static final String METHOD_NAME = "DELETE";
public String getMethod() {
return METHOD_NAME;
}
public HttpDeleteWithBody(final String uri) {
super();
setURI(URI.create(uri));
}
public HttpDeleteWithBody(final URI uri) {
super();
setURI(uri);
}
public HttpDeleteWithBody() {
super();
}
}
\ No newline at end of file
haoban-manage3-service/src/test/java/log/KibanaLogDownload.java 0 → 100644
package log;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.gic.commons.util.DateUtil;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.HashMap;
import java.util.Map;
import java.util.function.Consumer;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
public class KibanaLogDownload {
static KibanaLogDownload esQueryHelper = new KibanaLogDownload();
ObjectMapper objectMapper = new ObjectMapper();
private String indexName = "filebeat-6.7.2*";
private String ip = "http://10.0.2.11:9200";
private int skipTime = 1000 * 60 * 60 * 4;
public static KibanaLogDownload getInstance() {
return esQueryHelper;
}
public KibanaLogDownload setIndexName(String indexName) {
this.indexName = indexName;
return this;
}
public KibanaLogDownload setIp(String ip) {
this.ip = ip;
return this;
}
/**
* 游标查询
* @param param 参数
* @param time 失效时间
* @param consumer 单条回调
*/
public void postScroll(String param, String time, Consumer<String> consumer) {
EsResult res = null;
String htt = ip + "/" + indexName + "/_search?scroll=" + time;
String s = HttpClientUtil.postJson(htt, param, null);
String scrollId = null ;
try {
res = JSON.parseObject(s, EsResult.class);
scrollId = res.get_scroll_id();
for (EsResult.Hits hits2 : res.getHits()) {
for (EsResult.Source hit : hits2.getHits()) {
consumer.accept(hit.get_source());
}
}
boolean empty;
do {
empty=true;
String htt2 = ip + "/_search/scroll";
Map<String, String> pa = new HashMap<>();
pa.put("scroll", time);
pa.put("scroll_id", scrollId);
String s2 = HttpClientUtil.postJson(htt2, JSON.toJSONString(pa), null);
res = JSON.parseObject(s2, EsResult.class);
for (EsResult.Hits hits2 : res.getHits()) {
for (EsResult.Source hit : hits2.getHits()) {
empty=false;
consumer.accept(hit.get_source());
}
}
} while (!empty);
Map<String, String> pa = new HashMap<>();
pa.put("scroll_id", scrollId);
String clearScrollRes = HttpClientUtil.postDelJson(ip + "/_search/scroll/", JSON.toJSONString(pa), null);
System.out.println("游标清除1:"+clearScrollRes);
}catch (Exception e) {
e.printStackTrace();
if (null != scrollId) {
Map<String, String> pa = new HashMap<>();
pa.put("scroll_id", scrollId);
String clearScrollRes = HttpClientUtil.postDelJson(ip + "/_search/scroll/", JSON.toJSONString(pa), null);
System.out.println("游标清除2:"+clearScrollRes);
}
}
}
static int logCount = 0 ;
public static void main(String[] args) throws InterruptedException {
String startTime = "2024-05-08 19:00" ;
String endTime = "2024-05-08 22:00" ;
long start = DateUtil.strToDate(startTime,"yyyy-MM-dd HH:mm").getTime() ;
long end = DateUtil.strToDate(endTime,"yyyy-MM-dd HH:mm").getTime() ;
//long start = 1714446600000l ;
//long end = 1714448399999l ;
int size = 10000 ;
int batch = 1 ;
JSONArray arr = new JSONArray() ;
for(int i=0;i<batch;i++) {
long per = (end - start) / batch ;
long s1 = start+ (i)*per ;
long s2 = start+ (i+1)*per ;
System.out.println(s1 + " " + s2);
JSONObject root = JSONObject.parseObject("{}") ;
root.put("size",size) ;
JSONObject query = JSONObject.parseObject("{\"bool\":{\"must\":[{\"match_all\":{}},{\"bool\":{\"should\":[{\"match_phrase\":{\"message\":\"创蓝彩信回执=\"}}],\"minimum_should_match\":1}},{\"range\":{\"@timestamp\":{\"gte\":1715166000000,\"lte\":1715176800000,\"format\":\"epoch_millis\"}}}],\"filter\":[],\"should\":[],\"must_not\":[]}}") ;
root.put("query",query) ;
KibanaLogDownload.getInstance().postScroll(root.toJSONString(), "15m", source -> {
try {
//System.out.println(source + (logCount++));
//
// System.out.println((source.split("创蓝彩信回执=")[1]));
Pattern p = Pattern.compile("\\[.*\\]") ;
Matcher m = p.matcher(source.split("创蓝彩信回执=")[1]) ;
while(m.find()) {
String s = m.group() ;
// System.out.println(s);
JSONArray xx = JSONArray.parseArray(s.replace("\\",""));
// System.out.println(xx.toJSONString());
arr.addAll(xx) ;
}
}catch (Exception e) {
}
});
}
System.out.println(arr.toJSONString());
}
}
haoban-manage3-service/src/test/resources/applicationContext-conf.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
<import resource="classpath:gic-haoban-init.xml" />
<import resource="classpath*:redis-init.xml"/>
<import resource="classpath:dubbo-haoban-manage-service.xml" />
<import resource="classpath:dubbo-setting-test.xml"/>
<import resource="classpath:jdbc-haoban-manage-service.xml" />
<import resource="classpath*:log-record-init.xml" />
</beans>
\ No newline at end of file
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