From 03ee24e370a02b6d4bbce2634821b31fa056fce8 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 16 五月 2023 10:22:51 +0800
Subject: [PATCH] 修改日志存储

---
 user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/OrderServiceImpl.java |  392 ++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 309 insertions(+), 83 deletions(-)

diff --git a/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/OrderServiceImpl.java b/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/OrderServiceImpl.java
index 49c1200..fd6c398 100644
--- a/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/OrderServiceImpl.java
+++ b/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/service/impl/OrderServiceImpl.java
@@ -12,11 +12,15 @@
 import com.supersavedriving.user.modular.system.util.*;
 import com.supersavedriving.user.modular.system.util.GaoDe.MapUtil;
 import com.supersavedriving.user.modular.system.util.GaoDe.model.District;
+import com.supersavedriving.user.modular.system.util.MallBook.model.*;
+import com.supersavedriving.user.modular.system.util.MallBook.util.Transfer;
+import com.supersavedriving.user.modular.system.util.MallBook.util.TrhRequest;
 import com.supersavedriving.user.modular.system.util.juhe.WeatherUtil;
 import com.supersavedriving.user.modular.system.util.mongodb.model.Location;
 import com.supersavedriving.user.modular.system.warpper.*;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.geo.Circle;
 import org.springframework.data.geo.Distance;
 import org.springframework.data.geo.Metrics;
@@ -29,6 +33,7 @@
 import java.math.BigDecimal;
 import java.math.MathContext;
 import java.math.RoundingMode;
+import java.net.InetAddress;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -89,6 +94,18 @@
 
     @Autowired
     private IRevenueService revenueService;
+
+    @Autowired
+    private IAgentService agentService;
+
+    @Autowired
+    private IPlatformRechargeRecordService platformRechargeRecordService;
+
+    @Autowired
+    private IDivisionRecordService divisionRecordService;
+
+    @Value("${callbackPath}")
+    private String callbackPath;//支付回调网关地址
 
 
 
@@ -370,11 +387,13 @@
         String startAddress = travelOrder.getStartAddress();
         startAddress = startAddress.replaceAll("& #40;", "(");
         startAddress = startAddress.replaceAll("& #41;", ")");
-        travelOrder.setStartAddress(startAddress);;
-        String endAddress = travelOrder.getEndAddress();
-        endAddress = endAddress.replaceAll("& #40;", "(");
-        endAddress = endAddress.replaceAll("& #41;", ")");
-        travelOrder.setEndAddress(endAddress);
+        travelOrder.setStartAddress(startAddress);
+        if(ToolUtil.isNotEmpty(travelOrder.getEndAddress())){
+            String endAddress = travelOrder.getEndAddress();
+            endAddress = endAddress.replaceAll("& #40;", "(");
+            endAddress = endAddress.replaceAll("& #41;", ")");
+            travelOrder.setEndAddress(endAddress);
+        }
 
         order = new Order();
         BeanUtils.copyProperties(travelOrder, order);
@@ -383,7 +402,6 @@
             order.setUserName(appUser.getNickname());
         }
         order.setUserId(uid);
-        order.setCode(UUIDUtil.getTimeStr() + UUIDUtil.getNumberRandom(3));
         order.setSource(1);
         order.setHallOrder(0);
         order.setStatus(1);
@@ -397,6 +415,7 @@
             }
             d = Double.valueOf(distance.get("distance")) / 1000;
             order.setEstimatedMileage(d);
+            order.setEstimatedTime(Integer.valueOf(distance.get("duration")) / 60);
         }
         String city = "";
         District geocode = MapUtil.geocode(order.getStartLng(), order.getStartLat());
@@ -425,6 +444,7 @@
 
         for (Integer i = 0; i < travelOrder.getDriverNum(); i++) {
             order.setId(null);
+            order.setCode(UUIDUtil.getTimeStr() + UUIDUtil.getNumberRandom(3));
             this.insert(order);
 
             //推送状态
@@ -676,6 +696,7 @@
             }
             d = Double.valueOf(distance.get("distance")) / 1000;
             order.setEstimatedMileage(d);
