global class SparePartsSequencingBatch implements Database.Batchable<SObject> {
|
|
//有参无参构造 start execute finish
|
|
global Date startDate; //排序开始日期
|
global Date endDate; //排序结束日期
|
|
public String OCSMProvince;
|
|
// global SparePartsSequencingBatch(){
|
// }
|
|
// 带年月的构造参数，用来刷历史数据的
|
// global SparePartsSequencingBatch(Integer year, Integer month) {
|
// startDate = Date.newInstance(year, month, 1);
|
// endDate = startDate.addMonths(1);
|
// }
|
|
// // OSCM管理省
|
// global SparePartsSequencingBatch(String OCSMProvince){
|
// this.OCSMProvince = OCSMProvince;
|
// }
|
|
// // 带年月和OSCM管理省的构造函数
|
// global SparePartsSequencingBatch(Integer year, Integer month, String OCSMProvince) {
|
// startDate = Date.newInstance(year, month, 1);
|
// endDate = startDate.addMonths(1);
|
// this.OCSMProvince = OCSMProvince;
|
// }
|
|
global SparePartsSequencingBatch(Date startat, Date endat){
|
startDate = startat;
|
endDate = endat;
|
}
|
|
global SparePartsSequencingBatch(Date startat, Date endat, String province){
|
startDate = startat;
|
endDate = endat;
|
OCSMProvince = province;
|
}
|
|
|
global Database.QueryLocator start(Database.BatchableContext BC) {
|
|
String sql = 'select name from OCM_Management_Province__c';
|
if(String.isNotBlank(OCSMProvince)){
|
sql += ' Where name =: OCSMProvince';
|
}
|
|
return Database.getQueryLocator(sql);
|
|
}
|
|
// global void execute(Database.BatchableContext BC, List<OCM_Management_Province__c> ompList) {
|
// System.debug('lt123ompList<OCSM管理省>(初始)'+ompList);
|
|
// List<String> ocsmList = new List<String>();
|
// for(OCM_Management_Province__c omp : ompList){
|
// ocsmList.add(omp.name);
|
// }
|
|
// // Date today = Date.today();
|
// // Integer year = today.year();
|
// // Integer month = today.month() - 1;
|
|
// // 开始 结束日期
|
// if(startDate == null) {
|
// // 上个月
|
// Date outdate = Date.today().addMonths(-1);
|
// // 确保开始日期是1号，结束日期是下月1号
|
// startDate = Date.newInstance(outdate.year(), outdate.month(), 1);
|
// endDate = startDate.addMonths(1);
|
// }
|
|
// if(ocsmList.size()>0){
|
// List<OPDPlan__c> opdList = [Select Id, OPDPlanOCM_man_province__c, Deliver_Index__c, Bollowdate__c,
|
// Approved_Index__c, SparePartsAppDate__c
|
// From OPDPlan__c
|
// Where OPDPlanOCM_man_province__c in: ocsmList
|
// AND ((Bollowdate__c >=: startDate And Bollowdate__c <: endDate)
|
// OR (SparePartsAppDate__c >=: startDate And SparePartsAppDate__c <: endDate))];
|
|
// //Map<OCSM管理省,List>,按照OCSM管理省分类
|
// Set<String> outList1 = new Set<String>();
|
// Set<String> appList1 = new Set<String>();
|
// Map<String,List<OPDPlan__c>> outMap = new Map<String,List<OPDPlan__c>>(); //出库
|
// Map<String,List<OPDPlan__c>> appMap = new Map<String,List<OPDPlan__c>>(); //审批
|
|
// for(OPDPlan__c opd : opdList){
|
// //备品出库优先度
|
// if(opd.Bollowdate__c != null){
|
|
// outList1.add(opd.OPDPlanOCM_man_province__c);
|
|
// if(outMap.containsKey(opd.OPDPlanOCM_man_province__c)){
|
// outMap.get(opd.OPDPlanOCM_man_province__c).add(opd);
|
// }else{
|
// List<OPDPlan__c> appList = new List<OPDPlan__c>(); //上个月批准日不为空的opd计划
|
// appList.add(opd);
|
// outMap.put(opd.OPDPlanOCM_man_province__c, appList);
|
// }
|
|
// // Integer outyear = opd.Bollowdate__c.year();
|
// // Integer outmonth = opd.Bollowdate__c.month();
|
// // if(year == outyear && month == outmonth){
|
|
// // }
|
// }
|
// System.debug('lt123outMap备品出库<OCSM管理省，List<OPD计划>>'+outMap);
|
|
// //备品审批优先度
|
// System.debug('lt123+opd.SparePartsAppDate__c+test---'+opd.SparePartsAppDate__c);
|
// if(opd.SparePartsAppDate__c != null){
|
|
// appList1.add(opd.OPDPlanOCM_man_province__c);
|
|
// if(appMap.containsKey(opd.OPDPlanOCM_man_province__c)){
|
// appMap.get(opd.OPDPlanOCM_man_province__c).add(opd);
|
// }else{
|
// List<OPDPlan__c> appList = new List<OPDPlan__c>(); //上个月出库日不为空的opd计划
|
// appList.add(opd);
|
// appMap.put(opd.OPDPlanOCM_man_province__c, appList);
|
// }
|
|
// // Integer appyear = opd.SparePartsAppDate__c.year();
|
// // Integer appmonth = opd.SparePartsAppDate__c.month();
|
// // if(year == appyear && month == appmonth){
|
// // }
|
// }
|
// System.debug('lt123appMap备品审批<OCSM管理省，List<OPD计划>>'+appMap);
|
// }
|
|
// //出库--冒泡排序
|
// List<OPDPlan__c> outList2 = new List<OPDPlan__c>();
|
// for(string out : outList1){
|
// if(outMap.get(out) != null){
|
// Integer len = outMap.get(out).size();
|
// for(Integer i = 0 ; i < len - 1 ; i++){
|
// for(Integer j = 0 ; j < len - 1 - i ; j++){
|
// if(outMap.get(out)[j].Bollowdate__c > outMap.get(out)[j + 1].Bollowdate__c){
|
// OPDPlan__c temp = outMap.get(out)[j + 1];
|
// outMap.get(out)[j + 1] = outMap.get(out)[j];
|
// outMap.get(out)[j] = temp;
|
// }
|
// }
|
// }
|
// //赋值 排序
|
// for(Integer i = 0 ; i < len ; i++){
|
// outMap.get(out)[i].Deliver_Index__c = i + 1;
|
// }
|
// outList2.addAll(outMap.get(out));
|
// System.debug('lt123outMap备品出库(排序后)'+outMap.get(out));
|
// }
|
// }
|
// update outList2;
|
// System.debug('lt123outList2备品出库(更新后)'+outList2);
|
|
// //审批--冒泡排序
|
// List<OPDPlan__c> appList2 = new List<OPDPlan__c>();
|
// for(string app : appList1){
|
// if(appMap.get(app) != null){
|
// Integer len1 = appMap.get(app).size();
|
// for(Integer i = 0 ; i < len1 - 1 ; i++){
|
// for(Integer j = 0 ; j < len1 - 1 - i ; j++){
|
// if(appMap.get(app)[j].SparePartsAppDate__c > appMap.get(app)[j + 1].SparePartsAppDate__c){
|
// OPDPlan__c temp = appMap.get(app)[j + 1];
|
// appMap.get(app)[j + 1] = appMap.get(app)[j];
|
// appMap.get(app)[j] = temp;
|
// }
|
// }
|
// }
|
// //赋值 排序
|
// for(Integer i = 0 ; i < len1 ; i++){
|
// appMap.get(app)[i].Approved_Index__c = i + 1;
|
// }
|
// appList2.addAll(appMap.get(app));
|
// System.debug('lt123appMap备品审批(排序后)'+appMap.get(app));
|
// }
|
|
// }
|
// update appList2;
|
// System.debug('lt123appList2备品审批(更新后)'+appList2);
|
|
// }
|
|
// }
|
|
|
|
global void execute(Database.BatchableContext BC, List<OCM_Management_Province__c> ompList) {
|
|
System.debug('lt123ompList'+ompList);
|
|
List<String> ocsmList = new List<String>();
|
for(OCM_Management_Province__c omp : ompList){
|
ocsmList.add(omp.name);
|
}
|
|
// 待更新的OPD计划
|
Map<String, OPDPlan__c> mapUpdate = new Map<String, OPDPlan__c>();
|
// 先做发货优先
|
// 按发货日排序 不用管省份
|
String sql1 = 'Select Id, OPDPlanOCM_man_province__c, Deliver_Index__c, Bollowdate__c, Approved_Index__c, SparePartsAppDate__c From OPDPlan__c Where Bollowdate__c >= :startDate And Bollowdate__c < :endDate';
|
if (ocsmList != null && ocsmList.size() > 0) {
|
sql1 += ' And OPDPlanOCM_man_province__c in :ocsmList';
|
}
|
// if(String.isNotBlank(OCSMProvince)){
|
// sql1 += ' And OPDPlanOCM_man_province__c =: OCSMProvince Order By Bollowdate__c';
|
// }else{
|
// sql1 += ' Order By Bollowdate__c';
|
// }
|
sql1 += ' Order By Bollowdate__c';
|
List<OPDPlan__c> checkList1 = Database.query(sql1);
|
|
System.debug('lt123sql1(备品出库sql语句)'+sql1);
|
System.debug('lt123checkList1(备品出库OPD计划)'+checkList1);
|
|
// List<OPDPlan__c> checkList1 = [Select Id, OPDPlanOCM_man_province__c, Deliver_Index__c, Bollowdate__c,
|
// Approved_Index__c, SparePartsAppDate__c
|
// From OPDPlan__c
|
// Where Bollowdate__c >= :startDate And Bollowdate__c < :endDate
|
// Order By Bollowdate__c];
|
if (checkList1 != null && checkList1.size() > 0) {
|
checkList1 = setSort(checkList1, 1);
|
for (OPDPlan__c opd : checkList1) {
|
mapUpdate.put(opd.Id, opd);
|
}
|
}
|
|
// 再做审批日排序 不用管省份
|
String sql2 = 'Select Id, OPDPlanOCM_man_province__c, Deliver_Index__c, Bollowdate__c, Approved_Index__c, SparePartsAppDate__c From OPDPlan__c Where SparePartsAppDate__c >= :startDate And SparePartsAppDate__c < :endDate';
|
if (ocsmList != null && ocsmList.size() > 0) {
|
sql2 += ' And OPDPlanOCM_man_province__c in :ocsmList';
|
}
|
// if(String.isNotBlank(OCSMProvince)){
|
// sql2 += ' And OPDPlanOCM_man_province__c =: OCSMProvince Order By SparePartsAppDate__c';
|
// }else{
|
// sql2 += ' Order By SparePartsAppDate__c';
|
// }
|
sql2 += ' Order By SparePartsAppDate__c';
|
List<OPDPlan__c> checkList2 = Database.query(sql2);
|
|
System.debug('lt123sql2(备品审批sql语句)'+sql2);
|
System.debug('lt123checkList2(备品审批OPD计划)'+checkList2);
|
|
// List<OPDPlan__c> checkList2 = [Select Id, OPDPlanOCM_man_province__c, Deliver_Index__c, Bollowdate__c,
|
// Approved_Index__c, SparePartsAppDate__c
|
// From OPDPlan__c
|
// Where SparePartsAppDate__c >= :startDate And SparePartsAppDate__c < :endDate
|
// Order By SparePartsAppDate__c];
|
if (checkList2 != null && checkList2.size() > 0) {
|
checkList2 = setSort(checkList2, 2);
|
for (OPDPlan__c opd : checkList2) {
|
OPDPlan__c opdInMap = mapUpdate.get(opd.Id);
|
if (opdInMap == null) {
|
mapUpdate.put(opd.Id, opd);
|
} else {
|
opdInMap.Approved_Index__c = opd.Approved_Index__c;
|
}
|
}
|
}
|
|
if (mapUpdate.size() > 0) {
|
update mapUpdate.values();
|
}
|
}
|
|
// 写序号操作
|
private List<OPDPlan__c> setSort(List<OPDPlan__c> opdList, Integer sortType) {
|
// 初始化参数
|
// <省份, 当前序号>
|
Map<String, Integer> ProvinceSort = new Map<String, Integer>();
|
// 循环写序号
|
for (OPDPlan__c opd : opdList) {
|
// 取对应省份的当前序号
|
Integer SortNumber = ProvinceSort.get(opd.OPDPlanOCM_man_province__c);
|
// 判断省份是否已记录
|
if (SortNumber == null) {
|
SortNumber = 0;
|
}
|
// 序号加算；赋值；存入映射
|
SortNumber += 1;
|
if (sortType == 1) {
|
opd.Deliver_Index__c = SortNumber;
|
} else {
|
opd.Approved_Index__c = SortNumber;
|
}
|
ProvinceSort.put(opd.OPDPlanOCM_man_province__c, SortNumber);
|
}
|
return opdList;
|
}
|
|
global void finish(Database.BatchableContext BC) {
|
// 2022/01/04 从OPDPlanMarkBatchSchedule里挪过来的
|
// 这里以及OPDPlanMarkBatchSchedule的修改先不上线
|
// 数据确认没有问题之后，从2022/01月底的拍照开始修改
|
// Id execBTId = Database.executebatch(new OPDPlanSystemDelayBatch(), 100);
|
}
|
|
}
|
