Commit 075cca45 authored by zhangyingbin's avatar zhangyingbin

tzs注册 注解同步ugp部分

parent 4c980ed1
...@@ -135,23 +135,23 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI ...@@ -135,23 +135,23 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
// 3.2 自动创建:调用平台进行创建单位、用户信息 // 3.2 自动创建:调用平台进行创建单位、用户信息
this.createCompanyAndUser(regUnitInfo); this.createCompanyAndUser(regUnitInfo);
//多线程同步ugp信息 //多线程同步ugp信息(tzs和ugp一起后放开)
String token = RequestContext.getToken(); // String token = RequestContext.getToken();
String appKey = RequestContext.getAppKey(); // String appKey = RequestContext.getAppKey();
String product = RequestContext.getProduct(); // String product = RequestContext.getProduct();
Callable callable = new Callable(){ // Callable callable = new Callable(){
@Override // @Override
public Object call() throws Exception { // public Object call() throws Exception {
RequestContext.setToken(token); // RequestContext.setToken(token);
RequestContext.setAppKey(appKey); // RequestContext.setAppKey(appKey);
RequestContext.setProduct(product); // RequestContext.setProduct(product);
//同步企业至ugp,成功返回true,失败返回false // //同步企业至ugp,成功返回true,失败返回false
return ugpServiceFeignClient.syncCompany(model); // return ugpServiceFeignClient.syncCompany(model);
} // }
}; // };
FutureTask<ResponseModel<Boolean>> future = new FutureTask(callable); // FutureTask<ResponseModel<Boolean>> future = new FutureTask(callable);
Thread thread = new Thread(future); // Thread thread = new Thread(future);
thread.start(); // thread.start();
// 1.插入单位注册许可信息表:tz_base_unit_licence // 1.插入单位注册许可信息表:tz_base_unit_licence
...@@ -189,10 +189,10 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI ...@@ -189,10 +189,10 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
// 5.3工商信息 // 5.3工商信息
model.setRegUnitIc(Bean.toModel(regUnitIc, new RegUnitIcDto())); model.setRegUnitIc(Bean.toModel(regUnitIc, new RegUnitIcDto()));
//获取多线程执行结果 true成功 false失败 //获取多线程执行结果 true成功 false失败(tzs和ugp一起后放开)
if(!future.get().getResult()){ // if(!future.get().getResult()){
throw new Exception("UGP信息同步失败"); // throw new Exception("UGP信息同步失败");
} // }
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
......
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