更新失败处理情况暂存

This commit is contained in:
xiangerlin 2025-07-13 16:28:23 +08:00
parent af439f2966
commit afc0a53398
1 changed files with 25 additions and 1 deletions

View File

@ -21,6 +21,8 @@ import com.hzya.frame.mdm.mdmModuleDistributeTripartite.entity.MdmModuleDistribu
import com.hzya.frame.mdm.mdmModuleSendLog.dao.IMdmModuleSendLogDao; import com.hzya.frame.mdm.mdmModuleSendLog.dao.IMdmModuleSendLogDao;
import com.hzya.frame.mdm.mdmModuleSendLog.entity.MdmModuleSendLogEntity; import com.hzya.frame.mdm.mdmModuleSendLog.entity.MdmModuleSendLogEntity;
import com.hzya.frame.mdm.service.IMdmServiceCache; import com.hzya.frame.mdm.service.IMdmServiceCache;
import com.hzya.frame.seeyon.zxbank.dao.IZxBankDao;
import com.hzya.frame.seeyon.zxbank.entity.ZxBankEntity;
import com.hzya.frame.seeyon.zxbank.service.IZxBankService; import com.hzya.frame.seeyon.zxbank.service.IZxBankService;
import com.hzya.frame.sys.sysenum.SysEnum; import com.hzya.frame.sys.sysenum.SysEnum;
import com.hzya.frame.sysnew.application.api.dao.ISysApplicationApiDao; import com.hzya.frame.sysnew.application.api.dao.ISysApplicationApiDao;
@ -57,7 +59,8 @@ public class ZxBankDistributePluginInitializer extends PluginBaseEntity {
Logger logger = LoggerFactory.getLogger(ZxBankDistributePluginInitializer.class); Logger logger = LoggerFactory.getLogger(ZxBankDistributePluginInitializer.class);
@Autowired @Autowired
private IZxBankService zxBankService; private IZxBankService zxBankService;
@Autowired
private IZxBankDao zxBankDao;
@Resource @Resource
private IMdmModuleDistributeDetailDao mdmModuleDistributeDetailDao; private IMdmModuleDistributeDetailDao mdmModuleDistributeDetailDao;
@Resource @Resource
@ -1180,6 +1183,27 @@ public class ZxBankDistributePluginInitializer extends PluginBaseEntity {
updateMap.put("addStatus", "2"); updateMap.put("addStatus", "2");
updateMap.put("id", objects.get(i).getString("id")); updateMap.put("id", objects.get(i).getString("id"));
mdmModuleDao.updateMdmSTs(updateMap); mdmModuleDao.updateMdmSTs(updateMap);
try {
//这里还没写完要判断下如果推送失败 要更新OA表单
String dataId = objects.get(i).getString("data_id");
if (StrUtil.isNotEmpty(dataId)){
JSONObject attribute = JSONObject.parseObject(jsonResultEntity.getAttribute().toString());
if (null != attribute){
JSONObject bizInfo = attribute.getJSONObject("bizInfo");
String bizMessage = bizInfo.getString("bizMessage");
if (StrUtil.isEmpty(bizMessage)){
bizMessage = "失败";
}
ZxBankEntity zxBankEntity = new ZxBankEntity();
zxBankEntity.setPayResult(bizMessage);
zxBankEntity.setId(objects.get(i).getString("data_id"));
zxBankEntity.setDataSourceCode("HT-OA");
zxBankDao.updateResultStatus(zxBankEntity);
}
}
}catch (Exception e){
logger.error("中信司库付款单下发后更新OA表单支付结果失败:{}",e.getMessage());
}
continue; continue;
} }
} }