联动值充值
__KWBHssgPtqkxvqhTKlW
__KWBHssgPtqkxvqhTKlW
published
UTF-8
post
/dispatch/recharge
json
0){
var process = getDocumentProcess();
var formProcess = getFormProcess();
var deviceFromid="__Zq1ilPC4pdVmDthTXKN";
var deviceSubform = formProcess.doView(deviceFromid);
var deviceDetail = process.doNew(deviceSubform, getWebUser(), createParamsTable());
deviceDetail.findItem("name").setValue(productName);
deviceDetail.findItem("product_pk_id").setValue(productId);
var prefix = 3 + format(getToday(), "yyyyMMddHHmmss");
var val = countNext2(prefix, false, false, false, 4);
var code = getLastCount(prefix);
if (code <= 0) {
val = countNext2(prefix, false, false, false, 4);
} else {
val = getLastCount2(prefix, false, false, false, 4); //自动编号的最后编号
}
deviceDetail.findItem("number").setValue(val);
deviceDetail.findItem("device_type").setValue("0");
deviceDetail.findItem("status").setValue(0);
deviceDetail.findItem("model").setValue(productModel);
deviceDetail.findItem("begin_time").setValue(begin_time);
deviceDetail.findItem("end_time").setValue(end_time);
deviceDetail.findItem("domain_name").setValue(domain_name);
deviceDetail.findItem("domain_id").setValue(domainid);
deviceDetail.findItem("product_category").setValue("00001");
deviceDetail.findItem("reference_number").setValue(reference_number);
var prefix = 4 + format(getToday(), "yyyyMMddHHmmss");
var val = countNext2(prefix, false, false, false, 4);
var code = getLastCount(prefix);
if (code <= 0) {
val = countNext2(prefix, false, false, false, 4);
} else {
val = getLastCount2(prefix, false, false, false, 4); //自动编号的最后编号
}
deviceDetail.findItem("pk_id").setValue(val);
deviceDetail.setDomainid(domainid)
process.doCreate(deviceDetail);
result.put("deviceMsg"+f,"设备生成成功，设备id:" + deviceDetail.getId());
}
}
commitTransaction("dispatch");
}else if("00002".equals(product_category)){
var domainid = jsoni["domainid"];
var domain_name = jsoni["domain_name"];
var sumQuantity = jsoni["sumQuantity"];
var sumMoney = jsoni["sumMoney"];//总价
var reference_number = jsoni["reference_number"];//流水号
var operatorName = jsoni["operatorName"];//操作人
var operatorId = jsoni["operatorId"];//操作人名称
if("undefined".equals(domainid)||"undefined".equals(domain_name)||"undefined".equals(sumQuantity)||"undefined".equals(sumMoney)||"undefined".equals(reference_number)||"undefined".equals(operatorName)||"undefined".equals(operatorId)){
sss=联动值缺少参数
}
var process = getDocumentProcess();
var formProcess = getFormProcess();
var onlysql3="select 1 from tlk_org_purse_transaction where item_reference_number='"+reference_number+"'"
var onlydatas3 = queryByDSName("dispatch", onlysql3);
if(!onlydatas3.size()>0){
var domainsql = "select id from tlk_org_purse where item_organization_id='" + domainid + "'"
var datas = queryByDSName("dispatch", domainsql);
var orgPurseId =""
if(datas.size()>0){
for(var iterator = datas.iterator();iterator.hasNext();){
var map1 = iterator.next();//取值
orgPurseId= map1.get("id");
}
}
if (isNotNull(orgPurseId)) {
//联动值充值记录
var transactionfromid="__Mo4BefvUBDNi4DtP4TW";
var process = getDocumentProcess();
var formProcess = getFormProcess();
var transactionSubform = formProcess.doView(transactionfromid);
var transactionDoc = process.doNew(transactionSubform, getWebUser(), createParamsTable());
var prefix = 7+format(getToday(),"yyyyMMddHHmmss");
var val = countNext2(prefix,false,false,false,4);
var code = getLastCount(prefix);
if(code<=0){
val=countNext2(prefix,false,false,false,4);
}else{
val =getLastCount2(prefix,false,false,false,4); //自动编号的最后编号
}
transactionDoc.findItem("pk_id").setValue(val);
transactionDoc.findItem("organization_name").setValue(domain_name);
transactionDoc.findItem("organization_id").setValue(domainid);
transactionDoc.findItem("points").setValue(sumQuantity);
transactionDoc.findItem("type").setValue(0);
transactionDoc.findItem("price").setValue(sumMoney);
transactionDoc.findItem("reference_number").setValue(reference_number);
transactionDoc.findItem("created_time").setValue(getToday());
transactionDoc.findItem("operatorName").setValue(operatorName);
transactionDoc.findItem("operatorId").setValue(operatorId);
transactionDoc.setDomainid(domainid)
process.doCreate(transactionDoc);
result.put("recordMsg", "保存成功,记录id："+transactionDoc.getId());
//更新联动值
var orgPurseDoc = findDocument(orgPurseId);
var nowpoints = orgPurseDoc.findItem("points").getValue()
var resuiltpoint=parseDouble(sumQuantity)+parseDouble(nowpoints)
orgPurseDoc.findItem("points").setValue(parseDouble(resuiltpoint));
process.doUpdate(orgPurseDoc);
result.put("msg"+i, domain_name + "已充值" + sumQuantity + "联动值，当前联动值余额:" + orgPurseDoc.findItem("points").getValue());
} else {
//联动值充值记录
var transactionfromid="__Mo4BefvUBDNi4DtP4TW";
var process = getDocumentProcess();
var formProcess = getFormProcess();
var transactionSubform = formProcess.doView(transactionfromid);
var transactionDoc = process.doNew(transactionSubform, getWebUser(), createParamsTable());
var prefix = 7+format(getToday(),"yyyyMMddHHmmss");
var val = countNext2(prefix,false,false,false,4);
var code = getLastCount(prefix);
if(code<=0){
val=countNext2(prefix,false,false,false,4);
}else{
val =getLastCount2(prefix,false,false,false,4); //自动编号的最后编号
}
transactionDoc.findItem("pk_id").setValue(val);
transactionDoc.findItem("organization_name").setValue(domain_name);
transactionDoc.findItem("organization_id").setValue(domainid);
transactionDoc.findItem("points").setValue(sumQuantity);
transactionDoc.findItem("type").setValue(0);
transactionDoc.findItem("price").setValue(sumMoney);
transactionDoc.findItem("reference_number").setValue(reference_number);
transactionDoc.findItem("created_time").setValue(getToday());
transactionDoc.findItem("operatorName").setValue(operatorName);
transactionDoc.findItem("operatorId").setValue(operatorId);
transactionDoc.setDomainid(domainid)
process.doCreate(transactionDoc);
result.put("recordMsg", "保存成功,记录id："+transactionDoc.getId());
//新建企业
var process = getDocumentProcess();
var formProcess = getFormProcess();
var orgPursefromid = "__2j5BUeDTuCNmAILwwyt";
var orgPurseSubform = formProcess.doView(orgPursefromid);
var orgPurseDoc = process.doNew(orgPurseSubform, getWebUser(), createParamsTable());
orgPurseDoc.findItem("points").setValue(sumQuantity);
var prefix = 6 + format(getToday(), "yyyyMMddHHmmss");
var val = countNext2(prefix, false, false, false, 4);
var code = getLastCount(prefix);
if (code <= 0) {
val = countNext2(prefix, false, false, false, 4);
} else {
val = getLastCount2(prefix, false, false, false, 4); //自动编号的最后编号
}
orgPurseDoc.findItem("pk_id").setValue(val);
orgPurseDoc.findItem("created_time").setValue(getToday());
orgPurseDoc.findItem("organization_name").setValue(domain_name);
orgPurseDoc.findItem("organization_id").setValue(domainid);
orgPurseDoc.setDomainid(domainid)
process.doCreate(orgPurseDoc);
result.put("rechargeMsg"+i, domain_name + "已充值" + sumQuantity + "联动值，当前联动值余额:" + orgPurseDoc.findItem("points").getValue());
}
//创建联动值过期记录
var detailfromid = "__CWfNjPymUa0nQBXoGDA";
var process = getDocumentProcess();
var formProcess = getFormProcess();
var detailSubform = formProcess.doView(detailfromid);
var detailDoc = process.doNew(detailSubform, getWebUser(), createParamsTable());
detailDoc.findItem("created_time").setValue(getToday());
detailDoc.findItem("organization_name").setValue(domain_name);
detailDoc.findItem("organization_id").setValue(domainid);
detailDoc.findItem("points").setValue(sumQuantity);
detailDoc.findItem("residue_points").setValue(sumQuantity);
detailDoc.findItem("expiration_time").setValue(adjustYear(getToday(),1));
detailDoc.findItem("transaction_id").setValue(transactionDoc.getId());
process.doCreate(detailDoc);
//创建联动值累计等级
var levelsql="select id from tlk_org_purse_level where item_organization_id='" + domainid + "' and DATE_FORMAT(item_validity_time,'%Y-%m-%d')>='"+format(getToday(),"yyyy-MM-dd")+"' ";
var leveldatas = queryByDSName("dispatch", levelsql);
var levelId =""
if(leveldatas.size()>0){
for(var leveliterator = leveldatas.iterator();leveliterator.hasNext();){
var levelmap1 = leveliterator.next();//取值
levelId= levelmap1.get("id");
}
}
if (isNotNull(levelId)) {
//更新联动值总额
var process = getDocumentProcess();
var levelDoc = findDocument(levelId);
var nowpoints = levelDoc.findItem("sum_points").getValue()
var nowprice = levelDoc.findItem("sum_price").getValue()
var resuiltpoint=parseDouble(sumQuantity)+parseDouble(nowpoints)
var resuiltprice=parseDouble(sumMoney)+parseDouble(nowprice)
levelDoc.findItem("sum_points").setValue(parseDouble(resuiltpoint));
levelDoc.findItem("sum_price").setValue(parseDouble(resuiltprice));
levelDoc.findItem("validity_time").setValue(adjustYear(getToday(),1));
process.doUpdate(levelDoc);
}else{
var levelfromid = "__D0TzrAJTTNyOGJnvm3Q";
var levelSubform = formProcess.doView(levelfromid);
var levelDoc = process.doNew(levelSubform, getWebUser(), createParamsTable());
levelDoc.findItem("created_time").setValue(getToday());
levelDoc.findItem("organization_name").setValue(domain_name);
levelDoc.findItem("organization_id").setValue(domainid);
levelDoc.findItem("sum_points").setValue(sumQuantity);
levelDoc.findItem("sum_price").setValue(sumMoney);
levelDoc.findItem("validity_time").setValue(adjustYear(getToday(),1));
process.doCreate(levelDoc);
}
result.put("msglevel","等级保存成功："+levelDoc.getId())
var updevice="update tlk_device set item_end_time='"+format(adjustYear(getToday(),1),"yyyy-MM-dd HH:mm:ss")+"' where item_domain_id='"+domainid+"' and item_product_category='00003' "
result.put("updevice",updevice)
updateByDSName("dispatch",updevice);
}
commitTransaction("dispatch");
}else if("00003".equals(product_category)){
var quantity = parseInt(jsoni["quantity"]);//数量
for (var f = 0; f < quantity; f++) {
var productName = jsoni["productName"];//设备名称
var productId = jsoni["productId"];//设备id
var productModel = jsoni["productModel"];//设备型号
var begin_time = jsoni["begin_time"];//设备开始时间
var end_time = jsoni["end_time"];//设备结束时间
var domainid = jsoni["domainid"];
var domain_name = jsoni["domain_name"];
var reference_number = jsoni["reference_number"]+f;//流水号
if("undefined".equals(domainid)||"undefined".equals(domain_name)||"undefined".equals(productName)||"undefined".equals(productId)||"undefined".equals(productModel)||"undefined".equals(begin_time)||"undefined".equals(end_time)||"undefined".equals(reference_number)){
ss=调度台缺少参数+aaa
}
var onlysql2="select 1 from tlk_device where item_reference_number='"+reference_number+"'"
var onlydatas2 = queryByDSName("dispatch", onlysql2);
if(!onlydatas2.size()>0){
var process = getDocumentProcess();
var formProcess = getFormProcess();
var deviceFromid="__Zq1ilPC4pdVmDthTXKN";
var deviceSubform = formProcess.doView(deviceFromid);
var deviceDetail = process.doNew(deviceSubform, getWebUser(), createParamsTable());
deviceDetail.findItem("name").setValue(productName);
deviceDetail.findItem("product_pk_id").setValue(productId);
deviceDetail.findItem("reference_number").setValue(reference_number);
var prefix = 10+format(getToday(),"yyyyMMddHHmmss");
var val = countNext2(prefix,false,false,false,4);
var code = getLastCount(prefix);
if(code<=0){
val=countNext2(prefix,false,false,false,4);
}else{
val =getLastCount2(prefix,false,false,false,4); //自动编号的最后编号
}
deviceDetail.findItem("number").setValue(val);
deviceDetail.findItem("status").setValue(0);
deviceDetail.findItem("device_type").setValue(0);
deviceDetail.findItem("model").setValue(productModel);
deviceDetail.findItem("begin_time").setValue(begin_time);
deviceDetail.findItem("end_time").setValue(end_time);
deviceDetail.findItem("domain_name").setValue(domain_name);
deviceDetail.findItem("domain_id").setValue(domainid);
deviceDetail.findItem("product_category").setValue("00003");
var prefix = 10+format(getToday(),"yyyyMMddHHmmss");
var val = countNext2(prefix,false,false,false,4);
var code = getLastCount(prefix);
if(code<=0){
val=countNext2(prefix,false,false,false,4);
}else{
val =getLastCount2(prefix,false,false,false,4); //自动编号的最后编号
}
deviceDetail.findItem("pk_id").setValue(val+i);
deviceDetail.setDomainid(domainid)
process.doCreate(deviceDetail);
result.put("dispatchMsg"+f,"调度台生成成功，调度台id:" + deviceDetail.getId());
var devicePKId=deviceDetail.findItem("pk_id").getValue()
//创建授权记录
var recordFormId="__ob549Je9eBBUuFQUDYe";
var recordform = formProcess.doView(recordFormId);
var record = process.doNew(recordform, getWebUser(), createParamsTable());
record.findItem("deviceId").setValue(deviceDetail.getId());
record.findItem("operator").setValue(domain_name);
record.findItem("time").setValue(getToday());
record.findItem("content").setValue(format(getToday(),"yyyy-MM-dd HH:mm:ss")+"给账号授权");
record.findItem("operation_type").setValue(0);
record.setDomainid(domainid)
process.doCreate(record);
//创建ip记录
var ipfromid="__cB4XfVMvUfMuPjJHtSm";
var process = getDocumentProcess();
var formProcess = getFormProcess();
var ipSubform = formProcess.doView(ipfromid);
var ipdoc = process.doNew(ipSubform, getWebUser(), createParamsTable());
ipdoc.findItem("devicePKId").setValue(devicePKId);
ipdoc.findItem("type").setValue("");
ipdoc.findItem("ip").setValue("");
ipdoc.findItem("domain_id").setValue(domainid);
ipdoc.findItem("domain_name").setValue(domain_name);
ipdoc.findItem("last_updated_time").setValue(getToday());
ipdoc.findItem("last_updator_id").setValue(domainid);
ipdoc.findItem("last_updator_name").setValue(domain_name);
var prefix = 8+format(getToday(),"yyyyMMddHHmmss");
var val = countNext2(prefix,false,false,false,4);
var code = getLastCount(prefix);
if(code<=0){
val=countNext2(prefix,false,false,false,4);
}else{
val =getLastCount2(prefix,false,false,false,4); //自动编号的最后编号
}
ipdoc.findItem("pk_id").setValue(val);
ipdoc.setDomainid(domainid)
process.doCreate(ipdoc);
var ipPKId=ipdoc.findItem("pk_id").getValue()
//创建调度范围记录
var dep1sql="select ITEM_INDEXCODE from organizationauth.tlk_departmentlevel where item_code ='"+domainid+"'"
var dedatas = queryByDSName("organizationAuth",dep1sql);
var index=""
if(dedatas.size()>0){
for(var deiterator = dedatas.iterator();deiterator.hasNext();){
var map2 = deiterator.next();//取值
index= map2.get("ITEM_INDEXCODE");
}
}
if(isNotNull(index)){
var dep2sql="select item_code,item_name from tlk_departmentlevel where ITEM_INDEXCODE like '"+index+"%'"
var de2datas = queryByDSName("organizationAuth",dep2sql);
if(de2datas.size()>0){
for(var de2iterator = de2datas.iterator();de2iterator.hasNext();){
var map3 = de2iterator.next();//取值
var code= map3.get("item_code");
var codeName=map3.get("item_name");
var scopefromid="__iQxg5AI6uWHs0BdKsPZ";
var process = getDocumentProcess();
var formProcess = getFormProcess();
var scopeSubform = formProcess.doView(scopefromid);
var scopedoc = process.doNew(scopeSubform, getWebUser(), createParamsTable());
scopedoc.findItem("type").setValue(0);
scopedoc.findItem("assigned_depart_id").setValue(code);
scopedoc.findItem("assigned_depart_name").setValue(codeName);
scopedoc.findItem("device_desk_pk_id").setValue(ipPKId);
scopedoc.findItem("device_pk_Id").setValue(devicePKId);
scopedoc.setDomainid(domainid)
process.doCreate(scopedoc);
}
}
}
}
}
commitTransaction("dispatch");
}else{
y=无此类型+sss
}
}
result.put("flag", 1);
return result;
}catch(err){
rollbackTransaction("dispatch");
var result = new Packages.java.util.HashMap(); //创建指定类对象
result.put("msg","失败！！"+err);
return result;
}
})()]]>