优化 springboot 启动方式功能

service-api/src/main/java/com/java110/api/listener/task/DeleteTaskListener.java

@@ -1,49 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.task.ITaskBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.Assert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-
-/**
- * 保存小区侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("deleteTaskListener")
-public class DeleteTaskListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private ITaskBMO taskBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "taskId", "taskId不能为空");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        taskBMOImpl.deleteTask(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.DELETE_TASK;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/task/ListTaskTemplateListener.java

@@ -1,82 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.job.ITaskInnerServiceSMO;
-import com.java110.dto.task.TaskTemplateDto;
-import com.java110.vo.ResultVo;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.BeanConvertUtil;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 查询任务模板
- */
-@Java110Listener("listTaskTemplateListener")
-public class ListTaskTemplateListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private ITaskInnerServiceSMO taskInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.LIST_TASK_TEMPLATE;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public ITaskInnerServiceSMO getTaskInnerServiceSMOImpl() {
-        return taskInnerServiceSMOImpl;
-    }
-
-    public void setTaskInnerServiceSMOImpl(ITaskInnerServiceSMO taskInnerServiceSMOImpl) {
-        this.taskInnerServiceSMOImpl = taskInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        super.validatePageInfo(reqJson);
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        TaskTemplateDto taskTemplateDto = BeanConvertUtil.covertBean(reqJson, TaskTemplateDto.class);
-
-        int count = taskInnerServiceSMOImpl.queryTaskTemplateCount(taskTemplateDto);
-
-        List<TaskTemplateDto> taskTemplateDtos = null;
-
-        if (count > 0) {
-            taskTemplateDtos = taskInnerServiceSMOImpl.queryTaskTemplate(taskTemplateDto);
-        } else {
-            taskTemplateDtos = new ArrayList<>();
-        }
-
-        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, taskTemplateDtos);
-
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-        context.setResponseEntity(responseEntity);
-
-    }
-}

service-api/src/main/java/com/java110/api/listener/task/ListTaskTemplateSpecListener.java

@@ -1,82 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.job.ITaskInnerServiceSMO;
-import com.java110.dto.task.TaskTemplateSpecDto;
-import com.java110.vo.ResultVo;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.BeanConvertUtil;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 查询任务模板属性
- */
-@Java110Listener("listTaskTemplateSpecListener")
-public class ListTaskTemplateSpecListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private ITaskInnerServiceSMO taskInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.LIST_TASK_TEMPLATE_SPEC;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public ITaskInnerServiceSMO getTaskInnerServiceSMOImpl() {
-        return taskInnerServiceSMOImpl;
-    }
-
-    public void setTaskInnerServiceSMOImpl(ITaskInnerServiceSMO taskInnerServiceSMOImpl) {
-        this.taskInnerServiceSMOImpl = taskInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        super.validatePageInfo(reqJson);
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        TaskTemplateSpecDto taskTemplateSpecDto = BeanConvertUtil.covertBean(reqJson, TaskTemplateSpecDto.class);
-
-        int count = taskInnerServiceSMOImpl.queryTaskTemplateSpecCount(taskTemplateSpecDto);
-
-        List<TaskTemplateSpecDto> taskTemplateSpecDtos = null;
-
-        if (count > 0) {
-            taskTemplateSpecDtos = taskInnerServiceSMOImpl.queryTaskTemplateSpec(taskTemplateSpecDto);
-        } else {
-            taskTemplateSpecDtos = new ArrayList<>();
-        }
-
-        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, taskTemplateSpecDtos);
-
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-        context.setResponseEntity(responseEntity);
-
-    }
-}

service-api/src/main/java/com/java110/api/listener/task/ListTasksListener.java

