suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

//审批拒绝阶段 数据处理

Browse Source
This commit is contained in:
shuo.wang
2025-06-06 11:34:09 +08:00
parent d6051898c0
commit d71dfb05c5
4 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
coolstore-partner-dao/src/main/java/com/cool/store/dao/LinePayDAO.java
View File

@@ -108,4 +108,10 @@ public class LinePayDAO {
}
return linePayMapper.updateXgjClaimStatus(shopIds,xgjClaimStatus,payBusinessType);
}
public Integer deleteByShopId(List<Long> shopIds){
if (CollectionUtils.isEmpty(shopIds)){
return null;
}
return linePayMapper.deleteByShopId(shopIds);
}
}

2
coolstore-partner-dao/src/main/java/com/cool/store/mapper/LinePayMapper.java
View File

@@ -68,4 +68,6 @@ public interface LinePayMapper {
Integer dataUpdateLinePay(@Param("list") List<LinePayDO> linePayDOList);
Integer updateXgjClaimStatus(@Param("list") List<Long> shopIds,@Param("xgjClaimStatus") Integer xgjClaimStatus,@Param("payBusinessType") Integer payBusinessType);
Integer deleteByShopId(@Param("list")List<Long> shopIds);
}

8
coolstore-partner-dao/src/main/resources/mapper/LinePayMapper.xml
View File

@@ -48,6 +48,14 @@
from xfsg_line_pay
where id = #{id,jdbcType=BIGINT}
</delete>
<update id="deleteByShopId">
update xfsg_line_pay
set deleted = 1
where shop_id in
<foreach collection="list" index="index" item="item" separator="," open="(" close=")">
#{item}
</foreach>
</update>
<insert id="insertSelective" parameterType="com.cool.store.entity.LinePayDO">
<selectKey keyProperty="id" order="AFTER" resultType="java.lang.Long">
SELECT LAST_INSERT_ID()

6
coolstore-partner-service/src/main/java/com/cool/store/service/impl/DataHandlerServerImpl.java
View File

@@ -1070,6 +1070,12 @@ public class DataHandlerServerImpl implements DataHandlerServer {
List<ShopStageInfoDO> waitPayStageList = shopStageInfoDAO.getShopStageInfoByShopSubStageStatus(ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_71.getShopSubStageStatus());
List<Long> waitPayShopIds = waitPayStageList.stream().map(ShopStageInfoDO::getShopId).collect(Collectors.toList());
franchiseFeeDAO.batchUpdateXgjCollectionStatus(waitPayShopIds, XGJCollectionStatusEnum.WAIT_PAY.getCode());
//审批拒绝阶段
List<ShopStageInfoDO> refuseStageList = shopStageInfoDAO.getShopStageInfoByShopSubStageStatus(ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_74.getShopSubStageStatus());
List<Long> refuseShopIds = refuseStageList.stream().map(ShopStageInfoDO::getShopId).collect(Collectors.toList());
franchiseFeeDAO.batchUpdateXgjCollectionStatus(refuseShopIds, XGJCollectionStatusEnum.WAIT_PAY.getCode());
linePayDAO.deleteByShopId(refuseShopIds);
shopStageInfoDAO.dataUpdateStatus(refuseShopIds,ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_71);
return true;
}