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

1、新增档案特征模块

This commit is contained in:
zhengyf 2025-08-19 19:39:21 +08:00
parent 6a4be4b8ae
commit 0d657561df
15 changed files with 1473 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

356
base-buildpackage/src/main/java/com/hzya/frame/finance/bd/BdController.java Normal file
View File

@ -0,0 +1,356 @@
package com.hzya.frame.finance.bd;
import cn.hutool.core.lang.Assert;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.hzya.frame.mdm.mdmModule.dao.IMdmModuleDao;
import com.hzya.frame.mdm.mdmModule.entity.MdmModuleEntity;
import com.hzya.frame.mdm.mdmModule.service.IMdmModuleService;
import com.hzya.frame.mdm.mdmModuleDb.dao.IMdmModuleDbDao;
import com.hzya.frame.mdm.mdmModuleDb.entity.MdmModuleDbEntity;
import com.hzya.frame.voucher.ae.comf.bd.dao.*;
import com.hzya.frame.voucher.ae.comf.bd.entity.AccsubjTreeNode;
import com.hzya.frame.voucher.ae.comf.bd.entity.AeConfBdAccsubjEntity;
import com.hzya.frame.voucher.ae.comf.bd.entity.vo.*;
import com.hzya.frame.voucher.ae.comf.bd.utils.AccsubjTreeBuilder;
import com.hzya.frame.web.action.DefaultController;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import java.util.*;
import java.util.stream.Collectors;
/**
* Created by zydd on 2025-06-04 15:04
*/
@RestController("financeBdController")
@RequestMapping("/fe/finance/bd")
public class BdController extends DefaultController {
@Autowired
private IAeConfBdOrgBookVODao aeConfBdOrgBookVODao;
@Autowired
private IAeConfBdBdinfoDao aeConfBdBdinfoDao;
@Autowired
private IAeConfBdAccsubjDao aeConfBdAccsubjDao;
@Autowired
private IMdmDBQueryVODAO mdmDBQueryVODAO;
@Autowired
private IMdmModuleService mdmModuleService;
@Autowired
private IMdmModuleDao mdmModuleDao;
@Autowired
private IMdmModuleDbDao mdmModuleDbDao;
@Autowired
private IMdmDbFiledVODAO mdmDbFiledVODAO;
/**
* 查询所有公司
*/
@RequestMapping(value = "/queryOrgVO", method = RequestMethod.POST)
public JsonResultEntity queryOrgVO(@RequestBody OrgBookVO vo) {
try {
List<OrgBookVO> all = aeConfBdOrgBookVODao.queryOrgVO(vo);
return getSuccessMessageEntity("请求成功", all);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询所有公司账簿信息
*/
@RequestMapping(value = "/queryOrgBookVO", method = RequestMethod.POST)
public JsonResultEntity queryOrgBookVO(@RequestBody OrgBookVO vo) {
try {
List<OrgBookVO> all = aeConfBdOrgBookVODao.queryOrgBookVO(vo);
return getSuccessMessageEntity("请求成功", all);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询基础数据资源表
*/
@RequestMapping(value = "/queryPkCodeName", method = RequestMethod.POST)
public JsonResultEntity queryPkCodeName(@RequestBody MdmDbFiledVO entity) {
try {
List<MdmDbFiledVO> mdmDbFiledVOList = mdmDbFiledVODAO.queryMdmDbFiledVOByMdmID(entity);
for (MdmDbFiledVO dbFiledVO : mdmDbFiledVOList) {
dbFiledVO.setPkBdinfo(dbFiledVO.getMdmId());
dbFiledVO.setBdcode(dbFiledVO.getMdmCode());
dbFiledVO.setBdname(dbFiledVO.getMdmName());
dbFiledVO.setTablepkname(dbFiledVO.getTablepkname());
}
return getSuccessMessageEntity("请求成功", mdmDbFiledVOList);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询科目表根据账簿id
*/
@RequestMapping(value = "/queryAccSubjByOrgBookId", method = RequestMethod.POST)
public JsonResultEntity queryAccSubjByOrgBookId(@RequestBody AeConfBdAccsubjEntity entity) {
try {
Assert.notNull(entity.getPkGlorgbook(), "查询科目表时，账簿id不允许为空");
List<AeConfBdAccsubjEntity> all = aeConfBdAccsubjDao.query(entity);
//辅助核算
for (AeConfBdAccsubjEntity aeConfBdAccsubjEntity : all) {
List<AeConfBdAccsubjEntity> assists = aeConfBdAccsubjDao.queryAssist(aeConfBdAccsubjEntity);
List<String> codes = Optional.ofNullable(assists).orElse(Collections.emptyList()).stream()
.map(AeConfBdAccsubjEntity::getBdcode)
.filter(s -> s != null && !s.isEmpty())
.collect(Collectors.toList());
List<String> names = Optional.ofNullable(assists).orElse(Collections.emptyList()).stream()
.map(AeConfBdAccsubjEntity::getBdname)
.filter(s -> s != null && !s.isEmpty())
.collect(Collectors.toList());
aeConfBdAccsubjEntity.setAssistCodes(codes);
aeConfBdAccsubjEntity.setAssistNames(names);
}
List<AccsubjTreeNode> tree = AccsubjTreeBuilder.buildTree(all);
return getSuccessMessageEntity("请求成功", tree);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
// /**
// * 查询基础数据数据表，直连U8C数据库
// */
// @RequestMapping(value = "/queryDataByMap", method = RequestMethod.POST)
// public JsonResultEntity queryDataByMap(@RequestBody HashMap<String, String> map) {
// try {
// if (map.get("tablename") == null || "".equals(map.get("tablename"))) {
// return getSuccessMessageEntity("请求成功", null);
// }
// //查询u8c数据库
// U8CQueryVO u8CQueryVO = new U8CQueryVO();
// u8CQueryVO.setDataSourceCode(ProfilesActiveConstant.LETS_PROD_DATE_SOURCE);
// u8CQueryVO.setTablename(map.get("tablename"));
// List<Map<String, Object>> objectList = u8CQueryVODAO.queryU8CBD(u8CQueryVO);
//
// return getSuccessMessageEntity("请求成功", objectList);
// } catch (Exception e) {
// e.printStackTrace();
// return getFailureMessageEntity(e.getMessage());
// }
// }
/**
* 查询基础数据数据表，查询本地库
*/
@RequestMapping(value = "/queryDataByMap", method = RequestMethod.POST)
public JsonResultEntity queryDataByMap(@RequestBody MdmDBQueryVO mdmDBQueryVO) {
try {
if (mdmDBQueryVO.getTablename() == null || "".equals(mdmDBQueryVO.getTablename())) {
return getSuccessMessageEntity("请求成功", null);
}
//查询表remark，是否包含管理
MdmModuleDbEntity mdmModuleDbEntity = new MdmModuleDbEntity();
mdmModuleDbEntity.setDbName(mdmDBQueryVO.getTablename());
List<MdmModuleDbEntity> dbEntityList = mdmModuleDbDao.query(mdmModuleDbEntity);
if (dbEntityList.size() == 0) {
return getFailureMessageEntity("该表不存在");
}
String remark = dbEntityList.get(0).getRemark();
if (remark != null && !"".equals(remark)) {
if (!remark.contains("管理")) {
mdmDBQueryVO.setPkentityorg(null);
}
}
List<Map<String, Object>> objectList = mdmDBQueryVODAO.queryMdmDb(mdmDBQueryVO);
return getSuccessMessageEntity("请求成功", objectList);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询基础数据数据表
*/
@RequestMapping(value = "/queryDataPagedByMap", method = RequestMethod.POST)
public JsonResultEntity queryDataPagedByMap(@RequestBody MdmDBQueryVO mdmDBQueryVO) {
try {
if (mdmDBQueryVO.getTablename() == null || "".equals(mdmDBQueryVO.getTablename())) {
return getSuccessMessageEntity("请求成功", null);
}
//查询表remark，是否包含管理
MdmModuleDbEntity mdmModuleDbEntity = new MdmModuleDbEntity();
mdmModuleDbEntity.setDbName(mdmDBQueryVO.getTablename());
List<MdmModuleDbEntity> dbEntityList = mdmModuleDbDao.query(mdmModuleDbEntity);
if (dbEntityList.size() == 0) {
return getFailureMessageEntity("该表不存在");
}
String remark = dbEntityList.get(0).getRemark();
if (remark != null && !"".equals(remark)) {
if (!remark.contains("管理")) {
mdmDBQueryVO.setPkentityorg(null);
}
}
PageHelper.startPage(mdmDBQueryVO.getPageNum(), mdmDBQueryVO.getPageSize());
List<Map<String, Object>> objectList = mdmDBQueryVODAO.queryMdmDb(mdmDBQueryVO);
PageInfo pageInfo = new PageInfo(objectList);
return getSuccessMessageEntity("请求成功", pageInfo);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询现金流映射表
*/
@RequestMapping(value = "/queryCashFlowMap", method = RequestMethod.POST)
public JsonResultEntity queryCashFlowMap(@RequestBody CashFlowVO entity) {
try {
List<CashFlowVO> cashFlowVOS = mdmDBQueryVODAO.queryCashflowVO(entity);
return getSuccessMessageEntity("请求成功", cashFlowVOS);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询科目对应表
*/
@RequestMapping(value = "/queryGlsubrelation", method = RequestMethod.POST)
public JsonResultEntity queryGlsubrelation(@RequestBody GlSubrelationVO entity) {
try {
List<GlSubrelationVO> glSubrelationVOS = mdmDBQueryVODAO.queryGlsubrelationVO(entity);
return getSuccessMessageEntity("请求成功", glSubrelationVOS);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询基础档案表bd_bdinfo
*/
@RequestMapping(value = "/queryBdInfo", method = RequestMethod.POST)
public JsonResultEntity queryBdInfo(@RequestBody BdBdinfoEntity entity) {
try {
List<BdBdinfoEntity> list = mdmDBQueryVODAO.queryBdBdinfoList(entity);
return getSuccessMessageEntity("请求成功", list);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询辅助核算关联的档案
*/
@RequestMapping(value = "/queryBdInfoBySubjass", method = RequestMethod.POST)
public JsonResultEntity queryBdInfoBySubjass(@RequestBody BdAccassitemVO entity) {
try {
List<BdAccassitemVO> list = mdmDBQueryVODAO.queryBdInfoBySubjass(entity);
return getSuccessMessageEntity("请求成功", list);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询辅助核算关联的档案-事项分录可选
*/
@RequestMapping(value = "/queryBdInfoBySubjassFilter", method = RequestMethod.POST)
public JsonResultEntity queryBdInfoBySubjassFilter(@RequestBody BdAccassitemVO entity) {
try {
List<BdAccassitemVO> all = new ArrayList<>();
//查询所有关联
List<BdAccassitemVO> list = mdmDBQueryVODAO.queryBdInfoBySubjass(entity);
//查询现有的档案
List<MdmModuleEntity> query = mdmModuleDao.queryMdm(null);
System.out.println(query);
for (BdAccassitemVO bdBdinfoEntity : list) {
for (MdmModuleEntity mdmModuleEntity : query) {
if (bdBdinfoEntity.getPkAccassitem().equals(mdmModuleEntity.getU8cDbPk())
|| bdBdinfoEntity.getPkAccassitem().equals(mdmModuleEntity.getNccDbPk())
|| bdBdinfoEntity.getPkAccassitem().equals(mdmModuleEntity.getYsDbPk())) {
all.add(bdBdinfoEntity);
break;
}
}
}
return getSuccessMessageEntity("请求成功", all);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询凭证类别
*/
@RequestMapping(value = "/queryVoucherType", method = RequestMethod.POST)
public JsonResultEntity queryVoucherType(@RequestBody BdVoucherTypeVO entity) {
try {
List<BdVoucherTypeVO> list = mdmDBQueryVODAO.queryVoucherType(entity);
return getSuccessMessageEntity("请求成功", list);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 币种查询
*/
@RequestMapping(value = "/queryBdCurrtype", method = RequestMethod.POST)
public JsonResultEntity queryBdCurrtype(@RequestBody BdCurrtypeVO entity) {
try {
List<BdCurrtypeVO> list = mdmDBQueryVODAO.queryBdCurrtype(entity);
return getSuccessMessageEntity("请求成功", list);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
// /**
// *
// */
// @RequestMapping(value = "/", method = RequestMethod.POST)
// public JsonResultEntity (@RequestBody entity) {
// try {
// List<> list = mdmDBQueryVODAO.(entity);
// return getSuccessMessageEntity("请求成功", list);
// } catch (Exception e) {
// e.printStackTrace();
// return getFailureMessageEntity(e.getMessage());
// }
// }
}

123
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/controller/FileEigenController.java Normal file
View File

@ -0,0 +1,123 @@
package com.hzya.frame.finance.conf.fileeigen.controller;
import com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity;
import com.hzya.frame.finance.conf.fileeigen.service.IFeConfFileEigenService;
import com.hzya.frame.web.action.DefaultController;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.Map;
/**
* Created by zydd on 2025-08-19 15:15
* 档案特征
*/
@RestController
@RequestMapping("/fe/conf/fileeigen")
public class FileEigenController extends DefaultController {
@Autowired
private IFeConfFileEigenService fileEigenService;
@RequestMapping(value = "/queryAll", method = RequestMethod.POST)
public JsonResultEntity queryAll(@RequestBody FeConfFileEigenEntity entity) {
try {
List<FeConfFileEigenEntity> all = fileEigenService.queryAll(entity);
return getSuccessMessageEntity("请求成功", all);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
@RequestMapping(value = "/save", method = RequestMethod.POST)
public JsonResultEntity saveEntity(@RequestBody List<FeConfFileEigenEntity> list) {
try {
String save = fileEigenService.saveEntity(list);
if(save.contains("失败")){
return getFailureMessageEntity(save);
}
return getSuccessMessageEntity("请求成功", save);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
@RequestMapping(value = "/update", method = RequestMethod.POST)
public JsonResultEntity updateEntity(@RequestBody List<FeConfFileEigenEntity> list) {
try {
String update = fileEigenService.updateEntity(list);
if(update.contains("失败")){
return getFailureMessageEntity(update);
}
return getSuccessMessageEntity("请求成功", update);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
@RequestMapping(value = "/delete", method = RequestMethod.POST)
public JsonResultEntity deleteEntity(@RequestBody List<FeConfFileEigenEntity> list) {
try {
fileEigenService.deleteEntity(list);
return getSuccessMessageEntity("请求成功");
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 查询有档案特征的mdm
*/
@RequestMapping(value = "/queryMdmAll", method = RequestMethod.POST)
public JsonResultEntity queryMdmAll(@RequestBody FeConfFileEigenEntity entity) {
try {
List<FeConfFileEigenEntity> queryMdmAll = fileEigenService.queryMdmAll(entity);
return getSuccessMessageEntity("请求成功", queryMdmAll);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 根据mdmID查询数据
*/
@RequestMapping(value = "/queryDataMapByMdmId", method = RequestMethod.POST)
public JsonResultEntity queryDataMapByMdmId(@RequestBody FeConfFileEigenEntity entity) {
try {
List<Map<String, Object>> dataMapList = fileEigenService.queryDataMapByMdmId(entity);
return getSuccessMessageEntity("请求成功", dataMapList);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
/**
* 自动生成特征
*/
@RequestMapping(value = "/autoExecute", method = RequestMethod.POST)
public JsonResultEntity autoXxecute(@RequestBody FeConfFileEigenEntity entity) {
try {
List<FeConfFileEigenEntity> autoExecute = fileEigenService.autoExecute(entity);
return getSuccessMessageEntity("请求成功", autoExecute);
} catch (Exception e) {
e.printStackTrace();
return getFailureMessageEntity(e.getMessage());
}
}
}

18
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/IFeConfFileEigenDao.java Normal file
View File

@ -0,0 +1,18 @@
package com.hzya.frame.finance.conf.fileeigen.dao;
import com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity;
import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List;
/**
* 财资事项(finance_event)-配置-档案特征(fe_conf_file_eigen: table)表数据库访问层
*
* @author zydd
* @since 2025-08-19 15:12:04
*/
public interface IFeConfFileEigenDao extends IBaseDao<FeConfFileEigenEntity, String> {
List<FeConfFileEigenEntity> queryMdmAll(FeConfFileEigenEntity entity);
}

25
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/impl/FeConfFileEigenDaoImpl.java Normal file
View File

@ -0,0 +1,25 @@
package com.hzya.frame.finance.conf.fileeigen.dao.impl;
import com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity;
import com.hzya.frame.finance.conf.fileeigen.dao.IFeConfFileEigenDao;
import org.springframework.stereotype.Repository;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import java.util.List;
/**
* 财资事项(finance_event)-配置-档案特征(FeConfFileEigen)表数据库访问层
*
* @author zydd
* @since 2025-08-19 15:12:04
*/
@Repository
public class FeConfFileEigenDaoImpl extends MybatisGenericDao<FeConfFileEigenEntity, String> implements IFeConfFileEigenDao{
@Override
public List<FeConfFileEigenEntity> queryMdmAll(FeConfFileEigenEntity entity) {
List<FeConfFileEigenEntity> queryMdmAll = (List<FeConfFileEigenEntity>)selectList("com.hzya.frame.finance.conf.fileeigen.dao.impl.FeConfFileEigenDaoImpl.queryMdmAll", entity);
return queryMdmAll;
}
}

196
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.java Normal file
View File

@ -0,0 +1,196 @@
package com.hzya.frame.finance.conf.fileeigen.entity;
import java.util.Date;
import com.hzya.frame.web.entity.BaseEntity;
/**
* 财资事项(finance_event)-配置-档案特征(FeConfFileEigen)实体类
*
* @author zydd
* @since 2025-08-19 15:12:04
*/
public class FeConfFileEigenEntity extends BaseEntity {
private String splitName;
public String getSplitName() {
return splitName;
}
public void setSplitName(String splitName) {
this.splitName = splitName;
}
/**
* 主数据ID
*/
private String mdmId;
private String mdmCode;
private String mdmName;
/**
* 数据ID
*/
private String mdmDataId;
/**
* 特征值
*/
private String name;
private String def1;
private String def2;
private String def3;
private String def4;
private String def5;
private String def6;
private String def7;
private String def8;
private String def9;
private String def10;
/**
* 创建人
*/
private String createUser;
/**
* 修改人
*/
private String modifyUser;
public String getMdmId() {
return mdmId;
}
public void setMdmId(String mdmId) {
this.mdmId = mdmId;
}
public String getMdmCode() {
return mdmCode;
}
public void setMdmCode(String mdmCode) {
this.mdmCode = mdmCode;
}
public String getMdmName() {
return mdmName;
}
public void setMdmName(String mdmName) {
this.mdmName = mdmName;
}
public String getMdmDataId() {
return mdmDataId;
}
public void setMdmDataId(String mdmDataId) {
this.mdmDataId = mdmDataId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getDef1() {
return def1;
}
public void setDef1(String def1) {
this.def1 = def1;
}
public String getDef2() {
return def2;
}
public void setDef2(String def2) {
this.def2 = def2;
}
public String getDef3() {
return def3;
}
public void setDef3(String def3) {
this.def3 = def3;
}
public String getDef4() {
return def4;
}
public void setDef4(String def4) {
this.def4 = def4;
}
public String getDef5() {
return def5;
}
public void setDef5(String def5) {
this.def5 = def5;
}
public String getDef6() {
return def6;
}
public void setDef6(String def6) {
this.def6 = def6;
}
public String getDef7() {
return def7;
}
public void setDef7(String def7) {
this.def7 = def7;
}
public String getDef8() {
return def8;
}
public void setDef8(String def8) {
this.def8 = def8;
}
public String getDef9() {
return def9;
}
public void setDef9(String def9) {
this.def9 = def9;
}
public String getDef10() {
return def10;
}
public void setDef10(String def10) {
this.def10 = def10;
}
public String getCreateUser() {
return createUser;
}
public void setCreateUser(String createUser) {
this.createUser = createUser;
}
public String getModifyUser() {
return modifyUser;
}
public void setModifyUser(String modifyUser) {
this.modifyUser = modifyUser;
}
}

338
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.xml Normal file
View File

@ -0,0 +1,338 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.finance.conf.fileeigen.dao.impl.FeConfFileEigenDaoImpl">
<resultMap id="get-FeConfFileEigenEntity-result"
type="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
<result property="id" column="id" jdbcType="INTEGER"/>
<result property="mdmId" column="mdm_id" jdbcType="VARCHAR"/>
<result property="mdmCode" column="mdm_code" jdbcType="VARCHAR"/>
<result property="mdmName" column="mdm_name" jdbcType="VARCHAR"/>
<result property="mdmDataId" column="mdm_data_id" jdbcType="VARCHAR"/>
<result property="name" column="name" jdbcType="VARCHAR"/>
<result property="def1" column="def1" jdbcType="VARCHAR"/>
<result property="def2" column="def2" jdbcType="VARCHAR"/>
<result property="def3" column="def3" jdbcType="VARCHAR"/>
<result property="def4" column="def4" jdbcType="VARCHAR"/>
<result property="def5" column="def5" jdbcType="VARCHAR"/>
<result property="def6" column="def6" jdbcType="VARCHAR"/>
<result property="def7" column="def7" jdbcType="VARCHAR"/>
<result property="def8" column="def8" jdbcType="VARCHAR"/>
<result property="def9" column="def9" jdbcType="VARCHAR"/>
<result property="def10" column="def10" jdbcType="VARCHAR"/>
<result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
<result property="createUser" column="create_user" jdbcType="VARCHAR"/>
<result property="modify_time" column="modify_time" jdbcType="TIMESTAMP"/>
<result property="modifyUser" column="modify_user" jdbcType="VARCHAR"/>
<result property="sts" column="sts" jdbcType="VARCHAR"/>
</resultMap>
<!-- 查询的字段-->
<sql id="FeConfFileEigenEntity_Base_Column_List">
id
,mdm_id
,mdm_data_id
,name
,def1
,def2
,def3
,def4
,def5
,def6
,def7
,def8
,def9
,def10
,create_time
,create_user
,modify_time
,modify_user
,sts
</sql>
<!-- 查询 采用==查询 -->
<select id="entity_list_base" resultMap="get-FeConfFileEigenEntity-result"
parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
select
<include refid="FeConfFileEigenEntity_Base_Column_List"/>
from fe_conf_file_eigen
<trim prefix="where" prefixOverrides="and">
<if test="id != null">and id = #{id}</if>
<if test="mdmId != null and mdmId != ''">and mdm_id = #{mdmId}</if>
<if test="mdmDataId != null and mdmDataId != ''">and mdm_data_id = #{mdmDataId}</if>
<if test="name != null and name != ''">and name = #{name}</if>
<if test="def1 != null and def1 != ''">and def1 = #{def1}</if>
<if test="def2 != null and def2 != ''">and def2 = #{def2}</if>
<if test="def3 != null and def3 != ''">and def3 = #{def3}</if>
<if test="def4 != null and def4 != ''">and def4 = #{def4}</if>
<if test="def5 != null and def5 != ''">and def5 = #{def5}</if>
<if test="def6 != null and def6 != ''">and def6 = #{def6}</if>
<if test="def7 != null and def7 != ''">and def7 = #{def7}</if>
<if test="def8 != null and def8 != ''">and def8 = #{def8}</if>
<if test="def9 != null and def9 != ''">and def9 = #{def9}</if>
<if test="def10 != null and def10 != ''">and def10 = #{def10}</if>
<if test="create_time != null">and create_time = #{create_time}</if>
<if test="createUser != null and createUser != ''">and create_user = #{createUser}</if>
<if test="modify_time != null">and modify_time = #{modify_time}</if>
<if test="modifyUser != null and modifyUser != ''">and modify_user = #{modifyUser}</if>
<if test="sts != null and sts != ''">and sts = #{sts}</if>
and sts='Y'
</trim>
</select>
<!-- 查询符合条件的数量 -->
<select id="entity_count" resultType="Integer"
parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
select count(1) from fe_conf_file_eigen
<trim prefix="where" prefixOverrides="and">
<if test="id != null">and id = #{id}</if>
<if test="mdmId != null and mdmId != ''">and mdm_id = #{mdmId}</if>
<if test="mdmDataId != null and mdmDataId != ''">and mdm_data_id = #{mdmDataId}</if>
<if test="name != null and name != ''">and name = #{name}</if>
<if test="def1 != null and def1 != ''">and def1 = #{def1}</if>
<if test="def2 != null and def2 != ''">and def2 = #{def2}</if>
<if test="def3 != null and def3 != ''">and def3 = #{def3}</if>
<if test="def4 != null and def4 != ''">and def4 = #{def4}</if>
<if test="def5 != null and def5 != ''">and def5 = #{def5}</if>
<if test="def6 != null and def6 != ''">and def6 = #{def6}</if>
<if test="def7 != null and def7 != ''">and def7 = #{def7}</if>
<if test="def8 != null and def8 != ''">and def8 = #{def8}</if>
<if test="def9 != null and def9 != ''">and def9 = #{def9}</if>
<if test="def10 != null and def10 != ''">and def10 = #{def10}</if>
<if test="create_time != null">and create_time = #{create_time}</if>
<if test="createUser != null and createUser != ''">and create_user = #{createUser}</if>
<if test="modify_time != null">and modify_time = #{modify_time}</if>
<if test="modifyUser != null and modifyUser != ''">and modify_user = #{modifyUser}</if>
<if test="sts != null and sts != ''">and sts = #{sts}</if>
and sts='Y'
</trim>
</select>
<!-- 分页查询列表 采用like格式 -->
<select id="entity_list_like" resultMap="get-FeConfFileEigenEntity-result"
parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
select
<include refid="FeConfFileEigenEntity_Base_Column_List"/>
from fe_conf_file_eigen
<trim prefix="where" prefixOverrides="and">
<if test="id != null">and id like concat('%',#{id},'%')</if>
<if test="mdmId != null and mdmId != ''">and mdm_id like concat('%',#{mdmId},'%')</if>
<if test="mdmDataId != null and mdmDataId != ''">and mdm_data_id like concat('%',#{mdmDataId},'%')</if>
<if test="name != null and name != ''">and name like concat('%',#{name},'%')</if>
<if test="def1 != null and def1 != ''">and def1 like concat('%',#{def1},'%')</if>
<if test="def2 != null and def2 != ''">and def2 like concat('%',#{def2},'%')</if>
<if test="def3 != null and def3 != ''">and def3 like concat('%',#{def3},'%')</if>
<if test="def4 != null and def4 != ''">and def4 like concat('%',#{def4},'%')</if>
<if test="def5 != null and def5 != ''">and def5 like concat('%',#{def5},'%')</if>
<if test="def6 != null and def6 != ''">and def6 like concat('%',#{def6},'%')</if>
<if test="def7 != null and def7 != ''">and def7 like concat('%',#{def7},'%')</if>
<if test="def8 != null and def8 != ''">and def8 like concat('%',#{def8},'%')</if>
<if test="def9 != null and def9 != ''">and def9 like concat('%',#{def9},'%')</if>
<if test="def10 != null and def10 != ''">and def10 like concat('%',#{def10},'%')</if>
<if test="create_time != null">and create_time like concat('%',#{create_time},'%')</if>
<if test="createUser != null and createUser != ''">and create_user like concat('%',#{createUser},'%')</if>
<if test="modify_time != null">and modify_time like concat('%',#{modify_time},'%')</if>
<if test="modifyUser != null and modifyUser != ''">and modify_user like concat('%',#{modifyUser},'%')</if>
<if test="sts != null and sts != ''">and sts like concat('%',#{sts},'%')</if>
and sts='Y'
</trim>
</select>
<!-- 查询列表 字段采用or格式 -->
<select id="FeConfFileEigenentity_list_or" resultMap="get-FeConfFileEigenEntity-result"
parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
select
<include refid="FeConfFileEigenEntity_Base_Column_List"/>
from fe_conf_file_eigen
<trim prefix="where" prefixOverrides="and">
<if test="id != null">or id = #{id}</if>
<if test="mdmId != null and mdmId != ''">or mdm_id = #{mdmId}</if>
<if test="mdmDataId != null and mdmDataId != ''">or mdm_data_id = #{mdmDataId}</if>
<if test="name != null and name != ''">or name = #{name}</if>
<if test="def1 != null and def1 != ''">or def1 = #{def1}</if>
<if test="def2 != null and def2 != ''">or def2 = #{def2}</if>
<if test="def3 != null and def3 != ''">or def3 = #{def3}</if>
<if test="def4 != null and def4 != ''">or def4 = #{def4}</if>
<if test="def5 != null and def5 != ''">or def5 = #{def5}</if>
<if test="def6 != null and def6 != ''">or def6 = #{def6}</if>
<if test="def7 != null and def7 != ''">or def7 = #{def7}</if>
<if test="def8 != null and def8 != ''">or def8 = #{def8}</if>
<if test="def9 != null and def9 != ''">or def9 = #{def9}</if>
<if test="def10 != null and def10 != ''">or def10 = #{def10}</if>
<if test="create_time != null">or create_time = #{create_time}</if>
<if test="createUser != null and createUser != ''">or create_user = #{createUser}</if>
<if test="modify_time != null">or modify_time = #{modify_time}</if>
<if test="modifyUser != null and modifyUser != ''">or modify_user = #{modifyUser}</if>
<if test="sts != null and sts != ''">or sts = #{sts}</if>
and sts='Y'
</trim>
</select>
<!--新增所有列-->
<insert id="entity_insert" parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity"
keyProperty="id" useGeneratedKeys="true">
insert into fe_conf_file_eigen(
<trim suffix="" suffixOverrides=",">
<if test="id != null">id ,</if>
<if test="mdmId != null and mdmId != ''">mdm_id ,</if>
<if test="mdmDataId != null and mdmDataId != ''">mdm_data_id ,</if>
<if test="name != null and name != ''">name ,</if>
<if test="def1 != null and def1 != ''">def1 ,</if>
<if test="def2 != null and def2 != ''">def2 ,</if>
<if test="def3 != null and def3 != ''">def3 ,</if>
<if test="def4 != null and def4 != ''">def4 ,</if>
<if test="def5 != null and def5 != ''">def5 ,</if>
<if test="def6 != null and def6 != ''">def6 ,</if>
<if test="def7 != null and def7 != ''">def7 ,</if>
<if test="def8 != null and def8 != ''">def8 ,</if>
<if test="def9 != null and def9 != ''">def9 ,</if>
<if test="def10 != null and def10 != ''">def10 ,</if>
<if test="create_time != null">create_time ,</if>
<if test="create_time == null">create_time ,</if>
<if test="createUser != null and createUser != ''">create_user ,</if>
<if test="modify_time != null">modify_time ,</if>
<if test="modify_time == null">modify_time ,</if>
<if test="modifyUser != null and modifyUser != ''">modify_user ,</if>
<if test="sts != null and sts != ''">sts ,</if>
<if test="sts == null ">sts,</if>
</trim>
)values(
<trim suffix="" suffixOverrides=",">
<if test="id != null">#{id} ,</if>
<if test="mdmId != null and mdmId != ''">#{mdmId} ,</if>
<if test="mdmDataId != null and mdmDataId != ''">#{mdmDataId} ,</if>
<if test="name != null and name != ''">#{name} ,</if>
<if test="def1 != null and def1 != ''">#{def1} ,</if>
<if test="def2 != null and def2 != ''">#{def2} ,</if>
<if test="def3 != null and def3 != ''">#{def3} ,</if>
<if test="def4 != null and def4 != ''">#{def4} ,</if>
<if test="def5 != null and def5 != ''">#{def5} ,</if>
<if test="def6 != null and def6 != ''">#{def6} ,</if>
<if test="def7 != null and def7 != ''">#{def7} ,</if>
<if test="def8 != null and def8 != ''">#{def8} ,</if>
<if test="def9 != null and def9 != ''">#{def9} ,</if>
<if test="def10 != null and def10 != ''">#{def10} ,</if>
<if test="create_time != null">#{create_time} ,</if>
<if test="create_time == null">now() ,</if>
<if test="createUser != null and createUser != ''">#{createUser} ,</if>
<if test="modify_time != null">#{modify_time} ,</if>
<if test="modify_time == null">now() ,</if>
<if test="modifyUser != null and modifyUser != ''">#{modifyUser} ,</if>
<if test="sts != null and sts != ''">#{sts} ,</if>
<if test="sts == null ">'Y',</if>
</trim>
)
</insert>
<!-- 批量新增 -->
<insert id="entityInsertBatch" keyProperty="id" useGeneratedKeys="true">
insert into fe_conf_file_eigen(mdm_id, mdm_data_id, name, def1, def2, def3, def4, def5, def6, def7, def8, def9,
def10, create_time, create_user, modify_time, modify_user, sts, sts)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.mdmId},#{entity.mdmDataId},#{entity.name},#{entity.def1},#{entity.def2},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.def10},#{entity.create_time},#{entity.createUser},#{entity.modify_time},#{entity.modifyUser},#{entity.sts},
'Y')
</foreach>
</insert>
<!-- 批量新增或者修改-->
<insert id="entityInsertOrUpdateBatch" keyProperty="id" useGeneratedKeys="true">
insert into fe_conf_file_eigen(mdm_id, mdm_data_id, name, def1, def2, def3, def4, def5, def6, def7, def8, def9,
def10, create_time, create_user, modify_time, modify_user, sts)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.mdmId},#{entity.mdmDataId},#{entity.name},#{entity.def1},#{entity.def2},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.def10},#{entity.create_time},#{entity.createUser},#{entity.modify_time},#{entity.modifyUser},#{entity.sts})
</foreach>
on duplicate key update
mdm_id = values(mdm_id),
mdm_data_id = values(mdm_data_id),
name = values(name),
def1 = values(def1),
def2 = values(def2),
def3 = values(def3),
def4 = values(def4),
def5 = values(def5),
def6 = values(def6),
def7 = values(def7),
def8 = values(def8),
def9 = values(def9),
def10 = values(def10),
create_time = values(create_time),
create_user = values(create_user),
modify_time = values(modify_time),
modify_user = values(modify_user),
sts = values(sts)
</insert>
<!--通过主键修改方法-->
<update id="entity_update" parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
update fe_conf_file_eigen set
<trim suffix="" suffixOverrides=",">
<if test="mdmId != null and mdmId != ''">mdm_id = #{mdmId},</if>
<if test="mdmDataId != null and mdmDataId != ''">mdm_data_id = #{mdmDataId},</if>
<if test="name != null and name != ''">name = #{name},</if>
<if test="def1 != null and def1 != ''">def1 = #{def1},</if>
<if test="def2 != null and def2 != ''">def2 = #{def2},</if>
<if test="def3 != null and def3 != ''">def3 = #{def3},</if>
<if test="def4 != null and def4 != ''">def4 = #{def4},</if>
<if test="def5 != null and def5 != ''">def5 = #{def5},</if>
<if test="def6 != null and def6 != ''">def6 = #{def6},</if>
<if test="def7 != null and def7 != ''">def7 = #{def7},</if>
<if test="def8 != null and def8 != ''">def8 = #{def8},</if>
<if test="def9 != null and def9 != ''">def9 = #{def9},</if>
<if test="def10 != null and def10 != ''">def10 = #{def10},</if>
<if test="modify_time != null">modify_time = #{modify_time},</if>
<if test="modify_time == null">modify_time = now(),</if>
<if test="modifyUser != null and modifyUser != ''">modify_user = #{modifyUser},</if>
<if test="sts != null and sts != ''">sts = #{sts},</if>
</trim>
where id = #{id}
</update>
<!-- 逻辑删除 -->
<update id="entity_logicDelete" parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
update fe_conf_file_eigen
set sts= 'N',
modify_time = now()
where id = #{id}
</update>
<!-- 多条件逻辑删除 -->
<update id="entity_logicDelete_Multi_Condition"
parameterType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
update fe_conf_file_eigen set sts= 'N' ,modify_time = now()
<trim prefix="where" prefixOverrides="and">
<if test="id != null">and id = #{id}</if>
<if test="mdmId != null and mdmId != ''">and mdm_id = #{mdmId}</if>
<if test="mdmDataId != null and mdmDataId != ''">and mdm_data_id = #{mdmDataId}</if>
<if test="name != null and name != ''">and name = #{name}</if>
<if test="def1 != null and def1 != ''">and def1 = #{def1}</if>
<if test="def2 != null and def2 != ''">and def2 = #{def2}</if>
<if test="def3 != null and def3 != ''">and def3 = #{def3}</if>
<if test="def4 != null and def4 != ''">and def4 = #{def4}</if>
<if test="def5 != null and def5 != ''">and def5 = #{def5}</if>
<if test="def6 != null and def6 != ''">and def6 = #{def6}</if>
<if test="def7 != null and def7 != ''">and def7 = #{def7}</if>
<if test="def8 != null and def8 != ''">and def8 = #{def8}</if>
<if test="def9 != null and def9 != ''">and def9 = #{def9}</if>
<if test="def10 != null and def10 != ''">and def10 = #{def10}</if>
<if test="createUser != null and createUser != ''">and create_user = #{createUser}</if>
<if test="modifyUser != null and modifyUser != ''">and modify_user = #{modifyUser}</if>
<if test="sts != null and sts != ''">and sts = #{sts}</if>
and sts='Y'
</trim>
</update>
<!--通过主键删除-->
<delete id="entity_delete">
delete
from fe_conf_file_eigen
where id = #{id}
</delete>
<select id="queryMdmAll" resultType="com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity">
SELECT DISTINCT
fe_conf_file_eigen.mdm_id,
mdm_module.mdm_code,
mdm_module.mdm_name
FROM
fe_conf_file_eigen
LEFT JOIN mdm_module ON mdm_module.id = fe_conf_file_eigen.mdm_id COLLATE utf8mb4_general_ci
WHERE
fe_conf_file_eigen.sts = 'Y'
</select>
</mapper>

29
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/IFeConfFileEigenService.java Normal file
View File

@ -0,0 +1,29 @@
package com.hzya.frame.finance.conf.fileeigen.service;
import com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity;
import com.hzya.frame.basedao.service.IBaseService;
import java.util.List;
import java.util.Map;
/**
* 财资事项(finance_event)-配置-档案特征(FeConfFileEigen)表服务接口
*
* @author zydd
* @since 2025-08-19 15:12:04
*/
public interface IFeConfFileEigenService extends IBaseService<FeConfFileEigenEntity, String>{
List<FeConfFileEigenEntity> queryAll(FeConfFileEigenEntity entity);
String saveEntity(List<FeConfFileEigenEntity> entity);
String updateEntity(List<FeConfFileEigenEntity> list);
void deleteEntity(List<FeConfFileEigenEntity> list);
List<Map<String, Object>> queryDataMapByMdmId(FeConfFileEigenEntity entity);
List<FeConfFileEigenEntity> queryMdmAll(FeConfFileEigenEntity entity);
List<FeConfFileEigenEntity> autoExecute(FeConfFileEigenEntity entity);
}

287
base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/impl/FeConfFileEigenServiceImpl.java Normal file
View File

@ -0,0 +1,287 @@
package com.hzya.frame.finance.conf.fileeigen.service.impl;
import cn.hutool.core.lang.Assert;
import com.hzya.frame.finance.conf.fileeigen.entity.FeConfFileEigenEntity;
import com.hzya.frame.finance.conf.fileeigen.dao.IFeConfFileEigenDao;
import com.hzya.frame.finance.conf.fileeigen.service.IFeConfFileEigenService;
import com.hzya.frame.mdm.mdmModule.dao.IMdmModuleDao;
import com.hzya.frame.mdm.mdmModule.entity.MdmModuleEntity;
import com.hzya.frame.mdm.mdmModuleDb.dao.IMdmModuleDbDao;
import com.hzya.frame.mdm.mdmModuleDb.entity.MdmModuleDbEntity;
import com.hzya.frame.voucher.ae.comf.bd.dao.IMdmDBQueryVODAO;
import com.hzya.frame.voucher.ae.comf.bd.dao.IMdmDbFiledVODAO;
import com.hzya.frame.voucher.ae.comf.bd.entity.vo.MdmDBQueryVO;
import com.hzya.frame.voucher.ae.comf.bd.entity.vo.MdmDbFiledVO;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import javax.annotation.Resource;
import com.hzya.frame.basedao.service.impl.BaseService;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* 财资事项(finance_event)-配置-档案特征(FeConfFileEigen)表服务实现类
*
* @author zydd
* @since 2025-08-19 15:12:04
*/
@Service
public class FeConfFileEigenServiceImpl extends BaseService<FeConfFileEigenEntity, String> implements IFeConfFileEigenService {
private IFeConfFileEigenDao feConfFileEigenDao;
@Autowired
public void setFeConfFileEigenDao(IFeConfFileEigenDao dao) {
this.feConfFileEigenDao = dao;
this.dao = dao;
}
@Autowired
private IMdmModuleDao mdmModuleDao;
@Autowired
private IMdmModuleDbDao mdmModuleDbDao;
@Autowired
private IMdmDBQueryVODAO mdmDBQueryVODAO;
@Autowired
private IMdmDbFiledVODAO mdmDbFiledVODAO;
@Override
public List<FeConfFileEigenEntity> queryAll(FeConfFileEigenEntity entity) {
checkAssistNull("queryAll", entity);
List<FeConfFileEigenEntity> query = feConfFileEigenDao.query(entity);
return query;
}
@Override
public String saveEntity(List<FeConfFileEigenEntity> list) {
StringBuffer cg = new StringBuffer();
StringBuffer sb = new StringBuffer();
int i = 0;
int j = 0;
for (FeConfFileEigenEntity feConfFileEigenEntity : list) {
try {
checkAssistNull("saveEntity", feConfFileEigenEntity);
FeConfFileEigenEntity feConfFileEigenEntity1 = new FeConfFileEigenEntity();
feConfFileEigenEntity1.setName(feConfFileEigenEntity.getName());
List<FeConfFileEigenEntity> query = feConfFileEigenDao.query(feConfFileEigenEntity1);
if (query.size() != 0) {
Assert.state(false, "特征值:[{}],重复", feConfFileEigenEntity.getName());
}
FeConfFileEigenEntity save = feConfFileEigenDao.save(feConfFileEigenEntity);
i++;
cg.append(save.getName()).append(";");
} catch (Exception e) {
e.printStackTrace();
j++;
sb.append(e.getMessage()).append(";");
}
}
if (i == 0 && j != 0) {
return "失败：" + j + "条:" + sb;
}
if (i != 0 && j == 0) {
return "成功：" + i + "条：" + cg + "。";
}
return "成功：" + i + "条：" + cg + "。失败：" + j + "条:" + sb;
}
@Override
public String updateEntity(List<FeConfFileEigenEntity> list) {
StringBuffer cg = new StringBuffer();
StringBuffer sb = new StringBuffer();
int i = 0;
int j = 0;
for (FeConfFileEigenEntity feConfFileEigenEntity : list) {
try {
if (feConfFileEigenEntity.getId() == null) {
checkAssistNull("saveEntity", feConfFileEigenEntity);
FeConfFileEigenEntity feConfFileEigenEntity1 = new FeConfFileEigenEntity();
feConfFileEigenEntity1.setName(feConfFileEigenEntity.getName());
List<FeConfFileEigenEntity> query = feConfFileEigenDao.query(feConfFileEigenEntity1);
if (query.size() != 0) {
Assert.state(false, "特征值:[{}],重复", feConfFileEigenEntity.getName());
}
feConfFileEigenDao.save(feConfFileEigenEntity);
i++;
cg.append(feConfFileEigenEntity.getName()).append(";");
}
FeConfFileEigenEntity feConfFileEigenEntity1 = new FeConfFileEigenEntity();
feConfFileEigenEntity1.setName(feConfFileEigenEntity.getName());
List<FeConfFileEigenEntity> query = feConfFileEigenDao.query(feConfFileEigenEntity1);
if (query.size() != 0) {
Assert.state(false, "特征值:[{}],重复", feConfFileEigenEntity.getName());
}
feConfFileEigenDao.update(feConfFileEigenEntity);
i++;
cg.append(feConfFileEigenEntity.getName()).append(";");
} catch (Exception e) {
e.printStackTrace();
j++;
sb.append(e.getMessage()).append(";");
}
}
if (i == 0 && j != 0) {
return "失败：" + j + "条:" + sb;
}
if (i != 0 && j == 0) {
return "成功：" + i + "条：" + cg + "。";
}
return "成功：" + i + "条：" + cg + "。失败：" + j + "条:" + sb;
}
@Override
public void deleteEntity(List<FeConfFileEigenEntity> list) {
for (FeConfFileEigenEntity feConfFileEigenEntity : list) {
checkAssistNull("deleteEntity", feConfFileEigenEntity);
feConfFileEigenDao.logicRemove(feConfFileEigenEntity);
}
}
@Override
public List<FeConfFileEigenEntity> queryMdmAll(FeConfFileEigenEntity entity) {
List<FeConfFileEigenEntity> queryMdmAll = feConfFileEigenDao.queryMdmAll(entity);
return queryMdmAll;
}
@Override
public List<FeConfFileEigenEntity> autoExecute(FeConfFileEigenEntity entity) {
checkAssistNull("autoExecute", entity);
String mdmId = entity.getMdmId();
MdmDbFiledVO mdmDbFiledVO = new MdmDbFiledVO();
mdmDbFiledVO.setMdmId(mdmId);
List<MdmDbFiledVO> mdmDbFiledVOList = mdmDbFiledVODAO.queryMdmDbFiledVOByMdmID(mdmDbFiledVO);
if(mdmDbFiledVOList==null||mdmDbFiledVOList.size()==0){
Assert.state(false,"根据mdmId：{}，查询字段明细失败",mdmId);
}
MdmDbFiledVO mdmDbFiled = mdmDbFiledVOList.get(0);
String fieldName = mdmDbFiled.getNamefieldname();
if(fieldName==null){
Assert.state(false,"根据mdmId：{}，查询名称字段明细失败。",mdmId);
}
List<FeConfFileEigenEntity> all = new ArrayList<>();
int i=0;
List<Map<String, Object>> maps = queryDataByMdmId(mdmId);
for (Map<String, Object> map : maps) {
Object OId = map.get("id");
Object OName = map.get(fieldName);
if(OName==null){
continue;
}
if(OId==null){
continue;
}
String stringName = OName.toString();
String stringId = OId.toString();
// String[] split = stringName.split("有限公司");
String[] split = stringName.split(entity.getSplitName());
String s = split[0];
FeConfFileEigenEntity feConfFileEigenEntity = new FeConfFileEigenEntity();
feConfFileEigenEntity.setName(s);
List<FeConfFileEigenEntity> query = feConfFileEigenDao.query(feConfFileEigenEntity);
if (query.size() != 0) {
continue;
}
feConfFileEigenEntity.setMdmId(mdmId);
feConfFileEigenEntity.setMdmDataId(stringId);
feConfFileEigenDao.save(feConfFileEigenEntity);
i++;
}
System.out.println("===========================>"+i);
return all;
}
@Override
public List<Map<String, Object>> queryDataMapByMdmId(FeConfFileEigenEntity entity) {
checkAssistNull("queryDataMapByMdmId", entity);
String mdmId = entity.getMdmId();
List<Map<String, Object>> maps = queryDataByMdmId(mdmId);
if(maps==null){
Assert.state(false,"查询数据失败。queryDataMapByMdmId请检查");
}
return maps;
}
public void checkAssistNull(String type, FeConfFileEigenEntity entity) {
switch (type) {
case "queryAll":
Assert.notNull(entity.getMdmId(), "查询档案特征时，mdmId不能为空");
Assert.notNull(entity.getMdmDataId(), "查询档案特征时，mdmDataId不能为空");
break;
case "saveEntity":
Assert.notNull(entity.getMdmId(), "新增档案特征时，mdmId不能为空");
Assert.notNull(entity.getMdmDataId(), "新增档案特征时，mdmDataId不能为空");
Assert.notNull(entity.getName(), "新增档案特征时，name不能为空");
break;
case "deleteEntity":
Assert.notNull(entity.getId(), "删除档案特征时，id不能为空");
break;
case "queryDataMapByMdmId":
Assert.notNull(entity.getMdmId(), "查询档案数据时，mdmId不能为空");
break;
case "autoExecute":
Assert.notNull(entity.getMdmId(), "自动生成时，mdmId不能为空");
Assert.notNull(entity.getSplitName(), "自动生成时，splitName不能为空");
break;
}
}
/**
* 根据mdmId查询数据
*/
public List<Map<String, Object>> queryDataByMdmId(String mdmId){
try {
MdmModuleDbEntity mdmModuleDbEntity = new MdmModuleDbEntity();
mdmModuleDbEntity.setMdmId(mdmId);
mdmModuleDbEntity.setDbType("1");
List<MdmModuleDbEntity> mdmModuleEntityDbList = mdmModuleDbDao.query(mdmModuleDbEntity);
if (mdmModuleEntityDbList.size() == 0 || mdmModuleEntityDbList.size() > 1) {
Assert.state(false, "根据mdmId：{}，未查询到数据表或数据表不唯一。");
}
MdmModuleDbEntity mdmModuleDb = mdmModuleEntityDbList.get(0);
String dbName = mdmModuleDb.getDbName();
//查询数据
MdmDBQueryVO mdmDBQueryVO = new MdmDBQueryVO();
mdmDBQueryVO.setTablename(dbName);
List<Map<String, Object>> dataMapList = mdmDBQueryVODAO.queryMdmDb(mdmDBQueryVO);
return dataMapList;
}catch (Exception e){
Assert.state(false, "查询数据失败。失败原因：{}", e.getMessage());
}
return null;
}
}

19
base-buildpackage/src/main/java/com/hzya/frame/finance/utils/Attribute.java Normal file
View File

@ -0,0 +1,19 @@
package com.hzya.frame.finance.utils;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* U8C返回参数
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Attribute {
private String status;
private String taskNumber;
private String data;
private String errorcode;
private String errormsg;
}

18
base-buildpackage/src/main/java/com/hzya/frame/finance/utils/ZTResult.java Normal file
View File

@ -0,0 +1,18 @@
package com.hzya.frame.finance.utils;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ZTResult {
private String msg;
private String type;
private String flag;
private String status;
private Attribute attribute;
private String headMsg;
}

24
base-buildpackage/src/main/java/com/hzya/frame/plugin/coco/constant/ProfilesActiveConstant.java Normal file
View File

@ -0,0 +1,24 @@
package com.hzya.frame.plugin.coco.constant;
public class ProfilesActiveConstant {
public static final String COCO_DATE_SOURCE = "coco_bip_prod";
public static final String COCO_PROFILES_ACTIVE = "prod";
public static final String LOG_STATUS_Y = "Y";
public static final String LOG_STATUS_N = "N";
public static final String LOG_STATUS_Y_H = "'Y','H'";
public static final String TYPE_DATE = "date";
public static final String TYPE_VBILLCODE = "vbillcode";
public static final String TYPE_DETAIL_ERROR = "details_error";
public static final String TYPE_TIME_FRAME = "time_frame";
}

1
base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/IMdmDbFiledVODAO.java
View File

@ -11,4 +11,5 @@ import java.util.Map;
*/ */
public interface IMdmDbFiledVODAO extends IBaseDao<MdmDbFiledVO, String> { public interface IMdmDbFiledVODAO extends IBaseDao<MdmDbFiledVO, String> {
public List<MdmDbFiledVO> queryMdmDbFiledVO(MdmDbFiledVO vo); public List<MdmDbFiledVO> queryMdmDbFiledVO(MdmDbFiledVO vo);
public List<MdmDbFiledVO> queryMdmDbFiledVOByMdmID(MdmDbFiledVO vo);
} }

6
base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/impl/MdmDbFiledVODAOImpl.java
View File

@ -18,4 +18,10 @@ public class MdmDbFiledVODAOImpl extends MybatisGenericDao<MdmDbFiledVO, String>
List<MdmDbFiledVO> mdmDbFiledVOList = (List<MdmDbFiledVO>) selectList("com.hzya.frame.voucher.ae.comf.bd.dao.impl.MdmDbFiledVODAOImpl.queryMdmDbFiledVO", vo); List<MdmDbFiledVO> mdmDbFiledVOList = (List<MdmDbFiledVO>) selectList("com.hzya.frame.voucher.ae.comf.bd.dao.impl.MdmDbFiledVODAOImpl.queryMdmDbFiledVO", vo);
return mdmDbFiledVOList; return mdmDbFiledVOList;
} }
@Override
public List<MdmDbFiledVO> queryMdmDbFiledVOByMdmID(MdmDbFiledVO vo) {
List<MdmDbFiledVO> mdmDbFiledVOList = (List<MdmDbFiledVO>) selectList("com.hzya.frame.voucher.ae.comf.bd.dao.impl.MdmDbFiledVODAOImpl.queryMdmDbFiledVOByMdmID", vo);
return mdmDbFiledVOList;
}
} }

32
base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/entity/vo/MdmDbFiledVO.xml
View File

@ -57,5 +57,37 @@
AND db.db_type = '1' AND db.db_type = '1'
</select> </select>
<!-- 查询 采用==查询 -->
<select id="queryMdmDbFiledVOByMdmID" resultMap="get-MdmDbFiledVO-result"
parameterType="com.hzya.frame.voucher.ae.comf.bd.entity.vo.MdmDbFiledVO">
SELECT
mdm.id as mdmId,
mdm.mdm_code as mdmCode,
mdm.mdm_name as mdmName,
db.id as dbId,
db.db_name as tablename,
db.remark as dbName,
fileds.sys_pk as tablepkname,
fileds.sys_code AS codefieldname,
fileds.sys_name AS namefieldname,
fileds.sys_date AS datefieldname
FROM
mdm_module mdm
LEFT JOIN mdm_module_db db ON db.mdm_id = mdm.id
LEFT JOIN (SELECT db_id,
MAX(CASE WHEN sys_pk = 'Y' THEN en_name ELSE NULL END) AS sys_pk,
MAX(CASE WHEN sys_code = 'Y' THEN en_name ELSE NULL END) AS sys_code,
MAX(CASE WHEN sys_name = 'Y' THEN en_name ELSE NULL END) AS sys_name,
MAX(CASE WHEN sys_date = 'Y' THEN en_name ELSE NULL END) AS sys_date
FROM mdm_module_db_fileds
GROUP BY db_id) fileds ON fileds.db_id = db.id
WHERE
1=1
<if test="mdmId != null and mdmId != ''">and mdm.id = #{mdmId}</if>
AND mdm.sts = 'Y'
AND db.db_type = '1'
</select>
</mapper> </mapper>

6
base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/subject/service/impl/AeConfSubjectContrastServiceImpl.java
View File

@ -46,7 +46,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService<AeConfSubjectC
@Override @Override
public List<AeConfSubjectContrastEntity> queryAll(AeConfSubjectContrastEntity entity) { public List<AeConfSubjectContrastEntity> queryAll(AeConfSubjectContrastEntity entity) {
Assert.notNull(entity.getPkCorp(), "查询全部对照表时，公司id不能为空！");
List<AeConfSubjectContrastEntity> aeConfSubjectContrastEntityList = aeConfSubjectContrastDao.query(entity); List<AeConfSubjectContrastEntity> aeConfSubjectContrastEntityList = aeConfSubjectContrastDao.query(entity);
//查询子表 //查询子表
for (AeConfSubjectContrastEntity confSubjectContrastEntity : aeConfSubjectContrastEntityList) { for (AeConfSubjectContrastEntity confSubjectContrastEntity : aeConfSubjectContrastEntityList) {
@ -63,7 +62,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService<AeConfSubjectC
@Override @Override
public AeConfSubjectContrastEntity queryById(AeConfSubjectContrastEntity entity) { public AeConfSubjectContrastEntity queryById(AeConfSubjectContrastEntity entity) {
Assert.notNull(entity.getPkCorp(), "根据id查询科目对照时，公司id不能为空！");
Assert.notNull(entity.getId(), "根据id查询科目对照时，科目对照表id不能为空"); Assert.notNull(entity.getId(), "根据id查询科目对照时，科目对照表id不能为空");
List<AeConfSubjectContrastEntity> aeConfSubjectContrastEntityList = aeConfSubjectContrastDao.query(entity); List<AeConfSubjectContrastEntity> aeConfSubjectContrastEntityList = aeConfSubjectContrastDao.query(entity);
if (aeConfSubjectContrastEntityList.size() == 0) { if (aeConfSubjectContrastEntityList.size() == 0) {
@ -88,7 +86,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService<AeConfSubjectC
@Override @Override
public AeConfSubjectContrastEntity saveEntity(AeConfSubjectContrastEntity entity) throws NoSuchFieldException, IllegalAccessException { public AeConfSubjectContrastEntity saveEntity(AeConfSubjectContrastEntity entity) throws NoSuchFieldException, IllegalAccessException {
//校验主表 //校验主表
Assert.notNull(entity.getPkCorp(), "科目对照表新增时，公司id不能为空！");
Assert.notNull(entity.getCode(), "科目对照表新增时，code不能为空！"); Assert.notNull(entity.getCode(), "科目对照表新增时，code不能为空！");
Assert.notNull(entity.getName(), "科目对照表新增时，name不能为空！"); Assert.notNull(entity.getName(), "科目对照表新增时，name不能为空！");
Assert.notNull(entity.getAccountBookTypeId(), "科目对照表新增时，账簿类型id不能为空！"); Assert.notNull(entity.getAccountBookTypeId(), "科目对照表新增时，账簿类型id不能为空！");
@ -123,7 +120,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService<AeConfSubjectC
//保存主表 //保存主表
AeConfSubjectContrastEntity saveH = aeConfSubjectContrastDao.save(entity); AeConfSubjectContrastEntity saveH = aeConfSubjectContrastDao.save(entity);
String Hid = saveH.getId(); String Hid = saveH.getId();
String HpkCorp = saveH.getPkCorp();
if (contrastBList == null || contrastBList.size() == 0) { if (contrastBList == null || contrastBList.size() == 0) {
return saveH; return saveH;
@ -132,7 +128,7 @@ public class AeConfSubjectContrastServiceImpl extends BaseService<AeConfSubjectC
//保存子表 //保存子表
for (AeConfSubjectContrastBEntity aeConfSubjectContrastBEntity : contrastBList) { for (AeConfSubjectContrastBEntity aeConfSubjectContrastBEntity : contrastBList) {
aeConfSubjectContrastBEntity.setContrastId(Long.valueOf(Hid)); aeConfSubjectContrastBEntity.setContrastId(Long.valueOf(Hid));
aeConfSubjectContrastBEntity.setPkCorp(HpkCorp); // aeConfSubjectContrastBEntity.setPkCorp(HpkCorp);
aeConfSubjectContrastBDao.save(aeConfSubjectContrastBEntity); aeConfSubjectContrastBDao.save(aeConfSubjectContrastBEntity);
} }
return saveH; return saveH;