「小程序JAVA实战」小程序的举报功能开发（68）

package com.idig8.controller;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import com.idig8.pojo.Users;
import com.idig8.pojo.UsersReport;
import com.idig8.pojo.vo.PublisherVideo;
import com.idig8.pojo.vo.UsersVO;
import com.idig8.service.UserService;
import com.idig8.utils.JSONResult;
import com.idig8.utils.file.FileUtil;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;

@RestController
@Api(value="用户接口",tags={"用户的controller"})
@RequestMapping(value = "/user")
public class UserController extends BasicController{

    @Autowired
    private UserService userService;

    @Value("${server.file.path}")
    private String fileSpace;

    @ApiOperation(value="用户上传头像",notes="用户上传头像的接口")
    @ApiImplicitParams({
        @ApiImplicitParam(name="userId",value="用户id",required=true,dataType="String",paramType="query"),
    })
    @PostMapping(value="/uploadFace",headers="content-type=multipart/form-data")
    public JSONResult uploadFace(String userId,@ApiParam(value="图片",required=true) MultipartFile file) {
        if (StringUtils.isBlank(userId)) {
            return JSONResult.errorMsg("用户id不能为空...");
        }

        // 文件保存的命名空间
        String fileName = file.getOriginalFilename();
        // 保存到数据库中的相对路径
        String path = "";
         try {
             path = FileUtil.uploadFile(file.getBytes(), fileSpace, fileName);
            } catch (Exception e) {
                e.getStackTrace();
                return JSONResult.errorMsg(e.getMessage());
            }

         Users user = new Users();
         user.setId(userId);
         user.setFaceImage(path);
         userService.updateUser(user);


        return JSONResult.ok(path);
    }

    @ApiOperation(value="通过用户Id获取用户信息",notes="通过用户Id获取用户信息的接口")
    @ApiImplicitParam(name="userId",value="用户id",required=true,dataType="String",paramType="query")
    @PostMapping("/queryByUserId")
    public JSONResult queryByUserId(String userId, String fanId) {
        if (StringUtils.isBlank(userId)) {
            return JSONResult.errorMsg("用户id不能为空...");
        }

        Users user = userService.queryUserId(userId);
        UsersVO usersVO= new UsersVO();
        BeanUtils.copyProperties(user, usersVO);

        usersVO.setFollow(userService.queryIfFollow(userId, fanId));
        return JSONResult.ok(usersVO);
    }

    @PostMapping("/queryPublisher")
    public JSONResult queryPublisher(String loginUserId, String videoId, 
            String publishUserId) throws Exception {

        if (StringUtils.isBlank(publishUserId)) {
            return JSONResult.errorMsg("");
        }

        // 1. 查询视频发布者的信息
        Users userInfo = userService.queryUserInfo(publishUserId);
        UsersVO publisher = new UsersVO();
        BeanUtils.copyProperties(userInfo, publisher);

        // 2. 查询当前登录者和视频的点赞关系
        boolean userLikeVideo = userService.isUserLikeVideo(loginUserId, videoId);

        PublisherVideo bean = new PublisherVideo();
        bean.setPublisher(publisher);   
        bean.setUserLikeVideo(userLikeVideo);

        return JSONResult.ok(bean);
    }


    @PostMapping("/beyourfans")
    public JSONResult beyourfans(String userId, String fanId) throws Exception {

        if (StringUtils.isBlank(userId) || StringUtils.isBlank(fanId)) {
            return JSONResult.errorMsg("");
        }

        userService.saveUserFanRelation(userId, fanId);

        return JSONResult.ok("关注成功...");
    }

    @PostMapping("/dontbeyourfans")
    public JSONResult dontbeyourfans(String userId, String fanId) throws Exception {

        if (StringUtils.isBlank(userId) || StringUtils.isBlank(fanId)) {
            return JSONResult.errorMsg("");
        }

        userService.deleteUserFanRelation(userId, fanId);

        return JSONResult.ok("取消关注成功...");
    }

