package com.nuvole.four.controller.pc;
|
|
|
import cn.hutool.core.util.StrUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
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.ActivityShopRecord;
|
import com.nuvole.four.domain.ChannelInfo;
|
import com.nuvole.four.domain.dto.ActivityShopRecordDto;
|
import com.nuvole.four.domain.params.ActivityShopRecordParam;
|
import com.nuvole.four.domain.query.ActivityShopRecordQuery;
|
import com.nuvole.four.service.ActivityShopRecordService;
|
import com.nuvole.four.service.ChannelInfoService;
|
import com.nuvole.four.util.SystemUtil;
|
import com.nuvole.util.CommonUtil;
|
import com.walker.infrastructure.utils.CollectionUtils;
|
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.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description 活动补贴—上报商户管理
|
* @Author dqh
|
* @Date 2024-04-13 21:39:14
|
*/
|
@Api(value = "活动补贴—上报商户管理接口", tags = "活动补贴—上报商户管理接口")
|
@EnableTransactionManagement
|
@RestController
|
@RequestMapping("/v1/four/pc/activity/shop/record")
|
@RequiredArgsConstructor
|
public class ActivityShopRecordController extends BaseController {
|
|
private final ActivityShopRecordService activityShopRecordService;
|
private final ChannelInfoService channelInfoService;
|
// private final ShopServiceClient shopServiceClient;
|
|
@ApiOperation(value = "查询列表", notes = "查询列表")
|
@ApiImplicitParams({@ApiImplicitParam(name = "ActivityShopRecordQuery")})
|
@GetMapping("/getList")
|
public CommonResult<PageBean> getList(@ApiParam(name = "pageNumber", value = "分页页码", required = true) Integer pageNumber,
|
@ApiParam(name = "pageSize", value = "每页展示数", required = true) Integer pageSize) {
|
ActivityShopRecordQuery copy = CommonUtil.getObjFromReq(ActivityShopRecordQuery.class);
|
ActivityShopRecordQuery query = new ActivityShopRecordQuery();
|
BeanUtils.copyProperties(copy, query);
|
PageHelper.startPage(pageNumber, pageSize);
|
|
PageHelper.orderBy("create_time desc");
|
|
List<ActivityShopRecord> list = activityShopRecordService.getList(query);
|
CommonResult result = new CommonResult<>(new PageBean(list));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述:批量添加上报
|
*
|
* @date 2024-04-15 9:41
|
**/
|
@ApiOperation(value = "添加上报", notes = "添加上报")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "recordArray") })
|
@PostMapping("/add")
|
public CommonResult<Integer> add(String recordArray) {
|
List<ActivityShopRecord> recordList = new ArrayList<>();
|
if (StrUtil.isNotBlank(recordArray)) {
|
Object object = JSON.parse(recordArray);
|
if (object instanceof JSONArray) {
|
recordList = JSONArray.parseArray(recordArray, ActivityShopRecord.class);
|
}
|
}
|
|
CommonResult result = new CommonResult<>(activityShopRecordService.batchInsert(recordList));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
@ApiOperation(value = "根据id查询", notes = "根据id查询")
|
@ApiImplicitParams({@ApiImplicitParam(name = "id", value = "主键id")})
|
@GetMapping("/get")
|
public CommonResult<ActivityShopRecord> get(Long id) {
|
CommonResult result = new CommonResult<>(activityShopRecordService.get(id));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
@ApiOperation(value = "删除", notes = "删除")
|
@ApiImplicitParams({@ApiImplicitParam(name = "id", value = "主键id")})
|
@PostMapping("/del")
|
public CommonResult<Integer> del(Long id) {
|
CommonResult result = new CommonResult<>(activityShopRecordService.del(id));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
@ApiOperation(value = "根据店铺id查询活动费率", notes = "根据店铺id查询活动费率")
|
@ApiImplicitParams({@ApiImplicitParam(name = "店铺id", value = "店铺id")})
|
@GetMapping("/getActRateByShopIdAndChannelId")
|
public CommonResult<Map> getActRateByShopIdAndChannelId(Long shopId, Long channelId) {
|
ChannelInfo channelInfo = channelInfoService.getChannelInfo(channelId);
|
HashMap<Object, Object> channelRateMap = new HashMap<>();
|
if (channelInfo != null) {
|
channelRateMap.put("onlineAgreeWxRate", channelInfo.getOnlineAgreeWxRate());
|
channelRateMap.put("onlineAgreeZfbRate", channelInfo.getOnlineAgreeZfbRate());
|
channelRateMap.put("onlineAgreeUnionpayRate", channelInfo.getOnlineAgreeUnionpayRate());
|
channelRateMap.put("offlineAgreeWxRate", channelInfo.getOfflineAgreeWxRate());
|
channelRateMap.put("offlineAgreeZfbRate", channelInfo.getOfflineAgreeZfbRate());
|
channelRateMap.put("offlineAgreeUnionpayRate", channelInfo.getOfflineAgreeUnionpayRate());
|
}
|
Map actRateMap = activityShopRecordService.getActRateByShopIdAndChannelId(shopId, channelId);
|
if (actRateMap != null) {
|
channelRateMap.putAll(actRateMap);
|
}
|
CommonResult result = new CommonResult<>(channelRateMap);
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
@ApiOperation(value = "更新店铺使用额度", notes = "根据店铺id查询活动费率")
|
@ApiImplicitParams({@ApiImplicitParam(name = "店铺id", value = "店铺id")})
|
@PostMapping("/updShopSurplusFee")
|
public CommonResult<Map> updShopSurplusFee(Long activityId, Long merchantShopId, Long channelId, Integer useFee) {
|
CommonResult result = new CommonResult<>(activityShopRecordService.updShopSurplusFee(activityId, merchantShopId, channelId, useFee));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
/**
|
* 方法描述:上报商户列表
|
* 调用service-shop
|
* @date 2024-04-14 19:04
|
**/
|
@ApiOperation(value = "上报商户列表", notes = "上报商户列表")
|
@GetMapping("/getToMerchantList")
|
public CommonResult getToMerchantList(
|
@ApiParam(name = "queryOrgCode", value = "机构code") String queryOrgCode,
|
@ApiParam(name = "merchantId", value = "所属商户id") String merchantId,
|
@ApiParam(name = "shopName", value = "店铺名称") String shopName,
|
@ApiParam(name = "managerName", value = "客户经理名称") String managerName,
|
@ApiParam(name = "channelId", value = "通道id") String channelId,
|
@ApiParam(name = "activityId", value = "活动ID") Long activityId,
|
@ApiParam(name = "pageNumber", value = "分页页码", required = true) Integer pageNumber,
|
@ApiParam(name = "pageSize", value = "每页展示数", required = true) Integer pageSize) {
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
if(StrUtil.isBlank(queryOrgCode)){
|
queryOrgCode = user.getOrgCode();
|
}
|
// CommonResult<PageBean<Map>> mapResult = shopServiceClient.getMerchantShopExtendList(queryOrgCode,merchantId,shopName,managerName,channelId,"channelIdNotNull",pageNumber,pageSize);
|
CommonResult<PageBean<Map>> mapResult = new CommonResult<>();
|
List<Map> mapList = mapResult.getData().getRows();
|
if(!CollectionUtils.isEmpty(mapList)){
|
String[] idsArr = mapList.stream()
|
.map(map -> {
|
Object idObject = map.get("id");
|
if (idObject != null) {
|
return idObject.toString();
|
} else {
|
// 如果 idObject 为 null，跳过该值；且在filter中过滤掉为null的值
|
return null;
|
}
|
})
|
.filter(Objects::nonNull).toArray(String[]::new);
|
//匹配是否已上报，并添加返回标识字段
|
List<ActivityShopRecord> recordList = activityShopRecordService.selectByCondition(idsArr,activityId);
|
//existsShopIds = 已上报的shopIds
|
List<Long> existsShopIds = recordList.stream()
|
.map(ActivityShopRecord::getMerchantShopId)
|
.collect(Collectors.toList());
|
mapList.forEach(map -> {
|
Object idObject = map.get("id");
|
Long id = Long.parseLong(idObject.toString());
|
if(existsShopIds.contains(id)){
|
//已上报过的商户
|
map.put("existsOrNot",1);
|
}else{
|
//未上报的商户
|
map.put("existsOrNot",0);
|
}
|
});
|
}
|
PageBean pageBean = new PageBean();
|
pageBean.setPageNumber(pageNumber);
|
pageBean.setPageSize(pageSize);
|
pageBean.setRows(mapList);
|
pageBean.setTotal(mapResult.getData().getTotal());
|
CommonResult result = new CommonResult<>(pageBean);
|
return result;
|
}
|
|
/**
|
* 方法描述:已上报商户列表
|
*
|
* @date 2024-04-14 20:35
|
**/
|
@ApiOperation(value = "已上报商户列表", notes = "已上报商户列表")
|
@ApiImplicitParams({ @ApiImplicitParam(name = "ActivityShopRecordParam") })
|
@GetMapping("/getAlreadyMerchantList")
|
public CommonResult<PageBean> getAlreadyMerchantList(
|
@ApiParam(name = "pageNumber", value = "分页页码", required = true) Integer pageNumber,
|
@ApiParam(name = "pageSize", value = "每页展示数", required = true) Integer pageSize) {
|
ActivityShopRecordParam copy = CommonUtil.getObjFromReq(ActivityShopRecordParam.class);
|
ActivityShopRecordParam param = new ActivityShopRecordParam();
|
BeanUtils.copyProperties(copy, param);
|
|
PageHelper.startPage(pageNumber, pageSize);
|
PageHelper.orderBy("create_time desc");
|
|
List<ActivityShopRecordDto> list = activityShopRecordService.getAlreadyMerchantList(param);
|
CommonResult result = new CommonResult<>(new PageBean(list));
|
CommonResult result1 = new CommonResult<>();
|
BeanUtils.copyProperties(result, result1);
|
result = result1;
|
return result;
|
}
|
|
|
}
|
