elink-star
/
esua-epdc-cloud
12
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

修改新新向党 ，没插入item 直接抛异常

master
qushutong 2 years ago
parent
724705a0d7
commit
1cfab5e5e6
1 changed files with 37 additions and 17 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 54
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java

54
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java
View File

@ -5732,7 +5732,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
Integer sync = NumConstant.ZERO;
LambdaUpdateWrapper<XxxdEventEntity> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(XxxdEventEntity::getId, xxxdEventEntityId);
try {
// try {
//处理图片和语音，上传到市北的oss
if(CollectionUtils.isNotEmpty(submitItemFormDTO.getImages())){
List<String> images=getEpdcImgUrl(submitItemFormDTO.getImages());
@ -5758,7 +5758,17 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
if (!gisGridRes.success() || null == gisGridRes.getData()) {
internalRemark = "根据经纬度获取网格信息失败:" + gisGridRes.getMsg();
log.error("submitXxxdEventToItem上传到民生诉求异常:" + internalRemark);
return;// 测试时候注释掉，让它继续执行
updateWrapper.set(StringUtils.isNotBlank(internalStatus), XxxdEventEntity::getInternalStatus, internalStatus)
.set(StringUtils.isNotBlank(bssbEventId), XxxdEventEntity::getBssbEventId, bssbEventId)
.set(StringUtils.isNotBlank(internalRemark), XxxdEventEntity::getInternalRemark, internalRemark)
.set(StringUtils.isNotBlank(gridId), XxxdEventEntity::getGridId, gridId)
.set(StringUtils.isNotBlank(gridName), XxxdEventEntity::getGridName, gridName)
.set(StringUtils.isNotBlank(communityId), XxxdEventEntity::getCommunityId, communityId)
.set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId)
.set(null != sync, XxxdEventEntity::getSync, sync);
xxxdEventDao.update(null, updateWrapper);
throw new RenException(internalRemark);
// return;// 测试时候注释掉，让它继续执行
} else {
gridId = String.valueOf(gisGridRes.getData().getGridId());
gridName = gisGridRes.getData().getGridName();
@ -5801,21 +5811,31 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
sync=NumConstant.ONE;
log.info("submitXxxdEventToItem上传到民生诉求成功：bssbEventId："+bssbEventId);
}
} catch (Exception e) {
internalRemark="上传到民生诉求异常";
log.error("submitXxxdEventToItem上传到民生诉求异常",e);
} finally {
log.info("最终都会被执行-------------------");
updateWrapper.set(StringUtils.isNotBlank(internalStatus), XxxdEventEntity::getInternalStatus, internalStatus)
.set(StringUtils.isNotBlank(bssbEventId), XxxdEventEntity::getBssbEventId, bssbEventId)
.set(StringUtils.isNotBlank(internalRemark), XxxdEventEntity::getInternalRemark, internalRemark)
.set(StringUtils.isNotBlank(gridId), XxxdEventEntity::getGridId, gridId)
.set(StringUtils.isNotBlank(gridName), XxxdEventEntity::getGridName, gridName)
.set(StringUtils.isNotBlank(communityId), XxxdEventEntity::getCommunityId, communityId)
.set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId)
.set(null != sync, XxxdEventEntity::getSync, sync);
xxxdEventDao.update(null, updateWrapper);
}
updateWrapper.set(StringUtils.isNotBlank(internalStatus), XxxdEventEntity::getInternalStatus, internalStatus)
.set(StringUtils.isNotBlank(bssbEventId), XxxdEventEntity::getBssbEventId, bssbEventId)
.set(StringUtils.isNotBlank(internalRemark), XxxdEventEntity::getInternalRemark, internalRemark)
.set(StringUtils.isNotBlank(gridId), XxxdEventEntity::getGridId, gridId)
.set(StringUtils.isNotBlank(gridName), XxxdEventEntity::getGridName, gridName)
.set(StringUtils.isNotBlank(communityId), XxxdEventEntity::getCommunityId, communityId)
.set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId)
.set(null != sync, XxxdEventEntity::getSync, sync);
xxxdEventDao.update(null, updateWrapper);
// } catch (Exception e) {
// internalRemark="上传到民生诉求异常";
// log.error("submitXxxdEventToItem上传到民生诉求异常",e);
// } finally {
// log.info("最终都会被执行-------------------");
// updateWrapper.set(StringUtils.isNotBlank(internalStatus), XxxdEventEntity::getInternalStatus, internalStatus)
// .set(StringUtils.isNotBlank(bssbEventId), XxxdEventEntity::getBssbEventId, bssbEventId)
// .set(StringUtils.isNotBlank(internalRemark), XxxdEventEntity::getInternalRemark, internalRemark)
// .set(StringUtils.isNotBlank(gridId), XxxdEventEntity::getGridId, gridId)
// .set(StringUtils.isNotBlank(gridName), XxxdEventEntity::getGridName, gridName)
// .set(StringUtils.isNotBlank(communityId), XxxdEventEntity::getCommunityId, communityId)
// .set(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId)
// .set(null != sync, XxxdEventEntity::getSync, sync);
// xxxdEventDao.update(null, updateWrapper);
// }
}

Write Preview
Loading…
Cancel
Save