Merge branch 'master' of http://git.ycjcjy.com/whole-estate/service

whole-estate/pom.xml

@@ -123,6 +123,32 @@
             <version>2.7.0</version>
         </dependency>
 
+        <!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>3.11.0</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>26.0-jre</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jodd</groupId>
+            <artifactId>jodd-bean</artifactId>
+            <version>3.7.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>commons-collections</groupId>
+            <artifactId>commons-collections</artifactId>
+            <version>3.2.1</version>
+        </dependency>
+
     </dependencies>
 
     <build>

whole-estate/src/main/java/com/example/wholeestate/common/http/OkHttpRequestUtils.java

@@ -0,0 +1,241 @@
+package com.example.wholeestate.common.http;
+
+import com.google.common.collect.Maps;
+import okhttp3.*;
+
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.util.Iterator;
+import java.util.Map;
+
+/**
+ * 封装请求
+ * @author weiximei
+ */
+public class OkHttpRequestUtils {
+
+    // 定义请求客户端
+    private static OkHttpClient client = new OkHttpClient();
+
+    /**
+     * get 请求
+     * @param url 请求URL
+     * @return
+     * @throws Exception
+     */
+    public static String doGet(String url) throws Exception {
+       return doGet(url, Maps.newHashMap());
+    }
+
+
+    /**
+     * get 请求
+     * @param url 请求URL
+     * @param query 携带参数参数
+     * @return
+     * @throws Exception
+     */
+    public static String doGet(String url, Map<String, Object> query) throws Exception {
+
+        return doGet(url, Maps.newHashMap(), query);
+    }
+
+    /**
+     * get 请求
+     * @param url url
+     * @param header 请求头参数
+     * @param query 参数
+     * @return
+     */
+    public static String doGet(String url, Map<String, Object> header, Map<String, Object> query) throws Exception {
+
+        // 创建一个请求 Builder
+        Request.Builder builder = new Request.Builder();
+        // 创建一个 request
+        Request request = builder.url(url).build();
+
+        // 创建一个 HttpUrl.Builder
+        HttpUrl.Builder urlBuilder = request.url().newBuilder();
+        // 创建一个 Headers.Builder
+        Headers.Builder headerBuilder = request.headers().newBuilder();
+
+        // 装载请求头参数
+        Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
+        headerIterator.forEachRemaining(e -> {
+            headerBuilder.add(e.getKey(), (String) e.getValue());
+        });
+
+        // 装载请求的参数
+        Iterator<Map.Entry<String, Object>> queryIterator = query.entrySet().iterator();
+        queryIterator.forEachRemaining(e -> {
+            urlBuilder.addQueryParameter(e.getKey(), (String) e.getValue());
+        });
+
+        // 设置自定义的 builder
+        builder.url(urlBuilder.build()).headers(headerBuilder.build());
+
+        Request buildRequest = builder.build();
+
+        System.out.println("OkHttp 发起的请求：" + buildRequest.url().toString());
+
+        try (Response execute = client.newCall(buildRequest).execute()) {
+            return execute.body().string();
+        }
+    }
+
+    /**
+     * post 请求， 请求参数 并且 携带文件上传
+     * @param url
+     * @param header
+     * @param parameter
+     * @param file
+     * @return
+     * @throws Exception
+     */
+    public static String doPost(String url, Map<String, Object> header, Map<String, Object> parameter, File file) throws Exception {
+
+        // 创建一个请求 Builder
+        Request.Builder builder = new Request.Builder();
+        // 创建一个 request
+        Request request = builder.url(url).build();
+
+        // 创建一个 Headers.Builder
+        Headers.Builder headerBuilder = request.headers().newBuilder();
+
+        // 装载请求头参数
+        Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
+        headerIterator.forEachRemaining(e -> {
+            headerBuilder.add(e.getKey(), (String) e.getValue());
+        });
+
+        MultipartBody.Builder requestBuilder = new MultipartBody.Builder();
+
+        // 状态请求参数
+        Iterator<Map.Entry<String, Object>> queryIterator = parameter.entrySet().iterator();
+        queryIterator.forEachRemaining(e -> {
+            requestBuilder.addFormDataPart(e.getKey(), (String) e.getValue());
+        });
+
+        if (null != file) {
+            // application/octet-stream
+            requestBuilder.addFormDataPart("uploadFiles", file.getName(), RequestBody.create(MediaType.parse("application/octet-stream"), file));
+        }
+
+        // 设置自定义的 builder
+        builder.headers(headerBuilder.build()).post(requestBuilder.build());
+
+        // 然后再 build 一下
+        try (Response execute = client.newCall(builder.build()).execute()) {
+            return execute.body().string();
+        }
+    }
+
+    /**
+     * post 请求， 请求参数 并且 携带文件上传二进制流
+     * @param url
+     * @param header
+     * @param parameter
+     * @param fileName 文件名
+     * @param fileByte 文件的二进制流
+     * @return
+     * @throws Exception
+     */
+    public static String doPost(String url, Map<String, Object> header, Map<String, Object> parameter, String fileName, byte [] fileByte) throws Exception {
+// 创建一个请求 Builder
+        Request.Builder builder = new Request.Builder();
+        // 创建一个 request
+        Request request = builder.url(url).build();
+
+        // 创建一个 Headers.Builder
+        Headers.Builder headerBuilder = request.headers().newBuilder();
+
+        // 装载请求头参数
+        Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
+        headerIterator.forEachRemaining(e -> {
+            headerBuilder.add(e.getKey(), (String) e.getValue());
+        });
+
+        MultipartBody.Builder requestBuilder = new MultipartBody.Builder();
+
+        // 状态请求参数
+        Iterator<Map.Entry<String, Object>> queryIterator = parameter.entrySet().iterator();
+        queryIterator.forEachRemaining(e -> {
+            requestBuilder.addFormDataPart(e.getKey(), (String) e.getValue());
+        });
+
+        if (fileByte.length > 0) {
+            // application/octet-stream
+            requestBuilder.addFormDataPart("uploadFiles", fileName, RequestBody.create(MediaType.parse("application/octet-stream"), fileByte));
+        }
+
+        // 设置自定义的 builder
+        builder.headers(headerBuilder.build()).post(requestBuilder.build());
+
+        try (Response execute = client.newCall(builder.build()).execute()) {
+            return execute.body().string();
+        }
+    }
+
+
+    /**
+     * post 请求  携带文件上传
+     * @param url
+     * @param file
+     * @return
+     * @throws Exception
+     */
+    public static String doPost(String url, File file) throws Exception {
+        return doPost(url, Maps.newHashMap(), Maps.newHashMap(), file);
+    }
+
+    /**
+     * post 请求
+     * @param url
+     * @param header 请求头
+     * @param parameter 参数
+     * @return
+     * @throws Exception
+     */
+    public static String doPost(String url, Map<String, Object> header, Map<String, Object> parameter) throws Exception {
+        return doPost(url, header, parameter, null);
+    }
+
+    /**
+     * post 请求
+     * @param url
+     * @param parameter 参数
+     * @return
+     * @throws Exception
+     */
+    public static String doPost(String url, Map<String, Object> parameter) throws Exception {
+        return doPost(url, Maps.newHashMap(), parameter, null);
+    }
+
+    public static void main(String[] args) throws Exception {
+
+        byte [] fileByte = null;
+
+        File file = new File("C:\\Users\\szc\\Pictures\\file-read-4182.jpg");
+        FileInputStream fileInputStream = new FileInputStream(file);
+
+        ByteArrayOutputStream bos = new ByteArrayOutputStream();
+        byte[] b = new byte[1024];
+        int n;
+        while ((n = fileInputStream.read(b)) != -1)
+        {
+            bos.write(b, 0, n);
+        }
+        fileInputStream.close();
+        bos.close();
+        fileByte = bos.toByteArray();
+
+
+        Map<String, Object> queryMap = Maps.newHashMap();
+        queryMap.put("pageNum","2");
+        queryMap.put("pageSize","50");
+        System.out.println(OkHttpRequestUtils.doPost("http://localhost:8080/uploadImage" , Maps.newHashMap(), Maps.newHashMap(),file.getName(), fileByte));
+
+    }
+
+}

