suntianwu 3 years ago
parent
commit
137dba0eb6

+ 9 - 1
src/main/java/com/iden/bms/service/WarningService.java

@@ -114,6 +114,9 @@ public class WarningService {
                 handleEventComming(idenFaceImage);//昼伏夜出人员识别预警
                 handleEventComming(idenFaceImage);//昼伏夜出人员识别预警
             }
             }
         }
         }
+
+        //按小区统昨天的数据
+        staCommunity();
     }
     }
 
 
     //陌生人员识别预警
     //陌生人员识别预警
@@ -287,7 +290,7 @@ public class WarningService {
     private void handleResident() {
     private void handleResident() {
         //查询全部小区人员
         //查询全部小区人员
         QueryWrapper<IdenPerson> queryWrapper = new QueryWrapper<>();
         QueryWrapper<IdenPerson> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda().eq(IdenPerson::getType, PersonTypeEnum.COMMUNITY.getValue());
+        queryWrapper.lambda().like(IdenPerson::getType, PersonTypeEnum.COMMUNITY.getValue());
         List<IdenPerson> listPerson = this.idenPersonService.list(queryWrapper);
         List<IdenPerson> listPerson = this.idenPersonService.list(queryWrapper);
         if(CollUtil.isEmpty(listPerson)){
         if(CollUtil.isEmpty(listPerson)){
             return;
             return;
@@ -485,6 +488,11 @@ public class WarningService {
         }
         }
     }
     }
 
 
+    //按小区统计
+    private void staCommunity() {
+        idenWarningStaService.insertWarningPersonRateSta();
+    }
+
     //是否有连续7天情况
     //是否有连续7天情况
     private String getIsContinue(List<IdenFaceImage> listDataDate,int strangerDays) {
     private String getIsContinue(List<IdenFaceImage> listDataDate,int strangerDays) {
         if(CollUtil.isEmpty(listDataDate)){
         if(CollUtil.isEmpty(listDataDate)){

+ 2 - 0
src/main/java/com/iden/common/mapper/IdenWarningStaMapper.java

@@ -15,4 +15,6 @@ import java.util.List;
  */
  */
 public interface IdenWarningStaMapper extends BaseMapper<IdenWarningSta> {
 public interface IdenWarningStaMapper extends BaseMapper<IdenWarningSta> {
     List<HomePageWarningStaVO> queryWarningPersonRateSta();
     List<HomePageWarningStaVO> queryWarningPersonRateSta();
+
+    void insertWarningPersonRateSta();
 }
 }

+ 1 - 0
src/main/java/com/iden/common/service/IdenWarningStaService.java

@@ -14,4 +14,5 @@ import java.util.List;
  */
  */
 public interface IdenWarningStaService extends IService<IdenWarningSta> {
 public interface IdenWarningStaService extends IService<IdenWarningSta> {
     List<HomePageWarningStaVO> queryWarningPersonRateSta();
     List<HomePageWarningStaVO> queryWarningPersonRateSta();
+    void insertWarningPersonRateSta();
 }
 }

+ 6 - 0
src/main/java/com/iden/common/service/impl/IdenWarningStaServiceImpl.java

@@ -17,7 +17,13 @@ import java.util.List;
  */
  */
 @Service
 @Service
 public class IdenWarningStaServiceImpl extends ServiceImpl<IdenWarningStaMapper, IdenWarningSta> implements IdenWarningStaService {
 public class IdenWarningStaServiceImpl extends ServiceImpl<IdenWarningStaMapper, IdenWarningSta> implements IdenWarningStaService {
+    @Override
     public List<HomePageWarningStaVO> queryWarningPersonRateSta(){
     public List<HomePageWarningStaVO> queryWarningPersonRateSta(){
         return this.baseMapper.queryWarningPersonRateSta();
         return this.baseMapper.queryWarningPersonRateSta();
     }
     }
+
+    @Override
+    public void insertWarningPersonRateSta(){
+        this.baseMapper.insertWarningPersonRateSta();
+    }
 }
 }

+ 20 - 0
src/main/resources/mybatis/IdenWarningStaMapper.xml

@@ -8,4 +8,24 @@
         from iden_warning_sta  group by type
         from iden_warning_sta  group by type
     </select>
     </select>
 
 
+    <insert id="insertWarningPersonRateSta">
+       insert into iden_warning_sta(data_date,community_id,type,community_code,community_name,district,subdistrict,total)
+        select t.data_date dataDate,
+        t.community_id communityId,
+        t.type,
+        max(t.community_code) communityCode,
+        max(t.community_name) communityName,
+        max(t.district) district,
+        max(t.subdistrict) subdistrict,
+        count(1) total
+        from iden_warning_person t
+        where t.data_date = DATE_SUB(curdate(),INTERVAL -1 DAY)
+        group by t.data_date,t.community_id,t.type
+         on duplicate key update
+        community_code=values(community_code),
+        community_name=values(community_name),
+        district=values(district),
+       subdistrict=values(subdistrict),
+       total=values(total)
+    </insert>
 </mapper>
 </mapper>