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("