加入积分计算

java110-bean/src/main/java/com/java110/dto/integralRuleConfig/IntegralRuleConfigDto.java

@@ -15,6 +15,14 @@ import java.util.Date;
  **/
 public class IntegralRuleConfigDto extends PageDto implements Serializable {
 
+    //计算公式 1001 面积*单价 2002 金额乘以单价 3003 固定积分
+    public static final String COMPUTING_FORMULA_AREA = "1001";
+    public static final String COMPUTING_FORMULA_MONEY = "2002";
+    public static final String COMPUTING_FORMULA_FIXED = "3003";
+
+    public static final String SCALE_UP = "3";
+    public static final String SCALE_DOWN = "4";
+
     private String configId;
     private String configName;
 
@@ -29,6 +37,8 @@ public class IntegralRuleConfigDto extends PageDto implements Serializable {
     private String scaleName;
     private String ircId;
     private String ruleId;
+    private String[] ruleIds;
+
     private String communityId;
 
 
@@ -141,4 +151,12 @@ public class IntegralRuleConfigDto extends PageDto implements Serializable {
     public void setScaleName(String scaleName) {
         this.scaleName = scaleName;
     }
+
+    public String[] getRuleIds() {
+        return ruleIds;
+    }
+
+    public void setRuleIds(String[] ruleIds) {
+        this.ruleIds = ruleIds;
+    }
 }

java110-bean/src/main/java/com/java110/dto/integralRuleFee/IntegralRuleFeeDto.java

@@ -1,6 +1,7 @@
 package com.java110.dto.integralRuleFee;
 
 import com.java110.dto.PageDto;
+
 import java.io.Serializable;
 import java.util.Date;
 
@@ -15,13 +16,16 @@ import java.util.Date;
 public class IntegralRuleFeeDto extends PageDto implements Serializable {
 
     private String payMonth;
-private String irfId;
-private String feeConfigName;
-private String payStartTime;
-private String payEndTime;
-private String ruleId;
-private String communityId;
-private String feeConfigId;
+    private String irfId;
+    private String feeConfigName;
+    private String payStartTime;
+    private String payEndTime;
+    private String ruleId;
+    private String communityId;
+    private String feeConfigId;
+
+    private String curTime;
+    private String cycle;
 
 
     private Date createTime;
@@ -32,49 +36,64 @@ private String feeConfigId;
     public String getPayMonth() {
         return payMonth;
     }
-public void setPayMonth(String payMonth) {
+
+    public void setPayMonth(String payMonth) {
         this.payMonth = payMonth;
     }
-public String getIrfId() {
+
+    public String getIrfId() {
         return irfId;
     }
-public void setIrfId(String irfId) {
+
+    public void setIrfId(String irfId) {
         this.irfId = irfId;
     }
-public String getFeeConfigName() {
+
+    public String getFeeConfigName() {
         return feeConfigName;
     }
-public void setFeeConfigName(String feeConfigName) {
+
+    public void setFeeConfigName(String feeConfigName) {
         this.feeConfigName = feeConfigName;
     }
-public String getPayStartTime() {
+
+    public String getPayStartTime() {
         return payStartTime;
     }
-public void setPayStartTime(String payStartTime) {
+
+    public void setPayStartTime(String payStartTime) {
         this.payStartTime = payStartTime;
     }
-public String getPayEndTime() {
+
+    public String getPayEndTime() {
         return payEndTime;
     }
-public void setPayEndTime(String payEndTime) {
+
+    public void setPayEndTime(String payEndTime) {
         this.payEndTime = payEndTime;
     }
-public String getRuleId() {
+
+    public String getRuleId() {
         return ruleId;
     }
-public void setRuleId(String ruleId) {
+
+    public void setRuleId(String ruleId) {
         this.ruleId = ruleId;
     }
-public String getCommunityId() {
+
+    public String getCommunityId() {
         return communityId;
     }
-public void setCommunityId(String communityId) {
+
+    public void setCommunityId(String communityId) {
         this.communityId = communityId;
     }
-public String getFeeConfigId() {
+
+    public String getFeeConfigId() {
         return feeConfigId;
     }
-public void setFeeConfigId(String feeConfigId) {
+
+    public void setFeeConfigId(String feeConfigId) {
         this.feeConfigId = feeConfigId;
     }
 
@@ -94,4 +113,20 @@ public void setFeeConfigId(String feeConfigId) {
     public void setStatusCd(String statusCd) {
         this.statusCd = statusCd;
     }
+
+    public String getCurTime() {
+        return curTime;
+    }
+
+    public void setCurTime(String curTime) {
+        this.curTime = curTime;
+    }
+
+    public String getCycle() {
+        return cycle;
+    }
+
+    public void setCycle(String cycle) {
+        this.cycle = cycle;
+    }
 }

java110-db/src/main/resources/mapper/acct/IntegralRuleConfigV1ServiceDaoImplMapper.xml

@@ -38,6 +38,12 @@
         <if test="ruleId !=null and ruleId != ''">
             and t.rule_id= #{ruleId}
         </if>
+        <if test="ruleIds !=null ">
+            and t.rule_id in
+            <foreach collection="ruleIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
         <if test="communityId !=null and communityId != ''">
             and t.community_id= #{communityId}
         </if>

java110-db/src/main/resources/mapper/acct/IntegralRuleFeeV1ServiceDaoImplMapper.xml

@@ -26,6 +26,9 @@
         <if test="payMonth !=null and payMonth != ''">
             and t.pay_month= #{payMonth}
         </if>
+        <if test="cycle !=null and cycle != ''">
+            and t.pay_month &lt;= #{cycle}
+        </if>
         <if test="irfId !=null and irfId != ''">
             and t.irf_id= #{irfId}
         </if>
@@ -38,6 +41,10 @@
         <if test="payEndTime !=null and payEndTime != ''">
             and t.pay_end_time= #{payEndTime}
         </if>
+        <if test="curTime !=null and curTime != ''">
+            and t.pay_start_time &lt; #{curTime}
+            and t.pay_end_time &gt; #{curTime}
+        </if>
         <if test="statusCd !=null and statusCd != ''">
             and t.status_cd= #{statusCd}
         </if>
@@ -99,6 +106,9 @@
         <if test="payMonth !=null and payMonth != ''">
             and t.pay_month= #{payMonth}
         </if>
+        <if test="cycle !=null and cycle != ''">
+            and t.pay_month &lt;= #{cycle}
+        </if>
         <if test="irfId !=null and irfId != ''">
             and t.irf_id= #{irfId}
         </if>
@@ -111,6 +121,10 @@
         <if test="payEndTime !=null and payEndTime != ''">
             and t.pay_end_time= #{payEndTime}
         </if>
+        <if test="curTime !=null and curTime != ''">
+            and t.pay_start_time &lt; #{curTime}
+            and t.pay_end_time &gt; #{curTime}
+        </if>
         <if test="statusCd !=null and statusCd != ''">
             and t.status_cd= #{statusCd}
         </if>

service-acct/src/main/java/com/java110/acct/cmd/integral/ComputePayFeeIntegralCmd.java

@@ -0,0 +1,163 @@
+package com.java110.acct.cmd.integral;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.acct.smo.impl.IntegralRuleConfigV1InnerServiceSMOImpl;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.doc.annotation.*;
+import com.java110.dto.couponRuleCpps.CouponRuleCppsDto;
+import com.java110.dto.couponRuleFee.CouponRuleFeeDto;
+import com.java110.dto.fee.FeeDto;
+import com.java110.dto.integralRuleConfig.IntegralRuleConfigDto;
+import com.java110.dto.integralRuleFee.IntegralRuleFeeDto;
+import com.java110.intf.acct.ICouponRuleCppsV1InnerServiceSMO;
+import com.java110.intf.acct.ICouponRuleFeeV1InnerServiceSMO;
+import com.java110.intf.acct.IIntegralRuleConfigV1InnerServiceSMO;
+import com.java110.intf.acct.IIntegralRuleFeeV1InnerServiceSMO;
+import com.java110.intf.fee.IFeeInnerServiceSMO;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.DateUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.math.BigDecimal;
+import java.text.ParseException;
+import java.util.ArrayList;
+import java.util.List;
+
+@Java110CmdDoc(title = "缴费赠送积分",
+        description = "缴费时计算费用 是否有积分",
+        httpMethod = "get",
+        url = "http://{ip}:{port}/app/integral.computePayFeeIntegral",
+        resource = "acctDoc",
+        author = "吴学文",
+        serviceCode = "integral.computePayFeeIntegral"
+)
+
+@Java110ParamsDoc(params = {
+        @Java110ParamDoc(name = "feeId", length = 30, remark = "费用ID"),
+        @Java110ParamDoc(name = "cycle", length = 30, remark = "缴费周期"),
+        @Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"),
+        @Java110ParamDoc(name = "amount", length = 30, remark = "缴费金额"),
+        @Java110ParamDoc(name = "area", length = 30, remark = "缴费面积"),
+})
+
+@Java110ResponseDoc(
+        params = {
+                @Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"),
+                @Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"),
+                @Java110ParamDoc(name = "data", type = "int", remark = "赠送积分数"),
+        }
+)
+
+@Java110ExampleDoc(
+        reqBody="{'feeId':'123123','cycle':'1','communityId':'123123','amount':'123123','area':'123123'}",
+        resBody="{'code':0,'msg':'成功','data':1000}"
+)
+@Java110Cmd(serviceCode = "integral.computePayFeeIntegral")
+public class ComputePayFeeIntegralCmd extends Cmd {
+
+    @Autowired
+    private IIntegralRuleFeeV1InnerServiceSMO integralRuleFeeV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IIntegralRuleConfigV1InnerServiceSMO integralRuleConfigV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+
+        Assert.hasKeyAndValue(reqJson,"feeId","未包含费用");
+        Assert.hasKeyAndValue(reqJson,"communityId","未包含小区");
+        Assert.hasKeyAndValue(reqJson,"cycles","未包含缴费周期");
+        Assert.hasKeyAndValue(reqJson,"amount","未包含缴费周期");
+        Assert.hasKeyAndValue(reqJson,"area","未包含缴费周期");
+
+
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        FeeDto feeDto = new FeeDto();
+        feeDto.setFeeId(reqJson.getString("feeId"));
+        List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
+
+        Assert.listOnlyOne(feeDtos,"费用不存在");
+
+        IntegralRuleFeeDto integralRuleFeeDto = new IntegralRuleFeeDto();
+        integralRuleFeeDto.setFeeConfigId(feeDtos.get(0).getConfigId());
+        integralRuleFeeDto.setCurTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        integralRuleFeeDto.setCommunityId(reqJson.getString("communityId"));
+        integralRuleFeeDto.setCycle(reqJson.getString("cycles"));
+        List<IntegralRuleFeeDto> integralRuleFeeDtos = integralRuleFeeV1InnerServiceSMOImpl.queryIntegralRuleFees(integralRuleFeeDto);
+
+        if(integralRuleFeeDtos == null || integralRuleFeeDtos.size()<1){
+            context.setResponseEntity(ResultVo.createResponseEntity(new JSONArray()));
+            return ;
+        }
+
+        List<String> ruleIds = new ArrayList<>();
+        for(IntegralRuleFeeDto tmpCouponRuleFeeDto: integralRuleFeeDtos){
+            ruleIds.add(tmpCouponRuleFeeDto.getRuleId());
+        }
+
+        IntegralRuleConfigDto integralRuleConfigDto = new IntegralRuleConfigDto();
+        integralRuleConfigDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
+        List<IntegralRuleConfigDto> integralRuleConfigDtos = integralRuleConfigV1InnerServiceSMOImpl.queryIntegralRuleConfigs(integralRuleConfigDto);
+
+        if(integralRuleConfigDtos == null || integralRuleConfigDtos.size() < 1){
+            context.setResponseEntity(ResultVo.createResponseEntity(new JSONArray()));
+            return ;
+        }
+
+        // 计算赠送 积分公式
+        long quantity = computeIntegralQuantity(integralRuleConfigDtos,reqJson);
+        context.setResponseEntity(ResultVo.createResponseEntity(quantity));
+    }
+
+    private long computeIntegralQuantity(List<IntegralRuleConfigDto> integralRuleConfigDtos,JSONObject reqJson) {
+
+        long quantity = 0;
+        for(IntegralRuleConfigDto integralRuleConfigDto:integralRuleConfigDtos){
+            quantity += computeOneIntegralQuantity(integralRuleConfigDto,reqJson);
+        }
+        return quantity;
+    }
+
+    /**
+     * 计算计算积分
+     * @param integralRuleConfigDto
+     * @return
+     */
+    private long computeOneIntegralQuantity(IntegralRuleConfigDto integralRuleConfigDto,JSONObject reqJson) {
+       String computingFormula = integralRuleConfigDto.getComputingFormula();
+       BigDecimal amountDec = null;
+       long amount = 0;
+       if(IntegralRuleConfigDto.COMPUTING_FORMULA_AREA.equals(computingFormula)){ //面积乘以单价
+           BigDecimal areaDec = new BigDecimal(Double.parseDouble(reqJson.getString("area")));
+           BigDecimal squarePriceDec = new BigDecimal(Double.parseDouble(integralRuleConfigDto.getSquarePrice()));
+           amountDec = areaDec.multiply(squarePriceDec).setScale(2,BigDecimal.ROUND_HALF_UP);
+       }else if(IntegralRuleConfigDto.COMPUTING_FORMULA_MONEY.equals(computingFormula)){ // 金额乘以单价
+           BigDecimal aDec = new BigDecimal(Double.parseDouble(reqJson.getString("amount")));
+           BigDecimal squarePriceDec = new BigDecimal(Double.parseDouble(integralRuleConfigDto.getSquarePrice()));
+           amountDec = aDec.multiply(squarePriceDec).setScale(2,BigDecimal.ROUND_HALF_UP);
+       }else if(IntegralRuleConfigDto.COMPUTING_FORMULA_FIXED.equals(computingFormula)){ // 固定积分
+           amountDec = new BigDecimal(Double.parseDouble(integralRuleConfigDto.getAdditionalAmount()));
+       }else{
+           amountDec = new BigDecimal(0);
+       }
+
+       if(IntegralRuleConfigDto.SCALE_UP.equals(integralRuleConfigDto.getScale())){
+           amount = new Double(Math.ceil(amountDec.doubleValue())).longValue();
+       }else{
+           amount = new Double(Math.floor(amountDec.doubleValue())).longValue();
+       }
+       return amount;
+    }
+}