diff --git a/wisenergy-mapper/src/main/java/cn/wisenergy/mapper/UsersMapper.java b/wisenergy-mapper/src/main/java/cn/wisenergy/mapper/UsersMapper.java index 451e5ccf8830df909ca069664328a2636d2a9691..21b5fe4a8bf7b8225d6e29d34c37fed047c0e247 100644 --- a/wisenergy-mapper/src/main/java/cn/wisenergy/mapper/UsersMapper.java +++ b/wisenergy-mapper/src/main/java/cn/wisenergy/mapper/UsersMapper.java @@ -6,8 +6,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; -import java.util.List; -import java.util.Map; /** * @author 86187 @@ -41,221 +39,4 @@ public interface UsersMapper extends BaseMapper<Users> { */ int delById(@Param("id") Integer id); - List<Users> getList(); - - /** - * èŽ·å–æ‰€æœ‰çš„éžæ™®é€šç”¨æˆ·åˆ—表 - * - * @return éžæ™®é€šç”¨æˆ·åˆ—表 - */ - List<Users> findAllNotZeroUser(); - - Users findByName(String name); - - String findPswByName(String UserName); - - void save(Users users); - - /** - * 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Users getUserById(@Param("id") Long id); - - /** - * 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param userId 用户id - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Users getByUserId(@Param("userId") String userId); - - /** - * 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param userId 用户id - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Integer ByUserId(@Param("userId") String userId); - - /** - * 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Integer beInvitedCode1(@Param("beInvitedCode") String beInvitedCode); - - /** - * 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param beInvitedCode 用户被邀请ç - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Users getByBeInvitedCode(@Param("beInvitedCode") String beInvitedCode); - - /** - * 获å–é»„é‡‘æ ‘ä»¥ä¸Šä¼šå‘˜ç”¨æˆ· - * - * @return - */ - List<Users> getAllGoldUser(); - - /** - * 查询用户 - * - * @param param - * @return - */ - public List<Users> getUsersListByMap(Map<String, Object> param); - - //æ ¹æ®æ‰‹æœºå·æŸ¥è¯¢ç”¨æˆ·Integer - Users queryUsersByPhone(@Param("userId") String userId); - - //æ ¹æ®ç”¨æˆ·çš„æŽ¨èäººé‚€è¯·ç æ¯”对推è人的本人邀请ç ,查询推è人的用户ID - Integer inviteCodeBeInvitedCode(@Param("beInvitedCode") Integer beInvitedCode); - - /** - * 用户注册 - * - * @param userId - * @param inviteCode - * @param beInvitedCode - * @param userLevel - */ - Integer insertbyint(@Param("userId") String userId, @Param("inviteCode") String inviteCode, @Param("beInvitedCode") String beInvitedCode, @Param("userLevel") Integer userLevel, @Param("headImage") String headImage, @Param("frozen") Integer frozen); - - Integer save(@Param("userId") String userId, @Param("beInvitedCode") String beInvitedCode); - - Users edit1(int userLevel, String intiveCode, String userId); - - Integer getuserIdById(@Param("userId") String userId); - - Integer getById(@Param("userId") String userId); - - String BYQMById(@Param("userId") String userId); - - /** - * æ ¹æ®userid获å–èŽ·å–æ‰€æœ‰çš„直接推è人 - * - * @param inviteCode 用户本人的邀请ç - * @return 所有填写æ¤äººçš„邀请ç 的用户 - */ - List<Users> getByInviteCode(@Param("inviteCode") String inviteCode, @Param("userLevel") int userLevel); - - /** - * 通过邀请ç ,获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param inviteCode 邀请ç - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Users queryByInviteCode(@Param("inviteCode") String inviteCode); - - /** - * 通过用户ç‰çº§ï¼ŒèŽ·å–该ç‰çº§ç”¨æˆ·åˆ—表 - * - * @param userLevel 用户ç‰çº§ - * @return ç‰çº§ç”¨æˆ·åˆ—表 - */ - List<Users> getByLevel(@Param("userLevel") Integer userLevel); - - /** - * @param - * @return - */ - Users biInvitedCode1(@Param("inviteCode") String inviteCode); - - - /** - * ç”¨æˆ·é‚€è¯·ç æŸ¥è¯¢ç”¨æˆ·æ•°æ® - * - * @param inviteCode - * @return - */ - Users InvitedCode2(@Param("inviteCode") String inviteCode); - - /** - * æ ¹æ®ç”¨æˆ·çš„æŽ¨èäººé‚€è¯·ç æŸ¥è¯¢ä¸Šçº§ç”¨æˆ·çš„id - * - * @param beInvitedCode - * @return - */ - String getUserByIntiveCode(String beInvitedCode); - - String getUserIdByIntiveCode(String outerUserId); - - /** - * èŽ·å–æ‰€æœ‰çš„空投用户 - * ä¸”æ³¨å†Œæ—¶é—´ä¸ºä¸€æœˆä¹‹å‰ - * - * @return - */ - List<Users> getAerialDeliveryUserBeforOneMonth(@Param("before") String before, - @Param("now") String now); - - /** - * éšæœºèŽ·å–一æ¡å°äºŽå½“å‰id的用户 å³ï¼š 比当å‰ç”¨æˆ·æ—©æ³¨å†Œçš„用户 - * - * @param id - * @return - */ - Users randOneGetUserByUserId(Integer id); - - /** - * æ ¹æ®é‚€è¯·ç èŽ·å–æ‰€æœ‰çš„下级用户 - * - * @param userId - * @return - */ - List<Users> getListByIntvitedCode(String userId); - - /** - * æ ¹æ®å½“å‰ç”¨æˆ·çš„æŽ¨è人邀请ç èŽ·å–æŽ¨è人的用户信æ¯(上级用户信æ¯) - * - * @param beInvitedCode - * @return - */ - Users getuserByBeInvitedCode(String beInvitedCode); - - /** - * 获å–在团队ä¸å¤„于åŒä¸€ä½ç½®çš„ç”¨æˆ·é›†åˆ - * - * @param beInvitedCode - * @return - */ - List<Users> getListUserByBeInvitedCode(String beInvitedCode); - - /** - * 通过邀请ç 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param inviteCode - * @return - */ - Users getUserByInviteCode(String inviteCode); - - /** - * æ ¹æ®ç”¨æˆ·çš„userid查询用户对象 - * - * @param userId - * @return - */ - Users getUserByUserId(String userId); - - /** - * åˆ†é¡µæŸ¥è¯¢æ‰€æœ‰ç”¨æˆ·ä¿¡æ¯ - * - * @param map - * @return - */ - List<Users> getUserList(Map<String, Object> map); - - /** - * 统计用户总记录数 - * - * @param map å…¥å‚ - * @return 结果 - */ - int countUser(Map<String, Object> map); - } diff --git a/wisenergy-mapper/src/main/resources/mapper/UsersMapper.xml b/wisenergy-mapper/src/main/resources/mapper/UsersMapper.xml index d6df09ba9e4206d28a1106be2381d25e98d2d511..b9ef019e4453955484a921ccb07c41eee72fee4f 100644 --- a/wisenergy-mapper/src/main/resources/mapper/UsersMapper.xml +++ b/wisenergy-mapper/src/main/resources/mapper/UsersMapper.xml @@ -4,24 +4,41 @@ <mapper namespace="cn.wisenergy.mapper.UsersMapper"> <resultMap id="userMap" type="cn.wisenergy.model.app.Users"> <id column="id" property="id"/> - <result column="user_id" property="userId"/> + <result column="parent_id" property="parentId"/> + <result column="path" property="path"/> + <result column="rank" property="rank"/> + <result column="country_code" property="countryCode"/> + <result column="phone" property="phone"/> <result column="password" property="password"/> - <result column="head_image" property="headImage"/> - <result column="user_level" property="userLevel"/> - <result column="cross_border_line" property="crossBorderLine"/> - <result column="id_card_number" property="idCardNumber"/> - <result column="fans_nickname" property="fansNickname"/> - <result column="fans_id" property="fansId"/> - <result column="invite_code" property="inviteCode"/> - <result column="be_invited_code" property="beInvitedCode"/> - <result column="customer_service_id" property="customerServiceId"/> - <result column="frozen" property="frozen"/> - <result column="create_time" property="createTime"/> - <result column="update_time" property="updateTime"/> + <result column="fund_pass" property="fundPass"/> + <result column="nickname" property="nickname"/> + <result column="avatar" property="avatar"/> + <result column="invited_code" property="invitedCode"/> + <result column="token" property="token"/> + <result column="hash" property="hash"/> + <result column="level" property="level"/> + <result column="now_level" property="nowLevel"/> + <result column="grade" property="grade"/> + <result column="status" property="status"/> + <result column="fund_status" property="fundStatus"/> + <result column="active" property="active"/> + <result column="note" property="note"/> + <result column="reg_time" property="regTime"/> + <result column="reg_ip" property="regIp"/> + <result column="reg_address" property="regAddress"/> + <result column="did" property="did"/> + <result column="read_time" property="readTime"/> + <result column="start_at" property="startAt"/> + <result column="expire_at" property="expireAt"/> + <result column="proxy" property="proxy"/> + <result column="is_work" property="isWork"/> + <result column="work_at" property="workAt"/> + <result column="created_at" property="createdAt"/> + <result column="updated_at" property="updatedAt"/> </resultMap> <sql id="table"> - user_info + users </sql> <sql id="cols_all"> @@ -30,45 +47,83 @@ </sql> <sql id="cols_exclude_id"> - user_id,password,head_image,user_level,cross_border_line,id_card_number,fans_nickname,fans_id, invite_code, - be_invited_code,customer_service_id,create_time,update_time + parent_id,path,rank,country_code,phone,password,fund_pass,nickname, avatar,invited_code,token,hash,`level`,now_level, + grade,status,fund_status,active,note,reg_time,reg_ip,reg_address,did,read_time,start_at,expire_at,proxy,is_work, + work_at,created_at,updated_at </sql> <sql id="vals"> - #{userId},#{password},#{headImage},#{userLevel},#{crossBorderLine},#{idCardNumber},#{fansNickname},#{fansId},#{inviteCode}, - #{beInvitedCode},#{customerServiceId},now(),now() + #{parentId},#{path},#{rank},#{countryCode},#{phone},#{password},#{fundPass},#{nickname},#{avatar},#{inviteCode}, + #{token},#{hash},#{level},#{nowLevel},#{grade},#{status},#{fundStatus},#{active},#{note},#{regTime},#{regIp}, + #{regAddress},#{did},#{readTime},#{startAt},#{expireAt},#{proxy},#{isWork},#{workAt},now(),now() </sql> <sql id="updateCondition"> - <if test="userId != null">user_id = #{userId},</if> - <if test="password != null">password =#{password},</if> - <if test="headImage != null">head_image =#{headImage},</if> - <if test="userLevel != null">user_level =#{userLevel},</if> - <if test="crossBorderLine != null">cross_border_line =#{crossBorderLine},</if> - <if test="idCardNumber != null">id_card_number = #{idCardNumber},</if> - <if test="fansNickname != null">fans_nickname =#{fansNickname},</if> - <if test="fansId != null">fans_id =#{fansId},</if> - <if test="inviteCode != null">invite_code =#{inviteCode},</if> - <if test="beInvitedCode != null">be_invited_code = #{beInvitedCode},</if> - <if test="customerServiceId != null">customer_service_id = #{customerServiceId},</if> + <if test="parentId != null">parent_id = #{parentId},</if> + <if test="path != null">path =#{path},</if> + <if test="rank != null">rank =#{rank},</if> + <if test="countryCode != null">country_code =#{countryCode},</if> + <if test="phone != null">phone =#{phone},</if> + <if test="password != null">password = #{password},</if> + <if test="fundPass != null">fund_pass =#{fundPass},</if> + <if test="nickname != null">nickname =#{nickname},</if> + <if test="avatar != null">avatar =#{avatar},</if> + <if test="inviteCode != null">invited_code = #{inviteCode},</if> + <if test="token != null">token = #{token},</if> + <if test="hash != null">hash =#{hash},</if> + <if test="level != null">`level` =#{level},</if> + <if test="nowLevel != null">now_level =#{nowLevel},</if> + <if test="grade != null">grade =#{grade},</if> + <if test="status != null">status = #{status},</if> + <if test="fundStatus != null">fund_status =#{fundStatus},</if> + <if test="active != null">active =#{active},</if> + <if test="note != null">note =#{note},</if> + <if test="regTime != null">reg_time = #{regTime},</if> + <if test="regIp != null">reg_ip = #{regIp},</if> + <if test="regAddress != null">reg_address =#{regAddress},</if> + <if test="did != null">did = #{did},</if> + <if test="readTime != null">read_time =#{readTime},</if> + <if test="startAt != null">start_at =#{startAt},</if> + <if test="expireAt != null">expire_at =#{expireAt},</if> + <if test="proxy != null">proxy = #{proxy},</if> + <if test="isWork != null">is_work = #{isWork},</if> + <if test="workAt != null">work_at = #{workAt},</if> update_time =now() </sql> <sql id="criteria"> <if test="id != null">id = #{id}</if> - <if test="userId != null">and user_id = #{userId}</if> - <if test="password != null">and password =#{password}</if> - <if test="headImage != null">and head_image =#{headImage}</if> - <if test="userLevel != null">and user_level =#{userLevel}</if> - <if test="crossBorderLine != null">and cross_border_line =#{crossBorderLine}</if> - <if test="idCardNumber != null">and id_card_number = #{idCardNumber}</if> - <if test="fansNickname != null">and fans_nickname =#{fansNickname}</if> - <if test="fansId != null">and fans_id =#{fansId}</if> - <if test="inviteCode != null">and invite_code =#{inviteCode}</if> - <if test="beInvitedCode != null">and be_invited_code = #{beInvitedCode}</if> - <if test="customerServiceId != null">and customer_service_id = #{customerServiceId}</if> - <if test="createTime != null">and create_time >= #{createTime}</if> - <if test="updateTime != null">and #{updateTime} >= update_time</if> + <if test="parentId != null">and parent_id = #{parentId}</if> + <if test="path != null">and path =#{path}</if> + <if test="rank != null">and rank =#{rank}</if> + <if test="countryCode != null">and country_code =#{countryCode}</if> + <if test="phone != null">and phone =#{phone}</if> + <if test="password != null">and password = #{password}</if> + <if test="fundPass != null">and fund_pass =#{fundPass}</if> + <if test="nickname != null">and nickname =#{nickname}</if> + <if test="avatar != null">and avatar =#{avatar}</if> + <if test="inviteCode != null">and invited_code = #{inviteCode}</if> + <if test="token != null">and token = #{token}</if> + <if test="hash != null">and hash =#{hash}</if> + <if test="level != null">and `level` =#{level}</if> + <if test="nowLevel != null">and now_level =#{nowLevel}</if> + <if test="grade != null">and grade =#{grade}</if> + <if test="status != null">and status = #{status}</if> + <if test="fundStatus != null">and fund_status =#{fundStatus}</if> + <if test="active != null">and active =#{active}</if> + <if test="note != null">and note =#{note}</if> + <if test="regTime != null">and reg_time = #{regTime}</if> + <if test="regIp != null">and reg_ip = #{regIp}</if> + <if test="regAddress != null">and reg_address =#{regAddress}</if> + <if test="did != null">and did = #{did}</if> + <if test="readTime != null">and read_time =#{readTime}</if> + <if test="startAt != null">and start_at =#{startAt}</if> + <if test="expireAt != null">and expire_at =#{expireAt}</if> + <if test="proxy != null">and proxy = #{proxy}</if> + <if test="isWork != null">and is_work = #{isWork}</if> + <if test="workAt != null">and work_at = #{workAt}</if> + <if test="createdAt != null">and created_at >= #{createdAt}</if> + <if test="updatedAt != null">and #{updatedAt} >= updated_at</if> </sql> @@ -98,367 +153,4 @@ where id = #{id} </delete> - <select id="getList" resultMap="userMap" parameterType="map"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - be_invited_code=1 - </where> - order by create_time desc - </select> - - <select id="getUserById" resultType="cn.wisenergy.model.app.Users" parameterType="java.lang.Long"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - id=#{id} - </where> - </select> - - <select id="getByUserId" resultType="cn.wisenergy.model.app.Users" parameterType="string"> - select - id,user_id,password,head_image,user_level,cross_border_line,id_card_number,fans_nickname,fans_id, invite_code, - be_invited_code,customer_service_id,create_time,update_time - from - user_info - <where> - user_id=#{userId} - </where> - </select> - <select id="getById" resultType="java.lang.Integer" parameterType="string"> - select - userId - from - user_info - <where> - user_id=#{userId} - </where> - </select> - <select id="ByUserId" resultType="java.lang.Integer"> - select - id - from - user_info - <where> - user_id=#{userId} - </where> - </select> - - <select id="findAllNotZeroUser" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - user_level !=0 - </where> - </select> - - <!--查询用户--> - <select id="findByName" resultType="cn.wisenergy.model.app.Users"> - select * from User where user_id = #{userId} - </select> - - <!--查询密ç --> - <select id="findPswByName" resultType="String"> - select password from users where user_id = #{userId} - </select> - - <select id="getByBeInvitedCode" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - invite_code = #{beInvitedCode} - </where> - </select> - - <select id="getAllGoldUser" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - user_level >3 - </where> - </select> - - <!--用户注册--> - <insert id="insertbyint"> - insert into user_info(user_id,invite_code,be_invited_code,user_level,head_image,frozen) value - (#{userId},#{inviteCode},#{beInvitedCode},#{userLevel},#{headImage},#{frozen}) - </insert> - <insert id="save"> - insert into user_info(user_id,be_invited_code) value (#{userId},#{beInvitedCode}) - </insert> - - <select id="queryUsersByPhone" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="vals"/> - from - <include refid="table"/> - <where> - user_id=#{userId} - </where> - </select> - <!--æ ¹æ®ç”¨æˆ·çš„æŽ¨èäººé‚€è¯·ç æ¯”对推è人的本人邀请ç ,查询推è人的用户ID--> - <select id="inviteCodeBeInvitedCode" resultType="java.lang.Integer"> - select - user_id - from - <include refid="table"/> - <where> - invite_code=#{beInvitedCode} - </where> - </select> - <!--æ ¹æ®ç”¨æˆ·çš„æŽ¨èäººé‚€è¯·ç æ¯”对推è人的本人邀请ç ,查询推è人的用户ID--> - <select id="beInvitedCode1" resultType="java.lang.Integer"> - select - id - from - <include refid="table"/> - <where> - invite_code=#{beInvitedCode} - </where> - </select> - - <select id="InvitedCode2" resultType="cn.wisenergy.model.app.Users" parameterType="string"> - select - * - from - user_info - <where> - invite_code=#{inviteCode} - </where> - </select> - - <select id="getuserIdById" resultType="java.lang.Integer"> - select - id - from - user_info - <where> - user_id=#{userId} - </where> - </select> - <select id="BYQMById" resultType="String"> - select - be_invited_code - from - <include refid="table"/> - <where> - user_id=#{userId} - </where> - </select> - <update id="edit1"> - update - user_info - <set> - <if test="userLevel != null">user_level =#{userLevel},</if> - <if test="inviteCode != null">invite_code =#{inviteCode},</if> - create_time =now(), - update_time =now() - </set> - <where> - user_id = #{userId} - </where> - </update> - - - <!--åˆ†é¡µæŸ¥è¯¢æ‰€æœ‰ç”¨æˆ·ä¿¡æ¯ --> - <select id="getUsersListByMap" resultType="cn.wisenergy.model.app.Users" parameterType="java.util.Map"> - select id as id, - user_id as userId, - password as password, - user_level as userLevel, - cross_border_line as crossBorderLine, - id_card_number as idCardNumber, - fans_nickname as fansNickname, - invite_code as inviteCode, - be_invited_code as beInvitedCode, - create_time as createTime, - update_time as updateTime - from user_info - <trim prefix="where" prefixOverrides="and | or"> - <if test="id != null"> - and id=#{id} - </if> - <if test="account != null and account!=''"> - and userId=#{userId} - </if> - <if test="password != null and password!=''"> - and password=#{password} - </if> - <if test="salt != null and salt!=''"> - and userLevel=#{userLevel} - </if> - - <if test="sex != null"> - and idCardNumber=#{idCardNumber} - </if> - <if test="isAuthentication != null"> - and fansNickname=#{fansNickname} - </if> - <if test="name != null and name!=''"> - and inviteCode=#{inviteCode} - </if> - <if test="cardNo != null and cardNo!=''"> - and beInvitedCode=#{beInvitedCode} - </if> - <if test="null!=creatdTime"> - and creatdTime=#{creatdTime} - </if> - <if test="null!=updatedTime"> - and updatedTime=#{updatedTime} - </if> - </trim> - <if test="beginPos != null and pageSize != null "> - limit #{beginPos},#{pageSize} - </if> - </select> - - <!-- 获å–当å‰ç”¨æˆ·çš„æ‰€æœ‰ç›´æŽ¥æŽ¨è人--> - <select id="getByInviteCode" resultType="cn.wisenergy.model.app.Users" parameterType="string"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - be_invited_code=#{inviteCode} - and user_level=#{userLevel} - </where> - </select> - - <select id="queryByInviteCode" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - invite_code=#{inviteCode} - </where> - </select> - - <select id="getByLevel" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - user_level=#{userLevel} - </where> - </select> - - <select id="getUserByIntiveCode" parameterType="string" resultType="string"> - select user_id - from - <include refid="table"/> - where - invite_code = #{beInvitedCode} - </select> - - <select id="getUserIdByIntiveCode" resultType="string" parameterType="string"> - select user_id - from - <include refid="table"/> - where - invite_code = #{outerUserId} - </select> - - <select id="getAerialDeliveryUserBeforOneMonth" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - where - be_invited_code = '1' - and DATE_FORMAT(create_time,'%Y-%m-%d') - BETWEEN #{before} AND #{now} - </select> - - <select id="randOneGetUserByUserId" resultType="cn.wisenergy.model.app.Users"> - SELECT - <include refid="cols_all"/> - FROM - <include refid="table"/> - WHERE id < #{id} - ORDER BY RAND() LIMIT 1 - </select> - - <select id="getListByIntvitedCode" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - where be_invited_code = #{intiveCode} - </select> - - <select id="getuserByBeInvitedCode" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - where - invite_code = #{be_invited_code} - </select> - - <select id="getListUserByBeInvitedCode" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - where - be_invited_code = #{be_invited_code} - </select> - - <select id="getUserByInviteCode" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - where - invite_code = #{inviteCode} - </select> - - <select id="getUserByUserId" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - where - user_id = #{userId} - </select> - - - <select id="getUserList" resultType="cn.wisenergy.model.app.Users"> - select - <include refid="cols_all"/> - from - <include refid="table"/> - <where> - 1=1 - <if test="userId != null and userId != ''"> - and user_id = #{userId} - </if> - <if test="queryTime != null and queryTime != ''"> - and (YEAR(create_time) = YEAR(#{queryTime}) - AND MONTH(create_time) =MONTH(#{queryTime}) - AND DAY(create_time)=DAY(#{queryTime})) - </if> - </where> - order by create_time desc - limit #{startNum},#{endNum} - </select> - - <select id="countUser" resultType="java.lang.Integer"> - select count(1) - from - user_info - </select> - </mapper> diff --git a/wisenergy-model/src/main/java/cn/wisenergy/model/app/UserRecharge.java b/wisenergy-model/src/main/java/cn/wisenergy/model/app/UserRecharge.java new file mode 100644 index 0000000000000000000000000000000000000000..69486a173ea87934f98c722552bc00b92bae1634 --- /dev/null +++ b/wisenergy-model/src/main/java/cn/wisenergy/model/app/UserRecharge.java @@ -0,0 +1,21 @@ +package cn.wisenergy.model.app; + +import lombok.Data; + +/** + * @author 86187 + */ +@Data +public class UserRecharge { + private Long id; + + /** + * 会员id + */ + private Integer userId; + + /** + * å¸ç§id + */ + private Integer currencyId; +} diff --git a/wisenergy-service/src/main/java/cn/wisenergy/service/app/UserService.java b/wisenergy-service/src/main/java/cn/wisenergy/service/app/UserService.java index e32e85dad9a887de3a66be3bf301efd8983ce98a..3023d57645b9159d08277e3e55260c17e34f0029 100644 --- a/wisenergy-service/src/main/java/cn/wisenergy/service/app/UserService.java +++ b/wisenergy-service/src/main/java/cn/wisenergy/service/app/UserService.java @@ -19,20 +19,9 @@ public interface UserService { * @param userId 用户id * @return ç”¨æˆ·ä¿¡æ¯ */ - Users getById(String userId); + Users getById(Integer userId); - R<Integer> getById1(String userId); - - Users getUserById(Long id); - - /** - * 获å–ç”¨æˆ·ä¿¡æ¯ - * - * @param userId 用户id - * @return ç”¨æˆ·ä¿¡æ¯ - */ - Users getByUserId(String userId); /** * æ ¹æ®æ‰‹æœºå·æŸ¥è¯¢ç”¨æˆ· @@ -44,23 +33,4 @@ public interface UserService { */ Users queryUsersByOpenId(String openId); - /** - * 用户登出 - * - * @param token - * @return - */ - int logout(String token); - - Integer getUserIdById(String userId); - - /** - * è®¾ç½®ç”¨æˆ·å¤´åƒ - * - * @param userId 用户id - * @param headImage 头åƒå›¾ç‰‡åœ°å€ - * @return true or false - */ - R<Boolean> setHeadImage(String userId, String headImage); - } diff --git a/wisenergy-service/src/main/java/cn/wisenergy/service/app/impl/UserServiceImpl.java b/wisenergy-service/src/main/java/cn/wisenergy/service/app/impl/UserServiceImpl.java index 477159807a5a3dc192fd0b1d5a6519288fee36f9..1b7fe2440e82e7e10e7c7240718291600e966d83 100644 --- a/wisenergy-service/src/main/java/cn/wisenergy/service/app/impl/UserServiceImpl.java +++ b/wisenergy-service/src/main/java/cn/wisenergy/service/app/impl/UserServiceImpl.java @@ -1,12 +1,10 @@ package cn.wisenergy.service.app.impl; -import cn.wisenergy.common.utils.*; import cn.wisenergy.mapper.*; import cn.wisenergy.model.app.*; import cn.wisenergy.service.app.UserService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.extern.slf4j.Slf4j; -import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -23,91 +21,18 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, Users> implements @Autowired private UsersMapper usersMapper; - @Autowired - private RedisUtils redisUtils; - - private static final String INVITE_CODE = "1"; - @Override - public Users getById(String userId) { - return usersMapper.getByUserId(userId); - } - - @Override - public R<Integer> getById1(String userId) { - - return R.ok(usersMapper.ByUserId(userId)); - } - - @Override - public Users getUserById(Long id) { - return this.usersMapper.getUserById(id); - } - - @Override - public Users getByUserId(String userId) { - - return usersMapper.getByUserId(userId); + public Users getById(Integer userId) { + return null; } - @Override public Users queryUsersByPhone(String userId) { - //查询数æ®åº“,看看是å¦å˜åœ¨è¯¥ç”¨æˆ· - return usersMapper.getByUserId(userId); - } - - @Override - public Users queryUsersByOpenId(String id) { return null; } - @Override - public Integer getUserIdById(String userId) { + public Users queryUsersByOpenId(String id) { return null; } - - - @Override - public R<Boolean> setHeadImage(String userId, String headImage) { - log.info("shop-mall[]UserServiceImpl[]setHeadImage[]input.param.userId,headImage:" + userId, headImage); - if (StringUtils.isBlank(userId) || StringUtils.isBlank(headImage)) { - return R.error("å…¥å‚ä¸èƒ½ä¸ºç©º!"); - } - - //获å–ç”¨æˆ·ä¿¡æ¯ - Users users = usersMapper.getByUserId(userId); - if (null == users) { - return R.error("用户信æ¯ä¸å˜åœ¨!"); - } - - //æ·»åŠ å¤´åƒ - users.setHeadImage(headImage); - int count = usersMapper.edit(users); - if (count == 0) { - return R.error("设置头åƒå¤±è´¥!"); - } - return R.ok(0, true); - } - - /** - * 用户登出 - * - * @param token - * @return - */ - @Override - public int logout(String token) { - int succ = 0; - String key = RedisKeyUtils.formatKeyWithPrefix(Constants.Redis.PREFIX_TOKEN, token); - redisUtils.delete(key); - if (redisUtils.getValue(key) == null) { - succ = 1; - } - return succ; - } - - - } diff --git a/wisenergy-web-admin/src/main/java/cn/wisenergy/Application.java b/wisenergy-web-admin/src/main/java/cn/wisenergy/Application.java index bf80ba2759f064c5f16d4f1ecf08bab12142ca4c..659b6ae673fa8e163b719122f5a104157ab9c487 100644 --- a/wisenergy-web-admin/src/main/java/cn/wisenergy/Application.java +++ b/wisenergy-web-admin/src/main/java/cn/wisenergy/Application.java @@ -10,6 +10,7 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2; /** * é…ç½®nettyå¯åЍ + * @author 86187 */ @EnableCaching @SpringBootApplication(exclude = {MultipartAutoConfiguration.class}) diff --git a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/admin/controller/app/UserController.java b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/admin/controller/app/UserController.java index 5672739cb06f728449f96d48c0866c1672409722..ff87d457aeb92d86ec9204a1d10138b6b3cdcf58 100644 --- a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/admin/controller/app/UserController.java +++ b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/admin/controller/app/UserController.java @@ -41,9 +41,9 @@ public class UserController extends BaseController { private RedisUtils redisUtils; @ApiOperation(value = "获å–用户信æ¯", notes = "获å–用户信æ¯", httpMethod = "GET") - @ApiImplicitParam(name = "userId", value = "用户id", dataType = "String") + @ApiImplicitParam(name = "userId", value = "用户id", dataType = "int") @GetMapping("/user/getByUserId") - public Users getByUserId(String userId) { + public Users getByUserId(Integer userId) { return userService.getById(userId); } @@ -54,13 +54,13 @@ public class UserController extends BaseController { */ @ApiOperation(value = "获å–token接å£", notes = "获å–token接å£", httpMethod = "POST") @PostMapping(value = "/user/login") - public R<String> login(String id) { + public R<String> login(Integer id) { if (null == id) { return R.error("å…¥å‚为空!"); } //ç”¨æˆ·ä¿¡æ¯ - Users users = userService.getByUserId(id); + Users users = userService.getById(id); // 创建token String token = jwtUtil.generateToken(users); @@ -68,20 +68,4 @@ public class UserController extends BaseController { redisTemplate.opsForValue().set(RedisConsts.JWT_ACCESS_TOKEN + token, token); return R.ok(token); } - - - @ApiOperation(value = "设置头åƒ", notes = "设置头åƒ", httpMethod = "POST") - @ApiImplicitParams({ - @ApiImplicitParam(name = "userId", value = "用户id", dataType = "String"), - @ApiImplicitParam(name = "headImage", value = "头åƒUrl", dataType = "String") - }) - @PostMapping("/user/setHeadImage") - public R<Boolean> setHeadImage(String userId, String headImage) { - log.info("shop-mall[]UserController[]setHeadImage[]input.param.userId,headImage:" + userId, headImage); - if (StringUtils.isBlank(userId) || StringUtils.isBlank(headImage)) { - return R.error("å…¥å‚ä¸èƒ½ä¸ºç©º!"); - } - - return userService.setHeadImage(userId, headImage); - } } diff --git a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/DataAuthAspect.java b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/DataAuthAspect.java deleted file mode 100644 index adcf6b5ceb067fcdb1ad4d007e2c43bd0f5f1e2f..0000000000000000000000000000000000000000 --- a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/DataAuthAspect.java +++ /dev/null @@ -1,69 +0,0 @@ -package cn.wisenergy.web.aspect; - -import cn.wisenergy.common.annotation.DataAuth; -import cn.wisenergy.common.constant.CommonConstants; -import cn.wisenergy.common.enums.RespCodeEnum; -import cn.wisenergy.common.utils.exception.Result; -import org.apache.commons.lang3.StringUtils; -import org.apache.shiro.SecurityUtils; -import org.aspectj.lang.ProceedingJoinPoint; -import org.aspectj.lang.annotation.Around; -import org.aspectj.lang.annotation.Aspect; -import org.aspectj.lang.annotation.Pointcut; -import org.aspectj.lang.reflect.MethodSignature; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; - -import java.lang.reflect.Method; -import java.util.Map; - -/** - * æ•°æ®æƒé™ï¼Œåˆ‡é¢å¤„ç†ç±» - */ -@Aspect -@Component -public class DataAuthAspect { - @Autowired - AccountService sysUserService; - - @Pointcut("@annotation(cn.wisenergy.common.annotation.DataAuth)") - public void dataPointCut() { - } - - @Around("dataPointCut()") - public Object around(ProceedingJoinPoint pjp) throws Throwable { - MethodSignature signature = (MethodSignature) pjp.getSignature(); - Method method = signature.getMethod(); - // èŽ·å–æ–¹æ³•上的注解 - DataAuth dataAuth = method.getAnnotation(DataAuth.class); - if (dataAuth != null) { - // èŽ·å–æ³¨è§£å€¼ - String mapKey = dataAuth.value(); - // 获å–è¯·æ±‚å‚æ•° - Object[] args = pjp.getArgs(); - for (Object obj : args) { - if (obj instanceof Map) { - Map<String, Object> map = (Map<String, Object>) obj; - // 获å–当å‰ç”¨æˆ· - AccountInfo sysUser = (AccountInfo) SecurityUtils.getSubject().getPrincipal(); - if (sysUser != null) { - // 超级管ç†å‘˜è¿”å›žå…¨é‡æ•°æ® - if (!StringUtils.equals(sysUser.getId().toString(), CommonConstants.SUPER_ADMIN)) { - // æŸ¥è¯¢ç”¨æˆ·çš„æ•°æ®æƒé™ä¿¡æ¯ï¼Œå¦‚æžœå˜åœ¨æ•°æ®æƒé™é›†åˆï¼Œå°†é›†åˆå˜å…¥è¯·æ±‚傿•°mapä¸ -// Set<String> dataAuthList = sysUserService.getUserDataAuth(sysUser); -// if (dataAuthList != null && !dataAuthList.isEmpty()) { -// map.put(mapKey, dataAuthList); -// } - } - return pjp.proceed(); - } - } - } - } - Result result = new Result(); - result.setResult(Result.RESULT_FLG.FAIL.getValue()); - result.setErrorCode(RespCodeEnum.DATA_AUTH_UNAUTHORIZED.getCode()); - result.setErrorMsg(RespCodeEnum.DATA_AUTH_UNAUTHORIZED.getMsg()); - return result; - } -} diff --git a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/SysLogAspect.java b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/SysLogAspect.java deleted file mode 100644 index e5e5b44b3f01ec351b6150f89a882563150f60fd..0000000000000000000000000000000000000000 --- a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/SysLogAspect.java +++ /dev/null @@ -1,93 +0,0 @@ -package cn.wisenergy.web.aspect; - -import cn.wisenergy.common.utils.exception.Result; -import cn.wisenergy.common.utils.ip.IpUtils; -import com.alibaba.fastjson.JSON; -import org.apache.shiro.SecurityUtils; -import org.aspectj.lang.ProceedingJoinPoint; -import org.aspectj.lang.annotation.Around; -import org.aspectj.lang.annotation.Aspect; -import org.aspectj.lang.annotation.Pointcut; -import org.aspectj.lang.reflect.MethodSignature; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; -import org.springframework.web.context.request.RequestContextHolder; -import org.springframework.web.context.request.ServletRequestAttributes; - -import javax.servlet.http.HttpServletRequest; -import java.lang.reflect.Method; -import java.util.Date; - -/** - * 系统日志,切é¢å¤„ç†ç±» - */ -@Aspect -@Component -public class SysLogAspect { -// @Autowired -// private SysLogService sysLogService; -// -// @Pointcut("@annotation(cn.wisenergy.common.annotation.SysLog)") -// public void logPointCut() { -// } -// -// @Around("logPointCut()") -// public Object around(ProceedingJoinPoint point) throws Throwable { -// long beginTime = System.currentTimeMillis(); -// //执行方法 -// Object result = point.proceed(); -// //执行时长(毫秒) -// long time = System.currentTimeMillis() - beginTime; -// -// //ä¿å˜æ—¥å¿— -// saveSysLog(point, time, result); -// -// return result; -// } -// -// private void saveSysLog(ProceedingJoinPoint joinPoint, long time,Object result) { -// MethodSignature signature = (MethodSignature) joinPoint.getSignature(); -// Method method = signature.getMethod(); -// -// SysLogEntity sysLog = new SysLogEntity(); -// cn.wisenergy.common.annotation.SysLog syslog = method.getAnnotation(cn.wisenergy.common.annotation.SysLog.class); -// if(syslog != null){ -// //注解上的æè¿° -// sysLog.setOperation(syslog.value()); -// } -// -// //请求的方法å -// String className = joinPoint.getTarget().getClass().getName(); -// String methodName = signature.getName(); -// sysLog.setMethod(className + "." + methodName + "()"); -// -// //è¯·æ±‚çš„å‚æ•° -// Object[] args = joinPoint.getArgs(); -// String params = JSON.toJSONString(args); -// sysLog.setParams(params); -// -// //返回值 -// Result<?> r= (Result<?>) result; -// if("success".equals(r.getResult())) { -// sysLog.setState("æˆåŠŸ"); -// }else { -// sysLog.setState("失败"); -// } -// //获å–request -// HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); -// //设置IPåœ°å€ -// sysLog.setIp(IpUtils.getIpAddr(request)); -// //用户å -// SysUserEntity principal = (SysUserEntity) SecurityUtils.getSubject().getPrincipal(); -// String username =principal.getUsername(); -// sysLog.setUsername(username); -// sysLog.setTime(time); -// sysLog.setCreateDate(new Date()); -// //ä¿å˜ç³»ç»Ÿæ—¥å¿— -// try { -// sysLogService.save(sysLog); -// } catch (Exception e) { -// e.printStackTrace(); -// } -// } -} diff --git a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/WebLogAspect.java b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/WebLogAspect.java deleted file mode 100644 index 110dea5c83182d55e069bb1686888ce58213cd00..0000000000000000000000000000000000000000 --- a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/aspect/WebLogAspect.java +++ /dev/null @@ -1,63 +0,0 @@ -package cn.wisenergy.web.aspect; - -import com.alibaba.fastjson.JSON; -import lombok.extern.slf4j.Slf4j; -import org.aspectj.lang.JoinPoint; -import org.aspectj.lang.ProceedingJoinPoint; -import org.aspectj.lang.annotation.*; -import org.springframework.stereotype.Component; -import org.springframework.web.context.request.RequestContextHolder; -import org.springframework.web.context.request.ServletRequestAttributes; - -import javax.servlet.http.HttpServletRequest; - -/** - * AOP日志 - * @author 86187 - */ -@Aspect -@Component -@Slf4j -public class WebLogAspect { - - /** - * 两个..代表所有åç›®å½•ï¼Œæœ€åŽæ‹¬å·é‡Œçš„两个..ä»£è¡¨æ‰€æœ‰å‚æ•° - */ - @Pointcut("execution( * cn.wisenergy.web.admin.controller..*.*(..))") - public void logPointCut() { - } - - @Before("logPointCut()") - public void doBefore(JoinPoint joinPoint) { - // 接收到请求,记录请求内容 - ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); - HttpServletRequest request = attributes.getRequest(); - - // 记录下请求内容 - log.info(" ___________________________________________________________"); - log.info("| è¯·æ±‚åœ°å€ : {}", request.getRequestURL().toString()); - log.info("| è¯·æ±‚æ–¹å¼ : {}", request.getMethod()); - // èŽ·å–æ‰§è¡Œçš„æ–¹æ³•全路径 - String methodName = joinPoint.getSignature().getName(); - log.info("| 执行方法 : {}.{}", joinPoint.getSignature().getDeclaringTypeName(), methodName); - } - - /** - * returning的值和doAfterReturningçš„å‚æ•°å一致 - */ - @AfterReturning(returning = "ret", pointcut = "logPointCut()") - public void doAfterReturning(Object ret) { - // 处ç†å®Œè¯·æ±‚,返回内容 - log.info("| 返回值 : {}", JSON.toJSONString(ret)); - log.info(" ———————————————————————————————————————————"); - } - - @Around("logPointCut()") - public Object doAround(ProceedingJoinPoint pjp) throws Throwable { - long startTime = System.currentTimeMillis(); - // ob 为方法的返回值 - Object ob = pjp.proceed(); - log.info("| 耗时 : {}", (System.currentTimeMillis() - startTime)); - return ob; - } -} diff --git a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/shiro/filter/AuthRealm.java b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/shiro/filter/AuthRealm.java index 92a07583afe60d9f79df30f1ff7ad79c87a27587..028ce83a0b6ba81333425c9a64ccaf876d5cdb99 100644 --- a/wisenergy-web-admin/src/main/java/cn/wisenergy/web/shiro/filter/AuthRealm.java +++ b/wisenergy-web-admin/src/main/java/cn/wisenergy/web/shiro/filter/AuthRealm.java @@ -51,7 +51,7 @@ public class AuthRealm extends AuthorizingRealm { */ @Override protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) { - AccountInfo user = (AccountInfo) principals.getPrimaryPrincipal(); + Users user = (Users) principals.getPrimaryPrincipal(); String userId = user.getId().toString(); //用户æƒé™åˆ—表 // Set<String> permsSet = sysUserService.queryAllPerms(userId); @@ -98,7 +98,7 @@ public class AuthRealm extends AuthorizingRealm { throw new IncorrectCredentialsException(RespCodeEnum.TOKEN_IS_NOT_TIMEOUT.getMsg()); }*/ //æŸ¥è¯¢ç”¨æˆ·ä¿¡æ¯ - Users users = authUserService.getByUserId(usersEntity.getUserId()); + Users users = authUserService.getById(usersEntity.getId()); // 判æ–请求token与redis䏿˜¯å¦ç›¸åŒï¼Œå¦‚æžœtoken被刷新,则ä¸åˆ¤æ– if (!refreshFlag && !StringUtils.equals(accessToken, redisToken)) { throw new IncorrectCredentialsException(RespCodeEnum.NO_AUTH_REQUEST.getMsg()); diff --git a/wisenergy-web-admin/src/main/resources/application-dev.yml b/wisenergy-web-admin/src/main/resources/application-dev.yml index 287b65b164d8d3931e95677890fe9858cf260853..0a90fa65e558e2968c541c2eb8d82e5190f427d5 100644 --- a/wisenergy-web-admin/src/main/resources/application-dev.yml +++ b/wisenergy-web-admin/src/main/resources/application-dev.yml @@ -16,7 +16,7 @@ spring: type: com.alibaba.druid.pool.DruidDataSource druid: driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://8.140.102.52:3306/shop-mall?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=GMT%2B8 + url: jdbc:mysql://8.140.102.52:3306/yashi?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=GMT%2B8 username: root password: adm4HYservice$ initial-size: 10