From 2d2375543df4879e738e2bafe9f1f478c9b1ab44 Mon Sep 17 00:00:00 2001
From: xiejun <xj@2023>
Date: 星期二, 11 七月 2023 17:10:30 +0800
Subject: [PATCH] 集成接口管理模块相关接口开发

---
 Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java |  247 +++++++++++++++++++++++++++----------------------
 1 files changed, 135 insertions(+), 112 deletions(-)

diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java
index c17b3a8..91d1f4f 100644
--- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java
+++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeDuckingSyncServiceImpl.java
@@ -1,10 +1,16 @@
 package com.vci.ubcs.code.service.impl;
 
 
+import com.alibaba.cloud.commons.lang.StringUtils;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.vci.ubcs.code.entity.DockingSystem;
-import com.vci.ubcs.code.service.ICodeDuckingSyncService;
-import com.vci.ubcs.code.service.IDockingSystemService;
+import com.vci.ubcs.code.entity.*;
+import com.vci.ubcs.code.service.*;
+import com.vci.ubcs.starter.web.constant.QueryOptionConstant;
+import com.vci.ubcs.starter.web.util.VciBaseUtil;
+import com.vci.ubcs.starter.web.util.VciQueryWrapperForDO;
+import com.vci.ubcs.starter.web.util.WebUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.api.R;
 import org.springframework.stereotype.Service;
@@ -13,6 +19,8 @@
 import javax.annotation.Resource;
 import java.util.*;
 import java.util.stream.Collectors;
