项目数据上报删除改为物理删除

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenProjectDataDao.java

@@ -46,4 +46,22 @@ public interface ScreenProjectDataDao extends BaseDao<ScreenProjectDataEntity> {
     void insertBatch(@Param("list") List<ScreenProjectDataDTO> list);
 
     void updateBatch(@Param("list") List<ScreenProjectDataDTO> list,@Param("dateId") String dateId);
+
+    /**
+     * 根据项目ID删除数据
+     * @author zhaoqifeng
+     * @date 2021/7/9 17:33
+     * @param projectId
+     * @return int
+     */
+    int deleteByProjectId(@Param("projectId") String projectId);
+
+    /**
+     * 根据项目ID删除数据
+     * @author zhaoqifeng
+     * @date 2021/7/9 17:33
+     * @param list
+     * @return int
+     */
+    void deleteByProjectIds(@Param("list") List<String> list);
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenProjectImgDataDao.java

@@ -37,4 +37,6 @@ public interface ScreenProjectImgDataDao extends BaseDao<ScreenProjectImgDataEnt
 	void deleteByProjectIds(@Param("list") List<String> list);
 
 	void insertBatch(@Param("list") List<ScreenProjectImgDataDTO> list);
+
+	int deleteByProjectId(@Param("projectId") String projectId);
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectDataServiceImpl.java

@@ -177,14 +177,8 @@ public class ScreenProjectDataServiceImpl extends BaseServiceImpl<ScreenProjectD
                 }
             }
             //先删除该projectId对应的旧数据
-            QueryWrapper<ScreenProjectDataEntity> deleteWrapper = new QueryWrapper<>();
-            deleteWrapper.eq(StringUtils.isNotBlank(item.getProjectId()), "project_id", item.getProjectId())
-                    .eq(StringUtils.isNotBlank(param.getCustomerId()), "customer_id", param.getCustomerId());
-            baseDao.delete(deleteWrapper);
-            QueryWrapper<ScreenProjectImgDataEntity> screenProjectImgDataEntityQueryWrapper = new QueryWrapper<>();
-            screenProjectImgDataEntityQueryWrapper.eq(StringUtils.isNotBlank(item.getProjectId()), "project_id", item.getProjectId())
-                    .eq(StringUtils.isNotBlank(param.getCustomerId()), "customer_id", param.getCustomerId());
-            screenProjectImgDataDao.delete(screenProjectImgDataEntityQueryWrapper);
+            baseDao.deleteByProjectId(item.getProjectId());
+            screenProjectImgDataDao.deleteByProjectId(item.getProjectId());
 
             //如果orgType未知，获取一下
 //            if ("unknown".equals(item.getOrgType())){

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectDataDao.xml

@@ -46,6 +46,19 @@
         and DATE_FORMAT(PROJECT_CREATE_TIME,'%Y%m%d') = #{dateId}
         limit 1000
     </delete>
+    <delete id="deleteByProjectId">
+        delete from screen_project_data
+        where PROJECT_ID = #{projectId}
+    </delete>
+
+    <delete id="deleteByProjectIds">
+        delete from screen_project_data
+        <where>
+            <foreach collection="list" item="projectId" separator=" or ">
+                PROJECT_ID = #{projectId}
+            </foreach>
+        </where>
+    </delete>
 
     <select id="checkIfExisted" resultType="int">
         select count(id) from screen_project_data

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenProjectImgDataDao.xml

@@ -26,6 +26,10 @@
             </foreach>
         </where>
     </delete>
+    <delete id="deleteByProjectId">
+        delete from screen_project_img_data
+        where PROJECT_ID = #{projectId}
+    </delete>
 
 
     <insert id="insertBatch" parameterType="java.util.List">