dataExchange/src/main/java/com/dc/datachange/communityQuality/controller/CommunityQualityController.java

package com.dc.datachange.communityQuality.controller;

import com.dc.datachange.utils.R;
import com.dc.datachange.communityQuality.entity.LinkParam;
import com.dc.datachange.communityQuality.entity.Message;
import org.springframework.web.bind.annotation.*;


import java.util.ArrayList;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/community")
public class CommunityQualityController {

    private final List<Map<String, Object>> nodeList = new ArrayList<>();
    private final LinkParam linkParam = new LinkParam();
    private final List<Message> messageArrayList = new ArrayList<>();
    private final List<Message> receivedMessageArrayList = new ArrayList<>();

    @GetMapping("listLinkParam")
    public R listLinkParam() {
        System.out.printf(linkParam.toString());
        return R.ok().put("linkParam", linkParam);
    }

    @PostMapping("updateLink")
    public R updateLink(@RequestParam Map<String, Object> params) {
        int id = Integer.parseInt(params.get("PlatformID").toString());
        int isValid = Integer.parseInt(params.get("isValid").toString());
        int isSilence = Integer.parseInt(params.get("isSilence").toString());
        String linkSpeed = params.get("linkSpeed").toString();
        String linkQuality = params.get("linkQuality").toString();
        String nodeName = params.get("nodeName").toString();

        linkParam.setPlatformID(id);
        linkParam.setLinkSwitch(isValid);
        linkParam.setLinkQuality(linkQuality);
        linkParam.setLinkSpeed(linkSpeed);
        linkParam.setLinkSilent(isSilence);
        linkParam.setSelectedNode(nodeName);
        return R.ok();
    }

    @PostMapping("sendMessage")
    public R sendMessage(@RequestBody List<Message> messageList) {
        messageArrayList.addAll(messageList);
        return R.ok();
    }

    @GetMapping("listReceivedMessage")
    public R listReceivedMessage() {
        for (Message message : messageArrayList) {
            if (message.getStatus().equals("成功")){
                receivedMessageArrayList.add(message);
            }
        }
        return R.ok().put("receivedMessage", receivedMessageArrayList);
    }
}