package cn.gistack.sm.message.feign;
|
|
import cn.gistack.sm.intelligentCall.entity.CallNotFillRecord;
|
import cn.gistack.sm.intelligentCall.feign.OutCallClient;
|
import cn.gistack.sm.intelligentCall.service.CallService;
|
import cn.gistack.sm.intelligentCall.service.ICallNotFillRecordService;
|
import cn.gistack.sm.intelligentCall.service.ICallSmsNoticeTaskService;
|
import cn.gistack.sm.message.entity.MessageRecord;
|
import cn.gistack.sm.message.service.impl.MessageRecordService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RestController;
|
import springfox.documentation.annotations.ApiIgnore;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* Feign实现类
|
* @author zhongrj
|
* @date 2023-07-07
|
*/
|
@NonDS
|
@ApiIgnore
|
@RestController
|
@AllArgsConstructor
|
@Slf4j
|
public class MessageClient implements IMessageClient {
|
|
@Autowired
|
private MessageRecordService messageRecordService;
|
|
/**
|
* 保存站内信记录信息
|
* @param messageRecord
|
* @return
|
*/
|
@Override
|
@PostMapping(SAVE_MESSAGE_RECORD)
|
public void saveMessageRecord(@RequestBody List<MessageRecord> messageRecord) {
|
// 批量新增
|
messageRecordService.saveBatch(messageRecord);
|
}
|
|
/**
|
* 查询用户未读消息数量
|
* @param phone
|
* @return
|
*/
|
@Override
|
public Integer getNotReadNumber(String phone) {
|
return messageRecordService.getNotReadNumber(phone);
|
}
|
|
@Override
|
public List<MessageRecord> getNotReadList(String userId) {
|
MessageRecord messageRecord = new MessageRecord();
|
messageRecord.setRecipient(userId);
|
messageRecord.setStatus(0);
|
return messageRecordService.list(Condition.getQueryWrapper(messageRecord));
|
}
|
}
|
