/*
|
* HWAG-BG682M accountDailyUpdateBatch 更新询价和客户人员主担当的内容拆出来新batch
|
*/
|
|
global class OpportunityAndContactDailyUpdateBatch implements Database.Batchable<sObject>, Database.Stateful {
|
|
private String query;
|
private String salesdepartment;
|
private BatchIF_Log__c iflog;
|
|
private Integer runLimit;
|
private List<String> runTarget;
|
private String AccountList;
|
|
List<String> accList = new List<String>();
|
|
global OpportunityAndContactDailyUpdateBatch() {
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'PushNotification';
|
iflog.Is_Error__c = 0;
|
iflog.Log__c = 'OpportunityAndContactDailyUpdateBatch start1\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
}
|
global OpportunityAndContactDailyUpdateBatch(List<String> accList) {
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'PushNotification';
|
iflog.Is_Error__c = 0;
|
iflog.Log__c = 'OpportunityAndContactDailyUpdateBatch start2\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
this.accList = accList;
|
}
|
global OpportunityAndContactDailyUpdateBatch(String dePartment) {
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'PushNotification';
|
iflog.Is_Error__c = 0;
|
iflog.Log__c = 'OpportunityAndContactDailyUpdateBatch start3\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
|
salesdepartment = dePartment;
|
}
|
global OpportunityAndContactDailyUpdateBatch(Integer limitNum, String targetId1, String targetId2, String targetId3, String targetId4, String targetId5) {
|
//执行五条数据
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'PushNotification';
|
iflog.Is_Error__c = 0;
|
iflog.Log__c = 'OpportunityAndContactDailyUpdateBatch start4\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
|
runLimit = limitNum;
|
runTarget = new List<String>();
|
if (targetId1 != null && targetId1 != '') {
|
runTarget.add(targetId1);
|
}
|
if (targetId2 != null && targetId2 != '') {
|
runTarget.add(targetId2);
|
}
|
if (targetId3 != null && targetId3 != '') {
|
runTarget.add(targetId3);
|
}
|
if (targetId4 != null && targetId4 != '') {
|
runTarget.add(targetId4);
|
}
|
if (targetId5 != null && targetId5 != '') {
|
runTarget.add(targetId5);
|
}
|
system.debug(runTarget);
|
}
|
|
global Database.QueryLocator start(Database.BatchableContext BC) {
|
if (salesdepartment == null || salesdepartment == '') {
|
query = ' select Id,FSE_Main__c,GI_Main__c,SP_Main__c,GI_Product_Leader__c,GS_Product_Leader__c,GYN_Product_Leader__c,BF_owner__c, ';
|
query += 'ET_Product_Leader__c,BF_Product_Leader__c,ENT_Product_Leader__c,FSE_GI_Vice_Leader__c,FSE_SP_Vice_Leader__c,GYN_owner__c,';
|
/* SWAG-B7LADC 2018/12/19 FSE ENG start*/
|
query += 'FSE_ENG_Vice_Leader__c, FSE_ENG_Main_Leader__c, ';
|
/* SWAG-B7LADC 2018/12/19 FSE ENG end*/
|
query += 'ENT_owner_ID__c,Original_Date_Flag__c,ET_owner__c,URO_owner_ID__c ,URO_Produc_Leader__c,FSE_SP_Main_Leader__c, FSE_GI_Main_Leader__c, ParentId, OwnerId,Energy_LeaderStr__c,FSE_Extend_viceLeaderStr__c,Extend_Leader_Str__c,';
|
query += 'FSE_Main__r.IsActive ,GI_Main__r.IsActive ,URO_owner_ID__r.IsActive ,ET_owner__r.IsActive ,';
|
query += 'ENT_owner_ID__r.IsActive ,BF_owner__r.IsActive ,SP_Main__r.IsActive ,GYN_owner__r.IsActive ';
|
query += ' from Account where Is_Active__c = \'有効\' and RecordType.DeveloperName = \'HP\'';// and Id=\'0011000000V9UKl\'
|
if(accList.size()>0){
|
query += ' and Id In :accList ';
|
}
|
|
if (runTarget != null && runTarget.size() > 0) {
|
query += ' and id = :runTarget ';
|
}
|
if (runLimit != null && runLimit > 0) {
|
query += ' limit ' + runLimit;
|
}
|
} else {
|
query = ' select Id,FSE_Main__c,GI_Main__c,SP_Main__c,GI_Product_Leader__c,GS_Product_Leader__c,GYN_Product_Leader__c,BF_owner__c, ';
|
query += 'ET_Product_Leader__c,BF_Product_Leader__c,ENT_Product_Leader__c,FSE_GI_Vice_Leader__c,FSE_SP_Vice_Leader__c,GYN_owner__c,';
|
query += 'ENT_owner_ID__c,Original_Date_Flag__c,ET_owner__c,URO_owner_ID__c ,URO_Produc_Leader__c,FSE_SP_Main_Leader__c, FSE_GI_Main_Leader__c, ParentId, OwnerId,Energy_LeaderStr__c,FSE_Extend_viceLeaderStr__c,Extend_Leader_Str__c,';
|
query += 'FSE_Main__r.IsActive ,GI_Main__r.IsActive ,URO_owner_ID__r.IsActive ,ET_owner__r.IsActive ,';
|
/* SWAG-B7LADC 2018/12/19 FSE ENG start*/
|
query += 'FSE_ENG_Vice_Leader__c, FSE_ENG_Main_Leader__c, ';
|
/* SWAG-B7LADC 2018/12/19 FSE ENG end*/
|
query += 'ENT_owner_ID__r.IsActive ,BF_owner__r.IsActive ,SP_Main__r.IsActive ,GYN_owner__r.IsActive ';
|
query += ' from Account where Is_Active__c = \'有効\' and RecordType.DeveloperName = \'HP\' and '+
|
' Salesdepartment_HP__c = \'' + salesdepartment + '\'';
|
}
|
system.debug('=====query:' + query);
|
//Id=\'0011000000V9OGP\' and 测试用 给一条客户id
|
return Database.getQueryLocator(query);
|
|
}
|
|
global void execute(Database.BatchableContext BC, List<SObject> hpList){
|
List<Account> deptClassUpdateList = [select Id, RecordType.DeveloperName, Parent.Original_Date_Flag__c, ParentId, Parent.ownerId, Parent.owner.Alias__c, OwnerId from Account where Parent.Is_Active__c = '有効' and Parent.RecordType.DeveloperName = 'HP' and Hospital_Department_Class__c = :hpList order by Hospital_Department_Class__c, Account_Sort__c];
|
|
List<Account> deptUpdateList = [select Id, RecordType.DeveloperName, Parent.Parent.Original_Date_Flag__c, Parent.owner.Alias__c, Parent.ParentId, Parent.Parent.ownerId, OwnerId from Account where Parent.Parent.Is_Active__c = '有効' and Parent.Parent.RecordType.DeveloperName = 'HP' and Hospital__c = :hpList order by Hospital__c, Account_Sort__c];
|
|
AccountDailyUpdateBatch.updateFromHosToContact(deptUpdateList, iflog);
|
updateFromHosToContact(deptUpdateList, iflog);
|
//20220415 you SWAG-CBUB2W start
|
updateFromHosToInquiryForm(deptUpdateList, iflog);
|
//20220415 you SWAG-CBUB2W end
|
|
//20220509 you SWAG-CBUB2W start
|
updateFromHosToInquiryFormFSEMain(hpList, iflog);
|
//20220509 you SWAG-CBUB2W end
|
|
//20230731 you DB202306372336 start 更改战略科室所有人时，同步空更新招标项目
|
updateTenderInformationHandler(hpList, iflog);
|
//20230731 you DB202306372336 end
|
}
|
//同步所属的询价（业务机会）的所有人
|
public static void updateFromHosToContact(List<Account> deptUpdateList, BatchIF_Log__c iflog) {
|
List<Opportunity> updateOpportunityList =
|
[select id, Ownerid, Account.ownerId from Opportunity
|
where Accountid in:deptUpdateList
|
and isOwnerDiffWithAccount__c = true
|
//2023-05-18 zyh add start DB202305372478
|
AND StageName = '引合'
|
//2023-05-18 zyh add end DB202305372478
|
AND owner_not_automatically_update__c = FALSE ];
|
//20220928 you SWAG-CJP7TL start
|
system.debug('deptUpdateList==='+deptUpdateList);
|
Map<Id,String> mapoppid = new Map<Id,String>();
|
for (Opportunity opp : updateOpportunityList) {
|
if (opp.Ownerid != opp.Account.ownerId) {
|
opp.Ownerid = opp.Account.ownerId;
|
mapoppid.put(opp.id,opp.Account.ownerId);
|
}
|
}
|
List<Task__c> taskList = [
|
SELECT Id,OpportunityId__c,taskStatus__c
|
FROM task__c
|
WHERE OpportunityId__c in :mapoppid.keySet()
|
AND (RecordType.Name = '中标结果确认' OR RecordType.Name = '失单报告任务')
|
AND taskStatus__c = '02 接受'];
|
system.debug(mapoppid.keySet()+'test1-----'+taskList);
|
for(Task__c t: taskList){
|
if(mapoppid.containsKey(t.OpportunityId__c)){
|
t.Ownerid = mapoppid.get(t.OpportunityId__c);
|
t.assignee__c = mapoppid.get(t.OpportunityId__c);
|
}
|
|
}
|
|
Integer indexCon = 0;
|
Database.SaveResult[] lsrUpdateCon = Database.update(updateOpportunityList, false);
|
Database.SaveResult[] lsrUpdatetask = Database.update(taskList, false);
|
//20220928 you SWAG-CJP7TL end
|
for (Database.SaveResult lsrChild : lsrUpdateCon) {
|
if (!lsrChild.isSuccess()) {
|
iflog.Is_Error__c = 3;
|
Database.Error emsg = lsrChild.getErrors()[0];
|
iflog.ErrorLog__c += 'ownerId: ' + updateOpportunityList.get(indexCon).ownerId + ' \n'
|
+ 'OpportunityID: ' + updateOpportunityList.get(indexCon).Id + '\n ConLog:' + emsg.getMessage() + '\n';
|
|
}
|
indexCon ++ ;
|
}
|
|
}
|
//20220415 you SWAG-CBUB2W start
|
//同步所属的产品咨询单的所有人
|
public static void updateFromHosToInquiryForm(List<Account> deptUpdateList, BatchIF_Log__c iflog) {
|
List<Inquiry_form__c> updateInquiryFormList =
|
[select id, Ownerid,Depart_Owner__c,Product_Owner__c, Hospital_Name__r.ownerId from Inquiry_form__c
|
where Hospital_Name__c in:deptUpdateList
|
and isOwnerDiffWithAccount__c = true ];
|
for (Inquiry_form__c ifo : updateInquiryFormList) {
|
if (ifo.Ownerid != ifo.Hospital_Name__r.ownerId) {
|
ifo.Depart_Owner__c = ifo.Hospital_Name__r.ownerId;
|
//20221128 you DB202211530484 当勾选 转产品担当时，所有人可以手动更改，不需要同步跟科室所有人一致
|
if(ifo.Product_Owner__c == false){
|
ifo.Ownerid = ifo.Hospital_Name__r.ownerId;
|
}
|
|
}
|
}
|
Integer indexCon = 0;
|
Database.SaveResult[] lsrUpdateInq = Database.update(updateInquiryFormList, false);
|
for (Database.SaveResult lsrChild : lsrUpdateInq) {
|
if (!lsrChild.isSuccess()) {
|
iflog.Is_Error__c = 3;
|
Database.Error emsg = lsrChild.getErrors()[0];
|
iflog.ErrorLog__c += 'ownerId: ' + updateInquiryFormList.get(indexCon).ownerId + ' \n'
|
+ 'InquiryFormID: ' + updateInquiryFormList.get(indexCon).Id + '\n ConLog:' + emsg.getMessage() + '\n';
|
|
}
|
indexCon ++ ;
|
}
|
|
}
|
|
//20220415 you SWAG-CBUB2W end
|
//20220509 you SWAG-CBUB2W start
|
//FSE主担当变化
|
public static void updateFromHosToInquiryFormFSEMain(List<SObject> hpList, BatchIF_Log__c iflog) {
|
List<Inquiry_form__c> updateInquiryFormFSEList =
|
[select id, Ownerid,Hospital_Name__c,Hospital_Name__r.Name, Hospital_Name__r.ownerId,FSE_Owner__c,
|
Hospital_Name__r.Parent.Parent.FSE_GI_Main_Leader__c,Hospital_Name__r.Parent.Parent.FSE_SP_Main_Leader__c from Inquiry_form__c
|
where Hospital__c in:hpList
|
and isFSEDiffWithAccount__c = true ];
|
for (Inquiry_form__c ifo : updateInquiryFormFSEList) {
|
if (String.isNotBlank(ifo.Hospital_Name__r.Name) && (ifo.Hospital_Name__r.Name.contains('消化') || ifo.Hospital_Name__r.Name.contains('呼吸') || ifo.Hospital_Name__r.Name.contains('ET')) && ifo.FSE_Owner__c != ifo.Hospital_Name__r.Parent.Parent.FSE_GI_Main_Leader__c) {
|
ifo.FSE_Owner__c = ifo.Hospital_Name__r.Parent.Parent.FSE_GI_Main_Leader__c;
|
|
}
|
if(String.isNotBlank(ifo.Hospital_Name__r.Name) && !ifo.Hospital_Name__r.Name.contains('消化') && !ifo.Hospital_Name__r.Name.contains('呼吸') && !ifo.Hospital_Name__r.Name.contains('ET') && ifo.FSE_Owner__c != ifo.Hospital_Name__r.Parent.Parent.FSE_SP_Main_Leader__c){
|
ifo.FSE_Owner__c = ifo.Hospital_Name__r.Parent.Parent.FSE_SP_Main_Leader__c;
|
}
|
}
|
Integer indexCon = 0;
|
Database.SaveResult[] lsrUpdateInq = Database.update(updateInquiryFormFSEList, false);
|
for (Database.SaveResult lsrChild : lsrUpdateInq) {
|
if (!lsrChild.isSuccess()) {
|
iflog.Is_Error__c = 3;
|
Database.Error emsg = lsrChild.getErrors()[0];
|
iflog.ErrorLog__c += 'ownerId: ' + updateInquiryFormFSEList.get(indexCon).ownerId + ' \n'
|
+ 'InquiryFormID: ' + updateInquiryFormFSEList.get(indexCon).Id + '\n ConLog:' + emsg.getMessage() + '\n';
|
|
}
|
indexCon ++ ;
|
}
|
|
}
|
//20220509 you SWAG-CBUB2W end
|
//20230731 you DB202306372336 start
|
public static void updateTenderInformationHandler(List<SObject> hpList, BatchIF_Log__c iflog) {
|
List<Tender_information__c> UpdateTenderList = new List<Tender_information__c>();
|
String query = 'SELECT Id,IsReactionOpp__c,Hospital__c,Hospital1__c,Hospital2__c,Hospital3__c,Hospital4__c, ';
|
query += 'Hospital__r.Assume_Change__c,Hospital1__r.Assume_Change__c,Hospital2__r.Assume_Change__c,Hospital3__r.Assume_Change__c,Hospital4__r.Assume_Change__c ';
|
query += ', CreatedDate ';
|
query += 'FROM Tender_information__c ';
|
query += 'where (Hospital__r.Assume_Change__c = true ';
|
query += 'OR Hospital1__r.Assume_Change__c = true OR Hospital2__r.Assume_Change__c = true ';
|
query += 'OR Hospital3__r.Assume_Change__c = true OR Hospital4__r.Assume_Change__c = true)';
|
query += 'OR (Hospital__c In :hpList or Hospital1__c In :hpList or Hospital2__c In :hpList or Hospital3__c In :hpList or Hospital4__c In :hpList)';
|
system.debug('招标项目'+query);
|
UpdateTenderList = Database.query(query);
|
//符合条件直接空更新招标项目
|
Integer indexCon = 0;
|
if(UpdateTenderList.size()>0){
|
List<Tender_information__c> onlyEmptyUpdates = new List<Tender_information__c>();
|
List<Tender_information__c> emptyUpdateWithMainIds = new List<Tender_information__c>();
|
|
Date startingtime = Date.newInstance(2023,09,11);
|
// Date Createdate1 =
|
for (Tender_information__c t : UpdateTenderList) {
|
if (Date.valueOf(t.CreatedDate) >= startingtime) {
|
emptyUpdateWithMainIds.add(t);
|
} else {
|
onlyEmptyUpdates.add(t);
|
}
|
}
|
Database.SaveResult[] EmptySaveTenderResult;
|
if (emptyUpdateWithMainIds.size() > 0) {
|
StaticParameter.EscapeTenderInformationUpdate =false;
|
EmptySaveTenderResult = Database.update(emptyUpdateWithMainIds,false);
|
StaticParameter.EscapeTenderInformationUpdate =true;
|
|
for (Database.SaveResult lsrChild : EmptySaveTenderResult) {
|
if (!lsrChild.isSuccess()) {
|
iflog.Is_Error__c = 3;
|
Database.Error emsg = lsrChild.getErrors()[0];
|
iflog.ErrorLog__c += 'ownerId: ' + emptyUpdateWithMainIds.get(indexCon).ownerId + ' \n'
|
+ 'TenderInformationID: ' + emptyUpdateWithMainIds.get(indexCon).Id + '\n ConLog:' + emsg.getMessage() + '\n';
|
|
}
|
indexCon ++ ;
|
}
|
}
|
|
indexCon = 0;
|
if (onlyEmptyUpdates.size() > 0) {
|
EmptySaveTenderResult = Database.update(onlyEmptyUpdates,false);
|
|
for (Database.SaveResult lsrChild : EmptySaveTenderResult) {
|
if (!lsrChild.isSuccess()) {
|
iflog.Is_Error__c = 3;
|
Database.Error emsg = lsrChild.getErrors()[0];
|
iflog.ErrorLog__c += 'ownerId: ' + onlyEmptyUpdates.get(indexCon).ownerId + ' \n'
|
+ 'TenderInformationID: ' + onlyEmptyUpdates.get(indexCon).Id + '\n ConLog:' + emsg.getMessage() + '\n';
|
|
}
|
indexCon ++ ;
|
}
|
}
|
|
}
|
}
|
//20230731 you DB202306372336 end
|
global void finish(Database.BatchableContext BC) {
|
system.debug('=====iflog:' + iflog.id);
|
iflog.Log__c += 'OpportunityAndContactDailyUpdateBatch finish()\n';
|
iflog.Log__c += '\nOpportunityAndContactDailyUpdateBatch end';
|
|
String tmp = iflog.ErrorLog__c;
|
if (tmp.length() > 65000) {
|
tmp = tmp.substring(0, 65000);
|
tmp += ' ...have more lines...';
|
iflog.ErrorLog__c = tmp;
|
}
|
String tmp2 = iflog.Log__c;
|
if (tmp2.length() > 65000) {
|
tmp2 = tmp2.substring(0, 65000);
|
tmp2 += ' ...have more lines...';
|
iflog.Log__c = tmp2;
|
}
|
if (System.Label.Log_IO_Flag == 'Keep') {
|
update iflog;
|
} else if (System.Label.Log_IO_Flag == 'Auto') {
|
if (iflog.Is_Error__c > 0) {
|
update iflog;
|
}
|
}
|
//add by rentx 2020-12-29
|
if (String.isNotBlank(salesdepartment) && salesdepartment.equals('1.华北')) {
|
Database.executeBatch(new ConsumablesApplyOrLendBatch(), 50);
|
}
|
//add by rentx 2020-12-29
|
|
//20200819 ljh add start
|
//Database.executeBatch(new ConsumablesApplyOrLendBatch(), 50);
|
//20200819 ljh add end
|
}
|
|
@TestVisible private static void test() {
|
Integer i = 0;
|
i++;
|
i++;
|
i++;
|
// i++;
|
// i++;
|
}
|
}
|
