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

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Service;
 /**
  * ClassName: ConService
  * Package: com.unissoft.mqConsumer
- * Description:
+ * Description:新增，修改，删除
  *
  * @Author zlq
  * @Create 2023/3/2 10:36
@@ -31,7 +31,6 @@ public class TeDataConsumer{
          */
         @Override
         public void onMessage(TeData teData) {
-            
             System.out.println("接收到的消息"+teData.toString());
         }
     }

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

@@ -22,7 +22,7 @@ import org.springframework.stereotype.Component;
 @Component("producer")
 public class Producer {
     //topic名称
-    private static final String topic="TOPIC_LOCAL";
+    private final String topic="TOPIC_LOCAL:";
 
     @Autowired
     private RocketMQTemplate rocketMQTemplate;
@@ -33,7 +33,7 @@ public class Producer {
      * @param tag  消息类型
      */
     public void send(Object msgBody, String tag){
-        rocketMQTemplate.convertAndSend(topic+":"+tag,msgBody);
+        rocketMQTemplate.convertAndSend(topic+tag,msgBody);
     }
 
     /**
@@ -43,7 +43,7 @@ public class Producer {
      * @return
      */
     public SendResult sendMsg(String msgBody,String tag) {
-        SendResult sendResult = rocketMQTemplate.syncSend(topic+":"+tag, MessageBuilder.withPayload(msgBody).build());
+        SendResult sendResult = rocketMQTemplate.syncSend(topic+tag, MessageBuilder.withPayload(msgBody).build());
         return sendResult;
     }
 

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

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.PageParam;
 import com.unissoft.common.ResultView;
 import com.unissoft.common.SystemLog;
+import com.unissoft.mqProducer.Producer;
 import com.unissoft.parameter.model.HardwareParameter;
 import com.unissoft.parameter.service.HardwareParameterService;
 
@@ -33,6 +34,9 @@ public class HardwareParameterController {
     private HardwareParameterService hdService;
 
     @Autowired
+    private Producer producer;
+
+    @Autowired
     public void setHardwareParameterController(HardwareParameterService hdService) {
         this.hdService = hdService;
     }
@@ -61,9 +65,10 @@ public class HardwareParameterController {
     public ResultView saveUser(@RequestBody HardwareParameter hdParameter) {
     	hdParameter.setCreateTime(new Date());
         boolean save = hdService.save(hdParameter);
-        if (save)
+        if (save) {
+            producer.send(hdParameter, "HP_SAVE");
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
@@ -76,9 +81,10 @@ public class HardwareParameterController {
     @PostMapping("/update")
     public ResultView updateUser(@RequestBody HardwareParameter hdParameter) {
         boolean b = hdService.updateById(hdParameter);
-        if (b)
+        if (b) {
+            producer.send(hdParameter, "HP_UPDATE");
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
     
@@ -91,12 +97,20 @@ public class HardwareParameterController {
     @SystemLog(operModul = "参数设置", operType = "硬件参数", operDesc = "硬件参数删除")
     @ApiOperation(value = "根据id删除", notes = "")
     @DeleteMapping("/deleteById/{id}")
-    public ResultView deleteById(@PathVariable Integer id) {
+    public ResultView deleteById(@PathVariable String id) {
     	boolean b = hdService.removeById(id);
-    	if (b)
+        int i = hdService.deleteHarParamer(id);
+        if(i>0){
+            producer.send(id, "HP_DELETE");
             return ResultView.success();
-        else
+        }else {
             return ResultView.error();
+        }
+//        if (b) {
+//            producer.send(id, "HP_DELETE");
+//            return ResultView.success();
+//        }else
+//            return ResultView.error();
     }
     
 }

src/main/java/com/unissoft/parameter/model/HardwareParameter.java

@@ -28,8 +28,8 @@ public class HardwareParameter implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "硬件参数表")
-    @TableId(value = "id", type = IdType.AUTO)
-    private Integer id;
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private String id;
 
     @ApiModelProperty(value = "仓房id")
     @TableField("house_id")
@@ -55,11 +55,11 @@ public class HardwareParameter implements Serializable {
     @TableField("create_time")
     private Date createTime;
 
-	public Integer getId() {
+	public String getId() {
 		return id;
 	}
 
-	public void setId(Integer id) {
+	public void setId(String id) {
 		this.id = id;
 	}
 

src/main/java/com/unissoft/parameter/service/HardwareParameterService.java

@@ -18,5 +18,7 @@ public interface HardwareParameterService extends IService<HardwareParameter> {
 
 	IPage<HardwareParameter> getPage(PageParam pageParam);
 
+	int deleteHarParamer(String id);
+
 
 }

src/main/java/com/unissoft/parameter/service/impl/HardwareParameterServiceImpl.java

@@ -56,7 +56,13 @@ public class HardwareParameterServiceImpl extends ServiceImpl<HardwareParameterM
         }
         return hdMapper.selectPage(page, ew);
 	}
-	
-	
+
+	@Override
+	public int deleteHarParamer(String id) {
+		int i = hdMapper.deleteById(id);
+
+		return i;
+	}
+
 
 }