删除同步代码

src/main/java/com/unissoft/basic/controller/BasicEnumController.java

@@ -5,7 +5,6 @@ import java.util.Date;
 import java.util.List;
 
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -33,8 +32,6 @@ import io.swagger.annotations.ApiOperation;
 @RestController
 @RequestMapping("/basic-enum")
 public class BasicEnumController {
-    @Autowired
-    private Producer producer;
 
 	private BasicEnumService enumService;
 
@@ -68,7 +65,6 @@ public class BasicEnumController {
     	basicEnum.setUpdateTime(date);
         boolean save = enumService.save(basicEnum);
         if (save) {
-            producer.send(basicEnum, MessageEnum.SAVE, ServiceEnum.BASIC_ENUM);
             return ResultView.success();
         }else {
             return ResultView.error();
@@ -87,8 +83,6 @@ public class BasicEnumController {
     	basicEnum.setUpdateTime(new Date());
         boolean b = enumService.updateById(basicEnum);
         if (b) {
-            //发送消息
-            producer.send(basicEnum, MessageEnum.UPDATE,ServiceEnum.BASIC_ENUM);
             return ResultView.success();
         }else {
             return ResultView.error();

src/main/java/com/unissoft/interaction/service/impl/TeDataServiceImpl.java

@@ -14,7 +14,6 @@ import com.unissoft.interaction.mapper.ReMsgMapper;
 import com.unissoft.interaction.mapper.STaskMapper;
 import com.unissoft.interaction.mapper.TeDataMapper;
 import com.unissoft.interaction.service.TeDataService;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.parameter.mapper.HardwareParameterMapper;
 import com.unissoft.parameter.model.HardwareParameter;
 import com.unissoft.systemManage.mapper.NBasicEdgeMapper;
@@ -77,8 +76,6 @@ public class TeDataServiceImpl implements TeDataService {
     private OrgInfoMapper orgInfoMapper;
     @Resource
     private DensityDataMapper densityDataMapper;
-    @Resource
-    private Producer producer;
 
     /**
      * todo-----------暂时不用
@@ -393,9 +390,6 @@ public class TeDataServiceImpl implements TeDataService {
 			nBasicEdge.setHStatus("2");
 		}
         int insert = nBasicEdgeMapper.insert(nBasicEdge);
-        if (insert>0){
-            producer.send(nBasicEdge, MessageEnum.SAVE, ServiceEnum.NBASIC_EDGE);
-        }
     }
 
     

src/main/java/com/unissoft/mqConsumer/Consumer.java

@@ -1,87 +0,0 @@
-package com.unissoft.mqConsumer;
-
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.unissoft.mqConsumer.Manager.ServiceManager;
-import com.unissoft.parameter.model.HardwareParameter;
-import com.unissoft.parameter.service.HardwareParameterService;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-/**
- * ClassName: HardwareParameterConsumer
- * Package: com.unissoft.mqConsumer
- * Description: 消费者
- *
- * @Author zlq
- * @Create 2023/3/3 10:42
- * @Version 1.0
- */
-@Slf4j
-@Component
-public class Consumer {
-    @Autowired
-    private ServiceManager serviceManager;
-
-
-    //库端TOPIK，云端使用
-    private final static String topicLocal="TOPIC_LOCAL";
-    //云端topic,库端使用
-    private final static String topicCloud="TOPIC_CLOUD";
-
-
-    @Component
-    @RocketMQMessageListener(topic = topicLocal,consumerGroup = "local")
-    public class HPSave implements RocketMQListener<String>{
-        @Override
-        public void onMessage(String message) {
-            if (message == null) {
-                log.info("消息为空：｛｝",message);
-                return;
-            }
-            log.info("接收到的消息：{}",message);
-            JSONObject message1 = JSON.parseObject(message);
-            JSONObject headers = message1.getJSONObject("headers");
-
-            String type = headers.getString("type");
-            String payload = message1.getString("payload");
-            //获取消息所在业务
-            String service = headers.getString("service");
-
-            switch (service){
-                case "HD_PARAMETER":
-                    serviceManager.HDManager(payload,type);
-                    break;
-                case "BASIC_ENUM":
-                    serviceManager.BasicEnumManager(payload,type);
-                    break;
-                case "NBASIC_EDGE":
-                    serviceManager.NBasicEdgeManager(payload,type);
-                    break;
-                case "ROLE_INFO":
-                    serviceManager.RoleInfoManager(payload,type);
-                    break;
-                case "USER_INFO":
-                    serviceManager.UserInfoManager(payload,type);
-                    break;
-                case "ORG_INFO":
-                    serviceManager.OrgInfoManager(payload,type);
-                    break;
-                case "ORG_ANNOUNCEMENT":
-                    //公告管理
-                    serviceManager.OrgAnnouncementManager(payload,type);
-                    break;
-                case "STORE_HOUSE":
-                    //仓房明细
-                    serviceManager.StorehouseClxxManager(payload,type);
-                    break;
-                default:
-                    log.info("没有可用的业务类型！！{}",message);
-            }
-        }
-    }
-
-}

src/main/java/com/unissoft/mqConsumer/Manager/ServiceManager.java

@@ -1,245 +0,0 @@
-package com.unissoft.mqConsumer.Manager;
-
-import com.alibaba.fastjson.JSON;
-import com.unissoft.basic.model.BasicEnum;
-import com.unissoft.basic.service.BasicEnumService;
-import com.unissoft.parameter.model.HardwareParameter;
-import com.unissoft.parameter.service.HardwareParameterService;
-import com.unissoft.systemManage.model.*;
-import com.unissoft.systemManage.service.*;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-
-/**
- * ClassName: HDManager
- * Package: com.unissoft.mqConsumer.Manager
- * Description: 接收处理业务数据
- *
- * @Author zlq
- * @Create 2023/3/6 15:08
- * @Version 1.0
- */
-@Slf4j
-@Component
-public class ServiceManager {
-    @Resource
-    private RoleInfoService roleInfoService;
-    @Resource
-    private NBasicEdgeService nBasicEdgeService;
-    @Autowired
-    private BasicEnumService basicEnumService;
-
-    @Autowired
-    private HardwareParameterService hardwareParameterService;
-
-    /**
-     * 硬件参数
-     * @param payload
-     * @param type
-     */
-    public void HDManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                //获取硬件参数对象
-                HardwareParameter hardwareParameter = JSON.parseObject(payload, HardwareParameter.class);
-                //新增硬件数据
-                    boolean save = hardwareParameterService.save(hardwareParameter);
-                log.info("新增硬件信息{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                //获取硬件参数对象
-
-                HardwareParameter hardwareParameter1 = JSON.parseObject(payload, HardwareParameter.class);
-                    boolean b1 = hardwareParameterService.updateById(hardwareParameter1);
-                log.info("修改硬件信息{},是否成功：{}",payload,b1);
-                break;
-            case "DELETE":
-                    boolean b2 = hardwareParameterService.removeById(payload);
-                log.info("删除硬件id{},是否成功：{}",payload,b2);
-                break;
-        }
-    }
-
-    /**
-     * 字典
-     * @param payload
-     * @param type
-     */
-    public void BasicEnumManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                BasicEnum basicEnum = JSON.parseObject(payload, BasicEnum.class);
-                boolean save = basicEnumService.save(basicEnum);
-                log.info("新增字典{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                BasicEnum basicEnum1 = JSON.parseObject(payload, BasicEnum.class);
-                boolean b = basicEnumService.updateById(basicEnum1);
-                log.info("修改字典信息{},是否成功：{}",payload,b);
-                break;
-        }
-    }
-
-    /**
-     *打点的数据查询表
-     * @param payload
-     * @param type
-     */
-    public void NBasicEdgeManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                NBasicEdge nBasicEdge = JSON.parseObject(payload, NBasicEdge.class);
-                boolean save = nBasicEdgeService.save(nBasicEdge);
-                log.info("新增打点的数据信息{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                NBasicEdge nBasicEdge1 = JSON.parseObject(payload, NBasicEdge.class);
-                boolean b = nBasicEdgeService.updateById(nBasicEdge1);
-                log.info("修改打点的数据信息{},是否成功：{}",payload,b);
-                break;
-        }
-    }
-
-
-    /**
-     *用户角色消息
-     * @param payload
-     * @param type
-     */
-    public void RoleInfoManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                RoleInfo roleInfo = JSON.parseObject(payload, RoleInfo.class);
-                boolean save = roleInfoService.save(roleInfo);
-                log.info("新增角色消息{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                RoleInfo roleInfo1 = JSON.parseObject(payload, RoleInfo.class);
-                boolean b = roleInfoService.updateById(roleInfo1);
-                log.info("修改角色消息{},是否成功：{}",payload,b);
-                break;
-            case "DELETE":
-                boolean b2 = roleInfoService.removeById(payload);
-                log.info("删除角色id{},是否成功：{}",payload,b2);
-                break;
-        }
-    }
-
-    @Resource
-    private UserInfoService userInfoService;
-
-    /**
-     *用户消息
-     * @param payload
-     * @param type
-     */
-    public void UserInfoManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                UserInfo userInfo = JSON.parseObject(payload, UserInfo.class);
-                boolean save = userInfoService.save(userInfo);
-                log.info("新增用户{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                UserInfo userInfo1 = JSON.parseObject(payload, UserInfo.class);
-                boolean b = userInfoService.updateById(userInfo1);
-                log.info("修改用户{},是否成功：{}",payload,b);
-                break;
-            case "DELETE":
-                boolean b2 = userInfoService.removeById(payload);
-                log.info("删除用户{},是否成功：{}",payload,b2);
-                break;
-        }
-    }
-    @Resource
-    private OrgInfoService orgInfoService;
-    /**
-     *组织机构消息
-     * @param payload
-     * @param type
-     */
-    public void OrgInfoManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                OrgInfo orgInfo = JSON.parseObject(payload, OrgInfo.class);
-                boolean save = orgInfoService.save(orgInfo);
-                log.info("新增组织机构{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                OrgInfo orgInfo1 = JSON.parseObject(payload, OrgInfo.class);
-                boolean b = orgInfoService.updateById(orgInfo1);
-                log.info("修改组织机构信息{},是否成功：{}",payload,b);
-                break;
-            case "DELETE":
-                boolean b2 = orgInfoService.removeById(payload);
-                log.info("删除组织机构{},是否成功：{}",payload,b2);
-                break;
-        }
-    }
-
-    @Resource
-    private OrgAnnouncementService orgAnnouncementService;
-    /**
-     * 公告管理
-     * @param payload
-     * @param type
-     */
-    public void OrgAnnouncementManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "SAVE":
-                OrgAnnouncement orgAnnouncement = JSON.parseObject(payload, OrgAnnouncement.class);
-                boolean save = orgAnnouncementService.save(orgAnnouncement);
-                log.info("新增公告{},是否成功：{}",payload,save);
-                break;
-            case "UPDATE":
-                OrgAnnouncement orgAnnouncement1 = JSON.parseObject(payload, OrgAnnouncement.class);
-                boolean b = orgAnnouncementService.updateById(orgAnnouncement1);
-                log.info("修改公告{},是否成功：{}",payload,b);
-                break;
-            case "DELETE":
-                boolean b2 = orgAnnouncementService.removeById(payload);
-                log.info("删除公告{},是否成功：{}",payload,b2);
-                break;
-        }
-    }
-
-    @Resource
-    private StorehouseClxxService storehouseClxxService;
-    /**
-     * 仓房明细
-     * @param payload
-     * @param type
-     */
-    public void StorehouseClxxManager(String payload,String type){
-        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
-        switch (type){
-            case "DELETE_STORE_HOUSE":
-                boolean b1 = storehouseClxxService.deleteStorehouse(Integer.parseInt(payload));
-                log.info("删除仓房信息{},是否成功：{}",payload,b1);
-                break;
-            case "UPDATE":
-                boolean  b = false;
-                try {
-                  b = orgInfoService.updateStorehouse(payload);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-                log.info("修改仓房明细{},是否成功：{}",payload,b);
-                break;
-            case "DELETE":
-                boolean b2 = storehouseClxxService.removeById(payload);
-                log.info("删除仓房明细中的一条{},是否成功：{}",payload,b2);
-                break;
-        }
-    }
-}

