Source/BladeX/blade-service/blade-code/src/main/java/org/springblade/code/service/impl/CodeDuckingSyncServiceImpl.java

@@ -4,25 +4,6 @@
import com.alibaba.fastjson.JSONObject;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.DomDriver;
import com.vci.mdm.constant.MdmDuckingConstant;
import com.vci.mdm.dao.*;
import com.vci.mdm.dto.datapush.classify.JsonRootDataDTO;
import com.vci.mdm.dto.datapush.classify.NodeClassifyDTO;
import com.vci.mdm.dto.datapush.classify.NodeDataDTO;
import com.vci.mdm.dto.datapush.classify.NodeLibraryDTO;
import com.vci.mdm.dto.datapush.data.NodeJosnDTO;
import com.vci.mdm.dto.datapush.data.NodeObjectDTO;
import com.vci.mdm.dto.datapush.data.NodeProDTO;
import com.vci.mdm.dto.datapush.data.NodedataDTO;
import com.vci.mdm.dto.datapush.result.ResultJsonDTO;
import com.vci.mdm.dto.datapush.result.ResultNodeDataDTO;
import com.vci.mdm.dto.datapush.result.ResultNodeObjectDTO;
import com.vci.mdm.model.*;
import com.vci.mdm.pagemodel.CodeClassifyTemplateAttrVO;
import com.vci.mdm.pagemodel.CodeClassifyTemplateVO;
import com.vci.mdm.pagemodel.SysIntInfoVO;
import com.vci.mdm.service.*;
import com.vci.mdm.utils.*;
import com.vci.starter.web.constant.QueryOptionConstant;
import com.vci.starter.web.enumpck.UserSecretEnum;
import com.vci.starter.web.pagemodel.BaseResult;
@@ -37,6 +18,31 @@
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.code.constant.MdmDuckingConstant;
import org.springblade.code.dao.CodeClassifyDaoI;
import org.springblade.code.dao.DockingDataDaoI;
import org.springblade.code.dao.DockingLogeDaoI;
import org.springblade.code.dao.DockingTaskDaoI;
import org.springblade.code.dto.datapush.classify.JsonRootDataDTO;
import org.springblade.code.dto.datapush.classify.NodeClassifyDTO;
import org.springblade.code.dto.datapush.classify.NodeDataDTO;
import org.springblade.code.dto.datapush.classify.NodeLibraryDTO;
import org.springblade.code.dto.datapush.data.NodeJosnDTO;
import org.springblade.code.dto.datapush.data.NodeObjectDTO;
import org.springblade.code.dto.datapush.data.NodeProDTO;
import org.springblade.code.dto.datapush.data.NodedataDTO;
import org.springblade.code.dto.datapush.result.ResultJsonDTO;
import org.springblade.code.dto.datapush.result.ResultNodeDataDTO;
import org.springblade.code.dto.datapush.result.ResultNodeObjectDTO;
import org.springblade.code.model.*;
import org.springblade.code.service.CodeDuckingSyncServiceI;
import org.springblade.code.service.MdmEngineServiceI;
import org.springblade.code.service.SysIntInfoServiceI;
import org.springblade.code.utils.HttpUtils;
import org.springblade.code.utils.WsErpClientUtil;
import org.springblade.code.vo.pagemodel.CodeClassifyTemplateAttrVO;
import org.springblade.code.vo.pagemodel.CodeClassifyTemplateVO;
import org.springblade.code.vo.pagemodel.SysIntInfoVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
@@ -49,7 +55,7 @@
import java.util.*;
import java.util.stream.Collectors;

import static com.vci.mdm.constant.MdmDuckingConstant.*;
import static org.springblade.code.constant.MdmDuckingConstant.*;


/**
@@ -294,7 +300,7 @@
        initSysadmin();
        //查询哪些任务还没有执行完成
        VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(DockingTaskDO.class);
        queryWrapper.addQueryMap("sendFlag",MdmDuckingConstant.SEND_FLAG_FALSE);
        queryWrapper.addQueryMap("sendFlag", MdmDuckingConstant.SEND_FLAG_FALSE);
        queryWrapper.addQueryMap("btmId", QueryOptionConstant.NOTIN + "(" + VciBaseUtil.toInSql(DOCKING_DEFAULT_CLASSIFY.toUpperCase(Locale.ROOT)) + ")");
        List<DockingTaskDO> dockingTaskDOS = dockingTaskDaoI.selectByWrapper(queryWrapper);
        sendpushDataForService(dockingTaskDOS);