whole-estate/src/main/java/com/example/wholeestate/controller/ActivityController.java

@@ -189,7 +189,7 @@ public class ActivityController extends BaseController {
         return responseBean;
     }
 
-    @RequestMapping(value = "/wx/activity/{openid}", method = RequestMethod.GET)
+    @RequestMapping(value = "/wx/activity/byuser/{openid}", method = RequestMethod.GET)
     @ApiOperation(value = "微信小程序 根据openid查询参加过的活动列表", notes = "微信小程序 根据openid查询参加过的活动列表")
     @ApiImplicitParams({
             @ApiImplicitParam(paramType = "query", dataTypeClass = Integer.class, name = "pageNum", value = "pageNum第几页"),
@@ -212,4 +212,27 @@ public class ActivityController extends BaseController {
         return responseBean;
     }
 
+    @RequestMapping(value = "/wx/activity", method = RequestMethod.GET)
+    @ApiOperation(value = "微信活动列表", notes = "微信活动列表")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "query", dataTypeClass = Integer.class, name = "pageNum", value = "pageNum第几页"),
+            @ApiImplicitParam(paramType = "query", dataTypeClass = Integer.class, name = "pageSize", value = "pageSize一页多少行")
+    })
+    public ResponseBean getWxList(@RequestParam(defaultValue = "1") Integer pageNum,
+                                @RequestParam(defaultValue = "10") Integer pageSize) {
+        ResponseBean responseBean = new ResponseBean();
+        responseBean = iActivityService.getList(pageNum, pageSize, null,null,null);
+        return responseBean;
+    }
+
+    @RequestMapping(value = "/wx/activity/{activityId}", method = RequestMethod.GET)
+    @ApiOperation(value = "活动详情", notes = "活动详情")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "path", dataTypeClass = String.class, name = "activityId", value = "activityId活动id")
+    })
+    public ResponseBean getWxById(@PathVariable String activityId) {
+        ResponseBean responseBean = new ResponseBean();
+        responseBean = iActivityService.getWxActivityId(activityId);
+        return responseBean;
+    }
 }

