refactor(amos-boot-module-tcm): 重构企业信息更新逻辑- 异步处理公司信息更新，提高系统稳定性

amos-boot-system-tzs/amos-boot-module-tcm/amos-boot-module-tcm-biz/src/main/java/com/yeejoin/amos/boot/module/tcm/biz/service/impl/TzBaseEnterpriseInfoServiceImpl.java

@@ -63,6 +63,7 @@ import org.typroject.tyboot.core.restful.exception.instance.TooManyRequests;
 
 import java.text.ParseException;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 import java.util.stream.Collectors;
@@ -1134,19 +1135,13 @@ public class TzBaseEnterpriseInfoServiceImpl
 
 			boolean b = tzBaseEnterpriseInfoService.updateById(tzBaseEnterpriseInfo);
 			if (b) {
+				log.info("更新企业信息, 单位类型 => {}", tzBaseEnterpriseInfo.getUseUnitCode());
 				CompanyModel updateModel = Privilege.companyClient.queryByCompanyCode(String.valueOf(map.get("useCode"))).getResult();
-				HashMap<String, Object> parentMessage = (HashMap<String, Object>) Privilege.companyClient.queryByOrgcode(String.valueOf(map.get("superviseOrgCode"))).getResult();
-				// 目前平台返回key为compnay(存在拼写错误)
-				CompanyModel parentModel = JSON.parseObject(JSON.toJSONString(parentMessage.get("compnay")), CompanyModel.class);
-				updateModel.setParentId(parentModel.getSequenceNbr());
 				updateModel.setCompanyType(regUnitInfo.getUnitType());// 更新单位类型
-
-				FeignClientResult<CompanyModel> companyResult = Privilege.companyClient.update(updateModel, updateModel.getSequenceNbr());
-				if (companyResult == null || companyResult.getStatus() != 200) {
-					log.error("更新单位错误: {}", companyResult);
-					throw new BadRequest("更新单位失败！");
-				}
+				updateCompanyInfo(map, updateModel);
+				log.info("更新企业信息, 单位 => {}", tzBaseEnterpriseInfo.getUseUnitCode());
 				updateUnit(map, regUnitInfo, agencyUserModel, updateModel);
+				log.info("更新企业信息, 注册用户 => {}", tzBaseEnterpriseInfo.getUseUnitCode());
 				updateUserInfo(newData, String.valueOf(map.get("useCode")));
 				TzBaseEnterpriseInfoDto tzBaseEnterpriseInfoDto = new TzBaseEnterpriseInfoDto();
 				BeanUtils.copyProperties(tzBaseEnterpriseInfo, tzBaseEnterpriseInfoDto);
@@ -1156,8 +1151,8 @@ public class TzBaseEnterpriseInfoServiceImpl
 				return null;
 			}
 		} catch (Exception e) {
-			log.error("更新失败: ", e);
-			throw new BadRequest("更新失败！");
+			log.error("更新企业信息失败: ", e);
+			throw new BadRequest("更新企业信息失败！");
 		}
 	}
 
@@ -1167,6 +1162,29 @@ public class TzBaseEnterpriseInfoServiceImpl
 		return userInfoService.personalInfoUpdateById((Map<String, Object>) map.get("raw"));
 	}
 
+	private void updateCompanyInfo(Map<String, Object> map, CompanyModel updateModel) {
+		String token = RequestContext.getToken();
+		String appKey = RequestContext.getAppKey();
+		String product = RequestContext.getProduct();
+		CompletableFuture.runAsync(() -> {
+
+			RequestContext.setToken(token);
+			RequestContext.setAppKey(appKey);
+			RequestContext.setProduct(product);
+
+			HashMap<String, Object> parentMessage = (HashMap<String, Object>) Privilege.companyClient.queryByOrgcode(String.valueOf(map.get("superviseOrgCode"))).getResult();
+			// 目前平台返回key为compnay(存在拼写错误)
+			CompanyModel parentModel = JSON.parseObject(JSON.toJSONString(parentMessage.get("compnay")), CompanyModel.class);
+			updateModel.setParentId(parentModel.getSequenceNbr());
+			FeignClientResult<CompanyModel> companyResult = Privilege.companyClient.update(updateModel, updateModel.getSequenceNbr());
+			if (companyResult == null || companyResult.getStatus() != 200) {
+				log.error("更新单位错误: {}", companyResult);
+				throw new BadRequest("更新单位失败！");
+			}
+		});
+
+	}
+
 	private void handleUnitType(Map<String, Object> map, RegUnitInfo regUnitInfo, AgencyUserModel agencyUserModel) {
 		Object unitTypeCodesObj = map.get("unitTypeCodes");
 		if (!(unitTypeCodesObj instanceof List<?>)) {