diff --git a/src/main/java/com/qs/serve/common/framework/aop/RedisCacheAspect.java b/src/main/java/com/qs/serve/common/framework/aop/RedisCacheAspect.java index c0a52a3b..9645def9 100644 --- a/src/main/java/com/qs/serve/common/framework/aop/RedisCacheAspect.java +++ b/src/main/java/com/qs/serve/common/framework/aop/RedisCacheAspect.java @@ -27,8 +27,8 @@ import java.util.concurrent.TimeUnit; * @since 2024/10/18 */ @Slf4j -@Aspect -@Component +//@Aspect +//@Component @AllArgsConstructor public class RedisCacheAspect { diff --git a/src/main/java/com/qs/serve/common/model/dto/SimpleKeyValue.java b/src/main/java/com/qs/serve/common/model/dto/SimpleKeyValue.java index b2726302..d7eb4b61 100644 --- a/src/main/java/com/qs/serve/common/model/dto/SimpleKeyValue.java +++ b/src/main/java/com/qs/serve/common/model/dto/SimpleKeyValue.java @@ -2,13 +2,17 @@ package com.qs.serve.common.model.dto; import lombok.AllArgsConstructor; import lombok.Data; +import lombok.NoArgsConstructor; + +import javax.validation.constraints.NotNull; /** * @author YenHex * @since 2022/3/7 */ @Data -@AllArgsConstructor +@NotNull +@NoArgsConstructor public class SimpleKeyValue { /** 键 */ @@ -17,9 +21,16 @@ public class SimpleKeyValue { /** 值 */ private T value; + private String value2; + /** 说明 */ private String remark; + public SimpleKeyValue(String label,T value,String remark){ + this.label = label; + this.value = value; + this.remark = remark; + } public SimpleKeyValue(String label,T value){ this.label = label; this.value = value; diff --git a/src/main/java/com/qs/serve/common/util/CodeGenUtil.java b/src/main/java/com/qs/serve/common/util/CodeGenUtil.java index a3214536..5fcb46a4 100644 --- a/src/main/java/com/qs/serve/common/util/CodeGenUtil.java +++ b/src/main/java/com/qs/serve/common/util/CodeGenUtil.java @@ -59,7 +59,7 @@ public class CodeGenUtil { "X" , "Y" }; - public static Long getIdx(String key){ + public static synchronized Long getIdx(String key){ RedisService redisService = SpringUtils.getBean(RedisService.class); Long value = redisService.getLong(key); if(value==null){ diff --git a/src/main/java/com/qs/serve/modules/biz/controller/BizVisitController.java b/src/main/java/com/qs/serve/modules/biz/controller/BizVisitController.java index 8b8e2ae0..58da5bf8 100644 --- a/src/main/java/com/qs/serve/modules/biz/controller/BizVisitController.java +++ b/src/main/java/com/qs/serve/modules/biz/controller/BizVisitController.java @@ -8,6 +8,7 @@ import com.qs.serve.common.model.enums.BizType; import com.qs.serve.common.model.enums.SystemModule; import com.qs.serve.common.util.AuthContextUtils; import com.qs.serve.common.util.PageUtil; +import com.qs.serve.modules.biz.mapper.BizVisitMapper; import com.qs.serve.modules.sys.service.SysPostUserService; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -32,7 +33,19 @@ public class BizVisitController { private BizVisitService bizVisitService; + private BizVisitMapper bizVisitMapper; + private SysPostUserService postUserService; + + /** + * 获取签到类型下拉框数据 + * @return + */ + @GetMapping("/signTypeOptions") + public R> getSignTypeOptions(){ + return R.ok(bizVisitMapper.selectAllSignType()); + } + /** * 翻页(我的下属拜访记录) * @param param diff --git a/src/main/java/com/qs/serve/modules/biz/mapper/BizVisitMapper.java b/src/main/java/com/qs/serve/modules/biz/mapper/BizVisitMapper.java index 6abcea9a..9db23189 100644 --- a/src/main/java/com/qs/serve/modules/biz/mapper/BizVisitMapper.java +++ b/src/main/java/com/qs/serve/modules/biz/mapper/BizVisitMapper.java @@ -1,7 +1,11 @@ package com.qs.serve.modules.biz.mapper; +import com.baomidou.mybatisplus.annotation.InterceptorIgnore; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.qs.serve.modules.biz.entity.BizVisit; +import org.apache.ibatis.annotations.Select; + +import java.util.List; /** * 拜访日志 Mapper @@ -10,5 +14,16 @@ import com.qs.serve.modules.biz.entity.BizVisit; */ public interface BizVisitMapper extends BaseMapper { + @InterceptorIgnore(tenantLine = "1") + @Select("SELECT " + + " sign_type " + + "FROM " + + " biz_visit " + + "WHERE " + + " del_flag = '0' " + + " group BY sign_type " + + " order by sign_type") + List selectAllSignType(); + } diff --git a/src/main/java/com/qs/serve/modules/oms/controller/OmsOrderController.java b/src/main/java/com/qs/serve/modules/oms/controller/OmsOrderController.java index baca5314..5cddfa7b 100644 --- a/src/main/java/com/qs/serve/modules/oms/controller/OmsOrderController.java +++ b/src/main/java/com/qs/serve/modules/oms/controller/OmsOrderController.java @@ -1,5 +1,6 @@ package com.qs.serve.modules.oms.controller; +import cn.hutool.core.collection.CollUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.qs.serve.common.model.annotation.SysLog; import com.qs.serve.common.model.dto.PageVo; @@ -195,5 +196,13 @@ public class OmsOrderController { return R.ok(omsOrderService.getSpuAssess(param)); } + @GetMapping("/reSync/{code}") + public R getSpuAssess(@PathVariable("code") String code){ + List omsOrders = omsOrderService.list(new LambdaQueryWrapper().eq(OmsOrder::getOrderSn,code)); + if(CollUtil.isNotEmpty(omsOrders)){ + omsOrderOptionsService.syncToErp11DB(omsOrders); + } + return R.ok(); + } } diff --git a/src/main/java/com/qs/serve/modules/oms/controller/api/OmsOrderApi.java b/src/main/java/com/qs/serve/modules/oms/controller/api/OmsOrderApi.java index 07ba1c2d..2088e783 100644 --- a/src/main/java/com/qs/serve/modules/oms/controller/api/OmsOrderApi.java +++ b/src/main/java/com/qs/serve/modules/oms/controller/api/OmsOrderApi.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.qs.serve.common.model.annotation.SysLog; import com.qs.serve.common.model.dto.PageVo; import com.qs.serve.common.model.dto.R; +import com.qs.serve.common.model.dto.SimpleKeyValue; import com.qs.serve.common.model.enums.BizType; import com.qs.serve.common.model.enums.SystemModule; import com.qs.serve.common.util.*; @@ -27,6 +28,7 @@ import com.qs.serve.modules.oms.entity.OmsOrder; import com.qs.serve.modules.oms.entity.OmsOrderItem; import com.qs.serve.modules.oms.entity.bo.*; import com.qs.serve.modules.oms.entity.vo.OmsConfirmOrderResult; +import com.qs.serve.modules.oms.mapper.OmsOrderMapper; import com.qs.serve.modules.oms.service.OmsOrderItemService; import com.qs.serve.modules.oms.service.OmsOrderOptionsService; import com.qs.serve.modules.oms.service.OmsOrderPart1Service; @@ -59,6 +61,7 @@ public class OmsOrderApi { private BmsSupplierMapper bmsSupplierMapper; private OmsOrderService omsOrderService; + private OmsOrderMapper omsOrderMapper; private OmsOrderItemService omsOrderItemService; private BmsSupplierAddressService bmsSupplierAddressService; private SysUserService sysUserService; @@ -249,9 +252,20 @@ public class OmsOrderApi { lqw.in(OmsOrderItem::getOrderId,orderIds); List allItems = omsOrderItemService.list(lqw); + List> rates = omsOrderMapper.selectExpiredOrderRates(); + Map> itemsMap = allItems.stream().collect(Collectors.groupingBy(OmsOrderItem::getOrderId)); for (OmsOrder order : list) { + + if(order.getOrderType().equals(3)&&StringUtils.hasText(order.getOaRateId())){ + for (SimpleKeyValue rate : rates) { + if (rate.getValue().equals(order.getOaRateId())){ + order.setDiscountRateInfo(rate); + } + } + } + omsOrderService.checkMsOrderStatus(order); for (BmsSupplierAddress address : supplierAddressList) { @@ -320,6 +334,11 @@ public class OmsOrderApi { omsOrderOptionsService.runCompensate(omsOrder.getId()+""); omsOrder = omsOrderService.getById(id); } + // 关联折扣信息 + if(StringUtils.hasText(omsOrder.getOaRateId())){ + SimpleKeyValue obj = omsOrderMapper.getExpiredRateInfo(omsOrder.getOaRateId()); + omsOrder.setDiscountRateInfo(obj); + } omsOrder.setBrandRuleInfo(goodsCategoryRuleService.getById(omsOrder.getBrandRuleId())); omsOrder.setAddressInfo(bmsSupplierAddressService.getById(omsOrder.getSupplierAddrId())); omsOrder.setSupplierInfo(bmsSupplierMapper.selectById(omsOrder.getSupplierId())); diff --git a/src/main/java/com/qs/serve/modules/oms/entity/OmsOrder.java b/src/main/java/com/qs/serve/modules/oms/entity/OmsOrder.java index f0123211..f9348893 100644 --- a/src/main/java/com/qs/serve/modules/oms/entity/OmsOrder.java +++ b/src/main/java/com/qs/serve/modules/oms/entity/OmsOrder.java @@ -212,6 +212,10 @@ public class OmsOrder implements Serializable { @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") private LocalDate checkEndTime; - + /** + * 折扣信息 + */ + @TableField(exist = false) + private Object discountRateInfo; } diff --git a/src/main/java/com/qs/serve/modules/oms/mapper/OmsOrderMapper.java b/src/main/java/com/qs/serve/modules/oms/mapper/OmsOrderMapper.java index f27ba912..f166b311 100644 --- a/src/main/java/com/qs/serve/modules/oms/mapper/OmsOrderMapper.java +++ b/src/main/java/com/qs/serve/modules/oms/mapper/OmsOrderMapper.java @@ -18,8 +18,11 @@ public interface OmsOrderMapper extends BaseMapper { @Select("SELECT rate FROM `ext_expire_order_rate` where oa_id = #{oaId} and del_flag = 0 ") BigDecimal getExpiredOrderRates(String oaId); - @Select("SELECT oa_id as `value`,`name` as label FROM `ext_expire_order_rate` where del_flag = 0 order by rate") + @Select("SELECT oa_id as `value`,`name` as label,rate as value2 FROM `ext_expire_order_rate` where del_flag = 0 order by rate") List> selectExpiredOrderRates(); + @Select("SELECT oa_id as `value`,`name` as label,rate as value2 FROM `ext_expire_order_rate` where del_flag = 0 and oa_id = #{oaId} ") + SimpleKeyValue getExpiredRateInfo(String oaId); + } diff --git a/src/main/java/com/qs/serve/modules/oms/service/OmsOrderOptionsService.java b/src/main/java/com/qs/serve/modules/oms/service/OmsOrderOptionsService.java index c5a7bace..5f95b63f 100644 --- a/src/main/java/com/qs/serve/modules/oms/service/OmsOrderOptionsService.java +++ b/src/main/java/com/qs/serve/modules/oms/service/OmsOrderOptionsService.java @@ -1,7 +1,10 @@ package com.qs.serve.modules.oms.service; +import com.qs.serve.modules.oms.entity.OmsOrder; import com.qs.serve.modules.seeyon.service.SeeYonOperationService; +import java.util.List; + /** * @author YenHex * @since 2024/8/12 @@ -20,4 +23,5 @@ public interface OmsOrderOptionsService extends SeeYonOperationService { */ void syncToErp(); + void syncToErp11DB(List omsOrders); } diff --git a/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderOptionsServiceImpl.java b/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderOptionsServiceImpl.java index 7ccf631a..e38b7262 100644 --- a/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderOptionsServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/oms/service/impl/OmsOrderOptionsServiceImpl.java @@ -265,6 +265,11 @@ public class OmsOrderOptionsServiceImpl implements OmsOrderOptionsService { .eq(OmsOrder::getOrderCheckState,OmsOrderCheckState.Finished.getCode()) ); log.warn("临期品同步到ERP,数量:{}",omsOrders.size()); + syncToErp11DB(omsOrders); + } + + @Override + public void syncToErp11DB(List omsOrders) { for (OmsOrder omsOrder : omsOrders) { BmsSupplierAddress supplierAddress = bmsSupplierAddressService.getById(omsOrder.getSupplierAddrId()); List orderItemList = omsOrderItemService.listByOrderId(omsOrder.getId()); @@ -277,22 +282,25 @@ public class OmsOrderOptionsServiceImpl implements OmsOrderOptionsService { List categoryList = goodsCategoryMapper.selectBatchIds(cateIds); String bs = categoryList.stream().map(GoodsCategory::getName).collect(Collectors.joining(",")); // 读取OA最新订单折扣 - R codeRs = seeYonRequestBaseService.getBase( - TbsSeeYonConst.OA_DATA_EXPIRE_ORDER_DR + omsOrder.getOrderSn() - ,"获取条款申请流水号"); - BigDecimal dr = null; - if(codeRs.getStatus()==200 && codeRs.getMsg()!=null){ - try { - String oaRateId = codeRs.getMsg().toString(); - dr = omsOrderMapper.getExpiredOrderRates(oaRateId); - omsOrder.setDiscountRate(dr); - } catch (Exception e) { - e.printStackTrace(); + if(omsOrder.getOrderType().equals(3)){ + R codeRs = seeYonRequestBaseService.getBase( + TbsSeeYonConst.OA_DATA_EXPIRE_ORDER_DR + omsOrder.getOrderSn() + ,"获取条款申请流水号"); + BigDecimal dr = null; + if(codeRs.getStatus()==200 && codeRs.getMsg()!=null){ + try { + String oaRateId = codeRs.getMsg().toString(); + dr = omsOrderMapper.getExpiredOrderRates(oaRateId); + omsOrder.setDiscountRate(dr); + omsOrder.setOaRateId(oaRateId); + } catch (Exception e) { + e.printStackTrace(); + } + } + if(dr==null){ + log.error("临期品订单,获取最新的折扣率失败,单号:{}",omsOrder.getOrderSn()); + continue; } - } - if(dr==null){ - log.error("临期品订单,获取最新的折扣率失败,单号:{}",omsOrder.getOrderSn()); - continue; } // 写入到ERP中间表 omsOrderService.saveToErpOrder(omsOrder,orderItemList,bs,supplierAddress,bmsRegion); diff --git a/src/main/java/com/qs/serve/modules/tbs/controller/TbsCostApplyController.java b/src/main/java/com/qs/serve/modules/tbs/controller/TbsCostApplyController.java index df09dc95..e22a2378 100644 --- a/src/main/java/com/qs/serve/modules/tbs/controller/TbsCostApplyController.java +++ b/src/main/java/com/qs/serve/modules/tbs/controller/TbsCostApplyController.java @@ -101,9 +101,9 @@ public class TbsCostApplyController { * @param id * @return */ - //@PostMapping("/rebuildBudgetInit") + //@PostMapping("/testBanding") public R bu(Long id){ - tbsCostApplyService.rebuildBudgetInit(id); + //tbsCostApplyService.rebuildBudgetInit(id); return R.ok(); } diff --git a/src/main/java/com/qs/serve/modules/tbs/service/TbsActivityService.java b/src/main/java/com/qs/serve/modules/tbs/service/TbsActivityService.java index 2b703597..2e265be8 100644 --- a/src/main/java/com/qs/serve/modules/tbs/service/TbsActivityService.java +++ b/src/main/java/com/qs/serve/modules/tbs/service/TbsActivityService.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.extension.service.IService; import com.qs.serve.modules.tbs.entity.TbsActivity; import com.qs.serve.modules.tbs.entity.bo.TbsActivityBo; +import java.time.LocalDate; import java.util.List; /** @@ -32,7 +33,16 @@ public interface TbsActivityService extends IService { */ void checkCenterGoods(boolean updateBudgetLog); + /** + * 将重新打开的,过期修复回为未重新打开 + */ + void initReopenState(); + /** + * 更新费用申请的活动的冻结状态 + * @param costApplyIds + */ + void flushBandingState(List costApplyIds); } diff --git a/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsActivityServiceImpl.java b/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsActivityServiceImpl.java index c3186feb..59e18a99 100644 --- a/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsActivityServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsActivityServiceImpl.java @@ -80,6 +80,47 @@ public class TbsActivityServiceImpl extends ServiceImpl updReopen = new LambdaQueryWrapper<>(); + updReopen.eq(TbsActivity::getReopenFlag,1) + .lt(TbsActivity::getReopenTime, closeDay) + .eq(TbsActivity::getActivityState,0) + .eq(TbsActivity::getCostPassFlag,1); + TbsActivity updReopenParam = new TbsActivity(); + updReopenParam.setReopenFlag(0); + super.update(updReopenParam,updReopen); + } + + @Override + public void flushBandingState(List costApplyIds1) { + List> idsArray = CollUtil.split(costApplyIds1,1000); + for (List ids : idsArray) { + LocalDate now = LocalDate.now(); + LocalDate yesterday = now.plusDays(-1); + LambdaQueryWrapper lqw = new LambdaQueryWrapper<>(); + lqw.in(TbsActivity::getCostApplyId, ids); + lqw.and(qw->{ + qw.and( + qw1->qw1.le(TbsActivity::getPreCheckDate, yesterday) + .isNull(TbsActivity::getPreEndDateBack) + ).or().le(TbsActivity::getPreEndDateBack, yesterday); + }); + // 排除重新打开的活动 + lqw.ne(TbsActivity::getReopenFlag,1); + // 2-完成;4-已释放;5-已关闭 表流程已完结,冻结无意义 + lqw.eq(TbsActivity::getActivityState,TbsActivityState.STATE_0_Todo); + //通过审批的 + lqw.eq(TbsActivity::getCostPassFlag,1); + TbsActivity param = new TbsActivity(); + param.setActivityState(TbsActivityState.STATE_1_Baning); + super.update(param,lqw); + } + } @Override public void checkCenterGoods(boolean updateBudgetLog) { diff --git a/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyOperationServiceImpl.java b/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyOperationServiceImpl.java index 9c29533f..57bfb36f 100644 --- a/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyOperationServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyOperationServiceImpl.java @@ -69,6 +69,7 @@ public class TbsCostApplyOperationServiceImpl implements SeeYonOperationService private final TbsBudgetLogMapper tbsBudgetLogMapper; private final TbsBudgetMapper tbsBudgetMapper; + private final TbsActivityService activityService; private final TbsCostApplyPart1Service costApplyPart1Service; private final TbsActivitySubjectMapper activitySubjectMapper; private final TbsActivityCenterMapper activityCenterMapper; @@ -352,7 +353,9 @@ public class TbsCostApplyOperationServiceImpl implements SeeYonOperationService actLqw.eq(TbsActivity::getCostApplyId,targetId); tbsActivityMapper.update(tbsActivity,actLqw); activitySlottingFeeMapper.updatePassFlagByCostApplyId(targetId,1); - + //更新活动状态为冻结 + activityService.initReopenState(); + activityService.flushBandingState(Arrays.asList(costApply.getId())); return null; } @@ -898,6 +901,9 @@ public class TbsCostApplyOperationServiceImpl implements SeeYonOperationService this.doFinished(bo); } BirActivityCenterGoodsUtil.buildBir(costApply.getId()); + //更新活动状态为冻结 + activityService.initReopenState(); + activityService.flushBandingState(Arrays.asList(costApply.getId())); return null; } diff --git a/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyServiceImpl.java b/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyServiceImpl.java index 7eddba45..6a31411c 100644 --- a/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyServiceImpl.java @@ -963,6 +963,7 @@ public class TbsCostApplyServiceImpl extends ServiceImpl { */ Map buildSeeYonVerificationData(TbsActivity activity, SysUser sysUser, VtbVerification verification, String saleRegionNames, - String bizRegionNames); + String bizRegionNames,BmsSupplier supplier); /** * 审核通过回调 diff --git a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java index 520b70e4..e181702c 100644 --- a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java @@ -17,6 +17,7 @@ import com.qs.serve.modules.tbs.entity.TbsActivity; import com.qs.serve.modules.tbs.entity.bo.TbsAffairCommitBo; import com.qs.serve.modules.tbs.entity.vo.CtpAffairVo; import com.qs.serve.modules.tbs.mapper.TbsActivityMapper; +import com.qs.serve.modules.tbs.service.TbsActivityService; import com.qs.serve.modules.vtb.common.VtbVerificationState; import com.qs.serve.modules.vtb.entity.*; import com.qs.serve.modules.vtb.entity.vo.VtbVerificationActReleaseVo; @@ -28,6 +29,7 @@ import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import java.math.BigDecimal; +import java.time.LocalDate; import java.time.LocalDateTime; import java.util.*; import java.util.stream.Collectors; @@ -52,6 +54,7 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification private final VtbVerificationYardCenterItemService yardCenterItemService; private final VtbVerificationSubjectService vtbVerificationSubjectService; private final TbsActivityMapper tbsActivityMapper; + private final TbsActivityService activityService; @Override public String getTemplateCode() { @@ -84,6 +87,11 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification TbsActivity activity1 = new TbsActivity(); activity1.setId(activity.getId()); activity1.setActivityState(TbsActivityState.STATE_0_Todo); + // 延期3天 + if(activity.getPreCheckDate().isBefore(LocalDate.now())){ + activity1.setReopenFlag(1); + activity1.setPreEndDateBack(LocalDate.now().plusDays(3)); + } tbsActivityMapper.updateById(activity1); } return null; @@ -110,6 +118,9 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification BigDecimal totalAmt = vtbVerificationMapper.totalVtbAmtByBatchId(batch.getId()); batch.setResultCheckAmount(totalAmt); vtbVerificationBatchService.updateById(batch); + //更新活动状态为冻结 + activityService.initReopenState(); + activityService.flushBandingState(Arrays.asList(batch.getCostApplyId())); return null; } diff --git a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java index d51bdcf6..9cc6058b 100644 --- a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java @@ -322,6 +322,7 @@ public class VtbVerificationBatchServiceImpl extends ServiceImpl tags = tagInfoMapper.lisTagsBySupplierCode(supplier.getCode()); data.put("tags",tags); diff --git a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java index 08314942..d493c239 100644 --- a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java @@ -907,7 +907,7 @@ public class VtbVerificationServiceImpl extends ServiceImpl data = buildSeeYonVerificationData(activity, sysUser, verification, saleRegionNames, bizRegionNames); + private void commitSy(TbsActivity activity,SysUser sysUser,VtbVerification verification,String saleRegionNames,String bizRegionNames,BmsSupplier supplier){ + Map data = buildSeeYonVerificationData(activity, sysUser, verification, saleRegionNames, bizRegionNames,supplier); String dataJson = JsonUtil.objectToJson(data); log.warn("核销请求JSON,核销号:{}:{}",verification.getVerificationCode(),dataJson); BaseCreateProcessBo createProcess = new BaseCreateProcessBo(); @@ -1132,12 +1132,12 @@ public class VtbVerificationServiceImpl extends ServiceImpl buildSeeYonVerificationData(TbsActivity activity, SysUser sysUser, VtbVerification verification, String saleRegionNames, String bizRegionNames) { + public Map buildSeeYonVerificationData(TbsActivity activity, SysUser sysUser, VtbVerification verification, String saleRegionNames, String bizRegionNames,BmsSupplier supplier) { Map data = new HashMap<>(20); data.put("costApplyCode", verification.getVerificationCode()); data.put("applyUserCode", sysUser.getCode()); @@ -1157,6 +1157,7 @@ public class VtbVerificationServiceImpl extends ServiceImpl updReopen = new LambdaQueryWrapper<>(); - updReopen.eq(TbsActivity::getReopenFlag,1) - .lt(TbsActivity::getReopenTime, closeDay) - .eq(TbsActivity::getActivityState,0) - .eq(TbsActivity::getCostPassFlag,1); - TbsActivity updReopenParam = new TbsActivity(); - updReopenParam.setReopenFlag(0); - activityService.update(updReopenParam,updReopen); + activityService.initReopenState(); LambdaQueryWrapper lqwApply = new LambdaQueryWrapper<>(); lqwApply.select(TbsCostApply::getId); lqwApply.eq(TbsCostApply::getChargeState, TbsCostApplyState.State_2_actioning.getCode()); List costApplyList = tbsCostApplyService.list(lqwApply); - List costApplyIds = costApplyList.stream().map(a->a.getId()).collect(Collectors.toList()); - //只更新审批完成的申请活动状态 - LocalDate lastDay = now.plusDays(-1); - LambdaQueryWrapper lqw = new LambdaQueryWrapper<>(); - lqw.in(TbsActivity::getCostApplyId,costApplyIds); - lqw.and(qw->{ - qw.and( - qw1->qw1.le(TbsActivity::getPreCheckDate, lastDay) - .isNull(TbsActivity::getPreEndDateBack) - ).or() - .le(TbsActivity::getPreEndDateBack, lastDay); - }); - lqw.eq(TbsActivity::getReopenFlag,0); - // 2-完成;4-已释放;5-已关闭 表流程已完结,冻结无意义 - lqw.eq(TbsActivity::getActivityState,TbsActivityState.STATE_0_Todo); - //通过审批的 - lqw.eq(TbsActivity::getCostPassFlag,1); - TbsActivity param = new TbsActivity(); - param.setActivityState(TbsActivityState.STATE_1_Baning); - activityService.update(param,lqw); + List costApplyIds = costApplyList.stream().map(TbsCostApply::getId).collect(Collectors.toList()); + // 更新费用申请的活动的冻结状态 + activityService.flushBandingState(costApplyIds); } + //启用和停用模板规则 //@Scheduled(cron="0 0 1 * * ?") public void task2(){ diff --git a/src/main/resources/mapper/wx/WxFormPushMapper.xml b/src/main/resources/mapper/wx/WxFormPushMapper.xml index abd832cc..ca2b72ac 100644 --- a/src/main/resources/mapper/wx/WxFormPushMapper.xml +++ b/src/main/resources/mapper/wx/WxFormPushMapper.xml @@ -43,6 +43,7 @@ wx_form_push.`update_by`, wx_form_push.`del_flag`, wx_form_push.`status`, + `wx_form_push`.`publish_time`, wx_form_push.`pre_notify_status`, wx_form_push.`effective_start_time`, wx_form_push.`effective_end_time`,