From d2c37020f760f53ee9328fb4baadecc2716ea094 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期三, 04 三月 2026 13:18:19 +0800
Subject: [PATCH] yys 系统消息管理开发
---
src/main/java/com/ruoyi/sales/controller/BusinessOpportunityController.java | 40 +++++++++++++++++++++++++++++++++++++++-
1 files changed, 39 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/ruoyi/sales/controller/BusinessOpportunityController.java b/src/main/java/com/ruoyi/sales/controller/BusinessOpportunityController.java
index 49e311c..82944fc 100644
--- a/src/main/java/com/ruoyi/sales/controller/BusinessOpportunityController.java
+++ b/src/main/java/com/ruoyi/sales/controller/BusinessOpportunityController.java
@@ -3,10 +3,15 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.framework.aspectj.lang.annotation.Log;
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
import com.ruoyi.framework.web.controller.BaseController;
import com.ruoyi.framework.web.domain.AjaxResult;
+import com.ruoyi.project.system.domain.SysNotice;
+import com.ruoyi.project.system.mapper.SysNoticeMapper;
+import com.ruoyi.project.system.service.impl.SysNoticeServiceImpl;
+import com.ruoyi.project.system.service.impl.UnipushService;
import com.ruoyi.sales.mapper.BusinessDescriptionMapper;
import com.ruoyi.sales.pojo.BusinessDescription;
import com.ruoyi.sales.pojo.BusinessOpportunity;
@@ -20,6 +25,7 @@
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
+import java.util.ArrayList;
import java.util.List;
/**
@@ -39,6 +45,12 @@
@Autowired
private CommonFileServiceImpl commonFileService;
+
+ @Autowired
+ private UnipushService unipushService;
+
+ @Autowired
+ private SysNoticeMapper sysNoticeMapper;
@ApiOperation("鑾峰彇鐪佺骇鍒楄〃")
@GetMapping("/getProvinceList")
@@ -69,13 +81,26 @@
@ApiOperation("娣诲姞鍟嗘満")
@Log(title = "鍟嗘満绠＄悊-娣诲姞鍟嗘満", businessType = BusinessType.INSERT)
@Transactional(rollbackFor = Exception.class)
- public AjaxResult add(@RequestBody BusinessOpportunity businessOpportunity) throws Exception{
+ public AjaxResult add(@RequestBody BusinessOpportunity businessOpportunity) throws Exception{
businessOpportunityService.save(businessOpportunity);
BusinessDescription businessDescription = new BusinessDescription();
BeanUtils.copyProperties(businessOpportunity, businessDescription);
businessDescription.setBusinessOpportunityId(businessOpportunity.getId());
// 杩佺Щ涓存椂鏂囦欢鍒版寮忔枃浠�
commonFileService.migrateTempFilesToFormal(businessOpportunity.getId(), businessOpportunity.getTempFileIds());
+ // 鎺ㄩ�佹秷鎭�
+ List<SysNotice> sysNoticeList = new ArrayList<>();
+ SysNotice sysNotice = new SysNotice();
+ sysNotice.setNoticeTitle("涓氬姟鍛� "+ businessOpportunity.getEntryPerson());
+ sysNotice.setNoticeContent("鏂板瀹㈡埛 " + businessOpportunity.getCustomerName() + " 閲戦 "+ businessOpportunity.getContractAmount());
+ sysNotice.setNoticeType("1");
+ sysNotice.setStatus("0");
+ sysNotice.setSenderId(SecurityUtils.getUserId());
+ sysNotice.setConsigneeId(105L);
+ sysNotice.setAppJumpPath("pages/opportunityManagement/index");
+ sysNoticeMapper.insert(sysNotice);
+ sysNoticeList.add(sysNotice);
+ unipushService.sendClientMessage(sysNoticeList);
return businessDescriptionMapper.insert(businessDescription) > 0 ? success() : error();
}
@@ -90,6 +115,19 @@
if(byId != null){
byId.setStatus(businessDescription.getStatus());
businessOpportunityService.updateById(byId);
+ // 鎺ㄩ�佹秷鎭�
+ List<SysNotice> sysNoticeList = new ArrayList<>();
+ SysNotice sysNotice = new SysNotice();
+ sysNotice.setNoticeTitle("涓氬姟鍛� "+ businessDescription.getEntryPerson());
+ sysNotice.setNoticeContent("瀹㈡埛 " + byId.getCustomerName() + " 閲戦 "+ byId.getContractAmount() + " 鐘舵�� " + businessDescription.getStatus());
+ sysNotice.setNoticeType("1");
+ sysNotice.setStatus("0");
+ sysNotice.setSenderId(SecurityUtils.getUserId());
+ sysNotice.setConsigneeId(105L);
+ sysNotice.setAppJumpPath("pages/opportunityManagement/index");
+ sysNoticeMapper.insert(sysNotice);
+ sysNoticeList.add(sysNotice);
+ unipushService.sendClientMessage(sysNoticeList);
}
return businessDescriptionMapper.insert(businessDescription) > 0 ? success() : error();
}
--
Gitblit v1.9.3