From 13d521df34300f0131e848a2d00b3c71c727a80a Mon Sep 17 00:00:00 2001 From: Yen Date: Tue, 7 May 2024 10:09:45 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E4=BF=AE=E5=A4=8D=E5=9B=A0?= =?UTF-8?q?=E6=9C=AC=E5=9C=B0=E5=8C=96bir=E5=AF=BC=E8=87=B4=E7=9A=84?= =?UTF-8?q?=E5=B8=B8=E8=A7=84=E7=94=B3=E8=AF=B7=E6=88=90=E6=9C=AC=E4=B8=AD?= =?UTF-8?q?=E5=BF=83=E4=B8=A2=E5=A4=B1=20fix=EF=BC=9A=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=9B=A0=E9=80=80=E5=9B=9E=E6=9C=AA=E9=80=82=E9=85=8D=EF=BC=8C?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=B4=B9=E7=94=A8=E7=9A=84=E6=B4=BB=E5=8A=A8?= =?UTF-8?q?=E7=8A=B6=E6=80=81=E5=BC=82=E5=B8=B8=20fix=EF=BC=9A=E8=AE=A2?= =?UTF-8?q?=E5=8D=95=E7=A9=BA=E6=8C=87=E9=92=88=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/qs/serve/common/util/BirHttpUtil.java | 12 +++--- .../BirActivityCenterGoodsController.java | 22 ++++++++++ .../impl/BirCenterRateServiceImpl.java | 2 +- .../modules/goods/entity/GoodsCategory.java | 2 +- .../oms/service/impl/OmsOrderServiceImpl.java | 3 ++ .../tbs/controller/TbsActivityController.java | 4 ++ .../TbsActivityPayConditionController.java | 3 ++ .../mapper/TbsActivityCenterGoodsMapper.java | 9 ++++ .../tbs/mapper/TbsCostCheckStateMapper.java | 6 +++ .../TbsCostApplyOperationServiceImpl.java | 8 +++- .../impl/TbsCostApplyPart1ServiceImpl.java | 43 +++++++++++++++++++ .../service/impl/TbsCostApplyServiceImpl.java | 14 ++++-- .../impl/VtbVerificationServiceImpl.java | 1 + src/main/resources/application-dev.yml | 4 +- 14 files changed, 118 insertions(+), 15 deletions(-) diff --git a/src/main/java/com/qs/serve/common/util/BirHttpUtil.java b/src/main/java/com/qs/serve/common/util/BirHttpUtil.java index b967ba49..d23b1512 100644 --- a/src/main/java/com/qs/serve/common/util/BirHttpUtil.java +++ b/src/main/java/com/qs/serve/common/util/BirHttpUtil.java @@ -44,11 +44,7 @@ public class BirHttpUtil { public static String getBaseUrl(){ ProjectProperties projectProperties = SpringUtils.getBean(ProjectProperties.class); - boolean isRestBir = projectProperties.getBirService().equals("true"); - if(isRestBir){ - return projectProperties.getBirServiceUrl(); - } - return null; + return projectProperties.getBirServiceUrl(); } public static R get(String action){ @@ -83,6 +79,10 @@ public class BirHttpUtil { if(PageUtil.getPageNum()!=null){ url += "&pageNum="+PageUtil.getPageNum(); } + url = url.replace("//","/"); + url = url.replace("http:/","http://"); + url = url.replace("https:/","https://"); + log.debug("请求BIR中转URL:{}",url); String result = HttpUtil.doGet(url,hearders); log.debug("请求BIR中转URL:{}\n数据返回:{}",url,result); JSONObject object = JSON.parseObject(result); @@ -106,7 +106,7 @@ public class BirHttpUtil { String json = result.getData().toString(); return JsonUtil.jsonToPojo(json,TbsCostSubItem.CostCenterTranStr.class); } catch (Exception e) { - + e.printStackTrace(); } return null; } diff --git a/src/main/java/com/qs/serve/modules/bir/controller/BirActivityCenterGoodsController.java b/src/main/java/com/qs/serve/modules/bir/controller/BirActivityCenterGoodsController.java index ab3aea06..68ce75f8 100644 --- a/src/main/java/com/qs/serve/modules/bir/controller/BirActivityCenterGoodsController.java +++ b/src/main/java/com/qs/serve/modules/bir/controller/BirActivityCenterGoodsController.java @@ -29,9 +29,11 @@ import com.qs.serve.modules.bms.service.BmsChannelService; import com.qs.serve.modules.bms.service.BmsSupplierChannelService; import com.qs.serve.modules.his.service.HisUserChannelPointService; import com.qs.serve.modules.oss.service.OssService; +import com.qs.serve.modules.tbs.entity.TbsActivityCenterGoods; import com.qs.serve.modules.tbs.entity.TbsActivityChannel; import com.qs.serve.modules.tbs.entity.TbsCostApply; import com.qs.serve.modules.tbs.entity.TbsCostBirLog; +import com.qs.serve.modules.tbs.mapper.TbsActivityCenterGoodsMapper; import com.qs.serve.modules.tbs.mapper.TbsCostBirLogMapper; import com.qs.serve.modules.tbs.service.TbsActivityChannelService; import com.qs.serve.modules.tbs.service.TbsCostApplyService; @@ -64,6 +66,7 @@ public class BirActivityCenterGoodsController { private TbsCostApplyService tbsCostApplyService; private ProjectProperties projectProperties; private TbsCostBirLogMapper tbsCostBirLogMapper; + private TbsActivityCenterGoodsMapper tbsActivityCenterGoodsMapper; @GetMapping("/toSyncBir") public R syncBir(Long costId){ @@ -84,6 +87,25 @@ public class BirActivityCenterGoodsController { return R.ok(); } + @GetMapping("/toSyncBirToday") + public R toSyncBirEcro2(){ + //Long[] ids = new Long[]{301897L}; + Set ids = tbsActivityCenterGoodsMapper.selectUpdateCostApplyIds(); + List errIds = new ArrayList<>(); + for (Long id : ids) { + try { + centerGoodsService.rebuildBir(Arrays.asList(id)); + } catch (Exception e) { + e.printStackTrace(); + errIds.add(id); + } + } + for (Long errId : errIds) { + log.error("错误的费用申请ID:{}",errId); + } + return R.ok(); + } + /** * 移除因作废的费用申请导致的bir数据 * @return diff --git a/src/main/java/com/qs/serve/modules/bir/service/impl/BirCenterRateServiceImpl.java b/src/main/java/com/qs/serve/modules/bir/service/impl/BirCenterRateServiceImpl.java index 73e2532e..f7eaed11 100644 --- a/src/main/java/com/qs/serve/modules/bir/service/impl/BirCenterRateServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/bir/service/impl/BirCenterRateServiceImpl.java @@ -281,7 +281,7 @@ public class BirCenterRateServiceImpl implements BirCenterRateService { List tbsBudgetList = tbsBudgetMapper.selectList(budgetLambdaQueryWrapper); //通过预算ID取预算的发货和金额 LambdaQueryWrapper scheduleItemBudgetLambdaQueryWrapper = new LambdaQueryWrapper<>(); - scheduleItemBudgetLambdaQueryWrapper.in(TbsScheduleItemBudget::getBudgetId,tbsBudgetList.stream().map(a->a.getId()).collect(Collectors.toList())); + scheduleItemBudgetLambdaQueryWrapper.in(TbsScheduleItemBudget::getBudgetId,tbsBudgetList.stream().map(TbsBudget::getId).collect(Collectors.toList())); List scheduleItemBudgetList = tbsScheduleItemBudgetMapper.selectList(scheduleItemBudgetLambdaQueryWrapper); //合计目标发货和金定额 BigDecimal targetDispatchAmout = scheduleItemBudgetList.stream().map(a->a.getPreDispatchAmount()==null?BigDecimal.ZERO:a.getPreDispatchAmount()).reduce(BigDecimal.ZERO,BigDecimal::add); diff --git a/src/main/java/com/qs/serve/modules/goods/entity/GoodsCategory.java b/src/main/java/com/qs/serve/modules/goods/entity/GoodsCategory.java index d4f1085d..a840359d 100644 --- a/src/main/java/com/qs/serve/modules/goods/entity/GoodsCategory.java +++ b/src/main/java/com/qs/serve/modules/goods/entity/GoodsCategory.java @@ -39,7 +39,7 @@ public class GoodsCategory implements Serializable { private Long parentId; /** 名称 */ - @Length(max = 16,message = "名称长度不能超过16字") + @Length(max = 64,message = "名称长度不能超过16字") private String name; /** 排序 */ diff --git a/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderServiceImpl.java b/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderServiceImpl.java index f15fb763..dc3c45a7 100644 --- a/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderServiceImpl.java @@ -329,6 +329,9 @@ public class OmsOrderServiceImpl extends ServiceImpl im List skuCodes = newOrderItemList.stream().map(OmsOrderItem::getSkuCode).collect(Collectors.toList()); + //防止空指针 + skuCodes.add("NULL"); + List customerPrices = goodsCustomerPriceService.getBySupplierCodeAndCode(supplier.getCode(),skuCodes); for (OmsOrderItem orderItem : newOrderItemList) { for (GoodsCustomerPrice customerPrice : customerPrices) { diff --git a/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityController.java b/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityController.java index ae6d6060..a5fc8b4c 100644 --- a/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityController.java +++ b/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityController.java @@ -477,6 +477,10 @@ public class TbsActivityController { @GetMapping("/flushAmount2/{id}") @SysLog(module = SystemModule.Budget, title = "费用活动", biz = BizType.DELETE) public R flushActivityAmount2(@PathVariable("id") Long id){ +// Long[] ids = new Long[]{} +// for (Long aLong : ids) { +// tbsCostApplyPart1Service.updateAmtAndRateByActSubject(aLong); +// } tbsCostApplyPart1Service.updateAmtAndRateByActSubject(id); return R.ok(); } diff --git a/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityPayConditionController.java b/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityPayConditionController.java index ea2848de..2dabc14c 100644 --- a/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityPayConditionController.java +++ b/src/main/java/com/qs/serve/modules/tbs/controller/TbsActivityPayConditionController.java @@ -121,6 +121,9 @@ public class TbsActivityPayConditionController { } TbsActivityPayCondition entity = CopierUtil.copy(param,new TbsActivityPayCondition()); List activityList = tbsActivityService.listByCostApplyId(param.getCostApplyId()); + if(activityList.size()<1){ + Assert.throwEx("未存在有效活动"); + } Long actId = activityList.get(0).getId(); entity.setActivityId(actId); entity.setPreNotifyStatus(param.getPreNotifyTime()==null?0:1); diff --git a/src/main/java/com/qs/serve/modules/tbs/mapper/TbsActivityCenterGoodsMapper.java b/src/main/java/com/qs/serve/modules/tbs/mapper/TbsActivityCenterGoodsMapper.java index 7fadd6b9..21fffc05 100644 --- a/src/main/java/com/qs/serve/modules/tbs/mapper/TbsActivityCenterGoodsMapper.java +++ b/src/main/java/com/qs/serve/modules/tbs/mapper/TbsActivityCenterGoodsMapper.java @@ -8,6 +8,7 @@ import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import java.util.List; +import java.util.Set; /** * 活动成本中心配比项 Mapper @@ -16,6 +17,14 @@ import java.util.List; */ public interface TbsActivityCenterGoodsMapper extends BaseMapper { + @InterceptorIgnore(tenantLine = "1") + @Select("SELECT cost_apply_id FROM tbs_activity_center_goods \n" + + "left join tbs_cost_apply on tbs_activity_center_goods.cost_apply_id = tbs_cost_apply.id\n" + + "where tbs_cost_apply.del_flag = 0 and tbs_activity_center_goods.del_flag = 0\n" + + "and DATE(tbs_activity_center_goods.update_time) = DATE(CURDATE())\n" + + "GROUP BY cost_apply_id") + Set selectUpdateCostApplyIds(); + @Select("