@@ -1,105 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.job.ITaskInnerServiceSMO;
-import com.java110.intf.job.ITaskAttrInnerServiceSMO;
-import com.java110.dto.task.TaskDto;
-import com.java110.dto.taskAttr.TaskAttrDto;
-import com.java110.vo.ResultVo;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.BeanConvertUtil;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 查询小区侦听类
- */
-@Java110Listener("listTasksListener")
-public class ListTasksListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private ITaskInnerServiceSMO taskInnerServiceSMOImpl;
-
-    @Autowired
-    private ITaskAttrInnerServiceSMO taskAttrInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.LIST_TASKS;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public ITaskInnerServiceSMO getTaskInnerServiceSMOImpl() {
-        return taskInnerServiceSMOImpl;
-    }
-
-    public void setTaskInnerServiceSMOImpl(ITaskInnerServiceSMO taskInnerServiceSMOImpl) {
-        this.taskInnerServiceSMOImpl = taskInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        super.validatePageInfo(reqJson);
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        TaskDto taskDto = BeanConvertUtil.covertBean(reqJson, TaskDto.class);
-
-        int count = taskInnerServiceSMOImpl.queryTasksCount(taskDto);
-
-        List<TaskDto> taskDtos = null;
-
-        if (count > 0) {
-            taskDtos = taskInnerServiceSMOImpl.queryTasks(taskDto);
-            freshTaskAttr(taskDtos);
-        } else {
-            taskDtos = new ArrayList<>();
-        }
-
-        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, taskDtos);
-
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-        context.setResponseEntity(responseEntity);
-
-    }
-
-    /**
-     * 查询属性
-     *
-     * @param taskDtos
-     */
-    private void freshTaskAttr(List<TaskDto> taskDtos) {
-
-        for (TaskDto taskDto : taskDtos) {
-            TaskAttrDto taskAttrDto = new TaskAttrDto();
-            taskAttrDto.setTaskId(taskDto.getTaskId());
-            List<TaskAttrDto> taskAttrDtos = taskAttrInnerServiceSMOImpl.queryTaskAttrs(taskAttrDto);
-            taskDto.setTaskAttr(taskAttrDtos);
-        }
-
-
-    }
-}

service-api/src/main/java/com/java110/api/listener/task/SaveTaskListener.java

