package jnpf.base.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.unfbx.chatgpt.entity.chat.BaseMessage;
import com.unfbx.chatgpt.entity.chat.Message;
import jnpf.base.UserInfo;
import jnpf.base.entity.AiChatEntity;
import jnpf.base.entity.AiHistoryEntity;
import jnpf.base.mapper.AiChatMapper;
import jnpf.base.model.ai.AiChatVo;
import jnpf.base.model.ai.AiForm;
import jnpf.base.model.ai.AiHisVo;
import jnpf.base.service.AiChatService;
import jnpf.base.service.AiHistoryService;
import jnpf.base.service.SuperServiceImpl;
import jnpf.constant.MsgCode;
import jnpf.service.OpenAiService;
import jnpf.util.*;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * ai会话服务
 *
 * @author JNPF开发平台组
 * @version v5.2.0
 * @copyright 引迈信息技术有限公司
 * @date 2024/12/2 10:05:25
 */
@Service
public class AiChatServiceImpl extends SuperServiceImpl<AiChatMapper, AiChatEntity> implements AiChatService {
    @Autowired
    private OpenAiService openAiService;

    @Autowired
    private AiHistoryService aiHistoryService;

    @Override
    public String send(String keyword) {
        if ("JNPF是什么".equals(keyword)) {
            return "JNPF 是一款基于 Java 的低代码开发平台，旨在简化企业级应用的开发流程。以下是其核心特点：" +
                    "1. 低代码开发：\n" +
                    "提供可视化界面，通过拖拽组件和配置参数快速构建应用，减少代码编写。\n" +
                    "自动生成前后端代码，提升开发效率。\n" +
                    "2. 功能丰富：\n" +
                    "包含表单设计、流程引擎、报表工具等模块，满足企业多样化需求。\n" +
                    "支持移动端开发，便于创建跨平台应用。\n" +
                    "3. 灵活扩展：\n" +
                    "支持二次开发，允许根据需求深度定制。\n" +
                    "提供丰富的 API 接口，便于与其他系统集成。\n" +
                    "4. 国产化支持：\n" +
                    "兼容国产操作系统和数据库，适合国内企业使用。\n" +
                    "总结：JNPF 通过低代码方式简化开发流程，提供丰富的功能和灵活的扩展性，适合快速构建企业级应用。";
        }
        if ("JNPF的性能特点".equals(keyword)) {
            return "JNPF 作为低代码开发平台，其性能特点主要体现在以下几个方面：\n" +
                    "1. 高效开发：\n" +
                    "可视化开发： 通过拖拽组件和配置参数，快速构建应用，减少代码编写。\n" +
                    "代码生成： 自动生成前后端代码，提升开发效率。\n" +
                    "模块化设计： 提供丰富的功能模块，避免重复开发。\n" +
                    "2. 高稳定性：\n" +
                    "标准化开发： 统一的开发框架和规范，提升代码质量。\n" +
                    "持续更新： 平台不断更新，提供最新技术支持。\n" +
                    "3. 高扩展性：\n" +
                    "支持二次开发： 可根据需求进行深度定制。\n" +
                    "丰富接口： 提供多种接口，便于与其他系统集成。\n" +
                    "多环境部署： 支持多种部署方式，适应不同场景。\n" +
                    "4. 高性能：\n" +
                    "优化架构： 采用高性能架构，确保应用流畅运行。\n" +
                    "缓存机制： 内置缓存机制，提升数据访问速度。\n" +
                    "负载均衡： 支持负载均衡，有效应对高并发。\n" +
                    "5. 高安全性：\n" +
                    "权限控制： 提供细粒度的权限管理，保障数据安全。\n" +
                    "数据加密： 支持数据加密传输和存储。\n" +
                    "安全审计： 提供操作日志和审计功能，便于追踪问题。\n" +
                    "总结： JNPF 在开发效率、稳定性、扩展性、性能及安全性方面表现优异，适合快速构建高性能的企业级应用。";
        }
        if ("JNPF支持哪些数据库".equals(keyword)) {
            return "JNPF 作为一款低代码开发平台，支持多种数据库，具体支持的数据库类型可能因版本和配置而异，但通常包括以下几类：\n" +
                    "1. 关系型数据库 (SQL):\n" +
                    "MySQL: 开源、流行的关系型数据库。\n" +
                    "PostgreSQL: 功能强大、开源的关系型数据库。\n" +
                    "Oracle: 商业级关系型数据库。\n" +
                    "SQL Server: 微软开发的关系型数据库。\n" +
                    "达梦数据库 (DM): 国产关系型数据库。\n" +
                    "人大金仓数据库 (KingbaseES): 国产关系型数据库。\n" +
                    "2. 非关系型数据库 (NoSQL):\n" +
                    "Redis: 内存数据库，常用于缓存和消息队列。\n" +
                    "3. 国产数据库:\n" +
                    "达梦数据库 (DM)\n" +
                    "人大金仓数据库 (KingbaseES)\n" +
                    "总结： JNPF 支持多种数据库，包括主流的关系型数据库、非关系型数据库以及国产数据库，用户可根据需求选择合适的数据库。建议参考官方文档或咨询技术支持以获取最新的数据库支持信息。";
        }
        if(!AiLimitUtil.tryAcquire(UserProvider.getUser().getUserId())){
            return MsgCode.SYS182.get();
        }
        Message sysMessage = Message.builder().role(BaseMessage.Role.USER).content(keyword).build();
        return openAiService.completion(sysMessage);
    }

