添加消息发送系统

portal-manager/src/main/java/com/mortals/xhx/busiz/rsp/wait/WaitPersonInfo.java

@@ -44,6 +44,9 @@ public class WaitPersonInfo {
     @JSONField(name = "id")
     private Long waitId;
 
+    @JSONField(name = "siteid")
+    private Long siteId;
+
     @JSONField(name = "idcardData_PhotoFileName")
     private String idcardDataPhotoFileName;
 

portal-manager/src/main/java/com/mortals/xhx/daemon/task/SyncAppointWaitAndFinTaskImpl.java

@@ -126,25 +126,26 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
         }
 
         if (!ObjectUtils.isEmpty(waitPersonInfos)) {
-            // log.info("waitPersonInfos:{}", JSON.toJSONString(waitPersonInfos));
+            log.info("waitPersonInfos:{}", JSON.toJSONString(waitPersonInfos));
             List<DoworkRecordsEntity> recordsEntityList = waitPersonInfos.stream().map(item -> {
-                DoworkRecordsEntity careRecordsEntity = new DoworkRecordsEntity();
-                careRecordsEntity.initAttrValue();
-                careRecordsEntity.setName(item.getIdcardName());
-                careRecordsEntity.setContact(item.getPhone());
-                careRecordsEntity.setIdCard(item.getIdcardIDCardNo());
-                careRecordsEntity.setBussinessId(item.getBusinessId());
-                careRecordsEntity.setBussinessName(item.getBusinessName());
-                careRecordsEntity.setService(item.getBusinessName());
-                careRecordsEntity.setQueueNo(item.getFlowNum());
-                careRecordsEntity.setTakeTime(item.getTakeTime() == null ? new Date() : item.getTakeTime());
-                careRecordsEntity.setPersonId(DataUtil.converStr2Long(item.getPeopleId(), 0));
-                careRecordsEntity.setWaitId(item.getWaitId());
-                careRecordsEntity.setProcessStatus(ProcessStatusEnum.排队中.getValue());
-                careRecordsEntity.setCreateTime(new Date());
-                careRecordsEntity.setCreateUserName("system");
-                careRecordsEntity.setCreateUserId(1L);
-                return careRecordsEntity;
+                DoworkRecordsEntity doworkRecordsEntity = new DoworkRecordsEntity();
+                doworkRecordsEntity.initAttrValue();
+                doworkRecordsEntity.setName(item.getIdcardName());
+                doworkRecordsEntity.setSiteId(item.getSiteId());
+                doworkRecordsEntity.setContact(item.getPhone());
+                doworkRecordsEntity.setIdCard(item.getIdcardIDCardNo());
+                doworkRecordsEntity.setBussinessId(item.getBusinessId());
+                doworkRecordsEntity.setBussinessName(item.getBusinessName());
+                doworkRecordsEntity.setService(item.getBusinessName());
+                doworkRecordsEntity.setQueueNo(item.getFlowNum());
+                doworkRecordsEntity.setTakeTime(item.getTakeTime() == null ? new Date() : item.getTakeTime());
+                doworkRecordsEntity.setPersonId(DataUtil.converStr2Long(item.getPeopleId(), 0));
+                doworkRecordsEntity.setWaitId(item.getWaitId());
+                doworkRecordsEntity.setProcessStatus(ProcessStatusEnum.排队中.getValue());
+                doworkRecordsEntity.setCreateTime(new Date());
+                doworkRecordsEntity.setCreateUserName("system");
+                doworkRecordsEntity.setCreateUserId(1L);
+                return doworkRecordsEntity;
             }).collect(Collectors.toList());
 
             if (!ObjectUtils.isEmpty(recordsEntityList)) {