@@ -1,49 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.task.ITaskBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.Assert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-/**
- * 保存商户侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("saveTaskListener")
-public class SaveTaskListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private ITaskBMO taskBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "taskName", "请求报文中未包含taskName");
-        Assert.hasKeyAndValue(reqJson, "templateId", "请求报文中未包含templateId");
-        Assert.hasKeyAndValue(reqJson, "taskCron", "请求报文中未包含taskCron");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        taskBMOImpl.addTask(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.ADD_TASK;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/task/StartTaskListener.java

@@ -1,73 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.job.ITaskInnerServiceSMO;
-import com.java110.dto.task.TaskDto;
-import com.java110.vo.ResultVo;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.Assert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.List;
-
-/**
- * 保存商户侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("startTaskListener")
-public class StartTaskListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private ITaskInnerServiceSMO taskInnerServiceSMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "taskId", "请求报文中未包含taskName");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        TaskDto taskDto = new TaskDto();
-        taskDto.setTaskId(reqJson.getString("taskId"));
-        List<TaskDto> taskDtos = taskInnerServiceSMOImpl.queryTasks(taskDto);
-        ResultVo resultVo = null;
-        if (taskDtos == null || taskDtos.size() < 1) {
-            resultVo = new ResultVo(ResultVo.ORDER_ERROR, "传入任务ID错误");
-            ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-            context.setResponseEntity(responseEntity);
-            return;
-        }
-        int state = taskInnerServiceSMOImpl.startTask(taskDtos.get(0));
-
-        if(state >0){
-            resultVo = new ResultVo(ResultVo.CODE_OK, "启动成功");
-        }else{
-            resultVo = new ResultVo(ResultVo.ORDER_ERROR, "启动失败");
-        }
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-        context.setResponseEntity(responseEntity);
-        return;
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.START_TASK;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/task/StopTaskListener.java

@@ -1,73 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.job.ITaskInnerServiceSMO;
-import com.java110.dto.task.TaskDto;
-import com.java110.vo.ResultVo;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.Assert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.List;
-
-/**
- * 保存商户侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("stopTaskListener")
-public class StopTaskListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private ITaskInnerServiceSMO taskInnerServiceSMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "taskId", "请求报文中未包含taskName");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        TaskDto taskDto = new TaskDto();
-        taskDto.setTaskId(reqJson.getString("taskId"));
-        List<TaskDto> taskDtos = taskInnerServiceSMOImpl.queryTasks(taskDto);
-        ResultVo resultVo = null;
-        if (taskDtos == null || taskDtos.size() < 1) {
-            resultVo = new ResultVo(ResultVo.ORDER_ERROR, "传入任务ID错误");
-            ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-            context.setResponseEntity(responseEntity);
-            return;
-        }
-        int state = taskInnerServiceSMOImpl.stopTask(taskDtos.get(0));
-
-        if(state >0){
-            resultVo = new ResultVo(ResultVo.CODE_OK, "停止成功");
-        }else{
-            resultVo = new ResultVo(ResultVo.ORDER_ERROR, "停止失败");
-        }
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-        context.setResponseEntity(responseEntity);
-        return;
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.STOP_TASK;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/task/UpdateTaskListener.java

@@ -1,49 +0,0 @@
-package com.java110.api.listener.task;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.task.ITaskBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeTaskConstant;
-import com.java110.utils.util.Assert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-/**
- * 保存定时任务侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("updateTaskListener")
-public class UpdateTaskListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private ITaskBMO taskBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-
-        Assert.hasKeyAndValue(reqJson, "taskId", "taskId不能为空");
-        Assert.hasKeyAndValue(reqJson, "taskName", "请求报文中未包含taskName");
-        Assert.hasKeyAndValue(reqJson, "templateId", "请求报文中未包含templateId");
-        Assert.hasKeyAndValue(reqJson, "taskCron", "请求报文中未包含taskCron");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        taskBMOImpl.updateTask(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeTaskConstant.UPDATE_TASK;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-}

service-api/src/main/java/com/java110/api/listener/user/ChangeStaffPwdListener.java

@@ -1,74 +0,0 @@
-package com.java110.api.listener.user;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.user.IUserBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.factory.AuthenticationFactory;
-import com.java110.intf.user.IUserInnerServiceSMO;
-import com.java110.entity.center.AppService;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeConstant;
-import com.java110.utils.util.Assert;
-import org.slf4j.Logger;
-import com.java110.core.log.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-/**
- * 修改员工 2018年12月6日
- * Created by wuxw on 2018/5/18.
- */
-@Java110Listener("changeStaffPwdServiceListener")
-public class ChangeStaffPwdListener extends AbstractServiceApiPlusListener {
-
-    private final static Logger logger = LoggerFactory.getLogger(ChangeStaffPwdListener.class);
-
-    @Autowired
-    private IUserInnerServiceSMO userInnerServiceSMOImpl;
-    @Autowired
-    private IUserBMO userBMOImpl;
-
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.SERVICE_CODE_CHANGE_STAFF_PWD;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return 0;
-    }
-
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-//获取数据上下文对象
-        DataFlowContext dataFlowContext = event.getDataFlowContext();
-        AppService service = event.getAppService();
-        String paramIn = dataFlowContext.getReqData();
-        Assert.isJsonObject(paramIn, "添加员工时请求参数有误，不是有效的json格式 " + paramIn);
-        JSONObject paramInJson = JSONObject.parseObject(paramIn);
-        Assert.jsonObjectHaveKey(paramInJson, "userId", "请求参数中未包含userId 节点，请确认");
-        Assert.jsonObjectHaveKey(paramInJson, "oldPwd", "请求参数中未包含oldPwd 节点，请确认");
-        Assert.jsonObjectHaveKey(paramInJson, "newPwd", "请求参数中未包含newPwd 节点，请确认");
-
-        paramInJson.put("oldPwd", AuthenticationFactory.passwdMd5(paramInJson.getString("oldPwd")));
-        paramInJson.put("newPwd", AuthenticationFactory.passwdMd5(paramInJson.getString("newPwd")));
-
-        userBMOImpl.modifyStaff(paramInJson, dataFlowContext);
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/user/ListUsersListener.java

