diff --git a/web/src/main/java/com/ibeetl/jlw/enums/SubsystemName.java b/web/src/main/java/com/ibeetl/jlw/enums/SubsystemName.java index ecb0549c..932810f2 100644 --- a/web/src/main/java/com/ibeetl/jlw/enums/SubsystemName.java +++ b/web/src/main/java/com/ibeetl/jlw/enums/SubsystemName.java @@ -34,9 +34,13 @@ public enum SubsystemName { SECURITIES_TRADING("证券交易"), CSRC("证监会、银保监会、行业协会"), RISK_MANAGEMENT("风险管理"), - BIG_DATA_STORAGE("大数据储存"), DIGITAL_MARKETING("数字营销"), - CREDIT_RATING_AGENCIES("征信评级机构"); + CREDIT_RATING_AGENCIES("征信评级机构"), + FINANCIAL_BIGDATA("金融大数据"), //598 + BIGDATA_BASICS("大数据基础"), //Python基础 698 + MACHINE_LEARNING("机器学习"), //798 + INTELLIGEN_RISK_CONTROL("智能风控"),//金融风险管理 898 + IPO("私募"); diff --git a/web/src/main/java/com/ibeetl/jlw/util/HttpUtil.java b/web/src/main/java/com/ibeetl/jlw/util/HttpUtil.java index 240f96b6..dbac97fe 100644 --- a/web/src/main/java/com/ibeetl/jlw/util/HttpUtil.java +++ b/web/src/main/java/com/ibeetl/jlw/util/HttpUtil.java @@ -146,4 +146,5 @@ public class HttpUtil { } return null; } + } diff --git a/web/src/main/java/com/ibeetl/jlw/util/SubsystemUserUtil.java b/web/src/main/java/com/ibeetl/jlw/util/SubsystemUserUtil.java index 46e502c2..59ddef0f 100644 --- a/web/src/main/java/com/ibeetl/jlw/util/SubsystemUserUtil.java +++ b/web/src/main/java/com/ibeetl/jlw/util/SubsystemUserUtil.java @@ -11,9 +11,8 @@ import com.ibeetl.jlw.web.query.SchoolClassQuery; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; -import java.util.ArrayList; -import java.util.List; -import java.util.Map; +import java.io.IOException; +import java.util.*; public class SubsystemUserUtil { @@ -25,15 +24,26 @@ public class SubsystemUserUtil { private static final String MNJY_USER_INSERT_API_URL="http://120.79.161.177:8091/account/saveNewUsersFromZhiyunPlatform"; private static final String SZJJ_USER_INSERT_API_URL="http://112.74.160.81:9909/api/user/synchronizationStudentInfoByAuto"; private static final String QKL_USER_INSERT_API_URL="http://120.79.54.255:8800/account/checkOrCreateForexSimulationUser"; - private static final String JRDSJ_USER_INSERT_API_URL="http://120.78.220.29:8838/tea/user/checkOrCreateForexSimulationUser"; + private static final String IPO_USER_INSERT_API_URL="http://120.78.220.29:8818/api/user/checkOrCreateForexSimulationUser"; private static final String SZZX_USER_INSERT_API_URL="https://120.79.54.255:7899/api/user/synchronizationStudentInfoByCredit"; private static final String SZYX_USER_INSERT_API_URL="https://120.79.54.255:9868/api/user/synchronizationStudentInfoByAuto"; + private static final String JRDSJ_USER_INSERT_API_URL="http://120.78.220.29:9988/tea/user/checkOrCreateForexSimulationUser"; - public static void subsystemUserCreate(List zyUserInfos, List applications) throws JsonProcessingException { + + public static void subsystemUserCreate(List zyUserInfoss, List applications) throws JsonProcessingException { + Set set=new HashSet<>(); + List zyUserInfos=new ArrayList<>(); + for (int i = 0; i < zyUserInfoss.size(); i++) { + if(set.contains(zyUserInfoss.get(i).getUserId())){ + continue; + } + set.add(zyUserInfoss.get(i).getUserId()); + zyUserInfos.add(zyUserInfoss.get(i)); + } if (zyUserInfos != null && zyUserInfos.size() > 0) { ObjectMapper objectMapper = new ObjectMapper(); String json = objectMapper.writeValueAsString(zyUserInfos); @@ -53,14 +63,50 @@ public class SubsystemUserUtil { //MNJY系统新增用户信息 HttpUtil.sendPostRequest(QKL_USER_INSERT_API_URL, json, "application/json"); } - if (applications.contains(SubsystemName.BIG_DATA_STORAGE.getText())) { - //MNJY系统新增用户信息 - HttpUtil.sendPostRequest(JRDSJ_USER_INSERT_API_URL, json, "application/json"); + if (applications.contains(SubsystemName.FINANCIAL_BIGDATA.getText())) { + //金融大数据系统新增用户信息 + String systemOwner="?systemOwner=金融大数据"; + try { + HttpUtil.sendPost(JRDSJ_USER_INSERT_API_URL+systemOwner, json, "application/json", null); + } catch (IOException e) { + e.printStackTrace(); + } + } + if(applications.contains(SubsystemName.BIGDATA_BASICS.getText())){ + //大数据基础系统新增用户信息 + String systemOwner="?systemOwner=Python基础实训教学系统"; + try { + HttpUtil.sendPost(JRDSJ_USER_INSERT_API_URL+systemOwner, json, "application/json", null); + } catch (IOException e) { + e.printStackTrace(); + } + } + if(applications.contains(SubsystemName.MACHINE_LEARNING.getText())){ + //机器学习新增用户信息 + String systemOwner="?systemOwner=机器学习"; + try { + HttpUtil.sendPost(JRDSJ_USER_INSERT_API_URL+systemOwner, json, "application/json", null); + } catch (IOException e) { + e.printStackTrace(); + } + } + if(applications.contains(SubsystemName.INTELLIGEN_RISK_CONTROL.getText())){ + //智能风控新增用户信息 + String systemOwner="?systemOwner=金融风险管理实训系统"; + try { + HttpUtil.sendPost(JRDSJ_USER_INSERT_API_URL+systemOwner, json, "application/json", null); + } catch (IOException e) { + e.printStackTrace(); + } } if (applications.contains(SubsystemName.CREDIT_RATING_AGENCIES.getText())) { //MNJY系统新增用户信息 HttpUtil.sendPostRequest(SZZX_USER_INSERT_API_URL, json, "application/json"); } + if (applications.contains(SubsystemName.IPO.getText())) { + //皖西虚拟仿真 + HttpUtil.sendPostRequest(IPO_USER_INSERT_API_URL, json, "application/json"); + } //数字营销 if (applications.contains(SubsystemName.DIGITAL_MARKETING.getText())) { //MNJY系统新增用户信息