package cn.stylefeng.guns.modular.business.controller;
|
|
import cn.hutool.core.lang.Assert;
|
import cn.hutool.core.util.StrUtil;
|
import cn.stylefeng.guns.modular.business.dto.MentalAnalysisTimeConfigDetailDTO;
|
import cn.stylefeng.guns.modular.business.dto.MentalAnalysisTimeConfigPageDTO;
|
import cn.stylefeng.guns.modular.business.dto.MentalAppointmentPageDTO;
|
import cn.stylefeng.guns.modular.business.dto.TimeConfigDTO;
|
import cn.stylefeng.guns.modular.business.dto.request.MentalAnalysisTimeConfigAddUpdateRequest;
|
import cn.stylefeng.guns.modular.business.entity.MentalAnalysisTimeConfig;
|
import cn.stylefeng.guns.modular.business.service.IMentalAnalysisTimeConfigService;
|
import cn.stylefeng.guns.modular.business.service.IMentalAppointmentService;
|
import cn.stylefeng.roses.kernel.customer.modular.entity.Customer;
|
import cn.stylefeng.roses.kernel.customer.modular.service.CustomerService;
|
import cn.stylefeng.roses.kernel.db.api.factory.PageFactory;
|
import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory;
|
import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
|
import cn.stylefeng.roses.kernel.rule.annotation.BusinessLog;
|
import cn.stylefeng.roses.kernel.rule.enums.CustomerMentalAnalysisStatusEnum;
|
import cn.stylefeng.roses.kernel.rule.enums.DeleteEnum;
|
import cn.stylefeng.roses.kernel.rule.enums.MentalAppointmentStatusEnum;
|
import cn.stylefeng.roses.kernel.rule.enums.ResBizTypeEnum;
|
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 com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@RestController
|
@Api(tags = "性格分析师配置")
|
@ApiResource(name = "性格分析师配置", resBizType = ResBizTypeEnum.BUSINESS)
|
@RequestMapping("/business")
|
public class MentalAnalysisTimeConfigController {
|
|
@Resource
|
private CustomerService customerService;
|
|
@Resource
|
private IMentalAppointmentService mentalAppointmentService;
|
|
@Resource
|
private IMentalAnalysisTimeConfigService mentalAnalysisTimeConfigService;
|
|
@ApiOperation("添加性格分析师时间配置")
|
@PostResource(name = "添加性格分析师时间配置", path = "/mentalAnalysisTimeConfig/add")
|
@BusinessLog
|
public ResponseData<?> mentalAnalysisTimeConfigAdd(@RequestBody MentalAnalysisTimeConfigAddUpdateRequest req) {
|
this.mentalAnalysisTimeConfigService.addTimeConfig(req);
|
return new SuccessResponseData<>();
|
}
|
|
// @ApiOperation("修改性格分析师时间配置")
|
// @PostResource(name = "修改性格分析师时间配置", path = "/mentalAnalysisTimeConfig/edit")
|
// @BusinessLog
|
// public ResponseData<?> mentalAnalysisTimeConfigEdit(@RequestBody MentalAnalysisTimeConfigAddUpdateRequest req) {
|
// this.mentalAnalysisTimeConfigService.editTimeConfig(req);
|
// return new SuccessResponseData<>();
|
// }
|
|
@BusinessLog
|
@ApiOperation("性格分析师上下架")
|
@PostResource(name = "性格分析师上下架", path = "/mentalAnalysisTimeConfig/updateStatus")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id", value = "咨询师ID", dataTypeClass = Long.class, paramType = "query"),
|
@ApiImplicitParam(name = "status", value = "性格分析师上下架状态：1上架，2下架", dataTypeClass = Integer.class, paramType = "query")
|
})
|
public ResponseData<?> updateStatus(Long id, Integer status) {
|
// 咨询师ID
|
Customer worker = customerService.getById(id);
|
Assert.notNull(worker, "咨询师不存在");
|
Assert.isFalse(CustomerMentalAnalysisStatusEnum.NO_POST.getCode().equals(worker.getMentalAnalysisStatus()), "性格分析师岗位已调整，不支持修改上下架");
|
|
// 性格分析师上下架
|
Customer customer = new Customer();
|
customer.setCustomerId(id);
|
customer.setMentalAnalysisStatus(status);
|
customerService.updateCustomerRemoveCache(customer);
|
return new SuccessResponseData<>();
|
}
|
|
@ApiOperation("性格分析师时间配置详情")
|
@GetResource(name = "性格分析师时间配置详情", path = "/mentalAnalysisTimeConfig/detail/{counsellingInfoId}", requiredPermission = false)
|
public ResponseData<MentalAnalysisTimeConfigDetailDTO> detail(@PathVariable("counsellingInfoId") Long counsellingInfoId) {
|
List<MentalAnalysisTimeConfig> list = this.mentalAnalysisTimeConfigService.list(
|
Wrappers.<MentalAnalysisTimeConfig>lambdaQuery()
|
.eq(MentalAnalysisTimeConfig::getIsDelete, DeleteEnum.NOT_DELETE.getCode())
|
.eq(MentalAnalysisTimeConfig::getCounsellingInfoId, counsellingInfoId)
|
);
|
// 按moduleNo进行分组
|
Map<String, List<MentalAnalysisTimeConfig>> groupedData = list.stream().collect(Collectors.groupingBy(MentalAnalysisTimeConfig::getModuleNo));
|
List<TimeConfigDTO> dtoList = groupedData.values().stream()
|
.map(group -> {
|
TimeConfigDTO dto = new TimeConfigDTO();
|
|
dto.setWeeks(group.stream()
|
.map(MentalAnalysisTimeConfig::getWeekDay)
|
.distinct()
|
.map(Object::toString)
|
.collect(Collectors.joining(",")));
|
|
dto.setTimePoints(group.stream()
|
.map(oo -> oo.getBeginTimePoint() + "-" + oo.getEndTimePoint())
|
.distinct()
|
.map(Object::toString)
|
.collect(Collectors.joining(",")));
|
|
return dto;
|
})
|
.collect(Collectors.toList());
|
|
|
String nickName = customerService.getObj(
|
Wrappers.<Customer>lambdaQuery()
|
.select(Customer::getNickName)
|
.eq(Customer::getCustomerId, counsellingInfoId),
|
o -> StrUtil.toStringOrNull(o)
|
);
|
|
MentalAnalysisTimeConfigDetailDTO dto = MentalAnalysisTimeConfigDetailDTO.builder()
|
.counsellingInfoId(counsellingInfoId)
|
.counsellingInfoName(nickName)
|
.timeConfigList(list)
|
.timeConfigDtoList(dtoList)
|
.build();
|
|
return new SuccessResponseData<>(dto);
|
}
|
|
@ApiOperation("查看日程")
|
@GetResource(name = "查看日程", path = "/mentalAnalysisTimeConfig/schedulePage", requiredPermission = false)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageNo", value = "分页：第几页（从1开始）", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "pageSize", value = "分页：每页大小（默认20）", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "counsellingInfoId", value = "咨询师ID", dataTypeClass = Long.class, paramType = "query"),
|
@ApiImplicitParam(name = "workerNickName", value = "咨询师姓名", dataTypeClass = String.class, paramType = "query"),
|
@ApiImplicitParam(name = "userNickName", value = "用户姓名", dataTypeClass = String.class, paramType = "query"),
|
@ApiImplicitParam(name = "userTelephone", value = "联系电话", dataTypeClass = String.class, paramType = "query"),
|
@ApiImplicitParam(name = "statusFlag", value = "状态：0预约中，1已分配，2服务中，3已完成，9已取消", dataTypeClass = Integer.class, paramType = "query"),
|
})
|
public ResponseData<PageResult<MentalAppointmentPageDTO>> schedulePage(Integer pageNo, Integer pageSize, Long counsellingInfoId, String workerNickName, String userNickName, String userTelephone, Integer statusFlag) {
|
Page<MentalAppointmentPageDTO> page = mentalAppointmentService.getPage(
|
PageFactory.page(pageNo, pageSize),
|
counsellingInfoId,
|
workerNickName,
|
userNickName,
|
userTelephone,
|
statusFlag,
|
Arrays.asList(MentalAppointmentStatusEnum.WAIT_SERVICE.getCode(), MentalAppointmentStatusEnum.IN_SERVICE.getCode(), MentalAppointmentStatusEnum.DONE.getCode())
|
);
|
return new SuccessResponseData<>(PageResultFactory.createPageResult(page));
|
}
|
|
@ApiOperation("获取性格分析师配置(分页)")
|
@GetResource(name = "获取性格分析师配置(分页)", path = "/mentalAnalysisTimeConfig/page", requiredPermission = false)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageNo", value = "分页：第几页（从1开始）", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "pageSize", value = "分页：每页大小（默认20）", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "nickName", value = "分析师姓名", dataTypeClass = String.class, paramType = "query"),
|
})
|
public ResponseData<PageResult<MentalAnalysisTimeConfigPageDTO>> mentalAnalysisTimeConfigPage(Integer pageNo, Integer pageSize, String nickName) {
|
Page<MentalAnalysisTimeConfigPageDTO> page = this.mentalAnalysisTimeConfigService.getWorkerPage(PageFactory.page(pageNo, pageSize), nickName);
|
return new SuccessResponseData<>(PageResultFactory.createPageResult(page));
|
}
|
|
}
|
