test

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/DynamicQueryFormDTO.java

@@ -0,0 +1,22 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Description test
+ * @Author yinzuomei
+ * @Date 2021/11/2 10:38 上午
+ */
+@Data
+public class DynamicQueryFormDTO implements Serializable {
+    private String customerId;
+    private String formCode="resi_base_info";
+    @NotBlank(message = "resultTableName不能为空")
+    private String resultTableName;
+    private List<ResiUserQueryValueDTO> conditions;
+}
+

epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java

@@ -356,4 +356,12 @@ public class IcResiUserController {
 
     }
 
+    @PostMapping("test")
+    public Result<List<Map<String,Object>>> test(@LoginUser TokenDto tokenDto,@RequestBody DynamicQueryFormDTO formDTO){
+        formDTO.setCustomerId(tokenDto.getCustomerId());
+        return new Result<List<Map<String,Object>>>().ok(icResiUserService.dynamicQuery(formDTO.getCustomerId(),
+                formDTO.getFormCode(),
+                formDTO.getResultTableName(),
+                formDTO.getConditions()));
+    }
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserDao.java

@@ -80,4 +80,19 @@ public interface IcResiUserDao extends BaseDao<IcResiUserEntity> {
     int updateToDel(String icResiUserId);
 
     int updateSubTableToDel(@Param("subTalbeName") String subTalbeName, @Param("icResiUserId")String icResiUserId);
+
+    /**
+     * 接口名称
+     *
+     * @param customerId 客户id
+     * @param resultTableName 获取哪个表的数据？？？
+     * @param conditions 前端传入的查询入参
+     * @return  java.util.List<java.util.Map<java.lang.String,java.lang.Object>>
+     * @author yinzuomei
+     * @date 2021/11/2 10:35 上午
+     */
+    List<Map<String,Object>> dynamicQuery(@Param("customerId")String customerId,
+                                          @Param("resultTableName")String resultTableName,
+                                          @Param("conditions") List<ResiUserQueryValueDTO> conditions,
+                                          @Param("subTables") List<String> subTables);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/IcResiUserService.java

@@ -21,10 +21,7 @@ import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.dto.IcResiUserDTO;
-import com.epmet.dto.form.DelIcResiUserFormDTO;
-import com.epmet.dto.form.IcResiDetailFormDTO;
-import com.epmet.dto.form.IcResiUserFormDTO;
-import com.epmet.dto.form.IcResiUserPageFormDTO;
+import com.epmet.dto.form.*;
 import com.epmet.dto.result.HomeUserResultDTO;
 import com.epmet.entity.IcResiUserEntity;
 
@@ -130,4 +127,9 @@ public interface IcResiUserService extends BaseService<IcResiUserEntity> {
      */
     Map queryIcResiDetail(IcResiDetailFormDTO pageFormDTO);
 
+
+    List<Map<String,Object>> dynamicQuery(String customerId,
+                                          String formCode,
+                                          String resultTableName,
+                                          List<ResiUserQueryValueDTO> conditions);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java

@@ -417,4 +417,18 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
         return resultMap;
     }
 
+    public List<Map<String,Object>> dynamicQuery(String customerId,
+                                                 String formCode,
+                                                 String resultTableName,
+                                                 List<ResiUserQueryValueDTO> conditions){
+        CustomerFormQueryDTO queryDTO=new CustomerFormQueryDTO();
+        queryDTO.setCustomerId(customerId);
+        queryDTO.setFormCode(formCode);
+        Result<List<String>> subTablesRes=operCustomizeOpenFeignClient.querySubTables(queryDTO);
+        List<String> subTables=new ArrayList<>();
+        if(subTablesRes.success()&&CollectionUtils.isNotEmpty(subTablesRes.getData())){
+            subTables =subTablesRes.getData();
+        }
+        return baseDao.dynamicQuery(customerId,resultTableName,conditions,subTables);
+    }
 }