Browse Source

11.21 消息推送

sunjiabei/feature-20251021102635-银行接口
huangqizhen 5 days ago
parent
commit
fc4ac8cd0b
  1. 4
      src/main/java/com/example/demo/controller/cash/MessageController.java
  2. 2
      src/main/java/com/example/demo/mapper/cash/MessageMapper.java
  3. 3
      src/main/java/com/example/demo/service/cash/MessageService.java
  4. 4
      src/main/java/com/example/demo/serviceImpl/cash/MessageServiceImpl.java
  5. 10
      src/main/resources/cashMapper/MessageMapper.xml

4
src/main/java/com/example/demo/controller/cash/MessageController.java

@ -38,7 +38,7 @@ public class MessageController {
@Autowired @Autowired
private MarketService marketService; private MarketService marketService;
@PostMapping @PostMapping
public Result getMessage() throws Exception {
public Result getMessage(@RequestParam Integer status) throws Exception {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
String token = request.getHeader("token"); String token = request.getHeader("token");
@ -51,7 +51,7 @@ public class MessageController {
if (markets.contains("9") || markets.contains("9999")) { if (markets.contains("9") || markets.contains("9999")) {
markets=null; markets=null;
} }
return Result.success(messageService.getMessage(markets));
return Result.success(messageService.getMessage(markets, status));
} }
@PostMapping("/update") @PostMapping("/update")
public Result update(@RequestBody IdRequest idRequest) throws Exception { public Result update(@RequestBody IdRequest idRequest) throws Exception {

2
src/main/java/com/example/demo/mapper/cash/MessageMapper.java

@ -16,7 +16,7 @@ import java.util.List;
**/ **/
@Mapper @Mapper
public interface MessageMapper { public interface MessageMapper {
List<Messages> getMessage(List<String> markets);
List<Messages> getMessage(List<String> markets, Integer status);
void update(Integer id); void update(Integer id);
} }

3
src/main/java/com/example/demo/service/cash/MessageService.java

@ -1,6 +1,7 @@
package com.example.demo.service.cash; package com.example.demo.service.cash;
import com.example.demo.domain.vo.coin.Messages; import com.example.demo.domain.vo.coin.Messages;
import com.stripe.model.tax.Registration;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List; import java.util.List;
@ -15,7 +16,7 @@ import java.util.List;
**/ **/
@Service @Service
public interface MessageService { public interface MessageService {
List<Messages> getMessage(List<String> markets);
List<Messages> getMessage(List<String> markets, Integer status);
void update(Integer id) throws Exception; void update(Integer id) throws Exception;
} }

4
src/main/java/com/example/demo/serviceImpl/cash/MessageServiceImpl.java

@ -23,8 +23,8 @@ public class MessageServiceImpl implements MessageService {
@Autowired @Autowired
private MessageMapper messageMapper; private MessageMapper messageMapper;
@Override @Override
public List<Messages> getMessage(List<String> markets) {
return messageMapper.getMessage(markets) ;
public List<Messages> getMessage(List<String> markets, Integer status) {
return messageMapper.getMessage(markets, status) ;
} }
@Override @Override

10
src/main/resources/cashMapper/MessageMapper.xml

@ -11,6 +11,9 @@
FROM message FROM message
<where> <where>
flag=0 flag=0
<if test="status != null">
and status=#{status}
</if>
<choose> <choose>
<when test="markets != null and markets.size() > 0"> <when test="markets != null and markets.size() > 0">
market IN market IN
@ -19,14 +22,7 @@
</foreach> </foreach>
</when> </when>
</choose> </choose>
<choose>
<when test="sortField != null and sortField.length > 0 or sortOrder != null and sortOrder.length > 0">
ORDER BY ${sortField} ${sortOrder}
</when>
<otherwise>
ORDER BY cz_time DESC ORDER BY cz_time DESC
</otherwise>
</choose>
</where> </where>
</select> </select>
</mapper> </mapper>
Loading…
Cancel
Save