blame | history | patch | commit | commitdiff | ignore whitespace
Administrator
19 hours ago fe70ca5db711b458714bfbe4a6eda6cf7d8a0421 
 src/main/java/cc/mrbird/febs/ai/service/impl/AiTalkItemServiceImpl.java


@@ -9,11 +9,15 @@


import cc.mrbird.febs.ai.utils.UUID;


import cc.mrbird.febs.common.entity.FebsResponse;


import cn.hutool.core.date.DateTime;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Service;




import java.util.List;




@Slf4j


@Service


@@ -22,9 +26,10 @@




    private final AiTalkItemMapper aiTalkItemMapper;


    @Override


    public void add(String id, int code, String context, String memberUuid, DateTime date) {


    public void add(String id,String companyId, int code, String context, String memberUuid, DateTime date) {


        AiTalkItem aiTalkItem = new AiTalkItem();


        aiTalkItem.setId(UUID.getSimpleUUIDString());


        aiTalkItem.setCompanyId(companyId);


        aiTalkItem.setMemberId(memberUuid);


        aiTalkItem.setType(code);


        aiTalkItem.setTalkId(id);


@@ -40,4 +45,14 @@


        Page<ApiTalkItemPageVo> pageListByQuery = aiTalkItemMapper.getPageListByQuery(page, dto);


        return new FebsResponse().success().data(pageListByQuery);


    }




    @Override


    public List<AiTalkItem> getListByTalkId(String talkId) {


        LambdaQueryWrapper<AiTalkItem> queryWrapper = Wrappers.lambdaQuery(AiTalkItem.class);


        queryWrapper.eq(AiTalkItem::getTalkId, talkId);


        queryWrapper.orderByDesc(AiTalkItem::getCreatedTime);


        queryWrapper.last("limit 10");


        List<AiTalkItem> list = aiTalkItemMapper.selectList(queryWrapper);


        return list;


    }


}