//package com.iailab.module.http.service.impl;
//
//import com.alibaba.fastjson.JSONObject;
//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
//import com.baomidou.mybatisplus.core.metadata.IPage;
//import com.baomidou.mybatisplus.core.toolkit.StringUtils;
//import com.iailab.framework.common.service.impl.BaseServiceImpl;
//import com.iailab.common.utils.HttpsRequest;
//import com.iailab.common.utils.PageUtils;
//import com.iailab.common.utils.Query;
//import com.iailab.module.http.dao.FxjyTagDao;
//import com.iailab.module.http.entity.FxjyTagEntity;
//import com.iailab.module.http.service.HttpApiService;
//import lombok.extern.slf4j.Slf4j;
//import javax.annotation.Resource;
//import org.springframework.stereotype.Service;
//
//import java.lang.reflect.Field;
//import java.math.BigDecimal;
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//
//@Slf4j
//@Service
//public class FxjyTagServiceImpl extends BaseServiceImpl<FxjyTagDao, FxjyTagEntity> implements FxjyTagService {
//
//    @Resource
//    private HttpsRequest httpsRequest;
//
//    @Resource
//    private HttpApiService httpApiService;
//
//    private final String API_CODE = "fxjyHttpTag";
//
//    /**
//     * 分页查询tag
//     *
//     * @param params
//     */
//    @Override
//    public PageUtils queryPage(Map<String, Object> params) {
//        String tagType = (String) params.get("tagType");
//        String tagCode = (String) params.get("tagCode");
//        String tagName = (String) params.get("tagName");
//
//        IPage<FxjyTagEntity> page = baseDao.selectPage(
//                new Query<FxjyTagEntity>().getPage(params),
//                new QueryWrapper<FxjyTagEntity>()
//                        .like(StringUtils.isNotBlank(tagType), "tag_type", tagType)
//                        .like(StringUtils.isNotBlank(tagCode), "tag_code", tagCode)
//                        .like(StringUtils.isNotBlank(tagName), "tag_name", tagName)
//                        .orderByDesc("create_time")
//        );
//        return new PageUtils(page);
//    }
//
//    @Override
//    public Map<String, BigDecimal> getTagsValues(List<FxjyCurrentDto> tags){
//        Map<String, BigDecimal> result = new HashMap<>(tags.size());
//        Map<String, String> params = new HashMap<>(2);
//        String url = httpApiService.getByCode(API_CODE).getUrl();
////        String responseStr = httpsRequest.doGet(url, params,"utf-8", "");
//        String responseStr = "{\n" +
//                "\"flag\":true,\n" +
//                "\"data\":{\n" +
//                "\"ST\":\"2024-01-1616:42:36\",\n" +
//                "\"JYJ1\":{\n" +
//                "\"CURRENT_SPEED\":199.17,\n" +
//                "\"DL\":4.5,\n" +
//                "\"CW\":false,\n" +
//                "\"EN\":true,\n" +
//                "\"FAULT\":false,\n" +
//                "\"GL\":false,\n" +
//                "\"GY\":false,\n" +
//                "\"QY\":false,\n" +
//                "\"RUNING\":true,\n" +
//                "\"SPEED_SET\":200.0\n" +
//                "},\n" +
//                "\"JYJ2\":{\n" +
//                "\"CURRENT_SPEED\":0.0,\n" +
//                "\"DL\":1.8,\n" +
//                "\"CW\":false,\n" +
//                "\"EN\":true,\n" +
//                "\"FAULT\":false,\n" +
//                "\"GL\":false,\n" +
//                "\"GY\":false,\n" +
//                "\"QY\":false,\n" +
//                "\"RUNING\":false,\n" +
//                "\"SPEED_SET\":50.0\n" +
//                "},\n" +
//                "\"JYJ3\":{\n" +
//                "\"CURRENT_SPEED\":199.17,\n" +
//                "\"DL\":4.5,\n" +
//                "\"CW\":false,\n" +
//                "\"EN\":true,\n" +
//                "\"FAULT\":false,\n" +
//                "\"GL\":false,\n" +
//                "\"GY\":false,\n" +
//                "\"QY\":false,\n" +
//                "\"RUNING\":true,\n" +
//                "\"SPEED_SET\":200.0\n" +
//                "},\n" +
//                "\"JYJ4\":{\n" +
//                "\"CURRENT_SPEED\":0.0,\n" +
//                "\"DL\":1.8,\n" +
//                "\"CW\":false,\n" +
//                "\"EN\":true,\n" +
//                "\"FAULT\":false,\n" +
//                "\"GL\":false,\n" +
//                "\"GY\":false,\n" +
//                "\"QY\":false,\n" +
//                "\"RUNING\":false,\n" +
//                "\"SPEED_SET\":50.0\n" +
//                "},\n" +
//                "\"FXJY\":{\n" +
//                "\"YW401\":5.49,\n" +
//                "\"YW407\":66.83,\n" +
//                "\"YW408\":19.92,\n" +
//                "\"PumpRun_402A\":true,\n" +
//                "\"PumpRun_402B\":true,\n" +
//                "\"YCLQ_Run_403A\":true,\n" +
//                "\"YCLQ_Run_403B\":true,\n" +
//                "\"Valve1_GDW\":false,\n" +
//                "\"Valve1_KDW\":true,\n" +
//                "\"Valve1_ZZK\":false,\n" +
//                "\"Valve1_ZZG\":false,\n" +
//                "\"Valve2_GDW\":true,\n" +
//                "\"Valve2_KDW\":false,\n" +
//                "\"Valve2_ZZK\":false,\n" +
//                "\"Valve2_ZZG\":false,\n" +
//                "\"Valve3_GDW\":false,\n" +
//                "\"Valve3_KDW\":true,\n" +
//                "\"Valve3_ZZK\":false,\n" +
//                "\"Valve3_ZZG\":false,\n" +
//                "\"Valve4_GDW\":true,\n" +
//                "\"Valve4_KDW\":false,\n" +
//                "  \"Valve4_ZZK\": false,\n" +
//                "\"Valve4_ZZG\": false,\n" +
//                "\"ZLLLJ1_403A\": 19.35,\n" +
//                "\"ZLLLJ2_403A\": 2.73,\n" +
//                "\"ZLLLJ1_403B\": 15.99,\n" +
//                "\"ZLLLJ2_403B\": 5.19,\n" +
//                "\"FXRL_LLJ_403A1\": 983.75,\n" +
//                "\"FXRL_LLJ_403A2\": 583.91,\n" +
//                "\"FXPMHDJC1\": 5.11,\n" +
//                "\"FXPMHDJC2\": 1.95,\n" +
//                "\"LD3_LD1\": 0.0,\n" +
//                "\"LD3_LD2\": 0.0,\n" +
//                "\"LD3_ND\": 0.0\n" +
//                "},\n" +
//                "\"YLXT\": {\n" +
//                "\"YW405A\": 21.98,\n" +
//                "\"YW405B\": 17.04,\n" +
//                "\"YW601\": 33.79,\n" +
//                "\"VF861_Run\": true,\n" +
//                "\"VF862_Run\": true,\n" +
//                "\"VF863_Run\": true,\n" +
//                "\"KM414A_Run\": false,\n" +
//                "\"KM414B_Run\": false,\n" +
//                "\"KM418A_Run\": false,\n" +
//                "\"KM418B_Run\": false,\n" +
//                "\"KM602A_Run\": false,\n" +
//                "\"KM602B_Run\": false,\n" +
//                "\"KM602C_Run\": true,\n" +
//                "\"KM416A_Run\": false,\n" +
//                "\"KM416B_Run\": false,\n" +
//                "\"KM420A_Run\": false,\n" +
//                "\"KM420B_Run\": false,\n" +
//                "\"KM606A_Run\": false,\n" +
//                "\"KM606B_Run\": false,\n" +
//                "\"KM606C_Run\": false\n" +
//                "},\n" +
//                "\"LJL\": {\n" +
//                "\"Timestamp\": \"2024-01-16\",\n" +
//                "\"JYJ1\": 120.53,\n" +
//                "\"JYJ2\": 0.0,\n" +
//                "\"JYJ3\": 117.66,\n" +
//                "\"JYJ4\": 0.0\n" +
//                "},\n" +
//                "\"YCZ\": {\n" +
//                "\"JYJ1\": 249.6,\n" +
//                "\"JYJ2\": 0.0,\n" +
//                "\"JYJ3\": 248.23,\n" +
//                "\"JYJ4\": 0.0\n" +
//                "},\n" +
//                "\"YLCS\": {\n" +
//                "\"YL415A_GLCSXS\": 7,\n" +
//                "\"YL415B_GLCSXS\": 8,\n" +
//                "\"YL419A_GLCSXS\": 7,\n" +
//                "\"YL419B_GLCSXS\": 8,\n" +
//                "\"YL603A_GLCSXS\": 1,\n" +
//                "\"YL603B_GLCSXS\": 0,\n" +
//                "\"YL603C_GLCSXS\": 3\n" +
//                "},\n" +
//                "\"TEMP\": {\n" +
//                "\"FXRLNDJ403A\": 67.12\n" +
//                "}\n" +
//                "},\n" +
//                "\"msg\": \"查询成功\"\n" +
//                "}";
//        if (StringUtils.isNotBlank(responseStr)) {
//            FxjyJsonDto fxjyJsonDto = parseDto(responseStr);
//            fxjyJsonDto.getData().getLJL().getJYJ1();
//            tags.stream().forEach(
//                    item->{
//                        Class<?> fxjyClass= fxjyJsonDto.getData().getClass();
//                        try {
//                            Class<?> fxjyTypeClass = fxjyClass.getDeclaredField(item.getTagType()).getClass();
//                            Field field = fxjyTypeClass.getDeclaredField(item.getTagCode());
//                            field.setAccessible(true);
//                            BigDecimal value = new BigDecimal((String)field.get(fxjyJsonDto.getData()));
//                            result.put(item.getTagType()+"_"+item.getTagCode(), value);
//                        }catch (NoSuchFieldException e){
//                            log.info("没有找到tag"+item.getTagType()+";"+item.getTagCode());
//                        }catch(IllegalAccessException e){
//                            log.info("没有反射权限");
//                        }
//                    }
//            );
//        }
//        return result;
//    }
//
//    @Override
//    public List<FxjyTagEntity> selectList() {
//        return baseDao.selectList(new QueryWrapper<FxjyTagEntity>().orderByDesc("create_time"));
//    }
//
//    private FxjyJsonDto parseDto(String responseStr) {
//        FxjyJsonDto result = new FxjyJsonDto();
//        if (!org.apache.commons.lang.StringUtils.isEmpty(responseStr)) {
//            JSONObject items = JSONObject.parseObject(responseStr);
//            result = items.toJavaObject(FxjyJsonDto.class);
//        }
//        return result;
//    }
//}