queryIdList();
+}
diff --git a/manufact_influx_data/src/main/java/com/njcn/manufactinflux/service/impl/InfluxManufactServiceImpl.java b/manufact_influx_data/src/main/java/com/njcn/manufactinflux/service/impl/InfluxManufactServiceImpl.java
new file mode 100644
index 0000000..1895512
--- /dev/null
+++ b/manufact_influx_data/src/main/java/com/njcn/manufactinflux/service/impl/InfluxManufactServiceImpl.java
@@ -0,0 +1,313 @@
+package com.njcn.manufactinflux.service.impl;
+
+
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.LocalDateTimeUtil;
+import cn.hutool.core.text.StrPool;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.njcn.influx.imapper.*;
+import com.njcn.influx.pojo.po.*;
+import com.njcn.influx.query.InfluxQueryWrapper;
+import com.njcn.influx.utils.InfluxDbUtils;
+import com.njcn.manufactinflux.param.JobQueryParam;
+import com.njcn.manufactinflux.service.IInfluxManufactService;
+import com.njcn.manufactinflux.service.IMonitorService;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.collections4.ListUtils;
+import org.influxdb.dto.QueryResult;
+import org.influxdb.impl.InfluxDBResultMapper;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.temporal.ChronoUnit;
+import java.time.temporal.TemporalUnit;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class InfluxManufactServiceImpl implements IInfluxManufactService {
+
+
+ static InfluxDBResultMapper resultMapper = new InfluxDBResultMapper();
+
+ @Resource
+ private IMonitorService monitorService;
+
+ private final DataVMapper dataVMapper;
+
+ private final IDataIMapper dataIMapper;
+
+ private final DataInHarmVMapper dataInHarmVMapper;
+
+ private final DataHarmRateVMapper dataHarmRateVMapper;
+
+ private final DataFlickerMapper dataFlickerMapper;
+
+ private final DataPltMapper dataPltMapper;
+
+
+ @Value("${spring.influx.target.database}")
+ private String database;
+
+ @Value("${spring.influx.target.url}")
+ private String url;
+
+ @Value("${spring.influx.target.user}")
+ private String user;
+
+ @Value("${spring.influx.target.password}")
+ private String password;
+
+ /**
+ * 思路：
+ * 1、指定数据源的。
+ * 数据来源： 指定数据源的情况下，每个表查出联合索引的1000条模板数据，比如phasicType+valueType+qualityFlag
+ * 后续所有相同的联合索引从模版中随机获取数据赋值
+ * 数据录入： 从目标mysql库中查询出所有的需要做处理的监测点id，做业务循环处理
+ *
+ * 2、未指定数据源。
+ * todo... 区别是底层模板数据是提前准备好的
+ *
+ * @param jobQueryParam 查询参数
+ */
+ @Override
+ public IPage