diff --git a/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/query/DispatchQuery.java b/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/query/DispatchQuery.java new file mode 100644 index 0000000..68be998 --- /dev/null +++ b/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/query/DispatchQuery.java @@ -0,0 +1,60 @@ +package com.chushang.inspection.terminal.query; + +import cn.hutool.core.collection.ListUtil; +import cn.hutool.core.date.DatePattern; +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; +import org.hibernate.validator.constraints.Range; + +import javax.validation.constraints.NotNull; +import javax.validation.constraints.Size; +import java.io.Serializable; +import java.time.LocalDateTime; +import java.util.List; + +@Data +@NoArgsConstructor +@AllArgsConstructor +public class DispatchQuery implements Serializable { + + /** 终端id */ + private List ids; + + /** 任务id */ + @NotNull(message = "必须指定任务") + private Long taskId; + + /** 业务员id */ + private Long userId; + + /** 工单类型 */ + @NotNull(message = "必须指定工单类型") + @Range(min = 1, max = 50, message = "工单类型非法") + private Integer workType; + + /** 截至时间 */ + @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DatePattern.NORM_DATETIME_PATTERN) + private LocalDateTime endTime; + + /** 工单优先级 */ + private Integer workSort ; + + /** 备注 */ + @Size(max = 100, message = "备注不能超过100个字符") + private String remark; + + /** 工单来源 */ + @Range(min = 1, max = 4, message = "工单来源非法") + private Integer workSource; + + /** 商户号 */ + private List nos ; + + /** 终端号 */ + private List terminalNos ; + + +} diff --git a/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/vo/TerminalVO.java b/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/vo/TerminalVO.java index 28fba05..34f40f9 100644 --- a/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/vo/TerminalVO.java +++ b/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/vo/TerminalVO.java @@ -19,6 +19,8 @@ public class TerminalVO implements Serializable { @Serial private static final long serialVersionUID = 1L; + + /** * 终端 主键 */ @@ -34,6 +36,11 @@ public class TerminalVO implements Serializable { */ private Long lowerTaskId; + /** + * 任务名称 + */ + private String pollingName; + /** * 商户编号 */ diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/TerminalController.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/TerminalController.java index 88e9c65..d740532 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/TerminalController.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/TerminalController.java @@ -1,8 +1,11 @@ package com.chushang.inspection.terminal.controller; +import cn.hutool.core.bean.BeanUtil; import com.chushang.common.core.web.AjaxResult; import com.chushang.common.log.annotation.SysLog; import com.chushang.common.log.enums.BusinessType; +import com.chushang.inspection.project.po.PollingTaskAutograph; +import com.chushang.inspection.terminal.po.Terminal; import com.chushang.inspection.terminal.query.TerminalAppQuery; import com.chushang.inspection.terminal.query.TerminalQuery; import com.chushang.inspection.terminal.service.TerminalService; @@ -56,7 +59,7 @@ public class TerminalController { * TODO 需要查询 st_terminal_ins 表 */ @SysLog(value = "终端详情", businessType = BusinessType.QUERY) - @PostMapping("/info/{terminalId}") + @GetMapping("/info/{terminalId}") @RequiresPermissions("terminal:info") public AjaxResult info(@PathVariable Long terminalId) { return AjaxResult.success(terminalService.getById(terminalId)); @@ -71,9 +74,34 @@ public class TerminalController { @RequiresPermissions("terminal:info:app") public AjaxResult infoApp(@PathVariable Long terminalId, @RequestParam("taskId") Long taskId) { - return AjaxResult.success(terminalService.getAppById(terminalId, taskId)); } + /** + * 修改 -内改终端 + * @param query 条件 + */ + @SysLog(value = "修改终端", businessType = BusinessType.UPDATE) + @PostMapping("/update") + @RequiresPermissions("ins:terminal:update") + public AjaxResult update(@RequestBody @Validated TerminalQuery query) { + Terminal terminal = BeanUtil.copyProperties(query, Terminal.class); + return AjaxResult.success(terminalService.updateById(terminal)); + } + + + /** + * 派单-批量派单 + * @param query 条件 + */ + @SysLog(value = "派单-批量派单", businessType = BusinessType.OTHER) + @PostMapping("/dispatch/app") + @RequiresPermissions("ins:terminal:dispatch") + public AjaxResult dispatch(@RequestBody @Validated TerminalQuery query) { + Terminal terminal = BeanUtil.copyProperties(query, Terminal.class); +// terminalService.dispatch(terminal) + return AjaxResult.success(); + } + } diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/mapper/TerminalMapper.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/mapper/TerminalMapper.java index 63dec92..1c5989d 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/mapper/TerminalMapper.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/mapper/TerminalMapper.java @@ -23,4 +23,11 @@ public interface TerminalMapper extends BaseMapper { Page page); @DataScope(deptAlias = "t") List selectPageApp(@Param("query") TerminalAppQuery query, Page page); + + + List getStoreByTasKIdOrIds(@Param("taskId")Long taskId, + @Param("ids")List ids, + @Param("nos")List nos, + @Param("terminalNos")List terminalNos, + @Param("i")int i); } diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/TerminalService.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/TerminalService.java index 2137df6..b2027c5 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/TerminalService.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/TerminalService.java @@ -4,9 +4,11 @@ import com.baomidou.mybatisplus.extension.service.IService; import com.chushang.common.mybatis.utils.PageResult; import com.chushang.inspection.project.vo.TerminalApp; import com.chushang.inspection.terminal.po.Terminal; +import com.chushang.inspection.terminal.query.DispatchQuery; import com.chushang.inspection.terminal.query.TerminalAppQuery; import com.chushang.inspection.terminal.query.TerminalQuery; import com.chushang.inspection.terminal.vo.TerminalVO; +import com.chushang.inspection.work.po.WrkInfo; import java.util.List; @@ -33,4 +35,12 @@ public interface TerminalService extends IService{ * @return */ TerminalApp getAppById(Long terminalId, Long taskId); + + /** + * 派单 id + * @param query + * @param i + * @return + */ + List dispatch(DispatchQuery query, int i); } diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/TerminalServiceImpl.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/TerminalServiceImpl.java index c7b491b..290b1b2 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/TerminalServiceImpl.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/TerminalServiceImpl.java @@ -14,12 +14,15 @@ import com.chushang.inspection.project.vo.TerminalApp; import com.chushang.inspection.project.vo.TerminalAppVO; import com.chushang.inspection.terminal.po.Store; import com.chushang.inspection.terminal.po.Terminal; +import com.chushang.inspection.terminal.query.DispatchQuery; import com.chushang.inspection.terminal.query.TerminalAppQuery; import com.chushang.inspection.terminal.query.TerminalQuery; import com.chushang.inspection.terminal.service.StoreService; import com.chushang.inspection.terminal.service.TerminalService; import com.chushang.inspection.terminal.vo.TerminalVO; import com.chushang.inspection.utils.TaskConfigUtils; +import com.chushang.inspection.work.po.WrkInfo; +import com.sun.xml.bind.v2.TODO; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.chushang.inspection.terminal.mapper.TerminalMapper; @@ -73,4 +76,12 @@ public class TerminalServiceImpl extends ServiceImpl i } return null; } + + @Override + public List dispatch(DispatchQuery query, int i) { + // TODO 先关联终端和商户查询出来要派单的终端信息 然后通过派单方式走不同的策略拼接wrk_entity实体 + // 落入wrk_info表 然后修改终端占用 终端进度表没啥用 + + return List.of(); + } } diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/FiveStoreMapper.xml b/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/FiveStoreMapper.xml index 86475eb..092443e 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/FiveStoreMapper.xml +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/FiveStoreMapper.xml @@ -62,7 +62,7 @@ AND fs.first_level_branch = #{query.firstLevelBranch} - + AND fs.secondary_branches IN #{item} diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/TerminalMapper.xml b/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/TerminalMapper.xml index 31e82db..541f5a1 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/TerminalMapper.xml +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/resources/mapper/TerminalMapper.xml @@ -88,12 +88,11 @@ + + + + diff --git a/chushang-modules/chushang-module-oss/oss-service/src/main/java/com/chushang/oss/service/FileSourceService.java b/chushang-modules/chushang-module-oss/oss-service/src/main/java/com/chushang/oss/service/FileSourceService.java index 48ce5a6..976fa68 100644 --- a/chushang-modules/chushang-module-oss/oss-service/src/main/java/com/chushang/oss/service/FileSourceService.java +++ b/chushang-modules/chushang-module-oss/oss-service/src/main/java/com/chushang/oss/service/FileSourceService.java @@ -262,6 +262,7 @@ public class FileSourceService fileSourceInfo.setName(fName); fileSourceInfo.setSize(length); fileSourceInfo.setPath("contract/"+fName); + fileSourceInfo.setStorage("contract/"+fName); fileSourceInfo.setMimeType(mimetype); String upload = ossService.upload(file.getInputStream(), fileSourceInfo); fileSourceInfo.setRealPath(upload);