1

zj

2026-01-04 33ec216214e24410fc0d39dbb0918a2e23f6ea30

 src/main/java/com/nq/service/impl/SiteMessageServiceImpl.java

@@ -5,10 +5,12 @@
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.dao.SiteMessageMapper;
import com.nq.dao.UserMapper;
import com.nq.pojo.SiteMessage;
import com.nq.pojo.User;
import com.nq.service.ISiteMessageService;
import com.nq.service.IUserService;
import com.nq.utils.DateTimeUtil;
import com.nq.vo.agent.AgentAgencyFeeVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -30,6 +32,9 @@

    @Autowired
    IUserService iUserService;

    @Autowired
    UserMapper userMapper;

    @Override
    public int insert(SiteMessage siteMessage) {
@@ -113,4 +118,50 @@
        return ServerResponse.createByErrorMsg("删除失败");
    }

    @Override
    public ServerResponse sendMessage(Integer userId, String content, String typeName) {
        int ret = 0;
        if (content == null || content.trim().isEmpty()) {
            return ServerResponse.createByErrorMsg("消息内容不能为空");
        }

        try {
            // userId为0或null表示发送给所有用户
            if (userId == null || userId == 0) {
                List<User> users = this.userMapper.listByAdmin(null, null, null, null);
                for (User user : users) {
                    SiteMessage siteMessage = new SiteMessage();
                    siteMessage.setUserId(user.getId());
                    siteMessage.setUserName(user.getRealName() != null ? user.getRealName() : user.getPhone());
                    siteMessage.setTypeName(typeName != null ? typeName : "站内消息");
                    siteMessage.setStatus(1); // 1表示未读
                    siteMessage.setContent(content);
                    siteMessage.setAddTime(DateTimeUtil.getCurrentDate());
                    ret = siteMessageMapper.insert(siteMessage);
                }
            } else {
                // 发送给指定用户
                User user = userMapper.selectByPrimaryKey(userId);
                if (user == null) {
                    return ServerResponse.createByErrorMsg("用户不存在");
                }
                SiteMessage siteMessage = new SiteMessage();
                siteMessage.setUserId(user.getId());
                siteMessage.setUserName(user.getRealName() != null ? user.getRealName() : user.getPhone());
                siteMessage.setTypeName(typeName != null ? typeName : "站内消息");
                siteMessage.setStatus(1); // 1表示未读
                siteMessage.setContent(content);
                siteMessage.setAddTime(DateTimeUtil.getCurrentDate());
                ret = siteMessageMapper.insert(siteMessage);
            }

            if (ret > 0) {
                return ServerResponse.createBySuccessMsg("发送成功");
            }
            return ServerResponse.createByErrorMsg("发送失败");
        } catch (Exception e) {
            return ServerResponse.createByErrorMsg("发送失败：" + e.getMessage());
        }
    }

}