+
+import static com.vci.ubcs.code.constant.MdmDuckingConstant.*;
 
 
 /*
@@ -28,7 +36,14 @@
 	@Resource
 	private  IDockingSystemService dockingSystemService;
 
-
+	@Resource
+	private IDockingDataService dockingDataService;
+	@Resource
+	private IDockingTaskService dockingTaskService;
+	@Resource
+	private IDockingSystemConfigService dockingSystemConfigService;
+	@Resource
+	private ICodeClassifyService codeClassifyService;
 	@Override
 	public void DockingDataSyncScheduing() {
 
@@ -45,6 +60,9 @@
 
 	@Override
 	public R sendData(String oids) {
+
+
+
 		return null;
 	}
 
@@ -54,115 +72,120 @@
 	 * @param type
 	 */
 	private void initPushDataTaks(int type){
-//		//initSysadmin();
-//		//sysintinfo鏌ヨ瑕佹帹閫佺殑涓婚搴撳拰鐩稿叧绯荤粺淇℃伅
-//		Map<String, String> conditionMap = new HashMap<>();
-//		conditionMap.put("usedflag","true");
-//		conditionMap.put("pushType",type==2?"2":"1") ;//2鏄唬琛ㄥ垎绫绘帹閫侊紝1鏄唬琛ㄦ暟鎹帹閫�
-//
-//		Wrappers wrappers=new Wrappers();
-//
-//		List<DockingSystem> sysIntInfoVOList = dockingSystemService.list(Wrappers.query().lambda().eq());
-//		if(CollectionUtils.isEmpty(sysIntInfoVOList)){
-//			String title=type==2?"鍒嗙被鎺ㄩ��":"鏁版嵁鎺ㄩ��";
-//			log.info("info->鎵�鏈夐泦鎴愮郴缁燂紝鏈煡璇㈠埌鐩稿叧鐨勩��"+title+"銆戠殑鎺ュ彛閰嶇疆淇℃伅锛岄厤缃�");
-//			return;
-//		}
-//		Map<String ,List<DockingSystem>> sysIntInfoDOMap = new HashMap<String ,List<DockingSystem>>();//key=classifyoid,value=list<map>
-//		for (SysIntInfoDO sysIntInfoVOi:sysIntInfoVOList){
-//			List<SysIntInfoDO> SysIntInfoVOListi = sysIntInfoDOMap.get(sysIntInfoVOi.getClassifyoid());
-//			if(SysIntInfoVOListi==null){
-//				SysIntInfoVOListi = new ArrayList<SysIntInfoDO>();
-//			}
-//			SysIntInfoVOListi.add(sysIntInfoVOi);
-//			sysIntInfoDOMap.put(sysIntInfoVOi.getClassifyoid(),SysIntInfoVOListi);
-//		}
-//		//鏍规嵁绫诲瀷鍘绘煡璇㈤渶瑕侀泦鎴愮殑鍒嗙被鎴栬�呮暟鎹�
-//		VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(DockingDataDO.class);
-//		queryWrapperForDO.addQueryMap("sendflag","false");
-//		if(type==2){
-//			queryWrapperForDO.addQueryMap("btmTypeId",DOCKING_DEFAULT_CLASSIFY.toLowerCase(Locale.ROOT));
-//		}else {
-//			queryWrapperForDO.addQueryMap("btmTypeId", QueryOptionConstant.NOTIN + "(" + VciBaseUtil.toInSql(DOCKING_DEFAULT_CLASSIFY.toLowerCase(Locale.ROOT)) + ")");
-//		}
-//		List<DockingDataDO> dataList = dockingDataDaoI.selectByWrapper(queryWrapperForDO);
-//
-//		for (DockingDataDO mapi:dataList){
-//			WebUtil.setPersistence(false);
-//			BatchCBO batchCBO = new BatchCBO();
-//			String dataoid = mapi.getOid();//data瀵硅薄鐨刼id
-//			String classifyoid = mapi.getClassifyoid();
-//			String id = mapi.getId();
-//			String uniquecode = mapi.getUniquecode();
-//			String btmid = mapi.getBtmid();
-//			String btmoid = mapi.getBtmoid();
-//			String sendtype = mapi.getSendtype();
-//			String classifyid = mapi.getClassifyid();
-//			String classifyname = mapi.getClassifyname();
-//			String curentClassOid=null;
-//			if(type==2){
-//				curentClassOid=btmoid;
-//			}else{
-//				curentClassOid=classifyoid;
-//			}
-//			List<SysIntInfoDO> effectiveSysIntInfoVOs=new ArrayList<>();
-//			//鏍规嵁褰撳墠鏁版嵁鐨刬d锛屾煡璇㈣幏鍙栧摢浜涚郴缁熼渶瑕佸仛闆嗘垚
-//			List<CodeClassifyDO> parentLeveDO= codeClassifyDaoI.selectAllLevelParentByOid(curentClassOid);
-//			if(CollectionUtils.isEmpty(parentLeveDO)){
-//				continue;//璇存槑杩欎釜鍒嗙被琚垹鎺変簡锛屼笉鍋氬鐞�
-//			}
-//			Map<String, CodeClassifyDO> oidCodeclassifyDOMap = parentLeveDO.stream().filter(codeClassifyDO -> codeClassifyDO != null && StringUtils.isNotBlank(codeClassifyDO.getOid())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getOid(), t -> t));
-//
-//			oidCodeclassifyDOMap.keySet().forEach(oid->{
-//				if(sysIntInfoDOMap.containsKey(oid)){
-//					List<SysIntInfoDO> sysIntInfoDOS= sysIntInfoDOMap.get(oid);
-//					effectiveSysIntInfoVOs.addAll(sysIntInfoDOS);
-//				}
-//			});
-//			//濡傛灉鏍¢獙鐨勭郴缁熸帴鍙d俊鎭笉瀛樺湪锛屽垯鏁版嵁涓嶄笉寰�淇℃伅閲屾帹閫�
-//			if(CollectionUtils.isEmpty(effectiveSysIntInfoVOs)){
-//				continue;
-//			}
-//			List<DockingTaskDO> dockingTaskDO_insert = new ArrayList<DockingTaskDO>();
-//			for (SysIntInfoDO sysIntInfoVOi:effectiveSysIntInfoVOs){
-//				DockingTaskDO dockingTaskDO = new DockingTaskDO();
-//				dockingTaskDO.setOid(redisService.getUUIDEveryDay());
-//				dockingTaskDO.setSendflag(SEND_FLAG_FALSE);
-//				dockingTaskDO.setId(id);//缂栫爜
-//				dockingTaskDO.setUniquecode(uniquecode);
-//				dockingTaskDO.setBtmoid(btmoid);//鏁版嵁oid
-//				dockingTaskDO.setBtmid(btmid);//鏁版嵁涓氬姟绫诲瀷id
-//				dockingTaskDO.setClassifyid(classifyid);//鏁版嵁鍦ㄥ垎绫籭d
-//				dockingTaskDO.setClassifyoid(classifyoid);//鏁版嵁鎵�鍦ㄥ垎绫籵id
-//				dockingTaskDO.setClassifyname(classifyname);//鏁版嵁鎵�鍦ㄥ垎绫诲悕绉�
-//				dockingTaskDO.setSendtype(sendtype);//鏁版嵁鎺ㄩ�佺被鍨�
-//				dockingTaskDO.setDataoid(dataoid);
-//
-//				//intinfo
-//				dockingTaskDO.setSysinfooid(sysIntInfoVOi.getOid());//intinfo鐨刼id
-//				dockingTaskDO.setSystemoid(sysIntInfoVOi.getSysbaseoid());//绯荤粺oid
-//				dockingTaskDO.setSystemcode(sysIntInfoVOi.getSysbaseid());//绯荤粺缂栫爜
-//				dockingTaskDO.setSystemname(sysIntInfoVOi.getSysbasename());//绯荤粺name
-//				dockingTaskDO_insert.add(dockingTaskDO);
-//			}
-//
-//			BatchCBO bi = null;
-//			if(dockingTaskDO_insert.size()!=0) {
-//				bi = dockingTaskDaoI.batchInsert(dockingTaskDO_insert);
-//				batchCBO.copyFromOther(bi);
-//			}
-//			WebUtil.setPersistence(true);
-//			boService.persistenceBatch(batchCBO);
-//			//dockingTaskDaoI.updateByPrimaryKey鏂规硶鎶ラ敊浜嗭紝鎵�浠ユ墜鍐欎簡杩欎釜
-//			boolean u = updateDockingDatasSendFlag(dataoid,SEND_FLAG_TRUE);
-//			if(!u){
-//				log.error("闆嗘垚data鍒嗚В浠诲姟澶辫触锛乨ataoid:"+dataoid);
-//				continue;
-//			}
-//
-//		}
+		//initSysadmin();
+
+		List<DockingSystemConfig> dockingSystemConfigList = dockingSystemConfigService.list(
+			Wrappers.<DockingSystemConfig>query().lambda().eq(DockingSystemConfig::getUsedFlag,"true")
+				.eq(DockingSystemConfig::getPushType,type==2?"2":"1"));//2鏄唬琛ㄥ垎绫绘帹閫侊紝1鏄唬琛ㄦ暟鎹帹閫�
+
+		if(CollectionUtils.isEmpty(dockingSystemConfigList)){
+			String title=type==2?"鍒嗙被鎺ㄩ��":"鏁版嵁鎺ㄩ��";
+			log.info("info->鎵�鏈夐泦鎴愮郴缁燂紝鏈煡璇㈠埌鐩稿叧鐨勩��"+title+"銆戠殑鎺ュ彛閰嶇疆淇℃伅锛岄厤缃�");
+			return;
+		}
+		Map<String ,List<DockingSystemConfig>> sysIntInfoDOMap = new HashMap<>();//key=classifyoid,value=list<map>
+		for (DockingSystemConfig dockingSystemConfig:dockingSystemConfigList){
+			List<DockingSystemConfig> dockingSystemList = sysIntInfoDOMap.get(dockingSystemConfig.getClassifyOid());
+			if(dockingSystemList==null){
+				dockingSystemList = new ArrayList<>();
+			}
+			dockingSystemList.add(dockingSystemConfig);
+			sysIntInfoDOMap.put(dockingSystemConfig.getClassifyOid(),dockingSystemList);
+		}
+		//鏍规嵁绫诲瀷鍘绘煡璇㈤渶瑕侀泦鎴愮殑鍒嗙被鎴栬�呮暟鎹�
+		LambdaQueryWrapper<DockingData> queryWrapper = Wrappers.<DockingData>lambdaQuery();
+		queryWrapper.eq(DockingData::getSendFlag,"false");
+		if(type==2){
+			queryWrapper.eq(DockingData::getBtmId,DOCKING_DEFAULT_CLASSIFY.toLowerCase(Locale.ROOT));
+		}else {
+			queryWrapper.notIn(DockingData::getBtmId,DOCKING_DEFAULT_CLASSIFY.toLowerCase(Locale.ROOT));
+		}
+		List<DockingData> dataList = dockingDataService.list(queryWrapper);
+
+		for (DockingData mapi:dataList){
+			WebUtil.setPersistence(false);
+			String dataoid = mapi.getOid();//data瀵硅薄鐨刼id
+			String classifyoid = mapi.getClassifyOid();
+			String id = mapi.getId();
+			String uniquecode = mapi.getUniqueCode();
+			String btmid = mapi.getBtmId();
+			String btmoid = mapi.getBtmOid();
+			String sendtype = mapi.getSendType();
+			String classifyid = mapi.getClassifyId();
+			String classifyname = mapi.getClassifyName();
+			String curentClassOid=null;
+			if(type==2){
+				curentClassOid=btmoid;
+			}else{
+				curentClassOid=classifyoid;
+			}
+			List<DockingSystemConfig> effectiveSysIntInfoVOs=new ArrayList<>();
+			//鏍规嵁褰撳墠鏁版嵁鐨刬d锛屾煡璇㈣幏鍙栧摢浜涚郴缁熼渶瑕佸仛闆嗘垚
+			List<CodeClassify> parentLeveDO= codeClassifyService.selectAllLevelParentByOid(curentClassOid);
+			if(CollectionUtils.isEmpty(parentLeveDO)){
+				continue;//璇存槑杩欎釜鍒嗙被琚垹鎺変簡锛屼笉鍋氬鐞�
+			}
+			Map<String, CodeClassify> oidCodeclassifyDOMap = parentLeveDO.stream().filter(codeClassifyDO -> codeClassifyDO != null && StringUtils.isNotBlank(codeClassifyDO.getOid())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getOid(), t -> t));
+
+			oidCodeclassifyDOMap.keySet().forEach(oid->{
+				if(sysIntInfoDOMap.containsKey(oid)){
+					List<DockingSystemConfig> sysIntInfoDOS= sysIntInfoDOMap.get(oid);
+					effectiveSysIntInfoVOs.addAll(sysIntInfoDOS);
+				}
+			});
+			//濡傛灉鏍¢獙鐨勭郴缁熸帴鍙d俊鎭笉瀛樺湪锛屽垯鏁版嵁涓嶄笉寰�淇℃伅閲屾帹閫�
+			if(CollectionUtils.isEmpty(effectiveSysIntInfoVOs)){
+				continue;
+			}
+			List<DockingTask> dockingTask_insert = new ArrayList<>();
+			for (DockingSystemConfig sysIntInfoVOi:effectiveSysIntInfoVOs){
+				DockingTask dockingTask = new DockingTask();
+				dockingTask.setOid(VciBaseUtil.getPk());
+				dockingTask.setSendFlag(SEND_FLAG_FALSE);
+				dockingTask.setId(id);//缂栫爜
+				dockingTask.setUniqueCode(uniquecode);
+				dockingTask.setBtmOid(btmoid);//鏁版嵁oid
+				dockingTask.setBtmId(btmid);//鏁版嵁涓氬姟绫诲瀷id
+				dockingTask.setClassifyId(classifyid);//鏁版嵁鍦ㄥ垎绫籭d
+				dockingTask.setClassifyOid(classifyoid);//鏁版嵁鎵�鍦ㄥ垎绫籵id
+				dockingTask.setClassifyName(classifyname);//鏁版嵁鎵�鍦ㄥ垎绫诲悕绉�
+				dockingTask.setSendType(sendtype);//鏁版嵁鎺ㄩ�佺被鍨�
+				dockingTask.setDataOid(dataoid);
+
+				//intinfo
+				dockingTask.setSysInfoOid(sysIntInfoVOi.getOid());//intinfo鐨刼id
+				dockingTask.setSystemOid(sysIntInfoVOi.getSysBaseOid());//绯荤粺oid
+				dockingTask.setSystemCode(sysIntInfoVOi.getSysBaseId());//绯荤粺缂栫爜
+				dockingTask.setSystemName(sysIntInfoVOi.getSysBaseName());//绯荤粺name
+				dockingTask_insert.add(dockingTask);
+			}
+
+			if(dockingTask_insert.size()!=0) {
+				dockingTaskService.saveBatch(dockingTask_insert);
+			}
+			//dockingTaskDaoI.updateByPrimaryKey鏂规硶鎶ラ敊浜嗭紝鎵�浠ユ墜鍐欎簡杩欎釜
+			boolean u = updateDockingDatasSendFlag(dataoid,SEND_FLAG_TRUE);
+			if(!u){
+				log.error("闆嗘垚data鍒嗚В浠诲姟澶辫触锛乨ataoid:"+dataoid);
+				continue;
+			}
+		}
 	}
 
-
+	/**
+	 * dockingdata鏍规嵁oid淇敼sendflag
+	 * @param oid
+	 * @param sendflag
+	 * @return
+	 */
+	public boolean updateDockingDatasSendFlag(String oid,String sendflag){
+		boolean u=false;
+		DockingData dockingData=dockingDataService.getById(oid);
+		if(dockingData!=null){
+			dockingData.setSendFlag(sendflag);
+			u=	dockingDataService.updateById(dockingData);
+		}
+		return u;
+	}
 }
 

--
Gitblit v1.9.3