github
/
jeecg-boot
mirror of https://github.com/jeecgboot/jeecg-boot
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add job to send ShoumanOrder from DB

pull/8040/head
Qiuyi LI 2023-12-07 12:29:36 +01:00
parent 28ac56d2b7
commit baf33eb355
4 changed files with 200 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/api/shouman/JsonOrderCreationRequestBody.java Normal file
View File

@ -0,0 +1,18 @@
package org.jeecg.modules.business.domain.api.shouman;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
public class JsonOrderCreationRequestBody extends OrderCreationRequestBody {
private final String jsonString;
public JsonOrderCreationRequestBody(String jsonString) {
super(null, null);
this.jsonString = jsonString;
}
@Override
public JSONObject parameters() {
return JSON.parseObject(jsonString);
}
}

8
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/api/shouman/OrderCreationRequest.java Normal file
View File

@ -0,0 +1,8 @@
package org.jeecg.modules.business.domain.api.shouman;
public class OrderCreationRequest extends Request {
public OrderCreationRequest(JsonOrderCreationRequestBody body) {
super(body);
}
}

104
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/api/shouman/Request.java Normal file
View File

@ -0,0 +1,104 @@
package org.jeecg.modules.business.domain.api.shouman;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.parser.Feature;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import org.jeecg.common.util.RestUtil;
import org.jeecg.modules.business.entity.Shouman.ShoumanOrder;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
/**
* This class contains some key information and necessary procedures
* to send a request body to ShouMan API, for example target URL,
* correspondent HTTP method, procedure to generate authorization.
* <p>
* Subclass should implement the send() method by specifying the real response class and constructing it.
*/
@Slf4j
public abstract class Request {
private final static String BASE_URL = "http://xmsmdz.xyldiy.com:8012/api";
private static final HttpMethod METHOD = HttpMethod.POST;
private static final String KEY = "BpQWy6AtvKcixjePQ4ZMuvBqUyIsXWWX";
private static final String SHOP_CODE = "8ee5c82004c44049b9f22a0ed8dc4db3";
private static final String SHIPPING_SERVICE_LEVEL_CATEGORY = "Standard";
private final RequestBody body;
public Request(RequestBody body) {
this.body = body;
}
/**
* Sent request to the mabang API with a request body.
*
* @return the response of the body or null, if response
*/
public ResponseEntity<String> rawSend(ShoumanOrder shoumanOrder) {
int attempts = 0;
HttpHeaders headers = new HttpHeaders();
headers.add(HttpHeaders.CONTENT_TYPE, "application/json");
String bodyString = generateJsonBodyString(body);
String signatureString = generateSignForJson(bodyString);
String signatureMd5 = DigestUtils.md5Hex(signatureString).toUpperCase();
shoumanOrder.setSignatureString(signatureString);
shoumanOrder.setSignatureMd5(signatureMd5);
headers.add("signature", signatureMd5);
while (attempts++ < 5) {
try {
return RestUtil.request(BASE_URL + body.path(), METHOD, headers, null, bodyString, String.class);
} catch (Exception e) {
log.error("Request failed on attempt n°" + attempts);
}
}
return null;
}
/**
* Convert body's json parameters to json string with the necessary extra parameter to
* send request.
*
* @param body body to convert
* @return json string
*/
private static String generateJsonBodyString(RequestBody body) {
JSONObject param = new JSONObject();
param.putAll(body.parameters());
param.put("shipmentServiceLevelCategory", SHIPPING_SERVICE_LEVEL_CATEGORY);
param.put("isSendStandardPro", true);
param.put("shopCode", SHOP_CODE);
return param.toJSONString();
}
private static String generateSignForJson(String jsonString) {
log.info("JSON:{}", jsonString);
if (jsonString.isEmpty()) {
return null;
}
JSONObject jsonObject = JSONObject.parseObject(jsonString, Feature.OrderedField);
Map<String, Object> maps = jsonObject.getInnerMap();
ArrayList<String> arrayList = new ArrayList<>();
for (Map.Entry<String, Object> entry : maps.entrySet()) {
arrayList.add(entry.getKey() + "=" + entry.getValue() + "&");
}
if (arrayList.isEmpty()) {
return null;
}
String[] strArray = arrayList.toArray(new String[0]);
Arrays.sort(strArray);
StringBuilder stringBuffer = new StringBuilder();
for (String param : strArray) {
stringBuffer.append(param);
}
String params = stringBuffer + "key=" + KEY;
log.info("Signature:{}", params);
return params;
}
}

70
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/ShoumanOrderSendJob.java Normal file
View File

@ -0,0 +1,70 @@
package org.jeecg.modules.business.domain.job;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.jeecg.modules.business.domain.api.shouman.JsonOrderCreationRequestBody;
import org.jeecg.modules.business.domain.api.shouman.OrderCreationRequest;
import org.jeecg.modules.business.domain.api.shouman.OrderCreationRequestBody;
import org.jeecg.modules.business.domain.api.shouman.Request;
import org.jeecg.modules.business.entity.Country;
import org.jeecg.modules.business.entity.Shouman.ShoumanOrder;
import org.jeecg.modules.business.entity.ShoumanOrderContent;
import org.jeecg.modules.business.mapper.CountryMapper;
import org.jeecg.modules.business.mapper.PlatformOrderContentMapper;
import org.jeecg.modules.business.service.IShoumanOrderService;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
import static java.util.stream.Collectors.toMap;
@Slf4j
public class ShoumanOrderSendJob implements Job {
@Autowired
private IShoumanOrderService shoumanOrderService;
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
log.info("Started Shouman order send job");
List<ShoumanOrder> shoumanOrders = shoumanOrderService.findShoumanOrderToSend();
log.info("Retrieved {} Shouman orders to send to ShoumanAPI", shoumanOrders.size());
log.info("Started building and sending Shouman order requests");
for (ShoumanOrder shoumanOrder : shoumanOrders) {
String platformOrderId = shoumanOrder.getPlatformOrderId();
log.info("Started building Shouman Order {}", platformOrderId);
OrderCreationRequest request = new OrderCreationRequest(new JsonOrderCreationRequestBody(shoumanOrder.getOrderJson()));
log.info("Finished building Shouman Order {}", platformOrderId);
log.info("Started sending Shouman Order {}", platformOrderId);
String resultString = request.rawSend(shoumanOrder).getBody();
log.info("Finished sending Shouman Order {}", platformOrderId);
JSONObject json = JSON.parseObject(resultString);
Object status = json.get("status");
if (status != null) {
if (((Integer) status) == 1) {
log.info("Shouman Order {} ended with success", platformOrderId);
shoumanOrder.setSuccess(status.toString());
} else {
log.info("Shouman Order {} failed", platformOrderId);
}
}
}
log.info("Finished building and sending Shouman order requests");
log.info("Started updating Shouman Orders in DB");
shoumanOrderService.updateBatchById(shoumanOrders);
log.info("Finished updating Shouman Orders in DB");
log.info("Finished Shouman order send job");
}
}