    @PostMapping("/reportUser")
    public JSONResult reportUser(@RequestBody UsersReport usersReport) throws Exception {

        // 保存举报信息
        userService.reportUser(usersReport);

        return JSONResult.errorMsg("举报成功...有你平台变得更美好...");
    }


}

···

* service
UserService.java

/**
 * 判断用户名是否存在
 * @param username
 * @return
 */
public boolean queryUsernameIsExist(String username);

/**
 * 保存用户
 * @param user
 * @return
 */
public void saveUser(Users user);

/**
 * 查询用户对象
 * @param username
 * @return
 */
public Users queryUserIsExist(Users user);

/**
 * 更新对象
 * @param username
 * @return
 */
public void updateUser(Users user);


/**
 * userId查询用户对象
 * @param username
 * @return
 */
public Users queryUserId(String userId);

/**
 * 查询用户信息
 */
public Users queryUserInfo(String userId);

/**
 * 查询用户是否喜欢点赞视频
 */
public boolean isUserLikeVideo(String userId, String videoId);

/**
 * @Description: 增加用户和粉丝的关系
 */
public void saveUserFanRelation(String userId, String fanId);

/**
 * @Description: 删除用户和粉丝的关系
 */
public void deleteUserFanRelation(String userId, String fanId);

/**
 * @Description: 查询用户是否关注
 */
public boolean queryIfFollow(String userId, String fanId);

/**
 * @Description: 举报用户
 */
public void reportUser(UsersReport userReport);

* service
UserServiceImpl.java

@Autowired
private UsersMapper usersMapper;

@Autowired
private UsersLikeVideosMapper usersLikeVideosMapper;

@Autowired
private UsersMapper userMapper;

@Autowired
private Sid sid;

@Autowired
private UsersFansMapper usersFansMapper;

@Autowired
private UsersReportMapper usersReportMapper;

@Transactional(propagation =Propagation.SUPPORTS)
@Override
public boolean queryUsernameIsExist(String username) {
    Users user = new Users();
    user.setUsername(username);
    Users result = usersMapper.selectOne(user);
    return result==null? false:true;
}

@Transactional(propagation =Propagation.REQUIRED)
@Override
public void saveUser(Users user) {
    String userId =sid.nextShort();
    user.setId(userId);
    usersMapper.insert(user);
}

@Transactional(propagation =Propagation.SUPPORTS)
@Override
public Users queryUserIsExist(Users user) {
    Example queryExample = new Example(Users.class);
    Criteria criteria = queryExample.createCriteria();
    criteria.andEqualTo("username",user.getUsername());
    try {
        criteria.andEqualTo("password",MD5Utils.getMD5Str(user.getPassword()));
    } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    Users userOne =  usersMapper.selectOneByExample(queryExample);
    return userOne;
}

@Transactional(propagation =Propagation.REQUIRED)
@Override
public void updateUser(Users user) {

    Example userExample = new Example(Users.class);
    Criteria criteria = userExample.createCriteria();
    criteria.andEqualTo("id", user.getId());
    usersMapper.updateByExampleSelective(user, userExample);
}

@Transactional(propagation =Propagation.SUPPORTS)
@Override
public Users queryUserId(String userId){
    Example queryExample = new Example(Users.class);
    Criteria criteria = queryExample.createCriteria();
    criteria.andEqualTo("id",userId);
    Users userOne =  usersMapper.selectOneByExample(queryExample);
    return userOne;
}

@Transactional(propagation = Propagation.SUPPORTS)
@Override
public Users queryUserInfo(String userId) {
    Example userExample = new Example(Users.class);
    Criteria criteria = userExample.createCriteria();
    criteria.andEqualTo("id", userId);
    Users user = userMapper.selectOneByExample(userExample);
    return user;
}

@Transactional(propagation = Propagation.SUPPORTS)
@Override
public boolean isUserLikeVideo(String userId, String videoId) {

    if (StringUtils.isBlank(userId) || StringUtils.isBlank(videoId)) {
        return false;
    }

    Example example = new Example(UsersLikeVideos.class);
    Criteria criteria = example.createCriteria();

    criteria.andEqualTo("userId", userId);
    criteria.andEqualTo("videoId", videoId);

    List<UsersLikeVideos> list = usersLikeVideosMapper.selectByExample(example);

    if (list != null && list.size() >0) {
        return true;
    }

    return false;
}

