sync接收默认未同步。成功提交到民生诉求，置为已同步

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<XxxdEventDao, XxxdEven
         if (null == origin) {
             // 0已接收；1已转北上速办事件；2已完结
             entity.setInternalStatus(NumConstant.ZERO_STR);
+            entity.setSync(NumConstant.ZERO);
             insert(entity);
         } else {
             entity.setId(origin.getId());
@@ -100,6 +101,7 @@ public class XxxdEventServiceImpl extends BaseServiceImpl<XxxdEventDao, XxxdEven
         submitItemFormDTO.setIssueLongitude(Double.parseDouble(entity.getLongitude()));
         submitItemFormDTO.setIssueAddress(entity.getLocation());
         submitItemFormDTO.setPeopleFlag(NumConstant.ZERO_STR);
+        //区分 0 网格员上报还是 1 居民上报;2：新新向党随手拍
         submitItemFormDTO.setAppealSource(NumConstant.TWO_STR);
         submitItemFormDTO.setShowFlag(NumConstant.ZERO_STR);
         submitItemFormDTO.setDistributeTime(DateUtils.parse(entity.getPubTime(),"yyyy-MM-dd HH:mm:ss"));

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

@@ -5562,6 +5562,8 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
         String communityId = "";
         // 街道id
         String streetId = "";
+        // 是否已同步,0：未同步;1，已同步
+        Integer sync = NumConstant.ZERO;
         LambdaUpdateWrapper<XxxdEventEntity> updateWrapper = new LambdaUpdateWrapper<>();
         updateWrapper.eq(XxxdEventEntity::getId, xxxdEventEntityId);
         try {
@@ -5598,6 +5600,8 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> 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<ItemDao, ItemEntity> 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);
         }