+            order.setEstimatedTime(Integer.valueOf(distance.get("duration")) / 60);
         }
         String city = "";
         District geocode = MapUtil.geocode(order.getStartLng().toString(), order.getStartLat().toString());
@@ -848,9 +869,46 @@
         order.setPayMoney(payMoney);
         SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
         String out_trade_no = sdf.format(new Date()) + order.getId();
-        ResultUtil weixinpay = payMoneyUtil.weixinpay("代驾服务费", "", out_trade_no, payMoney.toString(), "/base/order/orderPayCallback", "JSAPI", appUser.getOpenid());
+//        ResultUtil weixinpay = payMoneyUtil.weixinpay("代驾服务费", "", out_trade_no, payMoney.toString(), "/base/order/orderPayCallback", "JSAPI", appUser.getOpenid());
+//        this.updateById(order);
+
+
+
+        PaymentOrder paymentOrder = new PaymentOrder();
+        paymentOrder.setBizOrderId(out_trade_no);
+        paymentOrder.setAmount(String.valueOf(payMoney * 100));
+        paymentOrder.setOrderName("代驾服务费");
+        paymentOrder.setPayType("WX_MINI");
+        paymentOrder.setTransferType("0");
+        paymentOrder.setAsynSplitFlag("1");
+        paymentOrder.setAppid("");
+        paymentOrder.setOpenid(appUser.getOpenid());
+        paymentOrder.setTerminalIp(InetAddress.getLocalHost().getHostAddress());
+        List<PaymentOrderGood> goodsDetail = new ArrayList<>();
+        PaymentOrderGood paymentOrderGood = new PaymentOrderGood();
+        paymentOrderGood.setGoodsName("服务费");
+        goodsDetail.add(paymentOrderGood);
+        paymentOrder.setGoodsDetail(goodsDetail);
+        paymentOrder.setFrontUrl("");
+        paymentOrder.setNotifyUrl(callbackPath + "/base/order/orderPayCallback");
+        paymentOrder.setParameter1(order.getId().toString());
+
+        TrhRequest<PaymentOrder> request = new TrhRequest();
+        InterfaceResponse execute = request.execute(paymentOrder, PaymentOrder.SERVICE_CODE);
+        if(!"0000".equals(execute.getResult())){
+            return ResultUtil.error(execute.getMsg());
+        }
+        JSONObject jsonObject = JSON.parseObject(execute.getResult());
+        String status = jsonObject.getString("status");
+        if("2".equals(status)){
+            return ResultUtil.error("失败");
+        }
+        if("0".equals(status)){
+            return ResultUtil.error("处理中");
+        }
+        String payCode = jsonObject.getString("payCode");
         this.updateById(order);
-        return weixinpay;
+        return ResultUtil.success(payCode);
     }
 
 
@@ -895,6 +953,7 @@
 
 
         AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+        accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
         accountChangeDetail.setUserType(1);
         accountChangeDetail.setUserId(appUser.getId());
         accountChangeDetail.setCreateTime(new Date());
@@ -940,6 +999,7 @@
         payMoney = payMoney > appUser.getAccountBalance() ? payMoney - appUser.getAccountBalance() : 0D;
 
         AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+        accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
         accountChangeDetail.setUserType(1);
         accountChangeDetail.setUserId(appUser.getId());
         accountChangeDetail.setCreateTime(new Date());
