| @@ -1,5 +1,5 @@ | |||||
| package com.simple.controller; | package com.simple.controller; | ||||
| import java.text.NumberFormat; | import java.text.NumberFormat; | ||||
| import java.text.SimpleDateFormat; | import java.text.SimpleDateFormat; | ||||
| import java.util.ArrayList; | import java.util.ArrayList; | ||||
| @@ -14,14 +14,18 @@ import org.springframework.web.bind.annotation.GetMapping; | |||||
| import org.springframework.web.bind.annotation.RequestMapping; | import org.springframework.web.bind.annotation.RequestMapping; | ||||
| import org.springframework.web.bind.annotation.RestController; | import org.springframework.web.bind.annotation.RestController; | ||||
| import com.github.pagehelper.PageInfo; | |||||
| import com.simple.common.ResultData; | import com.simple.common.ResultData; | ||||
| import com.simple.domain.dto.WxCuerBasicInfoDto; | import com.simple.domain.dto.WxCuerBasicInfoDto; | ||||
| import com.simple.domain.po.WxCUser; | |||||
| import com.simple.domain.vo.UserStructureVo; | import com.simple.domain.vo.UserStructureVo; | ||||
| import com.simple.enums.EnumAgeInfo; | import com.simple.enums.EnumAgeInfo; | ||||
| import com.simple.service.WxCUserBasicInfoService; | import com.simple.service.WxCUserBasicInfoService; | ||||
| import com.simple.service.WxCUserService; | import com.simple.service.WxCUserService; | ||||
| import io.swagger.annotations.Api; | import io.swagger.annotations.Api; | ||||
| import io.swagger.annotations.ApiImplicitParam; | |||||
| import io.swagger.annotations.ApiImplicitParams; | |||||
| import io.swagger.annotations.ApiOperation; | import io.swagger.annotations.ApiOperation; | ||||
| @RestController | @RestController | ||||
| @@ -154,7 +158,16 @@ public class WxUserStructureController { | |||||
| return new ResultData(map); | return new ResultData(map); | ||||
| } | } | ||||
| @ApiOperation("拓客分析") | |||||
| @GetMapping("/findUserByChannel") | |||||
| @ApiImplicitParams({ | |||||
| @ApiImplicitParam(name="pageNum",value="页数",dataType="int", paramType = "query",required=true), | |||||
| @ApiImplicitParam(name="pageSize",value="每页条数",dataType="int", paramType = "query",required=true)}) | |||||
| private ResultData findUserByChannel(String channelName,Integer pageNum, Integer pageSize) { | |||||
| PageInfo<WxCUser> list = wxCUserService.listByChannel(null, pageNum, pageSize); | |||||
| return new ResultData(list); | |||||
| } | |||||
| private long getCountByAge(EnumAgeInfo a,Calendar c, WxCuerBasicInfoDto dto ) { | private long getCountByAge(EnumAgeInfo a,Calendar c, WxCuerBasicInfoDto dto ) { | ||||
| c.add(Calendar.YEAR, -a.getEnd()); | c.add(Calendar.YEAR, -a.getEnd()); | ||||
| @@ -2,6 +2,8 @@ package com.simple.mapper; | |||||
| import java.util.List; | import java.util.List; | ||||
| import org.apache.ibatis.annotations.Param; | |||||
| import com.simple.common.CommonMapper; | import com.simple.common.CommonMapper; | ||||
| import com.simple.domain.dto.WxCuerBasicInfoDto; | import com.simple.domain.dto.WxCuerBasicInfoDto; | ||||
| import com.simple.domain.po.WxCUser; | import com.simple.domain.po.WxCUser; | ||||
| @@ -16,4 +18,8 @@ public interface WxCUserMapper extends CommonMapper<WxCUser, Long> { | |||||
| WxCUser findByToken(String token); | WxCUser findByToken(String token); | ||||
| long findCount(WxCuerBasicInfoDto dto); | long findCount(WxCuerBasicInfoDto dto); | ||||
| List<WxCUser> listByChannel(@Param("sceneList")List<String> sceneList); | |||||
| } | } | ||||
| @@ -1,5 +1,7 @@ | |||||
| package com.simple.service; | package com.simple.service; | ||||
| import java.util.List; | |||||
| import com.github.pagehelper.PageInfo; | import com.github.pagehelper.PageInfo; | ||||
| import com.simple.domain.dto.WxCuerBasicInfoDto; | import com.simple.domain.dto.WxCuerBasicInfoDto; | ||||
| import com.simple.domain.po.WxCUser; | import com.simple.domain.po.WxCUser; | ||||
| @@ -60,4 +62,15 @@ public interface WxCUserService { | |||||
| * @return | * @return | ||||
| */ | */ | ||||
| long findCount(WxCuerBasicInfoDto dto); | long findCount(WxCuerBasicInfoDto dto); | ||||
| /** | |||||
| * 通过渠道获取会员信息 | |||||
| * @param channel | |||||
| * @param pageIndex | |||||
| * @param pageSize | |||||
| * @return | |||||
| */ | |||||
| PageInfo<WxCUser> listByChannel(List<String> sceneList, Integer pageIndex, Integer pageSize); | |||||
| } | } | ||||
| @@ -66,6 +66,12 @@ public class WxCUserServiceImpl implements WxCUserService { | |||||
| public long findCount(WxCuerBasicInfoDto dto) { | public long findCount(WxCuerBasicInfoDto dto) { | ||||
| return wxCUserMapper.findCount(dto); | return wxCUserMapper.findCount(dto); | ||||
| } | } | ||||
| @Override | |||||
| public PageInfo<WxCUser> listByChannel(List<String> sceneList, Integer pageIndex, Integer pageSize) { | |||||
| return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxCUserMapper.listByChannel(sceneList)); | |||||
| } | |||||
| @@ -196,4 +196,16 @@ | |||||
| and create_date <= #{endTime} | and create_date <= #{endTime} | ||||
| </if> | </if> | ||||
| </select> | </select> | ||||
| <select id ="listByChannel" resultMap="BaseResultMap" parameterType="java.util.List"> | |||||
| select id,nick_name,phone,create_time,scene_address from wx_c_user where 1=1 | |||||
| <if test =" sceneList!= null "> | |||||
| scene_address in | |||||
| <foreach collection="sceneList" index="index" item="scene" open="(" separator="," close=")"> | |||||
| #{scene} | |||||
| </foreach> | |||||
| </if> | |||||
| </select> | |||||
| </mapper> | </mapper> | ||||