package com.fzzy.igds.dzhwk.v1.impl; import com.alibaba.fastjson.JSONObject; import com.fzzy.igds.dzhwk.domain.ColdValley; import com.fzzy.igds.dzhwk.service.repository.ColdValleyRepository; import com.fzzy.igds.dzhwk.v1.ApiV1Service; import com.fzzy.igds.dzhwk.v1.dto.ApiV1Data2007; import com.fzzy.igds.dzhwk.v1.dto.ApiV1ReqDto; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.time.DateUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.List; /** * @Description 解析谷冷作业信息 * @Author CZT * @Date 2025/6/05 14:46 */ @Slf4j @Service public class ApiV1ServiceImpl2007 implements ApiV1Service { @Resource private ColdValleyRepository repository; @Override public String getInterfaceId() { return "2007"; } @Override public void analysis(String dataStr, ApiV1ReqDto configData) { List list = JSONObject.parseArray(dataStr, ApiV1Data2007.class); if(null == list || list.isEmpty()){ log.error("-----未获取到谷冷作业信息,不解析---------"); return; } try { ColdValley data; for (ApiV1Data2007 apiData : list) { data = new ColdValley(); BeanUtils.copyProperties(apiData, data); data.setCompanyId(configData.getSign()); data.setDeptId(configData.getDeptId()); data.setKssj(DateUtils.parseDate(apiData.getKssj(), "yyyy-MM-dd HH:mm:ss")); data.setJssj(DateUtils.parseDate(apiData.getJssj(), "yyyy-MM-dd HH:mm:ss")); data.setZhgxsj(DateUtils.parseDate(apiData.getZhgxsj(), "yyyy-MM-dd HH:mm:ss")); repository.save(data); } }catch (Exception e){ log.error("-----解析错误={}---------", e.toString()); } } }