package com.gyee.impala.controller.diagnose;


import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.gyee.impala.common.result.JsonResult;
import com.gyee.impala.common.result.ResultCode;
import com.gyee.impala.common.spring.InitialRunner;
import com.gyee.impala.model.master.Windpowerstation;
import com.gyee.impala.model.master.diagnose.Diagnosepoint;
import com.gyee.impala.service.master.WindpowerstationService;
import com.gyee.impala.service.master.diagnose.DiagnosepointService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

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

@CrossOrigin
@RestController
@RequestMapping("/api/diagnosepoint")
public class DiagnosepointController {

    @Autowired
    private DiagnosepointService diagnosepointService;

    @Autowired
    private WindpowerstationService windpowerstationService;


    /**
     * 获取服务器配置参数信息
     */
    @GetMapping("/list")
    public JSONObject getDiagnosepointList(String station, String model) {
        if (!StringUtils.isEmpty(station) && !StringUtils.isEmpty(model)) {
            List<Diagnosepoint> list = new ArrayList<>();
            list.addAll(InitialRunner.mapPoint.get(station).get(model));
            list.add(new Diagnosepoint().faultType());
            return JsonResult.successData(ResultCode.SUCCESS, list);
        }
        else {
            Collection<Map<String, List<Diagnosepoint>>> list = InitialRunner.mapPoint.values();
            return JsonResult.successData(ResultCode.SUCCESS, list);
        }
    }


    /**
     * 新增
     */
    @PostMapping("/addPoint")
    public JSONObject addDiagnosepointList(@RequestBody JSONObject jsonObject) {
        String name = jsonObject.get("name").toString();
        JSONArray values = jsonObject.getJSONArray("values");

        Windpowerstation station = windpowerstationService.getWindpowerstation(name);

        for (int i = 0; i < values.size(); i++) {
            JSONObject json = values.getJSONObject(i);
            String modelId = json.get("modelId").toString();
            JSONArray codes = json.getJSONArray("codes");

            for (int c = 0; c < codes.size(); c++) {
                JSONObject code = codes.getJSONObject(c);
                List<Diagnosepoint> list = diagnosepointService.getDiagnosepointByModelAndUniformcode(station.getId(),modelId,code.get("code").toString());
               if (null !=list && list.size()>0){
                   continue;
               }
                Diagnosepoint d = new Diagnosepoint();
                if (code.get("code").toString().equals("AI067")) {
                    System.out.println(code.get("code").toString());
                }
                if (code.size() >= 4) {
                    d.setUnit(code.get("unit").toString());
                } else {
                }
                d.setStationcn(station.getName());
                d.setStationen(station.getId());
                d.setModel(modelId);
                d.setUniformcode(code.get("code").toString());
                d.setName(code.get("name").toString());
                d.setOrdernum(Integer.valueOf(code.get("num").toString()));
                diagnosepointService.insertItem(d);
            }
        }
        return JsonResult.success();
    }


}