package tqq9.lc123.cloud.app.plugin.operate.cas; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import kd.bos.dataentity.entity.DynamicObject; import kd.bos.entity.plugin.AbstractOperationServicePlugIn; import kd.bos.entity.plugin.args.AfterOperationArgs; import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.bos.servicehelper.operation.SaveServiceHelper; import org.apache.commons.lang3.StringUtils; import tqq9.lc123.cloud.app.plugin.trd.FWImpl; import tqq9.lc123.cloud.app.plugin.utils.FWRestfulUtils; import tqq9.lc123.cloud.app.plugin.utils.FWUtils; import java.io.IOException; import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL; import java.text.SimpleDateFormat; import java.util.Date; /** * 付款单付款状态回传泛微 kd.bos.form.plugin.bdctrl.AssignQueryPluginNew */ public class PaymentbillPushPaystateOp extends AbstractOperationServicePlugIn { @Override public void afterExecuteOperationTransaction(AfterOperationArgs e) { super.afterExecuteOperationTransaction(e); DynamicObject[] dataEntities = e.getDataEntities(); for (DynamicObject dataEntity : dataEntities) { dataEntity = BusinessDataServiceHelper.loadSingle(dataEntity.getPkValue(), dataEntity.getDynamicObjectType().getName()); String resultStr = FWImpl.returnPayState(dataEntity); if(StringUtils.isNotBlank(resultStr)){ JSONObject resultJson = JSONObject.parseObject(resultStr); String status = resultJson.getString("status"); if ("1".equals(status)) { dataEntity.set("tqq9_ispushfw", true); SaveServiceHelper.save(new DynamicObject[]{dataEntity}); } } } } }