diff --git a/op-modules/op-sap/src/main/java/com/op/sap/service/impl/SapServiceImpl.java b/op-modules/op-sap/src/main/java/com/op/sap/service/impl/SapServiceImpl.java index 6691157c..dc456481 100644 --- a/op-modules/op-sap/src/main/java/com/op/sap/service/impl/SapServiceImpl.java +++ b/op-modules/op-sap/src/main/java/com/op/sap/service/impl/SapServiceImpl.java @@ -18,10 +18,7 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import java.math.BigDecimal; -import java.util.ArrayList; -import java.util.Comparator; -import java.util.List; -import java.util.TreeSet; +import java.util.*; import java.util.stream.Collectors; @Service @@ -575,19 +572,25 @@ public class SapServiceImpl implements SapService { // 获取 内表 - ZMES_PRO JCoTable maraTable = func.getTableParameterList().getTable("LT_ROUTING"); JCoRecordMetaData metaData = maraTable.getRecordMetaData(); - System.out.println("###" + metaData.toString()); +// System.out.println("###" + metaData.toString()); // System.out.println("###" + metaData.toString()); + Map mapProRoute = new IdentityHashMap(); + Map mapProProcess = new IdentityHashMap(); + Map mapProRouteProcessNew = new IdentityHashMap(); + Map mapProRouteProcessOld = new IdentityHashMap(); List proProcessList = new ArrayList<>(); List proRouteProcessList = new ArrayList<>(); List proProcessContentList = new ArrayList<>(); List proRouteList = new ArrayList(); + Set set = new HashSet<>(); for (int i = 0,arr1=0,arr2=0; i list = Arrays.asList(set.toArray(new String[0])); +// Integer nums = sapSysUserMapper.getNums(); + for (int i=0;i{ + if (key.equals(s)){ + DynamicDataSourceContextHolder.push("ds_"+s); + if (value.getRouteName()!="无"){ + { +// System.out.println(s); +// System.out.println(sapProRouteMapper.selectProRouteByRouteCode(value.getRouteCode())); + if (sapProRouteMapper.selectProRouteByRouteCode(value.getRouteCode())==0){ + value.setRouteId(UUID.randomUUID().toString().replaceAll("-","")); + sapProRouteMapper.insertProRoute(value); +// arr1 = 1; + } + else{ +// System.out.println(value); + sapProRouteMapper.updateProRoute(value); +// arr1=0; + + } + }} + } + }); + mapProProcess.forEach((key, value) ->{ + if (key.equals(s)){ + DynamicDataSourceContextHolder.push("ds_"+s); + if (value.getProcessCode()!=null&&value.getProcessCode()!=""){ + if (sapProProcessMapper.selectProProcessByProcessName(value.getProcessName())==0){ + value.setProcessId(UUID.randomUUID().toString().replaceAll("-","")); +// System.out.println(value.getProcessCode()+"================================================"); + sapProProcessMapper.insertProProcess(value); + } + else{ +// System.out.println(value); + sapProProcessMapper.updateProProcess(value); + } + } + } + }); + mapProRouteProcessNew.forEach((key, value) ->{ + if (key.equals(s)){ + DynamicDataSourceContextHolder.push("ds_"+s); + if ((sapProRouteProcessMapper.selectProRouteProcessByProcessCode(value.getProcessCode()))==0){ +// System.out.println(value); + sapProRouteProcessMapper.insertProRouteProcess(value); + } + } + }); + mapProRouteProcessOld.forEach((key, value) ->{ + if (key.equals(s)){ + DynamicDataSourceContextHolder.push("ds_"+s); + if ((sapProRouteProcessMapper.selectProRouteProcessByProcessCode(value.getProcessCode()))!=0){ +// System.out.println(value); + sapProRouteProcessMapper.updateProRouteProcess(value); + }} + }); + } + + } catch (Exception e){ return R.fail(e.getMessage()); }