@@ -1,89 +0,0 @@
-package com.java110.api.listener.user;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.intf.user.IUserInnerServiceSMO;
-import com.java110.dto.user.UserDto;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeConstant;
-import com.java110.utils.util.BeanConvertUtil;
-import com.java110.vo.api.user.ApiUserDataVo;
-import com.java110.vo.api.user.ApiUserVo;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.ArrayList;
-import java.util.List;
-
-
-/**
- * 查询小区侦听类
- */
-@Java110Listener("listUsersListener")
-public class ListUsersListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private IUserInnerServiceSMO userInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.LIST_USERS;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
-        return userInnerServiceSMOImpl;
-    }
-
-    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
-        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        super.validatePageInfo(reqJson);
-        //Assert.hasKeyAndValue(reqJson, "storeId", "必填，请填写商户ID");
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        UserDto userDto = BeanConvertUtil.covertBean(reqJson, UserDto.class);
-
-        int count = userInnerServiceSMOImpl.getUserCount(userDto);
-
-        List<ApiUserDataVo> users = null;
-
-        if (count > 0) {
-            List<UserDto> userDtos = userInnerServiceSMOImpl.getUsers(userDto);
-            users = BeanConvertUtil.covertBeanList(userDtos, ApiUserDataVo.class);
-        } else {
-            users = new ArrayList<>();
-        }
-
-        ApiUserVo apiOrgVo = new ApiUserVo();
-
-        apiOrgVo.setTotal(count);
-        apiOrgVo.setRecords((int) Math.ceil((double) count / (double) reqJson.getInteger("row")));
-        apiOrgVo.setUsers(users);
-
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(apiOrgVo), HttpStatus.OK);
-
-        context.setResponseEntity(responseEntity);
-    }
-}

service-api/src/main/java/com/java110/api/listener/user/QueryUserSecretListener.java

@@ -1,88 +0,0 @@
-package com.java110.api.listener.user;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.user.IUserInnerServiceSMO;
-import com.java110.dto.user.UserAttrDto;
-import com.java110.dto.user.UserDto;
-import com.java110.utils.constant.ServiceCodeConstant;
-import com.java110.utils.util.Assert;
-import com.java110.utils.util.BeanConvertUtil;
-import com.java110.vo.ResultVo;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.ResponseEntity;
-
-import java.util.List;
-
-
-/**
- * 这个类专门查询用户秘钥信息
- */
-@Java110Listener("queryUserSecretListener")
-public class QueryUserSecretListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private IUserInnerServiceSMO userInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.QUERY_USER_SECRET;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
-        return userInnerServiceSMOImpl;
-    }
-
-    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
-        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //super.validatePageInfo(reqJson);
-        Assert.hasKeyAndValue(reqJson, "userId", "请求报文中未包含用户ID");
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        ResponseEntity<String> responseEntity = null;
-        UserDto userDto = BeanConvertUtil.covertBean(reqJson, UserDto.class);
-
-        List<UserDto> userDtos = userInnerServiceSMOImpl.getUsers(userDto);
-
-        if (userDtos == null || userDtos.size() < 1) {
-            responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "未找到用户信息");
-            context.setResponseEntity(responseEntity);
-            return;
-        }
-
-        userDto = userDtos.get(0);
-        List<UserAttrDto> userAttrDtos = userDto.getUserAttrs();
-        String key = "";
-        String openId = "";
-        for (UserAttrDto userAttrDto : userAttrDtos) {
-            if (UserAttrDto.SPEC_KEY.equals(userAttrDto.getSpecCd())) {
-                key = userAttrDto.getValue();
-            }
-
-            if (UserAttrDto.SPEC_OPEN_ID.equals(userAttrDto.getSpecCd())) {
-                openId = userAttrDto.getValue();
-            }
-        }
-        userDto.setKey(key);
-        userDto.setOpenId(openId);
-        responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, "成功", userDto);
-        context.setResponseEntity(responseEntity);
-    }
-}

