package com.kidgrow.oprationcenter.service.impl;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.kidgrow.common.model.*;
import com.kidgrow.common.service.impl.SuperServiceImpl;
import com.kidgrow.common.utils.DateUtils;
import com.kidgrow.oprationcenter.feign.DiagnosticService;
import com.kidgrow.oprationcenter.feign.RoleOrganizationService;
import com.kidgrow.oprationcenter.mapper.ProductOrderRecordMapper;
import com.kidgrow.oprationcenter.model.ProductOrderRecord;
import com.kidgrow.oprationcenter.service.IProductOrderRecordService;
import com.kidgrow.oprationcenter.vo.DiagnosisRecord;
import com.kidgrow.oprationcenter.vo.GroupProductDetail;
import com.kidgrow.oprationcenter.vo.ProductOrderJoinDetail;
import com.kidgrow.usercenter.feign.SysDoctorService;
import com.kidgrow.usercenter.feign.SysHospitalService;
import com.kidgrow.usercenter.model.SysHospital;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020
*
* @version 1.0
* @Description: 产品/明显的充值记录
* @Project: 用户中心
* @CreateDate: Created in 2020-04-01 09:37:05
* @Author: liuke
*/
@Slf4j
@Service
public class ProductOrderRecordServiceImpl extends SuperServiceImpl implements IProductOrderRecordService {
@Autowired
DiagnosticService diagnosticService;
@Autowired
private RoleOrganizationService roleOrganizationService;
@Autowired
private SysDoctorService sysDoctorService;
@Autowired
private SysHospitalService sysHospitalService;
/**
* 列表
*
* @param params
* @return
*/
@Override
public PageResult findList(Map params) {
Page page = new Page<>(MapUtils.getInteger(params, "page"), MapUtils.getInteger(params, "limit"));
List list = baseMapper.findList(page, params);
return PageResult.builder().data(list).code(0).count(page.getTotal()).build();
}
/**
* 获取诊断列表
*
* @param params
* @return
*/
@Override
public PageResult findAllDataList(Map params) {
return diagnosticService.getDiagnosticItemList(params).getData();
}
/**
* 查看报告
*/
@Override
public ResultBody getPdfPathForOperation(String diagnosticId, Integer reportType, Long hospitalId, Long departId) {
ResultBody pdfPathForOperation = diagnosticService.getPdfPathForOperation(diagnosticId, reportType, hospitalId, departId);
return pdfPathForOperation;
}
/**
* 列表
*
* @param params
* @return
*/
@Override
public PageResult findAllList(Map params, SysUser sysUser) {
Page page = new Page<>(MapUtils.getInteger(params, "page"), MapUtils.getInteger(params, "limit"));
// Map roleOrgMap = roleOrganizationService.getRoleOrgMap(sysUser);
// params.putAll(roleOrgMap);
List list = baseMapper.findAllList(page, params);
for (ProductOrderJoinDetail productOrderJoinDetail : list) {
Date proBegintime = productOrderJoinDetail.getProBegintime();
Date proEndtime = productOrderJoinDetail.getProEndtime();
Date nowDate = new Date();
if(nowDate.getTime()=proEndtime.getTime()){
productOrderJoinDetail.setUseType("已结束");
}
}
return PageResult.builder().data(list).code(0).count(page.getTotal()).build();
}
/**
* 获取统计数据
*
* @param params
* @return
*/
@Override
public PageResult groupList(Map params) {
Page page = new Page<>(MapUtils.getInteger(params, "page"), MapUtils.getInteger(params, "limit"));
List list = baseMapper.groupProductDetail(page, params);
return PageResult.builder().data(list).code(0).count(page.getTotal()).build();
}
/**
* 根据ProductOrderRecord对象当做查询条件进行查询
*
* @param productOrderRecord
* @return ProductOrderRecord
*/
@Override
public ProductOrderRecord findByObject(ProductOrderRecord productOrderRecord) {
return baseMapper.findByObject(productOrderRecord);
}
/**
* 修改数据状态 启用 禁用
*
* @param params
* @return
*/
@Override
public ResultBody updateEnabled(Map params) {
Long id = MapUtils.getLong(params, "id");
Boolean enabled = MapUtils.getBoolean(params, "enabled");
ProductOrderRecord productOrder = baseMapper.selectById(id);
if (productOrder == null) {
return ResultBody.failed("该数据不存在!");
}
productOrder.setEnabled(enabled);
productOrder.setUpdateTime(new Date());
int i = baseMapper.updateById(productOrder);
return i > 0 ? ResultBody.ok().data(productOrder).msg("更新成功") : ResultBody.failed("更新失败");
}
@Override
public ResultBody getTypeByUser(SysUser sysUser) {
List organizations = sysUser.getOrganizations();
if (organizations.size() > 0) {
SysOrganization sysOrganization = organizations.get(0);
List list = baseMapper.getTypeByUser(sysOrganization.getId());
if (list.size() > 0) {
ProductOrderJoinDetail productOrderJoinDetail = list.get(0);
//查询用户的真实姓名
Map selectMap = new HashMap<>();
selectMap.put("user_id", sysUser.getId());
ResultBody listByMap = sysDoctorService.getListByMap(selectMap);
List sysDoctors = JSON.parseArray(JSON.toJSONString(listByMap.getData()), SysDoctor.class);
String str = "";
if (sysDoctors != null && sysDoctors.size() > 0) {
str = sysDoctors.get(0).getDoctorName();
}
//查询医院的 logo
Map map = new HashMap<>();
map.put("id", sysOrganization.getId());
ResultBody allByMap = sysHospitalService.findAllByMap(map);
List hospitals = JSON.parseArray(JSON.toJSONString(allByMap.getData()), SysHospital.class);
String logo = "";
if (hospitals.size() > 0) {
logo = hospitals.get(0).getHospitalLogo();
}
Map mapVo = new HashMap<>();
mapVo.put("type", productOrderJoinDetail.getProType());
mapVo.put("realName", str);
//剩余时间
Date proEndtime = productOrderJoinDetail.getProEndtime();
Double surplusDay = DateUtils.getDays(proEndtime, new Date());
int surplus = surplusDay.intValue();
mapVo.put("surplus", surplus);
mapVo.put("logo", logo);
//获取 售后服务工程师********不能从sysOrganization获取,从department获取
/* mapVo.put("saleUserName",sysOrganization.getSaleUserName());
mapVo.put("saleUserTel",sysOrganization.getSaleUserTel());*/
return ResultBody.ok().data(mapVo);
} else {
return ResultBody.failed("该用户套餐已经失效");
}
} else {
return ResultBody.failed("该用户的组织已经失效");
}
}
}