100 lines
5.2 KiB
Java
100 lines
5.2 KiB
Java
package com.yem.wm.task;
|
|
|
|
import com.yem.ensign.common.DateUtils;
|
|
import com.yem.wm.utils.RequestCmmp;
|
|
import kd.bos.context.RequestContext;
|
|
import kd.bos.dataentity.OperateOption;
|
|
import kd.bos.dataentity.entity.DynamicObject;
|
|
import kd.bos.dataentity.entity.DynamicObjectCollection;
|
|
import kd.bos.dataentity.resource.ResManager;
|
|
import kd.bos.entity.EntityMetadataCache;
|
|
import kd.bos.entity.MainEntityType;
|
|
import kd.bos.entity.operate.result.IOperateInfo;
|
|
import kd.bos.entity.operate.result.OperationResult;
|
|
import kd.bos.exception.KDBizException;
|
|
import kd.bos.exception.KDException;
|
|
import kd.bos.id.ID;
|
|
import kd.bos.orm.query.QCP;
|
|
import kd.bos.orm.query.QFilter;
|
|
import kd.bos.schedule.executor.AbstractTask;
|
|
import kd.bos.servicehelper.BusinessDataServiceHelper;
|
|
import kd.bos.servicehelper.QueryServiceHelper;
|
|
import kd.bos.servicehelper.operation.OperationServiceHelper;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.Date;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
/**
|
|
* 库区
|
|
*/
|
|
|
|
public class SynWareAreaCMMPTask extends AbstractTask {
|
|
@Override
|
|
public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
|
|
//查询CMMP链接
|
|
DynamicObjectCollection connObjs = QueryServiceHelper.query("yem_cmmpconfig", "id,yem_belong", new QFilter[]{new QFilter("yem_num", QCP.in, new String[]{"ZZJ", "CC", "NZ"})});
|
|
for (DynamicObject connObj : connObjs) {
|
|
long id = connObj.getLong("id");
|
|
StringBuilder sql = new StringBuilder("SELECT wh_code,area_code,area_name,enable_flag,area_fid from VIEW_WH_AREA_WM where 1=1");
|
|
String isInit = (String) map.get("isInit");
|
|
if (!"true".equals(isInit)) {
|
|
Date dateed = new Date();
|
|
dateed = DateUtils.getBeginTime(dateed);
|
|
Date datebg = DateUtils.getAddDay(dateed, -2);
|
|
dateed = DateUtils.getEndTime(dateed);
|
|
sql.append(" and plmlastupdate>=to_date('" + DateUtils.formatString(datebg) + "','yyyy-mm-dd')" + " and plmlastupdate<=to_date('" + DateUtils.formatString(dateed) + "','yyyy-mm-dd')");
|
|
}
|
|
sql.append(" order by plmlastupdate");
|
|
//执行sql
|
|
List<Map> fromCmmpWithConnId = RequestCmmp.getFromCmmpWithConnId(id, sql.toString());
|
|
for (Map map1 : fromCmmpWithConnId) {
|
|
//先查询是否存在
|
|
ArrayList<QFilter> qFilters = new ArrayList<>();
|
|
qFilters.add(new QFilter("number", QCP.equals, map1.get("area_code")));
|
|
qFilters.add(new QFilter("group.number", QCP.equals, map1.get("wh_code")));
|
|
qFilters.add(new QFilter("group.yem_belong", QCP.equals, connObj.getString("yem_belong")));
|
|
qFilters.add(new QFilter("yem_belong", QCP.equals, connObj.getString("yem_belong")));
|
|
DynamicObjectCollection whs = QueryServiceHelper.query("yem_warearea", "id", qFilters.toArray(new QFilter[0]));
|
|
if (whs.size() > 0) {
|
|
//如果存在
|
|
DynamicObject wh = BusinessDataServiceHelper.loadSingle(whs.get(0).getString("id"), "yem_warearea");
|
|
createWA(map1, wh, connObj);
|
|
if(wh.get("group")==null){
|
|
continue;
|
|
}
|
|
OperationServiceHelper.executeOperate("save", "yem_warearea", new DynamicObject[]{wh}, OperateOption.create());
|
|
} else {
|
|
MainEntityType entityType = EntityMetadataCache.getDataEntityType("yem_warearea");
|
|
DynamicObject wh = new DynamicObject(entityType);
|
|
wh.getDataEntityType().getPrimaryKey().setValueFast(wh, ID.genLongId());
|
|
createWA(map1, wh, connObj);
|
|
OperationResult operationResult = OperationServiceHelper.executeOperate("save", "yem_warearea", new DynamicObject[]{wh}, OperateOption.create());
|
|
if (!operationResult.isSuccess()) {
|
|
for (IOperateInfo errInfo1 : operationResult.getAllErrorOrValidateInfo()) {
|
|
String detailMessage1 = errInfo1.getMessage();
|
|
throw new KDBizException(ResManager.loadKDString("生成时保存失败：", "EtcmanualList_2", "createEcatalog_res") + detailMessage1);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void createWA(Map map1, DynamicObject wh, DynamicObject connObj) {
|
|
wh.set("number", map1.get("area_code").toString());//仓库编码
|
|
wh.set("name", map1.get("area_name").toString());//仓库名称
|
|
wh.set("status", "C");//数据状态
|
|
wh.set("yem_transstate", 1);//业务状态
|
|
wh.set("enable", map1.get("enable_flag".toLowerCase()).toString());//是否启用
|
|
wh.set("yem_easid", map1.get("area_fid"));//EASID
|
|
//库区获取
|
|
DynamicObject whObj = BusinessDataServiceHelper.loadSingle("yem_warehouse",
|
|
new QFilter[]{new QFilter("number", QCP.equals, map1.get("wh_code")),
|
|
new QFilter("yem_belong", QCP.equals, connObj.getString("yem_belong"))});
|
|
wh.set("group", whObj);
|
|
wh.set("yem_belong", connObj.getString("yem_belong"));//仓库所属
|
|
}
|
|
}
|