批量审核

ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/areaMessageVo.java

@@ -0,0 +1,29 @@
+package com.ruoyi.zdsz.domain.vo;
+
+import com.ruoyi.common.core.domain.BaseEntity;
+import lombok.Data;
+import org.springframework.scheduling.annotation.Async;
+
+@Data
+public class areaMessageVo extends BaseEntity {
+    /**
+     * 房间名
+     */
+    private  String houseId;
+    /**
+     * 单元名
+     */
+    private  String unitId;
+    /**
+     * 楼栋名
+     */
+    private  String buildingId;
+    /**
+     * 小区名
+     */
+    private  String areaId;
+    /**
+     * 行政区
+     */
+    private  String district;
+}

ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/task/photoTask.java

@@ -0,0 +1,49 @@
+package com.ruoyi.zdsz.task;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.helper.LoginHelper;
+import com.ruoyi.common.utils.GetBeanUtil;
+import com.ruoyi.zdsz.domain.ZEngineeringCivil;
+import com.ruoyi.zdsz.domain.bo.ZEngineeringNodeBo;
+import com.ruoyi.zdsz.mapper.ZEngineeringCivilMapper;
+import com.ruoyi.zdsz.service.IZEngineeringNodeService;
+
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * 审核通过后将照片保存至指定目录task
+ */
+public class photoTask implements  Runnable{
+
+    private IZEngineeringNodeService izEngineeringNodeService;
+    //    private List<ZEngineeringCivil> zEngineeringCivilList;
+    private ZEngineeringNodeBo zEngineeringNodeBo;
+    private  String userId;
+    private CountDownLatch countDownLatch;
+    private ZEngineeringCivilMapper baseMapper;
+    private LambdaQueryWrapper<ZEngineeringCivil> lqw ;
+    private Page page;
+
+    public  photoTask(ZEngineeringNodeBo zEngineeringNodeBo, CountDownLatch countDownLatch, Page page, LambdaQueryWrapper lqw )
+    {
+//        this.zEngineeringCivilList=zEngineeringCivilList;
+        this.zEngineeringNodeBo=zEngineeringNodeBo;
+        this.izEngineeringNodeService= GetBeanUtil.getApplicationContext().getBean(IZEngineeringNodeService.class);
+        this.baseMapper= GetBeanUtil.getApplicationContext().getBean(ZEngineeringCivilMapper.class);
+        this.userId= LoginHelper.getLoginUser().getUsername().toString();
+        this.countDownLatch=countDownLatch;
+        this.lqw = lqw;
+        this.page=page;
+    }
+    @Override
+    public void run() {
+//        if (zEngineeringCivilList.size()>0)
+//        {
+        Page<ZEngineeringCivil> page1=baseMapper.selectPage(page, lqw);
+        //izEngineeringNodeService.batchReview(page1.getRecords(),zEngineeringNodeBo,userId);
+        izEngineeringNodeService.Civilinsert(page1.getRecords(),zEngineeringNodeBo,userId);
+        //countDownLatch.countDown();//发出线程任务完成的信号
+
+    }
+}