|
|
|
@ -41,6 +41,7 @@ import com.glxp.mipsdl.req.ctqyy.CtqyyRequest;
|
|
|
|
|
import com.glxp.mipsdl.req.dsxyy.DsOrderRequest;
|
|
|
|
|
import com.glxp.mipsdl.req.lhzyy.LhProductRequest;
|
|
|
|
|
import com.glxp.mipsdl.req.lhzyy.LhUnitRequest;
|
|
|
|
|
import com.glxp.mipsdl.req.lhzyy.LhzyyRequest;
|
|
|
|
|
import com.glxp.mipsdl.req.post.*;
|
|
|
|
|
import com.glxp.mipsdl.req.yxzyy.YxBusTypeRequest;
|
|
|
|
|
import com.glxp.mipsdl.req.yxzyy.YxProductRequest;
|
|
|
|
@ -56,6 +57,9 @@ import com.glxp.mipsdl.util.DictUtl;
|
|
|
|
|
import com.glxp.mipsdl.util.ResultVOUtils;
|
|
|
|
|
import com.glxp.mipsdl.util.SubmitOrderUtil;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.dom4j.Document;
|
|
|
|
|
import org.dom4j.DocumentException;
|
|
|
|
|
import org.dom4j.DocumentHelper;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
@ -80,6 +84,21 @@ public class LhzyyClient extends CommonHttpClient {
|
|
|
|
|
"</root>";
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public String parserResult(String response) {
|
|
|
|
|
if (response.contains("<root")) {
|
|
|
|
|
try {
|
|
|
|
|
Document document = DocumentHelper.parseText(response);
|
|
|
|
|
String message = document.getRootElement().element("message").getText();
|
|
|
|
|
return message;
|
|
|
|
|
} catch (DocumentException e) {
|
|
|
|
|
log.info("解析龙海中医院接口返回结果异常, 返回结果:{}", response);
|
|
|
|
|
log.error("异常信息:", e);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return response;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Resource
|
|
|
|
|
private ThrSystemDetailService thrSystemDetailService;
|
|
|
|
|
@Resource
|
|
|
|
@ -412,13 +431,13 @@ public class LhzyyClient extends CommonHttpClient {
|
|
|
|
|
materialDictEntity.setPriceItemClass(udiRelevanceResponse.getBasicPrductRemak8());
|
|
|
|
|
//暂无收费标志
|
|
|
|
|
materialDictEntity.setFeeFlag(udiRelevanceResponse.getBasicPrductRemak6());
|
|
|
|
|
CtqyyRequest ctqyyRequest = new CtqyyRequest();
|
|
|
|
|
ctqyyRequest.setMsgHeader(getMsgHeader("addMaterialDict"));
|
|
|
|
|
ctqyyRequest.setMsgBody(JSONUtil.toJsonStr(materialDictEntity));
|
|
|
|
|
String response = httpClient.postJson(thrSystemDetailService.getUrlExclude(Constants.URL_NAME_PRODUCT_SUBMIT_URL), ctqyyRequest);
|
|
|
|
|
// response = parserResult(response);
|
|
|
|
|
LhzyyRequest lhzyyRequest = new LhzyyRequest();
|
|
|
|
|
lhzyyRequest.setMsgHeader(getMsgHeader("addMaterialDict"));
|
|
|
|
|
lhzyyRequest.setMsgBody(JSONUtil.toJsonStr(materialDictEntity));
|
|
|
|
|
String response = httpClient.postJson(thrSystemDetailService.getUrlExclude(Constants.URL_NAME_PRODUCT_SUBMIT_URL), lhzyyRequest);
|
|
|
|
|
response = parserResult(response);
|
|
|
|
|
try {
|
|
|
|
|
log.error("提交新增产品信息:" + ctqyyRequest.getMsgBody());
|
|
|
|
|
log.error("提交新增产品信息:" + lhzyyRequest.getMsgBody());
|
|
|
|
|
CtBaseResponse baseResponse = JSONObject.parseObject(response, CtBaseResponse.class);
|
|
|
|
|
if (baseResponse.getCode() != 20000) {
|
|
|
|
|
String errMsg = "提交新增产品信息,异常:{}" + response;
|
|
|
|
|