当前博客：事务执行SQL语句_同步执行后马上查询插入的数据失败

66 次浏览【转载需注明来源】

收藏内容 (0) (0)

个性签名：寒窗苦读十年，一朝凤舞九天

代码运行调试的时候第一次执行操作可以的，后面都不行，每次点下调试都可以好一次，后面就报错了

局部变量 局_SQL = [];
        局部变量 返回提示文本信息;
        局部变量 销售单号 = 同步 生成单据编号("销售单号", 租户GUID);
        局部变量 局_GUID = 生成GUID();
        调试输出("add数据", 访问信息, 租户GUID, 销售单号);
        如果 (访问信息["表单对象"]["单据ID"] == "" || 访问信息["表单对象"]["单据ID"] == 未定义内容) {
            局_SQL.添加成员({ "sql": "insert into 销售单据表(GUID,公司GUID,所属公司,单据编号,单据类型,客户ID,客户名称,名称简拼,联系人,联系人简拼,手机,地址,备注信息,取货方式,单据金额,应收金额,优惠金额,已收金额,收款状态,删除状态,制单时间,制单人员) values ('" + 局_GUID + "','" + 租户GUID + "','" + 访问信息["cookie对象"]["company"] + "','" + 销售单号 + "','销售单据'," + 访问信息["表单对象"]["客户ID"] + ",'" + 访问信息["表单对象"]["客户名称"] + "','" + 拼音类.取拼音首拼(访问信息["表单对象"]["客户名称"]).替换所有(" ", "") + "','" + 访问信息["表单对象"]["联系人"] + "','" + 拼音类.取拼音首拼(访问信息["表单对象"]["联系人"]).替换所有(" ", "") + "','" + 访问信息["表单对象"]["联系电话"] + "','" + 访问信息["表单对象"]["客户地址"] + "','" + 访问信息["表单对象"]["备注信息"] + "','" + 访问信息["表单对象"]["取货方式"] + "'," + 访问信息["表单对象"]["单据金额"] + "," + 访问信息["表单对象"]["应收金额"] + "," + 访问信息["表单对象"]["优惠金额"] + "," + 访问信息["表单对象"]["已收金额"] + ",'未结完款','未删除',now(),'" + 访问信息["cookie对象"]["name"] + "')" });
            局_SQL.添加成员({ "sql": "insert into 日志信息表 (所属公司,公司GUID,产生时间,日志类型,日志详情,操作模块,姓名) values ('" + 访问信息["cookie对象"]["company"] + "','" + 租户GUID + "',now(),'操作单据','销售开单[" + 销售单号 + "]','商品销售模块','" + 访问信息["cookie对象"]["name"] + "')" });
            返回提示文本信息 = "添加";
        } 否则 {
            局_SQL.添加成员({ "sql": "update 销售单据表 set 客户ID=" + 访问信息["表单对象"]["客户ID"] + ",客户名称='" + 访问信息["表单对象"]["客户名称"] + "',名称简拼='" + 拼音类.取拼音首拼(访问信息["表单对象"]["客户名称"]).替换所有(" ", "") + "',联系人='" + 访问信息["表单对象"]["联系人"] + "',联系人简拼='" + 拼音类.取拼音首拼(访问信息["表单对象"]["联系人"]).替换所有(" ", "") + "',手机='" + 访问信息["表单对象"]["联系电话"] + "',地址='" + 访问信息["表单对象"]["客户地址"] + "',备注信息='" + 访问信息["表单对象"]["备注信息"] + "',取货方式='" + 访问信息["表单对象"]["取货方式"] + "',单据金额=" + 访问信息["表单对象"]["单据金额"] + ",应收金额=" + 访问信息["表单对象"]["应收金额"] + ",优惠金额=" + 访问信息["表单对象"]["优惠金额"] + ",已收金额=" + 访问信息["表单对象"]["已收金额"] + " where 公司GUID='" + 租户GUID + "' and ID=" + 访问信息["表单对象"]["单据ID"] });
            局_SQL.添加成员({ "sql": "insert into 日志信息表 (所属公司,公司GUID,产生时间,日志类型,日志详情,操作模块,姓名) values ('" + 访问信息["cookie对象"]["company"] + "','" + 租户GUID + "',now(),'操作单据','修改单据[" + 销售单号 + "]','商品销售模块','" + 访问信息["cookie对象"]["name"] + "')" });
            返回提示文本信息 = "修改";
        }
        局部变量 执行结果 = 同步 mysql客户端.事务执行SQL语句_同步(局_SQL);
        调试输出("ADD销售单据", 执行结果, 局_SQL);
        如果 (执行结果["状态"] == "失败") {
            如果 (执行结果["数据"]["code"] == "ER_DUP_ENTRY") {
                执行结果["状态"] = -1;
                执行结果["提示文本"] = "该订单已存在,请勿重复添加";
            } 否则 {
                执行结果["状态"] = -1;
                执行结果["提示文本"] = 返回提示文本信息 + "失败";
            }
        } 否则 {
            如果 (返回提示文本信息 == "添加") {
                局部变量 查询结果 = 同步 mysql客户端.查询SQL语句_同步("select ID,单据编号 from 销售单据表 where GUID='" + 局_GUID + "'");
                执行结果["单据ID"] = 查询结果["数据"][0]["ID"];
                执行结果["单据编号"] = 查询结果["数据"][0]["单据编号"];
            }
            执行结果["状态"] = 0;
            执行结果["提示文本"] = 返回提示文本信息 + "成功";
        }
        调试输出("操作单据", 执行结果);
        访问信息["主动发送"]({ "发送数据": JSON类.到可读JSON文本(执行结果), "数据协议": HTTP服务类.获取数据协议("json") });
    });