whole-estate/src/main/java/com/example/wholeestate/controller/BuildingController.java

@@ -265,4 +265,15 @@ public class BuildingController extends BaseController {
         ResponseBean  responseBean = iBuildingService.buildingUpdate(parameter);
         return responseBean;
     }
+
+
+    @RequestMapping(value = "/wx/buildingSelectId/{id}", method = RequestMethod.GET)
+    @ApiOperation(value = "楼盘详情", notes = "楼盘详情")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "path", dataTypeClass=String.class, name = "id", value = "楼盘id"),
+    })
+    public ResponseBean wxBuildingSelectId(@PathVariable(value = "id") String id){
+        ResponseBean  responseBean = iBuildingService.buildingAllSelectId(id);
+        return responseBean;
+    }
 }

whole-estate/src/main/java/com/example/wholeestate/controller/CustomerController.java

@@ -82,4 +82,5 @@ public class CustomerController extends BaseController {
         return responseBean;
     }
 
+
 }

whole-estate/src/main/java/com/example/wholeestate/controller/WxUserController.java

@@ -10,6 +10,8 @@ import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpSession;
+
 @RestController
 @RequestMapping("/")
 @Api(value = "微信小程序 用户 API", description = "微信小程序 用户 API")
@@ -50,4 +52,14 @@ public class WxUserController extends BaseController {
         return responseBean;
     }
 
+    @RequestMapping(value = "/wx/getOpenid", method = RequestMethod.GET)
+    @ApiOperation(value = "微信小程序获取 openid", notes = "微信小程序获取 openid")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "query", dataTypeClass=String.class, name = "code", value = "code"),
+    })
+    public ResponseBean getOpenid(@RequestParam(value = "code") String code, HttpSession session){
+        ResponseBean  responseBean = iCustomerService.wxOpenid(code);
+        return responseBean;
+    }
+
 }