src/main/java/com/unissoft/mqProducer/Producer.java

@@ -1,63 +0,0 @@
-package com.unissoft.mqProducer;
-
-
-import com.unissoft.common.MessageEnum;
-import com.unissoft.common.ServiceEnum;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.client.producer.SendResult;
-import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.messaging.MessageHeaders;
-import org.springframework.messaging.support.MessageBuilder;
-import org.springframework.stereotype.Component;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * ClassName: ProService
- * Package: com.unissoft.mqProducer
- * Description: rocketmq生产者
- *
- * @Author zlq
- * @Create 2023/3/2 9:44
- * @Version 1.0
- */
-@Slf4j
-@Component("producer")
-public class Producer {
-    //库端TOPIK，库端使用
-    private final String topicLocal="TOPIC_LOCAL";
-    //云端topic，云端使用
-    private final String topicCloud="TOPIC_CLOUD";
-
-    @Autowired
-    private RocketMQTemplate rocketMQTemplate;
-
-    /**
-     *
-     * @param body 消息内容
-     * @param type  消息属性
-     */
-    public void send(Object body, MessageEnum type, ServiceEnum ser){
-//        Map<String, Object> map = new HashMap<>();
-//        map.put("type",type);
-//        map.put("service",ser);
-//        org.springframework.messaging.Message<Object> message = MessageBuilder.createMessage(body, new MessageHeaders(map));
-//        rocketMQTemplate.convertAndSend(topicCloud,message);
-//        log.info("发送消息：{}",message);
-    }
-
-    /**
-     *
-     * @param msgBody  同步发送的消息
-     * @param tag  消息类型
-     * @return
-     */
-    /*public SendResult sendMsg(String msgBody,String tag) {
-        SendResult sendResult = rocketMQTemplate.syncSend(topicLocal+tag, MessageBuilder.withPayload(msgBody).build());
-        return sendResult;
-    }*/
-
-}