service-api/src/main/java/com/java110/api/listener/user/UserLoginListener.java

@@ -1,191 +0,0 @@
-package com.java110.api.listener.user;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.core.factory.AuthenticationFactory;
-import com.java110.dto.msg.SmsDto;
-import com.java110.dto.user.UserAttrDto;
-import com.java110.dto.user.UserDto;
-import com.java110.intf.common.ISmsInnerServiceSMO;
-import com.java110.intf.user.IUserAttrV1InnerServiceSMO;
-import com.java110.intf.user.IUserInnerServiceSMO;
-import com.java110.po.userAttr.UserAttrPo;
-import com.java110.utils.cache.CommonCache;
-import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.CommonConstant;
-import com.java110.utils.constant.ResponseConstant;
-import com.java110.utils.constant.ServiceCodeConstant;
-import com.java110.utils.exception.SMOException;
-import com.java110.utils.util.Assert;
-import com.java110.utils.util.BeanConvertUtil;
-import com.java110.utils.util.StringUtil;
-import com.java110.utils.util.ValidatorUtil;
-import com.java110.vo.ResultVo;
-import org.slf4j.Logger;
-import com.java110.core.log.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-
-/**
- * 用户注册 侦听
- * Created by wuxw on 2018/5/18.
- */
-@Java110Listener("userLoginListener")
-public class UserLoginListener extends AbstractServiceApiPlusListener {
-
-    private final static Logger logger = LoggerFactory.getLogger(UserLoginListener.class);
-
-
-    @Autowired
-    private IUserInnerServiceSMO userInnerServiceSMOImpl;
-
-    @Autowired
-    private IUserAttrV1InnerServiceSMO userAttrV1InnerServiceSMOImpl;
-
-    @Autowired
-    private ISmsInnerServiceSMO smsInnerServiceSMOImpl;
-
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.SERVICE_CODE_USER_LOGIN;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-
-        if (!reqJson.containsKey("userName")) {
-            Assert.hasKeyAndValue(reqJson, "key", "未包含key");
-        }
-
-        if (!reqJson.containsKey("key")) {
-            Assert.hasKeyAndValue(reqJson, "userName", "未包含userName");
-            Assert.hasKeyAndValue(reqJson, "password", "未包含password");
-        }
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        //1.0 优先用 手机号登录
-        UserDto userDto = new UserDto();
-        String errorInfo = "";
-        if (reqJson.containsKey("levelCd")) {
-            userDto.setLevelCd(reqJson.getString("levelCd"));
-        }
-        if (reqJson.containsKey("userName")) {
-            if (ValidatorUtil.isMobile(reqJson.getString("userName"))) {//用户临时秘钥登录
-                userDto.setTel(reqJson.getString("userName"));
-            } else {
-                userDto.setUserName(reqJson.getString("userName"));
-            }
-            //验证码登录
-            if (reqJson.containsKey("loginByPhone") && reqJson.getBoolean("loginByPhone")) {
-                SmsDto smsDto = new SmsDto();
-                smsDto.setTel(reqJson.getString("userName"));
-                smsDto.setCode(reqJson.getString("password"));
-                smsDto = smsInnerServiceSMOImpl.validateCode(smsDto);
-                if (!smsDto.isSuccess()) {
-                    throw new SMOException("验证码错误");
-                }
-
-            } else {
-                userDto.setPassword(AuthenticationFactory.passwdMd5(reqJson.getString("password")));
-            }
-            errorInfo = "用户名或密码错误";
-        } else {
-            userDto.setKey(reqJson.getString("key"));
-            errorInfo = "临时票据错误";
-        }
-
-
-        List<UserDto> userDtos = userInnerServiceSMOImpl.getUsers(userDto);
-
-        if (userDtos == null || userDtos.size() < 1) {
-            throw new SMOException(errorInfo);
-        }
-
-        //表名登录成功
-        UserDto tmpUserDto = userDtos.get(0);
-
-        List<UserAttrDto> userAttrDtos = tmpUserDto.getUserAttrs();
-
-        UserAttrDto userAttrDto = getCurrentUserAttrDto(userAttrDtos, UserAttrDto.SPEC_KEY);
-        String newKey = UUID.randomUUID().toString();
-        if (userAttrDto != null) {
-            UserAttrPo userAttrPo = BeanConvertUtil.covertBean(userAttrDto, UserAttrPo.class);
-            userAttrPo.setValue(newKey);
-            userAttrPo.setStatusCd("0");
-            //super.update(context, userAttrPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_USER_ATTR_INFO);
-            userAttrV1InnerServiceSMOImpl.updateUserAttr(userAttrPo);
-        } else {
-            UserAttrPo userAttrPo = new UserAttrPo();
-            userAttrPo.setAttrId("-1");
-            userAttrPo.setUserId(tmpUserDto.getUserId());
-            userAttrPo.setSpecCd(UserAttrDto.SPEC_KEY);
-            userAttrPo.setValue(newKey);
-            userAttrPo.setStatusCd("0");
-            //super.insert(context, userAttrPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_USER_ATTR_INFO);
-            userAttrV1InnerServiceSMOImpl.saveUserAttr(userAttrPo);
-        }
-
-
-        try {
-            Map userMap = new HashMap();
-            userMap.put(CommonConstant.LOGIN_USER_ID, tmpUserDto.getUserId());
-            userMap.put(CommonConstant.LOGIN_USER_NAME, tmpUserDto.getUserName());
-            String token = AuthenticationFactory.createAndSaveToken(userMap);
-            tmpUserDto.setPassword("");
-            tmpUserDto.setToken(token);
-            tmpUserDto.setKey(newKey);
-            context.setResponseEntity(ResultVo.createResponseEntity(tmpUserDto));
-        } catch (Exception e) {
-            logger.error("登录异常：", e);
-            throw new SMOException(ResponseConstant.RESULT_CODE_INNER_ERROR, "系统内部错误，请联系管理员");
-        }
-    }
-
-    private UserAttrDto getCurrentUserAttrDto(List<UserAttrDto> userAttrDtos, String specCd) {
-        if (userAttrDtos == null) {
-            return null;
-        }
-        for (UserAttrDto userAttrDto : userAttrDtos) {
-            if (specCd.equals(userAttrDto.getSpecCd())) {
-                return userAttrDto;
-            }
-        }
-
-        return null;
-    }
-
-    /**
-     * 对请求报文处理
-     *
-     * @param paramIn
-     * @return
-     */
-    private JSONObject refreshParamIn(String paramIn) {
-        JSONObject paramObj = JSONObject.parseObject(paramIn);
-        paramObj.put("userId", "-1");
-        paramObj.put("levelCd", "0");
-
-        return paramObj;
-    }
-
-
-}

