Merge branch 'v3' of http://git.ycjcjy.com/zhiyuxing/estateagents into v3

src/main/java/com/huiju/estateagents/center/taUser/controller/TaUserController.java

 import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.entity.TaPersonBuilding;
 import com.huiju.estateagents.entity.TaRole;
+import com.huiju.estateagents.mapper.TaRoleMapper;
 import com.huiju.estateagents.service.ITaPersonBuildingService;
 import com.huiju.estateagents.service.ITaRoleService;
 import org.slf4j.Logger;
     @Autowired
     private ITaUserRoleService taUserRoleService;
 
+    @Autowired
+    private TaRoleMapper taRoleMapper;
+
     /**
      * 分页查询列表
      * @param pageNum
             //获取所有菜单
             List<SysMenu> allMenus = (List<SysMenu>) iTaUserAuthMenuService.getAllMenu(null, null).getData();
             List<SysButtonInMenu> allButtons = (List<SysButtonInMenu>) iTaUserAuthButtonService.getAllButton(null, null).getData();
+
+            allButtons.forEach(e -> {
+                List<TaRole> taRoles = taRoleMapper.getRolesByBtnId(e.getBtnId());
+                e.setRolesList(taRoles);
+            });
+
             userMap.put("taUser", taUser);
             userMap.put("menuList", allMenus);
             userMap.put("buttonList", allButtons);

src/main/java/com/huiju/estateagents/controller/TaChannelController.java

     @RequestMapping(value="/admin/channel/broker",method= RequestMethod.GET)
     public  ResponseBean channelBrokerList(@RequestParam(value="name",required = false) String name,
                                            @RequestParam(value="phone",required = false) String phone,
+                                           @RequestParam(value="phone",required = false) Integer channelId,
                                            @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
                                            HttpServletRequest request){
         Integer orgid = getOrgId(request);
-        ResponseBean taPerson =  taPersonService.channelBrokerList(name,phone,pageNum,pageSize,orgid);
+        ResponseBean taPerson =  taPersonService.channelBrokerList(name,phone,pageNum,pageSize,orgid,channelId);
         return taPerson;
     }
 

src/main/java/com/huiju/estateagents/controller/TaPersonController.java

 import com.huiju.estateagents.common.SMSUtils;
 import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.service.ITaPersonBuildingService;
 import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.service.TaChannelPersonService;
 import com.huiju.estateagents.service.TaChannelService;
     ITaUserService taUserService;
     @Autowired
     SMSUtils smsUtils;
+    @Autowired
+    ITaPersonBuildingService taPersonBuildingService;
 
     /**
      *
             return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
         }
         TaPerson person = taPersons.get(0);
+//        QueryWrapper<TaPersonBuilding>queryWrapper = new QueryWrapper<>();
+//        queryWrapper.eq("user_id",person.getUserId());
+//        TaPersonBuilding personBuilding = taPersonBuildingService.getOne(queryWrapper);
 
         return taPersonService.getCardDetail(openid, id,person.getPersonId());
     }
                 QueryWrapper<TaChannel>channelQueryWrapper = new QueryWrapper<>();
                 channelQueryWrapper.eq("channel_code",channelCode);
                 QueryWrapper<TaChannelPerson>channelPersonQueryWrapper = new QueryWrapper<>();
-                TaChannel channel = taChannelService.getOne(channelQueryWrapper);
-                channelPersonQueryWrapper.eq("person_id",person.getPersonId());
-                channelPersonQueryWrapper.eq("channel_id",channel.getChannelId());
-                channelPersonQueryWrapper.eq("status",CommConstant.STATUS_NORMAL);
-                int count = taChannelPersonService.count(channelPersonQueryWrapper);
-                if(count >0){
-                    return ResponseBean.error("您已绑定过渠道",ResponseBean.ERROR_UNAVAILABLE);
+                List<TaChannel> channel = taChannelService.list(channelQueryWrapper);
+                if(channel.size()>0){
+                    channelPersonQueryWrapper.eq("person_id",person.getPersonId());
+                    channelPersonQueryWrapper.eq("channel_id",channel.get(0).getChannelId());
+                    channelPersonQueryWrapper.eq("status",CommConstant.STATUS_NORMAL);
+                    int count = taChannelPersonService.count(channelPersonQueryWrapper);
+                    if(count >0){
+                        return ResponseBean.error("您已绑定过渠道",ResponseBean.ERROR_UNAVAILABLE);
+                    }
+                    TaChannelPerson channelPerson = new TaChannelPerson();
+                    channelPerson.setCreateDate(LocalDateTime.now());
+                    channelPerson.setPersonId(person.getPersonId());
+                    channelPerson.setChannelId(channel.get(0).getChannelId());
+                    channelPerson.setStatus(CommConstant.STATUS_NORMAL);
+                    taChannelPersonService.save(channelPerson);
+                }else {
+                    responseBean.addError("渠道码错误");
                 }
-                TaChannelPerson channelPerson = new TaChannelPerson();
-                channelPerson.setCreateDate(LocalDateTime.now());
-                channelPerson.setPersonId(person.getPersonId());
-                channelPerson.setChannelId(channel.getChannelId());
-                channelPerson.setStatus(CommConstant.STATUS_NORMAL);
-                taChannelPersonService.save(channelPerson);
+
             }else {
                 QueryWrapper<TaChannelPerson>channelPersonQueryWrapper = new QueryWrapper<>();
                 channelPersonQueryWrapper.eq("person_id",person.getPersonId());
         }
         TaPerson person = taPersons.get(0);
         QueryWrapper<TaPerson>queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("recommend_agent",person.getRecommendAgent());
+        queryWrapper.eq("recommend_agent",person.getPersonId());
         queryWrapper.eq("status",CommConstant.STATUS_NORMAL);
         Page<TaPerson>page = new Page<>();
         page.setPages(pageNum);
         JSONObject resultJson = JSONObject.parseObject(result);
         if (!resultJson.getString("status").equals(CommConstant.STATUS_NORMAL)){
             String adcode =  resultJson.getJSONObject("regeocode").getJSONObject("addressComponent").getString("adcode");
+            String cityName =  resultJson.getJSONObject("regeocode").getJSONObject("addressComponent").getString("city");
             adcode = adcode.substring(0,adcode.length()-2) + "00";
             person.setCity(adcode);
             taPersonService.updateById(person);
-            responseBean.addSuccess("保存城市成功");
+            Map<Object,Object> data = new HashMap<>();
+            data.put("cityName",cityName);
+            data.put("cityCode",adcode);
+            responseBean.addSuccess(data);
             return responseBean;
         }
         responseBean.addError("未找到城市");

src/main/java/com/huiju/estateagents/controller/TaRecommendCustomerController.java

             QueryWrapper<TaRecommendCustomer>queryWrapper = new QueryWrapper<>();
             queryWrapper.eq("realty_consultant",person.getPersonId());
            // queryWrapper.eq("report_recommend_status",CommConstant.REPORTED);
-            queryWrapper.gt("status",CommConstant.CUSTOMER_REPORT);
+            queryWrapper.gt("status",CommConstant.STATUS_UNACCALIMED);
             queryWrapper.orderByDesc("create_date");
             IPage<TaRecommendCustomer>result = taRecommendCustomerService.page(pg,queryWrapper);
             return ResponseBean.success(result);
         ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), ExcelRecommendCustomer.class).registerWriteHandler(new CustomCellWriteHandler()).build();
         // 设置 sheet, 同一个sheet只需要设置一次
         WriteSheet writeSheet = EasyExcel.writerSheet("推荐客户").build();
-        List<ExcelRecommendCustomer> recCustomerExport = null;
         do {
-            recCustomerExport = taRecommendCustomerService.getRecCustomerExport(getOrgId(request), pageCode, pageSize);
+            List<ExcelRecommendCustomer> recCustomerExport = taRecommendCustomerService.getRecCustomerExport(getOrgId(request), pageCode, pageSize);
             excelWriter.write(recCustomerExport, writeSheet);
 
             pageCode ++;
         // 总页数
         Integer pageCount = count % pageSize == 0 ? count / pageSize : (count / pageSize) + 1;
         // 设置读取的class
-        ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), ExcelRecommendCustomer.class).registerWriteHandler(new CustomCellWriteHandler()).build();
+        ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), ReporRecommendCustomer.class).registerWriteHandler(new CustomCellWriteHandler()).build();
         // 设置 sheet, 同一个sheet只需要设置一次
         WriteSheet writeSheet = EasyExcel.writerSheet("报备客户").build();
         List<ReporRecommendCustomer> recCustomerExport = null;
         // 总页数
         Integer pageCount = count % pageSize == 0 ? count / pageSize : (count / pageSize) + 1;
         // 设置读取的class
-        ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), ExcelRecommendCustomer.class).registerWriteHandler(new CustomCellWriteHandler()).build();
+        ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), AgentsRecommendCustomer.class).registerWriteHandler(new CustomCellWriteHandler()).build();
         // 设置 sheet, 同一个sheet只需要设置一次
         WriteSheet writeSheet = EasyExcel.writerSheet("经纪人").build();
         List<AgentsRecommendCustomer> recCustomerExport = null;

src/main/java/com/huiju/estateagents/entity/SysButtonInMenu.java

 
     @TableField(exist = false)
     private List<Integer> roles;
+
+    @TableField(exist = false)
+    private List<TaRole> rolesList;
 }

src/main/java/com/huiju/estateagents/entity/TaChannelPerson.java

 package com.huiju.estateagents.entity;
 
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import java.time.LocalDateTime;
 import java.io.Serializable;
 
     private static final long serialVersionUID = 1L;
 
+    @TableId(value = "channel_person_id", type = IdType.AUTO)
+    private Integer channelPersonId;
+
     /**
      * 人员id
      */