@Transactional(propagation = Propagation.REQUIRED)
@Override
public void saveUserFanRelation(String userId, String fanId) {

    String relId = sid.nextShort();

    UsersFans userFan = new UsersFans();
    userFan.setId(relId);
    userFan.setUserId(userId);
    userFan.setFanId(fanId);

    usersFansMapper.insert(userFan);

    userMapper.addFansCount(userId);
    userMapper.addFollersCount(fanId);

}

@Transactional(propagation = Propagation.REQUIRED)
@Override
public void deleteUserFanRelation(String userId, String fanId) {

    Example example = new Example(UsersFans.class);
    Criteria criteria = example.createCriteria();

    criteria.andEqualTo("userId", userId);
    criteria.andEqualTo("fanId", fanId);

    usersFansMapper.deleteByExample(example);

    userMapper.reduceFansCount(userId);
    userMapper.reduceFollersCount(fanId);

}


@Override
public boolean queryIfFollow(String userId, String fanId) {

    Example example = new Example(UsersFans.class);
    Criteria criteria = example.createCriteria();

    criteria.andEqualTo("userId", userId);
    criteria.andEqualTo("fanId", fanId);

    List<UsersFans> list = usersFansMapper.selectByExample(example);

    if (list != null && !list.isEmpty() && list.size() > 0) {
        return true;
    }

    return false;
}

@Transactional(propagation = Propagation.REQUIRED)
@Override
public void reportUser(UsersReport userReport) {

    String urId = sid.nextShort();
    userReport.setId(urId);
    userReport.setCreateDate(new Date());

    usersReportMapper.insert(userReport);
}

### 小程序开发

* videoInfo
videoInfo.js

var serverUrl = app.serverUrl;
var user = app.getGlobalUserInfo();
var loginUserId = "";
if (user != null && user != undefined && user != '') {
  loginUserId = user.id;
}
wx.request({
  url: serverUrl + '/user/queryPublisher?loginUserId=' + loginUserId + "&videoId=" + videoInfo.id + "&publishUserId=" + videoInfo.userId,
  method: 'POST',
  success: function (res) {
    console.log(res.data);

    var publisher = res.data.data.publisher;
    var userLikeVideo = res.data.data.userLikeVideo;

    me.setData({
      serverUrl: serverUrl,
      publisher: publisher,
      userLikeVideo: userLikeVideo
    });
  }
})

var me = this;
var userInfo = app.getGlobalUserInfo();

var videoInfo = JSON.stringify(me.data.videoInfo);
var realUrl = '../videoInfo/videoInfo#videoInfo@' + videoInfo;

if (userInfo.id == '' || userInfo.id == undefined) {
  wx.navigateTo({
    url: '../userLogin/userLogin?realUrl=' + realUrl,
  })
} else {
  videoUtils.uploadVideo();
}

var videoInfo = JSON.parse

if (userInfo.id == '' || userInfo.id == undefined){
  wx.navigateTo({
    url: '../userLogin/userLogin',
  })
}else{
  wx.navigateTo({
    url: '../mine/mine',
  })
}

var videoInfoStr = JSON.stringify(me.data.videoInfo);
var realUrl = '../videoInfo/videoInfo#videoInfo@' + videoInfoStr;
if (userInfo.id == '' || userInfo.id == undefined) {
  wx.navigateTo({
    url: '../userLogin/userLogin?realUrl=' + realUrl,
  })
} else {
  var videoInfo = me.data.videoInfo;
  var userLikeVideo = me.data.userLikeVideo;
  var url = "/video/userLike?userId=" + userInfo.id + "&videoId=" + videoInfo.id + "&videoCreaterId=" + userLikeVideo.userId;

  if (userLikeVideo){
    var url = "/video/userUnLike?userId=" + userInfo.id + "&videoId=" + videoInfo.id + "&videoCreaterId=" + userLikeVideo.userId;
  }
  wx.showLoading({
    title: '....',
  })
  wx.request({
    url: app.serverUrl + url,
    method: "POST",
    header: {
      'content-type': 'application/json', // 默认值
      'headerUserId': userInfo.id,
      'headerUserToken': userInfo.userToken
    },
    success: function (res) {
      wx.hideLoading();
      me.setData({
        userLikeVideo: !userLikeVideo,
      })
    }
  })

}