src/main/java/com/unissoft/parameter/controller/HardwareParameterController.java

@@ -3,7 +3,6 @@ package com.unissoft.parameter.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.parameter.model.HardwareParameter;
 import com.unissoft.parameter.service.HardwareParameterService;
 
@@ -30,9 +29,6 @@ public class HardwareParameterController {
     private HardwareParameterService hdService;
 
     @Autowired
-    private Producer producer;
-
-    @Autowired
     public void setHardwareParameterController(HardwareParameterService hdService) {
         this.hdService = hdService;
     }
@@ -62,7 +58,6 @@ public class HardwareParameterController {
     	hdParameter.setCreateTime(new Date());
         boolean save = hdService.save(hdParameter);
         if (save) {
-            producer.send(hdParameter, MessageEnum.SAVE, ServiceEnum.HD_PARAMETER);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -78,7 +73,6 @@ public class HardwareParameterController {
     public ResultView updateUser(@RequestBody HardwareParameter hdParameter) {
         boolean b = hdService.updateById(hdParameter);
         if (b) {
-            producer.send(hdParameter, MessageEnum.UPDATE,ServiceEnum.HD_PARAMETER);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -96,7 +90,6 @@ public class HardwareParameterController {
     public ResultView deleteById(@PathVariable String id) {
     	boolean b = hdService.removeById(id);
         if (b) {
-            producer.send(id, MessageEnum.DELETE,ServiceEnum.HD_PARAMETER);
             return ResultView.success();
         }else
             return ResultView.error();

src/main/java/com/unissoft/systemManage/controller/NBasicEdgeController.java

@@ -2,8 +2,8 @@ package com.unissoft.systemManage.controller;
 
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
+import com.unissoft.common.PageParam;
+import com.unissoft.common.ResultView;
 import com.unissoft.systemManage.model.LogOperation;
 import com.unissoft.systemManage.model.NBasicEdge;
 import com.unissoft.systemManage.model.RoleInfo;
@@ -40,8 +40,6 @@ import javax.servlet.http.HttpServletResponse;
 @RestController
 @RequestMapping("/n-basic-edge")
 public class NBasicEdgeController {
-    @Autowired
-    private Producer producer;
 
     private NBasicEdgeService nBasicEdgeService;
 
@@ -80,11 +78,9 @@ public class NBasicEdgeController {
     public ResultView saveRoleInfo(@RequestBody NBasicEdge nBasicEdge) {
         boolean save = nBasicEdgeService.save(nBasicEdge);
         if (save) {
-            producer.send(nBasicEdge, MessageEnum.SAVE, ServiceEnum.NBASIC_EDGE);
             return ResultView.success();
-        }else {
-            return ResultView.error();
         }
+            return ResultView.error();
     }
 
     @ApiOperation(value = "修改扫描规则", notes = "")
@@ -92,7 +88,6 @@ public class NBasicEdgeController {
     public ResultView updateRoleInfo(@RequestBody NBasicEdge nBasicEdge) {
         boolean b = nBasicEdgeService.updateById(nBasicEdge);
         if (b) {
-            producer.send(nBasicEdge, MessageEnum.UPDATE, ServiceEnum.NBASIC_EDGE);
             return ResultView.success();
         }else {
             return ResultView.error();

src/main/java/com/unissoft/systemManage/controller/OrgAnnouncementController.java

@@ -3,7 +3,6 @@ package com.unissoft.systemManage.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.OrgAnnouncement;
 import com.unissoft.systemManage.model.UserInfo;
 import com.unissoft.systemManage.service.OrgAnnouncementService;
@@ -22,8 +21,6 @@ import javax.annotation.Resource;
 @RestController
 @RequestMapping("/orgAnnouncement")
 public class OrgAnnouncementController {
-    @Resource
-    private Producer producer;
 
     private OrgAnnouncementService orgAnnouncementService;
     @Autowired
@@ -56,8 +53,6 @@ public class OrgAnnouncementController {
     public ResultView saveUser(@RequestBody OrgAnnouncement announcement) {
         boolean save = orgAnnouncementService.save(announcement);
         if (save) {
-            //新增公告时同步云端和库端的数据
-            producer.send(announcement,MessageEnum.SAVE,ServiceEnum.ORG_ANNOUNCEMENT);
             return ResultView.success();
         } else{
             return ResultView.error();
@@ -68,7 +63,6 @@ public class OrgAnnouncementController {
     public ResultView updateUser(@RequestBody OrgAnnouncement announcement) {
         boolean b = orgAnnouncementService.updateById(announcement);
         if (b) {
-            producer.send(announcement,MessageEnum.UPDATE,ServiceEnum.ORG_ANNOUNCEMENT);
             return ResultView.success();
         } else{
             return ResultView.error();
@@ -79,7 +73,6 @@ public class OrgAnnouncementController {
     @GetMapping("/authority/deleteById/{id}")
     public ResultView getByIdForUserDelete(@PathVariable String id) {
         if (orgAnnouncementService.removeById(id)) {
-            producer.send(id,MessageEnum.DELETE,ServiceEnum.ORG_ANNOUNCEMENT);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/controller/OrgInfoController.java

@@ -4,7 +4,6 @@ package com.unissoft.systemManage.controller;
 import com.alibaba.fastjson.JSON;
 import com.unissoft.basic.model.BasicEnum;
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.OrgInfo;
 import com.unissoft.systemManage.model.OrgInfoChildren;
 import com.unissoft.systemManage.service.OrgInfoService;
@@ -27,8 +26,6 @@ import java.util.stream.Collectors;
 @RestController
 @RequestMapping("/orgInfo")
 public class OrgInfoController {
-    @Autowired
-    private Producer producer;
 
     private OrgInfoService orgInfoService;
 
@@ -55,7 +52,6 @@ public class OrgInfoController {
         orgInfo.setBuildTime(DateUtils.getDate());
         boolean save = orgInfoService.save(orgInfo);
         if (save) {
-            producer.send(orgInfo, MessageEnum.SAVE, ServiceEnum.ORG_INFO);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -67,7 +63,6 @@ public class OrgInfoController {
         orgInfo.setBuildTime(DateUtils.getDate());
         boolean b = orgInfoService.updateById(orgInfo);
         if (b) {
-            producer.send(orgInfo, MessageEnum.UPDATE, ServiceEnum.ORG_INFO);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -89,7 +84,6 @@ public class OrgInfoController {
     @GetMapping("/authority/getByIdDelete/{id}")
     public ResultView getByIdDelete(@PathVariable String id) {
         if (orgInfoService.removeById(id)) {
-            producer.send(id, MessageEnum.DELETE, ServiceEnum.ORG_INFO);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/controller/RoleInfoController.java

@@ -3,7 +3,6 @@ package com.unissoft.systemManage.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.RoleInfo;
 import com.unissoft.systemManage.model.UserInfo;
 import com.unissoft.systemManage.service.RoleInfoService;
@@ -23,8 +22,6 @@ import javax.annotation.Resource;
 @RestController
 @RequestMapping("/roleInfo")
 public class RoleInfoController {
-    @Resource
-    private Producer producer;
 
     private RoleInfoService roleInfoService;
 
@@ -51,7 +48,6 @@ public class RoleInfoController {
         roleInfo.setBulidTime(DateUtils.getDate());
         boolean save = roleInfoService.save(roleInfo);
         if (save) {
-            producer.send(roleInfo, MessageEnum.SAVE, ServiceEnum.ROLE_INFO);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -63,7 +59,6 @@ public class RoleInfoController {
         roleInfo.setBulidTime(DateUtils.getDate());
         boolean b = roleInfoService.updateById(roleInfo);
         if (b) {
-            producer.send(roleInfo, MessageEnum.UPDATE, ServiceEnum.ROLE_INFO);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -74,7 +69,6 @@ public class RoleInfoController {
     public ResultView getByIdDeleteRoleInfo(@PathVariable String id) {
         boolean  b= roleInfoService.removeById(id);
         if (b) {
-            producer.send(id, MessageEnum.DELETE, ServiceEnum.ROLE_INFO);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/controller/StorehouseController.java

@@ -2,7 +2,6 @@ package com.unissoft.systemManage.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.OrgInfo;
 import com.unissoft.systemManage.service.OrgInfoService;
 import com.unissoft.systemManage.service.StorehouseClxxService;
@@ -26,8 +25,6 @@ import java.util.Map;
 @RestController
 @RequestMapping("/storehouse")
 public class StorehouseController {
-    @Resource
-    private Producer producer;
 
     private OrgInfoService orgInfoService;
     private StorehouseClxxService storehouseClxxService;
@@ -67,7 +64,6 @@ public class StorehouseController {
             e.printStackTrace();
         }
         if (b) {
-            producer.send(storehouse, MessageEnum.UPDATE, ServiceEnum.STORE_HOUSE);
             return ResultView.success();
         } else {
             return ResultView.error();
@@ -80,7 +76,6 @@ public class StorehouseController {
     public ResultView deleteStorehouse(@PathVariable Integer id) {
         boolean flag = storehouseClxxService.deleteStorehouse(id);
         if (flag) {
-            producer.send(id,MessageEnum.DELETE_STORE_HOUSE, ServiceEnum.STORE_HOUSE);
             return ResultView.success();
         } else {
             return ResultView.error(MyConstant.ID_NULL);
@@ -93,7 +88,6 @@ public class StorehouseController {
     public ResultView deleteStorehouseClxx(@PathVariable String id) {
         boolean flag = storehouseClxxService.removeById(id);
         if (flag) {
-            producer.send(id,MessageEnum.DELETE, ServiceEnum.STORE_HOUSE);
             return ResultView.success();
         } else {
             return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/controller/UserInfoController.java

@@ -4,7 +4,6 @@ package com.unissoft.systemManage.controller;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.UserInfo;
 import com.unissoft.systemManage.service.UserInfoService;
 import com.unissoft.utils.JWTUtil;
@@ -39,8 +38,6 @@ import java.util.UUID;
 public class UserInfoController {
 
     private UserInfoService userInfoService;
-    @Autowired
-    private Producer producer;
 
     @Autowired
     public void setUserInfoController(UserInfoService userInfoService) {
@@ -77,7 +74,6 @@ public class UserInfoController {
         userInfo.setUserId(s);
         boolean save = userInfoService.save(userInfo);
         if (save) {
-            producer.send(userInfo, MessageEnum.SAVE, ServiceEnum.USER_INFO);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -90,7 +86,6 @@ public class UserInfoController {
         userInfo.setUserPassword(MD5Util.getMD5(userInfo.getUserPassword()));
         boolean b = userInfoService.updateById(userInfo);
         if (b) {
-            producer.send(userInfo, MessageEnum.UPDATE, ServiceEnum.USER_INFO);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -100,7 +95,6 @@ public class UserInfoController {
     @GetMapping("/authority/deleteById/{id}")
     public ResultView getByIdForUserDelete(@PathVariable String id) {
         if (userInfoService.removeById(id)) {
-            producer.send(id, MessageEnum.DELETE, ServiceEnum.USER_INFO);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/service/impl/NBasicEdgeServiceImpl.java

@@ -10,7 +10,6 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.unissoft.common.MessageEnum;
 import com.unissoft.common.PageParam;
 import com.unissoft.common.ServiceEnum;
-import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.mapper.NBasicEdgeMapper;
 import com.unissoft.systemManage.mapper.PointDataMapper;
 import com.unissoft.systemManage.model.LogOperation;
@@ -43,8 +42,6 @@ import java.util.List;
  */
 @Service
 public class NBasicEdgeServiceImpl extends ServiceImpl<NBasicEdgeMapper, NBasicEdge> implements NBasicEdgeService  {
-	@Resource
-	private Producer producer;
 
     @Resource
     private NBasicEdgeMapper nBasicEdgeMapper;
@@ -149,9 +146,6 @@ public class NBasicEdgeServiceImpl extends ServiceImpl<NBasicEdgeMapper, NBasicE
 
 
 		int i = nBasicEdgeMapper.insert(nBasicEdge);
-		if (i>=0){
-			producer.send(nBasicEdge, MessageEnum.SAVE, ServiceEnum.NBASIC_EDGE);
-		}
 		return i;
 	}
 

src/main/resources/bootstrap.yml

@@ -13,8 +13,9 @@ spring:
     driver-class-name: com.mysql.cj.jdbc.Driver
     #username: root
     #password: 123456
-    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
+#    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
 #    url: jdbc:mysql://192.168.8.101:3306/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
+    url: jdbc:mysql://localhost:3306/numberec?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
     username: root
 #    password: 123456
     password: 123456
@@ -65,11 +66,4 @@ mybatis-plus:
 # 操作日志版本号,或启动时写入
 version: 20121021
 
-#rocketmq:
-#  name-server: 192.168.8.142:9876 # 访问地址
-#  producer:
-#    group: Grouplocal # 必须指定group
-#    send-message-timeout: 3000 # 消息发送超时时长，默认3s
-#    retry-times-when-send-failed: 3 # 同步发送消息失败重试次数，默认2
-#    retry-times-when-send-async-failed: 3 # 异步发送消息失败重试次数，默认2