From e6836e42dc0bcdde1098564f16fa5b70d1fae6ac Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E6=AD=A3=40=E7=94=A8=E5=8F=8B?= Date: Fri, 11 Apr 2025 18:17:18 +0800 Subject: [PATCH] =?UTF-8?q?yxy=5F=E9=87=87=E8=B4=AD=E5=85=A5=E5=BA=93?= =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=8E=A5=E5=8F=A3=E8=B4=A7=E4=BD=8D=E7=BF=BB?= =?UTF-8?q?=E8=AF=91=E9=80=BB=E8=BE=91=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- yxy/component.xml | 5 + .../nc/impl/urmex/pub/RMGlobalCacheImpl.java | 625 ++++++++++++++++++ 2 files changed, 630 insertions(+) create mode 100644 yxy/component.xml create mode 100644 yxy/src/private/nc/impl/urmex/pub/RMGlobalCacheImpl.java diff --git a/yxy/component.xml b/yxy/component.xml new file mode 100644 index 0000000..bd348ed --- /dev/null +++ b/yxy/component.xml @@ -0,0 +1,5 @@ + + + + + \ No newline at end of file diff --git a/yxy/src/private/nc/impl/urmex/pub/RMGlobalCacheImpl.java b/yxy/src/private/nc/impl/urmex/pub/RMGlobalCacheImpl.java new file mode 100644 index 0000000..ebddf05 --- /dev/null +++ b/yxy/src/private/nc/impl/urmex/pub/RMGlobalCacheImpl.java @@ -0,0 +1,625 @@ +package nc.impl.urmex.pub; + +import java.text.MessageFormat; +import java.util.Collection; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; +import java.util.concurrent.ConcurrentHashMap; + +import nc.bs.dao.BaseDAO; +import nc.bs.framework.common.InvocationInfoProxy; +import nc.bs.framework.common.NCLocator; +import nc.impl.pubapp.env.BSContext; +import nc.itf.so.m30trantype.IM30TranTypeService; +import nc.itf.uap.IUAPQueryBS; +import nc.itf.uap.pf.IPFConfig; +import nc.itf.urmex.pub.IRMGlobalCache; +import nc.pubitf.org.IOrgUnitPubService; +import nc.vo.bd.balatype.BalaTypeVO; +import nc.vo.bd.currtype.CurrtypeVO; +import nc.vo.bd.cust.CustomerVO; +import nc.vo.bd.material.MaterialVersionVO; +import nc.vo.bd.material.measdoc.MeasdocVO; +import nc.vo.bd.psn.PsndocVO; +import nc.vo.bd.rack.RackVO; +import nc.vo.bd.stordoc.StordocVO; +import nc.vo.bd.supplier.SupplierVO; +import nc.vo.fibd.RecpaytypeVO; +import nc.vo.org.DeptVO; +import nc.vo.org.OrgVO; +import nc.vo.pub.BusinessException; +import nc.vo.pub.SuperVO; +import nc.vo.pub.billtype.BilltypeVO; +import nc.vo.pubapp.AppContext; +import nc.vo.pubapp.pattern.exception.ExceptionUtils; +import nc.vo.scmf.ic.mbatchcode.BatchcodeVO; +import nc.vo.scmpub.res.billtype.SOBillType; +import nc.vo.so.m30trantype.entity.M30TranTypeVO; +import nc.vo.so.mreturnreason.entity.ReturnReasonVO; +import nc.vo.bd.goodsref.GoodsRefVO; +import nc.vo.urmex.pub.util.SqlBuilder; +import nc.vo.urmex.pub.util.SqlUtil; +import nc.vo.urmex.pub.util.StringUtil; + + +/** + * @description 档案信息查询与清空 + * @author tianglk + * @date 2022年3月15日 下午1:13:50 + * @version ncc1.0 + */ +public class RMGlobalCacheImpl implements IRMGlobalCache { + + private IUAPQueryBS queryBS = null; + + public final IUAPQueryBS getQueryBS() { + if (null == queryBS) { + queryBS = NCLocator.getInstance().lookup(IUAPQueryBS.class); + } + return queryBS; + } + + BaseDAO baseDAO = null; + + public final BaseDAO getBaseDAO() { + if (baseDAO == null) { + baseDAO = new BaseDAO(); + } + return baseDAO; + } + + Map cache = new ConcurrentHashMap(); + + private void retrieveVOByCode(String prefix, String codeField, String[] codes, Class className, + String condition) throws BusinessException { + String pk_group = InvocationInfoProxy.getInstance().getGroupId(); + this.retrieveVOByCode(prefix, codeField, codes, className, condition, pk_group); + } + + @SuppressWarnings("unchecked") + private void retrieveVOByCode(String prefix, String codeField, String[] codes, Class className, + String condition, String pk_group) throws BusinessException { + Set codeset = new HashSet(); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, pk_group, code); + if (!cache.containsKey(key)) { + codeset.add(code); + } + } + if (codeset.size() > 0) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + if ("currtype_".equals(prefix)) { // 币种特殊处理 + sb.append("pk_org", new String[] { pk_group, "~" }); + } else { + sb.append("pk_group", new String[] { pk_group, "~" }); + } + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", codeField, codeset.toArray(new String[codeset.size()]))); + if (!StringUtil.isSEmptyOrNull(condition)) { + sb.append(" and "); + sb.append(condition); + } + Collection vos = this.getQueryBS().retrieveByClause(className, sb.toString()); + for (SuperVO vo : vos) { + String code = vo.getAttributeValue(codeField).toString(); + String key = MessageFormat.format("{0}{1}{2}", prefix, pk_group, code); + if (cache.containsKey(key)) { + SuperVO cacheVO = cache.get(key); + if (!cacheVO.getPrimaryKey().equals(vo.getPrimaryKey())) { + ExceptionUtils.wrappBusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("4081004_0","04081004-0073", null, new String[] {code}));/*@res "编码为{0}的档案查询结果不唯一,请检查!"*/ + } + } + cache.put(key, vo); + } + } + } + + @Override + public Map getOrgVO(String[] codes) throws BusinessException { + String prefix = "org_"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, OrgVO.class, "isbusinessunit='Y' and islastversion='Y'"); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (OrgVO) cache.get(key)); + } + } + return ret; + } + + @Override + public Map getCustomerVO(String[] codes) throws BusinessException { + String prefix = "cust_"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, CustomerVO.class, ""); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (CustomerVO) cache.get(key)); + } + } + return ret; + } + + + + @Override + public Map getTranstypeVO(String[] codes) throws BusinessException { + String pk_group = InvocationInfoProxy.getInstance().getGroupId(); + String initBillTypeKey = MessageFormat.format("initBillType_{0}", pk_group); + if (!cache.containsKey(initBillTypeKey)) { + //有可能事务回滚导致缓存不准,所以需要清空一下 + cache.clear(); + cache.put(initBillTypeKey, new BilltypeVO()); + } + String prefix = "trantype_"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "pk_billtypecode", codes, BilltypeVO.class, ""); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, pk_group, code); + if (cache.containsKey(key)) { + ret.put(code, (BilltypeVO) cache.get(key)); + } + } + return ret; + } + + @SuppressWarnings("unchecked") + @Override + public Map getBatchcodeVO(String[] materialvids, String[] batchcodes) + throws BusinessException { + Map ret = new HashMap(); + Map materialmap = new HashMap(); + Map batchmap = new HashMap(); + for (int i = 0; i < materialvids.length; i++) { + materialmap.put(materialvids[i], materialvids[i]); + batchmap.put(batchcodes[i], batchcodes[i]); + } + SqlBuilder sb = new SqlBuilder(); + sb.append("pk_group", InvocationInfoProxy.getInstance().getGroupId()); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "cmaterialvid", materialvids)); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "vbatchcode", batchcodes)); + Collection vos = this.getQueryBS().retrieveByClause(BatchcodeVO.class, sb.toString()); + for (BatchcodeVO vo : vos) { + String cmaterialvid = vo.getCmaterialvid(); + String vbatchcode = vo.getVbatchcode(); + if (materialmap.containsKey(cmaterialvid) && batchmap.containsKey(vbatchcode)) { + String key = cmaterialvid + "#" + vbatchcode; + ret.put(key, vo); + } + } + return ret; + } + + @Override + public Map getPsndocVO(String[] codes) throws BusinessException { + String prefix = "psn_"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, PsndocVO.class, ""); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (PsndocVO) cache.get(key)); + } + } + return ret; + } + + @Override + public Map getMaterialVersionVO(String[] codes) throws BusinessException { + String prefix = "material_"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, MaterialVersionVO.class, "enablestate=2"); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (MaterialVersionVO) cache.get(key)); + } + } + return ret; + } + + @SuppressWarnings("unchecked") + @Override + public Map getMeasdocVO(String[] codes) throws BusinessException { + String prefix = "measdoc_"; + Set codeset = new HashSet(); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}", prefix, code); + if (!cache.containsKey(key)) { + codeset.add(code); + } + } + if (codeset.size() > 0) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "code", codeset.toArray(new String[codeset.size()]))); + Collection vos = this.getQueryBS().retrieveByClause(MeasdocVO.class, sb.toString()); + for (SuperVO vo : vos) { + String code = vo.getAttributeValue("code").toString(); + String key = MessageFormat.format("{0}{1}", prefix, code); + cache.put(key, vo); + } + } + Map ret = new HashMap(); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}", prefix, code); + if (cache.containsKey(key)) { + ret.put(code, (MeasdocVO) cache.get(key)); + } + } + return ret; + } + + @Override + public OrgVO getOrgVOByPK(String pkOrg) throws BusinessException { + String prefix = "org_"; + Set set = new HashSet(); + String key = prefix + pkOrg; + if (!cache.containsKey(key)) { + set.add(pkOrg); + } + if (set.size() > 0) { + IOrgUnitPubService orgService = NCLocator.getInstance().lookup(IOrgUnitPubService.class); + OrgVO[] orgVOs = orgService.getOrgs(new String[] { pkOrg }, new String[] { OrgVO.CODE,OrgVO.PK_VID }); + if (orgVOs != null && orgVOs.length > 0) { + cache.put(key, orgVOs[0]); + } + } + return (OrgVO) cache.get(key); + } + + @Override + public Map getSKUVO(String[] codes) throws BusinessException { + + String prefix = "sku_"; + String condition = " exists(select 1 from bd_material_v where bd_material_v.pk_source=urm_goodsref.pk_material)"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "goodscode", codes, GoodsRefVO.class, condition); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (GoodsRefVO) cache.get(key)); + } + } + return ret; + } + + @Override + public M30TranTypeVO getM30TranstypeVO(String code) throws BusinessException { + String prefix = "m30_trantype_"; + String key = prefix + code; + this.initM30TransType(prefix, key, code); + return (M30TranTypeVO) cache.get(key); + } + + private void initM30TransType(String prefix, String key, String code) throws BusinessException { + M30TranTypeVO vo = NCLocator.getInstance().lookup(IM30TranTypeService.class) + .queryTranType(AppContext.getInstance().getPkGroup(), code); + if (null != vo) { + cache.put(key, vo); + } + } + + /** + * 设置业务流程 + */ + @Override + public String getBusitypeCanStart(String csaleorgid, String destTransType) throws BusinessException { + + String userId = BSContext.getInstance().getUserID(); + + String cbiztypeid = null; + try { + + IPFConfig pfsrv = NCLocator.getInstance().lookup(IPFConfig.class); + cbiztypeid = pfsrv.retBusitypeCanStart(SOBillType.Order.getCode(), destTransType, csaleorgid, userId); + + } catch (BusinessException e) { + ExceptionUtils.wrappException(e); + } + return cbiztypeid; + } + + @SuppressWarnings("unchecked") + @Override + public Map getSettleVO(String[] codes) throws BusinessException { + String prefix = "settle_"; + Set codeset = new HashSet(); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}", prefix, code); + if (!cache.containsKey(key)) { + codeset.add(code); + } + } + if (codeset.size() > 0) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "code", codeset.toArray(new String[codeset.size()]))); + Collection vos = this.getQueryBS().retrieveByClause(BalaTypeVO.class, sb.toString()); + for (SuperVO vo : vos) { + String code = vo.getAttributeValue("code").toString(); + String key = MessageFormat.format("{0}{1}", prefix, code); + cache.put(key, vo); + } + } + Map ret = new HashMap(); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}", prefix, code); + if (cache.containsKey(key)) { + ret.put(code, (BalaTypeVO) cache.get(key)); + } + } + return ret; + } + + + + @Override + public Map getSupplierVO(String[] codes) throws BusinessException { + String prefix = "supplier_"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, SupplierVO.class, ""); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (SupplierVO) cache.get(key)); + } + } + return ret; + } + + @SuppressWarnings("unchecked") + @Override + public Map getBackReasonVO(String[] codes, String[] orgIds) throws BusinessException { + String prefix = "backreason_"; + Set codeSet = new HashSet(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + String orgid = orgIds[i]; + String key1 = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + String key2 = key1 + "_" + orgid; + if (!cache.containsKey(key1) && !cache.containsKey(key2)) { + codeSet.add(code); + } + } + if (!codeSet.isEmpty()) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append("pk_group", new String[] { InvocationInfoProxy.getInstance().getGroupId(), "~" }); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "vreasoncode", codeSet.toArray(new String[0]))); + Collection vos = this.getQueryBS().retrieveByClause(ReturnReasonVO.class, sb.toString()); + for (ReturnReasonVO vo : vos) { + String key1 = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + vo.getVreasoncode()); + cache.put(key1, vo); + String key2 = key1 + "_" + vo.getPk_org(); + cache.put(key2, vo); + } + } + + Map ret = new HashMap(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + String orgid = orgIds[i]; + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (ReturnReasonVO) cache.get(key)); + } + if (!StringUtil.isSEmptyOrNull(orgid)) { + key = key + "_" + orgid; + if (cache.containsKey(key)) { + ret.put(code, (ReturnReasonVO) cache.get(key)); + } + } + } + return ret; + } + + @SuppressWarnings("unchecked") + @Override + public Map getDeptVO(String[] codes, String[] orgIds) throws BusinessException { + String prefix = "dept_"; + Set codeSet = new HashSet(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + String orgid = orgIds[i]; + String key1 = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + String key2 = key1 + "_" + orgid; + if (!cache.containsKey(key1) && !cache.containsKey(key2)) { + codeSet.add(code); + } + } + if (!codeSet.isEmpty()) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append("pk_group", new String[] { InvocationInfoProxy.getInstance().getGroupId(), "~" }); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "code", codeSet.toArray(new String[0]))); + Collection vos = this.getQueryBS().retrieveByClause(DeptVO.class, sb.toString()); + for (DeptVO vo : vos) { + String key1 = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + vo.getCode()); + cache.put(key1, vo); + String key2 = key1 + "_" + vo.getPk_org(); + cache.put(key2, vo); + } + } + + Map ret = new HashMap(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + String orgid = orgIds[i]; + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (DeptVO) cache.get(key)); + } + if (!StringUtil.isSEmptyOrNull(orgid)) { + key = key + "_" + orgid; + if (cache.containsKey(key)) { + ret.put(code, (DeptVO) cache.get(key)); + } + } + } + return ret; + } + + @SuppressWarnings("unchecked") + @Override + public Map getStordocVO(String[] codes, String[] orgIds) throws BusinessException { + String prefix = "stordoc_"; + Set codeSet = new HashSet(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + String orgid = orgIds[i]; + String key1 = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + String key2 = key1 + "_" + orgid; + if (!cache.containsKey(key1) && !cache.containsKey(key2)) { + codeSet.add(code); + } + } + if (!codeSet.isEmpty()) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append("pk_group", new String[] { InvocationInfoProxy.getInstance().getGroupId(), "~" }); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "code", codeSet.toArray(new String[0]))); + Collection vos = this.getQueryBS().retrieveByClause(StordocVO.class, sb.toString()); + for (StordocVO vo : vos) { + String key1 = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + vo.getCode()); + cache.put(key1, vo); + String key2 = key1 + "_" + vo.getPk_org(); + cache.put(key2, vo); + } + } + + Map ret = new HashMap(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + String orgid = orgIds[i]; + String key = MessageFormat.format("{0}{1}{2}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code); + if (cache.containsKey(key)) { + ret.put(code, (StordocVO) cache.get(key)); + } + if (!StringUtil.isSEmptyOrNull(orgid)) { + key = key + "_" + orgid; + if (cache.containsKey(key)) { + ret.put(code, (StordocVO) cache.get(key)); + } + } + } + return ret; + } + + @SuppressWarnings("unchecked") + @Override + public Map getRackVO(String[] codes, String[] warehouses) throws BusinessException { + String prefix = "rack_"; + Set codeSet = new HashSet(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + //修改查询逻辑--2025年4月11日15点38分--存在codes与warehouses长度不一致，需要做处理 start + for(String warehouse:warehouses){ + String key = MessageFormat.format("{0}{1}{2}{3}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code, warehouse); + if (!cache.containsKey(key)) { + codeSet.add(code); + } + } + //修改查询逻辑--2025年4月11日15点38分--存在codes与warehouses长度不一致，需要做处理 end + } + if (!codeSet.isEmpty()) { + SqlBuilder sb = new SqlBuilder(); + sb.append("isnull(dr,0)", 0); + sb.append(" and "); + sb.append("pk_group", new String[] { InvocationInfoProxy.getInstance().getGroupId(), "~" }); + sb.append(" and "); + sb.append(SqlUtil.getInOrExistsSql("", "code", codeSet.toArray(new String[0]))); + Collection vos = this.getQueryBS().retrieveByClause(RackVO.class, sb.toString()); + for (RackVO vo : vos) { + String key = MessageFormat.format("{0}{1}{2}{3}", prefix, + InvocationInfoProxy.getInstance().getGroupId(), vo.getCode(), vo.getPk_stordoc()); + cache.put(key, vo); + } + } + + Map ret = new HashMap(); + for (int i = 0; i < codes.length; i++) { + String code = codes[i]; + //修改查询逻辑--2025年4月11日15点38分--存在codes与warehouses长度不一致，需要做处理 start + for(String warehouse:warehouses){ + String key = MessageFormat.format("{0}{1}{2}{3}", prefix, InvocationInfoProxy.getInstance().getGroupId(), + code, warehouse); + if (cache.containsKey(key)) { + ret.put(code + warehouse, (RackVO) cache.get(key)); + } + } + //修改查询逻辑--2025年4月11日15点38分--存在codes与warehouses长度不一致，需要做处理 end + } + return ret; + } + + @Override + public Map getRecpaytypeVOs(String[] codes) throws BusinessException { + String prefix = "recpay_"; + String pk_group = "GLOBLE00000000000000"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, RecpaytypeVO.class, "", pk_group); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, pk_group, code); + if (cache.containsKey(key)) { + ret.put(code, (RecpaytypeVO) cache.get(key)); + } + } + return ret; + } + + @Override + public Map getCurrtypeVOs(String[] codes) throws BusinessException { + String prefix = "currtype_"; + String pk_group = "GLOBLE00000000000000"; + Map ret = new HashMap(); + this.retrieveVOByCode(prefix, "code", codes, CurrtypeVO.class, "", pk_group); + for (String code : codes) { + String key = MessageFormat.format("{0}{1}{2}", prefix, pk_group, code); + if (cache.containsKey(key)) { + ret.put(code, (CurrtypeVO) cache.get(key)); + } + } + return ret; + } + + @Override + public void clear() throws BusinessException { + if (cache != null) { + cache.clear(); + } + } +} \ No newline at end of file