Merge remote-tracking branch 'origin/main' into main
This commit is contained in:
commit
b99c9dc761
|
@ -2,29 +2,23 @@ package shkd.sys.sys.eoss;
|
||||||
|
|
||||||
import kd.bos.cache.CacheFactory;
|
import kd.bos.cache.CacheFactory;
|
||||||
import kd.bos.cache.DistributeSessionlessCache;
|
import kd.bos.cache.DistributeSessionlessCache;
|
||||||
import kd.bos.exception.ErrorCode;
|
|
||||||
import kd.bos.exception.KDBizException;
|
|
||||||
import kd.bos.exception.KDException;
|
|
||||||
import kd.bos.logging.Log;
|
import kd.bos.logging.Log;
|
||||||
import kd.bos.logging.LogFactory;
|
import kd.bos.logging.LogFactory;
|
||||||
import kd.bos.login.thirdauth.ThirdSSOAuthHandler;
|
import kd.bos.login.thirdauth.ThirdSSOAuthHandler;
|
||||||
import kd.bos.login.thirdauth.UserAuthResult;
|
import kd.bos.login.thirdauth.UserAuthResult;
|
||||||
import kd.bos.login.thirdauth.UserProperType;
|
import kd.bos.login.thirdauth.UserProperType;
|
||||||
import kd.bos.servicehelper.user.UserServiceHelper;
|
import kd.bos.servicehelper.user.UserServiceHelper;
|
||||||
|
import kd.bos.util.RevProxyUtil;
|
||||||
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.StringUtils;
|
||||||
import shkd.sys.sys.utils.AesUtils;
|
|
||||||
|
|
||||||
import javax.servlet.http.*;
|
import javax.servlet.http.*;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.UnsupportedEncodingException;
|
|
||||||
import java.nio.charset.StandardCharsets;
|
import java.nio.charset.StandardCharsets;
|
||||||
import java.security.PrivateKey;
|
|
||||||
import java.util.Base64;
|
import java.util.Base64;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author: Lang
|
*
|
||||||
* @description: 单点登录-川投统一认证
|
|
||||||
**/
|
**/
|
||||||
public class SSOPluginLogin implements ThirdSSOAuthHandler {
|
public class SSOPluginLogin implements ThirdSSOAuthHandler {
|
||||||
private final static Log logger = LogFactory.getLog(SSOPluginLogin.class);
|
private final static Log logger = LogFactory.getLog(SSOPluginLogin.class);
|
||||||
|
@ -34,7 +28,9 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler {
|
||||||
|
|
||||||
private final String CLIENT_ID2 = System.getProperty("scnyfz-clientKey");
|
private final String CLIENT_ID2 = System.getProperty("scnyfz-clientKey");
|
||||||
private final String CLIENT_SECRET2 = System.getProperty("scnyfz-scict");
|
private final String CLIENT_SECRET2 = System.getProperty("scnyfz-scict");
|
||||||
private final String EOSS_IP2 = System.getProperty("scnyfz-ip");
|
private final String EOSS_IP2 = System.getProperty("scnyfz-ip2");
|
||||||
|
private final String skIP = System.getProperty("backlog-ip");
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 方法实现用户没有登录的时候跳转认证中心的登录地址
|
* 方法实现用户没有登录的时候跳转认证中心的登录地址
|
||||||
|
@ -47,7 +43,6 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler {
|
||||||
String secret;
|
String secret;
|
||||||
|
|
||||||
String queryUrl = httpServletRequest.getQueryString();
|
String queryUrl = httpServletRequest.getQueryString();
|
||||||
|
|
||||||
if (queryUrl.contains("isNew")) {
|
if (queryUrl.contains("isNew")) {
|
||||||
ip = EOSS_IP2;
|
ip = EOSS_IP2;
|
||||||
client = CLIENT_ID2;
|
client = CLIENT_ID2;
|
||||||
|
@ -57,32 +52,40 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler {
|
||||||
client = CLIENT_ID;
|
client = CLIENT_ID;
|
||||||
secret = CLIENT_SECRET;
|
secret = CLIENT_SECRET;
|
||||||
}
|
}
|
||||||
if(queryUrl.contains("code")){
|
String ssourl = ip + "/service/SGE-project-sctz-master/pc/dist/login.html";
|
||||||
// httpServletResponse.sendRedirect(ssourl);
|
//图标登录到首页
|
||||||
|
if (!queryUrl.contains("yzjShareOpen.do")) {
|
||||||
|
try {
|
||||||
}else{
|
//重定向的统一认证的地址 获取授权码
|
||||||
|
ssourl = String.format("%s/sso2/authCenter/authorize?client_id=%s&response_type=code&sessionKeep=true&authType=0&redirect_uri=%s",
|
||||||
|
ip, client, s);
|
||||||
|
logger.info(String.format("重定向地址→sendRedirect:%s", ssourl));
|
||||||
|
httpServletResponse.sendRedirect(ssourl);
|
||||||
|
} catch (IOException e) {
|
||||||
|
throw new RuntimeException(e);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
queryUrl = Base64.getEncoder().encodeToString(queryUrl.getBytes(StandardCharsets.UTF_8));
|
queryUrl = Base64.getEncoder().encodeToString(queryUrl.getBytes(StandardCharsets.UTF_8));
|
||||||
// String skIp = httpServletRequest.getRemoteAddr();
|
// String skIp = httpServletRequest.getRemo
|
||||||
String skUrl = httpServletRequest.getRequestURL().toString();
|
String skUrl = RevProxyUtil.getURLContextPath(httpServletRequest);
|
||||||
skUrl = skUrl.substring(0, skUrl.indexOf("ierp"));
|
logger.info("getURLContextPath:" + skUrl);
|
||||||
String redirect = skUrl+"ierp/index.html?param="+queryUrl;
|
String redirect = skIP + "/index.html?param=" + queryUrl;
|
||||||
|
logger.info("skip:" + skUrl);
|
||||||
//认证中心的登录地址
|
//认证中心的登录地址
|
||||||
logger.info(String.format("eoss_ip:%s,client_id:%s,client_secret:%s,重定向地址:%s", ip, client, secret, s));
|
logger.info(String.format("eoss_ip:%s,client_id:%s,client_secret:%s,重定向地址:%s", ip, client, secret, s));
|
||||||
String ssourl = ip + "/service/SGE-project-sctz-master/pc/dist/login.html";
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (httpServletRequest.getRequestURI().contains("/auth/logout.do")) {
|
if (httpServletRequest.getRequestURI().contains("/auth/logout.do")) {
|
||||||
String userName = UserServiceHelper.getCurrentUser("name").getString("name");
|
String userName = UserServiceHelper.getCurrentUser("name").getString("name");
|
||||||
DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache("customRegion");
|
DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache("customRegion");
|
||||||
String userKey = "user_sessionId_" + userName; // 构造一个唯一的键
|
String userKey = "user_sessionId_" + userName; // 构造存储sessionId的键
|
||||||
String sessionId = cache.get(userKey);
|
String sessionId = cache.get(userKey);
|
||||||
if (sessionId != null) {
|
if (sessionId != null) {
|
||||||
AuthService.logout(ip, sessionId);
|
AuthService.logout(ip, sessionId);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
//重定向的统一认证的地址 获取授权码
|
//重定向的统一认证的地址 获取授权码
|
||||||
ssourl = String.format("%s/sso2/authCenter/authorize?client_id=%s&response_type=code&sessionKeep=false&authType=0&redirect_uri=%s",
|
ssourl = String.format("%s/sso2/authCenter/authorize?client_id=%s&response_type=code&sessionKeep=true&authType=0&redirect_uri=%s",
|
||||||
ip, client, redirect);
|
ip, client, redirect);
|
||||||
logger.info(String.format("重定向地址→sendRedirect:%s", ssourl));
|
logger.info(String.format("重定向地址→sendRedirect:%s", ssourl));
|
||||||
}
|
}
|
||||||
|
@ -111,84 +114,53 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler {
|
||||||
client = CLIENT_ID;
|
client = CLIENT_ID;
|
||||||
secret = CLIENT_SECRET;
|
secret = CLIENT_SECRET;
|
||||||
}
|
}
|
||||||
|
|
||||||
//返回的认证结果
|
//返回的认证结果
|
||||||
UserAuthResult result = new UserAuthResult();
|
UserAuthResult result = new UserAuthResult();
|
||||||
//获取返回的授权码
|
//获取返回的授权码
|
||||||
String code = httpServletRequest.getParameter("code");
|
String code = httpServletRequest.getParameter("code");
|
||||||
|
logger.info(String.format("getTrdSSOAuth→授权码code:%s", code));
|
||||||
|
if (StringUtils.isEmpty(code)) {
|
||||||
|
logger.error("getTrdSSOAuth→授权码code为空");
|
||||||
|
result.setSucess(false);
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
//调用EOSS获取token接口
|
||||||
|
String access_token = AuthService.accessToken(code, ip, client, secret);
|
||||||
|
logger.info(String.format("accessToken返回数据:%s", access_token));
|
||||||
|
//调用EOSS获取用户信息接口
|
||||||
|
String user = AuthService.getUserInfo(access_token, ip, client, secret);
|
||||||
|
logger.info(String.format("getUserInfo返回数据:%s", user));
|
||||||
String param = httpServletRequest.getParameter("param");
|
String param = httpServletRequest.getParameter("param");
|
||||||
if(param!=null){
|
//解码
|
||||||
|
if (param != null) {
|
||||||
byte[] decodedBytes = Base64.getDecoder().decode(param);
|
byte[] decodedBytes = Base64.getDecoder().decode(param);
|
||||||
String paramString = new String(decodedBytes, StandardCharsets.UTF_8);
|
String paramString = new String(decodedBytes, StandardCharsets.UTF_8);
|
||||||
try {
|
try {
|
||||||
httpServletResponse.sendRedirect(httpServletRequest.getRequestURI()+"?"+paramString+"&code="+code);
|
//获取返回的 sessionId
|
||||||
|
String sessionId = httpServletRequest.getParameter("sessionId");
|
||||||
|
logger.info(String.format("getTrdSSOAuth→sessionId:%s", sessionId));
|
||||||
|
String userKey = "user_sessionId_" + user;
|
||||||
|
//存储sessionId用于退出系统
|
||||||
|
DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache("customRegion");
|
||||||
|
cache.put(userKey, sessionId);
|
||||||
|
//二次重定向到待办页面,并且不携带EOSS返回的sessionId
|
||||||
|
httpServletResponse.sendRedirect(httpServletRequest.getRequestURI() + "?" + paramString + "&code=" + code);
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
|
logger.error("二次重定向到待办页面异常!" + e.getMessage());
|
||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
}
|
}
|
||||||
result.setSucess(false);
|
result.setSucess(false);
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
//二次重定向进入
|
||||||
|
|
||||||
// //获取返回的 sessionId
|
|
||||||
// String sessionId = httpServletRequest.getParameter("sessionId");
|
|
||||||
// String userName = httpServletRequest.getParameter("userName");
|
|
||||||
// if (userName != null) {
|
|
||||||
// userName = userName.replace(" ", "+"); // 将空格替换为 + 号
|
|
||||||
// }
|
|
||||||
// logger.info("获取待办链接中参数userName:" + userName);
|
|
||||||
|
|
||||||
// RSAUtils.
|
|
||||||
logger.info(String.format("getTrdSSOAuth→授权码code:%s", code));
|
|
||||||
result.setUserType(UserProperType.UserName);
|
result.setUserType(UserProperType.UserName);
|
||||||
if (StringUtils.isEmpty(code)) {
|
if (StringUtils.isNotEmpty(code) && user != null) {
|
||||||
logger.error("getTrdSSOAuth→授权码code为空");
|
//当前返回类型手机,用户名,email,工号
|
||||||
result.setSucess(false);
|
result.setUserType(UserProperType.UserName);
|
||||||
return result;
|
result.setUser(user);
|
||||||
} else if (StringUtils.isNotEmpty(code)) {
|
result.setSucess(true);
|
||||||
try {
|
logger.info("SSO用户登录成功,进入苍穹系统");
|
||||||
//TODO:调用accessToken方法
|
|
||||||
String access_token = AuthService.accessToken(code, ip, client, secret);
|
|
||||||
logger.info(String.format("accessToken返回数据:%s", access_token));
|
|
||||||
|
|
||||||
//TODO:调用getUserInfo方法
|
|
||||||
String user = AuthService.getUserInfo(access_token, ip, client, secret);
|
|
||||||
logger.info(String.format("getUserInfo返回数据:%s", user));
|
|
||||||
|
|
||||||
if (user != null) {
|
|
||||||
//当前返回类型手机,用户名,email,工号
|
|
||||||
result.setUserType(UserProperType.UserName);
|
|
||||||
result.setUser(user);
|
|
||||||
result.setSucess(true);
|
|
||||||
logger.info("SSO用户登录成功,进入苍穹系统");
|
|
||||||
// String userKey = "user_sessionId_" + user; // 构造一个唯一的键
|
|
||||||
// DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache("customRegion");
|
|
||||||
// cache.put(userKey, sessionId);//将自定义参数加入缓存
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
throw new KDBizException("获取用户信息接口异常,SSO用户登录失败!" + e);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
// else if (StringUtils.isNotEmpty(userName)) {
|
|
||||||
//
|
|
||||||
//// Object o = SystemParamServiceHelper.loadPublicParameterFromCache("shkd_privatekeystring_tag");
|
|
||||||
//// logger.info("获取公共参数shkd_privatekeystring_tag:"+o);
|
|
||||||
// logger.info("加密后user:" + userName);
|
|
||||||
//// String privateKeyString = "MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQDVcEZaQoPn+qado8nw5ZvKlbxEh/xQ9AiBMRUFpY0XibkrCa1T2A7bTWztoAkTaBby1ynOOX4q1BSTGiDVOcXkCZgMteqAlvg3y9YZTlV/6MkbPLNPZTuWgNMa2C6bMkkHfJJqkDI8IZbe3IUxNk4Rz6JWsLDaI6PNhSKbRIq3MHj/emsmkQN+ePAz0Elh4b/bD2L63lmJJEtoK9Ira2b/gl+VwqOiaZb8iZ4PrvCKQJucAPkdQAb2Etcv0Clb/VnzdgzzcR+gU5Ak2hJns29IFMS4jOGhAJkdLQX+fW1KS0Am9gsvYznIbv8R0Bv/PDz+jHrd36a9sMr/ixzOy3QBAgMBAAECggEAXOVc+XPxzUm+suXSwtJsmCPLqVg2bVWJThF6wNZpLlF3ElBH7DIhZTmxq0r4KEYpltAnFebYDvP3cH7yw1s90h6K2x1iT01mA4LoUGNTuzQqM3yb3naFFOBFAW4N+uZL+sIxR8gy1REZhS4dmmm0WPQyB+EnWAojBRRpF4MhjND0ncSRJhWLTg3SiOSidedaVuI9AncwXlsH3hvJTM9xrL86tGIuFZe1JDCbg5zCU0Scz6LFnSc4UISajPEy0u7v8l74k2Tqr+XXOCAbG4gSr12BazQ7c7pT0hnwE1t/WKdeu033dbTfz+FkZ/ARFgfsjuGBrc2LA7A/FbOD28mTcQKBgQDrC41Z14Iz4N+hr4fvilCqou/GcF7T5CP//tKqj3RRgCYu3XF1btQ+iXMRc40NzdCdxmH+BMJ9lS51Soi0dzvHuQTn/A/3cviBfmzptqTMp0T2RpXQ0bSe4wqUT3fdenFm39xbw9p+b+eknZ8lrGM6fn06GBP6mQ+USMvZAnkdawKBgQDod5hasx8rMveJsNdqp/vGOFVtCh6RVX0rV8vlJ1tLGAhxBQbPbbmB/H773Fqyhc7NOWPFbSuHXtZtArgTY5wHwHcBZ41nB7E5Y40wMql8eNFhBFAb1M8xy7o+cX5gIsphrBRiGGM9MBhQNea2cH3flKW9NPKdvH3dF0sv/OGDQwKBgQClV60JpDZtdCUcwjPn5+6y+oedmnK6r+Q7MvDTFrMGmhVCJnin2Vzo2RvfDOAO89drBaDtZj/Cw+y4icP831toNdkjsAczVOdHgL3w8pCffpNeg2zkRoC+vIw2pGh3nqija5rB2taa1vGmtVK817W98jj5YvK6+G0jLMppT/oPHQKBgQC7S3Ai02Jvabbq5uIIeqNtxwF8wsRyD9CzVR9f11/Elu5mMMiV4y+tPQQKZDVm1EwUKQLrk9OYU56rYZ9xb7XMwRKgvQ++TQJK3JxqksbfFHCNm+33HnR5CE1b9hD938ny+7PIfSGnsNJF/ceOgf/IXXlTgg9favh1Y0ketr3zBQKBgFKWHvw/i1j4F/6vQIBn4ke22Ja8qXDNLfIUEcgqqvIx5N6Imv8DLyvu56CWveThVzk810VHRqoJ3aIgA8oTs/mQyd8G/S8jbyufl2GeoHap9azSr63HZh4v8ZBMQuA6xP2CEUByEyIWknwo7pp9yj8gJZUFmvTthY6SvkYrqg1H";
|
|
||||||
//// logger.info("私钥string:" + privateKeyString);
|
|
||||||
//// String cleanedBase64String = privateKeyString.replaceAll("[^A-Za-z0-9+/=]", "");
|
|
||||||
// try {
|
|
||||||
// String user = AesUtils.aesDecryptString(userName);
|
|
||||||
// logger.info("SSO用户名:" + user);
|
|
||||||
// result.setUser(user);
|
|
||||||
// result.setSucess(true);
|
|
||||||
// logger.info("SSO用户登录成功,进入苍穹系统");
|
|
||||||
// } catch (Exception e) {
|
|
||||||
// logger.info("私钥获取密钥异常,异常信息:{}", e);
|
|
||||||
// ErrorCode errorCode = new ErrorCode("error_code", "私钥解密出现异常,请联系运维人员排查!");
|
|
||||||
// throw new KDException(errorCode, e);
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -0,0 +1,306 @@
|
||||||
|
package shkd.sys.sys.plugin.tmc;
|
||||||
|
|
||||||
|
import kd.bos.dataentity.entity.DynamicObject;
|
||||||
|
import kd.bos.dataentity.entity.DynamicObjectCollection;
|
||||||
|
import kd.bos.dataentity.entity.LocaleString;
|
||||||
|
import kd.bos.dataentity.resource.ResManager;
|
||||||
|
import kd.bos.dataentity.serialization.SerializationUtils;
|
||||||
|
import kd.bos.dataentity.utils.StringUtils;
|
||||||
|
import kd.bos.entity.datamodel.ListSelectedRow;
|
||||||
|
import kd.bos.entity.datamodel.ListSelectedRowCollection;
|
||||||
|
import kd.bos.entity.datamodel.events.ChangeData;
|
||||||
|
import kd.bos.entity.datamodel.events.PropertyChangedArgs;
|
||||||
|
import kd.bos.entity.operate.result.OperationResult;
|
||||||
|
import kd.bos.filter.CommonFilterColumn;
|
||||||
|
import kd.bos.filter.FilterColumn;
|
||||||
|
import kd.bos.form.CloseCallBack;
|
||||||
|
import kd.bos.form.FormShowParameter;
|
||||||
|
import kd.bos.form.ShowType;
|
||||||
|
import kd.bos.form.control.Button;
|
||||||
|
import kd.bos.form.control.Control;
|
||||||
|
import kd.bos.form.control.events.BeforeClickEvent;
|
||||||
|
import kd.bos.form.events.*;
|
||||||
|
import kd.bos.form.field.BasedataEdit;
|
||||||
|
import kd.bos.form.field.ComboEdit;
|
||||||
|
import kd.bos.form.field.ComboItem;
|
||||||
|
import kd.bos.form.field.events.BeforeF7SelectEvent;
|
||||||
|
import kd.bos.form.field.events.BeforeF7SelectListener;
|
||||||
|
import kd.bos.form.operate.AbstractOperate;
|
||||||
|
import kd.bos.form.plugin.AbstractFormPlugin;
|
||||||
|
import kd.bos.list.BillList;
|
||||||
|
import kd.bos.list.ListShowParameter;
|
||||||
|
import kd.bos.orm.query.QFilter;
|
||||||
|
import kd.bos.servicehelper.QueryServiceHelper;
|
||||||
|
import kd.bos.servicehelper.operation.SaveServiceHelper;
|
||||||
|
import kd.tmc.bdim.common.enums.MidOrgType;
|
||||||
|
import kd.tmc.fbp.common.enums.BillStatusEnum;
|
||||||
|
import kd.tmc.fbp.common.helper.TmcDataServiceHelper;
|
||||||
|
import kd.tmc.fbp.common.util.EmptyUtil;
|
||||||
|
import kd.tmc.fbp.formplugin.list.AbstractTmcListPlugin;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import java.util.*;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 16358
|
||||||
|
* @date 2025/6/25
|
||||||
|
*/
|
||||||
|
public class InterMediarySelectListPlugin extends AbstractFormPlugin implements BeforeF7SelectListener {
|
||||||
|
public InterMediarySelectListPlugin() {
|
||||||
|
}
|
||||||
|
|
||||||
|
public void registerListener(EventObject e) {
|
||||||
|
super.registerListener(e);
|
||||||
|
BasedataEdit control = (BasedataEdit)this.getControl("e_midorgname");
|
||||||
|
if (control != null) {
|
||||||
|
control.addBeforeF7SelectListener(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
this.addClickListeners(new String[]{"btnok"});
|
||||||
|
}
|
||||||
|
|
||||||
|
public void beforeF7Select(BeforeF7SelectEvent beforeF7SelectEvent) {
|
||||||
|
String key = beforeF7SelectEvent.getProperty().getName();
|
||||||
|
int index = beforeF7SelectEvent.getRow();
|
||||||
|
DynamicObject dataEntity = this.getModel().getDataEntity(true);
|
||||||
|
switch (key) {
|
||||||
|
case "e_midorgname":
|
||||||
|
DynamicObjectCollection entities = dataEntity.getDynamicObjectCollection("entryentity");
|
||||||
|
DynamicObject entry = (DynamicObject)entities.get(index);
|
||||||
|
String eMidOrgTypeWin = entry.getString("e_midorgtypewin");
|
||||||
|
QFilter qFilter = new QFilter("orgtype", "=", eMidOrgTypeWin);
|
||||||
|
ListShowParameter showParameter = (ListShowParameter)beforeF7SelectEvent.getFormShowParameter();
|
||||||
|
showParameter.getListFilterParameter().getQFilters().add(qFilter);
|
||||||
|
default:
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public void beforeFieldPostBack(BeforeFieldPostBackEvent e) {
|
||||||
|
super.beforeFieldPostBack(e);
|
||||||
|
Control source = (Control)e.getSource();
|
||||||
|
String key = source.getKey();
|
||||||
|
int rowIndex = e.getRowIndex();
|
||||||
|
Object value = e.getValue();
|
||||||
|
if ("e_fee".equals(key) && value == null) {
|
||||||
|
this.getModel().setValue("e_fee", BigDecimal.ZERO, rowIndex);
|
||||||
|
this.getView().updateView(key, rowIndex);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public void beforeBindData(EventObject e) {
|
||||||
|
super.beforeBindData(e);
|
||||||
|
Object pkId = this.getView().getFormShowParameter().getCustomParam("pkid");
|
||||||
|
if (!EmptyUtil.isEmpty(pkId)) {
|
||||||
|
DynamicObject selectBill = TmcDataServiceHelper.loadSingle(pkId, "bdim_intermediaryselect");
|
||||||
|
DynamicObjectCollection winningBidderEntries = selectBill.getDynamicObjectCollection("winningbidderentry");
|
||||||
|
DynamicObjectCollection entryEntities = this.getModel().getEntryEntity("entryentity");
|
||||||
|
Object currencyId = this.getView().getFormShowParameter().getCustomParam("currencyid");
|
||||||
|
Long currency = null;
|
||||||
|
if (EmptyUtil.isNoEmpty(currencyId)) {
|
||||||
|
currency = Long.parseLong(currencyId.toString());
|
||||||
|
}
|
||||||
|
|
||||||
|
this.getModel().setValue("currency", currency);
|
||||||
|
if (winningBidderEntries.size() != 0) {
|
||||||
|
entryEntities.clear();
|
||||||
|
}
|
||||||
|
|
||||||
|
int i = 0;
|
||||||
|
Iterator var9 = winningBidderEntries.iterator();
|
||||||
|
|
||||||
|
while(var9.hasNext()) {
|
||||||
|
DynamicObject entry = (DynamicObject)var9.next();
|
||||||
|
DynamicObject entryEntity = entryEntities.addNew();
|
||||||
|
entryEntity.set("seq", i++);
|
||||||
|
entryEntity.set("e_midorgtypewin", entry.get("e_midorgtypewin"));
|
||||||
|
entryEntity.set("e_underwritertypewin", entry.get("e_underwritertypewin"));
|
||||||
|
entryEntity.set("e_midorgname", entry.get("e_midorgname"));
|
||||||
|
entryEntity.set("shkd_pglx1", entry.get("shkd_pglx1"));
|
||||||
|
entryEntity.set("e_openingdatewin", entry.get("e_openingdatewin"));
|
||||||
|
entryEntity.set("e_fee", entry.get("e_fee"));
|
||||||
|
entryEntity.set("e_feerate", entry.get("e_feerate"));
|
||||||
|
DynamicObjectCollection eBidWinningNoticeEntry = entry.getDynamicObjectCollection("e_bidwinningnotice");
|
||||||
|
DynamicObjectCollection noticeEntryEntity = entryEntity.getDynamicObjectCollection("e_bidwinningnotice");
|
||||||
|
noticeEntryEntity.clear();
|
||||||
|
Iterator var14 = eBidWinningNoticeEntry.iterator();
|
||||||
|
|
||||||
|
while(var14.hasNext()) {
|
||||||
|
DynamicObject bidWinningNoticeEntry = (DynamicObject)var14.next();
|
||||||
|
noticeEntryEntity.addNew().set("fbasedataid", bidWinningNoticeEntry.get("fbasedataid"));
|
||||||
|
}
|
||||||
|
|
||||||
|
DynamicObjectCollection eContractEntry = entry.getDynamicObjectCollection("e_contract");
|
||||||
|
DynamicObjectCollection eContractEntryEntity = entryEntity.getDynamicObjectCollection("e_contract");
|
||||||
|
eContractEntryEntity.clear();
|
||||||
|
Iterator var16 = eContractEntry.iterator();
|
||||||
|
|
||||||
|
while(var16.hasNext()) {
|
||||||
|
DynamicObject contractEntry = (DynamicObject)var16.next();
|
||||||
|
eContractEntryEntity.addNew().set("fbasedataid", contractEntry.get("fbasedataid"));
|
||||||
|
}
|
||||||
|
|
||||||
|
entryEntity.set("e_explainwin", entry.get("e_explainwin"));
|
||||||
|
}
|
||||||
|
|
||||||
|
this.getView().updateView("entryentity");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public void afterBindData(EventObject e) {
|
||||||
|
super.afterBindData(e);
|
||||||
|
DynamicObjectCollection entryEntity = this.getModel().getDataEntity().getDynamicObjectCollection("entryentity");
|
||||||
|
|
||||||
|
for(int i = 0; i < entryEntity.size(); ++i) {
|
||||||
|
DynamicObject entry = (DynamicObject)entryEntity.get(i);
|
||||||
|
String eMidOrgType = entry.getString("e_midorgtypewin");
|
||||||
|
this.midOrgTypeChange(eMidOrgType, i);
|
||||||
|
}
|
||||||
|
|
||||||
|
Object midOrgType = this.getView().getFormShowParameter().getCustomParam("midOrgType");
|
||||||
|
Set<String> midOrgTypeList = (Set) SerializationUtils.fromJsonString(midOrgType.toString(), Set.class);
|
||||||
|
ComboEdit midOrgTypeWin = (ComboEdit)this.getView().getControl("e_midorgtypewin");
|
||||||
|
List<ComboItem> comboItems = new ArrayList(5);
|
||||||
|
Iterator var7 = midOrgTypeList.iterator();
|
||||||
|
|
||||||
|
while(var7.hasNext()) {
|
||||||
|
String mot = (String)var7.next();
|
||||||
|
comboItems.add(new ComboItem(new LocaleString(MidOrgType.getName(mot)), mot));
|
||||||
|
}
|
||||||
|
|
||||||
|
midOrgTypeWin.setComboItems(comboItems);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void propertyChanged(PropertyChangedArgs e) {
|
||||||
|
super.propertyChanged(e);
|
||||||
|
String key = e.getProperty().getName();
|
||||||
|
ChangeData[] changeData = e.getChangeSet();
|
||||||
|
Object newValue = changeData[0].getNewValue();
|
||||||
|
Object oldValue = changeData[0].getOldValue();
|
||||||
|
int iRow = changeData[0].getRowIndex();
|
||||||
|
if (newValue != oldValue) {
|
||||||
|
switch (key) {
|
||||||
|
case "e_midorgtypewin":
|
||||||
|
this.midOrgTypeChange((String)newValue, iRow);
|
||||||
|
this.getModel().setValue("e_underwritertypewin", (Object)null, iRow);
|
||||||
|
this.getModel().setValue("e_midorgname", (Object)null, iRow);
|
||||||
|
default:
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void midOrgTypeChange(String newValue, int index) {
|
||||||
|
Boolean isUnderWriter = "underwriter".equals(newValue);
|
||||||
|
((ComboEdit)this.getControl("e_underwritertypewin")).setMustInput(isUnderWriter);
|
||||||
|
this.getView().setEnable(isUnderWriter, index, new String[]{"e_underwritertypewin"});
|
||||||
|
}
|
||||||
|
|
||||||
|
public void beforeClick(BeforeClickEvent evt) {
|
||||||
|
super.beforeClick(evt);
|
||||||
|
Object source = evt.getSource();
|
||||||
|
String key = ((Button)source).getKey();
|
||||||
|
if ("btnok".equals(key)) {
|
||||||
|
Object pkId = this.getView().getFormShowParameter().getCustomParam("pkid");
|
||||||
|
DynamicObject selectBill = TmcDataServiceHelper.loadSingle(pkId, "bdim_intermediaryselect");
|
||||||
|
String billStatus = selectBill.getString("billstatus");
|
||||||
|
if (!"C".equals(billStatus)) {
|
||||||
|
evt.setCancel(true);
|
||||||
|
this.getView().showTipNotification(ResManager.loadKDString("操作单据不为已审核状态,请检查。", "WinningBidderPlugin_5", "tmc-bdim-formplugin", new Object[0]));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
DynamicObjectCollection entryEntities = this.getModel().getEntryEntity("entryentity");
|
||||||
|
|
||||||
|
for(int i = 0; i < entryEntities.size(); ++i) {
|
||||||
|
DynamicObject entry = (DynamicObject)entryEntities.get(i);
|
||||||
|
String eMidOrgTypeWin = entry.getString("e_midorgtypewin");
|
||||||
|
String eUnderWriterTypeWin = entry.getString("e_underwritertypewin");
|
||||||
|
if (EmptyUtil.isBlank(eMidOrgTypeWin)) {
|
||||||
|
evt.setCancel(true);
|
||||||
|
this.getView().showTipNotification(String.format(ResManager.loadKDString("第%s行:请填写”中介机构类型“。", "WinningBidderPlugin_4", "tmc-bdim-formplugin", new Object[0]), i + 1));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ("underwriter".equals(eMidOrgTypeWin) && EmptyUtil.isBlank(eUnderWriterTypeWin)) {
|
||||||
|
evt.setCancel(true);
|
||||||
|
this.getView().showTipNotification(String.format(ResManager.loadKDString("第%s行:”中介机构类型“为承销商时,”承销商类别“必填。", "WinningBidderPlugin_0", "tmc-bdim-formplugin", new Object[0]), i + 1));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
DynamicObject eMidOrgName = entry.getDynamicObject("e_midorgname");
|
||||||
|
if (eMidOrgName == null) {
|
||||||
|
evt.setCancel(true);
|
||||||
|
this.getView().showTipNotification(String.format(ResManager.loadKDString("第%s行:请填写“机构名称”。", "WinningBidderPlugin_1", "tmc-bdim-formplugin", new Object[0]), i + 1));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
Date eOpeningDateWin = entry.getDate("e_openingdatewin");
|
||||||
|
if (EmptyUtil.isEmpty(eOpeningDateWin)) {
|
||||||
|
evt.setCancel(true);
|
||||||
|
this.getView().showTipNotification(String.format(ResManager.loadKDString("第%s行:请填写“开标日期”。", "WinningBidderPlugin_2", "tmc-bdim-formplugin", new Object[0]), i + 1));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public void click(EventObject evt) {
|
||||||
|
super.click(evt);
|
||||||
|
Control control = (Control)evt.getSource();
|
||||||
|
if (StringUtils.equals("btnok", control.getKey())) {
|
||||||
|
Object pkId = this.getView().getFormShowParameter().getCustomParam("pkid");
|
||||||
|
DynamicObject selectBill = TmcDataServiceHelper.loadSingle(pkId, "bdim_intermediaryselect");
|
||||||
|
DynamicObjectCollection winningBidderEntries = selectBill.getDynamicObjectCollection("winningbidderentry");
|
||||||
|
DynamicObjectCollection entryEntity = this.getModel().getEntryEntity("entryentity");
|
||||||
|
winningBidderEntries.clear();
|
||||||
|
int i = 0;
|
||||||
|
Iterator var8 = entryEntity.iterator();
|
||||||
|
|
||||||
|
while(var8.hasNext()) {
|
||||||
|
DynamicObject entry = (DynamicObject)var8.next();
|
||||||
|
DynamicObject winningBidderEntry = winningBidderEntries.addNew();
|
||||||
|
winningBidderEntry.set("seq", i++);
|
||||||
|
winningBidderEntry.set("e_midorgtypewin", entry.get("e_midorgtypewin"));
|
||||||
|
winningBidderEntry.set("e_underwritertypewin", entry.get("e_underwritertypewin"));
|
||||||
|
winningBidderEntry.set("e_midorgname", entry.get("e_midorgname"));
|
||||||
|
winningBidderEntry.set("shkd_pglx1", entry.get("shkd_pglx1"));
|
||||||
|
winningBidderEntry.set("e_openingdatewin", entry.get("e_openingdatewin"));
|
||||||
|
winningBidderEntry.set("e_fee", entry.get("e_fee"));
|
||||||
|
winningBidderEntry.set("e_feerate", entry.get("e_feerate"));
|
||||||
|
DynamicObjectCollection eBidWinningNoticeEntry = entry.getDynamicObjectCollection("e_bidwinningnotice");
|
||||||
|
DynamicObjectCollection noticeEntryEntity = winningBidderEntry.getDynamicObjectCollection("e_bidwinningnotice");
|
||||||
|
noticeEntryEntity.clear();
|
||||||
|
Iterator var13 = eBidWinningNoticeEntry.iterator();
|
||||||
|
|
||||||
|
while(var13.hasNext()) {
|
||||||
|
DynamicObject bidWinningNoticeEntry = (DynamicObject)var13.next();
|
||||||
|
noticeEntryEntity.addNew().set("fbasedataid", bidWinningNoticeEntry.get("fbasedataid"));
|
||||||
|
}
|
||||||
|
|
||||||
|
DynamicObjectCollection eContractEntry = entry.getDynamicObjectCollection("e_contract");
|
||||||
|
DynamicObjectCollection eContractEntryEntity = winningBidderEntry.getDynamicObjectCollection("e_contract");
|
||||||
|
eContractEntryEntity.clear();
|
||||||
|
Iterator var15 = eContractEntry.iterator();
|
||||||
|
|
||||||
|
while(var15.hasNext()) {
|
||||||
|
DynamicObject contractEntry = (DynamicObject)var15.next();
|
||||||
|
eContractEntryEntity.addNew().set("fbasedataid", contractEntry.get("fbasedataid"));
|
||||||
|
}
|
||||||
|
|
||||||
|
winningBidderEntry.set("e_explainwin", entry.get("e_explainwin"));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (entryEntity.size() == 0) {
|
||||||
|
selectBill.set("callbizstatus", "calling");
|
||||||
|
} else {
|
||||||
|
selectBill.set("callbizstatus", "called");
|
||||||
|
}
|
||||||
|
|
||||||
|
SaveServiceHelper.save(new DynamicObject[]{selectBill});
|
||||||
|
this.getView().close();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue