diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeign.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeign.java index 7769e7a7b6..a9409bcf26 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeign.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeign.java @@ -7,6 +7,7 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.cloud.openfeign.SpringQueryMap; import org.springframework.web.bind.annotation.*; import javax.validation.Valid; @@ -160,4 +161,9 @@ public interface BaseManufacturerFeign { @ResponseBody public ResultBean queryBycertOrg(@PathVariable("certOrg") String certOrg); + @ApiOperation("厂家采购获取分公司销售通路") + @GetMapping("/selectNameByOrg") + @ResponseBody + ResultBean> selectNameByOrg(@SpringQueryMap BaseManufacturerListQuery query); + } \ No newline at end of file diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeignFallback.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeignFallback.java index 1bfa444cc8..9bac03f491 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeignFallback.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerFeignFallback.java @@ -90,4 +90,9 @@ public class BaseManufacturerFeignFallback implements BaseManufacturerFeign { public ResultBean queryBycertOrg(String certOrg) { return null; } + + @Override + public ResultBean> selectNameByOrg(BaseManufacturerListQuery query) { + return null; + } } \ No newline at end of file diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerListQuery.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerListQuery.java new file mode 100644 index 0000000000..bdf7a9a58d --- /dev/null +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerListQuery.java @@ -0,0 +1,17 @@ +package com.yxt.anrui.base.api.basemanufacturer; + +import com.yxt.common.core.query.Query; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @Author dimengzhe + * @Date 2022/9/30 10:57 + * @Description + */ +@Data +public class BaseManufacturerListQuery implements Query { + private static final long serialVersionUID = -8298971718012436562L; + @ApiModelProperty("分公司sid") + private String useOrgSid; +} diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerListVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerListVo.java new file mode 100644 index 0000000000..ee475b4417 --- /dev/null +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemanufacturer/BaseManufacturerListVo.java @@ -0,0 +1,19 @@ +package com.yxt.anrui.base.api.basemanufacturer; + +import com.yxt.common.core.vo.Vo; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @Author dimengzhe + * @Date 2022/9/30 10:55 + * @Description + */ +@Data +public class BaseManufacturerListVo implements Vo { + private static final long serialVersionUID = 4951280280938626700L; + @ApiModelProperty("供应商sid") + private String sid; + @ApiModelProperty("供应商销售通路") + private String name; +} diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemiddleman/BaseMiddlemanFeign.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemiddleman/BaseMiddlemanFeign.java index f0fdc138f8..e891e03891 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemiddleman/BaseMiddlemanFeign.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basemiddleman/BaseMiddlemanFeign.java @@ -89,7 +89,7 @@ public interface BaseMiddlemanFeign { ResultBean> getMiddleList(@Valid @RequestBody PagerQuery query); @ApiOperation("车辆出库中介人员") - @PostMapping("/selectMiddleList") + @GetMapping("/selectMiddleList") @ResponseBody ResultBean> selectMiddleList(@SpringQueryMap BaseMiddleListQuery query); } \ No newline at end of file diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicle.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicle.java index e260fd4874..28f68ca407 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicle.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicle.java @@ -140,4 +140,13 @@ public class BaseVehicle extends BaseEntity { private String witPinStateValue; @ApiModelProperty(value = "是否为问题车辆(0无问题 1有问题)") private String isProblemVeh; + @ApiModelProperty(value = "采购系统sid") + private String purchaseSystemSid; + @ApiModelProperty(value = "采购系统名称") + private String purchaseSystemName; + @ApiModelProperty(value = "厂家销售通路sid") + private String manufSaleAccessSid; + @ApiModelProperty(value = "厂家销售通路名称") + private String manufSaleAccessName; + } diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleDto.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleDto.java index 44e77c77fa..9b205afa71 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleDto.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleDto.java @@ -106,4 +106,12 @@ public class BaseVehicleDto implements Dto { private String witPinStateValue; @ApiModelProperty(value = "是否为问题车辆(0无问题 1有问题)") private String isProblemVeh; + @ApiModelProperty(value = "采购系统sid") + private String purchaseSystemSid; + @ApiModelProperty(value = "采购系统名称") + private String purchaseSystemName; + @ApiModelProperty(value = "厂家销售通路sid") + private String manufSaleAccessSid; + @ApiModelProperty(value = "厂家销售通路名称") + private String manufSaleAccessName; } \ No newline at end of file diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeign.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeign.java index 71bddc72d3..3bb82628a3 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeign.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeign.java @@ -166,6 +166,17 @@ public interface BaseVehicleFeign { @ResponseBody @ApiOperation(value = "导入") public ResultBean getExcelInfo(@RequestParam(value = "fileName") String fileName, @RequestParam(value = "file") MultipartFile file) throws IOException, ParseException; + + + /** + * 修改保存 + * + * @param sid 车辆sid + * @return + */ + @ApiOperation("修改车辆台账备注") + @PostMapping("/updateVehRemarks/{remarks}/{sid}") + public ResultBean updateVehRemarks(@PathVariable("remarks") String remarks, @PathVariable("sid") String sid); /***************************************************** PC现车接口 **********************************************************/ /** diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeignFallback.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeignFallback.java index 176442b218..f5ec3ad9e9 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeignFallback.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleFeignFallback.java @@ -98,6 +98,11 @@ public class BaseVehicleFeignFallback implements BaseVehicleFeign { return null; } + @Override + public ResultBean updateVehRemarks(String remarks, String sid) { + return null; + } + @Override public ResultBean> exiCarPagerList(PagerQuery pq) { return null; diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleSelectVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleSelectVo.java index f43c6d442d..999140d48f 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleSelectVo.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleSelectVo.java @@ -95,4 +95,12 @@ public class BaseVehicleSelectVo implements Vo { private String useOrgName; @ApiModelProperty(value = "是否为问题车辆(0无问题 1有问题)") private String isProblemVeh; + @ApiModelProperty(value = "采购系统sid") + private String purchaseSystemSid; + @ApiModelProperty(value = "采购系统名称") + private String purchaseSystemName; + @ApiModelProperty(value = "厂家销售通路sid") + private String manufSaleAccessSid; + @ApiModelProperty(value = "厂家销售通路名称") + private String manufSaleAccessName; } diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleVo.java index 8704f5c822..767a2ea9c1 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleVo.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicle/BaseVehicleVo.java @@ -106,6 +106,14 @@ public class BaseVehicleVo implements Vo { private Long libraryAge; @ApiModelProperty(value = "是否为问题车辆(0无问题 1有问题)") private String isProblemVeh; + @ApiModelProperty(value = "采购系统sid") + private String purchaseSystemSid; + @ApiModelProperty(value = "采购系统名称") + private String purchaseSystemName; + @ApiModelProperty(value = "厂家销售通路sid") + private String manufSaleAccessSid; + @ApiModelProperty(value = "厂家销售通路名称") + private String manufSaleAccessName; //车型配置 @ApiModelProperty("车身颜色(陕汽必须的字段)") diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutDetailsVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutDetailsVo.java new file mode 100644 index 0000000000..f68c39411b --- /dev/null +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutDetailsVo.java @@ -0,0 +1,61 @@ +package com.yxt.anrui.base.api.basevehicleout; + +import com.yxt.common.core.vo.Vo; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @Author dimengzhe + * @Date 2022/9/29 16:45 + * @Description + */ +@Data +public class BaseVehicleOutDetailsVo implements Vo { + private static final long serialVersionUID = -7699189616162991308L; + + private String vinSid; + private String vinNo; + @ApiModelProperty("出库类型") + private String type; + private String typeKey; + @ApiModelProperty("销售部门sid") + private String orgSid; + @ApiModelProperty("销售部门名称") + private String orgName; + @ApiModelProperty("销售专员sid") + private String staffSid; + @ApiModelProperty("销售专员") + private String staffName; + @ApiModelProperty("合同编号") + private String concatNo; + @ApiModelProperty("成交价") + private String price; + @ApiModelProperty("是否为终端客户:1是0不是") + private String isTerminal; + @ApiModelProperty("客户名称") + private String customerName; + @ApiModelProperty("客户sid") + private String customerSid; + @ApiModelProperty("手机号") + private String mobile; + @ApiModelProperty("赠品说明") + private String giftsDescription; + + @ApiModelProperty("销售折让") + private String salesAllowance; + @ApiModelProperty("中介人1") + private String middleOne; + @ApiModelProperty("中介人1sid") + private String middleOneSid; + @ApiModelProperty("返利金额1") + private String rebateMoneyOne; + @ApiModelProperty("中介人2") + private String middleTwo; + @ApiModelProperty("中介人2sid") + private String middleTwoSid; + @ApiModelProperty("返利金额2") + private String rebateMoneyTwo; + @ApiModelProperty("备注") + private String remarks; + private String saleDate; +} diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutFeign.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutFeign.java index e1aff860e3..2198a2266a 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutFeign.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutFeign.java @@ -5,9 +5,7 @@ import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.vo.PagerVo; import io.swagger.annotations.ApiOperation; import org.springframework.cloud.openfeign.FeignClient; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.*; /** * @Author dimengzhe @@ -30,6 +28,13 @@ public interface BaseVehicleOutFeign { @PostMapping("/pagerList") @ResponseBody ResultBean> pagerList(@RequestBody PagerQuery query); + + @ApiOperation("出库详情") + @GetMapping("/details/{sid}") + @ResponseBody + ResultBean details(@PathVariable("sid") String sid); + + } diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutVo.java index 588f946f93..4f1253e432 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutVo.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/basevehicleout/BaseVehicleOutVo.java @@ -13,6 +13,9 @@ import lombok.Data; public class BaseVehicleOutVo implements Vo { private static final long serialVersionUID = -1711615769602118459L; + @ApiModelProperty("sid") + private String sid; + @ApiModelProperty("车架号") private String vinSid; diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApply.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApply.java index d4c06a9fc0..ddbcf3adb0 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApply.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApply.java @@ -67,4 +67,9 @@ public class BusVehicleApply extends BaseEntity { private String userSids; private String userNames; + @ApiModelProperty("采购部门名称") + private String orgDeptName; + @ApiModelProperty("采购部门sid") + private String orgDeptSid; + } diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDetailsVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDetailsVo.java index 99b2d7706f..3c52bba8ac 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDetailsVo.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDetailsVo.java @@ -57,4 +57,9 @@ public class BusVehicleApplyDetailsVo implements Vo { private String userSids; private String userNames; private String nodeState; + + @ApiModelProperty("采购部门名称") + private String orgDeptName; + @ApiModelProperty("采购部门sid") + private String orgDeptSid; } diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDto.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDto.java index db790f4e2f..7a55d26bb0 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDto.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapply/BusVehicleApplyDto.java @@ -63,8 +63,13 @@ public class BusVehicleApplyDto implements Dto { @ApiModelProperty("订金付款备注") private String payRemarks; - + @ApiModelProperty("选择的销售经理sid") private String userSids; private String userNames; + @ApiModelProperty("采购部门名称") + private String orgDeptName; + @ApiModelProperty("采购部门sid") + private String orgDeptSid; + } \ No newline at end of file diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetail.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetail.java index 28977d56bc..e36fd593f5 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetail.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetail.java @@ -25,13 +25,13 @@ import lombok.Data; public class BusVehicleApplyDetail extends BaseEntity { private static final long serialVersionUID = 1L; - @ApiModelProperty("排产申请sid") + @ApiModelProperty("排产申请sid") private String applySid; - @ApiModelProperty("车型sid") + @ApiModelProperty("车型sid") private String vehicleSid; - @ApiModelProperty("车型名称") + @ApiModelProperty("车型名称") private String vehicleName; - @ApiModelProperty("排产数量") + @ApiModelProperty("排产数量") private String quantity; @ApiModelProperty("使用订金") private Integer useDeposit; @@ -47,4 +47,9 @@ public class BusVehicleApplyDetail extends BaseEntity { private String insideCode; @ApiModelProperty(value = "厂家合同价") private Integer contractPrice; + + @ApiModelProperty("厂家销售通路") + private String actualPay; + @ApiModelProperty("厂家销售通路sid") + private String actualSid; } diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailDto.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailDto.java index eda3859918..a29a7da269 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailDto.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailDto.java @@ -45,11 +45,15 @@ public class BusVehicleApplyDetailDto implements Dto { @ApiModelProperty("申请订金") private String applyForDeposit; @ApiModelProperty("备注") - private String remarks; // 备注 + private String remarks; @ApiModelProperty("内部编码") private String insideCode; @ApiModelProperty(value = "厂家合同价") private String contractPrice; private BusVehicleApplySzDto busVehicleApplySz; + @ApiModelProperty("厂家销售通路") + private String actualPay; + @ApiModelProperty("厂家销售通路sid") + private String actualSid; } \ No newline at end of file diff --git a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailVo.java b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailVo.java index 3815496a7e..8f4c4ae661 100644 --- a/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailVo.java +++ b/anrui-base/anrui-base-api/src/main/java/com/yxt/anrui/base/api/busvehicleapplydetail/BusVehicleApplyDetailVo.java @@ -55,4 +55,8 @@ public class BusVehicleApplyDetailVo implements Vo { @ApiModelProperty(value = "上装指导价") private Integer guidePrice; + @ApiModelProperty("厂家销售通路") + private String actualPay; + @ApiModelProperty("厂家销售通路sid") + private String actualSid; } diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.java index 108b110a10..c9b20f5dbe 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.java @@ -117,4 +117,6 @@ public interface BaseManufacturerMapper extends BaseMapper { List> wcgysNamesDown(String orgSid); List> bankNamesDown(String manufacturerSid); + + List selectNameByOrg(@Param("useOrgSid") String useOrgSid, @Param("supplierTypeValue") String supplierTypeValue); } \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.xml b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.xml index c549673163..2fb8dcdda8 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.xml +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerMapper.xml @@ -164,4 +164,8 @@ WHERE manufacturerSid = #{manufacturerSid} AND isDelete = 0 + + \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerRest.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerRest.java index 7a82050560..7ec09fe7a5 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerRest.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerRest.java @@ -1,15 +1,10 @@ package com.yxt.anrui.base.biz.basemanufacturer; -import com.auth0.jwt.JWT; -import com.auth0.jwt.interfaces.DecodedJWT; import com.baomidou.mybatisplus.core.metadata.IPage; import com.yxt.anrui.base.api.basemanufacturer.*; import com.yxt.anrui.base.biz.basemanufacturerbank.BaseManufacturerBankService; import com.yxt.anrui.base.biz.basemanufacturerfinance.BaseManufacturerFinanceService; -import com.yxt.anrui.portal.api.sysuser.SysUserFeign; -import com.yxt.anrui.portal.api.sysuser.SysUserVo; import com.yxt.common.base.utils.ExportExcelUtils; -import com.yxt.common.base.utils.JWTUtil; import com.yxt.common.base.utils.PagerUtil; import com.yxt.common.core.query.PagerQuery; import com.yxt.common.core.result.ResultBean; @@ -19,7 +14,6 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; -import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; @@ -168,4 +162,9 @@ public class BaseManufacturerRest implements BaseManufacturerFeign { BaseManufacturerVo vo = baseManufacturerService.queryBycertOrg(certOrg); return rb.success().setData(vo); } + + @Override + public ResultBean> selectNameByOrg(BaseManufacturerListQuery query) { + return baseManufacturerService.selectNameByOrg(query); + } } diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerService.java index a54b49bd59..8b05b69281 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerService.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basemanufacturer/BaseManufacturerService.java @@ -407,4 +407,12 @@ public class BaseManufacturerService extends MybatisBaseService> bankNames = baseMapper.bankNamesDown(manufacturerSid); return rb.success().setData(bankNames); } + + public ResultBean> selectNameByOrg(BaseManufacturerListQuery query) { + ResultBean> rb = ResultBean.fireFail(); + String useOrgSid = query.getUseOrgSid(); + String supplierTypeValue = "主机厂"; + List list = baseMapper.selectNameByOrg(useOrgSid,supplierTypeValue); + return rb.success().setData(list); + } } \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.java index b6d4eed199..9e7ceeb329 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleMapper.java @@ -9,6 +9,7 @@ import com.yxt.anrui.base.api.basevehicle.*; import com.yxt.anrui.base.api.basevehicle.app.AppBaseVehicleOrderVo; import com.yxt.anrui.base.api.basevehicle.app.InputVinListVo; import com.yxt.anrui.scm.api.scmvehiclepatrolinspection.AppScmVehiclePatrolinspectionPageQuery; +import com.yxt.common.core.result.ResultBean; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Update; @@ -460,4 +461,7 @@ public interface BaseVehicleMapper extends BaseMapper { IPage saleOrderVin(IPage page, @Param(Constants.WRAPPER) QueryWrapper qw, @Param("names") String names); + + @Update("update base_vehicle set remarks = #{remarks} where sid = #{sid}") + ResultBean updateVehRemarks(@Param("remarks") String remarks,@Param("sid") String sid); } \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleRest.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleRest.java index 8f1016587f..83c059b4e6 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleRest.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleRest.java @@ -420,6 +420,11 @@ public class BaseVehicleRest implements BaseVehicleFeign { } } + @Override + public ResultBean updateVehRemarks(String remarks, String sid) { + return baseVehicleService.updateVehRemarks(remarks,sid); + } + /** * pc端现车分页列表 * diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java index 5b100b6133..0b894d1c1c 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicle/BaseVehicleService.java @@ -2102,10 +2102,10 @@ public class BaseVehicleService extends MybatisBaseService p = PagerUtil.pageToVo(pagging, null); return p; } + + public ResultBean updateVehRemarks(String remarks, String sid) { + return baseMapper.updateVehRemarks(remarks,sid); + } } \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.java index 382fe7ad9a..7ac5ab7c4d 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Constants; import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOut; +import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutDetailsVo; import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutVo; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -25,4 +26,6 @@ public interface BaseVehicleOutMapper extends BaseMapper { IPage selectPageVo(IPage page, @Param(Constants.WRAPPER)QueryWrapper qw); + + BaseVehicleOutDetailsVo details(String sid); } diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.xml b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.xml index 57636e87d2..642e706a88 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.xml +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutMapper.xml @@ -42,10 +42,40 @@ bvo.middleOne, bvo.middleTwo, bvo.rebateMoneyOne, - bvo.rebateMoneyTwo + bvo.rebateMoneyTwo, + bv.configName as modelConfig, + bvo.sid from base_vehicle_out bvo + left join base_vehicle bv on bv.sid = bvo.vinSid ${ew.sqlSegment} + + \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutRest.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutRest.java index 157475632e..8afc9e4c9c 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutRest.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutRest.java @@ -1,9 +1,6 @@ package com.yxt.anrui.base.biz.basevehicleout; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutDto; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutFeign; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutQuery; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutVo; +import com.yxt.anrui.base.api.basevehicleout.*; import com.yxt.common.core.query.PagerQuery; import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.vo.PagerVo; @@ -36,4 +33,9 @@ public class BaseVehicleOutRest implements BaseVehicleOutFeign { PagerVo pv = baseVehicleOutService.pagerList(query); return rb.success().setData(pv); } + + @Override + public ResultBean details(String sid) { + return baseVehicleOutService.details(sid); + } } diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutService.java index 6ee0246721..80334eb196 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutService.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basevehicleout/BaseVehicleOutService.java @@ -4,10 +4,7 @@ import cn.hutool.core.bean.BeanUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.yxt.anrui.base.api.basevehicle.BaseVehicle; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOut; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutDto; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutQuery; -import com.yxt.anrui.base.api.basevehicleout.BaseVehicleOutVo; +import com.yxt.anrui.base.api.basevehicleout.*; import com.yxt.anrui.base.biz.basevehicle.BaseVehicleService; import com.yxt.anrui.base.common.enums.VehicleState; import com.yxt.common.base.service.MybatisBaseService; @@ -99,4 +96,10 @@ public class BaseVehicleOutService extends MybatisBaseService p = PagerUtil.pageToVo(pagging, null); return p; } + + public ResultBean details(String sid) { + ResultBean rb = ResultBean.fireFail(); + BaseVehicleOutDetailsVo baseVehicleOutDetailsVo = baseMapper.details(sid); + return rb.success().setData(baseVehicleOutDetailsVo); + } } diff --git a/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java b/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java index b15a784f1f..e039930ac5 100644 --- a/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java +++ b/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java @@ -37,6 +37,8 @@ public enum ProcDefEnum { SCMSPECIALREBATEWITHAPPLY("专项返利预提申请","process_l0yxpgs2:1:590004"), SCMSPECIALREBATECHECKAPPLY("专项返利核对申请","process_qw22vupn:1:590008"), SCMSPECIALREBATECHEDISTRIBUTE("专项返利分配申请","process_h3w1aval:1:615004"), + SCMCOLLECTIONREBATEWITHAPPLY("回款返利预提申请","process_k4lodiyg:1:630004"), + SCMCOLLECTIONREBATECHECKAPPLY("回款返利核对申请","process_fgrv1mbv:1:630008"), CONTRACTAPPLY("合同审核","process_gd8c9xd5:1:545008"), ; diff --git a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java index 6e284f469a..fb7efbb98e 100644 --- a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java +++ b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java @@ -450,7 +450,7 @@ public class FlowTaskService extends MybatisBaseService selectMappingInfo(@RequestBody SysMappingInfoQuery query); + + @ApiOperation("回显映射") + @GetMapping("/selectMappingListInfo/{dictSid}") + @ResponseBody + public ResultBean> selectMappingListInfo(@PathVariable("dictSid") String dictSid); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysmapping/SysMappingFeignFallback.java b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysmapping/SysMappingFeignFallback.java index 1aa609b3c8..69b4ad0a12 100644 --- a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysmapping/SysMappingFeignFallback.java +++ b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysmapping/SysMappingFeignFallback.java @@ -79,4 +79,9 @@ public class SysMappingFeignFallback implements SysMappingFeign { public ResultBean selectMappingInfo(SysMappingInfoQuery query) { return null; } + + @Override + public ResultBean> selectMappingListInfo(String dictSid) { + return null; + } } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeign.java b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeign.java index 879377e42e..ffd6fa92bb 100644 --- a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeign.java +++ b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeign.java @@ -139,4 +139,9 @@ public interface SysOrganizationFeign { @ResponseBody @ApiOperation("当前分公司销售部门及部门人员") ResultBean> selectOrgList(@SpringQueryMap SysOrganizationListQuery query); + + @GetMapping("/selectOrgLists") + @ResponseBody + @ApiOperation("当前分公司下所有部门") + ResultBean> selectOrgLists(@SpringQueryMap SysOrganizationListQuery query); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeignFallback.java b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeignFallback.java index a7bd307be5..2c64662f4d 100644 --- a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeignFallback.java +++ b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationFeignFallback.java @@ -142,4 +142,9 @@ public class SysOrganizationFeignFallback implements SysOrganizationFeign { public ResultBean> selectOrgList(SysOrganizationListQuery query) { return null; } + + @Override + public ResultBean> selectOrgLists(SysOrganizationListQuery query) { + return null; + } } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationListsVo.java b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationListsVo.java new file mode 100644 index 0000000000..a93ab2d4d1 --- /dev/null +++ b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysorganization/SysOrganizationListsVo.java @@ -0,0 +1,17 @@ +package com.yxt.anrui.portal.api.sysorganization; + +import com.yxt.common.core.vo.Vo; +import lombok.Data; + +/** + * @Author dimengzhe + * @Date 2022/9/30 11:28 + * @Description + */ +@Data +public class SysOrganizationListsVo implements Vo { + private static final long serialVersionUID = -7021974833444298712L; + + private String orgDeptSid; + private String orgDeptName; +} diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.java index 0020c83dea..0f8c0efd34 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.java @@ -32,6 +32,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.toolkit.Constants; import com.yxt.anrui.portal.api.sysmapping.SysMappingInfoVo; import com.yxt.anrui.portal.api.sysmapping.SysMappingQuery; +import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; @@ -67,4 +68,9 @@ public interface SysMappingMapper extends BaseMapper { List selectListVo(); SysMappingInfoVo selectMappingInfo(@Param(Constants.WRAPPER) QueryWrapper qw); + + List selectMappingListInfo(@Param("dictSid") String dictSid); + + @Delete("delete from sys_mapping where dictSid = #{dictSid}") + void deleteByDictSid(@Param("dictSid") String dictSid); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.xml b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.xml index 91f7ceda36..71dff95347 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.xml +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingMapper.xml @@ -44,5 +44,16 @@ LEFT JOIN dict_type dt ON dc.dictType = dt.dictTypeCode ${ew.sqlSegment} + \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingRest.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingRest.java index 19db2ebc09..b71b59ae62 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingRest.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingRest.java @@ -110,4 +110,11 @@ public class SysMappingRest implements SysMappingFeign { SysMappingInfoVo vo = sysMappingService.selectMappingInfo(query); return rb.success().setData(vo); } + + @Override + public ResultBean> selectMappingListInfo(String dictSid) { + ResultBean> rb = ResultBean.fireFail(); + List vo = sysMappingService.selectMappingListInfo(dictSid); + return rb.success().setData(vo); + } } diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingService.java index 1475ffac0a..a2735afab6 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingService.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysmapping/SysMappingService.java @@ -135,11 +135,14 @@ public class SysMappingService extends MybatisBaseService dto) { - for (SysMappingDto sysMappingDto : dto) { - SysMapping entity = new SysMapping(); - BeanUtil.copyProperties(sysMappingDto, entity); - entity.setCreateBySid(sysMappingDto.getUserSid()); - save(entity); + if (dto.size() > 0) { + baseMapper.deleteByDictSid(dto.get(0).getDictSid()); + for (SysMappingDto sysMappingDto : dto) { + SysMapping entity = new SysMapping(); + BeanUtil.copyProperties(sysMappingDto, entity); + entity.setCreateBySid(sysMappingDto.getUserSid()); + save(entity); + } } } @@ -163,4 +166,8 @@ public class SysMappingService extends MybatisBaseService selectMappingListInfo(String dictSid) { + return baseMapper.selectMappingListInfo(dictSid); + } } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.java index d10355bfe8..40a43556b5 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.java @@ -106,6 +106,7 @@ public interface SysOrganizationMapper extends BaseMapper { SysOrgVo getListOrgByBrand(String sid); List selectOrgList(String orgSid); + List selectOrgLists(String orgSid); List selectByOrgDeptSid(String orgDeptSid); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.xml b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.xml index 9a0dd40813..b6a16a4e9b 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.xml +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationMapper.xml @@ -181,6 +181,12 @@ and orgAttributeKey = 'DP03_SYS' + + + + + UPDATE scm_collection_rebate_with_apply + SET nodeState=#{nodeState}, nodeSid=#{taskDefKey} + + , procDefId=#{procDefId} + + + , procInstId=#{procInsId} + + + , taskId=#{taskId} + + WHERE sid=#{sid} + \ No newline at end of file diff --git a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyRest.java b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyRest.java index d77ed982a6..3ed229fb3b 100644 --- a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyRest.java +++ b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyRest.java @@ -25,6 +25,14 @@ *********************************************************/ package com.yxt.anrui.scm.biz.scmcollectionrebatewithapply; +import cn.hutool.core.bean.BeanUtil; +import com.yxt.anrui.flowable.api.utils.ProcDefEnum; +import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; +import com.yxt.anrui.scm.api.flow.FlowTaskVo; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.GetNodeQuery; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.GetNodeVo; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.ScmCollectionRebateWithApplyCompleteDto; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.SubmitScmCollectionRebateWithApplyDto; import com.yxt.common.core.query.PagerQuery; import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.vo.PagerVo; @@ -91,4 +99,47 @@ public class ScmCollectionRebateWithApplyRest implements ScmCollectionRebateWith public ResultBean fetchDetailsBySid(@PathVariable("sid") String sid){ return scmCollectionRebateWithApplyService.fetchAllDetailsVo(sid); } + + @Override + public ResultBean submitCollectionRebateWithApply(SubmitScmCollectionRebateWithApplyDto dto) { + return scmCollectionRebateWithApplyService.submitCollectionRebateWithApply(dto); + } + + @Override + public ResultBean complete(ScmCollectionRebateWithApplyCompleteDto dto) { + BusinessVariables bv = new BusinessVariables(); + BeanUtil.copyProperties(dto, bv); + bv.setModelId(ProcDefEnum.SCMCOLLECTIONREBATEWITHAPPLY.getProDefId()); + return scmCollectionRebateWithApplyService.complete(bv); + } + + @Override + public ResultBean revokeProcess(FlowTaskVo flowTaskVo) { + return scmCollectionRebateWithApplyService.revokeProcess(flowTaskVo); + } + + @Override + public ResultBean taskReject(FlowTaskVo flowTaskVo) { + return scmCollectionRebateWithApplyService.taskReject(flowTaskVo); + } + + @Override + public ResultBean breakProcess(FlowTaskVo flowTaskVo) { + return scmCollectionRebateWithApplyService.breakProcess(flowTaskVo); + } + + @Override + public ResultBean flowRecord(String procInsId) { + return scmCollectionRebateWithApplyService.flowRecord(procInsId); + } + + @Override + public ResultBean> getNextNodesForSubmit(GetNodeQuery query) { + return scmCollectionRebateWithApplyService.getNextNodesForSubmit(query); + } + + @Override + public ResultBean> getPreviousNodesForReject(GetNodeQuery query) { + return scmCollectionRebateWithApplyService.getPreviousNodesForReject(query); + } } diff --git a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyService.java b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyService.java index e466dda661..6baafd4fd3 100644 --- a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyService.java +++ b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmcollectionrebatewithapply/ScmCollectionRebateWithApplyService.java @@ -26,11 +26,26 @@ package com.yxt.anrui.scm.biz.scmcollectionrebatewithapply; import cn.hutool.core.bean.BeanUtil; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.yxt.anrui.flowable.api.flow.FlowableFeign; +import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; +import com.yxt.anrui.flowable.api.flowtask.FlowTaskFeign; +import com.yxt.anrui.flowable.api.utils.ProcDefEnum; +import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; +import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg; +import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign; +import com.yxt.anrui.portal.api.sysuser.SysUserFeign; +import com.yxt.anrui.portal.api.sysuser.SysUserVo; +import com.yxt.anrui.scm.api.flow.FlowTaskVo; import com.yxt.anrui.scm.api.scmcollectionrebatewith.ScmCollectionRebateWith; import com.yxt.anrui.scm.api.scmcollectionrebatewith.ScmCollectionRebateWithDetailsVo; import com.yxt.anrui.scm.api.scmcollectionrebatewith.ScmCollectionRebateWithDto; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.GetNodeQuery; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.GetNodeVo; +import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.flow.SubmitScmCollectionRebateWithApplyDto; +import com.yxt.anrui.scm.biz.scmcollectionrebate.ScmCollectionRebateService; import com.yxt.anrui.scm.biz.scmcollectionrebatewith.ScmCollectionRebateWithService; import org.apache.commons.lang3.StringUtils; import com.yxt.common.base.service.MybatisBaseService; @@ -48,8 +63,8 @@ import com.yxt.anrui.scm.api.scmcollectionrebatewithapply.ScmCollectionRebateWit import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import java.util.Arrays; -import java.util.List; +import java.util.*; +import java.util.stream.Collectors; /** * Project: anrui-scm(回款返利)
@@ -67,131 +82,371 @@ import java.util.List; @Service public class ScmCollectionRebateWithApplyService extends MybatisBaseService { - @Autowired - private ScmCollectionRebateWithService scmCollectionRebateWithService; - - private QueryWrapper createQueryWrapper(ScmCollectionRebateWithApplyQuery query) { - // todo: 这里根据具体业务调整查询条件 - // 多字段Like示例:qw.and(wrapper -> wrapper.like("name", query.getName()).or().like("remark", query.getName())); - QueryWrapper qw = new QueryWrapper<>(); - return qw; - } - - public PagerVo listPageVo(PagerQuery pq) { - ScmCollectionRebateWithApplyQuery query = pq.getParams(); - QueryWrapper qw = new QueryWrapper<>(); - if (StringUtils.isNotBlank(query.getBrandSid())) { - qw.eq("scrwa.brandSid", query.getBrandSid()); - } - if (StringUtils.isNotBlank(query.getCollectionApply())) { - qw.like("scrwa.withApply", query.getCollectionApply()); - } - String createStartTime = query.getCreateStartTime(); - String createEndTime = query.getCreateEndTime(); - qw.apply(StringUtils.isNotBlank(createStartTime), "date_format (scrwa.createTime,'%Y-%m-%d') >= date_format('" + createStartTime + "','%Y-%m-%d')"). - apply(StringUtils.isNotBlank(createEndTime), "date_format (scrwa.createTime,'%Y-%m-%d') <= date_format('" + createEndTime + "','%Y-%m-%d')" - ); - qw.eq("scrwa.createOrgSid", query.getCreateOrgSid()); - qw.groupBy("scrwa.sid"); - qw.orderByDesc("scrwa.createTime"); - IPage page = PagerUtil.queryToPage(pq); - IPage pagging = baseMapper.selectPageVo(page, qw); - PagerVo p = PagerUtil.pageToVo(pagging, null); - return p; - } - - public ResultBean saveOrUpdateDto(ScmCollectionRebateWithApplyDto dto){ - ResultBean rb = ResultBean.fireFail(); - String dtoSid = dto.getSid(); - List scmCollectionRebateWiths = dto.getScmCollectionRebateWiths(); - if (scmCollectionRebateWiths == null) { - return rb.setMsg("请选择回款返利信息"); - } - if (StringUtils.isBlank(dtoSid)) { - String sid = this.insertByDto(dto).getData(); - for (ScmCollectionRebateWithDto scmCollectionRebateWithDto : scmCollectionRebateWiths) { - List collectionRebateSids = scmCollectionRebateWithDto.getCollectionRebateSids(); - for (String collectionRebateSid : collectionRebateSids) { - ScmCollectionRebateWith scmCollectionRebateWith = new ScmCollectionRebateWith(); - scmCollectionRebateWith.setCollectionRebateSid(collectionRebateSid); - scmCollectionRebateWith.setMainSid(sid); - scmCollectionRebateWithService.save(scmCollectionRebateWith); - } - } - return rb.success().setMsg("添加成功").setData(sid); - } - ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(dtoSid); - if (scmCollectionRebateWithApply == null) { - rb.setMsg("该回款返利预提申请单不存在"); - } - this.updateByDto(dto); - scmCollectionRebateWithService.delByMainSid(dtoSid); - for (ScmCollectionRebateWithDto scmCollectionRebateWithDto : scmCollectionRebateWiths) { - List collectionRebateSids = scmCollectionRebateWithDto.getCollectionRebateSids(); - for (String collectionRebateSid : collectionRebateSids) { - ScmCollectionRebateWith scmCollectionRebateWith = new ScmCollectionRebateWith(); - scmCollectionRebateWith.setCollectionRebateSid(collectionRebateSid); - scmCollectionRebateWith.setMainSid(dtoSid); - scmCollectionRebateWithService.save(scmCollectionRebateWith); - } - } - return rb.success().setMsg("修改成功").setData(dtoSid); - } - - public ResultBean insertByDto(ScmCollectionRebateWithApplyDto dto){ - ResultBean rb = ResultBean.fireFail(); - ScmCollectionRebateWithApply entity = new ScmCollectionRebateWithApply(); - BeanUtil.copyProperties(dto, entity, "id", "sid"); - entity.setNodeState("待提交"); - baseMapper.insert(entity); - return rb.success().setData(entity.getSid()); - } - - public void updateByDto(ScmCollectionRebateWithApplyDto dto){ - String dtoSid = dto.getSid(); + @Autowired + private ScmCollectionRebateWithService scmCollectionRebateWithService; + @Autowired + private ScmCollectionRebateService scmCollectionRebateService; + @Autowired + private SysStaffOrgFeign sysStaffOrgFeign; + @Autowired + private FlowableFeign flowableFeign; + @Autowired + private FlowTaskFeign flowTaskFeign; + @Autowired + private SysUserFeign sysUserFeign; + + private QueryWrapper createQueryWrapper(ScmCollectionRebateWithApplyQuery query) { + // todo: 这里根据具体业务调整查询条件 + // 多字段Like示例:qw.and(wrapper -> wrapper.like("name", query.getName()).or().like("remark", query.getName())); + QueryWrapper qw = new QueryWrapper<>(); + return qw; + } + + public PagerVo listPageVo(PagerQuery pq) { + ScmCollectionRebateWithApplyQuery query = pq.getParams(); + QueryWrapper qw = new QueryWrapper<>(); + if (StringUtils.isNotBlank(query.getBrandSid())) { + qw.eq("scrwa.brandSid", query.getBrandSid()); + } + if (StringUtils.isNotBlank(query.getCollectionApply())) { + qw.like("scrwa.withApply", query.getCollectionApply()); + } + String createStartTime = query.getCreateStartTime(); + String createEndTime = query.getCreateEndTime(); + qw.apply(StringUtils.isNotBlank(createStartTime), "date_format (scrwa.createTime,'%Y-%m-%d') >= date_format('" + createStartTime + "','%Y-%m-%d')"). + apply(StringUtils.isNotBlank(createEndTime), "date_format (scrwa.createTime,'%Y-%m-%d') <= date_format('" + createEndTime + "','%Y-%m-%d')" + ); + qw.eq("scrwa.createOrgSid", query.getCreateOrgSid()); + qw.groupBy("scrwa.sid"); + qw.orderByDesc("scrwa.createTime"); + IPage page = PagerUtil.queryToPage(pq); + IPage pagging = baseMapper.selectPageVo(page, qw); + PagerVo p = PagerUtil.pageToVo(pagging, null); + return p; + } + + public ResultBean saveOrUpdateDto(ScmCollectionRebateWithApplyDto dto) { + ResultBean rb = ResultBean.fireFail(); + String dtoSid = dto.getSid(); + List scmCollectionRebateWiths = dto.getScmCollectionRebateWiths(); + if (scmCollectionRebateWiths == null) { + return rb.setMsg("请选择回款返利信息"); + } + if (StringUtils.isBlank(dtoSid)) { + String sid = this.insertByDto(dto).getData(); + for (ScmCollectionRebateWithDto scmCollectionRebateWithDto : scmCollectionRebateWiths) { + List collectionRebateSids = scmCollectionRebateWithDto.getCollectionRebateSids(); + for (String collectionRebateSid : collectionRebateSids) { + ScmCollectionRebateWith scmCollectionRebateWith = new ScmCollectionRebateWith(); + scmCollectionRebateWith.setCollectionRebateSid(collectionRebateSid); + scmCollectionRebateWith.setMainSid(sid); + scmCollectionRebateWithService.save(scmCollectionRebateWith); + } + } + return rb.success().setMsg("添加成功").setData(sid); + } + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(dtoSid); + if (scmCollectionRebateWithApply == null) { + rb.setMsg("该回款返利预提申请单不存在"); + } + this.updateByDto(dto); + scmCollectionRebateWithService.delByMainSid(dtoSid); + for (ScmCollectionRebateWithDto scmCollectionRebateWithDto : scmCollectionRebateWiths) { + List collectionRebateSids = scmCollectionRebateWithDto.getCollectionRebateSids(); + for (String collectionRebateSid : collectionRebateSids) { + ScmCollectionRebateWith scmCollectionRebateWith = new ScmCollectionRebateWith(); + scmCollectionRebateWith.setCollectionRebateSid(collectionRebateSid); + scmCollectionRebateWith.setMainSid(dtoSid); + scmCollectionRebateWithService.save(scmCollectionRebateWith); + } + } + return rb.success().setMsg("修改成功").setData(dtoSid); + } + + public ResultBean insertByDto(ScmCollectionRebateWithApplyDto dto) { + ResultBean rb = ResultBean.fireFail(); + ScmCollectionRebateWithApply entity = new ScmCollectionRebateWithApply(); + BeanUtil.copyProperties(dto, entity, "id", "sid"); + entity.setNodeState("待提交"); + baseMapper.insert(entity); + return rb.success().setData(entity.getSid()); + } + + public void updateByDto(ScmCollectionRebateWithApplyDto dto) { + String dtoSid = dto.getSid(); if (StringUtils.isBlank(dtoSid)) { return; - } - ScmCollectionRebateWithApply entity = fetchBySid(dtoSid); - BeanUtil.copyProperties(dto, entity, "id", "sid"); - baseMapper.updateById(entity); - } - - public ScmCollectionRebateWithApplyDetailsVo fetchDetailsVoBySid(String sid){ - ScmCollectionRebateWithApply entity = fetchBySid(sid); - ScmCollectionRebateWithApplyDetailsVo vo = new ScmCollectionRebateWithApplyDetailsVo(); - BeanUtil.copyProperties(entity, vo); - return vo; - } - - public ResultBean delAll(String[] sids) { - ResultBean rb = ResultBean.fireFail(); - //查询该sid中是否有流程不是待提交的 - int count = baseMapper.selectBySid(StringUtils.join(sids, ",")); - if (count > 0) { - return rb.setMsg("删除的数据中包含已经提交审批的数据,删除失败"); - } - delBySids(sids); - for (String sid : sids) { - scmCollectionRebateWithService.delByMainSid(sid); - } - return rb.success().setMsg("删除成功"); - } - - public ResultBean fetchAllDetailsVo(String sid) { - ResultBean rb = ResultBean.fireFail(); - ScmCollectionRebateWithApplyDetailsVo scmCollectionRebateWithApplyDetailsVo = new ScmCollectionRebateWithApplyDetailsVo(); - ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(sid); - BeanUtil.copyProperties(scmCollectionRebateWithApply, scmCollectionRebateWithApplyDetailsVo); - List scmCollectionRebateWithDetailsVos = scmCollectionRebateWithService.fetchByMainSid(sid); - for (ScmCollectionRebateWithDetailsVo scmCollectionRebateWithDetailsVo : scmCollectionRebateWithDetailsVos) { - String[] specialRebateSids = scmCollectionRebateWithDetailsVo.getCollectionRebateSid().split(","); - scmCollectionRebateWithDetailsVo.setCollectionRebateSids(Arrays.asList(specialRebateSids)); - String withRebate = scmCollectionRebateWithDetailsVo.getWithRebate(); - withRebate = withRebate.substring(0, withRebate.lastIndexOf(".")); - scmCollectionRebateWithDetailsVo.setWithRebate(withRebate); - } - scmCollectionRebateWithApplyDetailsVo.setScmCollectionRebateWiths(scmCollectionRebateWithDetailsVos); - return rb.success().setData(scmCollectionRebateWithApplyDetailsVo); - } + } + ScmCollectionRebateWithApply entity = fetchBySid(dtoSid); + BeanUtil.copyProperties(dto, entity, "id", "sid"); + baseMapper.updateById(entity); + } + + public ScmCollectionRebateWithApplyDetailsVo fetchDetailsVoBySid(String sid) { + ScmCollectionRebateWithApply entity = fetchBySid(sid); + ScmCollectionRebateWithApplyDetailsVo vo = new ScmCollectionRebateWithApplyDetailsVo(); + BeanUtil.copyProperties(entity, vo); + return vo; + } + + public ResultBean delAll(String[] sids) { + ResultBean rb = ResultBean.fireFail(); + //查询该sid中是否有流程不是待提交的 + int count = baseMapper.selectBySid(StringUtils.join(sids, ",")); + if (count > 0) { + return rb.setMsg("删除的数据中包含已经提交审批的数据,删除失败"); + } + delBySids(sids); + for (String sid : sids) { + scmCollectionRebateWithService.delByMainSid(sid); + } + return rb.success().setMsg("删除成功"); + } + + public ResultBean fetchAllDetailsVo(String sid) { + ResultBean rb = ResultBean.fireFail(); + ScmCollectionRebateWithApplyDetailsVo scmCollectionRebateWithApplyDetailsVo = new ScmCollectionRebateWithApplyDetailsVo(); + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(sid); + BeanUtil.copyProperties(scmCollectionRebateWithApply, scmCollectionRebateWithApplyDetailsVo); + List scmCollectionRebateWithDetailsVos = scmCollectionRebateWithService.fetchByMainSid(sid); + for (ScmCollectionRebateWithDetailsVo scmCollectionRebateWithDetailsVo : scmCollectionRebateWithDetailsVos) { + String[] collectionRebateSids = scmCollectionRebateWithDetailsVo.getCollectionRebateSid().split(","); + scmCollectionRebateWithDetailsVo.setCollectionRebateSids(Arrays.asList(collectionRebateSids)); + String withRebate = scmCollectionRebateWithDetailsVo.getWithRebate(); + withRebate = withRebate.substring(0, withRebate.lastIndexOf(".")); + scmCollectionRebateWithDetailsVo.setWithRebate(withRebate); + } + scmCollectionRebateWithApplyDetailsVo.setScmCollectionRebateWiths(scmCollectionRebateWithDetailsVos); + return rb.success().setData(scmCollectionRebateWithApplyDetailsVo); + } + + public ResultBean submitCollectionRebateWithApply(SubmitScmCollectionRebateWithApplyDto dto) { + ResultBean rb = ResultBean.fireFail(); + //根据用户sid获取staffSid + ResultBean userVoResultBean = sysUserFeign.fetchBySid(dto.getCreateBySid()); + if (!userVoResultBean.getSuccess()) { + return rb.setMsg(userVoResultBean.getMsg()); + } + //根据staffSid获取用户的组织全路径 + ResultBean orgByStaffSid = sysStaffOrgFeign.getOrgByStaffSid(userVoResultBean.getData().getStaffSid()); + if (!orgByStaffSid.getSuccess()) { + return rb.setMsg(orgByStaffSid.getMsg()); + } + //用户的组织全路径 + String orgSidPath = orgByStaffSid.getData().getOrgSidPath(); + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(dto.getSid()); + int r = submitBusinessData(dto, scmCollectionRebateWithApply); + if (r == 3) { + return rb.setMsg("该申请不存在"); + } + if (r == 0) { + return rb.setMsg("操作失败!提交的数据不一致"); + } + //新增修改保存 + ResultBean resultBean = saveOrUpdateDto(dto); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + String businessSid = resultBean.getData(); + //创建BusinessVariables实体对象 + BusinessVariables bv = new BusinessVariables(); + //流程中的参数赋值 + Map variables = BeanUtil.beanToMap(dto); + //若有网关,则赋值网关中判断的字段。 + variables.put("businessSid", businessSid); + //=====================添加app所需参数 + Map appMap = new HashMap<>(); + appMap.put("sid", businessSid); + variables.put("app", appMap); + //用户的部门全路径sid + bv.setOrgSidPath(orgSidPath); + //业务sid + bv.setBusinessSid(businessSid); + //用户sid + bv.setUserSid(dto.getCreateBySid()); + bv.setFormVariables(variables); + //流程定义id + bv.setModelId(ProcDefEnum.SCMCOLLECTIONREBATEWITHAPPLY.getProDefId()); + //获取回款返利sid + List scmCollectionRebateWiths = dto.getScmCollectionRebateWiths(); + for (ScmCollectionRebateWithDto scmCollectionRebateWith : scmCollectionRebateWiths) { + List collectionRebateSids = scmCollectionRebateWith.getCollectionRebateSids(); + for (String collectionRebateSid : collectionRebateSids) { + scmCollectionRebateService.updateWithholdingDateBySid(collectionRebateSid); + } + } + if (r == 1) { + ResultBean voResultBean = flowableFeign.startProcess(bv); + UpdateFlowFieldVo ufVo = voResultBean.getData(); + updateFlowFiled(BeanUtil.beanToMap(ufVo)); + + return voResultBean; + } + if (r == 2) { + // ToDo:驳回到发起人后再次提交 + if (StringUtils.isBlank(dto.getInstanceId())) { + return rb.setMsg("参数错误:instanceId"); + } + bv.setTaskId(scmCollectionRebateWithApply.getTaskId()); + bv.setTaskDefKey(scmCollectionRebateWithApply.getNodeSid()); + bv.setComment(StringUtils.isNotBlank(dto.getComment()) ? dto.getComment() : "重新提交"); + bv.setInstanceId(dto.getInstanceId()); + return complete(bv); + } + return rb; + } + + /** + * 判断提交的流程是否被允许 + * + * @param dto + * @return + */ + private synchronized int submitBusinessData(SubmitScmCollectionRebateWithApplyDto dto, ScmCollectionRebateWithApply scmCollectionRebateWithApply) { + int r = 0; + if (StringUtils.isBlank(dto.getSid())) { + r = 1; + } else { + if (scmCollectionRebateWithApply != null) { + String businessTaskId = scmCollectionRebateWithApply.getTaskId(); + if (StringUtils.isBlank(businessTaskId) && StringUtils.isBlank(dto.getTaskId())) { + //新提交 + r = 1; + } else if (StringUtils.isNotBlank(businessTaskId) && businessTaskId.equals(dto.getTaskId())) { + //二次提交//只有数据一致的时候才能进行下一步 + r = 2; + } + } else { + r = 3; + } + + } + return r; + } + + private int updateFlowFiled(Map beanToMap) { + return baseMapper.updateFlowFiled(beanToMap); + } + + public ResultBean complete(BusinessVariables bv) { + ResultBean rb = ResultBean.fireFail(); + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(bv.getBusinessSid()); + List collectionRebateSids = scmCollectionRebateWithService.fetchCollectionReBateSidByMainSid(bv.getBusinessSid()); + if (bv.getTaskId().equals(scmCollectionRebateWithApply.getTaskId())) { + ResultBean resultBean = flowableFeign.handleProsess(bv); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); + if ("Event_end".equals(resultBean.getData().getTaskDefKey())) { + for (String collectionRebateSid : collectionRebateSids) { + scmCollectionRebateService.updateState(collectionRebateSid); + } + } + return rb.success().setData(resultBean.getData()); + } else { + return rb.setMsg("操作失败!提交的数据不一致"); + } + } + + public ResultBean revokeProcess(FlowTaskVo query) { + ResultBean rb = ResultBean.fireFail(); + if (StringUtils.isBlank(query.getUserSid())) { + return rb.setMsg("参数错误:userSid"); + } + //根据业务sid查询排内购申请 + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(query.getBusinessSid()); + String businessTaskId = scmCollectionRebateWithApply.getTaskId(); + if (StringUtils.isNotBlank(businessTaskId)) { + if (businessTaskId.equals(query.getTaskId())) { + com.yxt.anrui.flowable.api.flowtask.FlowTaskVo flowTaskVo = new com.yxt.anrui.flowable.api.flowtask.FlowTaskVo(); + BeanUtil.copyProperties(query, flowTaskVo); + flowTaskVo.setValues(BeanUtil.beanToMap(scmCollectionRebateWithApply)); + ResultBean resultBean = flowableFeign.revokeProcess(flowTaskVo); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); + return rb.success().setData(resultBean.getData()); + } + } + return rb.setMsg("操作失败,提交的数据不一致!"); + } + + public ResultBean taskReject(FlowTaskVo query) { + ResultBean rb = ResultBean.fireFail(); + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(query.getBusinessSid()); + if (scmCollectionRebateWithApply == null) { + return rb.setMsg("该申请不存在"); + } + String businessTaskId = scmCollectionRebateWithApply.getTaskId(); + if (StringUtils.isNotBlank(businessTaskId)) { + if (businessTaskId.equals(query.getTaskId())) { + com.yxt.anrui.flowable.api.flowtask.FlowTaskVo flowTaskVo = new com.yxt.anrui.flowable.api.flowtask.FlowTaskVo(); + BeanUtil.copyProperties(query, flowTaskVo); + ResultBean resultBean = flowableFeign.taskReject(flowTaskVo); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + Map map = BeanUtil.beanToMap(resultBean.getData()); + //更新业务中的流程相关的参数 + updateFlowFiled(map); + return rb.success(); + } + } + return rb.setMsg("操作失败!提交的数据不一致!"); + } + + public ResultBean breakProcess(FlowTaskVo query) { + ResultBean rb = ResultBean.fireFail(); + if (StringUtils.isBlank(query.getInstanceId())) { + return rb.setMsg("参数错误:instanceId"); + } + if (StringUtils.isBlank(query.getUserSid())) { + return rb.setMsg("参数错误:userSid"); + } + ScmCollectionRebateWithApply scmCollectionRebateWithApply = fetchBySid(query.getBusinessSid()); + String businessTaskId = scmCollectionRebateWithApply.getTaskId(); + if (StringUtils.isNotBlank(businessTaskId)) { + if (businessTaskId.equals(query.getTaskId())) { + com.yxt.anrui.flowable.api.flowtask.FlowTaskVo flowTaskVo = new com.yxt.anrui.flowable.api.flowtask.FlowTaskVo(); + BeanUtil.copyProperties(query, flowTaskVo); + ResultBean resultBean = flowableFeign.breakProcess(flowTaskVo); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); + return rb.success().setData(resultBean.getData()); + } + } + return rb.setMsg("操作失败!提交的数据不一致!"); + } + + public ResultBean flowRecord(String procInsId) { + return flowTaskFeign.businessFlowRecord(procInsId); + } + + public ResultBean> getNextNodesForSubmit(GetNodeQuery query) { + ResultBean> rb = ResultBean.fireFail(); + BusinessVariables bv = new BusinessVariables(); + BeanUtil.copyProperties(query, bv); + bv.setModelId(ProcDefEnum.SCMCOLLECTIONREBATEWITHAPPLY.getProDefId()); + ResultBean>> resultBean = flowTaskFeign.getNextNodesForSubmit(bv); + //判断数组是否为空,若为空则赋值,若不为空,则遍历循环将map中的数据赋值给getNodeVo + List voList = Optional.ofNullable(resultBean.getData()).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), GetNodeVo.class)).collect(Collectors.toList()); +// List voList = resultBean.getData().stream().map(m -> JSON.parseObject(JSON.toJSONString(m), GetNodeVo.class)).collect(Collectors.toList()); + return rb.success().setData(voList); + } + + public ResultBean> getPreviousNodesForReject(GetNodeQuery query) { + ResultBean> rb = ResultBean.fireFail(); + BusinessVariables bv = new BusinessVariables(); + BeanUtil.copyProperties(query, bv); + bv.setModelId(ProcDefEnum.SCMCOLLECTIONREBATEWITHAPPLY.getProDefId()); + ResultBean>> resultBean = flowTaskFeign.getPreviousNodesForReject(bv); + //判断数组是否为空,若为空则赋值,若不为空,则遍历循环将map中的数据赋值给getNodeVo + List voList = Optional.ofNullable(resultBean.getData()).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), GetNodeVo.class)).collect(Collectors.toList()); +// List voList = resultBean.getData().stream().map(m -> JSON.parseObject(JSON.toJSONString(m), GetNodeVo.class)).collect(Collectors.toList()); + return rb.success().setData(voList); + } } \ No newline at end of file diff --git a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehicleinventory/ScmVehicleInventoryMapper.xml b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehicleinventory/ScmVehicleInventoryMapper.xml index 14b81f7793..a1e03cf5be 100644 --- a/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehicleinventory/ScmVehicleInventoryMapper.xml +++ b/anrui-scm/anrui-scm-biz/src/main/java/com/yxt/anrui/scm/biz/scmvehicleinventory/ScmVehicleInventoryMapper.xml @@ -118,11 +118,11 @@ - SELECT sid, - mainSid as recordSid, - vinNo as vin, - model, - modelSid, - situationExplain as `explain`, - problems, - results, - dutyName as liableName, - dutySid as liableSid, - location, - address, - createBySid as userSid - FROM scm_vehicle_patrolinspectionsheet - WHERE mainSid = #{recordSid} + SELECT svps.sid, + svps.mainSid as recordSid, + svps.vinNo as vin, + svps.model, + svps.modelSid, + svps.situationExplain as `explain`, + svps.problems, + svps.results, + svps.dutyName as liableName, + svps.dutySid as liableSid, + svps.location, + svps.address, + svps.createBySid as userSid + FROM scm_vehicle_patrolinspectionsheet svps + WHERE svps.mainSid = #{recordSid}