diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java index d6602400d..23ced4257 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/XxxdEventServiceImpl.java @@ -76,6 +76,7 @@ public class XxxdEventServiceImpl extends BaseServiceImpl implem String communityId = ""; // 街道id String streetId = ""; + // 是否已同步,0:未同步;1,已同步 + Integer sync = NumConstant.ZERO; LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.eq(XxxdEventEntity::getId, xxxdEventEntityId); try { @@ -5598,6 +5600,8 @@ public class ItemServiceImpl extends BaseServiceImpl implem if(StringUtils.isNotBlank(bssbEventId)){ //成功返回epdc_item.id,说明提交民生诉求成功,状态改为1 internalStatus=NumConstant.ONE_STR; + // 置为已同步 + sync=NumConstant.ONE; log.info("submitXxxdEventToItem上传到民生诉求成功:bssbEventId:"+bssbEventId); } } catch (Exception e) { @@ -5611,7 +5615,8 @@ public class ItemServiceImpl extends BaseServiceImpl implem .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(StringUtils.isNotBlank(streetId), XxxdEventEntity::getStreetId, streetId) + .set(null != sync, XxxdEventEntity::getSync, sync); xxxdEventDao.update(null, updateWrapper); }