service-api/src/main/java/com/java110/api/listener/user/UserLogoutServiceListener.java

@@ -1,87 +0,0 @@
-package com.java110.api.listener.user;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiDataFlowListener;
-import com.java110.utils.constant.ServiceCodeConstant;
-import com.java110.utils.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.factory.AuthenticationFactory;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import org.slf4j.Logger;
-import com.java110.core.log.LoggerFactory;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-/**
- * 用户退出登录
- * Created by wuxw on 2018/5/18.
- */
-@Java110Listener("userLogoutServiceListener")
-public class UserLogoutServiceListener extends AbstractServiceApiDataFlowListener{
-
-    private final static Logger logger = LoggerFactory.getLogger(UserLogoutServiceListener.class);
-
-
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.SERVICE_CODE_USER_SERVICE_LOGOUT;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return 0;
-    }
-
-
-    /**
-     * 校验用户登录：
-     *
-     * @param event
-     */
-    @Override
-    public void soService(ServiceDataFlowEvent event) {
-        //获取数据上下文对象
-        DataFlowContext dataFlowContext = event.getDataFlowContext();
-        String paramIn = dataFlowContext.getReqData();
-        Assert.isJsonObject(paramIn,"用户注册请求参数有误，不是有效的json格式 "+paramIn);
-        Assert.jsonObjectHaveKey(paramIn,"token","请求报文中未包含token 节点请检查");
-        JSONObject paramObj = JSONObject.parseObject(paramIn);
-        ResponseEntity responseEntity= null;
-        try {
-            //删除 token 信息
-            AuthenticationFactory.deleteToken(paramObj.getString("token"));
-            responseEntity = new ResponseEntity<String>("退出登录成功", HttpStatus.OK);
-        } catch (Exception e) {
-            //Invalid signature/claims
-            responseEntity = new ResponseEntity<String>("退出登录失败，请联系管理员", HttpStatus.UNAUTHORIZED);
-        }
-        dataFlowContext.setResponseEntity(responseEntity);
-    }
-
-    /**
-     * 对请求报文处理
-     * @param paramIn
-     * @return
-     */
-    private JSONObject refreshParamIn(String paramIn){
-        JSONObject paramObj = JSONObject.parseObject(paramIn);
-        paramObj.put("userId","-1");
-        paramObj.put("levelCd","0");
-
-        return paramObj;
-    }
-
-
-
-
-
-}

