Skip to content

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

printStackTrace删除

parent 2a55aff2
Showing with 224 additions and 490 deletions
haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/dto/ClerkEditInfoDTO.java
...@@ -40,16 +40,4 @@ public class ClerkEditInfoDTO { ...@@ -40,16 +40,4 @@ public class ClerkEditInfoDTO {
int delClerkFlag = vo.getDelClerkFlag() << 2; int delClerkFlag = vo.getDelClerkFlag() << 2;
return editClerkFlag | addClerkFlag | delClerkFlag ; return editClerkFlag | addClerkFlag | delClerkFlag ;
} }
public static void main(String[] args) {
ClerkEditInfoDTO vo = new ClerkEditInfoDTO();
vo.setAddClerkFlag(1);
vo.setDelClerkFlag(0);
vo.setEditClerkFlag(0);
System.out.println(getValue(vo));
System.out.println(JSON.toJSONString(info(getValue(vo))));
}
} }
haoban-manage3-operation-web/src/main/java/com/gic/haoban/manage/web/controller/test/TestController.java
...@@ -185,7 +185,6 @@ public class TestController extends WebBaseController { ...@@ -185,7 +185,6 @@ public class TestController extends WebBaseController {
try { try {
clientInstance.sendBatchMessages("qywxTagSyncDeal", mqList); clientInstance.sendBatchMessages("qywxTagSyncDeal", mqList);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
logger.info("批量异常：{}", e); logger.info("批量异常：{}", e);
} }
return resultResponse(HaoBanErrCode.ERR_1); return resultResponse(HaoBanErrCode.ERR_1);
......
haoban-manage3-operation-web/src/main/java/com/gic/haoban/manage/web/utils/IOUtils.java deleted 100644 → 0
package com.gic.haoban.manage.web.utils;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.FilenameFilter;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.Reader;
import java.io.Writer;
public class IOUtils {
/**
* 6.编写一个程序，将D:\\java目录下的所有.java文件复制到D:\\jad目录下，
* 并将原来文件的扩展名从.java改为.jad。
*/
// public static class FileCopy {
// public static void main(String[] args) {
//
// File oriFile = new File("D:\\java");//原文件目录
// //file.exists():判断文件目录是否存在
// //file.isDirectory():判断文件目录是否是一个目录
// if(!(oriFile.exists() && oriFile.isDirectory())){
// System.out.println("文件目录不存在！");
// }
//
// File[] files = oriFile.listFiles(
// new FilenameFilter(){ //文件名称过滤器
// public boolean accept(File file, String name) {
// return name.endsWith(".java");
// }
// }
// );
// System.out.println(files.length);//原文件个数
//
// File objFile = new File("D:\\jad");//目标文件目录
// //objFile.exists():判断目标文件目录是否存在
// //objFile.mkdir():创建目标文件目录
// if(!objFile.exists()){
// objFile.mkdir();
// }
//
// //copyByte(files,objFile);
// copyChar(files,objFile);
// System.out.println("写入完成！");
//
// }
//使用字节流进行文件复制(字节缓冲流可以不使用，使用其目的主要是为了提高性能)
private static void copyByte(File[] files,File objFile){
InputStream inputStream = null;
OutputStream outputStream = null;
BufferedInputStream bufferedInputStream = null;
BufferedOutputStream bufferedOutputStream = null;
for(File f : files){
//替换文件后缀
String objFileName = f.getName().replaceAll("\\.ACC$", ".mp3");
try {
inputStream = new FileInputStream(f);
outputStream = new FileOutputStream(new File(objFile,objFileName));
bufferedInputStream = new BufferedInputStream(inputStream);
bufferedOutputStream = new BufferedOutputStream(outputStream);
int c = 0;
while((c = bufferedInputStream.read()) != -1){
bufferedOutputStream.write(c);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
bufferedOutputStream.close();
bufferedInputStream.close();
outputStream.close();
inputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
//使用字符流进行文件复制(字符缓冲流可以不使用，使用其目的主要是为了提高性能)
public static void copyChar(File file,File objFile){
Reader reader = null;
Writer writer = null;
BufferedReader bufferedReader = null;
BufferedWriter bufferedWriter = null;
//替换文件后缀
String objFileName = file.getName().replaceAll("\\.AAC$", ".mp3");
try {
reader = new FileReader(file);
writer = new FileWriter(new File(objFile,objFileName));
bufferedReader = new BufferedReader(reader);
bufferedWriter = new BufferedWriter(writer);
int c = 0;
while ((c=bufferedReader.read()) != -1) {
bufferedWriter.write(c);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
bufferedWriter.close();
bufferedReader.close();
writer.close();
reader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/hm/impl/WxUserAddLogServiceImpl.java
...@@ -149,7 +149,7 @@ public class WxUserAddLogServiceImpl implements WxUserAddLogService { ...@@ -149,7 +149,7 @@ public class WxUserAddLogServiceImpl implements WxUserAddLogService {
} }
this.wxUserAddLogMapper.insert(entity); this.wxUserAddLogMapper.insert(entity);
}catch(Exception e) { }catch(Exception e) {
e.printStackTrace(); log.info("异常",e);
} }
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/HandoverServiceImpl.java
...@@ -318,7 +318,6 @@ public class HandoverServiceImpl implements HandoverService { ...@@ -318,7 +318,6 @@ public class HandoverServiceImpl implements HandoverService {
handoverExternalMapper.updateByPrimaryKeySelective(handoverExternal); handoverExternalMapper.updateByPrimaryKeySelective(handoverExternal);
} catch (Exception e) { } catch (Exception e) {
logger.info("exception:{},{}", JSONObject.toJSONString(dto), e); logger.info("exception:{},{}", JSONObject.toJSONString(dto), e);
e.printStackTrace();
} }
}); });
return true; return true;
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/MaterialServiceImpl.java
...@@ -287,7 +287,6 @@ public class MaterialServiceImpl implements MaterialService { ...@@ -287,7 +287,6 @@ public class MaterialServiceImpl implements MaterialService {
url+= "?imageView2/2/w/1440/h/1080" ; url+= "?imageView2/2/w/1440/h/1080" ;
} }
logger.info("url={}",url); logger.info("url={}",url);
System.out.println(JSON.toJSONString(url));
} }
public List<String> getImageMediaId(String wxEnterpriseId, List<ContentMaterialDTO> imageList, int mediaType) { public List<String> getImageMediaId(String wxEnterpriseId, List<ContentMaterialDTO> imageList, int mediaType) {
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/StaffClerkBindLogServiceImpl.java
...@@ -58,7 +58,7 @@ public class StaffClerkBindLogServiceImpl implements StaffClerkBindLogService { ...@@ -58,7 +58,7 @@ public class StaffClerkBindLogServiceImpl implements StaffClerkBindLogService {
logger.info("绑定的mq日志：{}", ret); logger.info("绑定的mq日志：{}", ret);
clientInstance.sendMessage(STAFF_LOG_MQ, ret); clientInstance.sendMessage(STAFF_LOG_MQ, ret);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
} }
} }
...@@ -80,7 +80,7 @@ public class StaffClerkBindLogServiceImpl implements StaffClerkBindLogService { ...@@ -80,7 +80,7 @@ public class StaffClerkBindLogServiceImpl implements StaffClerkBindLogService {
logger.info("绑定的mq日志：{},{}", optStaffId, relationIds); logger.info("绑定的mq日志：{},{}", optStaffId, relationIds);
clientInstance.sendBatchMessages(STAFF_LOG_MQ, ret); clientInstance.sendBatchMessages(STAFF_LOG_MQ, ret);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
} }
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/DealSyncOperationApiServiceImpl.java
...@@ -735,8 +735,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -735,8 +735,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
logger.info("放入mq={},{}",mqName,JSON.toJSONString(listRet)); logger.info("放入mq={},{}",mqName,JSON.toJSONString(listRet));
clientInstance.sendBatchMessages(mqName, listRet, 10); clientInstance.sendBatchMessages(mqName, listRet, 10);
} catch (Exception e) { } catch (Exception e) {
logger.info("发送失败:{},{}", taskId, JSONObject.toJSONString(listRet)); logger.info("发送失败:{},{}", taskId, JSONObject.toJSONString(listRet),e);
e.printStackTrace();
} }
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/HandoverOperationApiServiceImpl.java
...@@ -187,7 +187,6 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ ...@@ -187,7 +187,6 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ
List<QywxTransferCustomerInfoDTO> customerResults = customerDTO.getCustomer(); List<QywxTransferCustomerInfoDTO> customerResults = customerDTO.getCustomer();
handoverService.dealResult(wxEnterpriseId, dto.getHandoverTransferId(), customerResults); handoverService.dealResult(wxEnterpriseId, dto.getHandoverTransferId(), customerResults);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
logger.info("处理异常：{},{}", JSONObject.toJSONString(dto), e); logger.info("处理异常：{},{}", JSONObject.toJSONString(dto), e);
} }
}); });
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/HaobanCommonMQApiServiceImpl.java
...@@ -57,8 +57,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService { ...@@ -57,8 +57,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
mqClient.sendCommonMessage("haobanCommonRouter", message, mqClient.sendCommonMessage("haobanCommonRouter", message,
"com.gic.haoban.manage.api.service.HaobanCommonMQApiService", "commonHandler"); "com.gic.haoban.manage.api.service.HaobanCommonMQApiService", "commonHandler");
} catch (Exception e) { } catch (Exception e) {
log.error("发送MQ异常"); log.error("发送MQ异常",e);
e.printStackTrace();
} }
} }
...@@ -69,8 +68,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService { ...@@ -69,8 +68,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
try { try {
mqClient.sendMessage("haobanDelayMQ", message, delay); mqClient.sendMessage("haobanDelayMQ", message, delay);
} catch (Exception e) { } catch (Exception e) {
log.error("发送MQ异常"); log.error("发送MQ异常",e);
e.printStackTrace();
} }
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/TestServiceImpl.java
...@@ -40,7 +40,7 @@ public class TestServiceImpl implements TestApiService { ...@@ -40,7 +40,7 @@ public class TestServiceImpl implements TestApiService {
try { try {
Thread.sleep(expireTime); Thread.sleep(expireTime);
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); logger.info("异常",e);
} }
} }
logger.info("测试-end：{}", id); logger.info("测试-end：{}", id);
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/WxEnterpriseRelatedApiServiceImpl.java
...@@ -380,8 +380,7 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi ...@@ -380,8 +380,7 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi
try { try {
clientInstance.sendMessage(FLUSH_HAOBAN_BIND_STORE_MQ, str, DELAY_TIME); clientInstance.sendMessage(FLUSH_HAOBAN_BIND_STORE_MQ, str, DELAY_TIME);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("发送消息异常：{}", str,e);
logger.info("发送消息异常：{}", str);
} }
} else { } else {
logger.info("最近已有在刷新，无需重复刷新：{}", JSONObject.toJSONString(mqDTO)); logger.info("最近已有在刷新，无需重复刷新：{}", JSONObject.toJSONString(mqDTO));
...@@ -653,7 +652,6 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi ...@@ -653,7 +652,6 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi
detailDTO.getRelations().add(groupInfoDTO); detailDTO.getRelations().add(groupInfoDTO);
this.wxEnterpriseBind(detailDTO); this.wxEnterpriseBind(detailDTO);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
logger.info("企业历史初始化失败：{}, {}", needDealEnt.getEnterpriseId(), e); logger.info("企业历史初始化失败：{}, {}", needDealEnt.getEnterpriseId(), e);
RedisUtil.setCache("init-fail-enterprise:" + needDealEnt.getWxEnterpriseRelatedId(), needDealEnt); RedisUtil.setCache("init-fail-enterprise:" + needDealEnt.getWxEnterpriseRelatedId(), needDealEnt);
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/friend/FriendClerkSyncNewOperation.java
...@@ -142,7 +142,6 @@ public class FriendClerkSyncNewOperation implements BaseSyncOperation { ...@@ -142,7 +142,6 @@ public class FriendClerkSyncNewOperation implements BaseSyncOperation {
//成功更新状态 //成功更新状态
dealSuccess(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dataPre.getEnterpriseId(), dataPre.getWxEnterpriseId()); dealSuccess(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dataPre.getEnterpriseId(), dataPre.getWxEnterpriseId());
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e); logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e);
reason = "成员好友处理异常"; reason = "成员好友处理异常";
dealFlag = false; dealFlag = false;
...@@ -194,7 +193,6 @@ public class FriendClerkSyncNewOperation implements BaseSyncOperation { ...@@ -194,7 +193,6 @@ public class FriendClerkSyncNewOperation implements BaseSyncOperation {
clientInstance.sendBatchMessages("departmentSyncDealMq", ret); clientInstance.sendBatchMessages("departmentSyncDealMq", ret);
} catch (Exception e) { } catch (Exception e) {
logger.info("发送失败:{},{}", taskId); logger.info("发送失败:{},{}", taskId);
e.printStackTrace();
} }
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/friend/FriendSyncNewOperation.java
...@@ -111,7 +111,6 @@ public class FriendSyncNewOperation implements BaseSyncOperation { ...@@ -111,7 +111,6 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
dealFlag = tryAgainToMq(dataPre); dealFlag = tryAgainToMq(dataPre);
reason = "接口重试超出限制"; reason = "接口重试超出限制";
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e); logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e);
reason = "第三方好友处理异常"; reason = "第三方好友处理异常";
dealFlag = false; dealFlag = false;
...@@ -185,7 +184,6 @@ public class FriendSyncNewOperation implements BaseSyncOperation { ...@@ -185,7 +184,6 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
clientInstance.sendBatchMessages("departmentSyncDealMq", ret); clientInstance.sendBatchMessages("departmentSyncDealMq", ret);
} catch (Exception e) { } catch (Exception e) {
logger.info("发送失败:{}", taskId, e); logger.info("发送失败:{}", taskId, e);
e.printStackTrace();
} }
} }
} }
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/friend/SelfFriendSyncNewOperation.java
...@@ -99,7 +99,6 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation { ...@@ -99,7 +99,6 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
dealFlag = tryAgainToMq(dataPre); dealFlag = tryAgainToMq(dataPre);
reason = "重试次数过多"; reason = "重试次数过多";
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e); logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e);
reason = "自建应用好友处理异常"; reason = "自建应用好友处理异常";
dealFlag = false; dealFlag = false;
...@@ -171,8 +170,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation { ...@@ -171,8 +170,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
Log.info("发送队列SelfFriendSyncNewOperation={}",JSON.toJSONString(ret)); Log.info("发送队列SelfFriendSyncNewOperation={}",JSON.toJSONString(ret));
clientInstance.sendBatchMessages("departmentSyncDealMq", ret); clientInstance.sendBatchMessages("departmentSyncDealMq", ret);
} catch (Exception e) { } catch (Exception e) {
logger.info("发送失败:{},{}", taskId); logger.info("发送失败:{},{}", taskId,e);
e.printStackTrace();
} }
} }
} }
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/tag/FriendMemberTagSyncOperation.java
...@@ -80,7 +80,6 @@ public class FriendMemberTagSyncOperation implements BaseSyncOperation { ...@@ -80,7 +80,6 @@ public class FriendMemberTagSyncOperation implements BaseSyncOperation {
} catch (Exception e) { } catch (Exception e) {
resultFlag = false; resultFlag = false;
reason = "处理异常:"; reason = "处理异常:";
e.printStackTrace();
logger.info("处理异常:{}", e); logger.info("处理异常:{}", e);
} finally { } finally {
if (!resultFlag) { if (!resultFlag) {
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/tag/FriendTagSyncOperation.java
...@@ -89,7 +89,6 @@ public class FriendTagSyncOperation implements BaseSyncOperation { ...@@ -89,7 +89,6 @@ public class FriendTagSyncOperation implements BaseSyncOperation {
} catch (Exception e) { } catch (Exception e) {
resultFlag = false; resultFlag = false;
reason = "处理异常:"; reason = "处理异常:";
e.printStackTrace();
logger.info("处理异常:{}", e); logger.info("处理异常:{}", e);
} finally { } finally {
if (!resultFlag) { if (!resultFlag) {
...@@ -214,8 +213,7 @@ public class FriendTagSyncOperation implements BaseSyncOperation { ...@@ -214,8 +213,7 @@ public class FriendTagSyncOperation implements BaseSyncOperation {
try { try {
clientInstance.sendMessage("departmentSyncDealMq", JSONObject.toJSONString(dealParamMqDTO)); clientInstance.sendMessage("departmentSyncDealMq", JSONObject.toJSONString(dealParamMqDTO));
} catch (Exception e) { } catch (Exception e) {
logger.info("发送失败:{},{}", taskId, relationId); logger.info("发送失败:{},{}", taskId, relationId,e);
e.printStackTrace();
} }
}); });
} }
......
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/util/CommonUtil.java
...@@ -33,7 +33,6 @@ public class CommonUtil { ...@@ -33,7 +33,6 @@ public class CommonUtil {
public static void main(String[] args) { public static void main(String[] args) {
getFileByte("https://jhdm-1251519181.cos.ap-shanghai.myqcloud.com/image/material_content-cce7cc3de0bf48cebf16fb5c65f4ae9c.jpg?imageView2/format/jpg/q/50?imageView2/2/w/1440/h/1080") ; getFileByte("https://jhdm-1251519181.cos.ap-shanghai.myqcloud.com/image/material_content-cce7cc3de0bf48cebf16fb5c65f4ae9c.jpg?imageView2/format/jpg/q/50?imageView2/2/w/1440/h/1080") ;
System.out.println(1);
} }
} }
\ No newline at end of file
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/util/DrawImageUtils.java
...@@ -104,10 +104,8 @@ public class DrawImageUtils { ...@@ -104,10 +104,8 @@ public class DrawImageUtils {
Random random = new Random(); Random random = new Random();
String url = DrawImageUtils.drawImage("jhdm", Math.abs(random.nextInt(1000)) + "", String url = DrawImageUtils.drawImage("jhdm", Math.abs(random.nextInt(1000)) + "",
Math.abs(random.nextInt(1000)) + "万", DrawBkgImg.AREA_MONTH_BKG); Math.abs(random.nextInt(1000)) + "万", DrawBkgImg.AREA_MONTH_BKG);
System.out.println(url);
String temp = DrawImageUtils.drawImage("jhdm", Math.abs(random.nextInt(1000)) + "", String temp = DrawImageUtils.drawImage("jhdm", Math.abs(random.nextInt(1000)) + "",
Math.abs(random.nextInt(1000)) + "万", DrawBkgImg.CLERK_MONTH_BKG); Math.abs(random.nextInt(1000)) + "万", DrawBkgImg.CLERK_MONTH_BKG);
System.out.println(temp);
} }
} }
haoban-manage3-service/src/test/java/ChatTest.java
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.gic.clerk.api.service.ClerkService;
import com.gic.commons.util.GICMQClientUtil; import com.gic.commons.util.GICMQClientUtil;
import com.gic.dubbo.util.DubboInvokeUtil;
import com.gic.enterprise.api.service.StoreService;
import com.gic.haoban.app.customer.service.api.service.CustomerApiService;
import com.gic.haoban.manage.api.dto.SecretSettingDTO;
import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO; import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO;
import com.gic.haoban.manage.api.dto.chat.GroupChatPlanDTO; import com.gic.haoban.manage.api.dto.chat.GroupChatPlanDTO;
import com.gic.haoban.manage.api.dto.notify.qdto.NoticeMessageQDTO; import com.gic.haoban.manage.api.dto.notify.qdto.NoticeMessageQDTO;
import com.gic.haoban.manage.api.dto.notify.qdto.NotifyMessageBatchQDTO; import com.gic.haoban.manage.api.dto.notify.qdto.NotifyMessageBatchQDTO;
import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum; import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum;
import com.gic.haoban.manage.api.service.HandoverOperationApiService; import com.gic.haoban.manage.api.enums.SecretTypeEnum;
import com.gic.haoban.manage.api.service.QywxTagApiService; import com.gic.haoban.manage.api.service.*;
import com.gic.haoban.manage.api.service.StaffApiService; import com.gic.haoban.manage.api.service.hm.HmQrcodeApiService;
import com.gic.haoban.manage.api.service.notify.NoticeMessageApiService; import com.gic.haoban.manage.api.service.notify.NoticeMessageApiService;
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.dao.mapper.StaffMapper;
import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated;
import com.gic.haoban.manage.service.service.*;
import com.gic.haoban.manage.service.service.chat.GroupChatPlanService; import com.gic.haoban.manage.service.service.chat.GroupChatPlanService;
import com.gic.haoban.manage.service.service.chat.GroupChatService;
import com.gic.haoban.manage.service.service.hm.HmLinkService;
import com.gic.haoban.manage.service.service.hm.WxUserAddLogService;
import com.gic.haoban.manage.service.service.role.HaobanMenuService;
import com.gic.member.api.service.MemberApiService;
import com.gic.member.api.service.MemberEntranceApiService;
import com.gic.member.api.service.MemberService;
import com.gic.member.api.service.MemberStoreService;
import com.gic.member.tag.api.service.MemberTagOpenApiService;
import com.gic.wechat.api.dto.qywx.QywxNewsArticleMessageDTO; import com.gic.wechat.api.dto.qywx.QywxNewsArticleMessageDTO;
import com.gic.wechat.api.dto.qywx.QywxNewsSendMessageDTO; import com.gic.wechat.api.dto.qywx.QywxNewsSendMessageDTO;
import com.gic.wechat.api.service.qywx.QywxExternalUserService;
import com.gic.wechat.api.service.qywx.QywxSuiteApiService; import com.gic.wechat.api.service.qywx.QywxSuiteApiService;
import com.gic.wechat.api.service.qywx.QywxUserApiService;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -35,18 +54,175 @@ public class ChatTest { ...@@ -35,18 +54,175 @@ public class ChatTest {
private static Logger logger = LoggerFactory.getLogger(ChatTest.class); private static Logger logger = LoggerFactory.getLogger(ChatTest.class);
@Autowired @Autowired
private HandoverOperationApiService handoverOperationApiService; private GroupChatService croupChatService;
@Autowired @Autowired
private StaffApiService staffApiService ; private StaffApiService staffApiService ;
@Autowired
private QwFriendApiService qwFriendApiService ;
@Autowired
private MemberUnionRelatedService memberUnionRelatedService;
@Autowired
private StaffService staffService;
@Autowired
private QywxUserApiService qywxUserApiService;
@Autowired
private WxEnterpriseRelatedService wxEnterpriseRelatedService;
@Autowired
private WxEnterpriseService wxEnterpriseService;
@Autowired
private ClerkService clerkService;
@Autowired
private ClerkMainStoreRelatedService clerkMainStoreRelatedService;
@Autowired
private StoreService storeService;
@Autowired
private Config config;
@Autowired
private QywxSuiteApiService qywxSuiteApiService;
@Autowired
private SecretSettingService secretSettingService;
@Autowired
private StaffClerkRelationService staffClerkRelationService;
@Autowired
private ExternalClerkRelatedService externalClerkRelatedService;
@Autowired
private CheckQywxSettingApiService checkQywxSettingApiService;
@Autowired
private CustomerApiService customerApiService;
@Autowired
private MemberApiService memberApiService;
@Autowired
private TabHaobanExternalClerkRelatedMapper externalClerkRelatedMapper;
@Autowired
private ExternalClerkRelatedApiService externalClerkRelatedApiService;
@Autowired
private MemberStoreService memberStoreService;
@Autowired
private HmQrcodeApiService hmQrcodeApiService;
@Autowired
private WxUserAddLogService wxUserAddLogService;
@Autowired
private KeyDataService keyDataService;
@Autowired
private MemberTagOpenApiService memberTagOpenApiService;
@Autowired
private HmLinkService hmLinkService;
@Autowired
private MemberService memberService;
@Autowired
private StaffMapper staffMapper;
@Autowired
private MemberEntranceApiService memberEntranceApiService;
@Autowired
private QywxSendService qywxSendService ;
@Autowired
private GroupChatService groupChatService ;
@Autowired
private WelcomeSendService welcomeSendService ;
@Autowired
private ExternalMemberService externalMemberService ;
@Autowired
private ClerkMainStoreRelatedApiService clerkMainStoreRelatedApiService ;
@Autowired
private HaobanMenuService haobanMenuService ;
@Autowired
private QywxExternalUserService qywxExternalUserService;
@Test @Test
public void test() { public void test() {
this.staffApiService.updateStaffHead("ca66a01b79474c40b3e7c7f93daf1a3b","d7c29cb654b543d1966181c2ec2186ea","https://pic01-10001430.image.myqcloud.com/04564abc-5e82-4ba7-9ef3-39803438bb2c") ;
// this.handoverOperationApiService.dealQywxEnterpriseHandoverMq("ca66a01b79474c40b3e7c7f93daf1a3b") ;
for(int i=0;i<3;i++) {
new Thread(new Runnable() {
@Override
public void run() {
TabHaobanExternalClerkRelated dto = new TabHaobanExternalClerkRelated() ;
dto.setExternalUserId("1234567");
dto.setClerkId("123");
dto.setStatusFlag(1);
externalClerkRelatedService.insert(dto) ;
}
}).start();
}
if(true)
for(;;){
}
// Object token = this.qywxExternalUserService.token("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","wp8KhBDgAAaE3jm1L7ARKe2yxc1hci4A","1000045",1,"http://122.9.98.129:8990#192.168.0.58") ;
// logger.info("获取token"+JSONObject.toJSONString(token));
// Object token = this.qywxExternalUserService.token("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","wp8KhBDgAAE90YWr3_wIt6XXljkZvZXg","1000172",1,"http://122.9.98.129:8990#192.168.0.58") ;
// logger.info("获取token-润臣"+JSONObject.toJSONString(token));
String tokensy = "kxCbwqAa7KrxnmW4gOFCa-KGM2N3gbkgVLNKiWUDk5AfiBQK8Xus6AP74U9eBKVDZxM8_C6EtZ0WWBQonUx3wnjfTCVyH0yorHXU2gR08dTZjUKE4Ej8ERMdYisZ6f30tFv37zgQqangmweC6vp7eFpUQC81Bg2qTylmqV0mVupyXWGqp4m7rzCKh4-MUn6Ry-mGy3xPYUwkpImRFmneBQ" ;
String tokenyc = "t3Uu9b0cDIl_y5uyDRnQw3fhmUx-C1pCK1N6xHfDROrySlxUD74ophI0Pel2RQzy4f6qVGnpJu5k6w3j2LolMh2JqkmfAFe8-991h0a4zwlGgFzZAlY1jtcE8mJ911oJkowAvuf8cLuO-iaM2BwjBg8VGrjaVmtLJiNczHOQkVHmhSVF7ubWMj52HCIgxv51pGpMpG5G8SvRnbzIjyW5hw";
Object a1 = this.qywxExternalUserService.req("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","https://qyapi.weixin.qq.com/cgi-bin/corpgroup/unionid_to_pending_id?access_token=",JSONObject.parseObject("{\"unionid\":\"orXl9t6P-XBJQyaNCaJj38GLyYd0\",\"openid\":\"o0Yvd0246SId1HwEjQa54LzMcFU0\"}"),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("unionid查询pending_id"+JSONObject.toJSONString(a1));
Object a2 = this.qywxExternalUserService.req("https://qyapi.weixin.qq.com/cgi-bin/corpgroup/batch/external_userid_to_pending_id?access_token="+tokenyc,JSONObject.parseObject("{\"external_userid\":[\"wm8KhBDgAAlUiFWOeNzuyRR0EoMGLmRw\",\"wm8KhBDgAASGKj-mQQ2RAuU7e07gfJBg\"]}"),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("external_userid查询pending_id"+JSONObject.toJSONString(a2));
Object a3 = this.qywxExternalUserService.req("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","https://qyapi.weixin.qq.com/cgi-bin/corpgroup/batch/external_userid_to_pending_id?access_token=",JSONObject.parseObject("{\"external_userid\":[\"wm8KhBDgAASGKj-mQQ2RAuU7e07gfJBg\"]}"),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("external_userid查询pending_id3"+JSONObject.toJSONString(a3));
Object a4 = this.qywxExternalUserService.unionidToExternalUseridCorpgroup("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","orXl9t6P-XBJQyaNCaJj38GLyYd0","o0Yvd0246SId1HwEjQa54LzMcFU0","http://122.9.98.129:8990#192.168.0.58") ;
logger.info("通过unionid和openid查询external_userid"+JSONObject.toJSONString(a4));
Object o1 = this.qywxExternalUserService.listcorpid("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","1000031",1,"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("查询企业列表"+JSONObject.toJSONString(o1));
if(true) {
return ;
}
// 4Y6h7OfJSCzGYv3puNFLYO57s0TQubbFuIxLyqJjINflwa4Vezt2DgDf53k2ajRAFM6nm1uk4SsDSOmzSSUO-EbHAHm6bpTIkDjiMvAtQxWjzhpQW5y6MShFKCo91zjaqWCdXr8CMKNXfXlBW_Dlx3Tym7SJrs4FEN_h0lFftCe12gcgbfPqPxOMeP-sk3XaYPdtfZVkYFNAsFJGgPbzBA
Object o2 = this.qywxExternalUserService.req("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get?access_token="+tokensy+"&external_userid=wm8KhBDgAAl30re_xOKcrdP-XJW4hL9w",new JSONObject(),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("客户详情"+JSONObject.toJSONString(o2));
Object o3 = this.qywxExternalUserService.req("https://qyapi.weixin.qq.com/cgi-bin/user/simplelist?access_token="+tokensy+"&department_id=1",new JSONObject(),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("通讯录"+JSONObject.toJSONString(o3));
Object o4 = this.qywxExternalUserService.req("https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token="+tokensy+"&userid=wo8KhBDgAAoj4rHdDE0P0vNNfjs6cl3w",new JSONObject(),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("成员详情"+JSONObject.toJSONString(o4));
Object o6 = this.qywxExternalUserService.req("https://qyapi.weixin.qq.com/cgi-bin/agent/get?access_token="+tokensy+"&agentid=1000045",new JSONObject(),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("应用信息"+JSONObject.toJSONString(o6));
// {"errcode":0,"chains":[{"chain_id":"wgfc938e1ba44e30f5","chain_name":"达摩科技的经销商"}],"errmsg":"ok"}
Object o5 = this.qywxExternalUserService.req("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","https://qyapi.weixin.qq.com/cgi-bin/corpgroup/corp/get_chain_list?access_token=",new JSONObject(),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("滴答滴答滴答滴答滴答滴答5"+JSONObject.toJSONString(o5));
// {"errcode":0,"errmsg":"ok","groups":[{"group_name":"达摩科技的经销商","groupid":1,"parentid":0,"order":100000000},
// {"group_name":"一级经销商","groupid":3,"parentid":1,"order":99999000},{"group_name":"二级经销商","groupid":4,"parentid":1,"order":99998000}]}
Object o7 = this.qywxExternalUserService.req("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","https://qyapi.weixin.qq.com/cgi-bin/corpgroup/corp/get_chain_group?access_token=",JSONObject.parseObject("{\"chain_id\":\"wgfc938e1ba44e30f5\"}"),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("上下游"+JSONObject.toJSONString(o7));
Object o8 = this.qywxExternalUserService.req("ww468ed06ba5fa5604","StuEbLhpszQKMNWyRqwDeeX4AGRKm__DAF6k7UwXL-A","https://qyapi.weixin.qq.com/cgi-bin/corpgroup/corp/get_chain_list?access_token=",new JSONObject(),"http://122.9.98.129:8990#192.168.0.58") ;
logger.info("get_chain_list"+JSONObject.toJSONString(o8));
String wxEnterpriseId = "b18ffdc9d0644912865a248859914d80";
WxEnterpriseQwDTO qwDTO = this.wxEnterpriseService.getQwInfo(wxEnterpriseId);
SecretSettingDTO secretSetting = secretSettingService.getSecretSetting(wxEnterpriseId, SecretTypeEnum.CUSTOMIZED_APP.getVal());
// String unionIdJson = qywxUserApiService.getCorpSelfExternalUseridInfo(qwDTO.getDkCorpid(), secretSetting.getSecretVal(), "wm8KhBDgAAl30re_xOKcrdP-XJW4hL9w", qwDTO.getUrlHost());
// logger.info(unionIdJson);
// this.qwFriendApiService.getPendingIdByUnionid("ff80808189dd5e490189dd88daf60003","orXl9t6P-XBJQyaNCaJj38GLyYd0","") ;
} }
@Test @Test
public void sendMessageTest() throws Exception { public void sendMessageTest() throws Exception {
String params = "{\"enterpriseId\":\"ff8080815dacd3a2015dacd3ef5c0000\",\"memberId\":\"ff80808187732d6001877333a8030000\",\"opt\":1,\"unionId\":\"orXl9t70uwsdD7kqjNmWu03nKSCg\"}"; String params = "{\"enterpriseId\":\"ff8080815dacd3a2015dacd3ef5c0000\",\"memberId\":\"ff80808187732d6001877333a8030000\",\"opt\":1,\"unionId\":\"orXl9t70uwsdD7kqjNmWu03nKSCg\"}";
GICMQClientUtil.getClientInstance().sendMessage("memberIdChangeNotify", params); GICMQClientUtil.getClientInstance().sendMessage("memberIdChangeNotify", params);
} }
......
haoban-manage3-service/src/test/java/CountDownLatchTest.java
...@@ -36,7 +36,6 @@ public class CountDownLatchTest implements Runnable{ ...@@ -36,7 +36,6 @@ public class CountDownLatchTest implements Runnable{
long endTime = System.currentTimeMillis(); long endTime = System.currentTimeMillis();
System.out.println(Thread.currentThread().getName() + " ended at: " + endTime + ", cost: " + (endTime - startTime) + " ms."); System.out.println(Thread.currentThread().getName() + " ended at: " + endTime + ", cost: " + (endTime - startTime) + " ms.");
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
} }
} }
......
haoban-manage3-service/src/test/java/HandoverTest.java
...@@ -66,7 +66,6 @@ public class HandoverTest { ...@@ -66,7 +66,6 @@ public class HandoverTest {
try { try {
clientInstance.sendMessage("haobanEcmTaskDataCallback", "11111"); clientInstance.sendMessage("haobanEcmTaskDataCallback", "11111");
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
} }
} }
} }
haoban-manage3-service/src/test/java/TagTest3.java
...@@ -9,6 +9,7 @@ import com.gic.haoban.manage.service.config.Config; ...@@ -9,6 +9,7 @@ import com.gic.haoban.manage.service.config.Config;
import com.gic.haoban.manage.service.pojo.bo.hm.HmQrcodeBO; import com.gic.haoban.manage.service.pojo.bo.hm.HmQrcodeBO;
import com.gic.haoban.manage.service.service.StaffClerkRelationService; import com.gic.haoban.manage.service.service.StaffClerkRelationService;
import com.gic.haoban.manage.service.service.WxEnterpriseService; import com.gic.haoban.manage.service.service.WxEnterpriseService;
import com.gic.haoban.manage.service.service.chat.GroupChatService;
import com.gic.haoban.manage.service.service.hm.HmClerkRelationService; import com.gic.haoban.manage.service.service.hm.HmClerkRelationService;
import com.gic.haoban.manage.service.service.hm.HmQrcodeService; import com.gic.haoban.manage.service.service.hm.HmQrcodeService;
import com.gic.mq.sdk.GicMQClient; import com.gic.mq.sdk.GicMQClient;
...@@ -37,41 +38,13 @@ public class TagTest3 { ...@@ -37,41 +38,13 @@ public class TagTest3 {
@Autowired @Autowired
private Config config ; private Config config ;
@Autowired @Autowired
private HmClerkRelationService hmClerkRelationService ; private GroupChatService groupChatService ;
@Autowired @Autowired
private ExternalClerkRelatedApiService externalClerkRelatedApiService ; private ExternalClerkRelatedApiService externalClerkRelatedApiService ;
@Test @Test
public void tt() throws InterruptedException { public void tt() throws InterruptedException {
this.groupChatService.initStaffGroupChat("ef5f5650bc744413b817d3429271085c") ;
// String wxEnterpriseId, String enterpriseId, QywxTagInfoDTO infoDTO, List<QywxTagItemDTO> items
String wxEnterpriseId = "ca66a01b79474c40b3e7c7f93daf1a3b" ;
String enterpriseId = "ff8080815dacd3a2015dacd3ef5c0000" ;
QywxTagInfoDTO infoDTO = new QywxTagInfoDTO() ;
infoDTO.setWxEnterpriseId(wxEnterpriseId);
infoDTO.setMemberTagId("5b1db406e21748e88737a4cbe194d24f");
List<QywxTagItemDTO> items = new ArrayList<>() ;
QywxTagItemDTO mid = new QywxTagItemDTO();
mid.setMemberTagItemId("0f08ddb354654638bc8f71ce39fce688");
mid.setQywxTagName("企微1");
items.add(mid) ;
QywxTagItemDTO mid2 = new QywxTagItemDTO();
mid2.setMemberTagItemId("1e3f324af76842a0a3b7697f95419414");
mid2.setQywxTagName("企微2");
items.add(mid2) ;
QywxTagItemDTO mid3 = new QywxTagItemDTO();
mid3.setMemberTagItemId("qw5");
mid3.setQywxTagKey("qw5");
mid3.setQywxTagName("企微5");
items.add(mid3) ;
this.qywxTagApiService.syncTagToQywx(wxEnterpriseId,enterpriseId,infoDTO,items) ;
} }
} }
haoban-manage3-service/src/test/java/test.java deleted 100644 → 0
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.Date;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import cn.hutool.cache.CacheUtil;
import cn.hutool.cache.impl.TimedCache;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.Week;
import cn.hutool.crypto.digest.MD5;
import com.alibaba.fastjson.JSONObject;
import com.gic.haoban.manage.api.enums.NoticeMessageTypeEnum;
import com.gic.haoban.manage.api.enums.content.MaterialReportType;
import com.gic.haoban.manage.api.util.notify.NoticeMessageUtil;
import com.gic.haoban.manage.service.entity.TabHaobanPreDealLog;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.junit.Test;
public class test {
private static final TimedCache<String, TestQo> cache = CacheUtil.newTimedCache(3000L);
public static void main(String[] args) throws Exception {
// pages/hb/material/material-root/material-root?contentMaterialId=517690074188505121&storeId=ff8080818499a5f301849ceb9f870035&channelSource=5&clerkId=bcbfff6c8e2e40aaac795a99d0dde2aa
String refUrl = "pages/hb/material/material-root/material-root?contentMaterialId=517690074188505121&storeId=ff8080818499a5f301849ceb9f870035&channelSource=5&clerkId=bcbfff6c8e2e40aaac795a99d0dde2aaADASDD";
int indexOf = StringUtils.indexOf(refUrl, "clerkId=");
if (indexOf != -1) {
String clerkId = StringUtils.substring(refUrl, indexOf + 8, indexOf + 40);
System.out.println(clerkId);
}
System.out.println(DateUtil.year(new Date()) + "-" + DateUtil.month(DateUtil.lastMonth()));
System.out.println(DateUtil.year(new Date()) + "" + DateUtil.weekOfYear(DateUtil.lastWeek()));
System.out.println("-----");
int weekOfYear = DateUtil.weekOfYear(DateUtil.lastWeek());
System.out.println(DateUtil.thisYear() + "-" + StringUtils.leftPad(weekOfYear + "", 2, "0"));
// 月报
int month = DateUtil.lastMonth().month() + 1;
System.out.println(DateUtil.thisYear() + "-" + StringUtils.leftPad(month + "", 2, "0"));
System.out.println("---------------------");
DateTime dateTime = DateUtil.parse("2023-01-01", "yyyy-MM-dd");
System.out.println(DateUtil.weekOfYear(dateTime));
System.out.println(DateUtil.beginOfWeek(DateUtil.lastWeek()).toString("yyyy-MM-dd"));
System.out.println(DateUtil.offset(DateUtil.lastWeek(), DateField.DAY_OF_WEEK, DateUtil.weekOfYear(DateUtil.lastWeek())));
System.out.println(DateUtil.offsetWeek(new Date(), DateUtil.weekOfYear(DateUtil.lastWeek())));
System.out.println(DateUtil.offsetWeek(new Date(), DateUtil.weekOfYear(DateUtil.lastWeek())));
System.out.println(DateUtil.offsetWeek(new Date(), DateUtil.weekOfYear(DateUtil.lastWeek())));
System.out.println(DateUtil.beginOfMonth(DateUtil.lastMonth()).toString("yyyy-MM-dd"));
}
@Test
public void urlTest(){
JSONObject params = new JSONObject();
//params.put("clerkId", "300b60c7f8874ca2b9cc696ad6b6a480");
String bizDate = DateUtil.beginOfWeek(DateUtil.lastWeek()).toString("yyyy-MM-dd");
params.put("k", "ff8080816e216c04016e34294282004a_1_" + bizDate);
// params.put("t", 1);
// params.put("d", "04");
String s = params.toJSONString();
String s1 = NoticeMessageUtil.buildMiniAppUrl(NoticeMessageTypeEnum.MATERIAL_REPORT_NOTIFY_MONTH, s);
System.out.println("/pages/route/index?pageType=hbapp_material_report&data=".length());
System.out.println(s1);
System.out.println(s1.length());
}
@Test
public void timeTest(){
String key = "czMYwiF1VNyNBn2dOS0Aie2vL8yo0W1F" + "bcbfff6c8e2e40aaac795a99d0dde2aa" + "521005558220738651" + "ff8080818147efc8018148d1759903c8";
System.out.println(MD5.create().digestHex(key));
}
}
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/ApplicationController.java
...@@ -244,7 +244,7 @@ public class ApplicationController extends WebBaseController { ...@@ -244,7 +244,7 @@ public class ApplicationController extends WebBaseController {
try { try {
response.sendRedirect(redirectUri); response.sendRedirect(redirectUri);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); log.info("异常",e);
} }
} }
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/LoginController.java
...@@ -103,7 +103,7 @@ public class LoginController extends WebBaseController { ...@@ -103,7 +103,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} }
...@@ -116,7 +116,7 @@ public class LoginController extends WebBaseController { ...@@ -116,7 +116,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} }
...@@ -127,7 +127,7 @@ public class LoginController extends WebBaseController { ...@@ -127,7 +127,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} }
...@@ -146,7 +146,7 @@ public class LoginController extends WebBaseController { ...@@ -146,7 +146,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} }
...@@ -157,7 +157,7 @@ public class LoginController extends WebBaseController { ...@@ -157,7 +157,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} }
...@@ -169,7 +169,7 @@ public class LoginController extends WebBaseController { ...@@ -169,7 +169,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} }
...@@ -189,7 +189,7 @@ public class LoginController extends WebBaseController { ...@@ -189,7 +189,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code); response.sendRedirect(host+"/haoban-3/#/gic-error?errorCode="+code);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return this.fail(this.errMessage(code)); return this.fail(this.errMessage(code));
} else { } else {
...@@ -314,7 +314,7 @@ public class LoginController extends WebBaseController { ...@@ -314,7 +314,7 @@ public class LoginController extends WebBaseController {
try { try {
response.sendRedirect(gicHost); response.sendRedirect(gicHost);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return null ; return null ;
} }
...@@ -406,7 +406,7 @@ public class LoginController extends WebBaseController { ...@@ -406,7 +406,7 @@ public class LoginController extends WebBaseController {
response.sendRedirect(redirectUri); response.sendRedirect(redirectUri);
response.setHeader("token", token); response.setHeader("token", token);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); logger.info("异常",e);
} }
return null; return null;
} }
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/MaterialController.java
...@@ -287,8 +287,4 @@ public class MaterialController extends WebBaseController { ...@@ -287,8 +287,4 @@ public class MaterialController extends WebBaseController {
} }
return null ; return null ;
} }
public static void main(String[] args) {
System.out.println(EmojiFilterUtil.filterEmoji("！@#~！@#￥%……&*&）（）——+——+{}“”：？》") );;
}
} }
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/MemberController.java
...@@ -91,7 +91,6 @@ public class MemberController { ...@@ -91,7 +91,6 @@ public class MemberController {
ESResponseQueryCount esCount = esApiService.queryDataCount(search); ESResponseQueryCount esCount = esApiService.queryDataCount(search);
count = (int) esCount.getRes(); count = (int) esCount.getRes();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
} }
return RestResponse.successResult(count); return RestResponse.successResult(count);
} }
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/StaffController.java
...@@ -598,7 +598,7 @@ public class StaffController extends WebBaseController { ...@@ -598,7 +598,7 @@ public class StaffController extends WebBaseController {
try { try {
ExcelUtils.xls(response, request, fileName, voList, fileList, titleList); ExcelUtils.xls(response, request, fileName, voList, fileList, titleList);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
logger.info("导出失败"); logger.info("导出失败");
} }
return null; return null;
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/TestController.java
...@@ -520,7 +520,7 @@ public class TestController extends WebBaseController { ...@@ -520,7 +520,7 @@ public class TestController extends WebBaseController {
url = url+"/api-qywx-self/qywx/self-post?ip=" + ip + "&url=" url = url+"/api-qywx-self/qywx/self-post?ip=" + ip + "&url="
+ URLEncoder.encode(selfUrl, "utf-8"); + URLEncoder.encode(selfUrl, "utf-8");
Map<String, Object> map1 = httpsRequest(url, "GET", null); Map<String, Object> map1 = httpsRequest(url, "GET", null);
System.out.println(JSONObject.toJSONString(map1)); logger.info(JSONObject.toJSONString(map1));
String errcode = map1.get("errcode").toString(); String errcode = map1.get("errcode").toString();
if (!"0".equals(errcode)) { if (!"0".equals(errcode)) {
return map1; return map1;
...@@ -530,11 +530,11 @@ public class TestController extends WebBaseController { ...@@ -530,11 +530,11 @@ public class TestController extends WebBaseController {
for(int i=0;i<arr.size();i++) { for(int i=0;i<arr.size();i++) {
JSONObject obj = arr.getJSONObject(i) ; JSONObject obj = arr.getJSONObject(i) ;
// System.out.println(obj.toJSONString()); // logger.info(obj.toJSONString());
String groupName = obj.getString("group_name") ; String groupName = obj.getString("group_name") ;
String groupId = obj.getString("group_id") ; String groupId = obj.getString("group_id") ;
String where = " where qywx_group_name ='"+groupName+"' and wx_enterprise_id='"+wxEnterpriseId+"' and status_flag = 1 ; " ; String where = " where qywx_group_name ='"+groupName+"' and wx_enterprise_id='"+wxEnterpriseId+"' and status_flag = 1 ; " ;
//System.out.println("select * from tab_haoban_qywx_tag " + where ); //logger.info("select * from tab_haoban_qywx_tag " + where );
String str = ("update tab_haoban_qywx_tag set qywx_group_key = '"+groupId+"'" + where ); String str = ("update tab_haoban_qywx_tag set qywx_group_key = '"+groupId+"'" + where );
list.add(str) ; list.add(str) ;
} }
...@@ -552,7 +552,7 @@ public class TestController extends WebBaseController { ...@@ -552,7 +552,7 @@ public class TestController extends WebBaseController {
String tagName = tagObj.getString("name") ; String tagName = tagObj.getString("name") ;
String tagId = tagObj.getString("id") ; String tagId = tagObj.getString("id") ;
String tagWhere = " where qywx_group_key = '"+groupId+"' and qywx_tag_name ='"+tagName+"' and wx_enterprise_id='"+wxEnterpriseId+"' and status_flag = 1 ; " ; String tagWhere = " where qywx_group_key = '"+groupId+"' and qywx_tag_name ='"+tagName+"' and wx_enterprise_id='"+wxEnterpriseId+"' and status_flag = 1 ; " ;
//System.out.println("select * from tab_haoban_qywx_tag_item " + tagWhere ); //logger.info("select * from tab_haoban_qywx_tag_item " + tagWhere );
list.add("update tab_haoban_qywx_tag_item set qywx_tag_key = '"+tagId+"'" + tagWhere ); list.add("update tab_haoban_qywx_tag_item set qywx_tag_key = '"+tagId+"'" + tagWhere );
} }
} }
...@@ -597,9 +597,9 @@ public class TestController extends WebBaseController { ...@@ -597,9 +597,9 @@ public class TestController extends WebBaseController {
logger.info(JSON.toJSONString(map)); logger.info(JSON.toJSONString(map));
return map; return map;
} catch (ConnectException ce) { } catch (ConnectException ce) {
System.out.println(ce); logger.info("异常",ce);
} catch (Exception e) { } catch (Exception e) {
System.out.println(e); logger.info("异常",e);
} }
return null; return null;
} }
...@@ -636,9 +636,9 @@ public class TestController extends WebBaseController { ...@@ -636,9 +636,9 @@ public class TestController extends WebBaseController {
conn.disconnect(); conn.disconnect();
return buffer.toString(); return buffer.toString();
} catch (ConnectException ce) { } catch (ConnectException ce) {
ce.printStackTrace(); logger.info("异常",ce);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
} }
return null; return null;
} }
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/chat/GroupChatController.java
...@@ -208,7 +208,7 @@ public class GroupChatController { ...@@ -208,7 +208,7 @@ public class GroupChatController {
try { try {
ExcelUtils.xls(response, request, fileName, voList, fileList, titleList); ExcelUtils.xls(response, request, fileName, voList, fileList, titleList);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
logger.info("导出失败"); logger.info("导出失败");
} }
return RestResponse.successResult(true); return RestResponse.successResult(true);
...@@ -323,7 +323,7 @@ public class GroupChatController { ...@@ -323,7 +323,7 @@ public class GroupChatController {
try { try {
ExcelUtils.xls(response, request, fileName, page.getResult().getResult(), fileList, titleList); ExcelUtils.xls(response, request, fileName, page.getResult().getResult(), fileList, titleList);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
logger.info("导出失败"); logger.info("导出失败");
} }
return RestResponse.successResult(true); return RestResponse.successResult(true);
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/chat/GroupChatHmController.java
...@@ -489,7 +489,7 @@ public class GroupChatHmController { ...@@ -489,7 +489,7 @@ public class GroupChatHmController {
downloadReportService.updateDownloadReport(reportId, downloadReportDTO); downloadReportService.updateDownloadReport(reportId, downloadReportDTO);
tempFile.delete(); tempFile.delete();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
} }
} }
}); });
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/logrecord/HbLogRecordController.java
...@@ -72,7 +72,7 @@ public class HbLogRecordController { ...@@ -72,7 +72,7 @@ public class HbLogRecordController {
Date endDateD = DateUtils.parseDate(endDate, "yyyy-MM-dd HH:mm:ss"); Date endDateD = DateUtils.parseDate(endDate, "yyyy-MM-dd HH:mm:ss");
queryWrapper.between(OptRecordLogHaoban::getCreateTime,startDateD,endDateD); queryWrapper.between(OptRecordLogHaoban::getCreateTime,startDateD,endDateD);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); LOGGER.info("异常",e);
} }
} }
if(null == loginUser || StringUtils.isBlank(loginUser.getOperationUserName())) { if(null == loginUser || StringUtils.isBlank(loginUser.getOperationUserName())) {
......
haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/utils/ExportSheetUtil.java
package com.gic.haoban.manage.web.utils; package com.gic.haoban.manage.web.utils;
import com.gic.haoban.manage.web.qo.ExcelSheet; import com.gic.haoban.manage.web.qo.ExcelSheet;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.poi.hssf.usermodel.*; import org.apache.poi.hssf.usermodel.*;
import org.apache.poi.ss.usermodel.CellStyle; import org.apache.poi.ss.usermodel.CellStyle;
import org.apache.poi.ss.usermodel.HorizontalAlignment; import org.apache.poi.ss.usermodel.HorizontalAlignment;
...@@ -17,6 +19,7 @@ import java.util.List; ...@@ -17,6 +19,7 @@ import java.util.List;
* @Date: 2023/9/12 11:14 * @Date: 2023/9/12 11:14
*/ */
public class ExportSheetUtil { public class ExportSheetUtil {
private static Logger logger = LogManager.getLogger(ExportSheetUtil.class);
/** /**
* 拆解并导出多重Excel * 拆解并导出多重Excel
*/ */
...@@ -75,7 +78,7 @@ public class ExportSheetUtil { ...@@ -75,7 +78,7 @@ public class ExportSheetUtil {
response.flushBuffer(); response.flushBuffer();
wb.write(response.getOutputStream()); wb.write(response.getOutputStream());
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); logger.info("异常",e);
} }
} }
} }
haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/utils/IOUtils.java deleted 100644 → 0
package com.gic.haoban.manage.web.utils;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.FilenameFilter;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.Reader;
import java.io.Writer;
public class IOUtils {
/**
* 6.编写一个程序，将D:\\java目录下的所有.java文件复制到D:\\jad目录下，
* 并将原来文件的扩展名从.java改为.jad。
*/
// public static class FileCopy {
// public static void main(String[] args) {
//
// File oriFile = new File("D:\\java");//原文件目录
// //file.exists():判断文件目录是否存在
// //file.isDirectory():判断文件目录是否是一个目录
// if(!(oriFile.exists() && oriFile.isDirectory())){
// System.out.println("文件目录不存在！");
// }
//
// File[] files = oriFile.listFiles(
// new FilenameFilter(){ //文件名称过滤器
// public boolean accept(File file, String name) {
// return name.endsWith(".java");
// }
// }
// );
// System.out.println(files.length);//原文件个数
//
// File objFile = new File("D:\\jad");//目标文件目录
// //objFile.exists():判断目标文件目录是否存在
// //objFile.mkdir():创建目标文件目录
// if(!objFile.exists()){
// objFile.mkdir();
// }
//
// //copyByte(files,objFile);
// copyChar(files,objFile);
// System.out.println("写入完成！");
//
// }
//使用字节流进行文件复制(字节缓冲流可以不使用，使用其目的主要是为了提高性能)
private static void copyByte(File[] files,File objFile){
InputStream inputStream = null;
OutputStream outputStream = null;
BufferedInputStream bufferedInputStream = null;
BufferedOutputStream bufferedOutputStream = null;
for(File f : files){
//替换文件后缀
String objFileName = f.getName().replaceAll("\\.ACC$", ".mp3");
try {
inputStream = new FileInputStream(f);
outputStream = new FileOutputStream(new File(objFile,objFileName));
bufferedInputStream = new BufferedInputStream(inputStream);
bufferedOutputStream = new BufferedOutputStream(outputStream);
int c = 0;
while((c = bufferedInputStream.read()) != -1){
bufferedOutputStream.write(c);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
bufferedOutputStream.close();
bufferedInputStream.close();
outputStream.close();
inputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
//使用字符流进行文件复制(字符缓冲流可以不使用，使用其目的主要是为了提高性能)
public static void copyChar(File file,File objFile){
Reader reader = null;
Writer writer = null;
BufferedReader bufferedReader = null;
BufferedWriter bufferedWriter = null;
//替换文件后缀
String objFileName = file.getName().replaceAll("\\.AAC$", ".mp3");
try {
reader = new FileReader(file);
writer = new FileWriter(new File(objFile,objFileName));
bufferedReader = new BufferedReader(reader);
bufferedWriter = new BufferedWriter(writer);
int c = 0;
while ((c=bufferedReader.read()) != -1) {
bufferedWriter.write(c);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
bufferedWriter.close();
bufferedReader.close();
writer.close();
reader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/utils/target/DataTargetHttpUtils.java
...@@ -32,9 +32,6 @@ public class DataTargetHttpUtils { ...@@ -32,9 +32,6 @@ public class DataTargetHttpUtils {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("enterpriseId", "ff8080815dacd3a2015dacd3ef5c0000"); jsonObject.put("enterpriseId", "ff8080815dacd3a2015dacd3ef5c0000");
//Map<String, Object> res = http(getParamNoPage(jsonObject).toJSONString(), "data_mbr_target_overview_targetActual"); //Map<String, Object> res = http(getParamNoPage(jsonObject).toJSONString(), "data_mbr_target_overview_targetActual");
//System.out.println(JSON.toJSONString(responseOfOne(res, null)));
System.out.println("年模板".equals("年模板"));
System.out.println();
} }
public static JSONObject getCommonParam(String enterpriseId, String storeId, String startTime, String endTime) { public static JSONObject getCommonParam(String enterpriseId, String storeId, String startTime, String endTime) {
......
haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/utils/target/StoreTargetConfigHttpUtils.java
...@@ -32,7 +32,6 @@ public class StoreTargetConfigHttpUtils extends HttpClient{ ...@@ -32,7 +32,6 @@ public class StoreTargetConfigHttpUtils extends HttpClient{
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("enterpriseId", "ff8080815dacd3a2015dacd3ef5c0000"); jsonObject.put("enterpriseId", "ff8080815dacd3a2015dacd3ef5c0000");
//Map<String, Object> res = http(getParamNoPage(jsonObject).toJSONString(), "data_mbr_target_overview_targetActual"); //Map<String, Object> res = http(getParamNoPage(jsonObject).toJSONString(), "data_mbr_target_overview_targetActual");
//System.out.println(JSON.toJSONString(responseOfOne(res, null)));
} }
......
haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/vo/ClerkEditInfoVO.java
...@@ -40,16 +40,5 @@ public class ClerkEditInfoVO { ...@@ -40,16 +40,5 @@ public class ClerkEditInfoVO {
int delClerkFlag = vo.getDelClerkFlag() << 2; int delClerkFlag = vo.getDelClerkFlag() << 2;
return editClerkFlag | addClerkFlag | delClerkFlag ; return editClerkFlag | addClerkFlag | delClerkFlag ;
} }
public static void main(String[] args) {
ClerkEditInfoVO vo = new ClerkEditInfoVO();
vo.setAddClerkFlag(1);
vo.setDelClerkFlag(0);
vo.setEditClerkFlag(0);
System.out.println(getValue(vo));
System.out.println(JSON.toJSONString(info(getValue(vo))));
}
} }
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