|
@@ -18,6 +18,7 @@ import nc.vo.bd.meta.BatchOperateVO;
|
|
|
import nc.vo.hrwa.wadataexplain.Wadataexplain;
|
|
|
import nc.vo.pub.BusinessException;
|
|
|
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
|
|
|
+import nccloud.commons.collections.CollectionUtils;
|
|
|
import nccloud.itf.bd.wadataexplain.IWadataexplainQryService;
|
|
|
import nccloud.itf.bd.wadataexplain.IWadataexplainService;
|
|
|
|
|
@@ -96,24 +97,45 @@ public class WadataexplainServiceImpl extends BatchBaseService<Wadataexplain>
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<Wadataexplain> batchCommit(StringBuffer pk_psndoc_buf, StringBuffer pk_buf, HashMap<String, String> psndocMap)
|
|
|
+ public List<Wadataexplain> batchCommit(StringBuffer pk_wa_class_buf, StringBuffer pk_buf, HashMap<String, String> psndocMap,StringBuffer cyearperiodbuf)
|
|
|
throws BusinessException {
|
|
|
// TODO Auto-generated method stub
|
|
|
+ //当前会计期间已经 全部审批,不允许提交
|
|
|
+ StringBuffer dataBufall = new StringBuffer();
|
|
|
+ dataBufall.append(" select pk_wa_data from wa_data");
|
|
|
+ dataBufall.append(" where checkflag = 'N'");
|
|
|
+ dataBufall.append(" and pk_wa_class in ( ");
|
|
|
+ dataBufall.append(pk_wa_class_buf.substring(0, pk_wa_class_buf.length()-1));
|
|
|
+ dataBufall.append(" )");
|
|
|
+ dataBufall.append(" and cyearperiod in ( ");
|
|
|
+ dataBufall.append(cyearperiodbuf.substring(0, cyearperiodbuf.length()-1));
|
|
|
+ dataBufall.append(" )");
|
|
|
+ dataBufall.append(" and nvl(dr,0)=0");
|
|
|
+
|
|
|
+ List<Map<String, Object>> alldatalist = (List<Map<String, Object>>)getNcDAO().executeQuery(dataBufall.toString(), new MapListProcessor());
|
|
|
+ if(CollectionUtils.isEmpty(alldatalist))
|
|
|
+ ExceptionUtils.wrappBusinessException("薪资发放节点数据已全部审核,不允许提交");
|
|
|
+
|
|
|
+ //当前会计期间未全部审批,只要对应的数据审批,就可以提交
|
|
|
StringBuffer dataBuf = new StringBuffer();
|
|
|
dataBuf.append(" select pk_wa_data from wa_data");
|
|
|
dataBuf.append(" where checkflag = 'Y'");
|
|
|
- dataBuf.append(" and pk_wa_data in ( ");
|
|
|
- dataBuf.append(pk_psndoc_buf.substring(0, pk_psndoc_buf.length()-1));
|
|
|
- dataBuf.append(" ) and nvl(dr,0)=0");
|
|
|
+ dataBuf.append(" and pk_wa_class in ( ");
|
|
|
+ dataBuf.append(pk_wa_class_buf.substring(0, pk_wa_class_buf.length()-1));
|
|
|
+ dataBuf.append(" )");
|
|
|
+ dataBuf.append(" and cyearperiod in ( ");
|
|
|
+ dataBuf.append(cyearperiodbuf.substring(0, cyearperiodbuf.length()-1));
|
|
|
+ dataBuf.append(" )");
|
|
|
+ dataBuf.append(" and nvl(dr,0)=0");
|
|
|
|
|
|
List<Map<String, Object>> dataList = (List<Map<String, Object>>)getNcDAO().executeQuery(dataBuf.toString(), new MapListProcessor());
|
|
|
if(dataList!=null && dataList.size()>0){
|
|
|
StringBuffer retbuf = new StringBuffer();
|
|
|
- retbuf.append("薪资发放节点数据已审核,不允许提交: ");
|
|
|
- for(int i=0;i<dataList.size();i++){
|
|
|
- retbuf.append(psndocMap.get(dataList.get(i).get("pk_wa_data")));
|
|
|
- retbuf.append(" ");
|
|
|
- }
|
|
|
+ retbuf.append("薪资发放节点数据已审核,不允许提交");
|
|
|
+// for(int i=0;i<dataList.size();i++){
|
|
|
+// retbuf.append(psndocMap.get(dataList.get(i).get("pk_wa_data")));
|
|
|
+// retbuf.append(" ");
|
|
|
+// }
|
|
|
ExceptionUtils.wrappBusinessException( retbuf.toString());
|
|
|
}
|
|
|
|
|
@@ -132,30 +154,51 @@ public class WadataexplainServiceImpl extends BatchBaseService<Wadataexplain>
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<Wadataexplain> batchUncommit(StringBuffer pk_psndoc_buf, StringBuffer pk_buf, HashMap<String, String> psndocMap)
|
|
|
+ public List<Wadataexplain> batchUncommit(StringBuffer pk_wa_class_buf, StringBuffer pk_buf, HashMap<String, String> psndocMap,StringBuffer cyearperiodbuf)
|
|
|
throws BusinessException {
|
|
|
// TODO Auto-generated method stub
|
|
|
+ //当前会计期间已经 全部审批,不允许提交
|
|
|
+ StringBuffer dataBufall = new StringBuffer();
|
|
|
+ dataBufall.append(" select pk_wa_data from wa_data");
|
|
|
+ dataBufall.append(" where checkflag = 'N'");
|
|
|
+ dataBufall.append(" and pk_wa_class in ( ");
|
|
|
+ dataBufall.append(pk_wa_class_buf.substring(0, pk_wa_class_buf.length()-1));
|
|
|
+ dataBufall.append(" )");
|
|
|
+ dataBufall.append(" and cyearperiod in ( ");
|
|
|
+ dataBufall.append(cyearperiodbuf.substring(0, cyearperiodbuf.length()-1));
|
|
|
+ dataBufall.append(" )");
|
|
|
+ dataBufall.append(" and nvl(dr,0)=0");
|
|
|
+
|
|
|
+ List<Map<String, Object>> alldatalist = (List<Map<String, Object>>)getNcDAO().executeQuery(dataBufall.toString(), new MapListProcessor());
|
|
|
+ if(CollectionUtils.isEmpty(alldatalist))
|
|
|
+ ExceptionUtils.wrappBusinessException("薪资发放节点数据已全部审核,不允许收回");
|
|
|
+
|
|
|
StringBuffer dataBuf = new StringBuffer();
|
|
|
dataBuf.append(" select pk_wa_data from wa_data");
|
|
|
dataBuf.append(" where checkflag = 'Y'");
|
|
|
- dataBuf.append(" and pk_wa_data in ( ");
|
|
|
- dataBuf.append(pk_psndoc_buf.substring(0, pk_psndoc_buf.length()-1));
|
|
|
- dataBuf.append(" ) and nvl(dr,0)=0");
|
|
|
+ dataBuf.append(" and pk_wa_class in ( ");
|
|
|
+ dataBuf.append(pk_wa_class_buf.substring(0, pk_wa_class_buf.length()-1));
|
|
|
+ dataBuf.append(" )");
|
|
|
+ dataBuf.append(" and cyearperiod in ( ");
|
|
|
+ dataBuf.append(cyearperiodbuf.substring(0, cyearperiodbuf.length()-1));
|
|
|
+ dataBuf.append(" )");
|
|
|
+ dataBuf.append(" and nvl(dr,0)=0");
|
|
|
+
|
|
|
|
|
|
List<Map<String, Object>> dataList = (List<Map<String, Object>>)getNcDAO().executeQuery(dataBuf.toString(), new MapListProcessor());
|
|
|
if(dataList!=null && dataList.size()>0){
|
|
|
StringBuffer retbuf = new StringBuffer();
|
|
|
- retbuf.append("薪资发放节点数据已审核,不允许收回: ");
|
|
|
- for(int i=0;i<dataList.size();i++){
|
|
|
- retbuf.append(psndocMap.get(dataList.get(i).get("pk_wa_data")));
|
|
|
- retbuf.append(" ");
|
|
|
- }
|
|
|
+ retbuf.append("薪资发放节点数据已审核,不允许收回 ");
|
|
|
+// for(int i=0;i<dataList.size();i++){
|
|
|
+// retbuf.append(psndocMap.get(dataList.get(i).get("pk_wa_data")));
|
|
|
+// retbuf.append(" ");
|
|
|
+// }
|
|
|
ExceptionUtils.wrappBusinessException( retbuf.toString());
|
|
|
}
|
|
|
|
|
|
StringBuffer updatesql = new StringBuffer();
|
|
|
updatesql.append(" update wa_data_explain");
|
|
|
- updatesql.append(" set iscommit = 'N'");
|
|
|
+ updatesql.append(" set iscommit = 'N' ,isquote = 'N' " );
|
|
|
updatesql.append(" where pk_wa_data_explain in ( ");
|
|
|
updatesql.append(pk_buf.substring(0, pk_buf.length()-1));
|
|
|
updatesql.append(" )");
|