| java110-bean/src/main/java/com/java110/dto/workTask/WorkTaskDto.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| java110-db/src/main/resources/mapper/oa/WorkTaskV1ServiceDaoImplMapper.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-oa/src/main/java/com/java110/oa/cmd/work/ListWorkPoolCmd.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-oa/src/main/java/com/java110/oa/cmd/work/ListWorkTaskCmd.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-oa/src/main/java/com/java110/oa/cmd/workTask/DeleteWorkTaskCmd.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-oa/src/main/java/com/java110/oa/cmd/workTask/SaveWorkTaskCmd.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-oa/src/main/java/com/java110/oa/cmd/workTask/UpdateWorkTaskCmd.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
java110-bean/src/main/java/com/java110/dto/workTask/WorkTaskDto.java
@@ -21,6 +21,7 @@ private String staffName; private String startTime; private String state; private String stateName; private String endTime; private String communityId; private String storeId; @@ -131,4 +132,12 @@ public void setWorkIds(String[] workIds) { this.workIds = workIds; } public String getStateName() { return stateName; } public void setStateName(String stateName) { this.stateName = stateName; } } java110-db/src/main/resources/mapper/oa/WorkTaskV1ServiceDaoImplMapper.xml
@@ -19,8 +19,10 @@ <select id="getWorkTaskInfo" parameterType="Map" resultType="Map"> select t.staff_name,t.staff_name staffName,t.start_time,t.start_time startTime,t.status_cd,t.status_cd statusCd,t.state,t.end_time,t.end_time endTime,t.community_id,t.community_id communityId,t.store_id,t.store_id storeId,t.task_id,t.task_id taskId,t.work_id,t.work_id workId,t.staff_id,t.staff_id staffId,t.create_time createTime storeId,t.task_id,t.task_id taskId,t.work_id,t.work_id workId,t.staff_id,t.staff_id staffId,t.create_time createTime, td.`name` stateName from work_task t left join t_dict td on t.state = td.status_cd and td.table_name = 'work_pool' and td.table_columns = 'state' where 1 =1 <if test="staffName !=null and staffName != ''"> and t.staff_name= #{staffName} service-oa/src/main/java/com/java110/oa/cmd/work/ListWorkPoolCmd.java
@@ -21,11 +21,11 @@ import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.dto.workCopy.WorkCopyDto; import com.java110.dto.workPoolContent.WorkPoolContentDto; import com.java110.dto.workPoolFile.WorkPoolFileDto; import com.java110.intf.oa.IWorkPoolContentV1InnerServiceSMO; import com.java110.intf.oa.IWorkPoolFileV1InnerServiceSMO; import com.java110.intf.oa.IWorkPoolV1InnerServiceSMO; import com.java110.dto.workTask.WorkTaskDto; import com.java110.intf.oa.*; import com.java110.utils.exception.CmdException; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.ListUtil; @@ -65,6 +65,12 @@ @Autowired private IWorkPoolFileV1InnerServiceSMO workPoolFileV1InnerServiceSMOImpl; @Autowired private IWorkTaskV1InnerServiceSMO workTaskV1InnerServiceSMOImpl; @Autowired private IWorkCopyV1InnerServiceSMO workCopyV1InnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { super.validatePageInfo(reqJson); @@ -88,6 +94,8 @@ } queryContentAndFile(workPoolDtos); queryTaskAndCopy(workPoolDtos); ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, workPoolDtos); @@ -133,4 +141,68 @@ workPoolDtos.get(0).setPathUrl(workPoolFileDtos.get(0).getPathUrl()); } private void queryTaskAndCopy(List<WorkPoolDto> workPoolDtos) { if (ListUtil.isNull(workPoolDtos)) { return; } List<String> workIds = new ArrayList<>(); for (WorkPoolDto workPoolDto : workPoolDtos) { workIds.add(workPoolDto.getWorkId()); } WorkTaskDto workTaskDto = new WorkTaskDto(); workTaskDto.setWorkIds(workIds.toArray(new String[workIds.size()])); List<WorkTaskDto> workTaskDtos = workTaskV1InnerServiceSMOImpl.queryWorkTasks(workTaskDto); String curStaffName = ""; for (WorkPoolDto workPoolDto : workPoolDtos) { curStaffName = ""; for (WorkTaskDto tmpWorkTaskDto : workTaskDtos) { if (!WorkTaskDto.STATE_WAIT.equals(tmpWorkTaskDto.getState())) { continue; } if (!workPoolDto.getWorkId().equals(tmpWorkTaskDto.getWorkId())) { continue; } if (curStaffName.split(",").length > 2) { continue; } curStaffName += (tmpWorkTaskDto.getStaffName() + ","); } workPoolDto.setCurStaffName(curStaffName); } WorkCopyDto workCopyDto = new WorkCopyDto(); workCopyDto.setWorkIds(workIds.toArray(new String[workIds.size()])); List<WorkCopyDto> workCopyDtos = workCopyV1InnerServiceSMOImpl.queryWorkCopys(workCopyDto); String curCopyName = ""; for (WorkPoolDto workPoolDto : workPoolDtos) { curCopyName = ""; for (WorkCopyDto tmpWorkCopyDto : workCopyDtos) { if (!WorkTaskDto.STATE_WAIT.equals(tmpWorkCopyDto.getState())) { continue; } if (!workPoolDto.getWorkId().equals(tmpWorkCopyDto.getWorkId())) { continue; } if (curCopyName.split(",").length > 2) { continue; } curCopyName += (tmpWorkCopyDto.getStaffName() + ","); } workPoolDto.setCurCopyName(curCopyName); } } } service-oa/src/main/java/com/java110/oa/cmd/work/ListWorkTaskCmd.java
File was renamed from service-oa/src/main/java/com/java110/oa/cmd/workTask/ListWorkTaskCmd.java @@ -13,26 +13,24 @@ * See the License for the specific language governing permissions and * limitations under the License. */ package com.java110.oa.cmd.workTask; package com.java110.oa.cmd.work; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.CmdContextUtils; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.core.factory.GenerateCodeFactory; import com.java110.intf.oa.IWorkTaskV1InnerServiceSMO; import com.java110.po.workTask.WorkTaskPo; import com.java110.utils.exception.CmdException; 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 com.java110.dto.workTask.WorkTaskDto; import java.util.List; import java.util.ArrayList; import org.springframework.http.ResponseEntity; import org.springframework.http.HttpStatus; import org.slf4j.Logger; @@ -49,10 +47,10 @@ * 温馨提示:如果您对此文件进行修改 请不要删除原有作者及注释信息,请补充您的 修改的原因以及联系邮箱如下 * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复,注释10至20行 加入 20行至30行 */ @Java110Cmd(serviceCode = "workTask.listWorkTask") @Java110Cmd(serviceCode = "work.listWorkTask") public class ListWorkTaskCmd extends Cmd { private static Logger logger = LoggerFactory.getLogger(ListWorkTaskCmd.class); private static Logger logger = LoggerFactory.getLogger(ListWorkTaskCmd.class); @Autowired private IWorkTaskV1InnerServiceSMO workTaskV1InnerServiceSMOImpl; @@ -60,28 +58,28 @@ public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { super.validatePageInfo(reqJson); String storeId = CmdContextUtils.getStoreId(cmdDataFlowContext); reqJson.put("storeId",storeId); reqJson.put("storeId", storeId); } @Override public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { WorkTaskDto workTaskDto = BeanConvertUtil.covertBean(reqJson, WorkTaskDto.class); WorkTaskDto workTaskDto = BeanConvertUtil.covertBean(reqJson, WorkTaskDto.class); int count = workTaskV1InnerServiceSMOImpl.queryWorkTasksCount(workTaskDto); int count = workTaskV1InnerServiceSMOImpl.queryWorkTasksCount(workTaskDto); List<WorkTaskDto> workTaskDtos = null; List<WorkTaskDto> workTaskDtos = null; if (count > 0) { workTaskDtos = workTaskV1InnerServiceSMOImpl.queryWorkTasks(workTaskDto); } else { workTaskDtos = new ArrayList<>(); } if (count > 0) { workTaskDtos = workTaskV1InnerServiceSMOImpl.queryWorkTasks(workTaskDto); } else { workTaskDtos = new ArrayList<>(); } ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, workTaskDtos); ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, workTaskDtos); ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK); ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK); cmdDataFlowContext.setResponseEntity(responseEntity); cmdDataFlowContext.setResponseEntity(responseEntity); } } service-oa/src/main/java/com/java110/oa/cmd/workTask/DeleteWorkTaskCmd.java
File was deleted service-oa/src/main/java/com/java110/oa/cmd/workTask/SaveWorkTaskCmd.java
File was deleted service-oa/src/main/java/com/java110/oa/cmd/workTask/UpdateWorkTaskCmd.java
File was deleted