异步的利弊

 

 

异步的利弊

 

利:

1，异步避免http请求过长尝试,需要处理超时还可以增加超时时间

 

弊：

1，异步在有顺序依赖的结果变量的引用问题，异步a的结果或则中间变量不能被下游的b及时用到

   可以用线程的join方法控制，或者用条件唤醒控制或者调整位置

 

 

 

 

/**

* 投保结果通知

*/

@Override

public ApiResponse insureNotify(InsureNotifyRequest insureNotifyRequest, InsureApply insureApply) throws Exception {

// 如果投保成功，则判断有无发送银行要求

if (InsureResultStatusEnum.PASS.getStatus().equals(insureNotifyRequest.getStatus())

&& !StringUtil.isBlank(insureApply.getBankCode())

&& !StringUtil.isBlank(insureApply.getBankTradeCode())) {

// 银行发送信息

taskExecutor.execute(() -> {

FacadeSendRequest facadeSendRequest = new FacadeSendRequest();

facadeSendRequest.setApplyNo(insureNotifyRequest.getApplserialno());

facadeSendRequest.setChannelCode(BankTypeEnum.ASIA.getType());

facadeSendRequest.setBankCode(insureApply.getBankCode());

facadeSendRequest.setPacket(insureApply.getBankRequestData());

facadeSendRequest.setTradeCode(insureApply.getBankTradeCode());

facadeService.send(facadeSendRequest);

});

 

}

// 将返回状态跟新

taskExecutor.execute(() -> {

insureApply.setInsureCplyno(insureNotifyRequest.getCplyno());

insureApply.setInsureUrl(insureNotifyRequest.getCplyurl());

insureApply.setStatus(insureNotifyRequest.getStatus());

insureApply.setUpdateTime(new Date());

if (insureApplyMapper.updateInsureApplyBySerialno(insureApply) < 1)

logger.error("数据库操作失败updateInsureApplyBySerialno[{}]", JSONObject.toJSONString(insureApply));

//更新申请列表的核保状态，保单号---------------------------------------这个之前在异步之外，insureApply.getStatus(),由于异步问题这里用insureNotifyRequest.getStatus()

TApprovalResult tApprovalResult = new TApprovalResult();

//tApprovalResult.setApplyNo(insureApply.getApplyNo());

tApprovalResult.setInsureRes(insureNotifyRequest.getStatus());

tApprovalResult.setInsureCplyno(insureNotifyRequest.getCplyno());

//tApprovalResult.setInsureSerialno(insureApply.getInsureSerialno());

Example example = new Example(TApprovalResult.class);

Example.Criteria criteria = example.createCriteria();

//criteria.andCondition("applyNo",insureApply.getApplyNo());

criteria.andEqualTo("applyNo",insureApply.getApplyNo());

if(tApprovalResultMapper.updateByExampleSelective(tApprovalResult,example)<1){

logger.error("数据库操作失败updateByExampleSelective[{}]", JSONObject.toJSONString(tApprovalResult));

}

});

 

//返回的渠道的时候，电子保单url替换成外网的url

if(!StringUtil.isBlank(insureNotifyRequest.getCplyurl())){

String cplyUrl = insureNotifyRequest.getCplyurl();

cplyUrl = cplyUrl.replace(cplyUrl.substring(0, cplyUrl.indexOf("/h5img/app")), apiinsOuterUrl);

insureNotifyRequest.setCplyurl(cplyUrl);

}

FacadeSendRequest facadeSendRequest = new FacadeSendRequest();

facadeSendRequest.setApplyNo(insureNotifyRequest.getApplserialno());

facadeSendRequest.setChannelCode(BankTypeEnum.ASIA.getType());

facadeSendRequest.setBankCode(insureApply.getChannelCode());

facadeSendRequest.setPacket(JSONObject.toJSONString(insureNotifyRequest));

facadeSendRequest.setTradeCode(TradeEnum.S001.getTcode());

 

 /////////////之前的位置=================================== 放在这个位置insureApply.getStatus()第一次获取不到，更新不了状态

 

//记录统计的方法，已经有的话更新，没有的话插入

TApprovalStatistics tApprovalStatistics = new TApprovalStatistics();

tApprovalStatistics.setApplyNo(insureApply.getApplyNo());

List<TApprovalStatistics> tApprovalStatisticss= tApprovalStatisticsMapper.select(tApprovalStatistics);

if(tApprovalStatisticss==null || tApprovalStatisticss.size()==0){

tApprovalStatistics.setStatus(insureApply.getStatus());

tApprovalStatistics.setCreateTime(new Date());

tApprovalStatisticsMapper.insert(tApprovalStatistics);  //需要具体设置值？？？？？

}else{

TApprovalStatistics ts = tApprovalStatisticss.get(0);

tApprovalStatistics.setStatus(insureApply.getStatus());

tApprovalStatistics.setUpdateTime(new Date());

tApprovalStatistics.setId(ts.getId());

tApprovalStatisticsMapper.updateByPrimaryKeySelective(tApprovalStatistics);

}

 

 

 

 

 

//houbank特例：houbank渠道对于投保通知接口，根据业务不同，分不同的接口

if("BRH".equals(insureApply.getBankCode()))

facadeSendRequest.setUrl("1");

else

facadeSendRequest.setUrl("2");

return facadeService.send(facadeSendRequest);

}