whole-estate/src/main/java/com/example/wholeestate/dao/BuildingImgMapper.java

@@ -1,7 +1,11 @@
 package com.example.wholeestate.dao;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.example.wholeestate.model.BuildingDynamic;
 import com.example.wholeestate.model.BuildingImg;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * <p>
@@ -12,5 +16,5 @@ import com.example.wholeestate.model.BuildingImg;
  * @since 2019-03-21
  */
 public interface BuildingImgMapper extends BaseMapper<BuildingImg> {
-
+    List<BuildingImg> getBuildingImgByApartment(@Param("id") String id);
 }

whole-estate/src/main/java/com/example/wholeestate/model/Building.java

@@ -100,5 +100,9 @@ public class Building implements Serializable {
     @TableField(exist = false)
     private List<BuildingImg> BuildingImg;
 
-
+    /**
+     * 户型
+     */
+    @TableField(exist = false)
+    private List<BuildingApartment> buildingApartment;
 }

whole-estate/src/main/java/com/example/wholeestate/model/Customer.java

@@ -49,5 +49,9 @@ public class Customer implements Serializable {
 
     private String avatar;
 
+    /**
+     * 0 未注册 1 已注册
+     */
+    private Integer hasReg;
 
 }

whole-estate/src/main/java/com/example/wholeestate/service/IActivityService.java

@@ -39,5 +39,10 @@ public interface IActivityService extends IService<Activity> {
      */
     ResponseBean getWxActivityList(Integer pageNum, Integer pageSize);
 
-
+    /**
+     * 微信 精彩活动详情
+     * @param activityId
+     * @return
+     */
+    ResponseBean getWxActivityId(String activityId);
 }

whole-estate/src/main/java/com/example/wholeestate/service/IBuildingService.java

@@ -29,6 +29,14 @@ public interface IBuildingService extends IService<Building> {
      */
     ResponseBean buildingSelectId(String id);
 
+    /**
+     * 楼盘详情
+     * @param id
+     * @return
+     */
+    ResponseBean buildingAllSelectId(String id);
+
+
     /**
      * 修改楼盘
      * @param parameter

whole-estate/src/main/java/com/example/wholeestate/service/ICustomerService.java

@@ -42,6 +42,14 @@ public interface ICustomerService extends IService<Customer> {
      */
     ResponseBean getWXCustomer(String openid);
 
+    /**
+     * 根据 code 获取 openid
+     *
+     * @param code
+     * @return
+     */
+    ResponseBean wxOpenid(String code);
+
 
     ResponseBean updateCustomer(String parameter);
 }

whole-estate/src/main/java/com/example/wholeestate/service/impl/ActivityServiceImpl.java

@@ -92,4 +92,20 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
         responseBean.addSuccess(activityIPage);
         return responseBean;
     }
+
+    @Override
+    public  ResponseBean getWxActivityId(String activityId) {
+        ResponseBean responseBean = new ResponseBean();
+
+        QueryWrapper<Activity> activityQueryWrapper = new QueryWrapper<>();
+        activityQueryWrapper.eq("activity_id", activityId);
+        Activity activity = activityMapper.selectOne(activityQueryWrapper);
+        if (null == activity) {
+            responseBean.addError("活动不存在!");
+            return responseBean;
+        }
+
+        responseBean.addSuccess(activity);
+        return responseBean;
+    }
 }

whole-estate/src/main/java/com/example/wholeestate/service/impl/BuildingServiceImpl.java

@@ -93,6 +93,34 @@ public class BuildingServiceImpl extends ServiceImpl<BuildingMapper, Building> i
         return response;
     }
 
