From 6882eb4a211cad20c25664c642cd9097aa79c7d7 Mon Sep 17 00:00:00 2001 From: luozukai Date: Thu, 20 Jun 2019 10:45:43 +0800 Subject: [PATCH 1/8] =?UTF-8?q?[=E5=AE=A1=E6=89=B9][=E4=BF=AE=E6=94=B9][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=95=B0=E6=8D=AE]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../V201906201040__L_ADD_FLOW_DATA.sql | 81 +++++++++++++++++++ .../impl/WxPropertyContractServiceImpl.java | 5 -- .../impl/WxRentContractServiceImpl.java | 5 +- 3 files changed, 85 insertions(+), 6 deletions(-) create mode 100644 mallinkAdmin/src/main/resources/db/migration/V201906201040__L_ADD_FLOW_DATA.sql diff --git a/mallinkAdmin/src/main/resources/db/migration/V201906201040__L_ADD_FLOW_DATA.sql b/mallinkAdmin/src/main/resources/db/migration/V201906201040__L_ADD_FLOW_DATA.sql new file mode 100644 index 000000000..b5df17dea --- /dev/null +++ b/mallinkAdmin/src/main/resources/db/migration/V201906201040__L_ADD_FLOW_DATA.sql @@ -0,0 +1,81 @@ +delete from wx_flow_config where tenant_id !='456'; + +INSERT INTO `wx_flow_config` (`id`, `parent_id`, `tenant_id`, `name`, `type`, `model_id`, `create_date`, `update_date`, `sort`) +VALUES + (1561037689, 0, '1001', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561000622, 0, '1001', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1561026138, 1561000622, '1001', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1561035391, 1561000622, '1001', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561002700, 1561000622, '1001', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561028078, 1561000622, '1001', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1560971400, 1561037689, '1001', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561054659, 0, '1002', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561051609, 0, '1002', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1560987400, 1561051609, '1002', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1560983105, 1561051609, '1002', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1560971226, 1561051609, '1002', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561057278, 1561051609, '1002', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561030661, 1561054659, '1002', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561020831, 0, '1003', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1560974564, 0, '1003', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1560983628, 1560974564, '1003', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561019138, 1561020831, '1003', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1560985450, 1561020831, '1003', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1561052800, 1561020831, '1003', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1561020810, 1561020831, '1003', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561030951, 0, '1004', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1561031751, 0, '1004', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561047137, 1561030951, '1004', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1560980346, 1561030951, '1004', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1560990605, 1561030951, '1004', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1561004716, 1561030951, '1004', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561059134, 1561031751, '1004', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561058629, 0, '1005', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1560981619, 0, '1005', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561016658, 1560981619, '1005', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561031019, 1561058629, '1005', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561050999, 1561058629, '1005', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1561023445, 1561058629, '1005', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1561059049, 1561058629, '1005', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561013248, 0, '1006', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561044349, 0, '1006', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1561012583, 1561013248, '1006', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561049102, 1561044349, '1006', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1561052002, 1561044349, '1006', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561038202, 1561044349, '1006', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1560979080, 1561044349, '1006', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561020704, 0, '1007', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561056649, 0, '1007', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1561006459, 1561020704, '1007', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561048605, 1561056649, '1007', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561024693, 1561056649, '1007', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1560977117, 1561056649, '1007', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1561052381, 1561056649, '1007', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561034575, 0, '1008', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1561060600, 0, '1008', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561048087, 1561034575, '1008', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1560997446, 1561034575, '1008', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561051779, 1561034575, '1008', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1560987028, 1561034575, '1008', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1561025368, 1561060600, '1008', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1560979235, 0, '1009', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561044274, 0, '1009', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1560982828, 1560979235, '1009', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561041930, 1561044274, '1009', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561051961, 1561044274, '1009', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1561000314, 1561044274, '1009', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1560972165, 1561044274, '1009', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561009249, 0, '789', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1561048493, 0, '789', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561020995, 1561009249, '789', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3), + (1561008855, 1561009249, '789', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1560973533, 1561009249, '789', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1561033189, 1561009249, '789', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1561041774, 1561048493, '789', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561054066, 0, '790', '合同审批', 0, 0, '2019-06-11 13:42:18', '2019-06-11 13:42:18', 1), + (1560974795, 0, '790', '账单审批', 0, 0, '2019-06-11 13:49:43', '2019-06-11 13:49:43', 2), + (1561056192, 1560974795, '790', '账单应收金额变更', 8, 0, '2019-06-11 14:02:44', '2019-06-11 14:02:44', 1), + (1561048116, 1561054066, '790', '多经点位合同终止', 7, 0, '2019-06-11 14:02:43', '2019-06-11 14:02:43', 4), + (1560973899, 1561054066, '790', '多径点位合同签约', 5, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 2), + (1561010589, 1561054066, '790', '商铺合同签约', 4, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 1), + (1560977371, 1561054066, '790', '商铺合同终止', 6, 0, '2019-06-11 14:02:42', '2019-06-11 14:02:42', 3); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java index 06dbab3a9..8cfab0d5f 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java @@ -980,11 +980,6 @@ public class WxPropertyContractServiceImpl implements WxPropertyContractService wxBillProperty.setPropertyContractId(wxPropertyContract.getId()); wxBillPropertyMapper.updateInvalidStatus(wxBillProperty); } - - public static void main(String[] args) { - List l = new ArrayList(); - l.add(1) ; - } } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java index 70a4c054a..6402698eb 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java @@ -2072,6 +2072,9 @@ public class WxRentContractServiceImpl implements WxRentContractService { wxBillRentMapper.updateInvalidStatus(wxBillRent); //解绑商户和商铺关系 - wxMerchantService.disable(wxRentContractMapper.selectByPrimaryKey(wxRentContract.getId()).getMerchantId()); + WxRentContract rentContract = wxRentContractMapper.selectByPrimaryKey(wxRentContract.getId()); + if(rentContract != null && rentContract.getMerchantId() != null){ + wxMerchantService.disable(rentContract.getMerchantId()); + } } } \ No newline at end of file From c9d9098c15baafac23acc8ecc995aded073cd259 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Thu, 20 Jun 2019 11:34:05 +0800 Subject: [PATCH 2/8] =?UTF-8?q?[BUG][=E4=BF=AE=E6=94=B9][=E7=89=A9?= =?UTF-8?q?=E4=B8=9A=E4=BF=9D=E5=AD=98=E9=97=AE=E9=A2=98]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../WxPropertyContractController.java | 23 +++++-------------- .../service/WxPropertyContractService.java | 2 +- .../impl/WxPropertyContractServiceImpl.java | 2 +- 3 files changed, 8 insertions(+), 19 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java b/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java index d40bf7d3b..be0b06fa4 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java @@ -20,7 +20,6 @@ import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import java.util.Date; import java.util.Map; /** @@ -60,12 +59,11 @@ public class WxPropertyContractController extends BaseController { MallUserInfo user = getUser(); wxPropertyContract.setTenantId(user.getTenantId()); wxPropertyContract.setAdjustPeriodHandle(); - Date oldDate = wxPropertyContract.getRentalStartDate(); if(wxPropertyContract.getRentStartType()!=null && wxPropertyContract.getRentStartType().equals(EnumRentStartType.STARTTIME.getCode())){ wxPropertyContract.setRentalStartDate(wxPropertyContract.getStartDate()); } - return wxPropertyContractService.saveOrUpdate(wxPropertyContract, user.getId(), user.getName(), oldDate); + return wxPropertyContractService.saveOrUpdate(wxPropertyContract, user.getId(), user.getName()); } @PostMapping("updateRentStartTime") @@ -74,7 +72,6 @@ public class WxPropertyContractController extends BaseController { logger.debug("[" + getIpAddr() + "] WxPropertyContractController::updateRentStartTime"); WxPropertyContract propertyContract = wxPropertyContractMapper.selectByPrimaryKey(wxPropertyContract.getId()); propertyContract.setRentalStartDate(wxPropertyContract.getRentalStartDate()); - Date oldDate = wxPropertyContract.getRentalStartDate(); if(wxPropertyContract.getRentStartType()!=null && wxPropertyContract.getRentStartType().equals(EnumRentStartType.STARTTIME.getCode())){ propertyContract.setRentalStartDate(propertyContract.getStartDate()); @@ -84,7 +81,7 @@ public class WxPropertyContractController extends BaseController { propertyContract.setTenantId(user.getTenantId()); propertyContract.setAdjustPeriodHandle(); propertyContract.setRentStartType(wxPropertyContract.getRentStartType()); - return wxPropertyContractService.saveOrUpdate(propertyContract, user.getId(), user.getName(), oldDate); + return wxPropertyContractService.saveOrUpdate(propertyContract, user.getId(), user.getName()); } @@ -92,20 +89,12 @@ public class WxPropertyContractController extends BaseController { @SystemControllerLog(description = "物业合同-修改") public ResultData update(@RequestBody WxPropertyContract wxPropertyContract) { logger.debug("[" + getIpAddr() + "] WxPropertyContractController::update"); - WxPropertyContract propertyContract = wxPropertyContractMapper.selectByPrimaryKey(wxPropertyContract.getId()); - propertyContract.setRentalStartDate(wxPropertyContract.getRentalStartDate()); - Date oldDate = wxPropertyContract.getRentalStartDate(); - - if (wxPropertyContract.getRentStartType() != null && wxPropertyContract.getRentStartType().equals(EnumRentStartType.STARTTIME.getCode())) { - propertyContract.setRentalStartDate(propertyContract.getStartDate()); - } - MallUserInfo user = getUser(); - propertyContract.setTenantId(user.getTenantId()); - propertyContract.setAdjustPeriodHandle(); - propertyContract.setRentStartType(wxPropertyContract.getRentStartType()); + wxPropertyContract.setTenantId(user.getTenantId()); + wxPropertyContract.setAdjustPeriodHandle(); //第三步提交 SWITCH - return wxPropertyContractService.saveOrUpdate(wxPropertyContract, user.getId(), user.getName(), oldDate); + return wxPropertyContractService.saveOrUpdate(wxPropertyContract, user.getId(), user.getName()); + } @GetMapping("/del") diff --git a/mallinkService/src/main/java/com/iformall/service/WxPropertyContractService.java b/mallinkService/src/main/java/com/iformall/service/WxPropertyContractService.java index 64143f7bf..c73d99534 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxPropertyContractService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxPropertyContractService.java @@ -40,7 +40,7 @@ public interface WxPropertyContractService { * @param oldDate * @return */ - ResultData saveOrUpdate(WxPropertyContract record, Long userId, String userName, Date oldDate); + ResultData saveOrUpdate(WxPropertyContract record, Long userId, String userName); /** * 根据Id删除实体 diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java index 8cfab0d5f..5adf8153d 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java @@ -211,7 +211,7 @@ public class WxPropertyContractServiceImpl implements WxPropertyContractService @Override @Transactional(rollbackFor = {Exception.class}) - public ResultData saveOrUpdate(WxPropertyContract record, Long userId, String userName, Date oldDate) { + public ResultData saveOrUpdate(WxPropertyContract record, Long userId, String userName) { // 保存调整金额(预账单调整) boolean haspreview = false; if(!CollectionUtils.isEmpty(record.getPreviewBillRentList())){ From 8d33f552218b65bf0debe36521c4f955728d4514 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Thu, 20 Jun 2019 13:08:44 +0800 Subject: [PATCH 3/8] =?UTF-8?q?[BUG][=E4=BF=AE=E6=94=B9][=E7=94=9F?= =?UTF-8?q?=E6=88=90=E7=89=A9=E4=B8=9A=E8=B4=A6=E5=8D=95=E9=97=AE=E9=A2=98?= =?UTF-8?q?]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/contract/WxPropertyContractController.java | 6 ------ .../service/impl/WxPropertyContractServiceImpl.java | 7 ++++--- 2 files changed, 4 insertions(+), 9 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java b/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java index be0b06fa4..9e2afe7d7 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxPropertyContractController.java @@ -71,12 +71,6 @@ public class WxPropertyContractController extends BaseController { public ResultData updateRentStartTime(@RequestBody WxPropertyContract wxPropertyContract) { logger.debug("[" + getIpAddr() + "] WxPropertyContractController::updateRentStartTime"); WxPropertyContract propertyContract = wxPropertyContractMapper.selectByPrimaryKey(wxPropertyContract.getId()); - propertyContract.setRentalStartDate(wxPropertyContract.getRentalStartDate()); - - if(wxPropertyContract.getRentStartType()!=null && wxPropertyContract.getRentStartType().equals(EnumRentStartType.STARTTIME.getCode())){ - propertyContract.setRentalStartDate(propertyContract.getStartDate()); - } - MallUserInfo user = getUser(); propertyContract.setTenantId(user.getTenantId()); propertyContract.setAdjustPeriodHandle(); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java index 5adf8153d..c1b756059 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxPropertyContractServiceImpl.java @@ -707,9 +707,10 @@ public class WxPropertyContractServiceImpl implements WxPropertyContractService if (wxPropertyContract != null) { int receivePeriod = wxPropertyContract.getReceivePeriod().intValue(); Integer lease = wxPropertyContract.getLease(); - Date rentalStartDate = propertyContract.getRentalStartDate(); - if (propertyContract.getRentShopType().equals(EnumRentStartType.STARTTIME.getCode())) { - rentalStartDate = propertyContract.getStartDate(); + Date rentalStartDate = wxPropertyContract.getRentalStartDate(); + System.out.println(wxPropertyContract.getRentStartType().intValue() + "------------------"); + if (wxPropertyContract.getRentStartType().equals(EnumRentStartType.STARTTIME.getCode())) { + rentalStartDate = wxPropertyContract.getStartDate(); } propertyContract.setRentalStartDate(rentalStartDate); Long price = propertyContract.getPrice(); From a499ea6169b4f7ce5d2fcc30611d2dd3d6dd5d06 Mon Sep 17 00:00:00 2001 From: hupeng Date: Thu, 20 Jun 2019 14:33:43 +0800 Subject: [PATCH 4/8] =?UTF-8?q?[=E5=A4=A7=E5=B1=8F][=E4=BF=AE=E6=94=B9]:?= =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=8F=82=E6=95=B0=E5=8D=95=E4=BD=8D,?= =?UTF-8?q?=E5=BF=83=E8=B7=B3=E6=9B=B4=E6=96=B0=E8=AF=AD=E5=8F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/device/WxDeviceScreenAdController.java | 10 ++++++---- .../com/iformall/service/impl/WxDeviceServiceImpl.java | 6 +++--- .../src/main/resources/mapper/WxDeviceMapper.xml | 2 +- 3 files changed, 10 insertions(+), 8 deletions(-) diff --git a/mallinkCallback/src/main/java/com/iformall/controller/device/WxDeviceScreenAdController.java b/mallinkCallback/src/main/java/com/iformall/controller/device/WxDeviceScreenAdController.java index a7587b32f..b17f3276c 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/device/WxDeviceScreenAdController.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/device/WxDeviceScreenAdController.java @@ -92,11 +92,13 @@ public class WxDeviceScreenAdController extends BaseController { WxDevice wxDevice = findDevice(deviceId); if (wxDevice == null) return new ResultData(ErrorCode.DEVICE_NOT_FOUND); + WxDevice record = new WxDevice(); + record.setId(wxDevice.getId()); if (wxDevice.getFirstHbTime() == null) - wxDevice.setFirstHbTime(new Date()); - wxDevice.setLastHbTime(new Date()); - wxDevice.setVersion(paramMap.get("version")); - wxDeviceService.saveOrUpdate(wxDevice); + record.setFirstHbTime(new Date()); + record.setLastHbTime(new Date()); + record.setVersion(paramMap.get("version")); + wxDeviceService.saveOrUpdate(record); Map result = new HashMap<>(); result.put("config",wxDevice.getConfig()); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java index e1e57c510..e345ec635 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java @@ -29,9 +29,9 @@ public class WxDeviceServiceImpl implements WxDeviceService { WxDeviceMapper wxDeviceMapper; final String DEVICE_DEFAULT_CONFIG_SCREEN_AD = "{" + - "\"heartbeatInterval\":300000," + //5MIN - "\"dataRefreshInterval\":3600000," + //1HOUR - "\"pageChangeInterval\":10000," + //10SEC + "\"heartbeatInterval\":300," + //5MIN + "\"dataRefreshInterval\":3600," + //1HOUR + "\"pageChangeInterval\":10," + //10SEC "\"animationTheme\":0" + "}"; diff --git a/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml b/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml index c33a30a69..4c0e3e447 100644 --- a/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml @@ -35,7 +35,7 @@ - and `device_id` like concat('%', #{deviceId},'%') + and `device_id` = #{deviceId} From e8d5507c8270d6131d33b14a03c623c8b4148a04 Mon Sep 17 00:00:00 2001 From: hupeng Date: Thu, 20 Jun 2019 17:33:05 +0800 Subject: [PATCH 5/8] =?UTF-8?q?[=E7=94=B5=E8=A1=A8][=E4=BF=AE=E6=94=B9]:?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=AD=98=E5=82=A8=E9=80=BB=E8=BE=91,?= =?UTF-8?q?=E7=BB=9F=E4=B8=80=E5=AE=9A=E4=B9=89=E5=91=BD=E4=BB=A4=E5=AD=97?= =?UTF-8?q?=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/device/KwBoxV1Controller.java | 51 +++++------- .../com/iformall/service/kw/KwBoxService.java | 22 +++++- .../service/kw/KwMeterDataService.java | 2 +- .../service/kw/impl/KwBoxServiceImpl.java | 78 +++++++++++-------- .../kw/impl/KwMeterDataServiceImpl.java | 6 +- 5 files changed, 90 insertions(+), 69 deletions(-) diff --git a/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java b/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java index 66d1c6c7e..19b13d8bb 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java @@ -52,11 +52,11 @@ public class KwBoxV1Controller extends BaseController { private ResultData cmdRegist(String imei, String ccid, Date deviceTime, Map paramMap) { - String fwv = (String)paramMap.get("FWV"); + String fwv = (String)paramMap.get(KwBoxService.PREFIX_FW_VERSION); if (StringUtil.isNullOrEmpty(fwv)) return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); - String hwv = (String)paramMap.get("HWV"); + String hwv = (String)paramMap.get(KwBoxService.PREFIX_HW_VERSION); if (StringUtil.isNullOrEmpty(hwv)) return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); @@ -68,7 +68,7 @@ public class KwBoxV1Controller extends BaseController { if (!kwBox.getRegisterStatus().equals(EnumBoxRegisterStatus.INIT.getCode())) return new ResultData(ErrorCode.DEVICE_ALREADY_EXIST); - saveCmd(kwBox.getTenantId(),"regist",imei,ccid,deviceTime,paramMap); + saveCmd(kwBox.getTenantId(),KwBoxService.CMD_REGISTER,imei,ccid,deviceTime,paramMap); KwBox record = new KwBox(); record.setId(kwBox.getId()); @@ -82,14 +82,14 @@ public class KwBoxV1Controller extends BaseController { kwBoxService.saveOrUpdate(record); Map data = new HashMap<>(); - data.put("sysStatus",record.getRegisterStatus()); + data.put(KwBoxService.PREFIX_SYS_STATUS,record.getRegisterStatus()); if (kwBox.getComKey() != null) - data.put("comKey",kwBox.getComKey()); + data.put(KwBoxService.PREFIX_COM_KEY,kwBox.getComKey()); if (kwBox.getConfig() != null) - data.put("config",kwBox.getConfig()); + data.put(KwBoxService.PREFIX_CONFIG,kwBox.getConfig()); List meters = kwBoxService.findMetersAddress(kwBox); if (!meters.isEmpty()) - data.put("meters",meters); + data.put(KwBoxService.PREFIX_METERS,meters); return new ResultData(data); } @@ -104,7 +104,7 @@ public class KwBoxV1Controller extends BaseController { if (!kwBox.getRegisterStatus().equals(EnumBoxRegisterStatus.REGISTERED.getCode())) return new ResultData(ErrorCode.DEVICE_NOT_FOUND); - saveCmd(kwBox.getTenantId(),"login",imei,ccid,deviceTime,paramMap); + saveCmd(kwBox.getTenantId(),KwBoxService.CMD_LOGIN,imei,ccid,deviceTime,paramMap); KwBox record = new KwBox(); record.setId(kwBox.getId()); @@ -114,7 +114,7 @@ public class KwBoxV1Controller extends BaseController { kwBoxService.saveOrUpdate(record); Map data = new HashMap<>(); if (kwBox.getConfig() != null) - data.put("config",kwBox.getConfig() ); + data.put(KwBoxService.PREFIX_CONFIG,kwBox.getConfig() ); return new ResultData(data); } @@ -129,27 +129,17 @@ public class KwBoxV1Controller extends BaseController { if (!kwBox.getRegisterStatus().equals(EnumBoxRegisterStatus.REGISTERED.getCode())) return new ResultData(ErrorCode.DEVICE_NOT_FOUND); - saveCmd(kwBox.getTenantId(),"hb",imei,ccid,deviceTime,paramMap); + saveCmd(kwBox.getTenantId(),KwBoxService.CMD_HEARTBEAT,imei,ccid,deviceTime,paramMap); KwBox record = new KwBox(); record.setId(kwBox.getId()); record.setLastOnlineTime(new Date()); - kwBoxService.saveOrUpdate(record); - Map resData = new HashMap<>(); List> metersData = (List>)paramMap.get("meters"); - - if (!metersData.isEmpty()) { - metersData.stream().forEach(m->{ - String addr = m.get("addr"); - String activePower = m.get("ap"); //active power - kwBoxService.saveMeterData(kwBox, deviceTime, addr, activePower); - }); - } + kwBoxService.saveMeterData(kwBox, metersData, deviceTime); List meters = kwBoxService.findMetersAddress(kwBox); - boolean updateMeters = false; boolean updateConfig = false; @@ -161,11 +151,12 @@ public class KwBoxV1Controller extends BaseController { updateMeters = true; } + Map resData = new HashMap<>(); if (updateMeters) { - resData.put("meters", meters); + resData.put(KwBoxService.PREFIX_METERS, meters); } if (updateConfig) { - resData.put("config", kwBox.getConfig()); + resData.put(KwBoxService.PREFIX_CONFIG, kwBox.getConfig()); } return new ResultData(resData); @@ -179,19 +170,19 @@ public class KwBoxV1Controller extends BaseController { @PostMapping("command") public Result command(@RequestBody Map paramMap) { - String cmd = (String)paramMap.get("CMD"); + String cmd = (String)paramMap.get(KwBoxService.PREFIX_CMD); if (StringUtil.isNullOrEmpty(cmd)) return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); - String imei = (String)paramMap.get("IMEI"); + String imei = (String)paramMap.get(KwBoxService.PREFIX_IMEI); if (StringUtil.isNullOrEmpty(imei)) return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); - String ccid = (String)paramMap.get("CCID"); + String ccid = (String)paramMap.get(KwBoxService.PREFIX_ICCID); if (StringUtil.isNullOrEmpty(ccid)) return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); - String time = (String)paramMap.get("TIME"); + String time = (String)paramMap.get(KwBoxService.PREFIX_TIME); if (StringUtil.isNullOrEmpty(time)) return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); @@ -206,11 +197,11 @@ public class KwBoxV1Controller extends BaseController { switch(cmd) { - case "regist": + case KwBoxService.CMD_REGISTER: return cmdRegist(imei,ccid,deviceTime,paramMap); - case "login": + case KwBoxService.CMD_LOGIN: return cmdLogin(imei,ccid,deviceTime,paramMap); - case "hb": + case KwBoxService.CMD_HEARTBEAT: return cmdHb(imei,ccid,deviceTime,paramMap); } diff --git a/mallinkService/src/main/java/com/iformall/service/kw/KwBoxService.java b/mallinkService/src/main/java/com/iformall/service/kw/KwBoxService.java index 062a28e5e..6d970d5cf 100644 --- a/mallinkService/src/main/java/com/iformall/service/kw/KwBoxService.java +++ b/mallinkService/src/main/java/com/iformall/service/kw/KwBoxService.java @@ -10,9 +10,27 @@ import com.iformall.domain.po.KwMeterData; import java.util.Date; import java.util.List; +import java.util.Map; public interface KwBoxService { + final static String PREFIX_CMD = "CMD"; + final static String CMD_REGISTER = "regist"; + final static String CMD_LOGIN = "login"; + final static String CMD_HEARTBEAT = "hb"; + + final static String PREFIX_IMEI = "IMEI"; + final static String PREFIX_ICCID = "CCID"; + final static String PREFIX_TIME = "TIME"; + final static String PREFIX_HW_VERSION = "HWV"; + final static String PREFIX_FW_VERSION = "FWV"; + final static String PREFIX_COM_KEY = "comKey"; + final static String PREFIX_SYS_STATUS = "sysStatus"; + final static String PREFIX_CONFIG = "config"; + final static String PREFIX_METERS = "meters"; + + final static String METER_ADDRESS = "addr"; + final static String METER_ACTIVE_POWER = "ap"; /** @@ -60,9 +78,9 @@ public interface KwBoxService { List findMetersAddress(KwBox record); List findMeters(KwBox record); - KwMeter findMeter(KwBox record, String addr); + KwMeter findMeter(KwBox record, String addr); KwBox findByImei(String imei); - KwMeterData saveMeterData(KwBox record, Date deviceTime, String addr, String activePower); + KwMeterData saveMeterData(KwBox record, List> metersData, Date deviceTime); } \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/service/kw/KwMeterDataService.java b/mallinkService/src/main/java/com/iformall/service/kw/KwMeterDataService.java index ba2b9d1ef..095995e11 100644 --- a/mallinkService/src/main/java/com/iformall/service/kw/KwMeterDataService.java +++ b/mallinkService/src/main/java/com/iformall/service/kw/KwMeterDataService.java @@ -17,5 +17,5 @@ public interface KwMeterDataService { List findList(KwMeterData kwMeterData); - int save(KwMeterData record); + int save(List recordList); } \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java index 590a0c102..502ca5c56 100644 --- a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java @@ -24,6 +24,7 @@ import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.Map; import java.util.stream.Collectors; @@ -40,6 +41,7 @@ public class KwBoxServiceImpl implements KwBoxService { @Autowired KwMeterService kwMeterService; + @Override public PageInfo listAsPage(KwBox record, Integer pageIndex, Integer pageSize) { return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> kwBoxMapper.findList(record)); @@ -89,42 +91,54 @@ public class KwBoxServiceImpl implements KwBoxService { } @Override - public KwMeterData saveMeterData(KwBox kwBox, Date deviceTime, String addr, String activePower){ - - KwMeter kwMeter = findMeter(kwBox, addr); - - if (kwMeter==null) return null; + public KwMeterData saveMeterData(KwBox kwBox, List> metersData, Date deviceTime){ - KwMeterData kwMeterData = new KwMeterData(); - kwMeterData.setTenantId(kwBox.getTenantId()); - kwMeterData.setAddress(addr); - kwMeterData.setBoxId(kwBox.getId()); - kwMeterData.setCreateTime(new Date()); - kwMeterData.setDeviceTime(deviceTime); - kwMeterData.setMeterId(kwMeter.getId()); - if (!StringUtil.isNullOrEmpty(activePower)) { - kwMeterData.setTotalPower(Integer.parseInt(activePower)); - } + if (!metersData.isEmpty()) { - if (kwMeterData.getTotalPower() != null) { - - KwMeterData record = new KwMeterData(); - record.setBoxId(kwBox.getId()); - record.setMeterId(kwMeter.getId()); - record.setTotalPower(0); //set in sql not null - record.setSortColumns(KwMeterData.Field.DeviceTime_DESC); - PageInfo kwMeterDataPage = kwMeterDataService.listAsPage(record,1,1); - - if (kwMeterDataPage.getList().size() > 0) { - kwMeterData.setUsedPower( - kwMeterData.getTotalPower()-kwMeterDataPage.getList().get(0).getTotalPower()); - kwMeterData.setLastDeviceTime(kwMeterDataPage.getList().get(0).getDeviceTime()); - kwMeterData.setLastTotalPower(kwMeterDataPage.getList().get(0).getTotalPower()); - } + List kwMeterDataList = new ArrayList<>(); + Date recordTime = new Date(); + final IdWorker idWorker = IdWorker.get(); + metersData.stream().forEach(m->{ + String addr = m.get(KwBoxService.METER_ADDRESS); + String activePower = m.get(KwBoxService.METER_ACTIVE_POWER); //active power + + KwMeter kwMeter = findMeter(kwBox, addr); + if (kwMeter==null) return; + KwMeterData kwMeterData = new KwMeterData(); + + kwMeterData.setId(idWorker.nextId()); + kwMeterData.setTenantId(kwBox.getTenantId()); + kwMeterData.setAddress(addr); + kwMeterData.setBoxId(kwBox.getId()); + kwMeterData.setCreateTime(recordTime); + kwMeterData.setDeviceTime(deviceTime); + kwMeterData.setMeterId(kwMeter.getId()); + if (!StringUtil.isNullOrEmpty(activePower)) { + kwMeterData.setTotalPower(Integer.parseInt(activePower)); + } + + if (kwMeterData.getTotalPower() != null) { + KwMeterData record = new KwMeterData(); + record.setBoxId(kwBox.getId()); + record.setMeterId(kwMeter.getId()); + record.setTotalPower(0); //set in sql not null + record.setSortColumns(KwMeterData.Field.DeviceTime_DESC); + PageInfo kwMeterDataPage = kwMeterDataService.listAsPage(record,1,1); + + if (kwMeterDataPage.getList().size() > 0) { + kwMeterData.setUsedPower( + kwMeterData.getTotalPower()-kwMeterDataPage.getList().get(0).getTotalPower()); + kwMeterData.setLastDeviceTime(kwMeterDataPage.getList().get(0).getDeviceTime()); + kwMeterData.setLastTotalPower(kwMeterDataPage.getList().get(0).getTotalPower()); + } + } + kwMeterDataList.add(kwMeterData); + }); + + kwMeterDataService.save(kwMeterDataList); } - kwMeterDataService.save(kwMeterData); - return kwMeterData; + return null; } @Override diff --git a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMeterDataServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMeterDataServiceImpl.java index f83758b80..6aa024509 100644 --- a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMeterDataServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMeterDataServiceImpl.java @@ -45,10 +45,8 @@ public class KwMeterDataServiceImpl implements KwMeterDataService { } @Override - public int save(KwMeterData record) { - final IdWorker idWorker = IdWorker.get(); - record.setId(idWorker.nextId()); - return kwMeterDataMapper.insertSelective(record); + public int save(List recordList) { + return kwMeterDataMapper.insertList(recordList); } } From 86ba829d6739e2179fdfd1c966eff6d995d11a90 Mon Sep 17 00:00:00 2001 From: hupeng Date: Thu, 20 Jun 2019 18:11:08 +0800 Subject: [PATCH 6/8] =?UTF-8?q?[=E7=94=B5=E8=A1=A8][=E6=96=B0=E5=A2=9E]:?= =?UTF-8?q?=E7=94=B5=E8=A1=A8=E7=BB=91=E5=AE=9A=E5=95=86=E6=88=B7=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../device/KwMerchantMeterController.java | 64 +++++++++++++++++++ .../com/iformall/domain/po/KwMeterData.java | 2 +- .../service/kw/KwMerchantMeterService.java | 57 +++++++++++++++++ .../kw/impl/KwMerchantMeterServiceImpl.java | 60 +++++++++++++++++ 4 files changed, 182 insertions(+), 1 deletion(-) create mode 100644 mallinkAdmin/src/main/java/com/iformall/controller/device/KwMerchantMeterController.java create mode 100644 mallinkService/src/main/java/com/iformall/service/kw/KwMerchantMeterService.java create mode 100644 mallinkService/src/main/java/com/iformall/service/kw/impl/KwMerchantMeterServiceImpl.java diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/device/KwMerchantMeterController.java b/mallinkAdmin/src/main/java/com/iformall/controller/device/KwMerchantMeterController.java new file mode 100644 index 000000000..3e0a1a856 --- /dev/null +++ b/mallinkAdmin/src/main/java/com/iformall/controller/device/KwMerchantMeterController.java @@ -0,0 +1,64 @@ +package com.iformall.controller.device; + +import com.iformall.annotation.SystemControllerLog; +import com.iformall.common.ErrorCode; +import com.iformall.common.Result; +import com.iformall.common.ResultData; +import com.iformall.controller.base.BaseController; + +import com.iformall.domain.po.KwMerchantMeter; +import com.iformall.service.kw.KwMerchantMeterService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + + +@RestController +@RequestMapping("kwMerchantMeter") +@Api(description="电表设备") +public class KwMerchantMeterController extends BaseController { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private KwMerchantMeterService kwMerchantMeterService; + + + @ApiOperation("设备列表") + @GetMapping("list") + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageNum", value = "页数", dataType = "int", paramType = "query", required = true), + @ApiImplicitParam(name = "pageSize", value = "每页条数", dataType = "int", paramType = "query", required = true)}) + @SystemControllerLog(description = "电表设备-设备列表") + public Result list(@ModelAttribute KwMerchantMeter kwMerchantMeter, Integer pageNum, Integer pageSize) { + if (kwMerchantMeter == null) kwMerchantMeter = new KwMerchantMeter(); + + return new ResultData(); + } + + @ApiOperation("绑定设备") + @PostMapping("bind") + @SystemControllerLog(description = "电表设备-绑定设备") + public Result bind(@RequestBody KwMerchantMeter kwMerchantMeter) { + + if (kwMerchantMeter == null) + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); + + return new ResultData(); + } + + @ApiOperation("解绑定设备") + @PostMapping("unbind") + @SystemControllerLog(description = "电表设备-解绑定设备") + public Result unbind(@RequestBody KwMerchantMeter kwMerchantMeter) { + + if (kwMerchantMeter == null) + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); + + return new ResultData(); + } +} diff --git a/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java b/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java index 4e0151bc6..a0c6213f2 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java @@ -19,7 +19,7 @@ import java.util.List; @ToString(callSuper = true) @EqualsAndHashCode(callSuper = true) public class KwMeterData extends BaseEntity { - @Id + protected Long id; @Transient protected List ids; diff --git a/mallinkService/src/main/java/com/iformall/service/kw/KwMerchantMeterService.java b/mallinkService/src/main/java/com/iformall/service/kw/KwMerchantMeterService.java new file mode 100644 index 000000000..3f0c03138 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/service/kw/KwMerchantMeterService.java @@ -0,0 +1,57 @@ +package com.iformall.service.kw; + + +import com.github.pagehelper.PageInfo; +import com.iformall.common.ResultData; +import com.iformall.domain.po.KwMerchantMeter; + + +import java.util.List; + +public interface KwMerchantMeterService { + + /** + * 根据实体查询分页列表 + * + * @param record + * @param pageIndex + * @param pageSize + * @return + */ + PageInfo listAsPage(KwMerchantMeter record, Integer pageIndex, Integer pageSize); + + + /** + * 根据Id获得实体 + * + * @param id + * @return + */ + KwMerchantMeter getById(Long id); + + /** + * 保存或更新实体 + * + * @param record + */ + ResultData saveOrUpdate(KwMerchantMeter record); + + + /** + * 根据Id删除实体 + * + * @param id + */ + void deleteById(Long id); + + + /** + * 根据实体查询分页列表 + * + * @param record + * @return + */ + List findList(KwMerchantMeter record); + + +} \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMerchantMeterServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMerchantMeterServiceImpl.java new file mode 100644 index 000000000..1dd3c5d58 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwMerchantMeterServiceImpl.java @@ -0,0 +1,60 @@ +package com.iformall.service.kw.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.iformall.common.IdWorker; +import com.iformall.common.ResultData; +import com.iformall.domain.po.KwMerchantMeter; +import com.iformall.mapper.KwMerchantMeterMapper; +import com.iformall.service.kw.KwMerchantMeterService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + + +@Service +public class KwMerchantMeterServiceImpl implements KwMerchantMeterService { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + KwMerchantMeterMapper kwMerchantMeterMapper; + + @Override + public PageInfo listAsPage(KwMerchantMeter record, Integer pageIndex, Integer pageSize) { + return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> kwMerchantMeterMapper.findList(record)); + } + + @Override + public KwMerchantMeter getById(Long id) { + return kwMerchantMeterMapper.selectByPrimaryKey(id); + } + + + @Override + public ResultData saveOrUpdate(KwMerchantMeter record) { + if (record.getId() == null) { + final IdWorker idWorker = IdWorker.get(); + record.setId(idWorker.nextId()); + kwMerchantMeterMapper.insertSelective(record); + } else { + kwMerchantMeterMapper.updateByPrimaryKeySelective(record); + } + return new ResultData(); + } + + + @Override + public void deleteById(Long id) { + kwMerchantMeterMapper.deleteByPrimaryKey(id); + } + + @Override + public List findList(KwMerchantMeter record) { + return kwMerchantMeterMapper.findList(record); + } + + +} From c6aca5a753f4b1616baa461a7845e5672694dcf1 Mon Sep 17 00:00:00 2001 From: hupeng Date: Thu, 20 Jun 2019 18:15:11 +0800 Subject: [PATCH 7/8] =?UTF-8?q?[=E7=94=B5=E8=A1=A8][=E4=BF=AE=E5=A4=8D]:?= =?UTF-8?q?=E8=A7=A3=E5=86=B3=E6=89=B9=E9=87=8F=E6=8F=92=E5=85=A5=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/iformall/domain/po/KwMeterData.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java b/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java index a0c6213f2..ed956ceae 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/KwMeterData.java @@ -21,6 +21,10 @@ import java.util.List; public class KwMeterData extends BaseEntity { protected Long id; + + @Id + protected Long fake_id; + @Transient protected List ids; @Transient From 0d6941e9ba9e380f6ba90057ffc6351c75293aa3 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Thu, 20 Jun 2019 18:24:07 +0800 Subject: [PATCH 8/8] =?UTF-8?q?[BUG][=E4=BF=AE=E6=94=B9][=E5=95=86?= =?UTF-8?q?=E9=93=BA=E7=A7=9F=E8=B5=81=E5=90=88=E5=90=8C=20--=20=20?= =?UTF-8?q?=E8=B4=A6=E5=8D=95=E9=87=91=E9=A2=9D=E5=9C=A8=E6=8C=89=E5=9B=BA?= =?UTF-8?q?=E5=AE=9A=E9=87=91=E9=A2=9D=E9=80=92=E5=A2=9E=E5=90=8E=E3=80=82?= =?UTF-8?q?=20=E6=B2=A1=E6=9C=89=E5=8F=98=E5=8C=96]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/service/impl/WxRentContractServiceImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java index 6402698eb..5438f2d60 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxRentContractServiceImpl.java @@ -835,6 +835,7 @@ public class WxRentContractServiceImpl implements WxRentContractService { long[] priceArrs = null; List> shopInfos = new ArrayList<>(); if (wxRentContract.getRentShopType().equals(EnumRentShopType.SHOP.getCode()) && + wxRentContract.getRentInputWay().equals(EnumRentContractRentInputWay.PART.getCode()) && !wxRentContract.getType().equals(EnumRentContractType.RENT_BY_JOINT.getCode())) { String rentInfo = wxRentContract.getRentInfo(); JSONArray rentInfoArray = JSONArray.parseArray(rentInfo);