service-api/src/main/java/com/java110/api/listener/user/UserSendSmsListener.java

@@ -1,135 +0,0 @@
-package com.java110.api.listener.user;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.factory.SendSmsFactory;
-import com.java110.dto.owner.OwnerDto;
-import com.java110.intf.common.ISmsInnerServiceSMO;
-import com.java110.intf.user.IOwnerInnerServiceSMO;
-import com.java110.intf.user.IUserInnerServiceSMO;
-import com.java110.dto.msg.SmsDto;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.cache.CommonCache;
-import com.java110.utils.cache.MappingCache;
-import com.java110.utils.constant.ServiceCodeConstant;
-import com.java110.utils.util.Assert;
-import com.java110.utils.util.StringUtil;
-import com.java110.utils.util.ValidatorUtil;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-
-import java.util.Date;
-import java.util.List;
-
-
-
-/**
- * 用户发送短信
- */
-@Java110Listener("userSendSmsListener")
-public class UserSendSmsListener extends AbstractServiceApiListener {
-
-    //域
-    public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
-
-    public static final String ID_CARD_SWITCH = "ID_CARD_SWITCH";
-
-    @Autowired
-    private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
-
-    @Autowired
-    private IUserInnerServiceSMO userInnerServiceSMOImpl;
-
-    @Autowired
-    private ISmsInnerServiceSMO smsInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.USER_SEND_SMS;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
-        return userInnerServiceSMOImpl;
-    }
-
-    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
-        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //super.validatePageInfo(reqJson);
-        Assert.hasKeyAndValue(reqJson, "tel", "必填，请填写手机号");
-
-        if (!ValidatorUtil.isMobile(reqJson.getString("tel"))) {
-            throw new IllegalArgumentException("手机号格式错误");
-        }
-
-        //校验是否有有效的验证码
-        String smsCode = CommonCache.getValue(reqJson.getString("tel") + SendSmsFactory.VALIDATE_CODE);
-
-        if (!StringUtil.isEmpty(smsCode) && smsCode.contains("-")) {
-            long oldTime = Long.parseLong(smsCode.substring(smsCode.indexOf("-"), smsCode.length()));
-            long nowTime = new Date().getTime();
-            if (nowTime - oldTime < 1000 * 60 * 2) {
-                throw new IllegalArgumentException("请不要重复发送验证码");
-            }
-        }
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        String tel = reqJson.getString("tel");
-        String captchaType = reqJson.getString("captchaType");
-        if(!StringUtil.isEmpty(captchaType) && "ownerBinding".equals(captchaType)){
-            OwnerDto ownerDto = new OwnerDto();
-            ownerDto.setCommunityId(reqJson.getString("communityId"));
-            ownerDto.setName(reqJson.getString("appUserName"));
-            ownerDto.setLink(reqJson.getString("tel"));
-
-            //取出开关映射的值
-            String val = MappingCache.getValue(DOMAIN_COMMON, ID_CARD_SWITCH);
-            //取出身份证
-            String idCardErrorMsg ="";
-            String idCard = reqJson.getString("idCard");
-            if ("1".equals(val) && !StringUtil.isEmpty(idCard)) {
-                ownerDto.setIdCard(idCard);
-                idCardErrorMsg="或者身份证号";
-            }
-            List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto);
-            Assert.listOnlyOne(ownerDtos, "填写业主信息错误，请确认，预留业主姓名、手机号"+idCardErrorMsg+"信息是否正确！");
-        }
-        //校验是否传了 分页信息
-        String msgCode = SendSmsFactory.generateMessageCode(6);
-        SmsDto smsDto = new SmsDto();
-        smsDto.setTel(tel);
-        smsDto.setCode(msgCode);
-        if ("ON".equals(MappingCache.getValue(SendSmsFactory.SMS_SEND_SWITCH))) {
-            smsDto = smsInnerServiceSMOImpl.send(smsDto);
-        } else {
-            CommonCache.setValue(smsDto.getTel() + SendSmsFactory.VALIDATE_CODE, smsDto.getCode().toLowerCase() + "-" + new Date().getTime(), CommonCache.defaultExpireTime);
-            smsDto.setSuccess(true);
-            smsDto.setMsg("当前为演示环境，您的验证码为" + msgCode);
-        }
-        ResponseEntity<String> sendMessageResult = new ResponseEntity<String>(smsDto.getMsg(), smsDto.isSuccess() ? HttpStatus.OK : HttpStatus.BAD_REQUEST);
-        context.setResponseEntity(sendMessageResult);
-
-    }
-}

