package com.matrix.system.shopXcx.api.action; import com.matrix.biz.bean.BizUser; import com.matrix.biz.service.BizUserService; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.core.pojo.AjaxResult; import com.matrix.core.pojo.PaginationVO; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.system.shopXcx.bean.ShopScoreExchange; import com.matrix.system.shopXcx.bean.ShopScoreRecord; import com.matrix.system.shopXcx.dao.ShopScoreExchangeDao; import com.matrix.system.shopXcx.dao.ShopScoreRecordDao; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import java.util.List; /** * @description 用户积分控制器 * @author jyy * @date 2019-08-09 15:10 */ @Controller @RequestMapping(value="/wxapi/shopScoreRecord") @CrossOrigin(origins = "*", maxAge = 3600) public class WxShopScoreAction { @Autowired private ShopScoreRecordDao shopScoreRecordDao; @Autowired private ShopScoreExchangeDao shopScoreExchangeDao; @Autowired private RedisUserLoginUtils redisUserLoginUtils; @Autowired private BizUserService bizUserService; /** * 查询我的获得积分列表 * @return */ @RequestMapping(value = "/getRecordList") @ResponseBody public AjaxResult getRecordList(@RequestBody PaginationVO pageVo) { pageVo.setSort("create_time"); pageVo.setOrder("desc"); BizUser loginBizUser = redisUserLoginUtils.getLoginUser(BizUser.class); ShopScoreRecord params = new ShopScoreRecord(); params.setBeneficiaryId(loginBizUser.getOpenId()); List dataList = shopScoreRecordDao.selectInPage(params, pageVo); int total = shopScoreRecordDao.selectTotalRecord(params); AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList, total); //查询用户总积分 BizUser user = bizUserService.findById(loginBizUser.getUserId()); Integer totalScore = 0; if (user != null && user.getTotalScore() != null) { totalScore = user.getTotalScore(); } result.putInMap("totalScore", totalScore); //查询下级总人数 BizUser peopleSumParams = new BizUser(); peopleSumParams.setParentOpenId(loginBizUser.getOpenId()); int peopleSum = bizUserService.findTotal(peopleSumParams); result.putInMap("peopleSum", peopleSum); return result; } /** * 查询我的积分兑换列表 * @return */ @RequestMapping(value = "/getChangeRecordList") @ResponseBody public AjaxResult getChangeRecordList(@RequestBody PaginationVO pageVo) { //不分页 pageVo.setOffset(null); pageVo.setLimit(null); //按生成时间倒序排列 pageVo.setSort("create_time"); pageVo.setOrder("desc"); BizUser loginBizUser = redisUserLoginUtils.getLoginUser(BizUser.class); ShopScoreExchange params = new ShopScoreExchange(); params.setUserId(loginBizUser.getOpenId()); List dataList = shopScoreExchangeDao.selectInPage(params, pageVo); int total = shopScoreExchangeDao.selectTotalRecord(params); AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList, total); //查询用户当前积分 BizUser user = bizUserService.findById(loginBizUser.getUserId()); Integer currentScore = 0; if (user != null && user.getCurrentScore() != null) { currentScore = user.getCurrentScore(); } result.putInMap("currentScore", currentScore); return result; } }