代码暂存

java110-bean/src/main/java/com/java110/dto/user/StaffDto.java

@@ -0,0 +1,67 @@
+package com.java110.dto.user;
+
+import com.java110.dto.PageDto;
+
+import java.io.Serializable;
+
+public class StaffDto extends PageDto implements Serializable {
+    private String staffId;
+
+    private String staffName;
+
+    private String departmentId;
+
+    private String departmentName;
+
+    private String companyId;
+
+    private String companyName;
+
+    public String getStaffId() {
+        return staffId;
+    }
+
+    public void setStaffId(String staffId) {
+        this.staffId = staffId;
+    }
+
+    public String getStaffName() {
+        return staffName;
+    }
+
+    public void setStaffName(String staffName) {
+        this.staffName = staffName;
+    }
+
+    public String getDepartmentId() {
+        return departmentId;
+    }
+
+    public void setDepartmentId(String departmentId) {
+        this.departmentId = departmentId;
+    }
+
+    public String getDepartmentName() {
+        return departmentName;
+    }
+
+    public void setDepartmentName(String departmentName) {
+        this.departmentName = departmentName;
+    }
+
+    public String getCompanyId() {
+        return companyId;
+    }
+
+    public void setCompanyId(String companyId) {
+        this.companyId = companyId;
+    }
+
+    public String getCompanyName() {
+        return companyName;
+    }
+
+    public void setCompanyName(String companyName) {
+        this.companyName = companyName;
+    }
+}

java110-interface/src/main/java/com/java110/intf/common/workflow/IWorkflowApi.java

@@ -0,0 +1,25 @@
+package com.java110.intf.common.workflow;
+
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.user.StaffDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(name = "common-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/workflow")
+public interface IWorkflowApi {
+
+    /**
+     * 查询 工作流 第一个处理人
+     *
+     * @param flowType 工作流类型
+     * @param communityId 小区ID
+     * @return
+     */
+    @RequestMapping(value = "/getFirstStaff", method = RequestMethod.POST)
+    StaffDto getFirstStaff(@RequestParam(name = "flowType") String flowType,
+                           @RequestParam(name = "communityId") String communityId);
+}

java110-interface/src/main/java/com/java110/intf/store/purchase/IPurchaseApi.java

@@ -0,0 +1,19 @@
+package com.java110.intf.store.purchase;
+
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.user.StaffDto;
+import com.java110.dto.workflow.WorkflowDto;
+import com.java110.vo.api.staff.ApiStaffDataVo;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+/**
+ * 采购申请类
+ */
+@FeignClient(name = "store-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/purchase")
+public interface IPurchaseApi {
+
+}

java110-interface/src/main/java/com/java110/intf/user/org/IOrgApi.java

@@ -0,0 +1,13 @@
+package com.java110.intf.user.org;
+
+
+import com.java110.config.feign.FeignConfiguration;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+@FeignClient(name = "user-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/org")
+public interface IOrgApi {
+
+
+}

service-common/src/main/java/com/java110/common/api/WorkflowApi.java

@@ -0,0 +1,24 @@
+package com.java110.common.api;
+
+import com.java110.common.service.workflow.IQueryWorkFlowFirstStaffService;
+import com.java110.dto.user.StaffDto;
+import com.java110.dto.workflow.WorkflowDto;
+import com.java110.intf.common.workflow.IWorkflowApi;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class WorkflowApi implements IWorkflowApi {
+
+    @Autowired
+    private IQueryWorkFlowFirstStaffService queryWorkFlowFirstStaffServiceImpl;
+    @Override
+    public StaffDto getFirstStaff(@RequestParam(name = "flowType") String flowType,
+                                  @RequestParam(name = "communityId") String communityId) {
+        WorkflowDto workflowDto = new WorkflowDto();
+        workflowDto.setCommunityId(communityId);
+        workflowDto.setFlowType(flowType);
+        return queryWorkFlowFirstStaffServiceImpl.query(workflowDto);
+    }
+}

service-common/src/main/java/com/java110/common/service/workflow/IQueryWorkFlowFirstStaffService.java

@@ -0,0 +1,14 @@
+package com.java110.common.service.workflow;
+
+import com.java110.dto.user.StaffDto;
+import com.java110.dto.workflow.WorkflowDto;
+
+public interface IQueryWorkFlowFirstStaffService {
+
+    /**
+     * 查询 工作流第一个员工信息
+     * @param workflowDto
+     * @return
+     */
+    StaffDto query(WorkflowDto workflowDto);
+}

service-common/src/main/java/com/java110/common/service/workflow/impl/QueryWorkFlowFirstStaffServiceImpl.java

@@ -0,0 +1,69 @@
+package com.java110.common.service.workflow.impl;
+
+import com.java110.common.dao.IWorkflowServiceDao;
+import com.java110.common.dao.IWorkflowStepServiceDao;
+import com.java110.common.dao.IWorkflowStepStaffServiceDao;
+import com.java110.common.service.workflow.IQueryWorkFlowFirstStaffService;
+import com.java110.dto.user.StaffDto;
+import com.java110.dto.workflow.WorkflowDto;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service("queryWorkFlowFirstStaffServiceImpl")
+public class QueryWorkFlowFirstStaffServiceImpl implements IQueryWorkFlowFirstStaffService {
+
+    @Autowired
+    private IWorkflowServiceDao workflowServiceDaoImpl;
+
+    @Autowired
+    private IWorkflowStepServiceDao workflowStepServiceDaoImpl;
+
+    @Autowired
+    private IWorkflowStepStaffServiceDao workflowStepStaffServiceDaoImpl;
+
+    @Override
+    public StaffDto query(WorkflowDto workflowDto) {
+
+        List<Map> workflows = workflowServiceDaoImpl.getWorkflowInfo(BeanConvertUtil.beanCovertMap(workflowDto));
+
+        if (workflows == null || workflows.size() < 1) {
+            return null;
+        }
+
+        WorkflowDto tmpWorkflowDto = BeanConvertUtil.covertBean(workflows.get(0), WorkflowDto.class);
+
+        Map param = new HashMap();
+        param.put("statusCd", "0");
+        param.put("flowId", tmpWorkflowDto.getFlowId());
+        param.put("seq", "1");
+        param.put("communityId", tmpWorkflowDto.getCommunityId());
+        //查询步骤
+        List<Map> workflowSteps = workflowStepServiceDaoImpl.getWorkflowStepInfo(param);
+
+        if (workflowSteps == null || workflowSteps.size() < 1) {
+            return null;
+        }
+
+        param = new HashMap();
+        param.put("statusCd", "0");
+        param.put("communityId", tmpWorkflowDto.getCommunityId());
+        param.put("stepId", workflowSteps.get(0).get("stepId"));
+
+
+        List<Map> workflowStepStaffs = workflowStepStaffServiceDaoImpl.getWorkflowStepStaffInfo(param);
+
+        if (workflowStepStaffs == null || workflowStepStaffs.size() < 1) {
+            return null;
+        }
+
+
+
+
+        return null;
+    }
+}

service-store/src/main/java/com/java110/store/api/PurchaseApi.java

@@ -0,0 +1,8 @@
+package com.java110.store.api;
+
+
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class PurchaseApi {
+}