Просмотр исходного кода

查询字典 调整为修改cmd 成功

java110 лет назад: 4
Родитель
Сommit
0b1e1b0ee9

+ 4 - 0
service-community/src/main/java/com/java110/community/CommunityServiceApplicationStart.java

@@ -15,8 +15,10 @@
  */
 package com.java110.community;
 
+import com.java110.core.annotation.Java110CmdDiscovery;
 import com.java110.core.annotation.Java110ListenerDiscovery;
 import com.java110.core.client.RestTemplate;
+import com.java110.core.event.cmd.ServiceCmdEventPublishing;
 import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing;
 import com.java110.service.init.ServiceStartInit;
 import org.slf4j.Logger;
@@ -48,6 +50,8 @@ import java.nio.charset.Charset;
 @EnableDiscoveryClient
 @Java110ListenerDiscovery(listenerPublishClass = BusinessServiceDataFlowEventPublishing.class,
         basePackages = {"com.java110.community.listener"})
+@Java110CmdDiscovery(cmdPublishClass = ServiceCmdEventPublishing.class,
+        basePackages = {"com.java110.community.cmd"})
 @EnableFeignClients(basePackages = {"com.java110.intf.user", "com.java110.intf.common", "com.java110.intf.fee",
         "com.java110.intf.order"})
 public class CommunityServiceApplicationStart {

+ 42 - 0
service-community/src/main/java/com/java110/community/cmd/dict/QueryDictCmd.java

@@ -0,0 +1,42 @@
+package com.java110.community.cmd.dict;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.AbstractServiceCmdListener;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.dto.Dict.DictDto;
+import com.java110.dto.Dict.DictQueryDto;
+import com.java110.intf.community.DictInnerServiceSMO;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.BeanConvertUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+import java.util.List;
+
+/**
+ * 保存编码映射处理类
+ */
+@Java110Cmd(serviceCode = "dict.queryDict")
+public class QueryDictCmd extends AbstractServiceCmdListener {
+    private final static Logger logger = LoggerFactory.getLogger(QueryDictCmd.class);
+
+    @Autowired
+    private DictInnerServiceSMO dictInnerServiceSMO;
+
+    @Override
+    protected void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+
+    }
+
+    @Override
+    protected void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+        List<DictDto> dictDtos = this.dictInnerServiceSMO.queryDict(BeanConvertUtil.covertBean(reqJson, DictQueryDto.class));
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(dictDtos), HttpStatus.OK);
+        cmdDataFlowContext.setResponseEntity(responseEntity);
+    }
+}

+ 1 - 2
service-user/src/main/java/com/java110/user/cmd/PcUserLoginCmd.java

@@ -1,8 +1,7 @@
-package com.java110.user.cmd;
+package com.java110.user.cmd.login;
 
 import com.alibaba.fastjson.JSONObject;
 import com.java110.core.annotation.Java110Cmd;
-import com.java110.core.context.DataFlowContext;
 import com.java110.core.context.ICmdDataFlowContext;
 import com.java110.core.event.cmd.AbstractServiceCmdListener;
 import com.java110.core.event.cmd.CmdEvent;