Skip to content

Commit 7c662e9

Browse files
committed
refactor(Upload): 优化七牛云回调处理逻辑
- 提前创建 Auth 对象,减少重复代码 - 调整违规文件处理流程: - 修改处罚积分:block 情况下为 100 积分,review 情况下为 50 积分 - 优化处罚通知消息内容- 移除冗余的异常捕获块
1 parent a8c593a commit 7c662e9

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

src/main/java/org/b3log/symphony/processor/ApiProcessor.java

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,8 @@ public void loginWebInApiKey(final RequestContext context) {
182182
}
183183

184184
public void callbackFromQiNiu(final RequestContext context) {
185+
Auth auth = Auth.create(Symphonys.UPLOAD_QINIU_AK, Symphonys.UPLOAD_QINIU_SK);
186+
185187
JSONObject jsonObject = context.requestJSON();
186188
LOGGER.log(Level.INFO, jsonObject.toString());
187189

@@ -195,7 +197,6 @@ public void callbackFromQiNiu(final RequestContext context) {
195197
String suggestion = jsonObject.optJSONArray("items").optJSONObject(0).optJSONObject("result").optJSONObject("result").optString("suggestion");
196198
if (suggestion.equals("block") || suggestion.equals("review")) {
197199
try {
198-
Auth auth = Auth.create(Symphonys.UPLOAD_QINIU_AK, Symphonys.UPLOAD_QINIU_SK);
199200
String[] urls = new String[]{fileURL};
200201
CdnManager c = new CdnManager(auth);
201202
CdnResult.RefreshResult result = c.refreshUrls(urls);
@@ -213,29 +214,27 @@ public void callbackFromQiNiu(final RequestContext context) {
213214
switch (suggestion) {
214215
case "block":
215216
try {
216-
Auth auth = Auth.create(Symphonys.UPLOAD_QINIU_AK, Symphonys.UPLOAD_QINIU_SK);
217217
String[] urls = new String[]{fileURL};
218218
CdnManager c = new CdnManager(auth);
219219
CdnResult.RefreshResult result = c.refreshUrls(urls);
220220
LOGGER.log(Level.INFO, "CDN Refresh result: " + result.code);
221221
LOGGER.log(Level.WARN, "Block file " + fileURL);
222-
ChatRoomBot.sendBotMsg("[AI审查] 犯罪嫌疑人 @" + userName + " 由于上传违法文件/图片,被处以 50 积分的处罚,请引以为戒。如误报请联系管理员找回积分!\n@adlered 留档");
223-
ChatRoomBot.abusePoint(userId, 50, "[AI审查] [如有误报请联系管理员追回积分] 机器人罚单-上传违法文件");
222+
ChatRoomBot.sendBotMsg("[AI审查] 犯罪嫌疑人 @" + userName + " 由于上传违规文件/图片,被处以 100 积分的处罚,请引以为戒。如误报请联系管理员找回积分!\n@adlered 留档");
223+
ChatRoomBot.abusePoint(userId, 100, "[AI审查] [如有误报请联系管理员追回积分] 机器人罚单-上传违规文件");
224224
LogsService.censorLog(context, userName, "用户:" + userName + " 上传违规图片:" + fileURL);
225225
} catch (Exception e) {
226226
LOGGER.error(e);
227227
}
228228
break;
229229
case "review":
230230
try {
231-
Auth auth = Auth.create(Symphonys.UPLOAD_QINIU_AK, Symphonys.UPLOAD_QINIU_SK);
232231
String[] urls = new String[]{fileURL};
233232
CdnManager c = new CdnManager(auth);
234233
CdnResult.RefreshResult result = c.refreshUrls(urls);
235234
LOGGER.log(Level.INFO, "CDN Refresh result: " + result.code);
236235
LOGGER.log(Level.WARN, "Review file " + fileURL);
237-
ChatRoomBot.sendBotMsg("[AI审查] 用户 @" + userName + " 由于上传疑似违规文件/图片,被处以 20 积分的处罚,请引以为戒。如误报请联系管理员找回积分!\n@adlered 留档");
238-
ChatRoomBot.abusePoint(userId, 20, "[AI审查] [如有误报请联系管理员追回积分] 机器人罚单-上传疑似违规文件");
236+
ChatRoomBot.sendBotMsg("[AI审查] 用户 @" + userName + " 由于上传疑似违规文件/图片,被处以 50 积分的处罚,请引以为戒。如误报请联系管理员找回积分!\n@adlered 留档");
237+
ChatRoomBot.abusePoint(userId, 50, "[AI审查] [如有误报请联系管理员追回积分] 机器人罚单-上传疑似违规文件");
239238
LogsService.censorLog(context, userName, "用户:" + userName + " 上传疑似违规图片:" + fileURL);
240239
} catch (Exception e) {
241240
LOGGER.error(e);

0 commit comments

Comments
 (0)