审核之后删除未通过

esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserDao.java

@@ -40,4 +40,14 @@ public interface UserDao extends BaseDao<UserEntity> {
      * @date 2019/9/12 15:29
      */
     EpdcUserInfoResultDTO selectOneInfoById(String id);
+
+    /***
+     * 删除之前未通过的
+     * @param wxUnionId
+     * @return
+     * @author qushutong
+     * @date 2019/9/19 20:34
+     */
+    void deleteByUnionId(String wxUnionId);
+
 }

esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java

@@ -143,7 +143,10 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void audit(UserDTO dto) {
+        //先删除以前审核未通过的那条数据  根据WX_UNION_ID 判断
+        deleteByUnionId(dto);
         UserEntity entity = ConvertUtils.sourceToTarget(dto, UserEntity.class);
         //是否通过审核
         if (YesOrNoEnum.YES.value().equals(dto.getPass())) {
@@ -161,7 +164,11 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
             partyMembersDTO.setGridName(dto.getGrid());
             partyMembersService.save(partyMembersDTO);
         }
+    }
 
+    private void deleteByUnionId(UserDTO dto) {
+        String wxUnionId = dto.getWxUnionId();
+        baseDao.deleteByUnionId(wxUnionId);
     }
 
     @Override

esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserDao.xml

@@ -25,5 +25,12 @@
         WHERE
             eu.ID = #{id}
     </select>
+    <select id="deleteByUnionId">
+        DELETE
+        FROM
+            epdc_news
+        WHERE
+            WX_UNION_ID = #{wxUnionId}
+    </select>
 
 </mapper>