修改内部系统访问地址

refined-manager/src/main/java/com/mortals/xhx/daemon/task/RealTimePeopleStatTaskImpl.java

 package com.mortals.xhx.daemon.task;
 
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.RandomUtil;
 import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.PageInfo;
 import com.mortals.framework.service.ITask;
 import com.mortals.framework.service.ITaskExcuteService;
+import com.mortals.framework.util.DataUtil;
+import com.mortals.framework.util.DateUtils;
 import com.mortals.xhx.base.system.upload.service.UploadService;
+import com.mortals.xhx.common.code.CheckInMethodEnum;
+import com.mortals.xhx.module.monitor.model.MonitorAlarmEntity;
+import com.mortals.xhx.module.monitor.model.MonitorAlarmQuery;
+import com.mortals.xhx.module.monitor.model.MonitorAlarmRecordEntity;
+import com.mortals.xhx.module.monitor.service.MonitorAlarmRecordService;
+import com.mortals.xhx.module.monitor.service.MonitorAlarmService;
 import com.mortals.xhx.module.realtime.model.RealtimeDataflowEntity;
 import com.mortals.xhx.module.realtime.model.RealtimeDataflowQuery;
 import com.mortals.xhx.module.realtime.model.RealtimeDataflowStatEntity;
@@ -16,8 +27,10 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.ObjectUtils;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 人流统计接口
@@ -32,12 +45,79 @@ public class RealTimePeopleStatTaskImpl implements ITaskExcuteService {
     private RealtimeDataflowStatService realtimeDataflowStatService;
     @Autowired
     private UploadService uploadService;
+    @Autowired
+    private MonitorAlarmService monitorAlarmService;
+    @Autowired
+    private MonitorAlarmRecordService monitorAlarmRecordService;
 
 
     @Override
     public void excuteTask(ITask task) throws AppException {
         statPeople();
         delFiles();
+
+        //随机添加人员监控
+        randomAlarmPeople();
+
+    }
+
+
+    private void randomAlarmPeople() {
+
+        RealtimeDataflowQuery realtimeDataflowQuery = new RealtimeDataflowQuery();
+        realtimeDataflowQuery.setDetectTimeStart(DateUtil.offsetDay(new Date(),-7).toDateStr());
+        realtimeDataflowQuery.setDetectTimeEnd(DateUtil.today());
+
+        PageInfo pageInfo = new PageInfo();
+        pageInfo.setPrePageResult(200);
+
+
+        realtimeDataflowService.find(realtimeDataflowQuery,pageInfo,null).getList().stream().filter(f->RandomUtil.randomInt(1,100)>50).forEach(item->{
+            //新增
+            MonitorAlarmEntity monitorAlarm = new MonitorAlarmEntity();
+            monitorAlarm.initAttrValue();
+            monitorAlarm.setSiteId(item.getSiteId());
+            monitorAlarm.setSiteName(item.getSiteName());
+
+            monitorAlarm.setIdNumber("5101061994072"+RandomUtil.randomInt(10000,99999));
+            monitorAlarm.setLastIdentifyTime(item.getDetectTime());
+            monitorAlarm.setYear(DataUtil.converStr2Int(DateUtils.getThisYear(), 2023));
+            monitorAlarm.setMonth(DataUtil.converStr2Int(DateUtils.getCurrMonth(), 1));
+            monitorAlarm.setDay(DateUtils.getCurrentMonthDay());
+            monitorAlarm.setCreateTime(new Date());
+            monitorAlarm.setCreateUserName("system");
+            monitorAlarm.setCreateUserId(1L);
+            monitorAlarmService.save(monitorAlarm);
+
+            //新增当前用户信息告警详细记录
+            MonitorAlarmRecordEntity monitorAlarmRecordEntity = new MonitorAlarmRecordEntity();
+            monitorAlarmRecordEntity.setAlarmId(monitorAlarm.getId());
+
+
+            ArrayList<String> list = new ArrayList<>();
+
+            list.add("工程规划许可、用地规划许可、规划核实");
+            list.add("不动产一件事一次办业务（二手房买卖、抵押、换证、离婚析产、变更）");
+            list.add("不动产档案查询业务（仅限不动产权证产调、查封、抵押情况等）");
+            list.add("住房信息查询（接新房交契税、房屋套数查询等）");
+            list.add("普通公路涉路施工许可、超限运输许可、市航务业务");
+            list.add("企业职工社会保险费补缴申报（距申报当月6个月以上的补缴）");
+
+            monitorAlarmRecordEntity.setReservationService(list.get(RandomUtil.randomInt(0,5)));
+            monitorAlarmRecordEntity.setReservationNumber("V4BCB");
+            monitorAlarmRecordEntity.setMonitorTime(item.getDetectTime());
+            monitorAlarmRecordEntity.setMonitorDevice(item.getDevice());
+            monitorAlarmRecordEntity.setCheckInMethod(CheckInMethodEnum.自动签到.getValue());
+            monitorAlarmRecordEntity.setMonitorCertificate(item.getPicture());
+            monitorAlarmRecordEntity.setCreateTime(new Date());
+            monitorAlarmRecordEntity.setCreateUserName("system");
+            monitorAlarmRecordEntity.setCreateUserId(1L);
+            monitorAlarmRecordService.save(monitorAlarmRecordEntity);
+        });
+
+
+
+
     }
 
     private void delFiles() {