条件查询

generated/com/miniframe/generate/comm/system/A_C00001.java

@@ -48,17 +48,4 @@ public class A_C00001 extends BaseMapModel implements Serializable {
 	public String getSearchtag() {
 		return this.searchtag;
 	}
-	String isshare;//是否公开
-	/**
-	 *是否公开
-	 */
-	public void setIsshare(String isshare) {
-		this.isshare=isshare;
-	}
-	/**
-	 *是否公开
-	 */
-	public String getIsshare() {
-		return this.isshare;
-	}
 }

generated/validator/resources_a_c00001Form_validator.properties

@@ -1,5 +1,4 @@
 a_c00001.count = \u6BCF\u9875\u663E\u793A\u6761\u6570
 a_c00001.page = \u5F53\u524D\u9875\u6570
 a_c00001.searchtag = \u67E5\u8BE2\u6761\u4EF6
-a_c00001.isshare = \u662F\u5426\u516C\u5F00
 a_c00001Form = true

generated/validator/resources_a_c00001Form_validator_zh_CN.properties

@@ -1,5 +1,4 @@
 a_c00001.count = \u6BCF\u9875\u663E\u793A\u6761\u6570
 a_c00001.page = \u5F53\u524D\u9875\u6570
 a_c00001.searchtag = \u67E5\u8BE2\u6761\u4EF6
-a_c00001.isshare = \u662F\u5426\u516C\u5F00
 a_c00001Form = true

src/main/java/com/miniframe/service/mq/CaeMQ.java

@@ -46,7 +46,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
     public CaeMQ(MFMqConfig mfMqConfig) {
         super(mfMqConfig);
 //        setLocalMqOp(new CaeMqOp(),"caedyout");//设置监听
-        setLocalMqOp(new CaeMqOp(),"caeout");//设置监听
+        setLocalMqOp(new CaeMqOp(),"caeoutt");//设置监听
 //        setDefOp(new CaeMqOp());//设置默认监听
     }
 
@@ -57,7 +57,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
 
     @Override
     public String[] declareListenerQueueLocal(){
-        return new String[]{"caeout"};
+        return new String[]{"caeoutt"};
 //        return new String[]{};
     }
 
@@ -67,8 +67,8 @@ public class CaeMQ extends CaeViewMFMqDynamic {
         //TTLMS: 0，不设置x-message-ttl 参数
         //enableDlx : false 不申明dlx queue
         List<MFMqInfo> mfMqInfoList=new ArrayList<>();
-        mfMqInfoList.add(new MFMqInfo("caein","caein",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
-        mfMqInfoList.add(new MFMqInfo("caeout","caeout",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
+        mfMqInfoList.add(new MFMqInfo("caeint","caeint",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
+        mfMqInfoList.add(new MFMqInfo("caeoutt","caeoutt",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
         return mfMqInfoList;
     }
 
@@ -77,14 +77,14 @@ public class CaeMQ extends CaeViewMFMqDynamic {
      * @param data
      */
     public void sendCaein(String data){
-        sendData("caein",data);
+        sendData("caeint",data);
     }
     /**
      * 向未处理信息队列 发送消息
      * @param data
      */
     public void sendCaeout(String data){
-        sendData("caeout",data);
+        sendData("caeoutt",data);
     }
 
     /**
@@ -93,7 +93,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
     public static class CaeMqOp implements IMFMqOp {
         @Override
         public boolean handle(String data, long deliveryTag, Map<String, Object> headers, Channel channel) throws Exception {
-//            System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
+            System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
             try {
                 ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
                 WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");

系统设计/通信设计/通讯报文/system(系统服务)/报文体/C00001_A(项目查询).csv

@@ -2,4 +2,3 @@
 1,count,每页显示条数,int,,,,,,,,,,,
 2,page,当前页数,int,,,,,,,,,,,
 3,searchtag,查询条件,string,,,,,,,,,,,
-4,isshare,是否公开,string,,,是,,,,,,,,