Explorar o código

定时发送ai物流,存储记录到fastgpt_event_token_log

yh hai 5 días
pai
achega
137d36f6d1

+ 3 - 0
fs-service/src/main/java/com/fs/company/service/impl/OpenServiceImpl.java

@@ -8,6 +8,7 @@ import com.fs.erp.domain.ErpDeliverys;
 import com.fs.erp.dto.ErpDeliverysResponse;
 import com.fs.fastGpt.domain.FastGptRole;
 import com.fs.fastGpt.service.IFastGptRoleService;
+import com.fs.fastgptApi.util.EventLogUtils;
 import com.fs.his.mapper.FsStoreOrderMapper;
 import com.fs.his.utils.PhoneUtil;
 import com.fs.hisStore.domain.FsStoreOrderScrm;
@@ -196,6 +197,8 @@ public class OpenServiceImpl implements OpenService {
                                         wxWorkService.SendTextMsg(wxWorkSendTextMsgDTO, qwUser.getServerId());
                                         log.info("康年堂每日上午9点和下午4点发送物流消息 AI物流消息发送成功 - orderId: {}, sendId: {}", orderId, sendId);
 
+                                        // 保存日志到 fastgpt_event_token_log
+                                        EventLogUtils.recordEventTokenLog("定时发送ai物流消耗token(康年堂调用)", null, 1, 400L, 2, qwUser);
                                     } catch (Exception e) {
                                         log.error("康年堂每日上午9点和下午4点发送物流消息 AI物流消息发送失败 - orderId: {}, sendId: {}, 错误信息: {}", orderId, sendId, e.getMessage(), e);
                                         return R.error("AI物流消息发送失败");

+ 7 - 0
fs-service/src/main/java/com/fs/erp/service/impl/DfOrderServiceImpl.java

@@ -27,6 +27,7 @@ import com.fs.erp.dto.sdk.df.enums.RequestUrlEnum;
 import com.fs.erp.service.IErpOrderService;
 import com.fs.fastGpt.domain.FastGptRole;
 import com.fs.fastGpt.service.IFastGptRoleService;
+import com.fs.fastgptApi.util.EventLogUtils;
 import com.fs.his.config.FsSysConfig;
 import com.fs.his.domain.*;
 import com.fs.his.enums.FsStoreOrderLogEnum;
@@ -954,6 +955,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
                                             if ("301".equals(stateEx)){
                                                 redisCache.sAdd(signedKey, orderId.toString());
                                             }
+
+                                            // 保存日志到 fastgpt_event_token_log
+                                            EventLogUtils.recordEventTokenLog("定时发送ai物流消耗token", null, 1, 400L, 2, qwUser);
                                         } catch (Exception e) {
                                             log.error("AI物流消息发送失败 - orderId: {}, sendId: {}, 错误信息: {}", orderId, sendId, e.getMessage(), e);
                                         }
@@ -1433,6 +1437,9 @@ public class DfOrderServiceImpl implements IErpOrderService {
                                         if ("301".equals(stateEx)){
                                             redisCache.sAdd(signedKey, orderId.toString());
                                         }
+
+                                        // 保存日志到 fastgpt_event_token_log
+                                        EventLogUtils.recordEventTokenLog("定时发送ai物流消耗token", null, 1, 400L, 2, qwUser);
                                     } catch (Exception e) {
                                         log.error("每日上午9点和下午4点发送物流消息 AI物流消息发送失败 - orderId: {}, sendId: {}, 错误信息: {}", orderId, sendId, e.getMessage(), e);
                                     }