充电桩充电加入 充电月卡功能

java110-bean/src/main/java/com/java110/dto/chargeMachine/ChargeMachineOrderDto.java

@@ -30,6 +30,9 @@ public class ChargeMachineOrderDto extends PageDto implements Serializable {
     private String chargeHours;
     private String startTime;
     private String endTime;
+
+    private String queryTime;
+
     private String state;
     private String personTel;
     private String communityId;
@@ -234,4 +237,12 @@ public class ChargeMachineOrderDto extends PageDto implements Serializable {
     public void setStateName(String stateName) {
         this.stateName = stateName;
     }
+
+    public String getQueryTime() {
+        return queryTime;
+    }
+
+    public void setQueryTime(String queryTime) {
+        this.queryTime = queryTime;
+    }
 }

java110-db/src/main/resources/mapper/common/ChargeMachineOrderV1ServiceDaoImplMapper.xml

@@ -68,6 +68,10 @@
         <if test="endTime !=null and endTime != ''">
             and t.end_time= #{endTime}
         </if>
+        <if test="queryTime !=null and queryTime != ''">
+            and t.start_time &lt; #{queryTime}
+            and t.end_time &gt; #{queryTime}
+        </if>
         <if test="state !=null and state != ''">
             and t.state= #{state}
         </if>

service-common/src/main/java/com/java110/common/charge/ChargeCoreImpl.java

@@ -10,6 +10,8 @@ import com.java110.dto.chargeMachine.NotifyChargeOrderDto;
 import com.java110.dto.chargeMachine.ChargeMachineOrderCouponDto;
 import com.java110.dto.chargeMachine.ChargeMachinePortDto;
 import com.java110.dto.chargeMachine.ChargeRuleFeeDto;
+import com.java110.dto.chargeMonthOrder.ChargeMonthOrderDto;
+import com.java110.dto.user.UserDto;
 import com.java110.intf.acct.IAccountInnerServiceSMO;
 import com.java110.intf.common.*;
 import com.java110.po.accountDetail.AccountDetailPo;
@@ -60,6 +62,9 @@ public class ChargeCoreImpl implements IChargeCore {
     @Autowired
     private IChargeMachineOrderCouponV1InnerServiceSMO chargeMachineOrderCouponV1InnerServiceSMOImpl;
 
+    @Autowired
+    private IChargeMonthOrderV1InnerServiceSMO chargeMonthOrderV1InnerServiceSMOImpl;
+
 
     @Override
     public ResultVo startCharge(ChargeMachineDto chargeMachineDto, ChargeMachinePortDto chargeMachinePortDto, String chargeType, double duration, String orderId) {
@@ -103,10 +108,6 @@ public class ChargeCoreImpl implements IChargeCore {
         }
 
 
-        //订单退款 这里不操作，以设备 通知为主
-        // returnOrderMoney(chargeMachineDto, chargeMachinePortDto, "用户手工结束");
-
-
         return resultVo;
     }
 
@@ -114,24 +115,20 @@ public class ChargeCoreImpl implements IChargeCore {
      * 订单退款
      *
      * @param chargeMachineDto
-     * @param chargeMachinePortDto
      */
-    private void returnOrderMoney(ChargeMachineDto chargeMachineDto, ChargeMachinePortDto chargeMachinePortDto, String remark, String energy) {
+    private void returnOrderMoney(ChargeMachineDto chargeMachineDto,
+                                  String remark,
+                                  String energy,
+                                  List<ChargeMachineOrderDto> chargeMachineOrderDtos) {
         // 退款
-        ChargeMachineOrderDto chargeMachineOrderDto = new ChargeMachineOrderDto();
-        chargeMachineOrderDto.setMachineId(chargeMachineDto.getMachineId());
-        chargeMachineOrderDto.setPortId(chargeMachinePortDto.getPortId());
-        chargeMachineOrderDto.setState(ChargeMachineOrderDto.STATE_DOING);
-        List<ChargeMachineOrderDto> chargeMachineOrderDtos = chargeMachineOrderV1InnerServiceSMOImpl.queryChargeMachineOrders(chargeMachineOrderDto);
-
-        if (chargeMachineOrderDtos == null || chargeMachineOrderDtos.size() < 1) {
-            return;
-        }
-
-//        String chargeHours = chargeMachineOrderDtos.get(0).getChargeHours();
-//        double cHours = Double.parseDouble(chargeHours);
-//        if (999 == cHours) {
-//            cHours = 10;
+//        ChargeMachineOrderDto chargeMachineOrderDto = new ChargeMachineOrderDto();
+//        chargeMachineOrderDto.setMachineId(chargeMachineDto.getMachineId());
+//        chargeMachineOrderDto.setPortId(chargeMachinePortDto.getPortId());
+//        chargeMachineOrderDto.setState(ChargeMachineOrderDto.STATE_DOING);
+//        List<ChargeMachineOrderDto> chargeMachineOrderDtos = chargeMachineOrderV1InnerServiceSMOImpl.queryChargeMachineOrders(chargeMachineOrderDto);
+//
+//        if (chargeMachineOrderDtos == null || chargeMachineOrderDtos.size() < 1) {
+//            return;
 //        }
 
         Date startTime = DateUtil.getDateFromStringA(chargeMachineOrderDtos.get(0).getStartTime());
@@ -144,18 +141,18 @@ public class ChargeCoreImpl implements IChargeCore {
         String power = energy;
         if (usedHours < 0) {
             usedHours = 0;
-        }else{
-            BigDecimal powerDec = new BigDecimal(Double.parseDouble(energy)).divide(new BigDecimal(usedHours),2,BigDecimal.ROUND_HALF_UP);
-            power = powerDec.doubleValue()+"";
+        } else {
+            BigDecimal powerDec = new BigDecimal(Double.parseDouble(energy)).divide(new BigDecimal(usedHours), 2, BigDecimal.ROUND_HALF_UP);
+            power = powerDec.doubleValue() + "";
         }
 
         // todo 优惠券抵扣
         JSONObject result = useCoupon(usedHours, chargeMachineOrderDtos);
         usedHours = result.getDoubleValue("usedHours");
-        if(StringUtil.isEmpty(remark)) {
+        if (StringUtil.isEmpty(remark)) {
             remark = result.getString("remark");
-        }else{
-            remark = remark+";"+result.getString("remark");
+        } else {
+            remark = remark + ";" + result.getString("remark");
         }
 
         ChargeRuleFeeDto chargeRuleFeeDto = new ChargeRuleFeeDto();
@@ -245,6 +242,42 @@ public class ChargeCoreImpl implements IChargeCore {
         chargeMachineOrderAcctV1InnerServiceSMOImpl.saveChargeMachineOrderAcct(chargeMachineOrderAcctPo);
     }
 
+    public boolean ifMonthCard(String personTel, String communityId) {
+
+        ChargeMonthOrderDto chargeMonthOrderDto = new ChargeMonthOrderDto();
+        chargeMonthOrderDto.setPersonTel(personTel);
+        chargeMonthOrderDto.setCommunityId(communityId);
+        chargeMonthOrderDto.setQueryTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        List<ChargeMonthOrderDto> chargeMonthOrderDtos = chargeMonthOrderV1InnerServiceSMOImpl.queryChargeMonthOrders(chargeMonthOrderDto);
+        if (chargeMonthOrderDtos == null || chargeMonthOrderDtos.size() < 1) {
+            return false;
+        }
+
+        //todo 今天是否又充过电
+        ChargeMachineOrderDto chargeMachineOrderDto = new ChargeMachineOrderDto();
+        chargeMachineOrderDto.setPersonTel(personTel);
+        chargeMachineOrderDto.setCommunityId(communityId);
+        chargeMachineOrderDto.setQueryTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        List<ChargeMachineOrderDto> chargeMachineOrderDtos = chargeMachineOrderV1InnerServiceSMOImpl.queryChargeMachineOrders(chargeMachineOrderDto);
+
+        if (chargeMachineOrderDtos == null || chargeMachineOrderDtos.size() < 1) {
+            return true;
+        }
+
+
+        Date startTime = DateUtil.getDateFromStringA(chargeMachineOrderDtos.get(0).getStartTime());
+        Date endTime = DateUtil.getDateFromStringA(chargeMachineOrderDtos.get(0).getEndTime());
+
+
+        double usedHours = (endTime.getTime() - startTime.getTime()) / (60 * 60 * 1000.00);
+
+        if (usedHours < 1) {
+            return true;
+        }
+
+        return false;
+    }
+
     /**
      * 优惠券抵扣 小时
      *
@@ -354,11 +387,48 @@ public class ChargeCoreImpl implements IChargeCore {
         chargeMachinePortPo.setState(ChargeMachinePortDto.STATE_FREE);
         chargeMachinePortV1InnerServiceSMOImpl.updateChargeMachinePort(chargeMachinePortPo);
 
-        returnOrderMoney(chargeMachineDtos.get(0), chargeMachinePortDtos.get(0), notifyChargeOrderDto.getReason(), notifyChargeOrderDto.getEnergy());
+        ChargeMachineOrderDto chargeMachineOrderDto = new ChargeMachineOrderDto();
+        chargeMachineOrderDto.setMachineId(chargeMachineDto.getMachineId());
+        chargeMachineOrderDto.setPortId(chargeMachinePortDto.getPortId());
+        chargeMachineOrderDto.setState(ChargeMachineOrderDto.STATE_DOING);
+        List<ChargeMachineOrderDto> chargeMachineOrderDtos = chargeMachineOrderV1InnerServiceSMOImpl.queryChargeMachineOrders(chargeMachineOrderDto);
+
+        if (chargeMachineOrderDtos == null || chargeMachineOrderDtos.size() < 1) {
+            return new ResultVo(ResultVo.CODE_OK, "成功");
+        }
+
+        //todo 月卡直接修改状态
+        if (ifMonthCard(chargeMachineOrderDtos.get(0).getPersonTel(), chargeMachinePortDtos.get(0).getCommunityId())) {
+            finishMonthCardChargeOrder(notifyChargeOrderDto, chargeMachineOrderDtos);
+            return new ResultVo(ResultVo.CODE_OK, "成功");
+        }
+
+        returnOrderMoney(chargeMachineDtos.get(0), notifyChargeOrderDto.getReason(), notifyChargeOrderDto.getEnergy(),chargeMachineOrderDtos);
 
         return new ResultVo(ResultVo.CODE_OK, "成功");
     }
 
+    /**
+     * 结束月卡 充电订单
+     * @param notifyChargeOrderDto
+     * @param chargeMachineOrderDtos
+     */
+    private void finishMonthCardChargeOrder(NotifyChargeOrderDto notifyChargeOrderDto, List<ChargeMachineOrderDto> chargeMachineOrderDtos) {
+        ChargeMachineOrderPo chargeMachineOrderPo = new ChargeMachineOrderPo();
+        chargeMachineOrderPo.setOrderId(chargeMachineOrderDtos.get(0).getOrderId());
+        chargeMachineOrderPo.setRemark(notifyChargeOrderDto.getReason());
+        chargeMachineOrderPo.setState(ChargeMachineOrderDto.STATE_FINISH);
+        chargeMachineOrderPo.setAmount("0");
+        chargeMachineOrderPo.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        chargeMachineOrderPo.setCommunityId(chargeMachineOrderDtos.get(0).getCommunityId());
+        //chargeMachineOrderPo.setDurationPrice(durationPrice);
+        chargeMachineOrderPo.setEnergy(notifyChargeOrderDto.getEnergy());
+        int flag = chargeMachineOrderV1InnerServiceSMOImpl.updateChargeMachineOrder(chargeMachineOrderPo);
+        if (flag < 1) {
+            throw new IllegalArgumentException("修改订单失败");
+        }
+    }
+
     @Override
     public ResultVo workHeartbeat(NotifyChargeOrderDto notifyChargeOrderDto) {
 

service-common/src/main/java/com/java110/common/charge/IChargeCore.java

@@ -50,4 +50,6 @@ public interface IChargeCore {
      * @param chargeMachineDtos
      */
     void queryChargeMachineState(List<ChargeMachineDto> chargeMachineDtos);
+
+     boolean ifMonthCard(String personTel, String communityId);
 }

service-common/src/main/java/com/java110/common/cmd/chargeMachine/StartChargeCmd.java

@@ -13,6 +13,7 @@ import com.java110.dto.chargeMachine.ChargeMachineDto;
 import com.java110.dto.chargeMachine.ChargeMachineOrderDto;
 import com.java110.dto.chargeMachine.ChargeMachinePortDto;
 import com.java110.dto.chargeMachine.ChargeRuleFeeDto;
+import com.java110.dto.chargeMonthOrder.ChargeMonthOrderDto;
 import com.java110.dto.couponPool.CouponPropertyPoolConfigDto;
 import com.java110.dto.couponPool.CouponPropertyUserDto;
 import com.java110.dto.user.UserDto;
@@ -39,6 +40,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import java.math.BigDecimal;
 import java.text.ParseException;
 import java.util.Calendar;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -84,6 +86,9 @@ public class StartChargeCmd extends Cmd {
     @Autowired
     private IChargeMachineOrderCouponV1InnerServiceSMO chargeMachineOrderCouponV1InnerServiceSMOImpl;
 
+    @Autowired
+    private IChargeMonthOrderV1InnerServiceSMO chargeMonthOrderV1InnerServiceSMOImpl;
+
     @Override
     public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
         Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区信息");
@@ -139,6 +144,12 @@ public class StartChargeCmd extends Cmd {
 
         Assert.listOnlyOne(userDtos, "用户不存在");
 
+        //todo 如果是 月卡充值 ，后面不做校验
+        if (chargeCoreImpl.ifMonthCard(userDtos.get(0).getTel(), chargeMachinePortDtos.get(0).getCommunityId())) {
+            return;
+        }
+
+
         AccountDto accountDto = new AccountDto();
         accountDto.setLink(userDtos.get(0).getTel());
         accountDto.setAcctType(AccountDto.ACCT_TYPE_CASH);
@@ -254,6 +265,12 @@ public class StartChargeCmd extends Cmd {
         }
         resultVo.setData(orderId);
 
+        //todo 如果是 月卡充值 ，后面不做校验
+        if (chargeCoreImpl.ifMonthCard(userDtos.get(0).getTel(), chargeMachinePortDtos.get(0).getCommunityId())) {
+            monthCardOrder(reqJson, chargeMachineDtos, orderId, durationHours);
+            return;
+        }
+
 
         //todo 优惠券抵扣
         withholdCoupon(reqJson, chargeMachineDtos, orderId);
@@ -266,6 +283,34 @@ public class StartChargeCmd extends Cmd {
         context.setResponseEntity(ResultVo.createResponseEntity(resultVo));
     }
 
+    /**
+     * 月卡方式
+     *
+     * @param reqJson
+     * @param chargeMachineDtos
+     * @param orderId
+     * @param durationHours
+     */
+    private void monthCardOrder(JSONObject reqJson, List<ChargeMachineDto> chargeMachineDtos, String orderId, double durationHours) {
+
+        ChargeMachineOrderAcctPo chargeMachineOrderAcctPo = new ChargeMachineOrderAcctPo();
+        chargeMachineOrderAcctPo.setAcctDetailId("-1");
+        chargeMachineOrderAcctPo.setAmount("0");
+
+        chargeMachineOrderAcctPo.setCmoaId(GenerateCodeFactory.getGeneratorId("11"));
+        chargeMachineOrderAcctPo.setOrderId(orderId);
+        chargeMachineOrderAcctPo.setAcctId("-1");
+        chargeMachineOrderAcctPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        chargeMachineOrderAcctPo.setEndTime(DateUtil.getAddHoursStringA(DateUtil.getCurrentDate(), new Double(Math.ceil(durationHours)).intValue()));
+        chargeMachineOrderAcctPo.setRemark("月卡抵扣");
+        chargeMachineOrderAcctPo.setCommunityId(chargeMachineDtos.get(0).getCommunityId());
+        chargeMachineOrderAcctPo.setEnergy("0");
+        chargeMachineOrderAcctPo.setDurationPrice(reqJson.getString("durationPrice"));
+
+
+        chargeMachineOrderAcctV1InnerServiceSMOImpl.saveChargeMachineOrderAcct(chargeMachineOrderAcctPo);
+    }
+
     /**
      * 优惠券抵扣
      *
@@ -322,33 +367,11 @@ public class StartChargeCmd extends Cmd {
                 chargeMachineOrderCouponPo.setCmocId(GenerateCodeFactory.getGeneratorId("11"));
                 chargeMachineOrderCouponPo.setHours(value + "");
                 chargeMachineOrderCouponV1InnerServiceSMOImpl.saveChargeMachineOrderCoupon(chargeMachineOrderCouponPo);
-
-//                couponNames += ("优惠券名称：" + couponPropertyUserDtos.get(0).getCouponName() + "(" + couponId + "),小时："+value+";");
-//
-//                hours += value;
             } finally {
                 DistributedLock.releaseDistributedLock(requestId, key);
             }
         }
 
-//        hours = Math.ceil(hours);
-
-//        ChargeMachineOrderAcctPo chargeMachineOrderAcctPo = new ChargeMachineOrderAcctPo();
-//        chargeMachineOrderAcctPo.setAcctDetailId("-1");
-//        chargeMachineOrderAcctPo.setAmount("0");
-//        chargeMachineOrderAcctPo.setCmoaId(GenerateCodeFactory.getGeneratorId("11"));
-//        chargeMachineOrderAcctPo.setOrderId(orderId);
-//        chargeMachineOrderAcctPo.setAcctId(reqJson.getString("acctId"));
-//        chargeMachineOrderAcctPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
-//        chargeMachineOrderAcctPo.setEndTime(DateUtil.getAddHoursStringA(DateUtil.getCurrentDate(), new Double(hours).intValue()));
-//        chargeMachineOrderAcctPo.setRemark("优惠券抵扣," + couponNames);
-//        chargeMachineOrderAcctPo.setCommunityId(chargeMachineDtos.get(0).getCommunityId());
-//        chargeMachineOrderAcctPo.setEnergy("0");
-//        chargeMachineOrderAcctPo.setDurationPrice(reqJson.getString("durationPrice"));
-//
-//        chargeMachineOrderAcctV1InnerServiceSMOImpl.saveChargeMachineOrderAcct(chargeMachineOrderAcctPo);
-
-//        return hours;
     }
 
     /**