package io.renren.modules.consult.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import io.renren.common.exception.RRException;
import io.renren.common.utils.Constant;
import io.renren.common.utils.PageUtils;
import io.renren.common.utils.Query;
import io.renren.modules.consult.dao.ConsulinstitutionDao;
import io.renren.modules.consult.entity.ConsulinstitutionEntity;
import io.renren.modules.consult.service.ConsulinstitutionService;
import io.renren.modules.sys.entity.SysUserEntity;
import io.renren.modules.sys.shiro.ShiroUtils;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Service;

import java.util.Date;
import java.util.Map;


@Service("consulinstitutionService")
public class ConsulinstitutionServiceImpl extends ServiceImpl<ConsulinstitutionDao, ConsulinstitutionEntity> implements ConsulinstitutionService {

    @Override
    public PageUtils queryPage(Map<String, Object> params) {
        IPage<ConsulinstitutionEntity> page = this.page(
                new Query<ConsulinstitutionEntity>().getPage(params),
                new QueryWrapper<ConsulinstitutionEntity>()
                .like(StringUtils.isNotBlank((String) params.get("name")), "name",params.get("name"))
        );

        return new PageUtils(page);
    }

    @Override
    public void publish(Long id) {
        ConsulinstitutionEntity one = this.lambdaQuery().eq(ConsulinstitutionEntity::getId, id).one();

        //校验公告是否已发送过
        if (one.getIsPublish() == Constant.PublishStatus.PUBLISH.getValue()) {
            throw new RRException("该公告已发布过,请不要重复发布");
        }

        //修改发布状态为已发布
        one.setIsPublish(Constant.PublishStatus.PUBLISH.getValue());
        one.setUpdateTime(new Date());
        // 获取当前用户
        SysUserEntity userEntity = ShiroUtils.getUserEntity();
        one.setUpdateUserName(userEntity.getRealname());
        one.setUpdateUserId(userEntity.getUserId());

        this.updateById(one);
    }

    @Override
    public void unpublish(Long id) {
        ConsulinstitutionEntity one = this.lambdaQuery().eq(ConsulinstitutionEntity::getId, id).one();

        //校验公告是否已发送过
        if (one.getIsPublish() == Constant.PublishStatus.UNPUBLISH.getValue()) {
            throw new RRException("该公告未发布过,请误操作！");
        }

        //修改发布状态为已发布
        one.setIsPublish(Constant.PublishStatus.UNPUBLISH.getValue());
        //one.setUpdateTime(new Date());
        // 获取当前用户
        SysUserEntity userEntity = ShiroUtils.getUserEntity();
        one.setUpdateUserName(userEntity.getRealname());
        one.setUpdateUserId(userEntity.getUserId());

        this.updateById(one);
    }

}