diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/AccountChangeLogController.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/AccountChangeLogController.java
index 7a89cee1..c63a95a4 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/AccountChangeLogController.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/AccountChangeLogController.java
@@ -57,8 +57,7 @@ public class AccountChangeLogController extends BaseController {
     @SaCheckPermission("cai:accountChangeLog:list")
     @GetMapping("/list")
     public TableDataInfo<AccountChangeLog> list(AccountChangeLog bo, PageQuery pageQuery) {
-        Page<AccountChangeLog> page = accountChangeLogService.page(pageQuery.build(),
-                Wrappers.lambdaQuery(bo).orderByDesc(AccountChangeLog::getCreateTime));
+        Page<AccountChangeLog> page = accountChangeLogService.pageAdmin(pageQuery, bo);
         return TableDataInfo.build(page);
     }
 
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/ConsumeLogController.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/ConsumeLogController.java
index 5c387181..7d78578a 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/ConsumeLogController.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/controller/admin/ConsumeLogController.java
@@ -83,9 +83,10 @@ public class ConsumeLogController extends BaseController {
     @SaCheckPermission("cai:consumeLog:edit")
     @Log(title = "消费记录", businessType = BusinessType.UPDATE)
     @RepeatSubmit()
-    @PutMapping()
-    public R<Void> edit(@Validated(EditGroup.class) @RequestBody ConsumeLog bo) {
-        return toAjax(consumeLogService.updateById(bo));
+    @GetMapping("/consumer")
+    public R<Void> consumer(Long id) {
+        consumeLogService.dealFenxiao(id,false);
+        return R.ok();
     }
 
     /**
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/domain/AccountChangeLog.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/domain/AccountChangeLog.java
index 3a68927e..dbc1313d 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/domain/AccountChangeLog.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/domain/AccountChangeLog.java
@@ -1,5 +1,6 @@
 package com.ruoyi.cai.domain;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.ruoyi.cai.enums.account.AccountChangeCodeEnum;
@@ -47,7 +48,6 @@ public class AccountChangeLog implements Serializable {
      * 名称
      */
     private String cateAdminName;
-    private String cateAppName;
     private Long traceId;
     private String traceLinkType;
     /**
@@ -70,11 +70,13 @@ public class AccountChangeLog implements Serializable {
 
     private LocalDateTime createTime;
 
+    @TableField(exist = false)
+    private String showMessage;
+
 
     public void init(AccountChangeCodeEnum change){
         this.setAccountType(change.getAccountType().getCode());
         this.setCateId(change.getCate().getCode());
-        this.setCateAppName(change.getText());
         this.setCateAdminName(change.getText());
         this.setTraceLinkType(change.getCate().name());
         this.setRemark(change.getDesc());
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AccountChangeLogService.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AccountChangeLogService.java
index ec021d32..8c3fc6a2 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AccountChangeLogService.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/AccountChangeLogService.java
@@ -1,9 +1,11 @@
 package com.ruoyi.cai.service;
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ruoyi.cai.domain.AccountChangeLog;
 import com.ruoyi.cai.domain.Gift;
 import com.ruoyi.cai.enums.account.AccountChangeCodeEnum;
+import com.ruoyi.common.core.domain.PageQuery;
 
 /**
  * 账户明细Service接口
@@ -24,4 +26,6 @@ public interface AccountChangeLogService extends IService<AccountChangeLog> {
             , Long tarUserId, Gift gift);
 
     AccountChangeLog saveLogAdmin(Long userId, String usercode, AccountChangeCodeEnum change, Long price, Long traceId);
+
+    Page<AccountChangeLog> pageAdmin(PageQuery pageQuery, AccountChangeLog bo);
 }
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountChangeLogServiceImpl.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountChangeLogServiceImpl.java
index 7ae07a0e..3d826800 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountChangeLogServiceImpl.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountChangeLogServiceImpl.java
@@ -1,13 +1,26 @@
 package com.ruoyi.cai.service.impl;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.cai.domain.AccountChangeLog;
 import com.ruoyi.cai.domain.Gift;
+import com.ruoyi.cai.domain.User;
+import com.ruoyi.cai.enums.account.AccountCateEnum;
 import com.ruoyi.cai.enums.account.AccountChangeCodeEnum;
 import com.ruoyi.cai.mapper.AccountChangeLogMapper;
 import com.ruoyi.cai.service.AccountChangeLogService;
+import com.ruoyi.cai.service.UserService;
+import com.ruoyi.common.core.domain.PageQuery;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
 /**
  * 账户明细Service业务层处理
  *
@@ -69,5 +82,39 @@ public class AccountChangeLogServiceImpl extends ServiceImpl<AccountChangeLogMap
         return changeLog;
     }
 
+    @Autowired
+    private UserService userService;
+
+    @Override
+    public Page<AccountChangeLog> pageAdmin(PageQuery pageQuery, AccountChangeLog bo) {
+        Page<AccountChangeLog> page = this.page(pageQuery.build(), Wrappers.lambdaQuery(bo).orderByDesc(AccountChangeLog::getCreateTime));
+        List<AccountChangeLog> records = page.getRecords();
+        Set<Long> userIds = records.stream().map(AccountChangeLog::getTarUserId).collect(Collectors.toSet());
+        if(records.isEmpty()){
+            return page;
+        }
+        List<User> users = userService.listByIds(userIds);
+        Map<Long, User> userMap = users.stream().collect(Collectors.toMap(User::getId, Function.identity()));
+        for (AccountChangeLog record : records) {
+            User user = userMap.get(record.getTarUserId());
+            if(user != null){
+                String format = String.format("%s来自【%s】", record.getCateAdminName(), user.getNickname());
+                record.setShowMessage(format);
+            }else{
+                record.setShowMessage(record.getCateAdminName());
+            }
+            if(AccountCateEnum.IM.getCode().equals(record.getCateId())
+                || AccountCateEnum.SYSTEM.getCode().equals(record.getCateId())
+                || AccountCateEnum.UNION.getCode().equals(record.getCateId())){
+                if(record.getTarUserId() != null){
+                    if(user != null){
+                        record.setTarImg(user.getAvatar());
+                    }
+                }
+            }
+        }
+        return page;
+    }
+
 
 }
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java
index cfb298a3..ca6a428e 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AccountServiceImpl.java
@@ -112,13 +112,13 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
         }
         if(incomeCoin != 0){
             AccountChangeCodeEnum change = ConsumeLogType.getSourceChange(consumeLogType, AccountTypeEnum.INCOME_COIN);
-            accountChangeLogService.saveLogNoAdmin(userId, consumeLog.getSourceUsercode(), change, coin, consumeLog.getTraceId()
+            accountChangeLogService.saveLogNoAdmin(userId, consumeLog.getSourceUsercode(), change, incomeCoin, consumeLog.getTraceId()
                     ,consumeLog.getTargetUserId(),gift);
         }
         // 记录接收方的流水
         if(targetUserId != null){
             AccountChangeCodeEnum change = ConsumeLogType.getTargetChange(consumeLogType);
-            accountChangeLogService.saveLogNoAdmin(userId, consumeLog.getSourceUsercode(), change, coin, consumeLog.getTraceId()
+            accountChangeLogService.saveLogNoAdmin(userId, consumeLog.getSourceUsercode(), change, consumeLog.getAnchorAmount(), consumeLog.getTraceId()
                     ,consumeLog.getSourceUserId(),gift);
         }
         // 获取分销的比例和用户