#AI

zhou zhou

4 小时以前 51877df13075ad10ef51107f15bcd21f1661febe

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
package com.vincent.rsf.server.system.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.vincent.rsf.server.system.entity.AiPromptTemplate;
import com.vincent.rsf.server.system.mapper.AiPromptTemplateMapper;
import com.vincent.rsf.server.system.service.AiPromptPublishLogService;
import com.vincent.rsf.server.system.service.AiPromptTemplateService;
import org.springframework.stereotype.Service;
 
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
 
@Service("aiPromptTemplateService")
public class AiPromptTemplateServiceImpl extends ServiceImpl<AiPromptTemplateMapper, AiPromptTemplate> implements AiPromptTemplateService {
 
    @Resource
    private AiPromptPublishLogService aiPromptPublishLogService;
 
    @Override
    public AiPromptTemplate getTenantTemplate(Long tenantId, Long id) {
        if (tenantId == null || id == null) {
            return null;
        }
        return this.getOne(new LambdaQueryWrapper<AiPromptTemplate>()
                .eq(AiPromptTemplate::getTenantId, tenantId)
                .eq(AiPromptTemplate::getId, id)
                .last("limit 1"));
    }
 
    @Override
    public AiPromptTemplate getPublishedTemplate(Long tenantId, String sceneCode) {
        return this.getOne(new LambdaQueryWrapper<AiPromptTemplate>()
                .eq(AiPromptTemplate::getTenantId, tenantId)
                .eq(AiPromptTemplate::getSceneCode, sceneCode)
                .eq(AiPromptTemplate::getPublishedFlag, 1)
                .eq(AiPromptTemplate::getStatus, 1)
                .orderByDesc(AiPromptTemplate::getVersionNo, AiPromptTemplate::getId)
                .last("limit 1"));
    }
 
    @Override
    public List<AiPromptTemplate> listVersions(Long tenantId, String sceneCode) {
        return this.list(new LambdaQueryWrapper<AiPromptTemplate>()
                .eq(AiPromptTemplate::getTenantId, tenantId)
                .eq(AiPromptTemplate::getSceneCode, sceneCode)
                .orderByDesc(AiPromptTemplate::getVersionNo, AiPromptTemplate::getId));
    }
 
    @Override
    public boolean publishTemplate(Long tenantId, Long id, Long userId) {
        AiPromptTemplate target = getTenantTemplate(tenantId, id);
        if (target == null) {
            return false;
        }
        boolean updated = switchPublishedTemplate(tenantId, userId, target);
        if (updated) {
            aiPromptPublishLogService.saveLog(tenantId, userId, target, "publish", "发布 Prompt 版本");
        }
        return updated;
    }
 
    @Override
    public boolean rollbackTemplate(Long tenantId, Long id, Long userId) {
        AiPromptTemplate target = getTenantTemplate(tenantId, id);
        if (target == null) {
            return false;
        }
        boolean updated = switchPublishedTemplate(tenantId, userId, target);
        if (updated) {
            aiPromptPublishLogService.saveLog(tenantId, userId, target, "rollback", "回滚到指定 Prompt 版本");
        }
        return updated;
    }
 
    private boolean switchPublishedTemplate(Long tenantId, Long userId, AiPromptTemplate target) {
        this.update(new LambdaUpdateWrapper<AiPromptTemplate>()
                .set(AiPromptTemplate::getPublishedFlag, 0)
                .eq(AiPromptTemplate::getTenantId, tenantId)
                .eq(AiPromptTemplate::getSceneCode, target.getSceneCode())
                .eq(AiPromptTemplate::getPublishedFlag, 1));
        target.setPublishedFlag(1);
        target.setUpdateBy(userId);
        target.setUpdateTime(new Date());
        return this.updateById(target);
    }
 
    @Override
    public int nextVersionNo(Long tenantId, String sceneCode) {
        AiPromptTemplate latest = this.getOne(new LambdaQueryWrapper<AiPromptTemplate>()
                .eq(AiPromptTemplate::getTenantId, tenantId)
                .eq(AiPromptTemplate::getSceneCode, sceneCode)
                .orderByDesc(AiPromptTemplate::getVersionNo, AiPromptTemplate::getId)
                .last("limit 1"));
        return latest == null || latest.getVersionNo() == null ? 1 : latest.getVersionNo() + 1;
    }
 
    @Override
    public AiPromptTemplate copyTemplate(Long tenantId, Long id, Long userId) {
        AiPromptTemplate source = getTenantTemplate(tenantId, id);
        if (source == null) {
            return null;
        }
        Date now = new Date();
        AiPromptTemplate copied = new AiPromptTemplate()
                .setUuid(String.valueOf(System.currentTimeMillis()))
                .setSceneCode(source.getSceneCode())
                .setTemplateName((source.getTemplateName() == null ? source.getSceneCode() : source.getTemplateName()) + "-副本")
                .setBasePrompt(source.getBasePrompt())
                .setToolPrompt(source.getToolPrompt())
                .setOutputPrompt(source.getOutputPrompt())
                .setVersionNo(nextVersionNo(tenantId, source.getSceneCode()))
                .setPublishedFlag(0)
                .setStatus(source.getStatus())
                .setDeleted(0)
                .setTenantId(tenantId)
                .setCreateBy(userId)
                .setCreateTime(now)
                .setUpdateBy(userId)
                .setUpdateTime(now)
                .setMemo(source.getMemo());
        if (!this.save(copied)) {
            return null;
        }
        aiPromptPublishLogService.saveLog(tenantId, userId, copied, "copy", "复制 Prompt 版本为新草稿");
        return copied;
    }
}