package com.ruoyi.service.impl;
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.bean.BeanUtils;
import com.ruoyi.domain.*;
import com.ruoyi.domain.ZHealthInfo;
import com.ruoyi.domain.ZHealthInfo;
import com.ruoyi.domain.dto.ZHealthInfoDto;
import com.ruoyi.domain.dto.ZHealthInfoDto;
import com.ruoyi.domain.health.*;
import com.ruoyi.mapper.ZHealthInfoMapper;
import com.ruoyi.service.ZHealthInfoService;
import com.ruoyi.service.ZInfoUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.stream.Collectors;
/**
*
* 身体状况疾病表 服务实现类
*
*
* @author ojq
* @since 2023-03-14
*/
@Service
public class ZHealthInfoServiceImpl extends ServiceImpl implements ZHealthInfoService {
@Autowired
ZInfoUserService zInfoUserService;
@Override
public AjaxResult selectData() {
SysUser user = SecurityUtils.getLoginUser().getUser();
Long userId = user.getUserId();
LambdaQueryWrapper lqw = new LambdaQueryWrapper<>();
lqw.eq(ZHealthInfo::getUid,userId);
ZHealthInfo zHealthInfo = getOne(lqw);
if(zHealthInfo==null)
{
//根据userId查询到infouser的uaid
ZInfoUser zInfoUser = zInfoUserService.getInfoBysysId(userId);
// System.out.println("sdfsdf999000550");
//拿到所有的sysid
List fms = zInfoUserService.findByUaidToFaid(zInfoUser.getUaid()).stream().map(ZInfoUser::getSysId).collect(Collectors.toList());
System.out.println(fms.size());
for(Long id:fms)
{
LambdaQueryWrapper lqw1 = new LambdaQueryWrapper<>();
if(!id.equals(userId))
{
lqw1.eq(ZHealthInfo::getUid, id);
zHealthInfo = getOne(lqw1);
break;
}
}
}
//如果是第一次进来,之前没有这个用户的数据,抛异常让用户先插入数据
if(zHealthInfo == null){
throw new RuntimeException("第一次进来,请先填写好数据");
}
//封装要返回的数据
ZHealthInfoDto returnData = new ZHealthInfoDto();
BeanUtils.copyProperties(zHealthInfo,returnData);
// returnData.setName(zHealthInfo.getName());
// returnData.setSex(zHealthInfo.getSex());
// returnData.setEducationLevel(zHealthInfo.getEducationLevel());
// returnData.setWork(zHealthInfo.getWork());
// returnData.setPhone(zHealthInfo.getPhone());
// returnData.setEmail(zHealthInfo.getEmail());
// returnData.setMedicine(zHealthInfo.getMedicine());
// returnData.setBaseDisease(zHealthInfo.getBaseDisease());
//将json数组转换成对象
returnData.setSkinTypeClass(JSON.parseObject(zHealthInfo.getSkinType(), SkinType.class));
returnData.setPsychologyTypeClass(JSON.parseObject(zHealthInfo.getPsychologyType(), PsychologyType.class));
returnData.setAttitudeClass(JSON.parseObject(zHealthInfo.getAttitude(), AttitudeType.class));
returnData.setNutritionClass(JSON.parseObject(zHealthInfo.getNutrition(), NutritionType.class));
return AjaxResult.success(returnData);
}
@Override
public AjaxResult saveOrUpdateData(ZHealthInfoDto zHealthInfoDto) {
SysUser user = SecurityUtils.getLoginUser().getUser();
Long userId = user.getUserId();
LambdaQueryWrapper lqw = new LambdaQueryWrapper<>();
lqw.eq(ZHealthInfo::getUid,userId);
ZHealthInfo getResult = getOne(lqw);
ZHealthInfo zHealthInfo = new ZHealthInfo();
BeanUtils.copyProperties(zHealthInfoDto,zHealthInfo);
zHealthInfo.setUid(userId);
zHealthInfo.setSkinType(JSON.toJSONString(zHealthInfoDto.getSkinTypeClass()));
zHealthInfo.setPsychologyType(JSON.toJSONString(zHealthInfoDto.getPsychologyTypeClass()));
zHealthInfo.setAttitude(JSON.toJSONString(zHealthInfoDto.getAttitudeClass()));
zHealthInfo.setNutrition(JSON.toJSONString(zHealthInfoDto.getNutritionClass()));
if(getResult == null){
//如果是第一次进来,那么是新增数据
save(zHealthInfo);
}else {
//如果不是第一次,那就是修改数据了
zHealthInfo.setId(getResult.getId());
updateById(zHealthInfo);
}
return AjaxResult.success();
}
}