From cd161e7e893398c6be6235b241cd80d2e6c0ec4e Mon Sep 17 00:00:00 2001 From: lixinyu <2312963763@qq.com> Date: Sat, 30 Aug 2025 14:36:16 +0800 Subject: [PATCH] =?UTF-8?q?1.=E6=B6=88=E6=81=AF=E6=A8=A1=E6=9D=BF=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=202.=E9=80=9A=E7=9F=A5=E8=A7=84=E5=88=99=E9=85=8D?= =?UTF-8?q?=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../message/controller/MessageController.java | 98 ++++ .../dao/IFeConfMessageTemplateDao.java | 21 + .../impl/FeConfMessageTemplateDaoImpl.java | 39 ++ .../entity/FeConfMessageTemplateEntity.java | 207 +++++++ .../entity/FeConfMessageTemplateEntity.xml | 393 +++++++++++++ .../IFeConfMessageTemplateService.java | 23 + .../FeConfMessageTemplateServiceImpl.java | 94 +++ .../NotificationRulesController.java | 80 +++ .../dao/IFeConfNotificationRulesDao.java | 22 + .../impl/FeConfNotificationRulesDaoImpl.java | 39 ++ .../entity/FeConfNotificationRulesEntity.java | 326 +++++++++++ .../entity/FeConfNotificationRulesEntity.xml | 541 ++++++++++++++++++ .../IFeConfNotificationRulesService.java | 20 + .../FeConfNotificationRulesServiceImpl.java | 102 ++++ 14 files changed, 2005 insertions(+) create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/controller/MessageController.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/IFeConfMessageTemplateDao.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/impl/FeConfMessageTemplateDaoImpl.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.xml create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/IFeConfMessageTemplateService.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/impl/FeConfMessageTemplateServiceImpl.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/controller/NotificationRulesController.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/IFeConfNotificationRulesDao.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/impl/FeConfNotificationRulesDaoImpl.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.xml create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/IFeConfNotificationRulesService.java create mode 100644 base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/impl/FeConfNotificationRulesServiceImpl.java diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/controller/MessageController.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/controller/MessageController.java new file mode 100644 index 00000000..a1de9eae --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/controller/MessageController.java @@ -0,0 +1,98 @@ +package com.hzya.frame.finance.conf.message.controller; + +import com.github.pagehelper.PageInfo; +import com.hzya.frame.finance.conf.message.entity.FeConfMessageTemplateEntity; +import com.hzya.frame.finance.conf.message.service.IFeConfMessageTemplateService; +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; + +@RestController +@RequestMapping("/fe/conf/message") + +public class MessageController { + + @Autowired + private IFeConfMessageTemplateService iFeConfMessageTemplateService; + + /** + * 分页查询模板 + * + */ + @RequestMapping(value = "/queryPaged", method = RequestMethod.POST) + public JsonResultEntity query(@RequestBody FeConfMessageTemplateEntity feConfMessageTemplateEntity) { + PageInfo pageInfo = iFeConfMessageTemplateService.queryMessagePaged(feConfMessageTemplateEntity); + return new JsonResultEntity("查询成功",true,pageInfo); + } + /** + * 查询消息模板 + */ + @RequestMapping(value = "/queryAll", method = RequestMethod.POST) + public JsonResultEntity queryAll(@RequestBody FeConfMessageTemplateEntity feConfMessageTemplateEntity) { + List feConfMessageTemplateEntities = iFeConfMessageTemplateService.queryAll(feConfMessageTemplateEntity); + return new JsonResultEntity("查询成功",true,feConfMessageTemplateEntities); + } + + /** + * 新增消息模板 + */ + @RequestMapping(value = "/add", method = RequestMethod.POST) + public JsonResultEntity add(@RequestBody FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception { + if(feConfMessageTemplateEntity == null){ + throw new Exception("参数不能为空"); + } + if(feConfMessageTemplateEntity.getCode() == null){ + throw new Exception("编码不能为空"); + } + if(feConfMessageTemplateEntity.getName() == null){ + throw new Exception("名称不能为空"); + } + if(feConfMessageTemplateEntity.getTitle() == null){ + throw new Exception("标题不能为空"); + } + FeConfMessageTemplateEntity save = iFeConfMessageTemplateService.save(feConfMessageTemplateEntity); + return new JsonResultEntity("新增成功",true,save); + } + + /** + * 修改消息模板 + */ + @RequestMapping(value = "/update", method = RequestMethod.POST) + public JsonResultEntity update(@RequestBody FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception { + if(feConfMessageTemplateEntity == null){ + throw new Exception("参数不能为空"); + } + if(feConfMessageTemplateEntity.getSts().equals("N")){ + throw new Exception("该记录已删除"); + } + FeConfMessageTemplateEntity update = iFeConfMessageTemplateService.update(feConfMessageTemplateEntity); + return new JsonResultEntity("修改成功",true,update); + } + + /** + * 启用停用状态 + */ + @RequestMapping(value = "/updateStatus", method = RequestMethod.POST) + public JsonResultEntity updateStatus(@RequestBody FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception { + FeConfMessageTemplateEntity update = iFeConfMessageTemplateService.updateStatus(feConfMessageTemplateEntity); + + return new JsonResultEntity("修改成功",true,update); + } + + /** + * 删除消息模板 + */ + @RequestMapping(value = "/delete", method = RequestMethod.POST) + public JsonResultEntity delete(@RequestBody FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception { + if(feConfMessageTemplateEntity.getSts().equals("N")){ + throw new Exception("该记录已删除"); + } + iFeConfMessageTemplateService.logicRemove(feConfMessageTemplateEntity); + return new JsonResultEntity("删除成功",true,null); + } +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/IFeConfMessageTemplateDao.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/IFeConfMessageTemplateDao.java new file mode 100644 index 00000000..fe384b66 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/IFeConfMessageTemplateDao.java @@ -0,0 +1,21 @@ +package com.hzya.frame.finance.conf.message.dao; + +import com.hzya.frame.finance.conf.message.entity.FeConfMessageTemplateEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +import java.util.List; + +/** + * 消息模板表(fe_conf_message_template: table)表数据库访问层 + * + * @author lixinyu + * @since 2025-08-26 09:14:02 + */ +public interface IFeConfMessageTemplateDao extends IBaseDao { + + FeConfMessageTemplateEntity updateStatus(FeConfMessageTemplateEntity feConfMessageTemplateEntity); + + + List page(FeConfMessageTemplateEntity feConfMessageTemplateEntity); +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/impl/FeConfMessageTemplateDaoImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/impl/FeConfMessageTemplateDaoImpl.java new file mode 100644 index 00000000..be1db856 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/dao/impl/FeConfMessageTemplateDaoImpl.java @@ -0,0 +1,39 @@ +package com.hzya.frame.finance.conf.message.dao.impl; + +import com.hzya.frame.finance.conf.message.entity.FeConfMessageTemplateEntity; +import com.hzya.frame.finance.conf.message.dao.IFeConfMessageTemplateDao; +import org.apache.ibatis.session.SqlSession; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; + +import java.util.List; + +/** + * 消息模板表(FeConfMessageTemplate)表数据库访问层 + * + * @author lixinyu + * @since 2025-08-26 09:14:02 + */ +@Repository +public class FeConfMessageTemplateDaoImpl extends MybatisGenericDao implements IFeConfMessageTemplateDao{ + + @Override + public FeConfMessageTemplateEntity updateStatus(FeConfMessageTemplateEntity feConfMessageTemplateEntity) { + int update = this.update("com.hzya.frame.finance.conf.message.dao.impl.FeConfMessageTemplateDaoImpl.update_status", feConfMessageTemplateEntity); + if(update > 0){ + return feConfMessageTemplateEntity; + }else{ + throw new RuntimeException("更新状态失败"); + } + + } + + @Override + public List page(FeConfMessageTemplateEntity feConfMessageTemplateEntity) { + List objects = (List) this.selectList("com.hzya.frame.finance.conf.message.dao.impl.FeConfMessageTemplateDaoImpl.page", feConfMessageTemplateEntity); + return objects; + } + + +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.java new file mode 100644 index 00000000..d8643143 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.java @@ -0,0 +1,207 @@ +package com.hzya.frame.finance.conf.message.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 消息模板表(FeConfMessageTemplate)实体类 + * + * @author lixinyu + * @since 2025-08-26 09:14:02 + */ +public class FeConfMessageTemplateEntity extends BaseEntity { + + /** 消息模板编码 */ + private String code; + /** 消息模板名称 */ + private String name; + /** 消息标题 */ + private String title; + /** 启用状态 Y:启用 N:停用 */ + private String enablestate; + /** 备注 */ + private String remark; + /** 自定义项1 */ + private String def1; + /** 自定义项2 */ + private String def2; + /** 自定义项3 */ + private String def3; + /** 自定义项4 */ + private String def4; + /** 自定义项5 */ + private String def5; + /** 自定义项6 */ + private String def6; + /** 自定义项7 */ + private String def7; + /** 自定义项8 */ + private String def8; + /** 自定义项9 */ + private String def9; + /** 自定义项10 */ + private String def10; + /** 创建人 */ + private String createUser; + /** 修改人 */ + private String modifyUser; + /** 业务类型 + */ + private String mdmId; + /** 业务类型名称 */ + private String mdmName; + + + public String getCode() { + return code; + } + + public void setCode(String code) { + this.code = code; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getTitle() { + return title; + } + + public void setTitle(String title) { + this.title = title; + } + + public String getEnablestate() { + return enablestate; + } + + public void setEnablestate(String enablestate) { + this.enablestate = enablestate; + } + + public String getRemark() { + return remark; + } + + public void setRemark(String remark) { + this.remark = remark; + } + + 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; + } + + public String getMdmId() { + return mdmId; + } + + public void setMdmId(String mdmId) { + this.mdmId = mdmId; + } + + public String getMdmName() { + return mdmName; + } + + public void setMdmName(String mdmName) { + this.mdmName = mdmName; + } + +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.xml b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.xml new file mode 100644 index 00000000..7a35fa8e --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/entity/FeConfMessageTemplateEntity.xml @@ -0,0 +1,393 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,code + ,name + ,title + ,enablestate + ,remark + ,def1 + ,def2 + ,def3 + ,def4 + ,def5 + ,def6 + ,def7 + ,def8 + ,def9 + ,def10 + ,create_time + ,create_user + ,modify_time + ,modify_user + ,sts + ,mdm_id + ,mdm_name + + + + + + + + + update fe_conf_message_template + set enablestate = #{enablestate} + where id = #{id} + + + + + + + + + + + + + + insert into fe_conf_message_template( + + id , + code , + name , + title , + enablestate , + remark , + def1 , + def2 , + def3 , + def4 , + def5 , + def6 , + def7 , + def8 , + def9 , + def10 , + create_time , + create_user , + modify_time , + modify_user , + sts , + mdm_id , + mdm_name , + sts, + + )values( + + #{id} , + #{code} , + #{name} , + #{title} , + #{enablestate} , + #{remark} , + #{def1} , + #{def2} , + #{def3} , + #{def4} , + #{def5} , + #{def6} , + #{def7} , + #{def8} , + #{def9} , + #{def10} , + #{create_time} , + #{createUser} , + #{modify_time} , + #{modifyUser} , + #{sts} , + #{mdmId} , + #{mdmName} , + 'Y', + + ) + + + + insert into fe_conf_message_template(code, name, title, enablestate, remark, def1, def2, def3, def4, def5, def6, def7, def8, def9, def10, create_time, create_user, modify_time, modify_user, sts, mdm_id, mdm_name, sts) + values + + (#{entity.code},#{entity.name},#{entity.title},#{entity.enablestate},#{entity.remark},#{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},#{entity.mdmId},#{entity.mdmName}, 'Y') + + + + + insert into fe_conf_message_template(code, name, title, enablestate, remark, def1, def2, def3, def4, def5, def6, def7, def8, def9, def10, create_time, create_user, modify_time, modify_user, sts, mdm_id, mdm_name) + values + + (#{entity.code},#{entity.name},#{entity.title},#{entity.enablestate},#{entity.remark},#{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},#{entity.mdmId},#{entity.mdmName}) + + on duplicate key update + code = values(code), + name = values(name), + title = values(title), + enablestate = values(enablestate), + remark = values(remark), + 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), + mdm_id = values(mdm_id), + mdm_name = values(mdm_name) + + +update fe_conf_message_template set + + code = #{code}, + name = #{name}, + title = #{title}, + enablestate = #{enablestate}, + remark = #{remark}, + def1 = #{def1}, + def2 = #{def2}, + def3 = #{def3}, + def4 = #{def4}, + def5 = #{def5}, + def6 = #{def6}, + def7 = #{def7}, + def8 = #{def8}, + def9 = #{def9}, + def10 = #{def10}, + create_time = #{create_time}, + create_user = #{createUser}, + modify_time = #{modify_time}, + modify_user = #{modifyUser}, + sts = #{sts}, + mdm_id = #{mdmId}, + mdm_name = #{mdmName}, + +where id = #{id} + + + +update fe_conf_message_template set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update fe_conf_message_template set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and code = #{code} + and name = #{name} + and title = #{title} + and enablestate = #{enablestate} + and remark = #{remark} + 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 mdm_id = #{mdmId} + and mdm_name = #{mdmName} + and sts='Y' + + + + + delete from fe_conf_message_template where id = #{id} + + + + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/IFeConfMessageTemplateService.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/IFeConfMessageTemplateService.java new file mode 100644 index 00000000..76c10db1 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/IFeConfMessageTemplateService.java @@ -0,0 +1,23 @@ +package com.hzya.frame.finance.conf.message.service; + +import com.github.pagehelper.PageInfo; +import com.hzya.frame.finance.conf.message.entity.FeConfMessageTemplateEntity; +import com.hzya.frame.basedao.service.IBaseService; + +import java.util.List; + +/** + * 消息模板表(FeConfMessageTemplate)表服务接口 + * + * @author lixinyu + * @since 2025-08-26 09:14:02 + */ +public interface IFeConfMessageTemplateService extends IBaseService{ + List queryAll(FeConfMessageTemplateEntity feConfMessageTemplateEntity); + + FeConfMessageTemplateEntity updateStatus(FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception; + + void delete(FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception; + + PageInfo queryMessagePaged(FeConfMessageTemplateEntity feConfMessageTemplateEntity); +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/impl/FeConfMessageTemplateServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/impl/FeConfMessageTemplateServiceImpl.java new file mode 100644 index 00000000..ce944d3d --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/message/service/impl/FeConfMessageTemplateServiceImpl.java @@ -0,0 +1,94 @@ +package com.hzya.frame.finance.conf.message.service.impl; + +import com.github.pagehelper.Page; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.hzya.frame.finance.conf.message.entity.FeConfMessageTemplateEntity; +import com.hzya.frame.finance.conf.message.dao.IFeConfMessageTemplateDao; +import com.hzya.frame.finance.conf.message.service.IFeConfMessageTemplateService; +import com.hzya.frame.page.PageAttribute; +import org.junit.Assert; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import com.hzya.frame.basedao.service.impl.BaseService; + +import java.util.List; + +/** + * 消息模板表(FeConfMessageTemplate)表服务实现类 + * + * @author lixinyu + * @since 2025-08-26 09:14:02 + */ +@Service +public class FeConfMessageTemplateServiceImpl extends BaseService implements IFeConfMessageTemplateService { + + private IFeConfMessageTemplateDao feConfMessageTemplateDao; + + @Autowired + public void setFeConfMessageTemplateDao(IFeConfMessageTemplateDao dao) { + this.feConfMessageTemplateDao = dao; + this.dao = dao; + } + + /** + * 查询全部消息模板信息 + * @param feConfMessageTemplateEntity + * @return + */ + @Override + public List queryAll(FeConfMessageTemplateEntity feConfMessageTemplateEntity) { + List query = feConfMessageTemplateDao.queryByLike(feConfMessageTemplateEntity); + return query; + } + + /** + * 修改消息模板 + * @param feConfMessageTemplateEntity + * @return + * @throws Exception + */ + @Override + public FeConfMessageTemplateEntity updateStatus(FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception { + if(feConfMessageTemplateEntity == null){ + throw new Exception("参数不能为空"); + } + if(feConfMessageTemplateEntity.getId() == null){ + throw new Exception("id不能为空"); + } + if(feConfMessageTemplateEntity.getSts().equals("N")){ + throw new Exception("该记录已删除,无法修改"); + } + FeConfMessageTemplateEntity update = feConfMessageTemplateDao.updateStatus(feConfMessageTemplateEntity); + List query = feConfMessageTemplateDao.query(update); + return query.get(0); + } + + /** + * 删除消息模板 + * @param feConfMessageTemplateEntity + * @throws Exception + */ + @Override + public void delete(FeConfMessageTemplateEntity feConfMessageTemplateEntity) throws Exception { + if(feConfMessageTemplateEntity == null){ + throw new Exception("参数不能为空"); + } + if(feConfMessageTemplateEntity.getId() == null){ + throw new Exception("id不能为空"); + } + feConfMessageTemplateDao.logicRemove(feConfMessageTemplateEntity); + } + + /** + * 分页查询消息模板 + * @param feConfMessageTemplateEntity + * @return + */ + @Override + public PageInfo queryMessagePaged(FeConfMessageTemplateEntity feConfMessageTemplateEntity) { + PageHelper.startPage(feConfMessageTemplateEntity.getPageNum(), feConfMessageTemplateEntity.getPageSize()); + List query = feConfMessageTemplateDao.page(feConfMessageTemplateEntity); + return new PageInfo(query); + } +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/controller/NotificationRulesController.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/controller/NotificationRulesController.java new file mode 100644 index 00000000..12d17e72 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/controller/NotificationRulesController.java @@ -0,0 +1,80 @@ +package com.hzya.frame.finance.conf.notificationRules.controller; + +import com.github.pagehelper.PageInfo; +import com.hzya.frame.finance.conf.message.entity.FeConfMessageTemplateEntity; +import com.hzya.frame.finance.conf.notificationRules.dao.impl.FeConfNotificationRulesDaoImpl; +import com.hzya.frame.finance.conf.notificationRules.entity.FeConfNotificationRulesEntity; +import com.hzya.frame.finance.conf.notificationRules.service.IFeConfNotificationRulesService; +import com.hzya.frame.web.entity.JsonResultEntity; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +@RestController +@RequestMapping("/fe/conf/notificationRules") +public class NotificationRulesController { + @Autowired + private IFeConfNotificationRulesService iFeConfNotificationRulesService; + + /** + * 分页查询通知规则 + */ + @PostMapping("/queryPaged") + public JsonResultEntity queryPaged(@RequestBody FeConfNotificationRulesEntity feConfNotificationRulesEntity){ + PageInfo pageInfo = iFeConfNotificationRulesService.queryNotificationRulesPaged(feConfNotificationRulesEntity); + return new JsonResultEntity("查询成功",true,pageInfo); + } + + /** + * 条件查询通知规则 + */ + @PostMapping("/queryAll") + public JsonResultEntity queryAll(@RequestBody FeConfNotificationRulesEntity feConfNotificationRulesEntity){ + List list = iFeConfNotificationRulesService.queryByLike(feConfNotificationRulesEntity); + return new JsonResultEntity("查询成功",true,list); + } + + /** + * 新增通知规则 + */ + @PostMapping("/add") + public JsonResultEntity add(@RequestBody FeConfNotificationRulesEntity feConfNotificationRulesEntity){ + FeConfNotificationRulesEntity feConfNotificationRulesEntity1 = iFeConfNotificationRulesService.insert(feConfNotificationRulesEntity); + return new JsonResultEntity("新增成功",true,feConfNotificationRulesEntity1); + } + + /** + * 启用停用状态 + */ + @PostMapping("/updateStatus") + public JsonResultEntity updateStatus(@RequestBody FeConfNotificationRulesEntity feConfNotificationRulesEntity){ + FeConfNotificationRulesEntity feConfNotificationRulesEntity1 = iFeConfNotificationRulesService.updateStatus(feConfNotificationRulesEntity); + return new JsonResultEntity("更新成功",true,feConfNotificationRulesEntity1); + } + + /** + * 修改通知规则 + */ + @PostMapping("/update") + public JsonResultEntity update(@RequestBody FeConfNotificationRulesEntity feConfNotificationRulesEntity) throws Exception { + FeConfNotificationRulesEntity feConfNotificationRulesEntity1 = iFeConfNotificationRulesService.updateFeConfNotificationRulesEntity(feConfNotificationRulesEntity); + return new JsonResultEntity("修改成功",true,feConfNotificationRulesEntity1); + } + + /** + * 删除通知规则 + */ + @PostMapping("/delete") + public JsonResultEntity delete(@RequestBody FeConfNotificationRulesEntity feConfNotificationRulesEntity) throws Exception { + if(feConfNotificationRulesEntity.getSts().equals("N")){ + throw new Exception("该记录已删除"); + } + iFeConfNotificationRulesService.logicRemove(feConfNotificationRulesEntity); + return new JsonResultEntity("删除成功",true,null); + } + +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/IFeConfNotificationRulesDao.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/IFeConfNotificationRulesDao.java new file mode 100644 index 00000000..b57ea630 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/IFeConfNotificationRulesDao.java @@ -0,0 +1,22 @@ +package com.hzya.frame.finance.conf.notificationRules.dao; + +import com.hzya.frame.finance.conf.notificationRules.entity.FeConfNotificationRulesEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +import java.util.List; + +/** + * 通知规则表(fe_conf_notification_rules: table)表数据库访问层 + * + * @author lixinyu + * @since 2025-08-28 14:41:42 + */ +public interface IFeConfNotificationRulesDao extends IBaseDao { + + List queryNotificationRulesPaged(FeConfNotificationRulesEntity feConfNotificationRulesEntity); + + FeConfNotificationRulesEntity queryById(String id); + + int updateStatus(FeConfNotificationRulesEntity feConfNotificationRulesEntity); +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/impl/FeConfNotificationRulesDaoImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/impl/FeConfNotificationRulesDaoImpl.java new file mode 100644 index 00000000..d6144ac1 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/dao/impl/FeConfNotificationRulesDaoImpl.java @@ -0,0 +1,39 @@ +package com.hzya.frame.finance.conf.notificationRules.dao.impl; + +import com.hzya.frame.finance.conf.notificationRules.entity.FeConfNotificationRulesEntity; +import com.hzya.frame.finance.conf.notificationRules.dao.IFeConfNotificationRulesDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; + +import java.util.List; + +/** + * 通知规则表(FeConfNotificationRules)表数据库访问层 + * + * @author lixinyu + * @since 2025-08-28 14:41:42 + */ +@Repository +public class FeConfNotificationRulesDaoImpl extends MybatisGenericDao implements IFeConfNotificationRulesDao{ + + @Override + public List queryNotificationRulesPaged(FeConfNotificationRulesEntity feConfNotificationRulesEntity) { + List objects = (List) this.selectList("com.hzya.frame.finance.conf.notificationRules.dao.impl.FeConfNotificationRulesDaoImpl.page", feConfNotificationRulesEntity); + return objects; + } + + @Override + public FeConfNotificationRulesEntity queryById(String id) { + FeConfNotificationRulesEntity feConfNotificationRulesEntity = (FeConfNotificationRulesEntity) this.selectOne("com.hzya.frame.finance.conf.notificationRules.dao.impl.FeConfNotificationRulesDaoImpl.queryById", id); + return feConfNotificationRulesEntity; + } + + @Override + public int updateStatus(FeConfNotificationRulesEntity feConfNotificationRulesEntity) { + int update = this.update("com.hzya.frame.finance.conf.notificationRules.dao.impl.FeConfNotificationRulesDaoImpl.update_status", feConfNotificationRulesEntity); + return update; + } + + +} + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.java new file mode 100644 index 00000000..7101ba88 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.java @@ -0,0 +1,326 @@ +package com.hzya.frame.finance.conf.notificationRules.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 通知规则表(FeConfNotificationRules)实体类 + * + * @author lixinyu + * @since 2025-08-28 14:41:42 + */ +public class FeConfNotificationRulesEntity extends BaseEntity { + + /** 编码 */ + private String code; + /** 名称 */ + private String name; + /** 业务类型id */ + private String mdmId; + /** 业务类型名称 */ + private String mdmName; + /** 单据类型ID */ + private String pkBilltypeid; + /** 单据类型编码 */ + private String pkBilltypecode; + /** 单据类型名称 */ + private String pkBilltypename; + /** 通知方式Id */ + private String notificationMethodid; + /** 通知方式编码 */ + private String notificationMethodcode; + /** 通知方式名称 */ + private String notificationMethodname; + /** 通知策略(cron表达式) */ + private String notificationStrategy; + /** 通知对象id */ + private String notificationTargetid; + /** 通知对象编码 */ + private String notificationTargetcode; + /** 通知对象名称 */ + private String notificationTargetname; + /** 消息模板id */ + private Long messageTemplateid; + /** 消息模板编码 */ + private String messageTemplatecode; + /** 消息模板名称 */ + private String messageTemplatename; + /** 启用状态 Y:启用 N:停用 */ + private String enablestate; + /** 备注 */ + private String remark; + /** 自定义项1 */ + private String def1; + /** 自定义项2 */ + private String def2; + /** 自定义项3 */ + private String def3; + /** 自定义项4 */ + private String def4; + /** 自定义项5 */ + private String def5; + /** 自定义项6 */ + private String def6; + /** 自定义项7 */ + private String def7; + /** 自定义项8 */ + private String def8; + /** 自定义项9 */ + private String def9; + /** 自定义项10 */ + private String def10; + /** 创建人 */ + private String createUser; + /** 修改人 */ + private String modifyUser; + + + public String getCode() { + return code; + } + + public void setCode(String code) { + this.code = code; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getMdmId() { + return mdmId; + } + + public void setMdmId(String mdmId) { + this.mdmId = mdmId; + } + + public String getMdmName() { + return mdmName; + } + + public void setMdmName(String mdmName) { + this.mdmName = mdmName; + } + + public String getPkBilltypeid() { + return pkBilltypeid; + } + + public void setPkBilltypeid(String pkBilltypeid) { + this.pkBilltypeid = pkBilltypeid; + } + + public String getPkBilltypecode() { + return pkBilltypecode; + } + + public void setPkBilltypecode(String pkBilltypecode) { + this.pkBilltypecode = pkBilltypecode; + } + + public String getPkBilltypename() { + return pkBilltypename; + } + + public void setPkBilltypename(String pkBilltypename) { + this.pkBilltypename = pkBilltypename; + } + + public String getNotificationMethodid() { + return notificationMethodid; + } + + public void setNotificationMethodid(String notificationMethodid) { + this.notificationMethodid = notificationMethodid; + } + + public String getNotificationMethodcode() { + return notificationMethodcode; + } + + public void setNotificationMethodcode(String notificationMethodcode) { + this.notificationMethodcode = notificationMethodcode; + } + + public String getNotificationMethodname() { + return notificationMethodname; + } + + public void setNotificationMethodname(String notificationMethodname) { + this.notificationMethodname = notificationMethodname; + } + + public String getNotificationStrategy() { + return notificationStrategy; + } + + public void setNotificationStrategy(String notificationStrategy) { + this.notificationStrategy = notificationStrategy; + } + + public String getNotificationTargetid() { + return notificationTargetid; + } + + public void setNotificationTargetid(String notificationTargetid) { + this.notificationTargetid = notificationTargetid; + } + + public String getNotificationTargetcode() { + return notificationTargetcode; + } + + public void setNotificationTargetcode(String notificationTargetcode) { + this.notificationTargetcode = notificationTargetcode; + } + + public String getNotificationTargetname() { + return notificationTargetname; + } + + public void setNotificationTargetname(String notificationTargetname) { + this.notificationTargetname = notificationTargetname; + } + + public Long getMessageTemplateid() { + return messageTemplateid; + } + + public void setMessageTemplateid(Long messageTemplateid) { + this.messageTemplateid = messageTemplateid; + } + + public String getMessageTemplatecode() { + return messageTemplatecode; + } + + public void setMessageTemplatecode(String messageTemplatecode) { + this.messageTemplatecode = messageTemplatecode; + } + + public String getMessageTemplatename() { + return messageTemplatename; + } + + public void setMessageTemplatename(String messageTemplatename) { + this.messageTemplatename = messageTemplatename; + } + + public String getEnablestate() { + return enablestate; + } + + public void setEnablestate(String enablestate) { + this.enablestate = enablestate; + } + + public String getRemark() { + return remark; + } + + public void setRemark(String remark) { + this.remark = remark; + } + + 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/notificationRules/entity/FeConfNotificationRulesEntity.xml b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.xml new file mode 100644 index 00000000..9d68f30b --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/entity/FeConfNotificationRulesEntity.xml @@ -0,0 +1,541 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,code + ,name + ,mdm_id + ,mdm_name + ,pk_billtypeid + ,pk_billtypecode + ,pk_billtypename + ,notification_methodid + ,notification_methodcode + ,notification_methodname + ,notification_strategy + ,notification_targetid + ,notification_targetcode + ,notification_targetname + ,message_templateid + ,message_templatecode + ,message_templatename + ,enablestate + ,remark + ,def1 + ,def2 + ,def3 + ,def4 + ,def5 + ,def6 + ,def7 + ,def8 + ,def9 + ,def10 + ,create_time + ,create_user + ,modify_time + ,modify_user + ,sts + + + + update fe_conf_notification_rules + set enablestate = #{enablestate} + where id = #{id} + + + + + + + + + + + + + + + + + + insert into fe_conf_notification_rules( + + id , + code , + name , + mdm_id , + mdm_name , + pk_billtypeid , + pk_billtypecode , + pk_billtypename , + notification_methodid , + notification_methodcode , + notification_methodname , + notification_strategy , + notification_targetid , + notification_targetcode , + notification_targetname , + message_templateid , + message_templatecode , + message_templatename , + enablestate , + remark , + def1 , + def2 , + def3 , + def4 , + def5 , + def6 , + def7 , + def8 , + def9 , + def10 , + create_time , + create_user , + modify_time , + modify_user , + sts , + sts, + + )values( + + #{id} , + #{code} , + #{name} , + #{mdmId} , + #{mdmName} , + #{pkBilltypeid} , + #{pkBilltypecode} , + #{pkBilltypename} , + #{notificationMethodid} , + #{notificationMethodcode} , + #{notificationMethodname} , + #{notificationStrategy} , + #{notificationTargetid} , + #{notificationTargetcode} , + #{notificationTargetname} , + #{messageTemplateid} , + #{messageTemplatecode} , + #{messageTemplatename} , + #{enablestate} , + #{remark} , + #{def1} , + #{def2} , + #{def3} , + #{def4} , + #{def5} , + #{def6} , + #{def7} , + #{def8} , + #{def9} , + #{def10} , + #{create_time} , + #{createUser} , + #{modify_time} , + #{modifyUser} , + #{sts} , + + 'Y', + + ) + + + + insert into fe_conf_notification_rules(code, name, mdm_id, mdm_name, pk_billtypeid, pk_billtypecode, pk_billtypename, notification_methodid, notification_methodcode, notification_methodname, notification_strategy, notification_targetid, notification_targetcode, notification_targetname, message_templateid, message_templatecode, message_templatename, enablestate, remark, def1, def2, def3, def4, def5, def6, def7, def8, def9, def10, create_time, create_user, modify_time, modify_user, sts, sts) + values + + (#{entity.code},#{entity.name},#{entity.mdmId},#{entity.mdmName},#{entity.pkBilltypeid},#{entity.pkBilltypecode},#{entity.pkBilltypename},#{entity.notificationMethodid},#{entity.notificationMethodcode},#{entity.notificationMethodname},#{entity.notificationStrategy},#{entity.notificationTargetid},#{entity.notificationTargetcode},#{entity.notificationTargetname},#{entity.messageTemplateid},#{entity.messageTemplatecode},#{entity.messageTemplatename},#{entity.enablestate},#{entity.remark},#{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_notification_rules(code, name, mdm_id, mdm_name, pk_billtypeid, pk_billtypecode, pk_billtypename, notification_methodid, notification_methodcode, notification_methodname, notification_strategy, notification_targetid, notification_targetcode, notification_targetname, message_templateid, message_templatecode, message_templatename, enablestate, remark, def1, def2, def3, def4, def5, def6, def7, def8, def9, def10, create_time, create_user, modify_time, modify_user, sts) + values + + (#{entity.code},#{entity.name},#{entity.mdmId},#{entity.mdmName},#{entity.pkBilltypeid},#{entity.pkBilltypecode},#{entity.pkBilltypename},#{entity.notificationMethodid},#{entity.notificationMethodcode},#{entity.notificationMethodname},#{entity.notificationStrategy},#{entity.notificationTargetid},#{entity.notificationTargetcode},#{entity.notificationTargetname},#{entity.messageTemplateid},#{entity.messageTemplatecode},#{entity.messageTemplatename},#{entity.enablestate},#{entity.remark},#{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 + code = values(code), + name = values(name), + mdm_id = values(mdm_id), + mdm_name = values(mdm_name), + pk_billtypeid = values(pk_billtypeid), + pk_billtypecode = values(pk_billtypecode), + pk_billtypename = values(pk_billtypename), + notification_methodid = values(notification_methodid), + notification_methodcode = values(notification_methodcode), + notification_methodname = values(notification_methodname), + notification_strategy = values(notification_strategy), + notification_targetid = values(notification_targetid), + notification_targetcode = values(notification_targetcode), + notification_targetname = values(notification_targetname), + message_templateid = values(message_templateid), + message_templatecode = values(message_templatecode), + message_templatename = values(message_templatename), + enablestate = values(enablestate), + remark = values(remark), + 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_notification_rules set + + code = #{code}, + name = #{name}, + mdm_id = #{mdmId}, + mdm_name = #{mdmName}, + pk_billtypeid = #{pkBilltypeid}, + pk_billtypecode = #{pkBilltypecode}, + pk_billtypename = #{pkBilltypename}, + notification_methodid = #{notificationMethodid}, + notification_methodcode = #{notificationMethodcode}, + notification_methodname = #{notificationMethodname}, + notification_strategy = #{notificationStrategy}, + notification_targetid = #{notificationTargetid}, + notification_targetcode = #{notificationTargetcode}, + notification_targetname = #{notificationTargetname}, + message_templateid = #{messageTemplateid}, + message_templatecode = #{messageTemplatecode}, + message_templatename = #{messageTemplatename}, + enablestate = #{enablestate}, + remark = #{remark}, + def1 = #{def1}, + def2 = #{def2}, + def3 = #{def3}, + def4 = #{def4}, + def5 = #{def5}, + def6 = #{def6}, + def7 = #{def7}, + def8 = #{def8}, + def9 = #{def9}, + def10 = #{def10}, + create_time = #{create_time}, + create_user = #{createUser}, + modify_time = #{modify_time}, + modify_user = #{modifyUser}, + sts = #{sts}, + +where id = #{id} + + + +update fe_conf_notification_rules set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update fe_conf_notification_rules set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and code = #{code} + and name = #{name} + and mdm_id = #{mdmId} + and mdm_name = #{mdmName} + and pk_billtypeid = #{pkBilltypeid} + and pk_billtypecode = #{pkBilltypecode} + and pk_billtypename = #{pkBilltypename} + and notification_methodid = #{notificationMethodid} + and notification_methodcode = #{notificationMethodcode} + and notification_methodname = #{notificationMethodname} + and notification_strategy = #{notificationStrategy} + and notification_targetid = #{notificationTargetid} + and notification_targetcode = #{notificationTargetcode} + and notification_targetname = #{notificationTargetname} + and message_templateid = #{messageTemplateid} + and message_templatecode = #{messageTemplatecode} + and message_templatename = #{messageTemplatename} + and enablestate = #{enablestate} + and remark = #{remark} + 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_notification_rules where id = #{id} + + + + diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/IFeConfNotificationRulesService.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/IFeConfNotificationRulesService.java new file mode 100644 index 00000000..a5e10336 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/IFeConfNotificationRulesService.java @@ -0,0 +1,20 @@ +package com.hzya.frame.finance.conf.notificationRules.service; + +import com.github.pagehelper.PageInfo; +import com.hzya.frame.finance.conf.notificationRules.entity.FeConfNotificationRulesEntity; +import com.hzya.frame.basedao.service.IBaseService; +/** + * 通知规则表(FeConfNotificationRules)表服务接口 + * + * @author lixinyu + * @since 2025-08-28 14:41:42 + */ +public interface IFeConfNotificationRulesService extends IBaseService{ + PageInfo queryNotificationRulesPaged(FeConfNotificationRulesEntity feConfNotificationRulesEntity); + + FeConfNotificationRulesEntity insert(FeConfNotificationRulesEntity feConfNotificationRulesEntity); + + FeConfNotificationRulesEntity updateStatus(FeConfNotificationRulesEntity feConfNotificationRulesEntity); + + FeConfNotificationRulesEntity updateFeConfNotificationRulesEntity(FeConfNotificationRulesEntity feConfNotificationRulesEntity) throws Exception; +} diff --git a/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/impl/FeConfNotificationRulesServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/impl/FeConfNotificationRulesServiceImpl.java new file mode 100644 index 00000000..0ea54ce0 --- /dev/null +++ b/base-buildpackage/src/main/java/com/hzya/frame/finance/conf/notificationRules/service/impl/FeConfNotificationRulesServiceImpl.java @@ -0,0 +1,102 @@ +package com.hzya.frame.finance.conf.notificationRules.service.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.hzya.frame.finance.conf.notificationRules.entity.FeConfNotificationRulesEntity; +import com.hzya.frame.finance.conf.notificationRules.dao.IFeConfNotificationRulesDao; +import com.hzya.frame.finance.conf.notificationRules.service.IFeConfNotificationRulesService; +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.List; + +/** + * 通知规则表(FeConfNotificationRules)表服务实现类 + * + * @author lixinyu + * @since 2025-08-28 14:41:42 + */ +@Service +public class FeConfNotificationRulesServiceImpl extends BaseService implements IFeConfNotificationRulesService { + + private IFeConfNotificationRulesDao feConfNotificationRulesDao; + + @Autowired + public void setFeConfNotificationRulesDao(IFeConfNotificationRulesDao dao) { + this.feConfNotificationRulesDao = dao; + this.dao = dao; + } + + /** + * 分页查询通知规则 + * @param feConfNotificationRulesEntity + * @return + */ + @Override + public PageInfo queryNotificationRulesPaged(FeConfNotificationRulesEntity feConfNotificationRulesEntity) { + PageHelper.startPage(feConfNotificationRulesEntity.getPageNum(), feConfNotificationRulesEntity.getPageSize()); + List list = feConfNotificationRulesDao.queryNotificationRulesPaged(feConfNotificationRulesEntity); + return new PageInfo(list); + } + + /** + * 新增通知规则 + * @param feConfNotificationRulesEntity + * @return + */ + @Override + public FeConfNotificationRulesEntity insert(FeConfNotificationRulesEntity feConfNotificationRulesEntity) { + if(feConfNotificationRulesEntity.getPkBilltypeid() == null || "".equals(feConfNotificationRulesEntity.getPkBilltypeid())){ + throw new RuntimeException("单据类型不能为空"); + } + if(feConfNotificationRulesEntity.getNotificationStrategy() == null || "".equals(feConfNotificationRulesEntity.getNotificationStrategy())){ + throw new RuntimeException("通知策略不能为空"); + } + if(feConfNotificationRulesEntity.getNotificationTargetid() == null || "".equals(feConfNotificationRulesEntity.getNotificationTargetid())){ + throw new RuntimeException("通知对象不能为空"); + } + if(feConfNotificationRulesEntity.getMessageTemplateid() == null || "".equals(feConfNotificationRulesEntity.getMessageTemplateid())){ + throw new RuntimeException("消息模板不能为空"); + } + FeConfNotificationRulesEntity save = feConfNotificationRulesDao.save(feConfNotificationRulesEntity); + FeConfNotificationRulesEntity feConfNotificationRulesEntity1 = feConfNotificationRulesDao.queryById(save.getId()); + return feConfNotificationRulesEntity1; + } + + /** + * 启用停用 + * @param feConfNotificationRulesEntity + * @return + */ + @Override + public FeConfNotificationRulesEntity updateStatus(FeConfNotificationRulesEntity feConfNotificationRulesEntity) { + if(feConfNotificationRulesEntity.getId() == null){ + throw new RuntimeException("id不能为空"); + } + if(feConfNotificationRulesEntity.getSts().equals("N")){ + throw new RuntimeException("该数据已删除，无法修改"); + } + int update = feConfNotificationRulesDao.updateStatus(feConfNotificationRulesEntity); + if(update >0){ + return feConfNotificationRulesDao.queryById(feConfNotificationRulesEntity.getId()); + }else{ + throw new RuntimeException("更新失败"); + } + } + + /** + * 修改通知规则 + * @param feConfNotificationRulesEntity + * @return + */ + @Override + public FeConfNotificationRulesEntity updateFeConfNotificationRulesEntity(FeConfNotificationRulesEntity feConfNotificationRulesEntity) throws Exception { + if(feConfNotificationRulesEntity.getSts().equals("N")){ + throw new Exception("该记录已删除,修改失败"); + } + FeConfNotificationRulesEntity update = feConfNotificationRulesDao.update(feConfNotificationRulesEntity); + return update; + } +}