java110 пре 3 година
родитељ
комит
f10d13f866

+ 2 - 1
java110-db/src/main/resources/mapper/store/UserStorehouseServiceDaoImplMapper.xml

@@ -164,7 +164,8 @@
         <if test="userName !=null and userName != ''">
             and u.name= #{userName}
         </if>
-        GROUP BY t.us_id
+<!--        这里先注释 因为 mysql 8.0  有问题 后面遇到问题 分析 为啥重复 优化 sql-->
+<!--        GROUP BY t.us_id-->
         order by t.create_time desc
         <if test="page != -1 and page != null ">
             limit #{page}, #{row}

+ 4 - 0
service-job/src/main/java/com/java110/job/JobServiceApplication.java

@@ -1,6 +1,8 @@
 package com.java110.job;
 
+import com.java110.core.annotation.Java110CmdDiscovery;
 import com.java110.core.annotation.Java110ListenerDiscovery;
+import com.java110.core.event.cmd.ServiceCmdEventPublishing;
 import com.java110.core.trace.Java110RestTemplateInterceptor;
 import com.java110.core.client.RestTemplate;
 import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing;
@@ -35,6 +37,8 @@ import java.nio.charset.Charset;
 @EnableDiscoveryClient
 @Java110ListenerDiscovery(listenerPublishClass = BusinessServiceDataFlowEventPublishing.class,
         basePackages = {"com.java110.job.listener"})
+@Java110CmdDiscovery(cmdPublishClass = ServiceCmdEventPublishing.class,
+        basePackages = {"com.java110.job.cmd"})
 @EnableFeignClients(basePackages = {
         "com.java110.intf.community",
         "com.java110.intf.common",

+ 26 - 0
service-job/src/main/java/com/java110/job/cmd/export/ExportDataCmd.java

@@ -0,0 +1,26 @@
+package com.java110.job.cmd.export;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.utils.exception.CmdException;
+
+import java.text.ParseException;
+
+/**
+ * 数据导出处理类
+ */
+@Java110Cmd(serviceCode = "export.exportData")
+public class ExportDataCmd extends Cmd {
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+
+    }
+}