@@ -956,88 +1016,127 @@
         if(0 < payMoney){//还需要调起微信支付
             SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
             String out_trade_no = sdf.format(new Date()) + order.getId();
-            ResultUtil weixinpay = payMoneyUtil.weixinpay("代驾服务费", "", out_trade_no, payMoney.toString(), "/base/order/orderPayCallback", "JSAPI", appUser.getOpenid());
+//            ResultUtil weixinpay = payMoneyUtil.weixinpay("代驾服务费", "", out_trade_no, payMoney.toString(), "/base/order/orderPayCallback", "JSAPI", appUser.getOpenid());
 
-            new Thread(new Runnable() {
-                @Override
-                public void run() {
-                    try {
-                        int num = 1;
-                        int wait = 0;
-                        while (num <= 10){
-                            int min = 5000;
-                            wait += (min * num);
-                            Order order1 = OrderServiceImpl.this.selectById(order.getId());
-                            if(order1.getState() != 107){
-                                return;
-                            }
+            PaymentOrder paymentOrder = new PaymentOrder();
+            paymentOrder.setBizOrderId(out_trade_no);
+            paymentOrder.setAmount(String.valueOf(payMoney * 100));
+            paymentOrder.setOrderName("代驾服务费");
+            paymentOrder.setPayType("WX_MINI");
+            paymentOrder.setTransferType("0");
+            paymentOrder.setAsynSplitFlag("1");
+            paymentOrder.setAppid("");
+            paymentOrder.setOpenid(appUser.getOpenid());
+            paymentOrder.setTerminalIp(InetAddress.getLocalHost().getHostAddress());
+            List<PaymentOrderGood> goodsDetail = new ArrayList<>();
+            PaymentOrderGood paymentOrderGood = new PaymentOrderGood();
+            paymentOrderGood.setGoodsName("服务费");
+            goodsDetail.add(paymentOrderGood);
+            paymentOrder.setGoodsDetail(goodsDetail);
+            paymentOrder.setFrontUrl("");
+            paymentOrder.setNotifyUrl(callbackPath + "/base/order/orderPayCallback");
+            paymentOrder.setParameter1(order.getId().toString());
 
-                            /**
-                             * SUCCESS--支付成功
-                             * REFUND--转入退款
-                             * NOTPAY--未支付
-                             * CLOSED--已关闭
-                             * REVOKED--已撤销(刷卡支付)
-                             * USERPAYING--用户支付中
-                             * PAYERROR--支付失败(其他原因,如银行返回失败)
-                             * ACCEPT--已接收,等待扣款
-                             */
-                            ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(out_trade_no, "");
-                            if(resultUtil.getCode() == 200){
-                                Map<String, String> map = resultUtil.getData();
-                                String trade_type = map.get("trade_type");
-                                String trade_state = map.get("trade_state");
-                                String transaction_id = map.get("transaction_id");
-                                if("REFUND".equals(trade_state) || "NOTPAY".equals(trade_state) || "CLOSED".equals(trade_state) || "REVOKED".equals(trade_state) || "PAYERROR".equals(trade_state)){
-                                    AccountChangeDetail accountChangeDetail1 = accountChangeDetailService.selectById(accountChangeDetail.getId());
-                                    AppUser appUser1 = appUserService.selectById(accountChangeDetail1.getUserId());
-                                    Double b = accountChangeDetail1.getOldData() - accountChangeDetail1.getNewData();
-                                    appUser1.setAccountBalance(appUser1.getAccountBalance() + b);
-                                    appUserService.updateById(appUser1);
+            TrhRequest<PaymentOrder> request = new TrhRequest();
+            InterfaceResponse execute = request.execute(paymentOrder, PaymentOrder.SERVICE_CODE);
+            if(!"0000".equals(execute.getResult())){
+                return ResultUtil.error(execute.getMsg());
+            }
+            JSONObject jsonObject = JSON.parseObject(execute.getResult());
+            String status = jsonObject.getString("status");
+            if("2".equals(status)){
+                return ResultUtil.error("失败");
+            }
+            if("0".equals(status)){
+                return ResultUtil.error("处理中");
+            }
+            String payCode = jsonObject.getString("payCode");
+            this.updateById(order);
+            return ResultUtil.success(payCode);
 
-                                    accountChangeDetailService.deleteById(accountChangeDetail.getId());
-                                    return;
-                                }
-                                if("SUCCESS".equals(trade_state)){
-                                    order1.setPayTime(new Date());
-                                    order1.setState(108);
-                                    order1.setOrderNo(transaction_id);
-                                    OrderServiceImpl.this.updateById(order1);
-
-                                    //处理抽成及收入
-                                    saveCommission(order1);
-                                    return;
-                                }
-                                if("USERPAYING".equals(trade_state) || "ACCEPT".equals(trade_state)){
-                                    Thread.sleep(wait);
-                                    num++;
-                                }
-                            }else{
-                                Thread.sleep(wait);
-                                num++;
-                            }
-                            if(10 == num){
-                                AccountChangeDetail accountChangeDetail1 = accountChangeDetailService.selectById(accountChangeDetail.getId());
-                                AppUser appUser1 = appUserService.selectById(accountChangeDetail1.getUserId());
-                                Double b = accountChangeDetail1.getOldData() - accountChangeDetail1.getNewData();
-                                appUser1.setAccountBalance(appUser1.getAccountBalance() + b);
-                                appUserService.updateById(appUser1);
-
-                                accountChangeDetailService.deleteById(accountChangeDetail.getId());
-                            }
-                        }
-                    }catch (Exception e){
-                        e.printStackTrace();
-                    }
-                }
-            }).start();
-            return weixinpay;
+//
+//
+//            new Thread(new Runnable() {
+//                @Override
+//                public void run() {
+//                    try {
+//                        int num = 1;
+//                        int wait = 0;
+//                        while (num <= 10){
+//                            int min = 5000;
+//                            wait += (min * num);
+//                            Order order1 = OrderServiceImpl.this.selectById(order.getId());
+//                            if(order1.getState() != 107){
+//                                return;
+//                            }
+//
+//                            /**
+//                             * SUCCESS--支付成功
+//                             * REFUND--转入退款
+//                             * NOTPAY--未支付
+//                             * CLOSED--已关闭
+//                             * REVOKED--已撤销(刷卡支付)
+//                             * USERPAYING--用户支付中
+//                             * PAYERROR--支付失败(其他原因,如银行返回失败)
+//                             * ACCEPT--已接收,等待扣款
+//                             */
+//                            ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(out_trade_no, "");
+//                            if(resultUtil.getCode() == 200){
+//                                Map<String, String> map = resultUtil.getData();
+//                                String trade_type = map.get("trade_type");
+//                                String trade_state = map.get("trade_state");
+//                                String transaction_id = map.get("transaction_id");
+//                                if("REFUND".equals(trade_state) || "NOTPAY".equals(trade_state) || "CLOSED".equals(trade_state) || "REVOKED".equals(trade_state) || "PAYERROR".equals(trade_state)){
+//                                    AccountChangeDetail accountChangeDetail1 = accountChangeDetailService.selectById(accountChangeDetail.getId());
+//                                    AppUser appUser1 = appUserService.selectById(accountChangeDetail1.getUserId());
+//                                    Double b = accountChangeDetail1.getOldData() - accountChangeDetail1.getNewData();
+//                                    appUser1.setAccountBalance(appUser1.getAccountBalance() + b);
+//                                    appUserService.updateById(appUser1);
+//
+//                                    accountChangeDetailService.deleteById(accountChangeDetail.getId());
+//                                    return;
+//                                }
+//                                if("SUCCESS".equals(trade_state)){
+//                                    order1.setPayTime(new Date());
+//                                    order1.setState(108);
+//                                    order1.setOrderNo(transaction_id);
+//                                    OrderServiceImpl.this.updateById(order1);
+//
+//                                    //处理抽成及收入
+//                                    saveCommission(order1);
+//                                    return;
+//                                }
+//                                if("USERPAYING".equals(trade_state) || "ACCEPT".equals(trade_state)){
+//                                    Thread.sleep(wait);
+//                                    num++;
+//                                }
+//                            }else{
+//                                Thread.sleep(wait);
+//                                num++;
+//                            }
+//                            if(10 == num){
+//                                AccountChangeDetail accountChangeDetail1 = accountChangeDetailService.selectById(accountChangeDetail.getId());
+//                                AppUser appUser1 = appUserService.selectById(accountChangeDetail1.getUserId());
+//                                Double b = accountChangeDetail1.getOldData() - accountChangeDetail1.getNewData();
+//                                appUser1.setAccountBalance(appUser1.getAccountBalance() + b);
+//                                appUserService.updateById(appUser1);
+//
+//                                accountChangeDetailService.deleteById(accountChangeDetail.getId());
+//                            }
+//                        }
+//                    }catch (Exception e){
+//                        e.printStackTrace();
+//                    }
+//                }
+//            }).start();
+//            return weixinpay;
         }
