diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/bd/BdController.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/bd/BdController.java new file mode 100644 index 00000000..3a3b06f8 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/bd/BdController.java @@ -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 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 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 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 all = aeConfBdAccsubjDao.query(entity); + //辅助核算 + for (AeConfBdAccsubjEntity aeConfBdAccsubjEntity : all) { + List assists = aeConfBdAccsubjDao.queryAssist(aeConfBdAccsubjEntity); + List codes = Optional.ofNullable(assists).orElse(Collections.emptyList()).stream() + .map(AeConfBdAccsubjEntity::getBdcode) + .filter(s -> s != null && !s.isEmpty()) + .collect(Collectors.toList()); + + List 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 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 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> 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 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> 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 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> 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 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 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 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 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 all = new ArrayList<>(); + //查询所有关联 + List list = mdmDBQueryVODAO.queryBdInfoBySubjass(entity); + //查询现有的档案 + List 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 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 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()); +// } +// } +} + + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/controller/FileEigenController.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/controller/FileEigenController.java new file mode 100644 index 00000000..cf07a9aa --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/controller/FileEigenController.java @@ -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 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 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 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 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 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> 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 autoExecute = fileEigenService.autoExecute(entity); + return getSuccessMessageEntity("请求成功", autoExecute); + } catch (Exception e) { + e.printStackTrace(); + return getFailureMessageEntity(e.getMessage()); + } + } + + +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/IFeConfFileEigenDao.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/IFeConfFileEigenDao.java new file mode 100644 index 00000000..55e6a066 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/IFeConfFileEigenDao.java @@ -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 { + + List queryMdmAll(FeConfFileEigenEntity entity); +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/impl/FeConfFileEigenDaoImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/impl/FeConfFileEigenDaoImpl.java new file mode 100644 index 00000000..ab0d2450 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/dao/impl/FeConfFileEigenDaoImpl.java @@ -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 implements IFeConfFileEigenDao{ + + @Override + public List queryMdmAll(FeConfFileEigenEntity entity) { + List queryMdmAll = (List)selectList("com.hzya.frame.finance.conf.fileeigen.dao.impl.FeConfFileEigenDaoImpl.queryMdmAll", entity); + return queryMdmAll; + } +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.java new file mode 100644 index 00000000..42c821a6 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.java @@ -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; + } + +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.xml b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.xml new file mode 100644 index 00000000..ca4e18b9 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/entity/FeConfFileEigenEntity.xml @@ -0,0 +1,338 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 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 + + + + + + + + + + + + + + + + insert into fe_conf_file_eigen( + + id , + mdm_id , + mdm_data_id , + name , + def1 , + def2 , + def3 , + def4 , + def5 , + def6 , + def7 , + def8 , + def9 , + def10 , + create_time , + create_time , + create_user , + modify_time , + modify_time , + modify_user , + sts , + sts, + + )values( + + #{id} , + #{mdmId} , + #{mdmDataId} , + #{name} , + #{def1} , + #{def2} , + #{def3} , + #{def4} , + #{def5} , + #{def6} , + #{def7} , + #{def8} , + #{def9} , + #{def10} , + #{create_time} , + now() , + #{createUser} , + #{modify_time} , + now() , + #{modifyUser} , + #{sts} , + 'Y', + + ) + + + + 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 + + (#{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') + + + + + 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 + + (#{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}) + + 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) + + + + update fe_conf_file_eigen set + + mdm_id = #{mdmId}, + mdm_data_id = #{mdmDataId}, + name = #{name}, + def1 = #{def1}, + def2 = #{def2}, + def3 = #{def3}, + def4 = #{def4}, + def5 = #{def5}, + def6 = #{def6}, + def7 = #{def7}, + def8 = #{def8}, + def9 = #{def9}, + def10 = #{def10}, + modify_time = #{modify_time}, + modify_time = now(), + modify_user = #{modifyUser}, + sts = #{sts}, + + where id = #{id} + + + + update fe_conf_file_eigen + set sts= 'N', + modify_time = now() + where id = #{id} + + + + update fe_conf_file_eigen set sts= 'N' ,modify_time = now() + + and id = #{id} + and mdm_id = #{mdmId} + and mdm_data_id = #{mdmDataId} + and name = #{name} + and def1 = #{def1} + and def2 = #{def2} + and def3 = #{def3} + and def4 = #{def4} + and def5 = #{def5} + and def6 = #{def6} + and def7 = #{def7} + and def8 = #{def8} + and def9 = #{def9} + and def10 = #{def10} + and create_user = #{createUser} + and modify_user = #{modifyUser} + and sts = #{sts} + and sts='Y' + + + + + delete + from fe_conf_file_eigen + where id = #{id} + + + + + + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/IFeConfFileEigenService.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/IFeConfFileEigenService.java new file mode 100644 index 00000000..b71e7796 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/IFeConfFileEigenService.java @@ -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{ + List queryAll(FeConfFileEigenEntity entity); + + String saveEntity(List entity); + + String updateEntity(List list); + + void deleteEntity(List list); + + List> queryDataMapByMdmId(FeConfFileEigenEntity entity); + + List queryMdmAll(FeConfFileEigenEntity entity); + + List autoExecute(FeConfFileEigenEntity entity); +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/impl/FeConfFileEigenServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/impl/FeConfFileEigenServiceImpl.java new file mode 100644 index 00000000..4427e335 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/fileeigen/service/impl/FeConfFileEigenServiceImpl.java @@ -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 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 queryAll(FeConfFileEigenEntity entity) { + checkAssistNull("queryAll", entity); + List query = feConfFileEigenDao.query(entity); + return query; + } + + @Override + public String saveEntity(List 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 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 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 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 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 list) { + for (FeConfFileEigenEntity feConfFileEigenEntity : list) { + checkAssistNull("deleteEntity", feConfFileEigenEntity); + feConfFileEigenDao.logicRemove(feConfFileEigenEntity); + } + } + + @Override + public List queryMdmAll(FeConfFileEigenEntity entity) { + List queryMdmAll = feConfFileEigenDao.queryMdmAll(entity); + return queryMdmAll; + } + + @Override + public List autoExecute(FeConfFileEigenEntity entity) { + checkAssistNull("autoExecute", entity); + String mdmId = entity.getMdmId(); + + MdmDbFiledVO mdmDbFiledVO = new MdmDbFiledVO(); + mdmDbFiledVO.setMdmId(mdmId); + List 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 all = new ArrayList<>(); + + int i=0; + List> maps = queryDataByMdmId(mdmId); + for (Map 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 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> queryDataMapByMdmId(FeConfFileEigenEntity entity) { + checkAssistNull("queryDataMapByMdmId", entity); + String mdmId = entity.getMdmId(); + List> 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> queryDataByMdmId(String mdmId){ + try { + MdmModuleDbEntity mdmModuleDbEntity = new MdmModuleDbEntity(); + mdmModuleDbEntity.setMdmId(mdmId); + mdmModuleDbEntity.setDbType("1"); + List 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> dataMapList = mdmDBQueryVODAO.queryMdmDb(mdmDBQueryVO); + return dataMapList; + }catch (Exception e){ + Assert.state(false, "查询数据失败。失败原因：{}", e.getMessage()); + } + return null; + } +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/utils/Attribute.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/utils/Attribute.java new file mode 100644 index 00000000..f701782a --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/utils/Attribute.java @@ -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; +} \ No newline at end of file diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/utils/ZTResult.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/utils/ZTResult.java new file mode 100644 index 00000000..ee4abeea --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/utils/ZTResult.java @@ -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; + +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/coco/constant/ProfilesActiveConstant.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/coco/constant/ProfilesActiveConstant.java new file mode 100644 index 00000000..6c3ea811 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/coco/constant/ProfilesActiveConstant.java @@ -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"; + + +} \ No newline at end of file diff --git a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/IMdmDbFiledVODAO.java b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/IMdmDbFiledVODAO.java index c182942d..db3226fd 100644 --- a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/IMdmDbFiledVODAO.java +++ b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/IMdmDbFiledVODAO.java @@ -11,4 +11,5 @@ import java.util.Map; */ public interface IMdmDbFiledVODAO extends IBaseDao { public List queryMdmDbFiledVO(MdmDbFiledVO vo); + public List queryMdmDbFiledVOByMdmID(MdmDbFiledVO vo); } diff --git a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/impl/MdmDbFiledVODAOImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/impl/MdmDbFiledVODAOImpl.java index 92ed42f6..2c79bb02 100644 --- a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/impl/MdmDbFiledVODAOImpl.java +++ b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/dao/impl/MdmDbFiledVODAOImpl.java @@ -18,4 +18,10 @@ public class MdmDbFiledVODAOImpl extends MybatisGenericDao List mdmDbFiledVOList = (List) selectList("com.hzya.frame.voucher.ae.comf.bd.dao.impl.MdmDbFiledVODAOImpl.queryMdmDbFiledVO", vo); return mdmDbFiledVOList; } + + @Override + public List queryMdmDbFiledVOByMdmID(MdmDbFiledVO vo) { + List mdmDbFiledVOList = (List) selectList("com.hzya.frame.voucher.ae.comf.bd.dao.impl.MdmDbFiledVODAOImpl.queryMdmDbFiledVOByMdmID", vo); + return mdmDbFiledVOList; + } } diff --git a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/entity/vo/MdmDbFiledVO.xml b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/entity/vo/MdmDbFiledVO.xml index d2cdb225..06a10cc2 100644 --- a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/entity/vo/MdmDbFiledVO.xml +++ b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/bd/entity/vo/MdmDbFiledVO.xml @@ -57,5 +57,37 @@ AND db.db_type = '1' + + + + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/subject/service/impl/AeConfSubjectContrastServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/subject/service/impl/AeConfSubjectContrastServiceImpl.java index 7fd26af6..3d8e9e15 100644 --- a/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/subject/service/impl/AeConfSubjectContrastServiceImpl.java +++ b/base-buildpackage/src/main/java/com/hzya/frame/voucher/ae/comf/subject/service/impl/AeConfSubjectContrastServiceImpl.java @@ -46,7 +46,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService queryAll(AeConfSubjectContrastEntity entity) { - Assert.notNull(entity.getPkCorp(), "查询全部对照表时，公司id不能为空！"); List aeConfSubjectContrastEntityList = aeConfSubjectContrastDao.query(entity); //查询子表 for (AeConfSubjectContrastEntity confSubjectContrastEntity : aeConfSubjectContrastEntityList) { @@ -63,7 +62,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService aeConfSubjectContrastEntityList = aeConfSubjectContrastDao.query(entity); if (aeConfSubjectContrastEntityList.size() == 0) { @@ -88,7 +86,6 @@ public class AeConfSubjectContrastServiceImpl extends BaseService