事务问题优化

java110

2020-12-31 6f0c47b1eac0c775bd3a935f7c7e41e2f5fe41ad

 service-order/src/main/java/com/java110/order/smo/impl/OIdServiceSMOImpl.java

@@ -227,6 +227,10 @@
                sql = sql.substring(0, sql.length() - 1);
            }

            if (sql.endsWith(whereSql)) { // 说明没有条件 不做回退 回退整个表是有问题的
                continue;
            }

            sql += whereSql;

            param.put("fallBackSql", sql);
@@ -249,8 +253,9 @@

        JSONObject logTextObj = JSONObject.parseObject(logText);
        JSONArray afterValues = logTextObj.getJSONArray("afterValue");
        String whereSql = " where 1=1 ";
        for (int preValueIndex = 0; preValueIndex < afterValues.size(); preValueIndex++) {
            sql = "delete from " + orderItemDto.getActionObj() + " where 1=1 ";
            sql = "delete from " + orderItemDto.getActionObj() + whereSql;
            param = new JSONObject();
            JSONObject keyValue = afterValues.getJSONObject(preValueIndex);
            if (keyValue.isEmpty()) {
@@ -261,7 +266,10 @@
                    sql += (" and " + key + "=" + keyValue.getString(key));
                }
            }
            sql +=" limit 1";//防止程序异常删除 尴尬 根据业务场景 没有需要删除多余 1条的场景
            if (sql.endsWith(whereSql)) { // 说明没有条件 不做回退 回退整个表是有问题的
                continue;
            }
            sql += " limit 1";//防止程序异常删除 尴尬 根据业务场景 没有需要删除多余 1条的场景
            param.put("fallBackSql", sql);
            params.add(param);
        }