package com.fzzy.igds.dzhwk.v1.impl; import com.alibaba.fastjson.JSONObject; import com.fzzy.igds.dzhwk.domain.Dept; import com.fzzy.igds.dzhwk.v1.ApiV1Service; import com.fzzy.igds.dzhwk.v1.dto.ApiV1Data1002; import com.fzzy.igds.dzhwk.v1.dto.ApiV1ReqDto; import com.fzzy.igds.sys.repository.DeptRepository; 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/06/04 17:26 */ @Slf4j @Service public class ApiV1ServiceImpl1002 implements ApiV1Service { @Resource private DeptRepository deptRepository; @Override public String getInterfaceId() { return "1002"; } @Override public void analysis(String dataStr, ApiV1ReqDto configData){ List list = JSONObject.parseArray(dataStr, ApiV1Data1002.class); if(null == list || list.isEmpty()){ log.error("-----未获取到库区信息,不解析---------"); return; } try{ Dept dept; for (ApiV1Data1002 api2002 : list) { dept = deptRepository.getDataById(configData.getDeptId()); if(null == dept){ dept = new Dept(); } dept.setId(configData.getDeptId()); dept.setCompanyId(configData.getSign()); //赋值属性值 BeanUtils.copyProperties(api2002, dept); dept.setZhgxsj(DateUtils.parseDate(api2002.getZhgxsj(), "yyyy-MM-dd HH:mm:ss")); deptRepository.save(dept); } }catch (Exception e){ log.error("-----解析失败={}---------", e); } } }