package com.matrix.system.padApi.action;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.matrix.component.asyncmessage.AsyncMessageManager;
|
import com.matrix.core.constance.MatrixConstance;
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.core.pojo.PaginationVO;
|
import com.matrix.core.tools.DateUtil;
|
import com.matrix.core.tools.StringUtils;
|
import com.matrix.core.tools.WebUtil;
|
import com.matrix.system.common.bean.CustomerDataDictionary;
|
import com.matrix.system.common.bean.SysUsers;
|
import com.matrix.system.common.constance.AppConstance;
|
import com.matrix.system.common.dao.CustomerDataDictionaryDao;
|
import com.matrix.system.common.service.SysUsersService;
|
import com.matrix.system.constance.Dictionary;
|
import com.matrix.system.hive.action.BaseController;
|
import com.matrix.system.hive.action.util.QueryUtil;
|
import com.matrix.system.hive.bean.*;
|
import com.matrix.system.hive.dao.*;
|
import com.matrix.system.hive.pojo.CzXkVo;
|
import com.matrix.system.hive.service.*;
|
import com.matrix.system.padApi.dto.*;
|
import com.matrix.system.score.dao.ScoreUseRecordDao;
|
import com.matrix.system.score.dao.ScoreVipDetailDao;
|
import com.matrix.system.shopXcx.api.dto.ScoreFlowDto;
|
import com.matrix.system.shopXcx.api.vo.ScoreUseRecordVo;
|
import com.matrix.system.shopXcx.mqTask.AsyncMessageRouting;
|
import com.matrix.system.wechart.templateMsg.UniformMsgParam;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiResponse;
|
import io.swagger.annotations.ApiResponses;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@CrossOrigin(origins = "*")
|
@Api(value = "PadVipAction", tags = "pad端Vip客户请求")
|
@RestController
|
@RequestMapping(value = "/api/pad/vipInfo")
|
public class PadVipAction extends BaseController {
|
|
@Resource
|
private SysVipInfoService vipInfoService;
|
@Resource
|
private SysOrderService sysOrderService;
|
@Autowired
|
ShoppingGoodsDao shoppingGoodsDao;
|
@Autowired
|
private ScoreVipDetailDao scoreVipDetailDao;
|
@Resource
|
private MoneyCardUseService cardUseService;
|
@Autowired
|
private MoneyCardUseDao moneyCardUseDao;
|
@Autowired
|
private SysVipLabelDao sysVipLabelDao;
|
@Resource
|
private SysOrderService orderService;
|
@Autowired
|
private AsyncMessageManager asyncMessageManager;
|
@Autowired
|
private SysUsersService sysUsersService;
|
@Autowired
|
private CustomerDataDictionaryDao dataDictionaryDao;
|
|
/**
|
* 显示所有的会员信息
|
*/
|
@ApiOperation(value = "显示所有的会员信息列表", notes = "显示所有的会员信息列表")
|
@PostMapping(value = "/showVipInfoList")
|
public AjaxResult showList(@RequestBody @Validated PadVipListDto padVipListDto) {
|
|
SysVipInfo vipInfo = new SysVipInfo();
|
QueryUtil.setQueryLimit(vipInfo);
|
String queryKey = padVipListDto.getQueryKey();
|
if(StrUtil.isNotEmpty(queryKey)){
|
vipInfo.setPadQueryKey(queryKey);
|
}
|
int offset = (padVipListDto.getPageNum() - 1) * padVipListDto.getPageSize();
|
int limit = padVipListDto.getPageSize();
|
PaginationVO pageVo = new PaginationVO();
|
pageVo.setOffset(offset);
|
pageVo.setLimit(limit);
|
|
//默认排序
|
if (StringUtils.isBlank(pageVo.getSort())) {
|
pageVo.setSort("create_time");
|
}
|
if (StringUtils.isBlank(pageVo.getOrder())) {
|
pageVo.setOrder("desc");
|
}
|
|
return showList(vipInfoService, vipInfo, pageVo);
|
}
|
|
/**
|
* 添加或修改会员信息
|
*/
|
@ApiOperation(value = "添加或修改会员信息", notes = "添加或修改会员信息")
|
@PostMapping(value = "/addOrModify")
|
public AjaxResult addOrModify(@RequestBody SysVipInfo vipInfo) {
|
if (vipInfo.getId() != null) {
|
return modify(vipInfoService, vipInfo, "会员信息");
|
} else {
|
vipInfo.setVipState(Dictionary.VIP_STATE_HY);
|
SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
if(vipInfo.getShopId()==null){
|
vipInfo.setShopId(users.getShopId());
|
}
|
if(vipInfo.getCompanyId()==null){
|
vipInfo.setCompanyId(users.getCompanyId());
|
}
|
return add(vipInfoService, vipInfo, "会员信息");
|
}
|
}
|
|
@Resource
|
private SysVipLevelService cardLevelService;
|
|
@ApiOperation(value = "显示所有的会员卡等级信息,不分页", notes = "显示所有的会员卡等级信息,不分页")
|
@GetMapping(value = "/all")
|
public AjaxResult all() {
|
SysVipLevel sysVipLevel = new SysVipLevel();
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, cardLevelService.findByModel(sysVipLevel), null);
|
}
|
|
@Resource
|
private SysShopInfoService shopInfoService; // 店铺Service
|
|
@ApiOperation(value = "所属门店,不分页", notes = "所属门店,不分页")
|
@GetMapping(value = "/findShopByRole")
|
public AjaxResult findShopByRole() {
|
SysUsers user = getMe();
|
SysShopInfo shopInfo = new SysShopInfo();
|
shopInfo.setCompanyId(user.getCompanyId());
|
if(!user.getSuUserType().equals(AppConstance.USER_TYPE_ADMIN) && !user.getShopRole().equals(Dictionary.FLAG_YES_Y)){
|
shopInfo.setId(user.getShopId());
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, shopInfoService.findByModel(shopInfo), null);
|
}
|
|
/**
|
* 查看会员信息
|
*/
|
@SuppressWarnings("unchecked")
|
@ApiOperation(value = "查看会员信息", notes = "查看会员信息")
|
@GetMapping(value = "/showVipInfo/{phone}")
|
public AjaxResult findByModel(@PathVariable("phone")String phone) {
|
List<SysVipInfo> vips = vipInfoService.findByVipNoOrTel(phone);
|
if (vips.size() > 0) {
|
vips.get(0).setPointAll(scoreVipDetailDao.selectUserTotalScore(vips.get(0).getId()));
|
vips.get(0).setSysOrder(sysOrderService.findSysOrderTjByVipId(vips.get(0).getId()));
|
vips.get(0).setLevelCard(cardUseService.findByVipId(vips.get(0).getId()));
|
vips.get(0).setLabels(sysVipLabelDao.selectByVipId(vips.get(0).getId()));
|
vips.get(0).setAge(DateUtil.getAgeForBirthDay(vips.get(0).getBirthday1()));
|
vips.get(0).setBalance(moneyCardUseDao.selectVipCardTotalMoney(vips.get(0).getId()));
|
vips.get(0).setArrears(sysOrderService.findVipArrearsByVipId(vips.get(0).getId()));
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, vips, 0);
|
return result;
|
} else {
|
return AjaxResult.buildFailInstance("未查到询客户信息");
|
}
|
}
|
|
@Resource
|
private SysProjUseService projUseService;
|
|
@ApiOperation(value = "项目使用情况", notes = "")
|
@PostMapping(value = "/projectList")
|
public AjaxResult showTc(@RequestBody PadProjectDto padProjectDto) {
|
|
int offset = (padProjectDto.getPageNum() - 1) * padProjectDto.getPageSize();
|
int limit = padProjectDto.getPageSize();
|
PaginationVO pageVo = new PaginationVO();
|
pageVo.setOffset(offset);
|
pageVo.setLimit(limit);
|
|
SysProjUse sysProjUse = new SysProjUse();
|
sysProjUse.setType(Dictionary.SHOPPING_GOODS_TYPE_XM);
|
sysProjUse.setTaocanId(-1L);
|
sysProjUse.setVipId(padProjectDto.getVipId());
|
if(StrUtil.isNotEmpty(padProjectDto.getState())){
|
sysProjUse.setStatus(padProjectDto.getState());
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS,
|
projUseService.findInPage(sysProjUse, pageVo), projUseService.findTotal(sysProjUse));
|
}
|
|
/**
|
* 会员充值卡的列表显示
|
*/
|
@ApiOperation(value = "充值卡的列表显示", notes = "")
|
@PostMapping(value = "/showVipMoneyCardList")
|
public AjaxResult showVipMoneyCardList(@RequestBody PadVipCardDto padVipCardDto) {
|
|
int offset = (padVipCardDto.getPageNum() - 1) * padVipCardDto.getPageSize();
|
int limit = padVipCardDto.getPageSize();
|
PaginationVO pageVo = new PaginationVO();
|
pageVo.setOffset(offset);
|
pageVo.setLimit(limit);
|
|
MoneyCardUse moneyCardUse = new MoneyCardUse();
|
moneyCardUse.setVipId(padVipCardDto.getVipId());
|
if(StrUtil.isNotEmpty(padVipCardDto.getState())){
|
moneyCardUse.setStatus(padVipCardDto.getState());
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, cardUseService.findVipCardUseInPage(
|
moneyCardUse, pageVo), cardUseService.findTotalVipCardUse(moneyCardUse));
|
}
|
|
|
@Resource
|
private SysProjUseService sysProjUseService;
|
|
@ApiOperation(value = "套餐使用情况", notes = "")
|
@PostMapping(value = "/tcList")
|
public AjaxResult showTc(@RequestBody PadTcDto padTcDto) {
|
int offset = (padTcDto.getPageNum() - 1) * padTcDto.getPageSize();
|
int limit = padTcDto.getPageSize();
|
PaginationVO pageVo = new PaginationVO();
|
pageVo.setOffset(offset);
|
pageVo.setLimit(limit);
|
|
SysProjUse sysProjUse = new SysProjUse();
|
sysProjUse.setType(Dictionary.SHOPPING_GOODS_TYPE_TC);
|
sysProjUse.setVipId(padTcDto.getVipId());
|
if(StrUtil.isNotEmpty(padTcDto.getState())){
|
sysProjUse.setStatus(padTcDto.getState());
|
}
|
List<SysProjUse> projUseList =sysProjUseService.findInPage(sysProjUse,pageVo);
|
//设置套餐中的项目
|
projUseList.forEach(taocanProjUse -> {
|
taocanProjUse.setTaocanProjUse(sysProjUseService.selectTaocanProjUse(taocanProjUse.getId(),sysProjUse.getStatus()));
|
});
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, projUseList, sysProjUseService.findTotal(sysProjUse));
|
}
|
|
|
@Autowired
|
private SysVipInfoDao sysVipInfoDao;
|
|
@Autowired
|
private ScoreUseRecordDao scoreUseRecordDao;
|
|
@ApiOperation(value = "积分流水记录", notes = "")
|
@PostMapping(value = "/flowList")
|
@ApiResponses({
|
@ApiResponse(code = 200, message = "ok", response = ScoreUseRecordVo.class)
|
})
|
public AjaxResult getFlowList(@RequestBody ScoreFlowDto scoreFlowDto) {
|
SysVipInfo vipInfo = sysVipInfoDao.selectById(scoreFlowDto.getVipId());
|
scoreFlowDto.setVipId(vipInfo.getId());
|
Page<ScoreUseRecordVo> page=new Page<>(scoreFlowDto.getPageNum(),scoreFlowDto.getPageSize());
|
IPage<ScoreUseRecordVo> shopScoreRecord = scoreUseRecordDao.selectFlowList(page,scoreFlowDto);
|
AjaxResult result=AjaxResult.buildSuccessInstance(shopScoreRecord.getRecords(),shopScoreRecord.getTotal());
|
return result;
|
}
|
|
|
|
@Autowired
|
private SysSkinCheckRecordDao sysSkinCheckRecordDao;
|
|
@ApiOperation(value = "皮肤检测记录", notes = "")
|
@PostMapping(value = "/skinList")
|
public @ResponseBody AjaxResult showList(@RequestBody PadSkinDto padSkinDto) {
|
|
int offset = (padSkinDto.getPageNum() - 1) * padSkinDto.getPageSize();
|
int limit = padSkinDto.getPageSize();
|
PaginationVO pageVo = new PaginationVO();
|
pageVo.setOffset(offset);
|
pageVo.setLimit(limit);
|
|
SysSkinCheckRecord sysSkinCheckRecord = new SysSkinCheckRecord();
|
sysSkinCheckRecord.setUserId(padSkinDto.getVipId());
|
List<SysSkinCheckRecord> dataList = sysSkinCheckRecordDao.selectInPage(sysSkinCheckRecord, pageVo);
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList,
|
sysSkinCheckRecordDao.selectTotalRecord(sysSkinCheckRecord));
|
return result;
|
}
|
|
/**
|
* 充值 查询门店所有员工
|
*/
|
@ApiOperation(value = "充值 查询门店所有员工", notes = "充值 查询门店所有员工")
|
@GetMapping(value = "/shopAll")
|
public AjaxResult shopAll() {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, sysUsersService.findByRoleName(true, null));
|
}
|
/**
|
* 充值 查询业绩类型
|
*/
|
@ApiOperation(value = "充值 查询业绩类型", notes = "充值 查询业绩类型")
|
@GetMapping(value = "getListByParentCode/{parentCode}")
|
public AjaxResult getListByParentCode(@PathVariable String parentCode) {
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
|
List<CustomerDataDictionary> list = dataDictionaryDao.selectByParentCode(parentCode, user.getCompanyId());
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, list, list.size());
|
}
|
|
/**
|
* 充值 查询当前登录人
|
*/
|
@ApiOperation(value = "充值 查询当前登录人", notes = "充值 查询当前登录人")
|
@GetMapping(value = "getLoginUser")
|
public AjaxResult getLoginUser() {
|
AjaxResult result = AjaxResult.buildSuccessInstance("");
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
result.putInMap("user", user);
|
return result;
|
}
|
|
/**
|
* 充值
|
*/
|
@ApiOperation(value = "充值", notes = "充值")
|
@PostMapping(value = "/cz")
|
public AjaxResult cz(@RequestBody CzXkVo czVo) {
|
SysOrder order= orderService.moneyCardCz(czVo);
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, "充值成功");
|
|
//发送微信公众号提醒
|
UniformMsgParam uniformMsgParam=new UniformMsgParam(order.getCompanyId(),UniformMsgParam.GZH_CZCG);
|
uniformMsgParam.put("orderId",order.getId());
|
asyncMessageManager.sendMsg(AsyncMessageRouting.SEND_UNIFORM_TEMPLATE_MSG ,uniformMsgParam);
|
|
result.putInMap("orderId",order.getId());
|
return result;
|
}
|
|
}
|
