Merge branch 'developer' into 'master'

Developer

See merge request !57

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/DealSyncOperationApiServiceImpl.java

@@ -348,6 +348,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
     private void dealDepartmentToMq(String taskId, Set<String> dealList, SyncTaskStatusEnum syncTaskStatusEnum) {
         //预处理分组任务
         syncTaskService.updateTaskStatus(taskId, syncTaskStatusEnum.getVal());
+
         dealList.forEach(relationId -> {
             DealParamMqDTO dealParamMqDTO = new DealParamMqDTO();
             dealParamMqDTO.setTaskId(taskId);
@@ -361,6 +362,22 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
                 e.printStackTrace();
             }
         });
+
+        List<String> listRet = dealList.stream().map(relationId -> {
+            DealParamMqDTO dealParamMqDTO = new DealParamMqDTO();
+            dealParamMqDTO.setTaskId(taskId);
+            dealParamMqDTO.setData(relationId);
+            dealParamMqDTO.setType(syncTaskStatusEnum.getVal());
+            return JSONObject.toJSONString(dealParamMqDTO);
+        }).collect(Collectors.toList());
+
+        GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+        try {
+            clientInstance.sendBatchMessages("departmentSyncDealMq", listRet);
+        } catch (Exception e) {
+            logger.info("发送失败:{},{}", taskId, JSONObject.toJSONString(listRet));
+            e.printStackTrace();
+        }
     }
 
 

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/MemberUnionidRelatedApiServiceImpl.java

@@ -623,6 +623,9 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
 			return;
 		}
 		JSONArray jsonArr = JSON.parseArray(res);
+		if(jsonArr.size() == 0) {
+			return;
+		}
 		List<MemberUnionidRelatedDTO> list = this.getByWxUserIdAndWxEnterpriseId(wxUserId, wxEnterpriseId);
 		List<String> externalUserIdList = list.stream().map(student->student.getSelfExternalUserid())
 				   .collect(Collectors.toList());

haoban-manage3-service/src/test/java/ServiceTest.java

@@ -166,7 +166,7 @@ public void sendMessage() {
     @Test
     public void extensionList() {
 
-        String s = qywxUserApiService.listSelfExternalUserid("ww9ede832a84b7ae5f", "01YQ-pcdYzF3K0So8uCFfkB5i8D5EBW7KcVB4qA8Ktk", "qiuwenmin");
+        String s = qywxUserApiService.listSelfExternalUserid("ww9ede832a84b7ae5f", "01YQ-pcdYzF3K0So8uCFfkB5i8D5EBW7KcVB4qA8Ktk", "de2c33f2e8924ff884e0073ca2f2f711");
         System.out.println(JSONObject.toJSONString(s));
     }
 

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/WxEnterpriseController.java

@@ -224,7 +224,7 @@ public class WxEnterpriseController extends WebBaseController{
 		LoginVO login = (LoginVO) AuthRequestUtil.getLoginUser();
 		wxEnterpriseId = login.getWxEnterpriseId();
 		WxEnterpriseDTO wxEnterprise = wxEnterpriseApiService.getOne(wxEnterpriseId);
-		if(wxEnterprise != null && org.apache.commons.lang3.StringUtils.isAnyBlank(wxEnterprise.getContactSecret(),wxEnterprise.getWxSecretKey(),wxEnterprise.getMemberSecret())){
+		if(wxEnterprise != null && org.apache.commons.lang3.StringUtils.isAnyBlank(wxEnterprise.getContactSecret(),wxEnterprise.getWxSecretKey())){
 			return resultResponse(HaoBanErrCode.ERR_1,false);
 		}
 		return resultResponse(HaoBanErrCode.ERR_1,true);
@@ -276,7 +276,7 @@ public class WxEnterpriseController extends WebBaseController{
 		}
 		String res = qywxUserApiService.listSelfExternalUserid(wxEnterprise.getCorpid(), wxSecretKey, login.getStaffDTO().getWxUserId());
 		logger.info("【保存联系人key】res={}",res);
-		if(org.apache.commons.lang3.StringUtils.isBlank(res)){
+		if(res == null)){
 			wxEnterprise.setWxSecretKeyLastTime(new Date());
 			wxEnterpriseApiService.update(wxEnterprise);
 			return resultResponse(HaoBanErrCode.ERR_10013);