-        order.setPayTime(new Date());
-        this.updateById(order);
+//        order.setPayTime(new Date());
+//        this.updateById(order);
 
 
         return ResultUtil.success();
+
     }
 
     /**
@@ -1066,8 +1165,125 @@
             pushOrderInfoWarpper.setState(order.getState());
             pushUtil.pushOrderInfo(order.getDriverId(), 2, pushOrderInfoWarpper);
         }
+
+        //支付成功---->异步分账----->10s钟后再进行确认收货
+        //确认收货后才能进行提现(结算接口)
+        //异步分账
+        List<Revenue> revenues = revenueService.selectList(new EntityWrapper<Revenue>().eq("orderId", order.getId()));
+        Complete complete = new Complete();
+        complete.setOriginalMerOrderId(transaction_id);
+        complete.setNotifyUrl(callbackPath + "/base/order/ledgerCallback");
+        List<PamentOrderUser> splitList = new ArrayList<>();
+        for (Revenue revenue : revenues) {
+            if(revenue.getUserType() == 2){//司机
+                Driver driver = driverService.selectById(revenue.getUserId());
+                PamentOrderUser pamentOrderUser = new PamentOrderUser();
+                pamentOrderUser.setSplitUserId(driver.getMerchantNumber());
+                pamentOrderUser.setSplitAmount(revenue.getAmount().toString());
+                pamentOrderUser.setSplitType("2");
+                splitList.add(pamentOrderUser);
+
+                DivisionRecord divisionRecord = new DivisionRecord();
+                divisionRecord.setUserType(1);
+                divisionRecord.setUserId(revenue.getUserId());
+                divisionRecord.setOrderId(order.getId());
+                divisionRecord.setMerOrderId(transaction_id);
+                divisionRecord.setSourceType(1);
+                divisionRecord.setAmount(revenue.getAmount());
+                divisionRecord.setMerchantNumber(driver.getMerchantNumber());
+                divisionRecord.setState(1);
+                divisionRecord.setCreateTime(new Date());
+                divisionRecordService.insert(divisionRecord);
+            }
+            if(revenue.getUserType() == 3){//代理商
+                Agent agent = agentService.selectById(revenue.getUserId());
+                PamentOrderUser pamentOrderUser = new PamentOrderUser();
+                pamentOrderUser.setSplitUserId(agent.getMerchantNumber());
+                pamentOrderUser.setSplitAmount(revenue.getAmount().toString());
+                pamentOrderUser.setSplitType("2");
+                splitList.add(pamentOrderUser);
+
+                DivisionRecord divisionRecord = new DivisionRecord();
+                divisionRecord.setUserType(2);
+                divisionRecord.setUserId(revenue.getUserId());
+                divisionRecord.setOrderId(order.getId());
+                divisionRecord.setMerOrderId(transaction_id);
+                divisionRecord.setSourceType(1);
+                divisionRecord.setAmount(revenue.getAmount());
+                divisionRecord.setMerchantNumber(agent.getMerchantNumber());
+                divisionRecord.setState(1);
+                divisionRecord.setCreateTime(new Date());
+                divisionRecordService.insert(divisionRecord);
+            }
+
+        }
+        complete.setSplitList(splitList);
+        TrhRequest<Complete> request = new TrhRequest();
+        InterfaceResponse execute = request.execute(complete, Complete.SERVICE_CODE);
+        if(!"0000".equals(execute.getResult())){
+            return ResultUtil.error(execute.getMsg());
+        }
+        JSONObject jsonObject = JSON.parseObject(execute.getResult());
+        String status = jsonObject.getString("status");
+        if("2".equals(status)){
+            return ResultUtil.error("失败");
+        }
+        if("0".equals(status)){
+            return ResultUtil.error("处理中");
+        }
+
+        //使用优惠券的情况,通过转账接口将优惠券的收入转到司机电子账簿
+        if(null != order.getCouponId()){
+            List<PlatformRechargeRecord> platformRechargeRecords = platformRechargeRecordService.selectList(new EntityWrapper<PlatformRechargeRecord>().eq("state", 2).last(" and balance > 0 order by payTime"));
+            Double discountedPrice = order.getDiscountedPrice();
+            Driver driver = driverService.selectById(order.getDriverId());
+            for (PlatformRechargeRecord platformRechargeRecord : platformRechargeRecords) {
+                if(discountedPrice == 0){
+                    break;
+                }
+
+                if(platformRechargeRecord.getBalance().compareTo(discountedPrice) >= 0){
+                    discountedPrice = 0D;
+                    platformRechargeRecord.setBalance(platformRechargeRecord.getBalance() - discountedPrice);
+                    platformRechargeRecordService.updateById(platformRechargeRecord);
+                }else{
+
+                }
+
+                Transfer transfer = new Transfer();
+                transfer.setDepositMerOrderId("6831518911582834611");
+                transfer.setToUserId(driver.getMerchantNumber());
+                transfer.setAmount(discountedPrice.toString());
+                transfer.setOrderName("");
+                transfer.setNotifyUrl("");
+                transfer.setParameter1(order.getId().toString());
+
+                TrhRequest<Transfer> request1 = new TrhRequest();
+                InterfaceResponse execute1 = request1.execute(transfer, Transfer.SERVICE_CODE);
+                if(!"0000".equals(execute1.getResult())){
+                    return ResultUtil.error(execute1.getMsg());
+                }
+                JSONObject jsonObject1 = JSON.parseObject(execute1.getResult());
+                String status1 = jsonObject1.getString("status");
+                if("2".equals(status1)){
+                    return ResultUtil.error("失败");
+                }
+                if("0".equals(status1)){
+                    return ResultUtil.error("处理中");
+                }
+            }
+        }
+
+
         return ResultUtil.success();
     }
+
+
+
+
+
+
+
 
 
     /**
@@ -1106,6 +1322,7 @@
 
                 //增加积分变动记录
                 AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                 accountChangeDetail.setUserType(2);
                 accountChangeDetail.setUserId(order.getDriverId());
                 accountChangeDetail.setCreateTime(new Date());
@@ -1126,6 +1343,7 @@
 
                 //增加积分变动记录
                 AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                 accountChangeDetail.setUserType(2);
                 accountChangeDetail.setUserId(order.getDriverId());
                 accountChangeDetail.setCreateTime(new Date());
@@ -1174,6 +1392,7 @@
                         if(num1 > 0){
                             Driver driver1 = driverService.selectById(appUser.getInviterId());
                             AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                            accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                             accountChangeDetail.setUserType(2);
                             accountChangeDetail.setUserId(driver1.getId());
                             accountChangeDetail.setType(1);
@@ -1220,6 +1439,7 @@
                                     revenueService.insert(revenue);
 
                                     AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                                    accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                                     accountChangeDetail.setUserType(2);
                                     accountChangeDetail.setUserId(driver1.getId());
                                     accountChangeDetail.setType(1);
@@ -1245,6 +1465,7 @@
                                     revenueService.insert(revenue);
 
                                     AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                                    accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                                     accountChangeDetail.setUserType(2);
                                     accountChangeDetail.setUserId(driver2.getId());
                                     accountChangeDetail.setType(1);
@@ -1270,6 +1491,7 @@
                                     revenueService.insert(revenue);
 
                                     AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                                    accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                                     accountChangeDetail.setUserType(2);
                                     accountChangeDetail.setUserId(driver3.getId());
                                     accountChangeDetail.setType(1);
@@ -1298,6 +1520,7 @@
                                     revenueService.insert(revenue);
 
                                     AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                                    accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                                     accountChangeDetail.setUserType(2);
                                     accountChangeDetail.setUserId(driver1.getId());
                                     accountChangeDetail.setType(1);
@@ -1323,6 +1546,7 @@
                                     revenueService.insert(revenue);
 
                                     AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                                    accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                                     accountChangeDetail.setUserType(2);
                                     accountChangeDetail.setUserId(driver2.getId());
                                     accountChangeDetail.setType(1);
@@ -1351,6 +1575,7 @@
                                 revenueService.insert(revenue);
 
                                 AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+                                accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
                                 accountChangeDetail.setUserType(2);
                                 accountChangeDetail.setUserId(driver1.getId());
                                 accountChangeDetail.setType(1);
@@ -1391,6 +1616,7 @@
         revenueService.insert(revenue);
 
         AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
+        accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(3));
         accountChangeDetail.setUserType(2);
         accountChangeDetail.setUserId(driver.getId());
         accountChangeDetail.setType(1);

--
Gitblit v1.7.1