service-dev/src/main/java/com/java110/dev/cmd/task/ListTaskTemplateCmd.java

@@ -0,0 +1,4 @@
+package com.java110.dev.cmd.task;
+
+public class ListTaskTemplateCmd {
+}

service-dev/src/main/java/com/java110/dev/cmd/task/ListTaskTemplateSpecCmd.java

@@ -0,0 +1,4 @@
+package com.java110.dev.cmd.task;
+
+public class ListTaskTemplateSpecCmd {
+}

service-dev/src/main/java/com/java110/dev/cmd/task/StartTaskCmd.java

@@ -0,0 +1,4 @@
+package com.java110.dev.cmd.task;
+
+public class StartTaskCmd {
+}

service-dev/src/main/java/com/java110/dev/cmd/task/StopTaskCmd.java

@@ -0,0 +1,4 @@
+package com.java110.dev.cmd.task;
+
+public class StopTaskCmd {
+}

service-user/src/main/java/com/java110/user/cmd/user/ChangeStaffPwdCmd.java

@@ -0,0 +1,4 @@
+package com.java110.user.cmd.user;
+
+public class ChangeStaffPwdCmd {
+}

service-user/src/main/java/com/java110/user/cmd/user/ListUsersCmd.java

@@ -0,0 +1,4 @@
+package com.java110.user.cmd.user;
+
+public class ListUsersCmd {
+}

service-user/src/main/java/com/java110/user/cmd/user/QueryUserSecretCmd.java

@@ -0,0 +1,4 @@
+package com.java110.user.cmd.user;
+
+public class QueryUserSecretCmd {
+}

service-user/src/main/java/com/java110/user/cmd/user/UserLoginCmd.java

@@ -0,0 +1,4 @@
+package com.java110.user.cmd.user;
+
+public class UserLoginCmd {
+}

service-user/src/main/java/com/java110/user/cmd/user/UserLogoutServiceCmd.java

@@ -0,0 +1,4 @@
+package com.java110.user.cmd.user;
+
+public class UserLogoutServiceCmd {
+}

service-user/src/main/java/com/java110/user/cmd/user/UserSendSmsCmd.java

@@ -0,0 +1,4 @@
+package com.java110.user.cmd.user;
+
+public class UserSendSmsCmd {
+}