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) { // 批量新增 messageRecordService.saveBatch(messageRecord); } /** * 查询用户未读消息数量 * @param phone * @return */ @Override public Integer getNotReadNumber(String phone) { return messageRecordService.getNotReadNumber(phone); } @Override public List getNotReadList(String userId) { MessageRecord messageRecord = new MessageRecord(); messageRecord.setRecipient(userId); messageRecord.setStatus(0); return messageRecordService.list(Condition.getQueryWrapper(messageRecord)); } @Override @GetMapping(GET_NO_ALERT_RES_LIST) public String getNoAlertRes(String ruleName) { return messageRecordService.getNoAlertRes(ruleName); } }