src/main/java/com/huiju/estateagents/interceptor/AccessInterceptor.java

     
     //检验按钮权限
     private boolean checkButtonRole(HttpServletRequest request) {
-        if(StringUtils.isEmpty(request.getHeader("x-action"))){
+        String action = request.getHeader("x-action");
+        if(StringUtils.isEmpty(action)){
             return false;
         }
         //根据路径匹配code 一致继续 否则无权限
         if (null == taButtonUriMap){
             return true;
         }
+    
         
-        if (!taButtonUriMap.getButtonCode().equals(request.getHeader("x-action"))){
+        if (!taButtonUriMap.getButtonCode().equals(action)){
             return false;
         }
         
         //根据code查询按钮权限
         Map map = JWTUtils.getUserIdAndOrgId(request);
         QueryWrapper<SysButtonInMenu> sysButtonInMenuQueryWrapper = new QueryWrapper<>();
-        sysButtonInMenuQueryWrapper.eq("code",request.getHeader("x-action"));
+        sysButtonInMenuQueryWrapper.eq("code",action);
         SysButtonInMenu sysButtonInMenu = sysButtonInMenuService.getOne(sysButtonInMenuQueryWrapper);
         if (null == sysButtonInMenu){
             return false;

src/main/java/com/huiju/estateagents/mapper/TaPersonMapper.java

      * @param phone
      * @return
      */
-    IPage<TaPerson> channelBrokerList(IPage<TaChannel> pg, @Param("name") String name, @Param("phone") String phone,@Param("orgid") Integer orgid);
+    IPage<TaPerson> channelBrokerList(IPage<TaChannel> pg, @Param("name") String name, @Param("phone") String phone,@Param("orgid") Integer orgid,@Param("channelId") Integer channelId);
 
     /**
      * 渠道邀请经纪人

src/main/java/com/huiju/estateagents/mapper/TaRoleMapper.java

 public interface TaRoleMapper extends BaseMapper<TaRole> {
 
     List<TaRole> getRolesByUser(@Param("user") Integer userId);
+
+    /**
+     * 根据按钮ID查询出所有角色
+     * @param btnId
+     * @return
+     */
+    List<TaRole> getRolesByBtnId(@Param("btnId") Integer btnId);
 }

src/main/java/com/huiju/estateagents/service/ITaPersonService.java

      * @param phone
      * @return
      */
-    ResponseBean channelBrokerList(String name, String phone,Integer pageNum,Integer pageSize,Integer orgid);
+    ResponseBean channelBrokerList(String name, String phone,Integer pageNum,Integer pageSize,Integer orgid,Integer channelId);
 
     /**
      * 渠道下邀请经纪人

src/main/java/com/huiju/estateagents/service/impl/TaPersonServiceImpl.java

 
         Map<String, Object> result = new HashMap<>();
         result.put("id", person.getPersonId());
+        result.put("personType",person.getPersonType());
         result.put("name", user.getUserName());
         result.put("company", user.getOrgName());
         result.put("department", user.getDepartment());
     }
 
     @Override
-    public ResponseBean channelBrokerList(String name, String phone,Integer pageNum,Integer pageSize,Integer orgid) {
+    public ResponseBean channelBrokerList(String name, String phone,Integer pageNum,Integer pageSize,Integer orgid,Integer channelId) {
         ResponseBean responseBean = new ResponseBean<>();
         IPage<TaChannel> pg = new Page<>(pageNum, pageSize);
-        IPage<TaPerson> IPage = taPersonMapper.channelBrokerList(pg,name,phone,orgid);
+        IPage<TaPerson> IPage = taPersonMapper.channelBrokerList(pg,name,phone,orgid,channelId);
         List<TaPerson> taPersonList= IPage.getRecords();
         for (TaPerson taPerson:taPersonList){
             QueryWrapper<TaRecommendCustomer> taRecommendCustomerQuery= new QueryWrapper<>();

src/main/resources/mapper/TaBuildingMapper.xml

                 and  TO_DAYS(ta_building.opening_date ) = TO_DAYS(#{startDate})
             </if>
             <if test="buildingStatus != null and buildingStatus != ''">
-                and  ta_building.building_status = #{buildingStatus}
+                and  ta_building.status = #{buildingStatus}
             </if>
             <if test="marketStatus != null and marketStatus != ''">
                 and  ta_building.market_status =#{marketStatus}

src/main/resources/mapper/TaPersonMapper.xml

         rc.`name`,
         rc.phone,
         COUNT(rc.person_id) as recommendCount
-        from ta_person p
+        from ta_channel_person tch
+        left join  ta_person p on  tch.person_id = p.person_id
         LEFT JOIN ta_recommend_customer rc ON p.person_id = rc.person_id and rc.report_recommend_status = 1
         <where>
         <if test="name !=null and name !=''">
         </if>
             and p.person_type = 'estate agent'
             and p.org_id= #{orgid}
+            and tch.channel_id = #{channelId}
         </where>
-        GROUP BY p.person_id
+        GROUP BY tch.person_id
     </select>
 
     <select id="InviteClientsList" resultType="com.huiju.estateagents.entity.TaPerson">

src/main/resources/mapper/TaRecommendCustomerMapper.xml

         </where>
 
         ORDER BY
-        create_date DESC
+        a.create_date DESC
     </select>
 
     <select id="getIndependentAgentsExport" resultType="com.huiju.estateagents.excel.AgentsRecommendCustomer">
         a.nickname as nickname,
         a.phone as phone,
         if(a.gender = '1', '男', if(a.gender = '2', '女', '未知')) as gender,
-        a.personType as personType,
-        if(ifnull(tc.channel_name, '') != '', '渠道经纪人', '独立经纪人')  as channelName
+        if(ifnull(tc.channel_name, '') != '', '渠道经纪人', '独立经纪人') as personType,
+        tc.channel_name  as channelName
         FROM
         ta_person a
         left join ta_channel_person tcp on a.person_id = tcp.person_id

src/main/resources/mapper/TaRoleMapper.xml

         WHERE
             s.user_id = #{user}
     </select>
+
+    <select id="getRolesByBtnId" resultType="com.huiju.estateagents.entity.TaRole">
+        SELECT
+            t.*
+        FROM
+        ta_role_button trb left JOIN  ta_role t
+        ON trb.role_id = t.role_id
+        WHERE
+            trb.btn_id = #{btnId}
+    </select>
 </mapper>