Commit 6cb05759 by 周海峰

no message

parent 04149e3e
......@@ -6,7 +6,7 @@ import javax.persistence.Table;
@Entity
@Table(
name = "T_CORE_SCOPE _REGEX"
name = "T_CORE_SCOPE_REGEX"
)
public class TCoreScopeRegex extends TBaseEntity {
private String regex_id;
......
......@@ -7,9 +7,11 @@ import com.chenyang.nse.bussiness.entity.orm.table.core.dataproject.TCoreSecretk
import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreEncryption;
import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreEncryptionTypeField;
import com.chenyang.nse.bussiness.service.core.encryption.TCoreEncryptionService;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang.StringUtils;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Restrictions;
......@@ -21,69 +23,69 @@ import org.springframework.stereotype.Component;
@Component
public class KeyLoader {
private static final Logger LOGGER = LoggerFactory.getLogger(KeyLoader.class);
@Autowired
private TCoreSecretkeyDao tCoreSecretkeyDao;
@Autowired
TCoreEncryptionDao tCoreEncryptionDao;
@Autowired
@Qualifier("TCoreEncryptionContext")
private TCoreEncryptionService service;
@Autowired
protected TCoreEncryptionTypeFieldDao tCoreEncryptionTypeFieldDao;
private static final Logger LOGGER = LoggerFactory.getLogger(KeyLoader.class);
@Autowired
private TCoreSecretkeyDao tCoreSecretkeyDao;
@Autowired
TCoreEncryptionDao tCoreEncryptionDao;
@Autowired
@Qualifier("TCoreEncryptionContext")
private TCoreEncryptionService service;
@Autowired
protected TCoreEncryptionTypeFieldDao tCoreEncryptionTypeFieldDao;
public MulKey load() {
MulKey map = new MulKey();
public MulKey load() {
MulKey map = new MulKey();
try {
List<TCoreEncryptionTypeField> fieldCfgs = this.tCoreEncryptionTypeFieldDao.queryAll();
if (fieldCfgs != null && fieldCfgs.size() != 0) {
for(TCoreEncryptionTypeField fieldCfg : fieldCfgs) {
String encSecId = fieldCfg.getEncryption_secretkey_id();
if (encSecId != null && !encSecId.isEmpty()) {
Map<String, String> secMap = this.service.queryEncryptionInfo(encSecId);
if (secMap != null) {
String key = (String)secMap.get("secretkey");
String id = String.format("%s#$#%s#$#%s#$#%s", fieldCfg.getTschemas(), fieldCfg.getNames(), fieldCfg.getTable_field_id(), fieldCfg.getProjectid());
TCoreSecretkey tCoreSecretkey = (TCoreSecretkey)this.tCoreSecretkeyDao.queryUnique(new Criterion[]{Restrictions.eq("id", fieldCfg.getEncryption_secretkey_id())});
TCoreEncryption tCoreEncryp = new TCoreEncryption();
if (null != tCoreSecretkey) {
tCoreEncryp = (TCoreEncryption)this.tCoreEncryptionDao.queryUnique(new Criterion[]{Restrictions.eq("id", tCoreSecretkey.getId())});
}
try {
List<TCoreEncryptionTypeField> fieldCfgs = this.tCoreEncryptionTypeFieldDao.queryAll();
if (fieldCfgs != null && fieldCfgs.size() != 0) {
for (TCoreEncryptionTypeField fieldCfg : fieldCfgs) {
String encSecId = fieldCfg.getEncryption_secretkey_id();
if (encSecId != null && !encSecId.isEmpty()) {
Map<String, String> secMap = this.service.queryEncryptionInfo(encSecId);
if (secMap != null) {
String key = (String) secMap.get("secretkey");
String id = String.format("%s#$#%s#$#%s#$#%s", fieldCfg.getTschemas(), fieldCfg.getNames(), fieldCfg.getTable_field_id(), fieldCfg.getProjectid());
TCoreSecretkey tCoreSecretkey = (TCoreSecretkey) this.tCoreSecretkeyDao.queryUnique(new Criterion[]{Restrictions.eq("id", fieldCfg.getEncryption_secretkey_id())});
TCoreEncryption tCoreEncryp = new TCoreEncryption();
if (null != tCoreSecretkey) {
tCoreEncryp = (TCoreEncryption) this.tCoreEncryptionDao.queryUnique(new Criterion[]{Restrictions.eq("id", tCoreSecretkey.getId())});
}
String type = "";
if (null != tCoreEncryp && null != tCoreEncryp.getEncryption_type() && !"".equals(tCoreEncryp.getEncryption_type())) {
type = tCoreEncryp.getEncryption_type();
}
String type = "";
if (null != tCoreEncryp && null != tCoreEncryp.getEncryption_type() && !"".equals(tCoreEncryp.getEncryption_type())) {
type = tCoreEncryp.getEncryption_type();
}
if (type == null || type.length() == 0) {
type = "SM4";
}
if (type == null || type.length() == 0) {
type = "SM4";
}
String tkey = "";
tkey = key + ":" + type + ":" + fieldCfg.getIslike() + ":" + (StringUtils.isEmpty(fieldCfg.getKeepfirst()) ? "0" : fieldCfg.getKeepfirst()) + ":" + (StringUtils.isEmpty(fieldCfg.getEncdigit()) ? "0" : fieldCfg.getEncdigit()) + ":" + (StringUtils.isEmpty(fieldCfg.getTwoindex()) ? "0" : fieldCfg.getTwoindex());
String pid = fieldCfg.getProjectid() + ":" + fieldCfg.getId();
map.bKeys.put(id, tkey);
map.pKeys.put(pid, key);
}
}
}
String tkey = "";
tkey = key + ":" + type + ":" + fieldCfg.getIslike() + ":" + (StringUtils.isEmpty(fieldCfg.getKeepfirst()) ? "0" : fieldCfg.getKeepfirst()) + ":" + (StringUtils.isEmpty(fieldCfg.getEncdigit()) ? "0" : fieldCfg.getEncdigit()) + ":" + (StringUtils.isEmpty(fieldCfg.getTwoindex()) ? "0" : fieldCfg.getTwoindex());
String pid = fieldCfg.getProjectid() + ":" + fieldCfg.getId();
map.bKeys.put(id, tkey);
map.pKeys.put(pid, key);
}
}
}
return map;
} else {
return map;
}
} catch (Exception e) {
LOGGER.error(e.getMessage(), e);
MulKey var3 = new MulKey();
return var3;
} finally {
;
}
}
return map;
} else {
return map;
}
} catch (Exception e) {
LOGGER.error(e.getMessage(), e);
MulKey var3 = new MulKey();
return var3;
} finally {
;
}
}
static class MulKey {
public Map<String, String> bKeys = new HashMap();
public Map<String, String> pKeys = new HashMap();
}
static class MulKey {
public Map<String, String> bKeys = new HashMap();
public Map<String, String> pKeys = new HashMap();
}
}
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论