hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(service): 增加 U8C 销售订单取消签字功能 

- 新增取消签字功能，针对 2025-03-04 的销售出库单
- 优化了删除目标 U8C 数据的逻辑，增加了线程安全控制
- 修改了 sendU8C 方法，增加了执行耗时和条数的记录
- 更新了多个 API调用，增加了参数传递
This commit is contained in:
liuy 2025-03-04 11:03:05 +08:00
parent b6da932940
commit 33e273beb5
1 changed files with 34 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
service/src/main/java/com/hzya/frame/deletedata/DeleteU8cDataUtil.java
View File

@ -20,6 +20,7 @@ import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
@ -46,20 +47,32 @@ public class DeleteU8cDataUtil {
private static final Integer SPLIT_VAR = 1000; private static final Integer SPLIT_VAR = 1000;
private static Integer MARK = 0;
@PostConstruct
public void init() {
deleteTargetU8cData();
}
public void deleteTargetU8cData() { public void deleteTargetU8cData() {
Thread thread = new Thread(new Runnable() { Thread thread = new Thread(new Runnable() {
@Override @Override
public void run() { public void run() {
synchronized (LOCK_OBJECT) { synchronized (LOCK_OBJECT) {
if (MARK == 0) {
MARK = 1;
//删除销售发票 //删除销售发票
// deleteSoSaleinvoice(); // deleteSoSaleinvoice();
//删除销售出库单 //删除销售出库单
// deleteIcGeneralH(); // deleteIcGeneralH();
//删除销售订单 //删除销售订单
// deleteSoSale(); // deleteSoSale();
//取消签字销售出库单 已测试
cancelSignatureIcGeneralHV2("'0001A110000000001TH6', '0001A1100000000VKCOK'");
} }
} }
}, "删除U8C11月份TOC对应的销售发票、销售出库单、销售订单"); }
}, "U8C销售订单取消签字 2025-03-04");
thread.start(); thread.start();
} }
@ -93,7 +106,7 @@ public class DeleteU8cDataUtil {
jsonRootBeanCancelSignature.setApproveinfo(approveinfoCancelSignature); jsonRootBeanCancelSignature.setApproveinfo(approveinfoCancelSignature);
jsonRootBeanCancelSignature.setQueryinfo(queryinfoCancelSignature); jsonRootBeanCancelSignature.setQueryinfo(queryinfoCancelSignature);
sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleorder/unapprove", JSON.toJSONString(jsonRootBeanCancelSignature)); sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleorder/unapprove", JSON.toJSONString(jsonRootBeanCancelSignature), 1);
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -153,7 +166,7 @@ public class DeleteU8cDataUtil {
stringObjectMap3.put("approveinfo", stringObjectMap); stringObjectMap3.put("approveinfo", stringObjectMap);
stringObjectMap3.put("queryinfo", stringObjectMap2); stringObjectMap3.put("queryinfo", stringObjectMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleorder/unapprove", JSON.toJSONString(stringObjectMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleorder/unapprove", JSON.toJSONString(stringObjectMap3), vreceiptcodeList.size());
} }
} }
} }
@ -221,7 +234,7 @@ public class DeleteU8cDataUtil {
JsonRootBean jsonRootBean = new JsonRootBean(); JsonRootBean jsonRootBean = new JsonRootBean();
jsonRootBean.setDeleteInfo(deleteinfo); jsonRootBean.setDeleteInfo(deleteinfo);
jsonRootBean.setQueryInfo(queryinfo); jsonRootBean.setQueryInfo(queryinfo);
sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/delete", JSON.toJSONString(jsonRootBean)); sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/delete", JSON.toJSONString(jsonRootBean), 1);
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -274,7 +287,7 @@ public class DeleteU8cDataUtil {
Map<String, Object> objectMap3 = new HashMap<>(); Map<String, Object> objectMap3 = new HashMap<>();
objectMap3.put("deleteInfo", objectMap); objectMap3.put("deleteInfo", objectMap);
objectMap3.put("queryInfo", objectMap2); objectMap3.put("queryInfo", objectMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/delete", JSON.toJSONString(objectMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/delete", JSON.toJSONString(objectMap3), vbillcodeList.size());
} }
} }
} }
@ -309,7 +322,7 @@ public class DeleteU8cDataUtil {
JsonRootBean jsonRootBean = new JsonRootBean(); JsonRootBean jsonRootBean = new JsonRootBean();
jsonRootBean.setUnsignInfo(deleteinfo); jsonRootBean.setUnsignInfo(deleteinfo);
jsonRootBean.setQueryInfo(queryinfo); jsonRootBean.setQueryInfo(queryinfo);
sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/unsign", JSON.toJSONString(jsonRootBean)); sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/unsign", JSON.toJSONString(jsonRootBean), 1);
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -365,7 +378,8 @@ public class DeleteU8cDataUtil {
objectMap3.put("unsignInfo", objectMap1); objectMap3.put("unsignInfo", objectMap1);
objectMap3.put("queryInfo", objectMap2); objectMap3.put("queryInfo", objectMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/unsign", JSON.toJSONString(objectMap3)); // sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/unsign", JSON.toJSONString(objectMap3), vbillcodeList.size());
sendU8C("http://192.168.10.118:8088/u8cloud/api/ic/saleout/unsign", JSON.toJSONString(objectMap3), vbillcodeList.size());
} }
} }
} }
@ -413,7 +427,7 @@ public class DeleteU8cDataUtil {
objectMap3.put("signInfo", objectMap1); objectMap3.put("signInfo", objectMap1);
objectMap3.put("queryInfo", objectMap2); objectMap3.put("queryInfo", objectMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/sign", JSON.toJSONString(objectMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/ic/saleout/sign", JSON.toJSONString(objectMap3), vbillcodeList.size());
} }
} }
} }
@ -447,7 +461,7 @@ public class DeleteU8cDataUtil {
JsonRootBean jsonRootBean = new JsonRootBean(); JsonRootBean jsonRootBean = new JsonRootBean();
jsonRootBean.setDeleteinfo(deleteinfo); jsonRootBean.setDeleteinfo(deleteinfo);
jsonRootBean.setQueryinfo(queryinfo); jsonRootBean.setQueryinfo(queryinfo);
sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/delete", JSON.toJSONString(jsonRootBean)); sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/delete", JSON.toJSONString(jsonRootBean), 1);
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -502,7 +516,7 @@ public class DeleteU8cDataUtil {
objectMap3.put("deleteinfo", objectMap); objectMap3.put("deleteinfo", objectMap);
objectMap3.put("queryinfo", objectMap2); objectMap3.put("queryinfo", objectMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/delete", JSON.toJSONString(objectMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/delete", JSON.toJSONString(objectMap3), vreceiptcodeList.size());
} }
} }
} }
@ -517,14 +531,15 @@ public class DeleteU8cDataUtil {
* *
* @author liuyang * @author liuyang
*/ */
public void sendU8C(String url, String param) throws Exception { public void sendU8C(String url, String param, Integer number) throws Exception {
logger.info("入参：" + param); logger.info("入参：" + param);
long l = System.currentTimeMillis(); long l = System.currentTimeMillis();
String result = HttpRequest.post(url).header("usercode", "admin1").header("password", "f7fcde654e968541cc803c4b08c30abb").header("system", "lz1").header("trantype", "code").body(param)//表单内容 String result = HttpRequest.post(url).header("usercode", "admin1").header("password", "f7fcde654e968541cc803c4b08c30abb").header("system", "lz1").header("trantype", "code").body(param)//表单内容
.timeout(900000000)//超时，毫秒 .timeout(900000000)//超时，毫秒
.execute().body(); .execute().body();
long l1 = System.currentTimeMillis(); long l1 = System.currentTimeMillis();
logger.info("\n回参：" + result + " \n执行耗时：" + (l1 - l)); long timeConsuming = l1 - l;
logger.info("\n回参：" + result + " \n执行耗时：" + timeConsuming + "\n条数：" + number + " 每单耗时：" + (timeConsuming / 1000 / number));
// JSONObject jsonObject = JSON.parseObject(result); // JSONObject jsonObject = JSON.parseObject(result);
// result = String.valueOf(jsonObject.get("attribute")); // result = String.valueOf(jsonObject.get("attribute"));
// System.out.println(result); // System.out.println(result);
@ -559,7 +574,7 @@ public class DeleteU8cDataUtil {
Map<String, List<Map<String, String>>> stringStringMap2 = new HashMap<>(); Map<String, List<Map<String, String>>> stringStringMap2 = new HashMap<>();
stringStringMap2.put("bills", mapList); stringStringMap2.put("bills", mapList);
sendU8C("http://39.170.109.90:8088/u8cloud/api/arap/ys/unaudit", JSON.toJSONString(stringStringMap2)); sendU8C("http://39.170.109.90:8088/u8cloud/api/arap/ys/unaudit", JSON.toJSONString(stringStringMap2), 1);
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -593,7 +608,7 @@ public class DeleteU8cDataUtil {
Map<String, Map<String, String>> stringStringMap3 = new HashMap<>(); Map<String, Map<String, String>> stringStringMap3 = new HashMap<>();
stringStringMap3.put("deleteinfo", stringStringMap); stringStringMap3.put("deleteinfo", stringStringMap);
stringStringMap3.put("queryinfo", stringStringMap2); stringStringMap3.put("queryinfo", stringStringMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/arap/ys/delete", JSON.toJSONString(stringStringMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/arap/ys/delete", JSON.toJSONString(stringStringMap3), 1);
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -627,7 +642,7 @@ public class DeleteU8cDataUtil {
Map<String, Map<String, String>> stringStringMap3 = new HashMap<>(); Map<String, Map<String, String>> stringStringMap3 = new HashMap<>();
stringStringMap3.put("approveinfo", stringStringMap); stringStringMap3.put("approveinfo", stringStringMap);
stringStringMap3.put("queryinfo", stringStringMap2); stringStringMap3.put("queryinfo", stringStringMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/unapprove", JSON.toJSONString(stringStringMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/unapprove", JSON.toJSONString(stringStringMap3), 1);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
@ -681,7 +696,7 @@ public class DeleteU8cDataUtil {
Map<String, Map<String, Object>> stringStringMap3 = new HashMap<>(); Map<String, Map<String, Object>> stringStringMap3 = new HashMap<>();
stringStringMap3.put("approveinfo", stringStringMap); stringStringMap3.put("approveinfo", stringStringMap);
stringStringMap3.put("queryinfo", stringStringMap2); stringStringMap3.put("queryinfo", stringStringMap2);
sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/unapprove", JSON.toJSONString(stringStringMap3)); sendU8C("http://39.170.109.90:8088/u8cloud/api/so/saleinvoice/unapprove", JSON.toJSONString(stringStringMap3), vreceiptcodeList.size());
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();