| @ -1,19 +0,0 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.modules.commonBookAchievementLog.entity.CommonBookAchievementLog; | |||
| public interface AppletAchievementService { | |||
| // 获取读者成就列表 | |||
| Result<?> getAchievementList(); | |||
| // 设置读者成就等级名称 | |||
| Result<?> setAchievementName(String token, CommonBookAchievementLog bookAchievementLog ); | |||
| // 根据用户标识和书籍标识查询该用户的成就等级 | |||
| Result<?> getAchievement(String token , String bookId); | |||
| } | |||
| @ -1,26 +0,0 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.modules.commonBook.entity.CommonBook; | |||
| import org.jeecg.modules.commonBookNovel.entity.CommonBookNovel; | |||
| import org.jeecg.modules.commonMyBook.entity.CommonMyBook; | |||
| public interface AppletBookService { | |||
| //获取我阅读过的书籍列表带分页 | |||
| Result<?> getReadBookPage(String token,PageBean pageBean); | |||
| //增加我的书架阅读记录 | |||
| Result<?> addReadBook(String token, CommonBook commonBook); | |||
| //移除我阅读过的书籍根据书籍标识 | |||
| Result<?> removeReadBook(String token,String bookId); | |||
| //批量移除我阅读过的数据根据书籍标识 | |||
| Result<?> batchRemoveReadBook(String token,String bookIds); | |||
| } | |||
| @ -0,0 +1,31 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.common.api.vo.Result; | |||
| public interface AppletClassService { | |||
| //获取价格预览分类列表 | |||
| Result<?> getPricePreviewClassList(); | |||
| //根据分类标识获取分类商品列表带分页 | |||
| Result<?> getClassGoodsList(String classId, PageBean pageBean); | |||
| //根据商品标识查询商品详情 | |||
| Result<?> getGoodsDetail(String goodsId); | |||
| //根据商品标识查询商品回收规则 | |||
| Result<?> getGoodsRecycleRule(String goodsId); | |||
| //根据商品标识查询商品可回品牌 | |||
| Result<?> getGoodsBrandList(String name,String iconId,PageBean pageBean); | |||
| } | |||
| @ -1,32 +0,0 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.common.api.vo.Result; | |||
| public interface AppletCommentService { | |||
| //查询我未读的评论次数 | |||
| Result<?> getMyCommentNum(String token); | |||
| //查询我未读的评论列表 | |||
| Result<?> getMyCommentList(String token, PageBean pageBean); | |||
| //根据书籍标识查询评论信息列表带分页 | |||
| Result<?> getCommentList(String bookId, PageBean pageBean); | |||
| //保存评论信息 | |||
| Result<?> saveComment(String token, String bookId, String content); | |||
| //删除评论信息 | |||
| Result<?> deleteComment(String token, String commentId); | |||
| //回复评论信息 | |||
| Result<?> replyComment(String token, String commentId, String content); | |||
| //修改评论为已读 | |||
| Result<?> updateCommentRead(String token, String commentId); | |||
| //查看评论详情 | |||
| Result<?> getCommentDetail(String token, String commentId); | |||
| } | |||
| @ -0,0 +1,35 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.common.api.vo.Result; | |||
| public interface AppletInfoTeamService { | |||
| //获取用户列表带分页搜索 | |||
| Result<?> getInfoTeamListPage(String token,String name,PageBean pageBean); | |||
| //拉黑用户 | |||
| Result<?> blackUser(String token,String userId); | |||
| //升级推广官 | |||
| Result<?> upgrade(String token); | |||
| Result<?> getOrderListPage(String token,String userId,PageBean pageBean); | |||
| //获取订单详情 | |||
| Result<?> getOrderDetail(String token,String orderId); | |||
| //点击质量报告 | |||
| Result<?> clickQualityReport(String token,String orderId); | |||
| //获取员工信息列表 | |||
| Result<?> getMyTeamList(String token,String name,PageBean pageBean); | |||
| //查看员工详情信息 | |||
| Result<?> getMemberInfo(String token,String id); | |||
| //移除员工 | |||
| Result<?> removeMember(String token,String id); | |||
| } | |||
| @ -1,31 +0,0 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.modules.commonBookNovel.entity.CommonBookNovel; | |||
| import org.jeecg.modules.commonMyBook.entity.CommonMyBook; | |||
| import org.jeecg.modules.commonShop.entity.CommonShop; | |||
| public interface AppletMyBookService { | |||
| //获取我的作品带分页 | |||
| Result<?> getMyShopPage(String token, PageBean pageBean); | |||
| //增加或者修改我的作品 | |||
| Result<?> saveOrUpdateShop(String token, CommonShop commonShop); | |||
| //获取我的小说章节列表带分页 | |||
| Result<?> getMyShopNovelPage(String token, String bookId,Integer status,Integer reverse, PageBean pageBean); | |||
| //增加或修改我的小说章节 | |||
| Result<?> saveOrUpdateShopNovel(String token, CommonBookNovel commonBookNovel); | |||
| //删除我的作品 | |||
| Result<?> deleteMyShop(String token, String bookId); | |||
| //多选删除我的作品 | |||
| Result<?> deleteMyShopList(String token, String bookIds); | |||
| //删除作品章节 | |||
| Result<?> deleteMyShopNovel(String token, String bookId, String novelId); | |||
| } | |||
| @ -0,0 +1,22 @@ | |||
| package org.jeecg.api.service; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.common.api.vo.Result; | |||
| public interface AppletOrderTeamService { | |||
| //管理员:订单列表带分页搜索 | |||
| Result<?> getOrderListPage(String token, Integer status, PageBean pageBean); | |||
| //管理员:订单详情 | |||
| Result<?> getOrderDetail(String token,String orderId); | |||
| //管理员:订单通过 | |||
| Result<?> passOrder(String token,String orderId); | |||
| //管理员:订单拒绝 | |||
| Result<?> rejectOrder(String token,String orderId); | |||
| //管理员:提交质量信息 | |||
| Result<?> submitQualityInfo(); | |||
| } | |||
| @ -1,81 +0,0 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import org.apache.commons.lang3.StringUtils; | |||
| import org.jeecg.api.service.AppletAchievementService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonBookAchievement.entity.CommonBookAchievement; | |||
| import org.jeecg.modules.commonBookAchievement.service.ICommonBookAchievementService; | |||
| import org.jeecg.modules.commonBookAchievementLog.entity.CommonBookAchievementLog; | |||
| import org.jeecg.modules.commonBookAchievementLog.service.ICommonBookAchievementLogService; | |||
| import org.jeecg.modules.commonShop.entity.CommonShop; | |||
| import org.jeecg.modules.commonShop.service.ICommonShopService; | |||
| import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; | |||
| import org.springframework.beans.factory.annotation.Autowired; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| import java.util.List; | |||
| @Service | |||
| public class AppletAchievementServiceImpl implements AppletAchievementService { | |||
| //权限 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Autowired | |||
| private ICommonBookAchievementService commonBookAchievementService; | |||
| @Autowired | |||
| private ICommonBookAchievementLogService commonBookAchievementLogService; | |||
| @Autowired | |||
| private ICommonShopService commonShopService; | |||
| // 获取读者成就列表 | |||
| @Override | |||
| public Result<?> getAchievementList(){ | |||
| List<CommonBookAchievement> list = commonBookAchievementService.list(); | |||
| return Result.OK("读者成就列表",list); | |||
| } | |||
| // 设置读者成就等级名称 | |||
| @Override | |||
| public Result<?> setAchievementName(String token, CommonBookAchievementLog bookAchievementLog){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| //书籍标识不能为空 | |||
| if(StringUtils.isEmpty(bookAchievementLog.getBookId())){ | |||
| return Result.error("书籍标识不能为空"); | |||
| } | |||
| //根据书籍标识查询书籍信息 | |||
| CommonShop commonShop = commonShopService.getById(bookAchievementLog.getBookId()); | |||
| if(commonShop==null){ | |||
| return Result.error("书籍不存在"); | |||
| } | |||
| CommonBookAchievementLog one = commonBookAchievementLogService.lambdaQuery() | |||
| .eq(CommonBookAchievementLog::getBookId, bookAchievementLog.getBookId()) | |||
| .eq(CommonBookAchievementLog::getUserId, member.getId()) | |||
| .one(); | |||
| if(one!=null){ | |||
| bookAchievementLog.setId(one.getId()); | |||
| commonBookAchievementLogService.save(bookAchievementLog); | |||
| return Result.OK("修改成功"); | |||
| }else{ | |||
| bookAchievementLog.setBookId(commonShop.getId()); | |||
| bookAchievementLog.setUserId(member.getId()); | |||
| commonBookAchievementLogService.save(bookAchievementLog); | |||
| return Result.OK("设置成功"); | |||
| } | |||
| } | |||
| // 根据用户标识和书籍标识查询该用户的成就等级 | |||
| @Override | |||
| public Result<?> getAchievement(String token, String bookId){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonBookAchievementLog one = commonBookAchievementLogService.lambdaQuery() | |||
| .eq(CommonBookAchievementLog::getBookId, bookId) | |||
| .eq(CommonBookAchievementLog::getUserId, member.getId()) | |||
| .one(); | |||
| return Result.OK("查询成功",one); | |||
| } | |||
| } | |||
| @ -1,122 +0,0 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import com.baomidou.mybatisplus.core.metadata.IPage; | |||
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | |||
| import org.apache.commons.lang3.StringUtils; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.api.service.AppletBookService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonBanner.service.ICommonBannerService; | |||
| import org.jeecg.modules.commonBook.entity.CommonBook; | |||
| import org.jeecg.modules.commonBook.service.ICommonBookService; | |||
| import org.jeecg.modules.commonBookNovel.entity.CommonBookNovel; | |||
| import org.jeecg.modules.commonBookNovel.service.ICommonBookNovelService; | |||
| import org.jeecg.modules.commonGiftBack.service.ICommonGiftBackService; | |||
| import org.jeecg.modules.commonIconImage.service.ICommonIconImageService; | |||
| import org.jeecg.modules.commonMoneyLog.service.ICommonMoneyLogService; | |||
| import org.jeecg.modules.commonMyBook.entity.CommonMyBook; | |||
| import org.jeecg.modules.commonMyBook.service.ICommonMyBookService; | |||
| import org.jeecg.modules.commonMyGift.service.ICommonMyGiftService; | |||
| import org.jeecg.modules.commonNotice.service.ICommonNoticeService; | |||
| import org.jeecg.modules.commonRanking.service.ICommonRankingService; | |||
| import org.jeecg.modules.commonShop.service.ICommonShopService; | |||
| import org.jeecg.modules.commonShopClass.service.ICommonShopClassService; | |||
| import org.jeecg.modules.commonSign.service.ICommonSignService; | |||
| import org.jeecg.modules.commonSignLog.service.ICommonSignLogService; | |||
| import org.jeecg.modules.commonTask.service.ICommonTaskService; | |||
| import org.jeecg.modules.commonTaskLog.service.ICommonTaskLogService; | |||
| import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; | |||
| import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService; | |||
| import org.springframework.beans.factory.annotation.Autowired; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| import java.util.Arrays; | |||
| @Service | |||
| public class AppletBookServiceImpl implements AppletBookService { | |||
| //权限 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Autowired | |||
| private ICommonBannerService commonBannerService; | |||
| @Autowired | |||
| private ICommonBookService commonBookService; | |||
| @Autowired | |||
| private ICommonNoticeService commonNoticeService; | |||
| @Autowired | |||
| private ICommonShopService commonShopService; | |||
| @Autowired | |||
| private ICommonShopClassService commonShopClassService; | |||
| @Autowired | |||
| private ICommonIconImageService commonIconImageService; | |||
| @Autowired | |||
| private ICommonRankingService commonRankingService; | |||
| @Autowired | |||
| private ICommonSignService commonSignService; | |||
| @Autowired | |||
| private ICommonSignLogService commonSignLogService; | |||
| @Autowired | |||
| private ICommonTaskService commonTaskService; | |||
| @Autowired | |||
| private ICommonTaskLogService commonTaskLogService; | |||
| @Autowired | |||
| private ICommonMyGiftService commonMyGiftService; | |||
| @Autowired | |||
| private ICommonMoneyLogService commonMoneyLogService; | |||
| @Autowired | |||
| private ICommonGiftBackService commonGiftBackService; | |||
| @Autowired | |||
| private ICommonBookNovelService commonBookNovelService; | |||
| @Resource | |||
| private IHanHaiMemberService hanHaiMemberService; | |||
| //获取我阅读过的书籍列表带分页 | |||
| @Override | |||
| public Result<?> getReadBookPage(String token, PageBean pageBean){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| //查询阅读过的书籍列表带分页 | |||
| Page<CommonBook> page = new Page<CommonBook>(pageBean.getPageNo(), pageBean.getPageSize()); | |||
| IPage<CommonBook> pageList = commonBookService | |||
| .lambdaQuery() | |||
| .eq(CommonBook::getUserId,hanHaiMember.getId()) | |||
| .page(page); | |||
| return Result.OK("我阅读过的书籍列表",pageList); | |||
| } | |||
| //增加我的书架阅读记录 | |||
| @Override | |||
| public Result<?> addReadBook(String token, CommonBook commonBook) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| commonBook.setUserId(hanHaiMember.getId()); | |||
| commonBookService.save(commonBook); | |||
| return Result.OK("保存成功"); | |||
| } | |||
| //移除我阅读过的书籍根据书籍标识 | |||
| @Override | |||
| public Result<?> removeReadBook(String token,String bookId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| commonBookService.removeById(bookId); | |||
| return Result.OK("移除成功"); | |||
| } | |||
| //批量移除我阅读过的数据根据书籍标识 | |||
| @Override | |||
| public Result<?> batchRemoveReadBook(String token,String bookIds){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| commonBookService.removeByIds(Arrays.asList(bookIds.split(","))); | |||
| return Result.OK("移除成功"); | |||
| } | |||
| } | |||
| @ -0,0 +1,96 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import com.baomidou.mybatisplus.core.metadata.IPage; | |||
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.api.service.AppletClassService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonAddress.service.ICommonAddressService; | |||
| import org.jeecg.modules.commonShop.entity.CommonShop; | |||
| import org.jeecg.modules.commonShop.service.ICommonShopService; | |||
| import org.jeecg.modules.commonShopClass.entity.CommonShopClass; | |||
| import org.jeecg.modules.commonShopClass.service.ICommonShopClassService; | |||
| import org.jeecg.modules.commonVip.entity.CommonVip; | |||
| import org.jeecg.modules.commonVip.service.ICommonVipService; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| import java.util.List; | |||
| @Service | |||
| public class AppletClassServiceImpl implements AppletClassService { | |||
| //权限验证 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Resource | |||
| private ICommonAddressService commonAddressService; | |||
| @Resource | |||
| private ICommonShopService commonShopService; | |||
| @Resource | |||
| private ICommonShopClassService commonShopClassService; | |||
| @Resource | |||
| private ICommonVipService commonVipService; | |||
| //获取价格预览分类列表 | |||
| @Override | |||
| public Result<?> getPricePreviewClassList(){ | |||
| List<CommonShopClass> list = commonShopClassService.list(); | |||
| return Result.OK("价格预览分类列表",list); | |||
| } | |||
| //根据分类标识获取分类商品列表带分页 | |||
| @Override | |||
| public Result<?> getClassGoodsList(String classId, PageBean pageBean){ | |||
| Page<CommonShop> page = new Page<>(pageBean.getPageNo(),pageBean.getPageSize()); | |||
| IPage<CommonShop> pageList = commonShopService | |||
| .lambdaQuery() | |||
| .eq(CommonShop::getShopClass,classId) | |||
| .page(page); | |||
| return Result.OK("分类商品列表",pageList); | |||
| } | |||
| //根据商品标识查询商品详情 | |||
| @Override | |||
| public Result<?> getGoodsDetail(String goodsId){ | |||
| CommonShop commonShop = commonShopService.getById(goodsId); | |||
| return Result.OK("商品详情",commonShop); | |||
| } | |||
| //根据商品标识查询商品回收规则 | |||
| @Override | |||
| public Result<?> getGoodsRecycleRule(String goodsId){ | |||
| CommonShop commonShop = commonShopService.getById(goodsId); | |||
| return Result.OK("商品详情",commonShop.getDetails()); | |||
| } | |||
| //根据商品标识查询商品可回品牌 | |||
| @Override | |||
| public Result<?> getGoodsBrandList(String name,String iconId,PageBean pageBean){ | |||
| Page<CommonVip> page = new Page<>(pageBean.getPageNo(),pageBean.getPageSize()); | |||
| IPage<CommonVip> pageList = commonVipService | |||
| .lambdaQuery() | |||
| .eq(CommonVip::getPid, iconId) | |||
| .page(page); | |||
| //如果名称不为空 | |||
| if(name != null){ | |||
| pageList = commonVipService | |||
| .lambdaQuery() | |||
| .eq(CommonVip::getPid, iconId) | |||
| .like(CommonVip::getName, name) | |||
| .page(page); | |||
| } | |||
| return Result.OK("商品品牌",pageList); | |||
| } | |||
| } | |||
| @ -1,198 +0,0 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import com.baomidou.mybatisplus.core.metadata.IPage; | |||
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | |||
| import org.apache.commons.lang3.StringUtils; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.api.service.AppletCommentService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonBookComment.entity.CommonBookComment; | |||
| import org.jeecg.modules.commonBookComment.service.ICommonBookCommentService; | |||
| import org.jeecg.modules.commonShop.entity.CommonShop; | |||
| import org.jeecg.modules.commonShop.service.ICommonShopService; | |||
| import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; | |||
| import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| import java.util.ArrayList; | |||
| import java.util.List; | |||
| @Service | |||
| public class AppletCommentServiceImpl implements AppletCommentService { | |||
| //权限 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Resource | |||
| private IHanHaiMemberService hanHaiMemberService; | |||
| @Resource | |||
| private ICommonBookCommentService commonBookCommentService; | |||
| @Resource | |||
| private ICommonShopService commonShopService; | |||
| //查询我未读的评论次数 | |||
| @Override | |||
| public Result<?> getMyCommentNum(String token){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| List<CommonBookComment> n = commonBookCommentService.lambdaQuery() | |||
| .eq(CommonBookComment::getToUserId, member.getId()) | |||
| .eq(CommonBookComment::getIsLook, "N") | |||
| .list(); | |||
| return Result.OK("未读评论数",n.size()); | |||
| } | |||
| //查询我未读的评论列表 | |||
| @Override | |||
| public Result<?> getMyCommentList(String token, PageBean pageBean){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<CommonBookComment> page = new Page<>(pageBean.getPageNo(), pageBean.getPageSize()); | |||
| IPage<CommonBookComment> pageList = commonBookCommentService | |||
| .lambdaQuery() | |||
| .eq(CommonBookComment::getToUserId, member.getId()) | |||
| .eq(CommonBookComment::getIsLook, "N") | |||
| .page(page); | |||
| //创建一个新的集合 | |||
| List<CommonBookComment> commonBookComments = new ArrayList<>(); | |||
| //循环写入数据 | |||
| for (CommonBookComment commonBookComment : pageList.getRecords()) { | |||
| commonBookComment.setChildren( | |||
| commonBookCommentService.lambdaQuery() | |||
| .eq(CommonBookComment::getPid, commonBookComment.getId()) | |||
| .orderByDesc(CommonBookComment::getCreateTime) | |||
| .list() | |||
| ); | |||
| commonBookComment.setCommonShop( | |||
| commonShopService.getById(commonBookComment.getBookId()) | |||
| ); | |||
| commonBookComment.setHanHaiMember( | |||
| hanHaiMemberService.getById(commonBookComment.getUserId()) | |||
| ); | |||
| commonBookComments.add(commonBookComment); | |||
| } | |||
| pageList.setRecords(commonBookComments); | |||
| return Result.OK("查询成功",pageList); | |||
| } | |||
| //根据书籍标识查询评论信息列表带分页 | |||
| @Override | |||
| public Result<?> getCommentList(String bookId, PageBean pageBean){ | |||
| Page<CommonBookComment> page = new Page<CommonBookComment>(pageBean.getPageNo(), pageBean.getPageSize()); | |||
| IPage<CommonBookComment> pageList = commonBookCommentService | |||
| .lambdaQuery() | |||
| .eq(CommonBookComment::getBookId, bookId) | |||
| .eq(CommonBookComment::getPid, "0") | |||
| .orderByDesc(CommonBookComment::getCreateTime) | |||
| .page(page); | |||
| //创建一个新的集合 | |||
| List<CommonBookComment> commonBookComments = new ArrayList<>(); | |||
| //循环写入数据 | |||
| for (CommonBookComment commonBookComment : pageList.getRecords()) { | |||
| List<CommonBookComment> list = commonBookCommentService.lambdaQuery() | |||
| .eq(CommonBookComment::getPid, commonBookComment.getId()) | |||
| .orderByDesc(CommonBookComment::getCreateTime) | |||
| .list(); | |||
| //循环写入用户信息 | |||
| for (CommonBookComment bookComment : list) { | |||
| bookComment.setHanHaiMember(hanHaiMemberService.getById(bookComment.getUserId())); | |||
| } | |||
| commonBookComment.setChildren( | |||
| list | |||
| ); | |||
| commonBookComment.setCommonShop( | |||
| commonShopService.getById(commonBookComment.getBookId()) | |||
| ); | |||
| commonBookComment.setHanHaiMember( | |||
| hanHaiMemberService.getById(commonBookComment.getUserId()) | |||
| ); | |||
| commonBookComments.add(commonBookComment); | |||
| } | |||
| pageList.setRecords(commonBookComments); | |||
| return Result.OK("查询成功",pageList); | |||
| } | |||
| //保存评论信息 | |||
| @Override | |||
| public Result<?> saveComment(String token, String bookId, String content){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| //根据书籍标识查询书籍是否存在 | |||
| CommonShop commonShop = commonShopService.getById(bookId); | |||
| if(commonShop==null){ | |||
| return Result.error("书籍不存在"); | |||
| } | |||
| //增加评论信息 | |||
| CommonBookComment commonBookComment = new CommonBookComment(); | |||
| commonBookComment.setBookId(bookId); | |||
| commonBookComment.setUserId(member.getId()); | |||
| commonBookComment.setComment(content); | |||
| commonBookComment.setToUserId(commonShop.getUserId()); | |||
| commonBookComment.setPid(ICommonBookCommentService.ROOT_PID_VALUE); | |||
| commonBookCommentService.save(commonBookComment); | |||
| return Result.OK("评论成功"); | |||
| } | |||
| //删除评论信息 | |||
| @Override | |||
| public Result<?> deleteComment(String token, String commentId){ | |||
| //查询该评论是否是你的评论 | |||
| CommonBookComment commonBookComment = commonBookCommentService.getById(commentId); | |||
| if(commonBookComment.getUserId().equals(shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token).getId())){ | |||
| commonBookCommentService.deleteCommonBookComment(commentId); | |||
| return Result.OK("删除成功"); | |||
| } | |||
| return Result.error("删除失败"); | |||
| } | |||
| //回复评论信息 | |||
| @Override | |||
| public Result<?> replyComment(String token, String commentId, String content){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonBookComment commonBookComment = commonBookCommentService.getById(commentId); | |||
| if (commonBookComment == null){ | |||
| //评论不存在 | |||
| return Result.error("评论不存在"); | |||
| } | |||
| //增加评论信息 | |||
| CommonBookComment comment = new CommonBookComment(); | |||
| comment.setBookId(commonBookComment.getBookId()); | |||
| comment.setUserId(member.getId()); | |||
| comment.setComment(content); | |||
| comment.setToUserId(commonBookComment.getUserId()); | |||
| comment.setPid(commentId); | |||
| commonBookCommentService.save(comment); | |||
| return Result.ok("评论成功"); | |||
| } | |||
| //修改评论为已读 | |||
| @Override | |||
| public Result<?> updateCommentRead(String token, String commentId) { | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonBookComment commonBookComment = commonBookCommentService.getById(commentId); | |||
| if (commonBookComment == null) { | |||
| return Result.error("评论不存在"); | |||
| } | |||
| commonBookComment.setIsLook("Y"); | |||
| commonBookCommentService.updateById(commonBookComment); | |||
| return Result.OK("更新成功"); | |||
| } | |||
| //查看评论详情 | |||
| @Override | |||
| public Result<?> getCommentDetail(String token, String commentId) { | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonBookComment commonBookComment = commonBookCommentService.getById(commentId); | |||
| if (commonBookComment == null) { | |||
| return Result.error("评论不存在"); | |||
| } | |||
| //设置用户信息 | |||
| HanHaiMember hanHaiMember = hanHaiMemberService.getById(commonBookComment.getUserId()); | |||
| commonBookComment.setHanHaiMember(hanHaiMember); | |||
| commonBookComment.setCommonShop(commonShopService.getById(commonBookComment.getBookId())); | |||
| commonBookComment.setChildren(commonBookCommentService.lambdaQuery().eq(CommonBookComment::getPid,commentId).list()); | |||
| return Result.OK(commonBookComment); | |||
| } | |||
| } | |||
| @ -0,0 +1,133 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import com.baomidou.mybatisplus.core.metadata.IPage; | |||
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.api.service.AppletInfoTeamService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonOrder.entity.CommonOrder; | |||
| import org.jeecg.modules.commonOrder.service.ICommonOrderService; | |||
| import org.jeecg.modules.commonShop.entity.CommonShop; | |||
| import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; | |||
| import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| import java.util.List; | |||
| @Service | |||
| public class AppletInfoTeamServiceImpl implements AppletInfoTeamService { | |||
| //权限 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Resource | |||
| private IHanHaiMemberService hanHaiMemberService; | |||
| @Resource | |||
| private ICommonOrderService commonOrderService; | |||
| //获取用户信息列表带分页搜索 | |||
| @Override | |||
| public Result<?> getInfoTeamListPage(String token,String name,PageBean pageBean){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<HanHaiMember> page = new Page<>(pageBean.getPageNo(),pageBean.getPageSize()); | |||
| IPage<HanHaiMember> pageList = hanHaiMemberService | |||
| .lambdaQuery() | |||
| //姓名不为空则模糊搜索 | |||
| .like(name != null,HanHaiMember::getNickName,name) | |||
| .page(page); | |||
| return Result.OK("用户信息",pageList); | |||
| } | |||
| @Override | |||
| public Result<?> blackUser(String token,String userId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| hanHaiMember.setIsBlack("Y"); | |||
| hanHaiMemberService.updateById(hanHaiMember); | |||
| return Result.OK("拉黑成功"); | |||
| } | |||
| @Override | |||
| public Result<?> upgrade(String token){ | |||
| // HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| // hanHaiMember.setRole(2); | |||
| // hanHaiMemberService.updateById(hanHaiMember); | |||
| return Result.OK("接口未处理"); | |||
| } | |||
| @Override | |||
| public Result<?> getOrderListPage(String token,String userId,PageBean pageBean){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<CommonOrder> page = new Page<>(pageBean.getPageNo(),pageBean.getPageSize()); | |||
| IPage<CommonOrder> pageList = commonOrderService | |||
| .lambdaQuery() | |||
| .eq(CommonOrder::getUserId,userId) | |||
| .eq(CommonOrder::getPid,"0") | |||
| .page(page); | |||
| //循环得到下级集合 | |||
| for (CommonOrder commonOrder : pageList.getRecords()) { | |||
| //查询下级 | |||
| List<CommonOrder> children = commonOrderService | |||
| .lambdaQuery() | |||
| .eq(CommonOrder::getPid,commonOrder.getId()) | |||
| .list(); | |||
| commonOrder.setCommonOrderList(children); | |||
| } | |||
| return Result.OK("历史订单列表",pageList); | |||
| } | |||
| @Override | |||
| public Result<?> getOrderDetail(String token,String orderId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonOrder commonOrder = commonOrderService.getById(orderId); | |||
| List<CommonOrder> children = commonOrderService | |||
| .lambdaQuery() | |||
| .eq(CommonOrder::getPid,commonOrder.getId()) | |||
| .list(); | |||
| commonOrder.setCommonOrderList(children); | |||
| return Result.OK("订单详情",commonOrder); | |||
| } | |||
| @Override | |||
| public Result<?> clickQualityReport(String token,String orderId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonOrder commonOrder = commonOrderService.getById(orderId); | |||
| return Result.OK("质检详情",commonOrder); | |||
| } | |||
| //获取员工信息列表 | |||
| @Override | |||
| public Result<?> getMyTeamList(String token,String name,PageBean pageBean) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<HanHaiMember> page = new Page<>(pageBean.getPageNo(), pageBean.getPageSize()); | |||
| IPage<HanHaiMember> pageList = hanHaiMemberService | |||
| .lambdaQuery() | |||
| //姓名不为空则模糊搜索 | |||
| .like(name != null, HanHaiMember::getName, name) | |||
| .eq(HanHaiMember::getRole, 1) | |||
| .page(page); | |||
| return Result.OK("员工列表", pageList); | |||
| } | |||
| //查看员工详情信息 | |||
| @Override | |||
| public Result<?> getMemberInfo(String token, String id) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| HanHaiMember memberInfo = hanHaiMemberService.getById(id); | |||
| return Result.OK("员工详情", memberInfo); | |||
| } | |||
| @Override | |||
| public Result<?> removeMember(String token, String id) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| HanHaiMember memberInfo = hanHaiMemberService.getById(id); | |||
| memberInfo.setRole(0); | |||
| hanHaiMemberService.updateById(memberInfo); | |||
| return Result.OK("拉黑成功"); | |||
| } | |||
| } | |||
| @ -1,183 +0,0 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import com.baomidou.mybatisplus.core.metadata.IPage; | |||
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | |||
| import org.apache.commons.lang3.StringUtils; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.api.service.AppletMyBookService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonBook.entity.CommonBook; | |||
| import org.jeecg.modules.commonBookNovel.entity.CommonBookNovel; | |||
| import org.jeecg.modules.commonBookNovel.service.ICommonBookNovelService; | |||
| import org.jeecg.modules.commonMyBook.entity.CommonMyBook; | |||
| import org.jeecg.modules.commonMyBook.service.ICommonMyBookService; | |||
| import org.jeecg.modules.commonShop.entity.CommonShop; | |||
| import org.jeecg.modules.commonShop.service.ICommonShopService; | |||
| import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; | |||
| import org.springframework.beans.factory.annotation.Autowired; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| import java.util.Date; | |||
| @Service | |||
| public class AppletMyBookServiceImpl implements AppletMyBookService { | |||
| //权限 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Autowired | |||
| private ICommonShopService commonShopService; | |||
| @Autowired | |||
| private ICommonBookNovelService commonBookNovelService; | |||
| //获取我的作品带分页 | |||
| @Override | |||
| public Result<?> getMyShopPage(String token, PageBean pageBean){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<CommonShop> page = new Page<>(pageBean.getPageNo(), pageBean.getPageSize()); | |||
| IPage<CommonShop> pageList = commonShopService | |||
| .lambdaQuery() | |||
| .eq(CommonShop::getUserId,hanHaiMember.getId()) | |||
| .orderByDesc(CommonShop::getCreateTime) | |||
| .page(page); | |||
| return Result.OK("我的书架",pageList); | |||
| } | |||
| //添加作品或者修改作品 | |||
| @Override | |||
| public Result<?> saveOrUpdateShop(String token, CommonShop commonShop) { | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| //查询你是否是作者 | |||
| if(member.getIsUser().equals("N")){ | |||
| return Result.error("您不是作者,无法添加作品,请完善笔名简介"); | |||
| } | |||
| commonShop.setUserId(member.getId()); | |||
| if(StringUtils.isEmpty(commonShop.getId())){ | |||
| commonShop.setToolStatus(0); | |||
| commonShop.setStatus(0);//审核状态 | |||
| commonShop.setBookStatus(0); | |||
| commonShop.setQmNum(0); | |||
| commonShop.setTuiNum(0); | |||
| commonShop.setService("大家都在读"); | |||
| commonShop.setCreateTime(new Date()); | |||
| commonShopService.save(commonShop); | |||
| }else{ | |||
| commonShopService.updateById(commonShop); | |||
| } | |||
| return Result.ok("保存成功"); | |||
| } | |||
| //获取我的小说章节列表带分页 | |||
| @Override | |||
| public Result<?> getMyShopNovelPage(String token, String bookId,Integer status,Integer reverse, PageBean pageBean){ | |||
| HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<CommonBookNovel> page = new Page<>(pageBean.getPageNo(),pageBean.getPageSize()); | |||
| IPage<CommonBookNovel> commonBookNovels = commonBookNovelService | |||
| .lambdaQuery() | |||
| .eq(CommonBookNovel::getBookId,bookId) | |||
| .eq(CommonBookNovel::getStatus,status) | |||
| .page(page); | |||
| if(reverse == 0){ | |||
| commonBookNovels = commonBookNovelService | |||
| .lambdaQuery() | |||
| .select( | |||
| CommonBookNovel::getId, | |||
| CommonBookNovel::getBookId, | |||
| CommonBookNovel::getTitle, | |||
| CommonBookNovel::getSort, | |||
| CommonBookNovel::getStatus, | |||
| CommonBookNovel::getCreateTime | |||
| ) | |||
| .eq(CommonBookNovel::getBookId,bookId) | |||
| .eq(CommonBookNovel::getStatus,status) | |||
| .orderByAsc(CommonBookNovel::getCreateTime) | |||
| .page(page); | |||
| }else{ | |||
| commonBookNovels = commonBookNovelService | |||
| .lambdaQuery() | |||
| .eq(CommonBookNovel::getBookId,bookId) | |||
| .eq(CommonBookNovel::getStatus,status) | |||
| .orderByDesc(CommonBookNovel::getCreateTime) | |||
| .page(page); | |||
| } | |||
| return Result.OK("我的小说章节列表",commonBookNovels); | |||
| } | |||
| //增加或者修改作品章节 | |||
| @Override | |||
| public Result<?> saveOrUpdateShopNovel(String token, CommonBookNovel commonBookNovel){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| //书籍标识不能为空 | |||
| if(StringUtils.isEmpty(commonBookNovel.getBookId())){ | |||
| return Result.error("书籍标识不能为空"); | |||
| } | |||
| //查询书籍是否存在 | |||
| CommonShop commonShop = commonShopService.lambdaQuery() | |||
| .eq(CommonShop::getId,commonBookNovel.getBookId()) | |||
| .eq(CommonShop::getUserId,hanHaiMember.getId()) | |||
| .one(); | |||
| if(commonShop==null){ | |||
| return Result.error("书籍不存在或者该书籍不是您的作品无法更新"); | |||
| } | |||
| if(commonBookNovel.getStatus() == null){ | |||
| //章节状态不能为空 | |||
| return Result.error("章节状态不能为空"); | |||
| } | |||
| commonBookNovel.setBookId(commonShop.getId()); | |||
| commonBookNovel.setUserId(hanHaiMember.getId()); | |||
| if(StringUtils.isEmpty(commonBookNovel.getId())){ | |||
| commonBookNovelService.save(commonBookNovel); | |||
| }else{ | |||
| commonBookNovelService.updateById(commonBookNovel); | |||
| } | |||
| return Result.OK("编辑成功!"); | |||
| } | |||
| //删除我的作品 | |||
| @Override | |||
| public Result<?> deleteMyShop(String token, String bookId) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| commonShopService.removeById(bookId); | |||
| return Result.OK("删除成功!"); | |||
| } | |||
| //多选删除我的作品 | |||
| @Override | |||
| public Result<?> deleteMyShopList(String token, String bookIds) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| String[] bookIdArray = bookIds.split(","); | |||
| for (String bookId : bookIdArray) { | |||
| commonShopService.removeById(bookId); | |||
| } | |||
| return Result.OK("删除成功!"); | |||
| } | |||
| //删除我的作品章节 | |||
| @Override | |||
| public Result<?> deleteMyShopNovel(String token, String bookId, String novelId) { | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| commonBookNovelService.removeById(novelId); | |||
| return Result.OK("删除成功!"); | |||
| } | |||
| } | |||
| @ -0,0 +1,72 @@ | |||
| package org.jeecg.api.service.impl; | |||
| import com.baomidou.mybatisplus.core.metadata.IPage; | |||
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | |||
| import org.jeecg.api.bean.PageBean; | |||
| import org.jeecg.api.service.AppletOrderTeamService; | |||
| import org.jeecg.common.api.vo.Result; | |||
| import org.jeecg.config.shiro.ShiroRealm; | |||
| import org.jeecg.modules.commonMoneyLog.service.ICommonMoneyLogService; | |||
| import org.jeecg.modules.commonOrder.entity.CommonOrder; | |||
| import org.jeecg.modules.commonOrder.service.ICommonOrderService; | |||
| import org.jeecg.modules.commonShop.service.ICommonShopService; | |||
| import org.jeecg.modules.commonText.service.ICommonTextService; | |||
| import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; | |||
| import org.springframework.beans.factory.annotation.Autowired; | |||
| import org.springframework.stereotype.Service; | |||
| import javax.annotation.Resource; | |||
| @Service | |||
| public class AppletOrderTeamServiceImpl implements AppletOrderTeamService { | |||
| //权限 | |||
| @Resource | |||
| private ShiroRealm shiroRealm; | |||
| @Autowired | |||
| private ICommonOrderService commonOrderService; | |||
| @Autowired | |||
| private ICommonTextService commonTextService; | |||
| //管理员:订单列表带分页搜索 | |||
| @Override | |||
| public Result<?> getOrderListPage(String token, Integer status, PageBean pageBean){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| Page<CommonOrder> page = new Page<>(pageBean.getPageNo(),pageBean.getPageSize()); | |||
| IPage<CommonOrder> pageList = commonOrderService | |||
| .lambdaQuery() | |||
| //订单状态不为空则搜索 | |||
| .eq(status != null,CommonOrder::getStatus,status) | |||
| .page(page); | |||
| return Result.OK("订单列表",pageList); | |||
| } | |||
| @Override | |||
| public Result<?> getOrderDetail(String token, String orderId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonOrder commonOrder = commonOrderService.getById(orderId); | |||
| return Result.OK("订单详情",commonOrder); | |||
| } | |||
| @Override | |||
| public Result<?> passOrder(String token, String orderId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonOrder commonOrder = commonOrderService.getById(orderId); | |||
| commonOrder.setStatus(1); | |||
| commonOrderService.updateById(commonOrder); | |||
| return Result.OK("订单审核通过"); | |||
| } | |||
| @Override | |||
| public Result<?> rejectOrder(String token, String orderId){ | |||
| HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); | |||
| CommonOrder commonOrder = commonOrderService.getById(orderId); | |||
| commonOrder.setStatus(2); | |||
| commonOrderService.updateById(commonOrder); | |||
| return Result.OK("订单审核拒绝"); | |||
| } | |||
| @Override | |||
| public Result<?> submitQualityInfo(){ | |||
| return Result.OK("提交成功"); | |||
| } | |||
| } | |||