hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

报销接口编写,添加事物

This commit is contained in:
lvleigang 2024-08-19 09:17:09 +08:00
parent 0e717cd182
commit 885b0e4d28
2 changed files with 33 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjml/service/IOerDjmlService.java
View File

@ -1,6 +1,7 @@
package com.hzya.frame.grpU8.nxproof.oerdjml.service; package com.hzya.frame.grpU8.nxproof.oerdjml.service;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.dynamic.datasource.annotation.DSTransactional;
import com.hzya.frame.grpU8.nxproof.oerdjml.entity.OerDjmlEntity; import com.hzya.frame.grpU8.nxproof.oerdjml.entity.OerDjmlEntity;
import com.hzya.frame.sysnew.application.entity.SysExtensionApiEntity; import com.hzya.frame.sysnew.application.entity.SysExtensionApiEntity;
@ -32,5 +33,6 @@ public interface IOerDjmlService {
* @param jsonObject * @param jsonObject
* @return java.lang.Object * @return java.lang.Object
**/ **/
@DSTransactional()
Object handleOerDjml(JSONObject jsonObject); Object handleOerDjml(JSONObject jsonObject);
} }

53
service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjml/service/impl/OerDjmlServiceImpl.java
View File

@ -1206,31 +1206,39 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
logger.info("组装单据报销明细开始:------>"); logger.info("组装单据报销明细开始:------>");
List<OerDjnrEntity> oerDjnrEntityList = setOerDjnrEntity(entity,maxDjbh,maxMlId); List<OerDjnrEntity> oerDjnrEntityList = setOerDjnrEntity(entity,maxDjbh,maxMlId);
logger.info("保存报销明细开始:------>"); logger.info("保存报销明细开始:------>");
for(OerDjnrEntity djnrEntity : oerDjnrEntityList){ if(oerDjnrEntityList != null && oerDjnrEntityList.size() > 0){
djnrEntity.setDataSourceCode(dataSourceCode); for(OerDjnrEntity djnrEntity : oerDjnrEntityList){
iOerDjnrDao.saveData(djnrEntity); djnrEntity.setDataSourceCode(dataSourceCode);
logger.info("保存完报销明细后，根据明细数据生成预算指标数据:------>"); iOerDjnrDao.saveData(djnrEntity);
OerYszbEntity yszbEntity = createOerYszbEntity(djnrEntity,maxMlId); logger.info("保存完报销明细后，根据明细数据生成预算指标数据:------>");
logger.info("保存预算指标开始:------>"); OerYszbEntity yszbEntity = createOerYszbEntity(djnrEntity,maxMlId);
yszbEntity.setDataSourceCode(dataSourceCode); logger.info("保存预算指标开始:------>");
iOerYszbDao.saveData(yszbEntity); yszbEntity.setDataSourceCode(dataSourceCode);
logger.info("保存预算指标记录:------>"); iOerYszbDao.saveData(yszbEntity);
GbiZbsyrecEntity oeryszb= setOerYszbEntity(entity,djnrEntity); logger.info("保存预算指标记录:------>");
oeryszb.setDataSourceCode(dataSourceCode); GbiZbsyrecEntity oeryszb= setOerYszbEntity(entity,djnrEntity);
iGbiZbsyrecDao.saveData(oeryszb); oeryszb.setDataSourceCode(dataSourceCode);
iGbiZbsyrecDao.saveData(oeryszb);
}
} }
logger.info("组装单据结算方式明细开始:------>"); logger.info("组装单据结算方式明细开始:------>");
List<OerDjjsfsEntity> oerDjjsfsEntityList = setOerDjjsfsEntityList(entity,maxDjbh,maxMlId); List<OerDjjsfsEntity> oerDjjsfsEntityList = setOerDjjsfsEntityList(entity,maxDjbh,maxMlId);
logger.info("保存结算方式明细开始:------>"); logger.info("保存结算方式明细开始:------>");
for(OerDjjsfsEntity oerdjjsfs :oerDjjsfsEntityList){ if(oerDjjsfsEntityList != null && oerDjjsfsEntityList.size() > 0){
oerdjjsfs.setDataSourceCode(dataSourceCode); for(OerDjjsfsEntity oerdjjsfs :oerDjjsfsEntityList){
iOerDjjsfsDao.saveData(oerdjjsfs); oerdjjsfs.setDataSourceCode(dataSourceCode);
iOerDjjsfsDao.saveData(oerdjjsfs);
}
} }
//保存日志表PubAuditLog //保存日志表PubAuditLog
List<PubAuditLogEntity> pubAuditLogEntityList = setPubAuditLog(entity, maxMlId); List<PubAuditLogEntity> pubAuditLogEntityList = setPubAuditLog(entity, maxMlId);
for (PubAuditLogEntity pubAuditLog : pubAuditLogEntityList) { if(pubAuditLogEntityList != null&& pubAuditLogEntityList.size() > 0){
pubAuditLog.setDataSourceCode(dataSourceCode); for (PubAuditLogEntity pubAuditLog : pubAuditLogEntityList) {
iPubAuditLogDao.saveData(pubAuditLog); pubAuditLog.setDataSourceCode(dataSourceCode);
iPubAuditLogDao.saveData(pubAuditLog);
}
} }
if(!flag){ if(!flag){
//保存节点PUB_OBJ_FLOW //保存节点PUB_OBJ_FLOW
@ -1238,7 +1246,6 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
pubObjFlowEntity.setDataSourceCode(dataSourceCode); pubObjFlowEntity.setDataSourceCode(dataSourceCode);
iPubObjFlowDao.saveData(pubObjFlowEntity); iPubObjFlowDao.saveData(pubObjFlowEntity);
} }
return BaseResult.getSuccessMessageEntity("保存报销单成功",maxDjbh); return BaseResult.getSuccessMessageEntity("保存报销单成功",maxDjbh);
} }
@ -1253,9 +1260,11 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
**/ **/
private List<OerDjnrEntity> setOerDjnrEntity(OerDjmlEntity entity, String maxDjbh, String maxMlId) { private List<OerDjnrEntity> setOerDjnrEntity(OerDjmlEntity entity, String maxDjbh, String maxMlId) {
List<OerDjnrEntity> djnrEntityList = entity.getOerDjnrEntityList(); List<OerDjnrEntity> djnrEntityList = entity.getOerDjnrEntityList();
for (int i = 0; i < djnrEntityList.size(); i++) { if(djnrEntityList != null && djnrEntityList.size() > 0){
djnrEntityList.get(i).setMlId(maxMlId); for (int i = 0; i < djnrEntityList.size(); i++) {
djnrEntityList.get(i).setGsdm(entity.getGsdm()); djnrEntityList.get(i).setMlId(maxMlId);
djnrEntityList.get(i).setGsdm(entity.getGsdm());
}
} }
return djnrEntityList; return djnrEntityList;
} }