发展基金相关实现修改

This commit is contained in:
2025-02-18 13:42:07 +08:00
parent c18db6ffd3
commit dfba7801e2
4 changed files with 1468 additions and 1413 deletions

View File

@@ -3,6 +3,8 @@ package com.buy507.mall.mapper;
import com.buy507.mall.model.OmsOrder;
import com.buy507.mall.model.OmsOrderExample;
import java.util.List;
import com.buy507.mall.model.PmsProduct;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
@@ -31,4 +33,4 @@ public interface OmsOrderMapper {
int updateByPrimaryKey(OmsOrder record);
int selectPointsAreaStatus(@Param("orderSn") String orderSn);}
PmsProduct selectPointsAreaStatus(@Param("orderSn") String orderSn);}

View File

@@ -3,6 +3,7 @@ package com.buy507.mall.mapper;
import com.buy507.mall.model.UmsDevelopmentFund;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import java.math.BigDecimal;
@@ -18,29 +19,30 @@ public interface UmsDevelopmentFundMapper {
* 查询现金总和
* @return
*/
@Select("SELECT SUM(cash_total) FROM ums_development_fund")
@Select("SELECT cash_total FROM ums_development_fund")
BigDecimal getTotalCash();
/**
* 查询积分总和
* @return
*/
@Select("SELECT SUM(points_total) FROM ums_development_fund")
@Select("SELECT points_total FROM ums_development_fund")
Integer getTotalPoints();
/**
* 发展基金现金流水
* @param payAmount
*/
@Insert("INSERT INTO ums_development_fund (cash_total, updated_at) VALUES (#{payAmount}, NOW())")
void insertCash(BigDecimal payAmount);
/**
* 发展基金积分流水
* @param rewardPoints
* 更新积分
* @param fundPoints
*/
@Insert("INSERT INTO ums_development_fund (points_total, updated_at) VALUES (#{rewardPoints}, NOW())")
void insertPoints(BigDecimal rewardPoints);
@Update("update ums_development_fund set points_total = points_total + #{fundPoints}")
void updatePoints(int fundPoints);
/**
* 更新现金
* @param fundCash
*/
@Update("update ums_development_fund set cash_total = cash_total + #{fundCash}")
void updateCash(BigDecimal fundCash);
}

View File

@@ -50,8 +50,7 @@
<result column="settlement_status" jdbcType="INTEGER" property="settlementStatus" />
<result column="settlement_time" jdbcType="TIMESTAMP" property="settlementTime" />
</resultMap>
<sql id="Example_Where_Clause">
<where>
<foreach collection="oredCriteria" item="criteria" separator="or">
@@ -875,13 +874,56 @@
where id = #{id,jdbcType=BIGINT}
</update>
<select id="selectPointsAreaStatus" resultType="int">
<![CDATA[
SELECT p.points_area_status
FROM pms_product p
JOIN oms_order_item oi ON p.product_sn = oi.product_sn
JOIN oms_order o ON oi.order_sn = o.order_sn
WHERE o.order_sn = #{orderSn}
]]>
<select id="selectPointsAreaStatus" resultType="com.buy507.mall.model.PmsProduct">
SELECT p.id,
p.brand_id,
p.product_category_id,
p.feight_template_id,
p.product_attribute_category_id,
p.name,
p.pic,
p.product_sn,
p.delete_status,
p.publish_status,
p.new_status,
p.recommand_status,
p.verify_status,
p.sort,
p.sale,
p.price,
p.promotion_price,
p.gift_growth,
p.gift_point,
p.use_point_limit,
p.sub_title,
p.description,
p.original_price,
p.stock,
p.low_stock,
p.unit,
p.weight,
p.preview_status,
p.service_ids,
p.keywords,
p.note,
p.album_pics,
p.detail_title,
p.detail_desc,
p.detail_html,
p.detail_mobile_html,
p.promotion_start_time,
p.promotion_end_time,
p.promotion_per_limit,
p.promotion_type,
p.brand_name,
p.product_category_name,
p.distribution_flag,
p.vip_status,
p.points_area_status,
p.points_exchange_status
FROM pms_product p
JOIN oms_order_item oi ON p.product_sn = oi.product_sn
JOIN oms_order o ON oi.order_sn = o.order_sn
WHERE o.order_sn = #{orderSn}
</select>
</mapper>