多数据源配置

linkwe-chinacoal/src/main/java/com/linkwechat/coal/datasource/BdshdbDataSourceConfig.java

@@ -24,7 +24,7 @@ import javax.sql.DataSource;
  * 从数据源配置
  */
 @Configuration
-@MapperScan(basePackages = {"com.linkwechat.coal.modules.bdshdb.*.mapper"}, sqlSessionFactoryRef = "ltycaasdbSqlSessionFactory")
+@MapperScan(basePackages = {"com.linkwechat.coal.modules.bdshdb.*.mapper"}, sqlSessionFactoryRef = "bdshdbSqlSessionFactory")
 public class BdshdbDataSourceConfig {
 
     @Bean(name = "bdshdbDataSource")

linkwe-chinacoal/src/main/java/com/linkwechat/coal/modules/bdshdb/customer/controller/TestController.java

@@ -0,0 +1,40 @@
+package com.linkwechat.coal.modules.bdshdb.customer.controller;
+
+import com.linkwechat.coal.modules.bdshdb.customer.domain.entity.LocalAppUser;
+import com.linkwechat.coal.modules.bdshdb.customer.mapper.LocalAppUserMapper;
+import com.linkwechat.coal.modules.bdshdb.customer.service.ILocalAppUserService;
+import com.linkwechat.common.core.domain.AjaxResult;
+import com.linkwechat.common.core.page.TableDataInfo;
+import com.linkwechat.common.core.page.TableSupport;
+import com.linkwechat.domain.customer.query.WeCuUserQuery;
+import com.linkwechat.domain.customer.vo.WeUserVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@Slf4j
+@RestController
+@RequestMapping("/test")
+@Api(tags = "测试")
+public class TestController {
+
+    @Autowired
+    private LocalAppUserMapper localAppUserMapper;
+
+    /**
+     * 查询同步用户列表(分页),索引优化用户列表，未使用默认分页
+     */
+    @GetMapping("/test")
+    @ApiOperation(value = "测试",httpMethod = "GET")
+    public AjaxResult test() {
+        LocalAppUser localAppUser = localAppUserMapper.selectLocalAppUserById();
+        System.out.println(localAppUser.getUserType());
+        return AjaxResult.success(localAppUser);
+    }
+}

linkwe-chinacoal/src/main/java/com/linkwechat/coal/modules/bdshdb/customer/domain/entity/LocalAppUser.java

@@ -0,0 +1,73 @@
+package com.linkwechat.coal.modules.bdshdb.customer.domain.entity;
+
+import com.alibaba.excel.annotation.format.DateTimeFormat;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("local_app_user")
+public class LocalAppUser {
+
+    /**
+     * 主键
+     */
+    @TableId(type = IdType.ASSIGN_ID)
+    @TableField("id")
+    private Long id;
+
+    /**
+     * 用户姓名
+     */
+    @TableField("name")
+    private String name;
+
+    /**
+     * 用户手机号
+     */
+    @TableField("phone")
+    private String phone;
+
+    /**
+     * 用户类型 1-投保客户 2-平台商户/ 3供应商 4平台用户 5.三方用户
+     */
+    @TableField("user_type")
+    private Integer userType;
+
+    /**
+     * 微信昵称
+     */
+    @TableField("wechat_nickname")
+    private String wechatNickname;
+
+    /**
+     * 微信头像
+     */
+    @TableField("wechat_head_photo")
+    private String wechatHeadPhoto;
+
+    /**
+     * 是否临时用户 (1.临时 2.正式)
+     */
+    @TableField("is_formal")
+    private Integer isFormal;
+
+    /**
+     * 创建时间
+     */
+    @DateTimeFormat("yyyy-MM-dd")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @TableField("create_time")
+    private Date createTime;
+}

linkwe-chinacoal/src/main/java/com/linkwechat/coal/modules/bdshdb/customer/mapper/LocalAppUserMapper.java

@@ -0,0 +1,12 @@
+package com.linkwechat.coal.modules.bdshdb.customer.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.linkwechat.coal.modules.bdshdb.customer.domain.entity.LocalAppUser;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface LocalAppUserMapper  extends BaseMapper<LocalAppUser> {
+
+
+    LocalAppUser selectLocalAppUserById();
+}

linkwe-chinacoal/src/main/java/com/linkwechat/coal/modules/bdshdb/customer/service/ILocalAppUserService.java

@@ -0,0 +1,8 @@
+package com.linkwechat.coal.modules.bdshdb.customer.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.linkwechat.coal.modules.bdshdb.customer.domain.entity.LocalAppUser;
+
+public interface ILocalAppUserService extends IService<LocalAppUser> {
+
+}

linkwe-chinacoal/src/main/resources/mapper/modules/bdshdb/customer/LocalAppUserMapper.xml

@@ -0,0 +1,14 @@
+<?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.linkwechat.coal.modules.bdshdb.customer.mapper.LocalAppUserMapper">
+
+    <select id="selectLocalAppUserById"
+            resultType="com.linkwechat.coal.modules.bdshdb.customer.domain.entity.LocalAppUser">
+        SELECT * FROM local_app_user
+        <where>
+            id= '1897462048076500994'
+        </where>
+    </select>
+</mapper>