+    @Override
+    public ResponseBean buildingAllSelectId(String id) {
+        ResponseBean response= new ResponseBean();
+        QueryWrapper<Building> buildingtWrapper = new QueryWrapper<>();
+        buildingtWrapper.lambda().gt(Building::getStatus,-1);
+        buildingtWrapper.lambda().eq(Building::getBuildingId,id);
+        Building building= buildingMapper.selectOne(buildingtWrapper);
+        //查询当前图片
+        QueryWrapper<BuildingImg> BuildingImgQueryWrapper = new QueryWrapper<>();
+        BuildingImgQueryWrapper.eq("building_id", id);
+        BuildingImgQueryWrapper.eq("img_type", "banner");
+        List<BuildingImg> buildingImg= buildingImgMapper.selectList(BuildingImgQueryWrapper);
+        building.setBuildingImg(buildingImg);
+        // 查询户型
+        QueryWrapper<BuildingApartment> AppointmentQueryWrapper = new QueryWrapper<>();
+        AppointmentQueryWrapper.eq("building_id", id);
+        AppointmentQueryWrapper.eq("status", 1);
+        List<BuildingApartment> appoint= buildingApartmentMapper.selectList(AppointmentQueryWrapper);
+
+        for (BuildingApartment apar:appoint) {
+            List<BuildingImg> imgs = buildingImgMapper.getBuildingImgByApartment(apar.getApartmentId());
+            apar.setBuildingImgList(imgs);
+        }
+        building.setBuildingApartment(appoint);
+        response.addSuccess(building);
+        return response;
+    }
+
     @Override
     public ResponseBean buildingUpdate(String parameter) {
         ResponseBean response= new ResponseBean();
@@ -389,6 +417,15 @@ public class BuildingServiceImpl extends ServiceImpl<BuildingMapper, Building> i
         QueryWrapper<Building> buildingQueryWrapper = new QueryWrapper<>();
         buildingQueryWrapper.eq("status", 1);
         List<Building> buildingList = buildingMapper.selectList(buildingQueryWrapper);
+
+        for (Building build:buildingList) {
+            QueryWrapper<BuildingImg> BuildingImgQueryWrapper = new QueryWrapper<>();
+            BuildingImgQueryWrapper.eq("building_id", build.getBuildingId());
+            BuildingImgQueryWrapper.eq("img_type", "banner");
+            List<BuildingImg> buildingImg = buildingImgMapper.selectList(BuildingImgQueryWrapper);
+            build.setBuildingImg(buildingImg);
+        }
+
         responseBean.addSuccess(buildingList);
 
         return responseBean;

whole-estate/src/main/java/com/example/wholeestate/service/impl/CustomerServiceImpl.java

@@ -13,6 +13,8 @@ import com.example.wholeestate.dao.CustomerMapper;
 
 import com.example.wholeestate.model.Customer;
 import com.example.wholeestate.service.ICustomerService;
+import com.example.wholeestate.utils.BeanTools;
+import com.example.wholeestate.wx.mini.IWxMini;
 import org.apache.http.HttpStatus;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -36,6 +38,9 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> i
     @Autowired
     private CustomerMapper customerMapper;
 
+    @Autowired
+    private IWxMini iWxMini;
+
     private IdGen idGen = IdGen.get();
 
     @Override
@@ -74,9 +79,20 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> i
         Customer customer = JSONObject.parseObject(parameter, Customer.class);
         customer.setCreateDate(LocalDateTime.now());
         customer.setStatus(1);
+        customer.setHasReg(1);
 
-        customer.setCustomerId(idGen.nextId()+"");
-        customerMapper.insert(customer);
+        QueryWrapper<Customer> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("openid", customer.getOpenid());
+        Customer selectOne = customerMapper.selectOne(queryWrapper);
+        if (null == selectOne) {
+            responseBean.addError("用户不存在！");
+            return responseBean;
+        }
+
+        BeanTools.copyProperties(customer, selectOne);
+
+        customerMapper.update(selectOne, queryWrapper);
+        responseBean.addSuccess("操作成功！");
         return responseBean;
     }
 
@@ -95,6 +111,31 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> i
         return responseBean;
     }
 
