package com.nuvole.four.controller.pc;
|
|
|
import cn.hutool.core.util.StrUtil;
|
import com.github.pagehelper.PageHelper;
|
import com.nuvole.base.domain.SysUser;
|
import com.nuvole.common.domain.result.CommonResult;
|
import com.nuvole.common.domain.result.PageBean;
|
import com.nuvole.four.client.ShopServiceClient;
|
import com.nuvole.four.contants.Contants;
|
import com.nuvole.four.controller.BaseController;
|
import com.nuvole.four.domain.ActivityDistributeRecord;
|
import com.nuvole.four.domain.ActivityFee;
|
import com.nuvole.four.domain.SysOrg;
|
import com.nuvole.four.domain.dto.ActivityFeeDetailDto;
|
import com.nuvole.four.domain.query.ActivityFeeQuery;
|
import com.nuvole.four.service.ActivityFeeService;
|
import com.nuvole.four.service.impl.ActivityDistributeRecordServiceImpl;
|
import com.nuvole.four.service.impl.SysOrgServiceImpl;
|
import com.nuvole.four.util.SystemUtil;
|
import com.nuvole.util.CommonUtil;
|
import io.swagger.annotations.*;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.transaction.annotation.EnableTransactionManagement;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @Description 费率补贴活动管理
|
* @Author dqh
|
* @Date 2024-04-13 21:33:08
|
*/
|
@Api(value = "费率补贴活动管理接口", tags = "费率补贴活动管理接口")
|
@EnableTransactionManagement
|
@RestController
|
@RequestMapping("/v1/four/pc/acitivity/fee")
|
@RequiredArgsConstructor
|
public class ActivityFeeController extends BaseController {
|
|
private final ActivityFeeService activityFeeService;
|
private final SysOrgServiceImpl sysOrgService;
|
private final ActivityDistributeRecordServiceImpl activityDistributeRecordService;
|
private final ShopServiceClient shopServiceClient;
|
|
|
/**
|
* 方法描述:查询费率补贴活动列表
|
*
|
* @date 2024-04-13 21:46
|
**/
|
@ApiOperation(value = "查询列表", notes = "查询列表")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "AcitivityFeeQuery") })
|
@GetMapping("/getList")
|
public CommonResult<PageBean> getList(@ApiParam(name = "pageNumber", value = "分页页码", required = true) Integer pageNumber,
|
@ApiParam(name = "pageSize", value = "每页展示数", required = true) Integer pageSize) {
|
ActivityFeeQuery copy = CommonUtil.getObjFromReq(ActivityFeeQuery.class);
|
ActivityFeeQuery query = new ActivityFeeQuery();
|
BeanUtils.copyProperties(copy, query);
|
PageHelper.startPage(pageNumber, pageSize);
|
|
PageHelper.orderBy("create_time desc");
|
List<ActivityFee> list = activityFeeService.getList(query);
|
CommonResult result = new CommonResult<>(new PageBean(list));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述: 费率补贴活动添加
|
*
|
* @date 2024-04-13 21:46
|
**/
|
@ApiOperation(value = "添加", notes = "添加")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "AcitivityFee") })
|
@PostMapping("/add")
|
public CommonResult<Integer> add() {
|
ActivityFee copy = CommonUtil.getObjFromReq(ActivityFee.class);
|
ActivityFee activityFee = new ActivityFee();
|
BeanUtils.copyProperties(copy, activityFee);
|
|
CommonResult result = new CommonResult<>(activityFeeService.addSelective(activityFee));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述:根据id查询分配预算详情
|
*
|
* @date 2024-04-13 22:02
|
**/
|
@ApiOperation(value = "查询分配预算详情", notes = "根据id查询分配预算详情")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "id", value = "主键id") })
|
@GetMapping("/get")
|
public CommonResult<ActivityFee> get(Long id) {
|
CommonResult result = new CommonResult();
|
result = new CommonResult<>(activityFeeService.get(id));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述:查询分配额度信息
|
*
|
**/
|
@ApiOperation(value = "查询分配额度信息", notes = "查询分配额度信息")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "id", value = "主键id") })
|
@GetMapping("/getFeeMsg")
|
public CommonResult getFeeMsg(Long id) {
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
CommonResult result = new CommonResult();
|
//super用户直接查询活动本身
|
if(user.getLoginName().equalsIgnoreCase("super") && user.getOrgId() == null){
|
return new CommonResult(activityFeeService.get(id));
|
}
|
if(user.getOrgId() != null){
|
SysOrg sysOrg = sysOrgService.getById(user.getOrgId());
|
//查询机构分配的预算额度
|
ActivityDistributeRecord record = activityDistributeRecordService.getFeeByCondition(id, sysOrg.getId());
|
result = new CommonResult<>(record);
|
if(record == null){
|
//查询活动本身的预算额度
|
result = new CommonResult<>(activityDistributeRecordService.getActivityFeeByIdAndOrgId(id, sysOrg.getId()));
|
}
|
}
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述: 查询活动详情-活动数据
|
*
|
* @date 2024-04-15 13:17
|
**/
|
@ApiOperation(value = "查询活动详情-活动数据", notes = "查询活动详情-活动数据")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "id", value = "主键id") })
|
@GetMapping("/getDetail")
|
public CommonResult<ActivityFeeDetailDto> getActivityFeeDetail(Long id) {
|
ActivityFeeDetailDto detailDto = activityFeeService.getActivityFeeDetail(id);
|
return new CommonResult<>(detailDto);
|
}
|
|
/**
|
* 方法描述: 查询活动详情-商户活动数据
|
*
|
* @date 2024-04-15 16:47
|
**/
|
@ApiOperation(value = "查询活动详情-商户活动数据", notes = "查询活动详情-商户活动数据")
|
@GetMapping("/merchantActivityList")
|
public CommonResult merchantActivityList(
|
@ApiParam(name = "orgCode", value = "机构code") String orgCode,
|
@ApiParam(name = "channelId", value = "通道id") Long channelId,
|
@ApiParam(name = "activityId", value = "活动ID", required = true) Long activityId,
|
@ApiParam(name = "startDate", value = "交易时间") Date startDate,
|
@ApiParam(name = "endDate", value = "交易结束时间") Date endDate,
|
@ApiParam(name = "pageNumber", value = "分页页码", required = true) Integer pageNumber,
|
@ApiParam(name = "pageSize", value = "每页展示数", required = true) Integer pageSize) {
|
if(activityId == null){
|
throw new IllegalArgumentException("活动ID不能为空");
|
}
|
if(StrUtil.isBlank(orgCode)){
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
orgCode = user.getOrgCode();
|
}
|
CommonResult<PageBean<Map>> mapResult = shopServiceClient.merchantActivityList(orgCode, channelId, activityId, startDate,endDate, pageNumber, pageSize);
|
return mapResult;
|
}
|
|
/**
|
* 方法描述: 查询活动详情-商户活动数据-数据汇总
|
**/
|
@ApiOperation(value = "查询活动详情-商户活动数据-数据汇总", notes = "查询活动详情-商户活动数据-数据汇总")
|
@GetMapping("/merchantActivityCollect")
|
public CommonResult merchantActivityCollect(
|
@ApiParam(name = "orgCode", value = "机构code") String orgCode,
|
@ApiParam(name = "channelId", value = "通道id") Long channelId,
|
@ApiParam(name = "activityId", value = "活动ID", required = true) Long activityId,
|
@ApiParam(name = "startDate", value = "交易开始时间") Date startDate,
|
@ApiParam(name = "endDate", value = "交易结束时间") Date endDate) {
|
if(activityId == null){
|
throw new IllegalArgumentException("活动ID不能为空");
|
}
|
if(StrUtil.isBlank(orgCode)){
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
orgCode = user.getOrgCode();
|
}
|
CommonResult<Map> mapResult = shopServiceClient.merchantActivityCollect(orgCode, channelId, activityId, startDate,endDate);
|
return mapResult;
|
}
|
|
/**
|
* 方法描述: 编辑费率补贴活动
|
*
|
* @date 2024-04-13 22:01
|
**/
|
@ApiOperation(value = "修改", notes = "修改")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "AcitivityFee") })
|
@PostMapping("/upd")
|
public CommonResult<Integer> upd() {
|
ActivityFee copy = CommonUtil.getObjFromReq(ActivityFee.class);
|
ActivityFee activityFee = new ActivityFee();
|
BeanUtils.copyProperties(copy, activityFee);
|
|
CommonResult result = new CommonResult<>(activityFeeService.editSelective(activityFee));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述: 删除费率补贴活动
|
*
|
* @date 2024-04-13 22:01
|
**/
|
@ApiOperation(value = "删除", notes = "删除")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "id", value = "主键id") })
|
@PostMapping("/del")
|
public CommonResult<Integer> del(Long id) {
|
CommonResult result = new CommonResult<>(activityFeeService.del(id));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述: 开始/停止
|
* 同步停止活动表、商户活动表、机构预算分配表
|
*
|
* @date 2024-04-14 15:55
|
**/
|
@ApiOperation(value = "开始/停止", notes = "开始/停止")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "id", value = "主键id"),
|
@ApiImplicitParam(name = "status", value = "状态;1=开始 2=停止(结束)")})
|
@PostMapping("/startOrStop")
|
public CommonResult<Integer> startOrStop(Long id,Integer status) {
|
CommonResult result = new CommonResult<>(activityFeeService.startOrStop(id,status));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
}
|