var videoInfo = me.data.videoInfo;
var realUrl = '../mine/mine#publisherId@' + videoInfo.userId;
if (userInfo.id == '' || userInfo.id == undefined) {
  wx.navigateTo({
    url: '../userLogin/userLogin?realUrl=' + realUrl,
  })
} else {
  wx.navigateTo({
    url: '../mine/mine?publisherId=' + videoInfo.userId,
  })

}

} else if (res.tapIndex==1){
      // 举报
      var videoInfo = JSON.stringify(me.data.videoInfo);
      var realUrl = '../videoInfo/videoInfo#videoInfo@' + videoInfo;

      if (user == null || user == undefined || user == '') {
        wx.navigateTo({
          url: '../userLogin/userLogin?realUrl=' + realUrl,
        })
      } else {
        var publishUserId = me.data.videoInfo.userId;
        var videoId = me.data.videoInfo.id;
        var currentUserId = user.id;
        wx.navigateTo({
          url: '../report/report?videoId=' + videoId + "&publishUserId=" + publishUserId
        })
      }

    } else{

    }
  }
})

* report

onLoad:function(params) {
  var me = this;

  var videoId = params.videoId;
  var publishUserId = params.publishUserId;

  me.setData({
    publishUserId: publishUserId,
    videoId: videoId
  });
},

changeMe:function(e) {
  var me = this;

  var index = e.detail.value;
  var reasonType = app.reportReasonArray[index];

  me.setData({
    reasonType: reasonType
  });
},

submitReport:function(e) {
  var me = this;

  var reasonIndex = e.detail.value.reasonIndex;
  var reasonContent = e.detail.value.reasonContent;

  var user = app.getGlobalUserInfo();
  var currentUserId = user.id;

  if (reasonIndex == null || reasonIndex == '' || reasonIndex == undefined) {
    wx.showToast({
      title: '选择举报理由',
      icon: "none"
    })
    return;
  }

  var serverUrl = app.serverUrl;
  wx.request({
    url: serverUrl + '/user/reportUser',
    method: 'POST',
    data: {
      dealUserId: me.data.publishUserId,
      dealVideoId: me.data.videoId,
      title: app.reportReasonArray[reasonIndex],
      content:reasonContent,
      userid: currentUserId
    },
    header: {
      'content-type': 'application/json', // 默认值
      'headerUserId': user.id,
      'headerUserToken': user.userToken
    },
    success:function(res) {
      wx.showToast({
        title: res.data.msg,
        duration: 2000,
        icon: 'none',
        success: function() {
          wx.navigateBack();
        }
      })
    }

  })

}

<form bindsubmit='submitReport'>

    <view class='container-reason'>
        <label class='label'>举报理由:</label>
        <picker name="reasonIndex" value="{{index}}" range="{{reportReasonArray}}" bindchange="changeMe">
            <view class="picker">
                {{reasonType}}
            </view>
        </picker>
    </view>

    <view class='container-content'>
        <label class='label'>举报描述（选填）:</label>
        <textarea name="reasonContent" class='content' placeholder='请详细说明举报原因...'>
        </textarea>
    </view>

    <view class='container-tips'>
        <image src='../../resource/images/report_face.png' class='report-face'></image>
        收到举报后，我们会在12小时内处理，感谢您的举报，互联网环境因你更美好！~~
    </view>

    <view>
        <button class="submitBtn" type="" form-type='submit'>提  交</button>
    </view>

</form>

* app.js