+    @Override
+    public ResponseBean wxOpenid(String code) {
+        ResponseBean responseBean = new ResponseBean();
+        String openid = iWxMini.getOpenid(code);
+
+        QueryWrapper<Customer> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("openid", openid);
+        Customer customer = customerMapper.selectOne(queryWrapper);
+        if (null != customer) {
+            responseBean.addSuccess(customer);
+            return responseBean;
+        }
+
+        customer = new Customer();
+        customer.setCustomerId(idGen.nextId() + "");
+        customer.setCreateDate(LocalDateTime.now());
+        customer.setOpenid(openid);
+        customer.setHasReg(0);
+
+        customerMapper.insert(customer);
+
+        responseBean.addSuccess(customer);
+        return responseBean;
+    }
+
     @Override
     public ResponseBean updateCustomer(String parameter) {
         ResponseBean responseBean = new ResponseBean();

whole-estate/src/main/java/com/example/wholeestate/utils/BeanTools.java

@@ -0,0 +1,137 @@
+package com.example.wholeestate.utils;
+
+import jodd.bean.BeanCopy;
+import jodd.typeconverter.TypeConverterManager;
+import org.apache.commons.collections.BeanMap;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.BeanWrapper;
+import org.springframework.beans.BeanWrapperImpl;
+
+import java.beans.PropertyDescriptor;
+import java.lang.reflect.Method;
+import java.util.*;
+
+@SuppressWarnings("deprecation")
+public final class BeanTools {
+
+    private static Map<String, Object> toBeanMethodMap = new HashMap<String, Object>();
+
+    /**
+     * <pre>
+     * 功能：实现BEAN的属性对拷
+     * 创建人：JokenWang
+     * </pre>
+     *
+     * @param fromBean        待转换的源bean
+     * @param toBeanClassName 转换成目标bean的名称 形如：ItemSeries.class.getName()
+     * @return 目标BEAN类
+     */
+    public static <T> T convertBean(Object fromBean, Class<T> toBeanClassName) {
+        T toBean = null;
+        try {
+            toBean = getBeanInstance(toBeanClassName.getName());
+            return convertBean(fromBean, toBean);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return toBean;
+    }
+
+    private static <T> T convertBean(Object fromBean, T toBean) {
+        TypeConverterManager.register(String.class, new StringConverter());
+        BeanCopy.beans(fromBean, toBean).copy();
+        return toBean;
+    }
+
+    public static Method getDeclaredMethod(Object object, String methodName, Class<?>... parameterTypes) {
+        Method method;
+        for (Class<?> clazz = object.getClass(); clazz != Object.class; clazz = clazz.getSuperclass()) {
+            try {
+                method = clazz.getDeclaredMethod(methodName, parameterTypes);
+                return method;
+            } catch (Exception ignored) {
+
+            }
+        }
+        return null;
+    }
+
+    @SuppressWarnings("unchecked")
+    public static <T> T getBeanInstance(String clazzName)
+            throws InstantiationException, IllegalAccessException, ClassNotFoundException {
+
+        return (T) Class.forName(clazzName).newInstance();
+    }
+
+    public static Map<String, Object> toBeanMethodMap(String toBean)
+            throws InstantiationException, IllegalAccessException, ClassNotFoundException {
+
+        Class<?> toBeanClazz = getBeanInstance(toBean).getClass();
+        Method[] toBeanMethods = toBeanClazz.getDeclaredMethods();
+        if (!toBeanClazz.isInstance(Object.class))// 非超类Object
+        {
+            for (Method method : toBeanMethods) {
+                String methodName = method.getName();
+                toBeanMethodMap.put(methodName, method);
+            }
+
+            Class<?> toBeanSuperclazz = toBeanClazz.getSuperclass();// 获取父类
+            toBeanMethodMap(toBeanSuperclazz.getName());
+        }
+
+        return toBeanMethodMap;
+    }
+
+    public static Map<String, Object> toMap(Object object) {
+        Map<String, Object> map = new HashMap<String, Object>();
+
+        if (object == null) {
+            return map;
+        }
+
+        BeanMap beanMap;
+        beanMap = new BeanMap(object);
+        @SuppressWarnings("unchecked")
+        Iterator<String> it = beanMap.keyIterator();
+        while (it.hasNext()) {
+            String name = it.next();
+            Object value = beanMap.get(name);
+            // 转换时会将类名也转换成属性，此处去掉
+            if (value != null && !name.equals("class")) {
+                map.put(name, value);
+            }
+        }
+
+        return map;
+    }
+
+    public static Map<String, Object> toMap(Object... objs) {
+        Map<String, Object> map = new HashMap<>();
+        for (Object object : objs) {
+            if (object != null) {
+                map.putAll(toMap(object));
+            }
+        }
+        return map;
+    }
+
+    public static String[] getNullPropertyNames (Object source) {
+        final BeanWrapper src = new BeanWrapperImpl(source);
+        PropertyDescriptor[] pds = src.getPropertyDescriptors();
+
+        Set<String> emptyNames = new HashSet<String>();
+        for(PropertyDescriptor pd : pds) {
+            Object srcValue = src.getPropertyValue(pd.getName());
+            if (srcValue == null) {
+                emptyNames.add(pd.getName());
+            }
+        }
+        String[] result = new String[emptyNames.size()];
+        return emptyNames.toArray(result);
+    }
+
+    public static void copyProperties(Object src, Object target) {
+        BeanUtils.copyProperties(src, target, getNullPropertyNames(src));
+    }
+
+}

whole-estate/src/main/java/com/example/wholeestate/utils/StringConverter.java

@@ -0,0 +1,72 @@
+package com.example.wholeestate.utils;
+
+import jodd.typeconverter.TypeConversionException;
+import jodd.typeconverter.TypeConverter;
+import jodd.util.ArraysUtil;
+
+import java.sql.Clob;
+import java.sql.SQLException;
+import java.util.Date;
+
+public class StringConverter implements TypeConverter<String> {
+
+    public String convert(Object value) {
+        if (value == null) {
+            return null;
+        }
+
+        if (value instanceof CharSequence) { // for speed
+            return value.toString();
+        }
+        Class<?> type = value.getClass();
+        if (type == Class.class) {
+            return ((Class<?>) value).getName();
+        }
+        if (type.isArray()) {
+            if (type == char[].class) {
+                char[] charArray = (char[]) value;
+                return new String(charArray);
+            }
+            if (type == int[].class) {
+                return ArraysUtil.toString((int[]) value);
+            }
+            if (type == long[].class) {
+                return ArraysUtil.toString((long[]) value);
+            }
+            if (type == byte[].class) {
+                return ArraysUtil.toString((byte[]) value);
+            }
+            if (type == float[].class) {
+                return ArraysUtil.toString((float[]) value);
+            }
+            if (type == double[].class) {
+                return ArraysUtil.toString((double[]) value);
+            }
+            if (type == short[].class) {
+                return ArraysUtil.toString((short[]) value);
+            }
+            if (type == boolean[].class) {
+                return ArraysUtil.toString((boolean[]) value);
+            }
+            return ArraysUtil.toString((Object[]) value);
+        }
+        if (value instanceof Clob) {
+            Clob clob = (Clob) value;
+            try {
+                long length = clob.length();
+                if (length > Integer.MAX_VALUE) {
+                    throw new TypeConversionException("Clob is too big.");
+                }
+                return clob.getSubString(1, (int) length);
+            } catch (SQLException sex) {
+                throw new TypeConversionException(value, sex);
+            }
+        }
+        if (value instanceof Date) {
+            java.text.DateFormat format1 = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            return format1.format(value);
+        }
+
+        return value.toString();
+    }
+}

whole-estate/src/main/java/com/example/wholeestate/wx/WxBase.java

@@ -0,0 +1,22 @@
+package com.example.wholeestate.wx;
+
+import com.alibaba.fastjson.JSONObject;
+import com.example.wholeestate.exception.WholeEstateException;
+
+/**
+ * @author weiximei
+ */
+public class WxBase {
+
+    protected void wxMiniErrCode(JSONObject jsonObject) {
+
+        Integer errcode = jsonObject.getInteger("errcode");
+
+        if (null != errcode && errcode != 0) {
+            String errmsg = jsonObject.getString("errmsg");
+            throw new WholeEstateException(errmsg);
+        }
+
+    }
+
+}

whole-estate/src/main/java/com/example/wholeestate/wx/WxConstant.java

@@ -0,0 +1,22 @@
+package com.example.wholeestate.wx;
+
+/**
+ * 定义 微信相关 URL
+ * @author weiximei
+ */
+public class WxConstant {
+
+    // -------------   微信小程序 start  ---------------------
+
+    /**
+     * 根据 code 获取 openid, session_key, unionid 等
+     *
+     * 请求参数在发起请求的时候拼装
+     *
+     */
+    public static final String  WX_MINI_CODE2_SESSION = "https://api.weixin.qq.com/sns/jscode2session";
+
+
+    // ------------  微信小程序 end --------------------------
+
+}

whole-estate/src/main/java/com/example/wholeestate/wx/WxMiniProperties.java

@@ -0,0 +1,26 @@
+package com.example.wholeestate.wx;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * 微信小程序 参数
+ * @author weiximei
+ */
+@Data
+@Component
+@ConfigurationProperties(prefix = "wx.mini")
+public class WxMiniProperties {
+
+    /**
+     * 小程序 appId
+     */
+    private String appid;
+
+    /**
+     * 小程序 appSecret
+     */
+    private String secret;
+
+}

whole-estate/src/main/java/com/example/wholeestate/wx/mini/IWxMini.java

@@ -0,0 +1,20 @@
+package com.example.wholeestate.wx.mini;
+
+/**
+ * 微信小程序 接口
+ * @author weiximei
+ */
+public interface IWxMini {
+
+    /**
+     * 根据 code 获取
+     *
+     *      openid
+     *
+     * @param code
+     * @return
+     */
+    String getOpenid(String code);
+
+
+}

whole-estate/src/main/java/com/example/wholeestate/wx/mini/impl/WxMiniImpl.java

@@ -0,0 +1,56 @@
+package com.example.wholeestate.wx.mini.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.example.wholeestate.common.http.OkHttpRequestUtils;
+import com.example.wholeestate.wx.WxBase;
+import com.example.wholeestate.wx.WxConstant;
+import com.example.wholeestate.wx.WxMiniProperties;
+import com.example.wholeestate.wx.mini.IWxMini;
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+/**
+ * 微信 小程序实现
+ * @author weiximei
+ */
+@Service
+@Slf4j
+public class WxMiniImpl extends WxBase implements IWxMini {
+
+    @Autowired
+    private WxMiniProperties wxMiniProperties;
+
+    @Override
+    public String getOpenid(String code) {
+
+        Map<String, Object> query = Maps.newHashMap();
+        query.put("appid", wxMiniProperties.getAppid());
+        query.put("secret",wxMiniProperties.getSecret());
+        query.put("js_code", code);
+        query.put("grant_type","authorization_code");
+
+        String result = null;
+        try {
+            result = OkHttpRequestUtils.doGet(WxConstant.WX_MINI_CODE2_SESSION, query);
+            log.info("获取微信小程序 openid 数据：{}", result);
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("微信小程序--获取 openid 失败！", e);
+        }
+
+        JSONObject jsonObject = JSONObject.parseObject(result);
+
+        // 校验 errcode
+        wxMiniErrCode(jsonObject);
+
+        // 开始获取 openid
+        String openid = jsonObject.getString("openid");
+        return openid;
+    }
+
+
+}

whole-estate/src/main/resources/application.yml

@@ -29,4 +29,9 @@ logging:
   level:
     com.example.wholeestate.dao: debug
 
+# 微信配置
+wx:
+  mini:
+    appid: wx8d70a491c45b400e
+    secret: 7f995c77ef093410a3fe9909229796a5
 

whole-estate/src/main/resources/mapper/BuildingImgMapper.xml

@@ -1,5 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.example.wholeestate.dao.BuildingImgMapper">
-
+    <select id="getBuildingImgByApartment" resultType="com.example.wholeestate.model.BuildingImg" >
+      select a.* from ta_building_img a inner join ta_apartment_img b on a.img_id = b.img_id
+      where a.status = 1 and b.status=1 and b.apartment_id = #{id}
+    </select>
 </mapper>