From 0f88d296baf59ab73daa08faaf29330b5e6a4270 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 24 八月 2022 08:33:42 +0800
Subject: [PATCH] Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity
---
service-community/src/main/java/com/java110/community/cmd/room/QueryRoomsCmd.java | 18 ++++
service-fee/src/main/java/com/java110/fee/cmd/fee/PayFeeCmd.java | 105 ++++++++++++++-----------
service-community/src/main/java/com/java110/community/cmd/.DS_Store | 0
service-fee/src/main/java/com/java110/fee/cmd/fee/SaveTempCarFeeConfigCmd.java | 9 +
service-fee/src/main/java/com/java110/fee/cmd/fee/UpdateTempCarFeeConfigCmd.java | 8 +
service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/AddTempCarFeeConfigToIotAdapt.java | 16 ++-
service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/ModifyTempCarFeeConfigToIotAdapt.java | 14 ++-
service-fee/src/main/java/com/java110/fee/cmd/fee/DeleteTempCarFeeConfigCmd.java | 2
service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/DeleteTempCarFeeConfigToIotAdapt.java | 17 ++-
9 files changed, 124 insertions(+), 65 deletions(-)
diff --git a/service-community/src/main/java/com/java110/community/cmd/.DS_Store b/service-community/src/main/java/com/java110/community/cmd/.DS_Store
new file mode 100644
index 0000000..3893dd1
--- /dev/null
+++ b/service-community/src/main/java/com/java110/community/cmd/.DS_Store
Binary files differ
diff --git a/service-community/src/main/java/com/java110/community/cmd/room/QueryRoomsCmd.java b/service-community/src/main/java/com/java110/community/cmd/room/QueryRoomsCmd.java
index 339310c..025d7c0 100644
--- a/service-community/src/main/java/com/java110/community/cmd/room/QueryRoomsCmd.java
+++ b/service-community/src/main/java/com/java110/community/cmd/room/QueryRoomsCmd.java
@@ -146,6 +146,24 @@
roomDto.setRoomNum("");
}
}
+
+ //add by wuxw 鍟嗛摵 涓や釜鐭嚎鏂瑰紡澶勭悊
+ if(reqJson.containsKey("roomType") && "2020602".equals(reqJson.getString("roomType"))){
+ if (reqJson.containsKey("roomNum") && !StringUtil.isEmpty(reqJson.getString("roomNum"))) {
+ String[] roomNums = reqJson.getString("roomNum").split("-", 2);
+ if (roomNums != null && roomNums.length == 2) {
+ roomDto.setFloorNum(roomNums[0]);
+ roomDto.setUnitNum("0");
+ roomDto.setRoomNum(roomNums[1]);
+ } else {
+ roomDto.setRoomNum(reqJson.getString("roomNum"));
+ }
+ } else {
+ roomDto.setUnitNum("");
+ roomDto.setFloorNum("");
+ roomDto.setRoomNum("");
+ }
+ }
ApiRoomVo apiRoomVo = new ApiRoomVo();
//鏌ヨ鎬昏褰曟暟
int total = roomInnerServiceSMOImpl.queryRoomsCount(roomDto);
diff --git a/service-fee/src/main/java/com/java110/fee/cmd/fee/DeleteTempCarFeeConfigCmd.java b/service-fee/src/main/java/com/java110/fee/cmd/fee/DeleteTempCarFeeConfigCmd.java
index e61df42..76766e7 100644
--- a/service-fee/src/main/java/com/java110/fee/cmd/fee/DeleteTempCarFeeConfigCmd.java
+++ b/service-fee/src/main/java/com/java110/fee/cmd/fee/DeleteTempCarFeeConfigCmd.java
@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
@@ -32,6 +33,7 @@
}
@Override
+ @Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
TempCarFeeConfigPo tempCarFeeConfigPo = BeanConvertUtil.covertBean(reqJson, TempCarFeeConfigPo.class);
int flag = tempCarFeeConfigV1InnerServiceSMOImpl.deleteTempCarFeeConfig(tempCarFeeConfigPo);
diff --git a/service-fee/src/main/java/com/java110/fee/cmd/fee/PayFeeCmd.java b/service-fee/src/main/java/com/java110/fee/cmd/fee/PayFeeCmd.java
index 2f602e1..8ab143a 100644
--- a/service-fee/src/main/java/com/java110/fee/cmd/fee/PayFeeCmd.java
+++ b/service-fee/src/main/java/com/java110/fee/cmd/fee/PayFeeCmd.java
@@ -165,18 +165,14 @@
//涓�娆℃�ц垂鐢� 鍜岄棿鎺ユ�ц垂鐢�
Date maxEndTime = feeDtos.get(0).getDeadlineTime();
//鍛ㄦ湡鎬ц垂鐢�
- if (FeeDto.FEE_FLAG_CYCLE.equals(feeConfigDtos.get(0).getFeeFlag())
- || FeeDto.FEE_FLAG_CYCLE_ONCE.equals(feeConfigDtos.get(0).getFeeFlag())
- || FeeDto.FEE_FLAG_ONCE.equals(feeConfigDtos.get(0).getFeeFlag())) {
- try {
- maxEndTime = DateUtil.getDateFromString(feeConfigDtos.get(0).getEndTime(), DateUtil.DATE_FORMATE_STRING_A);
- } catch (ParseException e) {
- } catch (Exception e) {
- logger.error("姣旇緝璐圭敤鏃ユ湡澶辫触", e);
- }
+ if (maxEndTime == null) {
+ maxEndTime = DateUtil.getDateFromStringA(feeConfigDtos.get(0).getEndTime());
+ }
+
+ if (maxEndTime != null && endTime != null) {
Date newDate = DateUtil.stepMonth(endTime, reqJson.getDouble("cycles").intValue());
if (newDate.getTime() > maxEndTime.getTime()) {
- throw new IllegalArgumentException("缂磋垂鍛ㄦ湡瓒呰繃 缂磋垂缁撴潫鏃堕棿");
+ throw new IllegalArgumentException("缂磋垂鍛ㄦ湡瓒呰繃 缂磋垂缁撴潫鏃堕棿,璇风敤鎸夌粨鏉熸椂闂存柟寮忕即璐�");
}
}
@@ -204,33 +200,7 @@
payFeePo = BeanConvertUtil.covertBean(fee, PayFeePo.class);
PayFeeDetailPo payFeeDetailPo = BeanConvertUtil.covertBean(feeDetail, PayFeeDetailPo.class);
//鍒ゆ柇鏄惁鏈夎禒閫佽鍒�
- if (paramObj.containsKey("selectDiscount")) {
- JSONArray selectDiscount = paramObj.getJSONArray("selectDiscount");
- if (selectDiscount != null && selectDiscount.size() > 0) {
- for (int index = 0; index < selectDiscount.size(); index++) {
- JSONObject paramJson = selectDiscount.getJSONObject(index);
- if (!StringUtil.isEmpty(paramJson.getString("ruleId")) && paramJson.getString("ruleId").equals("102020008")) { //璧犻�佽鍒�
- JSONArray feeDiscountSpecs = paramJson.getJSONArray("feeDiscountSpecs");
- if (feeDiscountSpecs.size() > 0) {
- for (int specIndex = 0; specIndex < feeDiscountSpecs.size(); specIndex++) {
- JSONObject paramIn = feeDiscountSpecs.getJSONObject(specIndex);
- if (!StringUtil.isEmpty(paramIn.getString("specId")) && paramIn.getString("specId").equals("89002020980015")) { //璧犻�佹湀浠�
- SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- String specValue = paramIn.getString("specValue");
- //鑾峰彇璐圭敤缁撴潫鏃堕棿(涔熷氨鏄笅娆¤垂鐢ㄥ紑濮嬫椂闂�)
- Date endTime = df.parse(payFeeDetailPo.getEndTime());
- Calendar cal = Calendar.getInstance();
- cal.setTime(endTime);
- cal.add(Calendar.MONTH, Integer.parseInt(specValue));
- payFeeDetailPo.setEndTime(df.format(cal.getTime()));
- payFeePo.setEndTime(df.format(cal.getTime()));
- }
- }
- }
- }
- }
- }
- }
+ hasDiscount(paramObj, payFeePo, payFeeDetailPo);
//鍒ゆ柇閫夋嫨鐨勮处鍙�
JSONArray jsonArray = paramObj.getJSONArray("selectUserAccount");
if (jsonArray == null || jsonArray.size() < 1) {
@@ -382,6 +352,49 @@
// }
cmdDataFlowContext.setResponseEntity(ResultVo.createResponseEntity(feeReceiptDetailDto));
+ }
+
+ /**
+ * 鏀归�犺禒閫侀�昏緫 if 宓屽鏈夌偣澶� 浼樺寲
+ * @param paramObj
+ * @param payFeePo
+ * @param payFeeDetailPo
+ * @throws ParseException
+ */
+ private void hasDiscount(JSONObject paramObj, PayFeePo payFeePo, PayFeeDetailPo payFeeDetailPo) throws ParseException {
+ if (!paramObj.containsKey("selectDiscount")) {
+ return;
+ }
+ JSONArray selectDiscount = paramObj.getJSONArray("selectDiscount");
+
+ if (selectDiscount == null || selectDiscount.size() < 1) {
+ return;
+ }
+ for (int index = 0; index < selectDiscount.size(); index++) {
+ JSONObject paramJson = selectDiscount.getJSONObject(index);
+ if (!"102020008".equals(paramJson.getString("ruleId"))) { //璧犻�佽鍒�
+ continue;
+ }
+ JSONArray feeDiscountSpecs = paramJson.getJSONArray("feeDiscountSpecs");
+ if (feeDiscountSpecs == null || feeDiscountSpecs.size() < 1) {
+ continue;
+ }
+ for (int specIndex = 0; specIndex < feeDiscountSpecs.size(); specIndex++) {
+ JSONObject paramIn = feeDiscountSpecs.getJSONObject(specIndex);
+ if (!"89002020980015".equals(paramIn.getString("specId"))) { //璧犻�佹湀浠�
+ continue;
+ }
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String specValue = paramIn.getString("specValue");
+ //鑾峰彇璐圭敤缁撴潫鏃堕棿(涔熷氨鏄笅娆¤垂鐢ㄥ紑濮嬫椂闂�)
+ Date endTime = df.parse(payFeeDetailPo.getEndTime());
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(endTime);
+ cal.add(Calendar.MONTH, Integer.parseInt(specValue));
+ payFeeDetailPo.setEndTime(df.format(cal.getTime()));
+ payFeePo.setEndTime(df.format(cal.getTime()));
+ }
+ }
}
/**
@@ -585,9 +598,9 @@
paramInJson.put("tmpCycles", cycles.doubleValue());
businessFeeDetail.put("cycles", cycles.doubleValue());
//澶勭悊 鍙兘杩樺瓨鍦� 瀹炴敹鎵嬪伐鍑忓厤鐨勬儏鍐�
- if(paramInJson.containsKey("receivableAmount") && !StringUtil.isEmpty(paramInJson.getString("receivableAmount"))){
+ if (paramInJson.containsKey("receivableAmount") && !StringUtil.isEmpty(paramInJson.getString("receivableAmount"))) {
businessFeeDetail.put("receivableAmount", paramInJson.getString("receivableAmount"));
- }else {
+ } else {
businessFeeDetail.put("receivableAmount", receivedAmount.doubleValue());
}
} else if ("-103".equals(paramInJson.getString("cycles"))) { //杩欓噷鎸夌即璐圭粨鏉熸椂闂寸即璐�
@@ -598,15 +611,15 @@
c.add(Calendar.DAY_OF_MONTH, 1);
endDates = c.getTime();//杩欐槸鏄庡ぉ
targetEndTime = endDates;
- BigDecimal receivedAmount1 = new BigDecimal(Double.parseDouble(paramInJson.getString("receivedAmount")));
+ BigDecimal receivedAmount1 = new BigDecimal(Double.parseDouble(paramInJson.getString("receivedAmount")));
cycles = receivedAmount1.divide(feePrice, 4, BigDecimal.ROUND_HALF_EVEN);
paramInJson.put("tmpCycles", cycles.doubleValue());
businessFeeDetail.put("cycles", cycles.doubleValue());
BigDecimal receivedAmount = new BigDecimal(Double.parseDouble(paramInJson.getString("receivedAmount")));
//澶勭悊 鍙兘杩樺瓨鍦� 瀹炴敹鎵嬪伐鍑忓厤鐨勬儏鍐�
- if(paramInJson.containsKey("receivableAmount") && !StringUtil.isEmpty(paramInJson.getString("receivableAmount"))){
+ if (paramInJson.containsKey("receivableAmount") && !StringUtil.isEmpty(paramInJson.getString("receivableAmount"))) {
businessFeeDetail.put("receivableAmount", paramInJson.getString("receivableAmount"));
- }else {
+ } else {
businessFeeDetail.put("receivableAmount", receivedAmount.doubleValue());
}
} else {
@@ -617,8 +630,8 @@
//鍑虹閫掑闂澶勭悊
if (FeeConfigDto.COMPUTING_FORMULA_RANT_RATE.equals(feeDto.getComputingFormula())) {
- computeFeeSMOImpl.dealRentRateCycle(feeDto,cycles.doubleValue());
- if(feeDto.getOweFee()> 0){
+ computeFeeSMOImpl.dealRentRateCycle(feeDto, cycles.doubleValue());
+ if (feeDto.getOweFee() > 0) {
businessFeeDetail.put("receivableAmount", feeDto.getAmountOwed());
}
}
@@ -671,7 +684,7 @@
maxEndTime = feeInfo.getConfigEndTime();
}
- if(FeeDto.FEE_FLAG_CYCLE_ONCE.equals(feeInfo.getFeeFlag())){
+ if (FeeDto.FEE_FLAG_CYCLE_ONCE.equals(feeInfo.getFeeFlag())) {
maxEndTime = feeInfo.getMaxEndTime();
}
@@ -681,7 +694,7 @@
}
//鍒ゆ柇 缁撴潫鏃堕棿 鏄惁澶т簬 璐圭敤椤� 缁撴潫鏃堕棿锛岃繖閲� 瀹归敊涓�涓嬶紝濡傛灉 璐圭敤缁撴潫鏃堕棿澶т簬 璐圭敤椤圭粨鏉熸椂闂� 30澶� 璧版姤閿� 灞炰簬澶氱即璐�
- if(maxEndTime != null) {
+ if (maxEndTime != null) {
if (feeInfo.getEndTime().getTime() - maxEndTime.getTime() > 30 * 24 * 60 * 60 * 1000L) {
throw new IllegalArgumentException("缂磋垂瓒呰繃浜� 璐圭敤椤圭粨鏉熸椂闂�");
}
diff --git a/service-fee/src/main/java/com/java110/fee/cmd/fee/SaveTempCarFeeConfigCmd.java b/service-fee/src/main/java/com/java110/fee/cmd/fee/SaveTempCarFeeConfigCmd.java
index f82f08a..d64faf1 100644
--- a/service-fee/src/main/java/com/java110/fee/cmd/fee/SaveTempCarFeeConfigCmd.java
+++ b/service-fee/src/main/java/com/java110/fee/cmd/fee/SaveTempCarFeeConfigCmd.java
@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
@@ -60,16 +61,20 @@
}
@Override
+ @Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
reqJson.put("feeConfigId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_configId));
reqJson.put("configId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_configId));
TempCarFeeConfigPo tempCarFeeConfigPo = BeanConvertUtil.covertBean(reqJson, TempCarFeeConfigPo.class);
+
+ //澶勭悊鎴垮眿灞炴��
+ dealAttr(reqJson, context);
+
int flag = tempCarFeeConfigV1InnerServiceSMOImpl.saveTempCarFeeConfig(tempCarFeeConfigPo);
if (flag < 1) {
throw new CmdException("淇濆瓨涓存椂鏀惰垂澶辫触");
}
- //澶勭悊鎴垮眿灞炴��
- dealAttr(reqJson, context);
+
//琛ヨ垂鐢ㄩ」鏁版嵁
PayFeeConfigPo payFeeConfigPo = new PayFeeConfigPo();
diff --git a/service-fee/src/main/java/com/java110/fee/cmd/fee/UpdateTempCarFeeConfigCmd.java b/service-fee/src/main/java/com/java110/fee/cmd/fee/UpdateTempCarFeeConfigCmd.java
index 18c76f3..eba3e34 100644
--- a/service-fee/src/main/java/com/java110/fee/cmd/fee/UpdateTempCarFeeConfigCmd.java
+++ b/service-fee/src/main/java/com/java110/fee/cmd/fee/UpdateTempCarFeeConfigCmd.java
@@ -64,6 +64,8 @@
Assert.listOnlyOne(tempCarFeeConfigDtos, "涓存椂杞︽敹璐规爣鍑嗕笉瀛樺湪");
TempCarFeeConfigPo tempCarFeeConfigPo = BeanConvertUtil.covertBean(reqJson, TempCarFeeConfigPo.class);
+ updateAttr(reqJson);
+
int flag = tempCarFeeConfigV1InnerServiceSMOImpl.updateTempCarFeeConfig(tempCarFeeConfigPo);
if (flag < 1) {
@@ -80,7 +82,11 @@
updateFeeConfig(BeanConvertUtil.beanCovertJson(payFeeConfigPo), context);
- JSONArray attrs = reqJson.getJSONArray("attrs");
+
+ }
+
+ private void updateAttr(JSONObject reqJson) {
+ int flag;JSONArray attrs = reqJson.getJSONArray("attrs");
if (attrs == null || attrs.size() < 1) {
return;
}
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/AddTempCarFeeConfigToIotAdapt.java b/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/AddTempCarFeeConfigToIotAdapt.java
index 073a71c..ce5a17d 100755
--- a/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/AddTempCarFeeConfigToIotAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/AddTempCarFeeConfigToIotAdapt.java
@@ -73,11 +73,11 @@
public void execute(Business business, List<Business> businesses) {
JSONObject data = business.getData();
+ JSONArray businessTempCarFeeConfigs = new JSONArray();
if (data.containsKey(TempCarFeeConfigPo.class.getSimpleName())) {
Object bObj = data.get(TempCarFeeConfigPo.class.getSimpleName());
- JSONArray businessTempCarFeeConfigs = null;
+
if (bObj instanceof JSONObject) {
- businessTempCarFeeConfigs = new JSONArray();
businessTempCarFeeConfigs.add(bObj);
} else if (bObj instanceof List) {
businessTempCarFeeConfigs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
@@ -85,11 +85,17 @@
businessTempCarFeeConfigs = (JSONArray) bObj;
}
//JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
- for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
- JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
- doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+
+ }else {
+ if (data instanceof JSONObject) {
+ businessTempCarFeeConfigs.add(data);
}
}
+
+ for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
+ JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
+ doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+ }
}
private void doSendTempCarFeeConfig(Business business, JSONObject businessTempCarFeeConfig) {
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/DeleteTempCarFeeConfigToIotAdapt.java b/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/DeleteTempCarFeeConfigToIotAdapt.java
index 9d23bcc..7872d54 100755
--- a/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/DeleteTempCarFeeConfigToIotAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/DeleteTempCarFeeConfigToIotAdapt.java
@@ -64,23 +64,28 @@
@Override
public void execute(Business business, List<Business> businesses) {
JSONObject data = business.getData();
+ JSONArray businessTempCarFeeConfigs = new JSONArray();
if (data.containsKey(TempCarFeeConfigPo.class.getSimpleName())) {
Object bObj = data.get(TempCarFeeConfigPo.class.getSimpleName());
- JSONArray businessTempCarFeeConfigs = null;
+
if (bObj instanceof JSONObject) {
- businessTempCarFeeConfigs = new JSONArray();
+
businessTempCarFeeConfigs.add(bObj);
} else if (bObj instanceof List) {
businessTempCarFeeConfigs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
} else {
businessTempCarFeeConfigs = (JSONArray) bObj;
}
- //JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
- for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
- JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
- doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+ }else {
+ if (data instanceof JSONObject) {
+ businessTempCarFeeConfigs.add(data);
}
}
+ //JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
+ for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
+ JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
+ doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+ }
}
private void doSendTempCarFeeConfig(Business business, JSONObject businessTempCarFeeConfig) {
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/ModifyTempCarFeeConfigToIotAdapt.java b/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/ModifyTempCarFeeConfigToIotAdapt.java
index 64feaa3..308a97d 100755
--- a/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/ModifyTempCarFeeConfigToIotAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/ModifyTempCarFeeConfigToIotAdapt.java
@@ -78,11 +78,10 @@
public void execute(Business business, List<Business> businesses) {
JSONObject data = business.getData();
+ JSONArray businessTempCarFeeConfigs = new JSONArray();
if (data.containsKey(TempCarFeeConfigPo.class.getSimpleName())) {
Object bObj = data.get(TempCarFeeConfigPo.class.getSimpleName());
- JSONArray businessTempCarFeeConfigs = null;
if (bObj instanceof JSONObject) {
- businessTempCarFeeConfigs = new JSONArray();
businessTempCarFeeConfigs.add(bObj);
} else if (bObj instanceof List) {
businessTempCarFeeConfigs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
@@ -90,11 +89,16 @@
businessTempCarFeeConfigs = (JSONArray) bObj;
}
//JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
- for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
- JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
- doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+
+ }else {
+ if (data instanceof JSONObject) {
+ businessTempCarFeeConfigs.add(data);
}
}
+ for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
+ JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
+ doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+ }
}
private void doSendTempCarFeeConfig(Business business, JSONObject businessTempCarFeeConfig) {
--
Gitblit v1.8.0