package cn.stylefeng.rest.modular.home.controller;
|
|
import cn.hutool.core.util.ObjUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.json.JSONUtil;
|
import cn.stylefeng.guns.modular.business.entity.Area;
|
import cn.stylefeng.guns.modular.business.entity.SystemSet;
|
import cn.stylefeng.guns.modular.business.service.IAreaService;
|
import cn.stylefeng.guns.modular.business.service.ISystemSetService;
|
import cn.stylefeng.guns.utils.ObsUtil;
|
import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi;
|
import cn.stylefeng.roses.kernel.rule.constants.RuleConstants;
|
import cn.stylefeng.roses.kernel.rule.enums.*;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.ErrorResponseData;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.ResponseData;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.SuccessResponseData;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.ApiResource;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.GetResource;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.PostResource;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 主页接口-html富文本页面
|
*
|
* @author goupan
|
* @date 2024/01/02
|
*/
|
@RestController
|
@Api(tags = "公共接口")
|
@ApiResource(name = "公共接口")
|
@RequestMapping("/public")
|
public class PublicController {
|
|
@Resource
|
private ObsUtil obsUtil;
|
|
@Resource
|
private CacheOperatorApi<Object> objectCacheOperatorApi;
|
|
@Resource
|
private IAreaService areaService;
|
|
@Resource
|
private ISystemSetService systemSetService;
|
|
@ApiOperation("获取地区码表")
|
@GetResource(name = "获取地区码表", path = "/areaList", requiredPermission = false)
|
public ResponseData<List<Area>> areaList() {
|
List<Area> areaList;
|
// 缓存获取地区码表
|
Object areaCache = objectCacheOperatorApi.get(RuleConstants.AREA_CACHE_KEY);
|
if (ObjUtil.isNotEmpty(areaCache)){
|
areaList = JSONUtil.parseArray(areaCache).toList(Area.class);
|
return new SuccessResponseData<>(areaList);
|
}
|
|
// 查询p0级地区
|
areaList = areaService.list(
|
Wrappers.<Area>lambdaQuery()
|
.select(Area::getId, Area::getPid, Area::getName)
|
.eq(Area::getPid, 0)
|
.orderByAsc(Area::getId)
|
);
|
// 查询p1/2级地区
|
List<Area> areaListP12 = areaService.list(
|
Wrappers.<Area>lambdaQuery()
|
.select(Area::getId, Area::getPid, Area::getName)
|
.eq(Area::getLevel, 2)
|
.or().eq(Area::getLevel, 3)
|
.orderByAsc(Area::getId)
|
);
|
|
// pid相同地区分组
|
Map<Integer, List<Area>> groupAreasByPidMap = new HashMap<>();
|
for (Area area : areaListP12) {
|
Integer pid = area.getPid();
|
// 如果pid不存在，则添加一个新的空列表
|
groupAreasByPidMap.putIfAbsent(pid, new ArrayList<>());
|
// 将当前Area添加到对应pid的列表中
|
groupAreasByPidMap.get(pid).add(area);
|
}
|
|
areaList.stream().forEach(p0 -> {
|
List<Area> p1Area = groupAreasByPidMap.get(p0.getId());
|
p1Area.forEach(p1 -> {
|
List<Area> p2Area = groupAreasByPidMap.get(p1.getId());
|
p1.setChildAreaList(p2Area);
|
});
|
p0.setChildAreaList(p1Area);
|
});
|
|
// 地区码表存入缓存
|
objectCacheOperatorApi.put(RuleConstants.AREA_CACHE_KEY, areaList);
|
|
return new SuccessResponseData<>(areaList);
|
}
|
|
@ApiOperation("配置（H5、客服电话、启动页）目录")
|
@GetMapping(RuleConstants.NOT_LOGIN + "/setList")
|
@GetResource(name = "配置（H5、客服电话、启动页）目录", path = RuleConstants.NOT_LOGIN + "/setList", requiredPermission = false, requiredLogin = false)
|
public ResponseData<List<SystemSet>> setList() {
|
// 查询列表
|
List<SystemSet> list = systemSetService.list(
|
Wrappers.<SystemSet>lambdaQuery()
|
.select(SystemSet::getId, SystemSet::getKeyStr, SystemSet::getRemark)
|
);
|
return new SuccessResponseData(list);
|
}
|
|
@ApiOperation(value = "配置（H5、客服电话、启动页）信息", notes = "通过h5配置目录，获取id查询")
|
@GetMapping(RuleConstants.NOT_LOGIN + "/setDetail/{id}")
|
@GetResource(name = "配置（H5、客服电话、启动页）信息", path = RuleConstants.NOT_LOGIN + "/setDetail/{id}", requiredPermission = false, requiredLogin = false)
|
public ResponseData<SystemSet> setDetail(@PathVariable("id") Long id) {
|
// 查询详情
|
SystemSet obj = systemSetService.getById(id);
|
return new SuccessResponseData(obj);
|
}
|
|
@ApiOperation("文件上传")
|
@PostResource(name = "文件上传", path = "/uploadFile")
|
public ResponseData uploadFile(@RequestPart("file") MultipartFile file) {
|
String url = obsUtil.upload(file);
|
if (StrUtil.isEmpty(url)) {
|
return new ErrorResponseData("文件上传失败");
|
}
|
return new SuccessResponseData(url);
|
}
|
|
@ApiOperation("枚举说明")
|
@PostResource(name = "枚举说明", path = RuleConstants.NOT_LOGIN + "/enumDesc")
|
public ResponseData enumDesc() {
|
return new SuccessResponseData(Arrays.asList(
|
Arrays.stream(CustomerMentalAnalysisStatusEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(DeleteEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(ImPushTypeEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(ImStatusEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(MentalAppointmentStatusEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(OrderStatusFlagEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(PostIdEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(PostTypeEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(SexEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(StatusEnum.values()).map(e -> e.toString()).collect(Collectors.toList()),
|
Arrays.stream(SystemSetEnum.values()).map(e -> e.toString()).collect(Collectors.toList())
|
));
|
}
|
|
}
|
