xjm
/
ssjygl-xsct-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

审核订单取消申请接口修改

dev
徐杰盟 2024-04-17 09:46:58 +08:00
parent 4c8f0b6822
commit 17a4448fb6
1 changed files with 43 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

84
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java
View File

@ -31,9 +31,9 @@ import java.util.concurrent.LinkedBlockingQueue;
* PrimaryKey: id * PrimaryKey: id
*/ */
public class SyncTaskService { public class SyncTaskService {
private static Log log = Log.getLog(SyncTaskService.class); private static Log log = Log.getLog(SyncTaskService.class);
public static final SyncTaskService me = new SyncTaskService(); public static final SyncTaskService me = new SyncTaskService();
private BlockingQueue<JSONObject> taskQueue = new LinkedBlockingQueue<>(); // 砂站推送到服务端的数据队列 private BlockingQueue<JSONObject> taskQueue = new LinkedBlockingQueue<>(); // 砂站推送到服务端的数据队列
// 是否开启 // 是否开启
public boolean isEnable() { public boolean isEnable() {
@ -58,9 +58,9 @@ public class SyncTaskService {
try { try {
while (Config.server_run) { while (Config.server_run) {
try { try {
JSONObject data = taskQueue.take(); JSONObject data = taskQueue.take();
int supermarket_id = data.getInteger("supermarket_id"); int supermarket_id = data.getInteger("supermarket_id");
boolean ret = recv(data, supermarket_id); boolean ret = recv(data, supermarket_id);
// 接收成功后，返回id // 接收成功后，返回id
if (ret) { if (ret) {
@ -252,9 +252,9 @@ public class SyncTaskService {
long st = System.currentTimeMillis(); long st = System.currentTimeMillis();
try { try {
JSONObject save_data = JSONObject.parseObject(recvdata.getString("save_data")); JSONObject save_data = JSONObject.parseObject(recvdata.getString("save_data"));
JSONObject update_data = JSONObject.parseObject(recvdata.getString("update_data")); JSONObject update_data = JSONObject.parseObject(recvdata.getString("update_data"));
JSONObject delete_data = JSONObject.parseObject(recvdata.getString("delete_data")); JSONObject delete_data = JSONObject.parseObject(recvdata.getString("delete_data"));
JSONObject increment_data = JSONObject.parseObject(recvdata.getString("increment_data")); JSONObject increment_data = JSONObject.parseObject(recvdata.getString("increment_data"));
if ( if (
@ -272,16 +272,16 @@ public class SyncTaskService {
@Override @Override
public boolean run() { public boolean run() {
try { try {
JSONArray saveauthlics = new JSONArray(); // 授权车牌号需要推送更新到其他砂站 JSONArray saveauthlics = new JSONArray(); // 授权车牌号需要推送更新到其他砂站
JSONArray deleteauthlics = new JSONArray(); JSONArray deleteauthlics = new JSONArray();
List<SyncTask> sts = new ArrayList<>(); List<SyncTask> sts = new ArrayList<>();
Date now = new Date(); Date now = new Date();
if (save_data != null && !save_data.isEmpty()) { if (save_data != null && !save_data.isEmpty()) {
for (String tablename : save_data.keySet()) { for (String tablename : save_data.keySet()) {
JSONObject data = save_data.getJSONObject(tablename); JSONObject data = save_data.getJSONObject(tablename);
String pks = data.getString("pks"); String pks = data.getString("pks");
JSONArray arr = data.getJSONArray("data"); JSONArray arr = data.getJSONArray("data");
List<Record> list = new ArrayList<>(); List<Record> list = new ArrayList<>();
// 2021-10-30 AuthLicense 相关的处理数据要跳过 // 2021-10-30 AuthLicense 相关的处理数据要跳过
@ -335,7 +335,7 @@ public class SyncTaskService {
} }
} }
list = listFilter(tablename,list); list = listFilter(tablename, list);
int[] ret = Db.batchSave(tablename, list, list.size()); int[] ret = Db.batchSave(tablename, list, list.size());
@ -354,9 +354,9 @@ public class SyncTaskService {
if (update_data != null && !update_data.isEmpty()) { if (update_data != null && !update_data.isEmpty()) {
for (String tablename : update_data.keySet()) { for (String tablename : update_data.keySet()) {
JSONObject data = update_data.getJSONObject(tablename); JSONObject data = update_data.getJSONObject(tablename);
String pks = data.getString("pks"); String pks = data.getString("pks");
JSONArray arr = data.getJSONArray("data"); JSONArray arr = data.getJSONArray("data");
List<Record> list = new ArrayList<>(); List<Record> list = new ArrayList<>();
if (Transport.tablename.equals(tablename)) { if (Transport.tablename.equals(tablename)) {
@ -431,8 +431,8 @@ public class SyncTaskService {
if (delete_data != null && !delete_data.isEmpty()) { if (delete_data != null && !delete_data.isEmpty()) {
for (String tablename : delete_data.keySet()) { for (String tablename : delete_data.keySet()) {
JSONObject data = delete_data.getJSONObject(tablename); JSONObject data = delete_data.getJSONObject(tablename);
String pks = data.getString("pks"); String pks = data.getString("pks");
JSONArray arr = data.getJSONArray("data"); JSONArray arr = data.getJSONArray("data");
// 2021-10-30 AuthLicense 相关的处理数据要跳过 // 2021-10-30 AuthLicense 相关的处理数据要跳过
if (AuthLicense.dao.getTablename().equals(tablename)) { if (AuthLicense.dao.getTablename().equals(tablename)) {
@ -458,12 +458,12 @@ public class SyncTaskService {
if (increment_data != null && !increment_data.isEmpty()) { if (increment_data != null && !increment_data.isEmpty()) {
for (String tablename : increment_data.keySet()) { for (String tablename : increment_data.keySet()) {
JSONObject data = increment_data.getJSONObject(tablename); JSONObject data = increment_data.getJSONObject(tablename);
String pks = data.getString("pks"); String pks = data.getString("pks");
JSONArray pkv = data.getJSONArray("pkv"); JSONArray pkv = data.getJSONArray("pkv");
JSONObject increment_data = data.getJSONObject("increment"); JSONObject increment_data = data.getJSONObject("increment");
Record record = Db.findByIds(tablename, pks, pkv.toArray()); Record record = Db.findByIds(tablename, pks, pkv.toArray());
boolean change = false; boolean change = false;
if (record == null) { if (record == null) {
@ -576,49 +576,51 @@ public class SyncTaskService {
private List<Record> listFilter(String tablename, List<Record> list) { private List<Record> listFilter(String tablename, List<Record> list) {
List<Record> removeList = new ArrayList<>(); List<Record> removeList = new ArrayList<>();
if ("order_temp".equals(tablename)){ if ("order_temp".equals(tablename)) {
// sn // sn
for (Record o : list) { for (Record o : list) {
String sn = o.getStr("sn"); String sn = o.getStr("sn");
Record first = Db.findFirst("select * from " + tablename + " where sn = ?", sn); Record first = Db.findFirst("select * from " + tablename + " where sn = ?", sn);
if (o.toJson().equals(first.toJson())){ if (o.toJson().equals(first.toJson())) {
removeList.add(o); removeList.add(o);
} }
} }
} }
if ("ticket_log".equals(tablename)){ if ("ticket_log".equals(tablename)) {
// id // id
for (Record o : list) { for (Record o : list) {
String id = o.getStr("id"); String id = o.getStr("id");
Record first = Db.findFirst("select * from " + tablename + " where sn = ?", id); Record first = Db.findFirst("select * from " + tablename + " where sn = ?", id);
if (o.toJson().equals(first.toJson())){ if (o.toJson().equals(first.toJson())) {
removeList.add(o); removeList.add(o);
} }
} }
} }
if ("action_cmd_log".equals(tablename)){ if ("action_cmd_log".equals(tablename)) {
// id // id
for (Record o : list) { for (Record o : list) {
String id = o.getStr("id"); String id = o.getStr("id");
Record first = Db.findFirst("select * from " + tablename + " where sn = ?", id); Record first = Db.findFirst("select * from " + tablename + " where sn = ?", id);
if (o.toJson().equals(first.toJson())){ if (o.toJson().equals(first.toJson())) {
removeList.add(o); removeList.add(o);
} }
} }
} }
if ("transport".equals(tablename)){ if ("transport".equals(tablename)) {
// id // id
for (Record o : list) { for (Record o : list) {
String id = o.getStr("id"); String id = o.getStr("id");
Record first = Db.findFirst("select * from " + tablename + " where sn = ?", id); Record first = Db.findFirst("select * from " + tablename + " where sn = ?", id);
if (o.toJson().equals(first.toJson())){ if (o.toJson().equals(first.toJson())) {
removeList.add(o); removeList.add(o);
} }
} }
} }
if (CollectionUtils.isNotEmpty(removeList)){ if (CollectionUtils.isNotEmpty(removeList)) {
list.removeAll(removeList); log.debug("新增条数" + list.size());
list.removeAll(removeList);
log.debug("删除后条数" + list.size());
} }
return list; return list;
@ -634,7 +636,7 @@ public class SyncTaskService {
*/ */
public boolean recvAuthLicense(JSONArray savearr, JSONArray deletearr, int current_supermarket_id) { public boolean recvAuthLicense(JSONArray savearr, JSONArray deletearr, int current_supermarket_id) {
List<SyncTask> sts = new ArrayList<>(); List<SyncTask> sts = new ArrayList<>();
Date now = new Date(); Date now = new Date();
for (Map.Entry<Integer, Supermarket> entry : SvrCacheData.SUP_CACHE.entrySet()) { for (Map.Entry<Integer, Supermarket> entry : SvrCacheData.SUP_CACHE.entrySet()) {
Supermarket supermarket = entry.getValue(); Supermarket supermarket = entry.getValue();
@ -679,10 +681,10 @@ public class SyncTaskService {
* @return * @return
*/ */
public JSONArray filtrateTransport(JSONArray arr) { public JSONArray filtrateTransport(JSONArray arr) {
JSONArray out = new JSONArray(); JSONArray out = new JSONArray();
List<String> ids = new ArrayList<>(); List<String> ids = new ArrayList<>();
List<String> sqls = new ArrayList<>(); List<String> sqls = new ArrayList<>();
Map<String, JSONObject> map = new HashMap<>(); Map<String, JSONObject> map = new HashMap<>();
for (int i = 0; i < arr.size(); i++) { for (int i = 0; i < arr.size(); i++) {
JSONObject obj = arr.getJSONObject(i); JSONObject obj = arr.getJSONObject(i);