fix

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

@@ -571,36 +571,36 @@ public class DepartmentApiServiceImpl implements DepartmentApiService {
 		}
 		logger.info("【mq同步】parentId={}",parentId);
 		for (com.gic.wechat.api.dto.qywx.DepartmentDTO departmentDTO : handerList) {
-//			insertMQ(departmentDTO.getId(),wxEnterpriseId, corpid,contactSecret,taskId);
-//			try {
-//				TabHaobanDepartment exist = this.departmentService.getByWxId(departmentDTO.getId() + "", wxEnterpriseId);
-//				logger.info("分组是否存在：{}", JSON.toJSONString(exist));
-//				if(exist == null){
-//					com.gic.haoban.manage.api.dto.DepartmentDTO dto = new com.gic.haoban.manage.api.dto.DepartmentDTO();
-//					dto.setDepartmentName(departmentDTO.getName());
-//					dto.setLevel(level);
-//					dto.setWxEnterpriseId(wxEnterpriseId);
-//					dto.setWxDepartmentId(departmentDTO.getId()+"");
-//					dto.setParentDepartmentId(parentId + "");
-//					dto.setChainId(chainId);
-//					dto.setChainName(chainName);
-//					dto.setSort(departmentDTO.getOrder());
-//					dto.setIsStore(0);
-//					this.departmentService.add(dto);
-//				}
-//			} catch (Exception e) {
-//				TabHaobanSyncErrorLog tab = new TabHaobanSyncErrorLog();
-//				tab.setDataId(departmentDTO.getId()+"");
-//				tab.setDataType(0);
-//				tab.setLogType(0);
-//				tab.setReason(e.getMessage());
-//				tab.setTaskId(taskId);
-//				tab.setWxEnterpriseId(wxEnterpriseId);
-//				syncErrorLogService.add(tab);
-//			}
-//			//this.addAllDepartment(list, departmentDTO.getId(), wxEnterpriseId, corpid, contactSecret,taskId);
-//			this.staffApiService.initWxUser(corpid, contactSecret, wxEnterpriseId, departmentDTO.getId(),taskId);
-			return;
+			insertMQ(departmentDTO.getId(),wxEnterpriseId, corpid,contactSecret,taskId);
+			try {
+				TabHaobanDepartment exist = this.departmentService.getByWxId(departmentDTO.getId() + "", wxEnterpriseId);
+				logger.info("分组是否存在：{}", JSON.toJSONString(exist));
+				if(exist == null){
+					com.gic.haoban.manage.api.dto.DepartmentDTO dto = new com.gic.haoban.manage.api.dto.DepartmentDTO();
+					dto.setDepartmentName(departmentDTO.getName());
+					dto.setLevel(level);
+					dto.setWxEnterpriseId(wxEnterpriseId);
+					dto.setWxDepartmentId(departmentDTO.getId()+"");
+					dto.setParentDepartmentId(parentId + "");
+					dto.setChainId(chainId);
+					dto.setChainName(chainName);
+					dto.setSort(departmentDTO.getOrder());
+					dto.setIsStore(0);
+					this.departmentService.add(dto);
+				}
+			} catch (Exception e) {
+				TabHaobanSyncErrorLog tab = new TabHaobanSyncErrorLog();
+				tab.setDataId(departmentDTO.getId()+"");
+				tab.setDataType(0);
+				tab.setLogType(0);
+				tab.setReason(e.getMessage());
+				tab.setTaskId(taskId);
+				tab.setWxEnterpriseId(wxEnterpriseId);
+				syncErrorLogService.add(tab);
+			}
+			//this.addAllDepartment(list, departmentDTO.getId(), wxEnterpriseId, corpid, contactSecret,taskId);
+			this.staffApiService.initWxUser(corpid, contactSecret, wxEnterpriseId, departmentDTO.getId(),taskId);
+//			return;
 		}
 	}