    @Override
    public List<AiChatVo> historyList() {
        //当前用户信息
        UserInfo userInfo = UserProvider.getUser();
        QueryWrapper<AiChatEntity> queryWrapper = new QueryWrapper();
        queryWrapper.lambda().eq(AiChatEntity::getCreatorUserId, userInfo.getUserId());
        queryWrapper.lambda().orderByDesc(AiChatEntity::getCreatorTime);
        List<AiChatEntity> list = this.list(queryWrapper);
        List<AiChatVo> listVo = JsonUtil.getJsonToList(list, AiChatVo.class);
        return listVo;
    }

    @Override
    public List<AiHisVo> historyGet(String id) {
        QueryWrapper<AiHistoryEntity> queryWrapper = new QueryWrapper();
        queryWrapper.lambda().eq(AiHistoryEntity::getChatId, id);
        List<AiHistoryEntity> list = aiHistoryService.list(queryWrapper);
        List<AiHisVo> listVo = JsonUtil.getJsonToList(list, AiHisVo.class);
        return listVo;
    }

    @Override
    public String historySave(AiForm form) {
        String chatId = form.getId();
        AiChatEntity chatEntity;
        if (StringUtil.isNotEmpty(chatId)) {
            chatEntity = this.getById(chatId);
        } else {
            chatEntity = new AiChatEntity();
            chatId = RandomUtil.uuId();
            chatEntity.setId(chatId);
        }
        if (StringUtil.isNotEmpty(form.getFullName())) {
            chatEntity.setFullName(form.getFullName());
        }
        this.saveOrUpdate(chatEntity);
        List<AiHisVo> data = form.getData();
        if (CollectionUtils.isNotEmpty(data)) {
            AiHisVo last = data.get(data.size() - 1);
            if (StringUtil.isEmpty(last.getId())) {
                AiHistoryEntity entity = JsonUtil.getJsonToBean(last, AiHistoryEntity.class);
                entity.setId(RandomUtil.uuId());
                entity.setChatId(chatId);
                aiHistoryService.save(entity);
            }
        }
        return chatId;
    }

    @Override
    public void delete(String id) {

        this.removeById(id);
        QueryWrapper<AiHistoryEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(AiHistoryEntity::getChatId, id);
        aiHistoryService.remove(queryWrapper);
    }
}